PayProc.php 45 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900
  1. <?php
  2. namespace loyalsoft;
  3. require_once __DIR__ . '/../service_call/pay/official/pay_op.php'; # 封装渠道支付模块的操作
  4. /**
  5. * 付费、游戏内消费相关处理
  6. * 全部动态交易数据需要保存到db作为[存根]
  7. * @version <br/>
  8. * 6.0.0 第六版: 引入currency字段, 增加出海结算支持. 2022.11
  9. * 5.0.0 第五版: 全部动态交易数据存入mysql. 2021.11
  10. * 4.0.0 第四版: 言灵世界 商城模块. 2020.08
  11. * 2.2.0 第三版: 独立的游戏币<元宝>, 面向多渠道的充值模式, 拉起充值成功后, 给玩家发放元宝. 游戏内部消费元宝,钻石和金币.可以用元宝购买金币和钻石.这一版在上面的PayProc中 * 2015年9月23日 <br/>
  12. * 2.1.0 mn_pay mn_AddUserCash ... 以 mn_ 打头的函数是第二版, 修改为伪托管模式,除了充值的时候跟腾讯通讯,其余时间自己管理游戏币:钻石. * 2015年7月23日 <br/>
  13. * 2.0.1 m_pay m_AddUserCash ... 以 m_ 打头的函数是第一版, 完全按照应用宝官方要求托管游戏币的模式开发的. * 2015年4月23日 <br/>
  14. * 1.0.0 Created at 2016-4-20. by --gwang <br/>
  15. * @author gwang (mail@wanggangzero.cn)
  16. * @copyright © 2016-4-20, SJZ LoyalSoft Corporation & gwang. All rights reserved.
  17. */
  18. class PayProc {
  19. const orderTab = 'tpl_order_tab';
  20. /**
  21. * 逻辑分发
  22. * 所有的Proc中必须有这样一个方法
  23. */
  24. public static function procMain() {
  25. switch (req()->cmd) {
  26. // 支付相关的活动
  27. case CmdCode::cmd_pay_getfirstpaygift: # 8802 领取首充礼包
  28. return PayProc::m_GetFirstPayGift();
  29. // 游戏内二级货币消费
  30. case CmdCode::cmd_mpay_pay: # 8807 消费..
  31. return self::m_pay(); # ::==> 购买普通商城物品
  32. case CmdCode::cmd_mpay_buyDynamic: # 8809 购买动态商城物品
  33. return self::m_pay_buyDynamic();
  34. case CmdCode::cmd_mpay_getDynamic: # 8810 刷新神秘商城物品
  35. return self::m_pay_getDynamic();
  36. // 充值消费
  37. case CmdCode::cmd_mpay_get_balance: # 8808 刷新账号余额
  38. return self::m_refreshChargeOrders(); # ::==> 刷新订单-领取充值金额
  39. case CmdCode::cmd_mpay_selfCheckOrders: # 8811 自助检查异常订单
  40. return self::selfhelpCheckOrders();
  41. case CmdCode::cmd_mpay_getPayRecords: # 8812 查询订单记录
  42. return self::GetPayRecoreds();
  43. case CmdCode::cmd_mpay_PayDeliverGoods: # 8813 查询订单并发货
  44. return self::PayDeliverGoods();
  45. case CmdCode::cmd_mpay_UserRechargeDrawPrize: # 8814 充值领奖励 2022.10
  46. return self::UserRechargeDrawPrize();
  47. case CmdCode::cmd_mpay_NewFirstRecharge: # 8815 新首充功能 2022.10
  48. return self::NewFirstRecharge();
  49. default:
  50. return Resp::err(ErrCode::cmd_err);
  51. }
  52. }
  53. static $retArr;
  54. /**
  55. * 8815 新首冲功能5点前不能领取奖励,则该请求只是为了首充开发界面时获得最新时间戳
  56. */
  57. static function NewFirstRecharge() {
  58. UserProc::updateUserInfo();
  59. return Resp::ok(array(
  60. "ret" => 'true',
  61. ));
  62. }
  63. /**
  64. * [8814]领取奖励 (新版2021)
  65. */
  66. static function UserRechargeDrawPrize() {
  67. list($type, $typeId) = req()->paras;
  68. $user = ctx();
  69. self::$retArr = array();
  70. switch ($type) {
  71. case Enum_Recharge::FirstRecharge://首冲
  72. my_Assert($user->pay->firstRechage == 0, ErrCode::shop_firstRechargeNotRepeat);
  73. StoreProc::AddMultiItemInStore(GameConfig::globalsettings()->firstRechargePrizes);
  74. $user->pay->firstRechage = 1;
  75. self::$retArr[] = GameConfig::globalsettings()->firstRechargePrizes;
  76. break;
  77. case Enum_Recharge::DaliySpecialPackages://每日特惠
  78. my_Assert(!in_array($typeId, $user->shopdata->daliySpecialPackages), ErrCode::shop_daliySpecialRewardNotRepeat);
  79. $mo = GameConfig::shop_limit_getItem($typeId);
  80. my_Assert($mo != null, ErrCode::err_const_no);
  81. if ($mo->price != 0) {//购买60元7天特惠,则不是免费的礼包现在也可以领取。这里校验一下
  82. //my_Assert($user->shopdata->daliySpecial_ts!= 0, ErrCode::shop_daliySpecialRewardNotRepeat);
  83. $ts = $user->shopdata->daliySpecial_ts + 7 * 24 * 60 * 60;
  84. my_Assert(now() < $ts, ErrCode::shop_daliySpecialRewardNotRepeat);
  85. }
  86. $itemid = explode(',', $mo->reward)[0];
  87. $itemMO = GameConfig::item_package_getItem($itemid);
  88. my_Assert(null != $itemMO, ErrCode::err_const_no);
  89. StoreProc::AddMultiItemInStore($itemMO->contents);
  90. self::$retArr[] = $itemMO->contents;
  91. $shopdata = new Info_UserShop(ctx()->shopdata);
  92. $shopdata->daliySpecialPackages[] = $typeId;
  93. ctx()->shopdata = $shopdata;
  94. break;
  95. case Enum_Recharge::RechargeRebate://充值返利
  96. $mo = GameConfig::rechargeRebate_getItem(3, $typeId);
  97. my_Assert($mo != null, ErrCode::err_const_no);
  98. my_Assert($user->baseInfo->charge_amt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  99. my_Assert(!in_array($typeId, $user->shopdata->rechargeRebateRewardsList), ErrCode::shop_RechargeRebateRewardNotRepeat);
  100. StoreProc::AddMultiItemInStore($mo->rewards);
  101. self::$retArr[] = $mo->rewards;
  102. break;
  103. case Enum_Recharge::LimitBuy://限购中免费礼包领取
  104. $packageCfg = GameConfig::shop_limit_getItem($typeId);
  105. my_Assert(null != $packageCfg, ErrCode::err_const_no);
  106. my_Assert($packageCfg->price == 0, ErrCode::shop_limit_NotFree);
  107. self::checklimitBuyRecharge($typeId);
  108. break;
  109. case Enum_Recharge::Accumulate: # 累充, gwang 2022.10.18
  110. // list($amount, $day) = explode('-', $typeId); # 拆分key1,key2
  111. // $cfg = GameConfig::shop_accumulating_getItem($amount, $day); # 配置对象
  112. // my_Assert(null != $cfg, ErrCode::err_const_no); # 防御null
  113. //
  114. // $acc = new Ins_Accumulate($user->shopdata->shopAccumulateData); # 累充对象
  115. // my_Assert(!$acc->IsDrawed($amount, $day), ErrCode::active_hasgetted); # 防御: 已经领取
  116. // my_Assert($user->baseInfo->rechargeFun_amt >= $cfg->amount, "累充金额不足!"); # 校验: 金额
  117. // my_Assert($acc->EndDay() >= tsDay(), "领取时间已过!"); # 校验: 时间
  118. // StoreProc::AddMultiItemInStore($cfg->goods); # 发放奖品
  119. // $user->shopdata->shopAccumulateData = $acc->SetDrawd($amount, $day); # 更新数据
  120. // self::$retArr[] = $cfg->goods;
  121. $mo = GameConfig::rechargeRebate_getItem(Enum_Recharge::Accumulate, $typeId);
  122. my_Assert($mo != null, ErrCode::err_const_no);
  123. my_Assert($user->baseInfo->charge_amt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  124. my_Assert(!in_array($typeId, $user->shopdata->rechargeRebateRewardsList), ErrCode::shop_RechargeRebateRewardNotRepeat);
  125. $user->shopdata->rechargeRebateRewardsList[] = $typeId;
  126. StoreProc::AddMultiItemInStore($mo->rewards);
  127. self::$retArr[] = $mo->rewards;
  128. break;
  129. case Enum_Recharge::FirstRecharge_new:
  130. $mo = GameConfig::shop_accumulating_getItem($typeId);
  131. my_Assert(null != $mo, ErrCode::err_const_no);
  132. $shopdata = new Info_UserShop(ctx()->shopdata);
  133. $amount = $mo->amount;
  134. if (!StlUtil::dictHasProperty($shopdata->fRechargeRecord, $amount)) {
  135. $shopdata->fRechargeRecord->$amount = array();
  136. }
  137. my_Assert(!in_array($typeId, $shopdata->fRechargeRecord->$amount), ErrCode::active_FirstRechargeRewardRepeat);
  138. $shopdata->fRechargeRecord->$amount[] = $typeId;
  139. StoreProc::AddMultiItemInStore($mo->goods); # 发放奖品
  140. ctx()->shopdata = $shopdata;
  141. self::$retArr[] = $mo->goods;
  142. break;
  143. case Enum_Recharge::DayAccumulateRecharge: #每周累计金额奖励
  144. $mo = GameConfig::rechargeRebate_getItem($type, $typeId);
  145. my_Assert($mo != null, ErrCode::err_const_no);
  146. my_Assert($user->shopdata->dayRechargeAmt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  147. my_Assert(!in_array($typeId, $user->shopdata->dayRechargeReceived), ErrCode::shop_RechargeRebateRewardNotRepeat);
  148. $user->shopdata->dayRechargeReceived[] = $typeId;
  149. // if ($rechargeType == 1) {
  150. // my_Assert($user->shopdata->dayRechargeAmt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  151. // my_Assert(!in_array($rmb, $user->shopdata->dayRechargeReceived), ErrCode::shop_RechargeRebateRewardNotRepeat);
  152. // $user->shopdata->dayRechargeReceived[] = $rmb;
  153. // } else if($rechargeType == 2){
  154. // my_Assert($user->shopdata->weekRechargeAmt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  155. // my_Assert(!in_array($rmb, $user->shopdata->weekRechargeReceived), ErrCode::shop_RechargeRebateRewardNotRepeat);
  156. // $user->shopdata->weekRechargeReceived[] = $rmb;
  157. // }
  158. StoreProc::AddMultiItemInStore($mo->rewards);
  159. self::$retArr[] = $mo->rewards;
  160. break;
  161. case Enum_Recharge::WeekAccumulateRecharge: #每周累计金额奖励
  162. $mo = GameConfig::rechargeRebate_getItem($type, $typeId);
  163. my_Assert($mo != null, ErrCode::err_const_no);
  164. my_Assert($user->shopdata->weekRechargeAmt >= $mo->rmb, ErrCode::shop_RechargeRebateRmbNotEnough);
  165. my_Assert(!in_array($typeId, $user->shopdata->weekRechargeReceived), ErrCode::shop_RechargeRebateRewardNotRepeat);
  166. $user->shopdata->weekRechargeReceived[] = $typeId;
  167. StoreProc::AddMultiItemInStore($mo->rewards);
  168. self::$retArr[] = $mo->rewards;
  169. break;
  170. default:
  171. break;
  172. }
  173. ctx($user);
  174. UserProc::updateUserInfo();
  175. return Resp::ok(array(
  176. "ret" => self::$retArr,
  177. "pay" => $user->pay,
  178. "shopdata" => ctx()->shopdata,
  179. "base" => $user->baseInfo,
  180. "store" => $user->store,
  181. ));
  182. }
  183. /**
  184. * 限购礼包--终身礼包--套装礼包--校验
  185. * @param type $packageId
  186. */
  187. private static function checklimitBuyRecharge($packageId) { # 参数; 礼包id
  188. $shopdata = new Info_UserShop(ctx()->shopdata);
  189. $packageCfg = GameConfig::shop_limit_getItem($packageId);
  190. my_Assert(null != $packageCfg, ErrCode::err_const_no);
  191. $arr = array();
  192. if ($packageCfg->goodsType == Enum_Recharge::LifelongGift) {
  193. $shopdata->lifelongGiftReceived[] = $packageId;
  194. $arr = $shopdata->lifelongGiftReceived;
  195. } elseif ($packageCfg->goodsType == Enum_Recharge::SuitGift) {
  196. $ts = now() - $shopdata->suitGiftStartTs;
  197. my_Assert($ts <= $packageCfg->limit_ts, ErrCode::shop_limit_TsMax); # 校验时间
  198. $shopdata->suitGiftReceived[] = $packageId;
  199. $arr = $shopdata->suitGiftReceived;
  200. } else {
  201. switch ((int) $packageCfg->subType) {
  202. case 1:
  203. $shopdata->purchasedDailyLimitPackages[] = $packageId;
  204. $arr = $shopdata->purchasedDailyLimitPackages;
  205. break;
  206. case 2:
  207. $shopdata->purchasedWeeklyLimitPackages[] = $packageId;
  208. $arr = $shopdata->purchasedWeeklyLimitPackages;
  209. break;
  210. case 3:
  211. $shopdata->purchasedMonthlyLimitPackages[] = $packageId;
  212. $arr = $shopdata->purchasedMonthlyLimitPackages;
  213. break;
  214. default:
  215. Err(ErrCode::err_innerfault);
  216. }
  217. }
  218. $hasN = count(array_filter($arr, function ($val)use ($packageId) { # 计数:筛选条件
  219. return $val == $packageId;
  220. }));
  221. my_Assert($hasN <= $packageCfg->limit_num, ErrCode::shop_limit_max); # 校验购买数量
  222. $itemid = explode(',', $packageCfg->reward)[0]; # 奖励礼包Id
  223. $itemMO = GameConfig::item_package_getItem($itemid);
  224. my_Assert(null != $itemMO, ErrCode::err_const_no);
  225. $err = StoreProc::AddMultiItemInStore($itemMO->contents); # 发放奖励
  226. self::$retArr[] = $itemMO->contents;
  227. my_Assert(ErrCode::ok == $err, $err);
  228. ctx()->shopdata = $shopdata; # 回写数据
  229. }
  230. /**
  231. * [8813] 充值发货 (新版2021)
  232. */
  233. static function PayDeliverGoods() {
  234. list($cpOrderId) = req()->paras;
  235. $result = pay_op::CheckAndDrawOrder(req()->uid, $cpOrderId, array(new PayProc, 'distributePayGoods'));
  236. my_Assert($result->err == 0, ErrCode::pay_fail);
  237. $user = ctx();
  238. NormalEventProc::OnPaySuccess();
  239. UserProc::updateUserInfo(); # 回写玩家数据
  240. return Resp::ok(array(
  241. "ret" => self::$retArr,
  242. "pay" => $user->pay,
  243. "base" => $user->baseInfo,
  244. "shopdata" => $user->shopdata,
  245. "store" => $user->store,
  246. ));
  247. }
  248. //发货
  249. static function distributePayGoods($order = null) {
  250. my_Assert($order->product_id != null, ErrCode::pay_order_product_id);
  251. $user = ctx();
  252. self::$retArr = array();
  253. if ($order->product_id >= 6 && $order->product_id <= 1000) {//充值表
  254. $mo = GameConfig::recharge_getItem($order->product_id);
  255. my_Assert($mo != null, ErrCode::err_const_no);
  256. if (!StlUtil::dictHasProperty($user->shopdata, 'rechargeRecordList')) {
  257. $user->shopdata->rechargeRecordList = array();
  258. }
  259. $cash = $mo->rmd * 10;
  260. if (!in_array($order->product_id, $user->shopdata->rechargeRecordList)) {
  261. $cash = $mo->rmd * 10 * $mo->firstDouble;
  262. $user->shopdata->rechargeRecordList[] = $order->product_id;
  263. }
  264. $user->base()->Add_Cash($cash);
  265. self::$retArr[] = "2," . $cash;
  266. } elseif ($order->product_id >= 801001 && $order->product_id <= 803999) {//限购
  267. self::checklimitBuyRecharge($order->product_id);
  268. $mo = GameConfig::shop_limit_getItem($order->product_id);
  269. if ($mo->subType == 1) {
  270. $user->shopdata->dayRechargeAmt += $order->amount;
  271. } else if ($mo->subType == 2) {
  272. $user->shopdata->weekRechargeAmt += $order->amount;
  273. }
  274. } elseif ($order->product_id >= 804001 && $order->product_id <= 804999) {//每日特惠
  275. $mo = GameConfig::shop_limit_getItem($order->product_id);
  276. my_Assert($mo != null, ErrCode::err_const_no);
  277. if ($mo->price == 60) {
  278. $user->shopdata->daliySpecial_ts = now();
  279. } else {
  280. $itemid = explode(',', $mo->reward)[0];
  281. $itemMO = GameConfig::item_package_getItem($itemid);
  282. my_Assert(null != $itemMO, ErrCode::err_const_no);
  283. StoreProc::AddMultiItemInStore($itemMO->contents);
  284. $user->shopdata->daliySpecialPackages[] = $mo->typeId;
  285. self::$retArr[] = $itemMO->contents;
  286. }
  287. } elseif ($order->product_id >= 805001 && $order->product_id <= 805999) {//限时
  288. $mo = GameConfig::shop_limit_getItem($order->product_id);
  289. my_Assert($mo != null, ErrCode::err_const_no);
  290. my_Assert(!in_array($order->product_id, $user->shopdata->limitTsActiveRewardsList), ErrCode::err_const_no);
  291. $user->shopdata->limitTsActiveRewardsList[] = $mo->typeId;
  292. $itemid = explode(',', $mo->reward)[0];
  293. $itemMO = GameConfig::item_package_getItem($itemid);
  294. my_Assert(null != $itemMO, ErrCode::err_const_no);
  295. StoreProc::AddMultiItemInStore($itemMO->contents); //领取奖励
  296. self::$retArr[] = $itemMO->contents;
  297. } elseif ($order->product_id >= 806001 && $order->product_id <= 806999) {//首充【2022-10-19新的首充功能】
  298. $mo = GameConfig::shop_accumulating_getItem($order->product_id);
  299. my_Assert($mo != null, ErrCode::err_const_no);
  300. $shopdata = new Info_UserShop(ctx()->shopdata);
  301. $amount = $mo->amount;
  302. if (!StlUtil::dictHasProperty($shopdata->fRechargeTime, $amount)) {
  303. $shopdata->fRechargeTime->$amount = TimeUtil::tsDay();
  304. }
  305. $cost = 0;
  306. $dic = GameConfig::shop_accumulating();
  307. foreach ($dic as $k => $item) {
  308. if ($cost <= $item->amount) {
  309. $cost = $item->amount;
  310. }
  311. }
  312. if ($cost <= $amount && $shopdata->suitGiftStartTs == 0) {
  313. $shopdata->suitGiftStartTs = now();
  314. }
  315. ctx()->shopdata = $shopdata;
  316. //self::$retArr[] = $mo->goods;
  317. } elseif ($order->product_id >= 807001 && $order->product_id <= 807999) {//终身礼包
  318. self::checklimitBuyRecharge($order->product_id);
  319. } elseif ($order->product_id >= 808001 && $order->product_id <= 808999) {//套装礼包
  320. self::checklimitBuyRecharge($order->product_id);
  321. } elseif ($order->product_id >= 901001 && $order->product_id <= 999999) {//月卡
  322. $shopdata = new Info_UserShop(ctx()->shopdata);
  323. $packageCfg = GameConfig::shop_monthVIP_getItem($order->product_id);
  324. my_Assert(null != $packageCfg, ErrCode::err_const_no);
  325. if ($packageCfg->subType == 4) {
  326. my_Assert($shopdata->monthlyVIP1_ts + $packageCfg->ExpireTs * 3600 * 24 < now(), ErrCode::shop_monthlyvip_buyed);
  327. } elseif ($packageCfg->subType == 5) {
  328. my_Assert($shopdata->monthlyVIP2_ts + $packageCfg->ExpireTs * 3600 * 24 < now(), ErrCode::shop_monthlyvip_buyed);
  329. }
  330. $err = StoreProc::AddMultiItemInStore($packageCfg->pri_reward); # 发放一次性奖励
  331. self::$retArr[] = $packageCfg->pri_reward;
  332. my_Assert(ErrCode::ok == $err, $err);
  333. if ($packageCfg->subType == 4) {
  334. $shopdata->monthlyVIP1_ts = 3600 * 24 * (totalDays() + 1) - 1;
  335. } elseif ($packageCfg->subType == 5) {
  336. $shopdata->monthlyVIP2_ts = 3600 * 24 * (totalDays() + 1) - 1;
  337. }
  338. EmailProc::SendMonthlyVIPDailyReward(req()->zoneid, req()->uid, $packageCfg->name, $packageCfg->daily_reward);
  339. ctx()->shopdata = $shopdata;
  340. }
  341. $user->baseInfo->charge_amt += $order->amount;
  342. ctx($user);
  343. return true;
  344. }
  345. static function suitGiftCheck() {
  346. $shopdata = new Info_UserShop(ctx()->shopdata);
  347. $cost = 0;
  348. $dic = GameConfig::shop_accumulating();
  349. foreach ($dic as $k => $item) {
  350. if ($cost <= $item->amount) {
  351. $cost = $item->amount;
  352. }
  353. }
  354. if (StlUtil::dictHasProperty($shopdata->fRechargeTime, $cost)) {
  355. if ($shopdata->suitGiftStartTs == 0) {
  356. $shopdata->suitGiftStartTs = now();
  357. }
  358. } else {
  359. $shopdata->suitGiftStartTs = 0;
  360. }
  361. ctx()->shopdata = $shopdata;
  362. }
  363. static function checkAmount($order) {
  364. my_Assert($order->product_id != null, ErrCode::pay_order_product_id);
  365. if ($order->product_id >= 6 && $order->product_id <= 1000) {//充值表
  366. $mo = GameConfig::recharge_getItem($order->product_id);
  367. my_Assert($mo != null, ErrCode::err_const_no);
  368. my_Assert($order->amount == $mo->rmd, ErrCode::pay_price_err);
  369. } elseif ($order->product_id >= 801001 && $order->product_id <= 801999) {//限购
  370. //该功能暂时没有开发
  371. } elseif ($order->product_id >= 804001 && $order->product_id <= 804999) {//每日特惠
  372. $mo = GameConfig::shop_limit_getItem($order->product_id);
  373. my_Assert($mo->price == $order->amount, ErrCode::pay_price_err);
  374. } elseif ($order->product_id >= 805001 && $order->product_id <= 805999) {//限时
  375. //该功能暂时没有开发
  376. } elseif ($order->product_id >= 901001 && $order->product_id <= 999999) {//月卡
  377. $packageCfg = GameConfig::shop_monthVIP_getItem($order->product_id);
  378. my_Assert(null != $packageCfg, ErrCode::err_const_no);
  379. my_Assert($packageCfg->price == $order->amount, ErrCode::pay_price_err);
  380. }
  381. return true;
  382. }
  383. /**
  384. * 礼包有了的第一次登录记录
  385. */
  386. static function SuitGiftTsRecord() {
  387. $shopdata = new Info_UserShop(ctx()->shopdata);
  388. if (!StlUtil::dictHasProperty($shopdata, 'suitGiftStartTs')) {
  389. $shopdata->suitGiftStartTs = 0;
  390. }
  391. if ($shopdata->suitGiftStartTs == 0) {
  392. $shopdata->suitGiftStartTs = now();
  393. }
  394. ctx()->shopdata = $shopdata;
  395. }
  396. /**
  397. * 8812 查询充值记录
  398. */
  399. static function GetPayRecoreds() {
  400. $uid = req()->uid;
  401. $table = "tpl_order_tab";
  402. $arr = daoInst()->select(" cpOrderId as '订单' ,product_name as '道具',amount as '金额' ,from_unixtime(order_ts) as '时间' ")->from($table)
  403. ->where("uid")->eq($uid)
  404. ->andWhere("status")->eq(1)
  405. ->fetchall();
  406. return Resp::ok($arr);
  407. }
  408. //
  409. // <editor-fold defaultstate="collapsed" desc=" 移动支付 - 刷新订单 ">
  410. /**
  411. * 刷新充值订单(领取充值结果)
  412. */
  413. public static function m_refreshChargeOrders() {
  414. # 客户端参数解析
  415. $uid = req()->uid; # userID
  416. $zoneid = req()->zoneid; # 分区Id
  417. if (count(req()->paras) <= 0) { # 参数为空, 执行自检逻辑
  418. return self::selfhelpCheckOrders();
  419. }
  420. $cpOrderId = req()->paras[0]; # 后台订单编号
  421. if (!$uid || ($zoneid < 1) || strlen($cpOrderId) != 16) { # 订单编号长16位
  422. return Resp::err(ErrCode::paras_err);
  423. }
  424. $order = daoInst()->select()->from(self::orderTab) # 取订单数据
  425. ->where('cpOrderId')->eq($cpOrderId)
  426. ->limit(1)->fetch();
  427. if (!$order) {
  428. // var_dump($order);
  429. CLog::pay(' 订单不存在! ' . $cpOrderId);
  430. return Resp::err(ErrCode::pay_order_no);
  431. }
  432. if (false === strpos($uid, $order->uid)) { # UID不符
  433. return Resp::err(ErrCode::pay_order_uid);
  434. }
  435. if ($order->status != 1) {
  436. CLog::pay(' 订单尚未完成支付!');
  437. return Resp::err(ErrCode::pay_order_paystatus);
  438. }
  439. if ($order->drawed_ts > 0) { # 定单已经发过货了
  440. CLog::pay(' 订单重复请求发货!' . $cpOrderId);
  441. return Resp::err(ErrCode::pay_order_drawed);
  442. }
  443. // 准备发货
  444. $product_id = $order->product_id;
  445. $product_count = $order->product_count;
  446. $typid = substr("$product_id", 0, 3); # 提取商品编号前缀
  447. switch ($typid) {
  448. case '802': # 神秘商城物品
  449. $item = GameConfig::secretshop_typeId_getItem($product_id);
  450. break;
  451. case '801': # 商城物品
  452. $item = GameConfig::shop_getItem($product_id);
  453. break;
  454. default :
  455. return Resp::err(ErrCode::pay_systembusy_err);
  456. }
  457. my_Assert(isset($item), ErrCode::pay_shopItem_cosnt_goods_err);
  458. if ($item->pricetype != 0) {
  459. CLog::pay(" 道具付费类型异常:" . $product_id);
  460. return Resp::err(ErrCode::pay_m_type_err);
  461. }
  462. for ($i = 0; $i < $product_count; $i++) { # 默认为1,还没有设计为n的情况
  463. StoreProc::AddMultiItemInStore($item->goods, 5); # 发货
  464. }
  465. $n = daoInst()->update(self::orderTab)
  466. ->data(array('drawed_ts' => now()))
  467. ->where('cpOrderId')->eq($cpOrderId)
  468. ->exec();
  469. my_Assert($n > 0, ErrCode::err_db); # 数据库操作失败
  470. ctx()->baseInfo->charge_amt += $order->amount; # 历史充值记录(单位分)
  471. UserProc::updateUserInfo(); # 更新玩家数据信息
  472. Event::trigger('pay', array('amt' => $order->amount)); # 触发充值事件
  473. CLog::pay("订单发货成功: $cpOrderId");
  474. return Resp::ok(# 返回
  475. array('cash' => ctx()->baseInfo->cash, # # 直接将游戏币的最新值返回给客户端
  476. 'charge_amt' => ctx()->baseInfo->charge_amt, # 充值总记录
  477. 'store' => ctx()->store, # # 背包
  478. 'goods' => $item->goods, # # 发货内容
  479. 'count' => $product_count, # # 发货数量
  480. )
  481. );
  482. }
  483. /**
  484. * 检查删档内测订单
  485. */
  486. static function checkDeltest() {
  487. $uid = req()->uid;
  488. if (ctx()->privateState->deltest == 1) {
  489. $orders = daoInst()->select()->from('tpl_order_tab_deltest')
  490. ->where('uid')->eq($uid)
  491. ->andwhere('status')->eq(1)
  492. ->fetchall();
  493. if (count($orders) > 0) { # 有充值记录
  494. foreach ($orders as $order) {
  495. // 翻倍发放砖石
  496. isEditor() and $order = new pay\dbOrder();
  497. $rmb = intval($order->amount / 100); # 计算充值金额(元)
  498. EmailProc::SendDelTestMail(req()->zoneid, $uid, $rmb);
  499. CLog::pay(req()->uid . '发送删档内侧补偿邮件' . $order->cpOrderId);
  500. }
  501. }
  502. ctx()->privateState->deltest = 0;
  503. }
  504. // CLog::pay('删档内测补偿检查');
  505. }
  506. /**
  507. * 检查异常订单, 补发道具
  508. */
  509. public static function selfhelpCheckOrders() {
  510. $uid = req()->uid;
  511. $orders = daoInst()->select()
  512. ->from('tpl_order_tab')
  513. ->where('uid')->eq($uid)
  514. ->andWhere('status')->eq(1)
  515. ->andWhere('drawed_ts')->le(0)
  516. ->fetchAll();
  517. if (count($orders) > 0) {
  518. foreach ($orders as $order) {
  519. // 准备补发
  520. $product_id = $order->product_id;
  521. $product_count = $order->product_count;
  522. $typid = substr("$product_id", 0, 3); # 提取商品编号前缀
  523. $goods = '';
  524. switch ($typid) {
  525. case '802': # 神秘商城物品
  526. $item = GameConfig::secretshop_typeId_getItem($product_id);
  527. break;
  528. case '801': # 商城物品
  529. $item = GameConfig::shop_getItem($product_id);
  530. break;
  531. default :
  532. return Resp::err(ErrCode::pay_systembusy_err);
  533. }
  534. if (!$item) {
  535. return Resp::err(ErrCode::pay_shopItem_cosnt_goods_err);
  536. }
  537. if ($item->pricetype != 0) { # 并非人民币定价
  538. CLog::pay(" 道具付费类型异常:" . $product_id);
  539. return Resp::err(ErrCode::pay_m_type_err);
  540. }
  541. for ($i = 0; $i < $product_count; $i++) { # 默认为1,还没有设计为n的情况
  542. StoreProc::AddMultiItemInStore($item->goods, 5); # 发货
  543. }
  544. $goods .= $item->goods;
  545. $n = daoInst()->update(self::orderTab) # 更新订单状态
  546. ->data(array('drawed_ts' => now()))
  547. ->where('cpOrderId')->eq($order->cpOrderId)
  548. ->exec();
  549. if (!$n) { # 影响条数应为1
  550. CLog::pay(req()->uid . ' 登录补发订单失败 ' . $order->cpOrderId);
  551. return Resp::err(ErrCode::err_db); # 数据库操作失败
  552. }
  553. ctx()->baseInfo->charge_amt += $order->amount; # 历史充值记录(单位分)
  554. UserProc::updateUserInfo(); # 回写玩家数据
  555. CLog::pay(req()->uid . ' 登录补发订单 ' . $order->cpOrderId);
  556. }
  557. return Resp::ok(# 返回
  558. array('cash' => ctx()->baseInfo->cash, # # 直接将游戏币的最新值返回给客户端
  559. 'store' => ctx()->store, # # 背包
  560. 'goods' => $goods, # # 发货内容
  561. 'count' => count($orders), # # 发货数量
  562. 'msg' => "找到并处理" . count($orders) . "条未发货订单."
  563. ));
  564. }
  565. return Resp::ok('ok'); # everything is ok!
  566. }
  567. // </editor-fold>
  568. //
  569. // <editor-fold defaultstate="collapsed" desc=" 移动支付 - 商城购买 ">
  570. /**
  571. * 8810 免费或利用【游戏内货币】获取神秘商城物品
  572. * 刷新规则: 根据玩家拥有的英雄、装备、道具等数据进行刷新。(因英雄、道具、装备数量不足以支撑该刷新规则,目前先按照随机刷新做,几率平等)
  573. */
  574. public static function m_pay_getDynamic() {
  575. $user = ctx();
  576. $userSecretshop = new Info_UserSecretshop($user->userSecretshop);
  577. // 参数提取
  578. $refreshType = req()->paras[0]; # 刷新类型(参数)0,不刷,1,免费刷,2,钻石刷
  579. switch ($refreshType) {
  580. case 1: # 免费刷
  581. if (now() < $userSecretshop->lastRefreshTs + glc()->secretshop_refresh_interval) { // 检查是否达到免费刷新时间了, 执行自动更新
  582. return Resp::err(ErrCode::pay_secretshopt_freeRefresh_Time);
  583. }
  584. break;
  585. case 2: # 钻石刷
  586. if (glc()->secretshop_refresh_maxtimes <= $userSecretshop->refreshedTimes) { // 检查刷新次数, 已达上限, 返回错误信息
  587. return Resp::err(ErrCode::pay_refresh_times);
  588. } # 可以继续刷新,
  589. $cishu = $userSecretshop->refreshedTimes + 1; # 下次
  590. $amt = GameConfig::secretshop_refresh_getItem($cishu)->price;
  591. if (!$user->base()->Consume_Cash($amt)) { # 扣除本次所需费用, 余额不足, 返回错误信息
  592. return Resp::err(ErrCode::notenough_cash_msg);
  593. }
  594. $userSecretshop->refreshedTimes++; # 增加当天付费刷新计数
  595. break;
  596. case 0: # 不刷
  597. default : # 默认不刷
  598. // do nothing.
  599. break;
  600. }
  601. if ($refreshType != 0) { # 是否刷新
  602. $err = self::refreshDynamicShopItems($userSecretshop); # 更新物品表
  603. if ($err) {
  604. return Resp::err($err);
  605. }
  606. $user->userSecretshop = $userSecretshop;
  607. ctx($user);
  608. UserProc::updateUserInfo();
  609. }
  610. // 返回最新物品表
  611. return Resp::ok(array(# # 成功后将最新的玩家数据返回给客户端
  612. 'gold' => $user->baseInfo->gold,
  613. 'tili' => $user->baseInfo->tili,
  614. 'cash' => $user->baseInfo->cash,
  615. 'uss' => $userSecretshop, # # 当前神秘商城数据
  616. ));
  617. }
  618. /**
  619. * 更新神秘商城物品
  620. * @param Info_UserSecretshop $userSecretshop Description
  621. */
  622. private static function refreshDynamicShopItems(&$userSecretshop) {
  623. $userSecretshop->lastRefreshTs = now();
  624. // todo: 这里补完更新物品的函数, // 第一版: 随机
  625. $userSecretshop->currentItems = ObjectInit();
  626. for ($i = 1; $i <= 3; $i++) { # 3种类型的商品
  627. $arr = GameConfig::secretshop_goodsType_getItem($i);
  628. if (count($arr) > 0) {
  629. $err = self::Dice(GameConfig::secretshop_goodsType_getItem($i), 1, $userSecretshop); # 一个种类一次1个物品
  630. if ($err) {
  631. return $err;
  632. }
  633. }
  634. }
  635. return ErrCode::ok;
  636. }
  637. /**
  638. * 投骰子
  639. * @param assoc_array $arr 奖池物品
  640. * @param int $number 提取数量
  641. * @return string itemid,num;itemid,num;...
  642. */
  643. private static function Dice($arr, $number, &$userSecretshop) {
  644. $max = 0; # 计算物品权重总和
  645. array_walk($arr, function ($value) use (&$max) {
  646. $max += $value->probability;
  647. });
  648. if (!$max) { # 配置数据有问题
  649. return ErrCode::err_const_no;
  650. }
  651. for ($i = 0; $i < $number; $i++) {
  652. $rnd = CommUtil::random(1, $max); # 投骰子
  653. $start = 0;
  654. $rew = null;
  655. foreach ($arr as $item) { # 循环判断落入那个物品上
  656. if (CommUtil::isPropertyExists($item, 'probability') // #
  657. && $start < $rnd && $rnd <= $start + $item->probability) { # 落入区间
  658. $rew = $item; # 记录物品
  659. break;
  660. }
  661. $start += $item->probability; # 继续判断是否落入下一物品的区间
  662. } # foreach end
  663. if (!$rew) {
  664. return ErrCode::lottery_noselecteditem;
  665. }
  666. $id = $rew->typeId;
  667. $userSecretshop->currentItems->$id = 0;
  668. } # for end
  669. return ErrCode::ok;
  670. }
  671. /**
  672. * 清理每日各种上限
  673. */
  674. private static function clearDailyLimits() {
  675. $userSecretshop = new Info_UserSecretshop(ctx()->userSecretshop);
  676. $userSecretshop->refreshedTimes = 0;
  677. ctx()->userSecretshop = $userSecretshop;
  678. }
  679. /**
  680. * [8809]【游戏内货币】购买神秘商城物品
  681. * 规则: 商城物品会刷新
  682. */
  683. public static function m_pay_buyDynamic() {
  684. $user = new Data_UserGame(ctx());
  685. $userSecretshop = new Info_UserSecretshop($user->userSecretshop);
  686. $itemId = req()->paras[0]; # 商品id (点一次购买一个)
  687. $num = 1; # 暂时固定为一次购买一个
  688. #
  689. my_Assert(CommUtil::isPropertyExists($userSecretshop->currentItems, $itemId), ErrCode::pay_secretshop_noitem_err);
  690. $cishu = $userSecretshop->currentItems->$itemId; # 购买次数
  691. my_Assert($cishu < glc()->secretshop_itembuy_maxtimes, ErrCode::pay_secretshop_buytimes); # 判断购买次数
  692. $shopItem = GameConfig::secretshop_typeId_getItem($itemId); # 常量数据
  693. $amt = $shopItem->price * pow(2, $cishu); # 计算价格
  694. switch ($shopItem->pricetype) {
  695. case 1:
  696. my_Assert($user->base()->Consume_Cash($amt), ErrCode::notenough_cash_msg); # 扣除钻石
  697. break;
  698. case 2:
  699. my_Assert($user->base()->Consume_Gold($amt), ErrCode::notenough_gold_msg); # 扣除金币
  700. break;
  701. default :
  702. return Resp::err(ErrCode::pay_m_type_err);
  703. }
  704. // 道具解包/发货
  705. $err = self::expendSecretShopItem($shopItem, $num); # 发放商品
  706. if ($err != ErrCode::ok) { # 发货失败
  707. return Resp::err($err);
  708. }
  709. $userSecretshop->currentItems->$itemId += 1; # 购买次数+1
  710. $user->userSecretshop = $userSecretshop;
  711. ctx($user);
  712. UserProc::updateUserInfo(); # 回写数据
  713. // StatProc::secretShopbuy($req->zoneid, $req->uid, $itemId, $num); # 统计/监控数据
  714. return Resp::ok(array(# # 成功后将最新的玩家数据返回给客户端
  715. 'gold' => $user->baseInfo->gold,
  716. 'tili' => $user->baseInfo->tili,
  717. 'cash' => $user->baseInfo->cash,
  718. 'store' => $user->baseInfo->store, # # 背包,(装备、碎片、。。)
  719. 'heros' => $user->baseInfo->heros # # 角色
  720. ));
  721. //
  722. }
  723. /**
  724. * [8807]【游戏内货币】购买普通商城物品
  725. */
  726. public static function m_pay() {
  727. $user = ctx(); # user引用
  728. my_Assert(count(req()->paras) >= 3, ErrCode::parasnotenough_msg); # 参数不足
  729. list($paytype, $itemId, $num) = req()->paras; # 付费类型, 1.钻石, 2.金币 ,道具ID ,数量, 默认为1
  730. my_Assert($num >= 1, ErrCode::paras_err); # 参数非法,
  731. $shopItem = GameConfig::shop_getItem($itemId); # 取商品的常量数据
  732. my_Assert(isset($shopItem), ErrCode::err_const_no); # 检测是否存在道具的常量数据
  733. my_Assert($shopItem->pricetype == $paytype, ErrCode::pay_price_err); # 商品定价类型检查
  734. $amt = $shopItem->price; # 道具价格(钻石)
  735. my_Assert($amt > 0, ErrCode::pay_price_err); # 商品定价数值检查
  736. $bDeal = false; # 成交标志位
  737. switch ($paytype) { # 1. 钻石, 2. 金币, other:非法
  738. case 1: # 钻石
  739. $bDeal = ctx()->base()->Consume_Cash($amt); # 更新(扣除)玩家游戏币(钻石)余额
  740. my_Assert($bDeal, ErrCode::notenough_cash_msg); # 防范扣除失败
  741. break;
  742. case 2: # 金币
  743. $bDeal = $user->base()->Consume_Gold($amt * $num); # 更新玩家金币余额
  744. my_Assert($bDeal, ErrCode::notenough_gold_msg); # 防范扣除失败
  745. break;
  746. default : # 未知的支付类型
  747. return Resp::err(ErrCode::pay_m_type_err);
  748. }
  749. my_Assert($bDeal, ErrCode::err_innerfault); # 交易失败
  750. $err = self::expendShopItem($shopItem, $num); # 发放商品(普通商城只有金币和体力)
  751. my_Assert(ErrCode::ok == $err, $err); # 防范发货失败
  752. UserProc::updateUserInfo(); # 回写数据
  753. // StatProc::shopbuy($zoneid, $uid, $itemId, $num); # 统计/监控数据
  754. return Resp::ok(array(# # 成功后将最新的玩家数据返回给客户端
  755. 'gold' => $user->baseInfo->gold,
  756. 'tili' => $user->baseInfo->tili,
  757. 'cash' => $user->baseInfo->cash,
  758. 'store' => $user->store
  759. ));
  760. }
  761. /**
  762. * 解包商城物品并发货
  763. * @param sm_Shop $shopItem
  764. * @param int $num 数量
  765. */
  766. private static function expendShopItem($shopItem, $num) {
  767. for ($i = 0; $i < $num; $i++) {
  768. $err = StoreProc::AddMultiItemInStore($shopItem->goods, '商城');
  769. my_Assert(ErrCode::ok == $err, $err);
  770. }
  771. return ErrCode::ok;
  772. }
  773. /**
  774. * 道具解包并发货(神秘商城)
  775. * @param sm_secretshop $shopItem
  776. * @param type $num
  777. */
  778. private static function expendSecretShopItem($shopItem, $num) {
  779. for ($i = 0; $i < $num; $i++) {
  780. $err = StoreProc::AddMultiItemInStore($shopItem->goods, '神秘商城');
  781. if ($err) {
  782. return $err;
  783. }
  784. }
  785. return ErrCode::ok;
  786. }
  787. // </editor-fold>
  788. //
  789. //
  790. // <editor-fold defaultstate="collapsed" desc=" 支付活动 - 首付礼包">
  791. /**
  792. * [8802] 领取首付礼包
  793. */
  794. public static function m_GetFirstPayGift() {
  795. $itemId = glc()->FirstPay_ItemId;
  796. $privateState = ctx()->privateState;
  797. if (CommUtil::isPropertyExists($privateState, "firstPayGift") #
  798. && $privateState->firstPayGift) { # 如果已经领取首付礼包
  799. return Resp::err(ErrCode::pay_firstpaygetted);
  800. }
  801. my_Assert(ctx()->baseInfo->charge_amt > 0, ErrCode::pay_firstpayno_err); # 如果尚未完成首付
  802. $itemModel = GameConfig::shop_getItem($itemId); # 取商品常量
  803. if ($itemModel == null) { # 检测首付礼包是否存在
  804. return Resp::err(ErrCode::err_const_no);
  805. }
  806. ctx()->privateState->firstPayGift = true; # 设置首付标志
  807. StoreProc::AddMultiItemInStore($itemModel->goods); # 发放首付礼包到玩家仓库
  808. UserProc::updateUserInfo(); # 更新玩家数据
  809. return Resp::ok(array('itemid' => $itemId,
  810. 'rewardstr' => $itemModel->goods,
  811. 'store' => ctx()->store)); # 回送成功信息
  812. }
  813. // </editor-fold>
  814. //
  815. //
  816. //
  817. }