c-zhouhf1/zhgh_hmc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

广播订阅

Browse Source
This commit is contained in:
Paidax
2025-08-30 09:52:58 +08:00
parent eb95548ebb
commit d907d3eb92
15 changed files with 70 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/io/v/nutz/base/event/user/SysCommonDataChange.java → src/main/java/io/v/nutz/base/event/common/SysCommonDataChange.java
+1 -3
View File
@@ -1,6 +1,4 @@
package io.v.nutz.base.event.user;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
package io.v.nutz.base.event.common;
public interface SysCommonDataChange {
src/main/java/io/v/nutz/base/event/user/SysCommonDataChangeCenter.java → src/main/java/io/v/nutz/base/event/common/SysCommonDataChangeCenter.java
+1 -3
View File
@@ -1,7 +1,5 @@
package io.v.nutz.base.event.user;
package io.v.nutz.base.event.common;
import io.v.nutz.base.event.user.SysCommonDataChange;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import org.nutz.mvc.Mvcs;
/**
src/main/java/io/v/nutz/base/event/user/SysCommonDataChangeType.java → src/main/java/io/v/nutz/base/event/common/SysCommonDataChangeType.java
+1 -1
View File
@@ -1,4 +1,4 @@
package io.v.nutz.base.event.user;
package io.v.nutz.base.event.common;
/**
* 数据变更类型
src/main/java/io/v/nutz/base/event/user/UserChangePublisher.java
+6 -3
View File
@@ -1,6 +1,7 @@
package io.v.nutz.base.event.user;
import org.nutz.mvc.Mvcs;
import io.v.nutz.base.utils.AppIocUtil;
import org.nutz.ioc.Ioc;
/**
* @version 1.0
@@ -13,9 +14,11 @@ public class UserChangePublisher {
// 发送消息给所有订阅者
public static void broadcast(UserChangeMsg msg) {
String[] names = Mvcs.getIoc().getNamesByType(UserChangeEventListener.class);
Ioc ioc = AppIocUtil.get();
String[] names = ioc.getNamesByType(UserChangeEventListener.class);
for (String listener : names) {
UserChangeEventListener listenerBean = Mvcs.getIoc().get(UserChangeEventListener.class, listener);
UserChangeEventListener listenerBean = ioc.get(UserChangeEventListener.class, listener);
listenerBean.receive(msg);
}
}
src/main/java/io/v/nutz/base/utils/AppIocUtil.java
+27
View File
@@ -0,0 +1,27 @@
package io.v.nutz.base.utils;
import org.nutz.ioc.Ioc;
/**
* @version 1.0
* @Author zzr
* @name：AppIocUtil
* @Date 2025/8/26 17:40
* @注释
*/
public class AppIocUtil {
private static Ioc ioc;
public static void setIoc(Ioc ioc) {
AppIocUtil.ioc = ioc;
}
public static Ioc get() {
if (ioc == null) {
throw new IllegalStateException("Ioc not initialized yet!");
}
return ioc;
}
}
src/main/java/io/v/nutz/sys/controllers/platform/sys/SysUnionMangeCon.java
+2 -2
View File
@@ -6,8 +6,8 @@ import cn.afterturn.easypoi.excel.entity.ExportParams;
import cn.hutool.core.util.StrUtil;
import cn.wizzer.framework.base.Result;
import io.v.nutz.base.annontation.ViReturn;
import io.v.nutz.base.event.user.SysCommonDataChangeCenter;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import io.v.nutz.base.event.common.SysCommonDataChangeCenter;
import io.v.nutz.base.event.common.SysCommonDataChangeType;
import io.v.nutz.base.event.user.UserChangeMsg;
import io.v.nutz.base.event.user.UserChangePublisher;
import io.v.nutz.base.page.Pagination;
src/main/java/io/v/nutz/sys/controllers/platform/sys/SysUnitMangeController.java
+2 -2
View File
@@ -2,8 +2,8 @@ package io.v.nutz.sys.controllers.platform.sys;
import cn.wizzer.framework.base.Result;
import io.v.nutz.base.annontation.ViReturn;
import io.v.nutz.base.event.user.SysCommonDataChangeCenter;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import io.v.nutz.base.event.common.SysCommonDataChangeCenter;
import io.v.nutz.base.event.common.SysCommonDataChangeType;
import io.v.nutz.base.utils.Roles;
import io.v.nutz.base.dao.CndPlus;
import io.v.nutz.base.query.PageForm;
src/main/java/io/v/nutz/zhgh/activity/listener/ActivityUserChangeListener.java
-22
View File
@@ -1,22 +0,0 @@
package io.v.nutz.zhgh.activity.listener;
import io.v.nutz.base.event.user.UserChangeEventListener;
import io.v.nutz.base.event.user.UserChangeMsg;
import org.nutz.ioc.loader.annotation.IocBean;
/**
* @version 1.0
* @Author zzr
* @name：ActivityCommonListener
* @Date 2025/8/13 14:41
* @注释 活动的广播监听
*/
@IocBean
public class ActivityUserChangeListener implements UserChangeEventListener {
@Override
public void receive(UserChangeMsg message) {
System.out.println("=======================================================接收到消息=======================================================");
System.out.println(message);
}
}
src/main/java/io/v/nutz/zhgh/activity/listener/SysActivityUnionListener.java
+2 -3
View File
@@ -1,9 +1,8 @@
package io.v.nutz.zhgh.activity.listener;
import cn.hutool.core.bean.BeanUtil;
import io.v.nutz.base.event.user.SysCommonDataChange;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import io.v.nutz.base.event.user.SysCommonDataChange;
import io.v.nutz.base.event.common.SysCommonDataChange;
import io.v.nutz.base.event.common.SysCommonDataChangeType;
import io.v.nutz.sys.models.Sys_union;
import io.v.nutz.zhgh.activity.models.ActivityBasicUnion;
import org.nutz.dao.Cnd;
src/main/java/io/v/nutz/zhgh/activity/listener/SysActivityUnitListener.java
+2 -2
View File
@@ -1,8 +1,8 @@
package io.v.nutz.zhgh.activity.listener;
import cn.hutool.core.bean.BeanUtil;
import io.v.nutz.base.event.user.SysCommonDataChange;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import io.v.nutz.base.event.common.SysCommonDataChange;
import io.v.nutz.base.event.common.SysCommonDataChangeType;
import io.v.nutz.sys.models.Sys_unit;
import io.v.nutz.zhgh.activity.models.ActivityBasicUnit;
import org.nutz.dao.Cnd;
src/main/java/io/v/nutz/zhgh/proposal/listener/ProposalUnderTakeListener.java
+2 -2
View File
@@ -1,8 +1,8 @@
package io.v.nutz.zhgh.proposal.listener;
import cn.hutool.core.bean.BeanUtil;
import io.v.nutz.base.event.user.SysCommonDataChange;
import io.v.nutz.base.event.user.SysCommonDataChangeType;
import io.v.nutz.base.event.common.SysCommonDataChange;
import io.v.nutz.base.event.common.SysCommonDataChangeType;
import io.v.nutz.sys.models.Sys_unit;
import io.v.nutz.zhgh.proposal.models.ProposalUndertake;
import org.nutz.dao.Cnd;
src/main/java/io/v/nutz/zhgh/welfare/controller/evaluate/WelfareEvaluateActivityController.java
+1 -1
View File
@@ -244,7 +244,7 @@ public class WelfareEvaluateActivityController {
System.out.println(loginNames);
String link = Globals.AppDomain + "/platform/h5/welfare/evaluate?activityId=%s&type=welfare".formatted(activityId);
String link = Globals.AppDomain + "/platform/h5/welfare/evaluate?id=%s&type=welfare".formatted(activityId);
msgApi.sendMsg(List.of("DingTalk"), loginNames, 2, title, sendMsgValue, "", link);
return Result.success();
} catch (Exception e) {
src/main/java/io/v/nutz/zhgh/welfare/controller/evaluate/WelfareEvaluateStatisticsController.java
+15 -3
View File
@@ -33,6 +33,7 @@ import org.nutz.lang.Lang;
import org.nutz.lang.util.NutMap;
import org.nutz.mvc.annotation.At;
import org.nutz.mvc.annotation.Ok;
import org.nutz.mvc.annotation.Param;
import javax.servlet.http.HttpServletResponse;
import javax.validation.Valid;
@@ -68,7 +69,13 @@ public class WelfareEvaluateStatisticsController {
@At
@ViReturn
@RequiresPermissions("welfare.evaluate.statistics")
public Object pageData(PageForm pageForm, String projectId, String unionId, String unitId, String personType, String userState, String optionId) {
public Object pageData(PageForm pageForm,
@Param(value = "projectId", required = false) String projectId,
@Param(value = "unionId", required = false) String unionId,
@Param(value = "unitId", required = false) String unitId,
@Param(value = "personType", required = false) String personType,
@Param(value = "userState", required = false) String userState,
@Param(value = "optionId", required = false) String optionId) {
WelfareEvaluateActivity evaluate = dao.fetch(WelfareEvaluateActivity.class, Cnd.where("welfareId", "=", projectId));
if (Lang.isEmpty(evaluate)) {
return Result.error("未找到相应福利");
@@ -201,8 +208,13 @@ public class WelfareEvaluateStatisticsController {
@At
@Ok("void")
@RequiresPermissions("welfare.evaluate.statistics")
public void exportXlsx(PageForm pageForm, String projectId, String unionId, String unitId,
String personType, String userState, String optionId,
public void exportXlsx(PageForm pageForm,
@Param(value = "projectId", required = false) String projectId,
@Param(value = "unionId", required = false) String unionId,
@Param(value = "unitId", required = false) String unitId,
@Param(value = "personType", required = false) String personType,
@Param(value = "userState", required = false) String userState,
@Param(value = "optionId", required = false) String optionId,
HttpServletResponse response) {
try {
WelfareEvaluateActivity evaluate = dao.fetch(WelfareEvaluateActivity.class, Cnd.where("welfareId", "=", projectId));