Merge branch 'master' of http://121.41.102.225:3000/chenqp/queue_services

app/Console/Commands/OeeCommand.php

@@ -0,0 +1,224 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Jobs\SendDataJob;
+use App\Model\BigKingCbj;
+use App\Model\DeviceData;
+use App\Model\DeviceSite;
+use App\Service\DwyService;
+use App\Service\LabelDealService;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Illuminate\Support\Facades\Redis;
+
+class OeeCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'command:oee';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '读取文件';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        //设备数据
+        $key = DeviceSite::where('site',1)->groupBy('key')->pluck('title','key')->toArray();
+        $key_list = [];
+        foreach ($key as $k=>$v){
+            $key_list[] = $k;
+        }
+//        $id = DeviceData::wherein('dev_eui',$key_list)->max('id');
+        $list = DeviceData::wherein('dev_eui',$key_list)->orderBy('id','desc')->select('crt_time','device_name','happening_data','dev_eui')->paginate(100, '', 'page', 1)->toArray();
+        $list = $list['data'];
+        foreach ($list as &$v){
+            $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
+            $v['crt_time'] = date('Y-m-d H:i:s',$v['crt_time']);
+            $v['title'] = $key[$v['dev_eui']];
+        }
+
+        Redis::set('dwyApiDeviceAll',json_encode($list));
+        unset($list);
+
+        //oee数据
+        $models = [];
+        $site = 1;
+        $list = DeviceSite::where('site',$site)->where('title','压板上升')->groupBy('device_name')->pluck('device_name')->toArray();
+        foreach ($list as  $v){
+            $models[$v] = [
+                "machine_day_num"=> 0,
+                "machine_month_num"=> 0,
+                "machine_week_num"=> 0,
+                "break_day_num"=> 0,
+                "break_month_num"=> 0,
+                "break_week_num"=> 0,
+                "start_time"=> '',
+                "rate"=> 0
+            ];
+        }
+        $device_point_key = DeviceSite::where('site',$site)->select(
+            '*'
+        )->get()->toArray();
+        //失败次数
+        $err_key = [];
+        foreach ($device_point_key as $v){
+            if($v['title'] == '急停') $err_key[] = $v['key'];
+        }
+        list($day_key,$week_key,$month_key) = $this->initCount($err_key);
+        //当天最早开始时间
+        $dayStart = strtotime(date('Y-m-d')); //
+        $start_time = DeviceData::groupBy('device_name')->where('crt_time','>=',$dayStart)->select(DB::raw('min(crt_time) as crt_time'),'device_name')->get()->toArray();
+        $start_key = [];
+        foreach ($start_time as $v){
+            $v['device_name'] = str_replace('广西大王椰','',$v['device_name']);
+            $start_key[$v['device_name']] = $v['crt_time'];
+        }
+        //运行次数
+        $run_key = [];
+        foreach ($device_point_key as $v){
+            if($v['title'] == '压板上升') $run_key[] = $v['key'];
+        }
+        list($run_day_key,$run_week_key,$run_month_key) = $this->initCount($run_key);
+        //当天的开始与结束时间戳
+
+        foreach ($models as $k=>$v){
+            $a = rand(0,5)+(rand(0,100)/100);
+            $models[$k]['break_day_num'] = $day_key[$k]??0;
+            $models[$k]['title'] = str_replace('广西大王椰','',$k);
+            $models[$k]['break_month_num'] = $month_key[$k]??0;
+            $models[$k]['break_week_num'] = $week_key[$k]??0;
+            $models[$k]['start_time'] = $start_key[$k]??0;
+            $models[$k]['machine_day_num'] = $run_day_key[$k]??0;
+            $models[$k]['machine_month_num'] = $run_week_key[$k]??0;
+            $models[$k]['machine_week_num'] = $run_month_key[$k]??0;
+
+
+            //工作次数
+            $process_num  = $run_day_key[$k] ?? 0;
+            //故障次数
+            $fault_tmp = $day_key[$k] ?? 0;
+            //工作时间
+            $process_time_tmp = $this->calTimeReturnMin($run_day_key[$k]??0);
+            //故障时间
+            $fault_time_tmp = $this->calTimeReturnMin($day_key[$k]??0);
+            //计划运行时间 工作时间 - 计划停机 （没有计划停机）
+            //实际运行时间  计划运行时间 -故障停机 - 设备调整（没有设备调整
+            $true_process_time = $process_time_tmp - $fault_time_tmp;
+            //有效率 实际/计划运行 时间
+            $efficient = $process_time_tmp > 0  ? number_format($true_process_time / $process_time_tmp,2) : 0;
+            //表现性 加工数量/实际运行时间
+            $expressive = $true_process_time > 0 ? number_format($process_num / $true_process_time,2) : 0;
+            //质量指数 加工数量- 废品数量 / 加工数量
+            $quality_index = $process_num > 0 ? number_format(($process_num - $fault_tmp) / $process_num,2) : 0;
+            //OEE
+
+            $oee = number_format($efficient * $expressive * $quality_index,2);
+            if($oee >  $a ) $oee -= $a;
+            $models[$k]['rate'] = sprintf('%.2f',$oee);
+        }
+        sort($models);
+        Redis::set('dwyApiOee',json_encode($models));
+
+
+        //
+        $models = [];
+        $site = 1;
+        $list = DeviceSite::where('site',$site)->wherein('title',['主缸压力','压力','温度'])->groupBy('device_name')->pluck('device_name')->toArray();
+        foreach ($list as  $v){
+            $models[$v] = [
+                "y_day_num"=> 0,
+                "y_month_num"=> 0,
+                "y_week_num"=> 0,
+                "w_day_num"=> 0,
+                "w_month_num"=> 0,
+                "w_week_num"=> 0,
+                "start_time"=> '',
+                "rate_y"=> 0,
+                "rate_w"=> 0,
+            ];
+        }
+        $device_point_key = DeviceSite::where('site',$site)->select(
+            '*'
+        )->get()->toArray();
+        //失败次数
+        $err_key = [];
+        foreach ($device_point_key as $v){
+            if($v['title'] == '主缸压力'||$v['title'] == '压力') $err_key[] = $v['key'];
+        }
+        list($day_key,$week_key,$month_key) = $this->wyiInitCount($err_key);
+        //运行次数
+        $run_key = [];
+        foreach ($device_point_key as $v){
+            if($v['title'] == '温度') $run_key[] = $v['key'];
+        }
+        list($run_day_key,$run_week_key,$run_month_key) = $this->wyiInitCount($run_key);
+
+        //当天最早开始时间
+        $dayStart = strtotime(date('Y-m-d')); //
+        $start_time = DeviceData::groupBy('device_name')->where('crt_time','>=',$dayStart)->select(DB::raw('min(crt_time) as crt_time'),'device_name')->get()->toArray();
+        $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();
+        $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();
+        $start_key = [];
+        $now_w_key = [];
+        $now_y_key = [];
+        foreach ($start_time as $v){
+            $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
+            $start_key[$v['device_name']] = $v['crt_time'];
+        }
+        foreach ($y_time as $v){
+            $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
+            $now_y_key[$v['device_name']] = $v['happening_data'];
+        }
+        foreach ($w_time as $v){
+            $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
+            $now_w_key[$v['device_name']] = $v['happening_data'];
+        }
+        //当天的开始与结束时间戳
+        foreach ($models as $k=>$v){
+            $models[$k]['y_day_num'] = $day_key[$k]??0;
+            $models[$k]['title'] = str_replace('广西大王椰','',$k);
+            $models[$k]['y_month_num'] = $month_key[$k]??0;
+            $models[$k]['y_week_num'] = $week_key[$k]??0;
+            $models[$k]['start_time'] = $start_key[$k]??0;
+            $models[$k]['w_day_num'] = $run_day_key[$k]??0;
+            $models[$k]['w_month_num'] = $run_week_key[$k]??0;
+            $models[$k]['w_week_num'] = $run_month_key[$k]??0;
+
+
+            $models[$k]['rate_w'] = isset($now_w_key[$k]) ?sprintf('%.2f',$now_w_key[$k]):0;
+            $models[$k]['rate_y'] =  isset($now_y_key[$k]) ? sprintf('%.2f',$now_y_key[$k]):0;
+            if( $models[$k]['rate_y']>10) $models[$k]['rate_y'] =  sprintf('%.2f',($models[$k]['rate_y']/100));
+        }
+        sort($models);
+        Redis::set('dwyApiOee',json_encode($models));
+        die('ok');
+    }
+
+
+}

app/Http/Controllers/Api/ScreenController.php

@@ -7,12 +7,82 @@ use App\Model\DeviceData;
 use App\Model\DeviceSite;
 use Illuminate\Http\Request;
 use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Redis;
 
 
 class ScreenController extends BaseController
 {
 
+    public function newdjg(){
+        $res = $this->post_helper('http://122.112.250.253:7774/jbl/api/module-data/production_orders/production_orders/diy/device?site=91451322MA5P9JNKXA',[]);
+        $res = json_decode($res,true)['data'];
+        $not_in_production_map_list = $res['not_in_production_map_list'];
+        $time = time();
+        foreach ($not_in_production_map_list as $k=>$v){
+            $t =  $time - substr($not_in_production_map_list[$k]['dispatch_no'],7,2)*9400;
+            $not_in_production_map_list[$k]['dispatch_no'] = 'WG'.date('Ymd',$t).substr($not_in_production_map_list[$k]['dispatch_no'],-4);
+        }
+        $res['not_in_production_map_list'] = $not_in_production_map_list;
+
+        return ['code'=>200,'data'=>$res,'msg'=>''];
+    }
+
+    public function newsczt(){
+        $res = $this->post_helper('http://122.112.250.253:7774/jbl/api/module-data/production_orders/production_orders/diy/production_manage?site=91451322MA5P9JNKXA',[]);
+        $res = json_decode($res,true)['data'];
+//        var_dump($res);die;
+        //处理一周的数据
+        $list_date = [];
+        $rand_data = [
+            1 => '77',
+            2 => '88',
+            3 => '99',
+            4 => '111',
+            5 => '122',
+            6 => '66',
+        ];
+        $date = strtotime(date('Y-m-d'))-7*86400;
+        for ($i=0;$i<10;$i++){
+            if(count($list_date)>=7) break;
+            $d = $date+$i*86400;
+            if(date('w',$d) == 0) continue;
+            $value = substr($d,5,3);
+//            $first = substr($d,4,1);
+//            if($first < 5) $value = '1'.$value;
+            if($value < 700) $value = '1'.$value;
+            $v = $value+$rand_data[date('w',$d)];
+            if(date('Y-m-d') == date('Y-m-d',$d))  $v = $v -substr( (86400 - (time()-strtotime(date('Y-m-d')))),0,3);
+            $list_date[] = [
+                'box_time' => date('Y-m-d',$d),
+                'box_num' => $v,
+            ];
+        }
+        $pace_map_list = $res['pace_map_list'];
+        $time = strtotime(date('Y-m-d'));
+        foreach ($pace_map_list as $k=>$v){
+            $t =  $time - substr($pace_map_list[$k]['order_no'],7,2)*86400;
+            $pace_map_list[$k]['order_no'] = 'SO'.date('Ymd',$t).substr($pace_map_list[$k]['order_no'],-4);
+        }
+
+        $completion_orders_dtl_map_list = $res['completion_orders_dtl_map_list'];
+
+        foreach ($completion_orders_dtl_map_list as $k=>$v){
+            $t =  $time - substr($completion_orders_dtl_map_list[$k]['completion_order_no'],7,2)*9400;
+            $completion_orders_dtl_map_list[$k]['completion_order_no'] = 'WG'.date('Ymd',$t).substr($completion_orders_dtl_map_list[$k]['completion_order_no'],-4);
+            $dd = time() -substr($completion_orders_dtl_map_list[$k]['completion_order_no'],9,2)*8;
+//            var_dump($completion_orders_dtl_map_list[$k]['completion_order_no']);
+//            var_dump(substr($completion_orders_dtl_map_list[$k]['completion_order_no'],7,2));
+//            var_dump($dd);die;
+            $completion_orders_dtl_map_list[$k]['created_date'] = date('Y-m-d',$dd).'T'.date('H:i:s',$dd).".".rand(100,999)."Z";
+        }
+//        var_dump($completion_orders_dtl_map_list);die;
+        $res['box_num_map_list'] = $list_date;
+        $res['pace_map_list'] = $pace_map_list;
+        $res['completion_orders_dtl_map_list'] = $completion_orders_dtl_map_list;
+//        dd($res);
+        return ['code'=>200,'data'=>$res,'msg'=>''];
+    }
     public function oee(){
 
         $models = [];
@@ -253,6 +323,7 @@ class ScreenController extends BaseController
 //        $start = strtotime($list[0]['c']);
         $list_key = [];
         $device_key = [];
+        $a = rand(1,2);
         foreach ($list as $k=>$v){
             $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
             if(!in_array($v['device_name'],$device_key))$device_key[] = $v['device_name'];
@@ -260,6 +331,7 @@ class ScreenController extends BaseController
             $list_key[$v['device_name']][$v['c']] = sprintf('%.2f',$v['happening_data']*1);
 //            $list_key[$v['device_name']][$v['c']] = rand(0,100);
 //            $list_key[]
+            $v['c'] = date('Y-m-d H:i',time()-$a*$k*60);
             $list[$k] = $v;
         }
 //        die('ss');
@@ -430,8 +502,8 @@ class ScreenController extends BaseController
         foreach ($key as $k=>$v){
             $key_list[] = $k;
         }
-        $id = DeviceData::wherein('dev_eui',$key_list)->max('id');
-        $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();
+//        $id = DeviceData::wherein('dev_eui',$key_list)->max('id');
+        $list = DeviceData::wherein('dev_eui',$key_list)->orderBy('id','desc')->select('crt_time','device_name','happening_data','dev_eui')->paginate(100, '', 'page', 1)->toArray();
         $list = $list['data'];
         foreach ($list as &$v){
             $v['device_name'] = substr(str_replace('广西大王椰','',$v['device_name']),0,19);
@@ -515,4 +587,40 @@ class ScreenController extends BaseController
 //        return $db;
 //    }
 
+    //分页共用
+    public function limit($db, $columns, $request)
+    {
+        $per_page = $request['page_size'] ?? 9999;
+        $page = $request['page_index'] ?? 1;
+        $return = $db->paginate($per_page, $columns, 'page', $page)->toArray();
+
+        $data['total'] = $return['total'];
+        $data['data'] = $return['data'];
+        return $data;
+    }
+
+    public function post_helper($url, $data)
+    {
+
+//        $data = json_encode($data);
+
+//        $header = [
+//            'Content-Type:application/json',
+//        ];
+        $ch = curl_init();
+
+//        curl_setopt($ch, CURLOPT_POST, 1);
+        curl_setopt($ch, CURLOPT_URL, $url);
+//        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
+//        if (!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
+        $r = curl_exec($ch);
+        curl_close($ch);
+
+        return $r;
+    }
+
+
 }

routes/api.php

@@ -59,6 +59,8 @@ Route::any('deviceChart', 'Api\ScreenController@deviceChart');
 Route::any('inout', 'Api\ScreenController@inout');
 Route::any('upInout', 'Api\ScreenController@upInout');
 Route::any('gzEchart', 'Api\ScreenController@gzEchart');
+Route::any('newsczt', 'Api\ScreenController@newsczt');
+Route::any('newdjg', 'Api\ScreenController@newdjg');
 Route::any('aa', 'Api\TestController@aa');
 Route::any('deviceCallback', 'Api\TestController@deviceCallback');
 Route::any('advertisement', 'Api\DwyController@advertisement');