提交库存同步

陈战涛

2023-05-10 bca371e7ecc906ec824630c32aefd29a7a4f68d0

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

@@ -11,8 +11,8 @@
import com.fzzy.api.view.repository.Api1203Rep;
import com.fzzy.api.view.repository.ApiLogRep;
import com.fzzy.api.view.repository.GbCheckItemRep;
import com.fzzy.async.fzzy35.entity.InoutRecord;
import com.fzzy.async.fzzy35.entity.CheckItem;
import com.fzzy.async.fzzy35.entity.Fz35InoutRecord;
import com.fzzy.async.fzzy35.entity.Fz35CheckItem;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1202Rep;
import com.fzzy.async.fzzy35.repository.Fzzy35Sync1203Rep;
import lombok.extern.slf4j.Slf4j;
@@ -71,7 +71,7 @@
        apiLog.setId(ContextUtil.getUUID());
        try {
            //获取粮食入库记录信息
            List<InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);
            List<Fz35InoutRecord> list = fzzySync1202Rep.listInoutRecord(deptId, INOUT_TYPE_IN, start, end);

            if (null == list || list.isEmpty()) {
                log.info("-------------没有获取到粮食入库信息------------------");
@@ -80,17 +80,17 @@

            Api1203 apiData;
            Api1105 api1105;
            List<CheckItem> checkItems;
            List<Fz35CheckItem> fz35CheckItems;
            List<GbCheckItem> gbCheckList;
            String jyxm;
            String jyz;
            String zkj;
            String zkl;
            for (InoutRecord sysData : list) {
            for (Fz35InoutRecord sysData : list) {

                //获取入库质检信息
                checkItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId());
                if (null == checkItems || checkItems.isEmpty()) {
                fz35CheckItems = fzzySync1203Rep.listInoutCheckItem(sysData.getCheckId());
                if (null == fz35CheckItems || fz35CheckItems.isEmpty()) {
                    log.info("-------------没有获取到当前入库质检信息--------------");
                    continue;
                }
@@ -119,14 +119,14 @@
                jyz = "";
                zkj = "";
                zkl = "";
                for (CheckItem checkItem : checkItems) {
                    gbCheckList = gbCheckItemRep.findByBizCode(checkItem.getStandardId());
                for (Fz35CheckItem fz35CheckItem : fz35CheckItems) {
                    gbCheckList = gbCheckItemRep.findByBizCode(fz35CheckItem.getStandardId());

                    if (gbCheckList == null || gbCheckList.isEmpty()) {
                        continue;
                    }
                    jyxm += gbCheckList.get(0).getCode() + ",";
                    jyz += checkItem.getValue() + ",";
                    jyz += fz35CheckItem.getValue() + ",";
                    zkj += "0,";
                    zkl += "0,";
                }