MemGameLogic.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387
  1. <?php
  2. /**
  3. * MemGameLogic.php UTF-8
  4. * 玩家游戏逻辑
  5. *
  6. * @date : 2018/8/15 17:47
  7. *
  8. * @license 这不是一个自由软件,未经授权不许任何使用和传播。
  9. * @author : chenbingling <cbl@huosdk.com>
  10. * @version : HUOSDK 8.0
  11. */
  12. namespace huomp\logic\game;
  13. use huo\controller\wap\Option;
  14. use huo\model\agent\AgentGameModel;
  15. use huo\model\member\MemberModel;
  16. use huo\model\member\MemGameModel;
  17. use huo\model\order\OrderModel;
  18. use huo\model\user\UserModel;
  19. use huolib\constant\CacheConst;
  20. use huolib\constant\CommonConst;
  21. use huolib\constant\GameConst;
  22. use huolib\constant\OptionConst;
  23. use huolib\constant\OrderConst;
  24. use huolib\status\CommonStatus;
  25. use huolib\tool\Time;
  26. use huomp\model\common\CommonModel;
  27. use huomp\model\fill\MemFakerModel;
  28. use think\Cache;
  29. use think\db\exception\DataNotFoundException;
  30. use think\db\exception\ModelNotFoundException;
  31. use think\exception\DbException;
  32. class MemGameLogic extends CommonModel {
  33. protected function getWhere($where = []) {
  34. $_map = [];
  35. if (!empty($param['start_time']) && !empty($param['end_time'])) {
  36. $_map['create_time'] = ['between', [$param['start_time'], $param['end_time']]];
  37. } elseif (!empty($param['start_time'])) {
  38. $_map['create_time'] = ['egt', $param['start_time']];
  39. } elseif (!empty($param['end_time'])) {
  40. $_map['create_time'] = ['elt', $param['end_time']];
  41. }
  42. if (!empty($where['app_id'])) {
  43. $_map['app_id'] = $where['app_id'];
  44. }
  45. if (!empty($where['agent_id'])) {
  46. $_map['guided_agent_id'] = $where['agent_id'];
  47. if ('-1' == $where['agent_id']) {
  48. $_map['guided_agent_id'] = 0;
  49. }
  50. // 数组类型官方渠道筛选
  51. if (is_array($where['agent_id']) && !empty($where['agent_id'][1])
  52. && is_array($where['agent_id'][1])
  53. && in_array('-1', $where['agent_id'][1])) {
  54. $_map['guided_agent_id'] = 0;
  55. }
  56. }
  57. if (!empty($where['start_time']) && !empty($where['end_time'])) {
  58. $_map['create_time']
  59. = [
  60. 'between',
  61. [
  62. strtotime($where['start_time']),
  63. CommonConst::CONST_DAY_SECONDS + strtotime($where['end_time'])
  64. ]
  65. ];
  66. } elseif (!empty($where['start_time'])) {
  67. $_map['create_time'] = ['egt', strtotime($where['start_time'])];
  68. } elseif (!empty($where['end_time'])) {
  69. $_map['create_time'] = ['elt', CommonConst::CONST_DAY_SECONDS + strtotime($where['end_time'])];
  70. }
  71. if (!empty($where['mem_id'])) {
  72. $_map['mem_id'] = $where['mem_id'];
  73. }
  74. if (!empty($where['username'])) {
  75. $_map['mem_id'] = (new MemberModel())->getIdByUsername($where['username']);
  76. }
  77. if (!empty($where['is_recharged'])) {
  78. if ($where['is_recharged'] == CommonConst::STATUS_YES) {
  79. $_map['sum_money'] = ['>', 0];
  80. } else {
  81. $_map['sum_money'] = ['=', 0];
  82. }
  83. }
  84. return $_map;
  85. }
  86. /**
  87. * 获取玩家游戏列表
  88. *
  89. * @param int $mem_id
  90. * @param array $where
  91. * @param string $page
  92. * @param string $order
  93. *
  94. * @return array|int
  95. */
  96. public function getMemGames($mem_id = 0, $where = [], $page = '1,10', $order = 'create_time desc') {
  97. $_rdata = ['count' => 0, 'list' => []];
  98. if (!empty($mem_id)) {
  99. $_map['mem_id'] = $mem_id;
  100. }
  101. $_map = $this->getWhere($where);
  102. $_mem_game_model = new MemGameModel();
  103. $_count = $_mem_game_model->with('game2,guidedagent')->where($_map)->count('id');
  104. if (empty($_count)) {
  105. return $_rdata;
  106. }
  107. $_app_arr = $_mem_game_model->with('game2,guidedagent')
  108. ->where($_map)
  109. ->page($page)
  110. ->order($order)
  111. ->select();
  112. if (is_object($_app_arr)) {
  113. $_app_arr = $_app_arr->toArray();
  114. }
  115. if (empty($_app_arr)) {
  116. return $_rdata;
  117. }
  118. $_lis = [];
  119. foreach ($_app_arr as $_k => $_v) {
  120. $data = [];
  121. $data['id'] = $_v['id'];
  122. $data['mem_id'] = $_v['mem_id'];
  123. $data['app_id'] = $_v['app_id'];
  124. $data['nickname'] = $_v['nickname'];
  125. $data['create_time'] = $_v['create_time'];
  126. $data['update_time'] = $_v['update_time'];
  127. $data['name'] = empty($_v['game2']['name']) ? '' : $_v['game2']['name'];
  128. $data['icon'] = empty($_v['game2']['icon']) ? '' : $_v['game2']['icon'];
  129. $data['guided_agent_id'] = $_v['guided_agent_id'];
  130. $data['guided_agent_name'] = $_v['guidedagent']['user_login'] ?? '';
  131. $data['guided_agent_nicename'] = $_v['guidedagent']['user_nicename'] ?? '';
  132. $data['sum_money'] = $_v['sum_money'] ?? 0;
  133. $_lis[] = $data;
  134. }
  135. $_rdata = ['count' => $_count, 'list' => $_lis];
  136. return $_rdata;
  137. }
  138. /**
  139. * 获取玩家游戏列表
  140. *
  141. * @param int $mem_id
  142. *
  143. * @return array|int
  144. */
  145. public function getMemGamesIdName($mem_id = 0) {
  146. $_rdata = [];
  147. if (empty($mem_id)) {
  148. return $_rdata;
  149. }
  150. $_map['mem_id'] = $mem_id;
  151. try {
  152. $_app_arr = (new MemGameModel())->with('game2')
  153. ->field('app_id')
  154. ->where($_map)
  155. ->select();
  156. } catch (DataNotFoundException $e) {
  157. return CommonStatus::DATA_NOT_FOUND_EXCEPTION;
  158. } catch (ModelNotFoundException $e) {
  159. return CommonStatus::MODEL_NOT_FOUND_EXCEPTION;
  160. } catch (DbException $e) {
  161. return CommonStatus::DB_EXCEPTION;
  162. }
  163. if (is_object($_app_arr)) {
  164. $_app_arr = $_app_arr->toArray();
  165. }
  166. if (empty($_app_arr)) {
  167. $_rdata = [];
  168. }
  169. foreach ($_app_arr as $_k => $_v) {
  170. if (!empty($_v['game2'])) {
  171. $_rdata[$_v['app_id']] = $_v['game2']['name'];
  172. }
  173. }
  174. return $_rdata;
  175. }
  176. /**
  177. * 获取玩家游戏列表
  178. *
  179. * @param int $mem_id
  180. * @param array $where
  181. * @param string $page
  182. * @param string $order
  183. *
  184. * @return array|int
  185. */
  186. public function getApiMemGame($mem_id = 0, $where = [], $page = '1,10', $order = 'update_time desc') {
  187. $_rdata = ['count' => 0, 'list' => []];
  188. if (empty($mem_id)) {
  189. return $_rdata;
  190. }
  191. $_map = $this->getWhere($where);
  192. $_map['mem_id'] = $mem_id;
  193. $_map['classify'] = GameConst::GAME_MP;
  194. $_map['game.status'] = GameConst::GAME_STATUS_ON;
  195. $_mem_game_model = new MemGameModel();
  196. $_count = $_mem_game_model->with('game')->where($_map)->count('distinct(app_id)');
  197. if (empty($_count)) {
  198. return $_rdata;
  199. }
  200. $_app_arr = $_mem_game_model->with('game,gamemini,gameext,gv')
  201. ->where($_map)
  202. ->page($page)
  203. ->order($order)
  204. ->select();
  205. if (is_object($_app_arr)) {
  206. $_app_arr = $_app_arr->toArray();
  207. }
  208. if (empty($_app_arr)) {
  209. return $_rdata;
  210. }
  211. $_list = [];
  212. $_agent_id = (new UserModel())->getIdByMemId($mem_id);
  213. $_agent_game_model = new AgentGameModel();
  214. foreach ($_app_arr as $_k => $_v) {
  215. $data = [];
  216. $data['is_add'] = CommonConst::CONST_FALSE;
  217. if (!empty($_agent_id)) {
  218. $_agent_game_info = $_agent_game_model->getInfoByAgentIdAppId($_agent_id, $_v['app_id']);
  219. }
  220. if (!empty($_agent_game_info) && $_agent_game_info['is_delete'] == CommonConst::CONST_NOT_DELETE) {
  221. $data['is_add'] = CommonConst::CONST_TRUE;
  222. }
  223. $_need_popup = empty($_v['gamemini']['need_popup']) ? GameConst::RATE_MP_NEED_POPUP_NOT
  224. : $_v['gamemini']['need_popup'];
  225. $_entrance_image = '';
  226. if (GameConst::RATE_MP_NEED_POPUP == $_need_popup) {
  227. $_entrance_image = empty($_v['gamemini']['entrance_image'])
  228. ? ''
  229. : cmf_get_image_url(
  230. $_v['gamemini']['entrance_image']
  231. );
  232. }
  233. $data['ag_id'] = $_v['id'];
  234. $data['game_id'] = $_v['app_id'];
  235. $data['mini_app_id'] = empty($_v['gamemini']['mini_app_id']) ? '' : $_v['gamemini']['mini_app_id'];
  236. $data['gamename'] = empty($_v['game']['name']) ? '' : $_v['game']['name'];
  237. $data['icon'] = empty($_v['game']['icon']) ? '' : $_v['game']['icon'];
  238. $data['oneword'] = empty($_v['game']['oneword']) ? '' : $_v['game']['oneword'];
  239. $data['down_cnt'] = empty($_v['gameext']['down_cnt']) ? 0 : $_v['gameext']['down_cnt'];
  240. $data['url'] = empty($_v['gv']) ? '' : $_v['gv'][0]['package_url'];
  241. $data['mem_agent_reward'] = 0;// TODO: wuyonghong 2018/8/23 附加奖励
  242. $data['need_popup'] = $_need_popup;
  243. $data['entrance_image'] = $_entrance_image;
  244. $data['player'] = $this->getPlayer($mem_id, $_v['app_id']);
  245. $_list[] = $data;
  246. }
  247. $_rdata = ['count' => $_count, 'list' => $_list];
  248. return $_rdata;
  249. }
  250. /**
  251. * 获取该游戏,该玩家的亲友团信息
  252. *
  253. * @param $mem_id
  254. * @param $game_id
  255. *
  256. * @return array
  257. */
  258. public function getPlayer($mem_id, $game_id) {
  259. $_avatar_cnt = $this->getMemPlayerCfg(OptionConst::SETTING_MEM_PLAYER_AC);
  260. $_rdata = $this->getFakerPlayer(); //虚假数据,作为原始返回
  261. /* 获取玩家的亲友团 */
  262. $_sub_mem_ids = (new MemberModel())->getIdsByParentMemId($mem_id);
  263. if (empty($_sub_mem_ids)) {
  264. return $_rdata;
  265. }
  266. $_game_mems = $this->getGameMem($mem_id, $game_id, $_sub_mem_ids); //真实数据
  267. if (empty($_game_mems['count'])) {
  268. return $_rdata;
  269. }
  270. $_rdata['count'] += $_game_mems['count'];
  271. $_rdata['avatar'] = array_merge($_game_mems['avatar'], $_rdata['avatar']);
  272. if (count($_rdata['avatar']) > $_avatar_cnt) { //多余去除
  273. $_avatar = [];
  274. $_k = 0;
  275. foreach ($_rdata['avatar'] as $_v) {
  276. if ($_k >= $_avatar_cnt) {
  277. continue;
  278. }
  279. $_avatar[] = $_v;
  280. $_k++;
  281. }
  282. $_rdata['avatar'] = $_avatar;
  283. }
  284. return $_rdata;
  285. }
  286. /**
  287. * 获取虚拟的玩家数据
  288. */
  289. public function getFakerPlayer() {
  290. $_avatar_cnt = $this->getMemPlayerCfg(OptionConst::SETTING_MEM_PLAYER_AC);
  291. $_faker_cnt = $this->getMemPlayerCfg(OptionConst::SETTING_MEM_PLAYER_FC);
  292. $_rdata = ['count' => 0, 'avatar' => []];
  293. $_avatar = (new MemFakerModel())->getAvatars();
  294. if (empty($_avatar)) {
  295. return $_rdata;
  296. }
  297. $_rdata['count'] = $_faker_cnt;
  298. if (count($_avatar) > $_avatar_cnt) {
  299. $_key = array_rand($_avatar, $_avatar_cnt);
  300. foreach ($_key as $_v) {
  301. $_rdata['avatar'][] = cmf_get_image_preview_url($_avatar[$_v]);
  302. }
  303. }
  304. return $_rdata;
  305. }
  306. /**
  307. * 获取游戏玩家数据
  308. *
  309. * @param $mem_id
  310. * @param $game_id
  311. * @param $sub_mem_ids
  312. *
  313. * @return mixed
  314. */
  315. public function getGameMem($mem_id, $game_id, $sub_mem_ids) {
  316. $_tag = CacheConst::TAG_GAME_MEMS;
  317. $_avatar_cnt = $this->getMemPlayerCfg(OptionConst::SETTING_MEM_PLAYER_AC);
  318. $_rdata = ['count' => 0, 'avatar' => []];
  319. $_cache_key = CacheConst::CACHE_GAME_MEMS.json_encode([$mem_id, $game_id]);
  320. $_data = Cache::get($_cache_key);
  321. if (!empty($_data)) {
  322. return json_decode($_data, true);
  323. }
  324. $_map = [
  325. 'app_id' => $game_id,
  326. 'mem_id' => ['in', $sub_mem_ids]
  327. ];
  328. $_mem_ids = (new MemGameModel())->where($_map)->column('mem_id');
  329. list($_start_time, $_end_time) = Time::today();
  330. $_diff_time = $_end_time - time();
  331. if (empty($_mem_ids)) {
  332. Cache::tag($_tag, $_cache_key)->set($_cache_key, json_encode($_rdata), $_diff_time);
  333. return $_rdata;
  334. }
  335. $_rdata['count'] = count($_mem_ids);
  336. if ($_rdata['count'] > $_avatar_cnt) {
  337. $_key = array_rand($_mem_ids, $_avatar_cnt);
  338. $_mems = [];
  339. foreach ($_key as $_v) {
  340. $_mems[] = $_mem_ids[$_v];
  341. }
  342. $_mem_ids = $_mems;
  343. }
  344. $_avatar = (new MemberModel())->where(['id' => ['in', $_mem_ids]])->column('avatar');
  345. $_rdata['avatar'] = $_avatar;
  346. Cache::tag($_tag, $_cache_key)->set($_cache_key, json_encode($_rdata), $_diff_time);
  347. return $_rdata;
  348. }
  349. /**
  350. * 获取后台配置好友玩信息
  351. *
  352. * @param string $field
  353. *
  354. * @return int
  355. */
  356. public function getMemPlayerCfg($field = OptionConst::SETTING_MEM_PLAYER_FC) {
  357. $_setting_name = OptionConst::SETTING_MEM_PLAYER;
  358. $_m = new Option();
  359. $_item = $_m->getOptionData($_setting_name, 1, true);
  360. if (!empty($_item['option_value'])) {
  361. $_option_value = json_decode($_item['option_value'], true);
  362. }
  363. if (!empty($_option_value[$field])) {
  364. return $_option_value[$field];
  365. }
  366. return 0;
  367. }
  368. }