视频平台对接

src/main/java/com/zhiqiyun/open/core/mapper/statistics/HyMonitorConsumeMapper.java

@@ -49,4 +49,14 @@ public interface HyMonitorConsumeMapper extends BaseMapper<HyMonitorConsume> {
 
     @Select("select SUBSTRING_INDEX(hmc.source_area,'、',1) as label,count(hmc.id) as `value` from hy_monitor_consume hmc where hmc.is_deleted = 0 and hmc.mechanism_id = #{orgId} group by label ORDER BY `value` DESC LIMIT 10")
     List<EchartsModel> sourceGender(Long orgId);
+
+    /**
+     * 按天计算客流趋势
+     *
+     * @param start 开始时间
+     * @param end   结束时间
+     * @return 数据列表
+     */
+    @Select("select * from (select DATE_FORMAT(hmc.create_date,'%Y-%m-%d') as `label`,SUM(hmc.person) AS `value` from liucheng_smart.xc_monitor hmc where hmc.is_deleted = 0 group by DATE_FORMAT(hmc.create_date,'%Y-%m-%d')) h where h.label >= #{start} and h.label <= #{end}")
+    List<EchartsModel> monthlyFlowList(@Param("start") String start, @Param("end") String end);
 }

src/main/java/com/zhiqiyun/open/core/service/HyMonitorConsumeService.java

@@ -3,6 +3,7 @@ package com.zhiqiyun.open.core.service;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.zhiqiyun.open.core.models.EchartsModel;
 import com.zhiqiyun.open.core.models.statistics.HyMonitorConsume;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 import java.util.Map;
@@ -92,4 +93,11 @@ public interface HyMonitorConsumeService extends IService<HyMonitorConsume> {
      * @return List<EchartsModel>
      */
     List<EchartsModel> sourceGender(Long orgId);
+
+    /**
+     * 每日客流趋势
+     *
+     * @return List<EchartsModel>
+     */
+    List<EchartsModel> monthlyFlowList();
 }

src/main/java/com/zhiqiyun/open/core/service/impl/HyMonitorConsumeServiceImpl.java

@@ -93,4 +93,11 @@ public class HyMonitorConsumeServiceImpl extends ServiceImpl<HyMonitorConsumeMap
     public List<EchartsModel> sourceGender(Long orgId) {
         return baseMapper.sourceGender(orgId);
     }
+
+    @Override
+    public List<EchartsModel> monthlyFlowList() {
+        List<String> dayList = DateUtil.getDayList(7);
+        List<EchartsModel> models = baseMapper.monthlyFlowList(dayList.get(0), dayList.get(6));
+        return CommonUtils.getEchartsModel(dayList, models);
+    }
 }

src/main/java/com/zhiqiyun/open/mvc/controller/MonitorController.java

@@ -50,6 +50,11 @@ public class MonitorController {
         return this.getOapResponse("/openApi/xc/monitor/desc/list", params);
     }
 
+    @GetMapping("monthlyFlowList")
+    public Result monthlyFlowList(@RequestParam Map<String, String> params) throws Exception {
+        return Result.instance(Result.Code.SUCCESS).setData(this.hyMonitorConsumeService.monthlyFlowList());
+    }
+
     private Result getOapResponse(String uri, Map<String, String> dataMap) throws Exception {
         Connection.Response resp = Jsoup.connect(wlapiServerHost + uri)
                 .data(dataMap)