back_recharge
wangyuan 2019-09-18 17:51:35 +08:00
parent e852ef1b31
commit c350f920e5
1 changed files with 3 additions and 2 deletions

View File

@ -215,12 +215,13 @@ public class BuyGoodsLogic {
resultRes.setResultCode(1);
KtEventUtils.onKtEvent(user, ParamEventBean.UserPayEvent,goodsId,orderId,resultRes.getResultCode(),price);
notifyPaySuccessFul(uid,goodsId,amount != -999);
Class<? extends MongoUpdateCache> aClass = MongoUpdateCacheThreadLocal.getMongoUpdateCache().getClass();
Field requestMap = aClass.getDeclaredField("requestMap");
requestMap.setAccessible(true);
requestMap.set(MongoUpdateCacheThreadLocal.getMongoUpdateCache(), new HashMap<>());
AyyncWorker ayyncWorker = new AyyncWorker(user,true) {
/* AyyncWorker ayyncWorker = new AyyncWorker(user,true) {
@Override
public void work(User user) throws Exception {
MongoUtil.getLjsdMongoTemplate().save(user);
@ -228,7 +229,7 @@ public class BuyGoodsLogic {
};
ProtocolsManager instance = ProtocolsManager.getInstance();
HandlerLogicThread handlerThread = instance.handlerThreads[user.getId() % instance.HANDLER_THREAD_NUM];
handlerThread.addAyyncWorker(ayyncWorker);
handlerThread.addAyyncWorker(ayyncWorker);*/
return resultRes;
}