crm退款修改

data-base/base-sync-crm-refund/src/main/java/com/bailuntec/job/CrmRefundSyncJob.java

@@ -37,8 +37,8 @@ public class CrmRefundSyncJob extends PointJob {
     @Override
     public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
         HashMap<String, String> map = new HashMap<>(4);
-        map.put("btime", jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
-        map.put("etime", jobPointLog.getEndTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
+        map.put("r_btime", jobPointLog.getStartTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
+        map.put("r_etime", jobPointLog.getEndTime().format(DateTimeFormatter.ofPattern(CommonConstant.TIME_FORMAT)));
         map.put("rows", jobPointLog.getPageSize().toString());
         Integer totalPage = 0;
         do {
@@ -95,6 +95,8 @@ public class CrmRefundSyncJob extends PointJob {
                         } finally {
                             SessionUtil.closeSession();
                         }
+                    }else {
+                        break;
                     }
                 } else {
                     throw new RuntimeException("CRM退款接口返回200, 但JSON错误" + map);
@@ -104,7 +106,7 @@ public class CrmRefundSyncJob extends PointJob {
                 throw new RuntimeException("CRM退款接口返回200, 但JSON错误" + map);
             }
         }
-        while (jobPointLog.getPageIndex() <= totalPage);
+        while (true);
         if (jobPointLog.getPageIndex() > totalPage) {
             jobPointLog.setPageIndex(1);
             jobPointLog.setStartTime(jobPointLog.getEndTime());