main.cpp 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697
  1. #include <iostream>
  2. #include "cwmp.nsmap"
  3. #include "httppost.h"
  4. #include "soapcwmpService.h"
  5. #include "plugin/threads.h"
  6. #include <vector>
  7. #include <algorithm>
  8. #include <signal.h>
  9. #include <thread>
  10. #include <fstream>
  11. #include "json.hpp"
  12. #include <mysql++/mysql++.h>
  13. #include <zdb.h>
  14. #define HOST "localhost"
  15. #define USER "acs"
  16. #define PASSWORD "159753"
  17. #define DATABASE "ACS"
  18. #define PORT 3306
  19. using json = nlohmann::json;
  20. //int port = 7547;
  21. int port = 8001;
  22. int POST_handler(struct soap *soap);
  23. struct http_post_handlers http_post_handlers[] = {
  24. {"POST", POST_handler},
  25. {NULL}
  26. };
  27. std::string currentISO8601TimeUTC() {
  28. std::time_t t = std::time(nullptr);
  29. std::ostringstream ss;
  30. ss << std::put_time(std::localtime(&t), "%FT%T %Z");
  31. return ss.str();
  32. }
  33. void handler(int s) {
  34. printf("Sassan Caught SIGPIPE ...\n");
  35. }
  36. void *process_request(void *arg) {
  37. cwmpService *service = (cwmpService *) arg;
  38. THREAD_DETACH(THREAD_ID);
  39. if (service) {
  40. service->serve();
  41. service->destroy(); /* clean up */
  42. delete service;
  43. }
  44. return NULL;
  45. }
  46. //<editor-fold desc="zbx_keys">
  47. std::string zbx_keys[] = {"InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.Uptime",
  48. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_MCS",
  49. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.TX_Power",
  50. "InternetGatewayDevice.DeviceInfo.SoftwareVersion",
  51. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.SINR2",
  52. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.SINR1",
  53. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.RSRP2",
  54. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.RSRQ",
  55. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.RSRQ",
  56. "InternetGatewayDevice.LANDevice.1.LANHostConfigManagement.DHCPServerEnable",
  57. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Setting.Status",
  58. "InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ConnectionStatus",
  59. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.RSRP1",
  60. "InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ExternalIPAddress",
  61. "InternetGatewayDevice.WEB_GUI.Overview.DeviceInfo.IMSI",
  62. "InternetGatewayDevice.WEB_GUI.Overview.DeviceInfo.IMEI",
  63. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.EnodeBId",
  64. "InternetGatewayDevice.DeviceInfo.MemoryStatus.Free",
  65. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.EnodeBId",
  66. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_MCS",
  67. "InternetGatewayDevice.Time.CurrentLocalTime",
  68. "InternetGatewayDevice.DeviceInfo.ProcessStatus.CPUUsage",
  69. "InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.CellId",
  70. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.BytesSent",
  71. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.BytesReceived",
  72. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.PacketsReceived",
  73. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.PacketsSent",
  74. "InternetGatewayDevice.DeviceInfo.UpTime",
  75. "InternetGatewayDevice.DeviceInfo.X_TGT_IMSI",
  76. "InternetGatewayDevice.WEB_GUI.Network.Network_Mode.WANIPAddress",
  77. "InternetGatewayDevice.WEB_GUI.Network.ScanMode.Settings.PCILock",
  78. "InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.DnsServer",
  79. "InternetGatewayDevice.DeviceInfo.HardwareVersion",
  80. "InternetGatewayDevice.DeviceInfo.Manufacturer",
  81. "InternetGatewayDevice.DeviceInfo.ManufacturerOUI",
  82. "InternetGatewayDevice.DeviceInfo.ModelName",
  83. "InternetGatewayDevice.DeviceInfo.ModelNumber",
  84. "InternetGatewayDevice.DeviceInfo.Description",
  85. "InternetGatewayDevice.DeviceInfo.ProductClass",
  86. "InternetGatewayDevice.DeviceInfo.SerialNumber",
  87. "InternetGatewayDevice.LANDevice.1.LANEthernetInterfaceConfig.1.Enable",
  88. "InternetGatewayDevice.LANDevice.1.LANEthernetInterfaceConfig.2.Enable",
  89. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Enable",
  90. "InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.DL_DataRate_Current",
  91. "InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.UL_DataRate_Current",
  92. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.PCI",
  93. "InternetGatewayDevice.WEB_GUI.Overview.LANStatus.MacAddress",
  94. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_Frequency",
  95. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_Frequency",
  96. "InternetGatewayDevice.ManagementServer.ConnectionRequestURL"
  97. };
  98. //</editor-fold>
  99. void ZBX_Send(char **Name, char **Value, char **imsi) {
  100. if (!strcmp(*Name, "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_MCS") == 0 or
  101. !strcmp(*Name, "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_MCS") == 0) {
  102. if (!strcmp(*Value, "QPSK")) {
  103. *Value = "4";
  104. } else if (!strcmp(*Value, "QAM8")) {
  105. *Value = "8";
  106. } else if (!strcmp(*Value, "QAM16")) {
  107. *Value = "16";
  108. } else if (!strcmp(*Value, "QAM32")) {
  109. *Value = "32";
  110. } else if (!strcmp(*Value, "QAM64")) {
  111. *Value = "64";
  112. }
  113. std::ofstream zbx_data;
  114. std::string _time{};
  115. time_t second;
  116. second = time(NULL);
  117. std::stringstream strstream;
  118. strstream << second;
  119. strstream >> _time;
  120. zbx_data.open("/var/tmp/zbx_sender-" + _time, std::ios_base::app);
  121. zbx_data << "IMSI-" << *imsi << " " << *Name << " " << second << " \"" << *Value << "\"" << std::endl;
  122. }
  123. }
  124. std::string url_encode(const std::string &value) {
  125. std::ostringstream escaped;
  126. escaped.fill('0');
  127. escaped << std::hex;
  128. for (std::string::const_iterator i = value.begin(), n = value.end(); i != n; ++i) {
  129. std::string::value_type c = (*i);
  130. // Keep alphanumeric and other accepted characters intact
  131. if (isalnum(c) || c == '-' || c == '_' || c == '.' || c == '~') {
  132. escaped << c;
  133. continue;
  134. }
  135. // Any other characters are percent-encoded
  136. escaped << std::uppercase;
  137. escaped << '%' << std::setw(2) << int((unsigned char) c);
  138. escaped << std::nouppercase;
  139. }
  140. return escaped.str();
  141. }
  142. int main() {
  143. signal(SIGPIPE, handler);
  144. std::cout << "TR069 Server Started on Port " << port << "(1.1.1)...\n" << std::endl;
  145. cwmpService service(SOAP_XML_INDENT);
  146. service.soap->send_timeout = service.soap->recv_timeout = 5;
  147. service.soap->transfer_timeout = 60;
  148. service.soap->keep_alive = 20;
  149. service.soap->tcp_keep_alive = 1;
  150. service.soap->bind_flags |= SO_REUSEADDR;
  151. service.soap->bind_flags |= SO_REUSEPORT;
  152. service.soap->bind_flags |= MSG_NOSIGNAL;
  153. soap_init2(service.soap, SOAP_IO_KEEPALIVE, SOAP_IO_KEEPALIVE);
  154. SOAP_SOCKET m = service.bind(NULL, port, 100); /* master socket */
  155. if (soap_valid_socket(m)) {
  156. while (soap_valid_socket(service.accept())) {
  157. THREAD_TYPE tid;
  158. void *arg = (void *) service.copy();
  159. if (arg)
  160. while (THREAD_CREATE(&tid, (void *(*)(void *)) process_request, arg))
  161. sleep(1);
  162. }
  163. }
  164. service.soap_stream_fault(std::cerr);
  165. service.destroy(); /* clean up */
  166. return 0;
  167. }
  168. int POST_handler(struct soap *soap) {
  169. // struct _cwmp__GetParameterValues *res = soap_new__cwmp__GetParameterValues(soap, -1);
  170. // struct ParameterNames *list = soap_new_ParameterNames(soap, -1);
  171. const char *buf;
  172. size_t len;
  173. buf = soap_http_get_body(soap, &len);
  174. // std::cerr<<"Sassan3 ID: "<<soap->header->cwmp__SupportedCWMPVersions<<std::endl;
  175. // std::cerr<<"Debug1: "<<len<<std::endl;
  176. // std::cerr<<"Debug2: "<<buf<<std::endl;
  177. /* if HTTP has a content type header or a HTTP body is present then return 404 */
  178. if (len == 0) {
  179. std::cerr << "Sassan 204...: " << buf << std::endl;
  180. return 204; // HTTP 400 Bad Request
  181. // }else {
  182. // std::cerr<<"Debug0: "<<buf<<std::endl;
  183. // std::cerr<<"Debug1: "<<len<<std::endl;
  184. // std::cerr<<"Debug2: "<<buf<<std::endl;
  185. }
  186. // if (soap->http_content || soap_http_has_body(soap))
  187. // return 404;
  188. // (void)soap_end_recv(soap);
  189. // /* populate the response with one array item */
  190. // if (res && list)
  191. // {
  192. // list->__size = 1;
  193. // if ((list->__ptrstring = (char**)soap_malloc(soap, list->__size * sizeof(char*))) != NULL)
  194. // {
  195. // list->__ptrstring[0] = soap_strdup(soap, "...");
  196. // res->ParameterNames = list;
  197. // }
  198. // }
  199. // /* send response */
  200. // soap->encodingStyle = "";
  201. // soap_serializeheader(soap);
  202. // soap_serialize__cwmp__GetParameterValues(soap, res);
  203. // if (soap_begin_count(soap))
  204. // return soap->error;
  205. // if (soap->mode & SOAP_IO_LENGTH)
  206. // {
  207. // if (soap_envelope_begin_out(soap)
  208. // || soap_putheader(soap)
  209. // || soap_body_begin_out(soap)
  210. // || soap_put__cwmp__GetParameterValues(soap, res, "cwmp:GetParameterValues", "")
  211. // || soap_body_end_out(soap)
  212. // || soap_envelope_end_out(soap))
  213. // return soap->error;
  214. // };
  215. // if (soap_end_count(soap)
  216. // || soap_response(soap, SOAP_OK)
  217. // || soap_envelope_begin_out(soap)
  218. // || soap_putheader(soap)
  219. // || soap_body_begin_out(soap)
  220. // || soap_put__cwmp__GetParameterValues(soap, res, "cwmp:GetParameterValues", "")
  221. // || soap_body_end_out(soap)
  222. // || soap_envelope_end_out(soap)
  223. // || soap_end_send(soap))
  224. // return soap->error;
  225. // return soap_closesock(soap);
  226. }
  227. int cwmpService::GetParameterNames(struct _cwmp__GetParameterNames *cwmp__GetParameterNames,
  228. struct _cwmp__GetParameterNamesResponse *cwmp__GetParameterNamesResponse) { return SOAP_OK; }
  229. int cwmpService::GetParameterValues(struct _cwmp__GetParameterValues *cwmp__GetParameterValues,
  230. struct _cwmp__GetParameterValuesResponse *cwmp__GetParameterValuesResponse) { return SOAP_OK; }
  231. int cwmpService::SetParameterValues(struct _cwmp__SetParameterValues *cwmp__SetParameterValues,
  232. struct _cwmp__SetParameterValuesResponse *cwmp__SetParameterValuesResponse) { return SOAP_OK; }
  233. int cwmpService::SetParameterAttributes(
  234. struct _cwmp__SetParameterAttributes *cwmp__SetParameterAttributes,
  235. struct _cwmp__SetParameterAttributesResponse *cwmp__SetParameterAttributesResponse) { return SOAP_OK; }
  236. int cwmpService::GetParameterAttributes(struct _cwmp__GetParameterAttributes *cwmp__GetParameterAttributes,
  237. struct _cwmp__GetParameterAttributesResponse *cwmp__GetParameterAttributesResponse) { return SOAP_OK; }
  238. int cwmpService::Download(struct _cwmp__Download *cwmp__Download,
  239. struct _cwmp__DownloadResponse *cwmp__DownloadResponse) { return SOAP_OK; }
  240. int cwmpService::Upload(
  241. struct _cwmp__Upload *cwmp__Upload,
  242. struct _cwmp__UploadResponse *cwmp__UploadResponse) { return SOAP_OK; }
  243. int cwmpService::AddObject(
  244. struct _cwmp__AddObject *cwmp__AddObject,
  245. struct _cwmp__AddObjectResponse *cwmp__AddObjectResponse) { return SOAP_OK; }
  246. int cwmpService::DeleteObject(
  247. struct _cwmp__DeleteObject *cwmp__DeleteObject,
  248. struct _cwmp__DeleteObjectResponse *cwmp__DeleteObjectResponse) { return SOAP_OK; }
  249. int cwmpService::GetRPCMethods(
  250. struct _cwmp__GetRPCMethods *cwmp__GetRPCMethods,
  251. struct _cwmp__GetRPCMethodsResponse *cwmp__GetRPCMethodsResponse) { return SOAP_OK; }
  252. int cwmpService::GetParameterValuesResponse(
  253. struct _cwmp__GetParameterValuesResponse *cwmp__GetParameterValuesResponse) { return SOAP_OK; }
  254. int cwmpService::Inform(struct _cwmp__Inform *cwmp__Inform,
  255. struct _cwmp__InformResponse *cwmp__InformResponse) {
  256. std::string _id = std::string(cwmp__Inform->DeviceId->OUI) + "-" + std::string(cwmp__Inform->DeviceId->ProductClass)
  257. + "-" + std::string(cwmp__Inform->DeviceId->SerialNumber);
  258. std::cerr << "Inform Recieved from: " << url_encode(_id) << " at " << time(NULL) << std::endl;
  259. char *imsi;
  260. char *ip;
  261. auto timestamp = std::chrono::high_resolution_clock::now();
  262. std::vector<std::thread> th;
  263. std::vector<std::thread> th_acs;
  264. // int indexes[24];
  265. std::vector<int> ind;
  266. std::ofstream outfile;
  267. outfile.open("/var/tmp/tr069/" + url_encode(_id), std::ios::out | std::ios::trunc);
  268. std::ofstream mongoData;
  269. time_t second;
  270. std::string _time;
  271. std::map<std::string, std::string> tr069{};
  272. second = time(NULL);
  273. std::stringstream strstream;
  274. strstream << second;
  275. strstream >> _time;
  276. for (int i = 0; i < cwmp__Inform->ParameterList->__size; ++i) {
  277. char *_Name = cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Name;
  278. char *_Value = cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Value;
  279. outfile << _Name << ": " << _Value << std::endl;
  280. if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.X_TGT_IMSI") == 0) {
  281. imsi = _Value;
  282. }
  283. if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.Network_Mode.WANIPAddress") == 0) {
  284. ip = _Value;
  285. }
  286. std::string cpe = cwmp__Inform->DeviceId->SerialNumber;
  287. auto j = std::find(std::begin(zbx_keys), std::end(zbx_keys), _Name);
  288. if (j != std::end(zbx_keys)) {
  289. // th.push_back(std::thread(ZBX_Send, &_Name,&_Value, &imsi));
  290. // ind.push_back(i);
  291. // th.push_back(std::thread(ZBX_Send, &cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Name,
  292. // &cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Value, &imsi));
  293. if (!strcmp(_Name, "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_MCS") == 0 or
  294. !strcmp(_Name, "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_MCS") == 0) {
  295. if (!strcmp(_Value, "QPSK")) {
  296. _Value = "4";
  297. } else if (!strcmp(_Value, "QAM8")) {
  298. _Value = "8";
  299. } else if (!strcmp(_Value, "QAM16")) {
  300. _Value = "16";
  301. } else if (!strcmp(_Value, "QAM32")) {
  302. _Value = "32";
  303. } else if (!strcmp(_Value, "QAM64")) {
  304. _Value = "64";
  305. }
  306. std::ofstream zbx_data;
  307. std::string _time{};
  308. time_t second;
  309. second = time(NULL);
  310. std::stringstream strstream;
  311. strstream << second;
  312. strstream >> _time;
  313. zbx_data.open("/var/tmp/zbx_sender-" + _time, std::ios_base::app);
  314. zbx_data << "IMSI-" << imsi << " " << _Name << " " << second << " \"" << _Value << "\"" << std::endl;
  315. }
  316. //<editor-fold desc="Map Filler">
  317. if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.HardwareVersion") == 0)
  318. tr069.insert({"HardwareVersion", _Value});
  319. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.SoftwareVersion") == 0)
  320. tr069.insert({"SoftwareVersion", _Value});
  321. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.UpTime") == 0)
  322. tr069.insert({"UpTime", _Value});
  323. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Overview.DeviceInfo.IMEI") == 0)
  324. tr069.insert({"IMEI", _Value});
  325. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.X_TGT_IMSI") == 0)
  326. tr069.insert({"IMSI", _Value});
  327. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.MemoryStatus.Free") == 0)
  328. tr069.insert({"Free", _Value});
  329. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.ProcessStatus.CPUUsage") == 0)
  330. tr069.insert({"CPUUsage", _Value});
  331. else if (std::string(_Name).compare("InternetGatewayDevice.Time.CurrentLocalTime") == 0)
  332. tr069.insert({"CurrentLocalTime", _Value});
  333. else if (std::string(_Name).compare(
  334. "InternetGatewayDevice.LANDevice.1.LANEthernetInterfaceConfig.1.Enable") == 0)
  335. tr069.insert({"LAN1Enable", _Value});
  336. else if (std::string(_Name).compare(
  337. "InternetGatewayDevice.LANDevice.1.LANEthernetInterfaceConfig.2.Enable") == 0)
  338. tr069.insert({"LAN2Enable", _Value});
  339. else if (std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.SINR1") == 0)
  340. tr069.insert({"SINR1", _Value});
  341. else if (std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.SINR2") == 0)
  342. tr069.insert({"SINR2", _Value});
  343. else if (std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.EnodeBId") ==
  344. 0)
  345. tr069.insert({"EnodeBId", _Value});
  346. else if (std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.CellId") == 0)
  347. tr069.insert({"CellId", _Value});
  348. else if (std::string(_Name).compare(
  349. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.BytesSent") == 0)
  350. tr069.insert({"BytesSent", _Value});
  351. else if (std::string(_Name).compare(
  352. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.BytesReceived") == 0)
  353. tr069.insert({"BytesReceived", _Value});
  354. else if (std::string(_Name).compare(
  355. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.PacketsSent") == 0)
  356. tr069.insert({"PacketsSent", _Value});
  357. else if (std::string(_Name).compare(
  358. "InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Stats.PacketsReceived") == 0)
  359. tr069.insert({"PacketsReceived", _Value});
  360. else if (std::string(_Name).compare(
  361. "InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ConnectionStatus") == 0)
  362. tr069.insert({"ConnectionStatus", _Value});
  363. else if (std::string(_Name).compare(
  364. "InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.Uptime") == 0)
  365. tr069.insert({"Uptime", _Value});
  366. else if (std::string(_Name).compare(
  367. "InternetGatewayDevice.WANDevice.1.WANConnectionDevice.1.WANIPConnection.1.ExternalIPAddress") == 0)
  368. tr069.insert({"ExternalIPAddress", _Value});
  369. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.RSRP1") == 0)
  370. tr069.insert({"RSRP1", _Value});
  371. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.RSRP2") == 0)
  372. tr069.insert({"RSRP2", _Value});
  373. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.TX_Power") ==
  374. 0)
  375. tr069.insert({"TX_Power", _Value});
  376. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_MCS") == 0)
  377. tr069.insert({"DL_MCS", _Value});
  378. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_MCS") == 0)
  379. tr069.insert({"UL_MCS", _Value});
  380. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Setting.Status") ==
  381. 0)
  382. tr069.insert({"LTEStatus", _Value});
  383. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.ScanMode.Settings.PCILock") == 0)
  384. tr069.insert({"PCILock", _Value});
  385. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.Network_Mode.WANIPAddress") == 0)
  386. tr069.insert({"WANIPAddress", _Value});
  387. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.DnsServer") == 0)
  388. tr069.insert({"DnsServer", _Value});
  389. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Overview.DeviceInfo.IMSI") == 0)
  390. tr069.insert({"IMSI", _Value});
  391. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.Manufacturer") == 0)
  392. tr069.insert({"Manufacturer", _Value});
  393. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.ManufacturerOUI") == 0)
  394. tr069.insert({"OUI", _Value});
  395. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.ModelName") == 0)
  396. tr069.insert({"ModelName", _Value});
  397. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.ModelNumber") == 0)
  398. tr069.insert({"ModelNumber", _Value});
  399. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.Description") == 0)
  400. tr069.insert({"Description", _Value});
  401. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.ProductClass") == 0)
  402. tr069.insert({"ProductClass", _Value});
  403. else if (std::string(_Name).compare("InternetGatewayDevice.DeviceInfo.SerialNumber") == 0)
  404. tr069.insert({"SerialNumber", _Value});
  405. else if (std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.X_TGT_WANNetConfigInfo.RSRQ") == 0)
  406. tr069.insert({"RSRQ", _Value});
  407. else if (std::string(_Name).compare(
  408. "InternetGatewayDevice.LANDevice.1.LANHostConfigManagement.DHCPServerEnable") == 0)
  409. tr069.insert({"DHCPServerEnable", _Value});
  410. else if (
  411. std::string(_Name).compare("InternetGatewayDevice.WANDevice.1.WANEthernetInterfaceConfig.Enable") ==
  412. 0)
  413. tr069.insert({"WANEthernetInterfaceConfigEnable", _Value});
  414. else if (std::string(_Name).compare("InternetGatewayDevice.ManagementServer.ConnectionRequestURL") == 0)
  415. tr069.insert({"ConnectionRequestURL", _Value});
  416. else if (std::string(_Name).compare(
  417. "InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.DL_DataRate_Current") == 0)
  418. tr069.insert({"DL_DataRate_Current", _Value});
  419. else if (std::string(_Name).compare(
  420. "InternetGatewayDevice.WEB_GUI.Overview.LTEStatus.UL_DataRate_Current") == 0)
  421. tr069.insert({"UL_DataRate_Current", _Value});
  422. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.PCI") == 0)
  423. tr069.insert({"PCI", _Value});
  424. else if (std::string(_Name).compare(
  425. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.UL_Frequency") == 0)
  426. tr069.insert({"UL_Frequency", _Value});
  427. else if (std::string(_Name).compare(
  428. "InternetGatewayDevice.WEB_GUI.Network.LTE_Setting.Status.DL_Frequency") == 0)
  429. tr069.insert({"DL_Frequency", _Value});
  430. else if (std::string(_Name).compare("InternetGatewayDevice.WEB_GUI.Overview.LANStatus.MacAddress") == 0)
  431. tr069.insert({"MacAddress", _Value});
  432. // std::cerr<<"Key: "<<cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Name<<std::endl;
  433. // std::cerr<<"Value: "<<cwmp__Inform->ParameterList->__ptrParameterValueStruct[i]->Value<<std::endl;
  434. //</editor-fold>
  435. }
  436. }
  437. //<editor-fold desc="Json">
  438. std::string ISOTime = currentISO8601TimeUTC();
  439. json tr069_json{};
  440. tr069_json["_id"] = url_encode(_id);
  441. tr069_json["_deviceId"]["_Manufacturer"] = cwmp__Inform->DeviceId->Manufacturer;
  442. tr069_json["_deviceId"]["_OUI"] = cwmp__Inform->DeviceId->OUI;
  443. tr069_json["_deviceId"]["_ProductClass"] = cwmp__Inform->DeviceId->ProductClass;
  444. tr069_json["_deviceId"]["_SerialNumber"] = cwmp__Inform->DeviceId->SerialNumber;
  445. tr069_json["_lastInform"] = ISOTime;
  446. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANConnectionDevice"]["1"]["WANIPConnection"]["1"]["Uptime"]["_value"] = tr069["Uptime"];
  447. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["UL_MCS"]["_value"] = tr069["UL_MCS"];
  448. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["TX_Power"]["_value"] = tr069["TX_Power"];
  449. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["SoftwareVersion"]["_value"] = tr069["SoftwareVersion"];
  450. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["SINR2"]["_value"] = tr069["SINR2"];
  451. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["SINR1"]["_value"] = tr069["SINR1"];
  452. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["RSRP2"]["_value"] = tr069["RSRP2"];
  453. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["RSRQ"]["_value"] = tr069["RSRQ"];
  454. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["RSRQ"]["_value"] = tr069["RSRQ"];
  455. tr069_json["InternetGatewayDevice"]["LANDevice"]["1"]["LANHostConfigManagement"]["DHCPServerEnable"]["_value"] = tr069["DHCPServerEnable"];
  456. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Setting"]["Status"]["_value"] = tr069["LTEStatus"];
  457. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANConnectionDevice"]["1"]["WANIPConnection"]["1"]["ConnectionStatus"]["_value"] = tr069["ConnectionStatus"];
  458. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["RSRP1"]["_value"] = tr069["RSRP1"];
  459. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANConnectionDevice"]["1"]["WANIPConnection"]["1"]["ExternalIPAddress"]["_value"] = tr069["ExternalIPAddress"];
  460. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["DeviceInfo"]["IMSI"]["_value"] = tr069["IMSI"];
  461. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["DeviceInfo"]["IMEI"]["_value"] = tr069["IMEI"];
  462. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["EnodeBId"]["_value"] = tr069["EnodeBId"];
  463. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["MemoryStatus"]["Free"]["_value"] = tr069["Free"];
  464. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["EnodeBId"]["_value"] = tr069["EnodeBId"];
  465. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["DL_MCS"]["_value"] = tr069["DL_MCS"];
  466. tr069_json["InternetGatewayDevice"]["Time"]["CurrentLocalTime"]["_value"] = tr069["CurrentLocalTime"];
  467. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["ProcessStatus"]["CPUUsage"]["_value"] = tr069["CPUUsage"];
  468. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["X_TGT_WANNetConfigInfo"]["CellId"]["_value"] = tr069["CellId"];
  469. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANEthernetInterfaceConfig"]["Stats"]["BytesSent"]["_value"] = tr069["BytesSent"];
  470. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANEthernetInterfaceConfig"]["Stats"]["BytesReceived"]["_value"] = tr069["BytesReceived"];
  471. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANEthernetInterfaceConfig"]["Stats"]["PacketsReceived"]["_value"] = tr069["PacketsReceived"];
  472. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANEthernetInterfaceConfig"]["Stats"]["PacketsSent"]["_value"] = tr069["PacketsSent"];
  473. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["UpTime"]["_value"] = tr069["UpTime"];
  474. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["X_TGT_IMSI"]["_value"] = tr069["IMSI"];
  475. tr069_json["InternetGatewayDevice"]["LANDevice"]["1"]["LANEthernetInterfaceConfig"]["1"]["Enable"]["_value"] = tr069["Enable"];
  476. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["Network_Mode"]["WANIPAddress"]["_value"] = tr069["WANIPAddress"];
  477. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["ScanMode"]["Settings"]["PCILock"]["_value"] = tr069["PCILock"];
  478. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["LTEStatus"]["DnsServer"]["_value"] = tr069["DnsServer"];
  479. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["HardwareVersion"]["_value"] = tr069["HardwareVersion"];
  480. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["Manufacturer"]["_value"] = cwmp__Inform->DeviceId->Manufacturer;
  481. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["ManufacturerOUI"]["_value"] = cwmp__Inform->DeviceId->OUI;
  482. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["ModelName"]["_value"] = tr069["ModelName"];
  483. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["ModelNumber"]["_value"] = tr069["ModelNumber"];
  484. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["Description"]["_value"] = tr069["Description"];
  485. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["ProductClass"]["_value"] = cwmp__Inform->DeviceId->ProductClass;
  486. tr069_json["InternetGatewayDevice"]["DeviceInfo"]["SerialNumber"]["_value"] = cwmp__Inform->DeviceId->SerialNumber;
  487. tr069_json["InternetGatewayDevice"]["LANDevice"]["1"]["LANEthernetInterfaceConfig"]["1"]["Enable"]["_value"] = tr069["LAN1Enable"];
  488. tr069_json["InternetGatewayDevice"]["LANDevice"]["1"]["LANEthernetInterfaceConfig"]["2"]["Enable"]["_value"] = tr069["LAN2Enable"];
  489. tr069_json["InternetGatewayDevice"]["ManagementServer"]["ConnectionRequestURL"]["_value"] = tr069["ConnectionRequestURL"];
  490. tr069_json["InternetGatewayDevice"]["WANDevice"]["1"]["WANEthernetInterfaceConfig"]["Enable"]["_value"] = tr069["WANEthernetInterfaceConfigEnable"];
  491. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["LTEStatus"]["DL_DataRate_Current"]["_value"] = tr069["DL_DataRate_Current"];
  492. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["LTEStatus"]["UL_DataRate_Current"]["_value"] = tr069["UL_DataRate_Current"];
  493. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["PCI"]["_value"] = tr069["PCI"];
  494. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Overview"]["LANStatus"]["MacAddress"]["_value"] = tr069["MacAddress"];
  495. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["DL_Frequency"]["_value"] = tr069["DL_Frequency"];
  496. tr069_json["InternetGatewayDevice"]["WEB_GUI"]["Network"]["LTE_Setting"]["Status"]["UL_Frequency"]["_value"] = tr069["UL_Frequency"];
  497. //</editor-fold>
  498. mysqlpp::Connection conn(false);
  499. mysqlpp::Query query = conn.query();
  500. try {
  501. conn.connect(DATABASE, HOST, USER, PASSWORD, PORT);
  502. query << "replace into Device_List values ('" + std::string(ip) + "','" + imsi + "',NOW()" + ")";
  503. query.execute();
  504. } catch (mysqlpp::BadQuery er) { // handle any connection or
  505. std::cerr << "Error on IMSI-" << imsi << " :" << er.what() << std::endl;
  506. }
  507. conn.disconnect();
  508. std::ofstream json_data;
  509. // time_t second;
  510. second = time(NULL);
  511. strstream << second;
  512. strstream >> _time;
  513. json_data.open("/var/tmp/json_data/" + url_encode(_id) + "_" + _time, std::ios_base::app);
  514. json_data << tr069_json.dump(4);
  515. //
  516. // for(auto elem : tr069)
  517. // {
  518. // std::cerr<<elem.first<<"\t"<<elem.second<<std::endl;
  519. // }
  520. // std::cerr<< "Size: "<<tr069.size()<<std::endl;
  521. return SOAP_OK;
  522. }
  523. int cwmpService::FactoryReset(struct _cwmp__FactoryReset *cwmp__factoryReset,
  524. struct _cwmp__FactoryResetResponse *cwmp__factoryResetResponse) { return SOAP_OK; }
  525. int cwmpService::Reboot(struct _cwmp__Reboot *cwmp__Reboot,
  526. struct _cwmp__RebootResponse *cwmp__RebootResponse) { return SOAP_OK; }
  527. int cwmpService::CheckQueue(struct soap *soap, cwmpService *cwmpService1) {
  528. // std::cerr << "IP: " << soap->host << std::endl;
  529. soap->error = 0;
  530. std::string IMSI{}, s, id;
  531. const char *_actionParameters = "";
  532. int action{0};
  533. /*
  534. * {
  535. "FileType":"1",
  536. "URL":"http://172.20.9.24:808/ZLT_P11S_P13-NO_LOGO-P11PLUS-EN_48.3_update_file-all_2019_12_19_20_21_02.zip",
  537. "FilesSize":"4367707",
  538. "SuccessURL":null,
  539. "FailureURL":null
  540. }
  541. */
  542. std::stringstream strValue;
  543. json actionParameters = {};
  544. mysqlpp::Connection conn(false);
  545. mysqlpp::Query query = conn.query();
  546. mysqlpp::Query _query = conn.query();
  547. try {
  548. conn.connect(DATABASE, HOST, USER, PASSWORD, PORT);
  549. query
  550. << "select t.id, d.IMSI , t.action , t.ActionParameters from TaskList as t join Device_List as d on t.IMSI=d.IMSI where d.IP='"
  551. << soap->host << "' and t.response is null and t.Active=0 order by id limit 1;";
  552. mysqlpp::StoreQueryResult result = query.store();
  553. if (result.size() == 0)
  554. return soap->error = 204;
  555. mysqlpp::StoreQueryResult::const_iterator it;
  556. for (it = result.begin(); it != result.end(); ++it) {
  557. mysqlpp::Row row = *it;
  558. strValue << row["id"];
  559. strValue >> id;
  560. strValue << row["IMSI"];
  561. strValue >> IMSI;
  562. action = row["action"];
  563. _actionParameters = row["ActionParameters"];
  564. }
  565. // std::cerr<<"Size of result+: "<<result.size()<<std::endl;
  566. s = std::string(_actionParameters);
  567. _query << "update TaskList set Active=1 where id='" << id << "';";
  568. _query.execute();
  569. } catch (mysqlpp::BadQuery er) { // handle any connection or
  570. std::cerr << "Error on CPE with IP: " << soap->host << " :" << er.what() << std::endl;
  571. }
  572. conn.disconnect();
  573. actionParameters = json::parse(s);
  574. if (action == 1) {
  575. try {
  576. // std::cerr << actionParameters.dump(4) << std::endl;
  577. int DelaySeconds = 1;
  578. std::string str = actionParameters["FileType"];
  579. char *FileType = new char[str.length() + 1];
  580. strcpy(FileType, str.c_str());
  581. str = actionParameters["URL"];
  582. char *URL = new char[str.length() + 1];
  583. strcpy(URL, str.c_str());
  584. char *Username = NULL;
  585. char *Password = NULL;
  586. int FileSize = std::stoi(std::string(actionParameters["FilesSize"]));
  587. char *TargetFileName = NULL;
  588. str = actionParameters["SuccessURL"];
  589. char *SuccessURL = new char[str.length() + 1];
  590. strcpy(SuccessURL, str.c_str());
  591. str = actionParameters["FailureURL"];
  592. char *FailureURL = new char[str.length() + 1];
  593. strcpy(FailureURL, str.c_str());
  594. return CustomeDownload(soap, this, DelaySeconds, FileType, URL, Username, Password, FileSize, TargetFileName,
  595. SuccessURL, FailureURL);
  596. } catch (std::exception ex) { // handle any connection or
  597. std::cerr << "Error on CPE with IP: " << soap->host << " :" << ex.what() << std::endl;
  598. }
  599. }
  600. //
  601. // return CustomeDownload(soap, this, std::__cxx11::string(), std::__cxx11::string(), std::__cxx11::string(),
  602. // std::__cxx11::string(), std::__cxx11::string(), std::__cxx11::string(),
  603. // std::__cxx11::string(),
  604. // std::__cxx11::string(), std::__cxx11::string());
  605. // return soap_closesock(soap);
  606. return soap->error = 204;
  607. }
  608. int cwmpService::CustomeDownloadResponse(struct soap *pSoap, cwmpService *pService) {
  609. std::cerr << "Upgrade Response recieved." << std::endl;
  610. soap->error = 0;
  611. mysqlpp::Connection conn(false);
  612. mysqlpp::Query _query = conn.query();
  613. _query << "update TaskList set Active=1 where id='" << "';";
  614. _query.execute();
  615. // struct _cwmp__DownloadResponse cwmp__downloadResponse;
  616. // if ((soap->mode & SOAP_IO_LENGTH)) {
  617. // if (soap_envelope_begin_out(soap)
  618. // || soap_putheader(soap)
  619. // || soap_body_begin_out(soap)
  620. // || soap_put__cwmp__DownloadResponse(soap, &cwmp__downloadResponse, "cwmp:DownloadResponse", "")
  621. // || soap_body_end_out(soap)
  622. // || soap_envelope_end_out(soap))
  623. // return soap->error;
  624. // };
  625. // if (soap_end_count(soap)
  626. // || soap_response(soap, SOAP_OK)
  627. // || soap_envelope_begin_out(soap)
  628. // || soap_putheader(soap)
  629. // || soap_body_begin_out(soap)
  630. // || soap_put__cwmp__DownloadResponse(soap, &cwmp__downloadResponse, "cwmp:DownloadResponse", "")
  631. // || soap_body_end_out(soap)
  632. // || soap_envelope_end_out(soap)
  633. // || soap_end_send(soap))
  634. // return soap->error;
  635. soap->keep_alive = 0;
  636. return soap_closesock(soap);
  637. }