61版本13,14同步

YYC

2025-09-24 715af00851145d97afa322c211dcc44f78238ef1

61版本13,14同步

 src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService13.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,93 @@
package com.fzzy.async.fzzy61;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService13;
import com.fzzy.async.fzzy61.impl.*;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @Desc: ç²®é£Ÿç®¡ç†ä¿¡æ¯åŒæ­¥
 * @author: czt
 * @update-time: 2023/08/14
 */
@Component
public class Fzzy61SyncService13 implements SyncService13 {

    @Autowired
    private Fzzy61Sync1302 fzzySync1302;
    @Autowired
    private Fzzy61Sync1303 fzzySync1303;
    @Autowired
    private Fzzy61Sync1304 fzzySync1304;
    @Autowired
    private Fzzy61Sync1305 fzzySync1305;
    @Autowired
    private Fzzy61Sync1306 fzzySync1306;
    @Autowired
    private Fzzy61Sync1307 fzzySync1307;
    @Autowired
    private Fzzy61Sync1310 fzzySync1310;
    @Autowired
    private Fzzy61Sync1023 fzzySync1023;
    @Autowired
    private Fzzy61Sync1311 fzzySync1311;
    @Autowired
    private Fzzy61Sync9201 fzzySync9201;
    @Autowired
    private Fzzy61Sync2103 fzzy61Sync2103;

    @Override
    public String getProtocol() {
        return SyncProtocol.FZZY_V61_GB.getCode();
    }

    @Override
    public void syncData(ApiParam param) {


        /*-----各省独有接口信息同步-----*/
        if (StringUtils.isNotEmpty(param.getPushProtocol()) && (PushProtocol.SB_GD_2022.getCode().equals(param.getPushProtocol())||PushProtocol.SB_GD_2023.getCode().equals(param.getPushProtocol()))) {
            //广东省平台2022版，需要同步熏蒸备案信息
            //熏蒸备案数据同步
            fzzySync1023.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
            fzzySync9201.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
        }
        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
            //上海市平台2023版，需要同步粮情设备配置信息

            //同步粮情设备配置信息
            fzzy61Sync2103.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
            //视频监控信息同步
            fzzySync1311.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
        }

        /*-----公共接口-----*/

        //温湿度检测数据同步
        fzzySync1302.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //虫害检测同步
        fzzySync1303.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //气体检测同步
        fzzySync1304.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //质检同步
        fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //通风作业信息同步
        fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //熏蒸作业信息同步
        fzzySync1306.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //仓内视频图像抓拍同步
        fzzySync1307.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

    }

}

 src/main/java/com/fzzy/async/fzzy61/Fzzy61SyncService14.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,62 @@
package com.fzzy.async.fzzy61;

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService14;
import com.fzzy.async.fzzy61.impl.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * FZZY-粮库系统4.0对接
 */
@Component
public class Fzzy61SyncService14 implements SyncService14 {


    @Autowired
    private Fzzy61Sync1403 fzzy61Sync1403;
    @Autowired
    private Fzzy61Sync1404 fzzy61Sync1404;
    @Autowired
    private Fzzy61Sync1504 fzzy61Sync1504;
    @Autowired
    private Fzzy61Sync1505 fzzy61Sync1505;
    @Autowired
    private Fzzy61Sync1506 fzzy61Sync1506;
    @Autowired
    private Fzzy61Sync1507 fzzy61Sync1507;
    @Autowired
    private Fzzy61Sync1508 fzzy61Sync1508;
    @Autowired
    private Fzzy61Sync1509 fzzy61Sync1509;
    @Autowired
    private Fzzy61Sync1510 fzzy61Sync1510;


    @Override
    public String getProtocol() {
        return SyncProtocol.FZZY_V61_GB.getCode();
    }

    @Override
    public void syncData(ApiParam param) {

        //轮换计划同步
        fzzy61Sync1403.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //轮换计划明细同步
        fzzy61Sync1404.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //同步财务信息
//        fzzy61Sync1504.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1505.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1506.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1507.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1508.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1509.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        fzzy61Sync1510.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

    }

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1504.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,106 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * è´¦å¥—信息
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1504")
public class Fz61Api1504 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", precision = 23)
    private String nacctid;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套名称")
    @Column(name = "cncctname", length = 256)
    private String cncctname;

    @PropertyDef(label = "本位币")
    @Column(name = "ccurrency", length = 3)
    private String ccurrency;

    @PropertyDef(label = "会计主管")
    @Column(name = "cacctchief", length = 20)
    private String cacctchief;

    @JSONField(format = "yyyyMM")
    @PropertyDef(label = "启用期间", description = "yyyyMM")
    @Column(name = "cperiodstart", length = 10)
    private Date cperiodstart;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "启用日期")
    @Column(name = "cyearbmd", length = 10)
    private Date cyearbmd;

    @PropertyDef(label = "期间数", description = "默认12")
    @Column(name = "nacctperiodnum")
    private Integer nacctperiodnum;

    @PropertyDef(label = "会计制度代码", description = "11:企业会计准则制度(粮食2013版)(默认代码值)")
    @Column(name = "caccclasscode", length = 2)
    private String caccclasscode;

    @PropertyDef(label = "科目级次", description = "4-8:默认最小值为4")
    @Column(name = "naccgrade")
    private Integer naccgrade;

    @PropertyDef(label = "科目编码规则", description = "4222XXXX:默认前四级级长规则为4222")
    @Column(name = "cacccodestr", length = 40)
    private String cacccodestr;

    @PropertyDef(label = "单位名称")
    @Column(name = "ccropname", length = 256)
    private String ccropname;

    @PropertyDef(label = "单位代码")
    @Column(name = "corgcode", length = 18)
    private String corgcode;

    @PropertyDef(label = "每月结账日")
    @Column(name = "nendday")
    private Integer nendday;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1505.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,127 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * ç§‘目信息
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1505")
public class Fz61Api1505 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", precision = 110)
    @JSONField(serialize = false)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;


    @PropertyDef(label = "年度")
    @Column(name = "cyear")
    private Integer cyear;

    @PropertyDef(label = "科目编码")
    @Column(name = "ccode", length = 80)
    private String ccode;

    @PropertyDef(label = "科目名称")
    @Column(name = "cname", length = 256)
    private String cname;

    @PropertyDef(label = "科目全称")
    @Column(name = "callname", length = 65536)
    private String callname;

    /**
     * 1:资产类
     * 2:负债类
     * 3:共同类
     * 4:所有者权益类
     * 5:成本费用类
     * 6:损益类
     */
    @PropertyDef(label = "科目类别")
    @Column(name = "nclass", length = 9)
    private String nclass;
    /**
     * (-1)-贷方；1-借方
     */
    @PropertyDef(label = "余额方向")
    @Column(name = "cdc")
    private Integer cdc;

    @PropertyDef(label = "末级科目")
    @Column(name = "bl")
    private Integer bl;

    @PropertyDef(label = "科目级次")
    @Column(name = "ngrade")
    private Integer ngrade;

    @PropertyDef(label = "数量科目")
    @Column(name = "bq")
    private Integer bq;

    @PropertyDef(label = "数量单位")
    @Column(name = "cqunit")
    private Integer cqunit;

    @PropertyDef(label = "现金类科目")
    @Column(name = "bcash")
    private Integer bcash;

    @PropertyDef(label = "银行类科目")
    @Column(name = "bbank")
    private Integer bbank;

    @PropertyDef(label = "现金流量类科目")
    @Column(name = "bxjll")
    private Integer bxjll;

    @PropertyDef(label = "冻结")
    @Column(name = "bf")
    private Integer bf;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1506.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,127 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * ç§‘目余额表
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1506")
public class Fz61Api1506 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", precision = 110)
    @JSONField(serialize = false)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;

    @PropertyDef(label = "期间")
    @Column(name = "cyear")
    private Integer cyear;

    @PropertyDef(label = "年度")
    @Column(name = "nno")
    private Integer nno;

    @PropertyDef(label = "科目编码")
    @Column(name = "ccode", length = 80)
    private String ccode;

    @PropertyDef(label = "期初本位币余额")
    @Column(name = "bm", precision = 20, scale = 4)
    private Double bm;

    @PropertyDef(label = "期末本位币余额")
    @Column(name = "em", precision = 20, scale = 4)
    private Double em;

    @PropertyDef(label = "期初数量")
    @Column(name = "bqty", precision = 20, scale = 4)
    private Double bqty;

    @PropertyDef(label = "期末数量")
    @Column(name = "eqty", precision = 20, scale = 4)
    private Double eqty;
    /**
     * 1:借方
     * -1:贷方
     */
    @PropertyDef(label = "余额方向")
    @Column(name = "cdc")
    private Integer cdc;

    @PropertyDef(label = "借方本位币发生额")
    @Column(name = "dm", precision = 20, scale = 4)
    private Double dm;

    @PropertyDef(label = "贷方本位币发生额")
    @Column(name = "cm", precision = 20, scale = 4)
    private Double cm;

    @PropertyDef(label = "借方发生数量")
    @Column(name = "dq", precision = 20, scale = 4)
    private Double dq;

    @PropertyDef(label = "贷方发生数量")
    @Column(name = "cq", precision = 20, scale = 4)
    private Double cq;

    @PropertyDef(label = "期初外币余额")
    @Column(name = "bfm", precision = 20, scale = 4)
    private Double bfm;

    @PropertyDef(label = "期末外币余额")
    @Column(name = "efm", precision = 20, scale = 4)
    private Double efm;

    @PropertyDef(label = "借方外币发生额")
    @Column(name = "dfm", precision = 20, scale = 4)
    private Double dfm;

    @PropertyDef(label = "贷方外币发生额")
    @Column(name = "cfm", precision = 20, scale = 4)
    private Double cfm;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1507.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,155 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * ä¼šè®¡å‡­è¯ä¿¡æ¯
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1507")
public class Fz61Api1507 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", length = 40)
    @JSONField(serialize = false)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;

    @PropertyDef(label = "凭证类型")
    @Column(name = "cvkind", length = 9)
    private String cvkind;

    @PropertyDef(label = "期间")
    @Column(name = "cmon")
    private Integer cmon;

    @PropertyDef(label = "年度")
    @Column(name = "cyear")
    private Integer cyear;

    @PropertyDef(label = "凭证号")
    @Column(name = "nvno")
    private Integer nvno;

    @PropertyDef(label = "分录序号")
    @Column(name = "nno")
    private Integer nno;

    @PropertyDef(label = "凭证分类")
    @Column(name = "btmp")
    private Integer btmp;

    @PropertyDef(label = "摘要")
    @Column(name = "digest", length = 512)
    private String digest;

    @PropertyDef(label = "科目编码")
    @Column(name = "ccode", length = 80)
    private String ccode;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "凭证日期")
    @Column(name = "ccsmalldatetime", length = 10)
    private Date ccsmalldatetime;

    @PropertyDef(label = "制单人")
    @Column(name = "cmaker", length = 32)
    private String cmaker;
    /**
     * 1:借方
     * -1:贷方
     */
    @PropertyDef(label = "方向")
    @Column(name = "cdc")
    private Integer cdc;

    @PropertyDef(label = "审核人")
    @Column(name = "ccker", length = 32)
    private String ccker;

    @PropertyDef(label = "记账人")
    @Column(name = "cpter", length = 32)
    private String cpter;
    /**
     * 0:否
     * 1:是
     */
    @PropertyDef(label = "记账标志")
    @Column(name = "bpt")
    private Integer bpt;

    @PropertyDef(label = "附件张数")
    @Column(name = "nanum")
    private Integer nanum;

    @PropertyDef(label = "金额")
    @Column(name = "nm", precision = 20, scale = 4)
    private Double nm;

    @PropertyDef(label = "数量")
    @Column(name = "nqty", precision = 20, scale = 4)
    private Double nqty;

    @PropertyDef(label = "单价")
    @Column(name = "nprice", precision = 20, scale = 4)
    private Double nprice;

    @PropertyDef(label = "出纳")
    @Column(name = "ccashier", length = 32)
    private String ccashier;

    @PropertyDef(label = "汇率")
    @Column(name = "rate", precision = 20, scale = 4)
    private Double rate;

    @PropertyDef(label = "外币金额")
    @Column(name = "nfm", precision = 20, scale = 4)
    private Double nfm;

    @PropertyDef(label = "计量单位", description = "计量单位汉字")
    @Column(name = "meterunitid", length = 32)
    private String meterunitid;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1508.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,103 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * çŽ°é‡‘流量分配信息
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1508")
public class Fz61Api1508 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", length = 40)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;

    @PropertyDef(label = "凭证类型")
    @Column(name = "cvkind", length = 10)
    private String cvkind;

    @PropertyDef(label = "期间")
    @Column(name = "cmon")
    private Integer cmon;

    @PropertyDef(label = "年度")
    @Column(name = "cyear")
    private Integer cyear;

    @PropertyDef(label = "凭证号")
    @Column(name = "nvno")
    private Integer nvno;

    @PropertyDef(label = "科目编码")
    @Column(name = "ccode", length = 80)
    private String ccode;

    @PropertyDef(label = "对方科目编码")
    @Column(name = "cdfcode", length = 80)
    private String cdfcode;

    @PropertyDef(label = "现金流量项目代码")
    @Column(name = "ccashcode", length = 80)
    private String ccashcode;

    @PropertyDef(label = "分录序号")
    @Column(name = "nrowno")
    private Integer nrowno;

    @PropertyDef(label = "金额")
    @Column(name = "nm", precision = 20, scale = 4)
    private Double nm;

    /**
     * 1:流入
     * -1:流出
     */
    @PropertyDef(label = "方向")
    @Column(name = "cdc")
    private Integer cdc;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1509.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,195 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * å›ºå®šèµ„产卡片信息
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1509")
public class Fz61Api1509 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", precision = 18)
    @JSONField(serialize = false)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;

    @PropertyDef(label = "固定资产编码")
    @Column(name = "fixassetcode", length = 20)
    private String fixassetcode;

    @PropertyDef(label = "固定资产自编码")
    @Column(name = "origfixassetcode", length = 20)
    private String origfixassetcode;

    @PropertyDef(label = "资产类别编码")
    @Column(name = "groupcode", length = 20)
    private String groupcode;

    @PropertyDef(label = "固定资产名称")
    @Column(name = "fixassetname", length = 80)
    private String fixassetname;

    @PropertyDef(label = "计量单位名称")
    @Column(name = "unitname", length = 20)
    private String unitname;

    @PropertyDef(label = "原值")
    @Column(name = "valueorg", length = 20, scale = 4)
    private Double valueorg;

    @PropertyDef(label = "当前原值")
    @Column(name = "dresentvalueorg", length = 20, scale = 4)
    private Double dresentvalueorg;
    /**
     * 1:不提折旧法
     * 2:平均年限法
     * 3:动态平均年限法
     * 4:工作量法
     * 5:年数总和法
     * 6:双倍余额递减法
     */
    @PropertyDef(label = "折旧方法")
    @Column(name = "deprmethodid")
    private Integer deprmethodid;

    /**
     * 1:投资
     * 2:自建
     * 3:è´­ä¹°
     * 4:融资租赁
     * 5:经营租入
     * 6:无偿调入
     * 7:捐赠
     * 8:换入
     */
    @PropertyDef(label = "固定资产来源")
    @Column(name = "sourceid")
    private Integer sourceid;

    @PropertyDef(label = "型号")
    @Column(name = "model", length = 40)
    private String model;

    @PropertyDef(label = "规格")
    @Column(name = "specs", length = 40)
    private String specs;

    @PropertyDef(label = "制造商")
    @Column(name = "manufacturer", length = 60)
    private String manufacturer;

    @PropertyDef(label = "产地")
    @Column(name = "makingplace", length = 40)
    private String makingplace;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "进单位日期")
    @Column(name = "enterday", length = 10)
    private Date enterday;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "开始使用日期")
    @Column(name = "beginuseday", length = 10)
    private Date beginuseday;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "建卡日期")
    @Column(name = "makinday", length = 10)
    private Date makinday;

    @PropertyDef(label = "管理人")
    @Column(name = "keeper", length = 20)
    private String keeper;

    @PropertyDef(label = "建卡人")
    @Column(name = "maker", length = 20)
    private String maker;

    @PropertyDef(label = "预计使用期间数")
    @Column(name = "usingperiods")
    private Integer usingperiods;

    @PropertyDef(label = "预计净残值")
    @Column(name = "expecremain", precision = 20, scale = 4)
    private Double expecremain;

    @PropertyDef(label = "固定资产对应科目编码")
    @Column(name = "assetacctcode", length = 20)
    private String assetacctcode;

    @PropertyDef(label = "累计折旧对应科目编码")
    @Column(name = "depracctcode", length = 20)
    private String depracctcode;

    @PropertyDef(label = "累计折旧")
    @Column(name = "accumulatedepr", precision = 20, scale = 4)
    private Double accumulatedepr;
    /**
     * 0:否
     * 1:是
     */
    @PropertyDef(label = "是否报废清理")
    @Column(name = "abadoned", length = 1)
    private String abadoned;

    /**
     * 1:在使用
     * 2:未使用
     * 3:停用
     * 4:出售
     * 5:报损
     * 6:盘亏
     */
    @PropertyDef(label = "当前使用状态名称")
    @Column(name = "presentstatus", length = 20)
    private String presentstatus;

    @PropertyDef(label = "备注")
    @Column(name = "notes", length = 512)
    private String notes;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Api1510.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,136 @@
package com.fzzy.async.fzzy61.entity;

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2024-12-19 14:23
 **/

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;

/**
 * èµ„产折旧信息
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "API_1510")
public class Fz61Api1510 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = 1L;

    /**
     * é€šè¿‡æŽ¥å£èŽ·å–的单位账套后，在局端自动产生账套号
     */
    @Id
    @Column(name = "ID_", precision = 18)
    @JSONField(serialize = false)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "账套号")
    @Column(name = "nacctid", length = 23)
    private String nacctid;

    @PropertyDef(label = "固定资产编码")
    @Column(name = "fixassetcode", length = 20)
    private String fixassetcode;

    @PropertyDef(label = "期间")
    @Column(name = "period")
    private Integer period;

    @PropertyDef(label = "年度")
    @Column(name = "acctyear")
    private Integer acctyear;

    @PropertyDef(label = "期初原值")
    @Column(name = "bvalueorg", precision = 20, scale = 4)
    private Double bvalueorg;

    @PropertyDef(label = "累计折旧")
    @Column(name = "baccumdepr", precision = 20, scale = 4)
    private Double baccumdepr;

    @PropertyDef(label = "本期计提折旧")
    @Column(name = "deprammount", precision = 20, scale = 4)
    private Double deprammount;

    @PropertyDef(label = "本年累计计提折旧")
    @Column(name = "yaccumdepr", precision = 20, scale = 4)
    private Double yaccumdepr;

    @PropertyDef(label = "本期数量增加")
    @Column(name = "qtyadd", precision = 20, scale = 4)
    private Double qtyadd;

    @PropertyDef(label = "本期数量减少")
    @Column(name = "qtydecrease", precision = 20, scale = 4)
    private Double qtydecrease;

    @PropertyDef(label = "本期原值增加")
    @Column(name = "valueorgadd", precision = 20, scale = 4)
    private Double valueorgadd;

    @PropertyDef(label = "本期原值减少")
    @Column(name = "valueorgderease", precision = 20, scale = 4)
    private Double valueorgderease;

    @PropertyDef(label = "本期累计折旧调增")
    @Column(name = "accudepradjustadd", precision = 20, scale = 4)
    private Double accudepradjustadd;

    @PropertyDef(label = "本期累计折旧调减")
    @Column(name = "accudepradjustdec", precision = 20, scale = 4)
    private Double accudepradjustdec;

    @PropertyDef(label = "本年累计数量增加")
    @Column(name = "yqtyincrease", precision = 20, scale = 4)
    private Double yqtyIncrease;

    @PropertyDef(label = "本年累计数量减少")
    @Column(name = "yqtydecrease", precision = 20, scale = 4)
    private Double yqtydecrease;

    @PropertyDef(label = "本年原值累计增加")
    @Column(name = "yvalueincrease", precision = 20, scale = 4)
    private Double yvalueincrease;

    @PropertyDef(label = "本年原值累计减少")
    @Column(name = "yvaluedecrease", precision = 20, scale = 4)
    private Double yvaluedecrease;

    @PropertyDef(label = "本年累计折旧调增")
    @Column(name = "yaccudeprincrease", precision = 20, scale = 4)
    private Double yaccudeprincrease;

    @PropertyDef(label = "本年累计折旧调减")
    @Column(name = "yaccudeprdecrease", precision = 20, scale = 4)
    private Double yaccudeprdecrease;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间")
    @Column(name = "zhgxsj")
    private Date zhgxsj;

}


 src/main/java/com/fzzy/async/fzzy61/entity/Fz61AreationData.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,267 @@
package com.fzzy.async.fzzy61.entity;

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;

/**
 * é€šé£Žæ•°æ®
 * @author vince
 *
 */
@Data
@Entity
@Table(name = "D_AREATION_DATA")
public class Fz61AreationData implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 41)
    @PropertyDef(label = "主键")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "操作仓库")
    private String depotId;

    @Column(name = "OBJECTIVE_", length = 100)
    @PropertyDef(label = "通风目的")
    private String objective;

    @PropertyDef(label = "粮堆孔隙度")
    @Column(name = "ldkxd", precision = 10, scale = 3)
    private Double ldkxd;

    /**
     * 1：自然空气通风
     * 2：加热空气通风
     * 3：冷却空气通风
     * 4：内循环控温
     * 5：空调控温通风
     * 6：维持通风
     */
    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "通风类型")
    private String type;
    /**
     * 1：地槽
     * 2：地上笼
     * 3：移动式
     * 4：箱式
     * 5：径向
     * 6：夹底
     * 9：其他
     */
    @Column(name = "WIND_NET_TYPE_", length = 10)
    @PropertyDef(label = "风网类型")
    private String windNetType;

    @PropertyDef(label = "风网设置方式")
    @Column(name = "fwszfs", length = 64)
    private String fwszfs;

    @PropertyDef(label = "主风道截面积")
    @Column(name = "zfdjmj", precision = 10, scale = 3)
    private Double zfdjmj;

    @PropertyDef(label = "支风道截面积")
    @Column(name = "zhfdjmj", precision = 10, scale = 3)
    private Double zhfdjmj;

    @PropertyDef(label = "支风道总长度")
    @Column(name = "zfdzcd", precision = 20, scale = 3)
    private Double zfdzcd;

    @PropertyDef(label = "风网开孔率")
    @Column(name = "fwkkl", precision = 10, scale = 3)
    private Double fwkkl;

    @PropertyDef(label = "空气途径比")
    @Column(name = "kqtjb", precision = 10, scale = 3)
    private Double kqtjb;

    @PropertyDef(label = "通风口设置个数")
    @Column(name = "tfkszgs")
    private Integer tfkszgs;

    @PropertyDef(label = "通风机型号")
    @Column(name = "tfjxh", length = 128)
    private String tfjxh;

    @PropertyDef(label = "通风机台数")
    @Column(name = "tfjts")
    private Integer tfjts;

    @PropertyDef(label = "单台风机额定全压")
    @Column(name = "dtfjedqy", precision = 10, scale = 3)
    private Double dtfjedqy;

    @PropertyDef(label = "单台风机额定风量")
    @Column(name = "dtfjedfl", precision = 10, scale = 3)
    private Double dtfjedfl;

    @PropertyDef(label = "单台风机额定功率")
    @Column(name = "dtfjedgl", precision = 10, scale = 3)
    private Double dtfjedgl;

    /**
     * 1：压入式通风
     * 2：吸出式通风
     * 3：压入与吸出相结合式通风
     * 4：环流通风
     * 9：其它
     */
    @Column(name = "AIR_SUPPLY_MODE_", length = 10)
    @PropertyDef(label = "送风方式")
    private String airSupplyMode;

    @PropertyDef(label = "单台风机实测风量")
    @Column(name = "dtfjscfl", precision = 10, scale = 3)
    private Double dtfjscfl;

    @PropertyDef(label = "单台风机轴功率")
    @Column(name = "dtfjzgl", precision = 10, scale = 3)
    private Double dtfjzgl;

    @PropertyDef(label = "总风量")
    @Column(name = "zfl", precision = 10, scale = 3)
    private Double zfl;

    @PropertyDef(label = "单位通风量")
    @Column(name = "dwtfl", precision = 10, scale = 3)
    private Double dwtfl;

    @PropertyDef(label = "实测系统阻力")
    @Column(name = "scxtzl", precision = 10, scale = 3)
    private Double scxtzl;

    /**
     * æ€»è€—电量 åƒç“¦
     */
    @Column(name = "TOTAL_ES_")
    @PropertyDef(label = "总耗电量")
    private Double totalEs;

    @PropertyDef(label = "作业时气温")
    @Column(name = "zysqw", precision = 10, scale = 3)
    private double zysqw;

    @PropertyDef(label = "作业时气湿")
    @Column(name = "zysqs", precision = 10, scale = 3)
    private double zysqs;

    @Column(name = "BEFORE_TEMP_AVG_")
    @PropertyDef(label = "作业前平均粮温")
    private Double beforeTempAvg;

    @Column(name = "AFTER_TEMP_AVG_")
    @PropertyDef(label = "作业后平均粮温")
    private Double afterTempAvg;

    @PropertyDef(label = "降温幅度")
    @Column(name = "jwfd", precision = 10, scale = 3)
    private double jwfd;

    @PropertyDef(label = "吨粮降温能耗")
    @Column(name = "dljwnh", precision = 10, scale = 3)
    private double dljwnh;

    @PropertyDef(label = "失水率")
    @Column(name = "ssl_", precision = 10, scale = 3)
    private double ssl;

    @PropertyDef(label = "保水效果评价结果")
    @Column(name = "bsxgpjjg", length = 128)
    private String bsxgpjjg;

    @PropertyDef(label = "通风降温均匀性评价_整仓")
    @Column(name = "tfjwjyxpjzc", length = 128)
    private String tfjwjyxpjzc;

    @PropertyDef(label = "通风降温均匀性评价_上层")
    @Column(name = "tfjwjyxpjsc", length = 128)
    private String tfjwjyxpjsc;

    @PropertyDef(label = "通风降温均匀性评价_中(间)层")
    @Column(name = "tfjwjyxpjzjc", length = 128)
    private String tfjwjyxpjzjc;

    @PropertyDef(label = "通风降温均匀性评价_下层")
    @Column(name = "tfjwjyxpjxc", length = 128)
    private String tfjwjyxpjxc;

    @Column(name = "BEFORE_PER_WET_AVG_")
    @PropertyDef(label = "作业前平均水分")
    private Double beforPerWetAvg;

    @Column(name = "AFTER_PER_WET_AVG_")
    @PropertyDef(label = "作业后平均水分")
    private Double afterPerWetAvg;

    @PropertyDef(label = "降水幅度")
    @Column(name = "jsfd", precision = 10, scale = 3)
    private Double jsfd;

    @PropertyDef(label = "吨粮降水能耗")
    @Column(name = "dljsnh", precision = 10, scale = 3)
    private Double dljsnh;

    @PropertyDef(label = "通风降水均匀性分析_整仓")
    @Column(name = "tfjsjyxfxzc", length = 128)
    private String tfjsjyxfxzc;

    @PropertyDef(label = "通风降水均匀性分析_上层")
    @Column(name = "tfjsjyxfxsc", length = 128)
    private String tfjsjyxfxsc;

    @PropertyDef(label = "通风降水均匀性分析_中(间)层")
    @Column(name = "tfjsjyxfxzjc", length = 128)
    private String tfjsjyxfxzjc;

    @PropertyDef(label = "通风降水均匀性分析_下层")
    @Column(name = "tfjsjyxfxxc", length = 128)
    private String tfjsjyxfxxc;

    @Column(name = "CHARGE_USER_", length = 30)
    @PropertyDef(label = "负责人", description = "通风作业负责人")
    private String chargeUser;
    @Column(name = "OPERATORS_", length = 30)
    @PropertyDef(label = "作业人员", description = "通风作业人")
    private String operators;

    @Column(name = "START_TIME_")
    @PropertyDef(label = "通风作业时间")
    private Date startTime;

    @Column(name = "LONG_TIME_")
    @PropertyDef(label = "通风时长，单位小时")
    private Double longTime;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "修改时间", description = "最后修改时间")
    private Date updateTime;

    @Column(name = "UPDATE_USER_", length = 30)
    @PropertyDef(label = "修改人", description = "最后修改人")
    private String updateUser;

    @Column(name = "REMARK_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remark;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61AssetsLiability.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,598 @@
package com.fzzy.async.fzzy61.entity;

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;

/**
 * è´¢åŠ¡ç®¡ç†-资产负债
 *
 * @author czt
 * @date 2023-04-10 10:40
 */
@Data
@Entity
@Table(name = "D_FINANCE_ASSETS_Liability")
public class Fz61AssetsLiability implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @PropertyDef(label = "id" )
    @Column(name = "ID_", length = 40)
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @PropertyDef(label = "报表时间" )
    @Column(name = "bbsj")
    private Date bbsj;

    @PropertyDef(label = "货币资金期末余额(元)" )
    @Column(name = "hbjjqmye")
    private Double hbjjqmye;

    @PropertyDef(label = "货币资金年初余额(元)" )
    @Column(name = "hbjjncye")
    private Double hbjjncye;

    @PropertyDef(label = "交易性金融资产期末余额(元)" )
    @Column(name = "jyxjrzcqmye")
    private Double jyxjrzcqmye;

    @PropertyDef(label = "交易性金融资产年初余额(元)" )
    @Column(name = "jyxjrzcncye")
    private Double jyxjrzcncye;

    @PropertyDef(label = "衍生金融资产期末余额(元)" )
    @Column(name = "ysjrzcqmye")
    private Double ysjrzcqmye;

    @PropertyDef(label = "衍生金融资产年初余额(元)" )
    @Column(name = "ysjrzcncye")
    private Double ysjrzcncye;

    @PropertyDef(label = "应收票据期末余额(元)" )
    @Column(name = "yspjqmye")
    private Double yspjqmye;

    @PropertyDef(label = "应收票据年初余额(元)" )
    @Column(name = "yspjncye")
    private Double yspjncye;

    @PropertyDef(label = "应收账款期末余额(元)" )
    @Column(name = "yszkqmye")
    private Double yszkqmye;

    @PropertyDef(label = "应收账款年初余额(元)" )
    @Column(name = "yszkncye")
    private Double yszkncye;

    @PropertyDef(label = "预付款项期末余额(元)" )
    @Column(name = "yuskxqmye")
    private Double yuskxqmye;

    @PropertyDef(label = "预付款项年初余额(元)" )
    @Column(name = "yuskxncye")
    private Double yuskxncye;

    @PropertyDef(label = "其他应收款期末余额(元)" )
    @Column(name = "qtyszkqmye")
    private Double qtyszkqmye;

    @PropertyDef(label = "其他应收款年初余额(元)" )
    @Column(name = "qtyszkncye")
    private Double qtyszkncye;

    @PropertyDef(label = "存货期末余额(元)" )
    @Column(name = "chqmye")
    private Double chqmye;

    @PropertyDef(label = "存货年初余额(元)" )
    @Column(name = "chncye")
    private Double chncye;

    @PropertyDef(label = "合同资产期末余额(元)" )
    @Column(name = "htzcqmye")
    private Double htzcqmye;

    @PropertyDef(label = "合同资产年初余额(元)" )
    @Column(name = "htzcncye")
    private Double htzcncye;

    @PropertyDef(label = "持有待售资产期末余额(元)" )
    @Column(name = "cydszcqmye")
    private Double cydszcqmye;

    @PropertyDef(label = "持有待售资产年初余额(元)" )
    @Column(name = "cydszcncye")
    private Double cydszcncye;

    @PropertyDef(label = "一年内到期的非流动资产期末余额(元)" )
    @Column(name = "ynndqfldzcqmye")
    private Double ynndqfldzcqmye;

    @PropertyDef(label = "一年内到期的非流动资产年初余额(元)" )
    @Column(name = "ynndqfldzcncye")
    private Double ynndqfldzcncye;

    @PropertyDef(label = "其他流动资产期末余额(元)" )
    @Column(name = "qtldzcqmye")
    private Double qtldzcqmye;

    @PropertyDef(label = "其他流动资产年初余额(元)" )
    @Column(name = "qtldzcncye")
    private Double qtldzcncye;

    @PropertyDef(label = "流动资产合计期末余额(元)" )
    @Column(name = "ldzchjqmye")
    private Double ldzchjqmye;

    @PropertyDef(label = "流动资产合计年初余额(元)" )
    @Column(name = "ldzchjncye")
    private Double ldzchjncye;

    @PropertyDef(label = "债券投资期末余额(元)" )
    @Column(name = "zjtzqmye")
    private Double zjtzqmye;

    @PropertyDef(label = "债券投资年初余额(元)" )
    @Column(name = "zjtzncye")
    private Double zjtzncye;

    @PropertyDef(label = "其他债券投资期末余额(元)" )
    @Column(name = "qtzqtzqmye")
    private Double qtzqtzqmye;

    @PropertyDef(label = "其他债券投资年初余额(元)" )
    @Column(name = "qtzqtzncye")
    private Double qtzqtzncye;

    @PropertyDef(label = "长期应收款期末余额(元)" )
    @Column(name = "cqyskqmye")
    private Double cqyskqmye;

    @PropertyDef(label = "长期应收款年初余额(元)" )
    @Column(name = "cqyskncye")
    private Double cqyskncye;

    @PropertyDef(label = "长期股权投资期末余额(元)" )
    @Column(name = "cqgqtzqmye")
    private Double cqgqtzqmye;

    @PropertyDef(label = "长期股权投资年初余额(元)" )
    @Column(name = "cqgqtzncye")
    private Double cqgqtzncye;

    @PropertyDef(label = "其他权益工具投资期末余额(元)" )
    @Column(name = "qtqygjtzqmye")
    private Double qtqygjtzqmye;

    @PropertyDef(label = "其他权益工具投资年初余额(元)" )
    @Column(name = "qtqygjtzncye")
    private Double qtqygjtzncye;

    @PropertyDef(label = "其他非流动金融资产期末余额(元)" )
    @Column(name = "qtfldjrzcqmye")
    private Double qtfldjrzcqmye;

    @PropertyDef(label = "其他非流动金融资产年初余额(元)" )
    @Column(name = "qtfldjrzcncye")
    private Double qtfldjrzcncye;

    @PropertyDef(label = "投资性房地产期末余额(元)" )
    @Column(name = "tzxfdcqmye")
    private Double tzxfdcqmye;

    @PropertyDef(label = "投资性房地产年初余额(元)" )
    @Column(name = "tzxfdcncye")
    private Double tzxfdcncye;

    @PropertyDef(label = "固定资产期末余额(元)" )
    @Column(name = "gdzcqmye")
    private Double gdzcqmye;

    @PropertyDef(label = "固定资产年初余额(元)" )
    @Column(name = "gdzcncye")
    private Double gdzcncye;

    @PropertyDef(label = "在建工程期末余额(元)" )
    @Column(name = "zjgcqmye")
    private Double zjgcqmye;

    @PropertyDef(label = "在建工程年初余额(元)" )
    @Column(name = "zjgcncye")
    private Double zjgcncye;

    @PropertyDef(label = "生产性生物资产期末余额(元)" )
    @Column(name = "scxswzcqmye")
    private Double scxswzcqmye;

    @PropertyDef(label = "生产性生物资产年初余额(元)" )
    @Column(name = "scxswzcncye")
    private Double scxswzcncye;

    @PropertyDef(label = "油气资产期末余额(元)" )
    @Column(name = "yqzcqmye")
    private Double yqzcqmye;

    @PropertyDef(label = "油气资产年初余额(元)" )
    @Column(name = "yqzcncye")
    private Double yqzcncye;

    @PropertyDef(label = "无形资产期末余额(元)" )
    @Column(name = "wxzcqmye")
    private Double wxzcqmye;

    @PropertyDef(label = "无形资产年初余额(元)" )
    @Column(name = "wxzcncye")
    private Double wxzcncye;

    @PropertyDef(label = "开发支出期末余额(元)" )
    @Column(name = "kfzcqmye")
    private Double kfzcqmye;

    @PropertyDef(label = "开发支出年初余额(元)" )
    @Column(name = "kfzcncye")
    private Double kfzcncye;

    @PropertyDef(label = "商誉期末余额(元)" )
    @Column(name = "syqmye")
    private Double syqmye;

    @PropertyDef(label = "商誉年初余额(元)" )
    @Column(name = "syncye")
    private Double syncye;

    @PropertyDef(label = "长期待摊费用期末余额(元)" )
    @Column(name = "cqdtfyqmye")
    private Double cqdtfyqmye;

    @PropertyDef(label = "长期待摊费用年初余额(元)" )
    @Column(name = "cqdtfyncye")
    private Double cqdtfyncye;

    @PropertyDef(label = "递延所得税资产期末余额(元)" )
    @Column(name = "dysdszcqmye")
    private Double dysdszcqmye;

    @PropertyDef(label = "递延所得税资产年初余额(元)" )
    @Column(name = "dysdszcncye")
    private Double dysdszcncye;

    @PropertyDef(label = "其他非流动资产期末余额(元)" )
    @Column(name = "qtfldzcqmye")
    private Double qtfldzcqmye;

    @PropertyDef(label = "其他非流动资产年初余额(元)" )
    @Column(name = "qtfldzcncye")
    private Double qtfldzcncye;

    @PropertyDef(label = "非流动资产合计期末余额(元)" )
    @Column(name = "fldzcqmye")
    private Double fldzcqmye;

    @PropertyDef(label = "非流动资产合计年初余额(元)" )
    @Column(name = "fldzcncye")
    private Double fldzcncye;

    @PropertyDef(label = "资产总计期末余额(元)" )
    @Column(name = "zczjqmye")
    private Double zczjqmye;

    @PropertyDef(label = "资产总计年初余额(元)" )
    @Column(name = "zczjncye")
    private Double zczjncye;

    @PropertyDef(label = "短期借款期末余额(元)" )
    @Column(name = "dqjkmye")
    private Double dqjkmye;

    @PropertyDef(label = "短期借款年初余额(元)" )
    @Column(name = "dqjkncye")
    private Double dqjkncye;

    @PropertyDef(label = "交易性金融负债期末余额(元)" )
    @Column(name = "jyxjrfzqmye")
    private Double jyxjrfzqmye;

    @PropertyDef(label = "交易性金融负债年初余额(元)" )
    @Column(name = "jyxjrfzncye")
    private Double jyxjrfzncye;

    @PropertyDef(label = "衍生金融负债期末余额(元)" )
    @Column(name = "ysjrfzqmye")
    private Double ysjrfzqmye;

    @PropertyDef(label = "衍生金融负债年初余额(元)" )
    @Column(name = "ysjrfzncye")
    private Double ysjrfzncye;

    @PropertyDef(label = "应付票据期末余额(元)" )
    @Column(name = "ldfzyspjqmye")
    private Double ldfzyspjqmye;

    @PropertyDef(label = "应付票据年初余额(元)" )
    @Column(name = "ldfzyspjncye")
    private Double ldfzyspjncye;

    @PropertyDef(label = "应付账款期末余额(元)" )
    @Column(name = "ldfzyszkqmye")
    private Double ldfzyszkqmye;

    @PropertyDef(label = "应付账款年初余额(元)" )
    @Column(name = "ldfzyszkncye")
    private Double ldfzyszkncye;

    @PropertyDef(label = "预收款项期末余额(元)" )
    @Column(name = "ldfzyuskxqmye")
    private Double ldfzyuskxqmye;

    @PropertyDef(label = "预收款项年初余额(元)" )
    @Column(name = "ldfzyuskxncye")
    private Double ldfzyuskxncye;

    @PropertyDef(label = "合同负债期末余额(元)" )
    @Column(name = "htfzqmye")
    private Double htfzqmye;

    @PropertyDef(label = "合同负债年初余额(元)" )
    @Column(name = "htfzncye")
    private Double htfzncye;

    @PropertyDef(label = "应付职工薪酬期末余额(元)" )
    @Column(name = "yfzgxcqmye")
    private Double yfzgxcqmye;

    @PropertyDef(label = "应付职工薪酬年初余额(元)" )
    @Column(name = "yfzgxcncye")
    private Double yfzgxcncye;

    @PropertyDef(label = "应交税费期末余额(元)" )
    @Column(name = "yjsfqmye")
    private Double yjsfqmye;

    @PropertyDef(label = "应交税费年初余额(元)" )
    @Column(name = "yjsfncye")
    private Double yjsfncye;

    @PropertyDef(label = "其他应付款期末余额(元)" )
    @Column(name = "qtyfkqmye")
    private Double qtyfkqmye;

    @PropertyDef(label = "其他应付款年初余额(元)" )
    @Column(name = "qtyfkncye")
    private Double qtyfkncye;

    @PropertyDef(label = "持有待售负债期末余额(元)" )
    @Column(name = "cydsfzqmye")
    private Double cydsfzqmye;

    @PropertyDef(label = "持有待售负债年初余额(元)" )
    @Column(name = "cydsfzncye")
    private Double cydsfzncye;

    @PropertyDef(label = "一年内到期的非流动负债期末余额(元)" )
    @Column(name = "ynddqfldfzqmye")
    private Double ynddqfldfzqmye;

    @PropertyDef(label = "一年内到期的非流动负债年初余额(元)" )
    @Column(name = "ynddqfldfzncye")
    private Double ynddqfldfzncye;

    @PropertyDef(label = "其他流动负债期末余额(元)" )
    @Column(name = "qtldfzqmye")
    private Double qtldfzqmye;

    @PropertyDef(label = "其他流动负债年初余额(元)" )
    @Column(name = "qtldfzncye")
    private Double qtldfzncye;

    @PropertyDef(label = "流动负债合计期末余额(元)" )
    @Column(name = "ldfzhjqmye")
    private Double ldfzhjqmye;

    @PropertyDef(label = "流动负债合计年初余额(元)" )
    @Column(name = "ldfzhjncye")
    private Double ldfzhjncye;

    @PropertyDef(label = "长期借款期末余额(元)" )
    @Column(name = "cqjkqmye")
    private Double cqjkqmye;

    @PropertyDef(label = "长期借款年初余额(元)" )
    @Column(name = "cqjkncye")
    private Double cqjkncye;

    @PropertyDef(label = "应付债券期末余额(元)" )
    @Column(name = "yfzqqmye")
    private Double yfzqqmye;

    @PropertyDef(label = "应付债券年初余额(元)" )
    @Column(name = "yfzqncye")
    private Double yfzqncye;

    @PropertyDef(label = "其中：优先股期末余额(元)" )
    @Column(name = "yfzqyxgqmye")
    private Double yfzqyxgqmye;

    @PropertyDef(label = "其中：优先股年初余额(元)" )
    @Column(name = "yfzqyxgncye")
    private Double yfzqyxgncye;

    @PropertyDef(label = "永续债期末余额(元)" )
    @Column(name = "yfzqyxzqmye")
    private Double yfzqyxzqmye;

    @PropertyDef(label = "永续债年初余额(元)" )
    @Column(name = "yfzqyxzncye")
    private Double yfzqyxzncye;

    @PropertyDef(label = "长期应付款期末余额(元)" )
    @Column(name = "cqyfkqmye")
    private Double cqyfkqmye;

    @PropertyDef(label = "长期应付款年初余额(元)" )
    @Column(name = "cqyfkncye")
    private Double cqyfkncye;

    @PropertyDef(label = "预计负债期末余额(元)" )
    @Column(name = "ysfzqmye")
    private Double ysfzqmye;

    @PropertyDef(label = "预计负债年初余额(元)" )
    @Column(name = "ysfzncye")
    private Double ysfzncye;

    @PropertyDef(label = "递延收益期末余额(元)" )
    @Column(name = "dysyqmye")
    private Double dysyqmye;

    @PropertyDef(label = "递延收益年初余额(元)" )
    @Column(name = "dysyncye")
    private Double dysyncye;

    @PropertyDef(label = "递延所得税负债期末余额(元)" )
    @Column(name = "dysdsfzqmye")
    private Double dysdsfzqmye;

    @PropertyDef(label = "递延所得税负债年初余额(元)" )
    @Column(name = "dysdsfzncye")
    private Double dysdsfzncye;

    @PropertyDef(label = "其他非流动负债期末余额(元)" )
    @Column(name = "qtfldfzqmye")
    private Double qtfldfzqmye;

    @PropertyDef(label = "其他非流动负债年初余额(元)" )
    @Column(name = "qtfldfzncye")
    private Double qtfldfzncye;

    @PropertyDef(label = "非流动负债合计期末余额(元)" )
    @Column(name = "fldfzhjqmye")
    private Double fldfzhjqmye;

    @PropertyDef(label = "非流动负债合计年初余额(元)" )
    @Column(name = "fldfzhjncye")
    private Double fldfzhjncye;

    @PropertyDef(label = "负债合计期末余额(元)" )
    @Column(name = "fzhjqmye")
    private Double fzhjqmye;

    @PropertyDef(label = "负债合计年初余额(元)" )
    @Column(name = "fzhjncye")
    private Double fzhjncye;

    @PropertyDef(label = "实收资本(或股本)期末余额(元)" )
    @Column(name = "sszbqmye")
    private Double sszbqmye;

    @PropertyDef(label = "实收资本(或股本)年初余额(元)" )
    @Column(name = "sszbncye")
    private Double sszbncye;

    @PropertyDef(label = "其他权益工具期末余额(元)" )
    @Column(name = "qtqygjqmye")
    private Double qtqygjqmye;

    @PropertyDef(label = "其他权益工具年初余额(元)" )
    @Column(name = "qtqygjncye")
    private Double qtqygjncye;

    @PropertyDef(label = "其中：优先股期末余额(元)" )
    @Column(name = "qtqygjyxgqmye")
    private Double qtqygjyxgqmye;

    @PropertyDef(label = "其中：优先股年初余额(元)" )
    @Column(name = "qtqygjyxgncye")
    private Double qtqygjyxgncye;

    @PropertyDef(label = "永续债期末余额(元)" )
    @Column(name = "qtqygjyxzqmye")
    private Double qtqygjyxzqmye;

    @PropertyDef(label = "永续债年初余额(元)" )
    @Column(name = "qtqygjyxzncye")
    private Double qtqygjyxzncye;

    @PropertyDef(label = "资本公积期末余额(元)" )
    @Column(name = "zbgjqmye")
    private Double zbgjqmye;

    @PropertyDef(label = "资本公积年初余额(元)" )
    @Column(name = "zbgjncye")
    private Double zbgjncye;

    @PropertyDef(label = "减：库存股期末余额(元)" )
    @Column(name = "jkcgqmye")
    private Double jkcgqmye;

    @PropertyDef(label = "减：库存股年初余额(元)" )
    @Column(name = "jkcgncye")
    private Double jkcgncye;

    @PropertyDef(label = "其他综合收益期末余额(元)" )
    @Column(name = "qtzhsyqmye")
    private Double qtzhsyqmye;

    @PropertyDef(label = "其他综合收益年初余额(元)" )
    @Column(name = "qtzhsyncye")
    private Double qtzhsyncye;

    @PropertyDef(label = "专项储备期末余额(元)" )
    @Column(name = "zxcbqmye")
    private Double zxcbqmye;

    @PropertyDef(label = "专项储备年初余额(元)" )
    @Column(name = "zxcbncye")
    private Double zxcbncye;

    @PropertyDef(label = "盈余公积期末余额(元)" )
    @Column(name = "yygjqmye")
    private Double yygjqmye;

    @PropertyDef(label = "盈余公积年初余额(元)" )
    @Column(name = "yygjncye")
    private Double yygjncye;

    @PropertyDef(label = "未分配利润期末余额(元)" )
    @Column(name = "wfplrqmye")
    private Double wfplrqmye;

    @PropertyDef(label = "未分配利润年初余额(元)" )
    @Column(name = "wfplrncye")
    private Double wfplrncye;

    @PropertyDef(label = "所有者权益(或股东权益)合计期末余额(元)" )
    @Column(name = "syzqyqmye")
    private Double syzqyqmye;

    @PropertyDef(label = "所有者权益(或股东权益)合计年初余额(元)" )
    @Column(name = "syzqyncye")
    private Double syzqyncye;

    @PropertyDef(label = "负债和所有者权益(或股东益)总计期末余额(元)" )
    @Column(name = "fzhsyzqyqmye")
    private Double fzhsyzqyqmye;

    @PropertyDef(label = "负债和所有者权益(或股东益)总计年初余额(元)" )
    @Column(name = "fzhsyzqyncye")
    private Double fzhsyzqyncye;

    @PropertyDef(label = "最后更新时间" )
    @Column(name = "zhgxsj")
    private Date zhgxsj;
}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Depot.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,174 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;


/**
 * @Desc: åŸºç¡€ä¿¡æ¯-货位信息
 * @author: Andy
 * @update-time: 2023/5/26
 */
@Data
@Entity
@Table(name = "D_DEPOT")
public class Fz61Depot implements Serializable {

    @Id
    @Column(name = "ID_", length = 50)
    @PropertyDef(label = "货位编号")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "货位名称")
    private String name;

    @Column(name = "BUILDING_ID_", length = 40)
    @PropertyDef(label = "所属仓房")
    private String buildingId;

    @Column(name = "GRANARY_ID_", length = 40)
    @PropertyDef(label = "所属廒间")
    private String granaryId;

    @Column(name = "DEPOT_TYPE_", length = 10)
    @PropertyDef(label = "仓库类型", description = "根据国标配置类型，平房仓、立筒仓、浅圆仓、储油罐")
    private String depotType;

    @Column(name = "DEPOT_STATUS_", length = 10)
    @PropertyDef(label = "仓库状态", description = "与库存表关联，通过库存变更")
    private String depotStatus;

    @Column(name = "STORE_TYPE_", length = 6)
    @PropertyDef(label = "储粮方式", description = "与库存表关联")
    private String storeType;

    @Column(name = "STORAGE_MAX_")
    @PropertyDef(label = "设计储量", description = "单位：KG")
    private Double storageMax;

    @Column(name = "STORAGE_REAL_")
    @PropertyDef(label = "实际储量", description = "单位：KG，通过库存变更")
    private Double storageReal;

    @Column(name = "FOOD_TYPE_", length = 10)
    @PropertyDef(label = "粮食性质", description = "与库存表关联，通过库存变更")
    private String foodType;

    @Column(name = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种", description = "与库存表关联，通过库存变更")
    private String foodVariety;

    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级", description = "与库存表关联，通过库存变更")
    private String foodLevel;

    @Column(name = "FOOD_LOCATION_ID_", length = 50)
    @PropertyDef(label = "粮食产地")
    private String foodLocationId;

    @Column(name = "FOOD_LOCATION_", length = 50)
    @PropertyDef(label = "粮食产地", description = "与库存表关联，通过库存变更")
    private String foodLocation;

    @Column(name = "FOOD_YEAR_", length = 10)
    @PropertyDef(label = "粮食年份", description = "与库存表关联，通过库存变更")
    private String foodYear;

    @Column(name = "PER_WET_")
    @PropertyDef(label = "水分", description = "百分比，默认为空，来源质检信息")
    private Double perWet;

    @Column(name = "PER_IMPURITY_")
    @PropertyDef(label = "杂质", description = "百分比，默认为空，来源质检信息")
    private Double perImpurity;

    @Column(name = "BULK_WEIGHT_")
    @PropertyDef(label = "容重 g/L", description = "容重 g/L")
    private Double bulkWeight;

    @Column(name = "STORE_KEEPER_", length = 30)
    @PropertyDef(label = "保管员账号")
    private String storeKeeper;

    @Column(name = "STORE_KEEPER_NAME_", length = 50)
    @PropertyDef(label = "保管员", description = "中文名称")
    private String storeKeeperName;

    @Column(name = "STORE_DATE_")
    @PropertyDef(label = "入库时间", description = "默认空，通过库存变更")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date storeDate;

    @Column(name = "CHECK_DATE_")
    @PropertyDef(label = "最后质检时间", description = "默认空，来源质检信息")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date checkDate;

    @Column(name = "REMARK_", length = 200)
    @PropertyDef(label = "备注", description = "备注信息")
    private String remark;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;

    @Column(name = "BH_ID_", length = 50)
    @PropertyDef(label = "邦海粮情分机仓库编码")
    private String bhId;

    @Column(name = "ORDER_NUM_")
    @PropertyDef(label = "显示顺序")
    private Integer orderNum = 1;

    // ------------其他属性信息------------//
    @Transient
    @PropertyDef(label = "粮食品种")
    private String foodVarietyName;

    @Transient
    @PropertyDef(label = "粮食性质")
    private String foodTypeName;

    @Transient
    @PropertyDef(label = "仓库类型")
    private String depotTypeName;

    @Transient
    @PropertyDef(label = "仓库类型")
    private String depotStatusName;

    @Transient
    @PropertyDef(label = "粮食等级")
    private String foodLevelName;

    @Transient
    @PropertyDef(label = "X坐标", description = "三维模型中坐标，页面无需维护")
    private Double posX;

    @Transient
    @PropertyDef(label = "Y坐标", description = "三维模型中坐标，页面无需维护")
    private Double posY;

    @Transient
    @PropertyDef(label = "保管员等级")
    private String storeKeeperLevel = "高级保管员";

    @Transient
    @PropertyDef(label = "保管员等级")
    private String storeKeeperPhone = "####";

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotConf.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,168 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;

/**
 * ä»“库配置 ç”¨äºŽé…ç½®ç²®æƒ…分机等配置，气体采集配置等
 */
@Data
@Entity
@Table(name = "D_DEPOT_CONF")
@IdClass(Fz61DepotConfKey.class)
public class Fz61DepotConf implements Serializable {


    @Id
    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "所属仓库")
    private String depotId;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "GRAIN_SER_", length = 40)
    @PropertyDef(label = "粮情分机", description = "仅仅粮情采集分机")
    private String grainSer;

    @Column(name = "TH_SER_", length = 40)
    @PropertyDef(label = "温湿度分机", description = "仓温仓湿的分机")
    private String thSer;

    @Column(name = "ES_SER_", length = 40)
    @PropertyDef(label = "能耗分机")
    private String esSer;

    @Column(name = "ES_SER_TAG_", length = 40)
    @PropertyDef(label = "多能耗分机")
    private String esSerTag;

    @Column(name = "GAS_SER_", length = 40)
    @PropertyDef(label = "气体分机")
    private String gasSer;

    @Column(name = "GAS_SER_TAG_", length = 40)
    @PropertyDef(label = "多气体分机")
    private String gasSerTag;

    @Column(name = "PEST_SER_", length = 40)
    @PropertyDef(label = "虫害分机")
    private String pestSer;

    @Column(name = "PEST_SER_TAG_", length = 40)
    @PropertyDef(label = "多虫害分机")
    private String pestSerTag;

    @Column(name = "VERB_SER_", length = 40)
    @PropertyDef(label = "通风分机")
    private String verbSer;

    @Column(name = "GRAIN_FREQ_", length = 4)
    @PropertyDef(label = "粮情保存频率", description = "默认一天多次")
    private String grainFreq;

    @Column(name = "TH_CONF_", length = 5)
    @PropertyDef(label = "仓温仓湿通道")
    private String thConf = "1";

    @Column(name = "CABLE_RULE_", length = 20)
    @PropertyDef(label = "布线规则", description = "平方仓表示层行列，筒仓表示每圈的列数")
    private String cableRule;

    @Column(name = "CABLE_CIR_", length = 20)
    @PropertyDef(label = "筒仓层规则", description = "针对筒仓")
    private String cableCir;

    @Column(name = "CABLE_CONE_", length = 2)
    @PropertyDef(label = "筒仓锥形", description = "针对筒仓锥形，0=无判断，1=上锥形，2=下锥形")
    private String cableCone;

    @Column(name = "CABLE_START_")
    @PropertyDef(label = "电缆开始列")
    private int cableStart;

    @Column(name = "CABLE_END_")
    @PropertyDef(label = "电缆截至列")
    private int cableEnd;

    @Column(name = "START_ORIENTATION_", length = 20)
    @PropertyDef(label = "电缆起始方位", description = "默认右边(右边、右上、左边、左上)")
    private String startOrientation;

    @Column(name = "START_DIRECTION_", length = 20)
    @PropertyDef(label = "电缆起始方向", description = "默认纵向(纵向、横向)")
    private String startDirection;

    @Column(name = "START_POINT_", length = 20)
    @PropertyDef(label = "电缆起始点位", description = "默认顶部(顶部、底部)")
    private String startPoint;

    @Column(name = "START_CONVERT_", length = 20)
    @PropertyDef(label = "层行转换", description = "默认不转换(默认、顺时针、逆时针)")
    private String startConvert;

    @Column(name = "TEMP_MAX_")
    @PropertyDef(label = "温度上限")
    private Double tempMax;

    @Column(name = "ONLY_CUR_DEPOT_", length = 1)
    @PropertyDef(label = "显示当前", description = "默认不转换(默认、顺时针、逆时针)")
    private String onlyCurDepot = "Y";

    @Column(name = "GAS_START_")
    @PropertyDef(label = "气体采集点开始")
    private int gasStart;

    @Column(name = "GAS_END_")
    @PropertyDef(label = "气体采集点截至")
    private int gasEnd;

    @Column(name = "N2_MAX_")
    @PropertyDef(label = "氮气上限")
    private Double n2Max;

    @Column(name = "CO2_MAX_")
    @PropertyDef(label = "二氧化碳上限")
    private Double co2Max;

    @Column(name = "O2_MAX_")
    @PropertyDef(label = "氧气上限")
    private Double o2Max;

    @Column(name = "PH3_MAX_")
    @PropertyDef(label = "磷化氢上限")
    private Double ph3Max;

    @Column(name = "PEST_START_")
    @PropertyDef(label = "虫害采集点开始")
    private int pestStart;

    @Column(name = "PEST_END_")
    @PropertyDef(label = "虫害采集点截至")
    private int pestEnd;

    @Column(name = "PEST_MAX_")
    @PropertyDef(label = "虫害上限")
    private Double pestMax;

    @Column(name = "IS_ONLY_TH_", length = 2)
    @PropertyDef(label = "粮情是否温湿度", description = "默认否。")
    private String isOnlyTH ;

    // ä»“库名称
    @Transient
    private String depotName;

    //仓库类型
    @Transient
    private String depotType;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DepotConfKey.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,16 @@
package com.fzzy.async.fzzy61.entity;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61DepotConfKey implements Serializable {
        private String depotId;
        private String companyId;
        public Fz61DepotConfKey(){
            super();
        }
    }

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLog.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,314 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonFormat;
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;

/**
 * çŽ¯æµç†è’¸-熏蒸作业记录
 *
 * @date 2023å¹´7月26日
 */
@Data
@Entity
@Table(name = "D_DRUG_LOG")
public class Fz61DrugLog implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "熏蒸作业单号", description = "作业日期 (yyyyMMdd) +3 ä½é¡ºåºå·")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓库")
    private String depotId;

    @Column(name = "START_")
    @PropertyDef(label = "开始时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date start;

    @Column(name = "END_")
    @PropertyDef(label = "截至时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date end;

    @Column(name = "PEST_BATCH_ID_", length = 50)
    @PropertyDef(label = "虫害检测单号")
    private String pestBatchId;

    @Column(name = "NUM_")
    @PropertyDef(label = "第几次熏蒸")
    private Integer num = 0;


    @Column(name = "MODE_", length = 1)
    @PropertyDef(label = "熏蒸方式", description = "0:粮面潮解1:布袋埋藏2:探管3:综合施药")
    private String mode;

    @Column(name = "RECIR_MODE_", length = 1)
    @PropertyDef(label = "环流熏蒸方式", description = "0:固定式布置形式1:移动式布置形式")
    private String recirMode;

    @Column(name = "hlxzynhljsjh", length = 1)
    @PropertyDef(label = "环流熏蒸与内环流技术结合", description = "0:分别使用_固定式1:分别使用_移动式2:二合一应用_单向控制3:二合一应用_双向控制")
    private String hlxzynhljsjh;

    @PropertyDef(label = "熏蒸方案制定")
    @Column(name = "xzfazd", length = 128)
    private String xzfazd;

    @PropertyDef(label = "熏蒸方案起草人")
    @Column(name = "xzfaqcr", length = 64)
    private String xzfaqcr;

    @PropertyDef(label = "熏蒸方案批准人")
    @Column(name = "xzfapzr", length = 64)
    private String xzfapzr;

    @PropertyDef(label = "熏蒸方案报备情况")
    @Column(name = "xzfabbqk", length = 64)
    private String xzfabbqk;

    @PropertyDef(label = "施药人员资质情况")
    @Column(name = "syryzzqk", length = 64)
    private String syryzzqk;

    @PropertyDef(label = "施药资质审核")
    @Column(name = "syzzsh", length = 64)
    private String syzzsh;

    @Column(name = "DRUG_NAME_", length = 64)
    @PropertyDef(label = "药剂名称")
    private String drugName;

    @PropertyDef(label = "剂型")
    @Column(name = "jx", length = 64)
    private String jx;

    @Column(name = "CONCENTRATION_", length = 50)
    @PropertyDef(label = "药剂浓度", description = "%")
    private Double concentration = 0.0;

    @Column(name = "GRAIN_DOSE_")
    @PropertyDef(label = "粮堆单位用药量", description = "g/m³")
    private Double grainDose = 0.0;

    @Column(name = "SPACE_DOSE_")
    @PropertyDef(label = "空间单位用药量", description = "g/m³")
    private Double spaceDose = 0.0;

    @Column(name = "DOSE_")
    @PropertyDef(label = "总用药量", description = "kg")
    private Double dose = 0.0;

    @PropertyDef(label = "施药方法", description = "0:潮解法1:仓外发生器2:钢瓶气")
    @Column(name = "syff", length = 1)
    private String syff;

    @PropertyDef(label = "辅助施药措施")
    @Column(name = "fzsycs", length = 128)
    private String fzsycs;

    @PropertyDef(label = "空气呼吸器及安全检查情况")
    @Column(name = "kqhqjaqjcqk", length = 128)
    private String kqhqjaqjcqk;

    @PropertyDef(label = "磷化氢检测装置调试情况")
    @Column(name = "lhqjczztsqk", length = 128)
    private String lhqjczztsqk;

    @PropertyDef(label = "氧气深度检测装置调试情况")
    @Column(name = "yqsdjczztsqk", length = 128)
    private String yqsdjczztsqk;

    @PropertyDef(label = "磷化氢报警仪安全检查")
    @Column(name = "lhqbjyaqjc", length = 128)
    private String lhqbjyaqjc;

    @PropertyDef(label = "氧气报警仪安全检查")
    @Column(name = "yqbjyaqjc", length = 128)
    private String yqbjyaqjc;

    @PropertyDef(label = "补药前仓内磷化氢浓度")
    @Column(name = "byqcnlhqnd", precision = 20, scale = 3)
    private double byqcnlhqnd;

    @PropertyDef(label = "磷化氢浓度单位", description = "1：g/m³(默认);2：ppm;3:ml/m³;4：%VOL")
    @Column(name = "nlhqnddw", length = 1)
    private String nlhqnddw = "1";

    @PropertyDef(label = "目标浓度", description = "单位：g/m³")
    @Column(name = "mbnd", precision = 20, scale = 3)
    private double mbnd;

    @PropertyDef(label = "计算补药量", description = "单位：g")
    @Column(name = "jsbyl", precision = 20, scale = 3)
    private double jsbyl;

    @PropertyDef(label = "实际补药量", description = "单位：g")
    @Column(name = "sjbyl", precision = 20, scale = 3)
    private double sjbyl;

    @PropertyDef(label = "补药方法")
    @Column(name = "byff", length = 128)
    private String byff;

    @PropertyDef(label = "作业人数")
    @Column(name = "zyrs")
    private Integer zyrs;

    @PropertyDef(label = "补药作业批准人")
    @Column(name = "byzypzr", length = 64)
    private String byzypzr;

    @PropertyDef(label = "现场指挥人")
    @Column(name = "xczhr", length = 64)
    private String xczhr;

    @PropertyDef(label = "峰值浓度", description = "单位：g/m³")
    @Column(name = "fznd", precision = 20, scale = 3)
    private double fznd;

    @PropertyDef(label = "目标浓度维持天数", description = "单位：天")
    @Column(name = "mbndwcts")
    private Integer mbndwcts;

    @PropertyDef(label = "漏气位置监测")
    @Column(name = "lswzjc", length = 128)
    private String lswzjc;

    @PropertyDef(label = "漏气部位采取的补救措施")
    @Column(name = "lqbwcqdbjcs", length = 128)
    private String lqbwcqdbjcs;

    @PropertyDef(label = "密闭时间", description = "单位：天")
    @Column(name = "mbsj")
    private Integer mbsj;

    @PropertyDef(label = "CT值")
    @Column(name = "ctz", precision = 20, scale = 3)
    private double ctz;

    @PropertyDef(label = "散气前磷化氢浓度", description = "单位：g/m³")
    @Column(name = "sqqlhqnd", precision = 20, scale = 3)
    private double sqqlhqnd;

    @Column(name = "VENTILATE_TIME_")
    @PropertyDef(label = "散气时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date ventilateTime;

    @Column(name = "VENTILATE_METHOD_", length = 100)
    @PropertyDef(label = "散气方法")
    private String ventilateMethod;

    @PropertyDef(label = "散气批准人")
    @Column(name = "sqpzr", length = 64)
    private String sqpzr;

    @PropertyDef(label = "散气持续天数", description = "单位：天")
    @Column(name = "sqcsts")
    private Integer sqcsts;

    @Column(name = "AFTER_PH3_")
    @PropertyDef(label = "散气后磷化氢浓度", description = "单位：g/m³")
    private Double afterPh3;

    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    @PropertyDef(label = "残渣收集作业时间")
    @Column(name = "czsjzysj")
    private Date czsjzysj;

    @PropertyDef(label = "残渣收集作业人数")
    @Column(name = "czsjzyrs")
    private Integer czsjzyrs;

    @PropertyDef(label = "残渣收集方法")
    @Column(name = "czsjff", length = 128)
    private String czsjff;

    @PropertyDef(label = "残渣收集作业批准人")
    @Column(name = "czsjzypzr", length = 64)
    private String czsjzypzr;

    @PropertyDef(label = "残渣处理措施")
    @Column(name = "czclcs", length = 128)
    private String czclcs;

    @PropertyDef(label = "残渣处理作业人数")
    @Column(name = "czclzyrs")
    private Integer czclzyrs;

    @PropertyDef(label = "残渣处理批准人")
    @Column(name = "czclpzr", length = 64)
    private String czclpzr;

    @PropertyDef(label = "熏蒸后活虫检出情况")
    @Column(name = "xzhhcjcqk", length = 128)
    private String xzhhcjcqk;

    @PropertyDef(label = "熏蒸后虫口密度", description = "单位：头/kg")
    @Column(name = "xzhckmd")
    private Integer xzhckmd;

    @PropertyDef(label = "培养15天后活虫数", description = "单位：头/kg")
    @Column(name = "pyswthhcs")
    private Integer pyswthhcs;

    @PropertyDef(label = "培养45天后活虫数", description = "单位：头/kg")
    @Column(name = "pysswthhcs")
    private Integer pysswthhcs;


    /**
     * 0：良好
     * 1：一般
     * 2：不好
     */
    @Column(name = "EVALUATE_", length = 1)
    @PropertyDef(label = "熏蒸评价", description = "0：良好 1：一般 2：不好")
    private String evaluate;

    @PropertyDef(label = "熏蒸负责人")
    @Column(name = "xzfzr", length = 64)
    private String xzfzr;

    @PropertyDef(label = "熏蒸作业人员")
    @Column(name = "xzzyry", length = 128)
    private String xzzyry;

    @Column(name = "USER_", length = 30)
    @PropertyDef(label = "操作人")
    private String user;

    @PropertyDef(label = "更新人")
    @Column(name = "UPDATE_USER_", length = 30)
    private String updateUser;

    @PropertyDef(label = "更新时间")
    @Column(name = "UPDATE_TIME_")
    private Date updateTime;

    @Column(name = "REMARKS_", length = 500)
    @PropertyDef(label = "备注说明")
    private String remarks;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLogApply.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,291 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fzzy.async.fzzy40.entity.Fz40DrugLogDtl;
import com.fzzy.async.fzzy40.entity.Fz40DrugLogPeople;
import com.fzzy.async.fzzy40.entity.Fz40DrugLogWay;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
import java.util.List;

/**
 * ç†è’¸å¤‡æ¡ˆä¸»è¡¨ä¿¡æ¯
 *
 * @Author:YAN
 */
@Entity
@Data
@Table(name = "D_DRUG_LOG_APPLY")
public class Fz61DrugLogApply implements Serializable {

    public static String SORT_PROP = "xzbm";

    @Id
    @Column(name = "xzbm", length = 12)
    @PropertyDef(label = "熏蒸备案编号", description = "填报日期yyyyMMdd+4位顺序号")
    private String xzbm;

    @Column(name = "DEPT_ID_", length = 21)
    @PropertyDef(label = "库区代码")
    private String deptId;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "tbrq")
    @PropertyDef(label = "填报日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date tbrq;

    @Column(name = "sqxzrq")
    @PropertyDef(label = "申请熏蒸日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date sqxzrq;

    @Column(name = "fzr", length = 20)
    @PropertyDef(label = "负责人")
    private String fzr;

    @Column(name = "fzrdh", length = 11)
    @PropertyDef(label = "负责人电话")
    private String fzrdh;

    @Column(name = "xcfzr", length = 20)
    @PropertyDef(label = "现场负责人")
    private String xcfzr;

    @Column(name = "fzrzw", length = 10)
    @PropertyDef(label = "现场负责人职务")
    private String xcfzrzw;

    @Column(name = "xcfzrdh", length = 11)
    @PropertyDef(label = "现场负责人电话")
    private String xcfzrdh;

    @Column(name = "tbr", length = 20)
    @PropertyDef(label = "填表人")
    private String tbr;

    @Column(name = "tbrdh", length = 11)
    @PropertyDef(label = "填表人电话")
    private String tbrdh;

    @Column(name = "sfszjjxd", length = 2)
    @PropertyDef(label = "是否设置警戒线(东)", description = "是或否")
    private String sfszjjxd;

    @Column(name = "sfszjjxx", length = 2)
    @PropertyDef(label = "是否设置警戒线(西)", description = "是或否")
    private String sfszjjxx;

    @Column(name = "sfszjjxn", length = 2)
    @PropertyDef(label = "是否设置警戒线(南)", description = "是或否")
    private String sfszjjxn;

    @Column(name = "sfszjjxb", length = 2)
    @PropertyDef(label = "是否设置警戒线(北)", description = "是或否")
    private String sfszjjxb;

    @Column(name = "ssxzzystqybqk", length = 1024)
    @PropertyDef(label = "实施熏蒸作业时天气预报情况")
    private String ssxzzystqybqk;

    @Column(name = "xzssgcap", length = 1024)
    @PropertyDef(label = "熏蒸安排及实施过程")
    private String xzssgcap;

    @Column(name = "aqfhjyjcccs", length = 1024)
    @PropertyDef(label = "安全防护及应急处置措施")
    private String aqfhjyjcccs;

    @Column(name = "xzzysx", length = 1024)
    @PropertyDef(label = "熏蒸注意事项")
    private String xzzysx;

    @Column(name = "DRUG_NAME_", length = 64)
    @PropertyDef(label = "药剂名称")
    private String drugName;

    @Column(name = "DRUG_TYPE_", length = 10)
    @PropertyDef(label = "药剂类型/型号")
    private String drugType;

    @Column(name = "yjyxqz")
    @PropertyDef(label = "药剂有效期至")
    private Date yjyxqz;

    @Column(name = "lqsl", precision = 20, scale = 3)
    @PropertyDef(label = "领取数量", description = "公斤")
    private Double lqsl;

    @Column(name = "sysbjfs", length = 20)
    @PropertyDef(label = "施药设备及方式")
    private String sysbjfs;

    @Column(name = "zcdd", length = 30)
    @PropertyDef(label = "暂存地点")
    private String zcdd;

    @Column(name = "lqr", length = 20)
    @PropertyDef(label = "领取人")
    private String lqr;

    @Column(name = "lqsj")
    @PropertyDef(label = "领取时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
    private Date lqsj;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "更新时间")
    private Date updateTime;


    /**
     * å‚¨ç²®ç²®æƒ…明细表
     */
    @Transient
    private List<Fz61DrugLogDtl> drugLogDtls;

    @Column(name = "DTL_ID_", length = 40)
    @PropertyDef(label = "dtlId")
    private String dtlId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓房/油罐代码")
    private String depotId;

    @Column(name = "FOOD_VARIETY_", length = 20)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

    @Column(name = "FOOD_TYPE_", length = 20)
    @PropertyDef(label = "粮食性质")
    private String foodType;

    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级")
    private String foodLevel;

    @Column(name = "NUMBER_", precision = 20, scale = 3)
    @PropertyDef(label = "粮食数量", description = "单位：吨")
    private Double number = 0.0;

    @Column(name = "PER_WET_", precision = 20, scale = 3)
    @PropertyDef(label = "水分", description = "单位：%")
    private Double perWet;

    @Column(name = "PER_IMPURITY_", precision = 20, scale = 3)
    @PropertyDef(label = "杂质", description = "单位：%")
    private Double perImpurity;

    @Column(name = "lw", precision = 20, scale = 3)
    @PropertyDef(label = "粮温")
    private Double lw;

    @Column(name = "cw", precision = 20, scale = 3)
    @PropertyDef(label = "仓温")
    private Double cw;

    @Column(name = "cnsd", precision = 20, scale = 3)
    @PropertyDef(label = "仓内湿度")
    private Double cnsd;

    @Column(name = "clfs", length = 1)
    @PropertyDef(label = "存粮方式", description = "1：散装储粮;2：包装;3：围包散存;9：其他")
    private String clfs;

    @Column(name = "rkrq")
    @PropertyDef(label = "入库日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date rkrq;

    @Column(name = "hc", length = 30)
    @PropertyDef(label = "害虫")
    private String hc;

    @Column(name = "cldjpd", length = 3)
    @PropertyDef(label = "虫粮等级判定")
    private String cldjpd;

    @Column(name = "ldtj", precision = 20, scale = 3)
    @PropertyDef(label = "粮堆体积", description = "m³")
    private Double ldtj;

    @Column(name = "kjtj", precision = 20, scale = 3)
    @PropertyDef(label = "空间体积", description = "m³")
    private Double kjtj;

    @Column(name = "lddwyyl", precision = 20, scale = 3)
    @PropertyDef(label = "粮堆单位用药量")
    private Double lddwyyl;

    @Column(name = "kjdwyyl", precision = 20, scale = 3)
    @PropertyDef(label = "空间单位用药量")
    private Double kjdwyyl;

    @Column(name = "zyyl", precision = 20, scale = 3)
    @PropertyDef(label = "总用药量")
    private Double zyyl;
    /**
     * ä»“房气密性以 500 Pa çš„压力半衰 æœŸ t åˆ†ä¸ºå››ä¸ªç­‰çº§ã€‚
     * 1：   â… çº§ï¼Œt≥300s。
     * 2：   â…¡çº§ï¼Œ120s≤t<300s。
     * 3：Ⅲ级，40s≤t<120s (平房仓) ï¼Œ 60s≤ t<120s (立筒仓、浅圆仓) ã€‚
     * 4：Ⅳ级，t<40s (平房仓) ï¼Œt<60s (立筒仓、浅圆仓) ã€‚
     */
    @Column(name = "qmx", length = 1)
    @PropertyDef(label = "气密性")
    private String qmx;

    @Column(name = "jhxzksrq")
    @PropertyDef(label = "计划熏蒸开始日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date jhxzksrq;

    @Column(name = "jhxzjsrq")
    @PropertyDef(label = "计划熏蒸结束日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date jhxzjsrq;

    /**
     * ç†è’¸å¤‡æ¡ˆæ–¹å¼
     */
    @Transient
    private List<Fz61DrugLogWay> drugLogWays;

    @Column(name = "Way_ID_", length = 40)
    @PropertyDef(label = "wayId")
    private String wayId;

    @Column(name = "xznd", precision = 20, scale = 3)
    @PropertyDef(label = "设定熏蒸浓度", description = "单位：ml/m³")
    private Double xznd;

    @Column(name = "mbsj")
    @PropertyDef(label = "密闭时间", description = "单位：天")
    private Integer mbsj;

    @Column(name = "xzfs", length = 30)
    @PropertyDef(label = "熏蒸方式")
    private String xzfs;

    @Column(name = "sqfs", length = 30)
    @PropertyDef(label = "散气方式")
    private String sqfs;

    /**
     * ç†è’¸ä½œä¸šäººå‘˜
     */
    @Transient
    private List<Fz61DrugLogPeople> drugLogPeople;

    @Transient
    @PropertyDef(label = "附件信息")
    private List<Fz61FileInfo> files;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLogApplyKey.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
package com.fzzy.async.fzzy61.entity;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61DrugLogApplyKey implements Serializable {
        private String id;
        private String deptId;
        private String standardId;

    public Fz61DrugLogApplyKey(){
            super();
        }
    }

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLogDtl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,129 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonFormat;
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;

/**
 * å®žæ–½ç†è’¸ä½œä¸šçš„储粮粮情明细表
 *
 * @Author:YAN
 */
@Entity
@Data
@Table(name = "D_DRUG_LOG_DTL")
public class Fz61DrugLogDtl implements Serializable {

    @Id
    @Column(name = "DTL_ID_", length = 40)
    @PropertyDef(label = "dtlId")
    private String dtlId;

    @Column(name = "DRUG_LOG_ID_", length = 12)
    @PropertyDef(label = "熏蒸备案编号", description = "填报日期yyyyMMdd+4位顺序号")
    private String drugLogId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓房/油罐代码")
    private String depotId;

    @Column(name = "FOOD_VARIETY_", length = 20)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

    @Column(name = "FOOD_TYPE_", length = 20)
    @PropertyDef(label = "粮食性质")
    private String foodType;

    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级")
    private String foodLevel;

    @Column(name = "NUMBER_", precision = 20, scale = 3)
    @PropertyDef(label = "粮食数量", description = "单位：吨")
    private Double number = 0.0;

    @Column(name = "PER_WET_", precision = 20, scale = 3)
    @PropertyDef(label = "水分", description = "单位：%")
    private Double perWet;

    @Column(name = "PER_IMPURITY_", precision = 20, scale = 3)
    @PropertyDef(label = "杂质", description = "单位：%")
    private Double perImpurity;

    @Column(name = "lw", precision = 20, scale = 3)
    @PropertyDef(label = "粮温")
    private Double lw;

    @Column(name = "cw", precision = 20, scale = 3)
    @PropertyDef(label = "仓温")
    private Double cw;

    @Column(name = "cnsd", precision = 20, scale = 3)
    @PropertyDef(label = "仓内湿度")
    private Double cnsd;

    @Column(name = "clfs", length = 1)
    @PropertyDef(label = "存粮方式", description = "1：散装储粮;2：包装;3：围包散存;9：其他")
    private String clfs;

    @Column(name = "rkrq")
    @PropertyDef(label = "入库日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date rkrq;

    @Column(name = "hc", length = 30)
    @PropertyDef(label = "害虫")
    private String hc;

    @Column(name = "cldjpd", length = 3)
    @PropertyDef(label = "虫粮等级判定")
    private String cldjpd;

    @Column(name = "ldtj", precision = 20, scale = 3)
    @PropertyDef(label = "粮堆体积", description = "m³")
    private Double ldtj;

    @Column(name = "kjtj", precision = 20, scale = 3)
    @PropertyDef(label = "空间体积", description = "m³")
    private Double kjtj;

    @Column(name = "lddwyyl", precision = 20, scale = 3)
    @PropertyDef(label = "粮堆单位用药量")
    private Double lddwyyl;

    @Column(name = "kjdwyyl", precision = 20, scale = 3)
    @PropertyDef(label = "空间单位用药量")
    private Double kjdwyyl;

    @Column(name = "zyyl", precision = 20, scale = 3)
    @PropertyDef(label = "总用药量")
    private Double zyyl;
    /**
     * ä»“房气密性以 500 Pa çš„压力半衰 æœŸ t åˆ†ä¸ºå››ä¸ªç­‰çº§ã€‚
     * 1：   â… çº§ï¼Œt≥300s。
     * 2：   â…¡çº§ï¼Œ120s≤t<300s。
     * 3：Ⅲ级，40s≤t<120s (平房仓) ï¼Œ 60s≤ t<120s (立筒仓、浅圆仓) ã€‚ 4：Ⅳ级，t<40s (平房仓) ï¼Œt<60s (立筒仓、浅圆仓) ã€‚
     */
    @Column(name = "qmx", length = 1)
    @PropertyDef(label = "气密性")
    private String qmx;

    @Column(name = "jhxzksrq")
    @PropertyDef(label = "计划熏蒸开始日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date jhxzksrq;

    @Column(name = "jhxzjsrq")
    @PropertyDef(label = "计划熏蒸结束日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date jhxzjsrq;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLogPeople.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
package com.fzzy.async.fzzy61.entity;

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;

/**
 * ç†è’¸ä½œä¸šäººå‘˜ä¿¡æ¯è¡¨
 *
 * @Author:YAN
 */
@Data
@Entity
@Table(name = "D_DRUG_LOG_PEOPLE")
public class Fz61DrugLogPeople implements Serializable {

    @Id
    @Column(name = "PEOPLE_ID_", length = 40)
    @PropertyDef(label = "propleId")
    private String propleId;


    @Column(name = "DRUG_LOG_ID_", length = 12)
    @PropertyDef(label = "熏蒸备案编号", description = "填报日期yyyyMMdd+4位顺序号")
    private String drugLogId;

    @Column(name = "mx", length = 20)
    @PropertyDef(label = "姓名")
    private String mx;

    @Column(name = "zw", length = 10)
    @PropertyDef(label = "职务")
    private String zw;

    @Column(name = "zyzg", length = 6)
    @PropertyDef(label = "职业资格", description = "初级/中级/高级")
    private String zyzg;

    @Column(name = "stzk", length = 10)
    @PropertyDef(label = "身体状况")
    private String stzk;

    @Column(name = "xzrwfg", length = 30)
    @PropertyDef(label = "熏蒸任务分工")
    private String xzrwfg;

    @Column(name = "sfwb", length = 2)
    @PropertyDef(label = "是否外包", description = "是/否")
    private String sfwb;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61DrugLogWay.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,46 @@
package com.fzzy.async.fzzy61.entity;

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;

/**
 * ç†è’¸å¤‡æ¡ˆæ–¹å¼è¡¨
 *
 * @Author:YAN
 */
@Data
@Entity
@Table(name = "D_DRUG_LOG_WAY")
public class Fz61DrugLogWay implements Serializable {

    @Id
    @Column(name = "WAY_ID_", length = 40)
    @PropertyDef(label = "wayId")
    private String wayId;

    @Column(name = "DRUG_LOG_ID_", length = 12)
    @PropertyDef(label = "熏蒸备案编号", description = "填报日期yyyyMMdd+4位顺序号")
    private String drugLogId;

    @Column(name = "xznd", precision = 20, scale = 3)
    @PropertyDef(label = "设定熏蒸浓度", description = "单位：ml/m³")
    private Double xznd;

    @Column(name = "mbsj")
    @PropertyDef(label = "密闭时间", description = "单位：天")
    private Integer mbsj;

    @Column(name = "xzfs", length = 30)
    @PropertyDef(label = "熏蒸方式")
    private String xzfs;

    @Column(name = "sqfs", length = 30)
    @PropertyDef(label = "散气方式")
    private String sqfs;
}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Gas.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,124 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * æ°”体业务数据信息包括浓度，氮气，压力信息 æ°”体模块：包括气体浓度
 * 
 * @author Andy
 *
 */
@Data
@Entity
@Table(name = "D_GAS")
@IdClass(Fz61GasKey.class)
public class Fz61Gas implements Serializable {

    public static String SORT_PROP = "batchId";

    @Id
    @Column(name = "BATCH_ID_", length = 40)
    @PropertyDef(label = "批次ID")
    private String batchId;

    @Id
    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码", description = "")
    private String companyId;

    @Id
    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓库ID", description = "仓库编号")
    private String depotId;

    @Column(name = "TYPE_", length = 1)
    @PropertyDef(label = "类型", description = "0-常规检测，1-熏蒸检测")
    private String type;

    @Column(name = "PER_CO2_")
    @PropertyDef(label = "二氧化碳浓度", description = "平均二氧化碳浓度(PPM)")
    private Double perCo2 = 0.0;

    @Column(name = "PER_O2_")
    @PropertyDef(label = "氧气浓度", description = "平均氧气浓度(%)")
    private Double perO2 = 0.0;

    @Column(name = "PER_PH3_")
    @PropertyDef(label = "磷化氢浓度", description = "平均磷化氢浓度(PPM)")
    private Double perPh3 = 0.0;

    @Column(name = "PER_N2_")
    @PropertyDef(label = "氮气浓度", description = "氮气浓度(%)")
    private Double perN2 = 0.0;

    @Column(name = "PER_CO2_MAX_")
    @PropertyDef(label = "二氧化碳浓度-最大", description = "二氧化碳浓度(PPM)")
    private Double perCo2Max = 0.0;

    @Column(name = "PER_O2_MAX_")
    @PropertyDef(label = "氧气浓度-最大", description = "氧气浓度(%)")
    private Double perO2Max = 0.0;

    @Column(name = "PER_PH3_MAX_")
    @PropertyDef(label = "磷化氢浓度-最大", description = "磷化氢浓度(PPM)")
    private Double perPh3Max = 0.0;

    @Column(name = "PER_N2_MAX_")
    @PropertyDef(label = "氮气浓度-最大")
    private Double perN2Max = 0.0;

    @Column(name = "PER_CO2_MIN_")
    @PropertyDef(label = "二氧化碳浓度-最小", description = "二氧化碳浓度(PPM)")
    private Double perCo2Min = 0.0;

    @Column(name = "PER_O2_MIN_")
    @PropertyDef(label = "氧气浓度-最小", description = "氧气浓度(%)")
    private Double perO2Min = 0.0;

    @Column(name = "PER_PH3_MIN_")
    @PropertyDef(label = "磷化氢浓度-最小", description = "磷化氢浓度(PPM)")
    private Double perPh3Min = 0.0;

    @Column(name = "PER_N2_MIN_")
    @PropertyDef(label = "氮气浓度-最小")
    private Double perN2Min = 0.0;

    @Column(name = "RECEIVE_DATE_")
    @PropertyDef(label = "检测时间")
    private Date receiveDate;

    @Column(name = "GAS_START_")
    @PropertyDef(label = "气体采集点开始", description = "气体配置信息")
    private int gasStart;

    @Column(name = "GAS_END_")
    @PropertyDef(label = "气体采集点截至", description = "气体配置信息")
    private int gasEnd;

    @Column(name = "CHECK_NUM_")
    @PropertyDef(label = "采集通道个数")
    private int checkNum = 0;

    @Column(name = "POINTS_", length = 2000)
    @PropertyDef(label = "采集点信息", description = "固定为：passCode,co2,o2,ph3,n2;passCode,co2,o2,ph3,n2;")
    private String points;

    @Column(name = "CHECK_USER_", length = 30)
    @PropertyDef(label = "检测人")
    private String checkUser;

    @Column(name = "BATCH_TAG_", length = 2)
    @PropertyDef(label = "生成方式", description = "01-设备采集；02-手动补录")
    private String batchTag = "01";

    @Column(name = "REMARK_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remark;


}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61GasKey.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.fzzy.async.fzzy61.entity;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61GasKey implements Serializable {
        private String batchId;
        private String companyId;
        private String depotId;
        public Fz61GasKey(){
            super();
        }
    }

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Grain.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,114 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * ç²®æƒ…数据-主表
 * <p>
 * æ›´æ–°è®°å½•ï¼š
 * 1，删除行数据的表记录，调整为数据直接文本保存主表中
 * 2，保留点位坐标信息，便于以后点位走势图查看
 *
 * @author Andy
 */
@Entity
@Table(name = "D_GRAIN")
@Data
@IdClass(Fz61GrainKey.class)
public class Fz61Grain implements Serializable {

    public static String SORT_PROP = "batchId";

    @Id
    @Column(name = "BATCH_ID_", length = 30)
    @PropertyDef(label = "批次编号")
    private String batchId;

    @Id
    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码", description = "")
    private String companyId;

    @Id
    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "所属仓库", description = "仓库编号")
    private String depotId;


    @Column(name = "TEMP_MIN_")
    @PropertyDef(label = "最低温粮温", description = "单位℃，粮情最低温")
    private Double tempMin = 0.0;

    @Column(name = "TEMP_MAX_")
    @PropertyDef(label = "最高粮温", description = "单位℃，粮情最高温")
    private Double tempMax = 0.0;

    @Column(name = "TEMP_AVE_")
    @PropertyDef(label = "平均粮温", description = "单位℃，粮情平均温度")
    private Double tempAve = 0.0;

    @Column(name = "HUMIDITY_IN_")
    @PropertyDef(label = "仓内湿度")
    private Double humidityIn;

    @Column(name = "TEMP_IN_")
    @PropertyDef(label = "仓内温度")
    private Double tempIn;

    @Column(name = "HUMIDITY_OUT_")
    @PropertyDef(label = "仓外湿度")
    private Double humidityOut;

    @Column(name = "TEMP_OUT_")
    @PropertyDef(label = "仓外温度")
    private Double tempOut;

    @Column(name = "CABLE_", length = 20)
    @PropertyDef(label = "层行列", description = "用逗号隔开的配置信息,层-行-列")
    private String cable;

    @PropertyDef(label = "筒仓层配置", description = "用-隔开的配置信息")
    @Column(name = "CABLE_CIR_", length = 20)
    private String cableCir;

    @PropertyDef(label = "油面高度", description = "用-隔开的两个值，油面高度-建筑高度")
    @Column(name = "OIL_HEIGHT_", length = 20)
    private String oilHeight;

    @Column(name = "WEATHER_", length = 20)
    @PropertyDef(label = "天气", description = "直接填写中文信息，晴，阴雨天")
    private String weather = "";

    @Column(name = "RECEIVE_DATE_")
    @PropertyDef(label = "接收时间")
    private Date receiveDate;

    @Column(name = "CHECK_USER_", length = 30)
    @PropertyDef(label = "检测人")
    private String checkUser;

    @Column(name = "REMARK_", length = 500)
    @PropertyDef(label = "备注", description = "备注")
    private String remark;

    @Column(name = "POINTS_", length = 2000)
    @PropertyDef(label = "采集点信息", description = "用逗号隔开的温度信息信息")
    private String points;

    @Column(name = "PUSH_TAG_", length = 2)
    @PropertyDef(label = "推送标记", description = "推送平台标记")
    private String pushTag;

    @Column(name = "BATCH_TAG_", length = 2)
    @PropertyDef(label = "生成方式", description = "01-设备采集；02-手动补录")
    private String batchTag = "01";

    @Transient
    @PropertyDef(label = "所属分库", description = "分库编码，非数据库字段")
    private String deptId;
}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61GrainKey.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.fzzy.async.fzzy61.entity;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61GrainKey implements Serializable {
        private String batchId;
        private String companyId;
        private String depotId;
        public Fz61GrainKey(){
            super();
        }
    }

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutPlan.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,107 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;
import java.util.List;

/**
 * è®¡åˆ’管理-主表
 * <p>
 * åŒ…括：收购计划，销售计划，轮换记录，计划执行
 *
 * @author: andy.jia
 * @description: ç‰ˆæœ¬4.0字段已审
 * @version:
 * @data:2020å¹´5月27日
 */
@Data
@Entity
@Table(name = "D_INOUT_PLAN")
public class Fz61InoutPlan implements Serializable {

    public static String SORT_PROP = "year";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "计划编码")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "所属库区")
    private String deptId;

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "计划类型")
    private String type;

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "计划名称")
    private String name;

    @Column(name = "REFERENCE_NUMBER_", length = 40)
    @PropertyDef(label = "计划文号")
    private String referenceNumber;

    @Column(name = "YEAR_", length = 10)
    @PropertyDef(label = "年份")
    private String year;

    @Column(name = "BEGIN_TIME_")
    @PropertyDef(label = "开始时间")
    private Date beginTime;

    @Column(name = "END_TIME_")
    @PropertyDef(label = "截止时间")
    private Date endTime;

    @PropertyDef(label = "计划下达单位")
    @Column(name = "jhxddw", length = 18)
    private String jhxddw;

    @PropertyDef(label = "计划下达时间")
    @Column(name = "jhxdsj")
    private Date jhxdsj;

    @Column(name = "CREATE_USER_", length = 30)
    @PropertyDef(label = "创建人")
    private String createUser;

    @Column(name = "CREATE_TIME_")
    @PropertyDef(label = "创建时间")
    private Date createTime;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;

    @Column(name = "REMARK_", length = 250)
    @PropertyDef(label = "备注")
    private String remark;

    /**
     * --------附件--------
     **/
    @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 List<Fz61InoutPlanDetail> details;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61InoutPlanDetail.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,65 @@
package com.fzzy.async.fzzy61.entity;

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;

/**
 * è®¡åˆ’，计划详细
 *
 * @DESC ç‰ˆæœ¬4.0 éªŒè¯
 */
@Data
@Entity
@Table(name = "D_INOUT_PLAN_DETAIL")
public class Fz61InoutPlanDetail implements Serializable {

    public static String SORT_PROP = "planId";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "计划明细号")
    private String id;

    @Column(name = "PLAN_ID_", length = 40)
    @PropertyDef(label = "计划编码")
    private String planId;

    @Column(name = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

    @Column(name = "FOOD_TYPE_", length = 10)
    @PropertyDef(label = "粮食性质")
    private String foodType;

    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级")
    private String foodLevel;

    @Column(name = "YEAR_", length = 10)
    @PropertyDef(label = "收获年度")
    private String year;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓库")
    private String depotId;

    @Column(name = "PLAN_NUM_", precision = 16, scale = 2)
    @PropertyDef(label = "计划数量", description = "单位：吨")
    private Double planNum;

    @Column(name = "TYPE_", length = 4)
    @PropertyDef(label = "计划类型")
    private String type;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;
}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Pest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,109 @@
package com.fzzy.async.fzzy61.entity;

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;

import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * è™«å®³ç»Ÿè®¡
 * 
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2019å¹´12月25日
 *
 */
@Data
@Entity
@Table(name = "D_PEST")
@IdClass(Fz61PestKey.class)
public class Fz61Pest implements Serializable {

    public static String SORT_PROP = "batchId";

    @Id
    @Column(name = "BATCH_ID_", length = 40)
    @PropertyDef(label = "批次ID")
    private String batchId;

    @Id
    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码", description = "")
    private String companyId;

    @Id
    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓库ID", description = "仓库编号")
    private String depotId;

    @Column(name = "PEST_MAX_")
    @PropertyDef(label = "最多数量")
    private int pestMax = 0;

    @Column(name = "METHOD_", length = 10)
    @PropertyDef(label = "虫害检测方法", description = "0-粮堆扦样；1-墙面粮面检查")
    private String method;

    @Column(name = "POSITION_", length =30)
    @PropertyDef(label = "发生部位")
    private String position;

    @Column(name = "PEST_TYPE_", length =30)
    @PropertyDef(label = "虫害种类")
    private String pestType;

    @Column(name = "PEST_LEVEL_", length =30)
    @PropertyDef(label = "虫粮等级判定")
    private String pestLevel;

    @Column(name = "PEST_ANALYSIS_", length =60)
    @PropertyDef(label = "害虫抗药性分析")
    private String pestAnalysis;

    @Column(name = "PEST_START_")
    @PropertyDef(label = "虫害采集点开始", description = "气体配置信息")
    private int pestStart;

    @Column(name = "PEST_END_")
    @PropertyDef(label = "虫害采集点截至", description = "气体配置信息")
    private int pestEnd;

    @Column(name = "CHECK_NUM_")
    @PropertyDef(label = "采集通道个数")
    private int checkNum = 0;

    @Column(name = "RECEIVE_DATE_")
    @PropertyDef(label = "检测时间")
    private Date receiveDate;

    @Column(name = "POINTS_", length = 2000)
    @PropertyDef(label = "采集点信息", description = "固定为：passCode,num;passCode,num;")
    private String points;

    @Column(name = "CHECK_USER_", length = 30)
    @PropertyDef(label = "检测人")
    private String checkUser;

    @Column(name = "BATCH_TAG_", length = 2)
    @PropertyDef(label = "生成方式", description = "01-设备采集；02-手动补录")
    private String batchTag = "01";

    @Column(name = "REMARK_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remark;


    @Override
    public String toString() {
        return "Pest [batchId=" + batchId + ", companyId=" + companyId
                + ", depotId=" + depotId + ", pestMax=" + pestMax
                + ", checkNum=" + checkNum + ", receiveDate="
                + receiveDate + ", points=" + points + ", checkUser="
                + checkUser + ", remark=" + remark + "]";
    }


}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61PestKey.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.fzzy.async.fzzy61.entity;

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61PestKey implements Serializable {
        private String batchId;
        private String companyId;
        private String depotId;
        public Fz61PestKey(){
            super();
        }
    }

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61Quality.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,173 @@
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;
import java.util.List;

/**
 * è´¨é‡ç®¡ç†ï¼Œ2023å¹´5月26日 æ ¹æ®æ–°å›½ç²®è§„优化调整
 *
 * @author chen
 */
@Data
@Entity
@Table(name = "D_M_QUALITY")
public class Fz61Quality implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键ID", description = "yyyyMMdd + 4位顺序号")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 40)
    @PropertyDef(label = "库区编码")
    private String deptId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "仓库编码")
    private String depotId;

    @Column(name = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级")
    private String foodLevel;

    @PropertyDef(label = "入库日期")
    @Column(name = "STORE_DATE_")
    private Date storeDate;

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "检验类别", description = "01：入仓验收 02：出仓检验 03：3 æœˆæœ«æ™®æ£€04：9 æœˆæœ«æ™®æ£€ 05：入仓初检 06：月度检查 07：3 æœˆæœ«åº“内普查 08：9 æœˆæœ«åº“内普查")
    private String type;

    @Column(name = "TIME_")
    @PropertyDef(label = "检验时间")
    private Date time;

    @Column(name = "UNIT_", length = 50)
    @PropertyDef(label = "检验单位")
    private String unit;

    @Column(name = "USER_", length = 50)
    @PropertyDef(label = "检验人", description = "检验人员姓名，若有多个保管员")
    private String user;

    @Column(name = "STANDARD_", length = 4)
    @PropertyDef(label = "检验依据", description = "1-国标，0-其他")
    private String standard;


    @PropertyDef(label = "指标类别", description = "1: è´¨é‡æŒ‡æ ‡æ£€éªŒ2：储存品质检验3：食品安全检验 å¦‚果同时检验了多个，用#隔开，例如：1#2#3")
    @Column(name = "zblb", length = 8)
    private String zblb;

    @Column(name = "RESULT_", length = 40)
    @PropertyDef(label = "检验结论", description = "1、质量指标填写/达标/不达标 2、储存品质指标填写“宜存”、轻度不宜存”、“重度不宜存”3、食品安全指标填写“合格”、不合格” å¤šé¡¹æŒ‡æ ‡æ—¶ä»¥#分隔，例如：达标|综合判定#宜存#合格 ")
    private String result;

    @Column(name = "spaqzbsfhg", length = 40)
    @PropertyDef(label = "食品安全指标是否合格", description = "0-不合格，1-合格")
    private String spaqzbsfhg;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "签发日期")
    @Column(name = "qfrq")
    private Date qfrq;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "报告出具时间")
    @Column(name = "bgcjsj")
    private Date bgcjsj;

    @PropertyDef(label = "审核人姓名")
    @Column(name = "shrxm", length = 64)
    private String shrxm;

    @PropertyDef(label = "扦样单编号")
    @Column(name = "qydbh", length = 64)
    private String qydbh;

    @Column(name = "CHECK_TIME_")
    @PropertyDef(label = "扦样时间", required = true)
    private Date checkTime;

    @Column(name = "CHECK_AREA_", length = 50)
    @PropertyDef(label = "扦样区域")
    private String checkArea;

    @Column(name = "CHECK_USER_", length = 50)
    @PropertyDef(label = "扦样人", required = true)
    private String checkUser;

    @PropertyDef(label = "监督人姓名")
    @Column(name = "jdrxm", length = 64)
    private String jdrxm;

    @PropertyDef(label = "样品编号")
    @Column(name = "ypbh", length = 64)
    private String ypbh;

    @PropertyDef(label = "样品数量", required = true)
    @Column(name = "ypsl", precision = 20, scale = 6)
    private Double ypsl;

    @PropertyDef(label = "代表数量")
    @Column(name = "dbsl", precision = 20, scale = 6)
    private Double dbsl;

    @PropertyDef(label = "样品等级")
    @Column(name = "ypdj", length = 2)
    private String ypdj;

    @Column(name = "NORMAL_YEAR_", length = 10)
    @PropertyDef(label = "是否正常存储年限")
    private String normalYear;

    @Column(name = "REMARK_", length = 200)
    @PropertyDef(label = "备注", description = "备注信息")
    private String remark;

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;

    @Column(name = "REPORT_TYPE_", length = 10)
    @PropertyDef(label = "报告类型", description = "1-单位检验，2-整体检验(加权平均)，3-其他")
    private String reportType;

    /**
     * åŒ–验项目明细
     */
    @Transient
    private List<Fz61CheckItem> checkItems;

    /**
     * --------附件--------
     **/
    @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;

}

 src/main/java/com/fzzy/async/fzzy61/entity/Fz61SecSnapDepot.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,64 @@
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.util.Date;

/**
 * ä»“内视频图像数据表
 */
@Data
@Entity
@Table(name = "D_SEC_SNAP_DEPOT")
public class Fz61SecSnapDepot {

    public static String SORT_PROP = "updateTime";
    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键")
    private String id;

    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;

    @Column(name = "DEPT_ID_", length = 30)
    @PropertyDef(label = "所属分库")
    private String deptId;

    @Column(name = "DEPOT_ID_", length = 50)
    @PropertyDef(label = "所属仓库")
    private String depotId;

    @Column(name = "CAMERA_ID_", length = 50)
    @PropertyDef(label = "关联摄像头")
    private String cameraId;

    @Column(name = "RESULT_", length = 30)
    @PropertyDef(label = "抓拍结果")
    private String result = "SUCCESS";

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "抓拍时间")
    private Date updateTime;

    @Column(name = "FILE_SUFFIX_", length = 4)
    @PropertyDef(label = "图像文件后缀名")
    private String fileSuffix = "jpg";

    @Column(name = "FILE_NAME_", length = 100)
    @PropertyDef(label = "文件名称")
    private String fileName;

    @Column(name = "PRESET_ ", length = 4)
    @PropertyDef(label = "预置位编号")
    private String preset;

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1023.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,231 @@
package com.fzzy.async.fzzy61.impl;

import com.alibaba.fastjson.JSON;
import com.fzzy.api.Constant;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogApply;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogDtl;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogPeople;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1023Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDrugLogDtlRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDrugLogPeopleRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDrugLogWayRep;
import com.fzzy.push.gd2022.ApiCodeConstant;
import com.fzzy.push.gd2022.dto.Gd2022Api1023;
import com.fzzy.push.gd2022.dto.Gd2022Api1023Dtl;
import com.fzzy.push.gd2022.dto.Gd2022Api1023People;
import com.fzzy.push.gd2022.dto.Gd2022Api1023Way;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * ç†è’¸å¤‡æ¡ˆä¿¡æ¯
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1023 {
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1105Rep api1105Rep;
    @Autowired
    private Fzzy61Sync1023Rep fzzy61Sync1023Rep;
    @Autowired
    private Fzzy61SyncDrugLogPeopleRep drugLogPeopleRep;
    @Autowired
    private Fzzy61SyncDrugLogWayRep drugLogWayRep;
    @Autowired
    private Fzzy61SyncDrugLogDtlRep drugLogDtlRep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;
    @Autowired
    private ApiTriggerService apiTriggerService;


    /**
     * åŒæ­¥ç†è’¸å¤‡æ¡ˆä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1023接口熏蒸备案信息开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(ApiCodeConstant.API_9201);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DrugLogApply> list = fzzy61Sync1023Rep.listDrugLogApply(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到熏蒸备案信息------------------");
                return;
            }
            List<Gd2022Api1023Dtl> dtlList;
            List<Gd2022Api1023Way> wayList;
            List<Gd2022Api1023People> peopleList;


            Gd2022Api1023 GD2022Api1023;
            Gd2022Api1023Dtl gd2022Api1023Dtl;
            Gd2022Api1023Way gd2022Api1023Way;
            Gd2022Api1023People gd2022Api1023People;

            List<ApiInfoData> apiInfoList;
            ApiInfoData infoData;
            for (Fz61DrugLogApply data : list) {

                GD2022Api1023 = new Gd2022Api1023();
                BeanUtils.copyProperties(data, GD2022Api1023);
                GD2022Api1023.setXzbm(data.getXzbm().substring(8));
                GD2022Api1023.setKqdm(kqdm);
                List<Api1102> api1102List = api1102Rep.findPushData(kqdm);
                if (null != api1102List && api1102List.size() > 0) {
                    GD2022Api1023.setKqmc(api1102List.get(0).getKqmc());
                }

                GD2022Api1023.setDwdm(kqdm.substring(0, 18));
                List<Api1101> api1101List = api1101Rep.findPushData(kqdm);
                if (null != api1101List && api1101List.size() > 0) {
                    GD2022Api1023.setDwmc(api1101List.get(0).getDwmc());
                }
                GD2022Api1023.setYjmc(data.getDrugName());
                GD2022Api1023.setYjlx(data.getDrugType());
                GD2022Api1023.setLqrq(data.getLqsj());
                GD2022Api1023.setZhgxsj(data.getUpdateTime());
                if (data.getLqr().contains("、")) {
                    GD2022Api1023.setLqr(data.getLqr().replace('、', '|'));
                }

                //储粮粮情明细表
                List<Fz61DrugLogDtl> dtls = drugLogDtlRep.listDrugLogDtl(data.getXzbm());
                Api1105 api1105 = commonService.getApi1105Cache(data.getDepotId());
                gd2022Api1023Dtl = new Gd2022Api1023Dtl();
                BeanUtils.copyProperties(data, gd2022Api1023Dtl);
                if (null != api1105) {
                    gd2022Api1023Dtl.setCfmc(api1105.getHwmc());
                    gd2022Api1023Dtl.setCfdm(api1105.getHwdm().substring(0, 25));
                }

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, data.getFoodVariety());
                gd2022Api1023Dtl.setLspzdm(mappingCode);
                gd2022Api1023Dtl.setLsxzdm(data.getFoodType());
                gd2022Api1023Dtl.setLsdjdm(data.getFoodLevel());
                gd2022Api1023Dtl.setLssl(data.getNumber());
                gd2022Api1023Dtl.setSf(data.getPerWet());
                gd2022Api1023Dtl.setZz(data.getPerImpurity());


                dtlList = new ArrayList<>();
                dtlList.add(gd2022Api1023Dtl);
                GD2022Api1023.setDtls(dtlList);
//                if (null != dtls && dtls.size() > 0) {
//                    dtlList = new ArrayList<>();
//                    for (Fz61DrugLogDtl dtl : dtls) {
//                        gdApi1023Dtl = new GdApi1023Dtl();
//                        BeanUtils.copyProperties(dtl, gdApi1023Dtl);
//                        gdApi1023Dtl.setCfdm(dtl.getDepotId());
//                        gdApi1023Dtl.setLspzdm(dtl.getFoodVariety());
//                        gdApi1023Dtl.setLsxzdm(dtl.getFoodType());
//                        gdApi1023Dtl.setLsdjdm(dtl.getFoodLevel());
//                        gdApi1023Dtl.setLssl(dtl.getNumber());
//                        gdApi1023Dtl.setSf(dtl.getPerWet());
//                        gdApi1023Dtl.setZz(dtl.getPerImpurity());
//                        dtlList.add(gdApi1023Dtl);
//                    }
//                    gdApi1023.setDtls(dtlList);
//                }


                gd2022Api1023Way = new Gd2022Api1023Way();
                BeanUtils.copyProperties(data, gd2022Api1023Way);
                wayList = new ArrayList<>();
                wayList.add(gd2022Api1023Way);
                GD2022Api1023.setWays(wayList);
//                List<Fz61DrugLogWay> ways = drugLogWayRep.listDrugLogWay(data.getXzbm());
//                if (null != ways && ways.size() > 0) {
//                    wayList = new ArrayList<>();
//                    for (Fz61DrugLogWay way : ways) {
//                        gdApi1023Way = new GdApi1023Way();
//                        BeanUtils.copyProperties(way, gdApi1023Way);
//                        wayList.add(gdApi1023Way);
//                    }
//                    gdApi1023.setWays(wayList);
//                }

                List<Fz61DrugLogPeople> peoples = drugLogPeopleRep.listDrugLogPeople(data.getXzbm());
                if (null != peoples && peoples.size() > 0) {
                    peopleList = new ArrayList<>();
                    for (Fz61DrugLogPeople people : peoples) {
                        gd2022Api1023People = new Gd2022Api1023People();
                        BeanUtils.copyProperties(people, gd2022Api1023People);
                        gd2022Api1023People.setXm(people.getMx());
                        if (StringUtils.isEmpty(people.getZyzg())) {
                            gd2022Api1023People.setZyzg("中级");
                        }
                        peopleList.add(gd2022Api1023People);
                    }
                    GD2022Api1023.setPeoples(peopleList);
                }
                //持久化保存，单独存入非国标接口表
                infoData = new ApiInfoData();

                infoData.setKqdm(kqdm);
                infoData.setInteType(Constant.API_CATEGORY_13);
                infoData.setInteId(ApiCodeConstant.API_9201);
                infoData.setBizType(PushProtocol.SB_GD_2023.getCode());
                infoData.setUpdateTime(new Date());
                infoData.setDataId(data.getXzbm());
                apiInfoList = apiInfoDataRep.getDataByInteAndData(ApiCodeConstant.API_9201, data.getXzbm(), kqdm);

                if (null == apiInfoList || apiInfoList.isEmpty()) {
                    GD2022Api1023.setCzbz(Constant.CZBZ_I);
                    infoData.setCzbz(Constant.CZBZ_I);
                    infoData.setId(ContextUtil.getUUID());
                } else {
                    GD2022Api1023.setCzbz(apiInfoList.get(0).getCzbz());
                    infoData.setCzbz(apiInfoList.get(0).getCzbz());
                    infoData.setId(apiInfoList.get(0).getId());
                }

                infoData.setData(JSON.toJSONString(GD2022Api1023));

                //保存数据
                apiInfoDataRep.save(infoData);
                log.info("1023---同步数据：{}", GD2022Api1023.toString());
            }

        } catch (Exception e) {
            log.error("---熏蒸备案同步执行失败----{}", e.toString());
            apiLog.setResult("熏蒸备案信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1302.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,284 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1302;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1302Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Grain;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1302Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;


/**
 * æ¸©æ¹¿åº¦æ£€æµ‹æ•°æ®åŒæ­¥
 *
 * @author czt
 * @date 2022-09-07 14:41
 */
@Slf4j
@Component
public class Fzzy61Sync1302 {

    @Autowired
    private Fzzy61Sync1302Rep fzzySync1302Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1302Rep api1302Rep;
    @Autowired
    private ApiLogRep apiLogRep;


    /**
     * åŒæ­¥å¹¶å°è£…保存温湿度检测数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1302接口温湿度数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1302);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Grain> list = fzzySync1302Rep.findByReceiveDate(start, end);

            if (null == list || list.isEmpty()) {
                log.info("1302温湿度---同步数据：没有查询到需要同步的数据");
                return;
            }

            Date syncTime = new Date();
            Api1302 api1302;
            Api1105 api1105;
            List<Api1302> api1302List;
            for (Fz61Grain fz61Grain : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz61Grain.getDepotId());
                if (null == api1105) {
                    continue;
                }

                //由货位代码+检测日期     ï¼ˆyyyyMMdd） +4 ä½é¡ºåºå·ç»„成  --2019 1128 0819
                api1302 = new Api1302();
                api1302.setWsdjcdh(api1105.getHwdm() + fz61Grain.getBatchId());
                api1302.setJcsj(fz61Grain.getReceiveDate());
                api1302.setHwdm(api1105.getHwdm());

                api1302.setCfww(fz61Grain.getTempOut() == null ? 0.00 : fz61Grain.getTempOut());
                if (null == fz61Grain.getHumidityOut() || fz61Grain.getHumidityOut() < 0) {
                    api1302.setCfws(-1);
                } else {
                    api1302.setCfws(fz61Grain.getHumidityOut());
                }

                api1302.setCfnw(fz61Grain.getTempIn() == null ? 0.00 : fz61Grain.getTempIn());
                if (null == fz61Grain.getHumidityIn() || fz61Grain.getHumidityIn() < 0) {
                    api1302.setCfns(0);
                } else {
                    api1302.setCfns(fz61Grain.getHumidityIn());
                }

                api1302.setLszgw(fz61Grain.getTempMax() == null ? 0.00 : fz61Grain.getTempMax());
                api1302.setLspjw(fz61Grain.getTempAve() == null ? 0.00 : fz61Grain.getTempAve());
                api1302.setLszdw(fz61Grain.getTempMin() == null ? 0.00 : fz61Grain.getTempMin());

                //判断粮食最低温、平均温、最高温是否符合逻辑
                if (api1302.getLszdw() >= api1302.getLspjw()) {
                    continue;
                }
                if (api1302.getLspjw() >= api1302.getLszgw()) {
                    continue;
                }

                //温度集合
                if (StringUtils.isEmpty(fz61Grain.getCableCir())) {
                    api1302.setLswdzjh(getTempPointList1(fz61Grain.getPoints(), fz61Grain.getCable()));
                    api1302.setLssdzjh(getHumPointList1(fz61Grain.getPoints(), fz61Grain.getCable()));
                    if(StringUtils.isEmpty(api1302.getLswdzjh())){
                        continue;
                    }
                    if(StringUtils.isEmpty(api1302.getLssdzjh())){
                        continue;
                    }
                } else {
                    api1302.setLswdzjh(getTempPointList2(fz61Grain.getPoints(), fz61Grain.getCable(), fz61Grain.getCableCir()));
                    api1302.setLssdzjh(getHumPointList2(fz61Grain.getPoints(), fz61Grain.getCable(), fz61Grain.getCableCir()));
                    if(StringUtils.isEmpty(api1302.getLswdzjh())){
                        continue;
                    }
                    if(StringUtils.isEmpty(api1302.getLssdzjh())){
                        continue;
                    }
                }

                api1302.setZhgxsj(new Date());

                api1302.setBizId(fz61Grain.getBatchId());
                api1302.setKqdm(api1105.getKqdm());
                api1302.setSyncTime(syncTime);
                api1302List = api1302Rep.getDataByWsdjcdh(api1302.getWsdjcdh());
                if (null == api1302List || api1302List.isEmpty()) {
                    api1302.setCzbz(Constant.CZBZ_I);
                } else {
                    api1302.setCzbz(api1302List.get(0).getCzbz());
                }
                log.info("1302温湿度---同步数据：" + api1302.toString());
                api1302Rep.save(api1302);
            }

        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }

    }

    public static void main(String[] args) {
        String point = "31.8,20.0,15.1,18.6,28.2,14.3,11.3,16.1,28.1,15.6,13.3,18.4,28.8,16.6,10.2,14.4,27.8,14.3,10.8,16.0,27.5,14.5,11.7,17.1,26.5,13.6,10.1,15.0,29.7,17.4,13.8,17.8,29.7,18.6,15.0,18.6,26.4,13.5,9.2,13.1,27.6,11.8,8.9,13.5,28.1,12.0,8.6,12.8,27.8,11.6,7.6,12.4,26.1,10.8,7.5,12.6,27.8,10.3,7.1,12.0,26.1,11.3,8.5,12.7,28.6,16.9,12.9,17.7,29.1,12.3,8.8,12.1,27.4,11.9,8.6,12.8,29.0,11.5,7.6,11.1,26.9,10.2,8.0,12.7,27.0,9.6,7.7,13.5,26.7,9.5,7.1,12.3,26.3,10.7,8.4,13.4,27.6,15.9,11.5,15.8,28.7,12.6,8.7,12.2,28.1,12.2,8.8,12.5,30.3,11.9,8.0,12.0,27.9,11.1,7.8,11.5,26.3,10.1,7.8,12.0,27.2,10.5,6.9,11.1,27.1,11.6,9.5,13.6,27.4,14.8,10.7,16.6,27.7,12.4,9.1,13.0,27.7,13.2,9.0,12.8,27.5,12.1,8.1,12.6,26.6,11.8,7.3,12.3,26.8,10.5,8.0,13.3,26.3,11.0,7.6,12.5,26.1,10.6,8.5,13.5,29.8,21.3,15.5,17.8,28.3,18.2,11.6,12.8,29.4,17.4,13.0,16.1,28.4,22.3,14.6,15.4,28.7,17.5,11.8,15.2,26.5,14.6,10.9,14.8,27.8,15.3,10.3,14.8,27.6,16.7,13.6,17.4";
        String cable = "4-6-8";
        String tempPointList1 = getTempPointList1(point, cable);
        System.out.println(tempPointList1);
    }

    /**
     * èŽ·å–平方仓的温度值集合，格式：温度值,层数,行数,列数|温度值,层数,行数,列数|温度值,层数,行数,列数
     *
     * @return
     */
    private static String getTempPointList1(String point, String cable) {
        String[] cab = cable.split("-");
        int c = Integer.valueOf(cab[0]);
        int h = Integer.valueOf(cab[1]);
        int l = Integer.valueOf(cab[2]);

        String[] points = point.split(",");
        String result = "";
        if (c * h * l > points.length) {
            return result;
        }
        for (int i = 1; i <= l; i++) {
            for (int j = 1; j <= h; j++) {
                for (int z = 1; z <= c; z++) {
                    result += ("|" + points[((i-1)*h+j-1)*c + z -1] + "," + z + "," + j + "," + i);
                }
            }
        }
        if(result.length() > 0){
            result = result.substring(1);
        }
        return result;
    }

    /**
     * èŽ·å–筒仓的温度值集合，格式：温度值,圈数,点数,层数|温度值,圈数,点数,层数|温度值,圈数,点数,层数
     *
     * @return
     */
    private String getTempPointList2(String point, String cable, String cableCir) {
        String[] cab = cable.split("-");
        String[] cabCir = cableCir.split("-");

        int q = cab.length;  //圈数
        int c = Integer.valueOf(cabCir[0]);  //层数
        int g = 0;  //圈根数
        int g1 = 1;  //圈起始根数
        int g2 = 0;  //圈截止根数

        String[] points = point.split(",");
        String result = "";
        for (int i = 1; i <= q; i++) {
            g1 += g2;
            g = Integer.valueOf(cab[i - 1]);
            g2 += g;
            for (int j = g1; j <= g2; j++) {
                for (int z = 1; z <= c; z++) {
                    result += ("|" + points[(j - 1) * c + z - 1] + "," + i + "," + j + "," + z);
                }
            }

        }
        if(result.length() > 0){
            result = result.substring(1);
        }
        return result;
    }

    /**
     * èŽ·å–平方仓的湿度值集合，格式：湿度,层数,行数,列数|湿度,层数,行数,列数|湿度,层数,行数,列数
     *
     * @return
     */
    private String getHumPointList1(String point, String cable) {
        String[] cab = cable.split("-");
        int c = Integer.valueOf(cab[0]);
        int h = Integer.valueOf(cab[1]);
        int l = Integer.valueOf(cab[2]);

        // String[] points = point.split(",");
        String result = "";
        for (int i = 1; i <= l; i++) {
            for (int j = 1; j <= h; j++) {
                for (int z = 1; z <= c; z++) {
                    result += ("|" + "-1" + "," + z + "," + j + "," + i);
                }
            }
        }
        if(result.length() > 0){
            result = result.substring(1);
        }
        return result;
    }

    /**
     * èŽ·å–筒仓的湿度值集合，格式：湿度,圈数,点数,层数|湿度,圈数,点数,层数|湿度,圈数,点数,层数
     *
     * @return
     */
    private String getHumPointList2(String point, String cable, String cableCir) {
        String[] cab = cable.split("-");
        String[] cabCir = cableCir.split("-");

        int q = cab.length;  //圈数
        int c = Integer.valueOf(cabCir[0]);  //层数
        int g = 0;  //圈根数
        int g1 = 1;  //圈起始根数
        int g2 = 0;  //圈截止根数

        //  String[] points = point.split(",");
        String result = "";
        for (int i = 1; i <= q; i++) {
            g1 += g2;
            g = Integer.valueOf(cab[i - 1]);
            g2 += g;
            for (int j = g1; j <= g2; j++) {
                for (int z = 1; z <= c; z++) {
                    result += ("|" + "-1" + "," + i + "," + j + "," + z);
                }
            }

        }
        if(result.length() > 0){
            result = result.substring(1);
        }
        return result;
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1303.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,152 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1303;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1303Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Pest;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1303Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;


/**
 * è™«å®³æ£€æµ‹æ•°æ®åŒæ­¥
 *
 * @author chen
 * @date 2022-09-08 09:51
 */
@Slf4j
@Component
public class Fzzy61Sync1303 {


    @Autowired
    private Fzzy61Sync1303Rep fzzy61Sync1303Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1303Rep api1303Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存虫害检测数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1303虫害检测数据接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1303);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {

            List<Fz61Pest> list = fzzy61Sync1303Rep.findPestByReceiveDate(start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Date syncTime = new Date();
            Api1303 api1303;
            Api1105 api1105;
            List<Api1303> api1303List;
            for (Fz61Pest fz61Pest : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz61Pest.getDepotId());
                if (null == api1105) {
                    continue;
                }

                api1303 = new Api1303();
                api1303.setHcjcdh(api1105.getHwdm() + fz61Pest.getBatchId());
                api1303.setJcsj(fz61Pest.getReceiveDate());
                api1303.setHwdm(api1105.getHwdm());

                //检查害虫方法，0-远程、1-人工、2-其他
                api1303.setJchcff("0");
                //发生部位，坐标填写：x,y,z
                api1303.setFsbw("粮面");//非必填字段

                //害虫种类。多个用#隔开#TODO >> å¾…优化调整
                api1303.setHczl("21212");

                //虫口密度值集合
                String ckmdzjh = this.geeCkmdzjh(fz61Pest.getPestMax(), fz61Pest.getPoints());
                api1303.setCkmdzjh(ckmdzjh);

                //虫粮等级判定，531-基本无虫粮、532-一般虫粮、533严重虫粮、534危害虫粮
                api1303.setCldjpd("531");
                if (fz61Pest.getPestMax() > 5) {
                    api1303.setCldjpd("532");
                }
                if (fz61Pest.getPestMax() > 30) {
                    api1303.setCldjpd("533");
                }

                api1303.setZhgxsj(new Date());

                api1303.setBizId(fz61Pest.getBatchId());
                api1303.setKqdm(api1105.getKqdm());
                api1303.setSyncTime(new Date());
                api1303List = api1303Rep.getDataByHcjcdh(api1303.getHcjcdh());
                if (null == api1303List || api1303List.isEmpty()) {
                    api1303.setCzbz(Constant.CZBZ_I);
                } else {
                    api1303.setCzbz(api1303List.get(0).getCzbz());
                }
                api1303Rep.save(api1303);
            }

        } catch (Exception e) {
            log.error("---1303虫害检测数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }

    }

    /**
     * å¤´/kg，指粮食害虫值集合，与
     * å®³è™«ç§ç±»é¡ºåºå¯¹åº”，用“|”分
     * éš”，多个取样点用英文半角“，”
     * åˆ†éš”，按照取样点示意图标识顺
     * åºæŽ’列。
     *
     * @param pestMax
     * @param points
     * @return
     */
    private String geeCkmdzjh(int pestMax, String points) {

        if (StringUtils.isEmpty(points)) return "0";

        String[] attr = points.split(";");

        String result = "";
        for (String str : attr) {
            result += str.split(",")[1] + ",";
        }
        return result.substring(0, result.length() - 1);
    }


}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1304.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,141 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1304;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1304Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Gas;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1304Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * è™«å®³æ£€æµ‹æ•°æ®åŒæ­¥
 *
 * @author chen
 * @date 2022-09-08 09:51
 */
@Slf4j
@Component
public class Fzzy61Sync1304 {

    @Autowired
    private Fzzy61Sync1304Rep fzzySync1304Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1304Rep api1304Rep;

    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存气体检测数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1304气体检测数据接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Gas> list = fzzySync1304Rep.findByReceiveDate(start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1304 api1304;
            Api1105 api1105;
            List<Api1304> api1304List;
            for (Fz61Gas fz61Gas : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz61Gas.getDepotId());
                if (null == api1105) {
                    continue;
                }

                api1304 = new Api1304();
                api1304.setQtndjcdh(api1105.getHwdm() + fz61Gas.getBatchId());
                api1304.setJcsj(fz61Gas.getReceiveDate());
                api1304.setHwdm(api1105.getHwdm());
                api1304.setZylx("5");

                api1304 = updateGasInfo(api1304, fz61Gas.getPoints());

                api1304.setZhgxsj(new Date());

                api1304.setBizId(fz61Gas.getBatchId());
                api1304.setKqdm(api1105.getKqdm());
                api1304.setSyncTime(new Date());
                api1304List = api1304Rep.getDataByQtndjcdh(api1304.getQtndjcdh());
                if (null == api1304List || api1304List.isEmpty()) {
                    api1304.setCzbz(Constant.CZBZ_I);
                } else {
                    api1304.setCzbz(api1304List.get(0).getCzbz());
                }
                api1304Rep.save(api1304);
            }
        } catch (Exception e) {
            log.error("---1304气体检测数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

    /**
     * èŽ·å–对应气体浓度集合：passCode,co2,o2,ph3,n2;passCode,co2,o2,ph3,n2;
     *
     * @param points
     * @return
     */
    private Api1304 updateGasInfo(Api1304 api1304, String points) {
        String[] attr = points.split(";");

        String[] arrt2;
        String o2 = "", co2 = "", ph3 = "", n2 = "";
        for (String temp : attr) {
            arrt2 = temp.split(",");
            o2 +=  "," + arrt2[2];
            co2 += "," + arrt2[1];
            ph3 += "," + arrt2[3];
            n2 += "," + arrt2[4];
        }

        if(o2.length() > 0){
            o2 = o2.substring(1);
        }
        if(co2.length() > 0){
            co2 = co2.substring(1);
        }
        if(ph3.length() > 0){
            ph3 = ph3.substring(1);
        }
        if(n2.length() > 0){
            n2 = n2.substring(1);
        }
        co2 += "|ppm";
        ph3 += "|ppm";
        api1304.setYqhlzjh(o2);
        api1304.setEyhthlzjh(co2);
        api1304.setLhqndzjh(ph3);
        api1304.setDqndzjh(n2);
        return api1304;
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1305.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,115 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1305;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1305Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61AreationData;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1305Rep;
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;

/**
 * é€šé£Žæ•°æ®åŒæ­¥
 *
 * @author chen
 * @date 2022-09-08 09:51
 */
@Slf4j
@Component
public class Fzzy61Sync1305 {

    @Autowired
    private Fzzy61Sync1305Rep fzzySync1305Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1305Rep api1305Rep;

    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存气通风数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1305通风数据接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1305);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61AreationData> list = fzzySync1305Rep.findByReceiveDate(start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1305 api1305;
            Api1105 api1105;
            List<Api1305> api1305List;
            for (Fz61AreationData fzAreationData : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fzAreationData.getDepotId());
                if (null == api1105) {
                    continue;
                }

                api1305 = new Api1305();

                BeanUtils.copyProperties(fzAreationData, api1305);

                api1305.setTfzydh(api1105.getHwdm() + fzAreationData.getId());
                api1305.setTfrq(fzAreationData.getStartTime());
                api1305.setCfdm(api1105.getHwdm().substring(0,25));
                api1305.setTfmd(fzAreationData.getObjective());
                api1305.setTflx(fzAreationData.getType());
                api1305.setFdxs(fzAreationData.getWindNetType());
                api1305.setFdxs(fzAreationData.getWindNetType());
                api1305.setSffs(fzAreationData.getAirSupplyMode());
                api1305.setZhdl(fzAreationData.getTotalEs());
                api1305.setZyqpjlw(fzAreationData.getBeforeTempAvg());
                api1305.setJshpjlw(fzAreationData.getAfterTempAvg());
                api1305.setZyhpjsf(fzAreationData.getBeforPerWetAvg());
                api1305.setZyhpjsf(fzAreationData.getAfterPerWetAvg());
                api1305.setTfzyfzr(fzAreationData.getChargeUser());
                api1305.setTfzyry(fzAreationData.getOperators());
                api1305.setTfsc(fzAreationData.getLongTime());
                api1305.setZhgxsj(new Date());

                api1305.setKqdm(kqdm);
                api1305.setHwdm(api1105.getHwdm());
                api1305.setBizId(fzAreationData.getId());
                api1305List = api1305Rep.getDataById(api1305.getTfzydh());
                if (null == api1305List || api1305List.isEmpty()) {
                    api1305.setCzbz(Constant.CZBZ_I);
                } else {
                    api1305.setCzbz(api1305List.get(0).getCzbz());
                }
                api1305Rep.save(api1305);
            }
        } catch (Exception e) {
            log.error("---通风数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }


}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1306.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,128 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1303;
import com.fzzy.api.entity.Api1306;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1303Rep;
import com.fzzy.api.view.repository.Api1306Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61DrugLog;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1306Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
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;

/**
 * ç†è’¸ä½œä¸šæ•°æ®åŒæ­¥
 *
 * @author czt
 * @date 2022-09-08 09:51
 */
@Slf4j
@Component
public class Fzzy61Sync1306 {

    @Autowired
    private Fzzy61Sync1306Rep fzzySync1306Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1306Rep api1306Rep;
    @Autowired
    private Api1303Rep api1303Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存熏蒸数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1306熏蒸数据接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1306);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DrugLog> list = fzzySync1306Rep.findByReceiveDate(start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1306 api1306;
            Api1105 api1105;
            List<Api1306> api1306List;
            List<Api1303> api1303List;
            for (Fz61DrugLog fz61DrugLog : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz61DrugLog.getDepotId());
                if (null == api1105) {
                    continue;
                }

                api1306 = new Api1306();

                BeanUtils.copyProperties(fz61DrugLog, api1306);
                api1306.setXzzydh(api1105.getHwdm().substring(0,25) + fz61DrugLog.getId());
                api1306.setCfdm(api1105.getHwdm().substring(0,25));
                api1306.setXzkssj(fz61DrugLog.getStart());
                api1306.setXzjssj(fz61DrugLog.getEnd());
                //设置虫害检测单号
                api1306.setHcjcdh(api1105.getHwdm() + fz61DrugLog.getPestBatchId());
                api1303List = api1303Rep.getDataByBizId(fz61DrugLog.getPestBatchId());
                if (null != api1303List && api1303List.size() > 0) {
                    api1306.setHcjcdh(api1303List.get(0).getHcjcdh());
                }

                api1306.setDjcxz(fz61DrugLog.getNum());
                api1306.setCgxzfs(fz61DrugLog.getMode());
                api1306.setHlxzfs(fz61DrugLog.getRecirMode());
                api1306.setYjmc(fz61DrugLog.getDrugName());
                api1306.setNd(fz61DrugLog.getConcentration());
                api1306.setLddwyyl(fz61DrugLog.getGrainDose());
                api1306.setKjdwyyl(fz61DrugLog.getSpaceDose());
                api1306.setSyff(StringUtils.isEmpty(fz61DrugLog.getSyff())?"0":fz61DrugLog.getSyff());
                api1306.setZyyl(fz61DrugLog.getDose());
                api1306.setSqrq(fz61DrugLog.getVentilateTime());
                api1306.setSqff(fz61DrugLog.getVentilateMethod());
                api1306.setSqjsslhqnd(fz61DrugLog.getAfterPh3());
                api1306.setXzxgpj(fz61DrugLog.getEvaluate());
                api1306.setZhgxsj(new Date());

                api1306.setHwdm(api1105.getHwdm());
                api1306.setKqdm(kqdm);
                api1306.setBizId(fz61DrugLog.getId());
                api1306List = api1306Rep.getDataById(api1306.getXzzydh());
                if (null == api1306List || api1306List.isEmpty()) {
                    api1306.setCzbz(Constant.CZBZ_I);
                } else {
                    api1306.setCzbz(api1306List.get(0).getCzbz());
                }

                api1306Rep.save(api1306);
            }
        } catch (Exception e) {
            log.error("---1306熏蒸数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }


}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1307.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,161 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtils;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy61.entity.Fz61SecSnapDepot;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1307Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * ä»“内视频图像
 * @author czt
 */
@Slf4j
@Component
public class Fzzy61Sync1307 {

    @Autowired
    private Fzzy61Sync1307Rep fzzySync1307Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1111Rep api1111Rep;
    @Autowired
    private Api1307Rep api1307Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private FileUtils fileUtil;
    @Autowired
    private ApiConfsRep apiConfsRep;

    /**
     * åŒæ­¥ä»“内抓拍文件信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1307仓内视频图像接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1109);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取仓内抓拍图片
            List<Fz61SecSnapDepot> list = fzzySync1307Rep.listSnapDepotData(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到文件信息------------------");
                return;
            }
            Api1105 api1105;
            Api1307 apiData;
            List<Api1307> api1307List;
            List<Api1111> api1111List;
            Api1109 api1109;
            List<Api1109> api1109List;
            for (Fz61SecSnapDepot sysData : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }
                api1111List = api1111Rep.getApi1111ByBizId(sysData.getCameraId());
                if (null == api1111List || api1111List.isEmpty()) {
                    log.error("-------------没有获取到仓内视频点位信息------------------");
                    return;
                }

                apiData = new Api1307();
                //主键id
                apiData.setId(sysData.getFileName().replace(sysData.getDepotId() + "_", api1105.getHwdm()).replace(".jpg", ""));

                //查询摄像头对应监控设备ID
                apiData.setSpjksbid(api1111List.get(0).getSpjksbid());
                apiData.setCfdm(api1105.getHwdm().substring(0,25));

                apiData.setHwdm(api1105.getHwdm());
                apiData.setZpsj(sysData.getUpdateTime());
                apiData.setTxwjhzm("jpg");
                apiData.setYzwbh(apiData.getHwdm() + "01");
                //文件路径
                apiData.setWjdz(fileUtil.getSnapFilePath(sysData.getUpdateTime()) + sysData.getFileName());

                //操作标志及最后更新时间
                apiData.setZhgxsj(new Date());
                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);

                //上海省平台使用廒间代码、图像编码两个字段
                apiData.setAjdh(api1105.getHwdm().substring(0,28));
                apiData.setTxbh(sysData.getFileName().replace(sysData.getDepotId() + "_", api1105.getHwdm()));

                api1307List = api1307Rep.getDataByBizId(apiData.getBizId());
                if (null == api1307List || api1307List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1307List.get(0).getCzbz());
                }

                //保存数据
                api1307Rep.save(apiData);
                log.info("1307---同步数据：{}", apiData.toString());

                //若为上海省平台协议，则需同时同步文件信息
                List<ApiConfs> apiConfs = apiConfsRep.getDataByKqdm(kqdm);
                if(null != apiConfs && PushProtocol.SB_SH_2023.getCode().equals(apiConfs.get(0).getPushProtocol())){
                    api1109 = new Api1109();
                    //主键id
                    api1109.setId(apiData.getId());
                    //文件路径
                    api1109.setWjdz(apiData.getWjdz());
                    //文件名称
                    api1109.setWjmc(apiData.getTxbh());
                    //文件类型
                    api1109.setWjlx("7"); //7-仓内视频图像
                    //操作标志及最后更新时间
                    api1109.setZhgxsj(new Date());

                    //业务id、库区编码、同步时间
                    api1109.setBizId(apiData.getBizId());
                    api1109.setKqdm(kqdm);
                    api1109.setSyncTime(new Date());
                    api1109List = api1109Rep.getDataByBizId(api1109.getBizId());
                    if (null == api1109List || api1109List.isEmpty()) {
                        api1109.setCzbz(Constant.CZBZ_I);
                    } else {
                        api1109.setCzbz(api1109List.get(0).getCzbz());
                    }
                    //保存数据
                    api1109Rep.save(api1109);
                }

            }
        } catch (Exception e) {
            log.error("---仓内抓拍同步执行失败----{}", e.toString());
            apiLog.setResult("同步仓内抓拍失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1310.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,186 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1310;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.GbCheckItem;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1310Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.GbCheckItemRep;
import com.fzzy.async.fzzy61.entity.Fz61CheckItem;
import com.fzzy.async.fzzy61.entity.Fz61Quality;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1203Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1310Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * è´¨æ£€åŒæ­¥
 *
 * @author czt
 * @date 2023-05-14 19:51
 */
@Slf4j
@Component
public class Fzzy61Sync1310 {

    @Autowired
    private Fzzy61Sync1310Rep fzzySync1310Rep;
    @Autowired
    private Fzzy61Sync1203Rep fzzySync1203Rep;
    @Autowired
    private GbCheckItemRep gbCheckItemRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1310Rep api1310Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1310质检接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Quality> list = fzzySync1310Rep.findDateByTime(deptId, start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1310 api1310;
            Api1105 api1105;
            List<Fz61CheckItem> fz61CheckItems;
            List<GbCheckItem> gbCheckList;
            String jyxm;
            String jyz;
            List<Api1310> api1310List;

            for (Fz61Quality fz61Quality : list) {
                api1105 = commonService.getApi1105Cache(fz61Quality.getDepotId());
                if (null == api1105) {
                    continue;
                }
                api1310 = new Api1310();
                if (fz61Quality.getId().contains("ZJ_")) {
                    api1310.setZjbgdh(fz61Quality.getType() + fz61Quality.getId().substring(3));
                } else {
                    api1310.setZjbgdh(fz61Quality.getType() + fz61Quality.getId());
                }
                api1310.setHwdm(api1105.getHwdm());
                api1310.setKqdm(kqdm);
                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, fz61Quality.getFoodVariety().substring(0, 3));
                api1310.setLspzdm(mappingCode);

                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, fz61Quality.getFoodLevel());
                api1310.setLsdjdm(mappingCode);
                api1310.setRkrq(fz61Quality.getStoreDate());
                api1310.setJylb(fz61Quality.getType());
                api1310.setJysj(fz61Quality.getTime());
                api1310.setJydw(StringUtils.isEmpty(fz61Quality.getUnit()) ? "检验单位" : fz61Quality.getUnit());
                api1310.setJyr(StringUtils.isEmpty(fz61Quality.getUser()) ? "检验人" : fz61Quality.getUser());
                api1310.setJyyj(fz61Quality.getStandard());
                if (StringUtils.isEmpty(fz61Quality.getZblb())) {
                    api1310.setZblb("2");
                } else {
                    api1310.setZblb(fz61Quality.getZblb());
                }

                //检测项，检测值
                jyxm = "";
                jyz = "";
                fz61CheckItems = fzzySync1203Rep.listInoutCheckItem(fz61Quality.getId(), deptId.substring(0, 4));
                if (null != fz61CheckItems && fz61CheckItems.size() > 0) {

                    for (Fz61CheckItem fz61CheckItem : fz61CheckItems) {
                        if (StringUtils.isEmpty(fz61CheckItem.getValue())) {
                            continue;
                        }
                        gbCheckList = gbCheckItemRep.findByBizCode(fz61CheckItem.getStandardId());
                        if (gbCheckList == null || gbCheckList.isEmpty()) {
                            continue;
                        }
                        jyxm += "," + gbCheckList.get(0).getCode();
                        jyz += "," + fz61CheckItem.getValue();
                    }
                }
                if(jyxm.length() > 0){
                    jyxm = jyxm.substring(1);
                }
                if(jyz.length() > 0){
                    jyz = jyz.substring(1);
                }
                api1310.setJyxm(jyxm);
                api1310.setJyxmz(jyz);

                api1310.setZbjgpd(fz61Quality.getResult());
                api1310.setQfrq(fz61Quality.getTime());
                api1310.setBgcjsj(fz61Quality.getTime());
                api1310.setShrxm(fz61Quality.getShrxm().contains("、")?fz61Quality.getShrxm().replace('、','|'):fz61Quality.getShrxm());
                if (null == fz61Quality.getCheckTime()) {
                    fz61Quality.setCheckTime(DateUtils.addDays(fz61Quality.getTime(), -1));
                }
                if (!fz61Quality.getCheckTime().before(fz61Quality.getTime())) {
                    fz61Quality.setCheckTime(DateUtils.addDays(fz61Quality.getTime(), -1));
                }
                api1310.setSpaqzbsfhg(fz61Quality.getSpaqzbsfhg());
                api1310.setQysj(fz61Quality.getCheckTime());
                api1310.setQyqy(fz61Quality.getCheckArea());
                api1310.setQyrxm(fz61Quality.getCheckUser().contains("、") ? fz61Quality.getCheckUser().replace('、', '|') : fz61Quality.getCheckUser());
                api1310.setJdrxm(fz61Quality.getCheckUser().contains("、") ? fz61Quality.getCheckUser().replace('、', '|') : fz61Quality.getCheckUser());


                api1310.setYpsl(fz61Quality.getYpsl() == null ? 0.0 : fz61Quality.getYpsl());
                api1310.setDbsl(fz61Quality.getDbsl() == null ? 0.0 : fz61Quality.getDbsl());
                api1310.setYpdj(StringUtils.isEmpty(fz61Quality.getYpdj()) ? "0" : fz61Quality.getYpdj());
                api1310.setSfzcccnx(StringUtils.isEmpty(fz61Quality.getNormalYear()) ? "0" : fz61Quality.getNormalYear());
                api1310.setBz(fz61Quality.getRemark());
                api1310.setYpbh(fz61Quality.getYpbh());
                api1310.setQydbh(fz61Quality.getQydbh());
                api1310.setZhgxsj(new Date());
                api1310.setBizId(fz61Quality.getId());

                api1310List = api1310Rep.getDataByBizId(api1310.getBizId());
                if (null == api1310List || api1310List.isEmpty()) {
                    api1310.setCzbz(Constant.CZBZ_I);
                } else {
                    api1310.setCzbz(api1310List.get(0).getCzbz());
                    api1310.setBglx(api1310List.get(0).getBglx());
                }

                api1310Rep.save(api1310);
            }
        } catch (Exception e) {
            log.error("---质检同步同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1311.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,161 @@
package com.fzzy.async.fzzy61.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.ApiInfoData;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.ApiInfoDataRep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61SecCamera;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1311Rep;
import com.fzzy.push.sh2023.SH2023Constant;
import com.fzzy.push.sh2023.dto.SH2023Api1311;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * è§†é¢‘监控
 *
 * @Author:YAN
 */
@Component
@Slf4j
public class Fzzy61Sync1311 {
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Fzzy61Sync1311Rep fzzy61Sync1311Rep;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;

    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1311接口数据开始同步------------------");
        //同步数据
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61SecCamera> list = fzzy61Sync1311Rep.findDateByDeptId(deptId);
            if (list.isEmpty() || null == list) {
                log.debug("-------------没有获取到视频监控信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            SH2023Api1311 sh2023Api1311;
            SH2023Api1311 sh1311;
            List<ApiInfoData> apiInfoDataList;
            for (Fz61SecCamera sysData : list) {
                sh2023Api1311 = new SH2023Api1311();
                sh2023Api1311.setSpjksbid(sysData.getId());
                sh2023Api1311.setTdbh(sysData.getChanNum());
                sh2023Api1311.setJksbmc(sysData.getName());
                sh2023Api1311.setKqdm(kqdm);

                //监控厂商
                sh2023Api1311.setJkcs(getBrandId(sysData.getBrand()));

                sh2023Api1311.setJkxh(sysData.getSn());

                sh2023Api1311.setSpjklx(StringUtils.isEmpty(sysData.getSpjklx()) ? "3" : sysData.getSpjklx());
                sh2023Api1311.setSblxbm("1");

                sh2023Api1311.setAzwz(sysData.getName());
                sh2023Api1311.setAzwzlx(StringUtils.isEmpty(sysData.getSpdwlx()) ? "7" : sysData.getSpdwlx());
                if (sh2023Api1311.getAzwzlx().length() == 1) {
                    sh2023Api1311.setAzwzlx("0" + sh2023Api1311.getAzwzlx());
                }
                if ("12".equals(sh2023Api1311.getAzwzlx()) || "13".equals(sh2023Api1311.getAzwzlx())
                        || "14".equals(sh2023Api1311.getAzwzlx()) || "15".equals(sh2023Api1311.getAzwzlx())) {
                    sh2023Api1311.setAzwzlx("99");
                }
                if ("16".equals(sh2023Api1311.getAzwzlx())) {
                    sh2023Api1311.setAzwzlx("12");
                }
                sh2023Api1311.setSfazbgd("Y");

                if (StringUtils.isEmpty(sysData.getType())) {
                    sysData.setType("01");
                }
                if (sysData.getType().equals("02")) {
                    sh2023Api1311.setJkjlxbm("2");
                }
                if (sysData.getType().equals("01")) {
                    sh2023Api1311.setJkjlxbm("1");
                }
                sh2023Api1311.setJktyzw(12);
                sh2023Api1311.setSbipdz(sysData.getIp());
                sh2023Api1311.setSbdkh(sysData.getControlPort());
                sh2023Api1311.setSbdlmc(sysData.getLoginId());
                sh2023Api1311.setSbdlmm(sysData.getPwd());
                sh2023Api1311.setBz(sysData.getRemark());
                sh2023Api1311.setZhgxsj(sysData.getUpdateTime() == null ? new Date() : sysData.getUpdateTime());

                //持久化保存，单独存入非国标接口表
                ApiInfoData infoData = new ApiInfoData();
                infoData.setId(sh2023Api1311.getSpjksbid());
                infoData.setKqdm(kqdm);
                infoData.setInteType(Constant.API_CATEGORY_13);
                infoData.setInteId(SH2023Constant.SH_2023_API_CODE_1311);
                infoData.setUpdateTime(sh2023Api1311.getZhgxsj());
                infoData.setDataId(sh2023Api1311.getSpjksbid());
                infoData.setRemarks("视频监控信息");
                //设置操作标志
                apiInfoDataList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_1311, infoData.getDataId(), kqdm);
                if (null == apiInfoDataList || apiInfoDataList.isEmpty()) {
                    sh2023Api1311.setCzbz(Constant.CZBZ_I);
                    infoData.setCzbz(Constant.CZBZ_I);
                } else {
                    sh2023Api1311.setCzbz(apiInfoDataList.get(0).getCzbz());
                    infoData.setCzbz(apiInfoDataList.get(0).getCzbz());
                    sh1311 = JSONObject.parseObject(apiInfoDataList.get(0).getData(), SH2023Api1311.class);
                    if (null != sh1311 && StringUtils.isNotEmpty(sh1311.getAjdm())) {
                        sh2023Api1311.setAjdm(sh1311.getAjdm());
                    }
                    if (null != sh1311 && StringUtils.isNotEmpty(sh1311.getHwdm())) {
                        sh2023Api1311.setHwdm(sh1311.getHwdm());
                    }
                }

                infoData.setData(JSON.toJSONString(sh2023Api1311));
                apiInfoDataRep.save(infoData);
                log.info("1311---视频监控-同步数据：{}", sh2023Api1311);
            }

        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

    private String getBrandId(String brandName) {
        if (StringUtils.isEmpty(brandName)) {
            return "9";
        }
        if (brandName.contains("海康")) {
            return "1";
        }
        if (brandName.contains("大华")) {
            return "2";
        }
        if (brandName.contains("宇视")) {
            return "3";
        }
        return "9";
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1403.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,111 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1403;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtils;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1403Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutPlan;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1403Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * è½®æ¢è®¡åˆ’同步
 *
 * @author czt
 * @date 2023-10-30 09:55
 */
@Slf4j
@Component
public class Fzzy61Sync1403 {

    @Autowired
    private Fzzy61Sync1403Rep fzzy61Sync1403Rep;
    @Autowired
    private FileUtils fileUtil;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1403Rep api1403Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存轮换计划数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1403轮换计划接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1403);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutPlan> list = fzzy61Sync1403Rep.findDateByTime(deptId, start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1403 api1403;
            List<Api1101> api1101List;
            List<Api1403> api1403List;
            for (Fz61InoutPlan fz61Plan : list) {
                api1403 = new Api1403();
                api1403.setLhjhdh(kqdm.substring(0, 18) + fz61Plan.getId().split("_")[1] + fz61Plan.getId().split("_")[2]);
                api1403.setJhwh(fz61Plan.getReferenceNumber());
                api1403.setJhmc(fz61Plan.getName());
                api1403.setJhnd(fz61Plan.getYear());
                api1403.setKszxrq(fz61Plan.getBeginTime());
                api1403.setJzzxrq(fz61Plan.getEndTime());
                api1101List = api1101Rep.findPushData(kqdm);
                if (null != api1101List && api1101List.size() > 0) {
                    api1403.setJhxddw(api1101List.get(0).getDwdm());
                }
                api1403.setJhxdsj(fz61Plan.getCreateTime());
                api1403.setManageWay("1"); //默认直储
                api1403.setRotationType("1"); //默认静态轮换

                //若附件id不为空，则判断是否为广东省平台协议，广东省平台协议时，需同时同步计划附件信息
                if (StringUtils.isNotEmpty(fz61Plan.getFileId())) {
                    //文件路径
                    api1403.setWjdz(fileUtil.getCommonFilePath(fz61Plan.getFileTime()) + fz61Plan.getFileId());
                    //文件名称
                    api1403.setFileName(fz61Plan.getFileName());
                }

                api1403.setZhgxsj(new Date());
                api1403.setKqdm(kqdm);
                api1403.setBizId(fz61Plan.getId());
                api1403List = api1403Rep.getDataByLhjhdh(api1403.getLhjhdh());
                if (null == api1403List || api1403List.isEmpty()) {
                    api1403.setCzbz(Constant.CZBZ_I);
                } else {
                    api1403.setCzbz(api1403List.get(0).getCzbz());
                }
                api1403Rep.save(api1403);
            }
        } catch (Exception e) {
            log.error("---1403轮换计划同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1404.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,123 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1404;
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.Api1404Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutPlan;
import com.fzzy.async.fzzy61.entity.Fz61InoutPlanDetail;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1403Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1404Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;
import java.util.List;

/**
 * è½®æ¢è®¡åˆ’明细
 *
 * @author czt
 * @date 2023-10-30 09:55
 */
@Slf4j
@Component
public class Fzzy61Sync1404 {

    @Autowired
    private Fzzy61Sync1403Rep fzzy61Sync1403Rep;
    @Autowired
    private Fzzy61Sync1404Rep fzzy61Sync1404Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1404Rep api1404Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存轮换计划明细
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1404轮换计划明细接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutPlan> list = fzzy61Sync1403Rep.findDateByTime(deptId, start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1404 api1404;
            List<Fz61InoutPlanDetail> fz61PlanDetails;
            Api1105 api1105;
            List<Api1404> api1404List;
            for (Fz61InoutPlan fz61Plan : list) {

                fz61PlanDetails = fzzy61Sync1404Rep.findDate(fz61Plan.getId());
                if (null == fz61PlanDetails || fz61PlanDetails.isEmpty()) {
                    continue;
                }
                int index = 10001;
                for (Fz61InoutPlanDetail fz61PlanDetail : fz61PlanDetails) {
                    api1105 = commonService.getApi1105Cache(fz61PlanDetail.getDepotId());
                    if (null == api1105) {
                        continue;
                    }
                    api1404 = new Api1404();
                    api1404.setLhjhdh(kqdm.substring(0, 18) + fz61PlanDetail.getPlanId().split("_")[1] + fz61PlanDetail.getPlanId().split("_")[2]);
                    api1404.setJhmxdh(api1404.getLhjhdh() + kqdm + String.valueOf(index).substring(1));

                    String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, fz61PlanDetail.getFoodVariety().substring(0,3));
                    api1404.setLspzdm(mappingCode);
                    api1404.setLsdjdm(fz61PlanDetail.getFoodLevel());
                    mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, fz61PlanDetail.getFoodType());
                    api1404.setLsxzdm(mappingCode);
                    api1404.setShnd(StringUtils.isEmpty(fz61PlanDetail.getYear())?fz61Plan.getYear():fz61PlanDetail.getYear());
                    api1404.setLhhwdm(api1105.getHwdm());
                    if(null == fz61PlanDetail.getPlanNum()){
                        fz61PlanDetail.setPlanNum(0.0);
                    }
                    api1404.setLhsl(fz61PlanDetail.getPlanNum()/1000);
                    api1404.setLhlx(fz61PlanDetail.getType());
                    api1404.setZhgxsj(new Date());
                    api1404.setKqdm(kqdm);
                    api1404.setBizId(fz61PlanDetail.getId());
                    api1404List = api1404Rep.getDataByJhmxdh(api1404.getJhmxdh());
                    if(null == api1404List || api1404List.isEmpty()){
                        api1404.setCzbz(Constant.CZBZ_I);
                    }else {
                        api1404.setCzbz(api1404List.get(0).getCzbz());
                    }
                    api1404Rep.save(api1404);
                    index ++;
                }
            }
        } catch (Exception e) {
            log.error("---轮换计划明细同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1504.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1504;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1504Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1504;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1504Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-账套信息
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1504 {

    @Autowired
    private Fzzy61Sync1504Rep fzzy61Sync1504Rep;
    @Autowired
    private Api1504Rep api1504Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1504账套信息接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1504);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1504> list = fzzy61Sync1504Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1504 api1504;
            List<Api1504> api1504List;
            for (Fz61Api1504 sysData : list) {
                api1504 = new Api1504();
                BeanUtils.copyProperties(sysData, api1504);
                api1504.setKqdm(kqdm);

                api1504List = api1504Rep.findDateById(api1504.getNacctid());
                if (null == api1504List || api1504List.isEmpty()) {
                    api1504.setCzbz(Constant.CZBZ_I);
                } else {
                    api1504.setCzbz(api1504List.get(0).getCzbz());
                }
                api1504Rep.save(api1504);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1505.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1505;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1505Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1504;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1505Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-科目信息
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1505 {

    @Autowired
    private Fzzy61Sync1505Rep fzzy61Sync1505Rep;
    @Autowired
    private Api1505Rep api1505Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1505接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1505);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1504> list = fzzy61Sync1505Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1505 api1505;
            List<Api1505> api1505List;
            for (Fz61Api1504 sysData : list) {
                api1505 = new Api1505();
                BeanUtils.copyProperties(sysData, api1505);
                api1505.setKqdm(kqdm);

                api1505List = api1505Rep.findDateById(api1505.getId());
                if(null == api1505List || api1505List.isEmpty()){
                    api1505.setCzbz(Constant.CZBZ_I);
                }else {
                    api1505.setCzbz(api1505List.get(0).getCzbz());
                }
                api1505Rep.save(api1505);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1506.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1506;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1506Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1506;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1506Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-科目余额表
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1506 {

    @Autowired
    private Fzzy61Sync1506Rep fzzy61Sync1506Rep;
    @Autowired
    private Api1506Rep api1506Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1506接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1506);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1506> list = fzzy61Sync1506Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1506 api1506;
            List<Api1506> api1506List;
            for (Fz61Api1506 sysData : list) {
                api1506 = new Api1506();
                BeanUtils.copyProperties(sysData, api1506);
                api1506.setKqdm(kqdm);

                api1506List = api1506Rep.findDateById(api1506.getId());
                if(null == api1506List || api1506List.isEmpty()){
                    api1506.setCzbz(Constant.CZBZ_I);
                }else {
                    api1506.setCzbz(api1506List.get(0).getCzbz());
                }
                api1506Rep.save(api1506);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1507.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1507;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1507Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1507;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1507Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-会计凭证信息
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1507 {

    @Autowired
    private Fzzy61Sync1507Rep fzzy61Sync1507Rep;
    @Autowired
    private Api1507Rep api1507Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1507会计凭证信息接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1507);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1507> list = fzzy61Sync1507Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1507 api1507;
            List<Api1507> api1507List;
            for (Fz61Api1507 sysData : list) {
                api1507 = new Api1507();
                BeanUtils.copyProperties(sysData, api1507);
                api1507.setKqdm(kqdm);

                api1507List = api1507Rep.findDateById(api1507.getId());
                if(null == api1507List || api1507List.isEmpty()){
                    api1507.setCzbz(Constant.CZBZ_I);
                }else {
                    api1507.setCzbz(api1507List.get(0).getCzbz());
                }
                api1507Rep.save(api1507);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1508.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1508;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1508Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1508;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1508Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-现金流量分配信息
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1508 {

    @Autowired
    private Fzzy61Sync1508Rep fzzy61Sync1508Rep;
    @Autowired
    private Api1508Rep api1508Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1508现金流量分配信息接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1508);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1508> list = fzzy61Sync1508Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1508 api1508;
            List<Api1508> api1508List;
            for (Fz61Api1508 sysData : list) {
                api1508 = new Api1508();
                BeanUtils.copyProperties(sysData, api1508);
                api1508.setKqdm(kqdm);

                api1508List = api1508Rep.findDateById(api1508.getId());
                if(null == api1508List || api1508List.isEmpty()){
                    api1508.setCzbz(Constant.CZBZ_I);
                }else {
                    api1508.setCzbz(api1508List.get(0).getCzbz());
                }
                api1508Rep.save(api1508);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1509.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1509;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1509Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1508;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1509Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-利润
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1509 {

    @Autowired
    private Fzzy61Sync1509Rep fzzy61Sync1509Rep;
    @Autowired
    private Api1509Rep api1509Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1509接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1509);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1508> list = fzzy61Sync1509Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1509 api1509;
            List<Api1509> api1509List;
            for (Fz61Api1508 sysData : list) {
                api1509 = new Api1509();
                BeanUtils.copyProperties(sysData, api1509);
                api1509.setKqdm(kqdm);

                api1509List = api1509Rep.findDateById(api1509.getId());
                if(null == api1509List || api1509List.isEmpty()){
                    api1509.setCzbz(Constant.CZBZ_I);
                }else {
                    api1509.setCzbz(api1509List.get(0).getCzbz());
                }
                api1509Rep.save(api1509);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1510.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.async.fzzy61.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1510;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1510Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Api1510;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1510Rep;
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;

/**
 * è´¢åŠ¡ç®¡ç†-资产折旧信息
 *
 * @author czt
 * @date 2024-01-12 18:55
 */
@Slf4j
@Component
public class Fzzy61Sync1510 {

    @Autowired
    private Fzzy61Sync1510Rep fzzy61Sync1510Rep;
    @Autowired
    private Api1510Rep api1510Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1510资产折旧信息接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(kqdm);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1510);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61Api1510> list = fzzy61Sync1510Rep.findDateByTime(start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1510 api1510;
            List<Api1510> api1510List;
            for (Fz61Api1510 sysData : list) {
                api1510 = new Api1510();
                BeanUtils.copyProperties(sysData, api1510);
                api1510.setKqdm(kqdm);

                api1510List = api1510Rep.findDateById(api1510.getId());
                if (null == api1510List || api1510List.isEmpty()) {
                    api1510.setCzbz(Constant.CZBZ_I);
                } else {
                    api1510.setCzbz(api1510List.get(0).getCzbz());
                }
                api1510Rep.save(api1510);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync2103.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,205 @@
package com.fzzy.async.fzzy61.impl;

import com.alibaba.fastjson.JSON;
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.ApiConfs;
import com.fzzy.api.entity.ApiInfoData;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.ApiConfsRep;
import com.fzzy.api.view.repository.ApiInfoDataRep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61Depot;
import com.fzzy.async.fzzy61.entity.Fz61DepotConf;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDepotConfRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDepotRep;
import com.fzzy.push.sh2023.SH2023Constant;
import com.fzzy.push.sh2023.dto.SH2023Api2103;
import com.fzzy.push.sh2023.dto.SH2023Api2103Item;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * ç²®æƒ…检测设备信息同步
 *
 * @author czt
 * @date 2023-08-21
 */
@Slf4j
@Component
public class Fzzy61Sync2103 {

    @Autowired
    private Fzzy61SyncDepotRep fzzy61SyncDepotRep;
    @Autowired
    private Fzzy61SyncDepotConfRep fzzy61SyncDepotConfRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private ApiConfsRep apiConfsRep;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;


    /**
     * åŒæ­¥å¹¶å°è£…保存温湿度检测数据
     *
     * @param kqdm
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1302接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1302);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //由于depotConf表中没有库区编码，先查询仓库表
            List<Fz61Depot> list = fzzy61SyncDepotRep.listDepotList(deptId);

            if (null == list || list.isEmpty()) {
                log.info("2103---粮情设备配置同步数据：没有查询到仓库信息");
                return;
            }
            List<ApiConfs> apiConf = apiConfsRep.getDataByKqdm(kqdm);
            String bjw = "";
            if (null != apiConf && apiConf.size() > 0) {
                bjw = apiConf.get(0).getUserName();
            }

            SH2023Api2103 sh2023Api2103;
            Api1105 api1105;
            List<Fz61DepotConf> depotConfList;
            Fz61DepotConf depotConf;

            List<ApiInfoData> apiInfoDataList;
            SH2023Api2103Item sh2023Api2103Item;
            List<SH2023Api2103Item> listItem;
            for (Fz61Depot fz61Depot : list) {
                //根据仓库编码获取配置信息
                depotConfList = fzzy61SyncDepotConfRep.findDataByDepotId(fz61Depot.getId());
                if (null == depotConfList || depotConfList.isEmpty()) {
                    continue;
                }
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz61Depot.getId());
                if (null == api1105) {
                    continue;
                }

                sh2023Api2103 = new SH2023Api2103();
                sh2023Api2103.setHwdm(api1105.getHwdm());
                depotConf = depotConfList.get(0);
                String[] strs = depotConf.getCableRule().split("-");

                sh2023Api2103.setDlcs(strs[0]);
                sh2023Api2103.setDlhs(strs[1]);
                sh2023Api2103.setDlls(strs[2]);

                //判断是否有层行转换
                if(null != depotConf.getStartConvert() && !"default".equals(depotConf.getStartConvert())){
                    sh2023Api2103.setDlcs(strs[1]);
                    sh2023Api2103.setDlhs(strs[0]);
                }

                // 1-3-5
                // 8-8-8
                //筒仓规则
                sh2023Api2103.setDlqs("0");
                if (StringUtils.isNotEmpty(depotConf.getCableCir())) {
                    sh2023Api2103.setDlqs(String.valueOf(strs.length));
                    sh2023Api2103.setDlhs("0");
                    sh2023Api2103.setDlls("0");

                    //电缆圈排列详情
                    listItem = new ArrayList<>();
                    String[] cableCir = depotConf.getCableCir().split("-");
                    int num1 = 0;  //起始根
                    int num2 = 0;  //截止根
                    for (int i = 0; i < cableCir.length; i++) {
                        sh2023Api2103.setDlcs(cableCir[i]);

                        sh2023Api2103Item = new SH2023Api2103Item();
                        sh2023Api2103Item.setQh(i + 1 + "");
                        if (i == 0) {
                            num1 += 1;
                        } else {
                            num1 = num2 + 1;
                        }
                        num2 += Integer.valueOf(strs[i]);
                        sh2023Api2103Item.setQsdlbh(num1 + "");
                        sh2023Api2103Item.setJsdlbh(num2 + "");
                        sh2023Api2103Item.setCs(cableCir[i]);
                        sh2023Api2103Item.setYbj((i + 1) * 4 + "");
                        sh2023Api2103Item.setRowId(i + "");
                        listItem.add(sh2023Api2103Item);
                    }
                    sh2023Api2103.setDlqplxq(JSON.toJSONString(listItem));
                }

                sh2023Api2103.setScqd("1");
                sh2023Api2103.setSczd(Integer.valueOf(strs[1]) * Integer.valueOf(strs[2]) + "");

                sh2023Api2103.setZcqd("1");
                sh2023Api2103.setZczd(Integer.valueOf(strs[1]) * Integer.valueOf(strs[2]) + "");

                sh2023Api2103.setXcqd("1");
                sh2023Api2103.setXczd(Integer.valueOf(strs[1]) * Integer.valueOf(strs[2]) + "");

                sh2023Api2103.setYxfwqsc("1");
                sh2023Api2103.setYxfwjsc(sh2023Api2103.getDlcs());

                sh2023Api2103.setBjw(bjw);
                sh2023Api2103.setZhgxsj(new Date());

                //持久化保存，单独存入非国标接口表
                ApiInfoData infoData = new ApiInfoData();
                infoData.setId(sh2023Api2103.getHwdm());
                infoData.setKqdm(kqdm);
                infoData.setInteType(Constant.API_CATEGORY_13);
                infoData.setInteId(SH2023Constant.SH_2023_API_CODE_2103);
                infoData.setUpdateTime(new Date());
                infoData.setDataId(sh2023Api2103.getHwdm());
                infoData.setRemarks("粮情设备配置信息");

                //设置操作标志
                apiInfoDataList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2103, infoData.getDataId(),kqdm);
                if (null == apiInfoDataList || apiInfoDataList.isEmpty()) {
                    infoData.setCzbz(Constant.CZBZ_I);
                    sh2023Api2103.setCzbz(Constant.CZBZ_I);
                } else {
                    infoData.setCzbz(apiInfoDataList.get(0).getCzbz());
                    sh2023Api2103.setCzbz(apiInfoDataList.get(0).getCzbz());
                }

                infoData.setData(JSON.toJSONString(sh2023Api2103));
                apiInfoDataRep.save(infoData);

                log.info("2103---粮情设备配置-同步数据：{}", sh2023Api2103.toString());
            }

        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }

    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync9201.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,211 @@
package com.fzzy.async.fzzy61.impl;

import com.alibaba.fastjson2.JSON;
import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api9201Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogApply;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogDtl;
import com.fzzy.async.fzzy61.entity.Fz61DrugLogPeople;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync9201Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDrugLogDtlRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncDrugLogPeopleRep;
import com.fzzy.push.gd2022.ApiCodeConstant;
import com.fzzy.push.gd2022.dto.Gd2022Api1023Dtl;
import com.fzzy.push.gd2022.dto.Gd2022Api1023People;
import com.fzzy.push.gd2022.dto.Gd2022Api1023Way;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

/**
 * ç†è’¸å¤‡æ¡ˆä¿¡æ¯
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync9201 {
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Fzzy61Sync9201Rep fzzy61Sync9201Rep;
    @Autowired
    private Fzzy61SyncDrugLogPeopleRep drugLogPeopleRep;
    @Autowired
    private Fzzy61SyncDrugLogDtlRep drugLogDtlRep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiTriggerService apiTriggerService;

    @Autowired
    private Api9201Rep api9201Rep;


    /**
     * åŒæ­¥ç†è’¸å¤‡æ¡ˆä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------9201接口熏蒸备案信息开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(ApiCodeConstant.API_9201);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DrugLogApply> list = fzzy61Sync9201Rep.listDrugLogApply(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到熏蒸备案信息------------------");
                return;
            }
            List<Gd2022Api1023Dtl> dtlList;
            List<Gd2022Api1023Way> wayList;
            List<Gd2022Api1023People> peopleList;

            List<Api9201> api9201List;

            Api1105 api1105;
            Api9201 api9201;
            Gd2022Api1023Dtl api9201Dtl;
            Gd2022Api1023Way api9201Way;
            Gd2022Api1023People api9201People;

            for (Fz61DrugLogApply data : list) {

                api9201 = new Api9201();
                BeanUtils.copyProperties(data, api9201);
                api9201.setBizId(data.getXzbm());
                api9201.setId(data.getXzbm());
                api9201.setXzbm(data.getXzbm().substring(8));
                api9201.setKqdm(kqdm);
                List<Api1102> api1102List = api1102Rep.findPushData(kqdm);
                if (null != api1102List && api1102List.size() > 0) {
                    api9201.setKqmc(api1102List.get(0).getKqmc());
                }

                api9201.setDwdm(kqdm.substring(0, 18));
                List<Api1101> api1101List = api1101Rep.findPushData(kqdm);
                if (null != api1101List && api1101List.size() > 0) {
                    api9201.setDwmc(api1101List.get(0).getDwmc());
                }
                api9201.setYjmc(data.getDrugName().trim());
                api9201.setYjlx(data.getDrugType().trim());
                api9201.setLqrq(data.getLqsj());
                api9201.setZhgxsj(data.getUpdateTime());
                api9201.setXcfzr(data.getXcfzr().trim());
                if (data.getLqr().contains("、")) {
                    api9201.setLqr(data.getLqr().replace('、', '|').trim());
                }

                //储粮粮情明细表
                List<Fz61DrugLogDtl> dtls = drugLogDtlRep.listDrugLogDtl(data.getXzbm());

                if (null != dtls && dtls.size() > 0) {
                    dtlList = new ArrayList<>();
                    for (Fz61DrugLogDtl dtl : dtls) {
                        api9201Dtl = new Gd2022Api1023Dtl();
                        BeanUtils.copyProperties(dtl, api9201Dtl);
                        api1105 = commonService.getApi1105Cache(dtl.getDepotId());
                        if (null != api1105) {
                            api9201Dtl.setCfmc(api1105.getHwmc());
                            api9201Dtl.setCfdm(api1105.getHwdm().substring(0, 25));
                        }

                        //粮食品种
                        String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, dtl.getFoodVariety());
                        api9201Dtl.setLspzdm(mappingCode);
                        mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, dtl.getFoodType());
                        api9201Dtl.setLsxzdm(mappingCode);
                        api9201Dtl.setLsdjdm(dtl.getFoodLevel());
                        api9201Dtl.setLssl(dtl.getNumber());
                        api9201Dtl.setSf(dtl.getPerWet());
                        api9201Dtl.setZz(dtl.getPerImpurity());
                        dtlList.add(api9201Dtl);
                    }
                    api9201.setDtl(JSON.toJSONString(dtlList));
                    api9201List = api9201Rep.getDataByBizId(api9201.getBizId());
                    if (null == api9201List || api9201List.isEmpty()) {
                        api9201.setCzbz(Constant.CZBZ_I);
                    } else {
                        api9201.setCzbz(api9201List.get(0).getCzbz());
                    }
                }
//                BeanUtils.copyProperties(data, api9201Dtl);
//                dtlList = new ArrayList<>();
//                dtlList.add(api9201Dtl);
//                api9201.setDtl(JSON.toJSONString(dtlList));


                api9201Way = new Gd2022Api1023Way();
                BeanUtils.copyProperties(data, api9201Way);
                wayList = new ArrayList<>();
                api9201Way.setSqfs(data.getSqfs().trim());
                api9201Way.setXzfs(data.getXzfs().trim());
                wayList.add(api9201Way);
                api9201.setWay(JSON.toJSONString(wayList));

                List<Fz61DrugLogPeople> peoples = drugLogPeopleRep.listDrugLogPeople(data.getXzbm());
                if (null != peoples && peoples.size() > 0) {
                    peopleList = new ArrayList<>();
                    for (Fz61DrugLogPeople people : peoples) {
                        api9201People = new Gd2022Api1023People();
                        BeanUtils.copyProperties(people, api9201People);
                        api9201People.setXm(people.getMx().trim());
                        api9201People.setZw(people.getZw().trim());
                        api9201People.setXzrwfg(people.getXzrwfg().trim());
                        api9201People.setStzk(people.getStzk().trim());
                        if (StringUtils.isEmpty(people.getZyzg())) {
                            people.setZyzg("培训合格");
                        }
                        if (StringUtils.isEmpty(people.getSfwb())) {
                            people.setSfwb("否");
                        }
                        api9201People.setZyzg(people.getZyzg().trim());
                        peopleList.add(api9201People);
                    }
                    api9201.setPeople(JSON.toJSONString(peopleList));

                    api9201List = api9201Rep.getDataByBizId(api9201.getBizId());
                    if (null == api9201List || api9201List.isEmpty()) {
                        api9201.setCzbz(Constant.CZBZ_I);
                    } else {
                        api9201.setCzbz(api9201List.get(0).getCzbz());
                    }
                }
                api9201Rep.save(api9201);
                log.info("9201---同步数据：{}", api9201.toString());
            }

        } catch (Exception e) {
            log.error("---熏蒸备案同步执行失败----{}", e);
            apiLog.setResult("熏蒸备案信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1023Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLogApply;
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;

/**
 * ç†è’¸å¤‡æ¡ˆä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1023Rep extends JpaRepository<Fz61DrugLogApply, String> {

    //查询熏蒸备案主表
    @Query("from Fz61DrugLogApply where deptId =:deptId and updateTime >=:start and updateTime <=:end")
    List<Fz61DrugLogApply> listDrugLogApply(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);

   }

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1302Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Grain;
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;

/**
 * æŸ¥è¯¢ç²®æƒ…检测数据
 *
 * @author chen
 * @date 2022-09-07 14:35
 */
public interface Fzzy61Sync1302Rep extends JpaRepository<Fz61Grain, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Grain where receiveDate >=:start and receiveDate <:end order by receiveDate ")
    List<Fz61Grain> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1303Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Pest;
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;

/**
 * æŸ¥è¯¢è™«å®³æ£€æµ‹æ•°æ®
 *
 * @author chen
 * @date 2022-09-08 09:51
 */
public interface Fzzy61Sync1303Rep extends JpaRepository<Fz61Pest, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Pest where receiveDate >=:start and receiveDate <:end order by receiveDate ")
    List<Fz61Pest> findPestByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1304Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Gas;
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;

/**
 * æŸ¥è¯¢æ°”体检测数据
 *
 * @author chen
 * @date 2022-09-08 10:42
 */
public interface Fzzy61Sync1304Rep extends JpaRepository<Fz61Gas, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Gas where receiveDate >=:start and receiveDate <:end order by receiveDate ")
    List<Fz61Gas> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1305Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61AreationData;
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;

/**
 * æŸ¥è¯¢é€šé£Žä½œä¸šæ•°æ®
 *
 * @author chen
 * @date 2022-09-08 10:42
 */
public interface Fzzy61Sync1305Rep extends JpaRepository<Fz61AreationData, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢é€šé£Žæ•°æ®
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61AreationData where updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61AreationData> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1306Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLog;
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;

/**
 * æŸ¥è¯¢é€šé£Žä½œä¸šæ•°æ®
 *
 * @author chen
 * @date 2022-09-08 10:42
 */
public interface Fzzy61Sync1306Rep extends JpaRepository<Fz61DrugLog, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢é€šé£Žæ•°æ®
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61DrugLog where updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61DrugLog> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1307Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,30 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61SecSnapDepot;
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;

/**
 * ä»“内视频图像
 *
 * @author czt
 * @date 2024-01-02
 */
public interface Fzzy61Sync1307Rep extends JpaRepository<Fz61SecSnapDepot, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–仓内抓拍信息
     *
     * @param deptId
     * @param startTime
     * @param endTime
     * @return
     */
    @Query("from Fz61SecSnapDepot where deptId=:deptId and updateTime >=:startTime and updateTime <=:endTime order by id ")
    List<Fz61SecSnapDepot> listSnapDepotData(@Param("deptId") String deptId, @Param("startTime") Date startTime, @Param("endTime") Date endTime);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1310Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Quality;
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;

/**
 * æŸ¥è¯¢è´¨æ£€æ•°æ®
 *
 * @author czt
 * @date 2023-05-14 19:55
 */
public interface Fzzy61Sync1310Rep extends JpaRepository<Fz61Quality, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Quality where deptId =:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61Quality> findDateByTime(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1311Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61SecCamera;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * @Author:YAN
 */
public interface Fzzy61Sync1311Rep extends JpaRepository<Fz61SecCamera, String> {
    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     *
     * @param deptId
     * @return
     */
    @Query("from Fz61SecCamera where deptId =:deptId ")
    List<Fz61SecCamera> findDateByDeptId(@Param("deptId") String deptId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1403Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,36 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61InoutPlan;
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;

/**
 * æŸ¥è¯¢è½®æ¢è®¡åˆ’详细
 *
 * @author czt
 * @date 2023-10-30 09:55
 */
public interface Fzzy61Sync1403Rep extends JpaRepository<Fz61InoutPlan, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutPlan where type =:planType and createTime >=:start and createTime <:end order by createTime ")
    List<Fz61InoutPlan> findDate(@Param("planType") String planType, @Param("start") Date start, @Param("end") Date end);

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutPlan where deptId =:deptId and createTime >=:start and createTime <:end order by createTime ")
    List<Fz61InoutPlan> findDateByTime(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1404Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy40.entity.Fz40InoutPlanDetail;
import com.fzzy.async.fzzy61.entity.Fz61InoutPlanDetail;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * æŸ¥è¯¢è½®æ¢è®¡åˆ’详细
 *
 * @author czt
 * @date 2023-10-30 09:55
 */
public interface Fzzy61Sync1404Rep extends JpaRepository<Fz61InoutPlanDetail, String> {

    /**
     *
     * @return
     */
    @Query("from Fz61InoutPlanDetail where planId =:planId ")
    List<Fz61InoutPlanDetail> findDate(@Param("planId") String planId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1504Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1504;
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;

/**
 * è´¢åŠ¡ç®¡ç†-利润
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1504Rep extends JpaRepository<Fz61Api1504, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1504 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1504> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1505Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1504;
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;

/**
 * è´¢åŠ¡ç®¡ç†-利润
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1505Rep extends JpaRepository<Fz61Api1504, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1504 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1504> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1506Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1506;
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;

/**
 * è´¢åŠ¡ç®¡ç†-利润
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1506Rep extends JpaRepository<Fz61Api1506, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1506 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1506> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1507Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1507;
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;

/**
 * è´¢åŠ¡ç®¡ç†-会计凭证信息
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1507Rep extends JpaRepository<Fz61Api1507, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1507 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1507> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1508Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1508;
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;

/**
 * è´¢åŠ¡ç®¡ç†-现金流量分配信息
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1508Rep extends JpaRepository<Fz61Api1508, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1508 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1508> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1509Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1508;
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;

/**
 * è´¢åŠ¡ç®¡ç†-固定资产卡片信息
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1509Rep extends JpaRepository<Fz61Api1508, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1508 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1508> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1510Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Api1510;
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;

/**
 * è´¢åŠ¡ç®¡ç†-资产折旧信息
 *
 * @author czt
 * @date 2024-01-12 09:55
 */
public interface Fzzy61Sync1510Rep extends JpaRepository<Fz61Api1510, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61Api1510 where zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61Api1510> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync9201Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,22 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLogApply;
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;

/**
 * ç†è’¸å¤‡æ¡ˆä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61Sync9201Rep extends JpaRepository<Fz61DrugLogApply, String> {

    //查询熏蒸备案主表
    @Query("from Fz61DrugLogApply where deptId =:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61DrugLogApply> listDrugLogApply(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);

   }

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncDepotConfRep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DepotConf;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * æŸ¥è¯¢ç²®æƒ…检测数据
 *
 * @author czt
 *
 * @date 2023-08-21
 */
public interface Fzzy61SyncDepotConfRep extends JpaRepository<Fz61DepotConf, String> {

    /**
     * æ ¹æ®ä»“库编码获取粮情参数配置信息
     * @param depotId
     * @return
     */
    @Query("from Fz61DepotConf where depotId =:depotId order by depotId ")
    List<Fz61DepotConf> findDataByDepotId(@Param("depotId") String depotId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncDepotRep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61Depot;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * èŽ·å–仓库信息
 *
 * @author czt
 * @date 2023-08-21
 */
public interface Fzzy61SyncDepotRep extends JpaRepository<Fz61Depot, String> {

    /**
     * æ ¹æ®åº“区编码获取货位列表
     * @param deptId
     * @return
     */
    @Query("from Fz61Depot where deptId=:deptId order by id ")
    List<Fz61Depot> listDepotList(@Param("deptId") String deptId);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncDrugLogDtlRep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLogDtl;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * ç†è’¸å¤‡æ¡ˆå­è¡¨ - ç²®æƒ…信息
 *
 * @Author:YAN
 */
public interface Fzzy61SyncDrugLogDtlRep extends JpaRepository<Fz61DrugLogDtl, String> {


    @Query("from Fz61DrugLogDtl where drugLogId =:id")
    List<Fz61DrugLogDtl> listDrugLogDtl(@Param("id") String id );

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncDrugLogPeopleRep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLogPeople;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61SyncDrugLogPeopleRep extends JpaRepository<Fz61DrugLogPeople, String> {

    @Query("from Fz61DrugLogPeople where drugLogId =:id")
    List<Fz61DrugLogPeople> listDrugLogPeople(@Param("id") String id);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncDrugLogWayRep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,19 @@
package com.fzzy.async.fzzy61.repository;

import com.fzzy.async.fzzy61.entity.Fz61DrugLogWay;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61SyncDrugLogWayRep extends JpaRepository<Fz61DrugLogWay, String> {

    @Query("from Fz61DrugLogWay where drugLogId =:id")
    List<Fz61DrugLogWay> listDrugLogWay(@Param("id") String id );
}