From 611f10a6cc65f4d4db031bc3dcfcb3a4bff135f4 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E9=9B=84=E5=B3=B0?= Date: Tue, 15 Aug 2017 17:57:38 +0800 Subject: [PATCH] add jigsaw-rpc-order --- jigsaw-rpc-order/CHANGELOG.md | 29 ++++++ jigsaw-rpc-order/README.md | 1 + jigsaw-rpc-order/src/conf/pay_order.sql | 97 +++++++++++++++++++ .../src/main/assembly/package.xml | 35 +++++++ .../org/jigsaw/payment/order/JdbcSharder.java | 26 +++++ .../payment/order/PayOrderRepository.java | 27 ++++++ .../payment/order/mysql/MySQLJdbcSharder.java | 73 ++++++++++++++ .../MySQLShardingPayOrderRepository.java | 65 +++++++++++++ .../payment/order/rpc/GetTradeController.java | 25 +++++ .../org/jigsaw/payment/order/rpc/Server.java | 23 +++++ .../main/resources/application-dev.properties | 11 +++ .../src/main/resources/datasource.xml | 55 +++++++++++ .../src/main/resources/logback.xml | 68 +++++++++++++ .../payment/order/TestConfiguration.java | 41 ++++++++ .../jigsaw/payment/order/TestJdbcSharder.java | 43 ++++++++ .../payment/order/TestPayOrderRepository.java | 66 +++++++++++++ .../test/resources/application-dev.properties | 9 ++ .../src/test/resources/logback.xml | 72 ++++++++++++++ 18 files changed, 766 insertions(+) create mode 100644 jigsaw-rpc-order/CHANGELOG.md create mode 100644 jigsaw-rpc-order/README.md create mode 100644 jigsaw-rpc-order/src/conf/pay_order.sql create mode 100644 jigsaw-rpc-order/src/main/assembly/package.xml create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/JdbcSharder.java create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/PayOrderRepository.java create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLJdbcSharder.java create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLShardingPayOrderRepository.java create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/GetTradeController.java create mode 100644 jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/Server.java create mode 100644 jigsaw-rpc-order/src/main/resources/application-dev.properties create mode 100644 jigsaw-rpc-order/src/main/resources/datasource.xml create mode 100644 jigsaw-rpc-order/src/main/resources/logback.xml create mode 100644 jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestConfiguration.java create mode 100644 jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestJdbcSharder.java create mode 100644 jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestPayOrderRepository.java create mode 100644 jigsaw-rpc-order/src/test/resources/application-dev.properties create mode 100644 jigsaw-rpc-order/src/test/resources/logback.xml diff --git a/jigsaw-rpc-order/CHANGELOG.md b/jigsaw-rpc-order/CHANGELOG.md new file mode 100644 index 0000000..ce28a95 --- /dev/null +++ b/jigsaw-rpc-order/CHANGELOG.md @@ -0,0 +1,29 @@ +## 1.0.6 2017-07-19 +### Added +- 增加关闭订单服务 +### Updated +- 修正同步到ES的过期时间转换 + +## 1.0.5 2017-06-29 +### Updated +- 如果时账户消费 创建订单就进行账户消费 +- 支持奇豆消费时同步旧库中奇豆数据 +- 账户消费不再记录交易流水 + + +## 1.0.3 2017-05-08 +### Updated +- supported consuming qidian +- supported CreateTrade/PreparePay/FinishPay + +## 1.0.3 2017-05-08 +### Updated +- switch branch kepler + +## 1.0.3 2017-04-26 +### Added +- support sync extra_params to elastic + +## 1.0.1 2017-03-10 +### Added +- initial release diff --git a/jigsaw-rpc-order/README.md b/jigsaw-rpc-order/README.md new file mode 100644 index 0000000..df5c2b9 --- /dev/null +++ b/jigsaw-rpc-order/README.md @@ -0,0 +1 @@ +基于分库分表的支付流水基础服务 \ No newline at end of file diff --git a/jigsaw-rpc-order/src/conf/pay_order.sql b/jigsaw-rpc-order/src/conf/pay_order.sql new file mode 100644 index 0000000..b714cbd --- /dev/null +++ b/jigsaw-rpc-order/src/conf/pay_order.sql @@ -0,0 +1,97 @@ +/* +Navicat MySQL Data Transfer + +Source Server : jigsaw-payment +Source Server Version : 50719 +Source Host : localhost:3306 +Source Database : jigsaw-payment + +Target Server Type : MYSQL +Target Server Version : 50719 +File Encoding : 65001 + +Date: 2017-08-10 19:19:42 +*/ + +SET FOREIGN_KEY_CHECKS=0; + +-- ---------------------------- +-- Table structure for pay_order_0 +-- ---------------------------- +DROP TABLE IF EXISTS `pay_order_0`; +CREATE TABLE `pay_order_0` ( + `id` bigint(20) NOT NULL COMMENT '自增ID,兼容遗留数据', + `code` varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易流水号', + `version` bigint(20) NOT NULL DEFAULT '0', + `app_id` varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '发起交易的app id', + `pay_scenarios` int(4) NOT NULL COMMENT '发起交易的场景，包括api, 通用收银台，充值收银台，扫码支付等', + `notify_url` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '异步通知url', + `return_url` varchar(255) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '同步通知url', + `status` int(9) NOT NULL COMMENT '订单状态 1：已支付;2:未支付;3:等待中;4:退单;5:短信支付扣费成功;6:冻结;7:关闭', + `create_time` datetime NOT NULL, + `update_time` datetime NOT NULL, + `expire_time` datetime NOT NULL COMMENT '过期时间', + `pay_time` datetime NOT NULL COMMENT '支付时间', + `error_code` varchar(32) NOT NULL COMMENT '如果支付失败，这里需记录错误码', + `error_detail` varchar(128) NOT NULL COMMENT '详细错误信息，如果支付失败，需要在这里记录错误信息', + `partner_order_no` varchar(64) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '接入方订单号', + `pay_mode` tinyint(10) NOT NULL COMMENT '0.正常订单，1.代表测试订单', + `order_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '订单ID，记录用户购买的产品信息（需使用产品查询接口）', + `order_title` varchar(62) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '订单名称', + `order_detail` varchar(128) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '订单描述', + `order_show_url` varchar(256) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '订单显示的url地址', + `fee` int(9) NOT NULL COMMENT '预期金额', + `fee_real` int(9) NOT NULL COMMENT '实际支付总金额', + `fee_unit` tinyint(2) NOT NULL DEFAULT '1' COMMENT '货币类型 ', + `sub_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易主体不仅仅是用户，也可以是商户', + `sub_type` int(9) NOT NULL COMMENT '交易主体类型', + `sub_name` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易主体名称', + `sub_account_id` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易主体账号', + `sub_account_type` int(10) NOT NULL COMMENT '交易主体使用的账号类型；银行卡、钱包、奇点、奇豆等', + `sub_ip` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易主体ip地址', + `sub_mobile` varchar(32) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '交易主体使用的手机号', + `sub_client_code` varchar(16) NOT NULL COMMENT '交易主体的客户端代码，发起交易的平台代码，参考公司标准代码规范', + `sub_device_id` varchar(32) NOT NULL COMMENT '交易主体使用的设备', + `sub_email` varchar(128) NOT NULL COMMENT '交易主体的邮箱【预留】', + `sub_location` varchar(128) NOT NULL COMMENT '交易主体在交易发生时所在的位置【预留】', + `sub_country_code` varchar(128) NOT NULL COMMENT '交易主体所在的国家代码，默认为中国【预留】', + `partner_id` int(9) NOT NULL COMMENT '交易对手的Id,接入方ID', + `partner_type` int(9) NOT NULL COMMENT '交易对手的类型', + `partner_account_id` int(9) NOT NULL COMMENT '交易对手的账号,商户号pay_service_account的ID', + `partner_name` varchar(32) NOT NULL COMMENT '交易对手的名称', + `source_pay_type` int(9) NOT NULL COMMENT '用户选择的交易渠道实体编码', + `dest_pay_type` int(9) NOT NULL COMMENT '实际执行的交易渠道虚拟账户编码', + `third_create_time` datetime NOT NULL COMMENT '第三方创建时间', + `third_pay_time` datetime NOT NULL COMMENT '第三方创建时间', + `third_trade_code` varchar(256) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL COMMENT '第三方交易订单号', + `current_key` int(9) NOT NULL, + PRIMARY KEY (`code`), + KEY `idx_pay_uid_time` (`sub_id`,`create_time`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8; +DROP TABLE IF EXISTS `pay_order_1`; +CREATE TABLE `pay_order_1` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_2`; +CREATE TABLE `pay_order_2` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_3`; +CREATE TABLE `pay_order_3` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_4`; +CREATE TABLE `pay_order_4` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_5`; +CREATE TABLE `pay_order_5` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_6`; +CREATE TABLE `pay_order_6` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_7`; +CREATE TABLE `pay_order_7` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_8`; +CREATE TABLE `pay_order_8` like `pay_order_0` ; + +DROP TABLE IF EXISTS `pay_order_9`; +CREATE TABLE `pay_order_9` like `pay_order_0` ; + diff --git a/jigsaw-rpc-order/src/main/assembly/package.xml b/jigsaw-rpc-order/src/main/assembly/package.xml new file mode 100644 index 0000000..eeb211b --- /dev/null +++ b/jigsaw-rpc-order/src/main/assembly/package.xml @@ -0,0 +1,35 @@ + + package + + tar.gz + + ${project.artifactId} + + + src/conf + + *.* + + conf + 0644 + 0755 + + + target/lib + lib + 0644 + 0755 + + + + + + target/${project.artifactId}-${project.version}.${project.packaging} + lib + 0644 + + + + \ No newline at end of file diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/JdbcSharder.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/JdbcSharder.java new file mode 100644 index 0000000..2926416 --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/JdbcSharder.java @@ -0,0 +1,26 @@ +package org.jigsaw.payment.order; + +import org.jigsaw.payment.model.PayOrder; +import org.jigsaw.payment.mysql.JdbcProtobufTemplate; + +/** + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月10日 + */ +public interface JdbcSharder { + + /** + * 根据Uid获取JdbcTemplate + * @param uid + * @return + */ + public JdbcProtobufTemplate getTemplateByUserId(long uid); + + /** + * 获取对应的表名 + * @param uid + * @return + */ + public String getTableByUserId(long uid); +} diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/PayOrderRepository.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/PayOrderRepository.java new file mode 100644 index 0000000..b791beb --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/PayOrderRepository.java @@ -0,0 +1,27 @@ +/** + * + */ +package org.jigsaw.payment.order; + +import org.jigsaw.payment.model.PayOrder; + +/** + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月9日 + */ +public interface PayOrderRepository { + /** + * 根据交易主体和订单号获取给定的订单 + * @param subId 交易主体的ID + * @param code 订单号 + * @return 符合条件的订单，如果没有找到，返回空。 + */ + public PayOrder get(long subId, String code); + /** + * 创建订单 + * @param order 带插入的订单 + * @return 订单ID。 + */ + public long create(PayOrder order) ; +} diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLJdbcSharder.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLJdbcSharder.java new file mode 100644 index 0000000..49932ec --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLJdbcSharder.java @@ -0,0 +1,73 @@ +package org.jigsaw.payment.order.mysql; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; + +import javax.sql.DataSource; + +import org.jigsaw.payment.model.PayOrder; +import org.jigsaw.payment.mysql.JdbcProtobufTemplate; +import org.jigsaw.payment.order.JdbcSharder; +import org.springframework.jdbc.core.JdbcTemplate; + +/** + * 增加表可以减少锁的争用，增加库可以增加并发性能。 + * 按照这个原则，分表分库按照用户id（长整形）来进行，uid最后一位用来做分表。分库按照2、4、8的级数来扩展： 表号是： uid对10取模，即最后一位； + * 库号是： uid/10 后， 按照库的数量来取模。 加库时，先将表数据同步到1个从库，同步完成后，从库升级为主库即可。 表里有冗余数据，但是不会丢数据。 + * + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月10日 + */ +public class MySQLJdbcSharder implements JdbcSharder { + private List> templates; + private int tableCount = 10; + private int databaseCount = 2; + private String tableNamePattern = "pay_order_%01d"; + + /** + * 初始化template列表； + * + * @param dataSourceList + */ + public void setDataSourceList(List dataSourceList) { + this.templates = Collections + .synchronizedList(new ArrayList>( + dataSourceList.size())); + for (DataSource dataSource : dataSourceList) { + JdbcTemplate template = new JdbcTemplate(dataSource); + JdbcProtobufTemplate wrapper = new JdbcProtobufTemplate( + template, PayOrder.class); + this.templates.add(wrapper); + } + if (this.templates.size() != this.databaseCount) + throw new IllegalArgumentException( + "please check your database configuration, it should have " + + databaseCount + " count."); + } + + public void setTableCount(int tableCount) { + this.tableCount = tableCount; + } + + public void setDatabaseCount(int databaseCount) { + this.databaseCount = databaseCount; + } + + + public void setTableNamePattern(String tableNamePattern) { + this.tableNamePattern = tableNamePattern; + } + + @Override + public JdbcProtobufTemplate getTemplateByUserId(long uid) { + return this.templates.get((int) (uid / tableCount % databaseCount)); + } + + @Override + public String getTableByUserId(long uid) { + return String.format(tableNamePattern, uid % this.tableCount); + } + +} diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLShardingPayOrderRepository.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLShardingPayOrderRepository.java new file mode 100644 index 0000000..1b7c086 --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/mysql/MySQLShardingPayOrderRepository.java @@ -0,0 +1,65 @@ + +package org.jigsaw.payment.order.mysql; + +import java.text.MessageFormat; + +import org.jigsaw.payment.metric.Timer; +import org.jigsaw.payment.model.IllegalParameterException; +import org.jigsaw.payment.model.PayOrder; +import org.jigsaw.payment.model.StatusCode; +import org.jigsaw.payment.mysql.JdbcProtobufTemplate; +import org.jigsaw.payment.order.JdbcSharder; +import org.jigsaw.payment.order.PayOrderRepository; +import org.springframework.beans.factory.annotation.Autowired; + +/** + * 支持分表分库的MySQL订单管理 + * + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月9日 + */ +public class MySQLShardingPayOrderRepository implements PayOrderRepository { + + private JdbcSharder sharder; + + @Autowired + public MySQLShardingPayOrderRepository(JdbcSharder sharder) { + this.sharder = sharder; + } + + private static final String SQL_GET_PAY_ORDER = "select * from {0} where sub_id=? AND code = ?"; + + @Override + @Timer("get-order") + public PayOrder get(long subId, String code) { + JdbcProtobufTemplate template = this.sharder.getTemplateByUserId(subId); + String tableName = this.sharder.getTableByUserId(subId); + String sql = MessageFormat.format(SQL_GET_PAY_ORDER, tableName); + return template.get(sql, subId, code); + } + + /** + *验证数据有效性 + * @param order + */ + private void validate(PayOrder order){ + if(!order.hasSubId()) + throw new IllegalParameterException(StatusCode.DATA_REQUIRED_VALUE, "error.pay.order.require.sub_id"); + if(!order.hasCode()) + throw new IllegalParameterException(StatusCode.DATA_REQUIRED_VALUE, "error.pay.order.require.code"); + if(!order.hasCreateTime()) + throw new IllegalParameterException(StatusCode.DATA_REQUIRED_VALUE, "error.pay.order.require.create_time"); + + } + + @Override + @Timer("create-order") + public long create(PayOrder order) { + this.validate(order); + String tableName = this.sharder.getTableByUserId(order.getSubId()); + this.sharder.getTemplateByUserId(order.getSubId()).insert(order, tableName); + return order.getId(); + } + +} diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/GetTradeController.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/GetTradeController.java new file mode 100644 index 0000000..7aa21d9 --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/GetTradeController.java @@ -0,0 +1,25 @@ +package org.jigsaw.payment.order.rpc; + +import org.jigsaw.payment.rpc.PayOrderService.GetPayOrderRequest; +import org.jigsaw.payment.rpc.PayOrderService.GetPayOrderResponse; +import org.jigsaw.payment.rpc.server.BaseController; +import org.springframework.stereotype.Service; + +/** + * + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月9日 + */ +@Service("getPayOrder") +public class GetTradeController extends + BaseController { + + @Override + protected GetPayOrderResponse doProcess(GetPayOrderRequest request) + throws Exception { + + return null; + } + +} diff --git a/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/Server.java b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/Server.java new file mode 100644 index 0000000..c71d854 --- /dev/null +++ b/jigsaw-rpc-order/src/main/java/org/jigsaw/payment/order/rpc/Server.java @@ -0,0 +1,23 @@ + +package org.jigsaw.payment.order.rpc; + + +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * shard server + */ +@SpringBootApplication +public class Server{ + + /** + * main function + * @param args + * @throws Exception + */ + public static void main(String[] args) throws Exception { + SpringApplication.run(Server.class, args); + } + +} diff --git a/jigsaw-rpc-order/src/main/resources/application-dev.properties b/jigsaw-rpc-order/src/main/resources/application-dev.properties new file mode 100644 index 0000000..e60109a --- /dev/null +++ b/jigsaw-rpc-order/src/main/resources/application-dev.properties @@ -0,0 +1,11 @@ +#rpc settings +#min worker thread count; +rpc.server.min.worker.threads=50 +#max worker threads count; +rpc.server.max.worker.threads=500 +rpc.server.zookeeper.connect.string=localhost:2181 +rpc.server.zookeeper.username= payment +rpc.server.zookeeper.password= 123456 +rpc.server.service.path=/payment/rpc + + diff --git a/jigsaw-rpc-order/src/main/resources/datasource.xml b/jigsaw-rpc-order/src/main/resources/datasource.xml new file mode 100644 index 0000000..1a318bd --- /dev/null +++ b/jigsaw-rpc-order/src/main/resources/datasource.xml @@ -0,0 +1,55 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/jigsaw-rpc-order/src/main/resources/logback.xml b/jigsaw-rpc-order/src/main/resources/logback.xml new file mode 100644 index 0000000..d557b10 --- /dev/null +++ b/jigsaw-rpc-order/src/main/resources/logback.xml @@ -0,0 +1,68 @@ + + + + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss.SSS}] [%C{1}:%M:%L] %m%n + + + + + ${log_path}/app.log + + ${log_path}/app.log.%d{yyyy-MM-dd_HH} + 3 + 50GB + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss.SSS}] %m%n + + + + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss.SSS}] [%C{1}:%M:%L] %m%n + + + ERROR + + ${log_path}/error.log + + ${log_path}/error.log.%d{yyyy-MM-dd_HH} + 30 + 50GB + + + + + + 0 + + 512 + + false + + + + + + + + + 0 + + 512 + + false + + + + + + + + ${log.console} + + + + diff --git a/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestConfiguration.java b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestConfiguration.java new file mode 100644 index 0000000..1c386c9 --- /dev/null +++ b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestConfiguration.java @@ -0,0 +1,41 @@ +/* + * Copyright 2012-2017 the original author or authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package org.jigsaw.payment.order; + +import org.jigsaw.payment.order.mysql.MySQLShardingPayOrderRepository; +import org.springframework.boot.autoconfigure.EnableAutoConfiguration; +import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.ImportResource; + +/** + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月14日 + */ + +@Configuration() +@ImportResource("classpath:datasource.xml") +@EnableAutoConfiguration(exclude={DataSourceAutoConfiguration.class}) +public class TestConfiguration { + + @Bean("payOrderRepository") + public PayOrderRepository getPayOrderRepository(JdbcSharder jdbcSharder){ + return new MySQLShardingPayOrderRepository(jdbcSharder); + } + +} diff --git a/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestJdbcSharder.java b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestJdbcSharder.java new file mode 100644 index 0000000..b0adcd4 --- /dev/null +++ b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestJdbcSharder.java @@ -0,0 +1,43 @@ +package org.jigsaw.payment.order; + +import javax.annotation.Resource; + +import org.junit.Assert; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.boot.test.context.SpringBootTest.WebEnvironment; +import org.springframework.test.context.ActiveProfiles; +import org.springframework.test.context.junit4.SpringRunner; + +/** + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月11日 + */ +@RunWith(SpringRunner.class) +@ActiveProfiles("dev") +@SpringBootTest(classes= TestConfiguration.class, webEnvironment=WebEnvironment.NONE) +public class TestJdbcSharder { + @Resource(name = "jdbcSharder") + private JdbcSharder sharder; + + /** + * 验证按照算法计算出来的ID属于同一个数据库； + */ + @Test + public void TestGetTemplateByUserIdEquals() { + Assert.assertEquals(sharder.getTemplateByUserId(1081l),sharder.getTemplateByUserId(1063l)); + Assert.assertEquals(sharder.getTemplateByUserId(1081l),sharder.getTemplateByUserId(1049l)); + Assert.assertNotEquals(sharder.getTemplateByUserId(1081l),sharder.getTemplateByUserId(1079l)); + } + /** + * 验证按照算法计算出来的ID属于同一个表； + */ + @Test + public void TestGetTableByUserIdEquals() { + Assert.assertEquals(sharder.getTableByUserId(1081l),sharder.getTableByUserId(1061l)); + Assert.assertEquals(sharder.getTableByUserId(1081l),sharder.getTableByUserId(1041l)); + Assert.assertNotEquals(sharder.getTableByUserId(1081l),sharder.getTableByUserId(1079l)); + } +} diff --git a/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestPayOrderRepository.java b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestPayOrderRepository.java new file mode 100644 index 0000000..f46f85d --- /dev/null +++ b/jigsaw-rpc-order/src/test/java/org/jigsaw/payment/order/TestPayOrderRepository.java @@ -0,0 +1,66 @@ +/** + * + */ +package org.jigsaw.payment.order; + +import java.util.Calendar; +import java.util.Date; +import java.util.UUID; + +import javax.annotation.Resource; + + + +import org.apache.commons.lang3.RandomUtils; +import org.jigsaw.payment.model.FeeUnit; +import org.jigsaw.payment.model.PayOrder; +import org.junit.Assert; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.springframework.boot.test.context.SpringBootTest; +import org.springframework.boot.test.context.SpringBootTest.WebEnvironment; +import org.springframework.test.context.ActiveProfiles; +import org.springframework.test.context.junit4.SpringRunner; + +/** + * @author shamphone@gmail.com + * @version 1.0.0 + * @date 2017年8月11日 + */ +@RunWith(SpringRunner.class) +@ActiveProfiles("dev") +@SpringBootTest(classes= TestConfiguration.class, webEnvironment=WebEnvironment.NONE) +public class TestPayOrderRepository { + @Resource(name = "payOrderRepository") + private PayOrderRepository repository; + + @Test + public void testCreateAndGet(){ + PayOrder.Builder builder = PayOrder.newBuilder(); + long uid = System.nanoTime(); + String code = UUID.randomUUID().toString(); + builder.setId(System.currentTimeMillis()); + builder.setAppId("myapp"); + builder.setCode(code); + builder.setCreateTime(new Date().getTime()); + builder.setCurrentKey(19283745); + builder.setDestPayType(1982); + builder.setSubId(uid); + Calendar expireTime = Calendar.getInstance(); + expireTime.add(Calendar.HOUR, 1); + builder.setExpireTime(expireTime.getTime().getTime()); + int fee = RandomUtils.nextInt(1, 1000000); + builder.setFee(fee); + builder.setFeeReal(RandomUtils.nextInt(1, fee)); + builder.setFeeUnit(FeeUnit.CNY_VALUE); + builder.setNotifyUrl("http://localhost/notify"); + builder.setReturnUrl("http://localhost/returnUrl"); + builder.setOrderDetail("OrderDetail"); + builder.setOrderId(UUID.randomUUID().toString()); + repository.create(builder.build()); + PayOrder order = repository.get(uid, code); + Assert.assertEquals(order.getCode(), code); + + } + +} diff --git a/jigsaw-rpc-order/src/test/resources/application-dev.properties b/jigsaw-rpc-order/src/test/resources/application-dev.properties new file mode 100644 index 0000000..d9424e9 --- /dev/null +++ b/jigsaw-rpc-order/src/test/resources/application-dev.properties @@ -0,0 +1,9 @@ +#rpc settings +#min worker thread count; +rpc.server.min.worker.threads=50 +#max worker threads count; +rpc.server.max.worker.threads=500 +rpc.server.zookeeper.connect.string=localhost:2181 +rpc.server.zookeeper.username= payment +rpc.server.zookeeper.password= 123456 +rpc.server.service.path=/payment/rpc diff --git a/jigsaw-rpc-order/src/test/resources/logback.xml b/jigsaw-rpc-order/src/test/resources/logback.xml new file mode 100644 index 0000000..cc86b85 --- /dev/null +++ b/jigsaw-rpc-order/src/test/resources/logback.xml @@ -0,0 +1,72 @@ + + + + + + + + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss.SSS}] [%C{1}:%M:%L] %m%n + + + + + ${log_path}/app.log + + ${log_path}/app.log.%d{yyyy-MM-dd_HH} + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss}] [%C{1}:%M:%L] %m%n + + + + + + [%-5p] [%d{yyyy-MM-dd HH:mm:ss}] [%C{1}:%M:%L] %m%n + + + ERROR + + ${log_path}/error.log + + ${log_path}/error.log.%d{yyyy-MM-dd_HH} + 30 + 80GB + + + + + + 0 + + 512 + + true + + + + + + + + + 0 + + 512 + + true + + + + + + + + + + + + + +