14 Commits

Author SHA1 Message Date
MichaelWin
1a726b8b7d 【改进】使用内网环境 2026-03-16 10:08:31 +08:00
8f5f998c3a Merge remote-tracking branch 'origin/main' 2026-03-16 10:03:52 +08:00
37182d7efb 【新增】Sirius固件查询接口及API文档
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
2026-03-16 10:02:38 +08:00
MichaelWin
e472a3207f 【改进】查询固件版本增加当前版本参数 2026-03-06 14:58:52 +08:00
MichaelWin
c0896c199d 【新增】根据类型,型号查询固件版本 2026-03-06 14:08:11 +08:00
MichaelWin
ccfac2a9eb Merge remote-tracking branch 'origin/main' 2026-03-06 11:29:30 +08:00
MichaelWin
84594dda48 【新增】固件版本升级校验 2026-03-06 11:28:40 +08:00
MichaelWin
da144b7c6a 【改进】全局异常捕获 2026-03-06 11:28:15 +08:00
306222c55e 新增产品QC 2026-02-28 13:32:29 +08:00
MichaelWin
bd3523fd3d 测试 2026-02-27 18:33:44 +08:00
fa16fec0a0 新增产品QC 2026-02-27 17:41:08 +08:00
MichaelWin
7d5a62f8f2 【改进】不拦截工厂激活接口 2026-02-26 09:12:51 +08:00
MichaelWin
2ac80ae4d0 【新增】活动 2026-02-25 18:52:42 +08:00
MichaelWin
e5e540305d 【新增】用户设备激活,工厂设备激活 2026-02-25 18:52:34 +08:00
66 changed files with 3438 additions and 22 deletions

2
.gitignore vendored
View File

@@ -16,7 +16,7 @@ build/
bin/
!**/src/main/**/bin/
!**/src/test/**/bin/
logs
### IntelliJ IDEA ###
.idea
*.iws

View File

@@ -0,0 +1,346 @@
# Sirius 固件 API 接口文档
## 基本信息
- **Base URL**: `https://api.corewing.com`
- **接口前缀**: `/sirius_firmware`
## 统一响应格式
```json
{
"code": 200,
"message": "操作成功",
"data": {},
"success": true
}
```
| 字段 | 类型 | 说明 |
|------|------|------|
| code | Integer | 状态码200 成功500 失败) |
| message | String | 提示消息 |
| data | Object | 返回数据 |
| success | Boolean | 是否成功 |
## 枚举说明
### 固件类型firmwareType
| 值 | 说明 |
|----|------|
| 1 | 高频头 |
| 2 | 接收机 |
| 3 | 背包 |
### 协议类型protocolType
| 值 | 说明 |
|----|------|
| 1 | ELRS |
| 2 | CWLink |
## 固件对象字段说明
| 字段 | 类型 | 说明 |
|------|------|------|
| id | Integer | 主键ID |
| firmwareType | Integer | 固件类型1-高频头2-接收机3-背包 |
| protocolType | Integer | 协议类型1-ELRS2-CWLink |
| versionNumber | String | 版本号,如 v3.0.1 |
| fileName | String | 文件名 |
| filePath | String | 文件存储路径 |
| fileSize | Long | 文件大小(字节) |
| md5Hash | String | MD5 校验值 |
| releaseNotes | String | 版本更新说明(可能为 null |
| createTime | String | 创建时间 |
| updateTime | String | 更新时间 |
---
## 1. 查询最新固件版本
**接口描述:** 根据固件类型和协议类型查询最新版本,用于设备端检查更新。
**请求方式:** `GET`
**请求路径:** `/sirius_firmware/latest`
**请求参数:**
| 参数名 | 类型 | 必填 | 说明 |
|--------|------|------|------|
| firmwareType | Integer | 是 | 固件类型1-高频头2-接收机3-背包 |
| protocolType | Integer | 是 | 协议类型1-ELRS2-CWLink |
**请求示例:**
```bash
curl -X GET "http://your-server-host:8080/sirius_firmware/latest?firmwareType=1&protocolType=1"
```
**成功响应示例:**
```json
{
"code": 200,
"message": "操作成功",
"data": {
"id": 1,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.1",
"fileName": "sirius_hf_elrs_v3.0.1.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.1.bin",
"fileSize": 1048576,
"md5Hash": "d41d8cd98f00b204e9800998ecf8427e",
"releaseNotes": "优化信号连接稳定性",
"createTime": "2026-03-10 10:30:00",
"updateTime": "2026-03-10 10:30:00"
},
"success": true
}
```
**失败响应示例:**
```json
{
"code": 500,
"message": "固件不存在",
"data": null,
"success": false
}
```
---
## 2. 根据固件类型查询版本列表
**接口描述:** 查询指定固件类型下所有版本,按时间倒序排列。
**请求方式:** `GET`
**请求路径:** `/sirius_firmware/type/{firmwareType}`
**路径参数:**
| 参数名 | 类型 | 必填 | 说明 |
|--------|------|------|------|
| firmwareType | Integer | 是 | 固件类型1-高频头2-接收机3-背包 |
**请求示例:**
```bash
curl -X GET "http://your-server-host:8080/sirius_firmware/type/1"
```
**成功响应示例:**
```json
{
"code": 200,
"message": "操作成功",
"data": [
{
"id": 3,
"firmwareType": 1,
"protocolType": 2,
"versionNumber": "v2.1.0",
"fileName": "sirius_hf_cwlink_v2.1.0.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_cwlink_v2.1.0.bin",
"fileSize": 2097152,
"md5Hash": "098f6bcd4621d373cade4e832627b4f6",
"releaseNotes": "新增CWLink协议支持",
"createTime": "2026-03-12 14:00:00",
"updateTime": "2026-03-12 14:00:00"
},
{
"id": 1,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.1",
"fileName": "sirius_hf_elrs_v3.0.1.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.1.bin",
"fileSize": 1048576,
"md5Hash": "d41d8cd98f00b204e9800998ecf8427e",
"releaseNotes": "优化信号连接稳定性",
"createTime": "2026-03-10 10:30:00",
"updateTime": "2026-03-10 10:30:00"
}
],
"success": true
}
```
---
## 3. 根据固件类型和协议类型查询版本列表
**接口描述:** 查询指定固件类型和协议类型下所有版本,按时间倒序排列。
**请求方式:** `GET`
**请求路径:** `/sirius_firmware/type/{firmwareType}/protocol/{protocolType}`
**路径参数:**
| 参数名 | 类型 | 必填 | 说明 |
|--------|------|------|------|
| firmwareType | Integer | 是 | 固件类型1-高频头2-接收机3-背包 |
| protocolType | Integer | 是 | 协议类型1-ELRS2-CWLink |
**请求示例:**
```bash
curl -X GET "http://your-server-host:8080/sirius_firmware/type/1/protocol/1"
```
**成功响应示例:**
```json
{
"code": 200,
"message": "操作成功",
"data": [
{
"id": 5,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.1",
"fileName": "sirius_hf_elrs_v3.0.1.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.1.bin",
"fileSize": 1048576,
"md5Hash": "d41d8cd98f00b204e9800998ecf8427e",
"releaseNotes": "优化信号连接稳定性",
"createTime": "2026-03-12 14:00:00",
"updateTime": "2026-03-12 14:00:00"
},
{
"id": 2,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.0",
"fileName": "sirius_hf_elrs_v3.0.0.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.0.bin",
"fileSize": 1024000,
"md5Hash": "a1b2c3d4e5f6a7b8c9d0e1f2a3b4c5d6",
"releaseNotes": null,
"createTime": "2026-03-01 08:00:00",
"updateTime": "2026-03-01 08:00:00"
}
],
"success": true
}
```
---
## 4. 查询所有固件
**接口描述:** 查询所有固件记录。
**请求方式:** `GET`
**请求路径:** `/sirius_firmware/list`
**请求示例:**
```bash
curl -X GET "http://your-server-host:8080/sirius_firmware/list"
```
**成功响应示例:**
```json
{
"code": 200,
"message": "操作成功",
"data": [
{
"id": 1,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.1",
"fileName": "sirius_hf_elrs_v3.0.1.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.1.bin",
"fileSize": 1048576,
"md5Hash": "d41d8cd98f00b204e9800998ecf8427e",
"releaseNotes": "优化信号连接稳定性",
"createTime": "2026-03-10 10:30:00",
"updateTime": "2026-03-10 10:30:00"
}
],
"success": true
}
```
---
## 5. 根据ID查询固件
**接口描述:** 根据固件ID查询详情。
**请求方式:** `GET`
**请求路径:** `/sirius_firmware/{id}`
**路径参数:**
| 参数名 | 类型 | 必填 | 说明 |
|--------|------|------|------|
| id | Integer | 是 | 固件ID |
**请求示例:**
```bash
curl -X GET "http://your-server-host:8080/sirius_firmware/1"
```
**成功响应示例:**
```json
{
"code": 200,
"message": "操作成功",
"data": {
"id": 1,
"firmwareType": 1,
"protocolType": 1,
"versionNumber": "v3.0.1",
"fileName": "sirius_hf_elrs_v3.0.1.bin",
"filePath": "https://oss.corewing.com/sirius_firmware/sirius_hf_elrs_v3.0.1.bin",
"fileSize": 1048576,
"md5Hash": "d41d8cd98f00b204e9800998ecf8427e",
"releaseNotes": "优化信号连接稳定性",
"createTime": "2026-03-10 10:30:00",
"updateTime": "2026-03-10 10:30:00"
},
"success": true
}
```
**失败响应示例:**
```json
{
"code": 500,
"message": "固件不存在",
"data": null,
"success": false
}
```
---
## 接口总览
| 方法 | 路径 | 说明 | 使用场景 |
|------|------|------|----------|
| GET | `/sirius_firmware/latest?firmwareType=&protocolType=` | 查询最新版本 | 设备端检查更新 |
| GET | `/sirius_firmware/type/{firmwareType}` | 按固件类型查版本列表 | 查看某类固件所有版本 |
| GET | `/sirius_firmware/type/{firmwareType}/protocol/{protocolType}` | 按类型+协议查版本列表 | 精确筛选版本列表 |
| GET | `/sirius_firmware/list` | 查询所有固件 | 管理端展示全部数据 |
| GET | `/sirius_firmware/{id}` | 按ID查询固件 | 查看固件详情 |
---

303
docs/backend-api.md Normal file
View File

@@ -0,0 +1,303 @@
# Corewing QC 后端接口文档
> 基础路径: `/api/qc`
## 通用响应结构
所有接口统一返回 `Result<T>`:
```json
{
"code": 200,
"message": "操作成功",
"data": T,
"success": true
}
```
| 字段 | 类型 | 说明 |
|---------|---------|---------------------------|
| code | Integer | 状态码 |
| message | String | 消息内容 |
| data | T | 业务数据 |
| success | Boolean | 是否成功 |
---
## 1. 验证无线板
验证 BLE MAC 地址对应的无线板是否已在系统中注册。
- **URL**: `POST /api/qc/wireless/validate-wireless`
- **Content-Type**: `application/json`
### 请求体
```json
{
"mac": "AA:BB:CC:DD:EE:FF"
}
```
| 字段 | 类型 | 必填 | 说明 |
|------|--------|------|----------------------------------|
| mac | String | 是 | BLE MAC 地址,即设备 SN |
### 响应
```json
{
"code": 200,
"message": "验证通过",
"data": true,
"success": true
}
```
- `data = true` — 设备已注册,允许进行 QC 测试
- `data = false` / `success = false` — 设备未注册或验证失败APP 端将**作废本次测试**
---
## 2. 上传测试记录
上传完整的 QC 测试结果(含所有步骤数据和照片 URL
- **URL**: `POST /api/qc/test/upload`
- **Content-Type**: `application/json`
### 请求体
```json
{
"testNo": "WL-20260227-001",
"productType": "WIRELESS_BOARD",
"sn": "AA:BB:CC:DD:EE:FF",
"operatorId": "OP001",
"operatorName": "张三",
"phoneModel": "Pixel 7",
"appVersion": "1.0.0",
"status": "PASS",
"createTime": "1740000000000",
"updatedAt": "1740001000000",
"uploadTime": "1740002000000",
"steps": [
{
"stepIndex": 1,
"stepName": "BLE连接与特征订阅",
"result": "PASS",
"dataJson": "{\"deviceName\":\"CoreWing-001\",\"deviceMac\":\"AA:BB:CC:DD:EE:FF\",\"validated\":true}",
"duration": 5200,
"completedAt": "1740000500000"
}
],
"photoUrls": [
"https://qc.corewing.com/photos/xxx.jpg"
]
}
```
| 字段 | 类型 | 必填 | 说明 |
|--------------|------------------|------|------------------------------------------------|
| testNo | String | 是 | 测试单号,格式: `WL-yyyyMMdd-NNN``FC-yyyyMMdd-NNN` |
| productType | String | 是 | `WIRELESS_BOARD` / `FLIGHT_CONTROLLER` |
| sn | String | 是 | 产品序列号(无线板为 BLE MAC 地址) |
| operatorId | String | 是 | 测试员 ID |
| operatorName | String | 是 | 测试员姓名 |
| phoneModel | String | 否 | 测试手机型号 |
| appVersion | String | 否 | APP 版本号 |
| status | String | 是 | `PASS` / `FAIL` |
| createTime | String | 是 | 创建时间(毫秒时间戳字符串) |
| updatedAt | String | 否 | 最后更新时间(毫秒时间戳字符串) |
| uploadTime | String | 否 | 上传时间(毫秒时间戳字符串) |
| steps | StepResultData[] | 是 | 步骤结果数组 |
| photoUrls | String[] | 否 | 已上传照片的远程 URL 列表 |
**StepResultData:**
| 字段 | 类型 | 必填 | 说明 |
|-------------|--------|------|--------------------------------------|
| stepIndex | int | 是 | 步骤序号(从 1 开始) |
| stepName | String | 是 | 步骤名称 |
| result | String | 否 | `PASS` / `FAIL` / null未完成 |
| dataJson | String | 否 | 步骤详细数据 JSON 字符串 |
| duration | long | 否 | 步骤耗时(毫秒) |
| completedAt | String | 否 | 完成时间(毫秒时间戳字符串) |
### 响应
```json
{
"code": 200,
"message": "上传成功",
"data": "https://qc.corewing.com/report/WL-20260227-001",
"success": true
}
```
- `data` — 测试报告 URL可为 null
---
## 3. 上传照片
上传测试步骤关联的照片。
- **URL**: `POST /api/qc/test/upload-photo`
- **Content-Type**: `multipart/form-data`
### 请求参数
| 字段 | 类型 | 必填 | 说明 |
|--------|---------------|------|------------------|
| testNo | String (text) | 是 | 测试单号 |
| photo | File | 是 | 照片文件 (JPEG等)|
### 响应
```json
{
"code": 200,
"message": "上传成功",
"data": {
"url": "https://qc.corewing.com/photos/xxx.jpg"
},
"success": true
}
```
---
## 4. 验证 SN
验证序列号是否有效(飞控板扫码流程使用)。
- **URL**: `POST /api/qc/test/validate-sn`
- **Content-Type**: `application/json`
### 请求体
```json
{
"sn": "FC-SN-20260001"
}
```
### 响应
```json
{
"code": 200,
"message": "SN 有效",
"data": true,
"success": true
}
```
---
## 5. 获取测试配置
获取指定产品类型的测试参数/阈值。
- **URL**: `GET /api/qc/config/test-params?productType=WIRELESS_BOARD`
### 响应
```json
{
"code": 200,
"success": true,
"data": { }
}
```
> `data` 结构由后端自定义APP 当前未使用。
---
## 6. 查询 SN 历史记录
- **URL**: `GET /api/qc/test/history?sn=AA:BB:CC:DD:EE:FF`
### 响应
```json
{
"code": 200,
"success": true,
"data": { }
}
```
---
## 7. 获取测试报告
- **URL**: `GET /api/qc/test/report?testNo=WL-20260227-001`
### 响应
```json
{
"code": 200,
"success": true,
"data": "https://qc.corewing.com/report/WL-20260227-001"
}
```
---
## 枚举值参考
### productType产品类型
| 值 | 说明 |
|---------------------|--------|
| WIRELESS_BOARD | 无线板 |
| FLIGHT_CONTROLLER | 飞控板 |
### status测试状态
| 值 | 说明 |
|-------------|----------|
| IN_PROGRESS | 进行中 |
| PASS | 通过 |
| FAIL | 失败 |
| UPLOADED | 已上传 |
### result步骤结果
| 值 | 说明 |
|------|------|
| PASS | 通过 |
| FAIL | 失败 |
### 无线板测试步骤7 步)
| stepIndex | stepName |
|-----------|------------------------|
| 1 | BLE连接与特征订阅 |
| 2 | 安装无线板/外观检查 |
| 3 | 供电测试(4.5V) |
| 4 | Type-C USB测试 |
| 5 | BLE信号质量测试 |
| 6 | MAVLink心跳通信测试 |
| 7 | 激活/入库 |
### 飞控板测试步骤12 步)
| stepIndex | stepName |
|-----------|-----------------|
| 1 | USB串口连接 |
| 2 | 安装SD卡与装夹 |
| 3 | 心跳检测 |
| 4 | IMU测试 |
| 5 | 气压计测试 |
| 6 | GPS模块检测 |
| 7 | RC输入测试 |
| 8 | ADC接口测试 |
| 9 | PWM输出测试 |
| 10 | 图传与OSD检查 |
| 11 | 参数重置 |
| 12 | 数据上传/结束 |

116
docs/schema.sql Normal file
View File

@@ -0,0 +1,116 @@
-- ============================================================
-- Corewing QC 后端数据库建表 SQLMySQL
-- ============================================================
CREATE TABLE `flight_controller` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`sn` VARCHAR(64) NOT NULL COMMENT '序列号',
`model` VARCHAR(64) DEFAULT NULL COMMENT '型号',
`batch_no` VARCHAR(64) DEFAULT NULL COMMENT '批次号',
`status` VARCHAR(32) NOT NULL DEFAULT 'REGISTERED' COMMENT '状态: REGISTERED / QC_PASS / QC_FAIL / ACTIVATED',
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
`update_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
UNIQUE KEY `uk_sn` (`sn`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='飞控板设备注册表';
CREATE TABLE `qc_test_record` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_no` VARCHAR(32) NOT NULL COMMENT '测试单号,格式: WL-yyyyMMdd-NNN / FC-yyyyMMdd-NNN',
`product_type` VARCHAR(32) NOT NULL COMMENT '产品类型: WIRELESS_BOARD / FLIGHT_CONTROLLER',
`sn` VARCHAR(64) NOT NULL COMMENT '产品序列号(无线板为 BLE MAC',
`operator_id` VARCHAR(32) NOT NULL COMMENT '测试员 ID',
`operator_name` VARCHAR(64) NOT NULL COMMENT '测试员姓名',
`phone_model` VARCHAR(64) DEFAULT NULL COMMENT '测试手机型号',
`app_version` VARCHAR(16) DEFAULT NULL COMMENT 'APP 版本',
`status` VARCHAR(16) NOT NULL COMMENT '测试结果: PASS / FAIL',
`create_time` DATETIME NOT NULL COMMENT 'APP 端创建时间',
`updated_at` DATETIME DEFAULT NULL COMMENT 'APP 端最后更新时间',
`upload_time` DATETIME DEFAULT NULL COMMENT 'APP 端上传时间',
`report_url` VARCHAR(512) DEFAULT NULL COMMENT '测试报告 URL',
`server_create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '服务端入库时间',
PRIMARY KEY (`id`),
UNIQUE KEY `uk_test_no` (`test_no`),
KEY `idx_sn` (`sn`),
KEY `idx_product_type` (`product_type`),
KEY `idx_status` (`status`),
KEY `idx_create_time` (`create_time`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 测试记录主表';
CREATE TABLE `qc_step_result` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_record_id` BIGINT NOT NULL COMMENT '关联 qc_test_record.id',
`step_index` INT NOT NULL COMMENT '步骤序号(从 1 开始)',
`step_name` VARCHAR(64) NOT NULL COMMENT '步骤名称',
`result` VARCHAR(8) DEFAULT NULL COMMENT '步骤结果: PASS / FAIL / NULL',
`data_json` TEXT DEFAULT NULL COMMENT '步骤详细数据 JSON',
`duration` BIGINT DEFAULT 0 COMMENT '步骤耗时(毫秒)',
`completed_at` DATETIME DEFAULT NULL COMMENT '步骤完成时间',
PRIMARY KEY (`id`),
KEY `idx_test_record_id` (`test_record_id`),
UNIQUE KEY `uk_record_step` (`test_record_id`, `step_index`),
CONSTRAINT `fk_step_record` FOREIGN KEY (`test_record_id`)
REFERENCES `qc_test_record` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 步骤结果表';
CREATE TABLE `qc_photo` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_record_id` BIGINT NOT NULL COMMENT '关联 qc_test_record.id',
`test_no` VARCHAR(32) NOT NULL COMMENT '测试单号',
`url` VARCHAR(512) NOT NULL COMMENT '照片远程 URL',
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
KEY `idx_test_no` (`test_no`),
CONSTRAINT `fk_photo_record` FOREIGN KEY (`test_record_id`)
REFERENCES `qc_test_record` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 测试照片表';
-- ============================================================
-- 固件表
-- ============================================================
CREATE TABLE `app_aat_version` (
`id` BIGINT NOT NULL AUTO_INCREMENT COMMENT '主键ID',
`firmware_type` VARCHAR(50) NOT NULL COMMENT '固件类型: lb_main / lb_signal_master / lbPro_main / lbPro_signal_master / lbPro_screen_ui',
`firmware_name` VARCHAR(100) NOT NULL COMMENT '固件文件名',
`firmware_version` VARCHAR(20) NOT NULL COMMENT '固件版本号',
`min_hardware_version` VARCHAR(20) NOT NULL DEFAULT '0.0' COMMENT '最低硬件版本',
`download_url` VARCHAR(500) DEFAULT NULL COMMENT '固件下载地址',
`firmware_size` BIGINT DEFAULT NULL COMMENT '固件大小(字节)',
`firmware_description` TEXT DEFAULT NULL COMMENT '固件描述',
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
`update_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间',
PRIMARY KEY (`id`),
UNIQUE KEY `uk_type_version` (`firmware_type`, `firmware_version`),
KEY `idx_firmware_type` (`firmware_type`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='AAT固件版本表';
-- 插入固件数据
INSERT INTO `app_aat_version` (`firmware_type`, `firmware_name`, `firmware_version`, `min_hardware_version`)
VALUES
-- lb_main
('lb_main', 'lb_main_2.1.bin', '2.1', '1.0'),
-- lb_signal_master
('lb_signal_master', 'lbsm_1.1.bin', '1.1', '0.0'),
-- lbPro_main
('lbPro_main', 'lbPro_main_2.3.bin', '2.3', '0.0'),
-- lbPro_signal_master
('lbPro_signal_master', 'lbPro_sm_1.4.bin', '1.4', '0.0'),
-- lbPro_screen_ui
('lbPro_screen_ui', 'lbPro_ui_2.7.tft', '2.7', '0.0');
-- ============================================================
-- 示例数据(可选)
-- ============================================================
-- 注册一批无线板
-- INSERT INTO `wireless_board` (`mac`) VALUES
-- ('AA:BB:CC:DD:EE:01'),
-- ('AA:BB:CC:DD:EE:02'),
-- ('AA:BB:CC:DD:EE:03');

View File

@@ -30,6 +30,8 @@ public class SaTokenConfig implements WebMvcConfigurer {
.excludePathPatterns("/user/login", "/user/register", "/user/sendCode", "/user/forgetPassword", "/user/codeLogin")
// 排除后台管理登录接口
.excludePathPatterns("/sys/user/login")
//排除QC接口
.excludePathPatterns("/api/qc/**")
// 排除反馈接口(支持匿名提交)
.excludePathPatterns("/feedback", "/feedback/**")
// 排除教程接口(支持匿名查询)
@@ -38,12 +40,16 @@ public class SaTokenConfig implements WebMvcConfigurer {
.excludePathPatterns("/privacy_policy", "/privacy_policy/**")
// 排除固件查询接口(不需要登录)
.excludePathPatterns("/firmware/**")
// 排除AAT固件版本接口
.excludePathPatterns("/aat_version/**")
// 排除Sirius固件接口
.excludePathPatterns("/sirius_firmware/**")
// 排除公共固件
.excludePathPatterns("/public_firmware/**")
// 排除系统登录页(不需要登录)
// .excludePathPatterns("/loading.html", "/admin/login.html")
// 排除静态资源
.excludePathPatterns("/", "/*.css", "/*.js", "/*.ico", "/static/**", "/assets/**")
.excludePathPatterns("/", "/*.html", "/*.css", "/*.js", "/*.ico", "/static/**", "/assets/**")
// 排除接口静态资源
.excludePathPatterns("/doc.html", "/webjars/**")
.excludePathPatterns("/v3/api-docs/swagger-config", "/v3/api-docs/**", "/swagger-resources")
@@ -59,6 +65,7 @@ public class SaTokenConfig implements WebMvcConfigurer {
.excludePathPatterns("/api/app/access_statistics/accumulate")
.excludePathPatterns("/api/app/resource_category/**")
.excludePathPatterns("/api/app/resource/**")
.excludePathPatterns("/api/app/device/factoryActivation")
// 排除模型接口
.excludePathPatterns("/model/page", "/model/list", "/model/detail/**", "/model/category/**")
// 排除咨询接口

View File

@@ -12,4 +12,11 @@ public class DeviceActivationRequest {
@NotBlank(message = "MAC地址不能为空")
private String mac;
@ApiModelProperty(value = "设备型号", required = true)
@NotBlank(message = "设备型号不能为空")
private String modelId;
@ApiModelProperty(value = "时间戳", required = true)
private String timestamp;
}

View File

@@ -0,0 +1,23 @@
package com.corewing.app.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import javax.validation.constraints.NotNull;
@Data
public class FirmwareVersionRequest {
@ApiModelProperty(value = "型号id", required = true)
@NotNull(message = "型号不能为空")
private Integer modelId;
@ApiModelProperty(value = "版本号", required = true)
@NotNull(message = "版本号不能为空")
private String version;
@ApiModelProperty(value = "固件类型", required = true)
@NotNull(message = "固件类型不能为空")
private Integer firmwareType;
}

View File

@@ -0,0 +1,19 @@
package com.corewing.app.dto;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
@Data
public class SubmitActivityRequest {
@ApiModelProperty("活动id")
private String activityId;
/* 创作平台 */
@ApiModelProperty("创作平台")
private String creationPlatform;
/* 提交内容 */
@ApiModelProperty("提交内容")
private String content;
}

View File

@@ -0,0 +1,19 @@
package com.corewing.app.dto.qc;
import lombok.Data;
@Data
public class StepResultData {
private Integer stepIndex;
private String stepName;
private String result;
private String dataJson;
private Long duration;
private String completedAt;
}

View File

@@ -0,0 +1,35 @@
package com.corewing.app.dto.qc;
import lombok.Data;
import java.util.List;
@Data
public class UploadTestRecordRequest {
private String testNo;
private String productType;
private String sn;
private String operatorId;
private String operatorName;
private String phoneModel;
private String appVersion;
private String status;
private String createTime;
private String updatedAt;
private String uploadTime;
private List<StepResultData> steps;
private List<String> photoUrls;
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.dto.qc;
import lombok.Data;
@Data
public class ValidateSnRequest {
private String sn;
}

View File

@@ -0,0 +1,8 @@
package com.corewing.app.dto.qc;
import lombok.Data;
@Data
public class ValidateWirelessBoardRequest {
private String mac;
}

View File

@@ -0,0 +1,74 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
* AAT固件版本实体类
*/
@Data
@TableName("app_aat_version")
public class AatVersion implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键ID
*/
@TableId(value = "id", type = IdType.AUTO)
private Long id;
/**
* 固件类型: lb_main / lb_signal_master / lbPro_main / lbPro_signal_master / lbPro_screen_ui
*/
private String firmwareType;
/**
* 固件文件名
*/
private String firmwareName;
/**
* 固件版本号
*/
private String firmwareVersion;
/**
* 最低硬件版本
*/
private String minHardwareVersion;
/**
* 固件下载地址
*/
private String downloadUrl;
/**
* 固件大小(字节)
*/
private Long firmwareSize;
/**
* 固件描述
*/
private String firmwareDescription;
/**
* 创建时间
*/
@TableField(fill = FieldFill.INSERT)
private LocalDateTime createTime;
/**
* 更新时间
*/
@TableField(fill = FieldFill.INSERT_UPDATE)
private LocalDateTime updateTime;
}

View File

@@ -0,0 +1,71 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.corewing.app.common.base.CommonEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.Date;
/**
* 活动
*/
@EqualsAndHashCode(callSuper = true)
@Data
@TableName("biz_activity")
public class BizActivity extends CommonEntity {
/* id */
@TableId
private String id;
/* 活动图 */
private String thumbnail;
/* 活动标题 */
private String title;
/* 活动描述 */
private String description;
/* 活动分类 */
private String category;
/* 活动平台 */
private String platformCategory;
/* 活动人数 */
private Integer participationCount;
/* 当前参与人数 */
private Integer currentCount;
/* 活动详情 */
private String content;
/* 活动开始时间 */
private Date startTime;
/* 活动结束时间 */
private Date endTime;
/* 活动状态 */
private String status;
/* 是否开启活动参与人员审核 */
private String personnelReview;
/* 活动排序 */
private Integer sortCode;
/* 备注 */
private String remark;
/* 扩展 */
private String extJson;
}

View File

@@ -0,0 +1,53 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.corewing.app.common.base.CommonEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.Date;
@EqualsAndHashCode(callSuper = true)
@Data
@TableName("biz_activity_lottery")
public class BizActivityLottery extends CommonEntity {
/* id */
@TableId
private String id;
/* 活动id */
private String activityId;
/* 分类 */
private String category;
/* 用户名 */
private String userName;
/* 用户id */
private Long userId;
/* 状态 */
private String status;
/* 提交内容 */
private String content;
/* 审核时间 */
private Date reviewTime;
/* 创作平台 */
private String creationPlatform;
/* 备注 */
private String remark;
/* 排序 */
private Integer sortCode;
/* 扩展字段 */
private String extJson;
}

View File

@@ -11,6 +11,7 @@ import lombok.EqualsAndHashCode;
* 设备表
*/
@EqualsAndHashCode(callSuper = true)
@Data
@TableName("biz_device")
public class BizDevice extends CommonEntity {
@@ -28,6 +29,9 @@ public class BizDevice extends CommonEntity {
@ApiModelProperty("公布状态")
private String publicStatus;
@ApiModelProperty("型号")
private String categoryId;
@ApiModelProperty("排序")
private int sortCode;

View File

@@ -22,6 +22,9 @@ public class BizDeviceCategory extends CommonEntity {
@ApiModelProperty("设备型号缩略图")
private String thumbnail;
@ApiModelProperty("型号id")
private Integer modelId;
@ApiModelProperty("设备型号名称")
private String categoryName;

View File

@@ -45,6 +45,21 @@ public class Firmware implements Serializable {
*/
private Integer firmwareType;
/**
* 模型id
*/
private String modelId;
/**
* 版本校验id
*/
private Integer versionId;
/**
* 版本号
*/
private String version;
/**
* 固件下载地址
*/

View File

@@ -0,0 +1,28 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
@Data
@TableName("flight_controller")
public class FlightController {
@TableId(type = IdType.AUTO)
private Long id;
private String sn;
private String model;
private String batchNo;
private String status;
private LocalDateTime createTime;
private LocalDateTime updateTime;
}

View File

@@ -0,0 +1,24 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
@Data
@TableName("qc_photo")
public class QcPhoto {
@TableId(type = IdType.AUTO)
private Long id;
private Long testRecordId;
private String testNo;
private String url;
private LocalDateTime createTime;
}

View File

@@ -0,0 +1,30 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
@Data
@TableName("qc_step_result")
public class QcStepResult {
@TableId(type = IdType.AUTO)
private Long id;
private Long testRecordId;
private Integer stepIndex;
private String stepName;
private String result;
private String dataJson;
private Long duration;
private LocalDateTime completedAt;
}

View File

@@ -0,0 +1,42 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.time.LocalDateTime;
@Data
@TableName("qc_test_record")
public class QcTestRecord {
@TableId(type = IdType.AUTO)
private Long id;
private String testNo;
private String productType;
private String sn;
private String operatorId;
private String operatorName;
private String phoneModel;
private String appVersion;
private String status;
private LocalDateTime createTime;
private LocalDateTime updatedAt;
private LocalDateTime uploadTime;
private String reportUrl;
private LocalDateTime serverCreateTime;
}

View File

@@ -0,0 +1,79 @@
package com.corewing.app.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
import java.time.LocalDateTime;
/**
* Sirius固件信息实体类
*/
@Data
@TableName("app_sirius_firmware")
public class SiriusFirmware implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 主键ID
*/
@TableId(value = "id", type = IdType.AUTO)
private Integer id;
/**
* 固件类型1-高频头2-接收机3-背包
*/
private Integer firmwareType;
/**
* 协议类型1-ELRS2-CWLink
*/
private Integer protocolType;
/**
* 版本号v3.0.1
*/
private String versionNumber;
/**
* 文件名
*/
private String fileName;
/**
* 文件存储路径
*/
private String filePath;
/**
* 文件大小(字节)
*/
private Long fileSize;
/**
* MD5校验值
*/
private String md5Hash;
/**
* 版本更新说明
*/
private String releaseNotes;
/**
* 创建时间
*/
@TableField(fill = FieldFill.INSERT)
private LocalDateTime createTime;
/**
* 更新时间
*/
@TableField(fill = FieldFill.INSERT_UPDATE)
private LocalDateTime updateTime;
}

View File

@@ -57,6 +57,11 @@ public class CustomMetaObjectHandler implements MetaObjectHandler {
// 兼容 Date 和 LocalDateTime 类型的 createTime 填充
fillTimeField(metaObject, CREATE_TIME);
} catch (ReflectionException ignored) { }
try {
// 兼容 Date 和 LocalDateTime 类型的 updateTime 填充
fillTimeField(metaObject, UPDATE_TIME);
} catch (ReflectionException ignored) { }
}
@Override

View File

@@ -5,10 +5,16 @@ import com.corewing.app.common.Result;
import com.corewing.app.util.I18nUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpStatus;
import org.springframework.validation.FieldError;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import javax.validation.ConstraintViolation;
import javax.validation.ConstraintViolationException;
import java.util.stream.Collectors;
/**
* 全局异常处理器
*/
@@ -46,14 +52,39 @@ public class GlobalExceptionHandler {
return Result.error(HttpStatus.UNAUTHORIZED.value(), message);
}
/**
* 处理 @Valid 参数校验异常RequestBody 参数)
*/
@ExceptionHandler(MethodArgumentNotValidException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
public Result<String> handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
// 获取第一个错误信息
String errorMessage = e.getBindingResult().getFieldErrors().stream()
.map(FieldError::getDefaultMessage)
.collect(Collectors.joining("; "));
return Result.error(HttpStatus.BAD_REQUEST.value(), errorMessage);
}
/**
* 处理 @Validated 参数校验异常RequestParam/PathVariable 参数)
*/
@ExceptionHandler(ConstraintViolationException.class)
@ResponseStatus(HttpStatus.BAD_REQUEST)
public Result<String> handleConstraintViolationException(ConstraintViolationException e) {
// 获取第一个错误信息
String errorMessage = e.getConstraintViolations().stream()
.map(ConstraintViolation::getMessage)
.collect(Collectors.joining("; "));
return Result.error(HttpStatus.BAD_REQUEST.value(), errorMessage);
}
/**
* 处理其他异常
*/
@ExceptionHandler(Exception.class)
// @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
public Result<String> handleException(Exception e) {
log.error(e.getMessage());
log.error("系统异常: ", e);
return Result.error(HttpStatus.INTERNAL_SERVER_ERROR.value(),
e.getMessage());
I18nUtil.getMessage("error.system"));
}
}

View File

@@ -0,0 +1,13 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.AatVersion;
import org.apache.ibatis.annotations.Mapper;
/**
* AAT固件版本 Mapper 接口
*/
@Mapper
public interface AatVersionMapper extends BaseMapper<AatVersion> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.BizActivityLottery;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface BizActivityLotteryMapper extends BaseMapper<BizActivityLottery> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.BizActivity;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface BizActivityMapper extends BaseMapper<BizActivity> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.FlightController;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface FlightControllerMapper extends BaseMapper<FlightController> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.QcPhoto;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface QcPhotoMapper extends BaseMapper<QcPhoto> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.QcStepResult;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface QcStepResultMapper extends BaseMapper<QcStepResult> {
}

View File

@@ -0,0 +1,9 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.QcTestRecord;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface QcTestRecordMapper extends BaseMapper<QcTestRecord> {
}

View File

@@ -0,0 +1,13 @@
package com.corewing.app.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.corewing.app.entity.SiriusFirmware;
import org.apache.ibatis.annotations.Mapper;
/**
* Sirius固件信息 Mapper 接口
*/
@Mapper
public interface SiriusFirmwareMapper extends BaseMapper<SiriusFirmware> {
}

View File

@@ -0,0 +1,186 @@
package com.corewing.app.modules.app;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.corewing.app.common.Result;
import com.corewing.app.common.annotation.CommonLog;
import com.corewing.app.entity.AatVersion;
import com.corewing.app.service.AatVersionService;
import com.corewing.app.util.I18nUtil;
import com.corewing.app.util.OSSUploadUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.io.IOException;
import java.util.List;
import java.util.Map;
/**
* AAT固件版本 Controller
*/
@Api(tags = "AAT固件版本接口")
@RestController
@RequestMapping("/aat_version")
public class AppAatVersionController {
private final AatVersionService aatVersionService;
public AppAatVersionController(AatVersionService aatVersionService) {
this.aatVersionService = aatVersionService;
}
/**
* 查询所有类型的最新固件版本返回与原始JSON结构一致
*/
@CommonLog("查询所有AAT最新固件版本")
@ApiOperation("查询所有AAT最新固件版本")
@GetMapping("/latest")
public Result<Map<String, Object>> getAllLatestVersions() {
return Result.success(aatVersionService.getAllLatestVersions());
}
/**
* 根据固件类型查询最新版本
*/
@CommonLog("根据类型查询AAT最新固件版本")
@ApiOperation("根据类型查询AAT最新固件版本")
@GetMapping("/latest/{firmwareType}")
public Result<AatVersion> getLatestByType(@PathVariable String firmwareType) {
AatVersion version = aatVersionService.getLatestByType(firmwareType);
if (version != null) {
return Result.success(version);
}
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
/**
* 根据固件类型查询版本列表
*/
@CommonLog("根据类型查询AAT固件版本列表")
@ApiOperation("根据类型查询AAT固件版本列表")
@GetMapping("/type/{firmwareType}")
public Result<List<AatVersion>> listByType(@PathVariable String firmwareType) {
QueryWrapper<AatVersion> wrapper = new QueryWrapper<>();
wrapper.eq("firmware_type", firmwareType);
wrapper.orderByDesc("create_time");
return Result.success(aatVersionService.list(wrapper));
}
/**
* 分页查询固件版本列表
*/
@CommonLog("分页查询AAT固件版本列表")
@ApiOperation("分页查询AAT固件版本列表")
@GetMapping("/page")
public Result<IPage<AatVersion>> page(
@RequestParam(defaultValue = "1") Long current,
@RequestParam(defaultValue = "10") Long size,
@RequestParam(required = false) String firmwareType,
@RequestParam(required = false) String firmwareName) {
Page<AatVersion> page = new Page<>(current, size);
QueryWrapper<AatVersion> wrapper = new QueryWrapper<>();
if (StringUtils.hasText(firmwareType)) {
wrapper.eq("firmware_type", firmwareType);
}
if (StringUtils.hasText(firmwareName)) {
wrapper.like("firmware_name", firmwareName);
}
wrapper.orderByDesc("create_time");
return Result.success(aatVersionService.page(page, wrapper));
}
/**
* 查询所有固件版本
*/
@CommonLog("查询所有AAT固件版本")
@ApiOperation("查询所有AAT固件版本")
@GetMapping("/list")
public Result<List<AatVersion>> list() {
return Result.success(aatVersionService.list());
}
/**
* 根据ID查询固件版本
*/
@CommonLog("根据ID查询AAT固件版本")
@ApiOperation("根据ID查询AAT固件版本")
@GetMapping("/{id}")
public Result<AatVersion> getById(@PathVariable Long id) {
AatVersion version = aatVersionService.getById(id);
if (version != null) {
return Result.success(version);
}
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
/**
* 新增固件版本
*/
@CommonLog("新增AAT固件版本")
@ApiOperation("新增AAT固件版本")
@PostMapping
public Result<AatVersion> add(@RequestBody AatVersion aatVersion) {
boolean saved = aatVersionService.save(aatVersion);
return saved ? Result.success(aatVersion) : Result.error();
}
/**
* 修改固件版本
*/
@CommonLog("修改AAT固件版本")
@ApiOperation("修改AAT固件版本")
@PutMapping
public Result<Void> update(@RequestBody AatVersion aatVersion) {
return Result.isBool(aatVersionService.updateById(aatVersion));
}
/**
* 删除固件版本
*/
@CommonLog("删除AAT固件版本")
@ApiOperation("删除AAT固件版本")
@DeleteMapping("/{id}")
public Result<Void> delete(@PathVariable Long id) {
AatVersion version = aatVersionService.getById(id);
if (version == null) {
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
// 删除OSS上的文件
if (StringUtils.hasText(version.getDownloadUrl())) {
String objectName = version.getDownloadUrl().replace("https://oss.corewing.com/", "");
OSSUploadUtil.deleteFile(objectName);
}
return Result.isBool(aatVersionService.removeById(id));
}
/**
* 上传固件文件
*/
@CommonLog("上传AAT固件文件")
@ApiOperation("上传AAT固件文件")
@PostMapping("/upload/{id}")
public Result<AatVersion> upload(@PathVariable Long id, @RequestParam("file") MultipartFile file) {
AatVersion version = aatVersionService.getById(id);
if (version == null) {
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
try {
String objectName = "aat_firmware/" + file.getOriginalFilename();
String downloadUrl = OSSUploadUtil.uploadFile(file.getInputStream(), objectName);
version.setDownloadUrl(downloadUrl);
version.setFirmwareSize(file.getSize());
version.setFirmwareName(file.getOriginalFilename());
aatVersionService.updateById(version);
return Result.success(version);
} catch (IOException e) {
return Result.error("上传失败: " + e.getMessage());
}
}
}

View File

@@ -0,0 +1,40 @@
package com.corewing.app.modules.app;
import com.corewing.app.common.Result;
import com.corewing.app.dto.SubmitActivityRequest;
import com.corewing.app.service.BizActivityLotteryService;
import io.swagger.annotations.Api;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
@Api(tags = "活动控制")
@Controller
@RequestMapping("/api/app/activity")
public class AppActivityController {
@Resource
private BizActivityLotteryService bizActivityLotteryService;
/**
* 活动参与地址
* @param activityId
* @return
*/
@GetMapping("/eventVenue/{activityId}")
public String eventVenue(@PathVariable String activityId) {
return "/activity/eventVenue";
}
/**
* 提交活动
* @return
*/
@PostMapping("/submitActivity")
@ResponseBody
public Result<String> submitActivity(SubmitActivityRequest submitActivityRequest) {
return Result.isBool(bizActivityLotteryService.submitActivity(submitActivityRequest));
}
}

View File

@@ -31,5 +31,12 @@ public class AppDeviceController {
return Result.success(activationService.activation(deviceActivationRequest));
}
@CommonLog("工厂激活设备")
@ApiOperation("工厂激活设备")
@PostMapping("factoryActivation")
public Result<Boolean> factoryActivation(@RequestBody DeviceActivationRequest deviceActivationRequest) {
return Result.success(activationService.factoryActivation(deviceActivationRequest));
}
}

View File

@@ -1,31 +1,41 @@
package com.corewing.app.modules.app;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.corewing.app.common.Result;
import com.corewing.app.common.annotation.CommonLog;
import com.corewing.app.dto.FirmwareVersionRequest;
import com.corewing.app.entity.BizDeviceCategory;
import com.corewing.app.entity.Firmware;
import com.corewing.app.service.BizDeviceCategoryService;
import com.corewing.app.service.FirmwareService;
import com.corewing.app.util.I18nUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.util.StringUtils;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import javax.validation.Valid;
import java.util.List;
/**
* 固件 Controller
*/
@Api(tags = "固件接口")
@RestController
@RequestMapping("/firmware")
@Validated
public class AppFirmwareController {
private final FirmwareService firmwareService;
@Resource
private FirmwareService firmwareService;
public AppFirmwareController(FirmwareService firmwareService) {
this.firmwareService = firmwareService;
}
@Resource
private BizDeviceCategoryService bizDeviceCategoryService;
/**
* 根据ID查询固件
@@ -84,20 +94,20 @@ public class AppFirmwareController {
@CommonLog("查询所有固件集合")
@ApiOperation("查询所有固件集合")
@GetMapping("/list")
public Result<java.util.List<Firmware>> list() {
java.util.List<Firmware> list = firmwareService.list();
public Result<List<Firmware>> list() {
List<Firmware> list = firmwareService.list();
return Result.success(list);
}
/**
* 根据类型查询固件版本
* 根据类型查询固件版本 【兼容旧版APP】
*
* @param firmwareType 固件类型
*/
@CommonLog("根据类型查询固件版本")
@ApiOperation("根据类型查询固件版本")
@GetMapping("/type/{firmwareType}")
public Result<java.util.List<Firmware>> listByType(@PathVariable Integer firmwareType) {
public Result<List<Firmware>> listByType(@PathVariable Integer firmwareType) {
if (firmwareType == null) {
return Result.error(I18nUtil.getMessage("firmware.type.required"));
}
@@ -107,7 +117,49 @@ public class AppFirmwareController {
// 按版本号或创建时间倒序排列,最新版本在前
wrapper.orderByDesc("create_time");
java.util.List<Firmware> list = firmwareService.list(wrapper);
List<Firmware> list = firmwareService.list(wrapper);
return Result.success(list);
}
/**
* 根据类型查询固件版本 【兼容新版APP】
*
* @param firmwareType 固件类型
*/
@CommonLog("根据类型,型号,当前版本查询固件版本")
@ApiOperation("根据类型,当前版本查询固件版本")
@GetMapping("/type/{firmwareType}/{modelId}/{softwareVersion}")
public Result<List<Firmware>> listByType(@PathVariable Integer firmwareType, @PathVariable Integer modelId, @PathVariable Integer softwareVersion) {
if (firmwareType == null && modelId == null) {
return Result.error(I18nUtil.getMessage("firmware.type.or.model.required"));
}
LambdaQueryWrapper<BizDeviceCategory> categoryQueryWrapper = new LambdaQueryWrapper<>();
categoryQueryWrapper.eq(BizDeviceCategory::getModelId, modelId);
BizDeviceCategory bizDeviceCategory = bizDeviceCategoryService.getOne(categoryQueryWrapper);
if(bizDeviceCategory == null) {
return Result.error(I18nUtil.getMessage("firmware.device.not.found"));
}
LambdaQueryWrapper<Firmware> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(Firmware::getFirmwareType, firmwareType);
wrapper.eq(Firmware::getModelId, bizDeviceCategory.getId());
wrapper.ge(Firmware::getVersionId, softwareVersion);
// 按版本号或创建时间倒序排列,最新版本在前
wrapper.orderByDesc(Firmware::getCreateTime);
List<Firmware> list = firmwareService.list(wrapper);
return Result.success(list);
}
/**
* 校验是否存在新固件
* @return
*/
@CommonLog("校验是否存在新固件")
@ApiOperation("校验是否存在新固件")
@PostMapping("/checkVersion")
public Result<Firmware> checkVersion(@RequestBody @Valid FirmwareVersionRequest firmwareVersionRequest) {
return Result.success(firmwareService.checkVersion(firmwareVersionRequest));
}
}

View File

@@ -0,0 +1,97 @@
package com.corewing.app.modules.app;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.corewing.app.common.Result;
import com.corewing.app.common.annotation.CommonLog;
import com.corewing.app.entity.SiriusFirmware;
import com.corewing.app.service.SiriusFirmwareService;
import com.corewing.app.util.I18nUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* Sirius固件信息 Controller
*/
@Api(tags = "Sirius固件信息接口")
@RestController
@RequestMapping("/sirius_firmware")
public class AppSiriusFirmwareController {
private final SiriusFirmwareService siriusFirmwareService;
public AppSiriusFirmwareController(SiriusFirmwareService siriusFirmwareService) {
this.siriusFirmwareService = siriusFirmwareService;
}
/**
* 根据固件类型和协议类型查询最新版本
*/
@CommonLog("查询Sirius最新固件版本")
@ApiOperation("根据固件类型和协议类型查询最新版本")
@GetMapping("/latest")
public Result<SiriusFirmware> getLatest(
@RequestParam Integer firmwareType,
@RequestParam Integer protocolType) {
SiriusFirmware firmware = siriusFirmwareService.getLatestByTypeAndProtocol(firmwareType, protocolType);
if (firmware != null) {
return Result.success(firmware);
}
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
/**
* 根据固件类型查询版本列表
*/
@CommonLog("根据类型查询Sirius固件版本列表")
@ApiOperation("根据固件类型查询版本列表")
@GetMapping("/type/{firmwareType}")
public Result<List<SiriusFirmware>> listByType(@PathVariable Integer firmwareType) {
QueryWrapper<SiriusFirmware> wrapper = new QueryWrapper<>();
wrapper.eq("firmware_type", firmwareType);
wrapper.orderByDesc("create_time");
return Result.success(siriusFirmwareService.list(wrapper));
}
/**
* 根据固件类型和协议类型查询版本列表
*/
@CommonLog("根据类型和协议查询Sirius固件版本列表")
@ApiOperation("根据固件类型和协议类型查询版本列表")
@GetMapping("/type/{firmwareType}/protocol/{protocolType}")
public Result<List<SiriusFirmware>> listByTypeAndProtocol(
@PathVariable Integer firmwareType,
@PathVariable Integer protocolType) {
QueryWrapper<SiriusFirmware> wrapper = new QueryWrapper<>();
wrapper.eq("firmware_type", firmwareType);
wrapper.eq("protocol_type", protocolType);
wrapper.orderByDesc("create_time");
return Result.success(siriusFirmwareService.list(wrapper));
}
/**
* 查询所有固件
*/
@CommonLog("查询所有Sirius固件")
@ApiOperation("查询所有固件")
@GetMapping("/list")
public Result<List<SiriusFirmware>> list() {
return Result.success(siriusFirmwareService.list());
}
/**
* 根据ID查询固件
*/
@CommonLog("根据ID查询Sirius固件")
@ApiOperation("根据ID查询固件")
@GetMapping("/{id}")
public Result<SiriusFirmware> getById(@PathVariable Integer id) {
SiriusFirmware firmware = siriusFirmwareService.getById(id);
if (firmware != null) {
return Result.success(firmware);
}
return Result.error(I18nUtil.getMessage("firmware.not.found"));
}
}

View File

@@ -0,0 +1,27 @@
package com.corewing.app.modules.qc;
import com.corewing.app.common.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.Map;
@Api(tags = "QC配置")
@RestController
@RequestMapping("/api/qc/config")
public class QcConfigController {
@ApiOperation("获取测试配置")
@GetMapping("/test-params")
public Result<Map<String, Object>> getTestParams(@RequestParam("productType") String productType) {
Map<String, Object> params = new HashMap<>();
// 后续可根据 productType 返回不同的测试参数/阈值
params.put("productType", productType);
return Result.success(params);
}
}

View File

@@ -0,0 +1,57 @@
package com.corewing.app.modules.qc;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.UploadTestRecordRequest;
import com.corewing.app.dto.qc.ValidateSnRequest;
import com.corewing.app.entity.QcTestRecord;
import com.corewing.app.service.QcTestService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
import java.util.Map;
@Api(tags = "QC测试")
@RestController
@RequestMapping("/api/qc/test")
public class QcTestController {
private final QcTestService qcTestService;
public QcTestController(QcTestService qcTestService) {
this.qcTestService = qcTestService;
}
@ApiOperation("上传测试记录")
@PostMapping("/upload")
public Result<String> uploadTestRecord(@RequestBody UploadTestRecordRequest request) {
return qcTestService.uploadTestRecord(request);
}
@ApiOperation("上传照片")
@PostMapping("/upload-photo")
public Result<Map<String, String>> uploadPhoto(@RequestParam("testNo") String testNo,
@RequestParam("photo") MultipartFile photo) {
return qcTestService.uploadPhoto(testNo, photo);
}
@ApiOperation("验证SN")
@PostMapping("/validate-sn")
public Result<Boolean> validateSn(@RequestBody ValidateSnRequest request) {
return qcTestService.validateSn(request);
}
@ApiOperation("查询SN历史记录")
@GetMapping("/history")
public Result<List<QcTestRecord>> getHistory(@RequestParam("sn") String sn) {
return qcTestService.getHistory(sn);
}
@ApiOperation("获取测试报告")
@GetMapping("/report")
public Result<String> getReport(@RequestParam("testNo") String testNo) {
return qcTestService.getReport(testNo);
}
}

View File

@@ -0,0 +1,29 @@
package com.corewing.app.modules.qc;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.ValidateWirelessBoardRequest;
import com.corewing.app.service.BizDeviceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@Api(tags = "无线版QC")
@RestController
@RequestMapping("/api/qc/wireless")
public class WirelessBoardController {
private final BizDeviceService bizDeviceService;
public WirelessBoardController(BizDeviceService bizDeviceService) {
this.bizDeviceService = bizDeviceService;
}
@ApiOperation("验证已经激活的无线板")
@PostMapping("/validate-wireless")
public Result<Boolean> validateWirelessBoard(@RequestBody ValidateWirelessBoardRequest validateWirelessBoardRequest) {
return bizDeviceService.validateWirelessBoard(validateWirelessBoardRequest);
}
}

View File

@@ -0,0 +1,28 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.entity.AatVersion;
import java.util.List;
import java.util.Map;
/**
* AAT固件版本 Service 接口
*/
public interface AatVersionService extends IService<AatVersion> {
/**
* 根据固件类型查询最新版本
*
* @param firmwareType 固件类型
* @return 最新固件版本
*/
AatVersion getLatestByType(String firmwareType);
/**
* 查询所有类型的最新固件版本返回与原始JSON结构一致的格式
*
* @return 所有类型的最新版本映射
*/
Map<String, Object> getAllLatestVersions();
}

View File

@@ -0,0 +1,11 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.dto.SubmitActivityRequest;
import com.corewing.app.entity.BizActivityLottery;
public interface BizActivityLotteryService extends IService<BizActivityLottery> {
Boolean submitActivity(SubmitActivityRequest submitActivityRequest);
}

View File

@@ -0,0 +1,7 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.entity.BizActivity;
public interface BizActivityService extends IService<BizActivity> {
}

View File

@@ -6,4 +6,6 @@ import com.corewing.app.entity.BizDeviceActivation;
public interface BizDeviceActivationService extends IService<BizDeviceActivation> {
Boolean activation(DeviceActivationRequest deviceActivationRequest);
Boolean factoryActivation(DeviceActivationRequest deviceActivationRequest);
}

View File

@@ -1,7 +1,10 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.ValidateWirelessBoardRequest;
import com.corewing.app.entity.BizDevice;
public interface BizDeviceService extends IService<BizDevice> {
Result<Boolean> validateWirelessBoard(ValidateWirelessBoardRequest validateWirelessBoardRequest);
}

View File

@@ -3,6 +3,7 @@ package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.common.Result;
import com.corewing.app.dto.FirmwareVersionRequest;
import com.corewing.app.entity.Firmware;
import org.springframework.web.multipart.MultipartFile;
@@ -40,4 +41,11 @@ public interface FirmwareService extends IService<Firmware> {
* @return
*/
boolean removeData(Long id);
/**
* 校验固件是否有新固件
* @param firmwareVersionRequest
* @return
*/
Firmware checkVersion(FirmwareVersionRequest firmwareVersionRequest);
}

View File

@@ -0,0 +1,24 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.UploadTestRecordRequest;
import com.corewing.app.dto.qc.ValidateSnRequest;
import com.corewing.app.entity.QcTestRecord;
import org.springframework.web.multipart.MultipartFile;
import java.util.List;
import java.util.Map;
public interface QcTestService extends IService<QcTestRecord> {
Result<String> uploadTestRecord(UploadTestRecordRequest request);
Result<Map<String, String>> uploadPhoto(String testNo, MultipartFile photo);
Result<Boolean> validateSn(ValidateSnRequest request);
Result<List<QcTestRecord>> getHistory(String sn);
Result<String> getReport(String testNo);
}

View File

@@ -0,0 +1,19 @@
package com.corewing.app.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.corewing.app.entity.SiriusFirmware;
/**
* Sirius固件信息 Service 接口
*/
public interface SiriusFirmwareService extends IService<SiriusFirmware> {
/**
* 根据固件类型和协议类型查询最新版本
*
* @param firmwareType 固件类型
* @param protocolType 协议类型
* @return 最新固件版本
*/
SiriusFirmware getLatestByTypeAndProtocol(Integer firmwareType, Integer protocolType);
}

View File

@@ -0,0 +1,55 @@
package com.corewing.app.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.entity.AatVersion;
import com.corewing.app.mapper.AatVersionMapper;
import com.corewing.app.service.AatVersionService;
import org.springframework.stereotype.Service;
import java.util.*;
import java.util.stream.Collectors;
/**
* AAT固件版本 Service 实现类
*/
@Service
public class AatVersionServiceImpl extends ServiceImpl<AatVersionMapper, AatVersion> implements AatVersionService {
@Override
public AatVersion getLatestByType(String firmwareType) {
LambdaQueryWrapper<AatVersion> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(AatVersion::getFirmwareType, firmwareType);
wrapper.orderByDesc(AatVersion::getCreateTime);
wrapper.last("LIMIT 1");
return getOne(wrapper);
}
@Override
public Map<String, Object> getAllLatestVersions() {
// 查询所有固件,按类型分组,每组取最新的一条
List<AatVersion> allVersions = list(
new LambdaQueryWrapper<AatVersion>().orderByDesc(AatVersion::getCreateTime)
);
Map<String, Object> result = new LinkedHashMap<>();
Map<String, List<AatVersion>> grouped = allVersions.stream()
.collect(Collectors.groupingBy(AatVersion::getFirmwareType, LinkedHashMap::new, Collectors.toList()));
for (Map.Entry<String, List<AatVersion>> entry : grouped.entrySet()) {
Map<String, Object> typeInfo = new HashMap<>();
List<Map<String, String>> firmwares = new ArrayList<>();
// 取该类型下最新的一条
AatVersion latest = entry.getValue().get(0);
Map<String, String> firmwareInfo = new HashMap<>();
firmwareInfo.put("firmware_name", latest.getFirmwareName());
firmwareInfo.put("firmware_version", latest.getFirmwareVersion());
firmwareInfo.put("min_hardware_version", latest.getMinHardwareVersion());
firmwares.add(firmwareInfo);
typeInfo.put("firmwares", firmwares);
result.put(entry.getKey(), typeInfo);
}
return result;
}
}

View File

@@ -0,0 +1,62 @@
package com.corewing.app.service.impl;
import cn.dev33.satoken.stp.StpUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.dto.SubmitActivityRequest;
import com.corewing.app.entity.BizActivity;
import com.corewing.app.entity.BizActivityLottery;
import com.corewing.app.mapper.BizActivityLotteryMapper;
import com.corewing.app.service.BizActivityLotteryService;
import com.corewing.app.service.BizActivityService;
import com.corewing.app.util.DateUtils;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Date;
import java.util.Objects;
@Service
public class BizActivityLotteryServiceImpl extends ServiceImpl<BizActivityLotteryMapper, BizActivityLottery> implements BizActivityLotteryService {
@Resource
private BizActivityService bizActivityService;
@Override
public Boolean submitActivity(SubmitActivityRequest submitActivityRequest) {
Long userid = StpUtil.getLoginIdAsLong();
BizActivity activity = bizActivityService.getById(submitActivityRequest.getActivityId());
if(activity == null) {
throw new RuntimeException("该活动不存在");
}
// 验证活动是否在有效期内
if(activity.getStartTime() != null && activity.getEndTime() != null) {
if(!DateUtils.isBefore(activity.getStartTime())) {
throw new RuntimeException("活动还未开始");
}
if(!DateUtils.isAfter(activity.getEndTime())) {
throw new RuntimeException("活动已过期");
}
}
// 校验是否参与
LambdaQueryWrapper<BizActivityLottery> checkLotteryWrapper = new LambdaQueryWrapper<>();
checkLotteryWrapper.eq(BizActivityLottery::getUserId, userid);
checkLotteryWrapper.eq(BizActivityLottery::getActivityId, submitActivityRequest.getActivityId());
if(count(checkLotteryWrapper) > 0) {
throw new RuntimeException("该活动你已经参与");
}
BizActivityLottery bizActivityLottery = new BizActivityLottery();
bizActivityLottery.setActivityId(submitActivityRequest.getActivityId());
return null;
}
}

View File

@@ -0,0 +1,11 @@
package com.corewing.app.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.entity.BizActivity;
import com.corewing.app.mapper.BizActivityMapper;
import com.corewing.app.service.BizActivityService;
import org.springframework.stereotype.Service;
@Service
public class BizActivityServiceImpl extends ServiceImpl<BizActivityMapper, BizActivity> implements BizActivityService {
}

View File

@@ -2,17 +2,19 @@ package com.corewing.app.service.impl;
import cn.dev33.satoken.stp.StpUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.dto.DeviceActivationRequest;
import com.corewing.app.entity.BizDevice;
import com.corewing.app.entity.BizDeviceActivation;
import com.corewing.app.entity.BizDeviceCategory;
import com.corewing.app.mapper.BizDeviceActivationMapper;
import com.corewing.app.service.BizDeviceActivationService;
import com.corewing.app.service.BizDeviceCategoryService;
import com.corewing.app.service.BizDeviceService;
import com.corewing.app.util.CommonServletUtil;
import com.corewing.app.util.IpUtil;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource;
import java.util.Date;
@@ -24,15 +26,18 @@ public class BizDeviceActivationServiceImpl extends ServiceImpl<BizDeviceActivat
@Resource
private BizDeviceService deviceService;
@Resource
private BizDeviceCategoryService categoryService;
@Override
public Boolean activation(DeviceActivationRequest deviceActivationRequest) {
Object loginId = StpUtil.getLoginId();
LambdaQueryWrapper<BizDeviceActivation> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(BizDeviceActivation::getDeviceMac, deviceActivationRequest.getMac());
BizDeviceActivation checkDeviceActivation = getOne(wrapper);
if(checkDeviceActivation != null) {
if (checkDeviceActivation != null) {
// 该用户已经激活过该设备
if(checkDeviceActivation.getUserId().equals(loginId)) {
if (checkDeviceActivation.getUserId().equals(loginId)) {
return true;
}
return updateById(checkDeviceActivation);
@@ -42,7 +47,7 @@ public class BizDeviceActivationServiceImpl extends ServiceImpl<BizDeviceActivat
LambdaQueryWrapper<BizDevice> checkDeviceWrapper = new LambdaQueryWrapper<>();
checkDeviceWrapper.eq(BizDevice::getDeviceMac, deviceActivationRequest.getMac());
List<BizDevice> list = deviceService.list(checkDeviceWrapper);
if(list.isEmpty()) {
if (list.isEmpty()) {
throw new RuntimeException("该设备不是酷翼官方产品");
}
@@ -57,4 +62,36 @@ public class BizDeviceActivationServiceImpl extends ServiceImpl<BizDeviceActivat
deviceActivation.setDeviceId(bizDevice.getId());
return this.saveOrUpdate(deviceActivation);
}
@Transactional(rollbackFor = Exception.class)
@Override
public Boolean factoryActivation(DeviceActivationRequest deviceActivationRequest) {
BizDeviceActivation checkDeviceActivation = getBizDeviceActivationByMac(deviceActivationRequest.getMac());
if (checkDeviceActivation != null) {
return false;
}
LambdaQueryWrapper<BizDeviceCategory> findWrapper = new LambdaQueryWrapper<>();
findWrapper.eq(BizDeviceCategory::getModelId, deviceActivationRequest.getModelId());
BizDeviceCategory deviceCategory = categoryService.getOne(findWrapper);
BizDevice device = new BizDevice();
device.setDeviceMac(deviceActivationRequest.getMac());
device.setStatus("0");
device.setPublicStatus("1");
device.setCategoryId(deviceCategory.getId());
return deviceService.save(device);
}
/**
* 根据mac地址获取激活设备
*
* @param mac mac地址
* @return 激活设备
*/
private BizDeviceActivation getBizDeviceActivationByMac(String mac) {
LambdaQueryWrapper<BizDeviceActivation> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(BizDeviceActivation::getDeviceMac, mac);
return getOne(wrapper);
}
}

View File

@@ -1,6 +1,9 @@
package com.corewing.app.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.ValidateWirelessBoardRequest;
import com.corewing.app.entity.BizDevice;
import com.corewing.app.mapper.BizDeviceMapper;
import com.corewing.app.service.BizDeviceService;
@@ -8,4 +11,16 @@ import org.springframework.stereotype.Service;
@Service
public class BizDeviceServiceImpl extends ServiceImpl<BizDeviceMapper, BizDevice> implements BizDeviceService {
@Override
public Result<Boolean> validateWirelessBoard(ValidateWirelessBoardRequest validateWirelessBoardRequest) {
LambdaQueryWrapper<BizDevice> bizDeviceLambdaQueryWrapper = new LambdaQueryWrapper<>();
bizDeviceLambdaQueryWrapper.eq(BizDevice::getDeviceMac, validateWirelessBoardRequest.getMac());
long deviceCount = count(bizDeviceLambdaQueryWrapper);
if (deviceCount > 0) {
return Result.success(true);
}
return Result.error("设备不存在或未激活");
}
}

View File

@@ -4,8 +4,11 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.common.page.PageContext;
import com.corewing.app.dto.FirmwareVersionRequest;
import com.corewing.app.entity.BizDeviceCategory;
import com.corewing.app.entity.Firmware;
import com.corewing.app.mapper.FirmwareMapper;
import com.corewing.app.service.BizDeviceCategoryService;
import com.corewing.app.service.FirmwareService;
import com.corewing.app.util.OSSUploadUtil;
import org.springframework.stereotype.Service;
@@ -13,7 +16,9 @@ import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.StringUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.io.IOException;
import java.util.Objects;
/**
* 固件 Service 实现类
@@ -21,6 +26,9 @@ import java.io.IOException;
@Service
public class FirmwareServiceImpl extends ServiceImpl<FirmwareMapper, Firmware> implements FirmwareService {
@Resource
private BizDeviceCategoryService bizDeviceCategoryService;
@Override
public Page<Firmware> page(Firmware firmware) {
Page<Firmware> page = PageContext.getDefaultPage(Firmware.class);
@@ -63,6 +71,30 @@ public class FirmwareServiceImpl extends ServiceImpl<FirmwareMapper, Firmware> i
return false;
}
@Override
public Firmware checkVersion(FirmwareVersionRequest firmwareVersionRequest) {
// 根据型号id搜索到设备分类id
LambdaQueryWrapper<BizDeviceCategory> categoryLambdaQueryWrapper = new LambdaQueryWrapper<>();
categoryLambdaQueryWrapper.eq(BizDeviceCategory::getModelId, firmwareVersionRequest.getModelId());
BizDeviceCategory deviceCategory = bizDeviceCategoryService.getOne(categoryLambdaQueryWrapper);
if(Objects.isNull(deviceCategory)){
throw new RuntimeException("该设备型号不存在设备");
}
LambdaQueryWrapper<Firmware> wrapper = new LambdaQueryWrapper<>();
wrapper.ge(Firmware::getVersionId, firmwareVersionRequest.getVersion());
wrapper.eq(Firmware::getModelId, deviceCategory.getId());
wrapper.eq(Firmware::getFirmwareType, firmwareVersionRequest.getFirmwareType());
wrapper.orderByDesc(Firmware::getVersionId);
wrapper.last("LIMIT 1");
Firmware firmware = this.getOne(wrapper);
if (firmware == null) {
throw new RuntimeException("未找到匹配的固件版本");
}
return firmware;
}
/**
* 获取 URL 路径的最后一节(忽略查询参数 ? 和锚点 #
* @param urlStr URL字符串

View File

@@ -0,0 +1,241 @@
package com.corewing.app.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.common.Result;
import com.corewing.app.dto.qc.StepResultData;
import com.corewing.app.dto.qc.UploadTestRecordRequest;
import com.corewing.app.dto.qc.ValidateSnRequest;
import com.corewing.app.entity.FlightController;
import com.corewing.app.entity.QcPhoto;
import com.corewing.app.entity.QcStepResult;
import com.corewing.app.entity.QcTestRecord;
import com.corewing.app.mapper.FlightControllerMapper;
import com.corewing.app.mapper.QcPhotoMapper;
import com.corewing.app.mapper.QcStepResultMapper;
import com.corewing.app.mapper.QcTestRecordMapper;
import com.corewing.app.service.QcTestService;
import com.corewing.app.util.OSSUploadUtil;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;
@Service
public class QcTestServiceImpl extends ServiceImpl<QcTestRecordMapper, QcTestRecord> implements QcTestService {
@Resource
private QcStepResultMapper qcStepResultMapper;
@Resource
private QcPhotoMapper qcPhotoMapper;
@Resource
private FlightControllerMapper flightControllerMapper;
@Override
@Transactional(rollbackFor = Exception.class)
public Result<String> uploadTestRecord(UploadTestRecordRequest request) {
if (request.getTestNo() == null || request.getTestNo().isEmpty()) {
return Result.error("测试单号不能为空");
}
// 查找是否已存在相同 testNo 的记录
LambdaQueryWrapper<QcTestRecord> testNoQuery = new LambdaQueryWrapper<>();
testNoQuery.eq(QcTestRecord::getTestNo, request.getTestNo());
QcTestRecord existByTestNo = baseMapper.selectOne(testNoQuery);
QcTestRecord record;
if (existByTestNo != null) {
// 相同 testNo 已存在 → 更新APP 重传场景)
record = existByTestNo;
fillRecord(record, request);
baseMapper.updateById(record);
// 清除旧的步骤和照片,后面重新插入
deleteStepsAndPhotos(record.getId());
} else {
// 查找同一 SN 是否已有记录(返修重测场景)
LambdaQueryWrapper<QcTestRecord> snQuery = new LambdaQueryWrapper<>();
snQuery.eq(QcTestRecord::getSn, request.getSn())
.eq(QcTestRecord::getProductType, request.getProductType())
.orderByDesc(QcTestRecord::getCreateTime)
.last("LIMIT 1");
QcTestRecord existBySn = baseMapper.selectOne(snQuery);
if (existBySn != null) {
// 同一 SN 已有记录 → 更新最近一条(返修后重新 QC
record = existBySn;
fillRecord(record, request);
baseMapper.updateById(record);
deleteStepsAndPhotos(record.getId());
} else {
// 全新记录
record = new QcTestRecord();
fillRecord(record, request);
baseMapper.insert(record);
}
}
// 保存步骤结果
if (!CollectionUtils.isEmpty(request.getSteps())) {
for (StepResultData stepData : request.getSteps()) {
QcStepResult step = new QcStepResult();
BeanUtils.copyProperties(stepData, step, "completedAt");
step.setTestRecordId(record.getId());
step.setCompletedAt(parseTimestamp(stepData.getCompletedAt()));
qcStepResultMapper.insert(step);
}
}
// 保存照片 URL
if (!CollectionUtils.isEmpty(request.getPhotoUrls())) {
for (String photoUrl : request.getPhotoUrls()) {
QcPhoto photo = new QcPhoto();
photo.setTestRecordId(record.getId());
photo.setTestNo(request.getTestNo());
photo.setUrl(photoUrl);
qcPhotoMapper.insert(photo);
}
}
// 返回报告 URL可为 null
return Result.success("上传成功", record.getReportUrl());
}
private void fillRecord(QcTestRecord record, UploadTestRecordRequest request) {
// 拷贝同名同类型字段testNo, productType, sn, operatorId, operatorName, phoneModel, appVersion, status
BeanUtils.copyProperties(request, record, "createTime", "updatedAt", "uploadTime");
// 时间戳字符串 → LocalDateTime 需要手动转换
record.setCreateTime(parseTimestamp(request.getCreateTime()));
record.setUpdatedAt(parseTimestamp(request.getUpdatedAt()));
record.setUploadTime(parseTimestamp(request.getUploadTime()));
}
private void deleteStepsAndPhotos(Long recordId) {
LambdaQueryWrapper<QcStepResult> stepDelete = new LambdaQueryWrapper<>();
stepDelete.eq(QcStepResult::getTestRecordId, recordId);
qcStepResultMapper.delete(stepDelete);
LambdaQueryWrapper<QcPhoto> photoDelete = new LambdaQueryWrapper<>();
photoDelete.eq(QcPhoto::getTestRecordId, recordId);
qcPhotoMapper.delete(photoDelete);
}
@Override
public Result<Map<String, String>> uploadPhoto(String testNo, MultipartFile photo) {
if (photo == null || photo.isEmpty()) {
return Result.error("照片文件不能为空");
}
if (testNo == null || testNo.isEmpty()) {
return Result.error("测试单号不能为空");
}
// 查找对应的测试记录
LambdaQueryWrapper<QcTestRecord> query = new LambdaQueryWrapper<>();
query.eq(QcTestRecord::getTestNo, testNo);
QcTestRecord record = baseMapper.selectOne(query);
if (record == null) {
return Result.error("测试记录不存在: " + testNo);
}
try {
// 生成 OSS 存储路径
String originalFilename = photo.getOriginalFilename();
String suffix = "";
if (originalFilename != null && originalFilename.contains(".")) {
suffix = originalFilename.substring(originalFilename.lastIndexOf("."));
}
String objectName = "qc/photos/" + testNo + "/" + UUID.randomUUID().toString().replace("-", "") + suffix;
// 上传到 OSS
String url = OSSUploadUtil.uploadFile(photo.getInputStream(), objectName);
// 保存照片记录
QcPhoto qcPhoto = new QcPhoto();
qcPhoto.setTestRecordId(record.getId());
qcPhoto.setTestNo(testNo);
qcPhoto.setUrl(url);
qcPhotoMapper.insert(qcPhoto);
Map<String, String> result = new HashMap<>();
result.put("url", url);
return Result.success("上传成功", result);
} catch (Exception e) {
log.error("照片上传失败", e);
return Result.error("照片上传失败: " + e.getMessage());
}
}
@Override
public Result<Boolean> validateSn(ValidateSnRequest request) {
if (request.getSn() == null || request.getSn().isEmpty()) {
return Result.error("SN 不能为空");
}
LambdaQueryWrapper<FlightController> query = new LambdaQueryWrapper<>();
query.eq(FlightController::getSn, request.getSn());
Long count = flightControllerMapper.selectCount(query);
if (count > 0) {
return Result.success("SN 有效", true);
}
return Result.error("SN 无效或未注册");
}
@Override
public Result<List<QcTestRecord>> getHistory(String sn) {
if (sn == null || sn.isEmpty()) {
return Result.error("SN 不能为空");
}
LambdaQueryWrapper<QcTestRecord> query = new LambdaQueryWrapper<>();
query.eq(QcTestRecord::getSn, sn)
.orderByDesc(QcTestRecord::getCreateTime);
List<QcTestRecord> records = baseMapper.selectList(query);
return Result.success(records);
}
@Override
public Result<String> getReport(String testNo) {
if (testNo == null || testNo.isEmpty()) {
return Result.error("测试单号不能为空");
}
LambdaQueryWrapper<QcTestRecord> query = new LambdaQueryWrapper<>();
query.eq(QcTestRecord::getTestNo, testNo);
QcTestRecord record = baseMapper.selectOne(query);
if (record == null) {
return Result.error("测试记录不存在");
}
return Result.success(record.getReportUrl());
}
private LocalDateTime parseTimestamp(String timestamp) {
if (timestamp == null || timestamp.isEmpty()) {
return null;
}
try {
long millis = Long.parseLong(timestamp);
if (millis <= 0) {
return null;
}
return LocalDateTime.ofInstant(Instant.ofEpochMilli(millis), ZoneId.systemDefault());
} catch (NumberFormatException e) {
return null;
}
}
}

View File

@@ -0,0 +1,25 @@
package com.corewing.app.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.corewing.app.entity.SiriusFirmware;
import com.corewing.app.mapper.SiriusFirmwareMapper;
import com.corewing.app.service.SiriusFirmwareService;
import org.springframework.stereotype.Service;
/**
* Sirius固件信息 Service 实现类
*/
@Service
public class SiriusFirmwareServiceImpl extends ServiceImpl<SiriusFirmwareMapper, SiriusFirmware> implements SiriusFirmwareService {
@Override
public SiriusFirmware getLatestByTypeAndProtocol(Integer firmwareType, Integer protocolType) {
LambdaQueryWrapper<SiriusFirmware> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(SiriusFirmware::getFirmwareType, firmwareType);
wrapper.eq(SiriusFirmware::getProtocolType, protocolType);
wrapper.orderByDesc(SiriusFirmware::getCreateTime);
wrapper.last("LIMIT 1");
return getOne(wrapper);
}
}

View File

@@ -1,21 +1,526 @@
package com.corewing.app.util;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.ZoneId;
import java.time.format.DateTimeFormatter;
import java.util.Date;
public class DateUtils {
// 格式化LocalDateTime为字符串
public static void main(String[] args) {
//2026-02-24 08:40:90
System.out.println(isAfter(parseToLocalDateTime("2026-02-22 08:40:30")));
}
//==================== 字符串格式化方法 ====================
/**
* 将字符串格式化为LocalDateTime
* @param dateTimeStr 日期时间字符串
* @param pattern 格式模式yyyy-MM-dd HH:mm:ss
* @return LocalDateTime对象
*/
public static LocalDateTime parseToLocalDateTime(String dateTimeStr, String pattern) {
if (dateTimeStr == null || dateTimeStr.isEmpty() || pattern == null || pattern.isEmpty()) {
return null;
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return LocalDateTime.parse(dateTimeStr, formatter);
}
/**
* 将字符串格式化为LocalDate
* @param dateStr 日期字符串
* @param pattern 格式模式yyyy-MM-dd
* @return LocalDate对象
*/
public static LocalDate parseToLocalDate(String dateStr, String pattern) {
if (dateStr == null || dateStr.isEmpty() || pattern == null || pattern.isEmpty()) {
return null;
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return LocalDate.parse(dateStr, formatter);
}
/**
* 将字符串格式化为LocalTime
* @param timeStr 时间字符串
* @param pattern 格式模式HH:mm:ss
* @return LocalTime对象
*/
public static LocalTime parseToLocalTime(String timeStr, String pattern) {
if (timeStr == null || timeStr.isEmpty() || pattern == null || pattern.isEmpty()) {
return null;
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return LocalTime.parse(timeStr, formatter);
}
/**
* 将字符串格式化为Date
* @param dateTimeStr 日期时间字符串
* @param pattern 格式模式yyyy-MM-dd HH:mm:ss
* @return Date对象
*/
public static Date parseToDate(String dateTimeStr, String pattern) {
if (dateTimeStr == null || dateTimeStr.isEmpty() || pattern == null || pattern.isEmpty()) {
return null;
}
try {
SimpleDateFormat sdf = new SimpleDateFormat(pattern);
return sdf.parse(dateTimeStr);
} catch (Exception e) {
throw new IllegalArgumentException("日期解析失败: " + dateTimeStr, e);
}
}
//==================== 常用格式的快捷方法 ====================
/**
* 将字符串格式化为LocalDateTime默认格式yyyy-MM-dd HH:mm:ss
*/
public static LocalDateTime parseToLocalDateTime(String dateTimeStr) {
return parseToLocalDateTime(dateTimeStr, "yyyy-MM-dd HH:mm:ss");
}
/**
* 将字符串格式化为LocalDate默认格式yyyy-MM-dd
*/
public static LocalDate parseToLocalDate(String dateStr) {
return parseToLocalDate(dateStr, "yyyy-MM-dd");
}
/**
* 将字符串格式化为LocalTime默认格式HH:mm:ss
*/
public static LocalTime parseToLocalTime(String timeStr) {
return parseToLocalTime(timeStr, "HH:mm:ss");
}
/**
* 将字符串格式化为Date默认格式yyyy-MM-dd HH:mm:ss
*/
public static Date parseToDate(String dateTimeStr) {
return parseToDate(dateTimeStr, "yyyy-MM-dd HH:mm:ss");
}
//==================== 智能解析方法 ====================
/**
* 智能解析字符串为LocalDateTime自动识别常见格式
* 支持格式:
* - yyyy-MM-dd HH:mm:ss
* - yyyy/MM/dd HH:mm:ss
* - yyyy-MM-dd'T'HH:mm:ss
* - yyyy-MM-dd HH:mm
* - yyyy-MM-dd
* - yyyy/MM/dd
*/
public static LocalDateTime smartParseToLocalDateTime(String dateTimeStr) {
if (dateTimeStr == null || dateTimeStr.isEmpty()) {
return null;
}
String str = dateTimeStr.trim();
// 尝试各种格式
try {
// 格式1: yyyy-MM-dd HH:mm:ss
return LocalDateTime.parse(str, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
} catch (Exception e1) {
try {
// 格式2: yyyy/MM/dd HH:mm:ss
return LocalDateTime.parse(str, DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss"));
} catch (Exception e2) {
try {
// 格式3: yyyy-MM-dd'T'HH:mm:ss
return LocalDateTime.parse(str, DateTimeFormatter.ISO_LOCAL_DATE_TIME);
} catch (Exception e3) {
try {
// 格式4: yyyy-MM-dd HH:mm
return LocalDateTime.parse(str, DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm"));
} catch (Exception e4) {
try {
// 格式5: yyyy-MM-dd (转为当天开始时间)
LocalDate date = LocalDate.parse(str, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
return date.atStartOfDay();
} catch (Exception e5) {
try {
// 格式6: yyyy/MM/dd
LocalDate date = LocalDate.parse(str, DateTimeFormatter.ofPattern("yyyy/MM/dd"));
return date.atStartOfDay();
} catch (Exception e6) {
throw new IllegalArgumentException("无法解析的日期时间字符串: " + str);
}
}
}
}
}
}
}
/**
* 智能解析字符串为LocalDate自动识别常见格式
* 支持格式:
* - yyyy-MM-dd
* - yyyy/MM/dd
* - yyyyMMdd
* - dd/MM/yyyy
*/
public static LocalDate smartParseToLocalDate(String dateStr) {
if (dateStr == null || dateStr.isEmpty()) {
return null;
}
String str = dateStr.trim();
try {
return LocalDate.parse(str, DateTimeFormatter.ofPattern("yyyy-MM-dd"));
} catch (Exception e1) {
try {
return LocalDate.parse(str, DateTimeFormatter.ofPattern("yyyy/MM/dd"));
} catch (Exception e2) {
try {
return LocalDate.parse(str, DateTimeFormatter.ofPattern("yyyyMMdd"));
} catch (Exception e3) {
try {
return LocalDate.parse(str, DateTimeFormatter.ofPattern("dd/MM/yyyy"));
} catch (Exception e4) {
throw new IllegalArgumentException("无法解析的日期字符串: " + str);
}
}
}
}
}
//==================== 格式化输出方法 ====================
/**
* 将LocalDateTime格式化为字符串
* @param dateTime LocalDateTime对象
* @param pattern 格式模式
* @return 格式化后的字符串
*/
public static String format(LocalDateTime dateTime, String pattern) {
if (dateTime == null || pattern == null || pattern.isEmpty()) {
return "";
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return dateTime.format(formatter);
}
/**
* 将LocalDate格式化为字符串
*/
public static String format(LocalDate date, String pattern) {
if (date == null || pattern == null || pattern.isEmpty()) {
return "";
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return date.format(formatter);
}
/**
* 将LocalTime格式化为字符串
*/
public static String format(LocalTime time, String pattern) {
if (time == null || pattern == null || pattern.isEmpty()) {
return "";
}
DateTimeFormatter formatter = DateTimeFormatter.ofPattern(pattern);
return time.format(formatter);
}
/**
* 将Date格式化为字符串
*/
public static String format(Date time, String pattern) {
if (time == null || pattern == null || pattern.isEmpty()) {
return "";
}
// 创建SimpleDateFormat实例
SimpleDateFormat sdf = new SimpleDateFormat(pattern);
// 格式化日期为字符串
return sdf.format(time);
}
/**
* 将LocalDateTime格式化为默认格式yyyy-MM-dd HH:mm:ss
*/
public static String formatDateTime(LocalDateTime dateTime) {
return format(dateTime, "yyyy-MM-dd HH:mm:ss");
}
/**
* 将LocalDate格式化为默认格式yyyy-MM-dd
*/
public static String formatDate(LocalDate date) {
return format(date, "yyyy-MM-dd");
}
/**
* 将LocalTime格式化为默认格式HH:mm:ss
*/
public static String formatTime(LocalTime time) {
return format(time, "HH:mm:ss");
}
/**
* 将Date格式化为默认格式yyyy-MM-dd HH:mm:ss
*/
public static String formatDateTime(Date date) {
return format(date, "yyyy-MM-dd HH:mm:ss");
}
//==================== 判断方法 ====================
/**
* 判断传入时间是否大于当前时间
* @param time 支持Date, LocalDateTime, LocalDate, String
*/
public static boolean isAfter(Object time) {
LocalDateTime dateTime = convertToLocalDateTime(time);
return dateTime.isAfter(LocalDateTime.now());
}
/**
* 判断传入时间是否小于当前时间
* @param time 支持Date, LocalDateTime, LocalDate, String
*/
public static boolean isBefore(Object time) {
LocalDateTime dateTime = convertToLocalDateTime(time);
return dateTime.isBefore(LocalDateTime.now());
}
/**
* 判断传入时间是否等于当前时间(近似到分钟)
* @param time 支持Date, LocalDateTime, LocalDate, String
*/
public static boolean isEqual(Object time) {
LocalDateTime dateTime = convertToLocalDateTime(time);
LocalDateTime now = LocalDateTime.now().withSecond(0).withNano(0);
return dateTime.withSecond(0).withNano(0).isEqual(now);
}
//==================== 日期时间专用判断 ====================
/**
* 判断传入时间是否大于等于当前时间
*/
public static boolean isAfterOrEqual(Object time) {
LocalDateTime dateTime = convertToLocalDateTime(time);
return !dateTime.isBefore(LocalDateTime.now());
}
/**
* 判断传入时间是否小于等于当前时间
*/
public static boolean isBeforeOrEqual(Object time) {
LocalDateTime dateTime = convertToLocalDateTime(time);
return !dateTime.isAfter(LocalDateTime.now());
}
/**
* 判断传入时间是否大于等于指定时间
* @param time 要判断的时间
* @param targetTime 目标时间
*/
public static boolean isAfterOrEqual(Object time, Object targetTime) {
LocalDateTime dateTime = convertToLocalDateTime(time);
LocalDateTime target = convertToLocalDateTime(targetTime);
return !dateTime.isBefore(target);
}
/**
* 判断传入时间是否小于等于指定时间
* @param time 要判断的时间
* @param targetTime 目标时间
*/
public static boolean isBeforeOrEqual(Object time, Object targetTime) {
LocalDateTime dateTime = convertToLocalDateTime(time);
LocalDateTime target = convertToLocalDateTime(targetTime);
return !dateTime.isAfter(target);
}
/**
* 判断传入时间是否在指定时间范围内(包含边界)
* @param time 要判断的时间
* @param start 开始时间
* @param end 结束时间
*/
public static boolean isBetween(Object time, Object start, Object end) {
LocalDateTime dateTime = convertToLocalDateTime(time);
LocalDateTime startTime = convertToLocalDateTime(start);
LocalDateTime endTime = convertToLocalDateTime(end);
return !dateTime.isBefore(startTime) && !dateTime.isAfter(endTime);
}
/**
* 判断传入时间是否在指定时间范围内(不包含边界)
* @param time 要判断的时间
* @param start 开始时间
* @param end 结束时间
*/
public static boolean isBetweenExclusive(Object time, Object start, Object end) {
LocalDateTime dateTime = convertToLocalDateTime(time);
LocalDateTime startTime = convertToLocalDateTime(start);
LocalDateTime endTime = convertToLocalDateTime(end);
return dateTime.isAfter(startTime) && dateTime.isBefore(endTime);
}
//==================== 两个时间比较 ====================
/**
* 判断time1是否大于time2
*/
public static boolean isAfter(Object time1, Object time2) {
LocalDateTime dt1 = convertToLocalDateTime(time1);
LocalDateTime dt2 = convertToLocalDateTime(time2);
return dt1.isAfter(dt2);
}
/**
* 判断time1是否小于time2
*/
public static boolean isBefore(Object time1, Object time2) {
LocalDateTime dt1 = convertToLocalDateTime(time1);
LocalDateTime dt2 = convertToLocalDateTime(time2);
return dt1.isBefore(dt2);
}
/**
* 判断两个时间是否相等
*/
public static boolean isEqual(Object time1, Object time2) {
LocalDateTime dt1 = convertToLocalDateTime(time1);
LocalDateTime dt2 = convertToLocalDateTime(time2);
return dt1.isEqual(dt2);
}
//==================== 日期专用判断 ====================
/**
* 判断传入日期是否大于今天(只比较年月日)
*/
public static boolean isAfterDate(Object date) {
LocalDate localDate = convertToLocalDate(date);
return localDate.isAfter(LocalDate.now());
}
/**
* 判断传入日期是否小于今天(只比较年月日)
*/
public static boolean isBeforeDate(Object date) {
LocalDate localDate = convertToLocalDate(date);
return localDate.isBefore(LocalDate.now());
}
/**
* 判断传入日期是否等于今天
*/
public static boolean isToday(Object date) {
LocalDate localDate = convertToLocalDate(date);
return localDate.isEqual(LocalDate.now());
}
/**
* 判断传入日期是否大于等于今天(只比较年月日)
*/
public static boolean isAfterOrEqualDate(Object date) {
LocalDate localDate = convertToLocalDate(date);
return !localDate.isBefore(LocalDate.now());
}
/**
* 判断传入日期是否小于等于今天(只比较年月日)
*/
public static boolean isBeforeOrEqualDate(Object date) {
LocalDate localDate = convertToLocalDate(date);
return !localDate.isAfter(LocalDate.now());
}
//==================== 私有转换方法 ====================
/**
* 将各种类型转换为LocalDateTime
*/
private static LocalDateTime convertToLocalDateTime(Object time) {
if (time == null) {
throw new IllegalArgumentException("时间不能为null");
}
// 1. LocalDateTime
if (time instanceof LocalDateTime) {
return (LocalDateTime) time;
}
// 2. LocalDate
if (time instanceof LocalDate) {
return ((LocalDate) time).atStartOfDay();
}
// 3. Date
if (time instanceof Date) {
return ((Date) time).toInstant()
.atZone(ZoneId.systemDefault())
.toLocalDateTime();
}
// 4. String
if (time instanceof String) {
return smartParseToLocalDateTime((String) time);
}
// 5. Long (时间戳)
if (time instanceof Long) {
return LocalDateTime.ofInstant(
java.time.Instant.ofEpochMilli((Long) time),
ZoneId.systemDefault()
);
}
throw new IllegalArgumentException("不支持的时间类型: " + time.getClass().getName());
}
/**
* 将各种类型转换为LocalDate
*/
private static LocalDate convertToLocalDate(Object date) {
if (date == null) {
throw new IllegalArgumentException("日期不能为null");
}
// 1. LocalDate
if (date instanceof LocalDate) {
return (LocalDate) date;
}
// 2. LocalDateTime
if (date instanceof LocalDateTime) {
return ((LocalDateTime) date).toLocalDate();
}
// 3. Date
if (date instanceof Date) {
return ((Date) date).toInstant()
.atZone(ZoneId.systemDefault())
.toLocalDate();
}
// 4. String
if (date instanceof String) {
return smartParseToLocalDate((String) date);
}
// 5. Long (时间戳)
if (date instanceof Long) {
return LocalDateTime.ofInstant(
java.time.Instant.ofEpochMilli((Long) date),
ZoneId.systemDefault()
).toLocalDate();
}
throw new IllegalArgumentException("不支持的日期类型: " + date.getClass().getName());
}
}

View File

@@ -9,6 +9,7 @@ spring.profiles.active=prod
# 应用服务 WEB 访问端口
server.port=8080
# 单文件最大大小例如10MB支持单位B, KB, MB, GB
spring.servlet.multipart.max-file-size=100MB
# 一次请求中所有文件的总大小例如50MB

View File

@@ -0,0 +1,81 @@
-- ============================================================
-- Corewing QC 后端数据库建表 SQLMySQL
-- ============================================================
CREATE TABLE `flight_controller` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`sn` VARCHAR(64) NOT NULL COMMENT '序列号',
`model` VARCHAR(64) DEFAULT NULL COMMENT '型号',
`batch_no` VARCHAR(64) DEFAULT NULL COMMENT '批次号',
`status` VARCHAR(32) NOT NULL DEFAULT 'REGISTERED' COMMENT '状态: REGISTERED / QC_PASS / QC_FAIL / ACTIVATED',
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
`update_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
UNIQUE KEY `uk_sn` (`sn`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='飞控板设备注册表';
CREATE TABLE `qc_test_record` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_no` VARCHAR(32) NOT NULL COMMENT '测试单号,格式: WL-yyyyMMdd-NNN / FC-yyyyMMdd-NNN',
`product_type` VARCHAR(32) NOT NULL COMMENT '产品类型: WIRELESS_BOARD / FLIGHT_CONTROLLER',
`sn` VARCHAR(64) NOT NULL COMMENT '产品序列号(无线板为 BLE MAC',
`operator_id` VARCHAR(32) NOT NULL COMMENT '测试员 ID',
`operator_name` VARCHAR(64) NOT NULL COMMENT '测试员姓名',
`phone_model` VARCHAR(64) DEFAULT NULL COMMENT '测试手机型号',
`app_version` VARCHAR(16) DEFAULT NULL COMMENT 'APP 版本',
`status` VARCHAR(16) NOT NULL COMMENT '测试结果: PASS / FAIL',
`create_time` DATETIME NOT NULL COMMENT 'APP 端创建时间',
`updated_at` DATETIME DEFAULT NULL COMMENT 'APP 端最后更新时间',
`upload_time` DATETIME DEFAULT NULL COMMENT 'APP 端上传时间',
`report_url` VARCHAR(512) DEFAULT NULL COMMENT '测试报告 URL',
`server_create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '服务端入库时间',
PRIMARY KEY (`id`),
UNIQUE KEY `uk_test_no` (`test_no`),
KEY `idx_sn` (`sn`),
KEY `idx_product_type` (`product_type`),
KEY `idx_status` (`status`),
KEY `idx_create_time` (`create_time`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 测试记录主表';
CREATE TABLE `qc_step_result` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_record_id` BIGINT NOT NULL COMMENT '关联 qc_test_record.id',
`step_index` INT NOT NULL COMMENT '步骤序号(从 1 开始)',
`step_name` VARCHAR(64) NOT NULL COMMENT '步骤名称',
`result` VARCHAR(8) DEFAULT NULL COMMENT '步骤结果: PASS / FAIL / NULL',
`data_json` TEXT DEFAULT NULL COMMENT '步骤详细数据 JSON',
`duration` BIGINT DEFAULT 0 COMMENT '步骤耗时(毫秒)',
`completed_at` DATETIME DEFAULT NULL COMMENT '步骤完成时间',
PRIMARY KEY (`id`),
KEY `idx_test_record_id` (`test_record_id`),
UNIQUE KEY `uk_record_step` (`test_record_id`, `step_index`),
CONSTRAINT `fk_step_record` FOREIGN KEY (`test_record_id`)
REFERENCES `qc_test_record` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 步骤结果表';
CREATE TABLE `qc_photo` (
`id` BIGINT NOT NULL AUTO_INCREMENT,
`test_record_id` BIGINT NOT NULL COMMENT '关联 qc_test_record.id',
`test_no` VARCHAR(32) NOT NULL COMMENT '测试单号',
`url` VARCHAR(512) NOT NULL COMMENT '照片远程 URL',
`create_time` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
KEY `idx_test_no` (`test_no`),
CONSTRAINT `fk_photo_record` FOREIGN KEY (`test_record_id`)
REFERENCES `qc_test_record` (`id`) ON DELETE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='QC 测试照片表';
-- ============================================================
-- 示例数据(可选)
-- ============================================================
-- 注册一批无线板
-- INSERT INTO `wireless_board` (`mac`) VALUES
-- ('AA:BB:CC:DD:EE:01'),
-- ('AA:BB:CC:DD:EE:02'),
-- ('AA:BB:CC:DD:EE:03');

View File

@@ -64,6 +64,7 @@ error.token.replaced=Account has been logged in elsewhere
error.token.kicked.out=Account has been kicked offline
error.not.login=Not logged in, please login first
error.server.internal=Internal server error: {0}
error.system=System error, please try again later
# ==================== Utility Classes ====================
# Redis Utility
@@ -143,3 +144,5 @@ firmware.update.success=Firmware updated successfully
firmware.update.failed=Failed to update firmware
firmware.not.found=Firmware not found
firmware.type.required=Firmware type is required
firmware.type.or.model.required=Firmware type or model is required
firmware.device.not.found=Device not found

View File

@@ -64,6 +64,7 @@ error.token.replaced=账号已在其他地方登录
error.token.kicked.out=账号已被踢下线
error.not.login=未登录,请先登录
error.server.internal=服务器内部错误:{0}
error.system=系统错误,请稍后重试
# ==================== 工具类 ====================
# Redis工具类
@@ -143,3 +144,5 @@ firmware.update.success=固件更新成功
firmware.update.failed=固件更新失败
firmware.not.found=固件不存在
firmware.type.required=固件类型不能为空
firmware.type.or.model.required=固件类型或型号不能为空
firmware.device.not.found=设备不存在

View File

@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.corewing.app.mapper.BizActivityLotteryMapper">
</mapper>

View File

@@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.corewing.app.mapper.BizActivityMapper">
</mapper>

View File

@@ -0,0 +1,295 @@
<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<title>AAT 固件版本管理</title>
<style>
* { margin: 0; padding: 0; box-sizing: border-box; }
body { font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, sans-serif; background: #f5f7fa; color: #333; padding: 20px; }
.container { max-width: 1200px; margin: 0 auto; }
h1 { font-size: 22px; margin-bottom: 20px; color: #1a1a1a; }
.toolbar { display: flex; gap: 10px; margin-bottom: 16px; align-items: center; flex-wrap: wrap; }
.toolbar select, .toolbar input { padding: 8px 12px; border: 1px solid #d9d9d9; border-radius: 6px; font-size: 14px; }
.btn { padding: 8px 16px; border: none; border-radius: 6px; font-size: 14px; cursor: pointer; transition: all .2s; }
.btn-primary { background: #1677ff; color: #fff; }
.btn-primary:hover { background: #4096ff; }
.btn-danger { background: #ff4d4f; color: #fff; }
.btn-danger:hover { background: #ff7875; }
.btn-success { background: #52c41a; color: #fff; }
.btn-success:hover { background: #73d13d; }
.btn-sm { padding: 4px 10px; font-size: 12px; }
table { width: 100%; border-collapse: collapse; background: #fff; border-radius: 8px; overflow: hidden; box-shadow: 0 1px 4px rgba(0,0,0,.08); }
th, td { padding: 12px 14px; text-align: left; border-bottom: 1px solid #f0f0f0; font-size: 14px; }
th { background: #fafafa; font-weight: 600; color: #666; }
tr:hover { background: #fafafa; }
.empty { text-align: center; padding: 40px; color: #999; }
/* Modal */
.modal-overlay { display: none; position: fixed; top: 0; left: 0; width: 100%; height: 100%; background: rgba(0,0,0,.45); z-index: 1000; justify-content: center; align-items: center; }
.modal-overlay.active { display: flex; }
.modal { background: #fff; border-radius: 10px; padding: 24px; width: 480px; max-width: 90vw; }
.modal h2 { font-size: 18px; margin-bottom: 20px; }
.form-group { margin-bottom: 14px; }
.form-group label { display: block; font-size: 13px; color: #666; margin-bottom: 4px; }
.form-group input, .form-group select, .form-group textarea { width: 100%; padding: 8px 12px; border: 1px solid #d9d9d9; border-radius: 6px; font-size: 14px; }
.form-group textarea { height: 60px; resize: vertical; }
.modal-footer { display: flex; justify-content: flex-end; gap: 10px; margin-top: 20px; }
.btn-cancel { background: #f0f0f0; color: #333; }
.btn-cancel:hover { background: #d9d9d9; }
.file-upload { position: relative; }
.file-upload input[type="file"] { position: absolute; left: 0; top: 0; width: 100%; height: 100%; opacity: 0; cursor: pointer; }
.file-info { font-size: 12px; color: #999; margin-top: 4px; }
.url-link { color: #1677ff; text-decoration: none; word-break: break-all; }
.url-link:hover { text-decoration: underline; }
.tag { display: inline-block; padding: 2px 8px; border-radius: 4px; font-size: 12px; background: #e6f4ff; color: #1677ff; }
.size { color: #999; font-size: 13px; }
.toast { position: fixed; top: 20px; left: 50%; transform: translateX(-50%); padding: 10px 24px; border-radius: 8px; color: #fff; font-size: 14px; z-index: 2000; transition: opacity .3s; }
.toast-success { background: #52c41a; }
.toast-error { background: #ff4d4f; }
</style>
</head>
<body>
<div class="container">
<h1>AAT 固件版本管理</h1>
<div class="toolbar">
<select id="filterType">
<option value="">全部类型</option>
<option value="lb_main">lb_main</option>
<option value="lb_signal_master">lb_signal_master</option>
<option value="lbPro_main">lbPro_main</option>
<option value="lbPro_signal_master">lbPro_signal_master</option>
<option value="lbPro_screen_ui">lbPro_screen_ui</option>
</select>
<button class="btn btn-primary" onclick="openAddModal()">+ 新增固件</button>
</div>
<table>
<thead>
<tr>
<th>ID</th>
<th>固件类型</th>
<th>固件名称</th>
<th>版本号</th>
<th>最低硬件版本</th>
<th>文件大小</th>
<th>下载地址</th>
<th>操作</th>
</tr>
</thead>
<tbody id="tableBody">
<tr><td colspan="8" class="empty">加载中...</td></tr>
</tbody>
</table>
</div>
<!-- 新增/编辑 Modal -->
<div class="modal-overlay" id="formModal">
<div class="modal">
<h2 id="modalTitle">新增固件</h2>
<input type="hidden" id="formId">
<div class="form-group">
<label>固件类型</label>
<select id="formType">
<option value="lb_main">lb_main</option>
<option value="lb_signal_master">lb_signal_master</option>
<option value="lbPro_main">lbPro_main</option>
<option value="lbPro_signal_master">lbPro_signal_master</option>
<option value="lbPro_screen_ui">lbPro_screen_ui</option>
</select>
</div>
<div class="form-group">
<label>固件名称</label>
<input type="text" id="formName" placeholder="如 lb_main_2.1.bin">
</div>
<div class="form-group">
<label>固件版本号</label>
<input type="text" id="formVersion" placeholder="如 2.1">
</div>
<div class="form-group">
<label>最低硬件版本</label>
<input type="text" id="formMinHw" placeholder="如 1.0" value="0.0">
</div>
<div class="form-group">
<label>固件描述</label>
<textarea id="formDesc" placeholder="可选"></textarea>
</div>
<div class="modal-footer">
<button class="btn btn-cancel" onclick="closeModal()">取消</button>
<button class="btn btn-primary" onclick="submitForm()">确定</button>
</div>
</div>
</div>
<!-- 上传 Modal -->
<div class="modal-overlay" id="uploadModal">
<div class="modal">
<h2>上传固件文件</h2>
<input type="hidden" id="uploadId">
<div class="form-group">
<label>选择固件文件</label>
<input type="file" id="uploadFile">
<div class="file-info" id="uploadInfo"></div>
</div>
<div class="modal-footer">
<button class="btn btn-cancel" onclick="closeUploadModal()">取消</button>
<button class="btn btn-success" id="uploadBtn" onclick="doUpload()">上传</button>
</div>
</div>
</div>
<script>
const API = '/aat_version';
// Load list
function loadList() {
const type = document.getElementById('filterType').value;
const url = type ? `${API}/type/${type}` : `${API}/list`;
fetch(url).then(r => r.json()).then(res => {
if (!res.success) { showToast(res.message, 'error'); return; }
renderTable(res.data);
}).catch(() => showToast('加载失败', 'error'));
}
function renderTable(list) {
const tbody = document.getElementById('tableBody');
if (!list || list.length === 0) {
tbody.innerHTML = '<tr><td colspan="8" class="empty">暂无数据</td></tr>';
return;
}
tbody.innerHTML = list.map(item => `<tr>
<td>${item.id}</td>
<td><span class="tag">${item.firmwareType}</span></td>
<td>${item.firmwareName || '-'}</td>
<td>${item.firmwareVersion || '-'}</td>
<td>${item.minHardwareVersion || '0.0'}</td>
<td class="size">${item.firmwareSize ? formatSize(item.firmwareSize) : '-'}</td>
<td>${item.downloadUrl ? '<a class="url-link" href="' + item.downloadUrl + '" target="_blank">下载</a>' : '-'}</td>
<td>
<button class="btn btn-success btn-sm" onclick="openUpload(${item.id})">上传</button>
<button class="btn btn-primary btn-sm" onclick="openEdit(${item.id})">编辑</button>
<button class="btn btn-danger btn-sm" onclick="del(${item.id})">删除</button>
</td>
</tr>`).join('');
}
function formatSize(bytes) {
if (bytes < 1024) return bytes + ' B';
if (bytes < 1048576) return (bytes / 1024).toFixed(1) + ' KB';
return (bytes / 1048576).toFixed(2) + ' MB';
}
// Filter
document.getElementById('filterType').addEventListener('change', loadList);
// Add
function openAddModal() {
document.getElementById('modalTitle').textContent = '新增固件';
document.getElementById('formId').value = '';
document.getElementById('formType').value = 'lb_main';
document.getElementById('formName').value = '';
document.getElementById('formVersion').value = '';
document.getElementById('formMinHw').value = '0.0';
document.getElementById('formDesc').value = '';
document.getElementById('formModal').classList.add('active');
}
// Edit
function openEdit(id) {
fetch(`${API}/${id}`).then(r => r.json()).then(res => {
if (!res.success) { showToast(res.message, 'error'); return; }
const d = res.data;
document.getElementById('modalTitle').textContent = '编辑固件';
document.getElementById('formId').value = d.id;
document.getElementById('formType').value = d.firmwareType;
document.getElementById('formName').value = d.firmwareName || '';
document.getElementById('formVersion').value = d.firmwareVersion || '';
document.getElementById('formMinHw').value = d.minHardwareVersion || '0.0';
document.getElementById('formDesc').value = d.firmwareDescription || '';
document.getElementById('formModal').classList.add('active');
});
}
function closeModal() { document.getElementById('formModal').classList.remove('active'); }
function submitForm() {
const id = document.getElementById('formId').value;
const body = {
firmwareType: document.getElementById('formType').value,
firmwareName: document.getElementById('formName').value,
firmwareVersion: document.getElementById('formVersion').value,
minHardwareVersion: document.getElementById('formMinHw').value,
firmwareDescription: document.getElementById('formDesc').value
};
if (!body.firmwareName || !body.firmwareVersion) {
showToast('请填写固件名称和版本号', 'error'); return;
}
if (id) body.id = parseInt(id);
const method = id ? 'PUT' : 'POST';
fetch(API, { method, headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(body) })
.then(r => r.json()).then(res => {
if (res.success) { showToast('保存成功'); closeModal(); loadList(); }
else showToast(res.message || '保存失败', 'error');
}).catch(() => showToast('请求失败', 'error'));
}
// Delete
function del(id) {
if (!confirm('确定删除该固件版本?')) return;
fetch(`${API}/${id}`, { method: 'DELETE' }).then(r => r.json()).then(res => {
if (res.success) { showToast('删除成功'); loadList(); }
else showToast(res.message || '删除失败', 'error');
}).catch(() => showToast('请求失败', 'error'));
}
// Upload
function openUpload(id) {
document.getElementById('uploadId').value = id;
document.getElementById('uploadFile').value = '';
document.getElementById('uploadInfo').textContent = '';
document.getElementById('uploadBtn').disabled = false;
document.getElementById('uploadBtn').textContent = '上传';
document.getElementById('uploadModal').classList.add('active');
}
function closeUploadModal() { document.getElementById('uploadModal').classList.remove('active'); }
function doUpload() {
const id = document.getElementById('uploadId').value;
const fileInput = document.getElementById('uploadFile');
if (!fileInput.files.length) { showToast('请选择文件', 'error'); return; }
const formData = new FormData();
formData.append('file', fileInput.files[0]);
const btn = document.getElementById('uploadBtn');
btn.disabled = true;
btn.textContent = '上传中...';
fetch(`${API}/upload/${id}`, { method: 'POST', body: formData })
.then(r => r.json()).then(res => {
if (res.success) { showToast('上传成功'); closeUploadModal(); loadList(); }
else showToast(res.message || '上传失败', 'error');
}).catch(() => showToast('上传失败', 'error'))
.finally(() => { btn.disabled = false; btn.textContent = '上传'; });
}
// Toast
function showToast(msg, type) {
const el = document.createElement('div');
el.className = 'toast ' + (type === 'error' ? 'toast-error' : 'toast-success');
el.textContent = msg;
document.body.appendChild(el);
setTimeout(() => { el.style.opacity = '0'; setTimeout(() => el.remove(), 300); }, 2000);
}
// Init
loadList();
</script>
</body>
</html>

View File

@@ -0,0 +1,10 @@
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>Title</title>
</head>
<body>
123213
</body>
</html>