FinanceRepository.php 55 KB

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