修改当前登录用户获取

This commit is contained in:
Guava
2023-06-25 19:40:33 +08:00
parent 3bd3e7b9c4
commit 7e25369c86
3 changed files with 11 additions and 10 deletions

View File

@@ -165,8 +165,7 @@ public class CasesRecommendApi extends ApiBaseController {
if (CollectionUtil.isEmpty(casesRecommendLaunch.getPushUserIdList())) { if (CollectionUtil.isEmpty(casesRecommendLaunch.getPushUserIdList())) {
throw new RuntimeException("参数错误"); throw new RuntimeException("参数错误");
} }
return success(iCasesRecommendPushRecordService.launchPush(casesRecommendLaunch, getCurrent()));
return success(iCasesRecommendPushRecordService.launchPush(casesRecommendLaunch));
} }
/** /**

View File

@@ -1,5 +1,6 @@
package com.xboe.module.boecase.service; package com.xboe.module.boecase.service;
import com.xboe.core.CurrentUser;
import com.xboe.module.boecase.entity.CasesRecommendPushRecord; import com.xboe.module.boecase.entity.CasesRecommendPushRecord;
import com.xboe.module.boecase.vo.CasesRecommendLaunchVo; import com.xboe.module.boecase.vo.CasesRecommendLaunchVo;
@@ -11,10 +12,10 @@ public interface ICasesRecommendPushRecordService {
/** /**
* 案例推送 * 案例推送
* *
* @param casesRecommendLaunch * @param
* @return * @return
*/ */
boolean launchPush(CasesRecommendLaunchVo casesRecommendLaunch); boolean launchPush(CasesRecommendLaunchVo casesRecommendLaunch, CurrentUser currentUser);
/** /**
* 根据案例推荐ID查询案例推送列表信息 * 根据案例推荐ID查询案例推送列表信息

View File

@@ -1,8 +1,8 @@
package com.xboe.module.boecase.service.impl; package com.xboe.module.boecase.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.xboe.core.CurrentUser;
import com.xboe.core.orm.FieldFilters; import com.xboe.core.orm.FieldFilters;
import com.xboe.data.dto.UserData;
import com.xboe.data.outside.IOutSideDataService; import com.xboe.data.outside.IOutSideDataService;
import com.xboe.enums.CasesPushStatusEnum; import com.xboe.enums.CasesPushStatusEnum;
import com.xboe.module.boecase.dao.CasesDao; import com.xboe.module.boecase.dao.CasesDao;
@@ -51,13 +51,12 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
private CasesRecommendPushRecordDao casesRecommendPushRecordDao; private CasesRecommendPushRecordDao casesRecommendPushRecordDao;
@Override @Override
public boolean launchPush(CasesRecommendLaunchVo casesRecommendLaunch) { public boolean launchPush(CasesRecommendLaunchVo casesRecommendLaunch, CurrentUser currentUser) {
//当前用户登录信息
UserData userInfoByUserId = outSideDataService.getUserInfoByUserId(null);
CasesRecommend casesRecommend = new CasesRecommend(); CasesRecommend casesRecommend = new CasesRecommend();
casesRecommend.setRecommendId(userInfoByUserId.getId()); casesRecommend.setRecommendId(currentUser.getAccountId());
casesRecommend.setRecommendBy(userInfoByUserId.getName()); casesRecommend.setRecommendBy(currentUser.getName());
casesRecommend.setRecommendTime(LocalDateTime.now()); casesRecommend.setRecommendTime(LocalDateTime.now());
casesRecommend.setCaseCount(casesRecommendLaunch.getCasesIdList().size()); casesRecommend.setCaseCount(casesRecommendLaunch.getCasesIdList().size());
casesRecommend.setUserCount(casesRecommendLaunch.getPushUserIdList().size()); casesRecommend.setUserCount(casesRecommendLaunch.getPushUserIdList().size());
@@ -86,6 +85,8 @@ public class CasesRecommendPushRecordServiceImpl implements ICasesRecommendPushR
casesRecommendPushRecord.setPushUserId(userId); casesRecommendPushRecord.setPushUserId(userId);
casesRecommendPushRecord.setPushUserName(userMap.get(userId) != null ? userMap.get(userId).toString() : null); casesRecommendPushRecord.setPushUserName(userMap.get(userId) != null ? userMap.get(userId).toString() : null);
casesRecommendPushRecord.setPushStatus(CasesPushStatusEnum.WAIT_PUSH.getStatus()); casesRecommendPushRecord.setPushStatus(CasesPushStatusEnum.WAIT_PUSH.getStatus());
//默认未查看
casesRecommendPushRecord.setReadFlag(0);
pushRecords.add(casesRecommendPushRecord); pushRecords.add(casesRecommendPushRecord);
} }
if (CollectionUtil.isNotEmpty(pushRecords)) { if (CollectionUtil.isNotEmpty(pushRecords)) {