* bug fix

src/main/java/com/huiju/estateagents/controller/TaRecommendCustomerController.java

@@ -458,7 +458,6 @@ public class TaRecommendCustomerController extends BaseController {
         try {
             Integer orgId = getOrgId(request);
             return taRecommendCustomerService.batchConsultantAssist(taUser, orgId);
-
         } catch (Exception e) {
             e.printStackTrace();
             return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);

src/main/java/com/huiju/estateagents/service/impl/TaRecommendCustomerServiceImpl.java

@@ -1,5 +1,6 @@
 package com.huiju.estateagents.service.impl;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -508,9 +509,9 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
                 }
             }
             TaRecommendCustomer oldRecomendCustomer = result.get(0);
-            if (!StringUtils.isEmpty(oldRecomendCustomer.getRealtyConsultant())){
+            if (!StringUtils.isEmpty(oldRecomendCustomer.getRealtyConsultant())) {
                 return ResponseBean.error("您在当前项目的置业顾问是:" + conName, ResponseBean.ERROR_ILLEGAL_PARAMS);
-            }else {
+            } else {
                 oldRecomendCustomer.setRealtyConsultant(consultantUser.getUserId().toString());
                 taRecommendCustomerMapper.updateById(oldRecomendCustomer);
                 if (null != customerFrom) {
@@ -839,12 +840,19 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
 
     @Override
     public ResponseBean batchConsultantAssist(TaUser taUser, Integer orgId) {
+        Integer failNum = 0;
         if (CollectionUtils.isNotEmpty(taUser.getCustomerIds())) {
             for (TaRecommendCustomer taRecommendCustomer : taUser.getCustomerIds()) {
-                consultantAssist(taUser, taRecommendCustomer.getCustomerId(), orgId);
+                ResponseBean responseBean = consultantAssist(taUser, taRecommendCustomer.getCustomerId(), orgId);
+                if (responseBean.getCode() != 1000) {
+                    failNum++;
+                }
             }
         }
-        return ResponseBean.success("操作成功");
+        JSONObject obj = new JSONObject();
+        obj.put("failNum", failNum);
+        obj.put("totalNum", taUser.getCustomerIds().size());
+        return ResponseBean.success(obj);
     }
 
     @Override
@@ -898,7 +906,7 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
         TaRecommendCustomer customerInfo2 = taRecommendCustomerMapper.selectOne(customerQueryWrapper2);
         if (customerInfo2 != null) {
             logger.info("客户已在当前项目私客中，可以继续分配给其他项目");
-            responseBean.addError("分配客户失败");
+            responseBean.addError("客户已在当前项目私客中，可以继续分配给其他项目");
             return responseBean;
         }