appl.c 71 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886
  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <time.h>
  4. #include <pthread.h>
  5. #include <sys/ioctl.h>
  6. #include <linux/if.h>
  7. #include <linux/serial.h>
  8. #include <syslog.h>
  9. #include <unistd.h>
  10. #include "mongoose.h"
  11. #include "can_frame.h"
  12. #include "appl.h"
  13. #include "modbus.h"
  14. #include "MQTTClient.h"
  15. #include "MQTTClientPersistence.h"
  16. #define EXPORT_PATH "/sys/class/gpio/export" // GPIO设备导出设备
  17. #define DIR_OUT "out"
  18. #define DIR_IN "in"
  19. char* VERSION = "5.1.8";
  20. struct appl_t APPL;
  21. struct mg_mgr mgr_mqtt1; // thingsboard
  22. struct mg_mgr mgr_mqtt2; // cloud
  23. struct mg_mgr mgr_mqtt3; // gate and trans meter
  24. int appl_cfg_save( void )
  25. {
  26. FILE* fp = NULL;
  27. int rc ;
  28. fp = fopen("./cfg.bin","wb");
  29. if( fp == NULL){
  30. syslog(LOG_INFO,"%s, fopen ./cfg.bin Fail", __func__);
  31. return -1;
  32. }else{
  33. rc = fwrite(APPL.Set.buf, sizeof(char), sizeof(APPL.Set.buf), fp);
  34. if( rc != sizeof(APPL.Set.buf)){
  35. syslog(LOG_INFO,"%s, fwrite ./cfg.bin Fail, rc:%d", __func__, rc);
  36. return -1;
  37. }else{
  38. return 0;
  39. }
  40. }
  41. }
  42. int appl_cfg_read( void )
  43. {
  44. FILE* fp = NULL;
  45. int rc;
  46. fp = fopen("./cfg.bin","rb");
  47. if( fp == NULL){
  48. syslog(LOG_INFO,"%s, fopen ./cfg.bin Fail", __func__);
  49. return -1;
  50. }else{
  51. rc = fread(APPL.Set.buf, sizeof(char), sizeof(APPL.Set.buf), fp);
  52. if( rc != sizeof(APPL.Set.buf)){
  53. syslog(LOG_INFO,"%s, fread ./cfg.bin Fail, rc:%d", __func__, rc);
  54. return -1;
  55. }else{
  56. return 0;
  57. }
  58. }
  59. }
  60. void appl_cfg_set_err( void )
  61. {
  62. APPL.Set.s.bErr = 1;
  63. strcpy(APPL.Set.s.szState,"故障");
  64. }
  65. void appl_cfg_reset_err( void )
  66. {
  67. APPL.Set.s.bErr = 0;
  68. strcpy(APPL.Set.s.szState,"正常");
  69. }
  70. static char* appl_get_datetime_long( void )
  71. {
  72. time_t timep;
  73. struct tm *tsp;
  74. static char buf[128];
  75. time(&timep);
  76. // tsp = gmtime(&timep);
  77. tsp = localtime(&timep);
  78. sprintf(buf, "%04d-%02d-%02d %02d:%02d:%02d", tsp->tm_year + 1900,
  79. tsp->tm_mon + 1,
  80. tsp->tm_mday,
  81. tsp->tm_hour,
  82. tsp->tm_min,
  83. (short)tsp->tm_sec);
  84. return buf;
  85. }
  86. static char* appl_get_datetime_short( void )
  87. {
  88. static char buf[128];
  89. time_t timep;
  90. struct tm *tsp;
  91. time(&timep);
  92. // tsp = gmtime(&timep);
  93. tsp = localtime(&timep);
  94. sprintf(buf, "%02d:%02d:%02d",
  95. tsp->tm_hour,
  96. tsp->tm_min,
  97. (short)tsp->tm_sec);
  98. return buf;
  99. }
  100. static void appl_get_datetime_num(int *y, int *m, int *d, int *h, int *min, int *s)
  101. {
  102. time_t timep;
  103. struct tm *tsp;
  104. time(&timep);
  105. // tsp = gmtime(&timep);
  106. tsp = localtime(&timep);
  107. *y = 1900 + tsp->tm_year;
  108. *m = 1 + tsp->tm_mon;
  109. *d = tsp->tm_mday;
  110. *h = tsp->tm_hour;
  111. *min = tsp->tm_min;
  112. *s = tsp->tm_sec;
  113. }
  114. char* appl_get_dtstr(void)
  115. {
  116. time_t timep;
  117. struct tm *tsp;
  118. static char buf[200];
  119. time(&timep);
  120. tsp = localtime(&timep);
  121. sprintf(buf, "%04d-%02d-%02d %02d:%02d:%02d", tsp->tm_year + 1900,
  122. tsp->tm_mon + 1,
  123. tsp->tm_mday,
  124. tsp->tm_hour,
  125. tsp->tm_min,
  126. (short)tsp->tm_sec);
  127. return buf;
  128. }
  129. static void* thrd_485_1(void *param)
  130. {
  131. char buf[128];
  132. modbus_t* ctx = NULL;
  133. struct timeval t;
  134. int rc;
  135. unsigned short data[256];
  136. unsigned short start;
  137. unsigned short nbr;
  138. int chidx = 1;
  139. int i;
  140. struct chan485_t* ch = &APPL.chan485[chidx];
  141. struct Dtsd1352_t* m = NULL;
  142. int64_t startts;
  143. syslog(LOG_INFO,"%s ENTER", __func__);
  144. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  145. while(1){
  146. startts = mg_millis();
  147. switch( ch->state){
  148. case ST_485_INIT:
  149. ctx = modbus_new_rtu(ch->szdev, ch->baud, 'N', 8, 1);
  150. if (ctx == NULL){
  151. MG_INFO(("%s, modbus rtu new fail", __func__));
  152. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  153. }else if (modbus_connect(ctx) == -1){
  154. MG_INFO(("%s, modbus rtu connect fail", __func__));
  155. modbus_free(ctx);
  156. ctx = NULL;
  157. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  158. }else{
  159. // t.tv_sec = 0;
  160. // t.tv_usec = 500000; // 500ms
  161. // //modbus_set_response_timeout(ctx, &t);
  162. // modbus_set_response_timeout(ctx, 0, 500000);
  163. ch->reqcnt = 0;
  164. ch->failcnt = 0;
  165. appl_485_set_state(chidx, ST_485_RUN, ERR_485_NONE);
  166. }
  167. break;
  168. case ST_485_RUN:
  169. // Process Cmd
  170. if( ch->Cmd == CMD_485_RESET ){
  171. ch->Cmd = CMD_485_DONE;
  172. if (ctx != NULL){
  173. modbus_close(ctx);
  174. modbus_free(ctx);
  175. ctx = NULL;
  176. }
  177. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  178. break;
  179. }
  180. for( i = 1; i <= 1; i++ ){
  181. m = &APPL.Dtsd1352[i];
  182. if( mg_millis() - m->LastUpdate > 5000 ){
  183. m->CommState = ST_COMM_ERR;
  184. strcpy(m->szCommState,"故障");
  185. }else{
  186. m->CommState = ST_COMM_NORM;
  187. strcpy(m->szCommState,"正常");
  188. }
  189. // Comm with DTSD1352
  190. // PART 1
  191. appl_chan485_lock(chidx);
  192. usleep(100000);
  193. modbus_set_slave(ctx, m->Adr);
  194. start = 0x0000;
  195. nbr = 32;
  196. rc = modbus_read_registers( ctx, start, nbr, data);
  197. appl_chan485_unlock(chidx);
  198. ch->reqcnt += 1;
  199. if(rc != nbr){
  200. ch->failcnt += 1;
  201. m->CommFailTotalCnt += 1;
  202. modbus_flush(ctx);
  203. }else{
  204. m->com_active_e = ((uint32_t)(data[0x0000 - start] << 16 | data[0x0001 - start])) * m->PT * m->CT * 0.01;
  205. m->pos_active_e = ((uint32_t)(data[0x000A - start] << 16 | data[0x000B - start])) * m->PT * m->CT * 0.01;
  206. m->neg_active_e = ((uint32_t)(data[0x0014 - start] << 16 | data[0x0015 - start])) * m->PT * m->CT * 0.01;
  207. // PART 2
  208. appl_chan485_lock(chidx);
  209. usleep(100000);
  210. start = 0x0061;
  211. nbr = 23;
  212. rc = modbus_read_registers( ctx, start, nbr, data);
  213. appl_chan485_unlock(chidx);
  214. ch->reqcnt += 1;
  215. if(rc != nbr){
  216. ch->failcnt += 1;
  217. m->CommFailTotalCnt += 1;
  218. modbus_flush(ctx);
  219. }else{
  220. m->ua = data[0x0061 - start] * m->PT * 0.1;
  221. m->ub = data[0x0062 - start] * m->PT * 0.1;
  222. m->uc = data[0x0063 - start] * m->PT * 0.1;
  223. m->ia = data[0x0064 - start] * m->CT * 0.01;
  224. m->ib = data[0x0065 - start] * m->CT * 0.01;
  225. m->ic = data[0x0066 - start] * m->CT * 0.01;
  226. m->freq = data[0x0077 - start] * 0.01;
  227. // PART 3
  228. appl_chan485_lock(chidx);
  229. usleep(100000);
  230. start = 0x0078;
  231. nbr = 32;
  232. rc = modbus_read_registers( ctx, start, nbr, data);
  233. appl_chan485_unlock(chidx);
  234. ch->reqcnt += 1;
  235. if(rc != nbr){
  236. ch->failcnt += 1;
  237. m->CommFailTotalCnt += 1;
  238. modbus_flush(ctx);
  239. }else{
  240. m->PT = data[0x008D - start];
  241. m->CT = data[0x008E - start];
  242. // PART 4
  243. appl_chan485_lock(chidx);
  244. usleep(100000);
  245. start = 0x016A;
  246. nbr = 60;
  247. rc = modbus_read_registers( ctx, start, nbr, data);
  248. appl_chan485_unlock(chidx);
  249. ch->reqcnt += 1;
  250. if(rc != nbr){
  251. ch->failcnt += 1;
  252. m->CommFailTotalCnt += 1;
  253. modbus_flush(ctx);
  254. }else{
  255. m->com_active_p = ((int32_t)(data[0x016A - start] << 16 | data[0x016B - start])) * m->PT * m->CT * 0.001;
  256. m->com_ractive_p = ((int32_t)(data[0x0172 - start] << 16 | data[0x0173 - start])) * m->PT * m->CT * 0.001;
  257. m->pwr_factor = (short)data[0x017F - start] * 0.001;
  258. m->pos_active_dem = data[0x0198 - start];
  259. m->neg_active_dem = data[0x0199 - start];
  260. m->LastUpdate = mg_millis();
  261. strcpy(m->szLastUpdate, appl_get_dtstr());
  262. }
  263. }
  264. }
  265. }
  266. }
  267. break;
  268. case ST_485_ERR:
  269. if(ch->Cmd == CMD_485_RESET){
  270. ch->Cmd = CMD_485_DONE;
  271. if (ctx != NULL){
  272. modbus_close(ctx);
  273. modbus_free(ctx);
  274. ctx = NULL;
  275. }
  276. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  277. }else{
  278. usleep(300000);
  279. }
  280. break;
  281. default:
  282. // never reach here
  283. break;
  284. }
  285. usleep(100000);
  286. ch->loopcnt += 1;
  287. ch->looptime = mg_millis() - startts;
  288. }
  289. syslog(LOG_INFO, "%s EXIT", __func__);
  290. }
  291. static void* thrd_485_2(void *param)
  292. {
  293. char buf[128];
  294. modbus_t* ctx = NULL;
  295. struct timeval t;
  296. int rc;
  297. unsigned short data[256];
  298. unsigned short start;
  299. unsigned short nbr;
  300. int chidx = 2;
  301. struct chan485_t* ch = &APPL.chan485[chidx];
  302. struct Dtsd1352_t* m = NULL;
  303. int step = 1;
  304. int i;
  305. int64_t startts;
  306. syslog(LOG_INFO, "%s ENTER", __func__);
  307. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  308. while(1){
  309. startts = mg_millis();
  310. switch( ch->state){
  311. case ST_485_INIT:
  312. ctx = modbus_new_rtu(ch->szdev, ch->baud, 'N', 8, 1);
  313. if (ctx == NULL){
  314. MG_INFO(("%s, modbus rtu new fail", __func__));
  315. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  316. }else if (modbus_connect(ctx) == -1){
  317. MG_INFO(("%s, modbus rtu connect fail", __func__));
  318. modbus_free(ctx);
  319. ctx = NULL;
  320. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  321. }else{
  322. t.tv_sec = 0;
  323. t.tv_usec = 500000;
  324. //modbus_set_response_timeout(ctx, &t);
  325. modbus_set_response_timeout(ctx, 0, 500000);
  326. ch->reqcnt = 0;
  327. ch->failcnt = 0;
  328. appl_485_set_state(chidx, ST_485_RUN, ERR_485_NONE);
  329. }
  330. break;
  331. case ST_485_RUN:
  332. // Process Cmd
  333. if( ch->Cmd == CMD_485_RESET ){
  334. ch->Cmd = CMD_485_DONE;
  335. if (ctx != NULL){
  336. modbus_close(ctx);
  337. modbus_free(ctx);
  338. ctx = NULL;
  339. }
  340. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  341. break;
  342. }
  343. for( i = 2; i <= 2; i++ ){
  344. m = &APPL.Dtsd1352[i];
  345. if( mg_millis() - m->LastUpdate > 5000 ){
  346. m->CommState = ST_COMM_ERR;
  347. strcpy(m->szCommState,"故障");
  348. }else{
  349. m->CommState = ST_COMM_NORM;
  350. strcpy(m->szCommState,"正常");
  351. }
  352. // Comm with DTSD1352
  353. // PART 1
  354. appl_chan485_lock(chidx);
  355. usleep(50000);
  356. modbus_set_slave(ctx, m->Adr);
  357. start = 0x0000;
  358. nbr = 32;
  359. rc = modbus_read_registers( ctx, start, nbr, data);
  360. appl_chan485_unlock(chidx);
  361. ch->reqcnt += 1;
  362. if(rc != nbr){
  363. ch->failcnt += 1;
  364. m->CommFailTotalCnt += 1;
  365. modbus_flush(ctx);
  366. }else{
  367. m->com_active_e = ((int32_t)(data[0x0000 - start] << 16 | data[0x0001 - start])) * m->PT * m->CT * 0.01;
  368. m->pos_active_e = ((int32_t)(data[0x000A - start] << 16 | data[0x000B - start])) * m->PT * m->CT * 0.01;
  369. m->neg_active_e = ((int32_t)(data[0x0014 - start] << 16 | data[0x0015 - start])) * m->PT * m->CT * 0.01;
  370. // PART 2
  371. appl_chan485_lock(chidx);
  372. usleep(50000);
  373. start = 0x0061;
  374. nbr = 23;
  375. rc = modbus_read_registers( ctx, start, nbr, data);
  376. appl_chan485_unlock(chidx);
  377. ch->reqcnt += 1;
  378. if(rc != nbr){
  379. ch->failcnt += 1;
  380. m->CommFailTotalCnt += 1;
  381. modbus_flush(ctx);
  382. }else{
  383. m->ua = data[0x0061 - start] * m->PT * 0.1;
  384. m->ub = data[0x0062 - start] * m->PT * 0.1;
  385. m->uc = data[0x0063 - start] * m->PT * 0.1;
  386. m->ia = data[0x0064 - start] * m->CT * 0.01;
  387. m->ib = data[0x0065 - start] * m->CT * 0.01;
  388. m->ic = data[0x0066 - start] * m->CT * 0.01;
  389. m->freq = data[0x0077 - start] * 0.01;
  390. // PART 3
  391. appl_chan485_lock(chidx);
  392. usleep(50000);
  393. start = 0x0078;
  394. nbr = 32;
  395. rc = modbus_read_registers( ctx, start, nbr, data);
  396. appl_chan485_unlock(chidx);
  397. ch->reqcnt += 1;
  398. if(rc != nbr){
  399. ch->failcnt += 1;
  400. m->CommFailTotalCnt += 1;
  401. modbus_flush(ctx);
  402. }else{
  403. m->PT = data[0x008D - start];
  404. m->CT = data[0x008E - start];
  405. // PART 4
  406. appl_chan485_lock(chidx);
  407. usleep(50000);
  408. start = 0x016A;
  409. nbr = 60;
  410. rc = modbus_read_registers( ctx, start, nbr, data);
  411. appl_chan485_unlock(chidx);
  412. ch->reqcnt += 1;
  413. if(rc != nbr){
  414. ch->failcnt += 1;
  415. m->CommFailTotalCnt += 1;
  416. modbus_flush(ctx);
  417. }else{
  418. m->com_active_p = ((int32_t)(data[0x016A - start] << 16 | data[0x016B - start])) * m->PT * m->CT * 0.001;
  419. m->com_ractive_p = ((int32_t)(data[0x0172 - start] << 16 | data[0x0173 - start])) * m->PT * m->CT * 0.001;
  420. m->pwr_factor = (short)data[0x017F - start] * 0.001;
  421. m->pos_active_dem = data[0x0198 - start];
  422. m->neg_active_dem = data[0x0199 - start];
  423. m->LastUpdate = mg_millis();
  424. strcpy(m->szLastUpdate, appl_get_dtstr());
  425. }
  426. }
  427. }
  428. }
  429. }
  430. break;
  431. case ST_485_ERR:
  432. if(ch->Cmd == CMD_485_RESET){
  433. ch->Cmd = CMD_485_DONE;
  434. if (ctx != NULL){
  435. modbus_close(ctx);
  436. modbus_free(ctx);
  437. ctx = NULL;
  438. }
  439. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  440. }else{
  441. usleep(300000);
  442. }
  443. break;
  444. default:
  445. // never reach here
  446. break;
  447. }
  448. usleep(100000);
  449. ch->loopcnt += 1;
  450. ch->looptime = mg_millis() - startts;
  451. }
  452. syslog(LOG_INFO, "%s EXIT", __func__);
  453. }
  454. static void* thrd_485_3(void *param)
  455. {
  456. char buf[128];
  457. modbus_t* ctx = NULL;
  458. struct timeval t;
  459. int rc;
  460. unsigned short data[256];
  461. unsigned short start;
  462. unsigned short nbr;
  463. int chidx = 3;
  464. int i;
  465. struct chan485_t* ch = &APPL.chan485[chidx];
  466. int64_t startts;
  467. struct Dtsd1352_t* m = NULL;
  468. syslog(LOG_INFO,"%s ENTER", __func__);
  469. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  470. while(1){
  471. startts = mg_millis();
  472. switch( ch->state){
  473. case ST_485_INIT:
  474. ctx = modbus_new_rtu(ch->szdev, ch->baud, 'N', 8, 1);
  475. if (ctx == NULL){
  476. MG_INFO(("%s, modbus rtu new fail", __func__));
  477. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  478. }else if (modbus_connect(ctx) == -1){
  479. MG_INFO(("%s, modbus rtu connect fail", __func__));
  480. modbus_free(ctx);
  481. ctx = NULL;
  482. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  483. }else{
  484. t.tv_sec = 0;
  485. t.tv_usec = 500000;
  486. //modbus_set_response_timeout(ctx, &t);
  487. modbus_set_response_timeout(ctx, 0, 500000);
  488. ch->reqcnt = 0;
  489. ch->failcnt = 0;
  490. appl_485_set_state(chidx, ST_485_RUN, ERR_485_NONE);
  491. }
  492. break;
  493. case ST_485_RUN:
  494. // Process Cmd
  495. if( ch->Cmd == CMD_485_RESET ){
  496. ch->Cmd = CMD_485_DONE;
  497. if (ctx != NULL){
  498. modbus_close(ctx);
  499. modbus_free(ctx);
  500. ctx = NULL;
  501. }
  502. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  503. break;
  504. }
  505. for( i = 3; i <= 3; i++ ){
  506. m = &APPL.Dtsd1352[i];
  507. if( mg_millis() - m->LastUpdate > 5000 ){
  508. m->CommState = ST_COMM_ERR;
  509. strcpy(m->szCommState,"故障");
  510. ch->Cmd = CMD_485_RESET;
  511. }else{
  512. m->CommState = ST_COMM_NORM;
  513. strcpy(m->szCommState,"正常");
  514. }
  515. // Comm with DTSD1352
  516. // PART 1
  517. appl_chan485_lock(chidx);
  518. usleep(50000);
  519. modbus_set_slave(ctx, m->Adr);
  520. start = 0x0000;
  521. nbr = 32;
  522. rc = modbus_read_registers( ctx, start, nbr, data);
  523. appl_chan485_unlock(chidx);
  524. ch->reqcnt += 1;
  525. if(rc != nbr){
  526. ch->failcnt += 1;
  527. m->CommFailTotalCnt += 1;
  528. modbus_flush(ctx);
  529. }else{
  530. m->com_active_e = ((int32_t)(data[0x0000 - start] << 16 | data[0x0001 - start])) * m->PT * m->CT * 0.01;
  531. m->pos_active_e = ((int32_t)(data[0x000A - start] << 16 | data[0x000B - start])) * m->PT * m->CT * 0.01;
  532. m->neg_active_e = ((int32_t)(data[0x0014 - start] << 16 | data[0x0015 - start])) * m->PT * m->CT * 0.01;
  533. // PART 2
  534. appl_chan485_lock(chidx);
  535. usleep(50000);
  536. start = 0x0061;
  537. nbr = 23;
  538. rc = modbus_read_registers( ctx, start, nbr, data);
  539. appl_chan485_unlock(chidx);
  540. ch->reqcnt += 1;
  541. if(rc != nbr){
  542. ch->failcnt += 1;
  543. m->CommFailTotalCnt += 1;
  544. modbus_flush(ctx);
  545. }else{
  546. m->ua = data[0x0061 - start] * m->PT * 0.1;
  547. m->ub = data[0x0062 - start] * m->PT * 0.1;
  548. m->uc = data[0x0063 - start] * m->PT * 0.1;
  549. m->ia = data[0x0064 - start] * m->CT * 0.01;
  550. m->ib = data[0x0065 - start] * m->CT * 0.01;
  551. m->ic = data[0x0066 - start] * m->CT * 0.01;
  552. m->freq = data[0x0077 - start] * 0.01;
  553. // PART 3
  554. appl_chan485_lock(chidx);
  555. usleep(50000);
  556. start = 0x0078;
  557. nbr = 32;
  558. rc = modbus_read_registers( ctx, start, nbr, data);
  559. appl_chan485_unlock(chidx);
  560. ch->reqcnt += 1;
  561. if(rc != nbr){
  562. ch->failcnt += 1;
  563. m->CommFailTotalCnt += 1;
  564. modbus_flush(ctx);
  565. }else{
  566. m->PT = data[0x008D - start];
  567. m->CT = data[0x008E - start];
  568. // PART 4
  569. appl_chan485_lock(chidx);
  570. usleep(50000);
  571. start = 0x016A;
  572. nbr = 60;
  573. rc = modbus_read_registers( ctx, start, nbr, data);
  574. appl_chan485_unlock(chidx);
  575. ch->reqcnt += 1;
  576. if(rc != nbr){
  577. ch->failcnt += 1;
  578. m->CommFailTotalCnt += 1;
  579. modbus_flush(ctx);
  580. }else{
  581. m->com_active_p = ((int32_t)(data[0x016A - start] << 16 | data[0x016B - start])) * m->PT * m->CT * 0.001;
  582. m->com_ractive_p = ((int32_t)(data[0x0172 - start] << 16 | data[0x0173 - start])) * m->PT * m->CT * 0.001;
  583. m->pwr_factor = (short)data[0x017F - start] * 0.001;
  584. m->pos_active_dem = data[0x0198 - start];
  585. m->neg_active_dem = data[0x0199 - start];
  586. m->LastUpdate = mg_millis();
  587. strcpy(m->szLastUpdate, appl_get_dtstr());
  588. }
  589. }
  590. }
  591. }
  592. }
  593. break;
  594. case ST_485_ERR:
  595. if(ch->Cmd == CMD_485_RESET){
  596. ch->Cmd = CMD_485_DONE;
  597. if (ctx != NULL){
  598. modbus_close(ctx);
  599. modbus_free(ctx);
  600. ctx = NULL;
  601. }
  602. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  603. }else{
  604. usleep(300000);
  605. }
  606. break;
  607. default:
  608. // never reach here
  609. break;
  610. }
  611. usleep(100000);
  612. ch->loopcnt += 1;
  613. ch->looptime = mg_millis() - startts;
  614. }
  615. syslog(LOG_INFO,"%s EXIT", __func__);
  616. }
  617. static void* thrd_485_4(void *param)
  618. {
  619. char buf[128];
  620. modbus_t* ctx = NULL;
  621. struct timeval t;
  622. int rc;
  623. unsigned short data[256];
  624. unsigned short start;
  625. unsigned short nbr;
  626. int chidx = 4;
  627. int i;
  628. struct chan485_t* ch = &APPL.chan485[chidx];
  629. int64_t startts;
  630. struct Dtsd1352_t* m = NULL;
  631. syslog(LOG_INFO,"%s ENTER", __func__);
  632. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  633. while(1){
  634. startts = mg_millis();
  635. switch( ch->state){
  636. case ST_485_INIT:
  637. ctx = modbus_new_rtu(ch->szdev, ch->baud, 'N', 8, 1);
  638. if (ctx == NULL){
  639. MG_INFO(("%s, modbus rtu new fail", __func__));
  640. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  641. }else if (modbus_connect(ctx) == -1){
  642. MG_INFO(("%s, modbus rtu connect fail", __func__));
  643. modbus_free(ctx);
  644. ctx = NULL;
  645. appl_485_set_state(chidx, ST_485_ERR, ERR_485_INIT_FAIL);
  646. }else{
  647. t.tv_sec = 0;
  648. t.tv_usec = 500000;
  649. //modbus_set_response_timeout(ctx, &t);
  650. modbus_set_response_timeout(ctx, 0, 500000);
  651. ch->reqcnt = 0;
  652. ch->failcnt = 0;
  653. appl_485_set_state(chidx, ST_485_RUN, ERR_485_NONE);
  654. }
  655. break;
  656. case ST_485_RUN:
  657. // Process Cmd
  658. if( ch->Cmd == CMD_485_RESET ){
  659. ch->Cmd = CMD_485_DONE;
  660. if (ctx != NULL){
  661. modbus_close(ctx);
  662. modbus_free(ctx);
  663. ctx = NULL;
  664. }
  665. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  666. break;
  667. }
  668. for( i = 4; i <= 4; i++ ){
  669. m = &APPL.Dtsd1352[i];
  670. if( mg_millis() - m->LastUpdate > 5000 ){
  671. m->CommState = ST_COMM_ERR;
  672. strcpy(m->szCommState,"故障");
  673. ch->Cmd = CMD_485_RESET;
  674. }else{
  675. m->CommState = ST_COMM_NORM;
  676. strcpy(m->szCommState,"正常");
  677. }
  678. // Comm with DTSD1352
  679. // PART 1
  680. appl_chan485_lock(chidx);
  681. usleep(50000);
  682. modbus_set_slave(ctx, m->Adr);
  683. start = 0x0000;
  684. nbr = 32;
  685. rc = modbus_read_registers( ctx, start, nbr, data);
  686. appl_chan485_unlock(chidx);
  687. ch->reqcnt += 1;
  688. if(rc != nbr){
  689. ch->failcnt += 1;
  690. m->CommFailTotalCnt += 1;
  691. modbus_flush(ctx);
  692. }else{
  693. m->com_active_e = ((int32_t)(data[0x0000 - start] << 16 | data[0x0001 - start])) * m->PT * m->CT * 0.01;
  694. m->pos_active_e = ((int32_t)(data[0x000A - start] << 16 | data[0x000B - start])) * m->PT * m->CT * 0.01;
  695. m->neg_active_e = ((int32_t)(data[0x0014 - start] << 16 | data[0x0015 - start])) * m->PT * m->CT * 0.01;
  696. // PART 2
  697. appl_chan485_lock(chidx);
  698. usleep(50000);
  699. start = 0x0061;
  700. nbr = 23;
  701. rc = modbus_read_registers( ctx, start, nbr, data);
  702. appl_chan485_unlock(chidx);
  703. ch->reqcnt += 1;
  704. if(rc != nbr){
  705. ch->failcnt += 1;
  706. m->CommFailTotalCnt += 1;
  707. modbus_flush(ctx);
  708. }else{
  709. m->ua = data[0x0061 - start] * m->PT * 0.1;
  710. m->ub = data[0x0062 - start] * m->PT * 0.1;
  711. m->uc = data[0x0063 - start] * m->PT * 0.1;
  712. m->ia = data[0x0064 - start] * m->CT * 0.01;
  713. m->ib = data[0x0065 - start] * m->CT * 0.01;
  714. m->ic = data[0x0066 - start] * m->CT * 0.01;
  715. m->freq = data[0x0077 - start] * 0.01;
  716. // PART 3
  717. appl_chan485_lock(chidx);
  718. usleep(50000);
  719. start = 0x0078;
  720. nbr = 32;
  721. rc = modbus_read_registers( ctx, start, nbr, data);
  722. appl_chan485_unlock(chidx);
  723. ch->reqcnt += 1;
  724. if(rc != nbr){
  725. ch->failcnt += 1;
  726. m->CommFailTotalCnt += 1;
  727. modbus_flush(ctx);
  728. }else{
  729. m->PT = data[0x008D - start];
  730. m->CT = data[0x008E - start];
  731. // PART 4
  732. appl_chan485_lock(chidx);
  733. usleep(50000);
  734. start = 0x016A;
  735. nbr = 60;
  736. rc = modbus_read_registers( ctx, start, nbr, data);
  737. appl_chan485_unlock(chidx);
  738. ch->reqcnt += 1;
  739. if(rc != nbr){
  740. ch->failcnt += 1;
  741. m->CommFailTotalCnt += 1;
  742. modbus_flush(ctx);
  743. }else{
  744. m->com_active_p = ((int32_t)(data[0x016A - start] << 16 | data[0x016B - start])) * m->PT * m->CT * 0.001;
  745. m->com_ractive_p = ((int32_t)(data[0x0172 - start] << 16 | data[0x0173 - start])) * m->PT * m->CT * 0.001;
  746. m->pwr_factor = (short)data[0x017F - start] * 0.001;
  747. m->pos_active_dem = data[0x0198 - start];
  748. m->neg_active_dem = data[0x0199 - start];
  749. m->LastUpdate = mg_millis();
  750. strcpy(m->szLastUpdate, appl_get_dtstr());
  751. }
  752. }
  753. }
  754. }
  755. }
  756. break;
  757. case ST_485_ERR:
  758. if(ch->Cmd == CMD_485_RESET){
  759. ch->Cmd = CMD_485_DONE;
  760. if (ctx != NULL){
  761. modbus_close(ctx);
  762. modbus_free(ctx);
  763. ctx = NULL;
  764. }
  765. appl_485_set_state(chidx, ST_485_INIT, ERR_485_NONE);
  766. }else{
  767. usleep(300000);
  768. }
  769. break;
  770. default:
  771. // never reach here
  772. break;
  773. }
  774. usleep(100000);
  775. ch->loopcnt += 1;
  776. ch->looptime = mg_millis() - startts;
  777. }
  778. syslog(LOG_INFO,"%s EXIT", __func__);
  779. }
  780. void appl_chan485_lock(int idx)
  781. {
  782. //pthread_mutex_lock(&APPL.chan485[idx].mutex);
  783. }
  784. void appl_chan485_unlock(int idx)
  785. {
  786. //pthread_mutex_unlock(&APPL.chan485[idx].mutex);
  787. }
  788. void appl_485_set_state(int idx, int s, int e)
  789. {
  790. struct chan485_t* c = &APPL.chan485[idx];
  791. c->state = s;
  792. switch( c->state){
  793. case ST_485_INIT:
  794. strcpy(c->szstate,"初始化");
  795. break;
  796. case ST_485_RUN:
  797. strcpy(c->szstate,"运行");
  798. break;
  799. case ST_485_ERR:
  800. strcpy(c->szstate,"故障");
  801. break;
  802. default:
  803. strcpy(c->szstate,"未知");
  804. break;
  805. }
  806. c->err = e;
  807. switch (e)
  808. {
  809. case ERR_485_NONE:
  810. strcpy(c->szerr,"无");
  811. break;
  812. case ERR_485_INIT_FAIL:
  813. strcpy(c->szerr,"初始化失败");
  814. break;
  815. default:
  816. strcpy(c->szerr,"未知");
  817. break;
  818. }
  819. }
  820. int appl_chan485_get_state(int idx)
  821. {
  822. return APPL.chan485[idx].state;
  823. }
  824. void appl_can_set_state(int idx, int s, int e)
  825. {
  826. struct chancan_t* c = &APPL.chancan[idx];
  827. c->State = s;
  828. switch( c->State){
  829. case ST_CAN_INIT:
  830. strcpy(c->szState,"初始化");
  831. break;
  832. case ST_CHANCAN_RUN:
  833. strcpy(c->szState,"运行");
  834. break;
  835. case ST_CHANCAN_ERR:
  836. strcpy(c->szState,"故障");
  837. break;
  838. default:
  839. strcpy(c->szState,"未知");
  840. break;
  841. }
  842. c->Err = e;
  843. switch(e){
  844. case ERR_CAN_NONE:
  845. strcpy(c->szErr,"无");
  846. break;
  847. case ERR_CAN_INIT_FAIL:
  848. strcpy(c->szErr,"初始化失败");
  849. break;
  850. default:
  851. break;
  852. }
  853. }
  854. int appl_can_get_state(int idx)
  855. {
  856. return APPL.chancan[idx].State;
  857. }
  858. void appl_485_set_485mode( void ) {
  859. int fd;
  860. struct serial_rs485 rs485conf = {0};
  861. int ret;
  862. // 1# 485
  863. fd = open("/dev/ttymxc1", O_RDWR | O_NOCTTY);
  864. if (fd <= 0) {
  865. syslog(LOG_INFO,"%s, Open ttymxc1 Fail",__func__);
  866. }else{
  867. /* get configure from device */
  868. ret = ioctl(fd, TIOCGRS485, &rs485conf);
  869. if(ret < 0) {
  870. // failed
  871. syslog(LOG_INFO,"%s, ioctl ttymxc1 Fail",__func__);
  872. }
  873. /* set enable rs485 mode in configure */
  874. /* Enable RS485 mode: */
  875. rs485conf.flags |= SER_RS485_ENABLED;
  876. /* Set logical level for RTS pin equal to 1 when sending: */
  877. rs485conf.flags |= SER_RS485_RTS_ON_SEND;
  878. /* Set logical level for RTS pin equal to 0 after sending: */
  879. rs485conf.flags &= ~SER_RS485_RTS_AFTER_SEND;
  880. /* Set this flag if you want to receive data even whilst sending data */
  881. rs485conf.flags &= ~SER_RS485_RX_DURING_TX;
  882. /* Set rts delay before send, if needed: */
  883. rs485conf.delay_rts_before_send = 0; // in miliseconds
  884. /* Set rts delay after send, if needed: */
  885. rs485conf.delay_rts_after_send = 0; // in miliseconds
  886. ret = ioctl(fd, TIOCSRS485, &rs485conf);
  887. if (ret < 0) {
  888. /* Error handling. See errno. */
  889. syslog(LOG_INFO,"%s, Set ttymxc1 485 Fail",__func__);
  890. }
  891. close(fd);
  892. }
  893. // 2# 485
  894. fd = open("/dev/ttymxc2", O_RDWR | O_NOCTTY);
  895. if (fd <= 0) {
  896. syslog(LOG_INFO,"%s, Open ttymxc2 Fail",__func__);
  897. }else{
  898. /* get configure from device */
  899. ret = ioctl(fd, TIOCGRS485, &rs485conf);
  900. if(ret < 0) {
  901. // failed
  902. syslog(LOG_INFO,"%s, ioctl ttymxc2 Fail",__func__);
  903. }
  904. /* set enable rs485 mode in configure */
  905. /* Enable RS485 mode: */
  906. rs485conf.flags |= SER_RS485_ENABLED;
  907. /* Set logical level for RTS pin equal to 1 when sending: */
  908. rs485conf.flags |= SER_RS485_RTS_ON_SEND;
  909. /* Set logical level for RTS pin equal to 0 after sending: */
  910. rs485conf.flags &= ~SER_RS485_RTS_AFTER_SEND;
  911. /* Set this flag if you want to receive data even whilst sending data */
  912. rs485conf.flags &= ~SER_RS485_RX_DURING_TX;
  913. /* Set rts delay before send, if needed: */
  914. rs485conf.delay_rts_before_send = 0; // in miliseconds
  915. /* Set rts delay after send, if needed: */
  916. rs485conf.delay_rts_after_send = 0; // in miliseconds
  917. ret = ioctl(fd, TIOCSRS485, &rs485conf);
  918. if (ret < 0) {
  919. /* Error handling. See errno. */
  920. syslog(LOG_INFO,"%s, Set ttymxc2 485 Fail",__func__);
  921. }
  922. close(fd);
  923. }
  924. // 3# 485
  925. fd = open("/dev/ttymxc3", O_RDWR | O_NOCTTY);
  926. if (fd <= 0) {
  927. syslog(LOG_INFO,"%s, Open ttymxc3 Fail",__func__);
  928. }else{
  929. /* get configure from device */
  930. ret = ioctl(fd, TIOCGRS485, &rs485conf);
  931. if(ret < 0) {
  932. // failed
  933. syslog(LOG_INFO,"%s, ioctl ttymxc3 Fail",__func__);
  934. }
  935. /* set enable rs485 mode in configure */
  936. /* Enable RS485 mode: */
  937. rs485conf.flags |= SER_RS485_ENABLED;
  938. /* Set logical level for RTS pin equal to 1 when sending: */
  939. rs485conf.flags |= SER_RS485_RTS_ON_SEND;
  940. /* Set logical level for RTS pin equal to 0 after sending: */
  941. rs485conf.flags &= ~SER_RS485_RTS_AFTER_SEND;
  942. /* Set this flag if you want to receive data even whilst sending data */
  943. rs485conf.flags &= ~SER_RS485_RX_DURING_TX;
  944. /* Set rts delay before send, if needed: */
  945. rs485conf.delay_rts_before_send = 0; // in miliseconds
  946. /* Set rts delay after send, if needed: */
  947. rs485conf.delay_rts_after_send = 0; // in miliseconds
  948. ret = ioctl(fd, TIOCSRS485, &rs485conf);
  949. if (ret < 0) {
  950. /* Error handling. See errno. */
  951. syslog(LOG_INFO,"%s, Set ttymxc3 485 Fail",__func__);
  952. }
  953. close(fd);
  954. }
  955. // 4# 485
  956. fd = open("/dev/ttymxc5", O_RDWR | O_NOCTTY);
  957. if (fd <= 0) {
  958. syslog(LOG_INFO,"%s, Open ttymxc5 Fail",__func__);
  959. }else{
  960. /* get configure from device */
  961. ret = ioctl(fd, TIOCGRS485, &rs485conf);
  962. if(ret < 0) {
  963. // failed
  964. syslog(LOG_INFO,"%s, ioctl ttymxc5 Fail",__func__);
  965. }
  966. /* set enable rs485 mode in configure */
  967. /* Enable RS485 mode: */
  968. rs485conf.flags |= SER_RS485_ENABLED;
  969. /* Set logical level for RTS pin equal to 1 when sending: */
  970. rs485conf.flags |= SER_RS485_RTS_ON_SEND;
  971. /* Set logical level for RTS pin equal to 0 after sending: */
  972. rs485conf.flags &= ~SER_RS485_RTS_AFTER_SEND;
  973. /* Set this flag if you want to receive data even whilst sending data */
  974. rs485conf.flags &= ~SER_RS485_RX_DURING_TX;
  975. /* Set rts delay before send, if needed: */
  976. rs485conf.delay_rts_before_send = 0; // in miliseconds
  977. /* Set rts delay after send, if needed: */
  978. rs485conf.delay_rts_after_send = 0; // in miliseconds
  979. ret = ioctl(fd, TIOCSRS485, &rs485conf);
  980. if (ret < 0) {
  981. /* Error handling. See errno. */
  982. syslog(LOG_INFO,"%s, Set ttymxc5 485 Fail",__func__);
  983. }
  984. close(fd);
  985. }
  986. }
  987. static void fn_mqtt1(struct mg_connection *c, int ev, void *ev_data) {
  988. // struct chanmqtt_t* m = &APPL.chanmqtt[1];
  989. // if (ev == MG_EV_OPEN) {
  990. // MG_INFO(("%lu CREATED", c->id));
  991. // // c->is_hexdumping = 1;
  992. // } else if (ev == MG_EV_CONNECT) {
  993. // if (mg_url_is_ssl(m->szs_url)) {
  994. // struct mg_tls_opts opts = {.ca = mg_unpacked("/certs/ca.pem"),
  995. // .name = mg_url_host(m->szs_url)};
  996. // mg_tls_init(c, &opts);
  997. // }
  998. // } else if (ev == MG_EV_ERROR) {
  999. // // On error, log error message
  1000. // MG_ERROR(("%lu ERROR %s", c->id, (char *) ev_data));
  1001. // } else if (ev == MG_EV_MQTT_OPEN) {
  1002. // m->bConnected = 1;
  1003. // strcpy(m->szState,"正常");
  1004. // // MQTT connect is successful
  1005. // struct mg_str subt = mg_str(m->szs_sub_topic);
  1006. // MG_INFO(("%lu CONNECTED to %s", c->id, m->szs_url));
  1007. // struct mg_mqtt_opts sub_opts;
  1008. // memset(&sub_opts, 0, sizeof(sub_opts));
  1009. // sub_opts.topic = subt;
  1010. // sub_opts.qos = m->s_qos;
  1011. // mg_mqtt_sub(c, &sub_opts);
  1012. // MG_INFO(("%lu SUBSCRIBED to %.*s", c->id, (int) subt.len, subt.ptr));
  1013. // } else if (ev == MG_EV_MQTT_MSG) {
  1014. // // When we get echo response, print it
  1015. // struct mg_mqtt_message *mm = (struct mg_mqtt_message *) ev_data;
  1016. // MG_INFO(("%lu RECEIVED %.*s <- %.*s", c->id, (int) mm->data.len,
  1017. // mm->data.ptr, (int) mm->topic.len, mm->topic.ptr));
  1018. // } else if (ev == MG_EV_CLOSE) {
  1019. // MG_INFO(("%lu CLOSED", c->id));
  1020. // m->s_conn = NULL; // Mark that we're closed
  1021. // m->bConnected = 0;
  1022. // strcpy(m->szState,"故障");
  1023. // }
  1024. }
  1025. static void fn_mqtt2(struct mg_connection *c, int ev, void *ev_data) {
  1026. struct chanmqtt_t* m = &APPL.chanmqtt[2];
  1027. if (ev == MG_EV_OPEN) {
  1028. syslog(LOG_INFO,"%lu CREATED", c->id);
  1029. // c->is_hexdumping = 1;
  1030. } else if (ev == MG_EV_CONNECT) {
  1031. if (mg_url_is_ssl(m->szs_url)) {
  1032. struct mg_tls_opts opts = {.ca = mg_unpacked("/certs/ca.pem"),
  1033. .name = mg_url_host(m->szs_url)};
  1034. mg_tls_init(c, &opts);
  1035. }
  1036. } else if (ev == MG_EV_ERROR) {
  1037. // On error, log error message
  1038. syslog(LOG_INFO,"%lu ERROR %s", c->id, (char *) ev_data);
  1039. } else if (ev == MG_EV_MQTT_OPEN) {
  1040. m->bConnected = 1;
  1041. strcpy(m->szState,"正常");
  1042. m->TotalReconn++;
  1043. // MQTT connect is successful
  1044. struct mg_str subt = mg_str(m->szs_sub_topic);
  1045. syslog(LOG_INFO,"%lu CONNECTED to %s", c->id, m->szs_url);
  1046. struct mg_mqtt_opts sub_opts;
  1047. memset(&sub_opts, 0, sizeof(sub_opts));
  1048. sub_opts.topic = subt;
  1049. sub_opts.qos = m->s_qos;
  1050. mg_mqtt_sub(c, &sub_opts);
  1051. syslog(LOG_INFO,"%lu SUBSCRIBED to %.*s", c->id, (int) subt.len, subt.ptr);
  1052. } else if (ev == MG_EV_MQTT_MSG) {
  1053. // When we get echo response, print it
  1054. struct mg_mqtt_message *mm = (struct mg_mqtt_message *) ev_data;
  1055. syslog(LOG_INFO,"%lu RECEIVED %.*s <- %.*s", c->id, (int) mm->data.len,
  1056. mm->data.ptr, (int) mm->topic.len, mm->topic.ptr);
  1057. m->TotalRecv++;
  1058. } else if (ev == MG_EV_CLOSE) {
  1059. syslog(LOG_INFO,"%lu CLOSED", c->id);
  1060. m->s_conn = NULL; // Mark that we're closed
  1061. m->bConnected = 0;
  1062. strcpy(m->szState,"故障");
  1063. }
  1064. }
  1065. static void fn_mqtt3(struct mg_connection *c, int ev, void *ev_data) {
  1066. struct chanmqtt_t* m = &APPL.chanmqtt[3];
  1067. char buf[256];
  1068. if (ev == MG_EV_OPEN) {
  1069. syslog(LOG_INFO,"%s, %lu CREATED", __func__, c->id);
  1070. // c->is_hexdumping = 1;
  1071. } else if (ev == MG_EV_CONNECT) {
  1072. if (mg_url_is_ssl(m->szs_url)) {
  1073. struct mg_tls_opts opts = {.ca = mg_unpacked("/certs/ca.pem"),
  1074. .name = mg_url_host(m->szs_url)};
  1075. mg_tls_init(c, &opts);
  1076. }
  1077. } else if (ev == MG_EV_ERROR) {
  1078. // On error, log error message
  1079. syslog(LOG_INFO, "%s, %lu ERROR %s", __func__, c->id, (char *) ev_data);
  1080. } else if (ev == MG_EV_MQTT_OPEN) {
  1081. m->bConnected = 1;
  1082. strcpy(m->szState,"正常");
  1083. // MQTT connect is successful
  1084. syslog(LOG_INFO,"%s, %lu CONNECTED to %s", __func__, c->id, m->szs_url);
  1085. struct mg_str subt = mg_str(m->szs_sub_topic[0]);
  1086. struct mg_mqtt_opts sub_opts;
  1087. memset(&sub_opts, 0, sizeof(sub_opts));
  1088. sub_opts.topic = subt;
  1089. sub_opts.qos = m->s_qos;
  1090. mg_mqtt_sub(c, &sub_opts);
  1091. syslog(LOG_INFO,"%s, %lu SUBSCRIBED to %.*s", __func__, c->id, (int) subt.len, subt.ptr);
  1092. // subt = mg_str(m->szs_sub_topic[1]);
  1093. // memset(&sub_opts, 0, sizeof(sub_opts));
  1094. // sub_opts.topic = subt;
  1095. // sub_opts.qos = m->s_qos;
  1096. // mg_mqtt_sub(c, &sub_opts);
  1097. // syslog(LOG_INFO,"%s, %lu SUBSCRIBED to %.*s", __func__, c->id, (int) subt.len, subt.ptr);
  1098. } else if (ev == MG_EV_MQTT_MSG) {
  1099. // When we get echo response, print it
  1100. struct mg_mqtt_message *mm = (struct mg_mqtt_message *) ev_data;
  1101. //syslog(LOG_INFO,"%s, %lu RECEIVED %.*s <- %.*s", __func__, c->id, (int) mm->data.len,
  1102. // mm->data.ptr, (int) mm->topic.len, mm->topic.ptr);
  1103. struct mg_str json = mg_str(mm->data.ptr);
  1104. double dval;
  1105. bool ok;
  1106. if( strcmp(mm->topic.ptr, m->szs_sub_topic[0]) == 0){ // gate meter
  1107. syslog(LOG_INFO,"%s, Get Gate Meter Data", __func__);
  1108. ok = mg_json_get_num(json,"$.m1_com_ap", &dval);
  1109. if( ok ){
  1110. // gm->com_active_p = dval;
  1111. // gm->LastUpdate = mg_millis();
  1112. // strcpy(gm->szLastUpdate, appl_get_datetime_long());
  1113. }
  1114. ok = mg_json_get_num(json,"$.m2_com_ap", &dval);
  1115. if( ok ){
  1116. // tm->com_active_p = dval;
  1117. // tm->LastUpdate = mg_millis();
  1118. // strcpy(tm->szLastUpdate, appl_get_datetime_long());
  1119. }
  1120. }
  1121. } else if (ev == MG_EV_CLOSE) {
  1122. syslog(LOG_INFO,"%s, %lu CLOSED", __func__, c->id);
  1123. m->s_conn = NULL; // Mark that we're closed
  1124. m->bConnected = 0;
  1125. strcpy(m->szState,"故障");
  1126. }
  1127. }
  1128. static void* thrd_mqtt_1(void* param){
  1129. // struct chanmqtt_t* m = &APPL.chanmqtt[1];
  1130. // struct Dtsd1352_t* meter = NULL;
  1131. // struct mg_mqtt_opts opts = {.user = mg_str(m->szusrname),
  1132. // .clean = true,
  1133. // .qos = m->s_qos,
  1134. // .topic = mg_str(m->szs_pub_topic),
  1135. // .version = 4,
  1136. // .message = mg_str("bye")};
  1137. // struct mg_mqtt_opts pub_opts;
  1138. // struct mg_str pubt = mg_str(m->szs_pub_topic);
  1139. // char msg[2048];
  1140. // char buf[2048];
  1141. // int i;
  1142. // mg_mgr_init(&mgr_mqtt1);
  1143. // MG_INFO(("%s ENTER, idx:1", __func__));
  1144. // if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt1, m->szs_url, &opts, fn_mqtt1, NULL);
  1145. // while(1){
  1146. // mg_mgr_poll(&mgr_mqtt1, 50);
  1147. // if(mg_millis() - m->LastUpload > 5000){
  1148. // m->LastUpload = mg_millis();
  1149. // if(m->bConnected){
  1150. // for(i = 1; i <= 2; i++){
  1151. // meter = &APPL.Dtsd1352[i];
  1152. // if( meter->CommState == ST_COMM_NORM ){
  1153. // memset(&pub_opts, 0, sizeof(pub_opts));
  1154. // pub_opts.topic = pubt;
  1155. // sprintf(buf,
  1156. // "\"m%d_pf\":%.3f,\
  1157. // \"m%d_com_ap\":%.1f,\"m%d_com_ae\":%.1f,\"m%d_pos_ae\":%.1f,\"m%d_neg_ae\":%.1f, \
  1158. // \"m%d_ua\":%.1f,\"m%d_ub\":%.1f,\"m%d_uc\":%.1f, \
  1159. // \"m%d_ia\":%.1f,\"m%d_ib\":%.1f,\"m%d_ic\":%.1f",
  1160. // i, meter->pwr_factor,
  1161. // i, meter->com_active_p,i, meter->com_active_e,i, meter->pos_active_e,i, meter->neg_active_e,
  1162. // i, meter->ua,i, meter->ub,i, meter->uc,
  1163. // i, meter->ia,i, meter->ib,i, meter->ic);
  1164. // sprintf(msg,"{'ts':%lld,'values':{%s}}", (long long)time(NULL)*1000, buf);
  1165. // pub_opts.message = mg_str(msg);
  1166. // pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1167. // mg_mqtt_pub(m->s_conn, &pub_opts);
  1168. // }
  1169. // }
  1170. // }
  1171. // if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt1, m->szs_url, &opts, fn_mqtt1, NULL);
  1172. // }
  1173. // }
  1174. // MG_INFO(("%s EXIT, idx:1", __func__));
  1175. }
  1176. static void* thrd_mqtt_2(void* param){
  1177. int i;
  1178. struct Dtsd1352_t* me = NULL;
  1179. struct chanmqtt_t* m = &APPL.chanmqtt[2];
  1180. struct Settings_t* set = &APPL.Set.s;
  1181. struct mg_mqtt_opts opts = {.user = mg_str(m->szusrname),
  1182. .pass = mg_str(m->szpasswd),
  1183. .client_id = mg_str(m->szclientid),
  1184. .clean = true,
  1185. .qos = m->s_qos,
  1186. .topic = mg_str(m->szs_pub_topic),
  1187. .version = 4,
  1188. .message = mg_str("bye")};
  1189. struct mg_mqtt_opts pub_opts;
  1190. struct mg_str pubt = mg_str(m->szs_pub_topic);
  1191. char msg[2048];
  1192. char buf[2048];
  1193. mg_mgr_init(&mgr_mqtt2);
  1194. syslog(LOG_INFO,"%s ENTER idx:2", __func__);
  1195. if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt2, m->szs_url, &opts, fn_mqtt2, NULL);
  1196. while(1){
  1197. mg_mgr_poll(&mgr_mqtt2, 50);
  1198. // Process Cmd
  1199. if( m->Cmd == CMD_MQTT_REGISTER ){
  1200. m->Cmd = CMD_MQTT_DONE;
  1201. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":12,\"idx\":1}]}",
  1202. set->szCloudUserName, (long long)time(NULL)*1000, "CtnMeter");
  1203. pub_opts.message = mg_str(msg);
  1204. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1205. pub_opts.topic = mg_str("register");
  1206. mg_mqtt_pub(m->s_conn, &pub_opts);
  1207. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":15,\"idx\":1}]}",
  1208. set->szCloudUserName, (long long)time(NULL)*1000, "PvMeter");
  1209. pub_opts.message = mg_str(msg);
  1210. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1211. pub_opts.topic = mg_str("register");
  1212. mg_mqtt_pub(m->s_conn, &pub_opts);
  1213. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":16,\"idx\":1}]}",
  1214. set->szCloudUserName, (long long)time(NULL)*1000, "TransMeter");
  1215. pub_opts.message = mg_str(msg);
  1216. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1217. pub_opts.topic = mg_str("register");
  1218. mg_mqtt_pub(m->s_conn, &pub_opts);
  1219. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":17,\"idx\":1}]}",
  1220. set->szCloudUserName, (long long)time(NULL)*1000, "GateMeter");
  1221. pub_opts.message = mg_str(msg);
  1222. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1223. pub_opts.topic = mg_str("register");
  1224. mg_mqtt_pub(m->s_conn, &pub_opts);
  1225. }
  1226. if(mg_millis() - m->LastUpload > set->UploadIntv){
  1227. m->LastUpload = mg_millis();
  1228. if(m->bConnected){
  1229. //*******************************
  1230. // CtnMeter
  1231. //*******************************
  1232. me = &APPL.Dtsd1352[1];
  1233. if(me->CommState == ST_COMM_NORM){
  1234. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":12,\"idx\":1,\
  1235. \"pos_ae\":%.1f,\"neg_ae\":%.1f,\"com_ap\":%.1f,\"com_rap\":%.1f,\
  1236. \"ua\":%.1f,\"ub\":%.1f,\"uc\":%.1f,\"ia\":%.1f,\"ib\":%.1f,\"ic\":%.1f,\
  1237. \"gf\":%.1f,\"pf\":%.1f,\"pos_adem\":%.1f}]}",
  1238. set->szCloudUserName, (long long)time(NULL)*1000, "CtnMeter",
  1239. me->pos_active_e,me->neg_active_e,me->com_active_p,me->com_ractive_p,
  1240. me->ua, me->ub, me->uc, me->ia, me->ib, me->ic,
  1241. me->freq, me->pwr_factor, me->pos_active_dem);
  1242. pub_opts.message = mg_str(msg);
  1243. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1244. pub_opts.topic = mg_str(m->szs_pub_topic[0]);
  1245. mg_mqtt_pub(m->s_conn, &pub_opts);
  1246. m->TotalSend++;
  1247. }
  1248. //*******************************
  1249. // PvMeter
  1250. //*******************************
  1251. me = &APPL.Dtsd1352[2];
  1252. if(me->CommState == ST_COMM_NORM){
  1253. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":15,\"idx\":1,\
  1254. \"pos_ae\":%.1f,\"neg_ae\":%.1f,\"com_ap\":%.1f,\"com_rap\":%.1f,\
  1255. \"ua\":%.1f,\"ub\":%.1f,\"uc\":%.1f,\"ia\":%.1f,\"ib\":%.1f,\"ic\":%.1f,\
  1256. \"gf\":%.1f,\"pf\":%.1f,\"pos_adem\":%.1f}]}",
  1257. set->szCloudUserName, (long long)time(NULL)*1000, "PvMeter",
  1258. me->pos_active_e,me->neg_active_e,me->com_active_p,me->com_ractive_p,
  1259. me->ua, me->ub, me->uc, me->ia, me->ib, me->ic,
  1260. me->freq, me->pwr_factor, me->pos_active_dem);
  1261. pub_opts.message = mg_str(msg);
  1262. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1263. pub_opts.topic = mg_str(m->szs_pub_topic[1]);
  1264. mg_mqtt_pub(m->s_conn, &pub_opts);
  1265. m->TotalSend++;
  1266. }
  1267. //*******************************
  1268. // TransMeter
  1269. //*******************************
  1270. me = &APPL.Dtsd1352[3];
  1271. if(me->CommState == ST_COMM_NORM){
  1272. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":16,\"idx\":1,\
  1273. \"pos_ae\":%.1f,\"neg_ae\":%.1f,\"com_ap\":%.1f,\"com_rap\":%.1f,\
  1274. \"ua\":%.1f,\"ub\":%.1f,\"uc\":%.1f,\"ia\":%.1f,\"ib\":%.1f,\"ic\":%.1f,\
  1275. \"gf\":%.1f,\"pf\":%.1f,\"pos_adem\":%.1f}]}",
  1276. set->szCloudUserName, (long long)time(NULL)*1000, "TransMeter",
  1277. me->pos_active_e,me->neg_active_e,me->com_active_p,me->com_ractive_p,
  1278. me->ua, me->ub, me->uc, me->ia, me->ib, me->ic,
  1279. me->freq, me->pwr_factor, me->pos_active_dem);
  1280. pub_opts.message = mg_str(msg);
  1281. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1282. pub_opts.topic = mg_str(m->szs_pub_topic[2]);
  1283. mg_mqtt_pub(m->s_conn, &pub_opts);
  1284. m->TotalSend++;
  1285. }
  1286. //*******************************
  1287. // GateMeter
  1288. //*******************************
  1289. me = &APPL.Dtsd1352[4];
  1290. if(me->CommState == ST_COMM_NORM){
  1291. sprintf(msg, "{\"project_id\":\"%s\",\"timestamp\":%lld,\"data\":[{\"device_id\":\"%s\",\"type\":17,\"idx\":1,\
  1292. \"pos_ae\":%.1f,\"neg_ae\":%.1f,\"com_ap\":%.1f,\"com_rap\":%.1f,\
  1293. \"ua\":%.1f,\"ub\":%.1f,\"uc\":%.1f,\"ia\":%.1f,\"ib\":%.1f,\"ic\":%.1f,\
  1294. \"gf\":%.1f,\"pf\":%.1f,\"pos_adem\":%.1f}]}",
  1295. set->szCloudUserName, (long long)time(NULL)*1000, "GateMeter",
  1296. me->pos_active_e,me->neg_active_e,me->com_active_p,me->com_ractive_p,
  1297. me->ua, me->ub, me->uc, me->ia, me->ib, me->ic,
  1298. me->freq, me->pwr_factor, me->pos_active_dem);
  1299. pub_opts.message = mg_str(msg);
  1300. pub_opts.qos = m->s_qos, pub_opts.retain = false;
  1301. pub_opts.topic = mg_str(m->szs_pub_topic[3]);
  1302. mg_mqtt_pub(m->s_conn, &pub_opts);
  1303. m->TotalSend++;
  1304. }
  1305. }
  1306. }
  1307. if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt2, m->szs_url, &opts, fn_mqtt2, NULL);
  1308. }
  1309. syslog(LOG_INFO, "%s EXIT, idx:2", __func__);
  1310. }
  1311. // Get data from mosquitto server
  1312. static void* thrd_mqtt_3(void* param){
  1313. struct chanmqtt_t* m = &APPL.chanmqtt[3];
  1314. struct mg_mqtt_opts opts = {.user = mg_str(m->szusrname),
  1315. .clean = true,
  1316. .qos = m->s_qos,
  1317. .topic = mg_str(m->szs_pub_topic),
  1318. .version = 4,
  1319. .keepalive = 3,
  1320. .message = mg_str("bye")};
  1321. struct mg_mqtt_opts pub_opts;
  1322. struct mg_str pubt = mg_str(m->szs_pub_topic);
  1323. char msg[2048];
  1324. int64_t LastReconn = 0;
  1325. int64_t LastCommCheck = 0;
  1326. mg_mgr_init(&mgr_mqtt3);
  1327. syslog(LOG_INFO,"%s ENTER, idx:3", __func__);
  1328. if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt3, m->szs_url, &opts, fn_mqtt3, NULL);
  1329. while(1){
  1330. mg_mgr_poll(&mgr_mqtt3, 50);
  1331. if(mg_millis() - LastReconn > 5000){ // 5s
  1332. LastReconn = mg_millis();
  1333. if (m->s_conn == NULL) m->s_conn = mg_mqtt_connect(&mgr_mqtt1, m->szs_url, &opts, fn_mqtt3, NULL);
  1334. }
  1335. if(mg_millis() - LastCommCheck > 1000){ // 1s
  1336. LastCommCheck = mg_millis();
  1337. }
  1338. }
  1339. syslog(LOG_INFO,"%s EXIT, idx:1", __func__);
  1340. }
  1341. static int mqtt4_connlost = 0;
  1342. static void fn_mqtt4_connlost(void *context, char *cause)
  1343. {
  1344. syslog(LOG_INFO, "%s, mqtt connection lost, cause: %s\n", __func__, cause);
  1345. mqtt4_connlost = 1;
  1346. }
  1347. static int fn_mqtt4_msgarrvd(void *context, char *topicName, int topicLen, MQTTClient_message *message)
  1348. {
  1349. struct chanmqtt_t* mq = &APPL.chanmqtt[4];
  1350. int64_t CurrIntv;
  1351. //syslog(LOG_INFO,"%s, Message arrived, topic:%s topic len:%d payload len:%d", __func__, topicName,topicLen, message->payloadlen);
  1352. struct mg_str json = mg_str(message->payload);
  1353. double dval;
  1354. bool ok;
  1355. if( strcmp(topicName, mq->szs_sub_topic[0]) == 0){
  1356. if(mq->LastRecv == 0){ // First Recv
  1357. mq->TotalRecv = 0;
  1358. mq->LastRecv = mg_millis();
  1359. mq->TotalIntv = 0;
  1360. }else{
  1361. mq->TotalRecv++;
  1362. CurrIntv = mg_millis() - mq->LastRecv;
  1363. mq->LastRecv = mg_millis();
  1364. if(CurrIntv > mq->MaxIntv){
  1365. mq->MaxIntv = CurrIntv;
  1366. }
  1367. mq->TotalIntv += CurrIntv;
  1368. mq->AvgIntv = mq->TotalIntv/mq->TotalRecv;
  1369. }
  1370. ok = mg_json_get_num(json,"$.m1_com_ap", &dval);
  1371. if( ok ){
  1372. // cm->com_active_p = dval;
  1373. // cm->LastUpdate = mg_millis();
  1374. // strcpy(cm->szLastUpdate, appl_get_datetime_long());
  1375. //syslog(LOG_INFO,"%s, Get Gate M1 Data", __func__);
  1376. }
  1377. ok = mg_json_get_num(json,"$.m2_com_ap", &dval);
  1378. if( ok ){
  1379. // pm->com_active_p = dval;
  1380. // pm->LastUpdate = mg_millis();
  1381. // strcpy(pm->szLastUpdate, appl_get_datetime_long());
  1382. //syslog(LOG_INFO,"%s, Get Gate M2 Data", __func__);
  1383. }
  1384. ok = mg_json_get_num(json,"$.m3_com_ap", &dval);
  1385. if( ok ){
  1386. // tm->com_active_p = dval;
  1387. // tm->LastUpdate = mg_millis();
  1388. // strcpy(tm->szLastUpdate, appl_get_datetime_long());
  1389. //syslog(LOG_INFO,"%s, Get Gate M2 Data", __func__);
  1390. }
  1391. ok = mg_json_get_num(json,"$.m4_com_ap", &dval);
  1392. if( ok ){
  1393. //gm->com_active_p = dval;
  1394. //gm->LastUpdate = mg_millis();
  1395. //strcpy(gm->szLastUpdate, appl_get_datetime_long());
  1396. //syslog(LOG_INFO,"%s, Get Gate M2 Data", __func__);
  1397. }
  1398. }
  1399. }
  1400. static void mqtt4_connect( void ){
  1401. int rc;
  1402. struct chanmqtt_t* m = &APPL.chanmqtt[4];
  1403. MQTTClient_deliveryToken token;
  1404. MQTTClient_connectOptions conn_opts;
  1405. MQTTClient cli;
  1406. MQTTClient_connectOptions tmpconn_opts = MQTTClient_connectOptions_initializer5;
  1407. conn_opts = tmpconn_opts;
  1408. MQTTClient_createOptions createOpts = MQTTClient_createOptions_initializer;
  1409. createOpts.MQTTVersion = MQTTVERSION_5;
  1410. if ((rc = MQTTClient_createWithOptions(&cli, m->szs_url, m->szclientid, MQTTCLIENT_PERSISTENCE_NONE, NULL, &createOpts)) != MQTTCLIENT_SUCCESS){
  1411. syslog(LOG_INFO,"%s, MQTTClient_createWithOptions fail, rc:%d msg:%s %s %s", __func__, rc, MQTTClient_strerror(rc));
  1412. }
  1413. conn_opts.keepAliveInterval = 8;
  1414. conn_opts.cleansession = 0;
  1415. conn_opts.username = m->szusrname;
  1416. conn_opts.password = m->szpasswd;
  1417. MQTTProperties props = MQTTProperties_initializer;
  1418. MQTTProperties willProps = MQTTProperties_initializer;
  1419. MQTTResponse response = MQTTResponse_initializer;
  1420. MQTTClient_setCallbacks(cli, NULL, fn_mqtt4_connlost, fn_mqtt4_msgarrvd, NULL);
  1421. response = MQTTClient_connect5(cli, &conn_opts, &props, &willProps);
  1422. if (response.reasonCode != MQTTCLIENT_SUCCESS){
  1423. syslog(LOG_INFO,"%s, MQTTClient_connect fail, rc:%d msg:%s", __func__, response.reasonCode, MQTTClient_strerror(response.reasonCode));
  1424. mqtt4_connlost = 1;
  1425. }else{
  1426. syslog(LOG_INFO,"%s, Connect Ok",__func__);
  1427. mqtt4_connlost = 0;
  1428. response = MQTTClient_subscribe5(cli, m->szs_sub_topic[0], m->s_qos, NULL, NULL);
  1429. if (response.reasonCode != MQTTCLIENT_SUCCESS && response.reasonCode != m->s_qos){
  1430. syslog(LOG_INFO,"%s, MQTTClient_subscribe fail, rc: %d msg: %s", __func__, response.reasonCode, MQTTClient_strerror(response.reasonCode));
  1431. }
  1432. }
  1433. MQTTResponse_free(response);
  1434. }
  1435. static void* thrd_mqtt4(void* param){
  1436. int ReconnChk = 0;
  1437. syslog(LOG_INFO,"%s, ++",__func__);
  1438. mqtt4_connect();
  1439. while(1){
  1440. if(++ReconnChk > 10){
  1441. ReconnChk = 0;
  1442. if(mqtt4_connlost == 1){
  1443. mqtt4_connect();
  1444. }
  1445. }
  1446. sleep(1);
  1447. }
  1448. syslog(LOG_INFO,"%s, --",__func__);
  1449. }
  1450. void appl_snap_set_err( void )
  1451. {
  1452. APPL.Snap.bErr = 1;
  1453. strcpy(APPL.Snap.szState,"故障");
  1454. }
  1455. void appl_snap_reset_err( void )
  1456. {
  1457. APPL.Snap.bErr = 0;
  1458. strcpy(APPL.Snap.szState,"正常");
  1459. }
  1460. static int appl_snap_day_diff(int year_start, int month_start, int day_start, int year_end, int month_end, int day_end){
  1461. int y2, m2, d2;
  1462. int y1, m1, d1;
  1463. m1 = (month_start + 9) % 12;
  1464. y1 = year_start - m1 / 10;
  1465. d1 = 365 * y1 + y1 / 4 - y1 / 100 + y1 / 400 + (m1 * 306 + 5) / 10 + (day_start - 1);
  1466. m2 = (month_end + 9) % 12;
  1467. y2 = year_end - m2 / 10;
  1468. d2 = 365 * y2 + y2 / 4 - y2 / 100 + y2 / 400 + (m2 * 306 + 5) / 10 + (day_end - 1);
  1469. return (d2 - d1);
  1470. }
  1471. int appl_snap_rmdir(const char *path) {
  1472. DIR *d = opendir(path);
  1473. size_t path_len = strlen(path);
  1474. int r = -1;
  1475. if (d) {
  1476. struct dirent *p;
  1477. r = 0;
  1478. while (!r && (p=readdir(d))) {
  1479. int r2 = -1;
  1480. char *buf;
  1481. size_t len;
  1482. /* Skip the names "." and ".." as we don't want to recurse on them. */
  1483. if (!strcmp(p->d_name, ".") || !strcmp(p->d_name, ".."))
  1484. continue;
  1485. len = path_len + strlen(p->d_name) + 2;
  1486. buf = malloc(len);
  1487. if (buf) {
  1488. struct stat statbuf;
  1489. snprintf(buf, len, "%s/%s", path, p->d_name);
  1490. if (!stat(buf, &statbuf)) {
  1491. if (S_ISDIR(statbuf.st_mode))
  1492. r2 = appl_snap_rmdir(buf);
  1493. else
  1494. r2 = unlink(buf);
  1495. }
  1496. free(buf);
  1497. }
  1498. r = r2;
  1499. }
  1500. closedir(d);
  1501. }
  1502. if (!r)
  1503. r = rmdir(path);
  1504. return r;
  1505. }
  1506. static void* thrd_snap(void* param){
  1507. struct Snap_t* s = &APPL.Snap;
  1508. struct Dtsd1352_t* me = NULL;
  1509. char buf[128];
  1510. char szfn[128];
  1511. int y, m, d, h, min, ss; // current
  1512. int yy, mm, dd;//dir
  1513. int diff_day;
  1514. int rc;
  1515. DIR* dir;
  1516. struct dirent *ptr;
  1517. char szyy[8];
  1518. char szmm[8];
  1519. char szdd[8];
  1520. int i;
  1521. sleep(5);
  1522. syslog(LOG_INFO, "%s, ++",__func__);
  1523. while(1){
  1524. usleep(300000);
  1525. if(s->bErr){
  1526. continue;
  1527. }
  1528. if (s->bStart == 0){
  1529. appl_get_datetime_num(&y, &m, &d, &h, &min, &ss);
  1530. sprintf(s->szcurrDatePath, "./snap/%04d-%02d-%02d", y, m, d);
  1531. if( access(s->szcurrDatePath, NULL) !=0 ){ // directory does not exists
  1532. //syslog(LOG_INFO,"%s, DatePath:%s does not exist",__func__, s->szcurrDatePath);
  1533. if(mkdir(s->szcurrDatePath, 0755) < 0){
  1534. s->bErr = 1;
  1535. //syslog(LOG_INFO,"%s, mkdir fail",__func__);
  1536. continue;
  1537. }
  1538. }
  1539. // Meter Snap Start
  1540. for( i = 1; i <= 4; i++ ){
  1541. sprintf(szfn, "%s/M%d_%04d-%02d-%02d %02d-%02d-%02d.csv",s->szcurrDatePath, i, y, m, d, h, min, ss);
  1542. s->f[i] = fopen(szfn, "w+");
  1543. if (s->f[i] == NULL){
  1544. s->bErr = 1;
  1545. continue;
  1546. }else{
  1547. rc = fprintf(s->f[i],"ts,com_ap,pos_adem,neg_adem,com_ae,pos_ae,neg_ae,pf,pt,ct,ua,ub,uc,ia,ib,ic,freq,CommState\n");
  1548. if(rc < 0){
  1549. s->bErr = 1;
  1550. continue;
  1551. }
  1552. }
  1553. }
  1554. s->LastSnap = 0;
  1555. s->bStart = 1;
  1556. }else{
  1557. if (mg_millis() - s->LastSnap > 5000){ /* snap every 5 seconds */
  1558. s->LastSnap = mg_millis();
  1559. appl_get_datetime_num(&y, &m, &d, &h, &min, &ss);
  1560. sprintf(buf, "./snap/%04d-%02d-%02d", y, m, d);
  1561. if (strcmp(buf, s->szcurrDatePath) != 0){ /* new date */
  1562. //syslog(LOG_INFO,"%s, New Date Detected : %s", __func__, buf);
  1563. if(s->fpcs != NULL){
  1564. fclose(s->fpcs);
  1565. s->fpcs = NULL;
  1566. }
  1567. // del outofdate dir
  1568. if ((dir = opendir("./snap")) == NULL){
  1569. s->bErr = 1;
  1570. continue;
  1571. }else{
  1572. while ((ptr = readdir(dir)) != NULL){
  1573. if (strcmp(ptr->d_name, ".") == 0 || strcmp(ptr->d_name, "..") == 0){ /// current dir OR parrent dir
  1574. continue;
  1575. }else if (ptr->d_type == 8){ /// file
  1576. }
  1577. else if (ptr->d_type == 10){ /// link file
  1578. // printf("d_name:%s/%s\n",basePath,ptr->d_name);
  1579. }else if (ptr->d_type == 4){ /// dir
  1580. if(strlen(ptr->d_name) == 10 && ptr->d_name[4] == '-' && ptr->d_name[7] == '-'){ // target dir
  1581. //syslog(LOG_INFO,"%s, Target Dir:%s Detedted", __func__, ptr->d_name);
  1582. strncpy(szyy, ptr->d_name, 4);
  1583. strncpy(szmm, ptr->d_name + 5, 2);
  1584. strncpy(szdd, ptr->d_name + 8, 2);
  1585. yy = atoi(szyy);
  1586. mm = atoi(szmm);
  1587. dd = atoi(szdd);
  1588. diff_day = appl_snap_day_diff(yy, mm, dd, y, m, d);
  1589. if (diff_day > s->KeepDay){
  1590. sprintf(buf, "./snap/%s",ptr->d_name);
  1591. rc = appl_snap_rmdir(buf);
  1592. if( rc < 0 ){
  1593. syslog(LOG_INFO,"%s, Target Dir:%s Del Fail", __func__, ptr->d_name);
  1594. s->bErr = 1;
  1595. continue;
  1596. }else{
  1597. syslog(LOG_INFO,"%s, Target Dir:%s Del Ok", __func__, ptr->d_name);
  1598. }
  1599. }
  1600. }
  1601. }
  1602. }
  1603. closedir(dir);
  1604. }
  1605. s->bStart = 0; /* start again at next loop */
  1606. continue;
  1607. }else{
  1608. s->LastSnap = mg_millis();
  1609. strcpy(buf, appl_get_datetime_short());
  1610. // Meter Snap
  1611. for( i = 1; i <= 4; i++){
  1612. me = &APPL.Dtsd1352[i];
  1613. if(s->f[i] != NULL && me->CommState == ST_COMM_NORM){
  1614. fprintf(s->f[i],"\
  1615. %s,%.1f,%.1f,%.1f,\
  1616. %.1f,%.1f,%.1f,\
  1617. %.3f,%d,%d,\
  1618. %.1f,%.1f,%.1f,\
  1619. %.1f,%.1f,%.1f,\
  1620. %.1f,%.d\n",
  1621. /*1*/buf, me->com_active_p,me->pos_active_dem,me->neg_active_dem,
  1622. /*2*/me->com_active_e,me->pos_active_e,me->neg_active_e,
  1623. /*3*/me->pwr_factor, me->PT, me->CT,
  1624. /*4*/me->ua, me->ub, me->uc,
  1625. /*5*/me->ia, me->ib, me->ic,
  1626. /*6*/me->freq, me->CommState);
  1627. fflush(s->f[i]);
  1628. }
  1629. }
  1630. }
  1631. }
  1632. }
  1633. }
  1634. syslog(LOG_INFO, "%s, --",__func__);
  1635. }
  1636. void appl_start( void )
  1637. {
  1638. struct Settings_t* set = &APPL.Set.s;
  1639. struct chan485_t* ch = NULL;
  1640. struct chanmqtt_t* m = NULL;
  1641. struct Snap_t* snap = &APPL.Snap;
  1642. char buf[128];
  1643. char buf2[128];
  1644. int len;
  1645. int i;
  1646. pthread_t hthrd_485_1;
  1647. pthread_t hthrd_485_2;
  1648. pthread_t hthrd_485_3;
  1649. pthread_t hthrd_485_4;
  1650. pthread_t hthrd_can_1;
  1651. pthread_t hthrd_can_2;
  1652. pthread_t hthrd_dido;
  1653. pthread_t hthrd_ctl;
  1654. pthread_t hthrd_mqtt1;
  1655. pthread_t hthrd_mqtt2;
  1656. pthread_t hthrd_mqtt3;
  1657. pthread_t hthrd_mqtt4;
  1658. pthread_t hthrd_snap;
  1659. APPL.Dtsd1352[1].Adr = 1;
  1660. APPL.Dtsd1352[2].Adr = 3;
  1661. APPL.Dtsd1352[3].Adr = 2;
  1662. APPL.Dtsd1352[4].Adr = 4;
  1663. appl_485_set_485mode();
  1664. // CHAN 485 1
  1665. ch = &APPL.chan485[1];
  1666. strcpy(ch->szdev, "/dev/ttymxc1");
  1667. ch->baud = 9600;
  1668. ch->parity = 'N';
  1669. strcpy(ch->szinfo, "储能柜电表");
  1670. // CHAN 485 2
  1671. ch = &APPL.chan485[2];
  1672. strcpy(ch->szdev, "/dev/ttymxc2");
  1673. ch->baud = 9600;
  1674. ch->parity = 'N';
  1675. strcpy(ch->szinfo, "光伏电表");
  1676. // CHAN 485 3
  1677. ch = &APPL.chan485[3];
  1678. strcpy(ch->szdev, "/dev/ttymxc3");
  1679. ch->baud = 9600;
  1680. ch->parity = 'N';
  1681. strcpy(ch->szinfo, "关口表");
  1682. // CHAN 485 4
  1683. ch = &APPL.chan485[4];
  1684. strcpy(ch->szdev, "/dev/ttymxc5");
  1685. ch->baud = 9600;
  1686. ch->parity = 'N';
  1687. strcpy(ch->szinfo, "变压器电表");
  1688. pthread_create(&hthrd_485_1, NULL, thrd_485_1, NULL);
  1689. pthread_create(&hthrd_485_2, NULL, thrd_485_2, NULL);
  1690. pthread_create(&hthrd_485_3, NULL, thrd_485_3, NULL);
  1691. pthread_create(&hthrd_485_4, NULL, thrd_485_4, NULL);
  1692. // Set
  1693. if(appl_cfg_read() != 0){
  1694. appl_cfg_set_err();
  1695. syslog(LOG_INFO,"%s, appl_cfg_read fail", __func__);
  1696. }else{
  1697. appl_cfg_reset_err();
  1698. // //1# MQTT thingsboard
  1699. // m = &APPL.chanmqtt[1];
  1700. // m->s_conn = NULL;
  1701. // strcpy(m->szs_url,"124.222.45.156:1883");
  1702. // strcpy(m->szs_pub_topic,"v1/devices/me/telemetry");
  1703. // strcpy(m->szs_sub_topic,"v1/devices/me/ctl");
  1704. // m->s_qos = 1;
  1705. // //测试设备
  1706. // //strcpy(m->szusrname,"gFCNk8oSxC6VlYXkhs3a");
  1707. // strcpy(m->szusrname,"DZHbY2HAGeATfRCfhlW7");
  1708. // m->bConnected = 0;
  1709. //2# MQTT Cloud
  1710. m = &APPL.chanmqtt[2];
  1711. m->s_conn = NULL;
  1712. strncpy(m->szusrname,set->szCloudUserName, sizeof(m->szusrname) - 1);
  1713. strncpy(m->szpasswd,set->szCloudPasswd, sizeof(m->szpasswd) - 1);
  1714. strncpy(m->szclientid,set->szClientId, sizeof(m->szclientid) - 1);
  1715. strncpy(m->szs_url, set->szCloudUrl, sizeof(m->szs_url)-1);
  1716. sprintf(m->szs_pub_topic[0],"sequential/%s/CtnMeter",m->szusrname);
  1717. sprintf(m->szs_pub_topic[1],"sequential/%s/PvMeter",m->szusrname);
  1718. sprintf(m->szs_pub_topic[2],"sequential/%s/TransMeter",m->szusrname);
  1719. sprintf(m->szs_pub_topic[3],"sequential/%s/GateMeter",m->szusrname);
  1720. strcpy(m->szs_sub_topic,"control");
  1721. m->s_qos = 1;
  1722. m->bConnected = 0;
  1723. pthread_create(&hthrd_mqtt2, NULL, thrd_mqtt_2, NULL);
  1724. }
  1725. // Snap
  1726. appl_snap_reset_err();
  1727. snap->bStart = 0;
  1728. snap->KeepDay = 365;
  1729. pthread_create(&hthrd_snap, NULL, thrd_snap, NULL);
  1730. }