diff --git a/server/game2006service/tasks/feeback.js b/server/game2006service/tasks/feeback.js index cb0bab2f..84d6f2ba 100644 --- a/server/game2006service/tasks/feeback.js +++ b/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() {