#include "cyclic_storage_data_created_api.h"
#include "cyclic_storage_cfg_api.h"
#include "low_pwr_test.h"
#include "string.h"
#include "sundry.h"

TYPE_CHECK_SIZE(SYS_SEND_FLOW_DATA_SYSLOG_FORMAT_T,110);//ºË²é½á¹¹Ìå´óС	
TYPE_CHECK_SIZE(SYS_FLOW_DATA_SYSLOG_FORMAT_T,62);//ºË²é½á¹¹Ìå´óС	

TYPE_CHECK_SIZE(RESTORE_DEFAULT_SYSLOG_FORMAT_T,11);//ºË²é½á¹¹Ìå´óС	

TYPE_CHECK_SIZE(ALARM_SYSLOG_FORMAT_T,108);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(ALARM_SYSLOG_FORMAT_T,alarm_syslog_union,measure_alarm_data_s,48);//ºË²é½á¹¹Ìå´óС	
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(ALARM_SYSLOG_FORMAT_T,alarm_syslog_union,other_alarm_data_s,32);//ºË²é½á¹¹Ìå´óС

TYPE_CHECK_SIZE(PAY_SYSLOG_FORMAT_T,30);//ºË²é½á¹¹Ìå´óС	
PAY_SYSLOG_FORMAT_T pay_para_g = {0}; // ³äÖµ´ÎÊýÐèÒªÖØÆôʱ´Ó´¢´æÖлñÈ¡

TYPE_CHECK_SIZE(VALVE_SYSLOG_FORMAT_T,19);//ºË²é½á¹¹Ìå´óС	
VALVE_SYSLOG_FORMAT_T valve_log_g = {0}; // ¿ª¹Ø·§´ÎÊýÐèÒªÖØÆôʱ´Ó´¢´æÖлñÈ¡

TYPE_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,233);//ºË²é½á¹¹Ìå´óС	
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,gas_cumulate_amend_s,36);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,balance_amend_s,20);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,billing_price_amend_s,222);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,press_cfg_amend_s,88);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,temp_cfg_amend_s,76);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,flow_cfg_amend_s,56);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,cal_pulse_amend_s,16);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,sys_func_cfg_amend_s,16);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,sys_alarm_ctl_bytes_amend_s,56);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,sys_valve_ctl_bytes_amend_s,44);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,billing_alarm_cfg_amend_s,78);
TYPE_CHILDTYPE_MEMBER_CHECK_SIZE(PARA_AMEND_SYSLOG_FORMAT_T,para_amend_union,sec_corr_para_amend_s,160);
PARA_AMEND_SYSLOG_FORMAT_T para_amend_log_g = {0};

TYPE_CHECK_SIZE(TIMING_SYSLOG_FORMAT_T,23);//ºË²é½á¹¹Ìå´óС	
TIMING_SYSLOG_FORMAT_T timing_log_g = {0};



/*Ô¶´«·¢Ë͵ÄÁ÷Á¿Êý¾Ý¼Ç¼¹¹Ôì*/
void SendFlowData_LogRecordCreated(SYS_SEND_FLOW_DATA_SYSLOG_FORMAT_T *pOutput, SYS_REAL_TIME_DATA_T *realtime_data_p,
																				BILLING_REAL_PARA_T *billing_realtime_p, __IO RTC_TimeDateTypeDef *calendar_p)
{
	/*¹¹ÔìÊý¾Ý*/
  pOutput->record_time[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
  pOutput->record_time[1] = calendar_p->Month;
  pOutput->record_time[2] = calendar_p->Date;
  pOutput->record_time[3] = calendar_p->Hour;
  pOutput->record_time[4] = calendar_p->Minute;
  pOutput->record_time[5] = calendar_p->Second;

  pOutput->forward_cumulate_sc = realtime_data_p->measure_para_s.forward_cumulate_sc; // Á÷Á¿¼Ç¼¹¹Ôì
  pOutput->forward_cumulate_wc = realtime_data_p->measure_para_s.forward_cumulate_wc;
  pOutput->instant_sc = realtime_data_p->measure_para_s.instant_sc;
  pOutput->instant_wc = realtime_data_p->measure_para_s.instant_wc;
  pOutput->temperature = realtime_data_p->measure_para_s.temperature;
  pOutput->pressure = realtime_data_p->measure_para_s.pressure;

  pOutput->price_now = billing_realtime_p->price_now; // ¼Æ·Ñ¼Ç¼¹¹Ôì
  pOutput->balance_now = billing_realtime_p->balance_now;

  pOutput->cpu_temp = realtime_data_p->state_para_s.cpu_temperature; // ״̬Êý¾Ý¹¹Ôì
  pOutput->lith_vcc = realtime_data_p->state_para_s.lith_vcc;
  pOutput->alka_vcc = realtime_data_p->state_para_s.alka_vcc;
  pOutput->snr_up = realtime_data_p->state_para_s.snr_up;
  pOutput->snr_down = realtime_data_p->state_para_s.snr_down;
  pOutput->signal_gain_up = realtime_data_p->state_para_s.signal_gain_up;
  pOutput->signal_gain_down = realtime_data_p->state_para_s.signal_gain_down;
  pOutput->signal_intensity_up = realtime_data_p->state_para_s.signal_intensity_up;
  pOutput->signal_intensity_down = realtime_data_p->state_para_s.signal_intensity_down;
  pOutput->tof_up = realtime_data_p->state_para_s.tof_up;
  pOutput->tof_down = realtime_data_p->state_para_s.tof_down;
  pOutput->sound_vel = realtime_data_p->state_para_s.sound_vel;
  pOutput->flow_vel = realtime_data_p->state_para_s.flow_vel;
  memcpy(pOutput->sys_state_bytes, (void *)&sys_admin_g.sys_admin.state_bytes, SYS_STATUS_BYTES_TYPE_LENGTH);
}
/*ʱ/ÈÕ/ÔÂÕý³£µÄÁ÷Á¿Êý¾Ý¼Ç¼¹¹Ôì*/
void FlowData_LogRecordCreated(SYS_FLOW_DATA_SYSLOG_FORMAT_T *pOutput, SYS_REAL_TIME_DATA_T *realtime_data_p,
                               BILLING_REAL_PARA_T *billing_realtime_p, __IO RTC_TimeDateTypeDef *calendar_p)
{
  pOutput->record_time[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
  pOutput->record_time[1] = calendar_p->Month;
  pOutput->record_time[2] = calendar_p->Date;
  pOutput->record_time[3] = calendar_p->Hour;
  pOutput->record_time[4] = calendar_p->Minute;
  pOutput->record_time[5] = calendar_p->Second;

  pOutput->forward_cumulate_sc = realtime_data_p->measure_para_s.forward_cumulate_sc; // Á÷Á¿¼Ç¼¹¹Ôì
  pOutput->forward_cumulate_wc = realtime_data_p->measure_para_s.forward_cumulate_wc;
  pOutput->instant_sc = realtime_data_p->measure_para_s.instant_sc;
  pOutput->instant_wc = realtime_data_p->measure_para_s.instant_wc;
  pOutput->temperature = realtime_data_p->measure_para_s.temperature;
  pOutput->pressure = realtime_data_p->measure_para_s.pressure;

  pOutput->price_now = billing_realtime_p->price_now; // ¼Æ·Ñ¼Ç¼¹¹Ôì
  pOutput->balance_now = billing_realtime_p->balance_now;
}


void System_ValveLog_CyclicStorageHandler(VALVE_WORK_TYPE *pSucc_flag, SYS_ALARM_VALVE_T cause_id,
                                          VALVE_SYSLOG_FORMAT_T *valve_log_buffer_p, __IO RTC_TimeDateTypeDef *calendar_p)
{
  if (*pSucc_flag != VWT_NONE)
  {
		E2p_GPIO_Clk_Init();
    const SYSLOG_CYCLIC_TABLE_T *log_data_p = &sys_log_cyclic_table[CYCL_VALVE];

    valve_log_buffer_p->record_num = log_data_p->table_id->log_index + log_data_p->data_num * log_data_p->table_id->log_cyclic_full_cnt;

    valve_log_buffer_p->record_time[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
    valve_log_buffer_p->record_time[1] = calendar_p->Month;
    valve_log_buffer_p->record_time[2] = calendar_p->Date;
    valve_log_buffer_p->record_time[3] = calendar_p->Hour;
    valve_log_buffer_p->record_time[4] = calendar_p->Minute;
    valve_log_buffer_p->record_time[5] = calendar_p->Second;

    valve_log_buffer_p->work_type = *pSucc_flag;
    valve_log_buffer_p->switch_cause = cause_id;
    if (*pSucc_flag == VWT_NORMAL_CLOSE || *pSucc_flag == VWT_FORCED_CLOSE)
      valve_log_buffer_p->close_cnt++;
    else if (*pSucc_flag == VWT_OPEN)
      valve_log_buffer_p->open_cnt++;
    Sys_Log_E2pCyclicMultipleWrite(log_data_p, (uint8_t *)valve_log_buffer_p,1);
    *pSucc_flag = VWT_NONE;
  }
}

void AlarmLog_CyclicStorageHandler(SYS_ALARM_VALVE_T * pAlarm_id, SYS_REAL_TIME_DATA_T *realtime_data_p,
                                  BILLING_REAL_PARA_T *billing_realtime_p, __IO RTC_TimeDateTypeDef *calendar_p)
{
	if(*pAlarm_id != AV_NORMAL)
	{
#ifdef RS232_PRINTF				
		printf("ÆÕͨ±¨¾¯ÈÕÖ¾¼Ç¼ = %X\r\n", sys_alarm_id_g);
#endif
		E2p_GPIO_Clk_Init();
		ALARM_SYSLOG_FORMAT_T buffer = {0};
		buffer.record_time[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
		buffer.record_time[1] = calendar_p->Month;
		buffer.record_time[2] = calendar_p->Date;
		buffer.record_time[3] = calendar_p->Hour;
		buffer.record_time[4] = calendar_p->Minute;
		buffer.record_time[5] = calendar_p->Second;

		buffer.alarm_id = *pAlarm_id;

		buffer.forward_cumulate_sc = realtime_data_p->measure_para_s.forward_cumulate_sc;
		buffer.forward_cumulate_wc = realtime_data_p->measure_para_s.forward_cumulate_wc;
		buffer.instant_sc = realtime_data_p->measure_para_s.instant_sc;
		buffer.instant_wc = realtime_data_p->measure_para_s.instant_wc;
		buffer.temperature = realtime_data_p->measure_para_s.temperature;
		buffer.pressure = realtime_data_p->measure_para_s.pressure;
		buffer.cpu_temperature = realtime_data_p->state_para_s.cpu_temperature;
		buffer.lith_vcc = realtime_data_p->state_para_s.lith_vcc;
		buffer.alka_vcc = realtime_data_p->state_para_s.alka_vcc;
		memcpy(buffer.status_bytes, (void *)&sys_admin_g.sys_admin.state_bytes, SYS_STATUS_BYTES_TYPE_LENGTH);
		// ¼ÆÁ¿±¨¾¯
		if ((*pAlarm_id >= AV_UT_LOSE && *pAlarm_id <= AV_MEASURE_ERR))
		{
			const SYSLOG_CYCLIC_TABLE_T *log_data_p = &sys_log_cyclic_table[CYCL_MEASURE_ALARM];
			memcpy(&buffer.alarm_syslog_union.measure_alarm_data_s, &sys_realtime_data_g.state_para_s.tof_up, 20);
			buffer.alarm_syslog_union.measure_alarm_data_s.sound_vel = sys_realtime_data_g.state_para_s.sound_vel;
			buffer.alarm_syslog_union.measure_alarm_data_s.flow_vel = sys_realtime_data_g.state_para_s.flow_vel;
			buffer.record_num = log_data_p->table_id->log_index + log_data_p->data_num * log_data_p->table_id->log_cyclic_full_cnt;
			Sys_Log_E2pCyclicMultipleWrite(log_data_p, (uint8_t *)&buffer,1);
		}
		else
		{
			const SYSLOG_CYCLIC_TABLE_T *log_data_p = &sys_log_cyclic_table[CYCL_OTHER_ALARM];
			buffer.alarm_syslog_union.other_alarm_data_s.price_now = billing_realtime_p->price_now;
			buffer.alarm_syslog_union.other_alarm_data_s.balance_now = billing_realtime_p->balance_now;

			buffer.record_num = log_data_p->table_id->log_index + log_data_p->data_num * log_data_p->table_id->log_cyclic_full_cnt;
			Sys_Log_E2pCyclicMultipleWrite(log_data_p, (uint8_t *)&buffer,1);
		}
		*pAlarm_id = AV_NORMAL;
	}
}


void PayLog_CyclicStorageHandler(uint8_t * pPay_flag,PAY_SYSLOG_FORMAT_T * pay_log_buffer_p,__IO RTC_TimeDateTypeDef *calendar_p)
{
	if (*pPay_flag)
  {
    *pPay_flag = 0;
		E2p_GPIO_Clk_Init();
    const SYSLOG_CYCLIC_TABLE_T *log_data_p = &sys_log_cyclic_table[CYCL_PAY];
    pay_log_buffer_p->record_num = log_data_p->table_id->log_index + log_data_p->data_num * log_data_p->table_id->log_cyclic_full_cnt;

    pay_log_buffer_p->plant_number = 1;
		pay_log_buffer_p->pay_cnt++;

    pay_log_buffer_p->record_time[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
    pay_log_buffer_p->record_time[1] = calendar_p->Month;
    pay_log_buffer_p->record_time[2] = calendar_p->Date;
    pay_log_buffer_p->record_time[3] = calendar_p->Hour;
    pay_log_buffer_p->record_time[4] = calendar_p->Minute;
    pay_log_buffer_p->record_time[5] = calendar_p->Second;
    Sys_Log_E2pCyclicMultipleWrite(log_data_p, (uint8_t *)pay_log_buffer_p,1);
  }
}

void TimingLog_CyclicStorageHandler(TIMING_SYSLOG_FORMAT_T * timing_log_buffer_p,__IO RTC_TimeDateTypeDef *calendar_p)
{
	if(timing_log_buffer_p->timing_cause)
	{
		E2p_GPIO_Clk_Init();
		const SYSLOG_CYCLIC_TABLE_T *log_data_p = &sys_log_cyclic_table[CYCL_TIMING];
		timing_log_buffer_p->record_num = log_data_p->table_id->log_index + log_data_p->data_num * log_data_p->table_id->log_cyclic_full_cnt;;
		timing_log_buffer_p->plant_number = 1;
		
		timing_log_buffer_p->record_time_now[0] = calendar_p->Year; // ʱ¼ä¼Ç¼¹¹Ôì
    timing_log_buffer_p->record_time_now[1] = calendar_p->Month;
    timing_log_buffer_p->record_time_now[2] = calendar_p->Date;
    timing_log_buffer_p->record_time_now[3] = calendar_p->Hour;
    timing_log_buffer_p->record_time_now[4] = calendar_p->Minute;
    timing_log_buffer_p->record_time_now[5] = calendar_p->Second;

		Sys_Log_E2pCyclicMultipleWrite(log_data_p, (uint8_t *)timing_log_buffer_p,1);
		timing_log_buffer_p->timing_cause = TC_NULL;
	}
}

void ParaAmendLog_CyclicStorageHandler(PARA_AMEND_T * pAmend_flag,PARA_AMEND_SYSLOG_FORMAT_T * amend_log_buffer_p,__IO RTC_TimeDateTypeDef *calendar_p)
{
	if (*pAmend_flag != PARA_AMEND_NONE)
  {
		E2p_GPIO_Clk_Init();
    amend_log_buffer_p->plant_number = 1;
    amend_log_buffer_p->record_time[0] = calendar_g.Year; // ʱ¼ä¼Ç¼¹¹Ôì
    amend_log_buffer_p->record_time[1] = calendar_g.Month;
    amend_log_buffer_p->record_time[2] = calendar_g.Date;
    amend_log_buffer_p->record_time[3] = calendar_g.Hour;
    amend_log_buffer_p->record_time[4] = calendar_g.Minute;
    amend_log_buffer_p->record_time[5] = calendar_g.Second;
    for (uint8_t i = 0; i < PARA_AMEND_TABLE_NUM; i++)
    {
      if (*pAmend_flag == para_amend_table[i].amend_id && para_amend_table[i].data_address != NULL)
      {
        amend_log_buffer_p->record_num = para_amend_table[i].data_address->table_id->log_index +
                                      para_amend_table[i].data_address->data_num * para_amend_table[i].data_address->table_id->log_cyclic_full_cnt;
        Sys_Log_E2pCyclicMultipleWrite(para_amend_table[i].data_address, (uint8_t *)amend_log_buffer_p,1);
        break;
      }
    }
		*pAmend_flag = PARA_AMEND_NONE;
//    memset(amend_log_buffer_p, 0, AMEND_LOG_FORMAT_HEAD);
  }
}