getpetuserwork

www/protected/commands/getPetUserWorkCommand.php

@@ -0,0 +1,72 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: PHP
+ * Date: 2016/11/9
+ * Time: 15:31
+ */
+class GetPetUserWorkCommand extends CConsoleCommand{
+    public function run($args) {
+        error_reporting(E_ERROR);
+        ini_set('memory_limit', '256M');
+        //ini_set('mongo.long_as_object',1);
+
+        set_time_limit(0);
+        $this->getPetUser();
+
+    }
+
+    public function getPetUser(){
+
+        $m = new MongoClient(DB_CONNETC);
+        $collection = $m->selectCollection('cute','pet_user');
+        $cursor = $collection->find();
+        $cursor->sort(array('id' => -1));
+        $index = $cursor->getNext()['id'];
+        if (empty($index)){
+            $index = 1;
+        }
+        $start_time = time();
+        var_dump($start_time);
+        $collection->remove(array('id' => $index));
+        while($index) {
+            $res = CommonFn::simple_http('http://pet.appcute.im/api/user/get?id=' . $index++);
+            $d = json_decode($res, true);
+            $end_time = time();
+            if ($d['error'] == 10000) {
+                $data = $d['data'];
+                if (!$collection->find(array('id' => $data['id']))) {
+                    foreach($data['photos'] as $key => $value) {
+                        $data['photos'][$key] = $value;
+                    }
+                    foreach ($data['contact'] as $key => $value) {
+                        $data['contact'][$key] = $value;
+                    }
+                    foreach ($data['services'] as $key => $value) {
+                        $data['services'][$key] = $value;
+                    }
+                    foreach ($data['posts'] as $key => $value) {
+                        $data['posts'][$key] = $value;
+                    }
+                    foreach ($data['area'] as $key => $value) {
+                        if (is_array($data['area'][$key])){
+                            foreach($data['area'][$key] as $k => $v) {
+                                $data['area'][$key][$k] = $v;
+                            }
+                        } else {
+                            $data['area'][$key] = $value;
+                        }
+
+                    }
+                    $collection->insert($data);
+                }
+            }
+            if ($end_time  >= $start_time+60*1){
+                $collection->insert(array('id' => $index));
+                die();
+            }
+
+        }
+    }
+
+}

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

@@ -30,58 +30,7 @@ class  OrderController extends O2oBaseController{
                 //CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
             //}
         }
-        //双十一活动暂用  start 判断用户是否购买过  58227d2ba84ea0c17e8b45b2
-        $doubleEleventId = '582487169f5160d0048b4fe7';
-        $flag_book = 0;
-        if($products[0]['product_id'] == $doubleEleventId) {
-            $criteria_user = new EMongoCriteria();
-            $criteria_user->user('==', new MongoId($user_id));
-            $criteria_user->addCond('products.product', '==', new MongoId($doubleEleventId));//双十一产品id
-            //$criteria_user->addCond('status','==',1);
-            $order = ROrder::model()->findAll($criteria_user);
-            $o = CommonFn::getRowsFromCursor($order);
-           foreach($o as $value){
-                if ($value['status'] == 0 || $value['status'] == -1){
-                    $t = ROrder::model()->get($value['_id']);
-                    $t->delete();
-                } else {
-                    CommonFn::requestAjax(false, '对不起，双十一活动只能抢购一单，你已经抢购过');
-                }
-            }
-
-            //取出双十一活动暂用
-            $criteria_time = new EMongoCriteria();
-            $criteria_time->addCond('products.product', '==', new MongoId($doubleEleventId));
-            $cursor_time = ROrder::model()->findAll($criteria_time);
-            $rows = array();
-            if(!empty($cursor_time)) {
-                $rows = CommonFn::getRowsFromCursor($cursor_time);
-            }
-            $y = date("Y");
-            $m = date("m");
-            $d = date("d");
-            $day_start = mktime(0, 0, 0, $m, $d, $y);
-            $day_end = mktime(23, 59, 59, $m, $d, $y);
-            $total = 0;
-            if ($rows) {
-                foreach ($rows as $orders) {
-                    //判断订单是否达到111单
-                    if ($total >= 111) {
-                        CommonFn::requestAjax(false, '今天的双11订单已经抢购光了');
 
-                    }
-
-                    //判断是否是当天订单
-                    if ($orders['order_time'] >= $day_start && $orders['order_time'] <= $day_end) {
-                        $total += 1;
-                    }
-                }
-            }
-
-            $flag_book = 1;
-        }
-
-        //end
         if(!$user_id||!$products||!$address_id){
             CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
         }
@@ -192,11 +141,7 @@ class  OrderController extends O2oBaseController{
         }
         $order = new ROrder();
         $order->order_time = time();
-        if ($flag_book) {
-            $order->booking_time = time();
-        } else {
-            $order->booking_time = strtotime($booking_time);
-        }
+        $order->booking_time = strtotime($booking_time);
         $order->products = $product_list;
         $order->precedence = $precedence;
         $order->price = $price;