UserProc.php 35 KB

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