fix

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

@@ -132,6 +132,24 @@ public interface DealSyncOperationApiService {
 	 * @param wxEnterpriseId
 	 */
 	public void dealWxFriendClerk(String taskId, String wxEnterpriseId);
+	/**
+     * 创建企业微信好友刷新任务
+     * @param wxEnterpriseId
+     * @param taskName
+     * @param staffId
+     * @param desc
+     * @return
+     */
+	public String createWxFriendSingleTask(String wxEnterpriseId, String taskName, String staffId, String staffName);
+
+	/**
+	 * 单个导购刷新
+	 * @param taskId
+	 * @param wxUserId
+	 * @param staffId
+	 * @param wxEnterpriseId
+	 */
+	public void dealWxFriendClerkSingle(String taskId, String wxUserId, String staffId,String wxEnterpriseId);
 
 
 }

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

@@ -656,9 +656,35 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
 	}
 
+	@Override
+	public String createWxFriendSingleTask(String wxEnterpriseId, String taskName, String staffId, String staffName) {
+		TabHaobanSyncTask tabHaobanSyncTask = new TabHaobanSyncTask();
+        tabHaobanSyncTask.setAddUser(staffId);
+        tabHaobanSyncTask.setTaskName(taskName);
+        tabHaobanSyncTask.setTaskDesc(staffName);
+        tabHaobanSyncTask.setWxEnterpriseId(wxEnterpriseId);
+        tabHaobanSyncTask.setStatusFlag(SyncTaskStatusEnum.init.getVal());
+        tabHaobanSyncTask.setTaskId(ToolUtil.randomUUID());
+        tabHaobanSyncTask.setTaskType(4);
+        syncTaskService.createTask(tabHaobanSyncTask);
         
-	private Collector groupingBy(Object object) {
-		// TODO Auto-generated method stub
-		return null;
+        return tabHaobanSyncTask.getTaskId();
+	}
+
+
+	@Override
+	public void dealWxFriendClerkSingle(String taskId, String wxUserId, String staffId,String wxEnterpriseId) {
+		TabHaobanPreDealLog dealLog = new TabHaobanPreDealLog();
+        dealLog.setDataId(wxUserId);
+        dealLog.setpDataId(staffId);
+        dealLog.setDataType(PreDealTypeEnum.friend_clerk.getVal());
+        dealLog.setStatusFlag(0);
+        dealLog.setTaskId(taskId);
+        dealLog.setDataContent("刷新"+staffId);
+        dealLog.setWxEnterpriseId(wxEnterpriseId);
+        List<TabHaobanPreDealLog> dealLogList = new ArrayList<TabHaobanPreDealLog>();
+        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-wx/src/main/java/com/gic/haoban/manage/web/controller/ClerkController.java

@@ -72,6 +72,8 @@ public class ClerkController extends WebBaseController{
 	private ClerkNewService clerkNewService;
 	@Autowired
 	private AuditSettingApiService auditSettingApiService;
+	@Autowired
+	private DealSyncOperationApiService dealSyncOperationApiService;
 	//选择成员列表
 	@RequestMapping("/staff-list")
 	public HaobanResponse staffList(String storeId) {
@@ -394,13 +396,18 @@ public class ClerkController extends WebBaseController{
 			json.put("wxUserId", staff.getWxUserId());
 			json.put("wxEnterpriseId", wxEnterpriseId);
 			json.put("storeId", storeId);
-			logger.info("【刷下微信好友】{},{},{}",RouterConstant.FRESH_WX_FRIEND_SERVICENAME,RouterConstant.INIT_FRESH_WX_FRIEND_METHODNAME,json.toJSONString());
-	        try {
-				GICMQClientUtil.getClientInstance().sendCommonMessage(RouterConstant.ROUTERTYPE, json.toJSONString(),
-						RouterConstant.FRESH_WX_FRIEND_SERVICENAME, RouterConstant.INIT_FRESH_WX_FRIEND_METHODNAME);
-			} catch (Exception e) {
-				logger.info(e.getMessage(),e);
-			}
+//			logger.info("【刷下微信好友】{},{},{}",RouterConstant.FRESH_WX_FRIEND_SERVICENAME,RouterConstant.INIT_FRESH_WX_FRIEND_METHODNAME,json.toJSONString());
+			String taskName = "刷新企业微信好友（"+staff.getStaffName()+"）";
+			String taskId = dealSyncOperationApiService.createWxFriendSingleTask(wxEnterpriseId, taskName, staffId, staff.getStaffName());
+			if(StringUtils.isNotBlank(taskId)){
+				dealSyncOperationApiService.dealWxFriendClerkSingle(taskId,wxUserId,staffId,wxEnterpriseId);
+			}
+//	        try {
+//				GICMQClientUtil.getClientInstance().sendCommonMessage(RouterConstant.ROUTERTYPE, json.toJSONString(),
+//						RouterConstant.FRESH_WX_FRIEND_SERVICENAME, RouterConstant.INIT_FRESH_WX_FRIEND_METHODNAME);
+//			} catch (Exception e) {
+//				logger.info(e.getMessage(),e);
+//			}
 //			memberUnionidRelatedApiService.freshWxFrend(wxEnterpriseId, staff.getWxUserId(),storeId);
 			
 		}else{