main.c 6.4 KB

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