61版本同步

YYC

2025-09-22 f43613cc5aba07a9cb0482b7171ae6569c901e50

61版本同步

 src/main/java/com/fzzy/api/data/SyncProtocol.java

@@ -12,6 +12,7 @@
    FZZY_V30_GB("FZZY_V30_GB", "风正致远V3.0"),
    FZZY_V35_GB("FZZY_V35_GB", "风正致远V3.5"),
    FZZY_V40_GB("FZZY_V40_GB", "风正致远V4.0"),
    FZZY_V61_GB("FZZY_V61_GB", "风正致远V6.1"),
    FZZY_V40_WHJL("FZZY_V40_WHJL", "风正致远V4.0-武汉军粮"),
    FZZY_V35_SHYZ("FZZY_V35_SHYZ", "风正致远2上海佑卓规范");


 src/main/java/com/fzzy/api/service/ApiTriggerService.java

@@ -215,6 +215,7 @@
        list.add(new ApiTrigger(SyncProtocol.FZZY_V30_GB.getCode(), SyncProtocol.FZZY_V30_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V35_GB.getCode(), SyncProtocol.FZZY_V35_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V40_GB.getCode(), SyncProtocol.FZZY_V40_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V61_GB.getCode(), SyncProtocol.FZZY_V61_GB.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V40_WHJL.getCode(), SyncProtocol.FZZY_V40_WHJL.getName()));
        list.add(new ApiTrigger(SyncProtocol.FZZY_V35_SHYZ.getCode(), SyncProtocol.FZZY_V35_SHYZ.getName()));
        return list;

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

@@ -178,6 +178,9 @@
                        if (StringUtils.isEmpty(people.getZyzg())) {
                            people.setZyzg("培训合格");
                        }
                        if (StringUtils.isEmpty(people.getSfwb())) {
                            people.setSfwb("否");
                        }
                        api9201People.setZyzg(people.getZyzg().trim());
                        peopleList.add(api9201People);
                    }

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

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

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService11;
import com.fzzy.async.fzzy61.impl.Fzzy61Sync1107;
import com.fzzy.async.fzzy61.impl.Fzzy61Sync1108;
import com.fzzy.async.fzzy61.impl.Fzzy61Sync1111;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;

@Slf4j
@Component
public class Fzzy61SyncService11 implements SyncService11 {
    @Autowired
    private Fzzy61Sync1111 fzzy61Sync1111;
    @Autowired
    private Fzzy61Sync1108 fzzy61Sync1108;
    @Autowired
    private Fzzy61Sync1107 fzzy61Sync1107;

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

    @Override
    public void syncData(ApiParam param) {
        log.info("--------------基础数据手动配置推送--------");
        String kqdm = param.getKqdm();
        String deptId = param.getDeptId();
        Date start = param.getStart();
        Date end = param.getEnd();
        //监控点位信息同步
        fzzy61Sync1111.syncData(kqdm, deptId, start, end);

        //药剂信息同步
        fzzy61Sync1108.syncData(kqdm, deptId, start, end);

        //设备信息同步
        fzzy61Sync1107.syncData(kqdm, deptId, start, end);
        //人员信息同步
//        fzzy61Sync1112.syncData(kqdm, deptId, start, end);
    }
}

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

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

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

import java.util.Date;

/**
 * @Desc: ç²®é£Ÿè´­é”€ç›¸å…³æ•°æ®åŒæ­¥
 * @author: czt
 * @update-time: 2023/6/29
 */
@Component
public class Fzzy61SyncService12 implements SyncService12 {

    @Autowired
    private Fzzy61Sync1201 fzzySync1201;
    @Autowired
    private Fzzy61Sync1202 fzzySync1202;
    @Autowired
    private Fzzy61Sync1203 fzzySync1203;
    @Autowired
    private Fzzy61Sync1204 fzzySync1204;
    @Autowired
    private Fzzy61Sync1205 fzzySync1205;
    @Autowired
    private Fzzy61Sync1206 fzzySync1206;
    @Autowired
    private Fzzy61Sync1207 fzzySync1207;
    @Autowired
    private Fzzy61Sync1208 fzzySync1208;
    @Autowired
    private Fzzy61Sync1209 fzzySync1209;
    @Autowired
    private Fzzy61Sync1211 fzzySync1211;
    @Autowired
    private Fzzy61Sync1210 fzzySync1210;
    @Autowired
    private Fzzy61Sync1212 fzzySync1212;
    @Autowired
    private Fzzy61Sync1213 fzzySync1213;
    @Autowired
    private Fzzy61Sync1109 fzzySync1109;
    @Autowired
    private Fzzy61Sync2102 fzzySync2102;

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

    @Override
    public void syncData(ApiParam param) {

        String kqdm = param.getKqdm();
        String deptId = param.getDeptId();
        Date start = param.getStart();
        Date end = param.getEnd();

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

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

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

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

        //粮食入库质检
        fzzySync1203.syncData(kqdm, deptId, start, end);

        //粮食出库结算
        fzzySync1206.syncData(kqdm, deptId, start, end);

        //粮食出库同步
        fzzySync1205.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);

        //账面库存信息同步
        fzzySync1211.syncData(kqdm, deptId, start, end);
        //封仓确认信息同步
        fzzySync1213.syncData(kqdm, deptId, start, end);

        /*-----各省独有接口信息同步-----*/
        //上海市平台2023版
        if (StringUtils.isNotEmpty(param.getPushProtocol()) && PushProtocol.SB_SH_2023.getCode().equals(param.getPushProtocol())) {
            //倒仓倒入信息同步
            fzzySync2102.syncData(kqdm, deptId, start, end);
        }

    }

}

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

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

import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.async.fzzy40.entity.Fz40CheckItemKey;
import lombok.Data;

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

/**
 * ç”¨äºŽå‡ºå…¥åº“质检详细项和日常巡检的详细项记录
 *
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2020å¹´4月7日
 */
@Data
@Entity
@Table(name = "D_CHECK_ITEM")
@IdClass(Fz61CheckItemKey.class)
public class Fz61CheckItem implements Serializable {

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

    @Id
    @Column(name = "CHECK_ID_", length = 40)
    @PropertyDef(label = "检测编码")
    private String checkId;

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

    @Id
    @Column(name = "STANDARD_ID_", length = 10)
    @PropertyDef(label = "检测项编码")
    private String standardId;

    @Column(name = "STANDARD_NAME_", length = 50)
    @PropertyDef(label = "化验项")
    private String standardName;

    @Column(name = "UNIT_", length = 20)
    @PropertyDef(label = "单位")
    private String unit;

    @Column(name = "UPPER_LIMIT_")
    @PropertyDef(label = "标准伐值")
    private Double upperLimit;

    @Column(name = "OPERA_SYMBOL_", length = 4)
    @PropertyDef(label = "运算符号")
    private String operaSymbol;

    @Column(name = "RULE_NUM_")
    @PropertyDef(label = "扣重系数")
    private Double ruleNum;

    @Column(name = "RULE_ADD_")
    @PropertyDef(label = "增重%")
    private Double ruleAdd;

    @Column(name = "RULE_ADD_END_")
    @PropertyDef(label = "增重上限%")
    private Double ruleAddEnd;

    @Column(name = "RULE_REDUCE_")
    @PropertyDef(label = "扣重值%")
    private Double ruleReduce;

    @Column(name = "VALUE_", length = 40)
    @PropertyDef(label = "检测值")
    private String value;

    @Column(name = "RULE_PRICE_")
    @PropertyDef(label = "扣费系数")
    private Double rulePrice;

    @Column(name = "RULE_REDUCE_PRICE_")
    @PropertyDef(label = "扣费")
    private Double ruleReducePrice;

    @Column(name = "ADD_NUM_")
    @PropertyDef(label = "增重", description = "单位：kG")
    private Double addNum;

    @Column(name = "DE_NUM_")
    @PropertyDef(label = "扣重", description = "单位：kG")
    private Double deNum;

    @Column(name = "ADD_PRICE_")
    @PropertyDef(label = "增价", description = "单位：元")
    private Double addPrice;

    @Column(name = "DE_PRICE_")
    @PropertyDef(label = "扣价", description = "单位：元")
    private Double dePrice;

    @Column(name = "RESULT_", length = 2)
    @PropertyDef(label = "检验结果", description = "0=不合格 1=合格")
    private String result;

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

    @Transient
    @PropertyDef(label = "运算符号值，只做页面显示用")
    private String operaSymbolValue;

    @Transient
    @PropertyDef(label = "湿度")
    private double perWet;

    @Transient
    @PropertyDef(label = "杂质")
    private double perImpurity;
}

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

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

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;

@Data
@AllArgsConstructor
public class Fz61CheckItemKey implements Serializable {
        private String checkId;
        private String companyId;
        private String standardId;

    public Fz61CheckItemKey(){
            super();
        }
    }

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

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

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

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

/**
 * @author czt
 *
 * æŒ‰ä»“库进行统计，每个月底统计一次(因上海市账面库存接口为按货位统计，转换接口服务时根据省份要求统计成对应的账面库存)
 **/
@Data
@Entity
@Table(name = "D_DEPOT_BOOK_STORE")
public class Fz61DepotBookStore implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键", description = "规则：仓库编码_yyyyMMdd")
    private String id;

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

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

    @Column(name = "DEPOT_ID_", length = 30)
    @PropertyDef(label = "仓库编码", description = "目前上海使用")
    private String depotId;

    @PropertyDef(label = "粮食性质代码", description = "目前上海使用")
    @Column(name = "lsxzdm", length = 7)
    private String lsxzdm;

    @Column(name = "lspzdm", length = 7)
    @PropertyDef(label = "粮食品种代码")
    private String lspzdm;

    @Column(name = "nd", length = 4)
    @PropertyDef(label = "年度")
    private String nd;

    @Column(name = "yf", length = 2)
    @PropertyDef(label = "月份")
    private String yf;

    @Column(name = "qcsl", precision = 20, scale = 3)
    @PropertyDef(label = "期初数量", description = "单位：公斤")
    private Double qcsl = 0.0;

    @Column(name = "bqsrsl", precision = 20, scale = 3)
    @PropertyDef(label = "本期收入数量", description = "单位：公斤")
    private Double bqsrsl = 0.0;

    @Column(name = "bqzcsl", precision = 20, scale = 3)
    @PropertyDef(label = "本期支出数量", description = "单位：公斤")
    private Double bqzcsl = 0.0;

    @Column(name = "qmye", precision = 20, scale = 3)
    @PropertyDef(label = "期末数量", description = "单位：公斤")
    private Double qmye = 0.0;

    @Column(name = "yjbz")
    @PropertyDef(label = "月结标志", description = "0：月结；1 æœªæœˆç»“")
    private Integer yjbz;

    @Column(name = "ywrq")
    @PropertyDef(label = "业务日期")
    private Date ywrq;

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

}

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

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

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

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

/**
 * @Desc: ä»“房状态确认表
 * @author:
 * @update-time:
 */
@Data
@Entity
@Table(name = "D_DEPOT_STATUS_CONFIRM")
public class Fz61DepotStatusConfirm {

    public static String SORT_PROP = "fcqrdh";

    /**
     * 21yyyyMMdd+四位顺序号
     * 21202405041234
     */
    @Id
    @Column(name = "fcqrdh", length = 14)
    @PropertyDef(label = "封仓确认单号", description = "根据一定的规则生成")
    private String fcqrdh;

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

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

    @Column(name = "DEPOT_ID_", length = 28)
    @PropertyDef(label = "货位编码")
    private String depotId;

    /*** ------------------------确认内容-------------------------------------**/
    @Column(name = "fcrq")
    @PropertyDef(label = "封仓日期", description = "yyyy-MM-dd")
    private Date fcrq;

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

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

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

    @Column(name = "FOOD_LOCATION_ID_", length = 20)
    @PropertyDef(label = "产地名称代码")
    private String foodLocationId;

    @Column(name = "FOOD_LOCATION_", length = 40)
    @PropertyDef(label = "产地名称")
    private String foodLocation;

    @Column(name = "FOOD_YEAR_", length = 10)
    @PropertyDef(label = "收货年度")
    private String foodYear;

    @Column(name = "COUNTRY_", length = 10)
    @PropertyDef(label = "国别")
    private String country;

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

    @Column(name = "fcsl")
    @PropertyDef(label = "封仓数量", description = "所有入库信息中的净重之和，单位KG")
    private Double fcsl = 0.0;


    /*** ------------------------公共字段-------------------------------------**/

    @Column(name = "APPLY_USER_", length = 50)
    @PropertyDef(label = "申请人")
    private String applyUser;

    @Column(name = "DEPT_AUDIT_USER_", length = 50)
    @PropertyDef(label = "部门审核人")
    private String deptAuditUser;

    @Column(name = "LEADER_AUDIT_USER_", length = 50)
    @PropertyDef(label = "领导审核人")
    private String leaderAuditUser;

    // å¤‡æ³¨
    @Column(name = "REMARKS_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remarks;


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

}

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

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

import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.async.fzzy30.entity.Depot;
import lombok.Data;

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

/**
 * @Desc: ç²®é£Ÿåº“存管理，根据国标标结果要求创建
 * @author: Andy
 * @update-time: 2022/11/17
 */
@Data
@Entity
@Table(name = "D_DEPOT_STORE")
public class Fz61DepotStore implements Serializable {

    public static String SORT_PROP = "id";

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

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

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

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

    @Column(name = "COUNTRY_", length = 10)
    @PropertyDef(label = "国别")
    private String country;

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

    @Column(name = "MANAGE_TYPE_", length = 6)
    @PropertyDef(label = "管理方式", description = "01 ç›´å‚¨02 ä»£å‚¨03 ç§Ÿä»“04 å§”托")
    private String manageType;

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

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

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

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

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

    @Column(name = "FOOD_YEAR_", length = 10)
    @PropertyDef(label = "收货年度")
    private String foodYear;

    @Column(name = "DEPOT_STATUS_", length = 10)
    @PropertyDef(label = "仓库状态", description = "1=空仓、2=入库中、3=满仓、4=出库中、9=其他")
    private String depotStatus;

    @Column(name = "STORE_DATE_")
    @PropertyDef(label = "入库时间", description = "入库时间，第一车粮食入仓时间,格式：yyyy-MM-dd HH:mm:ss")
    private Date storeDate;

    @Column(name = "FULL_DATE_")
    @PropertyDef(label = "封仓日期", description = "当货位（油罐）状态为封仓时，此项为必填项")
    private Date fullDate;

    @Column(name = "OUT_DATE_")
    @PropertyDef(label = "出仓时间", description = "出库时间，最后一车粮食出仓完成时间,格式：yyyy-MM-dd HH:mm:ss")
    private Date outDate;

    @Column(name = "STORAGE_REAL_")
    @PropertyDef(label = "实际储量", description = "单位：KG")
    private Double storageReal;

    @Column(name = "STORE_SETTLE__")
    @PropertyDef(label = "计价数量", description = "单位：KG")
    private Double storageSettle;

    @Column(name = "GRAIN_HEIGHT_")
    @PropertyDef(label = "装粮线高", description = "单位：米")
    private Double grainHeight;

    @Column(name = "GRAIN_VOLUME_")
    @PropertyDef(label = "装粮体积", description = "单位：立方米")
    private Double grainVolume;

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

    @Column(name = "UPDATE_USER_", length = 50)
    @PropertyDef(label = "修改人")
    private String updateUser;

    @PropertyDef(label = "粮权归属单位代码")
    @Column(name = "lqgsdwdm", length = 18)
    private String lqgsdwdm;


    @Column(name = "UPDATE_DATE_")
    @PropertyDef(label = "修改时间")
    private Date updateDate;

    @Column(name = "CREATE_DATE_")
    private Date createDate;

}

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

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

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

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

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
@Data
@Entity
@Table(name = "D_DEPT_DEVICE")
public class Fz61DeptDevice implements Serializable {

    private static final long serialVersionUID = 1L;

    public static String SORT_PROP = "sbbh";

    @Id
    @Column(name = "sbbh", length = 20)
    @PropertyDef(label = "设备编号")
    private String sbbh;

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

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

    @Column(name = "sbyqmc", length = 50)
    @PropertyDef(label = "设备仪器名称")
    private String sbyqmc;

    @Column(name = "sbggxh", length = 50)
    @PropertyDef(label = "设备规格型号")
    private String sbggxh;

    @Column(name = "sccj", length = 256)
    @PropertyDef(label = "生产厂家")
    private String sccj;

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

    @Column(name = "sbms", length = 50)
    @PropertyDef(label = "设备描述")
    private String sbms;

    @Column(name = "sbzt", length = 1)
    @PropertyDef(label = "设备状态",description = "1 å®Œå¥½ 2 æŠ¥åºŸ 3 å¾…检修 4 å…¶ä»–")
    private String sbzt;

    @Column(name = "jdsj")
    @PropertyDef(label = "检定时间")
    private Date jdsj;

    @Column(name = "jddw", length = 256)
    @PropertyDef(label = "检定单位")
    private String jddw;

    @Column(name = "sbgly", length = 50)
    @PropertyDef(label = "设备管理员")
    private String sbgly;

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

}

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

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

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

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

/**
 * çŽ¯æµç†è’¸-药品库存
 *
 * @ClassName: Fz61Drug
 * @date 2023å¹´8月17日
 */
@Data
@Entity
@Table(name = "D_DRUG")
public class Fz61Drug implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "药剂编号", description = "采购日期(yyyyMMdd)+三位顺序号")
    private String id;

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

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

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

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

    @Column(name = "bzw", length = 1)
    @PropertyDef(label = "包装物", description = "1：瓶装，2：袋装，3：其他")
    private String bzw;

    @Column(name = "ggxh", length = 256)
    @PropertyDef(label = "型号规格", description = "如：100mg/粒或10g/片")
    private String ggxh;

    @Column(name = "aqsysms", length = 1000)
    @PropertyDef(label = "安全使用说明书")
    private String aqsysms;

    @Column(name = "sccj", length = 40)
    @PropertyDef(label = "生产厂家")
    private String sccj;

    @Column(name = "cgly", length = 40)
    @PropertyDef(label = "采购来源")
    private String cgly;

    @Column(name = "cctj", length = 200)
    @PropertyDef(label = "存储条件")
    private String cctj;

    @Column(name = "ccdd", length = 1)
    @PropertyDef(label = "储存地点", description = "1:药剂库,2:其他")
    private String ccdd;

    @Column(name = "bzwclfs", length = 1000)
    @PropertyDef(label = "包装物处理方式")
    private String bzwclfs;

    @Column(name = "czclfs", length = 1000)
    @PropertyDef(label = "残渣处理方式")
    private String czclfs;

    @Column(name = "bzq", length = 50)
    @PropertyDef(label = "保质期", description = "几年、几个月等")
    private String bzq;

    @Column(name = "COUNT_")
    @PropertyDef(label = "库存量")
    private Double count = 0.0;

    @Column(name = "kcsldw", length = 1)
    @PropertyDef(label = "库存量单位", description = "1(默认)：公斤；2：克；3：毫升；")
    private String kcsldw = "1";

    @PropertyDef(label = "操作员")
    @Column(name = "UPDATE_USER_", length = 30)
    private String updateUser;

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

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

    @Column(name = "DEL_TAG_")
    @PropertyDef(label = "删除标记，在页面删除时候使用")
    private String delTag;

}

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

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

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

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

/**
 * é™„件信息，系统所有类型附件均使用该类
 * <p>
 * å…¶ä¸­å›¾ç‰‡ä¿¡æ¯ï¼Œæ”¯æŒç›´æŽ¥ä¿å­˜åˆ°æ•°æ®åº“中，使用字段：imgData
 * <p>
 * é™„件信息全部保存在服务器硬盘中，不再保存数据库
 *
 * @author Andy
 */
@Data
@Entity
@Table(name = "D_FILE")
public class Fz61FileInfo implements Serializable {

    private static final long serialVersionUID = 86018008520229637L;

    @Id
    @Column(name = "FILE_ID_", length = 40)
    @PropertyDef(label = "附件ID")
    private String fileId;

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

    @Column(name = "BIZ_ID_", length = 40)
    @PropertyDef(label = "业务ID")
    private String bizId;

    @Column(name = "BIZ_TAG_", length = 20)
    @PropertyDef(label = "业务标签", description = "附件在绑定业务的时候可能需要其他标识区分")
    private String bizTag;

    @PropertyDef(label = "文件名称")
    @Column(name = "FILE_NAME_", length = 100)
    private String fileName;

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

}

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

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

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

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

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2025-9-17 15:07
 **/
@Data
@Entity
@Table(name = "D_INOUT_CONTRACT")
public class Fz61InoutContract implements Serializable {

    public static String SORT_PROP = "id";

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

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

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

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

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

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

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "业务类别", description = "1:销售合同 2:采购合同 3:代储合同")
    private String type;

    @Column(name = "CUSTOMER_TYPE_", length = 10)
    @PropertyDef(label = "客户类型", description = "1:企业 2:个人")
    private String customerType;

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

    @Column(name = "CUSTOMER_ID_", length = 20)
    @PropertyDef(label = "社会信用码", description = "如果是企业=客户统一社会信用代码")
    private String customerId;

    @Column(name = "CUSTOMER_NAME_", length = 50)
    @PropertyDef(label = "客户名称")
    private String customerName;

    @Column(name = "fddbr", length = 50)
    @PropertyDef(label = "法定代表人")
    private String fddbr;

    @Column(name = "txdz", length = 200)
    @PropertyDef(label = "通讯地址")
    private String txdz;

    @Column(name = "yzbm", length = 6)
    @PropertyDef(label = "邮政编码")
    private String yzbm;

    @PropertyDef(label = "联系人姓名")
    @Column(name = "lxrxm", length = 50)
    private String lxrxm;

    @PropertyDef(label = "联系电话")
    @Column(name = "lxrdh", length = 20)
    private String lxrdh;

    @PropertyDef(label = "身份证号")
    @Column(name = "sfzh", length = 20)
    private String sfzh;

    @PropertyDef(label = "电子信箱")
    @Column(name = "dzyx", length = 50)
    private String dzyx;

    @Column(name = "SIGNING_TIME_")
    @PropertyDef(label = "签订时间", description = "格式：yyyy-MM-dd")
    private Date signingTime;

    @Column(name = "SIGN_ADDRESS_", length = 100)
    @PropertyDef(label = "签约地点")
    private String signAddress;

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

    @Column(name = "END_TIME_")
    @PropertyDef(label = "约定完成时间")
    private Date endTime;

    @Column(name = "REL_END_TIME_")
    @PropertyDef(label = "实际完成时间")
    private Date relEndTime;

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

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

    @Column(name = "PRICE_")
    @PropertyDef(label = "合同单价，元/吨")
    private Double price;

    @Column(name = "MONEY_")
    @PropertyDef(label = "合同总金额", description = "单位：元")
    private Double money;

    @Column(name = "CONTRACT_AMOUNT_")
    @PropertyDef(label = "合同数量", description = "单位：公斤")
    private Double contactAmount;

    @Column(name = "COMPLETE_NUM_")
    @PropertyDef(label = "履约数量", description = "单位：公斤")
    private Double completeNum;

    @Column(name = "lybzj")
    @PropertyDef(label = "履约保证金", description = "单位：元")
    private Double lybzj;

    @PropertyDef(label = "履约率", description = "单位：%")
    @Column(name = "lyl")
    private Double lyl;

    @Column(name = "jsjg")
    @PropertyDef(label = "结算价格，元/吨")
    private Double jsjg;

    @PropertyDef(label = "结算总金额", description = "单位：元")
    @Column(name = "jszje")
    private Double jszje;

    @PropertyDef(label = "结算与合同一致性", description = "1：符合 2：不符合")
    @Column(name = "jsyhtyzx", length = 1)
    private String jsyhtyzx;

    @PropertyDef(label = "不一致原因")
    @Column(name = "jsyhtbyzyy", length = 250)
    private String jsyhtbyzyy;

    @Column(name = "CUSTOMER_BANK_", length = 10)
    @PropertyDef(label = "客户开户行")
    private String customerBank;

    @Column(name = "CUSTOMER_BANK_ACCOUNT_", length = 40)
    @PropertyDef(label = "客户方账号")
    private String customerBankAccount;

    @Column(name = "CUSTOMER_SIGN_USER_", length = 50)
    @PropertyDef(label = "客户签约人")
    private String customerSignUser;

    @Column(name = "BANK_", length = 50)
    @PropertyDef(label = "本方开户行")
    private String bank;

    @Column(name = "BANK_ACCOUNT_", length = 40)
    @PropertyDef(label = "本方账号")
    private String bankAccount;

    @Column(name = "SIGN_USER_", length = 50)
    @PropertyDef(label = "本方签约人")
    private String signUser;

    @Column(name = "PAY_TYPE_", length = 6)
    @PropertyDef(label = "支付方式")
    private String payType;

    @Column(name = "fkfs")
    @PropertyDef(label = "付款方式")
    private Integer fkfs;

    @Column(name = "ysfs", length = 64)
    @PropertyDef(label = "验收方式")
    private String ysfs;
    /**
     * --------审批信息--------
     **/

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

    @Column(name = "AUDIT_USER_", length = 50)
    @PropertyDef(label = "审批人")
    private String auditUser;

    @Column(name = "AUDIT_DATE_")
    @PropertyDef(label = "审批时间", description = "格式：yyyy-MM-dd HH:mm:ss")
    private Date auditDate;

    @Column(name = "AUDIT_STATUS_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditStatus;

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

    @Column(name = "wcrq")
    @PropertyDef(label = "完成时间")
    private Date wcrq;

    @Column(name = "hqzz", length = 30)
    @PropertyDef(label = "货权组织")
    private String hqzz;

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


    /**
     * --------附件--------
     **/
    @Column(name = "FILE_ID_", length = 30)
    @PropertyDef(label = "附件id")
    private String fileId;

    @Column(name = "FILE_NAME_", length = 50)
    @PropertyDef(label = "附件名称")
    private String fileName;

    @Column(name = "FILE_TIME_")
    @PropertyDef(label = "附件上传时间")
    private Date fileTime;

}

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

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

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

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

/**
 * å‡ºå…¥åº“客户-往来单位信息 2023å¹´5月26日 æ ¹æ®æ–°å›½ç²®è§„优化
 *
 * @author czt
 * @description ç‰ˆæœ¬4.0字段已审
 * @date 2023-05-25 17:16
 */
@Data
@Entity
@Table(name = "D_INOUT_CUSTOMER")
public class Fz61InoutCustomer implements Serializable {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键id编码", description = "系统内编码")
    private String id;

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

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

    @Column(name = "TYPE_", length = 4)
    @PropertyDef(label = "业务分类", description = "系统内使用：提货商、供货商")
    private String type;

    @Column(name = "khlx", length = 50)
    @PropertyDef(label = "客户类型", description = "1-企业，2-个人")
    private String khlx;

    @PropertyDef(label = "客户编码：企业客户填写统一社会信用代码，个人客户填写身份证号")
    @Column(name = "khbh", length = 18)
    private String khbh;

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

    @PropertyDef(label = "法定代表人")
    @Column(name = "fddbr", length = 64)
    private String fddbr;

    @Column(name = "ADDRESS_", length = 200)
    @PropertyDef(label = "通讯地址")
    private String address;

    @PropertyDef(label = "邮政编码")
    @Column(name = "yzbm", length = 6)
    private String yzbm;

    @Column(name = "CONTACT_USER_", length = 50)
    @PropertyDef(label = "联系人")
    private String contactUser;

    @Column(name = "PHONE_", length = 20)
    @PropertyDef(label = "联系电话")
    private String phone;

    @Column(name = "CARD_ID_", length = 20)
    @PropertyDef(label = "联系人身份证号")
    private String cardId;

    @PropertyDef(label = "电子信箱")
    @Column(name = "dzyx", length = 64)
    private String dzyx;

    @Column(name = "BANK_", length = 50)
    @PropertyDef(label = "开户银行")
    private String bank;

    @Column(name = "BANK_NUM_", length = 30)
    @PropertyDef(label = "银行账号")
    private String bankNum;

    @Column(name = "FOOD_AREA_", length = 30)
    @PropertyDef(label = "种植面积")
    private Double foodArea = 0.0;

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

}

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

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

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

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

/**
 * ç»¼åˆç®¡ç†-损溢管理
 *
 * @author: andy.jia
 * @description:
 * @version:
 * @data:2020å¹´5月27日
 */
@Data
@Entity
@Table(name = "D_INOUT_LOSS_OVER")
public class Fz61InoutLossOver implements Serializable {

    public static String SORT_PROP = "updateTime";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "损益单号", description = "业务日期(yyyyMMdd)+3位顺序号组成")
    private String id;

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

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

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

    @Column(name = "SUBMIT_TIME_")
    @PropertyDef(label = "业务日期", description = "yyyy-MM-dd")
    private Date submitTime;

    @Column(name = "TYPE_", length = 1)
    @PropertyDef(label = "类型", description = "1：损耗，2：损失，3：其他")
    private String type;

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

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

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

    @Column(name = "QUANTITY_ID1", length = 40)
    @PropertyDef(label = "入库质检", description = "数据从MQuantity中获取，上个质检批次")
    private String quantity1;

    @PropertyDef(label = "入库净重", description = "单位：KG")
    @Column(name = "rkjz", precision = 20, scale = 6)
    private Double rkjz;

    @PropertyDef(label = "入库数量", description = "单位：KG")
    @Column(name = "rksl", precision = 20, scale = 6)
    private Double rksl;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "入库时间")
    @Column(name = "rksj")
    private Date rksj;

    @PropertyDef(label = "入库水分(%)")
    @Column(name = "rksf", precision = 20, scale = 6)
    private Double rksf;

    @PropertyDef(label = "入库杂质(%)")
    @Column(name = "rkzz", precision = 20, scale = 6)
    private Double rkzz;

    @Column(name = "QUANTITY_ID2", length = 40)
    @PropertyDef(label = "出库质检", description = "数据从MQuantity中获取，上个质检批次")
    private String quantity2;

    @Column(name = "ccsc")
    @PropertyDef(label = "储存时长", description = "单位：月")
    private Integer ccsc;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "出库时间")
    @Column(name = "cksj")
    private Date cksj;

    @PropertyDef(label = "出库净重", description = "单位：KG")
    @Column(name = "ckjz", precision = 20, scale = 6)
    private Double ckjz;

    @PropertyDef(label = "出库水分(%)")
    @Column(name = "cksf", precision = 16, scale = 6)
    private Double cksf;

    @PropertyDef(label = "出库杂质(%)")
    @Column(name = "ckzz", precision = 16, scale = 6)
    private Double ckzz;

    @Column(name = "qzsfkl")
    @PropertyDef(label = "水分减量")
    private Double qzsfkl;

    @Column(name = "qzzzkl")
    @PropertyDef(label = "杂质减量")
    private Double qzzzkl;

    @Column(name = "qzszkl")
    @PropertyDef(label = "水杂总减量")
    private Double qzszkl;

    @Column(name = "qzzrshde")
    @PropertyDef(label = "保管自然损耗")
    private Double qzzrshde;

    @Column(name = "chsl")
    @PropertyDef(label = "超耗数量")
    private Double chsl;

    @Column(name = "AMOUNT_")
    @PropertyDef(label = "损耗量", description = "损溢数量KG；损耗为正数，溢余为负数")
    private Double amount;

    @Column(name = "LOSS_PER_")
    @PropertyDef(label = "损耗率")
    private Double lossPer;

    @PropertyDef(label = "是否超耗")
    @Column(name = "sfch")
    private Integer sfch;

    @PropertyDef(label = "损益是否正常", description = "0：正常 1：不正常")
    @Column(name = "sysfzc", length = 1)
    private String sysfzc;

    @PropertyDef(label = "损溢原因")
    @Column(name = "syyy", length = 400)
    private String syyy;

    @PropertyDef(label = "出清确认标识")
    @Column(name = "cqqrbs")
    private Integer cqqrbs;

    @Column(name = "cqqrsj")
    @PropertyDef(label = "出清确认时间")
    private Date cqqrsj;

    @PropertyDef(label = "仓储审核人")
    @Column(name = "ccshr", length = 64)
    private String ccshr;

    @Column(name = "AUDIT_CCSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditCcsh;

    @Column(name = "INFO_CCSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String InfoCcsh;

    @PropertyDef(label = "质检审核人")
    @Column(name = "zjshr", length = 64)
    private String zjshr;

    @Column(name = "AUDIT_ZJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditZjsh;

    @Column(name = "INFO_ZJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoZjsh;

    @PropertyDef(label = "统计审核人")
    @Column(name = "tjshr", length = 64)
    private String tjshr;

    @Column(name = "AUDIT_TJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditTjsh;

    @Column(name = "INFO_TJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoTjsh;

    @PropertyDef(label = "会计审核人")
    @Column(name = "kjshr", length = 64)
    private String kjshr;

    @Column(name = "AUDIT_KJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditKjsh;

    @Column(name = "INFO_KJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoKjsh;

    @PropertyDef(label = "领导审核人")
    @Column(name = "ldshr", length = 64)
    private String ldshr;

    @Column(name = "AUDIT_LDSH_", length = 10)
    @PropertyDef(label = "审批状态", description = "最终审核状态以领导审核为准")
    private String auditLdsh;

    @Column(name = "INFO_LDSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoLdsh;

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

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

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

}

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

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

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

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

/**
 * å‡ºå…¥åº“-入库通知单，2023å¹´5月26日 ä¼˜åŒ–调整
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "D_INOUT_NOTICE_IN")
public class Fz61InoutNoticeIn implements Serializable {

    public static String SORT_PROP = "id";

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

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

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

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "通知单名称")
    private String name;

    @Column(name = "PLAN_ID_", length = 40)
    @PropertyDef(label = "计划明细号", description = "针对轮换粮食必填")
    private String planId;

    @Column(name = "PLAN_NAME_", length = 40)
    @PropertyDef(label = "计划编码", description = "针对轮换粮食必填")
    private String planName;

    @Column(name = "CONTRACT_ID_", length = 40)
    @PropertyDef(label = "合同编码", description = "针对轮换粮食必填")
    private String contractId;

    @Column(name = "CONTRACT_NAME_", length = 50)
    @PropertyDef(label = "合同名称", description = "针对轮换粮食必填")
    private String contractName;

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

    @Column(name = "CUSTOMER_ID_", length = 40)
    @PropertyDef(label = "发货客户")
    private String customerId;

    @Column(name = "CUSTOMER_NAME_", length = 50)
    @PropertyDef(label = "发货客户")
    private String customerName;

    @Column(name = "UNIT_NAME_", length = 50)
    @PropertyDef(label = "收货单位", description = "库区所属公司，手动录入")
    private String unitName;

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

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

    @Column(name = "TARGET_NUMBER_")
    @PropertyDef(label = "目标数量", description = "单位：吨，手动填报")
    private Double targetNumber = 0.0;

    @Column(name = "COMPLETE_NUMBER_")
    @PropertyDef(label = "完成数量", description = "单位：吨，系统自动合计")
    private Double completeNumber = 0.0;

    @Column(name = "AUDIT_STATUS_", length = 10)
    @PropertyDef(label = "审核状态", description = "为审核，审核通过，拒接")
    private String auditStatus;

    @Column(name = "AUDIT_USER_", length = 50)
    @PropertyDef(label = "审核人")
    private String auditUser;

    @Column(name = "AUDIT_DATE_")
    @PropertyDef(label = "审批时间", description = "格式：yyyy-MM-dd HH:mm:ss")
    private String auditDate;

    @Column(name = "COMPLETE_STATUS_", length = 10)
    @PropertyDef(label = "完成状态", description = "未完成，已完成")
    private String completeStatus;

    @Column(name = "COMPLETE_TIME_")
    @PropertyDef(label = "完成时间")
    private Date completeTime;

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

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

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

    @Column(name = "TYPE_", length = 2)
    @PropertyDef(label = "业务说明", description = "轮换粮食，非轮换粮，如果为轮换粮食，计划明细和合同必填")
    private String type;

    @Transient
    @PropertyDef(label = "标记", description = "用于判断通知单是否为新增")
    private String tag;

    @Transient
    @PropertyDef(label = "仓库名称")
    private String depotName = "";

    @Transient
    @PropertyDef(label = "粮食品种")
    private String foodVarietyName;
}

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

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

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

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

/**
 * å‡ºå…¥åº“-出库通知单，根据新国标已核对 2023å¹´5月26日 09:35:23
 *
 * @author czt
 */
@Data
@Entity
@Table(name = "D_INOUT_NOTICE_OUT")
public class Fz61InoutNoticeOut implements Serializable {

    public static String SORT_PROP = "id";

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

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

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

    @Column(name = "NAME_", length = 50)
    @PropertyDef(label = "通知单名称")
    private String name;

    @Column(name = "PLAN_ID_", length = 40)
    @PropertyDef(label = "计划明细号", description = "针对轮换粮食必填")
    private String planId;

    @Column(name = "CONTRACT_ID_", length = 40)
    @PropertyDef(label = "合同编码", description = "针对轮换粮食必填")
    private String contractId;

    @Column(name = "CONTRACT_NAME_", length = 50)
    @PropertyDef(label = "合同名称", description = "针对轮换粮食必填")
    private String contractName;

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

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

    @Column(name = "CUSTOMER_ID_", length = 40)
    @PropertyDef(label = "发货客户")
    private String customerId;

    @Column(name = "CUSTOMER_NAME_", length = 50)
    @PropertyDef(label = "发货客户")
    private String customerName;

    @Column(name = "UNIT_NAME_", length = 50)
    @PropertyDef(label = "收货单位", description = "库区所属公司，手动录入")
    private String unitName;

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

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

    @Column(name = "TARGET_NUMBER_")
    @PropertyDef(label = "目标数量", description = "单位：KG，手动填报")
    private Double targetNumber = 0.0;

    @Column(name = "COMPLETE_NUMBER_")
    @PropertyDef(label = "完成数量", description = "单位：KG，系统自动合计")
    private Double completeNumber = 0.0;

    @Column(name = "AUDIT_STATUS_", length = 10)
    @PropertyDef(label = "审核状态", description = "为审核，审核通过，拒接")
    private String auditStatus;

    @Column(name = "AUDIT_USER_", length = 50)
    @PropertyDef(label = "审核人")
    private String auditUser;

    @Column(name = "AUDIT_DATE_")
    @PropertyDef(label = "审批时间", description = "格式：yyyy-MM-dd HH:mm:ss")
    private String auditDate;

    @Column(name = "COMPLETE_STATUS_", length = 10)
    @PropertyDef(label = "完成状态", description = "未完成，已完成")
    private String completeStatus;

    @Column(name = "COMPLETE_TIME_")
    @PropertyDef(label = "完成时间")
    private Date completeTime;

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

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

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

    @Column(name = "TYPE_", length = 2)
    @PropertyDef(label = "业务说明", description = "轮换粮食，非轮换粮，如果为轮换粮食，计划明细和合同必填")
    private String type;

    @Transient
    @PropertyDef(label = "标记", description = "用于判断通知单是否为新增")
    private String tag;

    @Transient
    @PropertyDef(label = "仓库名称")
    private String depotName = "";

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

}

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

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

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

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

/**
 * @Desc: å‡ºå…¥åº“流水表，根据新国粮规调整优化字段，2023å¹´5月26日 æ ¹æ®æ–°å›½ç²®è§„优化
 * @author: Andy
 * @update-time: 2023/5/26
 */
@Data
@Entity
@Table(name = "D_INOUT_RECORD")
public class Fz61InoutRecord {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "流水号", description = "根据一定的规则生成")
    private String id;

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

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

    @Column(name = "NOTICE_ID_", length = 40)
    @PropertyDef(label = "通知单编码")
    private String noticeId;

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

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "出入库类型", description = "IN=入库，OUT=出库")
    private String type;

    @Column(name = "PROGRESS_", length = 20)
    @PropertyDef(label = "流程进度")
    private String progress;

    @Column(name = "RECORD_STATUS_", length = 10)
    @PropertyDef(label = "数据状态", description = "数据状态，正常，异常（2小时内重复出入库等），补录")
    private String recordStatus;

    @Column(name = "CUSTOMER_NAME_", length = 50)
    @PropertyDef(label = "往来单位", description = "关联通知单获取")
    private String customerName;

    @Column(name = "INTEL_CARD_", length = 20)
    @PropertyDef(label = "智慧卡号")
    private String intelCard;

    /*** ------------------------登记-------------------------------------**/
    @Column(name = "REGISTER_TIME_")
    @PropertyDef(label = "登记时间")
    private Date registerTime;

    @Column(name = "REGISTER_USER_", length = 50)
    @PropertyDef(label = "登记人")
    private String registerUser;

    @Column(name = "USER_NAME_", length = 40)
    @PropertyDef(label = "承运人")
    private String userName;

    @Column(name = "USER_CONTACT_", length = 20)
    @PropertyDef(label = "联系方式")
    private String userContact;

    @Column(name = "USER_ID_", length = 20)
    @PropertyDef(label = "身份证号")
    private String userId;

    @Column(name = "USER_ADDRESS_", length = 100)
    @PropertyDef(label = "承运人地址")
    private String userAddress;

    @Column(name = "USER_BIRTHDAY_")
    @PropertyDef(label = "出生日期")
    private Date userBirthday;

    @Column(name = "USER_SEX_", length = 10)
    @PropertyDef(label = "性别")
    private String userSex;

    @Column(name = "USER_NATION_", length = 10)
    @PropertyDef(label = "民族")
    private String userNation;

    @Column(name = "PLATE_NUM_", length = 20)
    @PropertyDef(label = "车船号", description = "车牌号+标识符")
    private String plateNum;

    @Column(name = "TRANS_TYPE_", length = 6)
    @PropertyDef(label = "运输工具")
    private String transType;


    /*** ------------------------粮食基础信息-------------------------------------**/
    @Column(name = "FOOD_VARIETY_", length = 20)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

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

    @Column(name = "FOOD_LOCATION_ID_", length = 20)
    @PropertyDef(label = "产地名称代码")
    private String foodLocationId;

    @Column(name = "FOOD_LOCATION_", length = 40)
    @PropertyDef(label = "产地名称")
    private String foodLocation;

    @Column(name = "FOOD_YEAR_", length = 10)
    @PropertyDef(label = "收货年度")
    private String foodYear;

    /*** ------------------------扦样质检信息-------------------------------------**/
    @Column(name = "FOOD_LEVEL_", length = 20)
    @PropertyDef(label = "粮食定等")
    private String foodLevel;

    @Column(name = "CHECK_STATUS_", length = 10)
    @PropertyDef(label = "质检结果")
    private String checkStatus;

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

    @Column(name = "CHECK_TIME_")
    @PropertyDef(label = "质检时间")
    private Date checkTime;

    @Column(name = "SAMPLE_USER_", length = 50)
    @PropertyDef(label = "扦样人")
    private String sampleUser;

    @Column(name = "SAMPLE_TIME_")
    @PropertyDef(label = "扦样时间")
    private Date sampleTime;

    @Column(name = "SAMPLE_TYPE_", length = 1)
    @PropertyDef(label = "扦样方式", description = "0-人工，1=自动，2=智能随机")
    private String sampleType;

    @Column(name = "CHECK_ID_", length = 12)
    @PropertyDef(label = "质检单号")
    private String checkId;

    @Column(name = "DE_CHECK_")
    @PropertyDef(label = "质检扣重", description = "单位KG")
    private double deCheck = 0.0;

    @Column(name = "ADD_CHECK_")
    @PropertyDef(label = "质检增重", description = "单位KG")
    private double addCheck = 0.0;

    /*** ------------------------称重环节-------------------------------------**/

    @Column(name = "jjlx", length = 2)
    @PropertyDef(label = "检斤类型", description = "0：称重入库 1：标准包入库 é»˜è®¤ä¸ºç§°é‡å…¥åº“，标准包入库相关字段可为空")
    private String jjlx = "0";

    @Column(name = "FULL_WEIGHT_")
    @PropertyDef(label = "满车称重", description = "入库时候表示第一次称重，出库时候表示第二次称重，单位KG")
    private Double fullWeight = 0.0;

    @Column(name = "FULL_WEIGHT_TIME_")
    @PropertyDef(label = "满车称重时间")
    private Date fullWeightTime;

    @Column(name = "FULL_WEIGHT_USER_", length = 40)
    @PropertyDef(label = "满车称重人")
    private String fullWeightUser;

    @Column(name = "EMPTY_WEIGHT_")
    @PropertyDef(label = "空车称重", description = "入库时表示第二次称重，出库时候表示第一次称重，单位KG")
    private Double emptyWeight = 0.0;

    @Column(name = "EMPTY_WEIGHT_TIME_")
    @PropertyDef(label = "空车称重时间")
    private Date emptyWeightTime;

    @Column(name = "EMPTY_WEIGHT_USER_", length = 50)
    @PropertyDef(label = "空车称重人")
    private String emptyWeightUser;

    @Column(name = "NET_WEIGHT_")
    @PropertyDef(label = "净毛重", description = "单位KG，等于满车 - ç©ºè½¦")
    private double netWeight = 0.0;

    @Column(name = "DE_HANDLE_")
    @PropertyDef(label = "现场扣重", description = "单位KG")
    private double deHandle = 0.0;

    @Column(name = "DE_PACKAGE_")
    @PropertyDef(label = "包装扣重", description = "单位KG")
    private double dePackage = 0.0;

    @Column(name = "DE_OTHER_")
    @PropertyDef(label = "其他扣重", description = "单位KG")
    private double deOther = 0.0;

    @Column(name = "DE_OTHER_INTO_", length = 200)
    @PropertyDef(label = "其他扣重原因")
    private String deOtherInfo;

    @Column(name = "SETTLE_WEIGHT_")
    @PropertyDef(label = "结算重量", description = "扣重后净重，结算净重，单位KG")
    private Double settleWeight = 0.0;

    @Column(name = "RECORD_WEIGHT_")
    @PropertyDef(label = "入库重量", description = "扣重后净重，结算净重，补包括增重，单位KG")
    private Double recordWeight = 0.0;


    /**
     * -----------结算信息-----------------------
     **/
    @Column(name = "PRICE_")
    @PropertyDef(label = "单价", description = "单位：元/公斤，实际结算价格以结算单中单价为准")
    private Double price = 0.0;

    @Column(name = "SETTLE_MONEY_")
    @PropertyDef(label = "结算金额", description = "单位：元，实际结算以计算单为准")
    private Double settleMoney = 0.00;

    @Column(name = "SETTLE_ID_", length = 50)
    @PropertyDef(label = "结算单号", description = "如果是单车结算必填")
    private String settleId;

    @Column(name = "SETTLE_TAG_", length = 2)
    @PropertyDef(label = "结算标签")
    private String settleTag;

    /**
     * ----------- å€¼ä»“信息-----------------------
     **/
    @Column(name = "HANDLE_USER_", length = 40)
    @PropertyDef(label = "值仓操作人")
    private String handleUser;

    // å‡ºåº“
    @Column(name = "COMPLETE_TIME_")
    @PropertyDef(label = "完成时间")
    private Date completeTime;

    @Column(name = "COMPLETE_USER_", length = 40)
    @PropertyDef(label = "完成确认人")
    private String completeUser;

    // å¤‡æ³¨
    @Column(name = "REMARKS_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remarks;

    /**
     * ----------- å€¼ä»“时间，手机端使用-----------------------
     **/
    @Column(name = "HANDLE_START_")
    @PropertyDef(label = "值仓开始时间")
    private Date handleStart;

    @Column(name = "HANDLE_END_")
    @PropertyDef(label = "值仓结束时间")
    private Date handleEnd;

    /**
     * ----------- å…¶ä»–信息，针对检斤类型标准包入库填写-----------------------
     **/
    @Column(name = "bzw", length = 2)
    @PropertyDef(label = "包装物", description = "1：麻袋2：编织袋3：散装9：其他")
    private String bzw;

    @Column(name = "dbz")
    @PropertyDef(label = "单包重", description = "单位：公斤")
    private Double dbz;

    @Column(name = "bzbjs")
    @PropertyDef(label = "包件数", description = "单位：件")
    private int bzbjs;

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

}

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

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

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

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

/**
 * å‡ºå…¥åº“流水字表
 * @author
 */
@Data
@Entity
@Table(name = "D_INOUT_RECORD_ITEM")
public class Fz61InoutRecordItem {

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键id", description = "根据一定的规则生成")
    private String id;

    @Column(name = "RECORD_ID_", length = 40)
    @PropertyDef(label = "流水Id")
    private String recordId;

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

    @Column(name = "CAR_NUM_", length = 20)
    @PropertyDef(label = "船运车辆序号")
    private String carNum;

    @Column(name = "CAR_NAME_", length = 20)
    @PropertyDef(label = "船运车辆名称")
    private String carName;

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "出入库类型", description = "出库，入库")
    private String type;

    @Column(name = "PROGRESS_", length = 20)
    @PropertyDef(label = "流程进度")
    private String progress;

    @Column(name = "RECORD_STATUS_", length = 10)
    @PropertyDef(label = "数据状态", description = "数据状态，正常，异常（2小时内重复出入库等），补录")
    private String recordStatus;

    @Column(name = "DE_")
    @PropertyDef(label = "扣重", description = "单位KG")
    private Double de = 0.0;

    @Column(name = "FULL_WEIGHT_")
    @PropertyDef(label = "满车称重", description = "入库时候表示第一次称重，出库时候表示第二次称重，单位KG")
    private Double fullWeight = 0.0;

    @Column(name = "FULL_WEIGHT_TIME_")
    @PropertyDef(label = "满车称重时间")
    private Date fullWeightTime;

    @Column(name = "FULL_WEIGHT_USER_", length = 40)
    @PropertyDef(label = "满车称重人")
    private String fullWeightUser;

    @Column(name = "EMPTY_WEIGHT_")
    @PropertyDef(label = "空车称重", description = "入库时表示第二次称重，出库时候表示第一次称重，单位KG")
    private Double emptyWeight = 0.0;

    @Column(name = "EMPTY_WEIGHT_TIME_")
    @PropertyDef(label = "空车称重时间")
    private Date emptyWeightTime;

    @Column(name = "EMPTY_WEIGHT_USER_")
    @PropertyDef(label = "空车称重人")
    private String emptyWeightUser;

    @Column(name = "NET_WEIGHT_")
    @PropertyDef(label = "净重", description = "单位KG")
    private Double netWeight = 0.0;

    @Column(name = "SETTLE_WEIGHT_")
    @PropertyDef(label = "结算净重", description = "扣重后净重，结算净重，单位KG")
    private Double settleWeight = 0.0;

    @Column(name = "RECORD_WEIGHT_")
    @PropertyDef(label = "入库重量", description = "扣重后净重，结算净重，补包括增重，单位KG")
    private Double recordWeight = 0.0;

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

    // å¤‡æ³¨
    @Column(name = "REMARKS_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remarks;
}

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

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

import com.bstek.dorado.annotation.PropertyDef;
import com.fzzy.async.fzzy30.entity.InoutRecord;
import lombok.Data;

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

/**
 * å‡ºå…¥åº“结算，2023å¹´5月26日，根据新国粮规优化调整
 */
@Data
@Entity
@Table(name = "D_INOUT_SETTLE")
public class Fz61InoutSettle {

    public static String SORT_PROP = "id";

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "流水号",description = "结算日期（yyyyMMdd）+4位顺序号组成")
    private String id;

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

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

    @Column(name = "INOUT_TYPE_")
    @PropertyDef(label = "出入库类型")
    private String inoutType;

    @Column(name = "BIZ_TYPE_")
    @PropertyDef(label = "处理方式", description = "0=单车结算/1=合同结算")
    private String bizType;

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

    @Column(name = "CONTRACT_ID_", length = 40)
    @PropertyDef(label = "合同编码", description = "针对轮换粮食必填")
    private String contractId;

    @Column(name = "CONTRACT_NAME_", length = 50)
    @PropertyDef(label = "合同名称", description = "针对轮换粮食必填")
    private String contractName;

    // ç»“算信息
    @Column(name = "PAY_PRICE_")
    @PropertyDef(label = "单价")
    private Double payPrice = 0.0;

    @Column(name = "PAY_MONEY_")
    @PropertyDef(label = "结算总额")
    private Double payMoney = 0.0;

    @Column(name = "SETTLE_WEIGHT_")
    @PropertyDef(label = "结算重量")
    private double settleWeight = 0.0;

    @Column(name = "PAY_TIME_")
    @PropertyDef(label = "结算时间")
    private Date payTime;

    @Column(name = "PAY_TYPE_", length = 10)
    @PropertyDef(label = "付款方式")
    private String payType;

    @Column(name = "PAYEE_")
    @PropertyDef(label = "收款人", description = "收款单位或者个人")
    private String payee;

    @Column(name = "PAYEE_ID_")
    @PropertyDef(label = "收款人省份证号")
    private String payeeId;

    @Column(name = "BANK_CATEGORY_", length = 10)
    @PropertyDef(label = "银行行别代码")
    private String bankCategory;

    @Column(name = "BANK_CODE_", length = 40)
    @PropertyDef(label = "开户行号")
    private String bankCode;

    @Column(name = "BANK_", length = 50)
    @PropertyDef(label = "开户行名称")
    private String bank;

    @Column(name = "BANK_NUM_", length = 40)
    @PropertyDef(label = "银行账号")
    private String bankNum;

    @Column(name = "PAY_UNIT_", length = 50)
    @PropertyDef(label = "付款单位")
    private String payUnit;

    @Column(name = "PAY_USER_", length = 40)
    @PropertyDef(label = "付款操作人")
    private String payUser;

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

    @Column(name = "fphm", length = 10)
    @PropertyDef(label = "发票号码")
    private String fphm;

    @Column(name = "fpzt", length = 10)
    @PropertyDef(label = "发票状态",description = "1：正常,0：作废")
    private String fpzt;

    @Column(name = "INOUT_RECORD_ID_", length = 40)
    @PropertyDef(label = "流水号", description = "根据一定的规则生成")
    private String inoutRecordId;

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

    @Transient
    private List<InoutRecord> recordItems;

}

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

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

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

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

/**
 * @Desc: å€’仓功能，2023å¹´5月26日 æ ¹æ®æ–°å›½ç²®è§„更新优化
 * @author: Andy
 * @update-time: 2023/5/26
 */
@Data
@Entity
@Table(name = "D_INOUT_STOCK_CHANGE")
public class Fz61InoutStockChange {

    public static String SORT_PROP = "updateTime";
    /**
     * å€’仓单号
     */
    @Id
    @Column(name = "ID_", length = 32)
    @PropertyDef(label = "倒仓单号", description = "由倒仓日期(yyyyMMdd)+4位顺序号组成")
    private String id;

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

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

    @Column(name = "TYPE_", length = 2)
    @PropertyDef(label = "倒仓类型", description = "0：倒仓 1：移库")
    private String type;

    @Column(name = "PLAN_CODE_", length = 40)
    @PropertyDef(label = "倒仓计划文件编号", description = "倒仓计划文件编号")
    private String planCode;

    @Column(name = "NOTICE_ID_", length = 40)
    @PropertyDef(label = "通知单号", description = "通知单号")
    private String noticeId;

    @Column(name = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种", description = "代码不足7位需在末位补0")
    private String foodVariety;

    @Column(name = "DEPOT_ID_IN", length = 50)
    @PropertyDef(label = "倒入仓库")
    private String depotIdIn;

    @Column(name = "DEPOT_ID_OUT", length = 50)
    @PropertyDef(label = "倒出仓库")
    private String depotIdOut;

    @Column(name = "CHANGE_DATE_")
    @PropertyDef(label = "倒仓日期", description = "yyyy-MM-dd")
    private Date changeDate;

    @Column(name = "CHANGE_START_DATE_")
    @PropertyDef(label = "倒仓开始日期", description = "yyyy-MM-dd")
    private Date changeStartDate;

    @Column(name = "CHANGE_END_DATE_")
    @PropertyDef(label = "倒仓结束日期", description = "yyyy-MM-dd")
    private Date changeEndDate;

    @Column(name = "NUMBER_")
    @PropertyDef(label = "倒仓数量", description = "单位：公斤")
    private Double number = 0.0;

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

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

    @Column(name = "bzw", length = 1)
    @PropertyDef(label = "包装物", description = "1：麻袋 2：编织袋 3：散装 9：其他")
    private String bzw;

    @Column(name = "bzbjs")
    @PropertyDef(label = "标准包件数", description = "单位：件")
    private Integer bzbjs = 0;

    @Column(name = "zxzydw", length = 256)
    @PropertyDef(label = "装卸作业单位", description = "装卸作业的人员姓名或单位名称，用半角逗号分隔")
    private String zxzydw;

}

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

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

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

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

/**
 * ç»¼åˆç®¡ç†-粮食性质变更，主要是出入库之前做 å‚¨å¤‡è½¬å•†å“ï¼Œå®Œæˆä¹‹åŽ å•†å“è½¬å‚¨å¤‡ã€‚
 * <p>
 * å˜æ›´è®°å½•ï¼šè¡¨åå˜æ›´ä¸º D_INOUT_VARIETY_CHANGE
 */
@Data
@Entity
@Table(name = "D_INOUT_VARIETY_CHANGE")
public class Fz61InoutVarietyChange implements Serializable {

    public static String SORT_PROP = "changeTime";

    @Id
    @Column(name = "ID_", length = 41)
    @PropertyDef(label = "粮食性质转变单号", description = "由货位代码+划转日期（yyyyMMdd）+3位顺序号组成")
    private String id;

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

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

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

    @Column(name = "NUMBER_")
    @PropertyDef(label = "粮食数量", description = "单位：公斤")
    private Double number = 0.0;

    @Column(name = "CHANGE_NUMBER_")
    @PropertyDef(label = "划转数量", description = "单位：公斤")
    private Double changeNumber = 0.0;

    @Column(name = "APPROVAL_ID_", length = 40)
    @PropertyDef(label = "批准文号")
    private String approvalId;

    @Column(name = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种", description = "代码不足7位需在末位补0")
    private String foodVariety;

    /**
     * 100、储备粮 110、中央储备粮 120、地方储备粮
     * 121、省(自治区、直辖市)级地方储备粮
     * 122、市(地区、自治州、盟)级地方储备粮
     * 123、县(自治县、县级市、旗、自治旗、市辖区、林区、特区)级地方储备粮
     * 129、其他储备粮 200、商品粮 270、中储粮系统商品粮
     * 280、进口商品粮 290、其他商品粮 300、政策性粮食
     * 310、最低收购价粮 320、国家临时存储粮 330、国家临储进口粮
     * 340、地方临时存储粮
     */
    @Column(name = "FOOD_TYPE_", length = 10)
    @PropertyDef(label = "划转前粮食性质代码")
    private String foodType;

    @Column(name = "NEW_FOOD_TYPE_", length = 10)
    @PropertyDef(label = "划转后粮食性质代码")
    private String newFoodType;

    @Column(name = "CHANGE_TIME_")
    @PropertyDef(label = "划转日期")
    private Date changeTime;

    @PropertyDef(label = "仓储审核人")
    @Column(name = "ccshr", length = 64)
    private String ccshr;

    @Column(name = "AUDIT_CCSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditCcsh;

    @Column(name = "INFO_CCSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String InfoCcsh;

    @PropertyDef(label = "质检审核人")
    @Column(name = "zjshr", length = 64)
    private String zjshr;

    @Column(name = "AUDIT_ZJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditZjsh;

    @Column(name = "INFO_ZJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoZjsh;

    @PropertyDef(label = "统计审核人")
    @Column(name = "tjshr", length = 64)
    private String tjshr;

    @Column(name = "AUDIT_TJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditTjsh;

    @Column(name = "INFO_TJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoTjsh;

    @PropertyDef(label = "会计审核人")
    @Column(name = "kjshr", length = 64)
    private String kjshr;

    @Column(name = "AUDIT_KJSH_", length = 10)
    @PropertyDef(label = "审批状态")
    private String auditKjsh;

    @Column(name = "INFO_KJSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoKjsh;

    @PropertyDef(label = "领导审核人")
    @Column(name = "ldshr", length = 64)
    private String ldshr;

    @Column(name = "AUDIT_LDSH_", length = 10)
    @PropertyDef(label = "审批状态", description = "最终审核状态以领导审核为准")
    private String auditLdsh;

    @Column(name = "INFO_LDSH_", length = 200)
    @PropertyDef(label = "审核说明")
    private String infoLdsh;

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

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

}

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

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

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

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

/**
 * OA-人员管理
 *
 * @author: YAN
 * @description:
 * @version:
 * @data:2023å¹´8月10日
 */
@Data
@Entity
@Table(name = "D_OA_STAFF")
public class Fz61OAStaff implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @Column(name = "sfzhm", length = 18)
    @PropertyDef(label = "身份证号码")
    private String sfzhm;

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

    @Column(name = "DEPT_ID_", length = 20)
    @PropertyDef(label = "库区编码", description = "")
    private String deptId;

    @Column(name = "lsbm", length = 256)
    @PropertyDef(label = "隶属部门", description = "隶属部门名称")
    private String lsbm;

    @Column(name = "xzqhdm", length = 6)
    @PropertyDef(label = "所属行政区划")
    private String xzqhdm;

    @Column(name = "xzqhmc", length = 6)
    @PropertyDef(label = "所属行政区划")
    private String xzqhmc;

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

    @Column(name = "xb", length = 1)
    @PropertyDef(label = "性别")
    private String xb;

    @Column(name = "rzrq")
    @PropertyDef(label = "入职日期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date rzrq;
    /**
     * 11： åœ¨å²—职工(长期)，12： åœ¨å²— èŒå·¥(临时)，20： å…¶ä»–从业人员
     */
    @Column(name = "gwxz", length = 2)
    @PropertyDef(label = "岗位性质")
    private String gwxz;
    /**
     * 01： åœ¨å²— 02： å·²ç¦»èŒ
     */
    @Column(name = "zgzt", length = 2)
    @PropertyDef(label = "在岗状态")
    private String zgzt;

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

    @Column(name = "zjdh", length = 16)
    @PropertyDef(label = "座机电话")
    private String zjdh;

    @Column(name = "yddh", length = 16)
    @PropertyDef(label = "移动电话")
    private String yddh;

    @Column(name = "dzyx", length = 32)
    @PropertyDef(label = "电子邮箱")
    private String dzyx;

    @Column(name = "mz", length = 2)
    @PropertyDef(label = "民族")
    private String mz;

    @Column(name = "zzmm", length = 2)
    @PropertyDef(label = "政治面貌")
    private String zzmm;

    @Column(name = "rylb", length = 4)
    @PropertyDef(label = "人员类别")
    private String rylb;

    @Column(name = "zy", length = 128)
    @PropertyDef(label = "专业")
    private String zy;

    @Column(name = "qdzgzchzyzgsj")
    @PropertyDef(label = "取得最高职称或职业资格时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date qdzgzchzyzgsj;

    @Column(name = "xl", length = 1)
    @PropertyDef(label = "学历")
    private String xl;

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

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


}

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

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

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

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

/**
 * @Author: YYC
 * @Description:
 * @DateTime: 2025-9-16 16:25
 **/
@Data
@Entity
@Table(name = "D_SEC_CAMERA")
public class Fz61SecCamera implements Serializable {

    public static String SORT_PROP = "orderNum";

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

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

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


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


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


    @Column(name = "BRAND_", length = 50)
    @PropertyDef(label = "设备品牌")
    private String brand;

    @Column(name = "SN_", length = 50)
    @PropertyDef(label = "序列号")
    private String sn;

    @Column(name = "PLAY_TYPE_", length = 40)
    @PropertyDef(label = "播放方式")
    private String playType;

    @Column(name = "LOGIN_ID_", length = 20)
    @PropertyDef(label = "帐号")
    private String loginId;

    @Column(name = "PWD_", length = 20)
    @PropertyDef(label = "密码")
    private String pwd;

    @Column(name = "IP_", length = 20)
    @PropertyDef(label = "IP地址")
    private String ip;

    @Column(name = "CONTROL_PORT_")
    @PropertyDef(label = "控制端口")
    private Integer controlPort;

    @Column(name = "WEB_PORT_")
    @PropertyDef(label = "WEB端口")
    private Integer webPort;

    @Column(name = "CHAN_NUM_")
    @PropertyDef(label = "通道号")
    private Integer chanNum = 1;

    @PropertyDef(label = "内网直播地址")
    @Column(name = "URL_IN_", length = 254)
    private String urlIn;

    @PropertyDef(label = "外网直播地址")
    @Column(name = "URL_OUT_", length = 254)
    private String urlOut;

    @Column(name = "MEDIA_ADDR_", length = 100)
    @PropertyDef(label = "RTSP地址")
    private String mediaAddr;

    @Column(name = "SNAP_TYPE_", length = 25)
    @PropertyDef(label = "抓拍方式")
    private String snapType;

    @Column(name = "spjklx", length = 1)
    @PropertyDef(label = "视频监控类型")
    private String spjklx;

    @Column(name = "spdwlx", length = 2)
    @PropertyDef(label = "视频点位类型")
    private String spdwlx;

    @PropertyDef(label = "页面中的坐标")
    @Column(name = "POS_X_")
    private Double posX;

    @PropertyDef(label = "页面中的坐标")
    @Column(name = "POS_Y_")
    private Double posY;

    @PropertyDef(label = "大屏显示标记")
    @Column(name = "SCREEN_SHOW_", length = 1)
    private String screenShow;

    @PropertyDef(label = "手机是否显示")
    @Column(name = "PHONE_SHOW_TAG_", length = 1)
    private String phoneShowTag ;

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

    @PropertyDef(label = "是否使用")
    @Column(name = "VLD_", length = 1)
    private String vld;

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

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



}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1107.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1107;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1107Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40DeptDevice;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1107Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1107 {
    @Autowired
    private Fzzy40Sync1107Rep fzzy40Sync1107Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1107Rep api1107Rep;

    /**
     * åŒæ­¥è®¾å¤‡ä¿¡æ¯
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1107接口设备信息开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1107);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz40DeptDevice> list = fzzy40Sync1107Rep.listDevice(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到设备信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1107 apiData;
            List<Api1107> api1107List;
            for (Fz40DeptDevice sysData : list) {
                apiData = new Api1107();

                apiData.setSbbh(sysData.getSbbh());
                apiData.setDwdm(api1102.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setSbyqmc(sysData.getSbyqmc());
                apiData.setSbyqdm(sysData.getSbyqdm());
                apiData.setSbggxh(sysData.getSbggxh());
                if (StringUtils.isEmpty(sysData.getSccj())) {
                    apiData.setSccj("生产厂家");
                } else {
                    apiData.setSccj(sysData.getSccj());
                }
                apiData.setScrq(sysData.getScrq());
                apiData.setSbms(sysData.getSbms());
                apiData.setSbzt(sysData.getSbzt());
                apiData.setJdsj(sysData.getJdsj());
                apiData.setJddw(sysData.getJddw());
                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getSbbh());

                api1107List = api1107Rep.getDataByBizId(apiData.getBizId());
                if (null == api1107List || api1107List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1107List.get(0).getCzbz());
                }

                //保存数据
                api1107Rep.save(apiData);
                log.info("1107设备信息---同步数据：{}", apiData.toString());
            }

        } catch (Exception e) {
            log.error("---1107设备信息同步执行失败----{}", e.toString());
            apiLog.setResult("设备信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1108.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1108;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1108Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40Drug;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1108Rep;
import com.fzzy.async.fzzy61.entity.Fz61Drug;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1108Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * è¯å‰‚信息同步
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1108 {

    @Autowired
    private Fzzy61Sync1108Rep fzzy61Sync1108Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1108Rep api1108Rep;


    /**
     * åŒæ­¥è¯å‰‚信息
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1108接口药剂信息开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1108);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());

        try {
            List<Fz61Drug> list = fzzy61Sync1108Rep.listDrug(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到药剂信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1108 apiData;
            List<Api1108> api1108List;
            for (Fz61Drug sysData : list) {

                apiData = new Api1108();
                apiData.setId(kqdm + sysData.getId());//ID
                apiData.setBizId(sysData.getId());//业务id
                apiData.setDwdm(api1102.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setYjbh(kqdm + sysData.getId().substring(8));//药剂编号
                apiData.setYjmc(sysData.getName());//药剂名称
                apiData.setBzw(StringUtils.isEmpty(sysData.getBzw())?"":sysData.getBzw());//包装物
                apiData.setGgxh(StringUtils.isEmpty(sysData.getGgxh())?"":sysData.getGgxh());//型号规格
                apiData.setAqsysms(StringUtils.isEmpty(sysData.getAqsysms())?"":sysData.getAqsysms());//安全使用说明书
                apiData.setSccj(StringUtils.isEmpty(sysData.getSccj())?"":sysData.getSccj());//生产厂家
                apiData.setCgly(StringUtils.isEmpty(sysData.getCgly())?"":sysData.getCgly());//采购来源
                apiData.setCctj(StringUtils.isEmpty(sysData.getCctj())?"":sysData.getCctj());//存储条件
                apiData.setCcdd(StringUtils.isEmpty(sysData.getCcdd())?"":sysData.getCcdd());//储存地点
                apiData.setBzwclfs(StringUtils.isEmpty(sysData.getBzwclfs())?"":sysData.getBzwclfs());//包装物处理方式
                apiData.setCzclfs(StringUtils.isEmpty(sysData.getCzclfs())?"":sysData.getCzclfs());//残渣处理方式
                apiData.setBzq(StringUtils.isEmpty(sysData.getBzw())? "1å¹´": sysData.getBzq());//保质期
                apiData.setCgrq(null == sysData.getBzw()?new Date():sysData.getCgrq());//采购日期
                apiData.setKcsl(sysData.getCount());//库存数量
                apiData.setKcsldw(StringUtils.isEmpty(sysData.getKcsldw())?"":sysData.getKcsldw());//库存数量单位

                apiData.setZhgxsj(sysData.getUpdateTime());//最后更新时间
                apiData.setBizId(sysData.getId());//业务id

                api1108List = api1108Rep.getDataByBizId(apiData.getBizId());
                if (null == api1108List || api1108List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1108List.get(0).getCzbz());
                }

                //保存数据
                api1108Rep.save(apiData);
                log.info("1108药剂信息---同步数据：{}", apiData.toString());
            }

        } catch (Exception e) {
            log.error("---1108药剂信息同步执行失败----{}", e.toString());
            apiLog.setResult("药剂信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1109.java

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

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.FileUtils;
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.fzzy61.entity.Fz61FileInfo;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecord;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1109Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1202Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.*;
import java.util.stream.Collectors;

/**
 * æ–‡ä»¶ä¿¡æ¯
 */
@Slf4j
@Component
public class Fzzy61Sync1109 {

    private final static String IMG_START_C = "C_";
    private final static String IMG_START_R = "R_";
    /**
     * å›¾ç‰‡ç±»åž‹
     */
    private final static String IMG_TYPE_1 = "1";    //库区鸟瞰图
    private final static String IMG_TYPE_2 = "2";    //入库图片
    private final static String IMG_TYPE_3 = "3";    //出库图片
    private final static String IMG_TYPE_4 = "4";    //入库检斤视频
    private final static String IMG_TYPE_5 = "5";    //出库检斤视频
    private final static String IMG_TYPE_104 = "104";//熏蒸备案接口附件，用于广东省

    /**
     * ä¸šåŠ¡ç±»åž‹
     */
    private final static String BIZ_TAG_WEIGHT_FULL = "WEIGHT_FULL";
    private final static String BIZ_TAG_WEIGHT_EMPTY = "WEIGHT_EMPTY";
    private final static String BIZ_TAG_REGISTER = "REGISTER";
    private final static String BIZ_TAG_CARD_BACK = "CARD_BACK";
    /**
     * å‡ºå…¥åº“类型
     */
    private final static String INOUT_TYPE_IN = "IN";
    private final static String INOUT_TYPE_OUT = "OUT";

    @Autowired
    private Fzzy61Sync1109Rep fzzySync1109Rep;
    @Autowired
    private Fzzy61Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1205Rep api1205Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private FileUtils fileUtil;

    /**
     * åŒæ­¥æ–‡ä»¶æŽ¥å£
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1109文件信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1109);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取出入库数据
            List<Fz61InoutRecord> list = fzzySync1202Rep.listInAndOutRecord(deptId, INOUT_TYPE_IN, INOUT_TYPE_OUT, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到文件信息------------------");
                return;
            }

            Map<String, Integer> map = new HashMap<>();
            Api1109 apiData;
            String wjlx;
            String wjmc;
            List<Api1109> api1109List;
            List<Api1202> api1202List;
            List<Api1205> api1205List;
            String str = "";  //出入库业务单号
            List<Fz61FileInfo> fileList; //文件信息
            List<String> ids;
            for (Fz61InoutRecord inoutData : list) {
                if (inoutData.getRecordStatus().equals("DEL") || inoutData.getRecordStatus().equals("ERROR")) {
                    continue;
                }
                if (!inoutData.getProgress().equals("RECORD")) {
                    continue;
                }
                ids = new ArrayList<>();
                wjlx = "";
                //获取出入库业务单号信息
                if (inoutData.getType().equals(INOUT_TYPE_IN)) {
                    wjlx = IMG_TYPE_2;
                    api1202List = api1202Rep.getDataByBizId(inoutData.getId());
                    if (null == api1202List || api1202List.isEmpty()) {
                        continue;
                    }
                    ids = api1202List.stream().map(Api1202::getRkywdh).collect(Collectors.toList());
                }
                if (inoutData.getType().equals(INOUT_TYPE_OUT)) {
                    wjlx = IMG_TYPE_3;
                    api1205List = api1205Rep.getDataByBizId(inoutData.getId());
                    if (null == api1205List || api1205List.isEmpty()) {
                        continue;
                    }
                    ids = api1205List.stream().map(Api1205::getCkywdh).collect(Collectors.toList());

                }

                //若文件类型为空，则跳过
                if (StringUtils.isEmpty(wjlx)) {
                    continue;
                }

                //根据出入库单号获取对应文件信息
                fileList = fzzySync1109Rep.listFileInfoByBizId(inoutData.getId());
                if (null == fileList || fileList.isEmpty()) {
                    continue;
                }
                int num = 1;
                int idsNum = 0;
                String bizTag = null;
                for (Fz61FileInfo sysData : fileList) {
                    apiData = new Api1109();

                    //主键id
                    apiData.setId(sysData.getFileId());
                    //文件路径
                    apiData.setWjdz(fileUtil.getInoutFilePath(sysData.getCreateTime()) + sysData.getFileName());
                    //登记
                    if (BIZ_TAG_REGISTER.equals(sysData.getBizTag()) || BIZ_TAG_CARD_BACK.equals(sysData.getBizTag())) {
                        str = ids.get(0);
                        wjmc = kqdm + "_" + str;
                        //文件名称
                        wjmc = getImgNameType(wjmc, sysData.getBizTag(), str, sysData.getFileName(), map);
                        apiData.setWjmc(wjmc);
                        //文件类型
                        apiData.setWjlx(wjlx);
                    }
                    //称重
                    if (BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())) {
                        bizTag = sysData.getBizTag();
                        if (StringUtils.isNotEmpty(inoutData.getTransType()) && inoutData.getTransType().equals("3")) {
                            if (num > 6) {
                                num = 1;
                                idsNum++;
                            }
                        } else {
                            if (num > 8) {
                                num = 1;
                                idsNum++;
                            }
                        }
                        //2024-05-23 æ­¤å¤„暂时设置名称长度限制，后期调整后可删除
                        if (sysData.getCreateTime().after(DateUtils.parseDate("2024-04-18", new String[]{"yyyy-MM-dd"}))) {
                            if (StringUtils.isNotEmpty(inoutData.getTransType()) && inoutData.getTransType().equals("3")) {
                                bizTag = sysData.getBizTag();
                            } else {
                                bizTag = null;
                            }
                        }
                        if (idsNum == ids.size()) {
                            break;
                        }
                        str = ids.get(idsNum);

                        wjmc = kqdm + "_" + str;

                        //文件名称
                        wjmc = getImgNameType(wjmc, bizTag, str, sysData.getFileName(), map);
                        apiData.setWjmc(wjmc);
                        apiData.setWjlx(wjlx);
                        if (wjmc.indexOf(Constant.IMG_NAME_TYPE_IVG) >= 0 || wjmc.indexOf(Constant.IMG_NAME_TYPE_IVT) >= 0) {
                            apiData.setWjlx(IMG_TYPE_4);
                        }
                        if (wjmc.indexOf(Constant.IMG_NAME_TYPE_OVG) >= 0 || wjmc.indexOf(Constant.IMG_NAME_TYPE_OVT) >= 0) {
                            apiData.setWjlx(IMG_TYPE_5);
                        }
                        num++;
                    }

                    //操作标志及最后更新时间
                    apiData.setZhgxsj(new Date());

                    //业务id、库区编码、同步时间
                    apiData.setBizId(sysData.getFileId());
                    apiData.setKqdm(kqdm);
                    apiData.setSyncTime(new Date());

                    api1109List = api1109Rep.getDataByBizId(apiData.getBizId());
                    if (null == api1109List || api1109List.isEmpty()) {
                        apiData.setCzbz(Constant.CZBZ_I);
                    } else {
                        apiData.setCzbz(api1109List.get(0).getCzbz());
                    }

                    //保存数据
                    api1109Rep.save(apiData);
                    log.info("1109文件信息---同步数据：{}", apiData.toString());
                }
            }
        } catch (Exception e) {
            log.error("---1109文件同步执行失败----{}", e.toString());
            apiLog.setResult("同步文件信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

    /**
     * èŽ·å–图片命名类型
     *
     * @param wjmc     éœ€è¦çš„文件名称
     * @param bizTag   æ–‡ä»¶ä¸šåŠ¡ç±»åž‹
     * @param bizId    æ–‡ä»¶ä¸šåŠ¡id
     * @param fileName åŽŸæ–‡ä»¶å
     * @param map
     * @return
     */
    private String getImgNameType(String wjmc, String bizTag, String bizId, String fileName, Map<String, Integer> map) {
        if (null == bizTag) {
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_DJ) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_DJ + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_RK) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_RK + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_CK) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_CK + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_GL) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_GL + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_GR) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_GR + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_GT) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_GT + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_TL) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_TL + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_TR) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_TR + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_TT) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_TT + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_SL) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_SL + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_SF) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_SF + ".jpg";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_IVG) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_IVG + ".mp4";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_IVT) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_IVT + ".mp4";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_OVG) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_OVG + ".mp4";
            }
            if (fileName.indexOf(Constant.IMG_NAME_TYPE_OVT) >= 0) {
                return wjmc + "_" + Constant.IMG_NAME_TYPE_OVT + ".mp4";
            }
        }

        Integer num = 0;
        //毛重
        if (BIZ_TAG_WEIGHT_FULL.equals(bizTag)) {
            if (null == map.get(bizId + "_" + bizTag)) {
                map.put(bizId + "_" + bizTag, 1);
            }
            num = map.get(bizId + "_" + bizTag);
            if (num == 1) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_GL;
                map.put(bizId + "_" + bizTag, 2);
            }
            if (num == 2) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_GR;
                map.put(bizId + "_" + bizTag, 3);
            }
            if (num == 3) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_GT;
                map.remove(bizId + "_" + bizTag);
            }
        }
        //皮重
        if (BIZ_TAG_WEIGHT_EMPTY.equals(bizTag)) {
            if (null == map.get(bizId + "_" + bizTag)) {
                map.put(bizId + "_" + bizTag, 1);
            }
            num = map.get(bizId + "_" + bizTag);
            if (num == 1) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_TL;
                map.put(bizId + "_" + bizTag, 2);
            }
            if (num == 2) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_TR;
                map.put(bizId + "_" + bizTag, 3);
            }
            if (num == 3) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_TT;
                map.remove(bizId + "_" + bizTag);
            }
        }
        //入库登记
        if (BIZ_TAG_REGISTER.equals(bizTag)) {
            if (null == map.get(bizId + "_" + bizTag)) {
                map.put(bizId + "_" + bizTag, 1);
            }
            num = map.get(bizId + "_" + bizTag);
            if (num == 1) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_DJ;
                map.put(bizId + "_" + bizTag, 2);
            }
            if (num == 2) {
                wjmc += "_" + Constant.IMG_NAME_TYPE_RK;
                map.remove(bizId + "_" + bizTag);
            }
        }
        //出库照片
        if (BIZ_TAG_CARD_BACK.equals(bizTag)) {
            wjmc += "_" + Constant.IMG_NAME_TYPE_CK;
        }
        return wjmc + ".jpg";
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1111.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy40.entity.Fz40SecCamera;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1111Rep;
import com.fzzy.async.fzzy61.entity.Fz61SecCamera;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1111Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * åº“区图视频监控设备点位标注
 */
@Slf4j
@Component
public class Fzzy61Sync1111 {

    @Autowired
    private Fzzy61Sync1111Rep fzzy61Sync1111Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1111Rep api1111Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private ApiConfsRep apiConfsRep;

    /**
     * åŒæ­¥ç›‘控接口
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1111接口监控点位数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1111);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61SecCamera> list = fzzy61Sync1111Rep.listCamera(deptId, start, end);
            List<ApiConfs> apiConfs = apiConfsRep.getDataByKqdm(kqdm);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到监控信息------------------");
                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();
            Api1111 apiData;
            List<Api1111> listApi1111;
            Integer num = 1000001;
            for (Fz61SecCamera sysData : list) {

                apiData = new Api1111();
                apiData.setDwmc(api1101.getDwmc());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setKqdm(api1102.getKqdm());
                apiData.setKqmc(api1102.getKqmc());

                apiData.setSpjksbmc(api1102.getKqmc() + "-" + sysData.getName());
                apiData.setSpjksbid(api1102.getXzqhdm() + "00401327" + String.valueOf(num).substring(1));
                if (sysData.getId().contains(api1102.getXzqhdm())) {
                    apiData.setSpjksbid(sysData.getId());
                }

                apiData.setSpjksbxdwz("(" + Math.round(sysData.getPosX() * apiConfs.get(0).getPosX()) + "," + Math.round(sysData.getPosY() * apiConfs.get(0).getPosY()) + ")");
                apiData.setBz(sysData.getRemark());
                //视频监控类型和点位类型
                apiData.setSpjklx(StringUtils.isEmpty(sysData.getSpjklx()) ? "3" : sysData.getSpjklx());
                apiData.setSpdwlx(StringUtils.isEmpty(sysData.getSpdwlx()) ? "7" : sysData.getSpdwlx());
                //操作标志及最后更新时间
                apiData.setZhgxsj(new Date());
                //业务id、库区编码、同步时间
                apiData.setSyncTime(new Date());
                apiData.setCzbz(Constant.CZBZ_I);

                listApi1111 = api1111Rep.getApi1111ById(apiData.getSpjksbid());
                if (null != listApi1111 && listApi1111.size() > 0) {
                    apiData.setCzbz(listApi1111.get(0).getCzbz());
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getSpjklx())) {
                        apiData.setSpjklx(listApi1111.get(0).getSpjklx());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getSpdwlx())) {
                        apiData.setSpdwlx(listApi1111.get(0).getSpdwlx());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getHkCameraIndexCode())) {
                        apiData.setHkCameraIndexCode(listApi1111.get(0).getHkCameraIndexCode());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getCfdm())) {
                        apiData.setCfdm(listApi1111.get(0).getCfdm());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getAjdm())) {
                        apiData.setAjdm(listApi1111.get(0).getAjdm());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getSpjksbwzys())) {
                        apiData.setSpjksbwzys(listApi1111.get(0).getSpjksbwzys());
                    }
                    if (StringUtils.isNotEmpty(listApi1111.get(0).getBz())) {
                        apiData.setBz(listApi1111.get(0).getBz());
                    }
                    apiData.setCzbz(listApi1111.get(0).getCzbz());
                } else {
                    apiData.setCzbz(Constant.CZBZ_I);
                }
                apiData.setBizId(sysData.getId());

                //保存数据
                api1111Rep.save(apiData);
                num++;
                log.info("1111监控点位---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---1111监控点位同步执行失败----{}", e.toString());
            apiLog.setResult("监控点位同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1112.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1112;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1112Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40OAStaff;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1112Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * äººå‘˜ä¿¡æ¯
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1112 {

    @Autowired
    private Fzzy40Sync1112Rep fzzy40Sync1112Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1112Rep api1112Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥äººå‘˜ä¿¡æ¯
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1112接口人员信息数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1112);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());

        try {
            List<Fz40OAStaff> list = fzzy40Sync1112Rep.listStaff(deptId.substring(0, 4));
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到人员信息------------------");
                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();

            Api1112 apiData;
            List<Api1112> api1112List;
            for (Fz40OAStaff sysData : list) {
                apiData = new Api1112();
                apiData.setDwmc(api1101.getDwmc());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setKqdm(api1101.getKqdm());

                apiData.setSfzhm(sysData.getSfzhm());
                apiData.setLsbm(sysData.getLsbm());
                apiData.setXzqhdm(sysData.getXzqhdm());
                apiData.setXm(sysData.getXm());
                apiData.setXb(sysData.getXb());
                apiData.setRzrq(sysData.getRzrq());
                apiData.setGwxz(sysData.getGwxz());
                apiData.setZgzt(sysData.getZgzt());
                apiData.setLzrq(sysData.getLzrq());
                apiData.setZjdh(sysData.getZjdh());
                apiData.setYddh(sysData.getYddh());
                apiData.setDzyx(sysData.getDzyx());
                apiData.setMz(sysData.getMz());
                apiData.setZzmm(sysData.getZzmm());
                apiData.setZy(sysData.getZy());
                apiData.setQdzgzchzyzgsj(sysData.getQdzgzchzyzgsj());
                apiData.setXl(StringUtils.isEmpty(sysData.getXl()) ? "3" : sysData.getXl());
                apiData.setZw(sysData.getZw());
                apiData.setRylb(sysData.getRylb());

                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getSfzhm());

                api1112List = api1112Rep.getDataByBizId(apiData.getBizId());
                if (null == api1112List || api1112List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1112List.get(0).getCzbz());
                }

                //保存数据
                api1112Rep.save(apiData);
                log.info("1112人员信息---同步数据：{}", apiData.toString());

            }

        } catch (Exception e) {
            log.error("---1112人员信息同步执行失败----{}", e.toString());
            apiLog.setResult("人员信息同步执行失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1201.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.data.PushProtocol;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.FileUtils;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy61.entity.Fz61InoutContract;
import com.fzzy.async.fzzy61.entity.Fz61InoutCustomer;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1201Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1212Rep;
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.math.BigDecimal;
import java.util.Date;
import java.util.List;

/**
 * åˆåŒä¿¡æ¯æ•°æ®æŽ¥å£
 */
@Slf4j
@Component
public class Fzzy61Sync1201 {

    @Autowired
    private Fzzy61Sync1212Rep fzzySync1212Rep;
    @Autowired
    private Fzzy61Sync1201Rep fzzySync1201Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private ApiConfsRep apiConfsRep;
    @Autowired
    private FileUtils fileUtil;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private Api1201Rep api1201Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;


    /**
     * åŒæ­¥åˆåŒæŽ¥å£
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1201合同信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1201);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutContract> list = fzzySync1201Rep.listContract(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.debug("-------------没有获取到合同信息------------------");
                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1201 = api1102Rep.findById(kqdm).get();

            Api1201 apiData;
            List<Api1201> api1201List;
            List<Fz61InoutCustomer> listCustomer;
            Api1109 api1109;
            List<Api1109> api1109List;
            for (Fz61InoutContract sysData : list) {

                apiData = new Api1201();
                //单位代码（ 1101 æŽ¥å£çš„单位代 ç ï¼‰ +自定义编码
                apiData.setHth(api1201.getDwdm() + sysData.getId());
                apiData.setHtmc(sysData.getName().trim());
                apiData.setDwdm(api1201.getDwdm());

                //业务类型
                apiData.setYwlx(sysData.getType());
                apiData.setHtzl(sysData.getType());
                //客户类型
                apiData.setKhlx(sysData.getCustomerType());

                //企业客户，需要设置信用码
                if ("1".equals(sysData.getCustomerType())) {
                    listCustomer = fzzySync1212Rep.getDataById(sysData.getCustomerId());
                    if (null == listCustomer || listCustomer.isEmpty()) {
                        continue;
                    }
                    apiData.setKhtyshxydm(listCustomer.get(0).getKhbh());
                    apiData.setSfzh(listCustomer.get(0).getCardId());
                    apiData.setLxrdh(listCustomer.get(0).getPhone());
                    apiData.setYzbm(StringUtils.isEmpty(listCustomer.get(0).getYzbm()) ? "000000" : listCustomer.get(0).getYzbm());
                    apiData.setDzyx(listCustomer.get(0).getDzyx());
                }


                apiData.setKhmc(sysData.getCustomerName());
                apiData.setFddbr(StringUtils.isEmpty(sysData.getCustomerSignUser()) ? null : sysData.getCustomerSignUser());

                apiData.setQdrq(sysData.getSigningTime());

                if (StringUtils.isEmpty(sysData.getFoodVariety())) {
                    continue;
                }
                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType());
                apiData.setLsxzdm(mappingCode);


                apiData.setYsfs(StringUtils.isEmpty(sysData.getYsfs()) ? "以入仓数量为标准" : sysData.getYsfs());

                apiData.setFkfs(null == sysData.getFkfs() ? "1" : sysData.getFkfs().toString());
                //单价：元/吨
                apiData.setHtdj(sysData.getPrice() == null ? 0.0 : sysData.getPrice());
                apiData.setYdgxlssl(sysData.getContactAmount() == null ? 0.0 : sysData.getContactAmount());

                apiData.setHtzje(new BigDecimal(sysData.getMoney()));

                apiData.setJsyhtyzx(StringUtils.isEmpty(sysData.getJsyhtyzx()) ? "1" : sysData.getJsyhtyzx());

                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_BANK, sysData.getCustomerBank());
                apiData.setKhfkhh(mappingCode);

                apiData.setKhfzh(sysData.getCustomerBankAccount());

                apiData.setKhqyr(sysData.getCustomerSignUser());

                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_BANK, sysData.getBank());
                apiData.setBfkhh(mappingCode == null ? "999" : mappingCode);

                apiData.setBfzh(StringUtils.isEmpty(sysData.getBankAccount()) ? "100000000000000000" : sysData.getBankAccount());

                apiData.setWcrq(sysData.getEndTime());
                apiData.setLxrxm(StringUtils.isEmpty(sysData.getLxrxm()) ? apiData.getFddbr() : sysData.getLxrxm());
                apiData.setJsyhtbyzyy(StringUtils.isEmpty(sysData.getJsyhtbyzyy()) ? "结算与合同不一致原因" : sysData.getJsyhtbyzyy());
                apiData.setQddd(StringUtils.isEmpty(sysData.getSignAddress()) ? "签订地点" : sysData.getSignAddress());
                apiData.setTxdz(StringUtils.isEmpty(sysData.getTxdz()) ? "通讯地址" : sysData.getTxdz());
                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setShr(StringUtils.isEmpty(sysData.getAuditUser()) ? "审批人" : sysData.getAuditUser());
                apiData.setShsj(sysData.getAuditDate() == null ? new Date() : sysData.getAuditDate());
                apiData.setSswcsj(sysData.getRelEndTime());
                apiData.setYdwcsj(sysData.getEndTime());
                apiData.setBfqyr(StringUtils.isEmpty(sysData.getSignUser()) ? "本方签约人" : sysData.getSignUser());

                //设置年度
                apiData.setLhnd(sysData.getYear());

                apiData.setSyncTime(new Date());
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);

                api1201List = api1201Rep.getDataById(apiData.getHth());
                if (null == api1201List || api1201List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1201List.get(0).getCzbz());
                }

                //保存数据
                api1201Rep.save(apiData);
                log.info("1201---合同同步数据：{}", apiData.toString());

                //若附件id不为空，则判断是否为上海协议，上海协议时，需同时同步合同附件信息
                if (StringUtils.isNotEmpty(sysData.getFileId())) {
                    //若为上海省平台协议，则需同时同步合同附件信息
                    List<ApiConfs> apiConfs = apiConfsRep.getDataByKqdm(kqdm);
                    if (null != apiConfs && PushProtocol.SB_SH_2023.getCode().equals(apiConfs.get(0).getPushProtocol())) {
                        api1109 = new Api1109();
                        //主键id
                        api1109.setId(apiData.getHth());
                        //文件路径
                        api1109.setWjdz(fileUtil.getCommonFilePath(sysData.getFileTime()) + sysData.getFileId());

                        String kzm = "pdf"; //扩展名：默认为pdf
                        String[] split = sysData.getFileId().split("\\.");
                        if (split.length > 0) {
                            kzm = split[split.length - 1];
                        }

                        //文件名称(合同号+扩展名)
                        api1109.setWjmc(apiData.getHth() + "." + kzm);
                        //文件类型
                        api1109.setWjlx("6"); //6-合同文件(pdf,jpg)
                        api1109.setYwdh(apiData.getHth()); //6-合同文件(pdf,jpg)
                        //操作标志及最后更新时间
                        api1109.setZhgxsj(new Date());

                        //业务id、库区编码、同步时间
                        api1109.setBizId(apiData.getHth());
                        api1109.setKqdm(kqdm);
                        api1109.setSyncTime(new Date());
                        api1109List = api1109Rep.getDataByBizId(api1109.getBizId());
                        if (null == api1109List || api1109List.isEmpty()) {
                            api1109.setCzbz(Constant.CZBZ_I);
                        } else {
                            api1109.setCzbz(api1109List.get(0).getCzbz());
                        }
                        //保存数据
                        api1109Rep.save(api1109);
                        log.info("1201---合同附件信息同步：{}", api1109.toString());
                    }
                }
            }
        } catch (Exception e) {
            log.error("---1201合同同步执行失败----{}", e.toString());
            apiLog.setResult("同步合同信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1202.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy61.entity.Fz61InoutNoticeIn;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecord;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecordItem;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1202Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncInoutRecordItemRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncNoticeInRep;
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;

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

/**
 * ç²®é£Ÿå…¥åº“信息
 */
@Slf4j
@Component
public class Fzzy61Sync1202 {

    /**
     * å…¥åº“类型
     */
    private final static String INOUT_TYPE_IN = "IN";

    @Autowired
    private Fzzy61Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy61SyncInoutRecordItemRep fzzy61SyncInoutRecordItemRep;
    @Autowired
    private Fzzy61SyncNoticeInRep fzzySyncNoticeInRep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1201Rep api1201Rep;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1204Rep api1204Rep;
    @Autowired
    private Api1208Rep api1208Rep;
    @Autowired
    private Api1404Rep api1404Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * ç²®é£Ÿå…¥åº“信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1202接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1202);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食入库记录信息，根据流程完成时间获取
            List<Fz61InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食入库信息------------------");
                return;
            }

            Api1202 apiData;
            Api1105 api1105;
            List<Fz61InoutNoticeIn> listInoutNotice;
            List<Api1202> api1202List;
            List<Fz61InoutRecordItem> listInoutRecordItem;
            List<Api1201> api1201List;
            List<Api1204> api1204List;
            List<Api1404> api1404List;
            for (Fz61InoutRecord sysData : list) {
                if (sysData.getRecordStatus().equals("DEL") || sysData.getRecordStatus().equals("ERROR")) {
                    continue;
                }
                if (!sysData.getProgress().equals("RECORD")) {
                    continue;
                }
                if (null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0) {
                    sysData.setRecordWeight(sysData.getSettleWeight());
                }
                //判断净重是否大于0，等于0表示不合格，不进行同步上传
                if (null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0) {
                    continue;
                }
                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }
                apiData = new Api1202();

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

                //货位代码
                apiData.setHwdm(api1105.getHwdm());
                apiData.setYwlx(Constant.INOUT_TYPE_2);
                apiData.setYwrq(DateUtils.parseDate(sysData.getId().substring(2, 10), new String[]{"yyyyMMdd"}));
                apiData.setCyr(sysData.getUserName().trim());

                //默认一个随便值
                apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact().trim());

                if (StringUtils.isEmpty(sysData.getUserId()) || sysData.getUserId().length() != 18) {
                    sysData.setUserId("410183199003187055");
                }
                apiData.setSfzh(sysData.getUserId());

                //获取通知单信息，查询合同号和计划明细号
                listInoutNotice = fzzySyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
                if (null != listInoutNotice && listInoutNotice.size() > 0) {
                    //合同号
                    if (StringUtils.isNotEmpty(listInoutNotice.get(0).getContractId())) {
                        api1201List = api1201Rep.getDataByBizId(listInoutNotice.get(0).getContractId());
                        if (null != api1201List && api1201List.size() > 0) {
                            apiData.setHth(api1201List.get(0).getHth());
                        }
                    }
                    if (StringUtils.isNotEmpty(listInoutNotice.get(0).getPlanId())) {
                        api1404List = api1404Rep.getDataByBizIdAndKqdm(listInoutNotice.get(0).getPlanId(), kqdm);
                        if (null != api1404List && api1404List.size() > 0) {
                            apiData.setJhmxh(api1404List.get(0).getJhmxdh());
                            if (StringUtils.isEmpty(sysData.getFoodYear())) {
                                sysData.setFoodYear(api1404List.get(0).getShnd());
                            }
                        }
                    }
                }

                //粮权单位归属代码
                List<Api1208> dataByHwdm = api1208Rep.findDataByHwdm(apiData.getHwdm());
                if (null != dataByHwdm && dataByHwdm.size() > 0) {
                    apiData.setLqgsdwdm(StringUtils.isEmpty(dataByHwdm.get(0).getLqgsdwdm()) ? kqdm.substring(0, 18) : dataByHwdm.get(0).getLqgsdwdm());
                } else {
                    apiData.setLqgsdwdm(kqdm.substring(0, 18));
                }
                apiData.setSlr("售粮人");
                apiData.setSlrdz("售粮人地址");
                apiData.setBz(StringUtils.isEmpty(sysData.getRemarks()) ? "备注" : sysData.getRemarks());

                apiData.setXxdz(StringUtils.isEmpty(sysData.getUserAddress()) ? "详细地址" : sysData.getUserAddress());

                //运输工具，若为空，则默认给1-汽车
                apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1" : sysData.getTransType());

                //车船号
                apiData.setCch(sysData.getPlateNum().trim());

                apiData.setDjsj(sysData.getRegisterTime());

                //生成方式
                apiData.setScfs(1);
                if (StringUtils.isNotEmpty(sysData.getRecordStatus()) && sysData.getRecordStatus().equals("ADD")) {
                    apiData.setScfs(2);
                    apiData.setSdblyy("库区停电导致无法按流程进行出库");
                }

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType());
                apiData.setLsxzdm(mappingCode);

                apiData.setShnd(StringUtils.isEmpty(sysData.getFoodYear()) ? DateFormatUtils.format(sysData.getRegisterTime(), "yyyy") : sysData.getFoodYear());

                //产地代码
                mappingCode = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation());
                if (StringUtils.isEmpty(mappingCode)) {
                    mappingCode = apiData.getHwdm().substring(2, 8);
                }
                apiData.setCddm(mappingCode);

                //检斤类型，默认0-称重入库
                apiData.setJjlx(sysData.getJjlx());
                apiData.setBzbdbz(sysData.getDbz() == null ? 25 : sysData.getDbz());

                //毛重信息
                apiData.setMz(sysData.getFullWeight());
                if (null == sysData.getFullWeightTime()) {
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 25));
                }
                if (!sysData.getFullWeightTime().after(sysData.getRegisterTime())) {
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 25));
                }
                apiData.setMzjlsj(sysData.getFullWeightTime());
                apiData.setMzjby(sysData.getFullWeightUser());
                apiData.setMzjly(sysData.getFullWeightUser());

                apiData.setZcy(null == sysData.getHandleUser() ? sysData.getFullWeightUser() : sysData.getHandleUser());

                //皮重信息
                apiData.setPz(sysData.getEmptyWeight());
                if (null == sysData.getEmptyWeightTime()) {
                    sysData.setEmptyWeightTime(DateUtils.addMinutes(sysData.getFullWeightTime(), 60));
                }
                if (!sysData.getEmptyWeightTime().after(sysData.getFullWeightTime())) {
                    sysData.setEmptyWeightTime(DateUtils.addMinutes(sysData.getFullWeightTime(), 60));
                }

                apiData.setPzjlsj(sysData.getEmptyWeightTime());
                apiData.setPzjby(sysData.getEmptyWeightUser());
                apiData.setPzjly(sysData.getEmptyWeightUser());

                //扣重 åŒ–验总扣重
                apiData.setZjklxj(sysData.getDeCheck());
                apiData.setBzw(StringUtils.isEmpty(sysData.getBzw()) ? "9" : sysData.getBzw());
                apiData.setBzwkl(0 - sysData.getDePackage());
                apiData.setBzbjs(sysData.getBzbjs());
                apiData.setCmsj(sysData.getCompleteTime());
                //结算单号
                if (StringUtils.isNotEmpty(sysData.getSettleId())) {
                    apiData.setRkjsdh(kqdm + sysData.getSettleId());
                }
                if (StringUtils.isNotEmpty(apiData.getHth())) {
                    api1204List = api1204Rep.getDataByHthAndHwdm(apiData.getHth(), apiData.getHwdm());
                    if (null == api1204List || api1204List.isEmpty()) {
                        api1204List = api1204Rep.getDataByHth(apiData.getHth());
                        if (null != api1204List && api1204List.size() > 0) {
                            apiData.setRkjsdh(api1204List.get(0).getRkjsdh());
                        }
                    } else {
                        apiData.setRkjsdh(api1204List.get(0).getRkjsdh());
                    }
                }
                //其它
                apiData.setQtkl(0 - sysData.getDeOther());
                //值仓 çŽ°åœºæ‰£é‡
                apiData.setXckl(0 - sysData.getDeHandle());

                apiData.setJz(sysData.getRecordWeight());
                if (!sysData.getCompleteTime().after(sysData.getEmptyWeightTime())) {
                    sysData.setCompleteTime(DateUtils.addMinutes(sysData.getEmptyWeightTime(), 10));
                }
                apiData.setCmsj(sysData.getCompleteTime());

                //操作标志及最后更新时间
                apiData.setZhgxsj(sysData.getUpdateTime());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                apiData.setKlyy("扣量原因");

                apiData.setCmqrmgryxm(StringUtils.isEmpty(sysData.getRegisterUser()) ? "登记人" : sysData.getRegisterUser());
                apiData.setDjmgryxm(StringUtils.isEmpty(sysData.getRegisterUser()) ? "登记人" : sysData.getRegisterUser());
                //01:表示大型汽车号牌,黄底黑字； 02:表示小型汽车号牌,蓝底白字； 03:表示新能源汽车号牌,绿底黑 å­—ï¼›
                //04:表示农用车车牌号，绿底白字； LS:表示临时虚拟号牌，仅限于售 ç²®è½¦æ— å›ºå®šå·ç‰Œæ—¶ä½¿ç”¨
                apiData.setCchlx("01");
                apiData.setLdd("装粮地点");
                apiData.setZkj(0.0);
                apiData.setZlfyzkl(0.0);
                apiData.setQzsfzkl(0.0);
                apiData.setQzzzzkl(0.0);
                apiData.setQzgwcmkl(0.0);
                apiData.setQzhhkl(0.0);
                apiData.setQzbwslkl(0.0);
                apiData.setQzhlmkl(0.0);
                apiData.setQzsmlkl(0.0);
                apiData.setQzzjmlkl(0.0);
                apiData.setQzqtkl(0.0);
                apiData.setZkhyy("增扣价原因");
                apiData.setZxzydw(api1105.getBgdw());
                if (sysData.getCompanyId().equals("5329")) {
                    apiData.setLqgsdwdm("91461604MA56D2AM1X");
                }
                api1202List = api1202Rep.getDataById(apiData.getRkywdh());
                if (null == api1202List || api1202List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1202List.get(0).getCzbz());
                }
                //判断是否为船运
                if (StringUtils.isNotEmpty(sysData.getTransType()) && sysData.getTransType().equals("3")) {
                    listInoutRecordItem = fzzy61SyncInoutRecordItemRep.findDataByRecordId(sysData.getId());
                    if (null == listInoutRecordItem || listInoutRecordItem.isEmpty()) {
                        api1202Rep.save(apiData);
                        continue;
                    }

                    int idNum = Integer.valueOf(sysData.getId().substring(12)) * 100 + 10001;
                    for (Fz61InoutRecordItem fz61InoutRecordItem : listInoutRecordItem) {
                        if ("DEL".equals(fz61InoutRecordItem.getRecordStatus())) {
                            continue;
                        }
                        if (fz61InoutRecordItem.getSettleWeight() <= 0) {
                            continue;
                        }
                        apiData.setRkywdh(Constant.INOUT_TYPE_14 + sysData.getId().substring(4, 10) + String.valueOf(idNum).substring(1));
                        apiData.setMz(fz61InoutRecordItem.getFullWeight());
                        apiData.setPz(fz61InoutRecordItem.getEmptyWeight());
                        apiData.setJz(fz61InoutRecordItem.getSettleWeight());
                        apiData.setMzjlsj(fz61InoutRecordItem.getFullWeightTime());
                        apiData.setPzjlsj(fz61InoutRecordItem.getEmptyWeightTime());
                        apiData.setQtkl(0 - fz61InoutRecordItem.getDe());
                        api1202List = api1202Rep.getDataById(apiData.getRkywdh());
                        if (null == api1202List || api1202List.isEmpty()) {
                            apiData.setCzbz(Constant.CZBZ_I);
                        } else {
                            apiData.setCzbz(api1202List.get(0).getCzbz());
                        }
                        api1202Rep.save(apiData);
                        idNum++;
                    }
                } else {
                    //保存数据
                    api1202Rep.save(apiData);
                }

                log.info("1202---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {

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

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1203.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1202;
import com.fzzy.api.entity.Api1203;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.GbCheckItem;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.utils.DateUtil;
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;
import com.fzzy.async.fzzy61.entity.Fz61CheckItem;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecord;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecordItem;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1202Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1203Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncInoutRecordItemRep;
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;

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

/**
 * ç²®é£Ÿå…¥åº“检验信息
 */
@Slf4j
@Component
public class Fzzy61Sync1203 {

    /**
     * å…¥åº“类型
     */
    private final static String INOUT_TYPE_IN = "IN";

    @Autowired
    private Fzzy61Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy61SyncInoutRecordItemRep fzzy61SyncInoutRecordItemRep;
    @Autowired
    private Fzzy61Sync1203Rep fzzySync1203Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1202Rep api1202Rep;
    @Autowired
    private Api1203Rep api1203Rep;
    @Autowired
    private GbCheckItemRep gbCheckItemRep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * ç²®é£Ÿå…¥åº“检验信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1203入库检验接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1203);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食入库记录信息
            List<Fz61InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食入库信息------------------");
                return;
            }

            Api1203 apiData;
            List<Fz61CheckItem> fz61CheckItems;
            List<GbCheckItem> gbCheckList;
            String jyxm;
            String jyz;
            String zkj;
            String zkl;
            List<Api1203> api1203List;
            List<Api1202> api1102List;
            List<Fz61InoutRecordItem> listInoutRecordItem;
            List<String> listIds;
            for (Fz61InoutRecord sysData : list) {
                listIds = new ArrayList<>();
                //判断是否为船运
                if (StringUtils.isNotEmpty(sysData.getTransType()) && sysData.getTransType().equals("3")) {
                    listInoutRecordItem = fzzy61SyncInoutRecordItemRep.findDataByRecordId(sysData.getId());
                    if (null != listInoutRecordItem && listInoutRecordItem.size() > 0) {
                        int idNum = Integer.valueOf(sysData.getId().substring(12)) * 100 + 10001;

                        for (Fz61InoutRecordItem fz61InoutRecordItem : listInoutRecordItem) {
                            if ("DEL".equals(fz61InoutRecordItem.getRecordStatus())) {
                                continue;
                            }
                            listIds.add(Constant.INOUT_TYPE_14 + sysData.getId().substring(4, 10) + String.valueOf(idNum).substring(1));
                            idNum++;
                        }
                    } else {
                        listIds.add(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
                    }
                } else {
                    listIds.add(Constant.INOUT_TYPE_14 + sysData.getId().substring(4));
                }

                //获取入库质检信息
                fz61CheckItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId(), deptId.substring(0, 4));
                if (null == fz61CheckItems || fz61CheckItems.isEmpty()) {
                    log.info("-------------没有获取到当前入库质检信息--------------");
                    continue;
                }

                for (String listId : listIds) {
                    //查询粮食入库信息，若为空则不进行同步上传
                    api1102List = api1202Rep.getDataById(listId);
                    if (null == api1102List || api1102List.isEmpty()) {
                        continue;
                    }

                    apiData = new Api1203();

                    apiData.setRkjydh(api1102List.get(0).getRkywdh());
                    //货位代码
                    apiData.setHwdm(api1102List.get(0).getHwdm());
                    apiData.setRkywdh(api1102List.get(0).getRkywdh());
                    if (null == sysData.getFullWeightTime()) {
                        sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 5));
                    }

                    //判断业务时间与单据号是否匹配，若不匹配，则更改业务时间为单据号所在的时间
                    String time = apiData.getRkjydh().substring(2, 8);
                    if (sysData.getCheckTime() != null) {
                        String isCheckTime = DateFormatUtils.format(sysData.getCheckTime(), "yyMMdd");
                        if (!isCheckTime.equals(time)) {
                            int difDay = DateUtil.difDay1(sysData.getRegisterTime(), sysData.getCheckTime());
                            if (difDay == 0) {
                                apiData.setRkjydh("14" + isCheckTime + "01" + api1102List.get(0).getRkywdh().substring(10));
                            } else {
                                apiData.setRkjydh("14" + isCheckTime + String.format("%02d", difDay) + api1102List.get(0).getRkywdh().substring(10));
                            }
                        }
                    }

                    //船运使用入库单据号做质检单号
                    if (StringUtils.isNotEmpty(sysData.getTransType()) && sysData.getTransType().equals("3")) {
                        apiData.setRkjydh(api1102List.get(0).getRkywdh());
                    }

                    apiData.setQyrxm(sysData.getCheckUser());
                    //扦样方式 2-智能随机
                    apiData.setQyfs("2");

                    //检测项，检测值，增扣价及增扣量
                    jyxm = "";
                    jyz = "";
                    zkj = "";
                    zkl = "";
                    for (Fz61CheckItem fz61CheckItem : fz61CheckItems) {
                        gbCheckList = gbCheckItemRep.findByBizCode(fz61CheckItem.getStandardId());

                        if (gbCheckList == null || gbCheckList.isEmpty()) {
                            continue;
                        }
                        if (StringUtils.isEmpty(fz61CheckItem.getValue())) {
                            continue;
                        }
                        jyxm += "," + gbCheckList.get(0).getCode();
                        jyz += "," + fz61CheckItem.getValue();
                        zkj += ",0.0";
                        zkl += ",0.0";
                    }
                    if (jyxm.length() > 0) {
                        jyxm = jyxm.substring(1);
                    }
                    if (jyz.length() > 0) {
                        jyz = jyz.substring(1);
                    }
                    apiData.setJyxm(jyxm);
                    apiData.setJyz(jyz);
                    apiData.setZkj(StringUtils.isEmpty(zkj) ? "" : zkj.substring(1));
                    apiData.setZkl(StringUtils.isEmpty(zkl) ? "" : zkl.substring(1));
                    if ("UNPASS".equals(sysData.getCheckStatus())) {
                        apiData.setJyjg("0");
                    } else {
                        apiData.setJyjg("1");
                    }
                    apiData.setJyrxm(sysData.getCheckUser());
                    if (null == sysData.getCheckTime()) {
                        sysData.setCheckTime(DateUtils.addMinutes(sysData.getFullWeightTime(), -5));
                    }
                    if (sysData.getCheckTime().after(sysData.getEmptyWeightTime())) {
                        sysData.setCheckTime(DateUtils.addMinutes(sysData.getFullWeightTime(), -5));
                    }
                    apiData.setJysj(sysData.getCheckTime());
                    if (null == sysData.getSampleTime()) {
                        sysData.setSampleTime(DateUtils.addMinutes(sysData.getCheckTime(), -1));
                    }
                    if (sysData.getSampleTime().after(sysData.getCheckTime())) {
                        sysData.setSampleTime(DateUtils.addMinutes(sysData.getCheckTime(), -1));
                    }
                    apiData.setQysj(sysData.getSampleTime());

                    //粮食品种
                    String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                    apiData.setLspzdm(mappingCode);

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

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

                    //操作标志及最后更新时间
                    apiData.setZhgxsj(sysData.getCompleteTime());

                    //业务id、库区编码、同步时间
                    apiData.setBizId(sysData.getId());
                    apiData.setKqdm(kqdm);
                    apiData.setSyncTime(new Date());

                    api1203List = api1203Rep.getDataById(apiData.getRkjydh());
                    if (null == api1203List || api1203List.isEmpty()) {
                        apiData.setCzbz(Constant.CZBZ_I);
                    } else {
                        apiData.setCzbz(api1203List.get(0).getCzbz());
                    }

                    api1203Rep.save(apiData);
                    log.info("1203入库检验---同步数据：{}", apiData.toString());
                }
            }
        } catch (Exception e) {
            log.error("---1203入库检验数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

    public static void main(String[] args) {
        //判断业务时间与单据号是否匹配，若不匹配，则更改业务时间为单据号所在的时间
        String id = "142508200001";
        String time = id.substring(2, 8);

        String isCheckTime = "250821";
        if (!isCheckTime.equals(time)) {
            int difDay = 2;
            String idd = "14" + isCheckTime + difDay + id.substring(9);
            System.out.println(idd);
        }

    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1204.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1204;
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.Api1204Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutSettle;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1204Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * ç²®é£Ÿå…¥åº“结算信息同步
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1204 {

    /**
     * å…¥åº“类型
     */
    private final static String INOUT_TYPE_IN = "IN";

    @Autowired
    private Fzzy61Sync1204Rep fzzy61Sync1204Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1204Rep api1204Rep;
    @Autowired
    private ApiCommonService commonService;

    /**
     * ç²®é£Ÿå…¥åº“结算信息同步
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1204入库结算接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1204);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食入库结算信息
            List<Fz61InoutSettle> list = fzzy61Sync1204Rep.listInoutSettle(deptId, INOUT_TYPE_IN, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食入库结算信息------------------");
                return;
            }
            //根据库区代码获取库区信息
            Api1102 api1102 = api1102Rep.findById(kqdm).get();

            Api1204 apiData;
            Api1105 api1105;
            List<Api1204> api1204List;
            for (Fz61InoutSettle sysData : list) {

                apiData = new Api1204();
                //入库结算单号:库区代码 + yyyyMMdd + 4为顺序号
                apiData.setRkjsdh(kqdm + sysData.getId());

                //合同号
                if(StringUtils.isNotEmpty(sysData.getContractId())){
                    apiData.setHth(api1102.getDwdm() + sysData.getContractId());
                }

                if(StringUtils.isNotEmpty(sysData.getDepotId())){
                    api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                    //货位代码
                    apiData.setHwdm(api1105.getHwdm());
                }

                //结算重量、结算单价、结算金额、结算时间
                apiData.setJssl(sysData.getSettleWeight());
                apiData.setJsdj(sysData.getPayPrice());
                apiData.setJsje(sysData.getPayMoney());
                apiData.setJssj(sysData.getPayTime());

                //结算方式
                apiData.setJsfs(sysData.getPayType());

                apiData.setSkr(sysData.getPayee());
                apiData.setYhhbdm(sysData.getBankCategory());
                apiData.setSkrsfzh(sysData.getPayeeId());
                apiData.setKhhh(sysData.getBankCode());
                apiData.setKhhmc(sysData.getBank());
                apiData.setYhzh(sysData.getBankNum());
                apiData.setFphm("");
                apiData.setFpzt("");
                apiData.setFkdw(sysData.getPayUnit());

                //操作标志及最后更新时间
                apiData.setZhgxsj(new Date());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                log.info("1204入库结算---同步数据：{}", apiData.toString());
                //保存数据
                api1204List = api1204Rep.getDataById(apiData.getRkjsdh());
                if (null == api1204List || api1204List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1204List.get(0).getCzbz());
                }
                api1204Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---1204入库结算同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }


}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1205.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy61.entity.Fz61InoutNoticeOut;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecord;
import com.fzzy.async.fzzy61.entity.Fz61InoutRecordItem;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1202Rep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncInoutRecordItemRep;
import com.fzzy.async.fzzy61.repository.Fzzy61SyncNoticeOutRep;
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;

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

/**
 * ç²®é£Ÿå‡ºåº“信息
 */
@Slf4j
@Component
public class Fzzy61Sync1205 {

    /**
     * å‡ºåº“类型
     */
    private final static String INOUT_TYPE_OUT = "OUT";
    @Autowired
    private Fzzy61Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy61SyncInoutRecordItemRep fzzy61SyncInoutRecordItemRep;
    @Autowired
    private Fzzy61SyncNoticeOutRep fzzySyncNoticeOutRep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1201Rep api1201Rep;
    @Autowired
    private Api1205Rep api1205Rep;
    @Autowired
    private Api1206Rep api1206Rep;
    @Autowired
    private Api1310Rep api1310Rep;
    @Autowired
    private Api1404Rep api1404Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * ç²®é£Ÿå‡ºåº“信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1205出库信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1205);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食出库信息，根据流程完成时间获取
            List<Fz61InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_OUT, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食出库信息------------------");
                return;
            }

            Api1205 apiData;
            Api1105 api1105;
            List<Fz61InoutNoticeOut> listInoutNotice;
            List<Api1205> api1205List;
            List<Api1206> api1206List;
            List<Fz61InoutRecordItem> listInoutRecordItem;
            for (Fz61InoutRecord sysData : list) {
                if (sysData.getRecordStatus().equals("DEL") || sysData.getRecordStatus().equals("ERROR")) {
                    continue;
                }
                if (!sysData.getProgress().equals("RECORD")) {
                    continue;
                }
                if (null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0) {
                    sysData.setRecordWeight(sysData.getSettleWeight());
                }
                //判断净重是否大于0，等于0表示不合格，不进行同步上传
                if (null == sysData.getRecordWeight() || sysData.getRecordWeight() == 0) {
                    continue;
                }
                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }
                apiData = new Api1205();
                apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4));

                //货位代码
                apiData.setHwdm(api1105.getHwdm());
                apiData.setYwlx(Constant.INOUT_TYPE_1);
                apiData.setYwrq(DateUtils.parseDate(sysData.getId().substring(2, 10), new String[]{"yyyyMMdd"}));

                //默认一个随便值
                apiData.setLxdh(StringUtils.isEmpty(sysData.getUserContact()) ? "13012345678" : sysData.getUserContact().trim());

                if (StringUtils.isEmpty(sysData.getUserId()) || sysData.getUserId().length() != 18) {
                    sysData.setUserId("410183199003187055");
                }
                apiData.setSfzh(sysData.getUserId());

                //通知单号
                apiData.setCktzdh(sysData.getNoticeId());
                //获取合同号
                listInoutNotice = fzzySyncNoticeOutRep.listInoutNoticeOutById(sysData.getNoticeId());
                if (null != listInoutNotice && listInoutNotice.size() > 0) {
                    //合同号
                    if (StringUtils.isNotEmpty(listInoutNotice.get(0).getContractId())) {
                        List<Api1201> api1201List = api1201Rep.getDataByBizId(listInoutNotice.get(0).getContractId());
                        if (null != api1201List && api1201List.size() > 0) {
                            apiData.setHth(api1201List.get(0).getHth());
                        }
                    }
                    if (StringUtils.isNotEmpty(listInoutNotice.get(0).getPlanId())) {
                        List<Api1404> api1404List = api1404Rep.getDataByBizIdAndKqdm(listInoutNotice.get(0).getPlanId(), kqdm);
                        if (null != api1404List && api1404List.size() > 0) {
                            apiData.setJhmxh(api1404List.get(0).getJhmxdh());
                            if (StringUtils.isEmpty(sysData.getFoodYear())) {
                                sysData.setFoodYear(api1404List.get(0).getShnd());
                            }
                        }
                    }
                }

                //运输工具，若为空，则默认给1-汽车
                apiData.setYsgj(StringUtils.isEmpty(sysData.getTransType()) ? "1" : sysData.getTransType());

                //车船号
                apiData.setCch(sysData.getPlateNum());
                apiData.setDjsj(sysData.getRegisterTime());

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

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

                //质检报告单号
                List<Api1310> dataByHwdm = api1310Rep.getDataByHwdm(apiData.getHwdm(), "02");
                if (null != dataByHwdm && dataByHwdm.size() > 0) {
                    apiData.setZjbgdh(dataByHwdm.get(0).getZjbgdh());
                }

                //生成方式
                apiData.setScfs(1);
                if (StringUtils.isNotEmpty(sysData.getRecordStatus()) && sysData.getRecordStatus().equals("ADD")) {
                    apiData.setScfs(2);
                    apiData.setSdblyy("库区停电导致无法按流程进行出库");
                }

                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType());
                apiData.setLsxzdm(mappingCode);

                apiData.setShnd(StringUtils.isEmpty(sysData.getFoodYear()) ? DateFormatUtils.format(sysData.getRegisterTime(), "yyyy") : sysData.getFoodYear());

                //产地代码
                mappingCode = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation());
                if (StringUtils.isEmpty(mappingCode)) {
                    mappingCode = apiData.getHwdm().substring(2, 8);
                }
                apiData.setCddm(mappingCode);

                //皮重信息
                apiData.setPz(sysData.getEmptyWeight());
                if (null == sysData.getEmptyWeightTime()) {
                    sysData.setEmptyWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 25));
                }
                if (!sysData.getEmptyWeightTime().after(sysData.getRegisterTime())) {
                    sysData.setEmptyWeightTime(DateUtils.addMinutes(sysData.getRegisterTime(), 25));
                }
                apiData.setPzjlsj(sysData.getEmptyWeightTime());
                apiData.setPzjby(StringUtils.isEmpty(sysData.getEmptyWeightUser()) ? "监磅员" : sysData.getEmptyWeightUser());
                apiData.setPzjly(StringUtils.isEmpty(sysData.getEmptyWeightUser()) ? "计量员" : sysData.getEmptyWeightUser());

                //毛重信息
                apiData.setMz(sysData.getFullWeight());
                apiData.setKzl(0 - sysData.getDeCheck() + sysData.getAddCheck() - sysData.getDeHandle() - sysData.getDePackage() - sysData.getDeOther());
                if (null == sysData.getFullWeightTime()) {
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getEmptyWeightTime(), 60));
                }
                if (!sysData.getFullWeightTime().after(sysData.getEmptyWeightTime())) {
                    sysData.setFullWeightTime(DateUtils.addMinutes(sysData.getEmptyWeightTime(), 60));
                }
                apiData.setMzjlsj(sysData.getFullWeightTime());
                apiData.setMzjby(StringUtils.isEmpty(sysData.getFullWeightUser()) ? "监磅员" : sysData.getFullWeightUser());
                apiData.setMzjly(StringUtils.isEmpty(sysData.getFullWeightUser()) ? "计量员" : sysData.getFullWeightUser());

                //净重
                apiData.setJz(sysData.getRecordWeight());
                if (!sysData.getCompleteTime().after(sysData.getFullWeightTime())) {
                    sysData.setCompleteTime(DateUtils.addMinutes(sysData.getFullWeightTime(), 10));
                }
                apiData.setCmsj(sysData.getCompleteTime());
                //结算单号
                if (StringUtils.isNotEmpty(sysData.getSettleId())) {
                    apiData.setCkjsdh(kqdm + sysData.getSettleId());
                }
                if (StringUtils.isNotEmpty(apiData.getHth())) {
                    api1206List = api1206Rep.getDataByHthAndHwdm(apiData.getHth(), apiData.getHwdm());
                    if (null == api1206List || api1206List.isEmpty()) {
                        api1206List = api1206Rep.getDataByHth(apiData.getHth());
                        if (null != api1206List && api1206List.size() > 0) {
                            apiData.setCkjsdh(api1206List.get(0).getCkjsdh());
                        }
                    } else {
                        apiData.setCkjsdh(api1206List.get(0).getCkjsdh());
                    }
                }

                apiData.setCchlx("01");
                apiData.setXldd("库内");
                apiData.setBz(StringUtils.isEmpty(sysData.getRemarks()) ? "暂无备注信息" : sysData.getRemarks());
                apiData.setBzbdbz(sysData.getDbz() == null ? 25 : sysData.getDbz());
                apiData.setBzbjs(sysData.getBzbjs());
                apiData.setJjlx(sysData.getJjlx());
                apiData.setBzw(StringUtils.isEmpty(sysData.getBzw()) ? "9" : sysData.getBzw());
                apiData.setCmqrmgryxm(StringUtils.isEmpty(sysData.getRegisterUser()) ? "门岗人" : sysData.getRegisterUser());
                apiData.setDjmgryxm(StringUtils.isEmpty(sysData.getRegisterUser()) ? "登记人" : sysData.getRegisterUser());
                apiData.setZcbgyxm(StringUtils.isEmpty(sysData.getHandleUser()) ? "值仓员" : sysData.getHandleUser());
                apiData.setZxzydw("外聘单位");
                apiData.setKzlyy("扣（增）量原因");

                //操作标志及最后更新时间
                apiData.setZhgxsj(sysData.getUpdateTime());

                //承运人 èº«ä»½è¯å· ç”µè¯
                apiData.setSfzh(sysData.getUserId());
                apiData.setCyr(sysData.getUserName().trim());
                apiData.setLxdh(sysData.getUserContact());


                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                log.info("1205出库信息---同步数据：{}", apiData.toString());
                api1205List = api1205Rep.getDataById(apiData.getCkywdh());
                if (null == api1205List || api1205List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1205List.get(0).getCzbz());
                }
                //判断是否为船运
                if (StringUtils.isNotEmpty(sysData.getTransType()) && sysData.getTransType().equals("3")) {
                    listInoutRecordItem = fzzy61SyncInoutRecordItemRep.findDataByRecordId(sysData.getId());
                    if (null == listInoutRecordItem || listInoutRecordItem.isEmpty()) {
                        api1205Rep.save(apiData);
                        continue;
                    }

                    int idNum = Integer.valueOf(sysData.getId().substring(12)) * 100 + 10001;
                    for (Fz61InoutRecordItem fz61InoutRecordItem : listInoutRecordItem) {
                        if ("DEL".equals(fz61InoutRecordItem.getRecordStatus())) {
                            continue;
                        }
                        if (fz61InoutRecordItem.getSettleWeight() <= 0) {
                            continue;
                        }
                        apiData.setCkywdh(Constant.INOUT_TYPE_15 + sysData.getId().substring(4, 10) + String.valueOf(idNum).substring(1));
                        apiData.setMz(fz61InoutRecordItem.getFullWeight());
                        apiData.setPz(fz61InoutRecordItem.getEmptyWeight());
                        apiData.setJz(fz61InoutRecordItem.getSettleWeight());
                        apiData.setMzjlsj(fz61InoutRecordItem.getFullWeightTime());
                        apiData.setPzjlsj(fz61InoutRecordItem.getEmptyWeightTime());
                        apiData.setKzl(0 - fz61InoutRecordItem.getDe());
                        api1205List = api1205Rep.getDataById(apiData.getCkywdh());
                        if (null == api1205List || api1205List.isEmpty()) {
                            apiData.setCzbz(Constant.CZBZ_I);
                        } else {
                            apiData.setCzbz(api1205List.get(0).getCzbz());
                        }
                        api1205Rep.save(apiData);
                        idNum++;
                    }
                } else {
                    //保存数据
                    api1205Rep.save(apiData);
                }
            }
        } catch (Exception e) {
            log.error("---1205出库信息同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1206.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1206;
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.Api1206Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutSettle;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1204Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * ç²®é£Ÿå‡ºåº“结算
 */
@Slf4j
@Component
public class Fzzy61Sync1206 {

    /**
     * å‡ºåº“类型
     */
    private final static String INOUT_TYPE_OUT = "OUT";

    @Autowired
    private Fzzy61Sync1204Rep fzzySync1204Rep;
    @Autowired
    private Api1206Rep api1206Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private ApiCommonService commonService;

    /**
     * ç²®é£Ÿå‡ºåº“结算
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1206出库结算接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1206);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食出库结算信息
            List<Fz61InoutSettle> list = fzzySync1204Rep.listInoutSettle(deptId, INOUT_TYPE_OUT, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食出库结算信息------------------");
                return;
            }

            //根据库区代码获取库区信息
            Api1102 api1102 = api1102Rep.findById(kqdm).get();

            Api1206 apiData;
            Api1105 api1105;
            List<Api1206> api1206List;
            for (Fz61InoutSettle sysData : list) {

                apiData = new Api1206();
                //入库结算单号:库区代码 + yyyyMMdd + 4为顺序号
                apiData.setCkjsdh(kqdm + sysData.getId());

                //合同号
                if (StringUtils.isNotEmpty(sysData.getContractId())) {
                    apiData.setHth(api1102.getDwdm() + sysData.getContractId());
                }

                if (StringUtils.isNotEmpty(sysData.getDepotId())) {
                    api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                    //货位代码
                    apiData.setHwdm(api1105.getHwdm());
                }

                //结算重量、结算单价、结算金额、结算时间
                apiData.setJssl(sysData.getSettleWeight());
                apiData.setJsdj(sysData.getPayPrice());
                apiData.setJsje(sysData.getPayMoney());
                apiData.setJssj(sysData.getPayTime());

                //结算方式
                apiData.setJsfs(sysData.getPayType());
                apiData.setYhhbdm(sysData.getBankCategory());
                apiData.setKhhh(sysData.getBankCode());
                apiData.setKhhmc(sysData.getBank());
                apiData.setYhzh(sysData.getBankNum());
                apiData.setFkr(StringUtils.isEmpty(sysData.getPayUser()) ? "付款人" : sysData.getPayUser());
                apiData.setFphm("");
                apiData.setFpzt("");

                //操作标志及最后更新时间
                apiData.setZhgxsj(new Date());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                log.info("1206出库结算---同步数据：{}", apiData.toString());

                api1206List = api1206Rep.getDataById(apiData.getCkjsdh());
                if (null == api1206List || api1206List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1206List.get(0).getCzbz());
                }
                //保存数据
                api1206Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---1206出库结算数据同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1207.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1207;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1207Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutStockChange;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1207Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * å€’仓信息
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1207 {

    @Autowired
    private Fzzy61Sync1207Rep fzzySync1207Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1207Rep api1207Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * å€’仓信息同步
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1207倒仓接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1207);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());

        try {
            List<Fz61InoutStockChange> list = fzzySync1207Rep.listStockChange(deptId, start, end);
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到倒仓信息------------------");
                return;
            }

            Api1207 apiData;
            Api1105 api1105In;
            Api1105 api1105Out;
            List<Api1207> api1207List;
            for (Fz61InoutStockChange sysData : list) {
                //获取货位信息
                api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
                if (null == api1105Out) {
                    continue;
                }
                //获取货位信息
                api1105In = commonService.getApi1105Cache(sysData.getDepotIdIn());
                if (null == api1105In) {
                    continue;
                }
                apiData = new Api1207();
                apiData.setDcdh(kqdm + sysData.getId());
                apiData.setDclx(sysData.getType());
                apiData.setDcjhwjbh(sysData.getPlanCode());
                apiData.setTzdh(sysData.getNoticeId());
                apiData.setDcdw(kqdm);
                apiData.setDrdw(kqdm);
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);
                apiData.setDchwdm(api1105Out.getHwdm());
                apiData.setDrhwdm(api1105In.getHwdm());
                apiData.setDcrq(sysData.getChangeDate());
                apiData.setDcksrq(sysData.getChangeStartDate());
                apiData.setDcjsrq(sysData.getChangeEndDate());
                apiData.setDcsl(sysData.getNumber());
                apiData.setBzw(sysData.getBzw());
                apiData.setBzbjs(sysData.getBzbjs());
                apiData.setZxzydw(sysData.getZxzydw());
                apiData.setZhgxsj(sysData.getUpdateTime());

                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());

                api1207List = api1207Rep.getDataById(apiData.getDcdh());
                if (null == api1207List || api1207List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1207List.get(0).getCzbz());
                }

                //保存数据
                api1207Rep.save(apiData);
                log.info("1207---同步数据：{}", apiData.toString());
            }

        } catch (Exception e) {
            log.error("---1207倒仓信息同步失败----{}", e.toString());
            apiLog.setResult("倒仓信息同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1208.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,213 @@
package com.fzzy.async.fzzy61.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.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1208Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61DepotStore;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1208Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * ç²®é£Ÿåº“å­˜
 */
@Slf4j
@Component
public class Fzzy61Sync1208 {

    @Autowired
    private Fzzy61Sync1208Rep fzzySync1208Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1208Rep api1208Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥ç²®é£Ÿåº“å­˜
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1208粮食库存信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1208);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DepotStore> list = fzzySync1208Rep.listDepot(deptId, start, end);

            if (null == list || list.isEmpty()) {

                log.info("-------------没有获取到粮食库存信息------------------");

                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1102 = api1102Rep.findById(kqdm).get();

            Api1208 apiData;
            Api1105 api1105;
            List<Api1208> api1208List;
            for (Fz61DepotStore fz61DepotStore : list) {

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

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

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, fz61DepotStore.getFoodVariety());
                apiData.setLspzdm(mappingCode);

                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, fz61DepotStore.getFoodType());
                apiData.setLsxzdm(mappingCode);

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

                apiData.setShnd(fz61DepotStore.getFoodYear());

                //产地代码
                mappingCode = commonService.getFoodLocationIdFromCache(fz61DepotStore.getFoodLocation());
                if (StringUtils.isEmpty(mappingCode)) {
                    mappingCode = apiData.getHwdm().substring(2, 8);
                }
                apiData.setCd(mappingCode);

                apiData.setBgy(StringUtils.isEmpty(api1105.getBgy()) ? "保管员" : api1105.getBgy());
                apiData.setLqgsdwdm(fz61DepotStore.getLqgsdwdm());
                apiData.setLqxzqhdm(api1102.getXzqhdm());
                if (apiData.getLsxzdm().equals("121")) {
                    //省级储备粮-粮权行政区划代码为省级
                    apiData.setLqxzqhdm(api1102.getXzqhdm().substring(0, 2) + "0000");
                }
                if (apiData.getLsxzdm().equals("122")) {
                    //市级储备粮-粮权行政区划代码为市级
                    apiData.setLqxzqhdm(api1102.getXzqhdm().substring(0, 4) + "00");
                }

                //粮权归属单位
                if (null == apiData.getLqgsdwdm()) {
                    api1208List = api1208Rep.findDataByHwdm(api1105.getHwdm());
                    if (null != api1208List && api1208List.size() > 0) {
                        apiData.setLqgsdwdm(api1208List.get(0).getLqgsdwdm());
                        apiData.setLqxzqhdm(api1208List.get(0).getLqxzqhdm());
                        apiData.setLqgstydwbm(api1208List.get(0).getLqgstydwbm());
                    } else {
                        apiData.setLqgsdwdm(api1102.getDwdm());
                        apiData.setLqxzqhdm(api1102.getXzqhdm());
                    }
                }


                //若为商品粮，则粮权性质区划代码为null
                if ("200".equals(apiData.getLsxzdm())) {
                    apiData.setLqxzqhdm(null);
                }

                //管理方式-默认直储
                if (StringUtils.isEmpty(fz61DepotStore.getManageType())) {
                    apiData.setGlfs("01");
                } else {
                    apiData.setGlfs(fz61DepotStore.getManageType());
                }

                //收储地点-默认库内
                apiData.setScdd("1");
                //储粮方式
                apiData.setClfs(fz61DepotStore.getStoreType());
                //包装储粮是，核查包存粮包数
                if ("2".equals(apiData.getClfs())) {
                    apiData.setBclbs((int) (fz61DepotStore.getStorageReal() / 25));
                }

                //货位状态
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_HWZT, fz61DepotStore.getDepotStatus());
                apiData.setHwzt(mappingCode);
                if (null == fz61DepotStore.getStoreDate()) {
                    fz61DepotStore.setStoreDate(new Date());
                }
                //入仓时间
                apiData.setRcsj(fz61DepotStore.getStoreDate());
                //封仓日期
                if ("3".equals(apiData.getHwzt()) || "4".equals(apiData.getHwzt())) {
                    if (null == fz61DepotStore.getFullDate()) {
                        fz61DepotStore.setFullDate(DateUtils.addDays(fz61DepotStore.getStoreDate(), 30));
                    }
                    apiData.setFcrq(fz61DepotStore.getFullDate());
                }

                if ("1".equals(apiData.getHwzt())) {
                    //出仓完成时间
                    apiData.setCcwcsj(fz61DepotStore.getOutDate());
                    //清仓时间
                    apiData.setQcsj(DateUtils.addHours(apiData.getCcwcsj(), 60));
                }
                //国别
                apiData.setGb("156");
                apiData.setSjsl(fz61DepotStore.getStorageReal());
                apiData.setJjsl(fz61DepotStore.getStorageReal());
                apiData.setSjzlxg(6);
                apiData.setLdtj(10000);

                apiData.setZhgxsj(fz61DepotStore.getUpdateDate());

                //业务id、库区编码、同步时间
                apiData.setBizId(fz61DepotStore.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());

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

                //保存数据
                api1208Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---1208粮食库存信息同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1209.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1209;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1209Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutLossOver;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1209Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
import java.util.List;

/**
 * ç²®é£ŸæŸæº¢
 */
@Slf4j
@Component
public class Fzzy61Sync1209 {

    /**
     * æŸæº¢ç±»åž‹-损耗
     */
    public static final String LOSS_OVER_LOSS = "LOSS";
    /**
     * æŸæº¢ç±»åž‹-溢出
     */
    public static final String LOSS_OVER_OVER = "OVER";

    @Autowired
    private Fzzy61Sync1209Rep fzzySync1209Rep;
    @Autowired
    private Api1209Rep api1209Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥ç²®é£ŸæŸæº¢ä¿¡æ¯
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1209接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1209);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutLossOver> list = fzzySync1209Rep.listMLossOver(deptId, start, end);

            if (null == list || list.isEmpty()) {

                log.info("-------------没有获取到粮食损溢信息------------------");

                return;
            }

            Api1209 apiData;
            Api1105 api1105;
            List<Api1209> api1209List;
            for (Fz61InoutLossOver sysData : list) {

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

                apiData = new Api1209();
                apiData.setSydh(api1105.getHwdm() + sysData.getId());
                apiData.setHwdm(api1105.getHwdm());
                apiData.setYwrq(sysData.getSubmitTime());
                apiData.setSylx(sysData.getType());
                //净重损溢数量，损耗为正，溢出为负
                apiData.setJzsysl(sysData.getAmount());
                if (LOSS_OVER_LOSS.equals(sysData.getType())) {
                    sysData.setType("2");
                }
                if (LOSS_OVER_OVER.equals(sysData.getType())) {
                    sysData.setType("3");
                    apiData.setJzsysl(0 - sysData.getAmount());
                }
                apiData.setRkjz(sysData.getRkjz());
                apiData.setCkjz(sysData.getCkjz());
                apiData.setRksj(sysData.getRksj());
                apiData.setCksj(sysData.getCksj());
                apiData.setCcsc(sysData.getCcsc());

                apiData.setRksf(sysData.getRksf());
                apiData.setRkzz(sysData.getRkzz());
                apiData.setCksf(sysData.getCksf());
                apiData.setCkzz(sysData.getCkzz());
                apiData.setQzszkl(sysData.getQzszkl());

                BigDecimal bigDecimal = BigDecimal.valueOf(sysData.getQzzrshde());
                apiData.setQzzrshde(bigDecimal.setScale(3, RoundingMode.UP).doubleValue());

                apiData.setChsl(sysData.getChsl());
                apiData.setCqqrbs(1);
                apiData.setCqqrsj(sysData.getCqqrsj() == null ? DateUtils.addSeconds(sysData.getCksj(), 120) : sysData.getCqqrsj());
                apiData.setSyhj("2");
                apiData.setSysfzc(StringUtils.isEmpty(sysData.getSysfzc()) ? "0" : sysData.getSysfzc());
                apiData.setSfch(sysData.getSfch());
                apiData.setSyyy(sysData.getSyyy());
                apiData.setCcshr(StringUtils.isEmpty(sysData.getCcshr()) ? "审核人" : sysData.getCcshr());
                apiData.setZjshr(StringUtils.isEmpty(sysData.getZjshr()) ? "审核人" : sysData.getZjshr());
                apiData.setTjshr(StringUtils.isEmpty(sysData.getTjshr()) ? "审核人" : sysData.getTjshr());
                apiData.setKjshr(StringUtils.isEmpty(sysData.getKjshr()) ? "审核人" : sysData.getKjshr());
                apiData.setLdshr(StringUtils.isEmpty(sysData.getLdshr()) ? "审核人" : sysData.getLdshr());
                apiData.setBz(StringUtils.isEmpty(sysData.getRemark()) ? "备注信息" : sysData.getRemark());


                //操作标志及最后更新时间
                apiData.setZhgxsj(new Date());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());

                api1209List = api1209Rep.getDataBySydh(apiData.getSydh());
                if (null == api1209List || api1209List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1209List.get(0).getCzbz());
                }

                //保存数据
                api1209Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---1209损溢信息同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1210.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1210;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1210Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutVarietyChange;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1210Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * æ€§è´¨è½¬å˜
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy61Sync1210 {

    @Autowired
    private Fzzy61Sync1210Rep fzzySync1210Rep;
    @Autowired
    private Api1210Rep api1210Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private ApiLogRep apiLogRep;

    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1210性质转变接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1209);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());

        try {
            List<Fz61InoutVarietyChange> list = fzzySync1210Rep.listVarietyChange(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到性质转变信息------------------");
                return;
            }

            Api1210 apiData;
            Api1105 api1105;
            List<Api1210> api1210List;
            for (Fz61InoutVarietyChange sysData : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(sysData.getDepotId());
                if (null == api1105) {
                    continue;
                }
                apiData = new Api1210();
                apiData.setLsxzzbdh(api1105.getHwdm() + sysData.getId());
                apiData.setHwdm(api1105.getHwdm());
                apiData.setLssl(sysData.getNumber());
                apiData.setHzsl(sysData.getChangeNumber());
                apiData.setBzwh(sysData.getApprovalId());
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getFoodType());
                apiData.setHzqlsxzdm(mappingCode);
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, sysData.getNewFoodType());
                apiData.setHzhlsxzdm(mappingCode);
                apiData.setHzrq(sysData.getChangeTime());
                apiData.setCcshr(StringUtils.isEmpty(sysData.getCcshr()) ? "审批人" : sysData.getCcshr());
                apiData.setZjshr(StringUtils.isEmpty(sysData.getZjshr()) ? "审批人" : sysData.getZjshr());
                apiData.setTjshr(StringUtils.isEmpty(sysData.getTjshr()) ? "审批人" : sysData.getTjshr());
                apiData.setKjshr(StringUtils.isEmpty(sysData.getKjshr()) ? "审批人" : sysData.getKjshr());
                apiData.setLdshr(StringUtils.isEmpty(sysData.getLdshr()) ? "审批人" : sysData.getLdshr());
                apiData.setBz(sysData.getRemark());
                apiData.setZhgxsj(new Date());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                api1210List = api1210Rep.getDataById(apiData.getLsxzzbdh());
                if (null == api1210List || api1210List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    if (StringUtils.isNotEmpty(api1210List.get(0).getJhmxdh())) {
                        apiData.setJhmxdh(api1210List.get(0).getJhmxdh());
                    }
                    apiData.setCzbz(api1210List.get(0).getCzbz());
                }
                //保存数据
                api1210Rep.save(apiData);

            }

        } catch (Exception e) {
            log.error("---1210性质转变同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1211.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1211;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1211Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61DepotBookStore;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1211Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * @author czt
 * è´¦é¢åº“å­˜
 */
@Slf4j
@Component
public class Fzzy61Sync1211 {

    @Autowired
    private Fzzy61Sync1211Rep fzzy61Sync1211Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1211Rep api1211Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥ç²®é£Ÿåº“å­˜
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1211账面库存接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1208);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DepotBookStore> list = fzzy61Sync1211Rep.listDepot(deptId, start, end);
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到账面库存信息------------------");
                return;
            }

            Api1211 apiData;
            Api1105 api1105;
            List<Api1211> api1211List;
            for (Fz61DepotBookStore fz61DepotBookStore : list) {

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

                apiData = new Api1211();
                apiData.setId(fz61DepotBookStore.getId());
                apiData.setBizId(fz61DepotBookStore.getId());
                apiData.setKqdm(kqdm);
                apiData.setHwdm(api1105.getHwdm());

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, fz61DepotBookStore.getLspzdm());
                apiData.setLspzdm(mappingCode);

                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, fz61DepotBookStore.getLsxzdm());
                apiData.setLsxzdm(mappingCode);
                apiData.setNd(fz61DepotBookStore.getNd());
                apiData.setYf(fz61DepotBookStore.getYf());
                apiData.setQcsl(fz61DepotBookStore.getQcsl() == null ? 0.0 : fz61DepotBookStore.getQcsl());
                apiData.setBqsrsl(fz61DepotBookStore.getBqsrsl() == null ? 0.0 : fz61DepotBookStore.getBqsrsl());
                apiData.setBqzcsl(fz61DepotBookStore.getBqzcsl() == null ? 0.0 : fz61DepotBookStore.getBqzcsl());
                apiData.setQmye(fz61DepotBookStore.getQmye() == null ? 0.0 : fz61DepotBookStore.getQmye());
                //月结标志为空则默认给0-月结
                if (null == fz61DepotBookStore.getYjbz()) {
                    fz61DepotBookStore.setYjbz(0);
                }
                apiData.setYjbz(fz61DepotBookStore.getYjbz());
                apiData.setYwrq(fz61DepotBookStore.getYwrq());
                apiData.setZhgxsj(new Date());

                api1211List = api1211Rep.getDataByBizId(apiData.getBizId());
                if (null == api1211List || api1211List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1211List.get(0).getCzbz());
                }

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

        } catch (Exception e) {
            log.error("---1211账面库存同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1212.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1212;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1101Rep;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1212Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61InoutCustomer;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1212Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * å®¢æˆ·ä¿¡æ¯æ•°æ®æŽ¥å£
 */
@Slf4j
@Component
public class Fzzy61Sync1212 {

    @Autowired
    private Fzzy61Sync1212Rep fzzySync1212Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1212Rep api1212Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å®¢æˆ·æŽ¥å£
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1212客户信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1201);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutCustomer> list = fzzySync1212Rep.listInoutCustomer(deptId, start, end);

            if (null == list || list.isEmpty()) {
                log.debug("-------------没有获取到客户信息------------------");
                return;
            }

            //根据库区代码获取单位代码
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();

            Api1212 apiData;
            List<Api1212> api1212List;
            for (Fz61InoutCustomer sysData : list) {

                apiData = new Api1212();
                //单位代码
                apiData.setId(sysData.getKhbh());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setDwmc(api1101.getDwmc());
                apiData.setKqdm(api1102.getKqdm());
                apiData.setKqmc(api1102.getKqmc());
                apiData.setKhlx(sysData.getKhlx());
                apiData.setKhtyshxydmhsfzh(sysData.getKhbh());
                apiData.setKhmc(sysData.getName());
                apiData.setFddbr(StringUtils.isEmpty(sysData.getFddbr()) ? "法人" : sysData.getFddbr());
                apiData.setTxdz(StringUtils.isEmpty(sysData.getAddress()) ? "单位地址" : sysData.getAddress());

                apiData.setLxrxm(StringUtils.isEmpty(sysData.getContactUser()) ? sysData.getFddbr() : sysData.getContactUser());
                apiData.setLxrdh(StringUtils.isEmpty(sysData.getPhone()) ? "" : sysData.getPhone());
                if (StringUtils.isNotEmpty(sysData.getCardId())) {
                    apiData.setLxrsfzh(sysData.getCardId());
                }
                apiData.setYzbm(StringUtils.isEmpty(sysData.getYzbm()) ? "000000" : sysData.getYzbm());
                apiData.setDzyx(StringUtils.isEmpty(sysData.getDzyx()) ? "" : sysData.getDzyx());
                apiData.setKhfkhh(StringUtils.isEmpty(sysData.getBank()) ? "999" : sysData.getBank());
                apiData.setKhfzh(StringUtils.isEmpty(sysData.getBankNum()) ? "" : sysData.getBankNum());
                apiData.setZhgxsj(sysData.getUpdateTime() == null ? new Date() : sysData.getUpdateTime());
                apiData.setBizId(sysData.getId());


                api1212List = api1212Rep.getDataById(apiData.getId());
                if (null == api1212List || api1212List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1212List.get(0).getCzbz());
                }

                //保存数据
                api1212Rep.save(apiData);

                log.info("1212合同信息---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---1212合同信息同步执行失败----{}", e.toString());
            apiLog.setResult("同步合同信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync1213.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1213;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1213Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy61.entity.Fz61DepotStatusConfirm;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1213Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * @author czt
 * å°ä»“确认单
 */
@Slf4j
@Component
public class Fzzy61Sync1213 {

    @Autowired
    private Fzzy61Sync1213Rep fzzy61Sync1213Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1213Rep api1213Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å°ä»“确认信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        log.info("-------------1213封仓确认信息接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1208);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61DepotStatusConfirm> list = fzzy61Sync1213Rep.listData(deptId, start, end);
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到封仓确认信息------------------");
                return;
            }

            Api1213 apiData;
            Api1105 api1105;
            List<Api1213> api1213List;
            for (Fz61DepotStatusConfirm depotStatusConfirm : list) {

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

                apiData = new Api1213();
                BeanUtils.copyProperties(depotStatusConfirm, apiData);
                apiData.setFcqrdh(depotStatusConfirm.getFcqrdh());
                apiData.setBizId(depotStatusConfirm.getFcqrdh());
                apiData.setKqdm(kqdm);
                apiData.setHwdm(api1105.getHwdm());

                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, depotStatusConfirm.getFoodVariety().substring(0, 3));
                apiData.setLspzdm(mappingCode);

                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, depotStatusConfirm.getFoodType());
                apiData.setLsxzdm(mappingCode);
                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, depotStatusConfirm.getFoodLevel());
                apiData.setLsdjdm(mappingCode);
                //产地代码
                mappingCode = commonService.getFoodLocationIdFromCache(depotStatusConfirm.getFoodLocation());
                if (StringUtils.isEmpty(mappingCode)) {
                    mappingCode = apiData.getHwdm().substring(2, 8);
                }
                apiData.setCd(mappingCode);
                //年度
                apiData.setShnd(depotStatusConfirm.getFoodYear());
                if (StringUtils.isEmpty(depotStatusConfirm.getCountry())) {
                    apiData.setGb("156");
                }
                apiData.setBgy(depotStatusConfirm.getStoreKeeperName());
                apiData.setFcsqr(depotStatusConfirm.getApplyUser());
                apiData.setBmshr(depotStatusConfirm.getDeptAuditUser());
                apiData.setLdshr(depotStatusConfirm.getLeaderAuditUser());
                apiData.setZhgxsj(new Date());

                api1213List = api1213Rep.getDataById(apiData.getBizId());
                if (null == api1213List || api1213List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1213List.get(0).getCzbz());
                }

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

        } catch (Exception e) {
            log.error("---1213封仓确认信息同步失败----{}", e.toString());
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/impl/Fzzy61Sync2102.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,136 @@
package com.fzzy.async.fzzy61.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.fzzy61.entity.Fz61InoutStockChange;
import com.fzzy.async.fzzy61.repository.Fzzy61Sync1207Rep;
import com.fzzy.push.sh2023.SH2023Constant;
import com.fzzy.push.sh2023.dto.SH2023Api2102;
import com.fzzy.push.sh2023.dto.ShAreaBjw;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * å€’仓倒入
 *
 * @author czt
 */
@Slf4j
@Component
public class Fzzy61Sync2102 {

    @Autowired
    private Fzzy61Sync1207Rep fzzySync1207Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiInfoDataRep apiInfoDataRep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * å€’仓倒入信息同步
     *
     * @param kqdm
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------2101接口数据开始同步------------------");

        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(SH2023Constant.SH_2023_API_CODE_2101);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz61InoutStockChange> list = fzzySync1207Rep.listStockChange(deptId, start, end);
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到倒仓倒入信息------------------");
                return;
            }

            SH2023Api2102 apiData;
            Api1105 api1105;
            List<ApiInfoData> apiInfoDataList;
            List<Api1102> api1102List = api1102Rep.findPushData(kqdm);
            String bjw = "";
            if (null != api1102List && api1102List.size() > 0) {
                bjw = ShAreaBjw.getBjw(api1102List.get(0).getXzqhdm());
            }
            Api1105 api1105In;
            Api1105 api1105Out;
            for (Fz61InoutStockChange sysData : list) {
                //获取货位信息
                api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
                if (null == api1105Out) {
                    continue;
                }
                //获取货位信息
                api1105In = commonService.getApi1105Cache(sysData.getDepotIdIn());
                if (null == api1105In) {
                    continue;
                }
                apiData = new SH2023Api2102();
                apiData.setDrdh(kqdm + sysData.getId());
                apiData.setDrdw(kqdm);
                apiData.setDrhwdm(api1105In.getHwdm());
                apiData.setDrhwsl(sysData.getNumber());
                apiData.setDcrq(sysData.getChangeDate());
                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBjw(bjw);


                //持久化保存，单独存入非国标接口表
                ApiInfoData infoData = new ApiInfoData();
                infoData.setId(ContextUtil.getUUID());
                infoData.setKqdm(kqdm);
                infoData.setInteType(Constant.API_CATEGORY_12);
                infoData.setInteId(SH2023Constant.SH_2023_API_CODE_2102);
                infoData.setUpdateTime(new Date());
                infoData.setDataId(apiData.getDrdh());
                infoData.setRemarks("倒仓倒入");

                //设置操作标志
                apiInfoDataList = apiInfoDataRep.getDataByInteAndData(SH2023Constant.SH_2023_API_CODE_2101, infoData.getDataId(), kqdm);
                if (null == apiInfoDataList || apiInfoDataList.isEmpty()) {
                    infoData.setCzbz(Constant.CZBZ_I);
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    infoData.setCzbz(apiInfoDataList.get(0).getCzbz());
                    apiData.setCzbz(apiInfoDataList.get(0).getCzbz());
                }

                infoData.setData(JSON.toJSONString(apiData));
                apiInfoDataRep.save(infoData);

                log.info("2102---倒仓倒入-同步数据：{}", apiData);

            }

        } catch (Exception e) {
            log.error("---倒仓倒入同步执行失败----{}", e.toString());
            apiLog.setResult("倒仓倒入失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1107Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61DeptDevice;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1107Rep extends JpaRepository<Fz61DeptDevice, String> {
    @Query("from Fz61DeptDevice where deptId =:deptId order by sbbh")
    List<Fz61DeptDevice> listDevice(@Param("deptId") String deptId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1108Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61Drug;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * è¯å‰‚信息
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1108Rep extends JpaRepository<Fz61Drug, String> {

    @Query("from Fz61Drug where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61Drug> listDrug(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1109Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61FileInfo;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * @Author:YAN
 */
public interface Fzzy61Sync1109Rep extends JpaRepository<Fz61FileInfo, String> {
    /**
     * æ ¹æ®ä¿¡æ¯æ–‡ä»¶ä¿¡æ¯
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61FileInfo where createTime >=:start and createTime <:end order by createTime ")
    List<Fz61FileInfo> listFileInfo(@Param("start") Date start, @Param("end") Date end);

    @Query("from Fz61FileInfo where bizId =:bizId order by createTime ")
    List<Fz61FileInfo> listFileInfoByBizId(@Param("bizId") String bizId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1111Rep.java

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

import com.fzzy.async.fzzy40.entity.Fz40SecCamera;
import com.fzzy.async.fzzy61.entity.Fz61SecCamera;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * ç›‘控信息
 */
public interface Fzzy61Sync1111Rep extends JpaRepository<Fz61SecCamera, String> {

    /**
     * èŽ·å–摄像头信息
     *
     * @return
     */
    @Query("from Fz61SecCamera where deptId=:deptId and updateTime >=:start and updateTime <:end order by ip ")
    List<Fz61SecCamera> listCamera(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1112Rep.java

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

import com.fzzy.async.fzzy40.entity.Fz40OAStaff;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

import java.util.List;

/**
 * äººå‘˜ä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1112Rep extends JpaRepository<Fz40OAStaff, String> {
//    @Query("from Fz40OAStaff where companyId=:companyId order by sfzhm")
//    List<Fz40OAStaff> listStaff(@Param("companyId") String companyId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1201Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutContract;
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;

/**
 * ç²®é£Ÿè´­é”€-合同信息数据接口数据获取
 */
public interface Fzzy61Sync1201Rep extends JpaRepository<Fz61InoutContract, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–合同信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutContract where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61InoutContract> listContract(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1202Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutRecord;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * ç²®é£Ÿå‡ºå…¥åº“信息
 *
 * @author chen
 * @date 2022-09-23 17:10
 */
public interface Fzzy61Sync1202Rep extends JpaRepository<Fz61InoutRecord, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–出入库信息
     *
     * @param deptId
     * @param type
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <=:end order by id ")
    List<Fz61InoutRecord> listInoutRecord(@Param("deptId") String deptId, @Param("type") String type, @Param("start") Date start, @Param("end") Date end);

    /**
     * æ ¹æ®id获取粮食出入库信息
     *
     * @param id
     * @return
     */
    @Query("from Fz61InoutRecord where id=:id order by updateTime ")
    List<Fz61InoutRecord> listInoutRecordById(@Param("id") String id);


    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–出入库信息
     *
     * @param deptId
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutRecord where deptId=:deptId and updateTime >=:start and updateTime <:end order by id ")
    List<Fz61InoutRecord> listInoutRecord(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);


    @Query("from Fz61InoutRecord where deptId=:deptId and (type=:type1 or type=:type2) and updateTime >=:start and updateTime <=:end order by id ")
    List<Fz61InoutRecord> listInAndOutRecord(@Param("deptId") String deptId, @Param("type1") String type1, @Param("type2") String type2, @Param("start") Date start, @Param("end") Date end);


}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1203Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61CheckItem;
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;

/**
 * ç²®é£Ÿå…¥åº“质检
 */
public interface Fzzy61Sync1203Rep extends JpaRepository<Fz61CheckItem, String> {

    /**
     * æ ¹æ®å…¥åº“检验编码获取检验信息
     *
     * @param checkId
     * @return
     */
    @Query("from Fz61CheckItem where checkId=:checkId and companyId=:companyId order by standardId")
    List<Fz61CheckItem> listInoutCheckItem(@Param("checkId") String checkId, @Param("companyId") String companyId);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1204Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutSettle;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * ç²®é£Ÿå…¥åº“结算信息
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1204Rep extends JpaRepository<Fz61InoutSettle, String> {
    /**
     * èŽ·å–出入库结算信息
     *
     * @param type
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutSettle where deptId=:deptId and inoutType=:type and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61InoutSettle> listInoutSettle(@Param("deptId") String deptId, @Param("type") String type, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1207Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutStockChange;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * å€’仓
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1207Rep extends JpaRepository<Fz61InoutStockChange, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–倒仓信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutStockChange where deptId=:deptId and updateTime >=:start and updateTime <:end order by changeDate ")
    List<Fz61InoutStockChange> listStockChange(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1208Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61DepotStore;
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;

/**
 * ç²®é£Ÿè´­é”€-粮食库存
 */
public interface Fzzy61Sync1208Rep extends JpaRepository<Fz61DepotStore, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–仓库信息
     *
     * @return
     */
    @Query("from Fz61DepotStore where deptId=:deptId and updateDate >=:start and updateDate <:end order by updateDate ")
    List<Fz61DepotStore> listDepot(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1209Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutLossOver;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * æŸæº¢ä¿¡æ¯
 *
 * @Author:YAN
 */
public interface Fzzy61Sync1209Rep extends JpaRepository<Fz61InoutLossOver, String> {
    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–损溢信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz61InoutLossOver where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61InoutLossOver> listMLossOver(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1210Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutVarietyChange;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;

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

/**
 * @Author:YAN
 */
public interface Fzzy61Sync1210Rep extends JpaRepository<Fz61InoutVarietyChange, String> {
    @Query("from Fz61InoutVarietyChange where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61InoutVarietyChange> listVarietyChange(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1211Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61DepotBookStore;
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;

/**
 * ç²®é£Ÿè´­é”€-账面库存
 */
public interface Fzzy61Sync1211Rep extends JpaRepository<Fz61DepotBookStore, String> {

    /**
     * æ ¹æ®åº“区编码及时间获取账面库存信息
     *
     * @return
     */
    @Query("from Fz61DepotBookStore where deptId=:deptId and zhgxsj >=:start and zhgxsj <:end order by zhgxsj ")
    List<Fz61DepotBookStore> listDepot(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1212Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutCustomer;
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;

/**
 * ç²®é£Ÿè´­é”€-客户信息数据接口数据获取
 */
public interface Fzzy61Sync1212Rep extends JpaRepository<Fz61InoutCustomer, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–客户单位信息
     *
     * @return
     */
    @Query("from Fz61InoutCustomer where deptId=:deptId order by id ")
    List<Fz61InoutCustomer> listInoutCustomer(@Param("deptId") String deptId);

    @Query("from Fz61InoutCustomer where deptId=:deptId and updateTime >=:start and updateTime <=:end order by id ")
    List<Fz61InoutCustomer> listInoutCustomer(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);

    @Query("from Fz61InoutCustomer where id=:id order by id ")
    List<Fz61InoutCustomer> getDataById(@Param("id") String id);
}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61Sync1213Rep.java

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

import com.fzzy.async.fzzy61.entity.Fz61DepotStatusConfirm;
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;

/**
 * ç²®é£Ÿè´­é”€-账面库存
 */
public interface Fzzy61Sync1213Rep extends JpaRepository<Fz61DepotStatusConfirm, String> {

    /**
     * æ ¹æ®åº“区编码及时间获取账面库存信息
     *
     * @return
     */
    @Query("from Fz61DepotStatusConfirm where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz61DepotStatusConfirm> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncInoutRecordItemRep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutRecordItem;
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 Fzzy61SyncInoutRecordItemRep extends JpaRepository<Fz61InoutRecordItem, String> {

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

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncNoticeInRep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutNoticeIn;
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-04-06 10:10
 */
public interface Fzzy61SyncNoticeInRep extends JpaRepository<Fz61InoutNoticeIn, String> {


    /**
     * æ ¹æ®id获取入库通知单信息
     * @param id
     * @return
     */
    @Query("from Fz61InoutNoticeIn where id=:id ")
    List<Fz61InoutNoticeIn> listInoutNoticeInById(@Param("id") String id);

}

 src/main/java/com/fzzy/async/fzzy61/repository/Fzzy61SyncNoticeOutRep.java

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

import com.fzzy.async.fzzy61.entity.Fz61InoutNoticeOut;
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-04-06 10:10
 */
public interface Fzzy61SyncNoticeOutRep extends JpaRepository<Fz61InoutNoticeOut, String> {


    /**
     * æ ¹æ®id获取出库通知单信息
     * @param id
     * @return
     */
    @Query("from Fz61InoutNoticeOut where id=:id ")
    List<Fz61InoutNoticeOut> listInoutNoticeOutById(@Param("id") String id);

}