长者标签改版

This commit is contained in:
1378012178@qq.com 2026-02-25 14:54:29 +08:00
parent f3e17bd712
commit 38cc258e99
5 changed files with 210 additions and 4 deletions

View File

@ -0,0 +1,43 @@
package com.nu.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
/**
* @Description: 长者标签-操作日志-详情表
* @Author: jeecg-boot
* @Date: 2026-02-25
* @Version: V1.0
*/
@Data
public class ElderTagOpeLogInfoMQDto implements Serializable {
private static final long serialVersionUID = 1L;
/**id*/
private String id;
/**nu_config_elder_tag_ope_log_main.id*/
private String pkId;
/**创建日期*/
private Date createTime;
/**数据类型 1修改前 2修改后*/
private String dataType;
/**标签类型nu_elder_tag_type.id*/
private String type;
/**标签类型中文名*/
private String typeName;
/**标签名称*/
private String tagName;
/**说明*/
private String describ;
/**价格*/
private BigDecimal price;
/**默认图标*/
private String pic;
/**焦点图标*/
private String picFocus;
/**所属机构*/
private String sysOrgCode;
}

View File

@ -0,0 +1,44 @@
package com.nu.dto;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
/**
* @Description: 长者标签-操作日志-主表
* @Author: jeecg-boot
* @Date: 2026-02-25
* @Version: V1.0
*/
@Data
public class ElderTagOpeLogMainMQDto implements Serializable {
private static final long serialVersionUID = 1L;
/**id*/
private String id;
/**操作类型 1新增 2修改*/
private String opeType;
/**机构编码*/
private String orgCode;
/**操作人*/
private String createBy;
/**操作日期*/
private Date createTime;
/**标签类型中文名*/
private String typeName;
/**标签名称*/
private String tagName;
/**说明*/
private String describ;
/**价格*/
private BigDecimal price;
/**默认图标*/
private String pic;
/**焦点图标*/
private String picFocus;
private List<ElderTagOpeLogInfoMQDto> infoList;
}

View File

@ -0,0 +1,51 @@
package com.nu.dto;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import org.jeecgframework.poi.excel.annotation.Excel;
import org.springframework.format.annotation.DateTimeFormat;
import java.io.Serializable;
import java.math.BigDecimal;
import java.util.Date;
/**
* @Description: 长者标签-镜像-日志-指令详情表
* @Author: jeecg-boot
* @Date: 2026-02-25
* @Version: V1.0
*/
@Data
public class ElderTagSyncLogInfoMQDto implements Serializable {
private static final long serialVersionUID = 1L;
/**id*/
private String id;
/**nu_config_elder_tag_sync_log_main.id*/
private String pkId;
/**创建日期*/
private Date createTime;
/**标签类型nu_elder_tag_type.id*/
private String type;
/**标签类型中文名*/
private String typeName;
/**标签名称*/
private String tagName;
/**说明*/
private String describ;
/**价格*/
private BigDecimal price;
/**默认图标*/
private String pic;
/**焦点图标*/
private String picFocus;
/**所属机构*/
private String sysOrgCode;
}

View File

@ -0,0 +1,33 @@
package com.nu.dto;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
import java.util.List;
/**
* @Description: 长者标签-镜像-日志-主表
* @Author: jeecg-boot
* @Date: 2026-02-25
* @Version: V1.0
*/
@Data
public class ElderTagSyncLogMainMQDto implements Serializable {
private static final long serialVersionUID = 1L;
/**id*/
private String id;
/**哪个机构镜像的*/
private String opeOrgCode;
/**镜像的哪个机构的标签*/
private String targetOrgCode;
/**标签镜像码*/
private String orgTagCode;
/**创建人*/
private String createBy;
/**创建日期*/
private Date createTime;
private List<ElderTagSyncLogInfoMQDto> infoList;
}

View File

@ -1,14 +1,12 @@
package com.nu.mq.eldertag.listener;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.google.common.collect.Maps;
import com.nu.dto.ElderInfoMQDto;
import com.nu.dto.ElderTagAsyncMQDto;
import com.nu.dto.ElderTagTypeMQDto;
import com.nu.dto.StatusMQDto;
import com.nu.dto.*;
import com.nu.entity.NuWxNoticeEntity;
import com.nu.entity.WxNoticeEntity;
import com.nu.enums.MQStatus;
@ -20,6 +18,14 @@ import com.nu.modules.canaddeldertag.entity.CanAddElderTag;
import com.nu.modules.canaddeldertag.service.ICanAddElderTagService;
import com.nu.modules.elderinfo.entity.ElderInfo;
import com.nu.modules.elderinfo.service.IElderInfoService;
import com.nu.modules.eldertagopelog.entity.ElderTagOpeLogInfo;
import com.nu.modules.eldertagopelog.entity.ElderTagOpeLogMain;
import com.nu.modules.eldertagopelog.service.IElderTagOpeLogInfoService;
import com.nu.modules.eldertagopelog.service.IElderTagOpeLogMainService;
import com.nu.modules.eldertagsynclog.entity.ElderTagSyncLogInfo;
import com.nu.modules.eldertagsynclog.entity.ElderTagSyncLogMain;
import com.nu.modules.eldertagsynclog.service.IElderTagSyncLogInfoService;
import com.nu.modules.eldertagsynclog.service.IElderTagSyncLogMainService;
import com.nu.modules.eldertagtypere.entity.ElderTagTypeRe;
import com.nu.modules.eldertagtypere.service.IElderTagTypeReService;
import com.nu.modules.wxnotice.IWxNoticeApi;
@ -34,6 +40,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
import java.util.Map;
@Slf4j
@ -52,6 +59,14 @@ public class ElderTaggMQListener {
private IElderInfoService elderInfoService;
@Autowired
private IWxNoticeApi wxNoticeApi;
@Autowired
private IElderTagSyncLogMainService elderTagSyncLogMainService;
@Autowired
private IElderTagSyncLogInfoService elderTagSyncLogInfoService;
@Autowired
private IElderTagOpeLogMainService elderTagOpeLogMainService;
@Autowired
private IElderTagOpeLogInfoService elderTagOpeLogInfoService;
/**
* 其他平台新增指令
@ -217,4 +232,24 @@ public class ElderTaggMQListener {
}
}
}
@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "zzbq.synccode.log"), exchange = @Exchange(name = "hldy.zzbq", type = ExchangeTypes.DIRECT), key = "zzbq.synccode.log"), errorHandler = "directiveMQErrorHandler")
public void handleDirectiveSyncLog(ElderTagSyncLogMainMQDto dto) {
ElderTagSyncLogMain main = new ElderTagSyncLogMain();
BeanUtils.copyProperties(dto,main);
elderTagSyncLogMainService.save(main);
List<ElderTagSyncLogInfo> infoList = BeanUtil.copyToList(dto.getInfoList(), ElderTagSyncLogInfo.class);
elderTagSyncLogInfoService.saveBatch(infoList);
}
@RabbitListener(bindings = @QueueBinding(value = @Queue(name = "hldy.elderTag.ope"), exchange = @Exchange(name = "hldy.elderTag", type = ExchangeTypes.DIRECT), key = "hldy.elderTag.ope"), errorHandler = "directiveMQErrorHandler")
public void handleDirectiveOpeLog(ElderTagOpeLogMainMQDto dto) {
ElderTagOpeLogMain main = new ElderTagOpeLogMain();
BeanUtils.copyProperties(dto,main);
elderTagOpeLogMainService.save(main);
List<ElderTagOpeLogInfo> infoList = BeanUtil.copyToList(dto.getInfoList(), ElderTagOpeLogInfo.class);
elderTagOpeLogInfoService.saveBatch(infoList);
}
}