FinanceRepository.php 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123
  1. <?php
  2. /**
  3. * @package merchant
  4. *
  5. * @author xaboy
  6. * @day 2020-10-12
  7. *
  8. *
  9. */
  10. namespace app\common\repositories\finance;
  11. // use app\common\dao\article\ArticleDao;
  12. // use app\common\model\article\ArticleContent;
  13. use app\common\repositories\BaseRepository;
  14. use app\common\repositories\user\UserRepository;
  15. use think\Exception;
  16. use think\facade\Db;
  17. use think\facade\Request;
  18. class FinanceRepository extends BaseRepository
  19. {
  20. /**
  21. * 订单概况
  22. * @param int $mer_id
  23. * @return array
  24. * @throws \Exception
  25. */
  26. public function order_overview($mer_id = 0)
  27. {
  28. if ($mer_id) {
  29. $where = "mer_id = " . $mer_id . " and paid = 1";
  30. } else {
  31. $where = " paid = 1";
  32. }
  33. $type = input('type', 1);
  34. $day = input('day', '');
  35. if ($type == 1 and $day != '') {
  36. $where .= " and DATE(pay_time) = '" . $day . "'";
  37. }
  38. if ($type == 2 and $day != '') {
  39. $date = new \DateTime($day);
  40. $year = $date->format('Y');
  41. $month = $date->format('m');
  42. $where .= " and YEAR(pay_time) = " . $year . " AND MONTH(pay_time) = " . $month;
  43. }
  44. $xianshangzhifu = Db::name('store_order')->where($where)->whereIn('pay_type', [0, 1])->sum('pay_price');
  45. $xianshangzhifu_xuni = Db::name('store_order')->where($where)->where('pay_type', 0)->sum('pay_price');
  46. $hongjifenxiaofei = Db::name('store_order')->where($where)->where("pay_type", 5)->sum('pay_price');
  47. // echo Db::name('store_order')->getLastSql();
  48. $chengjiaomoney = decimal2($xianshangzhifu + $hongjifenxiaofei);
  49. $list1[] = ['count' => set_price_rtrim($xianshangzhifu), 'name' => '线上支付金额'];
  50. if (!$mer_id) {
  51. $list1[] = ['count' => set_price_rtrim($xianshangzhifu_xuni), 'name' => '虚拟支付金额'];
  52. }
  53. $list1[] = ['count' => 0, 'name' => '代付金额'];
  54. $xianshangzhifunum = Db::name('store_order')->where($where)->whereIn('pay_type', [0, 1])->count();
  55. $xianshangzhifunum_xuni = Db::name('store_order')->where($where)->where('pay_type', 0)->count();
  56. $hongjifenxiaofeinum = Db::name('store_order')->where($where)->where("pay_type", 5)->count();
  57. $chengjiaocount = $xianshangzhifunum + $hongjifenxiaofeinum;
  58. $list2[] = ['count' => $xianshangzhifunum, 'name' => '线上支付订单量'];
  59. if (!$mer_id) {
  60. $list2[] = ['count' => $xianshangzhifunum_xuni, 'name' => '虚拟支付订单量'];
  61. }
  62. $list2[] = ['count' => 0, 'name' => '代付订单量'];
  63. $xianshangzhifuren = Db::name('store_order')->where($where)->whereIn('pay_type', [0, 1])->group('uid')->count();
  64. $xianshangzhifuren_xuni = Db::name('store_order')->where($where)->where('pay_type', 0)->group('uid')->count();
  65. $hongjifenxiaofeiren = Db::name('store_order')->where($where)->where("pay_type", 5)->group('uid')->count();
  66. $chengjiaoren = Db::name('store_order')->where($where)->whereIn('pay_type', [0, 1, 5])->group('uid')->count();
  67. $list3[] = ['count' => set_price_rtrim($xianshangzhifuren), 'name' => '线上支付人数'];
  68. if (!$mer_id) {
  69. $list3[] = ['count' => set_price_rtrim($xianshangzhifuren_xuni), 'name' => '虚拟支付人数'];
  70. }
  71. $list3[] = ['count' => 0, 'name' => '代付人数'];
  72. $xianshangtuikuan = Db::name('store_order')->where($where)->where('status', -1)->sum('pay_price');
  73. $tuikuanmoney = $xianshangtuikuan;
  74. $list4 = array(
  75. array('count' => $xianshangtuikuan, 'name' => '线上支付退单'),
  76. array('count' => 0, 'name' => '代付退单'),
  77. );
  78. $xianshangzhifutuinum = Db::name('store_order')->where($where)->where('status', -1)->count();
  79. $tuikuancount = $xianshangzhifutuinum;
  80. $list5 = array(
  81. array('count' => set_price_rtrim($xianshangzhifutuinum), 'name' => '线上支付退单量'),
  82. array('count' => 0, 'name' => '代付退单量'),
  83. );
  84. $xianshangzhifutuiremn = Db::name('store_order')->where($where)->where('status', -1)->group('uid')->count();
  85. $tuikuanren = $xianshangzhifutuiremn;
  86. $list6 = array(
  87. array('count' => set_price_rtrim($xianshangzhifutuiremn), 'name' => '线上支付退单人数'),
  88. array('count' => 0, 'name' => '代付退单数'),
  89. );
  90. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaomoney), 'name' => '成交金额', 'list' => $list1];
  91. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaocount), 'name' => '成交订单量', 'list' => $list2];
  92. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaoren), 'name' => '支付人数', 'list' => $list3];
  93. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanmoney), 'name' => '退款金额', 'list' => $list4];
  94. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuancount), 'name' => '退款订单量', 'list' => $list5];
  95. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanren), 'name' => '退款人数', 'list' => $list6];
  96. return $data;
  97. }
  98. /**
  99. * 用户概况
  100. * @param int $mer_id
  101. * @return array
  102. * @throws \Exception
  103. */
  104. public function user_overview($mer_id = 0)
  105. {
  106. $where = "1=1 ";
  107. if ($mer_id) {
  108. $mer_uid = Db::name('merchant')->where('mer_id', $mer_id)->value('uid');
  109. $userRepository = app()->make(UserRepository::class);
  110. $chilid_userids = $userRepository->getSpreadUidBreak($mer_uid);
  111. $chilid_userids_string = "1";
  112. if (!empty($chilid_userids)) {
  113. $chilid_userids_string = implode(',',$chilid_userids);
  114. }
  115. $where .= "and uid in ({$chilid_userids_string})";
  116. }
  117. $type = input('type', 1);
  118. $day = input('day', '');
  119. if ($type == 1 and $day != '') {
  120. $where .= " and DATE(create_time) = '" . $day . "'";
  121. }
  122. if ($type == 2 and $day != '') {
  123. $date = new \DateTime($day);
  124. $year = $date->format('Y');
  125. $month = $date->format('m');
  126. $where .= " and YEAR(create_time) = " . $year . " AND MONTH(create_time) = " . $month;
  127. }
  128. $dataQuery = Db::query("SELECT user_group,count(uid) count FROM `rrx_user` where {$where} group by user_group");
  129. $dataQuery = array_column($dataQuery, 'count', 'user_group');
  130. $shopPartnerCount = Db::query("SELECT user_group,count(uid) count FROM `rrx_user` where mer_id={$mer_id} and is_shop_partner=1 group by user_group");
  131. $maker = Db::query("SELECT CONCAT(`user_group`, '-',`is_show`) as k, count(uid) count FROM `rrx_user` where {$where} group by user_group,is_show");
  132. $maker = array_column($maker, 'count', 'k');
  133. $userByCodeCount = Db::query("SELECT 'temp' as `temp1`, count(*) count FROM `rrx_user` where {$where} and user_group =4 and is_show = 3");
  134. $userByCodeCount = array_column($userByCodeCount, 'count', 'temp1');
  135. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[1] ?? 0), 'name' => '消费者'];
  136. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[2] ?? 0), 'name' => '业务员'];
  137. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[3] ?? 0), 'name' => '业务经理'];
  138. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[5] ?? 0), 'name' => '初级合伙人'];
  139. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[6] ?? 0), 'name' => '中级合伙人'];
  140. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[7] ?? 0), 'name' => '高级合伙人'];
  141. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[8] ?? 0), 'name' => '董事'];
  142. $list1 = array(
  143. array('className' => 'el-icon-s-goods', 'count' => intval($maker['4-2'] ?? 0), 'name' => '集团会员'),//is_show=2
  144. array('className' => 'el-icon-s-goods', 'count' => intval($maker['4-1'] ?? 0), 'name' => '电商创客'),
  145. array('className' => 'el-icon-s-goods', 'count' => intval($userByCodeCount['temp'] ?? 0), 'name' => '激活创客'),
  146. );
  147. if ($mer_id) {
  148. // $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($shopPartnerCount), 'name' => '创客合伙人'];
  149. $data[] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[4] ?? 0), 'name' => '创客'];
  150. }
  151. $res['left'][] = $data;
  152. $res['right'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(intval($maker['4-2'] ?? 0) + intval($maker['4-1'] ?? 0) + intval($userByCodeCount['temp'] ?? 0)), 'name' => '创客', 'list' => $list1];
  153. return $res;
  154. }
  155. public function jieyu($type, $day, $mer_id = 0)
  156. {
  157. if ($mer_id) {
  158. $uid = Db::name('merchant')->where('mer_id', $mer_id)->value('uid');
  159. $where = "mer_id = " . $mer_id . " and paid = 1";
  160. $where_order = "mer_id = " . $mer_id . " and paid = 1 and douhuomall=0";
  161. $bill_where = "mer_id = " . $mer_id . " and commission_type in (7, 17, 19) and status =1 and source=0 and uid={$uid}";
  162. $yanglao_where = "mer_id = " . $mer_id . " and commission_type =5 and status =1 and source=0 and uid={$uid}";
  163. } else {
  164. $where = "paid = 1";
  165. $where_order = "paid = 1 and (douhuomall=1 or mer_id=496)";
  166. $bill_where = "commission_type !=5 and source=0 ";
  167. $yanglao_where = " commission_type =5 and source=0 ";
  168. }
  169. if ($type == 1 and $day != '') {
  170. $lastDay = date('Y-m-d', strtotime($day));
  171. $day = $lastDay;
  172. $where .= " and DATE(pay_time) = '" . $day . "'";
  173. $where_order .= " and DATE(hf_clear_time) = '" . $day . "'";
  174. $ruzhang = Db::name('enterprise_platform_income_detail')
  175. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  176. ->when($mer_id, function ($query) use ($mer_id) {
  177. $query->where('mer_id', $mer_id)
  178. ->where('deal_type', 1);
  179. }, function ($query) use ($mer_id) {
  180. $query->where('mer_id', $mer_id)
  181. ->whereIn('deal_type', [6, 7]);
  182. })
  183. ->where("deal_time like '" . $lastDay . "%'")->sum('money');
  184. $tixinan = Db::name('enterprise_platform_income_detail')
  185. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  186. ->when($mer_id, function ($query) use ($mer_id) {
  187. $query->where('mer_id', $mer_id)
  188. ->where('deal_type', 2);
  189. }, function ($query) use ($mer_id) {
  190. $query->where('deal_type', 5);
  191. })
  192. ->sum('money');
  193. $my_money = Db::name('enterprise_platform_income_detail')
  194. ->alias('epid')
  195. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  196. ->where("store_order.douhuomall", 0)
  197. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  198. ->when($mer_id, function ($query) use ($mer_id) {
  199. $query->where('epid.mer_id', $mer_id);
  200. })
  201. ->where('epid.deal_type', 1)
  202. ->where("epid.deal_time like '" . $lastDay . "%'")
  203. ->sum('epid.money');
  204. $shouyi = Db::name('user_bill')
  205. ->where($bill_where)
  206. ->whereBetween('take_time', [strtotime($day), strtotime($day) + 24 * 3600])
  207. ->sum('number');//
  208. $yanglao = Db::name('user_bill')
  209. ->where($yanglao_where)
  210. ->whereBetween('take_time', [strtotime($day), strtotime($day) + 24 * 3600])
  211. ->sum('number');//养老金
  212. $jieyu = Db::name('enterprise_day_bill')
  213. ->when($mer_id, function ($query) use ($mer_id) {
  214. $query->where('mer_id', $mer_id);
  215. })
  216. ->where('day', $lastDay)->value('balance');
  217. $integral = Db::name('user_sign_score')
  218. ->where('pm', 1)
  219. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  220. ->sum('reward_socre');
  221. $gongxian = Db::name('user_sign_gongxian')
  222. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  223. ->sum('number');
  224. $jingdou = Db::name('user_sign_jingdou')
  225. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  226. ->sum('number');
  227. $hongbao = Db::name('user_sign_hongbao')
  228. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  229. ->sum('number');
  230. $fugou = Db::name('user_sign_fugou')
  231. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  232. ->sum('number');
  233. $vr = Db::name('user_sign_vr')
  234. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  235. ->sum('number');
  236. } else if ($type == 2 and $day != '') {
  237. $date = new \DateTime($day);
  238. $year = $date->format('Y');
  239. $month = $date->format('m');
  240. $where .= " and YEAR(pay_time) = " . $year . " AND MONTH(pay_time) = " . $month;
  241. $where_order .= " and YEAR(hf_clear_time) = " . $year . " AND MONTH(hf_clear_time) = " . $month;
  242. $yue = date('Y-m', strtotime($day));
  243. $lastDay = $date->format('Y-m-t');
  244. $ruzhang = Db::name('enterprise_platform_income_detail')
  245. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  246. ->when($mer_id, function ($query) use ($mer_id) {
  247. $query->where('mer_id', $mer_id)
  248. ->where('deal_type', 1);
  249. }, function ($query) use ($mer_id) {
  250. $query->where('mer_id', $mer_id)
  251. ->whereIn('deal_type', [6, 7]);
  252. })
  253. ->where("deal_time like '" . $yue . "%'")
  254. ->sum('money');
  255. $tixinan = Db::name('enterprise_platform_income_detail')
  256. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  257. ->when($mer_id, function ($query) use ($mer_id) {
  258. $query->where('mer_id', $mer_id)
  259. ->where('deal_type', 2);
  260. }, function ($query) use ($mer_id) {
  261. $query->where('deal_type', 5);
  262. })
  263. ->sum('money');
  264. $my_money = Db::name('enterprise_platform_income_detail')
  265. ->alias('epid')
  266. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  267. ->where("store_order.douhuomall", 0)
  268. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  269. ->when($mer_id, function ($query) use ($mer_id) {
  270. $query->where('epid.mer_id', $mer_id);
  271. })
  272. ->where('epid.deal_type', 1)
  273. ->where("epid.deal_time like '" . $yue . "%'")
  274. ->sum('epid.money');
  275. $shouyi = Db::name('user_bill')
  276. ->where($bill_where)
  277. ->whereBetween('take_time', [strtotime(date('Y-m-01 00:00:00', strtotime($year))), strtotime($lastDay) + 24 * 3600])
  278. ->sum('number');//
  279. $yanglao = Db::name('user_bill')
  280. ->where($yanglao_where)
  281. ->whereBetween('take_time', [strtotime(date('Y-m-01 00:00:00', strtotime($year))), strtotime($lastDay) + 24 * 3600])
  282. ->sum('number');//养老金
  283. $jieyu = Db::name('enterprise_day_bill')
  284. ->when($mer_id, function ($query) use ($mer_id) {
  285. $query->where('mer_id', $mer_id);
  286. })
  287. ->where('day', $lastDay)->value('balance');
  288. $integral = Db::name('user_sign_score')
  289. ->where('pm', 1)
  290. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  291. ->sum('reward_socre');
  292. $gongxian = Db::name('user_sign_gongxian')
  293. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  294. ->sum('number');
  295. $jingdou = Db::name('user_sign_jingdou')
  296. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  297. ->sum('number');
  298. $hongbao = Db::name('user_sign_hongbao')
  299. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  300. ->sum('number');
  301. $fugou = Db::name('user_sign_fugou')
  302. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  303. ->sum('number');
  304. $vr = Db::name('user_sign_vr')
  305. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  306. ->sum('number');
  307. } else {
  308. $ruzhang = Db::name('enterprise_platform_income_detail')->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  309. ->when($mer_id, function ($query) use ($mer_id) {
  310. $query->where('mer_id', $mer_id)
  311. ->where('deal_type', 1);
  312. }, function ($query) use ($mer_id) {
  313. $query->where('mer_id', $mer_id)
  314. ->whereIn('deal_type', [6, 7]);
  315. })
  316. ->sum('money');
  317. $tixinan = Db::name('enterprise_platform_income_detail')
  318. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  319. ->when($mer_id, function ($query) use ($mer_id) {
  320. $query->where('mer_id', $mer_id)
  321. ->where('deal_type', 2);
  322. }, function ($query) use ($mer_id) {
  323. $query->where('deal_type', 5);
  324. })
  325. ->sum('money');
  326. $my_money = Db::name('enterprise_platform_income_detail')
  327. ->alias('epid')
  328. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  329. ->where("store_order.douhuomall", 0)
  330. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  331. ->when($mer_id, function ($query) use ($mer_id) {
  332. $query->where('epid.mer_id', $mer_id)
  333. ->where('epid.deal_type', 1);
  334. }, function ($query) use ($mer_id) {
  335. $query->where('epid.deal_type', 6);
  336. })
  337. ->sum('epid.money');
  338. $shouyi = Db::name('user_bill')
  339. ->where($bill_where)
  340. ->sum('number');
  341. //养老金
  342. $yanglao = Db::name('user_bill')
  343. ->where($yanglao_where)
  344. ->sum('number');//养老金
  345. $jieyu = Db::name('enterprise_day_bill')
  346. ->where('mer_id', $mer_id)
  347. ->order('day desc')->value('balance');
  348. $integral = Db::name('user_sign_score')
  349. ->where('pm', 1)
  350. ->sum('reward_socre');
  351. $gongxian = Db::name('user_sign_gongxian')
  352. ->sum('number');
  353. $jingdou = Db::name('user_sign_jingdou')
  354. ->sum('number');
  355. $hongbao = Db::name('user_sign_hongbao')
  356. ->sum('number');
  357. $fugou = Db::name('user_sign_fugou')
  358. ->sum('number');
  359. $vr = Db::name('user_sign_vr')
  360. ->sum('number');
  361. }
  362. $yingyemoney = Db::name('store_order')->where($where)->sum('pay_price');
  363. $hf_fee_amt = Db::name('store_order')->where($where_order)->sum('hf_fee_amt');//汇付手续费
  364. return compact('yingyemoney', 'hf_fee_amt', 'my_money', 'tixinan', 'ruzhang', 'shouyi', 'jieyu', 'integral', 'yanglao', 'gongxian', 'jingdou', 'hongbao', 'fugou', 'vr');
  365. }
  366. /**
  367. * 用户账单
  368. * @return mixed
  369. */
  370. public function user_bill($mer_id = 0)
  371. {
  372. $page = input('page');
  373. $limit = input('limit');
  374. $where = request()->params(['date']);
  375. $params = request()->params(['commission_type', 'uid', 'status', 'phone', 'user_group', 'status']);
  376. $data = [];
  377. //商户ID
  378. $query = Db::name('user_bill')
  379. ->alias('ub')
  380. ->leftJoin('user u', 'u.uid=ub.uid')
  381. ->when($mer_id, function ($query) use ($mer_id) {
  382. $query->where('ub.mer_id', $mer_id);
  383. })
  384. ->when(isset($params['commission_type']) && $params['commission_type'] == 5, function ($query) use ($params) {
  385. // 养老金
  386. $query->where('ub.commission_type', 5);
  387. }, function ($query) use ($params) {
  388. // 非养老金
  389. $query->whereIn('ub.commission_type', [3, 16, 14, 10, 12, 20, 15, 7, 19]);
  390. })
  391. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  392. $query->where('ub.uid', $params['uid']);
  393. })
  394. ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
  395. $query->where('ub.commission_type', $params['commission_type']);
  396. })
  397. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  398. $query->where('ub.status', $params['status']);
  399. })
  400. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  401. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  402. })
  403. ->when(isset($params['user_group']) && $params['user_group'] != '', function ($query) use ($params) {
  404. $query->where('u.user_group', $params['user_group']);
  405. });
  406. $query1 = clone $query;
  407. $query2 = clone $query;
  408. $query3 = clone $query;
  409. $data['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
  410. ->field('ub.bill_id,ub.title,ub.number,ub.take_time,ub.commission_type,u.uid,u.phone,u.nickname,u.user_group,ub.order_sn,ub.take_time,ub.status,ub.create_time')
  411. ->order('ub.bill_id', 'desc')
  412. ->page($page, $limit)
  413. ->select()
  414. ->each(function ($item) {
  415. if($item['take_time'])
  416. $item['take_time'] = date('Y-m-d H:i:s', $item['take_time']);
  417. return $item;
  418. });
  419. $data['count'] = $query->count();
  420. $statistics = $query1->field('sum(ub.number) money,ub.commission_type')->group('ub.commission_type')->select()->toArray();
  421. $statistics = array_column($statistics, 'money', 'commission_type');
  422. $statistics_tow = $query3->field('sum(ub.number) money,ub.status')->group('ub.status')->select()->toArray();
  423. $statistics_tow = array_column($statistics_tow, 'money', 'status');
  424. //佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费 7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12区县代区域收益√ 13消费循环佣金 14-推荐代理收益√ 15邀请小区团长升级√ 16大V经理分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√' 20省级代理区域收益√
  425. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '佣金奖励总额'];
  426. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[1] ?? 0), 'name' => '已结算佣金'];
  427. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[0] ?? 0), 'name' => '未结算佣金'];
  428. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(0), 'name' => '转VR佣金'];
  429. $user_extra_money = Db::name('user_extract')->where('status', 1)->sum('extract_price');
  430. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现佣金'];
  431. $data['statistics'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现金额'];
  432. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[3] ?? 0), 'name' => '直推奖'];
  433. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[16] ?? 0), 'name' => '大V经理分享奖'];
  434. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[14] ?? 0), 'name' => '推荐代理商收益'];
  435. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[10] ?? 0), 'name' => '推荐创客收益'];
  436. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[12] ?? 0), 'name' => '区县代区域收益'];
  437. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[20] ?? 0), 'name' => '省级代理区域收益'];
  438. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[15] ?? 0), 'name' => '邀请小区团长升级奖'];
  439. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[7] ?? 0), 'name' => '跨店奖励'];
  440. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[19] ?? 0), 'name' => '创客实际补贴'];
  441. $statistics = $query2->field('sum(ub.number) money,ub.status')->group('ub.status')->select()->toArray();
  442. $statistics = array_column($statistics, 'money', 'status');
  443. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '养老金总额'];
  444. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[1] ?? 0), 'name' => '已结算养老金'];
  445. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[0] ?? 0), 'name' => '未结算养老金'];
  446. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[-1] ?? 0), 'name' => '已失效养老金'];
  447. return $data;
  448. }
  449. /**
  450. * 用户账单
  451. * @return mixed
  452. */
  453. public function user_bill_maker($mer_id = 0, $uid = 0)
  454. {
  455. $page = input('page');
  456. $limit = input('limit');
  457. $where = request()->params(['date']);
  458. $params = request()->params(['commission_type', 'uid', 'status', 'phone', 'user_group', 'status']);
  459. $data = [];
  460. //商户ID
  461. $query = Db::name('user_bill')
  462. ->alias('ub')
  463. ->leftJoin('user u', 'u.uid=ub.uid')
  464. ->when($mer_id, function ($query) use ($mer_id) {
  465. $query->where('ub.mer_id', $mer_id);
  466. })
  467. ->when($uid, function ($query) use ($uid) {
  468. $query->where('ub.uid', $uid);
  469. })
  470. ->when(isset($params['commission_type']) && $params['commission_type'] == 5, function ($query) use ($params) {
  471. // 养老金
  472. $query->where('ub.commission_type', 5);
  473. }, function ($query) use ($params) {
  474. // 非养老金
  475. $query->whereIn('ub.commission_type', [3, 16, 14, 10, 12, 20, 15, 7, 19]);
  476. })
  477. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  478. $query->where('ub.uid', $params['uid']);
  479. })
  480. ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
  481. $query->where('ub.commission_type', $params['commission_type']);
  482. })
  483. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  484. $query->where('ub.status', $params['status']);
  485. })
  486. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  487. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  488. })
  489. ->when(isset($params['user_group']) && $params['user_group'] != '', function ($query) use ($params) {
  490. $query->where('u.user_group', $params['user_group']);
  491. });
  492. $query1 = clone $query;
  493. $query2 = clone $query;
  494. $data['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
  495. ->field('ub.bill_id,ub.title,sum(ub.number) as number,ub.take_time,ub.commission_type,u.uid,u.phone,u.nickname,u.user_group,ub.order_sn,ub.take_time,ub.status,ub.create_time')
  496. ->when(!$uid, function ($query) use ($uid) {
  497. $query->group('ub.uid');
  498. })
  499. ->when($uid, function ($query) use ($uid) {
  500. $query->field('FROM_UNIXTIME( ub.take_time, "%Y%m%d" ) AS task_time_group, ub.bill_id,ub.title,sum(ub.number) as number,ub.take_time,ub.commission_type,u.uid,u.phone,u.nickname,u.user_group,ub.order_sn,ub.take_time,ub.status,ub.create_time');
  501. $query->group('task_time_group');
  502. })
  503. ->order('ub.bill_id', 'desc')
  504. ->page($page, $limit)
  505. ->select()
  506. ->each(function ($item) {
  507. if($item['take_time'])
  508. $item['take_time'] = date('Y-m-d H:i:s', $item['take_time']);
  509. return $item;
  510. });
  511. $statistics = $query1->field('sum(ub.number) money,ub.commission_type')->group('ub.commission_type')->select()->toArray();
  512. $statistics = array_column($statistics, 'money', 'commission_type');
  513. //佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费 7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12区县代区域收益√ 13消费循环佣金 14-推荐代理收益√ 15邀请小区团长升级√ 16大V经理分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√' 20省级代理区域收益√
  514. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '创客合伙人佣金总额'];
  515. return $data;
  516. }
  517. /**
  518. * 积分统计
  519. * @return mixed
  520. */
  521. public function integral_list($mer_id = 0)
  522. {
  523. $page = input('page');
  524. $limit = input('limit');
  525. $where = request()->params(['date']);
  526. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  527. $date = [];
  528. //商户ID
  529. $query = Db::name('user_sign_score')
  530. ->alias('uss')
  531. ->leftJoin('user u', 'u.uid=uss.uid')
  532. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  533. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  534. $query->where('uss.uid', $params['uid']);
  535. })
  536. ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  537. $query->where('uss.pm', $params['pm']);
  538. })
  539. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  540. $query->where('uss.status', $params['status']);
  541. })
  542. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  543. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  544. })
  545. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  546. $query->where('type', $params['type']);
  547. });
  548. $query1 = clone $query;
  549. $query2 = clone $query;
  550. $query3 = clone $query;
  551. $query4 = clone $query;
  552. $query5 = clone $query;
  553. $query6 = clone $query;
  554. $query7 = clone $query;
  555. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  556. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pm,uss.reward_socre,o.order_sn,uss.status,uss.mark,u.score')
  557. ->page($page, $limit)
  558. ->order('uss.id', 'desc')
  559. ->select()
  560. ->each(function ($item) {
  561. $item['mark'] = $item['mark'];
  562. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  563. return $item;
  564. });
  565. $date['count'] = $query->count();
  566. $date['statistics']['all'] = decimal2($query1->where('pm', 1)->sum('reward_socre'));
  567. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->where('pm', 1)->sum('reward_socre'));
  568. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->where('pm', 1)->sum('reward_socre'));
  569. $date['statistics']['lost'] = decimal2($query4->where('pm', 2)->sum('reward_socre'));
  570. // $date['statistics']['deduct'] = decimal2($query5->where('uss.status', 1)->where('pm', 2)->sum('reward_socre'));
  571. // $date['statistics']['all_mp1'] = decimal2($query6->where('uss.status', 1)->where('pm', 1)->sum('reward_socre') - $query7->where('uss.status', 1)->where('pm', 2)->sum('reward_socre'));
  572. return $date;
  573. }
  574. /**
  575. * 京豆统计
  576. * @return mixed
  577. */
  578. public function jingdou_list($mer_id = 0)
  579. {
  580. $page = input('page');
  581. $limit = input('limit');
  582. $where = request()->params(['date']);
  583. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  584. $date = [];
  585. //商户ID
  586. $query = Db::name('user_sign_jingdou')
  587. ->alias('uss')
  588. ->leftJoin('user u', 'u.uid=uss.uid')
  589. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  590. // ->date_where($query, $where['date'], 'uss,addtime', '-', 2)
  591. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  592. $query->where('uss.uid', $params['uid']);
  593. })
  594. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  595. // $query->where('uss.pm', $params['pm']);
  596. // })
  597. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  598. $query->where('uss.status', $params['status']);
  599. })
  600. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  601. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  602. })
  603. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  604. $query->where('type', $params['type']);
  605. });
  606. $query1 = clone $query;
  607. $query2 = clone $query;
  608. $query3 = clone $query;
  609. $query4 = clone $query;
  610. $query5 = clone $query;
  611. $query6 = clone $query;
  612. $query7 = clone $query;
  613. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  614. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  615. ->page($page, $limit)
  616. ->order('uss.id', 'desc')
  617. ->select()
  618. ->each(function ($item) {
  619. $item['mark'] = $item['mark'];
  620. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  621. return $item;
  622. });
  623. $date['count'] = $query->count();
  624. $date['statistics']['all'] = decimal2($query1->sum('number'));
  625. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  626. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  627. $date['statistics']['lost'] = decimal2($query4->where('uss.type', 2)->sum('number'));
  628. return $date;
  629. }
  630. /**
  631. * 贡献值统计
  632. * @return mixed
  633. */
  634. public function contribute_list($mer_id = 0)
  635. {
  636. $page = input('page');
  637. $limit = input('limit');
  638. $where = request()->params(['date']);
  639. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  640. $date = [];
  641. //商户ID
  642. $query = Db::name('user_sign_gongxian')
  643. ->alias('uss')
  644. ->leftJoin('user u', 'u.uid=uss.uid')
  645. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  646. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  647. $query->where('uss.uid', $params['uid']);
  648. })
  649. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  650. // $query->where('uss.pm', $params['pm']);
  651. // })
  652. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  653. $query->where('uss.status', $params['status']);
  654. })
  655. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  656. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  657. })
  658. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  659. $query->where('type', $params['type']);
  660. });
  661. $query1 = clone $query;
  662. $query2 = clone $query;
  663. $query3 = clone $query;
  664. $query4 = clone $query;
  665. $query5 = clone $query;
  666. $query6 = clone $query;
  667. $query7 = clone $query;
  668. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  669. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  670. ->page($page, $limit)
  671. ->order('uss.number', 'desc')
  672. ->select()
  673. ->each(function ($item) {
  674. $item['mark'] = $item['mark'];
  675. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  676. return $item;
  677. });
  678. $date['count'] = $query->count();
  679. $date['statistics']['all'] = decimal2($query1->sum('number'));
  680. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  681. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  682. $date['statistics']['lost'] = decimal2($query4->where('uss.status', 0)->sum('number'));
  683. return $date;
  684. }
  685. /**
  686. * 复购金统计
  687. * @return mixed
  688. */
  689. public function fugou_list($mer_id = 0)
  690. {
  691. $page = input('page');
  692. $limit = input('limit');
  693. $where = request()->params(['date']);
  694. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  695. $date = [];
  696. //商户ID
  697. $query = Db::name('user_sign_fugou')
  698. ->alias('uss')
  699. ->leftJoin('user u', 'u.uid=uss.uid')
  700. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  701. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  702. $query->where('uss.uid', $params['uid']);
  703. })
  704. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  705. // $query->where('uss.pm', $params['pm']);
  706. // })
  707. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  708. $query->where('uss.status', $params['status']);
  709. })
  710. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  711. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  712. })
  713. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  714. $query->where('type', $params['type']);
  715. });
  716. $query1 = clone $query;
  717. $query2 = clone $query;
  718. $query3 = clone $query;
  719. $query4 = clone $query;
  720. $query5 = clone $query;
  721. $query6 = clone $query;
  722. $query7 = clone $query;
  723. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  724. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  725. ->page($page, $limit)
  726. ->order('uss.id', 'desc')
  727. ->select()
  728. ->each(function ($item) {
  729. $item['mark'] = $item['mark'];
  730. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  731. return $item;
  732. });
  733. $date['count'] = $query->count();
  734. $date['statistics']['all'] = decimal2($query1->sum('number'));
  735. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  736. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  737. $date['statistics']['lost'] = decimal2($query4->where('uss.type', 2)->sum('number'));
  738. return $date;
  739. }
  740. /**
  741. * 红包统计
  742. * @return mixed
  743. */
  744. public function hongbao_list($mer_id = 0)
  745. {
  746. $page = input('page');
  747. $limit = input('limit');
  748. $where = request()->params(['date']);
  749. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  750. $date = [];
  751. //商户ID
  752. $query = Db::name('user_sign_hongbao')
  753. ->alias('uss')
  754. ->leftJoin('user u', 'u.uid=uss.uid')
  755. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  756. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  757. $query->where('uss.uid', $params['uid']);
  758. })
  759. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  760. // $query->where('uss.pm', $params['pm']);
  761. // })
  762. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  763. $query->where('uss.status', $params['status']);
  764. })
  765. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  766. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  767. })
  768. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  769. $query->where('type', $params['type']);
  770. });
  771. $query1 = clone $query;
  772. $query2 = clone $query;
  773. $query3 = clone $query;
  774. $query4 = clone $query;
  775. $query5 = clone $query;
  776. $query6 = clone $query;
  777. $query7 = clone $query;
  778. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  779. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  780. ->page($page, $limit)
  781. ->order('uss.id', 'desc')
  782. ->select()
  783. ->each(function ($item) {
  784. $item['mark'] = $item['mark'];
  785. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  786. return $item;
  787. });
  788. $date['count'] = $query->count();
  789. $date['statistics']['all'] = decimal2($query1->sum('number'));
  790. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  791. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  792. $date['statistics']['tixian'] = decimal2($query4->where('uss.status', 0)->sum('number'));
  793. $date['statistics']['zhuan_vr'] = decimal2('0');
  794. return $date;
  795. }
  796. /**
  797. * VR统计
  798. * @return mixed
  799. */
  800. public function vr_list($mer_id = 0)
  801. {
  802. $page = input('page');
  803. $limit = input('limit');
  804. $where = request()->params(['date']);
  805. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  806. $date = [];
  807. //商户ID
  808. $query = Db::name('user_sign_vr')
  809. ->alias('uss')
  810. ->leftJoin('user u', 'u.uid=uss.uid')
  811. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  812. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  813. $query->where('uss.uid', $params['uid']);
  814. })
  815. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  816. // $query->where('uss.pm', $params['pm']);
  817. // })
  818. // ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  819. // $query->where('uss.status', $params['status']);
  820. // })
  821. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  822. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  823. })
  824. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  825. $query->where('type', $params['type']);
  826. });
  827. $query1 = clone $query;
  828. $query2 = clone $query;
  829. $query3 = clone $query;
  830. $query4 = clone $query;
  831. $query5 = clone $query;
  832. $query6 = clone $query;
  833. $query7 = clone $query;
  834. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  835. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.type,uss.mark,u.score')
  836. ->page($page, $limit)
  837. ->order('uss.id', 'desc')
  838. ->select()
  839. ->each(function ($item) {
  840. $item['mark'] = $item['mark'];
  841. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  842. return $item;
  843. });
  844. $date['count'] = $query->count();
  845. $date['statistics']['all'] = decimal2($query1->sum('number'));
  846. // $date['statistics']['clear'] = decimal2($query2->where('uss.type', 1)->sum('number'));
  847. $date['statistics']['nclear'] = decimal2($query3->where('uss.type', 2)->sum('number'));
  848. return $date;
  849. }
  850. /**
  851. * 列表中的时间条件
  852. */
  853. public function date_where($Db, $where, $prefix = 'so.create_time', $field = '-', $type = 1)
  854. {
  855. if (!isset($where)) return $Db;
  856. if ($type == 1) {
  857. switch ($where) {
  858. case 'today':
  859. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('today')), date('Y-m-d H:i:s', strtotime('tomorrow -1second'))]);
  860. break;
  861. case 'week':
  862. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('this week 00:00:00')), date('Y-m-d H:i:s', strtotime('next week 00:00:00 -1second'))]);
  863. break;
  864. case 'month':
  865. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('first Day of this month 00:00:00')), date('Y-m-d H:i:s', strtotime('first Day of next month 00:00:00 -1second'))]);
  866. break;
  867. case 'year':
  868. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('this year 1/1')), date('Y-m-d H:i:s', strtotime('next year 1/1 -1second'))]);
  869. break;
  870. case 'yesterday':
  871. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('yesterday')), date('Y-m-d H:i:s', strtotime('today -1second'))]);
  872. break;
  873. case 'quarter':
  874. list($startTime, $endTime) = getMonth();
  875. $Db = $Db->where($prefix, '>', $startTime);
  876. $Db = $Db->where($prefix, '<', $endTime);
  877. break;
  878. case 'lately7':
  879. $Db = $Db->where($prefix, 'between', [date('Y-m-d', strtotime("-7 day")), date('Y-m-d H:i:s')]);
  880. break;
  881. case 'lately30':
  882. $Db = $Db->where($prefix, 'between', [date('Y-m-d', strtotime("-30 day")), date('Y-m-d H:i:s')]);
  883. break;
  884. default:
  885. if (strstr($where, $field) !== false) {
  886. list($startTime, $endTime) = explode($field, $where);
  887. if (strlen($startTime) == 4) {
  888. $Db->whereBetweenTime($prefix, date('Y-m-d H:i:s', strtotime($startTime)), date('Y-m-d H:i:s', strtotime($startTime . ' +1day -1second')));
  889. } else {
  890. if ($startTime == $endTime) {
  891. $Db = $Db->whereDay($prefix, $startTime);
  892. } else {
  893. $Db = $Db->where($prefix, '>', date('Y-m-d H:i:s', strtotime($startTime)));
  894. $Db = $Db->where($prefix, '<', date('Y-m-d H:i:s', strtotime($endTime)));
  895. }
  896. }
  897. }
  898. break;
  899. }
  900. } else {
  901. switch ($where) {
  902. case 'today':
  903. $Db->whereBetween($prefix, [strtotime('today'), strtotime('tomorrow -1second')]);
  904. break;
  905. case 'week':
  906. $Db->whereBetween($prefix, [strtotime('this week 00:00:00'), strtotime('next week 00:00:00 -1second')]);
  907. break;
  908. case 'month':
  909. $Db->whereBetween($prefix, [strtotime('first Day of this month 00:00:00'), strtotime('first Day of next month 00:00:00 -1second')]);
  910. break;
  911. case 'year':
  912. $Db->whereBetween($prefix, [strtotime('this year 1/1'), strtotime('next year 1/1 -1second')]);
  913. break;
  914. case 'yesterday':
  915. $Db->whereBetween($prefix, [strtotime('yesterday'), strtotime('today -1second')]);
  916. break;
  917. case 'quarter':
  918. list($startTime, $endTime) = getMonthTime();
  919. $Db = $Db->where($prefix, '>', $startTime);
  920. $Db = $Db->where($prefix, '<', $endTime);
  921. break;
  922. case 'lately7':
  923. $Db = $Db->where($prefix, 'between', [strtotime("-7 day"), time()]);
  924. break;
  925. case 'lately30':
  926. $Db = $Db->where($prefix, 'between', [strtotime("-30 day"), time()]);
  927. break;
  928. default:
  929. if (strstr($where, $field) !== false) {
  930. list($startTime, $endTime) = explode($field, $where);
  931. if (strlen($startTime) == 4) {
  932. $Db->whereBetweenTime($prefix, strtotime($startTime), strtotime($startTime . ' +1day -1second'));
  933. } else {
  934. if ($startTime == $endTime) {
  935. $Db = $Db->whereDay($prefix, $startTime);
  936. } else {
  937. $Db = $Db->where($prefix, '>', strtotime($startTime));
  938. $Db = $Db->where($prefix, '<', strtotime($endTime));
  939. }
  940. }
  941. }
  942. break;
  943. }
  944. }
  945. return $Db;
  946. }
  947. public function income_detail($id, $mer_id = 0)
  948. {
  949. //商户ID
  950. $data = Db::name('enterprise_platform_income_detail')
  951. ->field('money,pm,title,deal_time,deal_order_sn,deal_type,order_sn,uid,order_id,user_extra_id')
  952. ->where('id', $id)
  953. ->when($mer_id, function ($query) use ($mer_id) {
  954. $query->where('mer_id', $mer_id);
  955. })
  956. ->find();
  957. $data['user_info'] = Db::name('user')->where('uid', $data['uid'])->field('nickname,phone')->find();
  958. //交易类型 1自营订单入账(商户) 2佣金提现到账(商户) 3订单支付 4商户佣金提现 5用户佣金提现 6订单入账 7 创客自营订单让利
  959. switch ($data['deal_type']) {
  960. case 1:
  961. case 3:
  962. case 6:
  963. case 7:
  964. $data['order_info'] = Db::name('store_order')
  965. ->alias('o')
  966. ->join('user_bill u', 'u.order_sn=o.order_sn')
  967. ->join('store_order_extend soe', 'soe.order_id=o.order_id')
  968. ->field('o.total_price,o.hf_fee_amt,o.create_time,u.number as yanglao,soe.shop_bonus_rate,total_postage')
  969. ->where('o.order_id', $data['order_id'])
  970. ->where('u.commission_type', 5)
  971. ->find();
  972. if (!$data['order_info']) {
  973. $data['order_info'] = Db::name('store_order')
  974. ->alias('o')
  975. ->field('o.total_price,o.hf_fee_amt,o.create_time')
  976. ->where('o.order_id', $data['order_id'])
  977. ->find();
  978. $data['order_info']['yanglao'] = 0;
  979. }
  980. if (!isset($data['order_info']['hf_fee_amt']) || $data['order_info']['hf_fee_amt'] == null) {
  981. $data['order_info']['hf_fee_amt'] = 0;
  982. }
  983. //创客让利总额
  984. $order_extend = Db::name('store_order_extend')->where('order_id', $data['order_id'])->find();
  985. $shop_bonus_rate = $order_extend['shop_bonus_rate'] ?? 0;
  986. $data['order_info']['shop_bonus_rate'] = $shop_bonus_rate;
  987. $data['order_info']['shop_bonus_price'] = 0;
  988. if ($mer_id != 496) {
  989. $data['order_info']['shop_bonus_price'] = $data['order_info']['total_price'] * $order_extend['shop_bonus_rate'];
  990. }
  991. break;
  992. case 2:
  993. case 4:
  994. case 5:
  995. $data['user_extract_info'] = Db::name('user_extract')
  996. ->field('extract_price,create_time,service_money,extract_type,real_name,bank_code,bank_address,bank_info,alipay_code,wechat')
  997. ->where('extract_id', $data['user_extra_id'])
  998. ->find();
  999. $data['user_extract_info'] ['real_name'] = json_decode($data['user_extract_info'] ['bank_info'], true)['user_name'];
  1000. $data['user_extract_info'] ['bank_info'] = json_decode($data['user_extract_info'] ['bank_info'], true)['bank_name'];
  1001. break;
  1002. }
  1003. if (!$data)
  1004. throw new Exception('数据不存在');
  1005. return $data;
  1006. }
  1007. }