用户来源新需求

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

                                             HttpServletRequest request) {
         return iStatisticalService.selectPersonFrom(getOrgId(request), startDate,endDate);
     }
+
+    /**
+     * 用户来源  折线图 首页
+     * @return
+     */
+    @GetMapping(value = "/admin/selectPersonFromGroupByDay")
+    public ResponseBean selectPersonFromGroupByDay(@RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate startDate,
+                                         @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate endDate,
+                                         HttpServletRequest request) {
+        return iStatisticalService.selectPersonFromGroupByDay(getOrgId(request), startDate,endDate);
+    }
 }

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

 package com.huiju.estateagents.entity;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
     private String sceneAlias;
 
 
+    /**
+     * 来源人数合集
+     */
+    @TableField(exist = false)
+    private Integer fromData;
+
+    /**
+     * 注册人数合集
+     */
+    @TableField(exist = false)
+    private Integer registerSum;
 }

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

      * @return
      */
     ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate);
+
+    /**
+     * 用户来源数据统计折线图
+     * @param orgId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    ResponseBean selectPersonFromGroupByDay(Integer orgId, LocalDate startDate, LocalDate endDate);
 }

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

 package com.huiju.estateagents.service.impl;
 
+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.ResponseBean;
 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.entity.TaPersonVisitRecord;
+import com.huiju.estateagents.entity.TdWxDict;
 import com.huiju.estateagents.exception.EstaException;
 import com.huiju.estateagents.mapper.*;
 import com.huiju.estateagents.po.PersonPO;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDate;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.time.temporal.ChronoUnit;
 import java.util.*;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 /**
  * 数据统计
     @Autowired
     private TsPersonFromStatisticMapper tsPersonFromStatisticMapper;
 
+    @Autowired
+    private TdWxDictMapper tdWxDictMapper;
+
 
     @Override
     public ResponseBean indexStatistical(Integer orgId) {
      */
     @Override
     public ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate) {
+        ResponseBean responseBean = new ResponseBean();
         List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFrom(orgId,startDate,endDate);
-        return null;
+        QueryWrapper<TdWxDict> tdWxDictQueryWrapper = new QueryWrapper<>();
+        tdWxDictQueryWrapper.groupBy("scene_type");
+        List<TdWxDict> tdWxDicts = tdWxDictMapper.selectList(tdWxDictQueryWrapper);
+        tdWxDicts.forEach(e -> {
+            int fromSum = list.stream().filter(l -> e.getSceneType().equals(l.getSceneType())).mapToInt(TsPersonFromStatistic::getFromNum).sum();
+            int registerSum = list.stream().filter(l -> e.getSceneType().equals(l.getSceneType())).mapToInt(TsPersonFromStatistic::getRegisteredNum).sum();
+            e.setFromData(fromSum);
+            e.setRegisterSum(registerSum);
+        });
+
+        responseBean.addSuccess(tdWxDicts);
+        return responseBean;
+    }
+
+    /**
+     * 用户来源数据统计折线图
+     *
+     * @param orgId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    @Override
+    public ResponseBean selectPersonFromGroupByDay(Integer orgId, LocalDate startDate, LocalDate endDate) {
+        List<TsPersonFromStatistic> dayList = getDayList(startDate, endDate);
+        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFromGroupByDay(orgId,startDate,endDate);
+        dayList.forEach(e -> {
+            list.forEach(l -> {
+                if (e.getCreateTime().equals(l.getCreateTime())){
+                    e.setFromNum(l.getFromNum());
+                    e.setRegisteredNum(l.getRegisteredNum());
+                }
+            });
+        });
+        return ResponseBean.success(dayList);
+    }
+
+    /**
+     * 返回时间区间格式
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    private List<TsPersonFromStatistic> getDayList(LocalDate startDate, LocalDate endDate) {
+        if (null == startDate || null == endDate){
+            endDate = LocalDate.now();
+            startDate = LocalDate.now().plusDays(-7);
+        }
+
+        //获取时间区间
+        List<LocalDate> dates = Stream.iterate(startDate, date -> date.plusDays(1))
+                .limit(ChronoUnit.DAYS.between(startDate, endDate))
+                .collect(Collectors.toList());
+
+        //格式化时间
+        List<TsPersonFromStatistic> dataList = new ArrayList<>();
+        DateTimeFormatter dtf3 = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        dates.forEach(e -> {
+            TsPersonFromStatistic tsPersonFromStatistic = new TsPersonFromStatistic();
+            tsPersonFromStatistic.setRegisteredNum(0);
+            tsPersonFromStatistic.setFromNum(0);
+            tsPersonFromStatistic.setCreateTime(dtf3.format(e));
+            dataList.add(tsPersonFromStatistic);
+        });
+        return dataList;
     }
 }

src/main/java/com/huiju/estateagents/statistic/entity/TsPersonFromStatistic.java

 package com.huiju.estateagents.statistic.entity;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
      * 注册数量
      */
     private Integer registeredNum;
+
+    /**
+     * 时间
+     */
+    @TableField(exist = false)
+    private String createTime;
 }

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

     void insertStatisticList(List<TsPersonFromStatistic> list);
 
     List<TsPersonFromStatistic> selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate);
+
+    List<TsPersonFromStatistic> selectPersonFromGroupByDay(Integer orgId, LocalDate startDate, LocalDate endDate);
 }

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

         SELECT
             *
         FROM
-        ta_person_from_record tp
-        where tp.org_id = #{org}
+        ts_person_from_statistic tp
+        where tp.org_id = #{orgId}
         <if test="startDate != null or endDate != null">
             AND  tp.create_date BETWEEN #{startDate} and #{endDate}
         </if>
             AND tp.create_date BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
         </if>
     </select>
+    <select id="selectPersonFromGroupByDay"
+            resultType="com.huiju.estateagents.statistic.entity.TsPersonFromStatistic">
+        SELECT
+            sum( tp.from_num ) AS from_num,
+            sum( tp.registered_num ) AS registered_num,
+            DATE_FORMAT( tp.create_date, '%Y-%m-%d' ) AS create_time
+        FROM
+            ts_person_from_statistic tp
+        WHERE
+            tp.org_id = #{orgId}
+        <if test="startDate != null or endDate != null">
+            AND  tp.create_date BETWEEN #{startDate} and #{endDate}
+        </if>
+        <if test="startDate == null or endDate == null">
+            AND tp.create_date BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
+        </if>
+        GROUP BY
+            DATE_FORMAT( tp.create_date, '%Y-%m-%d' )
+    </select>
 </mapper>