东方新华同步付款状态-添加每十分钟定时同步付款状态

mjava-dongfangxinhua/src/main/java/com/malk/dongfangxinhua/schedule/ScheduleTask.java

@@ -32,7 +32,8 @@ public class ScheduleTask {
     /**
      * ，每天1点同步付款状态
      */
-    @Scheduled(cron = " 0 0 1 * * ? ")
+//    @Scheduled(cron = " 0 0 1 * * ? ")
+    @Scheduled(cron = "0 */10 * * * ?")
     public void syncPayStatus() {
         try {
             payService.syncPayStatus();
@@ -63,6 +64,4 @@ public class ScheduleTask {
             e.printStackTrace();
         }
     }
-
-
 }

mjava-yibaoju/src/main/java/com/malk/yibaoju/service/impl/YBJServiceImpl.java

@@ -272,23 +272,29 @@ public class YBJServiceImpl implements YBJService {
         long totalCount = ydClient.queryData(ydParam, YDConf.FORM_QUERY.retrieve_search_form).getTotalCount();
         log.info("totalCount{}",totalCount);
 
-        //如果条数不为0 就一直递归
-        if (totalCount>0){
-            ydParam.setPageSize(50);
-            List<Map> dataList = new ArrayList<>();
-            dataList = (List<Map>) ydClient.queryData(ydParam, YDConf.FORM_QUERY.retrieve_search_form).getData();
-            log.info("dataList:{}",dataList.size());
-            //循环处理修改状态为已上报
-            dataList.forEach(item -> {
-                //修改状态为已上报
-                ydClient.operateData(YDParam.builder()
+            //如果条数不为0 就一直递归
+            if (totalCount>0){
+                ydParam.setPageSize(50);
+                List<Map> dataList = new ArrayList<>();
+                dataList = (List<Map>) ydClient.queryData(ydParam, YDConf.FORM_QUERY.retrieve_search_form).getData();
+                log.info("dataList:{}",dataList.size());
+                //循环处理修改状态为已上报
+                dataList.forEach(item -> {
+                    //修改状态为已上报
+                    try {
+                        ydClient.operateData(YDParam.builder()
                         .formInstanceId(item.get("formInstanceId").toString())
                         .updateFormDataJson(JSON.toJSONString(UtilMap.map("selectField_lo56u5fn","已上报")))
                         .build(), YDConf.FORM_OPERATION.update);
-            });
-            Thread.sleep(5000);
-            syncUpdatePlanStatus();
-        }
+                    } catch (Exception e) {
+                        log.info("异常流程ID为：{}",item.get("formInstanceId").toString());
+                        throw new RuntimeException(e);
+                    }
+                });
+                Thread.sleep(5000);
+                syncUpdatePlanStatus();
+            }
+
     }
 
     /**