From b054362aaf616bfe0be0b50ae5dc2137091dbd7d Mon Sep 17 00:00:00 2001
From: zhangback <zhangback@163.com>
Date: 星期二, 09 十二月 2025 14:48:07 +0800
Subject: [PATCH] 提交
---
service/src/main/java/com/ruoyi/cwgl/service/impl/DispatchOrderServiceImpl.java | 244 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 241 insertions(+), 3 deletions(-)
diff --git a/service/src/main/java/com/ruoyi/cwgl/service/impl/DispatchOrderServiceImpl.java b/service/src/main/java/com/ruoyi/cwgl/service/impl/DispatchOrderServiceImpl.java
index 7ae20a3..dc5a30e 100644
--- a/service/src/main/java/com/ruoyi/cwgl/service/impl/DispatchOrderServiceImpl.java
+++ b/service/src/main/java/com/ruoyi/cwgl/service/impl/DispatchOrderServiceImpl.java
@@ -1,13 +1,43 @@
package com.ruoyi.cwgl.service.impl;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.lang.reflect.Method;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.List;
import java.math.BigDecimal;
import java.util.*;
+import java.util.function.Function;
import java.util.stream.Collectors;
+import java.util.stream.Stream;
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.PageUtil;
+import com.github.pagehelper.Page;
+import com.itextpdf.text.Document;
+import com.itextpdf.text.Font;
+import com.itextpdf.text.PageSize;
+import com.itextpdf.text.pdf.BaseFont;
+import com.itextpdf.text.pdf.PdfWriter;
+import com.ruoyi.common.annotation.Excel;
+import com.ruoyi.common.config.RuoYiConfig;
+import com.ruoyi.common.core.redis.RedisCache;
import com.ruoyi.common.utils.DateUtils;
import javax.annotation.Resource;
+import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.common.utils.bean.BeanUtils;
+import com.ruoyi.common.utils.file.DownloadExportUtil;
+import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.cwgl.domain.vo.DispatchOrderVo;
+import com.ruoyi.cwgl.enums.FeeTypeEnums;
+import com.ruoyi.cwgl.utils.MultiPagePdfWithImageUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+
import com.ruoyi.cwgl.domain.DispatchOrderItem;
+import com.ruoyi.cwgl.domain.vo.DispatchOrderAttachmentVo;
import com.ruoyi.cwgl.domain.vo.DispatchOrderItemVo;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
@@ -38,7 +68,8 @@
protected final Logger logger = LoggerFactory.getLogger(getClass());
@Resource
private DispatchOrderMapper dispatchOrderMapper;
-
+ @Autowired
+ private RedisCache redisCache;
/**
* 鏌ヨ璋冨害鍗�
@@ -98,16 +129,203 @@
* @param exportKey 瀵煎嚭鍔熻兘鐨勫敮涓�鏍囪瘑
* @return 璋冨害鍗曢泦鍚�
*/
- @DataSource(DataSourceType.SLAVE)
+ @DataSource(DataSourceType.CWSJ)
@Async
@Override
public void export(DispatchOrder dispatchOrder,String exportKey) {
super.export(DispatchOrder.class,exportKey,"dispatchOrderData",(pageNum)->{
PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
- return selectDispatchOrderList(dispatchOrder);
+ return selectDispatchOrderList2(dispatchOrder);
});
}
+
+ @DataSource(DataSourceType.CWSJ)
+ @Async
+ @Override
+ public void export2(DispatchOrder dispatchOrder,String exportKey) {
+
+ //鏌ヨ骞跺鍑烘暟鎹枃浠�
+ String fileName =selectListExport(dispatchOrder, "鍙拌处淇℃伅");
+ //璁剧疆鏂囦欢缂撳瓨
+ DownloadExportUtil.setDownloadFile(redisCache, exportKey, fileName);
+ }
+
+ @DataSource(DataSourceType.CWSJ)
+ public String selectListExport(DispatchOrder dispatchOrder, String fileName)
+ {
+ fileName =ExcelUtil.encodeFileName(fileName);
+ //鏁版嵁闆嗗悎
+ List<DispatchOrder> dataList = new ArrayList<>();
+ //瀵煎嚭琛ㄦ牸瀵硅薄
+ ExcelUtil<DispatchOrderVo> excelUtil = new ExcelUtil<>(DispatchOrderVo.class);
+ excelUtil.initialize("鍙拌处淇℃伅", null, Excel.Type.EXPORT);
+
+ List<DispatchOrderVo> exportList;//瀵煎嚭鐨勬暟缁�
+ int pageNum =1,i = 1;
+ boolean have=true;
+ //region寰幆鍒嗛〉鑾峰彇鏁版嵁
+ while (have) {
+ Page<Object> page = PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
+ List<DispatchOrder> dispatchOrders = selectDispatchOrderList2(dispatchOrder);
+ if (dispatchOrders != null && !dispatchOrders.isEmpty()) {
+ // 瀵煎嚭褰撳墠椤电殑鏁版嵁
+ exportList=structureData(dispatchOrders,i);
+ excelUtil.exportExcel(exportList);
+ pageNum++;
+ } else {
+ // 娌℃湁鏁版嵁鏃堕��鍑�
+ have = false;
+ }
+ }
+ excelUtil.finishExport(fileName);
+ return fileName;
+ }
+ /**
+ * 灏佽鏁版嵁
+ * @param list
+ * @return
+ */
+ @DataSource(DataSourceType.CWSJ)
+ private List<DispatchOrderVo> structureData(List<DispatchOrder> list,int i) {
+ List<DispatchOrderVo> exportList = new ArrayList<>();
+ Set<String> dispatchNos = list.stream().map(DispatchOrder::getDispatchNo).collect(Collectors.toSet());
+ Map<String, List<DispatchOrderItemVo>> itemMap = selectDispatchOrderItems(dispatchNos)
+ .stream().collect(Collectors.groupingBy(DispatchOrderItemVo::getDispatchNo));
+
+ for (DispatchOrder order : list) {
+ try {
+ DispatchOrderVo vo = BeanUtil.copyProperties(order, DispatchOrderVo.class);
+ vo.setId(i++);
+
+ // 鍒濆鍖栬垂鐢ㄧ粨鏋勶細Map<瑙掕壊_甯佺, Map<璐圭敤绫诲瀷, 閲戦>>
+ Map<String, Map<FeeTypeEnums, BigDecimal>> feeMap = initFeeMap();
+ Map<String, BigDecimal> totalMap = initTotalMap();
+ List<DispatchOrderItemVo> items = itemMap.get(order.getDispatchNo());
+ if (items != null) {
+ for (DispatchOrderItemVo item : items) {
+ if (!StringUtils.isNotEmpty(item.getFeeItem()) || item.getIsSettlement() == 0) continue;
+
+ FeeTypeEnums feeType = FeeTypeEnums.from(item.getFeeItem());
+ String actualCurrency = Optional.ofNullable(item.getActualFeeCurrency()).orElse("CNY");
+ String receivableCurrency = Optional.ofNullable(item.getReceivableFeeCurrency()).orElse("CNY");
+
+
+ addFee(feeMap, "customer_" + actualCurrency, feeType, item.getActualFee());
+ addTotal(totalMap, "customer_" + actualCurrency, item.getActualFee());
+
+ addFee(feeMap, "supplier_" + receivableCurrency, feeType, item.getReceivableFee());
+ addTotal(totalMap, "supplier_" + receivableCurrency, item.getReceivableFee());
+
+
+ }
+ }
+
+ // 璁剧疆 VO 瀛楁
+ setFeeToVo(vo, feeMap, totalMap);
+
+ exportList.add(vo);
+ } catch (Exception e) {
+ logger.error("鏁版嵁澶勭悊澶辫触 id锛歿}", order, e);
+ }
+ }
+
+ return exportList;
+ }
+ private Map<String, Map<FeeTypeEnums, BigDecimal>> initFeeMap() {
+ Map<String, Map<FeeTypeEnums, BigDecimal>> map = new HashMap<>();
+ for (String key : Arrays.asList("customer_CNY", "customer_HKD", "supplier_CNY", "supplier_HKD")) {
+ Map<FeeTypeEnums, BigDecimal> subMap = new EnumMap<>(FeeTypeEnums.class);
+ for (FeeTypeEnums feeType : FeeTypeEnums.values()) {
+ subMap.put(feeType, BigDecimal.ZERO);
+ }
+ map.put(key, subMap);
+ }
+ return map;
+ }
+
+ private Map<String, BigDecimal> initTotalMap() {
+ Map<String, BigDecimal> totalMap = new HashMap<>();
+ for (String key : Arrays.asList("customer_CNY", "customer_HKD", "supplier_CNY", "supplier_HKD")) {
+ totalMap.put(key, BigDecimal.ZERO);
+ }
+ return totalMap;
+ }
+
+ private void addFee(Map<String, Map<FeeTypeEnums, BigDecimal>> map, String key, FeeTypeEnums feeType, BigDecimal amount) {
+ if (amount == null) return;
+ Map<FeeTypeEnums, BigDecimal> subMap = map.get(key);
+ subMap.put(feeType, subMap.get(feeType).add(amount));
+ }
+ private void addTotal(Map<String, BigDecimal> totalMap, String key, BigDecimal amount) {
+ if (amount == null) return;
+ totalMap.put(key, totalMap.get(key).add(amount));
+ }
+
+ private void setFeeToVo(DispatchOrderVo vo,
+ Map<String, Map<FeeTypeEnums, BigDecimal>> map,
+ Map<String, BigDecimal> totalMap) {
+
+ for (String role : Arrays.asList("Customer", "Supplier")) {
+ for (String currency : Arrays.asList("Rmb", "Hkd")) {
+ String mapKey = role.toLowerCase() + "_" + ("Rmb".equals(currency) ? "CNY" : "HKD");
+ Map<FeeTypeEnums, BigDecimal> feeTypeMap = map.get(mapKey);
+
+ for (FeeTypeEnums feeType : FeeTypeEnums.values()) {
+ String methodName = "set" + role + feeType.getFieldSuffix() + currency;
+ invokeSetter(vo, methodName, feeTypeMap.get(feeType));
+ }
+
+ // 璁剧疆 total 瀛楁
+ String totalMethod = "set" + role + "Total" + currency;
+ invokeSetter(vo, totalMethod, totalMap.get(mapKey));
+ }
+ }
+ }
+ private void invokeSetter(Object obj, String methodName, BigDecimal value) {
+ try {
+ Method method = obj.getClass().getMethod(methodName, BigDecimal.class);
+ method.invoke(obj, value);
+ } catch (Exception e) {
+ logger.warn("璋冪敤鏂规硶澶辫触: {}", methodName, e);
+ }
+ }
+
+
+ @DataSource(DataSourceType.CWSJ)
+ public List<DispatchOrderItemVo> selectDispatchOrderItems( Set<String> nos) {
+ // 浣跨敤Map鏉ヤ复鏃跺瓨鍌ㄥ垎缁勭粨鏋�
+ List<DispatchOrderItemVo> vos = new ArrayList<>();
+ List<DispatchOrderItem> dispatchOrderItems=dispatchOrderMapper.selectDispatchOrderItemByNos(nos);
+ for (DispatchOrderItem dispatchOrderItem : dispatchOrderItems) {
+ HashSet<String> settableFeeItemSet = new HashSet<>(
+ Arrays.asList(Optional.ofNullable(dispatchOrderItem.getSettableFeeItems()).orElse("").split(",")));
+
+ // 鍒ゆ柇鏄惁鍙粨绠�
+ String feeItem = Optional.ofNullable(dispatchOrderItem.getFeeItem()).orElse("");
+ int isSettable = settableFeeItemSet.contains(feeItem)?1:0;
+ // 濡傛灉Map涓笉瀛樺湪璇ヨ垂鐢ㄧ被鍨嬶紝鍒欏垱寤烘柊鏉＄洰
+
+ DispatchOrderItemVo summary = new DispatchOrderItemVo();
+ summary.setDispatchNo(dispatchOrderItem.getDispatchNo());
+ summary.setFeeItem(feeItem);
+ summary.setReceivableFee(BigDecimal.ZERO);
+ summary.setActualFee(BigDecimal.ZERO);
+ summary.setIsSettlement(isSettable);
+
+ if ("R".equals(dispatchOrderItem.getBillType())) { // 搴旀敹
+ summary.setReceivableFee(dispatchOrderItem.getSettleFee());
+ summary.setReceivableFeeCurrency(dispatchOrderItem.getCurrencyType());
+ } else if ("P".equals(dispatchOrderItem.getBillType())) { // 搴斾粯
+ summary.setActualFee(dispatchOrderItem.getSettleFee());
+ summary.setActualFeeCurrency(dispatchOrderItem.getCurrencyType());
+
+ }
+ vos.add( summary);
+ }
+ return vos;
+ }
+
/**
@@ -227,8 +445,11 @@
DispatchOrderItemVo summary = summaryMap.get(feeItem);
if ("R".equals(dispatchOrderItem.getBillType())) { // 搴旀敹
summary.setReceivableFee(summary.getReceivableFee().add(dispatchOrderItem.getSettleFee()));
+ summary.setReceivableFeeCurrency(dispatchOrderItem.getCurrencyType());
} else if ("P".equals(dispatchOrderItem.getBillType())) { // 搴斾粯
summary.setActualFee(summary.getActualFee().add(dispatchOrderItem.getSettleFee()));
+ summary.setActualFeeCurrency(dispatchOrderItem.getCurrencyType());
+
}
}
// 杞崲涓篖ist骞惰繃婊ゃ�佹帓搴�
@@ -260,4 +481,21 @@
return 0;
}
+
+ @DataSource(DataSourceType.CWSJ)
+ @Override
+ public List<DispatchOrderAttachmentVo> selectDispatchOrderAttachment(String no) {
+ return dispatchOrderMapper.selectDispatchOrderAttachment(no);
+ }
+
+ @DataSource(DataSourceType.CWSJ)
+ @Override
+ public String downAttachment(String no) throws Exception {
+ List<DispatchOrderAttachmentVo> dispatchOrderAttachmentVos = selectDispatchOrderAttachment(no);
+ return MultiPagePdfWithImageUtils.createPdf(dispatchOrderAttachmentVos, no);
+ }
+
+
+
+
}
--
Gitblit v1.8.0