package com.ruoyi.cwgl.service.impl;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.ruoyi.common.utils.http.HttpUtils;
|
import com.ruoyi.cwgl.domain.PayableFeeManagement;
|
import com.ruoyi.cwgl.domain.ReceivableFeeManagement;
|
import com.ruoyi.cwgl.domain.dto.PayableAuditLog;
|
import com.ruoyi.cwgl.domain.dto.ReceivableAuditLog;
|
import com.ruoyi.cwgl.service.IPayableFeeManagementService;
|
import com.ruoyi.cwgl.service.IReceivableFeeManagementService;
|
import com.ruoyi.cwgl.service.ITmsAuditLogPushService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import java.util.List;
|
|
/**
|
* TMS审核日志推送服务实现类
|
*/
|
@Service
|
public class TmsAuditLogPushServiceImpl implements ITmsAuditLogPushService {
|
|
private static final Logger log = LoggerFactory.getLogger(TmsAuditLogPushServiceImpl.class);
|
|
@Value("${custom.tms.url}")
|
private String tmsBaseUrl;
|
|
@Autowired
|
private IPayableFeeManagementService payableFeeManagementService;
|
|
@Autowired
|
private IReceivableFeeManagementService receivableFeeManagementService;
|
|
@Override
|
public boolean pushPayableAuditLog(PayableAuditLog auditLog) {
|
try {
|
String url = tmsBaseUrl + "/api/third/audit/ap-bill";
|
String jsonBody = JSON.toJSONString(auditLog);
|
|
log.info("推送应付账单审核日志到TMS: {}", jsonBody);
|
|
String response = HttpUtils.sendPost(url, jsonBody);
|
log.info("TMS应付账单审核日志推送响应: {}", response);
|
|
return true;
|
} catch (Exception e) {
|
log.error("推送应付账单审核日志到TMS失败", e);
|
return false;
|
}
|
}
|
|
@Override
|
public boolean pushReceivableAuditLog(ReceivableAuditLog auditLog) {
|
try {
|
String url = tmsBaseUrl + "/api/third/audit/ar-bill";
|
String jsonBody = JSON.toJSONString(auditLog);
|
|
log.info("推送应收账单审核日志到TMS: {}", jsonBody);
|
|
String response = HttpUtils.sendPost(url, jsonBody);
|
log.info("TMS应收账单审核日志推送响应: {}", response);
|
|
return true;
|
} catch (Exception e) {
|
log.error("推送应收账单审核日志到TMS失败", e);
|
return false;
|
}
|
}
|
|
/**
|
* 判断应付账单是否来自TMS系统
|
* @param billNo 账单编号
|
* @return 是否来自TMS系统
|
*/
|
public boolean isPayableBillFromTms(String billNo) {
|
try {
|
PayableFeeManagement query = new PayableFeeManagement();
|
query.setRelatedBillNo(billNo);
|
List<PayableFeeManagement> fees = payableFeeManagementService.selectPayableFeeManagementList(query);
|
|
if (fees != null && !fees.isEmpty()) {
|
// 检查是否有费用来自TMS系统
|
return fees.stream()
|
.anyMatch(fee -> "TMS".equalsIgnoreCase(fee.getSourceSystem()));
|
}
|
return false;
|
} catch (Exception e) {
|
log.error("判断应付账单来源系统失败", e);
|
return false;
|
}
|
}
|
|
/**
|
* 判断应收账单是否来自TMS系统
|
* @param billNo 账单编号
|
* @return 是否来自TMS系统
|
*/
|
public boolean isReceivableBillFromTms(String billNo) {
|
try {
|
ReceivableFeeManagement query = new ReceivableFeeManagement();
|
query.setRelatedBillNo(billNo);
|
List<ReceivableFeeManagement> fees = receivableFeeManagementService.selectReceivableFeeManagementList(query);
|
|
if (fees != null && !fees.isEmpty()) {
|
// 检查是否有费用来自TMS系统
|
return fees.stream()
|
.anyMatch(fee -> "tms".equalsIgnoreCase(fee.getSourceSystem()));
|
}
|
return false;
|
} catch (Exception e) {
|
log.error("判断应收账单来源系统失败", e);
|
return false;
|
}
|
}
|
|
/**
|
* 获取应付账单的来源系统
|
* @param billNo 账单编号
|
* @return 来源系统，如果多个来源系统则返回第一个TMS系统，否则返回第一个非空系统
|
*/
|
public String getPayableBillSourceSystem(String billNo) {
|
try {
|
PayableFeeManagement query = new PayableFeeManagement();
|
query.setRelatedBillNo(billNo);
|
List<PayableFeeManagement> fees = payableFeeManagementService.selectPayableFeeManagementList(query);
|
|
if (fees != null && !fees.isEmpty()) {
|
// 优先返回TMS系统
|
return fees.stream()
|
.map(PayableFeeManagement::getSourceSystem)
|
.filter(source -> source != null && !source.trim().isEmpty())
|
.findFirst()
|
.orElse(null);
|
}
|
return null;
|
} catch (Exception e) {
|
log.error("获取应付账单来源系统失败", e);
|
return null;
|
}
|
}
|
|
/**
|
* 获取应收账单的来源系统
|
* @param billNo 账单编号
|
* @return 来源系统，如果多个来源系统则返回第一个TMS系统，否则返回第一个非空系统
|
*/
|
public String getReceivableBillSourceSystem(String billNo) {
|
try {
|
ReceivableFeeManagement query = new ReceivableFeeManagement();
|
query.setRelatedBillNo(billNo);
|
List<ReceivableFeeManagement> fees = receivableFeeManagementService.selectReceivableFeeManagementList(query);
|
|
if (fees != null && !fees.isEmpty()) {
|
// 优先返回TMS系统
|
return fees.stream()
|
.map(ReceivableFeeManagement::getSourceSystem)
|
.filter(source -> source != null && !source.trim().isEmpty())
|
.findFirst()
|
.orElse(null);
|
}
|
return null;
|
} catch (Exception e) {
|
log.error("获取应收账单来源系统失败", e);
|
return null;
|
}
|
}
|
}
|
