同步优化初步3

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/GroupSyncOperation.java

@@ -149,6 +149,7 @@ public class GroupSyncOperation implements BaseSyncOperation {
                 dealLog.setTaskId(taskId);
                 dealLog.setEnterpriseId(storeDTO.getEnterpriseId());
                 dealLog.setWxEnterpriseId(wxEnterpriseId);
+                dealLog.setEnterpriseId(enterpriseId);
                 return dealLog;
             }).collect(Collectors.toList());
             preDealService.insert(preDealLogList);

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/StoreSyncOperation.java

@@ -131,7 +131,7 @@ public class StoreSyncOperation implements BaseSyncOperation {
             return;
         }
         List<ClerkListDTO> clerks = clerkService.getClerkByStoreId(enterpriseId, dataId);
-        logger.info("导入clerk:{}", JSONObject.toJSONString(clerks));
+        logger.info("导入clerk:{},{},{}", enterpriseId, dataId, JSONObject.toJSONString(clerks));
         //预处理门店 写入预处理表
         if (CollectionUtils.isNotEmpty(clerks)) {
             List<TabHaobanPreDealLog> preDealLogList = clerks.stream().map(clerkMid -> {

haoban-manage3-service/src/main/resources/mapper/PreDealLogMapper.xml

@@ -28,11 +28,11 @@
     where id = #{id,jdbcType=INTEGER}
   </delete>
     <insert id="insert" parameterType="com.gic.haoban.manage.service.entity.TabHaobanPreDealLog">
-    insert into tab_haoban_pre_deal_log ( wx_enterprise_id, data_id,
+    insert into tab_haoban_pre_deal_log ( wx_enterprise_id,enterprise_id, data_id,
       p_data_id, task_id, data_type, 
       status_flag, create_time, update_time
       )
-    values (#{wxEnterpriseId,jdbcType=VARCHAR}, #{dataId,jdbcType=VARCHAR},
+    values (#{wxEnterpriseId,jdbcType=VARCHAR},#{enterpriseId,jdbcType=VARCHAR}, #{dataId,jdbcType=VARCHAR},
       #{pDataId,jdbcType=VARCHAR}, #{taskId,jdbcType=VARCHAR}, #{dataType,jdbcType=INTEGER}, 
       #{statusFlag,jdbcType=INTEGER}, now(), now()
       )