FenxiaoOrder.php 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553
  1. <?php
  2. /**
  3. * Niushop商城系统 - 团队十年电商经验汇集巨献!
  4. * =========================================================
  5. * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
  6. * ----------------------------------------------
  7. * 官方网址: https://www.niushop.com
  8. * =========================================================
  9. */
  10. namespace addon\fenxiao\model;
  11. use app\model\BaseModel;
  12. use app\model\message\Message;
  13. use app\model\system\Stat;
  14. /**
  15. * 分销商品
  16. */
  17. class FenxiaoOrder extends BaseModel
  18. {
  19. /**
  20. * 分销订单计算
  21. * @param unknown $order
  22. */
  23. public function calculate($order)
  24. {
  25. //获取分销基础配置
  26. $config_model = new Config();
  27. $fenxiao_basic_config = $config_model->getFenxiaoBasicsConfig($order[ 'site_id' ]);
  28. $level_config = $fenxiao_basic_config[ 'data' ][ 'value' ][ 'level' ];
  29. if (empty($level_config)) {
  30. return $this->success();
  31. }
  32. //检测分销商上级关系
  33. $member_info = model("member")->getInfo([ [ 'member_id', '=', $order[ 'member_id' ] ] ], 'fenxiao_id,is_fenxiao');
  34. //如果没有分销商直接返回不计算,没有考虑首次付款上下级绑定
  35. if (empty($member_info)) {
  36. return $this->success();
  37. }
  38. if ($member_info[ 'fenxiao_id' ] == 0) {
  39. return $this->success();
  40. }
  41. $fenxiao_id = $member_info[ 'fenxiao_id' ];
  42. $fenxiao_info = model("fenxiao")->getInfo([ [ 'fenxiao_id', '=', $fenxiao_id ], [ 'is_delete', '=', 0 ] ]);
  43. if (empty($fenxiao_info)) {
  44. return $this->success();
  45. }
  46. // 如果购买人是分销商 并且未开启分销商自购
  47. if ($member_info[ 'is_fenxiao' ] && $fenxiao_basic_config[ 'data' ][ 'value' ][ 'self_purchase_rebate' ] == 0) {
  48. if (empty($fenxiao_info[ 'parent' ])) return $this->success();
  49. $fenxiao_info = model("fenxiao")->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ]);
  50. if (empty($fenxiao_info)) return $this->success();
  51. }
  52. //判断几级分销
  53. $parent_fenxiao_info = $level_config >= 2 ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status, parent') : [];
  54. $grand_parent_fenxiao_info = $level_config >= 3 && !empty($parent_fenxiao_info[ 'parent' ]) ? model('fenxiao')->getInfo([ [ 'fenxiao_id', '=', $parent_fenxiao_info[ 'parent' ] ], [ 'is_delete', '=', 0 ] ], 'fenxiao_id, fenxiao_name, status') : [];
  55. $order_goods = model('order_goods')->getList([ [ 'order_id', '=', $order[ 'order_id' ] ], [ 'is_fenxiao', '=', 1 ] ], 'order_goods_id, goods_id, sku_id, sku_name, sku_image, sku_no, is_virtual, price, cost_price, num, goods_money, cost_money, delivery_no, delivery_status, real_goods_money');
  56. if (empty($order_goods)) return $this->success();
  57. model('fenxiao_order')->delete([ [ 'order_id', '=', $order[ 'order_id' ] ] ]);
  58. //获取分销等级
  59. foreach ($order_goods as $k => $v) {
  60. $v[ 'num' ] = numberFormat($v[ 'num' ]);
  61. //商品信息管理
  62. $goods_info = model('goods')->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ] ], 'is_fenxiao, fenxiao_type');
  63. if ($goods_info[ 'is_fenxiao' ] != 1) {
  64. continue;
  65. }
  66. $sku_info = model('goods_sku')->getInfo([ [ 'sku_id', '=', $v[ 'sku_id' ] ] ], 'fenxiao_price');
  67. if (!empty($sku_info) && $sku_info[ 'fenxiao_price' ] > 0) $v[ 'real_goods_money' ] = $sku_info[ 'fenxiao_price' ] * $v[ 'num' ];
  68. $commission = 0;
  69. $commission_rate = 0;
  70. $order_fenxiao_data = [
  71. 'one_rate' => 0,
  72. 'one_commission' => 0,
  73. 'two_rate' => 0,
  74. 'two_commission' => 0,
  75. 'three_rate' => 0,
  76. ];
  77. if ($goods_info[ 'fenxiao_type' ] == 2) {
  78. // 自定义分销规则
  79. $fenxiao_level = model('fenxiao_goods_sku')->getInfo([ [ 'goods_id', '=', $v[ 'goods_id' ] ], [ 'sku_id', '=', $v[ 'sku_id' ] ], [ 'level_id', '=', $fenxiao_info[ 'level_id' ] ] ]);
  80. if (empty($fenxiao_level)) continue;
  81. if ($fenxiao_info[ 'status' ] == 1) {
  82. if ($fenxiao_level[ 'one_rate' ] > 0) {
  83. $commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
  84. $commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
  85. } else {
  86. $commission_rate += $order_fenxiao_data[ 'one_rate' ] = round($fenxiao_level[ 'one_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
  87. $commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_money' ] * $v[ 'num' ];
  88. }
  89. }
  90. if (!empty($parent_fenxiao_info) && $parent_fenxiao_info[ 'status' ] == 1) {
  91. if ($fenxiao_level[ 'two_rate' ] > 0) {
  92. $commission_rate += $order_fenxiao_data[ 'two_rate' ] = $fenxiao_level[ 'two_rate' ];
  93. $commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_rate' ] * $v[ 'real_goods_money' ] / 100;
  94. } else {
  95. $commission_rate += $order_fenxiao_data[ 'two_rate' ] = round($fenxiao_level[ 'two_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
  96. $commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_money' ] * $v[ 'num' ];
  97. }
  98. }
  99. if (!empty($grand_parent_fenxiao_info) && $grand_parent_fenxiao_info[ 'status' ] == 1) {
  100. if ($fenxiao_level[ 'three_rate' ] > 0) {
  101. $commission_rate += $order_fenxiao_data[ 'three_rate' ] = $fenxiao_level[ 'three_rate' ];
  102. $commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_rate' ] * $v[ 'real_goods_money' ] / 100;
  103. } else {
  104. $commission_rate += $order_fenxiao_data[ 'three_rate' ] = round($fenxiao_level[ 'three_money' ] * $v[ 'num' ] / $v[ 'real_goods_money' ], 2);
  105. $commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_money' ] * $v[ 'num' ];
  106. }
  107. }
  108. } else {
  109. // 默认规则
  110. $fenxiao_level = model('fenxiao_level')->getInfo([ [ 'level_id', '=', $fenxiao_info[ 'level_id' ] ] ]);
  111. if ($fenxiao_info[ 'status' ] == 1) {
  112. if ($fenxiao_level[ 'one_rate' ] > 0) {
  113. $commission_rate += $order_fenxiao_data[ 'one_rate' ] = $fenxiao_level[ 'one_rate' ];
  114. $commission += $order_fenxiao_data[ 'one_commission' ] = $fenxiao_level[ 'one_rate' ] * $v[ 'real_goods_money' ] / 100;
  115. } else {
  116. $order_fenxiao_data[ 'one_rate' ] = 0;
  117. $order_fenxiao_data[ 'one_commission' ] = 0;
  118. }
  119. }
  120. if (!empty($parent_fenxiao_info) && $parent_fenxiao_info[ 'status' ] == 1) {
  121. if ($fenxiao_level[ 'two_rate' ] > 0) {
  122. $commission_rate += $order_fenxiao_data[ 'two_rate' ] = $fenxiao_level[ 'two_rate' ];
  123. $commission += $order_fenxiao_data[ 'two_commission' ] = $fenxiao_level[ 'two_rate' ] * $v[ 'real_goods_money' ] / 100;
  124. } else {
  125. $order_fenxiao_data[ 'two_rate' ] = 0;
  126. $order_fenxiao_data[ 'two_commission' ] = 0;
  127. }
  128. }
  129. if (!empty($grand_parent_fenxiao_info) && $grand_parent_fenxiao_info[ 'status' ] == 1) {
  130. if ($fenxiao_level[ 'three_rate' ] > 0) {
  131. $commission_rate += $order_fenxiao_data[ 'three_rate' ] = $fenxiao_level[ 'three_rate' ];
  132. $commission += $order_fenxiao_data[ 'three_commission' ] = $fenxiao_level[ 'three_rate' ] * $v[ 'real_goods_money' ] / 100;
  133. } else {
  134. $order_fenxiao_data[ 'three_rate' ] = 0;
  135. $order_fenxiao_data[ 'three_commission' ] = 0;
  136. }
  137. }
  138. }
  139. //启动分销
  140. $data = [
  141. 'order_id' => $order[ 'order_id' ],
  142. 'order_no' => $order[ 'order_no' ],
  143. 'order_goods_id' => $v[ 'order_goods_id' ],
  144. 'site_id' => $order[ 'site_id' ],
  145. 'site_name' => $order[ 'site_name' ],
  146. 'goods_id' => $v[ 'goods_id' ],
  147. 'sku_id' => $v[ 'sku_id' ],
  148. 'sku_name' => $v[ 'sku_name' ],
  149. 'sku_image' => $v[ 'sku_image' ],
  150. 'price' => $v[ 'price' ],
  151. 'num' => $v[ 'num' ],
  152. 'real_goods_money' => $order_goods[ $k ][ 'real_goods_money' ],
  153. 'member_id' => $order[ 'member_id' ],
  154. 'member_name' => $order[ 'name' ],
  155. 'member_mobile' => $order[ 'mobile' ],
  156. 'full_address' => $order[ 'full_address' ] . $order[ 'address' ],
  157. 'commission' => $commission,
  158. 'commission_rate' => $commission_rate,
  159. 'one_fenxiao_id' => empty($fenxiao_info) ? 0 : $fenxiao_info[ 'fenxiao_id' ],
  160. 'one_rate' => empty($order_fenxiao_data[ 'one_rate' ]) ? 0 : $order_fenxiao_data[ 'one_rate' ],
  161. 'one_commission' => empty($order_fenxiao_data[ 'one_commission' ]) ? 0 : $order_fenxiao_data[ 'one_commission' ],
  162. 'one_fenxiao_name' => empty($fenxiao_info) ? '' : $fenxiao_info[ 'fenxiao_name' ],
  163. 'two_fenxiao_id' => empty($parent_fenxiao_info) ? 0 : $parent_fenxiao_info[ 'fenxiao_id' ],
  164. 'two_rate' => empty($order_fenxiao_data[ 'two_rate' ]) ? 0 : $order_fenxiao_data[ 'two_rate' ],
  165. 'two_commission' => empty($order_fenxiao_data[ 'two_commission' ]) ? 0 : $order_fenxiao_data[ 'two_commission' ],
  166. 'two_fenxiao_name' => empty($parent_fenxiao_info) ? '' : $parent_fenxiao_info[ 'fenxiao_name' ],
  167. 'three_fenxiao_id' => empty($grand_parent_fenxiao_info) ? '' : $grand_parent_fenxiao_info[ 'fenxiao_id' ],
  168. 'three_rate' => empty($order_fenxiao_data[ 'three_rate' ]) ? 0 : $order_fenxiao_data[ 'three_rate' ],
  169. 'three_commission' => empty($order_fenxiao_data[ 'three_commission' ]) ? 0 : $order_fenxiao_data[ 'three_commission' ],
  170. 'three_fenxiao_name' => empty($grand_parent_fenxiao_info) ? '' : $grand_parent_fenxiao_info[ 'fenxiao_name' ],
  171. 'create_time' => time()
  172. ];
  173. model("fenxiao_order")->add($data);
  174. }
  175. // 分销商检测升级
  176. event('FenxiaoUpgrade', $member_info[ 'fenxiao_id' ]);
  177. return $this->success();
  178. }
  179. /**
  180. * 订单退款
  181. * @param $order_goods_id
  182. * @return array
  183. */
  184. public function refund($order_goods_id)
  185. {
  186. $order_goods_info = model('order_goods')->getInfo([ 'order_goods_id' => $order_goods_id ], 'refund_mode');
  187. if ($order_goods_info[ 'refund_mode' ] == 1) {
  188. $res = model("fenxiao_order")->update([ 'is_refund' => 1 ], [ [ 'order_goods_id', '=', $order_goods_id ] ]);
  189. return $this->success($res);
  190. }
  191. }
  192. /**
  193. * 订单结算
  194. * @param $order_id
  195. */
  196. public function settlement($order_id)
  197. {
  198. //获取未退款的和未结算的分销订单
  199. $fenxiao_orders = model("fenxiao_order")->getList([ [ 'order_id', '=', $order_id ], [ 'is_settlement', '=', 0 ], [ 'is_refund', '=', 0 ] ], '*');
  200. //同时修改分销订单状态为已结算
  201. model("fenxiao_order")->startTrans();
  202. try {
  203. model('fenxiao_order')->update([ 'is_settlement' => 1 ], [ [ 'order_id', '=', $order_id ] ]);
  204. $commission = 0;
  205. $fenxiao_account = new FenxiaoAccount();
  206. $site_id = 0;
  207. foreach ($fenxiao_orders as $fenxiao_order) {
  208. $site_id = $fenxiao_order[ 'site_id' ];
  209. $commission += $fenxiao_order[ 'one_commission' ];
  210. $fenxiao_account->addAccount($fenxiao_order[ 'one_fenxiao_id' ], $fenxiao_order[ 'one_fenxiao_name' ], 'order', $fenxiao_order[ 'one_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
  211. // 分销佣金发放通知
  212. ( new Message() )->sendMessage([
  213. 'keywords' => 'COMMISSION_GRANT',
  214. 'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
  215. 'site_id' => $fenxiao_order[ 'site_id' ],
  216. 'level' => 'one',
  217. ]);
  218. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'one_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'one_commission' ]);
  219. if ($fenxiao_order[ 'two_commission' ] > 0) {
  220. $commission += $fenxiao_order[ 'two_commission' ];
  221. $fenxiao_account->addAccount($fenxiao_order[ 'two_fenxiao_id' ], $fenxiao_order[ 'two_fenxiao_name' ], 'order', $fenxiao_order[ 'two_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
  222. // 分销佣金发放通知
  223. ( new Message() )->sendMessage([
  224. 'keywords' => 'COMMISSION_GRANT',
  225. 'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
  226. 'site_id' => $fenxiao_order[ 'site_id' ],
  227. 'level' => 'two',
  228. ]);
  229. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'two_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'two_commission' ]);
  230. }
  231. if ($fenxiao_order[ 'three_commission' ] > 0) {
  232. $commission += $fenxiao_order[ 'three_commission' ];
  233. $fenxiao_account->addAccount($fenxiao_order[ 'three_fenxiao_id' ], $fenxiao_order[ 'three_fenxiao_name' ], 'order', $fenxiao_order[ 'three_commission' ], $fenxiao_order[ 'fenxiao_order_id' ]);
  234. // 分销佣金发放通知
  235. ( new Message() )->sendMessage([
  236. 'keywords' => 'COMMISSION_GRANT',
  237. 'order_id' => $fenxiao_order[ 'fenxiao_order_id' ],
  238. 'site_id' => $fenxiao_order[ 'site_id' ],
  239. 'level' => 'three',
  240. ]);
  241. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order[ 'three_fenxiao_id' ] ] ], 'total_commission', $fenxiao_order[ 'three_commission' ]);
  242. }
  243. }
  244. $stat_model = new Stat();
  245. $stat_model->switchStat([ 'type' => 'fenxiao_order', 'data' => [ 'order_id' => $order_id, 'site_id' => $site_id ] ]);
  246. //增加订单佣金结算
  247. model('order')->setInc([ [ 'order_id', '=', $order_id ] ], 'commission', $commission);
  248. model("fenxiao_order")->commit();
  249. return $this->success();
  250. } catch (\Exception $e) {
  251. model("fenxiao_order")->rollback();
  252. return $this->error($e->getMessage());
  253. }
  254. }
  255. /**
  256. * calculateOrder 计算对应分销商的第一次订单数量&&金额
  257. * @param $order_id
  258. */
  259. public function calculateOrder($order_id)
  260. {
  261. $fenxiao_order_info = model('fenxiao_order')->getFirstData([ [ 'order_id', '=', $order_id ] ], 'one_fenxiao_id');
  262. if (!empty($fenxiao_order_info)) {
  263. $one_commission_sum = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'one_commission');
  264. $one_fenxiao_total_order = model('fenxiao_order')->getSum([ [ 'order_id', '=', $order_id ] ], 'real_goods_money');
  265. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_order_num');
  266. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_order_money', $one_commission_sum);
  267. model('fenxiao')->setInc([ [ 'fenxiao_id', '=', $fenxiao_order_info[ 'one_fenxiao_id' ] ] ], 'one_fenxiao_total_order', $one_fenxiao_total_order);
  268. // 分销商检测升级
  269. event('FenxiaoUpgrade', $fenxiao_order_info[ 'one_fenxiao_id' ]);
  270. }
  271. return $this->success();
  272. }
  273. /**
  274. * 获取分销订单列表
  275. * @param unknown $condition
  276. * @param number $page
  277. * @param string $page_size
  278. * @param string $order
  279. */
  280. public function getFenxiaoOrderPageList($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'fo.order_id DESC')
  281. {
  282. $field = '
  283. fo.fenxiao_order_id,fo.order_no,fo.site_id,fo.site_name,fo.sku_id,fo.sku_name,fo.sku_image,fo.price,fo.num,fo.real_goods_money,fo.member_name,
  284. fo.member_mobile,fo.one_fenxiao_name,fo.is_settlement,fo.commission,fo.is_refund,
  285. o.order_status_name,o.create_time,fo.one_fenxiao_id,fo.two_fenxiao_id,fo.three_fenxiao_id,fo.one_commission,fo.two_commission,fo.three_commission
  286. ';
  287. $alias = 'fo';
  288. $join = [
  289. [
  290. 'order o',
  291. 'fo.order_id = o.order_id',
  292. 'inner'
  293. ]
  294. ];
  295. $list = model('fenxiao_order')->pageList($condition, $field, $order, $page, $page_size, $alias, $join);
  296. return $this->success($list);
  297. }
  298. /**
  299. * 查询订单信息
  300. * @param $condition
  301. * @param string $field
  302. * @return array
  303. */
  304. public function getFenxiaoOrderInfo($condition, $field = '*')
  305. {
  306. $fenxiao_order_info = model('fenxiao_order')->getInfo($condition, $field);
  307. return $this->success($fenxiao_order_info);
  308. }
  309. /**
  310. * 查询订单信息
  311. * @param $condition
  312. * @param string $field
  313. * @return array
  314. */
  315. public function getFenxiaoOrderInfoNew($condition, $field = '*')
  316. {
  317. $alias = "fo";
  318. $join = [
  319. [
  320. 'order o',
  321. 'o.order_id = fo.order_id',
  322. 'left'
  323. ]
  324. ];
  325. $fenxiao_order_info = model('fenxiao_order')->getInfo($condition, $field, $alias, $join);
  326. return $this->success($fenxiao_order_info);
  327. }
  328. /**
  329. * 查询分销订单列表(管理端调用)
  330. */
  331. public function getFenxiaoOrderPage($condition = [], $page = 1, $page_size = PAGE_LIST_ROWS, $order = 'order_id DESC')
  332. {
  333. $field = 'order_id,order_no,site_name,member_name,create_time,is_settlement,fenxiao_order_id';
  334. $list = model('fenxiao_order')->pageList($condition, $field, $order, $page, $page_size, 'fo', [], 'order_id');
  335. if (!empty($list[ 'list' ])) {
  336. foreach ($list[ 'list' ] as $k => $item) {
  337. $order_info = model('order')->getInfo([ [ 'order_id', '=', $item[ 'order_id' ] ] ], 'name,full_address,mobile,order_status_name');
  338. $list[ 'list' ][ $k ] = array_merge($list[ 'list' ][ $k ], $order_info);
  339. $order_goods = model('fenxiao_order')->getList([ [ 'order_id', '=', $item[ 'order_id' ] ] ]);
  340. $list[ 'list' ][ $k ][ 'order_goods' ] = $order_goods;
  341. }
  342. }
  343. return $this->success($list);
  344. }
  345. /**
  346. * 获取分销订单详情
  347. * @param $order_id
  348. */
  349. public function getFenxiaoOrderDetail($condition, $field = '*')
  350. {
  351. $order_info = model('order')->getInfo($condition, $field);
  352. if (!empty($order_info)) {
  353. $order_goods = model('fenxiao_order')->getList([ [ 'order_id', '=', $order_info[ 'order_id' ] ] ]);
  354. $member_info = model("member")->getInfo([ 'member_id' => $order_info[ 'member_id' ] ], "nickname");
  355. $order_info[ 'order_goods' ] = $order_goods;
  356. $order_info[ 'nickname' ] = $member_info[ 'nickname' ];
  357. }
  358. return $this->success($order_info);
  359. }
  360. /**
  361. * 获取分销订单数量
  362. * @param $condition
  363. */
  364. public function getFenxiaoOrderCount($condition)
  365. {
  366. $count = model('fenxiao_order')->getCount($condition);
  367. return $this->success($count);
  368. }
  369. /**
  370. * 获取分销订单总和
  371. * @param array $condition
  372. * @param string $field
  373. * @param string $alias
  374. * @param null $join
  375. * @return array
  376. */
  377. public function getFenxiaoOrderSum(array $condition, $field = '', $alias = 'a', $join = null)
  378. {
  379. $data = model('fenxiao_order')->getSum($condition, $field, $alias, $join);
  380. return $this->success($data);
  381. }
  382. /**
  383. * 查询订单数据并导出
  384. * @param $condition
  385. */
  386. public function orderExport($condition, $site_id = 0)
  387. {
  388. $field = [
  389. 'order_no' => '订单编号',
  390. 'site_name' => '站点名称',
  391. 'sku_name' => '商品名称',
  392. 'member_name' => '购买人',
  393. 'member_mobile' => '购买人电话',
  394. 'commission' => '总佣金',
  395. 'one_rate' => '一级分销比例',
  396. 'one_commission' => '一级分销佣金',
  397. 'one_fenxiao_name' => '一级分销商名',
  398. 'two_rate' => '二级分销比例',
  399. 'two_commission' => '二级分销佣金',
  400. 'two_fenxiao_name' => '二级分销商名',
  401. 'three_rate' => '三级分销比例',
  402. 'three_commission' => '三级分销佣金',
  403. 'three_fenxiao_name' => '三级分销商名',
  404. 'is_settlement' => '是否结算',
  405. 'is_refund' => '是否退款',
  406. 'province_name' => '省',
  407. 'city_name' => '市',
  408. 'district_name' => '县',
  409. 'full_address' => '详细地址',
  410. 'order_status_name' => '订单状态'
  411. ];
  412. $fields = 'fo.*,o.address,o.full_address,o.order_status_name';
  413. $alias = 'fo';
  414. $join = [
  415. [
  416. 'order o',
  417. 'o.order_id = fo.order_id',
  418. 'left'
  419. ]
  420. ];
  421. $list = model('fenxiao_order')->getList($condition, $fields, '', $alias, $join);
  422. $head_html = [];
  423. $line_html = [];
  424. foreach ($field as $k => $v) {
  425. $head_html[] = $v;
  426. $line_html[] = $k;
  427. }
  428. $temp_line = implode(',', $head_html) . "\n";
  429. $html = str_replace("\n", '', $temp_line) . "\n";
  430. $line = implode(',', $line_html);
  431. $html .= str_replace("\n", '', $line) . "\n";
  432. $temp = [];
  433. foreach ($line_html as $temp_line_k => $temp_line_v) {
  434. $temp[] = "{\$$temp_line_v}";
  435. }
  436. $tempLine = implode(',', $temp) . "\n";
  437. foreach ($list as $item) {
  438. $new_line_value = $tempLine;
  439. $address_arr = explode("-", $item[ 'full_address' ]);
  440. $item[ 'province_name' ] = !empty($address_arr[ 0 ]) ? $address_arr[ 0 ] : "";
  441. $item[ 'city_name' ] = !empty($address_arr[ 1 ]) ? $address_arr[ 1 ] : "";
  442. $item[ 'district_name' ] = !empty($address_arr[ 2 ]) ? $address_arr[ 2 ] : "";
  443. $item[ 'is_settlement' ] = $item[ 'is_settlement' ] == 0 ? "否" : "是";
  444. $item[ 'is_refund' ] = $item[ 'is_refund' ] == 0 ? "否" : "是";
  445. foreach ($item as $key => $val) {
  446. if ($key == 'full_address') {
  447. $address = $item[ 'address' ] ?? '';
  448. $val = $val . $address;
  449. }
  450. //CSV比较简单,记得转义 逗号就好
  451. $values = str_replace(',', '\\', $val . "\t");
  452. $values = str_replace("\n", '', $values);
  453. $new_line_value = str_replace("{\$$key}", $values, $new_line_value);
  454. }
  455. $html .= $new_line_value;
  456. }
  457. $filename = date('YmdHis') . '.csv'; //设置文件名
  458. header("Content-type:text/csv");
  459. header("Content-Disposition:attachment;filename=" . $filename);
  460. header('Cache-Control:must-revalidate,post-check=0,pre-check=0');
  461. header('Expires:0');
  462. header('Pragma:public');
  463. exit(mb_convert_encoding($html, "GBK", "UTF-8"));
  464. }
  465. /**
  466. * 给csv写入新的数据
  467. * @param $item_list
  468. * @param $field_key
  469. * @param $temp_line
  470. * @param $fp
  471. */
  472. public function itemExport($item_list, $field_key, $temp_line, $fp)
  473. {
  474. $item_list = $item_list->toArray();
  475. foreach ($item_list as $k => $item_v) {
  476. $new_line_value = $temp_line;
  477. //省市县
  478. $address_arr = explode("-", $item_v[ 'full_address' ]);
  479. $item_v[ 'province_name' ] = $address_arr[ 0 ] ? $address_arr[ 0 ] : "";
  480. $item_v[ 'city_name' ] = $address_arr[ 1 ] ? $address_arr[ 1 ] : "";
  481. $item_v[ 'district_name' ] = $address_arr[ 2 ] ? $address_arr[ 2 ] : "";
  482. foreach ($item_v as $key => $value) {
  483. if ($key == 'full_address') {
  484. $address = $item_v[ 'address' ] ?? '';
  485. $value = $value . $address;
  486. }
  487. //CSV比较简单,记得转义 逗号就好
  488. $values = str_replace(',', '\\', $value . "\t");
  489. $values = str_replace("\n", '', $values);
  490. $new_line_value = str_replace("{\$$key}", $values, $new_line_value);
  491. }
  492. //写入第一行表头
  493. fwrite($fp, $new_line_value);
  494. dump($new_line_value);
  495. exit;
  496. //销毁变量, 防止内存溢出
  497. unset($new_line_value);
  498. }
  499. }
  500. }