淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

 fanli/src/main/java/com/yeshi/fanli/service/impl/money/msg/MsgMoneyDetailServiceImpl.java

@@ -5,6 +5,8 @@

import javax.annotation.Resource;

import com.yeshi.fanli.service.inter.msg.MsgOverViewsService;
import com.yeshi.fanli.util.factory.msg.MsgOverViewsFactory;
import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.mybatis.msg.MsgMoneyDetailMapper;
@@ -30,6 +32,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 +50,8 @@
            detail.setUpdateTime(new Date());
            detail.setRead(false);
            msgMoneyDetailMapper.insertSelective(detail);
            //加入消息索引
            msgOverViewsService.save(MsgOverViewsFactory.create(detail));
            msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY);
         } else {
            MsgMoneyDetail update = new MsgMoneyDetail();
@@ -52,6 +60,8 @@
            update.setRead(false);
            update.setStateDesc(detail.getStateDesc());
            msgMoneyDetailMapper.updateByPrimaryKeySelective(update);
            //更新消息索引时间
            msgOverViewsService.updateTime(MsgOverViewsFactory.create(detail).getId(), update.getUpdateTime());
            msgExtraService.addMsgExtra(update.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY);
         }
      } else if (detail.getMsgType() == MsgTypeMoneyTypeEnum.extractValid) {
@@ -64,6 +74,8 @@
            detail.setUpdateTime(new Date());
            detail.setRead(false);
            msgMoneyDetailMapper.insertSelective(detail);
            //加入消息索引
            msgOverViewsService.save(MsgOverViewsFactory.create(detail));
            msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY);
         } else {
            MsgMoneyDetail update = new MsgMoneyDetail();
@@ -72,6 +84,8 @@
            update.setRead(false);
            update.setStateDesc(detail.getStateDesc());
            msgMoneyDetailMapper.updateByPrimaryKeySelective(update);
            //更新消息索引时间
            msgOverViewsService.updateTime(MsgOverViewsFactory.create(detail).getId(), update.getUpdateTime());
            msgExtraService.addMsgExtra(update.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY);
         }
      }  else {
@@ -79,6 +93,8 @@
         detail.setUpdateTime(new Date());
         detail.setRead(false);
         msgMoneyDetailMapper.insertSelective(detail);
         //加入消息索引
         msgOverViewsService.save(MsgOverViewsFactory.create(detail));
         msgExtraService.addMsgExtra(detail.getId(), detail.getExtraInfo(), MsgExtra.MSG_TYPE_MONEY);
      }
      userMsgReadStateService.addMoneyMsgUnReadCount(detail.getUser().getId(), 1);
@@ -90,6 +106,11 @@
   }

   @Override
   public List<MsgMoneyDetail> listDetail(List<Long> ids) {
      return msgMoneyDetailMapper.listByPrimaryKeys(ids);
   }

   @Override
   public long countMsgMoneyDetail(Long uid) {
      return msgMoneyDetailMapper.countByUid(uid);
   }