Commit b314040f authored by 莫坚培's avatar 莫坚培

feat: 初始化时不做等待

parent f01a6b16
...@@ -28,7 +28,7 @@ let requestLoopTimer = null // 轮询定时器 ...@@ -28,7 +28,7 @@ let requestLoopTimer = null // 轮询定时器
let requestLoopDataPool = [] // 各个组件实时刷新的请求数据,放到一个集合里,原来的多个组件请求合并成一个请求发送 let requestLoopDataPool = [] // 各个组件实时刷新的请求数据,放到一个集合里,原来的多个组件请求合并成一个请求发送
let requestLoopStopFlag = false // requestLoopDataPool请求中标志,正在请求时不进行下一波轮询,前一波请求完成才执行下一波 let requestLoopStopFlag = false // requestLoopDataPool请求中标志,正在请求时不进行下一波轮询,前一波请求完成才执行下一波
let requestLoopTime = 5000 // 轮询定时器间隔 let requestLoopTime = 5000 // 轮询定时器间隔
let requestLoopWaitingTime = 1000 // 每一个请求的间隔时间 let requestLoopWaitingTime = 1000 // 每一个请求的间隔时间,减轻服务器压力,请求之间隔一秒
let requestLoopGroupSliceNum = 30 // 请求池requestLoopDataPool分组,每组多少个 let requestLoopGroupSliceNum = 30 // 请求池requestLoopDataPool分组,每组多少个
let requestLoopGroupSliceRes = [] // 分组结果 let requestLoopGroupSliceRes = [] // 分组结果
...@@ -860,7 +860,7 @@ async function initCanvas() { ...@@ -860,7 +860,7 @@ async function initCanvas() {
clearInterval(requestLoopTimer) clearInterval(requestLoopTimer)
// 初始化完成后开始轮询 // 初始化完成后开始轮询
for (let i = 0, len = requestLoopGroupSliceRes.length; i < len; i++) { for (let i = 0, len = requestLoopGroupSliceRes.length; i < len; i++) {
await sendLoopDataRequest(requestLoopGroupSliceRes[i], i, len) await sendLoopDataRequest(requestLoopGroupSliceRes[i], i, len, true)
} }
startRequestLoop(requestLoopTime) startRequestLoop(requestLoopTime)
...@@ -945,7 +945,7 @@ function startRequestLoop() { ...@@ -945,7 +945,7 @@ function startRequestLoop() {
} }
// 发起requestLoopDataPool的合并请求 // 发起requestLoopDataPool的合并请求
function sendLoopDataRequest(list, i, len) { function sendLoopDataRequest(list, i, len, isInit) {
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {
if (!(list instanceof Array)) { if (!(list instanceof Array)) {
reject() reject()
...@@ -971,7 +971,13 @@ function sendLoopDataRequest(list, i, len) { ...@@ -971,7 +971,13 @@ function sendLoopDataRequest(list, i, len) {
Object.keys(handleResMap).forEach(key => { Object.keys(handleResMap).forEach(key => {
renderRequestLoopData(Controls.dataPoolMap[key], handleResMap[key], res.data.code) renderRequestLoopData(Controls.dataPoolMap[key], handleResMap[key], res.data.code)
}) })
} }
// 初始化时不用等
if (isInit) {
resolve(res)
return
}
setTimeout(() => { setTimeout(() => {
resolve(res) resolve(res)
}, requestLoopWaitingTime) }, requestLoopWaitingTime)
...@@ -980,6 +986,7 @@ function sendLoopDataRequest(list, i, len) { ...@@ -980,6 +986,7 @@ function sendLoopDataRequest(list, i, len) {
if (i === len -1) { if (i === len -1) {
requestLoopStopFlag = false requestLoopStopFlag = false
} }
reject(err) reject(err)
}) })
}) })
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment