UserProc.php 29 KB

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