UserProc.php 28 KB

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