lihongjie/coal
1
0
Fork 0
mirror of https://codeup.aliyun.com/64f7d6b8ce01efaafef1e678/coal/coal.git synced 2026-01-25 07:46:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(coal): 修改事件广播类型

Browse Source 
- 将 update 事件改为 updateKfItems 和 updateMain
- 根据上下文推测，updateKfItems 可能用于更新铿奋项，updateMain 用于更新主数据
This commit is contained in:
lihongjie0209
2025-03-12 21:07:38 +08:00
parent 5cd2bd8282
commit 8bd5423bbd
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/cn/lihongjie/coal/coalWashingDailyAnalysis/service/CoalWashingDailyAnalysisService.java
View File

@@ -154,7 +154,7 @@ public class CoalWashingDailyAnalysisService
entity.setName(productService.get(entity.getProduct().getId()).getName()); entity.setName(productService.get(entity.getProduct().getId()).getName());
} }
this.repository.save(entity); this.repository.save(entity);
sseService.broadcast("coalWashingDailyAnalysis." + entity.getId(), ImmutableMap.of("id", entity.getId(), "event", "update")); sseService.broadcast("coalWashingDailyAnalysis." + entity.getId(), ImmutableMap.of("id", entity.getId(), "event", "updateKfItems"));
return getById(entity.getId()); return getById(entity.getId());
} }
@@ -183,7 +183,7 @@ public class CoalWashingDailyAnalysisService
entity.setName(productService.get(entity.getProduct().getId()).getName()); entity.setName(productService.get(entity.getProduct().getId()).getName());
} }
this.repository.save(entity); this.repository.save(entity);
sseService.broadcast("coalWashingDailyAnalysis." + entity.getId(), ImmutableMap.of("id", entity.getId(), "event", "update")); sseService.broadcast("coalWashingDailyAnalysis." + entity.getId(), ImmutableMap.of("id", entity.getId(), "event", "updateMain"));
return getById(entity.getId()); return getById(entity.getId());
} }