客户基本信息

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

@@ -749,5 +749,60 @@ public class TaRecommendCustomerController extends BaseController {
 
 
     }
-
+    
+    /**
+     * 查询判客工具下的我的客户人数集合
+     * @param request
+     * @return
+     */
+    @GetMapping("/wx/inventory/customer/statistics")
+    @ApiOperation(value = "查询我的客户人数统计", notes = "查询我的客户人数统计")
+    public ResponseBean getMyCustStatistics(HttpServletRequest request) {
+        String openid = getOpenId(request);
+        return taRecommendCustomerService.getMyCustStatistics(openid);
+    }
+    
+    /**
+     * 分页查询判客工具下的我的客户跟进人集合
+     *  根据type区分  follow 跟进  clinch 成交
+     * @param request
+     * @return
+     */
+    @GetMapping("/wx/inventory/customer/{type}")
+    @ApiOperation(value = "查询我的客户人数统计", notes = "查询我的客户人数统计")
+    public ResponseBean getMyCustFollows(@PathVariable(value = "type") String type,
+                                         @RequestParam(value = "pageNumber",defaultValue = "0") Integer pageNumber,
+                                         @RequestParam(value = "pageSize",defaultValue = "10") Integer pageSize,
+                                         @RequestParam(value = "name",required = false) String name,
+                                         @RequestParam(value = "phone",required = false) String phone,
+                                         @RequestParam(value = "status",required = false) Integer status,HttpServletRequest request) {
+        String openid = getOpenId(request);
+        return taRecommendCustomerService.getMyCustFollowOrClinch(pageNumber,pageSize,openid,type,name,phone,status);
+    }
+    
+    /**
+     * 查询盘客工具下我的客户详情
+     * @param request
+     * @return
+     */
+    @GetMapping("/wx/inventory/customer/{customerId}")
+    @ApiOperation(value = "查询客户详情", notes = "查询客户详情")
+    public ResponseBean getMyCustDetail(@PathVariable(value = "customerId") String customerId,HttpServletRequest request) {
+        String openid = getOpenId(request);
+        return taRecommendCustomerService.getMyCustDetail(customerId,openid);
+    }
+    
+    /**
+     * 查询盘客工具下编辑基本信息
+     * @param request
+     * @return
+     */
+    @PutMapping("/wx/inventory/customer/{customerId}")
+    @ApiOperation(value = "编辑客户信息", notes = "编辑客户信息")
+    public ResponseBean updateMyCustDetail(@PathVariable(value = "customerId") String customerId,
+                                           @RequestBody TaRecommendCustomer taRecommendCustomer, HttpServletRequest request) {
+        String openid = getOpenId(request);
+        taRecommendCustomer.setCustomerId(customerId);
+        return taRecommendCustomerService.updateMyCust(taRecommendCustomer,openid);
+    }
 }

src/main/java/com/huiju/estateagents/mapper/TaRecommendCustomerMapper.java

@@ -9,6 +9,7 @@ import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * <p>
@@ -149,5 +150,33 @@ public interface TaRecommendCustomerMapper extends BaseMapper<TaRecommendCustome
      * @return
      */
     List<PrivateCustomerExport> getCustomerExportList(@Param("pageCode") Integer pageCode, @Param("pageSize") Integer pageSize, @Param("building") String buildingId, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel, @Param("entryType") String entryType, @Param("verifyStatus") String verifyStatus, @Param("sex") Integer sex, @Param("orgId") Integer orgId, @Param("status")Integer status);
-
+    
+    /**
+     * 获取我的客户的人数统计
+     * @param personId
+     * @param userId
+     * @return
+     */
+	List<Map<String, Object>> getMyCustStatistics(@Param("personId") String personId,@Param("userId") Integer userId,@Param("orgId") Integer orgId);
+    
+    /**
+     * 获取我的跟进客户数据
+     * @param page
+     * @param personId
+     * @param userId
+     * @param orgId
+     * @param type
+     * @param name
+     * @param phone
+     * @param status
+     * @return
+     */
+    IPage<TaRecommendCustomer> getMyCustFollowOrClinch(IPage<TaRecommendCustomer> page, @Param("personId") String personId, @Param("userId") Integer userId, @Param("orgId") Integer orgId, @Param("type") String type, @Param("name") String name, @Param("phone") String phone,@Param("status") Integer status);
+    
+    /**
+     * 获取我的客户详情数据
+     * @param customerId
+     * @return
+     */
+    TaRecommendCustomer getMyCustDetailById(String customerId);
 }

src/main/java/com/huiju/estateagents/service/ITaRecommendCustomerService.java

@@ -95,5 +95,39 @@ public interface ITaRecommendCustomerService extends IService<TaRecommendCustome
      * @return
      */
     List<AgentsRecommendCustomer> getIndependentAgentsExport(Integer orgId, Integer pageCode, Integer pageSize);
-
+    
+    /**
+     * 查询我的客户人数集合
+     * @param openid
+     * @return
+     */
+    ResponseBean getMyCustStatistics(String openid);
+    
+    /**
+     * 分页查询我的跟进客户集合
+     * @param pageNumber
+     * @param pageSize
+     * @param openid
+     * @param name
+     * @param phone
+     * @param status
+     * @return
+     */
+    ResponseBean getMyCustFollowOrClinch(Integer pageNumber, Integer pageSize, String openid, String type, String name, String phone, Integer status);
+    
+    /**
+     * 获取盘客工具下我的客户详情
+     * @param customerId
+     * @param openid
+     * @return
+     */
+    ResponseBean getMyCustDetail(String customerId, String openid);
+    
+    /**
+     * 更新我的客户基本信息
+     * @param taRecommendCustomer
+     * @param openid
+     * @return
+     */
+    ResponseBean updateMyCust(TaRecommendCustomer taRecommendCustomer, String openid);
 }

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

@@ -1,6 +1,5 @@
 package com.huiju.estateagents.service.impl;
 
-import ch.qos.logback.core.status.StatusUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
@@ -23,10 +22,11 @@ import com.huiju.estateagents.mapper.*;
 import com.huiju.estateagents.service.IMiniAppService;
 import com.huiju.estateagents.service.ITaRecommendCustomerService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.statistic.entity.TaCustomerFollowUpRecord;
+import com.huiju.estateagents.statistic.mapper.TaCustomerFollowUpRecordMapper;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
-import javax.naming.spi.ResolveResult;
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.List;
@@ -63,6 +63,9 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
 
     @Autowired
     private TdCityMapper cityMapper;
+    
+    @Autowired
+    private TaCustomerFollowUpRecordMapper customerFollowUpRecordMapper;
 
     @Override
     public ResponseBean getMyCustList(String openid, String keywords, int pageNumber, int pageSize) {
@@ -579,4 +582,105 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
     public List<AgentsRecommendCustomer> getIndependentAgentsExport(Integer orgId, Integer pageCode, Integer pageSize) {
         return taRecommendCustomerMapper.getIndependentAgentsExport(orgId, pageCode, pageSize);
     }
+    
+    /**
+     * 查询我的客户人数集合
+     *
+     * @param openid
+     * @return
+     */
+    @Override
+    public ResponseBean getMyCustStatistics(String openid) {
+        List<TaPerson> taPersons = getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    
+        TaPerson taPerson = taPersons.get(0);
+        List<Map<String,Object>> list = taRecommendCustomerMapper.getMyCustStatistics(taPerson.getPersonId(),taPerson.getUserId(),taPerson.getOrgId());
+        return ResponseBean.success(list);
+    }
+    
+    /**
+     * 分页查询我的跟进客户集合
+     *
+     * @param pageNumber
+     * @param pageSize
+     * @param openid
+     * @param name
+     * @param phone
+     * @param status
+     * @return
+     */
+    @Override
+    public ResponseBean getMyCustFollowOrClinch(Integer pageNumber, Integer pageSize, String openid, String type, String name, String phone, Integer status) {
+        List<TaPerson> taPersons = getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    
+        TaPerson taPerson = taPersons.get(0);
+        
+        IPage<TaRecommendCustomer> page = new Page<>();
+        page.setCurrent(pageNumber);
+        page.setSize(pageSize);
+        
+        //分页获取跟进客户status != 4的为跟进客户， status = 4的为成交客户 根据type区分  follow 跟进  clinch 成交
+        IPage<TaRecommendCustomer> result = taRecommendCustomerMapper.getMyCustFollowOrClinch(page, taPerson.getPersonId(),taPerson.getUserId(),taPerson.getOrgId(), type,name,phone,status);
+        return ResponseBean.success(result);
+    }
+    
+    /**
+     * 获取盘客工具下我的客户详情
+     *
+     * @param customerId
+     * @param openid
+     * @return
+     */
+    @Override
+    public ResponseBean getMyCustDetail(String customerId, String openid) {
+        List<TaPerson> taPersons = getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    
+        TaPerson taPerson = taPersons.get(0);
+        TaRecommendCustomer taRecommendCustomer = taRecommendCustomerMapper.getMyCustDetailById(customerId);
+        //添加跟进行为
+        addCustomerFpllowUp(taPerson,taRecommendCustomer,"查看客户详情");
+        return ResponseBean.success(taRecommendCustomer);
+    }
+    
+    /**
+     * 更新我的客户基本信息
+     *
+     * @param taRecommendCustomer
+     * @param openid
+     * @return
+     */
+    @Override
+    public ResponseBean updateMyCust(TaRecommendCustomer taRecommendCustomer, String openid) {
+        List<TaPerson> taPersons = getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+    
+        TaPerson taPerson = taPersons.get(0);
+        taRecommendCustomerMapper.updateById(taRecommendCustomer);
+        //添加跟进行为
+        addCustomerFpllowUp(taPerson,taRecommendCustomer,"编辑客户信息");
+        return ResponseBean.success(taRecommendCustomer);
+    }
+    
+    //添加跟进行为
+    private void addCustomerFpllowUp(TaPerson taPerson,TaRecommendCustomer taRecommendCustomer,String recordType) {
+        TaCustomerFollowUpRecord taCustomerFollowUpRecord = new TaCustomerFollowUpRecord();
+        taCustomerFollowUpRecord.setOrgId(taPerson.getOrgId());
+        taCustomerFollowUpRecord.setCreateDate(LocalDateTime.now());
+        taCustomerFollowUpRecord.setCustomerId(taRecommendCustomer.getCustomerId());
+        taCustomerFollowUpRecord.setRecordType(recordType);
+        taCustomerFollowUpRecord.setFollowerId(taPerson.getPersonId());
+        taCustomerFollowUpRecord.setCustomerSex(taRecommendCustomer.getSex());
+        customerFollowUpRecordMapper.insert(taCustomerFollowUpRecord);
+    }
 }

src/main/java/com/huiju/estateagents/statistic/entity/TaCustomerFollowUpRecord.java

@@ -58,7 +58,7 @@ public class TaCustomerFollowUpRecord implements Serializable {
     /**
      * 跟进人ID
      */
-    private Integer followerId;
+    private String followerId;
     
     /**
      * 客户性别

src/main/resources/mapper/TaRecommendCustomerMapper.xml

@@ -606,4 +606,47 @@ FROM
         limit #{pageCode}, #{pageSize}
     </select>
 
+    <select id="getMyCustStatistics" resultType="java.util.Map">
+        SELECT
+            sum( IF ( STATUS = 4, 1, 0 ) ) AS followSum,
+            sum( IF ( STATUS != 4 AND STATUS != 4, 1, 0 ) ) AS clinchSum
+        FROM
+            ta_recommend_customer
+        WHERE
+            org_id = #{orgId}
+        AND ( realty_consultant = #{personId} OR realty_consultant = #{userId} )
+    </select>
+
+    <select id="getMyCustFollowOrClinch" resultType="com.huiju.estateagents.entity.TaRecommendCustomer">
+        SELECT
+            *
+        FROM
+            ta_recommend_customer
+        WHERE
+            org_id = #{orgId}
+        AND ( realty_consultant = #{personId} OR realty_consultant = #{userId} )
+        <if test="type == 'follow'">
+          AND STATUS != 4
+            <if test="name != null and name !=''">
+                and `name` like CONCAT('%',#{name}, '%')
+            </if>
+            <if test="phone != null and phone !=''">
+                and phone like CONCAT('%',#{phone}, '%')
+            </if>
+            <if test="status != null and status !=''">
+                and status = #{status}
+            </if>
+        </if>
+        <if test="type == 'clinch'">
+          AND STATUS = 4
+        </if>
+    </select>
+    <select id="getMyCustDetailById" resultType="com.huiju.estateagents.entity.TaRecommendCustomer">
+        SELECT
+            *
+        FROM
+            ta_recommend_customer
+        where customer_id = #{customerId}
+    </select>
+
 </mapper>