|
|
@@ -1,9 +1,15 @@
|
|
|
package com.zd.bottle.service.impl;
|
|
|
|
|
|
import cn.hutool.core.date.DateUtil;
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import com.zd.algorithm.api.alarm.entity.AlarmEntrty;
|
|
|
+import com.zd.algorithm.api.alarm.entity.Routes;
|
|
|
+import com.zd.algorithm.api.alarm.entity.SendTypes;
|
|
|
+import com.zd.algorithm.api.alarm.feign.RemoteAlarmService;
|
|
|
+import com.zd.algorithm.api.forward.feign.RemoteForwardService;
|
|
|
+import com.zd.algorithm.api.netty.feign.RemoteNettyService;
|
|
|
import com.zd.bottle.domain.AlarmRecord;
|
|
|
import com.zd.bottle.domain.BottleStorage;
|
|
|
import com.zd.bottle.domain.RfidTag;
|
|
|
@@ -11,31 +17,24 @@ import com.zd.bottle.domain.UsegasApply;
|
|
|
import com.zd.bottle.mapper.AlarmRecordMapper;
|
|
|
import com.zd.bottle.properties.AlarmProperties;
|
|
|
import com.zd.bottle.service.AlarmRecordService;
|
|
|
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import com.zd.bottle.service.BottleStorageService;
|
|
|
import com.zd.bottle.service.RfidTagService;
|
|
|
import com.zd.bottle.service.UsegasApplyService;
|
|
|
import com.zd.bottle.vo.AlarmRecordVo;
|
|
|
-import com.zd.model.constant.HttpStatus;
|
|
|
-import com.zd.common.core.domain.R;
|
|
|
+import com.zd.chemical.api.fegin.RemoteStockService;
|
|
|
+import com.zd.common.core.redis.RedisService;
|
|
|
import com.zd.common.core.utils.DateUtils;
|
|
|
-import com.zd.common.core.web.domain.AjaxResult;
|
|
|
-import com.zd.common.redis.service.RedisService;
|
|
|
-import com.zd.system.api.RemoteUserService;
|
|
|
-import com.zd.system.api.alarm.RemoteAlarmService;
|
|
|
-import com.zd.system.api.alarm.domain.AlarmEntrty;
|
|
|
-import com.zd.system.api.alarm.domain.Routes;
|
|
|
-import com.zd.system.api.alarm.domain.SendTypes;
|
|
|
-import com.zd.system.api.chemical.RemoteStockService;
|
|
|
-import com.zd.system.api.domain.InventoryTag;
|
|
|
-import com.zd.system.api.domain.SysFile;
|
|
|
-import com.zd.system.api.forward.RemoteForwardService;
|
|
|
-import com.zd.system.api.laboratory.RemoteLaboratoryService;
|
|
|
-import com.zd.system.api.laboratory.RemoteMessageContentService;
|
|
|
-import com.zd.system.api.laboratory.RemoteSubQueryService;
|
|
|
-import com.zd.system.api.laboratory.domain.LabSubject;
|
|
|
-import com.zd.system.api.laboratory.domain.RemoteLabHardware;
|
|
|
-import com.zd.system.api.netty.RemoteNettyService;
|
|
|
+import com.zd.laboratory.api.entity.LabSubjectEntity;
|
|
|
+import com.zd.laboratory.api.feign.RemoteLaboratoryService;
|
|
|
+import com.zd.laboratory.api.feign.RemoteMessageContentService;
|
|
|
+import com.zd.laboratory.api.feign.RemoteSubQueryService;
|
|
|
+import com.zd.model.constant.HttpStatus;
|
|
|
+import com.zd.model.domain.AjaxResult;
|
|
|
+import com.zd.model.domain.R;
|
|
|
+import com.zd.model.entity.InventoryTag;
|
|
|
+import com.zd.model.entity.RemoteLabHardware;
|
|
|
+import com.zd.model.entity.SysFile;
|
|
|
+import com.zd.system.api.feign.RemoteUserService;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.concurrent.BasicThreadFactory;
|
|
|
import org.jetbrains.annotations.Nullable;
|
|
|
@@ -197,12 +196,12 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
|
|
|
private void sendAlarm(BottleStorage storage) {
|
|
|
Long subjectId = storage.getSubjectId();
|
|
|
- R<List<LabSubject>> resultList = remoteSubQueryService.listByIds(Collections.singletonList(subjectId));
|
|
|
+ R<List<LabSubjectEntity>> resultList = remoteSubQueryService.listByIds(Collections.singletonList(subjectId));
|
|
|
log.info("==========>查询实验室:状态码:{},结果:{}", resultList.getCode(), resultList.getData());
|
|
|
if (resultList.getCode() == HttpStatus.SUCCESS) {
|
|
|
- List<LabSubject> data = resultList.getData();
|
|
|
+ List<LabSubjectEntity> data = resultList.getData();
|
|
|
if (data != null && !data.isEmpty()) {
|
|
|
- LabSubject labSubject = data.get(0);
|
|
|
+ LabSubjectEntity labSubject = data.get(0);
|
|
|
String subjectName = labSubject.getName();
|
|
|
//实验室负责人账号ID
|
|
|
Long adminId = labSubject.getAdminId();
|
|
|
@@ -239,7 +238,7 @@ public class AlarmRecordServiceImpl extends ServiceImpl<AlarmRecordMapper, Alarm
|
|
|
}
|
|
|
}
|
|
|
|
|
|
- private void sendHardware(LabSubject labSubject, String subjectName) {
|
|
|
+ private void sendHardware(LabSubjectEntity labSubject, String subjectName) {
|
|
|
RemoteLabHardware remoteLabHardware = new RemoteLabHardware();
|
|
|
remoteLabHardware.setType(8);
|
|
|
Long id = labSubject.getId();
|