UserProc.php 31 KB

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