@IPU_FIXBUG_2021@代码优化

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

@@ -13,7 +13,7 @@ import com.ai.ipu.restful.spring.SpringManager;
 * @desc 启动的时候需要指定参数--server.port=8080
 */
public class IpuRestDemoStart {
//    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-simple.xml";
    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-nacos.xml";
    public final static String EXCEPTION_MESSAGES_CONFIG = "exception_messages";
    
    public static void main(String[] args) {

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

@@ -64,6 +64,20 @@ public class DbSqlMgmtController {
    }
    
    @ResponseBody
    @RequestMapping("/delete")
    public JMap deleteByDbRepository(JMap param) throws Exception {
        // TODO Auto-generated method stub
    	JMap params = new JsonMap();
        params.put("pk", param.getInt("pk", 99));
        
        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
        int num = dao.executeDelete("com.ai.ipu.ipu-db-demo", "delete", params);
        JMap result = new JsonMap();
        result.put("result", num);
        return result;
    }
    
    @ResponseBody
    @RequestMapping("/refresh")
    public JMap refreshSqlRepository(JMap param) throws Exception {
        // TODO Auto-generated method stub

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

@@ -106,12 +106,16 @@ public class DbTableController {
    @RequestMapping("/update")
    public JMap update(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        int pk = param.getInt("pk", 0);
        long int_type = param.getLong("int_type", System.currentTimeMillis()%100);
        JMap data = new JsonMap();
        data.put("pk", 0);
        data.put("int_type", System.currentTimeMillis()%100);
        data.put("pk", pk);
        data.put("int_type", int_type);
        int re = dao.update(tableName, data);
        JMap result = new JsonMap();
        result.put("result_number", re);
        //"[int_type]不是主键，条件参数需要全部为主键"
        data.remove("int_type");
        result.put("content", dao.select(tableName, data));
        return result;
    }

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

@@ -1,7 +1,6 @@
package com.ai.ipu.server.demo.control.dubbo;
import org.springframework.data.annotation.Reference;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@@ -10,9 +9,11 @@ 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.restful.spring.SpringManager;
import com.ai.ipu.test.springboot.service.IBizService;
import com.ai.ipu.test.springboot.service.IpuService;
import com.ailk.common.data.IData;
import com.alibaba.dubbo.config.annotation.Reference;
/**
 * @author huangbo@asiainfo.com
@@ -34,6 +35,7 @@ public class DubboConsumerController {
	@ResponseBody
    @RequestMapping("/index")
    public String index(String data) {
//		IpuService ipuService = (IpuService)SpringManager.takeSpringContext().getBean("ipuService"); // 获取远程服务代理
        logger.info("I am ConsumerController" + System.getProperty("user.home"));
        if(data==null||"".equals(data)){
            data="你啥都没有输入！";
@@ -67,6 +69,7 @@ public class DubboConsumerController {
    @ResponseBody
    @RequestMapping("/common")
    public IData callCommonService(IData params) {
//    	IBizService bizService = (IBizService)SpringManager.takeSpringContext().getBean("bizService"); // 获取远程服务代理
//        String serviceName = params.getString("service_name");
        String methodName = params.getString("method_name");
//        Object service = SpringManager.takeSpringContext().getBean(serviceName);

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

@@ -55,7 +55,7 @@ spring.main.allow-bean-definition-overriding=true
#dubbo.protocol.name=dubbo
dubbo.protocol.port=-1
dubbo.consumer.check=false
#dubbo.registry.check=false
dubbo.registry.check=false
#dubbo.registry.address=zookeeper://47.105.160.21:2108
#dubbo.registry.client=curator
@@ -64,3 +64,5 @@ dubbo.application.name=dubbo_consumer
dubbo.registry.address=nacos://47.105.160.21:8849
dubbo.protocol.name=dubbo
#spring-data-es配置
spring.elasticsearch.rest.uris=http://47.105.160.21:10020

ipu-rest-demo/src/main/resources/dev/dubbo-consumer-simple.xml

@@ -15,6 +15,8 @@
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="bizService"
		interface="com.ai.ipu.service.demo.IBizService" />
		interface="com.ai.ipu.test.springboot.service.IBizService" />
		<dubbo:reference id="ipuService"
		interface="com.ai.ipu.test.springboot.service.IpuService" />
	<!-- 服务注册配置 end =========================== -->
</beans>

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

@@ -1,6 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
	xmlns:context="http://www.springframework.org/schema/context"
	xmlns:mvc="http://www.springframework.org/schema/mvc"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
@@ -11,7 +11,8 @@
		http://www.springframework.org/schema/mvc/spring-mvc.xsd">
	<!-- 自定义的control扫描目录 -->
    <context:component-scan base-package="com.ai.ipu.server.demo" />
    <!-- 扫描ipu-spring-nacos -->
    <context:component-scan base-package="com.ai.ipu.nacos.*" />
    <bean id="mongoTranscationAspects" class="com.ai.ipu.server.demo.aspect.MongoTransactionAspect" />
    <!-- <bean id="mongoTranscationAspects" class="com.ai.ipu.server.demo.aspect.MongoTransactionAspect" /> -->
</beans>