TestController.php 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Service\WorkFlowService;
  4. use Illuminate\Http\Request;
  5. use Illuminate\Support\Facades\Redis;
  6. use App\Events\MessageSent;
  7. use App\Console\Commands\WebSocketServer;
  8. use Ratchet\ConnectionInterface;
  9. class TestController extends BaseController
  10. {
  11. protected $webSocketServer;
  12. public function aa(){
  13. // (new OaService())->sendWxMsg(1,3,2,48,["T9RMO.202408071529012839","拒绝","2024-08-07 15:29:44","(未填写原因)"],"/pages/ReturnExchangeOrder/detail/detail?order_number=55");
  14. //测试消息发送
  15. $tmp_data = [
  16. "11111",
  17. '222',
  18. '审核通过',
  19. date('Y-m-d H:i:s'),
  20. ];
  21. (new OaService())->sendWxMsg(179,1,0,37,$tmp_data,"/pageA/pages/SalesOrder/detail/detail?order_number=T9XX.202408091241002925");
  22. (new OaService())->sendWxMsg(179,1,0,37,$tmp_data,"/pageA/pages/SalesOrder/detail/detail?order_number=T9XX.2024080912410029251");
  23. //测试消息发送
  24. $tmp_data = [
  25. "22222",
  26. '222',
  27. '审核通过',
  28. '22222',
  29. date('Y-m-d H:i:s'),
  30. ];
  31. // (new OaService())->sendWxMsg(1,2,1,37,$tmp_data,"/pages/SalesOrder/index/index");
  32. //测试消息发送
  33. $tmp_data = [
  34. "333333",
  35. '审核通过',
  36. date('Y-m-d H:i:s'),
  37. '22222',
  38. ];
  39. // (new OaService())->sendWxMsg(1,3,2,37,$tmp_data,"/pages/SalesOrder/index/index");
  40. die;
  41. $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);
  42. $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',];
  43. sort($hash_columns);
  44. $hash_data = '3b1db341fa70abc03af5c3676811a82bec99673f';
  45. foreach ($hash_columns as $column) {
  46. if (isset($params[$column])) {
  47. if (strlen($params[$column]) > 0) {
  48. $hash_data .= '|' . trim($params[$column]);
  49. }
  50. }
  51. }
  52. $hash = strtoupper(hash("sha512", $hash_data));
  53. var_dump($hash);die;
  54. return $hash;
  55. $text = '这是测试';
  56. $key = '72f8c912d462b1md034ff46cbedaskc80bf';
  57. $sign = Hash::make($text.$key);
  58. var_dump(Hash::check('这是测试'.'72f8c912d462b1md034ff46cbedaskc80bf',$sign));
  59. var_dump($sign);die;
  60. }
  61. public function pushLog(Request $request){
  62. $request = $request->all();
  63. if(isset($request['tag'])){
  64. $queueName = 'log_queue'; // 队列名称
  65. $logData = [
  66. 'tag' => $request['tag'],
  67. 'timestamp' => time(),
  68. ];
  69. // $webSocketServer = new WebSocketServer();
  70. // $webSocketServer->pushMessageToClients(json_encode($logData));
  71. // $this->webSocketServer->pushMessageToClients(json_encode($logData));
  72. // foreach ($this->clients as $client) {
  73. // $client->send(json_encode($logData));
  74. // }
  75. // broadcast(new MessageSent(json_encode($logData)))->toOthers();
  76. // 推送数据到 Redis 队列
  77. Redis::rpush($queueName, json_encode($logData));
  78. }
  79. echo 'ok';die;
  80. }
  81. public function delLog(){
  82. $queueName = 'log_queue';
  83. Redis::del($queueName);
  84. die('ok');
  85. $queueName = 'log_queue'; // 队列名称
  86. $logData = Redis::lpop($queueName);
  87. if ($logData) {
  88. $decodedData = json_decode($logData, true);
  89. return response()->json([
  90. 'status' => 200,
  91. 'data' => $decodedData,
  92. ]);
  93. }
  94. return response()->json([
  95. 'status' => 201,
  96. 'data' => '',
  97. ]);
  98. }
  99. }