开票-评估、会计开票失败发送通知后删除redis任务数据

jeeplus-modules/jeeplus-assess/src/main/java/com/jeeplus/assess/invoice/service/OMS/InvoiceDownloadService.java

@@ -183,6 +183,8 @@ public class InvoiceDownloadService {
                         || "0008".equals(resultDownInfo.getResult().getCode())
                 )){
                     omsDisposeService.handleInvoiceRetryAllFail(accessToken, workInvoiceId, "发票信息获取失败，失败原因：" + resultDownInfo.getResult().getMessage(), informType);
+                    //删除redis中的数据，防止重复操作
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId); // 成功删除Redis，保证数据一致
                 }
             }
 

jeeplus-modules/jeeplus-assess/src/main/java/com/jeeplus/assess/invoice/service/OMS/OMSDisposeService.java

@@ -525,7 +525,6 @@ public class OMSDisposeService {
                 if (!"12".equals(workInvoice.getStatus())) {
                     //通知发起人或者开票管理员
                     workInvoiceService.handleInvoiceRetryAllFail(workInvoice, errorMessage, informType);
-                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId);
                 }
             }
             System.err.println("============ 【失败兜底-系统信息修改逻辑】执行完成 ============");

jeeplus-modules/jeeplus-assess/src/main/java/com/jeeplus/assess/invoice/service/OMS/RedInvoiceDownloadService.java

@@ -184,6 +184,8 @@ public class RedInvoiceDownloadService {
                         || "0008".equals(resultDownInfo.getResult().getCode())
                 )){
                     omsDisposeService.handleInvoiceRetryAllFail(accessToken, workInvoiceId, "发票信息获取失败，失败原因：" + resultDownInfo.getResult().getMessage(), informType);
+                    //删除redis中的数据，防止重复操作
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId); // 成功删除Redis，保证数据一致
                 }
             }
 

jeeplus-modules/jeeplus-finance/src/main/java/com/jeeplus/finance/invoice/service/OMS/InvoiceDownloadService.java

@@ -197,6 +197,8 @@ public class InvoiceDownloadService {
                         || "0008".equals(resultDownInfo.getResult().getCode())
                 )){
                     omsDisposeService.handleInvoiceRetryAllFail(accessToken, workInvoiceId, "发票信息获取失败，失败原因：" + resultDownInfo.getResult().getMessage(), informType);
+                    //删除redis中的数据，防止重复操作
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId); // 成功删除Redis，保证数据一致
                 }
             }
 

jeeplus-modules/jeeplus-finance/src/main/java/com/jeeplus/finance/invoice/service/OMS/OMSDisposeService.java

@@ -538,7 +538,6 @@ public class OMSDisposeService {
                 if (!"12".equals(workInvoice.getStatus())) {
                     //通知发起人或者开票管理员
                     workInvoiceService.handleInvoiceRetryAllFail(workInvoice, errorMessage, informType);
-                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId);
                 }
             }
             System.err.println("============ 【失败兜底-系统信息修改逻辑】执行完成 ============");

jeeplus-modules/jeeplus-finance/src/main/java/com/jeeplus/finance/invoice/service/OMS/RedInvoiceDownloadService.java

@@ -197,6 +197,8 @@ public class RedInvoiceDownloadService {
                         || "0008".equals(resultDownInfo.getResult().getCode())
                 )){
                     omsDisposeService.handleInvoiceRetryAllFail(accessToken, workInvoiceId, "发票信息获取失败，失败原因：" + resultDownInfo.getResult().getMessage(), informType);
+                    //删除redis中的数据，防止重复操作
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId); // 成功删除Redis，保证数据一致
                 }
             }