OrdersController.php 80 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894
  1. <?php
  2. namespace App\Http\Controllers\Wap\Pay;
  3. use App\Admin\Models\User;
  4. use App\Modules\Book\Services\BookGiftsService;
  5. use App\Modules\Book\Services\ChapterService;
  6. use App\Modules\OfficialAccount\Services\OfficialAccountService;
  7. use App\Modules\Subscribe\Services\OrderParamService;
  8. use App\Modules\Subscribe\Services\OrderParamWsoService;
  9. use App\Modules\Subscribe\Services\SubstituteOrderService;
  10. use App\Modules\User\Services\ReadRecordService;
  11. use App\Modules\User\Services\UserBindPhoneService;
  12. use App\Modules\User\Services\UserDivisionCpcPropertyService;
  13. use App\Modules\User\Services\UserGiftService;
  14. use Illuminate\Routing\Controller;
  15. use App\Libs\Pay\WechatPay;
  16. use Illuminate\Http\Request;
  17. use App\Modules\Subscribe\Services\YearOrderService;
  18. use App\Modules\Subscribe\Services\BookOrderService;
  19. use App\Modules\Subscribe\Services\OrderService;
  20. use App\Modules\Product\Services\ProductService;
  21. use App\Modules\Book\Services\BookConfigService;
  22. use App\Modules\User\Services\UserService;
  23. use App\Modules\Channel\Services\ChannelService;
  24. use Log;
  25. use DB;
  26. use Cookie;
  27. use Redis;
  28. use Hashids;
  29. use EasyWeChat\Foundation\Application;
  30. use EasyWeChat\Support\XML;
  31. use App\Modules\OfficialAccount\Services\ForceSubscribeService;
  32. use App\Jobs\SendTexts;
  33. use App\Jobs\SendStatisticsList;
  34. use App\Libs\AliSMS;
  35. use App\Modules\Activity\Services\ActivityService;
  36. use App\Modules\SendOrder\Services\SendOrderService;
  37. use GuzzleHttp\Client;
  38. class OrdersController extends Controller
  39. {
  40. /**
  41. * @apiDefine pay 支付
  42. */
  43. /**
  44. * 支付唤起入口
  45. * 功能:授权、请求支付参数、并跳转微信支付
  46. * TODO 暂时不创建订单
  47. * tail -f /var/www/ydy_wap_backend/storage/logs/laravel-2017-12-01.log
  48. * zwap/goToPay?distribution_channel_id=3&price=1&uid=3
  49. * @apiVersion 1.0.0
  50. * @apiDescription 支付
  51. * @api {get} http://pay.aizhuishu.com/goToPay 支付
  52. * @apiGroup pay
  53. * @apiName wxindex
  54. * @apiParam {Int} product_id product_id
  55. * @apiParam {Int} uid uid
  56. * @apiParam {Int} distribution_channel_id distribution_channel_id
  57. * @apiParam {String} pay_redirect_url pay_redirect_url
  58. * @apiSuccess {int} code 状态码
  59. * @apiSuccessExample {json} Success-Response:
  60. * HTTP/1.1 200 OK
  61. * {
  62. * code: 0,
  63. * msg: "",
  64. * data: {
  65. * }
  66. */
  67. function wxindex(Request $request)
  68. {
  69. $product_id = $request->has('product_id') ? $request->get('product_id') : '';
  70. $uid = $request->has('uid') ? $request->get('uid') : '';
  71. $distribution_channel_id = $request->has('distribution_channel_id') ? $request->get('distribution_channel_id') : '';
  72. $p_channel_id = $request->has('p_channel_id') ? $request->get('p_channel_id') : 0;
  73. $pay_redirect_url = $request->has('pay_redirect_url') ? $request->get('pay_redirect_url') : '';
  74. $send_order_id = $request->has('send_order_id') ? $request->get('send_order_id') : 0;
  75. $activity_id = $request->has('activity_id') ? $request->get('activity_id') : 0;
  76. $ip = $request->has('ip') ? $request->get('ip') : '';
  77. $n = $request->has('n') ? $request->get('n') : 0;
  78. $crm = $request->has('crm') ? $request->get('crm') : 0;
  79. if ($send_order_id && strlen($send_order_id) > 50) {
  80. try {
  81. $send_order_id = decrypt($send_order_id);
  82. } catch (\Exception $e) {
  83. $send_order_id = 0;
  84. }
  85. }
  86. if ($send_order_id && strlen($send_order_id) > 50) {
  87. $send_order_id = 0;
  88. }
  89. //活动判断
  90. if ($activity_id) {
  91. $limit = $request->get('limit', 0);
  92. if ($limit && $limit == 1) {
  93. $order = OrderService::userIsParticipateActivity($uid, $activity_id);
  94. if ($order) {
  95. $activity = ActivityService::getById($activity_id);
  96. if ($activity) {
  97. $url = env('PROTOCOL', 'https') . '://site' . encodeDistributionChannelId($distribution_channel_id) . '.' . env('CUSTOM_HOST', 'leyuee') . '.com' . $activity->activity_page;
  98. return redirect()->to($url);
  99. }
  100. return '';
  101. }
  102. }
  103. }
  104. $suid = $request->get('suid', 0);
  105. if ($suid) {
  106. $user_info = UserService::getById($uid);
  107. $distribution_channel_id = $user_info->distribution_channel_id;
  108. $pay_redirect_url = 1;
  109. }
  110. if (empty($product_id) || empty($uid) || empty($distribution_channel_id) || empty($pay_redirect_url)) {
  111. return response()->error('WAP_PARAM_ERROR');
  112. }
  113. if ($suid && $suid == $uid) {
  114. return back();
  115. }
  116. $openid = $request->has('openid') ? $request->get('openid') : '';
  117. $bid = $request->has('bid') ? $request->get('bid') : 0;
  118. $hash_bid = $bid;
  119. $fromtype = $request->has('fromtype') ? $request->get('fromtype') : $request->get('from');
  120. if ($fromtype && strlen($fromtype) > 50) {
  121. try {
  122. $fromtype = decrypt($fromtype);
  123. } catch (\Exception $e) {
  124. $fromtype = 'main';
  125. }
  126. }
  127. if ($fromtype && strlen($fromtype) > 50) {
  128. $fromtype = 'main';
  129. }
  130. if (!$openid && !$p_channel_id && !$suid) {
  131. $transfer_channel_id = $this->transfer($distribution_channel_id);
  132. if ($transfer_channel_id) {
  133. $p_channel_id = $distribution_channel_id;
  134. $distribution_channel_id = $transfer_channel_id;
  135. }
  136. }
  137. //根据分校id获取支付配置id
  138. Log::info($request->all());
  139. $channel = ChannelService::getById($distribution_channel_id);
  140. if (!$channel || !$channel->pay_merchant_id) {
  141. return response()->error('WAP_PARAM_ERROR');
  142. }
  143. //获取支付类型
  144. $pay_merchant = DB::table('pay_merchants')->select('id', 'appid', 'source', 'config_info')->where('id', $channel->pay_merchant_id)->where('is_enabled', 1)->first();
  145. if (!$pay_merchant || !$pay_merchant->appid || !$pay_merchant->source) return response()->error('WAP_PARAM_ERROR');
  146. if ($pay_merchant->source == 'PALMPAYV2') {
  147. return redirect()->to($this->paympay($request, $pay_merchant));
  148. }
  149. //重定向 获取用户信息的次数
  150. $n++;
  151. if ($n >= 5) {
  152. //重定向次数过多,则授权公众号出问题
  153. $this->payAlert($channel->pay_merchant_id, '', '', $n);
  154. $back_url = env('PROTOCOL') . '://site' . encodeDistributionChannelId($distribution_channel_id) . '.' . env('CUSTOM_HOST') . '.com' . '/pay';
  155. return redirect()->to($back_url);
  156. }
  157. if (empty($openid)) {
  158. $trade_no = date("YmdHis") . str_shuffle(hexdec(uniqid()));
  159. if (isset($_SERVER['HTTP_X_FORWARDED_FOR']) && $_SERVER['HTTP_X_FORWARDED_FOR']) {
  160. $ip = $_SERVER['HTTP_X_FORWARDED_FOR'];
  161. } else {
  162. $ip = get_client_ip();
  163. }
  164. $params = compact('uid', 'product_id', 'distribution_channel_id', 'send_order_id', 'bid', 'trade_no', 'pay_redirect_url', 'fromtype', 'activity_id', 'n', 'suid', 'ip', 'p_channel_id','crm');
  165. $redirect_url = env('CREATE_PAY_URL') . '?' . http_build_query($params);
  166. //$redirect_url = env('CREATE_PAY_URL').'?uid='.$uid.'&product_id='.$product_id.'&distribution_channel_id='
  167. // .$distribution_channel_id.'&send_order_id='.$send_order_id.'&bid='.$bid.'&pay_redirect_url='.urlencode($pay_redirect_url)
  168. $auth_url = env('AUTH_URL') . '?gzh_app_id=' . $pay_merchant->appid . '&redirect_url=' . urlencode($redirect_url);
  169. Log::info('redirect_auth_url:' . $auth_url);
  170. header("Location:" . $auth_url);
  171. exit();
  172. }
  173. $trade_no = $request->input('trade_no');
  174. $order_info = OrderService::getByTradeNo($trade_no);
  175. if ($order_info) return response()->error('WAP_SYS_ERROR');
  176. $cid = $request->has('cid') ? $request->get('cid') : '';
  177. $product_info = ProductService::getProductSingle($product_id, false);
  178. //新用户只能冲一次
  179. //Log::info('新用户只能冲一次:' .$product_info->type);
  180. if ($this->isNewUserSecondCharge($product_info->type, $product_id, $uid)) {
  181. $url = env('PROTOCOL', 'https') . '://site' . encodeDistributionChannelId($distribution_channel_id) . '.' . env('CUSTOM_HOST', 'leyuee') . '.com/pay';
  182. return redirect()->to($url);
  183. }
  184. $price = $product_info->price * 100;
  185. if ($uid < 32) {
  186. $price = 1;
  187. }
  188. try {
  189. $send_order_id = (int)Redis::hget('book_read:' . $uid, 'send_order_id');
  190. } catch (\Exception $e) {
  191. }
  192. $this->updateUserSendOrderId($uid, $send_order_id);
  193. if (in_array($uid, explode(',', env('TEST_UID')))) {
  194. $price = 1;
  195. }
  196. if ($bid) {
  197. try {
  198. $bid = Hashids::decode($bid)[0];
  199. } catch (\Exception $e) {
  200. $bid = 0;
  201. }
  202. }
  203. try {
  204. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id:' . $distribution_channel_id;
  205. Redis::hset($key, $uid, time());
  206. $date = date('Y-m-d');
  207. Redis::hincrby('order_stat:' . $distribution_channel_id, 'order_num_' . $date, 1);
  208. if ($send_order_id) {
  209. Redis::hincrby('order_promotion_stat:' . $send_order_id, 'order_num_' . $date, 1);
  210. Redis::hincrby('order_promotion_stat:' . $send_order_id, 'total', 1);
  211. }
  212. } catch (\Exception $e) {
  213. }
  214. $data = [];
  215. $data['price'] = $price;
  216. $data['create_ip'] = $ip;
  217. $data['openid'] = $openid;//
  218. $data['body'] = 'novel read';
  219. $official_name = $this->getSubscribeOfficialName($uid, $distribution_channel_id);
  220. if ($official_name) {
  221. $data['body'] = '搜索公众号' . $official_name . ',请继续阅读';
  222. }
  223. $data['detail'] = 'novel read';
  224. $data['trade_no'] = $trade_no;
  225. $data['remark'] = json_encode(
  226. [
  227. 'uid' => $uid,
  228. 'dcd' => $distribution_channel_id,
  229. 'bid' => $bid,
  230. 'cp' => $ip,
  231. 'pms' => $pay_merchant->source,
  232. 'pmi' => $channel->pay_merchant_id,
  233. 'pd' => $product_id,
  234. 'soi' => $send_order_id,
  235. ]
  236. );
  237. if ($product_info->type == 'YEAR_ORDER') {
  238. $order_type = 'YEAR';
  239. } elseif ($product_info->type == 'BOOK_ORDER') {
  240. $order_type = 'BOOK';
  241. } elseif ($product_info->type == 'TICKET_RECHARGE') {
  242. $order_type = 'RECHARGE';
  243. } elseif ($product_info->type == 'NEW_USER') {
  244. $order_type = 'RECHARGE';
  245. } else {
  246. $order_type = 'UNKNOWN';
  247. }
  248. /*
  249. $this->createOrderTotal([
  250. 'distribution_channel_id'=>$distribution_channel_id,
  251. 'uid'=>$uid,
  252. 'product_id'=>$product_id,
  253. 'price'=>$price/100,
  254. 'pay_type'=>1,
  255. 'trade_no'=>$data['trade_no'],
  256. 'pay_merchant_source'=>$pay_merchant->source,
  257. 'pay_merchant_id'=>$channel->pay_merchant_id,
  258. 'create_ip'=>$request->getClientIp(),
  259. 'send_order_id'=>$send_order_id,
  260. 'order_type'=>$order_type,
  261. 'from_bid'=>$bid
  262. ]);*/
  263. $send_order_name = '';
  264. if ($send_order_id) {
  265. $send_order_info = SendOrderService::getById($send_order_id);
  266. if ($send_order_info && isset($send_order_info->name) && !empty($send_order_info->name)) {
  267. $send_order_name = $send_order_info->name;
  268. }
  269. if(redisEnv('MIWAN_TRANSFER_TO_CHANNEL_ID', 0) == $distribution_channel_id){
  270. $send_order_id = -$send_order_id;
  271. }
  272. }
  273. if ($suid) {
  274. $user_info = UserService::getById($uid);
  275. $distribution_channel_id = $user_info->distribution_channel_id;
  276. }
  277. $from_bid = ReadRecordService::getSimpleFirstReadRecord($uid);
  278. $inner_send_order_id = ReadRecordService::getInnerSendOrderId($uid);
  279. $init_order = [
  280. 'distribution_channel_id' => $distribution_channel_id,
  281. 'uid' => $uid,
  282. 'product_id' => $product_id,
  283. 'price' => $price / 100,
  284. 'pay_type' => 1,
  285. 'trade_no' => $data['trade_no'],
  286. 'pay_merchant_source' => $pay_merchant->source,
  287. 'pay_merchant_id' => $channel->pay_merchant_id,
  288. 'create_ip' => $ip,
  289. 'send_order_id' => $send_order_id,
  290. 'send_order_name' => $send_order_name,
  291. 'order_type' => $order_type,
  292. 'from_bid' => $from_bid,
  293. 'from_type' => $fromtype,
  294. 'activity_id' => $activity_id,
  295. 'inner_send_order_id' => $inner_send_order_id
  296. ];
  297. $result = $this->createUnPayOrder($init_order);
  298. //订单创建成功后增加统计
  299. if ($result) {
  300. $this->orderCreated($init_order);
  301. $this->recordOtherParam($result->id, $uid);
  302. if($p_channel_id){
  303. //miwa 转换
  304. OrderParamService::createByParam([
  305. 'order_id'=>$result->id,'gxhp'=>'mw_transfer','appid'=>'','bid'=>$bid,'data_hour_key'=>'','times'=>'','distribution_channel_id'=>$p_channel_id
  306. ]);
  307. }
  308. if($crm){
  309. OrderParamService::createByParam([
  310. 'order_id'=>$result->id,'gxhp'=>'crm','appid'=>'','bid'=>$bid,'data_hour_key'=>$crm,'times'=>'','distribution_channel_id'=>$distribution_channel_id
  311. ]);
  312. }
  313. $this->orderParamWso($uid,$result->id);
  314. }
  315. if ($request->get('suid')) {
  316. $this->createSubstituteOrder($result->id, $uid, $request->get('suid'));
  317. }
  318. Log::info($data);
  319. $config = [];
  320. if ($pay_merchant->config_info) {
  321. $config = json_decode($pay_merchant->config_info, true);
  322. }
  323. $wechatPay = WechatPay::instance($pay_merchant->source, $config);
  324. if (!$wechatPay) return response()->error('WAP_PARAM_ERROR');
  325. $pay_info = $wechatPay->send($data);
  326. if (!$pay_info) {
  327. $pay_info = $wechatPay->send($data);
  328. }
  329. if (!isset($pay_info['appId']) || !isset($pay_info['package'])) {
  330. //支付异常
  331. myLog('order')->info('pay error start---------------------------------');
  332. myLog('order')->info($pay_info);
  333. myLog('order')->info($request->all());
  334. myLog('order')->info('order info is');
  335. myLog('order')->info($init_order);
  336. myLog('order')->info('pay error end-----------------------------------');
  337. $this->payAlert($channel->pay_merchant_id, $trade_no, $pay_info);
  338. }
  339. $pay_info['pay_redirect_url'] = urldecode($pay_redirect_url);
  340. if ($request->has('cid')) {
  341. $pay_info['pay_redirect_url'] = $pay_info['pay_redirect_url'] . '&cid=' . $request->input('cid');
  342. }
  343. // if ($hash_bid) {
  344. // $pay_info['pay_redirect_url'] = $pay_info['pay_redirect_url'] . '&bid=' . $hash_bid;
  345. // }
  346. if ($suid) {
  347. $prize_fee = (int)(($product_info->price * 100) * 0.1);
  348. $help_pay_page_channel_id = env('HELP_PAY_PAGE_CHANNEL_ID', 123);
  349. $help_pay_page_channel_id = $distribution_channel_id;
  350. $url_format = '%s://site%s.%s.com/helppay?back=%s&su=%s';
  351. $pay_info['pay_redirect_url'] = $pay_redirect_url = sprintf(
  352. $url_format,
  353. env('PROTOCOL'),
  354. encodeDistributionChannelId($help_pay_page_channel_id),
  355. env('CUSTOM_HOST'),
  356. $prize_fee,
  357. $uid
  358. );
  359. }
  360. $pay_url_info = parse_url($pay_redirect_url);
  361. $pay_info['pay_wait_url'] = $pay_url_info['scheme'] . '://' . $pay_url_info['host'] . '/pay/wait?order=' . $data['trade_no'] . '&redirect=' . urlencode($pay_info['pay_redirect_url']);
  362. //$h5_scheme = env('H5_SCHEME','https');
  363. //$jsSdkSign = $this->jsSdkSign($pay_info,str_replace('http',$h5_scheme,url()->current()));
  364. Log::info('$pay_info is');
  365. $jsSdkSign = 0;
  366. Log::info($pay_info);
  367. Log::info('jsSdkSign---- :' . $jsSdkSign);
  368. $pay_order = $trade_no;
  369. // 注册动作-》创建订单
  370. $action_type = 'CreateOrder';
  371. $param = [
  372. 'openid' => isset($openid) ? $openid : '0',
  373. 'uid' => isset($uid) ? $uid : '0',
  374. 'order_sn' => isset($trade_no) ? $trade_no : '0',
  375. 'amount' => isset($price) ? $price : '0',
  376. ];
  377. UserService::PushUserActionToQueue($action_type, $distribution_channel_id, $param);
  378. return view('pay.order.index', compact('pay_info', 'referer', 'jsSdkSign', 'pay_order'));
  379. }
  380. private function paympay(Request $request, $pay_merchant)
  381. {
  382. $product_id = $request->get('product_id');
  383. $uid = $request->get('uid');
  384. $distribution_channel_id = $request->get('distribution_channel_id');
  385. $pay_redirect_url = $request->get('pay_redirect_url');
  386. $send_order_id = $request->get('send_order_id', 0);
  387. $activity_id = $request->get('activity_id', 0);
  388. $suid = $request->get('suid', 0);
  389. $bid = $request->has('bid') ? $request->get('bid') : 0;
  390. $crm = $request->has('crm') ? $request->get('crm') : '';
  391. $hash_bid = $bid;
  392. $fromtype = $request->has('fromtype') ? $request->get('fromtype') : $request->get('from', 'main');
  393. //根据分校id获取支付配置id
  394. Log::info($request->all());
  395. $trade_no = $trade_no = date("YmdHis") . str_shuffle(hexdec(uniqid()));
  396. $order_info = OrderService::getByTradeNo($trade_no);
  397. if ($order_info) return response()->error('WAP_SYS_ERROR');
  398. $cid = $request->has('cid') ? $request->get('cid') : '';
  399. $product_info = ProductService::getProductSingle($product_id, false);
  400. //新用户只能冲一次
  401. //Log::info('新用户只能冲一次:' .$product_info->type);
  402. if ($this->isNewUserSecondCharge($product_info->type, $product_id, $uid)) {
  403. $url = env('PROTOCOL', 'https') . '://site' . encodeDistributionChannelId($distribution_channel_id) . '.' . env('CUSTOM_HOST', 'leyuee') . '.com/pay';
  404. return redirect()->to($url);
  405. }
  406. $price = $product_info->price * 100;
  407. if ($uid < 32) {
  408. $price = 1;
  409. }
  410. if (!$send_order_id) {
  411. try {
  412. $send_order_id = (int)Redis::hget('book_read:' . $uid, 'send_order_id');
  413. } catch (\Exception $e) {
  414. }
  415. }
  416. $this->updateUserSendOrderId($uid, $send_order_id);
  417. if (in_array($uid, explode(',', env('TEST_UID')))) {
  418. $price = 1;
  419. }
  420. try {
  421. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id:' . $distribution_channel_id;
  422. Redis::hset($key, $uid, time());
  423. $date = date('Y-m-d');
  424. Redis::hincrby('order_stat:' . $distribution_channel_id, 'order_num_' . $date, 1);
  425. if ($send_order_id) {
  426. Redis::hincrby('order_promotion_stat:' . $send_order_id, 'order_num_' . $date, 1);
  427. Redis::hincrby('order_promotion_stat:' . $send_order_id, 'total', 1);
  428. }
  429. } catch (\Exception $e) {
  430. }
  431. if (isset($_SERVER['HTTP_X_FORWARDED_FOR']) && $_SERVER['HTTP_X_FORWARDED_FOR']) {
  432. $ip = $_SERVER['HTTP_X_FORWARDED_FOR'];
  433. } else {
  434. $ip = get_client_ip();
  435. }
  436. $data = [];
  437. $data['price'] = $price;
  438. $data['create_ip'] = $ip;
  439. $data['body'] = 'novel read';
  440. $official_name = $this->getSubscribeOfficialName($uid, $distribution_channel_id);
  441. if ($official_name) {
  442. $data['body'] = '搜索公众号' . $official_name . ',请继续阅读';
  443. }
  444. $data['detail'] = 'novel read';
  445. $data['trade_no'] = $trade_no;
  446. if ($product_info->type == 'YEAR_ORDER') {
  447. $order_type = 'YEAR';
  448. } elseif ($product_info->type == 'BOOK_ORDER') {
  449. $order_type = 'BOOK';
  450. } elseif ($product_info->type == 'TICKET_RECHARGE') {
  451. $order_type = 'RECHARGE';
  452. } elseif ($product_info->type == 'NEW_USER') {
  453. $order_type = 'RECHARGE';
  454. } else {
  455. $order_type = 'UNKNOWN';
  456. }
  457. $send_order_name = '';
  458. if ($send_order_id) {
  459. $send_order_info = SendOrderService::getById($send_order_id);
  460. if ($send_order_info && isset($send_order_info->name) && !empty($send_order_info->name)) {
  461. $send_order_name = $send_order_info->name;
  462. }
  463. }
  464. if ($suid) {
  465. $user_info = UserService::getById($uid);
  466. $distribution_channel_id = $user_info->distribution_channel_id;
  467. }
  468. $from_bid = ReadRecordService::getSimpleFirstReadRecord($uid);
  469. $inner_send_order_id = ReadRecordService::getInnerSendOrderId($uid);
  470. $init_order = [
  471. 'distribution_channel_id' => $distribution_channel_id,
  472. 'uid' => $uid,
  473. 'product_id' => $product_id,
  474. 'price' => $price / 100,
  475. 'pay_type' => 1,
  476. 'trade_no' => $data['trade_no'],
  477. 'pay_merchant_source' => 'PALMPAY',
  478. 'pay_merchant_id' => $pay_merchant->id,
  479. 'create_ip' => $ip,
  480. 'send_order_id' => $send_order_id,
  481. 'send_order_name' => $send_order_name,
  482. 'order_type' => $order_type,
  483. 'from_bid' => $from_bid,
  484. 'from_type' => $fromtype,
  485. 'activity_id' => $activity_id,
  486. 'inner_send_order_id' => $inner_send_order_id
  487. ];
  488. $result = $this->createUnPayOrder($init_order);
  489. //订单创建成功后增加统计
  490. if ($result) {
  491. $this->orderCreated($init_order);
  492. $this->recordOtherParam($result->id, $uid);
  493. if($crm){
  494. OrderParamService::createByParam([
  495. 'order_id'=>$result->id,'gxhp'=>'crm','appid'=>'','bid'=>$bid,'data_hour_key'=>$crm,'times'=>'','distribution_channel_id'=>$distribution_channel_id
  496. ]);
  497. }
  498. $this->orderParamWso($uid,$result->id);
  499. }
  500. if ($suid) {
  501. $this->createSubstituteOrder($result->id, $uid, $suid);
  502. }
  503. if ($suid) {
  504. $prize_fee = (int)(($product_info->price * 100) * 0.1);
  505. //$help_pay_page_channel_id = env('HELP_PAY_PAGE_CHANNEL_ID', 123);
  506. $help_pay_page_channel_id = $distribution_channel_id;
  507. $url_format = '%s://site%s.%s.com/helppay?back=%s&su=%s';
  508. $pay_redirect_url = sprintf(
  509. $url_format,
  510. env('PROTOCOL'),
  511. encodeDistributionChannelId($help_pay_page_channel_id),
  512. env('CUSTOM_HOST'),
  513. $prize_fee,
  514. $uid
  515. );
  516. }
  517. $de_pay_redirect_url = urldecode($pay_redirect_url);
  518. /*if ($request->has('cid')) {
  519. $de_pay_redirect_url = $de_pay_redirect_url . '&cid=' . $request->get('cid');
  520. }*/
  521. $pay_url_info = parse_url($de_pay_redirect_url);
  522. $data['pay_wait_url'] = $pay_url_info['scheme'] . '://' . $pay_url_info['host'] . '/pay/waitv2?order=' . $data['trade_no'] . '&redirect=' . urlencode($de_pay_redirect_url);
  523. Log::info($data);
  524. $config = [];
  525. if ($pay_merchant->config_info) {
  526. $config = json_decode($pay_merchant->config_info, true);
  527. }
  528. $wechatPay = WechatPay::instance($pay_merchant->source, $config);
  529. \Log::info('$wechatPay is');
  530. //\Log::info($wechatPay);
  531. if (!$wechatPay) return response()->error('WAP_PARAM_ERROR');
  532. \Log::info('$wechatPay ok-------------------');
  533. $pay_info = $wechatPay->send($data);
  534. \Log::info('send ok-------------------');
  535. // 注册动作-》创建订单
  536. $action_type = 'CreateOrder';
  537. $param = [
  538. 'openid' => isset($openid) ? $openid : '0',
  539. 'uid' => isset($uid) ? $uid : '0',
  540. 'order_sn' => isset($trade_no) ? $trade_no : '0',
  541. 'amount' => isset($price) ? $price : '0',
  542. ];
  543. \Log::info('FUCK_PALMPAYV2');
  544. UserService::PushUserActionToQueue($action_type, $distribution_channel_id, $param);
  545. return $pay_info;
  546. }
  547. public function waitPageV2(Request $request)
  548. {
  549. $order = $request->get('order');
  550. $order = (string)$order;
  551. $url = urldecode($request->get('redirect'));
  552. if (substr_count($url, '?') > 1) {
  553. $url = str_replace_last('?', '&', $url);
  554. }
  555. $url_info = parse_url($url);
  556. if (isset($url_info['query']) && !empty($url_info['query'])) {
  557. parse_str($url_info['query'], $path);
  558. if (isset($path['success']) && $path['success'] == 0) {
  559. if (isset($url_info['path']) && str_contains($url_info['path'], 'reader') && isset($path['cid']) && !empty($path['cid'])) {
  560. $chapter_info = ChapterService::getChapterNameByIdNoCheck($path['cid']);
  561. $path['cid'] = $chapter_info->prev_cid;
  562. $url = sprintf('%s://%s/reader?%s', $url_info['scheme'], $url_info['host'], http_build_query($path));
  563. }
  564. return redirect($url);
  565. }
  566. }
  567. if (isset($url_info['path']) && str_contains($url_info['path'], 'pay')) {
  568. $url = sprintf('%s://%s/recent', $url_info['scheme'], $url_info['host']);
  569. return redirect($url);
  570. }
  571. $order_info = OrderService::getByTradeNo($order);
  572. $uid = $order_info->uid;
  573. $bind_info = UserBindPhoneService::bindInfo($uid);
  574. $page = 'pay.order.wait';
  575. if(!$bind_info){
  576. $page = 'pay.order.bindPhone';
  577. }
  578. return view($page, compact('order', 'url'));
  579. }
  580. private function isNewUserSecondCharge($charge_type, $product_id, $uid)
  581. {
  582. //Log::info('新用户只能冲一次:' .$charge_type);
  583. if ($charge_type == 'NEW_USER') {
  584. $result = OrderService::getUserOrderByProductId($uid, $product_id);
  585. //Log::info('isNewUserSecondCharge-------------------------');
  586. //Log::info($result);
  587. if ($result) {
  588. return true;
  589. }
  590. }
  591. return false;
  592. }
  593. //订单创建后统计
  594. private function orderCreated($init_order)
  595. {
  596. try {
  597. if (isset($init_order['pay_merchant_id'])) {
  598. $key = 'pay_merchant:' . $init_order['pay_merchant_id'];
  599. Redis::hincrby($key, 'unpaid_num', 1);
  600. Redis::hset($key, 'last_create_time', time());
  601. }
  602. } catch (\Exception $e) {
  603. }
  604. }
  605. //订单回调后统计
  606. private function orderPaid($init_order)
  607. {
  608. try {
  609. if (isset($init_order['pay_merchant_id'])) {
  610. $key = 'pay_merchant:' . $init_order['pay_merchant_id'];
  611. Redis::hset($key, 'unpaid_num', 0);
  612. }
  613. } catch (\Exception $e) {
  614. }
  615. }
  616. public function reportError(Request $request)
  617. {
  618. $data = $request->post('data');
  619. DB::table('pay_page_error')->insert([
  620. 'msg' => $data,
  621. 'created_at' => date('Y-m-d H:i:s'),
  622. 'updated_at' => date('Y-m-d H:i:s')
  623. ]);
  624. return response()->success();
  625. }
  626. private function jsSdkSign($pay_info, $url)
  627. {
  628. if (!isset($pay_info['appId']) || !isset($pay_info['package'])) {
  629. return 0;
  630. }
  631. $appid = $pay_info['appId'];
  632. $jsapi_ticket = Redis::hget($appid, 'jsapi_ticket');
  633. //如果能获取到jsapi_ticket 则直接签名
  634. if ($jsapi_ticket) {
  635. $sign_arr = [
  636. 'noncestr' => $pay_info['nonceStr'],
  637. 'jsapi_ticket' => $jsapi_ticket,
  638. 'timestamp' => $pay_info['timeStamp'],
  639. 'url' => $url
  640. ];
  641. return sha1($this->arr_to_url($sign_arr));
  642. }
  643. //获取不到jsapi_ticket
  644. $app_secret_info = DB::table('official_setting')->select('secret')->first();
  645. if ($app_secret_info && !empty($app_secret_info->secret)) {
  646. $client = new Client(['timeout' => 5]);
  647. try {
  648. //获取access_token
  649. $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=' . $appid . '&secret=' . $app_secret_info->secret;
  650. $res = $client->request('get', $url)->getBody()->getContents();
  651. if (!$res) {
  652. return 0;
  653. }
  654. $res = json_decode($res, 1);
  655. if (!isset($res['access_token']) || empty($res['access_token'])) {
  656. return 0;
  657. }
  658. Redis::hset($appid, 'access_token', $res['access_token']);
  659. //获取jsapi_ticket
  660. $res = null;
  661. $url = 'https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=' . $res['access_token'] . '&type=jsapi';
  662. $res = $client->request('get', $url)->getBody()->getContents();
  663. if (!$res) {
  664. return 0;
  665. }
  666. $res = json_decode($res, 1);
  667. if (!isset($res['ticket']) || empty($res['ticket'])) {
  668. return 0;
  669. }
  670. Redis::hset($appid, 'jsapi_ticket', $res['ticket']);
  671. Redis::EXPIRE($appid, 7000);
  672. $sign_arr = [
  673. 'noncestr' => $pay_info['nonceStr'],
  674. 'jsapi_ticket' => $res['ticket'],
  675. 'timestamp' => $pay_info['timeStamp'],
  676. 'url' => $url
  677. ];
  678. return sha1($this->arr_to_url($sign_arr));
  679. } catch (\Exception $e) {
  680. return 0;
  681. }
  682. }
  683. return 0;
  684. }
  685. public function waitPage(Request $request)
  686. {
  687. $order = $request->input('order');
  688. //$order = "201712081711401585932843356442";
  689. $order = (string)$order;
  690. $order_info = OrderService::getByTradeNo($order);
  691. $uid = $order_info->uid;
  692. $bind_info = UserBindPhoneService::bindInfo($uid);
  693. $page = 'pay.order.wait';
  694. if(!$bind_info){
  695. $page = 'pay.order.bindPhone';
  696. }
  697. $url = urldecode($request->input('redirect'));
  698. return view($page, compact('order', 'url'));
  699. //return view('pay.order.wait');
  700. }
  701. /**
  702. * 官方微信回调
  703. * @param Request $request
  704. * @return \Symfony\Component\HttpFoundation\Response
  705. */
  706. function wcback_official(Request $request)
  707. {
  708. libxml_disable_entity_loader(true);
  709. $xml = XML::parse(strval($request->getContent()));
  710. Log::info('xml is');
  711. Log::info($xml);
  712. if (!$xml || !is_array($xml)) return 'fail';
  713. $remarks = json_decode($xml['attach'], true);
  714. $pay_merchant_id = $remarks['pmi'];
  715. $pay_merchant = DB::table('pay_merchants')->select('appid', 'source', 'config_info')->where('id', $pay_merchant_id)->where('is_enabled', 1)->first();
  716. $application = WechatPay::instance('OFFICIALPAY', json_decode($pay_merchant->config_info, true));
  717. //$app = new Application($options);
  718. $app = $application->app;
  719. $response = $app->payment->handleNotify(function ($notify, $successful) {
  720. if (!$successful) return 'fail';
  721. $trade_no = $notify->out_trade_no;
  722. $order = OrderService::getByTradeNo($trade_no);
  723. if (isset($order->status) && $order->status == 'PAID') {
  724. Log::info('has_pay:' . $trade_no);
  725. return true;
  726. }
  727. DB::beginTransaction();
  728. try {
  729. $transaction_id = $notify->transaction_id;
  730. $remarks = json_decode($notify->attach, true);
  731. $uid = $remarks['uid'];
  732. $distribution_channel_id = $remarks['dcd'];
  733. $product_id = $remarks['pd'];
  734. $product = ProductService::getProductSingle($product_id);
  735. $pay_merchant_source = $remarks['pms'];
  736. $pay_merchant_id = $remarks['pmi'];
  737. $send_order_id = $remarks['soi'];
  738. $create_ip = $remarks['cp'];
  739. $price = $product->price;
  740. $bid = $remarks['bid'];
  741. //$this->updateOrderTotal($trade_no,$transaction_id);
  742. $prize_fee = (int)(($product->price * 100) * 0.1);
  743. $this->substituteOrderPrice($order->id, $prize_fee);
  744. $this->smartPushTestBookPaidUv($order->from_bid, $order->uid, $order->price);
  745. //获取用户充值次数
  746. $order->pay_type = $this->getChargeTimes($order->uid);
  747. // 更新其他定制Order表
  748. if ($product->type == 'YEAR_ORDER') {
  749. Log::info('YEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDER');
  750. $order_type = 'YEAR';
  751. $this->yearOrder($uid, $distribution_channel_id, $price, $send_order_id);
  752. $order->order_type = $order_type;
  753. $order->status = 'PAID';
  754. $order->pay_end_at = date('Y-m-d H:i:s');
  755. $order->transaction_id = $transaction_id;
  756. $order->save();
  757. //$price = $price/100;
  758. /*
  759. $this->createOrder(
  760. compact(
  761. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  762. 'pay_merchant_id','create_ip','bid','transaction_id'
  763. )
  764. );*/
  765. } elseif ($product->type == 'BOOK_ORDER') {
  766. Log::info('BOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDER');
  767. $order_type = 'BOOK';
  768. $this->bookOrder($product_id, $uid, $send_order_id, $price, $distribution_channel_id);
  769. $order->order_type = $order_type;
  770. $order->status = 'PAID';
  771. $order->pay_end_at = date('Y-m-d H:i:s');
  772. $order->transaction_id = $transaction_id;
  773. $order->save();
  774. //$price = $price/100;
  775. /*
  776. $this->createOrder(
  777. compact(
  778. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  779. 'pay_merchant_id','create_ip','bid','transaction_id'
  780. )
  781. );*/
  782. } elseif ($product->type == 'TICKET_RECHARGE') {
  783. Log::info('TICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGE');
  784. $order_type = 'RECHARGE';
  785. $this->userCharge($product, $uid);
  786. $order->order_type = $order_type;
  787. $order->status = 'PAID';
  788. $order->pay_end_at = date('Y-m-d H:i:s');
  789. $order->transaction_id = $transaction_id;
  790. $order->save();
  791. //$price = $price/100;
  792. /*
  793. $this->createOrder(
  794. compact(
  795. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  796. 'pay_merchant_id','create_ip','bid','transaction_id'
  797. ));*/
  798. } elseif ($product->type == 'FOREVER') {
  799. Log::info('FOREVER------------------------FOREVER');
  800. $order_type = 'FOREVER';
  801. $this->foreverFreeOrder($uid, $distribution_channel_id, $price, $send_order_id);
  802. $order->order_type = $order_type;
  803. $order->status = 'PAID';
  804. $order->pay_end_at = date('Y-m-d H:i:s');
  805. $order->transaction_id = $transaction_id;
  806. $order->save();
  807. } else {
  808. DB::rollback();
  809. return 'Order not exist.';
  810. }
  811. $this->successPayPushMsg($uid, $product, $order->id);
  812. $this->orderStatistical($order);
  813. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id:' . $distribution_channel_id;
  814. Redis::hdel($key, $uid);
  815. DB::commit();
  816. $this->huaweiActivity($order->activity_id,$uid,$product_id);
  817. // 注册动作-》回调订单
  818. $action_type = 'CallBackOrder';
  819. $param = [
  820. 'order_sn' => isset($trade_no) ? $trade_no : '0',
  821. 'openid' => isset($uid) ? $uid : '0',// 没有openid,用uid写log
  822. ];
  823. UserService::PushUserActionToQueue($action_type, $distribution_channel_id, $param);
  824. //用户属性
  825. $this->userProperty($uid,$price,$product->type,$order->activity_id);
  826. //交换订单时间
  827. $this->exchangeUpdateAndCreated($order->id);
  828. return true;
  829. } catch (\Exception $e) {
  830. DB::rollback();
  831. return 'fail';
  832. }
  833. });
  834. return $response;
  835. }
  836. /**
  837. * 通联支付回调
  838. * @param Request $request
  839. */
  840. function wcback_allinpay(Request $request)
  841. {
  842. Log::info('wcback_allinpay_request');
  843. try {
  844. $data = $request->all();
  845. Log::info($request->all());
  846. if (!$data['trxreserved']) return 'fail';
  847. $pay_merchant_id = json_decode($data['trxreserved'], true)['pmi'];
  848. $pay_merchant = DB::table('pay_merchants')->select('appid', 'source', 'config_info')->where('id', $pay_merchant_id)->where('is_enabled', 1)->first();
  849. unset($data['_url']);
  850. if (!$pay_merchant->config_info) return 'fail';
  851. $wechatPay = WechatPay::instance('ALLINPAY', json_decode($pay_merchant->config_info, true));
  852. if ($wechatPay->NotifyValidSign($data, $wechatPay->appkey)) {
  853. Log::info('allinpay_notify_sign_success');
  854. /**
  855. * 只有0000表示交易成功或下单成功,其他为失败
  856. * 0000:交易成功
  857. * 3045,3088:交易超时
  858. * 3008:余额不足
  859. * 3999:交易失败
  860. * 2008:交易处理中
  861. * 3050:交易已撤销
  862. */
  863. if ($data['trxstatus'] == '0000') {
  864. // 修改表比较多,开启事务
  865. DB::beginTransaction();
  866. $trade_no = $data['cusorderid'];
  867. $transaction_id = $data['chnltrxid'];
  868. //$openid = $data['acct'];
  869. $remarks = $data['trxreserved'];
  870. // $remarks = '{"openid":"oEteU1VNvYozhXuu8TXhByPBtSl4","distribution_channel_id":2,"product_id":1,"uid":1,"price":"1","trade_no":"201711301937151585490779316114","create_ip":"::1","servicer":"AllinPay"}';
  871. $remarks = json_decode($remarks, true);
  872. Log::info('$remarks');
  873. Log::info($remarks);
  874. // 更新Order
  875. $order = OrderService::getByTradeNo($trade_no);
  876. // 防止重复推送
  877. if (isset($order->status) && $order->status == 'PAID') {
  878. Log::info('has_pay:' . $trade_no);
  879. echo 'success';
  880. exit();
  881. }
  882. $uid = $remarks['uid'];
  883. $distribution_channel_id = $remarks['dcd'];
  884. $product_id = $remarks['pd'];
  885. $product = ProductService::getProductSingle($product_id);
  886. $pay_merchant_source = $remarks['pms'];
  887. $pay_merchant_id = $remarks['pmi'];
  888. $send_order_id = $remarks['soi'];
  889. $create_ip = $remarks['cp'];
  890. $price = $product->price;
  891. $bid = $remarks['bid'];
  892. Log::info('save_order_end');
  893. //$this->updateOrderTotal($trade_no,$transaction_id);
  894. Log::info($product);
  895. Log::info('product_type:' . $product->type);
  896. $prize_fee = (int)(($product->price * 100) * 0.1);
  897. $this->substituteOrderPrice($order->id, $prize_fee);
  898. $this->smartPushTestBookPaidUv($order->from_bid, $order->uid, $order->price);
  899. //获取用户充值次数
  900. $order->pay_type = $this->getChargeTimes($order->uid);
  901. // 更新其他定制Order表
  902. if ($product->type == 'YEAR_ORDER') {
  903. Log::info('YEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDER');
  904. $order_type = 'YEAR';
  905. $this->yearOrder($uid, $distribution_channel_id, $price, $send_order_id);
  906. $order->order_type = $order_type;
  907. $order->status = 'PAID';
  908. $order->pay_end_at = date('Y-m-d H:i:s');
  909. $order->transaction_id = $transaction_id;
  910. $order->save();
  911. //$price = $price/100;
  912. /*
  913. $this->createOrder(
  914. compact(
  915. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  916. 'pay_merchant_id','create_ip','bid','transaction_id'
  917. )
  918. );*/
  919. } elseif ($product->type == 'BOOK_ORDER') {
  920. Log::info('BOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDER');
  921. $order_type = 'BOOK';
  922. $this->bookOrder($product_id, $uid, $send_order_id, $price, $distribution_channel_id);
  923. $order->order_type = $order_type;
  924. $order->status = 'PAID';
  925. $order->pay_end_at = date('Y-m-d H:i:s');
  926. $order->transaction_id = $transaction_id;
  927. $order->save();
  928. //$price = $price/100;
  929. /*
  930. $this->createOrder(
  931. compact(
  932. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  933. 'pay_merchant_id','create_ip','bid','transaction_id'
  934. )
  935. );*/
  936. } elseif ($product->type == 'TICKET_RECHARGE' || $product->type == 'NEW_USER') {
  937. Log::info('TICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGE');
  938. $order_type = 'RECHARGE';
  939. $this->userCharge($product, $uid);
  940. $order->order_type = $order_type;
  941. $order->status = 'PAID';
  942. $order->pay_end_at = date('Y-m-d H:i:s');
  943. $order->transaction_id = $transaction_id;
  944. $order->save();
  945. //$price = $price/100;
  946. /*
  947. $this->createOrder(
  948. compact(
  949. 'uid','distribution_channel_id','product_id','price','trade_no','send_order_id','order_type','pay_merchant_source',
  950. 'pay_merchant_id','create_ip','bid','transaction_id'
  951. ));*/
  952. } elseif ($product->type == 'FOREVER') {
  953. Log::info('FOREVER------------------------FOREVER');
  954. $order_type = 'FOREVER';
  955. $this->foreverFreeOrder($uid, $distribution_channel_id, $price, $send_order_id);
  956. $order->order_type = $order_type;
  957. $order->status = 'PAID';
  958. $order->pay_end_at = date('Y-m-d H:i:s');
  959. $order->transaction_id = $transaction_id;
  960. $order->save();
  961. }
  962. $this->successPayPushMsg($uid, $product, $order->id);
  963. $this->orderStatistical($order);
  964. DB::commit();
  965. $this->userProperty($uid,$price,$product->type,$order->activity_id);
  966. $this->huaweiActivity($order->activity_id,$uid,$product_id);
  967. //交换订单时间
  968. $this->exchangeUpdateAndCreated($order->id);
  969. //redis 删除未支付的uid
  970. try {
  971. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id:' . $distribution_channel_id;
  972. Redis::hdel($key, $uid);
  973. //Redis::srem($key,$uid);
  974. } catch (\Exception $e) {
  975. Log::info('redis remote error-----------------------');
  976. Log::info($e);
  977. }
  978. }
  979. } else {
  980. Log::info('allinpay_notify_sign_fail');
  981. }
  982. } catch (\Exception $e) {
  983. DB::rollBack();
  984. Log::info('receive_allinpay_ept:' . $e->getMessage());
  985. Log::info('pay_callback_end fail');
  986. echo 'fail';
  987. return;
  988. }
  989. Log::info('pay_callback_end');
  990. echo "success";
  991. }
  992. public function wcback_lianlianpay(Request $request)
  993. {
  994. $data = $request->getContent();
  995. Log::info('wcback_lianlianpay call back enter');
  996. Log::info($request->getContent());
  997. $data = json_decode($data, true);
  998. if ($data['result_pay'] == 'SUCCESS') {
  999. $trade_no = $data['no_order'];
  1000. $order = OrderService::getByTradeNo($trade_no);
  1001. if (!$order) return response()->json(['ret_code' => '-1']);
  1002. $pay_merchant_id = $order->pay_merchant_id;
  1003. $pay_merchant = DB::table('pay_merchants')->select('appid', 'source', 'config_info')->where('id', $pay_merchant_id)->where('is_enabled', 1)->first();
  1004. unset($data['_url']);
  1005. if (!$pay_merchant->config_info) response()->json(['ret_code' => '-1']);
  1006. $wechatPay = WechatPay::instance('LIANLIANPAY', json_decode($pay_merchant->config_info, true));
  1007. $uid = $order->uid;
  1008. $distribution_channel_id = $order->distribution_channel_id;
  1009. $price = $order->price;
  1010. $send_order_id = $order->send_order_id;
  1011. $product_id = $order->product_id;
  1012. if (!$wechatPay->rsaCheck($data)) {
  1013. Log::info('sign check error');
  1014. //return response()->json(['ret_code'=>'-1']);
  1015. }
  1016. // 防止重复推送
  1017. if (isset($order->status) && $order->status == 'PAID') {
  1018. Log::info('has_pay:' . $trade_no);
  1019. return response()->json(['ret_code' => '0000', 'ret_msg' => '交易成功']);
  1020. }
  1021. DB::beginTransaction();
  1022. try {
  1023. $product = ProductService::getProductSingle($order->product_id);
  1024. $transaction_id = $data['oid_paybill'];
  1025. $prize_fee = (int)(($product->price * 100));
  1026. $this->substituteOrderPrice($order->id, $prize_fee);
  1027. $this->smartPushTestBookPaidUv($order->from_bid, $order->uid, $order->price);
  1028. //获取用户充值次数
  1029. $order->pay_type = $this->getChargeTimes($order->uid);
  1030. // 更新其他定制Order表
  1031. if ($product->type == 'YEAR_ORDER') {
  1032. Log::info('YEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDER');
  1033. $order_type = 'YEAR';
  1034. $this->yearOrder($uid, $distribution_channel_id, $price, $send_order_id);
  1035. $order->order_type = $order_type;
  1036. $order->status = 'PAID';
  1037. $order->pay_end_at = date('Y-m-d H:i:s');
  1038. $order->transaction_id = $transaction_id;
  1039. $order->save();
  1040. } elseif ($product->type == 'BOOK_ORDER') {
  1041. Log::info('BOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDER');
  1042. $order_type = 'BOOK';
  1043. $this->bookOrder($product_id, $uid, $send_order_id, $price, $distribution_channel_id);
  1044. $order->order_type = $order_type;
  1045. $order->status = 'PAID';
  1046. $order->pay_end_at = date('Y-m-d H:i:s');
  1047. $order->transaction_id = $transaction_id;
  1048. $order->save();
  1049. } elseif ($product->type == 'TICKET_RECHARGE' || $product->type == 'NEW_USER') {
  1050. Log::info('TICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGE');
  1051. $order_type = 'RECHARGE';
  1052. $this->userCharge($product, $uid);
  1053. $order->order_type = $order_type;
  1054. $order->status = 'PAID';
  1055. $order->pay_end_at = date('Y-m-d H:i:s');
  1056. $order->transaction_id = $transaction_id;
  1057. $order->save();
  1058. } elseif ($product->type == 'FOREVER') {
  1059. Log::info('FOREVER------------------------FOREVER');
  1060. $order_type = 'FOREVER';
  1061. $this->foreverFreeOrder($uid, $distribution_channel_id, $price, $send_order_id);
  1062. $order->order_type = $order_type;
  1063. $order->status = 'PAID';
  1064. $order->pay_end_at = date('Y-m-d H:i:s');
  1065. $order->transaction_id = $transaction_id;
  1066. $order->save();
  1067. }
  1068. $this->successPayPushMsg($uid, $product, $order->id);
  1069. $this->orderStatistical($order);
  1070. DB::commit();
  1071. $this->userProperty($uid,$price,$product->type,$order->activity_id);
  1072. $this->huaweiActivity($order->activity_id,$uid,$product_id);
  1073. //redis 删除未支付的uid
  1074. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id' . $distribution_channel_id;
  1075. Redis::hdel($key, $uid);
  1076. //交换订单时间
  1077. $this->exchangeUpdateAndCreated($order->id);
  1078. return response()->json(['ret_code' => '0000', 'ret_msg' => '交易成功']);
  1079. } catch (\Exception $e) {
  1080. DB::rollBack();
  1081. Log::info('lianlian:' . $e->getMessage());
  1082. echo 'fail';
  1083. return;
  1084. }
  1085. }
  1086. echo 'success';
  1087. }
  1088. /**
  1089. * 微众支付回调
  1090. * @param Request $request
  1091. */
  1092. function wcback_palmpay(Request $request)
  1093. {
  1094. Log::info('wcback_palmpay_request');
  1095. try {
  1096. $data = $request->except('_url');
  1097. Log::info($request->all());
  1098. //订单
  1099. $trade_no = $data['outTradeNo'];
  1100. $order = OrderService::getByTradeNo($trade_no);
  1101. if (!$order) die('failed');
  1102. // 防止重复推送
  1103. if (isset($order->status) && $order->status == 'PAID') {
  1104. if($data['chorderid'] != $order->transaction_id){
  1105. Log::info('palmpay order repeat');
  1106. $this->palmpaySpecial($data['chorderid'],$trade_no);
  1107. }
  1108. Log::info('has_pay:' . $trade_no);
  1109. echo 'success';
  1110. exit();
  1111. }
  1112. $pay_merchant = DB::table('pay_merchants')->select('appid', 'source', 'config_info')->where('id', $order->pay_merchant_id)->where('is_enabled', 1)->first();
  1113. //校验签名
  1114. $sign = _sign($data, json_decode($pay_merchant->config_info, 1)['appKey']);
  1115. if ($sign != $data['sign']) die('failed');
  1116. $transaction_id = $data['chorderid'];
  1117. if ($data['status'] == 'success') {
  1118. Log::info('wcback_palmpay_notify_sign_success');
  1119. if ($data['status'] == 'success') {
  1120. // 修改表比较多,开启事务
  1121. DB::beginTransaction();
  1122. // 更新Order
  1123. $order = OrderService::getByTradeNo($trade_no);
  1124. $uid = $order->uid;
  1125. $distribution_channel_id = $order->distribution_channel_id;
  1126. $product_id = $order->product_id;
  1127. $product = ProductService::getProductSingle($product_id);
  1128. $send_order_id = $order->send_order_id;
  1129. $price = $product->price;
  1130. Log::info('save_order_end');
  1131. Log::info($product);
  1132. Log::info('product_type:' . $product->type);
  1133. $prize_fee = (int)(($product->price * 100) * 0.1);
  1134. $this->substituteOrderPrice($order->id, $prize_fee);
  1135. $this->smartPushTestBookPaidUv($order->from_bid, $order->uid, $order->price);
  1136. //获取用户充值次数
  1137. $order->pay_type = $this->getChargeTimes($order->uid);
  1138. // 更新其他定制Order表
  1139. if ($product->type == 'YEAR_ORDER') {
  1140. Log::info('YEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDERYEAR_ORDER');
  1141. $order_type = 'YEAR';
  1142. $this->yearOrder($uid, $distribution_channel_id, $price, $send_order_id);
  1143. $order->order_type = $order_type;
  1144. $order->status = 'PAID';
  1145. $order->pay_end_at = date('Y-m-d H:i:s');
  1146. $order->transaction_id = $transaction_id;
  1147. $order->save();
  1148. } elseif ($product->type == 'BOOK_ORDER') {
  1149. Log::info('BOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDERBOOK_ORDER');
  1150. $order_type = 'BOOK';
  1151. $this->bookOrder($product_id, $uid, $send_order_id, $price, $distribution_channel_id);
  1152. $order->order_type = $order_type;
  1153. $order->status = 'PAID';
  1154. $order->pay_end_at = date('Y-m-d H:i:s');
  1155. $order->transaction_id = $transaction_id;
  1156. $order->save();
  1157. } elseif ($product->type == 'TICKET_RECHARGE' || $product->type == 'NEW_USER') {
  1158. Log::info('TICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGETICKET_RECHARGE');
  1159. $order_type = 'RECHARGE';
  1160. $this->userCharge($product, $uid);
  1161. $order->order_type = $order_type;
  1162. $order->status = 'PAID';
  1163. $order->pay_end_at = date('Y-m-d H:i:s');
  1164. $order->transaction_id = $transaction_id;
  1165. $order->save();
  1166. } elseif ($product->type == 'FOREVER') {
  1167. Log::info('FOREVER------------------------FOREVER');
  1168. $order_type = 'FOREVER';
  1169. $this->foreverFreeOrder($uid, $distribution_channel_id, $price, $send_order_id);
  1170. $order->order_type = $order_type;
  1171. $order->status = 'PAID';
  1172. $order->pay_end_at = date('Y-m-d H:i:s');
  1173. $order->transaction_id = $transaction_id;
  1174. $order->save();
  1175. }
  1176. $this->successPayPushMsg($uid, $product, $order->id);
  1177. $this->orderStatistical($order);
  1178. DB::commit();
  1179. //redis 删除未支付的uid
  1180. try {
  1181. $key = 'leyuee:to_send_not_pay_uid:distribution_channel_id:' . $distribution_channel_id;
  1182. Redis::hdel($key, $uid);
  1183. } catch (\Exception $e) {
  1184. Log::info('redis remote error-----------------------');
  1185. Log::info($e);
  1186. }
  1187. // 注册动作-》回调订单
  1188. $action_type = 'CallBackOrder';
  1189. $param = [
  1190. 'order_sn' => isset($trade_no) ? $trade_no : '0',
  1191. 'openid' => isset($uid) ? $uid : '0',// 没有openid,用uid写log
  1192. ];
  1193. UserService::PushUserActionToQueue($action_type, $distribution_channel_id, $param);
  1194. $this->userProperty($uid,$price,$product->type,$order->activity_id);
  1195. $this->huaweiActivity($order->activity_id,$uid,$product_id);
  1196. //交换订单时间
  1197. $this->exchangeUpdateAndCreated($order->id);
  1198. }
  1199. } else {
  1200. Log::info('wcback_palmpay_notify_sign_fail');
  1201. }
  1202. } catch (\Exception $e) {
  1203. var_dump($e->getMessage());
  1204. DB::rollBack();
  1205. Log::info('receive_wcback_palmpay_ept:' . $e->getMessage());
  1206. echo 'fail';
  1207. Log::info('pay_callback_end error');
  1208. return;
  1209. }
  1210. Log::info('pay_callback_end');
  1211. echo "success";
  1212. }
  1213. /**
  1214. * 公众号签名@华灯初上
  1215. * @param $params
  1216. * @return string
  1217. */
  1218. protected function getSign($params, $key)
  1219. {
  1220. $url = $this->arr_to_url($params, false);
  1221. $url = $url . '&key=' . $key;
  1222. $sign = md5($url);
  1223. return $sign;
  1224. }
  1225. /**
  1226. * 公众号签名@华灯初上
  1227. * @param $array
  1228. * @param bool $has_sign
  1229. * @return string
  1230. */
  1231. protected function arr_to_url($array, $has_sign = false)
  1232. {
  1233. ksort($array);
  1234. reset($array);
  1235. $arg = "";
  1236. while (list ($name, $val) = each($array)) {
  1237. if ($name == 'sign' && !$has_sign) continue;
  1238. if (strpos($name, "_") === 0)
  1239. continue;
  1240. if (is_array($val))
  1241. $val = join(',', $val);
  1242. if ($val === "")
  1243. continue;
  1244. $arg .= $name . "=" . $val . "&";
  1245. }
  1246. $arg = substr($arg, 0, count($arg) - 2);
  1247. return $arg;
  1248. }
  1249. /**
  1250. * 单本充值会掉
  1251. * @param $product_id
  1252. * @param $uid
  1253. * @param $send_order_id
  1254. * @param $fee
  1255. */
  1256. protected function bookOrder($product_id, $uid, $send_order_id, $fee, $distribution_channel_id)
  1257. {
  1258. $book_conf = BookConfigService::getBookByProduct($product_id);
  1259. $insert_data['bid'] = isset($book_conf->bid) ? $book_conf->bid : '';
  1260. $insert_data['book_name'] = isset($book_conf->book_name) ? $book_conf->book_name : '';
  1261. $insert_data['uid'] = $uid;
  1262. $insert_data['distribution_channel_id'] = $distribution_channel_id;
  1263. $insert_data['fee'] = $fee;
  1264. $insert_data['send_order_id'] = $send_order_id;
  1265. $insert_data['charge_balance'] = 0;
  1266. $insert_data['reward_balance'] = 0;
  1267. Log::info('start_save_book_order');
  1268. Log::info($insert_data);
  1269. return BookOrderService::save_book_order($insert_data);
  1270. }
  1271. /**
  1272. * 包年
  1273. * @param $uid
  1274. * @param $distribution_channel_id
  1275. * @param $fee
  1276. * @param $send_order_id
  1277. * @return mixed
  1278. */
  1279. protected function yearOrder($uid, $distribution_channel_id, $fee, $send_order_id)
  1280. {
  1281. Log::info('start_save_year_order');
  1282. $insert_data['uid'] = $uid;
  1283. $insert_data['distribution_channel_id'] = $distribution_channel_id;
  1284. $insert_data['fee'] = $fee;
  1285. $insert_data['send_order_id'] = $send_order_id;
  1286. Log::info($insert_data);
  1287. return YearOrderService::save_year_order($insert_data);
  1288. }
  1289. private function foreverFreeOrder($uid, $distribution_channel_id, $fee, $send_order_id)
  1290. {
  1291. Log::info('start_save_year_order');
  1292. ('start_forever_Free_Order');
  1293. $insert_data['uid'] = $uid;
  1294. $insert_data['distribution_channel_id'] = $distribution_channel_id;
  1295. $insert_data['fee'] = $fee;
  1296. $insert_data['send_order_id'] = $send_order_id;
  1297. Log::info($insert_data);
  1298. return YearOrderService::foreverFree($insert_data);
  1299. }
  1300. /**
  1301. * 用户充值
  1302. * @param $product
  1303. * @param $uid\
  1304. */
  1305. protected function userCharge($product, $uid)
  1306. {
  1307. $total = $product->price * 100 + $product->given;
  1308. UserService::addBalance($uid, $total, $product->price * 100, $product->given);
  1309. Log::info('update_user_balance_end:' . $uid . ' balance_add:' . $total);
  1310. }
  1311. /**
  1312. * 添加订单
  1313. * @param array $data
  1314. * @return mixed
  1315. */
  1316. protected function createOrder(array $data)
  1317. {
  1318. $insert_data = array();
  1319. $insert_data['uid'] = $data['uid'];
  1320. $insert_data['distribution_channel_id'] = $data['distribution_channel_id'];
  1321. $insert_data['product_id'] = $data['product_id'];
  1322. $insert_data['price'] = $data['price'];
  1323. $insert_data['status'] = 'PAID';
  1324. $insert_data['pay_type'] = 1;
  1325. $insert_data['trade_no'] = $data['trade_no'];
  1326. $insert_data['send_order_id'] = $data['send_order_id'];
  1327. $insert_data['order_type'] = $data['order_type'];
  1328. $insert_data['pay_merchant_source'] = $data['pay_merchant_source'];
  1329. $insert_data['pay_merchant_id'] = $data['pay_merchant_id'];
  1330. $insert_data['transaction_id'] = $data['transaction_id'];
  1331. $insert_data['pay_end_at'] = date('Y-m-d H:i:s');
  1332. $insert_data['create_ip'] = $data['create_ip'];
  1333. $insert_data['from_bid'] = $data['bid'];
  1334. Log::info('createOrder');
  1335. Log::info($insert_data);
  1336. return OrderService::save_order($insert_data);
  1337. }
  1338. /**
  1339. * 添加位置付订单
  1340. * @param $data
  1341. * @return mixed
  1342. */
  1343. protected function createUnPayOrder($data)
  1344. {
  1345. $data['status'] = 'UNPAID';
  1346. $data['transaction_id'] = '';
  1347. $data['pay_end_at'] = '0000-00-00 00:00:00';
  1348. return OrderService::save_order($data);
  1349. }
  1350. /**
  1351. * order total
  1352. * @param $data
  1353. *
  1354. */
  1355. protected function createOrderTotal($data)
  1356. {
  1357. $data['status'] = 'UNPAID';
  1358. $data['created_at'] = date('Y-m-d H:i:s');
  1359. $data['updated_at'] = date('Y-m-d H:i:s');
  1360. DB::table('orders_total')->insert($data);
  1361. }
  1362. protected function updateOrderTotal($trade_no, $transaction_id)
  1363. {
  1364. $data['status'] = 'PAID';
  1365. $data['transaction_id'] = $transaction_id;
  1366. $data['pay_end_at'] = date('Y-m-d H:i:s');
  1367. //DB::table('orders_total')->where('trade_no',$trade_no)->update($data);
  1368. }
  1369. protected function successPayPushMsg($uid, $product_info, $order_id)
  1370. {
  1371. try {
  1372. $force_sub_info = $this->getSubscribeV2($uid);
  1373. $data = UserService::getById($uid);
  1374. if (!in_array($data->distribution_channel_id, [5, 123])) {
  1375. //return false;
  1376. }
  1377. if ($force_sub_info) {
  1378. //$content_format = "您好,你已经成功充值\r\n\r\n会员:%s\r\n会员ID:%s\r\n充值金额:%s\r\n充值状态:充值成功\r\n如有疑问,请点击用户中心-联系客服\r\n\r\n><a href='%s'>点击继续阅读上次阅读</a>";
  1379. if (SubstituteOrderService::getByOrderId($order_id)) {
  1380. $content_format = "代充值客服消息:\r\n\r\n你好,您的好友为你代付成功\r\n会员:%s\r\n会员ID:%s\r\n代付金额:%s\r\n充值状态:充值成功\r\n如有疑问,请点击用户中心-联系客服\r\n赠送的礼物道具在阅读页-送礼物\r\n\r\n><a href='%s'>点击继续阅读上次阅读</a>";
  1381. } else {
  1382. $content_format = "您好,你已经成功充值\r\n\r\n会员:%s\r\n会员ID:%s\r\n充值金额:%s\r\n充值状态:充值成功\r\n如有疑问,请点击用户中心-联系客服\r\n赠送的礼物道具在阅读页-送礼物\r\n\r\n><a href='%s'>点击继续阅读上次阅读</a>";
  1383. }
  1384. if ($product_info->type == 'YEAR_ORDER') {
  1385. $money_text = $product_info->price . '元(尊贵的年费VIP会员)';
  1386. } elseif ($product_info->type == 'TICKET_RECHARGE') {
  1387. if ($product_info->given) {
  1388. $money_text = $product_info->price . '元(' . ($product_info->price * 100) . '书币+赠送' . $product_info->given . '书币)';
  1389. } else {
  1390. $money_text = $product_info->price . '元(' . ($product_info->price * 100) . '书币)';
  1391. }
  1392. } else {
  1393. $money_text = '未知';
  1394. }
  1395. $delay = 0;
  1396. $url = env('PROTOCOL') . '://site' . encodeDistributionChannelId($data->distribution_channel_id) . '.' . env('CUSTOM_HOST') . '.com/continue';;
  1397. $content = sprintf($content_format, $data->nickname ? $data->nickname : '匿名', $uid, $money_text, $url);
  1398. foreach ($force_sub_info as $item) {
  1399. $res['openid'] = $item->openid;
  1400. $res['appid'] = $item->appid;
  1401. $res['content'] = $content;
  1402. $res['type'] = 'one_task';
  1403. $res['send_time'] = date("Y-m-d H:i:s");
  1404. $res['task_id'] = md5('pay_success_push');
  1405. $send_data = array(
  1406. 'send_time' => date("Y-m-d H:i:s"),
  1407. 'data' => $res
  1408. );
  1409. dispatch((new SendTexts($send_data))->onConnection('rabbitmq')->delay($delay)->onQueue('send_texts_list'));
  1410. }
  1411. }
  1412. } catch (\Exception $e) {
  1413. Log::info('pay_success_push error');
  1414. Log::info($e);
  1415. }
  1416. return true;
  1417. }
  1418. private function orderStatistical($order)
  1419. {
  1420. try {
  1421. $send_data = array(
  1422. 'type' => 'order_info',
  1423. 'data' => $order->toArray()
  1424. );
  1425. $send = new SendStatisticsList($send_data);
  1426. $job = ($send)->onConnection('rabbitmq')->delay(0)->onQueue('send_statistics_list');
  1427. dispatch($job);
  1428. } catch (\Exception $e) {
  1429. Log::info($e);
  1430. }
  1431. //灵界的推送统计\App\Modules\Statistic\Services\WapVisitStatService::customerAllStats
  1432. try {
  1433. if ($order->from_type) {
  1434. $pv = Redis::hget('push:distribution_channel_id:allpv', $order->from_type);
  1435. if ($pv) {
  1436. Redis::sadd('push:all:paidnum:from:' . $order->from_type, $order->uid);
  1437. $old = Redis::hget('push:all:paidamount', $order->from_type);
  1438. if ($old) {
  1439. Redis::hset('push:all:paidamount', $order->from_type, $old + $order->price);
  1440. } else {
  1441. Redis::hset('push:all:paidamount', $order->from_type, $order->price);
  1442. }
  1443. }
  1444. }
  1445. if (isset($order->pay_merchant_id) && $order->pay_merchant_id)//临时统计队列清0 用于报警
  1446. {
  1447. $key = 'pay_merchant:' . $order->pay_merchant_id;
  1448. Redis::hset($key, 'unpaid_num', 0);
  1449. }
  1450. } catch (\Exception $e) {
  1451. }
  1452. }
  1453. private function getSubscribe($uid)
  1454. {
  1455. return ForceSubscribeService::forceSubscribeUsersByUid(['uid' => $uid]);
  1456. }
  1457. private function getSubscribeV2($uid)
  1458. {
  1459. return DB::table('force_subscribe_users')->where('uid', $uid)->where('is_subscribed', 1)->get();
  1460. }
  1461. public function getSubscribeOfficialName($uid, $distribution_channel_id)
  1462. {
  1463. $subscribe = $this->getSubscribe($uid);
  1464. if ($subscribe && isset($subscribe->appid)) {
  1465. $official = DB::table('official_accounts')->where('appid', $subscribe->appid)->select('nickname')->first();
  1466. if ($official && isset($official->nickname)) {
  1467. return $official->nickname;
  1468. }
  1469. }
  1470. $res = OfficialAccountService::canUseOfficialAccountByChannelId(compact('distribution_channel_id'));
  1471. if (isset($res->nickname) && !empty($res->nickname)) {
  1472. return $res->nickname;
  1473. }
  1474. try {
  1475. $official = DB::table('official_accounts')
  1476. ->where('distribution_channel_id', $distribution_channel_id)
  1477. ->where('is_auth', 1)
  1478. ->orderBy('id', 'desc')
  1479. ->select('nickname')->first();
  1480. if ($official && isset($official->nickname)) {
  1481. return $official->nickname;
  1482. }
  1483. } catch (\Exception $e) {
  1484. }
  1485. return '';
  1486. }
  1487. private function payAlert($pay_merchant_id, $trade_no = '', $pay_info = '', $n = 0)
  1488. {
  1489. $change_pay_id = 40;
  1490. if ($pay_merchant_id == 40) {
  1491. $change_pay_id = 9;
  1492. }
  1493. try {
  1494. $time = (int)date('G');
  1495. $change = false;
  1496. if ($time <= 8 || $time >= 23) {
  1497. if (!$pay_info && $pay_merchant_id != $change_pay_id) {
  1498. DB::table('distribution_channels')->where('pay_merchant_id', $pay_merchant_id)->update(['pay_merchant_id' => $change_pay_id]);
  1499. $change = true;
  1500. }
  1501. }
  1502. //$number,$template_type,$param=array()
  1503. $phone_arr = ['15868100210', '15088790066', '13858057394', '18668029091', '18668420256'];
  1504. //$phone_arr = ['18668029091'];
  1505. $param = ['pay_id' => $pay_merchant_id];
  1506. if ($n) {
  1507. $template_type = 'pay_channel_remind';
  1508. //$content = '支付通道:' . $pay_merchant_id . ',获取授权信息失败';
  1509. } else {
  1510. $template_type = 'pay_channel_remind';
  1511. //$content = '支付通道:' . $pay_merchant_id . ',订单号为' . $trade_no . '支付异常,异常信息:' . json_encode($pay_info);
  1512. }
  1513. if ($change) {
  1514. $template_type = 'pay_channel_change';
  1515. $param = ['pay_id' => $pay_merchant_id, 'new_pay_id' => $change_pay_id];
  1516. }
  1517. $last_alert_time = Redis::hget('autopayalert',$pay_merchant_id);
  1518. if($last_alert_time && (time() -$last_alert_time) <= 3600 ){
  1519. return ;
  1520. }
  1521. Redis::hset('autopayalert',$pay_merchant_id,time());
  1522. foreach ($phone_arr as $phone) {
  1523. AliSMS::send($phone, $template_type, $param);
  1524. }
  1525. } catch (\Exception $e) {
  1526. }
  1527. }
  1528. private function createSubstituteOrder($order_id, $uid, $pay_uid)
  1529. {
  1530. SubstituteOrderService::createOrder($order_id, $uid, $pay_uid);
  1531. }
  1532. private function recordOtherParam($order_id, $uid)
  1533. {
  1534. $gxhp = ReadRecordService::getByField($uid, 'gxhp');
  1535. if ($gxhp) {
  1536. OrderParamService::create($order_id, $gxhp);
  1537. }
  1538. }
  1539. private function substituteOrderPrice($order_id, $prize_fee = 500)
  1540. {
  1541. SubstituteOrderService::SubstituteOrderPrize($order_id, $prize_fee);
  1542. }
  1543. private function updateUserSendOrderId(int $uid, $send_order_id)
  1544. {
  1545. if ($send_order_id && $uid) {
  1546. $user = UserService::getById($uid);
  1547. if ($user && !$user->send_order_id) {
  1548. UserService::updateInfo($uid, compact('send_order_id'));
  1549. }
  1550. }
  1551. }
  1552. /**
  1553. * 测书智能推送统计 付费用户数、充值金额
  1554. * @param $bid
  1555. * @param $uid
  1556. * @param $price
  1557. */
  1558. private function smartPushTestBookPaidUv($bid, $uid, $price)
  1559. {
  1560. $smart_bid = ReadRecordService::getSmartPush($uid);
  1561. if ($smart_bid && in_array($bid, $smart_bid)) {
  1562. try {
  1563. $key = 'smartPushTestBookPaidUv:bid:%s';
  1564. Redis::sadd(sprintf($key, $bid), $uid);
  1565. $now_amount = Redis::hget('smartPushTestBookPaidAmount', $bid);
  1566. if (!$now_amount) {
  1567. $now_amount = 0;
  1568. }
  1569. Redis::hset('smartPushTestBookPaidAmount', $bid, $now_amount + $price);
  1570. } catch (\Exception $e) {
  1571. }
  1572. }
  1573. }
  1574. /**
  1575. * 获取用户第几次充值
  1576. * @param $uid
  1577. * @return int
  1578. */
  1579. private function getChargeTimes($uid)
  1580. {
  1581. $count = OrderService::getUserChargeTimes($uid);
  1582. return $count + 1;
  1583. }
  1584. //米玩 订单转移
  1585. private function transfer($distribution_channel_id)
  1586. {
  1587. if (in_array($distribution_channel_id, explode(',', redisEnv('MIWAN_TRANSFER_CHANNEL_ID', 1)))) {
  1588. $random = random_int(1, 100);
  1589. $miwan_transfer_probability = redisEnv('MIWAN_TRANSFER_PROBABILITY', 0);
  1590. $miwan_transfer_to_channel_id = redisEnv('MIWAN_TRANSFER_TO_CHANNEL_ID', 0);
  1591. if ($miwan_transfer_to_channel_id && $random <= $miwan_transfer_probability) {
  1592. return $miwan_transfer_to_channel_id;
  1593. }
  1594. }
  1595. return 0;
  1596. }
  1597. private function userProperty($uid,$price,$charge_type,$activity_id){
  1598. try{
  1599. $old_property = UserDivisionCpcPropertyService::getUserProperty($uid);
  1600. if(!$activity_id){
  1601. $this->chargeGiveGift($uid,$old_property,$price,$charge_type);
  1602. }
  1603. $userproperty = UserDivisionCpcPropertyService::getUserSubscribeAndChargeInfoByUid($uid);
  1604. if(!$userproperty) {
  1605. return ;
  1606. }
  1607. UserDivisionCpcPropertyService::createorUpdate($userproperty);
  1608. }catch (\Exception $e){}
  1609. }
  1610. private function huaweiActivity($activity_id,$uid,$product_id){
  1611. return ;
  1612. /*$huawei_activity_id = redisEnv('HUAWEI_ACTIVITY_ID');
  1613. if($huawei_activity_id && $activity_id && $activity_id == $huawei_activity_id){
  1614. $product_id_relate_lottery_count = ['6117'=>1,'6118'=>2,'6119'=>4,'6120'=>8];
  1615. if(isset($product_id_relate_lottery_count[$product_id])){
  1616. $info = DB::table('huaweilottery_user_counts')->where('uid',$uid)->select('count')->first();
  1617. if($info){
  1618. DB::table('huaweilottery_user_counts')->where('uid',$uid)->update([
  1619. 'uid'=>$uid,
  1620. 'count'=>$info->count+$product_id_relate_lottery_count[$product_id],
  1621. 'updated_at'=>date('Y-m-d H:i:s')
  1622. ]);
  1623. }else{
  1624. DB::table('huaweilottery_user_counts')->insert([
  1625. 'uid'=>$uid,
  1626. 'count'=>$product_id_relate_lottery_count[$product_id],
  1627. 'updated_at'=>date('Y-m-d H:i:s'),
  1628. 'created_at'=>date('Y-m-d H:i:s')
  1629. ]);
  1630. }
  1631. }
  1632. }*/
  1633. }
  1634. private function palmpaySpecial($transaction_id,$trade_no)
  1635. {
  1636. try{
  1637. $order = OrderService::getByTradeNo($trade_no);
  1638. $product_id = $order->product_id;
  1639. $product = ProductService::getProductSingle($product_id);
  1640. $init_order = [
  1641. 'distribution_channel_id' => $order->distribution_channel_id,
  1642. 'uid' => $order->uid,
  1643. 'product_id' => $product_id,
  1644. 'price' => $order->price,
  1645. 'pay_type' => 1,
  1646. 'trade_no' => $order->uid.'-'.$order->id,
  1647. 'pay_merchant_source' => $order->pay_merchant_source,
  1648. 'pay_merchant_id' => $order->pay_merchant_id,
  1649. 'create_ip' => $order->create_ip,
  1650. 'send_order_id' => $order->send_order_id,
  1651. 'send_order_name' => $order->send_order_name,
  1652. 'order_type' => $order->order_type,
  1653. 'from_bid' => $order->from_bid,
  1654. 'from_type' => $order->from_type,
  1655. 'activity_id' => $order->activity_id,
  1656. 'inner_send_order_id' => $order->inner_send_order_id,
  1657. 'status'=>'PAID',
  1658. 'transaction_id'=>$transaction_id,
  1659. 'pay_end_at'=>date('Y-m-d H:i:s')
  1660. ];
  1661. OrderService::save_order($init_order);
  1662. if ($product->type == 'YEAR_ORDER') {
  1663. Log::info('palmpaySpecial YEAR_ORDER');
  1664. $this->yearOrder($order->uid, $order->distribution_channel_id, $order->price, $order->send_order_id);
  1665. } elseif ($product->type == 'BOOK_ORDER') {
  1666. Log::info('palmpaySpecial BOOK_ORDER');
  1667. $this->bookOrder($product_id, $order->ui, $order->send_order_id, $order->price, $order->distribution_channel_id);
  1668. } elseif ($product->type == 'TICKET_RECHARGE' || $product->type == 'NEW_USER') {
  1669. Log::info('palmpaySpecial TICKET_RECHARGE');
  1670. $this->userCharge($product, $order->uid);
  1671. } elseif ($product->type == 'FOREVER') {
  1672. Log::info('palmpaySpecial-------FOREVER');
  1673. $this->foreverFreeOrder($order->uid, $order->distribution_channel_id, $order->price, $order->send_order_id);
  1674. }
  1675. }catch (\Exception $e){
  1676. Log::info($e);
  1677. }
  1678. }
  1679. private function chargeGiveGift($uid,$property,$price,$charge_type){
  1680. $gift = BookGiftsService::chargeGiveGift($property,$price,$charge_type);
  1681. if($gift){
  1682. UserGiftService::addGift($uid,$gift);
  1683. }
  1684. return ;
  1685. }
  1686. private function orderParamWso($uid,$order_id){
  1687. list($new_outer,$new_inner,$new_total) = ReadRecordService::getByMultiField($uid,'new_outer','new_inner','new_total');
  1688. if(!$new_outer && !$new_inner && !$new_total){
  1689. return ;
  1690. }
  1691. if(!$new_total) return ;
  1692. $new_outer = $new_outer?$new_outer:0;
  1693. $new_inner = $new_inner?$new_inner:0;
  1694. $total_type = '';
  1695. $total_param_id = 0;
  1696. if(is_numeric($new_total)){
  1697. $send_order_info = SendOrderService::getById($new_total);
  1698. $total_param_id = $new_total;
  1699. $total_type = 'none';
  1700. if($send_order_info && isset($send_order_info->promotion_type)){
  1701. if($send_order_info->promotion_type == 'EXTERNAL'){
  1702. $total_type = 'OUTER';
  1703. }
  1704. if($send_order_info->promotion_type == 'INTERNAL'){
  1705. $total_type = 'INNER';
  1706. }
  1707. }
  1708. }
  1709. if(str_contains($new_total,'custom')){
  1710. $total_type = 'CUSTOM';
  1711. $temp = explode('_',$new_total);
  1712. if(isset($temp[1]) && is_numeric($temp[1])){
  1713. $total_param_id = $temp[1];
  1714. }
  1715. }
  1716. if(str_contains($new_total,'template')){
  1717. $total_type = 'TEMPLATE';
  1718. $temp = explode('_',$new_total);
  1719. if(isset($temp[1]) && is_numeric($temp[1])){
  1720. $total_param_id = $temp[1];
  1721. }
  1722. }
  1723. if($total_type){
  1724. OrderParamWsoService::createOrder($order_id,
  1725. $new_inner,
  1726. $new_outer,
  1727. $total_param_id,
  1728. $new_total,
  1729. $total_type);
  1730. }
  1731. }
  1732. private function exchangeUpdateAndCreated($order_id){
  1733. /*try{
  1734. $info = DB::table('orders')->where('id',$order_id)->select('created_at','updated_at')->first();
  1735. DB::table('orders')->where('id',$order_id)
  1736. ->update([
  1737. 'created_at'=>$info->updated_at,
  1738. 'updated_at'=>$info->created_at
  1739. ]);
  1740. }catch (\Exception $e){}*/
  1741. }
  1742. }