fix

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/SyncTaskMapper.java

@@ -2,6 +2,7 @@ package com.gic.haoban.manage.service.dao.mapper;
 
 import com.gic.haoban.manage.service.entity.TabHaobanSyncTask;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -34,4 +35,6 @@ public interface SyncTaskMapper {
     /**
      */
     List<TabHaobanSyncTask> listPageByWxEid(String wxEnterpriseId);
+
+	List<TabHaobanSyncTask> listTaskByType(@Param("taskType")int taskType);
 }
\ No newline at end of file

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

 package com.gic.haoban.manage.service.service;
 
+import java.util.List;
+
 import com.gic.api.base.commons.Page;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.manage.api.dto.SyncTaskDTO;
@@ -42,4 +44,10 @@ public interface SyncTaskService {
      * @return
      */
     public Page<SyncTaskDTO> listTaskPage(String wxEnterpriseId, BasePageInfo pageInfo);
+    /**
+     * 获取列表
+     * @param taskType
+     * @return
+     */
+	public List<TabHaobanSyncTask> listTaskByType(int taskType);
 }

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

@@ -58,4 +58,10 @@ public class SyncTaskServiceImpl implements SyncTaskService {
         Page<SyncTaskDTO> page = PageUtil.changePageHelperToCurrentPage(new PageInfo<>(list), SyncTaskDTO.class);
         return page;
     }
+
+	@Override
+	public List<TabHaobanSyncTask> listTaskByType(int taskType) {
+		List<TabHaobanSyncTask> list = syncTaskMapper.listTaskByType(taskType);
+		return list;
+	}
 }

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

@@ -729,11 +729,11 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
 
 	@Override
 	public void quartWxFriendClerk(String res) {
-		if(StringUtils.isNotBlank(res)){
-			JSONObject json = JSON.parseObject(res);
-			String taskId = json.getString("taskId");
-			String wxEnterpriseId = json.getString("wxEnterpriseId");
-			dealWxFriendClerk(taskId, wxEnterpriseId);
+		List<TabHaobanSyncTask> taskList = syncTaskService.listTaskByType(2);
+		if(CollectionUtils.isNotEmpty(taskList)){
+			for (TabHaobanSyncTask tabHaobanSyncTask : taskList) {
+				dealWxFriendClerk(tabHaobanSyncTask.getTaskId(), tabHaobanSyncTask.getWxEnterpriseId());
+			}
 		}
 		
 	}

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

@@ -125,4 +125,11 @@
         
          order by update_time desc
     </select>
+    <select id="listTaskByType" parameterType="java.lang.String" resultMap="BaseResultMap">
+        select
+        <include refid="Base_Column_List"/>
+        from tab_haoban_sync_task
+        where status_flag = 0
+        and task_type = #{taskType}
+    </select>
 </mapper>
\ No newline at end of file