销售简报

src/main/java/com/yunzhi/marketing/dto/StatisticsDTO.java

@@ -17,5 +17,5 @@ public class StatisticsDTO {
 
     private String personId;
 
-    private String channelId;
+    private Integer channelId;
 }

src/main/java/com/yunzhi/marketing/po/CustomerRankListVO.java

@@ -4,4 +4,12 @@ import lombok.Data;
 
 @Data
 public class CustomerRankListVO {
+
+    private Integer number;
+
+    private String recommendPerson;
+
+    private String name;
+
+    private String avatarurl;
 }

src/main/java/com/yunzhi/marketing/service/ChannelCustomerStatisticsService.java

@@ -5,4 +5,11 @@ import com.yunzhi.marketing.dto.StatisticsDTO;
 
 public interface ChannelCustomerStatisticsService {
     ResponseBean getRanklist(StatisticsDTO statisticsDTo);
+
+    /**
+     * 获取销售简报
+     * @param statisticsDTo
+     * @return
+     */
+    ResponseBean getBriefing(StatisticsDTO statisticsDTo);
 }

src/main/java/com/yunzhi/marketing/service/impl/ChannelCustomerStatisticsServiceImpl.java

@@ -3,16 +3,21 @@ package com.yunzhi.marketing.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.yunzhi.marketing.base.ResponseBean;
 import com.yunzhi.marketing.dto.StatisticsDTO;
+import com.yunzhi.marketing.entity.TaChannelPerson;
+import com.yunzhi.marketing.mapper.TaChannelPersonMapper;
 import com.yunzhi.marketing.po.CustomerRankListVO;
 import com.yunzhi.marketing.service.ChannelCustomerStatisticsService;
 import com.yunzhi.marketing.xlk.entity.BuildingChannel;
 import com.yunzhi.marketing.xlk.mapper.BuildingChannelMapper;
 import com.yunzhi.marketing.xlk.mapper.ChannelCustomerMapper;
+import com.yunzhi.marketing.xlk.mapper.CustomerVisitMapper;
 import org.ietf.jgss.ChannelBinding;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 @Service
 public class ChannelCustomerStatisticsServiceImpl implements ChannelCustomerStatisticsService {
@@ -23,17 +28,53 @@ public class ChannelCustomerStatisticsServiceImpl implements ChannelCustomerStat
     @Autowired
     private ChannelCustomerMapper channelCustomerMapper;
 
+    @Autowired
+    private TaChannelPersonMapper channelPersonMapper;
+
+    @Autowired
+    private CustomerVisitMapper customerVisitMapper;
+
     @Override
     public ResponseBean getRanklist(StatisticsDTO statisticsDTo) {
-        LambdaQueryWrapper<BuildingChannel> lambdaQueryWrapper = new LambdaQueryWrapper<>();
-        lambdaQueryWrapper.eq(BuildingChannel::getBuildingId,statisticsDTo.getBuildingId());
-        BuildingChannel buildingChannel = buildingChannelMapper.selectOne(lambdaQueryWrapper);
+        LambdaQueryWrapper<TaChannelPerson> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(TaChannelPerson::getPersonId,statisticsDTo.getPersonId());
+        TaChannelPerson taChannelPerson = channelPersonMapper.selectOne(lambdaQueryWrapper);
 
-        if (null == buildingChannel) {
-            return ResponseBean.error("此楼盘未绑定渠道商", ResponseBean.ERROR_UNAVAILABLE);
+        if (null == taChannelPerson) {
+            return ResponseBean.error("此用户未绑定渠道商", ResponseBean.ERROR_UNAVAILABLE);
         }
-        statisticsDTo.setChannelId(buildingChannel.getChannelId());
+        statisticsDTo.setChannelId(taChannelPerson.getChannelId());
         List<CustomerRankListVO> list = channelCustomerMapper.getRanklist(statisticsDTo);
         return ResponseBean.success(list);
     }
+
+    /**
+     * 获取销售简报
+     *
+     * @param statisticsDTo
+     * @return
+     */
+    @Override
+    public ResponseBean getBriefing(StatisticsDTO statisticsDTo) {
+        LambdaQueryWrapper<TaChannelPerson> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(TaChannelPerson::getPersonId,statisticsDTo.getPersonId());
+        TaChannelPerson taChannelPerson = channelPersonMapper.selectOne(lambdaQueryWrapper);
+
+        if (null == taChannelPerson) {
+            return ResponseBean.error("此用户未绑定渠道商", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        statisticsDTo.setChannelId(taChannelPerson.getChannelId());
+
+        // 获取新增客户
+        int newCustomerNum = channelCustomerMapper.getNewCustomer(statisticsDTo);
+        // 获取跟进客户
+        int followCustomerNum =  customerVisitMapper.getFollowCustomer(statisticsDTo);
+        // 获取成交客户
+        int successCustomerNum = channelCustomerMapper.getSuccessCustomer(statisticsDTo);
+        Map<String,Object> map = new HashMap<>();
+        map.put("newCustomerNum",newCustomerNum);
+        map.put("followCustomerNum",followCustomerNum);
+        map.put("successCustomerNum",successCustomerNum);
+        return ResponseBean.success(map);
+    }
 }

src/main/java/com/yunzhi/marketing/xlk/controller/ChannelCustomerStatisticsController.java

@@ -53,4 +53,29 @@ public class ChannelCustomerStatisticsController extends BaseController {
         statisticsDTo.setPersonId(person.getPersonId());
         return  channelCustomerStatisticsService.getRanklist(statisticsDTo);
     }
+
+    @ApiOperation(value = "wx-销售简报", notes = "wx-销售简报")
+    @GetMapping(value="/wx/briefing")
+    public ResponseBean getBriefing(@RequestParam("buildingId") String buildingId,
+                                    @RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime startDate,
+                                    @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime endDate,
+                                    @RequestHeader("authorization") String token, HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        String openid = getOpenId(request);
+        Integer orgId = getOrgId(request);
+        List<TaPerson> persons = taPersonService.getPersonsByOpenId(openid);
+        if (null == persons || persons.size() == 0) {
+            return ResponseBean.error("当前账户信息异常, 清除缓存重试", ResponseBean.ERROR_UNAVAILABLE);
+        }
+        TaPerson person = persons.get(0);
+
+        // 构造参数
+        StatisticsDTO statisticsDTo = new StatisticsDTO();
+        statisticsDTo.setBuildingId(buildingId);
+        statisticsDTo.setStartDate(startDate);
+        statisticsDTo.setEndDate(endDate);
+        statisticsDTo.setOrgId(orgId);
+        statisticsDTo.setPersonId(person.getPersonId());
+        return  channelCustomerStatisticsService.getBriefing(statisticsDTo);
+    }
 }

src/main/java/com/yunzhi/marketing/xlk/mapper/ChannelCustomerMapper.java

@@ -36,4 +36,18 @@ public interface ChannelCustomerMapper extends BaseMapper<ChannelCustomer> {
     List<CustomerRankListVO> getRanklist(@Param("params") StatisticsDTO statisticsDTo);
 
     IPage<MineRecommendCustomerPO>  getCustomersIRecommended(IPage<MineRecommendCustomerPO> page,@Param("params") RecommendCustomerDTO recommendCustomerDTO);
+
+    /**
+     * 新增客户
+     * @param statisticsDTo
+     * @return
+     */
+    int getNewCustomer(@Param("params") StatisticsDTO statisticsDTo);
+
+    /**
+     *
+     * @param statisticsDTo
+     * @return
+     */
+    int getSuccessCustomer(@Param("params") StatisticsDTO statisticsDTo);
 }

src/main/java/com/yunzhi/marketing/xlk/mapper/CustomerVisitMapper.java

@@ -1,8 +1,10 @@
 package com.yunzhi.marketing.xlk.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yunzhi.marketing.dto.StatisticsDTO;
 import com.yunzhi.marketing.xlk.entity.CustomerVisit;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
@@ -15,4 +17,5 @@ import org.apache.ibatis.annotations.Mapper;
 @Mapper
 public interface CustomerVisitMapper extends BaseMapper<CustomerVisit> {
 
+    int getFollowCustomer(@Param("params") StatisticsDTO statisticsDTo);
 }

src/main/resources/mapper/xlk/ChannelCustomerMapper.xml

@@ -48,12 +48,14 @@
         SELECT
             COUNT(1) as number,
             t.recommend_person,
-            p.`name`
+            p.`name`,
+            p.avatarurl
         FROM
             xlk_channel_customer t
         LEFT JOIN ta_person p on t.recommend_person = p.person_id
         WHERE t.channel_id  = #{params.channelId}
-        and `status` != 3
+        and t.building_id = #{params.buildingId}
+        and t.`status` != 3
         <if test="params.startDate != null or params.endDate != null">
             AND t.create_date BETWEEN #{params.startDate} and #{params.endDate}
         </if>
@@ -96,4 +98,35 @@
         ORDER BY
         a.create_date desc
     </select>
+    <select id="getNewCustomer" resultType="java.lang.Integer">
+        SELECT
+         COUNT(1)
+        FROM
+        xlk_channel_customer t
+        WHERE t.channel_id  = #{params.channelId}
+        and t.building_id = #{params.buildingId}
+        and t.`status` = 1
+        <if test="params.startDate != null or params.endDate != null">
+            AND t.create_date BETWEEN #{params.startDate} and #{params.endDate}
+        </if>
+        <if test="params.startDate == null or params.endDate == null">
+            AND t.create_date BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
+        </if>
+    </select>
+    <select id="getSuccessCustomer" resultType="java.lang.Integer">
+        SELECT
+        COUNT(1)
+        FROM
+        xlk_channel_customer t
+        LEFT join ta_recommend_customer r on t.customer_id = r.customer_id
+        WHERE t.channel_id  = #{params.channelId}
+        and t.building_id = #{params.buildingId}
+        and r.`status` in (4,5)
+        <if test="params.startDate != null or params.endDate != null">
+            AND t.create_date BETWEEN #{params.startDate} and #{params.endDate}
+        </if>
+        <if test="params.startDate == null or params.endDate == null">
+            AND t.create_date BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
+        </if>
+    </select>
 </mapper>

src/main/resources/mapper/xlk/CustomerVisitMapper.xml

@@ -2,4 +2,19 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yunzhi.marketing.xlk.mapper.CustomerVisitMapper">
 
+    <select id="getFollowCustomer" resultType="java.lang.Integer">
+        SELECT
+            COUNT(1)
+        FROM
+        xlk_channel_customer t
+        INNER JOIN xlk_customer_visit v on t.customer_id = v.customer_id
+        INNER JOIN ta_customer_follow_up_record f on t.customer_id = f.customer_id
+        WHERE t.channel_id  = #{params.channelId}
+        <if test="params.startDate != null or params.endDate != null">
+            AND t.create_date BETWEEN #{params.startDate} and #{params.endDate}
+        </if>
+        <if test="params.startDate == null or params.endDate == null">
+            AND t.create_date BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
+        </if>
+    </select>
 </mapper>