NN2023021801/app/api/controller/v1/Test.php

<?php

namespace app\api\controller\v1;

use AlibabaCloud\SDK\OSS\OSS\DeleteMultipleObjectsRequest\body\delete;
use app\admin\controller\coupon\Couponarea;
use app\admin\service\ConfigService;
use app\api\services\ThirdPayServices;
use app\api\services\UserAuthServices;
use app\api\services\UserServices;
use app\common\model\BoxMidHandleModel;
use app\common\model\BoxHandleModel;
use app\common\model\CouponAreaModel;
use app\common\model\CouponPlanLogModel;
use app\common\model\CouponPlanModel;
use app\common\model\GreenScoreLogModel;
use app\common\model\MachineListModel;
use app\common\model\MachineModel;
use app\common\model\ShopGoodsModel;
use app\common\model\User;
use app\common\model\UserDataModel;
use app\common\model\UserFansModel;
use app\common\model\UserModel;
use app\common\model\YgOrderModel;
use app\common\service\SystemConfigService;
use Grpc\Timeval;
use jobs\CouponPlanJob;
use jobs\JpOrderJob;
use jobs\ShopOrderJob;

use jobs\SystemMiddleOpenBox;
use PhpOffice\PhpSpreadsheet\IOFactory;
use PhpOffice\PhpSpreadsheet\Reader\Xls\MD5;
use Rsa\RsaClient;
use services\CacheServices;
use think\cache\driver\Redis;
use think\db\Where;
use think\Exception;
use think\facade\Cache;
use think\facade\Db;
use think\facade\Filesystem;
use think\Request;
use utils\Queue;

use jianyan\excel\Excel;
use utils\RedisCache;

class Test
{
    public function test(Request $request)
    {
        Db::startTrans();
        $lists = UserModel::field('id,money,score,profit_money,green_score')->select();
        $logs = [];
        foreach($lists as $item){
            $id = isset($item['id'])? $item['id'] : 0;
            $score = isset($item['score'])? $item['score'] : 0;
            $money = isset($item['money'])? $item['money'] : 0;
            $profit = isset($item['profit_money'])? $item['profit_money'] : 0;
            $greenScore = UserModel::where('id', $id)->value('green_score');
            $newGreenScore = $greenScore;
            if($score>0){
                echo "用户{$id} {$score}  积分转入<br>";
                $logs[] = [
                    'uid'=> $id,
                    'type'=> 1,
                    'score'=> $score,
                    'create_at'=> date('Y-m-d H:i:s'),
                    'from_id'=> 0,
                    'uid2'=> 0,
                    'state'=> 1,
                    'before_score'=> $greenScore,
                    'after_score'=> $newGreenScore+$score,
                    'remark'=> '积分转入'
                ];
                $newGreenScore += $score;
            }

            if($money>0){
                echo "用户{$id} {$money}  余额转入<br>";
                $logs[] = [
                    'uid'=> $id,
                    'type'=> 3,
                    'score'=> $money,
                    'create_at'=> date('Y-m-d H:i:s'),
                    'from_id'=> 0,
                    'uid2'=> 0,
                    'state'=> 1,
                    'before_score'=> $newGreenScore,
                    'after_score'=> $newGreenScore+$money,
                    'remark'=> '余额转入'
                ];
                $newGreenScore += $money;
            }

            if($profit>0){
                echo "用户{$id} {$profit}  利润转入<br>";
                $logs[] = [
                    'uid'=> $id,
                    'type'=> 2,
                    'score'=> $profit,
                    'create_at'=> date('Y-m-d H:i:s'),
                    'from_id'=> 0,
                    'uid2'=> 0,
                    'state'=> 1,
                    'before_score'=> $newGreenScore,
                    'after_score'=> $newGreenScore+$profit,
                    'remark'=> '利润转入'
                ];

                $newGreenScore +=$profit;
            }

            if($newGreenScore>0 && !UserModel::where('id',$id)->inc('green_score',$newGreenScore)->update()){
                Db::rollback();
                return 'fail';
            }
        }

        if($logs){
            if(!GreenScoreLogModel::insertAll($logs)){
                Db::rollback();
                return 'fail';
            }

            if(!UserModel::where('id','>',0)->update(['score'=>0,'money'=>0,'profit_money'=>0,'update_time'=>date('Y-m-d H:i:s')])){
                Db::rollback();
                return 'fail';
            }
        }

        Db::commit();

        return 'success';
    }

}