添加消息发送系统

portal-manager/src/main/java/com/mortals/xhx/module/message/web/MessageConfigController.java

 package com.mortals.xhx.module.message.web;
-import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
-import com.mortals.xhx.base.system.param.service.ParamService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.bind.annotation.*;
+
+import com.mortals.framework.exception.AppException;
 import com.mortals.framework.model.Context;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
 import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.common.code.ChannelEnum;
+import com.mortals.xhx.common.code.EnabledEnum;
+import com.mortals.xhx.common.code.MessageTypeEnum;
 import com.mortals.xhx.module.message.model.MessageConfigEntity;
+import com.mortals.xhx.module.message.model.MessageConfigQuery;
 import com.mortals.xhx.module.message.service.MessageConfigService;
-import org.apache.commons.lang3.ArrayUtils;
-import com.mortals.framework.util.StringUtils;
-import java.util.HashMap;
-import java.util.List;
+import org.checkerframework.checker.units.qual.A;
+import org.springframework.util.ObjectUtils;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
 import java.util.Map;
-import java.util.stream.Collectors;
-import com.alibaba.fastjson.JSONObject;
-import java.util.Arrays;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-import static com.mortals.framework.ap.SysConstains.*;
-import com.mortals.xhx.common.code.*;
+
 /**
-*
-* 消息发送配置
-*
-* @author zxfei
-* @date 2025-04-10
-*/
+ * 消息发送配置
+ *
+ * @author zxfei
+ * @date 2025-04-10
+ */
 @RestController
 @RequestMapping("message/config")
-public class MessageConfigController extends BaseCRUDJsonBodyMappingController<MessageConfigService,MessageConfigEntity,Long> {
+public class MessageConfigController extends BaseCRUDJsonBodyMappingController<MessageConfigService, MessageConfigEntity, Long> {
 
-    @Autowired
-    private ParamService paramService;
 
-    public MessageConfigController(){
-        super.setModuleDesc( "消息发送配置");
+    public MessageConfigController() {
+        super.setModuleDesc("消息发送配置");
     }
 
     @Override
     protected void init(Map<String, Object> model, Context context) {
-                this.addDict(model, "messageType", MessageTypeEnum.getEnumMap());
-                this.addDict(model, "channel", ChannelEnum.getEnumMap());
-                this.addDict(model, "enabled", EnabledEnum.getEnumMap());
+        this.addDict(model, "messageType", MessageTypeEnum.getEnumMap());
+        this.addDict(model, "channel", ChannelEnum.getEnumMap());
+        this.addDict(model, "enabled", EnabledEnum.getEnumMap());
         super.init(model, context);
     }
 
 
+    @Override
+    protected void saveBefore(MessageConfigEntity entity, Map<String, Object> model, Context context) throws AppException {
+        super.saveBefore(entity, model, context);
+        if (ObjectUtils.isEmpty(entity.getSiteId())) {
+            throw new AppException("站点id不能为空");
+        }
+        if (ObjectUtils.isEmpty(entity.getMessageType())) {
+            throw new AppException("消息类型不能为空！");
+        }
+
+        //查询如果存在 就更新  维度为 站点id 与消息类型
+        MessageConfigEntity messageConfigEntity = this.service.selectOne(new MessageConfigQuery().siteId(entity.getSiteId()).messageType(entity.getMessageType()));
+        if (!ObjectUtils.isEmpty(messageConfigEntity)) {
+            entity.setId(messageConfigEntity.getId());
+        }
+
+
+    }
 }
\ No newline at end of file

portal-manager/src/main/java/com/mortals/xhx/module/message/web/MessageTaskController.java

 package com.mortals.xhx.module.message.web;
-import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
-import com.mortals.xhx.base.system.param.service.ParamService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-import org.springframework.web.bind.annotation.*;
+
 import com.mortals.framework.model.Context;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
 import com.mortals.framework.web.BaseCRUDJsonBodyMappingController;
+import com.mortals.xhx.common.code.ChannelEnum;
+import com.mortals.xhx.common.code.EnabledEnum;
+import com.mortals.xhx.common.code.PriorityEnum;
+import com.mortals.xhx.common.code.SendStatusEnum;
 import com.mortals.xhx.module.message.model.MessageTaskEntity;
 import com.mortals.xhx.module.message.service.MessageTaskService;
-import org.apache.commons.lang3.ArrayUtils;
-import com.mortals.framework.util.StringUtils;
-import java.util.HashMap;
-import java.util.List;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
 import java.util.Map;
-import java.util.stream.Collectors;
-import com.alibaba.fastjson.JSONObject;
-import java.util.Arrays;
-import org.springframework.web.bind.annotation.*;
-import org.springframework.web.multipart.MultipartFile;
-import static com.mortals.framework.ap.SysConstains.*;
-import com.mortals.xhx.common.code.*;
+
 /**
-*
-* 消息任务
-*
-* @author zxfei
-* @date 2025-04-10
-*/
+ * 消息任务
+ *
+ * @author zxfei
+ * @date 2025-04-10
+ */
 @RestController
 @RequestMapping("message/task")
-public class MessageTaskController extends BaseCRUDJsonBodyMappingController<MessageTaskService,MessageTaskEntity,Long> {
+public class MessageTaskController extends BaseCRUDJsonBodyMappingController<MessageTaskService, MessageTaskEntity, Long> {
 
-    @Autowired
-    private ParamService paramService;
 
-    public MessageTaskController(){
-        super.setModuleDesc( "消息任务");
+    public MessageTaskController() {
+        super.setModuleDesc("消息任务");
     }
 
     @Override
     protected void init(Map<String, Object> model, Context context) {
-                this.addDict(model, "channel", ChannelEnum.getEnumMap());
-                this.addDict(model, "enabled", EnabledEnum.getEnumMap());
-                this.addDict(model, "priority", PriorityEnum.getEnumMap());
-                this.addDict(model, "sendStatus", SendStatusEnum.getEnumMap());
-                this.addDict(model, "retryCount", RetryCountEnum.getEnumMap());
+        this.addDict(model, "channel", ChannelEnum.getEnumMap());
+        this.addDict(model, "enabled", EnabledEnum.getEnumMap());
+        this.addDict(model, "priority", PriorityEnum.getEnumMap());
+        this.addDict(model, "sendStatus", SendStatusEnum.getEnumMap());
         super.init(model, context);
     }
 
 
+
+
 }
\ No newline at end of file