Update Luckdraw.php

This commit is contained in:
Anyon 2020-10-12 14:14:23 +08:00
parent f029bba269
commit a3ef52b9a5

View File

@ -114,55 +114,54 @@ class Luckdraw extends Controller
*/ */
public function prize() public function prize()
{ {
if ($this->record) $this->error('已经参与抽奖,不能再抽奖了!'); if ($this->record) {
$this->error('已经参与抽奖,不能再抽奖了!');
}
/* 统计已经发出的奖品 */ /* 统计已经发出的奖品 */
$query = $this->app->db->name('ActivityLuckdrawRecord')->group('prize_code'); $map = ['code' => $this->code];
$useds = $query->where(['code' => $this->code])->column('count(1) count', 'prize_code'); [$check, $useds, $rateNumber, $rateRand] = [[], [], 0, rand(1, 1000000) / 10000];
$query = $this->app->db->name('ActivityLuckdrawRecord')->where($map)->group('prize_code,prize_level');
$query->field('prize_code,prize_level,count(1) prize_used')->select()->map(function ($item) use (&$useds) {
$useds["{$item['prize_code']}_{$item['prize_level']}"] = $item['prize_used'];
});
/* 统计活动的奖品数据 */ /* 统计活动的奖品数据 */
$query = $this->app->db->name('ActivityLuckdrawConfigRecord'); $query = $this->app->db->name('ActivityLuckdrawConfigRecord')->field('prize_num,prize_rate,prize_level,prize_code');
$query->field('prize_num,prize_rate,prize_level,prize_code');
$prizes = $query->where(['code' => $this->code])->select()->toArray();
/* 统计奖品信息 */
[$prize, $prizesNum, $tempRate, $tempNumber] = [[], [], 0, rand(1, 1000000) / 10000];
foreach ($prizes as $item) $prizesNum[$item['prize_code']] = ($prizesNum[$item['prize_code']] ?? 0) + $item['prize_num'];
/* 计算抽奖的中奖数据 */ /* 计算抽奖的中奖数据 */
foreach ($prizes as $key => $item) { foreach ($query->where($map)->select()->toArray() as $key => $item) {
if (isset($useds[$item['prize_code']]) && $useds[$item['prize_code']] >= $prizesNum[$item['prize_code']]) { $item['prize_used'] = $useds["{$item['prize_code']}_{$item['prize_level']}"] ?? 0;
unset($prizes[$key]); if (empty($item['prize_num']) || $item['prize_used'] >= $item['prize_num']) {
continue; continue;
} } elseif ($rateRand <= ($rateNumber += $item['prize_rate'])) {
if ($tempNumber <= ($tempRate += $item['prize_rate'])) { $check = $item;
$prize = $item;
break; break;
} }
} }
if (empty($prize)) { /* 组装活动中奖记录 */
$data = [ $data = ['code' => $this->code];
'mid' => $this->member['id'], $data['mid'] = $this->member['id'];
'username' => $this->member['username'], $data['phone'] = $this->member['phone'];
'code' => $this->vo['code'], $data['username'] = $this->member['username'];
'prize_level' => '未中奖', if (empty($check)) {
'prize_code' => '', $data['prize_code'] = '';
]; $data['prize_level'] = '未中奖';
if ($this->app->db->name('ActivityLuckdrawRecord')->insert($data) !== false) { if ($this->app->db->name('ActivityLuckdrawRecord')->insert($data) !== false) {
$this->success('抱歉没有抽到奖品哦!'); $this->success('抱歉没有抽到奖品哦!');
} }
} else { } else {
$_prize = $this->app->db->name('ActivityLuckdrawPrize')->where(['code' => $prize['prize_code']])->find(); $map = ['code' => $check['prize_code'], 'deleted' => 0, 'status' => 1];
$data = [ $prize = $this->app->db->name('ActivityLuckdrawPrize')->where($map)->find();
'mid' => $this->member['id'], if (empty($prize)) {
'phone' => $this->member['phone'], $this->error('奖品已下架或被禁用!');
'username' => $this->member['username'], } else {
'code' => $this->code, $data['prize_code'] = $prize['code'];
'prize_level' => $prize['prize_level'], $data['prize_name'] = $prize['name'];
'prize_code' => $_prize['code'], $data['prize_cover'] = $prize['cover'];
'prize_name' => $_prize['name'], $data['prize_remark'] = $prize['remark'];
'prize_cover' => $_prize['cover'], $data['prize_express'] = $prize['express'];
'prize_remark' => $_prize['remark'], $data['prize_level'] = $check['prize_level'];
'prize_express' => $_prize['express'], if ($this->app->db->name('ActivityLuckdrawRecord')->insert($data) !== false) {
]; $this->success('奖品抽取成功!', $data);
if ($this->app->db->name('ActivityLuckdrawRecord')->insert($data) !== false) { }
$this->success('奖品抽取成功!', $data);
} }
} }
$this->error('抽奖失败,请稍候再试!'); $this->error('抽奖失败,请稍候再试!');
@ -189,10 +188,10 @@ class Luckdraw extends Controller
public function express() public function express()
{ {
$data = $this->_vali([ $data = $this->_vali([
'express_province.require#province' => '收货省份不能为空!',
'express_city.require#city' => '收货城市不能为空!', 'express_city.require#city' => '收货城市不能为空!',
'express_area.require#area' => '收货区域不能为空!', 'express_area.require#area' => '收货区域不能为空!',
'express_address.require#address' => '详细地址不能为空!', 'express_address.require#address' => '详细地址不能为空!',
'express_province.require#province' => '收货省份不能为空!',
]); ]);
$result = $this->app->db->name('ActivityLuckdrawRecord')->where(['id' => $this->record['id']])->update($data); $result = $this->app->db->name('ActivityLuckdrawRecord')->where(['id' => $this->record['id']])->update($data);
$result !== false ? $this->success('提交收货地址成功!') : $this->error('提交收货地址失败,请稍候再试!'); $result !== false ? $this->success('提交收货地址成功!') : $this->error('提交收货地址失败,请稍候再试!');