#

1

9 小时以前 53f87c2ff10f7ab71d6b0340a5a4811089d7cd1e

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

@@ -14,13 +14,16 @@
import com.zy.asrs.entity.result.StockVo;
import com.zy.asrs.mapper.TagMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.utils.MatUtils;
import com.zy.asrs.utils.OrderInAndOutUtil;
import com.zy.asrs.utils.Utils;
import com.zy.common.constant.ArmConstant;
import com.zy.common.model.DetlDto;
import com.zy.common.service.CommonService;
import com.zy.common.utils.HttpHandler;
import com.zy.common.utils.NodeUtils;
import com.zy.erp.kingdee.utils.PostMesDataUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -68,6 +71,8 @@
    private LocOwnerService locOwnerService;
    @Autowired
    private CommonService commonService;
    @Autowired
    private LocMastServiceImpl locMastService;

    @Override
    @Transactional
@@ -661,7 +666,8 @@
                .eq("status", 1)
        );
        if (Cools.isEmpty(basArm)){
            throw new CoolException("机械臂配置异常，查询不到机械臂数据！！！"+ JSON.toJSONString(param));
            return;
//            throw new CoolException("机械臂配置异常，查询不到机械臂数据！！！"+ JSON.toJSONString(param));
        }

        try{
@@ -731,7 +737,8 @@
        if (Cools.isEmpty(basArmMast)){
            throw new CoolException("未查询到相关机械臂拆码垛任务！！！"+ JSON.toJSONString(param));
        }
        basArmMastService.updateArmMastStatus(param.getArm_no(),basArmMast.getSortingLine(),2,3);
        basArmMastService.updateArmMastStatus(param.getArm_no(),basArmMast.getSortingLine(),basArmMast.getStaNo(),1,3);
        basArmMastService.updateArmMastStatus(param.getArm_no(),basArmMast.getSortingLine(),basArmMast.getStaNo(),2,3);
    }

    @Override
@@ -752,7 +759,7 @@
                        .eq("status", 5)
        );
        if (!Cools.isEmpty(basArmMast)){
            basArmMastService.updateArmMastStatus(param.getArm_no(),basArmMast.getSortingLine(), 5,6);
            basArmMastService.updateArmMastStatus(param.getArm_no(),basArmMast.getSortingLine(),basArmMast.getStaNo(), 5,6);
        }
    }

@@ -790,7 +797,6 @@
        if (param == null) {
            throw new CoolException("参数不能为空");
        }
        Integer devpId = 1;
        // 创建对象（构造函数中已生成 timestamp）
        BasAgvMast basAgvMast = new BasAgvMast();
        // 生成 WMS 任务号（如无外部传入，可以使用雪花ID 或自增）
@@ -806,7 +812,7 @@
        basAgvMast.setAppeTime(new Date());  // 添加时间
        basAgvMast.setModiTime(new Date());  // 修改时间
        basAgvMast.setIoType(param.getIoType());// 任务类型
        basAgvMast.setDevpId(devpId);
        basAgvMast.setFloorNo(param.getFloorNo()); //楼层

        // 插入数据库
        basAgvMastService.insert(basAgvMast);
@@ -816,30 +822,38 @@

    @Override
    @Transactional
    public List<AgvLocListDetlParam> getAgvLocList(AgvLocListParam param){

        if (param == null || Cools.isEmpty(param.getLocNoList())) {
            throw new CoolException("库位号不能为空");
        }

        List<String> locNos = param.getLocNoList();

    public List<AgvLocListDetlParam> getAgvLocList(AgvLocListParam param) {
        List<AgvLocListDetlParam> result = new ArrayList<>();

        for (String locNo : locNos) {
        if (Cools.isEmpty(param.getLocNo())) {
            EntityWrapper<LocMast> locMastEntityWrapper = new EntityWrapper<>();
            locMastEntityWrapper.setSqlSelect("TOP 5 loc_no as locNo,loc_sts as locSts")
                    .where("loc_sts in ('F','D','S','R') and whs_type = '5'");
            List<LocMast> locMasts = locMastService.selectList(locMastEntityWrapper);

            // 查询该库位 detail
            List<LocDetl> detlList = locDetlService.selectList(
                    new EntityWrapper<LocDetl>().eq("loc_no", locNo)
            for (LocMast locMast : locMasts) {
                result.add(buildAgvLocListDetlParam(locMast.getLocNo(), locMast.getLocSts$()));
            }
        } else {
            LocMast locMast = locMastService.selectOne(
                    new EntityWrapper<LocMast>().eq("loc_no", param.getLocNo())
            );

            AgvLocListDetlParam dto = new AgvLocListDetlParam();
            dto.setLocNo(locNo);
            dto.setAgvDetlList(detlList);
            result.add(dto);
            result.add(buildAgvLocListDetlParam(param.getLocNo(), locMast.getLocSts$()));
        }

        
        return result;
    }

    private AgvLocListDetlParam buildAgvLocListDetlParam(String locNo, String locSts) {
        List<LocDetl> detlList = locDetlService.selectList(
                new EntityWrapper<LocDetl>().eq("loc_no", locNo)
        );
        
        AgvLocListDetlParam dto = new AgvLocListDetlParam();
        dto.setLocNo(locNo);
        dto.setLocSys(locSts);
        dto.setAgvDetlList(detlList);
        return dto;
    }


@@ -904,5 +918,16 @@
    }


    @Override
    @Transactional
    public boolean agvApplicationPassedTheGrating(ArmAgvGratingParam arm) {
        ReturnT<String> result = new PostMesDataUtils().postMesDataArmGrating("光栅请求下发：", ArmConstant.getArmUrl(arm.getArmNo()), ArmConstant.ARM_ADAPTOR_GRATING_AGVENTER, arm);
        if (result.getCode()==200){
            return true;
        }
        return false;
    }



}