同步通讯录 微信同步gic

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

@@ -470,7 +470,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
     @Override
     public void dealQywxDepartment(String taskId, String wxEnterpriseId) {
         WxEnterpriseDTO wxEnterpriseDTO = wxEnterpriseService.selectById(wxEnterpriseId);
-        List<com.gic.wechat.api.dto.qywx.DepartmentDTO> list = qywxDepartmentApiService.listSelfDepartment(wxEnterpriseDTO.getCorpid(), wxEnterpriseDTO.getContactSecret(), 1);
+        List<com.gic.wechat.api.dto.qywx.DepartmentDTO> list = qywxDepartmentApiService.listSelfDepartment(wxEnterpriseDTO.getCorpid(), wxEnterpriseDTO.getContactSecret(), 9641);
         if (CollectionUtils.isEmpty(list)) {
             logger.info("没有数据同步");
             return;
@@ -489,7 +489,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
 
         preDealService.insert(dealLogList);
         HashSet<String> hashSet = new HashSet<>();
-        hashSet.add("1");
+        hashSet.add("9641");
         dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.group_sync);
     }
 

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

@@ -18,6 +18,10 @@
     id, wx_enterprise_id,enterprise_id, data_id, p_data_id, task_id, data_type, status_flag, create_time,
     update_time
   </sql>
+    <sql id="Base_Column_List_data">
+        id, wx_enterprise_id,enterprise_id, data_id,data_content, p_data_id, task_id, data_type, status_flag, create_time,
+        update_time
+    </sql>
     <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
         select
         <include refid="Base_Column_List"/>
@@ -169,7 +173,7 @@
 
     <select id="getByDataId" resultMap="BaseResultMap">
         select
-        <include refid="Base_Column_List"/>
+        <include refid="Base_Column_List_data"/>
         from tab_haoban_pre_deal_log
         where task_id = #{taskId} and data_id=#{dataId}
         <if test="status!=-1">

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

@@ -7,12 +7,13 @@
         <result column="task_name" jdbcType="VARCHAR" property="taskName"/>
         <result column="add_user" jdbcType="VARCHAR" property="addUser"/>
         <result column="task_desc" jdbcType="VARCHAR" property="taskDesc"/>
+        <result column="task_type" jdbcType="INTEGER" property="taskType"/>
         <result column="status_flag" jdbcType="INTEGER" property="statusFlag"/>
         <result column="create_time" jdbcType="TIMESTAMP" property="createTime"/>
         <result column="update_time" jdbcType="TIMESTAMP" property="updateTime"/>
     </resultMap>
     <sql id="Base_Column_List">
-    task_id,wx_enterprise_id, task_name, add_user, task_desc, status_flag, create_time, update_time
+        task_id,wx_enterprise_id, task_name, add_user, task_desc,task_type, status_flag, create_time, update_time
   </sql>
     <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
         select