yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[8.2.0][opt]降低同步云端途经点的频率

Browse Source
This commit is contained in:
Herry
2025-09-01 17:43:36 +08:00
parent 9275e8e79e
commit dcd40270f2
1 changed files with 8 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
OCH/shuttle/driver_weaknet/src/main/java/com/mogo/och/weaknet/model/SynchDataModel.kt
View File

@@ -131,8 +131,8 @@ object SynchDataModel {
private val isRequestingContrainInfo = AtomicBoolean(false) private val isRequestingContrainInfo = AtomicBoolean(false)
fun synContraiInfo(needUpdatePoint: MutableList<Long>, updateAll: Boolean = false) { fun synContraiInfo(needUpdatePoint: MutableList<Long>) {
if (!updateAll) waitSysData.addAll(needUpdatePoint) waitSysData.addAll(needUpdatePoint)
if(isRequestingContrainInfo.get()){ if(isRequestingContrainInfo.get()){
// 正在请求 // 正在请求
OchChainLogManager.writeChainLogNet(false,"同步轨迹","正在同步轨迹请稍等 ") OchChainLogManager.writeChainLogNet(false,"同步轨迹","正在同步轨迹请稍等 ")
@@ -141,12 +141,8 @@ object SynchDataModel {
isRequestingContrainInfo.set(true) isRequestingContrainInfo.set(true)
val lines = mutableListOf<Long>() val lines = mutableListOf<Long>()
if (updateAll) { waitSysData.forEach {
lines.addAll(needUpdatePoint) lines.add(it)
} else {
waitSysData.forEach {
lines.add(it)
}
} }
OchChainLogManager.writeChainLogNet(false,"同步轨迹","轨迹变更需同步禁行点和途径点 线路：${lines}") OchChainLogManager.writeChainLogNet(false,"同步轨迹","轨迹变更需同步禁行点和途径点 线路：${lines}")
RepositoryManager.queryPointFromNet(lines) RepositoryManager.queryPointFromNet(lines)
@@ -174,16 +170,12 @@ object SynchDataModel {
try { try {
i(TAG, "途经点和轨迹信息为:${data}") i(TAG, "途经点和轨迹信息为:${data}")
PointDb.addOrUpdate(data) PointDb.addOrUpdate(data)
if (!updateAll) { for (datum in data) {
for (datum in data) { waitSysData.remove(datum.lineId)
waitSysData.remove(datum.lineId)
}
} }
isRequestingContrainInfo.set(false) isRequestingContrainInfo.set(false)
if (!updateAll) { if(waitSysData.isNotEmpty()){
if(waitSysData.isNotEmpty()){ synContraiInfo(needUpdatePoint)
synContraiInfo(needUpdatePoint)
}
} }
OchChainLogManager.writeChainLogNet(false,"同步轨迹","网络请求重构 轨迹信息${data}") OchChainLogManager.writeChainLogNet(false,"同步轨迹","网络请求重构 轨迹信息${data}")
d(TAG, "同步轨迹网络成功") d(TAG, "同步轨迹网络成功")