feats

src/main/java/com/yunzhi/marketing/controller/TaRecommendCustomerController.java

 import com.yunzhi.marketing.dto.ChannelReportDTO;
 import com.yunzhi.marketing.entity.TaBuilding;
 import com.yunzhi.marketing.entity.TaPerson;
+import com.yunzhi.marketing.entity.TaPersonBuilding;
 import com.yunzhi.marketing.entity.TaRecommendCustomer;
 import com.yunzhi.marketing.event.EventBus;
 import com.yunzhi.marketing.excel.handler.CustomCellWriteHandler;
         return taRecommendCustomerService.reportCust(paramStr, openid, orgId);
     }
 
+    /**
+     * 置业顾问手动报备客户
+     * @param reportCust
+     * @param request
+     * @return
+     */
+    @PostMapping("/wx/customer/manualReport")
+    public ResponseBean manualReport(@RequestBody ChannelReportDTO reportCust, HttpServletRequest request) {
+        Integer orgId = getOrgId(request);
+        String personId = getPersonId(request);
+        TaPerson taPerson = taPersonService.getById(personId);
+        if (null == taPerson) {
+            return ResponseBean.error("校验人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        if (!CommConstant.PERSON_REALTY_CONSULTANT.equals(taPerson.getPersonType())) {
+            return ResponseBean.error("暂时只支持置业顾问报备", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        // 客户电话
+        String phone = reportCust.getPhone();
+        if (StringUtils.isEmpty(phone)) {
+            return ResponseBean.error("请填写客户电话", ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        try {
+            taRecommendCustomerService.manualReport(orgId, taPerson, reportCust);
+            return ResponseBean.success("报备成功");
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
 
     /**
      * 顾客列表

src/main/java/com/yunzhi/marketing/service/ITaRecommendCustomerService.java

      * @return
      */
     ResponseBean getMarkingCustList(String openid, String keywords, int pageNumber, int pageSize, String buildingId);
+
+    void manualReport(Integer orgId, TaPerson consultant, ChannelReportDTO reportCust) throws Exception;
 }

src/main/java/com/yunzhi/marketing/service/impl/TaRecommendCustomerServiceImpl.java

         return ResponseBean.success(result);
     }
 
+    @Override
+    public void manualReport(Integer orgId, TaPerson consultant, ChannelReportDTO reportCust) throws Exception {
+        TaRecommendCustomer recommendCustomer;
+        TaCustomerFrom customerFrom = new TaCustomerFrom();
+        String phone = reportCust.getPhone();
+        String consultantUser = consultant.getUserId().toString();
+
+        // 客户对应人员
+        QueryWrapper<TaPerson> query1 = new QueryWrapper<>();
+        query1.eq("org_id", orgId);
+        query1.eq("phone", phone);
+        TaPerson custPerson = taPersonMapper.selectOne(query1);
+        if (null != custPerson) {
+            if (CommConstant.PERSON_REALTY_CONSULTANT.equals(custPerson.getPersonType())) {
+                throw new Exception("置业顾问不可以绑定置业顾问");
+            }
+        }
+
+        // 查询置业授权的楼盘
+        QueryWrapper<TaPersonBuilding> query2 = new QueryWrapper<>();
+        query2.eq("user_id", consultant.getUserId());
+        List<TaPersonBuilding> taPersonBuildingList = taPersonBuildingMapper.selectList(query2);
+        if (taPersonBuildingList.size() < 1) {
+            throw new Exception("置业未绑定楼盘");
+        }
+        TaPersonBuilding taPersonBuilding = taPersonBuildingList.get(0);
+
+        // 查询楼盘下是否有该客户
+        QueryWrapper<TaRecommendCustomer> query3 = new QueryWrapper<>();
+        query3.eq("phone", phone);
+        query3.eq("building_id", taPersonBuilding.getBuildingId());
+        query3.eq("org_id", orgId);
+        List<TaRecommendCustomer> lst = list(query3);
+        if (lst.size() > 0) {
+            TaRecommendCustomer orign = lst.get(0);
+            if (!StringUtils.isEmpty(orign.getRealtyConsultant())) {
+                // 如果当前人员已经是当前置业的私客
+                if (orign.getRealtyConsultant().equals(consultantUser)) {
+                    return;
+                } else {
+                    throw new Exception("当前人员是其他置业的私客");
+                }
+            } else {
+                // 如果是项目公客, 则直接绑定为当前置业的私客
+                orign.setRealtyConsultant(consultantUser);
+                orign.setVerifyStatus(CommConstant.VERIFY_AGREE);
+                orign.setStatus(CommConstant.CUSTOMER_REPORT);
+                orign.setEntryType(CommConstant.ENTRY_INPUT);
+                orign.setReportDate(LocalDateTime.now());
+                recommendCustomer = orign;
+//                updateById(orign);
+//                return;
+            }
+        } else {
+            // 如果表中无此人员数据
+            recommendCustomer = new TaRecommendCustomer();
+
+            recommendCustomer.setOrgId(orgId);
+            recommendCustomer.setName(reportCust.getName());
+            recommendCustomer.setPicture(null != custPerson ? custPerson.getAvatarurl() : null);
+            recommendCustomer.setPhone(phone);
+            recommendCustomer.setSex(reportCust.getSex());
+            recommendCustomer.setRealtyConsultant(consultantUser);
+            recommendCustomer.setBuildingId(taPersonBuilding.getBuildingId());
+            TaBuilding building = taBuildingMapper.selectById(taPersonBuilding.getBuildingId());
+            recommendCustomer.setIntention(building.getBuildingName());
+            recommendCustomer.setReportRecommendStatus(CommConstant.VERIFY_AGREE);
+            recommendCustomer.setCreateDate(LocalDateTime.now());
+            recommendCustomer.setReportDate(LocalDateTime.now());
+            recommendCustomer.setPersonId(null != custPerson ? custPerson.getPersonId() : null);
+            recommendCustomer.setEntryType(CommConstant.ENTRY_INPUT);
+            recommendCustomer.setVerifyStatus(CommConstant.VERIFY_AGREE);
+            recommendCustomer.setStatus(CommConstant.CUSTOMER_REPORT);
+            recommendCustomer.setRecommendPerson(consultant.getPersonId());
+            customerFrom.setIsProjectFirst(true);
+            customerFrom.setIsOrgFirst(true);
+        }
+
+        if (StringUtils.isEmpty(recommendCustomer.getCustomerId())) {
+            if (!save(recommendCustomer)) {
+                throw new Exception("报备客户异常, 请重试");
+            }
+        } else {
+            if (!updateById(recommendCustomer)) {
+                throw new Exception("报备客户异常, 请重试");
+            }
+        }
+
+        customerFrom.setPersonId(recommendCustomer.getPersonId());
+        customerFrom.setCustomerId(recommendCustomer.getCustomerId());
+        customerFrom.setPersonName(recommendCustomer.getName());
+        customerFrom.setOrgId(recommendCustomer.getOrgId());
+        customerFrom.setCreateDate(LocalDateTime.now());
+        customerFrom.setBuildingId(recommendCustomer.getBuildingId());
+        customerFrom.setBuildingName(recommendCustomer.getIntention());
+        customerFrom.setSharePersonId(consultant.getPersonId());
+        customerFrom.setSharePersonName(consultant.getName());
+
+        taCustomerFromMapper.insert(customerFrom);
+        return;
+    }
+
     private void fillSomeFieldsOfCustomer(TaRecommendCustomer customer, TaPerson recommender, LocalDateTime now) {
         customer.setVerifyStatus(CommConstant.VERIFY_AGREE);
         customer.setStatus(CommConstant.CUSTOMER_REPORT);