snmp.c 39 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475
  1. #include "snmp.h"
  2. #include "lwip/apps/snmp.h"
  3. #include "lwip/apps/snmp_mib2.h"
  4. #include "lwip/apps/snmp_opts.h"
  5. #include "lwip/apps/snmpv3.h" // 如果使用 SNMP v3
  6. #include "lwip/apps/snmp_opts.h"
  7. #include "lwip/apps/snmp_core.h"
  8. #include "lwip/apps/snmp_table.h"
  9. #include "lwip/apps/snmp_scalar.h"
  10. #include "string.h"
  11. #include "power.h"
  12. #include "datadef.h"
  13. #include "sensor.h"
  14. #include "paras.h"
  15. #define SNMP_SMARTPDU_OID {1,3,6,1,2,1,1}
  16. #define SNMP_SMARTPDU_DEVICE_OID {1,3,6,1,4,1,2024,1}
  17. //#define SNMP_SMARTPDU_CHANNEL_TABLE {1,3,6,1,4,1,2024,1,3,9}
  18. //#define SNMP_SMARTPDU_ALARM_TABLE_IOD {1,3,6,1,4,1,2024,1,6,1}
  19. #define SNMP_SMARTPDU_THR_TABLE_IOD {1,3,6,1,4,1,2024,1,7}
  20. #define SNMP_SMARTPDU_TOTAL_OID {1,3,6,1,4,1,2024,1,3}
  21. typedef struct
  22. {
  23. uint8_t sysdescr[10];
  24. uint8_t syscontact[5];
  25. uint8_t sysname[3];
  26. uint8_t syslocation[3];
  27. struct snmp_obj_id device_enterprose_oid;
  28. // char *id_manifacture;
  29. // char *id_device;
  30. // char *id_sn;
  31. // char *id_version;
  32. // power_all_t all;
  33. }snmp_smarpdu_t;
  34. //static snmp_smarpdu_t snmp_smart={
  35. // .sysdescr={"Smart_pdu"},
  36. // .syscontact={"KyKy"},
  37. // .sysname={"Rt"},
  38. // .syslocation={"CN"},
  39. // .device_enterprose_oid={
  40. // .len = 7,
  41. // .id = SNMP_SMARTPDU_OID,
  42. // },
  43. //// .id_manifacture = "Gowone Industry",
  44. //// .id_device = "Smart_PDU",
  45. //// .id_sn = "SN123465",
  46. //// .id_version = "v1.0.0.0",
  47. //};
  48. static s16_t sysinfo_get_value(const struct snmp_scalar_array_node_def *node, void *value)
  49. {
  50. char *var = NULL;
  51. s16_t var_len;
  52. char buff[100]= {0};
  53. switch(node->oid)
  54. {
  55. case 1:
  56. {
  57. sprintf(buff,"%d",0);
  58. }
  59. break;
  60. case 2:
  61. {
  62. sprintf(buff,"%s","smart_pdu");
  63. }
  64. break;
  65. case 3:
  66. {
  67. sprintf(buff,"%s","DC");
  68. }
  69. break;
  70. case 4:
  71. {
  72. sprintf(buff,"%s","SN1235");
  73. }
  74. break;
  75. case 5:
  76. {
  77. sprintf(buff,"%d",12);
  78. }
  79. break;
  80. case 6:
  81. {
  82. sprintf(buff,"%d",7);
  83. }
  84. break;
  85. default:
  86. {
  87. LOGE("sysinfo_get_value(): unknown id: %d\n", node->oid);
  88. return 0;
  89. }
  90. }
  91. var_len = strlen(buff);
  92. memcpy(value, buff, var_len);
  93. return var_len;
  94. }
  95. static s16_t total_get_value(const struct snmp_scalar_array_node_def *node, void *value)
  96. {
  97. char *var = NULL;
  98. s16_t var_len;
  99. char buff[100]= {0};
  100. power_all_t *all = power_get_all();
  101. switch(node->oid)
  102. {
  103. case SCALAR_VOLTAGE:
  104. {
  105. sprintf(buff,"%.2f",all->ttl.total[0].voltage);
  106. }
  107. break;
  108. case SCALAR_CURRENT:
  109. {
  110. sprintf(buff,"%.2f",all->ttl.total[0].current);
  111. }
  112. break;
  113. case SCALAR_CONSUMEPTION:
  114. {
  115. sprintf(buff,"%.2f",all->ttl.total[0].consump);
  116. }
  117. break;
  118. case SCALAR_POWER_FACTOR:
  119. {
  120. sprintf(buff,"%.2f",all->ttl.total[0].factor);
  121. }
  122. break;
  123. case SCALAR_PACTIVE_POWER:
  124. {
  125. sprintf(buff,"%.2f",all->ttl.total[0].power);
  126. }
  127. break;
  128. case SCALAR_REACTIVE_POWER:
  129. {
  130. sprintf(buff,"%.2f",all->ttl.total[0].reactive);
  131. }
  132. break;
  133. case SCALAR_APPARENT_POWER:
  134. {
  135. sprintf(buff,"%.2f",all->ttl.total[0].active);
  136. }
  137. break;
  138. default:
  139. return 0;
  140. }
  141. var_len = strlen(buff);
  142. memcpy(value, buff, var_len);
  143. return var_len;
  144. }
  145. #define POWER_VALUE 4
  146. typedef struct power_data{
  147. uint8_t id;
  148. char * name;
  149. uint8_t status;
  150. float v;
  151. float i;
  152. float f;
  153. float c;
  154. float fa;
  155. float p;
  156. float r_p;
  157. float a_p;
  158. }p_data_t;
  159. typedef struct alarm_data{
  160. uint8_t id;
  161. uint8_t type;
  162. char * alarm_info;
  163. uint8_t alarm_action;
  164. uint32_t alarm_action_para;
  165. char * date;
  166. char * time;
  167. }p_alarm_t;
  168. typedef struct threshold_data{
  169. uint8_t id;
  170. char *name;
  171. float v_max;
  172. float v_min;
  173. float i_max;
  174. float p_max;
  175. float c_max;
  176. }thr_d_t;
  177. typedef struct thr_sensor_data{
  178. uint8_t id;
  179. char *name;
  180. uint32_t val1_up;
  181. uint32_t val2_up;
  182. uint32_t val1_down;
  183. uint32_t val2_down;
  184. }thr_s_t;
  185. static p_data_t p_data[POWER_VALUE]={
  186. {
  187. .id = 1,
  188. .name = "smart_pdu",
  189. .status = 1,
  190. .v=220.0,
  191. .i = 15.3,
  192. .f = 48.95,
  193. .c = 20.14,
  194. .fa = 0.89,
  195. .p = 480.12,
  196. .r_p = 520.45,
  197. .a_p = 600.12,
  198. },
  199. {
  200. .id = 2,
  201. .name = "smart_pdu",
  202. .status = 1,
  203. .v=218.0,
  204. .i = 15.3,
  205. .f = 49.95,
  206. .c = 20.14,
  207. .fa = 0.89,
  208. .p = 480.12,
  209. .r_p = 520.45,
  210. .a_p = 600.12,
  211. },
  212. {
  213. .id = 3,
  214. .name = "smart_pdu",
  215. .status = 1,
  216. .v=219.0,
  217. .i = 9.3,
  218. .f = 48.95,
  219. .c = 20.14,
  220. .fa = 0.89,
  221. .p = 100.12,
  222. .r_p = 230.45,
  223. .a_p = 460.12,
  224. },
  225. {
  226. .id = 4,
  227. .name = "smart_pdu",
  228. .status = 0,
  229. .v=220.0,
  230. .i = 15.3,
  231. .f = 48.95,
  232. .c = 20.14,
  233. .fa = 0.89,
  234. .p = 480.12,
  235. .r_p = 520.45,
  236. .a_p = 600.12,
  237. },
  238. };
  239. static thr_s_t p_thr_s[POWER_VALUE] = {
  240. {
  241. .id = 1,
  242. .name = "sers_th1",
  243. .val1_up = 23,
  244. .val2_up = 32,
  245. .val1_down = 11,
  246. .val2_down = 12,
  247. },
  248. {
  249. .id = 2,
  250. .name = "sers_th2",
  251. .val1_up = 23,
  252. .val2_up = 32,
  253. .val1_down = 11,
  254. .val2_down = 12,
  255. },
  256. {
  257. .id = 3,
  258. .name = "sers_th3",
  259. .val1_up = 23,
  260. .val2_up = 32,
  261. .val1_down = 11,
  262. .val2_down = 12,
  263. },
  264. {
  265. .id = 4,
  266. .name = "sers_th4",
  267. .val1_up = 23,
  268. .val2_up = 32,
  269. .val1_down = 11,
  270. .val2_down = 12,
  271. },
  272. };
  273. static struct snmp_oid_range th_table_oid_ranges[] = {
  274. {1, POWER_VALUE},
  275. };
  276. static struct snmp_oid_range th_sensor_oid_ranges[] = {
  277. {1,MAX_SENSOR},
  278. };
  279. static p_alarm_t p_a_data[POWER_VALUE]={
  280. {
  281. .id = 1,
  282. .type = 3,
  283. .alarm_info="voltage alarm!!!",
  284. .alarm_action = 0,
  285. .alarm_action_para = 4,
  286. .date = "2052.12.20",
  287. .time = "12:30:47",
  288. },
  289. {
  290. .id = 2,
  291. .type = 2,
  292. .alarm_info="current alarm!!!",
  293. .alarm_action = 1,
  294. .alarm_action_para = 2,
  295. .date = "2002-11-20",
  296. .time = "10:30:47",
  297. },
  298. {
  299. .id = 3,
  300. .type = 1,
  301. .alarm_info="power alarm!!!",
  302. .alarm_action = 3,
  303. .alarm_action_para = 6,
  304. .date = "2012-11-20",
  305. .time = "10:59:47",
  306. },
  307. {
  308. .id = 4,
  309. .type = 4,
  310. .alarm_info="consumer alarm!!!",
  311. .alarm_action = 3,
  312. .alarm_action_para = 6,
  313. .date = "2012-11-20",
  314. .time = "10:59:47",
  315. },
  316. };
  317. static thr_d_t p_t_data[POWER_VALUE]=
  318. {
  319. {
  320. .id = 1,
  321. .name="thrould",
  322. .v_max = 250.00,
  323. .v_min = 180.00,
  324. .i_max = 50.00,
  325. .p_max = 20000.00,
  326. .c_max = 10000,
  327. },
  328. {
  329. .id = 2,
  330. .name="thrould",
  331. .v_max = 250.00,
  332. .v_min = 180.00,
  333. .i_max = 50.00,
  334. .p_max = 20000.00,
  335. .c_max = 10000,
  336. },
  337. {
  338. .id = 3,
  339. .name="thrould",
  340. .v_max = 250.00,
  341. .v_min = 180.00,
  342. .i_max = 50.00,
  343. .p_max = 20000.00,
  344. .c_max = 10000,
  345. },
  346. {
  347. .id = 4,
  348. .name="thrould",
  349. .v_max = 250.00,
  350. .v_min = 180.00,
  351. .i_max = 50.00,
  352. .p_max = 20000.00,
  353. .c_max = 10000,
  354. },
  355. };
  356. static s16_t thr_s_get_info(struct snmp_node_instance *instance, void *value)
  357. {
  358. u32_t row = instance->reference.u32;
  359. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  360. sensor_all_t *sensor = sensor_get_data();
  361. char buff[50]= {0};
  362. if(!sensor)
  363. return 0;
  364. switch(col)
  365. {
  366. case COLUMN_PDUSENSORID:
  367. {
  368. *(s32_t *)value = row;
  369. return 4;
  370. }
  371. case COLUMN_PDUSENSORNAME:
  372. {
  373. sprintf(buff,"%s",sensor->data[row-1].info.name);
  374. }
  375. break;
  376. case COLUMN_PDUSENSORTYPE:
  377. {
  378. sprintf(buff,"%d",sensor->data[row-1].info.type);
  379. }
  380. break;
  381. case COLUMN_PDUSENSORDATACHENNEL:
  382. {
  383. sprintf(buff,"%d",sensor->data[row-1].info.num_val);
  384. }
  385. break;
  386. case COLUMN_PDUSENSORMODBUSADDRESS:
  387. {
  388. //sprintf(buff,"%d",sensor->data[row-1].info.addr);
  389. *(s32_t *)value = sensor->data[row-1].info.addr;
  390. return 4;
  391. }
  392. break;
  393. case COLUMN_PDUSENSORSTATUS:
  394. {
  395. //sprintf(buff,"%d",sensor->data[row-1].info.status);
  396. *(s32_t *)value = sensor->data[row-1].info.status;
  397. return 4;
  398. }
  399. break;
  400. case COLUMN_PDUSENSORVALUENUM:
  401. {
  402. //sprintf(buff,"%d",sensor->data[row-1].info.num_val);
  403. *(s32_t *)value = sensor->data[row-1].info.num_val;
  404. return 4;
  405. }
  406. break;
  407. case COLUMN_PDUSENSORVALUE1:
  408. {
  409. sprintf(buff,"%.2f",sensor->data[row-1].val[0].value);
  410. }
  411. break;
  412. case COLUMN_PDUSENSORVALUE2:
  413. {
  414. sprintf(buff,"%.2f",sensor->data[row-1].val[1].value);
  415. }
  416. break;
  417. default:
  418. break;
  419. }
  420. memcpy(value,buff,strlen(buff));
  421. return strlen(buff);
  422. }
  423. static snmp_err_t thr_s_set_value(struct snmp_node_instance *instance,u16_t len, void *value)
  424. {
  425. u32_t row = instance->reference.u32;
  426. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  427. sensor_all_t * sensor = sensor_get_data();
  428. paras_data_t *p=paras_get();
  429. uint32_t val = *(uint32_t *)value;
  430. if(sensor->data == 0)
  431. {
  432. return SNMP_ERR_NOTWRITABLE;
  433. }
  434. switch(col)
  435. {
  436. case COLUMN_PDUSENSORLIMITVALUE1UP:
  437. {
  438. sensor->data[row-1].val[0].thr.max = (val/100.0);
  439. p->sensor[row-1].th_max_1 = val;
  440. if(val)
  441. {
  442. sensor->data[row-1].val[0].thr.en.th_sen_max_en = 1;
  443. }else
  444. {
  445. sensor->data[row-1].val[0].thr.en.th_sen_max_en = 0;
  446. }
  447. }
  448. break;
  449. case COLUMN_PDUSENSORLIMITVALUE2UP:
  450. {
  451. sensor->data[row-1].val[1].thr.max = (val/100.0);
  452. p->sensor[row-1].th_max_2 = val;
  453. if(val)
  454. {
  455. sensor->data[row-1].val[1].thr.en.th_sen_max_en = 1;
  456. }else
  457. {
  458. sensor->data[row-1].val[1].thr.en.th_sen_max_en = 0;
  459. }
  460. }
  461. break;
  462. case COLUMN_PDUSENSORLIMITVALUE1DOWN:
  463. {
  464. sensor->data[row-1].val[0].thr.min = (val/100.0);
  465. p->sensor[row-1].th_min_1 = val;
  466. if(val)
  467. {
  468. sensor->data[row-1].val[0].thr.en.th_sen_min_en = 1;
  469. }else
  470. {
  471. sensor->data[row-1].val[0].thr.en.th_sen_min_en = 0;
  472. }
  473. }
  474. break;
  475. case COLUMN_PDUSENSORLIMITVALUE2DOWN:
  476. {
  477. sensor->data[row-1].val[1].thr.min = (val/100.0);
  478. p->sensor[row-1].th_min_2 = val;
  479. if(val)
  480. {
  481. sensor->data[row-1].val[1].thr.en.th_sen_min_en = 1;
  482. }else
  483. {
  484. sensor->data[row-1].val[1].thr.en.th_sen_min_en = 0;
  485. }
  486. }
  487. break;
  488. default:
  489. return SNMP_ERR_NOTWRITABLE;
  490. }
  491. paras_save();
  492. return SNMP_ERR_NOERROR;
  493. }
  494. static s16_t thr_s_get_value(struct snmp_node_instance *instance, void *value)
  495. {
  496. u32_t row = instance->reference.u32;
  497. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  498. sensor_all_t *sensor = sensor_get_data();
  499. char buff[50]= {0};
  500. switch(col)
  501. {
  502. case COLUMN_PDUSENSORLIMITID:
  503. {
  504. *(s32_t *)value = row;
  505. return 4;
  506. }
  507. break;
  508. case COLUMN_PDUSENSORLIMITNAME:
  509. {
  510. sprintf(buff,"%s",sensor->data[row-1].info.name);
  511. }
  512. break;
  513. case COLUMN_PDUSENSORLIMITVALUE1UP:
  514. {
  515. *(s32_t *)value = (sensor->data[row-1].val[0].thr.max * 100);
  516. return 4;
  517. }
  518. break;
  519. case COLUMN_PDUSENSORLIMITVALUE2UP:
  520. {
  521. *(s32_t *)value = (sensor->data[row-1].val[1].thr.max * 100);
  522. return 4;
  523. }
  524. break;
  525. case COLUMN_PDUSENSORLIMITVALUE1DOWN:
  526. {
  527. *(s32_t *)value = (sensor->data[row-1].val[0].thr.min * 100);
  528. return 4;
  529. }
  530. break;
  531. case COLUMN_PDUSENSORLIMITVALUE2DOWN:
  532. {
  533. *(s32_t *)value = (sensor->data[row-1].val[1].thr.min * 100);
  534. return 4;
  535. }
  536. break;
  537. default:
  538. return 0;
  539. }
  540. memcpy(value,buff,strlen(buff));
  541. return strlen(buff);
  542. }
  543. static s16_t thr_get_value(struct snmp_node_instance *instance, void *value)
  544. {
  545. power_all_t *all = power_get_all();
  546. u32_t row = instance->reference.u32;
  547. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  548. char buff[50]= {0};
  549. switch (col)
  550. {
  551. case COLUMN_PDUCHANNELLIMITID:
  552. {
  553. *(s32_t *)value = row-1;
  554. return 4;
  555. }
  556. break;
  557. case COLUMN_PDUCHANNELLIMITNAME:
  558. {
  559. sprintf(buff,"%s",all->pch[row-1].info.name);
  560. }
  561. break;
  562. case COLUMN_PDUCHANNELCURRENTLIMITUP:
  563. {
  564. sprintf(buff,"%.2f",((float)all->pch[row-1].thr.c_upper/10.0));
  565. }
  566. break;
  567. case COLUMN_PDUCHANNELVOLTAGELIMITUP:
  568. {
  569. sprintf(buff,"%.2f",((float)all->pch[row-1].thr.v_upper/10.0));
  570. }
  571. break;
  572. case COLUMN_PDUCHANNELVOLTAGELIMITDOWN:
  573. {
  574. sprintf(buff,"%.2f",((float)all->pch[row-1].thr.v_lower/10.0));
  575. }
  576. break;
  577. case COLUMN_PDUCHANNELPOWERLIMITUP:
  578. {
  579. sprintf(buff,"%.2f",((float)all->pch[row-1].thr.p_upper/10.0));
  580. }
  581. break;
  582. case COLUMN_PDUCHANNELCONSUMPTIONLIMITUP:
  583. {
  584. sprintf(buff,"%.2f",((float)all->pch[row-1].thr.w_upper/10.0));
  585. }
  586. break;
  587. default:
  588. return 0;
  589. }
  590. memcpy(value,buff,strlen(buff));
  591. return strlen(buff);
  592. }
  593. static s16_t alarm_get_value(struct snmp_node_instance *instance, void *value)
  594. {
  595. u32_t row = instance->reference.u32;
  596. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  597. char buff[50]= {0};
  598. switch (col)
  599. {
  600. case COLUMN_PDUALARMID:
  601. {
  602. *(s32_t *)value = p_a_data[row-1].id;
  603. return 4;
  604. }
  605. break;
  606. case COLUMN_PDUALARMTYPE:
  607. {
  608. *(s32_t *)value = p_a_data[row-1].type;
  609. return 4;
  610. }
  611. break;
  612. case COLUMN_PDUALARMCONTEXT:
  613. {
  614. sprintf(buff,"%s",p_a_data[row-1].alarm_info);
  615. }
  616. break;
  617. case COLUMN_PDUALARMACTION:
  618. {
  619. *(s32_t *)value = p_a_data[row-1].alarm_action;
  620. return 4;
  621. }
  622. break;
  623. case COLUMN_PDUALARMACTIONPARA:
  624. {
  625. *(s32_t *)value = p_a_data[row-1].alarm_action_para;
  626. return 4;
  627. }
  628. break;
  629. case COLUMN_PDUALARMDATE:
  630. {
  631. sprintf(buff,"%s",p_a_data[row-1].date);
  632. }
  633. break;
  634. case COLUMN_PDUALARMTIME:
  635. {
  636. sprintf(buff,"%s",p_a_data[row-1].time);
  637. }
  638. break;
  639. default:
  640. return 0;
  641. }
  642. memcpy(value,buff,strlen(buff));
  643. return strlen(buff);
  644. }
  645. static snmp_err_t power_get_instance(const u32_t *column, const u32_t *row_oid, u8_t row_oid_len, struct snmp_node_instance *cell_instance)
  646. {
  647. power_all_t *all = power_get_all();
  648. th_table_oid_ranges[0].max = all->chs-1;
  649. if (!snmp_oid_in_range(row_oid, row_oid_len, th_table_oid_ranges, LWIP_ARRAYSIZE(th_table_oid_ranges)))
  650. return SNMP_ERR_NOSUCHINSTANCE;
  651. cell_instance->reference.u32 = row_oid[0];
  652. return SNMP_ERR_NOERROR;
  653. }
  654. static snmp_err_t get_instance(const u32_t *column, const u32_t *row_oid, u8_t row_oid_len, struct snmp_node_instance *cell_instance)
  655. {
  656. if (!snmp_oid_in_range(row_oid, row_oid_len, th_table_oid_ranges, LWIP_ARRAYSIZE(th_table_oid_ranges)))
  657. return SNMP_ERR_NOSUCHINSTANCE;
  658. cell_instance->reference.u32 = row_oid[0];
  659. return SNMP_ERR_NOERROR;
  660. }
  661. static snmp_err_t get_sensor_instance(const u32_t *column, const u32_t *row_oid, u8_t row_oid_len, struct snmp_node_instance *cell_instance)
  662. {
  663. if (!snmp_oid_in_range(row_oid, row_oid_len, th_sensor_oid_ranges, LWIP_ARRAYSIZE(th_sensor_oid_ranges)))
  664. return SNMP_ERR_NOSUCHINSTANCE;
  665. cell_instance->reference.u32 = row_oid[0];
  666. return SNMP_ERR_NOERROR;
  667. }
  668. static snmp_err_t get_sensor_next_instance(const u32_t *column, struct snmp_obj_id *row_oid, struct snmp_node_instance *cell_instance)
  669. {
  670. u8_t i = 0;
  671. struct snmp_next_oid_state state;
  672. u32_t next_oid = 0;
  673. snmp_next_oid_init(&state, row_oid->id, row_oid->len, &next_oid, 1);
  674. for (i = 0; i < th_sensor_oid_ranges[0].max; i++)
  675. {
  676. u32_t test_oid = i + 1;
  677. snmp_next_oid_check(&state, &test_oid, 1, NULL);
  678. }
  679. if (state.status == SNMP_NEXT_OID_STATUS_SUCCESS)
  680. {
  681. snmp_oid_assign(row_oid, state.next_oid, state.next_oid_len);
  682. cell_instance->reference.u32 = *state.next_oid; /* 下个节点行OID */
  683. return SNMP_ERR_NOERROR;
  684. }
  685. return SNMP_ERR_NOSUCHINSTANCE;
  686. }
  687. static snmp_err_t power_get_next_instance(const u32_t *column, struct snmp_obj_id *row_oid, struct snmp_node_instance *cell_instance)
  688. {
  689. u8_t i = 0;
  690. struct snmp_next_oid_state state;
  691. u32_t next_oid = 0;
  692. snmp_next_oid_init(&state, row_oid->id, row_oid->len, &next_oid, 1);
  693. //power_data_get(&snmp_smart.all);
  694. power_all_t *all = power_get_all();
  695. for (i = 0; i < all->chs-1; i++)
  696. {
  697. u32_t test_oid = i + 1;
  698. snmp_next_oid_check(&state, &test_oid, 1, NULL);
  699. }
  700. if (state.status == SNMP_NEXT_OID_STATUS_SUCCESS)
  701. {
  702. snmp_oid_assign(row_oid, state.next_oid, state.next_oid_len);
  703. cell_instance->reference.u32 = *state.next_oid; /* 下个节点行OID */
  704. cell_instance->reference.u32++;
  705. return SNMP_ERR_NOERROR;
  706. }
  707. return SNMP_ERR_NOSUCHINSTANCE;
  708. }
  709. static snmp_err_t get_next_instance(const u32_t *column, struct snmp_obj_id *row_oid, struct snmp_node_instance *cell_instance)
  710. {
  711. u8_t i = 0;
  712. struct snmp_next_oid_state state;
  713. u32_t next_oid = 0;
  714. snmp_next_oid_init(&state, row_oid->id, row_oid->len, &next_oid, 1);
  715. power_all_t *all = power_get_all();
  716. //power_data_get(&snmp_smart.all);
  717. for (i = 0; i < POWER_VALUE; i++)
  718. {
  719. u32_t test_oid = i + 1;
  720. snmp_next_oid_check(&state, &test_oid, 1, NULL);
  721. }
  722. if (state.status == SNMP_NEXT_OID_STATUS_SUCCESS)
  723. {
  724. snmp_oid_assign(row_oid, state.next_oid, state.next_oid_len);
  725. cell_instance->reference.u32 = *state.next_oid; /* 下个节点行OID */
  726. return SNMP_ERR_NOERROR;
  727. }
  728. return SNMP_ERR_NOSUCHINSTANCE;
  729. }
  730. static s16_t alarm_power_get(struct snmp_node_instance *instance, void *value)
  731. {
  732. power_all_t *all = power_get_all();
  733. u32_t row = instance->reference.u32;
  734. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  735. switch (col)
  736. {
  737. case COLUMN_PDUCHANNELPOWERALARMID:
  738. {
  739. *(s32_t *)value = row-1;
  740. }
  741. break;
  742. case COLUMN_PDUCHANNELPOWERALARMVOLTAGEUP:
  743. {
  744. *(s32_t *)value = all->pch[row-1].alarm.v_upper;
  745. }
  746. break;
  747. case COLUMN_PDUCHANNELPOWERALARMVOLTAGEDOWN:
  748. {
  749. *(s32_t *)value = all->pch[row-1].alarm.v_lower;
  750. }
  751. break;
  752. case COLUMN_PDUCHANNELPOWERALARMCURRENTUP:
  753. {
  754. *(s32_t *)value = all->pch[row-1].alarm.c_upper;
  755. }
  756. break;
  757. case COLUMN_PDUCHANNELPOWERALARMPOWERUP:
  758. {
  759. *(s32_t *)value = all->pch[row-1].alarm.p_upper;
  760. }
  761. break;
  762. case COLUMN_PDUCHANNELPOWERALARMCONSUMPTIONUP:
  763. {
  764. *(s32_t *)value = all->pch[row-1].alarm.w_upper;
  765. }
  766. break;
  767. default:
  768. return 0;
  769. }
  770. return 4;
  771. }
  772. static s16_t alarm_sensor_get(struct snmp_node_instance *instance, void *value)
  773. {
  774. sensor_all_t *sensor = sensor_get_data();
  775. u32_t row = instance->reference.u32;
  776. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  777. switch (col)
  778. {
  779. case COLUMN_PDUSENSORALARMID:
  780. {
  781. *(s32_t *)value = row-1;
  782. }
  783. break;
  784. case COLUMN_PDUSENSORALARMVALUE1UP:
  785. {
  786. *(s32_t *)value = sensor->data[row-1].val[0].s_alarm.max_up;
  787. }
  788. break;
  789. case COLUMN_PDUSENSORALARMVALUE1DOWN:
  790. {
  791. *(s32_t *)value = sensor->data[row-1].val[0].s_alarm.min_down;
  792. }
  793. break;
  794. case COLUMN_PDUSENSORALARMVALUE2UP:
  795. {
  796. *(s32_t *)value = sensor->data[row-1].val[1].s_alarm.max_up;
  797. }
  798. break;
  799. case COLUMN_PDUSENSORALARMVALUE2DOWN:
  800. {
  801. *(s32_t *)value = sensor->data[row-1].val[0].s_alarm.min_down;
  802. }
  803. break;
  804. default:
  805. return 0;
  806. }
  807. return 4;
  808. }
  809. static s16_t power_get_value(struct snmp_node_instance *instance, void *value)
  810. {
  811. power_all_t *all = power_get_all();
  812. u32_t row = instance->reference.u32;
  813. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  814. char buff[100]= {0};
  815. switch (col)
  816. {
  817. case COLUMN_PDUCHANNELID:
  818. {
  819. *(s32_t *)value = row-1;
  820. return 4;
  821. }
  822. break;
  823. case COLUMN_PDUCHANNELNAME:
  824. {
  825. sprintf(buff,"%s",all->pch[row-1].info.name);
  826. }
  827. break;
  828. case COLUMN_PDUCHANNELSTATUS:
  829. {
  830. //sprintf(buff,"%d",p_data[row].status);
  831. //*(s32_t *)value = p_data[row-1].status;
  832. *(s32_t *)value = all->pch[row-1].status;
  833. return 4;
  834. }
  835. break;
  836. case COLUMN_PDUCHANNELVOLTAGE:
  837. {
  838. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].voltage)/10.0);
  839. }
  840. break;
  841. case COLUMN_PDUCHANNELCURRENT:
  842. {
  843. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].current)/10.0);
  844. }
  845. break;
  846. case COLUMN_PDUCHANNELFREQUENCY:
  847. {
  848. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].freq)/100.0);
  849. }
  850. break;
  851. case COLUMN_PDUCHANNELCONSUMPTION:
  852. {
  853. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].consump)/1000.0);
  854. }
  855. break;
  856. case COLUMN_PDUCHANNELPOWERFACTOR:
  857. {
  858. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].factor)/100.0);
  859. }
  860. break;
  861. case COLUMN_PDUCHANNELPACTIVEPOWER:
  862. {
  863. sprintf(buff,"%.2f",((float)all->pch[row-1].power[0].power)/1000.0);
  864. }
  865. break;
  866. case COLUMN_PDUCHANNELREACTIVEPOWER:
  867. {
  868. sprintf(buff,"%.2f",p_data[row-1].r_p);
  869. }
  870. break;
  871. case COLUMN_PDUCHANNELAPPARENTPOWER:
  872. {
  873. sprintf(buff,"%.2f",p_data[row-1].a_p);
  874. }
  875. break;
  876. default:
  877. return 0;
  878. }
  879. memcpy(value,buff,strlen(buff));
  880. return strlen(buff);
  881. }
  882. static snmp_err_t set_test(struct snmp_node_instance *instance, u16_t len, void *value)
  883. {
  884. LOGD("write test\n");
  885. return SNMP_ERR_NOERROR;
  886. }
  887. static snmp_err_t power_set_value (struct snmp_node_instance *instance, u16_t len, void *value)
  888. {
  889. power_all_t *all = power_get_all();
  890. u32_t row = instance->reference.u32;
  891. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  892. switch(col)
  893. {
  894. case COLUMN_PDUCHANNELSTATUS:
  895. {
  896. //p_data[row-1].status = *(uint32_t*)value;
  897. all->pch[row].status = *(uint32_t*)value;
  898. power_set_ch_sw_n(&all->pch[row]);
  899. }
  900. break;
  901. default:
  902. return SNMP_ERR_NOTWRITABLE;
  903. }
  904. return SNMP_ERR_NOERROR;
  905. }
  906. static snmp_err_t thr_set_value(struct snmp_node_instance *instance,u16_t len, void *value)
  907. {
  908. u32_t row = instance->reference.u32;
  909. u32_t col = SNMP_TABLE_GET_COLUMN_FROM_OID(instance->instance_oid.id);
  910. power_all_t *all = power_get_all();
  911. switch(col)
  912. {
  913. case COLUMN_PDUCHANNELCURRENTLIMITUP:
  914. {
  915. all->pch[row].thr.c_upper = (float)atof((char *)value) * 10;
  916. //p_t_data[row-1].i_max = (float)atof((char *)value);
  917. //all->pch[row-1]
  918. power_set_threshold(&all->pch[row]);
  919. }
  920. break;
  921. case COLUMN_PDUCHANNELVOLTAGELIMITUP:
  922. {
  923. //p_t_data[row-1].v_max = (float)atof((char *)value);
  924. all->pch[row].thr.v_upper = (float)atof((char *)value) * 10;
  925. power_set_threshold(&all->pch[row]);
  926. }
  927. break;
  928. case COLUMN_PDUCHANNELVOLTAGELIMITDOWN:
  929. {
  930. all->pch[row].thr.v_lower = (float)atof((char *)value) * 10;
  931. power_set_threshold(&all->pch[row]);
  932. //p_t_data[row-1].v_min = (float)atof((char *)value);
  933. //all->pch[row-1].thr.v_upper = (float)atof((char *)value) * 10;
  934. }
  935. break;
  936. case COLUMN_PDUCHANNELPOWERLIMITUP:
  937. {
  938. //p_t_data[row-1].p_max = (float)atof((char *)value);
  939. all->pch[row].thr.p_upper = (float)atof((char *)value) * 1000;
  940. power_set_threshold(&all->pch[row]);
  941. }
  942. break;
  943. case COLUMN_PDUCHANNELCONSUMPTIONLIMITUP:
  944. {
  945. //p_t_data[row-1].c_max = (float)atof((char *)value);
  946. all->pch[row].thr.w_upper = (float)atof((char *)value) * 1000;
  947. power_set_threshold(&all->pch[row]);
  948. }
  949. break;
  950. default:
  951. return SNMP_ERR_INCONSISTENTNAME;
  952. }
  953. return SNMP_ERR_NOERROR;
  954. }
  955. static const struct snmp_scalar_array_node_def sysinfo_scalars_nodes[] = {
  956. {1, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product id */
  957. {2, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product name */
  958. {3, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product type */
  959. {4, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product firmware */
  960. {5, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product channal number */
  961. {6, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY}, /* product sensor number */
  962. {0,0,0},
  963. };
  964. static const struct snmp_table_col_def power_table_channels[]={
  965. {COLUMN_PDUCHANNELID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  966. {COLUMN_PDUCHANNELNAME, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  967. {COLUMN_PDUCHANNELSTATUS, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_WRITE},
  968. {COLUMN_PDUCHANNELVOLTAGE, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  969. {COLUMN_PDUCHANNELCURRENT, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  970. {COLUMN_PDUCHANNELFREQUENCY, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  971. {COLUMN_PDUCHANNELCONSUMPTION, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  972. {COLUMN_PDUCHANNELPOWERFACTOR, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  973. {COLUMN_PDUCHANNELPACTIVEPOWER, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  974. {COLUMN_PDUCHANNELREACTIVEPOWER, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  975. {COLUMN_PDUCHANNELAPPARENTPOWER, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  976. {0,0,0},
  977. };
  978. static const struct snmp_table_col_def alarm_history_table[]={
  979. {COLUMN_PDUALARMID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  980. {COLUMN_PDUALARMTYPE, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  981. {COLUMN_PDUALARMCONTEXT, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  982. {COLUMN_PDUALARMACTION, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  983. {COLUMN_PDUALARMACTIONPARA, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  984. {COLUMN_PDUALARMDATE, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  985. {COLUMN_PDUALARMTIME, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  986. {0,0,0},
  987. };
  988. static const struct snmp_table_col_def alarm_power_table[]={
  989. {COLUMN_PDUCHANNELPOWERALARMID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  990. {COLUMN_PDUCHANNELPOWERALARMVOLTAGEUP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  991. {COLUMN_PDUCHANNELPOWERALARMVOLTAGEDOWN, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  992. {COLUMN_PDUCHANNELPOWERALARMCURRENTUP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  993. {COLUMN_PDUALARMACTIONPARA, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  994. {COLUMN_PDUCHANNELPOWERALARMPOWERUP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  995. {COLUMN_PDUCHANNELPOWERALARMCONSUMPTIONUP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  996. {0,0,0},
  997. };
  998. static const struct snmp_table_col_def alarm_sensor_table[]={
  999. {COLUMN_PDUSENSORALARMID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1000. {COLUMN_PDUSENSORALARMVALUE1UP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1001. {COLUMN_PDUSENSORALARMVALUE1DOWN, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1002. {COLUMN_PDUSENSORALARMVALUE2UP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1003. {COLUMN_PDUSENSORALARMVALUE2DOWN, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1004. {0,0,0},
  1005. };
  1006. static const struct snmp_table_col_def threshold_limit_table[] = {
  1007. {COLUMN_PDUCHANNELLIMITID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1008. {COLUMN_PDUCHANNELLIMITNAME, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1009. {COLUMN_PDUCHANNELCURRENTLIMITUP, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_WRITE},
  1010. {COLUMN_PDUCHANNELVOLTAGELIMITUP, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_WRITE},
  1011. {COLUMN_PDUCHANNELVOLTAGELIMITDOWN, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_WRITE},
  1012. {COLUMN_PDUCHANNELPOWERLIMITUP, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_WRITE},
  1013. {COLUMN_PDUCHANNELCONSUMPTIONLIMITUP, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_WRITE},
  1014. {0,0,0},
  1015. };
  1016. static const struct snmp_table_col_def sensor_limit_table[] = {
  1017. {COLUMN_PDUSENSORLIMITID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY,},
  1018. {COLUMN_PDUSENSORLIMITNAME, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY,},
  1019. {COLUMN_PDUSENSORLIMITVALUE1UP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_WRITE,},
  1020. {COLUMN_PDUSENSORLIMITVALUE2UP, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_WRITE,},
  1021. {COLUMN_PDUSENSORLIMITVALUE1DOWN, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_WRITE,},
  1022. {COLUMN_PDUSENSORLIMITVALUE2DOWN, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_WRITE,},
  1023. {0,0,0},
  1024. };
  1025. static const struct snmp_table_col_def sensor_info_table[] = {
  1026. {COLUMN_PDUSENSORID, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1027. {COLUMN_PDUSENSORNAME, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1028. {COLUMN_PDUSENSORTYPE, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1029. {COLUMN_PDUSENSORDATACHENNEL, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1030. {COLUMN_PDUSENSORMODBUSADDRESS, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1031. {COLUMN_PDUSENSORSTATUS, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1032. {COLUMN_PDUSENSORVALUENUM, SNMP_ASN1_TYPE_INTEGER, SNMP_NODE_INSTANCE_READ_ONLY},
  1033. {COLUMN_PDUSENSORVALUE1, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1034. {COLUMN_PDUSENSORVALUE2, SNMP_ASN1_TYPE_OCTET_STRING, SNMP_NODE_INSTANCE_READ_ONLY},
  1035. {0,0,0},
  1036. };
  1037. const struct snmp_scalar_array_node sysinfo_scalars = SNMP_SCALAR_CREATE_ARRAY_NODE(1, sysinfo_scalars_nodes, sysinfo_get_value, NULL, NULL);
  1038. static s16_t get_total_scalar_value(struct snmp_node_instance *instance , void* data)
  1039. {
  1040. power_all_t *all = power_get_all();
  1041. char buff[100] = {0};
  1042. switch(instance->node->oid)
  1043. {
  1044. case SCALAR_VOLTAGE:
  1045. sprintf(buff,"%.2f",all->ttl.total[0].voltage);
  1046. break;
  1047. case SCALAR_CURRENT:
  1048. sprintf(buff,"%.2f",all->ttl.total[0].current);
  1049. break;
  1050. case SCALAR_CONSUMEPTION:
  1051. sprintf(buff,"%.2f",all->ttl.total[0].consump);
  1052. break;
  1053. case SCALAR_POWER_FACTOR:
  1054. sprintf(buff,"%.2f",all->ttl.total[0].factor);
  1055. break;
  1056. case SCALAR_PACTIVE_POWER:
  1057. sprintf(buff,"%.2f",all->ttl.total[0].power);
  1058. break;
  1059. case SCALAR_REACTIVE_POWER:
  1060. sprintf(buff,"%.2f",all->ttl.total[0].reactive);
  1061. break;
  1062. case SCALAR_APPARENT_POWER:
  1063. sprintf(buff,"%.2f",all->ttl.total[0].active);
  1064. break;
  1065. default:
  1066. return 0;
  1067. }
  1068. memcpy(data,buff,strlen(buff));
  1069. return strlen(buff);
  1070. }
  1071. const struct snmp_scalar_node voltage_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_VOLTAGE,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1072. const struct snmp_scalar_node current_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_CURRENT,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1073. const struct snmp_scalar_node consumer_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_CONSUMEPTION,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1074. const struct snmp_scalar_node factor_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_POWER_FACTOR,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1075. const struct snmp_scalar_node pactive_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_PACTIVE_POWER,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1076. const struct snmp_scalar_node reactive_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_REACTIVE_POWER,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1077. const struct snmp_scalar_node appactive_scalar = SNMP_SCALAR_CREATE_NODE(SCALAR_APPARENT_POWER,SNMP_NODE_INSTANCE_READ_ONLY,SNMP_ASN1_TYPE_OCTET_STRING,get_total_scalar_value,NULL,NULL);
  1078. static const struct snmp_table_node power_table = SNMP_TABLE_CREATE(9, power_table_channels, power_get_instance, power_get_next_instance, \
  1079. power_get_value, set_test, power_set_value);
  1080. static const struct snmp_table_node alarm_table = SNMP_TABLE_CREATE(1, alarm_history_table, get_instance, get_next_instance, \
  1081. alarm_get_value, set_test, NULL);
  1082. static const struct snmp_table_node thr_table = SNMP_TABLE_CREATE(6, threshold_limit_table, power_get_instance, power_get_next_instance, \
  1083. thr_get_value, set_test, thr_set_value);
  1084. static const struct snmp_table_node thr_s_table = SNMP_TABLE_CREATE(1, sensor_limit_table, get_sensor_instance, get_sensor_next_instance, \
  1085. thr_s_get_value, set_test, thr_s_set_value);
  1086. static const struct snmp_table_node sensor_table = SNMP_TABLE_CREATE(1,sensor_info_table,get_sensor_instance,get_sensor_next_instance,\
  1087. thr_s_get_info,set_test,thr_s_set_value);
  1088. static const struct snmp_table_node alarm_p_table = SNMP_TABLE_CREATE(2,alarm_power_table,power_get_instance,power_get_next_instance,\
  1089. alarm_power_get,NULL,NULL);
  1090. static const struct snmp_table_node alarm_s_table = SNMP_TABLE_CREATE(3,alarm_sensor_table,get_sensor_instance,get_sensor_next_instance,\
  1091. alarm_sensor_get,NULL,NULL);
  1092. static const struct snmp_node *const alarm_subnodes[]={
  1093. &alarm_table.node.node,
  1094. &alarm_p_table.node.node,
  1095. &alarm_s_table.node.node
  1096. };
  1097. static const struct snmp_node *const power_subnodes[] = {
  1098. &power_table.node.node,
  1099. &voltage_scalar.node.node,
  1100. &current_scalar.node.node,
  1101. &consumer_scalar.node.node,
  1102. &factor_scalar.node.node,
  1103. &pactive_scalar.node.node,
  1104. &reactive_scalar.node.node,
  1105. &appactive_scalar.node.node,
  1106. };
  1107. static const struct snmp_node *const thr_subnodes[] = {
  1108. &thr_table.node.node,
  1109. };
  1110. static const struct snmp_node *const thr_s_subnodes[] = {
  1111. &thr_s_table.node.node,
  1112. };
  1113. static const struct snmp_node *const sensor_subnodes[] = {
  1114. &sensor_table.node.node,
  1115. };
  1116. const struct snmp_tree_node power_treenode = SNMP_CREATE_TREE_NODE(3, power_subnodes);
  1117. const struct snmp_tree_node alarm_treenode = SNMP_CREATE_TREE_NODE(6, alarm_subnodes);
  1118. const struct snmp_tree_node thr_treenode = SNMP_CREATE_TREE_NODE(2, thr_subnodes);
  1119. const struct snmp_tree_node thr_s_treenode = SNMP_CREATE_TREE_NODE(3, thr_s_subnodes);
  1120. const struct snmp_tree_node sensor_treenode = SNMP_CREATE_TREE_NODE(4, sensor_subnodes);
  1121. static const struct snmp_node *const mib2_nodes_dev[] =
  1122. {
  1123. &sysinfo_scalars.node.node,
  1124. &power_treenode.node,
  1125. &alarm_treenode.node,
  1126. &sensor_treenode.node,
  1127. };
  1128. static const struct snmp_node *const mib2_nodes_dev_2[]={
  1129. &thr_treenode.node,
  1130. &thr_s_treenode.node,
  1131. };
  1132. static const struct snmp_tree_node snmp_mib2_root_dev = SNMP_CREATE_TREE_NODE(1, mib2_nodes_dev);
  1133. static const struct snmp_tree_node snmp_mib2_thr_dev = SNMP_CREATE_TREE_NODE(7, mib2_nodes_dev_2);
  1134. static const u32_t prvmib_base_oid[] = SNMP_SMARTPDU_DEVICE_OID;
  1135. static const u32_t thr_base_oid [] = SNMP_SMARTPDU_THR_TABLE_IOD;
  1136. const struct snmp_mib mib2_dev = SNMP_MIB_CREATE(prvmib_base_oid, &snmp_mib2_root_dev.node);
  1137. const struct snmp_mib mib2_th_dev = SNMP_MIB_CREATE(thr_base_oid, &snmp_mib2_thr_dev.node);
  1138. static const struct snmp_mib *dev_mibs[] = {&mib2, &mib2_dev,&mib2_th_dev};
  1139. void snmp_power_alarm_trap(AlarmTrapinfo *data)
  1140. {
  1141. struct snmp_varbind vb={0},vb1={0},vb2={0},vb3={0};
  1142. int a= 1,b=2,c=3;
  1143. const u32_t oid_1[]={1,3,6,1,4,1,2024,2,1};
  1144. const u32_t pduAlarmID_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,2,data->ID};
  1145. const u32_t pduAlarmContext_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,3,data->ID};
  1146. const u32_t pduAlarmDate_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,6,data->ID};
  1147. snmp_oid_assign(&vb.oid, oid_1, LWIP_ARRAYSIZE(oid_1));
  1148. snmp_oid_assign(&vb1.oid, pduAlarmID_oid, LWIP_ARRAYSIZE(pduAlarmID_oid));
  1149. snmp_oid_assign(&vb2.oid, pduAlarmContext_oid, LWIP_ARRAYSIZE(pduAlarmContext_oid));
  1150. snmp_oid_assign(&vb3.oid, pduAlarmDate_oid, LWIP_ARRAYSIZE(pduAlarmDate_oid));
  1151. vb.type = SNMP_ASN1_TYPE_OBJECT_ID;
  1152. vb.value = (void*)&a;
  1153. vb.value_len = 4;
  1154. vb1.type = SNMP_ASN1_TYPE_INTEGER;
  1155. vb1.value = (void*)&data->Alarmid;
  1156. vb1.value_len = 4;
  1157. vb2.type = SNMP_ASN1_TYPE_OCTET_STRING;
  1158. vb2.value = (void*)&data->AlarmContext;
  1159. vb2.value_len = strlen(data->AlarmContext);
  1160. vb3.type = SNMP_ASN1_TYPE_OCTET_STRING;
  1161. vb3.value = (void*)&data->AlarmDate;
  1162. vb3.value_len = strlen(data->AlarmDate);
  1163. vb.next = &vb1;
  1164. vb1.next = &vb2;
  1165. vb2.next = &vb3;
  1166. vb3.prev = &vb2;
  1167. vb2.prev = &vb1;
  1168. vb1.prev = &vb;
  1169. snmp_send_trap_specific(SNMP_GENTRAP_COLDSTART, &vb);
  1170. // snmp_send_trap_specific(SNMP_GENTRAP_COLDSTART, &vb1);
  1171. // snmp_send_trap_specific(SNMP_GENTRAP_COLDSTART, &vb2);
  1172. // snmp_send_trap_specific(SNMP_GENTRAP_COLDSTART, &vb3);
  1173. }
  1174. void snmp_sensor_alarm_trap(AlarmTrapinfo *data)
  1175. {
  1176. struct snmp_varbind vb={0},vb1={0},vb2={0},vb3={0};
  1177. int a= 1,b=2,c=3;
  1178. const u32_t oid_1[]={1,3,6,1,4,1,2024,2,2};
  1179. const u32_t pduAlarmID_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,2, data->ID};
  1180. const u32_t pduAlarmContext_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,3, data->ID};
  1181. const u32_t pduAlarmDate_oid[] = { 1,3,6,1,4,1,2024,1,6,1,1,6,data->ID};
  1182. snmp_oid_assign(&vb.oid, oid_1, LWIP_ARRAYSIZE(oid_1));
  1183. snmp_oid_assign(&vb1.oid, pduAlarmID_oid, LWIP_ARRAYSIZE(pduAlarmID_oid));
  1184. snmp_oid_assign(&vb2.oid, pduAlarmContext_oid, LWIP_ARRAYSIZE(pduAlarmContext_oid));
  1185. snmp_oid_assign(&vb3.oid, pduAlarmDate_oid, LWIP_ARRAYSIZE(pduAlarmDate_oid));
  1186. vb.type = SNMP_ASN1_TYPE_OBJECT_ID;
  1187. vb.value = (void*)&a;
  1188. vb.value_len = 4;
  1189. vb1.type = SNMP_ASN1_TYPE_INTEGER;
  1190. vb1.value = (void*)&data->Alarmid;
  1191. vb1.value_len = 4;
  1192. vb2.type = SNMP_ASN1_TYPE_OCTET_STRING;
  1193. vb2.value = (void*)&data->AlarmContext;
  1194. vb2.value_len = strlen(data->AlarmContext);
  1195. vb3.type = SNMP_ASN1_TYPE_OCTET_STRING;
  1196. vb3.value = (void*)&data->AlarmDate;
  1197. vb3.value_len = strlen(data->AlarmDate);
  1198. vb.next = &vb1;
  1199. vb1.next = &vb2;
  1200. vb2.next = &vb3;
  1201. vb3.prev = &vb2;
  1202. vb2.prev = &vb1;
  1203. vb1.prev = &vb;
  1204. snmp_send_trap_specific(SNMP_GENTRAP_COLDSTART, &vb);
  1205. }
  1206. //MSH_CMD_EXPORT_ALIAS(cmd_snmp_tarp_test, snmp, snmp agent test);
  1207. void netif_event_callback(struct netif *netif) {
  1208. }
  1209. static void mibs_init(void) {
  1210. paras_data_t *para = paras_get();
  1211. // uint16_t len = 0;
  1212. // len= strlen((const char *)snmp_smart.sysdescr);
  1213. // snmp_mib2_set_sysdescr(snmp_smart.sysdescr, &len);
  1214. //
  1215. // len= strlen((const char *)snmp_smart.syscontact);
  1216. // snmp_mib2_set_syscontact(snmp_smart.syscontact, &len, 0);
  1217. //
  1218. // len= strlen((const char *)snmp_smart.sysname);
  1219. // snmp_mib2_set_sysname(snmp_smart.sysname, &len, 0);
  1220. //
  1221. // len= strlen((const char *)snmp_smart.syslocation);
  1222. // snmp_mib2_set_syslocation(snmp_smart.syslocation, &len, 0);
  1223. //
  1224. // snmp_set_device_enterprise_oid(&snmp_smart.device_enterprose_oid);
  1225. snmp_set_auth_traps_enabled(SNMP_AUTH_TRAPS_DISABLED);
  1226. snmp_strap_set();
  1227. // if(para->snmp.trapmode == 1)
  1228. // {
  1229. // ip_addr_t ip_addr={0};
  1230. // if(ipaddr_aton(para->snmp.nms_ip,&ip_addr) == 0)
  1231. // {
  1232. // snmp_trap_dst_enable(0, 1);
  1233. // snmp_trap_dst_ip_set(0, &ip_addr);
  1234. // }else
  1235. // {
  1236. // LOG_E("snmp trap ip error!!!!\n");
  1237. // snmp_trap_dst_enable(0, 0);
  1238. // }
  1239. // }else
  1240. // {
  1241. // snmp_trap_dst_enable(0, 0);
  1242. // }
  1243. snmp_set_mibs(&dev_mibs[0], LWIP_ARRAYSIZE(dev_mibs));
  1244. snmp_set_community("public");
  1245. if(strncmp(para->snmp.publics,"public",strlen("public")))
  1246. {
  1247. snmp_set_community_write("public");
  1248. }else
  1249. {
  1250. snmp_set_community_write("private");
  1251. }
  1252. //snmp_send_trap_specific();
  1253. }
  1254. int snmp2_init(void)
  1255. {
  1256. mibs_init();
  1257. snmp_init();
  1258. return 0;
  1259. }
  1260. void snmp_strap_set(void)
  1261. {
  1262. paras_data_t* para=paras_get();
  1263. if(para->snmp.trapmode == 1)
  1264. {
  1265. ip_addr_t ip_addr={0};
  1266. if(ipaddr_aton(para->snmp.nms_ip,&ip_addr))
  1267. {
  1268. snmp_trap_dst_enable(0, 1);
  1269. snmp_trap_dst_ip_set(0, &ip_addr);
  1270. }else
  1271. {
  1272. LOG_E("snmp trap ip error!!!!\n");
  1273. snmp_trap_dst_enable(0, 0);
  1274. }
  1275. }else
  1276. {
  1277. snmp_trap_dst_enable(0, 0);
  1278. }
  1279. }
  1280. int snmp2_deinit(void)
  1281. {
  1282. return 0;
  1283. }