php/www/protected/modules/o2o/controllers/RechargeController.php

<?php
/**
 * RechargeController o2o充值卡接口
 */
class  RechargeController extends O2oBaseController{
    //充值卡 支付

    public function actionTest(){

        //$user = RUser::model()->get(new MongoId('57e238929f5160d6048b456d'));
       // var_dump($user);exit;
        $criteria = new EMongoCriteria();
        //$criteria->status('==','1');
        $criteria->price('==',1000);

        $cursor = RechargeOrder::model()->findAll($criteria);
        $orders = CommonFn::getRowsFromCursor($cursor);
        $user_ids = array();
        $i = 0;
        foreach($orders as $order) {
            //start充值活动暂用
             if ($order['time'] > date_create("2016-11-11")->format('U') && $order['time'] < date_create("2016-11-17")->format('U')) {
                 $user = RUser::model()->get(new MongoId($order['user']));
                 if (!in_array((string)$user->_id,$user_ids)) {
                     $num = intval(ceil((rand(100000, 999999))) / 10000);
                     $data = '{
                        "touser": "' . $user->wx_pub_openid . '",
                        "msgtype": "text",
                        "text": {
                        "content": "' . '恭喜您获得参与本次活动的权利,' . $num . '为您参加本活动的号码,' . '"
                        }
                    }';
                     echo $i++;
                 }
                 $user_ids[] = $user->_id;
                 $user_ids = array_unique($user_ids);
                 //var_dump(CommonFn::sendWxMessage($data));
             }
        }
        $criteria_order = new EMongoCriteria();
        $criteria_order->status('==','1');
        $criteria_order->price('==',5000);

        $cursor = RechargeOrder::model()->findAll($criteria_order);
        $orders = CommonFn::getRowsFromCursor($cursor);
        foreach($orders as $order) {
            //start充值活动暂用
            if ($order['time'] >= date_create("2016-11-11")->format('U') && $order['time'] <= date_create("2016-11-16")->format('U')) {
                $user = RUser::model()->get(new MongoId($order['user']));
                $num = intval(ceil((rand(100000, 999999))) / 10000);
                $data = '{
                    "touser": "' . $user->wx_pub_openid . '",
                    "msgtype": "text",
                    "text": {
                    "content": "' . '恭喜您获得参与本次活动的权利,' . $num . '为您参加本活动的号码,' . '"
                    }
                }';
                var_dump(CommonFn::sendWxMessage($data));
            }
        }
        //end



    }


    public function actionPayRecharge(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $pay_channel = Yii::app()->getRequest()->getParam("pay_channel");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        if(!$user_id || !$pay_channel || !$order_id || !CommonFn::isMongoId($order_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = RechargeOrder::get(new MongoId($order_id));
        if(!$order || !$user_obj){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        if($order && (string)$order->user != $user_id){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        if($order->charge_id){
            CommonFn::requestAjax(false,'此订单已支付过',array('have_pay'=>1));
        }

        $str = '壹管家充值卡';
        $amount = ceil($order->price*1000)/10;
        $result = Service::factory('PayService')->Pay($pay_channel,$amount,'char'.(string)$order->_id,$str,$str,$user_obj->wx_pub_openid);
        if($result === false){
            CommonFn::requestAjax(false,'支付遇到点问题了，请稍候再试');
        }else{
            CommonFn::requestAjax(true,'success',json_decode($result),200,array());
        }
    }

    //充值卡订单创建
    public function actionAddRechargeorder(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $recharge_id = Yii::app()->getRequest()->getParam("recharge_id");

        if(!$user_id||!$recharge_id){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = CommonFn::apigetObJ($user_id,'ZUser',CommonFn::getMessage('user','id_not_exist'),array(),201);

        $recharge = Recharge::get(new MongoId($recharge_id));
        if(!$recharge){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }

        $order = new RechargeOrder();
        $order->time = time();

        $order->price = $recharge->denomination;
        $order->recharge = $recharge->_id;

        $order->user = $user_obj->_id;

        if($order->save()){
            $data = RechargeOrder::model()->parseRow($order);
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
        }else{
            CommonFn::requestAjax(true,'未知错误,请稍候再试',array());
        }
    }

    //获取充值卡列表
    public function actionRechargeList(){
        $criteria = new EMongoCriteria();

        $criteria->status('==', 1);

        $criteria->sort('order', EMongoCriteria::SORT_DESC);

        $cursor = Recharge::model()->findAll($criteria);
        $rows = CommonFn::getRows($cursor);
        $model = new Recharge();
        $res = $model->parse($rows);
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$res);
    }
}