#

luxiaotao1123

2024-10-23 b6bad62d8839cc50d1a82e9ffecbbf666efb780e

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
package com.zy.acs.manager.manager.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.zy.acs.common.constant.RedisConstant;
import com.zy.acs.common.enums.AgvStatusType;
import com.zy.acs.common.utils.JudgeSupport;
import com.zy.acs.common.utils.RedisSupport;
import com.zy.acs.framework.common.Cools;
import com.zy.acs.manager.common.domain.BaseParam;
import com.zy.acs.manager.common.domain.PageParam;
import com.zy.acs.manager.common.domain.PageResult;
import com.zy.acs.manager.core.domain.VehicleDto;
import com.zy.acs.manager.manager.controller.result.AgvResult;
import com.zy.acs.manager.manager.entity.*;
import com.zy.acs.manager.manager.enums.SegmentStateType;
import com.zy.acs.manager.manager.mapper.AgvMapper;
import com.zy.acs.manager.manager.service.*;
import com.zy.acs.manager.system.service.ConfigService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.util.ArrayList;
import java.util.List;
 
/**
 * 字典数据Service实现
 *
 * @author vincent
 * @since 2020-03-14 11:29:04
 */
@Slf4j
@Service
public class AgvServiceImpl extends ServiceImpl<AgvMapper, Agv> implements AgvService {
 
    private final RedisSupport redis = RedisSupport.defaultRedisSupport;
 
    @Autowired
    private AgvDetailService agvDetailService;
    @Autowired
    private AgvModelService agvModelService;
    @Autowired
    private ConfigService configService;
    @Autowired
    private CodeService codeService;
    @Autowired
    private SegmentService segmentService;
 
    @Override
    public PageResult<AgvResult> pageRel(PageParam<Agv, BaseParam> pageParam) {
        return new PageResult<>(this.baseMapper.selectPageRel(pageParam, pageParam.checkoutMap()), pageParam.getTotal());
    }
 
    @Override
    public Agv selectByUuid(String uuid) {
        return this.getOne(new LambdaQueryWrapper<Agv>().eq(Agv::getUuid, uuid));
    }
 
    @Override
    public Agv queryIdle(Task task) {
        if (Cools.isEmpty(task)) {
            return null;
        }
        return null;
    }
 
    @Override
    public Boolean judgeEnable(Long agvId) {
        return this.judgeEnable(agvId, null);
    }
 
    @Override
    public Boolean judgeEnable(Long agvId, JudgeSupport<AgvDetail> support) {
        Agv agv = this.getById(agvId);
        AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
        if (segmentService.count(new LambdaQueryWrapper<Segment>()
                .eq(Segment::getAgvId, agvId)
                .and( i -> {
//                    i.eq(Segment::getState, SegmentStateType.WAITING.toString()).or()
                    i.eq(Segment::getState, SegmentStateType.RUNNING.toString());
                })
        ) > 0) {
            log.warn("[{}]号Agv正在忙碌 -segment......", agv.getUuid());
            return false;
        }
        if (!this.judgeOnline(agv.getId())) {
            log.warn("[{}]号Agv不是在线状态......", agv.getUuid());
            return false;
        }
        AgvDetail agvDetail = agvDetailService.selectByAgvId(agv.getId());
        if (null == agvDetail) {
            log.warn("[{}]号Agv未收到状态包......", agv.getUuid());
            return false;
        }
        if (agvDetail.getVol() == 0) {
            return false;
        }
        if (!agvDetail.getAgvStatus().equals(AgvStatusType.IDLE) && !agvDetail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
            log.warn("[{}]号Agv不是空闲状态......", agv.getUuid());
            return false;
        }
        if (agvDetail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
            if (agvDetail.getVol() <= agvModel.getQuaBattery()) {
                return false;
            }
        }
        if (support != null) {
            if (!support.execute(agvDetail)) {
                return false;
            }
        }
        if (!agvDetail.getAgvStatus().equals(AgvStatusType.CHARGE)) {
            if (agvDetail.getPos() != 1) {
                log.warn("[{}]号Agv当前不在定位......", agv.getUuid());
                return false;
            }
        }
        return true;
    }
 
    @Override
    public Boolean judgeOnline(Long agvId) {
        Agv agv = this.getById(agvId);
        return redis.getObject(RedisConstant.AGV_ONLINE_FLAG, agv.getUuid()) != null;
    }
 
    @Override
    public List<VehicleDto> getVehicleDtoList(List<String> noIncluded) {
        List<VehicleDto> res = new ArrayList<>();
        List<Agv> list = this.list(new LambdaQueryWrapper<Agv>());
        for (Agv agv : list) {
            if (!Cools.isEmpty(noIncluded)) {
                if (noIncluded.contains(agv.getUuid())) {
                    continue;
                }
            }
            AgvDetail detail = agvDetailService.selectByAgvId(agv.getId());
            VehicleDto dto = new VehicleDto();
            dto.setVehicle(agv.getUuid());
            dto.setPosCode(codeService.getById(detail.getRecentCode()).getData());
            res.add(dto);
        }
        return res;
    }
 
    @Override
    public Integer getBackpack(Agv agv) {
        if (null != agv.getStage()) {
            return agv.getStage();
        }
        AgvModel agvModel = agvModelService.getById(agv.getAgvModel());
        assert null != agvModel;
        return agvModel.getBackpack();
    }
 
}