fix

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

@@ -737,4 +737,65 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
 		}
 		
 	}
+	
+	@Override
+	public void test(String wxEnterpriseId,String taskId){
+		List<TabHaobanStaffClerkRelation> relationList = new ArrayList<TabHaobanStaffClerkRelation>();
+		TabHaobanStaffClerkRelation tab = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab1 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab2 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab3 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab4 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab5 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab6 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab7 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab8 = new TabHaobanStaffClerkRelation();
+		TabHaobanStaffClerkRelation tab9 = new TabHaobanStaffClerkRelation();
+//		tab.setWxUserId("12");
+//		tab1.setWxUserId("13989473881");
+//		tab2.setWxUserId("1545shiyao");
+//		tab3.setWxUserId("15757150876");
+//		tab4.setWxUserId("18758285875");
+//		tab5.setWxUserId("2224324sdftgret90");
+//		tab6.setWxUserId("2341578784");
+//		tab7.setWxUserId("234324");
+//		tab8.setWxUserId("niweizhong");
+		tab9.setWxUserId("QiuWenMin");
+		
+//		tab.setStaffId("12");
+//		tab1.setStaffId("13989473881");
+//		tab2.setStaffId("1545shiyao");
+//		tab3.setStaffId("15757150876");
+//		tab4.setStaffId("18758285875");
+//		tab5.setStaffId("2224324sdftgret90");
+//		tab6.setStaffId("2341578784");
+//		tab7.setStaffId("234324");
+//		tab8.setStaffId("niweizhong");
+		tab9.setStaffId("QiuWenMin");
+//		relationList.add(tab);
+//		relationList.add(tab1);
+//		relationList.add(tab2);
+//		relationList.add(tab3);
+//		relationList.add(tab4);
+//		relationList.add(tab5);
+//		relationList.add(tab6);
+//		relationList.add(tab7);
+//		relationList.add(tab8);
+		relationList.add(tab9);
+        List<TabHaobanPreDealLog> dealLogList = relationList.stream().map(dto -> {
+            TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
+            dealLog.setDataId(dto.getWxUserId().toString());
+            dealLog.setpDataId(dto.getStaffId().toString());
+            dealLog.setDataType(PreDealTypeEnum.friend_clerk.getVal());
+            dealLog.setStatusFlag(0);
+            dealLog.setTaskId(taskId);
+            dealLog.setDataContent(JSONObject.toJSONString(dto));
+            dealLog.setWxEnterpriseId(wxEnterpriseId);
+            return dealLog;
+        }).collect(Collectors.toList());
+
+        preDealService.insert(dealLogList);
+        HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
+        dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
+	}
 }

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

@@ -11,6 +11,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.commons.util.GICMQClientUtil;
 import com.gic.haoban.manage.api.dto.DealParamMqDTO;
@@ -39,6 +40,7 @@ public class FriendClerkSyncOperation implements BaseSyncOperation {
 	
 	@Override
 	public void dealSingleByMq(DealParamMqDTO dealParamMqDTO, TabHaobanPreDealLog dataPre) {
+		logger.info("dealParamMqDTO={},dataPre={}",JSON.toJSONString(dealParamMqDTO),JSON.toJSONString(dataPre));
 		String reason = "";
 		boolean dealFlag = true;
 		String taskId = dealParamMqDTO.getTaskId();