Merge remote-tracking branch 'origin/master'

WS

2023-08-22 2627c9d3c01458587f9e1873a2a0284b8a08be04

Merge remote-tracking branch 'origin/master'

# Conflicts:
#	src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService13.java

 src/main/java/com/fzzy/api/timer/SyncDataScheduled.java

@@ -135,6 +135,7 @@

        ApiParam param = new ApiParam();
        param.setSyncProtocol(conf.getSyncProtocol());
        param.setPushProtocol(conf.getPushProtocol());
        param.setKqdm(conf.getKqdm());
        param.setStart(start);
        param.setEnd(exeDate);

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

@@ -1,7 +1,6 @@
package com.fzzy.api.view.repository;

import com.fzzy.api.entity.Api1107;
import com.fzzy.api.entity.Api1112;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;

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

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

import java.util.List;


public interface Api1108Rep extends JpaRepository<Api1108, String> {

@@ -23,4 +25,8 @@
    @Query("update Api1108 set czbz=:czbz where id=:id ")
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    @Query("from Api1108 where kqdm=:kqdm")
    List<Api1108> findPushData(@Param("kqdm") String kqdm);


}

 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/Api1110Rep.java

@@ -7,19 +7,24 @@
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;


public interface Api1110Rep extends JpaRepository<Api1110, String> {

    /**
     * æ ¹æ®è¡¨å•ä¸»é”®æ›´æ–°æ“ä½œæ ‡å¿—状态
     *
     * @param id   ä¸»é”®ID
     * @param hwdm ä¸»é”®ID
     * @param czbz æ“ä½œæ ‡å¿—
     * @return
     */
    @Transactional
    @Modifying
    @Query("update Api1110 set czbz=:czbz where id=:id ")
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);
    @Query("update Api1110 set czbz=:czbz where hwdm=:hwdm ")
    int updateStatus(@Param("hwdm") String hwdm, @Param("czbz") String czbz);

    @Query("from Api1110 where kqdm=:kqdm")
    List<Api1110> findPushData(@Param("kqdm") String kqdm);

}

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

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

import java.util.List;


public interface Api1113Rep extends JpaRepository<Api1113, String> {

@@ -23,4 +25,7 @@
    @Query("update Api1113 set czbz=:czbz where dwdm=:id ")
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    @Query("from Api1113 where kqdm=:kqdm")
    List<Api1113> findPushData(@Param("kqdm") String kqdm);

}

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

@@ -29,4 +33,12 @@

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

    /**
     * æ ¹æ®bizId查询数据
     * @param bizId
     * @return
     */
    @Query("from Api1202 where bizId =:bizId")
    List<Api1202> getDataByBizId(@Param("bizId") String bizId);
}

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

@@ -26,4 +26,12 @@

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

    /**
     * æ ¹æ®bizId查询数据
     * @param bizId
     * @return
     */
    @Query("from Api1205 where bizId =:bizId")
    List<Api1205> getDataByBizId(@Param("bizId") String bizId);
}

 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/async/fzzy35/impl/Fzzy35Sync1109.java

@@ -2,15 +2,17 @@

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1109;
import com.fzzy.api.entity.Api1202;
import com.fzzy.api.entity.Api1205;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtil;
import com.fzzy.api.view.repository.Api1109Rep;
import com.fzzy.api.view.repository.Api1202Rep;
import com.fzzy.api.view.repository.Api1205Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.Fz35FileInfo;
import com.fzzy.async.fzzy35.entity.Fz35InoutRecord;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1109Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -47,9 +49,11 @@
    @Autowired
    private Fzzy35Sync1109Rep fzzySync1109Rep;
    @Autowired
    private Fzzy35Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1205Rep api1205Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
@@ -87,24 +91,29 @@
            String wjlx;
            String wjmc;
            List<Api1109> api1109List;
            List<Fz35InoutRecord> listInout;
            List<Api1202> api1202List;
            List<Api1205> api1205List;
            String str = "";
            for (Fz35FileInfo sysData : list) {
                if (StringUtils.isEmpty(sysData.getBizId())) {
                    continue;
                }
                //根据图片id查询对应出入库信息
                listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId());
                if(null == listInout || listInout.isEmpty()){
                if(sysData.getBizId().startsWith(IMG_START_R)){
                    api1202List = api1202Rep.getDataByBizId(sysData.getBizId());
                    if (null == api1202List || api1202List.isEmpty()) {
                    continue;
                }
                //若出入库信息为删除或者错误状态，则不同步
                if("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())){
                    str = api1202List.get(0).getRkywdh();
                }
                if(sysData.getBizId().startsWith(IMG_START_C)){
                    api1205List = api1205Rep.getDataByBizId(sysData.getBizId());
                    if (null == api1205List || api1205List.isEmpty()) {
                    continue;
                }
                //若出入库信息中入库重量为空或为0，则不同步
                if(null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0){
                    continue;
                    str = api1205List.get(0).getCkywdh();
                }

                //只同步称重
                if(BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())){
                    wjlx = "";
@@ -132,7 +141,7 @@
                    apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());

                    //文件名称
                    wjmc = getImgNameType(wjmc, sysData.getBizTag(), sysData.getBizId(), sysData.getFileName(), map);
                    wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
                    apiData.setWjmc(wjmc);
                    //文件类型
                    apiData.setWjlx(wjlx);

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1202.java

@@ -20,9 +20,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.*;

/**
 * ç²®é£Ÿå…¥åº“信息
@@ -81,6 +79,9 @@
            List<Fz35InoutNoticeIn> listInoutNotice;
            List<Api1202> api1202List;
            Calendar c = Calendar.getInstance();
            String ywsj = "";
            String num = "";
            Map<String, Integer> map = new HashMap<>();
            for (Fz35InoutRecord sysData : list) {
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                    sysData.setRecordWeight(sysData.getSettleWeight());
@@ -97,6 +98,16 @@
                apiData = new Api1202();

                apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
                //判断业务时间与单据号是否匹配
                ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
                if(!ywsj.equals(sysData.getId().substring(4, 10))){
                    if(null == map.get(ywsj)){
                        map.put(ywsj, 10201);
                    }
                    num = String.valueOf(map.get(ywsj)).substring(1);
                    apiData.setRkywdh(Constant.INOUT_TYPE_14 + ywsj + num);
                    map.put(ywsj, map.get(ywsj) + 1);
                }

                //货位代码
                apiData.setHwdm(api1105.getHwdm());
@@ -107,7 +118,7 @@
                //默认一个随便值
                apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact());

                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId());
                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim());

                //获取合同号
                listInoutNotice = fzzy35SyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1203.java

@@ -5,6 +5,7 @@
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1202Rep;
import com.fzzy.api.view.repository.Api1203Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.GbCheckItemRep;
@@ -14,6 +15,7 @@
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateFormatUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -37,9 +39,10 @@
    private Fzzy35Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy35Sync1203Rep fzzySync1203Rep;

    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1203Rep api1203Rep;
    @Autowired
@@ -86,12 +89,11 @@
            String zkj;
            String zkl;
            List<Api1203> api1203List;
            List<Api1202> api1102List;
            for (Fz35InoutRecord sysData : list) {
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                    sysData.setRecordWeight(sysData.getSettleWeight());
                }
                //判断净重是否大于0，等于0表示不合格，不进行同步上传
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                //查询粮食入库信息，若为空则不进行同步上传
                api1102List = api1202Rep.getDataByBizId(sysData.getId());
                if(null == api1102List || api1102List.isEmpty()){
                    continue;
                }

@@ -102,19 +104,12 @@
                    continue;
                }

                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }

                apiData = new Api1203();

                apiData.setRkjydh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));

                apiData.setRkjydh(api1102List.get(0).getRkywdh());
                //货位代码
                apiData.setHwdm(api1105.getHwdm());
                apiData.setRkywdh(apiData.getRkjydh());
                apiData.setHwdm(api1102List.get(0).getHwdm());
                apiData.setRkywdh(api1102List.get(0).getRkywdh());
                if(null == sysData.getFullWeightTime()){
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
                }
@@ -160,6 +155,9 @@
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

                //保管员复核
                apiData.setBgyfh(apiData.getJyjg());

                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel());
                apiData.setLsdd(mappingCode);

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1205.java

@@ -18,9 +18,8 @@
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

import java.util.*;

/**
 * ç²®é£Ÿå‡ºåº“信息
@@ -78,8 +77,10 @@
        Api1105 api1105;
        List<Fz35InoutNoticeOut> listInoutNotice;
        List<Api1205> api1205List;
        // List<GbArea> gbAreaList;
        Calendar c = Calendar.getInstance();
            String ywsj = "";
            String num = "";
            Map<String, Integer> map = new HashMap<>();
        for (Fz35InoutRecord sysData : list) {
            if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,7 +96,16 @@
            }
            apiData = new Api1205();
            apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4));

            //判断业务时间与单据号是否匹配
            ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
            if(!ywsj.equals(sysData.getId().substring(4, 10))){
                if(null == map.get(ywsj)){
                    map.put(ywsj, 10201);
                }
                num = String.valueOf(map.get(ywsj)).substring(1);
                apiData.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num);
                map.put(ywsj, map.get(ywsj) + 1);
            }

            //货位代码
            apiData.setHwdm(api1105.getHwdm());

 src/main/java/com/fzzy/async/fzzy35/impl/Fzzy35Sync1208.java

@@ -71,6 +71,7 @@

            Api1208 apiData;
            Api1105 api1105;
            List<Api1208> api1208List;
            for (Fz35DepotStore fz35DepotStore : list) {

                //获取货位信息
@@ -80,6 +81,7 @@
                }

                apiData = new Api1208();
                apiData.setId(fz35DepotStore.getId());
                apiData.setHwdm(api1105.getHwdm());

                //粮食品种
@@ -135,7 +137,7 @@
                apiData.setSjzlxg(6);
                apiData.setLdtj(10000);

                apiData.setZhgxsj(new Date());
                apiData.setZhgxsj(fz35DepotStore.getUpdateDate());

                //业务id、库区编码、同步时间
                apiData.setBizId(fz35DepotStore.getId());
@@ -143,8 +145,13 @@
                apiData.setSyncTime(new Date());

                //库存每次新增
                api1208List = api1208Rep.getDataById(apiData.getId());
                if(null == api1208List || api1208List.isEmpty()){
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setId(ContextUtil.getCurTimeMillis());
                }else {
                    apiData.setCzbz(api1208List.get(0).getCzbz());
                }

                //保存数据
                api1208Rep.save(apiData);
            }

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

@@ -58,40 +58,40 @@
        Date end = param.getEnd();

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

        //合同同步
        fzzySync1201.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);

        //出入库文件信息同步
        fzzySync1109.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);


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

    }


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

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

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.fzzy40.impl.*;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -31,6 +33,8 @@
    private Fzzy40Sync1310 fzzySync1310;
    @Autowired
    private Fzzy40Sync1023 fzzySync1023;
    @Autowired
    private Fzzy40Sync2103 fzzy40Sync2103;

    @Override
    public String getProtocol() {
@@ -40,6 +44,20 @@
    @Override
    public void syncData(ApiParam param) {


        //各省独有接口信息同步
        if(StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_GD_2022.equals(param.getPushProtocol())){
            //广东省平台2022版，需要同步熏蒸备案信息
            //TODO ç†è’¸å¤‡æ¡ˆåŒæ­¥

        }
        if(StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.equals(param.getPushProtocol())){
            //上海市平台2023版，需要同步粮情设备配置信息

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

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


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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,134 @@
package com.fzzy.async.fzzy40.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 Fz40Depot implements Serializable {

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


    @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 = "ggm", length = 50)
    @PropertyDef(label = "国规码")
    private String ggm;

    @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 = "单位：吨")
    private Double storageMax;

    @Column(name = "STORAGE_REAL_", insertable = true)
    @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_", 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;

}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,128 @@
package com.fzzy.async.fzzy40.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(Fz40DepotConfKey.class)
public class Fz40DepotConf implements Serializable {

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

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

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

    @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 = "GAS_SER_", length = 40)
    @PropertyDef(label = "气体分机")
    private String gasSer;

    @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 = "TEMP_MAX_")
    @PropertyDef(label = "温度上限")
    private Double tempMax;

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

}

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

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

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

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

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

@@ -2,15 +2,17 @@

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1109;
import com.fzzy.api.entity.Api1202;
import com.fzzy.api.entity.Api1205;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtil;
import com.fzzy.api.view.repository.Api1109Rep;
import com.fzzy.api.view.repository.Api1202Rep;
import com.fzzy.api.view.repository.Api1205Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40FileInfo;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1109Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
@@ -48,9 +50,11 @@
    @Autowired
    private Fzzy40Sync1109Rep fzzySync1109Rep;
    @Autowired
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1205Rep api1205Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
@@ -88,24 +92,29 @@
            String wjlx;
            String wjmc;
            List<Api1109> api1109List;
            List<Fz40InoutRecord> listInout;
            List<Api1202> api1202List;
            List<Api1205> api1205List;
            String str = "";
            for (Fz40FileInfo sysData : list) {
                if (StringUtils.isEmpty(sysData.getBizId())) {
                    continue;
                }
                //根据图片id查询对应出入库信息
                listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId());
                if (null == listInout || listInout.isEmpty()) {
                if(sysData.getBizId().startsWith(IMG_START_R)){
                    api1202List = api1202Rep.getDataByBizId(sysData.getBizId());
                    if (null == api1202List || api1202List.isEmpty()) {
                    continue;
                }
                //若出入库信息为删除或者错误状态，则不同步
                if ("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())) {
                    str = api1202List.get(0).getRkywdh();
                }
                if(sysData.getBizId().startsWith(IMG_START_C)){
                    api1205List = api1205Rep.getDataByBizId(sysData.getBizId());
                    if (null == api1205List || api1205List.isEmpty()) {
                    continue;
                }
                //若出入库信息中入库重量为空或为0，则不同步
                if (null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0) {
                    continue;
                    str = api1205List.get(0).getCkywdh();
                }

                //只同步称重
                if (BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())) {
                    wjlx = "";
@@ -133,7 +142,7 @@
                    apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());

                    //文件名称
                    wjmc = getImgNameType(wjmc, sysData.getBizTag(), sysData.getBizId(), sysData.getFileName(), map);
                    wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
                    apiData.setWjmc(wjmc);
                    //文件类型
                    apiData.setWjlx(wjlx);

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

@@ -18,9 +18,8 @@
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

import java.util.*;

/**
 * ç²®é£Ÿå…¥åº“信息
@@ -65,7 +64,6 @@
        apiLog.setInteId(Constant.API_CODE_1202);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        String sfzh = "";
        try {
            //获取粮食入库记录信息，根据流程完成时间获取
            List<Fz40InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);
@@ -80,6 +78,9 @@
            List<Fz40InoutNoticeIn> listInoutNotice;
            List<Api1202> api1202List;
            Calendar c = Calendar.getInstance();
            String ywsj = "";
            String num = "";
            Map<String, Integer> map = new HashMap<>();
            for (Fz40InoutRecord sysData : list) {
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                    sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,11 +96,16 @@
                }
                apiData = new Api1202();


                apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
                //判断业务时间与单据号是否匹配
                if(!DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd").equals(sysData.getId().substring(4, 10))){
                    apiData.setRkywdh(Constant.INOUT_TYPE_14 + DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd") + sysData.getId().substring(10));
                ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
                if(!ywsj.equals(sysData.getId().substring(4, 10))){
                    if(null == map.get(ywsj)){
                        map.put(ywsj, 10201);
                    }
                    num = String.valueOf(map.get(ywsj)).substring(1);
                    apiData.setRkywdh(Constant.INOUT_TYPE_14 + ywsj + num);
                    map.put(ywsj, map.get(ywsj) + 1);
                }

                //货位代码
@@ -111,7 +117,7 @@
                //默认一个随便值
                apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact());

                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId());
                apiData.setSfzh(null == sysData.getUserId() ? "410183200010100000" : sysData.getUserId().trim());

                //获取合同号
                listInoutNotice = fzzySyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
@@ -189,13 +195,13 @@
                }else {
                    apiData.setCzbz(api1202List.get(0).getCzbz());
                }
                sfzh = apiData.getSfzh();

                //保存数据
                api1202Rep.save(apiData);
                log.info("1202---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            System.out.println(sfzh);

            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);

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

@@ -1,13 +1,10 @@
package com.fzzy.async.fzzy40.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1203;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.GbCheckItem;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1202Rep;
import com.fzzy.api.view.repository.Api1203Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.GbCheckItemRep;
@@ -20,9 +17,7 @@
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;
import java.util.*;

/**
 * ç²®é£Ÿå…¥åº“检验信息
@@ -40,15 +35,14 @@
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy40Sync1203Rep fzzySync1203Rep;

    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1203Rep api1203Rep;
    @Autowired
    private GbCheckItemRep gbCheckItemRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

@@ -81,7 +75,6 @@
            }

            Api1203 apiData;
            Api1105 api1105;
            List<Fz40CheckItem> fz40CheckItems;
            List<GbCheckItem> gbCheckList;
            String jyxm;
@@ -89,12 +82,11 @@
            String zkj;
            String zkl;
            List<Api1203> api1203List;
            List<Api1202> api1102List;
            for (Fz40InoutRecord sysData : list) {
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                    sysData.setRecordWeight(sysData.getSettleWeight());
                }
                //判断净重是否大于0，等于0表示不合格，不进行同步上传
                if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                //查询粮食入库信息，若为空则不进行同步上传
                api1102List = api1202Rep.getDataByBizId(sysData.getId());
                if(null == api1102List || api1102List.isEmpty()){
                    continue;
                }

@@ -105,19 +97,12 @@
                    continue;
                }

                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }

                apiData = new Api1203();

                apiData.setRkjydh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));

                apiData.setRkjydh(api1102List.get(0).getRkywdh());
                //货位代码
                apiData.setHwdm(api1105.getHwdm());
                apiData.setRkywdh(apiData.getRkjydh());
                apiData.setHwdm(api1102List.get(0).getHwdm());
                apiData.setRkywdh(api1102List.get(0).getRkywdh());
                if(null == sysData.getFullWeightTime()){
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
                }
@@ -163,10 +148,8 @@
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

                //粮食定等

                //保管员复核

                apiData.setBgyfh(apiData.getJyjg());

                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, sysData.getFoodLevel());

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

@@ -19,9 +19,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.*;

/**
 * ç²®é£Ÿå‡ºåº“信息
@@ -80,6 +78,9 @@
        List<Fz40InoutNoticeOut> listInoutNotice;
        List<Api1205> api1205List;
        Calendar c = Calendar.getInstance();
        String ywsj = "";
        String num = "";
        Map<String, Integer> map = new HashMap<>();
        for (Fz40InoutRecord sysData : list) {
            if(null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0){
                sysData.setRecordWeight(sysData.getSettleWeight());
@@ -95,7 +96,16 @@
            }
            apiData = new Api1205();
            apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4));

            //判断业务时间与单据号是否匹配
            ywsj = DateFormatUtils.format(sysData.getCompleteTime(),"yyMMdd");
            if(!ywsj.equals(sysData.getId().substring(4, 10))){
                if(null == map.get(ywsj)){
                    map.put(ywsj, 10201);
                }
                num = String.valueOf(map.get(ywsj)).substring(1);
                apiData.setCkywdh(Constant.INOUT_TYPE_15 + ywsj + num);
                map.put(ywsj, map.get(ywsj) + 1);
            }

            //货位代码
            apiData.setHwdm(api1105.getHwdm());

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

@@ -1,10 +1,7 @@
package com.fzzy.async.fzzy40.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1208;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
@@ -75,6 +72,7 @@

            Api1208 apiData;
            Api1105 api1105;
            List<Api1208> api1208List;
            for (Fz40DepotStore fz40DepotStore : list) {

                //获取货位信息
@@ -84,6 +82,7 @@
                }

                apiData = new Api1208();
                apiData.setId(fz40DepotStore.getId());
                apiData.setHwdm(api1105.getHwdm());

                //粮食品种
@@ -139,7 +138,7 @@
                apiData.setSjzlxg(6);
                apiData.setLdtj(10000);

                apiData.setZhgxsj(new Date());
                apiData.setZhgxsj(fz40DepotStore.getUpdateDate());

                //业务id、库区编码、同步时间
                apiData.setBizId(fz40DepotStore.getId());
@@ -147,8 +146,13 @@
                apiData.setSyncTime(new Date());

                //库存每次新增
                api1208List = api1208Rep.getDataById(apiData.getId());
                if(null == api1208List || api1208List.isEmpty()){
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setId(ContextUtil.getCurTimeMillis());
                }else {
                    apiData.setCzbz(api1208List.get(0).getCzbz());
                }

                //保存数据
                api1208Rep.save(apiData);
            }

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

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

import com.alibaba.fastjson.JSON;
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1105;
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.Api1102Rep;
import com.fzzy.api.view.repository.ApiInfoDataRep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40Depot;
import com.fzzy.async.fzzy40.entity.Fz40DepotConf;
import com.fzzy.async.fzzy40.repository.Fzzy40SyncDepotConfRep;
import com.fzzy.async.fzzy40.repository.Fzzy40SyncDepotRep;
import com.fzzy.push.sh2023.SH2023Constant;
import com.fzzy.push.sh2023.dto.SH2023Api2103;
import com.fzzy.push.sh2023.dto.SH2023Api2103Item;
import com.fzzy.push.sh2023.dto.ShAreaBjw;
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 Fzzy40Sync2103 {

    @Autowired
    private Fzzy40SyncDepotRep fzzy40SyncDepotRep;
    @Autowired
    private Fzzy40SyncDepotConfRep fzzy40SyncDepotConfRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @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 {
            List<Fz40Depot> list = fzzy40SyncDepotRep.listDepotList(deptId);

            if (null == list || list.isEmpty()) {
                log.info("2103---粮情设备配置同步数据：没有查询到仓库信息");
                return;
            }

            List<Api1102> api1102List = api1102Rep.findPushData(kqdm);
            String bjw = "";
            if(null != api1102List && api1102List.size() > 0){
                bjw = ShAreaBjw.getBjw(api1102List.get(0).getXzqhdm());
            }

            SH2023Api2103 sh2023Api2103;
            Api1105 api1105;
            List<Fz40DepotConf> depotConfList;
            Fz40DepotConf depotConf;

            List<ApiInfoData> apiInfoDataList;
            SH2023Api2103Item sh2023Api2103Item;
            List<SH2023Api2103Item> listItem;
            for (Fz40Depot fz40Depot : list) {
                //根据仓库编码获取配置信息
                depotConfList = fzzy40SyncDepotConfRep.findDataByDepotId(fz40Depot.getId());
                if(null == depotConfList || depotConfList.isEmpty()){
                    continue;
                }
                //获取货位信息
                api1105 = commonService.getApi1105Cache(fz40Depot.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]);
                // 1-3-5
                // 8-8-8
                //筒仓规则
                if(StringUtils.isNotEmpty(depotConf.getCableCir())){
                    sh2023Api2103.setDlqs(String.valueOf(strs.length));
                    sh2023Api2103.setDlhs(null);
                    sh2023Api2103.setDlls(null);

                    //电缆圈排列详情
                    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(strs[0]);

                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.getDataByDataId(infoData.getDataId());
                if (null == apiInfoDataList || apiInfoDataList.isEmpty()) {
                    infoData.setCzbz(Constant.CZBZ_I);
                } else {
                    infoData.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/fzzy40/repository/Fzzy40Sync1202Rep.java

@@ -23,7 +23,7 @@
     * @param end
     * @return
     */
    @Query("from Fz40InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <:end order by updateTime ")
    @Query("from Fz40InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <:end order by id ")
    List<Fz40InoutRecord> listInoutRecord(@Param("deptId") String deptId, @Param("type") String type, @Param("start") Date start, @Param("end") Date end);

    /**

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

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

import com.fzzy.async.fzzy40.entity.Fz40DepotConf;
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 Fzzy40SyncDepotConfRep extends JpaRepository<Fz40DepotConf, String> {

    /**
     * æ ¹æ®ä»“库编码获取粮情参数配置信息
     * @param depotId
     * @return
     */
    @Query("from Fz40DepotConf where depotId =:depotId order by depotId ")
    List<Fz40DepotConf> findDataByDepotId(@Param("depotId") String depotId);
}

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

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

import com.fzzy.async.fzzy40.entity.Fz40Depot;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
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-08-21
 */
public interface Fzzy40SyncDepotRep extends JpaRepository<Fz40Depot, String> {

    /**
     * æ ¹æ®åº“区编码获取货位列表
     * @param deptId
     * @return
     */
    @Query("from Fz40Depot where deptId=:deptId order by id ")
    List<Fz40Depot> listDepotList(@Param("deptId") String deptId);

}

 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,9 +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.ApiLogRep;
import com.fzzy.api.view.repository.*;
import com.fzzy.push.sh2023.dto.*;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
@@ -24,6 +22,7 @@
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashSet;
import java.util.List;

/**
@@ -49,6 +48,12 @@
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1104Rep api1104Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1205Rep api1205Rep;

    @Override
    public String getProtocol() {
@@ -200,6 +205,371 @@
                list.add(api1103);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1104.equals(inteId)) {
            SH2023Api1104 api1104;
            //最后转换为json
            List<SH2023Api1104> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1104> api1104List = castList(data, Api1104.class);
            for (Api1104 apiData : api1104List) {
                api1104 = new SH2023Api1104();
                BeanUtils.copyProperties(apiData, api1104);
                api1104.setAjdm(apiData.getAjdh());
                api1104.setCfdm(apiData.getCfbh());
                api1104.setSykqdm(apiData.getKqdm());
                api1104.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1104);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1105.equals(inteId)) {
            SH2023Api1105 api1105;
            //最后转换为json
            List<SH2023Api1105> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1105> api1105List = castList(data, Api1105.class);
            for (Api1105 apiData : api1105List) {
                api1105 = new SH2023Api1105();
                BeanUtils.copyProperties(apiData, api1105);
                api1105.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1105);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1106.equals(inteId)) {
            SH2023Api1106 api1106;
            //最后转换为json
            List<SH2023Api1106> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1106> api1106List = castList(data, Api1106.class);
            for (Api1106 apiData : api1106List) {
                api1106 = new SH2023Api1106();
                BeanUtils.copyProperties(apiData, api1106);
                api1106.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1106);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1107.equals(inteId)) {
            SH2023Api1107 api1107;
            //最后转换为json
            List<SH2023Api1107> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1107> api1107List = castList(data, Api1107.class);
            for (Api1107 apiData : api1107List) {
                api1107 = new SH2023Api1107();
                BeanUtils.copyProperties(apiData, api1107);
                api1107.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1107);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1108.equals(inteId)) {
            SH2023Api1108 api1108;
            //最后转换为json
            List<SH2023Api1108> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1108> api1108List = castList(data, Api1108.class);
            for (Api1108 apiData : api1108List) {
                api1108 = new SH2023Api1108();
                BeanUtils.copyProperties(apiData, api1108);
                api1108.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1108);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1109.equals(inteId)) {
            SH2023Api1109 api1109;
            //最后转换为json
            List<SH2023Api1109> list = new ArrayList<>();
            FileUtil file;
            //把data转化成list集合
            List<Api1109> api1109List = castList(data, Api1109.class);
            for (Api1109 apiData : api1109List) {
                api1109 = new SH2023Api1109();
                BeanUtils.copyProperties(apiData, api1109);
                api1109.setBjw(ShAreaBjw.getBjw(code));
                file = new FileUtil();
                api1109.setWjl(file.imgToIo(apiData.getWjdz() + apiData.getWjmc()));
                list.add(api1109);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1110.equals(inteId)) {
            SH2023Api1110 api1110;
            //最后转换为json
            List<SH2023Api1110> list = new ArrayList<>();
            HashSet<String> set = new HashSet<>();
            //把data转化成list集合
            List<Api1110> api1110List = castList(data, Api1110.class);
            for (Api1110 apiData : api1110List) {
                // å› ä¸ºå»’间是根据货位截取，所以要判断廒间是否重复
                if (!set.add(apiData.getHwdm().substring(0, 28))) {
                    continue;
                }
                api1110 = new SH2023Api1110();
                BeanUtils.copyProperties(apiData, api1110);
                api1110.setBjw(ShAreaBjw.getBjw(code));
                api1110.setAjdm(apiData.getHwdm().substring(0, 28));
                api1110.setAjxdwz(apiData.getHwxdwz());
                api1110.setAjwzys(apiData.getHwwzys());
                list.add(api1110);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1111.equals(inteId)) {
            SH2023Api1111 api1111;
            //最后转换为json
            List<SH2023Api1111> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1111> api1111List = castList(data, Api1111.class);
            for (Api1111 apiData : api1111List) {
                api1111 = new SH2023Api1111();
                BeanUtils.copyProperties(apiData, api1111);
                api1111.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1111);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1112.equals(inteId)) {
            SH2023Api1112 api1112;
            //最后转换为json
            List<SH2023Api1112> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1112> api1112List = castList(data, Api1112.class);
            for (Api1112 apiData : api1112List) {
                api1112 = new SH2023Api1112();
                BeanUtils.copyProperties(apiData, api1112);
                api1112.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1112);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1113.equals(inteId)) {
            SH2023Api1113 api1113;
            //最后转换为json
            List<SH2023Api1113> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1113> api1113List = castList(data, Api1113.class);
            for (Api1113 apiData : api1113List) {
                api1113 = new SH2023Api1113();
                BeanUtils.copyProperties(apiData, api1113);
                api1113.setBjw(ShAreaBjw.getBjw(code));
                list.add(api1113);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1201.equals(inteId)) {
            SH2023Api1201 api1201;
            //最后转换为json
            List<SH2023Api1201> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1201> api1201List = castList(data, Api1201.class);
            for (Api1201 apiData : api1201List) {
                api1201 = new SH2023Api1201();
                BeanUtils.copyProperties(apiData, api1201);
                api1201.setBjw(ShAreaBjw.getBjw(code));
                api1201.setHtsfzz("0");
                list.add(api1201);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1202.equals(inteId)) {
            SH2023Api1202 api1202;
            //最后转换为json
            List<SH2023Api1202> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1202> api1202List = castList(data, Api1202.class);
            for (Api1202 apiData : api1202List) {
                api1202 = new SH2023Api1202();
                BeanUtils.copyProperties(apiData, api1202);
                api1202.setBjw(ShAreaBjw.getBjw(code));
                api1202.setPch(apiData.getHwdm() + apiData.getShnd());
                //todo é©³è¿å•å·(2104)  æ£€æ–¤å•å·(2101)   å‡ä¸ºéžå¿…å¡«
                api1202.setJzrq(apiData.getCmsj());
                list.add(api1202);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1203.equals(inteId)) {
            SH2023Api1203 api1203;
            //最后转换为json
            List<SH2023Api1203> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1203> api1203List = castList(data, Api1203.class);
            for (Api1203 apiData : api1203List) {
                api1203 = new SH2023Api1203();
                BeanUtils.copyProperties(apiData, api1203);
                api1203.setBjw(ShAreaBjw.getBjw(code));
                //查询收获年份
                List<Api1202> api1202List = api1202Rep.getDataById(apiData.getRkywdh());
                api1203.setPch(apiData.getHwdm() + api1202List.get(0).getShnd());
                list.add(api1203);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1204.equals(inteId)) {
            SH2023Api1204 api1204;
            //最后转换为json
            List<SH2023Api1204> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1204> api1204List = castList(data, Api1204.class);
            for (Api1204 apiData : api1204List) {
                api1204 = new SH2023Api1204();
                BeanUtils.copyProperties(apiData, api1204);
                api1204.setBjw(ShAreaBjw.getBjw(code));
                api1204.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getJssj(), "yyyy"));
                list.add(api1204);
            }
            return JSON.toJSONString(list);
        } else if (SH2023Constant.SH_2023_API_CODE_1205.equals(inteId)) {
            SH2023Api1205 api1205;
            //最后转换为json
            List<SH2023Api1205> list = new ArrayList<>();
            //把data转化成list集合
            List<Api1205> api1205List = castList(data, Api1205.class);
            for (Api1205 apiData : api1205List) {
                api1205 = new SH2023Api1205();
                BeanUtils.copyProperties(apiData, api1205);
                api1205.setBjw(ShAreaBjw.getBjw(code));
                api1205.setPch(apiData.getHwdm() + DateFormatUtils.format(apiData.getCmsj(), "yyyy"));
                api1205.setJzrq(apiData.getCmsj());
                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/SH2023PushService11.java

@@ -108,7 +108,7 @@
            log.error("-----上海市平台2023版：未获取到单位信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1101);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -135,7 +135,7 @@
            log.error("-----上海市平台2023版：未获取到库区信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1102);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -163,7 +163,7 @@
            log.error("-----上海市平台2023版：未获取到仓房信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1103);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -191,7 +191,7 @@
            log.error("-----上海市平台2023版：未获取到廒间信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1104);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -205,8 +205,6 @@
                }
            }
        }


    }

    /**
@@ -220,7 +218,7 @@
            log.error("-----上海市平台2023版：未获取到货位信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1105);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -248,7 +246,7 @@
            log.error("-----上海市平台2023版：未获取到油罐信息，不推送-----");
            return;
        }

        param.setInteId(SH2023Constant.SH_2023_API_CODE_1106);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
@@ -269,7 +267,27 @@
     * 1107  è®¾å¤‡ä¿¡æ¯
     */
    public void pushData1107(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取设备信息
        List<Api1107> list = api1107Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到设备信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1107);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1107 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -277,7 +295,27 @@
     * 1108  è¯å‰‚信息
     */
    public void pushData1108(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取药剂信息
        List<Api1108> list = api1108Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到药剂信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1108);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1108 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -285,7 +323,27 @@
     * 1109  æ–‡ä»¶ä¿¡æ¯
     */
    public void pushData1109(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取文件信息
        List<Api1109> list = api1109Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到文件信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1109);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1109 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -293,7 +351,27 @@
     * 1110 åº“区图仓房点位标注
     */
    public void pushData1110(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取库区图仓房点位标注
        List<Api1110> list = api1110Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到库区图仓房点位标注，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1110);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1110 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -301,15 +379,54 @@
     * 1111 åº“区图视频监控设备点位标注
     */
    public void pushData1111(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取库区图视频监控设备点位标注
        List<Api1111> list = api1111Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到库区图视频监控设备点位标注，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1111);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1111 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    /**
     * 1112  äººå‘˜ä¿¡æ¯
     */
    public void pushData1112(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取人员信息
        List<Api1112> list = api1112Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到人员信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1112);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1112 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -317,7 +434,27 @@
     * 1113  ä¼ä¸šä¿¡ç”¨ä¿¡æ¯
     */
    public void pushData1113(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取企业信用信息
        List<Api1113> list = api1113Rep.findPushData(param.getKqdm());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到企业信用信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1113);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1113 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }


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

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

import com.alibaba.fastjson.JSONObject;
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.push.impl.ComPushService11;
import com.fzzy.api.view.repository.*;
import com.fzzy.otherview.sh2023.dto.ShApi2101;
import com.fzzy.push.sh2023.dto.SH2023Api2101;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

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

    @Autowired
    private SH2023ApiRemoteService apiRemoteService;
    @Autowired
    private Api1201Rep api1201Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1203Rep api1203Rep;
    @Autowired
    private Api1204Rep api1204Rep;
    @Autowired
    private Api1205Rep api1205Rep;
    @Autowired
    private Api1206Rep api1206Rep;
    @Autowired
    private Api1207Rep api1207Rep;
    @Autowired
    private Api1208Rep api1208Rep;
    @Autowired
    private Api1209Rep api1209Rep;
    @Autowired
    private Api1210Rep api1210Rep;
    @Autowired
    private Api1211Rep api1211Rep;
    @Autowired
    private Api1212Rep api1212Rep;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;

    @Override
    public String getProtocol() {
@@ -30,35 +65,116 @@

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

        //推送单位信息
        //推送合同信息
        this.pushData1201(apiRemoteService, param);
        //粮食入库信息
        this.pushData1202(apiRemoteService, param);
        //粮食入库检验信息
        this.pushData1203(apiRemoteService, param);
        //粮食入库结算信息
        this.pushData1204(apiRemoteService, param);
        //粮食出库信息
        this.pushData1205(apiRemoteService, param);
        //粮食出库结算信息
        this.pushData1206(apiRemoteService, param);
        //倒仓倒出
        this.pushData1207(apiRemoteService, param);
        //粮食库存
        this.pushData1208(apiRemoteService, param);
        //损溢单
        this.pushData1209(apiRemoteService, param);
        //粮食性质转变单
        this.pushData1210(apiRemoteService, param);
        //账面库存
        this.pushData1211(apiRemoteService, param);
        //客户信息
        this.pushData1212(apiRemoteService, param);


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

    /**
     * 1201 åˆåŒä¿¡æ¯
     */
    public void pushData1201(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取合同信息
        List<Api1201> list = api1201Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到合同信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1201);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1201 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    /**
     * 1202 ç²®é£Ÿå…¥åº“信息
     */
    public void pushData1202(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取粮食入库信息
        List<Api1202> list = api1202Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮食入库信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1202);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1202 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    /**
     * 1203 ç²®é£Ÿå…¥åº“检验信息
     */
    public void pushData1203(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取粮食入库检验信息
        List<Api1203> list = api1203Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮食入库检验信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1203);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1203 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -66,7 +182,27 @@
     * 1204 ç²®é£Ÿå…¥åº“结算信息
     */
    public void pushData1204(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取粮食入库结算信息
        List<Api1204> list = api1204Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮食入库结算信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1204);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1204 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -74,15 +210,54 @@
     * 1205 ç²®é£Ÿå‡ºåº“信息
     */
    public void pushData1205(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取粮食出库信息
        List<Api1205> list = api1205Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮食出库信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1205);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1205 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    /**
     * 1206 ç²®é£Ÿå‡ºåº“结算信息
     */
    public void pushData1206(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        //获取粮食出库结算信息
        List<Api1206> list = api1206Rep.findPushDataByTime(param.getKqdm(), param.getStart(), param.getEnd());

        if (null == list || list.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮食出库结算信息，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1206);
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (Api1206 data : list) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

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

    }

@@ -138,8 +313,31 @@
     * 2101 æ£€æ–¤å•
     */
    public void pushData2101(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

        //获取 æ£€æ–¤å•ä¿¡æ¯
        List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(SH2023Constant.SH_2023_API_CODE_2101);

        SH2023Api2101 shApi2101;
        List<SH2023Api2101> list = new ArrayList<>();

        param.setInteId(SH2023Constant.SH_2023_API_CODE_2101);
        for (ApiInfoData infoData : items) {
            shApi2101 = JSONObject.parseObject(infoData.getData(), SH2023Api2101.class);
            shApi2101.setCzbz(infoData.getCzbz());
            shApi2101.setZhgxsj(infoData.getUpdateTime());
            list.add(shApi2101);
        }
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (ApiInfoData data : items) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    apiInfoDataRep.save(data);
                }
            }
        }
    }

    /**

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

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

import com.alibaba.fastjson.JSONObject;
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.dto.ShApi2103;
import com.fzzy.otherview.sh2023.repository.ShApi1311Rep;
import com.fzzy.push.impl.ComPushService11;
import com.fzzy.push.sh2023.dto.SH2023Api1311;
import com.fzzy.push.sh2023.dto.SH2023Api2103;
import lombok.extern.slf4j.Slf4j;
import org.codehaus.jackson.JsonParser;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

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

    @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;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;

    @Override
    public String getProtocol() {
@@ -30,19 +66,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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1301);
        //推送，数据为集合形式
        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 +115,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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1302);
        //推送，数据为集合形式
        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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1303);
        //推送，数据为集合形式
        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 +170,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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1304);
        //推送，数据为集合形式
        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 +198,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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1305);
        //推送，数据为集合形式
        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 +226,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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1306);
        //推送，数据为集合形式
        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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1307);
        //推送，数据为集合形式
        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,15 +297,61 @@
     * 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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1310);
        //推送，数据为集合形式
        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);
                }
            }
        }
    }

    /**
     * 1311 è§†é¢‘监控接口
     */
    public void pushData1311(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO
        // èŽ·å– è§†é¢‘监控接口数据
        List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(SH2023Constant.SH_2023_API_CODE_1311);

        if (null == items || items.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到视频监控，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1311);

        SH2023Api1311 shApi1311;
        List<SH2023Api1311> list = new ArrayList<>();
        for (ApiInfoData infoData : items) {
            shApi1311 = JSONObject.parseObject(infoData.getData(), SH2023Api1311.class);
            shApi1311.setCzbz(infoData.getCzbz());
            shApi1311.setZhgxsj(infoData.getUpdateTime());
            list.add(shApi1311);
        }
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (ApiInfoData data : items) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    apiInfoDataRep.save(data);
                }
            }
        }

    }

@@ -130,7 +359,34 @@
     * 2103 ç²®æƒ…设备配置
     */
    public void pushData2103(ApiRemoteService apiRemoteService, ApiParam param) {
        //TODO

        // èŽ·å–粮情设备配置数据
        List<ApiInfoData> items = apiInfoDataRep.getDataByInteId(SH2023Constant.SH_2023_API_CODE_2103);

        if (null == items || items.isEmpty()) {
            log.error("-----上海市平台2023版：未获取到粮情设备配置，不推送-----");
            return;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_2103);
        SH2023Api2103 shApi2103;
        List<SH2023Api2103> list = new ArrayList<>();
        for (ApiInfoData infoData : items) {
            shApi2103 = JSONObject.parseObject(infoData.getData(), SH2023Api2103.class);
            shApi2103.setZhgxsj(infoData.getUpdateTime());
            list.add(shApi2103);
        }
        //推送，数据为集合形式
        ResponseDto responseDto = apiRemoteService.pushData(param, list);
        if (responseDto.getSuccess() == 0) {
            //推送成功，更新数据上传状态
            for (ApiInfoData data : items) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {

                    data.setCzbz(Constant.CZBZ_U);
                    apiInfoDataRep.save(data);
                }
            }
        }

    }
}

 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;
        }
        param.setInteId(SH2023Constant.SH_2023_API_CODE_1401);
        //推送，数据为集合形式
        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/SH2023Api1104.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,76 @@
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 14:18
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1104 implements Serializable {

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

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

    @PropertyDef(label = "廒间名称")
    private String ajmc;

    @PropertyDef(label = "仓房(或油罐)编码")
    private String cfdm;

    @PropertyDef(label = "廒间长度")
    private double ajcd;

    @PropertyDef(label = "廒间宽度")
    private double ajkd;

    @PropertyDef(label = "廒间高度")
    private double ajgd;

    @PropertyDef(label = "廒间设计仓容")
    private double ajsjcr;

    @PropertyDef(label = "廒间联系电话")
    private String ajlxdh;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "廒间启用日期")
    private Date ajqyrq;

    @PropertyDef(label = "廒间状态")
    private String ajzt;

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

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

    @PropertyDef(label = "使用库区代码")
    private String sykqdm;

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


}

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

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

/**
 * æŽ¥å£è¡¨-货位信息
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1105 implements Serializable {

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

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

    @PropertyDef(label = "货位名称")
    private String hwmc;

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

    @PropertyDef(label = "货位启用日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date hwqyrq;

    @PropertyDef(label = "货位容量")
    private double hwrl;

    @PropertyDef(label = "保管单位")
    private String bgdw;

    @PropertyDef(label = "保管员")
    private String bgy;

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

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

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

}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,88 @@
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;

/**
 * æŽ¥å£è¡¨-油罐信息
 */
@Data
public class SH2023Api1106 implements Serializable {

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

    @JSONField(serialize = false)
    @PropertyDef(label = "业务id")
    private String bizId;

    @PropertyDef(label = "油罐代码")
    private String ygdm;

    @PropertyDef(label = "油罐名称")
    private String ygmc;

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

    @PropertyDef(label = "罐容")
    private double gr;

    @PropertyDef(label = "建造时间")
    @JSONField(format = "yyyy-MM-dd")
    private Date jzsj;

    @PropertyDef(label = "油罐及附属设施是否完好")
    private String ygjfssssfwh;

    @PropertyDef(label = "有无加热装置")
    private String ywjrzz;

    @PropertyDef(label = "油罐类型")
    private String yglx;

    @PropertyDef(label = "罐内直径")
    private double gnzj;

    @PropertyDef(label = "罐内高度")
    private double gngd;

    @PropertyDef(label = "检定方式")
    private String jdfs;

    @PropertyDef(label = "焊接方式")
    private String hjfs;

    @PropertyDef(label = "油罐状态")
    private String ygzt;

    @PropertyDef(label = "设计单位")
    private String sjdw;

    @PropertyDef(label = "建设单位")
    private String jsdw;

    @PropertyDef(label = "监理单位")
    private String jldw;

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

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

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

}

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

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

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonIgnore;
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;

/**
 * æŽ¥å£è¡¨-设备信息
 */
@Data
public class SH2023Api1107 implements Serializable {

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


    @PropertyDef(label = "设备编号")
    private String sbbh;


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

    @PropertyDef(label = "设备仪器名称")
    private String sbyqmc;

    @PropertyDef(label = "设备仪器代码")
    private String sbyqdm;

    @PropertyDef(label = "设备规格型号")
    private String sbggxh;

    @PropertyDef(label = "生产厂家")
    private String sccj;

    @PropertyDef(label = "生产日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date scrq;

    @PropertyDef(label = "设备描述")
    private String sbms;

    @PropertyDef(label = "设备状态")
    private String sbzt;

    @PropertyDef(label = "检定时间")
    @JSONField(format = "yyyy-MM-dd")
    private Date jdsj;

    @PropertyDef(label = "检定单位")
    private String jddw;

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

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

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

}

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

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

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

/**
 * æŽ¥å£è¡¨-药剂信息
 */
@Data
public class SH2023Api1108 implements Serializable {

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


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

    @PropertyDef(label = "药剂编号")
    @Column(name = "yjbh", length = 50)
    private String yjbh;

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

    @PropertyDef(label = "包装物")
    private String bzw;

    @PropertyDef(label = "型号规格")
    private String ggxh;

    @PropertyDef(label = "安全使用说明书")
    private String aqsysms;

    @PropertyDef(label = "生产厂家")
    private String sccj;

    @PropertyDef(label = "采购来源")
    private String cgly;

    @PropertyDef(label = "储存条件")
    private String cctj;

    @PropertyDef(label = "储存地点")
    private String ccdd;

    @PropertyDef(label = "包装物处理方式")
    private String bzwclfs;

    @PropertyDef(label = "残渣处理方式")
    private String czclfs;

    @PropertyDef(label = "保质期")
    @JSONField(format = "yyyy-MM-dd")
    private Date bzq;

    @PropertyDef(label = "采购日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date cgrq;

    @PropertyDef(label = "库存数量")
    private Double kcsl;

    @PropertyDef(label = "库存数量单位")
    private String kcsldw;

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

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

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

}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,47 @@
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;

/**
 * æŽ¥å£è¡¨-文件信息
 */
@Data
public class SH2023Api1109 implements Serializable {

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


    @PropertyDef(label = "文件名称")
    private String wjmc;

    @PropertyDef(label = "库区代码")
    private String kqdm;
    
    @PropertyDef(label = "文件类型", description = "1：库区鸟瞰图 2：入库图片 3：出库图片 4：入库检斤视频（截取检斤时间前后各 5秒钟视频）5：出库检斤视频（截取检斤时间前后各 5 ç§’钟视频）104：熏蒸备案接口附件")
    private String wjlx;

    @PropertyDef(label = "文件流")
    private String wjl;

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

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

    @PropertyDef(label = "最后更新时间")
    private String bjw;
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,51 @@
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;

/**
 * æŽ¥å£è¡¨-库区图仓房点位标注
 */
@Data
public class SH2023Api1110 implements Serializable {

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

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

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

    @PropertyDef(label = "廒间相对位置")
    private String ajxdwz;

    @PropertyDef(label = "廒间位置样式")
    private String ajwzys;

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

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

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


}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,55 @@
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;

/**
 * æŽ¥å£è¡¨-库区图视频监控设备点位标注
 */
@Data
public class SH2023Api1111 implements Serializable {

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

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

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

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

    @PropertyDef(label = "视频监控设备相对位置")
    private String spjksbxdwz;

    @PropertyDef(label = "视频监控设备位置样式")
    private String spjksbwzys;

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

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

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

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

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

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,106 @@
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;

/**
 * æŽ¥å£è¡¨-人员信息
 */
@Data
public class SH2023Api1112 implements Serializable {

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

    @PropertyDef(label = "身份证号码")
    private String sfzhm;

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


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

    @PropertyDef(label = "单位名称")
    private String dwmc;

    @PropertyDef(label = "隶属部门")
    private String lsbm;

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

    @PropertyDef(label = "姓名")
    private String xm;

    @PropertyDef(label = "性别")
    private String xb;

    @PropertyDef(label = "入职日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date rzrq;

    @PropertyDef(label = "岗位性质")
    private String gwxz;

    @PropertyDef(label = "在岗状态")
    private String zgzt;

    @PropertyDef(label = "离职日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date lzrq;

    @PropertyDef(label = "座机电话")
    private String zjdh;

    @PropertyDef(label = "移动电话")
    private String yddh;

    @PropertyDef(label = "电子邮箱")
    private String dzyx;

    @PropertyDef(label = "民族")
    private String mz;

    @PropertyDef(label = "政治面貌")
    private String zzmm;

    @PropertyDef(label = "人员类别")
    private String rylb;

    @PropertyDef(label = "专业")
    private String zy;

    @PropertyDef(label = "取得最高职称或职业资格时间")
    @JSONField(format = "yyyy-MM-dd")
    private Date qdzgzchzyzgsj;

    @PropertyDef(label = "学历")
    private String xl;

    @PropertyDef(label = "职务")
    private String zw;

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

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

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


}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,48 @@
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;

/**
 * æŽ¥å£è¡¨-企业信用信息
 */
@Data
public class SH2023Api1113 implements Serializable {

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

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

    @PropertyDef(label = "信用等级")
    private String xydj;

    @PropertyDef(label = "评定年份")
    private String pdnf;

    @PropertyDef(label = "评定单位/机构名称")
    private String pddw;

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

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

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


}

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

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

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.conf.NumberSerializer;
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.math.BigDecimal;
import java.util.Date;

/**
 * æŽ¥å£è¡¨-合同信息
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1201 implements Serializable {

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

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

    @PropertyDef(label = "合同名称")
    @Column(name = "htmc", length = 128)
    private String htmc;

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

    @PropertyDef(label = "业务类别")
    private String ywlx;

    @PropertyDef(label = "客户类型")
    private String khlx;

    @PropertyDef(label = "客户统一社会信用代码")
    private String khtyshxydm;

    @PropertyDef(label = "客户名称")
    private String khmc;

    @PropertyDef(label = "法定代表人")
    private String fddbr;

    @PropertyDef(label = "通讯地址")
    private String txdz;

    @PropertyDef(label = "邮政编码")
    private String yzbm;

    @PropertyDef(label = "联系人姓名")
    private String lxrxm;

    @PropertyDef(label = "联系电话")
    private String lxrdh;

    @PropertyDef(label = "身份证号")
    private String sfzh;

    @PropertyDef(label = "电子信箱")
    private String dzyx;

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

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "约定完成时间")
    private Date ydwcsj;

    @PropertyDef(label = "签订地点")
    private String qddd;

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

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

    @PropertyDef(label = "合同单价")
    private double htdj;

    @PropertyDef(label = "约定购销粮食数量")
    private double ydgxlssl;

    @JSONField(serializeUsing = NumberSerializer.class)
    @PropertyDef(label = "合同总金额")
    private BigDecimal htzje;

    @PropertyDef(label = "履约保证金")
    private double lybzj;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "实际完成时间")
    private Date sswcsj;

    @JSONField(name = "Lysl")
    @PropertyDef(label = "履约数量")
    private double lysl;

    @JSONField(name = "Lyl")
    @PropertyDef(label = "履约率")
    private double lyl;

    @JSONField(name = "Jsjg")
    @PropertyDef(label = "结算价格")
    private double jsjg;

    @JSONField(name = "Jszje", serializeUsing = NumberSerializer.class)
    @PropertyDef(label = "结算总金额")
    private BigDecimal jszje;

    @PropertyDef(label = "结算与合同一致性")
    private String jsyhtyzx;

    @PropertyDef(label = "结算与合同不一致原因")
    private String jsyhtbyzyy;

    @PropertyDef(label = "客户方开户行")
    private String khfkhh;

    @PropertyDef(label = "客户方账号")
    private String khfzh;

    @PropertyDef(label = "客户签约人")
    private String khqyr;

    @PropertyDef(label = "本方开户行")
    private String bfkhh;

    @PropertyDef(label = "本方账号")
    private String bfzh;

    @PropertyDef(label = "本方签约人")
    private String bfqyr;

    @PropertyDef(label = "审批人")
    private String shr;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "审批时间")
    private Date shsj;

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

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

    @JSONField(serialize = false)
    @PropertyDef(label = "业务id")
    private String bizId;

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

    @JSONField(serialize = false)
    @PropertyDef(label = "同步时间", description = "从粮库系统同步到接口管理中心的时间")
    private Date syncTime;

    @PropertyDef(label = "合同是否中止")
    private String htsfzz;

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

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,227 @@
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 SH2023Api1202 implements Serializable {

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


    //12 ä½æ•°å­—组成，第 1-2 ä½ä¸ºä¸šåŠ¡ä»£ç ï¼ˆ14代表粮食入库），第 3-8 ä½ä¾æ¬¡ä¸ºå¹´ä»½çš„后两位、2 ä½æœˆä»½ã€2 ä½æ—¥æœŸï¼ŒåŽå››ä½ä¸ºé¡ºåºç ã€‚例如：141605041234

    @PropertyDef(label = "入库业务单号")
    private String rkywdh;

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

    @PropertyDef(label = "业务类型", description = "2：入库（默认）")
    private String ywlx = "2";

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "业务日期")
    private Date ywrq;

    @PropertyDef(label = "计划明细号")
    private String jhmxh;

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

    @PropertyDef(label = "粮权归属单位代码")
    private String lqgsdwdm;

    @PropertyDef(label = "承运人")
    private String cyr;

    @PropertyDef(label = "联系电话")
    private String lxdh;

    @PropertyDef(label = "身份证号")
    private String sfzh;

    @PropertyDef(label = "详细地址")
    private String xxdz;

    @PropertyDef(label = "运输工具")
    private String ysgj;

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

    @PropertyDef(label = "车船号类型")
    private String cchlx;

    @PropertyDef(label = "挂车号")
    private String gch;

    @PropertyDef(label = "装粮地点")
    private String ldd;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "登记时间")
    private Date djsj;

    @PropertyDef(label = "登记门岗人员姓名")
    private String djmgryxm;

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

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

    @PropertyDef(label = "收获年度")
    private String shnd;

    @PropertyDef(label = "产地代码")
    private String cddm;

    @PropertyDef(label = "检斤类型")
    private String jjlx;

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

    @PropertyDef(label = "毛重监磅员")
    private String mzjby;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "毛重计量时间")
    private Date mzjlsj;

    @PropertyDef(label = "毛重计量员")
    private String mzjly;

    @PropertyDef(label = "值仓员")
    private String zcy;

    @PropertyDef(label = "皮重(公斤)")
    private double pz;

    @PropertyDef(label = "皮重监磅员")
    private String pzjby;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "皮重计量时间")
    private Date pzjlsj;

    @PropertyDef(label = "皮重计量员")
    private String pzjly;

    @PropertyDef(label = "包装物")
    private String bzw;

    @PropertyDef(label = "标准包单包重(公斤)")
    private double bzbdbz = 25;

    @PropertyDef(label = "标准包件数(件)")
    private Integer bzbjs;

    @PropertyDef(label = "质检扣量(小计:公斤)")
    private double zjklxj;

    @PropertyDef(label = "其中：水分增扣量(公斤)")
    private double qzsfzkl;

    @PropertyDef(label = "其中：杂质增扣量(公斤)")
    private double qzzzzkl;

    @PropertyDef(label = "其中：不完善粒扣量(公斤)")
    private double qzbwslkl;

    @PropertyDef(label = "其中：互混扣量(公斤)")
    private double qzhhkl;

    @PropertyDef(label = "其中：生霉粒扣量(公斤)")
    private double qzsmlkl;

    @PropertyDef(label = "其中：整精米粒扣量(公斤)")
    private double qzzjmlkl;

    @PropertyDef(label = "其中：谷外糙米扣量(公斤)")
    private double qzgwcmkl;

    @PropertyDef(label = "其中黄粒米扣量(公斤)")
    private double qzhlmkl;

    @PropertyDef(label = "其中：其他扣量(公斤)")
    private double qzqtkl;

    @PropertyDef(label = "整理费用折扣量(公斤)")
    private double zlfyzkl;

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

    @PropertyDef(label = "其他扣量(公斤)")
    private double qtkl;

    @PropertyDef(label = "扣量原因")
    private String klyy;

    @PropertyDef(label = "现场扣量(公斤)")
    @Column(name = "xckl")
    private double xckl;

    @PropertyDef(label = "增扣价(公斤)")
    private double zkj;

    @PropertyDef(label = "增扣价原因")
    private String zkhyy;

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

    @PropertyDef(label = "装卸作业单位")
    private String zxzydw;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "出门时间")
    private Date cmsj;

    @PropertyDef(label = "出门确认门岗人员姓名")
    private String cmqrmgryxm;

    @PropertyDef(label = "入库结算单号")
    private String rkjsdh;

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

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

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

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

}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,94 @@
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 SH2023Api1203 implements Serializable {

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


    //入库业务单号由 12 ä½æ•°å­—组成，第 1-2 ä½ä¸ºä¸šåŠ¡ä»£ç ï¼ˆ14代表粮食入库），第 3-8 ä½ä¾æ¬¡ä¸ºå¹´ä»½çš„后两位、2 ä½æœˆä»½ã€2 ä½æ—¥æœŸï¼ŒåŽå››ä½ä¸ºé¡ºåºç ã€‚例如：141605041234
    @Id
    @PropertyDef(label = "入库检验单号")
    private String rkjydh;

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

    @PropertyDef(label = "入库业务单号")
    private String rkywdh;

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

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

    @PropertyDef(label = "扦样方式")
    private String qyfs;

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

    @PropertyDef(label = "检验值,隔开")
    private String jyz;

    @PropertyDef(label = "增扣价(元,隔开)")
    private String zkj;

    @PropertyDef(label = "增扣量(公斤,隔开)")
    private String zkl;

    @PropertyDef(label = "检验人姓名")
    private String jyrxm;

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

    @PropertyDef(label = "检验结果")
    private String jyjg;

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

    @PropertyDef(label = "粮食定等")
    private String lsdd;

    @PropertyDef(label = "保管员复核")
    private String bgyfh;

    @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/SH2023Api1204.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,92 @@
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 SH2023Api1204 implements Serializable {

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

    @PropertyDef(label = "入库结算单号", description = "由库点代码+结算日期（yyyyMMdd）+4 ä½é¡ºåºå·ç»„成")
    private String rkjsdh;

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

    @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 skr;

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

    @PropertyDef(label = "收款人身份证号")
    private String skrsfzh;

    @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 fkdw;

    @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/SH2023Api1205.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,174 @@
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 SH2023Api1205 extends ApiParent implements Serializable {


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


    //业务单号由 12 ä½æ•°å­—组成，第 1-2 ä½ä¸ºä¸šåŠ¡ç¼–码（15 ä»£è¡¨ç²®é£Ÿå‡ºåº“），第 3-8 ä½ä¾æ¬¡ä¸ºå¹´ä»½çš„后两位、2 ä½æœˆä»½ã€2位日期，后四位为顺序码。例如：141605041234
    @Id
    @PropertyDef(label = "出库业务单号")
    private String ckywdh;

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

    @PropertyDef(label = "计划明细号")
    private String jhmxh;

    @PropertyDef(label = "出库通知单号")
    private String cktzdh;

    @PropertyDef(label = "业务类型", description = "1：出库（默认）")
    private String ywlx = "1";

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "业务日期")
    private Date ywrq;

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

    @PropertyDef(label = "承运人")
    private String cyr;

    @PropertyDef(label = "联系电话")
    private String lxdh;

    @PropertyDef(label = "身份证号")
    private String sfzh;

    @PropertyDef(label = "运输工具")
    private String ysgj;

    @PropertyDef(label = "卸粮地点")
    private String xldd;

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

    @PropertyDef(label = "车船号类型")
    private String cchlx;

    @PropertyDef(label = "挂车号")
    private String gch;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "登记时间")
    private Date djsj;

    @PropertyDef(label = "登记门岗人员姓名")
    private String djmgryxm;

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

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

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

    @PropertyDef(label = "收获年度")
    private String shnd;

    @PropertyDef(label = "产地代码")
    private String cddm;

    @PropertyDef(label = "皮重(公斤)")
    private double pz;

    @PropertyDef(label = "皮重监磅员")
    private String pzjby;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "皮重计量时间")
    private Date pzjlsj;

    @PropertyDef(label = "皮重计量员")
    private String pzjly;

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

    @PropertyDef(label = "毛重监磅员")
    private String mzjby;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "毛重计量时间")
    private Date mzjlsj;

    @PropertyDef(label = "毛重计量员")
    private String mzjly;

    @PropertyDef(label = "包装物")
    private String bzw;

    @PropertyDef(label = "标准包单包重(公斤)")
    private double bzbdbz;

    @PropertyDef(label = "标准包件数(件)")
    private Integer bzbjs;

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

    @PropertyDef(label = "扣/增量(公斤)")
    private double kzl;

    @PropertyDef(label = "值仓保管员姓名")
    private String zcbgyxm;

    @PropertyDef(label = "装卸作业单位")
    private String zxzydw;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "出门时间")
    private Date cmsj;

    @PropertyDef(label = "出门确认门岗人员姓名")
    private String cmqrmgryxm;

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

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

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

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

    private String pch;
    private String bjw;
    private String jjdh;

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

 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/SH2023Api1311.java

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

/**
 * è§†é¢‘监控
 *
 * @Author:YAN
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api1311 extends ApiParent 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/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;

}

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

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

/**
 * ä¸Šæµ·å¸‚接口-2101 æ£€æ–¤å•
 *
 * @author czt
 * @date 2023/8/17
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class SH2023Api2101 extends ApiParent implements Serializable {
    /**
     *
     */
    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/push/sh2023/dto/SH2023Api2103.java

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

/**
 * ç²®æƒ…设备配置
 *
 * @author czt
 *
 * @date 2023-08-21
 */
@Data
public class SH2023Api2103 extends ApiParent implements Serializable {

    private static final long serialVersionUID = 9157617424050247565L;
    
    @PropertyDef(label = "货位代码")
    private String hwdm;

    @PropertyDef(label = "电缆行数")
    private String dlhs;

    @PropertyDef(label = "电缆列数")
    private String dlls;

    @PropertyDef(label = "电缆层数")
    private String dlcs;

    @PropertyDef(label = "电缆圈数")
    private String dlqs;

    @PropertyDef(label = "电缆圈排列详情")
    private String dlqplxq;

    @PropertyDef(label = "上层起点")
    private String scqd;

    @PropertyDef(label = "上层终点")
    private String sczd;

    @PropertyDef(label = "中层起点")
    private String zcqd;

    @PropertyDef(label = "中层终点")
    private String zczd;

    @PropertyDef(label = "下层起点")
    private String xcqd;

    @PropertyDef(label = "下层终点")
    private String xczd;

    @PropertyDef(label = "有效范围起始层")
    private String yxfwqsc;

    @PropertyDef(label = "有效范围结束层")
    private String yxfwjsc;

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

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

}

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

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

import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.api.entity.ApiParent;
import lombok.Data;
import java.io.Serializable;

/**
 * ç²®æƒ…设备配置-筒仓电缆圈排列详情
 *
 * @author czt
 *
 * @date 2023-08-21
 */
@Data
public class SH2023Api2103Item extends ApiParent implements Serializable {

    private static final long serialVersionUID = 9157617424050247565L;
    
    @PropertyDef(label = "圈号")
    private String qh;

    @PropertyDef(label = "起始电缆编号")
    private String qsdlbh;

    @PropertyDef(label = "结束电缆编号")
    private String jsdlbh;

    @PropertyDef(label = "各圈总层数")
    private String cs;

    @PropertyDef(label = "圈半径")
    private String ybj;

    @PropertyDef(label = "序号")
    private String rowId;

}

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

@@ -9,8 +9,8 @@
    BJW_310104("310104", "徐汇区", "xuhui"),
    BJW_310105("310105", "长宁区", "changning"),
    BJW_310106("310106", "静安区", "jingan"),
    BJW_310107("310107", "普陀区", "pituo"),
    BJW_310109("310109", "虹口区", "honhkou"),
    BJW_310107("310107", "普陀区", "putuo"),
    BJW_310109("310109", "虹口区", "hongkou"),
    BJW_310110("310110", "杨浦区", "yangpu"),
    BJW_310112("310112", "闵行区", "minhang"),
    BJW_310113("310113", "宝山区", "baoshan"),