denet-node-server/model/db/remote_config_db.js

const mysql = require("./mysql_db")
const logger = require('../logger')
var { db_config } = require('../../config/config.js')
const utils = require('../utils.js')


/**
 * 是否暂停归集动作
 */
async function isPause(type) {
    var sql = 'select * from remote_config WHERE type=? '
    var par = [type]
    logger.info('isPause', sql, par)
    return new Promise((resolve) => {
        mysql.getMySqlInstance().getConnection(function (err, connection) {
            if (err) {
                logger.error('isPause', err)
                logger.error('isPause', sql)
                resolve(null);
                return;
            }
            connection.query(
                sql, par,
                function selectCb(error, results) {
                    if (error) {
                        logger.error('isPause', error, sql, par)
                        resolve(1);
                        return;
                    }
                    logger.log('isPause ret=', error, results);
                    //用完当前连接需要释放,归还给连接池
                    connection.release();
                    if (results && Array.isArray(results) && results.length > 0) {
                        resolve(results[0].pause);
                    } else {
                        resolve(1);
                    }
                }
            );
        })
    })
}

/**
 * 是否使用 moralis sdk 
 */
async function isUseMoralisSDK() {
    var sql = 'select * from remote_config WHERE type=? '
    var par = ['use_moralis_sdk']
    logger.info('isUseMoralisSDK', sql, par)
    return new Promise((resolve) => {
        mysql.getMySqlInstance().getConnection(function (err, connection) {
            if (err) {
                logger.error('isUseMoralisSDK', err)
                logger.error('isUseMoralisSDK', sql)
                resolve(null);
                return;
            }
            connection.query(
                sql, par,
                function selectCb(error, results) {
                    if (error) {
                        logger.error('isUseMoralisSDK', error, sql, par)
                        resolve(1);
                        return;
                    }
                    logger.log('isUseMoralisSDK ret=', error, results);
                    //用完当前连接需要释放,归还给连接池
                    connection.release();
                    if (results && Array.isArray(results) && results.length > 0) {
                        resolve(results[0].pause == 0);
                    } else {
                        resolve(true);
                    }
                }
            );
        })
    })
}


/**
 * 是否暂停归集动作
 */
async function tokenCollectCoinsBlacklistExist(type, chain, token_address) {
    var sql = 'select * from blacklist WHERE type=? AND address=? AND status=1 AND chain=? '
    switch (chain) {
        case 'bsc_testnet':
        case 'bsc_mainnet':
        case 'bsc testnet':
        case 'bsc mainnet':
            chain = 'bsc'
            break
        case 'czz':
        case 'CZZ':
            chain = 'czz'
            break
    }
    var par = [type, token_address, chain]
    logger.info('getTokenCollectCoinsBlacklist', sql, par)
    return new Promise((resolve) => {
        mysql.getMySqlInstance().getConnection(function (err, connection) {
            if (err) {
                logger.error('getTokenCollectCoinsBlacklist', err)
                logger.error('getTokenCollectCoinsBlacklist', sql)
                resolve(null);
                return;
            }
            connection.query(
                sql, par,
                function selectCb(error, results) {
                    if (error) {
                        logger.error('getTokenCollectCoinsBlacklist', error, sql, par)
                        resolve(null);
                        return;
                    }
                    logger.log('getTokenCollectCoinsBlacklist ret=', error, results);
                    //用完当前连接需要释放,归还给连接池
                    connection.release();
                    if (results && Array.isArray(results) && results.length > 0) {
                        resolve(true);
                    } else {
                        resolve(null);
                    }
                }
            );
        })
    })
}

/**
 * 过滤某些地址归集
 * collect_coins
 */
async function isBlackList(type, chain, address) {
    var sql = 'select * from blacklist WHERE type=? AND address=? AND status=1 AND chain=? '
    switch (chain) {
        case 'bsc_testnet':
        case 'bsc_mainnet':
            chain = 'bsc'
            break
        case 'czz':
        case 'CZZ':
            chain = 'czz'
            break
    }
    var par = [type, address, chain]
    logger.info('isBlackList', sql, par)
    return new Promise((resolve) => {
        mysql.getMySqlInstance().getConnection(function (err, connection) {
            if (err) {
                logger.error('isBlackList', err)
                logger.error('isBlackList', sql)
                resolve(null);
                return;
            }
            connection.query(
                sql, par,
                function selectCb(error, results) {
                    if (error) {
                        logger.error('isBlackList', error, sql, par)
                        resolve(null);
                        return;
                    }
                    logger.log('isBlackList ret=', error, results);
                    //用完当前连接需要释放,归还给连接池
                    connection.release();
                    if (results && Array.isArray(results) && results.length > 0) {
                        resolve(1);
                    } else {
                        resolve(0);
                    }
                }
            );
        })
    })
}



async function getForceAddTokenLists(chain) {
    var sql = 'select * from force_token_list WHERE chain=? '
    var par = [chain]
    logger.info('getForceAddTokenLists', sql, par)
    return new Promise((resolve) => {
        mysql.getMySqlInstance().getConnection(function (err, connection) {
            if (err) {
                logger.error('getForceAddTokenLists', err)
                logger.error('getForceAddTokenLists', sql)
                resolve(null);
                return;
            }
            connection.query(
                sql, par,
                function selectCb(error, results) {
                    if (error) {
                        logger.error('getForceAddTokenLists', error, sql, par)
                        resolve(null);
                        return;
                    }
                    logger.log('getForceAddTokenLists ret=', error, results);
                    //用完当前连接需要释放,归还给连接池
                    connection.release();
                    if (results && Array.isArray(results) && results.length > 0) {
                        resolve(results);
                    } else {
                        resolve(null);
                    }
                }
            );
        })
    })
}


module.exports = {
    isPause,
    isBlackList,
    isUseMoralisSDK,
    getForceAddTokenLists,
    tokenCollectCoinsBlacklistExist,
}