#include "common.h"
#include "eeprom.h"
#include "flash.h"
#include "detection.h"
#include "fwdgt.h"
#include "haddr.h"
#include "relay.h"
#include "lock.h"
#include "uart.h"
#include "timer.h"
#include "led.h"
#include "systick.h"
#include "mb.h"
#include "flash.h"
#include "electricity.h"
#include "gd32e23x.h"
#include "string.h"
#include "query.h"




board_t  ac_board = 		{0};
META_DATA_S meta_data = {0};

float TotalWh[RelaySlaveChaNum] ={0.0};

board_t *get_board()
{
	return &ac_board;
}

extern uint16_t rl_delay_cnt[RelaySlaveChaNum];
extern uint8_t rl_open_delay_flag[RelaySlaveChaNum];
extern uint8_t rl_pwm_flag[RelaySlaveChaNum];
static void task_query(void);
static void task_1s(void);
static void task_10s(void);
static void task_100ms(void);
static void relay_ctrl(void);
static void app_init(META_DATA_S *meta);


int main(){
	
	flash_disable_read();
	ac_board.md_data.r_data.dev_chn =  ACSingCurrid << 8 | RelaySlaveChaNum;
	InitSysTick();
	led_init();
	lock_init();
	detection_init();
	
	relay_init();
	haddr_init();
	eeprom_init();
	read_config_from_eeprom();
	electricity_init();
	time_init();
	query_init();
	key_init();
	//device
	fwdgt_Init();
	eMBInit(MB_RTU, ac_board.haddr, 0, 115200, MB_PAR_NONE);
	eMBEnable();
	
	ac_board.md_data.r_data.info.channels = RelaySlaveChaNum;
	strcpy((char*)&(ac_board.md_data.r_data.info.date),__DATE__);
	strcat((char*)&(ac_board.md_data.r_data.info.date)," ");
	strcat((char*)&(ac_board.md_data.r_data.info.date),__TIME__);
	strcpy((char*)&(ac_board.md_data.r_data.info.ver),VERSION);
	
	flash_get_infomation(&ac_board.md_data.r_data.info);
#if SUPPORT_RELAY_REMENBER
	ac_board.handle_input_pt[0] = 1;
	#if SURPPORT_2_PT
		ac_board.handle_input_pt[1] = 1;
	#endif
	ac_board.detection();
	
#if SUPPORT_SELF_LOCK
	ac_board.get_lock_key();
#endif

	if((ac_board.md_data.r_data.detection & 0x1) == 0)
	{
		for(uint8_t i = 0; i < PT_SUB_COUNT;i++)
		{
			ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
			ac_board.relay_staging_staus[i] = 0;
#if SUPPORT_SELF_LOCK
			ac_board.handle_k_status[i] = ac_board.val_key[i];
#endif
		}
		ac_board.handle_input_pt[0] = 0;
	}
#if SUPPORT_SELF_LOCK
		else
		{
				for(uint8_t i = 0; i < PT_SUB_COUNT;i++)
				{
					if(ac_board.val_key[i] == 0)
					{
						ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
						ac_board.relay_staging_staus[i] = 0;
					}else
					{
						ac_board.handle_k_status[i] = ac_board.val_key[i];
					}
				}
		}
#endif	
	
#if SURPPORT_2_PT		
		if((ac_board.md_data.r_data.detection & 0x2) == 0)
		{
			for(uint8_t i = PT_SUB_COUNT; i < RelaySlaveChaNum;i++)
			{
				ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
				ac_board.relay_staging_staus[i] = 0;
			}
			ac_board.handle_input_pt[1] = 0;
		}
#endif
	
#endif
	
	while(1)
	{
		if(eMBCheck())
		{
			eMBInit(MB_RTU, ac_board.haddr, 0, 115200, MB_PAR_NONE);
			eMBEnable();
		}
		ac_board.feed_dog();
		task_query();
		task_100ms();
		task_1s();
		task_10s();
		eMBPoll();
#if SUPPORT_SELF_LOCK
		ac_board.opt_lock_key();
#endif
#ifndef SUPPORT_MON
		ac_board.opt_detection();
		relay_ctrl();
#endif
	}
	return 0;
}

static void task_query(void)
{
	w_eeprom_data_t data = {0};
	if(ac_board.q_cache.de_queue(&data))
	{
		ac_board.write_eeprom_page(data.start_addr,(uint8_t*)&data.data,data.lenth);
	}
}

static void task_1s(void)
{
	if(ac_board.flag_1s)
	{
			ac_board.flag_1s = 0;
			ac_board.md_data.r_data.info.runing_time++;
			ac_board.led_flash();
#ifndef SUPPORT_MON
			ac_board.detection();
#endif
#if SUPPORT_SELF_LOCK
			ac_board.get_lock_key();
#endif

	}
}

static void task_100ms(void)
{
	static uint8_t channel = 0;
	if(ac_board.flag_100ms)
	{
			ac_board.flag_100ms = 0;
			ac_board.read_ele(channel);
			ac_board.check_wanning(ELE_OUTPUT,channel);
#ifndef SUPPORT_MON
			ac_board.opt_overfunc(channel);		
#endif
			channel++;
			if(channel == RelaySlaveChaNum)
			{
				channel = 0;
			}	
	}
}


static void task_10s(void)
{
	if(ac_board.flag_10s)
	{
		ac_board.flag_10s = 0;
		for(int i = 0; i < RelaySlaveChaNum;i++)
		{
			ac_board.con_da.iic_da.iic_con.iic_consumer[i] = ac_board.md_data.r_data.ac_ele.ele_info[i].consumer;
		}
		if(ac_board.con_da.row >= MAX_ROW)
		{
			ac_board.con_da.row = 0;
		}
		if(ac_board.con_da.index >= UINT64_MAX)
		{
			iic_data chache1={0};
			ac_board.con_da.index = 0;
			for(int i = 0 ; i < MAX_ROW;i++)
				ac_board.write_eeprom_page(EEPROM_CONSUMER_ADDR +(CONSUM_PAGE*i),(uint8_t *)&chache1,CONSUM_PAGE);
			ac_board.con_da.row = 0;
		}
		eMBPoll();
		ac_board.con_da.iic_da.iic_con.recode_index1 = ac_board.con_da.index;
		ac_board.write_eeprom_page(EEPROM_CONSUMER_ADDR+(CONSUM_PAGE*ac_board.con_da.row),(uint8_t*)&ac_board.con_da.iic_da.iic_con,CONSUM_PAGE);
		ac_board.con_da.index++;
		ac_board.con_da.row++;
		eMBPoll();
	}
}
//static void app_init(META_DATA_S *meta)
//{
//	flash_get_meta_data(meta);
//	nvic_vector_table_set(NVIC_VECTTAB_FLASH,meta->rom_addr - NVIC_VECTTAB_FLASH);
//	__enable_irq();
//}


static void relay_ctrl(void)
{
	for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
	{
		if(IS_RL_ORDER_FLAG_EN(ac_board.relay_staging_staus[i]))
		{
			uint8_t rl_old_state = ac_board.md_data.r_data.state.state[i].state;
			uint8_t rl_now_state = GET_RL_STATUS(ac_board.relay_staging_staus[i]);
			if(rl_now_state > rl_old_state)
			{
				SET_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
				CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
				if(IS_RL_ON_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
				{
					ac_board.relay_limit_counter[i] = ac_board.md_data.rw_data.open.delay_open[i]/10;
					CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
					SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
					rl_delay_cnt[i] = 0;
				}else
				{
					ac_board.relay_limit_counter[i] = 0;
					SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
					CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
				}
				
			}else if (rl_now_state < rl_old_state)
			{
				CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
				SET_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
				if(IS_RL_OFF_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
				{
					ac_board.relay_limit_counter[i] = ac_board.md_data.rw_data.close.delay_close[i] / 10;
					CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
					SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
					rl_delay_cnt[i] = 0;
				}else
				{
					ac_board.relay_limit_counter[i] = 0;
					SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
					CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
				}
			}else{
					ac_board.relay_limit_counter[i] = 0;
					CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
					CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
					CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);				
				  CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
			}
			CLEAR_RL_ORDER_FLAG(ac_board.relay_staging_staus[i]);
		}
	}
	for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
	{
		if(IS_RL_COUNTER_END_FLAG_EN(ac_board.relay_staging_staus[i]))
		{
			CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
			if(IS_RL_ON_FLAG_EN(ac_board.relay_staging_staus[i]))
			{
				CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
				ac_board.open(i);
				rl_open_delay_flag[i] = 1;
			}else if(IS_RL_OFF_FLAG_EN(ac_board.relay_staging_staus[i]))
			{
				rl_pwm_flag[i] = 0;
				CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
				ac_board.close(i);
			}
		}
	}
}