wujianwei
2025-12-24 02737773121c421314d8c97daf9a320713afb7dd
应付接口
4个文件已修改
126 ■■■■■ 已修改文件
service/src/main/java/com/ruoyi/cwgl/controller/ReceivableFeeManagementController.java 25 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/src/main/java/com/ruoyi/cwgl/service/IReceivableFeeManagementService.java 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/src/main/java/com/ruoyi/cwgl/service/impl/PayableFeeManagementServiceImpl.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java 82 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
service/src/main/java/com/ruoyi/cwgl/controller/ReceivableFeeManagementController.java
@@ -11,6 +11,7 @@
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.multipart.MultipartFile;
import com.ruoyi.common.utils.file.DownloadExportUtil;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.core.controller.BaseController;
@@ -140,4 +141,28 @@
    {
        return toAjax(receivableFeeManagementService.voidReceivableFeeManagement(id));
    }
    /**
     * 导入应收费用管理数据
     */
    @Log(title = "应收费用管理", businessType = BusinessType.IMPORT)
    @PreAuthorize("@ss.hasPermi('cwgl:receivableFeeManagement:import')")
    @PostMapping("/importData")
    public AjaxResult importData(MultipartFile file, boolean updateSupport) throws Exception
    {
        ExcelUtil<ReceivableFeeManagement> util = new ExcelUtil<ReceivableFeeManagement>(ReceivableFeeManagement.class);
        List<ReceivableFeeManagement> receivableFeeList = util.importExcel(file.getInputStream());
        String message = receivableFeeManagementService.importReceivableFee(receivableFeeList, updateSupport, getUsername());
        return success(message);
    }
    /**
     * 下载导入模板
     */
    @GetMapping("/importTemplate")
    public AjaxResult importTemplate(String exportKey)
    {
        receivableFeeManagementService.importTemplate(exportKey);
        return AjaxResult.success("导出请求成功,请稍后点击下载...!");
    }
}
service/src/main/java/com/ruoyi/cwgl/service/IReceivableFeeManagementService.java
@@ -128,5 +128,22 @@
     * @return 结果
     */
    public int updateReceivableFeeManagementByRelatedBillNo(String relatedBillNo);
    /**
     * 导入应收费用管理数据
     *
     * @param receivableFeeList 应收费用管理数据列表
     * @param updateSupport 是否更新支持,如果已存在,则进行更新数据
     * @param operName 操作用户
     * @return 结果
     */
    public String importReceivableFee(List<ReceivableFeeManagement> receivableFeeList, Boolean updateSupport, String operName);
    /**
     * 下载导入模板
     *
     * @param exportKey 导出功能的唯一标识
     */
    public void importTemplate(String exportKey);
}
service/src/main/java/com/ruoyi/cwgl/service/impl/PayableFeeManagementServiceImpl.java
@@ -217,7 +217,7 @@
            // 设置每个明细的应付费用管理ID
            payableFeeManagement.getPayableFeeDetailList().forEach(detail -> {
                detail.setPayableFeeId(payableFeeId);
                detail.setUpdateTime(DateUtils.getNowDate()); // 设置更新时间
                detail.setCreateTime(DateUtils.getNowDate()); // 设置更新时间
            });
            
            // 调用批量插入方法
service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableFeeManagementServiceImpl.java
@@ -215,7 +215,7 @@
            // 设置每个明细的应收费用管理ID
            receivableFeeManagement.getReceivableFeeDetailList().forEach(detail -> {
                detail.setReceivableFeeId(receivableFeeId);
                detail.setUpdateTime(DateUtils.getNowDate()); // 设置更新时间
                detail.setCreateTime(DateUtils.getNowDate()); // 设置更新时间
            });
            
            // 调用批量插入方法
@@ -562,4 +562,84 @@
        
        return sb.toString();
    }
    /**
     * 导入应收费用管理数据
     *
     * @param receivableFeeList 应收费用管理数据列表
     * @param updateSupport 是否更新支持,如果已存在,则进行更新数据
     * @param operName 操作用户
     * @return 结果
     */
    @Override
    public String importReceivableFee(List<ReceivableFeeManagement> receivableFeeList, Boolean updateSupport, String operName) {
        if (receivableFeeList == null || receivableFeeList.isEmpty()) {
            return "导入用户数据不能为空!";
        }
        int successNum = 0;
        int failureNum = 0;
        StringBuilder successMsg = new StringBuilder();
        StringBuilder failureMsg = new StringBuilder();
        for (ReceivableFeeManagement receivableFee : receivableFeeList) {
            try {
                // 验证系统编号是否唯一
                ReceivableFeeManagement checkFee = new ReceivableFeeManagement();
                checkFee.setSystemNo(receivableFee.getSystemNo());
                List<ReceivableFeeManagement> existingFees = selectReceivableFeeManagementList(checkFee);
                if (!existingFees.isEmpty()) {
                    // 存在重复记录
                    if (updateSupport) {
                        // 更新支持,进行更新操作
                        ReceivableFeeManagement existingFee = existingFees.get(0);
                        receivableFee.setId(existingFee.getId());
                        receivableFee.setUpdateTime(DateUtils.getNowDate());
                        receivableFee.setUpdateBy(operName);
                        updateReceivableFeeManagement(receivableFee);
                        successNum++;
                        successMsg.append("<br/>" + successNum + ". 系统编号 " + receivableFee.getSystemNo() + " 更新成功");
                    } else {
                        failureNum++;
                        failureMsg.append("<br/>" + failureNum + ". 系统编号 " + receivableFee.getSystemNo() + " 已存在");
                    }
                } else {
                    // 新增记录
                    receivableFee.setCreateTime(DateUtils.getNowDate());
                    receivableFee.setCreateBy(operName);
                    insertReceivableFeeManagement(receivableFee);
                    successNum++;
                    successMsg.append("<br/>" + successNum + ". 系统编号 " + receivableFee.getSystemNo() + " 导入成功");
                }
            } catch (Exception e) {
                failureNum++;
                String msg = "<br/>" + failureNum + ". 系统编号 " + receivableFee.getSystemNo() + " 导入失败:";
                failureMsg.append(msg + e.getMessage());
                logger.error(msg, e);
            }
        }
        if (failureNum > 0) {
            failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
            throw new ServiceException(failureMsg.toString());
        } else {
            successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
        }
        return successMsg.toString();
    }
    /**
     * 下载导入模板
     *
     * @param exportKey 导出功能的唯一标识
     */
    @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void importTemplate(String exportKey) {
        super.export(ReceivableFeeManagement.class, exportKey, "receivableFeeManagementTemplate", (pageNum) -> {
            // 返回空列表,只导出模板结构
            return new ArrayList<ReceivableFeeManagement>();
        });
    }
}