TradeStatisticServices.php 36 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | CRMEB [ CRMEB赋能开发者,助力企业发展 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2016~2023 https://www.crmeb.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed CRMEB并不是自由软件,未经许可不能去掉CRMEB相关版权
  8. // +----------------------------------------------------------------------
  9. // | Author: CRMEB Team <admin@crmeb.com>
  10. // +----------------------------------------------------------------------
  11. namespace app\services\statistic;
  12. use app\services\BaseServices;
  13. use app\services\order\StoreOrderRefundServices;
  14. use app\services\other\export\ExportServices;
  15. use app\services\order\OtherOrderServices;
  16. use app\services\order\StoreOrderServices;
  17. use app\services\user\UserExtractServices;
  18. use app\services\user\UserMoneyServices;
  19. use app\services\user\UserRechargeServices;
  20. /**
  21. * Class TradeStatisticServices
  22. * @package app\services\statistic
  23. */
  24. class TradeStatisticServices extends BaseServices
  25. {
  26. public $_day = ['00时', '01时', '02时', '03时', '04时', '05时', '06时', '07时', '08时', '09时', '10时', '11时', '12时', '13时', '14时', '15时', '16时', '17时', '18时', '19时', '20时', '21时', '22时', '23时', '24时'];
  27. /**
  28. * 基本概况
  29. * @param $where
  30. * @return mixed
  31. */
  32. public function getTopLeftTrade($where)
  33. {
  34. //总交易额
  35. $selectType = "sum";
  36. $tradeTotalMoney = $this->tradeTotalMoney($where, $selectType);
  37. //交易曲线
  38. $selectType = "group";
  39. $hourTotalMoney = $this->tradeGroupMoney($where, $selectType);
  40. return ['total_money' => $tradeTotalMoney, 'curve' => $hourTotalMoney];
  41. }
  42. public function getTopRightOneTrade()
  43. {
  44. /** @var StoreOrderServices $orderService */
  45. $orderService = app()->make(StoreOrderServices::class);
  46. /** day订单数 */
  47. //今日订单数
  48. $orderCountWhere['is_del'] = 0;
  49. $orderCountWhere['paid'] = 1;
  50. $orderCountWhere['pid'] = 0;
  51. $orderCountWhere['timeKey'] = $this->TimeConvert("today");
  52. $todayOrderCount = $orderService->getOrderCountByWhere($orderCountWhere);
  53. //今日订单数曲线
  54. $todayHourOrderCount = $orderService->getOrderGroupCountByWhere($orderCountWhere);
  55. $todayHourOrderCount = $this->trendYdata($todayHourOrderCount, $orderCountWhere['timeKey']);
  56. //昨日订单数
  57. $yestodayWhere['is_del'] = 0;
  58. $yestodayWhere['paid'] = 1;
  59. $yestodayWhere['pid'] = 0;
  60. $yestodayWhere['timeKey'] = $this->TimeConvert("yestoday");
  61. $yesTodayOrderCount = $orderService->getOrderCountByWhere($yestodayWhere);
  62. //昨日订单曲线
  63. // $yestodayHourOrderCount = $orderService->getOrderGroupCountByWhere($yestodayWhere);
  64. // $yestodayHourOrderCount = $this->trendYdata($yestodayHourOrderCount, 'day');
  65. //订单数环比增长率
  66. $orderCountDayChain = $this->countRate($todayOrderCount, $yesTodayOrderCount);
  67. $data[] = [
  68. 'name' => "今日订单数",
  69. 'now_value' => $todayOrderCount,
  70. 'last_value' => $yesTodayOrderCount,
  71. 'rate' => $orderCountDayChain,
  72. 'curve' => $todayHourOrderCount
  73. ];
  74. /** day支付人数 */
  75. //今日支付人数
  76. $orderPeopleWhere['timeKey'] = $this->TimeConvert("today");
  77. $orderPeopleWhere['paid'] = 1;
  78. $orderPeopleWhere['pid'] = 0;
  79. $todayPayOrderPeople = count($orderService->getPayOrderPeopleByWhere($orderPeopleWhere));
  80. //今日支付人数曲线
  81. $todayHourOrderPeople = $orderService->getPayOrderGroupPeopleByWhere($orderPeopleWhere);
  82. $todayHourOrderPeople = $this->trendYdata($todayHourOrderPeople, $orderPeopleWhere['timeKey']);
  83. //昨日支付人数
  84. $yestodayOrderPeopleWhere['timeKey'] = $this->TimeConvert("yestoday");
  85. $yestodayOrderPeopleWhere['paid'] = 1;
  86. $yestodayPayOrderPeople = count($orderService->getPayOrderPeopleByWhere($yestodayOrderPeopleWhere));
  87. //昨日支付曲线
  88. // $yestodayHourOrderPeople = $orderService->getPayOrderGroupPeopleByWhere($yestodayOrderPeopleWhere);
  89. // $yestodayHourOrderPeople = $this->trendYdata($yestodayHourOrderPeople, 'day');
  90. //订单支付人数环比
  91. $orderPeopleDayChain = $this->countRate($todayPayOrderPeople, $yestodayPayOrderPeople);
  92. $data[] = [
  93. 'name' => "今日支付人数",
  94. 'now_value' => $todayPayOrderPeople,
  95. 'last_value' => $yestodayPayOrderPeople,
  96. 'rate' => $orderPeopleDayChain,
  97. 'curve' => $todayHourOrderPeople
  98. ];
  99. $new_data = [];
  100. foreach ($data as $k => $v) {
  101. $new_data['x'] = $v['curve']['x'];
  102. $new_data['series'][$k]['name'] = $v['name'];
  103. $new_data['series'][$k]['now_money'] = $v['now_value'];
  104. $new_data['series'][$k]['last_money'] = $v['last_value'];
  105. $new_data['series'][$k]['rate'] = $v['rate'];
  106. $new_data['series'][$k]['value'] = array_values($v['curve']['y']);
  107. }
  108. return $new_data;
  109. }
  110. public function getTopRightTwoTrade()
  111. {
  112. /** @var StoreOrderServices $orderService */
  113. $orderService = app()->make(StoreOrderServices::class);
  114. /** month订单数 */
  115. $monthOrderCountWhere['is_del'] = 0;
  116. $monthOrderCountWhere['paid'] = 1;
  117. $monthOrderCountWhere['pid'] = 0;
  118. $monthOrderCountWhere['timeKey'] = $this->TimeConvert("month");
  119. $monthOrderCount = $orderService->getOrderCountByWhere($monthOrderCountWhere);
  120. //本月订单数曲线
  121. $monthCurveOrderCount = $orderService->getOrderGroupCountByWhere($monthOrderCountWhere);
  122. $monthCurveOrderCount = $this->trendYdata($monthCurveOrderCount, $monthOrderCountWhere['timeKey']);
  123. //上月订单数
  124. $lastOrderCountWhere['timeKey'] = $this->TimeConvert("last_month");
  125. $lastOrderCountWhere['is_del'] = 0;
  126. $lastOrderCountWhere['paid'] = 1;
  127. $lastOrderCountWhere['pid'] = 0;
  128. $lastOrderCount = $orderService->getOrderCountByWhere($lastOrderCountWhere);
  129. //上月订单曲线
  130. // $lastCurveOrderCount = $orderService->getOrderGroupCountByWhere($lastOrderCountWhere);
  131. // $lastCurveOrderCount = $this->trendYdata($lastCurveOrderCount, 'month');
  132. //订单数环比增长率
  133. // $orderCountMonthChain = (($monthOrderCount - $lastOrderCount) / $lastOrderCount) * 100;
  134. $orderCountMonthChain = $this->countRate($monthOrderCount, $lastOrderCount);
  135. $data[] = [
  136. 'name' => "本月订单数",
  137. 'now_value' => $monthOrderCount,
  138. 'last_value' => $lastOrderCount,
  139. 'rate' => $orderCountMonthChain,
  140. 'curve' => $monthCurveOrderCount
  141. ];
  142. /** month下单人数 */
  143. //本月支付人数
  144. $monthOrderPeopleWhere['timeKey'] = $this->TimeConvert("month");;
  145. $monthOrderPeopleWhere['paid'] = 1;
  146. $monthPayOrderPeople = count($orderService->getPayOrderPeopleByWhere($monthOrderPeopleWhere));
  147. //本月支付人数曲线
  148. $monthCurveOrderPeople = $orderService->getPayOrderGroupPeopleByWhere($monthOrderPeopleWhere);
  149. $monthCurveOrderPeople = $this->trendYdata($monthCurveOrderPeople, $monthOrderPeopleWhere['timeKey']);
  150. //上月支付人数
  151. $lastOrderPeopleWhere['timeKey'] = $this->TimeConvert("last_month");
  152. $lastOrderPeopleWhere['paid'] = 1;
  153. $lastPayOrderPeople = count($orderService->getPayOrderPeopleByWhere($lastOrderPeopleWhere));
  154. //上月支付曲线
  155. // $lastCurveOrderPeople = $orderService->getPayOrderGroupPeopleByWhere($lastOrderPeopleWhere);
  156. // $lastCurveOrderPeople = $this->trendYdata($lastCurveOrderPeople, 'month');
  157. //订单支付人数环比
  158. $orderPeopleDayChain = $this->countRate($monthPayOrderPeople, $lastPayOrderPeople);
  159. $data[] = [
  160. 'name' => "本月支付人数",
  161. 'now_value' => $monthPayOrderPeople,
  162. 'last_value' => $lastPayOrderPeople,
  163. 'rate' => $orderPeopleDayChain,
  164. 'curve' => $monthCurveOrderPeople
  165. ];
  166. $new_data = [];
  167. foreach ($data as $k => $v) {
  168. $new_data[$k]['name'] = $v['name'];
  169. $new_data[$k]['now_money'] = $v['now_value'];
  170. $new_data[$k]['last_money'] = $v['last_value'];
  171. $new_data[$k]['rate'] = $v['rate'];
  172. $new_data[$k]['value'] = $v['curve']['y'];
  173. }
  174. return $new_data;
  175. }
  176. /**
  177. * 交易总额
  178. * @param $where
  179. * @param $selectType
  180. * @return array|float|int|mixed
  181. */
  182. public function tradeTotalMoney($where, $selectType, $isNum = false)
  183. {
  184. /** 收入营业额 */
  185. //商品订单收入
  186. $inOrderMoney = $this->getOrderTotalMoney($where, $selectType, "", $isNum);
  187. //用户充值收入
  188. $inRechargeMoneyHome = $this->getRechargeTotalMoney($where, $selectType, "", $isNum);
  189. $inrechgeMoneyAdmin = $this->getBillYeTotalMoney($where, $selectType, '', $isNum);
  190. $inRechargeMoney = bcadd($inRechargeMoneyHome, $inrechgeMoneyAdmin, 2);
  191. //购买会员收入
  192. $inMemberMoney = $this->getMemberTotalMoney($where, $selectType, "", $isNum);
  193. //线下收款收入
  194. $inOfflineMoney = $this->getOfflineTotalMoney($where, $selectType, "", $isNum);
  195. //总交易额
  196. $inTotalMoney = bcadd(bcadd($inOrderMoney, $inRechargeMoney, 2), bcadd($inMemberMoney, $inOfflineMoney, 2), 2);/* - $outExtractUserMoney*/
  197. return $inTotalMoney;
  198. }
  199. /**
  200. * 交易额曲线图
  201. * @param $where
  202. * @param $selectType
  203. * @return array
  204. */
  205. public function tradeGroupMoney($where, $selectType)
  206. {
  207. //商品订单收入
  208. $orderGroup = "add_time";
  209. $OrderMoney = $this->getOrderTotalMoney($where, $selectType, $orderGroup);
  210. //用户充值收入
  211. $rechargeGroup = "add_time";
  212. $RechargeMoneyHome = $this->getRechargeTotalMoney($where, $selectType, $rechargeGroup);
  213. $RechargeMoneyAdmin = $this->getBillYeTotalMoney($where, $selectType, $rechargeGroup);
  214. $RechargeMoney = $this->totalArrData([$RechargeMoneyHome, $RechargeMoneyAdmin]);
  215. //购买会员收入
  216. $memberGroup = "add_time";
  217. $MemberMoney = $this->getMemberTotalMoney($where, $selectType, $memberGroup);
  218. //线下收款收入
  219. $offlineGroup = "add_time";
  220. $OfflineMoney = $this->getOfflineTotalMoney($where, $selectType, $offlineGroup);
  221. return $this->totalArrData([$OrderMoney, $RechargeMoney, $MemberMoney, $OfflineMoney]);
  222. }
  223. /**
  224. * 底部数据
  225. * @param $where
  226. * @return array
  227. * @throws \Exception
  228. */
  229. public function getBottomTrade($where)
  230. {
  231. if (!$where['data']) {
  232. $where['time'] = ['start_time' => date('Y-m-d 00:00:00', time()), "end_time" => date('Y-m-d 23:59:59', time())];
  233. } else {
  234. $time = explode("-", $where['data']);
  235. $where['time'] = ['start_time' => date('Y-m-d 00:00:00', strtotime($time[0])), "end_time" => date('Y-m-d 23:59:59', strtotime($time[1]))];
  236. }
  237. unset($where['data']);
  238. /** @var ExportServices $exportService */
  239. $exportService = app()->make(ExportServices::class);
  240. $chainTime = $this->chainTime($where['time']);
  241. $isNum = false;
  242. if ($chainTime == "other") $isNum = true;
  243. $dateWhere['time'] = $isNum ? $where['time'] : $chainTime;
  244. $topData = array();
  245. $Chain = array();
  246. /** 商品支付金额 */
  247. $OrderMoney = $this->getOrderTotalMoney($where, "sum");
  248. $lastOrderMoney = $this->getOrderTotalMoney($dateWhere, "sum", "", $isNum);
  249. $OrderCurve = $this->getOrderTotalMoney($where, "group", "add_time");
  250. $OrderChain = $this->countRate($OrderMoney, $lastOrderMoney);
  251. $topData[2] = [
  252. 'title' => '商品支付金额',
  253. 'desc' => '选定条件下,用户购买商品的实际支付金额,包括微信支付、余额支付、支付宝支付、线下支付金额(拼团商品在成团之后计入,线下支付订单在后台确认支付后计入)',
  254. 'total_money' => $OrderMoney,
  255. 'rate' => $OrderChain,
  256. 'value' => $OrderCurve['y'],
  257. 'type' => 1,
  258. 'sign' => 'goods',
  259. ];
  260. $Chain['goods'] = $OrderCurve;
  261. /** 购买会员金额 */
  262. $memberMoney = $this->getMemberTotalMoney($where, 'sum');
  263. $lastMemberMoney = $this->getMemberTotalMoney($dateWhere, 'sum', "", $isNum);
  264. $memberCurve = $this->getMemberTotalMoney($where, 'group', "pay_time");
  265. $MemberChain = $this->countRate($memberMoney, $lastMemberMoney);
  266. $topData[3] = [
  267. 'title' => '购买会员金额',
  268. 'desc' => '选定条件下,用户成功购买付费会员的金额',
  269. 'total_money' => $memberMoney,
  270. 'rate' => $MemberChain,
  271. 'value' => $memberCurve['y'],
  272. 'type' => 1,
  273. 'sign' => 'member',
  274. ];
  275. $Chain['member'] = $memberCurve;
  276. /** 充值金额 */
  277. $rechgeMoneyHome = $this->getRechargeTotalMoney($where, 'sum');
  278. $rechgeMoneyAdmin = $this->getBillYeTotalMoney($where, 'sum');
  279. $rechgeMoneyTotal = bcadd($rechgeMoneyHome, $rechgeMoneyAdmin, 2);
  280. $lastRechgeMoneyHome = $this->getRechargeTotalMoney($dateWhere, 'sum', "", $isNum);
  281. $lastRechgeMoneyAdmin = $this->getBillYeTotalMoney($dateWhere, 'sum', "", $isNum);
  282. $lastRechgeMoneyTotal = bcadd($lastRechgeMoneyHome, $lastRechgeMoneyAdmin, 2);
  283. $RechgeHomeCurve = $this->getRechargeTotalMoney($where, 'group', "pay_time");
  284. $RechgeAdminCurve = $this->getBillYeTotalMoney($where, 'group', "add_time");
  285. $RechgeTotalCurve = $this->totalArrData([$RechgeHomeCurve, $RechgeAdminCurve]);
  286. $RechgeChain = $this->countRate($rechgeMoneyTotal, $lastRechgeMoneyTotal);
  287. $topData[4] = [
  288. 'title' => '充值金额',
  289. 'desc' => '选定条件下,用户成功充值的金额',
  290. 'total_money' => $rechgeMoneyTotal,
  291. 'rate' => $RechgeChain,
  292. 'value' => $RechgeTotalCurve['y'],
  293. 'type' => 1,
  294. 'sign' => 'rechge',
  295. ];
  296. $Chain['rechage'] = $RechgeTotalCurve;
  297. /** 线下收银 */
  298. $offlineMoney = $this->getOfflineTotalMoney($where, 'sum');
  299. $lastOfflineMoney = $this->getOfflineTotalMoney($dateWhere, 'sum', "", $isNum);
  300. $offlineCurve = $this->getOfflineTotalMoney($where, 'group', "pay_time");
  301. $offlineChain = $this->countRate($offlineMoney, $lastOfflineMoney);
  302. $topData[5] = [
  303. 'title' => '线下收银金额',
  304. 'desc' => '选定条件下,用户在线下扫码支付的金额',
  305. 'total_money' => $offlineMoney,
  306. 'rate' => $offlineChain,
  307. 'value' => $offlineCurve['y'],
  308. 'type' => 0,
  309. 'sign' => 'offline',
  310. ];
  311. $Chain['offline'] = $offlineCurve;
  312. /** 支出*/
  313. //余额支付商品
  314. $outYeOrderMoney = $this->getOrderTotalMoney(['pay_type' => "yue", 'time' => $where['time']], 'sum');
  315. $lastOutYeOrderMoney = $this->getOrderTotalMoney(['pay_type' => "yue", 'time' => $dateWhere['time']], 'sum', "", $isNum);
  316. $outYeOrderCurve = $this->getOrderTotalMoney(['pay_type' => "yue", 'time' => $where['time']], 'group', 'pay_time');
  317. $outYeOrderChain = $this->countRate($outYeOrderMoney, $lastOutYeOrderMoney);
  318. //余额购买会员
  319. $outYeMemberMoney = $this->getMemberTotalMoney(['pay_type' => "yue", 'time' => $where['time']], 'sum');
  320. $lastOutYeMemberMoney = $this->getMemberTotalMoney(['pay_type' => "yue", 'time' => $dateWhere['time']], 'sum', "", $isNum);
  321. $outYeMemberCurve = $this->getMemberTotalMoney(['pay_type' => "yue", 'time' => $where['time']], 'group', "pay_time");
  322. $outYeMemberChain = $this->countRate($outYeMemberMoney, $lastOutYeMemberMoney);
  323. //余额支付
  324. $outYeMoney = bcadd($outYeOrderMoney, $outYeMemberMoney, 2);
  325. $lastOutYeMoney = bcadd($lastOutYeOrderMoney, $lastOutYeMemberMoney, 2);
  326. $outYeCurve = $this->totalArrData([$outYeOrderCurve, $outYeMemberCurve]);
  327. $outYeChain = $this->countRate($outYeOrderChain, $outYeMemberChain);
  328. $topData[7] = [
  329. 'title' => '余额支付金额',
  330. 'desc' => '用户下单时使用余额实际支付的金额',
  331. 'total_money' => $outYeMoney,
  332. 'rate' => $outYeChain,
  333. 'value' => $outYeCurve['y'],
  334. 'type' => 0,
  335. 'sign' => 'yue',
  336. ];
  337. $Chain['out_ye'] = $outYeCurve;
  338. //支付佣金金额
  339. $outExtractMoney = $this->getExtractTotalMoney($where, 'sum');
  340. $lastOutExtractMoney = $this->getExtractTotalMoney($dateWhere, 'sum', "", $isNum);
  341. $OutExtractCurve = $this->getExtractTotalMoney($where, 'group', "add_time");
  342. $OutExtractChain = $this->countRate($outExtractMoney, $lastOutExtractMoney);
  343. $topData[8] = [
  344. 'title' => '支付佣金金额',
  345. 'desc' => '后台给推广员支付的推广佣金,以实际支付为准',
  346. 'total_money' => $outExtractMoney,
  347. 'rate' => $OutExtractChain,
  348. 'value' => $OutExtractCurve['y'],
  349. 'type' => 0,
  350. 'sign' => 'yong',
  351. ];
  352. $Chain['extract'] = $OutExtractCurve;
  353. //商品退款金额
  354. $outOrderRefund = $this->getOrderRefundTotalMoney(['refund_type' => 6, 'time' => $where['time']], 'sum');
  355. $lastOutOrderRefund = $this->getOrderRefundTotalMoney(['refund_type' => 6, 'time' => $dateWhere['time']], 'sum', "", $isNum);
  356. $outOrderRefundCurve = $this->getOrderRefundTotalMoney(['refund_type' => 6, 'time' => $where['time']], 'group', 'add_time');
  357. $orderRefundChain = $this->countRate($outOrderRefund, $lastOutOrderRefund);
  358. $topData[9] = [
  359. 'title' => '商品退款金额',
  360. 'desc' => '用户成功退款的商品金额',
  361. 'total_money' => $outOrderRefund,
  362. 'rate' => $orderRefundChain,
  363. 'value' => $outOrderRefundCurve['y'],
  364. 'type' => 0,
  365. 'sign' => 'refund',
  366. ];
  367. $Chain['refund'] = $outOrderRefundCurve;
  368. //支出金额
  369. $outTotalMoney = bcadd(bcadd($outYeMoney, $outExtractMoney, 2), $outOrderRefund, 2);
  370. $lastOutTotalMoney = bcadd(bcadd($lastOutYeMoney, $lastOutExtractMoney, 2), $lastOutOrderRefund, 2);
  371. $outTotalCurve = $this->totalArrData([$outYeCurve, $OutExtractCurve, $outOrderRefundCurve]);
  372. $outTotalChain = $this->countRate($outTotalMoney, $lastOutTotalMoney);
  373. $topData[6] = [
  374. 'title' => '支出金额',
  375. 'desc' => '余额支付金额、支付佣金金额、商品退款金额',
  376. 'total_money' => $outTotalMoney,
  377. 'rate' => $outTotalChain,
  378. 'value' => $outTotalCurve['y'],
  379. 'type' => 1,
  380. 'sign' => 'out',
  381. ];
  382. $Chain['out'] = $outTotalCurve;
  383. /** 交易毛利金额*/
  384. $jiaoyiMoney = $this->tradeTotalMoney($where, "sum");
  385. $jiaoyiMoney = bcsub($jiaoyiMoney, $outTotalMoney, 2);
  386. $lastJiaoyiMoney = $this->tradeTotalMoney($dateWhere, "sum", $isNum);
  387. $lastJiaoyiMoney = bcsub($lastJiaoyiMoney, $lastOutTotalMoney, 2);
  388. $jiaoyiCurve = $this->tradeGroupMoney($where, "group");
  389. $jiaoyiCurve = $this->subdutionArrData($jiaoyiCurve, $outTotalCurve);
  390. $jiaoyiChain = $this->countRate($jiaoyiMoney, $lastJiaoyiMoney);
  391. $topData[1] = [
  392. 'title' => '交易毛利金额',
  393. 'desc' => '交易毛利金额 = 营业额 - 支出金额',
  394. 'total_money' => $jiaoyiMoney,
  395. 'rate' => $jiaoyiChain,
  396. 'value' => $jiaoyiCurve['y'],
  397. 'type' => 1,
  398. 'sign' => 'jiaoyi',
  399. ];
  400. $Chain['jiaoyi'] = $jiaoyiCurve;
  401. /** @var 营业额 $inTotalMoney */
  402. $inTotalMoney = $this->tradeTotalMoney($where, "sum");
  403. $lastInTotalMoney = $this->tradeTotalMoney($dateWhere, "sum", $isNum);
  404. $inTotalCurve = $this->tradeGroupMoney($where, "group");
  405. $inTotalChain = $this->countRate($inTotalMoney, $lastInTotalMoney);
  406. $topData[0] = [
  407. 'title' => '营业额',
  408. 'desc' => '商品支付金额、充值金额、购买付费会员金额、线下收银金额',
  409. 'total_money' => $inTotalMoney,
  410. 'rate' => $inTotalChain,
  411. 'value' => $inTotalCurve['y'],
  412. 'type' => 1,
  413. 'sign' => 'in',
  414. ];
  415. ksort($topData);
  416. $data = [];
  417. foreach ($topData as $k => $v) {
  418. $data['x'] = $Chain['out']['x'];
  419. $data['series'][$k]['name'] = $v['title'];
  420. $data['series'][$k]['desc'] = $v['desc'];
  421. $data['series'][$k]['money'] = $v['total_money'];
  422. $data['series'][$k]['type'] = $v['type'];
  423. $data['series'][$k]['rate'] = $v['rate'];
  424. $data['series'][$k]['value'] = array_values($v['value']);
  425. }
  426. $export = $exportService->tradeData($data, '交易统计', 2);
  427. $data['export'] = $export[0];
  428. return $data;
  429. }
  430. /**
  431. * 多个数组相加
  432. * @param array $arr
  433. * @return array|false
  434. */
  435. public function totalArrData(array $arr)
  436. {
  437. if (!$arr || !is_array($arr)) return false;
  438. $item = array();
  439. $y = array_column($arr, "y");
  440. $x = array_column($arr, "x")[0];
  441. foreach ($y as $key => $value) {
  442. foreach ($value as $k => $v) {
  443. if (isset($item[$k])) {
  444. $item[$k] = bcadd($item[$k], $v, 2);
  445. } else {
  446. $item[$k] = $v;
  447. }
  448. }
  449. }
  450. return ['x' => $x, 'y' => $item];
  451. }
  452. /**
  453. * 数组相减
  454. * @param array $arr1
  455. * @param array $arr2
  456. * @return array
  457. */
  458. public function subdutionArrData(array $arr1, array $arr2)
  459. {
  460. $item = array();
  461. foreach ($arr1['y'] as $key => $value) {
  462. $item['y'][$key] = bcsub($value, $arr2['y'][$key], 2);
  463. }
  464. $item['x'] = $arr1['x'];
  465. return $item;
  466. }
  467. /**
  468. * 搜索时间转换
  469. * @param $timeKey
  470. * @param false $isNum
  471. * @return array
  472. * @throws \Exception
  473. */
  474. public function TimeConvert($timeKey, $isNum = false)
  475. {
  476. switch ($timeKey) {
  477. case "today" :
  478. $data['start_time'] = date('Y-m-d 00:00:00', time());
  479. $data['end_time'] = date('Y-m-d 23:59:59', time());
  480. $data['days'] = 1;
  481. break;
  482. case "yestoday" :
  483. $data['start_time'] = date('Y-m-d 00:00:00', strtotime('-1 day'));
  484. $data['end_time'] = date('Y-m-d 23:59:59', strtotime('-1 day'));
  485. $data['days'] = 1;
  486. break;
  487. case "last_month" :
  488. $data['start_time'] = date('Y-m-01 00:00:00', strtotime('-1 month'));
  489. $data['end_time'] = date('Y-m-t 23:59:59', strtotime('-1 month'));
  490. $data['days'] = 30;
  491. break;
  492. case "month" :
  493. $data['start_time'] = $month_start_time = date('Y-m-01 00:00:00', strtotime(date("Y-m-d")));
  494. $data['end_time'] = date('Y-m-d 23:59:59', strtotime("$month_start_time +1 month -1 day"));
  495. $data['days'] = 30;
  496. break;
  497. case "year" :
  498. $data['start_time'] = date('Y-01-01 00:00:00', time());
  499. $data['end_time'] = date('Y-12-t 23:59:59', time());
  500. $data['days'] = 365;
  501. break;
  502. case "last_year" :
  503. $data['start_time'] = date('Y-01-01 00:00:00', strtotime('-1 year'));
  504. $data['end_time'] = date('Y-12-t 23:59:59', strtotime('-1 year'));
  505. $data['days'] = 365;
  506. break;
  507. case 30 :
  508. case 15 :
  509. case 7 :
  510. if (!$isNum) {
  511. $data['start_time'] = date("Y-m-d 00:00:00", strtotime("-$timeKey day"));
  512. $data['end_time'] = date('Y-m-d 23:59:59', time());
  513. $data['days'] = $timeKey;
  514. } else {
  515. $day = $timeKey * 2;
  516. $data['start_time'] = date("Y-m-d 00:00:00", strtotime("-$day day"));
  517. $data['end_time'] = date("Y-m-d 23:59:59", strtotime("-$timeKey day"));
  518. $data['days'] = $timeKey;
  519. }
  520. break;
  521. default:
  522. $datetime_start = new \DateTime($timeKey['start_time']);
  523. $datetime_end = new \DateTime($timeKey['end_time']);
  524. $days = $datetime_start->diff($datetime_end)->days;
  525. $days = $days > 0 ? $days : 1;
  526. if (!$isNum) {
  527. $data['start_time'] = $timeKey['start_time'];
  528. $data['end_time'] = $timeKey['end_time'];
  529. $data['days'] = $days;
  530. } else {
  531. $data['start_time'] = date("Y-m-d 00:00:00", strtotime("-$days day"));
  532. $data['end_time'] = $timeKey['start_time'];
  533. $data['days'] = $days;
  534. }
  535. }
  536. return $data;
  537. }
  538. /**
  539. * 获取订单退款
  540. * @param $where
  541. * @param string $selectType
  542. * @param string $group
  543. * @param bool $isNum
  544. * @return array|float|int
  545. * @throws \Exception
  546. */
  547. public function getOrderRefundTotalMoney($where, string $selectType, string $group = '', bool $isNum = false)
  548. {
  549. $orderSumField = isset($where['refund_type']) ? "refunded_price" : "refund_price";
  550. $whereOrderMoner['refund_type'] = isset($where['refund_type']) ? $where['refund_type'] : 6;
  551. $whereOrderMoner['is_cancel'] = 0;
  552. $whereOrderMoner['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  553. /** @var StoreOrderRefundServices $storeOrderRefundServices */
  554. $storeOrderRefundServices = app()->make(StoreOrderRefundServices::class);
  555. $totalMoney = $storeOrderRefundServices->getOrderRefundMoneyByWhere($whereOrderMoner, $orderSumField, $selectType, $group);
  556. if ($group) {
  557. $totalMoney = $this->trendYdata($totalMoney, $whereOrderMoner['timeKey']);
  558. }
  559. return $totalMoney;
  560. }
  561. /**
  562. * 获取商品营收
  563. * @param $where
  564. * @param string $selectType
  565. * @param string $group
  566. * @param bool $isNum
  567. * @return array|float|int
  568. * @throws \Exception
  569. */
  570. public function getOrderTotalMoney($where, string $selectType, string $group = "", bool $isNum = false)
  571. {
  572. /** 普通商品订单支付金额 */
  573. /** @var StoreOrderServices $storeOrderService */
  574. $storeOrderService = app()->make(StoreOrderServices::class);
  575. $orderSumField = isset($where['refund_status']) ? "refund_price" : "pay_price";
  576. $whereOrderMoner['refund_status'] = isset($where['refund_status']) ? $where['refund_status'] : 0;
  577. $whereOrderMoner['paid'] = 1;
  578. $whereOrderMoner['pid'] = 0;
  579. if (isset($where['pay_type'])) {
  580. $whereOrderMoner['pay_type'] = $where['pay_type'];
  581. }
  582. $whereOrderMoner['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  583. $totalMoney = $storeOrderService->getOrderMoneyByWhere($whereOrderMoner, $orderSumField, $selectType, $group);
  584. if ($group) {
  585. $totalMoney = $this->trendYdata($totalMoney, $whereOrderMoner['timeKey']);
  586. }
  587. return $totalMoney;
  588. }
  589. /**
  590. * 支付佣金
  591. * @param $where
  592. * @param string $selectType
  593. * @param string $group
  594. * @param bool $isNum
  595. * @return array|float|mixed
  596. * @throws \Exception
  597. */
  598. public function getExtractTotalMoney($where, string $selectType, string $group = "", bool $isNum = false)
  599. {
  600. /** 普通商品订单支付金额 */
  601. /** @var UserExtractServices $extractService */
  602. $extractService = app()->make(UserExtractServices::class);
  603. $orderSumField = "extract_price";
  604. $whereData['status'] = 1;
  605. $whereData['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  606. $totalMoney = $extractService->getOutMoneyByWhere($whereData, $orderSumField, $selectType, $group);
  607. if ($group) {
  608. $totalMoney = $this->trendYdata($totalMoney, $whereData['timeKey']);
  609. }
  610. return $totalMoney;
  611. }
  612. /**
  613. * 获取用户充值营收
  614. * @param array $where
  615. * @param string $selectType
  616. * @param string $group
  617. * @param bool $isNum
  618. * @return array|float|int
  619. * @throws \Exception
  620. */
  621. public function getRechargeTotalMoney(array $where, string $selectType, string $group = "", bool $isNum = false)
  622. {
  623. /** 用户充值金额 */
  624. /** @var UserRechargeServices $userRechageService */
  625. $userRechageService = app()->make(UserRechargeServices::class);
  626. $rechargeSumField = "price";
  627. $whereInRecharge['paid'] = 1;
  628. $whereInRecharge['refund_price'] = '0.00';
  629. $whereInRecharge['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  630. $whereInRecharge['store_id'] = 0;
  631. $totalMoney = $userRechageService->getRechargeMoneyByWhere($whereInRecharge, $rechargeSumField, $selectType, $group);
  632. if ($group) {
  633. $totalMoney = $this->trendYdata($totalMoney, $whereInRecharge['timeKey']);
  634. }
  635. return $totalMoney;
  636. }
  637. /**
  638. * 后台手动充值
  639. * @param array $where
  640. * @param string $selectType
  641. * @param string $group
  642. * @param bool $isNum
  643. * @return array|float|int
  644. * @throws \Exception
  645. */
  646. public function getBillYeTotalMoney(array $where, string $selectType, string $group = "", bool $isNum = false)
  647. {
  648. /** 后台用户充值金额 */
  649. $rechargeSumField = "number";
  650. $whereInRecharge['pm'] = 1;
  651. $whereInRecharge['type'] = 'system_add';
  652. $whereInRecharge['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  653. $whereInRecharge['store_id'] = 0;
  654. /** @var UserMoneyServices $userMoneyServices */
  655. $userMoneyServices = app()->make(UserMoneyServices::class);
  656. $totalMoney = $userMoneyServices->getRechargeMoneyByWhere($whereInRecharge, $rechargeSumField, $selectType, $group);
  657. if ($group) {
  658. $totalMoney = $this->trendYdata($totalMoney, $whereInRecharge['timeKey']);
  659. }
  660. return $totalMoney;
  661. }
  662. /**
  663. * 购买会员总额
  664. * @param array $where
  665. * @param string $selectType
  666. * @param string $group
  667. * @param bool $isNum
  668. * @return array|mixed
  669. * @throws \Exception
  670. */
  671. public function getMemberTotalMoney(array $where, string $selectType, string $group = "", bool $isNum = false)
  672. {
  673. /** 购买会员 */
  674. /** @var OtherOrderServices $otherOrderService */
  675. $otherOrderService = app()->make(OtherOrderServices::class);
  676. $memberSumField = "pay_price";
  677. $whereInMember['type'] = 1;
  678. $whereInMember['paid'] = 1;
  679. $whereInMember['store_id'] = 0;
  680. if (isset($where['pay_type'])) {
  681. $whereInMember['pay_type'] = $where['pay_type'];
  682. } else {
  683. //$whereInMember['pay_type_no'] = 'yue';
  684. }
  685. $whereInMember['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  686. $totalMoney = $otherOrderService->getMemberMoneyByWhere($whereInMember, $memberSumField, $selectType, $group);
  687. if ($group) {
  688. $totalMoney = $this->trendYdata($totalMoney, $whereInMember['timeKey']);
  689. }
  690. return $totalMoney;
  691. }
  692. /**
  693. * 线下付款总额
  694. * @param array $where
  695. * @param string $selectType
  696. * @param string $group
  697. * @param bool $isNum
  698. * @return array|mixed
  699. * @throws \Exception
  700. */
  701. public function getOfflineTotalMoney(array $where, string $selectType, string $group = "", bool $isNum = false)
  702. {
  703. /** 线下付款总额 */
  704. /** @var OtherOrderServices $otherOrderService */
  705. $otherOrderService = app()->make(OtherOrderServices::class);
  706. $offlineSumField = "pay_price";
  707. $whereOffline['type'] = 3;
  708. $whereOffline['paid'] = 1;
  709. $whereOffline['store_id'] = 0;
  710. // $whereOffline['pay_type_no'] = 'yue';
  711. $whereOffline['timeKey'] = $this->TimeConvert($where['time'], $isNum);
  712. $totalMoney = $otherOrderService->getMemberMoneyByWhere($whereOffline, $offlineSumField, $selectType, $group);
  713. if ($group) {
  714. $totalMoney = $this->trendYdata($totalMoney, $whereOffline['timeKey']);
  715. }
  716. return $totalMoney;
  717. }
  718. /**
  719. * 处理Y坐标数据
  720. * @param array $data
  721. * @param array $timeKey
  722. * @return array
  723. * @throws \Exception
  724. */
  725. public function trendYdata(array $data, array $timeKey)
  726. {
  727. $hourMoney = array();
  728. $timeData = array();
  729. //获取日期之间的天数
  730. $getDayRange = function ($date, $timeKey) {
  731. $datearr = [];
  732. $stime = strtotime($timeKey['start_time']);
  733. $etime = strtotime($timeKey['end_time']);
  734. while ($stime <= $etime) {
  735. $datearr['x'][] = date($date, $stime);
  736. $datearr['y'][] = date($date, $stime);
  737. $stime = $stime + 86400;
  738. }
  739. return $datearr;
  740. };
  741. //获取日期之间的月份
  742. $getMonthRange = function ($date, $timeKey) {
  743. $datearr = [];
  744. $stime = date('Y-m-d', strtotime($timeKey['start_time']));
  745. $etime = date('Y-m-d', strtotime($timeKey['end_time']));
  746. $start = new \DateTime($stime);
  747. $end = new \DateTime($etime);
  748. $interval = \DateInterval::createFromDateString('1 month');
  749. $period = new \DatePeriod($start, $interval, $end);
  750. foreach ($period as $dt) {
  751. $datearr['x'][] = $dt->format($date);
  752. $datearr['y'][] = $dt->format($date);
  753. }
  754. return $datearr;
  755. };
  756. if ($timeKey['days'] == 1) {
  757. for ($i = 0; $i <= 24; $i++) {
  758. $timeData['x'][] = (string)($i < 10 ? ('0' . $i) : $i);
  759. $timeData['y'][] = $i < 10 ? ('0' . $i) : $i;
  760. //$timeData['y'][] = $i < 10 ? ('0' . $i . ":00") : $i . ":00";
  761. //$timeData['x'][] = $i < 10 ? ('0' . $i . ":00") : $i . ":00";
  762. }
  763. } elseif ($timeKey['days'] == 30) {
  764. $timeData = $getDayRange('Y-m-d', $timeKey);
  765. } elseif ($timeKey['days'] == 365) {
  766. $timeData = $getMonthRange('Y-m', $timeKey);
  767. } elseif ($timeKey['days'] > 1 && $timeKey['days'] < 30) {
  768. $timeData = $getDayRange('Y-m-d', $timeKey);
  769. } elseif ($timeKey['days'] > 30 && $timeKey['days'] < 365) {
  770. $timeData = $getMonthRange('Y-m', $timeKey);
  771. }
  772. if ($data) {
  773. $hourMoney = array_column($data, 'number', 'time');
  774. }
  775. $y = array();
  776. foreach ($timeData['y'] as $k => $v) {
  777. if (array_key_exists($v, $hourMoney)) {
  778. $y[$v] = $hourMoney[$v];
  779. } else {
  780. $y[$v] = 0;
  781. }
  782. }
  783. return ['x' => $timeData['x'], 'y' => $y];
  784. }
  785. /**
  786. * 计算环比增长率
  787. * @param $nowValue
  788. * @param $lastValue
  789. * @return float|int|string
  790. */
  791. public function countRate($nowValue, $lastValue)
  792. {
  793. if ($lastValue == 0 && $nowValue == 0) return 0;
  794. if ($lastValue == 0) return round(bcmul(bcdiv($nowValue, 1, 4), 100, 2), 2);
  795. if ($nowValue == 0) return -100;
  796. return bcmul(bcdiv((bcsub($nowValue, $lastValue, 2)), $lastValue, 2), 100, 2);
  797. }
  798. /**
  799. * 获取环比时间类型
  800. * @param $timeKey
  801. * @return string
  802. */
  803. public function chainTime($timeKey)
  804. {
  805. switch ($timeKey) {
  806. case "today" :
  807. return "yestoday";
  808. case "month" :
  809. return "last_month";
  810. case "year" :
  811. return "last_year";
  812. default :
  813. return "other";
  814. }
  815. }
  816. }