#

luxiaotao1123

2024-10-02 72df8e8ae96a4a3199332a10e5c104c6a603aa39

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
package com.zy.acs.gateway.process;
 
import com.zy.acs.common.domain.protocol.AGV_F0_UP;
import com.zy.acs.gateway.config.SystemProperties;
import com.zy.acs.gateway.domain.AgvPackage;
import com.zy.acs.common.utils.RedisSupport;
import io.netty.channel.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
/**
 * 此类处理的报文全为上行数据
 * Created by vincent on 2019-04-04
 */
@Component("agvProcessor")
public class AgvProcessor {
 
    private static final Logger log = LoggerFactory.getLogger(AgvProcessor.class);
 
    private final RedisSupport redis = RedisSupport.defaultRedisSupport;
 
    @Autowired
    private SystemProperties systemProperties;
 
    /**
     * agv登入
     */
    public Boolean loginBus(AgvPackage pac, Channel channel){
        String uniqueNo = pac.getHeader().getUniqueNo();
        boolean result = false;
 
        AGV_F0_UP agv__f0UP = (AGV_F0_UP) pac.getBody().getMessageBody();
 
        switch (uniqueNo) {
            case "1":
                if (agv__f0UP.getPassword().equals("12345678")) {
                    result = true;
                }
                break;
            case "2":
                if (agv__f0UP.getPassword().equals("12345678")) {
                    result = true;
                }
                break;
            default:
                if (agv__f0UP.getPassword().equals("12345678")) {
                    result = true;
                }
                break;
        }
 
//        result = agv__f0UP.getPassword().equals("12345678") && uniqueNo.equals("1");
 
 
 
        if (result){
//            ChannelCache.setChannel(uniqueNo, channel);
//            redis.setObject(AgvConstant.AGV_ONLINE_FLAG, uniqueNo, protocol, systemProperties.getHeartSeconds());
            log.info("Agv [{}] 登录成功", pac.getHeader().getUniqueNo());
        }
        return result;
    }
 
}