新需求 埋点信息数据

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

     }
 
     /**
-     * 保存对象
+     * 保存对象--埋点数据保存
      * @param taPersonVisitRecord 实体对象
      * @return
      */

src/main/java/com/huiju/estateagents/controller/TaSharePersonFromController.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.entity.TaSharePersonFrom;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.entity.*;
 import com.huiju.estateagents.service.ITaSharePersonFromService;
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.servlet.http.HttpServletRequest;
+import java.time.LocalDateTime;
+
 /**
  * <p>
     *   前端控制器
     }
 
     /**
-     * 保存对象
-     * @param taSharePersonFrom 实体对象
+     * 保存对象--分享记录埋点
+     *
      * @return
      */
-    @RequestMapping(value="/taSharePersonFrom",method= RequestMethod.POST)
-    public ResponseBean taSharePersonFromAdd(@RequestBody TaSharePersonFrom taSharePersonFrom){
+    @RequestMapping(value="/wx/taSharePersonFrom",method= RequestMethod.POST)
+    public ResponseBean taSharePersonFromAdd( @RequestParam(required = false) String from,
+                                              @RequestParam(required = false)String recommender,
+                                              @RequestParam(required = false)String targetId,
+                                              HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         try {
-            if (iTaSharePersonFromService.save(taSharePersonFrom)){
+            if(StringUtils.isNotBlank(from) &&StringUtils.isNotBlank(recommender) &&StringUtils.isNotBlank(targetId)){
+                //添加客户分享信息记录
+                TaSharePersonFrom taSharePersonFrom = iTaSharePersonFromService.addSharePersonRecord(getPersonId(request), getOrgId(request), from, recommender, targetId);
                 responseBean.addSuccess(taSharePersonFrom);
-            }else {
-                responseBean.addError("fail");
             }
         }catch (Exception e){
             e.printStackTrace();

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

      */
     private String consultantId;
 
+    /**
+     * 场景值id
+     */
+    private String sceneId;
+
     /**
      * 分享者personid
      */

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

 package com.huiju.estateagents.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.entity.TaSharePersonFrom;
 
 /**
  */
 public interface ITaSharePersonFromService extends IService<TaSharePersonFrom> {
 
+    /**
+     * 添加客户分享记录
+     * @param personId
+     * @param orgId
+     * @param from
+     * @param recommender
+     * @param targetId
+     * @return
+     */
+    TaSharePersonFrom addSharePersonRecord(String personId, Integer orgId, String from, String recommender, String targetId);
 }

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

 package com.huiju.estateagents.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.huiju.estateagents.entity.TaSharePersonFrom;
-import com.huiju.estateagents.mapper.TaSharePersonFromMapper;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.mapper.*;
 import com.huiju.estateagents.service.ITaSharePersonFromService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+
 /**
  * <p>
  *   服务实现类
 @Service
 public class TaSharePersonFromServiceImpl extends ServiceImpl<TaSharePersonFromMapper, TaSharePersonFrom> implements ITaSharePersonFromService {
 
+    @Autowired
+    private TaPersonMapper taPersonMapper;
+
+    @Autowired
+    private TaBuildingDynamicMapper taBuildingDynamicMapper;
+
+    @Autowired
+    private TaPersonBuildingMapper taPersonBuildingMapper;
+
+    @Autowired
+    private TaNewsMapper taNewsMapper;
+
+    @Autowired
+    private TaSharePersonFromMapper taSharePersonFromMapper;
+    /**
+     * 添加客户分享记录
+     *
+     * @param personId
+     * @param orgId
+     * @param from
+     * @param recommender
+     * @param targetId
+     * @return
+     */
+    @Override
+    public TaSharePersonFrom addSharePersonRecord(String personId, Integer orgId, String from, String recommender, String targetId) {
+        TaPerson taPerson = taPersonMapper.getById(personId);
+        TaSharePersonFrom taSharePersonFrom = new TaSharePersonFrom();
+        TaPerson recommenderPerson = taPersonMapper.getById(recommender);
+        taSharePersonFrom.setCreateDate(LocalDateTime.now());
+        taSharePersonFrom.setOrgId(orgId);
+        taSharePersonFrom.setPersonId(taPerson.getPersonId());
+        taSharePersonFrom.setSharePersonType(recommenderPerson.getPersonType());
+        taSharePersonFrom.setTargetId(targetId);
+        taSharePersonFrom.setTargetType(from);
+        if(CommConstant.PERSON_REALTY_CONSULTANT.equals(recommenderPerson.getPersonType())){
+            taSharePersonFrom.setSharePerson(recommenderPerson.getUserId().toString());
+        }else {
+            taSharePersonFrom.setSharePerson(recommenderPerson.getPersonId());
+        }
+        QueryWrapper<TaSharePersonFrom> sharePersonFromQueryWrapper = new QueryWrapper<>();
+        sharePersonFromQueryWrapper.eq("person_id",taPerson.getPersonId());
+        if(from.equals("dynamic_share")){ // activity_share
+            taSharePersonFrom.setStatus(CommConstant.STATUS_UNACCALIMED);
+            TaBuildingDynamic buildingDynamic = taBuildingDynamicMapper.selectById(targetId);
+            taSharePersonFrom.setBuildingId(buildingDynamic.getBuildingId());
+            sharePersonFromQueryWrapper.eq("building_id",buildingDynamic.getBuildingId());
+        }else {
+            taSharePersonFrom.setStatus(CommConstant.STATUS_NORMAL);
+        }
+        if (from.contains("card")){
+            // 因为targetId 是 personId ，需要查询出 userId
+            TaPerson person = taPersonMapper.getById(targetId);
+
+            QueryWrapper<TaPersonBuilding> personBuildingQueryWrapper = new QueryWrapper<>();
+            personBuildingQueryWrapper.eq("user_id",person.getUserId());
+            TaPersonBuilding personBuilding = taPersonBuildingMapper.selectOne(personBuildingQueryWrapper);
+            taSharePersonFrom.setBuildingId(personBuilding.getBuildingId());
+            sharePersonFromQueryWrapper.eq("building_id",personBuilding.getBuildingId());
+        }else if (from.contains("news")){
+            TaNews news = taNewsMapper.selectById(targetId);
+            taSharePersonFrom.setBuildingId(news.getBuildingId());
+            sharePersonFromQueryWrapper.eq("building_id",news.getBuildingId());
+        }else if (from.contains("building")){
+            taSharePersonFrom.setBuildingId(targetId);
+            sharePersonFromQueryWrapper.eq("building_id",targetId);
+        }
+        Integer isFirstTime = taSharePersonFromMapper.selectCount(sharePersonFromQueryWrapper);
+        if(isFirstTime>0){
+            taSharePersonFrom.setIsFirstTime(false);
+        }else {
+            taSharePersonFrom.setIsFirstTime(true);
+        }
+        taSharePersonFromMapper.insert(taSharePersonFrom);
+        return taSharePersonFrom;
+    }
 }