上海省平台协议-增加数据相符性接口

czt

2024-06-28 54b61daf58037385cb8d46404b12a95786c7c8f3

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

@@ -15,6 +15,7 @@
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1202Rep;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1207Rep;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@@ -36,6 +37,8 @@
    private ApiCommonService commonService;
    @Autowired
    private Api1207Rep api1207Rep;
    @Autowired
    private ApiTriggerService apiTriggerService;
    @Autowired
    private ApiLogRep apiLogRep;

@@ -69,6 +72,7 @@
            Api1207 apiData;
            Api1105 api1105In;
            Api1105 api1105Out;
            List<Api1207> api1207List;
            for (Fz40InoutStockChange sysData : list) {
                //获取货位信息
                api1105Out = commonService.getApi1105Cache(sysData.getDepotIdOut());
@@ -87,7 +91,8 @@
                apiData.setTzdh(sysData.getNoticeId());
                apiData.setDcdw(kqdm);
                apiData.setDrdw(kqdm);
                apiData.setLspzdm(sysData.getFoodVariety());
                String mappingCode = apiTriggerService.getMappingCode(Constant.TRIGGER_P_LSPZ, sysData.getFoodVariety().substring(0, 3));
                apiData.setLspzdm(mappingCode);
                apiData.setDchwdm(api1105Out.getHwdm());
                apiData.setDrhwdm(api1105In.getHwdm());
                apiData.setDcrq(sysData.getChangeDate());
@@ -95,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());