Merge branch 'master' of http://git.ycjcjy.com/zhiyuxing/estateagents

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

                                                @RequestParam(value = "pageNum",defaultValue = "1")Integer pageNum,
                                                @RequestParam(value = "pageSize",defaultValue = "10")Integer pageSize,
                                                HttpServletRequest request){
-        ResponseBean  responseBean = iBuildingDynamicService.getWxBuildingDynamiceList(pageNum,pageSize,buildingId);
+        String openid = JWTUtils.getSubject(request);
+        ResponseBean  responseBean = iBuildingDynamicService.getWxBuildingDynamiceList(pageNum,pageSize,buildingId,openid);
         return responseBean;
     }
 
      */
     @RequestMapping(value = "/wx/buildingDynamiceInfo/{dynamicId}", method = RequestMethod.GET)
     public ResponseBean iBuildingDynamicInfo(@PathVariable(value = "dynamicId") String dynamicId,
-                                             @RequestParam("buildingId")Integer buildingId){
-        ResponseBean  responseBean = iBuildingDynamicService.getWxBuildingDynamiceInfo(dynamicId,buildingId);
+                                             @RequestParam("buildingId")Integer buildingId,
+                                             HttpServletRequest request){
+        String openid = JWTUtils.getSubject(request);
+        ResponseBean  responseBean = iBuildingDynamicService.getWxBuildingDynamiceInfo(dynamicId,buildingId,openid);
         return responseBean;
     }
 

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

 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.JWTUtils;
+import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.entity.TaPersonVisitRecord;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.service.ITaPersonVisitRecordService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.util.List;
+
 
 /**
  * <p>
 
     @Autowired
     public ITaPersonVisitRecordService iTaPersonVisitRecordService;
+    @Autowired
+    public ITaPersonService taPersonService;
 
 
     /**
      * @param taPersonVisitRecord 实体对象
      * @return
      */
-    @RequestMapping(value="/taPersonVisitRecord",method= RequestMethod.POST)
-    public ResponseBean taPersonVisitRecordAdd(@RequestBody TaPersonVisitRecord taPersonVisitRecord){
+    @RequestMapping(value="/wx/taPersonVisitRecord",method= RequestMethod.POST)
+    public ResponseBean taPersonVisitRecordAdd(@RequestBody TaPersonVisitRecord taPersonVisitRecord, HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
+        String openid = JWTUtils.getSubject(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        taPersonVisitRecord.setPersonId(person.getPersonId());
+        taPersonVisitRecord.setVisitTime(LocalDateTime.now());
         try {
             if (iTaPersonVisitRecordService.save(taPersonVisitRecord)){
                 responseBean.success(taPersonVisitRecord);
      * @param taPersonVisitRecord 实体对象
      * @return
      */
-    @RequestMapping(value="/taPersonVisitRecord/{id}",method= RequestMethod.PUT)
+    @RequestMapping(value="/wx/taPersonVisitRecord/{id}",method= RequestMethod.PUT)
     public ResponseBean taPersonVisitRecordUpdate(@PathVariable Integer id,
                                         @RequestBody TaPersonVisitRecord taPersonVisitRecord){
         ResponseBean responseBean = new ResponseBean();
+        taPersonVisitRecord.setLeaveTime(LocalDateTime.now());
+        taPersonVisitRecord.setRecordId(id);
+        Long duation = taPersonVisitRecord.getLeaveTime().atZone(ZoneOffset.UTC).toEpochSecond()-taPersonVisitRecord.getVisitTime().atZone(ZoneOffset.UTC).toEpochSecond();
+        taPersonVisitRecord.setVisitDuration(duation.intValue());
         try {
             if (iTaPersonVisitRecordService.updateById(taPersonVisitRecord)){
                 responseBean.success(taPersonVisitRecord);

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

 
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.JWTUtils;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaRecommendCustomer;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.service.ITaRecommendCustomerService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import com.huiju.estateagents.base.BaseController;
 
 import javax.servlet.http.HttpServletRequest;
+import java.util.List;
 
 /**
  * <p>
 
     @Autowired
     ITaRecommendCustomerService taRecommendCustomerService;
+    @Autowired
+    ITaPersonService taPersonService;
 
     /**
      * 我的客户列表
         String openid = JWTUtils.getSubject(request);
         return taRecommendCustomerService.recommendCust(paramStr, openid);
     }
+
+    @PostMapping("/wx/customer/recommend")
+    public ResponseBean getUnSignedCustomerList (@RequestParam int pageNumber, @RequestParam int pageSize,HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = JWTUtils.getSubject(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        String buildingId = "";
+        try{
+            responseBean.success(taRecommendCustomerService.getUnSignedCustomerList(pageNumber,pageSize,buildingId,person.getPersonId()));
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+        return responseBean;
+    }
+
+    @PostMapping("/customer/recommend")
+    public ResponseBean getCustomerList (@RequestParam int pageNumber, @RequestParam int pageSize){
+        ResponseBean responseBean = new ResponseBean();
+        try{
+            String buildingId="";
+            responseBean.success(taRecommendCustomerService.getCustomerList(pageNumber,pageSize,buildingId));
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+        return responseBean;
+    }
+
+    @PostMapping("/customer/recommend/{customerId}")
+    public ResponseBean getCustomersIRecommended (@RequestParam int pageNumber, @RequestParam int pageSize,String customerId){
+        ResponseBean responseBean = new ResponseBean();
+        String buildingId="";
+        try{
+            responseBean.success(taRecommendCustomerService.getCustomersIRecommended(pageNumber,pageSize,customerId,buildingId));
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+        return responseBean;
+    }
+
+        /**
+     * 修改对象
+     * @param taRecommendCustomer 实体对象
+     * @return
+     */
+    @RequestMapping(value="/wx/customer/recommend/edit/{id}",method= RequestMethod.PUT)
+    public ResponseBean taRecommendCustomerUpdateWx(@PathVariable String id,
+                                        @RequestBody TaRecommendCustomer taRecommendCustomer){
+        ResponseBean responseBean = new ResponseBean();
+        taRecommendCustomer.setCustomerId(id);
+        try {
+            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
+                responseBean.addSuccess(taRecommendCustomer);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+    /**
+     * 修改对象
+     * @param taRecommendCustomer 实体对象
+     * @return
+     */
+    @RequestMapping(value="/customer/recommend/edit/{id}",method= RequestMethod.PUT)
+    public ResponseBean taRecommendCustomerUpdate(@PathVariable String id,
+            @RequestBody TaRecommendCustomer taRecommendCustomer){
+        ResponseBean responseBean = new ResponseBean();
+        taRecommendCustomer.setCustomerId(id);
+        try {
+            if (taRecommendCustomerService.updateById(taRecommendCustomer)){
+                responseBean.addSuccess(taRecommendCustomer);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/wx/customer/recommend/get/{id}")
+    public ResponseBean getSingleCustomer(String customerId) {
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(taRecommendCustomerService.getById(customerId));
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    @RequestMapping(value = "/customer/recommend/get/{id}")
+    public ResponseBean getCutomerDetail(String id) {
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(taRecommendCustomerService.getCustomerDetail(id));
+        }catch (Exception e){
+            e.printStackTrace();
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

src/main/java/com/huiju/estateagents/entity/TaActivityDynamicEnlist.java

     /**
      * 报名ID
      */
-    @TableId(value = "favor_id", type = IdType.AUTO)
+    @TableId(value = "enlist_id", type = IdType.AUTO)
     private Integer enlist_id;
 
     /**
      * 活动ID
      */
-    private String dynamic_id;
+    private String dynamicId;
 
     /**
      * 姓名
     /**
      * 楼盘id
      */
-    private String building_id;
+    private String buildingId;
 
     /**
      * 创建时间
      */
     private String phone;
 
+    /**
+     * favor_num
+     */
+
 
 }

src/main/java/com/huiju/estateagents/entity/TaBuilding.java

      */
     private String poster;
 
+    private String buildingTransport;
+
+    private String buildingMall;
+
+    private String buildingEdu;
+
+    private String buildingHospital;
+
+    private String buildingBank;
+
+    private String buildingRestaurant;
+
 
     /**
      * 图片

src/main/java/com/huiju/estateagents/entity/TaBuildingApartment.java

 
     private String buildingArea;
 
+    private String apartmentPrice;
+
+    private String apartmentDescription;
 
     /**
      * 户型图片列表

src/main/java/com/huiju/estateagents/entity/TaBuildingDynamic.java

     @TableField(exist = false)
     private  int count;
 
+    /**
+     * 是否报名1为已报名,0为未报名
+     */
+    @TableField(exist = false)
+    private String isSing;
 
+    /**
+     * 分享活动
+     */
+    private int shareNum;
 
+    /**
+     * 阅读量
+     */
+    private  int pvNum;
+
+    /**
+     * 收藏量
+     */
+    private  int saveNum;
+
+    /**
+     * 点赞
+     */
+    private  int favorNum;
 }

src/main/java/com/huiju/estateagents/entity/TaPerson.java

     @TableField(exist = false)
     private LocalDateTime visitTime;
 
+    private String personTags;
+
+    private String personDescription;
+
+    private String gender;
+
+    private String unionId;
+
+    private String country;
+
+    private String province;
+
+    private String city;
+
+    private String language;
+
+
 }

src/main/java/com/huiju/estateagents/entity/TaRecommendCustomer.java

 
 import java.time.LocalDateTime;
 import java.io.Serializable;
+import java.util.List;
 import java.util.Map;
 
 import com.baomidou.mybatisplus.annotation.IdType;
      * 服务顾问
      */
     @TableField(exist = false)
-    private Map<String, Object> consultant;
+    private Map<String, Object> consultants;
+
+    private String verifyStatus;
+
+    private String verifyRemark;
+
+    private String country;
+
+    private String province;
+
+    private String city;
+
+    @TableField(exist = false)
+    private List<TaPersonVisitRecord> visitRecords;
+
+    @TableField(exist = false)
+    private List<String> projects;
+
+    @TableField(exist = false)
+    private Integer duration;
+
+    @TableField(exist = false)
+    private LocalDateTime visitTime;
+
+    @TableField(exist = false)
+    private TaPerson consultant;
 }

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

      */
     @Update("UPDATE ta_building_dynamic  SET ${field} = IFNULL(${field}, 0) + #{increment}  WHERE dynamic_id = #{newsId}")
     void setFieldNum(@Param("newsId") String newsId, @Param("field") String field, @Param("increment") int increment);
+
+    void updateTaBuildingDynamic(@Param("dynamicId") String dynamicId, @Param("sum") String sum);
 }

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

     IPage<TaPerson> selectCustomer(IPage<TaPerson> page);
 
     TaPerson getById(@Param("personId") String personId);
+
+
+    List<String>getUserProjects(@Param("personId") String personId);
+
+    TaPerson selectByIdPerson(@Param("openid") String openid);
+
 }

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

  */
 @Mapper
 public interface TaPersonVisitRecordMapper extends BaseMapper<TaPersonVisitRecord> {
-//    List<TaPersonVisitRecord>visitRecordByPersonId(@Param("personId") String personId);
+    List<TaPersonVisitRecord>visitRecordByPersonId(@Param("personId") String personId);
 
 
 }

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

 public interface TaRecommendCustomerMapper extends BaseMapper<TaRecommendCustomer> {
 
     Integer getMyCutsomerNum(@Param("personId") String personId);
+
+    String getCustomerPersonId(@Param("customerId")String customerId);
+
+    TaRecommendCustomer getCustomerDetail(@Param("customerId")String customerId);
+
+
 }

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

      * 微信小程序 项目动态管理列表
      * @return
      */
-    ResponseBean getWxBuildingDynamiceList(Integer pageNum, Integer pageSize,Integer buildingId);
+    ResponseBean getWxBuildingDynamiceList(Integer pageNum, Integer pageSize,Integer buildingId,String openid);
 
     /**
      * 微信小程序 项目详情
      * @param dynamicId
      * @return
      */
-    ResponseBean getWxBuildingDynamiceInfo(String dynamicId,Integer buildingId);
+    ResponseBean getWxBuildingDynamiceInfo(String dynamicId,Integer buildingId,String openid);
 
     /**
      * 动态管理添加

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

     Map<String,Object> getExtraInfo(String personId);
 
     List<TaPerson> getPersonsByOpenId(String openid);
+
+    IPage<TaPerson> getDriftCustomerList (int pageNumber, int pageSize,String building);
 }

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

 package com.huiju.estateagents.service;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.TaRecommendCustomer;
 import com.baomidou.mybatisplus.extension.service.IService;
     ResponseBean updateCustByJSON(String paramStr);
 
     ResponseBean recommendCust(String paramStr, String openid);
+
+    IPage<TaRecommendCustomer> getUnSignedCustomerList(int pageNumber, int pageSize, String building,String personId);
+
+    IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize, String building);
+
+    TaRecommendCustomer getCustomerDetail(String customerId);
+
+    IPage<TaRecommendCustomer>getCustomersIRecommended(int pageNumber, int pageSize,String customerId,String building);
+
+
 }

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

 import com.huiju.estateagents.entity.TaActivityDynamicEnlist;
 import com.huiju.estateagents.entity.TaBuilding;
 import com.huiju.estateagents.entity.TaBuildingDynamic;
+import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.mapper.TaActivityDynamicEnlistMapper;
 import com.huiju.estateagents.mapper.TaBuildingDynamicMapper;
 import com.huiju.estateagents.mapper.TaBuildingMapper;
+import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.service.ITaBuildingDynamicService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.propertyeditors.CustomDateEditor;
     @Autowired
     private TaActivityDynamicEnlistMapper taActivityDynamicEnlistMapper;
 
+    @Autowired
+    private TaPersonMapper taPersonMapper;
+
 
     protected void initBinder(HttpServletRequest request, ServletRequestDataBinder binder) throws Exception {
         DateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
     }
 
     @Override
-    public ResponseBean getWxBuildingDynamiceList(Integer pageNum, Integer pageSize,Integer buildingId) {
+    public ResponseBean getWxBuildingDynamiceList(Integer pageNum, Integer pageSize,Integer buildingId,String openid) {
         Page<TaBuildingDynamic> page = new Page<>();
         page.setCurrent(pageNum);
         page.setSize(pageSize);
         List<TaBuildingDynamic> records = buildingDynamicIPage.getRecords();
         // 判断换当前列表活动状态—1:进行中(展示活动报名截止时间)，2:未开始（展示活动报名时间）,3:结束（不展示）
         for (TaBuildingDynamic taBuildingDynamic:records){
+            QueryWrapper<TaActivityDynamicEnlist> activityDynamicEnlist = new QueryWrapper<>();
+            TaPerson taPerson = taPersonMapper.selectByIdPerson(openid);
+            if (null == taPerson){
+                return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+            }
+            activityDynamicEnlist.eq("phone", taPerson.getPhone());
+            TaActivityDynamicEnlist taActivityDynamicEnlistPhone= taActivityDynamicEnlistMapper.selectOne(activityDynamicEnlist);
+            if (null == taActivityDynamicEnlistPhone){
+                taBuildingDynamic.setIsSing("1");
+            }
             // 获取当前时间状态
             taBuildingDynamic= timeCondition(taBuildingDynamic);
         }
     }
 
     @Override
-    public ResponseBean getWxBuildingDynamiceInfo(String dynamicId,Integer buildingId) {
+    public ResponseBean getWxBuildingDynamiceInfo(String dynamicId,Integer buildingId,String openid) {
+
         QueryWrapper<TaBuildingDynamic> buildingDynamicQueryWrapper = new QueryWrapper<>();
         buildingDynamicQueryWrapper.eq("dynamic_id", dynamicId);
         buildingDynamicQueryWrapper.eq("status",1);
+        TaBuildingDynamic tabuildingDynamic = buildingDynamicMapper.selectOne(buildingDynamicQueryWrapper);
+        // 当前阅读量加1
+
+        buildingDynamicMapper.updateById( tabuildingDynamic.setSaveNum(tabuildingDynamic.getSaveNum()+1));
         TaBuildingDynamic buildingDynamic = buildingDynamicMapper.selectOne(buildingDynamicQueryWrapper);
+        TaPerson taPerson = taPersonMapper.selectByIdPerson(openid);
+        if (null == taPerson){
+            return ResponseBean.error("验证当前人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        // 查询是否报名
+        QueryWrapper<TaActivityDynamicEnlist> activityDynamicEnlist = new QueryWrapper<>();
+        activityDynamicEnlist.eq("phone", taPerson.getPhone());
+        TaActivityDynamicEnlist taActivityDynamicEnlistPhone= taActivityDynamicEnlistMapper.selectOne(activityDynamicEnlist);
+        if (null == taActivityDynamicEnlistPhone){
+            buildingDynamic.setIsSing("1");
+        }
         // 获取报名总数
         QueryWrapper<TaActivityDynamicEnlist> taActivityDynamicEnlist = new QueryWrapper<>();
         taActivityDynamicEnlist.eq("dynamic_id", dynamicId);
         buildingDynamic.setCount(applyCount);
         // 获取当前时间状态
         buildingDynamic = timeCondition(buildingDynamic);
+
         return ResponseBean.success(buildingDynamic);
     }
 
     @Override
     public ResponseBean taActivityDynamicEnlistAdd(TaActivityDynamicEnlist taActivityDynamicEnlist) {
         // 查询当前活动属于哪个楼盘
-        TaBuildingDynamic taBuildingDynamic= buildingDynamicMapper.iBuildingDynamicSelectId(taActivityDynamicEnlist.getDynamic_id());
+        TaBuildingDynamic taBuildingDynamic= buildingDynamicMapper.iBuildingDynamicSelectId(taActivityDynamicEnlist.getDynamicId());
         taActivityDynamicEnlist.setCreateDate(LocalDateTime.now())
-                               .setBuilding_id(taBuildingDynamic.getDynamicId());
+                               .setBuildingId(taBuildingDynamic.getDynamicId());
         int state = taActivityDynamicEnlistMapper.insert(taActivityDynamicEnlist);
         return ResponseBean.success(state);
     }

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

         result.put("unReadNum", 0);
         result.put("projects", buildings);
         result.put("address", person.getAddress());
+        result.put("personTags",person.getPersonTags());
 
         // 当前人员
         List<TaPerson> taPersonList = getPersonsByOpenId(openid);
         queryWrapper.eq("person_id", personId);
         return taPersonBuildingMapper.selectList(queryWrapper);
     }
+
+    @Override
+    public IPage<TaPerson> getDriftCustomerList (int pageNumber, int pageSize,String building){
+        QueryWrapper<TaPerson> queryWrapper = new QueryWrapper<>();
+        queryWrapper.isNull("person_type");
+        queryWrapper.eq("building_id",building);
+        IPage<TaPerson> page = new Page<>(pageNumber, pageSize);
+        return taPersonMapper.selectPage(page,queryWrapper);
+    }
 }

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

 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;
 import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.entity.TaRecommendCustomer;
 import com.huiju.estateagents.mapper.TaPersonMapper;
+import com.huiju.estateagents.mapper.TaPersonVisitRecordMapper;
 import com.huiju.estateagents.mapper.TaRecommendCustomerMapper;
 import com.huiju.estateagents.service.IMiniAppService;
 import com.huiju.estateagents.service.ITaRecommendCustomerService;
     @Autowired
     IMiniAppService iMiniAppService;
 
+    @Autowired
+    TaPersonVisitRecordMapper taPersonVisitRecordMapper;
+
     @Override
     public ResponseBean getMyCustList(String openid, String keywords, int pageNumber, int pageSize) {
         List<TaPerson> taPersons = getPersonsByOpenId(openid);
         if (!StringUtils.isEmpty(taRecommendCustomer.getRealtyConsultant())) {
             TaPerson taPerson = taPersonMapper.selectById(taRecommendCustomer.getRealtyConsultant());
             if (null != taPerson) {
-                taRecommendCustomer.setConsultant(new HashMap<String, Object>() {{
+                taRecommendCustomer.setConsultants(new HashMap<String, Object>() {{
                     put("name", taPerson.getName());
                     put("phone", taPerson.getTel());
                     put("photo", taPerson.getPhoto());
     }
 
 
+
+
     List<TaPerson> getPersonsByOpenId(String openid) {
         return taPersonMapper.getPersonByOpenId(openid);
     }
+
+    @Override
+    public IPage<TaRecommendCustomer> getUnSignedCustomerList(int pageNumber, int pageSize,String building,String personId){
+        QueryWrapper<TaRecommendCustomer>queryWrapper = new QueryWrapper<>();
+//        queryWrapper.eq("building_id",building);
+        queryWrapper.eq("realty_consultant",personId);
+        queryWrapper.gt("status", CommConstant.MESSAGE_UNREAD);
+        IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);
+        return taRecommendCustomerMapper.selectPage(page,queryWrapper);
+    }
+
+    @Override
+    public IPage<TaRecommendCustomer> getCustomerList(int pageNumber, int pageSize,String building){
+        QueryWrapper<TaRecommendCustomer>queryWrapper = new QueryWrapper<>();
+//        queryWrapper.eq("building_id",building);
+        queryWrapper.gt("status", CommConstant.MESSAGE_UNREAD);
+        IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);
+        return taRecommendCustomerMapper.selectPage(page,queryWrapper);
+    }
+
+    @Override
+    public TaRecommendCustomer getCustomerDetail(String customerId){
+        String personId = taRecommendCustomerMapper.getCustomerPersonId(customerId);
+        TaRecommendCustomer taRecommendCustomer = taRecommendCustomerMapper.getCustomerDetail(customerId);
+        if(!personId.equals("")&& null != personId){
+            taRecommendCustomer.setVisitRecords(taPersonVisitRecordMapper.visitRecordByPersonId(personId));
+        }
+        if(!taRecommendCustomer.getRealtyConsultant().equals("")&&null != taRecommendCustomer.getRealtyConsultant()){
+            TaPerson consultant =  taPersonMapper.getById(taRecommendCustomer.getRealtyConsultant());
+            consultant.setProjects(taPersonMapper.getUserProjects(consultant.getPersonId()));
+            taRecommendCustomer.setConsultant(consultant);
+        }
+        return taRecommendCustomer;
+    }
+
+    @Override
+    public IPage<TaRecommendCustomer>getCustomersIRecommended(int pageNumber, int pageSize,String customerId,String building){
+        String personId = taRecommendCustomerMapper.getCustomerPersonId(customerId);
+        QueryWrapper<TaRecommendCustomer>queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("person_id",personId);
+//        queryWrapper.eq("building_id",building);
+        queryWrapper.gt("status", CommConstant.MESSAGE_UNREAD);
+        IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);
+        return taRecommendCustomerMapper.selectPage(page,queryWrapper);
+
+    }
 }

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

 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.common.StringUtils;
-import com.huiju.estateagents.entity.TaPerson;
-import com.huiju.estateagents.entity.TaPointsRecords;
-import com.huiju.estateagents.entity.TaShare;
-import com.huiju.estateagents.entity.TdPointsRules;
-import com.huiju.estateagents.mapper.TaPersonMapper;
-import com.huiju.estateagents.mapper.TaPointsRecordsMapper;
-import com.huiju.estateagents.mapper.TaShareMapper;
-import com.huiju.estateagents.mapper.TdPointsRulesMapper;
+import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.mapper.*;
 import com.huiju.estateagents.service.ITaShareService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
     @Autowired
     private TaPointsRecordsMapper taPointsRecordsMapper;
 
+    @Autowired
+    private TaBuildingDynamicMapper taBuildingDynamicMapper;
+
     @Override
     public ResponseBean saveData(String openid, String typeOf, String id) {
         List<TaPerson> persons = getPersonsByOpenId(openid);
         }
 
         TaPerson taPerson = persons.get(0);
+        // 如果是分享活动, 则活动 + 1
+        if (typeOf.equals(CommConstant.FAVOR_ACTIVITY)) {
+            QueryWrapper<TaBuildingDynamic> taBuildingDynamicQuery= new QueryWrapper<>();
+            taBuildingDynamicQuery.eq("dynamic_id",id);
+            TaBuildingDynamic taBuildingDynamic = taBuildingDynamicMapper.selectOne(taBuildingDynamicQuery);
+            taBuildingDynamicMapper.updateById( taBuildingDynamic.setShareNum(taBuildingDynamic.getShareNum()+1));
+            return ResponseBean.success("成功");
+        }
 
         QueryWrapper<TaShare> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("person_id", taPerson.getPersonId());
             wrapper.setSql("points = IFNULL(points, 0) + " + String.valueOf(tdPointsRules.getPointsAmount()));
             taPersonMapper.update(new TaPerson(), wrapper);
         }
-
         return ResponseBean.success("");
     }
 

src/main/resources/mapper/TaBuildingDynamicMapper.xml

         </set>
         where dynamic_id = #{dynamicId,jdbcType=VARCHAR}
     </update>
+    <select id="updateTaBuildingDynamic">
+        UPDATE ta_building_dynamic
+        SET  share_num = #{sum}
+        WHERE
+	      dynamic_id = #{dynamicId}
+    </select>
 
 </mapper>

src/main/resources/mapper/TaPersonMapper.xml

 WHERE
 	a.person_id = #{personId}
     </select>
+
+    <select id="getUserProjects" resultType="java.lang.String">
+        SELECT
+	b.building_name
+FROM
+	ta_person_building a
+	LEFT JOIN ta_building b ON a.building_id = b.building_id
+	WHERE a.person_id = #{personId}
+    </select>
+
+    <select id="selectByIdPerson" resultType="com.huiju.estateagents.entity.TaPerson">
+        select * from ta_person where mini_openid = #{openid};
+
+    </select>
 </mapper>

src/main/resources/mapper/TaRecommendCustomerMapper.xml

         WHERE
             t.person_id = #{personId}
     </select>
+    <select id="getCustomerPersonId" resultType="java.lang.String">
+        SELECT
+	person_id
+FROM
+	ta_customer_person
+WHERE
+	customer_id = #{customerId}
+    </select>
+
+    <select id="getCustomerDetail" resultType="com.huiju.estateagents.entity.TaRecommendCustomer">
+        SELECT
+	a.*,
+	(select c.visit_time FROM ta_person_visit_record c where b.person_id = c.person_id ORDER BY c.visit_time desc LIMIT 1) as visitTime,
+	(SELECT SUM(d.visit_duration) FROM ta_person_visit_record d WHERE b.person_id = d.person_id) as duration
+FROM
+	ta_recommend_customer a
+	LEFT JOIN ta_customer_person b on a.customer_id = b.customer_id
+	LEFT JOIN ta_person_visit_record c ON b.person_id = c.person_id
+	where a.customer_id = #{customerId}
+    </select>
 </mapper>