#入库获取Row优化

Junjie

13 小时以前 1817a79605b464735014a00e762e715788229a4b

 src/main/java/com/zy/core/utils/WmsOperateUtils.java

@@ -90,6 +90,7 @@
        Map<String, Object> requestParam = new LinkedHashMap<>();
        String response = null;
        int result = 0;
        long startMs = System.currentTimeMillis();
        try {
            BasStation basStation = basStationService
                    .getOne(new QueryWrapper<BasStation>().eq("station_id", request.getSourceStaNo()));
@@ -106,7 +107,7 @@
            requestParam.put("barcode", request.getBarcode());
            requestParam.put("sourceStaNo", stationNo);
            requestParam.put("locType1", request.getLocType1() == null ? 1 : request.getLocType1());
            requestParam.put("row", Utils.getInTaskEnableRow(request.getSourceStaNo()));
            requestParam.put("row", Utils.getInTaskEnableRowWithCache(request.getSourceStaNo()));
            if (request.getExtraParams() != null && !request.getExtraParams().isEmpty()) {
                requestParam.putAll(request.getExtraParams());
            }
@@ -122,19 +123,19 @@
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("code") == 200) {
                    result = 1;
                    News.info("请求WMS入库接口成功！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemInUrl,
                            JSON.toJSONString(requestParam), response);
                    News.info("请求WMS入库接口成功！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
                } else {
                    News.info("请求WMS入库接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemInUrl,
                            JSON.toJSONString(requestParam), response);
                    News.info("请求WMS入库接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
                }
            } else {
                News.info("请求WMS入库接口失败，接口未响应！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemInUrl,
                        JSON.toJSONString(requestParam), response);
                News.info("请求WMS入库接口失败，接口未响应！！！url：{}；request：{}；response：{}；cost={}ms",
                        wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
            }
        } catch (Exception e) {
            News.error("请求WMS入库接口异常！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemInUrl,
                    JSON.toJSONString(requestParam), response, e);
            News.error("请求WMS入库接口异常！！！url：{}；request：{}；response：{}；cost={}ms", wmsUrl + wmsSystemInUrl,
                    JSON.toJSONString(requestParam), response, elapsedMs(startMs), e);
        } finally {
            HttpRequestLog httpRequestLog = new HttpRequestLog();
            httpRequestLog.setName(wmsUrl + wmsSystemInUrl);
@@ -181,6 +182,7 @@
        HashMap<String, Object> requestParam = new HashMap<>();
        String response = null;
        int result = 0;
        long startMs = System.currentTimeMillis();
        try {
            List<Integer> excludeCrnList = new ArrayList<>();
            List<Integer> excludeDualCrnList = new ArrayList<>();
@@ -205,19 +207,23 @@
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("code") == 200) {
                    result = 1;
                    News.info("请求申请任务重新分配入库接口成功！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemReassignInTaskUrl,
                            JSON.toJSONString(requestParam), response);
                    News.info("请求申请任务重新分配入库接口成功！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
                            elapsedMs(startMs));
                } else {
                    News.info("请求申请任务重新分配入库接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}",
                            wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response);
                    News.info("请求申请任务重新分配入库接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
                            elapsedMs(startMs));
                }
            } else {
                News.info("请求申请任务重新分配入库接口失败，接口未响应！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemReassignInTaskUrl,
                        JSON.toJSONString(requestParam), response);
                News.info("请求申请任务重新分配入库接口失败，接口未响应！！！url：{}；request：{}；response：{}；cost={}ms",
                        wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
                        elapsedMs(startMs));
            }
        } catch (Exception e) {
            News.error("请求申请任务重新分配入库接口异常！！！url：{}；request：{}； response：{}", wmsUrl + wmsSystemReassignInTaskUrl,
                    JSON.toJSONString(requestParam), response, e);
            News.error("请求申请任务重新分配入库接口异常！！！url：{}；request：{}； response：{}；cost={}ms",
                    wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
                    elapsedMs(startMs), e);
        } finally {
            HttpRequestLog httpRequestLog = new HttpRequestLog();
            httpRequestLog.setName(wmsUrl + wmsSystemReassignInTaskUrl);
@@ -288,6 +294,7 @@
        HashMap<String, Object> requestParam = new HashMap<>();
        String response = null;
        int result = 0;
        long startMs = System.currentTimeMillis();
        try {
            requestParam.put("locNo", locNo);
            requestParam.put("row", crnRows);
@@ -304,19 +311,23 @@
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("code") == 200) {
                    result = 1;
                    News.info("请求WMS申请更换库位接口成功！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemChangeLocNoUrl,
                            JSON.toJSONString(requestParam), response);
                    News.info("请求WMS申请更换库位接口成功！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
                            elapsedMs(startMs));
                } else {
                    News.info("请求WMS申请更换库位接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}",
                            wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response);
                    News.info("请求WMS申请更换库位接口失败，接口返回Code异常！！！url：{}；request：{}；response：{}；cost={}ms",
                            wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
                            elapsedMs(startMs));
                }
            } else {
                News.info("请求WMS申请更换库位接口失败，接口未响应！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemChangeLocNoUrl,
                        JSON.toJSONString(requestParam), response);
                News.info("请求WMS申请更换库位接口失败，接口未响应！！！url：{}；request：{}；response：{}；cost={}ms",
                        wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
                        elapsedMs(startMs));
            }
        } catch (Exception e) {
            News.error("请求WMS申请更换库位接口异常！！！url：{}；request：{}；response：{}", wmsUrl + wmsSystemChangeLocNoUrl,
                    JSON.toJSONString(requestParam), response, e);
            News.error("请求WMS申请更换库位接口异常！！！url：{}；request：{}；response：{}；cost={}ms",
                    wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
                    elapsedMs(startMs), e);
        } finally {
            HttpRequestLog httpRequestLog = new HttpRequestLog();
            httpRequestLog.setName(wmsUrl + wmsSystemChangeLocNoUrl);
@@ -329,4 +340,8 @@
        return response;
    }

    private long elapsedMs(long startMs) {
        return System.currentTimeMillis() - startMs;
    }

}