From 6c6b10257d0df6259ac1811774e1de44a283c7c7 Mon Sep 17 00:00:00 2001
From: CZT <czt18638530771@163.com>
Date: 星期四, 09 十一月 2023 18:55:21 +0800
Subject: [PATCH] 新增宁夏省平台对接
---
src/main/java/com/fzzy/api/service/ApiTriggerService.java | 1
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService11.java | 18
src/main/java/com/fzzy/api/data/PushProtocol.java | 3
src/main/java/com/fzzy/push/nx2023/NX2023ApiRemoteService.java | 487 +++++++++
src/main/java/com/fzzy/push/nx2023/NX2023PushService14.java | 109 ++
src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1102.java | 64 +
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService14.java | 10
src/main/java/com/fzzy/push/nx2023/NX2023PushService11.java | 513 ++++++++++
src/main/java/com/fzzy/api/utils/NxRSAUtils.java | 172 +++
src/main/java/com/fzzy/push/nx2023/NX2023PushService12.java | 431 ++++++++
src/main/java/com/fzzy/push/nx2023/NX2023Constant.java | 164 +++
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java | 68
src/main/resources/application-pro5306.yml | 61 +
src/main/java/com/fzzy/push/nx2023/NX2023HttpClientUtil.java | 89 +
src/main/java/com/fzzy/push/nx2023/NX2023OrderApiServiceImpl.java | 200 ++++
src/main/java/com/fzzy/push/nx2023/NX2023PushService13.java | 359 +++++++
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java | 62
src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1101.java | 97 +
18 files changed, 2,828 insertions(+), 80 deletions(-)
diff --git a/src/main/java/com/fzzy/api/data/PushProtocol.java b/src/main/java/com/fzzy/api/data/PushProtocol.java
index 5deaff2..09c9cbe 100644
--- a/src/main/java/com/fzzy/api/data/PushProtocol.java
+++ b/src/main/java/com/fzzy/api/data/PushProtocol.java
@@ -18,7 +18,8 @@
SB_WHJL_2023("SB_WHJL_2023", "姝︽眽鍐涚伯骞冲彴2023鐗�"),
HB_FZZY_JG_2022("HB_FZZY_JG_2022", "椋庢鑷磋繙鐩戠2022鐗堟湰"),
SB_SHJdJW_2023("SB_SHJdJW_2023", "涓婃捣鍢夊畾绾鐩戠骞冲彴2023鐗�"),
- SB_SH_2023("SB_SH_2023", "涓婃捣甯傚钩鍙�2023鐗�");
+ SB_SH_2023("SB_SH_2023", "涓婃捣甯傚钩鍙�2023鐗�"),
+ SB_NX_2023("SB_NX_2023", "瀹佸鐪佸钩鍙�2023鐗�");
private String code;
diff --git a/src/main/java/com/fzzy/api/service/ApiTriggerService.java b/src/main/java/com/fzzy/api/service/ApiTriggerService.java
index 5e0b5c3..40e5b11 100644
--- a/src/main/java/com/fzzy/api/service/ApiTriggerService.java
+++ b/src/main/java/com/fzzy/api/service/ApiTriggerService.java
@@ -190,6 +190,7 @@
list.add(new ApiTrigger(PushProtocol.HB_FZZY_JG_2022.getCode(), PushProtocol.HB_FZZY_JG_2022.getName()));
list.add(new ApiTrigger(PushProtocol.SB_SHJdJW_2023.getCode(), PushProtocol.SB_SHJdJW_2023.getName()));
list.add(new ApiTrigger(PushProtocol.SB_SH_2023.getCode(), PushProtocol.SB_SH_2023.getName()));
+ list.add(new ApiTrigger(PushProtocol.SB_NX_2023.getCode(), PushProtocol.SB_NX_2023.getName()));
return list;
}
diff --git a/src/main/java/com/fzzy/api/utils/NxRSAUtils.java b/src/main/java/com/fzzy/api/utils/NxRSAUtils.java
new file mode 100644
index 0000000..e1b2d34
--- /dev/null
+++ b/src/main/java/com/fzzy/api/utils/NxRSAUtils.java
@@ -0,0 +1,172 @@
+package com.fzzy.api.utils;
+
+import org.apache.commons.codec.binary.Base64;
+
+import javax.crypto.Cipher;
+import java.io.ByteArrayOutputStream;
+import java.security.*;
+import java.security.spec.PKCS8EncodedKeySpec;
+import java.security.spec.X509EncodedKeySpec;
+import java.util.HashMap;
+import java.util.Map;
+
+;
+
+/**
+ * date: 2022-08-31
+ * 瀹佸鐪佸钩鍙版帴鍙ｄ汉鍛樻彁渚�
+ */
+public class NxRSAUtils {
+
+ // 鏁板瓧绛惧悕锛屽瘑閽ョ畻娉�
+ private static final String RSA_KEY_ALGORITHM = "RSA";
+ // 鏁板瓧绛惧悕绛惧悕/楠岃瘉绠楁硶
+ private static final String SIGNATURE_ALGORITHM = "MD5withRSA";
+ //鍒嗘鍔犲瘑澶у皬
+ public static int MAX_ENCRYPT_BLOCK = 117;
+ //鍒嗘瑙ｅ瘑澶у皬
+ public static int MAX_DECRYPT_BLOCK = 128;
+ //瀵嗛挜澶у皬
+ public static int KEY_SIZE = 1024;
+
+ /**
+ * 鍒濆鍖朢SA瀵嗛挜瀵�
+ */
+ @SuppressWarnings("unused")
+ private static Map<String, String> initKey(String str) throws Exception {
+ KeyPairGenerator keygen = KeyPairGenerator.getInstance(RSA_KEY_ALGORITHM);
+ SecureRandom secrand = new SecureRandom();
+ secrand.setSeed(str.getBytes());// 鍒濆鍖栭殢鏈轰骇鐢熷櫒
+ keygen.initialize(KEY_SIZE, secrand); // 鍒濆鍖栧瘑閽ョ敓鎴愬櫒
+ KeyPair keys = keygen.genKeyPair();
+ String pub_key = new String(Base64.encodeBase64(keys.getPublic().getEncoded()),"utf-8");
+ String pri_key = new String(Base64.encodeBase64(keys.getPrivate().getEncoded()),"utf-8");
+ Map<String, String> keyMap = new HashMap<String, String>();
+ System.out.println("鍏挜锛�" + pub_key);
+ System.out.println("绉侀挜锛�" + pri_key);
+ return keyMap;
+ }
+
+ /**
+ * 鏁板瓧绛惧悕
+ */
+ public static String sign(String text, String pri_key) throws Exception {
+ System.out.println(text);
+ byte[] data = text.getBytes();
+ // 鍙栧緱绉侀挜
+ byte[] pri_key_bytes = Base64.decodeBase64(pri_key.getBytes());
+ PKCS8EncodedKeySpec pkcs8KeySpec = new PKCS8EncodedKeySpec(pri_key_bytes);
+ KeyFactory keyFactory = KeyFactory.getInstance(RSA_KEY_ALGORITHM);
+ // 鐢熸垚绉侀挜
+ PrivateKey priKey = keyFactory.generatePrivate(pkcs8KeySpec);
+ // 瀹炰緥鍖朣ignature
+ Signature signature = Signature.getInstance(SIGNATURE_ALGORITHM);
+ // 鍒濆鍖朣ignature
+ signature.initSign(priKey);
+ // 鏇存柊
+ signature.update(data);
+ return new String(Base64.encodeBase64(signature.sign()),"utf-8");
+ }
+
+
+
+ /**
+ * 鍏挜鍔犲瘑
+ * @param data 寰呭姞瀵嗘暟鎹�
+ * @param pub_key 鍏挜
+ * @return 瀵嗘枃
+ * @throws Exception 鎶涘嚭寮傚父
+ */
+ private static byte[] encryptByPubKey(byte[] data, byte[] pub_key) throws Exception {
+ // 鍙栧緱鍏挜
+ X509EncodedKeySpec x509KeySpec = new X509EncodedKeySpec(pub_key);
+ KeyFactory keyFactory = KeyFactory.getInstance(RSA_KEY_ALGORITHM);
+ PublicKey publicKey = keyFactory.generatePublic(x509KeySpec);
+ // 瀵规暟鎹姞瀵�
+ Cipher cipher = Cipher.getInstance(keyFactory.getAlgorithm());
+ cipher.init(Cipher.ENCRYPT_MODE, publicKey);
+// return cipher.doFinal(data);
+
+ int inputLen = data.length;
+ ByteArrayOutputStream out = new ByteArrayOutputStream();
+ int offSet = 0;
+ byte[] cache;
+ int i = 0;
+ // 瀵规暟鎹垎娈靛姞瀵�
+ while (inputLen - offSet > 0) {
+ if (inputLen - offSet > MAX_ENCRYPT_BLOCK) {
+ cache = cipher.doFinal(data, offSet, MAX_ENCRYPT_BLOCK);
+ } else {
+ cache = cipher.doFinal(data, offSet, inputLen - offSet);
+ }
+ out.write(cache, 0, cache.length);
+ i++;
+ offSet = i * MAX_ENCRYPT_BLOCK;
+ }
+ byte[] encryptedData = out.toByteArray();
+ out.close();
+ return encryptedData;
+ }
+ /**
+ * RSA鏍￠獙鏁板瓧绛惧悕
+ */
+ public static boolean verify(byte[] data, byte[] sign, String pub_key) throws Exception {
+ // 杞崲鍏挜鏉愭枡
+ // 瀹炰緥鍖栧瘑閽ュ伐鍘�
+ byte[] pub_key_bytes = Base64.decodeBase64(pub_key.getBytes());
+ KeyFactory keyFactory = KeyFactory.getInstance(RSA_KEY_ALGORITHM);
+ // 鍒濆鍖栧叕閽�
+ // 瀵嗛挜鏉愭枡杞崲
+ X509EncodedKeySpec x509KeySpec = new X509EncodedKeySpec(pub_key_bytes);
+ // 浜х敓鍏挜
+ PublicKey pubKey = keyFactory.generatePublic(x509KeySpec);
+ // 瀹炰緥鍖朣ignature
+ Signature signature = Signature.getInstance(SIGNATURE_ALGORITHM);
+ // 鍒濆鍖朣ignature
+ signature.initVerify(pubKey);
+ // 鏇存柊
+ signature.update(data);
+ // 楠岃瘉
+ return signature.verify(sign);
+ }
+ public static boolean InspecdataSign(String data,String accessToken,String pubkey){
+ String sign = data;
+ try {
+ if(NxRSAUtils.verify(sign.getBytes(), Base64.decodeBase64(accessToken.getBytes()), pubkey)){
+ return true;
+ }else{
+ return false;
+ }
+ } catch (Exception e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ return false;
+ }
+ }
+ /**
+ * 鍏挜鍔犲瘑
+ * @param data 寰呭姞瀵嗘暟鎹�
+ * @param pub_key 鍏挜
+ * @return 瀵嗘枃
+ * @throws Exception 鎶涘嚭寮傚父
+ */
+ public static String encryptByPubKey(String data, String pub_key) throws Exception {
+
+ byte[] pub_key_bytes = Base64.decodeBase64(pub_key.getBytes("utf-8"));
+ byte[] enSign = encryptByPubKey(data.getBytes("utf-8"), pub_key_bytes);
+ return new String(Base64.encodeBase64(enSign),"utf-8");
+ }
+
+
+
+ public static void main(String[] args) throws Exception{
+ initKey("12640200735992821E001鎺ュ彛2023");
+// String signStr = "12640200735992821E001_2023-11-09";
+// String pri_key = "MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBAJGxqYyI/k6nYkm2nf4ggkAMViEvbnplbQqw6Qweu4neFXCC+iKY8cq5RZEj8JLfrm/gHBTPN8FF1sQIwWwsDV7UUc88DS5KwAi5JXBHMdcbh2tftkINr0YVn6rIgUBTbmPZ7Y8L2iW8psYsF9nxwvUUtcbFJXIMJfi39Qxl0NQvAgMBAAECgYBKWLHfoCy9sFbMrN7UxnwQ+PqetpiW5tkNApf58ljbErQ4FO5V51xDieXBGejy2igmuOM7jz6xZtUgdiNV8uji/RtiNRqsBekVBPMeYAnPwA4GQ0HNwyHJ3ebJNQqT9bwrk8QpRUuCnrx/U1l7P1QNR5o52H1HpEKPlS0ga0fuQQJBAMdiSFYKt8/PwsYclvU/GqXrPy4cxMBhtE/ZssH9KourxnJcyfRz7EPgfSZykxlGHn8j/r8C2XxtAIYW6mRckqECQQC7EIZCZ3eV8abSIB33oKmw2jZlPQrHXMt8DWz8FYbNIA/9bvk9e9O42iQwMUtHfOMcNMWbcvKR/J+83bcE08TPAkA1ErdYl+/H1HDvVUrlq0+HnPArcSL6ZsedfcB0nNRHa4kehg6IEJdylf4aTuNTFfQmOcmkxLhpw4YhK1ZnMrEhAkEAuiMLNXA3MmCumk+TAiBAOdYoYjyHSTEw2VOSqpPQ+rN4tbmDEIbyefG2KK4kNhIy+pIYP0H11QYG/KuxvX/rSQJBALs0TqUgcGOp9+IkOq4jCXiVkP5/r7JWinQ4d6bYhJ4wspQYloYFCHljKKXtst1m8I3PC+vJY8R6va/3xtQKT8U=";
+// String pub_key = "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCRsamMiP5Op2JJtp3+IIJADFYhL256ZW0KsOkMHruJ3hVwgvoimPHKuUWRI/CS365v4BwUzzfBRdbECMFsLA1e1FHPPA0uSsAIuSVwRzHXG4drX7ZCDa9GFZ+qyIFAU25j2e2PC9olvKbGLBfZ8cL1FLXGxSVyDCX4t/UMZdDULwIDAQAB";
+// String access_token = NxRSAUtils.sign(signStr, pri_key);
+// System.out.println(access_token);
+// System.out.println(InspecdataSign(signStr,access_token,pub_key));
+ }
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService11.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService11.java
index 05afc75..ea76614 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService11.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService11.java
@@ -48,15 +48,15 @@
//鏂囦欢淇℃伅鍚屾锛岃浆绉诲埌12澶х被涓�,涓昏鏄嚭鍏ュ簱杩芥函鐓х墖
- //鐩戞帶鐐逛綅淇℃伅鍚屾
- fzzy40Sync1111.syncData(kqdm, deptId, start, end);
-
- //鑽墏淇℃伅鍚屾
- fzzy40Sync1108.syncData(kqdm, deptId, start, end);
- //璁惧淇℃伅鍚屾
- fzzy40Sync1107.syncData(kqdm, deptId, start, end);
- //浜哄憳淇℃伅鍚屾
- fzzy40Sync1112.syncData(kqdm, deptId, start, end);
+// //鐩戞帶鐐逛綅淇℃伅鍚屾
+// fzzy40Sync1111.syncData(kqdm, deptId, start, end);
+//
+// //鑽墏淇℃伅鍚屾
+// fzzy40Sync1108.syncData(kqdm, deptId, start, end);
+// //璁惧淇℃伅鍚屾
+// fzzy40Sync1107.syncData(kqdm, deptId, start, end);
+// //浜哄憳淇℃伅鍚屾
+// fzzy40Sync1112.syncData(kqdm, deptId, start, end);
//浼佷笟淇＄敤淇℃伅鍚屾--鏆備笉鎵ц
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
index 1921416..68f1def 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
@@ -61,37 +61,37 @@
Date end = param.getEnd();
// //瀹㈡埛鍚屾
- fzzySync1212.syncData(kqdm, deptId, start, end);
-
- //鍚堝悓鍚屾
- fzzySync1201.syncData(kqdm, deptId, start, end);
-
- //绮鍏ュ簱鍚屾
- fzzySync1202.syncData(kqdm, deptId, start, end);
-
- //绮鍏ュ簱璐ㄦ
- fzzySync1203.syncData(kqdm, deptId, start, end);
-
- //绮鍏ュ簱缁撶畻
- fzzySync1204.syncData(kqdm, deptId, start, end);
- //绮鍑哄簱鍚屾
- fzzySync1205.syncData(kqdm, deptId, start, end);
-
- //绮鍑哄簱缁撶畻
- fzzySync1206.syncData(kqdm, deptId, start, end);
- //绮鎹熺泭
- fzzySync1209.syncData(kqdm, deptId, start, end);
- //鍊掍粨淇℃伅鍚屾
- fzzySync1207.syncData(kqdm, deptId, start, end);
-
- //鍑哄叆搴撴枃浠朵俊鎭悓姝�
- fzzySync1109.syncData(kqdm, deptId, start, end);
-
- //绮搴撳瓨鍚屾
- fzzySync1208.syncData(kqdm, deptId, start, end);
-
- //绮鎬ц川杞彉淇℃伅鍚屾
- fzzySync1210.syncData(kqdm, deptId, start, end);
+// fzzySync1212.syncData(kqdm, deptId, start, end);
+//
+// //鍚堝悓鍚屾
+// fzzySync1201.syncData(kqdm, deptId, start, end);
+//
+// //绮鍏ュ簱鍚屾
+// fzzySync1202.syncData(kqdm, deptId, start, end);
+//
+// //绮鍏ュ簱璐ㄦ
+// fzzySync1203.syncData(kqdm, deptId, start, end);
+//
+// //绮鍏ュ簱缁撶畻
+// fzzySync1204.syncData(kqdm, deptId, start, end);
+// //绮鍑哄簱鍚屾
+// fzzySync1205.syncData(kqdm, deptId, start, end);
+//
+// //绮鍑哄簱缁撶畻
+// fzzySync1206.syncData(kqdm, deptId, start, end);
+// //绮鎹熺泭
+// fzzySync1209.syncData(kqdm, deptId, start, end);
+// //鍊掍粨淇℃伅鍚屾
+// fzzySync1207.syncData(kqdm, deptId, start, end);
+//
+// //鍑哄叆搴撴枃浠朵俊鎭悓姝�
+// fzzySync1109.syncData(kqdm, deptId, start, end);
+//
+// //绮搴撳瓨鍚屾
+// fzzySync1208.syncData(kqdm, deptId, start, end);
+//
+// //绮鎬ц川杞彉淇℃伅鍚屾
+// fzzySync1210.syncData(kqdm, deptId, start, end);
/*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/
// if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java
index 05cb5f6..f816098 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java
@@ -45,40 +45,40 @@
public void syncData(ApiParam param) {
- /*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/
- if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_GD_2022.getCode().equals(param.getPushProtocol())) {
- //骞夸笢鐪佸钩鍙�2022鐗堬紝闇�瑕佸悓姝ョ啅钂稿妗堜俊鎭�
- //鐔忚捀澶囨鏁版嵁鍚屾
- fzzySync1023.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
- }
- if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
- //涓婃捣甯傚钩鍙�2023鐗堬紝闇�瑕佸悓姝ョ伯鎯呰澶囬厤缃俊鎭�
-
- //鍚屾绮儏璁惧閰嶇疆淇℃伅
- fzzy40Sync2103.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
- //瑙嗛鐩戞帶淇℃伅鍚屾
- fzzySync1311.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
- }
-
- /*-----鍏叡鎺ュ彛-----*/
-
- //娓╂箍搴︽娴嬫暟鎹悓姝�
- fzzySync1302.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //铏妫�娴嬪悓姝�
- fzzySync1303.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //姘斾綋妫�娴嬪悓姝�
- fzzySync1304.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //璐ㄦ鍚屾
- fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //閫氶浣滀笟淇℃伅鍚屾
- fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //鐔忚捀浣滀笟淇℃伅鍚屾
- fzzySync1306.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+// /*-----鍚勭渷鐙湁鎺ュ彛淇℃伅鍚屾-----*/
+// if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_GD_2022.getCode().equals(param.getPushProtocol())) {
+// //骞夸笢鐪佸钩鍙�2022鐗堬紝闇�瑕佸悓姝ョ啅钂稿妗堜俊鎭�
+// //鐔忚捀澶囨鏁版嵁鍚屾
+// fzzySync1023.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+// }
+// if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
+// //涓婃捣甯傚钩鍙�2023鐗堬紝闇�瑕佸悓姝ョ伯鎯呰澶囬厤缃俊鎭�
+//
+// //鍚屾绮儏璁惧閰嶇疆淇℃伅
+// fzzy40Sync2103.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+// //瑙嗛鐩戞帶淇℃伅鍚屾
+// fzzySync1311.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+// }
+//
+// /*-----鍏叡鎺ュ彛-----*/
+//
+// //娓╂箍搴︽娴嬫暟鎹悓姝�
+// fzzySync1302.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //铏妫�娴嬪悓姝�
+// fzzySync1303.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //姘斾綋妫�娴嬪悓姝�
+// fzzySync1304.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //璐ㄦ鍚屾
+// fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //閫氶浣滀笟淇℃伅鍚屾
+// fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //鐔忚捀浣滀笟淇℃伅鍚屾
+// fzzySync1306.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService14.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService14.java
index d94af34..1ddd3a1 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService14.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService14.java
@@ -28,11 +28,11 @@
@Override
public void syncData(ApiParam param) {
- //杞崲璁″垝鍚屾
- fzzy40Sync1403.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
-
- //杞崲璁″垝鏄庣粏鍚屾
- fzzy40Sync1404.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+// //杞崲璁″垝鍚屾
+// fzzy40Sync1403.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
+//
+// //杞崲璁″垝鏄庣粏鍚屾
+// fzzy40Sync1404.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
}
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023ApiRemoteService.java b/src/main/java/com/fzzy/push/nx2023/NX2023ApiRemoteService.java
new file mode 100644
index 0000000..079fc42
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023ApiRemoteService.java
@@ -0,0 +1,487 @@
+package com.fzzy.push.nx2023;
+
+import com.alibaba.fastjson.JSON;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.*;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.*;
+import com.fzzy.api.view.repository.*;
+import com.fzzy.order.data.OrderData;
+import com.fzzy.push.nx2023.dto.Nx2023Api1101;
+import com.fzzy.push.nx2023.dto.Nx2023Api1102;
+import com.fzzy.push.sh2023.dto.*;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.time.DateFormatUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.lang.reflect.Field;
+import java.util.*;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-涓婁紶鏁版嵁鏈嶅姟绫�
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Data
+@Service
+public class NX2023ApiRemoteService implements ApiRemoteService {
+
+ @Autowired
+ private RedisUtil redisUtil;
+ @Autowired
+ private ApiCommonService apiCommonService;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+ @Autowired
+ private Api1101Rep api1101Rep;
+ @Autowired
+ private Api1102Rep api1102Rep;
+ @Autowired
+ private Api1104Rep api1104Rep;
+ @Autowired
+ private Api1208Rep api1208Rep;
+ @Autowired
+ private Api1109Rep api1109Rep;
+ @Autowired
+ private Api1202Rep api1202Rep;
+ @Autowired
+ private Api1205Rep api1205Rep;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+ @Override
+ public ResponseDto pushData(ApiParam param, Object data) {
+ return pushData(param, null, data);
+ }
+
+ @Override
+ public ResponseDto pushData(ApiParam param, ApiConfs conf, Object data) {
+ String inteId = param.getInteId();
+ String kqdm = param.getKqdm();
+ //鏌ヨ搴撳尯淇℃伅琛屾斂鍖哄垝鐮�
+ List<Api1102> api1102List = api1102Rep.findPushData(kqdm);
+ try {
+ if (null == conf) {
+ conf = apiCommonService.getConf(kqdm);
+ }
+
+ //娣诲姞鏃ュ織
+ ApiLog apiLog = new ApiLog();
+ apiLog.setId(ContextUtil.getUUID());
+
+ //鑻ヤ负璐㈠姟1501銆�1502銆�1503鎺ュ彛锛屽垯鎺ュ彛缂栫爜濉啓1114
+ if (NX2023Constant.NX_2023_API_CODE_1114_1501.equals(param.getInteId())
+ || NX2023Constant.NX_2023_API_CODE_1114_1502.equals(param.getInteId())
+ || NX2023Constant.NX_2023_API_CODE_1114_1503.equals(param.getInteId())) {
+ inteId = NX2023Constant.NX_2023_API_CODE_1114;
+ }
+ apiLog.setInteId(inteId);
+
+ if (StringUtils.isEmpty(inteId)) {
+ ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒版帴鍙�");
+ apiLog.setStatus(99);
+ apiLog.setResult("娌℃湁鑾峰彇鍒版帴鍙�");
+ apiLogRep.save(apiLog);
+ return responseDto;
+ }
+
+ String jsonData = getJsonData(param.getInteId(), data);
+ log.info("鎺ュ彛鏁版嵁淇℃伅=" + jsonData);
+ apiLog.setData(jsonData);
+ apiLog.setKqdm(kqdm);
+ apiLog.setUploadTime(new Date());
+
+ if (conf == null) {
+ ResponseDto responseDto = new ResponseDto(99, "娌℃湁鑾峰彇鍒颁笂浼犻厤缃�");
+ apiLog.setStatus(99);
+ apiLog.setResult("娌℃湁鑾峰彇鍒颁笂浼犻厤缃�");
+ apiLogRep.save(apiLog);
+ return responseDto;
+ }
+
+ //灏佽鎺ㄩ�佹暟鎹�
+ SH2023ReqDto reqData = new SH2023ReqDto();
+ reqData.setId(ContextUtil.getUUID());
+ //鑾峰彇韬唤ID锛屽嵆绮簱鐨勭粍缁囦唬鐮�
+ reqData.setUid(conf.getUserName());
+ //鎸囦护id
+ String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm());
+ String orderId = reqData.getId();
+ OrderData orderData = (OrderData) redisUtil.get(key);
+ if (null != orderData && StringUtils.isNotEmpty(orderData.getOrderid())) {
+ orderId = orderData.getOrderid();
+ }
+ reqData.setOrderid(orderId);
+
+ //韬唤绛惧悕锛屼娇鐢ㄨ嚜鏈塕SA绉侀挜杩涜鍔犲瘑(搴撳尯缂栫爜_褰撳ぉ鏃ユ湡)
+ reqData.setAccess_token(NxRSAUtils.sign(reqData.getUid() + "_" + DateFormatUtils.format(new Date(), "yyyy-MM-dd"), conf.getPassword()));
+ reqData.setDatalength(1);
+
+ //浣跨敤鐪佸钩鍙扮殑RSA鍏挜瀵规暟鎹繘琛孯SA鍔犲瘑
+ reqData.setData(NxRSAUtils.encryptByPubKey(jsonData, conf.getPublicKey()));
+ //鎽樿锛屾暟鎹富浣撶殑MD5鍊�
+ reqData.setDigst(MyMD5Util.encrypt(jsonData));
+ log.info("涓婃姤鏁版嵁淇℃伅=" + JSON.toJSONString(reqData));
+ SH2023RespDto responseDto = NX2023HttpClientUtil.postPushData(conf.getApiUrl() + inteId, JSON.toJSONString(reqData), conf);
+
+ apiLog.setStatus(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
+ apiLog.setResult(responseDto.getResult());
+ apiLogRep.save(apiLog);
+ ResponseDto resd = new ResponseDto();
+ resd.setSuccess(responseDto.getCode() == 200 ? 0 : responseDto.getCode());
+ resd.setMsg(responseDto.getResult());
+
+ return resd;
+ } catch (Exception e) {
+ log.error(e.getMessage(), e);
+ return new ResponseDto(99, e.getMessage());
+ }
+ }
+
+ /**
+ * 杞负JSON
+ *
+ * @param inteId
+ * @param data
+ * @return
+ */
+ private String getJsonData(String inteId, Object data) {
+ //鑻ヤ负璐㈠姟1501銆�1502銆�1503鎺ュ彛锛屽垯鎺ュ彛缂栫爜濉啓1114
+ if (NX2023Constant.NX_2023_API_CODE_1114_1501.equals(inteId)
+ || NX2023Constant.NX_2023_API_CODE_1114_1502.equals(inteId)
+ || NX2023Constant.NX_2023_API_CODE_1114_1503.equals(inteId)) {
+ Object object = getJsonFinanceData(inteId, data);
+ return JSON.toJSONString(object);
+ } else {
+ List<Object> list = new ArrayList<>();
+ Object object = getJsonApiData(inteId, data);
+ list.add(object);
+ return JSON.toJSONString(list);
+ }
+
+ }
+
+ /**
+ * 甯歌鎺ュ彛灏佽
+ *
+ * @param inteId
+ * @param data
+ * @return
+ */
+ private Object getJsonApiData(String inteId, Object data) {
+ if (NX2023Constant.NX_2023_API_CODE_1101.equals(inteId)) {
+
+ Nx2023Api1101 api1101 = new Nx2023Api1101();
+ BeanUtils.copyProperties(data, api1101);
+ return api1101;
+ }
+ if (NX2023Constant.NX_2023_API_CODE_1102.equals(inteId)) {
+ Nx2023Api1102 api1102 = new Nx2023Api1102();
+ BeanUtils.copyProperties(data, api1102);
+ api1102.setLkxz("1");
+ return api1102;
+ }
+ if (NX2023Constant.NX_2023_API_CODE_1109.equals(inteId)) {
+
+ Api1109 apiData = (Api1109) data;
+ apiData.setWjl(FileUtils.fileToByteString(apiData.getWjdz()));
+ return apiData;
+ }
+ return data;
+ }
+
+ private String getWjmc(String wjlx, String wjmc){
+ if("2".equals(wjlx) || "3".equals(wjlx) || "4".equals(wjlx) || "5".equals(wjlx)){
+ if(wjmc.endsWith(".jpg")) {
+ wjmc = wjmc.replaceAll(".jpg", "_00.jpg");
+ }
+ if(wjmc.endsWith(".png")) {
+ wjmc = wjmc.replaceAll(".png", "_00.png");
+ }
+ }
+ return wjmc;
+ }
+
+ /**
+ * 鑾峰彇璐㈠姟鏁版嵁json
+ *
+ * @param inteId
+ * @param data
+ * @return
+ */
+ private Object getJsonFinanceData(String inteId, Object data) {
+ //璐㈠姟鎶ヨ〃鏁版嵁灏佽
+ if (NX2023Constant.NX_2023_API_CODE_1114_1501.equals(inteId)) {
+ return copyApi1501((Api1501) data);
+ } else if (NX2023Constant.NX_2023_API_CODE_1114_1502.equals(inteId)) {
+ return copyApi1502((Api1502) data);
+ } else {
+ return copyApi1503((Api1503) data);
+ }
+ }
+
+ /**
+ * Object绫诲瀷杞彉涓篖ist
+ *
+ * @param obj
+ * @param clazz
+ * @param <T>
+ * @return
+ */
+ public static <T> List<T> castList(Object obj, Class<T> clazz) {
+ List<T> result = new ArrayList<T>();
+ if (obj instanceof List<?>) {
+ for (Object o : (List<?>) obj) {
+ result.add(clazz.cast(o));
+ }
+ return result;
+ }
+ return null;
+ }
+
+
+ private List<SHFinanceDto> copyApi1503(Api1503 data) {
+ Api1503 api1503 = data;
+ List<SHFinanceDto> list = new ArrayList<>();
+ SHFinanceDto shFinanceDto = new SHFinanceDto();
+ shFinanceDto.setDwdm(api1503.getDwdm());
+ shFinanceDto.setBbsj(DateFormatUtils.format(api1503.getBbsj(), "yyyyMMdd"));
+ shFinanceDto.setBbm("03");
+ shFinanceDto.setCzbz(api1503.getCzbz());
+ shFinanceDto.setZhgxsj(DateFormatUtils.format(api1503.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
+
+ paddingData(shFinanceDto, list, "椤圭洰//t", "鏈湡閲戦//t", "鏈勾绱//t");
+ paddingData(shFinanceDto, list, "涓�銆佽惀涓氭敹鍏�", api1503.getYyzsrbqye() + "", api1503.getYyzsrbnlj() + "");
+ paddingData(shFinanceDto, list, "鍑忥細钀ヤ笟鎴愭湰", api1503.getYycbbqye() + "", api1503.getYycbbnlj() + "");
+ paddingData(shFinanceDto, list, "绋庨噾鍙婇檮鍔�", api1503.getSjjfjbqye() + "", api1503.getSjjfjbnlj() + "");
+ paddingData(shFinanceDto, list, "閿�鍞垂鐢�", api1503.getXsfybqye() + "", api1503.getXsfybnlj() + "");
+ paddingData(shFinanceDto, list, "绠＄悊璐圭敤", api1503.getGlfybqye() + "", api1503.getGlfybnlj() + "");
+ paddingData(shFinanceDto, list, "鐮斿彂璐圭敤", api1503.getYffybqye() + "", api1503.getYffybnlj() + "");
+ paddingData(shFinanceDto, list, "璐㈠姟璐圭敤", api1503.getCwfybqye() + "", api1503.getCwfybnlj() + "");
+ paddingData(shFinanceDto, list, "鍏朵腑锛氬埄鎭垂鐢�", api1503.getLxfybqye() + "", api1503.getLxfybnlj() + "");
+ paddingData(shFinanceDto, list, "鍒╂伅鏀跺叆", api1503.getLxsrbqye() + "", api1503.getLxsrbnlj() + "");
+ paddingData(shFinanceDto, list, "鍔狅細鍏朵粬鏀剁泭", api1503.getQtsybqye() + "", api1503.getQtsybnlj() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫鏀剁泭锛堟崯澶变互鈥�-鈥濆彿濉垪锛�", api1503.getTzsybqye() + "", api1503.getTzsybnlj() + "");
+ paddingData(shFinanceDto, list, "鍏朵腑锛氬鑱旇惀浼佷笟鍜屽悎钀ヤ紒涓氱殑鎶曡祫鏀剁泭", api1503.getLyqytzsybqye() + "", api1503.getLyqytzsybnlj() + "");
+ paddingData(shFinanceDto, list, "鍏厑浠峰�煎彉鍔ㄦ敹鐩婏紙鎹熷け浠モ��-鈥濆彿濉垪锛�", api1503.getGyjzbdsybqye() + "", api1503.getGyjzbdsybnlj() + "");
+ paddingData(shFinanceDto, list, "璧勪骇鍑忓�兼崯澶憋紙鎹熷け浠モ��-鈥濆彿濉垪锛�", api1503.getZcjzssbqye() + "", api1503.getZcjzssbnlj() + "");
+ paddingData(shFinanceDto, list, "璧勪骇澶勭疆鏀剁泭锛堟崯澶变互鈥�-鈥濆彿濉垪锛�", api1503.getZcczsybqye() + "", api1503.getZcczsybnlj() + "");
+ paddingData(shFinanceDto, list, "浜屻�佽惀涓氬埄娑︼紙浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getYylrbqye() + "", api1503.getYylrbnlj() + "");
+ paddingData(shFinanceDto, list, "鍔狅細钀ヤ笟澶栨敹鍏�", api1503.getYywsrbqye() + "", api1503.getYywsrbnlj() + "");
+ paddingData(shFinanceDto, list, "鍑忥細钀ヤ笟澶栨敮鍑�", api1503.getYywzcbqye() + "", api1503.getYywzcbnlj() + "");
+ paddingData(shFinanceDto, list, "涓夈�佸埄娑︽�婚锛堜簭鎹熸�婚浠モ��-鈥濆彿濉垪锛�", api1503.getLrzebqye() + "", api1503.getLrzebnlj() + "");
+ paddingData(shFinanceDto, list, "鍑忥細鎵�寰楃◣璐圭敤", api1503.getSdsfybqye() + "", api1503.getSdsfybnlj() + "");
+ paddingData(shFinanceDto, list, "鍥涖�佸噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getJlrbqye() + "", api1503.getJlrbnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜竴锛夋寔缁粡钀ュ噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getCxjyjlrbqye() + "", api1503.getCxjyjlrbnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜簩锛夌粓姝㈢粡钀ュ噣鍒╂鼎锛堝噣浜忔崯浠モ��-鈥濆彿濉垪锛�", api1503.getZzjyjlrbqye() + "", api1503.getZzjyjlrbnlj() + "");
+ paddingData(shFinanceDto, list, "浜斻�佸叾浠栫患鍚堟敹鐩婄殑绋庡悗鍑�棰�", api1503.getQtzhsyjebqye() + "", api1503.getQtzhsyjebnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜竴锛変笉鑳介噸鍒嗙被杩涙崯鐩婄殑鍏朵粬缁煎悎鏀剁泭", api1503.getBnflzhsybqye() + "", api1503.getBnflzhsybnlj() + "");
+ paddingData(shFinanceDto, list, "1锛庨噸鏂拌閲忚瀹氬彈鐩婅鍒掑彉鍔ㄩ", api1503.getCxjlbdebqye() + "", api1503.getCxjlbdebnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜簩锛夊皢閲嶅垎绫昏繘鎹熺泭鐨勫叾浠栫患鍚堟敹鐩�", "0", "0");
+ paddingData(shFinanceDto, list, "1锛庢潈鐩婃硶涓嬪彲杞崯鐩婄殑鍏朵粬缁煎悎鏀剁泭", api1503.getQyfkzsybqye() + "", api1503.getQyfkzsybnlj() + "");
+ paddingData(shFinanceDto, list, "2锛庡彲渚涘嚭鍞噾铻嶈祫浜у叕鍏佷环鍊煎彉鍔ㄦ崯鐩�", api1503.getKgcszcbdsybqye() + "", api1503.getKgcszcbdsybnlj() + "");
+ paddingData(shFinanceDto, list, "3锛庢寔鏈夎嚦鍒版湡鎶曡祫閲嶅垎绫讳负鍙緵鍑哄敭閲戣瀺璧勪骇鎹熺泭", api1503.getCydqtzzcsybqye() + "", api1503.getKgcszcbdsybnlj() + "");
+ paddingData(shFinanceDto, list, "4锛庣幇閲戞祦閲忓鏈熸崯鐩婄殑鏈夋晥閮ㄥ垎", api1503.getZjllsybqye() + "", api1503.getZjllsybnlj() + "");
+ paddingData(shFinanceDto, list, "5锛庡甯佽储鍔℃姤琛ㄦ姌绠楀樊棰�", api1503.getWbcwbbcebqye() + "", api1503.getWbcwbbcebnlj() + "");
+ paddingData(shFinanceDto, list, "鍏�佺患鍚堟敹鐩婃�婚", api1503.getZhsyzebqye() + "", api1503.getZhsyzebnlj() + "");
+ paddingData(shFinanceDto, list, "涓冦�佹瘡鑲℃敹鐩婏細", api1503.getMgsybqye() + "", api1503.getMgsybnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜竴锛夊熀鏈瘡鑲℃敹鐩�", api1503.getJbmgsybqye() + "", api1503.getJbmgsybnlj() + "");
+ paddingData(shFinanceDto, list, "锛堜簩锛夌█閲婃瘡鑲℃敹鐩�", api1503.getXsmgsybqye() + "", api1503.getXsmgsybnlj() + "");
+
+ return list;
+ }
+
+ private List<SHFinanceDto> copyApi1502(Api1502 data) {
+ Api1502 api1502 = data;
+ List<SHFinanceDto> list = new ArrayList<>();
+ SHFinanceDto shFinanceDto = new SHFinanceDto();
+ shFinanceDto.setDwdm(api1502.getDwdm());
+ shFinanceDto.setBbsj(DateFormatUtils.format(api1502.getBbsj(), "yyyyMMdd"));
+ shFinanceDto.setBbm("02");
+ shFinanceDto.setCzbz(api1502.getCzbz());
+ shFinanceDto.setZhgxsj(DateFormatUtils.format(api1502.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
+
+ paddingData(shFinanceDto, list, "椤圭洰//t", "鏈湀鏁�//t", "鏈勾绱鏁�//t");
+ paddingData(shFinanceDto, list, "涓�銆佺粡钀ユ椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getJyhdxjllbys() + "", api1502.getJyhdxjllbnljs() + "");
+ paddingData(shFinanceDto, list, "閿�鍞晢鍝併�佹彁渚涘姵鍔℃敹鍒扮殑鐜伴噾", api1502.getXssplwxjbys() + "", api1502.getXssplwxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀跺埌鐨勭◣璐硅繑杩�", api1502.getSffhbys() + "", api1502.getSffhbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀跺埌鍏朵粬涓庣粡钀ユ椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getQtjyhdxjbys() + "", api1502.getQtjyhdxjbnljs() + "");
+ paddingData(shFinanceDto, list, "缁忚惀娲诲姩鐜伴噾娴佸叆灏忚", api1502.getJyhdxjlrbys() + "", api1502.getJyhdxjlrbnljs() + "");
+ paddingData(shFinanceDto, list, "璐拱鍟嗗搧銆佹帴鍙楀姵鍔℃敮浠樼殑鐜伴噾", api1502.getGmsplwzfbys() + "", api1502.getGmsplwzfbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀粯缁欒亴宸ヤ互鍙婁负鑱屽伐鏀粯鐨勭幇閲�", api1502.getZfzgxjbys() + "", api1502.getZfzgxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀粯鐨勫悇椤圭◣璐�", api1502.getZfxxsfbys() + "", api1502.getZfxxsfbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀粯鍏朵粬涓庣粡钀ユ椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqtjyhdxjbys() + "", api1502.getZfqtjyhdxjbnljs() + "");
+ paddingData(shFinanceDto, list, "缁忚惀娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getJyhdxjlcbys() + "", api1502.getJyhdxjlcbnljs() + "");
+ paddingData(shFinanceDto, list, "缁忚惀娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getJyhdxjlljebys() + "", api1502.getJyhdxjlljebnljs() + "");
+ paddingData(shFinanceDto, list, "浜屻�佹姇璧勬椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getTzhdxjllbys() + "", api1502.getTzhdxjllbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀跺洖鎶曡祫鏀跺埌鐨勭幇閲�", api1502.getShtzxjbys() + "", api1502.getShtzxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鍙栧緱鎶曡祫鏀剁泭鏀跺埌鐨勭幇閲�", api1502.getQdtzsyxjbys() + "", api1502.getQdtzsyxjbnljs() + "");
+ paddingData(shFinanceDto, list, "澶勭疆鍥哄畾璧勪骇銆佹棤褰㈣祫浜у拰鍏朵粬闀挎湡璧勪骇鏀跺洖鐨勭幇閲戝噣棰�", api1502.getCzgdzcdxjjebys() + "", api1502.getCzgdzcdxjjebnljs() + "");
+ paddingData(shFinanceDto, list, "澶勭疆瀛愬叕鍙稿強鍏朵粬钀ヤ笟鍗曚綅鏀跺埌鐨勭幇閲戝噣棰�", api1502.getCzqtdwxjjebys() + "", api1502.getCzqtdwxjjebnljs() + "");
+ paddingData(shFinanceDto, list, "鏀跺埌鍏朵粬涓庢姇璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getSdqttzxjbys() + "", api1502.getSdqttzxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫娲诲姩鐜伴噾娴佸叆灏忚", api1502.getTzhdxjlrbys() + "", api1502.getTzhdxjlrbnljs() + "");
+ paddingData(shFinanceDto, list, "璐缓鍥哄畾璧勪骇銆佹棤褰㈣祫浜у拰鍏朵粬闀挎湡璧勪骇鏀粯鐨勭幇閲�", api1502.getGjgdzcdxjbys() + "", api1502.getGjgdzcdxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫鏀粯鐨勭幇閲�", api1502.getTzzfxjbys() + "", api1502.getTzzfxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鍙栧緱瀛愬叕鍙稿強鍏朵粬钀ヤ笟鍗曚綅鏀粯鐨勭幇閲戝噣棰�", api1502.getQdzgsdzfxjjebys() + "", api1502.getQdzgsdzfxjjebnljs() + "");
+ paddingData(shFinanceDto, list, "鏀粯鍏朵粬涓庢姇璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqttzxjbys() + "", api1502.getZfqttzxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getTzhdxjlcbys() + "", api1502.getTzhdxjlcbnljs() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getTzhdcsxjlljebys() + "", api1502.getTzhdcsxjlljebnljs() + "");
+ paddingData(shFinanceDto, list, "涓夈�佺璧勬椿鍔ㄤ骇鐢熺殑鐜伴噾娴侀噺锛�", api1502.getCchdxjllbys() + "", api1502.getCchdxjllbnljs() + "");
+ paddingData(shFinanceDto, list, "鍚告敹鎶曡祫鏀跺埌鐨勭幇閲�", api1502.getXstzxjbys() + "", api1502.getXstzxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鍙栧緱鍊熸鏀跺埌鐨勭幇閲�", api1502.getQdjkxjbys() + "", api1502.getQdjkxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀跺埌鍏朵粬涓庣璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getSdqtczxjbys() + "", api1502.getSdqttzxjbnljs() + "");
+ paddingData(shFinanceDto, list, "绛硅祫娲诲姩鐜伴噾娴佸叆灏忚", api1502.getCzhdxjlrbys() + "", api1502.getCzhdxjlrbnljs() + "");
+ paddingData(shFinanceDto, list, "鍋胯繕鍊哄姟鏀粯鐨勭幇閲�", api1502.getChzwzfxjbys() + "", api1502.getChzwzfxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鍒嗛厤鑲″埄銆佸埄娑︽垨鍋夸粯鍒╂伅鏀粯鐨勭幇閲�", api1502.getFpgldxjbys() + "", api1502.getFpgldxjbnljs() + "");
+ paddingData(shFinanceDto, list, "鏀粯鍏朵粬涓庣璧勬椿鍔ㄦ湁鍏崇殑鐜伴噾", api1502.getZfqtdxjbys() + "", api1502.getZfqtdxjbnljs() + "");
+ paddingData(shFinanceDto, list, "绛硅祫娲诲姩鐜伴噾娴佸嚭灏忚", api1502.getCzhdxjlcbys() + "", api1502.getCzhdxjlcbnljs() + "");
+ paddingData(shFinanceDto, list, "绛硅祫娲诲姩浜х敓鐨勭幇閲戞祦閲忓噣棰�", api1502.getCchdxjlljebys() + "", api1502.getCchdxjlljebnljs() + "");
+ paddingData(shFinanceDto, list, "鍥涖�佹眹鐜囧彉鍔ㄥ鐜伴噾鍙婄幇閲戠瓑浠风墿鐨勫奖鍝�", api1502.getHlbdxjyxbys() + "", api1502.getHlbdxjyxbnljs() + "");
+ paddingData(shFinanceDto, list, "浜斻�佺幇閲戝強鐜伴噾绛変环鐗╁噣澧炲姞棰�", api1502.getXjdjwjzebys() + "", api1502.getXjdjwjzebnljs() + "");
+ paddingData(shFinanceDto, list, "鍔狅細鏈熷垵鐜伴噾鍙婄幇閲戠瓑浠风墿浣欓", api1502.getQcxjdjwyebys() + "", api1502.getQcxjdjwyebnljs() + "");
+ paddingData(shFinanceDto, list, "鍏�佹湡鏈幇閲戝強鐜伴噾绛変环鐗╀綑棰�", api1502.getQmxjdjwyebys() + "", api1502.getQmxjdjwyebnljs() + "");
+
+ return list;
+ }
+
+ private List<SHFinanceDto> copyApi1501(Api1501 data) {
+ Api1501 api1501 = data;
+ List<SHFinanceDto> list = new ArrayList<>();
+ SHFinanceDto shFinanceDto = new SHFinanceDto();
+ shFinanceDto.setDwdm(api1501.getDwdm());
+ shFinanceDto.setBbsj(DateFormatUtils.format(api1501.getBbsj(), "yyyyMMdd"));
+ shFinanceDto.setBbm("01");
+ shFinanceDto.setCzbz(api1501.getCzbz());
+ shFinanceDto.setZhgxsj(DateFormatUtils.format(api1501.getZhgxsj(), "yyyy-MM-dd HH:mm:ss"));
+
+ paddingData(shFinanceDto, list, "璧勪骇//t", "鏈熸湯浣欓//t", "骞村垵浣欓//t");
+ paddingData(shFinanceDto, list, "娴佸姩璧勪骇锛�", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + "");
+ paddingData(shFinanceDto, list, "璐у竵璧勯噾", api1501.getHbjjqmye() + "", api1501.getHbjjncye() + "");
+ paddingData(shFinanceDto, list, "浜ゆ槗鎬ч噾铻嶈祫浜�", api1501.getJyxjrzcqmye() + "", api1501.getJyxjrzcncye() + "");
+ paddingData(shFinanceDto, list, "琛嶇敓閲戣瀺璧勪骇", api1501.getYsjrzcqmye() + "", api1501.getYsjrzcncye() + "");
+ paddingData(shFinanceDto, list, "搴旀敹绁ㄦ嵁", api1501.getYspjqmye() + "", api1501.getYspjncye() + "");
+ paddingData(shFinanceDto, list, "搴旀敹璐︽", api1501.getYszkqmye() + "", api1501.getYszkncye() + "");
+ paddingData(shFinanceDto, list, "棰勪粯娆鹃」", api1501.getYuskxqmye() + "", api1501.getYuskxncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬搴旀敹娆�", api1501.getQtyszkqmye() + "", api1501.getQtyszkncye() + "");
+ paddingData(shFinanceDto, list, "瀛樿揣", api1501.getChqmye() + "", api1501.getChncye() + "");
+ paddingData(shFinanceDto, list, "鍚堝悓璧勪骇", api1501.getHtzcqmye() + "", api1501.getHtzcncye() + "");
+ paddingData(shFinanceDto, list, "鎸佹湁寰呭敭璧勪骇", api1501.getCydszcqmye() + "", api1501.getCydszcncye() + "");
+ paddingData(shFinanceDto, list, "涓�骞村唴鍒版湡鐨勯潪娴佸姩璧勪骇", api1501.getYnndqfldzcqmye() + "", api1501.getYnndqfldzcncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬娴佸姩璧勪骇", api1501.getQtldzcqmye() + "", api1501.getQtldzcncye() + "");
+ paddingData(shFinanceDto, list, "娴佸姩璧勪骇鍚堣", api1501.getLdzchjqmye() + "", api1501.getLdzchjncye() + "");
+ paddingData(shFinanceDto, list, "闈炴祦鍔ㄨ祫浜э細", api1501.getFldzcqmye() + "", api1501.getFldzcncye() + "");
+ paddingData(shFinanceDto, list, "鍊哄埜鎶曡祫", api1501.getZjtzqmye() + "", api1501.getZjtzncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬鍊哄埜鎶曡祫", api1501.getQtzqtzqmye() + "", api1501.getQtzqtzncye() + "");
+ paddingData(shFinanceDto, list, "闀挎湡搴旀敹娆�", api1501.getCqyskqmye() + "", api1501.getCqyskncye() + "");
+ paddingData(shFinanceDto, list, "闀挎湡鑲℃潈鎶曡祫", api1501.getCqgqtzqmye() + "", api1501.getCqgqtzncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬鏉冪泭宸ュ叿鎶曡祫", api1501.getQtqygjtzqmye() + "", api1501.getQtqygjtzncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬闈炴祦鍔ㄩ噾铻嶈祫浜�", api1501.getQtfldjrzcqmye() + "", api1501.getQtfldjrzcncye() + "");
+ paddingData(shFinanceDto, list, "鎶曡祫鎬ф埧鍦颁骇", api1501.getTzxfdcqmye() + "", api1501.getTzxfdcncye() + "");
+ paddingData(shFinanceDto, list, "鍥哄畾璧勪骇", api1501.getGdzcqmye() + "", api1501.getGdzcncye() + "");
+ paddingData(shFinanceDto, list, "鍦ㄥ缓宸ョ▼", api1501.getZjgcqmye() + "", api1501.getZjgcncye() + "");
+ paddingData(shFinanceDto, list, "鐢熶骇鎬х敓鐗╄祫浜�", api1501.getScxswzcqmye() + "", api1501.getScxswzcncye() + "");
+ paddingData(shFinanceDto, list, "娌规皵璧勪骇", api1501.getYqzcqmye() + "", api1501.getYqzcncye() + "");
+ paddingData(shFinanceDto, list, "鏃犲舰璧勪骇", api1501.getWxzcqmye() + "", api1501.getWxzcncye() + "");
+ paddingData(shFinanceDto, list, "寮�鍙戞敮鍑�", api1501.getKfzcqmye() + "", api1501.getKfzcncye() + "");
+ paddingData(shFinanceDto, list, "鍟嗚獕", api1501.getSyqmye() + "", api1501.getSyncye() + "");
+ paddingData(shFinanceDto, list, "闀挎湡寰呮憡璐圭敤", api1501.getCqdtfyqmye() + "", api1501.getCqdtfyncye() + "");
+ paddingData(shFinanceDto, list, "閫掑欢鎵�寰楃◣璧勪骇", api1501.getDysdszcqmye() + "", api1501.getDysdszcncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬闈炴祦鍔ㄨ祫浜�", api1501.getQtfldzcqmye() + "", api1501.getQtfldzcncye() + "");
+ paddingData(shFinanceDto, list, "闈炴祦鍔ㄨ祫浜у悎璁�", api1501.getFldzcqmye() + "", api1501.getFldzcncye() + "");
+ paddingData(shFinanceDto, list, "璧勪骇鎬昏", api1501.getZczjqmye() + "", api1501.getZczjncye() + "");
+ paddingData(shFinanceDto, list, "璐熷�哄拰鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級//t", "鏈熸湯浣欓//t", "骞村垵浣欓//t");
+ paddingData(shFinanceDto, list, "娴佸姩璐熷�猴細", api1501.getLdfzhjqmye() + "", api1501.getLdfzhjncye() + "");
+ paddingData(shFinanceDto, list, "鐭湡鍊熸", api1501.getDqjkqmye() + "", api1501.getLdzchjncye() + "");
+ paddingData(shFinanceDto, list, "浜ゆ槗鎬ч噾铻嶈礋鍊�", api1501.getJyxjrfzqmye() + "", api1501.getJyxjrfzncye() + "");
+ paddingData(shFinanceDto, list, "琛嶇敓閲戣瀺璐熷��", api1501.getYsjrfzqmye() + "", api1501.getYsjrfzncye() + "");
+ paddingData(shFinanceDto, list, "搴斾粯绁ㄦ嵁", api1501.getLdfzyspjqmye() + "", api1501.getLdfzyspjncye() + "");
+ paddingData(shFinanceDto, list, "搴斾粯璐︽", api1501.getLdfzyszkqmye() + "", api1501.getLdfzyszkncye() + "");
+ paddingData(shFinanceDto, list, "棰勬敹娆鹃」", api1501.getLdfzyuskxqmye() + "", api1501.getLdfzyszkncye() + "");
+ paddingData(shFinanceDto, list, "鍚堝悓璐熷��", api1501.getHtfzqmye() + "", api1501.getHtfzncye() + "");
+ paddingData(shFinanceDto, list, "搴斾粯鑱屽伐钖叕", api1501.getYfzgxcqmye() + "", api1501.getYfzgxcncye() + "");
+ paddingData(shFinanceDto, list, "搴斾氦绋庤垂", api1501.getYjsfqmye() + "", api1501.getYjsfncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬搴斾粯娆�", api1501.getQtyfkqmye() + "", api1501.getQtyfkncye() + "");
+ paddingData(shFinanceDto, list, "鎸佹湁寰呭敭璐熷��", api1501.getCydsfzqmye() + "", api1501.getCydsfzncye() + "");
+ paddingData(shFinanceDto, list, "涓�骞村唴鍒版湡鐨勯潪娴佸姩璐熷��", api1501.getYnddqfldfzqmye() + "", api1501.getYnddqfldfzncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬娴佸姩璐熷��", api1501.getQtldfzqmye() + "", api1501.getQtldfzncye() + "");
+ paddingData(shFinanceDto, list, "娴佸姩璐熷�哄悎璁�", api1501.getLdfzhjqmye() + "", api1501.getLdfzhjncye() + "");
+ paddingData(shFinanceDto, list, "闈炴祦鍔ㄨ礋鍊猴細", api1501.getFldfzhjqmye() + "", api1501.getFldfzhjncye() + "");
+ paddingData(shFinanceDto, list, "闀挎湡鍊熸", api1501.getCqjkqmye() + "", api1501.getCqjkncye() + "");
+ paddingData(shFinanceDto, list, "搴斾粯鍊哄埜", api1501.getYfzqqmye() + "", api1501.getYfzqncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵腑锛氫紭鍏堣偂", api1501.getYfzqyxgqmye() + "", api1501.getYfzqyxgncye() + "");
+ paddingData(shFinanceDto, list, "姘哥画鍊�", api1501.getYfzqyxzqmye() + "", api1501.getYfzqyxzncye() + "");
+ paddingData(shFinanceDto, list, "闀挎湡搴斾粯娆�", api1501.getCqyfkqmye() + "", api1501.getCqyfkncye() + "");
+ paddingData(shFinanceDto, list, "棰勮璐熷��", api1501.getYjsfqmye() + "", api1501.getYjsfncye() + "");
+ paddingData(shFinanceDto, list, "閫掑欢鏀剁泭", api1501.getDysyqmye() + "", api1501.getDysyncye() + "");
+ paddingData(shFinanceDto, list, "閫掑欢鎵�寰楃◣璐熷��", api1501.getDysdsfzqmye() + "", api1501.getDysdsfzncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬闈炴祦鍔ㄨ礋鍊�", api1501.getQtfldfzqmye() + "", api1501.getQtfldfzncye() + "");
+ paddingData(shFinanceDto, list, "闈炴祦鍔ㄨ礋鍊哄悎璁�", api1501.getFldfzhjqmye() + "", api1501.getFldfzhjncye() + "");
+ paddingData(shFinanceDto, list, "璐熷�哄悎璁�", api1501.getFzhjqmye() + "", api1501.getFzhjncye() + "");
+ paddingData(shFinanceDto, list, "鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級锛�", api1501.getSyzqyqmye() + "", api1501.getSyzqyncye() + "");
+ paddingData(shFinanceDto, list, "瀹炴敹璧勬湰锛堟垨鑲℃湰锛�", api1501.getSszbqmye() + "", api1501.getSszbncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬鏉冪泭宸ュ叿", api1501.getQtqygjqmye() + "", api1501.getQtqygjncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵腑锛氫紭鍏堣偂", api1501.getQtqygjyxgqmye() + "", api1501.getQtqygjyxgncye() + "");
+ paddingData(shFinanceDto, list, "姘哥画鍊�", api1501.getQtqygjyxzqmye() + "", api1501.getQtqygjyxzncye() + "");
+ paddingData(shFinanceDto, list, "璧勬湰鍏Н", api1501.getZbgjqmye() + "", api1501.getZbgjncye() + "");
+ paddingData(shFinanceDto, list, "鍑忥細搴撳瓨鑲�", api1501.getJkcgqmye() + "", api1501.getJkcgncye() + "");
+ paddingData(shFinanceDto, list, "鍏朵粬缁煎悎鏀剁泭", api1501.getQtzhsyqmye() + "", api1501.getQtzhsyncye() + "");
+ paddingData(shFinanceDto, list, "涓撻」鍌ㄥ", api1501.getZxcbqmye() + "", api1501.getZxcbncye() + "");
+ paddingData(shFinanceDto, list, "鐩堜綑鍏Н", api1501.getYygjqmye() + "", api1501.getYygjncye() + "");
+ paddingData(shFinanceDto, list, "鏈垎閰嶅埄娑�", api1501.getWfplrqmye() + "", api1501.getWfplrncye() + "");
+ paddingData(shFinanceDto, list, "鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級鍚堣", api1501.getSyzqyqmye() + "", api1501.getSyzqyncye() + "");
+ paddingData(shFinanceDto, list, "璐熷�哄拰鎵�鏈夎�呮潈鐩婏紙鎴栬偂涓滄潈鐩婏級鎬昏", api1501.getFzhsyzqyqmye() + "", api1501.getFzhsyzqyncye() + "");
+ return list;
+ }
+
+ private void paddingData(SHFinanceDto common, List<SHFinanceDto> list, String zbmc, String zbz1, String zbz2) {
+ SHFinanceDto shFinanceDto = new SHFinanceDto();
+ BeanUtils.copyProperties(common, shFinanceDto);
+ shFinanceDto.setZbmc(zbmc);
+ shFinanceDto.setZbz1(zbz1);
+ shFinanceDto.setZbz2(zbz2);
+ list.add(shFinanceDto);
+ }
+
+ private Object changeObject(Object object) {
+ // 浣跨敤鍙嶅皠鑾峰彇灞炴�у垪琛� vo涓哄疄浣撳璞″悕
+ Field[] fields = object.getClass().getDeclaredFields();
+ for (Field field : fields) {
+ field.setAccessible(true);
+ try {
+ // 鍒ゆ柇灞炴�у�兼槸鍚︿负null
+ if (field.get(object) == null || field.get(object) == "") {
+ //鏍规嵁绫诲瀷璁剧疆榛樿鍊�
+ if (field.getType() == String.class) {
+ field.set(object, "鏃�");
+ }
+ if (field.getType() == Integer.class) {
+ field.set(object, 0);
+ }
+ if (field.getType() == Double.class) {
+ field.set(object, 0.0);
+ }
+ if (field.getType() == Date.class) {
+ field.set(object, new Date());
+ }
+ }
+ } catch (IllegalAccessException e) {
+ e.printStackTrace();
+ }
+ }
+ return object;
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023Constant.java b/src/main/java/com/fzzy/push/nx2023/NX2023Constant.java
new file mode 100644
index 0000000..54daa32
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023Constant.java
@@ -0,0 +1,164 @@
+package com.fzzy.push.nx2023;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鎺ュ彛-甯搁噺
+ */
+public class NX2023Constant {
+
+ /**
+ * 鎺ュ彛缂栫爜-1101 鍗曚綅淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1101 = "1101";
+ /**
+ * 鎺ュ彛缂栫爜-1102 搴撳尯淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1102 = "1102";
+ /**
+ * 鎺ュ彛缂栫爜-1103 浠撴埧淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1103 = "1103";
+ /**
+ * 鎺ュ彛缂栫爜-1104 寤掗棿淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1104 = "1104";
+ /**
+ * 鎺ュ彛缂栫爜-1105 璐т綅淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1105 = "1105";
+ /**
+ * 鎺ュ彛缂栫爜-1106 娌圭綈淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1106 = "1106";
+ /**
+ * 鎺ュ彛缂栫爜-1107 璁惧淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1107 = "1107";
+ /**
+ * 鎺ュ彛缂栫爜-1108 鑽墏淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1108 = "1108";
+ /**
+ * 鎺ュ彛缂栫爜-1109 鏂囦欢淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1109 = "1109";
+ /**
+ * 鎺ュ彛缂栫爜-1110 搴撳尯鍥句粨鎴跨偣浣嶆爣娉ㄦ暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1110 = "1110";
+ /**
+ * 鎺ュ彛缂栫爜-1111 搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉ㄦ暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1111 = "1111";
+ /**
+ * 鎺ュ彛缂栫爜-1112 浜哄憳淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1112 = "1112";
+
+ /**
+ * 鎺ュ彛缂栫爜-1114 璐㈠姟鎶ヨ〃鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1114 = "1114";
+ public static String NX_2023_API_CODE_1114_1501 = "1501";
+ public static String NX_2023_API_CODE_1114_1502 = "1502";
+ public static String NX_2023_API_CODE_1114_1503 = "1503";
+
+ /**
+ * 鎺ュ彛缂栫爜-1201 鍚堝悓淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1201 = "1201";
+ /**
+ * 鎺ュ彛缂栫爜-1202 绮鍏ュ簱淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1202 = "1202";
+ /**
+ * 鎺ュ彛缂栫爜-1203 绮鍏ュ簱妫�楠屼俊鎭暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1203 = "1203";
+ /**
+ * 鎺ュ彛缂栫爜-1204 绮鍏ュ簱缁撶畻淇℃伅鏁版嵁鍙�
+ */
+ public static String NX_2023_API_CODE_1204 = "1204";
+ /**
+ * 鎺ュ彛缂栫爜-1205 绮鍑哄簱淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1205 = "1205";
+ /**
+ * 鎺ュ彛缂栫爜-1206 绮鍑哄簱缁撶畻淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1206 = "1206";
+ /**
+ * 鎺ュ彛缂栫爜-1207 鍊掍粨鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1207 = "1207";
+ /**
+ * 鎺ュ彛缂栫爜-1208 绮搴撳瓨鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1208 = "1208";
+ /**
+ * 鎺ュ彛缂栫爜-1209 鎹熸孩鍗曟暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1209 = "1209";
+ /**
+ * 鎺ュ彛缂栫爜-1210 绮鎬ц川杞彉鍗曟暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1210 = "1210";
+ /**
+ * 鎺ュ彛缂栫爜-1211 璐﹂潰搴撳瓨鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1211 = "1211";
+ /**
+ * 鎺ュ彛缂栫爜-1212 瀹㈡埛淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1212 = "1212";
+
+ /**
+ * 鎺ュ彛缂栫爜-1301 瀹夊叏绠＄悊鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1301 = "1301";
+ /**
+ * 鎺ュ彛缂栫爜-1302 娓╂箍搴︽娴嬫暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1302 = "1302";
+ /**
+ * 鎺ュ彛缂栫爜-1303 瀹宠櫕妫�娴嬫暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1303 = "1303";
+ /**
+ * 鎺ュ彛缂栫爜-1304 姘斾綋妫�娴嬫暟鎹帴鍙�
+ */
+ public static String NX_2023_API_CODE_1304 = "1304";
+ /**
+ * 鎺ュ彛缂栫爜-1305 閫氶浣滀笟鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1305 = "1305";
+ /**
+ * 鎺ュ彛缂栫爜-1306 鐔忚捀浣滀笟鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1306 = "1306";
+ /**
+ * 鎺ュ彛缂栫爜-1307 浠撳唴瑙嗛鍥惧儚鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1307 = "1307";
+ /**
+ * 鎺ュ彛缂栫爜-1308 瑙嗛鐩戞帶寮傚父浜嬩欢鍛婅鍩烘湰淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1308 = "1308";
+ /**
+ * 鎺ュ彛缂栫爜-1309 杩濊棰勮淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1309 = "1309";
+ /**
+ * 鎺ュ彛缂栫爜-1310 璐ㄦ鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1310 = "1310";
+
+ /**
+ * 鎺ュ彛缂栫爜-1403 杞崲璁″垝淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1403 = "1403";
+ /**
+ * 鎺ュ彛缂栫爜-1404 杞崲璁″垝鏄庣粏淇℃伅鏁版嵁鎺ュ彛
+ */
+ public static String NX_2023_API_CODE_1404 = "1404";
+
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023HttpClientUtil.java b/src/main/java/com/fzzy/push/nx2023/NX2023HttpClientUtil.java
new file mode 100644
index 0000000..33ca5af
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023HttpClientUtil.java
@@ -0,0 +1,89 @@
+package com.fzzy.push.nx2023;
+
+import com.alibaba.fastjson.JSON;
+import com.fzzy.api.entity.ApiConfs;
+import com.fzzy.push.sh2023.dto.SH2023RespDto;
+import lombok.extern.slf4j.Slf4j;
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.URL;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-涓婁紶鏁版嵁鏈嶅姟绫�
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+public class NX2023HttpClientUtil {
+
+ /**
+ * post formData
+ * @param url
+ * @return
+ * @throws Exception
+ */
+ @SuppressWarnings("resource")
+ public static SH2023RespDto postPushData(String url, String reqData , ApiConfs apiConfs) throws Exception {
+ log.info("---------鎺ュ彛璇锋眰鍦板潃锛�" +url+ "----------鍙傛暟锛�" + reqData +"---------");
+ BufferedReader in = null;
+ URL urls = new URL(url);
+ HttpURLConnection connection = null;
+ OutputStream outputStream = null;
+ String rs = "";
+ SH2023RespDto responseDto;
+ try {
+
+ connection = (HttpURLConnection) urls.openConnection();
+ connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
+ connection.setDoOutput(true);
+ connection.setDoInput(true);
+ connection.setRequestProperty("Accept-Language", "zh-CN,zh;q=0.8");
+ connection.setRequestProperty("Accept", "*/*");
+ connection.setRequestProperty("Range", "bytes=" + "");
+ connection.setConnectTimeout(20000);
+ connection.setReadTimeout(30000);
+ connection.setRequestMethod("POST");
+
+ outputStream = connection.getOutputStream();
+
+ outputStream.write(reqData.getBytes("UTF-8"));
+ try {
+ connection.connect();
+ if (connection.getResponseCode() == 200) {
+ in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
+ String line = "";
+ while ((line = in.readLine()) != null) {
+ rs += line;
+ }
+ }else{
+ log.error("http鐘舵�侊細" + connection.getResponseCode());
+ log.error("http娑堟伅锛�" + connection.getResponseMessage());
+ }
+
+ } catch (Exception e) {
+ System.out.println("鍙戠敓寮傚父");
+ log.error(e.getMessage(),e);
+ rs = null;
+ return new SH2023RespDto(99,e.getMessage());
+ }
+ log.info("---------鎺ュ彛杩斿洖锛�" + rs +"---------");
+ responseDto = JSON.parseObject(rs,SH2023RespDto.class);
+ if(responseDto == null ) return new SH2023RespDto(99,"鎺ュ彛璇锋眰鍙戠敓鏈煡閿欒");
+ return responseDto;
+ } finally {
+ try {
+ outputStream.close();
+ if (in != null){
+ in.close();
+ }
+ } catch (Exception e) {
+ }
+ outputStream = null;
+ if (connection != null)
+ connection.disconnect();
+ connection = null;
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023OrderApiServiceImpl.java b/src/main/java/com/fzzy/push/nx2023/NX2023OrderApiServiceImpl.java
new file mode 100644
index 0000000..656ed7d
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023OrderApiServiceImpl.java
@@ -0,0 +1,200 @@
+package com.fzzy.push.nx2023;
+
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.entity.ApiConfs;
+import com.fzzy.api.utils.RedisConst;
+import com.fzzy.api.utils.RedisUtil;
+import com.fzzy.order.OrderApiService;
+import com.fzzy.order.data.OrderConstant;
+import com.fzzy.order.data.OrderData;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.lang.time.DateUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.text.ParseException;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鎸囦护瑙ｆ瀽
+ *
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Service
+public class NX2023OrderApiServiceImpl implements OrderApiService {
+
+ @Autowired
+ private RedisUtil redisUtil;
+ @Autowired
+ private NX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private NX2023PushService11 nX2023PushService11;
+ @Autowired
+ private NX2023PushService12 nX2023PushService12;
+ @Autowired
+ private NX2023PushService13 nX2023PushService13;
+ @Autowired
+ private NX2023PushService14 nX2023PushService14;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+
+ @Override
+ public void execute(OrderData req, String orderType, ApiConfs conf, String orderid) throws ParseException {
+
+ // 鑻ユ寚浠ょ被鍨嬩笉涓�1锛屽垯杩斿洖
+ if(!OrderConstant.ORDER_TYPE_1.equals(orderType)){
+ log.error("鎸囦护绫诲瀷涓嶄负1锛屼笉杩涜鏁版嵁涓婃姤={}", req);
+ return;
+ }
+ String ids = req.getContent();
+ if(StringUtils.isEmpty(ids)){
+ log.error("鎸囦护鎺ュ彛涓虹┖锛屼笉杩涜鏁版嵁涓婃姤={}", req);
+ return;
+ }
+
+ //鎸囦护瀛樺叆缂撳瓨锛屾椂鏁�24灏忔椂
+ String key = RedisConst.buildKey(RedisConst.KYE_ORDER, conf.getKqdm());
+ redisUtil.set(key, req, 59 * 60 * 24);
+
+ ApiParam param = new ApiParam();
+ param.setPushProtocol(conf.getPushProtocol());
+ param.setKqdm(conf.getKqdm());
+ param.setStart(DateUtils.parseDate(req.getStarttime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
+ param.setEnd(DateUtils.parseDate(req.getEndtime(), new String[]{"yyyy-MM-dd HH:mm:ss"}));
+ param.setDeptId(conf.getDeptId());
+
+ log.info("鎺ユ敹鐨勬寚浠や腑鎺ュ彛鍐呭涓�={}", req.getContent());
+ String[] interfaces = ids.split(";");
+ for (String inteId : interfaces) {
+ log.info("鎵ц鎺ュ彛={}鐨勬暟鎹笂鎶�", inteId);
+ getDataToPush(param, inteId);
+ }
+
+ }
+
+ private void getDataToPush(ApiParam param, String inteId) {
+ switch (inteId) {
+ case "1101":
+ nX2023PushService11.pushData1101(apiRemoteService, param);
+ break;
+ case "1102":
+ nX2023PushService11.pushData1102(apiRemoteService, param);
+ break;
+ case "1103":
+ nX2023PushService11.pushData1103(apiRemoteService, param);
+ break;
+ case "1104":
+ nX2023PushService11.pushData1104(apiRemoteService, param);
+ break;
+ case "1105":
+ nX2023PushService11.pushData1105(apiRemoteService, param);
+ break;
+ case "1106":
+ nX2023PushService11.pushData1106(apiRemoteService, param);
+ break;
+ case "1107":
+ nX2023PushService11.pushData1107(apiRemoteService, param);
+ break;
+ case "1108":
+ nX2023PushService11.pushData1108(apiRemoteService, param);
+ break;
+ case "1109":
+ nX2023PushService11.pushData1109(apiRemoteService, param);
+ break;
+ case "1110":
+ nX2023PushService11.pushData1110(apiRemoteService, param);
+ break;
+ case "1111":
+ nX2023PushService11.pushData1111(apiRemoteService, param);
+ break;
+ case "1112":
+ nX2023PushService11.pushData1112(apiRemoteService, param);
+ break;
+ case "1114":
+ nX2023PushService11.pushData1114(apiRemoteService, param);
+ break;
+ case "1201":
+ nX2023PushService12.pushData1201(apiRemoteService, param);
+ break;
+ case "1202":
+ nX2023PushService12.pushData1202(apiRemoteService, param);
+ break;
+ case "1203":
+ nX2023PushService12.pushData1203(apiRemoteService, param);
+ break;
+ case "1204":
+ nX2023PushService12.pushData1204(apiRemoteService, param);
+ break;
+ case "1205":
+ nX2023PushService12.pushData1205(apiRemoteService, param);
+ break;
+ case "1206":
+ nX2023PushService12.pushData1206(apiRemoteService, param);
+ break;
+ case "1207":
+ nX2023PushService12.pushData1207(apiRemoteService, param);
+ break;
+ case "1208":
+ nX2023PushService12.pushData1208(apiRemoteService, param);
+ break;
+ case "1209":
+ nX2023PushService12.pushData1209(apiRemoteService, param);
+ break;
+ case "1210":
+ nX2023PushService12.pushData1210(apiRemoteService, param);
+ break;
+ case "1211":
+ nX2023PushService12.pushData1211(apiRemoteService, param);
+ break;
+ case "1212":
+ nX2023PushService12.pushData1212(apiRemoteService, param);
+ break;
+ case "1301":
+ nX2023PushService13.pushData1301(apiRemoteService, param);
+ break;
+ case "1302":
+ nX2023PushService13.pushData1302(apiRemoteService, param);
+ break;
+ case "1303":
+ nX2023PushService13.pushData1303(apiRemoteService, param);
+ break;
+ case "1304":
+ nX2023PushService13.pushData1304(apiRemoteService, param);
+ break;
+ case "1305":
+ nX2023PushService13.pushData1305(apiRemoteService, param);
+ break;
+ case "1306":
+ nX2023PushService13.pushData1306(apiRemoteService, param);
+ break;
+ case "1307":
+ nX2023PushService13.pushData1307(apiRemoteService, param);
+ break;
+ case "1308":
+ nX2023PushService13.pushData1308(apiRemoteService, param);
+ break;
+ case "1309":
+ nX2023PushService13.pushData1309(apiRemoteService, param);
+ break;
+ case "1310":
+ nX2023PushService13.pushData1310(apiRemoteService, param);
+ break;
+ case "1403":
+ nX2023PushService14.pushData1403(apiRemoteService, param);
+ break;
+ case "1404":
+ nX2023PushService14.pushData1404(apiRemoteService, param);
+ break;
+ default:
+ log.error("-----瀹佸鐪佸钩鍙帮細鏈尮閰嶅埌鎺ュ彛缂栫爜锛屼笉鎺ㄩ��-----");
+ break;
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023PushService11.java b/src/main/java/com/fzzy/push/nx2023/NX2023PushService11.java
new file mode 100644
index 0000000..a70224b
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023PushService11.java
@@ -0,0 +1,513 @@
+package com.fzzy.push.nx2023;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.*;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.PushService11;
+import com.fzzy.api.view.repository.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.List;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鍩虹鏁版嵁涓婁紶
+ *
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Component
+public class NX2023PushService11 implements PushService11 {
+
+ @Autowired
+ private NX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private Api1101Rep api1101Rep;
+ @Autowired
+ private Api1102Rep api1102Rep;
+ @Autowired
+ private Api1103Rep api1103Rep;
+ @Autowired
+ private Api1104Rep api1104Rep;
+ @Autowired
+ private Api1105Rep api1105Rep;
+ @Autowired
+ private Api1106Rep api1106Rep;
+ @Autowired
+ private Api1107Rep api1107Rep;
+ @Autowired
+ private Api1108Rep api1108Rep;
+ @Autowired
+ private Api1109Rep api1109Rep;
+ @Autowired
+ private Api1110Rep api1110Rep;
+ @Autowired
+ private Api1111Rep api1111Rep;
+ @Autowired
+ private Api1112Rep api1112Rep;
+ @Autowired
+ private Api1501Rep api1501Rep;
+ @Autowired
+ private Api1502Rep api1502Rep;
+ @Autowired
+ private Api1503Rep api1503Rep;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+ @Override
+ public void pushData(ApiParam param) {
+
+ log.info("------->>>>涓婃捣2023鎺ュ彛涓嶄富鍔ㄤ笂鎶�");
+
+ //鎺ㄩ�佸崟浣嶄俊鎭�
+ this.pushData1101(apiRemoteService, param);
+ //搴撳尯淇℃伅
+ this.pushData1102(apiRemoteService, param);
+ //浠撴埧淇℃伅
+ this.pushData1103(apiRemoteService, param);
+ //寤掗棿淇℃伅
+ this.pushData1104(apiRemoteService, param);
+ //璐т綅淇℃伅
+ this.pushData1105(apiRemoteService, param);
+ //娌圭綈淇℃伅
+ this.pushData1106(apiRemoteService, param);
+ //璁惧淇℃伅
+ this.pushData1107(apiRemoteService, param);
+ //鑽墏淇℃伅
+ this.pushData1108(apiRemoteService, param);
+ //鏂囦欢淇℃伅
+ this.pushData1109(apiRemoteService, param);
+ //搴撳尯鍥句粨鎴跨偣浣嶆爣娉�
+ this.pushData1110(apiRemoteService, param);
+ //搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉�
+ this.pushData1111(apiRemoteService, param);
+ //浜哄憳淇℃伅
+ this.pushData1112(apiRemoteService, param);
+ //璐㈠姟鎶ヨ〃
+ this.pushData1114(apiRemoteService, param);
+
+ log.info("------->>>>鍩虹淇℃伅 鎺ュ彛妯″潡涓婃姤缁撴潫");
+ }
+
+ /**
+ * 1101 鍗曚綅淇℃伅
+ */
+ public void pushData1101(ApiRemoteService apiRemoteService, ApiParam param) {
+
+ //鑾峰彇鍗曚綅淇℃伅
+ List<Api1101> list = api1101Rep.getDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鍗曚綅淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1101);
+
+ ResponseDto responseDto;
+ for (Api1101 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1101Rep.updateStatus(data.getDwdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1102 搴撳尯淇℃伅
+ */
+ public void pushData1102(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇搴撳尯淇℃伅
+ List<Api1102> list = api1102Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌搴撳尯淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1102);
+
+ ResponseDto responseDto;
+ for (Api1102 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1102Rep.updateStatus(data.getKqdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1103 浠撴埧淇℃伅
+ */
+ public void pushData1103(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇浠撴埧淇℃伅
+ List<Api1103> list = api1103Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌浠撴埧淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1103);
+
+ ResponseDto responseDto;
+ for (Api1103 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1103Rep.updateStatus(data.getCfdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1104 寤掗棿淇℃伅
+ */
+ public void pushData1104(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇寤掗棿淇℃伅
+ List<Api1104> list = api1104Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌寤掗棿淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1104);
+
+ ResponseDto responseDto;
+ //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
+ for (Api1104 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1103Rep.updateStatus(data.getAjdh(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1105 璐т綅淇℃伅
+ */
+ public void pushData1105(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璐т綅淇℃伅
+ List<Api1105> list = api1105Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌璐т綅淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1105);
+
+ ResponseDto responseDto;
+ for (Api1105 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1105Rep.updateStatus(data.getHwdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1106 娌圭綈淇℃伅
+ */
+ public void pushData1106(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇娌圭綈淇℃伅
+ List<Api1106> list = api1106Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌娌圭綈淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1106);
+
+ ResponseDto responseDto;
+ for (Api1106 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1106Rep.updateStatus(data.getYgdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1107 璁惧淇℃伅
+ */
+ public void pushData1107(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璁惧淇℃伅
+ List<Api1107> list = api1107Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌璁惧淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1107);
+
+ ResponseDto responseDto;
+
+ //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
+ for (Api1107 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1107Rep.updateStatus(data.getSbbh(), Constant.CZBZ_U);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1108 鑽墏淇℃伅
+ */
+ public void pushData1108(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鑽墏淇℃伅
+ List<Api1108> list = api1108Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鑽墏淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1108);
+
+ ResponseDto responseDto;
+ for (Api1108 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1108Rep.updateStatus(data.getId(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1109 鏂囦欢淇℃伅
+ */
+ public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鏂囦欢淇℃伅
+ List<Api1109> list = api1109Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鏂囦欢淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1109);
+
+ ResponseDto responseDto;
+ for (Api1109 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1109Rep.updateStatus(data.getId(), Constant.CZBZ_U);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1110 搴撳尯鍥句粨鎴跨偣浣嶆爣娉�
+ */
+ public void pushData1110(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇搴撳尯鍥句粨鎴跨偣浣嶆爣娉�
+ List<Api1110> list = api1110Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌搴撳尯鍥句粨鎴跨偣浣嶆爣娉紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1110);
+
+ ResponseDto responseDto;
+ for (Api1110 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1110Rep.updateStatus(data.getHwdm(), Constant.CZBZ_U);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1111 搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉�
+ */
+ public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉�
+ List<Api1111> list = api1111Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌搴撳尯鍥捐棰戠洃鎺ц澶囩偣浣嶆爣娉紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1111);
+
+ ResponseDto responseDto;
+ for (Api1111 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1111Rep.updateStatus(data.getSpjksbid(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1112 浜哄憳淇℃伅
+ */
+ public void pushData1112(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇浜哄憳淇℃伅
+ List<Api1112> list = api1112Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌浜哄憳淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_11);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1112);
+ ResponseDto responseDto;
+
+ //鎺ㄩ�佹垚鍔燂紝鏇存柊鏁版嵁涓婁紶鐘舵��
+ for (Api1112 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ api1112Rep.updateStatus(data.getSfzhm(), Constant.CZBZ_U);
+ }
+ }
+ }
+ }
+
+
+ /**
+ * 1114 璐㈠姟鎶ヨ〃
+ */
+ public void pushData1114(ApiRemoteService apiRemoteService, ApiParam param) {
+ this.pushData1501(apiRemoteService, param);
+ this.pushData1502(apiRemoteService, param);
+ this.pushData1503(apiRemoteService, param);
+
+ }
+
+ /**
+ * 1501 璐㈠姟鎶ヨ〃-璧勪骇璐熷��--鍗曟潯涓婁紶
+ */
+ public void pushData1501(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璐㈠姟鎶ヨ〃-璧勪骇璐熷��
+ List<Api1501> list = api1501Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌璧勪骇璐熷�轰俊鎭紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1114_1501);
+ ResponseDto responseDto;
+ Api1501 d;
+ for (Api1501 data : list) {
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1501Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1502 璐㈠姟鎶ヨ〃-鐜伴噾娴�
+ */
+ public void pushData1502(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璐㈠姟鎶ヨ〃-璧勪骇璐熷��
+ List<Api1502> list = api1502Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鐜伴噾娴佷俊鎭紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1114_1502);
+ ResponseDto responseDto;
+ for (Api1502 data : list) {
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1502Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1503 璐㈠姟鎶ヨ〃-鍒╂鼎淇℃伅
+ */
+ public void pushData1503(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璐㈠姟鎶ヨ〃-璧勪骇璐熷��
+ List<Api1503> list = api1503Rep.findPushDataTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鍒╂鼎淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1114_1503);
+ ResponseDto responseDto;
+ Api1503 d;
+ for (Api1503 data : list) {
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1503Rep.save(data);
+ }
+ }
+ }
+ }
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023PushService12.java b/src/main/java/com/fzzy/push/nx2023/NX2023PushService12.java
new file mode 100644
index 0000000..18dcd11
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023PushService12.java
@@ -0,0 +1,431 @@
+package com.fzzy.push.nx2023;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.*;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.PushService11;
+import com.fzzy.api.view.repository.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鍩虹鏁版嵁涓婁紶
+ *
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Component
+public class NX2023PushService12 implements PushService11 {
+
+
+ @Autowired
+ private NX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private Api1201Rep api1201Rep;
+ @Autowired
+ private Api1202Rep api1202Rep;
+ @Autowired
+ private Api1203Rep api1203Rep;
+ @Autowired
+ private Api1204Rep api1204Rep;
+ @Autowired
+ private Api1205Rep api1205Rep;
+ @Autowired
+ private Api1206Rep api1206Rep;
+ @Autowired
+ private Api1207Rep api1207Rep;
+ @Autowired
+ private Api1208Rep api1208Rep;
+ @Autowired
+ private Api1209Rep api1209Rep;
+ @Autowired
+ private Api1210Rep api1210Rep;
+ @Autowired
+ private Api1211Rep api1211Rep;
+ @Autowired
+ private Api1212Rep api1212Rep;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+ @Override
+ public void pushData(ApiParam param) {
+ log.info("------->>>>绮璐攢 鎺ュ彛妯″潡涓婃姤寮�濮�");
+
+ //鎺ㄩ�佸悎鍚屼俊鎭�
+ this.pushData1201(apiRemoteService, param);
+ //绮鍏ュ簱淇℃伅
+ this.pushData1202(apiRemoteService, param);
+ //绮鍏ュ簱妫�楠屼俊鎭�
+ this.pushData1203(apiRemoteService, param);
+ //绮鍏ュ簱缁撶畻淇℃伅
+ this.pushData1204(apiRemoteService, param);
+ //绮鍑哄簱淇℃伅
+ this.pushData1205(apiRemoteService, param);
+ //绮鍑哄簱缁撶畻淇℃伅
+ this.pushData1206(apiRemoteService, param);
+ //鍊掍粨鍊掑嚭
+ this.pushData1207(apiRemoteService, param);
+ //绮搴撳瓨
+ this.pushData1208(apiRemoteService, param);
+ //鎹熸孩鍗�
+ this.pushData1209(apiRemoteService, param);
+ //绮鎬ц川杞彉鍗�
+ this.pushData1210(apiRemoteService, param);
+ //璐﹂潰搴撳瓨
+ this.pushData1211(apiRemoteService, param);
+ //瀹㈡埛淇℃伅
+ this.pushData1212(apiRemoteService, param);
+
+ log.info("------->>>>绮璐攢 鎺ュ彛妯″潡涓婃姤缁撴潫");
+ }
+
+ /**
+ * 1201 鍚堝悓淇℃伅
+ */
+ public void pushData1201(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鍚堝悓淇℃伅
+ List<Api1201> list = api1201Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鍚堝悓淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1201);
+
+ ResponseDto responseDto;
+ for (Api1201 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ api1201Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1202 绮鍏ュ簱淇℃伅
+ */
+ public void pushData1202(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮鍏ュ簱淇℃伅
+ List<Api1202> list = api1202Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮鍏ュ簱淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1202);
+
+ ResponseDto responseDto;
+ for (Api1202 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1202Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1203 绮鍏ュ簱妫�楠屼俊鎭�
+ */
+ public void pushData1203(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮鍏ュ簱妫�楠屼俊鎭�
+ List<Api1203> list = api1203Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮鍏ュ簱妫�楠屼俊鎭紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1203);
+
+ ResponseDto responseDto;
+ for (Api1203 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1203Rep.save(data);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1204 绮鍏ュ簱缁撶畻淇℃伅
+ */
+ public void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮鍏ュ簱缁撶畻淇℃伅
+ List<Api1204> list = api1204Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮鍏ュ簱缁撶畻淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1204);
+
+ ResponseDto responseDto;
+ for (Api1204 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1204Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1205 绮鍑哄簱淇℃伅
+ */
+ public void pushData1205(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮鍑哄簱淇℃伅
+ List<Api1205> list = api1205Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮鍑哄簱淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1205);
+
+ ResponseDto responseDto;
+ for (Api1205 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1205Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1206 绮鍑哄簱缁撶畻淇℃伅
+ */
+ public void pushData1206(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮鍑哄簱缁撶畻淇℃伅
+ List<Api1206> list = api1206Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮鍑哄簱缁撶畻淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1206);
+ ResponseDto responseDto;
+ for (Api1206 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1206Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1207 鍊掍粨鏁版嵁
+ */
+ public void pushData1207(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鍊掍粨淇℃伅
+ List<Api1207> list = api1207Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鍊掍粨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1207);
+
+ ResponseDto responseDto;
+ for (Api1207 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1207Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1208 绮搴撳瓨
+ */
+ public void pushData1208(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇绮搴撳瓨淇℃伅
+ List<Api1208> list = api1208Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮搴撳瓨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1208);
+
+ ResponseDto responseDto;
+ for (Api1208 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1208Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1209 鎹熸孩鍗�
+ */
+ public void pushData1209(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鎹熺泭鍗曚俊鎭�
+ List<Api1209> list = api1209Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮搴撳瓨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1209);
+
+ ResponseDto responseDto;
+ for (Api1209 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1209Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1210 绮鎬ц川杞彉鍗�
+ */
+ public void pushData1210(ApiRemoteService apiRemoteService, ApiParam param) {
+ //绮鎬ц川杞彉鍗�
+ List<Api1210> list = api1210Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮搴撳瓨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1210);
+
+ ResponseDto responseDto;
+ for (Api1210 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1210Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1211 璐﹂潰搴撳瓨
+ */
+ public void pushData1211(ApiRemoteService apiRemoteService, ApiParam param) {
+ //璐﹂潰搴撳瓨
+ List<Api1211> list = api1211Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌绮搴撳瓨淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1210);
+
+ ResponseDto responseDto;
+ for (Api1211 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1211Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1212 瀹㈡埛淇℃伅
+ */
+ public void pushData1212(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇瀹㈡埛淇℃伅
+ List<Api1212> list = api1212Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌瀹㈡埛淇℃伅锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_12);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1212);
+
+ ResponseDto responseDto;
+ for (Api1212 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1212Rep.save(data);
+ }
+ }
+ }
+ }
+
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023PushService13.java b/src/main/java/com/fzzy/push/nx2023/NX2023PushService13.java
new file mode 100644
index 0000000..6341e61
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023PushService13.java
@@ -0,0 +1,359 @@
+package com.fzzy.push.nx2023;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.*;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.PushService11;
+import com.fzzy.api.view.repository.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鍩虹鏁版嵁涓婁紶
+ *
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Component
+public class NX2023PushService13 implements PushService11 {
+
+
+ @Autowired
+ private NX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private Api1301Rep api1301Rep;
+ @Autowired
+ private Api1302Rep api1302Rep;
+ @Autowired
+ private Api1303Rep api1303Rep;
+ @Autowired
+ private Api1304Rep api1304Rep;
+ @Autowired
+ private Api1305Rep api1305Rep;
+ @Autowired
+ private Api1306Rep api1306Rep;
+ @Autowired
+ private Api1307Rep api1307Rep;
+ @Autowired
+ private Api1308Rep api1308Rep;
+ @Autowired
+ private Api1309Rep api1309Rep;
+ @Autowired
+ private Api1310Rep api1310Rep;
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+ @Override
+ public void pushData(ApiParam param) {
+ log.info("------->>>>绮簱绠＄悊 鎺ュ彛妯″潡涓婃姤寮�濮�");
+
+ this.pushData1301(apiRemoteService, param);
+ this.pushData1302(apiRemoteService, param);
+ this.pushData1303(apiRemoteService, param);
+ this.pushData1304(apiRemoteService, param);
+ this.pushData1305(apiRemoteService, param);
+ this.pushData1306(apiRemoteService, param);
+ this.pushData1307(apiRemoteService, param);
+ this.pushData1308(apiRemoteService, param);
+ this.pushData1309(apiRemoteService, param);
+ this.pushData1310(apiRemoteService, param);
+
+ log.info("------->>>>绮簱绠＄悊 鎺ュ彛妯″潡涓婃姤缁撴潫");
+ }
+
+ /**
+ * 1301 瀹夊叏绠＄悊
+ */
+ public void pushData1301(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇瀹夊叏绠＄悊
+ List<Api1301> list = api1301Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌瀹夊叏绠＄悊锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1301);
+
+ ResponseDto responseDto;
+ for (Api1301 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1301Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1302 娓╂箍搴︽娴�
+ */
+ public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇娓╂箍搴︽娴�
+ List<Api1302> list = api1302Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌娓╂箍搴︽娴嬶紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1302);
+
+ ResponseDto responseDto;
+ for (Api1302 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1302Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1303 瀹宠櫕妫�娴�
+ */
+ public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇瀹宠櫕妫�娴�
+ List<Api1303> list = api1303Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌瀹宠櫕妫�娴嬶紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1303);
+
+ ResponseDto responseDto;
+ for (Api1303 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1303Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1304 姘斾綋妫�娴�
+ */
+ public void pushData1304(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇姘斾綋妫�娴�
+ List<Api1304> list = api1304Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌姘斾綋妫�娴嬶紝涓嶆帹閫�-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1304);
+
+ ResponseDto responseDto;
+ for (Api1304 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1304Rep.save(data);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1305 閫氶浣滀笟
+ */
+ public void pushData1305(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇閫氶浣滀笟
+ List<Api1305> list = api1305Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌閫氶浣滀笟锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1305);
+
+ ResponseDto responseDto;
+ for (Api1305 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1305Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1306 鐔忚捀浣滀笟
+ */
+ public void pushData1306(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇鐔忚捀浣滀笟
+ List<Api1306> list = api1306Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌鐔忚捀浣滀笟锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1306);
+
+ ResponseDto responseDto;
+ for (Api1306 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1306Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1307 浠撳唴瑙嗛鍥惧儚
+ */
+ public void pushData1307(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇浠撳唴瑙嗛鍥惧儚
+ List<Api1307> list = api1307Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌浠撳唴瑙嗛鍥惧儚锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1307);
+
+ ResponseDto responseDto;
+ for (Api1307 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1307Rep.save(data);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1308 瑙嗛鐩戞帶寮傚父浜嬩欢鍛婅
+ */
+ public void pushData1308(ApiRemoteService apiRemoteService, ApiParam param) {
+ //瑙嗛鐩戞帶寮傚父浜嬩欢鍛婅
+ List<Api1308> list = api1308Rep.findAll();
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌浠撳唴瑙嗛鍥惧儚锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1308);
+
+ ResponseDto responseDto;
+ for (Api1308 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1308Rep.save(data);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1309 杩濊棰勮淇℃伅
+ */
+ public void pushData1309(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇浠撳唴瑙嗛鍥惧儚
+ List<Api1309> list = api1309Rep.findAll();
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌浠撳唴瑙嗛鍥惧儚锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1307);
+
+ ResponseDto responseDto;
+ for (Api1309 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1309Rep.save(data);
+ }
+ }
+ }
+
+ }
+
+ /**
+ * 1310 璐ㄦ鏁版嵁
+ */
+ public void pushData1310(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇璐ㄦ鏁版嵁
+ List<Api1310> list = api1310Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌璐ㄦ鏁版嵁锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_13);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1310);
+
+ ResponseDto responseDto;
+ for (Api1310 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1310Rep.save(data);
+ }
+ }
+ }
+ }
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/NX2023PushService14.java b/src/main/java/com/fzzy/push/nx2023/NX2023PushService14.java
new file mode 100644
index 0000000..244f754
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/NX2023PushService14.java
@@ -0,0 +1,109 @@
+package com.fzzy.push.nx2023;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.data.ApiParam;
+import com.fzzy.api.data.PushProtocol;
+import com.fzzy.api.dto.ResponseDto;
+import com.fzzy.api.entity.Api1403;
+import com.fzzy.api.entity.Api1404;
+import com.fzzy.api.service.ApiRemoteService;
+import com.fzzy.api.service.PushService11;
+import com.fzzy.api.view.repository.*;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 瀹佸鐪佸钩鍙�2023鐗�-鍩虹鏁版嵁涓婁紶
+ *
+ * @author czt
+ * @date 2023/11/09
+ */
+@Slf4j
+@Component
+public class NX2023PushService14 implements PushService11 {
+
+ @Autowired
+ private NX2023ApiRemoteService apiRemoteService;
+ @Autowired
+ private Api1403Rep api1403Rep;
+ @Autowired
+ private Api1404Rep api1404Rep;
+
+
+ @Override
+ public String getProtocol() {
+ return PushProtocol.SB_NX_2023.getCode();
+ }
+
+ @Override
+ public void pushData(ApiParam param) {
+ log.info("------->>>>琛屾斂绠＄悊 鎺ュ彛妯″潡涓婃姤寮�濮�");
+
+ //杞崲璁″垝
+ this.pushData1403(apiRemoteService, param);
+ //杞崲璁″垝鏄庣粏
+ this.pushData1404(apiRemoteService, param);
+
+ log.info("------->>>>琛屾斂绠＄悊 鎺ュ彛妯″潡涓婃姤缁撴潫");
+ }
+
+ /**
+ * 1403 杞崲璁″垝淇℃伅
+ */
+ public void pushData1403(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇杞崲璁″垝
+ List<Api1403> list = api1403Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌杞崲璁″垝锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_14);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1403);
+
+ ResponseDto responseDto;
+ for (Api1403 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1403Rep.save(data);
+ }
+ }
+ }
+ }
+
+ /**
+ * 1404 杞崲璁″垝鏄庣粏淇℃伅
+ */
+ public void pushData1404(ApiRemoteService apiRemoteService, ApiParam param) {
+ //鑾峰彇杞崲璁″垝鏄庣粏
+ List<Api1404> list = api1404Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());
+
+ if (null == list || list.isEmpty()) {
+ log.error("-----瀹佸鐪佸钩鍙�2023鐗堬細鏈幏鍙栧埌杞崲璁″垝鏄庣粏锛屼笉鎺ㄩ��-----");
+ return;
+ }
+ param.setInteCategory(Constant.API_CATEGORY_14);
+ param.setInteId(NX2023Constant.NX_2023_API_CODE_1404);
+
+ ResponseDto responseDto;
+ for (Api1404 data : list) {
+ param.setBizId(data.getBizId());
+ responseDto = apiRemoteService.pushData(param, data);
+ if (responseDto.getSuccess() == 0) {
+ if (Constant.CZBZ_I.equals(data.getCzbz())) {
+ data.setCzbz(Constant.CZBZ_U);
+ //鏇存柊鐘舵��
+ api1404Rep.save(data);
+ }
+ }
+ }
+ }
+
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1101.java b/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1101.java
new file mode 100644
index 0000000..cebe49e
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1101.java
@@ -0,0 +1,97 @@
+package com.fzzy.push.nx2023.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 瀹佸鐪佸钩鍙�-鍗曚綅淇℃伅
+ *
+ * @author czt
+ * @date 2023-11-09
+ */
+@Data
+public class Nx2023Api1101 implements Serializable {
+
+ @PropertyDef(label = "鍗曚綅浠ｇ爜")
+ private String dwdm;
+
+ @PropertyDef(label = "鍗曚綅鍚嶇О")
+ private String dwmc;
+
+ @PropertyDef(label = "鍗曚綅绫诲瀷")
+ private String dwlx;
+
+ @PropertyDef(label = "娉ㄥ唽鏃ユ湡")
+ @JSONField(format = "yyyy-MM-dd")
+ private Date zcrq;
+
+ @PropertyDef(label = "娉ㄥ唽璧勬湰")
+ private Double zczb;
+
+ @PropertyDef(label = "璧勪骇鎬婚")
+ private Double zcze;
+
+ @PropertyDef(label = "娉曞畾浠ｈ〃浜�")
+ private String fddbr;
+
+ @PropertyDef(label = "娉曚汉韬唤璇佸彿")
+ private String frsfzh;
+
+ @PropertyDef(label = "娉曚汉鑱旂郴鏂瑰紡")
+ private String frlxfs;
+
+ @PropertyDef(label = "浼佷笟鑱旂郴浜�")
+ private String qylxr;
+
+ @PropertyDef(label = "鍔炲叕鐢佃瘽")
+ private String bgdh;
+
+ @PropertyDef(label = "娉ㄥ唽鍦板潃")
+ private String zcdz;
+
+ @PropertyDef(label = "鐢靛瓙閭")
+ private String dzyx;
+
+ @PropertyDef(label = "浼佷笟瀹樻柟缃戠珯鍦板潃")
+ private String qygfwzdz;
+
+ @PropertyDef(label = "浼犵湡鍙风爜")
+ private String czhm;
+
+ @PropertyDef(label = "閭斂缂栫爜")
+ private String yzbm;
+
+ @PropertyDef(label = "琛屾斂鍖哄垝浠ｇ爜")
+ private String xzqhdm;
+
+ @PropertyDef(label = "涓婄骇鍗曚綅鍚嶇О")
+ private String sjdwmc;
+
+ @PropertyDef(label = "涓婄骇鍗曚綅浠ｇ爜")
+ private String sjdwdm;
+
+ @PropertyDef(label = "搴撳尯鏁�")
+ private Integer kqs;
+
+ @PropertyDef(label = "浠撴埧鏁�")
+ private Integer cfs;
+
+ @PropertyDef(label = "娌圭綈鏁�")
+ private Integer ygs;
+
+ @PropertyDef(label = "缁忓害")
+ private Double jd;
+
+ @PropertyDef(label = "绾害")
+ private Double wd;
+
+ @PropertyDef(label = "鎿嶄綔鏍囧織")
+ private String czbz;
+
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ private Date zhgxsj;
+}
diff --git a/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1102.java b/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1102.java
new file mode 100644
index 0000000..e942a45
--- /dev/null
+++ b/src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1102.java
@@ -0,0 +1,64 @@
+package com.fzzy.push.nx2023.dto;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 瀹佸鐪佸钩鍙�-搴撳尯淇℃伅
+ */
+@Data
+public class Nx2023Api1102 implements Serializable {
+
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String kqdm;
+
+ @PropertyDef(label = "鍗曚綅浠ｇ爜")
+ private String dwdm;
+
+ @PropertyDef(label = "搴撳尯鍚嶇О")
+ private String kqmc;
+
+ @PropertyDef(label = "搴撳尯鍦板潃")
+ private String kqdz;
+
+ @PropertyDef(label = "琛屾斂鍖哄垝浠ｇ爜")
+ private String xzqhdm;
+
+ @PropertyDef(label = "搴撳尯浜ф潈", description = "1锛� 鑷湁 2锛氱璧� 3锛氬叡鏈� 4锛氭贩鍚� 9锛氬叾浠�")
+ private String kqcq;
+
+ @PropertyDef(label = "鏈夋晥浠撳")
+ private Double yxcr;
+
+ @PropertyDef(label = "鏈夋晥缃愬")
+ private Double yxgr;
+
+ @PropertyDef(label = "鍗犲湴闈㈢Н")
+ private Double zdmj;
+
+ @PropertyDef(label = "浠撴埧鏁�")
+ private Integer cfs;
+
+ @PropertyDef(label = "娌圭綈鏁�")
+ private Integer ygs;
+
+ @PropertyDef(label = "搴撳尯缁忓害")
+ private Double jd;
+
+ @PropertyDef(label = "搴撳尯绾害")
+ private Double wd;
+
+ @PropertyDef(label = "绮簱鎬ц川", description = "1:鍥芥湁,2:姘戣惀,3:鍚堣祫")
+ private String lkxz;
+
+ @PropertyDef(label = "鎿嶄綔鏍囧織")
+ private String czbz;
+
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ private Date zhgxsj;
+
+}
\ No newline at end of file
diff --git a/src/main/resources/application-pro5306.yml b/src/main/resources/application-pro5306.yml
new file mode 100644
index 0000000..72304b3
--- /dev/null
+++ b/src/main/resources/application-pro5306.yml
@@ -0,0 +1,61 @@
+########################## 瀹佸鐭冲槾灞辩孩鏋滃瓙绮簱 ##########################
+server:
+ port: 8090
+ jetty:
+ max-http-post-size: 209715200
+ tomcat:
+ max-http-post-size: 209715200
+spring:
+ datasource:
+ #涓绘暟鎹簮
+ primary:
+ url: jdbc:mysql://127.0.0.1:3306/igds_api?useUnicode=true&characterEncoding=utf-8&useSSL=false
+ driver-class-name: com.mysql.jdbc.Driver
+ username: root
+ password: root
+ #娆℃暟鎹簮
+ secondary:
+ url: jdbc:mysql://127.0.0.1:3306/igds_master?useUnicode=true&characterEncoding=utf-8&useSSL=false
+ driver-class-name: com.mysql.jdbc.Driver
+ username: root
+ password: root
+ jpa:
+ #涓籮pa閰嶇疆
+ primary:
+ show-sql: true
+ properties:
+ hibernate:
+ hbm2ddl:
+ auto: update
+ dialect: org.hibernate.dialect.MySQL5InnoDBDialect
+ #娆pa閰嶇疆
+ secondary:
+ show-sql: true
+ properties:
+ hibernate:
+ hbm2ddl:
+ auto: none
+ dialect: org.hibernate.dialect.MySQL5InnoDBDialect
+ # Redis鐩稿叧閰嶇疆
+ redis:
+ database: 1
+ host: 127.0.0.1
+ port: 6379
+ password: Abc123..
+ # 杩炴帴姹犳渶澶ц繛鎺ユ暟锛堜娇鐢ㄨ礋鍊艰〃绀烘病鏈夐檺鍒讹級
+ pool:
+ max-active: 200
+ max-wait: -1
+ max-idle: 10
+ min-idle: 0
+ timeout: 6000
+igds:
+ default:
+ companyId: 5306
+ file-path: D:/IGDS-API/FILE/
+ img-path: D:/IGDS/FILE/
+ # 鐪佸钩鍙癛SA瀵嗛挜瀵逛俊鎭�
+ #鍏挜锛歁IGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCsoiS5Q5CKAT9w5EbZXCxJO/5J2iV3i2HrTW/YcGs2EGeQsQc97EWPdFE1SPXGH5p9TO8nCFRJScj4WeeKUVcuRpzR7czQQ+c6kf6cR9LLQrAiGEMQSk13j/5UsJho23IQDGKWoH18f5aPdX8tJn/o4aR6mMxUY9jdaSKEBck1TQIDAQAB
+ # 鍖虹骇骞冲彴RSA瀵嗛挜瀵逛俊鎭�
+ #鍏挜锛歁IGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCMsCJyl6EkjUEfB9Otl0bNmFD0Gr3g/v8DYnoq66EIviDNKT+bo5Aj6BRFngns1aCy1uyWgC5/+PIQ3sxs25nWXxFBYXy7cTiGwCCPfnmmI3rkXRGqRo6uh9K3BsucSE0kyhB8Eq76bQ6BPa5XpMyyq8V2oN2i0LLYpDhV97j3BwIDAQAB
+ #绉侀挜锛歁IICdgIBADANBgkqhkiG9w0BAQEFAASCAmAwggJcAgEAAoGBAIywInKXoSSNQR8H062XRs2YUPQaveD+/wNieirroQi+IM0pP5ujkCPoFEWeCezVoLLW7JaALn/48hDezGzbmdZfEUFhfLtxOIbAII9+eaYjeuRdEapGjq6H0rcGy5xITSTKEHwSrvptDoE9rlekzLKrxXag3aLQstikOFX3uPcHAgMBAAECgYAOZvWPz4/ygvdYqt9zlNntsBsRci9f+hq3CPzCqg55K6WF+yQE1dCqrFZu7gfME+54gGIF4idgeGanbXd16WEtFslEJlFKGk3cF62gaX5Y/nZ4zS65CLTjQ650j6SJ7OC2QYjIejTWhJD0k1tSazXdzV70nP+X3DbGyyO3Rm+juQJBANMCi+9RnzcGvltN/AdWD0DgshRBNrqrHtDkmzRFSkFwIqVSL5J7qRvntjhSstQIBB5KCosCmwRYKxGWQ9Ou420CQQCqrz2byBz3w2pkEfPY3rv7T4zE/2CHC74XtW9sEUTieYaxqIKlnwJacactzx4ZOAg21dGCoqOG9Y9RIpH2mMfDAkEAlAucXIt61qOfmPXtFsSVrSI5LybWHEAFPfC2yAS5ZZIkbLNt9ytV6eM3oOq81zDMmue93+wzEOg/R3aTHgj9PQJALNGxUsu8V473y+ku596s6/PamgwZE70QoHcjF/R86x9QMCx4ifb0Dj3T0WKWm7ar6YJB7pS4bgLjLEHwpBlAMwJAUUG2NhfGXFxfyFOC+5BzFTEr7EdSeHPXJl7dIWmRHncHsv8Nl2yvWsIOfDOYKS3ynptMgeSZaJPnXhvFdX0TnQ==
--
Gitblit v1.9.3