diff --git a/src/Oms.Application/Dtos/Xhs/XhsDtos.cs b/src/Oms.Application/Dtos/Xhs/XhsDtos.cs index c1ed96c..7bd4919 100644 --- a/src/Oms.Application/Dtos/Xhs/XhsDtos.cs +++ b/src/Oms.Application/Dtos/Xhs/XhsDtos.cs @@ -136,6 +136,11 @@ public class XhsTaskReportInput public string? ErrorMessage { get; set; } } +public class XhsTaskReportOutput +{ + public bool Ok { get; set; } = true; +} + public class XhsTaskListInput : XhsPageInput { public string? Status { get; set; } diff --git a/src/Oms.Application/Services/Xhs/XhsTaskService.cs b/src/Oms.Application/Services/Xhs/XhsTaskService.cs index 3df157b..40fcafb 100644 --- a/src/Oms.Application/Services/Xhs/XhsTaskService.cs +++ b/src/Oms.Application/Services/Xhs/XhsTaskService.cs @@ -43,7 +43,7 @@ public class XhsTaskService : ApplicationService } [HttpPost("/xhs/task/report")] - public async Task ReportAsync(XhsTaskReportInput input) + public async Task ReportAsync(XhsTaskReportInput input) { var customerId = await OmsSessionHelper.ResolveXhsCustomerIdAsync(CustomerRepository, CurrentUser); var task = await TaskRepository.FirstOrDefaultAsync(x => x.Id == input.TaskId); @@ -80,6 +80,7 @@ public class XhsTaskService : ApplicationService await TaskRepository.UpdateAsync(task); await SyncPublishRecordAsync(task, status, input); await SyncAnalysisSessionAsync(task, status, input); + return new XhsTaskReportOutput(); } [HttpPost("/xhs/task/list")] @@ -104,7 +105,7 @@ public class XhsTaskService : ApplicationService } [HttpPost("/xhs/task/cancel")] - public async Task CancelAsync(XhsTaskCancelInput input) + public async Task CancelAsync(XhsTaskCancelInput input) { var customerId = await OmsSessionHelper.ResolveXhsCustomerIdAsync(CustomerRepository, CurrentUser); var task = await TaskRepository.FirstOrDefaultAsync(x => x.Id == input.TaskId); @@ -121,6 +122,7 @@ public class XhsTaskService : ApplicationService task.Status = XhsTaskStatusCodes.Cancelled; task.FinishedAt = DateTime.Now; await TaskRepository.UpdateAsync(task); + return new XhsTaskReportOutput(); } private async Task SyncAnalysisSessionAsync(XhsTask task, string status, XhsTaskReportInput input)