手动刷新好友入口

haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/controller/test/TestController.java

@@ -7,8 +7,12 @@ import com.gic.commons.util.EntityUtil;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.common.utils.CheckContainUtil;
 import com.gic.haoban.common.utils.HaobanResponse;
+import com.gic.haoban.manage.api.dto.StaffDTO;
 import com.gic.haoban.manage.api.dto.TestDTO;
 import com.gic.haoban.manage.api.enums.QuartzEnum;
+import com.gic.haoban.manage.api.enums.SyncTaskTypeEnum;
+import com.gic.haoban.manage.api.service.DealSyncOperationApiService;
+import com.gic.haoban.manage.api.service.StaffApiService;
 import com.gic.haoban.manage.api.service.TestApiService;
 import com.gic.haoban.manage.api.service.TestService;
 import com.gic.haoban.manage.web.controller.WebBaseController;
@@ -44,6 +48,12 @@ public class TestController extends WebBaseController {
 
     @Autowired
     private MqApiService mqApiService;
+
+    @Autowired
+    private StaffApiService staffApiService;
+
+    @Autowired
+    private DealSyncOperationApiService dealSyncOperationApiService;
 //
 //    @RequestMapping("/testList")
 //    @ResponseBody
@@ -135,4 +145,32 @@ public class TestController extends WebBaseController {
         }
         return resultResponse(HaoBanErrCode.ERR_1);
     }
+
+    /**
+     * 刷新好友
+     *
+     * @return
+     */
+    @RequestMapping("/flush-friend-batch")
+    @ResponseBody
+    public HaobanResponse flushFriend(String key) {
+        if (StringUtils.isBlank(key)) {
+            return resultResponse(HaoBanErrCode.ERR_0);
+        }
+        String[] split = key.split(",");
+        for (String staffId : split) {
+            StaffDTO staff = staffApiService.selectById(staffId);
+            if (null == staff) {
+                continue;
+            }
+            String wxEnterpriseId = staff.getWxEnterpriseId();
+            String wxUserId = staff.getWxUserId();
+            String taskName = "刷新企业微信好友（" + staff.getStaffName() + "）";
+            String taskId = dealSyncOperationApiService.createWxFriendTaskSingle(staff.getWxEnterpriseId(), taskName, staffId, staff.getStaffName(), SyncTaskTypeEnum.FRIEND_SINGLE.getType());
+            if (StringUtils.isNotBlank(taskId)) {
+                dealSyncOperationApiService.dealWxFriendClerkSingle(taskId, wxUserId, staffId, wxEnterpriseId);
+            }
+        }
+
+    }
 }

haoban-manage3-operation-web/src/main/webapp/WEB-INF/dubbo-haoban-manage3-operation-web.xml

@@ -51,6 +51,9 @@
 	<dubbo:reference interface="com.gic.haoban.manage.api.service.HandoverOperationApiService"
 					 id="handoverOperationApiService"/>
 
+	<dubbo:reference interface="com.gic.haoban.manage.api.service.DealSyncOperationApiService"
+					 id="dealSyncOperationApiService"/>
+
 	<dubbo:reference interface="com.gic.sharing.core.service.api.service.MqApiService"
 					 id="mqApiService"/>