同步经销商的客户经理

src/main/java/com/wangxiaolu/promotion/domain/user/dao/impl/QinceDealerDaoImpl.java

@@ -31,7 +31,7 @@ public class QinceDealerDaoImpl implements QinceDealerDao {
 
     @Override
     public void saveList(List<Object> dealerJsons) {
-        // 目前没有查重逻辑，只在前边判断逻辑中判断是否新增
+        // SQL中根据经销商编码判断是否存在，存在则更新，不存在则插入
         qinceDealerMapper.saveList(dealerJsons);
     }
 

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

@@ -172,6 +172,12 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
             if (StringUtils.isBlank(dealerId)){
                 continue;
             }
+            // 001588、001488、001485
+            List<String> ypIds = Arrays.asList("001588", "001488", "001485");
+            if (ypIds.contains(dealerId)){
+                jsonObject.put("dealer_manager_code","");
+                jsonObject.put("dealer_manager","");
+            }
             dealerAddJsons.add(jsonObject);
 
             // 如果经销商不是合作中，则不存在到redis中

src/main/resources/mapper/QinceDealerMapper.xml

@@ -18,11 +18,11 @@
 
     <insert id="saveList">
         insert into qince_dealer
-        (dealer_id, dealer_name, dealer_cooperate_status, create_time,dealer_dept_waiqin365_id,dealer_dept_name,dealer_type,dealer_status)
+        (dealer_id, dealer_name, dealer_cooperate_status, create_time,dealer_dept_waiqin365_id,dealer_dept_name,dealer_type,dealer_status,dealer_manager_code,dealer_manager)
         VALUES
         <foreach collection="dealerJsons" item="item" separator=",">
             (#{item.dealer_id}, #{item.dealer_name},
-            #{item.dealer_cooperate_status},#{item.create_time},#{item.dealer_dept_waiqin365_id},#{item.dealer_dept_name},#{item.dealer_type},#{item.dealer_status})
+            #{item.dealer_cooperate_status},#{item.create_time},#{item.dealer_dept_waiqin365_id},#{item.dealer_dept_name},#{item.dealer_type},#{item.dealer_status},#{item.dealer_manager_code},#{item.dealer_manager})
         </foreach>
         ON DUPLICATE KEY UPDATE
         dealer_name = values(dealer_name),
@@ -30,7 +30,9 @@
         dealer_dept_waiqin365_id = values(dealer_dept_waiqin365_id),
         dealer_dept_name = values(dealer_dept_name),
         dealer_type = values(dealer_type),
-        dealer_status = values(dealer_status);
+        dealer_status = values(dealer_status),
+        dealer_manager_code = values(dealer_manager_code),
+        dealer_manager = values(dealer_manager);
     </insert>
 
     <update id="updateOrg">