tt-5-php-6001/app/business/TaskBusiness.php

<?php

namespace app\business;

use support\Db;
use support\Log;
use support\Redis;

class TaskBusiness
{
    /**产品的每日分红
     * @param int $taskId 任务ID
     * @return void
     */
    static public function taskOne(int $taskId)
    {

        Db::beginTransaction();
        try {
            $cronTask = Db::table('wa_cron_task')->where('id', $taskId)->lockForUpdate()->first();
            if (empty($cronTask)) {
                throw new \Exception('没有查询当任务!');
            }
            $proder = Db::table('wa_payorder')->where('id', $cronTask->order_id)->first();
            if (empty($proder)) {
                Db::table('wa_cron_task')->where('id', $taskId)->update([
                    'is_finish' => 2
                ]);
            }
            if ($cronTask->goods_type == 1) {
                /** @var  $has 查询今天是否已经发奖 */
                $has = Db::table('wa_stream')
                    ->where('user_id', $cronTask->user_id)
                    ->where('type', streamType9)
                    ->where('mold', moldType7)
                    ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
                    ->where('source_id', $taskId)
                    ->exists();
                /** @var  $usersData 查询会员信息 */
                $usersData = Db::table('wa_users')->where('id', $cronTask->user_id)->first();

                if (empty($has) && !empty($usersData)) {

                    $bonus = Db::table('wa_goods')->where('id',$cronTask->goods_id)->value('original_bonus');
                    if(!empty($bonus)){
                        StreamBusiness::addStream($usersData->id, $bonus, streamType9, moldType7, moldTypefild7, $taskId);
                    }
                    if (!empty($usersData->pid) && !empty($cronTask->rebate)) {
                        StreamBusiness::addStream($usersData->pid, $cronTask->rebate, streamType9, moldType9, moldTypefild9, $taskId);
                    }
                    if (!empty($usersData->ppid) && !empty($cronTask->rebate_one)) {
                        StreamBusiness::addStream($usersData->ppid, $cronTask->rebate_one, streamType9, moldType9, moldTypefild9, $taskId);
                    }
                    if (!empty($usersData->toppid) && !empty($cronTask->rebate_two)) {
                        StreamBusiness::addStream($usersData->toppid, $cronTask->rebate_two, streamType9, moldType9, moldTypefild9, $taskId);
                    }
                }
            } elseif ($cronTask->goods_type == 2) {
                /** @var  $has 查询今天是否已经发奖 */
                $has = Db::table('wa_stream')
                    ->where('user_id', $cronTask->user_id)
                    ->where('type', streamType26)
                    ->where('mold', moldType11)
                    ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
                    ->where('source_id', $taskId)
                    ->exists();
                /** @var  $usersData 查询会员信息 */
                $usersData = Db::table('wa_users')->where('id', $cronTask->user_id)->first();

                if (empty($has) && !empty($usersData)) {
                    if ($cronTask->is_activity > 0 && $cronTask->event_time < time() && $cronTask->event_time > 0) {
                        $bonus = bcdiv($cronTask->bonus, $cronTask->is_activity, 2);
                        if (!empty($cronTask->balance)) {
                            $balance = bcdiv($cronTask->balance, $cronTask->is_activity, 2);
                        } else {
                            $balance = 0;
                        }
                    } else {
                        $bonus   = $cronTask->bonus;
                        $balance = $cronTask->balance;
                    }
                    StreamBusiness::addStream($usersData->id, $bonus, streamType26, moldType11, moldTypefild11, $taskId);

                    if (!empty($balance)) {
                        StreamBusiness::addStream($usersData->id, $balance, streamType30, moldType10, moldTypefild10, $taskId);
                        StreamBusiness::delStream($usersData->id, $balance, streamType27, moldType3, moldTypefild3, $taskId);
                    }
                }
            }
            Db::table('wa_cron_task')->where('id', $taskId)->update([
                'day_dividend_time' => strtotime(date('Y-m-d', strtotime('+1 days')) . ' 00:10:00'),
                'is_day'            => 2
            ]);
            Db::commit();
        } catch (\Throwable $exception) {
            Db::rollBack();
            Log::channel('task')->error($exception->getMessage(), [$taskId]);

        }

    }

    static public function taskFj(int $taskId)
    {
        Db::beginTransaction();
        try {
            StreamBusiness::addStream($taskId, 88888, streamType13, moldType4, moldTypefild4, $taskId);

            Db::table('wa_users')->where('id', $taskId)->update([
                'is_f' => 2,
            ]);
            Db::commit();
        } catch (\Throwable $exception) {
            Db::rollBack();
            Log::channel('task_jr')->error($exception->getMessage(), $taskId);

        }
    }


    /** 申请通过
     * @param $taskId
     * @return void
     */
    static public function TaskRefund($taskId)
    {
        Db::beginTransaction();
        try {
            $cronTask = Db::table('wa_cron_task_sign_two')->where('id', $taskId)->lockForUpdate()->first();
            if (empty($cronTask)) {
                throw new \Exception('没有查询当任务!');
            }

            if ($cronTask->dividend_time >= time()) {
                /** @var  $has 查询今天是否已经发奖 */
                $has = Db::table('wa_stream')
                    ->where('user_id', $cronTask->user_id)
                    ->where('type', streamType19)
                    ->where('mold', moldType1)
                    ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
                    ->where('source_id', $taskId)
                    ->exists();
                /** @var  $usersData 查询会员信息 */
                $usersData = Db::table('wa_users')->where('id', $cronTask->user_id)->first();

                if (empty($has) && !empty($usersData)) {
                    StreamBusiness::addStream($usersData->id, $cronTask->highest_pay_price, streamType19, moldType5, moldTypefild5, $taskId);
                    StreamBusiness::addStream($usersData->id, $cronTask->day, streamType19, moldType1, moldTypefild1, $taskId);
                    Db::table('wa_users')->where('id', $usersData->id)->increment('raffle_num', $cronTask->bl);
                    Db::table('wa_users')->where('id', $usersData->id)->increment('accumulate_raffle_num', $cronTask->bl);
                }

//                $hasone = Db::table('wa_stream')
//                    ->where('user_id', $cronTask->user_id)
//                    ->where('type', streamType20)
//                    ->where('mold', moldType6)
//                    ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
//                    ->exists();
//                if(empty($hasone)){
//                    StreamBusiness::addStream($usersData->id, 1, streamType20, moldType6, moldTypefild6);
//                }

                Db::table('wa_cron_task_sign_two')->where('id', $taskId)->update([
                    'day_dividend_time' => strtotime(date('Y-m-d', strtotime('+1 days')) . ' 01:00:00'),
                    'is_day'            => 2
                ]);
            } else {
                Db::table('wa_cron_task_sign_two')->where('id', $taskId)->update([
                    'is_finish' => 2
                ]);
            }
            Db::commit();
        } catch (\Throwable $exception) {
            Db::rollBack();
            Log::channel('task')->error($exception->getMessage(), []);

        }
    }


    /**基金每日分红
     * @param int $taskId 任务ID
     * @return void
     */
    static public function taskSign(int $taskId)
    {

        Db::beginTransaction();
        try {
            $cronTask = Db::table('wa_cron_task_sign')->where('id', $taskId)->lockForUpdate()->first();
            if (empty($cronTask)) {
                throw new \Exception('没有查询当任务!');
            }

            if ($cronTask->dividend_time >= time()) {
                /** @var  $has 查询今天是否已经发奖 */
                $has = Db::table('wa_stream')
                    ->where('user_id', $cronTask->user_id)
                    ->where('type', streamType13)
                    ->where('mold', moldType2)
                    ->whereBetween('add_time', [strtotime(date('Y-m-d') . ' 00:00:00'), strtotime(date('Y-m-d') . ' 23:59:59')])
                    ->where('source_id', $taskId)
                    ->exists();
                /** @var  $usersData 查询会员信息 */
                $usersData = Db::table('wa_users')->where('id', $cronTask->user_id)->first();

                if (empty($has) && !empty($usersData)) {
                    StreamBusiness::addStream($usersData->id, $cronTask->bonus, streamType13, moldType2, moldTypefild2, $taskId);
                }

                Db::table('wa_cron_task_sign')->where('id', $taskId)->update([
                    'day_dividend_time' => strtotime(date('Y-m-d', strtotime('+1 days')) . ' 00:30:00'),
                    'is_day'            => 2
                ]);
            } else {
                $usersData = Db::table('wa_users')->where('id', $cronTask->user_id)->first();
                StreamBusiness::addStream($usersData->id, $cronTask->money, streamType15, moldType1, moldTypefild1, $taskId);
                Db::table('wa_cron_task_sign')->where('id', $taskId)->update([
                    'is_finish' => 2
                ]);
            }


            Db::commit();
        } catch (\Throwable $exception) {
            Db::rollBack();
            Log::channel('task')->error($exception->getMessage(), []);

        }

    }
}