138 lines
4.1 KiB
PHP
138 lines
4.1 KiB
PHP
<?php
|
|
/**
|
|
* This service file is part of item.
|
|
*
|
|
* @author ctexthuang
|
|
* @contact ctexthuang@qq.com
|
|
*/
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Service\Api\Coupon;
|
|
|
|
use App\Constants\Common\CouponCode;
|
|
use App\Exception\ErrException;
|
|
use App\Model\CouponDispenseLog;
|
|
use App\Model\CouponDispenseUser;
|
|
use App\Model\UserCoupon;
|
|
use App\Service\Api\BaseService;
|
|
use Hyperf\DbConnection\Db;
|
|
use Hyperf\Di\Annotation\Inject;
|
|
|
|
class HomePopupsService extends BaseService
|
|
{
|
|
/**
|
|
* @var CouponDispenseUser
|
|
*/
|
|
#[Inject]
|
|
protected CouponDispenseUser $couponDispenseUserModel;
|
|
|
|
/**
|
|
* @var CouponDispenseLog
|
|
*/
|
|
#[Inject]
|
|
protected CouponDispenseLog $couponDispenseLogModel;
|
|
|
|
/**
|
|
* @var UserCoupon
|
|
*/
|
|
#[Inject]
|
|
protected UserCoupon $userCouponModel;
|
|
|
|
|
|
public function handle(): array
|
|
{
|
|
$dispenseIds = $this->couponDispenseUserModel->getNoReceiveCountByUserId($this->userId);
|
|
|
|
$data = $this->couponDispenseLogModel->getNoReceiveCount();
|
|
if (empty($dispenseIds) && empty($data['all']) && empty($data['appoint'])) return $this->returnNullRes();
|
|
|
|
$allDispenseIds = [];
|
|
if (!empty($all['all'])) {
|
|
$allDispenseIds = $this->userCouponModel->getReceiveCountByUserIds($this->userId,$data['all']);
|
|
}
|
|
|
|
$canReceive = array_unique(array_merge(
|
|
array_diff($data['all'], $allDispenseIds),
|
|
array_intersect($dispenseIds,$data['appoint'])
|
|
));
|
|
|
|
if (empty($canReceive)) return $this->returnNullRes();
|
|
|
|
$this->receive($canReceive);
|
|
|
|
return $this->return->success('success',['canReceive'=>$canReceive]);
|
|
}
|
|
|
|
/**
|
|
* @param array $data
|
|
* @return void
|
|
*/
|
|
private function receive(array $data): void
|
|
{
|
|
$list = $this->couponDispenseLogModel->getListByIds($data);
|
|
if (empty($list)) return;
|
|
|
|
$insertData = [];
|
|
$appointUpdateData = [];
|
|
$allUpdateData =[];
|
|
foreach ($list as $item) {
|
|
$oneData = [
|
|
'user_id' => $this->userId,
|
|
'coupon_template_id' => $item['coupon_template_id'],
|
|
'coupon_name' => $item['coupon_name']->coupon_name,
|
|
'coupon_dispense_id' => $item['id'],
|
|
'status' => CouponCode::COUPON_STATUS_UNUSED,
|
|
'validity_start_time' => $item['validity_start_time'],
|
|
'validity_end_time' => $item['validity_end_time'],
|
|
];
|
|
|
|
$copies = array_map(function () use ($oneData) {
|
|
return $oneData;
|
|
}, array_fill(0, $item['item_count'], null));
|
|
|
|
$insertData = array_merge($insertData, $copies);
|
|
|
|
if ($item['appoint_group'] != CouponCode::DISPENSE_APPOINT_GROUP_ALL_PEOPLE) {
|
|
$appointUpdateData[] = [
|
|
'coupon_dispense_id' => $item['id'],
|
|
'user_id' => $this->userId,
|
|
];
|
|
}
|
|
|
|
$allUpdateData[] = [
|
|
'id' => $item['id'],
|
|
'receive_count' => $item['receive_count'] +$item['item_count'],
|
|
];
|
|
}
|
|
|
|
if (empty($allUpdateData)) return;
|
|
|
|
if (!empty($appointUpdateData)) {
|
|
$appointList = $this->couponDispenseUserModel->where('user_id',$this->userId)->whereIn('id',array_column($appointUpdateData,'coupon_dispense_id'))->pluck('id','coupon_dispense_id');
|
|
|
|
foreach ($appointUpdateData as &$item) {
|
|
$item['id'] = $appointList[$item['coupon_dispense_id']];
|
|
}
|
|
}
|
|
|
|
Db::transaction(function () use($allUpdateData,$appointUpdateData,$insertData) {
|
|
$appointUpdateFlag = true;
|
|
|
|
if (!empty($appointUpdateData)) {
|
|
$appointUpdateFlag = (new CouponDispenseUser())->update($appointUpdateData);
|
|
}
|
|
|
|
$allUpdateFlag = (new CouponDispenseLog)->update($allUpdateData);
|
|
|
|
$insertFlag = (new UserCoupon)->insert($insertData);
|
|
|
|
if (!$allUpdateFlag || !$appointUpdateFlag || !$insertFlag) throw new ErrException('领取失败');
|
|
});
|
|
}
|
|
|
|
private function returnNullRes(): array
|
|
{
|
|
return $this->return->success();
|
|
}
|
|
} |