优化库存同步

czt

2025-02-10 954480166aad6d24c9e9889906a0edf762f0da2a

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

@@ -1,18 +1,15 @@
package com.fzzy.async.fzzy40.impl;

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1101;
import com.fzzy.api.entity.Api1102;
import com.fzzy.api.entity.Api1112;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.entity.*;
import com.fzzy.api.utils.ContextUtil;
import com.fzzy.api.view.repository.*;
import com.fzzy.async.fzzy40.entity.Fz40OAStaff;
import com.fzzy.async.fzzy40.repository.Fzzy40Sync1112Rep;
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;

@@ -68,13 +65,13 @@
            Api1101 api1101 = api1101Rep.findById(api1102.getDwdm()).get();

            Api1112 apiData;

            List<Api1112> api1112List;
            for (Fz40OAStaff sysData : list) {
                apiData = new Api1112();
                apiData.setDwmc(api1101.getDwmc());
                apiData.setDwdm(api1101.getDwdm());
                apiData.setKqdm(api1102.getKqdm());
                apiData.setBizId(sysData.getId());
                apiData.setKqdm(api1101.getKqdm());

                apiData.setSfzhm(sysData.getSfzhm());
                apiData.setLsbm(sysData.getLsbm());
                apiData.setXzqhdm(sysData.getXzqhdm());
@@ -89,12 +86,21 @@
                apiData.setDzyx(sysData.getDzyx());
                apiData.setMz(sysData.getMz());
                apiData.setZzmm(sysData.getZzmm());
                apiData.setRylb(sysData.getZy());
                apiData.setZy(sysData.getZy());
                apiData.setQdzgzchzyzgsj(sysData.getQdzgzchzyzgsj());
                apiData.setXl(sysData.getXl());
                apiData.setXl(StringUtils.isEmpty(sysData.getXl())?"3":sysData.getXl());
                apiData.setZw(sysData.getZw());
                apiData.setCzbz(Constant.CZBZ_I);
                apiData.setRylb(sysData.getRylb());

                apiData.setZhgxsj(sysData.getUpdateTime());
                apiData.setBizId(sysData.getSfzhm());

                api1112List = api1112Rep.getDataByBizId(apiData.getBizId());
                if (null == api1112List || api1112List.isEmpty()) {
                    apiData.setCzbz(Constant.CZBZ_I);
                } else {
                    apiData.setCzbz(api1112List.get(0).getCzbz());
                }

                //保存数据
                api1112Rep.save(apiData);