From 9c49ede494a10d7e7a322eb2e793afa412ea07e1 Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期一, 24 八月 2026 09:35:40 +0800
Subject: [PATCH] feat:科室新增开票类型  水电房租标的物问题  机动车开票选项

---
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractInvoiceServiceImpl.java |  280 +++++++++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 248 insertions(+), 32 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
index 976dd7c..73098ea 100644
--- 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
@@ -40,10 +40,7 @@
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -137,10 +134,11 @@
 
 	@Override
 	public R genInvoiceInfo(GenInvoiceInfoDTO genInvoiceInfoDTO) {
-		if (ArrayUtil.isEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList())) {
+		if (CollUtil.isEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList())) {
 			return R.failed("璇烽�夋嫨寮�绁ㄥ嚭搴撳崟鍚庡啀鎿嶄綔");
 		}
 		Long contractId = null;
+		//棰勬敹娆惧紑绁�
 		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getContractId())) {
 			ContractPaymentSchedule schedule = contractPaymentScheduleMapper.selectOne(Wrappers.<ContractPaymentSchedule>lambdaQuery()
 					.eq(ContractPaymentSchedule::getStageName, "鍚堝悓绛捐").eq(ContractPaymentSchedule::getContractId,genInvoiceInfoDTO.getContractId())
@@ -174,6 +172,7 @@
 			return R.ok(vo);
 		}
 
+		//姝e父浜у搧寮�绁�
 		if (!StrUtil.equals(genInvoiceInfoDTO.getContractCategory(), "water_house")) {
 			ContractOutBound outBound = contractOutBoundMapper.selectById(genInvoiceInfoDTO.getOutBoundInvoiceList().get(0).getContractOutBoundId());
 			contractId = outBound.getContractId();
@@ -190,9 +189,91 @@
 			return R.failed("鑾峰彇寮�绁ㄥ崟浣嶅紓甯�");
 		}
 		SysDept b = r.getData();
+		//鏈哄姩杞﹀紑绁�
+		if (StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"3")||StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"4")){
+			if (StrUtil.isBlank(genInvoiceInfoDTO.getVehicleNo())){
+				return R.failed("鏈哄姩杞﹀紑绁ㄨ杈撳叆杞︽灦鍙�");
+			}
+			BigDecimal invoiceNumSum = genInvoiceInfoDTO.getOutBoundInvoiceList().stream().map(item->item.getInvoiceNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
+			if (invoiceNumSum.compareTo(new BigDecimal("1"))>0){
+				return R.failed("鏈哄姩杞﹀紑绁ㄥ彧鑳�1娆″紑1杈�");
+			}
+			JSONObject request = genQueryVinParam(genInvoiceInfoDTO.getVehicleNo(),b);
+			R r1 = requestQueryVehicleNo(request);
+			if (!r1.isOk()){
+				return r1;
+			}
+			JSONObject request1 = genQueryVehDetailParam(genInvoiceInfoDTO.getVehicleNo(),b);
+			R r2 = requestQueryVehicleDetail(request1);
+			if (!r2.isOk()){
+				return r2;
+			}
+			genInvoiceInfoDTO.setVehicleData(r2.getData().toString());
+		}
+
 		GenInvoiceInfoVo vo = genInvoiceInfoVo(genInvoiceInfoDTO, contract, b);
 
 		return R.ok(vo);
+	}
+
+	private R requestQueryVehicleDetail(JSONObject request) {
+		String requestId = IdUtil.fastUUID();
+
+		log.info("鏈哄姩杞﹀悎鏍艰瘉鏌ヨ鎺ュ彛鍏ュ弬锛歿},", request.toJSONString());
+		String result = HttpUtil.post(bwUrl+"method=baiwang.output.invoice.queryVinDetail&version=1.0&request_id=" + requestId, request.toJSONString());
+		log.info("鏈哄姩杞﹀悎鏍艰瘉鏌ヨ鎺ュ彛鍥炲弬锛歿},", result);
+		saveBwRequestRecord("baiwang.output.invoice.queryVinDetail", requestId, request.toJSONString(), result);
+		JSONObject resultObj = JSONObject.parseObject(result);
+		if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
+				!resultObj.getBoolean("success")) {
+			return R.failed("鏈哄姩杞﹀悎鏍艰瘉鏌ヨ澶辫触",result);
+		}
+		JSONArray models = resultObj.getJSONArray("model");
+		if (CollUtil.isNotEmpty(models)){
+			JSONObject model = (JSONObject) models.get(0);
+			return R.ok(model);
+		}
+		return R.failed("鏈哄姩杞﹀悎鏍艰瘉鏌ヨ寮傚父");
+	}
+
+	private JSONObject genQueryVehDetailParam(String vehicleNo, SysDept b) {
+		JSONObject jsonObject = new JSONObject();
+		jsonObject.put("taxNo",b.getOrgCode());
+		JSONObject data = new JSONObject();
+		data.put("vehicleNo", vehicleNo);
+		jsonObject.put("data",data);
+		return jsonObject;
+	}
+
+	private R requestQueryVehicleNo(JSONObject request) {
+		String requestId = IdUtil.fastUUID();
+
+		log.info("鏌ヨ绋庡眬杞︽灦鍙风爜鍏ュ弬锛歿},", request.toJSONString());
+		String result = HttpUtil.post(bwUrl+"method=baiwang.output.einvoice.queryvinlist&version=1.0&request_id=" + requestId, request.toJSONString());
+		log.info("鏌ヨ绋庡眬杞︽灦鍙风爜鍥炲弬锛歿},", result);
+		saveBwRequestRecord("baiwang.output.einvoice.queryvinlist", requestId, request.toJSONString(), result);
+		JSONObject resultObj = JSONObject.parseObject(result);
+		if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
+				!resultObj.getBoolean("success")) {
+			return R.failed("鏌ヨ绋庡眬杞︽灦鍙风爜澶辫触",result);
+		}
+		JSONArray models = resultObj.getJSONArray("model");
+		if (CollUtil.isNotEmpty(models)){
+			JSONObject model = (JSONObject) models.get(0);
+			if (!model.getBoolean("isOpenInvoice")){
+				return R.failed(model.getString("isNotOpenInvReason"));
+			}
+		}
+		return R.ok();
+	}
+
+	private JSONObject genQueryVinParam(String vehicleNo,SysDept b) {
+		JSONObject jsonObject = new JSONObject();
+		jsonObject.put("taxNo",b.getOrgCode());
+		JSONObject data = new JSONObject();
+		data.put("vinList", new ArrayList<String>(Arrays.asList(vehicleNo)));
+		jsonObject.put("data",data);
+		return jsonObject;
 	}
 
 	private GenInvoiceInfoVo genInvoiceInfoVo(GenInvoiceInfoDTO genInvoiceInfoDTO, Contract contract, SysDept b) {
@@ -206,6 +287,19 @@
 		vo.setPartyBOrgCode(b.getOrgCode());
 		vo.setPartyBOpenBank(b.getOrgBank());
 		vo.setPartyBBankAccount(b.getOrgBankAccount());
+		vo.setInvoiceType(a.getInvoiceType());
+		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getInvoiceType())) {
+			vo.setInvoiceVehicleType(genInvoiceInfoDTO.getInvoiceType());
+		}
+		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getVehicleNo())) {
+			vo.setVehicleNo(genInvoiceInfoDTO.getVehicleNo());
+		}
+		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getCertificateNo())) {
+			vo.setCertificateNo(genInvoiceInfoDTO.getCertificateNo());
+		}
+		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getVehicleData())) {
+			vo.setVehicleData(genInvoiceInfoDTO.getVehicleData());
+		}
 		List<InvoiceItemVo> invoiceItemVoList = new ArrayList<>();
 		List<String> erpCode = new ArrayList<>();
 		List<ContractOutBoundMergeVo> mergeOutBounds = new ArrayList<>();
@@ -229,19 +323,6 @@
 							mergeVo.setSpecification(product.getProductType());
 							mergeVo.setTaxRate(new BigDecimal(product.getTaxRate()));
 							mergeVo.setTaxCode(product.getTaxCode());
-							Product productClass = productMapper.selectById(product.getParentId());
-							if (ObjUtil.isNotNull(product)) {
-								if (StrUtil.equals(product.getErpCode(), "water_bill")) {
-									mergeVo.setItemName("*" + product.getTaxClass() + "*姘磋垂");
-								} else if (StrUtil.equals(product.getErpCode(), "electricity_bill")) {
-									mergeVo.setItemName("*" + product.getTaxClass() + "*鐢佃垂");
-								} else if (StrUtil.equals(product.getErpCode(), "house_rental")) {
-									mergeVo.setItemName("*" + product.getTaxClass() + "*鎴垮眿绉熻祦");
-								} else {
-									mergeVo.setItemName("*" + product.getTaxClass() + "*" + productClass.getProductName());
-								}
-
-							}
 						}
 						ContractSubjectMatter subjectMatter = subjectMatterMapper.selectOne(Wrappers.<ContractSubjectMatter>lambdaQuery()
 								.eq(ContractSubjectMatter::getMaterialCode, contractOutBound.getSubjectMatterCode())
@@ -249,6 +330,15 @@
 						if (ObjUtil.isNotNull(subjectMatter)) {
 							mergeVo.setUnitPrice(subjectMatter.getUnitPrice());
 							mergeVo.setUnit(subjectMatter.getUnit());
+							if (StrUtil.equals(product.getErpCode(), "water_bill")) {
+								mergeVo.setItemName("*" + product.getTaxClass() + "*姘磋垂");
+							} else if (StrUtil.equals(product.getErpCode(), "electricity_bill")) {
+								mergeVo.setItemName("*" + product.getTaxClass() + "*鐢佃垂");
+							} else if (StrUtil.equals(product.getErpCode(), "house_rental")) {
+								mergeVo.setItemName("*" + product.getTaxClass() + "*鎴垮眿绉熻祦");
+							} else {
+								mergeVo.setItemName("*" + product.getTaxClass() + "*" + subjectMatter.getMaterialName());
+							}
 						}
 						mergeOutBounds.add(mergeVo);
 					} else {
@@ -268,8 +358,10 @@
 						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));
+						invoiceItemVo.setPriceAndTax(itemPrice);
 					});
-					vo.setTotalPrice(invoiceItemVoList.stream().map(item -> item.getPriceTax().add(item.getPriceNoTax())).reduce(BigDecimal.ZERO, BigDecimal::add));
+					vo.setTotalPrice(invoiceItemVoList.stream().map(item -> item.getPriceAndTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
+					vo.setTotalTax(invoiceItemVoList.stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
 					vo.setInvoiceItemList(invoiceItemVoList);
 					vo.setPriceWords(Convert.digitToChinese(vo.getTotalPrice()));
 				}
@@ -285,6 +377,7 @@
 						mergeVo.setMaterialCode(schedule.getSubjectMatterCode());
 						mergeVo.setMaterialInternalName(schedule.getSubjectMatterName());
 						mergeVo.setPriceAndTax(schedule.getPlannedAmount());
+						mergeVo.setQuantity(schedule.getInvoiceNum());
 						Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode, schedule.getSubjectMatterCode())
 								.eq(Product::getCompId, SecurityUtils.getUser().getCompId()).last("limit 1"));
 						if (ObjUtil.isNotNull(product)) {
@@ -296,8 +389,10 @@
 							if (ObjUtil.isNotNull(product)) {
 								if (StrUtil.equals(product.getErpCode(), "water_bill")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*姘磋垂");
+									mergeVo.setUnit("鍚�");
 								} else if (StrUtil.equals(product.getErpCode(), "electricity_bill")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*鐢佃垂");
+									mergeVo.setUnit("搴�");
 								} else if (StrUtil.equals(product.getErpCode(), "house_rental")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*鎴垮眿绉熻祦");
 								} else {
@@ -329,8 +424,10 @@
 						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.getPriceAndTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
+					vo.setTotalTax(invoiceItemVoList.stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
 					vo.setInvoiceItemList(invoiceItemVoList);
 					vo.setPriceWords(Convert.digitToChinese(vo.getTotalPrice()));
 				}
@@ -376,8 +473,10 @@
 							if (ObjUtil.isNotNull(product)) {
 								if (StrUtil.equals(product.getErpCode(), "water_bill")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*姘磋垂");
+									mergeVo.setUnit("鍚�");
 								} else if (StrUtil.equals(product.getErpCode(), "electricity_bill")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*鐢佃垂");
+									mergeVo.setUnit("搴�");
 								} else if (StrUtil.equals(product.getErpCode(), "house_rental")) {
 									mergeVo.setItemName("*" + product.getTaxClass() + "*鎴垮眿绉熻祦");
 								} else {
@@ -401,8 +500,10 @@
 					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));
+					invoiceItemVo.setPriceAndTax(itemPrice);
 				});
-				vo.setTotalPrice(invoiceItemVoList.stream().map(item -> item.getPriceTax().add(item.getPriceNoTax())).reduce(BigDecimal.ZERO, BigDecimal::add));
+				vo.setTotalPrice(invoiceItemVoList.stream().map(item -> item.getPriceAndTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
+				vo.setTotalTax(invoiceItemVoList.stream().map(item -> item.getPriceTax()).reduce(BigDecimal.ZERO, BigDecimal::add));
 				vo.setInvoiceItemList(invoiceItemVoList);
 				vo.setPriceWords(Convert.digitToChinese(vo.getTotalPrice()));
 			}
@@ -415,6 +516,15 @@
 	public R toInvoice(GenInvoiceInfoDTO genInvoiceInfoDTO) {
 		if (ArrayUtil.isEmpty(genInvoiceInfoDTO.getOutBoundInvoiceList())) {
 			return R.failed("璇烽�夋嫨寮�绁ㄥ嚭搴撳崟鍚庡啀鎿嶄綔");
+		}
+		if (StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"3")||StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"4")){
+			if (StrUtil.isBlank(genInvoiceInfoDTO.getVehicleNo())){
+				return R.failed("鏈哄姩杞﹀紑绁ㄨ杈撳叆杞︽灦鍙�");
+			}
+			BigDecimal invoiceNumSum = genInvoiceInfoDTO.getOutBoundInvoiceList().stream().map(item->item.getInvoiceNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
+			if (invoiceNumSum.compareTo(new BigDecimal("1"))>0){
+				return R.failed("鏈哄姩杞﹀紑绁ㄥ彧鑳�1娆″紑1杈�");
+			}
 		}
 		Long contractId = null;
 		if (StrUtil.isNotBlank(genInvoiceInfoDTO.getContractId())) {
@@ -486,6 +596,27 @@
 			return R.failed("鑾峰彇寮�绁ㄥ崟浣嶅紓甯�");
 		}
 		SysDept b = r.getData();
+		//鏈哄姩杞﹀紑绁�
+		if (StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"3")||StrUtil.equals(genInvoiceInfoDTO.getInvoiceType(),"4")){
+			if (StrUtil.isBlank(genInvoiceInfoDTO.getVehicleNo())){
+				return R.failed("鏈哄姩杞﹀紑绁ㄨ杈撳叆杞︽灦鍙�");
+			}
+			BigDecimal invoiceNumSum = genInvoiceInfoDTO.getOutBoundInvoiceList().stream().map(item->item.getInvoiceNum()).reduce(BigDecimal.ZERO,BigDecimal::add);
+			if (invoiceNumSum.compareTo(new BigDecimal("1"))>0){
+				return R.failed("鏈哄姩杞﹀紑绁ㄥ彧鑳�1娆″紑1杈�");
+			}
+			JSONObject request = genQueryVinParam(genInvoiceInfoDTO.getVehicleNo(),b);
+			R r1 = requestQueryVehicleNo(request);
+			if (!r1.isOk()){
+				return r1;
+			}
+			JSONObject request1 = genQueryVehDetailParam(genInvoiceInfoDTO.getVehicleNo(),b);
+			R r2 = requestQueryVehicleDetail(request1);
+			if (!r2.isOk()){
+				return r2;
+			}
+			genInvoiceInfoDTO.setVehicleData(r2.getData().toString());
+		}
 		GenInvoiceInfoVo vo = genInvoiceInfoVo(genInvoiceInfoDTO, contract, b);
 		//鍙戠エ淇濆瓨
 		ContractInvoice invoice = saveContractInvoice(vo, contract, genInvoiceInfoDTO.getOutBoundInvoiceList(), DateUtil.current() + "","0");
@@ -532,7 +663,7 @@
 		bwRequestRecordMapper.insert(bwRequestRecord);
 	}
 
-	private JSONObject genBlueInvoice(GenInvoiceInfoVo vo, String serialNo) {
+	private JSONObject genBlueInvoice(GenInvoiceInfoVo vo, String serialNo,SysDept dept) {
 		JSONObject jsonObject = new JSONObject();
 		//閿�鏂�
 		jsonObject.put("taxNo", vo.getPartyBOrgCode());//绋庡彿
@@ -541,7 +672,7 @@
 		jsonObject.put("formatPushType", false);//鐗堝紡鐢熸垚鏄惁鎺ㄩ��(true / false)
 		//data
 		JSONObject data = new JSONObject();
-		data.put("invoiceTypeCode", "01");
+		data.put("invoiceTypeCode", vo.getInvoiceType());
 		data.put("serialNo", serialNo);
 		//data.invoiceDetailsList
 		JSONArray invoiceDetailsList = new JSONArray();
@@ -557,6 +688,12 @@
 			invoiceDetail.put("goodsUnit", invoiceItemVo.getUnit());
 			invoiceDetail.put("goodsQuantity", invoiceItemVo.getQuantity());
 //			invoiceDetail.put("goodsPrice", invoiceItemVo.getUnitPrice());
+			if (StrUtil.equals(vo.getInvoiceVehicleType(),"3")){
+				invoiceDetail.put("goodsSpecification", vo.getVehicleNo());
+			}else {
+				invoiceDetail.put("goodsSpecification", invoiceItemVo.getSpecification());
+			}
+
 			if (!StrUtil.equals(vo.getContractCategory(), "water_house")) {
 				invoiceDetail.put("goodsTotalPrice", invoiceItemVo.getPriceNoTax());
 			} else {
@@ -571,7 +708,7 @@
 		//璐柟
 		data.put("buyerTaxNo", vo.getPartyAOrgCode());
 		data.put("buyerName", vo.getPartyA());
-		data.put("drawer", SecurityUtils.getUser().getPhone());// TODO 绋庡姟鎬诲眬绯荤粺鐧婚檰浜烘墜鏈哄彿
+		data.put("drawer", dept.getInvoiceContact());// TODO 绋庡姟鎬诲眬绯荤粺鐧婚檰浜烘墜鏈哄彿
 		data.put("invoiceTotalPriceTax", vo.getTotalPrice());
 		data.put("buyerBankName", vo.getPartyAOpenBank());
 		data.put("buyerBankNumber", vo.getPartyABankAccount());
@@ -671,7 +808,7 @@
 		jsonObject.put("sellerTaxName", blueInvoice.getSellerTaxName());
 		jsonObject.put("buyerTaxName", blueInvoice.getBuyerTaxName());
 		jsonObject.put("buyerTaxNo", blueInvoice.getBuyerTaxNo());
-		jsonObject.put("originInvoiceDate", blueInvoice.getInvoiceTime());
+		jsonObject.put("originInvoiceDate", DateUtil.formatDateTime(blueInvoice.getInvoiceTime()));
 		jsonObject.put("originInvoiceTotalPrice", blueInvoice.getInvoiceTotalPrice());
 		jsonObject.put("originInvoiceTotalTax", blueInvoice.getInvoiceTotalTax());
 		jsonObject.put("invoiceTotalPrice", blueInvoice.getInvoiceTotalPrice().multiply(new BigDecimal("-1")));
@@ -896,20 +1033,52 @@
 	@Override
 	public void takeEffect(Long id) {
 		ContractInvoice invoice = baseMapper.selectById(id);
+		R<SysDept> r = remoteDeptService.getById(SecurityUtils.getUser().getCompId());
+		if (!r.isOk()){
+			log.error("鍗曚綅淇℃伅鏌ヨ寮傚父");
+			return;
+		}
+		SysDept dept = r.getData();
 		Contract contract = contractMapper.selectById(invoice.getContractId());
 		GenInvoiceInfoVo vo = BeanUtil.copyProperties(JSONObject.parseObject(invoice.getInvoicePreview()), GenInvoiceInfoVo.class);
 		vo.setContractCategory(contract.getContractCategory());
 		invoice.setApprovalStatus("1");
 		baseMapper.updateById(invoice);
 		invoice.setBwRequestResult("0");
+
 		//钃濈エ
 		if (invoice.getInvoiceCategory().equals("1")) {
-			// TODO 寮�钃濈エ鎺ュ彛
-			JSONObject request = genBlueInvoice(vo, invoice.getSerialNo());
+			// TODO 寮�钃濈エ鎺ュ彛鏈哄姩杞�
+			if (StrUtil.equals(vo.getInvoiceVehicleType(),"3")){
+				JSONObject request = genBlueInvoiceVehicle(vo, invoice.getSerialNo(),dept);
+				String requestId = IdUtil.fastUUID();
+				invoice.setBwRequestId(requestId);
+				invoice.setBwRequestParam(request.toJSONString());
+				log.info("鏈哄姩杞﹀彂绁ㄥ紑鍏疯姹傛帴鍙e叆鍙�:{}", request.toJSONString());
+				String result = HttpUtil.post(bwUrl + "method=baiwang.output.invoice.vehicleissue&version=1.0&requestId=" + requestId, request.toJSONString());
+				log.info("鏈哄姩杞﹀彂绁ㄥ紑鍏疯姹傛帴鍙e洖鍙�:{}", result);
+				saveBwRequestRecord("baiwang.output.invoice.vehicleissue", requestId, request.toJSONString(), result);
+				JSONObject resultObj = JSONObject.parseObject(result);
+				if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
+						resultObj.getBoolean("success")) {
+					log.info("寮�绁ㄦ垚鍔燂紒锛侊紒");
+					invoice.setBwRequestResult("1");
+				}
+				JSONObject modelJson = resultObj.getJSONObject("model");
+				if (ObjUtil.isNotNull(modelJson)) {
+					Date invoiceDate = DateUtil.parse(modelJson.getString("invoiceDate"), DatePattern.PURE_DATETIME_PATTERN);
+					invoice.setInvoiceTime(invoiceDate);
+					invoice.setInvoiceNo(modelJson.getString("invoiceNo"));
+					//鎺ㄩ�丅IP
+					pushBipInvoice(invoice);
+				}
+			}
+
+			// TODO 寮�钃濈エ鎺ュ彛 闈炴満鍔ㄨ溅
+			JSONObject request = genBlueInvoice(vo, invoice.getSerialNo(),dept);
 			if (bwFlag) {
 				String requestId = IdUtil.fastUUID();
 				invoice.setBwRequestId(requestId);
-				invoice.setBwRequestResult("1");
 				invoice.setBwRequestParam(request.toJSONString());
 				log.info("钃濈エ璇锋眰鎺ュ彛鍏ュ弬:{}", request.toJSONString());
 				String result = HttpUtil.post(bwUrl + "method=baiwang.output.invoice.issue&version=1.0&requestId=" + requestId, request.toJSONString());
@@ -966,10 +1135,7 @@
 				//鍒ゆ柇 寰幆鏄惁瀹屾垚
 				List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery().eq(ContractExecDate::getContractId, contract.getId())
 						.eq(ContractExecDate::getGenFlag, "0"));
-				List<MeterReadRecord> recordList = meterReadRecordMapper.selectList(Wrappers.<MeterReadRecord>lambdaQuery()
-						.eq(MeterReadRecord::getContractId, contract.getId())
-						.isNull(MeterReadRecord::getMeterReadNum));
-				if (ArrayUtil.isEmpty(execDateList) && ArrayUtil.isEmpty(recordList)) {
+				if (CollUtil.isEmpty(execDateList)) {
 					//鍒ゆ柇鏄惁鏈夊彲寮�绁ㄨ褰�
 					List<ContractPaymentSchedule> scheduleList = contractPaymentScheduleMapper.selectList(Wrappers.<ContractPaymentSchedule>lambdaQuery()
 							.eq(ContractPaymentSchedule::getContractId, contract.getId()).eq(ContractPaymentSchedule::getInvoiceFlag, "0"));
@@ -1090,6 +1256,56 @@
 
 	}
 
+	private JSONObject genBlueInvoiceVehicle(GenInvoiceInfoVo vo, String serialNo,SysDept dept) {
+		JSONObject vechicleData = JSONObject.parseObject(vo.getVehicleData());
+		JSONObject jsonObject = new JSONObject();
+		//閿�鏂�
+		jsonObject.put("taxNo", vo.getPartyBOrgCode());//绋庡彿
+		jsonObject.put("invoiceTerminalCode", "JDCwxj");//瓒呰繃鍙戠エ鍗曞紶闄愰鏄惁闇�瑕佹媶鍒嗗紑鍏凤紝榛樿涓嶆媶鍒嗭紙鎷嗗垎鍙敮鎸佸彂绁ㄧ被鍨嬩唬鐮佷负 涓撶エ 004 鏅エ 007 鐢靛瓙绁� 026鐨�
+		jsonObject.put("formatGenerate", false);//鏄惁闇�瑕佺敓鎴愮増寮忚繑鍥炵増寮忛摼鎺�(true / false)
+		jsonObject.put("formatPushType", false);//鐗堝紡鐢熸垚鏄惁鎺ㄩ��(true / false)
+		jsonObject.put("taxUserName", dept.getInvoiceContact());
+		//data
+		JSONObject data = new JSONObject();
+		data.put("invoiceTypeCode", "03");
+		data.put("invoiceType", "0");
+		data.put("serialNo", serialNo);
+		//data.invoiceDetailsList
+		Integer lineNo = 1;
+		JSONObject invoiceDetail = new JSONObject();
+
+		invoiceDetail.put("vehicleNo", vo.getVehicleNo());
+		invoiceDetail.put("manufacturingEnterprise","03");
+		invoiceDetail.put("originPlace", vechicleData.getString("originPlace"));
+		invoiceDetail.put("certificateNo",vo.getCertificateNo());
+		invoiceDetail.put("engineNo",vechicleData.getString("engineNo"));
+		invoiceDetail.put("tonnage",vechicleData.getString("tonnage"));
+		invoiceDetail.put("passengersLimited",vechicleData.getString("passengersLimited"));
+		invoiceDetail.put("brandModel",vechicleData.getString("brandModel"));
+
+		invoiceDetail.put("goodsCode", vo.getInvoiceItemList().get(0).getTaxCode());
+		invoiceDetail.put("goodsTaxRate", vo.getInvoiceItemList().get(0).getTaxRate().divide(new BigDecimal("100")));
+		if (!StrUtil.equals(vo.getContractCategory(), "water_house")) {
+			invoiceDetail.put("goodsTotalPrice", vo.getInvoiceItemList().get(0).getPriceNoTax());
+		} else {
+			invoiceDetail.put("goodsTotalPrice", vo.getInvoiceItemList().get(0).getPriceNoTax());
+		}
+		invoiceDetail.put("goodsTotalTax", vo.getInvoiceItemList().get(0).getPriceTax());
+		data.put("invoiceVehicleInfo", invoiceDetail);
+		//璐柟
+		data.put("buyerTaxNo", vo.getPartyAOrgCode());
+		data.put("buyerName", vo.getPartyA());
+		data.put("sellerTaxNo", vo.getPartyBOrgCode());// TODO 绋庡姟鎬诲眬绯荤粺鐧婚檰浜烘墜鏈哄彿
+		data.put("invoiceTotalPrice", vo.getTotalPrice().subtract(vo.getTotalTax()));
+		data.put("invoiceTotalPriceTax", vo.getTotalPrice());
+		data.put("invoiceTotalTax", vo.getTotalTax());
+		data.put("buyerBankName", vo.getPartyAOpenBank());
+		data.put("buyerBankNumber", vo.getPartyABankAccount());
+
+		jsonObject.put("data", data);
+		return jsonObject;
+	}
+
 	@Override
 	public void refuseApproval(Long id) {
 		ContractInvoice invoice = baseMapper.selectById(id);
@@ -1190,7 +1406,7 @@
 				JSONObject resultObj = JSONObject.parseObject(result);
 				if (resultObj.containsKey("requestId") && StrUtil.equals(resultObj.getString("requestId"), requestId) &&
 						!resultObj.getBoolean("success")) {
-					log.error("绾㈠瓧纭鍗曟垚鍔燂紒锛侊紒");
+					log.error("绾㈠瓧纭鍗曞け璐ワ紒锛侊紒");
 
 					return R.failed(resultObj.getString("message"));
 				}

--
Gitblit v1.9.1