OrderCreate.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com
  8. * =========================================================
  9. */
  10. namespace addon\pointexchange\model;
  11. use app\model\BaseModel;
  12. use app\model\express\Config as ExpressConfig;
  13. use app\model\express\Express;
  14. use app\model\express\Local;
  15. use app\model\goods\Goods;
  16. use app\model\member\Member;
  17. use app\model\member\MemberAccount;
  18. use app\model\member\MemberAddress;
  19. use app\model\order\Config;
  20. use app\model\order\LocalOrder;
  21. use app\model\order\Order as CommonOrder;
  22. use app\model\order\OrderCreateTool;
  23. use app\model\order\StoreOrder;
  24. use app\model\store\Store;
  25. use app\model\system\Cron;
  26. use app\model\system\Pay;
  27. use think\facade\Cache;
  28. /**
  29. * 积分兑换
  30. */
  31. class OrderCreate extends BaseModel
  32. {
  33. use OrderCreateTool;
  34. private $error = 0; //是否有错误
  35. private $error_msg = ''; //错误描述
  36. /**
  37. * 创建订单
  38. * @param $data
  39. */
  40. public function create($data)
  41. {
  42. $calculate_data = $this->calculate($data);//计算并查询套餐信息
  43. if (isset($calculate_data[ 'code' ]) && $calculate_data[ 'code' ] < 0)
  44. return $calculate_data;
  45. if ($this->error > 0) {
  46. return $this->error([ 'error_code' => $this->error ], $this->error_msg);
  47. }
  48. if (!empty($calculate_data[ 'invoice_type' ])) {
  49. if ($calculate_data[ 'invoice_type' ] == 1 && $calculate_data[ 'invoice_full_address' ] == "") {
  50. //物流,同城
  51. if ($calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "express" || $calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "local") {
  52. $calculate_data[ 'invoice_full_address' ] = $calculate_data[ 'member_address' ][ 'full_address' ] . $calculate_data[ 'member_address' ][ 'address' ];
  53. $calculate_data[ 'shop_goods_list' ][ 'invoice_full_address' ] = $calculate_data[ 'member_address' ][ 'full_address' ] . $calculate_data[ 'member_address' ][ 'address' ];
  54. }
  55. //门店
  56. if ($calculate_data[ 'shop_goods_list' ][ 'delivery' ][ 'delivery_type' ] == "store") {
  57. $delivery_store_info = json_decode($calculate_data[ 'shop_goods_list' ][ 'delivery_store_info' ], true);
  58. $calculate_data[ 'invoice_full_address' ] = $delivery_store_info[ 'full_address' ];
  59. $calculate_data[ 'shop_goods_list' ][ 'invoice_full_address' ] = $delivery_store_info[ 'full_address' ];
  60. }
  61. }
  62. }
  63. $pay_model = new Pay();
  64. $out_trade_no = $pay_model->createOutTradeNo($data[ 'member_id' ]);
  65. model("promotion_exchange_order")->startTrans();
  66. try {
  67. $order_no = $this->createOrderNo($calculate_data[ "site_id" ], $data[ 'member_id' ]);
  68. $exchange_info = $calculate_data[ "exchange_info" ] ?? [];
  69. $delivery_type = $data[ 'delivery' ][ 'delivery_type' ] ?? '';
  70. $site_id = $data[ 'site_id' ];
  71. $express_type_list = ( new \app\model\express\Config() )->getExpressTypeList($site_id);
  72. $delivery_type_name = $express_type_list[ $delivery_type ] ?? '';
  73. $order_id = 0;
  74. $order_data = array (
  75. "order_no" => $order_no,
  76. "member_id" => $data[ "member_id" ],
  77. "out_trade_no" => $out_trade_no,
  78. "point" => $calculate_data[ "point" ],
  79. "exchange_price" => $exchange_info[ "price" ],
  80. "delivery_price" => $calculate_data[ "delivery_money" ],
  81. "price" => $calculate_data[ 'exchange_info' ][ "price" ],
  82. "order_money" => $calculate_data[ "order_money" ],
  83. "create_time" => time(),
  84. "exchange_id" => $exchange_info[ "id" ],
  85. "exchange_goods_id" => $exchange_info[ "exchange_goods_id" ],
  86. "exchange_name" => $exchange_info[ "name" ],
  87. "exchange_image" => $exchange_info[ "image" ],
  88. "num" => $calculate_data[ "num" ],
  89. "order_status" => 0,
  90. "type" => $exchange_info[ "type" ],
  91. "type_name" => $exchange_info[ "type_name" ],
  92. 'name' => $calculate_data[ 'member_address' ][ 'name' ] ?? '',
  93. 'mobile' => $calculate_data[ 'member_address' ][ 'mobile' ] ?? '',
  94. 'telephone' => $calculate_data[ 'member_address' ][ 'telephone' ] ?? '',
  95. 'province_id' => $calculate_data[ 'member_address' ][ 'province_id' ] ?? '',
  96. 'city_id' => $calculate_data[ 'member_address' ][ 'city_id' ] ?? '',
  97. 'district_id' => $calculate_data[ 'member_address' ][ 'district_id' ] ?? '',
  98. 'community_id' => $calculate_data[ 'member_address' ][ 'community_id' ] ?? '',
  99. 'address' => $calculate_data[ 'member_address' ][ 'address' ] ?? '',
  100. 'full_address' => $calculate_data[ 'member_address' ][ 'full_address' ] ?? '',
  101. 'longitude' => $calculate_data[ 'member_address' ][ 'longitude' ] ?? '',
  102. 'latitude' => $calculate_data[ 'member_address' ][ 'latitude' ] ?? '',
  103. 'order_from' => $data[ 'order_from' ],
  104. 'order_from_name' => $data[ 'order_from_name' ],
  105. "buyer_message" => $calculate_data[ "buyer_message" ],
  106. "type_id" => $exchange_info[ "type_id" ],
  107. "balance" => $calculate_data[ "balance" ],
  108. "site_id" => $calculate_data[ "site_id" ],
  109. 'order_id' => $order_id,
  110. 'delivery_type' => $delivery_type,
  111. 'delivery_type_name' => $delivery_type_name,
  112. 'delivery_status' => $calculate_data[ "delivery_status" ] ?? 0,
  113. 'delivery_status_name' => $calculate_data[ "delivery_status_name" ] ?? '',
  114. 'delivery_store_id' => $data[ 'delivery' ][ 'store_id' ] ?? 0,
  115. "delivery_store_name" => $calculate_data[ "delivery_store_name" ] ?? '',
  116. "delivery_store_info" => $calculate_data[ "delivery_store_info" ] ?? '',
  117. 'buyer_ask_delivery_time' => $calculate_data[ 'buyer_ask_delivery_time' ] ?? '',//定时达
  118. );
  119. $order_id = model("promotion_exchange_order")->add($order_data);
  120. //判断库存
  121. $exchange_model = new Exchange();
  122. //减去套餐的库存
  123. $exchange_result = $exchange_model->decStock([ "id" => $exchange_info[ "id" ], "num" => $calculate_data[ "num" ] ]);
  124. if ($exchange_result[ 'code' ] < 0) {
  125. model("promotion_exchange_order")->rollback();
  126. return $exchange_result;
  127. }
  128. switch ( $exchange_info[ "type" ] ) {//兑换类型
  129. case "1"://商品
  130. //库存变化
  131. $result = $this->success();
  132. $goods_info = $calculate_data[ 'goods_info' ];
  133. $stock_result = $this->skuDecStock($goods_info, $order_data[ 'store_id' ] ?? 0);
  134. if ($stock_result[ 'code' ] != 0) {
  135. model('order')->rollback();
  136. return $stock_result;
  137. }
  138. break;
  139. case "2"://优惠券
  140. $result = $this->success();
  141. break;
  142. case "3":
  143. default:
  144. $result = $this->success();
  145. break;
  146. }
  147. if ($result[ "code" ] < 0) {
  148. model("promotion_exchange_order")->rollback();
  149. return $result;
  150. }
  151. //扣除积分
  152. $member_account_model = new MemberAccount();
  153. $member_account_result = $member_account_model->addMemberAccount($exchange_info[ 'site_id' ], $data[ "member_id" ], "point", -$calculate_data[ "point" ], "pointexchange", $order_id, "积分兑换扣除");
  154. if ($member_account_result[ "code" ] < 0) {
  155. model("promotion_exchange_order")->rollback();
  156. return $member_account_result;
  157. }
  158. // 积分兑换订单生成后操作
  159. $result_list = event("PointExchangeOrderCreate", [ 'order_id' => $order_id ]);
  160. if (!empty($result_list)) {
  161. foreach ($result_list as $k => $v) {
  162. if (!empty($v) && $v[ "code" ] < 0) {
  163. model("promotion_exchange_order")->rollback();
  164. return $v;
  165. }
  166. }
  167. }
  168. //生成整体支付单据
  169. $pay_model = new Pay();
  170. $pay_model->addPay($calculate_data[ "site_id" ], $out_trade_no, "POINT", $calculate_data[ "order_name" ], $calculate_data[ "order_name" ], $calculate_data[ "order_money" ], '', 'PointexchangeOrderPayNotify', '');
  171. model("promotion_exchange_order")->commit();
  172. return $this->success($out_trade_no);
  173. } catch (\Exception $e) {
  174. model("promotion_exchange_order")->rollback();
  175. return $this->error('', $e->getMessage() . $e->getFile() . $e->getLine());
  176. }
  177. }
  178. /**
  179. * 待支付订单
  180. * @param $data
  181. */
  182. public function payment($data)
  183. {
  184. $calculate_data = $this->calculate($data);//计算并查询套餐信息
  185. if (isset($calculate_data[ 'code' ]) && $calculate_data[ 'code' ] < 0)
  186. return $calculate_data;
  187. $express_type = [];
  188. if ($calculate_data[ 'exchange_info' ][ 'type' ] == 1 && $calculate_data[ 'is_virtual' ] == 0) {
  189. // if (!empty($calculate_data[ 'member_address' ])) {
  190. //2. 查询店铺配送方式(1. 物流 2. 自提 3. 外卖)
  191. if ($calculate_data[ "express_config" ][ "is_use" ] == 1) {
  192. $title = $calculate_data[ "express_config" ][ 'value' ][ 'express_name' ];
  193. if ($title == "") {
  194. $title = Express::express_type[ "express" ][ "title" ];
  195. }
  196. $express_type[] = [ "title" => $title, "name" => "express" ];
  197. }
  198. //查询店铺是否开启门店自提
  199. if ($calculate_data[ "store_config" ][ "is_use" ] == 1) {
  200. //根据坐标查询门店
  201. $store_model = new Store();
  202. $store_condition = array (
  203. [ 'site_id', '=', $data[ 'site_id' ] ],
  204. [ 'is_pickup', '=', 1 ],
  205. [ 'status', '=', 1 ],
  206. [ 'is_frozen', '=', 0 ],
  207. );
  208. $latlng = array (
  209. 'lat' => $data[ 'latitude' ],
  210. 'lng' => $data[ 'longitude' ],
  211. );
  212. $store_list_result = $store_model->getLocationStoreList($store_condition, '*', $latlng);
  213. $store_list = $store_list_result[ "data" ];
  214. $title = $calculate_data[ "store_config" ][ 'value' ][ 'store_name' ];
  215. if ($title == "") {
  216. $title = Express::express_type[ "store" ][ "title" ];
  217. }
  218. $express_type[] = [ "title" => $title, "name" => "store", "store_list" => $store_list ];
  219. }
  220. //查询店铺是否开启外卖配送
  221. if ($calculate_data[ "local_config" ][ "is_use" ] == 1) {
  222. //查询本店的通讯地址
  223. $title = $calculate_data[ "local_config" ][ 'value' ][ 'local_name' ];
  224. if ($title == "") {
  225. $title = '外卖配送';
  226. }
  227. $store_model = new Store();
  228. $store_condition = array (
  229. [ 'site_id', '=', $data[ 'site_id' ] ],
  230. );
  231. if (addon_is_exit('store', $data[ 'site_id' ])) {
  232. $store_condition[] = [ 'is_o2o', '=', 1 ];
  233. $store_condition[] = [ 'status', '=', 1 ];
  234. $store_condition[] = [ 'is_frozen', '=', 0 ];
  235. } else {
  236. $store_condition[] = [ 'is_default', '=', 1 ];
  237. }
  238. $latlng = array (
  239. 'lat' => $data[ 'latitude' ],
  240. 'lng' => $data[ 'longitude' ],
  241. );
  242. $store_list = $store_model->getLocationStoreList($store_condition, '*', $latlng)[ 'data' ];
  243. $express_type[] = [ "title" => $title, "name" => "local", 'store_list' => $store_list ];
  244. }
  245. // }
  246. }
  247. $calculate_data[ "express_type" ] = $express_type;
  248. return $this->success($calculate_data);
  249. }
  250. /**
  251. * 计算
  252. * @param $data
  253. */
  254. public function calculate($data)
  255. {
  256. $site_id = $data[ 'site_id' ];
  257. $data = $this->initMemberAddress($data);
  258. $data = $this->initMemberAccount($data); //初始化会员账户
  259. //交易配置
  260. $config_model = new Config();
  261. $order_config_result = $config_model->getOrderEventTimeConfig($site_id);
  262. $order_config = $order_config_result[ "data" ];
  263. $data[ 'order_config' ] = $order_config[ 'value' ] ?? [];
  264. $id = $data[ "id" ];
  265. $exchange_model = new Exchange();
  266. $exchange_info_result = $exchange_model->getExchangeInfo($id, '*', $data[ 'sku_id' ]);
  267. $exchange_info = $exchange_info_result[ "data" ];
  268. if (empty($exchange_info))
  269. return $this->error('', "找不到对应的积分兑换活动!");
  270. $data[ "exchange_info" ] = $exchange_info;
  271. if ($exchange_info[ "state" ] == 0) {
  272. $this->error = 1;
  273. $this->error_msg = "当前兑换活动未开启!";
  274. }
  275. if ($exchange_info[ "type" ] == 1 && $exchange_info[ "limit_num" ] > 0) {
  276. // 已兑换数量
  277. $exchangeed_num = model("promotion_exchange_order")->getSum([ [ 'exchange_id', '=', $exchange_info[ 'id' ] ], [ 'order_status', '<>', '-1' ], [ 'member_id', '=', $data[ 'member_id' ] ] ], 'num');
  278. if (( $exchangeed_num + $data[ 'num' ] ) > $exchange_info[ "limit_num" ]) {
  279. $this->error = 1;
  280. $this->error_msg = "兑换数量已超出该兑换活动的兑换限制!";
  281. }
  282. }
  283. if ($exchange_info[ "stock" ] <= 0) {
  284. if ($exchange_info[ 'type' ] == 2 && $exchange_info[ "stock" ] == -1) {
  285. } else {
  286. $this->error = 1;
  287. $this->error_msg = "当前兑换库存不足!";
  288. }
  289. }
  290. $delivery_status = 0;//发货状态
  291. $delivery_status_name = '';//发货状态名称
  292. $delivery_money = 0;//运费
  293. //兑换类型为1时 兑换物品为商品(相对优惠券和红包来说较为特殊)
  294. if ($exchange_info[ 'type' ] == 1) {
  295. $goods_model = new Goods();
  296. $goods_result = $goods_model->getGoodsSkuInfo([ [ 'sku_id', '=', $exchange_info[ 'sku_id' ] ], [ 'site_id', '=', $data[ 'site_id' ] ] ], '*');
  297. $goods_info = $goods_result[ 'data' ];
  298. $goods_info[ 'num' ] = $data[ 'num' ];
  299. $data[ 'goods_info' ] = $goods_info;
  300. $data[ 'is_virtual' ] = $goods_info[ 'is_virtual' ];
  301. //计算邮费
  302. if ($data[ 'is_virtual' ] == 1) {
  303. //虚拟订单 运费为0
  304. $delivery_money = 0;
  305. $data[ 'delivery' ][ 'delivery_type' ] = '';
  306. $data[ 'buyer_ask_delivery_time' ] = 0;
  307. } else {
  308. $express_config_model = new ExpressConfig();
  309. $deliver_type = $express_config_model->getDeliverTypeSort($site_id);
  310. $deliver_type = $deliver_type[ "data" ];
  311. $data[ "deliver_sort" ] = explode(',', $deliver_type[ 'value' ][ 'deliver_type' ]);
  312. //查询店铺是否开启快递配送
  313. $express_config_result = $express_config_model->getExpressConfig($site_id);
  314. $express_config = $express_config_result[ "data" ];
  315. $data[ "express_config" ] = $express_config;
  316. //查询店铺是否开启门店自提
  317. $store_config_result = $express_config_model->getStoreConfig($site_id);
  318. $store_config = $store_config_result[ "data" ];
  319. $data[ "store_config" ] = $store_config;
  320. //查询店铺是否开启外卖配送
  321. $local_config_result = $express_config_model->getLocalDeliveryConfig($site_id);
  322. $local_config = $local_config_result[ "data" ];
  323. $data[ "local_config" ] = $local_config;
  324. //如果本地配送开启, 则查询出本地配送的配置
  325. if ($data[ "local_config" ][ 'is_use' ] == 1 && isset($data[ 'delivery' ][ 'store_id' ])) {
  326. $local_model = new Local();
  327. $local_info_result = $local_model->getLocalInfo([ [ 'site_id', '=', $site_id ], [ 'store_id', '=', $data[ 'delivery' ][ 'store_id' ] ] ]);
  328. $local_info = $local_info_result[ 'data' ];
  329. $data[ "local_config" ][ 'info' ] = $local_info;
  330. } else {
  331. $shop_goods[ 'local_config' ][ 'info' ] = [];
  332. }
  333. $delivery_array = $data[ 'delivery' ] ?? [];
  334. $delivery_type = $delivery_array[ "delivery_type" ] ?? 'express';
  335. $data[ 'buyer_ask_delivery_time' ] = $delivery_type == 'local' ? $data[ 'buyer_ask_delivery_time' ] : 0;
  336. if ($delivery_type == "store") {
  337. if (isset($data[ 'delivery' ][ "delivery_type" ]) && $data[ 'delivery' ][ "delivery_type" ] == "store") {
  338. //门店自提
  339. $delivery_money = 0;
  340. $data[ 'delivery' ][ 'delivery_type' ] = 'store';
  341. if ($data[ "store_config" ][ "is_use" ] == 0) {
  342. $this->error = 1;
  343. $this->error_msg = "门店自提方式未开启!";
  344. }
  345. if (empty($data[ 'delivery' ][ "store_id" ])) {
  346. $this->error = 1;
  347. $this->error_msg = "门店未选择!";
  348. }
  349. $data[ 'delivery' ][ 'store_id' ] = $data[ 'delivery' ][ "store_id" ];
  350. $shop_goods[ 'buyer_ask_delivery_time' ] = $data[ 'buyer_ask_delivery_time' ];
  351. $data = $this->storeOrderData($data);
  352. }
  353. } else {
  354. if (empty($data[ 'member_address' ]) && $delivery_type == 'express') {
  355. $delivery_money = 0;
  356. $data[ 'delivery' ][ 'delivery_type' ] = 'express';
  357. $this->error = 1;
  358. $this->error_msg = "未配置默认收货地址!";
  359. } else {
  360. if (!isset($data[ 'delivery' ][ "delivery_type" ]) || $data[ 'delivery' ][ "delivery_type" ] == "express") {
  361. if ($data[ "express_config" ][ "is_use" ] == 1) {
  362. if ($exchange_info[ 'is_free_shipping' ] == 1) {//免邮
  363. $delivery_money = 0;
  364. } elseif ($exchange_info[ 'is_free_shipping' ] == 0 && $exchange_info[ 'delivery_type' ] == 0) { //固定运费
  365. $delivery_money = $exchange_info[ 'delivery_price' ];
  366. } else {
  367. if ($exchange_info[ 'delivery_type' ] == 1) {//运费模板
  368. $goods_info[ 'shipping_template' ] = $exchange_info[ 'shipping_template' ];
  369. }
  370. //物流配送
  371. $express = new Express();
  372. $express_fee_result = $express->pointExchangeCalculate($goods_info, $data);
  373. if ($express_fee_result[ "code" ] < 0) {
  374. $this->error = 1;
  375. $this->error_msg = $express_fee_result[ "message" ];
  376. $delivery_money = 0;
  377. } else {
  378. $delivery_money = $express_fee_result[ 'data' ][ 'delivery_fee' ];
  379. }
  380. }
  381. } else {
  382. $this->error = 1;
  383. $this->error_msg = "物流配送方式未开启!";
  384. $delivery_money = 0;
  385. }
  386. $data[ 'delivery' ][ 'delivery_type' ] = 'express';
  387. } else if ($data[ 'delivery' ][ "delivery_type" ] == "local") {
  388. //外卖配送
  389. $delivery_money = 0;
  390. $data[ 'delivery' ][ 'delivery_type' ] = 'local';
  391. if ($data[ "local_config" ][ "is_use" ] == 0) {
  392. $this->error = 1;
  393. $this->error_msg = "外卖配送方式未开启!";
  394. } else {
  395. if (empty($data[ 'delivery' ][ "store_id" ])) {
  396. $this->error = 1;
  397. $this->error_msg = "没有可配送的门店!";
  398. }
  399. $local_delivery_time = 0;
  400. if (!empty($data[ 'buyer_ask_delivery_time' ])) {
  401. $local_delivery_time = $data[ 'buyer_ask_delivery_time' ];
  402. }
  403. $goods_info[ 'buyer_ask_delivery_time' ] = $local_delivery_time;
  404. $local_model = new Local();
  405. $local_result = $local_model->pointExchangeCalculate($goods_info, $data);
  406. $data[ 'delivery' ][ 'start_money' ] = 0;
  407. if ($local_result[ 'code' ] < 0) {
  408. $this->error = $local_result[ 'data' ][ 'code' ];
  409. $this->error_msg = $local_result[ 'message' ];
  410. $data[ 'delivery' ][ 'start_money' ] = $local_result[ 'data' ][ 'start_money_array' ][ 0 ] ?? 0;
  411. } else {
  412. $delivery_money = $local_result[ 'data' ][ 'delivery_money' ];
  413. if (!empty($local_result[ 'data' ][ 'error_code' ])) {
  414. $this->error = $local_result[ 'data' ][ 'code' ];
  415. $this->error_msg = $local_result[ 'data' ][ 'error' ];
  416. }
  417. }
  418. $data[ 'delivery' ][ 'error' ] = $this->error;
  419. $data[ 'delivery' ][ 'error_msg' ] = $this->error_msg;
  420. }
  421. }
  422. }
  423. }
  424. }
  425. }
  426. $data[ 'delivery_status' ] = $delivery_status;
  427. $data[ 'delivery_status_name' ] = $delivery_status_name;
  428. $point = $exchange_info[ "point" ];
  429. $price = $exchange_info[ "price" ];
  430. $balance = $exchange_info[ "balance" ];
  431. $goods_num = $data[ "num" ];
  432. $goods_money = $price * $data[ "num" ];
  433. $order_money = $goods_money + $delivery_money;
  434. $order_name = $exchange_info[ "name" ] . "【" . $exchange_info[ "type_name" ] . "】";
  435. $data[ 'point' ] = $point * $data[ "num" ];
  436. $data[ 'price' ] = $price * $data[ "num" ];
  437. $data[ 'goods_num' ] = $goods_num;
  438. $data[ 'order_name' ] = $order_name;
  439. $data[ 'order_money' ] = $order_money;
  440. $data[ 'balance' ] = $balance * $data[ "num" ];
  441. $data[ 'delivery_money' ] = $delivery_money;
  442. return $data;
  443. }
  444. /**
  445. * 初始化收货地址
  446. * @param $data
  447. * @return mixed
  448. */
  449. public function initMemberAddress($data)
  450. {
  451. $delivery_type = $data[ 'delivery' ][ 'delivery_type' ] ?? '';
  452. if (empty($data[ 'member_address' ])) {
  453. $member_address = new MemberAddress();
  454. $type = 1;
  455. if ($delivery_type == 'local') {
  456. $type = 2;
  457. }
  458. $address = $member_address->getMemberAddressInfo([ [ 'member_id', '=', $data[ 'member_id' ] ], [ 'is_default', '=', 1 ], [ 'type', '=', $type ] ]);
  459. $data[ 'member_address' ] = $address[ 'data' ];
  460. }
  461. if (!empty($data[ 'member_address' ])) {
  462. if ($delivery_type == 'local') {
  463. //外卖订单 如果收货地址没有定位的话,就不取用地址
  464. $type = $data[ 'member_address' ][ 'type' ] ?? 1;
  465. if ($type == 1) {
  466. $data[ 'member_address' ] = '';
  467. }
  468. }
  469. }
  470. return $data;
  471. }
  472. /**
  473. * 初始化会员账户
  474. * @param $data
  475. * @return mixed
  476. */
  477. public function initMemberAccount($data)
  478. {
  479. $member_model = new Member();
  480. $member_info_result = $member_model->getMemberDetail($data[ "member_id" ], $data[ "site_id" ]);
  481. $member_info = $member_info_result[ "data" ];
  482. $data[ 'member_account' ] = $member_info;
  483. return $data;
  484. }
  485. /**
  486. * 增加订单自动关闭事件
  487. * @param $order_id
  488. * @param $site_id
  489. */
  490. public function addOrderCronClose($order_id, $site_id)
  491. {
  492. //计算订单自动关闭时间
  493. $config_model = new Config();
  494. $order_config_result = $config_model->getOrderEventTimeConfig($site_id);
  495. $order_config = $order_config_result[ "data" ];
  496. $now_time = time();
  497. if (!empty($order_config)) {
  498. $execute_time = $now_time + $order_config[ "value" ][ "auto_close" ] * 60;//自动关闭时间
  499. } else {
  500. $execute_time = $now_time + 3600;//尚未配置 默认一天
  501. }
  502. $cron_model = new Cron();
  503. $cron_model->addCron(1, 0, "积分兑换订单自动关闭", "CronExchangeOrderClose", $execute_time, $order_id);
  504. }
  505. /**
  506. * 验证订单支付金额知否为0 如果为0 立即支付完成
  507. * @param $order_data
  508. */
  509. public function checkFree($order_data)
  510. {
  511. if ($order_data[ "price" ] == 0) {
  512. $pay_model = new Pay();
  513. $pay_model->onlinePay($order_data[ "out_trade_no" ], "ONLINE_PAY", '', '');
  514. }
  515. }
  516. /**
  517. * 生成订单编号
  518. *
  519. * @param array $site_id
  520. */
  521. public function createOrderNo($site_id, $member_id = 0)
  522. {
  523. $time_str = date('YmdHi');
  524. $max_no = Cache::get($site_id . "_" . $member_id . "_" . $time_str);
  525. if (!isset($max_no) || empty($max_no)) {
  526. $max_no = 1;
  527. } else {
  528. $max_no = $max_no + 1;
  529. }
  530. $order_no = $time_str . $member_id . sprintf("%03d", $max_no);
  531. Cache::set($site_id . "_" . $member_id . "_" . $time_str, $max_no);
  532. return $order_no;
  533. }
  534. private function orderType($type_name)
  535. {
  536. if ($type_name == 'express') {
  537. $order = new CommonOrder();
  538. return [
  539. 'order_type_id' => 1,
  540. 'order_type_name' => '普通订单',
  541. 'order_status' => $order->order_status[ 0 ]
  542. ];
  543. } elseif ($type_name == 'store') {
  544. $order = new StoreOrder();
  545. return [
  546. 'order_type_id' => 2,
  547. 'order_type_name' => '自提订单',
  548. 'order_status' => $order->order_status[ 0 ]
  549. ];
  550. } elseif ($type_name == 'local') {
  551. $order = new LocalOrder();
  552. return [
  553. 'order_type_id' => 3,
  554. 'order_type_name' => '外卖订单',
  555. 'order_status' => $order->order_status[ 0 ]
  556. ];
  557. }
  558. }
  559. /**
  560. * 补齐门店数据
  561. * @param $data
  562. */
  563. public function storeOrderData($shop_goods)
  564. {
  565. $temp_data = [];
  566. $delivery_store_id = $shop_goods[ 'delivery' ][ 'store_id' ] ?? 0; //门店id
  567. if ($delivery_store_id > 0) {
  568. $store_model = new Store();
  569. $condition = array (
  570. [ "store_id", "=", $delivery_store_id ],
  571. [ "site_id", "=", $shop_goods[ 'site_id' ] ],
  572. [ "status", "=", 1 ],
  573. [ "is_pickup", "=", 1 ],
  574. );
  575. $store_info_result = $store_model->getStoreInfo($condition);
  576. $store_info = $store_info_result[ "data" ] ?? [];
  577. if (empty($store_info)) {
  578. $this->error = 1;
  579. $this->error_msg = "当前门店不存在或未开启!";
  580. } else {
  581. $temp_data[ "delivery_store_id" ] = $delivery_store_id;
  582. $delivery_store_name = $store_info_result[ "data" ][ "store_name" ];
  583. $temp_data[ "delivery_store_name" ] = $delivery_store_name;
  584. $store_info[ 'full_address' ] = $store_info[ "full_address" ] . $store_info[ "address" ];
  585. $temp_data[ "delivery_store_info" ] = json_encode($store_info, JSON_UNESCAPED_UNICODE);
  586. }
  587. } else {
  588. $this->error = 1;
  589. $this->error_msg = "配送门店不可为空!";
  590. }
  591. return array_merge($shop_goods, $temp_data);
  592. }
  593. }