自动化立库仓库-WCS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
#
Junjie
2025-03-13 5dba0daf423f5b4e45b3bcdb55c7de51950dc277 
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java


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


import com.zy.system.service.ConfigService;


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 java.util.*;


@@ -39,8 +38,6 @@


@Service("mainService")


public class MainServiceImpl {




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


    private String wmsUrl;


    @Autowired


    private SlaveProperties slaveProperties;


    @Autowired


@@ -83,30 +80,27 @@


     */


    public synchronized void initRealtimeBasMap() {


        try {


            for (int i = 1; i <= 4; i++) {//总共四层楼


                Object data = redisUtil.get(RedisKeyType.MAP.key + i);


                if (data == null) {//redis地图数据为空，从数据库中获取


                    BasMap basMap = basMapService.selectLatestMap(i);


                    if (basMap == null) {


                        //数据库中也不存在地图数据，从地图文件中获取


                        //载入地图


                        List<List<MapNode>> lists = navigateMapData.getJsonData(i, -1, null, null);//获取完整地图(包括入库出库)




                        //存入数据库


                        basMap = new BasMap();


                        basMap.setData(JSON.toJSONString(lists));


                        basMap.setCreateTime(new Date());


                        basMap.setUpdateTime(new Date());


                        basMap.setLev(i);


            List<BasMap> basMaps = basMapService.selectList(new EntityWrapper<BasMap>().orderBy("lev", true));


            for (BasMap basMap : basMaps) {


                Integer lev = basMap.getLev();


                Object data = redisUtil.get(RedisKeyType.MAP.key + lev);


                if (data == null) {//redis地图数据为空


                    //载入地图


                    List<List<MapNode>> lists = navigateMapData.getJsonData(lev, -1, null, null);//获取完整地图(包括入库出库)




                        if (!basMapService.insert(basMap)) {


                            log.info("地图数据存储失败");


                        }


                    //存入数据库


                    basMap.setData(JSON.toJSONString(lists));


                    basMap.setCreateTime(new Date());


                    basMap.setUpdateTime(new Date());


                    if (!basMapService.updateById(basMap)) {


                        log.info("地图数据存储失败");


                    }




                    //将数据库地图数据存入redis


                    redisUtil.set(RedisKeyType.MAP.key + i, JSON.toJSONString(basMap));


                    redisUtil.set(RedisKeyType.MAP.key + lev, JSON.toJSONString(basMap));


                }




            }


        } catch (Exception e) {


            e.printStackTrace();


@@ -218,7 +212,7 @@


                //下发任务


                shuttleAction.assignWork(shuttleProtocol.getShuttleNo(), assignCommand);


                //触发通知


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_TRANSPORT);


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_TRANSPORT);


                return false;


            }


            return false;


@@ -394,7 +388,7 @@


                //下发任务


                shuttleAction.assignWork(shuttleProtocol.getShuttleNo(), assignCommand);


                //触发通知


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_TRANSPORT);


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_TRANSPORT);


                return false;


            }


            return false;


@@ -442,17 +436,17 @@


                            //310.小车移动中 ==> 311.小车移动完成


                            wrkMast.setWrkSts(WrkStsType.COMPLETE_MOVE.sts);


                            shuttleThread.setSyncTaskNo(0);


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_MOVE_COMPLETE);//触发通知


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_MOVE_COMPLETE);//触发通知


                        } else if (wrkMast.getWrkSts() == WrkStsType.CHARGE_SHUTTLE_WORKING.sts) {


                            //204.小车充电中 ==> 205.小车充电完成


                            wrkMast.setWrkSts(WrkStsType.CHARGE_SHUTTLE_COMPLETE.sts);


                            shuttleThread.setSyncTaskNo(0);


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_POWER_COMPLETE);//触发通知


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_POWER_COMPLETE);//触发通知


                        } else if (wrkMast.getWrkSts() == WrkStsType.LOC_MOVE_SHUTTLE_RUN.sts) {


                            //502.小车搬运中 ==> 509.移库完成


                            wrkMast.setWrkSts(WrkStsType.COMPLETE_LOC_MOVE.sts);


                            shuttleThread.setSyncTaskNo(0);


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_DELIVERY);//触发通知


                            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_DELIVERY);//触发通知


                        } else {


                            continue;


                        }


@@ -573,7 +567,7 @@


                //下发任务


                shuttleAction.assignWork(shuttleProtocol.getShuttleNo(), assignCommand);


                //触发通知


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_MOVING);


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_MOVING);


                return false;


            }


            return false;


@@ -1312,7 +1306,7 @@


            //下发任务


            shuttleAction.assignWork(shuttleProtocol.getShuttleNo(), assignCommand);




            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_POWER_START);//触发通知


            notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_POWER_START);//触发通知


            return false;


        }


        return true;


@@ -1513,8 +1507,8 @@


            if (wrkMastService.updateById(wrkMast)) {


                //下发任务


                shuttleAction.assignWork(shuttleProtocol.getShuttleNo(), assignCommand);


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), wrkMast.getWmsWrkNo(), NotifyMsgType.SHUTTLE_MOVING);


                //触发通知


                notifyUtils.notify(String.valueOf(SlaveType.Shuttle), shuttleProtocol.getShuttleNo(), String.valueOf(wrkMast.getWrkNo()), NotifyMsgType.SHUTTLE_MOVING);


                return false;


            }


            return false;