优化非正常状态的出入库数据下的文件信息不同步

陈战涛

2023-05-25 7594c1e78092208fb07acecbf4d9d57ba12af7d3

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

@@ -7,13 +7,14 @@
import com.fzzy.api.utils.FileUtil;
import com.fzzy.api.view.repository.Api1109Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.async.fzzy35.entity.FileInfo;
import com.fzzy.async.fzzy35.entity.Fz35FileInfo;
import com.fzzy.async.fzzy35.entity.Fz35InoutRecord;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1109Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
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.*;

/**
@@ -46,6 +47,8 @@
    @Autowired
    private Fzzy35Sync1109Rep fzzySync1109Rep;
    @Autowired
    private Fzzy35Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
    private ApiLogRep apiLogRep;
@@ -72,7 +75,7 @@
        apiLog.setStatus(99);
        apiLog.setId(ContextUtil.getUUID());
        try {
            List<FileInfo> list = fzzySync1109Rep.listFileInfo(start, end);
            List<Fz35FileInfo> list = fzzySync1109Rep.listFileInfo(start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到文件信息------------------");
@@ -83,8 +86,23 @@
            Api1109 apiData;
            String wjlx;
            String wjmc;
            for (FileInfo sysData : list) {
            List<Api1109> api1109List;
            List<Fz35InoutRecord> listInout;
            for (Fz35FileInfo sysData : list) {
                if (StringUtils.isEmpty(sysData.getBizId())) {
                    continue;
                }
                //根据图片id查询对应出入库信息
                listInout = fzzySync1202Rep.listInoutRecordById(sysData.getBizId());
                if(null == listInout || listInout.isEmpty()){
                    continue;
                }
                //若出入库信息为删除或者错误状态，则不同步
                if("DEL".equals(listInout.get(0).getRecordStatus()) || "ERROR".equals(listInout.get(0).getRecordStatus())){
                    continue;
                }
                //若出入库信息中入库重量为空或为0，则不同步
                if(null == listInout.get(0).getRecordWeight() || listInout.get(0).getRecordWeight() == 0){
                    continue;
                }
                //只同步称重
@@ -120,7 +138,6 @@
                    apiData.setWjlx(wjlx);

                    //操作标志及最后更新时间
                    apiData.setCzbz(Constant.CZBZ_I);
                    apiData.setZhgxsj(new Date());

                    //业务id、库区编码、同步时间
@@ -128,6 +145,13 @@
                    apiData.setKqdm(kqdm);
                    apiData.setSyncTime(new Date());

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

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