|
@@ -19,6 +19,7 @@ import com.ruoyi.demo.mapper.*;
|
|
import com.ruoyi.demo.service.EquipmentService;
|
|
import com.ruoyi.demo.service.EquipmentService;
|
|
import com.ruoyi.demo.utils.InitMapUtil;
|
|
import com.ruoyi.demo.utils.InitMapUtil;
|
|
import com.ruoyi.demo.utils.MtStarUtil;
|
|
import com.ruoyi.demo.utils.MtStarUtil;
|
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
import org.springframework.beans.factory.annotation.Qualifier;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
@@ -32,6 +33,7 @@ import java.util.stream.Collectors;
|
|
|
|
|
|
@Service
|
|
@Service
|
|
@Transactional
|
|
@Transactional
|
|
|
|
+@Slf4j
|
|
public class EquipmentServiceImpl implements EquipmentService {
|
|
public class EquipmentServiceImpl implements EquipmentService {
|
|
@Autowired
|
|
@Autowired
|
|
EquipmentMapper equipmentMapper;
|
|
EquipmentMapper equipmentMapper;
|
|
@@ -95,25 +97,11 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
@Override
|
|
@Override
|
|
public R updateEquipment(EquipmentVo equipmentVo) {
|
|
public R updateEquipment(EquipmentVo equipmentVo) {
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
QueryWrapper<Equipment> queryWrapper = new QueryWrapper<>();
|
|
- queryWrapper.select("equipment_name","equipment_code","addr_info","addr_code","addr_code_info","on_state");
|
|
|
|
|
|
+ queryWrapper.select("equipment_name","equipment_code","addr_info","addr_code","addr_code_info");
|
|
queryWrapper.eq("equipment_id",equipmentVo.getEquipmentId());
|
|
queryWrapper.eq("equipment_id",equipmentVo.getEquipmentId());
|
|
Equipment equipment = equipmentMapper.selectOne(queryWrapper);
|
|
Equipment equipment = equipmentMapper.selectOne(queryWrapper);
|
|
|
|
|
|
if (equipment != null){
|
|
if (equipment != null){
|
|
- if (!equipmentVo.getAddrCode().equals(equipment.getAddrCode()))
|
|
|
|
- equipmentVo.setAddrCodeInfo(initMapUtil.getInitAddrCodeMap(equipmentVo.getAddrCode())); //更新地区码映射
|
|
|
|
-
|
|
|
|
- String state = "";
|
|
|
|
- if (equipmentVo.getOnState() != equipment.getOnState()){
|
|
|
|
- if (equipmentVo.getOnState() == 1){
|
|
|
|
- //唤醒
|
|
|
|
- state = mtStarUtil.wakeup(equipmentVo.getEquipmentCode());
|
|
|
|
- }else {
|
|
|
|
- //休眠
|
|
|
|
- state = mtStarUtil.dormancy(equipmentVo.getEquipmentCode());
|
|
|
|
- }
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
//2.更新时间
|
|
//2.更新时间
|
|
equipmentVo.setUpdateTime(LocalDateTime.now(ZoneId.of("Asia/Shanghai")));
|
|
equipmentVo.setUpdateTime(LocalDateTime.now(ZoneId.of("Asia/Shanghai")));
|
|
UpdateWrapper<Equipment> updateWrapper = new UpdateWrapper<>();
|
|
UpdateWrapper<Equipment> updateWrapper = new UpdateWrapper<>();
|
|
@@ -172,7 +160,7 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
planPushStatisticsMapper.update(null,updateWrapper5);
|
|
planPushStatisticsMapper.update(null,updateWrapper5);
|
|
}
|
|
}
|
|
|
|
|
|
- return R.ok("修改成功,"+state);
|
|
|
|
|
|
+ return R.ok("修改成功");
|
|
}else {
|
|
}else {
|
|
return R.fail("设备不存在");
|
|
return R.fail("设备不存在");
|
|
}
|
|
}
|
|
@@ -391,5 +379,16 @@ public class EquipmentServiceImpl implements EquipmentService {
|
|
planItemMapper.deleteBatchIds(Arrays.asList(planItemIds));
|
|
planItemMapper.deleteBatchIds(Arrays.asList(planItemIds));
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ @Override
|
|
|
|
+ public String equipmentOnStatedormancy(String equipmentCode) {
|
|
|
|
+ //调用接口
|
|
|
|
+ return mtStarUtil.dormancy(equipmentCode);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public String equipmentOnStateWakeup(String equipmentCode) {
|
|
|
|
+ return mtStarUtil.wakeup(equipmentCode);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
|
|
}
|
|
}
|