优化代码，移除冗余，修复bug

zhangc

2025-01-14 9c7b28c7b7cfc1c5f411d72e401a947eaba6b06b

优化代码，移除冗余，修复bug

 src/main/java/com/zy/asrs/controller/AgvBasDevpController.java

@@ -40,15 +40,17 @@

    @RequestMapping(value = "/basDevp/list/auth")
    @ManagerAuth
    public R list(@RequestParam(defaultValue = "1")Integer curr,
                  @RequestParam(defaultValue = "10")Integer limit,
                  @RequestParam(required = false)String orderByField,
                  @RequestParam(required = false)String orderByType,
                  @RequestParam Map<String, Object> param){
    public R list(@RequestParam(defaultValue = "1") Integer curr,
                  @RequestParam(defaultValue = "10") Integer limit,
                  @RequestParam(required = false) String orderByField,
                  @RequestParam(required = false) String orderByType,
                  @RequestParam Map<String, Object> param) {
        excludeTrash(param);
        EntityWrapper<AgvBasDevp> wrapper = new EntityWrapper<>();
        convert(param, wrapper);
        if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
        if (!Cools.isEmpty(orderByField)) {
            wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));
        }
        return R.ok(agvBasDevpService.selectPage(new Page<>(curr, limit), wrapper));
    }

@@ -68,7 +70,7 @@
    @ManagerAuth
    public R query(@RequestBody JSONObject param) {
        Wrapper<AgvBasDevp> wrapper = new EntityWrapper<AgvBasDevp>().eq(humpToLine(String.valueOf(param.get("key"))), param.get("val"));
        if (null != agvBasDevpService.selectOne(wrapper)){
        if (null != agvBasDevpService.selectOne(wrapper)) {
            return R.parse(BaseRes.REPEAT).add(getComment(BasDevp.class, String.valueOf(param.get("key"))));
        }
        return R.ok();
@@ -82,8 +84,8 @@

    @RequestMapping(value = "/basDevp/update/auth")
    @ManagerAuth(memo = "站点修改")
    public R update(AgvBasDevp basDevp){
        if (Cools.isEmpty(basDevp) || null==basDevp.getDevNo()){
    public R update(AgvBasDevp basDevp) {
        if (Cools.isEmpty(basDevp) || null == basDevp.getDevNo()) {
            return R.error("参数缺失");
        }
        basDevp.setModiUser(getUserId());
@@ -94,12 +96,12 @@

    @RequestMapping(value = "/basDevp/delete/auth")
    @ManagerAuth(memo = "站点删除")
    public R delete(@RequestParam String param){
    public R delete(@RequestParam String param) {
        List<AgvBasDevp> list = JSONArray.parseArray(param, AgvBasDevp.class);
        if (Cools.isEmpty(list)){
        if (Cools.isEmpty(list)) {
            return R.error("参数缺失");
        }
        for (AgvBasDevp entity : list){
        for (AgvBasDevp entity : list) {
            agvBasDevpService.delete(new EntityWrapper<>(entity));
        }
        return R.ok();
@@ -107,26 +109,26 @@

    @RequestMapping(value = "/basDevp/unbind/auth")
    @ManagerAuth(memo = "站点解绑")
    public R unbind(@RequestParam String param){
        AgvBasDevp agvBasDevp = JSONArray.parseObject(param,AgvBasDevp.class);
        if (agvBasDevp==null){
    public R unbind(@RequestParam String param) {
        AgvBasDevp agvBasDevp = JSONArray.parseObject(param, AgvBasDevp.class);
        if (agvBasDevp == null) {
            return R.error("参数缺失");
        }
        //若当前站点货位状态不为F.在库状态，则返回错误
        if(!agvBasDevp.getLocSts().equals("F")){
        if (!agvBasDevp.getLocSts().equals("F")) {
            return R.error("当前站点货位状态不为在库，无法解除绑定");
        }
        agvBasDevp.setLocSts("O");
        agvBasDevp.setBarcode("");
        agvBasDevp.setLocType2(null);
        agvBasDevpService.update(agvBasDevp,new EntityWrapper<AgvBasDevp>().eq("dev_no",agvBasDevp.getDevNo()));
        agvBasDevpService.update(agvBasDevp, new EntityWrapper<AgvBasDevp>().eq("dev_no", agvBasDevp.getDevNo()));

        return R.ok();
    }

    @RequestMapping(value = "/basDevp/export/auth")
    @ManagerAuth(memo = "站点导出")
    public R export(@RequestBody JSONObject param){
    public R export(@RequestBody JSONObject param) {
        List<String> fields = JSONObject.parseArray(param.getJSONArray("fields").toJSONString(), String.class);
        EntityWrapper<AgvBasDevp> wrapper = new EntityWrapper<>();
        Map<String, Object> map = excludeTrash(param.getJSONObject("basDevp"));
@@ -142,7 +144,7 @@
        wrapper.like("dev_no", condition);
        Page<AgvBasDevp> page = agvBasDevpService.selectPage(new Page<>(0, 10), wrapper);
        List<Map<String, Object>> result = new ArrayList<>();
        for (AgvBasDevp basDevp : page.getRecords()){
        for (AgvBasDevp basDevp : page.getRecords()) {
            Map<String, Object> map = new HashMap<>();
            map.put("id", basDevp.getDevNo());
            map.put("value", basDevp.getDevNo());
@@ -166,25 +168,25 @@
    站点明细
     */
    @RequestMapping(value = "/basDevp/detail/list/auth")
    public R basDevpDetailList(@RequestParam(defaultValue = "1")Integer curr,
                               @RequestParam(defaultValue = "10")Integer limit,
                               @RequestParam Map<String, Object> param){
    public R basDevpDetailList(@RequestParam(defaultValue = "1") Integer curr,
                               @RequestParam(defaultValue = "10") Integer limit,
                               @RequestParam Map<String, Object> param) {
        String devNo = param.get("devNo").toString();
        if (Cools.isEmpty(devNo) || !CodeDetectionUtil.carCodeDetection(devNo)){
        if (Cools.isEmpty(devNo) || !CodeDetectionUtil.carCodeDetection(devNo)) {
            throw new CoolException(devNo + "小车地码有误，请正确扫码！！！");
        }
        AgvBasDevp agvBasDevp = agvBasDevpService.selectById(devNo);
        if("F".equals(agvBasDevp.getLocSts()) || "R".equals(agvBasDevp.getLocSts())){
        if ("F".equals(agvBasDevp.getLocSts()) || "R".equals(agvBasDevp.getLocSts())) {
            //先去入库通知档找明细
            Page<AgvWaitPakin> agvWaitPakinPage = agvWaitPakinService.selectPage(new Page<>(curr, limit), new EntityWrapper<AgvWaitPakin>()
                    .eq("supp_code", agvBasDevp.getBarcode()));
            if(agvWaitPakinPage.getRecords().size()>0){
            if (agvWaitPakinPage.getRecords().size() > 0) {
                return R.ok(agvWaitPakinPage);
            }else {
            } else {
                //如果入库通档明细为空，则去工作档找明细
                AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>()
                        .eq("loc_no", agvBasDevp.getDevNo())
                        .or().eq("source_loc_no",agvBasDevp.getDevNo()));
                        .or().eq("source_loc_no", agvBasDevp.getDevNo()));
                if (Cools.isEmpty(agvWrkMast)) {
                    Page<AgvLocDetl> agvLocDetlPage = agvLocDetlService.selectPage(new Page<>(curr, limit), new EntityWrapper<AgvLocDetl>()
                            .eq("supp_code", agvBasDevp.getBarcode()));
@@ -198,7 +200,7 @@
                Page<AgvWrkDetl> agvWrkDetlPage = agvWrkDetlService.selectPage(new Page<>(curr, limit), new EntityWrapper<AgvWrkDetl>()
                        .eq("wrk_no", agvWrkMast.getWrkNo()));

                if(agvWrkDetlPage.getRecords().size()>0){
                if (agvWrkDetlPage.getRecords().size() > 0) {
                    return R.ok(agvWrkDetlPage);
                }
            }
@@ -208,7 +210,7 @@
    }

    @RequestMapping(value = "/basDevp/visualized/list/auth")
    public R visualizedList(@RequestBody JSONObject param){
    public R visualizedList(@RequestBody JSONObject param) {

        String stationCode = param.get("stationCode").toString();

@@ -216,26 +218,28 @@

        return R.ok(result);
    }

    @RequestMapping(value = "/basDevp/visualized/list/auth/v2")
    public R visualizedList(@RequestParam String stationCode){
    public R visualizedList(@RequestParam String stationCode) {

        Map<String, Object> result = agvBasDevpService.getAgvBasDevpDtoByStationCode(stationCode);

        return R.ok(result);
    }

    /*
    任务完成
     */
    @RequestMapping(value = "/basDevp/visualized/container/moveOut")
    @ManagerAuth(memo = "确认出库")
    public R visualiZedContainerMoveOut(@RequestBody Map<String,Object> map) {
    public R visualiZedContainerMoveOut(@RequestBody Map<String, Object> map) {

        String barcode = map.get("barcode").toString();
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L));
        if (agvWrkMast == null){
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts", 205L));
        if (agvWrkMast == null) {
            R.error("工作档不存在");
        }
        if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){
        if (agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110) {
            throw new CoolException("工作号为" + agvWrkMast.getWrkNo() + "类型不为101.出库，无法执行货架离场任务，请重新选择站点。");
        }

@@ -251,14 +255,14 @@
    */
    @RequestMapping(value = "/basDevp/visualized/container/moveOut2")
    @ManagerAuth(memo = "确认出库2")
    public R visualiZedContainerMoveOut2(@RequestBody Map<String,Object> map) {
    public R visualiZedContainerMoveOut2(@RequestBody Map<String, Object> map) {

        String barcode = map.get("barcode").toString();
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L));
        if (agvWrkMast == null){
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts", 205L));
        if (agvWrkMast == null) {
            return R.error("工作档不存在");
        }
        if(agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110){
        if (agvWrkMast.getIoType() != 101 && agvWrkMast.getIoType() != 110) {
            throw new CoolException("工作号为" + agvWrkMast.getWrkNo() + "类型不为101.出库，无法执行货架离场任务，请重新选择站点。");
        }

@@ -274,13 +278,19 @@
     */
    @RequestMapping(value = "/basDevp/visualized/container/pickIn")
    @ManagerAuth(memo = "已拣料回库")
    public R visualiZedPickIn(@RequestBody Map<String,Object> map){
    public R visualiZedPickIn(@RequestBody Map<String, Object> map) {
        if (Cools.isEmpty(map.get("devNo"))) {
            return R.error("站点不能为空");
        }
        if (Cools.isEmpty(map.get("barcode"))) {
            return R.error("货架码不能为空");
        }
        List<AgvWrkMast> agvWrkMastList = new ArrayList<>();
        String devNo = map.get("devNo").toString();
        String barcode = map.get("barcode").toString();
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts",205L));
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", barcode).eq("wrk_sts", 205L));
        if (agvWrkMast != null) {
            if(agvWrkMast.getIoType() == 101){
            if (agvWrkMast.getIoType() == 101) {
                throw new CoolException("工作号为" + agvWrkMast.getWrkNo() + "类型为101.出库，无法执行拣料入库任务，请重新选择站点。");
            }
            agvWrkMast.setLocNo(devNo);
@@ -291,14 +301,13 @@
        }



        return R.ok("生成拣料回库任务成功");
    }

    private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper){
        for (Map.Entry<String, Object> entry : map.entrySet()){
    private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper) {
        for (Map.Entry<String, Object> entry : map.entrySet()) {
            String val = String.valueOf(entry.getValue());
            if (val.contains(RANGE_TIME_LINK)){
            if (val.contains(RANGE_TIME_LINK)) {
                String[] dates = val.split(RANGE_TIME_LINK);
                wrapper.ge(entry.getKey(), DateUtils.convert(dates[0]));
                wrapper.le(entry.getKey(), DateUtils.convert(dates[1]));

 src/main/java/com/zy/asrs/controller/AgvMobileController.java

@@ -77,7 +77,7 @@
    @RequestMapping("/pick/again/auth")
    @ManagerAuth(memo = "再次拣料")
    public R pickAgain(@RequestBody PickParam pickParams) {
        if (pickParams == null ) {
        if (pickParams == null) {
            return R.error("缺少参数");
        }
        agvMobileService.pickAgain(pickParams, 1l);
@@ -177,6 +177,9 @@
            return R.error("缺少参数");
        }
        for (AgvMobileStartParam.Pda pda : params.getPad()) {
            if (pda == null || Cools.isEmpty(pda.getContainerCode())) {
                return R.error("缺少容器参数");
            }
            pda.setContainerType(Short.valueOf(pda.getContainerCode().substring(0, 2)));
            workService.emptyPlateIn(pda.getDevNo(), pda.getContainerCode(), pda.getContainerType(), getUserId(), false);
        }
@@ -416,7 +419,7 @@

        AgvLocMast agvLocMastByContainerCode = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("barcode", containerCode));
        AgvLocMast agvLocMastByLocNo = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", locNo));
        if (agvLocMastByLocNo==null){
        if (agvLocMastByLocNo == null) {
            return R.error("库位不存在");
        }
        String barcode1 = agvLocMastByLocNo.getBarcode();

 src/main/java/com/zy/asrs/service/impl/AgvMobileServiceImpl.java

@@ -654,6 +654,9 @@
    @Transactional
    public String allocationIn(AgvMobileStartPakin param, Long userId) {
        Date now = new Date();
        if (Cools.isEmpty(param.getBarcode())) {
            throw new CoolException("请输入货架码");
        }
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", param.getBarcode()));
        if (Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("暂无当前货架码的任务");
@@ -731,6 +734,9 @@
    @Synchronized
    public String empIn(AgvMobileStartPakin param, Long userId) {
        Date now = new Date();
        if (Cools.isEmpty(param.getBarcode())) {
            throw new CoolException("请输入货架码");
        }
        AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode", param.getBarcode()));
        if (Cools.isEmpty(agvWrkMast)) {
            throw new CoolException("工作档中没有此站点任务");

 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java

@@ -1036,7 +1036,7 @@
        od.setDevNo(odParam.getDevNo());
        //自由项
        if (!Cools.isEmpty(odParam.getBatch()) || !Cools.isEmpty(odParam.getBFree1())) {
            od.setBrand((Cools.isEmpty(odParam.getBatch()) ? "" : odParam.getBatch()) + "__" + (Cools.isEmpty(odParam.getBFree1()) ? "" : odParam.getBFree1()));
            od.setBatch((Cools.isEmpty(odParam.getBatch()) ? "" : odParam.getBatch()) + "__" + (Cools.isEmpty(odParam.getBFree1()) ? "" : odParam.getBFree1()));
        }
        od.setWeight(odParam.getINum());
        od.setVolume(odParam.getIinvexchrate());

 src/main/java/com/zy/asrs/task/AgvWarnScheduler.java

@@ -1,6 +1,5 @@
package com.zy.asrs.task;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
@@ -87,7 +86,10 @@
        HashMap<String, Object> sendData = new HashMap<>();
        for (AgvWarn agvWarn : agvWarnList) {
            Integer warnTime = getWarnTime(agvWarn.getTimes(), first.getValue(), second.getValue(), third.getValue());
            DateTime begin = DateUtil.parse(agvWarn.getBeginTime(), "yyyy-MM-dd HH:mm:ss");
            Date begin = DateUtil.parse(agvWarn.getBeginTime(), "yyyy-MM-dd HH:mm:ss");
            if (DateUtil.offsetMinute(agvWarn.getAppeTime(), -3).after(begin)) {
                begin = agvWarn.getAppeTime();
            }
            if (DateUtil.offsetMinute(new Date(), -warnTime).after(begin)) {
                buffer = new StringBuffer();
                buffer.append(processRegion(agvs, agvWarn.getRobotCode()) + "[" + agvWarn.getRobotCode() + "]号AGV小车报警了\n");
@@ -95,19 +97,21 @@
                if (!Cools.isEmpty(agvWarn.getSourceLocNo())) {
                    buffer.append("从:[" + agvWarn.getSourceLocNo() + "]到[" + agvWarn.getLocNo() + "]\n");
                }
                buffer.append("报警开始时间:" + agvWarn.getBeginTime() + "\n");
                buffer.append("当前时间:" + DateUtil.formatDateTime(new Date()) + "\n");
                int i = agvWarn.getTimes() + 1;
                //buffer.append("报警开始时间:" + agvWarn.getBeginTime() + "\n");
                buffer.append("报警开始时间:" + DateUtil.formatDateTime(begin) + "\n");
                buffer.append("当前时间:" + DateUtil.formatDateTime(new Date()));
                //int i = agvWarn.getTimes() + 1;
                //buffer.append("第[" + i + "]次报警");
                HashMap<String, Object> param = new HashMap<>();
                HashMap<String, Object> data = new HashMap<>();
                data.put("content", buffer.toString());
                param.put("msgtype", "text");
                param.put("text", data);
                //log.info("发送报警信息：{}", JSON.toJSONString(param));

                sendData.put(agvWarn.getRobotCode() + agvWarn.getWarnContent(), param);
            }
            for (HashMap.Entry<String, Object> entry : sendData.entrySet()) {
                log.info("发送报警信息：{}", JSON.toJSONString(entry.getValue()));
                String response = null;
                try {
                    response = new HttpHandler.Builder().setUri(url.getValue()).setJson(JSON.toJSONString(entry.getValue())).setHttps(true).build().doPost();
@@ -117,9 +121,8 @@
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.get("errmsg").equals("ok")) {
                    agvWarn.setTimes(agvWarn.getTimes() + 1);
                    agvWarn.setModiTime(new Date());
                    agvWarnService.updateById(agvWarn);
                    //发送成功
                    return;
                } else {
                    log.error("发送失败，错误信息：{}", jsonObject.get("errmsg"));
                }

 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java

@@ -1,6 +1,5 @@
package com.zy.asrs.task;

import cn.hutool.core.date.StopWatch;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
@@ -63,8 +62,6 @@
    @Scheduled(fixedDelay = 600000)
    //@Async("orderThreadPool")
    public void completeAndReport() {
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        String erpReport = Parameter.get().getErpReport();
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
            List<Order> orders = orderService.selectComplete();
@@ -91,8 +88,6 @@
                }
            }
        }
        stopWatch.stop();
        log.info("定时任务完成，耗时：{}ms", stopWatch.getTotalTimeMillis());
    }

    //@Scheduled(cron = "* 0/5 * * * ? ")
@@ -132,7 +127,6 @@
        } finally {
            page++;
        }
        log.info("分页查询完毕，{}", page);
    }

}

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

@@ -180,7 +180,7 @@
            childInfo.setIrowno(orderDetl.getItemNum());
            childInfo.setCInvCode(orderDetl.getMatnr());
            childInfo.setIQuantity(orderDetl.getQty() - (orderDetl.getReportQty() == null ? 0D : orderDetl.getReportQty()) + "");
            String batch = orderDetl.getBrand();
            String batch = orderDetl.getBatch();
            if (Cools.isEmpty(batch)) {
                childInfo.setCBatch("");
                childInfo.setBFree1("");