重置 获客链接

fs-service/src/main/java/com/fs/qw/service/impl/QwAcquisitionAssistantServiceImpl.java

@@ -30,6 +30,9 @@ import com.fs.qw.service.IQwContactAcquisitionUserService;
 import com.fs.qw.utils.UniqueStringUtil;
 import com.fs.qw.vo.AcquisitionAssistantDetailVO;
 import com.fs.qwApi.config.QwApiConfig;
+import com.fs.qwApi.domain.QwResult;
+import com.fs.qwApi.param.QwLinkCreateParam;
+import com.fs.qwApi.service.QwApiService;
 import com.fs.wx.kf.service.IWeixinKfService;
 import com.fs.wx.kf.vo.WeixinKfTokenVO;
 import lombok.extern.slf4j.Slf4j;
@@ -80,6 +83,9 @@ public class QwAcquisitionAssistantServiceImpl implements IQwAcquisitionAssistan
     @Autowired
     private RedisTemplate redisTemplate;
 
+    @Autowired
+    private QwApiService qwApiService;
+
     // 获客链接管理-企微的ACCESS_TOKEN的key
     private static final String QW_ACQUISITION_KEY_PREFIX = "qw:acquisition:key:";
 
@@ -924,14 +930,28 @@ public class QwAcquisitionAssistantServiceImpl implements IQwAcquisitionAssistan
                         assistant.setUserList(com.alibaba.fastjson.JSON.toJSONString(restoredUserList));
                         assistant.setQwUserTableIdList(com.alibaba.fastjson.JSON.toJSONString(restoredQwUserTableIdList));
 
-                        acquisitionAssistantMapper.updateQwAcquisitionAssistant(assistant);
 
-                        Set<String> keys = redisTemplate.keys("qwAcquisition:" + assistant.getCorpId() + ":" + assistant.getLinkId() + ":*");
-                        if (keys != null && !keys.isEmpty()) {
-                            redisTemplate.delete(keys);
-                            log.info("已清除获客链接{}的Redis计数缓存，共{}个键", assistant.getLinkId(), keys.size());
+                        // 构建请求
+                        QwLinkCreateParam linkCreateParam=new QwLinkCreateParam();
+                        linkCreateParam.setLink_id(assistant.getLinkId());
+
+                        QwLinkCreateParam.Range range=new QwLinkCreateParam.Range();
+                        range.setUser_list(JSON.parseArray(assistant.getUserList(), String.class));
+                        linkCreateParam.setRange(range);
+
+                        //调用企微API
+                        QwResult qwResult = qwApiService.linkUpdate(linkCreateParam, assistant.getCorpId());
+                        if (qwResult.getErrcode() == 0) {
+                            acquisitionAssistantMapper.updateQwAcquisitionAssistant(assistant);
+                            restoredUserCount += restoredUserList.size();
+                            processedCount++;
+
+                        }else {
+                            log.error("修改渠道活码 失败！"+linkCreateParam+":"+qwResult.getErrmsg());
                         }
 
+
+
                         restoredUserCount += restoredUserList.size();
                         processedCount++;