|
@@ -24,7 +24,7 @@ public class TableServiceImpl implements ITableService {
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public boolean createTable(String source, String coin, String type){
|
|
public boolean createTable(String source, String coin, String type){
|
|
|
- String tableName = String.format("%s_%s_%s", source, coin.replaceAll("_", ""), type).toUpperCase();
|
|
|
|
|
|
|
+ String tableName = String.format("%s_%s_%s", coin.replaceAll("_", ""), source, type).toUpperCase();
|
|
|
synchronized (interner.intern(tableName)){
|
|
synchronized (interner.intern(tableName)){
|
|
|
try {
|
|
try {
|
|
|
tableMapper.createTable(tableName);
|
|
tableMapper.createTable(tableName);
|
|
@@ -48,7 +48,7 @@ public class TableServiceImpl implements ITableService {
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
public void savePrice(PriceInfoDto dto){
|
|
public void savePrice(PriceInfoDto dto){
|
|
|
- String tableName = String.format("%s_%s_%s", dto.getSource(), dto.getCoin().replaceAll("_", ""), dto.getType()).toUpperCase();
|
|
|
|
|
|
|
+ String tableName = String.format("%s_%s_%s", dto.getCoin().replaceAll("_", ""), dto.getSource(), dto.getType()).toUpperCase();
|
|
|
try {
|
|
try {
|
|
|
// 尝试先写入
|
|
// 尝试先写入
|
|
|
this.tableMapper.savePrice(tableName, dto.getTime(), dto.getAsk(), dto.getBid());
|
|
this.tableMapper.savePrice(tableName, dto.getTime(), dto.getAsk(), dto.getBid());
|