跟进记录

src/main/java/com/huiju/estateagents/statistic/controller/TaCustomerFollowUpRecordController.java

@@ -5,6 +5,8 @@ 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.entity.TaPerson;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.statistic.entity.TaCustomerFollowUpRecord;
 import com.huiju.estateagents.statistic.service.ITaCustomerFollowUpRecordService;
 import org.slf4j.Logger;
@@ -18,6 +20,9 @@ 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.List;
+
 /**
  * <p>
     * 跟进记录表 小程序盘客工具我的客户跟进记录信息 前端控制器
@@ -27,14 +32,16 @@ import org.springframework.web.bind.annotation.RestController;
  * @since 2019-11-08
  */
 @RestController
-@RequestMapping("/")
+@RequestMapping("/api")
 public class TaCustomerFollowUpRecordController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(TaCustomerFollowUpRecordController.class);
 
     @Autowired
     public ITaCustomerFollowUpRecordService iTaCustomerFollowUpRecordService;
-
+    
+    @Autowired
+    private ITaPersonService taPersonService;
 
     /**
      * 分页查询列表
@@ -146,4 +153,72 @@ public class TaCustomerFollowUpRecordController extends BaseController {
         }
         return responseBean;
     }
+    
+    /**
+     * 盘客工具添加跟进记录
+     * @param taCustomerFollowUpRecord 实体对象
+     * @return
+     */
+    @RequestMapping(value="/wx/taCustomerFollowUpRecord",method= RequestMethod.POST)
+    public ResponseBean wxCustomerFollowUpRecordAdd(@RequestBody TaCustomerFollowUpRecord taCustomerFollowUpRecord, HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        try {
+            taCustomerFollowUpRecord.setFollowerId(person.getPersonId());
+            if (iTaCustomerFollowUpRecordService.save(taCustomerFollowUpRecord)){
+                responseBean.addSuccess(taCustomerFollowUpRecord);
+            }else {
+                responseBean.addError("fail");
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taCustomerFollowUpRecordAdd -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
+    
+    /**
+     * 分页查询跟进记录列表
+     * @param pageNum
+     * @param pageSize
+     * @return
+     */
+    @RequestMapping(value="/wx/taCustomerFollowUpRecord",method= RequestMethod.GET)
+    public ResponseBean wxCustomerFollowUpRecordList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                     @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                     @RequestParam(value ="customerId",required = true) Integer customerId,
+                                                     HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> taPersons = taPersonService.getPersonsByOpenId(openid);
+        if (null == taPersons || taPersons.size() != 1) {
+            return ResponseBean.error("验证人员信息失败", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = taPersons.get(0);
+        try {
+            //使用分页插件
+            IPage<TaCustomerFollowUpRecord> pg = new Page<>(pageNum, pageSize);
+            QueryWrapper<TaCustomerFollowUpRecord> queryWrapper = new QueryWrapper<>();
+            queryWrapper.eq("follower_id",person.getPersonId());
+            queryWrapper.eq("org_id",orgId);
+            queryWrapper.eq("customer_id",customerId);
+            queryWrapper.orderByDesc("create_date");
+            
+            IPage<TaCustomerFollowUpRecord> result = iTaCustomerFollowUpRecordService.page(pg, queryWrapper);
+            responseBean.addSuccess(result);
+        }catch (Exception e){
+            e.printStackTrace();
+            logger.error("taCustomerFollowUpRecordList -=- {}",e.toString());
+            responseBean.addError(e.getMessage());
+        }
+        return responseBean;
+    }
 }

src/main/resources/mapper/TaRecommendCustomerMapper.xml

@@ -640,7 +640,7 @@ FROM
           AND STATUS = 4
         </if>
     </select>
-    
+
     <select id="getMyCustDetailById" resultType="com.huiju.estateagents.entity.TaRecommendCustomer">
         SELECT
             *