UserProc.php 31 KB

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