From e31d4d2d3cecab2fb56508c0f5b82d821719e7bb Mon Sep 17 00:00:00 2001
From: zhangzeli <123456>
Date: 星期二, 25 一月 2022 14:39:14 +0800
Subject: [PATCH] bug

---
 xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/controller/pc/StatisticController.java |  226 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 226 insertions(+), 0 deletions(-)

diff --git a/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/controller/pc/StatisticController.java b/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/controller/pc/StatisticController.java
index 78679e7..3f3936e 100644
--- a/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/controller/pc/StatisticController.java
+++ b/xboot-modules/xboot-your/src/main/java/cn/exrick/xboot/your/controller/pc/StatisticController.java
@@ -1,8 +1,21 @@
 package cn.exrick.xboot.your.controller.pc;
 
 import cn.exrick.xboot.core.common.redis.RedisTemplateHelper;
+import cn.exrick.xboot.core.common.utils.PageUtil;
 import cn.exrick.xboot.core.common.utils.ResultUtil;
+import cn.exrick.xboot.core.common.vo.PageVo;
 import cn.exrick.xboot.core.common.vo.Result;
+import cn.exrick.xboot.your.entity.*;
+import cn.exrick.xboot.your.service.*;
+import cn.exrick.xboot.your.util.HaiKangPost;
+import cn.exrick.xboot.your.vo.AlarmVo;
+import cn.exrick.xboot.your.vo.PreviewURLsVo;
+import cn.exrick.xboot.your.vo.TalkURLsVo;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
@@ -25,6 +38,30 @@
     @Autowired
     private RedisTemplateHelper redisTemplateHelper;
 
+    @Autowired
+    private IOrderTaskService iOrderTaskService;
+
+    @Autowired
+    private IEventLogService iEventLogService;
+
+    @Autowired
+    private ICarService iCarService;
+
+    @Autowired
+    private HaiKangPost haiKangPost;
+
+    @Autowired
+    private IAreaService iAreaService;
+
+    @Autowired
+    private IAreaSectionService iAreaSectionService;
+
+    @Autowired
+    private IEquipmentService iEquipmentService;
+
+    @Autowired
+    private IAlarmService iAlarmService;
+
     @RequestMapping(value = "/getIndex1", method = RequestMethod.GET)
     @ApiOperation(value = "鑾峰彇棣栭〉鏁版嵁")
     public Result<Object> getIndex1() {
@@ -35,4 +72,193 @@
         }
         return new ResultUtil<Object>().setData(map);
     }
+
+    @RequestMapping(value = "/getTodayTask", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇浠婃棩閰嶉�佷换鍔�")
+    public Result<Object> getTodayTask() {
+        QueryWrapper<OrderTask> wrapper2 = new QueryWrapper<OrderTask>();
+        String format = DateUtil.format(new Date(), "yyyy-MM-dd");
+        wrapper2.eq("a.send_date",format);
+//        wrapper2.orderByAsc("a.seq");
+        List<OrderTask> list = iOrderTaskService.list3(format);
+        return new ResultUtil<Object>().setData(list);
+    }
+
+    @RequestMapping(value = "/getEventLog", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇浜嬩欢鏃ュ織")
+    public Result<Object> getEventLog() {
+        QueryWrapper<EventLog> wrapper2 = new QueryWrapper<EventLog>();
+        PageVo page = new PageVo();
+        page.setPageNumber(1);
+        page.setPageSize(20);
+        page.setOrder("desc");
+        page.setSort("createTime");
+        IPage<EventLog> data = iEventLogService.page(PageUtil.initMpPage(page),wrapper2);
+        return new ResultUtil<Object>().setData(data.getRecords());
+    }
+
+    @RequestMapping(value = "/getCars", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇杞﹁締瀹氫綅淇℃伅")
+    public Result<Object> getCars() {
+        List<Car> list = iCarService.list();
+        List<String> list2 = new ArrayList<>();
+
+        for(int i=0;i<list.size();i++){
+            if(!StrUtil.isEmpty(list.get(i).getCode())){
+                list2.add(list.get(i).getCode());
+            }
+        }
+
+        String codes[] = new String[list2.size()];
+        for(int i=0;i<list2.size();i++){
+            codes[i] = list2.get(i);
+        }
+        String latestGps = haiKangPost.findLatestGps(codes);
+        return new ResultUtil<Object>().setData(JSONUtil.parseObj(latestGps));
+    }
+
+    @RequestMapping(value = "/getAnalysis", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇閰嶉�佸垎鏋�")
+    public Result<Object> getAnalysis() {
+        List<Area> list = iAreaService.list2();
+        for(Area area:list){
+            double sum = 0;
+            int flag = 0;
+            for(AreaSection areaSection: area.getChildren()){
+                sum+=areaSection.getStability();
+                flag++;
+            }
+            if(flag>0){
+                double v = sum / flag;
+                area.setVariance(trans2(v));
+            }
+        }
+        return new ResultUtil<Object>().setData(list);
+    }
+
+    @RequestMapping(value = "/getAnalysisDetail", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇閰嶉�佸垎鏋愯鎯�")
+    public Result<Object> getAnalysisDetail(String areaName,String selectName) {
+        QueryWrapper<Area> wrapper = new QueryWrapper<Area>();
+        wrapper.eq("name",areaName);
+        Area one = iAreaService.getOne(wrapper);
+
+        QueryWrapper<AreaSection> wrapper2 = new QueryWrapper<AreaSection>();
+        wrapper2.eq("area_id",one.getId());
+        wrapper2.eq("name",selectName);
+        AreaSection one1 = iAreaSectionService.getOne(wrapper2);
+
+        List<OrderTask> list = iOrderTaskService.groupByTime(one.getId(),one1.getId());
+
+        List<String> list1 = new ArrayList<>();
+        List<Integer> list2 = new ArrayList<>();
+        List<Integer> list3 = new ArrayList<>();
+        List<Integer> list4 = new ArrayList<>();
+
+        for(OrderTask obj:list){
+            list1.add(obj.getCustomerName());
+            list2.add(Integer.valueOf(obj.getTime()/60000));
+            list3.add(Integer.valueOf(obj.getNum()/60000));
+            list4.add(Integer.valueOf(obj.getLevel()/60000));
+        }
+        Map<String,Object> map = new HashMap<>();
+        map.put("name",list1);
+        map.put("avg",list2);
+        map.put("min",list3);
+        map.put("max",list4);
+
+        return new ResultUtil<Object>().setData(map);
+    }
+
+    @RequestMapping(value = "/getOrderStatus", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇鏌愯締杞︾殑閰嶉�佹儏鍐�")
+    public Result<Object> getOrderStatus(String carNo) {
+
+        QueryWrapper<Car> wrapper = new QueryWrapper<>();
+        wrapper.eq("car_no",carNo);
+        Car car = iCarService.getOne(wrapper);
+
+        if(car==null){
+           return ResultUtil.error("杞﹁締涓嶅瓨鍦�,璇峰厛娣诲姞杞﹁締淇℃伅");
+        }
+
+        QueryWrapper<OrderTask> wrapper2 = new QueryWrapper<OrderTask>();
+        String format = DateUtil.format(new Date(), "yyyy-MM-dd");
+        wrapper2.eq("a.send_date",format);
+        wrapper2.eq("a.car_id",car.getId());
+        List<OrderTask> list = iOrderTaskService.list4(wrapper2);
+
+        return new ResultUtil<Object>().setData(list);
+    }
+
+    @RequestMapping(value = "/getVideoByCarId", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇瑙嗛淇℃伅 1锛氬墠缃� 4锛氳溅鍐�")
+    public Result<Object> getVideoByCarId(String carCode,int type) {
+        QueryWrapper<Car> wrapper = new QueryWrapper<Car>();
+        wrapper.eq("code",carCode);
+        Car car = iCarService.getOne(wrapper);
+        if(car==null){
+            return ResultUtil.error("杞﹁締缂栧彿閿欒");
+        }
+
+        QueryWrapper<Equipment> wrapper1 = new QueryWrapper<>();
+        wrapper1.eq("car_id",car.getId());
+        wrapper1.eq("type",type);
+        Equipment one = iEquipmentService.getOne(wrapper1);
+        if(one==null){
+            return ResultUtil.error("璁惧鏈壘鍒�");
+        }
+
+        PreviewURLsVo previewURLsVo = new PreviewURLsVo();
+		previewURLsVo.setCameraIndexCode(one.getCode());
+        String s = haiKangPost.previewURLs(previewURLsVo);
+        return new ResultUtil<Object>().setData(JSONUtil.parseObj(s));
+    }
+
+    @RequestMapping(value = "/getYuYinByCarId", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇瀵硅淇℃伅")
+    public Result<Object> getYuYinByCarId(String carCode,int type,int transmode) {
+        QueryWrapper<Car> wrapper = new QueryWrapper<Car>();
+        wrapper.eq("code",carCode);
+        Car car = iCarService.getOne(wrapper);
+        if(car==null){
+            return ResultUtil.error("杞﹁締缂栧彿閿欒");
+        }
+
+        QueryWrapper<Equipment> wrapper1 = new QueryWrapper<>();
+        wrapper1.eq("car_id",car.getId());
+        wrapper1.eq("type",type);
+        Equipment one = iEquipmentService.getOne(wrapper1);
+        if(one==null){
+            return ResultUtil.error("璁惧鏈壘鍒�");
+        }
+
+        TalkURLsVo talkURLsVo =new TalkURLsVo();
+        talkURLsVo.setCameraIndexCode(one.getCode());
+        talkURLsVo.setTransmode(transmode);
+        String s = haiKangPost.talkURLs(talkURLsVo);
+        return new ResultUtil<Object>().setData(JSONUtil.parseObj(s));
+    }
+
+    @RequestMapping(value = "/getAlarmByCarId", method = RequestMethod.GET)
+    @ApiOperation(value = "鑾峰彇鎶ヨ鍥剧墖")
+    public Result<Object> getAlarmByCarId(String alarmId) {
+        QueryWrapper<Alarm> wrapper = new QueryWrapper<Alarm>();
+        wrapper.eq("alarm_id",alarmId);
+        Alarm alarm = iAlarmService.getOne(wrapper);
+        if(alarm==null){
+            return ResultUtil.error("鎶ヨid閿欒");
+        }
+
+        AlarmVo alarmVo = new AlarmVo();
+        alarmVo.setAlarmId(alarm.getAlarmId());
+        String[] s1 = alarm.getAlarmTime().split(" ");
+        alarmVo.setAlarmTime(s1[0]+"T"+s1[1]+".000+08:00");
+        String s = haiKangPost.findPicturesByAlarmId(alarmVo);
+        return new ResultUtil<Object>().setData(JSONUtil.parseObj(s));
+    }
+
+    public double trans2(double v2){
+        return (double) Math.round(v2 * 100) / 100;
+    }
 }

--
Gitblit v1.9.1