小太阳WMS
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
王佳豪
2021-06-09 aa21112291b04d0d3d53d75104a348f019f935a1 
 src/main/java/com/zy/asrs/service/impl/WorkServiceImpl.java


@@ -6,6 +6,7 @@


import com.core.common.BaseRes;


import com.core.common.Cools;


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.param.*;


@@ -15,13 +16,18 @@


import com.zy.common.model.LocTypeDto;


import com.zy.common.model.OutLocDto;


import com.zy.common.model.StartupDto;


import com.zy.common.model.agv.AgvCommand;


import com.zy.common.model.agv.AgvResult;


import com.zy.common.service.CommonService;


import com.zy.common.service.erp.ErpSqlServer;


import com.zy.common.utils.HttpHandler;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




import java.io.IOException;


import java.text.MessageFormat;


import java.util.*;


import java.util.concurrent.TimeUnit;


@@ -39,6 +45,8 @@


    // 库位排号分配默认类别


    private static final int DEFAULT_ROW_NO_TYPE = 1;




    @Value("${agv.url}")


    private String agvUrl;


    @Autowired


    private WrkMastService wrkMastService;


    @Autowired


@@ -63,6 +71,8 @@


    private WrkDetlLogService wrkDetlLogService;


    @Autowired


    private ErpSqlServer erpSqlServer;


    @Autowired


    private BasAgvService basAgvService;




    @Override


    @Transactional


@@ -313,6 +323,36 @@


    @Override


    @Transactional


    public String emptyPlateIn(Integer devpNo, Long userId) {


        // 目标站点状态检测


        BasDevp staNo = basDevpService.checkSiteStatus(devpNo);


        if (!Cools.isEmpty(staNo.getFronting()) && staNo.getFronting().equals("Y")) {


            // 小车入库搬运命令 ----------------------------------------------------


            BasAgv idleAgv = basAgvService.selectIdleAgv();


            AgvCommand command = new AgvCommand();


            command.setAgvId(idleAgv.getAgvId());


            command.setInterCode(basAgvService.getEmptyAgvWorkNo());


            command.setBeginLoc(String.valueOf(devpNo));


            command.setEndLoc("1088");


            log.info(JSON.toJSONString(command));


            String result;


            try {


                result = new HttpHandler.Builder()


                        .setUri(agvUrl + "/api/interfaceTask/SendTaskByThirdParty")


                        .setJson(JSON.toJSONString(command))


                        .build()


                        .doPost();


            } catch (IOException e) {


                e.printStackTrace();


                throw new CoolException("访问AGV接口失败");


            }


            AgvResult agvResult = JSON.parseObject(result, AgvResult.class);


            log.info(JSON.toJSONString(agvResult));


            if (!agvResult.getResult()) {


                log.error("agv命令发送失败[agvId={}]，错误信息={}", command.getAgvId(), agvResult.getExplain());


                throw new CoolException("agv命令发送失败[agvId=" + command.getAgvId() + "]，错误信息=" + agvResult.getExplain());


            }


            return "待定";


        } else {


        // 源站点状态检测


        BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);


        // 检索库位


@@ -368,11 +408,78 @@


        return dto.getLocNo();


    }




    }




//    @Override


//    @Transactional


//    public String emptyPlateIn(Integer devpNo, Long userId) {


//        // 源站点状态检测


//        BasDevp sourceStaNo = basDevpService.checkSiteStatus(devpNo, true);


//        // 检索库位


//        LocTypeDto locTypeDto = new LocTypeDto(sourceStaNo);


//        StartupDto dto = commonService.getLocNo(DEFAULT_ROW_NO_TYPE, 10, devpNo, true, null, locTypeDto, 0);


//        // 工作号


//        int workNo = dto.getWorkNo();


//        // 生成工作档


//        WrkMast wrkMast = new WrkMast();


//        wrkMast.setWrkNo(workNo);


//        wrkMast.setIoTime(new Date());


//        wrkMast.setWrkSts(1L); // 工作状态：生成入库ID


//        wrkMast.setIoType(10); // 入出库状态：10.空板入库


//        wrkMast.setIoPri(13D); // 优先级：10


//        wrkMast.setCrnNo(dto.getCrnNo());


//        wrkMast.setSourceStaNo(dto.getSourceStaNo());


//        wrkMast.setStaNo(dto.getStaNo());


//        wrkMast.setLocNo(dto.getLocNo());


//        wrkMast.setFullPlt("N"); // 满板：Y


//        wrkMast.setPicking("N"); // 拣料


//        wrkMast.setExitMk("N"); // 退出


//        wrkMast.setEmptyMk("Y"); // 空板


//        wrkMast.setLinkMis("N");


//        wrkMast.setCtnType(sourceStaNo.getCtnType()); // 容器类型


//        // 操作人员数据


//        wrkMast.setAppeUser(userId);


//        wrkMast.setAppeTime(new Date());


//        wrkMast.setModiUser(userId);


//        wrkMast.setModiTime(new Date());


//        boolean res = wrkMastService.insert(wrkMast);


//        if (!res) {


//            throw new CoolException("保存工作档失败");


//        }


//        // 更新源站点信息


//        sourceStaNo.setWrkNo(workNo);


//        sourceStaNo.setModiUser(userId);


//        sourceStaNo.setModiTime(new Date());


//        if (!basDevpService.updateById(sourceStaNo)) {


//            throw new CoolException("更新源站失败");


//        }


//        // 更新目标库位状态


//        LocMast locMast = locMastService.selectById(dto.getLocNo());


//        if (locMast.getLocSts().equals("O")) {


//            locMast.setLocSts("S"); // S.入库预约


//            locMast.setModiUser(userId);


//            locMast.setModiTime(new Date());


//            if (!locMastService.updateById(locMast)) {


//                throw new CoolException("改变库位状态失败");


//            }


//        } else {


//            throw new CoolException(dto.getLocNo() + "目标库位已被占用");


//        }


//        return dto.getLocNo();


//    }




    @Override


    @Transactional


    public void emptyPlateOut(EmptyPlateOutParam param, Long userId) {


        if (Cools.isEmpty(param.getOutSite())) {


            throw new CoolException("站点不存在");


        }


        // 目标站点状态检测


        BasDevp staNo = basDevpService.checkSiteStatus(param.getOutSite());


        int agvSite = 0;


        if (!Cools.isEmpty(staNo.getFronting()) && staNo.getFronting().equals("Y")) {


            agvSite = staNo.getDevNo();


            staNo = basDevpService.checkSiteStatus(201);


        }


        for (String locNo : param.getLocNos()) {


            // 获取工作号


@@ -385,7 +492,7 @@


            // 获取源站


            Wrapper<StaDesc> wrapper = new EntityWrapper<StaDesc>()


                    .eq("type_no", 110)


                    .eq("stn_no", param.getOutSite())


                    .eq("stn_no", staNo.getDevNo())


                    .eq("crn_no", locMast.getCrnNo());


            StaDesc staDesc = staDescService.selectOne(wrapper);


            Integer sourceStaNo = staDesc.getCrnStn();


@@ -400,7 +507,7 @@


            wrkMast.setIoType(110); // 入出库状态： 110.空板出库


            wrkMast.setIoPri(10D);


            wrkMast.setSourceStaNo(sourceStaNo); // 源站


            wrkMast.setStaNo(param.getOutSite()); // 目标站


            wrkMast.setStaNo(staNo.getDevNo()); // 目标站


            wrkMast.setCrnNo(locMast.getCrnNo());


            wrkMast.setSourceLocNo(locNo); // 源库位


            wrkMast.setFullPlt("N"); // 满板：Y


@@ -408,6 +515,8 @@


            wrkMast.setExitMk("N"); // 退出


            wrkMast.setEmptyMk("Y"); // 空板


            wrkMast.setLinkMis("N");


            wrkMast.setCtnKind(agvSite); // 出库下的小车工作区站好


            wrkMast.setExitMk("N"); // 小车是否搬运


            wrkMast.setAppeUser(userId);


            wrkMast.setAppeTime(new Date());


            wrkMast.setModiUser(userId);