diff --git a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/controller/CcdiPurchaseTransactionController.java b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/controller/CcdiPurchaseTransactionController.java index 96b1c78..2c44d57 100644 --- a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/controller/CcdiPurchaseTransactionController.java +++ b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/controller/CcdiPurchaseTransactionController.java @@ -6,7 +6,7 @@ import com.ruoyi.ccdi.domain.dto.CcdiPurchaseTransactionEditDTO; import com.ruoyi.ccdi.domain.dto.CcdiPurchaseTransactionQueryDTO; import com.ruoyi.ccdi.domain.excel.CcdiPurchaseTransactionExcel; import com.ruoyi.ccdi.domain.vo.CcdiPurchaseTransactionVO; -import com.ruoyi.ccdi.domain.vo.ImportFailureVO; +import com.ruoyi.ccdi.domain.vo.PurchaseTransactionImportFailureVO; import com.ruoyi.ccdi.domain.vo.ImportStatusVO; import com.ruoyi.ccdi.service.ICcdiPurchaseTransactionImportService; import com.ruoyi.ccdi.service.ICcdiPurchaseTransactionService; @@ -164,7 +164,7 @@ public class CcdiPurchaseTransactionController extends BaseController { @PreAuthorize("@ss.hasPermi('ccdi:purchaseTransaction:import')") @GetMapping("/importFailures/{taskId}") public AjaxResult getImportFailures(@PathVariable String taskId) { - List failures = transactionImportService.getImportFailures(taskId); + List failures = transactionImportService.getImportFailures(taskId); return success(failures); } } diff --git a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/ICcdiPurchaseTransactionImportService.java b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/ICcdiPurchaseTransactionImportService.java index f4ccdd0..2af4c1f 100644 --- a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/ICcdiPurchaseTransactionImportService.java +++ b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/ICcdiPurchaseTransactionImportService.java @@ -1,7 +1,7 @@ package com.ruoyi.ccdi.service; import com.ruoyi.ccdi.domain.excel.CcdiPurchaseTransactionExcel; -import com.ruoyi.ccdi.domain.vo.ImportFailureVO; +import com.ruoyi.ccdi.domain.vo.PurchaseTransactionImportFailureVO; import com.ruoyi.ccdi.domain.vo.ImportStatusVO; import java.util.List; @@ -38,5 +38,5 @@ public interface ICcdiPurchaseTransactionImportService { * @param taskId 任务ID * @return 失败记录列表 */ - List getImportFailures(String taskId); + List getImportFailures(String taskId); } diff --git a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/impl/CcdiPurchaseTransactionImportServiceImpl.java b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/impl/CcdiPurchaseTransactionImportServiceImpl.java index 74b585a..b263404 100644 --- a/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/impl/CcdiPurchaseTransactionImportServiceImpl.java +++ b/ruoyi-ccdi/src/main/java/com/ruoyi/ccdi/service/impl/CcdiPurchaseTransactionImportServiceImpl.java @@ -5,7 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.ruoyi.ccdi.domain.CcdiPurchaseTransaction; import com.ruoyi.ccdi.domain.dto.CcdiPurchaseTransactionAddDTO; import com.ruoyi.ccdi.domain.excel.CcdiPurchaseTransactionExcel; -import com.ruoyi.ccdi.domain.vo.ImportFailureVO; +import com.ruoyi.ccdi.domain.vo.PurchaseTransactionImportFailureVO; import com.ruoyi.ccdi.domain.vo.ImportResult; import com.ruoyi.ccdi.domain.vo.ImportStatusVO; import com.ruoyi.ccdi.mapper.CcdiPurchaseTransactionMapper; @@ -46,7 +46,7 @@ public class CcdiPurchaseTransactionImportServiceImpl implements ICcdiPurchaseTr public void importTransactionAsync(List excelList, Boolean isUpdateSupport, String taskId, String userName) { List newRecords = new ArrayList<>(); List updateRecords = new ArrayList<>(); - List failures = new ArrayList<>(); + List failures = new ArrayList<>(); // 批量查询已存在的采购事项ID Set existingIds = getExistingPurchaseIds(excelList); @@ -75,11 +75,12 @@ public class CcdiPurchaseTransactionImportServiceImpl implements ICcdiPurchaseTr } } else { transaction.setCreatedBy(userName); + transaction.setUpdatedBy(userName); newRecords.add(transaction); } } catch (Exception e) { - ImportFailureVO failure = new ImportFailureVO(); + PurchaseTransactionImportFailureVO failure = new PurchaseTransactionImportFailureVO(); BeanUtils.copyProperties(excel, failure); failure.setErrorMessage(e.getMessage()); failures.add(failure); @@ -119,7 +120,7 @@ public class CcdiPurchaseTransactionImportServiceImpl implements ICcdiPurchaseTr * @return 失败记录列表 */ @Override - public List getImportFailures(String taskId) { + public List getImportFailures(String taskId) { String key = "import:purchaseTransaction:" + taskId + ":failures"; Object failuresObj = redisTemplate.opsForValue().get(key); @@ -127,7 +128,7 @@ public class CcdiPurchaseTransactionImportServiceImpl implements ICcdiPurchaseTr return Collections.emptyList(); } - return JSON.parseArray(JSON.toJSONString(failuresObj), ImportFailureVO.class); + return JSON.parseArray(JSON.toJSONString(failuresObj), PurchaseTransactionImportFailureVO.class); } /**