package com.by4cloud.platformx.business.service.impl;
|
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.by4cloud.platformx.business.dto.BankStatementUpdateDTO;
|
import com.by4cloud.platformx.business.dto.PaymentConfirmAddDTO;
|
import com.by4cloud.platformx.business.entity.BankStatement;
|
import com.by4cloud.platformx.business.entity.BusinessCustomer;
|
import com.by4cloud.platformx.business.entity.Contract;
|
import com.by4cloud.platformx.business.mapper.BankStatementMapper;
|
import com.by4cloud.platformx.business.mapper.BusinessCustomerMapper;
|
import com.by4cloud.platformx.business.mapper.ContractMapper;
|
import com.by4cloud.platformx.business.service.BankStatementService;
|
import com.by4cloud.platformx.business.service.PaymentConfirmService;
|
import com.by4cloud.platformx.common.core.util.R;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.data.redis.core.StringRedisTemplate;
|
import org.springframework.stereotype.Service;
|
/**
|
* 银行流水
|
*
|
* @author syt
|
* @date 2026-08-07 16:10:36
|
*/
|
@Slf4j
|
@Service
|
@RequiredArgsConstructor
|
public class BankStatementServiceImpl extends ServiceImpl<BankStatementMapper, BankStatement> implements BankStatementService {
|
|
private final PaymentConfirmService paymentConfirmService;
|
private final ContractMapper contractMapper;
|
private final BusinessCustomerMapper businessCustomerMapper;
|
private final StringRedisTemplate redisTemplate;
|
|
@Value("${bip.url}")
|
private String url;
|
|
@Override
|
public R edit(BankStatementUpdateDTO updateDTO) {
|
BankStatement statement = baseMapper.selectById(updateDTO.getId());
|
Contract contract = contractMapper.selectById(updateDTO.getContractId());
|
if (ObjUtil.isNull(contract)){
|
return R.failed("合同查询失败");
|
}
|
PaymentConfirmAddDTO addDTO = new PaymentConfirmAddDTO();
|
addDTO.setBusGuestId(statement.getBusGuestId()+"");
|
addDTO.setConfirmTime(statement.getTranDate());
|
addDTO.setContractNo(contract.getContractNo());
|
addDTO.setInOrOut("1");
|
addDTO.setTransationAmount(statement.getTranAmount());
|
R r = paymentConfirmService.add(addDTO);
|
if (!r.isOk()){
|
return r;
|
}
|
statement.setContractId(updateDTO.getContractId());
|
baseMapper.updateById(statement);
|
|
//bip推送
|
pushSaveCollection(statement);
|
return R.ok();
|
}
|
|
private void pushSaveCollection(BankStatement statement) {
|
String accessToken = "";
|
if (redisTemplate.hasKey("BIP_TOKEN")) {
|
accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
|
} else {
|
paymentConfirmService.getAccessToken(accessToken);
|
}
|
if (StrUtil.isEmpty(accessToken)) {
|
log.error("bip accessToken 获取异常");
|
return;
|
}
|
String finalAccessToken = accessToken;
|
JSONObject params = genRequestParam(statement);
|
|
log.info("收款单集成 Request:{}", params.toJSONString());
|
String result = HttpUtil.post(url + "/yonbip/EFI/receivable/save?access_token=" + finalAccessToken, params.toJSONString());
|
log.info("收款单集成 Response:{}", result);
|
|
}
|
|
private JSONObject genRequestParam(BankStatement statement) {
|
BusinessCustomer customer = businessCustomerMapper.selectById(statement.getBusGuestId());
|
Contract contract = contractMapper.selectById(statement.getContractId());
|
JSONObject req = new JSONObject();
|
|
JSONObject data = new JSONObject();
|
|
|
JSONObject freeCh = new JSONObject();
|
freeCh.put("YSYF57","MJHYXGLXT");
|
|
data.put("freeChId",freeCh);
|
data.put("extVouchCode",statement.getBankSeqNo());
|
data.put("billDate",statement.getTranDate());
|
data.put("objectType","1");
|
data.put("customerCode",customer.getCreditCode());
|
data.put("exchangeRate",1);
|
data.put("exchangeRateDate", DateUtil.now());
|
data.put("contractNo",contract.getContractNo());
|
|
JSONArray bodyItems = new JSONArray();
|
|
JSONObject bodyItem = new JSONObject();
|
bodyItem.put("srcBillType","38");
|
bodyItem.put("srcBillNo",statement.getBankSeqNo());
|
|
JSONObject freeChItem = new JSONObject();
|
freeChItem.put("YSZJX01A","业务资金预算项目");
|
freeChItem.put("YSZJX05","");
|
freeChItem.put("YSZJX11","2146820445301112836");
|
freeChItem.put("zzbkfl","");
|
bodyItem.put("freeChId",freeChItem);
|
|
bodyItems.add(bodyItem);
|
data.put("bodyItem",bodyItems);
|
|
data.put("_status","Insert");
|
data.put("oriTaxIncludedAmount",statement.getTranAmount());
|
|
req.put("data",data);
|
return req;
|
|
}
|
}
|
