";
        $i=0;
        $lasti=0;
        $key="adjust_test_no2";
        if(Redis::exists($key)) {
            $lasti=(int)Redis::get($key);
        }
        $step=20;
        $start=0;
        foreach ($datas as $data) {
            $i++;
            if($i>$lasti) {
                $curl = new HttpCurl();
                $data['app_token'] = 'dgc2q9jhsfeo';
                $data['event_token'] = '8m7lz8';
                $data['created_at_unix']=time();
//                print_r($data);
                $res = $curl->curlPost($gateway, $data,'');
                echo "
{$i}_{$res}";
                $start++;
                if($start>=$step)break;

//                sleep(1);
//                $curl = new HttpCurl();
//                $data['event_token'] = '2on9ll';
//                $data['created_at_unix']=time();
//                $res = $curl->curlPost($gateway, $data, '');
//                print_r($res);
            }

        }
        $lasti=$i;
        Redis::set($key,$lasti);
    }

    public function adjust(){
        $gateway='https://s2s.adjust.com/event';
        $datas='[{"gps_adid":"42897349-cef9-4631-b379-096b622ce82f","event_token":"dscml0","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693841080},{"gps_adid":"42897349-cef9-4631-b379-096b622ce82f","event_token":"5fxu12","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693841079,"revenue":10,"currency":"BRL"},{"gps_adid":"42897349-cef9-4631-b379-096b622ce82f","event_token":"gd6jin","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693841078} ,{"gps_adid":"d3bef6f8-5120-4668-adcc-0059a87cc9f2","event_token":"dscml0","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693873946},{"gps_adid":"d3bef6f8-5120-4668-adcc-0059a87cc9f2","event_token":"gd6jin","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693873944},{"gps_adid":"d3bef6f8-5120-4668-adcc-0059a87cc9f2","event_token":"5fxu12","app_token":"grajj7r58n40","s2s":1,"created_at_unix":1693873945,"revenue":10,"currency":"BRL"}]';
        $datas=json_decode($datas,true);
        print_r($datas);
        echo "
";
        $i=0;
        $tokens=[
            'gd6jin'    => 'pi6if1',
            '5fxu12'   => 'ltp413',
            'dscml0' => 'lt7ruq',
            '1n9joo' => 'rvwp03',
        ];


        foreach ($datas as $data) {

            $curl = new HttpCurl();
            $data['app_token'] = 'ok69c325y6tc';
            $data['event_token'] = $tokens[$data['event_token']];
            $data['created_at_unix']=time();
//                print_r($data);
            $res = $curl->curlPost($gateway, $data,'');
            echo "
{$i}_{$res}";

//                sleep(1);
//                $curl = new HttpCurl();
//                $data['event_token'] = '2on9ll';
//                $data['created_at_unix']=time();
//                $res = $curl->curlPost($gateway, $data, '');
//                print_r($res);

        }
    }
    public function repayOrders(){
        $orders=['BR907343225223468585744','BR9073084791786501864977','BR9072862766923101651997','BR9072629966687041935344','BR9072421424348241331333','BR9072367341848521637381','BR9072361173854741395682','BR907231397789871209229','BR9072154682810471428647','BR9071943851446521819498','BR9071918503504261720812','BR9071781047537621151100','BR9071664665360441673957','BR9071441992298301481029','BR907084559613508172139'];

        foreach ($orders as $order){
            $res=$this->repayOrder($order,true);
            echo $order;
            print_r($res);
        }
    }
    public function repayOrder($order_sn,$forceRepay=false){




        try {
            // 查询订单信息
            $order = DB::connection('write')->table('agent.dbo.order')->where('order_sn', $order_sn)->first();

            if (!$order) {
                return '{"success":false,"message":"订单不存在"}';
            }

            //如果不是强制重新支付
            if (!$forceRepay&&(!empty($order->pay_at) || !empty($order->finished_at)) ) {
                return 'SUCCESS';
            }



            $body = [
                'payment_sn' => '',
                'updated_at' => date('Y-m-d H:i:s'),
            ];

            $ordStatus = 1;
            $GiftsID = $order->GiftsID ?: '';
            $userID = $order->user_id ?: '';
            $AdId = $order->AdId ?: '';
            $eventType = $order->eventType ?: '';
            $payAmt = $order->amount/100;

            if(!$AdId){
                $redis = Redis::connection();
                $AdId = $redis->get('user_ad_'.$userID);
            }



            // 说明:除了成功，失败和退款状态,都可以认为是处理中
            switch ($ordStatus) {
                case 1:    // 支付成功


                    $body['pay_status'] = 1;
                    $body['pay_at'] = date('Y-m-d H:i:s');
                    $body['finished_at'] = date('Y-m-d H:i:s');
                    $body['amount'] = $payAmt * NumConfig::NUM_VALUE;

                    // 获取金额
                    $service = new OrderServices();

                    if ($order->amount != $body['amount']) {
                        $body['GiftsID'] = 0;
                        $body['amount'] = $payAmt * NumConfig::NUM_VALUE;
                        $Recharge = $payAmt;
                        $give = 0;
                        $favorable_price = $Recharge + $give;
                        $czReason = 1;
                        $cjReason = 45;
                    } else {
                        [$give, $favorable_price, $Recharge, $czReason, $cjReason] = $service->getPayInfo($GiftsID, $userID, $payAmt);
                    }
                    if($order->pay_status!=1) {
                        $order_up = DB::connection('write')->table('agent.dbo.order')
                            ->where('order_sn', $order_sn)
                            ->update($body);

                    }
                    [$Score] = $service->addRecord($userID, $payAmt, $favorable_price, $order_sn, $GiftsID, $Recharge, $czReason, $give, $cjReason, $AdId, $eventType);
                    // 成功处理回调
                    Order::dispatch([$userID, $payAmt, $Score,$favorable_price, $GiftsID,$order_sn]);

//                    $cpf = @$post['reference'];
//                    if($cpf){
//                        Cpf::insertCpf($userID,$cpf);
//                    }

                    break;
                case 2:    // 支付失败
                    $body['pay_status'] = 2;
                    $order_up = DB::connection('write')->table('agent.dbo.order')
                        ->where('order_sn', $order_sn)
                        ->update($body);
                    break;
            }

//            $order_up = DB::connection('write')->table('agent.dbo.order')
//                ->where('order_sn', $order_sn)
//                ->update($body);



            return 'SUCCESS';
        } catch (\Exception $exception) {
            Util::WriteLog('goopago','Goopago 支付失败' . $exception->getMessage());
            $this->error = $exception->getMessage();
            return '{"success":false,"message":"商户自定义出错信息"}';
        }
    }
}