增加V40接口-粮情、出入库

CZT

2023-07-18 254da24705ba4daa8bf289a2c10b912fb8c53ad2

 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,8 +87,22 @@
            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;
                }
                //只同步称重
@@ -132,6 +148,8 @@
                    api1109List = api1109Rep.getDataByBizId(apiData.getBizId());
                    if(null == api1109List || api1109List.isEmpty()){
                        apiData.setCzbz(Constant.CZBZ_I);
                    }else {
                        apiData.setCzbz(api1109List.get(0).getCzbz());
                    }

                    //保存数据