yusheng-php/application/cron/controller/Subsidy.php

<?php

namespace app\cron\controller;

use app\common\controller\adminApi;
use think\Controller;
use think\Db;

/*
 * 工会
 */
class Subsidy
{
    /*
     * 运行函数
     */
    function index()
    {
        echo  "工会补贴生成开始：\n";
        $this->createGuildSubsidyData();//工会补贴数据
        echo "\n";
        echo  "房间补贴生成开始：\n";
        $this->createRoomSubsidyData();//房间补贴数据
    }

    /*
     * 生成工会补贴数据
     * 配置：定时脚本每周一  执行
     * 配置：/cron/Subsidy/createGuildSubsidyData
     */
    public function createGuildSubsidyData(){
        //获取上周第一天时间
        $week_start_time = strtotime('-1 weeklast monday');
        $week_end_time = strtotime('last sunday');
//        $week_start_time = strtotime('this week monday');
//        $week_end_time = strtotime('sunday');
        //获取上周时间
        $time_value = date('o-W', strtotime('-1 week'));
        echo $time_value . "工会周补贴数据生成开始\n";
        //查询所有工会
        $guild_list = db::name('vs_guild')->where(['delete_time'=>0])->field('id')->select();
        $data_count = 0;
        foreach ($guild_list as $key => $value) {
            //获取所有工会房间ID
            $room_ids = db::name('vs_guild_user')->where('guild_id', $value['id'])->field('room_id')->select();
            $room_ids = array_column($room_ids, 'room_id');
            $transaction = db::name('vs_give_gift')
                ->whereIn('from_id',$room_ids)
                ->where(['from'=>['in',[2,3,6]],'createtime' => ['between', [$week_start_time, $week_end_time]]])
                ->sum('total_price');
            if($transaction > 0){
                //判断是否已经生成过
                if (db::name('vs_guild_subsidy')->where(['guild_id'=>$value['id'],'week'=>$time_value])->find()) {
                    continue;
                }
                //获取补贴配置
                $config = db::name('vs_guild_subsidy_config')->where(['status' => 1])->order('end_amount desc')->select(); //配置查询
                if (!$config) {
                    echo '补贴配置为空\n';
                    die;
                }
                $subsidy_ratio = 0;
                $subsidy_amount = 0;
                foreach ($config as $k => $v) {
                    if ($transaction >= $v['end_amount']) {
                        $subsidy_ratio = $v['subsidy_ratio'];
                        $subsidy_amount = $transaction * ($subsidy_ratio / 100);
                        break; // 找到匹配项后提前退出循环
                    }
                }
                //生成补贴数据
                $data = [
                    'guild_id' => $value['id'],
                    'week' => $time_value,
                    'start_time' => date('Y-m-d H:i:s', $week_start_time),
                    'end_time' =>date('Y-m-d H:i:s', $week_end_time),
                    'total_transaction' => $transaction,
                    'subsidy_amount' => $subsidy_amount,
                    'subsidy_ratio' => $subsidy_ratio,
                    'status' => 0,
                    'createtime' => time(),
                ];
                $subsidy_id = Db::name('vs_guild_subsidy')->insertGetId($data);
                if ($subsidy_id) {
                    echo "工会".$value['id']."生成成功(补贴ID：".$subsidy_id." 补贴金额：".$subsidy_amount.")\n";
                    $data_count++;
                }
            }
        }
        echo $time_value . "工会周补贴数据生成完成-共" . $data_count . "条数据\n";
    }

    /*
      * 生成房间补贴数据
      * 配置：定时脚本每周一  执行
      * 配置：/Core/RoomSubsidy/createRoomSubsidyData
      */
    public function createRoomSubsidyData(){
        //获取上周第一天时间
        $week_start_time = strtotime('-1 weeklast monday');
        $week_end_time = strtotime('last sunday');
//        $week_start_time = strtotime('this week monday');
//        $week_end_time = strtotime('sunday');
        //获取上周时间
        $time_value = date('o-W', strtotime('-1 week'));
        echo $time_value . "房间周补贴数据生成开始\n";
        //查询所有房间
        $room_list = db::name('vs_room')->where(['delete_time'=>0,'is_earnings'=>1])->field('id')->select();
        $data_count = 0;
        foreach ($room_list as $key => $value) {
            $transaction = db::name('vs_give_gift')
                ->where('from_id',$value['id'])
                ->where(['from'=>['in',[2,3,6]],'createtime' => ['between', [$week_start_time, $week_end_time]]])
                ->sum('total_price');
            if($transaction > 0){
                //判断是否已经生成过
                if (db::name('vs_room_subsidy')->where(['room_id'=>$value['id'],'week'=>$time_value])->find()) {
                    continue;
                }
                //获取补贴配置
                $config = db::name('vs_room_subsidy_config')->where(['status' => 1])->order('end_amount desc')->select(); //配置查询
                if (!$config) {
                    echo '补贴配置为空\n';
                    die;
                }
                $subsidy_ratio = 0;
                $subsidy_amount = 0;
                foreach ($config as $k => $v) {
                    if ($transaction >= $v['end_amount']) {
                        $subsidy_ratio = $v['subsidy_ratio'];
                        $subsidy_amount = $transaction * ($subsidy_ratio / 100);
                        break; // 找到匹配项后提前退出循环
                    }
                }
                //生成补贴数据
                $data = [
                    'room_id' => $value['id'],
                    'week' => $time_value,
                    'start_time' => date('Y-m-d H:i:s', $week_start_time),
                    'end_time' =>date('Y-m-d H:i:s', $week_end_time),
                    'total_transaction' => $transaction,
                    'subsidy_amount' => $subsidy_amount,
                    'subsidy_ratio' => $subsidy_ratio,
                    'status' => 0,
                    'createtime' => time(),
                ];
                $subsidy_id = Db::name('vs_room_subsidy')->insertGetId($data);
                if ($subsidy_id) {
                    echo "房间".$value['id']."生成成功(补贴ID：".$subsidy_id." 补贴金额：".$subsidy_amount.")\n";
                    $data_count++;
                }
            }
        }
        echo $time_value . "房间周补贴数据生成完成-共" . $data_count . "条数据\n";
    }
}