Browse Source

杭研接口使用。

songshuai 5 years ago
parent
commit
a4006b18c2

+ 248 - 0
src/main/java/cn/efunbox/audio/page/ResOnePage.java

@@ -0,0 +1,248 @@
+/**
+ * 文件名:@OnePage.java <br/>
+ * 包名:cn.efunbox.afw.core.domain.page <br/>
+ * 项目名:afw-core <br/>
+ * @author xtwin <br/>
+ */
+package cn.efunbox.audio.page;
+
+import java.io.Serializable;
+import java.util.Collections;
+import java.util.List;
+
+public class ResOnePage<E> implements ResPageable<List<E>> ,Serializable {
+
+	private static final long serialVersionUID = 1L;
+	// 默认分页数据条数
+	public final static int DEFAULT_PAGE_SIZE = 10;
+
+	// 当前页
+	private int pageNum = 1;
+
+	// 当前页大小
+	private int pageSize = DEFAULT_PAGE_SIZE;
+
+	// 总条数
+	private long pageTotal;
+
+	// 数据内容
+	private List<E> list;
+
+	/**
+	 * 构造方法
+	 */
+	protected ResOnePage() {
+		// 默认构造方法
+	}
+
+	/**
+	 * 构造方法
+	 */
+	public ResOnePage(Long pageTotal) {
+		this(pageTotal, null, null);
+	}
+
+	/**
+	 * 构造方法
+	 */
+	public ResOnePage(Long pageTotal, Integer pageNum) {
+		this(pageTotal, pageNum, null);
+	}
+
+	/**
+	 * 构造方法
+	 */
+	public ResOnePage(Long pageTotal, Integer pageNum, Integer pageSize) {
+		// 总记录数
+		if (null != pageTotal) {
+			if (pageTotal < 0) {
+				throw new RuntimeException("pageTotal must be not less than zero!");
+			}
+			this.pageTotal = pageTotal;
+		}
+		
+		// 当前页码
+		if (null != pageNum) {
+			if (pageNum < 0) {
+				throw new RuntimeException("pageNum must be not less than zero!");
+			}
+			this.pageNum = pageNum;
+		}
+
+		
+		// 当前页数据条数
+		if (null != pageSize) {
+			if (pageSize < 0) {
+				throw new RuntimeException("pageSize must be not less than zero!");
+			}
+			
+			this.pageSize = pageSize;
+		}
+
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public int getTotalNo() {
+		return pageTotal == 0 ? 1 : (int) ((pageTotal / pageSize) + (pageTotal % pageSize == 0 ? 0 : 1));
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public long getPageTotal() {
+		return pageTotal;
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public int getPageNum() {
+		return pageNum;
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public int getPageSize() {
+		return pageSize;
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public boolean hasNext() {
+		return getPageNum() < getTotalNo();
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年7月31日 上午9:27:27<br/>
+	 * 
+	 * @return <br/>
+	 */
+	@Override
+	public boolean hasPrevious() {
+		return getPageNum() > 1;
+	}
+
+	/**
+	 * @version 2016年7月31日-上午10:57:49
+	 */
+	public void setPageNum(int pageNum) {
+		this.pageNum = pageNum;
+	}
+
+	/**
+	 * @version 2016年7月31日-上午10:57:49
+	 */
+	public void setPageSize(int pageSize) {
+		this.pageSize = pageSize;
+	}
+
+	/**
+	 * @version 2016年7月31日-上午10:57:49
+	 */
+	public void setPageTotal(int pageTotal) {
+		/*if (pageTotal < 0) {
+			throw new AfwRuntimeException("pageTotal must be not less than zero!");
+		}*/
+		this.pageTotal = pageTotal;
+	}
+	
+	/**
+	 * 功能:bean规范 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年7月31日 下午12:54:59 <br/>
+	 */
+	public boolean isHasNext() {
+		return hasNext();
+	}
+	
+	/**
+	 * 功能:bean规范 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年7月31日 下午12:55:22 <br/>
+	 */
+	public boolean isHasPrevious() {
+		return hasPrevious();
+	}
+
+	/**
+	 * @version 2016年8月1日-上午10:00:32
+	 */
+	public void setList(List<E> list) {
+		this.list = list;
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年8月1日 上午9:49:32<br/>
+	 * 
+	 * @return <br/>
+	 * @see Pageable#getList()
+	 */
+	@Override
+	public List<E> getList() {
+		return null == list ? Collections.emptyList() : list;
+	}
+
+	/**
+	 * 功能: <br/>
+	 * 
+	 * 重写:xtwin <br/>
+	 * 
+	 * @version :2016年8月1日 上午10:05:48<br/>
+	 * 
+	 * @return <br/>
+	 * @see Pageable#getStart()
+	 */
+	@Override
+	public int getStart() {
+		return (getPageNum() - 1) * getPageSize();
+	}
+}

+ 74 - 0
src/main/java/cn/efunbox/audio/page/ResPageable.java

@@ -0,0 +1,74 @@
+/**
+ * 文件名:@Pageable.java <br/>
+ * 包名:cn.efunbox.afw.core.domain.page <br/>
+ * 项目名:afw-core <br/>
+ * @author xtwin <br/>
+ */
+package cn.efunbox.audio.page;
+
+public interface ResPageable<E> {
+	
+	/**
+	 * 功能:当前页的数据内容 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年7月28日 上午11:43:27 <br/>
+	 */
+	E getList();
+
+	/**
+	 * 功能:总页数 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:47:45 <br/>
+	 */
+	int getTotalNo();
+	
+	/**
+	 * 功能:总记录数 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:48:40 <br/>
+	 */
+	long getPageTotal();
+
+	/**
+	 * 功能:页码 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:48:33 <br/>
+	 */
+	int getPageNum();
+	
+	/**
+	 * 功能:每页数据条数 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:48:25 <br/>
+	 */
+	int getPageSize();
+	
+	/**
+	 * 功能:起始位置 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午10:02:52 <br/>
+	 */
+	int getStart();
+	
+	/**
+	 * 功能:是否还有下一页 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:48:07 <br/>
+	 */
+	boolean hasNext();
+	
+	/**
+	 * 功能:是否还有上一页 <br/>
+	 *
+	 * @author xtwin <br/>
+	 * @version 2016年8月1日 上午9:47:58 <br/>
+	 */
+	boolean hasPrevious();
+}

+ 29 - 0
src/main/java/cn/efunbox/audio/utils/ResApiCode.java

@@ -0,0 +1,29 @@
+package cn.efunbox.audio.utils;
+
+public class ResApiCode extends AbstractApiCode {
+    public static final int _C_OK = 1;
+    public static final ResApiCode OK = new ResApiCode((String)"操作成功", 1);
+    public static final int _C_OPERATION_FAIL = 0;
+    public static final ResApiCode OPERATION_FAIL = new ResApiCode("操作失败", 0);
+    public static final int _C_UNKNOWN_ERROR = -1;
+    public static final ApiCode UNKNOWN_ERROR = new ApiCode("系统异常", -1);
+    public static final int _C_PARAMETER_NULL = -102;
+    public static final ApiCode PARAMETER_NULL = new ApiCode("请求参数为空", -102);
+    public static final int _C_PARAMETER_ERROR = -103;
+    public static final ApiCode PARAMETER_ERROR = new ApiCode("请求参数非法", -103);
+    public static final int _C_NOT_SUPPORT = -104;
+    public static final ApiCode NOT_SUPPORT = new ApiCode("内容来源不存在", -104);
+    public static final int _C_SIGNATURE_ERROR = -105;
+    public static final ApiCode SIGNATURE_ERROR = new ApiCode("签名不匹配", -105);
+    public static final int _C_USER_DEFINED_ERROR = -201;
+    public static final ApiCode USER_DEFINED_ERROR = new ApiCode("自定义错误类型", -201);
+    public static final int _C_EXTERNAL_ERROR = -301;
+    public static final ApiCode EXTERNAL_ERROR = new ApiCode("外部平台访问失败", -301);
+    public static final int _C_NOT_FOUND = 24000;
+    public static final ApiCode NOT_FOUND = new ApiCode("服务端侧不存在符合条件的数据", 24000);
+
+    protected ResApiCode(String message, int code) {
+        super(code, message);
+    }
+}
+

+ 95 - 0
src/main/java/cn/efunbox/audio/utils/ResApiResult.java

@@ -0,0 +1,95 @@
+package cn.efunbox.audio.utils;
+
+import java.io.Serializable;
+import java.util.Map;
+
+
+public class ResApiResult<T> implements Serializable {
+    private static final long serialVersionUID = 1L;
+    private int recode;
+    private String msg;
+    private T data;
+
+    public ResApiResult(ResApiCode ResApiCode) {
+        this(ResApiCode.getCode(), ResApiCode.getMessage());
+    }
+
+    private ResApiResult(int recode, String msg) {
+        this.recode = recode;
+        this.msg = msg;
+    }
+
+    private ResApiResult(ResApiCode ResApiCode, String msg) {
+        this.recode = recode;
+        this.msg = msg;
+    }
+
+    private ResApiResult(ResApiCode ResApiCode, T data) {
+        this(ResApiCode.getCode(), ResApiCode.getMessage());
+        this.data = data;
+    }
+
+    public static ResApiResult ok() {
+        return new ResApiResult(ResApiCode.OK);
+    }
+
+    public static ResApiResult ok(Object value) {
+        return new ResApiResult(ResApiCode.OK, value);
+    }
+
+//    public static ApiResult ok(String name, Object value) {
+//        return new ApiResult(ResApiCode.OK, Maper.of(name, value));
+//    }
+
+    public static ResApiResult ok(Map<String, Object> data) {
+        return new ResApiResult(ResApiCode.OK, data);
+    }
+
+//    public static ApiResult error(ApiException exception) {
+//        return new ApiResult(Integer.parseInt(exception.getCode()), exception.getMessage());
+//    }
+
+    public static ResApiResult error(ResApiCode code) {
+        return new ResApiResult(code);
+    }
+
+    public static ResApiResult error(ResApiCode code,String msg){
+        return new ResApiResult(code,msg);
+    }
+
+    public static ResApiResult error(ResApiCode code, Object value) {
+        return new ResApiResult(code, value);
+    }
+
+//    public static ApiResult error(ResApiCode code, String name, Object value) {
+//        return new ApiResult(code, Maper.of(name, value));
+//    }
+
+    public static ResApiResult error(ResApiCode code, Map<String, Object> data) {
+        return new ResApiResult(code, data);
+    }
+
+    public int getRecode() {
+        return recode;
+    }
+
+    public void setRecode(int recode) {
+        this.recode = recode;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public T getData() {
+        return this.data;
+    }
+
+    public void setData(T data) {
+        this.data = data;
+    }
+}