提交上海嘉定纪委接口同步及推送

陈战涛

2023-05-14 fce0f324697f6313c13a28c29b93dfd2c8589566

提交上海嘉定纪委接口同步及推送

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

@@ -30,28 +30,28 @@

    @Id
    @PropertyDef(label = "质检报告单号" )
    @Column(name = "zjbgdh", length = 14, nullable = false)
    @Column(name = "zjbgdh", length = 14)
    private String zjbgdh;

    @PropertyDef(label = "货位代码" )
    @Column(name = "hwdm", length = 30, nullable = false)
    @Column(name = "hwdm", length = 30)
    private String hwdm;

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

    @PropertyDef(label = "粮食等级代码" )
    @Column(name = "lsdjdm", length = 2, nullable = false)
    @Column(name = "lsdjdm", length = 2)
    private String lsdjdm;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "入库日期" )
    @Column(name = "rkrq", nullable = false)
    @Column(name = "rkrq")
    private Date rkrq;

    @PropertyDef(label = "检验类别" )
    @Column(name = "jylb", length = 2, nullable = false)
    @Column(name = "jylb", length = 2)
    private String jylb;

    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
@@ -60,7 +60,7 @@
    private Date jysj;

    @PropertyDef(label = "检验单位" )
    @Column(name = "jydw", length = 128, nullable = false)
    @Column(name = "jydw", length = 128)
    private String jydw;

    @PropertyDef(label = "检验人" )
@@ -68,23 +68,23 @@
    private String jyr;

    @PropertyDef(label = "检验依据" )
    @Column(name = "jyyj", length = 1, nullable = false)
    @Column(name = "jyyj", length = 1)
    private String jyyj;

    @PropertyDef(label = "指标类别" )
    @Column(name = "zblb", length = 8, nullable = false)
    @Column(name = "zblb", length = 8)
    private String zblb;

    @PropertyDef(label = "检验项目" )
    @Column(name = "jyxm", length = 1000, nullable = false)
    @Column(name = "jyxm", length = 1000)
    private String jyxm;

    @PropertyDef(label = "检验项目值" )
    @Column(name = "jyxmz", length = 1000, nullable = false)
    @Column(name = "jyxmz", length = 1000)
    private String jyxmz;

    @PropertyDef(label = "指标结果判定" )
    @Column(name = "zbjgpd", length = 128, nullable = false)
    @Column(name = "zbjgpd", length = 128)
    private String zbjgpd;

    @JSONField(format = "yyyy-MM-dd")
@@ -98,7 +98,7 @@
    private Date bgcjsj;

    @PropertyDef(label = "审核人姓名" )
    @Column(name = "shrxm", length = 64, nullable = false)
    @Column(name = "shrxm", length = 64)
    private String shrxm;

    @PropertyDef(label = "扦样单编号" )
@@ -107,7 +107,7 @@

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

    @PropertyDef(label = "扦样区域" )
@@ -115,7 +115,7 @@
    private String qyqy;

    @PropertyDef(label = "扦样人姓名" )
    @Column(name = "qyrxm", length = 64, nullable = false)
    @Column(name = "qyrxm", length = 64)
    private String qyrxm;

    @PropertyDef(label = "监督人姓名" )
@@ -127,19 +127,19 @@
    private String ypbh;

    @PropertyDef(label = "样品数量" )
    @Column(name = "ypsl", precision = 20, scale = 6, nullable = false)
    @Column(name = "ypsl", precision = 20, scale = 6)
    private double ypsl;

    @PropertyDef(label = "代表数量" )
    @Column(name = "dbsl", precision = 20, scale = 6, nullable = false)
    @Column(name = "dbsl", precision = 20, scale = 6)
    private double dbsl;

    @PropertyDef(label = "样品等级" )
    @Column(name = "ypdj", length = 2, nullable = false)
    @Column(name = "ypdj", length = 2)
    private String ypdj;

    @PropertyDef(label = "是否正常存储年限" )
    @Column(name = "sfzcccnx", length = 1, nullable = false)
    @Column(name = "sfzcccnx", length = 1)
    private String sfzcccnx;

    @PropertyDef(label = "备注" )
@@ -147,12 +147,12 @@
    private String bz;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

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

}

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

@@ -30,7 +30,7 @@

    @Id
    @PropertyDef(label = "轮换计划单号" )
    @Column(name = "lhjhdh", length = 25, nullable = false)
    @Column(name = "lhjhdh", length = 25)
    private String lhjhdh;

    @PropertyDef(label = "计划文号" )
@@ -38,25 +38,25 @@
    private String jhwh;

    @PropertyDef(label = "计划名称" )
    @Column(name = "jhmc", length = 256, nullable = false)
    @Column(name = "jhmc", length = 256)
    private String jhmc;

    @PropertyDef(label = "计划年度" )
    @Column(name = "jhnd", length = 4, nullable = false)
    @Column(name = "jhnd", length = 4)
    private String jhnd;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "开始执行日期" )
    @Column(name = "kszxrq", nullable = false)
    @Column(name = "kszxrq")
    private Date kszxrq;

    @JSONField(format = "yyyy-MM-dd")
    @PropertyDef(label = "截止执行日期" )
    @Column(name = "jzzxrq", nullable = false)
    @Column(name = "jzzxrq")
    private Date jzzxrq;

    @PropertyDef(label = "计划下达单位" )
    @Column(name = "jhxddw", length = 18, nullable = false)
    @Column(name = "jhxddw", length = 18)
    private String jhxddw;

    @JSONField(format = "yyyy-MM-dd")
@@ -65,12 +65,12 @@
    private Date jhxdsj;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

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

    @JSONField(serialize = false)

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

@@ -30,27 +30,27 @@

    @Id
    @PropertyDef(label = "计划明细单号" )
    @Column(name = "jhmxdh", length = 50, nullable = false)
    @Column(name = "jhmxdh", length = 50)
    private String jhmxdh;

    @PropertyDef(label = "轮换计划单号" )
    @Column(name = "lhjhdh", length = 25, nullable = false)
    @Column(name = "lhjhdh", length = 25)
    private String lhjhdh;

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

    @PropertyDef(label = "粮食等级代码" )
    @Column(name = "lsdjdm", length = 2, nullable = false)
    @Column(name = "lsdjdm", length = 2)
    private String lsdjdm;

    @PropertyDef(label = "粮食性质代码" )
    @Column(name = "lsxzdm", length = 3, nullable = false)
    @Column(name = "lsxzdm", length = 3)
    private String lsxzdm;

    @PropertyDef(label = "收获年度" )
    @Column(name = "shnd", length = 4, nullable = false)
    @Column(name = "shnd", length = 4)
    private String shnd;

    @PropertyDef(label = "轮换货位代码" )
@@ -58,20 +58,20 @@
    private String lhhwdm;

    @PropertyDef(label = "轮换数量" )
    @Column(name = "lhsl", precision = 20, scale = 6, nullable = false)
    @Column(name = "lhsl", precision = 20, scale = 6)
    private double lhsl;

    @PropertyDef(label = "轮换类型" )
    @Column(name = "lhlx", length = 1, nullable = false)
    @Column(name = "lhlx", length = 1)
    private String lhlx;

    @PropertyDef(label = "操作标志" )
    @Column(name = "czbz", length = 1, nullable = false)
    @Column(name = "czbz", length = 1)
    private String czbz;

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



 src/main/java/com/fzzy/api/view/pr/Api1202PR.java

@@ -184,7 +184,7 @@
                if (responseDto.getSuccess() == 0) {
                    //todo ä»£è¡¨ä¸Šä¼ æˆåŠŸ ,后期需要保存日志
                    if ("i".equals(d.getCzbz())) {
                        apiRepository.updateStatus(d.getId(), Constant.CZBZ_U);
                        apiRepository.updateStatus(d.getRkywdh(), Constant.CZBZ_U);
                    }
                }
            }

 src/main/java/com/fzzy/api/view/pr/Api1203PR.java

@@ -185,7 +185,7 @@
            if (responseDto.getSuccess() == 0) {
                //todo ä»£è¡¨ä¸Šä¼ æˆåŠŸ ,后期需要保存日志
                if ("i".equals(d.getCzbz())) {
                    apiRepository.updateStatus(d.getId(), Constant.CZBZ_U);
                    apiRepository.updateStatus(d.getRkjydh(), Constant.CZBZ_U);
                }
            }
        }

 src/main/java/com/fzzy/api/view/pr/Api1205PR.java

@@ -186,7 +186,7 @@
            if (responseDto.getSuccess() == 0) {
                //todo ä»£è¡¨ä¸Šä¼ æˆåŠŸ ,后期需要保存日志
                if ("i".equals(d.getCzbz())) {
                    apiRepository.updateStatus(d.getId(), Constant.CZBZ_U);
                    apiRepository.updateStatus(d.getCkywdh(), Constant.CZBZ_U);
                }
            }
        }

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

@@ -19,6 +19,6 @@

    @Transactional
    @Modifying
    @Query("update Api1202 set czbz =:czbz where id=:id")
    void updateStatus(@Param("id") String id, @Param("czbz") String czbz);
    @Query("update Api1202 set czbz =:czbz where rkywdh=:rkywdh")
    int updateStatus(@Param("rkywdh") String rkywdh, @Param("czbz") String czbz);
}

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

@@ -19,6 +19,6 @@

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

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

@@ -20,6 +20,6 @@

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

 src/main/java/com/fzzy/async/fzzy35/Fzzy35SyncService12.java

@@ -49,29 +49,30 @@
        Date start = param.getStart();
        Date end = param.getEnd();

//        //合同同步
//        fzzySync1201.syncData(kqdm, deptId, start, end);
//
//        //粮食入库同步
//        fzzySync1202.syncData(kqdm, deptId, start, end);
//
//        //粮食入库质检同步
//        fzzySync1203.syncData(kqdm, deptId, start, end);
//
//        //粮食入库结算同步
//        fzzySync1204.syncData(kqdm, deptId, start, end);
//
//        //粮食出库同步
//        fzzySync1205.syncData(kqdm, deptId, start, end);
//
//        //粮食出库结算同步
//        fzzySync1206.syncData(kqdm, deptId, start, end);
//
//        //粮食损溢同步
//        fzzySync1209.syncData(kqdm, deptId, start, end);
//
//        //文件信息同步
//        fzzy35Sync1109.syncData(kqdm, deptId, start, end);

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

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

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

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

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

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

        //粮食损溢同步
        fzzySync1209.syncData(kqdm, deptId, start, end);

        //文件信息同步
        fzzy35Sync1109.syncData(kqdm, deptId, start, end);

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

 src/main/java/com/fzzy/async/fzzy35/Fzzy35SyncService13.java

@@ -6,6 +6,7 @@
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1302;
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1303;
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1304;
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1310;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -22,6 +23,8 @@
    private Fzzy35Sync1303 fzzySync1303;
    @Autowired
    private Fzzy35Sync1304 fzzySync1304;
    @Autowired
    private Fzzy35Sync1310 fzzySync1310;


    @Override
@@ -40,6 +43,9 @@

        //气体检测同步
        fzzySync1304.syncData(param.getDeptId(), param.getStart(), param.getEnd());

        //质检同步
        fzzySync1310.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
    }

}

 src/main/java/com/fzzy/async/fzzy35/Fzzy35SyncService14.java

@@ -3,6 +3,9 @@
import com.fzzy.api.data.ApiParam;
import com.fzzy.api.data.SyncProtocol;
import com.fzzy.api.service.SyncService14;
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1403;
import com.fzzy.async.fzzy35.impl.Fzzy35Sync1404;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
@@ -11,8 +14,10 @@
@Component
public class Fzzy35SyncService14 implements SyncService14 {

  //  public static final String BEAN_ID = "fzzy35.syncService14";

    @Autowired
    private Fzzy35Sync1403 fzzy35Sync1403;
    @Autowired
    private Fzzy35Sync1404 fzzy35Sync1404;

    @Override
    public String getProtocol() {
@@ -21,7 +26,11 @@

    @Override
    public void syncData(ApiParam param) {
        //轮换计划同步
        fzzy35Sync1403.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());

        //轮换计划明细同步
        fzzy35Sync1404.syncData(param.getKqdm(), param.getDeptId(), param.getStart(), param.getEnd());
    }

}

 src/main/java/com/fzzy/async/fzzy35/entity/Fz35Plan.java

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

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * è®¡åˆ’管理-主表
 *
 *
 */
@Data
@Entity
@Table(name = "D_M_PLAN")
public class Fz35Plan implements Serializable {

    private static final long serialVersionUID = 1L;

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

    @Column(name = "REFERENCE_NUMBER_", length = 40)
    @PropertyDef(label = "计划文号")
    private String referenceNumber;

    @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 = 10)
    @PropertyDef(label = "计划类型")
    private String type;

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

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

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

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

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

    @Column(name = "END_TIME_")
    @PropertyDef(label = "截止时间")
    private Date endTime;

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

}

 src/main/java/com/fzzy/async/fzzy35/entity/Fz35PlanDetail.java

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

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
import java.io.Serializable;
import java.util.Date;

/**
 * è®¡åˆ’管理-计划详细
 * 
 * @author:
 *
 */
@Data
@Entity
@Table(name = "D_M_PLAN_DETAIL")
public class Fz35PlanDetail implements Serializable {

    private static final long serialVersionUID = 1L;

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

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

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

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

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

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

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

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

    @Column(name = "PLAN_NUM_", precision = 16, scale = 2)
    @PropertyDef(label = "数量")
    private Double planNum;

    @Column(name = "PRICE_", precision = 16, scale = 2)
    @PropertyDef(label = "单价")
    private Double price;

    @Column(name = "TOTAL_", precision = 16, scale = 2)
    @PropertyDef(label = "总价")
    private Double total;

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

 src/main/java/com/fzzy/async/fzzy35/entity/Fz35Quality.java

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

import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import javax.persistence.*;
import java.io.Serializable;
import java.util.Date;

/**
 * è´¨é‡å·¡æ£€--粮食在仓检测
 * 
 * @author chen
 *
 */
@Data
@Entity
@Table(name = "D_M_QUALITY")
public class Fz35Quality implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @Column(name = "ID_", length = 40)
    @PropertyDef(label = "主键ID", description = "ZJ+检验类别+年月日时分秒")
    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 = "FOOD_VARIETY_", length = 10)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;

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

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

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

    @Column(name = "TYPE_", length = 10)
    @PropertyDef(label = "检验类别", description = "如入库验收、储藏检验、日常巡检等")
    private String type;

    @Column(name = "STANDARD_", length = 10)
    @PropertyDef(label = "检验依据", description = "01-国标，02-其他")
    private String standard;

    @Column(name = "USER_", length = 50)
    @PropertyDef(label = "检验单位或检验人")
    private String user;

    @Column(name = "TIME_")
    @PropertyDef(label = "检验时间")
    private Date time;

    @Column(name = "RESULT_", length = 50)
    @PropertyDef(label = "检验结论")
    private String result;

    @Column(name = "CHECK_AREA__", length = 50)
    @PropertyDef(label = "扦样区域")
    private String checkArea;

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

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

    @Column(name = "CHECK_NUM_")
    @PropertyDef(label = "样品数量")
    private Double checkNum;

    @Column(name = "CHECK_REPRESENT_", length = 50)
    @PropertyDef(label = "样品代表")
    private String checkRepresent;

    @Column(name = "CHECK_LEVEL_", length = 20)
    @PropertyDef(label = "样品等级")
    private String checkLevel;

    @Column(name = "NORMAL_YEAR_", length = 10)
    @PropertyDef(label = "是否正常存储年限")
    private String normalYear;

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

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1310Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.GbCheckItemRep;
import com.fzzy.async.fzzy35.entity.Fz35CheckItem;
import com.fzzy.async.fzzy35.entity.Fz35Quality;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1310Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.apache.commons.lang.time.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;

/**
 * è´¨æ£€åŒæ­¥
 *
 * @author chen
 * @date 2023-05-14 19:51
 */
@Slf4j
@Component
public class Fzzy35Sync1310 {

    @Autowired
    private Fzzy35Sync1310Rep fzzySync1310Rep;
    @Autowired
    private Fzzy35Sync1203Rep fzzySync1203Rep;
    @Autowired
    private GbCheckItemRep gbCheckItemRep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1310Rep api1310Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1310接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz35Quality> list = fzzySync1310Rep.findDateByTime(start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1310 api1310;
            Api1105 api1105;
            List<Fz35CheckItem> fz35CheckItems;
            List<GbCheckItem> gbCheckList;
            String jyxm;
            String jyxmz;
            for (Fz35Quality fz35Quality : list) {
                api1105 = commonService.getApi1105Cache(fz35Quality.getDepotId());
                if (null == api1105) {
                    continue;
                }
                api1310 = new Api1310();
                api1310.setZjbgdh(fz35Quality.getId());
                api1310.setHwdm(api1105.getHwdm());
                api1310.setKqdm(kqdm);
                api1310.setLspzdm(fz35Quality.getFoodVariety());
                api1310.setLsdjdm(fz35Quality.getFoodLevel());
                api1310.setRkrq(DateUtils.addDays(fz35Quality.getTime(), -30));
                api1310.setJylb(fz35Quality.getType());
                api1310.setJysj(fz35Quality.getTime());
                api1310.setJydw(fz35Quality.getUser());
                api1310.setJyr(fz35Quality.getUser());
                api1310.setJyyj(fz35Quality.getStandard());
                api1310.setZblb("2");
                //检测项，检测值
                jyxm = "";
                jyxmz = "";
                fz35CheckItems = fzzySync1203Rep.listInoutCheckItem(fz35Quality.getId());
                if (null != fz35CheckItems && fz35CheckItems.size() > 0) {

                    for (Fz35CheckItem fz35CheckItem : fz35CheckItems) {
                        gbCheckList = gbCheckItemRep.findByBizCode(fz35CheckItem.getStandardId());

                        if (gbCheckList == null || gbCheckList.isEmpty()) {
                            continue;
                        }
                        jyxm += gbCheckList.get(0).getCode() + ",";
                        jyxmz += fz35CheckItem.getValue() + ",";
                    }
                }
                api1310.setJyxm(jyxm);
                api1310.setJyxmz(jyxmz);

                api1310.setZbjgpd(fz35Quality.getResult());
                api1310.setQfrq(fz35Quality.getTime());
                api1310.setBgcjsj(fz35Quality.getTime());
                api1310.setShrxm(fz35Quality.getCheckUser());
                api1310.setQysj(fz35Quality.getCheckTime());
                api1310.setQyqy(fz35Quality.getCheckArea());
                api1310.setQyrxm(fz35Quality.getCheckUser());
                api1310.setJdrxm(fz35Quality.getCheckUser());

                api1310.setYpsl(fz35Quality.getCheckNum()==null?0.0:(fz35Quality.getCheckNum()));
                api1310.setDbsl(StringUtils.isEmpty(fz35Quality.getCheckRepresent())? 0.0:Double.valueOf(fz35Quality.getCheckRepresent()));
                api1310.setYpdj(StringUtils.isEmpty(fz35Quality.getCheckLevel())?"0": fz35Quality.getCheckLevel());
                api1310.setSfzcccnx(StringUtils.isEmpty(fz35Quality.getNormalYear())?"0": fz35Quality.getNormalYear());
                api1310.setBz(fz35Quality.getRemark());
                api1310.setCzbz(Constant.CZBZ_I);
                api1310.setZhgxsj(new Date());

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

}

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy35.entity.Fz35CheckItem;
import com.fzzy.async.fzzy35.entity.Fz35Plan;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1403Rep;
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 chen
 * @date 2023-05-14 19:51
 */
@Slf4j
@Component
public class Fzzy35Sync1403 {

    @Autowired
    private Fzzy35Sync1403Rep fzzy35Sync1403Rep;
    @Autowired
    private Api1101Rep api1101Rep;
    @Autowired
    private Api1403Rep api1403Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存轮换计划数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1403接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz35Plan> list = fzzy35Sync1403Rep.findDate("3", start, end);
            if (null == list || list.isEmpty()) {
                return;
            }

            Api1403 api1403;
            List<Api1101> api1101List;
            for (Fz35Plan fz35Plan : list) {
                api1403 = new Api1403();
                api1403.setLhjhdh(fz35Plan.getId());
                api1403.setJhwh(fz35Plan.getReferenceNumber());
                api1403.setJhmc(fz35Plan.getName());
                api1403.setJhnd(fz35Plan.getYear());
                api1403.setKszxrq(fz35Plan.getBeginTime());
                api1403.setJzzxrq(fz35Plan.getEndTime());
                api1101List = api1101Rep.findPushData(kqdm);
                if(null != api1101List && api1101List.size() > 0){
                    api1403.setJhxddw(api1101List.get(0).getDwdm());
                }
                api1403.setJhxdsj(fz35Plan.getCreateTime());
                api1403.setCzbz(Constant.CZBZ_I);
                api1403.setZhgxsj(new Date());
                api1403.setKqdm(kqdm);
                api1403.setBizId(fz35Plan.getId());
                api1403Rep.save(api1403);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

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

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

import com.fzzy.api.Constant;
import com.fzzy.api.entity.*;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1404Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.Fz35Plan;
import com.fzzy.async.fzzy35.entity.Fz35PlanDetail;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1403Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1404Rep;
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 chen
 * @date 2023-05-14 19:51
 */
@Slf4j
@Component
public class Fzzy35Sync1404 {

    @Autowired
    private Fzzy35Sync1403Rep fzzy35Sync1403Rep;
    @Autowired
    private Fzzy35Sync1404Rep fzzy35Sync1404Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private Api1404Rep api1404Rep;
    @Autowired
    private ApiLogRep apiLogRep;

    /**
     * åŒæ­¥å¹¶å°è£…保存质检数据
     *
     * @param deptId ç³»ç»Ÿå¯¹åº”库区编码
     * @param start  èµ·å§‹æ—¶é—´
     * @param end    æˆªæ­¢æ—¶é—´
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1404接口数据开始同步------------------");
        //同步数据，只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1304);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz35Plan> list = fzzy35Sync1403Rep.findDate("3", start, end);

            if (null == list || list.isEmpty()) {
                return;
            }

            Api1404 api1404;
            List<Fz35PlanDetail> fz35PlanDetails;
            Api1105 api1105;
            for (Fz35Plan fz35Plan : list) {

                fz35PlanDetails = fzzy35Sync1404Rep.findDate(fz35Plan.getId());
                if (null == fz35PlanDetails || fz35PlanDetails.isEmpty()) {
                    continue;
                }
                for (Fz35PlanDetail fz35PlanDetail : fz35PlanDetails) {
                    api1105 = commonService.getApi1105Cache(fz35PlanDetail.getDepotId());
                    if (null == api1105) {
                        continue;
                    }
                    api1404 = new Api1404();
                    api1404.setJhmxdh(fz35PlanDetail.getId());
                    api1404.setLhjhdh(fz35PlanDetail.getPlanId());
                    api1404.setLspzdm(fz35PlanDetail.getFoodVariety());
                    api1404.setLsdjdm(fz35PlanDetail.getFoodLevel());
                    api1404.setLsxzdm(fz35PlanDetail.getFoodType());
                    api1404.setShnd(fz35PlanDetail.getYear());
                    api1404.setLhhwdm(fz35PlanDetail.getDepotId());
                    api1404.setLhsl(fz35PlanDetail.getPlanNum());
                    api1404.setLhlx(fz35PlanDetail.getType());
                    api1404.setCzbz(Constant.CZBZ_I);
                    api1404.setZhgxsj(new Date());
                    api1404.setKqdm(kqdm);
                    api1404.setBizId(fz35PlanDetail.getId());
                    api1404Rep.save(api1404);
                }
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败：" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }

}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1310Rep.java

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

import com.fzzy.async.fzzy35.entity.Fz35Quality;
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 2023-05-14 19:55
 */
public interface Fzzy35Sync1310Rep extends JpaRepository<Fz35Quality, String> {

    /**
     * æ ¹æ®æ—¶é—´æ®µæŸ¥è¯¢ç²®æƒ…数据
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz35Quality where time >=:start and time <:end order by time ")
    List<Fz35Quality> findDateByTime(@Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1403Rep.java

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

import com.fzzy.async.fzzy35.entity.Fz35Plan;
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 2023-05-14 19:55
 */
public interface Fzzy35Sync1403Rep extends JpaRepository<Fz35Plan, String> {

    /**
     *
     * @param start
     * @param end
     * @return
     */
    @Query("from Fz35Plan where type =:planType and createTime >=:start and createTime <:end order by createTime ")
    List<Fz35Plan> findDate(@Param("planType") String planType, @Param("start") Date start, @Param("end") Date end);
}

 src/main/java/com/fzzy/async/fzzy35/repository/Fzzy35Sync1404Rep.java

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

import com.fzzy.async.fzzy35.entity.Fz35PlanDetail;
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 chen
 * @date 2023-05-14 19:55
 */
public interface Fzzy35Sync1404Rep extends JpaRepository<Fz35PlanDetail, String> {

    /**
     *
     * @return
     */
    @Query("from Fz35PlanDetail where planId =:planId ")
    List<Fz35PlanDetail> findDate(@Param("planId") String planId);
}

 src/main/java/com/fzzy/push/impl/ComPushService12.java

@@ -119,7 +119,7 @@

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1202Rep.updateStatus(data.getId(), Constant.CZBZ_U);
                    api1202Rep.updateStatus(data.getRkywdh(), Constant.CZBZ_U);
                }
            }
        }
@@ -147,7 +147,7 @@

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1203Rep.updateStatus(data.getBizId(), Constant.CZBZ_U);
                    api1203Rep.updateStatus(data.getRkjydh(), Constant.CZBZ_U);
                }
            }
        }
@@ -204,7 +204,7 @@

            if (responseDto.getSuccess() == 0) {
                if (Constant.CZBZ_I.equals(data.getCzbz())) {
                    api1205Rep.updateStatus(data.getId(), Constant.CZBZ_U);
                    api1205Rep.updateStatus(data.getCkywdh(), Constant.CZBZ_U);
                }
            }
        }

 src/main/java/com/fzzy/push/shjdjw2023/Shjdjw2023PushService12.java

@@ -43,15 +43,15 @@
        log.info("------->>>>粮食购销 æŽ¥å£æ¨¡å—上报开始");


        //TODO ç²®é£Ÿå…¥åº“信息
        //粮食入库信息
        pushService.pushData1202(apiRemoteService, param);
        //TODO ç²®é£Ÿå…¥åº“质检信息
        //粮食入库质检信息
        pushService.pushData1203(apiRemoteService, param);
        //TODO ç²®é£Ÿå‡ºåº“信息
        //粮食出库信息
        pushService.pushData1205(apiRemoteService, param);
        //TODO ç²®é£Ÿåº“存信息
        //粮食库存信息
        pushService.pushData1208(apiRemoteService, param);
        //TODO æŸç›Šå•ä¿¡æ¯
        //损益单信息
        pushService.pushData1209(apiRemoteService, param);



 src/main/resources/application-pro.yml

@@ -1,4 +1,4 @@
##########################  å¹¿ä¸œæ½®é˜³   ##########################
##########################  ä¸Šæµ·å˜‰å®š   ##########################
server:
  port: 8090
  jetty:
@@ -11,13 +11,13 @@
    primary:
      url: jdbc:mysql://127.0.0.1:3306/igds_api?useUnicode=true&characterEncoding=utf-8
      username: root
      password: Abc123..
      password: root
      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..
      password: root
      driver-class-name: com.mysql.jdbc.Driver
  jpa:
    #主jpa配置
@@ -38,7 +38,7 @@
          dialect: org.hibernate.dialect.MySQL5InnoDBDialect
  # Redis相关配置
  redis:
    database: 0
    database: 1
    host: 127.0.0.1
    port: 6379
    password: Abc123..
@@ -51,7 +51,6 @@
      timeout: 6000
igds:
  default:
    companyId: 5317

  file-path: D:/IGDS-API/FILE/
    companyId: 5303
  file-path: C:/app/igds-api/
  img-path: D:/IGDS/FILE/

 src/main/resources/application-pro5303.yml

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,56 @@
##########################  ä¸Šæµ·å˜‰å®š   ##########################
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: root
      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: root
      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: 5303
  file-path: C:/app/igds-api/
  img-path: D:/IGDS/FILE/