diff --git a/web/ws_task.php b/web/ws_task.php index 0eb2857..79f8fde 100644 --- a/web/ws_task.php +++ b/web/ws_task.php @@ -8,6 +8,7 @@ require_once __DIR__ . '../../source/application/common/dm/Dm.php'; require_once __DIR__ . '../../source/application/common/logic/PassFlow.php'; require_once __DIR__ . '../../source/thinkphp/helper.php'; require_once __DIR__ . '../../source/thinkphp/library/think/Config.php'; +require_once __DIR__ . '../../source/application/common.php'; $config = require_once __DIR__ . '../../source/application/database.php'; $dm = new Dm($config['connections']['dm']); @@ -34,22 +35,18 @@ $ws_worker->onMessage = function(TcpConnection $connection, $data) use($dm) { break; case 'allGroupNum': $passData = PassFlow::allGroupNum($dm); - if (empty($passData['code'])) throw new Exception($passData['msg']); $returnData['data'] = $passData; break; case 'realTimeData': $passData = PassFlow::realTimeData($dm); - if (empty($passData['code'])) throw new Exception($passData['msg']); $returnData['data'] = $passData; break; case 'toDayGroupsEnterNum': $passData = PassFlow::toDayGroupsEnterNum($dm); - if (empty($passData['code'])) throw new Exception($passData['msg']); $returnData['data'] = $passData; break; case 'allFlowTrends': $passData = PassFlow::allFlowTrends($dm); - if (empty($passData['code'])) throw new Exception($passData['msg']); $returnData['data'] = $passData; break; default: