自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zyh
21 小时以前 437faf8e56bfc30d00473e65ece48be504a57fe7 
 src/main/java/com/zy/common/web/WcsController.java


@@ -1,5 +1,8 @@


package com.zy.common.web;




import com.alibaba.excel.util.StringUtils;


import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.baomidou.mybatisplus.mapper.Wrapper;


import com.core.common.Cools;


@@ -7,21 +10,29 @@


import com.core.exception.CoolException;


import com.zy.asrs.entity.*;


import com.zy.asrs.entity.param.EmptyPlateOutParam;


import com.zy.asrs.entity.rcs.RcsReturn;


import com.zy.asrs.entity.result.FindLocNoAttributeVo;


import com.zy.asrs.service.*;


import com.zy.asrs.service.impl.RcsServiceImpl;


import com.zy.common.CodeRes;


import com.zy.common.model.LocTypeDto;


import com.zy.common.model.StartupDto;


import com.zy.common.service.CommonService;


import com.zy.common.utils.RedisUtil;


import com.zy.common.web.param.SearchLocParam;


import lombok.extern.slf4j.Slf4j;


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


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


import org.springframework.transaction.annotation.Transactional;


import org.springframework.web.bind.annotation.*;




import javax.annotation.Resource;


import java.util.ArrayList;


import java.util.Date;


import java.util.List;


import java.util.stream.Collectors;




import static com.zy.asrs.service.impl.RcsServiceImpl.sendPost;




/**


 * Created by vincent on 2020/10/30


@@ -49,11 +60,23 @@


    private RowLastnoService rowLastnoService;


    @Autowired


    private WorkService workService;


    @Autowired


    private RedisUtil redisUtil;


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


    private String HIK_URL;




    private static final String IS_START_PRE_SCHEDULE = "schedule:check";




    // TODO：称重、拍照上报存储，CTU料箱运转




    @PostMapping("/pakin/loc/v1")


    @ResponseBody


    public synchronized R getLocNo(@RequestBody SearchLocParam param) {




        log.info("收到WCS入库接口请求====>>入参:{}", param);




        PreScheduling();




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


            return R.error("入出库类型不能为空");


        }


@@ -111,7 +134,9 @@


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




        // 检索库位


        StartupDto dto = commonService.getLocNo( 10, 12, null,null,null, locTypeDto);


        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();




        StartupDto dto = commonService.getLocNo( 10, 12, findLocNoAttributeVo, locTypeDto);


        Date now = new Date();


        // 生成工作档


        WrkMast wrkMast = new WrkMast();


@@ -121,8 +146,8 @@


        wrkMast.setIoPri(13D);


        wrkMast.setIoType(10);


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo());


        wrkMast.setStaNo(dto.getStaNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo() + "");


        wrkMast.setStaNo(dto.getStaNo() + "");


        wrkMast.setLocNo(dto.getLocNo());


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


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


@@ -160,22 +185,29 @@


        // 源站点状态检测


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


        // 检索库位


        List<String> matnrs = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList());


        List<String> batchs = waitPakins.stream().map(WaitPakin::getBatch).distinct().collect(Collectors.toList());


        StartupDto dto = commonService.getLocNo( 1, devpNo, matnrs.get(0),batchs.get(0),null, locTypeDto);


        int workNo = dto.getWorkNo();


//        List<String> matnrs = waitPakins.stream().map(WaitPakin::getMatnr).distinct().collect(Collectors.toList());


//        List<String> batchs = waitPakins.stream().map(WaitPakin::getBatch).distinct().collect(Collectors.toList());


//        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(matnrs.get(0), batchs.get(0));


//        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo(waitPakins.get(0));


//        StartupDto dto = commonService.getLocNo( 1, devpNo,findLocNoAttributeVo, locTypeDto);


        // 获取空库位


        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").orderBy("lev1").orderBy("bay1").orderBy("row1"));


        if (locMast == null) {


            throw new CoolException("无空库位！");


        }


        int workNo =commonService.getWorkNo(0);


        Date now = new Date();


        // 生成工作档


        WrkMast wrkMast = new WrkMast();


        wrkMast.setWrkNo(workNo);


        wrkMast.setIoTime(new Date());


        wrkMast.setIoTime(now);


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


        wrkMast.setIoType(1); // 入出库状态：1.入库


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


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo());


        wrkMast.setStaNo(dto.getStaNo());


        wrkMast.setLocNo(dto.getLocNo());


        wrkMast.setCrnNo(1);


        wrkMast.setSourceStaNo("104");


        wrkMast.setStaNo("106");


        wrkMast.setLocNo(locMast.getLocNo());


        wrkMast.setBarcode(barcode); // 托盘码


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


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


@@ -206,7 +238,7 @@


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


                .eq("zpallet", barcode);


        WaitPakin setParam = new WaitPakin();


        setParam.setLocNo(dto.getLocNo());


        setParam.setLocNo(locMast.getLocNo());


        setParam.setIoStatus("Y");


        setParam.setModiTime(now);


        if (!waitPakinService.update(setParam, wrapper)) {


@@ -219,7 +251,6 @@


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


        }


        // 更新目标库位状态


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


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


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


            locMast.setModiTime(now);


@@ -227,8 +258,14 @@


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


            }


        } else {


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


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


        }


        StartupDto dto = new StartupDto();


        dto.setWorkNo(workNo);


        dto.setLocNo(locMast.getLocNo());


        dto.setSourceStaNo(104);


        dto.setStaNo(106);


        dto.setCrnNo(1);


        return dto;


    }




@@ -237,7 +274,20 @@


        // 源站点状态检测


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


        // 检索库位


        StartupDto dto = commonService.getLocNo( 10, devpNo, null,null,null, locTypeDto);


//        FindLocNoAttributeVo findLocNoAttributeVo = new FindLocNoAttributeVo();


//


//        StartupDto dto = commonService.getLocNo( 10, devpNo, findLocNoAttributeVo, locTypeDto);




        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_sts", "O").orderBy("lev1").orderBy("bay1").orderBy("row1"));


        if (locMast == null) {


            throw new CoolException("无空库位！");


        }


        StartupDto dto = new StartupDto();


        dto.setWorkNo(commonService.getWorkNo(0));


        dto.setCrnNo(1);


        dto.setSourceStaNo(104);


        dto.setStaNo(106);


        dto.setLocNo(locMast.getLocNo());


        int workNo = dto.getWorkNo();


        // 生成工作档


        WrkMast wrkMast = new WrkMast();


@@ -247,8 +297,8 @@


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


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


        wrkMast.setCrnNo(dto.getCrnNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo());


        wrkMast.setStaNo(dto.getStaNo());


        wrkMast.setSourceStaNo(dto.getSourceStaNo() + "");


        wrkMast.setStaNo(dto.getStaNo() + "");


        wrkMast.setLocNo(dto.getLocNo());


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


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


@@ -271,7 +321,6 @@


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


        }


        // 更新目标库位状态


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


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


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


            locMast.setModiTime(new Date());


@@ -284,4 +333,27 @@


        return dto;


    }




    public void PreScheduling(){




        if (redisUtil.get(IS_START_PRE_SCHEDULE)!=null && redisUtil.get(IS_START_PRE_SCHEDULE).equals("T")){


            return;


        }else {


            redisUtil.set(IS_START_PRE_SCHEDULE, "T",70);


        }


        String url = "api/robot/controller/task/pretask";


        String URL = HIK_URL + url;


        JSONObject preSchedule = new JSONObject();


        preSchedule.put("siteCode", "106");


        preSchedule.put("nextTaskTime", "70");


        preSchedule.put("robotType", "18,25");


        preSchedule.put("taskCount", 3);




        String response = sendPost(URL, JSONObject.toJSONString(preSchedule));


        if (!StringUtils.isEmpty(response) && response.contains("code")){


            log.info("预调度成功{}", preSchedule);


        } else {


            log.info("预调度失败{}", preSchedule);


        }


    }




}