This commit is contained in:
sxu 2024-12-20 15:15:41 +08:00
parent 00326913d2
commit 6e24bf1194
1 changed files with 8 additions and 1 deletions

View File

@ -3,6 +3,8 @@ package com.bonus.material.basic.service.impl;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import com.alibaba.fastjson2.JSONObject;
import com.bonus.common.biz.constant.MaterialConstants;
import com.bonus.common.core.exception.ServiceException;
@ -47,13 +49,18 @@ public class BmMessageServiceImpl implements IBmMessageService {
*/
@Override
public List<BmMessage> selectBmMessageList(BmMessage bmMessage) {
Long companyId = SecurityUtils.getLoginUser().getSysUser().getCompanyId();
bmMessage.setFromCompany(companyId);
bmMessage.setToCompany(companyId);
return bmMessageMapper.selectBmMessageList(bmMessage);
}
@Override
public List<BmMessage> selectBmMessageListFromCache(BmMessage bmMessage) {
List<BmMessage> bmMessages = redisService.getCacheList(MaterialConstants.CACHE_MATERIAL_MALL_MESSAGE);
return bmMessages;
Long companyId = SecurityUtils.getLoginUser().getSysUser().getCompanyId();
List<BmMessage> result = bmMessages.stream().filter(o -> companyId.equals(o.getFromCompany()) || companyId.equals(o.getToCompany())).collect(Collectors.toList());
return result;
}
/**