center_config

变更历史

版本	变更内容	变更时间	变更人员
v0.01	初稿	2018-07-24	wuxw

本页内容

1. 配置相关表
2. 外部应用表（c_app）配置
3. 服务提供表（c_service）配置
4. 路由表配置（c_route）
5. 查询类服务实现表配置（c_service_sql）

配置相关表

-- 外部应用表
select a.* from c_app a ;
-- 服务提供表
select a.* from c_service a;
-- 外部应用 和 服务关联表
select a.* from c_route a;

-- 查询类 服务实现表
select a.* from c_service_sql a;

外部应用表（c_app）配置

表字段	类型	约束	长度	可空	配置说明
id	int	1	-	否	自动增长
app_id	String	1	10	否	开始于8000418001，新增加1
name	String	1	50	否	外部应用名称，如 微信小程序
security_code	String	?	64	是	加密掩码，如123456
while_list_ip	String	?	200	是	白名单ip 多个之间用;隔开
black_list_ip	String	?	200	是	黑名单ip 多个之间用;隔开
remark	String	?	200	是	备注信息
status_cd	String	1	2	否	数据状态，0在用，1失效

security_code 不为空则sign签名校验，为空则不做校验

while_list_ip 不为空则只有配置了ip才能访问，为空不做校验

black_list_ip 不为空则配置了ip不能访问，为空不做校验

相关insert语句，请参考：

insert into c_app(app_id,`name`,security_code,remark,status_cd)
values('8000418001','内部测试应用','WEBURFPKIFJUHNCJUEIKMKJUJHULSMNCHDY89KMC','记得删除','0');

服务提供表（c_service）配置

表字段	类型	约束	长度	可空	配置说明
id	int	1	-	否	自动增长
service_id	String	1	12	否	服务编码ID，开始于1003180001，新增加1
service_code	String	1	50	否	自定义，命名方式查询类query.+目标系统+.+业务名称 保存类 save.+目标系统+.+业务名称 修改类 modify.+目标系统+.+业务名称 删除类 remove.+目标系统+.+业务名称 例如：query.user.userinfo save.user.adduserinfo
business_type_cd	String	1	4	否	业务项类型，参考c_business_type表
name	String	1	50	否	服务名称
seq	int	1	-	否	顺序 只有同步方式下根据seq从小到大调用接口
messageQueueName	String	?	50	是	消息队里名称，只有异步时有用
is_instance	String	1	2	否	是否Instance过程 Y 需要，N不需要
url	String	?	200	是	目标地址
method	String	?	50	是	方法 空 为http post LOCAL_SERVICE 为调用本地服务 其他为webservice方式调用
timeout	int	?	-	是	超时时间，单位为秒
retry_count	int	?	-	是	重试次数
provide_app_id	String	1	30	否	服务提供appId
status_cd	String	1	2	否	数据状态，0在用，1失效

messageQueueName 在异步的情况下使用，为落地方系统kafka topic 如 commentServiceTopic

/**
 * kafka侦听
 * Created by wuxw on 2018/4/15.
 */
public class CommentServiceKafka extends BaseController {

    @KafkaListener(topics = {"commentServiceTopic"})
    public void listen(ConsumerRecord<?, ?> record) {
    }
}

相关insert语句，请参考

insert into c_service(service_id,service_code,business_type_cd,`name`,seq,messageQueueName,url,provide_app_id,status_cd)
values('1003180001','query.order.orderInfo','Q','订单信息',1,'','http://center-service/businessApi/query','8000418001','0');

路由表配置（c_route）

表字段	类型	约束	长度	可空	配置说明
id	int	1	-	否	自动增长
app_id	String	1	10	否	关联c_app表
service_id	String	1	12	否	关联c_service表
order_type_cd	String	1	4	否	查看订单类型说明
invoke_limit_times	int	?	-	是	调用次数限制
invoke_model	String	1	1	否	调用方式S同步方式，A异步方式
status_cd	String	1	2	否	数据状态，0在用，1失效

invoke_model 为同步 S时，表c_service 表中的url字段不能为空；为A时 c_service 表中的messageQueueName字段不能为空

相关insert语句，请参考

insert into c_route(app_id,service_id,invoke_model,order_type_cd,status_cd) values(
'8000418001','1003180001','S','Q','0'
);

查询类服务实现表配置（c_service_sql）

表字段	类型	约束	长度	可空	配置说明
id	int	1	-	否	自动增长
service_code	String	1	50	否	关联c_service表
name	String	1	50	否	名称
params	String	1	500	否	查询参数
query_model	String	1	1	否	查询方式 1、sql,2、存储过程，3、执行java代码
sql	String	?	-	是	在查询方式为1 的情况下 执行sql
proc	String	?	200	是	在查询方式为2时执行，存储过程，不推荐
java_script	String	?	-	是	在查询方式为3时执行java脚本代码
template	String	?	-	是	在查询方式为1 时，输出模板
remark	String	?	200	是	描述
status_cd	String	1	2	否	数据状态，0在用，1失效

sql 配置方式 如下格式：

{
	"param1": "SELECT co.app_id appId,co.create_time createTime,co.ext_transaction_id extTransactionId,co.finish_time finishTime,co.order_type_cd orderTypeCd,co.o_id oId,co.remark remark,co.request_time requestTime,co.user_id userId,co.status_cd statusCd FROM c_orders co WHERE co.o_id = #oId# ",
	"param2": "SELECT cb.b_id bId, cb.business_type_cd businessTypeCd,cb.create_time createTime,cb.finish_time finishTime ,cb.o_id oId,cb.remark remark,cb.status_cd statusCd FROM c_business cb WHERE cb.o_id = #oId# "
}

template 配置格式如下：

{
	"PARAM": {
		"param1": "$.#order#Object",
		"param2": "$.#business#Array"
	},
	"TEMPLATE": {
		"response": {
			"code": "0000",
			"message": "成功"
		}
	}
}

template 的param1 和 sql 的param1 对应 ，模板是TEMPLATE，最后生成的格式为：

{
	"response": {
		"code": "0000",
		"message": "成功"
	},
	"order": {
		"appId": "",
		"createTime": "",
		"下面节点对应sql的查询出来字段": ""
	},
	"business": [{
		"bId": "",
		"businessTypeCd": "",
		"下面节点对应sql的查询出来字段": ""
	}]
}

请求报文格式为：

{
  "orders": {
    "transactionId": "100000000020180409224736000001",
    "requestTime": "20180409224736",
    "orderTypeCd":"订单类型,查询,受理",
    "dataFlowId":"20020180000001",
    "businessType":"Q"//B business 过程 I Instance过程
  },
  "business": {
    "bId":"12345678",
    "serviceCode": "querycustinfo",
    "serviceName": "查询客户",
    "remark": "备注",
    "datas": {
      "params": {
        //这个做查询时的参数
      }
    }
  }
}

相关insert 语句，请参考：

INSERT INTO c_service_sql(service_code,`name`,params,query_model,`sql`,proc,template,remark,status_cd)
VALUES('query.order.orderInfo','订单信息','oId','1','{
                                                 	"param1":"SELECT co.app_id appId,co.create_time createTime,co.ext_transaction_id extTransactionId,co.finish_time finishTime
                                                 ,co.order_type_cd orderTypeCd,co.o_id oId ,co.remark remark ,co.request_time requestTime ,co.user_id userId,co.status_cd statusCd
                                                  FROM c_orders co WHERE co.o_id = #oId#",
                                                  "param2":"SELECT cb.b_id bId, cb.business_type_cd businessTypeCd,cb.create_time createTime,cb.finish_time finishTime ,cb.o_id oId,
                                                 cb.remark remark,cb.status_cd statusCd FROM c_business cb WHERE cb.o_id = #oId#"
                                                 }','','{"PARAM":{
                                                            "param1": "$.#order#Object",
                                                            "param2": "$.#business#Array"
                                                            },"TEMPLATE":{
                                                         "response": {
                                                           "code": "0000",
                                                           "message": "成功"
                                                         }
                                                       }}','','0');

>回到首页