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

ipu-rest-demo/pom.xml

@@ -26,11 +26,11 @@
    </distributionManagement>
    
	<properties>
        <dockerDirectory>${project.basedir}/docker</dockerDirectory>
        <!-- 设置配置文件输出目录 -->
        <output-resources-conf>${project.basedir}/docker/target/conf</output-resources-conf>
        <output-resources-conf>${dockerDirectory}/target/conf</output-resources-conf>
        <!-- 设置依赖jar输出目录 -->
        <output-dependency-jar>${project.basedir}/docker/target/lib</output-dependency-jar>
        <dockerDirectory>${project.basedir}/docker</dockerDirectory>
        <output-dependency-jar>${dockerDirectory}/target/lib</output-dependency-jar>
		<env>dev</env>
		<skip-test>true</skip-test>
		<start-class>com.ai.ipu.server.demo.IpuRestDemoStart</start-class>
@@ -68,6 +68,21 @@
				<type>pom</type>
				<scope>import</scope>
			</dependency>
			<dependency>
				<groupId>org.springframework.cloud</groupId>
				<artifactId>spring-cloud-dependencies</artifactId>
				<version>Greenwich.RELEASE</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
			<dependency>
				<groupId>com.alibaba.cloud</groupId>
				<artifactId>spring-cloud-alibaba-dependencies</artifactId>
				<version>${org.springframework.boot}</version>
				<type>pom</type>
				<scope>import</scope>
			</dependency>
		</dependencies>
	</dependencyManagement>
@@ -117,14 +132,34 @@
		    <artifactId>guava</artifactId>
		    <version>${google.plugin}</version>
		</dependency>
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
			<version>8.0.17</version>
		</dependency>
		<!-- nacos -->
		<dependency>
			<groupId>com.alibaba.cloud</groupId>
			<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
		</dependency>
		<dependency>
			<groupId>com.alibaba.cloud</groupId>
			<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
		</dependency>
	</dependencies>
	<build>
        <directory>${project.basedir}/docker/target</directory>
        <directory>${dockerDirectory}/target</directory>
        <plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
				<version>2.4.5</version>
				    <configuration>
                        <image>
                            <name>megale/${project.artifactId}:${project.version}</name>
                        </image>
                     </configuration>			
			</plugin>
			<!-- 添加docker镜像功能 -->
			<plugin>

ipu-rest-demo/readme.md

@@ -1,5 +1,7 @@
一、启动服务脚本范例：java -Dipu.lic.path=D:/git/rest-guide/ipu-rest-demo/ipu.lic -jar target/ipu-rest-demo.jar  --server.port=8080
注意事项:需要增加证书。参数格式[-Dipu.lic.path]
由于增加了dubbo的consumer代码，需要事先启动dubbo的provider服务后再启动ipu-rest-demo。
二、区分context-path、servlet-path、static-path，正确配置拦截器的exclude-mapping
三、待办事项

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

@@ -0,0 +1,106 @@
package com.ai.ipu.server.demo.config;
import java.util.Properties;
import java.util.concurrent.Executor;
import javax.annotation.PostConstruct;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import com.ai.ipu.basic.string.StringUtil;
import com.alibaba.nacos.api.NacosFactory;
import com.alibaba.nacos.api.PropertyKeyConst;
import com.alibaba.nacos.api.config.ConfigService;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import lombok.extern.slf4j.Slf4j;
//springcloud也支持在程序中手工注册到配置中心，此时就可以监听到配置中心推送的配置文件。
//springcloud已经不再支持@NacosConfigListener，配置了也不生效。
@Component
@Slf4j
public class NacosConfig {
	private String service002Url;
	private String service002Param;
	
	@Bean(name="getService002Url")
	public String getService002Url() {
		return service002Url;
	}
	
	@Bean(name="getService002Param")
	public String getService002Param() {
		return service002Param;
	}
	
	
	@Value("${spring.cloud.nacos.config.server-addr}")
    private String nacosConfigServer;
	@Value("${spring.cloud.nacos.namespace}")
    private String nacosNamespace;
	
	@Value("${spring.cloud.nacos.dataid}")
    private String dataId;
	@Value("${spring.cloud.nacos.group}")
    private String group;
	@Value("${spring.cloud.nacos.timeout}")
    private long timeout;
	
	@PostConstruct
	public void initConfigServer() {
		try {
	        Properties properties = new Properties();
	        if (!StringUtil.isEmpty(nacosNamespace))
	        	properties.put(PropertyKeyConst.NAMESPACE, nacosNamespace);
	        properties.put(PropertyKeyConst.SERVER_ADDR, nacosConfigServer);
	        ConfigService configService = NacosFactory.createConfigService(properties);
	        String content = configService.getConfig(dataId, group, timeout);
	        //从配置中心获取到指定配置，需要自己解析后给service002Url、service002Param赋值
	        log.debug(content);
	        dealConfigServerConfig(content);
	        configService.addListener(dataId, group, new Listener() {
	            @Override
	            public void receiveConfigInfo(String configInfo) {
	            	//从配置中心获取到推送来的更新配置信息，需要自己解析给service002Url、service002Param赋值
	            	log.debug(configInfo);
	            	dealConfigServerConfig(configInfo);
	            }
	
	            @Override
	            public Executor getExecutor() {
	                return null;
	            }
	        });
	    } catch (NacosException e) {
	        log.error(e.getMessage());
	    }
	}
	
	private void dealConfigServerConfig(String configInfo) {
		if (StringUtil.isEmpty(configInfo))
			return;
		String[] configs = configInfo.split("\n\r|\n|\r|\r\n");
		int i=0;
		for (;i<configs.length;i++) {
			if (!StringUtil.isEmpty(configs[i]))
			{
				if (configs[i].indexOf("service002Url")>=0)
				{
					String[] urls = configs[i].split("=");
					service002Url = urls[1];
				}
				if (configs[i].indexOf("service002Param")>=0)
				{
					String[] params = configs[i].split("=");
					service002Param = params[1];
				}
			}
		}
	}
	
}

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

@@ -0,0 +1,17 @@
package com.ai.ipu.server.demo.config;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
public class RestConsumerConfiguration {
	@LoadBalanced
    @Bean
    public RestTemplate ipuRestTemplate() {
        return new RestTemplate();
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/cache/RedisController.java

@@ -68,7 +68,7 @@ public class RedisController {
			LOGGER.debug(result.getString("result"));				
		} catch (Exception e)
		{
			String errorMsg = "从redis中获取" + key + "错误：" + e.getMessage();
			String errorMsg = "从redis中获取" + key + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
@@ -94,7 +94,7 @@ public class RedisController {
			LOGGER.debug(result.getString("result"));		
		} catch (Exception e)
		{
			String errorMsg = "从redis中获取" + key + "错误：" + e.getMessage();
			String errorMsg = "从redis中获取" + key + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {

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

@@ -7,6 +7,9 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.common.date.TimeUtil;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
@@ -24,6 +27,7 @@ import com.ailk.common.data.IData;
@Controller
@RequestMapping("/db/table")
public class DbTableController {
	private static final transient ILogger LOGGER = IpuLoggerFactory.createLogger(DbTableController.class);
    private String connName = "test";
    private String druidConnName = "test_druid";
    private String tableName = "ipu_db_demo";
@@ -37,8 +41,10 @@ public class DbTableController {
    @RequestMapping("/select")
    public JMap select(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        int pk = param.getInt("pk", 0);
        LOGGER.info("select pk is:" + pk);
        JMap data = new JsonMap();
        data.put("pk", 0);
        data.put("pk", pk);
        Map<String, Object> re = dao.select(tableName, data);
        JMap result = new JsonMap();
        result.put("result", re);
@@ -72,7 +78,7 @@ public class DbTableController {
    public JMap insert(JMap param) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        LOGGER.info("insert pk is:" + pk);
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk);
@@ -141,11 +147,11 @@ public class DbTableController {
    @RequestMapping("/delete")
    public JMap delete(JMap params) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        int pk = params.getInt("pk", bizDao.takePK()-1);
        LOGGER.info("delete pk is:" + pk);
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk-1);
        data.put("pk", pk);
        
        Map<String, Object> content = dao.select(tableName, data);
        int re = dao.delete(tableName, data);
@@ -196,4 +202,30 @@ public class DbTableController {
        result.put("result", re);
        return result;
    }
    
    @ResponseBody
    @RequestMapping("/rollback")
    public JMap rollback(JMap param) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        LOGGER.info("insert pk is:" + pk);
        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);
        
        IpuUtility.error("rollback test");
        
        JMap conds = new JsonMap();
        conds.put("pk", pk);
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", dao.select(tableName, conds));
        return result;
    }
}

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

@@ -5,10 +5,13 @@ import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.basic.reflect.ReflectUtil;
import com.ai.ipu.basic.util.IpuUtility;
import com.ai.ipu.data.JMap;
import com.ai.ipu.test.springboot.service.IBizService;
import com.ai.ipu.test.springboot.service.IpuService;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
@@ -18,10 +21,29 @@ import com.ai.ipu.test.springboot.service.IBizService;
 */
@Controller
@RequestMapping("/dubbo")
public class DubboControl {
public class DubboConsumerController {
	private static final transient ILogger logger = IpuLoggerFactory.createLogger(DubboConsumerController.class);
	
	@Reference
	IBizService bizService;
	
	@Reference
    IpuService ipuService;
    
	@ResponseBody
    @RequestMapping("/index")
    public String index(String data) {
        logger.info("I am ConsumerController" + System.getProperty("user.home"));
        if(data==null||"".equals(data)){
            data="你啥都没有输入！";
        }
        logger.info("你输入的是"+data);
        ipuService.genaratePlumelog(data);
        logger.info("调用dubbo结束...........");
        return data;
    }
    /**
     * @author huangbo@asiainfo.com
     * @title: callBizService
@@ -29,9 +51,9 @@ public class DubboControl {
     */
    @ResponseBody
    @RequestMapping("/biz")
    public JMap callBizService(JMap params) {
    public IData callBizService(IData params) {
//        IBizService bizService = (IBizService)SpringManager.takeSpringContext().getBean("bizService"); // 获取远程服务代理
    	JMap result = bizService.queryUserInfo(params); // 执行远程方法
    	IData result = bizService.queryUserInfo(params); // 执行远程方法
        result.put("rest_result", "测试biz类型服务调用");
        return result;
    }
@@ -43,17 +65,17 @@ public class DubboControl {
     */
    @ResponseBody
    @RequestMapping("/common")
    public JMap callCommonService(JMap params) {
    public IData callCommonService(IData params) {
//        String serviceName = params.getString("service_name");
        String methodName = params.getString("method_name");
//        Object service = SpringManager.takeSpringContext().getBean(serviceName);
        JMap result = null;
        IData result = null;
        try {
            result = (JMap)ReflectUtil.invokeMethod(bizService, methodName, new Object[]{params}, new Class<?>[]{JMap.class});
            result =(IData) ReflectUtil.invokeMethod(bizService, methodName, new Object[]{params}, new Class<?>[]{IData.class});
            result.put("rest_result", "测试common类型服务调用");
        }catch (Exception e) {
            // TODO Auto-generated catch block
            IpuUtility.error( methodName + "方法调用异常:" + e.getMessage());
            IpuUtility.error( methodName + "方法调用异常:" + e.toString());
        }
        return result;
    }

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/nacos/NacosController.java

@@ -45,8 +45,8 @@ import com.github.pagehelper.util.StringUtil;
 */
@Controller
@RequestMapping("/nacos/")
public class NacosController {
	private static final ILogger LOGGER = IpuLoggerFactory.createLogger(NacosController.class);
public class IpuSpringNacosController {
	private static final ILogger LOGGER = IpuLoggerFactory.createLogger(IpuSpringNacosController.class);
	
	@Autowired
	private IpuNacosServiceImpl service;
@@ -85,7 +85,7 @@ public class NacosController {
	
		} catch (Exception e)
		{
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuCacheDataid() + "错误：" + e.getMessage();
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuCacheDataid() + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
@@ -145,7 +145,7 @@ public class NacosController {
		{
			if (noSql != null)
				noSql.abortTransaction();
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuNosqlDataid() + "错误：" + e.getMessage();
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuNosqlDataid() + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
@@ -220,7 +220,7 @@ public class NacosController {
	
		} catch (Exception e)
		{
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuDfsDataid() + "错误：" + e.getMessage();
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuDfsDataid() + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {
@@ -278,7 +278,7 @@ public class NacosController {
	
		} catch (Exception e)
		{
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuDatabaseDataid() + "错误：" + e.getMessage();
			String errorMsg = "从nacos server:" + IpuNacosConfig.getNacosServerAddr() + "同步" + nacosConfig.getIpuDatabaseDataid() + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}finally {

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/nacos/SpringCloudConsumerController.java

@@ -0,0 +1,53 @@
package com.ai.ipu.server.demo.control.nacos;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import com.ai.ipu.server.demo.config.NacosConfig;
import com.alibaba.nacos.api.exception.NacosException;
import com.google.common.collect.Maps;
@RestController
@RefreshScope
@RequestMapping("/nacos/discovery/restConsumer")
public class SpringCloudConsumerController {
	private static final Logger logger = LoggerFactory.getLogger(SpringCloudConsumerController.class);
    @Autowired
    private RestTemplate restTemplate;
    
    @Value("${spring.application.name}")
    private String appName;
    
    @Autowired
	NacosConfig config;
    
	@ResponseBody
    @GetMapping(value = "/service002")
    public String service002() throws NacosException {
		
		try {
			/*用于ipu-spring-plumlog
			Map<String, Object> variables = Maps.newHashMap();
			variables.put("message", appName);*/
			return restTemplate.getForObject("http://ipu-nacos-cloud-provider" + config.getService002Url() + "?message=" + appName , String.class);
		} catch (Exception e) {
			logger.error(e.getMessage());
		}
		
        return null;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/service/demo/IBizService.java

@@ -1,33 +0,0 @@
package com.ai.ipu.service.demo;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年10月23日下午7:25:11
 * @desc 业务服务调用案例
 */
public interface IBizService {
    
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 查询用户信息
     */
    public IData queryUserInfo(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: queryUserInfo
     * @desc: 查询用户列表
     */
    public IData queryUserList(IData param);
    
    /**
     * @author huangbo@asiainfo.com
     * @title: triggerException
     * @desc: 触发业务异常
     */
    public IData triggerException(IData param);
}

ipu-rest-demo/src/main/java/com/ipu/server/bean/LoginBean.java

@@ -2,6 +2,8 @@ package com.ipu.server.bean;
import java.awt.image.BufferedImage;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.server.util.MobileUtility;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@@ -13,12 +15,14 @@ import com.ipu.server.util.Constant;
import com.ipu.server.util.ImageVerify;
public class LoginBean extends IpuAppBean {
	private static final ILogger LOGGER = IpuLoggerFactory.createLogger(LoginBean.class);
	
	/**
	 * 初始化登陆页面,获取验证码
	 */
	public IData init(IData prama) throws Exception {
		String verifyCode = ImageVerify.getVerifyCode(6, 2);
		
		BufferedImage image = ImageVerify.getImageVerify(verifyCode);
		String imageVerifyCode = ImageVerify.getImageBase64(image);
@@ -30,6 +34,7 @@ public class LoginBean extends IpuAppBean {
		IData resultData = new DataMap();
		resultData.put("VERIFY_IMG", imageVerifyCode);
		resultData.put(Constant.Session.SESSION_ID, sessionId);
		resultData.put("VARIFY_CODE", verifyCode);
		return resultData;
	}
@@ -40,7 +45,7 @@ public class LoginBean extends IpuAppBean {
		String verifyCode = ImageVerify.getVerifyCode(6, 2);
		BufferedImage image = ImageVerify.getImageVerify(verifyCode);
		String imageVerifyCode = ImageVerify.getImageBase64(image);
		getContextData().setVerifyCode(verifyCode.toUpperCase());
//		getContextData().setVerifyCode(verifyCode.toUpperCase());
		IData resultData = new DataMap();
		resultData.put("VERIFY_IMG", imageVerifyCode);
		return resultData;
@@ -51,7 +56,7 @@ public class LoginBean extends IpuAppBean {
	 */
	public IData doLogin(IData param) throws Exception {
		/* 校验验证码 */
		String verifyCode = getContextData().getVerifyCode();
		String verifyCode = (String)getContextData().getMapData().get("VERIFY_CODE");
		String clientVerifyCode = param.getString("VARIFY_CODE");
		if (clientVerifyCode == null) {
			MobileUtility.error("验证码忘记填写了,重新输入验证码~");
@@ -66,7 +71,7 @@ public class LoginBean extends IpuAppBean {
		IData resultData = new DataMap();
		boolean isLoginSuccess = true;
		if (isLoginSuccess) {
			getContextData().setUserName(userName);
			getContextData().getMapData().put("USER_NAME", userName);
			resultData.put("LOGIN_SUCCESS", true);
		} else {
			resultData.put("LOGIN_SUCCESS", false);

ipu-rest-demo/src/main/java/com/ipu/server/core/bean/IpuAppBean.java

@@ -1,11 +1,11 @@
package com.ipu.server.core.bean;
import com.ai.ipu.server.frame.bean.AbstractBean;
import com.ipu.server.core.context.IpuContextData;
import com.ai.ipu.server.frame.context.impl.DefaultJsonContextData;
public class IpuAppBean extends AbstractBean {
	@Override
	protected IpuContextData getContextData() throws Exception {
		return (IpuContextData)(getContext().getContextData());
	protected DefaultJsonContextData getContextData() throws Exception {
		return (DefaultJsonContextData) getContext().getContextData();
	}
}

ipu-rest-demo/src/main/java/com/ipu/server/core/context/IpuContextData.java

@@ -1,9 +1,10 @@
package com.ipu.server.core.context;
import com.ai.ipu.server.frame.context.impl.DefaultContextData;
import com.ai.ipu.server.frame.context.impl.DefaultJsonContextData;
@SuppressWarnings("serial")
public class IpuContextData extends DefaultContextData {
public class IpuContextData extends DefaultJsonContextData {
	public IpuContextData() {
	}

ipu-rest-demo/src/main/java/com/ipu/server/core/session/IpuSessionManager.java

@@ -4,8 +4,7 @@ import com.ai.ipu.server.frame.context.IContextData;
import com.ai.ipu.server.frame.session.impl.AbstractSessionManager;
import com.ai.ipu.server.util.MobileUtility;
import com.ailk.common.data.IData;
import com.ipu.server.core.context.IpuContextData;
import com.ai.ipu.server.frame.context.impl.DefaultJsonContextData;
public class IpuSessionManager extends AbstractSessionManager {
	/**
@@ -14,7 +13,7 @@ public class IpuSessionManager extends AbstractSessionManager {
	@Override
	public void customVerify(String paramString, IData paramIData, IContextData paramIContextData) throws Exception {
		String userName = paramIData.getString("USER_NAME");
		String contextUserName = ((IpuContextData)paramIContextData).getUserName();
		String contextUserName = (String)((DefaultJsonContextData)paramIContextData).get("USER_NAME");
		if(userName == null || !userName.equals(contextUserName)){
			MobileUtility.error("非法操作，请重新登陆!", SESSION_ERROR_CODE);
		}

ipu-rest-demo/src/main/resources/dev/application.properties

@@ -49,12 +49,18 @@ management.security.enabled=false
#spring.devtools.restart.additional-paths=src/main/java
#spring.devtools.restart.exclude=WEB-INF/**
#使用zookeeper当注册中心
spring.main.allow-bean-definition-overriding=true
dubbo.application.name=dubbo_consumer
dubbo.protocol.name=dubbo
#dubbo.application.name=dubbo_consumer
#dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.consumer.check=false
dubbo.registry.check=false
dubbo.registry.address=zookeeper://47.105.160.21:2108
dubbo.registry.client=curator
#dubbo.registry.check=false
#dubbo.registry.address=zookeeper://47.105.160.21:2108
#dubbo.registry.client=curator
#使用nacos当注册中心
dubbo.application.name=dubbo_consumer
dubbo.registry.address=nacos://47.105.160.21:8849
dubbo.protocol.name=dubbo

ipu-rest-demo/src/main/resources/dev/bootstrap.properties

@@ -0,0 +1,11 @@
spring.cloud.nacos.config.server-addr=47.105.160.21:8849
spring.cloud.nacos.config.prefix=example
spring.cloud.nacos.config.file-extension=properties
spring.cloud.nacos.config.group=DEFAULT_GROUP
spring.cloud.nacos.dataid=example
spring.cloud.nacos.group=DEFAULT_GROUP
spring.cloud.nacos.timeout=10000
spring.cloud.nacos.namespace
spring.cloud.nacos.discovery.server-addr=47.105.160.21:8849

ipu-rest-demo/src/main/resources/sql/com/ai/ipu/ipu-db-demo.xml

@@ -7,7 +7,13 @@
		</select>
		]]>
	</sql>
	
	<sql name="delete">
		<![CDATA[
		<select id="delete" resultType="java.util.Map">
	        DELETE FROM  ipu_db_demo WHERE pk=#{pk}
		</select>
		]]>
	</sql>
	<sql name="insert">
		<![CDATA[
		<insert id="insert" resultType="java.util.Map">