queue_services/app/Http/Controllers/Api/DwyController.php

<?php

namespace App\Http\Controllers\Api;


use App\Model\BigKingTbj;
use App\Service\EmployeeService;
use App\Service\SysMenuService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Redis;
use Illuminate\Support\Str;

class DwyController extends BaseController
{


    public function advertisement()
    {

        return ['status' => 200, 'data' => [
            'video' => ['https://clouddevice.qingyaokeji.com/1.mp4',
                'https://clouddevice.qingyaokeji.com/2.mp4'],
            'img' => [
                'https://clouddevice.qingyaokeji.com/3.jpeg',
                'https://clouddevice.qingyaokeji.com/3.jpeg',
            ],
            'limit_time' => 10
        ]];
    }

    public function openCommand(Request $request)
    {
        $data = $request->all();
        file_put_contents('dwy1.txt', json_encode($data) . PHP_EOL, 8);
        $device_id = $data['device_code'];
        $box_code = $data['box_code'];
        $key = $data['type'];
        if ($key === 'UP') {
            $num = Redis::get($device_id . 'status_num');
            if (empty($num)) $num = 0;
            $num++;

            if ($num === 1) {
                Redis::set($device_id . 'status_num', $num);
                Redis::expire($device_id . 'status_num', 300);

                Redis::set($device_id . 'status', 201);
                Redis::expire($device_id . 'status', 300);

                Redis::set($device_id, json_encode([$box_code]));
                Redis::expire($device_id, 300);
            } else {

                $old = Redis::get($device_id);
                if (empty($old)) $old = [];
                else $old = json_decode($old, true);
                $data = array_merge($old, [$box_code]);
                Redis::set($device_id, json_encode($data));
                Redis::expire($device_id, 300);

                Redis::del($device_id . 'status');
                Redis::del($device_id . 'status_num');
            }

        } else {
            Redis::set($device_id, json_encode([$box_code]));
            Redis::expire($device_id, 300);
        }

        return ['status' => 200];


    }

    public function openDoor(Request $request)
    {
        $data = $request->all();
        file_put_contents('dwy1.txt', json_encode($data) . PHP_EOL, 8);
        $data = $data['device_code'];
        $code = Redis::get($data);
        Redis::del($data);
//        return ['data'=>['CK00001','CK00018'],'status'=>200];
        if (empty($code)) return ['data' => [], 'status' => 201];

        $status = Redis::get($data . 'status');
        if (empty($status)) $status = 200;
        return ['data' => json_decode($code, true), 'status' => $status];
    }


    public function getOpenCommand(Request $request)
    {

        $data = $request->all();
        file_put_contents('dwy1.txt', json_encode($data) . PHP_EOL, 8);
        $device_id = $data['device_code'];
        $box_code = $data['box_code'];
        $key = $device_id . '_' . $box_code;
        $return = 201;
        $status = Redis::get($key);
        if ($status) {
            $return = 200;
            Redis::del($key);
        }

        return ['status' => $return];
    }

    public function boxList(Request $request)
    {
        $param = $request->all();
        $token = $param['token'];
        $device_code = $param['device_code'];

        //商标仓列表
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/device/device/diy/device_code';
        $header = [
            'Content-Type:application/json',
            'Authorization: ' . $token,
        ];
        $box_data = $this->post_helper($url, '{"device_code":"' . $device_code . '"}', $header);
        $box_data = json_decode($box_data, true);
        if (isset($box_data['status']) && $box_data['status'] === 'success') {
            //库存查询
            $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/box_inventory';
            $stock_data = $this->post_helper($url, '{"device_code":"' . $device_code . '"}', $header);
            $stock_data = json_decode($stock_data, true);
            if ($stock_data) {
                $list = [];
                $material_list = [];
                foreach ($box_data['data'] as $v) {
                    $list[$v['box_code']] = [
                        'material_code' => $v['material_code'],
                        'material_code_show' => $v['material_code_show'],
                        'box_code' => $v['box_code'],
                        'box_code_show' => $v['box_code_show'],
                        'min_stock_qty' => $v['min_stock_qty'] ?? 0,
                        'safe_stock_qty' => $v['safe_stock_qty'] ?? 0,
                        'status' => 1, //0设备仓中没有对应库存，1有对应库存，2对应商标仓中还有数量不允许上标
                        'qty' => 0,
                    ];
                    $material_list[$v['material_code']][] = $v['box_code'];
                }

                $return = [];
                foreach ($stock_data as $v) {
                    if (isset($material_list[$v['material_code']]) && $v['box_code'] == 'CK00001' && $v['qty'] > 0) {
                        foreach ($material_list[$v['material_code']] as $vv) {
                            $list[$vv]['status'] = 1;
                        }
                    }
                    if (isset($list[$v['box_code']]) && $v['qty'] > 0) {
                        $list[$v['box_code']]['qty'] = $v['qty'];
                    }
                }
                foreach ($list as $v) {
                    if ($v['qty'] > 0) {
                        $v['status'] = 2;
                    }
                    $return[] = $v;
                }
                return ['status' => 'success', 'data' => $return];
            }

        }

        return $box_data;


    }


    public function setLb(Request $request)
    {

        $param = $request->all();
        file_put_contents('dwy.txt', json_encode($param) . PHP_EOL, 8);
//        $param = [
//            'token'=>'Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiIyNzM2OTUyNTA3NTI5NTQzNzMiLCJhdXRoIjoiUk9MRV9JTk5FUl9VU0VSLFJPTEVfQlJBTkRfQVJSRVNULFJPTEVfQURNSU4iLCJ0b2tlbklkIjoiOTUwIiwiZXhwIjoxNzA3OTcxMTcxfQ.2VQ9Wqmk4rvKAcTsQPw59llBbeXjalKDGIZA4kesnuOJ0POmPVOVlRLbTtUDxl0XiFdPDUrKzuEFl2DXSgQdJg',
//            'list'=>[
//                [
//                    'title'=>'优选A7家具板ENF小标',
//                    'num'=>'20',
//                ],[
//                    'title'=>'植萃除醛圆标',
//                    'num'=>'10',
//                ],
//            ],
//        ];
        $token = $param['token'];
        $list = $param['list'];
        $mac = $param['mac'];
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/box_inventory';
        $header = [
            'Content-Type:application/json',
            'Authorization: ' . $token,
        ];
        $data = $this->post_helper($url, '{"device_code":"'.$mac.'"}', $header);
        $data = json_decode($data, true);

        usort($data, function ($a,$b){
            return str_replace('CK','',$a['box_code']) - str_replace('CK','',$b['box_code']);
        });
        foreach ($data as $k => &$v) {

            if (!isset($v['product_list'])) $v['product_list'] = [];
            if (!isset($v['box_code_show']) || $v['box_code_show'] == '设备仓') {
                unset($data[$k]);
                continue;
            }
//            $v['use_qty'] = $v['qty'];
//            if($v['box_code'] === 'CK00008'){
//                $v['use_qty'] = 150;
//                $v['qty'] = 150;
////                $v['qty'] = 200;
//                $v['in_stock_qty'] = 0;
//            }

            if ($v['qty'] <= 0) {
                unset($data[$k]);
                continue;
            }
            $v['use_qty'] = $v['qty'];
            if (!isset($v['send_qty'])) $v['send_qty'] = 0;
            foreach ($list as $kk => $vv) {


                if ($vv['num'] == 0) continue;
                if ($v['material_code_show'] === $vv['title']) {
                    $v['restore_qty'] = isset($vv['restock_qty']) && $vv['restock_qty'] > 0 ? $vv['restock_qty'] : 0;
                    if (($v['qty'] - $v['send_qty']) > $vv['num']) {
                        $list[$kk]['num'] -= $vv['num'];
                        $v['send_qty'] += $vv['num'];
                        $p_total = $vv['num'];
                    } else {
                        $list[$kk]['num'] -= ($v['qty'] - $v['send_qty']);
                        $p_total = $vv['num'] - ($v['qty'] - $v['send_qty']);
                        $v['send_qty'] += ($v['qty'] - $v['send_qty']);
                    }


                    //把产品相关参数进行封装
                    ////产品编号
                    //"product_code": "",
                    ////产品名称
                    //"product_code_show": "",
                    ////工艺
                    //"process_title": "",
                    ////花色
                    //"color": "",
                    ////工艺2
                    //"process_title_two": "",
                    ////花色2
                    //"color_two": "",
                    $key_arr = [
                        'product_code' => $vv['product_code'] ?? '',
                        'product_code_show' => $vv['product_code_show'] ?? '',
                        'order_item_id' => $vv['order_item_id'] ?? '',
                        'order_item_id_show' => $vv['order_item_id_show'] ?? '',
                        'process_title' => $vv['process_title'] ?? '',
                        'color' => $vv['color'] ?? '',
                        'process_title_two' => $vv['process_title_two'] ?? '',
                        'color_two' => $vv['color_two'] ?? '',
                        'send_qty' => $p_total,
                        'fake_qty' => $p_total,
//                        'send_qty' => 0,
                        'restock_qty' => $vv['restock_qty'] ?? 0,
                    ];
                    $v['product_list'][] = $key_arr;
                }



            }
        }

        usort($data, function ($a,$b){
            return str_replace('CK','',$a['box_code']) - str_replace('CK','',$b['box_code']);
        });
        return ['status' => 200, 'data' => $data];
    }

    public function zjlb(Request $request)
    {

        $param = $request->all();
        file_put_contents('dwy1.txt', json_encode($param) . PHP_EOL, 8);
//        $param = [
//            'token'=>'Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiIyNzM2OTUyNTA3NTI5NTQzNzMiLCJhdXRoIjoiUk9MRV9JTk5FUl9VU0VSLFJPTEVfQlJBTkRfQVJSRVNULFJPTEVfQURNSU4iLCJ0b2tlbklkIjoiOTUwIiwiZXhwIjoxNzA3OTcxMTcxfQ.2VQ9Wqmk4rvKAcTsQPw59llBbeXjalKDGIZA4kesnuOJ0POmPVOVlRLbTtUDxl0XiFdPDUrKzuEFl2DXSgQdJg',
//            'list'=>[
//                [
//                    'title'=>'优选A7家具板ENF小标',
//                    'num'=>'20',
//                ],[
//                    'title'=>'植萃除醛圆标',
//                    'num'=>'10',
//                ],
//            ],
//        ];
//        dd(json_encode($param));
//        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/box_inventory';
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/box_inventory_dtl_qr/page';
        $header = [
            'Content-Type:application/json',
            'Authorization: ' . $request->header('Authorization'),
        ];
        $param = '{"direction":"DESC","property":"id","fromClientType":"pc","number":0,"sorts":[],"rules":[{"field":"box_inventory.device_code","option":"LIKE_ANYWHERE","values":["'.$param['device_code'].'"]}],"size":15,"specialConditions":[],"workflowSearchBean":{},"dynamicFormCode":"box_inventory","developmentSystemId":null,"debugFlag":true}';
        $data = $this->post_helper($url, $param, $header);
//        $data = $this->post_helper($url, json_encode($param), $header);
        $data = json_decode($data, true);
        $data = $data['content'] ?? [];
        foreach ($data as $k => &$v) {
            $v['material_code_show'] = $v['box_inventory']['material_code_show'];
            $v['qty'] = $v['roll_qty'];
            $v['use_qty'] = 0;
        }
        sort($data);
        return json_encode($data);
    }

    public function boxOut(Request $request)
    {


        $param = $request->all();
        file_put_contents('dwy.txt', json_encode($param) . PHP_EOL, 8);
        //商标绑定
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/1';
//        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/lead_bind';
        $header = [
            'Content-Type:application/json',
            'Authorization: ' . $request->header('Authorization'),
        ];
        $lead_bind = $param['lead_bind'];
        $this->post_helper($url, json_encode($lead_bind), $header);

        //商标出库
//        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/lead_bind_out_stock';
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_in_stock/brand_in_stock/diy/11';
        $lead_bind = $param['lead_out'];
        $this->post_helper($url, json_encode($lead_bind), $header);
        return ['status'=>200,'msg'=>'success'];
    }

    public function post_helper($url, $data, $header)
    {
        $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);
        file_put_contents('33.txt',$r.PHP_EOL,8);
        return $r;

    }

    public function setTbData(Request $request){
        $data = $request->all();
        if(empty($data['id']) && empty($data['data'])) return [201, ''];

        BigKingTbj::updateOrCreate(
            ['id' => $data['id']], //查询条件
            [
                "id" => $data['id'],
                "data" => json_encode($data['data'])
            ]  //添加或者修改的数据
        );

        return [200, ''];
    }

    public function getTbData(Request $request){
        $data = $request->all();
        if(empty($data['id'])) return [201, ''];

        $result = BigKingTbj::where('id',$data['id'])->first();
        if(empty($result)) return [200,'data' => []];
        $result = $result->toArray();

        return [200, 'data' => json_decode($result['data'],true)];
    }
    public function setBoxTrademark(Request $request){
        $url = 'https://tm.dwycloud.com/jbl/api/module-data/brand_sale_order/brand_sale_order/diy/find_roll_qr_code_list';
        $header = [
            'Content-Type:application/json',
            'Authorization: ' .'Bearer eyJhbGciOiJIUzUxMiJ9.eyJzdWIiOiI1NjYxNTc5MjMwMDUzNzAzNjgiLCJhdXRoIjoiUk9MRV9JTk5FUl9VU0VSLFJPTEVfQlJBTkRfU1VQUExJRVIsUk9MRV9JTlRFUkZBQ0UsUk9MRV9VU0VfQlJBTkRfU1VQUExJRVIsUk9MRV9TRU5EX0JSQU5EX1NVUFBMSUVSIiwidG9rZW5JZCI6IjQiLCJleHAiOjE3MTk2MzM1NTJ9.CC69s4dpUdd9UqQlpeK5UF3DwY5Zenn-YHv8Iy1ai0cCXgere7r7jskWU9ARmKotys2tCGYRlO-Idtxdwdsefg',
        ];
        $data  = [
            'roll_qr_code_list' => [
                '171368443563212'
            ]
        ];
        $a = $this->post_helper($url, json_encode($data), $header);
        var_dump($a);die;
        $a = json_decode($a,true);
        $detail = [];
        foreach ($a['data'] as $v){
            $code = $v['brand_qr_code'];
            $detail[] = $code;
        }
        file_put_contents('1.txt',json_encode($detail));
        var_dump($a);die;
    }


    public function getBoxTrademark(Request $request){
        $data = $request->all();
        if(empty($data['box_nos']) && empty($data['mac'])) return ['status' => 201,'data' => []];

        $box_nos = $data['box_nos'];
        $dv = $data['mac'];
        $detail = [];

        //测试写入文件
//        foreach ($box_nos as $v) {
//            $filePath = storage_path( "app/box_trade/"."{$dv}_{$v}.txt");
//            if (! file_exists(storage_path('box_trade'))) Storage::makeDirectory('box_trade');
//            file_put_contents($filePath,json_encode(['a' => '测试','b'=>'测试2']));
//        }

        //读取文件
        foreach ($box_nos as $v) {
            //            $filePath = public_path($file_path . "{$dv}_{$v}.txt");
            $filePath = storage_path("app/box_trade/"."{$dv}_{$v}.txt");
            if(file_exists($filePath)){
                if (($content = file_get_contents($filePath)) === false) continue;
                $decodedContent = json_decode($content, true);
                if (json_last_error() !== JSON_ERROR_NONE) continue;
                $detail[] = [
                    'detail'=>$decodedContent,
                    'code'=>$v,
                ];
            }
        }

        return ['status' => 200, 'data' => $detail];
    }


}