bugfix

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

@@ -200,6 +200,14 @@ public class MiniAppController {
         List<TaRecommendCustomer> customer = taRecommendCustomerService.list(cus);
         if (customer.size()>0){
             TaRecommendCustomer customers = customer.get(0);
+            customers.setPersonId(person.getPersonId());
+            customers.setPicture(person.getAvatarurl());
+            customers.setCountry(person.getCountry());
+            customers.setCity(person.getCity());
+            customers.setProvince(person.getProvince());
+            if(!taRecommendCustomerService.updateById(customers)){
+                return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+            }
             person.setRecommendPerson(customers.getRecommendPerson());
             TaPerson recommender = taPersonService.getById(customers.getRecommendPerson());
             person.setRecommendPersonType(recommender.getPersonType());
@@ -210,14 +218,22 @@ public class MiniAppController {
             if(list.size()<=0){
                 taCustomerPersonService.insertBean(person.getPersonId(),customers.getCustomerId());
             }
+        } else{
+            TaRecommendCustomer reCustomer = new TaRecommendCustomer();
+            reCustomer.setVerifyStatus(CommConstant.VERIFY_AGREE);
+            reCustomer.setName(person.getNickname());
+            reCustomer.setPhone(phoneNoInfo.getPhoneNumber());
+            reCustomer.setSex(Integer.valueOf(person.getGender()));
+            reCustomer.setPersonId(person.getPersonId());
+            reCustomer.setPicture(person.getAvatarurl());
+            reCustomer.setCountry(person.getCountry());
+            reCustomer.setCity(person.getCity());
+            reCustomer.setProvince(person.getProvince());
+            reCustomer.setEntryType(CommConstant.ENTRY_VOLUNTEER);
+            if(!taRecommendCustomerService.save(reCustomer)){
+                return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+            }
         }
-
-
-
-
-
-
-
         return ResponseBean.success(phoneNoInfo);
     }
 

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

@@ -1,225 +1,229 @@
-package com.huiju.estateagents.controller;
-
-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.entity.TaPerson;
-import com.huiju.estateagents.entity.TaPointsRecords;
-import com.huiju.estateagents.service.ITaPersonService;
-import com.huiju.estateagents.service.ITaPointsRecordsService;
-import org.apache.ibatis.annotations.Mapper;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.servlet.http.HttpServletRequest;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-/**
- * <p>
-    * 积分消费流水表  前端控制器
-    * </p>
- *
- * @author jobob
- * @since 2019-07-25
- */
-@RestController
-@RequestMapping("/api")
-public class TaPointsRecordsController extends BaseController {
-
-    private final Logger logger = LoggerFactory.getLogger(TaPointsRecordsController.class);
-
-    @Autowired
-    public ITaPointsRecordsService iTaPointsRecordsService;
-    
-    @Autowired
-    private ITaPersonService taPersonService;
-
-
-    /**
-     * 分页查询列表
-     * @param pageNum
-     * @param pageSize
-     * @return
-     */
-    @RequestMapping(value="/taPointsRecords",method= RequestMethod.GET)
-    public ResponseBean taPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            //使用分页插件
-		    IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
-            queryWrapper.orderByDesc("create_date");
-
-            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
-            responseBean.addSuccess(result);
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsList -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-
-    /**
-     * 保存对象
-     * @param taPointsRecords 实体对象
-     * @return
-     */
-    @RequestMapping(value="/taPointsRecords",method= RequestMethod.POST)
-    public ResponseBean taPointsRecordsAdd(@RequestBody TaPointsRecords taPointsRecords){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            if (iTaPointsRecordsService.save(taPointsRecords)){
-                responseBean.addSuccess(taPointsRecords);
-            }else {
-                responseBean.addError("fail");
-            }
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsAdd -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-
-    /**
-     * 根据id删除对象
-     * @param id  实体ID
-     */
-    @ResponseBody
-    @RequestMapping(value="/taPointsRecords/{id}", method= RequestMethod.DELETE)
-    public ResponseBean taPointsRecordsDelete(@PathVariable Integer id){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            if(iTaPointsRecordsService.removeById(id)){
-                responseBean.addSuccess("success");
-            }else {
-                responseBean.addError("fail");
-            }
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsDelete -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-
-    /**
-     * 修改对象
-     * @param id  实体ID
-     * @param taPointsRecords 实体对象
-     * @return
-     */
-    @RequestMapping(value="/taPointsRecords/{id}",method= RequestMethod.PUT)
-    public ResponseBean taPointsRecordsUpdate(@PathVariable Integer id,
-                                        @RequestBody TaPointsRecords taPointsRecords){
-        ResponseBean responseBean = new ResponseBean();
-        taPointsRecords.setPointsRecordId(id);
-        try {
-            if (iTaPointsRecordsService.updateById(taPointsRecords)){
-                responseBean.addSuccess(taPointsRecords);
-            }else {
-                responseBean.addError("fail");
-            }
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsUpdate -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-
-    /**
-     * 根据id查询对象
-     * @param id  实体ID
-     */
-    @RequestMapping(value="/taPointsRecords/{id}",method= RequestMethod.GET)
-    public ResponseBean taPointsRecordsGet(@PathVariable Integer id){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            responseBean.addSuccess(iTaPointsRecordsService.getById(id));
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsDelete -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-    
-    /**
-     * 分页查询列表
-     * @param pageNum
-     * @param pageSize
-     * @return
-     */
-    @RequestMapping(value="/wx/taPointsRecords",method= RequestMethod.GET)
-    public ResponseBean wxPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
-                                            HttpServletRequest request){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            String openid = JWTUtils.getSubject(request);
-            TaPerson taPerson = taPersonService.getPersonsByOpenId(openid).get(0);
-            //使用分页插件
-            IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
-            queryWrapper.eq("person_id",taPerson.getPersonId());
-            queryWrapper.orderByDesc("create_date");
-            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
-            responseBean.addSuccess(result);
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsList -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-
-    /**
-     * 分页查询列表
-     * @param pageNum
-     * @param pageSize
-     * @return
-     */
-    @RequestMapping(value="/admin/taPointsRecords/{id}",method= RequestMethod.GET)
-    public ResponseBean CustomerPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
-                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
-                                            @PathVariable(value = "id") String id){
-        ResponseBean responseBean = new ResponseBean();
-        try {
-            IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
-            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
-            queryWrapper.eq("person_id",taPersonService.getPersonIdByCustomerId(id));
-            queryWrapper.orderByDesc("create_date");
-            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
-            Integer totalPoints = 0;
-            for (int i = 0;i<result.getRecords().size();i++){
-                totalPoints += result.getRecords().get(i).getPointsAmount();
-            }
-            Map<String,Object> data = new HashMap<>();
-            data.put("totalPoints",totalPoints);
-            data.put("result",result);
-            responseBean.addSuccess(data);
-        }catch (Exception e){
-            e.printStackTrace();
-            logger.error("taPointsRecordsList -=- {}",e.toString());
-            responseBean.addError(e.getMessage());
-        }
-        return responseBean;
-    }
-}
+package com.huiju.estateagents.controller;
+
+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.entity.TaPerson;
+import com.huiju.estateagents.entity.TaPointsRecords;
+import com.huiju.estateagents.service.ITaPersonService;
+import com.huiju.estateagents.service.ITaPointsRecordsService;
+import com.huiju.estateagents.service.ITaRecommendCustomerService;
+import org.apache.ibatis.annotations.Mapper;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+    * 积分消费流水表  前端控制器
+    * </p>
+ *
+ * @author jobob
+ * @since 2019-07-25
+ */
+@RestController
+@RequestMapping("/api")
+public class TaPointsRecordsController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TaPointsRecordsController.class);
+
+    @Autowired
+    public ITaPointsRecordsService iTaPointsRecordsService;
+    
+    @Autowired
+    private ITaPersonService taPersonService;
+
+    @Autowired
+    private ITaRecommendCustomerService recommendCustomerService;
+
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/taPointsRecords",method= RequestMethod.GET)
+    public ResponseBean taPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            //使用分页插件
+		    IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
+            queryWrapper.orderByDesc("create_date");
+
+            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 保存对象
+     * @param taPointsRecords 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taPointsRecords",method= RequestMethod.POST)
+    public ResponseBean taPointsRecordsAdd(@RequestBody TaPointsRecords taPointsRecords){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if (iTaPointsRecordsService.save(taPointsRecords)){
+                responseBean.addSuccess(taPointsRecords);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id删除对象
+     * @param id  实体ID
+     */
+    @ResponseBody
+    @RequestMapping(value="/taPointsRecords/{id}", method= RequestMethod.DELETE)
+    public ResponseBean taPointsRecordsDelete(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            if(iTaPointsRecordsService.removeById(id)){
+                responseBean.addSuccess("success");
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 修改对象
+     * @param id  实体ID
+     * @param taPointsRecords 实体对象
+     * @return
+     */
+    @RequestMapping(value="/taPointsRecords/{id}",method= RequestMethod.PUT)
+    public ResponseBean taPointsRecordsUpdate(@PathVariable Integer id,
+                                        @RequestBody TaPointsRecords taPointsRecords){
+        ResponseBean responseBean = new ResponseBean();
+        taPointsRecords.setPointsRecordId(id);
+        try {
+            if (iTaPointsRecordsService.updateById(taPointsRecords)){
+                responseBean.addSuccess(taPointsRecords);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsUpdate -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 根据id查询对象
+     * @param id  实体ID
+     */
+    @RequestMapping(value="/taPointsRecords/{id}",method= RequestMethod.GET)
+    public ResponseBean taPointsRecordsGet(@PathVariable Integer id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            responseBean.addSuccess(iTaPointsRecordsService.getById(id));
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsDelete -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+    
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/wx/taPointsRecords",method= RequestMethod.GET)
+    public ResponseBean wxPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                            HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            String openid = JWTUtils.getSubject(request);
+            TaPerson taPerson = taPersonService.getPersonsByOpenId(openid).get(0);
+            //使用分页插件
+            IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("person_id",taPerson.getPersonId());
+            queryWrapper.orderByDesc("create_date");
+            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/admin/taPointsRecords/{id}",method= RequestMethod.GET)
+    public ResponseBean CustomerPointsRecordsList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                            @PathVariable(value = "id") String id){
+        ResponseBean responseBean = new ResponseBean();
+        try {
+            IPage<TaPointsRecords> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaPointsRecords> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("person_id",recommendCustomerService.getById(id).getPersonId());
+            queryWrapper.orderByDesc("create_date");
+            IPage<TaPointsRecords> result = iTaPointsRecordsService.page(pg, queryWrapper);
+            Integer totalPoints = 0;
+            for (int i = 0;i<result.getRecords().size();i++){
+                totalPoints += result.getRecords().get(i).getPointsAmount();
+            }
+            Map<String,Object> data = new HashMap<>();
+            data.put("totalPoints",totalPoints);
+            data.put("result",result);
+            responseBean.addSuccess(data);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taPointsRecordsList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+}

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

@@ -4,6 +4,7 @@ package com.huiju.estateagents.controller;
 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.TaPerson;
 import com.huiju.estateagents.entity.TaRecommendCustomer;
 import com.huiju.estateagents.event.EventBus;
@@ -172,7 +173,7 @@ public class TaRecommendCustomerController extends BaseController {
      */
     @RequestMapping(value="/admin/customer/recommend/edit/{id}",method= RequestMethod.PUT)
     public ResponseBean taRecommendCustomerUpdate(@PathVariable String id,
-            @RequestBody TaRecommendCustomer taRecommendCustomer){
+                                                  @RequestBody TaRecommendCustomer taRecommendCustomer){
         ResponseBean responseBean = new ResponseBean();
         taRecommendCustomer.setCustomerId(id);
         try {
@@ -243,7 +244,7 @@ public class TaRecommendCustomerController extends BaseController {
      * @return
      */
     @RequestMapping(value="/admin/customer/recommend/verify/{id}",method= RequestMethod.PUT)
-    public ResponseBean taRecommendCustomerVerify(@PathVariable String id,@RequestParam Integer verifyStatus, @RequestParam String verifyRemark){
+    public ResponseBean taRecommendCustomerVerify(@PathVariable String id,@RequestParam Integer verifyStatus, @RequestParam(required = false) String verifyRemark){
         if (null == verifyStatus) {
             return ResponseBean.error("审核结果非法", ResponseBean.ERROR_ILLEGAL_PARAMS);
         }
@@ -253,7 +254,9 @@ public class TaRecommendCustomerController extends BaseController {
             TaRecommendCustomer taRecommendCustomer = taRecommendCustomerService.getById(id);
             if(taRecommendCustomer.getVerifyStatus() != CommConstant.VERIFY_READY){
                 taRecommendCustomer.setVerifyStatus(verifyStatus);
-                taRecommendCustomer.setVerifyRemark(verifyRemark);
+                if(!StringUtils.isEmpty(verifyRemark)){
+                    taRecommendCustomer.setVerifyRemark(verifyRemark);
+                }
                 if (taRecommendCustomerService.updateById(taRecommendCustomer)){
 
                     // 审核通过增加积分

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

@@ -178,6 +178,7 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
         taRecommendCustomer.setDemandType(params.getString("demandType"));
         taRecommendCustomer.setPriceRange(params.getString("priceRange"));
         taRecommendCustomer.setEntryType(CommConstant.ENTRY_INPUT);
+        taRecommendCustomer.setVerifyStatus(CommConstant.VERIFY_READY);
 
         // 报备日期是今天
         taRecommendCustomer.setReportDate(LocalDateTime.now());
@@ -260,8 +261,8 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
 
     @Override
     public TaRecommendCustomer getCustomerDetail(String customerId){
-        String personId = taRecommendCustomerMapper.getCustomerPersonId(customerId);
         TaRecommendCustomer taRecommendCustomer = taRecommendCustomerMapper.getCustomerDetail(customerId);
+        String personId = taRecommendCustomer.getPersonId();
         if(!StringUtils.isEmpty(personId)){
             taRecommendCustomer.setVisitRecords(taPersonVisitRecordMapper.visitRecordByPersonId(personId));
             taRecommendCustomer.setVisitTimes(taPersonVisitRecordMapper.visitRecordByPersonId(personId).size());
@@ -276,11 +277,11 @@ public class TaRecommendCustomerServiceImpl extends ServiceImpl<TaRecommendCusto
 
     @Override
     public IPage<TaRecommendCustomer>getCustomersIRecommended(int pageNumber, int pageSize,String customerId,String building){
-        String personId = taRecommendCustomerMapper.getCustomerPersonId(customerId);
+        String personId = taRecommendCustomerMapper.getCustomerById(customerId).getRecommendPerson();
         QueryWrapper<TaRecommendCustomer>queryWrapper = new QueryWrapper<>();
         // todo
         // 此处可能不是 person_id 而是 recommend_person
-        queryWrapper.eq("person_id",personId);
+        queryWrapper.eq("recommend_person",personId);
 //        queryWrapper.eq("building_id",building);
         queryWrapper.gt("status", CommConstant.MESSAGE_UNREAD);
         IPage<TaRecommendCustomer>page = new Page<>(pageNumber,pageSize);

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

@@ -10,6 +10,7 @@ import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.*;
 import com.huiju.estateagents.event.EventBus;
 import com.huiju.estateagents.mapper.*;
+import com.huiju.estateagents.service.ITaNewsService;
 import com.huiju.estateagents.service.ITaShareService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.ApplicationContext;
@@ -40,6 +41,9 @@ public class TaShareServiceImpl extends ServiceImpl<TaShareMapper, TaShare> impl
 
     @Autowired
     private TaBuildingDynamicMapper taBuildingDynamicMapper;
+
+    @Autowired
+    private TaNewsMapper newsMapper;
     
     @Resource
     private ApplicationContext applicationContext;
@@ -100,6 +104,10 @@ public class TaShareServiceImpl extends ServiceImpl<TaShareMapper, TaShare> impl
             taPersonMapper.setFieldNum(id, "share_num", 1);
         }
 
+        if(typeOf.equals(CommConstant.FAVOR_NEWS)){
+            newsMapper.setFieldNum(id,"share_num",1);
+        }
+
         return ResponseBean.success("");
     }