workHour/app/Service/Device/DeviceCommonService.php

<?php

namespace App\Service\Device;


use App\Jobs\PushDeviceJob;
use App\Service\Service;

class DeviceCommonService extends Service
{
    public $deviceList = [
        //腹带抛光机
        ///HC/STWDL/WriteRealtimeData/WDL2
        ['type' => 'FDPGJ', 'id' => 'FDPGJ', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'WXM', 'id' => 'WXM1', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'STWDL', 'id' => 'WDL2', 'cmd' => '00 00 00 00 00 06 01 02 00 00 00 0A'],
        ['type' => 'STWDL', 'id' => 'WDL3', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 32'],
        ['type' => 'GTPGJ', 'id' => 'GTPG1', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG2', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG3', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG4', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG5', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG6', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG7', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'GTPGJ', 'id' => 'GTPG8', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 07'],
        ['type' => 'BLJ', 'id' => 'BL1', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ1', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ2', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ3', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ4', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ5', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ6', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ7', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ8', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ9', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'QZJ', 'id' => 'QZ10', 'cmd' => '00 00 00 00 00 06 01 03 00 00 00 09'],
        ['type' => 'CGJ', 'id' => 'CG1', 'cmd' => '00 03 00 00 00 06 01 03 A4 04 00 01'],
        ['type' => 'CGJ', 'id' => 'CG1', 'cmd' => '00 09 00 00 00 06 01 02 60 05 00 01'],
        ['type' => 'CGJ', 'id' => 'CG1', 'cmd' => '00 0A 00 00 00 06 01 02 60 06 00 01'],
        // 以后增加更多设备...
    ];

    public function dealDevice($type, $message, callable $logger = null)
    {
        $message = str_replace(" ", "", $message);
        $return = '';
        switch ($type) {
            case "FDPGJ":
                $return = $this->FDPGJ($message, $type);
                break;
            case "WXM1":
                $return = $this->WXM1($message, $type);
                break;
            case "GTPG1":
            case "GTPG2":
            case "GTPG3":
            case "GTPG4":
            case "GTPG5":
            case "GTPG6":
            case "GTPG7":
            case "GTPG8":
                $return = $this->GTPG($message, $type);
                break;
            case "BL1":
                $return = $this->BLJ($message, $type);
                break;
            case "QZ1":
            case "QZ2":
            case "QZ3":
            case "QZ4":
            case "QZ5":
            case "QZ6":
            case "QZ7":
            case "QZ8":
            case "QZ9":
            case "QZ10":
                $return = $this->QZ($message, $type);
                break;
            case "CG1":
                $return = $this->CG($message, $type);
                break;
            case "WDL3":
                $return = $this->WDL($message, $type);
                break;
            default:
                break;
        }

        if (!empty($return)) {
            $data = [
                "data" => [
                    "deviceId" => "",
                    "dataPoints" => [
                    ],
                ],
                "type" => "dataPoint"

            ];
            foreach ($return as $v) {
                if(empty($data['data']['deviceId'])) $data['data']['deviceId'] = $v['code'];
                $data['data']['dataPoints'][] =  [
                    "dataPointId" => $v['type'],
                    "value" => $v['value'],
                ];
            }
            dispatch((new PushDeviceJob($data)))->onQueue('device_hc');
            //拼装结构
            if (isset($data)) {
                $logger("设备 {$type} 处理完成,数据：" . json_encode($data));
            }
        }
    }


    public function WDL($message, $type)
    {
        //0000 0000 0067 0103 64
        //0255 0288 02a2 02a2 028f 0247 0022 0000 0000 0079 0087 008e 0086 0022 0000 0000 0000 0000 0002 0002 0002 0002 0002 0002 0000 0002 0002 0002 0002 0001 0000 0000
        //0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000
        //运行状态、运行时间（分)、停止时间(分）、下压次数、下压频率（速度），次/分
        if (strlen($message) > 100) {
            $list = $this->dealMessage($message, [0, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4, 4]);
            $dispatch = [
                [
                    'code' => $type,
                    "type" => '_0',
                    "value" => $list[0],
                ], [
                    'code' => $type,
                    "type" => '_1',
                    "value" => $list[1],
                ], [
                    'code' => $type,
                    "type" => '_2',
                    "value" => $list[2],
                ], [
                    'code' => $type,
                    "type" => '_3',
                    "value" => $list[3],
                ], [
                    'code' => $type,
                    "type" => '_4',
                    "value" => $list[4],
                ], [
                    'code' => $type,
                    "type" => '_5',
                    "value" => $list[5],
                ], [
                    'code' => $type,
                    "type" => '_6',
                    "value" => $list[6],
                ], [
                    'code' => $type,
                    "type" => '_9',
                    "value" => $list[9],
                ], [
                    'code' => $type,
                    "type" => '_10',
                    "value" => $list[10],
                ], [
                    'code' => $type,
                    "type" => '_11',
                    "value" => $list[11],
                ], [
                    'code' => $type,
                    "type" => '_12',
                    "value" => $list[12],
                ], [
                    'code' => $type,
                    "type" => '_20',
                    "value" => $list[20],
                ]
            ];
            return $dispatch;
        }

    }


    //车沟机
    public function CG($message, $type)
    {
        $code = substr($message, 3, 1);
        //0004 0000 0005 0103 02 3a98
        if (strlen($message) > 10) {
            //进刀长度\进刀速度\退刀速度\产量计数\产量设定\急停\主机热继电器\料斗热继电器\气压报警\车沟马达启动（运行信号）\报警
            $dispatch = [];
            switch ($code) {
                case "3":
                    $list = $this->dealMessage($message, [4]);
                    $value = hexdec($list[0]);
                    $num = 3;
                    break;
                case "9":
                    $list = $this->dealMessage($message, [2]);
                    $value = hexdec($list[0]);
                    $num = 9;
                    break;
                case "a":
                    $list = $this->dealMessage($message, [2]);
                    $value = hexdec($list[0]);
                    $num = 10;
                    break;
                default:
                    break;
            }
            if (isset($value)) {
                $dispatch[] = [
                    'code' => $type,
                    "type" => '_' . $num,
                    "value" => $value,
                ];
            }
            return $dispatch;
        }

    }

    //切轴机
    public function QZ($message, $type)
    {
        //0000 0000 0015 01 03 12 0001 00000370 00000326 00020b3d 000001e0
        //运行状态、运行时间（分)、停止时间(分）、下压次数、下压频率（速度），次/分
        if (strlen($message) > 50) {
            $list = $this->dealMessage($message, [4, 8, 8, 8, 8]);
            $run_state = hexdec($list[0]);
            $run_time = hexdec($list[1]);
            $stop_time = hexdec($list[2]);
            $run_num = hexdec($list[3]);
            $run_frequency = hexdec($list[4]);
            $dispatch = [
                [
                    'code' => $type,
                    "type" => '_0',
                    "value" => $run_state,
                ], [
                    'code' => $type,
                    "type" => '_1',
                    "value" => $run_time,
                ], [
                    'code' => $type,
                    "type" => '_2',
                    "value" => $stop_time,
                ], [
                    'code' => $type,
                    "type" => '_3',
                    "value" => $run_num,
                ], [
                    'code' => $type,
                    "type" => '_4',
                    "value" => $run_frequency,
                ],
            ];
            return $dispatch;
        }

    }

    //编链机
    public function BLJ($message, $type)
    {
        //0000 0000 0015 0103 12 0000 00000000 00000036 00000011 00000000
        //运行状态、运行时间（分)、停止时间(分）、下压次数、下压频率（速度），次/分
        if (strlen($message) > 50) {
            $list = $this->dealMessage($message, [4, 8, 8, 8, 8]);
            $run_state = hexdec($list[0]);
            $run_time = hexdec($list[1]);
            $stop_time = hexdec($list[2]);
            $run_num = hexdec($list[3]);
            $run_frequency = hexdec($list[4]);
            $dispatch = [
                [
                    'code' => $type,
                    "type" => '_0',
                    "value" => $run_state,
                ], [
                    'code' => $type,
                    "type" => '_1',
                    "value" => $run_time,
                ], [
                    'code' => $type,
                    "type" => '_2',
                    "value" => $stop_time,
                ], [
                    'code' => $type,
                    "type" => '_3',
                    "value" => $run_num,
                ], [
                    'code' => $type,
                    "type" => '_4',
                    "value" => $run_frequency,
                ],
            ];
            return $dispatch;
        }
    }

    //滚筒抛光机
    public function GTPG($message, $type)
    {
        //0000 0000 0011 01 03 0e 0001 0000004b 00000355 00000007
        //运行状态、运行时间（分)、停止时间(分）、运行次数
        if (strlen($message) > 40) {
            $list = $this->dealMessage($message, [4, 8, 8, 8]);
            $run_state = hexdec($list[0]);
            $run_time = hexdec($list[1]);
            $stop_time = hexdec($list[2]);
            $run_num = hexdec($list[3]);
            $dispatch = [
                [
                    'code' => $type,
                    "type" => '_0',
                    "value" => $run_state,
                ], [
                    'code' => $type,
                    "type" => '_1',
                    "value" => $run_time,
                ], [
                    'code' => $type,
                    "type" => '_2',
                    "value" => $stop_time,
                ], [
                    'code' => $type,
                    "type" => '_3',
                    "value" => $run_num,
                ],
            ];
            return $dispatch;
        }

    }

    //无芯磨机
    public function WXM1($message, $type)
    {
        //0000 0000 0015 01 03 12 0001 00000153 00000244 00000003 00000000
        //00000000001101030e0001000006e7000003e20000000a
        //运行状态、运行时间（分)、停止时间(分）、运行次数
        if (strlen($message) > 40) {
            $list = $this->dealMessage($message, [4, 8, 8, 8]);
            $run_state = hexdec($list[0]);
            $run_time = hexdec($list[1]);
            $stop_time = hexdec($list[2]);
            $run_num = hexdec($list[3]);
            $dispatch = [
                [
                    'code' => $type,
                    "type" => '_0',
                    "value" => $run_state,
                ], [
                    'code' => $type,
                    "type" => '_1',
                    "value" => $run_time,
                ], [
                    'code' => $type,
                    "type" => '_2',
                    "value" => $stop_time,
                ], [
                    'code' => $type,
                    "type" => '_3',
                    "value" => $run_num,
                ],
            ];
            return $dispatch;
        }

    }

    //腹带抛光机
    public function FDPGJ($message, $type)
    {
        //0000 0000 0015 01 03 12 0000 00000000 000003d7 00000000 00000000
        //运行状态、运行时间（分)、停止时间(分）、运行次数
        if (strlen($message) > 40) {
            $list = $this->dealMessage($message, [4, 8, 8, 8]);
            $run_state = hexdec($list[0]);
            $run_time = hexdec($list[1]);
            $stop_time = hexdec($list[2]);
            $run_num = hexdec($list[3]);
            $dispatch = [
                [
                    "code" => $type,
                    "type" => '_0',
                    "value" => $run_state,
                ], [
                    "type" => $type . '_1',
                    "value" => $run_time,
                ], [
                    "type" => $type . '_2',
                    "value" => $stop_time,
                ], [
                    "type" => $type . '_3',
                    "value" => $run_num,
                ],
            ];
            return $dispatch;
        }

    }

    public function dealMessage($message, $list)
    {
        $message = substr($message, 18);
        $return = [];
        foreach ($list as $v) {
            $return[] = substr($message, 0, $v);
            $message = substr($message, $v);
        }
        return $return;
    }

    public function disPatch($data){

    }
}