OrderPayDataForm.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800
  1. <?php
  2. /**
  3. * 重庆赤晓店信息科技有限公司
  4. * https://www.chixiaodian.com
  5. * Copyright (c) 2023 赤店商城 All rights reserved.
  6. */
  7. namespace app\modules\client\models\v1\pt\order;
  8. use app\jobs\CancelPtOrderJob;
  9. use app\jobs\CreatedPtOrderJob;
  10. use app\models\AccountLog;
  11. use app\models\Goods;
  12. use app\models\GoodsBook;
  13. use app\models\Order;
  14. use app\models\OrderDetail;
  15. use app\models\PtActivity;
  16. use app\models\PtActivityGoods;
  17. use app\models\PtActivityOrder;
  18. use app\models\PtActivityOrderDetail;
  19. use app\models\User;
  20. use app\models\VerifyCardLog;
  21. use app\models\VerifyCardSale;
  22. use app\modules\admin\models\pt\PtActivityOrderForm;
  23. use app\modules\client\models\OrderComplete;
  24. use app\modules\client\models\v1\LoginForm;
  25. use app\modules\client\models\v1\ShareMoneyForm;
  26. use app\modules\common\models\NotifyForm;
  27. use app\utils\Alipay\Alipay;
  28. use app\utils\Alipay\AlipayProfit;
  29. use app\utils\CloudPrint;
  30. use app\utils\OrderNo;
  31. use app\utils\Wechat\WechatNewPay;
  32. use app\utils\Wechat\WechatPay;
  33. use app\utils\yunst\src\OrderYunst;
  34. use ByteDance\ByteDance;
  35. use yii\base\Model;
  36. use yii\helpers\Json;
  37. use app\utils\Delivery\Delivery;
  38. use app\models\Store;
  39. /**
  40. * @property User $user
  41. * @property Order $order
  42. */
  43. class OrderPayDataForm extends Model
  44. {
  45. public $store_id;
  46. public $order_id;
  47. public $order_id_list;
  48. public $pay_type;
  49. public $user;
  50. public $form_id;
  51. public $parent_user_id;
  52. public $condition;
  53. public $_from;
  54. public $is_combine;
  55. /** @var Wechat $wechat */
  56. private $wechat;
  57. private $wechatPay;
  58. private $order;
  59. const PAY_FROM_APP = 'app';
  60. const PAY_FROM_MINI = 'mini';
  61. const PAY_FROM_H5 = 'h5';
  62. const PAY_FROM_OFFICIAL = 'official';
  63. const PAY_FROM_YUNST = 'yunst';
  64. public function rules()
  65. {
  66. return [
  67. [['pay_type', '_from'], 'required'],
  68. [['_from'], 'in', 'range' => ['app', 'mini', 'h5', 'official']],
  69. [['pay_type'], 'in', 'range' => [-1, 1, 2, 3, 4, 5, Order::PAY_TYPE_YUNST_WECHAT_PAY]], // 'WECHAT_PAY', 'HUODAO_PAY', 'BALANCE_PAY' 'ALIPAY',
  70. [['form_id', 'order_id_list', '_from'], 'string'],
  71. ['is_combine', 'default', 'value' => 0],
  72. [['parent_user_id', 'condition', 'order_id', 'is_combine'], 'integer'],
  73. ];
  74. }
  75. public function search()
  76. {
  77. $this->wechatPay = \Yii::$app->controller->wechatPay;
  78. if (!$this->validate()) {
  79. return [
  80. 'code' => 1,
  81. 'msg' => $this->getErrorSummary(false)[0],
  82. ];
  83. }
  84. $this->user->money = doubleval($this->user->money);
  85. if ($this->order_id_list) {
  86. $order_id_list = json_decode($this->order_id_list, true);
  87. if (is_array($order_id_list) && count($order_id_list) == 1) {
  88. $this->order_id = $order_id_list[0];
  89. $this->order_id_list = '';
  90. }
  91. }
  92. $t = \Yii::$app->db->beginTransaction();
  93. if ($this->order_id) { //单个订单付款
  94. //检测活动是否存在
  95. $this->order = PtActivityOrder::findOne([
  96. 'store_id' => $this->store_id,
  97. 'id' => $this->order_id,
  98. ]);
  99. $pt_activity = PtActivityOrderDetail::find()->alias('pod')->where(['pod.order_id' => $this->order_id])
  100. ->leftJoin(['pa' => PtActivity::tableName()], 'pod.activity_id = pa.id')
  101. ->select('pa.start_time, pa.end_time, pa.id, pa.party_size, pa.party_type, pa.party_goods_count, pa.split_time, pa.join_num, pod.goods_id')->asArray()->one();
  102. if (empty($pt_activity)) {
  103. return [
  104. 'code' => 1,
  105. 'msg' => "拼团活动不存在",
  106. ];
  107. }
  108. $join_num = $pt_activity['join_num'];
  109. $s_today_time = strtotime(date('Y-m-d'));
  110. $e_today_time = (strtotime(date('Y-m-d')) + 3600 * 24);
  111. $join_count = PtActivityOrderDetail::find()->alias('od')
  112. ->leftJoin(['o' => PtActivityOrder::tableName()], 'od.order_id = o.id')
  113. ->where(['od.goods_id' => $pt_activity['goods_id'], 'o.user_id' => get_user_id(), 'is_pay' => 1])
  114. ->andWhere(['AND', ['>', 'od.created_at', $s_today_time], ['<', 'od.created_at', $e_today_time]])->select('od.id')->count();
  115. if($pt_activity->party_type == 0){
  116. if ($join_num > 0 && $join_count >= $join_num) {
  117. return [
  118. 'code' => 1,
  119. 'msg' => "今日参加此商品的拼团次数已达上限"
  120. ];
  121. }
  122. }
  123. if ($pt_activity['end_time'] < time() || $pt_activity['start_time'] > time()) {
  124. return [
  125. 'code' => 1,
  126. 'msg' => "当前时间不在拼团活动时间范围内",
  127. ];
  128. }
  129. if (!empty($this->order->pt_number)) {
  130. $pt_order = PtActivityOrder::findOne(['id' => $this->order->pt_number]);
  131. if ($pt_order) {
  132. if ((int)$pt_order->is_pay === 0) {
  133. return [
  134. 'code' => 1,
  135. 'msg' => "当前团暂未开放"
  136. ];
  137. }
  138. //error
  139. $check_pt_order = PtActivityOrder::find()->where(['trade_status' => 0, 'is_pay' => 1])
  140. ->andWhere(['OR', ['id' => $this->order->pt_number], ['pt_number' => $this->order->pt_number]])
  141. ->select('id, is_winner')->asArray()->all();
  142. //判断是否到解散时间
  143. $end_time = (($pt_activity['split_time'] * 60 * 60) + ($pt_order->pay_time));
  144. if ($end_time <= time()) {
  145. return [
  146. 'code' => 1,
  147. 'msg' => "当前团已解散"
  148. ];
  149. }
  150. //判断是否开奖
  151. $open = false;
  152. foreach ($check_pt_order as $item) {
  153. if ((int)$item['is_winner'] > 0) {
  154. $open = true;
  155. }
  156. if ((int)$item['user_id'] === get_user_id()) {
  157. return [
  158. 'code' => 1,
  159. 'msg' => "已加入,不可重复操作"
  160. ];
  161. }
  162. }
  163. if ($open) {
  164. return [
  165. 'code' => 1,
  166. 'msg' => "当前团已开奖"
  167. ];
  168. }
  169. if($pt_activity['party_type'] == 0){
  170. if ($pt_activity['party_size'] <= count($check_pt_order)) {
  171. return [
  172. 'code' => 1,
  173. 'msg' => "当前团人数已达上限"
  174. ];
  175. }
  176. }
  177. if($pt_activity['party_type'] == 1){
  178. $goodsCountQuery = PtActivityOrderDetail::find()->alias('pod')
  179. ->leftJoin(['po' => PtActivityOrder::tableName()], 'pod.order_id = po.id')
  180. ->where(['po.is_pay' => 1, 'pod.is_delete' => 0])
  181. ->andWhere(['OR' , ['po.id' => $this->order->pt_number], ['po.pt_number' => $this->order->pt_number]]);
  182. $goodsCount = $goodsCountQuery->sum('pod.num');
  183. if($pt_activity['party_goods_count'] <= (int)$goodsCount){
  184. return [
  185. 'code' => 1,
  186. 'msg' => "当前团商品数量已达上限"
  187. ];
  188. }
  189. }
  190. }
  191. } else {
  192. if ($this->order->head_integral > 0) {
  193. if ($this->order->head_integral > get_user()->integral) {
  194. return [
  195. 'code' => 1,
  196. 'msg' => '开团积分不足'
  197. ];
  198. }
  199. }
  200. }
  201. // 供应链系统下单时是否使用平台商户号,1使用,0未使用
  202. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming($this->order->store_id)) {
  203. $this->order->is_use_platform_mch = 1;
  204. $this->order->save();
  205. }
  206. if ($this->order->pay_price == 0) {
  207. // 这里要判断订单之前是不是货到付款的订单 如果是货到付款的订单
  208. $this->order->pay_time = time();
  209. $this->order->is_pay = 1;
  210. $this->order->pay_type = 3;
  211. $this->order->trade_status = Order::ORDER_FLOW_NO_SEND;
  212. $this->order->save();
  213. $t->commit();
  214. //TODO 拼团成功后需要走注释部分
  215. // 支付完成后,相关操作
  216. // (new NotifyForm())->videoGoodsShare($this->order);
  217. // $form = new OrderComplete();
  218. // $form->order_id = $this->order->id;
  219. // $form->order_type = 0;
  220. // $form->store_id = get_store_id();
  221. // $form->notify();
  222. return [
  223. 'code' => 0,
  224. 'msg' => '支付成功'
  225. ];
  226. }
  227. if (!$this->order) {
  228. $t->rollBack();
  229. return [
  230. 'code' => 1,
  231. 'msg' => '订单不存在',
  232. ];
  233. }
  234. if ($this->order->is_delete == 1 || $this->order->trade_status == Order::ORDER_FLOW_CANCEL) {
  235. $t->rollBack();
  236. return [
  237. 'code' => 1,
  238. 'msg' => '订单已取消',
  239. ];
  240. }
  241. if ($this->order->is_pay == 1 || ($this->order->trade_status > -1 && $this->order->pay_type != 2)) {
  242. $t->rollBack();
  243. return [
  244. 'code' => 1,
  245. 'msg' => '订单状态异常',
  246. ];
  247. }
  248. // try {
  249. // $this->checkGoodsConfine($this->order);
  250. // } catch (\Exception $e) {
  251. // $t->rollBack();
  252. // return [
  253. // 'code' => 1,
  254. // 'msg' => $e->getMessage()
  255. // ];
  256. // }
  257. // 存储parent_id
  258. // if ($this->user && $this->user->parent_user_id) {
  259. // CommonOrder::saveParentId($this->user->parent_user_id);
  260. // }
  261. $goods_names = '';
  262. $goods_list = PtActivityOrderDetail::find()->alias('od')->leftJoin(['g' => Goods::tableName()],
  263. 'g.id=od.goods_id')->where(['od.order_id' => $this->order->id, 'od.is_delete' => 0,
  264. ])->select('g.name')->asArray()->all();
  265. foreach ($goods_list as $goods) {
  266. $goods_names .= $goods['name'] . ';';
  267. }
  268. $goods_names = mb_substr($goods_names, 0, 32, 'utf-8');
  269. //TODO 拼团成功后需要走注释部分
  270. // $this->setReturnData($this->order);
  271. if (!$this->order->save()) {
  272. $t->rollBack();
  273. return [
  274. 'code' => 1,
  275. 'msg' => '订单保存失败'
  276. ];
  277. }
  278. if ($this->pay_type == 2) {
  279. $this->is_combine = Order::NOT_COMBINE_PAY;
  280. }
  281. // 余额抵扣支付
  282. $balance_price = 0;
  283. if ($this->is_combine) {
  284. if ($this->user->money >= $this->order->pay_price) {
  285. $this->pay_type = 3;
  286. } else {
  287. $balance_price = $this->user->money;
  288. $this->order->combine_money = $this->user->money;
  289. $this->order->is_combine_pay = Order::IS_COMBINE_PAY;
  290. $this->order->save();
  291. }
  292. if ($this->pay_type == -1) {
  293. $this->pay_type = 3;
  294. }
  295. } else {
  296. $this->order->combine_money = 0;
  297. $this->order->is_combine_pay = Order::NOT_COMBINE_PAY;
  298. $this->order->save();
  299. }
  300. if ($this->pay_type == 1 || $this->pay_type == 4 || $this->pay_type == 5 || $this->pay_type == Order::PAY_TYPE_YUNST_WECHAT_PAY) {
  301. if ($this->order->pay_price == 0) {
  302. $this->order->is_pay = 1;
  303. $this->order->pay_type = 1;
  304. if ($this->pay_type == 4) {
  305. $this->order->pay_type = 4;
  306. }
  307. $this->order->pay_time = time();
  308. if (!$this->order->save()) {
  309. $t->rollBack();
  310. return [
  311. 'code' => 1,
  312. 'msg' => '支付失败'
  313. ];
  314. }
  315. // 支付完成后,相关操作
  316. // (new NotifyForm())->videoGoodsShare($this->order);
  317. // $form = new OrderComplete();
  318. // $form->order_id = $this->order->id;
  319. // $form->order_type = 0;
  320. // $form->store_id = get_store_id();
  321. // $form->notify();
  322. $t->commit();
  323. return [
  324. 'code' => 0,
  325. 'msg' => '0元支付'
  326. ];
  327. }
  328. if ($this->pay_type == 1) {
  329. // \Yii::error($this->_from);
  330. if ($this->_from == self::PAY_FROM_APP) {
  331. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  332. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, true, $balance_price);
  333. } else {
  334. if (is_profit_pay()) {
  335. $result = WechatNewPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, true, $balance_price);
  336. } else {
  337. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, true, $balance_price);
  338. }
  339. }
  340. } else if ($this->_from == self::PAY_FROM_H5) {
  341. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  342. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, true);
  343. } else {
  344. if (is_profit_pay()) {
  345. $result = WechatNewPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, true);
  346. } else {
  347. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, true);
  348. }
  349. }
  350. } else if ($this->_from == self::PAY_FROM_OFFICIAL) {
  351. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  352. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, false, true);
  353. } else {
  354. if (is_profit_pay()) {
  355. $result = WechatNewPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, false, true);
  356. } else {
  357. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price, false, true);
  358. }
  359. }
  360. } else {
  361. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  362. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price);
  363. } else {
  364. if (is_profit_pay()) {
  365. $result = WechatNewPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price);
  366. } else {
  367. $result = WechatPay::orderUnify($this->order, OrderNo::ORDER_PT, $goods_names, 0, false, $balance_price);
  368. }
  369. }
  370. }
  371. if (isset($result['code']) && $result['code'] == 1) {
  372. if ($this->_from == self::PAY_FROM_OFFICIAL) {
  373. $result['wechat_platform_open_id'] = get_user()->wechat_platform_open_id;
  374. $result['h5_auth_link'] = LoginForm::getAuthLink();
  375. }
  376. return $result;
  377. }
  378. CloudPrint::doPrint($this->order->id, 0, $this->order->store_id);
  379. $t->commit();
  380. return [
  381. 'code' => 0,
  382. 'msg' => 'success',
  383. 'data' => (object)$result['data'],
  384. 'res' => $result['res'],
  385. 'body' => $goods_names
  386. ];
  387. }
  388. if ($this->pay_type == Order::PAY_TYPE_YUNST_WECHAT_PAY) {
  389. // if (!Store::hasIncoming($this->order->store_id, 'yunst')) {
  390. // return [
  391. // 'code' => 1,
  392. // 'msg' => '商家未配置通联支付'
  393. // ];
  394. // }
  395. //是非独立部署 进件流程//通联支付 start
  396. $store = Store::findOne(['id' => $this->order->store_id]);
  397. $OrderYunst = new OrderYunst();
  398. $result2 = $OrderYunst->payYunst($this->order->store_id, $this->order->order_no, $store->cusid, $this->order->pay_price * 100);
  399. if ($result2['subCode'] == 'SUCCESS') {
  400. $payInfo = json_decode($result2['data']['payinfo'], true);
  401. if (!empty($payInfo)) {
  402. if (is_array($payInfo)) {
  403. return [
  404. 'code' => 0,
  405. 'data' => $payInfo,
  406. 'msg' => 'success',
  407. 'res' => $payInfo
  408. ];
  409. }
  410. return [
  411. 'code' => 1,
  412. 'msg' => $result2['data']['errmsg']
  413. ];
  414. }
  415. return [
  416. 'code' => 1,
  417. 'msg' => $result2['subMsg']
  418. ];
  419. }
  420. return $result2;
  421. //通联支付 end
  422. }
  423. if ($this->pay_type == 4) {
  424. if ($this->_from == self::PAY_FROM_MINI) {
  425. if (\Yii::$app->prod_is_dandianpu() && !Store::hasIncoming(get_store_id()) && self_mini() === false) {
  426. $result = Alipay::mini($this->order, $goods_names, $this->user, '', '', 0, $balance_price);
  427. } else {
  428. if (is_profit_pay('ali')) {
  429. $result = AlipayProfit::mini($this->order, $goods_names, $this->user, '', '', false, 0, $balance_price);
  430. } else {
  431. $result = Alipay::mini($this->order, $goods_names, $this->user, '', '', 0, $balance_price);
  432. }
  433. }
  434. if (isset($result['code']) && $result['code'] == 1) {
  435. return $result;
  436. }
  437. $t->commit();
  438. return [
  439. 'code' => 0,
  440. 'msg' => 'success',
  441. 'data' => $result['data']['trade_no'],
  442. 'body' => $goods_names
  443. ];
  444. } else {
  445. if (is_profit_pay('ali')) {
  446. $result = AlipayProfit::app($this->order, $goods_names, $this->user, $balance_price);
  447. } else {
  448. $result = Alipay::app($this->order, $goods_names, $this->user, $balance_price);
  449. }
  450. if (isset($result['code']) && $result['code'] == 1) {
  451. $t->commit();
  452. return $result;
  453. }
  454. $t->commit();
  455. return [
  456. 'code' => 0,
  457. 'msg' => 'success',
  458. 'data' => $result['data'],
  459. 'body' => $goods_names
  460. ];
  461. }
  462. }
  463. // 抖音小程序
  464. if ($this->pay_type == 5) {
  465. $result = ByteDance::pay($this->order, '', $goods_names, 0, $balance_price);
  466. if (isset($result['code']) && $result['code'] == 1) {
  467. return $result;
  468. }
  469. $t->commit();
  470. return [
  471. 'code' => 0,
  472. 'msg' => 'success',
  473. 'data' => $result['data'],
  474. ];
  475. }
  476. }
  477. //货到付款和余额支付数据处理
  478. debug_log('拼团处理:'. 21111,'ptOrderLog.log');
  479. if ($this->pay_type == 2 || $this->pay_type == 3) {
  480. $order = $this->order;
  481. // 中间页选择货到付款,需要存入支付类型
  482. if ($this->pay_type == 2) {
  483. $order->is_pay = 0;
  484. $order->pay_type = 2;
  485. $order->save();
  486. }
  487. //余额支付 用户余额变动
  488. if ($this->pay_type == 3) {
  489. $user = User::findOne(['id' => $order->user_id]);
  490. if ($user->money < $order->pay_price) {
  491. $t->rollBack();
  492. return [
  493. 'code' => 1,
  494. 'msg' => '支付失败,余额不足',
  495. ];
  496. }
  497. if ($order->head_integral > 0) {
  498. $res = AccountLog::saveLog($user->id, floatval($order->head_integral), AccountLog::TYPE_INTEGRAL, AccountLog::LOG_TYPE_EXPEND, 3, $order->id, "商城拼团开团支付积分,订单号为:{$order->order_no}。");
  499. if (!$res) {
  500. $t->rollBack();
  501. return [
  502. 'code' => 1,
  503. 'msg' => '支付失败'
  504. ];
  505. }
  506. $order->head_integral_status = 1;
  507. $order->save();
  508. }
  509. // $user->money -= floatval($order->pay_price);
  510. $res = AccountLog::saveLog($user->id, floatval($order->pay_price), AccountLog::TYPE_BALANCE, AccountLog::LOG_TYPE_EXPEND, 3, $order->id, "商城余额支付,订单号为:{$order->order_no}。");
  511. if (!$res) {
  512. $t->rollBack();
  513. return [
  514. 'code' => 1,
  515. 'msg' => '支付失败'
  516. ];
  517. }
  518. $order->is_pay = 1;
  519. $order->pay_type = 3;
  520. $order->trade_status = Order::ORDER_FLOW_NO_SEND;
  521. $order->pay_time = time();
  522. if ($order->user_id != get_user_id()) {
  523. $order->pay_user_id = get_user_id();
  524. }
  525. if (!$order->save()) {
  526. $t->rollBack();
  527. return [
  528. 'code' => 1,
  529. 'msg' => '支付失败'
  530. ];
  531. }
  532. $pt_number = $order->pt_number ?: $order->id;
  533. //判断是团长开团
  534. $is_first_order = false;
  535. if ($pt_number === $order->id) {
  536. $is_first_order = true;
  537. }
  538. debug_log('拼团处理:'. 11111,'ptOrderLog.log');
  539. $order->pt_number && $order = PtActivityOrder::findOne($order->pt_number);
  540. $order_detail = PtActivityOrderDetail::find()->where(['order_id' => $pt_number])->select('goods_id, activity_id')->asArray()->one();
  541. if (!empty($order) && !empty($order_detail)) {
  542. $pt_activity_goods = PtActivityGoods::findOne([
  543. 'activity_id' => $order_detail['activity_id'],
  544. 'goods_id' => $order_detail['goods_id'],
  545. 'is_delete' => 0
  546. ]);
  547. if ($pt_activity_goods) {
  548. $pt_activity = PtActivity::findOne(['id' => $pt_activity_goods->activity_id, 'is_delete' => 0]);
  549. if ($pt_activity) {
  550. $pt_order = PtActivityOrder::find()->where(['trade_status' => 0, 'is_pay' => 1])
  551. ->andWhere(['OR', ['id' => $pt_number], ['pt_number' => $pt_number]])->select('id')->column();
  552. if($pt_activity->party_type == 0){
  553. if ($pt_activity->party_size <= count($pt_order)) {
  554. queue_push(new CreatedPtOrderJob(['order_id' => ($pt_number ?: $order->id)]));
  555. }
  556. }
  557. if($pt_activity->party_type == 1){
  558. $goodsCountQuery = PtActivityOrderDetail::find()->alias('pod')
  559. ->leftJoin(['po' => PtActivityOrder::tableName()], 'pod.order_id = po.id')
  560. ->where(['po.is_pay' => 1, 'pod.is_delete' => 0])
  561. ->andWhere(['OR' , ['po.id' => $pt_number], ['po.pt_number' => $pt_number]]);
  562. $goodsCount = $goodsCountQuery->sum('pod.num');
  563. if($pt_activity->party_goods_count <= (int)$goodsCount){
  564. queue_push(new CreatedPtOrderJob(['order_id' => ($pt_number ?: $order->id)]));
  565. }
  566. }
  567. //判断是团长开团
  568. if ($is_first_order) {
  569. $delay = $pt_activity->split_time * 60 * 60;
  570. queue_push(new CancelPtOrderJob(['order_id' => $order->id, 'store_id' => $order->store_id]), $delay);
  571. }
  572. }
  573. }
  574. }
  575. }
  576. // 支付完成后,相关操作
  577. // (new NotifyForm())->videoGoodsShare($order);
  578. //TODO 拼团成功后需要走注释部分
  579. // $form = new OrderComplete();
  580. // $form->order_id = $order->id;
  581. // $form->order_type = 0;
  582. // $form->store_id = get_store_id();
  583. // $form->notify();
  584. CloudPrint::doPrint($this->order->id, 0, $this->order->store_id);
  585. $t->commit();
  586. return [
  587. 'code' => 0,
  588. 'msg' => '支付成功',
  589. 'data' => ''
  590. ];
  591. }
  592. }
  593. }
  594. /**
  595. * 设置佣金
  596. * @param Order $order
  597. * @return mixed
  598. */
  599. private function setReturnData($order)
  600. {
  601. $form = new ShareMoneyForm();
  602. $form->order = $order;
  603. $form->order_type = 0;
  604. return $form->setData();
  605. }
  606. /**
  607. * @param Order $PtActivityOrder
  608. * @throws \Exception
  609. * 检查限购
  610. */
  611. private function checkGoodsConfine($order)
  612. {
  613. foreach ($order->detail as $detail) {
  614. /* @var Goods $goods*/
  615. /* @var OrderDetail $detail*/
  616. $goods = $detail->goods;
  617. if ($goods->confine_count && $goods->confine_count > 0) {
  618. $goodsNum = Goods::getBuyNum($this->user, $goods->id);
  619. if ($goodsNum) {
  620. } else {
  621. $goodsNum = 0;
  622. }
  623. $goodsTotalNum = intval($goodsNum + $detail->num);
  624. if ($goodsTotalNum > $goods->confine_count) {
  625. throw new \Exception('商品:' . $goods->name . ' 超出购买数量', 1);
  626. }
  627. }
  628. //起订数量
  629. if (($goods['order_min_count'] && $goods['order_min_count'] > 0)) {
  630. if ($detail->num < $goods['order_min_count']) {
  631. throw new \Exception('商品:' . $goods->name . ' 起订数量' . $goods['order_min_count'], 1);
  632. }
  633. }
  634. }
  635. }
  636. /**
  637. * @param Goods $goods
  638. * @param OrderDetail $detail
  639. * @param Order $order
  640. */
  641. private function bookCheckGoodsNum($goods, $detail, $order) {
  642. // 判断时间
  643. if (time() - $order->created_at > 15 * 60) {
  644. return [
  645. 'code' => 1,
  646. 'msg' => '订单已过支付时间,将自动取消'
  647. ];
  648. }
  649. $attr = Json::decode($detail->attr);
  650. // 酒店预约
  651. if ($order->order_type == 1) {
  652. // $date_book = GoodsBook::findOne(['goods_id' => $goods->id])->date_book;
  653. // $date_book = Json::decode($date_book);
  654. // if (!$date_book) {
  655. // return [
  656. // 'code' => 1,
  657. // 'msg' => '数据异常'
  658. // ];
  659. // }
  660. // $data_config = array_combine(array_column($date_book, 'date'), array_column($date_book, 'num'));
  661. // foreach ($attr as $value) {
  662. // if (isset($data_config[$value['date']])) {
  663. // if ($data_config[$value['date']] < $detail->num) {
  664. // return [
  665. // 'code' => 1,
  666. // 'msg' => '选中日期' . $value['date'] . '内暂无房源'
  667. // ];
  668. // }
  669. // } else {
  670. // return [
  671. // 'code' => 1,
  672. // 'msg' => '未找到预约时间下相关商品数据'
  673. // ];
  674. // }
  675. // }
  676. }
  677. // 服务预约
  678. if ($order->order_type == 2) {
  679. $service_book = GoodsBook::findOne(['goods_id' => $goods->id])->service_book;
  680. $service_book = Json::decode($service_book);
  681. if (!$service_book) {
  682. return [
  683. 'code' => 1,
  684. 'msg' => '数据异常'
  685. ];
  686. }
  687. $date_data = $this->getDateByInterval(7);
  688. $count = 0;
  689. $new_arr = [
  690. 'data' => []
  691. ];
  692. $order = Order::find()->alias('o')
  693. ->leftJoin(['od' => OrderDetail::tableName()], 'o.id = od.order_id')
  694. ->where(['o.trade_status' => [0, 2, 3], 'o.is_delete' => 0, 'o.order_type' => 2, 'goods_id' => $goods['id']])
  695. ->andWhere(['>', 'o.created_at', strtotime(date("Y-m-d"))])
  696. ->select('od.attr, od.num')->asArray()->all();
  697. foreach ($date_data as $index => $datum) {
  698. $new_arr['data'][$index]['date'] = $datum;
  699. $new_arr['data'][$index]['time'] = $service_book['data'][0]['time'];
  700. }
  701. if (!$new_arr) {
  702. return [
  703. 'code' => 1,
  704. 'msg' => '数据异常'
  705. ];
  706. }
  707. $service_book = $new_arr['data'];
  708. $service_book_date = array_column($service_book, NULL, 'date');
  709. $service_book_time = $service_book_date[$attr['date']]['time'];
  710. $num = 0;
  711. $is = false;
  712. foreach ($order as $item) {
  713. $item['attr'] = json_decode($item['attr'], true);
  714. if ($item['attr']['date'] === $attr['date']) {
  715. if ($attr['time'] == $item['attr']['time']) {
  716. $num += $item['num'];
  717. }
  718. }
  719. }
  720. foreach ($service_book_time as $m) {
  721. foreach ($m['times'] as $n) {
  722. $is = true;
  723. if ($n['time'] == $attr['time']) {
  724. if (($detail->num + $num) > $n['num']) {
  725. return [
  726. 'code' => 1,
  727. 'msg' => $n['time'] . '时间段内暂不可预约'
  728. ];
  729. }
  730. }
  731. }
  732. }
  733. if ($is === false) {
  734. return [
  735. 'code' => 1,
  736. 'msg' => '未找到预约时间下相关商品数据'
  737. ];
  738. }
  739. }
  740. return [
  741. 'code' => 0,
  742. 'msg' => 'success'
  743. ];
  744. }
  745. public function getDateByInterval(int $num) :array
  746. {
  747. //var_dump($st, $et);die;
  748. $returnData = [];
  749. $i = 0;
  750. do {
  751. $temp = date('Y-m-d', strtotime('+' . $i . ' day', strtotime(date('Y-m-d'))));
  752. $returnData[] = $temp;
  753. $i++;
  754. } while ($i < $num);
  755. return $returnData;
  756. }
  757. }