cid

fs-wx-task/src/main/java/com/fs/app/service/WxTaskService.java

@@ -16,6 +16,7 @@ import com.fs.company.service.ICompanyVoiceRoboticService;
 import com.fs.company.service.ICompanyWxAccountService;
 import com.fs.company.service.ICompanyWxClientService;
 import com.fs.company.service.ICompanyWxDialogService;
+import com.fs.company.service.impl.CompanyVoiceRoboticCalleesServiceImpl;
 import com.fs.company.service.impl.CompanyVoiceRoboticWxServiceImpl;
 import com.fs.company.util.ObjectPlaceholderResolver;
 import com.fs.company.vo.SendMsgVo;
@@ -59,6 +60,7 @@ public class WxTaskService {
     private final CompanyWxClientMapper companyWxClientMapper;
     private final CompanyVoiceRoboticWxServiceImpl companyVoiceRoboticWxServiceImpl;
     private final CompanyWxAccountMapper companyWxAccountMapper;
+    private final CompanyVoiceRoboticCalleesServiceImpl companyVoiceRoboticCalleesServiceImpl;
     private RedissonClient redissonClient;
 
     private final ExecutorService cidExcutor = new ThreadPoolExecutor(
@@ -163,6 +165,13 @@ public class WxTaskService {
                 StringBuilder sb = new StringBuilder(Constants.CID_NEXT_TASK_ID).append(callees.getRoboticId()).append(":").append(callees.getId());
                 redisCache.setCacheObject(sb.toString(), String.valueOf(endT),addWxTime + 5, TimeUnit.MINUTES);
             }
+            companyVoiceRoboticCallees.forEach(robotic ->
+                    robotic.setRunTaskFlow(
+                            StringUtils.isBlank(robotic.getRunTaskFlow()) ?
+                                    Constants.ADD_WX: robotic.getRunTaskFlow() +  Constants.ADD_WX
+                    )
+            );
+            companyVoiceRoboticCalleesServiceImpl.updateBatchById(companyVoiceRoboticCallees);
 
         }
         if(!addAccountList.isEmpty()){