qyadmin/app/Http/Controllers/Api/TestController.php

<?php

namespace App\Http\Controllers\Api;

use App\Service\WorkFlowService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Redis;
use App\Events\MessageSent;
use App\Console\Commands\WebSocketServer;
use Ratchet\ConnectionInterface;
class TestController extends BaseController
{
    protected $webSocketServer;

    public function aa(){
//       (new OaService())->sendWxMsg(1,3,2,48,["T9RMO.202408071529012839","拒绝","2024-08-07 15:29:44","(未填写原因)"],"/pages/ReturnExchangeOrder/detail/detail?order_number=55");
        var_dump(md5(123123));die;
        //测试消息发送
        $tmp_data = [
            "11111",
            '222',
            '审核通过',
            date('Y-m-d H:i:s'),
        ];
        (new OaService())->sendWxMsg(179,1,0,37,$tmp_data,"/pageA/pages/SalesOrder/detail/detail?order_number=T9XX.202408091241002925");
        (new OaService())->sendWxMsg(179,1,0,37,$tmp_data,"/pageA/pages/SalesOrder/detail/detail?order_number=T9XX.2024080912410029251");

        //测试消息发送
        $tmp_data = [
            "22222",
            '222',
            '审核通过',
            '22222',
            date('Y-m-d H:i:s'),

        ];
//        (new OaService())->sendWxMsg(1,2,1,37,$tmp_data,"/pages/SalesOrder/index/index");

        //测试消息发送
        $tmp_data = [
            "333333",
            '审核通过',
            date('Y-m-d H:i:s'),
            '22222',
        ];
//        (new OaService())->sendWxMsg(1,3,2,37,$tmp_data,"/pages/SalesOrder/index/index");
die;
        $params = json_decode('{"api_key":"d3848b47-4179-4b02-8d32-b78cd7672c6c","return_url":"https://payment.rummyliver.in/notify/s2pay/payment","mode":"LIVE","order_id":"1710493215363410880003","amount":"501.00","currency":"INR","description":"for payment","name":"iahfi","email":"jvqbgvv2908699@outlook.com","phone":"9329086994","city":"Mumbai","zip_code":"400002","country":"IND"}',true);

        $hash_columns = ['merchant_reference_number','Amount','account_name','account_number','ifsc_code','bank_name','bank_branch','transfer_type','address_line_1', 'address_line_2', 'amount', 'api_key', 'city', 'country', 'currency', 'description', 'email', 'mode', 'name', 'order_id', 'phone', 'return_url', 'state', 'udf1', 'udf2', 'udf3', 'udf4', 'udf5', 'zip_code',];
        sort($hash_columns);
        $hash_data = '3b1db341fa70abc03af5c3676811a82bec99673f';
        foreach ($hash_columns as $column) {
            if (isset($params[$column])) {
                if (strlen($params[$column]) > 0) {
                    $hash_data .= '|' . trim($params[$column]);
                }
            }
        }
        $hash = strtoupper(hash("sha512", $hash_data));
        var_dump($hash);die;
        return $hash;

        $text = '这是测试';
        $key = '72f8c912d462b1md034ff46cbedaskc80bf';
        $sign = Hash::make($text.$key);
        var_dump(Hash::check('这是测试'.'72f8c912d462b1md034ff46cbedaskc80bf',$sign));
        var_dump($sign);die;
    }

    public function pushLog(Request $request){
        $request = $request->all();
        if(isset($request['tag'])){
            $queueName = 'log_queue'; // 队列名称
            $logData = [
                'tag' => $request['tag'],
                'type' => $request['type'],
                'box' => $request['box'],
                'timestamp' => round(microtime(true) * 1000),
            ];
//            $webSocketServer = new WebSocketServer();
//            $webSocketServer->pushMessageToClients(json_encode($logData));
//            $this->webSocketServer->pushMessageToClients(json_encode($logData));
//            foreach ($this->clients as $client) {
//                $client->send(json_encode($logData));
//            }
//            broadcast(new MessageSent(json_encode($logData)))->toOthers();
            // 推送数据到 Redis 队列
            Redis::rpush($queueName, json_encode($logData));


        }
        echo 'ok';die;
    }

    public function delLog(){
        $queueName = 'log_queue';
        Redis::del($queueName);
        die('ok');
        $queueName = 'log_queue'; // 队列名称
        $logData = Redis::lpop($queueName);

        if ($logData) {
            $decodedData = json_decode($logData, true);
            return response()->json([
                'status' => 200,
                'data' => $decodedData,
            ]);
        }

        return response()->json([
            'status' => 201,
            'data' => '',
        ]);
    }
}