增加V40接口-粮情、出入库

CZT

2023-07-18 254da24705ba4daa8bf289a2c10b912fb8c53ad2

增加V40接口-粮情、出入库

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

@@ -11,6 +11,7 @@
    GB_DEFAULT("GB_DEFAULT", "系统默认协议"),
    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_V35_SHYZ("FZZY_V35_SHYZ", "风正致远2上海佑卓规范");



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

@@ -36,9 +36,8 @@

    @JSONField(serialize = false)
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Integer id;
    private String id;

    @PropertyDef(label = "单位代码",required =true )
    @Column(name = "dwdm", length = 18)

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

@@ -201,6 +201,7 @@
        list.add(new ApiTrigger(SyncProtocol.GB_DEFAULT.getCode(), SyncProtocol.GB_DEFAULT.getName()));
        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_V35_SHYZ.getCode(), SyncProtocol.FZZY_V35_SHYZ.getName()));
        return list;
    }

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

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


import com.fzzy.api.entity.Api1101;

import com.fzzy.api.entity.Api1111;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
@@ -28,7 +25,7 @@
    int updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    /**
     * æŸ¥è¯¢æ‰€æœ‰çš„监控点位信息
     * å•ä½ä¿¡æ¯
     * @param kqdm
     * @return
     */

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

@@ -1,18 +1,22 @@
package com.fzzy.api.view.repository;

import com.fzzy.api.entity.Api1212;

import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;


public interface Api1212Rep extends JpaRepository<Api1212, Integer>, JpaSpecificationExecutor<Api1212> {
public interface Api1212Rep extends JpaRepository<Api1212, String>, JpaSpecificationExecutor<Api1212> {

    @Transactional
    @Modifying
    @Query("update Api1212 set czbz =:czbz where id=:id")
    void updateStatus(@Param("id") Integer id, @Param("czbz") String czbz);
    void updateStatus(@Param("id") String id, @Param("czbz") String czbz);

    @Query("from Api1212 where id=:id ")
    List<Api1212> getDataById(@Param("id") String id);
}

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

@@ -46,18 +46,18 @@
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {

        //修改库存数据为每天2点同步，每天只同步一条
        Date nowTime = new Date();
        int hour = ContextUtil.getHourOfDay(nowTime);
        if (!String.valueOf(hour).equals("2")) {
            log.info("-------------当前时间不在2点钟，1208库存接口数据接口不同步------------------");
            return;
        }
        int minute = ContextUtil.getMinuteOfHour(nowTime);
        if (!String.valueOf(minute).equals("00")) {
            log.info("-------------当前时间不在2点钟0分，1208库存接口数据接口不同步------------------");
            return;
        }
//        //修改库存数据为每天2点同步，每天只同步一条
//        Date nowTime = new Date();
//        int hour = ContextUtil.getHourOfDay(nowTime);
//        if (!String.valueOf(hour).equals("2")) {
//            log.info("-------------当前时间不在2点钟，1208库存接口数据接口不同步------------------");
//            return;
//        }
//        int minute = ContextUtil.getMinuteOfHour(nowTime);
//        if (!String.valueOf(minute).equals("00")) {
//            log.info("-------------当前时间不在2点钟0分，1208库存接口数据接口不同步------------------");
//            return;
//        }
        log.info("-------------1208接口数据开始同步------------------");

        //同步数据，只记录失败的信息

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

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

import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService12;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1201;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1202;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1205;
import com.fzzy.async.fzzy40.impl.Fzzy40Sync1212;
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 Fzzy40SyncService12 implements SyncService12 {

    @Autowired
    private Fzzy40Sync1201 fzzySync1201;
    @Autowired
    private Fzzy40Sync1202 fzzySync1202;
    @Autowired
    private Fzzy40Sync1205 fzzySync1205;
    @Autowired
    private Fzzy40Sync1212 fzzySync1212;

    @Override
    public String getProtocol() {
        return SyncProtocol.FZZY_V40_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);

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

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

    }

}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,230 @@
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:
 * @author: Andy
 * @update-time: 2023/5/22 æ ¹æ®æ–°å›½æ ‡è°ƒæ•´åç§°ï¼Œä¼˜åŒ–字段
 */
@Data
@Entity
@Table(name = "D_INOUT_CONTRACT")
public class Fz40InoutContract 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 = "组织编码")
    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 = "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 String 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;

}

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

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

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

    private static final long serialVersionUID = 1L;

    @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/fzzy40/entity/Fz40InoutNoticeIn.java

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

    private static final long serialVersionUID = 1L;

    @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 = "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;
}

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

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

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

    @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 = "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;
}

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

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

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

    @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 = "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 = "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/fzzy40/impl/Fzzy40Sync1201.java

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1201;
import com.fzzy.api.entity.ApiLog;
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.Api1201Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40InoutContract;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1201Rep;
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 Fzzy40Sync1201 {

    @Autowired
    private Fzzy40Sync1201Rep fzzySync1201Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @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<Fz40InoutContract> list = fzzySync1201Rep.listContract(deptId);

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

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

            Api1201 apiData;
            List<Api1201> api1201List;
            for (Fz40InoutContract sysData : list) {

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

                //业务类型
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_HT_YWLX, sysData.getType());
                apiData.setYwlx(mappingCode);
                //客户类型
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_KHLX, sysData.getCustomerType());
                apiData.setKhlx(mappingCode);

                apiData.setKhtyshxydm(StringUtils.isEmpty(sysData.getCustomerId()) ? "100000000000000000" :sysData.getCustomerId());

                apiData.setKhmc(sysData.getCustomerName());
                apiData.setFddbr(sysData.getCustomerSignUser());

                apiData.setQdrq(sysData.getSigningTime());

                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety());
                apiData.setLspzdm(mappingCode);

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

                //单价：元/公斤-->元/吨
                apiData.setHtdj(sysData.getPrice() == null ? 0.0 : sysData.getPrice()*1000);
                apiData.setYdgxlssl(sysData.getContactAmount() == null ? 0.0 : sysData.getContactAmount());

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

                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_JSYHTYZX, "");
                apiData.setJsyhtyzx(mappingCode);

                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()) ? "1000000000000000000" : sysData.getBankAccount());

                apiData.setWcrq(sysData.getEndTime());

                apiData.setZhgxsj(sysData.getCreateTime());

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

                apiLog.setDataId(apiData.getBizId());
                apiLog.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());
            }
        } catch (Exception e) {
            log.error("---合同同步执行失败----{}", e);
            apiLog.setResult("同步合同信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1202;
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.Api1202Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40InoutNoticeIn;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40SyncNoticeInRep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Calendar;
import java.util.Date;
import java.util.List;

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

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

    @Autowired
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy40SyncNoticeInRep fzzySyncNoticeInRep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1202Rep api1202Rep;
    @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<Fz40InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);

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

            Api1202 apiData;
            Api1105 api1105;
            List<Fz40InoutNoticeIn> listInoutNotice;
            List<Api1202> api1202List;
            Calendar c = Calendar.getInstance();
            for (Fz40InoutRecord sysData : list) {
                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(sysData.getRegisterTime());
                apiData.setCyr(sysData.getUserName());

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

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

                //获取合同号
                listInoutNotice = fzzySyncNoticeInRep.listInoutNoticeInById(sysData.getNoticeId());
                if(null != listInoutNotice && listInoutNotice.size() >0){
                    apiData.setHth(api1105.getHwdm().substring(0,18) + listInoutNotice.get(0).getContractId());
                }else {
                    apiData.setHth(api1105.getHwdm().substring(0,18) + apiData.getRkywdh());
                }

                apiData.setXxdz(sysData.getUserAddress());

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

                //车船号
                apiData.setCch(sysData.getPlateNum());
                c.setTime(sysData.getRegisterTime());
                c.add(Calendar.MINUTE,-3);
                apiData.setDjsj(c.getTime());

                //粮食品种
                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(new Date(), "yyyy") :sysData.getFoodYear());

                //产地代码
                String cddm = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation());
                apiData.setCddm(cddm);

                //检斤类型，默认0-称重入库
                apiData.setJjlx("0");

                //毛重信息
                apiData.setMz(sysData.getFullWeight());
                apiData.setMzjlsj(sysData.getFullWeightTime());
                apiData.setMzjby(sysData.getFullWeightUser());
                apiData.setMzjly(sysData.getFullWeightUser());

                apiData.setZcy(sysData.getHandleUser());

                //皮重信息
                apiData.setPz(sysData.getEmptyWeight());
                apiData.setPzjlsj(sysData.getEmptyWeightTime());
                apiData.setPzjby(sysData.getEmptyWeightUser());
                apiData.setPzjly(sysData.getEmptyWeightUser());

                //扣重 åŒ–验总扣重
                apiData.setZjklxj(sysData.getDeCheck());

                //其它
                apiData.setQtkl( 0 - sysData.getDeOther());
                //值仓 çŽ°åœºæ‰£é‡
                apiData.setXckl( 0 - sysData.getDeHandle());

                apiData.setJz(sysData.getRecordWeight());
                c.setTime(sysData.getCompleteTime());
                c.add(Calendar.MINUTE,3);
                apiData.setCmsj(c.getTime());

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

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

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1205;
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.Api1205Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40InoutNoticeOut;
import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40SyncNoticeOutRep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateFormatUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

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

/**
 * ç²®é£Ÿå‡ºåº“信息
 */
@Slf4j
@Component
public class Fzzy40Sync1205 {

    /**
     * å‡ºåº“类型
     */
    private final static String INOUT_TYPE_OUT = "OUT";
    @Autowired
    private Fzzy40Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Fzzy40SyncNoticeOutRep fzzySyncNoticeOutRep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1205Rep api1205Rep;
    @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<Fz40InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_OUT, start, end);

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

        Api1205 apiData;
        Api1105 api1105;
        List<Fz40InoutNoticeOut> listInoutNotice;
        List<Api1205> api1205List;
        Calendar c = Calendar.getInstance();
        for (Fz40InoutRecord sysData : list) {
            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.setCktzdh(sysData.getNoticeId());

            apiData.setYwrq(sysData.getRegisterTime());

            //获取合同号
            listInoutNotice = fzzySyncNoticeOutRep.listInoutNoticeOutById(sysData.getNoticeId());
            if(null != listInoutNotice && listInoutNotice.size() >0){
                apiData.setHth(api1105.getHwdm().substring(0,18) + listInoutNotice.get(0).getContractId());
            }else {
                apiData.setHth(api1105.getHwdm().substring(0,18) + apiData.getCkywdh());
            }


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

            //车船号
            apiData.setCch(sysData.getPlateNum());
            c.setTime(sysData.getRegisterTime());
            c.add(Calendar.MINUTE,-3);
            apiData.setDjsj(c.getTime());

            //粮食品种
            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);

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

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

            //产地代码
            String cddm = commonService.getFoodLocationIdFromCache(sysData.getFoodLocation());
            apiData.setCddm(cddm);

            //皮重信息
            apiData.setPz(sysData.getEmptyWeight());
            apiData.setPzjlsj(sysData.getEmptyWeightTime());
            apiData.setPzjby(sysData.getEmptyWeightUser());
            apiData.setPzjly(sysData.getEmptyWeightUser());

            //毛重信息
            apiData.setMz(sysData.getFullWeight());
            apiData.setMzjlsj(sysData.getFullWeightTime());
            apiData.setMzjby(sysData.getFullWeightUser());
            apiData.setMzjly(sysData.getFullWeightUser());

            //净重
            apiData.setJz(sysData.getRecordWeight());
            c.setTime(sysData.getCompleteTime());
            c.add(Calendar.MINUTE,3);
            apiData.setCmsj(c.getTime());

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

            //业务id、库区编码、同步时间
            apiData.setBizId(sysData.getId());
            apiData.setKqdm(kqdm);
            apiData.setSyncTime(new Date());
            log.info("1201---同步数据：{}",apiData.toString());

            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);
        }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

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

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,114 @@
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.Api1212Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40InoutCustomer;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1212Rep;
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 Fzzy40Sync1212 {

    @Autowired
    private Fzzy40Sync1212Rep fzzySync1212Rep;
    @Autowired
    private Api1102Rep api1102Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1212Rep api1212Rep;
    @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<Fz40InoutCustomer> list = fzzySync1212Rep.listInoutCustomer(deptId);

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

            //根据库区代码获取库区代码
            Api1102 api1201 = api1102Rep.findById(kqdm).get();
            List<Api1101> list1 = api1101Rep.findPushData(kqdm);
            Api1101 api1101 = list1.get(0);

            Api1212 apiData;
            List<Api1212> api1212List;
            for (Fz40InoutCustomer sysData : list) {

                apiData = new Api1212();

                apiData.setId(sysData.getId());
                //单位代码（ 1101 æŽ¥å£çš„单位代 ç ï¼‰ +自定义编码
                apiData.setDwdm(api1101.getDwdm());
                apiData.setDwmc(api1101.getDwmc());
                apiData.setKqmc(api1201.getKqmc());
                apiData.setKqdm(kqdm);
                apiData.setKhlx(StringUtils.isEmpty(sysData.getKhlx()) ? "1":sysData.getKhlx());
                apiData.setKhtyshxydmhsfzh(sysData.getCardId());
                apiData.setKhmc(sysData.getName());

                apiData.setFddbr(StringUtils.isEmpty(sysData.getFddbr())? "法定人" : sysData.getFddbr());

                apiData.setTxdz(sysData.getAddress());
                apiData.setYzbm(sysData.getYzbm());
                apiData.setLxrdh(sysData.getContactUser());
                apiData.setKhfkhh(sysData.getBank());
                apiData.setKhfzh(sysData.getBankNum());
                apiData.setBizId(sysData.getId());
                apiData.setZhgxsj(new Date());

                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("1201---同步数据：{}", apiData.toString());
            }
        } catch (Exception e) {
            log.error("---合同同步执行失败----{}", e);
            apiLog.setResult("同步合同信息失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}

 src/main/java/com/fzzy/async/fzzy40/package-info.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,6 @@
/**
 * é£Žæ­£è‡´è¿œ4.0版本数据同步
 *
 * ä¸»è¦é€‚用粮库：所有已升级4.0版本的粮库
 */
package com.fzzy.async.fzzy40;

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

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

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

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

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

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

import com.fzzy.async.fzzy40.entity.Fz40InoutRecord;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import java.util.Date;
import java.util.List;

/**
 * ç²®é£Ÿå‡ºå…¥åº“信息
 *
 * @author chen
 * @date 2022-09-23 17:10
 */
public interface Fzzy40Sync1202Rep extends JpaRepository<Fz40InoutRecord, String> {

    /**
     * æ ¹æ®ä¿¡æ¯èŽ·å–出入库信息
     * @param deptId
     * @param type
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz40InoutRecord where deptId=:deptId and type=:type and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz40InoutRecord> listInoutRecord(@Param("deptId") String deptId, @Param("type") String type, @Param("start") Date start, @Param("end") Date end);

    /**
     * æ ¹æ®id获取粮食出入库信息
     * @param id
     * @return
     */
    @Query("from Fz40InoutRecord where id=:id order by updateTime ")
    List<Fz40InoutRecord> listInoutRecordById(@Param("id") String id);

}

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

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

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

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

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

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

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


    /**
     * æ ¹æ®id获取入库通知单信息
     * @param id
     * @return
     */
    @Query("from Fz40InoutNoticeIn where id=:id ")
    List<Fz40InoutNoticeIn> listInoutNoticeInById(@Param("id") String id);

}

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

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

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


    /**
     * æ ¹æ®id获取出库通知单信息
     * @param id
     * @return
     */
    @Query("from Fz40InoutNoticeOut where id=:id ")
    List<Fz40InoutNoticeOut> listInoutNoticeOutById(@Param("id") String id);

}

 src/main/resources/application-dev.yml

@@ -6,20 +6,35 @@
    #主数据源
    primary:
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5016?useUnicode=true&useSSL=false&characterEncoding=utf-8
      url: jdbc:mysql://127.0.0.1:3306/igds_api_5303?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5303?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5311?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_1?useUnicode=true&useSSL=false&characterEncoding=utf-8 #港口新仓
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_2?useUnicode=true&useSSL=false&characterEncoding=utf-8 #关埠老仓
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_3?useUnicode=true&useSSL=false&characterEncoding=utf-8 #直属仓库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_4?useUnicode=true&useSSL=false&characterEncoding=utf-8 #西胪-新仓粮库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_4_2?useUnicode=true&useSSL=false&characterEncoding=utf-8 #西胪-新凤粮库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_5?useUnicode=true&useSSL=false&characterEncoding=utf-8 #金灶一所粮库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_6?useUnicode=true&useSSL=false&characterEncoding=utf-8 #金灶二所粮库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_7?useUnicode=true&useSSL=false&characterEncoding=utf-8 #粮油转运站
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_8?useUnicode=true&useSSL=false&characterEncoding=utf-8 #河溪粮所
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_9?useUnicode=true&useSSL=false&characterEncoding=utf-8 #海门粮所
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_10?useUnicode=true&useSSL=false&characterEncoding=utf-8 #和平粮所
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5320?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5321?useUnicode=true&useSSL=false&characterEncoding=utf-8  #广东韶关
      url: jdbc:mysql://127.0.0.1:3306/igds_api_5326?useUnicode=true&useSSL=false&characterEncoding=utf-8   #惠州惠新
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
    #次数据源
    secondary:
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5016?useUnicode=true&useSSL=false&characterEncoding=utf-8
      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5303?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5303?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5311?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5317?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5320?useUnicode=true&useSSL=false&characterEncoding=utf-8
#      url: jdbc:mysql://127.0.0.1:3306/igds_3.5_5321?useUnicode=true&useSSL=false&characterEncoding=utf-8
      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5326?useUnicode=true&useSSL=false&characterEncoding=utf-8  #惠州惠新
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver

 src/main/resources/application-pro.yml

@@ -1,4 +1,4 @@
##########################  å¹¿ä¸œæ½®é˜³   ##########################
##########################  å¹¿ä¸œéŸ¶å…³   ##########################
server:
  port: 8090
  jetty:
@@ -51,7 +51,7 @@
      timeout: 6000
igds:
  default:
    companyId: 5317
    companyId: 5321

  file-path: D:/IGDS-API/FILE/
  img-path: D:/IGDS/FILE/

 src/main/resources/application-pro5321.yml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,57 @@
##########################  å¹¿ä¸œéŸ¶å…³   ##########################
server:
  port: 8090
  jetty:
    max-http-post-size: 209715200
  tomcat:
    max-http-post-size: 209715200
spring:
  datasource:
    #主数据源
    primary:
      url: jdbc:mysql://127.0.0.1:3306/igds_api?useUnicode=true&characterEncoding=utf-8
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
    #次数据源
    secondary:
      url: jdbc:mysql://127.0.0.1:3306/igds_master?useUnicode=true&characterEncoding=utf-8
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
  jpa:
    #主jpa配置
    primary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: update
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
    #次jpa配置
    secondary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: none
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
  # Redis相关配置
  redis:
    database: 0
    host: 127.0.0.1
    port: 6379
    password: Abc123..
    # è¿žæŽ¥æ± æœ€å¤§è¿žæŽ¥æ•°ï¼ˆä½¿ç”¨è´Ÿå€¼è¡¨ç¤ºæ²¡æœ‰é™åˆ¶ï¼‰
    pool:
      max-active: 200
      max-wait: -1
      max-idle: 10
      min-idle: 0
      timeout: 6000
igds:
  default:
    companyId: 5321

  file-path: D:/IGDS-API/FILE/
  img-path: D:/IGDS/FILE/

 src/main/resources/application-pro5326.yml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,57 @@
##########################  å¹¿ä¸œæƒ å·žæƒ é˜³   ##########################
server:
  port: 8090
  jetty:
    max-http-post-size: 209715200
  tomcat:
    max-http-post-size: 209715200
spring:
  datasource:
    #主数据源
    primary:
      url: jdbc:mysql://127.0.0.1:3306/igds_api?useUnicode=true&characterEncoding=utf-8
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
    #次数据源
    secondary:
      url: jdbc:mysql://127.0.0.1:3306/igds_master?useUnicode=true&characterEncoding=utf-8
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
  jpa:
    #主jpa配置
    primary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: update
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
    #次jpa配置
    secondary:
      show-sql: true
      properties:
        hibernate:
          hbm2ddl:
            auto: none
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
  # Redis相关配置
  redis:
    database: 1
    host: 127.0.0.1
    port: 6379
    password: Abc123..
    # è¿žæŽ¥æ± æœ€å¤§è¿žæŽ¥æ•°ï¼ˆä½¿ç”¨è´Ÿå€¼è¡¨ç¤ºæ²¡æœ‰é™åˆ¶ï¼‰
    pool:
      max-active: 200
      max-wait: -1
      max-idle: 10
      min-idle: 0
      timeout: 6000
igds:
  default:
    companyId: 5326

  file-path: D:/IGDS-API/FILE/
  img-path: D:/IGDS/FILE/