yangjun
/
nursing_unit_java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改bug

This commit is contained in:
yangjun 2026-03-09 15:13:19 +08:00
parent 93a9f3c18b
commit 8044157d1d
4 changed files with 66 additions and 39 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
nursing-unit-common/src/main/java/com/nu/dto/NuBaseInfoMQDto.java
View File

@ -1,6 +1,9 @@
package com.nu.dto; package com.nu.dto;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable; import java.io.Serializable;
@ -28,4 +31,22 @@ public class NuBaseInfoMQDto implements Serializable {
* 护理单元编码 * 护理单元编码
*/ */
private String nuId; private String nuId;
private java.lang.String id;
private java.lang.String nuName;
private java.lang.String areaFlag;
private java.lang.String status;
private java.lang.String customerId;
private java.lang.String delFlag;
private java.lang.String createBy;
@JsonFormat(timezone = "GMT+8",pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss")
@ApiModelProperty(value = "创建日期")
private java.util.Date createTime;
private java.lang.String updateBy;
private java.util.Date updateTime;
private java.lang.String sysOrgCode;
private java.lang.String izSync;
} }

4
nursing-unit-elder/nu-elder-biz/src/main/java/com/nu/modules/elderinfo/entity/ElderInfo.java
View File

@ -382,8 +382,8 @@ public class ElderInfo implements Serializable {
/** /**
* 长者入住时间 * 长者入住时间
*/ */
@JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd") @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss")
@DateTimeFormat(pattern = "yyyy-MM-dd") @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Date checkinTime; private Date checkinTime;
@TableField(exist = false) @TableField(exist = false)

70
nursing-unit-iot/nu-iot-biz/src/main/java/com/nu/mq/device/listener/IotSyncBizMQListener.java
View File

@ -70,41 +70,41 @@ public class IotSyncBizMQListener {
private void saveSyncBizInfo(IotSyncBizMQDto dto) { private void saveSyncBizInfo(IotSyncBizMQDto dto) {
List<StatusMQDto> statusList = new ArrayList<>(); List<StatusMQDto> statusList = new ArrayList<>();
IotNuBaseInfoMQDto iotNuBaseInfoMQDto = dto.getNuBaseInfo(); // IotNuBaseInfoMQDto iotNuBaseInfoMQDto = dto.getNuBaseInfo();
try { // try {
NuBaseInfoEntity entity = nuBaseInfoApi.getOneByNuId(iotNuBaseInfoMQDto.getNuId()); // NuBaseInfoEntity entity = nuBaseInfoApi.getOneByNuId(iotNuBaseInfoMQDto.getNuId());
StatusMQDto statusMQDto = new StatusMQDto(); // StatusMQDto statusMQDto = new StatusMQDto();
statusMQDto.setAsyncId(iotNuBaseInfoMQDto.getId()); // statusMQDto.setAsyncId(iotNuBaseInfoMQDto.getId());
statusMQDto.setMessage("成功"); // statusMQDto.setMessage("成功");
statusMQDto.setPrimaryKey(iotNuBaseInfoMQDto.getLogId()); // statusMQDto.setPrimaryKey(iotNuBaseInfoMQDto.getLogId());
statusMQDto.setNote("区域"); // statusMQDto.setNote("区域");
if(entity!=null){ // if(entity!=null){
if(iotNuBaseInfoMQDto.getDelFlag().equals(entity.getDelFlag())){ // if(iotNuBaseInfoMQDto.getDelFlag().equals(entity.getDelFlag())){
statusMQDto.setMessage("忽略"); // statusMQDto.setMessage("忽略");
}else{ // }else{
entity.setDelFlag(iotNuBaseInfoMQDto.getDelFlag()); // entity.setDelFlag(iotNuBaseInfoMQDto.getDelFlag());
NuBaseInfoEntity nuBaseInfo = new NuBaseInfoEntity(); // NuBaseInfoEntity nuBaseInfo = new NuBaseInfoEntity();
BeanUtils.copyProperties(entity, nuBaseInfo); // BeanUtils.copyProperties(entity, nuBaseInfo);
nuBaseInfo.setSysOrgCode(iotNuBaseInfoMQDto.getOrgCode()); // nuBaseInfo.setSysOrgCode(iotNuBaseInfoMQDto.getOrgCode());
nuBaseInfoApi.updateById(nuBaseInfo); // nuBaseInfoApi.updateById(nuBaseInfo);
} // }
}else{ // }else{
NuBaseInfoEntity nuBaseInfo = new NuBaseInfoEntity(); // NuBaseInfoEntity nuBaseInfo = new NuBaseInfoEntity();
BeanUtils.copyProperties(iotNuBaseInfoMQDto, nuBaseInfo); // BeanUtils.copyProperties(iotNuBaseInfoMQDto, nuBaseInfo);
nuBaseInfo.setSysOrgCode(iotNuBaseInfoMQDto.getOrgCode()); // nuBaseInfo.setSysOrgCode(iotNuBaseInfoMQDto.getOrgCode());
nuBaseInfo.setStatus("0"); // nuBaseInfo.setStatus("0");
nuBaseInfoApi.save(nuBaseInfo); // nuBaseInfoApi.save(nuBaseInfo);
} // }
statusList.add(statusMQDto); // statusList.add(statusMQDto);
} catch (Exception e) { // } catch (Exception e) {
StatusMQDto statusMQDto = new StatusMQDto(); // StatusMQDto statusMQDto = new StatusMQDto();
statusMQDto.setAsyncId(iotNuBaseInfoMQDto.getId()); // statusMQDto.setAsyncId(iotNuBaseInfoMQDto.getId());
statusMQDto.setMessage("失败"); // statusMQDto.setMessage("失败");
statusMQDto.setPrimaryKey(iotNuBaseInfoMQDto.getLogId()); // statusMQDto.setPrimaryKey(iotNuBaseInfoMQDto.getLogId());
statusMQDto.setNote("区域"); // statusMQDto.setNote("区域");
statusList.add(statusMQDto); // statusList.add(statusMQDto);
e.printStackTrace(); // e.printStackTrace();
} // }
List<IotCameraInfoMQDto> cameraList = dto.getCameraInfoList(); List<IotCameraInfoMQDto> cameraList = dto.getCameraInfoList();
if(cameraList!=null&&cameraList.size()>0){ if(cameraList!=null&&cameraList.size()>0){

10
nursing-unit-nu/nu-nu-biz/src/main/java/com/nu/modules/nubaseinfo/controller/NuBaseInfoController.java
View File

@ -3,6 +3,7 @@ package com.nu.modules.nubaseinfo.controller;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.nu.dto.NuBaseInfoMQDto;
import com.nu.modules.nubaseinfo.entity.NuBaseInfo; import com.nu.modules.nubaseinfo.entity.NuBaseInfo;
import com.nu.modules.nubaseinfo.service.INuBaseInfoService; import com.nu.modules.nubaseinfo.service.INuBaseInfoService;
import com.nu.utils.RabbitMQUtil; import com.nu.utils.RabbitMQUtil;
@ -16,6 +17,7 @@ import org.jeecg.common.aspect.annotation.AutoLog;
import org.jeecg.common.system.base.controller.JeecgController; import org.jeecg.common.system.base.controller.JeecgController;
import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.query.QueryGenerator;
import org.jeecg.common.system.query.QueryRuleEnum; import org.jeecg.common.system.query.QueryRuleEnum;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView; import org.springframework.web.servlet.ModelAndView;
@ -139,7 +141,9 @@ public class NuBaseInfoController extends JeecgController<NuBaseInfo, INuBaseInf
service.setNuId(nuBaseInfo); service.setNuId(nuBaseInfo);
nuBaseInfoService.save(nuBaseInfo); nuBaseInfoService.save(nuBaseInfo);
rabbitMQUtil.sendToExchange("hldy.hldy", "hldy.async.addBase", nuBaseInfo); NuBaseInfoMQDto nuBaseInfoMQDto = new NuBaseInfoMQDto();
BeanUtils.copyProperties(nuBaseInfo, nuBaseInfoMQDto);
rabbitMQUtil.sendToExchange("hldy.hldy", "hldy.async.addBase", nuBaseInfoMQDto);
return Result.OK("添加成功！"); return Result.OK("添加成功！");
} }
@ -155,7 +159,9 @@ public class NuBaseInfoController extends JeecgController<NuBaseInfo, INuBaseInf
@RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST}) @RequestMapping(value = "/edit", method = {RequestMethod.PUT, RequestMethod.POST})
public Result<String> edit(@RequestBody NuBaseInfo nuBaseInfo) { public Result<String> edit(@RequestBody NuBaseInfo nuBaseInfo) {
nuBaseInfoService.updateById(nuBaseInfo); nuBaseInfoService.updateById(nuBaseInfo);
rabbitMQUtil.sendToExchange("hldy.hldy", "hldy.async.updateBase", nuBaseInfo); NuBaseInfoMQDto nuBaseInfoMQDto = new NuBaseInfoMQDto();
BeanUtils.copyProperties(nuBaseInfo, nuBaseInfoMQDto);
rabbitMQUtil.sendToExchange("hldy.hldy", "hldy.async.updateBase", nuBaseInfoMQDto);
return Result.OK("操作成功!"); return Result.OK("操作成功!");
} }