|
|
@@ -0,0 +1,493 @@
|
|
|
+package com.jeeplus.modules.workinvoice.service.OMS;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.jeeplus.common.utils.JedisUtils;
|
|
|
+import com.jeeplus.common.utils.StringUtils;
|
|
|
+import com.jeeplus.modules.workinvoice.entity.OMS.OMSAccessTokenInfo;
|
|
|
+import com.jeeplus.modules.workinvoice.utils.HttpPostJsonUtil;
|
|
|
+import com.jeeplus.modules.workinvoice.utils.OMSNationUtil;
|
|
|
+import org.springframework.context.annotation.Lazy;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
+import redis.clients.jedis.Jedis;
|
|
|
+
|
|
|
+import java.util.Map;
|
|
|
+import java.util.UUID;
|
|
|
+
|
|
|
+@Service
|
|
|
+@Transactional(readOnly = true)
|
|
|
+@Lazy
|
|
|
+public class OMSDisposeService {
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 给accessToken查询的有效时间设置为1天
|
|
|
+ */
|
|
|
+ private final int seconds = 86400;
|
|
|
+ private final String appId = "hyc1";
|
|
|
+ private final String appKey = "hyc1";
|
|
|
+ private final String deptCode = "500102204228315131";
|
|
|
+ //如果接口访问不正确,可以循环访问的次数
|
|
|
+ private final int remainRetryTimes = 20;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 用于生成开蓝票信息
|
|
|
+ * @param map
|
|
|
+ * @param workInvoiceId
|
|
|
+ */
|
|
|
+ public void doInvoiceBusiness(Map<String,Object> map, String workInvoiceId) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String accessToken = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ accessToken = jedis.get("OMSAccessToken");
|
|
|
+ if(StringUtils.isBlank(accessToken)){
|
|
|
+ // 获取AccessToken 9998重试5次
|
|
|
+ accessToken = getOmsAccessTokenWithRetry(5, "accessToken");
|
|
|
+ if(StringUtils.isNotBlank(accessToken)){
|
|
|
+ jedis.setex("OMSAccessToken", seconds, accessToken);
|
|
|
+ map.put("token状态", "重新获取token成功,存入Redis");
|
|
|
+ } else {
|
|
|
+ accessToken = "";
|
|
|
+ map.put("token状态", "获取token失败");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ map.put("token状态", "从Redis获取token成功");
|
|
|
+ }
|
|
|
+
|
|
|
+ OMSNationUtil util = new OMSNationUtil();
|
|
|
+ //生成开票基础信息
|
|
|
+ String string = util.neatenData(workInvoiceId);
|
|
|
+
|
|
|
+ OMSAccessTokenInfo InvoiceTokenInfo = new OMSAccessTokenInfo();
|
|
|
+ InvoiceTokenInfo.setAppId(appId);
|
|
|
+ InvoiceTokenInfo.setAppKey(appKey);
|
|
|
+ InvoiceTokenInfo.setExchangeId(UUID.randomUUID().toString());
|
|
|
+ InvoiceTokenInfo.setAccessToken(accessToken);
|
|
|
+ InvoiceTokenInfo.setData(string);
|
|
|
+ String jsonInvoiceStr = JSON.toJSONString(InvoiceTokenInfo);
|
|
|
+
|
|
|
+ String jsonInvoicResultStr = HttpPostJsonUtil.doPost("https://oms-sandbox.einvoice.js.cn:7079/prod-api/output/server/order/upload", jsonInvoiceStr);
|
|
|
+ System.out.println("✅ 订单提交接口返回值:" + jsonInvoicResultStr);
|
|
|
+ map.put("订单接口信息", jsonInvoicResultStr);
|
|
|
+
|
|
|
+ // 调用订单上传重试方法(包含所有码值规则)
|
|
|
+ if(StringUtils.isNotBlank(jsonInvoicResultStr)){
|
|
|
+ String finalAccessToken = accessToken;
|
|
|
+ String finalJsonInvoiceStr = jsonInvoiceStr;
|
|
|
+ executeOrderUploadRetry(remainRetryTimes, jsonInvoicResultStr, finalJsonInvoiceStr, finalAccessToken, workInvoiceId, map,"accessToken", "blueTicket");
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ map.put("errorMsg", "系统异常:" + e.getMessage());
|
|
|
+ } finally {
|
|
|
+ if(jedis != null){
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 用于调用accessToken
|
|
|
+ * @param remainRetryTimes
|
|
|
+ * @param getKey
|
|
|
+ * @return
|
|
|
+ */
|
|
|
+ public String getOmsAccessTokenWithRetry(int remainRetryTimes, String getKey) {
|
|
|
+ try {
|
|
|
+ OMSAccessTokenInfo tokenInfo = new OMSAccessTokenInfo();
|
|
|
+ tokenInfo.setAppId(appId);
|
|
|
+ tokenInfo.setAppKey(appKey);
|
|
|
+ tokenInfo.setExchangeId(UUID.randomUUID().toString());
|
|
|
+ String jsonStr = JSON.toJSONString(tokenInfo);
|
|
|
+ String accessTokenStr = HttpPostJsonUtil.doPost("https://oms-sandbox.einvoice.js.cn:7079/prod-api/server/accessToken", jsonStr);
|
|
|
+
|
|
|
+ if(StringUtils.isBlank(accessTokenStr)){
|
|
|
+ System.err.println("获取AccessToken失败:接口返回空,剩余重试次数:"+remainRetryTimes);
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+
|
|
|
+ OMSAccessTokenInfo resultTokenInfo = JSON.parseObject(accessTokenStr, OMSAccessTokenInfo.class);
|
|
|
+ if(null == resultTokenInfo || null == resultTokenInfo.getResult()){
|
|
|
+ System.err.println("获取AccessToken失败:返回结果解析异常,剩余重试次数:"+remainRetryTimes);
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+
|
|
|
+ String code = resultTokenInfo.getResult().getCode();
|
|
|
+ if ("0000".equals(code)) {
|
|
|
+ String token = OMSNationUtil.extractAccessTokenFromBase64(getKey, resultTokenInfo.getData().toString());
|
|
|
+ System.out.println("✅ 获取AccessToken成功,重试次数剩余:"+remainRetryTimes);
|
|
|
+ return token;
|
|
|
+ } else if ("9998".equals(code)) {
|
|
|
+ if (remainRetryTimes > 1) {
|
|
|
+ int nextRetry = remainRetryTimes - 1;
|
|
|
+ System.err.println("⚠️ 获取AccessToken返回9998接口波动,30秒后重试,剩余次数:"+nextRetry);
|
|
|
+ Thread.sleep(30 * 1000);
|
|
|
+ return getOmsAccessTokenWithRetry(nextRetry,getKey);
|
|
|
+ } else {
|
|
|
+ System.err.println("❌ 获取AccessToken失败:连续5次返回9998,重试次数耗尽!");
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ System.err.println("❌ 获取AccessToken失败:返回业务错误码,code="+code);
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ System.err.println("❌ 获取AccessToken失败:重试延迟被中断");
|
|
|
+ Thread.currentThread().interrupt();
|
|
|
+ return "";
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ System.err.println("❌ 获取AccessToken失败:调用接口异常,剩余重试次数:"+remainRetryTimes);
|
|
|
+ return "";
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 对方法进行发起并进行处理
|
|
|
+ * @param remainRetryTimes
|
|
|
+ * @param jsonInvoicResultStr
|
|
|
+ * @param jsonInvoiceStr
|
|
|
+ * @param accessToken
|
|
|
+ * @param orderno
|
|
|
+ * @param map
|
|
|
+ * @param getKey
|
|
|
+ * @param initiationType 用来判定是什么类型的,比如蓝票、全类型红票、还是快捷红票
|
|
|
+ */
|
|
|
+ public void executeOrderUploadRetry(int remainRetryTimes, String jsonInvoicResultStr, String jsonInvoiceStr, String accessToken, String orderno, Map<String,Object> map, String getKey, String initiationType) {
|
|
|
+ String jsonInvoicResult = "";
|
|
|
+ try {
|
|
|
+ OMSAccessTokenInfo resultTokenInfo = JSON.parseObject(jsonInvoicResultStr, OMSAccessTokenInfo.class);
|
|
|
+ if(null == resultTokenInfo || null == resultTokenInfo.getResult()){
|
|
|
+ System.err.println("❌ 订单上传解析失败,剩余重试次数:"+remainRetryTimes);
|
|
|
+ handleInvoiceRetryAllFail(accessToken); // 解析失败也执行兜底方法
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ String code = resultTokenInfo.getResult().getCode();
|
|
|
+ String message = resultTokenInfo.getResult().getMessage();
|
|
|
+
|
|
|
+ // ======================== 所有码值规则 全部在这里【最终定稿】=========================
|
|
|
+ if ("0000".equals(code)) {
|
|
|
+ // ✅ 0000 成功:解析数据+存入map+触发30秒后异步下载发票
|
|
|
+ jsonInvoicResult = OMSNationUtil.extractAccessTokenFromBase64(getKey, resultTokenInfo.getData().toString());
|
|
|
+ map.put("订单接口返回值",jsonInvoicResult);
|
|
|
+ System.out.println("✅ 订单上传返回0000成功,触发发票下载接口");
|
|
|
+ if(StringUtils.isNotBlank(jsonInvoicResult)){
|
|
|
+ if(initiationType.equals("fastRed")){
|
|
|
+ orderno = jsonInvoicResult;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ String finalOrderno = orderno;
|
|
|
+ // 存入Redis,由InvoiceDownloadTask接管
|
|
|
+ saveInvoiceDownloadTaskToRedis(accessToken, finalOrderno);
|
|
|
+ System.out.println("✅ 解析开票数据任务["+finalOrderno+"]已存入Redis,由InvoiceDownloadTask接管重试");
|
|
|
+
|
|
|
+ } else if ("9998".equals(code)) {
|
|
|
+ // 通过redis调用 方式系统崩溃导致的数据丢失
|
|
|
+ // ✅ 9998 接口波动,放入redis中 用于定时任务进行处理
|
|
|
+ saveInvoiceRetryScheduledTaskToRedis(jsonInvoiceStr, accessToken, orderno, getKey, initiationType);
|
|
|
+
|
|
|
+ } else if ("0003".equals(code)) {
|
|
|
+ // ✅ 0003 token失效:清除旧token → 重新获取token → 从头完整执行所有流程
|
|
|
+ System.err.println("⚠️ 订单上传返回0003(token失效),开始重新获取token并从头执行流程");
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ jedis.del("OMSAccessToken");
|
|
|
+ map.put("0003处理", "已清除旧token,准备重新获取");
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ if(jedis != null) jedis.close();
|
|
|
+ }
|
|
|
+ doInvoiceBusiness(map, orderno);
|
|
|
+ } else {
|
|
|
+ // ✅ ✅ ✅ 核心修正:0001/0002/其他任意错误码 → 直接调用handleInvoiceRetryAllFail执行修改系统信息逻辑 ✅ ✅ ✅
|
|
|
+ System.err.println("❌ 订单上传返回业务错误码:"+code+"(0001/0002等),立即执行失败兜底逻辑修改系统信息!");
|
|
|
+ System.err.println("❌ 订单上传返回业务错误原因:"+message);
|
|
|
+ map.put("订单状态", "失败,错误码:"+code);
|
|
|
+ handleInvoiceRetryAllFail(accessToken); // 关键:直接执行你的修改逻辑,不抛异常、不重试
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ System.err.println("❌ 订单上传重试异常,剩余次数:"+remainRetryTimes);
|
|
|
+ handleInvoiceRetryAllFail(accessToken); // 异常也执行兜底方法
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 用于访问接口返回9998时使用,存入Redis供定时任务处理
|
|
|
+ * 硬编码配置:初始重试次数20次,Redis过期时间1天(86400秒)
|
|
|
+ * @param jsonInvoiceStr 订单上传的JSON参数
|
|
|
+ * @param accessToken AccessToken
|
|
|
+ * @param orderno 订单号
|
|
|
+ * @param getKey 获取token的key
|
|
|
+ * @param initiationType 开票类型(蓝票/红票)
|
|
|
+ */
|
|
|
+ public void saveInvoiceRetryScheduledTaskToRedis(String jsonInvoiceStr ,String accessToken, String orderno, String getKey, String initiationType) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ // 硬编码:初始重试次数20次
|
|
|
+ final int INIT_RETRY_COUNT = 20;
|
|
|
+ // 硬编码:Redis任务过期时间1天(86400秒)
|
|
|
+ final int REDIS_EXPIRE_SECONDS = 86400;
|
|
|
+
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ String redisKey = "OMS_invoice_retry_scheduled:" + orderno;
|
|
|
+
|
|
|
+ // 先检查是否已存在,存在则复用原有重试次数,不存在则初始化20次
|
|
|
+ String retryTimes = jedis.hget(redisKey, "retryTimes");
|
|
|
+ if (StringUtils.isBlank(retryTimes)) {
|
|
|
+ retryTimes = String.valueOf(INIT_RETRY_COUNT); // 初始20次
|
|
|
+ }
|
|
|
+
|
|
|
+ // 存储所有需要的字段
|
|
|
+ jedis.hset(redisKey, "jsonInvoiceStr", jsonInvoiceStr);
|
|
|
+ jedis.hset(redisKey, "accessToken", accessToken);
|
|
|
+ jedis.hset(redisKey, "orderno", orderno);
|
|
|
+ jedis.hset(redisKey, "getKey", getKey);
|
|
|
+ jedis.hset(redisKey, "initiationType", initiationType);
|
|
|
+ jedis.hset(redisKey, "firstExecTime", String.valueOf(System.currentTimeMillis()));
|
|
|
+ jedis.hset(redisKey, "retryTimes", retryTimes); // 重试次数
|
|
|
+
|
|
|
+ jedis.expire(redisKey, REDIS_EXPIRE_SECONDS); // 1天过期
|
|
|
+ System.out.println("✅ 9998重试任务已存入Redis,订单号:" + orderno + ",剩余重试次数:" + retryTimes);
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ System.err.println("❌ 存入9998重试任务到Redis失败,订单号:" + orderno + ",原因:" + e.getMessage());
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 新增开蓝票生成的下载用的redis
|
|
|
+ * @param accessToken
|
|
|
+ * @param orderno
|
|
|
+ */
|
|
|
+ public void saveInvoiceDownloadTaskToRedis(String accessToken, String orderno) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ String redisKey = "OMS_invoice_download:" + orderno;
|
|
|
+ jedis.hset(redisKey, "accessToken", accessToken);
|
|
|
+ jedis.hset(redisKey, "orderno", orderno);
|
|
|
+ jedis.hset(redisKey, "firstExecTime", String.valueOf(System.currentTimeMillis()));
|
|
|
+ jedis.expire(redisKey, seconds); // 1天过期
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 兜底方法
|
|
|
+ * @param accessToken
|
|
|
+ */
|
|
|
+ public void handleInvoiceRetryAllFail(String accessToken) {
|
|
|
+ // ============ 你的所有【修改系统信息/更新订单状态/写失败日志】逻辑 全部写在这里!!! ============
|
|
|
+ try {
|
|
|
+ System.err.println("============ 开始执行【失败兜底-系统信息修改逻辑】 ============");
|
|
|
+
|
|
|
+ // 示例1:更新订单表的发票状态为【开票失败】
|
|
|
+ // orderService.updateInvoiceStatusByToken(accessToken, "99");
|
|
|
+
|
|
|
+ // 示例2:写入失败日志到数据库,方便人工排查和补偿处理
|
|
|
+ // invoiceFailLogService.saveFailLog(accessToken, "开票失败,错误码非0000/9998/0003", new Date());
|
|
|
+
|
|
|
+ // 示例3:标记该单据为异常,方便后台运维查看
|
|
|
+ // abnormalOrderService.saveAbnormalOrder(accessToken, "开票失败");
|
|
|
+
|
|
|
+ // 示例4:调用其他系统接口,同步失败状态
|
|
|
+ // otherSystemApi.notifyInvoiceFail(accessToken);
|
|
|
+
|
|
|
+ System.err.println("============ 【失败兜底-系统信息修改逻辑】执行完成 ============");
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ // 必加:捕获这个方法的异常,避免兜底方法报错导致线程异常
|
|
|
+ e.printStackTrace();
|
|
|
+ System.err.println("❌ 执行失败兜底方法时抛出异常:" + e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 快速开红票的调用方法
|
|
|
+ * @param map
|
|
|
+ * @param allEinvno
|
|
|
+ */
|
|
|
+ public void doFastRedInvoiceBusiness(Map<String,Object> map, String allEinvno) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ String accessToken = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ accessToken = jedis.get("OMSAccessToken");
|
|
|
+ if(StringUtils.isBlank(accessToken)){
|
|
|
+ // 获取AccessToken 9998重试5次
|
|
|
+ accessToken = getOmsAccessTokenWithRetry(5, "accessToken");
|
|
|
+ if(StringUtils.isNotBlank(accessToken)){
|
|
|
+ jedis.setex("OMSAccessToken", seconds, accessToken);
|
|
|
+ map.put("token状态", "重新获取token成功,存入Redis");
|
|
|
+ } else {
|
|
|
+ accessToken = "";
|
|
|
+ map.put("token状态", "获取token失败");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ map.put("token状态", "从Redis获取token成功");
|
|
|
+ }
|
|
|
+
|
|
|
+ OMSNationUtil util = new OMSNationUtil();
|
|
|
+ String string = util.neatenFastRedInvoiceData(allEinvno);
|
|
|
+
|
|
|
+ OMSAccessTokenInfo InvoiceTokenInfo = new OMSAccessTokenInfo();
|
|
|
+ InvoiceTokenInfo.setAppId(appId);
|
|
|
+ InvoiceTokenInfo.setAppKey(appKey);
|
|
|
+ InvoiceTokenInfo.setExchangeId(UUID.randomUUID().toString());
|
|
|
+ InvoiceTokenInfo.setAccessToken(accessToken);
|
|
|
+ InvoiceTokenInfo.setData(string);
|
|
|
+ String jsonInvoiceStr = JSON.toJSONString(InvoiceTokenInfo);
|
|
|
+
|
|
|
+ String jsonInvoicResultStr = HttpPostJsonUtil.doPost("https://oms-sandbox.einvoice.js.cn:7079/prod-api/output/server/invoice/makeredinv", jsonInvoiceStr);
|
|
|
+ System.out.println("✅ 快速红冲订单提交接口返回值:" + jsonInvoicResultStr);
|
|
|
+ map.put("快速红冲订单接口信息", jsonInvoicResultStr);
|
|
|
+
|
|
|
+ // 调用订单上传重试方法(包含所有码值规则)
|
|
|
+ if(StringUtils.isNotBlank(jsonInvoicResultStr)){
|
|
|
+ String finalAccessToken = accessToken;
|
|
|
+ String finalJsonInvoiceStr = jsonInvoiceStr;
|
|
|
+ executeOrderUploadRetry(5, jsonInvoicResultStr, finalJsonInvoiceStr, finalAccessToken, allEinvno, map, "orderno", "fastRed");
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ map.put("errorMsg", "系统异常:" + e.getMessage());
|
|
|
+ } finally {
|
|
|
+ if(jedis != null){
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 调用生成红字确认申请单
|
|
|
+ * @param map
|
|
|
+ * @param applyNo
|
|
|
+ * @param originalInvno
|
|
|
+ */
|
|
|
+ public void doAllScenarioRedInvoiceBusiness(Map<String,Object> map, String applyNo, String originalInvno) {
|
|
|
+ int seconds = 86400;
|
|
|
+ Jedis jedis = null;
|
|
|
+ String accessToken = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ accessToken = jedis.get("OMSAccessToken");
|
|
|
+ if(StringUtils.isBlank(accessToken)){
|
|
|
+ // 获取AccessToken 9998重试5次
|
|
|
+ accessToken = getOmsAccessTokenWithRetry(5, "accessToken");
|
|
|
+ if(StringUtils.isNotBlank(accessToken)){
|
|
|
+ jedis.setex("OMSAccessToken", seconds, accessToken);
|
|
|
+ map.put("token状态", "重新获取token成功,存入Redis");
|
|
|
+ } else {
|
|
|
+ accessToken = "";
|
|
|
+ map.put("token状态", "获取token失败");
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ map.put("token状态", "从Redis获取token成功");
|
|
|
+ }
|
|
|
+
|
|
|
+ OMSNationUtil util = new OMSNationUtil();
|
|
|
+ //生成红冲的数据
|
|
|
+ String string = util.neatenAllScenarioRedInvoiceData(applyNo, originalInvno);
|
|
|
+
|
|
|
+ OMSAccessTokenInfo InvoiceTokenInfo = new OMSAccessTokenInfo();
|
|
|
+ InvoiceTokenInfo.setAppId(appId);
|
|
|
+ InvoiceTokenInfo.setAppKey(appKey);
|
|
|
+ InvoiceTokenInfo.setExchangeId(UUID.randomUUID().toString());
|
|
|
+ InvoiceTokenInfo.setAccessToken(accessToken);
|
|
|
+ InvoiceTokenInfo.setData(string);
|
|
|
+ String jsonInvoiceStr = JSON.toJSONString(InvoiceTokenInfo);
|
|
|
+
|
|
|
+ String jsonInvoicResultStr = HttpPostJsonUtil.doPost("https://oms-sandbox.einvoice.js.cn:7079/prod-api/output/server/redApply/apply", jsonInvoiceStr);
|
|
|
+ System.out.println("✅ 全场景红冲订单提交接口返回值:" + jsonInvoicResultStr);
|
|
|
+ map.put("全场景红冲订单接口信息", jsonInvoicResultStr);
|
|
|
+
|
|
|
+ // 调用订单上传重试方法(包含所有码值规则)
|
|
|
+ if(StringUtils.isNotBlank(jsonInvoicResultStr)){
|
|
|
+ String finalAccessToken = accessToken;
|
|
|
+ queryRedInvoiceConfirm (5, jsonInvoicResultStr, finalAccessToken, applyNo);
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ map.put("errorMsg", "系统异常:" + e.getMessage());
|
|
|
+ } finally {
|
|
|
+ if(jedis != null){
|
|
|
+ jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 全类型红冲--红字确认单查询接口(仅存Redis,不执行业务)
|
|
|
+ * @param remainRetryTimes 剩余重试次数
|
|
|
+ * @param jsonInvoicResultStr 需要解析的返回值密文
|
|
|
+ * @param accessToken accessToken
|
|
|
+ * @param applyNo
|
|
|
+ */
|
|
|
+ public void queryRedInvoiceConfirm (int remainRetryTimes, String jsonInvoicResultStr, String accessToken, String applyNo) {
|
|
|
+ try {
|
|
|
+ OMSAccessTokenInfo resultTokenInfo = JSON.parseObject(jsonInvoicResultStr, OMSAccessTokenInfo.class);
|
|
|
+ if(null == resultTokenInfo || null == resultTokenInfo.getResult()){
|
|
|
+ System.err.println("❌ 全场景红冲订单提交接口返回值解析失败,剩余重试次数:"+remainRetryTimes);
|
|
|
+ handleInvoiceRetryAllFail(accessToken); // 解析失败直接兜底
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ String code = resultTokenInfo.getResult().getCode();
|
|
|
+
|
|
|
+ if ("0000".equals(code)) {
|
|
|
+ // 仅存入Redis,删除所有业务执行逻辑
|
|
|
+ saveRedInvoiceTaskToRedis(remainRetryTimes, jsonInvoicResultStr, accessToken, applyNo, System.currentTimeMillis());
|
|
|
+ System.out.println("✅ 红冲任务["+applyNo+"]已存入Redis,由定时任务接管执行");
|
|
|
+ } else {
|
|
|
+ String message = resultTokenInfo.getResult().getMessage();
|
|
|
+ System.err.println("❌ 订单上传返回业务错误码:"+code+",触发兜底逻辑!");
|
|
|
+ handleInvoiceRetryAllFail(accessToken);
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ handleInvoiceRetryAllFail(accessToken);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 存储红冲任务到Redis(供原有业务代码调用,参数完整)
|
|
|
+ */
|
|
|
+ public void saveRedInvoiceTaskToRedis(int remainRetryTimes, String jsonInvoicResultStr, String accessToken, String applyNo, long startTime) {
|
|
|
+ Jedis jedis = null;
|
|
|
+ try {
|
|
|
+ jedis = JedisUtils.getResource();
|
|
|
+ String redisKey = "OMS_red_invoice_task:" + applyNo;
|
|
|
+ // 存储所有执行所需的参数(确保定时任务能独立执行)
|
|
|
+ jedis.hset(redisKey, "remainRetryTimes", String.valueOf(remainRetryTimes));
|
|
|
+ jedis.hset(redisKey, "jsonInvoicResultStr", jsonInvoicResultStr);
|
|
|
+ jedis.hset(redisKey, "accessToken", accessToken);
|
|
|
+ jedis.hset(redisKey, "applyNo", applyNo);
|
|
|
+ jedis.hset(redisKey, "startTime", String.valueOf(startTime));
|
|
|
+ jedis.expire(redisKey, 259200 + 3600); // 3天+1小时过期
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ handleInvoiceRetryAllFail(accessToken);
|
|
|
+ } finally {
|
|
|
+ if (jedis != null) jedis.close();
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+}
|