优化异常处理及订单同步逻辑

zhangc

2025-01-07 aa22bc31604e33e4d86cf7f4918a26192760209b

 src/main/java/com/zy/asrs/task/handler/ReportDataHandler.java

@@ -27,6 +27,7 @@

import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
 * Created by vincent on 2020/7/7
@@ -114,7 +115,7 @@
                throw new CoolException("mes接口调用失败，返回信息:" + jsonObject);
            }
            success = true;
            return null;
            return response;

        } catch (Exception e) {
            log.error("mes接口调用失败，返回信息：{}", e.getMessage());
@@ -128,7 +129,22 @@

    @Transactional
    public ReturnT<String> stock(Map<String, Object> mesTokenInfo) {
        mesLocDetlService.delete(new EntityWrapper<MesLocDetl>().eq("1", 1));
        List<MesLocDetl> all = mesLocDetlService.selectList(new EntityWrapper<>());
        if (all != null) {
            List<Long> collect = all.stream().map(MesLocDetl::getId).collect(Collectors.toList());
            boolean del = true;
            int d = 1;
            while (del && collect.size() > 0) {
                if (collect.size() > d * 1000) {
                    mesLocDetlService.deleteBatchIds(collect.subList((d - 1) * 1000, d * 1000));
                } else {
                    mesLocDetlService.deleteBatchIds(collect.subList((d - 1) * 1000, collect.size()));
                    del = false;
                }
                d++;
            }
        }

        boolean flag = true;
        Map<String, Object> req = new HashMap<>();
        int i = 1;
@@ -155,16 +171,19 @@
                        mesLocDetl.setBatch(mesStock.getBatchNo());
                        mesLocDetl.setAnfme(mesStock.getOpAmount().getAmount().getAmount());
                        mesLocDetls.add(mesLocDetl);
                        mesLocDetlService.insert(mesLocDetl);
                    }
                } else {
                    flag = false;
                }
            }
            if (!mesLocDetls.isEmpty()) {
                mesLocDetlService.insertBatch(mesLocDetls);
                //mesLocDetlService.insertBatch(mesLocDetls);
            }
            i++;
        }
        return SUCCESS;
    }


}