From 4390e392275b4320e18e39a508149d24bce04f93 Mon Sep 17 00:00:00 2001 From: kongdeqiang <123456> Date: 星期三, 05 七月 2023 14:49:46 +0800 Subject: [PATCH] 提交 --- src/main/java/com/boying/job/BaoJingScheduled.java | 7 ++- src/main/java/com/boying/job/YunWeiSchheduled.java | 7 ++- src/main/java/com/boying/entity/DongHuanBaoJing.java | 3 + src/main/java/com/boying/entity/WarnLog.java | 7 +++ src/main/java/com/boying/controller/ApiController.java | 69 ++++++++++++++++++++++++++++++++-- src/main/resources/application.yml | 9 +++- 6 files changed, 87 insertions(+), 15 deletions(-) diff --git a/src/main/java/com/boying/controller/ApiController.java b/src/main/java/com/boying/controller/ApiController.java index c36aea7..f7bcdc3 100755 --- a/src/main/java/com/boying/controller/ApiController.java +++ b/src/main/java/com/boying/controller/ApiController.java @@ -4,6 +4,7 @@ import cn.hutool.http.HttpRequest; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.extension.api.R; import com.boying.entity.*; import com.boying.service.*; @@ -16,6 +17,7 @@ import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; +import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; @@ -121,9 +123,12 @@ Map<String,Object> map = new HashMap<>(); try { QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>(); + wrapper.select(" id,is_ok"); wrapper.lambda() .eq(InspectionTask::getIsOk,1); - List<InspectionTask> inspectionTasks = inspectionTaskService.list(null); + QueryWrapper<InspectionTask> wrapper1 = new QueryWrapper<>(); + wrapper1.select(" id,is_ok"); + List<InspectionTask> inspectionTasks = inspectionTaskService.list(wrapper1); List<InspectionTask> inspectionTasks2 = inspectionTaskService.list(wrapper); map.put("count",inspectionTasks.size()); map.put("normalCount",inspectionTasks2.size()); @@ -137,6 +142,7 @@ public R getTaskInfoById(String id){ try { QueryWrapper<TaskInfo> wrapper = new QueryWrapper<>(); + wrapper.select(" id,task_id,task_date,is_ok,content"); wrapper.lambda() .eq(TaskInfo::getTaskId,id); List<TaskInfo> infos = taskInfoService.list(wrapper); @@ -150,8 +156,9 @@ public R getTaskByDate(String startDate,String endDate){ try { QueryWrapper<InspectionTask> wrapper = new QueryWrapper<>(); + wrapper.select(" id,title,start_date"); wrapper.lambda() - .between(InspectionTask::getStartDate,startDate,endDate); + .between(StringUtils.isNotBlank(startDate) && StringUtils.isNotBlank(endDate),InspectionTask::getStartDate,startDate,endDate); return R.ok(inspectionTaskService.list(wrapper)); } catch (Exception e) { return R.failed("鍑洪敊"); @@ -195,8 +202,60 @@ QueryWrapper<WarnLog> wrapper = new QueryWrapper<>(); wrapper.lambda().eq(type != null,WarnLog::getType,type) .orderByDesc(WarnLog::getWarnDate) - .last( " limit 15"); + .last( " limit 11"); List<WarnLog> list = warnService.list(wrapper); + return R.ok(list); + } + + /** + * 鍦板浘鏁版嵁 + * @param + * @return + */ + @GetMapping("/getMapData") + public R getMapData(){ + List<Map<String,Object>> list = new ArrayList<>(); + Map<String,Object> map1 = new HashMap<>(); + map1.put("lon","118.14360"); + map1.put("lat","39.67260"); + map1.put("address","娌冲寳鐪佸攼灞卞競璺寳鍖洪暱瀹侀亾603鍙�"); + map1.put("health",0); + + Map<String,Object> map2 = new HashMap<>(); + map2.put("lon","118.26958"); + map2.put("lat","39.68333"); + map2.put("address","娌冲寳鐪佸攼灞卞競寮�骞冲尯涓滆タ澶ц199鍙�"); + map2.put("health",0); + + Map<String,Object> map3 = new HashMap<>(); + map3.put("lon","118.15782"); + map3.put("lat","39.63102"); + map3.put("address","娌冲寳鐪佸攼灞卞競璺崡鍖烘柊鍗庤タ閬�76鍙�4灞�"); + map3.put("health",0); + + Map<String,Object> map4 = new HashMap<>(); + map4.put("lon","118.09289"); + map4.put("lat","39.58163"); + map4.put("address","娌冲寳鐪佸攼灞卞競涓板崡鍖烘鑻戝ぇ琛�7鍙�"); + map4.put("health",0); + + Map<String,Object> map5 = new HashMap<>(); + map5.put("lon","118.14114"); + map5.put("lat","39.83368"); + map5.put("address","娌冲寳鐪佸攼灞卞競涓版鼎鍖烘浌闆姽澶ц17鍙�"); + map5.put("health",0); + + Map<String,Object> map6 = new HashMap<>(); + map6.put("lon","118.45153"); + map6.put("lat","39.74049"); + map6.put("address","娌冲寳鐪佸攼灞卞競鍙ゅ喍鍖烘案鐩涜矾"); + map6.put("health",0); + list.add(map1); + list.add(map2); + list.add(map3); + list.add(map4); + list.add(map5); + list.add(map6); return R.ok(list); } @@ -209,8 +268,8 @@ @RequestMapping("/upload") public R upload(@RequestParam("file") MultipartFile file,@RequestParam("type") Integer type)throws Exception{ String name = file.getOriginalFilename(); - String s = name.split(".")[1]; - if(!s.equals(".xls")) { + String[] split = name.split("\\."); + if(!split[1].equals("xlsx")) { throw new Exception("鏂囦欢鏍煎紡閿欒"); } if(type == 0){ diff --git a/src/main/java/com/boying/entity/DongHuanBaoJing.java b/src/main/java/com/boying/entity/DongHuanBaoJing.java index 65ecf4b..1e69ae6 100644 --- a/src/main/java/com/boying/entity/DongHuanBaoJing.java +++ b/src/main/java/com/boying/entity/DongHuanBaoJing.java @@ -10,7 +10,8 @@ * @createTime 2023骞�06鏈�19鏃� 08:30:00 */ @Data -public class DongHuanBaoJing extends BaseEntity { +public class DongHuanBaoJing{ + private String id; private String oid; private String deviceName; private String bianLiangName; diff --git a/src/main/java/com/boying/entity/WarnLog.java b/src/main/java/com/boying/entity/WarnLog.java index 20be5d2..f8d0781 100644 --- a/src/main/java/com/boying/entity/WarnLog.java +++ b/src/main/java/com/boying/entity/WarnLog.java @@ -1,8 +1,11 @@ package com.boying.entity; +import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; +import org.springframework.format.annotation.DateTimeFormat; import java.time.LocalDate; +import java.time.LocalDateTime; import java.util.Date; /** @@ -15,7 +18,9 @@ @Data public class WarnLog{ private String id; - private LocalDate warnDate; + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss", timezone = "GMT+8") + private LocalDateTime warnDate; private Integer type; //1.涓绘満 2.鏁伴�氳澶� 3.ups 4.绌鸿皟 5.娓╂箍搴� 6銆佹紡姘� 7.鍏朵粬 private String name; private String content; diff --git a/src/main/java/com/boying/job/BaoJingScheduled.java b/src/main/java/com/boying/job/BaoJingScheduled.java index cbc4794..bf10d87 100644 --- a/src/main/java/com/boying/job/BaoJingScheduled.java +++ b/src/main/java/com/boying/job/BaoJingScheduled.java @@ -14,6 +14,7 @@ import org.springframework.stereotype.Component; import java.time.LocalDate; +import java.time.LocalDateTime; import java.util.List; /** @@ -33,7 +34,7 @@ private WarnService warnService; private Boolean taskFlag = false; - @Scheduled(cron = "0 0/6 * * * ?") + //@Scheduled(cron = "0 0/6 * * * ?") public void execute() throws Exception { if (taskFlag == true) { System.out.println("姝e湪杩愯锛屽己鍒堕��鍑�-------銆�"); @@ -56,7 +57,7 @@ && !dongHuanBaoJing.getBianLiangName().contains("璐熻浇淇濇姢")){ WarnLog warnLog = new WarnLog(); warnLog.setId(UUID.fastUUID().toString(true)); - warnLog.setWarnDate(LocalDate.now()); + warnLog.setWarnDate(LocalDateTime.now()); warnLog.setName(dongHuanBaoJing.getDeviceName()); warnLog.setContent(dongHuanBaoJing.getBianLiangName()+"寮傚父"); WarnLog type = getType(warnLog); @@ -65,7 +66,7 @@ || dongHuanBaoJing.getBianLiangName().contains("璐熻浇淇濇姢")) ){ WarnLog warnLog = new WarnLog(); warnLog.setId(UUID.fastUUID().toString(true)); - warnLog.setWarnDate(LocalDate.now()); + warnLog.setWarnDate(LocalDateTime.now()); warnLog.setName(dongHuanBaoJing.getDeviceName()); warnLog.setContent(dongHuanBaoJing.getBianLiangName()+"寮傚父"); WarnLog type = getType(warnLog); diff --git a/src/main/java/com/boying/job/YunWeiSchheduled.java b/src/main/java/com/boying/job/YunWeiSchheduled.java index 9340ea6..c35e62e 100644 --- a/src/main/java/com/boying/job/YunWeiSchheduled.java +++ b/src/main/java/com/boying/job/YunWeiSchheduled.java @@ -14,6 +14,7 @@ import org.springframework.stereotype.Component; import java.time.LocalDate; +import java.time.LocalDateTime; import java.util.List; /** @@ -38,7 +39,7 @@ private Boolean taskFlag = false; - @Scheduled(cron = "0 0/6 * * * ?") + @Scheduled(cron = "0 0/3 * * * ?") public void execute() throws Exception { if (taskFlag == true) { System.out.println("姝e湪杩愯锛屽己鍒堕��鍑�-------銆�"); @@ -51,7 +52,7 @@ for (SystemInfo systemInfo : list) { WarnLog warnLog = new WarnLog(); warnLog.setId(UUID.fastUUID().toString(true)); - warnLog.setWarnDate(LocalDate.now()); + warnLog.setWarnDate(LocalDateTime.now()); warnLog.setName(systemInfo.getHostName()); warnLog.setContent("涓绘満鎺夌嚎"); warnLog.setType(1); @@ -64,7 +65,7 @@ for (SnmpInfo snmpInfo : list1) { WarnLog warnLog = new WarnLog(); warnLog.setId(UUID.fastUUID().toString(true)); - warnLog.setWarnDate(LocalDate.now()); + warnLog.setWarnDate(LocalDateTime.now()); warnLog.setName(snmpInfo.getHostName()); warnLog.setContent("璁惧鎺夌嚎"); warnLog.setType(2); diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index c4cd304..1630b66 100755 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -13,15 +13,20 @@ #password: 2022Sw!@# password: rootroot driverClassName: com.mysql.cj.jdbc.Driver - jpa: database: mysql show-sql: false hibernate: ddl-auto: update - redis: host: 127.0.0.1 + servlet: + multipart: + max-file-size: -1 + max-request-size: -1 + jackson: + date-format: yyyy-MM-dd HH:mm:ss + time-zone: GMT+8 # slf4j鏃ュ織閰嶇疆 logging: -- Gitblit v1.9.1