main.c 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282
  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 "ADC.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. int main(){
  35. flash_disable_read();
  36. ac_board.md_data.r_data.dev_info = ACSingCurrid << 8 | RelaySlaveChaNum;
  37. InitSysTick();
  38. led_init();
  39. lock_init();
  40. detection_init();
  41. relay_init();
  42. haddr_init();
  43. eeprom_init();
  44. read_config_from_eeprom();
  45. electricity_init();
  46. time_init();
  47. query_init();
  48. key_init();
  49. //device
  50. init_adc_parameter();
  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((ac_board.md_data.r_data.detection & 0x1) == 0)
  67. {
  68. for(uint8_t i = 0; i < PT_SUB_COUNT;i++)
  69. {
  70. ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
  71. ac_board.relay_staging_staus[i] = 0;
  72. }
  73. ac_board.handle_input_pt[0] = 0;
  74. }
  75. #if SURPPORT_2_PT
  76. if((ac_board.md_data.r_data.detection & 0x2) == 0)
  77. {
  78. for(uint8_t i = PT_SUB_COUNT; i < RelaySlaveChaNum;i++)
  79. {
  80. ac_board.handle_status[i] = ac_board.relay_staging_staus[i];
  81. ac_board.relay_staging_staus[i] = 0;
  82. }
  83. ac_board.handle_input_pt[1] = 0;
  84. }
  85. #endif
  86. #endif
  87. while(1)
  88. {
  89. if(eMBCheck())
  90. {
  91. eMBEnable();
  92. }
  93. ac_board.feed_dog();
  94. task_query();
  95. task_100ms();
  96. task_1s();
  97. task_10s();
  98. eMBPoll();
  99. if(ac_board.opt_detection)
  100. ac_board.opt_detection();
  101. relay_ctrl();
  102. }
  103. return 0;
  104. }
  105. static void task_query(void)
  106. {
  107. w_eeprom_data_t data = {0};
  108. if(ac_board.q_cache.de_queue(&data))
  109. {
  110. ac_board.write_eeprom_page(data.start_addr,(uint8_t*)&data.data,data.lenth);
  111. }
  112. }
  113. static void task_1s(void)
  114. {
  115. static uint32_t count = 0;
  116. if(ac_board.flag_1s)
  117. {
  118. ac_board.flag_1s = 0;
  119. ac_board.md_data.r_data.info.runing_time++;
  120. ac_board.led_flash();
  121. if(ac_board.detection)
  122. ac_board.detection();
  123. #if (SUPPORT_IM1253E)
  124. count++;
  125. if(count == 5)
  126. {
  127. count = 0;
  128. ac_board.flag_read_im1253 = 1;
  129. }
  130. #else
  131. #endif
  132. ac_board.read_valtage();
  133. ac_board.read_consumer();
  134. for(int i = 0; i < RelaySlaveChaNum;i++)
  135. {
  136. ac_board.check_wanning(ELE_OUTPUT,i);
  137. ac_board.opt_overfunc(i);
  138. }
  139. }
  140. }
  141. static void task_100ms(void)
  142. {
  143. //static uint8_t channel = 0;
  144. if(ac_board.flag_100ms)
  145. {
  146. ac_board.flag_100ms = 0;
  147. read_adc_val();
  148. ac_board.read_current();
  149. }
  150. }
  151. static void task_10s(void)
  152. {
  153. if(ac_board.flag_10s)
  154. {
  155. ac_board.flag_10s = 0;
  156. for(int i = 0; i < RelaySlaveChaNum;i++)
  157. {
  158. ac_board.con_da.iic_da.iic_con.iic_consumer[i] = ac_board.md_data.r_data.output[i].consumer;
  159. }
  160. if(ac_board.con_da.row >= MAX_ROW)
  161. {
  162. ac_board.con_da.row = 0;
  163. }
  164. if(ac_board.con_da.index >= UINT64_MAX)
  165. {
  166. iic_data chache1={0};
  167. ac_board.con_da.index = 0;
  168. for(int i = 0 ; i < MAX_ROW;i++)
  169. ac_board.write_eeprom_page(EEPROM_CONSUMER_ADDR +(CONSUM_PAGE*i),(uint8_t *)&chache1,CONSUM_PAGE);
  170. ac_board.con_da.row = 0;
  171. }
  172. eMBPoll();
  173. ac_board.con_da.iic_da.iic_con.recode_index1 = ac_board.con_da.index;
  174. 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);
  175. ac_board.con_da.index++;
  176. ac_board.con_da.row++;
  177. eMBPoll();
  178. }
  179. }
  180. static void relay_ctrl(void)
  181. {
  182. for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
  183. {
  184. if(IS_RL_ORDER_FLAG_EN(ac_board.relay_staging_staus[i]))
  185. {
  186. uint8_t rl_old_state = (ac_board.md_data.r_data.rl_status & ( 1 << i));
  187. uint8_t rl_now_state = GET_RL_STATUS(ac_board.relay_staging_staus[i]);
  188. if(rl_now_state > rl_old_state)
  189. {
  190. SET_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  191. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  192. if(IS_RL_ON_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
  193. {
  194. ac_board.relay_limit_counter[i] = (ac_board.md_data.rw_data.delay_on[i]*1000) / 10;
  195. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  196. SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  197. rl_delay_cnt[i] = 0;
  198. }else
  199. {
  200. ac_board.relay_limit_counter[i] = 0;
  201. SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  202. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  203. }
  204. }else if (rl_now_state < rl_old_state)
  205. {
  206. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  207. SET_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  208. if(IS_RL_OFF_DELAY_FLAG_EN(ac_board.relay_staging_staus[i]))
  209. {
  210. ac_board.relay_limit_counter[i] = (ac_board.md_data.rw_data.delay_off[i]*1000) / 10;
  211. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  212. SET_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  213. rl_delay_cnt[i] = 0;
  214. }else
  215. {
  216. ac_board.relay_limit_counter[i] = 0;
  217. SET_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  218. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  219. }
  220. }else{
  221. ac_board.relay_limit_counter[i] = 0;
  222. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  223. CLEAR_RL_COUNTER_BEGIN_FLAG(ac_board.relay_staging_staus[i]);
  224. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  225. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  226. }
  227. CLEAR_RL_ORDER_FLAG(ac_board.relay_staging_staus[i]);
  228. }
  229. }
  230. for(uint8_t i = 0; i < RelaySlaveChaNum;i++)
  231. {
  232. if(IS_RL_COUNTER_END_FLAG_EN(ac_board.relay_staging_staus[i]))
  233. {
  234. CLEAR_RL_COUNTER_END_FLAG(ac_board.relay_staging_staus[i]);
  235. if(IS_RL_ON_FLAG_EN(ac_board.relay_staging_staus[i]))
  236. {
  237. CLEAR_RL_ON_FLAG(ac_board.relay_staging_staus[i]);
  238. ac_board.open(i);
  239. }else if(IS_RL_OFF_FLAG_EN(ac_board.relay_staging_staus[i]))
  240. {
  241. CLEAR_RL_OFF_FLAG(ac_board.relay_staging_staus[i]);
  242. ac_board.close(i);
  243. }
  244. }
  245. }
  246. }