四期

zhangc

2025-03-05 029b996ab6f5d8bf9c4ef5f97db635984fc59858

四期

 src/main/java/com/zy/Boot.java

@@ -11,6 +11,7 @@
@SpringBootApplication
public class Boot extends SpringBootServletInitializer {


    public static void main(String[] args) {
        RandomValidateCodeUtil.init();
        SpringApplication.run(Boot.class, args);
@@ -22,4 +23,5 @@
        return builder.sources(Boot.class);
    }


}

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

@@ -170,6 +170,9 @@
    end{
        @Transactional
        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {



            //修改AGV工作档的工作状态为205.工作完成
            agvWrkMast.setWrkSts(205L);

@@ -196,6 +199,7 @@
            //修改AGV工作档的工作状态为203.任务开始
            agvWrkMast.setWrkSts(203L);
            agvWrkMast.setModiTime(new Date());
            agvWrkMast.setPdcType(param.getRobotCode());
            agvWrkMastService.updateById(agvWrkMast);
        }
    },

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

@@ -124,7 +124,7 @@

    private void logPost(String param, String response, boolean success) {
        apiLogService.save(
                "ESS任务回调",
                "ESS小车报警回调",
                "/phyzwms/agv/task/event/status",
                null,
                null,

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

@@ -183,6 +183,7 @@
        for (OrderDetl record : page.getRecords()) {
            Double sumAnfme = agvLocDetlService.getSumAnfme(record.getMatnr(), record.getThreeCode());
            record.setStock(sumAnfme == null ? 0 : sumAnfme);
            record.setWorkNum(0D);
        }
        return R.ok(page);
    }
@@ -239,6 +240,7 @@
                sumAnfme = agvLocDetlService.getSumAnfme(record.getMatnr(), record.getThreeCode());
            }
            record.setStock(sumAnfme == null ? 0 : sumAnfme);
            record.setWorkNum(0D);
        }
        return R.ok(page);
    }
@@ -307,6 +309,7 @@
        for (OrderDetl record : page.getRecords()) {
            Double sumAnfme = agvLocDetlService.getSumAnfmeProcessed(record.getMatnr(), record.getThreeCode());
            record.setStock(sumAnfme == null ? 0 : sumAnfme);
            record.setWorkNum(0D);
        }

        return R.ok(page);
@@ -341,6 +344,7 @@
        for (OrderDetl record : page.getRecords()) {
            Double sumAnfme = agvLocDetlService.getSumAnfmeProcessed2(record.getMatnr(), record.getThreeCode());
            record.setStock(sumAnfme == null ? 0 : sumAnfme);
            record.setWorkNum(0D);
        }

        return R.ok(page);
@@ -374,6 +378,7 @@
        for (OrderDetl record : page.getRecords()) {
            Double sumAnfme = agvLocDetlService.getSumAnfme(record.getMatnr(), record.getThreeCode());
            record.setStock(sumAnfme == null ? 0 : sumAnfme);
            record.setWorkNum(0D);
        }

        return R.ok(page);

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

@@ -14,7 +14,6 @@
import com.zy.common.model.OrderMergeVo;
import com.zy.common.model.TaskDto;
import com.zy.common.web.BaseController;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import lombok.Synchronized;
import org.springframework.beans.factory.annotation.Autowired;
@@ -270,7 +269,13 @@


            if (!staNoList.contains(locDto.getAgvStaNo())) {
                return R.error(locDto.getAgvStaNo() + "该站点已有出库任务，无法选择该站点出库");
                AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("loc_no", locDto.getAgvStaNo()));
                if (Cools.isEmpty(agvWrkMast.getPdcType())) {
                    return R.error(locDto.getAgvStaNo() + "该站点已有出库任务,工作号：" + agvWrkMast.getWrkNo() + ",物料库位号：" + agvWrkMast.getSourceLocNo() + ",任务状态：" + agvWrkMast.getWrkSts$());
                } else {
                    return R.error(locDto.getAgvStaNo() + "该站点已有出库任务,工作号：" + agvWrkMast.getWrkNo() + ",物料库位号：" + agvWrkMast.getSourceLocNo() + ",任务状态：" + agvWrkMast.getWrkSts$() + ",小车编号：" + agvWrkMast.getPdcType());

                }
            }
        }
        //如果所有库都没有库存，则返回

 src/main/java/com/zy/asrs/entity/OrderDetl.java

@@ -305,6 +305,9 @@
    @TableField("dev_no")
    private String devNo;

    @TableField(exist = false)
    private Double workNum;

    public OrderDetl() {}

    public OrderDetl(Long orderId, String orderNo, Double anfme, Double qty, String matnr, String maktx, String batch, String specs, String model, String color, String brand, String unit, Double price, String sku, Double units, String barcode, String origin, String manu, String manuDate, String itemNum, Double safeQty, Double weight, Double length, Double volume, String threeCode, String supp, String suppCode, Integer beBatch, String deadTime, Integer deadWarn, Integer source, Integer inspect, Integer danger, Integer status, Long createBy, Date createTime, Long updateBy, Date updateTime, String memo,Integer processSts) {

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

@@ -864,7 +864,7 @@
        // TODO: å››æœŸ
        List<AgvWrkDetl> agvWrkDetls = agvWrkDetlService.selectList(new EntityWrapper<AgvWrkDetl>().eq("supp_code", param.getBarcode()));
        String factory = param.getFactory();
        AgvLocMast newLocMast = agvCommonService.getLocByLocRule(3, 1, factory,false);
        AgvLocMast newLocMast = agvCommonService.getLocByLocRule20(3, 1, factory,false);
        if (newLocMast == null) {
            throw new CoolException("无可用库位");
        }

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

@@ -742,7 +742,7 @@
//                }
//            }
            // é¢„ç•™20个库位
            agvLocMast = agvCommonService.getLocByLocRule(3, 1, code,false);
            agvLocMast = agvCommonService.getLocByLocRule20(3, 1, code,false);


            String devNo = agvBasDevp.getDevNo();

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

@@ -166,21 +166,11 @@
        List<OrderDetl> orderDetls = orderDetlMapper.selectList(new EntityWrapper<OrderDetl>().eq("order_id", order.getId()));
        // ä½œä¸šæ•°é‡æ˜¯å¦ç­‰äºŽæ•°é‡
        boolean complete = true;
        if (order.getDocType() == 38) {
            for (OrderDetl orderDetl : orderDetls) {
                if (orderDetl.getAnfme() > orderDetl.getQty()) {
                    if (orderDetl.getReportQty() < orderDetl.getQty()) {
                        complete = false;
                        break;
                    }
                }
            }
        } else {
            for (OrderDetl orderDetl : orderDetls) {
                if (orderDetl.getAnfme() > orderDetl.getQty()) {
                    complete = false;
                    break;
                }

        for (OrderDetl orderDetl : orderDetls) {
            if (orderDetl.getAnfme() > orderDetl.getQty()) {
                complete = false;
                break;
            }
        }


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

@@ -284,8 +284,8 @@
            try {
                agvWrkMastHandler.autoEmptyOut(agvBasDevp);
            }catch (Exception e){
                log.error(e.getMessage());
                e.printStackTrace();
                //log.error(e.getMessage());
                //e.printStackTrace();
            }

        }

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

@@ -3,20 +3,19 @@
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
import com.zy.asrs.entity.AgvLocDetl;
import com.zy.asrs.entity.DocType;
import com.zy.asrs.entity.Order;
import com.zy.asrs.entity.OrderDetl;
import com.zy.asrs.entity.*;
import com.zy.asrs.mapper.OrderDetlMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.OrderSyncHandler;
import com.zy.common.entity.Parameter;
import com.zy.common.utils.Synchro;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.List;

/**
@@ -30,6 +29,15 @@
    private OrderSyncHandler orderSyncHandler;
    @Autowired
    private OrderService orderService;


    @Autowired
    private OrderLogService orderLogService;

    @Autowired
    private OrderDetlLogService orderDetlLogService;


    @Autowired
    private ApiLogService apiLogService;

@@ -129,4 +137,6 @@
        }
    }



}

 src/main/java/com/zy/common/service/AgvCommonService.java

@@ -178,14 +178,23 @@
                num = Integer.parseInt(config.getValue());
            }
            agvLocMasts = agvLocMastService.selectList(wrapper);
            int er = 0;
            for (AgvLocMast agvLocMast : agvLocMasts) {

                if (agvLocMast.getLev1() == 2) {
                    er++;
                }
            }

            for (AgvLocMast agvLocMast : agvLocMasts) {
                AgvLocMast agvLocMast1 = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocMast.getLocNo()));
                if (agvLocMast1.getLocSts().equals("O")) {
                    return agvLocMast1;
                    if (agvLocMast1.getLev1() == 2) {
                        if (er > num) {
                            return agvLocMast1;
                        }
                    } else {
                        return agvLocMast1;
                    }

                }
            }
            throw new CoolException("搜索库位时，未找到可入库库位。");

 src/main/resources/ËÄÆÚsql/devp

@@ -103,3 +103,20 @@





INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_80F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, 133, '2024-07-04 16:24:38.550', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_81F4', NULL, NULL, 'N', 'Y', NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, NULL, '2024-04-02 09:25:50.747', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_82F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, 133, '2024-07-04 16:24:44.310', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_83F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, 133, '2024-07-04 16:25:01.967', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_84F4', NULL, NULL, 'N', 'Y', NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, NULL, '2024-04-02 09:25:50.747', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('YO_85F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 2, 20, NULL, 133, '2024-07-04 16:24:44.310', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);

INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_51F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, 133, '2024-07-04 16:24:38.550', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_52F4', NULL, NULL, 'N', 'Y', NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, NULL, '2024-04-02 09:25:50.747', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_53F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, 133, '2024-07-04 16:24:44.310', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_54F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, 133, '2024-07-04 16:24:38.550', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_55F4', NULL, NULL, 'N', 'Y', NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, NULL, '2024-04-02 09:25:50.747', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);
INSERT INTO [dbo].[agv_bas_devp]([dev_no], [dec_desc], [dev_mk], [in_enable], [out_enable], [autoing], [loading], [canining], [canouting], [fronting], [rearing], [uping], [downing], [loc_sts], [cache_shelves], [wrk_no], [floor], [ctn_type], [barcode], [in_qty], [row1], [io_time], [area], [in_ok], [out_ok], [loc_type1], [loc_type2], [loc_type3], [modi_user], [modi_time], [appe_user], [appe_time], [std_qty], [min_wt], [max_wt], [gross_wt], [cart_pos], [qr_code_value], [loc_no], [station_code]) VALUES ('QO_56F4', NULL, NULL, 'N', 'Y', 'N', NULL, NULL, NULL, NULL, NULL, NULL, NULL, 'O', NULL, 0, 4, 0, '', 0, NULL, NULL, NULL, NULL, NULL, 6, 31, NULL, 133, '2024-07-04 16:24:44.310', NULL, '2024-04-02 09:25:50.747', .000, .000, .000, .000, 0, NULL, NULL, NULL);