fix

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

@@ -61,7 +61,7 @@ public class FriendSyncOperation implements BaseSyncOperation {
 		String externalUserId = dataPre.getDataContent();
 		ExternalUserDTO pojo = memberUnionidRelatedApiService.getExternalUseridInfo(wxEnterpriseId, wxUserId, externalUserId);
 		if(pojo == null){
-			preDealService.updateStatusByDataId(taskId, externalUserId, PreDealStatusEnum.exception.getVal(), "好友不存在");
+			preDealService.updateStatusByDataId(taskId, dataPre.getDataId(), PreDealStatusEnum.exception.getVal(), "好友不存在");
 			checkStaffTask(taskId, wxUserId);
 			return;
 		}
@@ -69,7 +69,7 @@ public class FriendSyncOperation implements BaseSyncOperation {
 		json.put("name", pojo.getName());
 		json.put("externalUserId", pojo.getExternalUserId());
 		json.put("addCreateTime", pojo.getAddCreateTime());
-		dealSuccess(taskId, externalUserId,JSON.toJSONString(json),wxEnterpriseId);
+		dealSuccess(taskId, dataPre.getDataId(),JSON.toJSONString(json),wxEnterpriseId);
 		try {
 			checkStaffTask(taskId, wxUserId);
 		} catch (Exception e) {
@@ -79,7 +79,7 @@ public class FriendSyncOperation implements BaseSyncOperation {
             dealFlag = false;
 		}finally {
 			if (!dealFlag) {
-               dealException(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), reason);
+               dealException(dealParamMqDTO.getTaskId(), dataPre.getDataId(), dataPre.getEnterpriseId(), reason);
            } 
 		}
 	}

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

@@ -72,7 +72,7 @@ public class SelfFriendSyncOperation implements BaseSyncOperation{
 		String externalUserId = dataPre.getDataContent();
 		ExternalUserDTO pojo = memberUnionidRelatedApiService.getCorpSelfExternalUseridInfo(wxEnterpriseId,wxUserId, externalUserId);
 		if(pojo == null){
-			dealException(taskId, externalUserId, null, "好友不存在");
+			dealException(taskId, dataPre.getDataId(), null, "好友不存在");
 			checkStaffTask(taskId, wxUserId);
 			return;
 		}
@@ -81,7 +81,7 @@ public class SelfFriendSyncOperation implements BaseSyncOperation{
 		json.put("unionId", pojo.getUnionId());
 		json.put("addCreateTime", pojo.getAddCreateTime());
 		try {
-			dealSuccess(taskId, externalUserId,json.toJSONString(),wxEnterpriseId);
+			dealSuccess(taskId, dataPre.getDataId(),json.toJSONString(),wxEnterpriseId);
 			checkStaffTask(taskId, wxUserId);
 		} catch (Exception e) {
 			 e.printStackTrace();
@@ -90,7 +90,7 @@ public class SelfFriendSyncOperation implements BaseSyncOperation{
              dealFlag = false;
 		}finally {
 			if (!dealFlag) {
-                dealException(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dataPre.getEnterpriseId(), reason);
+                dealException(dealParamMqDTO.getTaskId(), dataPre.getDataId(), dataPre.getEnterpriseId(), reason);
             } 
 		}
 	}