Jersey重新整理,开箱即用

Author: mrdear

Jersey--Demo/.idea/workspace.xml

@@ -1,15 +1,15 @@
-package com.haikong.exception;
+package com.haikong;
 
 /**
  * Created by 牛李 on 2016/7/26.
  */
-public enum ErrorCode {
+public enum ResultVO {
     OK(0,"OK"),ID_INVALID(1,"ID is invalid"),OTHER_ERR(2,"未知错误");
 
     private int code;
     private String message;
 
-    ErrorCode(int code, String message) {
+    ResultVO(int code, String message) {
         this.code = code;
         this.message = message;
     }

Jersey--Demo/src/main/java/com/haikong/exception/ErrorCode.java renamed to Jersey--Demo/src/main/java/com/haikong/ResultVO.java

@@ -1,5 +1,9 @@
 package com.haikong.exception;
 
+import com.haikong.ResultVO;
+
+import org.apache.log4j.Logger;
+
 import javax.ws.rs.core.MediaType;
 import javax.ws.rs.core.Response;
 import javax.ws.rs.ext.ExceptionMapper;
@@ -14,20 +18,18 @@ public class DeviceExceptionMapper implements ExceptionMapper<Exception> {
 
     @Override
     public Response toResponse(Exception e) {
-//        e.printStackTrace();
-        System.out.println(e.toString());
+        logger.error("错误信息:",e);
         Response.ResponseBuilder ResponseBuilder = null;
-        if (e instanceof DeviceException){
-
-            //截取自定义类型
-            DeviceException exp = (DeviceException) e;
-            ErrorEntity entity = new ErrorEntity(exp.getCode(),exp.getMessage());
+        if (e instanceof NumberFormatException){
+            ErrorEntity entity = new ErrorEntity(ResultVO.OTHER_ERR.getCode(),ResultVO.OTHER_ERR.getMessage());
             ResponseBuilder = Response.ok(entity, MediaType.APPLICATION_JSON);
         }else {
-            ErrorEntity entity = new ErrorEntity(ErrorCode.OTHER_ERR.getCode(),e.getMessage());
+            ErrorEntity entity = new ErrorEntity(ResultVO.OTHER_ERR.getCode(),e.getMessage());
             ResponseBuilder = Response.ok(entity, MediaType.APPLICATION_JSON);
         }
         System.out.println("执行自定义异常");
         return ResponseBuilder.build();
     }
+
+    private static Logger logger = Logger.getLogger(DeviceExceptionMapper.class);
 }

Jersey--Demo/src/main/java/com/haikong/exception/DeviceException.java

@@ -1,17 +1,20 @@
 package com.haikong.resources;
 
 import com.alibaba.fastjson.JSONObject;
-import com.haikong.exception.DeviceException;
-import com.haikong.exception.ErrorCode;
 import com.haikong.service.DeviceService;
 import com.haikong.util.CheckUtil;
 import com.haikong.util.DeviceUtil;
+
 import org.springframework.stereotype.Controller;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
-import javax.ws.rs.*;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.QueryParam;
 import javax.ws.rs.core.Context;
 import javax.ws.rs.core.MediaType;
 
@@ -25,19 +28,6 @@ public class DeviceController {
     @Resource(name = "DeviceService")
     private DeviceService deviceService;
 
-    /**
-     * 测试全局异常托管
-     * @throws DeviceException
-     */
-    @GET
-    @Path("/testexception")
-    @Produces(MediaType.APPLICATION_JSON)
-    public void testException() throws DeviceException {
-        if (1==1){
-            throw new DeviceException(ErrorCode.OTHER_ERR);
-        }
-    }
-
     /**
      * 验证设备URL用的方法
      * @param signature

Jersey--Demo/src/main/java/com/haikong/exception/DeviceExceptionMapper.java

@@ -1,9 +1,8 @@
 package com.haikong.service;
 
-import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.haikong.dao.DeviceMapper;
-import com.haikong.model.ReqDevice;
+
 import org.apache.log4j.Logger;
 import org.springframework.stereotype.Service;
 
@@ -24,80 +23,34 @@ public class DeviceService {
      * @param object
      */
     public void deviceNotify(JSONObject object){
-        ReqDevice device = JSON.parseObject(object.toJSONString(),ReqDevice.class);//解析json类
-        device.setAsy_error_code(0);
-        if (deviceMapper.updateDeviceDetail(device)){
-            logger.info("notify类型设备状态"+object.toString());
-        }else {
-            logger.error("更新设备出错"+object.toString());
-        }
     }
 
     /**
      * 接收get_resp类型的设备消息,这里还要根据返回码来设置设备的其他状态
      * @param object
      */
     public void deviceGetResp(JSONObject object){
-        ReqDevice reqDevice = JSON.parseObject(object.toJSONString(),ReqDevice.class);//解析传来的串
-        if (reqDevice.getAsy_error_code()==0){//这里有一种情况是请求的设备关闭
-            if (deviceMapper.updateDeviceDetail(reqDevice)){
-                logger.info("get_resp类型更新设备状态"+object.toString());
-            }else {
-                logger.error("get_resp类型更新设备出错"+object.toString());
-            }
-        }else{//无响应,则设置设备为关闭状态
-            if (deviceMapper.updateDeviceOff(reqDevice)){
-                logger.info("设备:"+reqDevice.getDevice_id()+"无响应,已设置为关闭");
-            }else {
-                logger.error("关闭设备出错"+object.toJSONString());
-            }
-        }
     }
 
     /**
      * 接收set_resp类型的设备消息,这里还要根据返回码来设置设备的其他状态
      * @param object
      */
     public void deviceSetResp(JSONObject object){
-        ReqDevice reqDevice = JSON.parseObject(object.toJSONString(),ReqDevice.class);//解析传来的串
-        int asy_error_code = reqDevice.getAsy_error_code();
-            if (asy_error_code == 0){
-                deviceMapper.updateDeviceDetail(reqDevice);
-                logger.info("set_resp类型更新设备状态" + object.toString());
-            }else {//证明未联网
-                deviceMapper.updateDeviceOff(reqDevice);
-                logger.error("设备未联网,已记录到数据库"+object.toString());
-            }
     }
 
     /**
      * 处理用户绑定事件
      * @param object
      */
     public void deviceBind(JSONObject object){
-        ReqDevice reqDevice = new ReqDevice();
-        reqDevice.setDevice_id(object.getString("device_id"));
-        reqDevice.setDevice_type(object.getString("device_type"));
-        reqDevice.setUser(object.getString("open_id"));
-        if (deviceMapper.insertDevice(reqDevice)){
-            logger.info("用户:"+reqDevice.getUser()+"绑定设备:"+reqDevice.getDevice_id()+"成功");
-        }else {
-            logger.error("用户:"+reqDevice.getUser()+"绑定设备:"+reqDevice.getDevice_id()+"失败");
-        }
     }
     /**
      * 处理用户解绑事件
      * @param object
      */
     public void deviceUnBind(JSONObject object){
-        ReqDevice reqDevice = new ReqDevice();
-        reqDevice.setDevice_id(object.getString("device_id"));
-        reqDevice.setUser(object.getString("open_id"));
-        if (deviceMapper.deleteUserDevice(reqDevice)){
-            logger.info("用户:"+reqDevice.getUser()+"解除绑定设备:"+reqDevice.getDevice_id()+"成功");
-        }else {
-            logger.error("用户:"+reqDevice.getUser()+"解除绑定设备:"+reqDevice.getDevice_id()+"失败");
-        }
+
     }
 
     private static Logger logger  = Logger.getLogger(DeviceService.class);

Jersey--Demo/src/main/java/com/haikong/resources/DeviceController.java

@@ -1,20 +1,7 @@
-#\u914D\u7F6E\u81EA\u5DF1\u7684\u65E5\u5FD7\u5199\u5165\u5230\u6587\u4EF6\u4E2D
 log4j.logger.com.haikong = warn, file
 log4j.rootLogger=warn, stdout
 #Console
 log4j.appender.stdout=org.apache.log4j.ConsoleAppender
 log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%-5p - %m%n
-#LogFile
-log4j.appender.file=org.apache.log4j.FileAppender
-log4j.appender.file.File=E://test/hklog.log
-log4j.appender.file.layout=org.apache.log4j.PatternLayout
-log4j.appender.file.encoding=UTF-8
-log4j.appender.file.layout.ConversionPattern=%d{ABSOLUTE} %5p %c{1}:%L - %m%n
-
-##    MySQL
-log4j.appender.logindb.sql=INSERT INTO LOGIN_LOG_P(LOGIN_LOG_ID,LOGIN_NAME,IP_ADDRESS,LOGIN_TIME) VALUES(uuid(),'','',NOW())
-log4j.appender.logindb.layout=org.apache.log4j.PatternLayout
-log4j.logger.org.apache=info
-log4j.logger.org.springframework=info
+log4j.appender.stdout.layout.ConversionPattern=%d{HH:mm:ss} [%t] %c %p - %m%n