同步优化初步3-同步成员

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/entity/TabHaobanSyncTask.java

@@ -15,6 +15,8 @@ public class TabHaobanSyncTask implements Serializable {
      */
     private String taskId;
 
+    private String wxEnterpriseId;
+
     /**
      *
      */
@@ -49,6 +51,14 @@ public class TabHaobanSyncTask implements Serializable {
      */
     private static final long serialVersionUID = 1L;
 
+    public String getWxEnterpriseId() {
+        return wxEnterpriseId;
+    }
+
+    public void setWxEnterpriseId(String wxEnterpriseId) {
+        this.wxEnterpriseId = wxEnterpriseId;
+    }
+
     /**
      * This method returns the value of the database column tab_haoban_sync_task.task_id
      *

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/DealSyncOperationApiServiceImpl.java

@@ -159,6 +159,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         tabHaobanSyncTask.setAddUser(userId);
         tabHaobanSyncTask.setTaskName(taskName);
         tabHaobanSyncTask.setTaskDesc(desc);
+        tabHaobanSyncTask.setWxEnterpriseId(wxEnterpriseId);
         tabHaobanSyncTask.setStatusFlag(SyncTaskStatusEnum.init.getVal());
         tabHaobanSyncTask.setTaskId(ToolUtil.randomUUID());
         syncTaskService.createTask(tabHaobanSyncTask);

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

@@ -24,10 +24,10 @@
         where task_id = #{taskId,jdbcType=VARCHAR}
     </delete>
     <insert id="insert" parameterType="com.gic.haoban.manage.service.entity.TabHaobanSyncTask">
-        insert into tab_haoban_sync_task (task_id, task_name, add_user,
+        insert into tab_haoban_sync_task (task_id,wx_enterprise_id, task_name, add_user,
         task_desc, status_flag, create_time,
         update_time)
-        values (#{taskId,jdbcType=VARCHAR}, #{taskName,jdbcType=VARCHAR}, #{addUser,jdbcType=VARCHAR},
+        values (#{taskId,jdbcType=VARCHAR},#{wxEnterpriseId}, #{taskName,jdbcType=VARCHAR}, #{addUser,jdbcType=VARCHAR},
         #{taskDesc,jdbcType=VARCHAR}, #{statusFlag,jdbcType=INTEGER}, now(),now())
     </insert>
     <insert id="insertSelective" parameterType="com.gic.haoban.manage.service.entity.TabHaobanSyncTask">

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/SyncDealContoller.java

@@ -60,7 +60,7 @@ public class SyncDealContoller extends WebBaseController {
         if (null != taskLock) {
             return resultResponse(HaoBanErrCode.ERR_10011);
         }
-        task = dealSyncOperationApiService.createTask("门店同步", login.getStaffDTO().getStaffId(), "部门同步");
+        task = dealSyncOperationApiService.createTask(wxEnterpriseId, "门店同步", login.getStaffDTO().getStaffId(), "部门同步");
         dealSyncOperationApiService.dealDepartment(task, login.getWxEnterpriseId(), qo.getAddDepartment(), qo.getEditDepartment());
 
         return resultResponse(HaoBanErrCode.ERR_1, task);