BSS客户订单管理系统：Jabdp订单处理源码解析与实战

/** * BSS客户订单实体类 * 对应数据库表：t_bss_order * 注：使用Jabdp注解实现ORM映射，简化数据库操作 */ @Entity @Table(name = “t_bss_order”) public class Order extends JabdpEntity { // 序列化版本号，保证序列化一致性 private static final long serialVersionUID = 1L; // 订单编号（唯一标识，自动生成，格式：ORDER+时间戳+随机数） @Column(name = “order_no”, unique = true, nullable = false) private String orderNo; // 客户ID（关联客户表） @Column(name = “customer_id”, nullable = false) private String customerId; // 客户名称 @Column(name = “customer_name”, nullable = false) private String customerName; // 订单金额（单位：分，避免浮点数精度问题） @Column(name = “order_amount”, nullable = false) private Long orderAmount; // 订单状态（0：待审核，1：已审核，2：已执行，3：已取消，4：异常） @Column(name = “order_status”, nullable = false) private Integer orderStatus; // 订单创建时间 @Column(name = “create_time”, nullable = false) private Date createTime; // 订单审核时间 @Column(name = “audit_time”) private Date auditTime; // 订单备注 @Column(name = “remark”, length = 500) private String remark; // 物流单号（关联物流信息，可扩展） @Column(name = “logistics_no”) private String logisticsNo; // getter/setter方法（Jabdp可自动生成，此处简化展示） public String getOrderNo() { return orderNo; } public void setOrderNo(String orderNo) { this.orderNo = orderNo; } // 其他getter/setter方法省略… // 订单状态转换方法（封装状态变更逻辑，避免业务逻辑分散） public void changeStatus(Integer newStatus) { // 状态合法性校验 if (!Arrays.asList(0,1,2,3,4).contains(newStatus)) { throw new OrderException(“订单状态不合法，允许的状态：0-待审核，1-已审核，2-已执行，3-已取消，4-异常”); } // 状态变更规则（例：待审核状态才能转为已审核/已取消） if (this.orderStatus == 0) { if (newStatus == 1 || newStatus == 3) { this.orderStatus = newStatus; // 审核状态更新审核时间 if (newStatus == 1) { this.setAuditTime(new Date()); } } else { throw new OrderException(“待审核订单仅可转为已审核或已取消状态”); } } // 其他状态变更规则可自行扩展 } }

/** * BSS订单处理业务逻辑类 * 核心职责：订单创建、审核、状态变更、查询等业务操作 */ @Service public class OrderService extends JabdpService { // 注入数据访问层对象（Jabdp自动注入，无需手动new） @Autowired private OrderDao orderDao; // 注入客户服务（关联客户信息，可扩展） @Autowired private CustomerService customerService; /** * 订单创建 * @param customerId 客户ID * @param orderAmount 订单金额（单位：分） * @param remark 订单备注 * @return 创建成功的订单对象 */ @Transactional(rollbackFor = Exception.class) // 事务管理，异常时回滚 public Order createOrder(String customerId, Long orderAmount, String remark) { // 1. 校验参数合法性 if (StringUtils.isEmpty(customerId)) { throw new OrderException(“客户ID不能为空”); } if (orderAmount == null || orderAmount <= 0) { throw new OrderException(“订单金额必须大于0”); } // 2. 校验客户是否存在（关联客户服务，可根据实际业务扩展） Customer customer = customerService.getById(customerId); if (customer == null) { throw new OrderException(“客户不存在，无法创建订单”); } // 3. 生成唯一订单编号（格式：ORDER+时间戳+3位随机数） String orderNo = “ORDER” + System.currentTimeMillis() + RandomUtils.nextInt(100, 999); // 4. 构建订单对象 Order order = new Order(); order.setOrderNo(orderNo); order.setCustomerId(customerId); order.setCustomerName(customer.getCustomerName()); order.setOrderAmount(orderAmount); order.setOrderStatus(0); // 初始状态：待审核 order.setCreateTime(new Date()); order.setRemark(remark); // 5. 保存订单（Jabdp的save方法，自动实现数据库插入） orderDao.save(order); // 6. 后续扩展：订单创建成功后，发送通知、同步库存等操作 // 此处可添加消息队列、库存扣减等逻辑，根据业务需求扩展 return order; } /** * 订单审核 * @param orderNo 订单编号 * @param auditPass 是否审核通过（true：通过，false：拒绝） * @return 审核后的订单对象 */ @Transactional(rollbackFor = Exception.class) public Order auditOrder(String orderNo, boolean auditPass) { // 1. 根据订单编号查询订单 Order order = orderDao.findByOrderNo(orderNo); if (order == null) { throw new OrderException(“订单不存在，无法审核”); } // 2. 校验订单状态（仅待审核订单可审核） if (order.getOrderStatus() != 0) { throw new OrderException(“当前订单状态不可审核，仅待审核订单可操作”); } // 3. 审核逻辑处理 if (auditPass) { // 审核通过：状态转为已审核，更新审核时间 order.changeStatus(1); } else { // 审核拒绝：状态转为已取消，可添加拒绝原因（此处简化，可扩展） order.changeStatus(3); order.setRemark(order.getRemark() + “【审核拒绝：未满足审核条件】”); } // 4. 更新订单信息 orderDao.update(order); return order; } /** * 订单查询（根据订单编号、客户ID、订单状态查询） * @param orderNo 订单编号（可选） * @param customerId 客户ID（可选） * @param orderStatus 订单状态（可选） * @return 订单列表 */ public List<Order> queryOrder(String orderNo, String customerId, Integer orderStatus) { // 使用Jabdp的查询构建器，无需手动编写SQL QueryBuilder queryBuilder = orderDao.createQueryBuilder(); if (StringUtils.isNotEmpty(orderNo)) { queryBuilder.andEqualTo(“orderNo”, orderNo); } if (StringUtils.isNotEmpty(customerId)) { queryBuilder.andEqualTo(“customerId”, customerId); } if (orderStatus != null) { queryBuilder.andEqualTo(“orderStatus”, orderStatus); } // 按创建时间倒序排列 queryBuilder.orderByDesc(“createTime”); // 执行查询，返回结果列表 return queryBuilder.list(); } // 其他业务方法（如订单取消、订单异常处理等）可自行扩展 }

/** * 订单数据访问类 * 继承Jabdp的BaseDao，自动获得CRUD操作能力 */ @Repository public class OrderDao extends BaseDao<Order> { /** * 根据订单编号查询订单（自定义查询方法） * @param orderNo 订单编号 * @return 订单对象 */ public Order findByOrderNo(String orderNo) { // 使用Jabdp的查询方法，简化查询逻辑 return this.findOneByProperty(“orderNo”, orderNo); } // 其他自定义查询方法可自行扩展，例如：根据客户ID查询所有订单、查询今日新增订单等 // 示例：根据客户ID查询订单列表 public List<Order> findByCustomerId(String customerId) { return this.findByProperty(“customerId”, customerId); } }

/** * 订单处理自定义异常类 * 继承RuntimeException，无需强制捕获，适合业务异常场景 */ public class OrderException extends RuntimeException { // 无参构造方法 public OrderException() { super(); } // 带消息的构造方法 public OrderException(String message) { super(message); } // 带消息和异常原因的构造方法 public OrderException(String message, Throwable cause) { super(message, cause); } }