commands_api.c 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396
  1. /********************************* (C) РОТЕК ***********************************
  2. * @module commands_api
  3. * @file commands_api.c
  4. * @version 1.0.0
  5. * @date XX.XX.XXXX
  6. * $brief commands_api
  7. *******************************************************************************
  8. * @history Version Author Comment
  9. * XX.XX.XXXX 1.0.0 Telenkov D.A. First release.
  10. *******************************************************************************
  11. */
  12. #include "common_config.h"
  13. #include "stm32f4xx.h"
  14. #include "commands_api.h"
  15. #include "settings_api.h"
  16. #include "sys_api.h"
  17. #include "buttons.h"
  18. #include "led.h"
  19. #include "usart.h"
  20. #include "parameters.h"
  21. #include "bt_6701_settings.h"
  22. #include "bt_6701_commands.h"
  23. #include "netconf.h"
  24. #include "stm32f4x7_eth.h"
  25. #include "http_server.h"
  26. #include "config_service.h"
  27. #include "rtc.h"
  28. #include "port_microrl.h"
  29. #include "FreeRTOS.h"
  30. #include "task.h"
  31. #include "lwip/opt.h"
  32. #include "lwip/api.h"
  33. #include "lwip/sys.h"
  34. #ifdef PRINTF_STDLIB
  35. #include <stdio.h>
  36. #endif
  37. #ifdef PRINTF_CUSTOM
  38. #include "tinystdio.h"
  39. #endif
  40. #define UDP_PORT 49049
  41. TESTING_STATE_t TESTING_STATE = TEST_IDLE;
  42. static TEST_t testState = TEST_WAIT;
  43. bool ifTest_DEF = false;
  44. bool ifTest_SET = false;
  45. bool macWaiting = false;
  46. bool macIsInstalled = false;
  47. bool fUpdatable = false;
  48. bool fDefPressed = false;
  49. bool testEthernet = false;
  50. bool testRtc = false;
  51. bool testSerno = false;
  52. bool testT2Ready = false;
  53. bool testSet = false;
  54. bool testRS485 = false;
  55. #define MSG_LEN 300
  56. char msg[MSG_LEN];
  57. extern char STM_ID[33];
  58. extern char STM_ID_HEX[12];
  59. uint8_t MAC[6];
  60. /**
  61. * @brief Общая структура настроек
  62. */
  63. extern SETTINGS_t sSettings;
  64. /**
  65. * @brief
  66. */
  67. void vTestCommands(void *params)
  68. {
  69. for (;;)
  70. {
  71. if (fUpdatable) {
  72. if(RTC_GetUnixTime() <= 946685800)
  73. {
  74. memset(SETTINGS_GetTestState(), 0, 16);
  75. SETTINGS_SetTest(SETTINGS_GetTestState());
  76. #ifdef LED_ALARM
  77. LED_On(LED_ALARM);
  78. #endif
  79. //xTaskCreate(vTaskServiceLedBlinkErr, "LED_Blink_Err", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  80. xTaskCreate(vTaskServiceLedBlink, "LED_Blink", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  81. while(1){
  82. vTaskDelay(10);
  83. }
  84. }
  85. //COM_TestEthernet();
  86. SETTINGS_SetInfoDef();
  87. Test_Ethernet();
  88. vTaskDelay(8000);
  89. /* Стартует таск для опроса кнопки DEF */
  90. //xTaskCreate(vBootloaderButton, "DEF_Bootloader", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  91. xTaskCreate(vTaskButtons, "DEF_Waiting", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  92. xTaskCreate(vTaskServiceLedBlink, "LED_Blink", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  93. while (!fDefPressed) {
  94. vTaskDelay(10);
  95. }
  96. #ifdef LED_INIT_ERR
  97. LED_On(LED_INIT_ERR);
  98. #endif
  99. #ifdef LED_ALARM
  100. LED_On(LED_ALARM);
  101. #endif
  102. #ifdef LED_RED_MINOR
  103. LED_On(LED_RED_MINOR);
  104. #endif
  105. //sSettings.bootParams.loadMode = 1;
  106. SetLoadMode();
  107. COM_TestSerno();
  108. COM_SetTestState(T2READY);
  109. vTaskDelay(1000);
  110. NVIC_SystemReset();
  111. while (1) {};
  112. }
  113. switch (testState)
  114. {
  115. case TEST_WAIT :
  116. break;
  117. case TEST_U232 :
  118. Test_U232();
  119. break;
  120. #ifdef DINS_ENABLE || DOUTS_ENABLE
  121. case TEST_DRY :
  122. Test_DRY();
  123. break;
  124. #endif
  125. case TEST_DEF :
  126. if (!ifTest_DEF) {
  127. ifTest_DEF = true;
  128. xTaskCreate(vTest_DEF, "DEF_Test", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  129. }
  130. break;
  131. case TEST_SET :
  132. if (!ifTest_SET) {
  133. ifTest_SET = true;
  134. xTaskCreate(vTest_SET, "SET_Test", configMINIMAL_STACK_SIZE, NULL, tskIDLE_PRIORITY, NULL);
  135. }
  136. break;
  137. case TEST_RTC :
  138. COM_TestRtc();
  139. break;
  140. case TEST_SPIFLASH :
  141. COM_TestSPIflash();
  142. break;
  143. case TEST_ETHERNET :
  144. COM_SetMAC();
  145. Test_Ethernet();
  146. break;
  147. case TEST_SERNO :
  148. Test_Serno();
  149. break;
  150. default :
  151. break;
  152. }
  153. vTaskDelay(200);
  154. //TestProcessing();
  155. }
  156. }
  157. /**
  158. * @brief
  159. */
  160. void TEST_SetTest(TEST_t state)
  161. {
  162. // Изменяем стейт только в том случае если контроллер находится в режиме ожидания
  163. if (testState == TEST_WAIT)
  164. testState = state;
  165. // На TEST_WAIT можно изменить всегда
  166. if (state == TEST_WAIT)
  167. testState = state;
  168. }
  169. #ifdef PORTGW_ENABLE
  170. /**
  171. * @brief Отправка данных по интерфейсу RS485
  172. */
  173. void COM_TestRS485(char *str, uint8_t len)
  174. {
  175. if (str) {
  176. uint8_t sent = rs485_send_block((uint8_t *)str, len);
  177. sprintf(msg, "RS485 sent %d bytes", sent);
  178. print(msg);
  179. }
  180. print("\r\n");
  181. testRS485 = false;
  182. return;
  183. }
  184. #endif
  185. /**
  186. * @brief Считать статут тестирования (T0, T1, etc)
  187. */
  188. void COM_ReadTestState(void)
  189. {
  190. if (strncmp(SETTINGS_GetTestState(), "T0READY", 5) == 0) {
  191. TESTING_STATE = T0READY;
  192. printf("T0READY\r\n");
  193. }
  194. else if (strncmp(SETTINGS_GetTestState(), "T0OK", 5) == 0)
  195. TESTING_STATE = T0OK;
  196. else if (strncmp(SETTINGS_GetTestState(), "T1OK", 5) == 0) {
  197. TESTING_STATE = T1OK;
  198. // TODO Если осуществлять поддержку старых версий UCN нужно учесть этот флаг
  199. fUpdatable = true;
  200. }
  201. else if (strncmp(SETTINGS_GetTestState(), "T2READY", 8) == 0) {
  202. TESTING_STATE = T2READY;
  203. }
  204. else
  205. TESTING_STATE = TEST_IDLE;
  206. }
  207. /**
  208. * @brief Сохранение Serno и отправка сообщения на сервер
  209. */
  210. void COM_TestSerno(void)
  211. {
  212. struct netconn *conn;
  213. struct netbuf *buf;
  214. char *data;
  215. err_t err;
  216. char str[20] = {0};
  217. uint8_t len;
  218. /* Отправляем сообщение на сервер по UDP */
  219. memset(msg, 0, MSG_LEN);
  220. conn = netconn_new( NETCONN_UDP );
  221. if (conn!= NULL)
  222. {
  223. err = netconn_bind(conn, IP_ADDR_ANY, UDP_PORT);
  224. if (err == ERR_OK)
  225. {
  226. netconn_connect(conn, IP_ADDR_BROADCAST, UDP_PORT);
  227. memset(str, 0, 20);
  228. GetModelStr(str, &len);
  229. //strcpy(msg, sSettings.sSnmp.sysName);
  230. strcpy(msg, str);
  231. strcat(msg, ";");
  232. memset(str, 0, 20);
  233. GetSerialNumberStr(str, &len);
  234. //strcat(msg, sSettings.sInfo.serialNumber);
  235. strcat(msg, str);
  236. strcat(msg, ";");
  237. /* empty column (format reqs)*/
  238. strcat(msg, ";");
  239. strcat(msg, VERSION_TEST);
  240. strcat(msg, ";");
  241. /* empty column (format reqs)*/
  242. strcat(msg, ";");
  243. /* empty column (format reqs)*/
  244. strcat(msg, ";");
  245. strcat(msg, STM_ID);
  246. strcat(msg, ";");
  247. /* empty column (format reqs)*/
  248. strcat(msg, ";");
  249. /* empty column (format reqs)*/
  250. strcat(msg, ";");
  251. if (TESTING_STATE == T0OK)
  252. strcat(msg, "T0OK");
  253. else if (TESTING_STATE == T1OK)
  254. strcat(msg, "T1OK");
  255. else if (TESTING_STATE == T0READY)
  256. strcat(msg, "T0READY");
  257. else if (TESTING_STATE == T2READY)
  258. strcat(msg, "T2READY");
  259. strcat(msg, ";");
  260. /* empty column (format reqs)*/
  261. strcat(msg, ";");
  262. buf = netbuf_new();
  263. data = netbuf_alloc(buf, strlen(msg));
  264. memcpy(data, msg, strlen(msg));
  265. netconn_send(conn, buf);
  266. netbuf_delete(buf);
  267. }
  268. else
  269. netconn_delete(conn);
  270. }
  271. }
  272. /**
  273. * @brief Устанавливает mac адрес исходя из unique id
  274. */
  275. void COM_SetMAC(void)
  276. {
  277. uint8_t octet1 = 0;
  278. uint8_t octet2 = 0;
  279. uint8_t octet3 = 0;
  280. for (uint8_t i = 0; i < 4; i++)
  281. {
  282. octet1 ^= STM_ID_HEX[i];
  283. octet2 ^= STM_ID_HEX[i + 4];
  284. octet3 ^= STM_ID_HEX[i + 8];
  285. }
  286. /* Восьмой бит первого октета должен быть равен 0 */
  287. /* MAC[0] = octet1 & 0xFE;
  288. MAC[1] = octet2;
  289. MAC[2] = octet3;
  290. MAC[3] = 0x00;
  291. MAC[4] = 0x00;
  292. MAC[5] = 0x00;*/
  293. /* Устанавливаем MAC, но не сохраняем */
  294. snprintf(sSettings.sInfo.mac, MAC_LEN, "%02X-%02X-%02X-00-00-00", octet1 & 0xFE, octet2, octet3);
  295. }
  296. /**
  297. * @brief Установить статут тестирования (T0, T1, etc)
  298. */
  299. void COM_SetTestState(TESTING_STATE_t status)
  300. {
  301. switch (status)
  302. {
  303. case T0READY :
  304. //memset(sSettings.sFlags.testState, 0, 16);
  305. //strncpy(sSettings.sFlags.testState, "T0READY", 7);
  306. memset(SETTINGS_GetTestState(), 0, 16);
  307. strncpy(SETTINGS_GetTestState(), "T0READY", 7);
  308. TESTING_STATE = T0READY;
  309. break;
  310. case T0OK :
  311. //memset(sSettings.sFlags.testState, 0, 16);
  312. //strncpy(sSettings.sFlags.testState, "T0OK", 4);
  313. memset(SETTINGS_GetTestState(), 0, 16);
  314. strncpy(SETTINGS_GetTestState(), "T0OK", 4);
  315. TESTING_STATE = T0OK;
  316. break;
  317. case T1OK :
  318. //memset(sSettings.sFlags.testState, 0, 16);
  319. //strncpy(sSettings.sFlags.testState, "T1OK", 4);
  320. memset(SETTINGS_GetTestState(), 0, 16);
  321. strncpy(SETTINGS_GetTestState(), "T1OK", 4);
  322. TESTING_STATE = T1OK;
  323. break;
  324. case T2READY :
  325. //memset(sSettings.sFlags.testState, 0, 16);
  326. //strncpy(sSettings.sFlags.testState, "T2READY", 7);
  327. memset(SETTINGS_GetTestState(), 0, 16);
  328. strncpy(SETTINGS_GetTestState(), "T2READY", 7);
  329. TESTING_STATE = T2READY;
  330. break;
  331. }
  332. SETTINGS_SetTest(SETTINGS_GetTestState());
  333. }
  334. /********************************* (C) РОТЕК **********************************/