From ac852d8662829793e4015c17c2ece706d93a81ed Mon Sep 17 00:00:00 2001 From: yangzongjia Date: Thu, 8 Jun 2023 21:44:17 +0800 Subject: [PATCH] =?UTF-8?q?=E6=91=84=E5=83=8F=E5=A4=B4=E7=8A=B6=E6=80=81?= =?UTF-8?q?=20=20=20=E5=8A=A0=E7=8A=B6=E6=80=81=20=E8=AE=BE=E5=A4=87?= =?UTF-8?q?=E6=97=A5=E5=BF=97=E6=9F=A5=E8=AF=A2=20=E4=BB=93=E5=BA=93?= =?UTF-8?q?=E8=A1=A8=20=E6=9F=A5=E8=AF=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../monitor/api/entity/MessageInfo.java | 13 +++++++ .../monitor/api/entity/WareHouse.java | 35 +++++++++++++++++ .../monitor/biz/device/YDeviceMapper.java | 5 +++ .../monitor/biz/device/YDeviceMapper.xml | 8 ++++ .../monitor/biz/device/YDeviceRest.java | 9 +++++ .../monitor/biz/device/YDeviceService.java | 19 ++++++++- .../biz/deviceImage/YDeviceImageService.java | 14 ++++--- .../biz/messageInfo/YMessageInfoMapper.java | 3 +- .../biz/messageInfo/YMessageInfoMapper.xml | 10 +++++ .../biz/messageInfo/YMessageInfoRest.java | 19 ++++----- .../biz/messageInfo/YMessageInfoService.java | 39 +++++++++++++++++++ .../monitor/biz/scheduled/SyncDetection.java | 2 +- .../monitor/biz/scheduled/SyncService.java | 2 +- .../monitor/biz/util/ImageDownloadUtil.java | 2 +- .../src/main/resources/application-test.yml | 5 +++ .../src/main/resources/task-config.properties | 3 -- 16 files changed, 165 insertions(+), 23 deletions(-) create mode 100644 yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/WareHouse.java create mode 100644 yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.xml create mode 100644 yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoMapper.xml delete mode 100644 yxt-supervise-monitor-biz/src/main/resources/task-config.properties diff --git a/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/MessageInfo.java b/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/MessageInfo.java index 0ef4abc..9427110 100644 --- a/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/MessageInfo.java +++ b/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/MessageInfo.java @@ -1,5 +1,6 @@ package com.yxt.supervise.monitor.api.entity; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; import com.yxt.common.core.domain.EntityWithId; @@ -51,4 +52,16 @@ public class MessageInfo extends EntityWithId { @ApiModelProperty("信息内容") private String content; + + @TableField(exist = false) + @ApiModelProperty("消息类型") + private String callType; + + @TableField(exist = false) + @ApiModelProperty("设备名称") + private String name; + + @TableField(exist = false) + @ApiModelProperty("设备位置") + private String position; } diff --git a/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/WareHouse.java b/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/WareHouse.java new file mode 100644 index 0000000..a72fe57 --- /dev/null +++ b/yxt-supervise-monitor-api/src/main/java/com/yxt/supervise/monitor/api/entity/WareHouse.java @@ -0,0 +1,35 @@ +package com.yxt.supervise.monitor.api.entity; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.yxt.common.core.domain.EntityWithId; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Date; + +@Data +@ApiModel(value = "有ID的实体", description = "有ID的实体") +public class WareHouse { + + @ApiModelProperty("ID,唯一编号") + private Integer id; + + @ApiModelProperty("仓库名称") + private String name; // 名称 + + @ApiModelProperty("位置") + private String position; + + @ApiModelProperty("货架号") + private String code; + + @ApiModelProperty("联系人") + private String lxr; + + @ApiModelProperty("手机号") + private String lxdh; + +} diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.java index a46526f..538793b 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.java @@ -3,9 +3,14 @@ package com.yxt.supervise.monitor.biz.device; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.yxt.supervise.monitor.api.entity.Device; +import com.yxt.supervise.monitor.api.entity.WareHouse; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + @Mapper public interface YDeviceMapper extends BaseMapper { IPage getDevicePage(); + + List getWareHouseList(); } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.xml b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.xml new file mode 100644 index 0000000..c81360d --- /dev/null +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceMapper.xml @@ -0,0 +1,8 @@ + + + + + \ No newline at end of file diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceRest.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceRest.java index bcc949d..27dc223 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceRest.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceRest.java @@ -92,4 +92,13 @@ public class YDeviceRest { return yDeviceService.removeDeviceByIds(ids); } + + @ApiOperation("获取仓库列表") + @GetMapping("/getWareHouseList") + public ResultBean getWareHouseList() { + ResultBean rb = ResultBean.fireSuccess(); + rb.setData(yDeviceService.getWareHouseList()); + return rb; + } + } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceService.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceService.java index 14fd181..62bb800 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceService.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/device/YDeviceService.java @@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yxt.common.core.result.ResultBean; import com.yxt.supervise.monitor.api.entity.Device; +import com.yxt.supervise.monitor.api.entity.WareHouse; import com.yxt.supervise.monitor.api.vo.PageVo; import com.yxt.supervise.monitor.biz.scheduled.SyncService; import com.yxt.supervise.monitor.biz.util.HttpUtils; @@ -46,6 +47,9 @@ public class YDeviceService extends ServiceImpl { if (StrUtil.isNotBlank(searchVo.get("type"))) { queryWrapper.eq("type", searchVo.get("type")); } + if (StrUtil.isNotBlank(searchVo.get("ckId"))) { + queryWrapper.eq("ckId", searchVo.get("ckId")); + } queryWrapper.eq("isDelete", 0); IPage athleteBOIPage = null; @@ -76,6 +80,19 @@ public class YDeviceService extends ServiceImpl { } + public List getWareHouseList() { + + List athleteBOIPage = null; + try { + athleteBOIPage = yDeviceMapper.getWareHouseList(); + } catch (Exception e) { + System.out.println(e); + athleteBOIPage = null; + } + return athleteBOIPage; + } + + public List getStatusList() { QueryWrapper queryWrapper = new QueryWrapper<>(); @@ -91,7 +108,7 @@ public class YDeviceService extends ServiceImpl { } int allCount = this.count(); for (Device device : athleteBOIPage) { - BigDecimal tempCount = new BigDecimal(device.getMaintenance()).divide(new BigDecimal(allCount), 2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100")).setScale(0, BigDecimal.ROUND_HALF_UP); + BigDecimal tempCount = new BigDecimal(device.getMaintenanceCount()).divide(new BigDecimal(allCount), 2, BigDecimal.ROUND_HALF_UP).multiply(new BigDecimal("100")).setScale(0, BigDecimal.ROUND_HALF_UP); String temp = tempCount.toString(); device.setMaintenanceCount(temp); } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/deviceImage/YDeviceImageService.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/deviceImage/YDeviceImageService.java index bb018f2..7259d55 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/deviceImage/YDeviceImageService.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/deviceImage/YDeviceImageService.java @@ -29,7 +29,7 @@ import java.util.Map; @Service public class YDeviceImageService extends ServiceImpl { - @Value("${image.folder}") + @Value("${scheduleTime.folder}") private String filePath; public IPage getDeviceImagePage(Map searchVo, PageVo pageVo) { @@ -85,7 +85,7 @@ public class YDeviceImageService extends ServiceImpl 0) { deviceImage.setSimilarity(similarSplit[0] + "%"); @@ -122,8 +124,8 @@ public class YDeviceImageService extends ServiceImpl { - + IPage getMessageInfoPage(IPage page, @Param("ew") QueryWrapper queryWrapper); } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoMapper.xml b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoMapper.xml new file mode 100644 index 0000000..dda4b8e --- /dev/null +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoMapper.xml @@ -0,0 +1,10 @@ + + + + + \ No newline at end of file diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoRest.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoRest.java index 1cf5dac..8dc2cba 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoRest.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoRest.java @@ -1,12 +1,11 @@ package com.yxt.supervise.monitor.biz.messageInfo; +import com.yxt.common.core.result.ResultBean; +import com.yxt.supervise.monitor.api.vo.PageVo; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import java.util.Map; @@ -19,11 +18,13 @@ public class YMessageInfoRest { private YMessageInfoService yCallPoliceService; - @ApiOperation("分页获取报警列表") - @GetMapping("/getDevicePage") - public String getDevicePage(@RequestParam Map searchVo) { -// yCallPoliceService.getDevicePage(searchVo); - return null; + @ApiOperation("分页获取消息列表") + @GetMapping("/getMessageInfoPage") + public ResultBean getDevicePage(@RequestParam Map searchVo, + @ModelAttribute PageVo pageVo) { + ResultBean rb = ResultBean.fireSuccess(); + rb.setData(yCallPoliceService.getMessageInfoPage(searchVo, pageVo)); + return rb; } } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoService.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoService.java index e31586a..b07d7ac 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoService.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/messageInfo/YMessageInfoService.java @@ -1,14 +1,17 @@ package com.yxt.supervise.monitor.biz.messageInfo; +import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yxt.supervise.monitor.api.entity.CallPolice; import com.yxt.supervise.monitor.api.entity.Device; import com.yxt.supervise.monitor.api.entity.DeviceLog; import com.yxt.supervise.monitor.api.entity.MessageInfo; import com.yxt.supervise.monitor.api.vo.MessageVo; +import com.yxt.supervise.monitor.api.vo.PageVo; import com.yxt.supervise.monitor.biz.callpolice.YCallPoliceMapper; import com.yxt.supervise.monitor.biz.device.YDeviceMapper; import com.yxt.supervise.monitor.biz.device.YDeviceService; @@ -36,6 +39,9 @@ public class YMessageInfoService extends ServiceImpl saveMessageInfo() { String url = "https://api2.hik-cloud.com/api/v1/mq/consumer/messages"; @@ -108,4 +114,37 @@ public class YMessageInfoService extends ServiceImpl getMessageInfoPage(Map searchVo, PageVo pageVo) { + IPage page = new com.baomidou.mybatisplus.extension.plugins.pagination.Page<>(); + page.setSize(pageVo.getSize()); + page.setCurrent((long) pageVo.getCurrent()); + + QueryWrapper queryWrapper = new QueryWrapper<>(); + + if (StrUtil.isNotBlank(searchVo.get("startTime"))) { + queryWrapper.gt("t.createTime", searchVo.get("startTime")); + } + + if (StrUtil.isNotBlank(searchVo.get("name"))) { + queryWrapper.like("d.name", searchVo.get("name")); + } + + if (StrUtil.isNotBlank(searchVo.get("position"))) { + queryWrapper.like("d.position", searchVo.get("position")); + } + queryWrapper.eq("t.isDelete", 0); + + IPage athleteBOIPage = null; + try { + athleteBOIPage = yMessageInfoMapper.getMessageInfoPage(page, queryWrapper); + athleteBOIPage.getRecords().forEach(oo -> { + oo.setCallType("消息通知"); + }); + } catch (Exception e) { + System.out.println(e); + athleteBOIPage = null; + } + return athleteBOIPage; + } } diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncDetection.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncDetection.java index 8e68760..6efa9a8 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncDetection.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncDetection.java @@ -26,7 +26,7 @@ import java.util.Map; @Data @Slf4j @Component -@PropertySource("classpath:/task-config.properties") +@PropertySource("classpath:/application-test.yml") public class SyncDetection implements SchedulingConfigurer { @Value("${scheduleTime.cron}") diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncService.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncService.java index 1067975..44c2d9a 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncService.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/scheduled/SyncService.java @@ -73,7 +73,7 @@ public class SyncService { } - +// // @Async // @Scheduled(fixedDelay = 1000 * 20 * 1) //20秒拉取一次报警信息 // public void pushEmail() { diff --git a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/util/ImageDownloadUtil.java b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/util/ImageDownloadUtil.java index 823b8be..7f20b9d 100644 --- a/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/util/ImageDownloadUtil.java +++ b/yxt-supervise-monitor-biz/src/main/java/com/yxt/supervise/monitor/biz/util/ImageDownloadUtil.java @@ -33,7 +33,7 @@ public class ImageDownloadUtil { } //jdk 1.7 新特性自动关闭 try (InputStream in = con.getInputStream(); - OutputStream out = new FileOutputStream(sf.getPath() + "\\" + filename)) { + OutputStream out = new FileOutputStream(sf.getPath() + "/" + filename)) { //创建缓冲区 byte[] buff = new byte[1024]; int n; diff --git a/yxt-supervise-monitor-biz/src/main/resources/application-test.yml b/yxt-supervise-monitor-biz/src/main/resources/application-test.yml index 53ffe9f..785375a 100644 --- a/yxt-supervise-monitor-biz/src/main/resources/application-test.yml +++ b/yxt-supervise-monitor-biz/src/main/resources/application-test.yml @@ -28,3 +28,8 @@ image: url: prefix: http://122.14.222.186:7003/upload/ +scheduleTime: + cron: 0/59 0/2 * * * ? +# folder: D:\resources\download + folder: /root/huirong/monitor-java/imagesDownload + diff --git a/yxt-supervise-monitor-biz/src/main/resources/task-config.properties b/yxt-supervise-monitor-biz/src/main/resources/task-config.properties deleted file mode 100644 index 91e7a93..0000000 --- a/yxt-supervise-monitor-biz/src/main/resources/task-config.properties +++ /dev/null @@ -1,3 +0,0 @@ -scheduleTime.cron=0/59 0/2 * * * ? - -image.folder=D:\\resources\\download\\ \ No newline at end of file