czt
2024-11-25 eb28cab79dc230ed71771f3984bcab69a435e53b
接口调整,增加封仓确认单同步
已修改12个文件
已添加11个文件
607 ■■■■■ 文件已修改
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotStatusConfirm.java 109 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1213.java 130 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1213Rep.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1504.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2442.java 68 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2443.java 26 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2444.java 28 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2445.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2446.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2447.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2448.java 27 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2449.java 28 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1205.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1209.java 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1504.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sx2024/SX2024ApiRemoteService.java 12 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sx2024/data/SX2024Api1209.java 16 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/push/sx2024/data/SX2024Api1504.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application-dev.yml 30 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application-pro5349.yml 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/application.yml 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/fzzy/async/fzzy40/Fzzy40SyncService12.java
@@ -43,6 +43,8 @@
    @Autowired
    private Fzzy40Sync1212 fzzySync1212;
    @Autowired
    private Fzzy40Sync1213 fzzySync1213;
    @Autowired
    private Fzzy40Sync1109 fzzySync1109;
    @Autowired
    private Fzzy40Sync2102 fzzySync2102;
@@ -97,6 +99,8 @@
        //账面库存信息同步
        fzzySync1211.syncData(kqdm, deptId, start, end);
        //封仓确认信息同步
        fzzySync1213.syncData(kqdm, deptId, start, end);
        /*-----各省独有接口信息同步-----*/
        //上海市平台2023版
src/main/java/com/fzzy/async/fzzy40/entity/Fz40DepotStatusConfirm.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,109 @@
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: ä»“房状态确认表
 * @author:
 * @update-time:
 */
@Data
@Entity
@Table(name = "D_DEPOT_STATUS_CONFIRM")
public class Fz40DepotStatusConfirm {
    /**
     * 21yyyyMMdd+四位顺序号
     * 21202405041234
     */
    @Id
    @Column(name = "fcqrdh", length = 14)
    @PropertyDef(label = "封仓确认单号", description = "根据一定的规则生成")
    private String fcqrdh;
    @Column(name = "COMPANY_ID_", length = 10)
    @PropertyDef(label = "组织编码")
    private String companyId;
    @Column(name = "DEPT_ID_", length = 50)
    @PropertyDef(label = "库区编码")
    private String deptId;
    @Column(name = "DEPOT_ID_", length = 28)
    @PropertyDef(label = "货位编码")
    private String depotId;
    /*** ------------------------确认内容-------------------------------------**/
    @Column(name = "fcrq")
    @PropertyDef(label = "封仓日期", description = "yyyy-MM-dd")
    private Date fcrq;
    @Column(name = "FOOD_VARIETY_", length = 20)
    @PropertyDef(label = "粮食品种")
    private String foodVariety;
    @Column(name = "FOOD_TYPE_", length = 20)
    @PropertyDef(label = "粮食性质")
    private String foodType;
    @Column(name = "FOOD_LEVEL_", length = 10)
    @PropertyDef(label = "粮食等级")
    private String foodLevel;
    @Column(name = "FOOD_LOCATION_ID_", length = 20)
    @PropertyDef(label = "产地名称代码")
    private String foodLocationId;
    @Column(name = "FOOD_LOCATION_", length = 40)
    @PropertyDef(label = "产地名称")
    private String foodLocation;
    @Column(name = "FOOD_YEAR_", length = 10)
    @PropertyDef(label = "收货年度")
    private String foodYear;
    @Column(name = "COUNTRY_", length = 10)
    @PropertyDef(label = "国别")
    private String country;
    @Column(name = "STORE_KEEPER_NAME_", length = 64)
    @PropertyDef(label = "保管员", description = "中文名称")
    private String storeKeeperName;
    @Column(name = "fcsl")
    @PropertyDef(label = "封仓数量", description = "所有入库信息中的净重之和,单位KG")
    private Double fcsl = 0.0;
    /*** ------------------------公共字段-------------------------------------**/
    @Column(name = "APPLY_USER_", length = 50)
    @PropertyDef(label = "申请人")
    private String applyUser;
    @Column(name = "DEPT_AUDIT_USER_", length = 50)
    @PropertyDef(label = "部门审核人")
    private String deptAuditUser;
    @Column(name = "LEADER_AUDIT_USER_", length = 50)
    @PropertyDef(label = "领导审核人")
    private String leaderAuditUser;
    // å¤‡æ³¨
    @Column(name = "REMARKS_", length = 200)
    @PropertyDef(label = "备注信息")
    private String remarks;
    @Column(name = "UPDATE_TIME_")
    @PropertyDef(label = "数据更新时间")
    private Date updateTime;
}
src/main/java/com/fzzy/async/fzzy40/impl/Fzzy40Sync1213.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,130 @@
package com.fzzy.async.fzzy40.impl;
import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1105;
import com.fzzy.api.entity.Api1213;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.service.ApiCommonService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.Api1213Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy40.entity.Fz40DepotStatusConfirm;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1213Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.List;
/**
 * @author czt
 * å°ä»“确认单
 */
@Slf4j
@Component
public class Fzzy40Sync1213 {
    @Autowired
    private Fzzy40Sync1213Rep fzzy40Sync1213Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1213Rep api1213Rep;
    @Autowired
    private ApiCommonService commonService;
    @Autowired
    private ApiLogRep apiLogRep;
    /**
     * åŒæ­¥å°ä»“确认信息
     *
     * @param deptId
     * @param start
     * @param end
     */
    public void syncData(String kqdm, String deptId, Date start, Date end) {
        log.info("-------------1213接口数据开始同步------------------");
        //同步数据,只记录失败的信息
        ApiLog apiLog = new ApiLog();
        apiLog.setType(ApiLog.TYPE_SYNC);
        apiLog.setKqdm(deptId);
        apiLog.setUploadTime(new Date());
        apiLog.setInteId(Constant.API_CODE_1208);
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<Fz40DepotStatusConfirm> list = fzzy40Sync1213Rep.listData(deptId, start, end);
            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到封仓确认信息------------------");
                return;
            }
            Api1213 apiData;
            Api1105 api1105;
            List<Api1213> api1213List;
            for (Fz40DepotStatusConfirm depotStatusConfirm : list) {
                //获取货位信息
                api1105 = commonService.getApi1105Cache(depotStatusConfirm.getDepotId());
                if (null == api1105) {
                    continue;
                }
                apiData = new Api1213();
                BeanUtils.copyProperties(depotStatusConfirm, apiData);
                apiData.setFcqrdh(depotStatusConfirm.getFcqrdh());
                apiData.setBizId(depotStatusConfirm.getFcqrdh());
                apiData.setKqdm(kqdm);
                apiData.setHwdm(api1105.getHwdm());
                //粮食品种
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, depotStatusConfirm.getFoodVariety().substring(0, 3));
                apiData.setLspzdm(mappingCode);
                //粮食性质
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSXZ, depotStatusConfirm.getFoodType());
                apiData.setLsxzdm(mappingCode);
                //粮食等级
                mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSDJ, depotStatusConfirm.getFoodLevel());
                apiData.setLsdjdm(mappingCode);
                //产地代码
                mappingCode = commonService.getFoodLocationIdFromCache(depotStatusConfirm.getFoodLocation());
                if (StringUtils.isEmpty(mappingCode)) {
                    mappingCode = apiData.getHwdm().substring(2, 8);
                }
                apiData.setCd(mappingCode);
                //年度
                apiData.setShnd(depotStatusConfirm.getFoodYear());
                if(StringUtils.isEmpty(depotStatusConfirm.getCountry())){
                    apiData.setGb("156");
                }
                apiData.setBgy(depotStatusConfirm.getStoreKeeperName());
                apiData.setFcsqr(depotStatusConfirm.getApplyUser());
                apiData.setBmshr(depotStatusConfirm.getDeptAuditUser());
                apiData.setLdshr(depotStatusConfirm.getLeaderAuditUser());
                apiData.setZhgxsj(new Date());
                api1213List = api1213Rep.getDataById(apiData.getBizId());
                if (null == api1213List || api1213List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1213List.get(0).getCzbz());
                }
                //保存数据
                api1213Rep.save(apiData);
            }
        } catch (Exception e) {
            log.error("---同步失败----{}", e);
            apiLog.setResult("同步失败:" + e.getMessage());
            apiLogRep.save(apiLog);
        }
    }
}
src/main/java/com/fzzy/async/fzzy40/repository/Fzzy40Sync1213Rep.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,24 @@
package com.fzzy.async.fzzy40.repository;
import com.fzzy.async.fzzy40.entity.Fz40DepotStatusConfirm;
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 Fzzy40Sync1213Rep extends JpaRepository<Fz40DepotStatusConfirm, String> {
    /**
     * æ ¹æ®åº“区编码及时间获取账面库存信息
     *
     * @return
     */
    @Query("from Fz40DepotStatusConfirm where deptId=:deptId and updateTime >=:start and updateTime <:end order by updateTime ")
    List<Fz40DepotStatusConfirm> listData(@Param("deptId") String deptId, @Param("start") Date start, @Param("end") Date end);
}
src/main/java/com/fzzy/push/nx2023/dto/Nx2023Api1504.java
@@ -68,7 +68,7 @@
    private String corgcode;
    @PropertyDef(label = "统一单位编码")
    @JsonProperty("xqydm")
    @JsonProperty("tydwbm")
    private String tydwbm;
    @PropertyDef(label = "统一库区编码")
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2442.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,68 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-封仓确认单
 * @Author CZT
 * @Date 2024/10/28 15:20
 */
@Data
public class Nx2024Api2442 implements Serializable {
    @PropertyDef(label = "封仓确认单号")
    private String fcqrdh;
    @PropertyDef(label = "统一货位编码")
    private String tyhwbm;
    @PropertyDef(label = "封仓日期")
    @JSONField(format = "yyyy-MM-dd")
    private Date fcrq;
    @PropertyDef(label = "粮食品种代码")
    private String lspzdm;
    @PropertyDef(label = "粮食性质代码")
    private String lsxzdm;
    @PropertyDef(label = "粮食等级代码")
    private String lsdjdm;
    @PropertyDef(label = "收获年度")
    private String shnd;
    @PropertyDef(label = "国别")
    private String gb;
    @PropertyDef(label = "产地")
    private String cd;
    @PropertyDef(label = "保管员")
    private String bgy;
    @PropertyDef(label = "封仓数量(公斤)")
    private Double fcsl;
    @PropertyDef(label = "封仓申请人")
    private String fcsqr;
    @PropertyDef(label = "部门审核人")
    private String bmshr;
    @PropertyDef(label = "领导审核人")
    private String ldshr;
    @PropertyDef(label = "备注")
    private String bz;
    @PropertyDef(label = "操作标志")
    private String czbz;
    @PropertyDef(label = "最后更新时间")
    private String zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2443.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-账套信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2443 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2444.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-科目信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2444 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2445.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-科目余额表
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2445 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2446.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-会计凭证信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2446 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2447.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-现金流量分配信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2447 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2448.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,27 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-固定资产卡片信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2448 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/nx2024/dto/Nx2024Api2449.java
¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,28 @@
package com.fzzy.push.nx2024.dto;
import com.alibaba.fastjson.annotation.JSONField;
import com.bstek.dorado.annotation.PropertyDef;
import lombok.Data;
import java.io.Serializable;
import java.util.Date;
/**
 * @Description å®å¤çœå¹³å°2024版-资产折旧信息
 * @Author CZT
 * @Date 2024/10/28 15:38
 */
@Data
public class Nx2024Api2449 implements Serializable {
    @PropertyDef(label = "操作标志" )
    private String czbz;
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
    @PropertyDef(label = "最后更新时间" )
    private Date zhgxsj;
}
src/main/java/com/fzzy/push/sh2023/SH2023ApiRemoteService.java
@@ -662,11 +662,11 @@
            //质检单号
            List<Api1310> api1310List = api1310Rep.getDataByHwdm(api1205.getHwdm(), "02");
            if (null != api1310List && api1310List.size() > 0) {
                api1205.setZjbgdh(apiData.getHwdm() + api1310List.get(0).getZjbgdh());
                api1205.setZjbgdh(api1310List.get(0).getZjbgdh());
            }
            //生成方式
            if(null == api1205.getScfs()){
                api1205.setScfs(1);
                api1205.setScfs("1");
            }
            if(StringUtils.isEmpty(api1205.getSdblyy())){
                api1205.setSdblyy("流程生成无补录原因");
@@ -799,6 +799,8 @@
            if(api1209.getRksl() < api1209.getRkjz()){
                api1209.setRksl(api1209.getRkjz());
            }
            api1209.setCqqrbs(apiData.getCqqrbs() + "");
            api1209.setSfch(apiData.getSfch() + "");
            //设置空属性为默认值
            changeObject(api1209);
            return api1209;
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1205.java
@@ -151,7 +151,7 @@
    private String ckjsdh;
    @PropertyDef(label = "生成方式")
    private Integer scfs;
    private String scfs;
    @PropertyDef(label = "手动补录原因")
    private String sdblyy;
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1209.java
@@ -83,7 +83,7 @@
    private Double zrshde;
    @PropertyDef(label = "是否超耗", description = "1:是,2:否")
    private Integer sfch;
    private String sfch;
    @PropertyDef(label = "超耗数量")
    private Double chsl;
@@ -95,7 +95,7 @@
    private String syyy;
    @PropertyDef(label = "出清确认标识",description = "0:未完成出清确认,1:已完成出清确认")
    private Integer cqqrbs;
    private String cqqrbs;
    @PropertyDef(label = "出清确认时间")
    @JSONField(format = "yyyy-MM-dd HH:mm:ss")
src/main/java/com/fzzy/push/sh2023/dto/SH2023Api1504.java
@@ -72,7 +72,7 @@
    private String tydwbm;
    @PropertyDef(label = "统一库区编码")
    @JsonProperty("xkqdm")
    @JsonProperty("tykqbm")
    private String tykqbm;
    @PropertyDef(label = "操作标志")
src/main/java/com/fzzy/push/sx2024/SX2024ApiRemoteService.java
@@ -11,6 +11,7 @@
import com.fzzy.api.service.ApiRemoteService;
import com.fzzy.api.service.ApiTriggerService;
import com.fzzy.api.utils.*;
import com.fzzy.api.view.repository.Api1208Rep;
import com.fzzy.api.view.repository.Api1404Rep;
import com.fzzy.api.view.repository.ApiLogRep;
@@ -43,6 +44,8 @@
    private ApiCommonService apiCommonService;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private Api1208Rep api1208Rep;
    @Autowired
    private ApiLogRep apiLogRep;
    @Autowired
@@ -573,6 +576,15 @@
            }
            //实际损耗数量赋值
            apiData.setSjsysl(api1209.getJzsysl());
            //设置品种、性质、等级、年度
            List<Api1208> api1208List = api1208Rep.findDataByHwdm(apiData.getHwdm());
            if (null != api1208List && api1208List.size() > 0) {
                apiData.setLspzdm(api1208List.get(0).getLspzdm());
                apiData.setLsxzdm(api1208List.get(0).getLsxzdm());
                apiData.setLsdjdm(api1208List.get(0).getLsdjdm());
                apiData.setShnd(api1208List.get(0).getShnd());
            }
            return apiData;
        }
        if (Constant.API_CODE_1210.equals(inteId)) {
src/main/java/com/fzzy/push/sx2024/data/SX2024Api1209.java
@@ -143,6 +143,22 @@
    @JsonProperty("BZ")
    private String bz;
    @PropertyDef(label = "粮食品种代码")
    @JsonProperty("LSPZDM")
    private String lspzdm;
    @PropertyDef(label = "粮食性质代码")
    @JsonProperty("LSXZDM")
    private String lsxzdm;
    @PropertyDef(label = "粮食等级代码")
    @JsonProperty("LSDJDM")
    private String lsdjdm;
    @PropertyDef(label = "收获年度")
    @JsonProperty("SHND")
    private String shnd;
    @PropertyDef(label = "操作标志")
    @JsonProperty("CZBZ")
    private String czbz;
src/main/java/com/fzzy/push/sx2024/data/SX2024Api1504.java
@@ -71,7 +71,7 @@
    private String tydwbm;
    @PropertyDef(label = "统一库区编码")
    @JsonProperty("xkqdm")
    @JsonProperty("tydwbm")
    private String tykqbm;
    @PropertyDef(label = "操作标志")
src/main/resources/application-dev.yml
@@ -6,34 +6,52 @@
    #主数据源
    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_5306?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_002?useUnicode=true&useSSL=false&characterEncoding=utf-8     #潮阳库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_001_gkxc?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-港口新仓 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_002_lcck?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-老仓仓库 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_003_jzys?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-金灶一所 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_004_jzes?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-金灶二所 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_005_xcck?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-西胪新仓仓库 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_006_dfck?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-西胪东凤仓库 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_007_zsck?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-直属仓库 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_008_lyzyz?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-粮油转运站 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_009_hxls?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-河溪粮食管理所 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_010_hpls?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-和平粮食管理所 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_011_hmls?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-海门粮食管理所 1
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_012_hsmy?useUnicode=true&useSSL=false&characterEncoding=utf-8 #潮阳-恒生米业
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5317_201?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_5322?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     #惠州惠新
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5326?useUnicode=true&useSSL=false&characterEncoding=utf-8     #惠州惠新
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5327?useUnicode=true&useSSL=false&characterEncoding=utf-8     #武汉黄陂军粮
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5329?useUnicode=true&useSSL=false&characterEncoding=utf-8     #广东佛山禅城区
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5348?useUnicode=true&useSSL=false&characterEncoding=utf-8     #广东汕头潮南
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5349_sx?useUnicode=true&useSSL=false&characterEncoding=utf-8  #陕西柞水县
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5352?useUnicode=true&useSSL=false&characterEncoding=utf-8     #广东增城冷链-天润增城库
#      url: jdbc:mysql://127.0.0.1:3306/igds_api_5354?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_4.0_5016?useUnicode=true&useSSL=false&characterEncoding=utf-8  #大湾区
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5303?useUnicode=true&useSSL=false&characterEncoding=utf-8  #上海嘉定
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5306?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_4.0_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_5322?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  #惠州惠新
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5326?useUnicode=true&useSSL=false&characterEncoding=utf-8  #惠州惠新
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5327?useUnicode=true&useSSL=false&characterEncoding=utf-8  #武汉黄陂军粮
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5348?useUnicode=true&useSSL=false&characterEncoding=utf-8  #广东汕头潮南
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5349?useUnicode=true&useSSL=false&characterEncoding=utf-8  #陕西柞水县
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5352?useUnicode=true&useSSL=false&characterEncoding=utf-8  #广东增城冷链-天润增城库
#      url: jdbc:mysql://127.0.0.1:3306/igds_4.0_5354?useUnicode=true&useSSL=false&characterEncoding=utf-8  #广东增城-东部粮油中心库
      username: root
      password: Abc123..
      driver-class-name: com.mysql.jdbc.Driver
src/main/resources/application-pro5349.yml
@@ -1,6 +1,6 @@
##########################  é™•西柞水县   ##########################
server:
  port: 8090
  port: 8091
  jetty:
    max-http-post-size: 209715200
  tomcat:
@@ -9,7 +9,7 @@
  datasource:
    #主数据源
    primary:
      url: jdbc:mysql://127.0.0.1:3306/igds_api?useUnicode=true&characterEncoding=utf-8&useSSL=false
      url: jdbc:mysql://127.0.0.1:3306/igds_api_2024?useUnicode=true&characterEncoding=utf-8&useSSL=false
      driver-class-name: com.mysql.jdbc.Driver
      username: root
      password: Fzzy@#$%5432..K
src/main/resources/application.yml
@@ -1,7 +1,7 @@
##########################  Server   ##########################
spring:
  profiles:
    active: dev
    active: pro
  application:
    name: igds-api
  main: