From 79a7af577ba1462e05d8fd5e238919e55f1b0b52 Mon Sep 17 00:00:00 2001 From: pengjie <17373303529@163.com> Date: Fri, 13 Dec 2024 17:43:19 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=89=E5=85=A8=E5=B8=BD=E8=B0=83=E6=95=B4(?= =?UTF-8?q?=E4=B8=AD=E5=8C=97=E6=B0=B4=E5=88=A9)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../zhgd/xmgl/config/SafetyHatWSClient.java | 21 ++++----- .../controller/SafetyHatDevController.java | 40 +++++++++--------- .../safetyhat/entity/SafetyHatAlarm.java | 6 +++ .../safetyhat/entity/SafetyHatData.java | 14 ++++++ .../safetyhat/entity/SafetyHatDev.java | 13 ++++-- .../mapper/xml/SafetyHatAlarmMapper.xml | 2 +- .../mapper/xml/SafetyHatDataMapper.xml | 5 ++- .../mapper/xml/SafetyHatDevMapper.xml | 2 +- .../impl/SafetyHatAlarmServiceImpl.java | 1 + .../impl/SafetyHatDataServiceImpl.java | 6 +-- .../service/impl/SafetyHatDevServiceImpl.java | 28 +++++++++--- .../com/zhgd/xmgl/task/SafetyHatTask.java | 2 + .../java/com/zhgd/xmgl/util/ExcelUtils.java | 13 +++++- .../resources/excel/安全帽设备导入模板.xlsx | Bin 9545 -> 10204 bytes 14 files changed, 105 insertions(+), 48 deletions(-) diff --git a/src/main/java/com/zhgd/xmgl/config/SafetyHatWSClient.java b/src/main/java/com/zhgd/xmgl/config/SafetyHatWSClient.java index 05de7fb46..2996dfa26 100644 --- a/src/main/java/com/zhgd/xmgl/config/SafetyHatWSClient.java +++ b/src/main/java/com/zhgd/xmgl/config/SafetyHatWSClient.java @@ -86,16 +86,16 @@ public class SafetyHatWSClient { JSONObject joLocationInfo = joData.getJSONObject("location_info"); if (joLocationInfo != null) { //纬度(坐标系:高德地图 GCJ-02) - Double xPoint = joLocationInfo.getDouble("x_point"); - Double yPoint = joLocationInfo.getDouble("y_point"); - Long ctime = joLocationInfo.getLong("ctime"); - SafetyHatData data = new SafetyHatData(); - data.setWorkerInfoId(dev.getWorkerInfoId()); - data.setDevSn(dev.getDevSn()); - data.setLatitude(xPoint); - data.setLongitude(yPoint); - data.setUploadTime(new Date(ctime * 1000L)); - data.setProjectSn(dev.getProjectSn()); +// Double xPoint = joLocationInfo.getDouble("x_point"); +// Double yPoint = joLocationInfo.getDouble("y_point"); +// Long ctime = joLocationInfo.getLong("ctime"); +// SafetyHatData data = new SafetyHatData(); +// data.setWorkerInfoId(dev.getWorkerInfoId()); +// data.setDevSn(dev.getDevSn()); +// data.setLatitude(xPoint); +// data.setLongitude(yPoint); +// data.setUploadTime(new Date(ctime * 1000L)); +// data.setProjectSn(dev.getProjectSn()); try { //不从这里获取实时坐标,因为从这里获取的轨迹没有经过过滤 //SpringContextUtils.getBean(ISafetyHatDataService.class).add(data); @@ -173,6 +173,7 @@ public class SafetyHatWSClient { alarm.setLongitude(xPoint); alarm.setFenceId(dev.getFenceId()); alarm.setType(dev.getType()); + alarm.setWorkerInfoName(dev.getWorkerInfoName()); if (dev.getType() == 2) { alarm.setAlarmInfo(jo.getString("msg")); } diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/controller/SafetyHatDevController.java b/src/main/java/com/zhgd/xmgl/modules/safetyhat/controller/SafetyHatDevController.java index aadcf4101..a952c2656 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/controller/SafetyHatDevController.java +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/controller/SafetyHatDevController.java @@ -36,10 +36,7 @@ import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.URLEncoder; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; @@ -205,15 +202,19 @@ public class SafetyHatDevController { @GetMapping(value = "/enterprise/tree/list") public Result> queryEnterpriseTreeList(@ApiIgnore @RequestParam HashMap paramMap) { List safetyHatDevs = safetyHatDevService.queryList(paramMap); - List workerIds = safetyHatDevs.stream().map(safetyHatDev -> safetyHatDev.getWorkerInfoId()).collect(Collectors.toList()); - if (CollUtil.isEmpty(workerIds)) { - workerIds.add(-1L); +// List workerIds = safetyHatDevs.stream().map(safetyHatDev -> safetyHatDev.getWorkerInfoId()).collect(Collectors.toList()); +// if (CollUtil.isEmpty(workerIds)) { +// workerIds.add(-1L); +// } +// List workerInfos = workerInfoService.list(new LambdaQueryWrapper().in(WorkerInfo::getId, workerIds)); + List enterpriseIds = new ArrayList<>(); + for (SafetyHatDev safetyHatDev : safetyHatDevs) { + enterpriseIds.addAll(Arrays.asList(safetyHatDev.getEnterpriseIds().split(","))); } - List workerInfos = workerInfoService.list(new LambdaQueryWrapper().in(WorkerInfo::getId, workerIds)); - List enterpriseIds = workerInfos.stream().map(WorkerInfo::getEnterpriseId).collect(Collectors.toList()); - Map> enterpriseMap = workerInfos.stream().collect(Collectors.groupingBy(WorkerInfo::getEnterpriseId)); +// List enterpriseIds = safetyHatDevs.stream().map(WorkerInfo::getEnterpriseId).collect(Collectors.toList()); +// Map> enterpriseMap = workerInfos.stream().collect(Collectors.groupingBy(WorkerInfo::getEnterpriseId)); if (CollUtil.isEmpty(enterpriseIds)) { - enterpriseIds.add(-1L); + enterpriseIds.add("-1"); } List enterpriseInfos = enterpriseInfoService.list(new LambdaQueryWrapper().in(EnterpriseInfo::getId, enterpriseIds)); List rt = new ArrayList<>(); @@ -221,14 +222,15 @@ public class SafetyHatDevController { QueryEnterpriseTreeVo vo = new QueryEnterpriseTreeVo(); vo.setName(enterpriseInfo.getEnterpriseName()); vo.setEnterpriseId(enterpriseInfo.getId()); - List hatDevs = safetyHatDevs.stream().filter(safetyHatDev -> { - safetyHatDev.setName(safetyHatDev.getWorkerName()); - List l = enterpriseMap.get(enterpriseInfo.getId()); - if (CollUtil.isNotEmpty(l)) { - return l.stream().anyMatch(workerInfo -> safetyHatDev.getWorkerInfoId().equals(workerInfo.getId())); - } - return false; - }).collect(Collectors.toList()); +// List hatDevs = safetyHatDevs.stream().filter(safetyHatDev -> { +// safetyHatDev.setName(safetyHatDev.getWorkerName()); +// List l = enterpriseMap.get(enterpriseInfo.getId()); +// if (CollUtil.isNotEmpty(l)) { +// return l.stream().anyMatch(workerInfo -> safetyHatDev.getWorkerInfoId().equals(workerInfo.getId())); +// } +// return false; +// }).collect(Collectors.toList()); + List hatDevs = safetyHatDevs.stream().filter(s -> s.getEnterpriseIds().contains(enterpriseInfo.getId().toString())).collect(Collectors.toList()); vo.setSafetyHatDevs(hatDevs); rt.add(vo); } diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatAlarm.java b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatAlarm.java index cb7877419..b342bdd8f 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatAlarm.java +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatAlarm.java @@ -37,6 +37,12 @@ public class SafetyHatAlarm implements Serializable { @Excel(name = "人员id", width = 15) @ApiModelProperty(value = "人员id") private java.lang.Long workerInfoId; + /** + * 人员姓名 + */ + @Excel(name = "人员姓名", width = 15) + @ApiModelProperty(value = "人员姓名") + private java.lang.String workerInfoName; /** * 设备序号 */ diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatData.java b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatData.java index 2d48b04f1..4e629519f 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatData.java +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatData.java @@ -38,6 +38,12 @@ public class SafetyHatData implements Serializable { @Excel(name = "人员id", width = 15) @ApiModelProperty(value = "人员id") private java.lang.Long workerInfoId; + /** + * 人员姓名 + */ + @Excel(name = "人员姓名", width = 15) + @ApiModelProperty(value = "人员姓名") + private java.lang.String workerInfoName; /** * 设备序号 */ @@ -104,6 +110,14 @@ public class SafetyHatData implements Serializable { @TableField(exist = false) private java.lang.String workerName; + /** + * 企业名称 + */ + @Excel(name = "企业名称", width = 15) + @ApiModelProperty(value = "企业名称") + @TableField(exist = false) + private java.lang.String enterpriseName; + @TableField(exist = false) @ApiModelProperty(value = "身份证号") private java.lang.String idCard; diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatDev.java b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatDev.java index 4df7ef9d5..c6d8fc20a 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatDev.java +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/entity/SafetyHatDev.java @@ -1,9 +1,6 @@ package com.zhgd.xmgl.modules.safetyhat.entity; -import com.baomidou.mybatisplus.annotation.IdType; -import com.baomidou.mybatisplus.annotation.TableField; -import com.baomidou.mybatisplus.annotation.TableId; -import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.*; import com.fasterxml.jackson.annotation.JsonFormat; import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModelProperty; @@ -36,7 +33,15 @@ public class SafetyHatDev implements Serializable { */ @Excel(name = "人员id", width = 15) @ApiModelProperty(value = "人员id") + @TableField(updateStrategy = FieldStrategy.IGNORED) private java.lang.Long workerInfoId; + /** + * 人员姓名 + */ + @Excel(name = "人员姓名", width = 15) + @ApiModelProperty(value = "人员姓名") + @TableField(updateStrategy = FieldStrategy.IGNORED) + private java.lang.String workerInfoName; /** * 设备序号 */ diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatAlarmMapper.xml b/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatAlarmMapper.xml index 75a8a9655..85e937f63 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatAlarmMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatAlarmMapper.xml @@ -2,7 +2,7 @@ - select shd.*, wi.worker_name + select shd.*, CONCAT(IFNULL(wi.worker_name, ''), IFNULL(shd.worker_info_name, '')) worker_name from safety_hat_data shd left join worker_info wi on wi.id = shd.worker_info_id ${ew.customSqlSegment} @@ -22,7 +22,7 @@ diff --git a/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatDevMapper.xml b/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatDevMapper.xml index 32d56356b..90dbc87f3 100644 --- a/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatDevMapper.xml +++ b/src/main/java/com/zhgd/xmgl/modules/safetyhat/mapper/xml/SafetyHatDevMapper.xml @@ -2,7 +2,7 @@