{{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