|
|
@@ -9,12 +9,16 @@ use \App\Http\Models;
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
use \Exception;
|
|
|
|
|
|
+use Monolog\Logger;
|
|
|
+use Monolog\Handler\StreamHandler;
|
|
|
+
|
|
|
/**
|
|
|
* 第三方管理类
|
|
|
*/
|
|
|
class PartyController extends Controller
|
|
|
{
|
|
|
|
|
|
+ public $logger;
|
|
|
/**
|
|
|
* 构造函数
|
|
|
*
|
|
|
@@ -23,7 +27,8 @@ class PartyController extends Controller
|
|
|
* @return array JsonString
|
|
|
*/
|
|
|
public function __construct() {
|
|
|
-
|
|
|
+ $this->logger = new Logger('party');
|
|
|
+ $this->logger->pushHandler(new StreamHandler(storage_path('logs/api.log'), Logger::WARNING));
|
|
|
}
|
|
|
|
|
|
|
|
|
@@ -36,6 +41,10 @@ class PartyController extends Controller
|
|
|
*/
|
|
|
public function login(Request $req)
|
|
|
{
|
|
|
+ $reqArr = $req->input();
|
|
|
+
|
|
|
+ $this->logger->addWarning('login get:'.json_encode($reqArr));
|
|
|
+
|
|
|
$code = -200;
|
|
|
$msg = '操作失败';
|
|
|
try {
|
|
|
@@ -53,12 +62,14 @@ class PartyController extends Controller
|
|
|
|
|
|
$money = $req->input('money');
|
|
|
if($partyInfo['balance'] < $money){
|
|
|
+ $this->logger->addError('login out: status:-100;您的余额不足');
|
|
|
return toJson(-100, '您的余额不足', []);
|
|
|
}
|
|
|
|
|
|
$appModel = new Models\App;
|
|
|
$appInfo = $appModel->where('id', $appid)->first();
|
|
|
if($appInfo['balance'] < $money){
|
|
|
+ $this->logger->addError('login out: status:-101;我在应用的余额不足');
|
|
|
return toJson(-101, '系统繁忙,请稍后重试', []); //我的余额不足
|
|
|
}
|
|
|
|
|
|
@@ -92,7 +103,8 @@ class PartyController extends Controller
|
|
|
if(empty($appUserInfo)){
|
|
|
$result = $adapter->syncUser($appid, $appUsername, $req->input('password')); //检测用户并创建用户
|
|
|
if($result['code'] != 1){
|
|
|
- return toJson(-2, $result['msg'], []);
|
|
|
+ $this->logger->addError('login out: status:-102;创建应用用户失败; '.json_encode($result));
|
|
|
+ return toJson(-102, $result['msg'], []);
|
|
|
}
|
|
|
|
|
|
$appUserModel->insert([
|
|
|
@@ -115,31 +127,23 @@ class PartyController extends Controller
|
|
|
$billno = date('YmdHis', time()).rand(10000, 99999);
|
|
|
$appResult = $adapter->login($appid, $appUsername, $req->input('password'), $money, $billno);
|
|
|
if($appResult['code'] != 1){
|
|
|
- return toJson(-3, $appResult['msg'], []);
|
|
|
+ $this->logger->addError('login out: status:-103;调用应用登陆接口失败'.json_encode($appResult));
|
|
|
+ return toJson(-103, $appResult['msg'], []);
|
|
|
}
|
|
|
|
|
|
DB::beginTransaction();
|
|
|
//更新额度
|
|
|
- $result = $partyModel->where('id', $partyInfo['id'])->update(array(
|
|
|
+ $result1 = $partyModel->where('id', $partyInfo['id'])->update(array(
|
|
|
'balance' => $partyInfo['balance'] - $money
|
|
|
));
|
|
|
- if($result === false){
|
|
|
- $appUserModel->rollBack();
|
|
|
- return toJson(-4, '系统繁忙', []);
|
|
|
- }
|
|
|
-
|
|
|
|
|
|
//更新额度
|
|
|
- $result = $appModel->where('id', $appInfo['id'])->update(array(
|
|
|
+ $result2 = $appModel->where('id', $appInfo['id'])->update(array(
|
|
|
'balance' => $appInfo['balance'] - $money
|
|
|
));
|
|
|
- if($result === false){
|
|
|
- DB::rollBack();
|
|
|
- return toJson(-4, '系统繁忙', []);
|
|
|
- }
|
|
|
|
|
|
//记录日志
|
|
|
- $result = $balanceLogModel = new Models\BalanceLog();
|
|
|
+ $result3 = $balanceLogModel = new Models\BalanceLog();
|
|
|
$balanceLogModel->insert([
|
|
|
'type' => 2,
|
|
|
'money' => $money,
|
|
|
@@ -150,9 +154,10 @@ class PartyController extends Controller
|
|
|
'billno' => $billno,
|
|
|
//'ctime' =>now()
|
|
|
]);
|
|
|
- if($result === false){
|
|
|
- $appUserModel->rollBack();
|
|
|
- return toJson(-4, '系统繁忙', []);
|
|
|
+ if($result1 === false || $result2 === false || $result3 === false){
|
|
|
+ DB::rollBack();
|
|
|
+ $this->logger->addError('login out: status:-104;更新数据库失败');
|
|
|
+ return toJson(-104, '系统繁忙', []);
|
|
|
}
|
|
|
|
|
|
DB::commit();
|
|
|
@@ -160,7 +165,8 @@ class PartyController extends Controller
|
|
|
$msg = '成功';
|
|
|
$code = 1;
|
|
|
|
|
|
- return toJson($code, $msg, []);
|
|
|
+ $this->logger->addWarning('login out: 成功,$appResult:'.json_encode($appResult));
|
|
|
+ return toJson($code, $msg, $appResult);
|
|
|
} catch (Exception $e) {
|
|
|
return toJson($code, $msg, []);
|
|
|
}
|