#include <signal.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <unistd.h>
#include <fstream>
#include <iostream>
#include <string.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <boost/thread.hpp>
#include <zlog.h>
#include "platform/platform_init.hpp"
#include "common/common_func.hpp"
#include "common/global.hpp"
#include "threadfunc/thread_func.hpp"
#include "utility/secure.hpp"
#include "utility/aes.h"
#include "dbaccess/sql_db.hpp"
#include "uart/uart.hpp"
#include "minilzo/minilzo.h"

extern std::vector<RecvData> g_VecWaveDataX;
extern std::vector<RecvData> g_VecWaveDataY;
extern std::vector<RecvData> g_VecWaveDataZ;

zlog_category_t *zct = NULL;
zlog_category_t *zbt = NULL;

int main(int argc, char *argv[]) {
    
    int rc = zlog_init("/opt/configenv/wlg.conf");
    if (rc) {
        printf("init failed\n");
        return -1;
    }

    zct = zlog_get_category("wlg");
    zbt = zlog_get_category("cfg");
    if (!zct || !zbt) {
        printf("get category fail\n");
        zlog_fini();
        return -2;
    }

    zlog_info(zbt, " Firmware compile time:%s %s,version %s", __DATE__, __TIME__, GlobalConfig::Version.c_str());
    zlog_info(zbt, "####CIDNSOFT start####");       
    
    g_VecWaveDataX.reserve(1000);
    g_VecWaveDataY.reserve(1000);
    g_VecWaveDataZ.reserve(1500);
    boost::thread::attributes attrs;
    attrs.set_stack_size(1024 * 1024);

    PlatformInit::Init();

    sqlite_db_ctrl::instance().InintGateway();

    uart_inst::instance().InitZigbeeHW();
    // UDP，接收客户端发来的组播消息，用于外接 QT 专家系统，屏蔽之
    boost::thread searchT(SearchThread);
    searchT.detach();

    // 串口处理线程,用于与 ZigBee 模块通信，通过ZigBee无线通信技术与无线传感器通信
    boost::thread uartReadTh(UartStart);
    uartReadTh.detach();

    boost::thread uartTestReadTh(TestUart);
    uartReadTh.detach();

    // boost::thread InitModuleReadTh(InitModule);
    // InitModuleReadTh.detach();

    InitModule();

    // 休眠2秒，等待串口线程初始化完毕
    sleep(2);

    // 串口数据处理,读取传感器原始波形数据
    boost::thread uartWaveReadTh(UartStartWave);
    uartWaveReadTh.detach();
    //启动 RUN LED
    boost::thread startRunLED(RunLED);
    startRunLED.detach();


#ifdef NR5G_MODULE
    print_info("NR5G_MODULE \n");
    // 5G
    boost::thread startCSQ(GetCSQ);
    startCSQ.detach();
#ifndef NR5G_MEIGE
    boost::thread startDial(Dial5G);
    startDial.detach();
#endif
#endif

#ifdef Q4G_MODULE
    boost::thread startCSQ(GetCSQ);
    startCSQ.detach();
    zlog_info(zbt, "4G_MODULE");  

#endif
#ifdef WIFI_MODULE
    print_info("WiFi_MODULE \n");
#endif

    //通过UDP接收数据
    boost::thread StartConnectSys(attrs, StartUdpSys);
    StartConnectSys.detach();

    //循环检测线程
    boost::thread normalCheckThread(attrs, CheckThread);
    normalCheckThread.detach();

    //启动cgi server
    boost::thread startTcpCgi(attrs, StartCgiServer);
    startTcpCgi.detach();

    // //启动CMT server
    // boost::thread startTcpCmt(attrs, StartCMTServer);
    // startTcpCmt.detach();

    sleep(5);
    uart_inst::instance().ZigbeeParameterConfig();
    sleep(1);
    uart_inst::instance().UpdateZigbeeInfoCtrl();

    //启动 mqtt客户端
    boost::thread startMqtt(StartMqttClient);
    startMqtt.detach();

    //启动 mqtt 心跳
    boost::thread startHeart(HeartRep);
    startHeart.detach();

    boost::thread DiskCheck(attrs, DiskSpaceCheck);
    DiskCheck.detach();

    if (lzo_init() != LZO_E_OK) {
        zlog_error(zbt, "internal error - lzo_init() failed !!!");
        zlog_error(zbt, "(this usually indicates a compiler bug - try recompiling\nwithout optimizations, and enable '-DLZO_DEBUG' for diagnostics)");
    }

    int fd = OpenWatchDog();
    int count = 0;
    while (GlobalConfig::QuitFlag_G) {
        gpio_set(GlobalConfig::GPIO_G.hardWatchDog, 1);
        usleep(20000);
        gpio_set(GlobalConfig::GPIO_G.hardWatchDog, 0);
        WriteWatchDog(fd);
        sleep(20);
        if (GlobalConfig::threadStatus == 0) {
            count++;
        } else if (GlobalConfig::threadStatus == 1) {
            GlobalConfig::threadStatus = 0;
            count = 0;
        }
        if (count >= 30) {
            zlog_error(zbt, "===========threadStatus ========failed");
            break;
        }
    }
    return 0;
}