package com.ruoyi.tms.service.impl;
|
|
import java.util.List;
|
|
import com.ruoyi.common.utils.DateUtils;
|
import javax.annotation.Resource;
|
|
import com.ruoyi.tms.domain.TmsApBillItem;
|
import com.ruoyi.tms.domain.TmsArBillItem;
|
import com.ruoyi.tms.mapper.TmsApBillItemMapper;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.stereotype.Service;
|
import org.springframework.scheduling.annotation.Async;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.ruoyi.common.utils.PageUtils;
|
import com.ruoyi.common.constant.Constants;
|
import com.ruoyi.common.annotation.DataSource;
|
import com.ruoyi.common.enums.DataSourceType;
|
import com.ruoyi.common.core.service.BaseService;
|
|
import com.ruoyi.tms.mapper.TmsApBillMapper;
|
import com.ruoyi.tms.domain.TmsApBill;
|
import com.ruoyi.tms.service.ITmsApBillService;
|
import com.ruoyi.common.core.text.Convert;
|
import com.ruoyi.tms.mapper.TmsPayableFeeMapper;
|
import com.ruoyi.tms.domain.TmsPayableFee;
|
import com.ruoyi.tms.domain.TmsPayableFeeItem;
|
import com.ruoyi.tms.mapper.TmsPayableFeeItemMapper;
|
import org.springframework.beans.factory.annotation.Autowired;
|
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.web.client.RestTemplate;
|
import com.alibaba.fastjson2.JSON;
|
import com.ruoyi.tms.domain.PayableAuditLog;
|
import com.ruoyi.tms.service.IPayableAuditLogService;
|
|
/**
|
* 应付账单Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2026-01-12
|
*/
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class TmsApBillServiceImpl extends BaseService<TmsApBillMapper, TmsApBill> implements ITmsApBillService
|
{
|
protected final Logger logger = LoggerFactory.getLogger(getClass());
|
@Resource
|
private TmsApBillMapper tmsApBillMapper;
|
|
@Resource
|
private TmsApBillItemMapper tmsApBillItemMapper;
|
|
@Resource
|
private TmsPayableFeeMapper tmsPayableFeeMapper;
|
|
@Resource
|
private TmsPayableFeeItemMapper tmsPayableFeeItemMapper;
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
@Autowired
|
private IPayableAuditLogService payableAuditLogService;
|
|
@Value("${custom.cwxtApi.url}")
|
private String url;
|
|
/**
|
* 查询应付账单
|
*
|
* @param id 应付账单ID
|
* @return 应付账单
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public TmsApBill selectTmsApBillById(Integer id)
|
{
|
TmsApBill tmsApBill = tmsApBillMapper.selectTmsApBillById(id);
|
tmsApBill.setItems(tmsApBillItemMapper.selectTmsApBillItemList(new TmsApBillItem(){{setBillId( id);setStatus(0);}}));
|
return tmsApBill;
|
}
|
|
/**
|
* 查询应付账单 记录数
|
*
|
* @param tmsApBill 应付账单
|
* @return 应付账单集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public int selectTmsApBillCount(TmsApBill tmsApBill)
|
{
|
return tmsApBillMapper.selectTmsApBillCount(tmsApBill);
|
}
|
|
/**
|
* 查询应付账单列表
|
*
|
* @param tmsApBill 应付账单
|
* @return 应付账单
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public List<TmsApBill> selectTmsApBillList(TmsApBill tmsApBill)
|
{
|
return tmsApBillMapper.selectTmsApBillList(tmsApBill);
|
}
|
|
/**
|
* 查询应付账单列表 异步 导出
|
*
|
* @param tmsApBill 应付账单
|
* @param exportKey 导出功能的唯一标识
|
* @return 应付账单集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Async
|
@Override
|
public void export(TmsApBill tmsApBill,String exportKey) {
|
|
super.export(TmsApBill.class,exportKey,"tmsApBillData",(pageNum)->{
|
PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
|
return selectTmsApBillList(tmsApBill);
|
});
|
}
|
|
|
/**
|
* 新增应付账单
|
*
|
* @param tmsApBill 应付账单
|
* @return 结果
|
*/
|
@Override
|
public int insertTmsApBill(TmsApBill tmsApBill)
|
{
|
tmsApBill.setCreateTime(DateUtils.getNowDate());
|
return tmsApBillMapper.insertTmsApBill(tmsApBill);
|
}
|
|
/**
|
* 新增应付账单[批量]
|
*
|
* @param tmsApBills 应付账单
|
* @return 结果
|
*/
|
@Override
|
public int insertTmsApBillBatch(List<TmsApBill> tmsApBills)
|
{
|
int rows = tmsApBillMapper.insertTmsApBillBatch(tmsApBills);
|
return rows;
|
}
|
|
/**
|
* 修改应付账单
|
*
|
* @param tmsApBill 应付账单
|
* @return 结果
|
*/
|
@Override
|
public int updateTmsApBill(TmsApBill tmsApBill)
|
{
|
tmsApBill.setUpdateTime(DateUtils.getNowDate());
|
return tmsApBillMapper.updateTmsApBill(tmsApBill);
|
}
|
|
/**
|
* 修改应付账单[批量]
|
*
|
* @param tmsApBills 应付账单
|
* @return 结果
|
*/
|
@Override
|
public int updateTmsApBillBatch(List<TmsApBill> tmsApBills){
|
return tmsApBillMapper.updateTmsApBillBatch(tmsApBills);
|
}
|
|
/**
|
* 删除应付账单对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsApBillByIds(String ids)
|
{
|
return deleteTmsApBillByIds(Convert.toIntArray(ids));
|
}
|
|
/**
|
* 删除应付账单对象
|
*
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsApBillByIds(Integer[] ids)
|
{
|
return tmsApBillMapper.deleteTmsApBillByIds(ids);
|
}
|
|
/**
|
* 删除应付账单信息
|
*
|
* @param id 应付账单ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteTmsApBillById(Integer id)
|
{
|
return tmsApBillMapper.deleteTmsApBillById(id);
|
}
|
|
/**
|
* 手动推送应付账单到外部系统
|
*
|
* @param id 应付账单ID
|
* @return 结果
|
*/
|
@Override
|
public void manualPushToExternalSystem(Integer id) {
|
TmsApBill tmsApBill = tmsApBillMapper.selectTmsApBillById(id);
|
if (tmsApBill == null) {
|
throw new RuntimeException("应付账单不存在");
|
}
|
|
// 查询关联的应付费用列表
|
List<TmsPayableFee> tmsPayableFeeList = tmsPayableFeeMapper.selectList(new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<TmsPayableFee>()
|
.eq(TmsPayableFee::getBillPayableId, id)
|
);
|
|
// 为每个应付费用加载明细
|
for (TmsPayableFee fee : tmsPayableFeeList) {
|
List<TmsPayableFeeItem> payableFeeItems = tmsPayableFeeItemMapper.selectTmsPayableFeeItemList(new TmsPayableFeeItem() {
|
{
|
setHeadId(fee.getId());
|
}
|
});
|
fee.setPayableFeeItems(payableFeeItems);
|
}
|
|
// 异步推送
|
AsyncTaskExecutor executor = new SimpleAsyncTaskExecutor();
|
executor.execute(() -> pushPayableToExternalSystem(tmsApBill, tmsPayableFeeList));
|
}
|
|
/**
|
* 更新推送状态
|
*
|
* @param id 应付账单ID
|
* @param pushStatus 推送状态
|
* @return 结果
|
*/
|
@Override
|
public int updatePushStatus(Integer id, Integer pushStatus) {
|
TmsApBill tmsApBill = new TmsApBill();
|
tmsApBill.setId(id);
|
tmsApBill.setPushStatus(pushStatus);
|
tmsApBill.setPushTime(DateUtils.getNowDate());
|
return tmsApBillMapper.updateTmsApBill(tmsApBill);
|
}
|
|
/**
|
* 添加应付账单审核日志
|
*
|
* @param auditLog 审核日志
|
* @return 结果
|
*/
|
public int addApBillAuditLog(PayableAuditLog auditLog) {
|
return payableAuditLogService.insertPayableAuditLog(auditLog);
|
}
|
|
/**
|
* 向外部系统推送应付数据
|
* @param tmsApBill 应付账单
|
* @param tmsPayableFeeList 应付费用列表
|
*/
|
@Async
|
protected void pushPayableToExternalSystem(TmsApBill tmsApBill, List<TmsPayableFee> tmsPayableFeeList) {
|
java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
|
try {
|
// 更新推送状态为推送中
|
tmsApBill.setPushStatus(1);
|
tmsApBill.setPushTime(DateUtils.getNowDate());
|
tmsApBillMapper.updateTmsApBill(tmsApBill);
|
|
// 构建请求体
|
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", "");
|
billMap.put("sourceSystemId", tmsApBill.getId());
|
|
// 构建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()));
|
java.math.BigDecimal rmbAmount = fee.getPayableRmbAmount();
|
java.math.BigDecimal hkbAmount = fee.getPayableHkbAmount();
|
StringBuilder amountStr = new StringBuilder();
|
if (rmbAmount.compareTo(java.math.BigDecimal.ZERO) > 0) {
|
amountStr.append(rmbAmount).append("人民币");
|
}
|
if (hkbAmount.compareTo(java.math.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());
|
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());
|
tmsApBillMapper.updateTmsApBill(tmsApBill);
|
}
|
}
|
}
|
