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

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

@@ -525,6 +525,7 @@ public class OMSDisposeService {
                 if (!"12".equals(workInvoice.getStatus())) {
                     //通知发起人或者开票管理员
                     workInvoiceService.handleInvoiceRetryAllFail(workInvoice, errorMessage, informType);
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId);
                 }
             }
             System.err.println("============ 【失败兜底-系统信息修改逻辑】执行完成 ============");
@@ -810,5 +811,19 @@ public class OMSDisposeService {
         }
     }
 
+    // ========== 辅助方法：删除Redis解析任务 ==========
+    private void deleteInvoiceDownloadTaskFromRedis(String orderno) {
+        RedisUtils jedis = null;
+        try {
+            jedis = RedisUtils.getInstance();
+            jedis.delete("PG_OMS_invoice_download:" + orderno);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (jedis != null) {
+                //jedis.close();
+            }
+        }
+    }
 
 }

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

@@ -538,6 +538,7 @@ public class OMSDisposeService {
                 if (!"12".equals(workInvoice.getStatus())) {
                     //通知发起人或者开票管理员
                     workInvoiceService.handleInvoiceRetryAllFail(workInvoice, errorMessage, informType);
+                    deleteInvoiceDownloadTaskFromRedis(workInvoiceId);
                 }
             }
             System.err.println("============ 【失败兜底-系统信息修改逻辑】执行完成 ============");
@@ -825,4 +826,19 @@ public class OMSDisposeService {
     }
 
 
+    // ========== 辅助方法：删除Redis解析任务 ==========
+    private void deleteInvoiceDownloadTaskFromRedis(String orderno) {
+        RedisUtils jedis = null;
+        try {
+            jedis = RedisUtils.getInstance();
+            jedis.delete("OMS_invoice_download:" + orderno);
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            if (jedis != null) {
+                //jedis.close();
+            }
+        }
+    }
+
 }