fix

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

@@ -41,6 +41,7 @@ public class FriendClerkSyncOperation implements BaseSyncOperation {
 	public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
 		String reason = "";
 		boolean dealFlag = true;
+		String taskId = dealParamMqDTO.getTaskId();
 		try {
 			String wxEnterpriseId = dataPre.getWxEnterpriseId();
 			String wxUserId = dataPre.getDataId();
@@ -93,6 +94,7 @@ public class FriendClerkSyncOperation implements BaseSyncOperation {
             } else {
                 dealSuccess(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), dataPre.getWxEnterpriseId());
             }
+			checkDepartmentTask(taskId);
 		}
 	}
 
@@ -110,24 +112,20 @@ public class FriendClerkSyncOperation implements BaseSyncOperation {
 
 	@Override
 	public void checkDepartmentTask(String taskId) {
-		boolean b = preDealService.checkTask(taskId, PreDealTypeEnum.friend.getVal());
+		boolean b = preDealService.checkTask(taskId, PreDealTypeEnum.friend_clerk.getVal());
         if (!b) {
             return;
         }
         logger.info("好友同步成功:{}", taskId);
         TabHaobanSyncTask syncTask = syncTaskService.getSyncTask(taskId);
         //同步成功 进入门店处理
-        if (syncTask.getStatusFlag().equals(SyncTaskStatusEnum.friend_sync.getVal())) {
-            int errCount = preDealService.countByTaskId(taskId, -1, PreDealStatusEnum.exception.getVal());
-            if (errCount > 0) {
-                syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.exception_compute.getVal());
-            } else {
-                syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
-            }
+        if (syncTask.getStatusFlag().equals(SyncTaskStatusEnum.friend_clerk_sync.getVal())) {
+        	syncTaskService.updateTaskStatus(taskId, SyncTaskStatusEnum.compute.getVal());
         }
 
 	}
 	
+	
 	/**
      * 放入mq处理部门数据
      *