Index.php 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. /**
  5. * 首页接口
  6. */
  7. class Index extends Api
  8. {
  9. protected $noNeedLogin = ['*'];
  10. protected $noNeedRight = ['*'];
  11. public function _initialize()
  12. {
  13. $this->recordModel= new \app\admin\model\greenroom\Record;
  14. $this->adminModel= new \app\admin\model\Admin;
  15. $this->userlinkModel= new \app\admin\model\greenroom\Userlink;
  16. }
  17. /**
  18. * 首页
  19. *
  20. */
  21. public function index()
  22. {
  23. $this->success('请求成功');
  24. }
  25. //跟新收益
  26. public function upincome(){
  27. $recorddata= $this->recordModel->field('sum(income) as income ,uid as id')->where(['status'=>0])->group('uid')->select();
  28. $temp=$userids=[];
  29. $returndata='1';
  30. if($recorddata){
  31. $returndata='12';
  32. foreach ($recorddata as $key=>$val){
  33. $temp[$val['id']]=$val['income'];
  34. $userids[]=$val['id'];
  35. }
  36. $admindata=db('admin')->where(['id'=>['in',$userids]])->select();
  37. $upincome=[];
  38. foreach ($admindata as $k=>$vl){
  39. if(isset($temp[$vl['id']])){
  40. $upincome[]=['id'=>$vl['id'],'money'=>$vl['money']+$temp[$vl['id']]];
  41. }
  42. }
  43. if($upincome){
  44. $returndata='123';
  45. $this->adminModel->saveAll($upincome);
  46. }
  47. }
  48. return $returndata;
  49. }
  50. /**
  51. * 跑链接收益
  52. *
  53. */
  54. public function runrecord()
  55. {
  56. $nowtime = time();
  57. $spacetime = 10 * 60;
  58. $returndata='';
  59. $userdata = db('admin')->field("id")
  60. ->where(['livetime'=>['gt', $nowtime - $spacetime]])
  61. ->where(['incomeendtime'=>['gt', $nowtime]])
  62. ->select();
  63. if (!$userdata) {
  64. $returndata= 'no data';
  65. } else {
  66. $userids = array_column($userdata, 'id');
  67. $userlink = db('userlink')
  68. ->join(['fa_link'], 'fa_userlink.link_id = fa_link.id')
  69. ->field("fa_link.link as link,
  70. fa_link.id as link_id,
  71. fa_userlink.uid as uid,
  72. fa_link.minincome as minincome,
  73. fa_link.maxincome as maxincome
  74. ")->where(['uid'=>['in', $userids]])->select();
  75. if (!$userlink) {
  76. $returndata='no data1';
  77. } else {
  78. $savedata = [];
  79. foreach ($userlink as $key => $val) {
  80. $savedata[] = ['income' => mt_rand($val['minincome'] * 10000, $val['maxincome'] * 10000) / 10000,
  81. 'time' => $nowtime,
  82. 'link' => $val['link'],
  83. 'uid' => $val['uid'],
  84. 'status' => 0
  85. ];
  86. }
  87. $this->recordModel->saveAll($savedata);
  88. $returndata= 'insert ' . count($savedata) . ' record';
  89. }
  90. }
  91. return $returndata;
  92. }
  93. public function oldrecord()
  94. {
  95. $beginYesterday=mktime(0,0,0,date('m'),date('d')-1,date('Y'));
  96. $userlink = db('userlink')->select();
  97. $uplink=[];
  98. foreach ($userlink as $key=>$val){
  99. if($val['dayincome']>0){
  100. $uplinktemp=[
  101. 'id'=>$val['id'],
  102. 'dayincome'=>0,
  103. 'oldincome'=>$val['dayincome'],
  104. ];
  105. if($val['endtime']<$beginYesterday){
  106. $uplinktemp['oldincome']=0;
  107. }
  108. $uplink[]= $uplinktemp;
  109. }
  110. }
  111. $this->userlinkModel->saveAll($uplink);
  112. }
  113. }