获取数据字典下拉框

hx-customer/src/main/java/com/fjhx/customer/contants/XiaomanContant.java

@@ -7,6 +7,9 @@ public class XiaomanContant {
     public static final String CUSTOMER_DETAIL_API_URL = "https://api-sandbox.xiaoman.cn/v1/company/info";
     /** 客户更新列表**/
     public static final String UPDATE_CUSTOMER_API_URL = "https://api-sandbox.xiaoman.cn/v1/company/updates";
+    /**客户状态，客户分组，公海分组，客户来源下拉框数据**/
+    public static final String SELECTOR_API_URL = "https://api-sandbox.xiaoman.cn/v1/company/fields/selector";
+
     /**任务状态redis key**/
     public static final String TASK_STATUS_KEY = "all_customer:task_status_key";
     public static final String TASK_STATUS_VALUE = "start_task";
@@ -18,4 +21,5 @@ public class XiaomanContant {
     public static final int DELAY_DELETE_KEY_TIME = 300;
 
 
+
 }

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

@@ -19,6 +19,7 @@ import com.fjhx.customer.entity.xiaoman.vo.XiaomanCustomerVo;
 import com.fjhx.customer.service.xiaoman.XiaomanCustomerService;
 import com.ruoyi.common.utils.spring.SpringUtils;
 import com.fjhx.customer.service.xiaoman.XiaomanConfigService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.StringRedisTemplate;
 
 
@@ -31,6 +32,7 @@ import java.util.concurrent.TimeUnit;
 import java.util.*;
 import java.util.stream.Collectors;
 
+@Slf4j
 public class HandleXiaomanData {
     private static XiaomanConfigService xiaomanConfigService = SpringUtils.getBean(XiaomanConfigService.class);
     private static XiaomanCustomerService xiaomanCustomerService = SpringUtils.getBean(XiaomanCustomerService.class);
@@ -178,7 +180,26 @@ public class HandleXiaomanData {
             e.printStackTrace();
         }
     }
-    
+
+    private static final List<String> SELECTOR_KEY = Arrays.asList("trail_status", "group_id", "pool_id", "origin");
+
+
+    /**
+     * 获取下拉框字典数据
+     * @author hj
+     * @date 2024/4/7 10:51
+     */
+    public static void getSelectorData() {
+        XiaomanConfig config = xiaomanConfigService.getConfig();
+        String token = config.getAccessToken();
+        Map<String, Object> params = new HashMap<>();
+        SELECTOR_KEY.forEach(key -> {
+            params.put("field", key);
+            String str = getData(XiaomanContant.SELECTOR_API_URL, token, params);
+            JSONObject jsonObject = JSONObject.parseObject(str);
+            log.info("获取小满下拉框字典数据：{}", jsonObject);
+        });
+    }
     
 
     private static Map<String, Object> initPageParams(int page) {
@@ -188,7 +209,7 @@ public class HandleXiaomanData {
         return params;
     }
 
-    public static String getData(String url, String token, Map<String, Object> params) {
+    private static String getData(String url, String token, Map<String, Object> params) {
         String res = HttpUtil.createGet(url).header("Authorization", "Bearer " + token).form(params).execute().body();
         JSONObject jsonObject = JSONObject.parseObject(res);
         String error = jsonObject.getString("error");
@@ -216,4 +237,6 @@ public class HandleXiaomanData {
         }
         return false;
     }
+
+
 }

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

@@ -59,4 +59,22 @@ public class XiaomanInitializers {
             }
         }
     }
+
+
+
+
+    /**
+     * 获取下拉框字典数据
+     * @author hj
+     * @date 2024/4/7 10:49
+     */
+    @Scheduled(cron = "0 0 0 0/1 * ? ")
+    void getSelectorData(){
+        //获取全量数据
+        try {
+            HandleXiaomanData.getSelectorData();
+        } catch (Exception e) {
+            log.error("获取小满下拉框字典数据异常", e);
+        }
+    }
 }