From 245bf498b0b145b21b73cc73c77637c895528322 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期二, 14 四月 2020 09:18:07 +0800 Subject: [PATCH] 消息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java | 20 +++++++++++++------- 1 files changed, 13 insertions(+), 7 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java index 6993d12..6968c20 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java @@ -6,16 +6,17 @@ import javax.annotation.Resource; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; import com.google.gson.Gson; import com.yeshi.fanli.dao.mybatis.msg.MsgAccountDetailMapper; import com.yeshi.fanli.dto.msg.MsgAccountVipDTO; import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail; import com.yeshi.fanli.entity.bus.msg.MsgAccountDetail.MsgTypeAccountTypeEnum; -import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum; +import com.yeshi.fanli.entity.bus.msg.MsgExtra; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.exception.msg.MsgAccountDetailException; -import com.yeshi.fanli.exception.msg.MsgOtherDetailException; +import com.yeshi.fanli.service.inter.msg.MsgExtraService; import com.yeshi.fanli.service.inter.msg.UserMsgReadStateService; import com.yeshi.fanli.service.inter.user.msg.MsgAccountDetailService; import com.yeshi.fanli.util.Constant; @@ -29,19 +30,24 @@ @Resource private UserMsgReadStateService userMsgReadStateService; + + @Resource + private MsgExtraService msgExtraService; @Override + @Transactional(rollbackFor = Exception.class) public void addMsgAccountDetail(MsgAccountDetail detail) throws MsgAccountDetailException { - if (detail == null) - throw new MsgAccountDetailException(1, "娑堟伅涓虹┖"); - if (StringUtil.isNullOrEmpty(detail.getTitle()) || StringUtil.isNullOrEmpty(detail.getContent()) - || detail.getType() == null || detail.getUser() == null) - throw new MsgAccountDetailException(2, "娑堟伅鍐呭涓嶅畬鏁�"); + if (detail == null || detail.getUser() == null || detail.getType() == null + || StringUtil.isNullOrEmpty(detail.getExtraInfo())) + throw new MsgAccountDetailException(1, "娑堟伅淇℃伅涓嶅叏"); // 鎸佷箙鍖栧埌鏁版嵁搴� detail.setCreateTime(new Date()); detail.setUpdateTime(new Date()); detail.setRead(false); msgAccountDetailMapper.insertSelective(detail); + // 娑堟伅鍐呭 + msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); + // 绾㈢偣 userMsgReadStateService.addAccountMsgUnReadCount(detail.getUser().getId(), 1); } -- Gitblit v1.8.0