fanli/src/main/java/com/yeshi/fanli/entity/system/ConfigKeyEnum.java
@@ -146,7 +146,8 @@ searchDiscoveryKeys("search_discovery_keys", "搜索发现关键词"), searchDiscoveryH5Link("search_discovery_h5_link", "搜索发现h5连接"), autoExtractHelpUrl("auto_extract_help_url", "自动提现帮助链接"), // 协议 homePageBgColors("home_page_bg_colors","首页背景颜色"), // 协议0 userProtocolHomeData("user_protocol_home_data", "用户协议首页内容"), serviceProtocolLink("service_protocol_link", "服务协议"), privacyProtocolLink("privacy_protocol_link", "隐私协议"), fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/MsgMoneyDetailServiceImpl.java
@@ -5,6 +5,7 @@ import javax.annotation.Resource; import com.yeshi.fanli.service.inter.msg.MsgOverViewsService; import org.springframework.stereotype.Service; import com.yeshi.fanli.dao.mybatis.msg.MsgMoneyDetailMapper; @@ -30,6 +31,10 @@ @Resource private MsgExtraService msgExtraService; @Resource private MsgOverViewsService msgOverViewsService; @Override public void addMsgMoneyDetail(MsgMoneyDetail detail) throws MsgMoneyDetailException { if (detail == null || detail.getUser() == null || StringUtil.isNullOrEmpty(detail.getExtraInfo())) @@ -44,6 +49,7 @@ detail.setUpdateTime(new Date()); detail.setRead(false); msgMoneyDetailMapper.insertSelective(detail); / msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } else { MsgMoneyDetail update = new MsgMoneyDetail(); @@ -52,6 +58,7 @@ update.setRead(false); update.setStateDesc(detail.getStateDesc()); msgMoneyDetailMapper.updateByPrimaryKeySelective(update); / msgExtraService.addMsgExtra(update.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } } else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.extractValid) { @@ -64,6 +71,7 @@ detail.setUpdateTime(new Date()); detail.setRead(false); msgMoneyDetailMapper.insertSelective(detail); / msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } else { MsgMoneyDetail update = new MsgMoneyDetail(); @@ -72,6 +80,7 @@ update.setRead(false); update.setStateDesc(detail.getStateDesc()); msgMoneyDetailMapper.updateByPrimaryKeySelective(update); / msgExtraService.addMsgExtra(update.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } } else { @@ -79,6 +88,7 @@ detail.setUpdateTime(new Date()); detail.setRead(false); msgMoneyDetailMapper.insertSelective(detail); / msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY); } userMsgReadStateService.addMoneyMsgUnReadCount(detail.getUser().getId(), 1); fanli/src/main/java/com/yeshi/fanli/service/impl/order/msg/MsgOrderDetailServiceImpl.java
@@ -5,6 +5,7 @@ import javax.annotation.Resource; import com.yeshi.fanli.service.inter.msg.MsgOverViewsService; import com.yeshi.fanli.util.RedisManager; import org.springframework.stereotype.Service; @@ -38,6 +39,9 @@ @Resource private MsgExtraService msgExtraService; @Resource private MsgOverViewsService msgOverViewsService; @Override public void addMsgOrderDetail(MsgOrderDetail detail, boolean needNotify) throws MsgOrderDetailException { @@ -68,6 +72,7 @@ detail.setUpdateTime(new Date()); detail.setRead(false); msgOrderDetailMapper.insertSelective(detail); / // 消息内容 msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ORDER); } else { @@ -80,6 +85,7 @@ update.setRead(false); update.setBeiZhu(detail.getBeiZhu()); msgOrderDetailMapper.updateByPrimaryKeySelective(update); / msgExtraService.addMsgExtra(update.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ORDER); } if (needNotify) fanli/src/main/java/com/yeshi/fanli/service/impl/user/msg/MsgAccountDetailServiceImpl.java
@@ -5,6 +5,7 @@ import javax.annotation.Resource; import com.yeshi.fanli.service.inter.msg.MsgOverViewsService; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -34,6 +35,8 @@ @Resource private MsgExtraService msgExtraService; @Override @Transactional(rollbackFor = Exception.class) public void addMsgAccountDetail(MsgAccountDetail detail) throws MsgAccountDetailException { @@ -45,6 +48,8 @@ detail.setUpdateTime(new Date()); detail.setRead(false); msgAccountDetailMapper.insertSelective(detail); // 消息内容 msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_ACCOUNT); // 红点