Commit 6ffb21b8 authored by 顾文旭's avatar 顾文旭

Job 定时任务

parent 92c44150
...@@ -5,6 +5,7 @@ ...@@ -5,6 +5,7 @@
* Date: 2021/9/3 2:23 下午 * Date: 2021/9/3 2:23 下午
*/ */
use App\Base\Base;
use App\Base\Job; use App\Base\Job;
use Api\PhpServices\Idgen\Idgen; use Api\PhpServices\Idgen\Idgen;
use App\Models\marketing\mysql\ColonelDistributorColonel; use App\Models\marketing\mysql\ColonelDistributorColonel;
...@@ -19,7 +20,7 @@ use App\Services\marketing\PindanActivityColonelConfigService; ...@@ -19,7 +20,7 @@ use App\Services\marketing\PindanActivityColonelConfigService;
use Api\PhpUtils\Log\JobLog; use Api\PhpUtils\Log\JobLog;
use App\Services\marketing\ColonelService; use App\Services\marketing\ColonelService;
class ColonelorderController extends Job class ColonelorderController extends Base
{ {
const REWARD_UNIT = 100; // 奖励单位: 分 const REWARD_UNIT = 100; // 奖励单位: 分
const INVITE_NEW_USER_REWARD = 3 * self::REWARD_UNIT; // 邀请新用户奖励 const INVITE_NEW_USER_REWARD = 3 * self::REWARD_UNIT; // 邀请新用户奖励
...@@ -111,13 +112,13 @@ class ColonelorderController extends Job ...@@ -111,13 +112,13 @@ class ColonelorderController extends Job
$userNickList = $this->getUserList(array_column($inviteNewUserList, 'user_id')); $userNickList = $this->getUserList(array_column($inviteNewUserList, 'user_id'));
foreach ($inviteNewUserList as $newUser) { foreach ($inviteNewUserList as $newUser) {
$colonelPayInfoData[] = [ $colonelPayInfoData[] = [
'date' => $this->settlementDate, 'date' => $this->settlementDate,
'type' => ColonelDistributorPayInfo::TYPE_NEW_USER, 'type' => ColonelDistributorPayInfo::TYPE_NEW_USER,
'reward' => self::INVITE_NEW_USER_REWARD, 'reward' => self::INVITE_NEW_USER_REWARD,
'finish_num' => 1, 'finish_num' => 1,
'invite_user_id' => $newUser['user_id'], 'invite_user_id' => $newUser['user_id'],
'invite_user_nick' => empty($userNickList[$newUser['user_id']]['user_nick']) ? '' : $userNickList[$newUser['user_id']]['user_nick'], 'invite_user_nick' => empty($userNickList[$newUser['user_id']]['user_nick']) ? '' : $userNickList[$newUser['user_id']]['user_nick'],
'colonel_user_id' => $newUser['inviter_user_id'], 'colonel_user_id' => $newUser['inviter_user_id'],
]; ];
} }
} }
...@@ -138,13 +139,13 @@ class ColonelorderController extends Job ...@@ -138,13 +139,13 @@ class ColonelorderController extends Job
foreach ($this->colonelConfigList as $config) { foreach ($this->colonelConfigList as $config) {
if ($orderNum['num'] >= $config['assess_order_num']) { if ($orderNum['num'] >= $config['assess_order_num']) {
$colonelPayInfoData[] = [ $colonelPayInfoData[] = [
'date' => $this->settlementDate, 'date' => $this->settlementDate,
'type' => ColonelDistributorPayInfo::TYPE_FINISH_TARGET, 'type' => ColonelDistributorPayInfo::TYPE_FINISH_TARGET,
'reward' => $config['reward_amount'] * self::REWARD_UNIT, 'reward' => $config['reward_amount'] * self::REWARD_UNIT,
'finish_num' => $config['assess_order_num'], 'finish_num' => $config['assess_order_num'],
'invite_user_id' => 0, 'invite_user_id' => 0,
'invite_user_nick' => '', 'invite_user_nick' => '',
'colonel_user_id' => $orderNum['colonel_user_id'], 'colonel_user_id' => $orderNum['colonel_user_id'],
]; ];
} }
} }
...@@ -161,9 +162,9 @@ class ColonelorderController extends Job ...@@ -161,9 +162,9 @@ class ColonelorderController extends Job
{ {
$config = ColonelDistributorConfig::getRecord([ $config = ColonelDistributorConfig::getRecord([
'date[<=]' => $settlementDate, 'date[<=]' => $settlementDate,
'type' => ColonelDistributorConfig::TYPE_COLONEL, 'type' => ColonelDistributorConfig::TYPE_COLONEL,
'ORDER' => ['date' => 'DESC'], 'ORDER' => ['date' => 'DESC'],
'LIMIT' => 1 'LIMIT' => 1
]); ]);
$configData = []; $configData = [];
if (!empty($config['data'])) { if (!empty($config['data'])) {
...@@ -183,7 +184,7 @@ class ColonelorderController extends Job ...@@ -183,7 +184,7 @@ class ColonelorderController extends Job
return ColonelDistributorInviteOrderNum::getRecords( return ColonelDistributorInviteOrderNum::getRecords(
[ [
'colonel_user_id' => $colonelUserIds, 'colonel_user_id' => $colonelUserIds,
'date' => $date, 'date' => $date,
], ],
['colonel_user_id', 'num'] ['colonel_user_id', 'num']
); );
...@@ -226,9 +227,9 @@ class ColonelorderController extends Job ...@@ -226,9 +227,9 @@ class ColonelorderController extends Job
$count = count($data); $count = count($data);
$httpParams = [ $httpParams = [
[ [
'type' => 'goods', 'type' => 'goods',
'number' => 00, 'number' => 00,
'count' => $count 'count' => $count
] ]
]; ];
$res = Idgen::get(appConfig('idgen.partner'), appConfig('idgen.key'), [], $httpParams); $res = Idgen::get(appConfig('idgen.partner'), appConfig('idgen.key'), [], $httpParams);
...@@ -294,7 +295,7 @@ class ColonelorderController extends Job ...@@ -294,7 +295,7 @@ class ColonelorderController extends Job
$balance = ($result['capital_pool_total'] - $result['capital_pool_lock'] - $result['capital_pool_used']); $balance = ($result['capital_pool_total'] - $result['capital_pool_lock'] - $result['capital_pool_used']);
return [ return [
'marketing_id' => $marketing['marketing_id'], 'marketing_id' => $marketing['marketing_id'],
'balance' => $balance 'balance' => $balance
]; ];
} }
...@@ -330,7 +331,7 @@ class ColonelorderController extends Job ...@@ -330,7 +331,7 @@ class ColonelorderController extends Job
private function loadTimeConfig() private function loadTimeConfig()
{ {
// 如果传入时间-使用指定时间 // 如果传入时间-使用指定时间
$params = $this->getRequest()->getParams(); $params = $this->params;
if (empty($params['date']) || !strtotime($params['date'])) { if (empty($params['date']) || !strtotime($params['date'])) {
$timeRange = PindanActivityColonelConfigService::getSettlementTimeRange(); $timeRange = PindanActivityColonelConfigService::getSettlementTimeRange();
$this->settlementDate = $timeRange['date']; $this->settlementDate = $timeRange['date'];
......
...@@ -5,13 +5,14 @@ ...@@ -5,13 +5,14 @@
* Date: 2021/9/3 2:23 下午 * Date: 2021/9/3 2:23 下午
*/ */
use App\Base\Base;
use App\Base\Job; use App\Base\Job;
use App\Models\marketing\mysql\ColonelDistributorPayInfo; use App\Models\marketing\mysql\ColonelDistributorPayInfo;
use Api\PhpUtils\Http\HttpUtil; use Api\PhpUtils\Http\HttpUtil;
use Api\PhpUtils\Log\JobLog; use Api\PhpUtils\Log\JobLog;
use App\Services\marketing\ColonelService; use App\Services\marketing\ColonelService;
class ColonelwalletController extends Job class ColonelwalletController extends Base
{ {
const CAPITAL_POOL_OP = 200; //200:团长奖励 const CAPITAL_POOL_OP = 200; //200:团长奖励
const WALLET_SERVICE_NAME = 10; // 10生活圈优惠券,11营销活动 const WALLET_SERVICE_NAME = 10; // 10生活圈优惠券,11营销活动
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment