package com.by4cloud.platformx.business.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.IdUtil;
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.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.by4cloud.platformx.admin.api.entity.SysDept;
import com.by4cloud.platformx.admin.api.feign.RemoteDeptService;
import com.by4cloud.platformx.business.dto.BankStatementUpdateDTO;
import com.by4cloud.platformx.business.dto.BipQueryDTO;
import com.by4cloud.platformx.business.dto.PaymentConfirmAddDTO;
import com.by4cloud.platformx.business.entity.*;
import com.by4cloud.platformx.business.mapper.*;
import com.by4cloud.platformx.business.service.BankStatementService;
import com.by4cloud.platformx.business.service.PaymentConfirmService;
import com.by4cloud.platformx.business.vo.ReceiveBipVo;
import com.by4cloud.platformx.business.vo.ReceiveItemVo;
import com.by4cloud.platformx.business.vo.StatementContractVo;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.datascope.DataScope;
import com.by4cloud.platformx.common.security.util.SecurityUtils;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import okhttp3.*;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

import java.io.IOException;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 银行流水
 *
 * @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;
	private final RemoteDeptService remoteDeptService;
	private final BankStatementItemMapper bankStatementItemMapper;
	private final ErpRequestRecordMapper erpRequestRecordMapper;
	private final BipViewMapper bipViewMapper;

	@Value("${bip.url}")
	private String url;

	@Value("${bip.flag}")
	private Boolean bipFlag;

	@Value("${dept.sgb}")
	private String sgb;

	@Value("${erp.sgb}")
	private String sgbErp;

	@Override
	public R edit(BankStatementUpdateDTO updateDTO) {
		BankStatement statement = baseMapper.selectById(updateDTO.getId());
		if (CollUtil.isEmpty(updateDTO.getContractCollectionList())) {
			return R.failed("请选择收款合同后在提交");
		}
		BigDecimal toPaidTotal = updateDTO.getContractCollectionList().stream().map(StatementContractDTO::getToPaidAmount)
				.reduce(BigDecimal.ZERO, BigDecimal::add);
		if (toPaidTotal.compareTo(statement.getTranAmount().subtract(statement.getConfirmAmount())) != 0) {
			return R.failed("确认收款总额必须与交易流水金额一致");
		}

		statement.setConfirmAmount(statement.getConfirmAmount().add(toPaidTotal));
		baseMapper.updateById(statement);

		updateDTO.getContractCollectionList().stream().forEach(statementContractDTO -> {
			Contract contract = contractMapper.selectById(statementContractDTO.getId());
			R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
			SysDept b = r.getData();
			BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
			BankStatementItem item = new BankStatementItem();
			item.setStatetId(statement.getId());
			item.setBankSeqNo(statement.getBankSeqNo());
			item.setConfirmAmount(statementContractDTO.getToPaidAmount());
			item.setContractId(statementContractDTO.getId());
			ReceiveBipVo bipVo = tranBipVo(statement, item, b, customer);
			item.setBipParam(JSONObject.toJSONString(bipVo));
			bankStatementItemMapper.insert(item);
			PaymentConfirmAddDTO addDTO = new PaymentConfirmAddDTO();
			addDTO.setBusGuestId(statement.getBusGuestId() + "");
			addDTO.setConfirmTime(statement.getTranDate());
			addDTO.setContractNo(contract.getContractNo());
			addDTO.setInOrOut(statement.getDcFlag());
			addDTO.setTransationAmount(statementContractDTO.getToPaidAmount());
			addDTO.setBankSeqNo(statement.getBankSeqNo());
			paymentConfirmService.add(addDTO);

		});

		//石工泵主动推送系统
		if ((StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) && StrUtil.isNotEmpty(sgbErp)) {
			pushCollectionSgb(statement, updateDTO.getContractCollectionList());
		}

//		//判断是否内部单位
//		CustInfoVo custInfoVo = bipViewMapper.selectBaseInfoByCustName(statement.getPayBankAccName());
//		if (ObjUtil.isNull(custInfoVo)){
//			return R.ok();
//		}
//		//bip推送
//		if (bipFlag&&custInfoVo.getCustCode().equals("01")) {
//			return pushSaveCollection(statement, updateDTO.getContractCollectionList());
//		}
//		log.info("内部往来收款单，客户名称：{},客户类型：{},不用保存收款单",custInfoVo.getCustName(),custInfoVo.getCustclass());
		return R.ok();
	}

	private void pushCollectionSgb(BankStatement statement, List<StatementContractDTO> contractCollectionList) {
		JSONObject request = genErpParam(statement, contractCollectionList);
		statement.setPushParam(request.toJSONString());
		log.info("工业泵收款地址:{}", sgbErp + "/apilink/arclose/create?corpsecret=12345678&appserver=appserver1&accountid=888&tradeid=" + IdUtil.fastUUID());

//		HttpResponse resp = HttpUtil.createPost(sgbErp + "/apilink/arclose/create?corpsecret=12345678&appserver=appserver1&accountid=888&tradeid="
//				+ IdUtil.fastUUID())
//				.header("Content-Type","application/x-www-form-urlencoded")
//				.body(URLEncodeUtil.encode(request.toJSONString(), StandardCharsets.UTF_8))
//				.timeout(30000)
//				// 指定编码格式
//				.charset(StandardCharsets.UTF_8)
//				.execute();

			log.info("工业泵收款入参:{}", "=" +request.toJSONString());
			OkHttpClient client = new OkHttpClient().newBuilder()
					.build();
			MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded");
			RequestBody body = RequestBody.create(mediaType, "=" + request.toJSONString());
			Request req = new Request.Builder()
					.url(sgbErp + "/apilink/arclose/create?corpsecret=12345678&appserver=appserver1&accountid=888&tradeid=" + IdUtil.fastUUID())
					.method("POST", body)
					.addHeader("Content-Type", "application/x-www-form-urlencoded")
					.build();
			String result = "";
			try (Response response = client.newCall(req).execute()){
				if (response.isSuccessful()) {
					// 仅调用一次string()，结果存入变量复用，后续所有逻辑直接读取该变量
					result = response.body().string();
					// 业务逻辑直接使用result，禁止再次调用response.body().string()
				}
			log.info("工业泵收款回参：{}", result);
			saveErpRequestRecord("sgb", "/apilink/arclose/create", request.toJSONString(), result);
			JSONObject respJson = JSONObject.parseObject(result);
			if (respJson.containsKey("errcode") && respJson.getString("errcode").equals("0")) {
				statement.setPushFlag(1);
				statement.setPushVouchNo(respJson.getString("code"));
				baseMapper.updateById(statement);
				return;
			}
			log.error("工业泵收款推送失败：{}", response.body().string());
		} catch (IOException e) {
			e.printStackTrace();
		}

	}

	private void saveErpRequestRecord(String ymj, String medthodName, String toJSONString, String result) {
		ErpRequestRecord record = new ErpRequestRecord();
		record.setErpName(ymj);
		record.setMothedName(medthodName);
		record.setRequestParams(toJSONString);
		record.setResponseParams(result);
		erpRequestRecordMapper.insert(record);
	}

	private JSONObject genErpParam(BankStatement statement, List<StatementContractDTO> contractCollectionList) {
		JSONObject req = new JSONObject();
		Map<String, Object> djt = new LinkedHashMap<>();
		Contract contract = contractMapper.selectById(contractCollectionList.get(0).getId());
		BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
		djt.put("dVouchDate", DateUtil.formatDate(statement.getTranDate()));//单据日期
		if (ObjUtil.isNotNull(customer)) {
			djt.put("cDwCode", customer.getErpCompanyCode());//单位编码
		}
		djt.put("cexch_name", "人民币");//单位编码
		djt.put("cOperator", "10123");//录入人编码
		djt.put("cSSCode", "01");//录入人编码
		djt.put("iAmount", statement.getConfirmAmount());//人民币金额
		djt.put("cBankAccount", statement.getReceiveBankAccAcc());//本方银行账号
		djt.put("cBank", statement.getPayBankAccName());//本方银行账号
		djt.put("cContractType", "161");
		if (CollUtil.size(contractCollectionList)==1) {
			Contract contractHeader = contractMapper.selectById(contractCollectionList.get(0).getId());
			djt.put("cContractID", contractHeader.getErpContractNo());
		}
		req.put("单据头", djt);
		JSONObject line = new JSONObject();
		JSONArray array = new JSONArray();

		contractCollectionList.stream().forEach(statementContractDTO -> {
			JSONObject djti = new JSONObject();
			djti.put("cCusVen", customer.getErpCompanyCode());//往来单位编码
			djti.put("iAmt_f", statementContractDTO.getToPaidAmount());//本行本币金额
			djti.put("iAmt", statementContractDTO.getToPaidAmount());//本行本币金额
			djti.put("cPersonCode", "00164");//业务员编码
			djti.put("cConID", contract.getErpContractNo());//合同编码
			djti.put("款项类型", "应收款");
			djti.put("cConType","镇江市");
			array.add(djti);
		});

		line.put("行", array);
		req.put("单据体", line);
		JSONObject apicontext = new JSONObject();
		apicontext.put("username", "");
		req.put("apicontext", apicontext);
		return req;
	}

	private R pushSaveCollection(BankStatement statement, BankStatementItem bankStatementItem) {
		String accessToken = "";
		if (redisTemplate.hasKey("BIP_TOKEN")) {
			accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
		} else {
			accessToken = paymentConfirmService.getAccessToken(accessToken);
		}
		if (StrUtil.isEmpty(accessToken)) {
			log.error("bip accessToken 获取异常");
			return R.failed("bip accessToken 获取异常");
		}
		String finalAccessToken = accessToken;

		R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
		log.info("查询单位信息:{}", JSONObject.toJSONString(r.getData()));
		if (!r.isOk()) {
			log.error("查询单位信息异常");
			return R.failed("查询单位信息异常");
		}
		SysDept dept = r.getData();
		JSONObject params = genRequestParam(statement, dept, bankStatementItem);

		log.info("收款单集成 Request:{}", params.toJSONString());
		String result = HttpUtil.post(url + "/yonbip/EFI/collection/saveandsubmit?access_token=" + finalAccessToken, params.toJSONString());
		log.info("收款单集成 Response:{}", result);

		JSONObject resultJson = JSONObject.parseObject(result);
		if (!resultJson.getString("code").equals("200")) {
			return R.failed(resultJson.getString("message"));
		}
		bankStatementItem.setBipPush("1");
		bankStatementItem.setBipId(resultJson.getJSONObject("data").getLong("id"));
		bankStatementItemMapper.updateById(bankStatementItem);
		return R.ok();
	}

	private JSONObject genRequestParam(BankStatement statement, SysDept dept, BankStatementItem statementItem) {
		Contract contract = contractMapper.selectById(statementItem.getContractId());
		BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
		ReceiveBipVo bipVo = BeanUtil.copyProperties(JSONObject.parseObject(statementItem.getBipParam()), ReceiveBipVo.class);
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("billDate", DateUtil.format(statement.getTranDate(), DatePattern.NORM_DATETIME_FORMAT));
		data.put("exchangeRate", "1");//汇率
		data.put("exchangeRateDate", DateUtil.now());//汇率时间
		data.put("objectType", "1");
		data.put("customerCode", customer.getBipCode());//客户编码
		data.put("financeOrgCode", dept.getBipCode());//开票组织编码
		data.put("orgCode", dept.getBipCode());//业务组织编码
		data.put("bustypeCode", "ar_colsale");// TODO 交易类型编码 暂估默认ZGYSFP，装备默认ZBYXGLXT暂时不能用
		data.put("oriCurrencyCode", "CNY");//币种
		data.put("srcBillType", "38");
		data.put("srcBillNo", statement.getBankSeqNo());
		data.put("_status", "Insert");
		JSONArray bodyItem = new JSONArray();

		JSONObject item = new JSONObject();
		item.put("oriTaxIncludedAmount", statementItem.getConfirmAmount());
		item.put("contractNo", contract.getContractNo());
		item.put("quickTypeCode", "1");
		item.put("_status", "Insert");

		item.put("expenseItemCode", bipVo.getItemList().get(0).getJjsx());//经济事项
		item.put("remarks", bipVo.getItemList().get(0).getZy());//摘要
		JSONObject freeChId = new JSONObject();
		freeChId.put("GX08", bipVo.getItemList().get(0).getHsdy());//核算单元
		freeChId.put("YSYF14", "1");//款项类型 1 预收款 2 应收款
		freeChId.put("JT04", bipVo.getItemList().get(0).getHsjylx());//核算交易类型 0101 集团外部 01020301 三级分子公司间 01020302 三级分公司与子子公司之间
		freeChId.put("JT06", bipVo.getItemList().get(0).getKxmx());//款项明细
		freeChId.put("JT12", bipVo.getItemList().get(0).getCpwlfl());//产品物料分类

		item.put("freeChId", freeChId);


		bodyItem.add(item);
		data.put("bodyItem", bodyItem);
		JSONObject datafreeChId = new JSONObject();
		datafreeChId.put("YSYF_SFZY", bipVo.getSfzy());//是否主营
		datafreeChId.put("fk_038", bipVo.getPzzdr());//凭证制单人
		datafreeChId.put("YSYF_08", bipVo.getSfnbwl());//是否内部往来
		datafreeChId.put("YSYF24", bipVo.getSfjyjs());//是否简易计税
		datafreeChId.put("fk_002", bipVo.getFjzs());//附件1
		datafreeChId.put("GX08", bipVo.getHsdy());//核算单元
		datafreeChId.put("TzMY042", contract.getExpirationDate());//预计回款日期
		data.put("freeChId", datafreeChId);
		data.put("remarks", bipVo.getZy());//摘要
		jsonObject.put("data", data);
		return jsonObject;
	}

	@Override
	public R getHistoryById(Long id) {
		MPJLambdaWrapper<BankStatementItem> wrapper = new MPJLambdaWrapper<BankStatementItem>()
				.selectAll(BankStatementItem.class)
				.select(Contract::getContractNo)
				.select(Contract::getPartyA)
				.select(Contract::getAmount)
				.leftJoin(Contract.class, Contract::getId, BankStatementItem::getContractId)
				.eq(BankStatementItem::getCompId, SecurityUtils.getUser().getCompId())
				.eq(BankStatementItem::getStatetId, id)
				.orderByDesc(BankStatementItem::getCreateTime);
		return R.ok(bankStatementItemMapper.selectJoinList(StatementContractVo.class, wrapper));
	}

	@Override
	public R delHistoryById(Long id) {

		BankStatementItem statement = bankStatementItemMapper.selectById(id);
		BankStatement bankStatement = baseMapper.selectById(statement.getStatetId());
		Contract contract = contractMapper.selectById(statement.getContractId());
		if (ObjUtil.isNull(contract)) {
			return R.failed("合同信息异常");
		}
		BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
		if (ObjUtil.isNull(customer)) {
			return R.failed("客户信息信息异常");
		}
		R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
		if (!r.isOk()) {
			return r;
		}
		//bip推送
		if (bipFlag) {
			String accessToken = "";
			if (redisTemplate.hasKey("BIP_TOKEN")) {
				accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
			} else {
				accessToken = paymentConfirmService.getAccessToken(accessToken);
			}
			if (StrUtil.isEmpty(accessToken)) {
				log.error("bip accessToken 获取异常");
				return R.failed("bip accessToken 获取异常");
			}
			String finalAccessToken = accessToken;
			JSONObject request = genRefundParam(bankStatement, statement, contract, customer, r.getData());
			log.info("收款退款单-退款单一历史确认请求入参：{}", request.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/arRefund/saveandsubmit?access_token=" + finalAccessToken, request.toJSONString());
			log.info("收款退款单-退款单一历史确认请求回参:{}", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (!resultJson.getString("code").equals("200")) {
				return R.failed(resultJson.getString("message"));
			}
		}
		bankStatementItemMapper.deleteById(id);

		bankStatement.setConfirmAmount(bankStatement.getConfirmAmount().subtract(statement.getConfirmAmount()));
		baseMapper.updateById(bankStatement);
		return R.ok();
	}

	private JSONObject genRefundParam(BankStatement bankStatement, BankStatementItem statement, Contract contract, BusinessCustomer customer, SysDept dept) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("billDate", DateUtil.now());
		data.put("exchangeRate", "1");//汇率
		data.put("exchangeRateDate", DateUtil.now());//汇率时间
		data.put("objectType", "1");
		data.put("customerCode", customer.getBipCode());//客户编码
		data.put("financeOrgCode", dept.getBipCode());//开票组织编码
		data.put("orgCode", dept.getBipCode());//业务组织编码
		data.put("bustypeCode", "ar_refsale");//交易类型编码 暂估默认ZGYSFP，销售默认MJHYXGLXT
		data.put("oriCurrencyCode", "CNY");//币种
		data.put("srcBillType", "38");
		data.put("srcBillNo", bankStatement.getBankSeqNo());
		data.put("_status", "Insert");
		JSONArray bodyItem = new JSONArray();
		JSONObject item = new JSONObject();
		item.put("oriTaxIncludedAmount", statement.getConfirmAmount());
		item.put("contractNo", contract.getContractNo());
		item.put("quickTypeCode", "1");
		item.put("_status", "Insert");
		bodyItem.add(item);
		data.put("bodyItem", bodyItem);
		jsonObject.put("data", data);
		return jsonObject;
	}

	@Override
	public R backBal(Long id) {
		BankStatement bankStatement = baseMapper.selectById(id);
		BusinessCustomer customer = businessCustomerMapper.selectById(bankStatement.getBusGuestId());
		if (ObjUtil.isNull(customer) || StrUtil.isEmpty(customer.getBipCode())) {
			log.error("查询客户信息异常");
			return R.failed("查询客户信息异常");
		}
		R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
		if (!r.isOk()) {
			log.error("查询单位信息异常");
			return R.failed("查询单位信息异常");
		}
		SysDept dept = r.getData();
		List<BankStatementItem> items = bankStatementItemMapper.selectList(Wrappers.<BankStatementItem>lambdaQuery()
				.eq(BankStatementItem::getStatetId, id));
		if (bipFlag) {
			String accessToken = "";
			if (redisTemplate.hasKey("BIP_TOKEN")) {
				accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
			} else {
				accessToken = paymentConfirmService.getAccessToken(accessToken);
			}
			if (StrUtil.isEmpty(accessToken)) {
				log.error("bip accessToken 获取异常");
				return R.failed("bip accessToken 获取异常");
			}
			String finalAccessToken = accessToken;
			JSONObject request = genBackBalParam(bankStatement, customer, dept, items);
			log.info("收款退款单-退款余额请求入参：{}", request.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/arRefund/saveandsubmit?access_token=" + finalAccessToken, request.toJSONString());
			log.info("收款退款单-退款余额请求回参:{}", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (!resultJson.getString("code").equals("200")) {
				return R.failed(resultJson.getString("message"));
			}
		}
		bankStatement.setTranAmount(bankStatement.getConfirmAmount());
		baseMapper.updateById(bankStatement);
		return R.ok();
	}

	private JSONObject genBackBalParam(BankStatement bankStatement, BusinessCustomer customer, SysDept dept, List<BankStatementItem> items) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("billDate", DateUtil.now());
		data.put("exchangeRate", "1");//汇率
		data.put("exchangeRateDate", DateUtil.now());//汇率时间
		data.put("objectType", "1");
		data.put("customerCode", customer.getBipCode());//客户编码
		data.put("financeOrgCode", dept.getBipCode());//开票组织编码
		data.put("orgCode", dept.getBipCode());//业务组织编码
		data.put("bustypeCode", "ar_refsale");//交易类型编码 暂估默认ZGYSFP，销售默认MJHYXGLXT
		data.put("oriCurrencyCode", "CNY");//币种
		data.put("srcBillType", "38");
		data.put("srcBillNo", bankStatement.getBankSeqNo());
		data.put("_status", "Insert");
		JSONArray bodyItem = new JSONArray();
		JSONObject item = new JSONObject();
		item.put("oriTaxIncludedAmount", bankStatement.getTranAmount().subtract(bankStatement.getConfirmAmount()));
		item.put("quickTypeCode", "1");
		item.put("_status", "Insert");
		bodyItem.add(item);
		data.put("bodyItem", bodyItem);
		jsonObject.put("data", data);
		return jsonObject;
	}

	@Override
	public R backAll(Long id) {
		BankStatement bankStatement = baseMapper.selectById(id);
		BusinessCustomer customer = businessCustomerMapper.selectById(bankStatement.getBusGuestId());
		if (ObjUtil.isNull(customer) || StrUtil.isEmpty(customer.getBipCode())) {
			log.error("查询客户信息异常");
			return R.failed("查询客户信息异常");
		}
		R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
		if (!r.isOk()) {
			log.error("查询单位信息异常");
			return R.failed("查询单位信息异常");
		}
		SysDept dept = r.getData();
		List<BankStatementItem> items = bankStatementItemMapper.selectList(Wrappers.<BankStatementItem>lambdaQuery()
				.eq(BankStatementItem::getStatetId, id));
		if (bipFlag) {
			String accessToken = "";
			if (redisTemplate.hasKey("BIP_TOKEN")) {
				accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
			} else {
				accessToken = paymentConfirmService.getAccessToken(accessToken);
			}
			if (StrUtil.isEmpty(accessToken)) {
				log.error("bip accessToken 获取异常");
				return R.failed("bip accessToken 获取异常");
			}
			String finalAccessToken = accessToken;
			JSONObject request = genBackAllParam(bankStatement, customer, dept, items);
			log.info("收款退款单-退款所有请求入参：{}", request.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/arRefund/saveandsubmit?access_token=" + finalAccessToken, request.toJSONString());
			log.info("收款退款单-退款所有请求回参:{}", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (!resultJson.getString("code").equals("200")) {
				return R.failed(resultJson.getString("message"));
			}
		}
		bankStatement.setConfirmAmount(new BigDecimal("0"));
		baseMapper.updateById(bankStatement);
		return R.ok();
	}

	private JSONObject genBackAllParam(BankStatement bankStatement, BusinessCustomer customer, SysDept dept, List<BankStatementItem> items) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("billDate", DateUtil.now());
		data.put("exchangeRate", "1");//汇率
		data.put("exchangeRateDate", DateUtil.now());//汇率时间
		data.put("objectType", "1");
		data.put("customerCode", customer.getBipCode());//客户编码
		data.put("financeOrgCode", dept.getBipCode());//开票组织编码
		data.put("orgCode", dept.getBipCode());//业务组织编码
		data.put("bustypeCode", "ar_refsale");//交易类型编码 暂估默认ZGYSFP，销售默认MJHYXGLXT
		data.put("oriCurrencyCode", "CNY");//币种
		data.put("srcBillType", "38");
		data.put("srcBillNo", bankStatement.getBankSeqNo());
		data.put("_status", "Insert");
		JSONArray bodyItem = new JSONArray();
		JSONObject item = new JSONObject();
		item.put("oriTaxIncludedAmount", bankStatement.getTranAmount());
		item.put("quickTypeCode", "1");
		item.put("_status", "Insert");
		bodyItem.add(item);
		data.put("bodyItem", bodyItem);
		jsonObject.put("data", data);
		return jsonObject;
	}

	@Override
	public R backHis(Long id) {
		BankStatement bankStatement = baseMapper.selectById(id);
		BusinessCustomer customer = businessCustomerMapper.selectById(bankStatement.getBusGuestId());
		if (ObjUtil.isNull(customer) || StrUtil.isEmpty(customer.getBipCode())) {
			log.error("查询客户信息异常");
			return R.failed("查询客户信息异常");
		}
		R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
		if (!r.isOk()) {
			log.error("查询单位信息异常");
			return R.failed("查询单位信息异常");
		}
		SysDept dept = r.getData();
		List<BankStatementItem> items = bankStatementItemMapper.selectList(Wrappers.<BankStatementItem>lambdaQuery()
				.eq(BankStatementItem::getStatetId, id));
		if (bipFlag) {
			String accessToken = "";
			if (redisTemplate.hasKey("BIP_TOKEN")) {
				accessToken = (String) redisTemplate.opsForValue().get("BIP_TOKEN");
			} else {
				accessToken = paymentConfirmService.getAccessToken(accessToken);
			}
			if (StrUtil.isEmpty(accessToken)) {
				log.error("bip accessToken 获取异常");
				return R.failed("bip accessToken 获取异常");
			}
			String finalAccessToken = accessToken;
			JSONObject request = genBackHisParam(bankStatement, customer, dept, items);
			log.info("收款退款单-退款历史确认请求入参：{}", request.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/arRefund/saveandsubmit?access_token=" + finalAccessToken, request.toJSONString());
			log.info("收款退款单-退款历史确认请求回参:{}", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (!resultJson.getString("code").equals("200")) {
				return R.failed(resultJson.getString("message"));
			}
		}

		bankStatement.setConfirmAmount(new BigDecimal("0"));
		baseMapper.updateById(bankStatement);
		bankStatementItemMapper.deleteByIds(items.stream().map(item -> item.getId()).collect(Collectors.toList()));
		return R.ok();
	}

	private JSONObject genBackHisParam(BankStatement bankStatement, BusinessCustomer customer, SysDept dept, List<BankStatementItem> items) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("billDate", DateUtil.now());
		data.put("exchangeRate", "1");//汇率
		data.put("exchangeRateDate", DateUtil.now());//汇率时间
		data.put("objectType", "1");
		data.put("customerCode", customer.getBipCode());//客户编码
		data.put("financeOrgCode", dept.getBipCode());//开票组织编码
		data.put("orgCode", dept.getBipCode());//业务组织编码
		data.put("bustypeCode", "ar_refsale");//交易类型编码 暂估默认ZGYSFP，销售默认MJHYXGLXT
		data.put("oriCurrencyCode", "CNY");//币种
		data.put("srcBillType", "38");
		data.put("srcBillNo", bankStatement.getBankSeqNo());
		data.put("_status", "Insert");
		JSONArray bodyItem = new JSONArray();
		for (BankStatementItem statementItem : items) {
			Contract contract = contractMapper.selectById(statementItem.getContractId());
			JSONObject item = new JSONObject();
			item.put("oriTaxIncludedAmount", statementItem.getConfirmAmount());
			item.put("contractNo", contract.getContractNo());
			item.put("quickTypeCode", "1");
			item.put("_status", "Insert");
			bodyItem.add(item);
		}
		data.put("bodyItem", bodyItem);
		jsonObject.put("data", data);
		return jsonObject;
	}

	private ReceiveBipVo tranBipVo(BankStatement statement, BankStatementItem bankStatementItem, SysDept b, BusinessCustomer customer) {
		ReceiveBipVo bipVo = new ReceiveBipVo();
		bipVo.setDjrq(DateUtil.formatDate(statement.getTranDate()));
		bipVo.setKpzz(b.getBipCode());
		bipVo.setYwzz(b.getBipCode());
		R<SysDept> rDept = remoteDeptService.getById(SecurityUtils.getUser().getDeptId());
		if (rDept.isOk()) {
			bipVo.setBm(rDept.getData().getOrgCode());
			bipVo.setHsdy(rDept.getData().getOrgCode());
		}
		bipVo.setYwy(SecurityUtils.getUser().getNickname());
		bipVo.setPzzdr(SecurityUtils.getUser().getNickname());
		bipVo.setJylx("ZBYXGLXT");
		bipVo.setWldxlx("1");
		bipVo.setKh(customer.getCreditCode());
		bipVo.setBz("CNY");
		bipVo.setFjzs("0");
		bipVo.setSfzy("1");
		bipVo.setSfnbwl("1");
		bipVo.setSfjyjs("0");
		bipVo.setDjfx("1");
		List<ReceiveItemVo> list = new ArrayList<>();
		ReceiveItemVo itemVo = new ReceiveItemVo();
		itemVo.setConfirmAmount(bankStatementItem.getConfirmAmount());
		list.add(itemVo);
		bipVo.setItemList(list);
		return bipVo;
	}

	@Override
	public Page pageBip(Page page, BipQueryDTO queryDTO) {
		return baseMapper.pageBip(page, queryDTO, DataScope.of("comp_id"));
	}

	@Override
	public R saveAndPush(BankStatementUpdateDTO updateDTO) {
		BankStatementItem item = bankStatementItemMapper.selectById(updateDTO.getId());
		item.setBipParam(updateDTO.getBipParam());
		bankStatementItemMapper.updateById(item);
		BankStatement statement = baseMapper.selectById(item.getStatetId());
		return pushSaveCollection(statement, item);
	}
}