function_helper.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989
  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 lampMqttCmd($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,255);
  112. $seq = base_convert($seq, 10, 16);
  113. return substr('00'.$seq, -2);
  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. return false;
  422. $CI =& get_instance();
  423. $host = $CI->config->item('cmd_server');
  424. $ip = $host['ip'];
  425. $port = $host['port'];
  426. $client = @stream_socket_client("tcp://{$ip}:{$port}", $errno, $errstr, 30);
  427. if ($client) {
  428. fwrite($client, $cmd);
  429. stream_set_timeout($client, $timeout, $ms_timeout);
  430. $result = fread($client, 8196);
  431. fclose($client);
  432. return $result;
  433. } else {
  434. return false;
  435. }
  436. }
  437. /**
  438. * 模拟post进行url请求
  439. * @param string $url
  440. * @param string $param
  441. */
  442. function request_post($url = '', $data = '',$header=array(),$timeout = 30) {
  443. $tuCurl = curl_init();
  444. //参数
  445. curl_setopt($tuCurl, CURLOPT_URL,$url);
  446. curl_setopt($tuCurl, CURLOPT_POSTFIELDS, $data);
  447. curl_setopt($tuCurl, CURLOPT_SSL_VERIFYPEER, false);
  448. // curl_setopt($tuCurl, CURLOPT_SSL_VERIFYHOST, false);
  449. curl_setopt($tuCurl, CURLOPT_SSLVERSION, 1);
  450. curl_setopt($tuCurl, CURLOPT_RETURNTRANSFER, 1);
  451. curl_setopt($tuCurl, CURLOPT_TIMEOUT, $timeout);
  452. if (!empty($header)) {
  453. curl_setopt($tuCurl, CURLOPT_HTTPHEADER, $header);
  454. }
  455. $tuData = curl_exec($tuCurl);
  456. curl_close($tuCurl);
  457. return $tuData;
  458. }
  459. // 通过时区获取当地时间
  460. function get_time_by_timezone($timezone){
  461. $time = strtotime(gmdate("Y-m-d H:i:s"));
  462. return date('Y-m-d H:i:s',$time + $timezone*3600);
  463. }
  464. // 给定时间、时区计算目标时区时间
  465. function date_change($date,$start,$end){
  466. $H = intval(date('H',strtotime($date)));
  467. $d = intval(date('d',strtotime($date)));
  468. $m = intval(date('m',strtotime($date)));
  469. $Y = intval(date('Y',strtotime($date)));
  470. if ($m <= 1) {
  471. $beginDateMonth = date(($Y-1).'-12-01', strtotime($date));
  472. }else{
  473. $beginDateMonth = date($Y.'-'.($m-1).'-01', strtotime($date));
  474. }
  475. $day = intval(date('d', strtotime("$beginDateMonth +1 month -1 day")));
  476. $day1 = intval(date('d', strtotime(date('Y-m-01',strtotime($date))." +1 month -1 day")));
  477. $H1 = $H-($start - $end);
  478. if ($H1 < 0) {
  479. $H1 += 24;
  480. if ($d <= 1) {
  481. $d = $day;
  482. if ($m <= 1) {
  483. $Y -= 1;
  484. $m = 12;
  485. }else{
  486. $m -= 1;
  487. }
  488. }else{
  489. $d -= 1;
  490. }
  491. }elseif ($H1 >= 24) {
  492. $H1 -= 24;
  493. if ($d >= $day1) {
  494. $d = 1;
  495. if ($m >= 12) {
  496. $m = 1;
  497. $Y += 1;
  498. }else{
  499. $m += 1;
  500. }
  501. }else{
  502. $d += 1;
  503. }
  504. }
  505. if ($m < 10) $m = '0'.$m;
  506. if ($d < 10) $d = '0'.$d;
  507. if ($H1 < 10) $H1 = '0'.$H1;
  508. return date("{$Y}-{$m}-{$d} {$H1}:i:s",strtotime($date));
  509. }
  510. // 文件下载
  511. function file_download($filePath){
  512. $file_name = basename($filePath); //下载文件名
  513. //检查文件是否存在
  514. if (! file_exists ( $filePath )) {
  515. exit (json_result('0012','找不到文件',array()));
  516. } else {
  517. //打开文件
  518. $file = fopen ( $filePath, "r" );
  519. //输入文件标签
  520. Header ( "Content-type: application/octet-stream" );
  521. Header ( "Accept-Ranges: bytes" );
  522. Header ( "Accept-Length: " . filesize ( $filePath) );
  523. Header ( "Content-Disposition: attachment; filename=" . $file_name );
  524. //输出文件内容
  525. //读取文件内容并直接输出到浏览器
  526. echo fread ( $file, filesize ( $filePath ) );
  527. fclose ( $file );
  528. exit ();
  529. }
  530. }
  531. /**
  532. * 模拟get进行url请求
  533. * @param string $url
  534. */
  535. function http_get($url,$header = array()) {
  536. $ch = curl_init();
  537. curl_setopt($ch, CURLOPT_URL, $url);
  538. curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  539. curl_setopt($ch, CURLOPT_HEADER, 0);
  540. if (!empty($header)) {
  541. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  542. }
  543. // curl_setopt($ch, CURLOPT_TIMEOUT_MS, 1);
  544. $result = curl_exec($ch);
  545. curl_close($ch);
  546. return $result;
  547. }
  548. //截取字符串
  549. function cut_str($string, $length, $append=true) {
  550. if(strlen($string) <= $length ) {
  551. return $string;
  552. } else {
  553. $i = 0;
  554. while ($i < $length) {
  555. $stringTMP = substr($string,$i,1);
  556. if ( ord($stringTMP) >=224 ) {
  557. $stringTMP = substr($string,$i,3);
  558. $i = $i + 3;
  559. } elseif( ord($stringTMP) >=192 ) {
  560. $stringTMP = substr($string,$i,2);
  561. $i = $i + 2;
  562. } else {
  563. $i = $i + 1;
  564. }
  565. $stringLast[] = $stringTMP;
  566. }
  567. $stringLast = implode("",$stringLast);
  568. if($append) {
  569. $stringLast .= "...";
  570. }
  571. return $stringLast;
  572. }
  573. }
  574. //填充数组不存在的键值对
  575. function fillUnsetData($array, $length) {
  576. for ($i=1; $i <= $length; $i++) {
  577. if (!isset($array[$i])) {
  578. $array[$i] = '';
  579. }
  580. }
  581. return $array;
  582. }
  583. //查找数组第一个元素的key
  584. function findFirstKey($array) {
  585. foreach ($array as $k => $v){
  586. return $k;
  587. }
  588. }
  589. function doAsyncRequest($url, $param=array()){
  590. $urlinfo = parse_url($url);
  591. $host = $urlinfo['host'];
  592. $path = $urlinfo['path'];
  593. $query = isset($param)? http_build_query($param) : '';
  594. $port = 80;
  595. $errno = 0;
  596. $errstr = '';
  597. $timeout = 10;
  598. $fp = fsockopen($host, $port, $errno, $errstr, $timeout);
  599. $out = "POST ".$path." HTTP/1.1\r\n";
  600. $out .= "host:".$host."\r\n";
  601. $out .= "content-length:".strlen($query)."\r\n";
  602. $out .= "content-type:application/x-www-form-urlencoded\r\n";
  603. $out .= "connection:close\r\n\r\n";
  604. $out .= $query;
  605. fputs($fp, $out);
  606. fclose($fp);
  607. }
  608. function send_websocket($clientid,$data = array(),$resType='cmd')
  609. {
  610. if (!empty($clientid)) {
  611. $CI =& get_instance();
  612. $CI->db->insert('message',['client'=>$clientid,'msg'=>json_encode($data),'type'=>'cmd']);
  613. }
  614. }
  615. //token生成算法
  616. function generate_token($username, $password, $client_key) {
  617. $CI =& get_instance();
  618. $salt = $CI->config->config['encryption_key'];
  619. return md5($username.$password.$client_key.$salt);
  620. // return md5($username.$password.date('yyyy').date('mm').$client_key.$salt);
  621. }
  622. //获取汉字拼音的第一个字母
  623. function get_first_char($str) {
  624. $firstchar_ord = ord(strtoupper($str{0}));
  625. if (($firstchar_ord >= 65 and $firstchar_ord <= 91) or ($firstchar_ord >= 48 and $firstchar_ord <= 57)) return $str{0};
  626. $s = iconv("UTF-8", "GBK//TRANSLIT//IGNORE", $str);
  627. $asc = ord($s{0}) * 256 + ord($s{1}) - 65536;
  628. if ($asc >= - 20319 and $asc <= - 20284) return "A";
  629. if ($asc >= - 20283 and $asc <= - 19776) return "B";
  630. if ($asc >= - 19775 and $asc <= - 19219) return "C";
  631. if ($asc >= - 19218 and $asc <= - 18711) return "D";
  632. if ($asc >= - 18710 and $asc <= - 18527) return "E";
  633. if ($asc >= - 18526 and $asc <= - 18240) return "F";
  634. if ($asc >= - 18239 and $asc <= - 17923) return "G";
  635. if ($asc >= - 17922 and $asc <= - 17418) return "H";
  636. if ($asc >= - 17417 and $asc <= - 16475) return "J";
  637. if ($asc >= - 16474 and $asc <= - 16213) return "K";
  638. if ($asc >= - 16212 and $asc <= - 15641) return "L";
  639. if ($asc >= - 15640 and $asc <= - 15166) return "M";
  640. if ($asc >= - 15165 and $asc <= - 14923) return "N";
  641. if ($asc >= - 14922 and $asc <= - 14915) return "O";
  642. if ($asc >= - 14914 and $asc <= - 14631) return "P";
  643. if ($asc >= - 14630 and $asc <= - 14150) return "Q";
  644. if ($asc >= - 14149 and $asc <= - 14091) return "R";
  645. if ($asc >= - 14090 and $asc <= - 13319) return "S";
  646. if ($asc >= - 13318 and $asc <= - 12839) return "T";
  647. if ($asc >= - 12838 and $asc <= - 12557) return "W";
  648. if ($asc >= - 12556 and $asc <= - 11848) return "X";
  649. if ($asc >= - 11847 and $asc <= - 11056) return "Y";
  650. if ($asc >= - 11055 and $asc <= - 10247) return "Z";
  651. return '~';
  652. }
  653. //翻译错误
  654. function transfer_error_tips($msg) {
  655. if(strpos($msg,'project not existed') !== false) {
  656. return '项目不存在';
  657. } else if(strpos($msg,'all of networks in this project are not online') !== false) {
  658. return '当前项目下所有网络都不在线';
  659. } else if(strpos($msg,'error check_code') !== false) {
  660. return '路灯发生未知错误';
  661. } else if(strpos($msg,'cmd not existed') !== false) {
  662. return '未知命令';
  663. } else if(strpos($msg,'address not correct') !== false) {
  664. return '无线模块地址不正确';
  665. } else if(strpos($msg,'current address not online') !== false) {
  666. return '无线模块不在线';
  667. } else if(strpos($msg,'time out no response') !== false) {
  668. return '超时未响应';
  669. } else if(strpos($msg,'PDU error') !== false) {
  670. return 'PDU错误';
  671. } else if(strpos($msg,'not online') !== false) {
  672. return '网络不在线';
  673. } else if(strpos($msg,'send command timeout') !== false) {
  674. return '下发指令超时';
  675. } else if(strpos($msg,'The file you are attempting to upload is larger than the permitted size.') !== false) {
  676. return '上传文件过大';
  677. } else if(strpos($msg,'The filetype you are attempting to upload is not allowed.') !== false) {
  678. return '上传文件类型错误';
  679. }else if($msg == '') {
  680. return '未知错误';
  681. } else {
  682. return '未知错误';
  683. }
  684. }
  685. //俄语翻译错误
  686. function transfer_error_tips_ru($msg) {
  687. if(strpos($msg,'project not existed') !== false) {
  688. return 'Проект не существует';
  689. } else if(strpos($msg,'all of networks in this project are not online') !== false) {
  690. return 'Все сети в рамках текущего проекта не подключены';
  691. } else if(strpos($msg,'error check_code') !== false) {
  692. return 'Неизвестная ошибка уличных фонарей';
  693. } else if(strpos($msg,'cmd not existed') !== false) {
  694. return 'Неизвестная команда';
  695. } else if(strpos($msg,'address not correct') !== false) {
  696. return 'Неверный адрес модуля';
  697. } else if(strpos($msg,'current address not online') !== false) {
  698. return 'беспроводной модуль не подключен';
  699. } else if(strpos($msg,'time out no response') !== false) {
  700. return 'задержка без ответа';
  701. } else if(strpos($msg,'PDU error') !== false) {
  702. return 'ошибка PDU';
  703. } else if(strpos($msg,'not online') !== false) {
  704. return 'сеть не работает';
  705. } else if(strpos($msg,'send command timeout') !== false) {
  706. return 'время ожидания следующей команды';
  707. } else if(strpos($msg,'The file you are attempting to upload is larger than the permitted size.') !== false) {
  708. return 'загружать слишком большой файл';
  709. } else if(strpos($msg,'The filetype you are attempting to upload is not allowed.') !== false) {
  710. return 'Ошибка загрузки типа файла';
  711. }else if($msg == '') {
  712. return 'Неизвестная ошибка';
  713. } else {
  714. return 'Неизвестная ошибка';
  715. }
  716. }
  717. /**
  718. * 把返回的数据集转换成Tree
  719. * @param array $list 要转换的数据集
  720. * @param string $pid parent标记字段
  721. * @param string $level level标记字段
  722. * @return array
  723. * @author 麦当苗儿 <zuojiazi@vip.qq.com>
  724. */
  725. function list_to_tree($list, $pk='id', $pid = 'pid', $child = '_child', $root = 0) {
  726. // 创建Tree
  727. $tree = array();
  728. if(is_array($list)) {
  729. // 创建基于主键的数组引用
  730. $refer = array();
  731. foreach ($list as $key => $data) {
  732. $refer[$data[$pk]] =& $list[$key];
  733. }
  734. foreach ($list as $key => $data) {
  735. // 判断是否存在parent
  736. $parentId = $data[$pid];
  737. if ($root == $parentId) {
  738. $tree[] =& $list[$key];
  739. }else{
  740. if (isset($refer[$parentId])) {
  741. $parent =& $refer[$parentId];
  742. $parent[$child][] =& $list[$key];
  743. }
  744. }
  745. }
  746. }
  747. return $tree;
  748. }
  749. function getTree($data, $pId)
  750. {
  751. $tree = [];
  752. foreach($data as $k => $v)
  753. {
  754. if($v['pid'] == $pId)
  755. {
  756. $v['subList'] = getTree($data, $v['id']);
  757. $tree[] = $v;
  758. unset($data[$k]);
  759. }
  760. }
  761. return $tree;
  762. }
  763. // 编号设置
  764. function set_number($n){
  765. $n = intval($n);
  766. $res = $n + 1000000;
  767. return substr($res, 1);
  768. }
  769. function get_fields_by_type($fileds,$type){
  770. // 系统默认
  771. $data = array(
  772. 'number' => array('name'=>'路灯编号','enname'=>'Lamp number'),
  773. 'section' => array('name'=>'路段','enname'=>'Road'),
  774. 'lampstatus' => array('name'=>'路灯状态','enname'=>'Lamp status'),
  775. 'status' => array('name'=>'信号状态','enname'=>'Network status'),
  776. 'updatetime' => array('name'=>'更新时间','enname'=>'Update time'),
  777. 'lighteness' => array('name'=>'路灯亮度(%)','enname'=>'Brightness(%)'),
  778. 'address' => array('name'=>'无线模块地址','enname'=>'Wireless module address'),
  779. 'loadpower' => array('name'=>'负载功率(W)','enname'=>'load power(W)'),
  780. 'chargestage' => array('name'=>'蓄电池充电阶段','enname'=>'Charging stage'),
  781. 'battvoltage' => array('name'=>'蓄电池电压(V)','enname'=>'Battery voltage(V)'),
  782. 'overtimes' => array('name'=>'蓄电池总过放次数','enname'=>'Over discharge times'),
  783. 'solarpower' => array('name'=>'太阳能板功率(W)','enname'=>'Solar panel power(W)'),
  784. 'isfaulted' => array('name'=>'是否故障','enname'=>'Fault'),
  785. 'id' => array('name'=>'路灯id','enname'=>'Lamp ID'),
  786. 'networkname' => array('name'=>'网络名称','enname'=>'Network name'),
  787. 'projectname' => array('name'=>'项目名称','enname'=>'Project name'),
  788. 'longitude' => array('name'=>'经度','enname'=>'Longitude'),
  789. 'latitude' => array('name'=>'纬度','enname'=>'Latitude'),
  790. 'simid' => array('name'=>'sim卡号','enname'=>'SIM card number'),
  791. 'packageSurplus' => array('name'=>'套餐剩余','enname'=>'Package surplus'),
  792. 'poleheight' => array('name'=>'灯杆高度(m)','enname'=>'Lamp-post length(m)'),
  793. 'polediameter' => array('name'=>'灯杆直径(m)','enname'=>'Lamp-post diameter(m)'),
  794. 'polematerial' => array('name'=>'灯杆材质','enname'=>'Lamp-post materials'),
  795. 'lighttype' => array('name'=>'灯具类型','enname'=>'Light type'),
  796. 'lamptype' => array('name'=>'路灯类型','enname'=>'Lamp type'),
  797. 'boardtype' => array('name'=>'太阳能板类型','enname'=>'Solar panel type'),
  798. 'boardpower' => array('name'=>'太阳能板功率(W)','enname'=>'Solar panel power(W)'),
  799. 'batterytype' => array('name'=>'蓄电池类型','enname'=>'Battery type'),
  800. 'batteryah' => array('name'=>'蓄电池AH数(ah)','enname'=>'Battery capacity(ah)'),
  801. 'loadpower' => array('name'=>'负载功率(W)','enname'=>'Load power(W)'),
  802. 'electricleft' => array('name'=>'蓄电池剩余电量','enname'=>'Remaining battery capacity(Ah)'),
  803. 'lampvoltage' => array('name'=>'路灯电压(V)','enname'=>'Lamp voltage(V)'),
  804. 'lampcurrent' => array('name'=>'路灯电流(A)','enname'=>'Lamp current(A)'),
  805. 'temper' => array('name'=>'灯头温度(℃)','enname'=>'Lamp temperature(℃)'),
  806. 'solarvoltage' => array('name'=>'太阳能板电压(V)','enname'=>'Solar panel voltage(V)'),
  807. 'solarcurrent' => array('name'=>'太阳能板电流(A)','enname'=>'Solar panel current(A)'),
  808. 'battstatus' => array('name'=>'蓄电池状态','enname'=>'Battery status'),
  809. 'chargecurrent' => array('name'=>'蓄电池充电电流(A)','enname'=>'Charging current(A)'),
  810. 'discharcurrent' => array('name'=>'蓄电池放电电流(A)','enname'=>'Discharging current(A)'),
  811. 'chargepower' => array('name'=>'蓄电池充电功率(w)','enname'=>'Charging power(w)'),
  812. 'dischargepower' => array('name'=>'蓄电池放电功率(w)','enname'=>'Discharging power(w)'),
  813. 'batttemper' => array('name'=>'蓄电池表面温度(℃)','enname'=>'Battery surface temperature(℃)'),
  814. 'electrictotal' => array('name'=>'蓄电池总电量','enname'=>'Total battery capacity(Ah)'),
  815. 'electricSOC' => array('name'=>'蓄电池电量SOC(%)','enname'=>'Battery SOC(%)'),
  816. 'voltagedaymin' => array('name'=>'当天最低电压(V)','enname'=>'Minimum voltage(V)'),
  817. 'voltagedaymax' => array('name'=>'当天最高电压(V)','enname'=>'Highest voltage(V)'),
  818. 'daychargeah' => array('name'=>'当天充电安时数(ah)','enname'=>'Charging AH(ah)'),
  819. 'daydischarah' => array('name'=>'当天放电安时数(ah)','enname'=>'Discharging AH(ah)'),
  820. 'daychargemaxpow' => array('name'=>'当天充电最大功率(W)','enname'=>'Charging max-power(W)'),
  821. 'daydischarmaxpow' => array('name'=>'当天放电最大功率(W)','enname'=>'Discharging max-power(W)'),
  822. 'daychargemincurrent' => array('name'=>'当天灯亮时间(hh:mm)','enname'=>'Turn-on duration'),
  823. 'daycharmaxcurrent' => array('name'=>'当天充电最大电流(A)','enname'=>'Highest charging current(A)'),
  824. 'daydischargemincurrent' => array('name'=>'当天充电时间(hh:mm)','enname'=>'Charging duration'),
  825. 'daydischarmaxcurrent' => array('name'=>'当天放电最大电流(A)','enname'=>'Highest discharging current(A)'),
  826. 'daybattmintemper' => array('name'=>'当天蓄电池最低温度(℃)','enname'=>'Battery min-temperature(℃)'),
  827. 'daybattmaxtemper' => array('name'=>'当天蓄电池最高温度(℃)','enname'=>'Battery max-temperature(℃)'),
  828. 'daygeneration' => array('name'=>'当天发电量(W)','enname'=>'Power generation(W)'),
  829. 'dayconsumption' => array('name'=>'当天用电量(W)','enname'=>'Power consumption(W)'),
  830. 'totalgeneration' => array('name'=>'累计发电量(W)','enname'=>'Cumulative power generation(W)'),
  831. 'totalconsumption' => array('name'=>'累计用电量(W)','enname'=>'Cumulative power consumption(W)'),
  832. 'sysvoltage' => array('name'=>'系统电压(V)','enname'=>'System voltage(V)'),
  833. 'syscurrent' => array('name'=>'系统电流(A)','enname'=>'System current(A)'),
  834. 'controlTemper' => array('name'=>'控制器温度(℃)','enname'=>'Controller temperature(℃)'),
  835. 'rundays' => array('name'=>'运行天数','enname'=>'Running duration'),
  836. 'fulltimes' => array('name'=>'蓄电池总充满次数','enname'=>'Full charge times'),
  837. 'totalchargeah' => array('name'=>'蓄电池总充电安时数(ah)','enname'=>'Total charge AH(ah)'),
  838. 'totaldischarah' => array('name'=>'蓄电池总放电安时数(ah)','enname'=>'Total discharge AH(ah)'),
  839. 'policyid' => array('name'=>'当前策略','enname'=>'Current strategy'),
  840. );
  841. $temp = [];
  842. $filedArr = explode(',', $fileds);
  843. if ($type == 0) {
  844. foreach ($filedArr as $f) {
  845. if (!empty($data[$f])) {
  846. $temp[] = $data[$f]['name'];
  847. }
  848. }
  849. }else{
  850. foreach ($filedArr as $f) {
  851. if (!empty($data[$f])) {
  852. $temp[] = $data[$f]['enname'];
  853. }
  854. }
  855. }
  856. return $temp;
  857. }
  858. // 翻译故障信息
  859. function alarm_translate($msg){
  860. $data = array(
  861. '过放' => 'over release',
  862. '超压' => 'overpressure',
  863. '负载短路' => 'load short circuit',
  864. '电池故障' => 'Error display',
  865. '内部超温' => 'internal overtemperature',
  866. '外部超温' => 'external overtemperature',
  867. '负载开路' => 'load opening',
  868. '输出电容超压保护' => 'output capacitance overvoltage protection',
  869. '电池板过流' => 'panel overcurrent',
  870. '电池板短路' => 'panel short circuit',
  871. '电池板超压' => 'panel overpressure',
  872. '充电逆流' => 'charging current',
  873. '锂电池低温关闭充电' => 'the lithium battery is turned off and charged at low temperature',
  874. '电池电压异常' => 'Abnormal battery voltage'
  875. );
  876. return isset($data[$msg]) ? $data[$msg] : 'unknown error';
  877. }
  878. // 新控制器翻译故障信息
  879. function modbus_alarm_translate($msg){
  880. $data = array(
  881. 'BMS过充保护' => 'BMS Overcharge Protection',
  882. '电池低温保护,停止充电' => 'Battery Low Temperature Protection, Stop Charging',
  883. '电池反接' => 'Battery reverse connection',
  884. '电容超压' => 'Capacitance overpressure',
  885. '感应探头损坏' => 'Damage of induction probe',
  886. '负载开路' => 'Load open circuit',
  887. '蓄电池过放' => 'Battery Overdischarge',
  888. '蓄电池超压' => 'Battery overvoltage',
  889. '欠压警告' => 'Undervoltage warning',
  890. '负载短路' => 'Load short circuit',
  891. '负载功率过大或负载过流' => 'Excessive Load Power or Overcurrent',
  892. '控制器温度过高' => 'Controller temperature is too high',
  893. '外部环境温度过高' => 'External ambient temperature is too high',
  894. '光伏输入功率过大' => 'Excessive input power of photovoltaic',
  895. '光伏输入端短路' => 'Photovoltaic Input Short Circuit',
  896. '光伏输入端超压' => 'Photovoltaic Input Overvoltage',
  897. '太阳板逆流' => 'Solar plate countercurrent',
  898. '太阳板工作点超压' => 'Operating point overpressure of solar panel',
  899. '太阳板反接' => 'Solar Plate Reverse Connection'
  900. );
  901. return isset($data[$msg]) ? $data[$msg] : 'unknown error';
  902. }
  903. function alarm_translate_ch($msg){
  904. $data = array(
  905. 'over release' => '过放',
  906. 'overpressure' => '超压',
  907. 'load short circuit' => '负载短路',
  908. 'battery failure' => '电池故障',
  909. 'internal overtemperature' => '内部超温',
  910. 'external overtemperature' => '外部超温',
  911. 'load opening' => '负载开路',
  912. 'output capacitance overvoltage protection' => '输出电容超压保护',
  913. 'panel overcurrent' => '电池板过流',
  914. 'panel short circuit' => '电池板短路',
  915. 'panel overpressure' => '电池板超压',
  916. 'charging current' => '充电逆流',
  917. 'the lithium battery is turned off and charged at low temperature' => '锂电池低温关闭充电',
  918. 'BMS Overcharge Protection'=>'BMS过充保护',
  919. 'Battery Low Temperature Protection, Stop Charging'=>'电池低温保护,停止充电',
  920. 'Battery reverse connection'=>'电池反接',
  921. 'Capacitance overpressure'=>'电容超压',
  922. 'Damage of induction probe'=>'感应探头损坏',
  923. 'Undervoltage warning'=>'欠压警告',
  924. 'Excessive Load Power or Overcurrent'=>'负载功率过大或负载过流',
  925. 'Controller temperature is too high'=>'控制器温度过高',
  926. 'External ambient temperature is too high'=>'外部环境温度过高',
  927. 'Excessive input power of photovoltaic'=>'光伏输入功率过大',
  928. 'Photovoltaic Input Short Circuit'=>'光伏输入端短路',
  929. 'Photovoltaic Input Overvoltage'=>'光伏输入端超压',
  930. 'Solar plate countercurrent'=>'太阳板逆流',
  931. 'Operating point overpressure of solar panel'=>'太阳板工作点超压',
  932. 'Solar Plate Reverse Connection'=>'太阳板反接',
  933. );
  934. return isset($data[$msg]) ? $data[$msg] : '';
  935. }
  936. ?>