智能售货机运营管理系统：AI 辅助若依框架实战

3.1.3 关键技术实现

为了优化关联查询，我们在显示区域列表时直接统计点位数：

<!-- 区域列表显示点位数 -->
<select resultType="RegionVo">
    SELECT r.*, COUNT(n.id) AS node_count 
    FROM tb_region r 
    LEFT JOIN tb_node n ON r.id = n.region_id 
    GROUP BY r.id
</select>

同时，全局异常处理器会捕获外键约束异常，给出友好的提示：

// 全局异常处理器处理外键约束异常
@ExceptionHandler(DataIntegrityViolationException.class)
public AjaxResult handleDataIntegrityViolationException(DataIntegrityViolationException e) {
    if (e.getMessage().contains("foreign")) {
        return AjaxResult.error("无法删除，有其他数据引用");
    }
    return AjaxResult.error("操作违反了数据库完整性约束");
}

3.2 人员管理系统

3.2.1 业务需求

涵盖员工信息管理（运维、运营人员）、角色权限分配及区域责任划分。

3.2.2 冗余字段设计

为了提高查询效率，我们在员工表中添加了冗余字段，如 region_name、role_name 和 role_code，避免频繁 Join 查询。

3.2.3 同步更新机制

当区域名称修改时，需要同步更新员工表中的区域名称，确保数据一致性：

@Transactional(rollbackFor = Exception.class)
public int updateRegion(Region region) {
    // 更新区域信息
    int result = regionMapper.updateRegion(region);
    // 同步更新员工表区域名称
    empMapper.updateByRegionId(region.getRegionName(), region.getId());
    return result;
}

3.3 文件存储方案

3.3.1 云存储集成

本地文件存储存在硬件要求高、维护复杂及单点故障风险。因此我们选择阿里云 OSS 对象存储作为解决方案。

1. 开通 OSS 服务并创建 Bucket
2. 配置 AccessKey 和 SecretKey
3. 集成 OSS SDK 实现文件上传

3.3.2 统一文件存储框架

使用 x-file-storage 统一文件存储接口，配置文件如下：

# yaml 文件配置
dromara:
  x-file-storage:
    default-platform: aliyun-oss-1
    aliyun-oss:
      - platform: aliyun-oss-1
        access-key: ${OSS_ACCESS_KEY_ID}
        secret-key: ${OSS_ACCESS_KEY_SECRET}
        end-point: oss-cn-beijing.aliyuncs.com
        bucket-name: your-bucket
        base-path: project-images/

3.3.3 文件上传实现

上传逻辑相对简单，指定 OSS 保存路径后调用服务即可：

public AjaxResult uploadFile(MultipartFile file) {
    // 指定 OSS 保存路径
    String objectName = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyy/MM/dd")) + "/";
    // 上传文件到 OSS
    FileInfo fileInfo = fileStorageService.of(file).setPath(objectName).upload();
    // 返回文件访问 URL
    return AjaxResult.success().put("url", fileInfo.getUrl());
}

3.4 设备管理系统

3.4.1 设备全生命周期管理

设备状态流转清晰：

• 0：未投放 → 创建投放工单
• 1：运营 → 可创建补货、维修工单
• 3：撤机 → 设备下线

3.4.2 设备新增事务处理

新增设备涉及多个步骤，包括生成编号、补充规格信息、关联点位及批量创建货道，全部在一个事务中完成：

@Transactional
public int insertVendingMachine(VendingMachine vendingMachine) {
    // 1. 生成设备编号
    String innerCode = UUIDUtils.getUUID();
    vendingMachine.setInnerCode(innerCode);
    // 2. 补充设备信息
    VmType vmType = vmTypeService.selectVmTypeById(vendingMachine.getVmTypeId());
    vendingMachine.setChannelMaxCapacity(vmType.getChannelMaxCapacity());
    // 3. 查询点位信息
    Node node = nodeService.selectNodeById(vendingMachine.getNodeId());
    BeanUtil.copyProperties(node, vendingMachine, "id");
    vendingMachine.setAddr(node.getAddress());
    // 4. 保存设备信息
    int result = vendingMachineMapper.insertVendingMachine(vendingMachine);
    // 5. 批量创建货道（根据设备类型规格）
    List<Channel> channelList = createChannels(vendingMachine, vmType);
    channelService.batchInsertChannel(channelList);
    return result;
}

3.4.3 货道管理

货道编号遵循'行号 - 列号'格式（如"1-1", "1-2"），最大容量由设备类型决定。批量更新货道商品关联的逻辑如下：

public int setChannel(ChannelConfigDto channelConfigDto) {
    // 批量更新货道商品关联
    List<Channel> list = channelConfigDto.getChannelList().stream()
        .map(dto -> {
            Channel channel = channelMapper.getChannelInfo(dto.getInnerCode(), dto.getChannelCode());
            if (channel != null) {
                channel.setSkuId(dto.getSkuId());
                channel.setUpdateTime(DateUtils.getNowDate());
            }
            return channel;
        }).collect(Collectors.toList());
    return channelMapper.batchUpdateChannel(list);
}

3.5 策略管理系统

3.5.1 营销策略设计

支持折扣策略（固定比例）、策略分配（单个或多个设备）及实时计算商品折扣价。

3.5.2 策略分配实现

更新设备时，如果点位变更，需要同步更新冗余的地址信息：

public int updateVendingMachine(VendingMachine vendingMachine) {
    if (vendingMachine.getNodeId() != null) {
        // 更新点位相关冗余信息
        Node node = nodeService.selectNodeById(vendingMachine.getNodeId());
        BeanUtil.copyProperties(node, vendingMachine, "id");
        vendingMachine.setAddr(node.getAddress());
    }
    vendingMachine.setUpdateTime(DateUtils.getNowDate());
    return vendingMachineMapper.updateVendingMachine(vendingMachine);
}

3.6 商品管理系统

3.6.1 商品管理功能

包括商品分类管理、信息维护（名称、图片、价格、规格）以及批量导入导出。

3.6.2 EasyExcel 集成

相比传统 POI，EasyExcel 内存消耗大幅降低，API 更简洁，支持大文件处理。集成步骤包括添加依赖、实体类注解及实现导入导出逻辑。

批量导入实现示例：

@PostMapping("/import")
public AjaxResult excelImport(MultipartFile file) throws Exception {
    ExcelUtil<Sku> util = new ExcelUtil<Sku>(Sku.class);
    // 使用 EasyExcel 解析
    List<Sku> skuList = util.importEasyExcel(file.getInputStream());
    return toAjax(skuService.insertSkus(skuList));
}

3.6.3 逻辑外键约束

由于货道表默认 SKU_ID 为 0，物理外键约束会导致插入失败，因此采用应用层逻辑约束：

public int deleteSkuBySkuIds(Long[] skuIds) {
    // 检查商品是否被货道引用
    int count = channelService.countChannelBySkuIds(skuIds);
    if (count > 0) {
        throw new ServiceException("此商品被货道关联，无法删除");
    }
    return skuMapper.deleteSkuBySkuIds(skuIds);
}

3.7 工单管理系统

3.7.1 工单系统设计

工单分为运营工单（补货）和运维工单（投放、撤机、维修）。状态包括待处理、进行中、已取消、已完成。

3.7.2 工单创建流程

关键校验逻辑包括设备状态匹配、同类型未完成工单检查、员工区域匹配及详情完整性校验。工单编号利用 Redis 原子递增生成，确保唯一性：

public String generateTaskCode() {
    String dateStr = DateUtils.getDate().replaceAll("-", "");
    String key = "project.task.code." + dateStr;
    if (!redisTemplate.hasKey(key)) {
        redisTemplate.opsForValue().set(key, 1, Duration.ofDays(1));
        return dateStr + "0001";
    }
    Long increment = redisTemplate.opsForValue().increment(key);
    return dateStr + String.format("%04d", increment);
}

3.7.3 工单取消逻辑

取消前需校验当前状态，防止重复取消或取消已完成工单：

public int cancelTask(Task task) {
    // 检查工单状态是否可取消
    Task taskDb = taskMapper.selectTaskByTaskId(task.getTaskId());
    if (taskDb.getTaskStatus().equals(TASK_STATUS_CANCEL)) {
        throw new ServiceException("该工单已取消了，不能再次取消");
    }
    if (taskDb.getTaskStatus().equals(TASK_STATUS_FINISH)) {
        throw new ServiceException("该工单已完成了，不能取消");
    }
    // 更新为取消状态
    task.setTaskStatus(TASK_STATUS_CANCEL);
    task.setUpdateTime(DateUtils.getNowDate());
    return taskMapper.updateTask(task);
}

3.7.4 API 文档集成

使用 Knife4j 替代 Swagger，添加依赖、配置路径、添加 API 注解并统一返回类型处理。

@Api(tags = "工单管理")
@RestController
@RequestMapping("/manage/task")
public class TaskController {
    @ApiOperation("创建工单")
    @PostMapping
    public R<String> createTask(@RequestBody TaskDto taskDto) {
        // 业务逻辑
        return R.ok("创建成功");
    }
}

四、多端协同架构

4.1 运营管理 App 端

技术栈：Spring Boot + MyBatis-Plus + 阿里云短信。 核心功能包括工单接收与处理、设备维修操作、商品补货执行。

4.2 设备屏幕端

技术栈：Spring Boot + MyBatis-Plus。 核心功能包括商品展示与选择、支付二维码生成、订单状态同步。

4.3 支付出货流程

1. 屏幕端发起支付请求
2. 订单服务创建订单并调用支付平台
3. 返回支付二维码链接
4. 用户扫码支付成功
5. 支付平台回调通知
6. 订单服务更新状态并触发出货

五、项目技术亮点总结

5.1 架构设计亮点

1. 分层清晰：Controller-Service-Mapper 标准分层
2. 模块化：按功能划分模块，高内聚低耦合
3. 扩展性：易于新增功能模块

5.2 性能优化实践

1. 冗余字段：减少关联查询，提升列表查询性能
2. Redis 应用：工单编号生成、缓存热点数据
3. 批量操作：批量插入、更新减少数据库交互

5.3 数据一致性保障

1. 事务管理：关键业务操作添加事务注解
2. 外键约束：数据库层与应用层双重保障
3. 状态机设计：明确的状态流转规则

5.4 开发效率提升

1. 代码生成器：快速生成基础 CRUD 代码
2. AI 辅助：Prompt 工程加速开发过程
3. 统一异常处理：全局异常处理器简化错误处理

5.5 运维友好性

1. 完整日志：关键操作记录操作日志
2. 接口文档：Knife4j 提供清晰 API 文档
3. 配置外化：关键配置统一管理

六、项目部署与运维

6.1 环境要求

• JDK 8+
• MySQL 5.7+
• Redis 3.2+
• Node.js 14+

6.2 部署步骤

1. 数据库初始化
2. 后端应用打包部署
3. 前端构建部署
4. 反向代理配置
5. 域名绑定与 SSL 证书

6.3 监控与维护

1. 应用健康检查接口
2. 日志集中管理
3. 数据库备份策略
4. 性能监控告警

七、扩展与优化方向

7.1 功能扩展

1. 智能预警：基于销售数据预测补货时间
2. 会员系统：用户积分、优惠券体系
3. 数据分析：销售热力图、用户偏好分析

7.2 技术优化

1. 微服务化：按业务域拆分微服务
2. 容器化部署：Docker + Kubernetes
3. 消息队列：异步处理订单、工单等业务
4. 分布式事务：跨服务数据一致性保障

7.3 安全加固

1. API 安全：请求签名、防重放攻击
2. 数据加密：敏感数据加密存储
3. 权限细化：更细粒度的 RBAC 权限控制