update

cron/coinAndPairSetting.ts

@@ -4,7 +4,7 @@
 const schedule = require('node-schedule');
 let { logger, datetimeUtils } = require('@madex/ex-js-public');
 
-import { spotPairs, ormDB, coinType } from "@madex/ex-ts-dao";
+import { spotPairs, ormDB, coinType,contractPairs } from "@madex/ex-ts-dao";
 import { getPairFromCore, getCoinFromCore } from '../src/utils/coreSystemUtils'
 
 
@@ -30,9 +30,11 @@ let job = schedule.scheduleJob('*/15 * * * * ?', async function () {
 
     }
 });
+
 const syncPair = async () => {
     let now = new Date();
-    let res = await spotPairs.prototype.findAll({
+    for (const pairModel of [spotPairs,contractPairs]) {
+        let res = await pairModel.prototype.findAll({
             where: {
                 status: 1,
                 updatedAt: { [ormDB.Op.lt]: new Date(now.getTime() - 10 * 1000) } // 10秒之前的
@@ -44,20 +46,23 @@ const syncPair = async () => {
             const { symbol, id } = pair;
             let cfg = await getPairFromCore(symbol);
             if (cfg) {
-            await spotPairs.prototype.update({
+                await pairModel.prototype.update({
                     status: 2,
                     product_id: cfg.id,
-                price_scale: cfg["price-scale"],
-                price_increment: cfg["price-increment"],
-                quantity_scale: cfg["quantity-scale"],
-                quantity_increment: cfg["quantity-increment"],
-
+                    price_scale: cfg["priceScale"],
+                    price_increment: cfg["priceIncrement"],
+                    quantity_scale: cfg["quantityScale"],
+                    quantity_increment: cfg["quantityIncrement"],
+                    taker_fee:cfg["takerFee"],
+                    maker_fee:cfg["makerFee"]
                 }, {
                     where: { id, status: 1 }
                 });
                 logger.info(symbol, "sync config success")
             }
         }
+    }
+
 
 
 }

src/utils/coreSystemUtils.ts

@@ -19,16 +19,21 @@ export const getCoinFromCore = async (symbol) => {
     return data.result[0];
 }
 
-// {
-//     "id": 1,
-//      "symbol": 'BTC_USDT',
-//     'price-scale': 4,
-//     'price-increment': 1,
-//     'quantity-scale': 2,
-//     'quantity-increment': '0'
-// }
-export const getPairFromCore = async (symbol, market = "spot") => {
-    const url = `${webadmin_endpoint}/pair/by_symbol?symbol=${symbol}&market=${market}`
+// {"market":"spot",
+// "symbol":"BTC_USDT",
+// "takerFee":"0.001",
+// "minOrderSize":"0",
+// "quantityIncrement":"0.01",
+// "makerFee":"0.001",
+// "priceIncrement":1,"
+// quantityScale":2,
+// "priceScale":4,
+// "maxOrderSize":"0",
+// "maxOrderValue":"0",
+// "minOrderValue":"0"}
+// 合约的话还有多余对应db字段 predictedFundingRate nextFundingTime ...
+export const getPairFromCore = async (symbol) => {
+    const url = `${webadmin_endpoint}/pair/by_symbol?symbol=${symbol}`
     let { data } = await axios.get(url);
     if (data.state != 0) {
         logger.error("getPairFromCore", data.msg);