diff --git a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTask.java b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTask.java index b44993f..848a58a 100644 --- a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTask.java +++ b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTask.java @@ -173,4 +173,7 @@ public class InspectionTask extends BaseEntity implements Serializable { @TableField(exist = false) private List groupIdList; + @TableField(exist = false) + private String groupName; + } diff --git a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTaskPoint.java b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTaskPoint.java index 45096ed..b843ccf 100644 --- a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTaskPoint.java +++ b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InspectionTaskPoint.java @@ -3,6 +3,8 @@ package org.springblade.lims.entry; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.NullSerializer; import lombok.Data; import org.springblade.core.mp.base.BaseEntity; import org.springframework.data.annotation.Id; @@ -95,11 +97,13 @@ public class InspectionTaskPoint extends BaseEntity implements Serializable { /** * 位置经度 */ + @JsonSerialize(nullsUsing = NullSerializer.class) private Double pointPosLongitude; /** * 位置纬度 */ + @JsonSerialize(nullsUsing = NullSerializer.class) private Double pointPosLatitude; /** diff --git a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InstrumentData.java b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InstrumentData.java index 520e347..6afd981 100644 --- a/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InstrumentData.java +++ b/lab-service-api/lab-lims-api/src/main/java/org/springblade/lims/entry/InstrumentData.java @@ -26,6 +26,11 @@ public class InstrumentData extends BaseEntity implements Serializable { */ private String imei; + /** + * 总用电 + */ + private Double totalElectricity; + /** * 总有功功率 */ diff --git a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/ApplyDetailController.java b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/ApplyDetailController.java index f7e26b4..f011c83 100644 --- a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/ApplyDetailController.java +++ b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/ApplyDetailController.java @@ -76,6 +76,10 @@ public class ApplyDetailController extends BladeController { // wrapper.between(ApplyDetail::getCreateTime, apply.getStartTime(), apply.getEndTime()); // } // wrapper.orderByDesc(ApplyDetail::getCreateTime); + List roles = Arrays.asList(AuthUtil.getUserRole().split(",")); + if(!roles.contains("admin")){ + apply.setCreateDept(Long.parseLong(AuthUtil.getDeptId())); + } List details = applyDetailService.listOut(apply); List excels = new ArrayList<>(); diff --git a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/GoodsController.java b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/GoodsController.java index 59963c9..b1ef5ed 100644 --- a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/GoodsController.java +++ b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/controller/GoodsController.java @@ -724,6 +724,10 @@ public class GoodsController extends BladeController { @GetMapping("/censusOut") public void censusOut(HttpServletResponse response, Goods goods) { LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + List roles = Arrays.asList(AuthUtil.getUserRole().split(",")); + if(!roles.contains("admin")){ + wrapper.eq(BaseEntity::getCreateDept,AuthUtil.getDeptId()); + } if (StringUtils.isNotBlank(goods.getName())) { wrapper.and(wq -> wq .like(Goods::getName, goods.getName()).or() diff --git a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/mapper/AppleDetailMapper.xml b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/mapper/AppleDetailMapper.xml index f6b4fab..82e04d0 100644 --- a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/mapper/AppleDetailMapper.xml +++ b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/mapper/AppleDetailMapper.xml @@ -59,6 +59,9 @@ and b.create_time >= #{apply.startTime} and b.create_time <= #{apply.endTime} + + and a.create_dept = #{apply.createDept} + and b.is_deleted = 0 order by b.create_time desc diff --git a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/service/impl/GoodsServiceImpl.java b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/service/impl/GoodsServiceImpl.java index 37cdeac..5de8d85 100644 --- a/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/service/impl/GoodsServiceImpl.java +++ b/lab-service/lab-capital/src/main/java/org/springblade/lims/goods/service/impl/GoodsServiceImpl.java @@ -55,6 +55,7 @@ public class GoodsServiceImpl extends BaseServiceImpl implem } catch (Exception e) { e.printStackTrace(); } + path = sysClient.getParamValue("jiahe_file_url").getData() + fileName; } map.put("filename",originalFilename); map.put("path",path); diff --git a/lab-service/lab-lims/src/main/java/org/springblade/lims/job/CreateMaintainTaskJob.java b/lab-service/lab-lims/src/main/java/org/springblade/lims/job/CreateMaintainTaskJob.java index 6230874..77fa42c 100644 --- a/lab-service/lab-lims/src/main/java/org/springblade/lims/job/CreateMaintainTaskJob.java +++ b/lab-service/lab-lims/src/main/java/org/springblade/lims/job/CreateMaintainTaskJob.java @@ -16,6 +16,6 @@ public class CreateMaintainTaskJob { @Scheduled(cron ="0 0/2 * * * ? ") public void createTask(){ inspectionPlanService.checkAndCreateTask(); - //maintainPlanService.checkAndCreateTask(); + maintainPlanService.checkAndCreateTask(); } } diff --git a/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/callback/MyMQTTCallback.java b/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/callback/MyMQTTCallback.java index edf108e..11126bf 100644 --- a/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/callback/MyMQTTCallback.java +++ b/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/callback/MyMQTTCallback.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import org.apache.commons.lang3.time.DateUtils; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.client.mqttv3.MqttCallbackExtended; +import org.eclipse.paho.client.mqttv3.MqttException; import org.eclipse.paho.client.mqttv3.MqttMessage; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -55,7 +56,7 @@ public class MyMQTTCallback implements MqttCallbackExtended { @Override public void connectionLost(Throwable throwable) { log.error("mqtt connectionLost 连接断开,5S之后尝试重连: {}", throwable.getMessage()); - /*long reconnectTimes = 1; + long reconnectTimes = 1; while (true) { if (MyMQTTClient.getClient().isConnected()) { //判断已经重新连接成功 需要重新订阅主题 可以在这个if里面订阅主题 或者 connectComplete(方法里面) 看你们自己选择 @@ -76,7 +77,7 @@ public class MyMQTTCallback implements MqttCallbackExtended { Thread.sleep(5000); } catch (InterruptedException e1) { } - }*/ + } } /** @@ -96,6 +97,9 @@ public class MyMQTTCallback implements MqttCallbackExtended { Map map1 = (Map) JSON.parse(map.get("vals").toString()); data.setCreateTime(DateUtils.parseDate(map.get("tsstr").toString(),"yyyy-MM-dd hh:mm:ss")); data.setImei(map.get("imei").toString()); + if(map1.containsKey("总用电")){ + data.setTotalElectricity(Double.parseDouble(map1.get("总用电").toString())); + } if(map1.containsKey("总有功功率")){ data.setTotalActivePower(Double.parseDouble(map1.get("总有功功率").toString())); } diff --git a/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/config/MqttConfiguration.java b/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/config/MqttConfiguration.java index fab3f47..5976b9a 100644 --- a/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/config/MqttConfiguration.java +++ b/lab-service/lab-lims/src/main/java/org/springblade/lims/mqtt/config/MqttConfiguration.java @@ -7,13 +7,14 @@ import org.slf4j.LoggerFactory; import org.springblade.lims.mqtt.client.MyMQTTClient; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.DependsOn; /** 1. @author WXY 2. @date 2022/6/29 20:42 */ -//@Configuration +@Configuration @DependsOn({"springUtil"}) @Data public class MqttConfiguration { diff --git a/lab-service/lab-lims/src/main/java/org/springblade/lims/service/impl/InspectionPlanServiceImpl.java b/lab-service/lab-lims/src/main/java/org/springblade/lims/service/impl/InspectionPlanServiceImpl.java index 8869c65..47fd42f 100644 --- a/lab-service/lab-lims/src/main/java/org/springblade/lims/service/impl/InspectionPlanServiceImpl.java +++ b/lab-service/lab-lims/src/main/java/org/springblade/lims/service/impl/InspectionPlanServiceImpl.java @@ -268,6 +268,7 @@ public class InspectionPlanServiceImpl extends BaseServiceImpl findPage(InspectionTask entry, Query query) { @@ -119,6 +121,9 @@ public class InspectionTaskServiceImpl extends BaseServiceImpl taskPointList = inspectionTaskPointService.list(new LambdaQueryWrapper().eq(InspectionTaskPoint::getTaskId,id)); entry.setTaskPointList(taskPointList); @@ -189,6 +196,7 @@ public class InspectionTaskServiceImpl extends BaseServiceImpl