1

server/game2006service/tasks/feeback.js

@@ -26,18 +26,87 @@ class FeeBack {
       }
       {
         const {err, rows} = await conn.execQuery(
-          'SELECT * FROM t_transaction_prefee WHERE createtime < ?',
+          'SELECT * FROM t_transaction_prefee WHERE done = 0 AND createtime < ?',
           [
-            nowTime - 3600 * 24 - 3600 * 12
+            nowTime - 3600 * 24 - 3600 * 6
           ]
         );
-        console.log(rows);
+        await utils.serial(
+          rows,
+          async (element) {
+            await this.procBack(conn, element);
+          }
+        );
       }
     } catch (err) {
       console.log(err);
     }
   }
 
+  async procBack(conn, row) {
+    if (row['item_uniid']) {
+      conn.update(
+        't_bag',
+        [
+          ['account_id', row['account_id']],
+          ['idx', row['item_uniid']],
+        ],
+        [
+          ['!item_num',
+           () => {
+             return 'item_num + ' + row['item_num']
+           }],
+        ]
+      );
+    } else {
+      switch (Number(row['item_id'])) {
+      case 666:
+        {
+
+        }
+        break;
+      case 10001:
+        {
+          //gold
+          conn.update(
+            't_user',
+            [
+              ['account_id', row['account_id']],
+            ],
+            [
+              ['!gold',
+               () => {
+                 return 'gold + ' + row['item_num']
+               }],
+            ]
+          );
+        }
+        break;
+      case 10002:
+        {
+          //diamond
+          conn.update(
+            't_user',
+            [
+              ['account_id', row['account_id']],
+            ],
+            [
+              ['!diamond',
+               () => {
+                 return 'diamond + ' + row['diamond']
+               }],
+            ]
+          );
+        }
+        break;
+      default:
+        {
+
+        }
+      }
+    }
+  }
+
 }
 
 function init() {