From b0ba33dce8487581d2bb3c49f886d158724dc44e Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期一, 08 六月 2026 17:19:49 +0800
Subject: [PATCH] fix:产品列表接口

---
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractInvoiceServiceImpl.java |  652 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 652 insertions(+), 0 deletions(-)

diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractInvoiceServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractInvoiceServiceImpl.java
new file mode 100644
index 0000000..fa9c7b6
--- /dev/null
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractInvoiceServiceImpl.java
@@ -0,0 +1,652 @@
+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.ContractInvoiceOutBoundVo;
+import com.by4cloud.platformx.business.vo.ContractOutBoundMergeVo;
+import com.by4cloud.platformx.business.vo.GenInvoiceInfoVo;
+import com.by4cloud.platformx.business.vo.InvoiceItemVo;
+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);
+		return R.ok(invoiceOutBoundVoList);
+	}
+
+	@Override
+	public R genInvoiceInfo(GenInvoiceInfoDTO genInvoiceInfoDTO) {
+		if (ArrayUtil.isEmpty(genInvoiceInfoDTO.getContractOutBoundIds())) {
+			return R.failed("璇烽�夋嫨寮�绁ㄥ嚭搴撳崟鍚庡啀鎿嶄綔");
+		}
+		ContractOutBound outBound = contractOutBoundMapper.selectById(genInvoiceInfoDTO.getContractOutBoundIds().get(0));
+		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.getCompanyName());
+		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.getContractOutBoundIds()));
+		if (ArrayUtil.isNotEmpty(outBounds.toArray())) {
+			outBounds.stream().forEach(contractOutBound -> {
+				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(contractOutBound.getOutBoundNum());
+					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.getContractOutBoundIds().toArray())) {
+			return R.failed("璇烽�夋嫨寮�绁ㄥ嚭搴撳崟鍚庡啀鎿嶄綔");
+		}
+		ContractOutBound outBound = contractOutBoundMapper.selectById(genInvoiceInfoDTO.getContractOutBoundIds().get(0));
+		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.getContractOutBoundIds(), 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.getContractOutBoundIds().stream().forEach(outBoundId -> {
+			ContractOutBound bound = contractOutBoundMapper.selectById(outBoundId);
+			bound.setInvoiceStatus("1");
+			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<Long> outBoundIds, 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(outBoundIds.stream()
+				.map(String::valueOf) // 鎴栬�� .map(Object::toString)
+				.collect(Collectors.joining(",")));
+		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");
+		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);
+					}
+					//鎺ㄩ�丅IP
+					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);
+							//鎺ㄩ�丅IP
+							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");
+							//鎺ㄩ�丅IP
+							pushBipInvoice(invoice);
+						}
+					}
+				}
+			}
+			//鏇存柊鍚堝悓寮�绁ㄧ姸鎬�
+			contract.setBillingStatus("2");
+			contract.setBillingAmout(contract.getAmount().subtract(invoice.getInvoiceTotalPriceTax()));
+			contractMapper.updateById(contract);
+
+			//鏇存柊鍚堝悓鍑哄簱鍗曠姸鎬�
+			String[] outBoundIds = blueInvoice.getOutBoundId().split(",");
+			Arrays.stream(outBoundIds).forEach(outBoundId -> {
+				ContractOutBound bound = contractOutBoundMapper.selectById(outBoundId);
+				bound.setInvoiceStatus("0");
+				contractOutBoundMapper.updateById(bound);
+			});
+		}
+		invoice.setApprovalStatus("1");
+		baseMapper.updateById(invoice);
+	}
+
+	@Override
+	public void refuseApproval(Long id) {
+		ContractInvoice invoice = baseMapper.selectById(id);
+		//鏇存柊鍚堝悓鍑哄簱鍗曠姸鎬�
+		String[] outBoundIds = invoice.getOutBoundId().split(",");
+		Arrays.stream(outBoundIds).forEach(outBoundId -> {
+			ContractOutBound bound = contractOutBoundMapper.selectById(outBoundId);
+			bound.setInvoiceStatus("0");
+			contractOutBoundMapper.updateById(bound);
+		});
+		invoice.setApprovalStatus("2");
+		baseMapper.updateById(invoice);
+	}
+}

--
Gitblit v1.9.1