From 6bbed1ea6b36af4eb0b234bec9d6e42d56f0cd00 Mon Sep 17 00:00:00 2001
From: shiyunteng <shiyunteng@example.com>
Date: 星期三, 30 九月 2026 16:12:49 +0800
Subject: [PATCH] feat:合同新增关联单位  开票可根据甲方或关联单位选择开票单位  收款去掉强制确认 收款只关联合同甲方或关联单位

---
 platformx-business-finance-biz/src/main/java/com/by4cloud/platformx/business/service/impl/ContractServiceImpl.java |  522 ++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 419 insertions(+), 103 deletions(-)

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 c14554a..3add066 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
@@ -5,7 +5,6 @@
 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.ObjUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.HttpRequest;
@@ -29,7 +28,6 @@
 import com.by4cloud.platformx.business.entity.*;
 import com.by4cloud.platformx.business.mapper.*;
 import com.by4cloud.platformx.business.service.ContractPaymentScheduleProcessService;
-import com.by4cloud.platformx.business.service.ContractPaymentScheduleService;
 import com.by4cloud.platformx.business.service.ContractService;
 import com.by4cloud.platformx.business.utils.BatchInsertListener;
 import com.by4cloud.platformx.business.utils.ItemGeneratorUtil;
@@ -49,6 +47,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.core.io.ClassPathResource;
 import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.security.core.parameters.P;
 import org.springframework.stereotype.Service;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -101,6 +100,12 @@
 	@Value("${erp.smj}")
 	private String smjErp;
 
+	@Value("${erp.smjsc}")
+	private String smjscErp;
+
+	@Value("${erp.smjzt}")
+	private String smjztErp;
+
 	@Value("${erp.sgb}")
 	private String sgbErp;
 
@@ -118,6 +123,9 @@
 
 	@Value("${dept.smjzt}")
 	private String smjzt;
+
+	@Value("${dept.smjhw}")
+	private String smjhw;
 
 	@Value("${dept.sgb}")
 	private String sgb;
@@ -196,7 +204,8 @@
 		}
 
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			contract.setContractNo(generateSMJContractNo());
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -320,7 +329,8 @@
 		contract.setBillingAmout(new BigDecimal("0"));
 		contract.setNickName(SecurityUtils.getUser().getNickname());
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			contract.setContractNo(generateSMJContractNo());
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -515,12 +525,13 @@
 		requestApply.put("fd_settlementType", "00");
 		requestApply.put("fd_applyType", "澶栭攢");
 		if (CollUtil.isNotEmpty(subjectMatterList)) {
-			requestApply.put("fd_contractsubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
+			requestApply.put("fd_contractSubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
 		}
 		requestApply.put("fd_docNumber", contract.getContractNo());
 //		requestApply.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			requestApply.put("fd_templateId", tempSMJ);
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -538,16 +549,18 @@
 		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_contractCreater", SecurityUtils.getUser().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_docStatus", "10");
 		requestApply.put("fd_taxRates", 13);
 		requestApply.put("fd_customerName", contract.getPartyA());
 		requestApply.put("fd_systemSource", "闈炵叅閿�鍞郴缁�");
 		requestApply.put("fd_type", "00");
+		requestApply.put("fd_baozhangren", comp.getBaozhangren());
+		requestApply.put("fd_summary",contract.getSummary());
 		JSONArray signList = new JSONArray();
 		JSONObject j = new JSONObject();
 		j.put("fd_standing","鐢�");
@@ -555,19 +568,48 @@
 		j.put("fd_signMain","2");
 		signList.add(j);
 		JSONObject y = new JSONObject();
-		y.put("fd_standing","鐢�");
+		y.put("fd_standing","涔�");
 		y.put("fd_Iden",comp.getOrgCode());
 		y.put("fd_signMain","1");
 		signList.add(y);
 		requestApply.put("fd_signList", signList);
-		JSONArray attList = new JSONArray();
-		JSONObject att = new JSONObject();
-		att.put("fd_attNum","1");
-		att.put("fd_attName",contract.getAttachmentName());
-		att.put("fd_attQuality","00");
-		att.put("fd_attcontent",NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
-		attList.add(att);
-		requestApply.put("attList", att);
+		if (StrUtil.isNotBlank(contract.getAttachmentUrl())) {
+			JSONArray attList = new JSONArray();
+			JSONObject att = new JSONObject();
+			att.put("fd_attNum", "1");
+			att.put("fd_attName", contract.getAttachmentName());
+			att.put("fd_attType", contract.getAttachmentName().substring(contract.getAttachmentName().lastIndexOf('.')+1));
+			att.put("fd_attQuality", "00");
+			att.put("fd_attcontent", NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
+			attList.add(att);
+			requestApply.put("attList", attList);
+		}
+		if (CollUtil.isNotEmpty(subjectMatterList)){
+			JSONArray materialList = new JSONArray();
+			subjectMatterList.stream().forEach(subjectMatter->{
+				JSONObject material = new JSONObject();
+				material.put("fd_materiaCode", subjectMatter.getMaterialCode());
+				material.put("fd_materiaName", subjectMatter.getMaterialInternalName());
+				material.put("fd_specification", StrUtil.isNotBlank(subjectMatter.getSpecification())?subjectMatter.getSpecification():"");
+				material.put("fd_figureNumber", "");
+				material.put("fd_measureUnit", subjectMatter.getUnit());
+				material.put("fd_number", subjectMatter.getQuantity());
+				material.put("fd_price", subjectMatter.getUnitPrice());
+				Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode,subjectMatter.getMaterialCode()).last("limit 1"));
+				if (ObjUtil.isNotNull(product)){
+					material.put("fd_rate", product.getTaxRate().toString());
+				}
+				material.put("fd_amount", subjectMatter.getUnitPrice().multiply(subjectMatter.getQuantity()));
+				material.put("fd_requirements", "");
+				material.put("fd_standard", "");
+				material.put("fd_factory", "");
+				material.put("fd_Deadlines", ObjUtil.isNotNull(subjectMatter.getPlannedDeliveryDate())?subjectMatter.getPlannedDeliveryDate():"");
+				material.put("fd_delivery", "");
+				material.put("fd_des", "");
+				materialList.add(material);
+			});
+			requestApply.put("materialList", materialList);
+		}
 		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍏ュ弬锛歿}", requestApply.toJSONString());
 		String respApply = HttpUtil.post("https://oa.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
 		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍥炲弬锛歿}", respApply);
@@ -632,7 +674,7 @@
 				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_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());
@@ -664,7 +706,7 @@
 					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_reviewerNo", SecurityUtils.getUser().getNickname());
 					request.put("fd_docStatus", "20");
 					request.put("fd_templateId", "19e39bb6c1edadbdb162c434274a8a18");
 					request.put("fd_attName", contract.getAttachmentName());
@@ -722,33 +764,32 @@
 						});
 						request.put("details", subjectMatter);
 					}
-
-					JSONObject loginJson = new JSONObject();
-					loginJson.put("username", "admin");
-					loginJson.put("password", "admin123");
-					log.info("涓�鐓ゆ満鍚堝悓鎺ㄩ�佽幏鍙杢oken鍏ュ弬锛歿}", loginJson.toJSONString());
-					String loginResp = HttpUtil.post(ymjErp + "/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(ymjErp + "/api/contract-staging/v1/receive")
-								.header("token", dataJson.getString("token"))       // 娣诲姞璁よ瘉澶�
-								.header("Content-Type", "application/json")         // 璁剧疆鍐呭绫诲瀷
-								.body(request.toJSONString())                        // 璁剧疆璇锋眰浣�
-								.execute();                                         // 鎵ц璇锋眰.post(ymjErp,request.toJSONString());
-						log.info("涓�鐓ゆ満鍚堝悓鎺ㄩ�乪rp鍥炲弬锛歿}", response.body());
-						//淇濆瓨璇锋眰璁板綍
-						saveErpRequestRecord("ymj", request.toJSONString(), response.body());
-						//鏇存柊鍚堝悓erp鎺ㄩ�佹爣璇�
-						contract.setErpPushFlag("1");
-						baseMapper.updateById(contract);
+					String token = "";
+					if (redisTemplate.hasKey("YMJ_ERP_TOKEN")) {
+						token = (String) redisTemplate.opsForValue().get("YMJ_ERP_TOKEN");
+					} else {
+						token = getYmjErpToken();
 					}
+					if (StrUtil.isEmpty(token)){
+						log.error("涓�鐓ゆ満鐧诲綍鑾峰彇token澶辫触");
+						return;
+					}
+					log.info("涓�鐓ゆ満鍚堝悓鎺ㄩ�乪rp鍏ュ弬锛歿}", request.toJSONString());
+					HttpResponse response = HttpRequest.post(ymjErp + "/api/contract-staging/v1/receive")
+							.header("token", token)       // 娣诲姞璁よ瘉澶�
+							.header("Content-Type", "application/json")         // 璁剧疆鍐呭绫诲瀷
+							.body(request.toJSONString())                        // 璁剧疆璇锋眰浣�
+							.execute();                                         // 鎵ц璇锋眰.post(ymjErp,request.toJSONString());
+					log.info("涓�鐓ゆ満鍚堝悓鎺ㄩ�乪rp鍥炲弬锛歿}", response.body());
+					//淇濆瓨璇锋眰璁板綍
+					saveErpRequestRecord("ymj", request.toJSONString(), response.body());
+					//鏇存柊鍚堝悓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)) {
+				if ((StrUtil.equals(contract.getPartyBId() + "", smj) ||
+						StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) && StrUtil.isNotEmpty(smjErp)) {
 					request.put("customerCode", customer.getErpCompanyCode());
 					request.put("currencyId", "RMB");
 					request.put("signDate", DateUtil.format(contract.getSignDate(), DatePattern.NORM_DATETIME_PATTERN));
@@ -756,6 +797,7 @@
 					request.put("moneySum", contract.getAmount());
 					request.put("signManner", "闈㈢");
 					request.put("salesman", "");
+					request.put("tenantId", "tenant1");
 					if (CollUtil.isNotEmpty(subjectMatterList)) {
 						JSONArray subjectMatter = new JSONArray();
 						subjectMatterList.stream().forEach(contractSubjectMatter -> {
@@ -777,30 +819,139 @@
 						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);
-					}
-				}
 
+					String token = "";
+					if (redisTemplate.hasKey("SMJ_ERP_TOKEN")) {
+						token = (String) redisTemplate.opsForValue().get("SMJ_ERP_TOKEN");
+					} else {
+						token = getErpToken();
+					}
+					if (StrUtil.isEmpty(token)){
+						log.error("鐭崇叅鏈虹櫥褰曡幏鍙杢oken澶辫触");
+						return;
+					}
+
+					log.info("鐭崇叅鏈哄悎鍚屾帹閫乪rp鍏ュ弬锛歿}", request.toJSONString());
+					HttpResponse response = HttpRequest.post(smjErp + "/api/contract/v1/createWithDetails?tenantId=tenant1")
+							.header("token", 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() + "", smjsc) && StrUtil.isNotEmpty(smjscErp)) {
+					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", "");
+					request.put("tenantId", "tenant2");
+					if (CollUtil.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);
+					}
+
+					String token = "";
+					if (redisTemplate.hasKey("SMJ_ERP_TOKEN")) {
+						token = (String) redisTemplate.opsForValue().get("SMJ_ERP_TOKEN");
+					} else {
+						token = getErpToken();
+					}
+					if (StrUtil.isEmpty(token)){
+						log.error("鐭崇叅鏈虹櫥褰曡幏鍙杢oken澶辫触");
+						return;
+					}
+
+					log.info("鐭崇叅鏈洪殢杞﹀垎鍏徃鍚堝悓鎺ㄩ�乪rp鍏ュ弬锛歿}", request.toJSONString());
+					HttpResponse response = HttpRequest.post(smjErp + "/api/contract/v1/createWithDetails?tenantId=tenant2")
+							.header("token", 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() + "", smjzt) && StrUtil.isNotEmpty(smjztErp)) {
+					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", "");
+					request.put("tenantId", "tenant3");
+					if (CollUtil.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);
+					}
+
+					String token = "";
+					if (redisTemplate.hasKey("SMJ_ERP_TOKEN")) {
+						token = (String) redisTemplate.opsForValue().get("SMJ_ERP_TOKEN");
+					} else {
+						token = getErpToken();
+					}
+					if (StrUtil.isEmpty(token)){
+						log.error("鐭崇叅鏈虹櫥褰曡幏鍙杢oken澶辫触");
+						return;
+					}
+
+					log.info("鐭崇叅鏈洪捇鎺㈠垎鍏徃鍚堝悓鎺ㄩ�乪rp鍏ュ弬锛歿}", request.toJSONString());
+					HttpResponse response = HttpRequest.post(smjztErp + "/api/contract/v1/createWithDetails?tenantId=tenant3")
+							.header("token", 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)) {
 					log.info("鏈烘鍘傚悎鍚屾帹閫乪rp鍏ュ弬锛歿}", request.toJSONString());
 					String result = HttpUtil.post(jxcErp, request.toJSONString());
@@ -822,6 +973,40 @@
 
 	}
 
+	private String getErpToken() {
+		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"));
+			redisTemplate.opsForValue().set("SMJ_ERP_TOKEN",dataJson.getString("token"));
+			log.info("鐭崇叅鏈篹rp token涓猴細{}",dataJson.getString("token"));
+			return dataJson.getString("token");
+		}
+		return "";
+	}
+
+	private String getYmjErpToken(){
+		JSONObject loginJson = new JSONObject();
+		loginJson.put("username", "admin");
+		loginJson.put("password", "admin123");
+		log.info("涓�鐓ゆ満鍚堝悓鎺ㄩ�佽幏鍙杢oken鍏ュ弬锛歿}", loginJson.toJSONString());
+		String loginResp = HttpUtil.post(ymjErp + "/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"));
+			redisTemplate.opsForValue().set("YMJ_ERP_TOKEN",dataJson.getString("token"));
+			log.info("涓�鐓ゆ満erp token涓猴細{}",dataJson.getString("token"));
+			return dataJson.getString("token");
+		}
+		return "";
+	}
+
 	private void saveScheduleProcess(Contract contract,ContractPaymentSchedule schedule) {
 		//鏂板鍚堝悓灞ョ害璁板綍
 		ContractPaymentScheduleProcess process = new ContractPaymentScheduleProcess();
@@ -830,7 +1015,12 @@
 		process.setScheduleId(schedule.getId());
 		process.setScheduleName(schedule.getStageName());
 		process.setProcessDate(contract.getSignDate());
-		contractPaymentScheduleProcessMapper.insert(process);
+		ContractPaymentScheduleProcess lastProcess = contractPaymentScheduleProcessMapper.selectOne(Wrappers.<ContractPaymentScheduleProcess>lambdaQuery()
+				.eq(ContractPaymentScheduleProcess::getContractId, schedule.getContractId())
+				.eq(ContractPaymentScheduleProcess::getScheduleId, schedule.getId()).last("limit 1"));
+		if (ObjUtil.isNull(lastProcess)) {
+			contractPaymentScheduleProcessMapper.insert(process);
+		}
 	}
 
 	private void handleWaterHouseCycle(Contract contract, List<ContractSubjectMatter> subjectMatterList) {
@@ -1076,7 +1266,8 @@
 		newContract.setContractStatus(0);
 		newContract.setBillingAmout(new BigDecimal("0"));
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			newContract.setContractNo(generateSMJContractNo());
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -1716,6 +1907,10 @@
 
 	@Override
 	public R addContractSgb(ContractAddDTO addDTO) {
+		Contract contractOld = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getDataId, addDTO.getDataId()).last("limit 1"));
+		if (ObjUtil.isNotNull(contractOld)) {
+			return R.failed("鍚堝悓鏁版嵁ID锛歿}宸插瓨鍦紝涓嶈兘鏂板閲嶅鏁版嵁", addDTO.getDataId());
+		}
 		if (CollUtil.isEmpty(addDTO.getContractSubjectMatter())) {
 			return R.failed("璇锋坊鍔犳爣鐨勭墿");
 		}
@@ -1773,7 +1968,24 @@
 			addDTO.getContractSubjectMatter().stream().forEach(contractSubjectMatterAddDTO -> {
 				ContractSubjectMatter subjectMatter = BeanUtil.copyProperties(contractSubjectMatterAddDTO, ContractSubjectMatter.class);
 				subjectMatter.setContractId(contract.getId());
-
+				if (StrUtil.isNotBlank(subjectMatter.getMaterialCode())){
+					Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode,subjectMatter.getMaterialCode())
+							.last("limit 1"));
+					if (ObjUtil.isNotNull(product)){
+						subjectMatter.setMaterialInternalName(product.getId()+"");
+					}
+					if (ObjUtil.isNull(product)){
+						product = new Product();
+						product.setParentId(2101559148831944705L);
+						product.setProductName(subjectMatter.getMaterialInternalName());
+						product.setErpCode(subjectMatter.getMaterialCode());
+						product.setProductType(subjectMatter.getSpecification());
+						product.setTaxCode("1090117040000000000");
+						product.setTaxClass("娉�");
+						productMapper.insert(product);
+						subjectMatter.setMaterialInternalName(product.getId()+"");
+					}
+				}
 				subjectMatter.setDeliveredQuantity(new BigDecimal("0"));
 				subjectMatter.setDeliveryStatus(0);
 				subjectMatter.setTotalAmount(contractSubjectMatterAddDTO.getQuantity().multiply(contractSubjectMatterAddDTO.getUnitPrice()));
@@ -1838,7 +2050,7 @@
 		}
 
 		//鎺ㄩ�佸悎鍚屼腑蹇�
-		pushCenter(contract.getId());
+//		pushCenter(contract.getId());
 		return R.ok(contract.getContractNo());
 	}
 
@@ -2351,7 +2563,8 @@
 		contract.setNickName(SecurityUtils.getUser().getNickname());
 
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			contract.setContractNo(generateSMJContractNo());
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -2371,8 +2584,17 @@
 	}
 
 	@Override
-	public R pushCenter(Long id) {
-		Contract contract = baseMapper.selectById(id);
+	public R pushCenter(PushCenterDTO dto) {
+		Contract contract = baseMapper.selectById(dto.getId());
+
+		contract.setSelectionMethod(dto.getSelectionMethod());
+		contract.setIsRelated(dto.getIsRelated());
+		contract.setContractCreater(dto.getContractCreater());
+		if(StrUtil.isNotBlank(dto.getAttachmentUrl())) {
+			contract.setAttachmentName(dto.getAttachmentName());
+			contract.setAttachmentUrl(dto.getAttachmentUrl());
+		}
+		baseMapper.updateById(contract);
 
 		BusinessCustomer customer = businessCustomerMapper.selectById(contract.getPartyAId());
 		if (ObjUtil.isNull(customer)){
@@ -2386,20 +2608,21 @@
 		SysDept comp = r.getData();
 
 		List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
-				.eq(ContractSubjectMatter::getContractId, id));
+				.eq(ContractSubjectMatter::getContractId, dto.getId()));
 		JSONObject requestApply = new JSONObject();
-		requestApply.put("fd_selectionmethod", "鍏紑鎷涙爣");
-		requestApply.put("fd_isrelated", "鏄�");
+		requestApply.put("fd_selectionmethod", dto.getSelectionMethod());
+		requestApply.put("fd_isrelated", dto.getIsRelated());
 		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_contractSubject ", subjectMatterList.stream().map(item -> item.getMaterialName()).collect(Collectors.joining(",")));
 		requestApply.put("fd_docNumber", contract.getContractNo());
 
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			requestApply.put("fd_templateId", tempSMJ);
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -2417,7 +2640,7 @@
 		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_contractCreater", StrUtil.isNotEmpty(dto.getContractCreater())?dto.getContractCreater():SecurityUtils.getUser().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)
@@ -2427,6 +2650,8 @@
 		requestApply.put("fd_customerName", contract.getPartyA());
 		requestApply.put("fd_systemSource", "闈炵叅閿�鍞郴缁�");
 		requestApply.put("fd_type", "00");
+		requestApply.put("fd_baozhangren", comp.getBaozhangren());
+		requestApply.put("fd_summary",contract.getSummary());
 		JSONArray signList = new JSONArray();
 		JSONObject j = new JSONObject();
 		j.put("fd_standing","鐢�");
@@ -2434,29 +2659,58 @@
 		j.put("fd_signMain","2");
 		signList.add(j);
 		JSONObject y = new JSONObject();
-		y.put("fd_standing","鐢�");
+		y.put("fd_standing","涔�");
 		y.put("fd_Iden",comp.getOrgCode());
 		y.put("fd_signMain","1");
 		signList.add(y);
 		requestApply.put("fd_signList", signList);
-		JSONArray attList = new JSONArray();
-		JSONObject att = new JSONObject();
-		att.put("fd_attNum","1");
-		att.put("fd_attName",contract.getAttachmentName());
-		att.put("fd_attQuality","00");
-		att.put("fd_attcontent",NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
-		attList.add(att);
-		requestApply.put("attList", att);
-		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍏ュ弬锛歿}", requestApply.toJSONString());
+		if(StrUtil.isNotBlank(contract.getAttachmentUrl())){
+			JSONArray attList = new JSONArray();
+			JSONObject att = new JSONObject();
+			att.put("fd_attNum","1");
+			att.put("fd_attName",contract.getAttachmentName());
+			att.put("fd_attQuality","00");
+			att.put("fd_attcontent",NetworkFileToBase64.convertNetworkFileToBase64("https://zbjt.res.jzeg.cn/api" + contract.getAttachmentUrl()));
+			attList.add(att);
+			requestApply.put("attList", att);
+		}
+		if (CollUtil.isNotEmpty(subjectMatterList)){
+			JSONArray materialList = new JSONArray();
+			subjectMatterList.stream().forEach(subjectMatter->{
+				JSONObject material = new JSONObject();
+				material.put("fd_materiaCode", subjectMatter.getMaterialCode());
+				material.put("fd_materiaName", subjectMatter.getMaterialInternalName());
+				material.put("fd_specification", StrUtil.isNotBlank(subjectMatter.getSpecification())?subjectMatter.getSpecification():"");
+				material.put("fd_figureNumber", "");
+				material.put("fd_measureUnit", subjectMatter.getUnit());
+				material.put("fd_number", subjectMatter.getQuantity());
+				material.put("fd_price", subjectMatter.getUnitPrice());
+				Product product = productMapper.selectOne(Wrappers.<Product>lambdaQuery().eq(Product::getErpCode,subjectMatter.getMaterialCode()).last("limit 1"));
+				if (ObjUtil.isNotNull(product)){
+					material.put("fd_rate", product.getTaxRate().toString());
+				}
+				material.put("fd_amount", subjectMatter.getUnitPrice().multiply(subjectMatter.getQuantity()));
+				material.put("fd_requirements", "");
+				material.put("fd_standard", "");
+				material.put("fd_factory", "");
+				material.put("fd_Deadlines", ObjUtil.isNotNull(subjectMatter.getPlannedDeliveryDate())?subjectMatter.getPlannedDeliveryDate():"");
+				material.put("fd_delivery", "");
+				material.put("fd_des", "");
+				materialList.add(material);
+			});
+			requestApply.put("materialList", materialList);
+		}
+		log.info("宸ヤ笟娉垫帹閫佲�斺�斿悎鍚屼腑蹇冨悎鍚岃捣鑽夋帴鍙e叆鍙傦細{}", requestApply.toJSONString());
 		String respApply = HttpUtil.post("https://oa.res.jzeg.cn/ekp/api/km-agreement/kmAgreementWebService/addSupplyContractApply", requestApply.toJSONString());
-		log.info("鍚堝悓涓績鍚堝悓璧疯崏鎺ュ彛鍥炲弬锛歿}", respApply);
+		log.info("宸ヤ笟娉垫帹閫佲�斺�斿悎鍚屼腑蹇冨悎鍚岃捣鑽夋帴鍙e洖鍙傦細{}", respApply);
 		JSONObject applyResp = JSONObject.parseObject(respApply);
 		if (applyResp.getString("code").equals("00")) {
 			contract.setCenterPushFlag("1");
 			baseMapper.updateById(contract);
 			return R.ok();
 		}
-		return R.failed("鎺ㄩ�佸悎鍚屼腑蹇冨鏍稿け璐ワ紝鍘熷洜涓猴細{}",applyResp.getString("msg"));
+		log.error("宸ヤ笟娉垫帹閫佲�斺�旀帹閫佸悎鍚屼腑蹇冨鏍稿け璐ワ紝鍘熷洜涓猴細{}",applyResp.getString("msg"));
+		return R.failed("宸ヤ笟娉垫帹閫佲�斺�旀帹閫佸悎鍚屼腑蹇冨鏍稿け璐ワ紝鍘熷洜涓猴細{}",applyResp.getString("msg"));
 	}
 
 	@Override
@@ -2755,8 +3009,9 @@
 
 	@Override
 	public R syncContractStatus(SyncContractStatusDTO dto) {
-		if (StrUtil.isBlank(dto.getContractNumber())){
-			return R.failed("鍚堝悓缂栧彿涓嶈兘涓虹┖");
+		log.info("鍚堝悓瀹℃壒缁撴灉鍚屾锛屽悎鍚岀紪鍙�:{}锛屽鎵圭粨鏋滐細{}",dto.getContractNumber(),dto.getStatus());
+		if (StrUtil.isBlank(dto.getFd_bizId())){
+			return R.failed("鏁版嵁ID涓嶈兘涓虹┖");
 		}
 		if (StrUtil.isBlank(dto.getStatus())){
 			return R.failed("瀹℃壒鐘舵�佷笉鑳戒负绌�");
@@ -2764,18 +3019,22 @@
 		if (StrUtil.isBlank(dto.getReturnPerson())){
 			return R.failed("瀹℃壒浜轰笉鑳戒负绌�");
 		}
-		if (StrUtil.isBlank(dto.getReturnDateTime())){
+		if (StrUtil.isBlank(dto.getReturnDate())){
 			return R.failed("瀹℃壒鏃堕棿涓嶈兘涓虹┖");
 		}
-		Contract contract = baseMapper.selectOne(Wrappers.<Contract>lambdaQuery().eq(Contract::getContractNo,dto.getContractNumber()).last("limit 1"));
+		Contract contract = baseMapper.selectById(dto.getFd_bizId());
 		if(ObjUtil.isNull(contract)){
-			return R.failed("鍚堝悓缂栧彿涓嶅紓甯�");
+			return R.failed("鏁版嵁ID寮傚父");
 		}
 		if (StrUtil.equals(dto.getStatus(),"1")){
 			takeEffect(contract.getId());
 		}
-		if (!StrUtil.equals(dto.getStatus(),"1")){
+		if (StrUtil.equals(dto.getStatus(),"2")){
 			refuseApproval(contract.getId());
+		}
+		if (StrUtil.equals(dto.getStatus(),"3")||StrUtil.equals(dto.getStatus(),"4")){
+			contract.setContractStatus(3);
+			baseMapper.updateById(contract);
 		}
 		saveContractApproval(contract,dto);
 		return R.ok();
@@ -2784,7 +3043,7 @@
 	private void saveContractApproval(Contract contract, SyncContractStatusDTO dto) {
 		ContractApproval approval = BeanUtil.copyProperties(dto,ContractApproval.class);
 		approval.setContractId(contract.getId());
-		approval.setReturnDateTime(DateUtil.parseDateTime(dto.getReturnDateTime()));
+		approval.setReturnDateTime(DateUtil.parseDateTime(dto.getReturnDate()));
 		approval.setCompId(contract.getCompId());
 		contractApprovalMapper.insert(approval);
 	}
@@ -2798,21 +3057,31 @@
 		if (!StrUtil.equals(contract.getContractStatus()+"","2")){
 			return R.failed("鍚堝悓寮傚父鐘舵��");
 		}
+		contract.setSignDate(attDTO.getSignDate());
+		contract.setExpirationDate(attDTO.getExpirationDate());
+		contract.setSinger(attDTO.getSinger());
+		contract.setReviewerNo(attDTO.getReviewerNo());
+		contract.setLinkPerson(attDTO.getLinkPerson());
+		contract.setLinkPhone(attDTO.getLinkPhone());
+		Long betweenDay = DateUtil.betweenDay(attDTO.getExpirationDate(),attDTO.getSignDate(),true);
+		contract.setDeliveryCycle(betweenDay.intValue());
+		baseMapper.updateById(contract);
 		JSONObject request = new JSONObject();
 		request.put("fd_docNumber", contract.getContractNo());
-		request.put("fd_singer", contract.getNickName());
+		request.put("fd_singer", StrUtil.isNotEmpty(attDTO.getSinger())?attDTO.getSinger():SecurityUtils.getUser().getNickname());
 		request.put("fd_signTime", DateUtil.formatDate(contract.getSignDate()));
-		request.put("fd_linkPerson", "");
-		request.put("fd_linkPhone", "");
+		request.put("fd_linkPerson", StrUtil.isNotEmpty(attDTO.getLinkPerson())?attDTO.getLinkPerson():"");
+		request.put("fd_linkPhone", StrUtil.isNotEmpty(attDTO.getLinkPhone())?attDTO.getLinkPhone():"");
 		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_reviewerNo", StrUtil.isNotEmpty(attDTO.getReviewerNo())?attDTO.getReviewerNo():SecurityUtils.getUser().getNickname());
 		request.put("fd_docStatus", "20");
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smj) || StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjsc) ||
-				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)) {
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjzt)||
+				StrUtil.equals(SecurityUtils.getUser().getCompId() + "", smjhw)) {
 			request.put("fd_templateId", tempSMJ);
 		}
 		if (StrUtil.equals(SecurityUtils.getUser().getCompId() + "", sgb)) {
@@ -3067,4 +3336,51 @@
 		}
 		return R.ok();
 	}
+
+	@Override
+	public R getFinallyInfo(Long id) {
+		Contract contract = baseMapper.selectById(id);
+		return R.ok(BeanUtil.copyProperties(contract,ContractFinallyVo.class));
+	}
+
+	@Override
+	public R erpPush(Long id) {
+		Contract contract = baseMapper.selectById(id);
+		List<ContractSubjectMatter> subjectMatterList = contractSubjectMatterMapper.selectList(Wrappers.<ContractSubjectMatter>lambdaQuery()
+				.eq(ContractSubjectMatter::getContractId, id));
+		pushSubCompany(contract,subjectMatterList);
+		return R.ok();
+	}
+
+	@Override
+	public R associationPartyC(ContractAssociationPartyCyDTO associationPartyCyDTO) {
+		Contract contract = baseMapper.selectById(associationPartyCyDTO.getId());
+		contract.setPartyCId(Long.valueOf(associationPartyCyDTO.getPartyCId()));
+		baseMapper.updateById(contract);
+		return R.ok();
+	}
+
+	@Override
+	public R getInvoiceObj(Long id) {
+		Contract contract = baseMapper.selectById(id);
+		ContractInvoiceObjVo objVo = BeanUtil.copyProperties(contract,ContractInvoiceObjVo.class);
+		List<BusinessCustomerSelectVo> selectVoList = new ArrayList<>();
+		BusinessCustomer a = businessCustomerMapper.selectById(contract.getPartyAId());
+		if (ObjUtil.isNotNull(a)){
+			objVo.setPartyA(a.getCompanyName());
+			objVo.setPartyAOrgCode(a.getCreditCode());
+			objVo.setInvoiceType(StrUtil.isNotBlank(a.getInvoiceType())?a.getInvoiceType():"01");
+			BusinessCustomerSelectVo selectVo = BeanUtil.copyProperties(a,BusinessCustomerSelectVo.class);
+			selectVoList.add(selectVo);
+		}
+		if (ObjUtil.isNotNull(contract.getPartyCId())){
+			BusinessCustomer c = businessCustomerMapper.selectById(contract.getPartyCId());
+			if (ObjUtil.isNotNull(c)){
+				BusinessCustomerSelectVo selectVo = BeanUtil.copyProperties(c,BusinessCustomerSelectVo.class);
+				selectVoList.add(selectVo);
+			}
+		}
+		objVo.setLinkPartyC(selectVoList);
+		return R.ok(objVo);
+	}
 }

--
Gitblit v1.9.1