添加了一个错误类型

@@ -8,10 +8,9 @@ package com.sunyo.wlpt.message.bus.service.exception;
 
 public enum CustomExceptionType {
     MESSAGE_SUCCESS("10200", "消息发送成功"),
+    SERVER_EXCEPTION("10500", "服务器异常，发送消息失败！"),
 
     BINDING_ERROR("10501", "配置信息，未进行绑定！"),
-
-
     SENDER_ERROR("10401", "报文格式错误，发送者不能为空！"),
     CONTENT_ERROR("10402", "报文格式错误，消息内容不能为空！"),
     SERVER_ERROR("10403", "报文格式错误，服务器名称不能为空！"),
@@ -27,8 +26,6 @@ public enum CustomExceptionType {
     EXCHANGE_NO_EXIST("20405", "报文数据错误，交换机不存在！"),
     ROUTING_KEY_NO_EXIST("20406", "报文数据错误，路由键不存在！"),
 
-    SERVER_EXCEPTION("50500", "服务器异常，发送消息失败！"),
-
     CLIENT_ERROR("400", "客户端异常"),
     SYSTEM_ERROR("500", "系统服务异常"),
     OTHER_ERROR("999", "其他未知异常");

 package com.sunyo.wlpt.message.bus.service.exception;
 
+import com.sunyo.wlpt.message.bus.service.response.ResultJson;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseBody;
 
 /**
  * @author 子诚
  * Description：自定义全局异常处理类
  * 时间：2020/7/17 17:44
  */
-@ControllerAdvice
+//@ControllerAdvice
 public class GlobalExceptionHandler {
     private static final Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class);
-    
+
+    //处理程序员主动转换的自定义异常
+    @ExceptionHandler(CustomException.class)
+    @ResponseBody
+    public ResultJson customerException(CustomException e) {
+        if(e.getCode() == CustomExceptionType.SYSTEM_ERROR.getCode()){
+            //400异常不需要持久化，将异常信息以友好的方式告知用户就可以
+
+            //TODO 将500异常信息持久化处理，方便运维人员处理
+            logger.error("");
+        }
+        return ResultJson.error(e);
+    }
 }