#include "sys_config.h" #if PRODUCT_SY #include "UWater_frame_app.h" #include "UWater_eeprom_driver.h" #include "UWater_rtcc_driver.h" #include "UWater_rtcc_app.h" #include "UWater_lcd_app.h" #include "UWater_gp22_app.h" #include "UWater_DataTools_App.h" #include "UWater_pt_app.h" #include "UWater_valve_driver.h" #include "UWater_valve_app.h" #include "SOE.h" #include "UWater_power_app.h" #include "UWater_SY_Store_App.h" #include "sys_processor.h" /**********公用变量************************************************************/ DateTime uTempRtccTime_BCD; TYP_STATE_SY step_ShenYangStoreInit=SY_STATE_S0; //EE存储参数初始化状态机 TYP_STATE_SY step_ShenYangStoreMachine=SY_STATE_S0;//沈阳规约数据存储主状态机 UNION_SY_STORE_INDEX uStoreIndex_SY;//存储索引 u16 uTemp_ee_addr=0; u8 uTempMsg_EE=0; u8 s_sy_eep_complete=0; static u8 s_sy_clear_history_buf[256]; DateTime sy_protl_rtcc_time; /**********周期数据存储相关变量***********************************************/ UNION_SY_STORE_CIRCLE temp_Circle_data;//周期数据存储缓存 u8 uStoreCircleIndex_SY=0; //周期数据存储地址索引 TYP_STATE_SY step_CircleDataStore=SY_STATE_S0;//周期数据存储状态机 u32 uUploadIndexTimeBuf[6];//周期数据指针时间排序 u8 uUploadIndexBuf[6];//周期数据指针排序 /**********冻结信息存储相关变量***********************************************/ UNION_SY_STORE_FROZEN temp_frozen_data;//冻结数据存储缓存 u8 *pTempBuf_DailyHighestFlow;//日最高流量指针 TYP_STATE_SY step_FrozenDataStore=SY_STATE_S0;//冻结数据存储状态机 TYP_STATE_SY step_FrozenDataClear = SY_STATE_S0;//冻结数据和周期数据清除 u8 uClearDataLen=0; /**********报警信息存储相关变量***********************************************/ TYP_STATE_SY step_ShenYangSOEMachine=SY_STATE_S0; u16 uSOE_Data_New=0; u16 uSOE_Data_Old=0; u8 uSOE_Valve_New=0; u8 uSOE_Valve_Old=0; u8 uSOE_Power_New=0; u8 uSOE_Power_Old=0; float uSOE_Temprature_New=0; u8 uSOE_Temprature_ShortNew=0; u8 uSOE_Temprature_ShortOld=0; u8 uSOE_Temprature_OpenNew=0; u8 uSOE_Temprature_OpenOld=0; u32 uSOE_Update_Flag=0xFFFFFFFF; u32 uSOE_Update_Flag_Old=0xFFFFFFFF; u8 uWaterState=0; DateTime ValveActiveDateTime; u8 Valve_Active=0; /**********TLV数据存储相关变量***********************************************/ TYP_STATE_SY step_TlvDataStore=SY_STATE_S0; u8 temp_tlv_data[32]; Type_TLVValue TlvValue; u8 tlv_store_cnt=0; /**********周期数据上报***********************************************/ int SY_ThisPack_Count=0; TYP_STATE_SY SY_CircleUploadStep=SY_STATE_S0;//上报状态机 /******************************************************************************** 函数名：ShenYang_Store_InitApp 说 明：沈阳数据存储初始化 ********************************************************************************/ void ShenYang_Store_InitApp(void) { TYP_STATE_SY tmp_init_stat; while (tmp_init_stat) { switch (tmp_init_stat) { case SY_STATE_S0: { if(TASK_IDLE == EepIfIdle()) { tmp_init_stat = SY_STATE_S0; } break; } case SY_STATE_S1: { if (TASK_IDLE == EepIfIdle()) { EepRead(EEP_ADDR_SY_STORE_INDEX_CIRCLE, &uStoreIndex_SY.data_buf[0], SIZE_SY_STORE_INDEX, &uTempMsg_EE); tmp_init_stat = SY_STATE_S2; } break; } case SY_STATE_S2://非第一次上电需要读取参数 { if (TASK_IDLE == EepIfIdle()) { EepRead(EEP_ADDR_SY_TLVDATA,&TlvValue.data_buf[0], TLV_VALUE_LEN, &s_sy_eep_complete); tmp_init_stat =SY_STATE_S3; } break; } case SY_STATE_S3://判断第一次上电标志 { if (TASK_IDLE == EepIfIdle()) { if(uStoreIndex_SY.Data.firstPowerOn != SY_FIRST_POWERON_FLAG) { tmp_init_stat =SY_STATE_S10; } else { tmp_init_stat =SY_STATE_S0; } } break; } //第一次上电流程 case SY_STATE_S10: { if (TASK_IDLE == EepIfIdle()) { for(int i=0;i p[i + 1]) { temp = p[i]; p[i] = p[i + 1]; p[i + 1] = temp; } } } } /******************************************************************************** 函数名：getSY_StoreCircleIndex 说 明：获取周期数据存储位置 ********************************************************************************/ u8 getSY_StoreCircleIndex(void) { u8 i=0; u8 new_index=0; u8 temp_hour=0; //获取当前时间 RtccGetDateTime(&uTempRtccTime_BCD); //检测上半天或下半天 if(uTempRtccTime_BCD.s.hour>=0x12) { temp_hour = 0x12; } else { temp_hour = 0x00; } for(i=0;i<6;i++) { if((uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.year == uTempRtccTime_BCD.s.year) &&(uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.month == uTempRtccTime_BCD.s.month) &&(uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.day == uTempRtccTime_BCD.s.day) &&(uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.hour == temp_hour)) { new_index = (BCD2HEX(uTempRtccTime_BCD.s.hour) % 12)*2+BCD2HEX(uTempRtccTime_BCD.s.minute)/30;//根据时间计算当前应该存储的位置 //合法性判断,指针错误则初始话start和end if((uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntEnd > 24)|| (uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntEnd < uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntStart)|| (uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntEnd != new_index))//存储位置和当前时间不对应,则重新初始该位置 { uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.year = uTempRtccTime_BCD.s.year; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.month = uTempRtccTime_BCD.s.month; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.day = uTempRtccTime_BCD.s.day; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.hour = temp_hour; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.minute= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleDataTime.s.second= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntStart = new_index; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntEnd = uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.ReadStart = uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.ReadEnd = uStoreIndex_SY.Data.Circle.CircleIndex[i].Data.CircleCntStart; } return i; } } //如果没有查询到当天对应日期，则按照已存储时间顺序递增，新递增到的位置存储数量清0 //在重新上电的情况下，表计时间小于存储的时间,不会覆盖已存储时间 //出现这种情况的原因可能有:断过电RTC时间重置,校时往前或往后超过半天 for(new_index=0; new_index<6; new_index++)//使用无效的指针 { if((uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntEnd > 24)|| (uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntStart > uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntEnd)|| (Rtcc_Check_DateTime(&uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime) == ERROR)|| (RtccCalculateDiffTime(&uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime, &uTempRtccTime_BCD)>0)) { uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.year = uTempRtccTime_BCD.s.year; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.month = uTempRtccTime_BCD.s.month; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.day = uTempRtccTime_BCD.s.day; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.hour = temp_hour; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.minute= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime.s.second= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntStart = (BCD2HEX(uTempRtccTime_BCD.s.hour) % 12)*2+BCD2HEX(uTempRtccTime_BCD.s.minute)/30; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntEnd = uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.ReadStart = uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.ReadEnd = uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleCntStart; return new_index; } else { uUploadIndexTimeBuf[new_index] = get_mktime(&uStoreIndex_SY.Data.Circle.CircleIndex[new_index].Data.CircleDataTime); } } SortMinToMax(uUploadIndexTimeBuf, new_index);//时间按大小排序 for(int index=0;index<6;index++) { if(uUploadIndexTimeBuf[0] == get_mktime(&uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime)) { uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.year = uTempRtccTime_BCD.s.year; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.month = uTempRtccTime_BCD.s.month; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.day = uTempRtccTime_BCD.s.day; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.hour = temp_hour; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.minute= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.second= 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart = (BCD2HEX(uTempRtccTime_BCD.s.hour) % 12)*2+BCD2HEX(uTempRtccTime_BCD.s.minute)/30; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntEnd = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadStart = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadEnd = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart; return index; } } return 0; } /******************************************************************************** 函数名：ShenYang_CircleDataStore_proc 说 明：周期数据存储 累计流量单位为L/0.001M3，4字节无符号整数。 瞬时流量单位为0.01L/H，4字节无符号整数。 电压单位为0.01V，2字节无符号整数。 压力单位为10mbar/0.01kg/1KPa，2字节无符号整数。 温度单位为0.01℃，2字节有符号整数。 正向累计流量 4 负向累计流量 4 瞬时流量 4 压力 2 温度 2 ********************************************************************************/ static int ShenYang_CircleDataStore_proc(void) { switch(step_CircleDataStore) { case SY_STATE_S0: { SY_U32_To_Float temp_float_data; //获取当前流量 temp_float_data.gp22_u32 = Gp30CheckDataApp(2); temp_Circle_data.Data.CurrentFlow = (u32)(temp_float_data.gp22_float*10);//(注意测试最大最小值) //负向累计 temp_float_data.gp22_u32 = Gp30CheckDataApp(3); temp_Circle_data.Data.CurrentFlowReverse = (u32)(temp_float_data.gp22_float*10); //瞬时流量 temp_float_data.gp22_float = Gp30CheckDataApp(1); //瞬时流量 瞬时流量单位为0.01L/H，4字节无符号整数。 temp_Circle_data.Data.InstantaneousFlow = (u32)(temp_float_data.gp22_float / (float)65536.00)*100; //压力 temp_Circle_data.Data.Presure = 0; //温度 temp_float_data.gp22_float = TempCheckValueApp(); if(temp_float_data.gp22_float<0) { temp_Circle_data.Data.Temprature = (~(u16)(-temp_float_data.gp22_float*100))|0x8000; } else { temp_Circle_data.Data.Temprature = ((u16)(temp_float_data.gp22_float*100)); } step_CircleDataStore = SY_STATE_S1; break; } case SY_STATE_S1://存储数据 { if(TASK_IDLE == EepIfIdle()) { uStoreCircleIndex_SY = getSY_StoreCircleIndex(); uTemp_ee_addr = EEP_ADDR_SY_STORE_CIRCLE + //周期数据基地址 (uStoreCircleIndex_SY*STORE_SIZE_DATA_CIRCLE*24)+ //每半天偏移地址长度 uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.CircleCntEnd*STORE_SIZE_DATA_CIRCLE; //当前半天偏移位置 EepWrite(temp_Circle_data.data_buf, uTemp_ee_addr, STORE_SIZE_DATA_CIRCLE, &uTempMsg_EE); step_CircleDataStore = SY_STATE_S2; } break; } case SY_STATE_S2: //存储指针 { if(TASK_IDLE == EepIfIdle()) { uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.CircleCntEnd++; if(uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.CircleCntEnd>=24) { uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.CircleCntEnd = 24; } uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.ReadEnd = uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].Data.CircleCntEnd; /*当CircleCntEnd++到24时，禁止归0，而是在下次存储调用getSY_StoreCircleIndex的时候重新切换存储块*/ EepWrite(&uStoreIndex_SY.Data.Circle.CircleIndex[uStoreCircleIndex_SY].data_buf[0], EEP_ADDR_SY_STORE_INDEX_CIRCLE+uStoreCircleIndex_SY*11, 11, &uTempMsg_EE); step_CircleDataStore = SY_STATE_S3; } break; } case SY_STATE_S3: { if(TASK_IDLE == EepIfIdle()) { step_CircleDataStore = SY_STATE_S0; return 1; } break; } default: { step_CircleDataStore = SY_STATE_S0; break; } } return 0; } //清除已经上报成功的索引;保留时间,ReadStart和ReadEnd以备读取周期数据使用 int ShenYang_CircleDataStore_ClearUploadIndex(u8 index) { if(TASK_IDLE == EepIfIdle()) { uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart=uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntEnd; EepWrite(&uStoreIndex_SY.Data.Circle.CircleIndex[index].data_buf[7], EEP_ADDR_SY_STORE_INDEX_CIRCLE+index*11+7, 2, &uTempMsg_EE); return 1; } return 0; } /******************************************************************************** 函数名：ShenYang_FrozenDataStore_proc 说 明：冻结数据存储, 0点存储日冻结数据\ 半小时的间隔流量\ 日最高流速\ 日最高水温\ 日最低水温\ 报警状态字\ 时间年月日 日期 3 时间 3 正向累计流量 4 负向累计流量 4 峰值流量 4 峰值流量时间 3 电池电压 6 水表状态 1 水表故障 1 阀门状态 1 预留 1 校验和 1 总字节数 32 ********************************************************************************/ static int ShenYang_FrozenDataStore_proc(TYP_STATE_SY StoreType) { switch(step_FrozenDataStore) { case SY_STATE_S0: { u8 temp_index = 0; SY_U32_To_Float temp_float_data; RTCC_HISTORY_DATA temp_his_data; RtccGetDateTime(&uTempRtccTime_BCD); //冻结日期时间 temp_frozen_data.Data.FrozenDataTime.s.year = uTempRtccTime_BCD.s.year; temp_frozen_data.Data.FrozenDataTime.s.month = uTempRtccTime_BCD.s.month; temp_frozen_data.Data.FrozenDataTime.s.day = uTempRtccTime_BCD.s.day; temp_frozen_data.Data.FrozenDataTime.s.hour = uTempRtccTime_BCD.s.hour; temp_frozen_data.Data.FrozenDataTime.s.minute = uTempRtccTime_BCD.s.minute; temp_frozen_data.Data.FrozenDataTime.s.second = uTempRtccTime_BCD.s.second; //获取当前流量 temp_float_data.gp22_u32 = Gp30CheckDataApp(2); temp_frozen_data.Data.CurrentFlow = (u32)(temp_float_data.gp22_float*10);//(注意测试最大最小值) //负向累计 temp_float_data.gp22_u32 = Gp30CheckDataApp(3); temp_frozen_data.Data.CurrentFlowReverse = (u32)(temp_float_data.gp22_float*10); //获取日最高流速 RtccCheck_Hight_Flow(&pTempBuf_DailyHighestFlow); for(temp_index = 0; temp_index <14 ;temp_index++) { temp_his_data.byte[temp_index] = *(pTempBuf_DailyHighestFlow+temp_index); } temp_frozen_data.Data.PeakCurrentFlow = temp_his_data.s.most_high_flow;//(temp_his_data.s.most_high_flow/10)*60;//原存储格式386~38.6L/min temp_frozen_data.Data.PeakCurrentFlowTime[0] = temp_his_data.byte[8];//最高流速起始时间:hour temp_frozen_data.Data.PeakCurrentFlowTime[1] = temp_his_data.byte[7];//最高流速起始时间:minute temp_frozen_data.Data.PeakCurrentFlowTime[2] = temp_his_data.byte[6];//最高流速起始时间:second //电池电压 for(temp_index = 0; temp_index <6 ;temp_index++) { temp_frozen_data.Data.BatPower[temp_index] = 0; }//选一组电池电压----------------- temp_frozen_data.Data.BatPower[0] = PowerCheckValueSys()&0xFF; temp_frozen_data.Data.BatPower[1] = (PowerCheckValueSys()>>8)&0xFF; //水表状态 temp_frozen_data.Data.MeterState = 0;//0为正常，按实计自己定义有用状态 //水表故障 temp_frozen_data.Data.MeterFault = 0;//0为正常，按实计自己定义有用故障信息 //阀门状态 temp_frozen_data.Data.ValveState = 0; if(Sys_data_object.P1.ies_valve_paras.valve_err) { temp_frozen_data.Data.ValveState = 0xFF; } else { #if defined(VALVE) if(VALVE_STATE_CLOSE == ValveGetStateApp()) { temp_frozen_data.Data.ValveState = 0x99; } else if(VALVE_STATE_OPEN == ValveGetStateApp()) { temp_frozen_data.Data.ValveState = 0x55; } #endif } //预留字节 temp_frozen_data.Data.Reverse =0x99; //校验和 temp_frozen_data.Data.CheckSum = 0; for(temp_index = 0; temp_index<(STORE_SIZE_DATA_FROZEN-1); temp_index++) { temp_frozen_data.Data.CheckSum += temp_frozen_data.data_buf[temp_index]; } step_FrozenDataStore = StoreType; break; } case SY_STATE_S10://存储数据:日冻结 { if(TASK_IDLE == EepIfIdle()) { if(uStoreIndex_SY.Data.Daily>=7) { uStoreIndex_SY.Data.Daily = 0; } EepWrite(temp_frozen_data.data_buf, EEP_ADDR_SY_STORE_FROZEN_DAILY + uStoreIndex_SY.Data.Daily*32, 32, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S11; } break; } case SY_STATE_S11: //存储指针:日冻结指针 { if(TASK_IDLE == EepIfIdle()) { uStoreIndex_SY.Data.Daily++;//下次要存的位置 EepWrite(&uStoreIndex_SY.Data.Daily, EEP_ADDR_SY_STORE_INDEX_DAILY, 1, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S1; } break; } case SY_STATE_S20://存储数据:月冻结 { if(TASK_IDLE == EepIfIdle()) { if(uStoreIndex_SY.Data.Month >=18) { uStoreIndex_SY.Data.Month = 0; } EepWrite(temp_frozen_data.data_buf, EEP_ADDR_SY_STORE_FROZEN_MONTH + uStoreIndex_SY.Data.Month*32, 32, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S21; } break; } case SY_STATE_S21: //存储指针:月冻结指针 { if(TASK_IDLE == EepIfIdle()) { uStoreIndex_SY.Data.Month++;//下次要存的位置 EepWrite(&uStoreIndex_SY.Data.Month, EEP_ADDR_SY_STORE_INDEX_MONTH, 1, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S1; } break; } case SY_STATE_S30://存储数据:年冻结 { if(TASK_IDLE == EepIfIdle()) { if(uStoreIndex_SY.Data.Year>=6) { uStoreIndex_SY.Data.Year = 0; } EepWrite(temp_frozen_data.data_buf, EEP_ADDR_SY_STORE_FROZEN_YEAR + uStoreIndex_SY.Data.Year*32, 32, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S31; } break; } case SY_STATE_S31: //存储指针:年冻结指针 { if(TASK_IDLE == EepIfIdle()) { uStoreIndex_SY.Data.Year++;//下次要存的位置 EepWrite(&uStoreIndex_SY.Data.Year, EEP_ADDR_SY_STORE_INDEX_YEAR, 1, &uTempMsg_EE); step_FrozenDataStore = SY_STATE_S1; } break; } case SY_STATE_S1: { if(TASK_IDLE == EepIfIdle()) { step_FrozenDataStore = SY_STATE_S0; return SY_STATE_S1; } break; } default: { step_FrozenDataStore = SY_STATE_S0; break; } } return 0; } //冻结数据和周期数据的清除 static int ShenYang_StoreDataClear_proc(TYP_STATE_SY StoreType) { switch(step_FrozenDataClear) { case SY_STATE_S0: { uClearDataLen =0; step_FrozenDataClear = StoreType; break; } case SY_STATE_S10://清除冻结数据 { if(TASK_IDLE == EepIfIdle()) { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_FROZEN_DAILY + uClearDataLen*CLEAR_HIS_BUF_LEN, CLEAR_HIS_BUF_LEN, &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S11; } break; } case SY_STATE_S11: { if(TASK_IDLE == EepIfIdle()) { uClearDataLen++; if((uClearDataLen+1)*CLEAR_HIS_BUF_LEN < EEP_DATA_LEN_FROZEN) { step_FrozenDataClear = SY_STATE_S10; } else { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_FROZEN_DAILY + uClearDataLen*CLEAR_HIS_BUF_LEN, (EEP_DATA_LEN_FROZEN%CLEAR_HIS_BUF_LEN), &uTempMsg_EE); uStoreIndex_SY.Data.Daily = 0; uStoreIndex_SY.Data.Month = 0; uStoreIndex_SY.Data.Year = 0; step_FrozenDataClear = SY_STATE_S12; } } break; } case SY_STATE_S12://清除冻结数据存储指针 { if(TASK_IDLE == EepIfIdle()) { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_INDEX_DAILY, 3, &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S0; return 1; } break; } case SY_STATE_S20://清除周期数据 { if(TASK_IDLE == EepIfIdle()) { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_CIRCLE + uClearDataLen*CLEAR_HIS_BUF_LEN, CLEAR_HIS_BUF_LEN, &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S21; } break; } case SY_STATE_S21: { if(TASK_IDLE == EepIfIdle()) { uClearDataLen++; if((uClearDataLen+1)*CLEAR_HIS_BUF_LEN < EEP_DATA_LEN_CIRCLE) { step_FrozenDataClear = SY_STATE_S20; } else { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_CIRCLE + uClearDataLen*CLEAR_HIS_BUF_LEN, (EEP_DATA_LEN_CIRCLE%CLEAR_HIS_BUF_LEN), &uTempMsg_EE); for(int index=0; index<6; index++) { uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.year = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.month = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.day = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.hour = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.minute = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.second = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.weekday = 0x00; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart = 0; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntEnd = 0; //清除读取索引 uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadStart = 0; uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadEnd = 0; } step_FrozenDataClear = SY_STATE_S22; } } break; } case SY_STATE_S22://清除周期数据存储指针 { if(TASK_IDLE == EepIfIdle()) { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SY_STORE_INDEX_CIRCLE, 66, &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S0; return 1; } break; } case SY_STATE_S30://清除报警事件 { if(TASK_IDLE == EepIfIdle()) { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SOE_BASE + uClearDataLen*CLEAR_HIS_BUF_LEN, CLEAR_HIS_BUF_LEN, &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S31; } break; } case SY_STATE_S31: { if(TASK_IDLE == EepIfIdle()) { uClearDataLen++; if((uClearDataLen+1)*CLEAR_HIS_BUF_LEN < EEP_DATA_LEN_SOE) { step_FrozenDataClear = SY_STATE_S30; } else { memset(s_sy_clear_history_buf,0,sizeof(s_sy_clear_history_buf)); EepWrite(s_sy_clear_history_buf, EEP_ADDR_SOE_BASE + uClearDataLen*CLEAR_HIS_BUF_LEN, (EEP_DATA_LEN_SOE%CLEAR_HIS_BUF_LEN), &uTempMsg_EE); step_FrozenDataClear = SY_STATE_S0; return 1; } } break; } default: { step_FrozenDataClear = SY_STATE_S0; break; } } return 0; } /******************************************************************************** ShenYang_Store_Machine 说 明：沈阳数据存储状态机 ********************************************************************************/ void ShenYang_Store_Machine(void) { switch(step_ShenYangStoreMachine) { case SY_STATE_S0://数据存储消息判断 { if (RtccCheckMsgApp(RtccMsg_OtherProtl)) { RtccClearMsgApp(RtccMsg_OtherProtl); FrameSetMsgApp(MsgShenYang_WarningCheck); RtccGetDateTime(&sy_protl_rtcc_time); if((sy_protl_rtcc_time.s.hour==0)&&(sy_protl_rtcc_time.s.minute==1))//每月1号0点1分存储月冻结数据 { FrameSetMsgApp(MsgShenYang_DailySave);//沈阳日冻结数据存储 if(sy_protl_rtcc_time.s.day == 1) { FrameSetMsgApp(MsgShenYang_MonthSave);//沈阳月冻结数据存储 if(sy_protl_rtcc_time.s.month == 1) { FrameSetMsgApp(MsgShenYang_YearSave);//沈阳年冻结数据存储 } } } if((sy_protl_rtcc_time.s.minute==0x00)||(sy_protl_rtcc_time.s.minute==0x30)) { FrameSetMsgApp(MsgShenYang_CircleSave);//周期数据存储 } if (sy_protl_rtcc_time.s.hour == 0)//零点 { FrameSetMsgApp(MsgShenYang_WarningStoreReset);//重置报警存储标志 } } if(FrameCheckMsgApp(MsgShenYang_DailySave))//日冻结存储消息 { FrameClearMsgApp(MsgShenYang_DailySave); //清消息 step_ShenYangStoreMachine = SY_STATE_S1; } else if(FrameCheckMsgApp(MsgShenYang_MonthSave))//月冻结存储消息 { FrameClearMsgApp(MsgShenYang_MonthSave); step_ShenYangStoreMachine = SY_STATE_S2; } else if(FrameCheckMsgApp(MsgShenYang_YearSave))//年冻结存储消息 { FrameClearMsgApp(MsgShenYang_YearSave); step_ShenYangStoreMachine = SY_STATE_S3; } else if(FrameCheckMsgApp(MsgShenYang_CircleSave))//周期数据存储消息 { FrameClearMsgApp(MsgShenYang_CircleSave); step_ShenYangStoreMachine = SY_STATE_S4; } else if(FrameCheckMsgApp(MsgShenYang_CircleClear))//周期数据清除 { FrameClearMsgApp(MsgShenYang_CircleClear); step_ShenYangStoreMachine = SY_STATE_S6; } else if(FrameCheckMsgApp(MsgShenYang_WarningClear))//报警数据清除 { uSOE_Update_Flag=0xFFFFFFFF; //清除标志，当天重复的报警可以再次记录 FrameClearMsgApp(MsgShenYang_WarningClear); step_ShenYangStoreMachine = SY_STATE_S7; } else if(FrameCheckMsgApp(MsgShenYang_FrozenClear))//冻结数据清除 { FrameClearMsgApp(MsgShenYang_FrozenClear); SaveNewSoe(SOE_SY_FROZEN_CLEAR,SOE_REMARK_NOR);//冻结数据清空 step_ShenYangStoreMachine = SY_STATE_S5; } else if(FrameCheckMsgApp(MsgShenYang_FactorySettingAndReset))//恢复出厂设置 { FrameClearMsgApp(MsgShenYang_FactorySettingAndReset); step_ShenYangStoreMachine = SY_STATE_S8; } else if(FrameCheckMsgApp(MsgShenYang_SysReset))//系统重启 { FrameClearMsgApp(MsgShenYang_SysReset); step_ShenYangStoreMachine = SY_STATE_S8; } break; } case SY_STATE_S1://日冻结数据存储 { if(ShenYang_FrozenDataStore_proc(SY_STATE_S10) == 1) { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S2://月冻结数据存储 { if(ShenYang_FrozenDataStore_proc(SY_STATE_S20) == 1) { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S3://年冻结数据存储 { if(ShenYang_FrozenDataStore_proc(SY_STATE_S30) == 1) { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S4://周期数据存储 { if(ShenYang_CircleDataStore_proc() == 1) { //RtccAdjustDateTime(1,1800-5);//往后校时半小时,测试使用 step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S5: { if(ShenYang_StoreDataClear_proc(SY_STATE_S10) == 1)//清冻结数据 { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S6: { if(ShenYang_StoreDataClear_proc(SY_STATE_S20) == 1)//清周期数据 { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S7: { if(ShenYang_StoreDataClear_proc(SY_STATE_S30) == 1)//清报警数据 { step_ShenYangStoreMachine = SY_STATE_S0; } break; } case SY_STATE_S8://暂不使用恢复出厂设置 { if (TASK_IDLE == EepIfIdle()) { NVIC_SystemReset(); step_ShenYangStoreMachine = SY_STATE_S0; } break; } default: { step_ShenYangStoreMachine = SY_STATE_S0; break; } } } //计算上报总包数 u8 getSY_CircleUploadPackets(void) { u8 temp_count=0; u32 temp_time=0; for(int i=0;i<6;i++) { uUploadIndexTimeBuf[i] = 0; } for(int index=0; index<6; index++) { if(uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntEnd <= 24) //合法性判断 { if(uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart < uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntEnd) { uUploadIndexTimeBuf[temp_count] = get_mktime(&uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime); temp_count++; } } } SortMinToMax(uUploadIndexTimeBuf, temp_count);//时间按大小排序 for(int j=0; juStoreIndex_SY.Data.Circle.CircleIndex[i].Data.ReadStart))//判断存储指针是否有效 { if((sec_circle >= sec_start) && (sec_circle <= sec_end)) //判断时间是否有效 { *pIndexBuf++ = i; temp_packet_cnt++; } } } return temp_packet_cnt; } /******************************************************************************* * @fun_name: NB_SY_Frame_Upload_CurrentData * @brief : 上报当前表数据 * @param[in] : None * @param[out]: None * @retval : None * @other : 联调测试平台接收到的数据需要非加密，平台应答数据时间返回的是HEX格式 ******************************************************************************/ int NB_SY_Frame_Upload_CurrentData(u8 *pBuf) { UNION_4U8TOU32 tmp_datas_buf; SY_U32_To_Float temp_float_data; *pBuf++ = 1; //总包数 1字节 *pBuf++ = 1; //当前包序号 1字节 RtccGetDateTime(&uTempRtccTime_BCD); //起始日期 3字节 *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.year); *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.month); *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.day); //起始时间 3字节 *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.hour); *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.minute); *pBuf++ = BCD2HEX(uTempRtccTime_BCD.s.second); *pBuf++ = 6; //6:表示30分钟（5x6）时间间隔1字节 *pBuf++ = 1; //数据条数1字节 temp_float_data.gp22_u32 = Gp30CheckDataApp(2); //正向累计流量 累计流量单位为L/0.001M3，4字节无符号整数。 tmp_datas_buf.datas = (u32)(temp_float_data.gp22_float*10); *pBuf++ = tmp_datas_buf.data_buf[0];//小数位 *pBuf++ = tmp_datas_buf.data_buf[1]; *pBuf++ = tmp_datas_buf.data_buf[2]; *pBuf++ = tmp_datas_buf.data_buf[3];//小数位 temp_float_data.gp22_u32 = Gp30CheckDataApp(3); //反向累计流量 tmp_datas_buf.datas = (u32)(temp_float_data.gp22_float*10); *pBuf++ = tmp_datas_buf.data_buf[0];//小数位 *pBuf++ = tmp_datas_buf.data_buf[1]; *pBuf++ = tmp_datas_buf.data_buf[2]; *pBuf++ = tmp_datas_buf.data_buf[3];//小数位 temp_float_data.gp22_float = Gp30CheckDataApp(GP30_APP_INS_FLOW); //瞬时流量 瞬时流量单位为0.01L/H，4字节无符号整数。 tmp_datas_buf.datas = (u32)(temp_float_data.gp22_float / (float)65536.00)*100; *pBuf++ = tmp_datas_buf.data_buf[0]; *pBuf++ = tmp_datas_buf.data_buf[1]; *pBuf++ = tmp_datas_buf.data_buf[2];//小数位 *pBuf++ = tmp_datas_buf.data_buf[3]; //tmp_datas_buf_yali.datas = 210; //测试大表返回压力 压力单位为10mbar/0.01kg/1KPa，2字节无符号整数。 *pBuf++ = 0; //压力 *pBuf++ = 0; //温度 温度单位为0.01℃，2字节有符号整数 float tmep = TempCheckValueApp(); // //tmep = -12.03; //测试 if(tmep <0) { tmp_datas_buf.datas = (u16)(tmep*(-100)); tmp_datas_buf.datas &= 0x0FFF; tmp_datas_buf.datas = ~tmp_datas_buf.datas; tmp_datas_buf.datas |= 0x8000; } else { tmp_datas_buf.datas = (u16)(tmep*(100)); } *pBuf++ = tmp_datas_buf.datas_map.data0; //温度 *pBuf++ = tmp_datas_buf.datas_map.data1; return 26; } /******************************************************************************** 函数名：SY_GetCircleDateTime 说 明：获取数据包的起始时间 ********************************************************************************/ void SY_GetCircleDateTime(DateTime *pDT, u8 index, u8 UploadOrRead) { u8 temp_hour=0; u8 temp_minute=0; u32 temp_second=0; pDT->s.year = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.year; pDT->s.month = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.month; pDT->s.day = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.day; pDT->s.hour = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.hour; pDT->s.minute = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.minute; pDT->s.second = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleDataTime.s.second; if(UploadOrRead == 0)//上报周期数据使用 { temp_second = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.CircleCntStart*30*60; } else//读取周期数据使用 { temp_second = uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadStart*30*60; } temp_hour = (temp_second/3600)%12; temp_minute = (temp_second/60)%60; pDT->s.hour = HEX2BCD(BCD2HEX(pDT->s.hour)+temp_hour); pDT->s.minute = HEX2BCD(BCD2HEX(pDT->s.minute)+temp_minute); } //根据包号获取存储指针的起始和结束位置 u8 SY_GetCircleReadStartEnd(u8 index, u8 StartOrEnd) { if(StartOrEnd == 0) { return uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadStart; } else { return uStoreIndex_SY.Data.Circle.CircleIndex[index].Data.ReadEnd; } } /******************************************************************************** 函数名：get_SY_StorePara 说 明：获取沈阳数据存储当前指针 ********************************************************************************/ u8 get_SY_StorePara(SY_ParaTypeDef paraType) { switch(paraType) { case SY_StoreCurIndex_Daily://日冻结存储指针 { return uStoreIndex_SY.Data.Daily; } case SY_StoreCurIndex_Month://月冻结存储指针 { return uStoreIndex_SY.Data.Month; } case SY_StoreCurIndex_Year://年冻结存储指针 { return uStoreIndex_SY.Data.Year; } default: break; } return 0; } /**************************************************************** Function: u16 Gp30CheckErrDataApp (void) Description: 查询错误信息 Input: Return: Others: Bit0:当前流量>Q4或者temp_data) { temp_state |=0x0001;//满足条件再置起 } } } else { sy_rtc_time_overflow = 0; } //反流报警 if(temp_state&0x0004)//gp30_event_flag.low_high_flow<<0 { temp_state &=~0x0004; sy_rtc_time_reverseflow += 1; if(GetTLVData(TagReverseFlowMinute, LenReverseFlowMinute, &temp_data)) { if(sy_rtc_time_reverseflow>temp_data) { temp_state |=0x0004; } } } else { sy_rtc_time_reverseflow = 0; } //漏水报警 if(temp_state&0x0020)//gp30_event_flag.low_high_flow<<0 { temp_state &=~0x0020; sy_rtc_time_leakflow += 1; if(GetTLVData(TagLeakFlowMinute, LenLeakFlowMinute, &temp_data)) { if(sy_rtc_time_leakflow>temp_data) { temp_state |=0x0020; } } } else { sy_rtc_time_leakflow = 0; } //空管报警 if(temp_state&0x0008)//gp30_event_flag.low_high_flow<<0 { temp_state &=~0x0008; sy_rtc_time_nowater += 1; if(GetTLVData(TagNoWaterMinute, LenNoWaterMinute, &temp_data)) { if(sy_rtc_time_nowater>temp_data) { temp_state |=0x0008; } } } else { sy_rtc_time_nowater = 0; } return temp_state; } u8 PowerCheckStatusSys_ReWrite(void) { UNION_2U8TOU16 temp_data; u16 temp_power; if(GetTLVData(TagPowerLow001V, LenPowerLow001V, &temp_data.data_buf[0])) { temp_power = PowerCheckValueSys(); if(temp_power < temp_data.datas)//数据转一下 { return LOW_POWER; } } return NORMAL_POWER; } void ShenYang_SOE_Machine(void) { switch(step_ShenYangSOEMachine) { case SY_STATE_S0: { if(FrameCheckMsgApp(MsgShenYang_WarningCheck)) { FrameClearMsgApp(MsgShenYang_WarningCheck); step_ShenYangSOEMachine =SY_STATE_S1; } if(FrameCheckMsgApp(MsgShenYang_WarningStoreReset)) { FrameClearMsgApp(MsgShenYang_WarningStoreReset); uSOE_Data_Old = 0; uSOE_Temprature_ShortOld = 0; uSOE_Temprature_OpenOld = 0; uSOE_Update_Flag = 0xFFFFFFFF; uWaterState =0; } } break; case SY_STATE_S1://报警事件消息判断 { uSOE_Data_New = Gp30CheckErrDataApp_ReWrite(); #if defined(VALVE) uSOE_Valve_New = ValveGetStateApp(); #endif uSOE_Power_New = PowerCheckStatusSys_ReWrite(); uSOE_Temprature_New = TempCheckValueApp(); if(uSOE_Data_Old != uSOE_Data_New) { uSOE_Data_Old = uSOE_Data_New; if((uSOE_Data_New&0x0001)&&(uSOE_Update_Flag&0x00000001))//gp30_event_flag.low_high_flow<<0 { uSOE_Update_Flag &=~0x00000001; SaveNewSoe(SOE_SY_OVER_FLOW,SOE_REMARK_NOR);//流量超限 if(checkWarningUploadState(UPLOAD_OVER_FLOW)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); uWaterState = SOE_SY_OVER_FLOW -1000; } if((uSOE_Data_New&0x0002)&&(uSOE_Update_Flag&0x00000002))//(gp30_event_flag.out_temp<<1) { uSOE_Update_Flag &=~0x00000002; SaveNewSoe(SOE_SY_TEMP_OVER,SOE_REMARK_NOR);//温度超限 if(checkWarningUploadState(UPLOAD_TEMP_OVER)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); } if((uSOE_Data_New&0x0004)&&(uSOE_Update_Flag&0x00000004))//(gp30_event_flag.reverse_flow<<2) { uSOE_Update_Flag &=~0x00000004; SaveNewSoe(SOE_SY_REVERSE_FLOW,SOE_REMARK_NOR);//反流报警 if(checkWarningUploadState(UPLOAD_REVERSE_FLOW)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); uWaterState = SOE_SY_REVERSE_FLOW -1000; } if((uSOE_Data_New&0x0008)&&(uSOE_Update_Flag&0x00000008))//(gp30_event_flag.no_water<<3) { uSOE_Update_Flag &=~0x00000008; SaveNewSoe(SOE_SY_NO_WATER,SOE_REMARK_NOR);//空管报警 if(checkWarningUploadState(UPLOAD_NO_WATER)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); } if((uSOE_Data_New&0x0010)&&(uSOE_Update_Flag&0x00000010))//(gp30_event_flag.gp30_err<<4) { uSOE_Update_Flag &=~0x00000010; SaveNewSoe(SOE_SY_CIRCLE_WRONG,SOE_REMARK_NOR);//电路故障 FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); uWaterState = SOE_SY_CIRCLE_WRONG -1000; } if((uSOE_Data_New&0x0020)&&(uSOE_Update_Flag&0x00000020))//(gp30_event_flag.low_flow<<5) { uSOE_Update_Flag &=~0x00000020; SaveNewSoe(SOE_SY_LEAK_FLOW,SOE_REMARK_NOR);//漏水报警 if(checkWarningUploadState(UPLOAD_LEAK_FLOW)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); } if((uSOE_Data_New&0x0040)&&(uSOE_Update_Flag&0x00000040))//(gp30_event_flag.low_amp<<6) { uSOE_Update_Flag &=~0x00000040; SaveNewSoe(SOE_SY_LOW_AMP,SOE_REMARK_NOR);//低振幅 } if((uSOE_Data_New&0x0080)&&(uSOE_Update_Flag&0x00000080))//(gp30_event_flag.communication_err<<7) { uSOE_Update_Flag &=~0x00000080; SaveNewSoe(SOE_SY_GP30_COMERR,SOE_REMARK_NOR);//GP30通信故障 FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); uWaterState = SOE_SY_GP30_COMERR -1000; } if((uSOE_Data_New&0x0001)&&(uSOE_Update_Flag&0x00000100))//(gp30_event_flag.tof_overrun<<8) { uSOE_Update_Flag &=~0x00000100; SaveNewSoe(SOE_SY_TOF_OVER,SOE_REMARK_NOR);//TOF跳变 } if((uSOE_Data_New&0x0100)&&(uSOE_Update_Flag&0x00000200))//(gp30_event_flag.water_direction<<9) { uSOE_Update_Flag &=~0x00000200; SaveNewSoe(SOE_SY_REVERSE_FLOW,SOE_REMARK_NOR);//反流报警 /*if(checkWarningUploadState(UPLOAD_REVERSE_FLOW)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); }*/ uWaterState = SOE_SY_REVERSE_FLOW -1000; } } if(uSOE_Valve_Old != uSOE_Valve_New) { u8 tem_tlv_data[7]; uSOE_Valve_Old = uSOE_Valve_New; RtccGetDateTime(&uTempRtccTime_BCD);//阀门动作时间 if(Sys_data_object.P1.ies_valve_paras.valve_err) { SaveNewSoe(SOE_SY_VALVE_ERR,SOE_REMARK_NOR);//阀门操作失败 tem_tlv_data[0] = 0xFF; } else { if(uSOE_Valve_New == VALVE_STATE_OPEN) { SaveNewSoe(SOE_SY_VALVE_OPEN,SOE_REMARK_NOR);//开阀 tem_tlv_data[0] = 0x55; } else if(uSOE_Valve_New == VALVE_STATE_CLOSE) { SaveNewSoe(SOE_SY_VALVE_CLOSE,SOE_REMARK_NOR);//关阀 tem_tlv_data[0] = 0x99; } } if(checkWarningUploadState(UPLOAD_VALVE_CHANGE)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); tem_tlv_data[1] = uTempRtccTime_BCD.s.year; tem_tlv_data[2] = uTempRtccTime_BCD.s.month; tem_tlv_data[3] = uTempRtccTime_BCD.s.day; tem_tlv_data[4] = uTempRtccTime_BCD.s.hour; tem_tlv_data[5] = uTempRtccTime_BCD.s.minute; tem_tlv_data[6] = uTempRtccTime_BCD.s.second; SetTLVData(TagValveState, LenValveState, tem_tlv_data);//保存到TLV缓存 } if(uSOE_Power_Old != uSOE_Power_New) { uSOE_Power_Old = uSOE_Power_New; if((LOW_POWER == uSOE_Power_New)&&(uSOE_Update_Flag&0x00000400)) { uSOE_Update_Flag &=~0x00000400; SaveNewSoe(SOE_SY_LOW_POWER,SOE_REMARK_NOR);//低电压报警 if(checkWarningUploadState(UPLOAD_LOW_POWER)) { FrameSetMsgApp(MsgShenYang_NbUploadWarning); } FrameSetMsgApp(MsgShenYang_NbUploadWarningWithCircle); } } if(uSOE_Temprature_New == -1) { uSOE_Temprature_OpenNew = 1; } else if(uSOE_Temprature_New == 36) { uSOE_Temprature_ShortNew = 1; } step_ShenYangSOEMachine = SY_STATE_S2; } break; case SY_STATE_S2://其他触发事件的处理 { //获取当前时间 RtccGetDateTime(&uTempRtccTime_BCD); //需要存eeprom if( (uTempRtccTime_BCD.s.year == ValveActiveDateTime.s.year)&& (uTempRtccTime_BCD.s.month == ValveActiveDateTime.s.month)&& (uTempRtccTime_BCD.s.day == ValveActiveDateTime.s.day)&& (uTempRtccTime_BCD.s.hour == ValveActiveDateTime.s.hour)&& (uTempRtccTime_BCD.s.minute == ValveActiveDateTime.s.minute)) { if (Valve_Active == 0x55) //开阀门 { FrameSetMsgApp(ValveOpenMsg); } else if (Valve_Active == 0x99) //关阀门 { FrameSetMsgApp(ValveCloseMsg); } else if(Valve_Active == 0xAA)//半开 { FrameSetMsgApp(ValveHalfMsg); } } step_ShenYangSOEMachine = SY_STATE_S0; } break; default: { step_ShenYangSOEMachine = SY_STATE_S0; break; } } } u8 getWaterState(void) { return uWaterState; } //TLV数据 u8 getTlvTagIndex(u8 inTag) { int index=0; for(index=0;index>tWarningType)&0x0001) { return 1; } } return 0; } void ShenYang_TlvDataStoreMachine(void) { static u8 index_edit=0xFF; switch(step_TlvDataStore) { case SY_STATE_S0: { if(FrameCheckMsgApp(MsgNbUploadFreqChange)) { FrameClearMsgApp(MsgNbUploadFreqChange); temp_tlv_data[0]=0; temp_tlv_data[1]=Sys_data_object.P1.Time_upload_2006.s.hour;//小时 temp_tlv_data[2]=Sys_data_object.P1.Time_upload_2006.s.minute;//分钟 temp_tlv_data[3]=0; SetTLVData(TagUploadStartTime, LenUploadStartTime, temp_tlv_data); } if(FrameCheckMsgApp(MsgShenYang_UdpIpPortChange)) { int len=0; FrameClearMsgApp(MsgShenYang_UdpIpPortChange); //IP for (int i = 0; i < 4; i++) { if (Sys_data_object.P2.server_ip[i] < 10) { temp_tlv_data[len++] = Sys_data_object.P2.server_ip[i] + 0x30; } else if (Sys_data_object.P2.server_ip[i] < 100) { temp_tlv_data[len++] = (Sys_data_object.P2.server_ip[i] / 10) + 0x30; temp_tlv_data[len++] = (Sys_data_object.P2.server_ip[i] % 10) + 0x30; } else { temp_tlv_data[len++] = (Sys_data_object.P2.server_ip[i] / 100) + 0x30; temp_tlv_data[len++] = (Sys_data_object.P2.server_ip[i] / 10) % 10 + 0x30; temp_tlv_data[len++] = (Sys_data_object.P2.server_ip[i] % 10) + 0x30; } temp_tlv_data[len++] = '.'; } len--; //消除多余的点号 temp_tlv_data[len++] = ':'; temp_tlv_data[len++] = ((Sys_data_object.P2.server_port.datas) / 10000) + 0x30; temp_tlv_data[len++] = (((Sys_data_object.P2.server_port.datas) % 10000) / 1000) + 0x30; temp_tlv_data[len++] = (((Sys_data_object.P2.server_port.datas) % 1000) / 100) + 0x30; temp_tlv_data[len++] = (((Sys_data_object.P2.server_port.datas) % 100) / 10) + 0x30; temp_tlv_data[len++] = ((Sys_data_object.P2.server_port.datas) % 10) + 0x30; temp_tlv_data[len++] = 0; SetTLVData(TagServerIpPort, LenServerIpPort, temp_tlv_data); } if(tlv_store_cnt>0) { step_TlvDataStore = SY_STATE_S1; } } break; case SY_STATE_S1:// { if(TASK_IDLE == EepIfIdle()) { for(int index=0; index> 4) * 10 + (cdt.s.year & 0x0F) + 100; tmdt.tm_mon = (cdt.s.month >> 4) * 10 + (cdt.s.month & 0x0F) - 1; tmdt.tm_mday = (cdt.s.day >> 4) * 10 + (cdt.s.day & 0x0F); tmdt.tm_hour = (cdt.s.hour >> 4) * 10 + (cdt.s.hour & 0x0F); tmdt.tm_min = (cdt.s.minute >> 4) * 10 + (cdt.s.minute & 0x0F); tmdt.tm_sec = (cdt.s.second >> 4) * 10 + (cdt.s.second & 0x0F); tmdt.tm_isdst = 0; ctt = mktime(&tmdt); //时间往前 ctt -= backDays*24*3600; ldt = localtime(&ctt); cdt.s.year = ((*ldt).tm_year - 100) / 10 * 16 + ((*ldt).tm_year - 100) % 10; cdt.s.month = ((*ldt).tm_mon + 1) / 10 * 16 + ((*ldt).tm_mon + 1) % 10; cdt.s.day = ((*ldt).tm_mday) / 10 * 16 + ((*ldt).tm_mday) % 10; cdt.s.weekday = ((*ldt).tm_wday) / 10 * 16 + ((*ldt).tm_wday) % 10; cdt.s.hour = ((*ldt).tm_hour) / 10 * 16 + ((*ldt).tm_hour) % 10; cdt.s.minute = ((*ldt).tm_min) / 10 * 16 + ((*ldt).tm_min) % 10; cdt.s.second = ((*ldt).tm_sec) / 10 * 16 + ((*ldt).tm_sec) % 10; return cdt; } //计算往前几天的日期和时间,不带周 DateTime_noweek getBackDateTimeNoWeek(u8 backDays) { DateTime cdt; DateTime_noweek cdt_noweek; struct tm tmdt; struct tm *ldt; time_t ctt; RtccGetDateTime(&cdt);//获取当前时间 tmdt.tm_year = (cdt.s.year >> 4) * 10 + (cdt.s.year & 0x0F) + 100; tmdt.tm_mon = (cdt.s.month >> 4) * 10 + (cdt.s.month & 0x0F) - 1; tmdt.tm_mday = (cdt.s.day >> 4) * 10 + (cdt.s.day & 0x0F); tmdt.tm_hour = (cdt.s.hour >> 4) * 10 + (cdt.s.hour & 0x0F); tmdt.tm_min = (cdt.s.minute >> 4) * 10 + (cdt.s.minute & 0x0F); tmdt.tm_sec = (cdt.s.second >> 4) * 10 + (cdt.s.second & 0x0F); tmdt.tm_isdst = 0; ctt = mktime(&tmdt); //时间往前 ctt -= backDays*24*3600; ldt = localtime(&ctt); cdt_noweek.s.year = ((*ldt).tm_year - 100) / 10 * 16 + ((*ldt).tm_year - 100) % 10; cdt_noweek.s.month = ((*ldt).tm_mon + 1) / 10 * 16 + ((*ldt).tm_mon + 1) % 10; cdt_noweek.s.day = ((*ldt).tm_mday) / 10 * 16 + ((*ldt).tm_mday) % 10; cdt_noweek.s.hour = ((*ldt).tm_hour) / 10 * 16 + ((*ldt).tm_hour) % 10; cdt_noweek.s.minute = ((*ldt).tm_min) / 10 * 16 + ((*ldt).tm_min) % 10; cdt_noweek.s.second = ((*ldt).tm_sec) / 10 * 16 + ((*ldt).tm_sec) % 10; return cdt_noweek; } /******************************************************************************** 函数名：ShenYangStore_IfSleep 说 明：数据存储状态机空闲判断 ********************************************************************************/ u8 ShenYangStore_IfSleep(void) { if((step_ShenYangStoreMachine == SY_STATE_S0)&&(step_ShenYangSOEMachine == SY_STATE_S0)&&(step_TlvDataStore ==SY_STATE_S0)) { return TRUE; } else { return FALSE; } } #endif