Skip to content

杨树贤 / ic_server_welfare

Go to a project
Commit d310a101 by 杨树贤
Options

修复合并的冲突

parents 75315a6a 7f1a9930
Inline Side-by-side
Showing with 297 additions and 11 deletions
app/Http/Controllers/ExchangeController.php
......@@ -6,8 +6,5 @@ use Illuminate\Support\Facades\DB;
class ExchangeController extends Controller
{
//用于抢兑换名额
public function create(Request $request){
$Field = ['user_id',''];
}
}
\ No newline at end of file
app/Http/Controllers/ExchangesTask.php 0 → 100644
<?php
namespace App\Http\Controllers;
use App\Models\Recharge;
use App\Models\UserExchange;
use Common\Model\RedisModel;
use Hhxsv5\LaravelS\Swoole\Task\Task;
use DB;
class ExchangesTask extends Task
{
private $data;
private $Exchange;
public function __construct($data,$Exchange)
{
$this->data = $data;
$this->Exchange = $Exchange;
}
// 处理任务的逻辑，运行在Task进程中，不能投递任务
public function handle()
{
//金额大于等于20走审核流程
if($this->Exchange['amount'] >= 20)
return true;
//微信红包暂时不能对接，走人工
if($this->data['type'] == 2 )
return true;
try{
DB::beginTransaction();
//获取用户手机号
$Redis = new RedisModel(false);
$UserInfo = json_decode($Redis->hget('ic_user',$this->data['user_id']),true);
if(!$UserInfo || empty($UserInfo['mobile']))
throw new \Exception('用户手机号获取失败#'.$this->data['id']);
//先修改提现记录状态
$UserExchangModel = new UserExchange();
$Exchang = [
'status' => 1,
'audit_id' => 1,
'audit_reason' => '系统自动审核'
];
$result = $UserExchangModel->SaveRecord($this->data['id'] , $Exchang);
if(!$result)
throw new \Exception('提现记录状态修改失败#'.$this->data['id']);
$RechargeModel = new Recharge();
//验证手机号能不能充值
$RechargeModel->TelCheck($UserInfo['mobile'] , $this->Exchange['amount']);
//开始充值
$time = date('Ymd');
$OrderId = $this->data['user_id'].$time;//用户ID拼接时间
$result = $RechargeModel->Recharge($UserInfo['mobile'] , $this->Exchange['amount'] , $OrderId);
if(!$result)
throw new \Exception('充值失败#'.$this->data['id']);
DB::commit();
}catch (\Exception $e){
DB::rollBack();
return SendErrMsg($e);
}
}
public function finish()
{
}
}
app/Http/Controllers/UserExchangesController.php
......@@ -5,7 +5,11 @@ namespace App\Http\Controllers;
use App\Http\Filters\UserExchangeFilter;
use App\Models\ExchangeSetting;
use App\Models\UserExchange;
use App\Models\UserIntegral;
use Common\Model\RedisModel;
use Hhxsv5\LaravelS\Swoole\Task\Task;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
......@@ -99,4 +103,80 @@ class UserExchangesController extends Controller
return $this->Export(17, '审核批量拒绝兑换失败');
}
}
//用于抢兑换名额（接口自己需要先验证是否能）
public function create(Request $request){
$Field = ['user_id','exchange_id'];
$collert = $request->only($Field);
$Redis = new RedisModel();
//先判断客户今天是否抢到名额
$time = date('Ymd');
$Pre = 'ic_exchanges_quota_'.$time;
$Record = $Redis->hget($Pre , $collert['user_id']);
if($Record)
return $this->Export(ErrorCode(100,1),'今天已经兑换过来，请明天再来吧');
//消费名额
$Cahce = $Redis->rpop('ic_exchange_settings_'.$collert['exchange_id']);
if(!$Cahce)
return $this->Export(ErrorCode(101,1),'已经被兑换完了');
$Cahce = json_decode($Cahce,true);
//记录当前消费的名额，自动过期
$Redis->hset($Pre , $collert['user_id'] , 1);
$Redis->expire($Pre , 60*60*24);
try{
DB::beginTransaction();
//扣减用户金额
$UserIntrgralModel = new UserIntegral();
$result = $UserIntrgralModel->Deduction($collert['user_id'] , $Cahce['amount']);
if(!$result){
ErrorLog(ErrorCode(1,9),'扣减用户红包失败,用户ID:'.$collert['user_id']);
throw new \Exception('扣减用户红包失败,用户ID:'.$collert['user_id']);
}
//添加红包记录
$UserExchangeModel = new UserExchange();
$data = [
'user_id' => $collert['user_id'],
'type' => $Cahce['type'],
'exchange_id' => $Cahce['id'],
];
$result = $UserExchangeModel->addRecord($data);
if(!$result){
$Errinfo = '红包提现记录添加失败'.$collert['user_id'];
ErrorLog(ErrorCode(1,9),$Errinfo);
throw new \Exception($Errinfo);
}
//提前提交事务
DB::commit();
//扣减缓存里面的红包金额
$UserInfo = json_decode($Redis->hget('ic_user' , $collert['user_id']),true);
$UserInfo['integral'] = $UserInfo['integral'] - $Cahce['amount'];
$Redis->hset('ic_user' , json_encode($UserInfo));
//推送一个异步任务（用来提现或者充值），延时10秒，防止主从同步不及时
$Task = new ExchangesTask($data,$Cahce);
$Task->delay(10);
$result = Task::deliver($Task);
if(!$result)
ErrorLog(ErrorCode(1,9),'提现任务推送失败，提现ID:'.$data['id']);
return $this->Export(0,'ok',['data'=>$data['id']]);
}catch (\Exception $e){
DB::rollBack();
SendErrMsg($e);
return $this->Export(ErrorCode(100,5),'提现失败');
}
}
}
\ No newline at end of file
app/Models/ExchangeSetting.php
<?php
namespace App\Models;
use App\Http\Filters\QueryFilter;
use Common\Model\RedisModel;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use DB;
class ExchangeSetting extends Model
{
......@@ -24,6 +24,7 @@ class ExchangeSetting extends Model
return $filters->apply($query);
}
public function getExchangeSettingList($page, $pageSize, $filter)
{
$settings = ExchangeSetting::filter($filter)
......@@ -216,5 +217,11 @@ class ExchangeSetting extends Model
return $result;
}
//抢占兑换名额
public function QuotaSnatching($data)
{
}
}
\ No newline at end of file
app/Models/Recharge.php 0 → 100644
<?php
namespace App\Models;
use Illuminate\Database\Eloquent\Model;
class Recharge extends Model
{
protected $connection = false;
private $key = 'b6ca0e6b55c2d10ebb0e6803a263bcd4';
private $OpenID = 'JH3f55c02fc5aaf8e1bca362b9de5051ba';
//话费充值
public function Recharge($mobile , $amount , $OrderId){
$Url = 'http://op.juhe.cn/ofpay/mobile/onlineorder';
$data = [
'phoneno' => $mobile,
'cardnum' => $amount,
'orderid' => $OrderId,
'key' => $this->key,
'sign' => $this->OpenID.$this->key.$mobile.$amount.$OrderId
];
$result = curl($Url , $data , true);
$result = json_decode($result ,true);
if(!$result || !isset($result['error_code']) || !$result['error_code'] == 10014){
$message = '话费充值订单异常，需要联系聚合客服确认'."\r";
$message .= '订单号：'.$OrderId."\r";
$message .= json_encode($result);
SendDingTalk($message);
return false;
}
if($result['error_code'] !== 0 ){
$message = '充值失败'."\r";
$message .= '订单号：'.$OrderId."\r";
$message .= json_encode($result);
SendDingTalk($message);
return false;
}
return true;
}
//检测订单状态
public function OrderStatus($OrderId){
$Url = 'http://op.juhe.cn/ofpay/mobile/ordersta';
$data = [
'orderid' => $OrderId,
'key' => $this->key
];
$result = curl($Url , $data , true);
$result = json_decode($result ,true);
if(!$result || !isset($result['error_code']) || !$result['error_code'] == 10014){
SendDingTalk('话费充值订单状态检查异常');
return false;
}
}
//查询手机是否能充值
public function TelCheck($mobile , $amount){
$Url = 'http://op.juhe.cn/ofpay/mobile/telcheck';
$data = [
'phoneno' => $mobile,
'cardnum' => $amount,
'key' => $this->key
];
$result = curl($Url , $data , true);
$result = json_decode($result ,true);
if(!$result || !isset($result['error_code'])){
$message = '话费充值检测接口异常'."\r";
$message .= '手机号：'.$mobile."\r";
$message .= '金额：'.$amount."\r";
$message .= json_encode($result);
SendDingTalk($message);
return false;
}
if($result['error_code'] !== 0 ){
$message = '用户手机及金额不可以充值'."\r";
$message .= '手机号：'.$mobile."\r";
$message .= '金额：'.$amount."\r";
$message .= json_encode($result);
SendDingTalk($message);
return false;
}
return true;
}
}
\ No newline at end of file
app/Models/UserExchange.php
......@@ -22,6 +22,24 @@ class UserExchange extends Model
return $filters->apply($query);
}
//添加提现记录
public function addRecord(&$data){
$data['add_time'] = time();
$data['update_time'] = $data['add_time'];
$ID = $this->insertGetId($data);
if(!$ID)
return false;
$data['id'] = $ID;
return true;
}
public function SaveRecord($id,$data)
{
$data['update_time'] = time();
return $this->where('id', '=', $id)->update($data);
}
public function exchange_setting()
{
return $this->hasOne(ExchangeSetting::class, 'id', 'exchange_id');
......
app/Models/UserIntegral.php
......@@ -22,6 +22,13 @@ class UserIntegral extends Model
return $filters->apply($query);
}
//扣减红包，需要制定扣减数量
public function Deduction($user_id, $integral)
{
return $this->where('user_id', '=', $user_id)->decrement('integral', $integral, ['update_time' => time()]);
}
public function addUserIntegral($data = [])
{
$result = DB::table('user_integrals')->insert($data);
......
app/helpers.php
......@@ -2,4 +2,12 @@
function ErrorCode($code = 0, $level = 1){
$systemcode = config('system.code');
return errCode($code , $level , $systemcode);
}
function SendErrMsg($e){
return SendAlarm($e,config('system.RobotUrl'),[config('system.at')],config('system.SystemName'));
}
function SendDingTalk($message){
return SendRobot(config('website.RobotUrl'),$message,[config('website.at')],config('website.SystemName'));
}
\ No newline at end of file
config/system.php
......@@ -2,4 +2,7 @@
return [
'code' => env('SYSTEM_CODE'),
'RobotUrl' => 'https://oapi.dingtalk.com/robot/send?access_token=245f39f3b18bfcb8d739068327a32327f5c0c868529b5d5ba357f919567ef1fd',
'SystemName' => env('SYSTEM_NAME','这家伙没设置系统'),//系统名称
"at" => env('AT'),
];
\ No newline at end of file
routes/web.php
......@@ -58,11 +58,11 @@ $router->post('/user_exchanges/list', 'UserExchangesController@index');
$router->post('/user_exchanges/update', 'UserExchangesController@update');
$router->post('/user_exchanges/batchAuditReject', 'UserExchangesController@batchAuditReject');
//抢兑换名额
$router->post('/rob/exchange/quota', 'ExchangeController@create');
//用户签到
$router->post('/check_in/list','CheckInController@index');
$router->post('/check_in/add','CheckInController@store');
$router->post('/check_in/list', 'CheckInController@index');
$router->post('/check_in/add', 'CheckInController@store');
//抢兑换名额
$router->post('/rob/exchange/quota', 'UserExchangesController@create');
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment