归集加上response

model/db/collect_coins_db.js

@@ -19,15 +19,17 @@ async function create_collect_coins_task(opts) {
 
     var status = opts.status
 
+    var resposes = opts.collects ? opts.collects : ''
+
     var error_msg = opts.errMsg ? opts.errMsg : ''
 
     var create_time = utils.getCurrentDate()
 
     var update_time = utils.getCurrentDate()
 
-    var create_withdraw_sql = 'INSERT INTO collect_coins_manage (balances,transfers,prestore_gas_fee,company_public_key,total_gas_fee,status,create_time,update_time,error_msg)' +
+    var create_withdraw_sql = 'INSERT INTO collect_coins_manage (balances,transfers,prestore_gas_fee,company_public_key,total_gas_fee,status,create_time,update_time,resposes,error_msg)' +
         'VALUES(?,?,?,?,?,?,?,?,?)'
-    var create_withdraw_params = [JSON.stringify(balances), JSON.stringify(transfers), JSON.stringify(prestore_gas_free), company_public_key, total_gas_fee, status, create_time, update_time, error_msg ? error_msg : '']
+    var create_withdraw_params = [JSON.stringify(balances), JSON.stringify(transfers), JSON.stringify(prestore_gas_free), company_public_key, total_gas_fee, status, create_time, update_time,resposes,error_msg ? error_msg : '']
 
     logger.log('create_collect_coins_task create_collect_coins_task_sql', create_withdraw_sql, create_withdraw_params);
     return new Promise((resolve) => {

model/moralis_sdk.js

@@ -496,6 +496,7 @@ async function transfers(obj, my_account_all_coins, logParams) {
         }
         //日志埋点-归集全部所花费的 gas 费用
         logParams.collectCoinsTotalGasFee = totalGasFee.toString();
+        logParams.collects = JSON.stringify(collects)
         if (t_i == my_account_all_coins.transfer_arrays.length) {
             logger.log('归集日志上报：', logParams);
             logParams.type = report.REPORT_TYPE.collect_coins