customer&personMap

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

@@ -5,13 +5,18 @@ import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import cn.binarywang.wx.miniapp.bean.WxMaPhoneNumberInfo;
 import cn.binarywang.wx.miniapp.bean.WxMaUserInfo;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.common.WxUtils;
+import com.huiju.estateagents.entity.TaCustomerPerson;
 import com.huiju.estateagents.entity.TaMiniappQrcode;
 import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaRecommendCustomer;
 import com.huiju.estateagents.service.IMiniAppService;
+import com.huiju.estateagents.service.ITaCustomerPersonService;
 import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.common.JWTUtils;
+import com.huiju.estateagents.service.ITaRecommendCustomerService;
 import me.chanjar.weixin.common.error.WxErrorException;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.http.HttpStatus;
@@ -34,6 +39,14 @@ public class MiniAppController {
     @Autowired
     private IMiniAppService miniAppService;
 
+    @Autowired
+    private ITaRecommendCustomerService taRecommendCustomerService;
+
+    @Autowired
+    private ITaCustomerPersonService taCustomerPersonService;
+
+
+
     /**
      * 验证接入
      */
@@ -173,7 +186,37 @@ public class MiniAppController {
 
         // 更新用户绑定手机
         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);
+        QueryWrapper<TaRecommendCustomer> cus= new QueryWrapper<>();
+        cus.eq("phone",phoneNoInfo.getPhoneNumber());
+        List<TaRecommendCustomer> customer = taRecommendCustomerService.list(cus);
         taPersonService.updatePersonPhone(openid, phoneNoInfo.getPhoneNumber());
+        if (customer.size()>0){
+            TaRecommendCustomer customers = customer.get(0);
+            person.setRecommendPerson(customers.getRecommendPerson());
+            TaPerson recommender = taPersonService.getById(customers.getRecommendPerson());
+            person.setRecommendPersonType(recommender.getPersonType());
+            QueryWrapper<TaCustomerPerson> customerPersonQueryWrapper = new QueryWrapper<>();
+            customerPersonQueryWrapper.eq("person_id",person.getPersonId());
+            customerPersonQueryWrapper.eq("customer_id",customers.getCustomerId());
+            List<TaCustomerPerson> list = taCustomerPersonService.list(customerPersonQueryWrapper);
+            if(list.size()<=0){
+                TaCustomerPerson customerPerson = new TaCustomerPerson();
+                customerPerson.setCustomerId(customers.getCustomerId());
+                customerPerson.setPersonId(person.getPersonId());
+                taCustomerPersonService.save(customerPerson);
+            }
+        }
+
+
+
+
+
+
 
         return ResponseBean.success(phoneNoInfo);
     }

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

@@ -129,6 +129,12 @@ public class TaBuildingDynamicController extends BaseController {
     public ResponseBean taActivityDynamicEnlist(@RequestBody TaActivityDynamicEnlist taActivityDynamicEnlist,
                                                 HttpServletRequest request){
         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);
+        taActivityDynamicEnlist.setPersonId(person.getPersonId());
         ResponseBean  responseBean = iBuildingDynamicService.taActivityDynamicEnlistAdd(taActivityDynamicEnlist);
         return responseBean;
     }

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

@@ -1,178 +1,178 @@
-package com.huiju.estateagents.controller;
-
-import ch.qos.logback.core.status.StatusUtil;
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-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.CommConstant;
-import com.huiju.estateagents.common.JWTUtils;
-import com.huiju.estateagents.common.StringUtils;
-import com.huiju.estateagents.entity.TaEventProperties;
-import com.huiju.estateagents.entity.TaPerson;
-import com.huiju.estateagents.entity.TaPersonVisitRecord;
-import com.huiju.estateagents.service.ITaEventPropertiesService;
-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>
-    *   前端控制器
-    * </p>
- *
- * @author jobob
- * @since 2019-07-23
- */
-@RestController
-@RequestMapping("/api")
-public class TaPersonVisitRecordController extends BaseController {
-
-    private final Logger logger = LoggerFactory.getLogger(TaPersonVisitRecordController.class);
-
-    @Autowired
-    public ITaPersonVisitRecordService iTaPersonVisitRecordService;
-    @Autowired
-    public ITaPersonService taPersonService;
-    @Autowired
-    public ITaEventPropertiesService taEventPropertiesService;
-
-
-    /**
-     * 分页查询列表
-     * @param pageNum
-     * @param pageSize
-     * @return
-     */
-    @RequestMapping(value="/taPersonVisitRecord",method= RequestMethod.GET)
-    public ResponseBean taPersonVisitRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-                                                @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
-        try {
-            //使用分页插件
-		    IPage<TaPersonVisitRecord> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaPersonVisitRecord> queryWrapper = new QueryWrapper<>();
-            queryWrapper.orderByDesc("create_date");
-
-            IPage<TaPersonVisitRecord> result = iTaPersonVisitRecordService.page(pg, queryWrapper);
-            return ResponseBean.success(result);
-        }catch (Exception e){
-            logger.error("taPersonVisitRecordList -=- {}",e.toString());
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
-        }
-    }
-
-    /**
-     * 保存对象
-     * @param taPersonVisitRecord 实体对象
-     * @return
-     */
-    @RequestMapping(value="/wx/taPersonVisitRecord",method= RequestMethod.POST)
-    public ResponseBean taPersonVisitRecordAdd(@RequestBody TaPersonVisitRecord taPersonVisitRecord, HttpServletRequest request){
-        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.setActivity(taPersonVisitRecord.getPropertyName());
-        QueryWrapper<TaEventProperties>event = new QueryWrapper<>();
-        event.eq("targetId",taPersonVisitRecord.getTargetId());
-        event.eq("event_type",taPersonVisitRecord.getEventType());
-        event.eq("property_code",taPersonVisitRecord.getActivity());
-        List<TaEventProperties> eventProperties = taEventPropertiesService.list(event);
-        if(eventProperties.size()<=0){
-            TaEventProperties taEventProperty = new TaEventProperties();
-            taEventProperty.setBuildingId(taPersonVisitRecord.getTargetId());
-            taEventProperty.setCreateDate(LocalDateTime.now());
-            taEventProperty.setPropertyCode(taPersonVisitRecord.getPropertyName());
-            taEventProperty.setPropertyName(taPersonVisitRecord.getPropertyName());
-            taEventProperty.setStatus(CommConstant.STATUS_NORMAL);
-            taEventProperty.setBuildingId(taPersonVisitRecord.getBuildingId());
-            taEventProperty.setEventType(taPersonVisitRecord.getEventType());
-            if (!taEventPropertiesService.save(taEventProperty)){
-                return ResponseBean.error("新增失败",ResponseBean.ERROR_UNAVAILABLE);
-            }
-
-        }
-
-        taPersonVisitRecord.setPersonId(person.getPersonId());
-        taPersonVisitRecord.setVisitTime(LocalDateTime.now());
-        try {
-            if (iTaPersonVisitRecordService.save(taPersonVisitRecord)){
-                return ResponseBean.success(taPersonVisitRecord);
-            }else {
-                return ResponseBean.error("保存失败",ResponseBean.ERROR_UNAVAILABLE);
-            }
-        }catch (Exception e){
-            logger.error("taPersonVisitRecordAdd -=- {}",e.toString());
-            return ResponseBean.error("系统异常"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
-        }
-    }
-
-    /**
-     * 根据id删除对象
-     * @param id  实体ID
-     */
-    @ResponseBody
-    @RequestMapping(value="/taPersonVisitRecord/{id}", method= RequestMethod.DELETE)
-    public ResponseBean taPersonVisitRecordDelete(@PathVariable Integer id){
-        try {
-            if(iTaPersonVisitRecordService.removeById(id)){
-                return ResponseBean.success("success");
-            }else {
-                return ResponseBean.error("删除失败",ResponseBean.ERROR_UNAVAILABLE);
-            }
-        }catch (Exception e){
-            logger.error("taPersonVisitRecordDelete -=- {}",e.toString());
-            return ResponseBean.error("保存失败"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
-        }
-    }
-
-    /**
-     * 修改对象
-     * @param id  实体ID
-     * @return
-     */
-    @RequestMapping(value="/wx/taPersonVisitRecord/{id}",method= RequestMethod.PUT)
-    public ResponseBean taPersonVisitRecordUpdate(@PathVariable Integer id){
-        TaPersonVisitRecord taPersonVisitRecord = iTaPersonVisitRecordService.getById(id);
-        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)){
-                return ResponseBean.success(taPersonVisitRecord);
-            }else {
-                return ResponseBean.error("更新失败",ResponseBean.ERROR_UNAVAILABLE);
-            }
-        }catch (Exception e){
-            logger.error("taPersonVisitRecordUpdate -=- {}",e.toString());
-            return ResponseBean.error("更新失败"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
-        }
-    }
-
-    /**
-     * 根据id查询对象
-     * @param id  实体ID
-     */
-    @RequestMapping(value="/taPersonVisitRecord/{id}",method= RequestMethod.GET)
-    public ResponseBean taPersonVisitRecordGet(@PathVariable Integer id){
-        try {
-            return ResponseBean.success(iTaPersonVisitRecordService.getById(id));
-        }catch (Exception e){
-            logger.error("taPersonVisitRecordDelete -=- {}",e.toString());
-            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
-        }
-    }
-}
+package com.huiju.estateagents.controller;
+
+import ch.qos.logback.core.status.StatusUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+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.CommConstant;
+import com.huiju.estateagents.common.JWTUtils;
+import com.huiju.estateagents.common.StringUtils;
+import com.huiju.estateagents.entity.TaEventProperties;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaPersonVisitRecord;
+import com.huiju.estateagents.service.ITaEventPropertiesService;
+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>
+    *   前端控制器
+    * </p>
+ *
+ * @author jobob
+ * @since 2019-07-23
+ */
+@RestController
+@RequestMapping("/api")
+public class TaPersonVisitRecordController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaPersonVisitRecordController.class);
+
+    @Autowired
+    public ITaPersonVisitRecordService iTaPersonVisitRecordService;
+    @Autowired
+    public ITaPersonService taPersonService;
+    @Autowired
+    public ITaEventPropertiesService taEventPropertiesService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/taPersonVisitRecord",method= RequestMethod.GET)
+    public ResponseBean taPersonVisitRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
+        try {
+            //使用分页插件
+		    IPage<TaPersonVisitRecord> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaPersonVisitRecord> queryWrapper = new QueryWrapper<>();
+            queryWrapper.orderByDesc("create_date");
+
+            IPage<TaPersonVisitRecord> result = iTaPersonVisitRecordService.page(pg, queryWrapper);
+            return ResponseBean.success(result);
+        }catch (Exception e){
+            logger.error("taPersonVisitRecordList -=- {}",e.toString());
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 保存对象
+     * @param taPersonVisitRecord 实体对象
+     * @return
+     */
+    @RequestMapping(value="/wx/taPersonVisitRecord",method= RequestMethod.POST)
+    public ResponseBean taPersonVisitRecordAdd(@RequestBody TaPersonVisitRecord taPersonVisitRecord, HttpServletRequest request){
+        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.setActivity(taPersonVisitRecord.getPropertyName());
+        QueryWrapper<TaEventProperties>event = new QueryWrapper<>();
+        event.eq("target_id",taPersonVisitRecord.getTargetId());
+        event.eq("event_type",taPersonVisitRecord.getEventType());
+        event.eq("property_code",taPersonVisitRecord.getActivity());
+        List<TaEventProperties> eventProperties = taEventPropertiesService.list(event);
+        if(eventProperties.size()<=0){
+            TaEventProperties taEventProperty = new TaEventProperties();
+            taEventProperty.setBuildingId(taPersonVisitRecord.getTargetId());
+            taEventProperty.setCreateDate(LocalDateTime.now());
+            taEventProperty.setPropertyCode(taPersonVisitRecord.getPropertyName());
+            taEventProperty.setPropertyName(taPersonVisitRecord.getPropertyName());
+            taEventProperty.setStatus(CommConstant.STATUS_NORMAL);
+            taEventProperty.setBuildingId(taPersonVisitRecord.getBuildingId());
+            taEventProperty.setEventType(taPersonVisitRecord.getEventType());
+            if (!taEventPropertiesService.save(taEventProperty)){
+                return ResponseBean.error("新增失败",ResponseBean.ERROR_UNAVAILABLE);
+            }
+
+        }
+
+        taPersonVisitRecord.setPersonId(person.getPersonId());
+        taPersonVisitRecord.setVisitTime(LocalDateTime.now());
+        try {
+            if (iTaPersonVisitRecordService.save(taPersonVisitRecord)){
+                return ResponseBean.success(taPersonVisitRecord);
+            }else {
+                return ResponseBean.error("保存失败",ResponseBean.ERROR_UNAVAILABLE);
+            }
+        }catch (Exception e){
+            logger.error("taPersonVisitRecordAdd -=- {}",e.toString());
+            return ResponseBean.error("系统异常"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @ResponseBody
+    @RequestMapping(value="/taPersonVisitRecord/{id}", method= RequestMethod.DELETE)
+    public ResponseBean taPersonVisitRecordDelete(@PathVariable Integer id){
+        try {
+            if(iTaPersonVisitRecordService.removeById(id)){
+                return ResponseBean.success("success");
+            }else {
+                return ResponseBean.error("删除失败",ResponseBean.ERROR_UNAVAILABLE);
+            }
+        }catch (Exception e){
+            logger.error("taPersonVisitRecordDelete -=- {}",e.toString());
+            return ResponseBean.error("保存失败"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @return
+     */
+    @RequestMapping(value="/wx/taPersonVisitRecord/{id}",method= RequestMethod.PUT)
+    public ResponseBean taPersonVisitRecordUpdate(@PathVariable Integer id){
+        TaPersonVisitRecord taPersonVisitRecord = iTaPersonVisitRecordService.getById(id);
+        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)){
+                return ResponseBean.success(taPersonVisitRecord);
+            }else {
+                return ResponseBean.error("更新失败",ResponseBean.ERROR_UNAVAILABLE);
+            }
+        }catch (Exception e){
+            logger.error("taPersonVisitRecordUpdate -=- {}",e.toString());
+            return ResponseBean.error("更新失败"+e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/taPersonVisitRecord/{id}",method= RequestMethod.GET)
+    public ResponseBean taPersonVisitRecordGet(@PathVariable Integer id){
+        try {
+            return ResponseBean.success(iTaPersonVisitRecordService.getById(id));
+        }catch (Exception e){
+            logger.error("taPersonVisitRecordDelete -=- {}",e.toString());
+            return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+}

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

@@ -0,0 +1,34 @@
+package com.huiju.estateagents.entity;
+
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 客户映射人员 
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-08-08
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TaCustomerPerson implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 人员ID
+     */
+    private String personId;
+
+    /**
+     * 客户ID
+     */
+    private String customerId;
+
+
+}

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

@@ -0,0 +1,19 @@
+package com.huiju.estateagents.mapper;
+
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huiju.estateagents.entity.TaCustomerPerson;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * <p>
+ * 客户映射人员  Mapper 接口
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-08-08
+ */
+@Mapper
+public interface TaCustomerPersonMapper extends BaseMapper<TaCustomerPerson> {
+
+}

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

@@ -0,0 +1,17 @@
+package com.huiju.estateagents.service;
+
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.entity.TaCustomerPerson;
+
+/**
+ * <p>
+ * 客户映射人员  服务类
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-08-08
+ */
+public interface ITaCustomerPersonService extends IService<TaCustomerPerson> {
+
+}

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

@@ -1,39 +1,38 @@
-package com.huiju.estateagents.service;
-
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.huiju.estateagents.base.ResponseBean;
-import com.huiju.estateagents.entity.TaPerson;
-import com.huiju.estateagents.entity.TaRecommendCustomer;
-import com.baomidou.mybatisplus.extension.service.IService;
-
-/**
- * <p>
- * 推荐客户表 服务类
- * </p>
- *
- * @author jobob
- * @since 2019-05-10
- */
-public interface ITaRecommendCustomerService extends IService<TaRecommendCustomer> {
-
-    ResponseBean getMyCustList(String openid, String keywords, int pageNumber, int pageSize);
-
-    ResponseBean getCustDetail(String id);
-
-    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,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus);
-
-    TaRecommendCustomer getCustomerDetail(String customerId);
-
-    TaRecommendCustomer getCustomerById(String customerId);
-
-    IPage<TaRecommendCustomer>getCustomersIRecommended(int pageNumber, int pageSize,String customerId,String building);
-
-
-    TaRecommendCustomer newByPerson(TaPerson person);
-}
+package com.huiju.estateagents.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaRecommendCustomer;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ * 推荐客户表 服务类
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-05-10
+ */
+public interface ITaRecommendCustomerService extends IService<TaRecommendCustomer> {
+
+    ResponseBean getMyCustList(String openid, String keywords, int pageNumber, int pageSize);
+
+    ResponseBean getCustDetail(String id);
+
+    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,String name,String tel,String consultName,String consultTel,String entryType,String verifyStatus);
+
+    TaRecommendCustomer getCustomerDetail(String customerId);
+
+    TaRecommendCustomer getCustomerById(String customerId);
+
+    IPage<TaRecommendCustomer>getCustomersIRecommended(int pageNumber, int pageSize,String customerId,String building);
+
+    TaRecommendCustomer newByPerson(TaPerson person);
+}

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

@@ -0,0 +1,21 @@
+package com.huiju.estateagents.service.impl;
+
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.entity.TaCustomerPerson;
+import com.huiju.estateagents.mapper.TaCustomerPersonMapper;
+import com.huiju.estateagents.service.ITaCustomerPersonService;
+import org.springframework.stereotype.Service;
+
+/**
+ * <p>
+ * 客户映射人员  服务实现类
+ * </p>
+ *
+ * @author jobob
+ * @since 2019-08-08
+ */
+@Service
+public class TaCustomerPersonServiceImpl extends ServiceImpl<TaCustomerPersonMapper, TaCustomerPerson> implements ITaCustomerPersonService {
+
+}