diff --git a/src/main/java/com/jmfy/controller/RechargeController.java b/src/main/java/com/jmfy/controller/RechargeController.java index 0bbfc33..4e187ea 100644 --- a/src/main/java/com/jmfy/controller/RechargeController.java +++ b/src/main/java/com/jmfy/controller/RechargeController.java @@ -49,8 +49,13 @@ public class RechargeController { FindPlayerResult findPlayerResult = new FindPlayerResult("1010","sign derify failed",null); return JsonUtil.getInstence().getGson().toJson(findPlayerResult); } - CUserInfo cUserInfo = cuserDao.getUserInfobyNameAndServerId(userId, Integer.parseInt(serverCode)); + String plat = "android"; + if (gameCode.equals(YsjConstant.TW_IOS_GameCode)){ + plat = "ios"; + } + CUserInfo cUserInfo = cuserDao.getUserInfobyNameAndServerId(userId, Integer.parseInt(serverCode),plat); if (Integer.parseInt(creditId) != cUserInfo.getUserId()){ + LOGGER.info("deliveryGoods==>creditId={},uId={}",creditId,cUserInfo.getUserId()); ResultVo resultVo = new ResultVo("1038", "该用户无此角色"); return JsonUtil.getInstence().getGson().toJson(resultVo); } diff --git a/src/main/java/com/jmfy/dto/CUserDao.java b/src/main/java/com/jmfy/dto/CUserDao.java index 828fb5e..566dfbd 100644 --- a/src/main/java/com/jmfy/dto/CUserDao.java +++ b/src/main/java/com/jmfy/dto/CUserDao.java @@ -6,7 +6,7 @@ public interface CUserDao { String findUserInfo(int serverId, int userId); - CUserInfo getUserInfobyNameAndServerId(String name,int serverId) throws Exception; + CUserInfo getUserInfobyNameAndServerId(String name,int serverId,String plat) throws Exception; CUser getCUser(int userId, int serverid) throws Exception; diff --git a/src/main/java/com/jmfy/dto/impl/CUserDaoImpl.java b/src/main/java/com/jmfy/dto/impl/CUserDaoImpl.java index 549ac3d..8e1b343 100644 --- a/src/main/java/com/jmfy/dto/impl/CUserDaoImpl.java +++ b/src/main/java/com/jmfy/dto/impl/CUserDaoImpl.java @@ -34,11 +34,11 @@ public class CUserDaoImpl implements CUserDao { } @Override - public CUserInfo getUserInfobyNameAndServerId(String name, int serverId) throws Exception { + public CUserInfo getUserInfobyNameAndServerId(String name, int serverId,String plat) throws Exception { Query query = new Query(); Criteria cr = new Criteria(); MongoTemplate mongoTemplate = connect.getMongoTemplete("ysj_core"); - cr.andOperator(Criteria.where("serverid").is(serverId), Criteria.where("openId").is(name)); + cr.andOperator(Criteria.where("serverid").is(serverId), Criteria.where("openId").is(name),Criteria.where("platform").is(plat)); query.addCriteria(cr); CUserInfo cUserInfo = mongoTemplate.findOne(query, CUserInfo.class); return cUserInfo;