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

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ArrayUtil;
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.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.api.feign.RemoteFlowProcessService;
import com.by4cloud.platformx.business.constant.FlowNameEnum;
import com.by4cloud.platformx.business.dto.GenInvoiceInfoDTO;
import com.by4cloud.platformx.business.entity.*;
import com.by4cloud.platformx.business.mapper.*;
import com.by4cloud.platformx.business.service.ContractInvoiceService;
import com.by4cloud.platformx.business.service.PaymentConfirmService;
import com.by4cloud.platformx.business.vo.*;
import com.by4cloud.platformx.common.core.util.R;
import com.by4cloud.platformx.common.data.mybatis.BaseModel;
import com.by4cloud.platformx.common.security.util.SecurityUtils;
import com.by4cloud.platformx.flow.task.dto.ProcessInstanceParamDto;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import io.swagger.v3.oas.annotations.Operation;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springdoc.core.annotations.ParameterObject;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.stream.Collectors;

@Slf4j
@Service
@RequiredArgsConstructor
public class ContractInvoiceServiceImpl extends ServiceImpl<ContractInvoiceMapper, ContractInvoice> implements ContractInvoiceService {

	private final ContractMapper contractMapper;
	private final BusinessCustomerMapper businessCustomerMapper;
	private final ContractOutBoundMapper contractOutBoundMapper;
	private final ContractSubjectMatterMapper subjectMatterMapper;
	private final ProductMapper productMapper;
	private final BwRequestRecordMapper bwRequestRecordMapper;
	private final RemoteDeptService remoteDeptService;
	private final RemoteFlowProcessService remoteFlowProcessService;
	private final PaymentConfirmService paymentConfirmService;
	private final RedisTemplate redisTemplate;


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

	@Value("${BWInvoice.flag}")
	private Boolean bwFlag;

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

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

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


	@Override
	public R getContractOutBound(Long contractId) {
		MPJLambdaWrapper<ContractOutBound> wrapper = new MPJLambdaWrapper<ContractOutBound>()
				.selectAll(ContractOutBound.class)
				.eq(ContractOutBound::getContractId, contractId);
		List<ContractInvoiceOutBoundVo> invoiceOutBoundVoList = contractOutBoundMapper.selectJoinList(ContractInvoiceOutBoundVo.class, wrapper);
		if (ArrayUtil.isNotEmpty(invoiceOutBoundVoList.toArray())){
			invoiceOutBoundVoList.stream().forEach(contractInvoiceOutBoundVo -> {
				contractInvoiceOutBoundVo.setInvoiceNum(contractInvoiceOutBoundVo.getOutBoundNum().subtract(contractInvoiceOutBoundVo.getInvoiceNum()));
				contractInvoiceOutBoundVo.setToInvoiceNum(contractInvoiceOutBoundVo.getInvoiceNum());
			});
		}
		return R.ok(invoiceOutBoundVoList);
	}

	@Override
	public R genInvoiceInfo(GenInvoiceInfoDTO genInvoiceInfoDTO) {
		if (ArrayUtil.isEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList())) {
			return R.failed("请选择开票出库单后再操作");
		}
		ContractOutBound outBound = contractOutBoundMapper.selectById(genInvoiceInfoDTO.getOutBoundInvoiceList().get(0).getContractOutBoundId());
		Contract contract = contractMapper.selectById(outBound.getContractId());
		if (ObjUtil.isNull(contract)) {
			return R.failed("合同信息异常，请联系技术人员");
		}
		R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
		if (!r.isOk()) {
			return R.failed("获取开票单位异常");
		}
		SysDept b = r.getData();
		GenInvoiceInfoVo vo = genInvoiceInfoVo(genInvoiceInfoDTO, contract, b);

		return R.ok(vo);
	}

	private GenInvoiceInfoVo genInvoiceInfoVo(GenInvoiceInfoDTO genInvoiceInfoDTO, Contract contract, SysDept b) {
		GenInvoiceInfoVo vo = new GenInvoiceInfoVo();
		BusinessCustomer a = businessCustomerMapper.selectById(contract.getPartyAId());
		vo.setPartyA(a.getRegisterName());
		vo.setPartyAOrgCode(a.getCreditCode());
		vo.setPartyAOpenBank(a.getBankName());
		vo.setPartyABankAccount(a.getBankAccount());
		vo.setPartyB(b.getOrgName());
		vo.setPartyBOrgCode(b.getOrgCode());
		vo.setPartyBOpenBank(b.getOrgBank());
		vo.setPartyBBankAccount(b.getOrgBankAccount());
		List<InvoiceItemVo> invoiceItemVoList = new ArrayList<>();
		List<String> erpCode = new ArrayList<>();
		List<ContractOutBoundMergeVo> mergeOutBounds = new ArrayList<>();
//		List<ContractOutBound> outBounds = contractOutBoundMapper.selectList(Wrappers.<ContractOutBound>lambdaQuery()
//				.in(ContractOutBound::getId, genInvoiceInfoDTO.getOutBoundInvoiceList().stream().map(item->item.getContractOutBoundId()).collect(Collectors.toList())));
		if (ArrayUtil.isNotEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList().toArray())) {
			genInvoiceInfoDTO.getOutBoundInvoiceList().stream().forEach(contractOutBoundInvoiceVo -> {
				ContractOutBound contractOutBound = contractOutBoundMapper.selectById(contractOutBoundInvoiceVo.getContractOutBoundId());

				if (!ArrayUtil.contains(erpCode.toArray(), contractOutBound.getSubjectMatterCode())) {
					erpCode.add(contractOutBound.getSubjectMatterCode());
					ContractOutBoundMergeVo mergeVo = new ContractOutBoundMergeVo();
					mergeVo.setMaterialCode(contractOutBound.getSubjectMatterCode());
					mergeVo.setMaterialInternalName(contractOutBound.getSubjectMatterName());
					mergeVo.setQuantity(contractOutBoundInvoiceVo.getInvoiceNum());
					Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode, contractOutBound.getSubjectMatterCode())
							.eq(Product::getCompId, SecurityUtils.getUser().getCompId()).last("limit 1"));
					if (ObjUtil.isNotNull(product)) {
						mergeVo.setTaxClass(product.getTaxClass());
						mergeVo.setSpecification(product.getProductType());
						mergeVo.setTaxRate(new BigDecimal(product.getTaxRate()));
						mergeVo.setTaxCode(product.getTaxCode());
						Product productClass = productMapper.selectById(product.getParentId());
						if (ObjUtil.isNotNull(product)) {
							mergeVo.setItemName("*" + product.getTaxClass() + "*" + productClass.getProductName());
						}
					}
					ContractSubjectMatter subjectMatter = subjectMatterMapper.selectOne(Wrappers.<ContractSubjectMatter>lambdaQuery()
							.eq(ContractSubjectMatter::getMaterialCode, contractOutBound.getSubjectMatterCode())
							.eq(ContractSubjectMatter::getContractId, contract.getId()).last("limit 1"));
					if (ObjUtil.isNotNull(subjectMatter)) {
						mergeVo.setUnitPrice(subjectMatter.getUnitPrice());
						mergeVo.setUnit(subjectMatter.getUnit());
					}
					mergeOutBounds.add(mergeVo);
				} else {
					List<ContractOutBoundMergeVo> filteredList = mergeOutBounds.stream()
							.filter(item -> contractOutBound.getSubjectMatterCode().equals(item.getMaterialCode())) // 防止空指针，建议常量在前
							.collect(Collectors.toList());
					if (ArrayUtil.isNotEmpty(filteredList.toArray())) {
						filteredList.get(0).setQuantity(filteredList.get(0).getQuantity().add(contractOutBound.getOutBoundNum()));
					}
				}
			});
			if (ArrayUtil.isNotEmpty(mergeOutBounds.toArray())) {
				invoiceItemVoList = BeanUtil.copyToList(mergeOutBounds, InvoiceItemVo.class);
				invoiceItemVoList.stream().forEach(invoiceItemVo -> {
//				for (InvoiceItemVo invoiceItemVo:invoiceItemVoList) {
					BigDecimal itemPrice = invoiceItemVo.getUnitPrice().multiply(invoiceItemVo.getQuantity());
					BigDecimal itemPriceTax = itemPrice.divide(new BigDecimal("100").add(invoiceItemVo.getTaxRate()), 2, RoundingMode.HALF_UP).multiply(invoiceItemVo.getTaxRate());
					invoiceItemVo.setPriceTax(itemPriceTax);
					invoiceItemVo.setPriceNoTax(itemPrice.subtract(itemPriceTax));
				});
				vo.setTotalPrice(invoiceItemVoList.stream().map(item -> item.getPriceTax().add(item.getPriceNoTax())).reduce(BigDecimal.ZERO, BigDecimal::add));
				vo.setInvoiceItemList(invoiceItemVoList);
				vo.setPriceWords(Convert.digitToChinese(vo.getTotalPrice()));
			}
		}
		return vo;
	}

	@Override
	public R toInvoice(GenInvoiceInfoDTO genInvoiceInfoDTO) {
		if (ArrayUtil.isEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList().toArray())) {
			return R.failed("请选择开票出库单后再操作");
		}
		ContractOutBound outBound = contractOutBoundMapper.selectById(genInvoiceInfoDTO.getOutBoundInvoiceList().get(0).getContractOutBoundId());
		Contract contract = contractMapper.selectById(outBound.getContractId());
		if (ObjUtil.isNull(contract)) {
			return R.failed("合同信息异常，请联系技术人员");
		}
		R<SysDept> r = remoteDeptService.getById(contract.getPartyBId());
		if (!r.isOk()) {
			return R.failed("获取开票单位异常");
		}
		SysDept b = r.getData();
		GenInvoiceInfoVo vo = genInvoiceInfoVo(genInvoiceInfoDTO, contract, b);
		//发票保存
		ContractInvoice invoice = saveContractInvoice(vo, contract, genInvoiceInfoDTO.getOutBoundInvoiceList(), DateUtil.current() + "");
		//启动流程
		ProcessInstanceParamDto dto = new ProcessInstanceParamDto();
		Map<String, Object> map = BeanUtil.beanToMap(invoice);
		dto.setParamMap(map);
		dto.setFlowName(FlowNameEnum.销售挂账审批.name());
		R r1 = remoteFlowProcessService.startProcessInstance(dto);
		if (r1.getCode() == 1) {
			return R.failed("流程启动失败");
		}
		//更新合同出库单状态
		genInvoiceInfoDTO.getOutBoundInvoiceList().stream().forEach(contractOutBoundInvoiceVo -> {
			ContractOutBound bound = contractOutBoundMapper.selectById(contractOutBoundInvoiceVo.getContractOutBoundId());
			bound.setInvoiceStatus("1");
			bound.setInvoiceNum(bound.getInvoiceNum().add(contractOutBoundInvoiceVo.getInvoiceNum()));
			contractOutBoundMapper.updateById(bound);
		});
		return R.ok();
	}

	private void saveBwRequestRecord(String method, String requestId, String toJSONString, String result) {
		BwRequestRecord bwRequestRecord = new BwRequestRecord();
		bwRequestRecord.setRequestId(requestId);
		bwRequestRecord.setRequestParams(toJSONString);
		bwRequestRecord.setResponseParams(result);
		bwRequestRecord.setResponseCode(JSONObject.parseObject(result).getString("success"));
		bwRequestRecord.setInterfaceName(method);
		bwRequestRecordMapper.insert(bwRequestRecord);
	}

	private JSONObject genBlueInvoice(GenInvoiceInfoVo vo, String serialNo) {
		JSONObject jsonObject = new JSONObject();
		//销方
		jsonObject.put("taxNo", vo.getPartyBOrgCode());//税号
		jsonObject.put("isSplit", false);//超过发票单张限额是否需要拆分开具，默认不拆分（拆分只支持发票类型代码为 专票 004 普票 007 电子票 026的
		jsonObject.put("taxUserName", "");//登录名为税局页面登		录名
		jsonObject.put("formatGenerate", false);//是否需要生成版式返回版式链接(true / false)
		jsonObject.put("formatPushType", false);//版式生成是否推送(true / false)
		//data
		JSONObject data = new JSONObject();
		data.put("invoiceTypeCode", "01");
		data.put("serialNo", serialNo);
		//data.invoiceDetailsList
		JSONArray invoiceDetailsList = new JSONArray();
		Integer lineNo = 1;
		for (InvoiceItemVo invoiceItemVo : vo.getInvoiceItemList()) {
			JSONObject invoiceDetail = new JSONObject();

			invoiceDetail.put("goodsLineNo", lineNo);
			invoiceDetail.put("goodsCode", invoiceItemVo.getTaxCode());
			invoiceDetail.put("goodsTaxRate", invoiceItemVo.getTaxRate().divide(new BigDecimal("100")));
			invoiceDetail.put("goodsUnit", invoiceItemVo.getUnit());
			invoiceDetail.put("goodsQuantity", invoiceItemVo.getQuantity());
			invoiceDetail.put("goodsPrice", invoiceItemVo.getUnitPrice());
			invoiceDetail.put("goodsTotalPrice", invoiceItemVo.getUnitPrice().multiply(invoiceItemVo.getQuantity()));
			invoiceDetail.put("goodsTotalTax", invoiceItemVo.getPriceTax());

			invoiceDetailsList.add(invoiceDetail);
			lineNo++;
		}
		jsonObject.put("invoiceDetailsList", invoiceDetailsList);
		//购方
		data.put("buyerTaxNo", vo.getPartyAOrgCode());
		data.put("buyerName", vo.getPartyA());
		data.put("invoiceTotalPrice", vo.getTotalPrice().subtract(vo.getInvoiceItemList().stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add)));
		data.put("invoiceTotalTax", vo.getInvoiceItemList().stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
		data.put("invoiceTotalPriceTax", vo.getTotalPrice());
		data.put("buyerBankName", vo.getPartyAOpenBank());
		data.put("buyerBankNumber", vo.getPartyABankAccount());

		jsonObject.put("data", data);
		return jsonObject;
	}

	private ContractInvoice saveContractInvoice(GenInvoiceInfoVo genInvoiceInfoVo, Contract contract, List<ContractOutBoundInvoiceVo> outBoundInvoiceVoList, String serialNo) {
		ContractInvoice invoice = new ContractInvoice();
		invoice.setContractId(contract.getId());
		invoice.setInvoiceCategory("1");
		invoice.setRedReversal("0");
		invoice.setSerialNo(serialNo);
		invoice.setTexNo(genInvoiceInfoVo.getPartyBOrgCode());
		invoice.setSellerTaxName(genInvoiceInfoVo.getPartyB());
		invoice.setBuyerTaxName(genInvoiceInfoVo.getPartyA());
		invoice.setInvoiceTotalTax(genInvoiceInfoVo.getInvoiceItemList().stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
		invoice.setInvoiceTotalPrice(genInvoiceInfoVo.getTotalPrice().subtract(invoice.getInvoiceTotalTax()));
		invoice.setInvoiceTotalPriceTax(genInvoiceInfoVo.getTotalPrice());
		invoice.setInvoicePreview(JSONObject.toJSONString(genInvoiceInfoVo));
		invoice.setInvoiceStatus("1");
		invoice.setApprovalStatus("0");
		invoice.setOutBoundId(outBoundInvoiceVoList.stream()
				.map(item-> String.valueOf(item.getContractOutBoundId())) // 或者 .map(Object::toString)
				.collect(Collectors.joining(",")));
		invoice.setInvoicePreviewParam(JSONObject.toJSONString(outBoundInvoiceVoList));
		baseMapper.insert(invoice);
		return invoice;
	}

	@Override
	public R getContractInvoiceList(Long contractId) {
		List<ContractInvoice> invoiceList = baseMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery()
				.eq(ContractInvoice::getContractId, contractId)
				.orderByDesc(ContractInvoice::getCreateTime));
		return R.ok(invoiceList);
	}

	@Override
	public R toRedInvoice(Long invoiceId) {

		ContractInvoice blueInvoice = baseMapper.selectById(invoiceId);
		blueInvoice.setRedReversal("2");
		baseMapper.updateById(blueInvoice);
		ContractInvoice invoice = new ContractInvoice();
		invoice.setContractId(blueInvoice.getContractId());
		invoice.setTexNo(blueInvoice.getTexNo());
		invoice.setSellerTaxName(blueInvoice.getSellerTaxName());
		invoice.setBuyerTaxName(blueInvoice.getBuyerTaxName());
		invoice.setInvoiceTotalTax(blueInvoice.getInvoiceTotalTax());
		invoice.setInvoiceTotalPrice(blueInvoice.getInvoiceTotalPrice());
		invoice.setInvoiceTotalPriceTax(blueInvoice.getInvoiceTotalPriceTax());
		invoice.setInvoicePreview(blueInvoice.getInvoicePreview());
		invoice.setInvoiceTotalTax(blueInvoice.getInvoiceTotalTax());
		invoice.setInvoiceTotalPrice(blueInvoice.getInvoiceTotalPrice());
		invoice.setInvoiceTotalPriceTax(blueInvoice.getInvoiceTotalPriceTax());
		invoice.setOutBoundId(blueInvoice.getOutBoundId());
		invoice.setInvoiceTime(new Date());
		invoice.setInvoiceCategory("2");
		invoice.setRedReversal("0");
		invoice.setInvoiceStatus("0");
		invoice.setSerialNo(DateUtil.current() + "");
		invoice.setBlueInvoiceId(invoiceId);
		invoice.setApprovalStatus("0");
		invoice.setInvoicePreviewParam(blueInvoice.getInvoicePreviewParam());
		baseMapper.insert(invoice);
		//启动流程
		ProcessInstanceParamDto dto = new ProcessInstanceParamDto();
		Map<String, Object> map = BeanUtil.beanToMap(invoice);
		dto.setParamMap(map);
		dto.setFlowName(FlowNameEnum.销售挂账审批.name());
		R r1 = remoteFlowProcessService.startProcessInstance(dto);
		if (r1.getCode() == 1) {
			return R.failed("流程启动失败");
		}

		return R.ok();
	}

	private JSONObject genRedInvoice(ContractInvoice blueInvoice, String redConfirmSerialNo) {
		JSONObject jsonObject = new JSONObject();
		jsonObject.put("taxNo", blueInvoice.getTexNo());
		jsonObject.put("redConfirmSerialNo", redConfirmSerialNo);
		jsonObject.put("entryIdentity", "01");
		jsonObject.put("sellerTaxNo", blueInvoice.getTexNo());
		jsonObject.put("sellerTaxName", blueInvoice.getSellerTaxName());
		jsonObject.put("buyerTaxName", blueInvoice.getBuyerTaxName());
		jsonObject.put("originalInvoiceNo", blueInvoice.getInvoiceNo());
		jsonObject.put("originInvoiceIsPaper", "N");
		jsonObject.put("originInvoiceDate", blueInvoice.getInvoiceTime());
		jsonObject.put("originInvoiceTotalPrice", blueInvoice.getInvoiceTotalPrice());
		jsonObject.put("originInvoiceTotalTax", blueInvoice.getInvoiceTotalPrice());
		jsonObject.put("originInvoiceType", "01");
		jsonObject.put("invoiceTotalPrice", blueInvoice.getInvoiceTotalPrice());
		jsonObject.put("invoiceTotalTax", blueInvoice.getInvoiceTotalPrice());
		jsonObject.put("redInvoiceLabel", "2");
		GenInvoiceInfoVo vo = BeanUtil.copyProperties(JSONObject.parseObject(blueInvoice.getInvoicePreview()), GenInvoiceInfoVo.class);
		JSONArray invoiceDetailsList = new JSONArray();
		Integer lineNo = 1;
		for (InvoiceItemVo invoiceItemVo : vo.getInvoiceItemList()) {
			JSONObject invoiceDetail = new JSONObject();
			invoiceDetail.put("originalInvoiceDetailNo", lineNo);
			invoiceDetail.put("goodsLineNo", lineNo);
			invoiceDetail.put("goodsCode", invoiceItemVo.getTaxCode());
			invoiceDetail.put("goodsTaxRate", invoiceItemVo.getTaxRate().divide(new BigDecimal("100")));
			invoiceDetail.put("goodsUnit", invoiceItemVo.getUnit());
			invoiceDetail.put("goodsQuantity", invoiceItemVo.getQuantity());
			invoiceDetail.put("goodsPrice", invoiceItemVo.getUnitPrice());
			invoiceDetail.put("goodsTotalPrice", invoiceItemVo.getUnitPrice().multiply(invoiceItemVo.getQuantity()));
			invoiceDetail.put("goodsTotalTax", invoiceItemVo.getPriceTax());

			invoiceDetailsList.add(invoiceDetail);
			lineNo++;
		}
		jsonObject.put("redConfirmDetailReqEntityList", invoiceDetailsList);
		return jsonObject;

	}

	@Override
	public R queryBlueInvoice() {
		if (bwFlag) {
			List<ContractInvoice> contractInvoices = baseMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery()
					.eq(ContractInvoice::getInvoiceCategory, "1").eq(ContractInvoice::getInvoiceStatus, "1"));
			if (ArrayUtil.isNotEmpty(contractInvoices.toArray())) {
				contractInvoices.stream().forEach(contractInvoice -> {
					JSONObject request = new JSONObject();
					request.put("tax_no", contractInvoice.getTexNo());
					JSONObject data = new JSONObject();
					data.put("serial_no", contractInvoice.getSerialNo());
					data.put("return_type", "1");
					String requestId = IdUtil.fastUUID();
					log.info("serial_no:{},发票查询入参：{},", contractInvoice.getSerialNo(), request.toJSONString());
					String result = HttpUtil.post("method=baiwang.output.format.query&version=1.0&request_id=" + requestId, request.toJSONString());
					log.info("serial_no:{},发票查询回参：{},", contractInvoice.getSerialNo(), result);
					saveBwRequestRecord("baiwang.output.format.query", requestId, request.toJSONString(), result);
					JSONObject resultObj = JSONObject.parseObject(result);
					if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) && resultObj.getBoolean("success")) {
						JSONObject model = resultObj.getJSONObject("model");
						contractInvoice.setInvoicePath(model.getString("query_data"));
						contractInvoice.setInvoiceStatus("2");
						baseMapper.updateById(contractInvoice);
					}
					//推送BIP
					pushBipInvoice(contractInvoice);
				});
			}
		}
		return R.ok();
	}

	private void pushBipInvoice(ContractInvoice contractInvoice) {
		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;
		}
		//蓝票
		if (StrUtil.equals(contractInvoice.getInvoiceCategory(),"1")) {
			JSONObject params = genBlueReceiveParams(contractInvoice);
			String finalAccessToken = accessToken;

			log.info("XSJZ_YS_DJ_INSERT Request:", params.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/receivable/save?access_token=" + finalAccessToken, params.toJSONString());
			log.info("XSJZ_YS_DJ_INSERT Response:{}", result);
			//保存请求记录
			paymentConfirmService.saveBipRequestRecord(params, "< XSJZ_YS_DJ_001>-应收发票保存接口", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (resultJson.containsKey("code") && resultJson.getString("code").equals("200")) {
				JSONObject data = resultJson.getJSONObject("data");
				contractInvoice.setBipPush("1");
				contractInvoice.setBipId(data.getLong("id"));
				contractInvoice.setBipBody(resultJson.getString("data"));
				baseMapper.updateById(contractInvoice);
			}
		}
		//红票
		if (StrUtil.equals(contractInvoice.getInvoiceCategory(),"2")) {
			JSONObject params = genRedReceiveParams(contractInvoice);
			String finalAccessToken = accessToken;

			log.info("XSJZ_YS_DJ_DELETE Request:", params.toJSONString());
			String result = HttpUtil.post(url + "/yonbip/EFI/receivable/delete?access_token=" + finalAccessToken, params.toJSONString());
			log.info("XSJZ_YS_DJ_DELETE Response:{}", result);
			//保存请求记录
			paymentConfirmService.saveBipRequestRecord(params, "< XSJZ_YS_DJ_002>-应收发票删除接口", result);
			JSONObject resultJson = JSONObject.parseObject(result);
			if (resultJson.containsKey("code") && resultJson.getString("code").equals("200")) {
				contractInvoice.setBipPush("1");
				baseMapper.updateById(contractInvoice);
			}
		}
	}

	private JSONObject genRedReceiveParams(ContractInvoice contractInvoice) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		data.put("id",contractInvoice.getBipId());
		jsonObject.put("data",data);
		return  jsonObject;
	}

	private JSONObject genBlueReceiveParams(ContractInvoice contractInvoice) {
		JSONObject jsonObject = new JSONObject();
		JSONObject data = new JSONObject();
		if (contractInvoice.getInvoiceCategory().equals("1")){
			data.put("direction","1");
		}else {
			data.put("direction","-1");
		}
		data.put("billDate",DateUtil.format(contractInvoice.getInvoiceTime(),DatePattern.NORM_DATETIME_FORMAT));
		data.put("objectType","1");
		data.put("exchangeRate","1");
		data.put("exchangeRate",DateUtil.now());
		data.put("_status","Insert");
		GenInvoiceInfoVo vo = BeanUtil.copyProperties(JSONObject.parseObject(contractInvoice.getInvoicePreview()), GenInvoiceInfoVo.class);
		JSONArray bodyItem = new JSONArray();
		for (InvoiceItemVo invoiceItemVo : vo.getInvoiceItemList()) {
			JSONObject item = new JSONObject();
			item.put("invoiceNo",contractInvoice.getInvoiceNo());
			item.put("materialCode",invoiceItemVo.getErpCode());
			item.put("taxRate", invoiceItemVo.getTaxRate());
			item.put("oriTaxAmount", invoiceItemVo.getPriceTax());
			item.put("oriTaxIncludedAmount", invoiceItemVo.getUnitPrice().multiply(invoiceItemVo.getQuantity()));
			item.put("_status","Insert");

			bodyItem.add(item);
		}
		data.put("bodyItem",bodyItem);
		jsonObject.put("data",data);
		return  jsonObject;
	}

	@Override
	public R queryRedInvoice() {
		if (bwFlag) {
			List<ContractInvoice> contractInvoices = baseMapper.selectList(Wrappers.<ContractInvoice>lambdaQuery()
					.eq(ContractInvoice::getInvoiceCategory, "2").eq(ContractInvoice::getInvoiceStatus, "3"));
			if (ArrayUtil.isNotEmpty(contractInvoices.toArray())) {
				contractInvoices.stream().forEach(contractInvoice -> {
					JSONObject request = new JSONObject();
					request.put("taxNo", contractInvoice.getTexNo());
					JSONObject data = new JSONObject();
					data.put("redConfirmSerialNo", contractInvoice.getSerialNo());
					data.put("buySelSelector", "1");
					String requestId = IdUtil.fastUUID();
					log.info("serial_no:{},红字确认单查询入参：{},", contractInvoice.getSerialNo(), request.toJSONString());
					String result = HttpUtil.post("method=baiwang.output.redinvoice.formlist&&version=1.0&request_id=" + requestId, request.toJSONString());
					log.info("serial_no:{},红字确认单查询回参：{},", contractInvoice.getSerialNo(), result);
					JSONObject resultObj = JSONObject.parseObject(result);
					saveBwRequestRecord("baiwang.output.redinvoice.formlist", requestId, request.toJSONString(), result);
					if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) && resultObj.getBoolean("success")) {
						JSONArray models = JSONArray.parseArray(resultObj.getString("model"));
						if (ArrayUtil.isNotEmpty(models.toArray())) {
							contractInvoice.setInvoiceStatus("2");
							contractInvoice.setRedReversal("1");
							baseMapper.updateById(contractInvoice);
							//推送BIP
							pushBipInvoice(contractInvoice);
						}
					}
				});
			}
		}
		return R.ok();
	}

	@Override
	public void takeEffect(Long id) {
		ContractInvoice invoice = baseMapper.selectById(id);
		Contract contract = contractMapper.selectById(invoice.getContractId());
		GenInvoiceInfoVo vo = BeanUtil.copyProperties(JSONObject.parseObject(invoice.getInvoicePreview()), GenInvoiceInfoVo.class);

		//蓝票
		if (invoice.getInvoiceCategory().equals("1")) {
			// TODO 开蓝票接口
			JSONObject request = genBlueInvoice(vo, invoice.getSerialNo());
			if (bwFlag) {
				String requestId = IdUtil.fastUUID();
				log.info("蓝票请求接口入参", request.toJSONString());
				String result = HttpUtil.post(bwUrl + "method=baiwang.output.invoice.issue&version=1.0&requestId=" + requestId, request.toJSONString());
				log.info("蓝票请求接口回参", result);
				saveBwRequestRecord("baiwang.output.invoice.issue", requestId, request.toJSONString(), result);
				JSONObject resultObj = JSONObject.parseObject(result);
				if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
						!resultObj.getBoolean("success")) {
				}
				JSONArray models = JSONArray.parseArray(resultObj.getString("success"));
				if (ArrayUtil.isNotEmpty(models.toArray())) {
					JSONObject model = (JSONObject) models.get(0);
					Date invoiceDate = DateUtil.parse(model.getString("invoiceDate"), DatePattern.PURE_DATETIME_PATTERN);
					invoice.setInvoiceTime(invoiceDate);
					invoice.setInvoiceNo(model.getString("invoiceNo"));
				}
			}

			//合同状态
			if (StrUtil.equals(contract.getBillingStatus(), "2")) {
				if (ObjUtil.isNull(contract.getBillingAmout())) {
					contract.setBillingAmout(vo.getTotalPrice());
					if (contract.getBillingAmout().compareTo(contract.getAmount()) == 0) {
						contract.setBillingStatus("3");
					}
					contractMapper.updateById(contract);
				} else {
					contract.setBillingAmout(vo.getTotalPrice().add(contract.getBillingAmout()));
					if (contract.getBillingAmout().compareTo(contract.getAmount()) == 0) {
						contract.setBillingStatus("3");
					}
					contractMapper.updateById(contract);
				}
			} else {
				if (ObjUtil.isNull(contract.getBillingAmout())) {
					contract.setBillingAmout(vo.getTotalPrice());
					contractMapper.updateById(contract);
				} else {
					contract.setBillingAmout(vo.getTotalPrice().add(contract.getBillingAmout()));
					contractMapper.updateById(contract);
				}
			}
		}
		//红票
		if (invoice.getInvoiceCategory().equals("2")) {
			// TODO 开红票接口
			ContractInvoice blueInvoice = baseMapper.selectById(invoice.getBlueInvoiceId());
			JSONObject request = genRedInvoice(blueInvoice, invoice.getSerialNo());
			String requestId = IdUtil.fastUUID();
			if (bwFlag) {
				log.info("红字确认单请求接口入参", request.toJSONString());
				String result = HttpUtil.post(bwUrl + "method=baiwang.output.redinvoice.add&version=1.0&requestId=" + requestId, request.toJSONString());
				log.info("红字确认单请求接口回参", result);
				saveBwRequestRecord("baiwang.output.redinvoice.add", requestId, request.toJSONString(), result);
				JSONObject resultObj = JSONObject.parseObject(result);
				if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
						!resultObj.getBoolean("success")) {
					JSONArray models = JSONArray.parseArray(resultObj.getString("success"));
					if (ArrayUtil.isNotEmpty(models.toArray())) {
						JSONObject model = (JSONObject) models.get(0);

						if (StrUtil.isEmpty(model.getString("confirmBillingMark"))||StrUtil.equals(model.getString("confirmBillingMark"),"N")) {
							//等待确认
							invoice.setRedReversal("3");
						}else if (StrUtil.equals(model.getString("confirmBillingMark"),"Y")) {
							//确认即开
							invoice.setInvoiceNo(model.getString("redInvoiceNo"));
							invoice.setRedReversal("1");
							//推送BIP
							pushBipInvoice(invoice);
						}
					}
				}
			}
			//更新合同开票状态 前提出库完成
			if (StrUtil.equals(contract.getBillingStatus(),"3")) {
				contract.setBillingStatus("2");
				contract.setBillingAmout(contract.getBillingAmout().subtract(invoice.getInvoiceTotalPriceTax()));
				contractMapper.updateById(contract);
			}
			blueInvoice.setRedReversal("1");
			baseMapper.updateById(blueInvoice);

			//更新合同出库单状态
			List<ContractOutBoundInvoiceVo> outBoundInvoiceVoList = BeanUtil.copyToList(JSONArray.parseArray(blueInvoice.getInvoicePreviewParam()),ContractOutBoundInvoiceVo.class);
			if (ArrayUtil.isNotEmpty(outBoundInvoiceVoList.toArray())){
				outBoundInvoiceVoList.stream().forEach(contractOutBoundInvoiceVo -> {
					ContractOutBound contractOutBound = contractOutBoundMapper.selectById(contractOutBoundInvoiceVo.getContractOutBoundId());
					contractOutBound.setInvoiceNum(contractOutBound.getInvoiceNum().subtract(contractOutBoundInvoiceVo.getInvoiceNum()));
					contractOutBoundMapper.updateById(contractOutBound);
				});
			}
		}
		invoice.setApprovalStatus("1");
		baseMapper.updateById(invoice);
	}

	@Override
	public void refuseApproval(Long id) {
		ContractInvoice invoice = baseMapper.selectById(id);
		invoice.setApprovalStatus("2");
		baseMapper.updateById(invoice);
		//蓝票
		if (invoice.getInvoiceCategory().equals("1")) {
			//更新合同出库单状态
			List<ContractOutBoundInvoiceVo> outBoundInvoiceVoList = BeanUtil.copyToList(JSONArray.parseArray(invoice.getInvoicePreviewParam()),ContractOutBoundInvoiceVo.class);
			if (ArrayUtil.isNotEmpty(outBoundInvoiceVoList.toArray())){
				outBoundInvoiceVoList.stream().forEach(contractOutBoundInvoiceVo -> {
					ContractOutBound contractOutBound = contractOutBoundMapper.selectById(contractOutBoundInvoiceVo.getContractOutBoundId());
					contractOutBound.setInvoiceNum(contractOutBound.getInvoiceNum().subtract(contractOutBoundInvoiceVo.getInvoiceNum()));
					contractOutBoundMapper.updateById(contractOutBound);
				});
			}
		}
		//红票
		if (invoice.getInvoiceCategory().equals("2")) {
			ContractInvoice blueInvoice = baseMapper.selectById(invoice.getBlueInvoiceId());
			blueInvoice.setRedReversal("0");
			baseMapper.updateById(blueInvoice);
		}
	}
}