#ifndef _CYCLIC_STORAGE_DATA_CREATED_API_H_
#define _CYCLIC_STORAGE_DATA_CREATED_API_H_

#include "define_all.h" 
#include "valve_control.h"
#include "billing.h"
#include "system_parameter.h"



#define SEND_FLOW_DATA_LOG_FORMAT_SIZE sizeof(SYS_SEND_FLOW_DATA_SYSLOG_FORMAT_T)
#define HISTORY_FLOW_DATA_LOG_FORMAT_SIZE sizeof(SYS_FLOW_DATA_SYSLOG_FORMAT_T)

#define VALVE_LOG_FORMAT_SIZE sizeof(VALVE_SYSLOG_FORMAT_T)
#define PAY_LOG_FORMAT_SIZE sizeof(PAY_SYSLOG_FORMAT_T)
#define RESTORE_DEFAULT_LOG_FORMAT_SIZE sizeof(RESTORE_DEFAULT_SYSLOG_FORMAT_T)
#define TIMING_LOG_FORMAT_SIZE sizeof(TIMING_SYSLOG_FORMAT_T)

#define AMEND_LOG_FORMAT_HEAD (sizeof(PARA_AMEND_SYSLOG_FORMAT_T) - sizeof(PARA_AMEND_UNION_T))
#define GAS_CUMULATE_AMEND_LOG_FORMAT_SIZE (sizeof(struct gas_cumulate_amend) + AMEND_LOG_FORMAT_HEAD)
#define BALANCE_AMEND_LOG_FORMAT_SIZE (sizeof(struct balance_amend) + AMEND_LOG_FORMAT_HEAD)
#define BILLING_PRICE_AMEND_LOG_FORMAT_SIZE (sizeof(struct billing_price_amend) + AMEND_LOG_FORMAT_HEAD)
#define PRESS_CFG_AMEND_LOG_FORMAT_SIZE (sizeof(struct press_cfg_amend) + AMEND_LOG_FORMAT_HEAD)
#define TEMP_CFG_AMEND_LOG_FORMAT_SIZE (sizeof(struct temp_cfg_amend) + AMEND_LOG_FORMAT_HEAD)
#define FLOW_CFG_AMEND_LOG_FORMAT_SIZE (sizeof(struct flow_cfg_amend) + AMEND_LOG_FORMAT_HEAD)
#define CAL_PULSE_AMEND_LOG_FORMAT_SIZE (sizeof(struct cal_pulse_amend) + AMEND_LOG_FORMAT_HEAD)
#define SYS_FUNC_CFG_AMEND_LOG_FORMAT_SIZE (sizeof(struct sys_func_cfg_amend) + AMEND_LOG_FORMAT_HEAD)
#define ALARM_CTL_SEND_BYTES_AMEND_LOG_FORMAT_SIZE (sizeof(struct sys_alarm_ctl_send_amend) + AMEND_LOG_FORMAT_HEAD)
#define VALVE_CTL_BYTES_AMEND_LOG_FORMAT_SIZE (sizeof(struct sys_valve_ctl_bytes_amend) + AMEND_LOG_FORMAT_HEAD)
#define BILLING_ALARM_CFG_AMEND_LOG_FORMAT_SIZE (sizeof(struct billing_alarm_cfg_amend) + AMEND_LOG_FORMAT_HEAD)
#define SEC_CORR_PARA_AMEND_LOG_FORMAT_SIZE	(sizeof(struct sec_corr_para_amend) + AMEND_LOG_FORMAT_HEAD)

#define ALARM_DATA_LOG_FORMAT_HEAD (sizeof(ALARM_SYSLOG_FORMAT_T) - sizeof(ALARM_SYSLOG_UNION_T))
#define MEASURE_ALARM_DATA_LOG_FORMAT_SIZE (sizeof(struct measure_alarm_data) + ALARM_DATA_LOG_FORMAT_HEAD)
#define OTHER_ALARM_DATA_LOG_FORMAT_SIZE (sizeof(struct other_alarm_data) + ALARM_DATA_LOG_FORMAT_HEAD)

typedef enum
{
  SDM_NULL = 0U,
  SDM_UPPER,    // ÉÏλ»ú
  SDM_BT_APP,   // À¶ÑÀAPP
  SDM_GPRS_CMD, // Ô¶´«ÃüÁî
} SYS_DATA_MENDER;

typedef enum
{
	TC_NULL = 0U,
	TC_AUTO,
	TC_GPRS,
	TC_UPPER,
	TC_BT_APP,
}TIMING_CAUSE_T;

#pragma pack(1)

/*****************************Cyclic Data************************************************/
typedef union
{
  struct measure_alarm_data
  {
    float tof_up;
    float tof_down;
    float tof_diff;
    uint8_t signal_intensity_up;
    uint8_t signal_intensity_down;
    uint8_t signal_gain_up;
    uint8_t signal_gain_down;
    uint16_t snr_up; // ÐÅÔë±È_ÉÏͨµÀ
    uint16_t snr_down;
    float sound_vel;
    float flow_vel;
    uint8_t reserve[20]; // Ô¤Áô
  } measure_alarm_data_s;
  struct other_alarm_data
  {
    uint32_t price_now;
    double balance_now;
    uint8_t reserve[20];
  } other_alarm_data_s;
} ALARM_SYSLOG_UNION_T;

typedef struct
{
  uint16_t record_num;
  uint8_t record_time[6];
  uint16_t alarm_id;
  double forward_cumulate_sc; // ÕýÏò±ê¿öÀÛ»ýÁ¿
  double forward_cumulate_wc;
  float instant_sc;
  float instant_wc;
  float temperature;
  float pressure;
  float cpu_temperature; // »·¾³Î¶È
  uint8_t lith_vcc;
  uint8_t alka_vcc;
  uint16_t status_bytes[SYS_STATUS_BYTES_TYPE_LENGTH >> 1];
  ALARM_SYSLOG_UNION_T alarm_syslog_union;
} ALARM_SYSLOG_FORMAT_T;

typedef struct // 19 bytes
{
  uint16_t record_num;
  uint8_t record_time[6];
  VALVE_WORK_TYPE work_type;
  SYS_ALARM_VALVE_T switch_cause;
  uint16_t open_cnt;
  uint16_t close_cnt;
  uint8_t reserve[4];
} VALVE_SYSLOG_FORMAT_T; //4 bytesÔ¤Áô //·§ÃÅÀúÊ·¼Ç¼

typedef struct // 11 bytes
{
  uint16_t record_num;
	uint8_t record_time[6];
  SYS_DATA_MENDER mender;
  uint8_t reserve[2];
} RESTORE_DEFAULT_SYSLOG_FORMAT_T; // 4 bytesÔ¤Áô//»Ö¸´Ä¬ÈÏÉèÖüǼ¸ñʽ

typedef struct // 30 bytes
{
  uint16_t record_num;    // ÐòºÅ
  uint8_t record_time[6]; // ʱ¼ä
	SYS_DATA_MENDER mender;         // ÐÞ¸ÄÕß
  uint16_t plant_number;  // ³§¼Ò´úÂë
  uint8_t pay_type;
  uint16_t pay_cnt;
  int32_t pay_value;
  long long pay_value_cumulate;
  uint8_t reserve[4];  // Ô¤ÁôÊÇΪÁËÒÔºóÇø·ÖÆøÁ¿³äÖµ
} PAY_SYSLOG_FORMAT_T; // 4 bytesÔ¤Áô // ³äÖµ¼Ç¼

typedef struct
{
	uint16_t record_num;    // ÐòºÅ
  uint8_t record_time_before[6]; // ʱ¼ä
	TIMING_CAUSE_T timing_cause;
	uint16_t plant_number;  // ³§¼Ò´úÂë
	uint8_t record_time_now[6];
	uint8_t reserve[6];
}TIMING_SYSLOG_FORMAT_T;//6 bytesÔ¤Áô //Уʱ¼Ç¼

typedef union
{
  struct gas_cumulate_amend // 36 bytes
  {
    double cumulate_sc_before;
    double cumulate_wc_before;
    double cumulate_sc_after;
    double cumulate_wc_after;
    uint8_t reserve[4];
  } gas_cumulate_amend_s; // ÀÛ»ýÁ¿Ð޸ļǼ
  struct balance_amend    // 20 bytes
  {
    double balance_before;
    double balance_now;
    uint8_t reserve[4];      // Ô¤ÁôÊÇΪÁËÒÔºóÇø·ÖÊÇÓà¶î»¹ÊÇÓàÁ¿
  } balance_amend_s;         // Óà¶î/ÓàÁ¿Ð޸ļǼ¸ñʽ
  struct billing_price_amend // 222 bytes
  {
    LADDER_PRICE_CFG_PARA_T price_cfg_before;
    LADDER_PRICE_CFG_PARA_T price_cfg_now;
  } billing_price_amend_s; // ¼Æ·Ñ¼Û¸ñÐ޸ļǼ¸ñʽ£¨²»ÓÃÔ¤Áô£¬ÒòΪLADDER_PRICE_CFG_PARA_TÖÐÓÐÔ¤Áô£©
  struct press_cfg_amend   // 88 bytes
  {
    SYS_PRESS_ALARM_CFG_T press_cfg_before;
    SYS_PRESS_ALARM_CFG_T press_cgf_now;
  } press_cfg_amend_s;  // ѹÁ¦ÅäÖÃÐ޸ļǼ¸ñʽ£¨²»ÓÃÔ¤Áô£¬ÒòΪSYS_PRESS_ALARM_CFG_TÖÐÓÐÔ¤Áô£©
  struct temp_cfg_amend // 76 bytes
  {
    SYS_TEMP_ALARM_CFG_T temp_cfg_before;
    SYS_TEMP_ALARM_CFG_T temp_cgf_now;
  } temp_cfg_amend_s;   // ζÈÅäÖÃÐ޸ļǼ¸ñʽ£¨²»ÓÃÔ¤Áô£¬ÒòΪSYS_TEMP_ALARM_CFG_TÖÐÓÐÔ¤Áô£©
  struct flow_cfg_amend // 56 bytes
  {
    SYS_FLOW_ALARM_CFG_T flow_cfg_before;
    SYS_FLOW_ALARM_CFG_T flow_cfg_now;
  } flow_cfg_amend_s;    // Á÷Á¿ÅäÖÃÐ޸ļǼ¸ñʽ£¨²»ÓÃÔ¤Áô£¬ÒòΪSYS_FLOW_ALARM_CFG_TÖÐÓÐÔ¤Áô£©
  struct cal_pulse_amend // 16 bytes
  {
    CAL_PULSE_PARA_T cal_pulse_cfg_before;
    CAL_PULSE_PARA_T cal_pulse_cfg_now;
  } cal_pulse_amend_s; // ±ê¶¨Âö³å²ÎÊýÐ޸ļǼ¸ñʽ£¨²»ÓÃÔ¤Áô£¬ÒòΪCAL_PULSE_PARA_TÖÐÓÐÔ¤Áô£©
  struct sys_func_cfg_amend
  {
    uint16_t func_cfg_bytes_before[SYS_FUNC_CTL_BYTES_TYPE_LENGTH >> 1];
    uint16_t func_cfg_bytes_now[SYS_FUNC_CTL_BYTES_TYPE_LENGTH >> 1];
  } sys_func_cfg_amend_s;
  struct sys_alarm_ctl_send_amend
  {
    uint16_t alarm_ctl_bytes_before[SYS_ALARM_CTL_BYTES_TYPE_LENGTH >> 1];
    uint16_t alarm_send_bytes_before[SYS_ALARM_SEND_BYTES_TYPE_LENGTH >> 1];
    uint16_t alarm_ctl_bytes_now[SYS_ALARM_CTL_BYTES_TYPE_LENGTH >> 1];
    uint16_t alarm_send_bytes_now[SYS_ALARM_SEND_BYTES_TYPE_LENGTH >> 1];
  } sys_alarm_ctl_bytes_amend_s;
  struct sys_valve_ctl_bytes_amend
  {
    uint16_t valve_ctl_bytes_before[VALVE_CTL_LEN >> 1];
    uint16_t valve_ctl_bytes_now[VALVE_CTL_LEN >> 1];
  } sys_valve_ctl_bytes_amend_s;
  struct billing_alarm_cfg_amend
  {
    BILLING_ALARM_CFG_T billing_alarm_before;
    BILLING_ALARM_CFG_T billing_alarm_now;
  } billing_alarm_cfg_amend_s;
	struct sec_corr_para_amend
	{
		SECOND_ORDER_CORR_T sec_corr_para_before;
		SECOND_ORDER_CORR_T sec_corr_para_now;
	}sec_corr_para_amend_s;
} PARA_AMEND_UNION_T;

typedef struct
{
  uint16_t record_num;
	uint8_t record_time[6];
  SYS_DATA_MENDER mender;
  uint16_t plant_number;
  PARA_AMEND_UNION_T para_amend_union;
} PARA_AMEND_SYSLOG_FORMAT_T; // ¸÷ÖÖ²ÎÊýÐ޸ļǼ¸ñʽ

typedef struct // 110 bytes
{
  uint8_t check_sum; // ÓÉÓÚ´¢´æ¶Áдʱ¿ÉÄܱ»Öжϴò¶Ï£¬ÇÒÔ¶´«Êý¾Ý½ÏΪÖØÒª£¬ËùÒÔµ¥¶ÀÌí¼ÓУÑéºÍ×öÅжϡ£
  uint8_t record_time[6];
  double forward_cumulate_sc; // ÕýÏò±ê¿öÀÛ»ýÁ¿
  double forward_cumulate_wc;
  float instant_sc;
  float instant_wc;
  float temperature;
  float pressure;
  uint32_t price_now;
  double balance_now;
  float cpu_temp;
  uint8_t lith_vcc;
  uint8_t alka_vcc;
  uint16_t snr_up; // ÐÅÔë±È_ÉÏͨµÀ
  uint16_t snr_down;
  uint8_t signal_gain_up;
  uint8_t signal_gain_down;
  uint8_t signal_intensity_up;
  uint8_t signal_intensity_down;
  float tof_up;
  float tof_down;
  float sound_vel;
  float flow_vel;
  uint16_t sys_state_bytes[SYS_STATUS_BYTES_TYPE_LENGTH >> 1];
  uint8_t reserve[17];
} SYS_SEND_FLOW_DATA_SYSLOG_FORMAT_T; // ·¢ËÍÁ÷Á¿¶³½áÊý¾Ý¼Ç¼¸ñʽ

typedef struct // 62 bytes
{
  uint8_t record_time[6];
  double forward_cumulate_sc; // ÕýÏò±ê¿öÀÛ»ýÁ¿
  double forward_cumulate_wc;
  float instant_sc;
  float instant_wc;
  float temperature;
  float pressure;
  uint32_t price_now;
  double balance_now;
  uint8_t reserve[12];
} SYS_FLOW_DATA_SYSLOG_FORMAT_T; // 50 bytes + 12 bytesÔ¤Áô Á÷Á¿Êý¾ÝÀúÊ·¼Ç¼´¢´æ¸ñʽ

#pragma pack()

extern PAY_SYSLOG_FORMAT_T pay_para_g;
extern VALVE_SYSLOG_FORMAT_T valve_log_g;
extern PARA_AMEND_SYSLOG_FORMAT_T para_amend_log_g;
extern TIMING_SYSLOG_FORMAT_T timing_log_g;


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);
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);
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);
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);

void PayLog_CyclicStorageHandler(uint8_t *pPay_flag, PAY_SYSLOG_FORMAT_T *pay_log_buffer_p, __IO RTC_TimeDateTypeDef *calendar_p);
void ParaAmendLog_CyclicStorageHandler(PARA_AMEND_T *pAmend_flag, PARA_AMEND_SYSLOG_FORMAT_T *amend_log_buffer_p, __IO RTC_TimeDateTypeDef *calendar_p);

void TimingLog_CyclicStorageHandler(TIMING_SYSLOG_FORMAT_T * timing_log_buffer_p,__IO RTC_TimeDateTypeDef *calendar_p);

#endif