调整上海接口：粮食管理相关同步

CZT

2023-10-20 07ff6686da8e9922a6f5a4f276e69d045e12a044

调整上海接口：粮食管理相关同步

 src/main/java/com/fzzy/api/entity/Api1305.java

@@ -35,23 +35,23 @@

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "通风日期" )
    @Column(name = "tfrq", nullable = false)
    @Column(name = "tfrq")
    private Date tfrq;

    @PropertyDef(label = "仓房代码" )
    @Column(name = "cfdm", length = 25, nullable = false)
    @Column(name = "cfdm", length = 25)
    private String cfdm;

    @PropertyDef(label = "通风目的" )
    @Column(name = "tfmd", length = 128, nullable = false)
    @Column(name = "tfmd", length = 128)
    private String tfmd;

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

    @PropertyDef(label = "通风类型" )
    @Column(name = "tflx", length = 1, nullable = false)
    @Column(name = "tflx", length = 1)
    private String tflx;

    @PropertyDef(label = "风道型式" )
@@ -59,28 +59,28 @@
    private String fdxs;

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

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

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

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

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

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

    @PropertyDef(label = "通风口设置个数" )
    @Column(name = "tfkszgs")
@@ -95,76 +95,76 @@
    private Integer tfjts;

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

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

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

    @PropertyDef(label = "送风方式" )
    @Column(name = "sffs", length = 1, nullable = false)
    @Column(name = "sffs", length = 1)
    private String sffs;

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

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

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

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

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

    @PropertyDef(label = "总耗电量" )
    @Column(name = "zhdl", precision = 10, scale = 3)
    private double zhdl;
    @Column(name = "zhdl")
    private Double zhdl;

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

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

    @PropertyDef(label = "通风时长" )
    @Column(name = "tfsc", precision = 10, scale = 3)
    private double tfsc;
    @Column(name = "tfsc")
    private Double tfsc;

    @PropertyDef(label = "作业前平均粮温" )
    @Column(name = "zyqpjlw", precision = 10, scale = 3, nullable = false)
    private double zyqpjlw;
    @Column(name = "zyqpjlw")
    private Double zyqpjlw;

    @PropertyDef(label = "结束后平均粮温" )
    @Column(name = "jshpjlw", precision = 10, scale = 3, nullable = false)
    private double jshpjlw;
    @Column(name = "jshpjlw")
    private Double jshpjlw;

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

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

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

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

    @PropertyDef(label = "作业前平均水分" )
    @Column(name = "zyqpjsf", precision = 10, scale = 3, nullable = false)
    private double zyqpjsf;
    @Column(name = "zyqpjsf")
    private Double zyqpjsf;

    @PropertyDef(label = "结束后平均水分" )
    @Column(name = "zyhpjsf", precision = 10, scale = 3, nullable = false)
    private double zyhpjsf;
    @Column(name = "zyhpjsf")
    private Double zyhpjsf;

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

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

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

    @PropertyDef(label = "通风作业负责人" )
    @Column(name = "tfzyfzr", length = 64, nullable = false)
    @Column(name = "tfzyfzr", length = 64)
    private String tfzyfzr;

    @PropertyDef(label = "通风作业人员" )
    @Column(name = "tfzyry", length = 128, nullable = false)
    @Column(name = "tfzyry", length = 128)
    private String tfzyry;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

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

}

 src/main/java/com/fzzy/api/entity/Api1306.java

@@ -30,29 +30,29 @@

    @Id
    @PropertyDef(label = "熏蒸作业单号" )
    @Column(name = "xzzydh", length = 36, nullable = false)
    @Column(name = "xzzydh", length = 36)
    private String xzzydh;

    @PropertyDef(label = "仓房代码" )
    @Column(name = "cfdm", length = 25, nullable = false)
    @Column(name = "cfdm", length = 25)
    private String cfdm;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "熏蒸开始时间" )
    @Column(name = "xzkssj", nullable = false)
    @Column(name = "xzkssj")
    private Date xzkssj;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "熏蒸结束时间" )
    @Column(name = "xzjssj", nullable = false)
    @Column(name = "xzjssj")
    private Date xzjssj;

    @PropertyDef(label = "害虫检测单号" )
    @Column(name = "hcjcdh", length = 42, nullable = false)
    @Column(name = "hcjcdh", length = 42)
    private String hcjcdh;

    @PropertyDef(label = "封仓后熏蒸的次数 第几次熏蒸" )
    @Column(name = "djcxz", nullable = false)
    @Column(name = "djcxz")
    private Integer djcxz;

    @PropertyDef(label = "常规熏蒸方式" )
@@ -92,7 +92,7 @@
    private String syzzsh;

    @PropertyDef(label = "药剂名称" )
    @Column(name = "yjmc", length = 64, nullable = false)
    @Column(name = "yjmc", length = 64)
    private String yjmc;

    @PropertyDef(label = "剂型" )
@@ -116,7 +116,7 @@
    private Double zyyl;

    @PropertyDef(label = "施药方法" )
    @Column(name = "syff", length = 1, nullable = false)
    @Column(name = "syff", length = 1)
    private String syff;

    @PropertyDef(label = "辅助施药措施" )
@@ -213,7 +213,7 @@
    private Date sqrq;

    @PropertyDef(label = "散气方法" )
    @Column(name = "sqff", length = 128, nullable = false)
    @Column(name = "sqff", length = 128)
    private String sqff;

    @PropertyDef(label = "散气批准人" )
@@ -221,7 +221,7 @@
    private String sqpzr;

    @PropertyDef(label = "散气持续天数" )
    @Column(name = "sqcsts", nullable = false)
    @Column(name = "sqcsts")
    private Integer sqcsts;

    @PropertyDef(label = "散气结束时磷化氢浓度" )
@@ -274,7 +274,7 @@
    private Integer pysswthhcs;

    @PropertyDef(label = "熏蒸效果评价" )
    @Column(name = "xzxgpj", length = 1, nullable = false)
    @Column(name = "xzxgpj", length = 1)
    private String xzxgpj;

    @PropertyDef(label = "熏蒸负责人" )
@@ -286,12 +286,18 @@
    private String xzzyry;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

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

    /*---------系统内使用:国标和广东熏蒸单号：仓房代码+yyyyMMdd+3位顺序号；上海熏蒸单号：货位代码+yyyyMMdd+3位顺序号----------*/
    @JSONField(serialize = false)
    @PropertyDef(label = "货位代码" )
    @Column(name = "hwdm", length = 30)
    private String hwdm;

}

 src/main/java/com/fzzy/api/view/Api1305.view.xml

@@ -290,7 +290,7 @@
        <Property></Property>
        <Property name="label">操作标志</Property>
        <Property name="mapping">
          <Property name="mapValues">${dorado.getDataProvider(&quot;triggerUtil#czbz&quot;).getResult()}</Property>
          <Property name="mapValues">${dorado.getDataProvider(&quot;apiTriggerService#trigger&quot;).getResult(&quot;CZBZ&quot;)}</Property>
          <Property name="keyProperty">code</Property>
          <Property name="valueProperty">name</Property>
        </Property>

 src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java

@@ -60,38 +60,38 @@
        Date start = param.getStart();
        Date end = param.getEnd();

        //客户同步
        fzzySync1212.syncData(kqdm, deptId, start, end);

        //合同同步
        fzzySync1201.syncData(kqdm, deptId, start, end);

        //粮食入库同步
        fzzySync1202.syncData(kqdm, deptId, start, end);

        //粮食入库质检
//        //客户同步
//        fzzySync1212.syncData(kqdm, deptId, start, end);
//
//        //合同同步
//        fzzySync1201.syncData(kqdm, deptId, start, end);
//
//        //粮食入库同步
//        fzzySync1202.syncData(kqdm, deptId, start, end);
//
//        //粮食入库质检
        fzzySync1203.syncData(kqdm, deptId, start, end);

        //粮食入库结算
        fzzySync1204.syncData(kqdm, deptId, start, end);
        //粮食出库同步
        fzzySync1205.syncData(kqdm, deptId, start, end);

        //粮食出库结算
        fzzySync1206.syncData(kqdm, deptId, start, end);
        //粮食损益
        fzzySync1209.syncData(kqdm, deptId, start, end);
        //倒仓信息同步
        fzzySync1207.syncData(kqdm, deptId, start, end);

        //出入库文件信息同步
//
//        //粮食入库结算
//        fzzySync1204.syncData(kqdm, deptId, start, end);
//        //粮食出库同步
//        fzzySync1205.syncData(kqdm, deptId, start, end);
//
//        //粮食出库结算
//        fzzySync1206.syncData(kqdm, deptId, start, end);
//        //粮食损益
//        fzzySync1209.syncData(kqdm, deptId, start, end);
//        //倒仓信息同步
//        fzzySync1207.syncData(kqdm, deptId, start, end);
//
//        //出入库文件信息同步
//        fzzySync1109.syncData(kqdm, deptId, start, end);

        //粮食库存同步
        fzzySync1208.syncData(kqdm, deptId, start, end);

        //粮食性质转变信息同步
        fzzySync1210.syncData(kqdm, deptId, start, end);
//        fzzySync1210.syncData(kqdm, deptId, start, end);

        /*-----各省独有接口信息同步-----*/
//        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {

 src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java

@@ -51,31 +51,31 @@
            //熏蒸备案数据同步
            fzzySync1023.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
        }
        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
            //上海市平台2023版，需要同步粮情设备配置信息

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

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

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

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

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

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

        //通风作业信息同步
        fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
//            //上海市平台2023版，需要同步粮情设备配置信息
//
//            //同步粮情设备配置信息
//            fzzy40Sync2103.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//            //视频监控信息同步
//            fzzySync1311.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//        }
//
//        /*-----公共接口-----*/
//
//        //温湿度检测数据同步
//        fzzySync1302.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//
//        //虫害检测同步
//        fzzySync1303.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//
//        //气体检测同步
//        fzzySync1304.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//
//        //质检同步
//        fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
//
//        //通风作业信息同步
//        fzzySync1305.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

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

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40AreationData.java

@@ -47,7 +47,7 @@

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

    /**
     * 1：自然空气通风
@@ -79,23 +79,23 @@

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

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

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

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

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

    @PropertyDef(label = "通风口设置个数")
    @Column(name = "tfkszgs")
@@ -111,15 +111,15 @@

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

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

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

    /**
     * 1：压入式通风
@@ -134,23 +134,23 @@

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

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

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

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

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

    /**
     * 总耗电量 千瓦
@@ -161,11 +161,11 @@

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

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

    @Column(name = "BEFORE_TEMP_AVG_")
    @PropertyDef(label = "作业前平均粮温")
@@ -177,15 +177,15 @@

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

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

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

    @PropertyDef(label = "保水效果评价结果")
    @Column(name = "bsxgpjjg", length = 128)
@@ -217,11 +217,11 @@

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

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

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

 src/main/java/com/fzzy/async/fzzy40/entity/Fz40DrugLog.java

@@ -147,7 +147,7 @@

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

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

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

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

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

    @PropertyDef(label = "补药方法")
    @Column(name = "byff", length = 128)
@@ -183,7 +183,7 @@

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

    @PropertyDef(label = "目标浓度维持天数", description = "单位：天")
    @Column(name = "mbndwcts")
@@ -203,11 +203,11 @@

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

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

    @Column(name = "VENTILATE_TIME_")
    @PropertyDef(label = "散气时间")

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1109.java

@@ -174,6 +174,121 @@
        }
    }


//    /**
//     * 同步文件接口
//     *
//     * @param deptId
//     * @param start
//     * @param end
//     */
//    public void syncData(String kqdm, String deptId, Date start, Date end) {
//
//        log.info("-------------1109接口数据开始同步------------------");
//
//        //同步数据，只记录失败的信息
//        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<Fz40FileInfo> list = fzzySync1109Rep.listFileInfo(start, end);
//
//            if (null == list || list.isEmpty()) {
//                log.info("-------------没有获取到文件信息------------------");
//                return;
//            }
//
//            Map<String, Integer> map = new HashMap<>();
//            Api1109 apiData;
//            String wjlx;
//            String wjmc;
//            List<Api1109> api1109List;
//            List<Api1202> api1202List;
//            List<Api1205> api1205List;
//            String str = "";
//            for (Fz40FileInfo sysData : list) {
//                if (StringUtils.isEmpty(sysData.getBizId())) {
//                    continue;
//                }
//                //根据图片id查询对应出入库信息
//                if(sysData.getBizId().startsWith(IMG_START_R)){
//                    api1202List = api1202Rep.getDataByBizId(sysData.getBizId());
//                    if (null == api1202List || api1202List.isEmpty()) {
//                        continue;
//                    }
//                    str = api1202List.get(0).getRkywdh();
//                }
//                if(sysData.getBizId().startsWith(IMG_START_C)){
//                    api1205List = api1205Rep.getDataByBizId(sysData.getBizId());
//                    if (null == api1205List || api1205List.isEmpty()) {
//                        continue;
//                    }
//                    str = api1205List.get(0).getCkywdh();
//                }
//
//                //只同步称重
//                if (BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())) {
//                    wjlx = "";
//                    wjmc = kqdm;
//                    //入库抓拍图
//                    if (sysData.getBizId().startsWith(IMG_START_R)) {
//                        wjlx = IMG_TYPE_2;
//                        wjmc += "_" + Constant.INOUT_TYPE_14 + sysData.getBizId().substring(4);
//                    }
//                    //出库抓拍图
//                    if (sysData.getBizId().startsWith(IMG_START_C)) {
//                        wjlx = IMG_TYPE_3;
//                        wjmc += "_" + Constant.INOUT_TYPE_15 + sysData.getBizId().substring(4);
//                    }
//                    //若文件类型为空，则跳过
//                    if (StringUtils.isEmpty(wjlx)) {
//                        continue;
//                    }
//
//                    apiData = new Api1109();
//
//                    //主键id
//                    apiData.setId(UUID.randomUUID().toString());
//                    //文件路径
//                    apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());
//
//                    //文件名称
//                    wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
//                    apiData.setWjmc(wjmc);
//                    //文件类型
//                    apiData.setWjlx(wjlx);
//
//                    //操作标志及最后更新时间
//                    apiData.setZhgxsj(sysData.getCreateTime());
//
//                    //业务id、库区编码、同步时间
//                    apiData.setBizId(sysData.getFileId());
//                    apiData.setKqdm(kqdm);
//                    apiData.setSyncTime(new Date());
//
//                    api1109List = api1109Rep.getDataByBizId(apiData.getBizId());
//                    if (null == api1109List || api1109List.isEmpty()) {
//                        apiData.setCzbz(Constant.CZBZ_I);
//                    } else {
//                        apiData.setCzbz(api1109List.get(0).getCzbz());
//                    }
//
//                    //保存数据
//                    api1109Rep.save(apiData);
//                    log.info("1109---同步数据：{}", apiData.toString());
//                }
//            }
//        } catch (Exception e) {
//            log.error("---文件同步执行失败----{}", e);
//            apiLog.setResult("同步文件信息失败：" + e.getMessage());
//            apiLogRep.save(apiLog);
//        }
//    }

    /**
     * 获取图片命名类型
     *

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1303.java

@@ -90,6 +90,9 @@
                api1303.setHczl("21212");

                //虫口密度值集合
                if(StringUtils.isEmpty(fz40Pest.getPoints())){
                    continue;
                }
                String ckmdzjh = this.geeCkmdzjh(fz40Pest.getPestMax(), fz40Pest.getPoints());
                api1303.setCkmdzjh(ckmdzjh);


 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1305.java

@@ -76,9 +76,9 @@

                BeanUtils.copyProperties(fzAreationData, api1305);

                api1305.setTfzydh(fzAreationData.getId());
                api1305.setTfzydh(api1105.getHwdm() + fzAreationData.getId());
                api1305.setTfrq(fzAreationData.getStartTime());
                api1305.setCfdm(fzAreationData.getDepotId());
                api1305.setCfdm(api1105.getHwdm().substring(0,25));
                api1305.setTfmd(fzAreationData.getObjective());
                api1305.setTflx(fzAreationData.getType());
                api1305.setFdxs(fzAreationData.getWindNetType());
@@ -94,6 +94,8 @@
                api1305.setTfsc(fzAreationData.getLongTime());
                api1305.setZhgxsj(fzAreationData.getUpdateTime());

                api1305.setKqdm(kqdm);
                api1305.setBizId(fzAreationData.getId());
                api1305List = api1305Rep.getDataById(api1305.getTfzydh());
                if (null == api1305List || api1305List.isEmpty()) {
                    api1305.setCzbz(Constant.CZBZ_I);

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1306.java

@@ -75,8 +75,8 @@
                api1306 = new Api1306();

                BeanUtils.copyProperties(fz40DrugLog, api1306);
                api1306.setXzzydh(fz40DrugLog.getId());
                api1306.setCfdm(fz40DrugLog.getDepotId());
                api1306.setXzzydh(api1105.getHwdm().substring(0,25) + fz40DrugLog.getId());
                api1306.setCfdm(api1105.getHwdm().substring(0,25));
                api1306.setXzkssj(fz40DrugLog.getStart());
                api1306.setXzjssj(fz40DrugLog.getEnd());
                api1306.setHcjcdh(fz40DrugLog.getPestBatchId());
@@ -94,6 +94,9 @@
                api1306.setXzxgpj(fz40DrugLog.getEvaluate());
                api1306.setZhgxsj(fz40DrugLog.getUpdateTime());

                api1306.setHwdm(api1105.getHwdm());
                api1306.setKqdm(kqdm);
                api1306.setBizId(fz40DrugLog.getId());
                api1306List = api1306Rep.getDataById(api1306.getXzzydh());
                if (null == api1306List || api1306List.isEmpty()) {
                    api1306.setCzbz(Constant.CZBZ_I);

 src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1310.java

@@ -6,6 +6,7 @@
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;
@@ -43,6 +44,8 @@
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1310Rep api1310Rep;
    @Autowired
    private ApiLogRep apiLogRep;
@@ -74,8 +77,8 @@
            Api1105 api1105;
            List<Fz40CheckItem> fz40CheckItems;
            List<GbCheckItem> gbCheckList;
            StringBuilder jyxm;
            StringBuilder jyxmz;
            String jyxm;
            String jyxmz;
            List<Api1310> api1310List;
            int index = 10001;
            for (Fz40Quality fz40Quality : list) {
@@ -87,8 +90,13 @@
                api1310.setZjbgdh(fz40Quality.getType() + DateFormatUtils.format(fz40Quality.getTime(), "yyyyMMdd") + String.valueOf(index).substring(1));
                api1310.setHwdm(api1105.getHwdm());
                api1310.setKqdm(kqdm);
                api1310.setLspzdm(fz40Quality.getFoodVariety());
                api1310.setLsdjdm(fz40Quality.getFoodLevel());
                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, fz40Quality.getFoodVariety().substring(0,3));
                api1310.setLspzdm(mappingCode);

                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, fz40Quality.getFoodLevel());
                api1310.setLsdjdm(mappingCode);
                api1310.setRkrq(DateUtils.addDays(fz40Quality.getTime(), -30));
                api1310.setJylb(fz40Quality.getType());
                api1310.setJysj(fz40Quality.getTime());
@@ -97,8 +105,8 @@
                api1310.setJyyj(fz40Quality.getStandard());
                api1310.setZblb("2");
                //检测项，检测值
                jyxm = new StringBuilder();
                jyxmz = new StringBuilder();
                jyxm = "";
                jyxmz = "";
                fz40CheckItems = fzzySync1203Rep.listInoutCheckItem(fz40Quality.getId(), deptId.substring(0, 4));
                if (null != fz40CheckItems && fz40CheckItems.size() > 0) {

@@ -110,12 +118,12 @@
                        if (gbCheckList == null || gbCheckList.isEmpty()) {
                            continue;
                        }
                        jyxm.append(",").append(gbCheckList.get(0).getCode());
                        jyxmz.append(",").append(fz40CheckItem.getValue());
                        jyxm += gbCheckList.get(0).getCode() + ",";
                        jyxmz += fz40CheckItem.getValue() + ",";
                    }
                }
                api1310.setJyxm(jyxm.toString().substring(1));
                api1310.setJyxmz(jyxmz.toString().substring(1));
                api1310.setJyxm(jyxm);
                api1310.setJyxmz(jyxmz);

                api1310.setZbjgpd(fz40Quality.getResult());
                api1310.setQfrq(fz40Quality.getTime());
@@ -126,8 +134,8 @@
                api1310.setQyrxm(fz40Quality.getCheckUser());
                api1310.setJdrxm(fz40Quality.getCheckUser());

                api1310.setYpsl(fz40Quality.getYpsl());
                api1310.setDbsl(fz40Quality.getDbsl());
                api1310.setYpsl(fz40Quality.getYpsl() == null ? 0.0 : fz40Quality.getYpsl());
                api1310.setDbsl(fz40Quality.getDbsl() == null ? 0.0 : fz40Quality.getDbsl());
                api1310.setYpdj(StringUtils.isEmpty(fz40Quality.getYpdj())?"0": fz40Quality.getYpdj());
                api1310.setSfzcccnx(StringUtils.isEmpty(fz40Quality.getNormalYear())?"0": fz40Quality.getNormalYear());
                api1310.setBz(fz40Quality.getRemark());

 src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1305Rep.java

@@ -23,6 +23,6 @@
     * @param end
     * @return
     */
    @Query("from Fz40AreationData where startTime >=:start and startTime <:end order by startTime ")
    @Query("from Fz40AreationData where updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz40AreationData> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1306Rep.java

@@ -1,11 +1,9 @@
package com.fzzy.async.fzzy40.repository;

import com.fzzy.async.fzzy40.entity.Fz40AreationData;
import com.fzzy.async.fzzy40.entity.Fz40DrugLog;
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;

@@ -23,6 +21,6 @@
     * @param end
     * @return
     */
    @Query("from Fz40DrugLog where start >=:start and start <:end order by start ")
    @Query("from Fz40DrugLog where updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz40DrugLog> findByReceiveDate(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/otherview/sh2023/pr/SHApi2103PR.java

@@ -182,17 +182,20 @@
        for (SH2023Api2103 data : items) {
            responseDto = apiService.pushData(param, apiConf, data);
            if (responseDto.getSuccess() == 0) {
                infoData = new ApiInfoData();
                infoData.setId(data.getHwdm());
                infoData.setKqdm(data.getHwdm().substring(0, 21));
                infoData.setInteType("21");
                infoData.setInteId(SH2023Constant.SH_2023_API_CODE_2103);
                infoData.setUpdateTime(new Date());
                infoData.setDataId(data.getHwdm());
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    infoData = new ApiInfoData();
                    infoData.setId(data.getHwdm());
                    infoData.setKqdm(data.getHwdm().substring(0, 21));
                    infoData.setInteType("21");
                    infoData.setInteId(SH2023Constant.SH_2023_API_CODE_2103);
                    infoData.setUpdateTime(new Date());
                    infoData.setDataId(data.getHwdm());

                infoData.setCzbz(Constant.CZBZ_U);
                infoData.setData(JSON.toJSONString(data));
                apiInfoDataRep.save(infoData);
                    infoData.setCzbz(Constant.CZBZ_U);
                    data.setCzbz(Constant.CZBZ_U);
                    infoData.setData(JSON.toJSONString(data));
                    apiInfoDataRep.save(infoData);
                }
            }
            result += responseDto.toString();
        }

 src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java

@@ -513,6 +513,9 @@
            BeanUtils.copyProperties(apiData, api1305);
            api1305.setBjw(ShAreaBjw.getBjw(code));
            api1305.setAjdm(apiData.getTfzydh().substring(0, 28));
            //上海通风作业单号：廒间代码+yyyyMMdd+3位顺序号
            api1305.setAjdm(apiData.getTfzydh().substring(0, 28));
            api1305.setTfzydh(apiData.getTfzydh().substring(0, 28) + apiData.getTfzydh().substring(30));

            //设置空属性为默认值
            changeObject(api1305);
@@ -524,7 +527,9 @@
            BeanUtils.copyProperties(apiData, api1306);
            api1306.setBjw(ShAreaBjw.getBjw(code));
            api1306.setPch(apiData.getXzzydh().substring(0, 30) + DateFormatUtils.format(apiData.getXzkssj(), "yyyy"));
            api1306.setAjdm(apiData.getXzzydh().substring(0, 28));
            api1306.setAjdm(apiData.getHwdm().substring(0, 28));
            //上海熏蒸作业单号：货位代码+yyyyMMdd + 3位顺序号
            api1306.setXzzydh(apiData.getHwdm() + apiData.getBizId());

            //设置空属性为默认值
            changeObject(api1306);
@@ -572,9 +577,6 @@
            api1310.setBjw(ShAreaBjw.getBjw(code));
            api1310.setJyrq(apiData.getJysj());
            api1310.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJysj(), "yyyy"));
            List<Api1202> api1202List = api1202Rep.getDataByHwdm(apiData.getHwdm());
            api1310.setLspzdm(api1202List.get(0).getLspzdm());
            api1310.setLsxzdm("123");

            //设置空属性为默认值
            changeObject(api1310);