优化客户信息同步

CZT

2023-08-10 92e9a188a146b3807909901cc9f6496a52700c23

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

@@ -2,19 +2,19 @@

import com.fzzy.api.Constant;
import com.fzzy.api.entity.Api1109;
import com.fzzy.api.entity.Api1201;
import com.fzzy.api.entity.ApiLog;
import com.fzzy.api.utils.ContextUtil;
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.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 +46,8 @@

    @Autowired
    private Fzzy35Sync1109Rep fzzySync1109Rep;
    @Autowired
    private Fzzy35Sync1202Rep fzzySync1202Rep;
    @Autowired
    private Api1109Rep api1109Rep;
    @Autowired
@@ -85,10 +87,24 @@
            String wjlx;
            String wjmc;
            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;
                }
                //只同步称重
                if(BIZ_TAG_WEIGHT_FULL.equals(sysData.getBizTag()) || BIZ_TAG_WEIGHT_EMPTY.equals(sysData.getBizTag())){
                    wjlx = "";