勤策_经销商数据同步时_修改客户助理人员的id为工号

src/main/java/com/wangxiaolu/promotion/service/user/impl/QinCeDataTaskServiceImpl.java

@@ -185,6 +185,55 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
                 jsonObject.put("dealer_manager_code","");
                 jsonObject.put("dealer_manager","");
             }
+
+            // 处理经销商助理ID：从勤策员工ID转换为emp_code
+            String dealerAssistantId = jsonObject.getString("dealer_assistant_id");
+            if (StringUtils.isNotBlank(dealerAssistantId)) {
+                String[] assistantIds = dealerAssistantId.split(",");
+                StringBuilder empCodes = new StringBuilder();
+                StringBuilder empNames = new StringBuilder();
+
+                for (String assistantId : assistantIds) {
+                    assistantId = assistantId.trim();
+                    if (StringUtils.isBlank(assistantId)) {
+                        continue;
+                    }
+                    try {
+                        // 调用员工查询接口获取emp_code
+                        Map<String, Object> empParams = qinCeUtils.queryEmployeeByIdParam(assistantId);
+                        String empUrl = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE_BY_ID, empParams);
+                        JSONObject empResultJson = OkHttp.postQC(empUrl, empParams);
+                        JSONArray empDatas = empResultJson.getJSONArray("response_data");
+
+                        if (empDatas != null && empDatas.size() > 0) {
+                            JSONObject empInfo = empDatas.getJSONObject(0);
+                            String empCode = empInfo.getString("emp_code");
+                            String empName = empInfo.getString("emp_name");
+
+                            if (StringUtils.isNotBlank(empCode)) {
+                                if (empCodes.length() > 0) {
+                                    empCodes.append(",");
+                                }
+                                empCodes.append(empCode);
+                            }
+
+                            if (StringUtils.isNotBlank(empName)) {
+                                if (empNames.length() > 0) {
+                                    empNames.append(",");
+                                }
+                                empNames.append(empName);
+                            }
+                        }
+                    } catch (Exception e) {
+                        log.error("勤策-查询员工信息失败，员工ID：{}，错误：{}", assistantId, e.getMessage());
+                    }
+                }
+
+                // 更新为emp_code和emp_name
+                jsonObject.put("dealer_assistant_id", empCodes.toString());
+                jsonObject.put("dealer_assistant_name", empNames.toString());
+            }
+
             dealerAddJsons.add(jsonObject);
 
             // 如果经销商不是合作中，则不存在到redis中

src/main/java/com/wangxiaolu/promotion/utils/QinCeUtils.java

@@ -50,6 +50,8 @@ public class QinCeUtils {
     public static final String QUERY_PRODUCT = "/api/product/v1/queryProduct/";
     // 经销商
     public static final String QUERY_DEALER = "/api/dealer/v1/queryDealer/";
+    // 查询员工（用于获取emp_code）
+    public static final String QUERY_EMPLOYEE_BY_ID = "/api/employee/v3/queryEmployee/";
 
     public String builderUrl(String sidepath, Map<String, Object> params) {
         String msgId = UUID.randomUUID().toString();
@@ -176,4 +178,13 @@ public class QinCeUtils {
 //        params.put("after_create_date", DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
         return params;
     }
+
+    /**
+     * 根据员工ID查询员工信息参数
+     */
+    public Map<String, Object> queryEmployeeByIdParam(String empId) {
+        Map<String, Object> params = new HashMap<>();
+        params.put("id", empId);
+        return params;
+    }
 }