OrderComplete.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379
  1. <?php
  2. /**
  3. * 重庆赤晓店信息科技有限公司
  4. * https://www.chixiaodian.com
  5. * Copyright (c) 2023 赤店商城 All rights reserved.
  6. */
  7. namespace app\plugins\scanCodePay\models;
  8. use app\constants\OptionSetting;
  9. use app\models\common\events\OrderEvent;
  10. use app\models\AccountLog;
  11. use app\models\CardSend;
  12. use app\models\common\Bind;
  13. use app\models\common\ShareMoney;
  14. use app\models\CouponPaySend;
  15. use app\models\Goods;
  16. use app\models\Option;
  17. use app\models\OrderMessage;
  18. use app\models\Share;
  19. use app\models\Shop;
  20. use app\models\ShopShare;
  21. use app\models\User;
  22. use app\models\VerifyCard;
  23. use app\models\VerifyCardLog;
  24. use app\models\VerifyCardSale;
  25. use app\modules\client\models\v1\ShareMoneyForm;
  26. use app\utils\Notice\NoticeSend;
  27. use app\utils\PrintOrder;
  28. use yii\base\BaseObject;
  29. use yii\base\Model;
  30. use yii\helpers\Json;
  31. class OrderComplete extends Model
  32. {
  33. public $order;
  34. public $store_id = 1;
  35. public $order_id;
  36. public $order_type;
  37. public $form_id;
  38. public $order_refund_no;
  39. const EVENT_ORDER_FOLLOW = 'order_follow_up';
  40. const EVENT_ORDER_REFUND = 'order_refund';
  41. // 支付完成之后,相关的操作
  42. public function notify(OrderEvent $event = null)
  43. {
  44. $this->store_id = $event ? $event->store_id : $this->store_id;
  45. $this->order_id = $event ? $event->order_id : $this->order_id;
  46. $this->order_type = $event ? $event->order_type : $this->order_type;
  47. try {
  48. $this->OrderNotify($event);
  49. $is_print = 1;
  50. $order = $this->order;
  51. $this->shareShop($order, $event);
  52. //发放核销卡
  53. $this->sendVerifyCard($order->id, $order->user_id, $this->order_type);
  54. // 后台订单提醒
  55. OrderMessage::set($order->id, $order->store_id, $this->order_type, 0);
  56. // 订单打印
  57. if ($is_print == 1) {
  58. // 订单打印
  59. if ((int)$order->md_id === -1 || (int)$order->md_id === 0 || !isset($order->md_id)) {
  60. $order->md_id = 0;
  61. }
  62. $printer_order = new PrintOrder($order->store_id, $order->id, 'pay', $this->order_type,
  63. $order->md_id, 0, $order['mch_id']);
  64. $res = $printer_order->print_order();
  65. }
  66. } catch (\Exception $e) {
  67. \Yii::error('line->>>' . $e->getLine());
  68. \Yii::error($e->getMessage());
  69. \Yii::error('订单支付完成后操作异常');
  70. }
  71. }
  72. /**
  73. * 发放核销卡
  74. */
  75. private function sendVerifyCard($order_id, $user_id, $order_type) {
  76. $goods_id = OrderDetail::find()->select('goods_id')->where(['order_id' => $order_id,'is_delete' => 0])->asArray()->all();
  77. foreach ($goods_id as $k => $v) {
  78. $verify_card_info = Goods::find()->select('id, verify_card_id')->where(['id' => $v['goods_id'], 'is_delete' => 0])->asArray()->one();
  79. $this->startSendVerifyCard($verify_card_info['verify_card_id'],$verify_card_info['id'],$user_id,$order_type);
  80. }
  81. }
  82. /**
  83. * 核销卡发放
  84. */
  85. private function startSendVerifyCard($verify_card_id, $goods_id, $user_id, $order_type){
  86. if(!empty($verify_card_id)){
  87. $verify_card_id_arr = explode(',', $verify_card_id);
  88. foreach($verify_card_id_arr as $value){
  89. $verify_form = new VerifyCardSale();
  90. $verify_form->store_id = $this->store_id;
  91. $verify_form->user_id = $user_id;
  92. $verify_form->verify_card_id = $value;
  93. //查询核销卡使用总次数
  94. $left_info = VerifyCard::find()->select('total_num,expire_day, type')->where([
  95. 'id' => $value,
  96. 'is_delete' => 0
  97. ])->asArray()->one();
  98. $verify_form->left_num = $left_info['total_num'];
  99. $verify_form->sale_time = time();
  100. $verify_form->end_time = time() + $left_info['expire_day'] * (3600*24);
  101. $verify_form->goods_id = $goods_id;
  102. $verify_form->order_type = $order_type;
  103. //视频卡改为使用状态,新增领取记录
  104. if ($left_info->type == 5) {
  105. $verify_form->status = 1;
  106. }
  107. $verify_form->save();
  108. //视频卡改为使用状态,新增领取记录
  109. if ($left_info->type == 5) {
  110. $logModel = new VerifyCardLog();
  111. $logModel->sale_id = $verify_form->id;
  112. $logModel->store_id = $this->store_id;
  113. $logModel->use_time = time();
  114. $logModel->user_id = $user_id;
  115. $logModel->type = VerifyCardLog::WRITE_TYPE_EXCHANGE;
  116. $logModel->describe = '视频卡兑换';
  117. if (!$logModel->save()) {
  118. \Yii::error("视频卡兑换失败");
  119. }
  120. }
  121. //核销卡核销数量增加
  122. $verify_card_form = VerifyCard::findOne([
  123. 'id' => $value,
  124. 'is_delete' => 0
  125. ]);
  126. $verify_card_form ->use_num += 1;
  127. $verify_card_form ->save();
  128. }
  129. }
  130. }
  131. // 自提点分销
  132. public function shareShop($order) {
  133. if ($order->is_offline == 1) {
  134. $shop = Shop::findOne($order->shop_id);
  135. if ($shop) {
  136. $user = User::findOne($order->user_id);
  137. $info = addslashes("会员 ".$user->nickname." 下单,获得奖励");
  138. $orderDetail = OrderDetail::find()->select(['goods_id','total_price','num'])->where(['order_id' => $order->id])->all();
  139. $shop_bili = Option::get(OptionSetting::SHOP_RATIO, $order->store_id)['value'];
  140. $shop_bili_type = Option::get(OptionSetting::SHOP_RATIO_TYPE, $order->store_id)['value'];
  141. $money = 0;
  142. foreach ($orderDetail as $v){
  143. $goods_money = $v['total_price'];
  144. if($shop_bili_type == 2){
  145. $money += $v['num']*$shop_bili;
  146. }else{
  147. $money += $goods_money*$shop_bili * 0.01;
  148. }
  149. }
  150. if ($money > 0.01) {
  151. $share_form = new ShopShare();
  152. $share_form->store_id = $order->store_id;
  153. $share_form->order_id = $order->id;
  154. $share_form->shop_id = $shop->id;
  155. $share_form->amount = $money;
  156. $share_form->user_id = $order->user_id;
  157. $share_form->the_desc = $info;
  158. $share_form->created_at = time();
  159. $share_form->save();
  160. }
  161. }
  162. }
  163. }
  164. // 商城
  165. private function OrderNotify($event = null)
  166. {
  167. $order = $this->order = Order::findOne(['id' => $this->order_id]);
  168. $user = User::findOne($order->user_id);
  169. // 首次付款,绑定上下级
  170. if ($user->parent_id == 0) {
  171. $form = new Bind();
  172. $form->user_id = $order->user_id;
  173. $form->store_id = $this->store_id;
  174. $form->parent_id = $user->parent_user_id;
  175. $form->condition = 2;
  176. $bindForm = $form->save();
  177. if ($bindForm['code'] == 0) {
  178. $form = new ShareMoneyForm();
  179. $form->order = $this->order;
  180. $form->order_type = $this->order_type;
  181. $form->setData();
  182. }
  183. }
  184. // 消费满指定金额自动成为分销商
  185. $this->autoBecomeShare($order->user_id, $order->store_id, 'STORE');
  186. // 购买指定或任意商品自动成为分销商
  187. $this->autoBuyGood($order->user_id, $order->store_id, $order->id);
  188. if (in_array($this->order->pay_type, [1, 3])) {
  189. // 支付成功赠送优惠券
  190. $this->paySendCoupon($order->store_id, $order->user_id);
  191. // 支付成功赠送卡券
  192. $this->paySendCard($order->store_id, $order->user_id, $order->id);
  193. }
  194. // 记录购买记录
  195. $this->setBuyData($order);
  196. // 消息通知
  197. // $goods = Goods::findOne(OrderDetail::findOne(['order_id' => $this->order_id])->goods_id);
  198. NoticeSend::OrderPay($order->user_id, $order->mobile, $order->order_no, $order->pay_price, '当面付');
  199. NoticeSend::PlaceOrder($order->order_no, $order->mch_id, $order->store_id, $order);
  200. return true;
  201. }
  202. /**
  203. * 支付成功送优惠券
  204. */
  205. private function paySendCoupon($store_id, $user_id)
  206. {
  207. $form = new CouponPaySend();
  208. $form->store_id = $store_id;
  209. $form->user_id = $user_id;
  210. $form->save();
  211. }
  212. /**
  213. * 消费满指定金额自动成为分销商
  214. * @param $user_id integer 用户id
  215. */
  216. private function autoBecomeShare($user_id, $store_id, $type = null)
  217. {
  218. $setting = Option::get('share_basic_setting', $store_id);
  219. $setting = $setting ? Json::decode($setting['value']) : [];
  220. $auto_share_val = floatval($setting['auto_share_val']['value']);
  221. if ($auto_share_val == 0) {
  222. return;
  223. }
  224. $share = Share::findOne(['user_id' => $user_id, 'is_delete' => 0, 'store_id' => $store_id]);
  225. if ($share && $share->status == 1) {
  226. return;
  227. }
  228. $consumption_sum = Order::find()->where(['user_id' => $user_id, 'is_delete' => 0, 'is_pay' => 1])->sum('pay_price');
  229. $consumption_sum = floatval(($consumption_sum ? $consumption_sum : 0));
  230. if ($consumption_sum < $auto_share_val) {
  231. return;
  232. }
  233. if (!$share || $share->status == 2) {
  234. $share = new Share();
  235. $share->user_id = $user_id;
  236. $share->mobile = '';
  237. $share->name = '';
  238. $share->is_delete = 0;
  239. $share->store_id = $store_id;
  240. }
  241. $share->status = 1;
  242. $share->created_at = time();
  243. $share->save();
  244. $user = User::findOne($user_id);
  245. $user->time = time();
  246. $user->is_distributor = 1;
  247. $user->save();
  248. }
  249. /**
  250. * 购买指定商品成为分销商
  251. */
  252. public function autoBuyGood($user_id, $store_id, $order_id, $type = 0)
  253. {
  254. $setting = Option::get('share_basic_setting', $store_id);
  255. $setting = $setting ? Json::decode($setting['value']) : [];
  256. //如果开启无需审核才能开始走下面逻辑
  257. if (intval($setting['share_condition']['value']) !== 2) {
  258. return;
  259. }
  260. // 购买商城成分销商关闭状态不执行
  261. if ($setting['share_goods_status']['value'] == 0) {
  262. return;
  263. }
  264. $share = Share::findOne(['user_id' => $user_id, 'is_delete' => 0, 'store_id' => $store_id]);
  265. if ($share && $share->status == 1) {
  266. return;
  267. }
  268. $goodIds = OrderDetail::find()->where(['order_id' => $order_id])->select('goods_id')->all();
  269. $sign = false;
  270. // 购买任意商品
  271. if ($setting['share_goods_status']['value'] == 1) {
  272. $sign = true;
  273. }
  274. // 购买指定商品自动成为分销商
  275. if ($setting['share_goods_status']['value'] == 2) {
  276. foreach ($goodIds as $item) {
  277. $goods_ids = \explode(',', $setting['share_goods_id']['value']);
  278. if (in_array($item->goods_id, $goods_ids)) {
  279. $sign = true;
  280. break;
  281. }
  282. }
  283. }
  284. if ($sign) {
  285. if (!$share || $share->status == 2) {
  286. $share = new Share();
  287. $share->user_id = $user_id;
  288. $share->mobile = '';
  289. $share->name = '';
  290. $share->is_delete = 0;
  291. $share->store_id = $store_id;
  292. }
  293. $share->status = 1;
  294. $share->created_at = time();
  295. $share->save();
  296. $user = User::findOne($user_id);
  297. $user->time = time();
  298. $user->is_distributor = 1;
  299. $user->save();
  300. }
  301. }
  302. /**
  303. * 支付成功送卡券
  304. */
  305. private function paySendCard($store_id, $user_id, $order_id)
  306. {
  307. $form = new CardSend();
  308. $form->store_id = $store_id;
  309. $form->user_id = $user_id;
  310. $form->order_id = $order_id;
  311. $form->save();
  312. }
  313. // 售后订单申请成功,相关操作
  314. public function refund(OrderEvent $event = null)
  315. {
  316. $this->store_id = $event ? $event->store_id : $this->store_id;
  317. $this->order_id = $event ? $event->order_id : $this->order_id;
  318. $this->order_type = $event ? $event->order_type : $this->order_type;
  319. $this->order_refund_no = $event ? $event->order_refund_no : $this->order_refund_no;
  320. $this->form_id = $event ? $event->form_id : $this->form_id;
  321. try {
  322. $order = Order::findOne(['id' => $this->order_id]);
  323. NoticeSend::MchCancel($order->order_no, $order->mch_id);
  324. } catch (\Exception $e) {
  325. }
  326. }
  327. public function setBuyData($order)
  328. {
  329. $key = "buy_data";
  330. // 用户
  331. $user = User::findOne($order->user_id);
  332. $goods = OrderDetail::findOne(['order_id' => $order->id]);
  333. $data = (object)null;
  334. $data->type = 0;
  335. $data->store_id = $order->store_id;
  336. $data->order_no = $order->order_no;
  337. $data->user = $user->nickname;
  338. $data->goods = $goods->goods_id;
  339. $data->address = $goods->goods_name;
  340. $data->avatar_url = $user->avatar_url;
  341. $data->time = time();
  342. $new = json_encode($data);
  343. $cache = cache();
  344. $cache->set($key, $new, 300);
  345. }
  346. }