消息通知

xin

2025-08-25 78a1ece4ca72dbf123f63387f3bab91bc87a2bac

消息通知

 oying-system/src/main/java/com/oying/modules/message/domain/MesMsgRecord.java

@@ -74,21 +74,6 @@
    @ApiModelProperty(value = "扩展字段 存跳转链接等")
    private String extra;

    @NotBlank
    @ApiModelProperty(value = "创建人")
    private String createBy;

    @NotNull
    @ApiModelProperty(value = "创建时间")
    private Timestamp createTime;

    @NotBlank
    @ApiModelProperty(value = "更新人")
    private String updateBy;

    @NotNull
    @ApiModelProperty(value = "更新时间")
    private Timestamp updateTime;
    // 新增字段
    @NotNull
    @ApiModelProperty(value = "订单ID")

 oying-system/src/main/java/com/oying/modules/message/service/impl/MesMsgRecordServiceImpl.java

@@ -114,23 +114,6 @@
        return mesMsgRecordMapper.queryorder(shopId);
    }

//    @Override
//    @Transactional(rollbackFor = Exception.class)
//    public void insertOrderMsg(String orderNo, MsgStatusEnum content, Long shopId) {
//        MesMsgRecord record = new MesMsgRecord();
//        record.setOrderNo(orderNo);
//        record.setContent(content.getValue()); // 使用枚举的描述作为消息内容
//        record.setContentKey(String.valueOf(content.getKey()));// 使用枚举的描述作为消息内容key
//        record.setShopId(shopId);
//        record.setMsgType(MesTypeEnum.ORDER.getKey()); // 订单消息类型为2
//        record.setIsRead(MesReadEnum.UNREAD.getKey()); // 默认未读 0
//        record.setCreateTime(new Timestamp(System.currentTimeMillis()));
//        record.setUpdateTime(new Timestamp(System.currentTimeMillis()));
//        mesMsgRecordMapper.insert(record);   // 让异常直接往外抛
//
//    }


    @Override
    public List<MesMsgRecordQueryPollDto> PollMesAll(Long platform) {
        return mesMsgRecordMapper.PollMesAll(platform);
@@ -150,8 +133,6 @@
        record.setShopId(order.getStoreId());
        record.setMsgType(typeEnum.getKey()); // 订单消息类型为2
        record.setIsRead(MesReadEnum.UNREAD.getKey()); // 默认未读 0
        record.setCreateTime(new Timestamp(System.currentTimeMillis()));
        record.setUpdateTime(new Timestamp(System.currentTimeMillis()));
        mesMsgRecordMapper.insert(record);
    }