[深爱]获取客商数据

src/main/java/com/uas/eis/service/Impl/RequestSTKServiceImpl.java

@@ -47,10 +47,6 @@ public class RequestSTKServiceImpl implements RequestSTKService {
      * */
     @Override
     public TravellingMerchantVo selectTravellingMerchantList(QueryTravellingMerchantDto dto, String url){
-        if(null == dto.getPage() || null == dto.getSize()){
-            dto.setPage(1);
-            dto.setSize(10);
-        }
 
         dto.setS_orgcode(S_ORG_CODE);
 

src/main/java/com/uas/eis/service/Impl/STKServiceImpl.java

@@ -157,10 +157,12 @@ public class STKServiceImpl implements STKService {
 
 
     @Override
-    public void getCustvend(TravellingMerchantVo travellingMerchantVo ) {
+    public void getCustvend(TravellingMerchantVo travellingMerchantVo , Boolean isdelete) {
         List<CustvendDTO> custvendDTOS = travellingMerchantVo.getData().getList();
         List<String> sqls = new ArrayList<>();
-        sqls.add("delete from STK_CUSTVEND2");
+        if (isdelete) {
+            sqls.add("delete from STK_CUSTVEND2");
+        }
         for (int i = 0; i < custvendDTOS.size(); i++) {
             sqls.add("insert into STK_CUSTVEND2(ID,S_ID,S_CODE,NAME,UID_TYPE,UID2,CUSTOMER_TYPE,IS_VALID,CREATED_ORG,CREATED_SYSTEM,ISTEMPORARY,MDM_CODE,REG_COUNTRY, " +
                     "REG_PLACE,REG_REP,REG_CAPTIAL,REG_PERIOD,REG_BIZSCOPE," +

src/main/java/com/uas/eis/service/STKService.java

@@ -48,5 +48,5 @@ public interface STKService {
     /**
      * 获取客商信息
      * */
-    void getCustvend(TravellingMerchantVo travellingMerchantVo );
+    void getCustvend(TravellingMerchantVo travellingMerchantVo , Boolean isdelete);
 }

src/main/java/com/uas/eis/task/STKTask.java

@@ -17,7 +17,7 @@ import java.util.List;
 import java.util.Set;
 
 @Slf4j
-//@Component
+@Component
 public class STKTask {
 
     /**
@@ -44,17 +44,32 @@ public class STKTask {
     @Autowired
     private STKService stkService;
 
-    //@Scheduled(cron = "0 0/2 * * * ?")
+    @Scheduled(cron = "0 30 22 * * ?")
     public void getSellerOrders(){
         log.info("开始获取深投控客商状态信息=========start=============");
         Date date = new Date();
 
         QueryTravellingMerchantDto dto = new QueryTravellingMerchantDto();
         dto.setCode(GET_TRAVELLING_MERCHANT);
+        dto.setPage(1);
+        dto.setSize(500);
 
         TravellingMerchantVo travellingMerchantVo =  requestSTKService.selectTravellingMerchantList(dto,COMPLEXITY_QUERY_URL);
-        log.info("定时任务获取深投控客商信息数据结果1：{}", JSONObject.toJSONString(travellingMerchantVo));
-        stkService.getCustvend(travellingMerchantVo);
+        log.info("定时任务获取深投控客商信息数据结果：{}", JSONObject.toJSONString(travellingMerchantVo));
+        //第一次删除STK_CUSTVEND的数据
+        stkService.getCustvend(travellingMerchantVo, true);
+        if (travellingMerchantVo.getData().getHasNextPage()){
+            Boolean isBreak = true;
+            while(isBreak) {
+                dto.setPage(travellingMerchantVo.getData().getNextPage());
+                log.info("while循环获取客商数据，查询参数：{}",JSONObject.toJSONString(dto));
+                travellingMerchantVo = requestSTKService.selectTravellingMerchantList(dto, COMPLEXITY_QUERY_URL);
+                stkService.getCustvend(travellingMerchantVo, false);
+                if (!travellingMerchantVo.getData().getHasNextPage() || dto.getSize() > travellingMerchantVo.getData().getEndRow()){
+                    isBreak = false;
+                }
+            }
+        }
         log.info("定时任务获取深投控客商信息数据结果2：{}", JSONObject.toJSONString(travellingMerchantVo));
 
         log.info("开始获取深投控客商状态信息,结束:"+((System.currentTimeMillis()-date.getTime())/1000));