陕西2025版接口调整5-新增功能数据同步，包含4.0版本和6.1版本

czt

2025-11-08 edb0ae72155f3c0454ecbe4f089975b1320d8b88

陕西2025版接口调整5-新增功能数据同步，包含4.0版本和6.1版本

 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);
        }

    }


 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;
}

 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;

}

 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;

}

 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;
}

 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;
}

 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;
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);

}

 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);

}

 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);

}

 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);

}

 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);

}

 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);

}

 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);
        }

    }

}

 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;
}

 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;

}

 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;

}

 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;
}

 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;
}

 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;
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);
        }
    }
}

 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);

}

 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);

}

 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);

}

 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);

}

 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);

}

 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);

}