批量添加结算消息

admin

2022-10-28 0e9b6603d4ae9d11c1fbc90257ce816c5807b8ff

 app/src/main/java/com/yeshi/makemoney/app/service/impl/msg/UserMsgServiceImpl.java

@@ -3,6 +3,8 @@
import java.lang.Exception;
import javax.annotation.Resource;

import com.yeshi.makemoney.app.entity.user.UserExtraInfo;
import com.yeshi.makemoney.app.service.inter.user.UserExtraInfoService;
import org.springframework.data.domain.Sort;
import org.springframework.stereotype.Service;

@@ -27,6 +29,9 @@

    @Resource
    private UserMsgDao userMsgDao;

    @Resource
    private UserExtraInfoService userExtraInfoService;

    @Override
    public List<UserMsg> list(UserMsgQuery userMsgQuery, int page, int pageSize) {
@@ -60,16 +65,25 @@

    @Override
    public void add(UserMsg userMsg) throws Exception {

        if (userMsg.getCreateTime() == null) {
            userMsg.setCreateTime(new Date());
        }

        if (userMsg.getId() == null) {
            userMsg.setId(userMsg.toId());
        }

        //查询主键ID是否存在
        if (userMsgDao.get(userMsg.getId()) != null) {
            throw new Exception("已存在");
        }

        if (userMsg.getCreateTime() == null) {
            userMsg.setCreateTime(new Date());
        }
        //保存
        userMsgDao.save(userMsg);

        //添加消息数量
        userExtraInfoService.addUnReadMsgCount(userMsg.getUid(), 1);
    }

    @Override
@@ -88,5 +102,10 @@
        }
    }

    @Override
    public void readAllMsg(Long uid) {
        userExtraInfoService.setMsgRead(uid);
    }


}