generated from root/miduo_server
去除mongo加载
parent
6f3cbbdd1c
commit
c25811fd7c
|
@ -2,12 +2,19 @@
|
||||||
<html lang="en">
|
<html lang="en">
|
||||||
<head>
|
<head>
|
||||||
<meta charset="UTF-8">
|
<meta charset="UTF-8">
|
||||||
<title>Title</title>
|
<title>发货机</title>
|
||||||
</head>
|
</head>
|
||||||
<body>
|
<body>
|
||||||
<form action="http://localhost:9992/delivery/test" method="post">
|
<form action="http://localhost:9991/delivery/test" method="post">
|
||||||
用 户 Id:<input type="text" name="userId"><br><br>
|
用 户 Id: <input type="text" name="userId"><br><br>
|
||||||
物 品 Id:<input type="text" name="itemId"><br><br>
|
礼包类型:
|
||||||
|
<select name="itemType">
|
||||||
|
<option>请选择礼包类型</option>
|
||||||
|
<option value="1">金币</option>
|
||||||
|
<option value="2">钻石</option>
|
||||||
|
<option value="3">神劵</option>
|
||||||
|
<option value="4">礼包一(钻石1000,金币10000,神劵10)</option>
|
||||||
|
</select> <br><br>
|
||||||
物品数量:<input type="text" name="itemNum"><br><br>
|
物品数量:<input type="text" name="itemNum"><br><br>
|
||||||
<input type="submit" value="发送">
|
<input type="submit" value="发送">
|
||||||
</form>
|
</form>
|
||||||
|
|
|
@ -6,11 +6,13 @@ import com.jmfy.thrift.pool.ThriftPoolUtils;
|
||||||
import com.jmfy.util.KProducer;
|
import com.jmfy.util.KProducer;
|
||||||
import org.springframework.boot.SpringApplication;
|
import org.springframework.boot.SpringApplication;
|
||||||
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
import org.springframework.boot.autoconfigure.SpringBootApplication;
|
||||||
|
import org.springframework.boot.autoconfigure.data.mongo.MongoDataAutoConfiguration;
|
||||||
|
import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration;
|
||||||
import org.springframework.context.ConfigurableApplicationContext;
|
import org.springframework.context.ConfigurableApplicationContext;
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
@SpringBootApplication
|
@SpringBootApplication(exclude = {MongoAutoConfiguration.class,MongoDataAutoConfiguration.class})
|
||||||
public class Application {
|
public class Application {
|
||||||
public static void main(String[] args) throws Exception {
|
public static void main(String[] args) throws Exception {
|
||||||
ConfigurableApplicationContext configurableApplicationContext = SpringApplication.run(Application.class, args);
|
ConfigurableApplicationContext configurableApplicationContext = SpringApplication.run(Application.class, args);
|
||||||
|
|
|
@ -20,8 +20,10 @@ public class TestController {
|
||||||
@RequestMapping(value = "/test")
|
@RequestMapping(value = "/test")
|
||||||
public JsonResult deliveryGoods(HttpServletRequest request){
|
public JsonResult deliveryGoods(HttpServletRequest request){
|
||||||
int userId = Integer.parseInt(request.getParameter("userId"));
|
int userId = Integer.parseInt(request.getParameter("userId"));
|
||||||
int itemId = Integer.parseInt(request.getParameter("itemId"));
|
int itemType = Integer.parseInt(request.getParameter("itemType"));
|
||||||
int itemNum = Integer.parseInt(request.getParameter("itemNum"));
|
String num = request.getParameter("itemNum");
|
||||||
|
|
||||||
|
int itemNum = Integer.parseInt(String.valueOf("".equals(num) ?0:num));
|
||||||
|
|
||||||
//TODO 根据大区id和小区id从redis找到对应服的 IP和 Port
|
//TODO 根据大区id和小区id从redis找到对应服的 IP和 Port
|
||||||
String ip = "127.0.0.1";
|
String ip = "127.0.0.1";
|
||||||
|
@ -32,7 +34,7 @@ public class TestController {
|
||||||
String serviceKey = getServiceKey(ServiceKey.RPCCore,ip,port);
|
String serviceKey = getServiceKey(ServiceKey.RPCCore,ip,port);
|
||||||
try {
|
try {
|
||||||
rPCClient = ClientAdapterPo.getClientAdapterPo(serviceKey);
|
rPCClient = ClientAdapterPo.getClientAdapterPo(serviceKey);
|
||||||
result = rPCClient.getClient().TestdeliveryGood(userId,itemId,itemNum);
|
result = rPCClient.getClient().testdeliveryGood(userId,itemType,itemNum);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
} finally {
|
} finally {
|
||||||
|
|
|
@ -1,10 +0,0 @@
|
||||||
package com.jmfy.dao;
|
|
||||||
|
|
||||||
import com.jmfy.dto.CPayOrder;
|
|
||||||
|
|
||||||
public interface UserDao {
|
|
||||||
/*
|
|
||||||
* 获取玩家订单信息
|
|
||||||
* */
|
|
||||||
CPayOrder getBuyOrderInfo(String orderId, String dbName);
|
|
||||||
}
|
|
|
@ -1,30 +0,0 @@
|
||||||
package com.jmfy.dao.impl;
|
|
||||||
|
|
||||||
import com.jmfy.dao.UserDao;
|
|
||||||
import com.jmfy.dto.CPayOrder;
|
|
||||||
import com.mongodb.Mongo;
|
|
||||||
import org.springframework.data.mongodb.core.MongoTemplate;
|
|
||||||
import org.springframework.data.mongodb.core.query.BasicQuery;
|
|
||||||
import org.springframework.stereotype.Repository;
|
|
||||||
|
|
||||||
import javax.annotation.Resource;
|
|
||||||
|
|
||||||
@Repository
|
|
||||||
public class UserDaoImpl implements UserDao{
|
|
||||||
|
|
||||||
@Resource
|
|
||||||
private Mongo mongo;
|
|
||||||
|
|
||||||
public MongoTemplate getrMongoTemplateByDBName(String dataBaseName){
|
|
||||||
return new MongoTemplate(mongo,dataBaseName);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public CPayOrder getBuyOrderInfo(String orderId, String dbName) {
|
|
||||||
MongoTemplate rMongoTemplate =getrMongoTemplateByDBName(dbName);
|
|
||||||
String sql = "{id:" + orderId + "}";
|
|
||||||
BasicQuery basicQuery = new BasicQuery(sql);
|
|
||||||
return rMongoTemplate.findOne(basicQuery, CPayOrder.class);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
|
@ -14,24 +14,24 @@ import javax.annotation.Resource;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
@Component
|
//@Component
|
||||||
public class Connect {
|
public class Connect {
|
||||||
|
//
|
||||||
@Resource
|
// @Resource
|
||||||
private MongoClient mongo;
|
// private MongoClient mongo;
|
||||||
@Resource
|
// @Resource
|
||||||
private MongoConverter mongoConverter;
|
// private MongoConverter mongoConverter;
|
||||||
|
//
|
||||||
private Map<String,MongoTemplate> mongoMaps= new HashMap<>();
|
// private Map<String,MongoTemplate> mongoMaps= new HashMap<>();
|
||||||
|
//
|
||||||
@PostConstruct
|
// @PostConstruct
|
||||||
public void init(){
|
// public void init(){
|
||||||
MongoIterable<String> databases = mongo.listDatabaseNames();
|
// MongoIterable<String> databases = mongo.listDatabaseNames();
|
||||||
for(String dbName:databases){
|
// for(String dbName:databases){
|
||||||
MongoDbFactory simpleMongoDbFactory = new SimpleMongoDbFactory(mongo,dbName);
|
// MongoDbFactory simpleMongoDbFactory = new SimpleMongoDbFactory(mongo,dbName);
|
||||||
MongoTemplate mongoTemplate = new MongoTemplate(simpleMongoDbFactory, mongoConverter);
|
// MongoTemplate mongoTemplate = new MongoTemplate(simpleMongoDbFactory, mongoConverter);
|
||||||
mongoMaps.put(dbName,mongoTemplate);
|
// mongoMaps.put(dbName,mongoTemplate);
|
||||||
}
|
// }
|
||||||
}
|
// }
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,9 +2,9 @@
|
||||||
server.port=9991
|
server.port=9991
|
||||||
##contextPath
|
##contextPath
|
||||||
server.context-path=/delivery
|
server.context-path=/delivery
|
||||||
|
#
|
||||||
spring.data.mongodb.host=192.168.0.169
|
#spring.data.mongodb.host=192.168.0.170
|
||||||
spring.data.mongodb.port=27017
|
#spring.data.mongodb.port=27017
|
||||||
|
|
||||||
#spring.data.mongodb.host=gameP.pr1.ysj.db
|
#spring.data.mongodb.host=gameP.pr1.ysj.db
|
||||||
#spring.data.mongodb.port=27017
|
#spring.data.mongodb.port=27017
|
||||||
|
|
|
@ -10,5 +10,5 @@ service RPCRequestIFace{
|
||||||
|
|
||||||
Result deliveryGood(1:string openid, 2:i32 userId, 3:string payitem, 4:string billno, 5:string amt,
|
Result deliveryGood(1:string openid, 2:i32 userId, 3:string payitem, 4:string billno, 5:string amt,
|
||||||
6:string channel_id, 7:string token, 8:string serverOrder) throws (1:common.InvalidOperException ouch);
|
6:string channel_id, 7:string token, 8:string serverOrder) throws (1:common.InvalidOperException ouch);
|
||||||
Result TestdeliveryGood(1:i32 userId, 2:i32 itemId ,3:i32 itemNum) throws (1:common.InvalidOperException ouch);
|
Result testdeliveryGood(1:i32 userId, 2:i32 itemType ,3:i32 itemNum) throws (1:common.InvalidOperException ouch);
|
||||||
}
|
}
|
Loading…
Reference in New Issue