From edb0ae72155f3c0454ecbe4f089975b1320d8b88 Mon Sep 17 00:00:00 2001
From: czt <czt18638530771@163.com>
Date: 星期六, 08 十一月 2025 17:15:08 +0800
Subject: [PATCH] 陕西2025版接口调整5-新增功能数据同步，包含4.0版本和6.1版本
---
src/main/java/com/fzzy/async/fzzy61/entity/Fz61PlanCheck.java | 142 ++
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1216Rep.java | 26
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1218.java | 112 ++
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1215Rep.java | 26
src/main/java/com/fzzy/async/fzzy40/entity/Fz40OilEmptyCheck.java | 143 ++
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1216.java | 123 ++
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1215.java | 105 +
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1218Rep.java | 27
src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerifyItem.java | 86 +
src/main/java/com/fzzy/async/fzzy61/entity/Fz61OilEmptyCheck.java | 143 ++
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1217Rep.java | 26
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1215.java | 107 +
src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotEmptyCheck.java | 171 +++
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1218.java | 111 ++
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1214Rep.java | 25
src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotEmptyCheck.java | 171 +++
src/main/java/com/fzzy/async/fzzy40/entity/Fz40PlanCheck.java | 142 ++
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1216Rep.java | 25
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1219.java | 108 +
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1219Rep.java | 25
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1215Rep.java | 25
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java | 33
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1218Rep.java | 25
src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java | 28
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1219Rep.java | 25
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1214.java | 113 ++
src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutStockCheck.java | 142 ++
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1217Rep.java | 25
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1217.java | 127 ++
src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerify.java | 85 +
src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerifyItem.java | 86 +
src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerify.java | 85 +
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1216.java | 124 ++
src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutStockCheck.java | 142 ++
src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1219.java | 109 +
src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1214Rep.java | 26
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1214.java | 112 ++
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1217.java | 126 ++
38 files changed, 3,279 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
index bdfbef9..017442f 100644
--- a/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
+++ b/src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
@@ -19,6 +19,8 @@
public class Fzzy40SyncService12 implements SyncService12 {
@Autowired
+ private Fzzy40Sync1109 fzzySync1109;
+ @Autowired
private Fzzy40Sync1201 fzzySync1201;
@Autowired
private Fzzy40Sync1202 fzzySync1202;
@@ -37,15 +39,25 @@
@Autowired
private Fzzy40Sync1209 fzzySync1209;
@Autowired
- private Fzzy40Sync1211 fzzySync1211;
- @Autowired
private Fzzy40Sync1210 fzzySync1210;
+ @Autowired
+ private Fzzy40Sync1211 fzzySync1211;
@Autowired
private Fzzy40Sync1212 fzzySync1212;
@Autowired
private Fzzy40Sync1213 fzzySync1213;
@Autowired
- private Fzzy40Sync1109 fzzySync1109;
+ private Fzzy40Sync1214 fzzySync1214;
+ @Autowired
+ private Fzzy40Sync1215 fzzySync1215;
+ @Autowired
+ private Fzzy40Sync1216 fzzySync1216;
+ @Autowired
+ private Fzzy40Sync1217 fzzySync1217;
+ @Autowired
+ private Fzzy40Sync1218 fzzySync1218;
+ @Autowired
+ private Fzzy40Sync1219 fzzySync1219;
@Autowired
private Fzzy40Sync2102 fzzySync2102;
@@ -108,6 +120,21 @@
//鍊掍粨鍊掑叆淇℃伅鍚屾
fzzySync2102.syncData(kqdm, deptId, start, end);
}
+ //闄曡タ鐪佸钩鍙�2025鐗�
+ if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SX_2025.getCode().equals(param.getPushProtocol())) {
+ //鍌ㄥ绮┖浠撻獙鏀惰〃
+ fzzySync1214.syncData(kqdm, deptId, start, end);
+ //鍌ㄥ娌圭┖缃愰獙鏀惰〃
+ fzzySync1215.syncData(kqdm, deptId, start, end);
+ //鍌ㄥ绮�掍粨楠屾敹琛�
+ fzzySync1216.syncData(kqdm, deptId, start, end);
+ //杞崲楠屾敹淇℃伅
+ fzzySync1217.syncData(kqdm, deptId, start, end);
+ //鍏ュ簱鎴愭湰鏍稿畾琛�
+ fzzySync1218.syncData(kqdm, deptId, start, end);
+ //鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ fzzySync1219.syncData(kqdm, deptId, start, end);
+ }
}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotEmptyCheck.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotEmptyCheck.java
new file mode 100644
index 0000000..8d0afa5
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotEmptyCheck.java
@@ -0,0 +1,171 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 绌轰粨楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:06
+ */
+@Data
+@Entity
+@Table(name = "D_DEPOT_EMPTY_CHECK")
+public class Fz40DepotEmptyCheck implements Serializable {
+
+ public static String SORT_PROP = "kcysdh";
+
+ @Id
+ @PropertyDef(label = "绌轰粨楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "kcysdh", length = 14)
+ private String kcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鎷熷瓨鍝佺浠ｇ爜")
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "绮绛夌骇浠ｇ爜")
+ @Column(name = "lsdjdm", length = 3)
+ private String lsdjdm;
+
+ @PropertyDef(label = "璁捐浠撳")
+ @Column(name = "sjcr", precision = 20, scale = 3)
+ private Double sjcr;
+
+ @PropertyDef(label = "瀹為檯鍌ㄧ伯鍝佺鏈�澶т粨瀹�")
+ @Column(name = "sjclzdcr", precision = 20, scale = 3)
+ private Double sjclzdcr;
+
+ @PropertyDef(label = "鎷熷偍绮暟閲�")
+ @Column(name = "jysj", precision = 20, scale = 3)
+ private Double jysj;
+
+ @PropertyDef(label = "鍌ㄥ瓨鏂瑰紡", description = "1-鍖呰 2-鏁ｈ 3-鍖呭洿鏁ｅ瓨")
+ @Column(name = "jydw", length = 1)
+ private String jydw;
+
+ @PropertyDef(label = "浠撴埧鍦板潽瀹屽ソ鎯呭喌")
+ @Column(name = "dpwhqk", length = 128)
+ private String dpwhqk;
+
+ @PropertyDef(label = "浠撴埧澧欎綋瀹屽ソ鎯呭喌")
+ @Column(name = "qtwhqk", length = 128)
+ private String qtwhqk;
+
+ @PropertyDef(label = "浠撴埧灞嬮潰瀹屽ソ鎯呭喌")
+ @Column(name = "wmwhqk", length = 128)
+ private String wmwhqk;
+
+ @PropertyDef(label = "浠撴埧闂ㄧ獥瀹屽ソ鎯呭喌")
+ @Column(name = "mcwhqk", length = 128)
+ private String mcwhqk;
+
+ @PropertyDef(label = "浠撴埧鏄惁鎿呰嚜鏀瑰彉浠撴埧缁撴瀯")
+ @Column(name = "sfszgd", length = 128)
+ private String sfszgd;
+
+ @PropertyDef(label = "闃查泙缃戝畬濂芥儏鍐�")
+ @Column(name = "fqwwhqk", length = 128)
+ private String fqwwhqk;
+
+ @PropertyDef(label = "闃茶櫕绾垮畬濂芥儏鍐�")
+ @Column(name = "fcxwhqk", length = 128)
+ private String fcxwhqk;
+
+ @PropertyDef(label = "闃查紶鏉垮畬濂芥儏鍐�")
+ @Column(name = "fsbwhqk", length = 128)
+ private String fsbwhqk;
+
+ @PropertyDef(label = "閫氶鎶�鏈墜娈�")
+ @Column(name = "tfjssd", length = 128)
+ private String tfjssd;
+
+ @PropertyDef(label = "閫氶绯荤粺鏄惁瀹屽ソ")
+ @Column(name = "tfxtsfwh", length = 128)
+ private String tfxtsfwh;
+
+ @PropertyDef(label = "鐔忚捀鎶�鏈墜娈�")
+ @Column(name = "xzjssd", length = 128)
+ private String xzjssd;
+
+ @PropertyDef(label = "绮儏妫�娴嬫墜娈�")
+ @Column(name = "lqjcsd", length = 128)
+ private String lqjcsd;
+
+ @PropertyDef(label = "绮儏妫�娴嬬郴缁熸槸鍚﹀畬濂�")
+ @Column(name = "lqjcxtsfwh", length = 128)
+ private String lqjcxtsfwh;
+
+ @PropertyDef(label = "浠撻棬妗ｇ伯璁炬柦鏄惁瀹屽ソ")
+ @Column(name = "cmdlsssfwh", length = 128)
+ private String cmdlsssfwh;
+
+ @PropertyDef(label = "鏄惁娓呮秷")
+ @Column(name = "sfqx", length = 128)
+ private String sfqx;
+
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @PropertyDef(label = "鏁存敼鎰忚")
+ @Column(name = "zgyj", length = 128)
+ private String zgyj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerify.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerify.java
new file mode 100644
index 0000000..7ba48d7
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerify.java
@@ -0,0 +1,85 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍏ュ簱鎴愭湰鏍稿畾
+ * @Author CZT
+ * @Date 2025/11/04 20:18
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_COST_VERIFY")
+public class Fz40InoutCostVerify implements Serializable {
+
+ public static String SORT_PROP = "rkhddh";
+
+ @Id
+ @PropertyDef(label = "鍏ュ簱鏍稿畾鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "rkhddh", length = 14)
+ private String rkhddh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鍌ㄧ伯鍝佺浠ｇ爜" )
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "鏍稿畾鍗曚环" )
+ @Column(name = "hddj", precision = 20, scale = 3)
+ private Double hddj;
+
+ @PropertyDef(label = "鏍稿畾鏁伴噺" )
+ @Column(name = "hdsl", precision = 20, scale = 3)
+ private Double hdsl;
+
+ @PropertyDef(label = "绮鎬ц川" )
+ @Column(name = "lsxz", length = 3)
+ private String lsxz;
+
+ @PropertyDef(label = "濉姤鍗曚綅" )
+ @Column(name = "tbdw", length = 512)
+ private String tbdw;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "濉姤鏃堕棿")
+ @Column(name = "tbsj")
+ private Date tbsj;
+
+ @PropertyDef(label = "鍗曚綅璐熻矗浜�")
+ @Column(name = "dwfzr", length = 512)
+ private String dwfzr;
+
+ @PropertyDef(label = "濉姤浜�")
+ @Column(name = "tbr", length = 512)
+ private String tbr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "REMARKS_", length = 512)
+ private String remarks;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerifyItem.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerifyItem.java
new file mode 100644
index 0000000..93abf85
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutCostVerifyItem.java
@@ -0,0 +1,86 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍏ュ簱鎴愭湰鏍稿畾鏄庣粏
+ * @Author CZT
+ * @Date 2025/11/04 20:20
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_COST_VERIFY_ITEM")
+public class Fz40InoutCostVerifyItem implements Serializable {
+
+ public static String SORT_PROP = "rkhddh";
+
+ @Id
+ @PropertyDef(label = "鍏ュ簱鏍稿畾鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "rkhddh", length = 14)
+ private String rkhddh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鍌ㄧ伯鍝佺浠ｇ爜" )
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "璐锋閲戦" )
+ @Column(name = "dkje", precision = 20, scale = 3)
+ private Double dkje;
+
+ @PropertyDef(label = "鏀惰幏骞村害" )
+ @Column(name = "shnd", length = 4)
+ private String shnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @PropertyDef(label = "濉姤鍗曚綅" )
+ @Column(name = "tbdw", length = 512)
+ private String tbdw;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "濉姤鏃堕棿")
+ @Column(name = "tbsj")
+ private Date tbsj;
+
+ @PropertyDef(label = "鍗曚綅璐熻矗浜�")
+ @Column(name = "dwfzr", length = 512)
+ private String dwfzr;
+
+ @PropertyDef(label = "濉姤浜�")
+ @Column(name = "tbr", length = 512)
+ private String tbr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "REMARKS_", length = 512)
+ private String remarks;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutStockCheck.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutStockCheck.java
new file mode 100644
index 0000000..e85d945
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40InoutStockCheck.java
@@ -0,0 +1,142 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍊掍粨楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:13
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_STOCK_CHECK")
+public class Fz40InoutStockCheck implements Serializable {
+
+ public static String SORT_PROP = "dcysdh";
+
+ @Id
+ @PropertyDef(label = "鍊掍粨楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "dcysdh", length = 14)
+ private String dcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 40)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅" )
+ @Column(name = "ccdw", length = 256)
+ private String ccdw;
+
+ @PropertyDef(label = "璁″垝鏂囧彿")
+ @Column(name = "jhwh", length = 14)
+ private String jhwh;
+
+ @PropertyDef(label = "鍊掑嚭璐т綅" )
+ @Column(name = "dchwbm", length = 30)
+ private String dchwbm;
+
+ @PropertyDef(label = "鍊掑嚭绮鍝佺浠ｇ爜" )
+ @Column(name = "dclspzdm", length = 7)
+ private String dclspzdm;
+
+ @PropertyDef(label = "鍊掑嚭绮绛夌骇浠ｇ爜" )
+ @Column(name = "dclsdjdm", length = 2)
+ private String dclsdjdm;
+
+ @PropertyDef(label = "鍊掑嚭绮鐢熶骇骞村害" )
+ @Column(name = "dclsscnd", length = 4)
+ private String dclsscnd;
+
+ @PropertyDef(label = "鍊掑嚭绮鏁伴噺(鍚�)" )
+ @Column(name = "dclssl", precision = 20, scale = 3)
+ private Double dclssl;
+
+ @PropertyDef(label = "鍊掑叆璐т綅" )
+ @Column(name = "drhwdm", length = 30)
+ private String drhwbm;
+
+ @PropertyDef(label = "鍊掑叆绮鍝佺浠ｇ爜" )
+ @Column(name = "drlspzdm", length = 7)
+ private String drlspzdm;
+
+ @PropertyDef(label = "鍊掑叆绮绛夌骇浠ｇ爜" )
+ @Column(name = "drlsdjdm", length = 2)
+ private String drlsdjdm;
+
+ @PropertyDef(label = "鍊掑叆绮鏁伴噺(鍚�)" )
+ @Column(name = "drlssl", precision = 20, scale = 3)
+ private Double drlssl;
+
+ @PropertyDef(label = "鍊掑叆绮搴撳瓨鎴愭湰(鍏�/鍚�)" )
+ @Column(name = "drlskccb", precision = 20, scale = 3)
+ private Double drlskccb;
+
+ @PropertyDef(label = "鍊掑叆绮鐢熶骇骞村害" )
+ @Column(name = "drlsscnd", length = 4)
+ private String drlsscnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍊掍粨瀹屾垚鏃堕棿")
+ @Column(name = "wcsj")
+ private Date wcsj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @JSONField(format = "yyyy-MM-dd")
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40OilEmptyCheck.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40OilEmptyCheck.java
new file mode 100644
index 0000000..e5a1b79
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40OilEmptyCheck.java
@@ -0,0 +1,143 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 绌虹綈楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:09
+ */
+@Data
+@Entity
+@Table(name = "D_OIL_EMPTY_CHECK")
+public class Fz40OilEmptyCheck implements Serializable {
+
+ public static String SORT_PROP = "kgysdh";
+
+ @Id
+ @PropertyDef(label = "绌虹綈楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "kgysdh", length = 14)
+ private String kgysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鎷熷瓨鍝佺浠ｇ爜")
+ @Column(name = "ncpzdm", length = 7)
+ private String ncpzdm;
+
+ @PropertyDef(label = "璁捐鐏屽")
+ @Column(name = "sjgr", precision = 20, scale = 3)
+ private Double sjgr;
+
+ @PropertyDef(label = "瀹為檯鍌ㄦ补鍝佺鏈�澶х綈瀹�")
+ @Column(name = "sjcyzdgr", precision = 20, scale = 3)
+ private Double sjcyzdgr;
+
+ @PropertyDef(label = "鎷熷偍娌规暟閲�")
+ @Column(name = "jysj", precision = 20, scale = 3)
+ private Double jysj;
+
+ @PropertyDef(label = "鏄惁鎿呰嚜鏀瑰彉娌圭綈缁撴瀯")
+ @Column(name = "sfszgdygjg", length = 128)
+ private String sfszgdygjg;
+
+ @PropertyDef(label = "娌圭綈鏈夋棤娓楁紡閿堣殌")
+ @Column(name = "ygywslxs", length = 128)
+ private String ygywslxs;
+
+ @PropertyDef(label = "缃愬熀鏈夋棤寮�瑁傘�佷笅娌夌幇璞�")
+ @Column(name = "gjywklxcxx", length = 128)
+ private String gjywklxcxx;
+
+ @PropertyDef(label = "娌圭綈鍦板潽鏄惁瀹屽叏纭寲")
+ @Column(name = "ygdpsfwqyh", length = 128)
+ private String ygdpsfwqyh;
+
+ @PropertyDef(label = "鎶ゆ补鍫ゆ槸鍚﹀瓨鍦ㄥ紑瑁傜己鍙ｇ瓑鎯呭喌")
+ @Column(name = "hydsfzc", length = 128)
+ private String hydsfzc;
+
+ @PropertyDef(label = "缃愬尯鍐呮帓姘存湁鏃犻榾闂ㄦ帶鍒�")
+ @Column(name = "gtfmsfzc", length = 128)
+ private String gtfmsfzc;
+
+ @PropertyDef(label = "缃愬唴鏄惁娓呮磥")
+ @Column(name = "gnsfqj", length = 128)
+ private String gnsfqj;
+
+ @PropertyDef(label = "鐖鏄惁瀹夊叏")
+ @Column(name = "ptsfaq", length = 128)
+ private String ptsfaq;
+
+ @PropertyDef(label = "鐏岄《瀹夊叏鎶ゆ爮鏄惁瀹屽ソ")
+ @Column(name = "gdaqhlsfwh", length = 128)
+ private String gdaqhlsfwh;
+
+ @PropertyDef(label = "娌圭綈鍖烘槸鍚﹀浜庝綆娲肩偣")
+ @Column(name = "gqsfcydwd", length = 128)
+ private String gqsfcydwd;
+
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @PropertyDef(label = "鏁存敼鎰忚")
+ @Column(name = "zgyj", length = 128)
+ private String zgyj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/entity/Fz40PlanCheck.java b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40PlanCheck.java
new file mode 100644
index 0000000..191fa0d
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/entity/Fz40PlanCheck.java
@@ -0,0 +1,142 @@
+package com.fzzy.async.fzzy40.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:16
+ */
+@Data
+@Entity
+@Table(name = "D_PLAN_CHECK")
+public class Fz40PlanCheck implements Serializable {
+
+ public static String SORT_PROP = "dcysdh";
+
+ @Id
+ @PropertyDef(label = "杞崲楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "dcysdh", length = 14)
+ private String dcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 40)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅" )
+ @Column(name = "ccdw", length = 256)
+ private String ccdw;
+
+ @PropertyDef(label = "璁″垝鏂囧彿")
+ @Column(name = "jhwh", length = 14)
+ private String jhwh;
+
+ @PropertyDef(label = "璁″垝瀹夋帓璐т綅缂栫爜" )
+ @Column(name = "dchwbm", length = 30)
+ private String dchwbm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鍝佺浠ｇ爜" )
+ @Column(name = "dclspzdm", length = 7)
+ private String dclspzdm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮绛夌骇浠ｇ爜" )
+ @Column(name = "dclsdjdm", length = 2)
+ private String dclsdjdm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鐢熶骇骞村害" )
+ @Column(name = "dclsscnd", length = 4)
+ private String dclsscnd;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鏁伴噺(鍚�)" )
+ @Column(name = "dclssl", precision = 20, scale = 3)
+ private Double dclssl;
+
+ @PropertyDef(label = "瀹為檯鎵ц璐т綅缂栫爜" )
+ @Column(name = "drhwbm", length = 30)
+ private String drhwbm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鍝佺浠ｇ爜" )
+ @Column(name = "drlspzdm", length = 7)
+ private String drlspzdm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮绛夌骇浠ｇ爜" )
+ @Column(name = "drlsdjdm", length = 2)
+ private String drlsdjdm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鏁伴噺(鍚�)" )
+ @Column(name = "drlssl", precision = 20, scale = 3)
+ private Double drlssl;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮搴撳瓨鎴愭湰(鍏�/鍚�)" )
+ @Column(name = "drlskccb", precision = 20, scale = 3)
+ private Double drlskccb;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鐢熶骇骞村害" )
+ @Column(name = "drlsscnd", length = 4)
+ private String drlsscnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "瀹為檯鎵ц鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "瀹為檯鎵ц瀹屾垚鏃堕棿")
+ @Column(name = "wcsj")
+ private Date wcsj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @JSONField(format = "yyyy-MM-dd")
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1214.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1214.java
new file mode 100644
index 0000000..cf1a730
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1214.java
@@ -0,0 +1,112 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1214;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1214Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40DepotEmptyCheck;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1214Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌轰粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:26
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1214 {
+
+ @Autowired
+ private Fzzy40Sync1214Rep fzzy40Sync1214Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1214Rep api1214Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1214鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40DepotEmptyCheck> list = fzzy40Sync1214Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒颁俊鎭�------------------");
+ return;
+ }
+
+ Api1214 apiData;
+ Api1105 api1105;
+ List<Api1214> api1214List;
+ for (Fz40DepotEmptyCheck depotEmptyCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(depotEmptyCheck.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1214();
+ BeanUtils.copyProperties(depotEmptyCheck, apiData);
+
+ apiData.setBizId(depotEmptyCheck.getKcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, depotEmptyCheck.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+ //绮绛夌骇
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, depotEmptyCheck.getLsdjdm());
+ apiData.setLsdjdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1214List = api1214Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1214List || api1214List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1214List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1214Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1215.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1215.java
new file mode 100644
index 0000000..4d9d6d7
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1215.java
@@ -0,0 +1,107 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1215;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1215Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40OilEmptyCheck;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1215Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌虹綈楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:30
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1215 {
+
+ @Autowired
+ private Fzzy40Sync1215Rep fzzy40Sync1215Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1215Rep api1215Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1215鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40OilEmptyCheck> list = fzzy40Sync1215Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒颁俊鎭�------------------");
+ return;
+ }
+
+ Api1215 apiData;
+ Api1105 api1105;
+ List<Api1215> api1215List;
+ for (Fz40OilEmptyCheck oilEmptyCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(oilEmptyCheck.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1215();
+ BeanUtils.copyProperties(oilEmptyCheck, apiData);
+ apiData.setBizId(oilEmptyCheck.getKgysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, oilEmptyCheck.getNcpzdm().substring(0, 3));
+ apiData.setNcpzdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1215List = api1215Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1215List || api1215List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1215List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1215Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1216.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1216.java
new file mode 100644
index 0000000..49554e7
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1216.java
@@ -0,0 +1,123 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1216;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1216Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40InoutStockCheck;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1216Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍊掍粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:32
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1216 {
+
+ @Autowired
+ private Fzzy40Sync1216Rep fzzy40Sync1216Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1216Rep api1216Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1216鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40InoutStockCheck> list = fzzy40Sync1216Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1216 apiData;
+ Api1105 api1105In;
+ Api1105 api1105Out;
+ List<Api1216> api1216List;
+ for (Fz40InoutStockCheck inoutStockCheck : list) {
+ //鑾峰彇璐т綅淇℃伅
+ api1105Out = commonService.getApi1105Cache(inoutStockCheck.getDchwbm());
+ if (null == api1105Out) {
+ continue;
+ }
+ //鑾峰彇璐т綅淇℃伅
+ api1105In = commonService.getApi1105Cache(inoutStockCheck.getDrhwbm());
+ if (null == api1105In) {
+ continue;
+ }
+
+ apiData = new Api1216();
+ BeanUtils.copyProperties(inoutStockCheck, apiData);
+ apiData.setBizId(inoutStockCheck.getDcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setDchwbm(api1105Out.getHwdm());
+ apiData.setDrhwbm(api1105In.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutStockCheck.getDclspzdm().substring(0, 3));
+ apiData.setDclspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, inoutStockCheck.getDclsdjdm());
+ apiData.setDclsdjdm(mappingCode);
+
+ //绮鍝佺
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutStockCheck.getDrlspzdm().substring(0, 3));
+ apiData.setDrlspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, inoutStockCheck.getDrlsdjdm());
+ apiData.setDrlsdjdm(mappingCode);
+
+ api1216List = api1216Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1216List || api1216List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1216List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1216Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1217.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1217.java
new file mode 100644
index 0000000..5d8c25d
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1217.java
@@ -0,0 +1,126 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1217;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1217Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40PlanCheck;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1217Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/08 10:43
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1217 {
+
+ @Autowired
+ private Fzzy40Sync1217Rep fzzy40Sync1217Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1217Rep api1217Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1217鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40PlanCheck> list = fzzy40Sync1217Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1217 apiData;
+ Api1105 api1105In;
+ Api1105 api1105Out;
+ List<Api1217> api1217List;
+ for (Fz40PlanCheck planCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105Out = commonService.getApi1105Cache(planCheck.getDchwbm());
+ if (null == api1105Out) {
+ continue;
+ }
+ //鑾峰彇璐т綅淇℃伅
+ api1105In = commonService.getApi1105Cache(planCheck.getDrhwbm());
+ if (null == api1105In) {
+ continue;
+ }
+
+ apiData = new Api1217();
+ BeanUtils.copyProperties(planCheck, apiData);
+ apiData.setBizId(planCheck.getDcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setDchwbm(api1105Out.getHwdm());
+ apiData.setDrhwbm(api1105In.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, planCheck.getDclspzdm().substring(0, 3));
+ apiData.setDclspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, planCheck.getDclsdjdm());
+ apiData.setDclsdjdm(mappingCode);
+
+ //绮鍝佺
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, planCheck.getDrlspzdm().substring(0, 3));
+ apiData.setDrlspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, planCheck.getDrlsdjdm());
+ apiData.setDrlsdjdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1217List = api1217Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1217List || api1217List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1217List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1217Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1218.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1218.java
new file mode 100644
index 0000000..b1af762
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1218.java
@@ -0,0 +1,111 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1218;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1218Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40InoutCostVerify;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1218Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:15
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1218 {
+
+ @Autowired
+ private Fzzy40Sync1218Rep fzzy40Sync1218Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1218Rep api1218Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1218鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40InoutCostVerify> list = fzzy40Sync1218Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1218 apiData;
+ Api1105 api1105;
+ List<Api1218> api1218List;
+ for (Fz40InoutCostVerify inoutCostVerify : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(inoutCostVerify.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1218();
+ BeanUtils.copyProperties(inoutCostVerify, apiData);
+ apiData.setBizId(inoutCostVerify.getRkhddh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutCostVerify.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, inoutCostVerify.getLsxz());
+ apiData.setLsxz(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1218List = api1218Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1218List || api1218List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1218List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1218Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1219.java b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1219.java
new file mode 100644
index 0000000..1ca2a9d
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1219.java
@@ -0,0 +1,108 @@
+package com.fzzy.async.fzzy40.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1219;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1219Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy40.entity.Fz40InoutCostVerifyItem;
+import com.fzzy.async.fzzy40.repository.Fzzy40Sync1219Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:17
+ */
+@Slf4j
+@Component
+public class Fzzy40Sync1219 {
+
+ @Autowired
+ private Fzzy40Sync1219Rep fzzy40Sync1219Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1219Rep api1219Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1219鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz40InoutCostVerifyItem> list = fzzy40Sync1219Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1219 apiData;
+ Api1105 api1105;
+ List<Api1219> api1219List;
+ for (Fz40InoutCostVerifyItem inoutCostVerifyItem : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(inoutCostVerifyItem.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1219();
+ BeanUtils.copyProperties(inoutCostVerifyItem, apiData);
+ apiData.setBizId(inoutCostVerifyItem.getRkhddh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutCostVerifyItem.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+
+ apiData.setZhgxsj(new Date());
+
+ api1219List = api1219Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1219List || api1219List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1219List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1219Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1214Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1214Rep.java
new file mode 100644
index 0000000..e2dac08
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1214Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+
+import com.fzzy.async.fzzy40.entity.Fz40DepotEmptyCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌轰粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:06
+ */
+public interface Fzzy40Sync1214Rep extends JpaRepository<Fz40DepotEmptyCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栫┖浠撻獙鏀惰〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz40DepotEmptyCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40DepotEmptyCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1215Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1215Rep.java
new file mode 100644
index 0000000..6f2617e
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1215Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+
+import com.fzzy.async.fzzy40.entity.Fz40OilEmptyCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌虹綈楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:10
+ */
+public interface Fzzy40Sync1215Rep extends JpaRepository<Fz40OilEmptyCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栫┖缃愰獙鏀惰〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz40OilEmptyCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40OilEmptyCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1216Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1216Rep.java
new file mode 100644
index 0000000..ce5a67b
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1216Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+
+import com.fzzy.async.fzzy40.entity.Fz40InoutStockCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍊掍粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:12
+ */
+public interface Fzzy40Sync1216Rep extends JpaRepository<Fz40InoutStockCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧�掍粨楠屾敹琛ㄤ俊鎭�
+ *
+ * @return
+ */
+ @Query("from Fz40InoutStockCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40InoutStockCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1217Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1217Rep.java
new file mode 100644
index 0000000..c4867bc
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1217Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+
+import com.fzzy.async.fzzy40.entity.Fz40PlanCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/08 10:13
+ */
+public interface Fzzy40Sync1217Rep extends JpaRepository<Fz40PlanCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栬疆鎹㈤獙鏀朵俊鎭�
+ *
+ * @return
+ */
+ @Query("from Fz40PlanCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40PlanCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1218Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1218Rep.java
new file mode 100644
index 0000000..e6d407c
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1218Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+;
+import com.fzzy.async.fzzy40.entity.Fz40InoutCostVerify;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:15
+ */
+public interface Fzzy40Sync1218Rep extends JpaRepository<Fz40InoutCostVerify, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧叆搴撴垚鏈牳瀹氳〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz40InoutCostVerify where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40InoutCostVerify> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1219Rep.java b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1219Rep.java
new file mode 100644
index 0000000..1bc8f8b
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1219Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy40.repository;
+
+import com.fzzy.async.fzzy40.entity.Fz40InoutCostVerifyItem;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:17
+ */
+public interface Fzzy40Sync1219Rep extends JpaRepository<Fz40InoutCostVerifyItem, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧叆搴撴垚鏈牳瀹氭槑缁嗚〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz40InoutCostVerifyItem where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz40InoutCostVerifyItem> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java
index 37885d1..6b161dd 100644
--- a/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java
+++ b/src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService12.java
@@ -48,6 +48,18 @@
@Autowired
private Fzzy61Sync1109 fzzySync1109;
@Autowired
+ private Fzzy61Sync1214 fzzySync1214;
+ @Autowired
+ private Fzzy61Sync1215 fzzySync1215;
+ @Autowired
+ private Fzzy61Sync1216 fzzySync1216;
+ @Autowired
+ private Fzzy61Sync1217 fzzySync1217;
+ @Autowired
+ private Fzzy61Sync1218 fzzySync1218;
+ @Autowired
+ private Fzzy61Sync1219 fzzySync1219;
+ @Autowired
private Fzzy61Sync2102 fzzySync2102;
@Override
@@ -110,6 +122,22 @@
fzzySync2102.syncData(kqdm, deptId, start, end);
}
+ //闄曡タ鐪佸钩鍙�2025鐗�
+ if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SX_2025.getCode().equals(param.getPushProtocol())) {
+ //鍌ㄥ绮┖浠撻獙鏀惰〃
+ fzzySync1214.syncData(kqdm, deptId, start, end);
+ //鍌ㄥ娌圭┖缃愰獙鏀惰〃
+ fzzySync1215.syncData(kqdm, deptId, start, end);
+ //鍌ㄥ绮�掍粨楠屾敹琛�
+ fzzySync1216.syncData(kqdm, deptId, start, end);
+ //杞崲楠屾敹淇℃伅
+ fzzySync1217.syncData(kqdm, deptId, start, end);
+ //鍏ュ簱鎴愭湰鏍稿畾琛�
+ fzzySync1218.syncData(kqdm, deptId, start, end);
+ //鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ fzzySync1219.syncData(kqdm, deptId, start, end);
+ }
+
}
}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotEmptyCheck.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotEmptyCheck.java
new file mode 100644
index 0000000..47b48c2
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotEmptyCheck.java
@@ -0,0 +1,171 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 绌轰粨楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:06
+ */
+@Data
+@Entity
+@Table(name = "D_DEPOT_EMPTY_CHECK")
+public class Fz61DepotEmptyCheck implements Serializable {
+
+ public static String SORT_PROP = "kcysdh";
+
+ @Id
+ @PropertyDef(label = "绌轰粨楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "kcysdh", length = 14)
+ private String kcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鎷熷瓨鍝佺浠ｇ爜")
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "绮绛夌骇浠ｇ爜")
+ @Column(name = "lsdjdm", length = 3)
+ private String lsdjdm;
+
+ @PropertyDef(label = "璁捐浠撳")
+ @Column(name = "sjcr", precision = 20, scale = 3)
+ private Double sjcr;
+
+ @PropertyDef(label = "瀹為檯鍌ㄧ伯鍝佺鏈�澶т粨瀹�")
+ @Column(name = "sjclzdcr", precision = 20, scale = 3)
+ private Double sjclzdcr;
+
+ @PropertyDef(label = "鎷熷偍绮暟閲�")
+ @Column(name = "jysj", precision = 20, scale = 3)
+ private Double jysj;
+
+ @PropertyDef(label = "鍌ㄥ瓨鏂瑰紡", description = "1-鍖呰 2-鏁ｈ 3-鍖呭洿鏁ｅ瓨")
+ @Column(name = "jydw", length = 1)
+ private String jydw;
+
+ @PropertyDef(label = "浠撴埧鍦板潽瀹屽ソ鎯呭喌")
+ @Column(name = "dpwhqk", length = 128)
+ private String dpwhqk;
+
+ @PropertyDef(label = "浠撴埧澧欎綋瀹屽ソ鎯呭喌")
+ @Column(name = "qtwhqk", length = 128)
+ private String qtwhqk;
+
+ @PropertyDef(label = "浠撴埧灞嬮潰瀹屽ソ鎯呭喌")
+ @Column(name = "wmwhqk", length = 128)
+ private String wmwhqk;
+
+ @PropertyDef(label = "浠撴埧闂ㄧ獥瀹屽ソ鎯呭喌")
+ @Column(name = "mcwhqk", length = 128)
+ private String mcwhqk;
+
+ @PropertyDef(label = "浠撴埧鏄惁鎿呰嚜鏀瑰彉浠撴埧缁撴瀯")
+ @Column(name = "sfszgd", length = 128)
+ private String sfszgd;
+
+ @PropertyDef(label = "闃查泙缃戝畬濂芥儏鍐�")
+ @Column(name = "fqwwhqk", length = 128)
+ private String fqwwhqk;
+
+ @PropertyDef(label = "闃茶櫕绾垮畬濂芥儏鍐�")
+ @Column(name = "fcxwhqk", length = 128)
+ private String fcxwhqk;
+
+ @PropertyDef(label = "闃查紶鏉垮畬濂芥儏鍐�")
+ @Column(name = "fsbwhqk", length = 128)
+ private String fsbwhqk;
+
+ @PropertyDef(label = "閫氶鎶�鏈墜娈�")
+ @Column(name = "tfjssd", length = 128)
+ private String tfjssd;
+
+ @PropertyDef(label = "閫氶绯荤粺鏄惁瀹屽ソ")
+ @Column(name = "tfxtsfwh", length = 128)
+ private String tfxtsfwh;
+
+ @PropertyDef(label = "鐔忚捀鎶�鏈墜娈�")
+ @Column(name = "xzjssd", length = 128)
+ private String xzjssd;
+
+ @PropertyDef(label = "绮儏妫�娴嬫墜娈�")
+ @Column(name = "lqjcsd", length = 128)
+ private String lqjcsd;
+
+ @PropertyDef(label = "绮儏妫�娴嬬郴缁熸槸鍚﹀畬濂�")
+ @Column(name = "lqjcxtsfwh", length = 128)
+ private String lqjcxtsfwh;
+
+ @PropertyDef(label = "浠撻棬妗ｇ伯璁炬柦鏄惁瀹屽ソ")
+ @Column(name = "cmdlsssfwh", length = 128)
+ private String cmdlsssfwh;
+
+ @PropertyDef(label = "鏄惁娓呮秷")
+ @Column(name = "sfqx", length = 128)
+ private String sfqx;
+
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @PropertyDef(label = "鏁存敼鎰忚")
+ @Column(name = "zgyj", length = 128)
+ private String zgyj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerify.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerify.java
new file mode 100644
index 0000000..e808ff8
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerify.java
@@ -0,0 +1,85 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍏ュ簱鎴愭湰鏍稿畾
+ * @Author CZT
+ * @Date 2025/11/04 20:18
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_COST_VERIFY")
+public class Fz61InoutCostVerify implements Serializable {
+
+ public static String SORT_PROP = "rkhddh";
+
+ @Id
+ @PropertyDef(label = "鍏ュ簱鏍稿畾鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "rkhddh", length = 14)
+ private String rkhddh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鍌ㄧ伯鍝佺浠ｇ爜" )
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "鏍稿畾鍗曚环" )
+ @Column(name = "hddj", precision = 20, scale = 3)
+ private Double hddj;
+
+ @PropertyDef(label = "鏍稿畾鏁伴噺" )
+ @Column(name = "hdsl", precision = 20, scale = 3)
+ private Double hdsl;
+
+ @PropertyDef(label = "绮鎬ц川" )
+ @Column(name = "lsxz", length = 3)
+ private String lsxz;
+
+ @PropertyDef(label = "濉姤鍗曚綅" )
+ @Column(name = "tbdw", length = 512)
+ private String tbdw;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "濉姤鏃堕棿")
+ @Column(name = "tbsj")
+ private Date tbsj;
+
+ @PropertyDef(label = "鍗曚綅璐熻矗浜�")
+ @Column(name = "dwfzr", length = 512)
+ private String dwfzr;
+
+ @PropertyDef(label = "濉姤浜�")
+ @Column(name = "tbr", length = 512)
+ private String tbr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "REMARKS_", length = 512)
+ private String remarks;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerifyItem.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerifyItem.java
new file mode 100644
index 0000000..0e13710
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutCostVerifyItem.java
@@ -0,0 +1,86 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍏ュ簱鎴愭湰鏍稿畾鏄庣粏
+ * @Author CZT
+ * @Date 2025/11/04 20:20
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_COST_VERIFY_ITEM")
+public class Fz61InoutCostVerifyItem implements Serializable {
+
+ public static String SORT_PROP = "rkhddh";
+
+ @Id
+ @PropertyDef(label = "鍏ュ簱鏍稿畾鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "rkhddh", length = 14)
+ private String rkhddh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鍌ㄧ伯鍝佺浠ｇ爜" )
+ @Column(name = "lspzdm", length = 7)
+ private String lspzdm;
+
+ @PropertyDef(label = "璐锋閲戦" )
+ @Column(name = "dkje", precision = 20, scale = 3)
+ private Double dkje;
+
+ @PropertyDef(label = "鏀惰幏骞村害" )
+ @Column(name = "shnd", length = 4)
+ private String shnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @PropertyDef(label = "濉姤鍗曚綅" )
+ @Column(name = "tbdw", length = 512)
+ private String tbdw;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "濉姤鏃堕棿")
+ @Column(name = "tbsj")
+ private Date tbsj;
+
+ @PropertyDef(label = "鍗曚綅璐熻矗浜�")
+ @Column(name = "dwfzr", length = 512)
+ private String dwfzr;
+
+ @PropertyDef(label = "濉姤浜�")
+ @Column(name = "tbr", length = 512)
+ private String tbr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "REMARKS_", length = 512)
+ private String remarks;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutStockCheck.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutStockCheck.java
new file mode 100644
index 0000000..48ef4ff
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutStockCheck.java
@@ -0,0 +1,142 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 鍊掍粨楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:13
+ */
+@Data
+@Entity
+@Table(name = "D_INOUT_STOCK_CHECK")
+public class Fz61InoutStockCheck implements Serializable {
+
+ public static String SORT_PROP = "dcysdh";
+
+ @Id
+ @PropertyDef(label = "鍊掍粨楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "dcysdh", length = 14)
+ private String dcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 40)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅" )
+ @Column(name = "ccdw", length = 256)
+ private String ccdw;
+
+ @PropertyDef(label = "璁″垝鏂囧彿")
+ @Column(name = "jhwh", length = 14)
+ private String jhwh;
+
+ @PropertyDef(label = "鍊掑嚭璐т綅" )
+ @Column(name = "dchwbm", length = 30)
+ private String dchwbm;
+
+ @PropertyDef(label = "鍊掑嚭绮鍝佺浠ｇ爜" )
+ @Column(name = "dclspzdm", length = 7)
+ private String dclspzdm;
+
+ @PropertyDef(label = "鍊掑嚭绮绛夌骇浠ｇ爜" )
+ @Column(name = "dclsdjdm", length = 2)
+ private String dclsdjdm;
+
+ @PropertyDef(label = "鍊掑嚭绮鐢熶骇骞村害" )
+ @Column(name = "dclsscnd", length = 4)
+ private String dclsscnd;
+
+ @PropertyDef(label = "鍊掑嚭绮鏁伴噺(鍚�)" )
+ @Column(name = "dclssl", precision = 20, scale = 3)
+ private Double dclssl;
+
+ @PropertyDef(label = "鍊掑叆璐т綅" )
+ @Column(name = "drhwdm", length = 30)
+ private String drhwbm;
+
+ @PropertyDef(label = "鍊掑叆绮鍝佺浠ｇ爜" )
+ @Column(name = "drlspzdm", length = 7)
+ private String drlspzdm;
+
+ @PropertyDef(label = "鍊掑叆绮绛夌骇浠ｇ爜" )
+ @Column(name = "drlsdjdm", length = 2)
+ private String drlsdjdm;
+
+ @PropertyDef(label = "鍊掑叆绮鏁伴噺(鍚�)" )
+ @Column(name = "drlssl", precision = 20, scale = 3)
+ private Double drlssl;
+
+ @PropertyDef(label = "鍊掑叆绮搴撳瓨鎴愭湰(鍏�/鍚�)" )
+ @Column(name = "drlskccb", precision = 20, scale = 3)
+ private Double drlskccb;
+
+ @PropertyDef(label = "鍊掑叆绮鐢熶骇骞村害" )
+ @Column(name = "drlsscnd", length = 4)
+ private String drlsscnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鍊掍粨瀹屾垚鏃堕棿")
+ @Column(name = "wcsj")
+ private Date wcsj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @JSONField(format = "yyyy-MM-dd")
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61OilEmptyCheck.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61OilEmptyCheck.java
new file mode 100644
index 0000000..3efa801
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61OilEmptyCheck.java
@@ -0,0 +1,143 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 绌虹綈楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:09
+ */
+@Data
+@Entity
+@Table(name = "D_OIL_EMPTY_CHECK")
+public class Fz61OilEmptyCheck implements Serializable {
+
+ public static String SORT_PROP = "kgysdh";
+
+ @Id
+ @PropertyDef(label = "绌虹綈楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "kgysdh", length = 14)
+ private String kgysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 20)
+ @PropertyDef(label = "搴撳尯浠ｇ爜")
+ private String deptId;
+
+ @Column(name = "DEPOT_ID_", length = 30)
+ @PropertyDef(label = "浠撳簱缂栫爜", description = "鐩墠涓婃捣浣跨敤")
+ private String depotId;
+
+ @PropertyDef(label = "鎷熷瓨鍝佺浠ｇ爜")
+ @Column(name = "ncpzdm", length = 7)
+ private String ncpzdm;
+
+ @PropertyDef(label = "璁捐鐏屽")
+ @Column(name = "sjgr", precision = 20, scale = 3)
+ private Double sjgr;
+
+ @PropertyDef(label = "瀹為檯鍌ㄦ补鍝佺鏈�澶х綈瀹�")
+ @Column(name = "sjcyzdgr", precision = 20, scale = 3)
+ private Double sjcyzdgr;
+
+ @PropertyDef(label = "鎷熷偍娌规暟閲�")
+ @Column(name = "jysj", precision = 20, scale = 3)
+ private Double jysj;
+
+ @PropertyDef(label = "鏄惁鎿呰嚜鏀瑰彉娌圭綈缁撴瀯")
+ @Column(name = "sfszgdygjg", length = 128)
+ private String sfszgdygjg;
+
+ @PropertyDef(label = "娌圭綈鏈夋棤娓楁紡閿堣殌")
+ @Column(name = "ygywslxs", length = 128)
+ private String ygywslxs;
+
+ @PropertyDef(label = "缃愬熀鏈夋棤寮�瑁傘�佷笅娌夌幇璞�")
+ @Column(name = "gjywklxcxx", length = 128)
+ private String gjywklxcxx;
+
+ @PropertyDef(label = "娌圭綈鍦板潽鏄惁瀹屽叏纭寲")
+ @Column(name = "ygdpsfwqyh", length = 128)
+ private String ygdpsfwqyh;
+
+ @PropertyDef(label = "鎶ゆ补鍫ゆ槸鍚﹀瓨鍦ㄥ紑瑁傜己鍙ｇ瓑鎯呭喌")
+ @Column(name = "hydsfzc", length = 128)
+ private String hydsfzc;
+
+ @PropertyDef(label = "缃愬尯鍐呮帓姘存湁鏃犻榾闂ㄦ帶鍒�")
+ @Column(name = "gtfmsfzc", length = 128)
+ private String gtfmsfzc;
+
+ @PropertyDef(label = "缃愬唴鏄惁娓呮磥")
+ @Column(name = "gnsfqj", length = 128)
+ private String gnsfqj;
+
+ @PropertyDef(label = "鐖鏄惁瀹夊叏")
+ @Column(name = "ptsfaq", length = 128)
+ private String ptsfaq;
+
+ @PropertyDef(label = "鐏岄《瀹夊叏鎶ゆ爮鏄惁瀹屽ソ")
+ @Column(name = "gdaqhlsfwh", length = 128)
+ private String gdaqhlsfwh;
+
+ @PropertyDef(label = "娌圭綈鍖烘槸鍚﹀浜庝綆娲肩偣")
+ @Column(name = "gqsfcydwd", length = 128)
+ private String gqsfcydwd;
+
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @PropertyDef(label = "鏁存敼鎰忚")
+ @Column(name = "zgyj", length = 128)
+ private String zgyj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/entity/Fz61PlanCheck.java b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61PlanCheck.java
new file mode 100644
index 0000000..f218a8a
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/entity/Fz61PlanCheck.java
@@ -0,0 +1,142 @@
+package com.fzzy.async.fzzy61.entity;
+
+import com.alibaba.fastjson.annotation.JSONField;
+import com.bstek.dorado.annotation.PropertyDef;
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Description 杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/04 20:16
+ */
+@Data
+@Entity
+@Table(name = "D_PLAN_CHECK")
+public class Fz61PlanCheck implements Serializable {
+
+ public static String SORT_PROP = "dcysdh";
+
+ @Id
+ @PropertyDef(label = "杞崲楠屾敹鍗曞彿", description = "楠屾敹鐢宠鏃ユ湡yyyyMMdd + 4浣嶉『搴忓彿")
+ @Column(name = "dcysdh", length = 14)
+ private String dcysdh;
+
+ @Column(name = "COMPANY_ID_", length = 10)
+ @PropertyDef(label = "缁勭粐缂栫爜")
+ private String companyId;
+
+ @Column(name = "DEPT_ID_", length = 40)
+ @PropertyDef(label = "鎵�灞炲垎搴�")
+ private String deptId;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅" )
+ @Column(name = "ccdw", length = 256)
+ private String ccdw;
+
+ @PropertyDef(label = "璁″垝鏂囧彿")
+ @Column(name = "jhwh", length = 14)
+ private String jhwh;
+
+ @PropertyDef(label = "璁″垝瀹夋帓璐т綅缂栫爜" )
+ @Column(name = "dchwbm", length = 30)
+ private String dchwbm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鍝佺浠ｇ爜" )
+ @Column(name = "dclspzdm", length = 7)
+ private String dclspzdm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮绛夌骇浠ｇ爜" )
+ @Column(name = "dclsdjdm", length = 2)
+ private String dclsdjdm;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鐢熶骇骞村害" )
+ @Column(name = "dclsscnd", length = 4)
+ private String dclsscnd;
+
+ @PropertyDef(label = "璁″垝瀹夋帓绮鏁伴噺(鍚�)" )
+ @Column(name = "dclssl", precision = 20, scale = 3)
+ private Double dclssl;
+
+ @PropertyDef(label = "瀹為檯鎵ц璐т綅缂栫爜" )
+ @Column(name = "drhwbm", length = 30)
+ private String drhwbm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鍝佺浠ｇ爜" )
+ @Column(name = "drlspzdm", length = 7)
+ private String drlspzdm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮绛夌骇浠ｇ爜" )
+ @Column(name = "drlsdjdm", length = 2)
+ private String drlsdjdm;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鏁伴噺(鍚�)" )
+ @Column(name = "drlssl", precision = 20, scale = 3)
+ private Double drlssl;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮搴撳瓨鎴愭湰(鍏�/鍚�)" )
+ @Column(name = "drlskccb", precision = 20, scale = 3)
+ private Double drlskccb;
+
+ @PropertyDef(label = "瀹為檯鎵ц绮鐢熶骇骞村害" )
+ @Column(name = "drlsscnd", length = 4)
+ private String drlsscnd;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "瀹為檯鎵ц鍏ュ簱鏃堕棿")
+ @Column(name = "rksj")
+ private Date rksj;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "瀹為檯鎵ц瀹屾垚鏃堕棿")
+ @Column(name = "wcsj")
+ private Date wcsj;
+
+ @PropertyDef(label = "楠屾敹缁撹")
+ @Column(name = "ysjl", length = 128)
+ private String ysjl;
+
+ @JSONField(format = "yyyy-MM-dd")
+ @PropertyDef(label = "楠屾敹鏃堕棿")
+ @Column(name = "yssj")
+ private Date yssj;
+
+ @PropertyDef(label = "鎵垮偍鍗曚綅璐熻矗浜�")
+ @Column(name = "ccdwfzr", length = 128)
+ private String ccdwfzr;
+
+ @PropertyDef(label = "楠屾敹浜�")
+ @Column(name = "ysr", length = 128)
+ private String ysr;
+
+ @PropertyDef(label = "澶囨敞")
+ @Column(name = "bz", length = 200)
+ private String bz;
+
+ @JSONField(format = "yyyy-MM-dd HH:mm:ss")
+ @PropertyDef(label = "鏈�鍚庢洿鏂版椂闂�")
+ @Column(name = "zhgxsj")
+ private Date zhgxsj;
+
+ /**
+ * --------闄勪欢--------
+ **/
+ @Column(name = "FILE_ID_", length = 30)
+ @PropertyDef(label = "鐓х墖id")
+ private String fileId;
+
+ @Column(name = "FILE_NAME_", length = 50)
+ @PropertyDef(label = "鐓х墖鍚嶇О")
+ private String fileName;
+
+ @Column(name = "FILE_TIME_")
+ @PropertyDef(label = "鐓х墖涓婁紶鏃堕棿")
+ private Date fileTime;
+
+ //鍏ㄨ矾寰�
+ @Transient
+ private String imgFilePath;
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1214.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1214.java
new file mode 100644
index 0000000..0819fd7
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1214.java
@@ -0,0 +1,113 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1214;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1214Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61DepotEmptyCheck;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1214Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌轰粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:26
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1214 {
+
+ @Autowired
+ private Fzzy61Sync1214Rep fzzy61Sync1214Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1214Rep api1214Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1214鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61DepotEmptyCheck> list = fzzy61Sync1214Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒颁俊鎭�------------------");
+ return;
+ }
+
+ Api1214 apiData;
+ Api1105 api1105;
+ List<Api1214> api1214List;
+ for (Fz61DepotEmptyCheck depotEmptyCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(depotEmptyCheck.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1214();
+ BeanUtils.copyProperties(depotEmptyCheck, apiData);
+
+ apiData.setBizId(depotEmptyCheck.getKcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, depotEmptyCheck.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+ //绮绛夌骇
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, depotEmptyCheck.getLsdjdm());
+ apiData.setLsdjdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1214List = api1214Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1214List || api1214List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1214List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1214Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1215.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1215.java
new file mode 100644
index 0000000..3ebdffc
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1215.java
@@ -0,0 +1,105 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1215;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1215Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61OilEmptyCheck;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1215Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌虹綈楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:30
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1215 {
+
+ @Autowired
+ private Fzzy61Sync1215Rep fzzy61Sync1215Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1215Rep api1215Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1215鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61OilEmptyCheck> list = fzzy61Sync1215Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒颁俊鎭�------------------");
+ return;
+ }
+ Api1215 apiData;
+ Api1105 api1105;
+ List<Api1215> api1215List;
+ for (Fz61OilEmptyCheck oilEmptyCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(oilEmptyCheck.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+ apiData = new Api1215();
+ BeanUtils.copyProperties(oilEmptyCheck, apiData);
+ apiData.setBizId(oilEmptyCheck.getKgysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, oilEmptyCheck.getNcpzdm().substring(0, 3));
+ apiData.setNcpzdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1215List = api1215Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1215List || api1215List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1215List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1215Rep.save(apiData);
+ }
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1216.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1216.java
new file mode 100644
index 0000000..6f0b3fb
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1216.java
@@ -0,0 +1,124 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1216;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1216Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61InoutStockCheck;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1216Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍊掍粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:32
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1216 {
+
+ @Autowired
+ private Fzzy61Sync1216Rep fzzy61Sync1216Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1216Rep api1216Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1216鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61InoutStockCheck> list = fzzy61Sync1216Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1216 apiData;
+ Api1105 api1105In;
+ Api1105 api1105Out;
+ List<Api1216> api1216List;
+ for (Fz61InoutStockCheck inoutStockCheck : list) {
+ //鑾峰彇璐т綅淇℃伅
+ api1105Out = commonService.getApi1105Cache(inoutStockCheck.getDchwbm());
+ if (null == api1105Out) {
+ continue;
+ }
+ //鑾峰彇璐т綅淇℃伅
+ api1105In = commonService.getApi1105Cache(inoutStockCheck.getDrhwbm());
+ if (null == api1105In) {
+ continue;
+ }
+
+ apiData = new Api1216();
+ BeanUtils.copyProperties(inoutStockCheck, apiData);
+ apiData.setBizId(inoutStockCheck.getDcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setDchwbm(api1105Out.getHwdm());
+ apiData.setDrhwbm(api1105In.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutStockCheck.getDclspzdm().substring(0, 3));
+ apiData.setDclspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, inoutStockCheck.getDclsdjdm());
+ apiData.setDclsdjdm(mappingCode);
+
+ //绮鍝佺
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutStockCheck.getDrlspzdm().substring(0, 3));
+ apiData.setDrlspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, inoutStockCheck.getDrlsdjdm());
+ apiData.setDrlsdjdm(mappingCode);
+
+ api1216List = api1216Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1216List || api1216List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1216List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1216Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1217.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1217.java
new file mode 100644
index 0000000..dad2f68
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1217.java
@@ -0,0 +1,127 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1217;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1217Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61PlanCheck;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1217Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/08 10:43
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1217 {
+
+ @Autowired
+ private Fzzy61Sync1217Rep fzzy61Sync1217Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1217Rep api1217Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1217鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61PlanCheck> list = fzzy61Sync1217Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1217 apiData;
+ Api1105 api1105In;
+ Api1105 api1105Out;
+ List<Api1217> api1217List;
+ for (Fz61PlanCheck planCheck : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105Out = commonService.getApi1105Cache(planCheck.getDchwbm());
+ if (null == api1105Out) {
+ continue;
+ }
+ //鑾峰彇璐т綅淇℃伅
+ api1105In = commonService.getApi1105Cache(planCheck.getDrhwbm());
+ if (null == api1105In) {
+ continue;
+ }
+
+ apiData = new Api1217();
+ BeanUtils.copyProperties(planCheck, apiData);
+ apiData.setBizId(planCheck.getDcysdh());
+ apiData.setKqdm(kqdm);
+ apiData.setDchwbm(api1105Out.getHwdm());
+ apiData.setDrhwbm(api1105In.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, planCheck.getDclspzdm().substring(0, 3));
+ apiData.setDclspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, planCheck.getDclsdjdm());
+ apiData.setDclsdjdm(mappingCode);
+
+ //绮鍝佺
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, planCheck.getDrlspzdm().substring(0, 3));
+ apiData.setDrlspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, planCheck.getDrlsdjdm());
+ apiData.setDrlsdjdm(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1217List = api1217Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1217List || api1217List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1217List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1217Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1218.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1218.java
new file mode 100644
index 0000000..1fc5881
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1218.java
@@ -0,0 +1,112 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1218;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1218Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61InoutCostVerify;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1218Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:15
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1218 {
+
+ @Autowired
+ private Fzzy61Sync1218Rep fzzy61Sync1218Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1218Rep api1218Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1218鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61InoutCostVerify> list = fzzy61Sync1218Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1218 apiData;
+ Api1105 api1105;
+ List<Api1218> api1218List;
+ for (Fz61InoutCostVerify inoutCostVerify : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(inoutCostVerify.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1218();
+ BeanUtils.copyProperties(inoutCostVerify, apiData);
+ apiData.setBizId(inoutCostVerify.getRkhddh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutCostVerify.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+ //绮鎬ц川
+ mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, inoutCostVerify.getLsxz());
+ apiData.setLsxz(mappingCode);
+
+ apiData.setZhgxsj(new Date());
+
+ api1218List = api1218Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1218List || api1218List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1218List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1218Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1219.java b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1219.java
new file mode 100644
index 0000000..47c94c1
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1219.java
@@ -0,0 +1,109 @@
+package com.fzzy.async.fzzy61.impl;
+
+import com.fzzy.api.Constant;
+import com.fzzy.api.entity.Api1105;
+import com.fzzy.api.entity.Api1219;
+import com.fzzy.api.entity.ApiLog;
+import com.fzzy.api.service.ApiCommonService;
+import com.fzzy.api.service.ApiTriggerService;
+import com.fzzy.api.utils.ContextUtil;
+import com.fzzy.api.view.repository.Api1219Rep;
+import com.fzzy.api.view.repository.ApiLogRep;
+import com.fzzy.async.fzzy61.entity.Fz61InoutCostVerifyItem;
+import com.fzzy.async.fzzy61.repository.Fzzy61Sync1219Rep;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:17
+ */
+@Slf4j
+@Component
+public class Fzzy61Sync1219 {
+
+ @Autowired
+ private Fzzy61Sync1219Rep fzzy61Sync1219Rep;
+ @Autowired
+ private ApiTriggerService apiTriggerService;
+ @Autowired
+ private Api1219Rep api1219Rep;
+ @Autowired
+ private ApiCommonService commonService;
+ @Autowired
+ private ApiLogRep apiLogRep;
+
+ /**
+ * 鍚屾灏佷粨纭淇℃伅
+ *
+ * @param deptId
+ * @param start
+ * @param end
+ */
+ public void syncData(String kqdm, String deptId, Date start, Date end) {
+
+ log.info("-------------1219鎺ュ彛鏁版嵁寮�濮嬪悓姝�------------------");
+
+ //鍚屾鏁版嵁锛屽彧璁板綍澶辫触鐨勪俊鎭�
+ ApiLog apiLog = new ApiLog();
+ apiLog.setType(ApiLog.TYPE_SYNC);
+ apiLog.setKqdm(deptId);
+ apiLog.setUploadTime(new Date());
+ apiLog.setInteId(Constant.API_CODE_1208);
+ apiLog.setStatus(99);
+ apiLog.setId(ContextUtil.getUUID());
+ try {
+ List<Fz61InoutCostVerifyItem> list = fzzy61Sync1219Rep.listData(deptId, start, end);
+ if (null == list || list.isEmpty()) {
+ log.info("-------------娌℃湁鑾峰彇鍒板皝浠撶‘璁や俊鎭�------------------");
+ return;
+ }
+
+ Api1219 apiData;
+ Api1105 api1105;
+ List<Api1219> api1219List;
+ for (Fz61InoutCostVerifyItem inoutCostVerifyItem : list) {
+
+ //鑾峰彇璐т綅淇℃伅
+ api1105 = commonService.getApi1105Cache(inoutCostVerifyItem.getDepotId());
+ if (null == api1105) {
+ continue;
+ }
+
+ apiData = new Api1219();
+ BeanUtils.copyProperties(inoutCostVerifyItem, apiData);
+ apiData.setBizId(inoutCostVerifyItem.getRkhddh());
+ apiData.setKqdm(kqdm);
+ apiData.setHwdm(api1105.getHwdm());
+
+ //绮鍝佺
+ String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, inoutCostVerifyItem.getLspzdm().substring(0, 3));
+ apiData.setLspzdm(mappingCode);
+
+
+ apiData.setZhgxsj(new Date());
+
+ api1219List = api1219Rep.getDataByBizId(apiData.getBizId());
+ if (null == api1219List || api1219List.isEmpty()) {
+ apiData.setCzbz(Constant.CZBZ_I);
+ } else {
+ apiData.setCzbz(api1219List.get(0).getCzbz());
+ }
+
+ //淇濆瓨鏁版嵁
+ api1219Rep.save(apiData);
+ }
+
+ } catch (Exception e) {
+ log.error("---鍚屾澶辫触----{}", e);
+ apiLog.setResult("鍚屾澶辫触锛�" + e.getMessage());
+ apiLogRep.save(apiLog);
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1214Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1214Rep.java
new file mode 100644
index 0000000..83e04a8
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1214Rep.java
@@ -0,0 +1,26 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61DepotEmptyCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌轰粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:06
+ */
+public interface Fzzy61Sync1214Rep extends JpaRepository<Fz61DepotEmptyCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栫┖浠撻獙鏀惰〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz61DepotEmptyCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61DepotEmptyCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1215Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1215Rep.java
new file mode 100644
index 0000000..ead4d84
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1215Rep.java
@@ -0,0 +1,26 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61OilEmptyCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-绌虹綈楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:10
+ */
+public interface Fzzy61Sync1215Rep extends JpaRepository<Fz61OilEmptyCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栫┖缃愰獙鏀惰〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz61OilEmptyCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61OilEmptyCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1216Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1216Rep.java
new file mode 100644
index 0000000..b44f4f3
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1216Rep.java
@@ -0,0 +1,26 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61InoutStockCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍊掍粨楠屾敹琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:12
+ */
+public interface Fzzy61Sync1216Rep extends JpaRepository<Fz61InoutStockCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧�掍粨楠屾敹琛ㄤ俊鎭�
+ *
+ * @return
+ */
+ @Query("from Fz61InoutStockCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61InoutStockCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1217Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1217Rep.java
new file mode 100644
index 0000000..27c1e04
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1217Rep.java
@@ -0,0 +1,26 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61PlanCheck;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-杞崲楠屾敹
+ * @Author CZT
+ * @Date 2025/11/08 10:13
+ */
+public interface Fzzy61Sync1217Rep extends JpaRepository<Fz61PlanCheck, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栬疆鎹㈤獙鏀朵俊鎭�
+ *
+ * @return
+ */
+ @Query("from Fz61PlanCheck where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61PlanCheck> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1218Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1218Rep.java
new file mode 100644
index 0000000..4d36aff
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1218Rep.java
@@ -0,0 +1,27 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61InoutCostVerify;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:15
+ */
+public interface Fzzy61Sync1218Rep extends JpaRepository<Fz61InoutCostVerify, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧叆搴撴垚鏈牳瀹氳〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz61InoutCostVerify where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61InoutCostVerify> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
diff --git a/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1219Rep.java b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1219Rep.java
new file mode 100644
index 0000000..048bd79
--- /dev/null
+++ b/src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1219Rep.java
@@ -0,0 +1,25 @@
+package com.fzzy.async.fzzy61.repository;
+
+import com.fzzy.async.fzzy61.entity.Fz61InoutCostVerifyItem;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @Description 绮璐攢-鍏ュ簱鎴愭湰鏍稿畾鏄庣粏琛�
+ * @Author CZT
+ * @Date 2025/11/08 10:17
+ */
+public interface Fzzy61Sync1219Rep extends JpaRepository<Fz61InoutCostVerifyItem, String> {
+
+ /**
+ * 鏍规嵁搴撳尯缂栫爜鍙婃椂闂磋幏鍙栧叆搴撴垚鏈牳瀹氭槑缁嗚〃淇℃伅
+ *
+ * @return
+ */
+ @Query("from Fz61InoutCostVerifyItem where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
+ List<Fz61InoutCostVerifyItem> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
+
+}
--
Gitblit v1.9.3