基本信息，粮食购销同步

YYC

2023-08-17 9a29c498c851a412f5f64e6b0a293f27ed469702

基本信息，粮食购销同步

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

@@ -2,6 +2,7 @@

import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonIgnore;

import lombok.Data;
@@ -17,14 +18,14 @@
@Data
@Entity
@Table(name = "API_1108")
public class Api1108  implements Serializable {
public class Api1108 implements Serializable {

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

    @Id
    @Id
    @Column(name = "ID_", length = 40)
    @JsonIgnore
    private String id;
@@ -92,7 +93,8 @@

    @PropertyDef(label = "保质期")
    @Column(name = "bzq", length = 20)
    private String bzq;
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date bzq;

    @PropertyDef(label = "采购日期")
    @JSONField(format = "yyyy-MM-dd")
@@ -103,6 +105,10 @@
    @Column(name = "kcsl", precision = 20, scale = 6)
    private Double kcsl;

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

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

@@ -3,19 +3,21 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService11;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1107;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1108;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1111;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1112;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;


/**
 * @Desc: åŸºç¡€ä¿¡æ¯åŒæ­¥
 *
 * @author: czt
 * @update-time: 2023/08/14
 *
 */
@Slf4j
@Component
@@ -24,6 +26,12 @@

    @Autowired
    private Fzzy40Sync1111 fzzy40Sync1111;
    @Autowired
    private Fzzy40Sync1107 fzzy40Sync1107;
    @Autowired
    private Fzzy40Sync1108 fzzy40Sync1108;
    @Autowired
    private Fzzy40Sync1112 fzzy40Sync1112;

    @Override
    public String getProtocol() {
@@ -43,12 +51,12 @@
        //监控点位信息同步
        fzzy40Sync1111.syncData(kqdm, deptId, start, end);

        //药剂信息同步  TODO

        //设备信息同步  TODO

        //人员信息同步  TODO

        //药剂信息同步
        fzzy40Sync1108.syncData(kqdm, deptId, start, end);
        //设备信息同步
        fzzy40Sync1107.syncData(kqdm, deptId, start, end);
        //人员信息同步
        fzzy40Sync1112.syncData(kqdm, deptId, start, end);
        //企业信用信息同步--暂不执行
    }


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

@@ -8,6 +8,7 @@
import com.fzzy.async.fzzy40.impl.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Date;

/**
@@ -30,6 +31,12 @@
    private Fzzy40Sync1208 fzzySync1208;
    @Autowired
    private Fzzy40Sync1203 fzzySync1203;
    @Autowired
    private Fzzy40Sync1204 fzzySync1204;
    @Autowired
    private Fzzy40Sync1206 fzzySync1206;
    @Autowired
    private Fzzy40Sync1209 fzzySync1209;

    @Override
    public String getProtocol() {
@@ -53,18 +60,18 @@
        //粮食入库同步
        fzzySync1202.syncData(kqdm, deptId, start, end);

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

        //粮食入库结算  TODO

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

        //粮食出库结算   TODO

        //粮食损益  TODO

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



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

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

    private static final long serialVersionUID = 1L;
    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "ID")
    private String id;

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

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

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

    @Column(name = "kqmc", length = 256)
    @PropertyDef(label = "库区名称")
    private String kqmc;

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

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

    @Column(name = "sbyqdm", length = 8)
    @PropertyDef(label = "设备仪器代码")
    private String sbyqdm;

    @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 = "设备状态")
    private String sbzt;

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

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

    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "更新时间")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date updateTime;

}

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

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

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

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

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

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "药剂编号", description = "库区代码+三位顺序号")
    private String id;

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

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

    @Column(name = "DEPT_NAME_", length = 256)
    @PropertyDef(label = "库区名称")
    private String deptName;

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

    @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 = 20)
    @PropertyDef(label = "保质期")
    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
    private Date bzq;

//    @Column(name = "SPEC_", length = 50)
//    @PropertyDef(label = "规格说明")
//    private String spec;

    @Column(name = "DOSAGE_", length = 20)
    @PropertyDef(label = "剂型")
    private String dosage;

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

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


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

}

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

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

import lombok.AllArgsConstructor;
import lombok.Data;

import java.io.Serializable;
import java.util.Date;

@Data
@AllArgsConstructor
public class Fz40DrugKey implements Serializable {
    private String id;
    private String deptId;
    private Date cgrq;

    public Fz40DrugKey() {
        super();
    }
}

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

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

    private static final long serialVersionUID = 1L;

    @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 = "TYPE_", length = 10)
    @PropertyDef(label = "类型", description = "损耗/溢出")
    private String type;

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

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

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

    @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 = "AMOUNT_")
    @PropertyDef(label = "重量", description = "损溢数量KG；损耗为正数，溢余为负数")
    private Double amount;


    @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 = "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/fzzy40/entity/Fz40InoutSettle.java

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

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

    @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 = 20)
    @PropertyDef(label = "开户行号")
    private String bankCode;

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

    @Column(name = "BANK_NUM_", length = 20)
    @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 = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;

}

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

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

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

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

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

    /**
     * å€’仓单号
     */
    @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 = "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/fzzy40/entity/Fz40OAStaff.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,132 @@
package com.fzzy.async.fzzy40.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 Fz40OAStaff implements Serializable {
    private static final long serialVersionUID = 1L;
    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "ID")
    private String id;

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

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

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

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

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

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

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

    @Column(name = "sfzhm", length = 18)
    @PropertyDef(label = "身份证号码")
    private String sfzhm;

    @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/fzzy40/impl/Fzzy40Sync1107.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
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.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.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * è®¾å¤‡ä¿¡æ¯
 *
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy40Sync1107 {
    @Autowired
    private Fzzy40Sync1107Rep fzzy40Sync1107Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1101Rep api1101Rep;
    @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.listDecixe(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到设备信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();
            Api1107 apiData;

            for (Fz40DeptDevice sysData : list) {
                apiData = new Api1107();

                apiData.setBizId(sysData.getId());
                apiData.setSbbh(sysData.getSbbh());
                apiData.setDwdm(api1101.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setSbyqmc(sysData.getSbyqmc());
                apiData.setSbyqdm(sysData.getSbyqdm());
                apiData.setSbggxh(sysData.getSbggxh());
                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.setCzbz(Constant.CZBZ_I);
                apiData.setZhgxsj(sysData.getUpdateTime());

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

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

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
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.Api1101Rep;
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 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 Fzzy40Sync1108 {

    @Autowired
    private Fzzy40Sync1108Rep fzzy40Sync1108Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
    private Api1101Rep api1101Rep;
    @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<Fz40Drug> list = fzzy40Sync1108Rep.listDrug(deptId);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到药剂信息------------------");
                return;
            }
            Api1102 api1102 = api1102Rep.findById(kqdm).get();
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();
            Api1108 apiData;
            for (Fz40Drug sysData : list) {

                apiData = new Api1108();
                apiData.setId(ContextUtil.getUUID());//ID
                apiData.setBizId(sysData.getId());//业务id
                apiData.setDwdm(api1101.getDwdm());//单位代码
                apiData.setKqdm(api1102.getKqdm());//库区代码
                apiData.setKqmc(api1102.getKqmc());//库区名称
                apiData.setYjbh(sysData.getId());//药剂编号
                apiData.setYjmc(sysData.getName());//药剂名称
                apiData.setBzw(sysData.getBzw());//包装物
                apiData.setGgxh(sysData.getGgxh());//型号规格
                apiData.setAqsysms(sysData.getAqsysms());//安全使用说明书
                apiData.setSccj(sysData.getSccj());//生产厂家
                apiData.setCgly(sysData.getCgly());//采购来源
                apiData.setCctj(sysData.getCctj());//存储条件
                apiData.setCcdd(sysData.getCcdd());//储存地点
                apiData.setBzwclfs(sysData.getBzwclfs());//包装物处理方式
                apiData.setCzclfs(sysData.getCzclfs());//残渣处理方式
                apiData.setBzq(sysData.getBzq());//保质期
                apiData.setCgrq(sysData.getCgrq());//采购日期
                apiData.setKcsl(sysData.getCount());//库存数量
                apiData.setKcsldw(sysData.getKcsldw());//库存数量单位
                apiData.setCzbz(Constant.CZBZ_I);//操作标志
                apiData.setZhgxsj(sysData.getUpdateTime());//最后更新时间

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

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

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,111 @@
package com.fzzy.async.fzzy40.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.*;
import com.fzzy.async.fzzy40.entity.Fz40OAStaff;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1112Rep;
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 Fzzy40Sync1112 {

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

            for (Fz40OAStaff sysData : list) {
                apiData = new Api1112();
                apiData.setDwmc(api1101.getDwmc());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setKqdm(api1102.getKqdm());
                apiData.setBizId(sysData.getId());
                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.setRylb(sysData.getZy());
                apiData.setQdzgzchzyzgsj(sysData.getQdzgzchzyzgsj());
                apiData.setXl(sysData.getXl());
                apiData.setZw(sysData.getZw());
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setZhgxsj(sysData.getUpdateTime());

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

            }

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

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

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

import com.fzzy.api.Constant;
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.*;
import com.fzzy.async.fzzy30.repository.FzzySync1202Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.entity.Fz40InoutSettle;
import com.fzzy.async.fzzy40.entity.Fz40InoutNoticeIn;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.entity.Fz40InoutSettle;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1107Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1204Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40SyncNoticeInRep;
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 Fzzy40Sync1204 {

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

    @Autowired
    private Fzzy40Sync1202Rep fzzy40Sync1202Rep;
    @Autowired
    private Fzzy40Sync1204Rep fzzy40Sync1204Rep;
    @Autowired
    private Fzzy40SyncNoticeInRep fzzySyncNoticeInRep;
    @Autowired
    private ApiLogRep apiLogRep;
    @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<Fz40InoutSettle> list = fzzy40Sync1204Rep.listInoutSettle(INOUT_TYPE_IN, start, end);

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

            Api1204 apiData;
            Api1105 api1105;
            List<Fz40InoutRecord> fz40InoutRecords;
            Fz40InoutRecord fz40InoutRecord;
            for (Fz40InoutSettle sysData : list) {

                //获取粮食入库信息
                fz40InoutRecords = fzzy40Sync1202Rep.listInoutRecordById(sysData.getId());
                if (null == fz40InoutRecords || fz40InoutRecords.isEmpty()) {
                    continue;
                }
                fz40InoutRecord = fz40InoutRecords.get(0);
                if (!deptId.equals(fz40InoutRecord.getDeptId())) {
                    continue;
                }

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

                apiData = new Api1204();
                //入库结算单号:库区代码 + yyMMdd + 4为顺序号
                apiData.setRkjsdh(kqdm + sysData.getId().substring(2));

                //货位代码
                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.setCzbz(Constant.CZBZ_I);
                apiData.setZhgxsj(sysData.getUpdateTime());

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                log.info("1204---同步数据：{}", apiData.toString());
                //保存数据
                api1204Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }


}

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1206;
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.Api1206Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.entity.Fz40InoutSettle;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1204Rep;
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;

/**
 * ç²®é£Ÿå‡ºåº“结算
 */
@Slf4j
@Component
public class Fzzy40Sync1206 {

    /**
     * å‡ºåº“类型
     */
    private final static String INOUT_TYPE_OUT = "OUT";

    @Autowired
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy40Sync1204Rep fzzySync1204Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1206Rep api1206Rep;
    @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("-------------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<Fz40InoutSettle> list = fzzySync1204Rep.listInoutSettle(INOUT_TYPE_OUT, start, end);

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

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

            Api1206 apiData;
            Api1105 api1105;
            List<Fz40InoutRecord> fz40InoutRecords;
            Fz40InoutRecord fz40InoutRecord;
            for (Fz40InoutSettle sysData : list) {

                //获取粮食出库信息
                fz40InoutRecords = fzzySync1202Rep.listInoutRecordById(sysData.getId());
                if (null == fz40InoutRecords || fz40InoutRecords.isEmpty()) {
                    continue;
                }
                fz40InoutRecord = fz40InoutRecords.get(0);
                if (!deptId.equals(fz40InoutRecord.getDeptId())) {
                    continue;
                }

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

                apiData = new Api1206();
                //入库结算单号:库区代码 + yyMMdd + 4为顺序号
                apiData.setCkjsdh(kqdm + sysData.getId().substring(2));

                //合同号
                apiData.setHth(api1201.getDwdm() + sysData.getId());

                //结算重量、结算单价、结算金额、结算时间
                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.setFphm("");
                apiData.setFpzt("");

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

                //业务id、库区编码、同步时间
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(kqdm);
                apiData.setSyncTime(new Date());
                log.info("1206---同步数据：{}", apiData.toString());
                //保存数据
                api1206Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

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

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

import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.view.repository.Api1102Rep;
import com.fzzy.api.view.repository.Api1207Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1207Rep;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @Author:YAN
 */
@Slf4j
@Component
public class Fzzy40Sync1207 {

    @Autowired
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy40Sync1207Rep fzzySync1207Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1207Rep api1207Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private ApiLogRep apiLogRep;
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,146 @@
package com.fzzy.async.fzzy40.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.fzzy40.entity.Fz40InoutLossOver;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1209Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * ç²®é£ŸæŸæº¢
 */
@Slf4j
@Component
public class Fzzy40Sync1209 {

    /**
     * æŸæº¢ç±»åž‹-损耗
     */
    public static final String LOSS_OVER_LOSS = "LOSS";
    /**
     * æŸæº¢ç±»åž‹-溢出
     */
    public static final String LOSS_OVER_OVER = "OVER";

    @Autowired
    private Fzzy40Sync1209Rep 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<Fz40InoutLossOver> list = fzzySync1209Rep.listMLossOver(deptId, start, end);

            if (null == list || list.isEmpty()) {

                log.info("-------------没有获取到粮食损溢信息------------------");

                return;
            }

            Api1209 apiData;
            Api1105 api1105;
            List<Api1209> api1209List;
            for (Fz40InoutLossOver 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());

                //净重损溢数量，损耗为正，溢出为负
                if (LOSS_OVER_LOSS.equals(sysData.getType())) {
                    apiData.setJzsysl(sysData.getAmount());
                    apiData.setCkjz(sysData.getAmount());
                    apiData.setRkjz(0);
                } else {
                    apiData.setJzsysl(0 - sysData.getAmount());
                    apiData.setRkjz(sysData.getAmount());
                    apiData.setCkjz(0);
                }

                apiData.setRksj(sysData.getSubmitTime());
                apiData.setCksj(sysData.getSubmitTime());

                apiData.setRksf(sysData.getRksf());
                apiData.setRkzz(sysData.getRkzz());
                apiData.setCksf(sysData.getCksf());
                apiData.setCkzz(sysData.getCkzz());
                apiData.setQzchwqsh(0);
                apiData.setQzszkl(0);
                apiData.setQzzrshde(0);
                apiData.setChsl(0);
                apiData.setSysfzc(null == sysData.getSysfzc() || sysData.getSysfzc() == "" ? "0" : sysData.getSysfzc());
                apiData.setSyyy(sysData.getSyyy());
                apiData.setCcshr(sysData.getCcshr());
                apiData.setZjshr(sysData.getZjshr());
                apiData.setTjshr(sysData.getTjshr());
                apiData.setKjshr(sysData.getKjshr());
                apiData.setLdshr(sysData.getLdshr());
                apiData.setBz(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("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

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

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

import com.fzzy.async.fzzy40.entity.Fz40DeptDevice;
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 Fzzy40Sync1107Rep extends JpaRepository<Fz40DeptDevice, String> {
    @Query("from Fz40DeptDevice where kqdm=:deptId order by sbbh")
    List<Fz40DeptDevice> listDecixe(@Param("deptId") String deptId);
}

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

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

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

    @Query("from Fz40Drug where deptId=:deptId order by id")
    List<Fz40Drug> listDrug(@Param("deptId") String deptId);
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
package com.fzzy.async.fzzy40.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 Fzzy40Sync1112Rep 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/fzzy40/repository/Fzzy40Sync1204Rep.java

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

import com.fzzy.async.fzzy40.entity.Fz40InoutSettle;
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 Fzzy40Sync1204Rep extends JpaRepository<Fz40InoutSettle, String> {
    /**
     * èŽ·å–出入库结算信息
     *
     * @param type
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz40InoutSettle where inoutType=:type and payTime >=:start and payTime <:end order by payTime ")
    List<Fz40InoutSettle> listInoutSettle(@Param("type") String type, @Param("start") Date start, @Param("end") Date end);
}

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

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

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

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–倒仓信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz40InoutStockChange where deptId=:deptId and changeDate >=:start and changeDate <:end order by changeDate ")
    List<Fz40InoutStockChange> listStockChange(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

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

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

import com.fzzy.async.fzzy35.entity.Fz35MLossOver;
import com.fzzy.async.fzzy40.entity.Fz40InoutLossOver;
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 Fzzy40Sync1209Rep extends JpaRepository<Fz40InoutLossOver, String> {
    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–损溢信息
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz40InoutLossOver where deptId=:deptId and submitTime >=:start and submitTime <:end order by submitTime ")
    List<Fz40InoutLossOver> listMLossOver(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/whhpjl/entity/Fz40WhjlDefaultBuild.java

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

    @Column(name = "ggm", length = 50)
    @PropertyDef(label = "国规码")
    private String ggm;

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

 src/main/java/com/fzzy/async/whhpjl/entity/Fz40WhjlDefaultDepot.java

@@ -29,6 +29,10 @@
    @PropertyDef(label = "货位编号")
    private String id;

    @Column(name = "ggm", length = 50)
    @PropertyDef(label = "国规码")
    private String ggm;

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