ソースを参照

定时任务-对账单下载未判断打印id是否为空,导致一直查询失败

ZhangWenQiang 4 年 前
コミット
38870a2b04

+ 19 - 12
happy-cloud-wisdom/happy-cloud-wisdom-biz/src/main/java/org/jeecg/modules/hlwpayment/task/PaymentRsaDownloadJob.java

@@ -6,6 +6,7 @@ import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import com.xxl.job.core.log.XxlJobLogger;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.jeecg.common.oss.OSSClientUtil;
 import org.jeecg.common.util.DateUtils;
 import org.jeecg.modules.hlwpayaccount.entity.HlwPayRecord;
@@ -111,10 +112,12 @@ public class PaymentRsaDownloadJob {
             if (jsonObjectBody != null) {
                 //打印任务编号
                 String printId = jsonObjectBody.getString("printid");
-                //每个下载任务独立线程池(需要考虑并发问题)
-                ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
-                //下载对账单
-                downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                if (StringUtils.isNotBlank(printId)) {
+                    //每个下载任务独立线程池(需要考虑并发问题)
+                    ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
+                    //下载对账单
+                    downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                }
             }
         }
         return ReturnT.SUCCESS;
@@ -146,10 +149,12 @@ public class PaymentRsaDownloadJob {
             if (jsonObjectBody != null) {
                 //打印任务编号
                 String printId = jsonObjectBody.getString("printid");
-                //每个下载任务独立线程池(需要考虑并发问题)
-                ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
-                //下载对账单
-                downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                if (StringUtils.isNotBlank(printId)) {
+                    //每个下载任务独立线程池(需要考虑并发问题)
+                    ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
+                    //下载对账单
+                    downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                }
             }
         }
         return ReturnT.SUCCESS;
@@ -181,10 +186,12 @@ public class PaymentRsaDownloadJob {
             if (jsonObjectBody != null) {
                 //打印任务编号
                 String printId = jsonObjectBody.getString("printid");
-                //每个下载任务独立线程池(需要考虑并发问题)
-                ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
-                //下载对账单
-                downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                if (StringUtils.isNotBlank(printId)) {
+                    //每个下载任务独立线程池(需要考虑并发问题)
+                    ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(2);
+                    //下载对账单
+                    downLoad(hlwPayment, printId, hlwSubcontractor, scheduledThreadPoolExecutor);
+                }
             }
         }
         return ReturnT.SUCCESS;