#agv任务

zhou zhou

2025-12-30 0eab67f624c2b3349002860b408942265a076b9e

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

@@ -601,6 +601,7 @@
     * @description: AGV出库任务
     * @version 1.0
     */
    @Transactional(rollbackFor = Exception.class)
    public ReturnT<String> agvDoOut(Task task) {
        if (task.getIoType().equals(101)) {
            Date now = new Date();
@@ -635,8 +636,35 @@
            if (!taskService.updateById(task)) {
                throw new CoolException("任务状态修改失败！！");
            }
        } else {
        } else if(task.getIoType().equals(53) || task.getIoType().equals(54) || task.getIoType().equals(57)){
            LocCache locCache = locCacheService.selectOne(new EntityWrapper<LocCache>().eq("loc_no", task.getSourceLocNo()));
            if (Objects.isNull(locCache)) {
                throw new CoolException("数据错误，库位不存在！！");
            }
            if (!locCache.getLocSts().equals(LocStsType.LOC_STS_TYPE_R.type)) {
                throw new CoolException("当前库位状态为：" + LocStsType.LOC_STS_TYPE_R.type + "." + LocStsType.LOC_STS_TYPE_R.desc + "，不是出库预约状态");
            }

            locCache.setLocSts(LocStsType.LOC_STS_TYPE_O.type);
            locCache.setModiTime(new Date());
            locCache.setBarcode(null);
            locCache.setModiTime(new Date());
            locCache.setIoTime(new Date());
            if (!locCacheService.updateById(locCache)) {
                throw new CoolException("库位状态修改失败！");
            }

            boolean deleted = locCacheDetlService.delete(new EntityWrapper<LocCacheDetl>().eq("loc_id", locCache.getId()));

            if (!deleted){
                throw new CoolException("库位明细删除失败！");
            }

            task.setWrkSts(15L);
            task.setModiTime(new Date());
            if (!taskService.updateById(task)) {
                throw new CoolException("任务状态修改失败！！");
            }
        }
        return SUCCESS;
    }
@@ -644,6 +672,7 @@

    @Transactional(rollbackFor = Exception.class)
    public ReturnT<String> agvDoIn(Task wrkMast) {
        if (wrkMast.getIoType().equals(1)) {
        LocCache locCache = locCacheService.selectOne(new EntityWrapper<LocCache>().eq("loc_no", wrkMast.getLocNo()));
        if (Objects.isNull(locCache)) {
            throw new CoolException("数据错误，库位不存在！！");
@@ -688,6 +717,10 @@
        if (!taskService.updateById(wrkMast)) {
            throw new CoolException("任务状态修改失败！！");
        }
        }else {
            throw new CoolException("数据错误：ioType不存在！！");
        }


        return SUCCESS;
    }