main.c 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288
  1. #include "common.h"
  2. #include "eeprom.h"
  3. #include "flash.h"
  4. #include "detection.h"
  5. #include "fwdgt.h"
  6. #include "haddr.h"
  7. #include "relay.h"
  8. #include "lock.h"
  9. #include "uart.h"
  10. #include "timer.h"
  11. #include "led.h"
  12. #include "systick.h"
  13. #include "mb.h"
  14. #include "flash.h"
  15. #include "electricity.h"
  16. #include "gd32e23x.h"
  17. #include "string.h"
  18. #include "query.h"
  19. static META_DATA_S meta_data = {0};
  20. static board_t ac_board = {0};
  21. board_t *get_board()
  22. {
  23. return &ac_board;
  24. }
  25. extern uint16_t rl_delay_cnt[RelaySlaveChaNum];
  26. static void task_query(void);
  27. static void task_1s(void);
  28. static void task_10s(void);
  29. static void task_100ms(void);
  30. static void relay_ctrl(void);
  31. static void app_init(META_DATA_S *meta);
  32. static void break_2_boot_upgreade(void);
  33. int main(){
  34. ac_board.md_data.r_data.dev_chn = ACSingCurrid << 8 | RelaySlaveChaNum;
  35. InitSysTick();
  36. led_init();
  37. lock_init();
  38. detection_init();
  39. key_init();
  40. relay_init();
  41. haddr_init();
  42. eeprom_init();
  43. read_config_from_eeprom();
  44. electricity_init();
  45. time_init();
  46. query_init();
  47. //device
  48. fwdgt_Init();
  49. eMBInit(MB_RTU, ac_board.haddr, 0, 115200, MB_PAR_NONE);
  50. eMBEnable();
  51. ac_board.md_data.r_data.info.channels = RelaySlaveChaNum;
  52. strcpy((char*)&(ac_board.md_data.r_data.info.date),__DATE__);
  53. strcat((char*)&(ac_board.md_data.r_data.info.date)," ");
  54. strcat((char*)&(ac_board.md_data.r_data.info.date),__TIME__);
  55. strcpy((char*)&(ac_board.md_data.r_data.info.ver),VERSION);
  56. flash_get_infomation(&ac_board.md_data.r_data.info);
  57. ac_board.handle_input_pt[0] = 1;
  58. ac_board.detection();
  59. if((ac_board.md_data.r_data.detection & 0x1) == 0)
  60. {
  61. for(uint8_t i = 0; i < PT_SUB_COUNT;i++)
  62. {
  63. ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
  64. ac_board.relay_staging_staus[i] = 0;
  65. }
  66. ac_board.handle_input_pt[0] = 0;
  67. }
  68. #if SURPPORT_2_PT
  69. if((ac_board.md_data.r_data.detection & 0x2) == 0)
  70. {
  71. for(uint8_t i = PT_SUB_COUNT; i < RelaySlaveChaNum;i++)
  72. {
  73. ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
  74. ac_board.relay_staging_staus[i] = 0;
  75. }
  76. }
  77. #endif
  78. while(1)
  79. {
  80. if(eMBCheck())
  81. {
  82. eMBEnable();
  83. }
  84. ac_board.feed_dog();
  85. task_query();
  86. task_100ms();
  87. task_1s();
  88. task_10s();
  89. eMBPoll();
  90. ac_board.opt_detection();
  91. relay_ctrl();
  92. if(ac_board.clear_flag)
  93. {
  94. ac_board.clear_flag = 0;
  95. reset_config_for_eeprom();
  96. }
  97. }
  98. return 0;
  99. }
  100. static uint16_t _count = 0;
  101. static void task_query(void)
  102. {
  103. w_eeprom_data_t data = {0};
  104. if(ac_board.q_cache.de_queue(&data))
  105. {
  106. ac_board.write_eeprom_page(data.start_addr,(uint8_t*)&data.data,data.lenth);
  107. }
  108. }
  109. static void task_1s(void)
  110. {
  111. if(ac_board.flag_1s)
  112. {
  113. ac_board.flag_1s = 0;
  114. ac_board.md_data.r_data.info.runing_time++;
  115. ac_board.led_flash();
  116. ac_board.detection();
  117. }
  118. }
  119. static void task_100ms(void)
  120. {
  121. static uint8_t channel = 0;
  122. if(ac_board.flag_100ms)
  123. {
  124. ac_board.flag_100ms = 0;
  125. ac_board.read_ele(channel);
  126. ac_board.check_wanning(ELE_OUTPUT,channel);
  127. ac_board.opt_overfunc(channel);
  128. channel++;
  129. if(channel == RelaySlaveChaNum)
  130. {
  131. //check input wanning
  132. //calculate input
  133. channel = 0;
  134. }
  135. }
  136. }
  137. static void task_10s(void)
  138. {
  139. if(ac_board.flag_10s)
  140. {
  141. ac_board.flag_10s = 0;
  142. for(int i = 0; i < RelaySlaveChaNum;i++)
  143. {
  144. ac_board.con_da.iic_da.iic_con.iic_consumer[i] = ac_board.md_data.r_data.ac_ele.ele_info[i].consumer;
  145. }
  146. if(ac_board.con_da.row >= MAX_ROW)
  147. {
  148. ac_board.con_da.row = 0;
  149. }
  150. if(ac_board.con_da.index >= UINT64_MAX)
  151. {
  152. iic_data chache1={0};
  153. ac_board.con_da.index = 0;
  154. for(uint8_t i = 0 ; i < MAX_ROW;i++)
  155. ac_board.write_eeprom_page(EEPROM_CONSUMER_ADDR +(CONSUM_PAGE*i),(uint8_t*)&chache1,CONSUM_PAGE);
  156. ac_board.con_da.row = 0;
  157. }
  158. eMBPoll();
  159. ac_board.con_da.iic_da.iic_con.recode_index1 = ac_board.con_da.index;
  160. 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);
  161. ac_board.con_da.index++;
  162. ac_board.con_da.row++;
  163. eMBPoll();
  164. }
  165. }
  166. //static void break_2_boot_upgreade(void)
  167. //{
  168. // meta_data.errno = 0;
  169. // meta_data.operation_flag = 1;
  170. // meta_data.recent_running_time = (uint32_t) ac_board.md_data.r_data.info.runing_time;
  171. // flash_erase_meta();
  172. // flash_write_meta(&meta_data);
  173. // __disable_irq();
  174. // //__set_FAULTMASK(1);
  175. // NVIC_SystemReset();
  176. //}
  177. //static void app_init(META_DATA_S *meta)
  178. //{
  179. // nvic_vector_table_set(NVIC_VECTTAB_FLASH,0x08004000 - NVIC_VECTTAB_FLASH);
  180. // flash_get_meta_data(meta);
  181. // __enable_irq();
  182. //}
  183. static void relay_ctrl(void)
  184. {
  185. for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
  186. {
  187. if(IS_RL_ORDER_FLAG_EN(ac_board.relay_staging_staus[i]))
  188. {
  189. uint8_t rl_old_state = ac_board.md_data.r_data.state.state[i].state;
  190. uint8_t rl_now_state = GET_RL_STATUS(ac_board.relay_staging_staus[i]);
  191. if(rl_now_state > rl_old_state)
  192. {
  193. SET_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  194. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  195. if(IS_RL_ON_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
  196. {
  197. ac_board.relay_limit_counter[i] = ac_board.md_data.rw_data.open.delay_open[i] / 10;
  198. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  199. SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  200. rl_delay_cnt[i] = 0;
  201. }else
  202. {
  203. ac_board.relay_limit_counter[i] = 0;
  204. SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  205. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  206. }
  207. }else if (rl_now_state < rl_old_state)
  208. {
  209. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  210. SET_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  211. if(IS_RL_OFF_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
  212. {
  213. ac_board.relay_limit_counter[i] = ac_board.md_data.rw_data.close.delay_close[i] / 10;
  214. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  215. SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  216. rl_delay_cnt[i] = 0;
  217. }else
  218. {
  219. ac_board.relay_limit_counter[i] = 0;
  220. SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  221. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  222. }
  223. }else{
  224. ac_board.relay_limit_counter[i] = 0;
  225. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  226. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  227. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  228. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  229. }
  230. CLEAR_RL_ORDER_FLAG(ac_board.relay_staging_staus[i]);
  231. }
  232. }
  233. for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
  234. {
  235. if(IS_RL_COUNTER_END_FLAG_EN(ac_board.relay_staging_staus[i]))
  236. {
  237. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  238. if(IS_RL_ON_FLAG_EN(ac_board.relay_staging_staus[i]))
  239. {
  240. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  241. ac_board.open(i);
  242. }else if(IS_RL_OFF_FLAG_EN(ac_board.relay_staging_staus[i]))
  243. {
  244. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  245. ac_board.close(i);
  246. }
  247. }
  248. }
  249. }