Эх сурвалжийг харах

增加定时任务及更新时长改为24小时

1018653686@qq.com 1 жил өмнө
parent
commit
84581657c9

+ 2 - 2
hx-customer/src/main/java/com/fjhx/customer/initializers/XiaomanInitializers.java

@@ -44,7 +44,7 @@ public class XiaomanInitializers {
     }
 
 
-    @Scheduled(cron = "0 0/30 * * * ? ")
+    @Scheduled(cron = "0 0 0/8 * * ? ")
     void refreshToken(){
         //如果过期时间是空的,就获取新的token
         XiaomanConfig config = xiaomanConfigService.getConfig();
@@ -64,7 +64,7 @@ public class XiaomanInitializers {
 
     @Scheduled(cron = "0 0 0 * * ? ")
     void updateList(){
-        xiaomanApiService.updateList();
+        xiaomanApiService.updateList(8);
     }
 
 }

+ 1 - 1
hx-customer/src/main/java/com/fjhx/customer/service/xiaoman/XiaomanApiService.java

@@ -18,7 +18,7 @@ public interface XiaomanApiService {
     String getCustomerDetail(Long companyId);
 
 
-    void updateList();
+    void updateList(int hours);
 
     @DSTransactional
     void getSelectorData();

+ 2 - 2
hx-customer/src/main/java/com/fjhx/customer/service/xiaoman/impl/XiaomanApiServiceImpl.java

@@ -131,7 +131,7 @@ public class XiaomanApiServiceImpl implements XiaomanApiService {
      */
     @Override
     @Async
-    public void updateList(){
+    public void updateList(int hours){
         try {
             //先更新一下数据字典
             getSelectorData();
@@ -145,7 +145,7 @@ public class XiaomanApiServiceImpl implements XiaomanApiService {
             do {
                 Map<String, Object> params = initPageParams(pageIndex);
                 String nowStr = DateUtil.offsetHour(DateUtil.date(), 1).toString("yyyy-MM-dd HH:00:00");
-                params.put("start_time", DateUtil.parse(nowStr).offset(DateField.HOUR, -24).toString("yyyy-MM-dd HH:00:00"));
+                params.put("start_time", DateUtil.parse(nowStr).offset(DateField.HOUR, -hours).toString("yyyy-MM-dd HH:00:00"));
                 params.put("end_time", nowStr);
                 String str = getData(XiaomanContant.GET_UPDATE_CUSTOMER_API_URL, token, params);
                 CustomerListApiVo customerListApiVo = HandleXiaomanData.handleAllCustomer(str, collect);

+ 1 - 1
hx-customer/src/main/java/com/fjhx/customer/service/xiaoman/impl/XiaomanCustomerServiceImpl.java

@@ -337,6 +337,6 @@ public class XiaomanCustomerServiceImpl extends ServiceImpl<XiaomanCustomerMappe
     }
     @Override
     public void updateList() {
-        xiaomanApiService.updateList();
+        xiaomanApiService.updateList(8);
     }
 }