back_recharge
wangyuan 2019-07-02 21:14:48 +08:00
parent 4622b3ff8e
commit fe3bac1880
3 changed files with 5 additions and 2 deletions

View File

@ -1,5 +1,6 @@
package com.ljsd.jieling.handler; package com.ljsd.jieling.handler;
import com.google.gson.Gson;
import com.ljsd.jieling.db.redis.RedisKey; import com.ljsd.jieling.db.redis.RedisKey;
import com.ljsd.jieling.db.redis.RedisUtil; import com.ljsd.jieling.db.redis.RedisUtil;
import com.ljsd.jieling.handler.map.MapLogic; import com.ljsd.jieling.handler.map.MapLogic;

View File

@ -42,7 +42,7 @@ public class BuyGoodsLogic {
return; return;
} }
MessageUtil.sendMessage(session,1, MessageTypeProto.MessageType.TEST_BUY_GIGT_GOODS_RESPONSE_VALUE,null,true); MessageUtil.sendMessage(session,1, MessageTypeProto.MessageType.TEST_BUY_GIGT_GOODS_RESPONSE_VALUE,null,true);
// sendGoods(uid,goodsId); sendGoods(uid,goodsId,"gm-test","111111",System.currentTimeMillis(),-1);
} }
public static Result sendGoods(int uid, int goodsId, String openId, String orderId, long orderTime, int amount) throws Exception { public static Result sendGoods(int uid, int goodsId, String openId, String orderId, long orderTime, int amount) throws Exception {

View File

@ -1,5 +1,6 @@
package com.ljsd.jieling.thread.task; package com.ljsd.jieling.thread.task;
import com.google.gson.Gson;
import com.ljsd.CoreService; import com.ljsd.CoreService;
import com.ljsd.jieling.config.json.CoreSettings; import com.ljsd.jieling.config.json.CoreSettings;
import com.ljsd.jieling.thrift.idl.RPCRequestIFace; import com.ljsd.jieling.thrift.idl.RPCRequestIFace;
@ -23,8 +24,9 @@ public class RPCServerTask extends Thread{
private CoreSettings coreSettings; private CoreSettings coreSettings;
public RPCServerTask(ConfigurableApplicationContext configurableApplicationContext){ public RPCServerTask(ConfigurableApplicationContext configurableApplicationContext){
Gson gson = new Gson();
this.coreSettings = configurableApplicationContext.getBean(CoreSettings.class); this.coreSettings = configurableApplicationContext.getBean(CoreSettings.class);
userCallBackUrl = this.coreSettings.getIp() + ":" + this.coreSettings.getPort(); userCallBackUrl = gson.toJson(this.coreSettings.getIp() + ":" + this.coreSettings.getPort());
setName("rpc"); setName("rpc");
} }