|
@@ -14,12 +14,14 @@ class Index extends Api
|
|
{
|
|
{
|
|
protected $noNeedLogin = ['*'];
|
|
protected $noNeedLogin = ['*'];
|
|
protected $noNeedRight = ['*'];
|
|
protected $noNeedRight = ['*'];
|
|
|
|
+
|
|
public function _initialize()
|
|
public function _initialize()
|
|
{
|
|
{
|
|
- $this->recordModel= new \app\admin\model\greenroom\Record;
|
|
|
|
- $this->adminModel= new \app\admin\model\Admin;
|
|
|
|
- $this->userlinkModel= new \app\admin\model\greenroom\Userlink;
|
|
|
|
|
|
+ $this->recordModel = new \app\admin\model\greenroom\Record;
|
|
|
|
+ $this->adminModel = new \app\admin\model\Admin;
|
|
|
|
+ $this->userlinkModel = new \app\admin\model\greenroom\Userlink;
|
|
}
|
|
}
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 首页
|
|
* 首页
|
|
*
|
|
*
|
|
@@ -28,42 +30,45 @@ class Index extends Api
|
|
{
|
|
{
|
|
$this->success('请求成功');
|
|
$this->success('请求成功');
|
|
}
|
|
}
|
|
|
|
+
|
|
//跟新收益
|
|
//跟新收益
|
|
- public function upincome(){
|
|
|
|
|
|
+ public function upincome()
|
|
|
|
+ {
|
|
|
|
|
|
$maxId = $this->recordModel->max('id');
|
|
$maxId = $this->recordModel->max('id');
|
|
|
|
|
|
- $recorddata= $this->recordModel
|
|
|
|
|
|
+ $recorddata = $this->recordModel
|
|
->field('sum(income) as income ,uid as id')
|
|
->field('sum(income) as income ,uid as id')
|
|
->where("id", "<=", $maxId)
|
|
->where("id", "<=", $maxId)
|
|
- ->where(['status'=>0])
|
|
|
|
|
|
+ ->where(['status' => 0])
|
|
->group('uid')
|
|
->group('uid')
|
|
->select();
|
|
->select();
|
|
- $temp=$userids=[];
|
|
|
|
- $returndata='1';
|
|
|
|
|
|
+ $temp = $userids = [];
|
|
|
|
+ $returndata = '1';
|
|
Db::startTrans();
|
|
Db::startTrans();
|
|
- if($recorddata){
|
|
|
|
- $returndata='12';
|
|
|
|
- foreach ($recorddata as $key=>$val){
|
|
|
|
- $temp[$val['id']]=$val['income'];
|
|
|
|
- $userids[]=$val['id'];
|
|
|
|
|
|
+ if ($recorddata) {
|
|
|
|
+ $returndata = '12';
|
|
|
|
+ foreach ($recorddata as $key => $val) {
|
|
|
|
+ $temp[$val['id']] = $val['income'];
|
|
|
|
+ $userids[] = $val['id'];
|
|
}
|
|
}
|
|
- $admindata=db('admin')->where(['id'=>['in',$userids]])->select();
|
|
|
|
- $upincome=[];
|
|
|
|
- foreach ($admindata as $k=>$vl){
|
|
|
|
- if(isset($temp[$vl['id']])){
|
|
|
|
- $upincome[]=['id'=>$vl['id'],'money'=>$vl['money']+$temp[$vl['id']]];
|
|
|
|
|
|
+ $admindata = db('admin')->where(['id' => ['in', $userids]])->select();
|
|
|
|
+ $upincome = [];
|
|
|
|
+ foreach ($admindata as $k => $vl) {
|
|
|
|
+ if (isset($temp[$vl['id']])) {
|
|
|
|
+ $upincome[] = ['id' => $vl['id'], 'money' => $vl['money'] + $temp[$vl['id']]];
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- if($upincome){
|
|
|
|
- $returndata='123';
|
|
|
|
|
|
+ if ($upincome) {
|
|
|
|
+ $returndata = '123';
|
|
$this->adminModel->saveAll($upincome);
|
|
$this->adminModel->saveAll($upincome);
|
|
- $this->recordModel->where("id", "<=", $maxId)->where(['status'=>0])->update(['status'=>1]);
|
|
|
|
|
|
+ $this->recordModel->where("id", "<=", $maxId)->where(['status' => 0])->update(['status' => 1]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
Db::commit();
|
|
Db::commit();
|
|
return $returndata;
|
|
return $returndata;
|
|
}
|
|
}
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* 跑链接收益
|
|
* 跑链接收益
|
|
*
|
|
*
|
|
@@ -72,16 +77,15 @@ class Index extends Api
|
|
{
|
|
{
|
|
$nowtime = time();
|
|
$nowtime = time();
|
|
$spacetime = 10 * 60;
|
|
$spacetime = 10 * 60;
|
|
- $returndata='';
|
|
|
|
|
|
+ $returndata = '';
|
|
$userdata = db('admin')->field("id")
|
|
$userdata = db('admin')->field("id")
|
|
- ->where(['livetime'=>['gt', $nowtime - $spacetime]])
|
|
|
|
- ->where(['incomeendtime'=>['gt', $nowtime]])
|
|
|
|
- ->select();
|
|
|
|
|
|
+ ->where(['livetime' => ['gt', $nowtime - $spacetime]])
|
|
|
|
+ ->where(['incomeendtime' => ['gt', $nowtime]])
|
|
|
|
+ ->select();
|
|
Db::startTrans();
|
|
Db::startTrans();
|
|
if (!$userdata) {
|
|
if (!$userdata) {
|
|
- $returndata= 'no data';
|
|
|
|
|
|
+ $returndata = 'no data';
|
|
} else {
|
|
} else {
|
|
- Db::startTrans();
|
|
|
|
$userids = array_column($userdata, 'id');
|
|
$userids = array_column($userdata, 'id');
|
|
$userlink = db('userlink')
|
|
$userlink = db('userlink')
|
|
->join(['fa_link'], 'fa_userlink.link_id = fa_link.id')
|
|
->join(['fa_link'], 'fa_userlink.link_id = fa_link.id')
|
|
@@ -92,27 +96,27 @@ class Index extends Api
|
|
fa_userlink.income as income,
|
|
fa_userlink.income as income,
|
|
fa_link.minincome as minincome,
|
|
fa_link.minincome as minincome,
|
|
fa_link.maxincome as maxincome
|
|
fa_link.maxincome as maxincome
|
|
- ")->where(['uid'=>['in', $userids]])->select();
|
|
|
|
|
|
+ ")->where(['uid' => ['in', $userids]])->select();
|
|
if (!$userlink) {
|
|
if (!$userlink) {
|
|
- $returndata='no data1';
|
|
|
|
|
|
+ $returndata = 'no data1';
|
|
|
|
|
|
} else {
|
|
} else {
|
|
- $savedata =$userlinkdata= [];
|
|
|
|
|
|
+ $savedata = $userlinkdata = [];
|
|
foreach ($userlink as $key => $val) {
|
|
foreach ($userlink as $key => $val) {
|
|
- $income=mt_rand($val['minincome'] * 10000, $val['maxincome'] * 10000) / 10000;
|
|
|
|
|
|
+ $income = mt_rand($val['minincome'] * 10000, $val['maxincome'] * 10000) / 10000;
|
|
$savedata[] = ['income' => $income,
|
|
$savedata[] = ['income' => $income,
|
|
'time' => $nowtime,
|
|
'time' => $nowtime,
|
|
'link' => $val['link'],
|
|
'link' => $val['link'],
|
|
'uid' => $val['uid'],
|
|
'uid' => $val['uid'],
|
|
'status' => 0
|
|
'status' => 0
|
|
];
|
|
];
|
|
- $userlinkdata[]=['id'=>$val['userlinkid'],'income'=>$val['income']+$income];
|
|
|
|
|
|
+ $userlinkdata[] = ['id' => $val['userlinkid'], 'income' => $val['income'] + $income];
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
$this->userlinkModel->saveAll($userlinkdata);
|
|
$this->userlinkModel->saveAll($userlinkdata);
|
|
$this->recordModel->saveAll($savedata);
|
|
$this->recordModel->saveAll($savedata);
|
|
- $returndata= 'insert ' . count($savedata) . ' record';
|
|
|
|
|
|
+ $returndata = 'insert ' . count($savedata) . ' record';
|
|
}
|
|
}
|
|
Db::commit();
|
|
Db::commit();
|
|
}
|
|
}
|
|
@@ -122,8 +126,8 @@ class Index extends Api
|
|
|
|
|
|
public function oldrecord()
|
|
public function oldrecord()
|
|
{
|
|
{
|
|
- $beginYesterday=mktime(0,0,0,date('m'),date('d') - 1,date('Y'));
|
|
|
|
- $endYesterday = mktime(0,0,0,date('m'),date('d'),date('Y'));
|
|
|
|
|
|
+ $beginYesterday = mktime(0, 0, 0, date('m'), date('d') - 1, date('Y'));
|
|
|
|
+ $endYesterday = mktime(0, 0, 0, date('m'), date('d'), date('Y'));
|
|
|
|
|
|
// 统计前面的收益
|
|
// 统计前面的收益
|
|
$total = Record::where('time', ">=", $beginYesterday)
|
|
$total = Record::where('time', ">=", $beginYesterday)
|
|
@@ -134,13 +138,12 @@ class Index extends Api
|
|
|
|
|
|
$date = date("Y-m-d", $beginYesterday);
|
|
$date = date("Y-m-d", $beginYesterday);
|
|
Db::startTrans();
|
|
Db::startTrans();
|
|
- foreach ($total as $item)
|
|
|
|
- {
|
|
|
|
|
|
+ foreach ($total as $item) {
|
|
DayRecord::create([
|
|
DayRecord::create([
|
|
- "uid" => $item->id,
|
|
|
|
- "addtime" => $date,
|
|
|
|
- "link_num" => $item->num,
|
|
|
|
- "income" => bcmul('1', $item->income, 4)
|
|
|
|
|
|
+ "uid" => $item->id,
|
|
|
|
+ "addtime" => $date,
|
|
|
|
+ "link_num" => $item->num,
|
|
|
|
+ "income" => bcmul('1', $item->income, 4)
|
|
]);
|
|
]);
|
|
}
|
|
}
|
|
|
|
|