package org.yzh.client;

import io.github.yezhihao.netmc.session.Session;
import io.swagger.models.auth.In;
import org.yzh.client.netty.ClientConfig;
import org.yzh.client.netty.HandlerMapping;
import org.yzh.client.netty.TCPClient;
import org.yzh.commons.util.DateUtils;
import org.yzh.commons.util.StrUtils;
import org.yzh.protocol.basics.JTMessage;
import org.yzh.protocol.codec.JTMessageAdapter;
import org.yzh.protocol.commons.JT808;
import org.yzh.protocol.commons.transform.attribute.AlarmADAS;
import org.yzh.protocol.commons.transform.attribute.AlarmBSD;
import org.yzh.protocol.commons.transform.attribute.AlarmDSM;
import org.yzh.protocol.commons.transform.attribute.AlarmTPMS;
import org.yzh.protocol.t808.*;

import java.time.LocalDateTime;
import java.util.Map;
import java.util.TreeMap;
import java.util.concurrent.ThreadLocalRandom;

public class ClientTest {

    public static final JTMessageAdapter messageAdapter = new JTMessageAdapter("org.yzh.protocol");

    // tcp://server.demo.natool.cn:19392
//    dmtest.ahapp.net:7611
    public static final ClientConfig jtConfig = new ClientConfig.Builder()
//            .setIp("server.demo.natool.cn")
//            .setPort(31146)
            .setIp("dmtest.ahapp.net")
            .setPort(7611)
            .setMaxFrameLength(2 + 21 + 1023 * 2 + 1 + 2)
            .setDelimiters(new byte[]{0x7e})
            .setDecoder(messageAdapter)
            .setEncoder(messageAdapter)
            .setHandlerMapping(new HandlerMapping("org.yzh.client"))
            .build();

    public static void main(String[] args) {
        TCPClient tcpClient = new TCPClient("0", jtConfig).start();
        tcpClient.writeObject(T0100("2"));
       /* for (int i = 0; i < 1000; i++) {
            try {
                Thread.sleep(3000L);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            boolean alarm = i % 10 == 0;
            tcpClient.writeObject(T0200(""+i, alarm));
        }*/
    }

    public static T0100 T0100(String id) {
        String deviceId = "T" + StrUtils.leftPad(id, 6, '0');
        String clientId = "1" + StrUtils.leftPad(id, 10, '0');
        String plateNo = "皖A" + StrUtils.leftPad(id, 5, '0');

        T0100 message = new T0100();
        message.setMessageId(JT808.终端注册);
        message.setProtocolVersion(1);
        message.setVersion(true);
        message.setClientId(clientId);

        message.setProvinceId(31);
        message.setCityId(115);
        message.setMakerId("yzh");
        message.setDeviceModel("www.baidu.cn");
        message.setDeviceId(deviceId);
        message.setPlateColor(1);
        message.setPlateNo(plateNo);
        return message;
    }

    private static ThreadLocalRandom random = ThreadLocalRandom.current();

    public static T0200 T0200(String id, int no) {
        return T0200(id, false,no);
    }
    public static T0201_0500 T0201_0500(String id, int no) {
        return T0201_0500(id, no);
    }

    public static T0201_0500 T0201_0500(JTMessage msg) {
//        String clientId = "1" + StrUtils.leftPad(id, 10, '0');
        T0201_0500 message = new T0201_0500();
//        message.setMessageId(JT808.位置信息汇报);
        message.setMessageId(JT808.位置信息查询应答);
        message.setProtocolVersion(1);
        message.setResponseSerialNo(msg.getSerialNo());
        message.setVersion(true);
        message.setClientId(msg.getClientId());
        message.setWarnBit(1024);
        message.setStatusBit(2048);
        message.setLatitude(39915931);
        message.setLongitude(116403829);
        message.setAltitude(312);
        message.setSpeed(111);
        message.setDirection(99);
        LocalDateTime dateTime = LocalDateTime.now();
        message.setDeviceTime(dateTime);
        return message;
    }
    public static T0107 T0107_0500(JTMessage msg) {
//        String clientId = "1" + StrUtils.leftPad(id, 10, '0');
        T0107 message = new T0107();
        message.setMessageId(JT808.查询终端属性应答);
        message.setProtocolVersion(1);
        message.setResponseSerialNo(msg.getSerialNo());
        message.setVersion(true);
        message.setClientId(msg.getClientId());
        message.setDeviceType(1);
        message.setDeviceId("123123");
        message.setDeviceModel("12324235235325");
        message.setIccid("23");
        message.setReserved(true);
        message.setDeviceId ("T00002");
        LocalDateTime dateTime = LocalDateTime.now();
        return message;
    }

    public static T0200 T0200(String clientId, boolean alarm, int no) {
//        String clientId = "1" + StrUtils.leftPad(id, 10, '0');

        T0200 message = new T0200();
//        message.setMessageId(JT808.位置信息汇报);
        message.setMessageId(JT808.位置信息查询应答);
        message.setProtocolVersion(1);
        message.setSerialNo(no);
        message.setVersion(true);
        message.setClientId(clientId);
        message.setWarnBit(1024);
        message.setStatusBit(2048);
        message.setLatitude(39915931);
        message.setLongitude(116403829);
        message.setAltitude(312);
        message.setSpeed(111);
        message.setDirection(99);
        LocalDateTime dateTime = LocalDateTime.now();
        message.setDeviceTime(dateTime);

        if (alarm) {
            AlarmADAS alarmADAS = new AlarmADAS();
            alarmADAS.setId(64);
            alarmADAS.setState(1);
            alarmADAS.setType(random.nextInt(1, 11));
            alarmADAS.setLevel(1);
            alarmADAS.setFrontSpeed(10);
            alarmADAS.setFrontDistance(10);
            alarmADAS.setDeviateType(1);
            alarmADAS.setRoadSign(1);
            alarmADAS.setRoadSignValue(10);
            alarmADAS.setSpeed(10);
            alarmADAS.setAltitude(100);
            alarmADAS.setLatitude(32111111);
            alarmADAS.setLongitude(123111111);
            alarmADAS.setAlarmTime(dateTime);
            alarmADAS.setStatusBit(1);
            alarmADAS.setDeviceId(clientId);
            alarmADAS.setDateTime(dateTime);
            alarmADAS.setSequenceNo(1);
            alarmADAS.setFileTotal(1);
            alarmADAS.setReserved(1);

            AlarmDSM alarmDSM = new AlarmDSM();
            alarmDSM.setId(65);
            alarmDSM.setState(2);
            alarmDSM.setType(random.nextInt(1, 17));
            alarmDSM.setLevel(2);
            alarmDSM.setFatigueDegree(20);
            alarmDSM.setReserved(20);
            alarmDSM.setSpeed(20);
            alarmDSM.setAltitude(200);
            alarmDSM.setLatitude(32222222);
            alarmDSM.setLongitude(123222222);
            alarmDSM.setAlarmTime(dateTime);
            alarmDSM.setStatusBit(2);
            alarmDSM.setDeviceId(clientId);
            alarmDSM.setDateTime(dateTime);
            alarmDSM.setSequenceNo(2);
            alarmDSM.setFileTotal(2);
            alarmDSM.setReserved(2);

            AlarmTPMS alarmTPMS = new AlarmTPMS();
            alarmTPMS.setId(66);
            alarmTPMS.setState(3);
            alarmTPMS.setSpeed(30);
            alarmTPMS.setAltitude(300);
            alarmTPMS.setLatitude(32333333);
            alarmTPMS.setLongitude(123333333);
            alarmTPMS.setAlarmTime(dateTime);
            alarmTPMS.setStatusBit(3);
            alarmTPMS.setDeviceId(clientId);
            alarmTPMS.setDateTime(dateTime);
            alarmTPMS.setSequenceNo(3);
            alarmTPMS.setFileTotal(3);
            alarmTPMS.setReserved(3);

            AlarmBSD alarmBSD = new AlarmBSD();
            alarmBSD.setId(67);
            alarmBSD.setState(4);
            alarmBSD.setType(random.nextInt(1, 3));
            alarmBSD.setSpeed(40);
            alarmBSD.setAltitude(400);
            alarmBSD.setLatitude(32444444);
            alarmBSD.setLongitude(123444444);
            alarmBSD.setAlarmTime(dateTime);
            alarmBSD.setStatusBit(4);
            alarmBSD.setDeviceId(clientId);
            alarmBSD.setDateTime(dateTime);
            alarmBSD.setSequenceNo(4);
            alarmBSD.setFileTotal(4);
            alarmBSD.setReserved(4);

            Map<Integer, Object> attributes = new TreeMap<>();
            attributes.put(Integer.valueOf(AlarmADAS.key), alarmADAS);
            attributes.put(Integer.valueOf(AlarmDSM.key), alarmDSM);
            attributes.put(Integer.valueOf(AlarmTPMS.key), alarmTPMS);
            attributes.put(Integer.valueOf(AlarmBSD.key), alarmBSD);

            message.setAttributes(attributes);
        }
        return message;
    }

}