变更历史

本页内容

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');

>回到首页