diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/controller/DeviceManagerController.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/controller/DeviceManagerController.java index 09dfa492..f2a9b0e6 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/controller/DeviceManagerController.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/controller/DeviceManagerController.java @@ -358,4 +358,23 @@ public class DeviceManagerController extends JeecgController> ghList(DeviceManager DeviceManager, + @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, + @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, + HttpServletRequest req) { + Page page = new Page(pageNo, pageSize); + IPage pageList = service.findGhPage(page, DeviceManager); + return Result.OK(pageList); + } } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/entity/DeviceBindLog.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/entity/DeviceBindLog.java index 29e06afa..b52dded2 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/entity/DeviceBindLog.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/entity/DeviceBindLog.java @@ -34,4 +34,5 @@ public class DeviceBindLog implements Serializable { private String optType; private String remarks; private Integer ywId; + private Integer newId; } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/DeviceManagerMapper.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/DeviceManagerMapper.java index 2b13cac3..5aec0a79 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/DeviceManagerMapper.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/DeviceManagerMapper.java @@ -41,4 +41,5 @@ public interface DeviceManagerMapper extends BaseMapper { IPage findHumidDeviceUnbindPage(Page page, @Param("params") DeviceManager deviceManager); void editPreviewStatusBySn(DeviceManager deviceManager); void editPreviewById(DeviceManager deviceManager); + IPage findGhPage(Page page, @Param("params") DeviceManager deviceManager); } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/xml/DeviceManagerMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/xml/DeviceManagerMapper.xml index c778641c..de5da98a 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/xml/DeviceManagerMapper.xml +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/mapper/xml/DeviceManagerMapper.xml @@ -22,6 +22,11 @@ a.yw_id, t.device_index from nu_iot_device_preview a + inner join ( + select distinct sdi.item_value,sdi.item_text + from sys_dict sd inner join sys_dict_item sdi on sd.id = sdi.dict_id + where sd.dict_code = 'tplink_device_type' and sdi.status = '0' + ) dict on a.device_type = dict.item_value left join nu_base_info c on a.nu_id = c.nu_id left join ( select mac as sn, @@ -46,21 +51,14 @@ ) t on a.sn = t.sn where a.sn is not null and ifnull(a.device_status,'') != '损坏' - - AND c.nu_name LIKE concat('%',#{params.nuName},'%') - - - AND a.dimension = #{params.dimension} - - - AND a.device_type = #{params.deviceType} - - - AND a.batch_no = #{params.batchNo} - - - AND t.online_status = #{params.deviceStatus} - + + AND ( + c.nu_name LIKE concat('%',#{params.nuName},'%') + or a.dimension LIKE concat('%',#{params.nuName},'%') + or a.batch_no LIKE concat('%',#{params.nuName},'%') + or dict.item_text LIKE concat('%',#{params.nuName},'%') + ) + order by a.batch_no,a.dimension,a.device_type,a.device_model,a.sn @@ -159,7 +157,7 @@ AND device_name LIKE concat('%',#{params.deviceName},'%') - order by factory asc ,device_type asc ,device_model asc ,sn asc,opt_date desc + order by opt_date desc ,factory asc ,device_type asc ,device_model asc ,sn asc @@ -298,4 +296,61 @@ where id = #{id} + + diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/IDeviceManagerService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/IDeviceManagerService.java index ddf7e3cd..3d99963a 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/IDeviceManagerService.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/IDeviceManagerService.java @@ -26,7 +26,7 @@ public interface IDeviceManagerService extends IService { IPage findAllPage(Page page, DeviceManager deviceManager); IPage findBingLogPage(Page page, DeviceBindLog deviceBindLog); Result updateManager(DeviceManager deviceManager); - void addLog(DeviceBindLog deviceBindLog); + void addLog(DeviceBindLog deviceBindLog) throws Exception; List queryNuList(DeviceManager deviceManager); List exportDeviceExcel(DeviceManager deviceManager); List exportDeviceHzExcel(DeviceManagerHz deviceManager); @@ -40,4 +40,6 @@ public interface IDeviceManagerService extends IService { DeviceManager findOneByType(DeviceManager deviceManager); void editPreviewStatusBySn(DeviceManager deviceManager); void editPreviewById(DeviceManager deviceManager); + IPage findGhPage(Page page, DeviceManager deviceManager); + } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/impl/DeviceManagerServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/impl/DeviceManagerServiceImpl.java index ea9953fe..fc82a279 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/impl/DeviceManagerServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/manager/service/impl/DeviceManagerServiceImpl.java @@ -1,6 +1,7 @@ package com.nu.modules.manager.service.impl; 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.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -22,6 +23,7 @@ import org.jeecg.common.system.api.ISysBaseAPI; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import java.util.List; import java.util.Map; @@ -74,13 +76,17 @@ public class DeviceManagerServiceImpl extends ServiceImpl qw = new QueryWrapper<>(); + qw.eq("id",deviceBindLog.getNewId()); + DeviceManager entity = this.getOne(qw); + if(deviceBindLog.getDimension().equals("区域维度")){ + entity.setNuId(deviceBindLog.getNuId()); + entity.setNuName(deviceBindLog.getNuName()); + } + entity.setDeviceStatus("已绑定"); + baseMapper.updateById(entity); + + //同步给运维平台 + DevicePreviewMqDto dto2 = new DevicePreviewMqDto(); + BeanUtils.copyProperties(entity, dto2); + dto2.setOrgCode(orgCode); + dto2.setDeviceStatus("更换设备"); + dto2.setRemarks(deviceBindLog.getRemarks()); + rabbitMQUtil.sendToExchange("hldy.iotsyncbiz", "iotsyncbiz.bindpreview", dto2); + + DeviceBindLog deviceBindLog2 = new DeviceBindLog(); + BeanUtils.copyProperties(entity, deviceBindLog2); + deviceBindLog2.setOptType("更换设备"); + deviceBindLog2.setRemarks(deviceBindLog.getRemarks()); + baseMapper.addLog(deviceBindLog2); + } + } } @Override @@ -162,4 +200,9 @@ public class DeviceManagerServiceImpl extends ServiceImpl findGhPage(Page page, DeviceManager deviceManager){ + return baseMapper.findGhPage(page,deviceManager); + } } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/device/listener/IotSyncBizMQListener.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/device/listener/IotSyncBizMQListener.java index 717b9a4a..65243023 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/device/listener/IotSyncBizMQListener.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/device/listener/IotSyncBizMQListener.java @@ -156,13 +156,19 @@ public class IotSyncBizMQListener { deviceManager.setDeviceType(iotCameraInfoMQDto.getDeviceType()); DeviceManager dm = deviceManagerService.findBySn(deviceManager); if(dm!=null){ - deviceManager.setDeviceStatus("正常"); + deviceManager.setDeviceStatus("未绑定"); + if(dm.getDimension().equals("机构维度")){ + deviceManager.setDeviceStatus("已绑定"); + } deviceManagerService.editPreviewStatusBySn(deviceManager); }else{ DeviceManager snEmpty = deviceManagerService.findOneByType(deviceManager); if(snEmpty!=null){ deviceManager.setId(snEmpty.getId()); - deviceManager.setDeviceStatus("正常"); + deviceManager.setDeviceStatus("未绑定"); + if(snEmpty.getDimension().equals("机构维度")){ + deviceManager.setDeviceStatus("已绑定"); + } deviceManagerService.updateById(deviceManager); deviceManager.setYwId(snEmpty.getYwId()); @@ -250,7 +256,7 @@ public class IotSyncBizMQListener { mqttMessageHandler.subscribeUplinkMessage(iotElectricityMeterMQDto.getSn()); DeviceManager deviceManager = new DeviceManager(); deviceManager.setSn(iotElectricityMeterMQDto.getSn()); - deviceManager.setDeviceStatus("正常"); + deviceManager.setDeviceStatus("未绑定"); deviceManagerService.editPreviewStatusBySn(deviceManager); } statusList.add(statusMQDto); @@ -297,7 +303,7 @@ public class IotSyncBizMQListener { waterMeterService.save(waterMeter); DeviceManager deviceManager = new DeviceManager(); deviceManager.setSn(iotWaterMeterMQDto.getCid()); - deviceManager.setDeviceStatus("正常"); + deviceManager.setDeviceStatus("未绑定"); deviceManagerService.editPreviewStatusBySn(deviceManager); } statusList.add(statusMQDto); @@ -375,7 +381,7 @@ public class IotSyncBizMQListener { humidDeviceService.save(humidDevice); DeviceManager deviceManager = new DeviceManager(); deviceManager.setSn(iotHumidDeviceMQDto.getSn()); - deviceManager.setDeviceStatus("正常"); + deviceManager.setDeviceStatus("未绑定"); deviceManagerService.editPreviewStatusBySn(deviceManager); } statusList.add(statusMQDto);