TestController.php 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. <?php
  2. namespace App\Http\Controllers\Api;
  3. use App\Service\Box\BoxService;
  4. use App\Service\ProductionOrderService;
  5. use Illuminate\Support\Facades\Config;
  6. use Illuminate\Support\Facades\DB;
  7. class TestController extends BaseController
  8. {
  9. public function delTestQ(){
  10. (new BoxService())->delBoxLock();
  11. dd(1);
  12. }
  13. public function delTestQ2(){
  14. (new ProductionOrderService())->delBoxLock();
  15. dd(1);
  16. }
  17. public function tt(){
  18. // $db = DB::connection("mysql_001");
  19. // $u8 = $db->table('sys_config')
  20. // ->first();
  21. // dd($u8);
  22. $model_box = DB::connection("mysqlT9");
  23. $u8 = $model_box->table('setting')
  24. ->where('setting_name','u8')
  25. ->where('setting_value','<>','')
  26. ->first();
  27. if(empty($u8)) return [false, 'u8配置参数不存在!'];
  28. $u8 = $u8->setting_value;
  29. // 使用 eval() 函数执行字符串并转换为数组
  30. $u8 = eval("return {$u8};");
  31. if(empty($u8['domain'])) return [false, '外部域名不能为空!'];
  32. if(empty($u8['u8_api_port'])) return [false, 'u8程序API端口不能为空!'];
  33. if(empty($u8['u8_database_port'])) return [false, 'u8程序数据库端口不能为空!'];
  34. if(empty($u8['database'])) return [false, 'u8程序数据库不能为空!'];
  35. if(empty($u8['database_account'])) return [false, 'u8程序数据库登录账号不能为空!'];
  36. if(empty($u8['database_password'])) return [false, 'u8程序数据库登录密码不能为空!'];
  37. if(empty($u8['sAccID'])) return [false, 'u8程序sAccID不能为空!'];
  38. if(empty($u8['sServer'])) return [false, 'u8程序sServer不能为空!'];
  39. if(empty($u8['sUserID'])) return [false, 'u8程序sUserID不能为空!'];
  40. if(empty($u8['sPassword'])) return [false, 'u8程序sPassword不能为空!'];
  41. $config = [
  42. 'driver' => 'sqlsrv',
  43. 'host' => $u8['domain'],
  44. 'port' => $u8['u8_database_port'],
  45. 'database' => $u8['database'],
  46. 'username' => $u8['database_account'],
  47. 'password' => $u8['database_password'],
  48. ];
  49. // 数据库配置设置
  50. Config::set('database.connections.sqlsrvs', $config);
  51. // 连接
  52. try {
  53. $pdo = DB::connection('sqlsrvs')->getPdo();
  54. if ($pdo instanceof \PDO) {
  55. // 连接成功的逻辑代码
  56. $db = DB::connection('sqlsrvs');
  57. dd(111);
  58. } else {
  59. dd(1233);
  60. }
  61. } catch (\Throwable $e) {
  62. dd($e->getMessage());
  63. }
  64. }
  65. }