统计

src/main/java/com/huiju/estateagents/job/CustomerStatisticTimeJob.java

      *
      * 开启定时任务，每天23:50执行
      */
-    @Scheduled(cron = "00 50 23 * * ?")
-    //@Scheduled(cron = "* 0/5 * * * ?")
+    //@Scheduled(cron = "00 50 23 * * ?")
+    @Scheduled(cron = "* 0/5 * * * ?")
     private void configureTasks() {
         LocalDateTime nowDate = LocalDateTime.now();
     

src/main/java/com/huiju/estateagents/statistic/controller/TsCustomerGenderStatisticController.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.TaPerson;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.statistic.entity.TsCustomerGenderStatistic;
 import com.huiju.estateagents.statistic.service.ITsCustomerGenderStatisticService;
 import org.slf4j.Logger;
 
     @Autowired
     public ITsCustomerGenderStatisticService iTaCustomerGenderStatisticService;
+    
+    @Autowired
+    private ITaPersonService taPersonService;
 
 
     /**
     public ResponseBean wxCustomerGenderStatisticList(@PathVariable(value = "customerType") String customerType, HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         try {
-            //查询当前小程序的男女比统计
+            String openid = getOpenId(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<TsCustomerGenderStatistic> queryWrapper = new QueryWrapper<>();
             queryWrapper.eq("org_id",getOrgId(request));
             queryWrapper.eq("customer_type",customerType);
+            queryWrapper.eq("realty_consultant",person.getPersonId());
             queryWrapper.orderByDesc("create_date");
      
             List<TsCustomerGenderStatistic> result = iTaCustomerGenderStatisticService.list(queryWrapper);

src/main/java/com/huiju/estateagents/statistic/controller/TsCustomerStatisticDailyController.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.TaPerson;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.statistic.entity.TsCustomerStatisticDaily;
 import com.huiju.estateagents.statistic.service.ITsCustomerStatisticDailyService;
 import org.slf4j.Logger;
 
     @Autowired
     public ITsCustomerStatisticDailyService iTaCustomerStatisticDailyService;
-
+    
+    @Autowired
+    private ITaPersonService taPersonService;
 
     /**
      * 分页查询列表
     public ResponseBean wxCustomerStatisticDailyList(@PathVariable(value = "customerType") String customerType,
                                                      HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(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 {
-            List<TsCustomerStatisticDaily> list = iTaCustomerStatisticDailyService.getDailyList(customerType,getOrgId(request));
+            List<TsCustomerStatisticDaily> list = iTaCustomerStatisticDailyService.getDailyList(customerType,getOrgId(request),person.getPersonId());
             responseBean.addSuccess(list);
         }catch (Exception e){
             e.printStackTrace();

src/main/java/com/huiju/estateagents/statistic/controller/TsCustomerStatisticMonthlyController.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.TaPerson;
+import com.huiju.estateagents.service.ITaPersonService;
 import com.huiju.estateagents.statistic.entity.TsCustomerStatisticMonthly;
 import com.huiju.estateagents.statistic.service.ITsCustomerStatisticMonthlyService;
 import org.slf4j.Logger;
 
     @Autowired
     public ITsCustomerStatisticMonthlyService iTaCustomerStatisticMonthlyService;
-
-
+    
+    @Autowired
+    private ITaPersonService taPersonService;
+    
     /**
      * 分页查询列表
      * @param pageNum
     public ResponseBean taCustomerStatisticMonthlyList(@PathVariable(value = "customerType") String customerType,
                                                        HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(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 {
             //查询月客户分析数据
-            List<TsCustomerStatisticMonthly> result = iTaCustomerStatisticMonthlyService.getCustomerMonthlyList(customerType, getOrgId(request));
+            List<TsCustomerStatisticMonthly> result = iTaCustomerStatisticMonthlyService.getCustomerMonthlyList(customerType, getOrgId(request),person.getPersonId());
             responseBean.addSuccess(result);
         }catch (Exception e){
             e.printStackTrace();

src/main/java/com/huiju/estateagents/statistic/mapper/TsCustomerStatisticDailyMapper.java

 	 * @param orgId
 	 * @param nowDate
 	 * @param beforeDate
+	 * @param personId
 	 * @return
 	 */
-	List<TsCustomerStatisticDaily> getDailyList(@Param("customerType") String customerType, @Param("orgId")  Integer orgId, @Param("nowDate")  LocalDateTime nowDate, @Param("beforeDate")  LocalDateTime beforeDate);
+	List<TsCustomerStatisticDaily> getDailyList(@Param("customerType") String customerType, @Param("orgId") Integer orgId, @Param("nowDate") LocalDateTime nowDate, @Param("beforeDate") LocalDateTime beforeDate,@Param("personId") String personId);
 	
 	int deleteNowDate(@Param("nowDate") LocalDateTime nowDate,@Param("customerType") String customerType);
 }

src/main/java/com/huiju/estateagents/statistic/mapper/TsCustomerStatisticMonthlyMapper.java

 	 * @param orgId
 	 * @param nowDate
 	 * @param beforeDate
+	 * @param personId
 	 * @return
 	 */
-	List<TsCustomerStatisticMonthly> getMonthlyList(@Param("customerType") String customerType, @Param("orgId") Integer orgId, @Param("nowDate") LocalDateTime nowDate, @Param("beforeDate") LocalDateTime beforeDate);
+	List<TsCustomerStatisticMonthly> getMonthlyList(@Param("customerType") String customerType, @Param("orgId") Integer orgId, @Param("nowDate") LocalDateTime nowDate, @Param("beforeDate") LocalDateTime beforeDate,@Param("personId") String personId);
 }

src/main/java/com/huiju/estateagents/statistic/service/ITsCustomerStatisticDailyService.java

 	 * 获取日统计数据
 	 * @param customerType
 	 * @param orgId
+	 * @param personId
 	 * @return
 	 */
-	List<TsCustomerStatisticDaily> getDailyList(String customerType, Integer orgId);
+	List<TsCustomerStatisticDaily> getDailyList(String customerType, Integer orgId, String personId);
 }

src/main/java/com/huiju/estateagents/statistic/service/ITsCustomerStatisticMonthlyService.java

 	 * 查询12个月的客户统计分析数据
 	 * @param customerType
 	 * @param orgId
+	 * @param personId
 	 * @return
 	 */
-	List<TsCustomerStatisticMonthly> getCustomerMonthlyList(String customerType, Integer orgId);
+	List<TsCustomerStatisticMonthly> getCustomerMonthlyList(String customerType, Integer orgId, String personId);
 }

src/main/java/com/huiju/estateagents/statistic/service/impl/TsCustomerStatisticDailyServiceImpl.java

 	 *
 	 * @param customerType
 	 * @param orgId
+	 * @param personId
 	 * @return
 	 */
 	@Override
-	public List<TsCustomerStatisticDaily> getDailyList(String customerType, Integer orgId) {
+	public List<TsCustomerStatisticDaily> getDailyList(String customerType, Integer orgId, String personId) {
 		//当前日期
 		LocalDateTime nowDate = LocalDateTime.now();
 		//31天前的日期
 		LocalDateTime beforeDate = nowDate.plusDays(-31);
 		//获取31天的日期数据
 
-		List<TsCustomerStatisticDaily> list = customerStatisticDailyMapper.getDailyList(customerType,orgId,nowDate,beforeDate);
+		List<TsCustomerStatisticDaily> list = customerStatisticDailyMapper.getDailyList(customerType,orgId,nowDate,beforeDate,personId);
 		return list;
 	}
 	

src/main/java/com/huiju/estateagents/statistic/service/impl/TsCustomerStatisticMonthlyServiceImpl.java

 	 *
 	 * @param customerType
 	 * @param orgId
+	 * @param personId
 	 * @return
 	 */
 	@Override
-	public List<TsCustomerStatisticMonthly> getCustomerMonthlyList(String customerType, Integer orgId) {
+	public List<TsCustomerStatisticMonthly> getCustomerMonthlyList(String customerType, Integer orgId, String personId) {
 		//当前日期
 		LocalDateTime nowDate = LocalDateTime.now();
 		//12个月前的日期
 		LocalDateTime beforeDate = nowDate.plusMonths(-12);
 		//获取31天的日期数据
-		List<TsCustomerStatisticMonthly> list = customerStatisticMonthlyMapper.getMonthlyList(customerType,orgId,nowDate,beforeDate);
+		List<TsCustomerStatisticMonthly> list = customerStatisticMonthlyMapper.getMonthlyList(customerType,orgId,nowDate,beforeDate,personId);
 		return list;
 	}
 	

src/main/resources/mapper/statistic/TsCustomerStatisticDailyMapper.xml

         WHERE
           org_id = #{orgId}
         AND customer_type = #{customerType}
+        AND realty_consultant = #{personId}
         AND date_format( create_date, '%Y-%m-%d' ) >= date_format( #{beforeDate}, '%Y-%m-%d' )
         AND date_format( create_date, '%Y-%m-%d' ) <= date_format( #{nowDate}, '%Y-%m-%d' )
         order by `day`

src/main/resources/mapper/statistic/TsCustomerStatisticMonthlyMapper.xml

         WHERE
           org_id = #{orgId}
         AND customer_type = #{customerType}
+        AND realty_consultant = #{personId}
         AND date_format( create_date, '%Y-%m-%d' ) >= date_format( #{beforeDate}, '%Y-%m-%d' )
         AND date_format( create_date, '%Y-%m-%d' ) <= date_format( #{nowDate}, '%Y-%m-%d' )
          order by `month`