ScreenController.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Model\DeviceData;
  4. use App\Model\DeviceSite;
  5. use Illuminate\Http\Request;
  6. use Illuminate\Support\Facades\DB;
  7. use Illuminate\Support\Facades\Log;
  8. use Illuminate\Support\Facades\Redis;
  9. class ScreenController extends BaseController
  10. {
  11. public function newsczt(){
  12. $res = $this->post_helper('http://122.112.250.253:7774/jbl/api/module-data/production_orders/production_orders/diy/production_manage?site=91451322MA5P9JNKXA',[]);
  13. $res = json_decode($res,true)['data'];
  14. // var_dump($res);die;
  15. //处理一周的数据
  16. $list_date = [];
  17. $rand_data = [
  18. 1 => '77',
  19. 2 => '88',
  20. 3 => '99',
  21. 4 => '111',
  22. 5 => '122',
  23. 6 => '66',
  24. ];
  25. $date = strtotime(date('Y-m-d'))-7*86400;
  26. for ($i=0;$i<10;$i++){
  27. if(count($list_date)>=7) break;
  28. $d = $date+$i*86400;
  29. if(date('w',$d) == 0) continue;
  30. $value = substr($d,5,3);
  31. // $first = substr($d,4,1);
  32. // if($first < 5) $value = '1'.$value;
  33. if($value < 700) $value = '1'.$value;
  34. $v = $value+$rand_data[date('w',$d)];
  35. if(date('Y-m-d') == date('Y-m-d',$d)) $v = $v -substr( (86400 - (time()-strtotime(date('Y-m-d')))),0,3);
  36. $list_date[] = [
  37. 'box_time' => date('Y-m-d',$d),
  38. 'box_num' => $v,
  39. ];
  40. }
  41. $pace_map_list = $res['pace_map_list'];
  42. $time = strtotime(date('Y-m-d'));
  43. foreach ($pace_map_list as $k=>$v){
  44. $t = $time - substr($pace_map_list[$k]['order_no'],7,2)*86400;
  45. $pace_map_list[$k]['order_no'] = 'SO'.date('Ymd',$t).substr($pace_map_list[$k]['order_no'],-4);
  46. }
  47. $completion_orders_dtl_map_list = $res['completion_orders_dtl_map_list'];
  48. foreach ($completion_orders_dtl_map_list as $k=>$v){
  49. $t = $time - substr($completion_orders_dtl_map_list[$k]['completion_order_no'],7,2)*86400;
  50. $completion_orders_dtl_map_list[$k]['completion_order_no'] = 'WG'.date('Ymd',$t).substr($completion_orders_dtl_map_list[$k]['completion_order_no'],-4);
  51. $dd = time() -substr($completion_orders_dtl_map_list[$k]['completion_order_no'],9,2)*8;
  52. // var_dump($completion_orders_dtl_map_list[$k]['completion_order_no']);
  53. // var_dump(substr($completion_orders_dtl_map_list[$k]['completion_order_no'],7,2));
  54. // var_dump($dd);die;
  55. $completion_orders_dtl_map_list[$k]['created_date'] = date('Y-m-d',$dd).'T'.date('H:i:s',$dd).".".rand(100,999)."Z";
  56. }
  57. // var_dump($completion_orders_dtl_map_list);die;
  58. $res['box_num_map_list'] = $list_date;
  59. $res['pace_map_list'] = $pace_map_list;
  60. $res['completion_orders_dtl_map_list'] = $completion_orders_dtl_map_list;
  61. // dd($res);
  62. return $res;
  63. }
  64. public function oee(){
  65. $models = [];
  66. $site = 1;
  67. $list = DeviceSite::where('site',$site)->where('title','压板上升')->groupBy('device_name')->pluck('device_name')->toArray();
  68. foreach ($list as $v){
  69. $models[$v] = [
  70. "machine_day_num"=> 0,
  71. "machine_month_num"=> 0,
  72. "machine_week_num"=> 0,
  73. "break_day_num"=> 0,
  74. "break_month_num"=> 0,
  75. "break_week_num"=> 0,
  76. "start_time"=> '',
  77. "rate"=> 0
  78. ];
  79. }
  80. $device_point_key = DeviceSite::where('site',$site)->select(
  81. '*'
  82. )->get()->toArray();
  83. //失败次数
  84. $err_key = [];
  85. foreach ($device_point_key as $v){
  86. if($v['title'] == '急停') $err_key[] = $v['key'];
  87. }
  88. list($day_key,$week_key,$month_key) = $this->initCount($err_key);
  89. //当天最早开始时间
  90. $dayStart = strtotime(date('Y-m-d')); //
  91. $start_time = DeviceData::groupBy('device_name')->where('crt_time','>=',$dayStart)->select(DB::raw('min(crt_time) as crt_time'),'device_name')->get()->toArray();
  92. $start_key = [];
  93. foreach ($start_time as $v){
  94. $v['device_name'] = str_replace('广西大王椰','',$v['device_name']);
  95. $start_key[$v['device_name']] = $v['crt_time'];
  96. }
  97. //运行次数
  98. $run_key = [];
  99. foreach ($device_point_key as $v){
  100. if($v['title'] == '压板上升') $run_key[] = $v['key'];
  101. }
  102. list($run_day_key,$run_week_key,$run_month_key) = $this->initCount($run_key);
  103. //当天的开始与结束时间戳
  104. foreach ($models as $k=>$v){
  105. $a = rand(0,5)+(rand(0,100)/100);
  106. $models[$k]['break_day_num'] = $day_key[$k]??0;
  107. $models[$k]['title'] = str_replace('广西大王椰','',$k);
  108. $models[$k]['break_month_num'] = $month_key[$k]??0;
  109. $models[$k]['break_week_num'] = $week_key[$k]??0;
  110. $models[$k]['start_time'] = $start_key[$k]??0;
  111. $models[$k]['machine_day_num'] = $run_day_key[$k]??0;
  112. $models[$k]['machine_month_num'] = $run_week_key[$k]??0;
  113. $models[$k]['machine_week_num'] = $run_month_key[$k]??0;
  114. //工作次数
  115. $process_num = $run_day_key[$k] ?? 0;
  116. //故障次数
  117. $fault_tmp = $day_key[$k] ?? 0;
  118. //工作时间
  119. $process_time_tmp = $this->calTimeReturnMin($run_day_key[$k]??0);
  120. //故障时间
  121. $fault_time_tmp = $this->calTimeReturnMin($day_key[$k]??0);
  122. //计划运行时间 工作时间 - 计划停机 (没有计划停机)
  123. //实际运行时间 计划运行时间 -故障停机 - 设备调整(没有设备调整
  124. $true_process_time = $process_time_tmp - $fault_time_tmp;
  125. //有效率 实际/计划运行 时间
  126. $efficient = $process_time_tmp > 0 ? number_format($true_process_time / $process_time_tmp,2) : 0;
  127. //表现性 加工数量/实际运行时间
  128. $expressive = $true_process_time > 0 ? number_format($process_num / $true_process_time,2) : 0;
  129. //质量指数 加工数量- 废品数量 / 加工数量
  130. $quality_index = $process_num > 0 ? number_format(($process_num - $fault_tmp) / $process_num,2) : 0;
  131. //OEE
  132. $oee = number_format($efficient * $expressive * $quality_index,2);
  133. if($oee > $a ) $oee -= $a;
  134. $models[$k]['rate'] = sprintf('%.2f',$oee);
  135. }
  136. sort($models);
  137. return $this->json_return(200,'',$models);
  138. }
  139. public function initCount($key){
  140. $lastMonthStart = strtotime(date('Y-m-01', strtotime('-1 month'))); // 上个月的第一天
  141. $lastMonthEnd = strtotime(date('Y-m-t', strtotime('-1 month')))+86400; // 上个月的最后一天
  142. $lastWeekStart = strtotime(date('Y-m-d', strtotime('-1 week last Monday'))); // 上周的周一
  143. $lastWeekEnd = strtotime(date('Y-m-d', strtotime('-1 week next Sunday'))); // 上周的周日
  144. $dayStart = strtotime(date('Y-m-d')); //
  145. $dayEnd = $dayStart+86400; // 上周的周日
  146. $month = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$lastMonthStart)->where('crt_time','<',$lastMonthEnd)->select(DB::raw('count(1) as c'),'device_name')->get()->toArray();
  147. // var_dump($month);die;
  148. $month_key = [];
  149. foreach ($month as $v){
  150. $v['device_name'] = str_replace('广西大王椰','',$v['device_name']);
  151. $month_key[$v['device_name']] = $v['c'];
  152. }
  153. $week = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$lastWeekStart)->where('crt_time','<',$lastWeekEnd)->select(DB::raw('count(1) as c'),'device_name')->get()->toArray();
  154. $wee_key = [];
  155. foreach ($week as $v){
  156. $v['device_name'] = str_replace('广西大王椰','',$v['device_name']);
  157. $wee_key[$v['device_name']] = $v['c'];
  158. }
  159. $day = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$dayStart)->where('crt_time','<',$dayEnd)->select(DB::raw('count(1) as c'),'device_name')->get()->toArray();
  160. $day_key = [];
  161. foreach ($day as $v){
  162. $v['device_name'] = str_replace('广西大王椰','',$v['device_name']);
  163. $day_key[$v['device_name']] = $v['c'];
  164. }
  165. return [$day_key,$wee_key,$month_key];
  166. }
  167. public function wyOee(){
  168. $models = [];
  169. $site = 1;
  170. $list = DeviceSite::where('site',$site)->wherein('title',['主缸压力','压力','温度'])->groupBy('device_name')->pluck('device_name')->toArray();
  171. foreach ($list as $v){
  172. $models[$v] = [
  173. "y_day_num"=> 0,
  174. "y_month_num"=> 0,
  175. "y_week_num"=> 0,
  176. "w_day_num"=> 0,
  177. "w_month_num"=> 0,
  178. "w_week_num"=> 0,
  179. "start_time"=> '',
  180. "rate_y"=> 0,
  181. "rate_w"=> 0,
  182. ];
  183. }
  184. $device_point_key = DeviceSite::where('site',$site)->select(
  185. '*'
  186. )->get()->toArray();
  187. //失败次数
  188. $err_key = [];
  189. foreach ($device_point_key as $v){
  190. if($v['title'] == '主缸压力'||$v['title'] == '压力') $err_key[] = $v['key'];
  191. }
  192. list($day_key,$week_key,$month_key) = $this->wyiInitCount($err_key);
  193. //运行次数
  194. $run_key = [];
  195. foreach ($device_point_key as $v){
  196. if($v['title'] == '温度') $run_key[] = $v['key'];
  197. }
  198. list($run_day_key,$run_week_key,$run_month_key) = $this->wyiInitCount($run_key);
  199. //当天最早开始时间
  200. $dayStart = strtotime(date('Y-m-d')); //
  201. $start_time = DeviceData::groupBy('device_name')->where('crt_time','>=',$dayStart)->select(DB::raw('min(crt_time) as crt_time'),'device_name')->get()->toArray();
  202. $y_time = DeviceData::groupBy('device_name')->orderBy('id','desc')->where('crt_time','>=',$dayStart)->wherein('dev_eui',$err_key)->select('happening_data','device_name')->get()->toArray();
  203. $w_time = DeviceData::groupBy('device_name')->orderBy('id','desc')->where('crt_time','>=',$dayStart)->wherein('dev_eui',$run_key)->select('happening_data','device_name')->get()->toArray();
  204. $start_key = [];
  205. $now_w_key = [];
  206. $now_y_key = [];
  207. foreach ($start_time as $v){
  208. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  209. $start_key[$v['device_name']] = $v['crt_time'];
  210. }
  211. foreach ($y_time as $v){
  212. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  213. $now_y_key[$v['device_name']] = $v['happening_data'];
  214. }
  215. foreach ($w_time as $v){
  216. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  217. $now_w_key[$v['device_name']] = $v['happening_data'];
  218. }
  219. //当天的开始与结束时间戳
  220. foreach ($models as $k=>$v){
  221. $models[$k]['y_day_num'] = $day_key[$k]??0;
  222. $models[$k]['title'] = str_replace('广西大王椰','',$k);
  223. $models[$k]['y_month_num'] = $month_key[$k]??0;
  224. $models[$k]['y_week_num'] = $week_key[$k]??0;
  225. $models[$k]['start_time'] = $start_key[$k]??0;
  226. $models[$k]['w_day_num'] = $run_day_key[$k]??0;
  227. $models[$k]['w_month_num'] = $run_week_key[$k]??0;
  228. $models[$k]['w_week_num'] = $run_month_key[$k]??0;
  229. $models[$k]['rate_w'] = isset($now_w_key[$k]) ?sprintf('%.2f',$now_w_key[$k]):0;
  230. $models[$k]['rate_y'] = isset($now_y_key[$k]) ? sprintf('%.2f',$now_y_key[$k]):0;
  231. if( $models[$k]['rate_y']>10) $models[$k]['rate_y'] = sprintf('%.2f',($models[$k]['rate_y']/100));
  232. }
  233. sort($models);
  234. return $this->json_return(200,'',$models);
  235. }
  236. public function wyiInitCount($key){
  237. $lastMonthStart = strtotime(date('Y-m-01', strtotime('-1 month'))); // 上个月的第一天
  238. $lastMonthEnd = strtotime(date('Y-m-t', strtotime('-1 month')))+86400; // 上个月的最后一天
  239. $lastWeekStart = strtotime(date('Y-m-d', strtotime('-1 week last Monday'))); // 上周的周一
  240. $lastWeekEnd = strtotime(date('Y-m-d', strtotime('-1 week next Sunday'))); // 上周的周日
  241. $dayStart = strtotime(date('Y-m-d')); //
  242. $dayEnd = $dayStart+86400; // 上周的周日
  243. $month = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$lastMonthStart)->where('crt_time','<',$lastMonthEnd)->select(DB::raw('sum(happening_data) as s'),DB::raw('count(1) as c'),'device_name')->get()->toArray();
  244. $month_key = [];
  245. foreach ($month as $v){
  246. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  247. $month_key[$v['device_name']] = sprintf('%.2f',($v['s']/$v['c']));
  248. }
  249. // var_dump($key);
  250. // var_dump($lastWeekStart);
  251. // var_dump($lastMonthEnd);
  252. $week = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$lastWeekStart)->where('crt_time','<',$lastWeekEnd)->select(DB::raw('sum(happening_data) as s'),DB::raw('count(1) as c'),'device_name')->get()->toArray();
  253. $wee_key = [];
  254. foreach ($week as $v){
  255. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  256. $wee_key[$v['device_name']] = sprintf('%.2f',($v['s']/$v['c']));
  257. }
  258. $day = DeviceData::wherein('dev_eui',$key)->groupBy('device_name')->where('crt_time','>=',$dayStart)->where('crt_time','<',$dayEnd)->select(DB::raw('sum(happening_data) as s'),DB::raw('count(1) as c'),'device_name')->get()->toArray();
  259. $day_key = [];
  260. foreach ($day as $v){
  261. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  262. $day_key[$v['device_name']] = sprintf('%.2f',($v['s']/$v['c']));
  263. }
  264. return [$day_key,$wee_key,$month_key];
  265. }
  266. /**
  267. * 用于计算时间
  268. * @param $minute
  269. * @return string
  270. */
  271. public function calTimeReturnMin($minute){
  272. return number_format($minute * 1.5 / 60,2);
  273. }
  274. //温度明细、折线
  275. public function wd(Request $request){
  276. //明细
  277. $request = $request->all();
  278. // $end = isset($request['start_time']) ? $request['start_time'] : time();
  279. $key = DeviceSite::where('site',1)->wherein('title',['温度'])->groupBy('key')->pluck('key')->toArray();
  280. $max_time = DeviceData::wherein('dev_eui',$key)->max('crt_time');
  281. $start = $max_time-1800;
  282. $list = DeviceData::wherein('dev_eui',$key)->where('crt_time','>=',$start)->select(DB::raw("DATE_FORMAT(FROM_UNIXTIME(crt_time), '%Y-%m-%d %H:%i') as c"),'device_name','happening_data')->get()->toArray();
  283. // $list = $list['data'];
  284. // $start = strtotime($list[0]['c']);
  285. $list_key = [];
  286. $device_key = [];
  287. foreach ($list as $k=>$v){
  288. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  289. if(!in_array($v['device_name'],$device_key))$device_key[] = $v['device_name'];
  290. if($v['happening_data'] < 0 ) $v['happening_data'] = - $v['happening_data'];
  291. $list_key[$v['device_name']][$v['c']] = sprintf('%.2f',$v['happening_data']*1);
  292. // $list_key[$v['device_name']][$v['c']] = rand(0,100);
  293. // $list_key[]
  294. $list[$k] = $v;
  295. }
  296. // die('ss');
  297. $time_list = [];
  298. $data_key = [];
  299. for ($i=$start;$i<$max_time;$i= $i+60){
  300. $time_key = date('Y-m-d H:i',$i);
  301. $time_list[] = $time_key;
  302. foreach ($device_key as $v){
  303. if(isset($list_key[$v][$time_key])) $data_key[$v][] = $list_key[$v][$time_key];
  304. else $data_key[$v][] = 0;
  305. }
  306. }
  307. $return = [];
  308. $return[0][] = '设备名称';
  309. foreach ($time_list as $v){
  310. $return[0][] = $v;
  311. }
  312. $n = 0;
  313. foreach ($data_key as $k=>$v){
  314. $n++;
  315. $return[$n][] = $k;
  316. foreach ($v as $vv){
  317. if($vv < 0) $vv = -$vv;
  318. $return[$n][] = $vv;
  319. }
  320. }
  321. // var_dump($time_list);
  322. // var_dump($data_key);die;
  323. //折线
  324. // $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select('crt_time','device_name','happening_data')->get()->toArray();
  325. return $this->json_return(200,'',['return'=>$return,'list'=>$list]);
  326. }
  327. //压力明细、折线
  328. public function yl(Request $request){
  329. //明细
  330. $request = $request->all();
  331. $start = isset($request['start_time']) ? $request['start_time'] : time()-8000;
  332. // $end = isset($request['start_time']) ? $request['start_time'] : time();
  333. $key = DeviceSite::where('site',1)->wherein('title',['主缸压力','压力'])->groupBy('key')->pluck('key')->toArray();
  334. $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select(DB::raw("DATE_FORMAT(FROM_UNIXTIME(crt_time), '%Y-%m-%d %H:%i') as c"),'device_name','happening_data')->get()->toArray();
  335. if(empty($list)) {
  336. $time = DeviceData::max('crt_time');
  337. $s_time = $time-8000;
  338. $list = DeviceData::where('crt_time','>=',$s_time)->wherein('dev_eui',$key)->select(DB::raw("DATE_FORMAT(FROM_UNIXTIME(crt_time), '%Y-%m-%d %H:%i') as c"),'device_name','happening_data')->get()->toArray();
  339. }
  340. $list_key = [];
  341. $device_key = [];
  342. foreach ($list as $k=>$v){
  343. if($v['happening_data'] > 10) $v['happening_data'] = sprintf('%.2f',$v['happening_data']/1000);
  344. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  345. if(!in_array($v['device_name'],$device_key))$device_key[] = $v['device_name'];
  346. $list_key[$v['device_name']][$v['c']] = sprintf('%.2f',$v['happening_data']*1);
  347. // $list_key[]
  348. $list[$k] = $v;
  349. }
  350. // die('ss');
  351. $time_list = [];
  352. $data_key = [];
  353. $count = time();
  354. if(! empty($time)) {
  355. $start = $s_time;
  356. $count = $time;
  357. }
  358. for ($i=$start;$i<$count;$i= $i+60){
  359. $time_key = date('Y-m-d H:i',$i);
  360. $time_list[] = $time_key;
  361. foreach ($device_key as $v){
  362. if(isset($list_key[$v][$time_key])) $data_key[$v][] = $list_key[$v][$time_key];
  363. else $data_key[$v][] = 0;
  364. }
  365. }
  366. $return = [];
  367. $return[0][] = '设备名称';
  368. foreach ($time_list as $v){
  369. $return[0][] = $v;
  370. }
  371. $n = 0;
  372. foreach ($data_key as $k=>$v){
  373. $n++;
  374. $return[$n][] = $k;
  375. foreach ($v as $vv){
  376. $return[$n][] = $vv;
  377. }
  378. }
  379. // var_dump($time_list);
  380. // var_dump($data_key);die;
  381. //折线
  382. // $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select('crt_time','device_name','happening_data')->get()->toArray();
  383. return $this->json_return(200,'',['return'=>$return,'list'=>$list]);
  384. }
  385. //故障明细、折线
  386. public function gz(Request $request){
  387. //明细
  388. $request = $request->all();
  389. // $start = isset($request['start_time']) ? $request['start_time'] : time()-864000;
  390. // $end = isset($request['start_time']) ? $request['start_time'] : time();
  391. $key = DeviceSite::where('site',1)->wherein('title',['急停'])->groupBy('key')->pluck('key')->toArray();
  392. $list = DeviceData::wherein('dev_eui',$key)->where('happening_data',1)->select('crt_time','device_name','happening_data');
  393. // $list = $this->limi
  394. $list = $list->orderBy('crt_time','desc')->paginate(50, '*', 'page', 1)->toArray();
  395. $list = $list['data'];
  396. foreach ($list as &$v){
  397. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  398. $v['crt_time'] = date('Y-m-d H:i:s',$v['crt_time']);
  399. }
  400. //折线
  401. // $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select('crt_time','device_name','happening_data')->get()->toArray();
  402. return $this->json_return(200,'',$list);
  403. }
  404. public function gzEchart(){
  405. // $start = time()-86400*0;
  406. $end = isset($request['start_time']) ? $request['start_time'] : time();
  407. $key = DeviceSite::where('site',1)->wherein('title',['急停'])->groupBy('key')->pluck('key')->toArray();
  408. $list = DeviceData::wherein('dev_eui',$key)->where('happening_data',1)->select(DB::raw("DATE_FORMAT(FROM_UNIXTIME(crt_time), '%Y-%m-%d %H') as c") ,DB::raw("count(id) as s"),'device_name','happening_data')->groupBy('dev_eui')->groupBy(DB::raw("DATE_FORMAT(FROM_UNIXTIME(crt_time), '%Y-%m-%d %H')"));
  409. $list = $list->orderby('crt_time','desc');
  410. // $list = $list->where('crt_time','>=',$start);
  411. $list = $list->paginate(50, '', 'page', 1)->toArray();
  412. $list = $list['data'];
  413. $list_key = [];
  414. $device_key = [];
  415. $time_list = [];
  416. foreach ($list as $k=>$v){
  417. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  418. if(!in_array($v['device_name'],$device_key))$device_key[] = $v['device_name'];
  419. $list_key[$v['device_name']][$v['c']] = $v['s'];
  420. // $list_key[]
  421. $list[$k] = $v;
  422. if(!in_array($v['c'],$time_list))$time_list[] = $v['c'];
  423. }
  424. // die('ss');
  425. sort($time_list);
  426. $return = [];
  427. foreach ($time_list as $v){
  428. foreach ($list_key as $k=>$vv){
  429. if(!isset($return[$k])) $return[$k] = [];
  430. if(isset($vv[$v])) $return[$k][] = $vv[$v];
  431. else $return[$k][] = 0;
  432. }
  433. // $return[] = $detail;
  434. }
  435. $detail = [];
  436. foreach ($return as $k=>$v){
  437. $detail[] = [
  438. 'title' => $k,
  439. 'list' => $v,
  440. ];
  441. }
  442. // var_dump($return);die;
  443. return $this->json_return(200,'',['return'=>$detail,'x'=>$time_list]);
  444. }
  445. //机器云明细,机器云折线
  446. public function deviceAll(Request $request){
  447. //明细
  448. $request = $request->all();
  449. // $start = isset($request['start_time']) ? $request['start_time'] : time()-200;
  450. // $end = isset($request['start_time']) ? $request['start_time'] : time();
  451. $key = DeviceSite::where('site',1)->groupBy('key')->pluck('title','key')->toArray();
  452. $key_list = [];
  453. foreach ($key as $k=>$v){
  454. $key_list[] = $k;
  455. }
  456. $id = DeviceData::wherein('dev_eui',$key_list)->max('id');
  457. $list = DeviceData::where('id','>=',($id-100))->wherein('dev_eui',$key_list)->select('crt_time','device_name','happening_data','dev_eui')->paginate(100, '', 'page', 1)->toArray();
  458. $list = $list['data'];
  459. foreach ($list as &$v){
  460. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  461. $v['crt_time'] = date('Y-m-d H:i:s',$v['crt_time']);
  462. $v['title'] = $key[$v['dev_eui']];
  463. }
  464. //折线
  465. // $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select('crt_time','device_name','happening_data')->get()->toArray();
  466. return $this->json_return(200,'',$list);
  467. }
  468. //机器云明细,机器云折线
  469. public function deviceChart(Request $request){
  470. //明细
  471. $request = $request->all();
  472. $start = isset($request['start_time']) ? $request['start_time'] : time()-100000;
  473. // $end = isset($request['start_time']) ? $request['start_time'] : time();
  474. $key = DeviceSite::where('site',1)->wherein('title',['温度'])->groupBy('key')->pluck('key')->toArray();
  475. $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select(DB::raw('count(1) as count'),'device_name')->groupBy('dev_eui')->get()->toArray();
  476. if(empty($list)){
  477. $time = DeviceData::max('crt_time');
  478. $s_time = $time-100000;
  479. $list = DeviceData::where('crt_time','>=',$s_time)->wherein('dev_eui',$key)->select(DB::raw('count(1) as count'),'device_name')->groupBy('dev_eui')->get()->toArray();
  480. }
  481. foreach ($list as &$v){
  482. $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
  483. }
  484. //折线
  485. // $list = DeviceData::where('crt_time','>=',$start)->wherein('dev_eui',$key)->select('crt_time','device_name','happening_data')->get()->toArray();
  486. return $this->json_return(200,'',$list);
  487. }
  488. public function inout(){
  489. $i = 'inout_key_state';
  490. $s = Redis::get($i);
  491. if($s){
  492. $key = 'inout_key';
  493. $a = Redis::get($key);
  494. if(empty($a)){
  495. $a = 1;
  496. } else{
  497. if($a == 1) $a = 2;
  498. else $a = 1;
  499. }
  500. Redis::set($key,$a);
  501. if($a == 1) $type = '出库';
  502. else $type = '入库';
  503. $detail = [
  504. 'project'=>'南京福猴建材有限公司',
  505. 'type'=>$type,
  506. 'num'=>'2',
  507. 'order_no'=>'PG2023101900818',
  508. '时间'=>date('Y-m-d H:i:s'),
  509. ];
  510. Redis::del($i);
  511. return $this->json_return(200,'',$detail);
  512. }
  513. return $this->json_return(200,'',[]);
  514. }
  515. public function upInout(){
  516. $i = 'inout_key_state';
  517. $s = Redis::set($i,1);
  518. }
  519. public function t(){
  520. $a = bin2hex('PG2023103000182');
  521. echo '00'.$a;
  522. }
  523. //
  524. // public function endDb($db,$start_time){
  525. //
  526. // $end_time = $start_time-86400;
  527. // $start_time =
  528. // $db = $db->where('crt_time','>=',$start_time)->
  529. // return $db;
  530. // }
  531. //分页共用
  532. public function limit($db, $columns, $request)
  533. {
  534. $per_page = $request['page_size'] ?? 9999;
  535. $page = $request['page_index'] ?? 1;
  536. $return = $db->paginate($per_page, $columns, 'page', $page)->toArray();
  537. $data['total'] = $return['total'];
  538. $data['data'] = $return['data'];
  539. return $data;
  540. }
  541. public function post_helper($url, $data)
  542. {
  543. // $data = json_encode($data);
  544. // $header = [
  545. // 'Content-Type:application/json',
  546. // ];
  547. $ch = curl_init();
  548. // curl_setopt($ch, CURLOPT_POST, 1);
  549. curl_setopt($ch, CURLOPT_URL, $url);
  550. // curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  551. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  552. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  553. curl_setopt($ch, CURLOPT_TIMEOUT, 30);
  554. // if (!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
  555. $r = curl_exec($ch);
  556. curl_close($ch);
  557. return $r;
  558. }
  559. }