/*
 * Copyright (c) 2006-2021, RT-Thread Development Team
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Change Logs:
 * Date           Author       Notes
 * 2023-06-16     murmur       the first version
 */
//姿态调配用demo程序。固定数据包循环重发

#include <rtthread.h>

#define LOG_TAG "repeatSend"
#define LOG_LVL  LOG_LVL_DBG
#include <ulog.h>

#include <ttTR.h>
#include <usrcfg.h>
/* 定时器的控制块 */
static rt_timer_t timer1;
static struct rt_event readyToSend;

static rt_sem_t ttack= RT_NULL;
#define TIME_IS_UP 1<<1
void upTTflagtmp(void)
{
//    rt_event_send(&readyToSend, TT_IS_OK);
    rt_sem_release(ttack);
}


void repeatSend_thread_entry()
{
    static rt_uint8_t d[10][200] = { };
    static rt_uint8_t s[10] = { };
    while(tcpInit() != RT_EOK)
    {
        LOG_W("TT server is not ready.");
        rt_thread_mdelay(100);
    }
    LOG_D("TT server is ready.");
    while (1)
    {
        if (rt_event_recv(&readyToSend, TIME_IS_UP, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR, RT_WAITING_FOREVER,
        RT_NULL) == RT_EOK)
        {
//记录次数
//此次数为总定时超时次数
            add_val("allCnt");
//            if (rt_event_recv(&readyToSend, TT_IS_OK, RT_EVENT_FLAG_OR | RT_EVENT_FLAG_CLEAR,
//                    rt_tick_from_millisecond(1 * 60 * 1000),
//                    RT_NULL) == RT_EOK)//等待1分钟
            if(rt_sem_take(ttack, rt_tick_from_millisecond(1 * 60 * 1000)) == RT_EOK)
            {
                LOG_D("TT is ready.");
                char *f = "2023_06_17_16_30_00_000.bin";
                rt_uint8_t len = 0;
                len = pack_File(f, 0, d, s);
                LOG_D("Pack done.");
                if (len)
                {
                    for (size_t var = 0; var < len; var++)
                    {
                        sendMsg(d[var], s[var]);
                        rt_uint8_t rd[30];
                        tcpRec(rd);
                        LOG_HEX("ack",16,rd,30);
                        rt_thread_mdelay(3000);
//                        LOG_HEX("d", 27, d[var], s[var]);
                    }
//                    tcpClose();
                    LOG_I("send msg Done.");
                    //记录次数
                    //此次数为发送成功次数
                    add_val("okCnt");
                }
            }
            else
            {
                LOG_W("TT is not ready.");
            }
        }
    }
}
    /* 定时器1超时函数 */
    static void timeout1(void *parameter)
    {

        LOG_D("定时时间到，准备发送数据");
        rt_event_send(&readyToSend, TIME_IS_UP);
    }





    void timer_demo()
    {
    /* 创建定时器1  周期定时器 */
    timer1 = rt_timer_create("repeatSendtimer", timeout1,
                             RT_NULL, rt_tick_from_millisecond(5*60*1000),
                             RT_TIMER_FLAG_PERIODIC);

    /* 启动定时器1 */
    if (timer1 != RT_NULL)
        rt_timer_start(timer1);

    /* 创建 serial 线程 */
       rt_thread_t thread = rt_thread_create("repSendT", repeatSend_thread_entry, RT_NULL, 1024*3, 25+1, 10);
       /* 创建成功则启动线程 */
       if (thread != RT_NULL)
       {
           rt_thread_startup(thread);
       }
       else
       {
          LOG_E("Failed to create thread.");
       }
}
  MSH_CMD_EXPORT(timer_demo,定时发送)
void inievt()
  {

      pwTT_thread_entry("1");//开机
      rt_event_init(&readyToSend, "repSend", RT_IPC_FLAG_PRIO);
      ttack = rt_sem_create("ttack", 0, RT_IPC_FLAG_PRIO);

      rt_hw_stm32_eth_init();//激活网口
      rt_thread_mdelay(10*1000);
      repGetTT();//持续更新
//      runTT();
  }
INIT_APP_EXPORT(inievt);
INIT_APP_EXPORT(timer_demo);


MSH_CMD_EXPORT(upTTflagtmp,喂数据);