package jnpf.limsService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import jnpf.limsEntity.LimsBizLogEntity;
|
import jnpf.limsEntity.bizlog.BizLogAction;
|
import jnpf.limsEntity.bizlog.BizLogType;
|
import jnpf.limsEntity.bizlog.LimsBizLogQueryParam;
|
import jnpf.limsEntity.bizlog.LimsBizLogVo;
|
import jnpf.limsMapper.LimsBizLogMapper;
|
import jnpf.limsService.LimsBizLogService;
|
import jnpf.permission.UserApi;
|
import jnpf.permission.entity.UserEntity;
|
import jnpf.util.DateUtil;
|
import jnpf.util.UploaderUtil;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.stream.Collectors;
|
|
@Slf4j
|
@Service
|
public class LimsBizLogServiceImpl
|
extends ServiceImpl<LimsBizLogMapper, LimsBizLogEntity>
|
implements LimsBizLogService {
|
|
@Autowired
|
private UserApi userApi;
|
|
@Override
|
public List<LimsBizLogVo> listByBizCode(LimsBizLogQueryParam q) {
|
QueryWrapper<LimsBizLogEntity> wrapper = new QueryWrapper<>();
|
wrapper.lambda()
|
.eq(LimsBizLogEntity::getBizCode, q.getBizCode())
|
.eq(LimsBizLogEntity::getDeleteMark, 0);
|
if (StringUtils.hasText(q.getBizType())) {
|
wrapper.lambda().eq(LimsBizLogEntity::getBizType, q.getBizType());
|
}
|
if (StringUtils.hasText(q.getActionType())) {
|
wrapper.lambda().eq(LimsBizLogEntity::getActionType, q.getActionType());
|
}
|
if (StringUtils.hasText(q.getOperatorUserId())) {
|
wrapper.lambda().eq(LimsBizLogEntity::getOperatorUserId, q.getOperatorUserId());
|
}
|
if (q.getStartTime() != null) {
|
wrapper.lambda().ge(LimsBizLogEntity::getCreatorTime, q.getStartTime());
|
}
|
if (q.getEndTime() != null) {
|
wrapper.lambda().le(LimsBizLogEntity::getCreatorTime, q.getEndTime());
|
}
|
wrapper.lambda().orderByDesc(LimsBizLogEntity::getCreatorTime).orderByDesc(LimsBizLogEntity::getLogSeq);
|
|
Page<LimsBizLogEntity> page = new Page<>(q.getCurrentPage(), q.getPageSize());
|
Page<LimsBizLogEntity> result = this.page(page, wrapper);
|
List<LimsBizLogEntity> rows = result.getRecords();
|
|
// 批量补 user 信息
|
List<String> userIds = rows.stream()
|
.map(LimsBizLogEntity::getOperatorUserId)
|
.filter(StringUtils::hasText)
|
.distinct()
|
.collect(Collectors.toList());
|
Map<String, UserEntity> userMap = new HashMap<>();
|
if (!userIds.isEmpty()) {
|
List<UserEntity> users = userApi.getUserName(userIds);
|
if (users != null) {
|
userMap = users.stream().collect(Collectors.toMap(UserEntity::getId, u -> u, (a, b) -> a));
|
}
|
}
|
|
List<LimsBizLogVo> voList = new ArrayList<>(rows.size());
|
for (LimsBizLogEntity e : rows) {
|
voList.add(toVo(e, userMap));
|
}
|
// 把 total 写回 Pagination 入参，Controller 复制到 PaginationVO 即可
|
q.setData(voList, result.getTotal());
|
return voList;
|
}
|
|
private LimsBizLogVo toVo(LimsBizLogEntity e, Map<String, UserEntity> userMap) {
|
LimsBizLogVo vo = new LimsBizLogVo();
|
vo.setId(e.getId());
|
vo.setLogSeq(e.getLogSeq());
|
vo.setBizCode(e.getBizCode());
|
vo.setBizType(e.getBizType());
|
vo.setActionType(e.getActionType());
|
vo.setActionLabel(e.getActionLabel());
|
vo.setCreatorTime(e.getCreatorTime() == null ? null
|
: DateUtil.dateToString(e.getCreatorTime(), "yyyy-MM-dd HH:mm"));
|
vo.setCreatorUserId(e.getOperatorUserId());
|
|
BizLogAction action = parseAction(e.getActionType());
|
vo.setType(action == null ? null : action.getFrontendType());
|
|
UserEntity user = userMap.get(e.getOperatorUserId());
|
if (user != null) {
|
vo.setCreatorUserName(user.getRealName());
|
vo.setHeadIcon(UploaderUtil.uploaderImg(user.getHeadIcon()));
|
}
|
|
// JSON 字符串直接透传，前端 JSON.parse 解析（与平台原生日志一致）
|
vo.setDataLog(e.getDataLog());
|
vo.setExtraJson(e.getExtraJson());
|
return vo;
|
}
|
|
private BizLogAction parseAction(String code) {
|
if (code == null) return null;
|
for (BizLogAction a : BizLogAction.values()) {
|
if (a.getCode().equals(code)) return a;
|
}
|
return null;
|
}
|
|
/** 仅供切面/调用方查 bizType 文案，目前未直接用，保留扩展 */
|
@SuppressWarnings("unused")
|
private BizLogType parseType(String code) {
|
if (code == null) return null;
|
for (BizLogType t : BizLogType.values()) {
|
if (t.getCode().equals(code)) return t;
|
}
|
return null;
|
}
|
}
|
