function_helper.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939
  1. <?php
  2. /*
  3. ** 通用函数helper
  4. */
  5. //移除空参数
  6. function remove_null_params($data = array()) {
  7. foreach ($data as $key => $value) {
  8. if ($value === NULL || $value === '') {
  9. unset($data[$key]);
  10. }
  11. }
  12. return $data;
  13. }
  14. // 通过pm2.5获取aqi的值
  15. function get_aqi_and_level_by_pm25($pm25){
  16. if ($pm25 < 35) { // 很好
  17. $aqi = 50 / 35 * $pm25;
  18. }elseif ($pm25 >= 35 && $pm25 < 75) { // 好
  19. $aqi = 50 / 40 * ($pm25 - 35) + 50;
  20. }elseif ($pm25 >= 75 && $pm25 < 115) { // 一般
  21. $aqi = 50 / 40 * ($pm25 - 75) + 100;
  22. }elseif ($pm25 >= 115 && $pm25 < 150) { // 较差
  23. $aqi = 50 / 35 * ($pm25 - 115) + 150;
  24. }elseif ($pm25 >= 150 && $pm25 < 250) { // 差
  25. $aqi = 100 / 100 * ($pm25 - 150) + 200;
  26. }elseif ($pm25 >= 250 && $pm25 < 350) { // 很差
  27. $aqi = 100 / 100 * ($pm25 - 250) + 300;
  28. }elseif ($pm25 >= 350) { // 非常差
  29. $aqi = 100 / 150 * ($pm25 - 350) + 400;
  30. }
  31. $level = get_aqi_str($aqi);
  32. return array('aqi'=>round($aqi),'level'=>$level);
  33. }
  34. function get_aqi_str($aqi){
  35. if ($aqi < 50) { // 很好
  36. $level = 'Very good';
  37. }elseif ($aqi >= 50 && $aqi < 100) { // 好
  38. $level = 'Good';
  39. }elseif ($aqi >= 100 && $aqi < 150) { // 一般
  40. $level = 'Commonly';
  41. }elseif ($aqi >= 150 && $aqi < 200) { // 较差
  42. $level = 'Poor';
  43. }elseif ($aqi >= 200 && $aqi < 300) { // 差
  44. $level = 'Difference';
  45. }elseif ($aqi >= 300 && $aqi < 400) { // 很差
  46. $level = 'Very bad';
  47. }elseif ($aqi >= 400) { // 非常差
  48. $level = 'Very bad';
  49. }
  50. return $level;
  51. }
  52. // modbus crc 16 校验码计算
  53. function crc16($string) {
  54. $crc = 0xFFFF;
  55. for ($x = 0; $x < strlen ($string); $x++) {
  56. $crc = $crc ^ ord($string[$x]);
  57. for ($y = 0; $y < 8; $y++) {
  58. if (($crc & 0x0001) == 0x0001) {
  59. $crc = (($crc >> 1) ^ 0xA001);
  60. } else { $crc = $crc >> 1; }
  61. }
  62. }
  63. $crc = strval(base_convert($crc, 10, 16));
  64. $crc = substr('0000'.$crc, -4);
  65. return substr($crc, -2).substr($crc, 0,2);
  66. }
  67. function crc_result($cmd){
  68. $begin = pack('H*',substr($cmd, 0,2));
  69. for ($i=0; $i < intval(strlen($cmd) / 2) - 1; $i++) {
  70. $begin = $begin ^ pack('H*',substr($cmd, $i*2+2,2));
  71. }
  72. $begin = unpack('H*', $begin);
  73. return substr('00'.$begin[1], -2);
  74. }
  75. function mqttCmd($sendTopic,$backTopic,$sendData,$timeout = 5,$seq = ''){
  76. require_once './application/libraries/Mqtt.php';
  77. // 订阅信息,接收一个信息后退出
  78. $CI =& get_instance();
  79. $server = $CI->config->item('WIFIMqttServer');
  80. $port = $CI->config->item('WIFIMqttPort');
  81. $username = $CI->config->item('WIFIMqttUsername');
  82. $password = $CI->config->item('WIFIMqttPassword');
  83. $client_id = time().rand(100000,999999); // 设置你的连接客户端id
  84. $mqtt = new Mqtt($server, $port, $client_id);
  85. if($mqtt->connect(true, NULL, $username, $password)) { //链接不成功再重复执行监听连接
  86. $mqtt->publish($sendTopic, $sendData, 0);
  87. // $mqtt->publish('/WEGW/ReadIn/865860046894466', pack('H*','010AA00B'), 2);
  88. }else{
  89. return '';
  90. }
  91. $topics[$backTopic] = array("qos" => 0,"function" => "procmsg");
  92. // $topics['/WEGW/ReadOut/865860046894466'] = array("qos" => 2, "function" => "procmsg");
  93. // 订阅主题
  94. $mqtt->subscribe($topics, 0);
  95. $true = 1;
  96. $t = time();
  97. while($true == 1){
  98. $true = $mqtt->proc();
  99. if (!empty($seq) && $true != 1){
  100. $res = unpack('H*', $true['msg']);
  101. if (substr($res[1], 0,4) != strtolower($seq) && substr(substr($res[1], 0,4), -2).substr(substr($res[1], 0,4), 0,2) != strtolower($seq)) $true = 1;
  102. }
  103. if (time() - $t >= $timeout) {
  104. return '';
  105. }
  106. }
  107. $mqtt->close();
  108. return $true;
  109. }
  110. function get_seq(){
  111. $seq = rand(0,100000000);
  112. $seq = base_convert($seq, 10, 16);
  113. return substr('0000'.$seq, -4);
  114. }
  115. function get_check_sum($data){
  116. $sum = 0;
  117. for ($i=0; $i < strlen($data)/2; $i++) {
  118. $sum += base_convert(substr($data, $i*2,2), 16, 10);
  119. }
  120. $sum = base_convert($sum, 10, 16);
  121. $sum = substr('00'.$sum, -2);
  122. return $sum;
  123. }
  124. // 设置时区
  125. function set_timezone($date,$timezone){
  126. $time = strtotime($date) + $timezone*3600;
  127. return date('Y-m-d H:i:s',$time);
  128. }
  129. //小时数
  130. function secToTime($times){
  131. $result = '00';
  132. if ($times>0) {
  133. $hour = floor($times/3600);
  134. $minute = floor(($times-3600 * $hour)/60);
  135. $second = floor((($times-3600 * $hour) - 60 * $minute) % 60);
  136. $result = $hour;
  137. }
  138. return $result;
  139. }
  140. // 发送邮件
  141. function send_email($to,$msg,$title = '维修通知'){
  142. // $this->load->library('Smtp');
  143. require_once FCPATH.'application/libraries/Smtp.php';
  144. //******************** 配置信息 ********************************
  145. $CI =& get_instance();
  146. $config = $CI->config->config['email'];
  147. $smtpserver = $config['smtp_host'];//SMTP服务器
  148. $smtpserverport = $config['smtp_port'];//SMTP服务器端口
  149. $smtpusermail = $config['user_email'];//SMTP服务器的用户邮箱
  150. $smtpemailto = $to;//发送给谁
  151. $smtpuser = $config['smtp_user'];//SMTP服务器的用户帐号,注:部分邮箱只需@前面的用户名
  152. $smtppass = $config['smtp_pass'];//SMTP服务器的用户密码
  153. $mailtitle = $title;//邮件主题
  154. $mailcontent = $msg;//邮件内容
  155. $mailtype = "HTML";//邮件格式(HTML/TXT),TXT为文本邮件
  156. //************************ 配置信息 ****************************
  157. $smtp = new Smtp($smtpserver,$smtpserverport,true,$smtpuser,$smtppass);//这里面的一个true是表示使用身份验证,否则不使用身份验证.
  158. $smtp->debug = false;//是否显示发送的调试信息
  159. return $smtp->sendmail($smtpemailto, $smtpusermail, $mailtitle, $mailcontent, $mailtype);
  160. }
  161. /**
  162. * 获取密码安全等级
  163. * @param string $password 密码
  164. * @return int 0:低,1:中,2:高
  165. */
  166. function get_password_level($password){
  167. if(preg_match('/^([0-9]{6,16})$/',$password)){
  168. return 0;
  169. } else if (preg_match('/^[0-9 a-z]{6,16}$/',$password)){
  170. return 1;
  171. } else if (preg_match('/^[0-9 a-z A-Z !@#$%^&*]{6,16}$/',$password)) {
  172. return 2;
  173. }
  174. return 0;
  175. }
  176. // 天气信息翻译
  177. function weather_translate_en($code){
  178. $data = array(
  179. '100' => 'Sunny/Clear',
  180. '101' => 'Cloudy',
  181. '102' => 'Few Clouds',
  182. '103' => 'Partly Cloudy',
  183. '104' => 'Overcast',
  184. '200' => 'Windy',
  185. '201' => 'Calm',
  186. '202' => 'Light Breeze',
  187. '203' => 'Moderate/Gentle Breeze',
  188. '204' => 'Fresh Breeze',
  189. '205' => 'Strong Breeze',
  190. '206' => 'High Wind, Near Gale',
  191. '207' => 'Gale',
  192. '208' => 'Strong Gale',
  193. '209' => 'Storm',
  194. '210' => 'Violent Storm',
  195. '211' => 'Hurricane',
  196. '212' => 'Tornado',
  197. '213' => 'Tropical Storm',
  198. '300' => 'Shower Rain',
  199. '301' => 'Heavy Shower Rain',
  200. '302' => 'Thundershower',
  201. '303' => 'Heavy Thunderstorm',
  202. '304' => 'Thundershower with hail',
  203. '305' => 'Light Rain',
  204. '306' => 'Moderate Rain',
  205. '307' => 'Heavy Rain',
  206. '308' => 'Extreme Rain',
  207. '309' => 'Drizzle Rain',
  208. '310' => 'Storm',
  209. '311' => 'Heavy Storm',
  210. '312' => 'Severe Storm',
  211. '313' => 'Freezing Rain',
  212. '314' => 'Light to moderate rain',
  213. '315' => 'Moderate to heavy rain',
  214. '316' => 'Heavy rain to storm',
  215. '317' => 'Storm to heavy storm',
  216. '318' => 'Heavy to severe storm',
  217. '399' => 'Rain',
  218. '400' => 'Light Snow',
  219. '401' => 'Moderate Snow',
  220. '402' => 'Heavy Snow',
  221. '403' => 'Snowstorm',
  222. '404' => 'Sleet',
  223. '405' => 'Rain And Snow',
  224. '406' => 'Shower Snow',
  225. '407' => 'Snow Flurry',
  226. '408' => 'Light to moderate snow',
  227. '409' => 'Moderate to heavy snow',
  228. '410' => 'Heavy snow to snowstorm',
  229. '499' => 'Snow',
  230. '500' => 'Mist',
  231. '501' => 'Foggy',
  232. '502' => 'Haze',
  233. '503' => 'Sand',
  234. '504' => 'Dust',
  235. '507' => 'Duststorm',
  236. '508' => 'Sandstorm',
  237. '509' => 'Dense fog',
  238. '510' => 'Strong fog',
  239. '511' => 'Moderate haze',
  240. '512' => 'Heavy haze',
  241. '513' => 'Severe haze',
  242. '514' => 'Heavy fog',
  243. '515' => 'Extra heavy fog',
  244. '900' => 'Hot',
  245. '901' => 'Cold',
  246. '999' => 'Unknown',
  247. );
  248. return isset($data[$code]) ? $data[$code] : '';
  249. }
  250. function weather_translate_cn($code){
  251. $data = array(
  252. '100' => '晴',
  253. '101' => '多云',
  254. '102' => '少云',
  255. '103' => '晴间多云',
  256. '104' => '阴',
  257. '200' => '有风',
  258. '201' => '平静',
  259. '202' => '微风',
  260. '203' => '和风',
  261. '204' => '清风',
  262. '205' => '强风/劲风',
  263. '206' => '疾风',
  264. '207' => '大风',
  265. '208' => '烈风',
  266. '209' => '风暴',
  267. '210' => '狂爆风',
  268. '211' => '飓风',
  269. '212' => '龙卷风',
  270. '213' => '热带风暴',
  271. '300' => '阵雨',
  272. '301' => '强阵雨',
  273. '302' => '雷阵雨',
  274. '303' => '强雷阵雨',
  275. '304' => '雷阵雨伴有冰雹',
  276. '305' => '小雨',
  277. '306' => '中雨',
  278. '307' => '大雨',
  279. '308' => '极端降雨',
  280. '309' => '毛毛雨/细雨',
  281. '310' => '暴雨',
  282. '311' => '大暴雨',
  283. '312' => '特大暴雨',
  284. '313' => '冻雨',
  285. '314' => '小到中雨',
  286. '315' => '中到大雨',
  287. '316' => '大到暴雨',
  288. '317' => '暴雨到大暴雨',
  289. '318' => '大暴雨到特大暴雨',
  290. '399' => '雨',
  291. '400' => '小雪',
  292. '401' => '中雪',
  293. '402' => '大雪',
  294. '403' => '暴雪',
  295. '404' => '雨夹雪',
  296. '405' => '雨雪天气',
  297. '406' => '阵雨夹雪',
  298. '407' => '阵雪',
  299. '408' => '小到中雪',
  300. '409' => '中到大雪',
  301. '410' => '大到暴雪',
  302. '499' => '雪',
  303. '500' => '薄雾',
  304. '501' => '雾',
  305. '502' => '霾',
  306. '503' => '扬沙',
  307. '504' => '浮尘',
  308. '507' => '沙尘暴',
  309. '508' => '强沙尘暴',
  310. '509' => '浓雾',
  311. '510' => '强浓雾',
  312. '511' => '中度霾',
  313. '512' => '重度霾',
  314. '513' => '严重霾',
  315. '514' => '大雾',
  316. '515' => '特强浓雾',
  317. '900' => '热',
  318. '901' => '冷',
  319. '999' => '未知',
  320. );
  321. return isset($data[$code]) ? $data[$code] : '';
  322. }
  323. function weather_translate_ru($code){
  324. $data = array(
  325. '100' => 'чинг',
  326. '101' => 'облачно',
  327. '102' => 'Меньше облако',
  328. '103' => 'Ясная и облачная',
  329. '104' => 'инь',
  330. '200' => 'дует',
  331. '201' => 'спокойствие',
  332. '202' => 'ветерок',
  333. '203' => 'зефир',
  334. '204' => 'Свежий ветер',
  335. '205' => 'Сильный ветер/сильный ветер',
  336. '206' => 'шквал',
  337. '207' => 'ветер',
  338. '208' => 'шторм',
  339. '209' => 'шторм',
  340. '210' => 'Сильный ветер',
  341. '211' => 'ураган',
  342. '212' => 'Торнадо',
  343. '213' => 'Тропический шторм',
  344. '300' => 'ливень',
  345. '301' => 'Сильный душ',
  346. '302' => 'Грозовой дождь',
  347. '303' => 'Сильный грозовой дождь',
  348. '304' => 'Ливень сопровождается градом',
  349. '305' => 'дождик',
  350. '306' => 'Средний дождь',
  351. '307' => 'дождь',
  352. '308' => 'Экстремальный дождь',
  353. '309' => 'Дождик/мелкий дождь',
  354. '310' => 'Проливной дождь',
  355. '311' => 'Сильный дождь',
  356. '312' => 'Сильный ливень',
  357. '313' => 'Ледяной дождь',
  358. '314' => 'Немного дождя',
  359. '315' => 'Под дождём',
  360. '316' => 'Большой до грозы',
  361. '317' => 'От грозы до грозы',
  362. '318' => 'Сильные ливни, сильные ливни',
  363. '399' => 'дождь',
  364. '400' => 'Мелкий снежок',
  365. '401' => 'средний снег',
  366. '402' => 'снегопад',
  367. '403' => 'Снежная буря',
  368. '404' => 'Дождь и снег',
  369. '405' => 'Дождливая и снежная погода',
  370. '406' => 'Дождь и снег',
  371. '407' => 'снежный',
  372. '408' => 'Маленький до снега',
  373. '409' => 'Прямо в снег',
  374. '410' => 'От большой до снежной бури',
  375. '499' => 'снег',
  376. '500' => 'дымка',
  377. '501' => 'туман',
  378. '502' => 'мгла',
  379. '503' => 'янша',
  380. '504' => 'пыль',
  381. '507' => 'Песчаная буря',
  382. '508' => 'Сильная песчаная буря',
  383. '509' => 'Густой туман',
  384. '510' => 'Сильный густой туман',
  385. '511' => 'Умеренный туман',
  386. '512' => 'Тяжелая смола',
  387. '513' => 'Туман',
  388. '514' => 'Сильный туман',
  389. '515' => 'Густой туман',
  390. '900' => 'горячая',
  391. '901' => 'холодно',
  392. '999' => 'неизвестный',
  393. );
  394. return isset($data[$code]) ? $data[$code] : '';
  395. }
  396. //输出json
  397. function json_result($code, $msg, $data = array()) {
  398. $res = array('code' => $code,'msg' => $msg,'data' => $data);
  399. $CI =& get_instance();
  400. $clientId = $CI->input->post('clientId',true);
  401. if (!empty($clientId)) {
  402. if (is_array($res['data']) && !isset($res['data']['status'])) {
  403. $res['data']['status'] = 2;
  404. }else{
  405. $res['data'] = array('status'=>2);
  406. }
  407. exit(send_websocket($clientId,$res));
  408. }else{
  409. echo json_encode($res);
  410. }
  411. }
  412. // 获取jwt的token值
  413. function get_jwt_token(){
  414. $CI =& get_instance();
  415. $CI->load->library('Jwt');
  416. $payload=array("iss"=>"chirpstack-application-server","aud"=>"chirpstack-application-server","nbf"=>time()-60, "exp"=>time()+7200,'sub'=>'user','username'=>'admin');
  417. return $CI->jwt->getToken($payload);
  418. }
  419. //发送命令到server
  420. function send_cmd($cmd, $timeout = 30, $ms_timeout = 200) {
  421. $CI =& get_instance();
  422. $host = $CI->config->item('cmd_server');
  423. $ip = $host['ip'];
  424. $port = $host['port'];
  425. $client = @stream_socket_client("tcp://{$ip}:{$port}", $errno, $errstr, 30);
  426. if ($client) {
  427. fwrite($client, $cmd);
  428. stream_set_timeout($client, $timeout, $ms_timeout);
  429. $result = fread($client, 8196);
  430. fclose($client);
  431. return $result;
  432. } else {
  433. return false;
  434. }
  435. }
  436. /**
  437. * 模拟post进行url请求
  438. * @param string $url
  439. * @param string $param
  440. */
  441. function request_post($url = '', $data = '',$header=array(),$timeout = 30) {
  442. $tuCurl = curl_init();
  443. //参数
  444. curl_setopt($tuCurl, CURLOPT_URL,$url);
  445. curl_setopt($tuCurl, CURLOPT_POSTFIELDS, $data);
  446. curl_setopt($tuCurl, CURLOPT_SSL_VERIFYPEER, false);
  447. // curl_setopt($tuCurl, CURLOPT_SSL_VERIFYHOST, false);
  448. curl_setopt($tuCurl, CURLOPT_SSLVERSION, 1);
  449. curl_setopt($tuCurl, CURLOPT_RETURNTRANSFER, 1);
  450. curl_setopt($tuCurl, CURLOPT_TIMEOUT, $timeout);
  451. if (!empty($header)) {
  452. curl_setopt($tuCurl, CURLOPT_HTTPHEADER, $header);
  453. }
  454. $tuData = curl_exec($tuCurl);
  455. curl_close($tuCurl);
  456. return $tuData;
  457. }
  458. // 通过时区获取当地时间
  459. function get_time_by_timezone($timezone){
  460. $time = strtotime(gmdate("Y-m-d H:i:s"));
  461. return date('Y-m-d H:i:s',$time + $timezone*3600);
  462. }
  463. // 文件下载
  464. function file_download($filePath){
  465. $file_name = basename($filePath); //下载文件名
  466. //检查文件是否存在
  467. if (! file_exists ( $filePath )) {
  468. exit (json_result('0012','找不到文件',array()));
  469. } else {
  470. //打开文件
  471. $file = fopen ( $filePath, "r" );
  472. //输入文件标签
  473. Header ( "Content-type: application/octet-stream" );
  474. Header ( "Accept-Ranges: bytes" );
  475. Header ( "Accept-Length: " . filesize ( $filePath) );
  476. Header ( "Content-Disposition: attachment; filename=" . $file_name );
  477. //输出文件内容
  478. //读取文件内容并直接输出到浏览器
  479. echo fread ( $file, filesize ( $filePath ) );
  480. fclose ( $file );
  481. exit ();
  482. }
  483. }
  484. /**
  485. * 模拟get进行url请求
  486. * @param string $url
  487. */
  488. function http_get($url,$header = array()) {
  489. $ch = curl_init();
  490. curl_setopt($ch, CURLOPT_URL, $url);
  491. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  492. curl_setopt($ch, CURLOPT_HEADER, 0);
  493. if (!empty($header)) {
  494. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  495. }
  496. // curl_setopt($ch, CURLOPT_TIMEOUT_MS, 1);
  497. $result = curl_exec($ch);
  498. curl_close($ch);
  499. return $result;
  500. }
  501. //截取字符串
  502. function cut_str($string, $length, $append=true) {
  503. if(strlen($string) <= $length ) {
  504. return $string;
  505. } else {
  506. $i = 0;
  507. while ($i < $length) {
  508. $stringTMP = substr($string,$i,1);
  509. if ( ord($stringTMP) >=224 ) {
  510. $stringTMP = substr($string,$i,3);
  511. $i = $i + 3;
  512. } elseif( ord($stringTMP) >=192 ) {
  513. $stringTMP = substr($string,$i,2);
  514. $i = $i + 2;
  515. } else {
  516. $i = $i + 1;
  517. }
  518. $stringLast[] = $stringTMP;
  519. }
  520. $stringLast = implode("",$stringLast);
  521. if($append) {
  522. $stringLast .= "...";
  523. }
  524. return $stringLast;
  525. }
  526. }
  527. //填充数组不存在的键值对
  528. function fillUnsetData($array, $length) {
  529. for ($i=1; $i <= $length; $i++) {
  530. if (!isset($array[$i])) {
  531. $array[$i] = '';
  532. }
  533. }
  534. return $array;
  535. }
  536. //查找数组第一个元素的key
  537. function findFirstKey($array) {
  538. foreach ($array as $k => $v){
  539. return $k;
  540. }
  541. }
  542. function doAsyncRequest($url, $param=array()){
  543. $urlinfo = parse_url($url);
  544. $host = $urlinfo['host'];
  545. $path = $urlinfo['path'];
  546. $query = isset($param)? http_build_query($param) : '';
  547. $port = 80;
  548. $errno = 0;
  549. $errstr = '';
  550. $timeout = 10;
  551. $fp = fsockopen($host, $port, $errno, $errstr, $timeout);
  552. $out = "POST ".$path." HTTP/1.1\r\n";
  553. $out .= "host:".$host."\r\n";
  554. $out .= "content-length:".strlen($query)."\r\n";
  555. $out .= "content-type:application/x-www-form-urlencoded\r\n";
  556. $out .= "connection:close\r\n\r\n";
  557. $out .= $query;
  558. fputs($fp, $out);
  559. fclose($fp);
  560. }
  561. function send_websocket($clientid,$data = array(),$resType='cmd')
  562. {
  563. if (!empty($clientid)) {
  564. $CI =& get_instance();
  565. $CI->db->insert('message',['client'=>$clientid,'msg'=>json_encode($data),'type'=>'cmd']);
  566. }
  567. }
  568. //token生成算法
  569. function generate_token($username, $password, $client_key) {
  570. $CI =& get_instance();
  571. $salt = $CI->config->config['encryption_key'];
  572. return md5($username.$password.$client_key.$salt);
  573. // return md5($username.$password.date('yyyy').date('mm').$client_key.$salt);
  574. }
  575. //获取汉字拼音的第一个字母
  576. function get_first_char($str) {
  577. $firstchar_ord = ord(strtoupper($str{0}));
  578. if (($firstchar_ord >= 65 and $firstchar_ord <= 91) or ($firstchar_ord >= 48 and $firstchar_ord <= 57)) return $str{0};
  579. $s = iconv("UTF-8", "GBK//TRANSLIT//IGNORE", $str);
  580. $asc = ord($s{0}) * 256 + ord($s{1}) - 65536;
  581. if ($asc >= - 20319 and $asc <= - 20284) return "A";
  582. if ($asc >= - 20283 and $asc <= - 19776) return "B";
  583. if ($asc >= - 19775 and $asc <= - 19219) return "C";
  584. if ($asc >= - 19218 and $asc <= - 18711) return "D";
  585. if ($asc >= - 18710 and $asc <= - 18527) return "E";
  586. if ($asc >= - 18526 and $asc <= - 18240) return "F";
  587. if ($asc >= - 18239 and $asc <= - 17923) return "G";
  588. if ($asc >= - 17922 and $asc <= - 17418) return "H";
  589. if ($asc >= - 17417 and $asc <= - 16475) return "J";
  590. if ($asc >= - 16474 and $asc <= - 16213) return "K";
  591. if ($asc >= - 16212 and $asc <= - 15641) return "L";
  592. if ($asc >= - 15640 and $asc <= - 15166) return "M";
  593. if ($asc >= - 15165 and $asc <= - 14923) return "N";
  594. if ($asc >= - 14922 and $asc <= - 14915) return "O";
  595. if ($asc >= - 14914 and $asc <= - 14631) return "P";
  596. if ($asc >= - 14630 and $asc <= - 14150) return "Q";
  597. if ($asc >= - 14149 and $asc <= - 14091) return "R";
  598. if ($asc >= - 14090 and $asc <= - 13319) return "S";
  599. if ($asc >= - 13318 and $asc <= - 12839) return "T";
  600. if ($asc >= - 12838 and $asc <= - 12557) return "W";
  601. if ($asc >= - 12556 and $asc <= - 11848) return "X";
  602. if ($asc >= - 11847 and $asc <= - 11056) return "Y";
  603. if ($asc >= - 11055 and $asc <= - 10247) return "Z";
  604. return '~';
  605. }
  606. //翻译错误
  607. function transfer_error_tips($msg) {
  608. if(strpos($msg,'project not existed') !== false) {
  609. return '项目不存在';
  610. } else if(strpos($msg,'all of networks in this project are not online') !== false) {
  611. return '当前项目下所有网络都不在线';
  612. } else if(strpos($msg,'error check_code') !== false) {
  613. return '路灯发生未知错误';
  614. } else if(strpos($msg,'cmd not existed') !== false) {
  615. return '未知命令';
  616. } else if(strpos($msg,'address not correct') !== false) {
  617. return '无线模块地址不正确';
  618. } else if(strpos($msg,'current address not online') !== false) {
  619. return '无线模块不在线';
  620. } else if(strpos($msg,'time out no response') !== false) {
  621. return '超时未响应';
  622. } else if(strpos($msg,'PDU error') !== false) {
  623. return 'PDU错误';
  624. } else if(strpos($msg,'not online') !== false) {
  625. return '网络不在线';
  626. } else if(strpos($msg,'send command timeout') !== false) {
  627. return '下发指令超时';
  628. } else if(strpos($msg,'The file you are attempting to upload is larger than the permitted size.') !== false) {
  629. return '上传文件过大';
  630. } else if(strpos($msg,'The filetype you are attempting to upload is not allowed.') !== false) {
  631. return '上传文件类型错误';
  632. }else if($msg == '') {
  633. return '未知错误';
  634. } else {
  635. return '未知错误';
  636. }
  637. }
  638. //俄语翻译错误
  639. function transfer_error_tips_ru($msg) {
  640. if(strpos($msg,'project not existed') !== false) {
  641. return 'Проект не существует';
  642. } else if(strpos($msg,'all of networks in this project are not online') !== false) {
  643. return 'Все сети в рамках текущего проекта не подключены';
  644. } else if(strpos($msg,'error check_code') !== false) {
  645. return 'Неизвестная ошибка уличных фонарей';
  646. } else if(strpos($msg,'cmd not existed') !== false) {
  647. return 'Неизвестная команда';
  648. } else if(strpos($msg,'address not correct') !== false) {
  649. return 'Неверный адрес модуля';
  650. } else if(strpos($msg,'current address not online') !== false) {
  651. return 'беспроводной модуль не подключен';
  652. } else if(strpos($msg,'time out no response') !== false) {
  653. return 'задержка без ответа';
  654. } else if(strpos($msg,'PDU error') !== false) {
  655. return 'ошибка PDU';
  656. } else if(strpos($msg,'not online') !== false) {
  657. return 'сеть не работает';
  658. } else if(strpos($msg,'send command timeout') !== false) {
  659. return 'время ожидания следующей команды';
  660. } else if(strpos($msg,'The file you are attempting to upload is larger than the permitted size.') !== false) {
  661. return 'загружать слишком большой файл';
  662. } else if(strpos($msg,'The filetype you are attempting to upload is not allowed.') !== false) {
  663. return 'Ошибка загрузки типа файла';
  664. }else if($msg == '') {
  665. return 'Неизвестная ошибка';
  666. } else {
  667. return 'Неизвестная ошибка';
  668. }
  669. }
  670. /**
  671. * 把返回的数据集转换成Tree
  672. * @param array $list 要转换的数据集
  673. * @param string $pid parent标记字段
  674. * @param string $level level标记字段
  675. * @return array
  676. * @author 麦当苗儿 <zuojiazi@vip.qq.com>
  677. */
  678. function list_to_tree($list, $pk='id', $pid = 'pid', $child = '_child', $root = 0) {
  679. // 创建Tree
  680. $tree = array();
  681. if(is_array($list)) {
  682. // 创建基于主键的数组引用
  683. $refer = array();
  684. foreach ($list as $key => $data) {
  685. $refer[$data[$pk]] =& $list[$key];
  686. }
  687. foreach ($list as $key => $data) {
  688. // 判断是否存在parent
  689. $parentId = $data[$pid];
  690. if ($root == $parentId) {
  691. $tree[] =& $list[$key];
  692. }else{
  693. if (isset($refer[$parentId])) {
  694. $parent =& $refer[$parentId];
  695. $parent[$child][] =& $list[$key];
  696. }
  697. }
  698. }
  699. }
  700. return $tree;
  701. }
  702. function getTree($data, $pId)
  703. {
  704. $tree = [];
  705. foreach($data as $k => $v)
  706. {
  707. if($v['pid'] == $pId)
  708. {
  709. $v['subList'] = getTree($data, $v['id']);
  710. $tree[] = $v;
  711. unset($data[$k]);
  712. }
  713. }
  714. return $tree;
  715. }
  716. // 编号设置
  717. function set_number($n){
  718. $n = intval($n);
  719. $res = $n + 1000000;
  720. return substr($res, 1);
  721. }
  722. function get_fields_by_type($fileds,$type){
  723. // 系统默认
  724. $data = array(
  725. 'number' => array('name'=>'路灯编号','enname'=>'Lamp number'),
  726. 'section' => array('name'=>'路段','enname'=>'Road'),
  727. 'lampstatus' => array('name'=>'路灯状态','enname'=>'Lamp status'),
  728. 'status' => array('name'=>'信号状态','enname'=>'Network status'),
  729. 'updatetime' => array('name'=>'更新时间','enname'=>'Update time'),
  730. 'lighteness' => array('name'=>'路灯亮度(%)','enname'=>'Brightness(%)'),
  731. 'address' => array('name'=>'无线模块地址','enname'=>'Wireless module address'),
  732. 'lamppower' => array('name'=>'路灯功率(W)','enname'=>'Lamp power(W)'),
  733. 'chargestage' => array('name'=>'蓄电池充电阶段','enname'=>'Charging stage'),
  734. 'battvoltage' => array('name'=>'蓄电池电压(V)','enname'=>'Battery voltage(V)'),
  735. 'overtimes' => array('name'=>'蓄电池总过放次数','enname'=>'Over discharge times'),
  736. 'solarpower' => array('name'=>'太阳能板功率(W)','enname'=>'Solar panel power(W)'),
  737. 'isfaulted' => array('name'=>'是否故障','enname'=>'Fault'),
  738. 'id' => array('name'=>'路灯id','enname'=>'Lamp ID'),
  739. 'networkname' => array('name'=>'网络名称','enname'=>'Network name'),
  740. 'projectname' => array('name'=>'项目名称','enname'=>'Project name'),
  741. 'longitude' => array('name'=>'经度','enname'=>'Longitude'),
  742. 'latitude' => array('name'=>'纬度','enname'=>'Latitude'),
  743. 'simid' => array('name'=>'sim卡号','enname'=>'SIM card number'),
  744. 'packageSurplus' => array('name'=>'套餐剩余','enname'=>'Package surplus'),
  745. 'poleheight' => array('name'=>'灯杆高度(m)','enname'=>'Lamp-post length(m)'),
  746. 'polediameter' => array('name'=>'灯杆直径(m)','enname'=>'Lamp-post diameter(m)'),
  747. 'polematerial' => array('name'=>'灯杆材质','enname'=>'Lamp-post materials'),
  748. 'lighttype' => array('name'=>'灯具类型','enname'=>'Light type'),
  749. 'lamptype' => array('name'=>'路灯类型','enname'=>'Lamp type'),
  750. 'boardtype' => array('name'=>'太阳能板类型','enname'=>'Solar panel type'),
  751. 'boardpower' => array('name'=>'太阳能板功率(W)','enname'=>'Solar panel power(W)'),
  752. 'batterytype' => array('name'=>'蓄电池类型','enname'=>'Battery type'),
  753. 'batteryah' => array('name'=>'蓄电池AH数(ah)','enname'=>'Battery capacity(ah)'),
  754. 'loadpower' => array('name'=>'负载功率(W)','enname'=>'Load power(W)'),
  755. 'electricleft' => array('name'=>'蓄电池剩余电量','enname'=>'Remaining battery capacity(Ah)'),
  756. 'lampvoltage' => array('name'=>'路灯电压(V)','enname'=>'Lamp voltage(V)'),
  757. 'lampcurrent' => array('name'=>'路灯电流(A)','enname'=>'Lamp current(A)'),
  758. 'temper' => array('name'=>'灯头温度(℃)','enname'=>'Lamp temperature(℃)'),
  759. 'solarvoltage' => array('name'=>'太阳能板电压(V)','enname'=>'Solar panel voltage(V)'),
  760. 'solarcurrent' => array('name'=>'太阳能板电流(A)','enname'=>'Solar panel current(A)'),
  761. 'battstatus' => array('name'=>'蓄电池状态','enname'=>'Battery status'),
  762. 'chargecurrent' => array('name'=>'蓄电池充电电流(A)','enname'=>'Charging current(A)'),
  763. 'discharcurrent' => array('name'=>'蓄电池放电电流(A)','enname'=>'Discharging current(A)'),
  764. 'chargepower' => array('name'=>'蓄电池充电功率(w)','enname'=>'Charging power(w)'),
  765. 'dischargepower' => array('name'=>'蓄电池放电功率(w)','enname'=>'Discharging power(w)'),
  766. 'batttemper' => array('name'=>'蓄电池表面温度(℃)','enname'=>'Battery surface temperature(℃)'),
  767. 'electrictotal' => array('name'=>'蓄电池总电量','enname'=>'Total battery capacity(Ah)'),
  768. 'electricSOC' => array('name'=>'蓄电池电量SOC(%)','enname'=>'Battery SOC(%)'),
  769. 'voltagedaymin' => array('name'=>'当天最低电压(V)','enname'=>'Minimum voltage(V)'),
  770. 'voltagedaymax' => array('name'=>'当天最高电压(V)','enname'=>'Highest voltage(V)'),
  771. 'daychargeah' => array('name'=>'当天充电安时数(ah)','enname'=>'Charging AH(ah)'),
  772. 'daydischarah' => array('name'=>'当天放电安时数(ah)','enname'=>'Discharging AH(ah)'),
  773. 'daychargemaxpow' => array('name'=>'当天充电最大功率(W)','enname'=>'Charging max-power(W)'),
  774. 'daydischarmaxpow' => array('name'=>'当天放电最大功率(W)','enname'=>'Discharging max-power(W)'),
  775. 'daychargemincurrent' => array('name'=>'当天灯亮时间(hh:mm)','enname'=>'Turn-on duration'),
  776. 'daycharmaxcurrent' => array('name'=>'当天充电最大电流(A)','enname'=>'Highest charging current(A)'),
  777. 'daydischargemincurrent' => array('name'=>'当天充电时间(hh:mm)','enname'=>'Charging duration'),
  778. 'daydischarmaxcurrent' => array('name'=>'当天放电最大电流(A)','enname'=>'Highest discharging current(A)'),
  779. 'daybattmintemper' => array('name'=>'当天蓄电池最低温度(℃)','enname'=>'Battery min-temperature(℃)'),
  780. 'daybattmaxtemper' => array('name'=>'当天蓄电池最高温度(℃)','enname'=>'Battery max-temperature(℃)'),
  781. 'daygeneration' => array('name'=>'当天发电量(W)','enname'=>'Power generation(W)'),
  782. 'dayconsumption' => array('name'=>'当天用电量(W)','enname'=>'Power consumption(W)'),
  783. 'totalgeneration' => array('name'=>'累计发电量(W)','enname'=>'Cumulative power generation(W)'),
  784. 'totalconsumption' => array('name'=>'累计用电量(W)','enname'=>'Cumulative power consumption(W)'),
  785. 'sysvoltage' => array('name'=>'系统电压(V)','enname'=>'System voltage(V)'),
  786. 'syscurrent' => array('name'=>'系统电流(A)','enname'=>'System current(A)'),
  787. 'controlTemper' => array('name'=>'控制器温度(℃)','enname'=>'Controller temperature(℃)'),
  788. 'rundays' => array('name'=>'运行天数','enname'=>'Running duration'),
  789. 'fulltimes' => array('name'=>'蓄电池总充满次数','enname'=>'Full charge times'),
  790. 'totalchargeah' => array('name'=>'蓄电池总充电安时数(ah)','enname'=>'Total charge AH(ah)'),
  791. 'totaldischarah' => array('name'=>'蓄电池总放电安时数(ah)','enname'=>'Total discharge AH(ah)'),
  792. 'policyid' => array('name'=>'当前策略','enname'=>'Current strategy'),
  793. );
  794. $temp = [];
  795. $filedArr = explode(',', $fileds);
  796. if ($type == 0) {
  797. foreach ($filedArr as $f) {
  798. if (!empty($data[$f])) {
  799. $temp[] = $data[$f]['name'];
  800. }
  801. }
  802. }else{
  803. foreach ($filedArr as $f) {
  804. if (!empty($data[$f])) {
  805. $temp[] = $data[$f]['enname'];
  806. }
  807. }
  808. }
  809. return $temp;
  810. }
  811. // 翻译故障信息
  812. function alarm_translate($msg){
  813. $data = array(
  814. '过放' => 'over release',
  815. '超压' => 'overpressure',
  816. '负载短路' => 'load short circuit',
  817. '电池故障' => 'Error display',
  818. '内部超温' => 'internal overtemperature',
  819. '外部超温' => 'external overtemperature',
  820. '负载开路' => 'load opening',
  821. '输出电容超压保护' => 'output capacitance overvoltage protection',
  822. '电池板过流' => 'panel overcurrent',
  823. '电池板短路' => 'panel short circuit',
  824. '电池板超压' => 'panel overpressure',
  825. '充电逆流' => 'charging current',
  826. '锂电池低温关闭充电' => 'the lithium battery is turned off and charged at low temperature',
  827. '电池电压异常' => 'Abnormal battery voltage'
  828. );
  829. return isset($data[$msg]) ? $data[$msg] : 'unknown error';
  830. }
  831. // 新控制器翻译故障信息
  832. function modbus_alarm_translate($msg){
  833. $data = array(
  834. 'BMS过充保护' => 'BMS Overcharge Protection',
  835. '电池低温保护,停止充电' => 'Battery Low Temperature Protection, Stop Charging',
  836. '电池反接' => 'Battery reverse connection',
  837. '电容超压' => 'Capacitance overpressure',
  838. '感应探头损坏' => 'Damage of induction probe',
  839. '负载开路' => 'Load open circuit',
  840. '蓄电池过放' => 'Battery Overdischarge',
  841. '蓄电池超压' => 'Battery overvoltage',
  842. '欠压警告' => 'Undervoltage warning',
  843. '负载短路' => 'Load short circuit',
  844. '负载功率过大或负载过流' => 'Excessive Load Power or Overcurrent',
  845. '控制器温度过高' => 'Controller temperature is too high',
  846. '外部环境温度过高' => 'External ambient temperature is too high',
  847. '光伏输入功率过大' => 'Excessive input power of photovoltaic',
  848. '光伏输入端短路' => 'Photovoltaic Input Short Circuit',
  849. '光伏输入端超压' => 'Photovoltaic Input Overvoltage',
  850. '太阳板逆流' => 'Solar plate countercurrent',
  851. '太阳板工作点超压' => 'Operating point overpressure of solar panel',
  852. '太阳板反接' => 'Solar Plate Reverse Connection'
  853. );
  854. return isset($data[$msg]) ? $data[$msg] : 'unknown error';
  855. }
  856. function alarm_translate_ch($msg){
  857. $data = array(
  858. 'over release' => '过放',
  859. 'overpressure' => '超压',
  860. 'load short circuit' => '负载短路',
  861. 'battery failure' => '电池故障',
  862. 'internal overtemperature' => '内部超温',
  863. 'external overtemperature' => '外部超温',
  864. 'load opening' => '负载开路',
  865. 'output capacitance overvoltage protection' => '输出电容超压保护',
  866. 'panel overcurrent' => '电池板过流',
  867. 'panel short circuit' => '电池板短路',
  868. 'panel overpressure' => '电池板超压',
  869. 'charging current' => '充电逆流',
  870. 'the lithium battery is turned off and charged at low temperature' => '锂电池低温关闭充电',
  871. 'BMS Overcharge Protection'=>'BMS过充保护',
  872. 'Battery Low Temperature Protection, Stop Charging'=>'电池低温保护,停止充电',
  873. 'Battery reverse connection'=>'电池反接',
  874. 'Capacitance overpressure'=>'电容超压',
  875. 'Damage of induction probe'=>'感应探头损坏',
  876. 'Undervoltage warning'=>'欠压警告',
  877. 'Excessive Load Power or Overcurrent'=>'负载功率过大或负载过流',
  878. 'Controller temperature is too high'=>'控制器温度过高',
  879. 'External ambient temperature is too high'=>'外部环境温度过高',
  880. 'Excessive input power of photovoltaic'=>'光伏输入功率过大',
  881. 'Photovoltaic Input Short Circuit'=>'光伏输入端短路',
  882. 'Photovoltaic Input Overvoltage'=>'光伏输入端超压',
  883. 'Solar plate countercurrent'=>'太阳板逆流',
  884. 'Operating point overpressure of solar panel'=>'太阳板工作点超压',
  885. 'Solar Plate Reverse Connection'=>'太阳板反接',
  886. );
  887. return isset($data[$msg]) ? $data[$msg] : '';
  888. }
  889. ?>