| | |
| | | |
| | | import java.math.BigDecimal; |
| | | import java.math.RoundingMode; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | import java.util.Objects; |
| | | import java.util.*; |
| | | |
| | | import com.ruoyi.common.enums.SystemDataNoEnum; |
| | | import com.ruoyi.common.exception.ServiceException; |
| | |
| | | String noByKey = systemDataNoService.getNoByKey(SystemDataNoEnum.YS); |
| | | receivableFeeManagement.setSystemNo(noByKey); |
| | | |
| | | // 计算应收金额字符串描述 |
| | | if (receivableFeeManagement.getReceivableFeeDetailList() != null && !receivableFeeManagement.getReceivableFeeDetailList().isEmpty()) { |
| | | String receivableAmountStr = calculateReceivableAmountStr(receivableFeeManagement.getReceivableFeeDetailList()); |
| | | receivableFeeManagement.setReceivableAmountStr(receivableAmountStr); |
| | | } |
| | | receivableFeeManagement.setCreateBy(SecurityUtils.getUsername()); |
| | | // 保存主表信息 |
| | | int result = receivableFeeManagementMapper.insertReceivableFeeManagement(receivableFeeManagement); |
| | | |
| | |
| | | { |
| | | receivableFeeManagement.setUpdateTime(DateUtils.getNowDate()); |
| | | |
| | | // 计算应收金额字符串描述 |
| | | if (receivableFeeManagement.getReceivableFeeDetailList() != null && !receivableFeeManagement.getReceivableFeeDetailList().isEmpty()) { |
| | | String receivableAmountStr = calculateReceivableAmountStr(receivableFeeManagement.getReceivableFeeDetailList()); |
| | | receivableFeeManagement.setReceivableAmountStr(receivableAmountStr); |
| | | } |
| | | |
| | | // 1. 更新主表信息 |
| | | int result = receivableFeeManagementMapper.updateReceivableFeeManagement(receivableFeeManagement); |
| | | |
| | |
| | | // 设置每个明细的应收费用管理ID |
| | | receivableFeeManagement.getReceivableFeeDetailList().forEach(detail -> { |
| | | detail.setReceivableFeeId(receivableFeeId); |
| | | detail.setUpdateTime(DateUtils.getNowDate()); // 设置更新时间 |
| | | detail.setCreateTime(DateUtils.getNowDate()); // 设置更新时间 |
| | | }); |
| | | |
| | | // 调用批量插入方法 |
| | |
| | | SysConfig sysConfig = sysConfigMapper.selectConfig(new SysConfig() {{ |
| | | setConfigKey("sys.hk.rmb.rate"); |
| | | }}); |
| | | // 计算总应收金额 |
| | | BigDecimal totalReceivableAmount = receivableFeeList.stream() |
| | | .map(ReceivableFeeManagement::getReceivableAmount) |
| | | .reduce(BigDecimal.ZERO, BigDecimal::add); |
| | | // 计算总应收金额(按币种分别计算) |
| | | BigDecimal totalAmountRmb = BigDecimal.ZERO; |
| | | BigDecimal totalAmountHkd = BigDecimal.ZERO; |
| | | |
| | | |
| | | // 获取所有应收费用明细,按币种汇总 |
| | | if (!receivableFeeList.isEmpty()) { |
| | | // 获取所有应收费用ID |
| | | Integer[] feeIds = receivableFeeList.stream() |
| | | .map(ReceivableFeeManagement::getId) |
| | | .toArray(Integer[]::new); |
| | | |
| | | // 查询所有明细记录 |
| | | List<ReceivableFeeDetail> allDetails = receivableFeeDetailService.selectReceivableFeeDetailByReceivableFeeIds(feeIds); |
| | | |
| | | // 按币种汇总金额 |
| | | for (ReceivableFeeDetail detail : allDetails) { |
| | | if (detail.getBillingAmount() != null && detail.getCurrency() != null) { |
| | | if ("RMB".equals(detail.getCurrency())) { |
| | | totalAmountRmb = totalAmountRmb.add(detail.getBillingAmount()); |
| | | } else if ("HKD".equals(detail.getCurrency())) { |
| | | totalAmountHkd = totalAmountHkd.add(detail.getBillingAmount()); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | |
| | | BigDecimal exchangeRate = new BigDecimal(sysConfig.getConfigValue()); |
| | | BigDecimal totalAmountHkd = totalReceivableAmount.divide(exchangeRate, 2, RoundingMode.HALF_UP); |
| | | |
| | | // 计算人民币总金额(人民币金额 + 港币换算成人民币) |
| | | BigDecimal totalAmountRmbWithConversion = totalAmountRmb.add( |
| | | totalAmountHkd.multiply(exchangeRate).setScale(2, RoundingMode.HALF_UP) |
| | | ); |
| | | |
| | | // 计算港币总金额(港币金额 + 人民币换算成港币) |
| | | BigDecimal totalAmountHkdWithConversion = totalAmountHkd.add( |
| | | totalAmountRmb.divide(exchangeRate, 2, RoundingMode.HALF_UP) |
| | | ); |
| | | |
| | | |
| | | // 组装返回结果 |
| | | ReceivableFeeStatisticsVo result = new ReceivableFeeStatisticsVo(); |
| | | result.setDocumentCount(documentCount); |
| | | result.setRate(exchangeRate); |
| | | result.setTotalReceivableAmount(totalReceivableAmount); |
| | | result.setTotalAmountRmb(totalReceivableAmount); |
| | | result.setTotalAmountHkd(totalAmountHkd); |
| | | result.setTotalReceivableAmount(totalAmountRmbWithConversion); // 默认使用人民币总金额 |
| | | result.setTotalAmountRmb(totalAmountRmbWithConversion); |
| | | result.setTotalAmountHkd(totalAmountHkdWithConversion); |
| | | result.setIds(ids); |
| | | |
| | | return result; |
| | |
| | | billManagement.setCreateTime(DateUtils.getNowDate()); |
| | | billManagement.setBillName(billCreateVo.getBillName()); |
| | | billManagement.setCustomerName(billCreateVo.getCustomerName()); |
| | | billManagement.setCreateBy(SecurityUtils.getUsername()); |
| | | billManagement.setIsInternalSettlement(billCreateVo.getIsInternalSettlement()); |
| | | billManagement.setInternalSettlementUnit(billCreateVo.getInternalSettlementUnit()); |
| | | // 3. 根据账单类型设置币种和总金额 |
| | | if (billType == 0) { |
| | | // 人民币账单 |
| | | billManagement.setCurrency("CNY"); |
| | | billManagement.setCurrency("RMB"); |
| | | billManagement.setTotalAmount(statisticsVo.getTotalAmountRmb()); |
| | | } else if (billType == 1) { |
| | | // 港币账单 |
| | |
| | | } else { |
| | | throw new IllegalArgumentException("无效的账单类型:" + billType); |
| | | } |
| | | billManagement.setPendingAmount(billManagement.getTotalAmount()); |
| | | String noByKey = systemDataNoService.getNoByKey(SystemDataNoEnum.YSZD); |
| | | billManagement.setSystemNo(noByKey); |
| | | // 4. 保存主账单记录 |
| | |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | } |
| | | /** |
| | | * 根据关联账单编号批量更新应收费用管理记录 |
| | | * 清除关联账单编号并将状态改为0(待生成账单) |
| | | * |
| | | * @param relatedBillNo 关联账单编号 |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public int updateReceivableFeeManagementByRelatedBillNo(String relatedBillNo) { |
| | | return receivableFeeManagementMapper.updateReceivableFeeManagementByRelatedBillNo(relatedBillNo); |
| | | } |
| | | |
| | | /** |
| | | * 计算应收金额字符串描述 |
| | | * 根据明细列表按币种汇总金额,格式如:"200港币100人民币" |
| | | * |
| | | * @param detailList 应收费用明细列表 |
| | | * @return 应收金额字符串描述 |
| | | */ |
| | | private String calculateReceivableAmountStr(List<ReceivableFeeDetail> detailList) { |
| | | if (detailList == null || detailList.isEmpty()) { |
| | | return ""; |
| | | } |
| | | |
| | | // 按币种汇总金额 |
| | | Map<String, BigDecimal> currencyAmountMap = new HashMap<>(); |
| | | for (ReceivableFeeDetail detail : detailList) { |
| | | String currency = detail.getCurrency(); |
| | | BigDecimal billingAmount = detail.getActualAmount(); |
| | | |
| | | if (currency != null && billingAmount != null) { |
| | | currencyAmountMap.merge(currency, billingAmount, BigDecimal::add); |
| | | } |
| | | } |
| | | |
| | | // 构建字符串描述 |
| | | StringBuilder sb = new StringBuilder(); |
| | | for (Map.Entry<String, BigDecimal> entry : currencyAmountMap.entrySet()) { |
| | | if (sb.length() > 0) { |
| | | sb.append(" "); |
| | | } |
| | | sb.append(entry.getValue().stripTrailingZeros().toPlainString()); |
| | | |
| | | // 根据币种显示对应的货币名称 |
| | | String currency = entry.getKey(); |
| | | if ("RMB".equals(currency)) { |
| | | sb.append("人民币"); |
| | | } else if ("HKD".equals(currency)) { |
| | | sb.append("港币"); |
| | | } else if ("USD".equals(currency)) { |
| | | sb.append("美元"); |
| | | } else { |
| | | sb.append(currency); |
| | | } |
| | | } |
| | | |
| | | return sb.toString(); |
| | | } |
| | | |
| | | /** |
| | | * 导入应收费用管理数据(包含明细数据) |
| | | * |
| | | * @param receivableFeeList 应收费用管理数据列表(包含明细数据) |
| | | * @param operName 操作用户 |
| | | * @return 结果 |
| | | */ |
| | | @Override |
| | | public String importReceivableFee(List<ReceivableFeeManagement> receivableFeeList, 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 { |
| | | // 自动生成系统编号(和新增功能一样) |
| | | String noByKey = systemDataNoService.getNoByKey(SystemDataNoEnum.YS); |
| | | receivableFee.setSystemNo(noByKey); |
| | | |
| | | // 设置创建时间和创建人 |
| | | receivableFee.setCreateTime(DateUtils.getNowDate()); |
| | | receivableFee.setCreateBy(operName); |
| | | |
| | | // 计算应收金额字符串描述 |
| | | if (receivableFee.getReceivableFeeDetailList() != null && !receivableFee.getReceivableFeeDetailList().isEmpty()) { |
| | | String receivableAmountStr = calculateReceivableAmountStr(receivableFee.getReceivableFeeDetailList()); |
| | | receivableFee.setReceivableAmountStr(receivableAmountStr); |
| | | } |
| | | |
| | | // 新增记录(不做存在性判断) |
| | | int result = insertReceivableFeeManagement(receivableFee); |
| | | |
| | | if (result > 0) { |
| | | successNum++; |
| | | successMsg.append("<br/>" + successNum + ". 系统编号 " + receivableFee.getSystemNo() + " 导入成功"); |
| | | } else { |
| | | failureNum++; |
| | | failureMsg.append("<br/>" + failureNum + ". 系统编号 " + receivableFee.getSystemNo() + " 导入失败"); |
| | | } |
| | | } catch (Exception e) { |
| | | failureNum++; |
| | | String msg = "<br/>" + failureNum + ". 系统编号 " + (receivableFee.getSystemNo() != null ? 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>(); |
| | | }); |
| | | } |
| | | } |