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;
    }

}