|
@@ -35,6 +35,13 @@ export class LpMaintenance {
|
|
|
const token0 = lp.token0.toLowerCase()
|
|
const token0 = lp.token0.toLowerCase()
|
|
|
const token1 = lp.token1.toLowerCase()
|
|
const token1 = lp.token1.toLowerCase()
|
|
|
|
|
|
|
|
|
|
+ if (ethTokenAddressList.indexOf(token0) !== -1 || ethTokenAddressList.indexOf(token1) !== -1) {
|
|
|
|
|
+ return {
|
|
|
|
|
+ '0': ethTokenAddressList.indexOf(token0) !== -1 ? 1 : 0,
|
|
|
|
|
+ '1': ethTokenAddressList.indexOf(token1) !== -1 ? 1 : 0
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
// 1.两token之一能直接与ethw或wethw做直接池子的
|
|
// 1.两token之一能直接与ethw或wethw做直接池子的
|
|
|
// 2.两token之一能直接与baseToken做池子的
|
|
// 2.两token之一能直接与baseToken做池子的
|
|
|
// 这两种情况直接带入baseTokenConvertEthValueMap计算
|
|
// 这两种情况直接带入baseTokenConvertEthValueMap计算
|
|
@@ -137,7 +144,8 @@ export class LpMaintenance {
|
|
|
const lpAddressList: any = []
|
|
const lpAddressList: any = []
|
|
|
|
|
|
|
|
for (const lp of lpList) {
|
|
for (const lp of lpList) {
|
|
|
- lp.dataObj = JSON.parse(lp.data)
|
|
|
|
|
|
|
+ if (!lp.dataObj) lp.dataObj = JSON.parse(lp.data)
|
|
|
|
|
+
|
|
|
lpAddressList.push(lp.dataObj.LP)
|
|
lpAddressList.push(lp.dataObj.LP)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -303,7 +311,7 @@ export class LpMaintenance {
|
|
|
await this.pullAllToken(allTypeLpList)
|
|
await this.pullAllToken(allTypeLpList)
|
|
|
|
|
|
|
|
// 集中拉取r0,r1并更新本地的
|
|
// 集中拉取r0,r1并更新本地的
|
|
|
- const size = needToCheckEthLp ? 200 : 2000
|
|
|
|
|
|
|
+ const size = needToCheckEthLp ? 500 : 2000
|
|
|
for (let from = 0; from < allTypeLpList.length; from += size) {
|
|
for (let from = 0; from < allTypeLpList.length; from += size) {
|
|
|
// logger.debug(`${from}, ${allTypeLpList.length}`)
|
|
// logger.debug(`${from}, ${allTypeLpList.length}`)
|
|
|
if (needToCheckEthLp) await Time.delay(168)
|
|
if (needToCheckEthLp) await Time.delay(168)
|