mirror of https://gitee.com/stylefeng/roses
【8.0】【org】更新对event的依赖
parent
e5169fb2a0
commit
587ce34c1c
|
@ -17,6 +17,12 @@
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
|
||||||
|
<!-- 事件模块 -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>cn.stylefeng.roses</groupId>
|
||||||
|
<artifactId>event-spring-boot-starter</artifactId>
|
||||||
|
</dependency>
|
||||||
|
|
||||||
<!--基础核心业务api-->
|
<!--基础核心业务api-->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>cn.stylefeng.roses</groupId>
|
<groupId>cn.stylefeng.roses</groupId>
|
||||||
|
|
|
@ -0,0 +1,16 @@
|
||||||
|
package cn.stylefeng.roses.kernel.sys.modular.org.enums;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加组织机构的事件
|
||||||
|
*
|
||||||
|
* @author fengshuonan
|
||||||
|
* @since 2023/7/14 14:18
|
||||||
|
*/
|
||||||
|
public enum OrgEventEnums {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加组织机构的事件
|
||||||
|
*/
|
||||||
|
ADD_ORG_EVENT
|
||||||
|
|
||||||
|
}
|
|
@ -0,0 +1,41 @@
|
||||||
|
package cn.stylefeng.roses.kernel.sys.modular.org.listener;
|
||||||
|
|
||||||
|
import cn.hutool.core.util.ObjectUtil;
|
||||||
|
import cn.stylefeng.roses.kernel.cache.api.CacheOperatorApi;
|
||||||
|
import cn.stylefeng.roses.kernel.sys.modular.org.entity.HrOrganization;
|
||||||
|
import cn.stylefeng.roses.kernel.sys.modular.org.enums.OrgEventEnums;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import javax.annotation.Resource;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 添加组织机构的
|
||||||
|
*
|
||||||
|
* @author fengshuonan
|
||||||
|
* @since 2023/7/14 14:19
|
||||||
|
*/
|
||||||
|
@Service
|
||||||
|
public class AddOrgListener {
|
||||||
|
|
||||||
|
@Resource(name = "sysOrgSubFlagCache")
|
||||||
|
private CacheOperatorApi<Boolean> sysOrgSubFlagCache;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String getBusinessCode() {
|
||||||
|
return OrgEventEnums.ADD_ORG_EVENT.name();
|
||||||
|
}
|
||||||
|
|
||||||
|
@(OrgEventEnums.ADD_ORG_EVENT)
|
||||||
|
public void doCallbackAction(HrOrganization businessObject) {
|
||||||
|
|
||||||
|
if (ObjectUtil.isNotEmpty(businessObject.getOrgId())) {
|
||||||
|
sysOrgSubFlagCache.remove(String.valueOf(businessObject.getOrgId()));
|
||||||
|
}
|
||||||
|
|
||||||
|
if (ObjectUtil.isNotEmpty(businessObject.getOrgParentId())) {
|
||||||
|
sysOrgSubFlagCache.remove(String.valueOf(businessObject.getOrgParentId()));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
|
@ -21,6 +21,7 @@ import cn.stylefeng.roses.kernel.sys.api.exception.enums.OrgExceptionEnum;
|
||||||
import cn.stylefeng.roses.kernel.sys.api.pojo.org.CompanyDeptDTO;
|
import cn.stylefeng.roses.kernel.sys.api.pojo.org.CompanyDeptDTO;
|
||||||
import cn.stylefeng.roses.kernel.sys.modular.org.constants.OrgConstants;
|
import cn.stylefeng.roses.kernel.sys.modular.org.constants.OrgConstants;
|
||||||
import cn.stylefeng.roses.kernel.sys.modular.org.entity.HrOrganization;
|
import cn.stylefeng.roses.kernel.sys.modular.org.entity.HrOrganization;
|
||||||
|
import cn.stylefeng.roses.kernel.sys.modular.org.enums.OrgEventEnums;
|
||||||
import cn.stylefeng.roses.kernel.sys.modular.org.factory.OrganizationFactory;
|
import cn.stylefeng.roses.kernel.sys.modular.org.factory.OrganizationFactory;
|
||||||
import cn.stylefeng.roses.kernel.sys.modular.org.mapper.HrOrganizationMapper;
|
import cn.stylefeng.roses.kernel.sys.modular.org.mapper.HrOrganizationMapper;
|
||||||
import cn.stylefeng.roses.kernel.sys.modular.org.pojo.request.CommonOrgTreeRequest;
|
import cn.stylefeng.roses.kernel.sys.modular.org.pojo.request.CommonOrgTreeRequest;
|
||||||
|
@ -76,6 +77,9 @@ public class HrOrganizationServiceImpl extends ServiceImpl<HrOrganizationMapper,
|
||||||
OrganizationFactory.fillParentIds(hrOrganization);
|
OrganizationFactory.fillParentIds(hrOrganization);
|
||||||
|
|
||||||
this.save(hrOrganization);
|
this.save(hrOrganization);
|
||||||
|
|
||||||
|
// 发布一个新增组织机构的事件
|
||||||
|
BusinessEventPublisher.publishEvent(OrgEventEnums.ADD_ORG_EVENT.name(), hrOrganization);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue