You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
311 lines
13 KiB
311 lines
13 KiB
7 months ago
|
<?php
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | CRMEB [ CRMEB赋能开发者，助力企业发展 ]
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | Licensed CRMEB并不是自由软件，未经许可不能去掉CRMEB相关版权
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
// | Author: CRMEB Team <admin@crmeb.com>
|
||
|
|
// +----------------------------------------------------------------------
|
||
|
|
declare (strict_types=1);
|
||
|
|
|
||
|
|
namespace app\services\activity\lottery;
|
||
|
|
|
||
|
|
use app\services\BaseServices;
|
||
|
|
use app\dao\activity\lottery\LuckLotteryRecordDao;
|
||
|
|
use app\services\activity\coupon\StoreCouponIssueServices;
|
||
|
|
use app\services\order\StoreOrderCreateServices;
|
||
|
|
use app\services\statistic\CapitalFlowServices;
|
||
|
|
use app\services\user\UserBillServices;
|
||
|
|
use app\services\user\UserMoneyServices;
|
||
|
|
use app\services\user\UserServices;
|
||
|
|
use app\services\wechat\WechatUserServices;
|
||
|
|
use crmeb\exceptions\ApiException;
|
||
|
|
use crmeb\services\app\WechatService;
|
||
|
|
use crmeb\services\pay\Pay;
|
||
|
|
use think\facade\Log;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 抽奖记录
|
||
|
|
* Class LuckLotteryRecordServices
|
||
|
|
* @package app\services\activity\lottery
|
||
|
|
*/
|
||
|
|
class LuckLotteryRecordServices extends BaseServices
|
||
|
|
{
|
||
|
|
|
||
|
|
/**
|
||
|
|
* LuckLotteryRecordServices constructor.
|
||
|
|
* @param LuckLotteryRecordDao $dao
|
||
|
|
*/
|
||
|
|
public function __construct(LuckLotteryRecordDao $dao)
|
||
|
|
{
|
||
|
|
$this->dao = $dao;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取抽奖记录列表
|
||
|
|
* @param array $where
|
||
|
|
* @return array
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function getList(array $where)
|
||
|
|
{
|
||
|
|
[$page, $limit] = $this->getPageValue();
|
||
|
|
/** @var LuckLotteryServices $luckServices */
|
||
|
|
$luckServices = app()->make(LuckLotteryServices::class);
|
||
|
|
$where['lottery_id'] = $where['factor'] == '' ? '' : $luckServices->value(['factor' => $where['factor']], 'id');
|
||
|
|
unset($where['factor']);
|
||
|
|
$list = $this->dao->getList($where, '*', ['lottery', 'prize', 'user'], $page, $limit);
|
||
|
|
foreach ($list as &$item) {
|
||
|
|
$item['add_time'] = $item['add_time'] ? date('Y-m-d H:i:s', $item['add_time']) : '';
|
||
|
|
}
|
||
|
|
$count = $this->dao->count($where);
|
||
|
|
return compact('list', 'count');
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取中奖记录
|
||
|
|
* @param array $where
|
||
|
|
* @param int $limit
|
||
|
|
* @return array
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function getWinList(array $where, int $limit = 20)
|
||
|
|
{
|
||
|
|
$where = $where + ['not_type' => 1];
|
||
|
|
$list = $this->dao->getList($where, 'id,uid,prize_id,lottery_id,receive_time,add_time', ['user', 'prize'], 0, $limit);
|
||
|
|
foreach ($list as &$item) {
|
||
|
|
$item['receive_time'] = $item['receive_time'] ? date('Y-m-d H:i:s', $item['receive_time']) : '';
|
||
|
|
$item['add_time'] = $item['add_time'] ? date('Y-m-d H:i', $item['add_time']) : '';
|
||
|
|
}
|
||
|
|
return $list;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 参与抽奖数据统计
|
||
|
|
* @param int $lottery_id
|
||
|
|
* @return int[]
|
||
|
|
*/
|
||
|
|
public function getLotteryRecordData(int $lottery_id)
|
||
|
|
{
|
||
|
|
$data = ['all' => 0, 'people' => 0, 'win' => 0];
|
||
|
|
if ($lottery_id) {
|
||
|
|
$where = [['lottery_id', '=', $lottery_id]];
|
||
|
|
$data['all'] = $this->dao->getCount($where);
|
||
|
|
$data['people'] = $this->dao->getCount($where, 'uid');
|
||
|
|
$data['win'] = $this->dao->getCount($where + [['type', '>', 1]], 'uid');
|
||
|
|
}
|
||
|
|
return $data;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 写入中奖纪录
|
||
|
|
* @param int $uid
|
||
|
|
* @param array $prize
|
||
|
|
* @param array $userInfo
|
||
|
|
* @return mixed
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function insertPrizeRecord(int $uid, array $prize, array $userInfo = [])
|
||
|
|
{
|
||
|
|
if (!$userInfo) {
|
||
|
|
/** @var UserServices $userServices */
|
||
|
|
$userServices = app()->make(UserServices::class);
|
||
|
|
$userInfo = $userServices->getUserInfo($uid);
|
||
|
|
}
|
||
|
|
if (!$userInfo) {
|
||
|
|
throw new ApiException(410032);
|
||
|
|
}
|
||
|
|
if (!$prize) {
|
||
|
|
throw new ApiException(410048);
|
||
|
|
}
|
||
|
|
$data = [];
|
||
|
|
$data['uid'] = $uid;
|
||
|
|
$data['lottery_id'] = $prize['lottery_id'];
|
||
|
|
$data['prize_id'] = $prize['id'];
|
||
|
|
$data['type'] = $prize['type'];
|
||
|
|
$data['add_time'] = time();
|
||
|
|
if (!$res = $this->dao->save($data)) {
|
||
|
|
throw new ApiException(400439);
|
||
|
|
}
|
||
|
|
return $res;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 领取奖品
|
||
|
|
* @param int $uid
|
||
|
|
* @param int $lottery_record_id
|
||
|
|
* @param string $receive_info
|
||
|
|
* @return bool
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function receivePrize(int $uid, int $lottery_record_id, array $receive_info = [])
|
||
|
|
{
|
||
|
|
/** @var UserServices $userServices */
|
||
|
|
$userServices = app()->make(UserServices::class);
|
||
|
|
$userInfo = $userServices->getUserInfo($uid);
|
||
|
|
if (!$userInfo) {
|
||
|
|
throw new ApiException(410032);
|
||
|
|
}
|
||
|
|
$lotteryRecord = $this->dao->get($lottery_record_id, ['*'], ['prize']);
|
||
|
|
if (!$lotteryRecord || !isset($lotteryRecord['prize'])) {
|
||
|
|
throw new ApiException(410050);
|
||
|
|
}
|
||
|
|
if ($lotteryRecord['is_receive'] == 1) {
|
||
|
|
throw new ApiException(410051);
|
||
|
|
}
|
||
|
|
$data = ['is_receive' => 1, 'receive_time' => time(), 'receive_info' => $receive_info];
|
||
|
|
$prize = $lotteryRecord['prize'];
|
||
|
|
$this->transaction(function () use ($uid, $userInfo, $lottery_record_id, $data, $prize, $userServices, $receive_info) {
|
||
|
|
//奖品类型1：未中奖2：积分3:余额4：红包5:优惠券6：站内商品7：等级经验8：用户等级 9：svip天数
|
||
|
|
switch ($prize['type']) {
|
||
|
|
case 1:
|
||
|
|
break;
|
||
|
|
case 2:
|
||
|
|
/** @var UserBillServices $userBillServices */
|
||
|
|
$userBillServices = app()->make(UserBillServices::class);
|
||
|
|
$userBillServices->income('lottery_give_integral', $uid, $prize['num'], $userInfo['integral'] + $prize['num'], $prize['id']);
|
||
|
|
$userServices->update($uid, ['integral' => bcadd((string)$userInfo['integral'], (string)$prize['num'], 0)], 'uid');
|
||
|
|
break;
|
||
|
|
case 3:
|
||
|
|
/** @var UserMoneyServices $userMoneyServices */
|
||
|
|
$userMoneyServices = app()->make(UserMoneyServices::class);
|
||
|
|
$now_money = bcadd((string)$userInfo['now_money'], (string)$prize['num'], 2);
|
||
|
|
$userMoneyServices->income('lottery_give_money', $uid, $prize['num'], $now_money, $prize['id']);
|
||
|
|
$userServices->update($uid, ['now_money' => $now_money], 'uid');
|
||
|
|
break;
|
||
|
|
case 4:
|
||
|
|
/** @var WechatUserServices $wechatServices */
|
||
|
|
$wechatServices = app()->make(WechatUserServices::class);
|
||
|
|
$openid = $wechatServices->uidToOpenid((int)$uid, 'wechat');
|
||
|
|
$type = 'JSAPI';
|
||
|
|
if (!$openid) {
|
||
|
|
$openid = $wechatServices->uidToOpenid((int)$uid, 'routine');
|
||
|
|
$type = 'mini';
|
||
|
|
}
|
||
|
|
if (!$openid) {
|
||
|
|
$openid = $wechatServices->uidToOpenid((int)$uid, 'app');
|
||
|
|
$type = 'APP';
|
||
|
|
}
|
||
|
|
if ($openid) {
|
||
|
|
/** @var StoreOrderCreateServices $services */
|
||
|
|
$services = app()->make(StoreOrderCreateServices::class);
|
||
|
|
$wechat_order_id = $services->getNewOrderId();
|
||
|
|
/** @var CapitalFlowServices $capitalFlowServices */
|
||
|
|
$capitalFlowServices = app()->make(CapitalFlowServices::class);
|
||
|
|
$capitalFlowServices->setFlow([
|
||
|
|
'order_id' => $wechat_order_id,
|
||
|
|
'uid' => $uid,
|
||
|
|
'price' => bcmul('-1', (string)$prize['num'], 2),
|
||
|
|
'pay_type' => 'weixin',
|
||
|
|
'nickname' => $userInfo['nickname'],
|
||
|
|
'phone' => $userInfo['phone']
|
||
|
|
], 'luck');
|
||
|
|
|
||
|
|
if (sys_config('pay_wechat_type')) {
|
||
|
|
$pay = new Pay('v3_wechat_pay');
|
||
|
|
$pay->merchantPay($openid, $wechat_order_id, $prize['num'], [
|
||
|
|
'type' => $type,
|
||
|
|
'batch_name' => '抽奖中奖红包',
|
||
|
|
'batch_remark' => '您于' . date('Y-m-d H:i:s') . '中奖.' . $prize['num'] . '元'
|
||
|
|
]);
|
||
|
|
} else {
|
||
|
|
WechatService::merchantPay($openid, $wechat_order_id, $prize['num'], '抽奖中奖红包');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case 5:
|
||
|
|
/** @var StoreCouponIssueServices $couponIssueService */
|
||
|
|
$couponIssueService = app()->make(StoreCouponIssueServices::class);
|
||
|
|
try {
|
||
|
|
$couponIssueService->issueUserCoupon($prize['coupon_id'], $userInfo);
|
||
|
|
} catch (\Throwable $e) {
|
||
|
|
Log::error('抽奖领取优惠券失败，原因：' . $e->getMessage());
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
case 6:
|
||
|
|
if (!$receive_info['name'] || !$receive_info['phone'] || !$receive_info['address']) {
|
||
|
|
throw new ApiException(410052);
|
||
|
|
}
|
||
|
|
if (!check_phone($receive_info['phone'])) {
|
||
|
|
throw new ApiException(410053);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
$this->dao->update($lottery_record_id, $data, 'id');
|
||
|
|
});
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 发货、备注
|
||
|
|
* @param int $lottery_record_id
|
||
|
|
* @param array $data
|
||
|
|
* @return bool
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function setDeliver(int $lottery_record_id, array $data)
|
||
|
|
{
|
||
|
|
$lotteryRecord = $this->dao->get($lottery_record_id);
|
||
|
|
if (!$lotteryRecord) {
|
||
|
|
throw new ApiException(410054);
|
||
|
|
}
|
||
|
|
$deliver_info = $lotteryRecord['deliver_info'];
|
||
|
|
$edit = [];
|
||
|
|
//备注
|
||
|
|
if ($data['deliver_name'] && $data['deliver_number']) {
|
||
|
|
if ($lotteryRecord['type'] != 6 && ($data['deliver_name'] || $data['deliver_number'])) {
|
||
|
|
throw new ApiException(410055);
|
||
|
|
}
|
||
|
|
if ($lotteryRecord['type'] == 6 && (!$data['deliver_name'] || !$data['deliver_number'])) {
|
||
|
|
throw new ApiException(410056);
|
||
|
|
}
|
||
|
|
$deliver_info['deliver_name'] = $data['deliver_name'];
|
||
|
|
$deliver_info['deliver_number'] = $data['deliver_number'];
|
||
|
|
$edit['is_deliver'] = 1;
|
||
|
|
$edit['deliver_time'] = time();
|
||
|
|
}
|
||
|
|
$deliver_info['mark'] = $data['mark'];
|
||
|
|
$edit['deliver_info'] = $deliver_info;
|
||
|
|
if (!$this->dao->update($lottery_record_id, $edit, 'id')) {
|
||
|
|
throw new ApiException(100005);
|
||
|
|
}
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 获取中奖记录
|
||
|
|
* @param int $uid
|
||
|
|
* @param array $where
|
||
|
|
* @return array
|
||
|
|
* @throws \think\db\exception\DataNotFoundException
|
||
|
|
* @throws \think\db\exception\DbException
|
||
|
|
* @throws \think\db\exception\ModelNotFoundException
|
||
|
|
*/
|
||
|
|
public function getRecord(int $uid, $where = [])
|
||
|
|
{
|
||
|
|
if (!$where) {
|
||
|
|
$where['uid'] = $uid;
|
||
|
|
$where['not_type'] = 1;
|
||
|
|
}
|
||
|
|
[$page, $limit] = $this->getPageValue();
|
||
|
|
$list = $this->dao->getList($where, '*', ['prize'], $page, $limit);
|
||
|
|
foreach ($list as &$item) {
|
||
|
|
$item['deliver_time'] = $item['deliver_time'] ? date('Y-m-d H:i:s', $item['deliver_time']) : '';
|
||
|
|
$item['receive_time'] = $item['receive_time'] ? date('Y-m-d H:i:s', $item['receive_time']) : '';
|
||
|
|
}
|
||
|
|
return $list;
|
||
|
|
}
|
||
|
|
}
|