From 37f3237f61960efa89b6e83b0c65f69b0635d358 Mon Sep 17 00:00:00 2001 From: old burden Date: Fri, 3 Apr 2026 12:38:46 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A7=86=E9=A2=91=E7=94=9F=E6=88=90?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- admin-ui/.env.production | 3 + admin-ui/.env.staging | 3 +- admin-ui/src/views/ai/user/index.vue | 95 +++++++++++++++---- portal-ui/src/views/VideoGen.vue | 11 ++- .../java/com/ruoyi/api/ByteApiController.java | 83 +++++++++++++++- .../com/ruoyi/api/PortalVideoController.java | 19 +++- .../common/core/domain/entity/AiUser.java | 6 +- .../java/com/ruoyi/ai/domain/ByteBodyRes.java | 5 + .../ai/service/impl/AiOrderServiceImpl.java | 3 +- .../ai/service/impl/AiUserServiceImpl.java | 24 +++++ 10 files changed, 221 insertions(+), 31 deletions(-) diff --git a/admin-ui/.env.production b/admin-ui/.env.production index a11a545..521c967 100644 --- a/admin-ui/.env.production +++ b/admin-ui/.env.production @@ -6,3 +6,6 @@ ENV = 'production' # 若依管理系统/生产环境 VUE_APP_BASE_API = 'http://111.230.37.169:10009' +# VUE_APP_BASE_API = 'http://101.96.201.225:8011' +# VUE_APP_BASE_API = 'http://47.86.170.114:8011' + diff --git a/admin-ui/.env.staging b/admin-ui/.env.staging index a7ed22f..ae256d9 100644 --- a/admin-ui/.env.staging +++ b/admin-ui/.env.staging @@ -8,5 +8,4 @@ NODE_ENV = production # 测试环境配置 ENV = 'staging' -# 若依管理系统/测试环境 -VUE_APP_BASE_API = '/api' +VUE_APP_BASE_API = 'http://101.96.201.225:8011' diff --git a/admin-ui/src/views/ai/user/index.vue b/admin-ui/src/views/ai/user/index.vue index 1a893f5..1465e0d 100644 --- a/admin-ui/src/views/ai/user/index.vue +++ b/admin-ui/src/views/ai/user/index.vue @@ -67,6 +67,27 @@ + + 新增 + + + 删除 + - + @@ -150,8 +178,24 @@ /> - - + + + + + + + + @@ -176,10 +220,10 @@ + + + - - -
确 定 取 消 @@ -307,11 +351,18 @@ export default { form: {}, // 表单校验 rules: { - delFlag: [ - { required: true, message: "删除标志不能为空", trigger: "blur" } - ], - phone: [ - { required: true, message: "手机号码不能为空", trigger: "blur" } + username: [{ required: true, message: "用户账号不能为空", trigger: "blur" }], + password: [ + { + validator: (rule, value, callback) => { + if (this.form.id == null && (!value || !String(value).trim())) { + callback(new Error("密码不能为空")); + } else { + callback(); + } + }, + trigger: "blur" + } ] } }; @@ -442,6 +493,7 @@ export default { updateBy: null, updateTime: null, remark: null, + username: null, nickname: null, gender: null, avatar: null, @@ -496,13 +548,17 @@ export default { this.$refs["form"].validate(valid => { if (valid) { if (this.form.id != null) { - updateUser(this.form).then(response => { + const payload = { ...this.form }; + if (!payload.password || !String(payload.password).trim()) { + delete payload.password; + } + updateUser(payload).then(() => { this.$modal.msgSuccess("修改成功"); this.open = false; this.getList(); }); } else { - addUser(this.form).then(response => { + addUser(this.form).then(() => { this.$modal.msgSuccess("新增成功"); this.open = false; this.getList(); @@ -523,11 +579,16 @@ export default { }, /** 删除按钮操作 */ handleDelete(row) { - const ids = row.id || this.ids; + const ids = row && row.id != null ? row.id : this.ids; + if (ids == null || (Array.isArray(ids) && !ids.length)) { + this.$modal.msgWarning("请选择要删除的数据"); + return; + } + const idParam = Array.isArray(ids) ? ids.join(",") : ids; this.$modal - .confirm('是否确认删除ai-用户信息编号为"' + ids + '"的数据项？') - .then(function() { - return delUser(ids); + .confirm('是否确认删除ai-用户信息编号为"' + idParam + '"的数据项？') + .then(() => { + return delUser(idParam); }) .then(() => { this.getList(); diff --git a/portal-ui/src/views/VideoGen.vue b/portal-ui/src/views/VideoGen.vue index c6d505f..49a5cbb 100644 --- a/portal-ui/src/views/VideoGen.vue +++ b/portal-ui/src/views/VideoGen.vue @@ -581,10 +581,14 @@ export default { }, taskStatusText(row) { - if (row.status === 1 && row.result && this.isHttpOrHttpsUrl(row.result)) return '已完成' - if (row.status === 1) return '执行任务中' + // 与后端约定：0 执行中，2 失败，1+http(s) 成功，1 且非 http 为生成失败 if (row.status === 2) return '已失败/已取消' - return '进行中' + if (row.status === 0) return '执行中' + if (row.status === 1) { + if (row.result && this.isHttpOrHttpsUrl(row.result)) return '已完成' + return '任务生成失败' + } + return '执行中' }, /** 是否展示完整「结果区」（视频 / 链接）；其余状态仅紧凑展示在用户行右侧 */ @@ -594,6 +598,7 @@ export default { chatRowInlineStatusClass(row) { if (row.status === 2) return 'vg-chat-inline-status--failed' + if (row.status === 1 && !this.isHttpOrHttpsUrl(row.result)) return 'vg-chat-inline-status--failed' return 'vg-chat-inline-status--running' }, diff --git a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteApiController.java b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteApiController.java index 3ae4b5f..bc3c970 100644 --- a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteApiController.java +++ b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/ByteApiController.java @@ -327,30 +327,105 @@ public class ByteApiController extends BaseController { return AjaxResult.success(byteBodyRes); } - @GetMapping(value = "/volcCallback") + @PostMapping(value = "/volcCallback") @ApiOperation("火山引擎视频回调") @Anonymous public AjaxResult volcCallback(@RequestBody ByteBodyRes byteBodyRes) throws Exception { - if ("succeeded".equals(byteBodyRes.getStatus())) { - String id = byteBodyRes.getId(); + logger.info("volcCallback 收到回调数据: {}", byteBodyRes); + String id = byteBodyRes.getId(); + if (StringUtils.isEmpty(id)) { + logger.warn("volcCallback 无任务 id，跳过业务处理"); + return AjaxResult.success("callback success"); + } + + Integer code = byteBodyRes.getCode(); + boolean codeError = code != null && code != 200; + String st = byteBodyRes.getStatus(); + + if ("running".equals(st) && !codeError) { + return AjaxResult.success("callback success"); + } + + if (codeError) { + markVolcCallbackOrderClearResultFailed(id, "code=" + code); + return AjaxResult.success("callback success"); + } + + if ("succeeded".equals(st)) { content contentObj = byteBodyRes.getContent(); if (contentObj != null && StringUtils.isNotEmpty(contentObj.getVideo_url())) { String videoUrl = contentObj.getVideo_url(); videoUrl = tencentCosUtil.uploadFileByUrl(videoUrl); contentObj.setVideo_url(videoUrl); - AiOrder aiOrderByResult = aiOrderService.getAiOrderByResult(id); + AiOrder aiOrderByResult = findAiOrderByVolcTaskId(id); if (aiOrderByResult != null) { AiOrder aiOrder = new AiOrder(); aiOrder.setId(aiOrderByResult.getId()); aiOrder.setResult(videoUrl); + aiOrder.setStatus(1); aiOrderService.updateAiOrder(aiOrder); } + } else { + handleVolcCallbackFailure(id, "succeeded但缺少video_url"); } + return AjaxResult.success("callback success"); + } + + // failed、canceled 等终态，或 status 与成功/进行中均不一致 + if (StringUtils.isNotEmpty(st) || code != null) { + handleVolcCallbackFailure(id, "status=" + st); + } else { + logger.warn("volcCallback 未携带可判定的 status/code，id={}", id); } return AjaxResult.success("callback success"); } + /** + * 回调体 code 非 200（HTTP/业务状态码）：清空 result，status=2，不退款。 + */ + private void markVolcCallbackOrderClearResultFailed(String taskId, String reason) { + AiOrder order = findAiOrderByVolcTaskId(taskId); + if (order == null) { + logger.warn("volcCallback code 非 200：未找到任务对应订单, taskId={}, {}", taskId, reason); + return; + } + AiOrder upd = new AiOrder(); + upd.setId(order.getId()); + upd.setResult(""); + upd.setStatus(2); + aiOrderService.updateAiOrder(upd); + logger.warn("volcCallback code 非 200，已清空 result 并 status=2, orderId={}, {}", order.getId(), reason); + } + + private AiOrder findAiOrderByVolcTaskId(String taskId) { + AiOrder order = aiOrderService.getAiOrderByPortalVideoTask(taskId); + if (order != null) { + return order; + } + return aiOrderService.getAiOrderByResult(taskId); + } + + /** + * 回调判定任务失败：订单仍持有火山任务 id、且非已失败时，标记失败并退余额（orderFailure）。 + */ + private void handleVolcCallbackFailure(String taskId, String reason) { + AiOrder order = aiOrderService.getAiOrderByResult(taskId); + if (order == null) { + logger.warn("volcCallback 失败：未找到 result={} 的订单, {}", taskId, reason); + return; + } + if (!taskId.equals(order.getResult())) { + logger.info("volcCallback 失败处理跳过：订单结果已更新, taskId={}, {}", taskId, reason); + return; + } + if (Integer.valueOf(2).equals(order.getStatus())) { + return; + } + aiOrderService.orderFailure(order); + logger.warn("volcCallback 任务失败，已标记订单失败并退款, taskId={}, reason={}", taskId, reason); + } + @PostMapping(value = "/{id}/cancel") @ApiOperation("取消视频生成任务") public AjaxResult cancelTask(@PathVariable("id") String id) throws Exception { diff --git a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/PortalVideoController.java b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/PortalVideoController.java index 7795619..3ee7622 100644 --- a/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/PortalVideoController.java +++ b/web-api/ruoyi-admin/src/main/java/com/ruoyi/api/PortalVideoController.java @@ -484,7 +484,24 @@ public class PortalVideoController extends BaseController { return AjaxResult.error("无权查看该任务"); } String key = apiKey(); - ByteBodyRes byteBodyRes = byteService.uploadVideo(taskId, key); + ByteBodyRes byteBodyRes; + try { + byteBodyRes = byteService.uploadVideo(taskId, key); + } catch (Exception e) { + String msg = e.getMessage(); + // ByteService 在 HTTP 非 2xx 时抛出以此前缀开头的异常，仅此种情况清空订单，避免网络抖动等误伤 + if (msg != null && msg.startsWith("uploadVideo error")) { + logger.warn("查询火山任务 HTTP 非成功，已清空订单 result 并标记失败, orderId={}, taskId={}", + owned.getId(), taskId, e); + AiOrder failedOrder = new AiOrder(); + failedOrder.setId(owned.getId()); + failedOrder.setResult(""); + failedOrder.setStatus(2); + aiOrderService.updateAiOrder(failedOrder); + return AjaxResult.error(msg); + } + throw e; + } if ("succeeded".equals(byteBodyRes.getStatus())) { content contentObj = byteBodyRes.getContent(); if (contentObj != null && StringUtils.isNotEmpty(contentObj.getVideo_url())) { diff --git a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/AiUser.java b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/AiUser.java index 0cd4948..6e473a3 100644 --- a/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/AiUser.java +++ b/web-api/ruoyi-common/src/main/java/com/ruoyi/common/core/domain/entity/AiUser.java @@ -8,7 +8,7 @@ import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; -import com.fasterxml.jackson.annotation.JsonIgnore; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.commons.lang3.builder.ToStringStyle; @@ -54,8 +54,8 @@ public class AiUser extends BaseEntity { @Excel(name = "手机号码") private String phone; - /** 密码 */ - @JsonIgnore + /** 密码（仅接受入参反序列化，响应 Json 不输出，避免与 @JsonIgnore 导致入参丢失） */ + @JsonProperty(access = JsonProperty.Access.WRITE_ONLY) @Excel(name = "密码") private String password; diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/domain/ByteBodyRes.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/domain/ByteBodyRes.java index c6e858a..d3a305a 100644 --- a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/domain/ByteBodyRes.java +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/domain/ByteBodyRes.java @@ -12,6 +12,11 @@ public class ByteBodyRes { private ByteUsageRes usage; private String id; + /** + * 部分错误响应携带的业务/HTTP类状态码；非 200 视为失败（与 status 同时判定时以失败告终） + */ + private Integer code; + /** * running生成中 succeeded已完成 */ diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiOrderServiceImpl.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiOrderServiceImpl.java index 9e5227b..ff2f117 100644 --- a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiOrderServiceImpl.java +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiOrderServiceImpl.java @@ -180,7 +180,8 @@ public class AiOrderServiceImpl implements IAiOrderService { String remark = MessageUtils.message("order.number.generation.failed", aiOrder.getOrderNum()); aiOrder.setRemark(remark); aiOrderMapper.updateById(aiOrder); - aiUserService.addUserBalance(aiOrder.getOrderNum(), SecurityUtils.getAiUserId(), aiOrder.getAmount(), BalanceChangerConstants.REFUND, remark); + Long userId = aiOrder.getUserId() != null ? aiOrder.getUserId() : SecurityUtils.getAiUserId(); + aiUserService.addUserBalance(aiOrder.getOrderNum(), userId, aiOrder.getAmount(), BalanceChangerConstants.REFUND, remark); } @Override diff --git a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiUserServiceImpl.java b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiUserServiceImpl.java index 69c2bc4..1fd0935 100644 --- a/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiUserServiceImpl.java +++ b/web-api/ruoyi-system/src/main/java/com/ruoyi/ai/service/impl/AiUserServiceImpl.java @@ -114,6 +114,25 @@ public class AiUserServiceImpl implements IAiUserService { */ @Override public int insertAiUser(AiUser aiUser) { + if (StringUtils.isEmpty(aiUser.getUsername())) { + throw new ServiceException("用户账号不能为空", HttpStatus.BAD_REQUEST); + } + if (StringUtils.isEmpty(aiUser.getPassword())) { + throw new ServiceException("密码不能为空", HttpStatus.BAD_REQUEST); + } + if (getUserCountByUserName(aiUser.getUsername()) > 0) { + throw new ServiceException(MessageUtils.message("user.username.exists", aiUser.getUsername()), HttpStatus.CONFLICT); + } + aiUser.setPassword(SecurityUtils.encryptPassword(aiUser.getPassword())); + if (StringUtils.isEmpty(aiUser.getUserId())) { + aiUser.setUserId(generateUuiD()); + } + if (StringUtils.isEmpty(aiUser.getInvitationCode())) { + aiUser.setInvitationCode(generateUniqueString()); + } + if (aiUser.getStatus() == null) { + aiUser.setStatus(0); + } aiUser.setDelFlag("0"); aiUser.setCreateBy(SecurityUtils.getUsername()); aiUser.setCreateTime(DateUtils.getNowDate()); @@ -129,6 +148,11 @@ public class AiUserServiceImpl implements IAiUserService { @Override public int updateAiUser(AiUser aiUser) { aiUser.setUpdateTime(DateUtils.getNowDate()); + if (StringUtils.isNotEmpty(aiUser.getPassword())) { + aiUser.setPassword(SecurityUtils.encryptPassword(aiUser.getPassword())); + } else { + aiUser.setPassword(null); + } return aiUserMapper.updateById(aiUser); }