四期

zhangc

2025-03-05 1044d25ccaa5350b68fa259788246812139267b1

四期

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

@@ -11,7 +11,10 @@
import com.core.common.DateUtils;
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.asrs.entity.*;
import com.zy.asrs.entity.AdjDetl;
import com.zy.asrs.entity.AgvLocDetl;
import com.zy.asrs.entity.AgvLocMast;
import com.zy.asrs.entity.AgvWrkMast;
import com.zy.asrs.entity.param.LocMastInitParam;
import com.zy.asrs.service.AdjDetlService;
import com.zy.asrs.service.AgvLocDetlService;
@@ -49,7 +52,9 @@
        excludeTrash(param);
        EntityWrapper<AgvLocMast> wrapper = new EntityWrapper<>();
        convert1(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(agvLockMastService.selectPage(new Page<>(curr, limit), wrapper.eq("status",0)));
    }

@@ -132,6 +137,10 @@
                    locMast.setBarcode("");
                }
            }
        } else if (oldLocMast.getLocSts().equals("D")) {
            if (locMast.getLocSts().equals("O")) {
                locMast.setBarcode("");
            }
        }
        locMast.setModiUser(getUserId());
        locMast.setModiTime(now);
@@ -208,6 +217,7 @@
            }
        }
    }

    private <T> void convert1(Map<String, Object> map, EntityWrapper<T> wrapper){
        for (Map.Entry<String, Object> entry : map.entrySet()){
            String val = String.valueOf(entry.getValue());

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

@@ -254,19 +254,19 @@
            List<String> staNoList = agvBasDevpService.selectCacheShelvesStationCodeByLocType(agvLocMast.getLocType1());


            Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "FOUR"));
            if (config != null) {
                if (config.getStatus().intValue() == 1) {
                    List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("source_loc_no", locDto.getAgvStaNo()));
                    if (agvWrkMasts != null && !agvWrkMasts.isEmpty()) {
                        for (AgvWrkMast agvWrkMast : agvWrkMasts) {
                            if (agvWrkMast.getWrkSts() < 204) {
                                return R.error(locDto.getAgvStaNo() + "该站点已有任务，等任务完成或者货架搬走再叫料");
                            }
                        }
                    }
                }
            }
//            Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "FOUR"));
//            if (config != null) {
//                if (config.getStatus().intValue() == 1) {
//                    List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("source_loc_no", locDto.getAgvStaNo()));
//                    if (agvWrkMasts != null && !agvWrkMasts.isEmpty()) {
//                        for (AgvWrkMast agvWrkMast : agvWrkMasts) {
//                            if (agvWrkMast.getWrkSts() < 204) {
//                                return R.error(locDto.getAgvStaNo() + "该站点已有任务，等任务完成或者货架搬走再叫料");
//                            }
//                        }
//                    }
//                }
//            }


            if (!staNoList.contains(locDto.getAgvStaNo())) {

 src/main/java/com/zy/asrs/mapper/AgvLocDetlMapper.java

@@ -34,6 +34,10 @@
    @Select("select * from agv_loc_detl where 1=1 and loc_no = #{locNo} and matnr = #{matnr} and three_code = #{csocode}")
    AgvLocDetl selectItemByOrderNo(@Param("locNo")String locNo, @Param("matnr")String matnr, @Param("batch")String batch, @Param("csocode")String csocode, @Param("isocode")String isocode);

    @Select("select * from agv_loc_detl where 1=1 and loc_no = #{locNo} and matnr = #{matnr} and three_code = #{csocode}")
    List<AgvLocDetl> selectItemByOrderNo2(@Param("locNo")String locNo, @Param("matnr")String matnr, @Param("batch")String batch, @Param("csocode")String csocode, @Param("isocode")String isocode);


    @Select("select sum(a.anfme) as sum from agv_loc_detl a left join agv_loc_mast b on a.loc_no = b.loc_no where b.loc_sts = 'F' and a.matnr = #{matnr} AND a.three_code = #{threeCode} AND a.process_sts = 1")
    Double selectSumAnfmeByMatnrProcess(@Param("matnr") String matnr,@Param("threeCode") String threeCode);


 src/main/java/com/zy/asrs/service/AgvLocDetlService.java

@@ -17,6 +17,8 @@

    AgvLocDetl selectItem(String locNo, String matnr, String batch, String csocode, String isoCode);

    List<AgvLocDetl> selectItem2(String locNo, String matnr, String batch, String csocode, String isoCode);

    public double queryStockAndSetLocDto(String matnr, String batch, String orderNo, List<LocDto> locDtoList, double issued, String csocode, String isoseq, String type);

    public void updateStock(String sourceLoc, String targetLoc);

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

@@ -221,6 +221,11 @@
    }

    @Override
    public List<AgvLocDetl> selectItem2(String locNo, String matnr, String batch, String csocode, String isoCode) {
        return this.baseMapper.selectItemByOrderNo2(locNo, matnr, batch, csocode, isoCode);
    }

    @Override
    public Double getSumAnfmeProcess(String matnr, String threeCode) {
        return this.baseMapper.selectSumAnfmeByMatnrProcess(matnr, threeCode);
    }

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

@@ -741,6 +741,7 @@
//                    //agvLocMast = agvCommonService.getLocNo(locType,agvBasDevp.getFloor(),false,false);
//                }
//            }
            // 预留20个库位
            agvLocMast = agvCommonService.getLocByLocRule(3, 1, code,false);



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

@@ -157,9 +157,6 @@
    @Transactional
    public void checkComplete2(String orderNo) {
        Order order = this.selectByNo(orderNo);
        if (order.getDocType() == 38) {
            return;
        }
        if (Cools.isEmpty(order)) {
            return;
        }
@@ -169,12 +166,23 @@
        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;
            }
        }
        }

        // 如果 作业数量等于单据总数量 && 工作明细档中无该单据的数据 && AGV工作明细档中无该单据的数据
        //int count = wrkDetlService.selectCount(new EntityWrapper<WrkDetl>().eq("order_no", orderNo));

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

@@ -220,7 +220,7 @@
                    
                    agvWrkMastWorking = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>()
                            .eq("source_loc_no",agvWrkMast.getLocNo())
                            .le("wrk_sts",204L));
                            .lt("wrk_sts",204L));

                    if(!Cools.isEmpty(agvWrkMastWorking)){
                        return;

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

@@ -433,11 +433,17 @@
                    //目标站点
                    if (agvWrkMast.getLocNo().startsWith("QO") && agvWrkMast.getLocNo().endsWith("F4") && Integer.valueOf(agvWrkMast.getBarcode().substring(0, 2)) == 30) {
                        if (!agvWrkMast.getSourceLocNo().endsWith("02F1")) {
                            AgvLocMast locByFloor = agvCommonService.getLocByLocRule(3, 1, AsrsConstants.ERCHANG,true);
                            if (locByFloor != null) {
                            AgvLocMast locByFloor = null;
                            try {
                                locByFloor = agvCommonService.getLocByLocRule(3, 1, AsrsConstants.ERCHANG, true);
                            } catch (Exception e) {

                            }
                            if (locByFloor != null && locByFloor.getLocNo().endsWith("02F1")) {
                                AgvLocMast agvLocMast = agvLocMastService.selectById(agvWrkMast.getSourceLocNo());
                                agvLocMast.setLocSts("O");
                                agvLocMast.setModiTime(now);
                                agvLocMast.setBarcode("");
                                agvLocMastService.updateById(agvLocMast);
                                wrkMast.setLocNo(locByFloor.getLocNo());
                            } else {

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

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


import com.baomidou.mybatisplus.enums.SqlLike;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
@@ -427,7 +428,7 @@
        } else if (agvLocMast.getFloor() == 1 && agvLocMast.getLev1() == 2) {
            floor = "02F1";
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("source_loc_no", floor).or().eq("io_type", 113));
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("barcode", "30").like("source_loc_no", floor).or().eq("io_type", 113));
        if (agvWrkMasts.size() >= 5) {
            //log.error("暂停回流");
            return FAIL;
@@ -505,9 +506,9 @@
        } else if (agvLocMast.getFloor() == 2) {
            floor = "F2";
        }
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("source_loc_no", floor).or().eq("io_type", 113));
        List<AgvWrkMast> agvWrkMasts = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>().eq("io_type", 109).like("barcode", "31", SqlLike.RIGHT).like("source_loc_no", floor).or().eq("io_type", 113));
        Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "RETURN_6_MAX"));
        if (config == null && !Cools.isEmpty(config.getValue())) {
        if (config != null && !Cools.isEmpty(config.getValue())) {
            if (agvWrkMasts.size() >= Integer.parseInt(config.getValue())) {
                return FAIL;
            }
@@ -555,7 +556,7 @@
        mast.setAppeTime(now);
        mast.setModiUser(9527L);
        mast.setModiTime(now);
        mast.setLogErrMemo("autoEmptyBack4");
        mast.setLogErrMemo("autoEmptyBackSiqi");
        if (!agvWrkMastService.insertByIncrease(mast)) {
            throw new CoolException("保存工作档失败");
        }

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

@@ -6,6 +6,8 @@
import com.zy.asrs.entity.*;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.LocUtils;
import com.zy.system.entity.Config;
import com.zy.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -35,6 +37,9 @@
    private LocRuleService locRuleService;
    @Autowired
    AgvBasDevpService agvBasDevpService;

    @Autowired
    private ConfigService configService;

    @Autowired
    private LocUtils locUtils;
@@ -146,6 +151,52 @@
    }

    /**
     * 库位规则查找，会预留20个库位
     */
    public synchronized AgvLocMast getLocByLocRule20(int type, int floor, String factory, boolean flag) {

        try {
            EntityWrapper<AgvLocMast> wrapper = new EntityWrapper<>();
            wrapper.eq("loc_sts", "O").eq("loc_type1", type);
            List<AgvLocMast> agvLocMasts = new ArrayList<>();
            //不是空板优先找2层
            if (Cools.isEmpty(factory)) {
                wrapper.eq("floor", floor).orderBy("lev1", true);
            } else {
                //B是二厂，G是三厂
                if (factory.equals("B")) {
                    wrapper.eq("floor", floor).orderBy("lev1", false).orderBy("row1", flag);

                } else {
                    wrapper.eq("floor", floor).orderBy("lev1", true);

                }
            }
            int num = 20;
            Config config = configService.selectOne(new EntityWrapper<Config>().eq("code", "LOC_3_NUM"));
            if (config != null && !Cools.isEmpty(config.getValue())) {
                num = Integer.parseInt(config.getValue());
            }
            agvLocMasts = agvLocMastService.selectList(wrapper);
            for (AgvLocMast agvLocMast : agvLocMasts) {

            }

            for (AgvLocMast agvLocMast : agvLocMasts) {
                AgvLocMast agvLocMast1 = agvLocMastService.selectOne(new EntityWrapper<AgvLocMast>().eq("loc_no", agvLocMast.getLocNo()));
                if (agvLocMast1.getLocSts().equals("O")) {
                    return agvLocMast1;
                }
            }
            throw new CoolException("搜索库位时，未找到可入库库位。");
        } catch (Exception e) {
            throw new CoolException("搜索库位时，未找到可入库库位。");
        }


    }

    /**
     * 库位规则查找
     */
    public synchronized AgvLocMast getLocByLocRule(int type, int floor, String factory, boolean flag) {