edi

act/lib/Num.php

@@ -48,7 +48,7 @@ class Num
         return $data;
     }
 
-    public function submit($id, $uid = false, $num = false)
+    public function submit($id, $uid = false, $num = false, $update = true)
     {
         $where['uid'] = $uid;
         $where['journal_id'] = $id;
@@ -59,9 +59,11 @@ class Num
             $where['num'] = $num;
             $db->insert($where);
         } else {
-            $where['where_id'] = $info['id'];
-            $where['num'] = $info['num'] + $num;
-            $db->update($where);
+            if ($update) {
+                $where['where_id'] = $info['id'];
+                $where['num'] = $info['num'] + $num;
+                $db->update($where);
+            }
         }
 
         return true;

main/lib/Cron.php

@@ -39,6 +39,55 @@ class Cron
 
         return 'ok';
     }
+
+    public function buy_num_api()
+    {
+        # 根据订单的buy_id来确定生成的本数
+        $id = Dever::input('product_id', 26);
+        $where['product_id'] = $id;
+        $where['status'] = 2;
+        //$where['score_status'] = 1;
+        $order_id = Dever::input('order_id');
+        if ($order_id) {
+            $where['order_id'] = $order_id;
+        }
+        $uid = Dever::input('uid');
+        if ($uid) {
+            $where['uid'] = $uid;
+        }
+        $order = Dever::db('act/order')->state($where);
+        $test = Dever::input('test');
+        if ($test == 1) {
+            print_r($order);die;
+        }
+        if ($order) {
+            $db = Dever::load('act/lib/num');
+            $user = array();
+            foreach ($order as $k => $v) {
+                if ($v['type'] == 1 || $v['type'] == 3) {
+                    if ($v['buy_id'] > 0) {
+                        $num = Dever::db('journal/buy_num')->one($v['buy_id']);
+                        if ($num) {
+                            if (isset($user[$v['uid']]) && $user[$v['uid']]) {
+                                $user[$v['uid']]['num'] += $num['num'];
+                            } else {
+                                $user[$v['uid']] = array();
+                                $user[$v['uid']]['uid'] = $v['uid'];
+                                $user[$v['uid']]['id'] = $v['product_id'];
+                                $user[$v['uid']]['num'] = $num['num'];
+                            }
+                        }
+                    }
+                }
+            }
+
+            foreach ($user as $k => $v) {
+                $db->submit($v['id'], $v['uid'], $v['num'], false);
+            }
+        }
+
+        return 'ok';
+    }
     # 增加积分
     public function scores2_api()
     {