Merge branch 'master' of http://10.1.235.20:3000/rest/rest-guide

ipu-rest-demo/pom.xml

@@ -37,34 +37,6 @@
	</properties>
	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>javax.servlet-api</artifactId>
			<scope>provided</scope>
		</dependency>
		<!-- 由于重写了spring的部分类，需要置前引入，提高优先级 -->
		<dependency>
			<groupId>com.ai.ipu.server</groupId>
			<artifactId>ipu-restful</artifactId>
		</dependency>
		<!-- spring监听,admin-client会引入actuator -->
		<dependency>  
		    <groupId>de.codecentric</groupId>  
		    <artifactId>spring-boot-admin-starter-client</artifactId>
		</dependency>
		<dependency>
			<groupId>com.ai.wade</groupId>
			<artifactId>wade-data</artifactId>
		</dependency>
		<dependency>
			<groupId>com.ai.ipu</groupId>
			<artifactId>ipu-server-web</artifactId>
		</dependency>
		<!-- dubbo相关依赖 -->
		<dependency>
			<groupId>com.alibaba</groupId>

ipu-rest-demo/sql/ipu_db_demo.sql

@@ -0,0 +1,30 @@
/*
Navicat MySQL Data Transfer
Source Server         : ipu测试-121.42.183.206
Source Server Version : 50625
Source Host           : 121.42.183.206:3307
Source Database       : test
Target Server Type    : MYSQL
Target Server Version : 50625
File Encoding         : 65001
Date: 2019-03-03 00:08:09
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for ipu_db_demo
-- ----------------------------
DROP TABLE IF EXISTS `ipu_db_demo`;
CREATE TABLE `ipu_db_demo` (
  `pk` int(255) NOT NULL COMMENT '主键',
  `string_type` varchar(255) NOT NULL COMMENT '字符串字段',
  `int_type` int(255) NOT NULL COMMENT '整型字段',
  `decimal_type` decimal(4,2) NOT NULL COMMENT '小数值字段',
  `date_type` date NOT NULL COMMENT '日期字段',
  `datetime_type` datetime NOT NULL COMMENT '日期时间字段',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/IpuRestDemoStart.java

@@ -2,6 +2,7 @@ package com.ai.ipu.server.demo;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.restful.boot.IpuRestApplication;
import com.ai.ipu.restful.spring.SpringManager;
@@ -13,10 +14,15 @@ import com.ai.ipu.restful.spring.SpringManager;
 */
public class IpuRestDemoStart {
    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-simple.xml";
    public final static String EXCEPTION_MESSAGES_CONFIG = "exception_messages";
    
    public static void main(String[] args) {
        /*在spring中注册dubbo消费者配置*/
        SpringManager.registerSpringContext(
                new ClassPathXmlApplicationContext(new String[] { DUBBO_CONSUMER_CONFIG }));
        /*注册dubbo异常信息编码配置*/
        IpuBaseException.registerCode(EXCEPTION_MESSAGES_CONFIG);
        /*启动SpringBoot服务*/
        IpuRestApplication.start(args);
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/common/ExceptionController.java

@@ -5,38 +5,69 @@ import org.springframework.web.bind.annotation.RequestMapping;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年1月5日下午18:05:42
 * @desc 各类异常处理范例
 */
@Controller
@RequestMapping("/excep")
public class ExceptionController {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: defaultException
     * @desc: 抛出默认异常的范例
     */
    @RequestMapping("/default")
    public JMap defaultException(JMap data) throws Exception {
        if(true){
            IpuUtility.error("抛出默认异常");
        }
        return data;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: customException
     * @desc: 抛出定制异常的范例
     */
    @SuppressWarnings("unused")
    @RequestMapping("/custom")
    public JMap customException(JMap data) throws Exception {
        JMap result = new JsonMap();
        if(true){
            throw new Exception("抛出定制异常");
        }
        return data;
        return result;
    }
    
    @RequestMapping("/default")
    public JMap defaultException(JMap data) throws Exception {
    /**
     * @author huangbo@asiainfo.com
     * @title: codeException
     * @desc: 抛出异常编码的范例
     */
    @RequestMapping("/code")
    public JMap codeException(JMap data) throws Exception {
        if(true){
            IpuUtility.error("抛出默认异常");
            IpuUtility.errorCode("100");
        }
        return data;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: uiExceptionHandler
     * @desc: 局部异常，对应全局异常
     * @title: codeMatcherException
     * @desc: 抛出有可变参数的异常编码的范例
     */
    /*@ExceptionHandler
    public ModelAndView uiExceptionHandler(Exception ex){
        ModelAndView mv = new ModelAndView("/custom");
        mv.addObject("exception", ex);
        return mv;
    }*/
    @RequestMapping("/matcher")
    public JMap codeMatcherException(JMap data) throws Exception {
        if(true){
            IpuUtility.errorCode("200", "Request");
        }
        return data;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/common/LocalExceptionController.java

@@ -0,0 +1,59 @@
package com.ai.ipu.server.demo.control.common;
import org.apache.commons.lang3.exception.ExceptionUtils;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.servlet.ModelAndView;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.data.JMap;
import com.ai.ipu.restful.util.IpuRestConstant;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年3月1日上午12:18:00
 * @desc 局部异常的处理范例
 */
@Controller
@RequestMapping("/excep")
public class LocalExceptionController {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: localException
     * @desc: 抛出局部异常的范例
     */
    @RequestMapping("/local")
    public JMap localException(JMap data) throws Exception {
        if(true){
            IpuUtility.error("抛出局部异常");
        }
        return data;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: localExceptionHandler
     * @desc: 捕获局部异常，对应全局异常
     */
    @ExceptionHandler
    public ModelAndView localExceptionHandler(Exception e){
        ModelAndView mv = new ModelAndView("/custom"); //ModelAndView只能对应Jsp吗？
        if(IpuBaseException.class.isAssignableFrom(e.getClass())){
            String resultCode = ((IpuBaseException)e).getCode();
            resultCode = StringUtil.isEmpty(resultCode) ? IpuRestConstant.ResultCode.ERROR_CODE : resultCode;
            mv.addObject("error_msg", e.getMessage());
            mv.addObject("error_code", resultCode);
            mv.addObject("error_trace", ExceptionUtils.getStackTrace(e));
            return mv;
        }else{
            mv.addObject("error_msg", e.getMessage());
            mv.addObject("error_trace", ExceptionUtils.getStackTrace(e));
            return mv;
        }
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/data/ContextDataController.java

@@ -6,25 +6,29 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.restful.frame.context.IpuContextData;
import com.ai.ipu.restful.util.IpuRestConstant;
import com.ai.ipu.restful.web.ServletManager;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年11月7日下午11:36:42
 * @desc 上下文使用范例
 * @desc 上下文Context操作范例
 */
@Controller
@RequestMapping("/context")
public class ContextDataController {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: createContext
     * @desc: 创建上下文Context的范例
     */
    @ResponseBody
    @RequestMapping("/create")
    public IData createContext(IData param) {
    public JMap createContext(JMap param) {
        // TODO Auto-generated method stub
        IpuContextData ipuContextData = new IpuContextData();
        Iterator<String> it = param.keySet().iterator();
@@ -33,34 +37,46 @@ public class ContextDataController {
            key = it.next();
            ipuContextData.put(key, param.get(key).toString());
        }
        ServletManager.getSession().setAttribute(IpuRestConstant.IPU_CONTEXT, ipuContextData.toString());
        IData result = new DataMap();
        result.put("msg", "上下文创建成功");
        ServletManager.storageContextData(ipuContextData);
        JMap result = new JsonMap();
        result.put("msg", "创建上下文");
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: updateContext
     * @desc: 修改上下文Context的范例
     */
    @ResponseBody
    @RequestMapping("/update")
    public IData updateContext(IData param) {
    public JMap updateContext(JMap param) {
        IpuContextData ipuContextData = ServletManager.getContextData();
        Iterator<String> it = param.keySet().iterator();
        String key;
        /*请求结束时，上下文如果有修改，则回写到Session中*/
        while(it.hasNext()){
            key = it.next();
            ipuContextData.put(key, param.get(key).toString());
        }
        
        IData result = new DataMap();
        result.put("msg", "上下文修改成功");
        JMap result = new JsonMap();
        result.put("msg", "修改上下文");
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: takeContext
     * @desc: 获取上下文Context的范例
     */
    @ResponseBody
    @RequestMapping("/get")
    public IData getContext(IData params) {
    @RequestMapping("/take")
    public JMap takeContext(JMap params) {
        IpuContextData ipuContextData = ServletManager.getContextData();
        IData result = new DataMap();
        result.put("context", ipuContextData.toString());
        JMap result = new JsonMap();
        result.put("context", ipuContextData == null ? "" : ipuContextData.toString());
        result.put("msg", "获取上下文");
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/data/DataController.java

@@ -1,84 +1,43 @@
package com.ai.ipu.server.demo.control.data;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.basic.util.IpuBaseException;
import com.ai.ipu.data.JMap;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月30日上午10:11:03
 * @desc 数据请求操作范例
 */
@Controller
@RequestMapping("/request")
@RequestMapping("/data")
public class DataController {
	
    /**
     * @author huangbo@asiainfo.com
     * @title: request
     * @desc: JMap类型数据请求范例
     */
    @ResponseBody
    @RequestMapping("/jget")
    public JMap getRequest(JMap params) {
        params.put("msg", "测试get请求传参");
        return params;
    @RequestMapping("/jmap")
    public JMap request(JMap param) {
        param.put("msg", "JMap请求传参");
        return param;
    }
    
    @ResponseBody
    @RequestMapping("/jpost")
    public JMap postRequest(JMap params) {
        params.put("msg", "测试post请求传参");
        return params;
    }
    
	@ResponseBody
	@RequestMapping("/get")
    public IData getRequest(IData params) {
		params.put("msg", "测试get请求传参");
        return params;
    }
	
	@ResponseBody
	@RequestMapping("/post")
    public IData postRequest(IData params) {
		params.put("msg", "测试post请求传参");
        return params;
    }
	
    @RequestMapping("/error")
    public void error() throws Exception {
        throw new Exception("使用默认异常抛出全局data异常");
    }
	
    @RequestMapping("/ipuerror")
    public void ipuerror() throws Exception {
        throw new IpuBaseException("使用IPU异常抛出全局data异常");
    }
	
	@ResponseBody
	@RequestMapping("/map")
    public Map<String, String> mapRequest(@RequestBody Map<String, String> params) {
		params.put("msg", "测试post请求传参");
        return params;
    }
	
	@ResponseBody
	@RequestMapping("/string")
    public String mapRequest(String key) {
        return key;
    }
	
	/**
	 * 通过注解RequestParam获取指定的key的参数
	 * @param data
	 * @return
	 * @author huangbo@asiainfo.com
	 * @title: request
	 * @desc: IData类型数据请求范例
	 */
	@ResponseBody
	@RequestMapping(value="/data")
    public String stringRequest(@RequestParam(value="data")String data) {
		IData params = new DataMap(data);
		params.put("msg", "测试get请求传参");
		params.put("data", data);
        return params.toString();
	@RequestMapping("/idata")
    public IData request(IData param) {
	    param.put("msg", "IData请求传参");
        return param;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/data/DataOtherController.java

@@ -0,0 +1,60 @@
package com.ai.ipu.server.demo.control.data;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月31日上午10:11:03
 * @desc 数据请求操作范例
 */
@Controller
@RequestMapping("/data")
public class DataOtherController {
    /**
     * @author huangbo@asiainfo.com
     * @title: mapRequest
     * @desc: Map类型数据请求范例
     */
    @ResponseBody
    @RequestMapping("/map")
    public Map<String, String> mapRequest(@RequestBody Map<String, String> params) {
        params.put("msg", "测试post请求传参");
        return params;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: stringRequest
     * @desc: 字符串类型数据请求范例
     */
    @ResponseBody
    @RequestMapping("/string")
    public String stringRequest(String key) {
        return key;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: stringDataRequest
     * @desc: 指定字段的字符串类型数据请求范例
     * 通过注解RequestParam获取指定的key的参数
     */
    @ResponseBody
    @RequestMapping(value="/data")
    public String stringDataRequest(@RequestParam(value="data")String data) {
        JMap param = new JsonMap(data);
        param.put("msg", "测试get请求传参");
        param.put("data", data);
        return param.toString();
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/data/SessionController.java

@@ -9,23 +9,29 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.restful.web.ServletManager;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月28日下午11:11:46
 * @desc Session操作的存取类，默认支持redis
 * @desc 会话Session的操作范例
 * 支持redis
 */
@Controller
@RequestMapping("/session")
public class SessionController {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: setSession
     * @desc: 设置会话Session的范例
     */
    @ResponseBody
    @RequestMapping("/set")
    public IData setSession(IData param) {
    public JMap setSession(JMap param) {
        // TODO Auto-generated method stub
        HttpSession session = ServletManager.getSession();
        Iterator<String> it = param.keySet().iterator();
@@ -34,15 +40,21 @@ public class SessionController {
            key = it.next();
            session.setAttribute(key, param.get(key));
        }
        IData result = new DataMap();
        result.put("msg", "session保存成功");
        JMap result = new JsonMap();
        result.put("msg", "设置会话Session");
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: getSession
     * @desc: 获得会话Session的范例
     */
    @ResponseBody
    @RequestMapping("/get")
    public IData getSession(IData params) {
        IData session = ServletManager.transSession(ServletManager.getRequest().getSession());
    public JMap getSession(JMap params) {
        JMap session = ServletManager.transSession(ServletManager.getSession());
        session.put("msg", "获得会话Session");
        return session;
    }
    

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbController.java

@@ -1,52 +0,0 @@
package com.ai.ipu.server.demo.control.db;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.DemoBizDao;
import com.ai.ipu.server.demo.dao.DemoDao;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@Controller
@RequestMapping("/db")
public class DbController {
    @ResponseBody
    @RequestMapping("/insert")
    public IData insert(IData params) {
        return null;
    }
    
    @ResponseBody
    @RequestMapping("/delete")
    public IData delete(IData params) {
        return null;
    }
    
    @ResponseBody
    @RequestMapping("/update")
    public IData update(IData params) throws Exception {
        DemoDao dao = IpuDaoManager.takeDao(DemoDao.class, "test");
        int dbResult = dao.update();
        IData result = new DataMap();
        result.put("UPDATE_NUM", dbResult);
        return result;
    }
    
    @ResponseBody
    @RequestMapping("/select")
    public IData select(IData params) throws Exception {
        DemoBizDao dao = IpuDaoManager.takeDao(DemoBizDao.class, "test");
        List<Map<String, Object>> dbResult = dao.select();
        IData result = new DataMap();
        /*dbResult需要转化成json字符串*/
        result.put("IPU_MEMBERS", dbResult);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbSqlController.java

@@ -0,0 +1,40 @@
package com.ai.ipu.server.demo.control.db;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.BizSqlDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年3月2日下午8:35:22
 * @desc 基于SQL的操作范例
 */
@Controller
@RequestMapping("/db/sql")
public class DbSqlController {
    private String connName = "test";
    
    /**
     * @author huangbo@asiainfo.com
     * @title: executeSql
     * @desc: 执行SQL查询的范例
     */
    @ResponseBody
    @RequestMapping("/execute")
    public JMap executeSql(JMap param) throws Exception {
        BizSqlDao dao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        List<Map<String, Object>> dataResult = dao.executeSql();
        JMap result = new JsonMap();
        result.put("result", dataResult);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbTableController.java

@@ -1,6 +1,5 @@
package com.ai.ipu.server.demo.control.db;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -9,150 +8,190 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.common.date.TimeUtil;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.DemoTableBizDao;
import com.ai.ipu.server.demo.dao.BizSqlDao;
import com.ai.ipu.server.demo.dao.CommonTableDao;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年9月13日下午4:14:55
 * @desc 单表快捷操作范例
 * 建表语句
 CREATE TABLE `ipu_db_test` (
  `pk` varchar(20) CHARACTER SET utf8 NOT NULL COMMENT '键主',
  `string_type1` varchar(255) CHARACTER SET utf8 DEFAULT NULL COMMENT '字符串(可为空)',
  `string_type2` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '字符串(不为空)',
  `int_type1` int(11) DEFAULT NULL COMMENT '整型(可为空)',
  `int_type2` int(11) NOT NULL COMMENT '整型(不为空)',
  `date_type1` datetime DEFAULT NULL COMMENT '日期(不为空)',
  `date_type2` datetime NOT NULL COMMENT '日期(不为空)',
  `decimal_type1` decimal(10,0) DEFAULT NULL COMMENT '小数(可为空)',
  `decimal_type2` decimal(10,0) NOT NULL COMMENT '小数(不为空)',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 * @desc 基于单表CRUD的操作范例
 */
@Controller
@RequestMapping("/db/table")
public class DbTableController {
    private String connName = "test";
    private String druidConnName = "test_druid";
    private String tableName = "ipu_db_test";
    private String tableName = "ipu_db_demo";
    
    /**
     * @author huangbo@asiainfo.com
     * @title: select
     * @desc: 基于主键查询数据的范例
     */
    @ResponseBody
    @RequestMapping("/select")
    public IData select(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap select(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        
        Map<String, Object> re = dao.select(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: selectByCond
     * @desc: 基于条件查询数据的范例
     */
    @ResponseBody
    @RequestMapping("/selectby")
    public IData selectByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> condition = new HashMap<String, Object>();
        condition.put("int_type1", "111111");
        
    public JMap selectByCond(IData param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap condition = new JsonMap();
        condition.put("int_type", "0");
        List<Map<String, Object>> re = dao.selectByCond(tableName, condition);
        IData result = new DataMap();
        result.put("RESULT", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: insert
     * @desc: 新增数据的范例
     */
    @ResponseBody
    @RequestMapping("/insert")
    public IData insert(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("pk", 0);
        data.put("string_type1", "字符串1");
        data.put("string_type2", "字符串2");
        data.put("int_type1", "111111");
        data.put("int_type2", "222222");
        data.put("date_type1", TimeUtil.getSysTime());
        data.put("date_type2", TimeUtil.getSysTime());
        data.put("decimal_type1", "9.99");
        data.put("decimal_type2", "99.9");
    public JMap insert(JMap param) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk);
        data.put("string_type", "字符串"+pk);
        data.put("int_type", pk);
        data.put("decimal_type", "10."+pk);
        data.put("date_type", TimeUtil.getSysDate());
        data.put("datetime_type", TimeUtil.getSysTime());
        int re = dao.insert(tableName, data);
        IData result = new DataMap();
        
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", dao.select(tableName, data));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: update
     * @desc: 基于主键修改数据的范例
     */
    @ResponseBody
    @RequestMapping("/update")
    public IData update(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap update(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        data.put("int_type2", "111111");
        
        data.put("int_type", System.currentTimeMillis()%100);
        int re = dao.update(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", dao.select(tableName, data));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: updateByCond
     * @desc: 基于条件修改数据的范例
     */
    @ResponseBody
    @RequestMapping("/updateby")
    public IData updateByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("string_type2", "字符串1");
        data.put("int_type2", "111111");
        Map<String, Object> condition = new HashMap<String, Object>();
        condition.put("int_type1", "111111");
    public JMap updateByCond(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("int_type", System.currentTimeMillis()%100);
        JMap condition = new JsonMap();
        condition.put("string_type", "字符串0");
        
        int re = dao.updateByCond(tableName, data, condition);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        condition.put("pk", 0);
        result.put("content", dao.select(tableName, condition));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: delete
     * @desc: 基于主键删除数据的范例
     */
    @ResponseBody
    @RequestMapping("/delete")
    public IData delete(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("pk", 0);
    public JMap delete(JMap params) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk-1);
        
        Map<String, Object> content = dao.select(tableName, data);
        int re = dao.delete(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", content);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: deleteByCond
     * @desc: 基于条件删除数据的范例
     */
    @ResponseBody
    @RequestMapping("/deleteby")
    public IData deleteByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("string_type1", "字符串1");
        data.put("int_type1", "111111");
    public JMap deleteByCond(JMap params) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("string_type", "字符串"+(pk-1));
        List<Map<String, Object>> contents = dao.selectByCond(tableName, data);
        Map<String, Object> content = (contents!=null&&contents.size()>0)?contents.get(0):null;
        int re = dao.deleteByCond(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", content);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: selectByDruid
     * @desc: 基于主键查询数据的范例，使用druid连接池
     */
    @ResponseBody
    @RequestMapping("druid/select")
    public IData selectByDruid(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, druidConnName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap selectByDruid(JMap params) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, druidConnName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        
        Map<String, Object> re = dao.select(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/dubbo/DubboControl.java

@@ -10,10 +10,21 @@ import com.ai.ipu.restful.spring.SpringManager;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年10月24日上午00:13:37
 * @desc Dubbo客户端的使用范例
 */
@Controller
@RequestMapping("/dubbo")
public class DubboControl {
    /**
     * @author huangbo@asiainfo.com
     * @title: callBizService
     * @desc: Dubbo客户端调用服务范例
     */
    @ResponseBody
    @RequestMapping("/biz")
    public IData callBizService(IData params) {
@@ -23,6 +34,11 @@ public class DubboControl {
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: callCommonService
     * @desc: Dubbo客户端调用通用服务范例
     */
    @ResponseBody
    @RequestMapping("/common")
    public IData callCommonService(IData params) {

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/other/MsgFrameController.java

@@ -1,4 +1,4 @@
package com.ai.ipu.server.demo.control.other;
package com.ai.ipu.server.demo.control.mq;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -11,10 +11,21 @@ import com.ai.ipu.restful.util.IpuRestConstant;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年4月30日下午3:17:49
 * @desc MsgFrame的使用范例
 */
@Controller
@RequestMapping("/msgframe")
public class MsgFrameController{
    /**
     * @author huangbo@asiainfo.com
     * @title: produceMessage
     * @desc: MsgFrame消息生产者范例
     */
    @ResponseBody
    @RequestMapping("/produce")
    public IData produceMessage(IData params){

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/ui/UiController.java

@@ -8,18 +8,18 @@ import javax.servlet.http.HttpServletResponse;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
/**
 * @author huangbo
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2017年11月26日 下午11:50:04
 * @desc 
 * @desc 常用页面范例
 */
@Controller
@RequestMapping("/ui")
public class UiController {
	@RequestMapping("/login")
    public String login() {
    public String pageLogin() {
        return "../login.html";
    }
	
@@ -31,4 +31,22 @@ public class UiController {
		buff.append("/index.html");
		response.sendRedirect(buff.toString());
	}
	
	@RequestMapping("/404")
    public void page404(HttpServletRequest request, HttpServletResponse response) throws IOException  {
        StringBuilder buff = new StringBuilder();
        buff.append("../ipuui/");
        buff.append("demo");
        buff.append("/index.html");
        response.sendRedirect(buff.toString());
    }
	
	@RequestMapping("/error")
    public void pageError(HttpServletRequest request, HttpServletResponse response) throws IOException  {
        StringBuilder buff = new StringBuilder();
        buff.append("../ipuui/");
        buff.append("demo");
        buff.append("/index.html");
        response.sendRedirect(buff.toString());
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/BizSqlDao.java

@@ -0,0 +1,40 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:35
 * @desc 基于SQL的操作范例
 * 业务dao不暴露和业务无关的方法.
 */
public class BizSqlDao extends AbstractBizDao{
    public BizSqlDao(String connName) throws IOException {
        super(connName);
    }
    public List<Map<String, Object>> executeSql() throws Exception {
        String sql = "SELECT * FROM ipu_db_demo";
        List<Map<String, Object>> dataResult = getBasicDao().executeSelect(sql);
        return dataResult;
    }
    
    public int takePK() throws Exception {
        String sql = "SELECT * FROM ipu_db_demo order by datetime_type desc";
        Map<String, Object> dataResult = getBasicDao().executeSelectFirst(sql);
        int pk;
        if(dataResult==null||dataResult.isEmpty()){
            pk = 0;
        }else{
            pk = Integer.parseInt(dataResult.get("pk").toString());
            pk++;
        }
        return pk;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoTableBizDao.java

@@ -10,24 +10,11 @@ import com.ai.ipu.database.dao.impl.AbstractBizDao;
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年9月6日下午10:05:42
 * @desc 单表增删改查测试
 * 建表语句
 CREATE TABLE `ipu_db_test` (
  `pk` varchar(20) CHARACTER SET utf8 NOT NULL COMMENT '键主',
  `string_type1` varchar(255) CHARACTER SET utf8 DEFAULT NULL COMMENT '字符串(可为空)',
  `string_type2` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '字符串(不为空)',
  `int_type1` int(11) DEFAULT NULL COMMENT '整型(可为空)',
  `int_type2` int(11) NOT NULL COMMENT '整型(不为空)',
  `date_type1` datetime DEFAULT NULL COMMENT '日期(不为空)',
  `date_type2` datetime NOT NULL COMMENT '日期(不为空)',
  `decimal_type1` decimal(10,0) DEFAULT NULL COMMENT '小数(可为空)',
  `decimal_type2` decimal(10,0) NOT NULL COMMENT '小数(不为空)',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 * @desc 通用基于单表CRUD的操作范例
 */
public class DemoTableBizDao extends AbstractBizDao{
public class CommonTableDao extends AbstractBizDao{
    public DemoTableBizDao(String connName) throws IOException {
    public CommonTableDao(String connName) throws IOException {
        super(connName);
    }

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoBizDao.java

@@ -1,40 +0,0 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:35
 * @desc 内置一个BasicDao,让业务dao不暴露和业务无关的方法.
 */
public class DemoBizDao extends AbstractBizDao{
    public DemoBizDao(String connName) throws IOException {
        super(connName);
    }
    public int insert() {
        return -1;
    }
    public int delete() {
        return -1;
    }
    public int update() throws Exception {
        String sql = "update TAB_IPU_MEMBER set PASSWORD='000002'";
        int result = dao.executeUpdate(sql, null);
        return result;
    }
    public List<Map<String, Object>> select() throws Exception {
        String sql = "SELECT * FROM tab_ipu_member";
        List<Map<String, Object>> dbResult = getBasicDao().executeSelect(sql);
        return dbResult;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoDao.java

@@ -1,42 +0,0 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.conn.SqlSessionManager;
import com.ai.ipu.database.dao.impl.BasicDao;
import com.ai.ipu.database.dao.impl.SqlDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:43
 * @desc 继承BasicDao,让每个业务dao具备全量方法.
 */
public class DemoDao extends BasicDao {
    public DemoDao(String connName) throws IOException {
        super(connName);
    }
    public int insert() {
        return -1;
    }
    public int delete() {
        return -1;
    }
    public int update() throws Exception {
        String sql = "update TAB_IPU_MEMBER set PASSWORD='000002'";
        int result = executeUpdate(sql, null);
        return result;
    }
    public List<Map<String, Object>> select() throws Exception {
        String sql = "SELECT * FROM tab_ipu_member";
        List<Map<String, Object>> dbResult = executeSelect(sql);
        return dbResult;
    }
}

ipu-rest-demo/src/main/resources/exception_messages_zh_CN.properties

@@ -1,2 +1,2 @@
100=条件参数不能为空
200=[%v]不是主键，条件参数需要全部为主键
200=[%v]参数异常

ipu-rest-demo/src/main/resources/ipu-spring-mvc.xml

@@ -11,22 +11,4 @@
		http://www.springframework.org/schema/mvc/spring-mvc.xsd">
	<!-- 自定义的control扫描目录 -->
    <context:component-scan base-package="com.ai.ipu.server.demo" />
    
    <!-- 定义文件上传解析器 -->
	<!-- <bean id="multipartResolver"
		class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
		设定默认编码
		<property name="defaultEncoding" value="UTF-8"></property>
		设定文件上传的最大值为5MB，5*1024*1024
		<property name="maxUploadSize" value="5242880"></property>
		设定文件上传时写入内存的最大值，如果小于这个参数不会生成临时文件，默认为10240
		<property name="maxInMemorySize" value="40960"></property>
		上传文件的临时路径
		<property name="uploadTempDir" value="fileUpload/temp"></property>
		延迟文件解析
		<property name="resolveLazily" value="true" />
	</bean> -->
    
    <!-- 不处理静态资源 -->
    <mvc:default-servlet-handler/>
</beans> 

ipu-rest-demo/src/main/resources/ipu-spring-mvc2.xml

@@ -1,19 +0,0 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
           
    <!-- 处理器映射器 将bean的name作为url进行查找 -->
	<bean class="org.springframework.web.servlet.handler.BeanNameUrlHandlerMapping" />
	<bean name="/name" class="com.ai.ipu.server.demo.control.BeanNameUrlController" />
	
	<bean class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">
		<property name="mappings">
			<props>
				<prop key="/url">urlController</prop>
			</props>
		</property>
	</bean>
	<bean id="urlController" class="com.ai.ipu.server.demo.control.UrlController" />
</beans>