上海数据上报2

YYC

2023-08-21 2b63170e6ec11246a5029ea74340adb1b7d2f1a9

上海数据上报2

 src/main/java/com/fzzy/api/view/repository/Api1109Rep.java

@@ -7,6 +7,7 @@
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

@@ -25,4 +26,7 @@

    @Query("from Api1109 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1109> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

    @Query("from Api1109 where fileStorageId=:fileStorageId ")
    List<Api1109> getDataByFileId(@Param("fileStorageId") String fileStorageId);
}

 src/main/java/com/fzzy/api/view/repository/Api1202Rep.java

@@ -7,6 +7,7 @@
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;

@@ -21,6 +22,9 @@
    @Query("update Api1202 set czbz =:czbz where rkywdh=:rkywdh")
    int updateStatus(@Param("rkywdh") String rkywdh, @Param("czbz") String czbz);

    @Query("from Api1202 where rkywdh=:hwdm ")
    List<Api1202> getDataByHwdm(@Param("hwdm") String hwdm);

    @Query("from Api1202 where rkywdh=:rkywdh ")
    List<Api1202> getDataById(@Param("rkywdh") String rkywdh);


 src/main/java/com/fzzy/api/view/repository/Api1301Rep.java

@@ -1,11 +1,20 @@
package com.fzzy.api.view.repository;

import com.fzzy.api.entity.Api1212;
import com.fzzy.api.entity.Api1301;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;


public interface Api1301Rep extends JpaRepository<Api1301, String>, JpaSpecificationExecutor<Api1301> {

    @Query("from Api1301 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1301> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/api/view/repository/Api1307Rep.java

@@ -1,10 +1,20 @@
package com.fzzy.api.view.repository;

import com.fzzy.api.entity.Api1301;
import com.fzzy.api.entity.Api1307;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;


public interface Api1307Rep extends JpaRepository<Api1307, String>, JpaSpecificationExecutor<Api1307> {


    @Query("from Api1307 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1307> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/api/view/repository/Api1401Rep.java

@@ -3,8 +3,16 @@
import com.fzzy.api.entity.Api1401;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.Date;
import java.util.List;


public interface Api1401Rep extends JpaRepository<Api1401, Integer>, JpaSpecificationExecutor<Api1401> {

    @Query("from Api1401 where kqdm=:kqdm and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Api1401> findPushDataByTime(@Param("kqdm") String kqdm, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/otherview/sh2023/dto/ShApi1311.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,133 @@
package com.fzzy.otherview.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import lombok.EqualsAndHashCode;

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
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class ShApi1311 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "监控编号")
    private String sxtbh;

    @PropertyDef(label = "通道编号")
    private int tdbh;

    @PropertyDef(label = "通道名称")
    private String tdmc;

    @PropertyDef(label = "监控设备编码")
    private String jksbbm;

    @PropertyDef(label = "监控设备名称")
    private String jksbmc;

    @PropertyDef(label = "库区代码")
    private String kqdm;

    /**
     * 1 æµ·åº·, 2 å¤§åŽ, 3 å®‡è§†
     * 4 å¤©åœ°ä¼Ÿä¸š,5 åŽä¸º,9 å…¶ä»–
     */
    @PropertyDef(label = "监控厂商")
    private String jkcs;

    @PropertyDef(label = "监控型号")
    private String jkxh;

    @PropertyDef(label = "监控序列号")
    private String jkxlh;

    /**
     * 1:仓内，2:业务，
     * 3:安防
     */
    @PropertyDef(label = "视频监控类型")
    private String spjklx;

    /**
     * 1:DVR   2:NVR
     */
    @PropertyDef(label = "设备类型")
    private String sblxbm;

    @PropertyDef(label = "安装位置")
    private String azwz;

    /**
     * ç²®åº“大门（01），扦样机（02），化验室（03），结算室（04），
     * åœ°ç£…房（05），库区主干道（06），仓间监控（07），仓内（08），
     * è¯å“åº“（09），器材库（10），制高点（11），周界（12），其他（99）
     */
    @PropertyDef(label = "安装位置类型")
    private String azwzlx;

    @PropertyDef(label = "照射区域")
    private String zsqy;

    /**
     * Y/N
     */
    @PropertyDef(label = "是否安装补光灯")
    private String sfazbgd;

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    /**
     * 1 :枪机 2 :球机
     */
    @PropertyDef(label = "监控类型编码")
    private String jkjlxbm;

    @PropertyDef(label = "监控预置位数量")
    private int jktyzw;

    @PropertyDef(label = "设备IP地址")
    private String sbipdz;

    @PropertyDef(label = "设备端口号")
    private int sbdkh;

    @PropertyDef(label = "设备登录名称")
    private String sbdlmc;

    @PropertyDef(label = "设备登录密码")
    private String sbdlmm;

    @PropertyDef(label = "备注")
    private String bz;

    @PropertyDef(label = "标记位")
    private String bjw;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

}

 src/main/java/com/fzzy/otherview/sh2023/dto/ShApi2101.java

@@ -1,8 +1,13 @@
package com.fzzy.otherview.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import lombok.EqualsAndHashCode;

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

/**
 * ä¸Šæµ·å¸‚接口-2101 æ£€æ–¤å•
@@ -18,5 +23,92 @@
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "检斤单号")
    private String jjdh;

    @PropertyDef(label = "库区代码")
    private String kqdm;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "检斤日期")
    private Date jjrq;

    @PropertyDef(label = "驳运单号/库际调拨单号")
    private String inbillno;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "记账日期")
    private Date jzrq;

    @PropertyDef(label = "作业单号")
    private String zydh;

    /**
     * 1：入库作业 2：中转调出 3：中转进仓
     * 4：出库作业 5：库存调出 6：库存调入 7：移仓桩
     */
    @PropertyDef(label = "作业类型")
    private String zylx;

    @PropertyDef(label = "客户编号")
    private String khmc;

    @PropertyDef(label = "来粮预报号/提货单号")
    private String psplan;

    @PropertyDef(label = "合同号")
    private String hth;

    @PropertyDef(label = "车船号")
    private String cch;

    @PropertyDef(label = "中转车船号")
    private String zzchh;

    @PropertyDef(label = "品种大类")
    private String lspzdmdl;

    @PropertyDef(label = "粮食性质代码")
    private String lsxzdm;

    @PropertyDef(label = "来粮代码")
    private String lldm;

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "移入廒间代码")
    private String yrajdh;

    @PropertyDef(label = "移入货位代码")
    private String yrhwdm;

    @PropertyDef(label = "装卸班")
    private String zxb;

    @PropertyDef(label = "包装物增扣量(公斤)")
    private double bzwzkl;

    @PropertyDef(label = "毛重(公斤)")
    private double mz;

    @PropertyDef(label = "净重(公斤)")
    private double jz;

    @PropertyDef(label = "数据状态")
    private String czbz;

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

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/otherview/sh2023/repository/ShApi1311Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package com.fzzy.otherview.sh2023.repository;

import com.fzzy.otherview.sh2023.dto.ShApi1311;
import com.fzzy.otherview.sh2023.dto.ShApi2101;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
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 ShApi1311Rep {


}

 src/main/java/com/fzzy/otherview/sh2023/repository/ShApi2101Rep.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package com.fzzy.otherview.sh2023.repository;

import com.fzzy.api.entity.Api1310;
import com.fzzy.otherview.sh2023.dto.ShApi2101;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
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 ShApi2101Rep {
    
}

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

@@ -9,10 +9,7 @@
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.*;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1104Rep;
import com.fzzy.api.view.repository.Api1202Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.sh2023.dto.*;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
@@ -51,7 +48,11 @@
    @Autowired
    private Api1104Rep api1104Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1205Rep api1205Rep;

    @Override
    public String getProtocol() {
@@ -320,6 +321,152 @@
                list.add(api1205);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1206.equals(inteId)) {
            SH2023Api1206 api1206;
            //最后转换为json
            List<SH2023Api1206> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1206> api1206List = castList(data, Api1206.class);
            for (Api1206 apiData : api1206List) {
                api1206 = new SH2023Api1206();
                BeanUtils.copyProperties(apiData, api1206);
                api1206.setBjw(ShAreaBjw.getBjw(code));
                List<Api1205> api1205List = api1205Rep.getDataById(apiData.getCkjsdh());
                api1206.setPch(api1205List.get(0).getHwdm() + DateFormatUtils.format(api1205List.get(0).getCmsj(), "yyyy"));
                list.add(api1206);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1301.equals(inteId)) {
            SH2023Api1301 api1301;
            //最后转换为json
            List<SH2023Api1301> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1301> api1301List = castList(data, Api1301.class);
            for (Api1301 apiData : api1301List) {
                api1301 = new SH2023Api1301();
                BeanUtils.copyProperties(apiData, api1301);
                api1301.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1301);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1302.equals(inteId)) {
            SH2023Api1302 api1302;
            //最后转换为json
            List<SH2023Api1302> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1302> api1302List = castList(data, Api1302.class);
            for (Api1302 apiData : api1302List) {
                api1302 = new SH2023Api1302();
                BeanUtils.copyProperties(apiData, api1302);
                api1302.setBjw(ShAreaBjw.getBjw(code));
                api1302.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy"));
                //todo æ¸©æ¹¿åº¦æ£€æµ‹æ•°æ®ä¸å…¨
                list.add(api1302);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1303.equals(inteId)) {
            SH2023Api1303 api1303;
            //最后转换为json
            List<SH2023Api1303> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1303> api1303List = castList(data, Api1303.class);
            for (Api1303 apiData : api1303List) {
                api1303 = new SH2023Api1303();
                BeanUtils.copyProperties(apiData, api1303);
                api1303.setBjw(ShAreaBjw.getBjw(code));
                api1303.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy"));
                list.add(api1303);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1304.equals(inteId)) {
            SH2023Api1304 api1304;
            //最后转换为json
            List<SH2023Api1304> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1304> api1304List = castList(data, Api1304.class);
            for (Api1304 apiData : api1304List) {
                api1304 = new SH2023Api1304();
                BeanUtils.copyProperties(apiData, api1304);
                api1304.setBjw(ShAreaBjw.getBjw(code));
                api1304.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJcsj(), "yyyy"));
                list.add(api1304);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1305.equals(inteId)) {
            SH2023Api1305 api1305;
            //最后转换为json
            List<SH2023Api1305> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1305> api1305List = castList(data, Api1305.class);
            for (Api1305 apiData : api1305List) {
                api1305 = new SH2023Api1305();
                BeanUtils.copyProperties(apiData, api1305);
                api1305.setBjw(ShAreaBjw.getBjw(code));
                api1305.setAjdm(apiData.getTfzydh().substring(0, 28));
                list.add(api1305);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1306.equals(inteId)) {
            SH2023Api1306 api1306;
            //最后转换为json
            List<SH2023Api1306> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1306> api1306List = castList(data, Api1306.class);
            for (Api1306 apiData : api1306List) {
                api1306 = new SH2023Api1306();
                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));
                list.add(api1306);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1307.equals(inteId)) {
            SH2023Api1307 api1307;
            //最后转换为json
            List<SH2023Api1307> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1307> api1307List = castList(data, Api1307.class);
            for (Api1307 apiData : api1307List) {
                api1307 = new SH2023Api1307();
                BeanUtils.copyProperties(apiData, api1307);
                api1307.setBjw(ShAreaBjw.getBjw(code));
                api1307.setAjdm(apiData.getHwdm().substring(0, 28));
                List<Api1109> api1109List = api1109Rep.getDataByFileId(apiData.getFileStorageId());
                api1307.setTxbh(api1109List.get(0).getWjmc());
                list.add(api1307);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1310.equals(inteId)) {
            SH2023Api1310 api1310;
            //最后转换为json
            List<SH2023Api1310> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1310> api1310List = castList(data, Api1310.class);
            for (Api1310 apiData : api1310List) {
                api1310 = new SH2023Api1310();
                BeanUtils.copyProperties(apiData, api1310);
                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());
                list.add(api1310);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1401.equals(inteId)) {
            SH2023Api1401 api1401;
            //最后转换为json
            List<SH2023Api1401> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1401> api1401List = castList(data, Api1401.class);
            for (Api1401 apiData : api1401List) {
                api1401 = new SH2023Api1401();
                BeanUtils.copyProperties(apiData, api1401);
                api1401.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1401);
            }
            return JSON.toJSONString(list);
        } else {
            return JSON.toJSONString(data);
        }

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

@@ -8,7 +8,7 @@
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.impl.ComPushService11;
import com.fzzy.otherview.sh2023.dto.ShApi2101;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -308,8 +308,7 @@
     * 2101 æ£€æ–¤å•
     */
    public void pushData2101(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

        // todo
    }

    /**

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

@@ -1,13 +1,21 @@
package com.fzzy.push.sh2023;

import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.api.view.repository.*;
import com.fzzy.otherview.sh2023.dto.ShApi1311;
import com.fzzy.otherview.sh2023.repository.ShApi1311Rep;
import com.fzzy.push.impl.ComPushService11;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * ä¸Šæµ·å¸‚平台2023版-基础数据上传
@@ -22,6 +30,26 @@

    @Autowired
    private SH2023ApiRemoteService apiRemoteService;
    @Autowired
    private Api1301Rep api1301Rep;
    @Autowired
    private Api1302Rep api1302Rep;
    @Autowired
    private Api1303Rep api1303Rep;
    @Autowired
    private Api1304Rep api1304Rep;
    @Autowired
    private Api1305Rep api1305Rep;
    @Autowired
    private Api1306Rep api1306Rep;
    @Autowired
    private Api1307Rep api1307Rep;
    @Autowired
    private Api1308Rep api1308Rep;
    @Autowired
    private Api1309Rep api1309Rep;
    @Autowired
    private Api1310Rep api1310Rep;

    @Override
    public String getProtocol() {
@@ -30,19 +58,48 @@

    @Override
    public void pushData(ApiParam param) {
        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报开始");
        log.info("------->>>>粮库管理 æŽ¥å£æ¨¡å—上报开始");

        //推送单位信息
        this.pushData1301(apiRemoteService, param);
        this.pushData1302(apiRemoteService, param);
        this.pushData1303(apiRemoteService, param);
        this.pushData1304(apiRemoteService, param);
        this.pushData1305(apiRemoteService, param);
        this.pushData1306(apiRemoteService, param);
        this.pushData1307(apiRemoteService, param);
        this.pushData1308(apiRemoteService, param);
        this.pushData1309(apiRemoteService, param);
        this.pushData1310(apiRemoteService, param);
        this.pushData1311(apiRemoteService, param);


        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");
        log.info("------->>>>粮库管理 æŽ¥å£æ¨¡å—上报结束");
    }

    /**
     * 1301 å®‰å…¨ç®¡ç†
     */
    public void pushData1301(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取安全管理
        List<Api1301> list = api1301Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到安全管理，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1301 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1301Rep.save(data);
                }
            }
        }

    }

@@ -50,15 +107,54 @@
     * 1302 æ¸©æ¹¿åº¦æ£€æµ‹
     */
    public void pushData1302(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取温湿度检测
        List<Api1302> list = api1302Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到温湿度检测，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1302 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1302Rep.save(data);
                }
            }
        }
    }

    /**
     * 1303 å®³è™«æ£€æµ‹
     */
    public void pushData1303(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取害虫检测
        List<Api1303> list = api1303Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到害虫检测，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1303 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1303Rep.save(data);
                }
            }
        }

    }

@@ -66,7 +162,27 @@
     * 1304 æ°”体检测
     */
    public void pushData1304(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取气体检测
        List<Api1304> list = api1304Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到气体检测，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1304 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1304Rep.save(data);
                }
            }
        }

    }

@@ -74,7 +190,27 @@
     * 1305 é€šé£Žä½œä¸š
     */
    public void pushData1305(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取通风作业
        List<Api1305> list = api1305Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到通风作业，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1305 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1305Rep.save(data);
                }
            }
        }

    }

@@ -82,15 +218,54 @@
     * 1306 ç†è’¸ä½œä¸š
     */
    public void pushData1306(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取熏蒸作业
        List<Api1306> list = api1306Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到熏蒸作业，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1306 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1306Rep.save(data);
                }
            }
        }
    }

    /**
     * 1307 ä»“内视频图像
     */
    public void pushData1307(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取仓内视频图像
        List<Api1307> list = api1307Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到仓内视频图像，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1307 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1307Rep.save(data);
                }
            }
        }

    }

@@ -114,7 +289,27 @@
     * 1310 è´¨æ£€æ•°æ®
     */
    public void pushData1310(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取质检数据
        List<Api1310> list = api1310Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到质检数据，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1310 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1310Rep.save(data);
                }
            }
        }

    }

@@ -122,7 +317,7 @@
     * 1311 è§†é¢‘监控接口
     */
    public void pushData1311(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        // todo

    }


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

@@ -1,12 +1,19 @@
package com.fzzy.push.sh2023;

import com.fzzy.api.Constant;
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.dto.ResponseDto;
import com.fzzy.api.entity.Api1310;
import com.fzzy.api.entity.Api1401;
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.PushService11;
import com.fzzy.api.view.repository.Api1401Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.List;

/**
 * ä¸Šæµ·å¸‚平台2023版-基础数据上传
@@ -21,6 +28,8 @@

    @Autowired
    private SH2023ApiRemoteService apiRemoteService;
    @Autowired
    private Api1401Rep api1401Rep;

    @Override
    public String getProtocol() {
@@ -29,19 +38,40 @@

    @Override
    public void pushData(ApiParam param) {
        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报开始");
        log.info("------->>>>行政管理 æŽ¥å£æ¨¡å—上报开始");

        //推送单位信息
        //储备规模
        this.pushData1401(apiRemoteService, param);


        log.info("------->>>>基础信息 æŽ¥å£æ¨¡å—上报结束");
        log.info("------->>>>行政管理 æŽ¥å£æ¨¡å—上报结束");
    }

    /**
     * 1401 å‚¨å¤‡è§„模
     */
    public void pushData1401(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取储备规模
        List<Api1401> list = api1401Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到储备规模，不推送-----");
            return;
        }

        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1401 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    //更新状态
                    api1401Rep.save(data);
                }
            }
        }

    }

@@ -68,6 +98,7 @@
        //TODO

    }

    /**
     * 1405 é¡¹ç›®ä¿¡æ¯
     */

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1206.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,82 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
import java.util.Date;

/**
 * æŽ¥å£è¡¨-粮食出库结算信息
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1206 implements Serializable {
    /**
     *
     */
    private static final long serialVersionUID = -8778664614878279565L;

    @PropertyDef(label = "出库结算单号")
    private String ckjsdh;

    @PropertyDef(label = "合同号")
    private String hth;

    @PropertyDef(label = "结算数量(公斤)")
    private double jssl;

    @PropertyDef(label = "结算单价(元/公斤)")
    private double jsdj;

    @PropertyDef(label = "结算金额(元)")
    private double jsje;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "结算时间")
    private Date jssj;

    @PropertyDef(label = "结算方式")
    private String jsfs;

    @PropertyDef(label = "付款人")
    private String fkr;

    @PropertyDef(label = "银行行别代码")
    private String yhhbdm;

    @PropertyDef(label = "开户行号")
    private String khhh;

    @PropertyDef(label = "开户行名称")
    private String khhmc;

    @PropertyDef(label = "银行账号")
    private String yhzh;

    @PropertyDef(label = "发票号码")
    private String fphm;

    @PropertyDef(label = "发票状态")
    private String fpzt;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "标记位")
    private String bjw;
}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1301.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,101 @@
package com.fzzy.push.sh2023.dto;

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 chen
 * @date 2022-09-02 16:06
 */
@Data
public class SH2023Api1301 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "库区代码")
    private String kqdm;

    @PropertyDef(label = "单位代码")
    private String dwdm;

    @PropertyDef(label = "库区名称")
    private String kqmc;

    @PropertyDef(label = "地点")
    private String dd;

    @PropertyDef(label = "风险点编码")
    private String fxdbm;

    @PropertyDef(label = "识别人")
    private String sbr;

    @PropertyDef(label = "环节/部位")
    private String hjbw;

    @PropertyDef(label = "风险信息")
    private String fxxx;

    @PropertyDef(label = "风险类型")
    private String fxlx;

    @PropertyDef(label = "风险分级")
    private String fxfj;

    @PropertyDef(label = "风险管控措施")
    private String fxglcs;

    @JSONField(name = "Yhxx")
    @PropertyDef(label = "隐患信息")
    private String yhxx;

    @PropertyDef(label = "隐患排查信息")
    private String yhpcxx;

    @PropertyDef(label = "隐患整改信息")
    private String yhzgxx;

    @PropertyDef(label = "隐患整改验收信息")
    private String yhysxx;

    @PropertyDef(label = "事故基本信息")
    private String sgjbxx;

    @PropertyDef(label = "整改时限")
    private String zgsx;

    @PropertyDef(label = "责任单位")
    private String zrdw;

    @PropertyDef(label = "责任人")
    private String zrr;

    @PropertyDef(label = "整改验收信息")
    private String zgysxx;

    @PropertyDef(label = "风险跟踪监管责任人")
    private String fxgzjgzrr;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "标记位")
    private String bjw;
}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1302.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,106 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:07
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1302 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = -7985638448449311029L;


    @PropertyDef(label = "温湿度检测单号")
    private String wsdjcdh;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "检测时间")
    private Date jcsj;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "仓房外温")
    private double cfww;

    @PropertyDef(label = "仓房外湿")
    private double cfws;

    @PropertyDef(label = "仓房内温")
    private double cfnw;

    @PropertyDef(label = "仓房内湿")
    private double cfns;

    @PropertyDef(label = "粮食最高温")
    private double lszgw;

    @PropertyDef(label = "粮食最低温")
    private double lszdw;

    @PropertyDef(label = "粮食平均温")
    private double lspjw;

    @PropertyDef(label = "粮食温度值集合")
    private String lswdzjh;

    @PropertyDef(label = "粮食湿度值集合")
    private String lssdzjh;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "层平均温")
    private String cpjw;

    @PropertyDef(label = "层最高温")
    private String czgw;

    @PropertyDef(label = "层最低温")
    private String czdw;

    @PropertyDef(label = "各范围均温")
    private String gfwjw;

    @PropertyDef(label = "粮温明细")
    private String lwmx;

    @PropertyDef(label = "粮温状态")
    private String lwzt;

    @PropertyDef(label = "异常点个数")
    private String ycdgs;

    @PropertyDef(label = "粮情技术")
    private String lqjs;

    @PropertyDef(label = "标记位")
    private String bjw;

    @PropertyDef(label = "批次号")
    private String pch;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1303.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,72 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:10
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1303 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 7545059969928419761L;

    @PropertyDef(label = "害虫检测单号", description = "由货位代码+检测日期（yyyyMMdd）+4 ä½é¡ºåºå·ç»„成")
    private String hcjcdh;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "检测时间")
    private Date jcsj;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "检查害虫方法")
    private String jchcff;

    @PropertyDef(label = "发生部位")
    private String fsbw;

    @PropertyDef(label = "害虫种类")
    private String hczl;

    @PropertyDef(label = "虫口密度值集合")
    private String ckmdzjh;

    @PropertyDef(label = "虫粮等级判定")
    private String cldjpd;

    @PropertyDef(label = "害虫抗药性分析")
    private String hckyxfx;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1304.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,75 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:12
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1304 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 5367656121593571013L;

    @PropertyDef(label = "气体浓度检测单号")
    private String qtndjcdh;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "检测时间")
    private Date jcsj;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "氧气含量值集合")
    private String yqhlzjh;

    @PropertyDef(label = "二氧化碳含量值集合")
    private String eyhthlzjh;

    @PropertyDef(label = "硫酰氟浓度值集合")
    private String lxfndzjh;

    @PropertyDef(label = "磷化氢浓度值集合")
    private String lhqndzjh;

    @PropertyDef(label = "一氧化氮含量值集合")
    private String yyhdhlzjh;

    @PropertyDef(label = "一氧化碳含量值集合")
    private String yyhthlzjh;

    @PropertyDef(label = "操作标志")
    private String czbz;

    @PropertyDef(label = "作业类型")
    private String zylx;

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

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1305.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,192 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:17
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1305 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "通风作业单号")
    private String tfzydh;

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

    @PropertyDef(label = "仓房代码")
    private String cfdm;

    @PropertyDef(label = "通风目的")
    private String tfmd;

    @PropertyDef(label = "粮堆孔隙度")
    private double ldkxd;

    @PropertyDef(label = "通风类型")
    private String tflx;

    @PropertyDef(label = "风道型式")
    private String fdxs;

    @PropertyDef(label = "风网设置方式")
    private String fwszfs;

    @PropertyDef(label = "主风道截面积")
    private double zfdjmj;

    @PropertyDef(label = "支风道截面积")
    private double zhfdjmj;

    @PropertyDef(label = "支风道总长度")
    private double zfdzcd;

    @PropertyDef(label = "风网开孔率")
    private double fwkkl;

    @PropertyDef(label = "空气途径比")
    private double kqtjb;

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

    @PropertyDef(label = "通风机型号")
    private String tfjxh;

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

    @PropertyDef(label = "单台风机额定全压")
    private double dtfjedqy;

    @PropertyDef(label = "单台风机额定风量")
    private double dtfjedfl;

    @PropertyDef(label = "单台风机额定功率")
    private double dtfjedgl;

    @PropertyDef(label = "送风方式")
    private String sffs;

    @PropertyDef(label = "单台风机实测风量")
    private double dtfjscfl;

    @PropertyDef(label = "单台风机轴功率")
    private double dtfjzgl;

    @PropertyDef(label = "总风量")
    private double zfl;

    @PropertyDef(label = "单位通风量")
    private double dwtfl;

    @PropertyDef(label = "实测系统阻力")
    private double scxtzl;

    @PropertyDef(label = "总耗电量")
    private double zhdl;

    @PropertyDef(label = "作业时气温")
    private double zysqw;

    @PropertyDef(label = "作业时气湿")
    private double zysqs;

    @PropertyDef(label = "通风时长")
    private double tfsc;

    @PropertyDef(label = "作业前平均粮温")
    private double zyqpjlw;

    @PropertyDef(label = "结束后平均粮温")
    private double jshpjlw;

    @PropertyDef(label = "降温幅度")
    private double jwfd;

    @PropertyDef(label = "吨粮降温能耗")
    private double dljwnh;

    @PropertyDef(label = "失水率")
    private double ssl;

    @PropertyDef(label = "保水效果评价结果")
    private String bsxgpjjg;

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

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

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

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

    @PropertyDef(label = "作业前平均水分")
    private double zyqpjsf;

    @PropertyDef(label = "结束后平均水分")
    private double zyhpjsf;

    @PropertyDef(label = "降水幅度")
    private double jsfd;

    @PropertyDef(label = "吨粮降水能耗")
    private double dljsnh;

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

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

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

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

    @PropertyDef(label = "通风作业负责人")
    private String tfzyfzr;

    @PropertyDef(label = "通风作业人员")
    private String tfzyry;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "廒间数")
    private String ajdm;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1306.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,240 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:21
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1306 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "熏蒸作业单号")
    private String xzzydh;

    @PropertyDef(label = "仓房代码")
    private String cfdm;

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

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

    @PropertyDef(label = "害虫检测单号")
    private String hcjcdh;

    @PropertyDef(label = "封仓后熏蒸的次数 ç¬¬å‡ æ¬¡ç†è’¸")
    private Integer djcxz;

    @PropertyDef(label = "常规熏蒸方式")
    private String cgxzfs;

    @PropertyDef(label = "环流熏蒸方式")
    private String hlxzfs;

    @PropertyDef(label = "环流熏蒸与内环流技术结合")
    private String hlxzynhljsjh;

    @PropertyDef(label = "熏蒸方案制定")
    private String xzfazd;

    @PropertyDef(label = "熏蒸方案起草人")
    private String xzfaqcr;

    @PropertyDef(label = "熏蒸方案批准人")
    private String xzfapzr;

    @PropertyDef(label = "熏蒸方案报备情况")
    private String xzfabbqk;

    @PropertyDef(label = "施药人员资质情况")
    private String syryzzqk;

    @PropertyDef(label = "施药资质审核")
    private String syzzsh;

    @PropertyDef(label = "药剂名称")
    private String yjmc;

    @PropertyDef(label = "剂型")
    private String jx;

    @PropertyDef(label = "浓度")
    private Double nd;

    @PropertyDef(label = "粮堆单位用药量")
    private Double lddwyyl;

    @PropertyDef(label = "空间单位用药量")
    private Double kjdwyyl;

    @PropertyDef(label = "总用药量")
    private Double zyyl;

    @PropertyDef(label = "施药方法")
    private String syff;

    @PropertyDef(label = "辅助施药措施")
    private String fzsycs;

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

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

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

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

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

    @PropertyDef(label = "补药前仓内磷化氢浓度")
    private Double byqcnlhqnd;

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

    @PropertyDef(label = "目标浓度")
    private Double mbnd;

    @PropertyDef(label = "计算补药量")
    private Double jsbyl;

    @PropertyDef(label = "实际补药量")
    private Double sjbyl;

    @PropertyDef(label = "补药方法")
    private String byff;

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

    @PropertyDef(label = "补药作业批准人")
    private String byzypzr;

    @PropertyDef(label = "现场指挥人")
    private String xczhr;

    @PropertyDef(label = "峰值浓度")
    private Double fznd;

    @PropertyDef(label = "目标浓度维持天数")
    private Integer mbndwcts;

    @PropertyDef(label = "漏气位置监测")
    private String lswzjc;

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

    @PropertyDef(label = "密闭时间")
    private Integer mbsj;

    @PropertyDef(label = "CT值")
    private Double ctz;

    @PropertyDef(label = "散气前磷化氢浓度")
    private Double sqqlhqnd;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "散气日期")
    private Date sqrq;

    @PropertyDef(label = "散气方法")
    private String sqff;

    @PropertyDef(label = "散气批准人")
    private String sqpzr;

    @PropertyDef(label = "散气持续天数")
    private Integer sqcsts;

    @PropertyDef(label = "散气结束时磷化氢浓度")
    private Double sqjsslhqnd;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "残渣收集作业时间")
    private Date czsjzysj;

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

    @PropertyDef(label = "残渣收集方法")
    private String czsjff;

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

    @PropertyDef(label = "残渣处理措施")
    private String czclcs;

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

    @PropertyDef(label = "残渣处理批准人")
    private String czclpzr;

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

    @PropertyDef(label = "熏蒸后虫口密度")
    private Integer xzhckmd;

    @PropertyDef(label = "培养15天后活虫数")
    private Integer pyswthhcs;

    @PropertyDef(label = "培养45天后活虫数")
    private Integer pysswthhcs;

    @PropertyDef(label = "熏蒸效果评价")
    private String xzxgpj;

    @PropertyDef(label = "熏蒸负责人")
    private String xzfzr;

    @PropertyDef(label = "熏蒸作业人员")
    private String xzzyry;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1307.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 15:57
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1307 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "库区代码")
    private String kqdm;

    @PropertyDef(label = "视频监控设备id")
    private String spjksbid;

    @PropertyDef(label = "仓房代码")
    private String cfdm;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "抓拍时间")
    private Date zpsj;

    @PropertyDef(label = "图像编号")
    private String txbh;

    @PropertyDef(label = "文件id")
    private String fileStorageId;
    
    @JSONField(name = "yzwbh")
    @PropertyDef(label = "预置位编号")
    private String yzwbh;

    @PropertyDef(label = "操作标志")
    private String czbz;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    private Date zhgxsj;

    @PropertyDef(label = "廒间代码")
    private String ajdm;

    @PropertyDef(label = "标记位")
    private String bjw;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1310.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,132 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import lombok.EqualsAndHashCode;

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 chen
 * @date 2022-09-02 16:03
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1310 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;

    @PropertyDef(label = "质检报告单号")
    private String zjbgdh;

    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "粮食品种代码")
    private String lspzdm;

    @PropertyDef(label = "粮食等级代码")
    private String lsdjdm;

    @PropertyDef(label = "检验类别")
    private String jylb;

    @PropertyDef(label = "检验单位")
    private String jydw;

    @PropertyDef(label = "检验人")
    private String jyr;

    @PropertyDef(label = "检验依据")
    private String jyyj;

    @PropertyDef(label = "指标类别")
    private String zblb;

    @PropertyDef(label = "检验项目")
    private String jyxm;

    @PropertyDef(label = "检验项目值")
    private String jyxmz;

    @PropertyDef(label = "指标结果判定")
    private String zbjgpd;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "签发日期")
    private Date qfrq;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "报告出具时间")
    private Date bgcjsj;

    @PropertyDef(label = "审核人姓名")
    private String shrxm;

    @PropertyDef(label = "扦样单编号")
    private String qydbh;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "扦样时间")
    private Date qysj;

    @PropertyDef(label = "扦样区域")
    private String qyqy;

    @PropertyDef(label = "扦样人姓名")
    private String qyrxm;

    @PropertyDef(label = "监督人姓名")
    private String jdrxm;

    @PropertyDef(label = "样品编号")
    private String ypbh;

    @PropertyDef(label = "样品数量")
    private double ypsl;

    @PropertyDef(label = "代表数量")
    private double dbsl;

    @PropertyDef(label = "样品等级")
    private String ypdj;

    @PropertyDef(label = "是否正常存储年限")
    private String sfzcccnx;

    @PropertyDef(label = "备注")
    private String bz;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "检验日期")
    private Date jyrq;

    @PropertyDef(label = "标记位")
    private String bjw;

    @PropertyDef(label = "批次号")
    private String pch;

    @PropertyDef(label = "粮食性质代码")
    private String lsxzdm;

}

 src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1401.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,67 @@
package com.fzzy.push.sh2023.dto;

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.hibernate.annotations.GenericGenerator;

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

/**
 * æŽ¥å£è¡¨-储备规模数据表
 *
 * @author chen
 * @date 2022-09-02 16:03
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1401 implements Serializable {

    /**
     *
     */
    private static final long serialVersionUID = 1L;


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

    @PropertyDef(label = "年份")
    private String nf;

    @PropertyDef(label = "行政区划代码")
    private String xzqhdm;

    @PropertyDef(label = "承储企业")
    private String ccqy;

    @PropertyDef(label = "粮食品种")
    private String ylpz;

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

    @PropertyDef(label = "储备规模计划数量")
    private double ylcbgmjhsl;

    @PropertyDef(label = "储备规模计划文号")
    private String cbgmjhwh;

    @PropertyDef(label = "备注")
    private String remarks;

    @PropertyDef(label = "操作标志")
    private String czbz;

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

    @PropertyDef(label = "标记位")
    private String bjw;

}