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 +++++++++++++++++++++++++++---
 platformx-business-finance-biz/src/main/resources/mapper/ContractMapper.xml                                                              |    1 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractPageVo.java                                      |    2 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/MeterReadRecordServiceImpl.java                |    4 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractPaymentScheduleProcessServiceImpl.java |    6 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/ContractController.java                          |   14 +
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/ContractService.java                                |    2 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/BusinessCustomer.java                                |    4 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractHouseWaterVo.java                                |    3 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/dto/GenInvoiceInfoDTO.java                                  |    7 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java                       |  129 +++++++++++++-
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java                 |    2 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/OutBoundServiceImpl.java                       |    6 
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentOffsetServiceImpl.java                  |    2 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/ContractPaymentSchedule.java                         |    4 
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/GenInvoiceInfoVo.java                                    |   17 +
 platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractDetailVo.java                                    |    3 
 17 files changed, 438 insertions(+), 48 deletions(-)

diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/dto/GenInvoiceInfoDTO.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/dto/GenInvoiceInfoDTO.java
index a8c1a55..fdf79ab 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/dto/GenInvoiceInfoDTO.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/dto/GenInvoiceInfoDTO.java
@@ -14,4 +14,11 @@
 
 	private String contractId;
 
+	private String invoiceType;
+
+	private String vehicleNo;
+
+	private String certificateNo;
+
+	private String vehicleData;
 }
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/BusinessCustomer.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/BusinessCustomer.java
index fcc8b14..b371e50 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/BusinessCustomer.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/BusinessCustomer.java
@@ -91,6 +91,10 @@
     @Column(columnDefinition = "VARCHAR(40) comment '鑱旂郴鐢佃瘽'")
     private String contactPhone;
 
+	@Schema(description = "寮�绁ㄧ被鍨�")
+	@Column(columnDefinition = "VARCHAR(2) comment '寮�绁ㄧ被鍨� 绁� 01:鍏ㄧ數鍙戠エ(澧炲�肩◣涓撶敤鍙戠エ) 02:鍏ㄧ數鍙戠エ(鏅�氬彂绁�)' ")
+	private String invoiceType;
+
 /*    @Schema(description = "閭")
     @Column(columnDefinition = "VARCHAR(50) comment '閭'")
     private String email;*/
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/ContractPaymentSchedule.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/ContractPaymentSchedule.java
index c2c355c..48246f7 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/ContractPaymentSchedule.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/entity/ContractPaymentSchedule.java
@@ -170,6 +170,10 @@
 	@Column(columnDefinition="char comment '寮�绁ㄦ爣璇� 0/鏈紑 1/宸插紑'")
 	private String invoiceFlag;
 
+	@Schema(description = "寮�绁ㄦ暟閲� 姘寸數涓撶敤")
+	@Column(columnDefinition = "decimal(14,2) comment '寮�绁ㄦ暟閲� 姘寸數涓撶敤'")
+	private BigDecimal invoiceNum;
+
 //    @Schema(description = "鎺掑簭鍙�")
 //    @Column(columnDefinition = "int default 0 comment '鎺掑簭鍙�'")
 //    private Integer sortOrder;
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractDetailVo.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractDetailVo.java
index 3761788..7d64468 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractDetailVo.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractDetailVo.java
@@ -246,6 +246,9 @@
 	@Schema(description = "绠�鏄撳悎鍚岄檮浠跺悕绉�")
 	private String attachmentSimpleName;
 
+	@Schema(description = "寮�绁ㄧ被鍨�")
+	private String invoiceType;
+
 	private List<ContractPaymentSchedule> contractPaymentSchedule;
 
 	private List<ContractSubjectMatter> contractSubjectMatter;
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractHouseWaterVo.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractHouseWaterVo.java
index 3516134..9aec9f3 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractHouseWaterVo.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractHouseWaterVo.java
@@ -19,6 +19,9 @@
 	@Schema(description = "璁″垝鏀舵閲戦")
 	private BigDecimal plannedAmount;
 
+	@Schema(description = "寮�绁ㄦ暟閲�")
+	private BigDecimal invoiceNum;
+
 	@Schema(description = "澶囨敞")
 	private String remark;
 
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractPageVo.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractPageVo.java
index 40d0252..84feb93 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractPageVo.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/ContractPageVo.java
@@ -185,4 +185,6 @@
 
 	@Schema(description = "璐ㄤ繚鑺傜偣ID")
 	private Long warrantyScheduleId;
+
+	private String centerPushFlag;
 }
diff --git a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/GenInvoiceInfoVo.java b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/GenInvoiceInfoVo.java
index 40a2eaa..c14a4d0 100644
--- a/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/GenInvoiceInfoVo.java
+++ b/platformx-business-finance-api/src/main/java/com/by4cloud/platformx/business/vo/GenInvoiceInfoVo.java
@@ -15,6 +15,18 @@
 	@Schema(description = "棰勫紑鍙戠エ")
 	private String advanceInvoice;
 
+	@Schema(description = "杞︽灦鍙�")
+	private String vehicleNo;
+
+	@Schema(description = "杞﹁締鍚堟牸璇佸彿")
+	private String certificateNo;
+
+	@Schema(description = "浜ょ◣鍒嗙被")
+	private String invoiceType;
+
+	@Schema(description = "鏈哄姩杞︿氦绋庡垎绫�")
+	private String invoiceVehicleType;
+
 	@Schema(description = "鐢叉柟鍚嶇О")
 	private String partyA;
 
@@ -42,8 +54,13 @@
 	@Schema(description = "寮�绁ㄩ噾棰濓紙鍚◣锛�")
 	private BigDecimal totalPrice;
 
+	@Schema(description = "绋庨")
+	private BigDecimal totalTax;
+
 	@Schema(description = "澶у啓寮�绁ㄩ噾棰�")
 	private String priceWords;
 
+	private String vehicleData;
+
 	private List<InvoiceItemVo> invoiceItemList;
 }
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/ContractController.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/ContractController.java
index 0ade98b..5864fb8 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/ContractController.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/controller/ContractController.java
@@ -76,7 +76,19 @@
         return R.ok(contractService.detail(id));
     }
 
-    /**
+	/**
+	 * 閫氳繃id鎵嬪姩鎺ㄩ�佸悎鍚屼腑蹇�
+	 * @param id id
+	 * @return R
+	 */
+	@Operation(summary = "閫氳繃id鎵嬪姩鎺ㄩ�佸悎鍚屼腑蹇�" , description = "閫氳繃id鎵嬪姩鎺ㄩ�佸悎鍚屼腑蹇�" )
+	@GetMapping("/pushCenter/{id}" )
+	public R pushCenter(@PathVariable("id" ) Long id) {
+		return contractService.pushCenter(id);
+	}
+
+
+	/**
      * 鏂板鍚堝悓绠$悊
      * @param addDTO 鍚堝悓绠$悊
      * @return R
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/ContractService.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/ContractService.java
index 49fb6ab..22940cb 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/ContractService.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/ContractService.java
@@ -66,4 +66,6 @@
 	void exportContractJXCXSWord(Long id, HttpServletResponse response);
 
 	R addSimple(ContractAddDTO addDTO);
+
+	R pushCenter(Long id);
 }
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"));
 				}
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractPaymentScheduleProcessServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractPaymentScheduleProcessServiceImpl.java
index c1a18c9..1529de8 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractPaymentScheduleProcessServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractPaymentScheduleProcessServiceImpl.java
@@ -246,7 +246,8 @@
 						//褰撳墠涓哄悎鍚屾渶鍚庨樁娈�
 						PaymentConfirm lastNewConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
 								.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
-						if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0) {
+						if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0
+								&&contract.getBillingAmout().compareTo(contract.getAmount())==0) {
 							//鏈夐浠樹笖瓒呰繃搴旀敹 鍏抽棴鍚堝悓鐘舵��
 							contract.setContractStatus(3);
 							contractMapper.updateById(contract);
@@ -358,7 +359,8 @@
 				//褰撳墠涓哄悎鍚屾渶鍚庨樁娈�
 				PaymentConfirm lastNewConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
 						.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
-				if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0) {
+				if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0
+						&&contract.getBillingAmout().compareTo(contract.getAmount())==0) {
 					//鏈夐浠樹笖瓒呰繃搴旀敹 鍏抽棴鍚堝悓鐘舵��
 					contract.setContractStatus(3);
 					contractMapper.updateById(contract);
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java
index 4245c12..2f5997a 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java
@@ -425,6 +425,10 @@
 		if (CollUtil.isNotEmpty(slipList)){
 			detailVo.setPaymentSlip(slipList);
 		}
+		BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
+		if (ObjUtil.isNotNull(customer)){
+			detailVo.setInvoiceType(customer.getInvoiceType());
+		}
 		return detailVo;
 	}
 
@@ -720,15 +724,58 @@
 					}
 
 				}
-				if (StrUtil.equals(contract.getPartyBId()+"",smj)&&StrUtil.isNotEmpty(smjErp)){
-					log.info("鐭崇叅鏈哄悎鍚屾帹閫乪rp鍏ュ弬锛歿}",request.toJSONString());
-					String result = HttpUtil.post(smjErp,request.toJSONString());
-					log.info("鐭崇叅鏈哄悎鍚屾帹閫乪rp鍥炲弬锛歿}",result);
-					//淇濆瓨璇锋眰璁板綍
-					saveErpRequestRecord("smj",request.toJSONString(),result);
-					//鏇存柊鍚堝悓erp鎺ㄩ�佹爣璇�
-					contract.setErpPushFlag("1");
-					baseMapper.updateById(contract);
+				if ((StrUtil.equals(contract.getPartyBId()+"",smj)||StrUtil.equals(contract.getPartyBId()+"",smjsc)||
+						StrUtil.equals(contract.getPartyBId()+"",smjzt))&&StrUtil.isNotEmpty(smjErp)){
+					request.put("customerCode",customer.getErpCompanyCode());
+					request.put("currencyId","RMB");
+					request.put("signDate",DateUtil.format(contract.getSignDate(),DatePattern.NORM_DATETIME_PATTERN));
+					request.put("dateDeliver",DateUtil.format(contract.getExpirationDate(),DatePattern.NORM_DATETIME_PATTERN));
+					request.put("moneySum",contract.getAmount());
+					request.put("signManner","闈㈢");
+					request.put("salesman","");
+					if (ArrayUtil.isNotEmpty(subjectMatterList)){
+						JSONArray subjectMatter = new JSONArray();
+						subjectMatterList.stream().forEach(contractSubjectMatter -> {
+							JSONObject subjectMatterItem = new JSONObject();
+							subjectMatterItem.put("itemNo",contractSubjectMatter.getMaterialCode());
+							subjectMatterItem.put("salePrice",contractSubjectMatter.getUnitPrice());
+							subjectMatterItem.put("qtyRequired",contractSubjectMatter.getQuantity());
+							subjectMatterItem.put("money",contractSubjectMatter.getQuantity().multiply(contractSubjectMatter.getUnitPrice()));
+							Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getCompId,contract.getCompId())
+									.eq(Product::getErpCode,contractSubjectMatter.getMaterialCode()));
+							if (ObjUtil.isNotNull(product)){
+								subjectMatterItem.put("taxRate",new BigDecimal(product.getTaxRate()).divide(new BigDecimal("100")));
+							}
+							subjectMatterItem.put("dateDeliver",ObjUtil.isNotNull(contractSubjectMatter.getPlannedDeliveryDate())?
+									DateUtil.format(contractSubjectMatter.getPlannedDeliveryDate(),DatePattern.NORM_DATETIME_PATTERN):
+									DateUtil.format(contract.getExpirationDate(),DatePattern.NORM_DATETIME_PATTERN));
+							subjectMatter.add(subjectMatterItem);
+						});
+						request.put("details",subjectMatter);
+					}
+
+					JSONObject loginJson = new JSONObject();
+					loginJson.put("username","admin");
+					loginJson.put("password","Zimafold@2026");
+					log.info("鐭崇叅鏈哄悎鍚屾帹閫佽幏鍙杢oken鍏ュ弬锛歿}",loginJson.toJSONString());
+					String loginResp = HttpUtil.post(smjErp+"/api/account/v1/login",loginJson.toJSONString());
+					log.info("鐭崇叅鏈哄悎鍚屾帹閫佽幏鍙杢oken鍥炲弬锛歿}",loginResp);
+					JSONObject respJson = JSONObject.parseObject(loginResp);
+					if (respJson.getInteger("code")==0){
+						JSONObject dataJson = JSONObject.parseObject(respJson.getString("data"));
+						log.info("鐭崇叅鏈哄悎鍚屾帹閫乪rp鍏ュ弬锛歿}",request.toJSONString());
+						HttpResponse response = HttpRequest.post(smjErp+"/api/contract/v1/createWithDetails")
+								.header("token", dataJson.getString("token"))       // 娣诲姞璁よ瘉澶�
+								.header("Content-Type", "application/json")         // 璁剧疆鍐呭绫诲瀷
+								.body(request.toJSONString())                        // 璁剧疆璇锋眰浣�
+								.execute();                                         // 鎵ц璇锋眰.post(ymjErp,request.toJSONString());
+						log.info("鐭崇叅鏈哄悎鍚屾帹閫乪rp鍥炲弬锛歿}",response.body());
+						//淇濆瓨璇锋眰璁板綍
+						saveErpRequestRecord("smj",request.toJSONString(),response.body());
+						//鏇存柊鍚堝悓erp鎺ㄩ�佹爣璇�
+						contract.setErpPushFlag("1");
+						baseMapper.updateById(contract);
+					}
 				}
 
 				if (StrUtil.equals(contract.getPartyBId()+"",jxc)&&StrUtil.isNotEmpty(jxcErp)){
@@ -1188,6 +1235,8 @@
 				}
 				contractExecDate.setGenFlag("1");
 				contractExecDateMapper.updateById(contractExecDate);
+				contract.setBillingStatus("2");
+				baseMapper.updateById(contract);
 			});
 		}
 		return R.ok();
@@ -2270,4 +2319,66 @@
 		baseMapper.insert(contract);
 		return R.ok();
 	}
+
+	@Override
+	public R pushCenter(Long id) {
+		Contract contract = baseMapper.selectById(id);
+		List<ContractSubjectMatter> subjectMatterList=contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
+				.eq(ContractSubjectMatter::getContractId,id));
+		JSONObject requestApply = new JSONObject();
+		requestApply.put("fd_selectionmethod", "鍏紑鎷涙爣");
+		requestApply.put("fd_isrelated", "鏄�");
+		requestApply.put("fd_bizId", contract.getId());
+		requestApply.put("fd_remark", contract.getRemark());
+		requestApply.put("fd_MainContent", "");
+		requestApply.put("fd_settlementType", "00");
+		requestApply.put("fd_applyType", "澶栭攢");
+		requestApply.put("fd_contractsubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
+		requestApply.put("fd_docNumber", contract.getContractNo());
+		requestApply.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
+		requestApply.put("fd_name", contract.getContractName());
+		requestApply.put("fd_signDate", DateUtil.formatDate(contract.getSignDate()));
+		requestApply.put("fd_endDate", DateUtil.formatDate(contract.getExpirationDate()));
+		requestApply.put("fd_contractCreater", contract.getNickName());
+		requestApply.put("fd_currency", "浜烘皯甯�");
+		requestApply.put("fd_ContractAmount", contract.getAmount());
+		requestApply.put("fd_finAmount", contract.getAmount().divide(new BigDecimal("113"), 2, RoundingMode.HALF_UP)
+				.multiply(new BigDecimal("87")));
+		requestApply.put("fd_docStatus", "20");
+		requestApply.put("fd_taxRates", 13);
+		requestApply.put("fd_customerName", contract.getPartyA());
+		requestApply.put("fd_systemSource", "闈炵叅閿�鍞郴缁�");
+		requestApply.put("fd_type", "00");
+		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍏ュ弬锛歿}", requestApply.toJSONString());
+		String respApply = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
+		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍥炲弬锛歿}", respApply);
+		JSONObject applyResp = JSONObject.parseObject(respApply);
+		if (applyResp.getString("code").equals("00")) {
+			JSONObject request = new JSONObject();
+			request.put("fd_docNumber", contract.getContractNo());
+			request.put("fd_singer", contract.getNickName());
+			request.put("fd_signTime", DateUtil.formatDate(contract.getSignDate()));
+			request.put("fd_linkPerson", "");
+			request.put("fd_linkPhone", "");
+			request.put("fd_address", contract.getSignPlace());
+			request.put("fd_receivedTime", DateUtil.format(contract.getCreateTime(), DatePattern.NORM_DATETIME_PATTERN));
+			request.put("fd_receivedNum", 1);
+			request.put("fd_effedate", DateUtil.formatDate(contract.getSignDate()));
+			request.put("fd_enddate", DateUtil.formatDate(contract.getExpirationDate()));
+			request.put("fd_reviewerNo", contract.getNickName());
+			request.put("fd_docStatus", "20");
+			request.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
+			request.put("fd_attName", contract.getAttachmentName());
+			request.put("fd_attcontent", NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
+			log.info("鍚堝悓涓績鍚屾鍚堝悓鎺ュ彛鍏ュ弬锛歿}", request.toJSONString());
+			String resp = HttpUtil.post("https://oatest.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addContractReview", request.toJSONString());
+			log.info("鍚堝悓涓績鍚屾鍚堝悓鎺ュ彛鍥炲弬锛歿}", resp);
+			JSONObject respJson = JSONObject.parseObject(resp);
+			if (respJson.getString("code").equals("00")) {
+				contract.setCenterPushFlag("1");
+				baseMapper.updateById(contract);
+			}
+		}
+		return R.ok();
+	}
 }
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/MeterReadRecordServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/MeterReadRecordServiceImpl.java
index c695e47..baa79ff 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/MeterReadRecordServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/MeterReadRecordServiceImpl.java
@@ -100,6 +100,7 @@
 		schedule.setPaymentStatus(0);
 		schedule.setActualAmount(new BigDecimal("0"));
 		schedule.setInvoiceFlag("0");
+		schedule.setInvoiceNum(record.getUsageNum());
 		contractPaymentScheduleMapper.insert(schedule);
 		//鎴垮眿绉熻祦鐢熸垚搴旀敹
 		PaymentConfirm confirm = new PaymentConfirm();
@@ -133,6 +134,9 @@
 			confirm.setCompId(contract.getCompId());
 			paymentConfirmMapper.insert(confirm);
 		}
+		contract.setBillingStatus("2");
+		contract.setAmount(contract.getAmount().add(confirm.getTransationAmount()));
+		contractMapper.updateById(contract);
 		//鍒ゆ柇 寰幆鏄惁瀹屾垚
 		List<ContractExecDate> execDateList = contractExecDateMapper.selectList(Wrappers.<ContractExecDate>lambdaQuery().eq(ContractExecDate::getContractId,contract.getId())
 				.eq(ContractExecDate::getGenFlag,"0"));
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/OutBoundServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/OutBoundServiceImpl.java
index 32a829d..a5b26da 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/OutBoundServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/OutBoundServiceImpl.java
@@ -405,7 +405,8 @@
 						//褰撳墠涓哄悎鍚屾渶鍚庨樁娈�
 						PaymentConfirm lastNewConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
 								.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
-						if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0) {
+						if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0
+								&&contract.getBillingAmout().compareTo(contract.getAmount())==0) {
 							//鏈夐浠樹笖瓒呰繃搴旀敹 鍏抽棴鍚堝悓鐘舵��
 							contract.setContractStatus(3);
 							contractMapper.updateById(contract);
@@ -736,7 +737,8 @@
 				//褰撳墠涓哄悎鍚屾渶鍚庨樁娈�
 				PaymentConfirm lastNewConfirm = paymentConfirmMapper.selectOne(Wrappers.<PaymentConfirm>lambdaQuery().eq(PaymentConfirm::getContractId, contract.getId())
 						.orderByDesc(PaymentConfirm::getCreateTime).last("limit 1"));
-				if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0) {
+				if (lastNewConfirm.getTotalAmount().compareTo(new BigDecimal("0")) >= 0
+						&&contract.getBillingAmout().compareTo(contract.getAmount())==0) {
 					//鏈夐浠樹笖瓒呰繃搴旀敹 鍏抽棴鍚堝悓鐘舵��
 					contract.setContractStatus(3);
 					contractMapper.updateById(contract);
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
index 885ac46..6472e46 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentConfirmServiceImpl.java
@@ -209,7 +209,7 @@
 				}
 				paid = paid.add(addDTO.getTransationAmount());
 				contract.setPaidAmount(paid);
-				if (paid.compareTo(contract.getAmount()) == 0) {
+				if (paid.compareTo(contract.getAmount()) == 0&&contract.getBillingAmout().compareTo(contract.getAmount())==0) {
 					contract.setContractStatus(3);
 					contract.setPaidAmount(contract.getAmount());
 				}
diff --git a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentOffsetServiceImpl.java b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentOffsetServiceImpl.java
index aed8023..ab5d187 100644
--- a/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentOffsetServiceImpl.java
+++ b/platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/PaymentOffsetServiceImpl.java
@@ -137,7 +137,7 @@
 		}
 		paid = paid.add(paymentOffset.getOffsetAmount());
 		contract.setPaidAmount(paid);
-		if (paid.compareTo(contract.getAmount())==0){
+		if (paid.compareTo(contract.getAmount())==0&&contract.getBillingAmout().compareTo(contract.getAmount())==0){
 //			contract.setBillingStatus("2");
 			contract.setContractStatus(3);
 		}
diff --git a/platformx-business-finance-biz/src/main/resources/mapper/ContractMapper.xml b/platformx-business-finance-biz/src/main/resources/mapper/ContractMapper.xml
index a22070a..0e416cd 100644
--- a/platformx-business-finance-biz/src/main/resources/mapper/ContractMapper.xml
+++ b/platformx-business-finance-biz/src/main/resources/mapper/ContractMapper.xml
@@ -1094,6 +1094,7 @@
 		   	c.next_schedule_name,
 		    c.warranty_schedule_id,
 			c.comp_id,
+			c.center_push_flag,
 			(select sum(delivered_quantity*unit_price) from contract_subject_matter csm where csm.contract_id = c.id) outAmount
 			FROM
 		contract c,

--
Gitblit v1.9.1