Browse Source

1、数据处理

lqh 1 year ago
parent
commit
a6f6f76b71

+ 4 - 2
hx-customer/src/main/java/com/fjhx/customer/handle/HandleXiaomanData.java

@@ -101,6 +101,8 @@ public class HandleXiaomanData {
     ///////////////////////////////////////////////////////////////////////////////////////////////////
 
     public static void initAllList(){
+        redisTemplate.delete(XiaomanContant.TASK_STATUS_KEY);
+        redisTemplate.opsForValue().set(XiaomanContant.TASK_STATUS_DESC_KEY, "全量更新出现异常,已停止");
         boolean result = setNxWithExpiration(XiaomanContant.TASK_STATUS_KEY, XiaomanContant.TASK_STATUS_VALUE, XiaomanContant.DELAY_DELETE_KEY_TIME);
         if (!result) {
             String mes = redisTemplate.opsForValue().get(XiaomanContant.TASK_STATUS_DESC_KEY);
@@ -181,8 +183,8 @@ public class HandleXiaomanData {
 
     private static Map<String, Object> initPageParams(int page) {
         Map<String, Object> params = new HashMap<>();
-        params.put("page", page);
-        params.put("pageSize", PAGE_SIZE);
+        params.put("start_index", page);
+        params.put("count", PAGE_SIZE);
         return params;
     }