snmp.c 40 KB

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