diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/controller/ElectricityMeterController.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/controller/ElectricityMeterController.java index 4badd1a..c42699f 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/controller/ElectricityMeterController.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/controller/ElectricityMeterController.java @@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.nu.modules.tq.electricity.entity.ElectricityMeter; import com.nu.modules.tq.electricity.service.IElectricityMeterService; +import com.nu.modules.tq.water.entity.WaterMeter; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.jeecg.common.api.vo.Result; @@ -73,13 +74,19 @@ public class ElectricityMeterController extends JeecgController edit(@RequestBody ElectricityMeter electricityMeter) { service.updateById(electricityMeter); return Result.OK("编辑成功!"); } + @AutoLog(value = "修改电表的机构及护理单元信息") + @RequestMapping(value = "/editHldy", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result editHldy(@RequestBody ElectricityMeter electricityMeter) { + service.editHldy(electricityMeter); + return Result.OK("编辑成功!"); + } @AutoLog(value = "同步电表到业务系统") @RequestMapping(value = "/syncElectricity", method = {RequestMethod.PUT,RequestMethod.POST}) diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java index 9be9315..592d643 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/IElectricityMeterService.java @@ -20,4 +20,6 @@ public interface IElectricityMeterService extends IService { String eleReadNotify(String response_content, String timestamp, String sign); void syncElectricity(String dataSourceCode, ElectricityMeter electricityMeter); + + void editHldy(ElectricityMeter electricityMeter); } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java index d15b1a9..1e00653 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/electricity/service/impl/ElectricityMeterServiceImpl.java @@ -15,6 +15,7 @@ import com.nu.modules.tq.common.service.ITqApiLogService; import com.nu.modules.tq.utils.HttpTool; import com.nu.modules.tq.utils.SignTool; import com.nu.modules.tq.utils.TqApi; +import com.nu.modules.tq.water.entity.WaterMeter; import lombok.extern.slf4j.Slf4j; import com.nu.modules.tq.electricity.entity.ElectricityMeter; import com.nu.modules.tq.electricity.mapper.ElectricityMeterMapper; @@ -452,7 +453,7 @@ public class ElectricityMeterServiceImpl extends ServiceImpl edit(@RequestBody WaterMeter waterMeter) { + service.updateById(waterMeter); + return Result.OK("编辑成功!"); + } + + + @AutoLog(value = "修改机构及护理单元信息") + @RequestMapping(value = "/editHldy", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result editHldy(@RequestBody WaterMeter waterMeter) { + service.editHldy(waterMeter); + return Result.OK("编辑成功!"); + } + + + @AutoLog(value = "同步电表到业务系统") + @RequestMapping(value = "/syncElectricity", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result syncElectricity(@RequestBody WaterMeter waterMeter) { + String dataSourceCode = waterMeter.getDepartServerUrl(); + service.syncElectricity(dataSourceCode,waterMeter); + return Result.OK("同步成功!"); + } } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/entity/WaterMeter.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/entity/WaterMeter.java index 70a4995..1e7ea6a 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/entity/WaterMeter.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/entity/WaterMeter.java @@ -70,12 +70,13 @@ public class WaterMeter implements Serializable { @ApiModelProperty(value = "描述") private String remark; - @TableField(exist = false) private String nuId;//护理单元ID - @TableField(exist = false) private String nuName;//护理单元 - @TableField(exist = false) private String departId;//机构ID - @TableField(exist = false) private String departName;//机构名称 + private String departServerUrl;//机构服务地址 + private String oldServerUrl;//原机构服务地址 + private String syncType;//是否同步 0 未同步 1已同步 + private String oldDepartId;//原机构id + private String oldDepartName;//原机构名称 } \ No newline at end of file diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml index d88b985..76c128f 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/mapper/xml/WaterMeterMapper.xml @@ -19,7 +19,11 @@ a.nu_id as nuId, a.nu_name as nuName, a.depart_id as departId, - a.depart_name as departName + a.depart_name as departName, + a.depart_server_url as departServerUrl, + a.old_server_url as oldServerUrl, + a.old_depart_id as oldDepartId, + a.old_depart_name as oldDepartName from nu_iot_tq_water_meter a left join nu_iot_tq_collector b on a.cid = b.cid diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java index 0661cd3..912c467 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/IWaterMeterService.java @@ -18,4 +18,8 @@ public interface IWaterMeterService extends IService { String waterResetNotify(String response_content, String timestamp, String sign); String waterControlNotify(String response_content, String timestamp, String sign); String waterReadNotify(String response_content, String timestamp, String sign); + + void syncElectricity(String dataSourceCode, WaterMeter waterMeter); + + void editHldy(WaterMeter waterMeter); } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java index 427b2dc..7c5820a 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/tq/water/service/impl/WaterMeterServiceImpl.java @@ -3,11 +3,17 @@ package com.nu.modules.tq.water.service.impl; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; +import com.baomidou.dynamic.datasource.annotation.DS; +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; +import com.nu.modules.nuIotTqElectricitySyncLog.entity.NuIotTqElectricitySyncLog; +import com.nu.modules.nuIotTqElectricitySyncLog.service.INuIotTqElectricitySyncLogService; import com.nu.modules.tq.common.entity.TqApiLog; import com.nu.modules.tq.common.service.ITqApiLogService; +import com.nu.modules.tq.electricity.entity.ElectricityMeter; +import com.nu.modules.tq.electricity.service.impl.ElectricityMeterServiceImpl; import com.nu.modules.tq.utils.HttpTool; import com.nu.modules.tq.utils.SignTool; import com.nu.modules.tq.utils.TqApi; @@ -15,8 +21,10 @@ import com.nu.modules.tq.water.entity.WaterMeter; import com.nu.modules.tq.water.mapper.WaterMeterMapper; import com.nu.modules.tq.water.service.IWaterMeterService; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; import org.jeecg.common.api.vo.Result; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import java.util.*; @@ -31,6 +39,14 @@ public class WaterMeterServiceImpl extends ServiceImpl findPage(Page page, WaterMeter waterMeter){ return baseMapper.findPage(page,waterMeter); @@ -438,4 +454,114 @@ public class WaterMeterServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("cid",waterMeter.getCid()); + WaterMeter oldParam = baseMapper.selectOne(queryWrapper);//查询数据库中该表号数据原始数据 + if(oldParam == null){ + baseMapper.insert(waterMeter); + }else{ + baseMapper.updateById(waterMeter); + } + } catch (Exception e) { + throw new RuntimeException(e); + } + return true; + } } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/controller/HumidDeviceController.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/controller/HumidDeviceController.java index 9762ecf..3bbd004 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/controller/HumidDeviceController.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/controller/HumidDeviceController.java @@ -2,10 +2,12 @@ package com.nu.modules.yiweilian.humid.controller; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.nu.modules.tq.water.entity.WaterMeter; import com.nu.modules.yiweilian.humid.entity.HumidDevice; import com.nu.modules.yiweilian.humid.service.IHumidDeviceService; import lombok.extern.slf4j.Slf4j; import org.jeecg.common.api.vo.Result; +import org.jeecg.common.aspect.annotation.AutoLog; import org.jeecg.common.system.base.controller.JeecgController; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @@ -115,4 +117,27 @@ public class HumidDeviceController extends JeecgController pageList = service.findLogPage(page, humidDevice); return Result.OK(pageList); } + @AutoLog(value = "修改温湿度表信息") + @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result edit(@RequestBody HumidDevice humidDevice) { + service.updateById(humidDevice); + return Result.OK("编辑成功!"); + } + + + @AutoLog(value = "修改温湿度表的机构及护理单元信息") + @RequestMapping(value = "/editHldy", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result editHldy(@RequestBody HumidDevice humidDevice) { + service.editHldy(humidDevice); + return Result.OK("编辑成功!"); + } + + + @AutoLog(value = "同步电表到业务系统") + @RequestMapping(value = "/syncHumidDevice", method = {RequestMethod.PUT,RequestMethod.POST}) + public Result syncHumidDevice(@RequestBody HumidDevice humidDevice) { + String dataSourceCode = humidDevice.getDepartServerUrl(); + service.syncHumidDevice(dataSourceCode,humidDevice); + return Result.OK("同步成功!"); + } } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/entity/HumidDevice.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/entity/HumidDevice.java index f28cdec..04b06ab 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/entity/HumidDevice.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/entity/HumidDevice.java @@ -95,10 +95,14 @@ public class HumidDevice implements Serializable { @ApiModelProperty(value = "电量") private String electricity; //电量 0~4 + @TableField(exist = false) private String optType; //操作类型 + @TableField(exist = false) private String optTime; //操作时间 + @TableField(exist = false) private String optBy; //操作人 + @TableField(exist = false) private Integer alarmCn; //告警数量 private String nuId;//护理单元ID diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/IHumidDeviceService.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/IHumidDeviceService.java index 3925949..a28145d 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/IHumidDeviceService.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/IHumidDeviceService.java @@ -16,4 +16,7 @@ public interface IHumidDeviceService extends IService { Result getDeviceParameters(HumidDevice humidDevice); IPage findLogPage(Page page, HumidDevice humidDevice); + void syncHumidDevice(String dataSourceCode, HumidDevice humidDevice); + + void editHldy(HumidDevice humidDevice); } diff --git a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java index 098cd07..00d5a00 100644 --- a/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java +++ b/nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/modules/yiweilian/humid/service/impl/HumidDeviceServiceImpl.java @@ -2,19 +2,27 @@ package com.nu.modules.yiweilian.humid.service.impl; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; +import com.baomidou.dynamic.datasource.annotation.DS; +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; +import com.nu.modules.nuIotTqElectricitySyncLog.entity.NuIotTqElectricitySyncLog; +import com.nu.modules.nuIotTqElectricitySyncLog.service.INuIotTqElectricitySyncLogService; import com.nu.modules.tq.utils.HttpTool; +import com.nu.modules.tq.water.entity.WaterMeter; +import com.nu.modules.tq.water.service.impl.WaterMeterServiceImpl; import com.nu.modules.yiweilian.humid.entity.HumidDevice; import com.nu.modules.yiweilian.humid.mapper.HumidDeviceMapper; import com.nu.modules.yiweilian.humid.service.IHumidDeviceService; import com.nu.modules.yiweilian.utils.YiweilianApi; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; import org.apache.shiro.SecurityUtils; import org.jeecg.common.api.vo.Result; import org.jeecg.common.system.vo.LoginUser; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import java.util.HashMap; @@ -28,6 +36,13 @@ public class HumidDeviceServiceImpl extends ServiceImpl findPage(Page page, HumidDevice humidDevice){ return baseMapper.findPage(page,humidDevice); } @@ -395,5 +410,114 @@ public class HumidDeviceServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("sn",humidDevice.getSn()); + HumidDevice oldParam = baseMapper.selectOne(queryWrapper);//查询数据库中该表号数据原始数据 + if(oldParam == null){ + baseMapper.insert(humidDevice); + }else{ + baseMapper.updateById(humidDevice); + } + } catch (Exception e) { + throw new RuntimeException(e); + } + return true; + } + }