UserProc.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707
  1. <?php
  2. namespace loyalsoft;
  3. // 常量设定
  4. define("USER_Backup_MaxRecords", 10); // 玩家数据备份,最多10条,每天1条,最后一次登录时的数据.
  5. define("USER_ActiveRecord_Days", 108); // 玩家记录集维持的最大天数
  6. define("USER_RANDOM_DAYS", 7); // 玩家记录集随机的最大天数
  7. define("USER_ACTION_DAYS", 108); // 玩家行为集维持的最大天数
  8. define("INIT_TUTORIAL", 1); // 新手引导是否开启 0.否 1.是
  9. //
  10. /**
  11. * Description of UserProc
  12. * 玩家数据处理流程
  13. *
  14. */
  15. class UserProc {
  16. const role_Table = 'tab_rolename';
  17. /**
  18. * 逻辑分发
  19. * 所有的Proc中必须有这样一个方法
  20. * @param Req $req
  21. */
  22. public static function procMain($req) {
  23. switch ($req->cmd) {
  24. case CmdCode::cmd_user_getzonelist: # 6000 分区列表
  25. return UserProc::GetZoneList($req);
  26. case CmdCode::cmd_user_loginuserinfo: # 6001 登录
  27. return UserProc::loginUserInfo($req);
  28. case CmdCode::cmd_user_gameconstinfo: # 6002 下载游戏配置
  29. return UserProc::downloadConstInfo($req);
  30. case CmdCode::cmd_user_acceptcontidaysgift: # 6003 领取连续登陆奖励
  31. return UserProc::acceptContiDaysGift($req);
  32. case CmdCode::cmd_user_registerNewUID: # 6004 注册新的用户 (送审/官方包接口)
  33. return UserProc::RegisterNewUID($req);
  34. case CmdCode::cmd_user_testUserLogin: # 6005 机器码登录(测试接口)
  35. return UserProc::TestUserLogin($req);
  36. case CmdCode::cmd_user_registerNewRole: # 6006 注册新角色
  37. return UserProc::RegisterNewRole($req);
  38. case CmdCode::cmd_user_completeNewbieGuide: # 6007 提交新手引导步骤
  39. return UserProc::completeNewbieGuide($req);
  40. // case CmdCode::cmd_user_setNewbieGuideCards: # 6008 发放新手引导所需卡牌
  41. // return self::SetNewbieGuideCards($req);
  42. case CmdCode::cmd_user_setNewbieGuideOver: # 6009 跳过新手引导
  43. return UserProc::setNewbieGuideOver($req);
  44. case CmdCode::cmd_user_setNickname: # 6010 设置/修改玩家昵称
  45. return self::SetUserNickname($req);
  46. case CmdCode::cmd_user_SetUserHeadImageBorder: # 6011 修改玩家头像框
  47. return self::SetUserImageBorder($req);
  48. case CmdCode::cmd_user_setUserImage: # 6012 更换玩家形象
  49. return self::SetUserImage($req);
  50. case CmdCode::cmd_user_changeUserHeadImg: # 6013 更换玩家头像
  51. return self::SetUserHeadImage($req);
  52. default:
  53. Err(ErrCode::cmd_err);
  54. }
  55. }
  56. //
  57. // <editor-fold defaultstate="collapsed" desc="玩家信息 修改">
  58. /**
  59. * [6013]修改玩家头像
  60. * @param Req $req
  61. */
  62. static function SetUserHeadImage($req) {
  63. list($headImage) = $req->paras; # 参数, 新头像
  64. $req->userInfo->game->baseInfo->headImg = $headImage;
  65. UserProc::updateUserInfo();
  66. return Resp::ok(array('ret' => 'ok'));
  67. }
  68. /**
  69. * [6012]修改玩家形象
  70. * @param Req $req
  71. */
  72. static function SetUserImage($req) {
  73. list($image) = $req->paras; # 参数, 新形象
  74. $req->userInfo->game->baseInfo->img = $image;
  75. UserProc::updateUserInfo();
  76. return Resp::ok(array('ret' => 'ok'));
  77. }
  78. /**
  79. * [6011]修改玩家头像框
  80. * @param Req $req
  81. */
  82. static function SetUserImageBorder($req) {
  83. list($imgborderId) = $req->paras; # 参数, 新头像框ID
  84. $req->userInfo->game->baseInfo->imgBorderId = $imgborderId;
  85. UserProc::updateUserInfo();
  86. return Resp::ok(array('ret' => 'ok'));
  87. }
  88. /**
  89. * [6010] 设置/修改玩家昵称
  90. * @param Req $req
  91. */
  92. static function SetUserNickname($req) {
  93. list($newname) = $req->paras; # 参数: 新昵称, 头像
  94. my_Assert(isset(glc()->User_SetNickname_Cost), "全局变量中未找到改名消耗钻石数量的配置字段");
  95. $amt = glc()->User_SetNickname_Cost; # 改名需要消耗钻石
  96. $ok = UserGameModel::Consume_Cash($req->userInfo->game->baseInfo, $amt); # 扣除钻石
  97. my_Assert($ok, ErrCode::notenough_cash_msg);
  98. my_Assert(self::checkRoleNameNotExist($newname), ErrCode::user_nicknameexist); # 昵称已存在
  99. $req->userInfo->game->baseInfo->name = $newname;
  100. daoInst()->update(self::role_Table)
  101. ->data(array('roleName' => $newname))
  102. ->where('userID')->eq($req->uid)
  103. ->andWhere('zoneid')->eq($req->zoneid)
  104. ->exec();
  105. UserProc::updateUserInfo();
  106. return Resp::ok(array('ret' => 'ok'));
  107. }
  108. // </editor-fold>
  109. //
  110. // <editor-fold defaultstate="collapsed" desc="新手引导">
  111. /**
  112. * [6009] 新手引导 发送n张碎片到玩家身上
  113. * @param Req $req
  114. */
  115. static function SetNewbieGuideCards($req) {
  116. Err(ErrCode::function_notopen_msg); # 功能已经废弃 -wg
  117. $private = $req->userInfo->game->privateState;
  118. if (!property_exists($private, 'newbieguideCards')) { # 逻辑检查, 是否已经发放过
  119. $private->newbieguideCards = true;
  120. $req->userInfo->game->privateState = $private; # 回写私有数据
  121. $sp = explode(';', glc()->User_SetNewbieGuideCards); # 碎片
  122. foreach ($sp as $cardinfo) {
  123. $arr = explode(',', $cardinfo);
  124. $itemid = $arr[0];
  125. $num = $arr[1];
  126. StoreProc::addSegmentIntoStore($req->userInfo->game->store, $itemid, $num);
  127. }
  128. $exp = explode(';', glc()->User_SetNewbieGuideExps); # 经验卡
  129. foreach ($exp as $expinfo) {
  130. $arr = explode(',', $expinfo);
  131. $itemid = $arr[0];
  132. $num = $arr[1];
  133. StoreProc::PutOverlyingItemInStore($itemid, $num);
  134. }
  135. UserProc::updateUserInfo(); # 回存玩家数据
  136. return Resp::ok(array('store' => $req->userInfo->game->store));
  137. }
  138. return Resp::err(ErrCode::active_hasgetted);
  139. }
  140. /**
  141. * [6011] 增加 设置引导结束的标志位
  142. * @param type $req
  143. */
  144. public static function setNewbieGuideOver($req) {
  145. $user = new UserGameModel($req->userInfo->game); # user
  146. if (!CommUtil::isPropertyExists($user, "NewbieGuideOver")) { # 防御: 变量未初始化
  147. $user->NewbieGuideOver = 1;
  148. }
  149. $user->NewbieGuideOver = 1;
  150. $req->userInfo->game = $user;
  151. UserProc::updateUserInfo(); # 回写数据
  152. return Resp::ok(array(# # 返回值
  153. 'result' => "succeed"
  154. ));
  155. }
  156. /**
  157. * [6007] 更新初始的强制的新手引导阶段步骤
  158. * 第一阶段的引导
  159. * @param Req $req
  160. */
  161. public static function completeNewbieGuide($req) {
  162. $guideIndex = $req->paras[0]; # 参数: 新手引导步骤
  163. $user = new UserGameModel($req->userInfo->game); # user
  164. if (!CommUtil::isPropertyExists($user, "NewbieGuide")) { # 防御: 变量未初始化
  165. $user->NewbieGuide = ObjectInit();
  166. }
  167. $NewbieGuide = $user->NewbieGuide;
  168. if (!CommUtil::isPropertyExists($NewbieGuide, "guideStep")) { # 防御: 变量未初始化
  169. $NewbieGuide->guideStep = 0;
  170. }
  171. my_Assert($guideIndex >= $NewbieGuide->guideStep, ErrCode::user_settutorialscompletedfail_err);
  172. if ($guideIndex == 1) {
  173. $huid = 10001; # 初始英雄
  174. $pos = 1;
  175. $newYanlingTypeId = 4020001; # 普通上官雀
  176. $hero = $user->heros->collectHeros->$huid;
  177. $oldYanlingUId = $hero->yanling->$pos->itemuid;
  178. $user->store->yanling->$oldYanlingUId->typeId = $newYanlingTypeId; # 直接修改类型变为普通言灵
  179. }
  180. $NewbieGuide->guideStep = $guideIndex;
  181. $user->NewbieGuide = $NewbieGuide;
  182. $req->userInfo->game = $user;
  183. UserProc::updateUserInfo(); # 回写数据
  184. return Resp::ok(array(
  185. "store" => $req->userInfo->game->store, # # 目前来看只涉及到items变化
  186. "heros" => $user->heros, # # 英雄数据
  187. ));
  188. }
  189. // </editor-fold>
  190. //
  191. /**
  192. * 6006 注册新角色
  193. * @param Req $req
  194. */
  195. public static function RegisterNewRole($req) {
  196. // Err(ErrCode::err_method_obsoleted, "注册逻辑已经转移到龙游SDK中 --王刚");
  197. $userID = $req->uid;
  198. list($rolename, $gender, $profile_img) = $req->paras; # 参数: 昵称,性别,头像
  199. if (self::checkRoleNameNotExist($rolename)) { # 记录玩家
  200. $userinfo = self::createUser($req, $rolename, $gender, $profile_img);
  201. self::regRole($req->zoneid, $userID, $rolename, $gender, $profile_img, $userinfo->getPlatStr());
  202. $resp = Resp::ok($userinfo);
  203. // StatProc::UserGuidStep($userinfo->user->firstLogOn, $req->zoneid, -2, 1);
  204. } else { # 昵称已存在
  205. $resp = Resp::ok(array('ret' => '用户已存在.'));
  206. }
  207. return $resp;
  208. }
  209. /**
  210. * 6000 【移动端】 获取分区列表
  211. * @param Req $req
  212. */
  213. public static function GetZoneList($req) {
  214. $defaultZone = new ZoneInfoModel(1, 0, ""); # 新用户默认分区
  215. $bGetRecommended = false;
  216. if (count($req->paras) > 0) { # 是否只拉取推荐分区
  217. $bGetRecommended = $req->paras[0];
  218. }
  219. $zoneList = array();
  220. $ts = now();
  221. foreach (GameConfig::zonelist() as $zoneid => $zone) {
  222. isEditor() and $zone = new \sm_zonelist();
  223. if ($zone->publicTs > $ts) {
  224. continue;
  225. }
  226. $zone->zoneid = $zoneid; # 把zoneid塞进zone数据结构中
  227. if ($bGetRecommended) {
  228. if ($zone->isRecommended > 0 && $zone->status == 1) {
  229. $zoneList[] = $zone;
  230. } else {
  231. }
  232. } else {
  233. $zoneList[] = $zone;
  234. }
  235. unset($zone->isRecommended);
  236. }
  237. UserProc::_AddTesterZonelist($req, $zoneList); # 添加测试分区
  238. #
  239. // <editor-fold defaultstate="collapsed" desc=" 取玩家分区记录 ">
  240. $userZoneInfo = self::getUserZoneInfo($req); # 玩家分区记录
  241. $isNewUser = false;
  242. if ($userZoneInfo == null) { // 这里使用推荐分区的数据,推荐分区信息,在后台编辑,编辑器可用
  243. $userZoneInfo = new UserZoneInfoModel();
  244. $userZoneInfo->lastZone = $defaultZone; # 新用户导向默认分区
  245. $isNewUser = true;
  246. // $err = self::RegisterNewUser($req); # 新用户添加到总表中
  247. // if ($err != ErrCode::succeed) {
  248. // return ResponseVo::myErrResponse($req, $err);
  249. // }
  250. # 统计模块添加记录
  251. // StatProc::UserGuidStep(CommUtil::tsCurrent(), $req->zoneid, -1, 1); // 第一次进入游戏
  252. } else { # 转换一下格式,去掉key,只保留value的集合
  253. // $userZoneInfo->playedZones = ArrayInit();
  254. // array_merge($userZoneInfo->playedZones, array_values((array) $userZoneInfo->playedZones));
  255. }
  256. // </editor-fold>
  257. $ret = array(
  258. 'isNewUser' => $isNewUser,
  259. 'zonelist' => json_decode(json_encode($zoneList)),
  260. 'userZoneInfo' => $userZoneInfo
  261. );
  262. return Resp::ok($ret); # 返回值
  263. }
  264. private static function _AddTesterZonelist($req, &$zoneList) {
  265. if (config::Inst()->isTester($req->uid)) { # 添加测试分区
  266. $zoneList[] = array('zoneid' => 999, 'name' => '内测专区', 'status' => 2, 'publicTs' => 0);
  267. }
  268. }
  269. /**
  270. * 6002 客户端下载常量配置信息
  271. * @param Req $req
  272. * @return type
  273. */
  274. public static function downloadConstInfo($req) {
  275. $clientver = $req->paras[0]; # 客户端数据版本号
  276. $serverVer = GameConfig::ver(); # 最新数据版本号
  277. my_Assert($serverVer, ErrCode::err_const_no); # 找不到常量数据
  278. if ($clientver == $serverVer) { # 如果版本一致,数据体抹掉,只传回版本号
  279. // $md5 = md5(json_encode($constInfo)); # 计算MD5值,多余计算md5
  280. $ret = array(
  281. 'version' => $clientver,
  282. 'data' => null);
  283. return Resp::ok($ret);
  284. }
  285. $constInfo = GameConfig::client(); # 取出来的已经是base64过的压缩数据
  286. my_Assert($constInfo, ErrCode::err_const_no); # 找不到配置数据
  287. return Resp::ok(array('data' => $constInfo));
  288. }
  289. /**
  290. * 6001 客户端登录并返还玩家信息
  291. * @param Req $req
  292. * @return Resp
  293. */
  294. public static function loginUserInfo($req) {
  295. // return ResponseVo::ErrResponse($req, ErrCode::msg_methodnotimplement);
  296. $userInfo = UserProc::getUserInfo(gMem(), $req->zoneid, $req->uid); # 取玩家信息
  297. if ($userInfo == null) { # 新用户, -> 6006创建账号
  298. $ret = array(
  299. 'isNewUser' => true
  300. );
  301. return Resp::ok($ret);
  302. } else {//2.如果玩家已存在,则处理普通登录流程
  303. $req->userInfo = $userInfo; # 给Req挂载userInfo
  304. UserProc::checkContidays($req); # 连续登录,状态检查
  305. // UserProc::_checkUpdateGift($req); # 检查更新礼包
  306. // UserProc::fetchFromInteract($mem, $req); # 从交互体更新部分信息
  307. PayProc::m_refreshChargeOrders($req); # 刷新订单, 多平台版本
  308. PayProc::checkDeltest($req); # 检查内侧充值记录(函数内部会只检查一次)
  309. UserProc::updateUserInfo(); # 这一步回存操作只有在 userInfo正常存在的情况下才进行
  310. $resp = Resp::ok($userInfo); # 设置返回值
  311. // if (isset($req->updateGift)) { # 透传更新礼包给Response
  312. // $resp->updateGift = $req->updateGift;
  313. // }
  314. self::backupUserInfo($req); # 数据回写
  315. self::updtateUserZoneInfo($req); # 1. 更新玩家分区记录
  316. }
  317. return $resp;
  318. }
  319. /**
  320. * 6003 领取连续登录奖励
  321. * @param Req $req
  322. */
  323. public static function acceptContiDaysGift($req) {
  324. $resp = Resp::err(ErrCode::err_method_notimplement);
  325. return $resp;
  326. }
  327. // <editor-fold defaultstate="collapsed" desc="送审/测试用方法">
  328. /**
  329. * 6004 测试: 注册新用户UID
  330. * @param Req $req
  331. * @return type
  332. */
  333. public static function RegisterNewUID($req) {
  334. if (count($req->paras) < 2) { # 参数数量不足
  335. return Resp::err(ErrCode::parasnotenough_msg);
  336. }
  337. $userName = $req->paras[0]; # 取参数 昵称
  338. $pwd = $req->paras[1]; # 密码
  339. $email = count($req->paras) > 2 ? $req->paras[2] : ""; # 邮箱
  340. $phoneNumber = count($req->paras) > 3 ? $req->paras[3] : ""; # 电话号码
  341. $ret = RegNewUser::Write2MysqlUserInfo($userName, $pwd, $email, $phoneNumber); // 执行逻辑
  342. self::setNewbieGuideOver($req);
  343. return Resp::ok($ret);
  344. }
  345. /**
  346. * 6005 测试用的用户登录
  347. * @param Req $req
  348. */
  349. public static function TestUserLogin($req) {
  350. if (count($req->paras) < 2) {// 防御:参数数量不足
  351. return Resp::err(ErrCode::parasnotenough_msg);
  352. }
  353. $userName = $req->paras[0]; // 用户名
  354. $pwd = $req->paras[1]; // 密码
  355. $ret = RegNewUser::VerifyUserPwd($userName, $pwd); // 校验
  356. return Resp::ok($ret);
  357. }
  358. // </editor-fold>
  359. //
  360. // <editor-fold defaultstate="collapsed" desc=" 辅助方法 ">
  361. /**
  362. * 检查昵称是否已经存在
  363. * @param string $roleName
  364. * @return boolean
  365. */
  366. static function checkRoleNameNotExist($roleName) {
  367. static $sqlFormat = "SELECT count(*) as rows FROM `tab_rolename` WHERE roleName='%s';";
  368. $sql = sprintf($sqlFormat, $roleName);
  369. $n = daoInst()->query($sql)->fetch();
  370. return $n->rows <= 0;
  371. }
  372. /**
  373. * 插入玩家新角色
  374. *
  375. * @param string $zoneid
  376. * @param string $userID
  377. * @param string $nickname
  378. * @param string $gender
  379. * @param string $profile_img
  380. * @param string $plat
  381. */
  382. static function regRole($zoneid, $userID, $nickname, $gender, $profile_img, $plat) {
  383. $paydb = CPayInit();
  384. $sqlFormat = "INSERT INTO `tab_rolename` ( zoneid,userID,roleName,gender, profile,plat) "
  385. . "VALUES ('%s','%s','%s','%s','%s','%s')";
  386. $sql = sprintf($sqlFormat, $zoneid, $userID, #
  387. $paydb->escape_string($nickname), $gender, $profile_img, $plat);
  388. $paydb->query($sql);
  389. $paydb->close();
  390. }
  391. /**
  392. * 检测连续登录状态,重置必要字段[时间戳自动记录]
  393. * @param Req $req
  394. */
  395. static function checkContidays($req, $isnew = 0) {
  396. $ret = TimeUtil::tsDay() - TimeUtil::tsDay($req->userInfo->game->baseInfo->lastLogin); // 对比登录日期
  397. if ($ret > 0) { # 当天第一次登录
  398. self::OnNewDay($req, $isnew);
  399. } else {
  400. # 更新下登录次数记录(任务计数器)
  401. }
  402. if ($ret == 1) { # 连续登录
  403. } else if ($ret >= 2) { # 隔天登录
  404. }
  405. $req->userInfo->game->baseInfo->lastLogin = now(); # 更新下访问时间
  406. TaskProc::ResetDailyTask($req); # 重置每日任务
  407. TaskProc::OnUserLogin();
  408. return $ret;
  409. }
  410. /**
  411. * 处理当天第一次登录
  412. * @param RequesstVo $req
  413. * @param bool $isnew Description
  414. */
  415. static function OnNewDay($req, $isnew) {
  416. self::updatePlatUserRecord($req, $isnew); # 添加到到当天活跃玩家记录集合
  417. ActiveProc::DailyReset($req); # 抽奖、每日任务状态,计数器...
  418. FightProc::ClearByDay($req); # 战斗相关状态每日清理
  419. ShopProc::DailyCheck($req);
  420. }
  421. // <editor-fold defaultstate="collapsed" desc="创建新用户">
  422. /**
  423. * 创建用户
  424. * @param Req $req
  425. * @return UserInfoMo
  426. */
  427. static function createUser($req, $rolename, $gender, $profile_img) {
  428. $userInfo = new UserInfoMo();
  429. $req->userInfo = $userInfo; # 更新Req的userinfo,
  430. $userInfo->uid = $req->uid;
  431. $userInfo->zoneid = $req->zoneid;
  432. $userInfo->game = new UserGameModel();
  433. $userInfo->game->initialize(); # 初始化玩家数据
  434. $userInfo->game->baseInfo->name = $rolename;
  435. $userInfo->game->baseInfo->gender = $gender;
  436. $userInfo->game->baseInfo->headImg = $profile_img;
  437. $userInfo->game->baseInfo->firstLogin = now();
  438. // $userInfo->game->pvp->socre = PVPProc::_getScore_by_uid($req, $req->uid); # 初始化pvp积分
  439. // $userInfo->game->NewbieGuideOver = 1;
  440. // UserProc::_intiHeroManual($userInfo->game); # 初始化图鉴
  441. #Ps 6006是没有获得到Userinfo到Req中的
  442. UserProc::checkContidays($req, 1); # 每日状态检查
  443. // UserProc::fetchFromInteract($mem, $req); # 从interact拉取数据,Ps.初始化的过程应该还拉取不到什么有效数据
  444. UserProc::updateUserInfo(); # 回存用户数据
  445. // FriendProc::Init($req);
  446. // StatProc:: ...
  447. gMem()->increment(MemKey_GameRun::Stat_UserCountByZone_int($req->zoneid)); # 增加玩家数量计数
  448. // GoalsDailyProc::dealDailyLogin($mem, $req, $resp); # 每日登录任务
  449. return $userInfo;
  450. }
  451. /**
  452. * 整理平台玩家记录集
  453. * @param Req $req
  454. * @param int $isnew
  455. */
  456. private static function updatePlatUserRecord($req, $isnew = 0) {
  457. $zoneid = $req->zoneid;
  458. $uid = $req->uid;
  459. $user = $req->userInfo->game->baseInfo;
  460. $day = tsDay();
  461. $level = $user->level;
  462. $platUser = ObjectInit();
  463. $platUser->uid = $uid; #
  464. $platUser->name = $user->name; #
  465. $platUser->level = $level;
  466. $platUser->img = $user->headImg; # 头像字段
  467. $platUser->cash = $user->cash;
  468. $platUser->gold = $user->gold;
  469. $platUser->tili = $user->tili;
  470. $platUser->ts = now();
  471. $platUser->isnew = $isnew;
  472. gMem()->delete(MemKey_GameRun::DailyLoginUser_byUID_hash($zoneid, $day - 108));
  473. gMem()->hset(MemKey_GameRun::DailyLoginUser_byUID_hash($zoneid), $uid, $platUser);
  474. gMem()->delete(MemKey_GameRun::DailyLoginUser_byLevel_hash($zoneid, $level, $day - 108));
  475. gMem()->hset(MemKey_GameRun::DailyLoginUser_byLevel_hash($zoneid, $level), $uid, $platUser);
  476. }
  477. // </editor-fold>
  478. //
  479. // <editor-fold defaultstate="collapsed" desc="读写玩家数据">
  480. /**
  481. * 玩家数据
  482. * @param CRedisUtil $mem
  483. * @param type $zoneid
  484. * @param type $uid
  485. * @return UserInfoMo
  486. */
  487. public static function getUserInfo($mem, $zoneid, $uid) {
  488. $key = MemKey_User::Info_hash($zoneid, $uid);
  489. $a = new UserGameModel();
  490. if (null == $a->readDataFromMem($key)) {
  491. return null;
  492. }
  493. $usrInfo = new UserInfoMo();
  494. $usrInfo->zoneid = $zoneid;
  495. $usrInfo->uid = $uid;
  496. $g = new UserGameModel($a);
  497. $usrInfo->game = $g;
  498. return $usrInfo;
  499. }
  500. /**
  501. * 更新用户数据(设置标志位,最后统一更新-gwang 2017.07.18)
  502. */
  503. public static function updateUserInfo() {
  504. my_Assert(req(), "req()为空");
  505. my_Assert(req()->userInfo, "[" . req()->cmd . "] 玩家数据正在被清空!" . req()->uid);
  506. req()->userInfoChanged = TRUE; # 设置回写标志位
  507. }
  508. /**
  509. * 回写玩家数据
  510. * @param UserInfoMo $userInfo
  511. */
  512. public static function setUserInfo(UserInfoMo $userInfo) {
  513. if ($userInfo) {
  514. $zoneid = $userInfo->zoneid;
  515. $uid = $userInfo->uid;
  516. $userInfo->game->baseInfo->lastSaveTs = now();
  517. $key = MemKey_User::Info_hash($zoneid, $uid);
  518. return $userInfo->game->updateData($key);
  519. // return $mem->set(MemKey_User::Info($zoneid, $uid), $userInfo->game);
  520. }
  521. return false;
  522. }
  523. // </editor-fold>
  524. //
  525. // <editor-fold defaultstate="collapsed" desc="玩家分区记录">
  526. /**
  527. * 读取玩家的分区记录
  528. * @param Req $req
  529. * @return UserZoneInfoModel Description
  530. */
  531. public static function getUserZoneInfo($req) {
  532. $ret = $req->mem->get(MemKey_User::Union_PlayedZoneInfo_normal($req->uid));
  533. return $ret;
  534. }
  535. /**
  536. * 更新玩家分区记录
  537. * @param Req $req
  538. */
  539. public static function updtateUserZoneInfo($req) {
  540. $userZoneInfo = self::getUserZoneInfo($req); # 取玩家分区记录
  541. if (!$userZoneInfo) {
  542. $userZoneInfo = new UserZoneInfoModel;
  543. }
  544. $level = 0;
  545. $zoneid = $req->zoneid;
  546. $playerName = "";
  547. $headImg = "";
  548. if (isset($req->userInfo)) { # 防御确保玩家数据不为空
  549. $level = $req->userInfo->game->baseInfo->level;
  550. $playerName = $req->userInfo->game->baseInfo->name;
  551. $headImg = $req->userInfo->game->baseInfo->headImg;
  552. } else {
  553. CLog::warn('玩家数据为空!' . __CLASS__ . '.' . __FUNCTION__);
  554. }
  555. if (is_null($level)) {
  556. $level = 0;
  557. }
  558. $userZoneInfo->lastZone = new ZoneInfoModel($zoneid, $level, $playerName, $headImg); # 更新玩家分区记录
  559. $userZoneInfo->playedZones->$zoneid = $userZoneInfo->lastZone; # 玩过的分区集合
  560. $req->mem->set(MemKey_User::Union_PlayedZoneInfo_normal($req->uid), $userZoneInfo); # 回写数据
  561. }
  562. // </editor-fold>
  563. // <editor-fold defaultstate="collapsed" desc=" 用户数据备份 ">
  564. /**
  565. * 备份玩家数据,(玩家数据落地),一天一份,当天记为最后一次登录时的状态而非最后一次操作的状态
  566. * @history
  567. * version 3.0.13 mysql版备份玩家数据, (性能优化后表现还不错)
  568. * 除非用脚本在redis中实现备份,否则直接写入mysql.
  569. * 主要是mysql版本利用存储过程之后性能已经和redis版相差不多.
  570. * version 2.0.0 Redis storage 从MySQL转到Redis中存储. 这个备份数据没有大规模导出硬盘的需求
  571. * 因为mysql版本实在是负载太大了, 上百毫秒. 所以改在redis中了.
  572. * version 1.0.0 Mysql storagef 1. 分表不做了, 2. 存储过程不用了 3. 先能用再说
  573. * @param Req $req
  574. */
  575. public static function backupUserInfo($req) {
  576. $tsday = TimeUtil::tsDay(); # 精确到天,保留10个最近记录.
  577. $value = base64_encode(gzdeflate(JsonUtil::encode($req->userInfo))); # blob数据,序列化下
  578. $sql = sprintf("call insertUserInfo('%s', %d, %d, '%s');", # # 所以直接将序列化后的结果存进去吧,
  579. $req->uid, $req->zoneid, $tsday, $value); # zoneid, uid, tsday
  580. daoInst()->query($sql); # 也可以用exec($sql)
  581. }
  582. // </editor-fold>
  583. //</editor-fold>
  584. //
  585. }
  586. //
  587. // <editor-fold defaultstate="collapsed" desc="测试/送审 => 注册新用户的业务逻辑">
  588. /**
  589. * 注册新用户
  590. * @author gwang
  591. */
  592. class RegNewUser {
  593. /**
  594. * 查找已有用户
  595. */
  596. const SQL_SelectUser = "Select tid, pwd from `tab_register` where `userName` = '%s' order by tid limit 1;
  597. ";
  598. /**
  599. * 插入新用户, Ps 常量字符串只能这么写了
  600. */
  601. const SQL_InsertNewUser = <<<sql
  602. Insert Into `tab_register` ( `userName`, `pwd`, `mail`, `phoneNumber`) values ( '%s', '%s', '%s', '%s');
  603. sql;
  604. /**
  605. * 写用户信息到数据库
  606. * @param string $userName
  607. * @param string $pwd
  608. * @param string $email
  609. * @param string $phoneNumber
  610. * @return array
  611. */
  612. public static function Write2MysqlUserInfo($userName, $pwd, $email = "", $phoneNumber = "") {
  613. $paydb = CPayInit();
  614. $sql_sel = sprintf(self::SQL_SelectUser, $userName);
  615. $data = $paydb->fetch_result($sql_sel);
  616. if (count($data) > 0) { # 已经有用户了,那么注册失败.
  617. return array('ret' => -1, 'msg' => "这个账号已经注册过了.");
  618. } # 尚未注册, 继续执行
  619. $sql_insert = sprintf(self::SQL_InsertNewUser, $userName, $pwd, $email, $phoneNumber);
  620. if (false === $paydb->query($sql_insert)) { # 插入用户信息
  621. return array('ret' => -1, 'msg' => "数据插入失败, 请重试.");
  622. }
  623. $ret = array('ret' => 0, 'msg' => "注册成功."); # 插入成功, 返回
  624. $paydb->close();
  625. return $ret;
  626. }
  627. /**
  628. * 验证用户名和密码
  629. * @param type $userName
  630. * @param type $pwd
  631. */
  632. public static function VerifyUserPwd($userName, $pwd) {
  633. $paydb = CPayInit();
  634. $sql_sel = sprintf(self::SQL_SelectUser, $userName);
  635. $data = $paydb->fetch_result($sql_sel);
  636. $paydb->close();
  637. if (count($data) > 0) {
  638. if ($data[0]["pwd"] == $pwd) { # 验证成功
  639. return array('ret' => 0, 'msg' => "通过.");
  640. } else {
  641. return array('ret' => -1, 'msg' => "密码错误.");
  642. }
  643. }
  644. return array('ret' => -1, 'msg' => "账号不存在.");
  645. }
  646. }
  647. // </editor-fold>
  648. //