优化倒仓数据同步

CZT

2023-11-29 81f8164227bd019f8fe0233e0bebfe5614bfa644

优化倒仓数据同步

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

@@ -26,4 +26,7 @@

    @Query("from Api1207 where dcdh=:dcdh ")
    List<Api1207> getDataByDcdh(@Param("dcdh") String dcdh);

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

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

@@ -72,6 +72,7 @@
            Api1207 apiData;
            Api1105 api1105In;
            Api1105 api1105Out;
            List<Api1207> api1207List;
            for (Fz40InoutStockChange sysData : list) {
                //获取货位信息
                api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
@@ -99,13 +100,19 @@
                apiData.setBzw(sysData.getBzw());
                apiData.setBzbjs(sysData.getBzbjs());
                apiData.setZxzydw(sysData.getZxzydw());
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setZhgxsj(sysData.getUpdateTime());

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

                api1207List = api1207Rep.getDataById(apiData.getDcdh());
                if (null == api1207List || api1207List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1207List.get(0).getCzbz());
                }

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

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

@@ -76,6 +76,7 @@
                api1304.setQtndjcdh(api1105.getHwdm() + fz40Gas.getBatchId());
                api1304.setJcsj(fz40Gas.getReceiveDate());
                api1304.setHwdm(api1105.getHwdm());
                api1304.setZylx("5");

                api1304 = updateGasInfo(api1304, fz40Gas.getPoints());