qilincloud168/ERPTurbo_Server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: qilincloud168:ed6a5f6ed91a548b06f2dcd5c7d88f828ff15b8b
Branches Tags
qilincloud168:master
...
compare: qilincloud168:198cc6e8d9207dbf3b88c2ebf421ed16470dfd66
Branches Tags
qilincloud168:master

2 Commits
ed6a5f6ed9 ... 198cc6e8d9

Author SHA1 Message Date
shenyifei
198cc6e8d9 feat(audit): 增强审核功能并优化查询接口 
- 在AuditPageQry和OrderPageQry中新增订单编号、车辆编号和车牌字段
- 重构审核网关实现，添加详细的业务验证逻辑和异常处理
- 实现录入员提交审核、撤回审核以及审核员驳回等功能
- 优化消息通知机制，添加目标用户过滤功能
- 修复数据库表字段映射错误，统一audit_reason和delivery_time字段名
- 添加订单发货时西瓜等级更新的安全检查
- 实现自定义分页查询支持订单编号、车辆编号和车牌的模糊搜索
 2026-01-16 11:05:39 +08:00
shenyifei
a0bfb12556 refactor(audit): 优化审核网关实现并支持模板变量替换 
- 修改sendAuditNotification方法参数，增加AuditDO对象传递
- 重构老板审核记录处理逻辑，改为查询更新或新建记录
- 新增buildTemplateVariables方法构建模板变量映射
- 新增replaceTemplateVariables方法实现模板变量替换功能
- 集成订单信息查询并填充到消息模板变量中
- 支持订单编号、录入员、车辆信息等动态变量替换
- 支持审核员、审批员等操作人员信息变量替换
- 添加日期时间格式化处理功能
- 优化消息发送流程，支持动态模板内容生成
 2026-01-15 18:08:11 +08:00
7 changed files with 413 additions and 147 deletions
Show Stats Expand all files Collapse all files

382
erp-turbo-business/erp-turbo-biz/src/main/java/com/xunhong/erp/turbo/biz/infrastructure/gateway/AuditGatewayImpl.java
View File

@ -27,6 +27,7 @@ import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;
@ -51,14 +52,12 @@ public class AuditGatewayImpl implements AuditGateway {
LambdaQueryWrapper<AuditDO> queryWrapper = Wrappers.lambdaQuery(AuditDO.class);
queryWrapper.eq(Objects.nonNull(auditPageQry.getAuditId()), AuditDO::getAuditId, auditPageQry.getAuditId());
queryWrapper.eq(Objects.nonNull(auditPageQry.getType()), AuditDO::getType, auditPageQry.getType());
queryWrapper.eq(Objects.nonNull(auditPageQry.getState()), AuditDO::getState, auditPageQry.getState());
queryWrapper.eq(Objects.nonNull(auditPageQry.getSubjectType()), AuditDO::getSubjectType, auditPageQry.getSubjectType());
queryWrapper.orderByDesc(AuditDO::getCreatedAt);
IPage<AuditDO> page = new Page<>(auditPageQry.getPageIndex(), auditPageQry.getPageSize());
page = auditMapper.selectPage(page, queryWrapper);
page = auditMapper.selectPage(page, queryWrapper, auditPageQry);
Set<Long> orderIdList = page.getRecords().stream().filter(auditDO -> auditDO.getSubjectType().equals(AuditSubjectTypeEnum.PURCHASE_ORDER)).map(AuditDO::getSubjectId).collect(Collectors.toSet());
if (CollUtil.isNotEmpty(orderIdList)) {
List<OrderDO> orderDOList = orderMapper.selectByOrderIdList(orderIdList);
@ -102,8 +101,25 @@ public class AuditGatewayImpl implements AuditGateway {
return auditConvert.toAudit(auditDO);
}
/**
* 录入员提交审核
* 1、录入员首次提交。
* 2、审核员驳回后，录入员提交
*/
@Override
public Audit submitReview(OrderSubmitReviewCmd orderSubmitReviewCmd) {
// 1. 验证订单是否存在
OrderDO orderDO = orderMapper.selectByOrderId(orderSubmitReviewCmd.getOrderId());
if (Objects.isNull(orderDO)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_FOUND);
}
// 2. 验证订单状态是否允许提交审核
if (!orderDO.getState().equals(OrderStateEnum.DRAFT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_DRAFT);
}
// 3. 查询或创建审核记录
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getSubjectId, orderSubmitReviewCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
@ -125,144 +141,194 @@ public class AuditGatewayImpl implements AuditGateway {
auditMapper.updateById(auditDO);
}
// 发送提审消息（待审核消息）
sendAuditNotification(MessageTemplateSceneEnum.WAIT_AUDIT, auditDO.getAuditId(),
orderSubmitReviewCmd.getCreatedBy(), orderSubmitReviewCmd.getCreatedByName());
// 4. 发送提审消息（待审核消息）
sendAuditNotification(MessageTemplateSceneEnum.WAIT_AUDIT, auditDO, orderSubmitReviewCmd.getCreatedBy(), orderSubmitReviewCmd.getCreatedByName());
return auditConvert.toAudit(auditDO);
}
/**
* 录入员撤回审核
*/
@Override
public Audit withdrawReview(OrderWithdrawReviewCmd orderWithdrawReviewCmd) {
// 更新审核记录状态为草稿（撤回审核）
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getSubjectId, orderWithdrawReviewCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
auditQueryWrapper.eq(AuditDO::getState, AuditStateEnum.WAITING_AUDIT);
auditQueryWrapper.eq(AuditDO::getType, AuditTypeEnum.REVIEWER_AUDIT);
auditQueryWrapper.last("limit 1");
AuditDO auditDO = auditMapper.selectOne(auditQueryWrapper);
// 1. 验证审核记录ID
Long auditId = orderWithdrawReviewCmd.getAuditId();
if (Objects.isNull(auditId)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
if (auditDO != null) {
// 2. 查询审核记录
AuditDO auditDO = auditMapper.selectById(auditId);
if (Objects.isNull(auditDO)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 3. 验证审核记录状态是否为待审核
if (!auditDO.getState().equals(AuditStateEnum.WAITING_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_WAITING_FOR_WITHDRAW);
}
// 4. 更新审核记录状态为已取消
auditDO.setState(AuditStateEnum.AUDIT_CANCEL);
auditDO.setAuditAt(LocalDateTime.now());
auditDO.setAuditBy(orderWithdrawReviewCmd.getCreatedBy());
auditDO.setAuditByName(orderWithdrawReviewCmd.getCreatedByName());
auditMapper.updateById(auditDO);
}
// 撤回审核不发送消息通知
return auditConvert.toAudit(auditDO);
}
/**
* 审核员驳回
*/
@Override
public Audit rejectApprove(OrderRejectApproveCmd orderRejectApproveCmd) {
// 更新审核记录
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getAuditId, orderRejectApproveCmd.getAuditId());
auditQueryWrapper.eq(AuditDO::getSubjectId, orderRejectApproveCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
auditQueryWrapper.eq(AuditDO::getState, AuditStateEnum.WAITING_AUDIT);
auditQueryWrapper.eq(AuditDO::getType, AuditTypeEnum.REVIEWER_AUDIT);
auditQueryWrapper.last("limit 1");
AuditDO auditDO = auditMapper.selectOne(auditQueryWrapper);
// 1. 验证审核记录ID
Long auditId = orderRejectApproveCmd.getAuditId();
if (Objects.isNull(auditId)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
if (auditDO != null) {
// 2. 查询审核记录
AuditDO auditDO = auditMapper.selectById(auditId);
if (Objects.isNull(auditDO)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 3. 验证审核记录类型是否为审核员审核
if (!auditDO.getType().equals(AuditTypeEnum.REVIEWER_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 4. 验证审核记录状态是否为待审核
if (!auditDO.getState().equals(AuditStateEnum.WAITING_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_WAITING_AUDIT);
}
// 5. 更新审核记录为已驳回
auditDO.setState(AuditStateEnum.AUDIT_REJECTED);
auditDO.setAuditReason(orderRejectApproveCmd.getRejectReason());
auditDO.setAuditAt(LocalDateTime.now());
auditDO.setAuditBy(orderRejectApproveCmd.getCreatedBy());
auditDO.setAuditByName(orderRejectApproveCmd.getCreatedByName());
auditMapper.updateById(auditDO);
} else {
// 如果审核记录不存在，抛出异常
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 发送审核驳回消息
sendAuditNotification(MessageTemplateSceneEnum.AUDIT_REJECT, auditDO.getAuditId(),
orderRejectApproveCmd.getCreatedBy(), orderRejectApproveCmd.getCreatedByName());
// 6. 发送审核驳回消息
sendAuditNotification(MessageTemplateSceneEnum.AUDIT_REJECT, auditDO, orderRejectApproveCmd.getCreatedBy(), orderRejectApproveCmd.getCreatedByName());
return auditConvert.toAudit(auditDO);
}
/**
* 老板审批通过
*/
@Override
public Audit finalApprove(OrderFinalApproveCmd orderFinalApproveCmd) {
// 更新审核记录为审核成功
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getSubjectId, orderFinalApproveCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
auditQueryWrapper.eq(AuditDO::getState, AuditStateEnum.WAITING_AUDIT);
auditQueryWrapper.eq(AuditDO::getType, AuditTypeEnum.BOSS_AUDIT);
auditQueryWrapper.eq(AuditDO::getAuditId, orderFinalApproveCmd.getAuditId());
auditQueryWrapper.last("limit 1");
AuditDO auditDO = auditMapper.selectOne(auditQueryWrapper);
// 1. 验证审核记录ID
Long auditId = orderFinalApproveCmd.getAuditId();
if (Objects.isNull(auditId)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
if (auditDO != null) {
// 2. 查询审核记录
AuditDO auditDO = auditMapper.selectById(auditId);
if (Objects.isNull(auditDO)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 3. 验证审核记录类型是否为老板审核
if (!auditDO.getType().equals(AuditTypeEnum.BOSS_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 4. 验证审核记录状态是否为待审核
if (!auditDO.getState().equals(AuditStateEnum.WAITING_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_WAITING_FOR_FINAL_APPROVE);
}
// 5. 更新审核记录为审核成功
auditDO.setState(AuditStateEnum.AUDIT_SUCCESS);
auditDO.setAuditAt(LocalDateTime.now());
auditDO.setAuditBy(orderFinalApproveCmd.getCreatedBy());
auditDO.setAuditByName(orderFinalApproveCmd.getCreatedByName());
auditMapper.updateById(auditDO);
} else {
// 如果审核记录不存在，抛出异常
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 发送审批通过消息
sendAuditNotification(MessageTemplateSceneEnum.APPROVE_PASS, auditDO.getAuditId(),
orderFinalApproveCmd.getCreatedBy(), orderFinalApproveCmd.getCreatedByName());
// 6. 发送审批通过消息
sendAuditNotification(MessageTemplateSceneEnum.APPROVE_PASS, auditDO, orderFinalApproveCmd.getCreatedBy(), orderFinalApproveCmd.getCreatedByName());
return auditConvert.toAudit(auditDO);
}
/**
* 老板审批驳回
*/
@Override
public Audit rejectFinal(OrderRejectFinalCmd orderRejectFinalCmd) {
// 更新审核记录
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getSubjectId, orderRejectFinalCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
auditQueryWrapper.eq(AuditDO::getState, AuditStateEnum.WAITING_AUDIT);
auditQueryWrapper.eq(AuditDO::getType, AuditTypeEnum.BOSS_AUDIT);
auditQueryWrapper.eq(AuditDO::getAuditId, orderRejectFinalCmd.getAuditId());
auditQueryWrapper.last("limit 1");
AuditDO auditDO = auditMapper.selectOne(auditQueryWrapper);
// 1. 验证审核记录ID
Long auditId = orderRejectFinalCmd.getAuditId();
if (Objects.isNull(auditId)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
if (auditDO != null) {
// 2. 查询审核记录
AuditDO auditDO = auditMapper.selectById(auditId);
if (Objects.isNull(auditDO)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 3. 验证审核记录类型是否为老板审核
if (!auditDO.getType().equals(AuditTypeEnum.BOSS_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 4. 验证审核记录状态是否为待审核
if (!auditDO.getState().equals(AuditStateEnum.WAITING_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_WAITING_FOR_REJECT_FINAL);
}
// 5. 更新审核记录为已驳回
auditDO.setState(AuditStateEnum.AUDIT_REJECTED);
auditDO.setAuditReason(orderRejectFinalCmd.getRejectReason());
auditDO.setAuditAt(LocalDateTime.now());
auditDO.setAuditBy(orderRejectFinalCmd.getCreatedBy());
auditDO.setAuditByName(orderRejectFinalCmd.getCreatedByName());
auditMapper.updateById(auditDO);
} else {
// 如果审核记录不存在，抛出异常
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 发送审批驳回消息
sendAuditNotification(MessageTemplateSceneEnum.APPROVE_REJECT, auditDO.getAuditId(),
orderRejectFinalCmd.getCreatedBy(), orderRejectFinalCmd.getCreatedByName());
// 6. 发送审批驳回消息
sendAuditNotification(MessageTemplateSceneEnum.APPROVE_REJECT, auditDO, orderRejectFinalCmd.getCreatedBy(), orderRejectFinalCmd.getCreatedByName());
return auditConvert.toAudit(auditDO);
}
/**
* 审核员审核通过，
* 1、录入员提交的审核，审核员审核通过。
* 2、老板驳回审核，审核员重新提交审核。
*/
@Override
public Audit approve(OrderApproveCmd orderApproveCmd) {
// 更新审核记录状态为审核成功
LambdaQueryWrapper<AuditDO> auditQueryWrapper = Wrappers.lambdaQuery(AuditDO.class);
auditQueryWrapper.eq(AuditDO::getSubjectId, orderApproveCmd.getOrderId());
auditQueryWrapper.eq(AuditDO::getSubjectType, AuditSubjectTypeEnum.PURCHASE_ORDER);
auditQueryWrapper.eq(AuditDO::getState, AuditStateEnum.WAITING_AUDIT);
auditQueryWrapper.eq(AuditDO::getType, AuditTypeEnum.REVIEWER_AUDIT);
AuditDO auditDO = auditMapper.selectOne(auditQueryWrapper);
if (Objects.isNull(auditDO)) {
// 如果审核记录不存在，抛出异常
// 1. 验证审核记录ID
Long auditId = orderApproveCmd.getAuditId();
if (Objects.isNull(auditId)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 2. 查询审核记录
AuditDO auditDO = auditMapper.selectById(auditId);
if (Objects.isNull(auditDO)) {
throw new BizException(BizErrorCode.B_BIZ_AUDIT_NOT_FOUND);
}
// 3. 验证审核记录状态是否为待审核
if (!auditDO.getState().equals(AuditStateEnum.WAITING_AUDIT)) {
throw new BizException(BizErrorCode.B_BIZ_ORDER_NOT_WAITING_AUDIT);
}
// 4. 根据审核类型执行不同逻辑
// 录入员的记录审核员审核
if (auditDO.getType().equals(AuditTypeEnum.REVIEWER_AUDIT)) {
if (orderApproveCmd.getDraft()) {
return auditConvert.toAudit(auditDO);
}
@ -273,7 +339,7 @@ public class AuditGatewayImpl implements AuditGateway {
auditDO.setAuditByName(orderApproveCmd.getCreatedByName());
auditMapper.updateById(auditDO);
// 自动生成报老板待审核记录（每次都创建新记录）
// 自动生成报老板待审核记录
AuditDO auditDO1 = new AuditDO();
auditDO1.setSubjectId(orderApproveCmd.getOrderId());
auditDO1.setSubjectType(AuditSubjectTypeEnum.PURCHASE_ORDER);
@ -282,25 +348,36 @@ public class AuditGatewayImpl implements AuditGateway {
auditDO1.setCreatedBy(orderApproveCmd.getCreatedBy());
auditDO1.setCreatedByName(orderApproveCmd.getCreatedByName());
auditMapper.insert(auditDO1);
// 发送待审批消息
sendAuditNotification(MessageTemplateSceneEnum.WAIT_APPROVE, auditDO.getAuditId(),
sendAuditNotification(MessageTemplateSceneEnum.WAIT_APPROVE, auditDO,
orderApproveCmd.getCreatedBy(), orderApproveCmd.getCreatedByName());
return auditConvert.toAudit(auditDO1);
}
// 审核员被驳回后的审核
if (auditDO.getType().equals(AuditTypeEnum.BOSS_AUDIT)) {
auditDO.setState(AuditStateEnum.WAITING_AUDIT);
auditMapper.updateById(auditDO);
// 发送待审批消息
sendAuditNotification(MessageTemplateSceneEnum.WAIT_APPROVE, auditDO, orderApproveCmd.getCreatedBy(), orderApproveCmd.getCreatedByName());
return auditConvert.toAudit(auditDO);
}
return null;
}
/**
* 发送审核流程消息通知
*
* @param sceneEnum 消息场景枚举
* @param subjectId 关联主体ID（订单ID等）
* @param auditDO 审核记录
* @param createdBy 操作人ID
* @param createdByName 操作人名称
*/
@Transactional(rollbackFor = Exception.class)
private void sendAuditNotification(MessageTemplateSceneEnum sceneEnum, Long subjectId, Long createdBy, String createdByName) {
private void sendAuditNotification(MessageTemplateSceneEnum sceneEnum, AuditDO auditDO, Long createdBy, String createdByName) {
// 1. 查询启用的消息模板
LambdaQueryWrapper<MessageTemplateDO> templateWrapper = Wrappers.lambdaQuery(MessageTemplateDO.class);
templateWrapper.eq(MessageTemplateDO::getTemplateCategory, MessageTemplateCategoryEnum.PURCHASE_ORDER_MESSAGE_TEMPLATE);
@ -320,38 +397,55 @@ public class AuditGatewayImpl implements AuditGateway {
return;
}
// 2. 创建消息记录
// 2. 查询订单信息用于变量替换
OrderDO orderDO = orderMapper.selectByOrderId(auditDO.getSubjectId());
// 3. 构建变量替换映射
Map<String, String> variables = buildTemplateVariables(orderDO, auditDO, createdByName, sceneEnum);
// 4. 替换模板变量
String title = replaceTemplateVariables(template.getTitleTemplate(), variables);
String content = replaceTemplateVariables(template.getContentTemplate(), variables);
// 5. 创建消息记录
MessageDO message = new MessageDO();
message.setMessageTemplateId(template.getMessageTemplateId());
message.setTitle(template.getTitleTemplate());
message.setContent(template.getContentTemplate());
message.setTitle(title);
message.setContent(content);
message.setCreatedBy(createdBy);
message.setCreatedByName(createdByName);
message.setState(MessageStateEnum.SENT);
message.setSubjectId(subjectId);
message.setSubjectId(auditDO.getSubjectId());
message.setSubjectType(MessageSubjectTypeEnum.AUDIT);
message.setSentAt(LocalDateTime.now());
messageMapper.insert(message);
// 3. 查询所有需要接收消息的用户
// 6. 查询所有需要接收消息的用户
UserListQry userListQry = new UserListQry();
userListQry.setRoleIdList(template.getRoleIds());
List<UserVO> userVOList = userService.list(userListQry);
List<Long> userIdList = userVOList.stream().map(UserVO::getUserId).toList();
if (CollUtil.isEmpty(userIdList)) {
if (CollUtil.isEmpty(userVOList)) {
return;
}
// 7. 根据消息场景过滤接收人
List<Long> targetUserIdList = filterTargetUsers(sceneEnum, userVOList, orderDO, createdBy);
if (CollUtil.isEmpty(targetUserIdList)) {
return;
}
// 8. 查询对应的 Admin 记录
AdminListQry adminListQry = new AdminListQry();
adminListQry.setUserIdList(userIdList);
adminListQry.setUserIdList(targetUserIdList);
List<AdminVO> adminVOList = adminService.list(adminListQry);
if (CollUtil.isEmpty(adminVOList)) {
return;
}
// 4. 批量创建消息接收记录
// 9. 批量创建消息接收记录
List<MessageReceiverDO> receiverList = new ArrayList<>();
for (AdminVO adminVO : adminVOList) {
MessageReceiverDO receiver = new MessageReceiverDO();
@ -366,5 +460,109 @@ public class AuditGatewayImpl implements AuditGateway {
receiverList.forEach(messageReceiverMapper::insert);
}
}
/**
* 根据消息场景过滤目标用户
*
* @param sceneEnum 消息场景
* @param userVOList 所有拥有对应角色的用户列表
* @param orderDO 订单信息
* @param currentUserId 当前操作人ID
* @return 目标用户ID列表
*/
private List<Long> filterTargetUsers(MessageTemplateSceneEnum sceneEnum, List<UserVO> userVOList, OrderDO orderDO, Long currentUserId) {
// 驳回场景：只发给订单创建人（且拥有对应角色的人）
if (sceneEnum.equals(MessageTemplateSceneEnum.AUDIT_REJECT) ||
sceneEnum.equals(MessageTemplateSceneEnum.APPROVE_REJECT)) {
if (Objects.isNull(orderDO) || Objects.isNull(orderDO.getCreatedBy())) {
return List.of();
}
final Long orderCreatedBy = orderDO.getCreatedBy();
return userVOList.stream()
.filter(user -> user.getUserId().equals(orderCreatedBy))
.map(UserVO::getUserId)
.toList();
}
// 其他场景：发给所有拥有对应角色的用户
return userVOList.stream()
.map(UserVO::getUserId)
.toList();
}
/**
* 构建模板变量映射
*
* @param orderDO 订单信息
* @param operatorName 操作人
* @param sceneEnum 消息场景
* @return 变量映射表
*/
private Map<String, String> buildTemplateVariables(OrderDO orderDO, AuditDO auditDO, String operatorName, MessageTemplateSceneEnum sceneEnum) {
Map<String, String> variables = new HashMap<>();
if (Objects.nonNull(orderDO)) {
// 订单基本信息
variables.put("订单编号", Objects.nonNull(orderDO.getOrderSn()) ? orderDO.getOrderSn() : "未知");
variables.put("录入员姓名", Objects.nonNull(orderDO.getCreatedByName()) ? orderDO.getCreatedByName() : "未知");
variables.put("录入员提审时间", Objects.nonNull(orderDO.getCreatedAt()) ? orderDO.getCreatedAt().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) : "未知");
variables.put("车牌号", Objects.nonNull(orderDO.getOrderVehicleDO()) ? orderDO.getOrderVehicleDO().getPlate() : "未知");
variables.put("目的地", Objects.nonNull(orderDO.getOrderVehicleDO()) ? orderDO.getOrderVehicleDO().getDestination() : "未知");
variables.put("车次号", Objects.nonNull(orderDO.getOrderVehicleDO()) ? orderDO.getOrderVehicleDO().getVehicleNo() : "-");
// 经销商信息
if (Objects.nonNull(orderDO.getOrderDealerDO())) {
variables.put("经销商简称", Objects.nonNull(orderDO.getOrderDealerDO().getShortName())
? orderDO.getOrderDealerDO().getShortName() : "未知");
} else {
variables.put("经销商简称", "未知");
}
}
if (auditDO.getType().equals(AuditTypeEnum.REVIEWER_AUDIT)) {
// 操作人信息
variables.put("审核员姓名", Objects.nonNull(operatorName) ? operatorName : "系统");
// 审核员驳回原因
variables.put("审核员驳回原因", Objects.nonNull(auditDO.getAuditReason()) ? auditDO.getAuditReason() : "无");
// 审核员审核时间
variables.put("审核员审核时间", Objects.nonNull(auditDO.getAuditAt()) ? auditDO.getAuditAt().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) : "未知");
}
if (auditDO.getType().equals(AuditTypeEnum.BOSS_AUDIT)) {
// 操作人信息
variables.put("审批员姓名", Objects.nonNull(operatorName) ? operatorName : "系统");
// 审核员驳回原因
variables.put("审批员驳回原因", Objects.nonNull(auditDO.getAuditReason()) ? auditDO.getAuditReason() : "无");
// 审核员审核时间
variables.put("审批员审批时间", Objects.nonNull(auditDO.getAuditAt()) ? auditDO.getAuditAt().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) : "未知");
}
return variables;
}
/**
* 替换模板变量
* 支持格式：{{变量名}}
*
* @param template 模板内容
* @param variables 变量映射
* @return 替换后的内容
*/
private String replaceTemplateVariables(String template, Map<String, String> variables) {
if (Objects.isNull(template) || template.isEmpty()) {
return template;
}
String result = template;
for (Map.Entry<String, String> entry : variables.entrySet()) {
String placeholder = "{{" + entry.getKey() + "}}";
String value = Objects.nonNull(entry.getValue()) ? entry.getValue() : "";
result = result.replace(placeholder, value);
}
return result;
}
}

5
erp-turbo-business/erp-turbo-biz/src/main/java/com/xunhong/erp/turbo/biz/infrastructure/gateway/OrderShipGatewayImpl.java
View File

@ -147,13 +147,16 @@ public class OrderShipGatewayImpl implements OrderShipGateway {
OrderShipDO orderShipDO = orderShipMapper.selectOne(queryWrapper);
List<OrderShipItem> orderShipItemList = orderShipGenerateDocumentCmd.getOrderShipItemList();
if (CollUtil.isNotEmpty(orderShipItemList)) {
// 更新订单明细
for (OrderShipItem orderShipItem : orderShipGenerateDocumentCmd.getOrderShipItemList()) {
for (OrderShipItem orderShipItem : orderShipItemList) {
LambdaUpdateWrapper<OrderShipItemDO> updateWrapper = Wrappers.lambdaUpdate(OrderShipItemDO.class);
updateWrapper.eq(OrderShipItemDO::getOrderShipId, orderShipDO.getOrderShipId());
updateWrapper.set(OrderShipItemDO::getWatermelonGrade, orderShipItem.getWatermelonGrade());
orderShipItemMapper.update(null, updateWrapper);
}
}
orderShipConvert.toOrderShipDO(orderShipDO, orderShipGenerateDocumentCmd);
orderShipMapper.updateById(orderShipDO);

6
erp-turbo-business/erp-turbo-biz/src/main/java/com/xunhong/erp/turbo/biz/infrastructure/mapper/AuditMapper.java
View File

@ -1,13 +1,19 @@
package com.xunhong.erp.turbo.biz.infrastructure.mapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Constants;
import com.xunhong.erp.turbo.api.biz.dto.qry.AuditPageQry;
import com.xunhong.erp.turbo.biz.infrastructure.entity.AuditDO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
/**
* @author shenyifei
*/
@Mapper
public interface AuditMapper extends BaseMapper<AuditDO> {
IPage<AuditDO> selectPage(IPage<AuditDO> page, @Param(Constants.WRAPPER) LambdaQueryWrapper<AuditDO> queryWrapper, @Param("query") AuditPageQry auditPageQry);
}

44
erp-turbo-business/erp-turbo-biz/src/main/resources/mapper/AuditMapper.xml
View File

@ -9,10 +9,10 @@
<result property="subjectType" column="subject_type"/>
<result property="state" column="state"/>
<result property="type" column="type"/>
<result property="auditReason" column="reject_reason"/>
<result property="auditReason" column="audit_reason"/>
<result property="auditAt" column="audit_at"/>
<result property="auditId" column="reject_by"/>
<result property="auditByName" column="reject_by_name"/>
<result property="auditByName" column="audit_by_name"/>
<result property="createdBy" column="created_by"/>
<result property="createdByName" column="created_by_name"/>
<result property="createdAt" column="created_at"/>
@ -20,5 +20,45 @@
<result property="isDelete" column="is_delete"/>
<result property="version" column="version"/>
</resultMap>
<select id="selectPage"
resultType="com.xunhong.erp.turbo.biz.infrastructure.entity.AuditDO"
resultMap="BaseResultMap">
SELECT
a.*
FROM audit a
<if test="query.orderSn != null">
LEFT JOIN `order` po ON po.order_id = a.subject_id AND
a.subject_type = 1 AND po.is_delete = 0
</if>
<if test="query.vehicleNo != null or query.plate != null">
LEFT JOIN order_vehicle ov ON ov.order_id = a.subject_id AND
a.subject_type = 1 AND ov.is_delete = 0
</if>
<where>
AND a.is_delete = 0
<if test="query.orderSn != null">
AND po.order_sn like CONCAT('%',#{query.orderSn},'%')
</if>
<if test="query.vehicleNo != null">
AND ov.vehicle_no like CONCAT('%',#{query.vehicleNo},'%')
</if>
<if test="query.plate != null">
AND ov.plate like CONCAT('%',#{query.plate},'%')
</if>
<if test="query.state != null">
AND a.state = #{query.state}
</if>
<if test="query.type != null">
AND a.type = #{query.type}
</if>
<if test="ew != null">
<if test="ew.nonEmptyOfWhere">
AND
</if>
${ew.sqlSegment}
</if>
</where>
</select>
</mapper>

19
erp-turbo-business/erp-turbo-biz/src/main/resources/mapper/OrderMapper.xml
View File

@ -30,7 +30,7 @@
<result property="dealerName" column="dealer_name"/>
<result property="origin" column="origin"/>
<result property="destination" column="destination"/>
<result property="deliveryTime" column="deliveryTime"/>
<result property="deliveryTime" column="delivery_time"/>
</association>
</resultMap>
@ -49,6 +49,7 @@
<result property="dealerName" column="dealer_name"/>
<result property="origin" column="origin"/>
<result property="destination" column="destination"/>
<result property="deliveryTime" column="delivery_time"/>
</association>
</resultMap>
@ -57,7 +58,7 @@
resultMap="SelectByOrderIdListResultMap">
SELECT
po.order_id, po.order_sn, po.state, po.audit_state, po.type,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin, ov.delivery_time,
ov.destination
FROM `order` po
LEFT JOIN order_vehicle ov ON po.order_id = ov.order_id AND ov.is_delete
@ -79,7 +80,7 @@
resultMap="BaseResultMap">
SELECT
po.*,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin, ov.delivery_time,
ov.destination
FROM `order` po
LEFT JOIN order_vehicle ov ON po.order_id = ov.order_id AND ov.is_delete
@ -89,6 +90,12 @@
<if test="query.vehicleNo != null">
AND ov.vehicle_no LIKE CONCAT('%',#{query.vehicleNo},'%')
</if>
<if test="query.orderSn != null">
AND po.order_sn LIKE CONCAT('%',#{query.orderSn},'%')
</if>
<if test="query.plate != null">
AND ov.plate LIKE CONCAT('%',#{query.plate},'%')
</if>
<if test="query.dealerId != null">
AND ov.dealer_id = #{query.dealerId}
</if>
@ -120,7 +127,7 @@
resultMap="SelectByOrderIdListResultMap">
SELECT
po.order_id, po.order_sn, po.state, po.audit_state, po.type,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin, ov.delivery_time,
ov.destination
FROM `order` po
LEFT JOIN order_vehicle ov ON po.order_id = ov.order_id AND ov.is_delete
@ -134,7 +141,7 @@
resultMap="BaseResultMap">
SELECT
po.*,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin, ov.delivery_time,
ov.destination, ov.delivery_time
FROM `order` po
LEFT JOIN order_vehicle ov ON po.order_id = ov.order_id AND ov.is_delete
@ -160,7 +167,7 @@
resultType="com.xunhong.erp.turbo.biz.infrastructure.entity.OrderDO">
SELECT
po.*,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin,
ov.vehicle_id, ov.vehicle_no, ov.dealer_id, ov.dealer_name, ov.origin, ov.delivery_time,
ov.destination
FROM `order` po
LEFT JOIN order_vehicle ov ON po.order_id = ov.order_id AND ov.is_delete

9
erp-turbo-common/erp-turbo-api/src/main/java/com/xunhong/erp/turbo/api/biz/dto/qry/AuditPageQry.java
View File

@ -27,5 +27,14 @@ public class AuditPageQry extends PageQuery {
@Schema(title = "审核对象类型：1_采购单；")
private AuditSubjectTypeEnum subjectType;
@Schema(title = "订单编号")
private String orderSn;
@Schema(title = "车辆编号")
private String vehicleNo;
@Schema(title = "车牌")
private String plate;
}

3
erp-turbo-common/erp-turbo-api/src/main/java/com/xunhong/erp/turbo/api/biz/dto/qry/OrderPageQry.java
View File

@ -25,6 +25,9 @@ public class OrderPageQry extends PageQuery {
@Schema(title = "采购订单编号", type = "string")
private String orderSn;
@Schema(title = "车牌号", type = "string")
private String plate;
/**
* 采购订单状态: 0_草稿；1_审核中；2_已完成；3_已关闭；
*/