1581 lines
60 KiB
PHP
1581 lines
60 KiB
PHP
<?php
|
||
|
||
// +----------------------------------------------------------------------
|
||
// | ThinkAdmin
|
||
// +-------------s---------------------------------------------------------
|
||
// | 版权所有 2014~2019 广州楚才信息科技有限公司 [ http://www.cuci.cc ]
|
||
// +----------------------------------------------------------------------
|
||
// | 官方网站: http://demo.thinkadmin.top
|
||
// +----------------------------------------------------------------------
|
||
// | 开源协议 ( https://mit-license.org )
|
||
// +----------------------------------------------------------------------
|
||
// | gitee 代码仓库3：https://gitee.com/zoujingli/ThinkAdmin
|
||
// | github 代码仓库3：https://github.com/zoujingli/ThinkAdmin
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace app\index\controller\api;
|
||
|
||
use library\Controller;
|
||
use think\Db;
|
||
use think\facade\Lang;
|
||
use think\facade\Request;
|
||
|
||
/**
|
||
* 应用入口
|
||
* Class Index
|
||
* @package app\index\controller
|
||
*/
|
||
class Index extends Controller
|
||
{
|
||
/**
|
||
* @var mixed
|
||
*/
|
||
private $uid;
|
||
|
||
public function __construct()
|
||
{
|
||
$token = Request::header('token');
|
||
$uid = Db::name('LcUser')->where(['token' => $token])->value('id');
|
||
if (!$uid) {
|
||
$this->error('', '', 1002);
|
||
} else {
|
||
Db::name('LcUser')->where(['token' => $token])->update([
|
||
'access_time' => time(),
|
||
]);
|
||
$this->uid = $uid;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @description：首页
|
||
* @date: 2020/5/13 0013
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function index()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) {
|
||
if (true) { // true:开启线路;false:关闭线路
|
||
return $this->fetch();
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* @description：未登录新闻页
|
||
* @date: 2020/5/14 0014
|
||
*/
|
||
public function news()
|
||
{
|
||
$this->fetch('new_index');
|
||
}
|
||
|
||
/**
|
||
* Describe: 新闻页面
|
||
* DateTime: 2020/5/14 1:16
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function my_news()
|
||
{
|
||
$this->login = 0;
|
||
if (!isLogin()) $this->login = 1;
|
||
$this->conf = Db::name('LcReward')->get(1);
|
||
$this->fetch('my_news');
|
||
}
|
||
|
||
/**
|
||
* Describe: 关于我们
|
||
* DateTime: 2020/5/14 0:31
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function aboutUs()
|
||
{
|
||
$id = input('id', 2);
|
||
$uid = $this->uid;
|
||
$where['uid'] = $uid;
|
||
$where['mid'] = $id;
|
||
$ret = Db::name('LcMsgIs')->where($where)->find();
|
||
if (!$ret) Db::name('LcMsgIs')->insertGetId(['uid' => $uid, 'mid' => $id]);
|
||
$msg = Db::name('LcMsg')->find($id);
|
||
if ($msg) {
|
||
$this->success(json_lang("操作成功"), $msg);
|
||
} else {
|
||
$this->error('暂无数据');
|
||
}
|
||
}
|
||
public function msg()
|
||
{
|
||
$uid = $this->uid;
|
||
$list = Db::name('LcMsg')->where(['uid' => $uid])->order('id desc')->select();
|
||
$this->success(json_lang("操作成功"), $list);
|
||
}
|
||
public function msgInfo()
|
||
{
|
||
$uid = $this->uid;
|
||
$list = Db::name('LcMsg')->where(['uid' => $uid,'id'=>Request::param('id')])->find();
|
||
if (!empty($list)){
|
||
Db::name('LcMsg')->where(['uid' => $uid,'id'=>Request::param('id')])->update(['status' => 1]);
|
||
}
|
||
$this->success(json_lang("操作成功"), $list);
|
||
}
|
||
/**
|
||
* Describe: 隐私政策
|
||
* DateTime: 2020/5/14 0:31
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function privacyPolicy()
|
||
{
|
||
$id = input('id', 1);
|
||
$uid = $this->uid;
|
||
|
||
$where['uid'] = $uid;
|
||
$where['mid'] = $id;
|
||
$ret = Db::name('LcMsgIs')->where($where)->find();
|
||
if (!$ret) Db::name('LcMsgIs')->insertGetId(['uid' => $uid, 'mid' => $id]);
|
||
$msg = Db::name('LcMsg')->find($id);
|
||
if ($msg) {
|
||
$this->success(json_lang("操作成功"), $msg);
|
||
} else {
|
||
$this->error('暂无数据');
|
||
}
|
||
}
|
||
|
||
/**
|
||
* Describe: 帮助中心
|
||
* DateTime: 2020/5/14 0:31
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function helpCenter()
|
||
{
|
||
$id = input('id', 3);
|
||
$uid = $this->uid;
|
||
|
||
$where['uid'] = $uid;
|
||
$where['mid'] = $id;
|
||
$ret = Db::name('LcMsgIs')->where($where)->find();
|
||
if (!$ret) Db::name('LcMsgIs')->insertGetId(['uid' => $uid, 'mid' => $id]);
|
||
$msg = Db::name('LcMsg')->find($id);
|
||
if ($msg) {
|
||
$this->success(json_lang("操作成功"), $msg);
|
||
} else {
|
||
$this->error('暂无数据');
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* Describe: 新闻奖励
|
||
* DateTime: 2020/5/14 1:27
|
||
* @throws \think\Exception
|
||
* @throws \think\Exception\DbException
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function news_reward()
|
||
{
|
||
$uid = $this->uid;
|
||
$reward = Db::name('LcReward')->get(1);
|
||
$start_time = strtotime(date("Y-m-d", time()));
|
||
$end_time = $start_time + 60 * 60 * 24;
|
||
$reward['newsmoney'] = round($this->randFloat($reward['newsmoney'], $reward['newsmoneytwo']), 2);
|
||
$todaynum = Db::name('LcSeeLog')->where('uid=\'' . $uid . '\' and dateline > \'' . $start_time . '\' and dateline < \'' . $end_time . '\'')->count();
|
||
if ($todaynum < $reward['getnum']) {
|
||
addFinance($uid, $reward['newsmoney'], 1, '浏览新闻，系统赠送' . $reward['newsmoney'] . '元');
|
||
setNumber('LcUser', 'money', $reward['newsmoney'], 1, "id = $uid");
|
||
setNumber('LcUser', 'income', $reward['newsmoney'], 1, "id = $uid");
|
||
$add = array('uid' => $uid, 'dateline' => time(), 'money' => $reward['newsmoney']);
|
||
Db::name('LcSeeLog')->insert($add);
|
||
$morenum = $reward['getnum'] - $todaynum - 1;
|
||
$this->success('奖励领取成功', ['more' => $morenum, 'times' => $reward['seetime'] * 60]);
|
||
} else {
|
||
$this->error('今日领取次数用尽');
|
||
}
|
||
}
|
||
|
||
private function randFloat($min = 0, $max = 1)
|
||
{
|
||
return $min + mt_rand() / mt_getrandmax() * ($max - $min);
|
||
}
|
||
|
||
/**
|
||
* @description：首页
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function home()
|
||
{
|
||
// $this->ater = Db::name('LcArticle')->where(['type'=>17,'show'=>1])->find();
|
||
// $this->banner = Db::name('LcSlide')->where(['show'=>1])->order("sort asc,id desc")->select();
|
||
$allproducts = Db::name('LcProduct')->where(['isdelete' => 0, 'iskq' => 1])->order("sort asc,id desc")->select();
|
||
//判断是否开市
|
||
$weekday = date("w");
|
||
$newallproducts = array();
|
||
if ($weekday == 0) $weekday = 7;
|
||
foreach ($allproducts as $x => $p) {
|
||
if (strpos($p['code'], "btc") !== false || strpos($p['code'], "usdt") !== false) {
|
||
$p['isclosetime'] = 0;
|
||
$ttimes = $p['opentime_' . $weekday];
|
||
if (empty($ttimes)) {
|
||
$p['isclosetime'] = 1;
|
||
continue;
|
||
};
|
||
//var_dump($this->info['opentime_'.$weekday],$weekday);die;
|
||
if (!empty($ttimes)) {
|
||
$optime = 0;
|
||
$ttimesarr = explode("|", $ttimes);
|
||
foreach ($ttimesarr as $t) {
|
||
$t = explode('~', $t);
|
||
if (time() > strtotime(date('Y-m-d ' . $t[0])) and time() < strtotime(date('Y-m-d ' . $t[1]))) $optime = $optime + 1;
|
||
}
|
||
if ($optime == 0) $p['isclosetime'] = 1;
|
||
}
|
||
$newallproducts[$x] = $p;
|
||
}
|
||
}
|
||
$data['products'] = $newallproducts;
|
||
// $data['ater'] = Db::name('LcArticle')->where(['type'=>17,'show'=>1])->find();
|
||
$data['banner'] = Db::name('LcSlide')->where(['show' => 1])->order("sort asc,id desc")->select();
|
||
$this->success(json_lang("操作成功"), $data);
|
||
}
|
||
|
||
/**
|
||
* @description：首页底部交易对信息
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function getProducts()
|
||
{
|
||
$allproducts = Db::name('LcProduct')->where(['isdelete' => 0, 'iskq' => 1])->order("sort asc,id asc")->select();
|
||
//判断是否开市
|
||
$weekday = date("w");
|
||
$newallproducts = array();
|
||
if ($weekday == 0) $weekday = 7;
|
||
foreach ($allproducts as $x => $p) {
|
||
if (strpos($p['code'], "btc") !== false || strpos($p['code'], "usdt") !== false) {
|
||
$p['isclosetime'] = 0;
|
||
$ttimes = $p['opentime_' . $weekday];
|
||
if (empty($ttimes)) {
|
||
$p['isclosetime'] = 1;
|
||
continue;
|
||
};
|
||
//var_dump($this->info['opentime_'.$weekday],$weekday);die;
|
||
if (!empty($ttimes)) {
|
||
$optime = 0;
|
||
$ttimesarr = explode("|", $ttimes);
|
||
foreach ($ttimesarr as $t) {
|
||
$t = explode('~', $t);
|
||
if (time() > strtotime(date('Y-m-d ' . $t[0])) and time() < strtotime(date('Y-m-d ' . $t[1]))) $optime = $optime + 1;
|
||
}
|
||
if ($optime == 0) $p['isclosetime'] = 1;
|
||
}
|
||
$newallproducts[$x] = $p;
|
||
}
|
||
}
|
||
$data = $newallproducts;
|
||
$this->success(json_lang('操作成功'), $data);
|
||
}
|
||
|
||
/**
|
||
* @description：首页轮播图信息
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function getBanner()
|
||
{
|
||
$data = Db::name('LcSlide')->where(['show' => 1])->order("sort asc,id desc")->select();
|
||
$this->success(json_lang('操作成功'), $data);
|
||
}
|
||
|
||
/**
|
||
* @description：项目列表
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function lists()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->ljsy = Db::name('LcMallInvestList')->where(['status' => 1, 'uid' => $uid])->sum("money1");
|
||
$now = date('Y-m-d H:i:s');
|
||
$this->yxkj = Db::name('LcMallInvest')->where("time2 >= '$now' and uid = $uid")->count();
|
||
$this->dqkj = Db::name('LcMallInvest')->where("time2 <= '$now' and uid = $uid")->count();
|
||
$this->invest = Db::name('LcMallInvest')->where('uid', $uid)->where("time2 >= '$now'")->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
public function normalfutures()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->ljsy = Db::name('LcInvestList')->where(['status' => 1, 'uid' => $uid])->sum("money1");
|
||
$now = date('Y-m-d H:i:s');
|
||
$this->yxkj = Db::name('LcInvest')->where("time2 >= '$now'")->count();
|
||
$this->dqkj = Db::name('LcInvest')->where("time2 <= '$now'")->count();
|
||
$this->invest = Db::name('LcInvest')->where('uid', $uid)->where("time2 >= '$now'")->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
public function expirefutures()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->ljsy = Db::name('LcInvestList')->where(['status' => 1, 'uid' => $uid])->sum("money1");
|
||
$now = date('Y-m-d H:i:s');
|
||
$this->yxkj = Db::name('LcInvest')->where("time2 >= '$now'")->count();
|
||
$this->dqkj = Db::name('LcInvest')->where("time2 <= '$now'")->count();
|
||
$this->invest = Db::name('LcInvest')->where('uid', $uid)->where("time2 <= '$now'")->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* @description：项目列表
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function ex_lists()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->ljsy = Db::name('LcMallInvestList')->where(['status' => 1, 'uid' => $uid])->sum("money1");
|
||
$now = date('Y-m-d H:i:s');
|
||
$this->yxkj = Db::name('LcMallInvest')->where("time2 >= '$now'")->count();
|
||
$this->dqkj = Db::name('LcMallInvest')->where("time2 <= '$now'")->count();
|
||
$this->invest = Db::name('LcMallInvest')->where('uid', $uid)->where("time2 <= '$now'")->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* @description：项目详情
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function item()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$id = Request::param('id');
|
||
if (!$id) msg('无效参数', 2, '/index');
|
||
$this->data = Db::name('LcItem')->where(['id' => $id])->find();
|
||
if (!$this->data) msg('无效项目', 2, '/index');
|
||
if (date('Y-m-d H:i:s') < $this->data['time']) msg('项目暂未开始！', 2, '/index');
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* @description：矿机详情
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function mall_detail()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$id = Request::param('id');
|
||
if (!$id) msg('无效参数', 2, '/index');
|
||
$this->data = Db::name('LcMall')->where(['id' => $id])->find();
|
||
if (!$this->data) msg('无效矿机', 2, '/index');
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* @description：投资
|
||
* @date: 2020/5/14 0014
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function investment()
|
||
{
|
||
$arr = array();
|
||
$uid = $this->uid;
|
||
|
||
$id = input('id', '');
|
||
if (!$id) $this->error(json_lang("产品不存在"));
|
||
$data = Db::name('LcItem')->where(['id' => $id])->find();
|
||
if (!$data) $this->error(json_lang("产品不存在"));
|
||
if (date('Y-m-d H:i:s') < $data['time']) $this->error('项目暂未开始！');
|
||
if (getProjectPercent($data['id']) == 100) $this->error('项目已满，请选择其他项目！');
|
||
$user = Db::name('LcUser')->find($uid);
|
||
if ($user['auth'] != 1) $this->error('请实名认证后再投资！');
|
||
//抵用券
|
||
$voucher_info = Db::name('LcVoucher')->where("uid = $uid AND status = 2")->order('money desc')->select();
|
||
if (empty($voucher_info)) {
|
||
$arr['vinfo'] = array();
|
||
} else {
|
||
$arr['vinfo'] = $voucher_info;
|
||
}
|
||
$count = Db::name('LcVoucher')->where('status = 1 and uid = ' . $uid . ' and xid = ' . $id)->count();
|
||
if ($data['usevoucher'] <= $count) {
|
||
$arr['voushow'] = 0;
|
||
$arr['usevounum'] = 0;
|
||
} else {
|
||
$arr['voushow'] = 1;
|
||
$arr['usevounum'] = $data['usevoucher'] - $count;
|
||
}
|
||
$arr['item'] = $data;
|
||
$arr['user'] = $user;
|
||
//检查等级
|
||
$level = Db::name('LcItemClass')->alias('c')->field("c.id,m.value")->join("lc_user_member m", "c.member_id = m.id")->where("c.id = {$data['class']}")->find();
|
||
if ($user['value'] < $level['value']) $this->error('您的等级不够！');
|
||
if (Request::isPost()) {
|
||
$param = Request::param();
|
||
// $voucher = $param['voucher'];
|
||
$voucher = 0;
|
||
$money = $param['money'];
|
||
if ($voucher) {
|
||
$arrvid = explode(',', $voucher);
|
||
$vouallmoney = 0;
|
||
foreach ($arrvid as $k => $v) {
|
||
$voucherinfos = Db::name('LcVoucher')->where("vid = '$v'")->find();
|
||
if (empty($voucherinfos)) {
|
||
msg('抵用券不存在', 2, '/index');
|
||
}
|
||
if ($voucherinfos['status'] != 2) {
|
||
msg('抵用券已使用', 2, '/index');
|
||
}
|
||
$vouallmoney = $vouallmoney + $voucherinfos['money'];
|
||
}
|
||
$count = $count + count($arrvid);
|
||
if ($count > $data['usevoucher']) {
|
||
msg('最多使用' . $data['usevoucher'] . '张投资抵用券', 2, '/index');
|
||
}
|
||
$money = $param['money'] - $vouallmoney;
|
||
if ($money < 0) $money = 0;
|
||
}
|
||
$my_count = Db::name('LcInvest')->where(['uid' => $uid, 'pid' => $id])->count();
|
||
if ($data['num'] <= $my_count) msg('该项目每人限投' . $data['num'] . '次！', 2, '/index');
|
||
if ($user['password2'] != md5($param['pwd'])) msg('请输入正确的交易密码！', 2, '/index');
|
||
if ($user['money'] < $money) msg('余额不足，请充值后再进行投资！', 2, '/index');
|
||
if ($data['max'] < $money) msg('投资金额大于项目最大投资额度！', 2, '/index');
|
||
if (getProjectSurplus($data['id']) < $money) msg('投资金额大于项目剩余投资额度！', 2, '/index');
|
||
if ($data['min'] > $money) msg('投资金额小于项目最小投资额度！', 2, '/index');
|
||
addFinance($uid, $money, 2, '投资项目：' . $data['title'] . '，使用余额' . $money . '元');
|
||
setNumber('LcUser', 'money', $money, 2, "id = $uid");
|
||
setInvestReward_old($uid, $money);
|
||
if ($voucher) {
|
||
foreach ($arrvid as $k => $v) {
|
||
Db::name('LcVoucher')->where("vid = '{$v}'")->update(array('status' => 1, 'xid' => $id, 'title' => $data['title']));
|
||
}
|
||
}
|
||
if (getInvestList($id, $money, $uid)) {
|
||
if (0 < $data['red']) {
|
||
$multiple = floor($money / $data['min']) * $data['red'] ?: 0;
|
||
|
||
if (0 < $multiple) {
|
||
addFinance($uid, $multiple, 1, '投资送红包');
|
||
setNumber('LcUser', 'money', $multiple, 1, "id = $uid");
|
||
}
|
||
}
|
||
msg('投资成功！', 2, '/index/user/index');
|
||
}
|
||
msg('投资失败！', 2, '/index/user/index');
|
||
}
|
||
$this->success($arr);
|
||
}
|
||
|
||
|
||
/**
|
||
* Describe:文章列表
|
||
* DateTime: 2020/5/14 21:13
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function about_list()
|
||
{
|
||
$id = Request::param('id');
|
||
$list = Db::name('lcArticle')->where(['type' => $id,'lang' => Lang::detect(), 'show' => 1])->select();
|
||
$this->success('', ['list' => $list]);
|
||
}
|
||
public function home_article()
|
||
{
|
||
$article = Db::name('lcArticle')->where(['type' => 17,'lang' => Lang::detect(), 'show' => 1])->order('id desc')->find();
|
||
$this->success('', $article);
|
||
}
|
||
/**
|
||
* Describe:文章详情
|
||
* DateTime: 2020/5/14 21:25
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function about_details()
|
||
{
|
||
$id = Request::param('id');
|
||
$article = Db::name('lcArticle')->where(['id' => $id, 'show' => 1])->find();
|
||
$this->success('', $article);
|
||
}
|
||
|
||
|
||
/**
|
||
* Describe:开始抽奖
|
||
* DateTime: 2020/5/14 23:06
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function prize_start()
|
||
{
|
||
$res = $this->get_gift();
|
||
$item = $res['id'] + 1;
|
||
if (empty($item)) $this->error("参数缺失，请刷新后重试！");
|
||
if (!isLogin()) $this->error("参数缺失，请刷新后重试！", '', 2);
|
||
$uid = $this->uid;
|
||
$this->user = Db::name('LcUser')->find($uid);
|
||
if ($this->user['prize'] <= 0) $this->error("抽奖次数不足，请投资后再进行抽奖！");
|
||
$prize = Db::name("LcPrize")->find(1);
|
||
$name = $prize['name' . $item] ?: '谢谢参与';
|
||
$type = $prize['type' . $item] ?: '无';
|
||
$reason = $prize['reason' . $item] ?: '继续投资，还有机会哟！';
|
||
$money = $prize['money' . $item] ?: 0;
|
||
if ($prize['endtime'] < date('Y-m-d H:i:s')) $this->error("活动已结束");
|
||
$add_prize = array('uid' => $uid, 'item' => $item, 'name' => $name, 'type' => $type, 'money' => $money, 'time' => date('Y-m-d H:i:s'));
|
||
Db::name("LcPrizeList")->insert($add_prize);
|
||
if ($prize['type' . $item] == 1) {
|
||
addFinance($uid, $money, 1, '抽奖获得' . $money . '元现金红包');
|
||
setNumber('LcUser', 'money', $money, 1, "id = $uid");
|
||
}
|
||
setNumber('LcUser', 'prize', 1, 2, "id = $uid");
|
||
$this->success($reason, ['item' => $item]);
|
||
}
|
||
|
||
/**
|
||
* Describe:抽奖记录
|
||
* DateTime: 2020/5/14 23:14
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function prize_list()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->prize = Db::name("LcPrizeList")->where("uid = $uid AND type <> 0")->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* Describe:积分商城
|
||
* DateTime: 2020/5/14 23:48
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function shop()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->shop = Db::name("LcShop")->where("num > 0")->order("sort asc,id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* Describe:商品详情
|
||
* DateTime: 2020/5/15 0:06
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function shop_details()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$id = Request::param('id');
|
||
if (!$id) msg('参数缺失！', 2, 'index/user/index');
|
||
$this->goods = Db::name("LcShop")->where(['id' => $id])->find();
|
||
$integral = Db::name('LcUser')->where(['id' => $uid])->value('integral');
|
||
$this->count = $integral ?: 0;
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* Describe:积分兑换
|
||
* DateTime: 2020/5/15 0:15
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function shop_exchange()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->error("请先登录", '', 2);
|
||
$gid = Request::param('gid');
|
||
if (!$gid) msg('参数缺失！', 2, 'index/user/index');
|
||
$this->goods = Db::name("LcShop")->where(['id' => $gid])->find();
|
||
if (!$this->goods) msg('暂无该商品！', 2, 'index/user/index');
|
||
$this->user = Db::name('LcUser')->find($uid);
|
||
if ($this->user['integral'] < $this->goods['integral']) $this->error("积分不足，请投资后再进行兑换！");
|
||
if ($this->goods['num'] <= 0) $this->error("商品数量不足，请兑换其他商品！");
|
||
$add_order = array('uid' => $uid, 'gid' => $gid, 'goods' => $this->goods['title'], 'img' => $this->goods['img'], 'integral' => $this->goods['integral'], 'type' => $this->goods['type'], 'money' => $this->goods['money'], 'time' => date('Y-m-d H:i:s'));
|
||
Db::name("LcShopOrder")->insert($add_order);
|
||
setNumber('LcUser', 'integral', $this->goods['integral'], 2, "id = $uid");
|
||
setNumber('LcShop', 'num', 1, 2, "id = $gid");
|
||
if ($this->goods['type'] == '1') {
|
||
addFinance($uid, $this->goods['money'], 1, '积分兑换获得' . $this->goods['money'] . '元现金红包');
|
||
setNumber('LcUser', 'money', $this->goods['money'], 1, "id = $uid");
|
||
$this->success($this->goods['money'] . "元现金下发到您的余额！");
|
||
}
|
||
$this->success("兑换成功，请联系客服邮寄！");
|
||
}
|
||
|
||
/**
|
||
* Describe:兑换记录
|
||
* DateTime: 2020/5/15 0:22
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function shop_order()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->shop_order = Db::name("LcShopOrder")->where(['uid' => $uid])->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* Describe:抽奖算法
|
||
* DateTime: 2020/5/14 22:46
|
||
* @return mixed
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
private function get_gift()
|
||
{
|
||
$data = Db::name("LcPrize")->find(1);
|
||
$surplus = 100 - $data['odds1'] - $data['odds2'] - $data['odds3'] - $data['odds4'] - $data['odds5'];
|
||
if (0 < $surplus) {
|
||
$data['odds6'] = $surplus;
|
||
} else {
|
||
$data['odds6'] = 0;
|
||
}
|
||
//奖品数组
|
||
$prize_arr = array(
|
||
'0' => array('id' => 1, 'prize' => $data['name1'], 'v' => $data['odds1']),
|
||
'1' => array('id' => 2, 'prize' => $data['name2'], 'v' => $data['odds2']),
|
||
'2' => array('id' => 3, 'prize' => $data['name3'], 'v' => $data['odds3']),
|
||
'3' => array('id' => 4, 'prize' => $data['name4'], 'v' => $data['odds4']),
|
||
'4' => array('id' => 5, 'prize' => $data['name5'], 'v' => $data['odds5']),
|
||
'5' => array('id' => 6, 'prize' => '谢谢参与', 'v' => $data['odds6']),
|
||
);
|
||
foreach ($prize_arr as $key => $val) {
|
||
$arr[$val['id']] = $val['v'];
|
||
}
|
||
$rid = $this->get_rand($arr);
|
||
$res['yes'] = $prize_arr[$rid - 1]['prize'];
|
||
$res['id'] = $rid - 1;
|
||
unset($prize_arr[$rid - 1]);
|
||
shuffle($prize_arr);
|
||
for ($i = 0; $i < count($prize_arr); $i++) {
|
||
$pr[] = $prize_arr[$i]['prize'];
|
||
}
|
||
$res['no'] = $pr;
|
||
if ($res['yes'] != '谢谢参与') {
|
||
$result['status'] = 1;
|
||
$result['name'] = $res['yes'];
|
||
$result['id'] = $res['id'];
|
||
} else {
|
||
$result['status'] = -1;
|
||
$result['msg'] = $res['yes'];
|
||
$result['id'] = $res['id'];
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* Describe:随机
|
||
* DateTime: 2020/5/14 22:49
|
||
* @param $proArr
|
||
* @return int|string
|
||
*/
|
||
private function get_rand($proArr)
|
||
{
|
||
$result = '';
|
||
$proSum = array_sum($proArr);
|
||
foreach ($proArr as $key => $proCur) {
|
||
$randNum = mt_rand(1, $proSum);
|
||
if ($randNum <= $proCur) {
|
||
$result = $key;
|
||
break;
|
||
} else {
|
||
$proSum -= $proCur;
|
||
}
|
||
}
|
||
unset ($proArr);
|
||
return $result;
|
||
}
|
||
|
||
public function MarketDatas()
|
||
{
|
||
$period = array(
|
||
1 => '1min',
|
||
60 => '1hour',
|
||
1440 => '1day',
|
||
);
|
||
$data = $this->request->param();
|
||
$assets = json_decode(vpost("http://api.zb.center/data/v1/kline?market=btc_qc&type={$period[$data['period']]}&size={$data['coin_nums']}", ""), true);
|
||
$btc = json_decode(vpost("http://api.zb.center/data/v1/ticker?market=btc_qc", ""), true);
|
||
$result = array(
|
||
'lastprice' => $btc['ticker']['sell'],
|
||
'chg' => $btc['ticker']['riseRate'],
|
||
);
|
||
foreach ($assets['data'] as $k => $v) {
|
||
$result['time'][$k] = $v[0] / 1000;
|
||
$result['date'][$k] = date('Y-m-d H:i:s', $v[0] / 1000);
|
||
$result['data'][$k] = array($v[1], $v[2], $v[3], $v[4]);
|
||
}
|
||
$this->success("OK", $result);
|
||
}
|
||
|
||
public function GetRealTimeDatas()
|
||
{
|
||
$ticker = json_decode(vpost("http://api.zb.center/data/v1/allTicker", ''), true);
|
||
$data = array(
|
||
0 => array('coin_ad' => round($ticker['btcqc']['riseRate'] / 100, 4), 'coin_name' => 'BTC', 'coin_price' => $ticker['btcqc']['sell']),
|
||
1 => array('coin_ad' => round($ticker['ethqc']['riseRate'] / 100, 4), 'coin_name' => 'ETH', 'coin_price' => $ticker['ethqc']['sell']),
|
||
2 => array('coin_ad' => round($ticker['ltcqc']['riseRate'] / 100, 4), 'coin_name' => 'LTC', 'coin_price' => $ticker['ltcqc']['sell']),
|
||
);
|
||
$this->success("OK", $data);
|
||
}
|
||
|
||
public function mall()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->redirect('/index/login');
|
||
$this->mall = Db::name('LcMall')->where("stock > 0")->order("sort asc,id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
public function futureslist()
|
||
{
|
||
$now = date('Y-m-d H:i:s');
|
||
$this->item = Db::name('LcItem')->where("time <= '$now' AND round(percent) < 100")->order("sort asc,id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
/**
|
||
* Describe:定时结算任务
|
||
* DateTime: 2020/5/14 22:22
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function item_crontab()
|
||
{
|
||
$now = time();
|
||
$invest_list = Db::name("LcInvestList")->where("UNIX_TIMESTAMP(time1) <= $now AND status = '0'")->select();
|
||
if (empty($invest_list)) exit('暂无返息计划');
|
||
foreach ($invest_list as $k => $v) {
|
||
$data = array('time2' => date('Y-m-d H:i:s'), 'pay2' => $v['pay1'], 'status' => 1);
|
||
if (Db::name("LcInvestList")->where(['id' => $v['id']])->update($data)) {
|
||
if ($v['pay1'] > 0) {
|
||
addFinance($v['uid'], $v['pay1'], 1, $v['title'] . ' 第' . $v['num'] . '期收益' . $v['pay1'] . '元');
|
||
setNumber('LcUser', 'money', $v['pay1'], 1, "id = {$v['uid']}");
|
||
setNumber('LcUser', 'income', $v['money1'], 1, "id = {$v['uid']}");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
public function mall_crontab()
|
||
{
|
||
$now = time();
|
||
$mall_invest_list = Db::name("LcMallInvestList")->where("UNIX_TIMESTAMP(time1) <= $now AND status = '0'")->select();
|
||
if (empty($mall_invest_list)) exit('暂无返息计划');
|
||
foreach ($mall_invest_list as $k => $v) {
|
||
$data = array('time2' => date('Y-m-d H:i:s'), 'pay2' => $v['pay1'], 'status' => 1);
|
||
if (Db::name("LcMallInvestList")->where(['id' => $v['id']])->update($data)) {
|
||
if ($v['pay1'] > 0) {
|
||
addFinance($v['uid'], $v['pay1'], 1, $v['title'] . ' 第' . $v['num'] . '期收益' . $v['pay1'] . 'BTC');
|
||
if ($v['tran_type'] > 1) {
|
||
$btc_price = json_decode(vpost("http://api.zb.center/data/v1/ticker?market=btc_qc", ''), true)['ticker']['sell'];
|
||
$money = round($btc_price * $data['buynum'], 2);
|
||
addFinance($v['uid'], $money, 1, "BTC兑换交易{$money}元");
|
||
setNumber('LcUser', 'money', $money, 1, "id = {$v['uid']}");
|
||
} else {
|
||
setNumber('LcUser', 'btc', $v['money1'], 1, "id = {$v['uid']}");
|
||
}
|
||
}
|
||
if ($v['money2'] > 0) {
|
||
addFinance($v['uid'], $v['money2'], 1, $v['title'] . '，保证金退还' . $v['pay1'] . '元');
|
||
setNumber('LcUser', 'money', $v['money2'], 1, "id = {$v['uid']}");
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* Describe:最新公告
|
||
* DateTime: 2020/5/14 21:02
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
public function notice()
|
||
{
|
||
$this->notice = Db::name('lcArticle')->where(['type' => 9, 'show' => 1])->order("id desc")->select();
|
||
$this->fetch();
|
||
}
|
||
|
||
public function goods()
|
||
{
|
||
$uid = $this->uid;
|
||
if (!$uid) $this->error(json_lang("用户不存在"));
|
||
$id = input('id', '');
|
||
if (!$id) $this->error(json_lang("产品不存在"));
|
||
$this->info = Db::name('LcProduct')->find($id);
|
||
if (!$this->info) $this->error(json_lang("产品不存在"));
|
||
if ($this->info['iskq'] == 0) $this->error(json_lang("产品未开启"));
|
||
$this->user = Db::name('LcUser')->find($uid);
|
||
if (!$this->user) $this->error(json_lang("用户不存在"));
|
||
$weekday = date("w");
|
||
if ($weekday == 0) $weekday = 7;
|
||
$ttimes = $this->info['opentime_' . $weekday];
|
||
|
||
if (empty($ttimes)) $this->error(json_lang("产品未开启"));
|
||
//var_dump($this->info['opentime_'.$weekday],$weekday);die;
|
||
if (!empty($ttimes)) {
|
||
$optime = 0;
|
||
$ttimesarr = explode("|", $ttimes);
|
||
foreach ($ttimesarr as $t) {
|
||
$t = explode('~', $t);
|
||
if (time() > strtotime(date('Y-m-d ' . $t[0])) and time() < strtotime(date('Y-m-d ' . $t[1]))) $optime = $optime + 1;
|
||
}
|
||
if ($optime == 0) $this->error(json_lang("产品未开启"));
|
||
}
|
||
//var_dump($this->info);die;
|
||
if ($this->info['protime_1'] > 0) {
|
||
$this->info['order_price'][] = ['time' => $this->info['protime_1'], 'prices' => explode('|', trim($this->info['order_amount_1'])), 'shouyi' => $this->info['proscale_1'], 'kuisun' => $this->info['lossrate_1']];
|
||
}
|
||
unset($this->info['protime_1']);
|
||
unset($this->info['order_amount_1']);
|
||
if ($this->info['protime_2'] > 0) {
|
||
$this->info['order_price'][] = ['time' => $this->info['protime_2'] , 'prices' => explode('|', trim($this->info['order_amount_2'])), 'shouyi' => $this->info['proscale_2'], 'kuisun' => $this->info['lossrate_2']];
|
||
}
|
||
unset($this->info['protime_2']);
|
||
unset($this->info['order_amount_2']);
|
||
if ($this->info['protime_3'] > 0) {
|
||
$this->info['order_price'][] = ['time' => $this->info['protime_3'], 'prices' => explode('|', trim($this->info['order_amount_3'])), 'shouyi' => $this->info['proscale_3'], 'kuisun' => $this->info['lossrate_3']];
|
||
}
|
||
unset($this->info['protime_3']);
|
||
unset($this->info['order_amount_3']);
|
||
if ($this->info['protime_4'] > 0) {
|
||
$this->info['order_price'][] = ['time' => $this->info['protime_4'], 'prices' => explode('|', trim($this->info['order_amount_4'])), 'shouyi' => $this->info['proscale_4'], 'kuisun' => $this->info['lossrate_4']];
|
||
}
|
||
unset($this->info['protime_4']);
|
||
unset($this->info['order_amount_4']);
|
||
$this->info['fee'] = getinfo('order_charge');
|
||
$this->success(json_lang("操作成功"), ['info' => $this->info, 'user' => $this->user]);
|
||
}
|
||
|
||
public function goodsinfo()
|
||
{
|
||
$pid = Request::param('pid');
|
||
$goods = Db::name('LcProduct')->find($pid);
|
||
$res = base64_encode(json_encode($goods));
|
||
return $res;
|
||
}
|
||
|
||
public function getchart()
|
||
{
|
||
$data['kaipan'] = '开盘';
|
||
$data['zuidi'] = '最低';
|
||
$data['zuigao'] = '最高';
|
||
$data['Kxian'] = 'k线';
|
||
$data['zoushi'] = '走势';
|
||
$data['DIFF'] = 'DIFF:';
|
||
$data['DEA'] = 'DEA:';
|
||
$data['MACD'] = 'MACD:';
|
||
$data['chicang'] = '持仓';
|
||
$data['maizhang'] = '买涨';
|
||
$data['maidie'] = '买跌';
|
||
$data['xiushi'] = json_lang("休市中");
|
||
$data['tousijine'] = '投资金额';
|
||
$data['chicangmingxi'] = '持仓明细';
|
||
$res = base64_encode(json_encode($data));
|
||
return $res;
|
||
}
|
||
|
||
public function getprodata()
|
||
{
|
||
$pid = input('pid', 1);
|
||
$data = Db::name('LcProduct')->field('Price,Open,Close,High,Low,UpdateTime')->find($pid);
|
||
|
||
if (!$data) {
|
||
exit;
|
||
}
|
||
|
||
$topdata = array(
|
||
'topdata' => $data['UpdateTime'],
|
||
'now' => $data['Price'],
|
||
'open' => $data['Open'],
|
||
'lowest' => $data['Low'],
|
||
'highest' => $data['High'],
|
||
'close' => $data['Close']
|
||
);
|
||
$this->success(json_lang("操作成功"), $topdata);
|
||
}
|
||
|
||
public function ajaxpro()
|
||
{
|
||
$id = Request::param('pid');
|
||
$data = Db::name('LcProduct')->field('Price,Open,Close,High,Low,UpdateTime')->find($id);
|
||
$data['UpdateTime'] = date('H:i:s', $data['UpdateTime']);
|
||
$this->success(json_lang("操作成功"), $data);
|
||
}
|
||
|
||
public function ajaxdata()
|
||
{
|
||
$product = Db::name('LcProduct')->field("id,title as Name,Price,isdelete")->where(array('isdelete' => 0))->select();
|
||
foreach ($product as $k => $val) {
|
||
$rd = rand(-3, 3);
|
||
//修改前端显示位数！！！
|
||
$product[$k]['Price'] = round($val['Price'] + $rd * 0.01 * $val['Price'], 3);
|
||
$lastprice = session('price' . $val['id']);
|
||
$product[$k]['is_rise'] = ($lastprice >= $val['Price']) ? 1 : 2;
|
||
$product[$k]['is_deal'] = ChickIsOpen($val['id']);
|
||
session('price' . $val['id'], $product[$k]['Price']);
|
||
}
|
||
$this->success(json_lang("操作成功"), $product);
|
||
}
|
||
|
||
|
||
public function getkdata()
|
||
{
|
||
$pid = Request::param('pid');
|
||
if (!$pid) $this->error(json_lang("产品不存在"));
|
||
$num = Request::param('num', 200);
|
||
if (!$num) $this->error(json_lang("产品不存在"));
|
||
$pro = Db::name('LcProduct')->where(['id' => $pid])->find();
|
||
$all_data = array();
|
||
if (!$pro) {
|
||
$this->error(json_lang("产品不存在"));
|
||
}
|
||
$interval = input('interval', '1');
|
||
$nowtime = time() . rand(100, 999);
|
||
if ($interval == 'd') {
|
||
$klength = 24 * 60 * 60 * $num;
|
||
} else {
|
||
$klength = $interval * 60 * $num;
|
||
}
|
||
|
||
//数据库里的产品K线参考值
|
||
|
||
if ($klength == 'd') $klength = 1 * 60 * 24 * $num;
|
||
|
||
$k_map['pid'] = $pid;
|
||
$pro['procode'] = $pro['code'];
|
||
if (strpos($pro['procode'], "btc") !== false or strpos($pro['procode'], "usdt") !== false) {
|
||
switch ($interval) {
|
||
case '1':
|
||
$datalen = "1min";
|
||
break;
|
||
case '5':
|
||
$datalen = "5min";
|
||
break;
|
||
case '15':
|
||
$datalen = "15min";
|
||
break;
|
||
case '30':
|
||
$datalen = "30min";
|
||
break;
|
||
case '60':
|
||
$datalen = "1hour";
|
||
break;
|
||
case 'd':
|
||
$datalen = "1day";
|
||
break;
|
||
default:
|
||
exit;
|
||
break;
|
||
}
|
||
$testacode = explode("_", $pro['procode']);
|
||
$newcodess = $testacode[0] . $testacode[1];
|
||
$geturl = "https://api.huobi.pro/market/history/kline?period=" . $datalen . "&size=" . $num . "&symbol=" . $newcodess;
|
||
$_data_arr = json_decode(file_get_contents($geturl), true);
|
||
if ($_data_arr['status'] == 'ok') {
|
||
foreach ($_data_arr['data'] as $k => $v) {
|
||
// 数据意义：时间(id) 开盘(open)，收盘(close)，最低(lowest)，最高(highest)
|
||
$res_arr[] = [$v['id'], $v['open'], $v['close'], $v['low'], $v['high']];
|
||
}
|
||
}
|
||
}
|
||
|
||
//以下是整体处理。
|
||
//var_dump($pro);die;
|
||
|
||
if ($pro['Price'] < $res_arr[$num - 1][1]) {
|
||
$_state = 'down';
|
||
} else {
|
||
$_state = 'up';
|
||
}
|
||
|
||
$all_data['topdata'] = array(
|
||
'topdata' => strtotime("now"),
|
||
'now' => $pro['Price'],
|
||
'open' => $pro['Open'],
|
||
'lowest' => $pro['Low'],
|
||
'highest' => $pro['High'],
|
||
'close' => $pro['Close'],
|
||
'state' => $_state
|
||
);
|
||
|
||
$all_data['items'] = $res_arr;
|
||
$this->success(json_lang("操作成功"), $all_data);
|
||
}
|
||
|
||
//curl获取数据
|
||
public function curlfun($url, $params = array(), $method = 'GET')
|
||
{
|
||
$header = array();
|
||
$opts = array(CURLOPT_TIMEOUT => 10, CURLOPT_RETURNTRANSFER => 1, CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYHOST => false, CURLOPT_HTTPHEADER => $header);
|
||
|
||
/* 根据请求类型设置特定参数 */
|
||
switch (strtoupper($method)) {
|
||
case 'GET' :
|
||
$opts[CURLOPT_URL] = $url . '?' . http_build_query($params);
|
||
$opts[CURLOPT_URL] = substr($opts[CURLOPT_URL], 0, -1);
|
||
|
||
break;
|
||
case 'POST' :
|
||
//判断是否传输文件
|
||
$params = http_build_query($params);
|
||
$opts[CURLOPT_URL] = $url;
|
||
$opts[CURLOPT_POST] = 1;
|
||
$opts[CURLOPT_POSTFIELDS] = $params;
|
||
break;
|
||
default :
|
||
}
|
||
|
||
/* 初始化并执行curl请求 */
|
||
$ch = curl_init();
|
||
curl_setopt_array($ch, $opts);
|
||
$data = curl_exec($ch);
|
||
$error = curl_error($ch);
|
||
curl_close($ch);
|
||
|
||
if ($error) {
|
||
$data = null;
|
||
}
|
||
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 数据风控
|
||
* @param [type] $price [description]
|
||
* @param [type] $pro [description]
|
||
* @return [type] [description]
|
||
* @author lukui 2017-06-27
|
||
*/
|
||
public function fengkong($price, $pro)
|
||
{
|
||
|
||
$point_low = $pro['point_low'];
|
||
$point_top = $pro['point_top'];
|
||
|
||
$FloatLength = getFloatLength($point_top);
|
||
$jishu_rand = pow(10, $FloatLength);
|
||
$point_low = $point_low * $jishu_rand;
|
||
$point_top = $point_top * $jishu_rand;
|
||
$rand = rand($point_low, $point_top) / $jishu_rand;
|
||
|
||
$_new_rand = rand(0, 10);
|
||
if ($_new_rand % 2 == 0) {
|
||
$price = $price + $rand;
|
||
} else {
|
||
$price = $price - $rand;
|
||
}
|
||
return $price;
|
||
}
|
||
|
||
/**
|
||
* 全局产品更新
|
||
* @return false|void [type] [description]
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public function product()
|
||
{
|
||
$list = Db::name('LcProduct')->where('isdelete', 0)->select();
|
||
|
||
if (!isset($list)) return false;
|
||
|
||
$nowtime = time();
|
||
$_rand = rand(1, 900) / 100000;
|
||
$thisdatas = array();
|
||
|
||
foreach ($list as $k => $v) {
|
||
$v['procode'] = $v['code'];
|
||
|
||
if (strpos($v['procode'], "index") !== false) {
|
||
$indexcode = explode("_", $v['procode']);
|
||
$v['procode'] = $indexcode[0];
|
||
}
|
||
//验证休市
|
||
$isopen = 0;
|
||
if ($v['isopen']) {
|
||
$isopen = ChickIsOpen($v['id']);
|
||
|
||
//var_dump($v);exit();
|
||
}
|
||
if (!$isopen) {
|
||
continue;
|
||
}
|
||
|
||
//腾讯证券
|
||
if (strpos($v['procode'], "btc") !== false or strpos($v['procode'], "usdt") !== false) {
|
||
$testcode = explode('_', $v['procode']);
|
||
$procode = $testcode[0] . $testcode[1];
|
||
$minute = date('i', $nowtime);
|
||
if ($minute >= 0 && $minute < 15) {
|
||
$minute = 0;
|
||
} elseif ($minute >= 15 && $minute < 30) {
|
||
$minute = 15;
|
||
} elseif ($minute >= 30 && $minute < 45) {
|
||
$minute = 30;
|
||
} elseif ($minute >= 45 && $minute < 60) {
|
||
$minute = 45;
|
||
}
|
||
$url = 'https://api.huobi.pro/market/history/kline?period=1day&size=2&symbol=' . $procode;
|
||
$data_arr = json_decode($this->curlfun($url), true); //dump($url);dump($data_arr);
|
||
if ($data_arr['status'] != 'ok') continue;
|
||
$thisdata['Price'] = $data_arr['data']['0']['close']; //价格 没有 只能给收盘价
|
||
$thisdata['Open'] = $data_arr['data']['0']['open']; //开盘价
|
||
$thisdata['Close'] = $data_arr['data']['1']['close']; //收盘价
|
||
$thisdata['High'] = $data_arr['data']['0']['high']; //最高价
|
||
$thisdata['Low'] = $data_arr['data']['0']['low'];
|
||
$thisdata['Diff'] = $data_arr['data']['0']['close'] - $data_arr['data']['1']['close'];
|
||
$thisdata['Diff'] = 0;
|
||
$thisdata['DiffRate'] = 0;
|
||
}
|
||
$thisdata['UpdateTime'] = $nowtime;
|
||
$ids = Db::name('LcProduct')->where('id', $v['id'])->update($thisdata);
|
||
}
|
||
exit;
|
||
|
||
}
|
||
/**
|
||
* 订单类型
|
||
* @param [type] $orders [description]
|
||
* @return [type] [description]
|
||
*/
|
||
public function order_type($orders, $pro, $risk, $data_info)
|
||
{
|
||
$_prcie = $pro['Price'];
|
||
$pid = $pro;
|
||
$thispro = array(); //买此产品的用户
|
||
//此产品购买人数
|
||
$price_num = 0;
|
||
//买涨金额，计算过盈亏比例以后的
|
||
$up_price = 0;
|
||
//买跌金额，计算过盈亏比例以后的
|
||
$down_price = 0;
|
||
//买入最低价
|
||
$min_buyprice = 0;
|
||
//买入最高价
|
||
$max_buyprice = 0;
|
||
//下单最大金额
|
||
$max_fee = 0;
|
||
//指定客户亏损
|
||
$to_win = explode('|', $risk['to_win']);
|
||
|
||
$is_to_win = array();
|
||
//指定客户亏损
|
||
$to_loss = explode('|', $risk['to_loss']);
|
||
|
||
$is_to_loss = array();
|
||
$i = 0;
|
||
|
||
foreach ($orders as $k => $v) {
|
||
if ($v['pid'] == $pid) {
|
||
//没炒过最小风控值直接退出price
|
||
if ($v['fee'] < $risk['min_price']) {
|
||
//return $pro['Price'];
|
||
echo 2222;
|
||
}
|
||
$i++;
|
||
|
||
//单控 赢利 全赢
|
||
if ($v['kong_type'] == '1' || $v['kong_type'] == '3') {
|
||
$dankong_ying = $v;
|
||
break;
|
||
}
|
||
//单控 亏损 全亏
|
||
if ($v['kong_type'] == '2' || $v['kong_type'] == '4') {
|
||
$dankong_kui = $v;
|
||
break;
|
||
}
|
||
echo $v['uid'];
|
||
//是否存在指定盈利
|
||
if (in_array($v['uid'], $to_win)) {
|
||
$is_to_win = $v;
|
||
break;
|
||
}
|
||
//是否存在指定亏损
|
||
if (in_array($v['uid'], $to_loss)) {
|
||
$is_to_loss = $v;
|
||
break;
|
||
}
|
||
|
||
//总下单人数
|
||
$price_num++;
|
||
//买涨买跌累加
|
||
if ($v['ostyle'] == 0) {
|
||
$up_price += $v['fee'] * $v['endloss'] / 100;
|
||
} else {
|
||
$down_price += $v['fee'] * $v['endloss'] / 100;
|
||
}
|
||
//统计最大买入价与最大下单价
|
||
if ($i == 1) {
|
||
$min_buyprice = $v['buyprice'];
|
||
$max_buyprice = $v['buyprice'];
|
||
$max_fee = $v['fee'];
|
||
} else {
|
||
if ($min_buyprice > $v['buyprice']) {
|
||
$min_buyprice = $v['buyprice'];
|
||
|
||
}
|
||
if ($max_buyprice < $v['buyprice']) {
|
||
$max_buyprice = $v['buyprice'];
|
||
}
|
||
if ($max_fee < $v['fee']) {
|
||
$max_fee = $v['fee'];
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
$proinfo = $data_info->where('id', $pid)->find();
|
||
|
||
//根据现在的价格算出风控点
|
||
$FloatLength = getFloatLength((float)$pro['Price']);
|
||
if ($FloatLength == 0) {
|
||
$FloatLength = getFloatLength($proinfo['point_top']);
|
||
}
|
||
|
||
//是否存在指定盈利
|
||
$is_do_price = 0; //是否已经操作了价格
|
||
$jishu_rand = pow(10, $FloatLength);
|
||
$beishu_rand = rand(1, 10);
|
||
$data_rands = $proinfo['rands'];
|
||
|
||
$data_randsLength = getFloatLength($data_rands);
|
||
|
||
if ($data_randsLength > 0) {
|
||
$_j_rand = pow(200, $data_randsLength) * $data_rands;
|
||
$_s_rand = rand(1, $_j_rand) / pow(10, $data_randsLength);
|
||
|
||
} else {
|
||
$_s_rand = 0;
|
||
|
||
}
|
||
$do_rand = $_s_rand;
|
||
|
||
//先考虑单控
|
||
if (!empty($dankong_ying) && $is_do_price == 0) { //单控 1赢利
|
||
if ($dankong_ying['ostyle'] == 0) {
|
||
$pro['Price'] = $v['buyprice'] + $do_rand;
|
||
} elseif ($dankong_ying['ostyle'] == 1) {
|
||
$pro['Price'] = $v['buyprice'] - $do_rand;
|
||
}
|
||
$is_do_price = 1;
|
||
}
|
||
if (!empty($dankong_kui) && $is_do_price == 0) { //单控 2亏损
|
||
if ($dankong_kui['ostyle'] == 0) {
|
||
$pro['Price'] = $v['buyprice'] - $do_rand;
|
||
} elseif ($dankong_kui['ostyle'] == 1) {
|
||
$pro['Price'] = $v['buyprice'] + $do_rand;
|
||
}
|
||
|
||
//echo 2;
|
||
$is_do_price = 1;
|
||
}
|
||
|
||
//指定客户赢利
|
||
if (!empty($is_to_win) && $is_do_price == 0) {
|
||
|
||
if ($is_to_win['ostyle'] == 0) {
|
||
$pro['Price'] = $v['buyprice'] + $do_rand;
|
||
} elseif ($is_to_win['ostyle'] == 1) {
|
||
$pro['Price'] = $v['buyprice'] - $do_rand;
|
||
}
|
||
$is_do_price = 1;
|
||
|
||
}
|
||
//是否存在指定亏损
|
||
if (!empty($is_to_loss) && $is_do_price == 0) {
|
||
|
||
|
||
if ($is_to_loss['ostyle'] == 0) {
|
||
$pro['Price'] = $v['buyprice'] - $do_rand;
|
||
} elseif ($is_to_loss['ostyle'] == 1) {
|
||
$pro['Price'] = $v['buyprice'] + $do_rand;
|
||
}
|
||
$is_do_price = 1;
|
||
}
|
||
//没有任何下单记录
|
||
if ($up_price == 0 && $down_price == 0 && $is_do_price == 0) {
|
||
$is_do_price = 2;
|
||
}
|
||
echo 111111;
|
||
exit;
|
||
//只有一个人下单，或者所有人下单买的方向相同
|
||
if ((($up_price == 0 && $down_price != 0) || ($up_price != 0 && $down_price == 0)) && $is_do_price == 0) {
|
||
|
||
//风控参数
|
||
$chance = $risk["chance"];
|
||
$chance_1 = explode('|', $chance);
|
||
$chance_1 = array_filter($chance_1);
|
||
//循环风控参数
|
||
if (count($chance_1) >= 1) {
|
||
foreach ($chance_1 as $key => $value) {
|
||
//切割风控参数
|
||
$arr_1 = explode(":", $value);
|
||
$arr_2 = explode("-", $arr_1[0]);
|
||
//比较最大买入价格
|
||
if ($max_fee >= $arr_2[0] && $max_fee < $arr_2[1]) {
|
||
//得出风控百分比
|
||
if (!isset($arr_1[1])) {
|
||
$chance_num = 30;
|
||
} else {
|
||
$chance_num = $arr_1[1];
|
||
}
|
||
|
||
$_rand = rand(1, 100);
|
||
continue;
|
||
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
|
||
//买涨
|
||
if (isset($_rand) && $up_price != 0) {
|
||
|
||
if ($_rand > $chance_num) { //客损
|
||
$pro['Price'] = $min_buyprice - $do_rand;
|
||
|
||
// if( abs($pro['Price'] - $_prcie) > $proinfo['point_top']){
|
||
// $pro['Price'] = $_prcie - ($proinfo['point_top'] + rand(100,999)/1000);
|
||
// }
|
||
|
||
$is_do_price = 1;
|
||
//echo 5;
|
||
} else { //客赢
|
||
$pro['Price'] = $max_buyprice + $do_rand;
|
||
// if( abs($pro['Price'] - $_prcie) > $proinfo['point_top']){
|
||
// $pro['Price'] = $_prcie + ($proinfo['point_top'] + rand(100,999)/1000);
|
||
// }
|
||
$is_do_price = 1;
|
||
//echo 6;
|
||
}
|
||
|
||
}
|
||
|
||
if (isset($_rand) && $down_price != 0) {
|
||
|
||
if ($_rand > $chance_num) { //客损
|
||
$pro['Price'] = $max_buyprice + $do_rand;
|
||
// if( abs($pro['Price'] - $_prcie) > $proinfo['point_top']){
|
||
// $pro['Price'] = $_prcie + ($proinfo['point_top'] + rand(100,999)/1000);
|
||
// }
|
||
$is_do_price = 1;
|
||
//echo 7;
|
||
} else { //客赢
|
||
$pro['Price'] = $min_buyprice - $do_rand;
|
||
// if( abs($pro['Price'] - $_prcie) > $proinfo['point_top']){
|
||
// $pro['Price'] = $_prcie - ($proinfo['point_top'] + rand(100,999)/1000);
|
||
// }
|
||
$is_do_price = 1;
|
||
//echo 8;
|
||
}
|
||
|
||
}
|
||
|
||
|
||
}
|
||
|
||
//多个人下单，并且所有人下单买的方向不相同
|
||
if ($up_price != 0 && $down_price != 0 && $is_do_price == 0) {
|
||
//买涨大于买跌的
|
||
if ($up_price > $down_price) {
|
||
$pro['Price'] = $min_buyprice - $do_rand;
|
||
$is_do_price = 1;
|
||
}
|
||
//买涨小于买跌的
|
||
if ($up_price < $down_price) {
|
||
$pro['Price'] = $max_buyprice + $do_rand;
|
||
$is_do_price = 1;
|
||
}
|
||
if ($up_price == $down_price) {
|
||
$is_do_price = 2;
|
||
}
|
||
}
|
||
|
||
if ($is_do_price == 2 || $is_do_price == 0) {
|
||
$pro['Price'] = $this->fengkong($pro['Price'], $proinfo);
|
||
}
|
||
$data_info->where('id', $pid)->update($pro);
|
||
return $pro['Price'];
|
||
}
|
||
|
||
public function yebeveryday()
|
||
{
|
||
if ($this->request->get('token') == "ABCD484088") {
|
||
$nowtime = time();
|
||
$keepnum = 0;
|
||
$closenum = 0;
|
||
$nowprift = 0;
|
||
$getdoing = Db::table('lc_yuebao_lists')->where('status=1')->select();
|
||
|
||
foreach ($getdoing as $n => $v) {
|
||
//第一步，计算未到期
|
||
if ($v['end_time'] > $nowtime) {
|
||
$nowprift = ($v['money'] * $v['lily'] / 100 / 365) * round(($nowtime - $v['start_time']) / 86400, 1);
|
||
$nowprift = number_format($nowprift, 5);
|
||
Db::table('lc_yuebao_lists')->where('id=' . $v['id'])->update(['nowprofit' => $nowprift]);
|
||
$keepnum = $keepnum + 1;
|
||
}
|
||
//第二步，已到期待结算
|
||
if ($nowtime > $v['end_time']) {
|
||
//更新参保状态。
|
||
$nowprift = ($v['money'] * $v['lily'] / 100 / 365) * round(($nowtime - $v['start_time']) / 86400, 1);
|
||
$nowprift = number_format($nowprift, 5);
|
||
Db::table('lc_yuebao_lists')->where('id=' . $v['id'])->update(['status' => 2, 'end_time' => $nowtime, 'nowprofit' => $nowprift]);
|
||
|
||
//获取用户余额；
|
||
$getuserinfo = Db::table('lc_user')->where('id=' . $v['uid'])->find();
|
||
//记录日志！
|
||
unset($v['id']);
|
||
$v['status'] = 2;
|
||
$v['end_time'] = time();
|
||
$v['nowprofit'] = $nowprift;
|
||
$v['balance'] = $getuserinfo['money'];
|
||
$v['closetime'] = time();
|
||
$v['remarks'] = "自动结算";
|
||
Db::table('lc_yuebao_log')->insert($v);
|
||
//更新用户余额
|
||
/*$newbalance=$getuserinfo['money']+$nowprift+$v['money'];
|
||
Db::table('lc_user')->where('id='.$v['uid'])->update(['money'=>$newbalance]);
|
||
//更新UC
|
||
$getuc=Db::table('lc_yuebao_uc')->where('uid='.$v['uid'])->find();
|
||
Db::table('lc_yuebao_uc')->where('uid='.$v['uid'])->update(['balance'=>$getuc['balance']-$v['money']]);*/
|
||
$getuc = Db::table('lc_yuebao_uc')->where('uid=' . $v['uid'])->find();
|
||
Db::table('lc_yuebao_uc')->where('uid=' . $v['uid'])->update([
|
||
'balance' => $getuc['balance'] - $v['money'],
|
||
'trans_balance' => round($getuc['trans_balance'] + $nowprift + $v['money'], 1),
|
||
'totalprofit' => round($getuc['totalprofit'] + $nowprift, 1)
|
||
]);
|
||
//记录UCLOG
|
||
$saveuclog = array(
|
||
'uid' => $v['uid'],
|
||
'balance' => $getuc['balance'],
|
||
'money' => "-" . $v['money'],
|
||
'addtime' => time(),
|
||
'remarks' => $v['yebtitle'] . "到期结算"
|
||
);
|
||
Db::table('lc_yuebao_uclog')->insert($saveuclog);
|
||
$closenum = $closenum + 1;
|
||
}
|
||
}
|
||
//结算完，更新UC
|
||
|
||
echo("更新" . $keepnum . "个记录，结算" . $closenum . "个记录.");
|
||
return json_encode("ABCD484088");
|
||
die;
|
||
}
|
||
}
|
||
|
||
public function upuceveryday1()
|
||
{
|
||
if ($this->request->get('token') == "ABCD484088") {
|
||
$getalluc = Db::table('lc_yuebao_uc')->where("id > 0")->select();
|
||
foreach ($getalluc as $v) {
|
||
$res = Db::table('lc_yuebao_uc')->where("uid = " . $v['uid'])->update(['prebalance' => $v['balance'], 'preprofit' => $v['totalprofit']]);
|
||
var_dump($v, $res);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
public function upuceveryday2()
|
||
{
|
||
if ($this->request->get('token') == "ABCD484188") {
|
||
$getalluc = Db::table('lc_yuebao_uc')->where("id > 0")->select();
|
||
foreach ($getalluc as $v) {
|
||
$totalprofit = Db::table('lc_yuebao_lists')->where("uid = " . $v['uid'])->sum('nowprofit');
|
||
$res = Db::table('lc_yuebao_uc')->where("uid = " . $v['uid'])->update(['totalprofit' => round($totalprofit, 5)]);
|
||
var_dump($v, $res);
|
||
}
|
||
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 余利宝列表
|
||
*/
|
||
public function yeblist()
|
||
{
|
||
$uid = $this->uid;
|
||
$param = Request::param();
|
||
$page = $param['page'];
|
||
$limit = $param['limit'];
|
||
if ($uid) {
|
||
$map['uid'] = $uid;
|
||
}
|
||
$list = Db::table('lc_yuebao_lists')->where($map)->limit(($page - 1) * $limit, $limit)->order('id desc')->select();
|
||
$this->success(json_lang('操作成功'), [
|
||
'list' => $list,
|
||
'count' => Db::table('lc_yuebao_lists')->where($map)->count(),
|
||
'page' => $page,
|
||
'limit' => $limit
|
||
]);
|
||
}
|
||
}
|