main.c 7.6 KB

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