springboot2+avue
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wujianwei
2026-04-01 8f30b77a480f8921bffe2bf176bf3479f5bcbedc 
 tms/src/main/java/com/ruoyi/tms/service/impl/TmsPayableFeeServiceImpl.java


@@ -19,11 +19,21 @@


import com.ruoyi.tms.domain.*;


import com.ruoyi.tms.mapper.*;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.core.task.AsyncTaskExecutor;


import org.springframework.core.task.SimpleAsyncTaskExecutor;


import org.springframework.http.HttpEntity;


import org.springframework.http.HttpHeaders;


import org.springframework.http.HttpMethod;


import org.springframework.http.MediaType;


import org.springframework.http.ResponseEntity;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.scheduling.annotation.Async;


import org.springframework.web.client.RestTemplate;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;


import com.alibaba.fastjson2.JSON;


import com.ruoyi.common.utils.PageUtils;


import com.ruoyi.common.constant.Constants;


import com.ruoyi.common.annotation.DataSource;


@@ -61,7 +71,10 @@


    ISysConfigService sysConfigService;


    @Autowired


    ISystemDataNoService systemDataNoService;




    @Autowired


    private RestTemplate restTemplate;


    @Value("${custom.cwxtApi.url}")


    private String url;


    /**


     * 查询应付费用


     *


@@ -265,7 +278,10 @@




        tmsApBill.setSettleAmount(BigDecimal.ZERO);


        tmsPayableFeeList.forEach(item ->{




            List<TmsPayableFeeItem> tmsPayableFeeItems = tmsPayableFeeItemMapper.selectTmsPayableFeeItemList(new TmsPayableFeeItem() {{


                setHeadId(item.getId());


            }});


            item.setPayableFeeItems(tmsPayableFeeItems);


            BigDecimal rmbAmount = item.getPayableHkbAmount()


                    .multiply(exchangeRate)


                    .setScale(2, RoundingMode.HALF_UP);


@@ -286,6 +302,7 @@


        tmsApBill.setSettledAmount(BigDecimal.ZERO);


        tmsApBill.setInvoiceStatus(0);


        tmsApBill.setStatus(0);


        tmsApBill.setPushStatus(0); // 初始推送状态：未推送


        tmsApBill.setCreateBy(SecurityUtils.getUsername());


        tmsApBillMapper.insertTmsApBill(tmsApBill);




@@ -312,8 +329,138 @@


        if (!rmb.isEmpty()){


            tmsApBillItemMapper.insertTmsApBillItemBatch(rmb);


        }


        


        //向外部系统推送数据


        AsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();


        executor.execute(() -> pushPayableToExternalSystem(tmsApBill, tmsPayableFeeList));




        return AjaxResult.success();


    }


    


    /**


     * 向外部系统推送应付数据


     * @param tmsApBill 应付账单


     * @param tmsPayableFeeList 应付费用列表


     */


    @Async


    protected void pushPayableToExternalSystem(TmsApBill tmsApBill, List<TmsPayableFee> tmsPayableFeeList) {


        java.util.Map<String, Object> requestBody = new java.util.HashMap<>();


        try {


            // 构建请求体


            String apiUrl = url+"/addPayableBill";


            


            // 构建bill部分


            java.util.Map<String, Object> billMap = new java.util.HashMap<>();


            billMap.put("billName", tmsApBill.getBillName());


            billMap.put("supplierName", tmsApBill.getServiceProviderName());


            billMap.put("totalAmount", tmsApBill.getSettleAmount());


            billMap.put("currency", "RMB");


            billMap.put("status", "0");


            billMap.put("isInternalSettlement", "0");


            billMap.put("internalSettlementUnit", tmsApBill.getServiceProviderName());


            billMap.put("documentCount", tmsPayableFeeList.size());


            billMap.put("discountAmount", 0.00);


            billMap.put("paidAmount", 0.00);


            billMap.put("pendingAmount", tmsApBill.getSettleAmount());


            billMap.put("exchangeRate", tmsApBill.getSettleRate());


            billMap.put("cnyAmount", tmsApBill.getSettleAmount());


            billMap.put("periodType", "");


            billMap.put("businessStartDate", "");


            billMap.put("businessEndDate", "");


            billMap.put("billingStartDate", "");


            billMap.put("billingEndDate", "");


            billMap.put("billGenerateDate", "");


            billMap.put("billSendDate", "");


            billMap.put("billDueDate", "");


            billMap.put("remark", "");


            


            // 构建fees部分


            List<java.util.Map<String, Object>> feesList = new java.util.ArrayList<>();


            for (int i = 0; i < tmsPayableFeeList.size(); i++) {


                TmsPayableFee fee = tmsPayableFeeList.get(i);


                java.util.Map<String, Object> feeMap = new java.util.HashMap<>();


                feeMap.put("sourceSystem", "TMS");


                feeMap.put("documentNo", fee.getDispatchNo() != null ? fee.getDispatchNo() : "");


                feeMap.put("supplierName", tmsApBill.getServiceProviderName());


                feeMap.put("payableAmount", fee.getPayableRmbAmount().add(fee.getPayableHkbAmount()));


                BigDecimal rmbAmount = fee.getPayableRmbAmount();


                BigDecimal hkbAmount = fee.getPayableHkbAmount();


                StringBuilder amountStr = new StringBuilder();


                if (rmbAmount.compareTo(BigDecimal.ZERO) > 0) {


                    amountStr.append(rmbAmount).append("人民币");


                }


                if (hkbAmount.compareTo(BigDecimal.ZERO) > 0) {


                    if (amountStr.length() > 0) {


                        amountStr.append(" ");


                    }


                    amountStr.append(hkbAmount).append("港币");


                }


                feeMap.put("payableAmountStr", amountStr.toString());


                feeMap.put("serialNumber", String.format("%03d", i + 1));


                feeMap.put("relatedBillNo", "");


                feeMap.put("businessSector", "0");


                feeMap.put("documentType", "0");


                feeMap.put("isInternalSettlement", "0");


                feeMap.put("internalSettlementUnit", "");


                feeMap.put("projectName", fee.getProjectName() != null ? fee.getProjectName() : "");


                feeMap.put("businessTime", fee.getDispatchConfirmTime());


                feeMap.put("payableConfirmTime", fee.getDispatchConfirmTime());


                feeMap.put("status", "1");


                feeMap.put("remark", "");


                


                // 构建feeDetails部分


                List<java.util.Map<String, Object>> feeDetailsList = new java.util.ArrayList<>();


                List<TmsPayableFeeItem> payableFeeItems = fee.getPayableFeeItems();


                for (TmsPayableFeeItem payableFeeItem : payableFeeItems) {


                    java.util.Map<String, Object> feeDetailMap = new java.util.HashMap<>();


                    feeDetailMap.put("feeType", payableFeeItem.getFeeType());


                    feeDetailMap.put("feeName", payableFeeItem.getFeeName());


                    feeDetailMap.put("unitPrice", payableFeeItem.getRegisterAmount());


                    feeDetailMap.put("billingQuantity", payableFeeItem.getRegisterAmount());


                    feeDetailMap.put("billingAmount", payableFeeItem.getRegisterAmount());


                    feeDetailMap.put("billingUnit", "次");


                    feeDetailMap.put("actualAmount", payableFeeItem.getRegisterAmount());


                    feeDetailMap.put("currency", payableFeeItem.getCurrency());


                    feeDetailMap.put("feeRegTime",payableFeeItem.getRegisterTime());


                    feeDetailMap.put("remark", "");


                    feeDetailsList.add(feeDetailMap);


                }




                


                feeMap.put("feeDetails", feeDetailsList);


                feesList.add(feeMap);


            }


            


            // 构建完整请求体


            requestBody.put("bill", billMap);


            requestBody.put("fees", feesList);


            


            // 设置HTTP头


            HttpHeaders headers = new HttpHeaders();


            headers.setContentType(MediaType.APPLICATION_JSON);


            HttpEntity<String> entity = new HttpEntity<>(JSON.toJSONString(requestBody), headers);


            


            // 发送API请求


            ResponseEntity<String> response = restTemplate.exchange(apiUrl, HttpMethod.POST, entity, String.class);


            logger.info("推送应付数据到外部系统成功，响应: {}", response.getBody());


            


            // 更新推送状态为成功


            tmsApBill.setPushStatus(2);


            tmsApBill.setPushTime(DateUtils.getNowDate());


            tmsApBill.setPushFailReason(null);


            tmsApBillMapper.updateTmsApBill(tmsApBill);


        } catch (Exception e) {


            logger.error("推送应付数据到外部系统失败，账单ID: {}, 供应商: {}", 


                tmsApBill.getId(), tmsApBill.getServiceProviderName(), e);


            logger.debug("推送失败的请求数据: {}", JSON.toJSONString(requestBody));


            


            // 更新推送状态为失败


            tmsApBill.setPushStatus(3);


            tmsApBill.setPushTime(DateUtils.getNowDate());


            tmsApBill.setPushFailReason(e.getMessage());


            tmsApBillMapper.updateTmsApBill(tmsApBill);


        }


    }




    /**


     * 删除应付费用信息