{{main.c(uploading...)}}

include "wm_include.h"

include "FreeRTOS.h"

include "task.h"

include "wm_cpu.h"

include "wm_dma.h"

include "wm_gpio_afsel.h"

include "wm_timer.h"

include "wm_bt.h"

include "wm_pmu.h"

include "cJSON.h"

include "libemqtt.h"

include "lwip/netif.h"

include <string.h>

tls_os_task_t Task1_HandHdle;
tls_os_task_t Task2_HandHdle;

define DEMO_TASK_SIZE2 1024*4

static OS_STK DemoTaskStk2[DEMO_TASK_SIZE2];

define DEMO_TASK_SIZE1 1024*6

static OS_STK DemoTaskStk1[DEMO_TASK_SIZE1];

xTaskHandle tcpclient_handle,http_handle;

typedef struct
{

char ssid[33];
char pwd[65];

}Wifi_flash; //账号密码结构体

int Wifi_Connect(char ssid, char pwd);
int Mqtt_Publish_Msg_All(char *msg);

void control_test()
{

char *data;
int g = tls_gpio_read(LED_2);
cJSON *IOTJSObject1=NULL, *IOTJSObject2=NULL;
char json_data[250];
if(g==0)
{
    printf("relay open !!!\r\n");
    tls_gpio_write(LED_0,0);
    tls_gpio_write(LED_1,1);
    tls_gpio_write(LED_2,1);
}
else
{
    printf("relay close !!!\r\n");
    tls_gpio_write(LED_0,1);
    tls_gpio_write(LED_1,0);
    tls_gpio_write(LED_2,0);
}
if(1 != Mqtt_Publish_Msg(json_data))
    printf("MQTTSendData servicemsg error\n");
else
    printf("MQTTSendData servicemsg ok 2\n");

}

void tls_ble_output_func(uint8_t *data,uint32_t len)
{

printf("BLE-->free22  %d Byte\n", tls_mem_get_avail_heapsize());
char cpy[40]={0};
char *ret;
printf("data = %s,len = %d\n",data,len);
if((len!=0)&&(data!=NULL))
{
    memcpy(cpy,data,len);
    memset(bt_id_pwd,0,sizeof(bt_id_pwd));
    strcat(bt_id_pwd,cpy);
}
if(strcmp(bt_id_pwd,"control")==0)
{
    control_test();
    printf("BLE-->free33  %d Byte\n", tls_mem_get_avail_heapsize());
    return;
}

}

void ble_Bluetooth_On()
{

demo_bt_enable();
tls_ble_server_demo_api_init(tls_ble_output_func);

}
void ble_Bluetooth_Off()
{

tls_ble_server_demo_api_deinit();
demo_bt_destroy();
tls_os_time_delay(1 * 500);

}

void demo_console_task1(void *sdata)
{

//MQTT连接
int get_sta=0,socket_num = 1;
int keep_p=1;
int packet_length=0;

while(1)
{
    get_sta = tls_wifi_get_state();
    if(get_sta == 3)
    {
        if(ft_connect)
        {
            socket_num = Mqtt_Socket_Init();
            if(socket_num == 0)
            {
                ft_connect = 0;
                if(reset_flag == 1)
                {
                    reset_flag = 0;
                    send_reset();
                }
                Get_Mac();
                get_state();
                
                tls_timer_start(timer_id_3);
                Mqtt_Ping_Msg = 0;
                keep_mp=0;
            }
            else
            {
                printf("Create a failure\n");
                ft_connect = 1;//连接失败标志位 ，再次连接
                tls_os_time_delay(2 * 500);
            }
        }
        if(Mqtt_Ping_Msg == 1)
        {
            keep_p = mqtt_ping(&mqtt_broker_handle);
            if(keep_p == -1)
                mqtt_close_socket(&mqtt_broker_handle);
            Mqtt_Ping_Msg = 0;
            keep_mp=0;
        }

        if(socket_num == 0)
        {
            packet_length = mqtt_read_packet(1,0);
            if(packet_length!=-1000)
                printf("Error(%d) on read packet!\n", packet_length);
            if((packet_length == -1)||(packet_length == -2))
            {
                tls_timer_stop(timer_id_3);
                Mqtt_Ping_Msg = 0;
                printf("Error(%d) on read packet!\n", packet_length);
                mqtt_close_socket(&mqtt_broker_handle);
                ft_connect = 1;
            }
        }
    }
    if(get_sta != 3)
    {
        tls_os_time_delay(5 * 500);
        printf("task stop\n");
        ft_connect = 1;
        Mqtt_Ping_Msg = 0;
        tls_timer_stop(timer_id_3);
        task_flag = 1;
        tls_os_task_suspend(Task1_HandHdle);//任务挂起,WiFi未连接将当前任务挂起
    }
}

}

void demo_console_task2(void *sdata)
{

int spd,auto_cnt;
int test = 0;
u8 auto_reconnect1 = WIFI_AUTO_CNT_ON;
ble_Bluetooth_On();
Wifi_Connect(my_ssid0, my_password0);

while(1)
{
    auto_cnt = tls_wifi_get_state();
    if(((auto_cnt != 3)&&(task_flag == 1)&&(xTaskIsTaskSuspended(Task1_HandHdle)==0))||(switchover_wifi==1))
    {
        ft_connect = 1;
        task_flag_1 = 0;
        tls_timer_stop(timer_id_3);
        tls_os_task_suspend(Task1_HandHdle);
        tls_wifi_auto_connect_flag(WIFI_AUTO_CNT_FLAG_SET,&auto_reconnect1);
        task_flag = 1;
    }

    if((auto_cnt == 3)&&(task_flag == 1))
    {
        task_flag = 0;
        Ble_flag = 0;
        tls_timer_stop(timer_id_2);
        tls_os_time_delay(1 * 500);
        test = tls_os_task_resume(Task1_HandHdle);
    }
    tls_os_time_delay(1 * 25);
}

}

void UserMain(void)
{

Get_Mac();
timer_id_1 = timer_func(1000,1,isr_timer_irq);
timer_id_2 = timer_func(200,1,isr_timer_irq_buling);
timer_id_3 = timer_func(1000,1,isr_timer_irq_ping);//MQTT心跳包定时器
timer_id_4 = timer_func(120000,0,isr_timer_irq_Ble);

tls_os_task_create(&Task2_HandHdle,"smartconfig_task2",demo_console_task2,NULL,(void *)DemoTaskStk2,DEMO_TASK_SIZE2 * sizeof(u32),DEMO_TASK_PRIO,0);//高
tls_os_task_create(&Task1_HandHdle,"smartconfig_task1",demo_console_task1,NULL,(void *)DemoTaskStk1,DEMO_TASK_SIZE1 * sizeof(u32),DEMO_SOCKET_C_TASK_PRIO,0);//低

}

endif