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

<?php
/**
 * OrderController o2o下单相关接口
 *
 * @author leeon<leeon_on@qq.com>
 *
 */
class  OrderController extends O2oBaseController{

    public function actionAdd(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $products = json_decode(Yii::app()->getRequest()->getParam("products","[]"),true);
        $memo = Yii::app()->getRequest()->getParam("memo","");
        $booking_time = Yii::app()->getRequest()->getParam("booking_time",'');
        $precedence = intval(Yii::app()->getRequest()->getParam("precedence",0));
        $coupons = json_decode(Yii::app()->getRequest()->getParam("coupons","[]"),true);
        $address_id = Yii::app()->getRequest()->getParam("address_id");
        $tech_id = Yii::app()->getRequest()->getParam("tech_id");
        $station = Yii::app()->getRequest()->getParam("station");
        $order_channel = Yii::app()->getRequest()->getParam("order_channel");

        CommonFn::requestAjax(false,'系统升级中，暂时不能下单');
        
        if(!$precedence){
            $booking_check  = strtotime($booking_time);
            $verity_check = $booking_check - time();
            if($verity_check < 13800){
                CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
            }
        }
        if(!$user_id||!$products||!$address_id){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = CommonFn::apigetObJ($user_id,'ZUser',CommonFn::getMessage('user','id_not_exist'),array(),201);
        $address_list = $user_obj->shop_address?$user_obj->shop_address:array();
        $address = array();
        foreach ($address_list as $value) {
            if($address_id == $value['address_id']){
                $address = $value;
            }
        }
        if(!$address){
            file_put_contents('/data/erroraddressc.log',var_export($address,true),FILE_APPEND);
            CommonFn::requestAjax(false,CommonFn::getMessage('shop','address_false'));
        }else{
            if($station){
                $station = Station::get(new MongoId($station));
                if(!$station){
                    file_put_contents('/data/erroraddressa.log',var_export($address,true),FILE_APPEND);
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','address_cannot_service'));
                }
                $divide_station = $station->_id;
            }else{
                file_put_contents('/data/erroraddressb.log',var_export($address,true),FILE_APPEND);
                CommonFn::requestAjax(false,CommonFn::getMessage('o2o','address_cannot_service'));
            }
            $o2o_address['name'] = $address['name'];
            $o2o_address['mobile'] = $address['mobile'];
            $o2o_address['province'] = $address['address']['province'];
            $o2o_address['city'] = $address['address']['city'];
            $o2o_address['area'] = $address['address']['area'];
            $o2o_address['detail'] = $address['address']['detail'];
            $o2o_address['position'] = isset($address['position'])?$address['position']:array(0,0);
            $o2o_address['poi'] = isset($address['address']['poi'])?$address['address']['poi']:array();
        }
        $product_list = array();
        $price = 0;
        $service_type = 0;
        foreach ($products as $product) {
            if(isset($product['product_id']) && $product['count'] >= 1){
                $product_temp = array();
                $product_obj = Product::get(new MongoId($product['product_id']));
                if($product_obj){
                    $price += ($product_obj->price*$product['count']);
                    $product_temp['product'] = $product_obj->_id;
                    $product_temp['count'] = $product['count'];
                    $product_list[] = $product_temp;
                    if($product_obj->is_extra == 0){
                        $service_type = $product_obj->type;
                    }
                }else{
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_not_exist'));
                }
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_illegal'));
            }
        }
        if($precedence){
            $price += 40;
        }
        $final_price = $price;
        $used_coupon = array();
        foreach ($coupons as $coupon){
            $user_coupon = UserCoupon::get(new MongoId($coupon));
            $current_time = time();
            if($user_coupon && (string)$user_coupon->user == $user_id && $user_coupon->start_time < $current_time && $user_coupon->end_time > $current_time && $user_coupon->status == 1){
                $coupon = Coupon::get($user_coupon->coupon);
                //判断优惠券可用时间
                $weekend_check = (date('w',strtotime($booking_time))==0 || date('w',strtotime($booking_time))==6)?1:0;
                $booking_hour = date('H',strtotime($booking_time));
                if($weekend_check){
                    if($coupon->workday_limit==1){
                        CommonFn::requestAjax(false,CommonFn::getMessage('o2o','coupon_unuseable'));
                    }
                }else{
                    if($coupon->workday_limit==2){
                        CommonFn::requestAjax(false,CommonFn::getMessage('o2o','coupon_unuseable'));
                    }
                }
                if($coupon->time_limit_start && $coupon->time_limit_end && ($coupon->time_limit_start > $booking_hour || $coupon->time_limit_end < $booking_hour)){
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','coupon_unuseable'));
                }

                $new_user_coupons = Yii::app()->params['new_user_coupons'];
                if(($coupon->type == 0 || $coupon->type == $service_type ) && $coupon->status==1 && $coupon->min_price <= $final_price){
                    $final_price = $final_price-$coupon->value>=0?$final_price-$coupon->value:0; 
                    $used_coupon[] = $user_coupon->_id; 
                    $user_coupon->status = -1;
                    $user_coupon->use_time = time();
                    $user_coupon->update(array('status','use_time'),true);
                }else{
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','coupon_unuseable'));
                }
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('o2o','coupon_unuseable'));
            }
        }
        $order = new ROrder();
        $order->order_time = time();
        $order->booking_time = strtotime($booking_time);
        $order->products = $product_list;
        $order->precedence = $precedence;
        $order->price = $price;
        $order->channel = $order_channel;
        $order->final_price = ceil($final_price*100)/100;
        $order->address = $o2o_address;
        $order->memo = $memo;
        $order->station = $divide_station;
        $order->coupons = $used_coupon;
        if(isset($user_coupon->coupon)){
            $order->coupon_type = $user_coupon->coupon;
        }
        if($order->final_price == 0){
            $order->status = 1;
        }else{
            $order->status = 0;
        }
        $order->user = $user_obj->_id;
        $order->type = $service_type;
        $order->technician = intval($tech_id);
        if($order->save()){
            $data = ROrder::model()->parseRow($order);
            foreach ($products as $product) {
                if(isset($product['product_id']) && $product['count'] >= 1){
                    $product_obj = Product::get(new MongoId($product['product_id']));
                    if($product_obj){
                        $product_obj->sale_count+=$product['count'];
                        $product_obj->update(array('sale_count'),true);
                    }
                }
            }
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
        }
    }

    public function actionList(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $type = Yii::app()->getRequest()->getParam("type");
        $order_type = Yii::app()->getRequest()->getParam("order_type");
        if(!$order_type){
            $order_type = $type;
        }
        $user_obj = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        $pagesize = Yii::app()->params['ROrderListPageSize'];
        if($order_type == 1 ){
            $conditions = array(
                                'user'=>array('==',$user_obj->_id),
                                'status'=>array('notin',array(-3,-2,-1,6,7))
                            );
        }elseif ($order_type == 2) {
            $conditions = array(
                                'user'=>array('==',$user_obj->_id),
                                'status'=>array('in',array(-3,-2,-1,7))
                            );
        }elseif($order_type == 3){
            $conditions = array(
                                'user'=>array('==',$user_obj->_id),
                                'status'=>array('==',6)
                            );
        }else{
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $order = array(
                        'booking_time'=>'desc'
                        );
        $model = new ROrder();
        $pagedata = CommonFn::getPagedata($model,$page,$pagesize,$conditions,$order);
        $order_list = $pagedata['res'];
        foreach ($order_list as $key => $value) {
            $order_list[$key] = $model->output($value);
        }
        $data = array_values($order_list);
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page']));
    }

    public function actionPay(){
        $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 = ROrder::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));
        }
        foreach ($order->products as $value) {
            if(isset($value['product'])){
                $product = Product::get($value['product']);
            }
            if($product){
                break;
            }
        }
        if(isset($product)&&$product){
            switch ($product->type) {
                case 1:
                    $str = '宠物洗澡';
                    break;
                case 2:
                    $str = '宠物剪毛';
                    break;
                case 3:
                    $str = '宠物美容';
                    break;
                default:
                    $str = '宠物洗澡';
                    break;
            }
        }
        $str = isset($str)?$str:'上门';
        $amount = ceil($order->final_price*1000)/10;
        $result = Service::factory('PayService')->Pay($pay_channel,$amount,(string)$order->_id,$str,$str,$user_obj->wx_pub_openid);
        if($result === false){
            CommonFn::requestAjax(false,'支付遇到点问题了，请稍候再试');
        }else{
            // 支付成功后用户有效订单数增加
            if (isset($user_obj->order_count)) {
                $user_obj->order_count += 1;
            } else {
                $user_obj->order_count = 1;
            }
            $user_obj->save();
            CommonFn::requestAjax(true,'success',json_decode($result),200,array('booking_time'=>$order->booking_time));
        }
    }

    public function actionDel(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        if(!$user_id || !$order_id || !CommonFn::isMongoId($order_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::get(new MongoId($order_id));
        $status = -1;
        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->status != 0){
            CommonFn::requestAjax(false,'此订单暂不支持取消');
        }
        if( $order->status!=-1 && $order->status!=-2 ){
            foreach ($order->coupons as $user_coupon) {
                $user_coupon = UserCoupon::get($user_coupon);
                $user_coupon->status = 1;
                $user_coupon->update(array('status'),true);
            }
        }
        // 触宝信息更新
        $from = Yii::app()->request->getParam('from', '');
        if ($from == 'chubao') {
            $chubaoConfig = Yii::app()->params['chubao'];
            $chubao = new Chubao();
            $client = $chubao->getClient();
            $orderPush = $chubao->getOrderPush();
            $userId = $user_obj->name;

            $product_list = $order->products;
            $product_id = $product_list[0]['product'];
            $product = Product::get($product_id);
            $o2o_service = Yii::app()->params['o2o_service'];
            $shortInfo = $o2o_service[$product->type]['name'];

            $orderPush->setUserId($userId);
            $orderPush->setOrderId($order_id);
            $orderPush->setOrderService($chubaoConfig['service']);
            $orderPush->setTitle('壹管家宠物');
            $orderPush->setShortInfo('壹管家上门服务-'.$shortInfo);
            $orderPush->setOrderStatus('订单已取消');
            $orderPush->setCreateTime(date('YmdHis', $order->order_time));
            $orderPush->setFinishTime('');
            $orderPush->setOrderUrl($chubaoConfig['orderUrl'].'/'.$order_id);
            $orderPush->setTradeStatus('TRADE_CLOSED');

            $response = $client->execute($orderPush);

            if ($response['result'] == 'FAIL') {
                CommonFn::requestAjax(false, '订单取消失败，请稍后重试');
            }
        }
        $order->status = $status;
        $arr_order = array('status');
        $success = $order->update($arr_order,true);
        if($success){
            $order_info = $order->parseRow($order);
        }
        CommonFn::requestAjax($success, '');
       
    }

    public function actionUsableCoupon(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $get_all = Yii::app()->getRequest()->getParam("get_all");
        $type = Yii::app()->getRequest()->getParam("type");
        $booking_time = Yii::app()->getRequest()->getParam("booking_time");
        if($booking_time){
            $booking_time = strtotime($booking_time);
            $weekend_check = (date('w',$booking_time)==0||date('w',$booking_time)==6)?1:0;
            $booking_hour = date('H',$booking_time);
        }
        $device_id = Yii::app()->getRequest()->getParam("device_id",'');
        $products = json_decode(Yii::app()->getRequest()->getParam("products",'[]'),true);
        if(!CommonFn::isMongoId($user_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        
        $UserCoupon = new UserCoupon();
        if($get_all){
            $criteria = new EMongoCriteria();
            $criteria->user('==',new MongoId($user_id));
            $current_time = time();
            $criteria->end_time('>=',$current_time);
            $criteria->status('==',1);
            $coupons = UserCoupon::model()->findAll($criteria);
            $coupon_list = array(); 
            $coupon_list['useable_coupons'] = array(); 
            foreach ($coupons as $value) {
                $coupon = Coupon::get($value->coupon);
                if($coupon->status!=1){
                    continue;
                }
                $coupon_list['useable_coupons'][] = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
            }
            if(count($coupon_list['useable_coupons']) <= 15){
                $criteria = new EMongoCriteria();
                $criteria->user('==',new MongoId($user_id));
                $criteria->status('==',-1);
                $coupons = UserCoupon::model()->findAll($criteria);
                $coupon_list['used_coupons'] = array();
                foreach ($coupons as $value) {
                    $coupon = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
                    $coupon['unuseable_reason'] = '已使用';
                    $coupon_list['used_coupons'][] = $coupon;
                }
                $criteria = new EMongoCriteria();
                $criteria->user('==',new MongoId($user_id));
                $current_time = time();
                $criteria->end_time('<',$current_time);
                $coupons = UserCoupon::model()->findAll($criteria);
                $coupon_list['overtime_coupons'] = array();
                foreach ($coupons as $value) {
                    $coupon = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
                    $coupon['unuseable_reason'] = '已过期';
                    $coupon_list['overtime_coupons'][] = $coupon;
                }
            }else{
                $coupon_list['used_coupons'] = array();
                $coupon_list['overtime_coupons'] = array();
            }
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$coupon_list);
        }
        $price = 0;
        if($products){
            foreach ($products as $product) {
                if(isset($product['product_id']) && $product['count'] >= 1){
                    $product_temp = array();
                    $product_obj = Product::get(new MongoId($product['product_id']));
                    if($product_obj){
                        $price += ($product_obj->price*$product['count']);
                    }else{
                        CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_not_exist'));
                    }
                }else{
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_illegal'));
                }
            }
        }
  
        $criteria = new EMongoCriteria();
        $criteria->user('==',new MongoId($user_id));
        $current_time = time();
        $criteria->start_time('<=',$current_time);
        $criteria->end_time('>=',$current_time);
        $criteria->status('==',1);
        $coupons = UserCoupon::model()->findAll($criteria);
        $coupon_list = array(); 
        $unuseable_coupons = array();
        foreach ($coupons as $value) {
            $coupon = Coupon::get($value->coupon);
            if($coupon->status!=1){
                continue;
            }
            if($coupon->min_price>$price || ($type && $coupon->type != $type && $coupon->type != 0)){
                continue;
            }
            if($booking_time){
                if($weekend_check){
                    if($coupon->workday_limit==1){
                        $unuseable_coupons[] = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
                        continue;
                    }
                }else{
                    if($coupon->workday_limit==2){
                        $unuseable_coupons[] = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
                        continue;
                    }
                }
                if($coupon->time_limit_start && $coupon->time_limit_end && ($coupon->time_limit_start > $booking_hour || $coupon->time_limit_end < $booking_hour)){
                    $unuseable_coupons[] = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
                    continue;
                }
            }
            $coupon_list[] = $UserCoupon->parseRow($value,array('id','start_time','end_time','start_time_str','end_time_str','coupon'));
        }
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$coupon_list,200,array('unuseable_coupons' => $unuseable_coupons));
    }

    public function actionCheckAddress(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $address_id = Yii::app()->getRequest()->getParam("address_id");
        $user_obj = CommonFn::apigetObJ($user_id,'ZUser',CommonFn::getMessage('user','id_not_exist'),array(),201);
        $address_list = $user_obj->shop_address?$user_obj->shop_address:array();
        $address = array();
        foreach ($address_list as $value) {
            if($address_id == $value['address_id']){
                $address = $value;
            }
        }
        if(!$address){
            file_put_contents('/data/erroraddress_user.log',var_export($user_id,true),FILE_APPEND);
            CommonFn::requestAjax(false,CommonFn::getMessage('shop','address_false'));
        }else{
            if(isset($address['address']['province']) && ($address['address']['province'] == '上海市' || $address['address']['province'] == '')){
                CommonFn::requestAjax(true,'success',array('station' => '5548b05e0eb9fbc5728b51ea'));
            }else{
                file_put_contents('/data/erroraddress.log',var_export($address,true),FILE_APPEND);
                CommonFn::requestAjax(false,CommonFn::getMessage('o2o','address_cannot_service'));
            }
        }
    }

    public function actionAppend(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        $products = json_decode(Yii::app()->getRequest()->getParam("products","[]"),true);
        if(!$user_id || !$products || !$order_id || !CommonFn::isMongoId($order_id) || !CommonFn::isMongoId($user_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::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'));
        }
        $product_list = array();
        $price = 0;
        foreach ($products as $product) {
            if(isset($product['product_id']) && $product['count'] >= 1){
                $product_temp = array();
                $product_obj = Product::get(new MongoId($product['product_id']));
                if($product_obj){
                    $price += ($product_obj->price*$product['count']);
                    $product_temp['product'] = $product_obj->_id;
                    $product_temp['count'] = $product['count'];
                    $product_list[] = $product_temp;
                    if($product_obj->is_extra != 1){
                        CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_illegal'));
                    }
                }else{
                    CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_not_exist'));
                }
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('o2o','product_illegal'));
            }
        }
        $append_product = new AppendOrder();
        $append_product->order = $order->_id;
        $append_product->products = $product_list;
        $append_product->price = $price;
        $append_product->append_time = time();
        $success = $append_product->save();
        if($success){
            $order->append_orders[] =  $append_product->_id;
            $order->update(array('append_orders'),true);
            $list = new ARedisList('append_order_list');
            $list->push((string)$order->_id);
            $append_info = $append_product->parseRow($append_product);
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$append_info);
        }
        CommonFn::requestAjax($success, '');
    }

    public function actionAppendPay(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $pay_channel = Yii::app()->getRequest()->getParam("pay_channel");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        $append_id = Yii::app()->getRequest()->getParam("append_id");
        if(!$user_id || !$pay_channel || !$order_id || !$append_id || !CommonFn::isMongoId($append_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::get(new MongoId($order_id));
        $append_product = AppendOrder::get(new MongoId($append_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($append_product->status == 1){
            CommonFn::requestAjax(false,'此订单已支付过',array('have_pay'=>1));
        }
        $str = '附加服务';
        $amount = ceil($append_product->price*1000)/10;
        $result = Service::factory('PayService')->Pay($pay_channel,$amount,(string)$append_product->_id,$str,$str,$user_obj->wx_pub_openid);
        if($result === false){
            CommonFn::requestAjax(false,'支付遇到点问题了，请稍候再试');
        }else{
            // 追加订单并付款后通知保洁师
            if (!empty($order->technician)) {
                $techObj = TechInfo::get($order->technician);
                if (!empty($techObj) && !empty($techObj->weixin_userid)) {
                    $wechat = O2oApp::getWechatActive();
                    $url_prefix = ENVIRONMENT == 'product' ? 'http://api.wozhua.mobi' : 'http://apitest.wozhua.mobi';
                    $wechat_data = array(
                        'touser'  => $techObj->weixin_userid,
                        'msgtype' => 'news',
                        'agentid' => '24',
                        'news'    => array(
                            'articles' => array(
                                array(
                                    'title' => '壹管家提示-新的追加订单',
                                    'description' => $techObj->name.'你好！预定时间在'.date('m月d日H:i', $order->booking_time).'的订单刚刚被用户追加了新的服务，请点击查看。',
                                    'url' => $url_prefix.'/index.php?r=o2o/myOrder/info&order='.(string)$order->_id.'&user='.$order->technician,
                                ),
                            ),
                        ),
                    );
                    $wechat->sendMessage($wechat_data);
                }
            }
            CommonFn::requestAjax(true,'success',json_decode($result));
        }
    }

    public function actionRetrieve(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        $from = Yii::app()->request->getParam('from', '');
        if(!$user_id || !$order_id ){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::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->status != 1){
            CommonFn::requestAjax(false,'此订单不可申请退款');
        }
        $order->status = -3;
        $order->apply_refund_time = time();

        // 触宝平台更新
        if ($from == 'chubao') {
            $chubao = new Chubao();
            $client = $chubao->getClient();
            $tradeRefund = $chubao->getTradeRefund();
            $chubaoConfig = Yii::app()->params['chubao'];
            $chubao_info = $order->third_platform_info;
            $userId = $user_obj->name;

            $tradeRefund->setUserId($userId);
            $tradeRefund->setNotifyUrl($chubaoConfig['refundCallbackUrl']);
            $tradeRefund->setTransactionId($chubao_info['transactionId']);
            $tradeRefund->setRefundNo($order_id);
            $tradeRefund->setTotalFee($order->final_price * 100);
            $tradeRefund->setCashFee($order->final_price * 100);
            $tradeRefund->setRefundFee($order->final_price * 100);
            $response = $client->execute($tradeRefund);
            
            $refundStatus = $response['refundStatus'];
            if ($refundStatus == 'REFUND_FAIL') {
                CommonFn::requestAjax(false, '申请退款失败');
            }

            $chubao_info['redundId'] = $response['refundId'];
            $order->third_platform_info = $chubao_info;
            $order->save(true, array('third_platform_info'));
        }

        if($order->update(array('status','apply_refund_time'),true)){
            // 发送通知给保洁师
            if (!empty($order->technician)) {
                $techObj = TechInfo::get($order->technician);
                if (!empty($techObj) && !empty($techObj->weixin_userid)) {
                    $wechat = O2oApp::getWechatActive();
                    $url_prefix = ENVIRONMENT == 'product' ? 'http://api.wozhua.mobi' : 'http://apitest.wozhua.mobi';
                    $wechat_data = array(
                        'touser'  => $techObj->weixin_userid,
                        'msgtype' => 'news',
                        'agentid' => '24',
                        'news'    => array(
                            'articles' => array(
                                array(
                                    'title' => '壹管家提示-申请退款',
                                    'description' => $techObj->name.'你好！预定时间在'.date('m月d日H:i', $order->booking_time).'的订单刚刚已被用户申请退款，请点击查看。',
                                    'url' => $url_prefix.'/index.php?r=o2o/myOrder/info&order='.$order_id.'&user='.$order->technician,
                                ),
                            ),
                        ),
                    );
                    $wechat->sendMessage($wechat_data);
                }
            }
            CommonFn::requestAjax(true,'申请退款成功，请等待确认');
        }else{
            CommonFn::requestAjax(false,'请稍后再试');
        }
    }

    public function actionConfirmComplete(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        $from = Yii::app()->request->getParam('from', '');
        if(!$user_id || !$order_id ){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::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(!in_array($order->status, array(1,2,3,4,5))){
            CommonFn::requestAjax(false,'此订单不支持修改状态');
        }
        $order->status = 6;
        $order->finish_time = time();
        // 触宝信息更新
        if ($from == 'chubao') {
            $chubaoConfig = Yii::app()->params['chubao'];
            $chubao = new Chubao();
            $client = $chubao->getClient();
            $orderPush = $chubao->getOrderPush();
            $userId = $user_obj->name;

            $orderPush->setUserId($userId);
            $orderPush->setOrderId($order_id);
            $orderPush->setOrderService($chubaoConfig['service']);
            $orderPush->setTitle('壹管家宠物');

            $product_list = $order->products;
            $product_id = $product_list[0]['product'];
            $product = Product::get($product_id);
            $o2o_service = Yii::app()->params['o2o_service'];
            $shortInfo = $o2o_service[$product->type]['name'];
            $orderPush->setOrderShortInfo('壹管家上门服务-'.$shortInfo);
            $orderPush->setOrderStatus('订单已完成');
            $orderPush->setOrderCreateTime(date('YmdHis', $order->order_time));
            $orderPush->setOrderFinishTime(date('YmdHis', time()));
            $orderPush->setOrderUrl($chubaoConfig['orderUrl'].'/'.$order_id);
            $orderPush->setTradeStatus('TRADE_FINISH');

            $response = $client->execute($orderPush);
            if ($response['result'] == 'FAIL') {
                CommonFn::requestAjax(false,'请稍后再试');
            }
            $success = $order->update(array('finish_time','status'),true);
            if ($success) {
                CommonFn::requestAjax(true,'订单已完成，期待您的下次预约');
            } else {
                CommonFn::requestAjax(false,'请稍后再试');
            }
        }

        $success = $order->update(array('finish_time','status'),true);
        if($success && $from != 'chubao'){
            $result = Service::factory('ScoreService')->changeScore($user_id,intval($order->final_price),'下单奖爪币');
            if($result){
                $z_message = new ZMessage();
                $from_user = Yii::app()->params['sys_user'];
                $message_data = array(
                    'from_user' => $from_user,
                    'to_user' => $user_id,
                    'content' => '您成功下单，获得了'.intval($order->final_price).'个爪币的奖励。',
                    'pics' => array(),
                    'voice' => array(),
                    'video'=> array()
                );
                $z_message->addMessage($message_data);
                CommonSMS::send('final_order',array('name' =>$order->address['name'],'num' =>intval($order->final_price),'mobile'=>$order->address['mobile']));
            }

            // 保洁师订单统计
            if ($order->technician) {
                $tech_obj = TechInfo::get($order->technician);
                if ($tech_obj) {
                    $order_count = $tech_obj->order_count + 1;
                    $tech_obj->order_count = $order_count;
                }
            }
            CommonFn::requestAjax(true,'订单已完成，期待您的下次预约');
        }else{
            CommonFn::requestAjax(false,'请稍后再试');
        }
    }

    public function actionDetail(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $order_id = Yii::app()->getRequest()->getParam("order_id");
        if(!$user_id || !$order_id || !CommonFn::isMongoId($order_id) || !CommonFn::isMongoId($user_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_obj = RUser::get(new MongoId($user_id));
        $order = ROrder::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'));
        }
        $order_info = $order->parseRow($order);
        CommonFn::requestAjax(true,'',$order_info);
    }

    //选择保洁师
    public function actionSelectTech(){
        $booking_time = Yii::app()->getRequest()->getParam("booking_time");
        $service_type = json_decode(Yii::app()->getRequest()->getParam("service_type","[]"),true);
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $address_id = Yii::app()->getRequest()->getParam("address_id");
        $user_obj = CommonFn::apigetObJ($user_id,'ZUser',CommonFn::getMessage('user','id_not_exist'),array(),201);
        $address_list = $user_obj->shop_address?$user_obj->shop_address:array();
        $address = array();
        foreach ($address_list as $value) {
            if($address_id == $value['address_id']){
                $address = $value;
            }
        }
        if(strtotime($booking_time) < time()){
            CommonFn::requestAjax(false,'此时间段不可预约');
        }
        if(!$address){
            CommonFn::requestAjax(false,CommonFn::getMessage('shop','address_false'));
        }
        if(!isset($address['position'][0])||$address['position'][0]==0||is_int($address['position'][0])){
            $address_res = CommonFn::simple_http('http://api.map.baidu.com/geocoder/v2/?ak=B349f0b32ef6e78b2e678f45cb9fddaf&address='.$address['address']['area'].$address['address']['detail'].'&city='.$address['address']['city'].'&output=json');
            $address_info = json_decode($address_res,true);
            $position = $address_info['result']['location'];
            $detail_res = CommonFn::simple_http('http://api.map.baidu.com/geocoder/v2/?ak=B349f0b32ef6e78b2e678f45cb9fddaf&location='.$position['lat'].','.$position['lng'].'&output=json&pois=1');
            $detail_info = json_decode($detail_res,true);
            $business = explode(',',$detail_info['result']['business']);
            
        }else{
            $detail_res = CommonFn::simple_http('http://api.map.baidu.com/geocoder/v2/?ak=B349f0b32ef6e78b2e678f45cb9fddaf&location='.$address['position'][1].','.$address['position'][0].'&output=json&pois=1');
            $detail_info = json_decode($detail_res,true);
            $business = explode(',',$detail_info['result']['business']);
        }
        $user_model = new TechInfo();
        $criteria = new EMongoCriteria();
        $criteria->service_type('all', $service_type);
        if( !in_array(9, $service_type) && !in_array(10, $service_type)){
            foreach ($business as $value) {
                $criteria->addCond('business','or',$value);
            }
        }
        $criteria->status('==', 1);
        $cursor = $user_model->findAll($criteria);
        //获取满足服务类型保洁师列表
        $match_service_tech_list = array();
        $tech_list = array();
        foreach ($cursor as $key => $value) {
            $match_service_tech_list[] = $value->_id;
            $tech_list[$value->_id] = $value;
        }
        $parse_time = strtotime(date('Y-m-d H:00',strtotime($booking_time)));
        $FreeTimeRecord = FreeTimeRecord::get($parse_time);
        // $last_parse_time = strtotime(date('Y-m-d H:00',strtotime($booking_time)))-3600;
        // $LastFreeTimeRecord = FreeTimeRecord::get($last_parse_time);
        // $next_parse_time = strtotime(date('Y-m-d H:00',strtotime($booking_time)))-3600;
        // $NextFreeTimeRecord = FreeTimeRecord::get($next_parse_time);
        //获取此时段空闲保洁师列表
        $free_tech_list = array();
        // $last_free_tech_list = array();
        // $next_free_tech_list = array();
        if($FreeTimeRecord){
            $free_tech_list = $FreeTimeRecord->free_technician;
        }
        // if($LastFreeTimeRecord){
        //     $last_free_tech_list = $LastFreeTimeRecord->free_technician;
        // }
        // if($NextFreeTimeRecord){
        //     $next_free_tech_list = $NextFreeTimeRecord->free_technician;
        // }
        //空闲且满足服务能力保洁师，推荐用户选择
        $recommend_tech = array_intersect($match_service_tech_list,$free_tech_list);
        $can_select_tech = array();
        foreach ($recommend_tech as $key => $value) {
            $tech = $tech_list[$value];
            unset($tech_list[$value]);
            $tmp['id'] = $tech->_id;
            $tmp['name'] = $tech->name;
            $tmp['desc'] = $tech->desc;
            $tmp['service_type'] = $tech->service_type;
            $tmp['avatar'] = $tech->avatar;
            $tmp['favourable_count'] = $tech->favourable_count;
            $can_select_tech[] = $tmp;
        }
        //满足服务能力，但此时段不空闲，展示给用户此保洁师下个空闲时段
        $service_match_tech = array();
        foreach ($tech_list as $key => $value) {
            $tmp['id'] = $value->_id;
            $tmp['name'] = $value->name;
            $tmp['desc'] = $value->desc;
            $tmp['service_type'] = $value->service_type;
            $tmp['avatar'] = $value->avatar;
            $tmp['favourable_count'] = $value->favourable_count;
            $criteria = new EMongoCriteria();
            $criteria->free_technician('==', $tmp['id']);
            $criteria->_id('>',time());
            $criteria->limit(1);
            $criteria->sort('_id', EMongoCriteria::SORT_ASC);
            if(FreeTimeRecord::model()->count($criteria)){
                $free_time = FreeTimeRecord::model()->findAll($criteria);
                foreach ($free_time as $next_free_time) {
                    $tmp['next_free_time'] = FreeTimeRecord::parseFreeTime($next_free_time->_id);
                    break;
                }
            }else{
                continue;
            }
            $service_match_tech[] = $tmp;
        }
        $data['can_select_tech'] = $can_select_tech;
        $data['service_match_tech'] = $service_match_tech;
        CommonFn::requestAjax(true,'',$data);
    }

     /**
     * 获取评价列表接口
     */
    public function actionTechComment() {
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        $tech_id = intval(Yii::app()->getRequest()->getParam("tech_id"));
        $pagesize = Yii::app()->params['O2oCommentListPageSize'];
        if(!$tech_id){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $conditions = array(
                            'technician'=>array('==',$tech_id),
                            'status'=>array('==',1),
                        );
        $order = array(
                        'time' => 'desc'
                        );
        $model = new Comment();
        $pagedata = CommonFn::getPagedata($model,$page,$pagesize,$conditions,$order);
        $data['comments'] = $pagedata['res'];
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page']));
    }

}