main.c 7.8 KB

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