测试

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

@@ -15,21 +15,25 @@ class  RechargeController extends O2oBaseController{
 
         $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-16")->format('U')) {
                  $user = RUser::model()->get(new MongoId($order['user']));
-                 var_dump($user);
-                 $num = intval(ceil((rand(100000, 999999))) / 10000);
-                 $data = '{
-                    "touser": "' . $user->wx_pub_openid . '",
-                    "msgtype": "text",
-                    "text": {
-                    "content": "' . '恭喜您获得参与本次活动的权利,' . $num . '为您参加本活动的号码,' . '"
-                    }
-                }';
-
+                 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));
              }
         }