#include <sys/time.h>
#include <sys/timeb.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/ioctl.h>
#include <sys/socket.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/shm.h>
#include <sys/mman.h>
#include <linux/wireless.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdbool.h>

#include <unistd.h>
#include <stdarg.h>
#include <stdio.h>      /*標準輸入輸出定義*/
#include <stdlib.h>     /*標準函數庫定義*/
#include <unistd.h>     /*Unix 標準函數定義*/
#include <fcntl.h>      /*檔控制定義*/
#include <termios.h>    /*PPSIX 終端控制定義*/
#include <errno.h>      /*錯誤號定義*/
#include <errno.h>
#include <string.h>
#include <time.h>
#include <ctype.h>
#include <ifaddrs.h>
#include <math.h>

#include "../Define/define.h"
#include "../Config.h"
#include "PrimaryComm.h"
#include "Module_PrimaryComm.h"

struct SysConfigAndInfo *ShmSysConfigAndInfo;
struct StatusCodeData *ShmStatusCodeData;
struct PrimaryMcuData *ShmPrimaryMcuData;

const char *priPortName = "/dev/ttyS1";
uint8_t gun_count; //DS60-120 add

struct ChargingInfoData *ChargingData[CHAdeMO_QUANTITY + CCS_QUANTITY + GB_QUANTITY];

//------------------------------------------------------------------------------
int StoreLogMsg(const char *fmt, ...)
{
    char Buf[4096 + 256];
    char buffer[4096];
    va_list args;
    struct timeb  SeqEndTime;
    struct tm *tm;

    va_start(args, fmt);
    int rc = vsnprintf(buffer, sizeof(buffer), fmt, args);
    va_end(args);

    memset(Buf, 0, sizeof(Buf));
    ftime(&SeqEndTime);
    SeqEndTime.time = time(NULL);
    tm = localtime(&SeqEndTime.time);

    if (ShmSysConfigAndInfo->SysConfig.SwitchDebugFlag == YES) {
        sprintf(Buf, "%02d:%02d:%02d:%03d - %s",
                tm->tm_hour, tm->tm_min, tm->tm_sec, SeqEndTime.millitm, buffer);
        printf("%s \n", Buf);
    } else {
        sprintf(Buf, "echo \"%04d-%02d-%02d %02d:%02d:%02d:%03d - %s\" >> /Storage/SystemLog/[%04d.%02d]SystemLog",
                tm->tm_year + 1900, tm->tm_mon + 1, tm->tm_mday, tm->tm_hour, tm->tm_min, tm->tm_sec, SeqEndTime.millitm,
                buffer,
                tm->tm_year + 1900, tm->tm_mon + 1);
        system(Buf);
    }

    return rc;
}

int DiffTimeb(struct timeb ST, struct timeb ET)
{
    //return milli-second
    unsigned int StartTime, StopTime;

    StartTime = (unsigned int)ST.time;
    StopTime = (unsigned int)ET.time;
    return (StopTime - StartTime) * 1000 + ET.millitm - ST.millitm;
}

//=================================
// Common routine
//=================================
char *getTimeString(void)
{
    char *result = malloc(21);
    time_t timep;
    struct tm *p;
    time(&timep);
    p = gmtime(&timep);

    sprintf(result, "[%04d-%02d-%02d %02d:%02d:%02d]", (1900 + p->tm_year), (1 + p->tm_mon), p->tm_mday, p->tm_hour, p->tm_hour, p->tm_sec);

    return result;
}

//==========================================
// Init all share memory
//==========================================
int InitShareMemory()
{
    int result = PASS;
    int MeterSMId;

    //creat ShmSysConfigAndInfo
    if ((MeterSMId = shmget(ShmSysConfigAndInfoKey, sizeof(struct SysConfigAndInfo),  0777)) < 0) {
        result = FAIL;
    } else if ((ShmSysConfigAndInfo = shmat(MeterSMId, NULL, 0)) == (void *) - 1) {
        result = FAIL;
    }

    //creat ShmStatusCodeData
    if ((MeterSMId = shmget(ShmStatusCodeKey, sizeof(struct StatusCodeData),  0777)) < 0) {
        result = FAIL;
    } else if ((ShmStatusCodeData = shmat(MeterSMId, NULL, 0)) == (void *) - 1) {
        result = FAIL;
    }

    //creat ShmStatusCodeData
    if ((MeterSMId = shmget(ShmPrimaryMcuKey, sizeof(struct PrimaryMcuData), 0777)) < 0) {
        result = FAIL;
    } else if ((ShmPrimaryMcuData = shmat(MeterSMId, NULL, 0)) == (void *) - 1) {
        result = FAIL;
    }

    return result;
}

//================================================
// Function
//================================================
void GetFwAndHwVersion(int fd)
{
    Ver ver = {0};

    if (Query_FW_Ver(fd, OP_ADDR_IO_EXTEND, &ver) == PASS) {
        //log_info("Primary FW Rev = %s \n", ver.Version_FW);
        strcpy((char *)ShmPrimaryMcuData->version, ver.Version_FW);
        strcpy((char *) ShmSysConfigAndInfo->SysInfo.CsuPrimFwRev, ver.Version_FW);
    }

    //if (Query_HW_Ver(fd, OP_ADDR_IO_EXTEND, &ver) == PASS)
    //    ;//log_info("Primary HW Rev  = %s \n", ver.Version_HW);
}

void GetInputGpioStatus(int fd)
{
    uint8_t dispenserSwTmp = 0;
    Gpio_in gpio_in = {0};
    static uint8_t dispenserSw = 0;

    //log_info("GetInputGpioStatus \n");
    if (Query_Gpio_Input(fd, OP_ADDR_IO_EXTEND, &gpio_in) == PASS) {
#if !defined DD360 && !defined DD360Audi && !defined DD360ComBox
        static uint8_t _curDeviceStatus[3] = {0};
        static uint8_t _reCheckCount[3] = {0};

        //DS60-120 add
        if (_curDeviceStatus[_PRIMARY_CHECK_TAG_AC_CONTACT] != gpio_in.AC_Connector) {
            if (_reCheckCount[_PRIMARY_CHECK_TAG_AC_CONTACT] >= 3) {
                _curDeviceStatus[_PRIMARY_CHECK_TAG_AC_CONTACT] = gpio_in.AC_Connector;
                ShmSysConfigAndInfo->SysInfo.AcContactorStatus =
                    ShmPrimaryMcuData->InputDet.bits.AcContactorDetec =
                        gpio_in.AC_Connector;
            } else {
                _reCheckCount[_PRIMARY_CHECK_TAG_AC_CONTACT]++;
            }
        } else {
            _reCheckCount[_PRIMARY_CHECK_TAG_AC_CONTACT] = 0;
        }

        if (_curDeviceStatus[_PRIMARY_CHECK_TAG_MAIN_BREAKER] != gpio_in.AC_MainBreaker) {
            if (_reCheckCount[_PRIMARY_CHECK_TAG_MAIN_BREAKER] >= 3) {
                _curDeviceStatus[_PRIMARY_CHECK_TAG_MAIN_BREAKER] = gpio_in.AC_MainBreaker;
                ShmPrimaryMcuData->InputDet.bits.AcMainBreakerDetec = gpio_in.AC_MainBreaker;
            } else {
                _reCheckCount[_PRIMARY_CHECK_TAG_MAIN_BREAKER]++;
            }
        } else {
            _reCheckCount[_PRIMARY_CHECK_TAG_MAIN_BREAKER] = 0;
        }
        //ShmSysConfigAndInfo->SysInfo.AcContactorStatus = ShmPrimaryMcuData->InputDet.bits.AcContactorDetec = gpio_in.AC_Connector;
        //ShmPrimaryMcuData->InputDet.bits.AcMainBreakerDetec = gpio_in.AC_MainBreaker;
#else
        if ((strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[7], "V", 1) == 0) ||
                (strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[9], "V", 1) == 0) ||
                (strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[7], "F", 1) == 0) ||
                (strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[9], "F", 1) == 0)
           ) {
            ShmStatusCodeData->AlarmCode.AlarmEvents.bits.CcsLiquidChillerWaterLevelWarning = ~gpio_in.AC_Connector;
            ShmStatusCodeData->FaultCode.FaultEvents.bits.CcsLiquidChillerWaterLevelFault = ~gpio_in.AC_MainBreaker;
        } else {
            ShmStatusCodeData->AlarmCode.AlarmEvents.bits.CcsLiquidChillerWaterLevelWarning = gpio_in.AC_Connector;
            ShmStatusCodeData->FaultCode.FaultEvents.bits.CcsLiquidChillerWaterLevelFault = gpio_in.AC_MainBreaker;
        }
#endif //!defined DD360 && !defined DD360Audi

        ShmPrimaryMcuData->InputDet.bits.SpdDetec = gpio_in.SPD;
#if defined DD360 ||defined DD360Audi || defined DD360ComBox

#if defined DD360ComBox
        ShmPrimaryMcuData->InputDet.bits.DoorOpen = gpio_in.Door_Open;
#else
        ShmPrimaryMcuData->InputDet.bits.DoorOpen = ~gpio_in.Door_Open;
#endif //

        ShmPrimaryMcuData->InputDet.bits.Key0 = ~gpio_in.Key[0] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key1 = ~gpio_in.Key[1] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key2 = ~gpio_in.Key[2] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key3 = ~gpio_in.Key[3] & 0x01;
        //ShmPrimaryMcuData->InputDet.bits.EmergencyButton = gpio_in.Emergency_Btn;
#else

        ShmPrimaryMcuData->InputDet.bits.Key0 = gpio_in.Key[0] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key1 = gpio_in.Key[1] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key2 = gpio_in.Key[2] & 0x01;
        ShmPrimaryMcuData->InputDet.bits.Key3 = gpio_in.Key[3] & 0x01;
        //ShmPrimaryMcuData->InputDet.bits.EmergencyButton = ~gpio_in.Emergency_Btn;
        ShmPrimaryMcuData->InputDet.bits.DoorOpen = gpio_in.Door_Open;
#endif //defined DD360 ||defined DD360Audi

#if defined DD360ComBox
        ShmPrimaryMcuData->InputDet.bits.EmergencyButton = ~gpio_in.Emergency_Btn;
#else
        ShmPrimaryMcuData->InputDet.bits.EmergencyButton = gpio_in.Emergency_Btn;
#endif //

        dispenserSwTmp |= (ShmPrimaryMcuData->InputDet.bits.Key0);
        dispenserSwTmp |= (ShmPrimaryMcuData->InputDet.bits.Key1 << 1);
        dispenserSwTmp |= (ShmPrimaryMcuData->InputDet.bits.Key2 << 2);
        dispenserSwTmp |= (ShmPrimaryMcuData->InputDet.bits.Key3 << 3);

        if (dispenserSwTmp != dispenserSw) {
            dispenserSw = dispenserSwTmp;
            log_info("Dispenser switch number =  %d, bit = %d, %d, %d, %d\r\n",
                     dispenserSw,
                     ShmPrimaryMcuData->InputDet.bits.Key3,
                     ShmPrimaryMcuData->InputDet.bits.Key2,
                     ShmPrimaryMcuData->InputDet.bits.Key1,
                     ShmPrimaryMcuData->InputDet.bits.Key0);
        }

        ShmPrimaryMcuData->InputDet.bits.Button1 = gpio_in.Button[0];
        ShmPrimaryMcuData->InputDet.bits.Button2 = gpio_in.Button[1];

        /*printf(" gpio_in.Key[0]~ gpio_in.Key[3]=%d, %d, %d, %d\n",
        ShmPrimaryMcuData->InputDet.bits.Key0 , ShmPrimaryMcuData->InputDet.bits.Key1,
        ShmPrimaryMcuData->InputDet.bits.Key2,ShmPrimaryMcuData->InputDet.bits.Key3);
        printf("ShmStatusCodeData->AlarmCode.AlarmEvents.bits.CcsLiquidChillerWaterLevelWarning=%d\n", ShmStatusCodeData->AlarmCode.AlarmEvents.bits.CcsLiquidChillerWaterLevelWarning);
        printf("ShmStatusCodeData->FaultCode.FaultEvents.bits.CcsLiquidChillerWaterLevelFault=%d\n", ShmStatusCodeData->FaultCode.FaultEvents.bits.CcsLiquidChillerWaterLevelFault);
        */
        //log_info("left = %d \n", ShmPrimaryMcuData->InputDet.bits.Button1);
        //log_info("right = %d \n", ShmPrimaryMcuData->InputDet.bits.Button2);
        //log_info("ShmSysConfigAndInfo->SysInfo.AcContactorStatus = %d \n", ShmSysConfigAndInfo->SysInfo.AcContactorStatus);
#if !defined DD360 && !defined DD360Audi && !defined DD360ComBox
        if (ShmPrimaryMcuData->InputDet.bits.AcMainBreakerDetec == YES) {
            log_error("AC Mainbreaker occur. \n");
        }
#endif //!defined DD360 && !defined DD360Audi
    }
}

static void checkChillerStatus(Gpio_out *gpio)
{
    uint8_t gunIndex = 0;
    uint8_t chillerCount = 0;
    struct ChargingInfoData *pDcChargingInfo = NULL;
    static ChillerInfo fChillerInfo[2] = {0}, *pChillerInfo = NULL;
    Gpio_out *pGpio = (Gpio_out *)gpio;

    if ((strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[7], "V", 1) == 0) ||
            (strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[7], "F", 1) == 0)) {
        chillerCount++;
    }

    if ((strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[9], "V", 1) == 0) ||
            (strncmp((char *)&ShmSysConfigAndInfo->SysConfig.ModelName[9], "F", 1) == 0)) {
        chillerCount++;
    }

    if (chillerCount == 0) {
        pGpio->AC_Connector = 0x00;
        return;
    }

    for (gunIndex = 0; gunIndex < chillerCount; gunIndex++) {
        pDcChargingInfo = (struct ChargingInfoData *)ChargingData[gunIndex];
        pChillerInfo = (ChillerInfo *)&fChillerInfo[gunIndex];

        if ((pDcChargingInfo->PresentChargingCurrent) >= 150) {
            pChillerInfo->ChillerSwitch = YES;
            pChillerInfo->ChillerOnTime = time((time_t *)NULL);
        } else {
            if (pChillerInfo->ChillerSwitch == YES) {
                if ((pDcChargingInfo->PresentChargingCurrent) >= 100) {
                    pChillerInfo->ChillerSwitch = YES;
                    pChillerInfo->ChillerOnTime = time((time_t *)NULL);
                } else {
                    if ((time((time_t *)NULL) - pChillerInfo->ChillerOnTime) >= 600) {
                        pChillerInfo->ChillerSwitch = NO;
                    } else {
                        pChillerInfo->ChillerSwitch = YES;
                    }
                }
            } else {
                pChillerInfo->ChillerSwitch = NO;
            }
        }
    }

    pGpio->AC_Connector = pChillerInfo->ChillerSwitch;//Chiller ON/OFF Control, "0: Chiller disable, 1: Chiller enable"
}

void SetOutputGpio(int fd, uint8_t outputValue)
{
    Gpio_out gpio;
    LedConfig *pLedConfig = (LedConfig *)&outputValue;
    static uint8_t flash = NO;

    if (strcmp((char *)ShmSysConfigAndInfo->SysInfo.LcmHwRev, " ") == 0x00) {
        if (flash == NO) {
            flash = YES;
        } else {
            flash = NO;
        }
    } else {
        if (flash == NO) {
            flash = YES;
        }
    }

    pLedConfig->LeftButtonLed = flash;
    pLedConfig->RightButtonLed = flash;

    gpio.Button_LED[0] = pLedConfig->LeftButtonLed;
    gpio.Button_LED[1] = pLedConfig->RightButtonLed;

    gpio.System_LED[0] = pLedConfig->GreenLED;
    gpio.System_LED[1] = pLedConfig->YellowLED;
    gpio.System_LED[2] = pLedConfig->RedLED;
    gpio.System_LED[3] = 0x00;

    checkChillerStatus(&gpio);

    gpio.AC_Breaker = 0x00;

    Config_Gpio_Output(fd, OP_ADDR_IO_EXTEND, &gpio);
}

void SetRtcData(int fd)
{
    Rtc rtc = {0};
    struct timeb csuTime;
    struct tm *tmCSU;

    ftime(&csuTime);
    tmCSU = localtime(&csuTime.time);
    //log_info("Time : %04d-%02d-%02d %02d:%02d:%02d \n",
    //         tmCSU->tm_year + 1900,
    //         tmCSU->tm_mon + 1,
    //         tmCSU->tm_mday,
    //         tmCSU->tm_hour,
    //         tmCSU->tm_min,
    //         tmCSU->tm_sec);

    rtc.RtcData[0] = '0' + (tmCSU->tm_year + 1900) / 1000 % 10;
    rtc.RtcData[1] = '0' + (tmCSU->tm_year + 1900) / 100 % 10;
    rtc.RtcData[2] = '0' + (tmCSU->tm_year + 1900) / 10 % 10;
    rtc.RtcData[3] = '0' + (tmCSU->tm_year + 1900) / 1 % 10;

    rtc.RtcData[4] = '0' + (tmCSU->tm_mon + 1) / 10 % 10;
    rtc.RtcData[5] = '0' + (tmCSU->tm_mon + 1) / 1 % 10;

    rtc.RtcData[6] = '0' + (tmCSU->tm_mday) / 10 % 10;
    rtc.RtcData[7] = '0' + (tmCSU->tm_mday) / 1 % 10;

    rtc.RtcData[8] = '0' + (tmCSU->tm_hour) / 10 % 10;
    rtc.RtcData[9] = '0' + (tmCSU->tm_hour) / 1 % 10;

    rtc.RtcData[10] = '0' + (tmCSU->tm_min) / 10 % 10;
    rtc.RtcData[11] = '0' + (tmCSU->tm_min) / 1 % 10;

    rtc.RtcData[12] = '0' + (tmCSU->tm_sec) / 10 % 10;
    rtc.RtcData[13] = '0' + (tmCSU->tm_sec) / 1 % 10;

    if (Config_Rtc_Data(fd, OP_ADDR_IO_EXTEND, &rtc) == PASS) {
        //log_info("SetRtc sucessfully. \n");
    } else {
        //log_info("SetRtc fail. \n");
    }
}

void SetModelName(int fd)
{
    if (Config_Model_Name(fd, OP_ADDR_IO_EXTEND, ShmSysConfigAndInfo->SysConfig.ModelName) == PASS) {
    }
}

//================================================
// Main process
//================================================
int InitComPort()
{
    int fd;
    struct termios tios;

    fd = open(priPortName, O_RDWR);
    if (fd <= 0) {
#ifdef SystemLogMessage
        log_error("open 407 Communication port NG \n");
#endif
        return -1;
    }
    ioctl (fd, TCGETS, &tios);
    tios.c_cflag = B115200 | CS8 | CLOCAL | CREAD;
    tios.c_lflag = 0;
    tios.c_iflag = 0;
    tios.c_oflag = 0;
    tios.c_cc[VMIN] = 0;
    tios.c_cc[VTIME] = (uint8_t)1;
    tios.c_lflag = 0;
    tcflush(fd, TCIFLUSH);
    ioctl (fd, TCSETS, &tios);

    return fd;
}

unsigned long GetTimeoutValue(struct timeval _sour_time)
{
    struct timeval _end_time;
    gettimeofday(&_end_time, NULL);

    return 1000000 * (_end_time.tv_sec - _sour_time.tv_sec) + _end_time.tv_usec - _sour_time.tv_usec;
}

int FindChargingInfoData(uint8_t target, struct ChargingInfoData **chargingData)
{
    for (uint8_t index = 0; index < CHAdeMO_QUANTITY; index++) {
        if (ShmSysConfigAndInfo->SysInfo.ChademoChargingData[index].Index == target) {
            chargingData[target] = &ShmSysConfigAndInfo->SysInfo.ChademoChargingData[index];
            return 1;
        }
    }

    for (uint8_t index = 0; index < CCS_QUANTITY; index++) {
        if (ShmSysConfigAndInfo->SysInfo.CcsChargingData[index].Index == target) {
            chargingData[target] = &ShmSysConfigAndInfo->SysInfo.CcsChargingData[index];
            return 1;
        }
    }

    for (uint8_t index = 0; index < GB_QUANTITY; index++) {
        if (ShmSysConfigAndInfo->SysInfo.GbChargingData[index].Index == target) {
            chargingData[target] = &ShmSysConfigAndInfo->SysInfo.GbChargingData[index];
            return 1;
        }
    }

    return 0;
}

void Initialization() //DS60-120 add
{
    bool isPass = false;
    while (!isPass) {
        isPass = true;
        for (uint8_t _index = 0; _index < gun_count; _index++) {
            if (!FindChargingInfoData(_index, &ChargingData[0])) {
                log_error("EvComm (main) : FindChargingInfoData false \n");
                isPass = false;
                break;
            }
        }
        sleep(1);
    }
}

int main(void)
{
    int Uart1Fd = -1;

    if (InitShareMemory() == FAIL) {
        log_error("InitShareMemory NG\r\n");
        if (ShmStatusCodeData != NULL) {
            ShmStatusCodeData->AlarmCode.AlarmEvents.bits.FailToCreateShareMemory = 1;
        }
        sleep(5);
        return 0;
    }

    //DS60-120 remove
    //for (uint8_t _index = 0; _index < ShmSysConfigAndInfo->SysConfig.TotalConnectorCount; _index++) {
    //    if (!FindChargingInfoData(_index, &ChargingData[0])) {
    //        log_error("FindChargingInfoData false \n");
    //        break;
    //    }
    //}

    Uart1Fd = InitComPort();
    //log_info("407 Port id = %d \n", Uart1Fd);

    if (Uart1Fd < 0) {
#ifdef SystemLogMessage
        log_error("InitComPort (Uart1 : AM3352 - STM32) NG");
#endif
        if (ShmStatusCodeData != NULL) {
            ShmStatusCodeData->AlarmCode.AlarmEvents.bits.CsuInitFailed = 1;
        }
        sleep(5);

        return 0;
    }

    SetRtcData(Uart1Fd);
    SetModelName(Uart1Fd);

    gun_count = ShmSysConfigAndInfo->SysConfig.TotalConnectorCount;

    Initialization();

    for (;;) {
        // 程序開始之前~ 必須先確定 FW 版本與硬體版本，確認後!!~ 該模組才算是真正的 Initial Comp.
        // 模組更新 FW 後，需重新做
        if (ShmPrimaryMcuData->SelfTest_Comp != PASS) {
            //log_info("(407) Get Fw and Hw Ver. \n");
            GetFwAndHwVersion(Uart1Fd);
            sleep(1);
            ShmPrimaryMcuData->SelfTest_Comp = PASS;
        } else {
            SetOutputGpio(Uart1Fd, ShmPrimaryMcuData->OutputDrv.OutputDrvValue[0]);

            GetInputGpioStatus(Uart1Fd);
        }

        usleep(50000);
    }

    return FAIL;
}