From b003a49794f49a329e2702918ecfc8d14b371d0d Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期三, 04 三月 2026 14:51:25 +0800
Subject: [PATCH] 云仓WMS接口流程
---
rsf-server/src/main/java/com/vincent/rsf/server/system/service/impl/DictDataServiceImpl.java | 49 ++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 46 insertions(+), 3 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/system/service/impl/DictDataServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/system/service/impl/DictDataServiceImpl.java
index c788c76..9526a17 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/system/service/impl/DictDataServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/system/service/impl/DictDataServiceImpl.java
@@ -1,12 +1,55 @@
package com.vincent.rsf.server.system.service.impl;
-import com.vincent.rsf.server.system.mapper.DictDataMapper;
-import com.vincent.rsf.server.system.entity.DictData;
-import com.vincent.rsf.server.system.service.DictDataService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.vincent.rsf.server.common.event.DictDataChangedEvent;
+import com.vincent.rsf.server.system.entity.DictData;
+import com.vincent.rsf.server.system.mapper.DictDataMapper;
+import com.vincent.rsf.server.system.service.DictDataService;
+import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.io.Serializable;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
@Service("dictDataService")
public class DictDataServiceImpl extends ServiceImpl<DictDataMapper, DictData> implements DictDataService {
+ @Resource
+ private ApplicationEventPublisher applicationEventPublisher;
+
+ @Override
+ public boolean save(DictData entity) {
+ boolean result = super.save(entity);
+ if (result && entity.getDictTypeCode() != null) {
+ applicationEventPublisher.publishEvent(new DictDataChangedEvent(this, entity.getDictTypeCode()));
+ }
+ return result;
+ }
+
+ @Override
+ public boolean updateById(DictData entity) {
+ boolean result = super.updateById(entity);
+ if (result && entity.getDictTypeCode() != null) {
+ applicationEventPublisher.publishEvent(new DictDataChangedEvent(this, entity.getDictTypeCode()));
+ }
+ return result;
+ }
+
+ @Override
+ public boolean removeByIds(Collection<? extends Serializable> list) {
+ if (list == null || list.isEmpty()) {
+ return true;
+ }
+ List<DictData> before = listByIds(list);
+ boolean result = super.removeByIds(list);
+ if (result && before != null) {
+ for (String dictTypeCode : before.stream().map(DictData::getDictTypeCode).filter(c -> c != null).distinct().collect(Collectors.toList())) {
+ applicationEventPublisher.publishEvent(new DictDataChangedEvent(this, dictTypeCode));
+ }
+ }
+ return result;
+ }
}
--
Gitblit v1.9.1