/*
 * Copyright (c) 2006-2021, RT-Thread Development Team
 *
 * SPDX-License-Identifier: Apache-2.0
 *
 * Change Logs:
 * Date           Author       Notes
 * 2025-10-20     Administrator       the first version
 * 2025-11-12     Modified            Switch to IDLE interrupt mode (no DMA, no ringbuffer)
 * 2025-11-21     Fixed               Enable RX_IDLE mode correctly for RT-Thread 5.1
 */
#include <rtthread.h>
#include <rtdevice.h>
#include "data_comm.h"
#include <rs485.h>

#define DBG_TAG "SCCM_link"
#define DBG_LVL DBG_LOG
#include <rtdbg.h>

static struct rt_semaphore rx_sem;

#define RX_LINE_BUF_SIZE     1024
#define RS485_SAMPLE_SLAVE_SERIAL       "uart4"
#define RS485_SAMPLE_SLAVE_BAUDRATE     115200
#define RS485_SAMPLE_MASTER_PARITY      0 //0 -- none parity
#define RS485_SAMPLE_SLAVE_PIN          -1 //-1 -- nonuse rs485 mode control
#define RS485_SAMPLE_SLAVE_LVL          1
#define RS485_TOM_MS          50

void uart_thread_entry(void *parameter)
{
    rt_sem_init(&rx_sem, "rx_sem", 0, RT_IPC_FLAG_FIFO);

    static rt_uint8_t input[RX_LINE_BUF_SIZE];
        rs485_inst_t *hinst = rs485_create(RS485_SAMPLE_SLAVE_SERIAL, RS485_SAMPLE_SLAVE_BAUDRATE,
                RS485_SAMPLE_MASTER_PARITY, RS485_SAMPLE_SLAVE_PIN, RS485_SAMPLE_SLAVE_LVL);

        if (hinst == RT_NULL)
        {
            LOG_E("create LINK instance fail.");
            return;
        }

        rs485_set_recv_tmo(hinst, RS485_TOM_MS);
        if (rs485_connect(hinst) != RT_EOK)
        {
            rs485_destory(hinst);
            LOG_E("LINK connect fail.");
            return;
        }

    LOG_I("SCCM thread running on %s", RS485_SAMPLE_SLAVE_SERIAL);

    while (1)
    {
        int len = rs485_recv(hinst, input, sizeof(input));

        if (len > 0)
        {
            // 动态分配请求结构体（见之前完整代码）
            struct proc_request *req = rt_malloc(sizeof(struct proc_request));
            if (!req) continue;
            rt_strncpy(req->input, (const char *)input, sizeof(req->input));
            req->input_len = len;

            // 发送到处理线程
            if (rt_mq_send(request_mq, &req, sizeof(req)) == RT_EOK)
            {
                // 等待处理完成
                if (rt_mq_recv(response_mq, &req, sizeof(req), 500) >= RT_EOK)
                {
                    if(req->output_len>0) rs485_send(hinst, req->output, req->output_len);
                }
            }
            // 清理
            rt_free(req);
        }
    }
}

extern struct rt_memheap sram_DTCMRAM;
static struct rt_thread dat_uart_thread;
static void *dat_uart_stack __attribute__((aligned(4)))= RT_NULL ;
int start_uart_thread(void)
{
    rt_err_t db_err;
    dat_uart_stack = rt_memheap_alloc(&sram_DTCMRAM, 1024*2);
    db_err = rt_thread_init(&dat_uart_thread, "sccm", uart_thread_entry, RT_NULL,dat_uart_stack, 1024*2, 11, 10);
    if(db_err != RT_EOK)
    {
        LOG_D("Failed to create SCCM_uart thread!");
        return -1;
    }
    rt_thread_startup(&dat_uart_thread);
    LOG_I("Create SCCM_uart thread");
    return 0;
   /* rt_thread_t tid = rt_thread_create("sccm",uart_thread_entry,RT_NULL,2048,11,10);
    if (tid != RT_NULL)
    {
        rt_thread_startup(tid);
        LOG_I("Create SCCM_uart thread");
        return 0;
    }
    else
    {
        LOG_E("Failed to create SCCM_uart thread!");
        return -1;
    }*/
}
INIT_COMPONENT_EXPORT(start_uart_thread);