提交

kongdeqiang

2023-07-05 4390e392275b4320e18e39a508149d24bce04f93

提交

 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){

 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;

 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;

 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("正在运行，强制退出-------》");
@@ -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);

 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("正在运行，强制退出-------》");
@@ -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);

 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: