| | |
| | | import com.alibaba.fastjson.JSON; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.framework.common.SnowflakeIdWorker; |
| | | import com.zy.acs.framework.exception.CoolException; |
| | | import com.zy.acs.common.domain.AgvAction; |
| | | import com.zy.acs.common.domain.AgvActionItem; |
| | | import com.zy.acs.common.domain.AgvProtocol; |
| | |
| | | import com.zy.acs.common.domain.protocol.AGV_70_UP; |
| | | import com.zy.acs.common.domain.protocol.IMessageBody; |
| | | import com.zy.acs.common.domain.protocol.action.*; |
| | | import com.zy.acs.common.enums.*; |
| | | import com.zy.acs.common.enums.AgvBackpackType; |
| | | import com.zy.acs.common.enums.AgvCompleteType; |
| | | import com.zy.acs.common.enums.AgvDirectionType; |
| | | import com.zy.acs.common.enums.AgvSpeedType; |
| | | import com.zy.acs.common.utils.RedisSupport; |
| | | import com.zy.acs.common.utils.Utils; |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.framework.common.SnowflakeIdWorker; |
| | | import com.zy.acs.framework.exception.CoolException; |
| | | import com.zy.acs.manager.common.domain.TaskDto; |
| | | import com.zy.acs.manager.common.exception.BusinessException; |
| | | import com.zy.acs.manager.common.utils.CommonUtil; |
| | |
| | | @Component("mainService") |
| | | public class MainService { |
| | | |
| | | private final RedisSupport redis = RedisSupport.defaultRedisSupport; |
| | | private static final int LOCK_TIMEOUT = 5; |
| | | private final ReentrantLock lock = new ReentrantLock(Boolean.TRUE); |
| | | |
| | |
| | | break; |
| | | } |
| | | |
| | | // if (taskType.equals(TaskTypeType.TO_STANDBY)) { |
| | | // redis.setObject(RedisConstant.AGV_TO_STANDBY_FLAG, agv.getUuid(), false); |
| | | // } |
| | | |
| | | return true; |
| | | } catch (Exception e) { |
| | | log.error("mainService.buildMinorTask[task]", e); |