FinanceRepository.php 92 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011
  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. use crmeb\services\SpreadsheetExcelService;
  19. class FinanceRepository extends BaseRepository
  20. {
  21. /**
  22. * 订单概况
  23. * @param int $mer_id
  24. * @return array
  25. * @throws \Exception
  26. */
  27. public function order_overview($mer_id = 0)
  28. {
  29. // if ($mer_id) {
  30. // $where = "mer_id = " . $mer_id . " and paid = 1";
  31. // } else {
  32. $where = " paid = 1";
  33. // }
  34. $type = input('type', 1);
  35. $day = input('day', '');
  36. //天
  37. if ($type == 1 and $day != '') {
  38. $where .= " and DATE(create_time) = '" . $day . "'";
  39. }
  40. //月
  41. if ($type == 2 and $day != '') {
  42. $date = new \DateTime($day);
  43. $year = $date->format('Y');
  44. $month = $date->format('m');
  45. $where .= " and YEAR(create_time) = " . $year . " AND MONTH(create_time) = " . $month;
  46. }
  47. $weekWhere = " paid = 1";
  48. $dayWhere = " paid = 1";
  49. // 获取今天的日期和时间
  50. $today = new \DateTime();
  51. // 计算一周前的日期
  52. $oneWeekAgo = clone $today; // 克隆一个对象,避免修改原始对象
  53. $oneWeekAgo->sub(new \DateInterval('P1W')); // 减去一周
  54. // 格式化日期
  55. $todayFormatted = $today->format('Y-m-d');
  56. $oneWeekAgoFormatted = $oneWeekAgo->format('Y-m-d');
  57. //周时间条件
  58. $weekWhere .= " and DATE(create_time) >= '" . $oneWeekAgoFormatted . "' and DATE(create_time) <= '" . $todayFormatted . "'";
  59. //今日时间条件
  60. $dayWhere .= " and DATE(create_time) = '" . $todayFormatted . "'";
  61. // 会员专区订单总数
  62. //总数
  63. $chengjiaomoney = Db::name('store_order')->where($where)->where('mer_id', 496)->count();
  64. $weekCount = Db::name('store_order')->where($weekWhere)->where('mer_id', 496)->count();
  65. $todayCount = Db::name('store_order')->where($dayWhere)->where('mer_id', 496)->count();
  66. $list1[] = ['count' => $weekCount, 'name' => '周订单总数'];
  67. $list1[] = ['count' => $todayCount, 'name' => '日订单总数'];
  68. //精彩生活区订单总数
  69. //总数
  70. $chengjiaocount = Db::name('store_order')->where($where)->where('mer_id', 439)->count();
  71. $weekCount = Db::name('store_order')->where($weekWhere)->where('mer_id', 439)->count();
  72. $todayCount = Db::name('store_order')->where($dayWhere)->where('mer_id', 439)->count();
  73. $list2[] = ['count' => $weekCount, 'name' => '周订单总数'];
  74. $list2[] = ['count' => $todayCount, 'name' => '日订单总数'];
  75. //商贸区订单总数
  76. //总数
  77. $chengjiaoren = Db::name('store_order')->where($where)->whereNotIn('mer_id', [496, 439, 491])->count();
  78. $weekCount = Db::name('store_order')->where($weekWhere)->whereNotIn('mer_id', [496, 439, 491])->count();
  79. $todayCount = Db::name('store_order')->where($dayWhere)->whereNotIn('mer_id', [496, 439, 491])->count();
  80. $list3[] = ['count' => $weekCount, 'name' => '周订单总数'];
  81. $list3[] = ['count' => $todayCount, 'name' => '日订单总数'];
  82. //复购区订单总数
  83. //总数
  84. $tuikuanmoney = Db::name('store_order')->where($where)->where('mer_id', 491)->count();
  85. $weekCount = Db::name('store_order')->where($weekWhere)->where('mer_id', 491)->count();
  86. $todayCount = Db::name('store_order')->where($dayWhere)->where('mer_id', 491)->count();
  87. $list4[] = ['count' => $weekCount, 'name' => '周订单总数'];
  88. $list4[] = ['count' => $todayCount, 'name' => '日订单总数'];
  89. //三方平台订单总数
  90. //总数
  91. //话费
  92. $whereNew = str_replace("paid", "status", $where);
  93. $weekWhereNew = str_replace("paid", "status", $weekWhere);
  94. $dayWhereNew = str_replace("paid", "status", $dayWhere);
  95. $huafei = Db::name('order_huafei_hf')->where($whereNew)->count();
  96. $huafei_week = Db::name('order_huafei_hf')->where($weekWhereNew)->count();
  97. $huafei_today = Db::name('order_huafei_hf')->where($dayWhereNew)->count();
  98. //京东
  99. $whereNew = str_replace(" paid = 1", " status IN (16, 17)", $where);
  100. $weekWhereNew = str_replace(" paid = 1", " status IN (16, 17)", $weekWhere);
  101. $dayWhereNew = str_replace(" paid = 1", " status IN (16, 17)", $dayWhere);
  102. $jd = Db::name('order_jd')->where($whereNew)->count();
  103. $jd_week = Db::name('order_jd')->where($weekWhereNew)->count();
  104. $jd_today = Db::name('order_jd')->where($dayWhereNew)->count();
  105. //拼多多
  106. $whereNew = str_replace(" paid = 1", " pin_order_status IN (0, 2, 3)", $where);
  107. $weekWhereNew = str_replace(" paid = 1", " pin_order_status IN (0, 2, 3)", $weekWhere);
  108. $dayWhereNew = str_replace(" paid = 1", " pin_order_status IN (0, 2, 3)", $dayWhere);
  109. $pdd = Db::name('order_pdd')->where($whereNew)->count();
  110. $pdd_week = Db::name('order_pdd')->where($weekWhereNew)->count();
  111. $pdd_today = Db::name('order_pdd')->where($dayWhereNew)->count();
  112. //淘宝
  113. $whereNew = str_replace(" paid = 1", " tk_status IN (12, 3)", $where);
  114. $weekWhereNew = str_replace(" paid = 1", " tk_status IN (12, 3)", $weekWhere);
  115. $dayWhereNew = str_replace(" paid = 1", " tk_status IN (12, 3)", $dayWhere);
  116. $tb = Db::name('order_tb')->where($whereNew)->count();
  117. $tb_week = Db::name('order_tb')->where($weekWhereNew)->count();
  118. $tb_today = Db::name('order_tb')->where($dayWhereNew)->count();
  119. //电影票
  120. $whereNew = str_replace(" paid = 1", " status IN (1, 4)", $where);
  121. $weekWhereNew = str_replace(" paid = 1", " status IN (1, 4)", $weekWhere);
  122. $dayWhereNew = str_replace(" paid = 1", " status IN (1, 4)", $dayWhere);
  123. $movie = Db::name('order_movie')->where($whereNew)->count();
  124. $movie_week = Db::name('order_movie')->where($weekWhereNew)->count();
  125. $movie_today = Db::name('order_movie')->where($dayWhereNew)->count();
  126. $tuikuancount = $huafei+$jd+$pdd+$tb+$movie;
  127. $weekCount = $huafei_week+$jd_week+$pdd_week+$tb_week+$movie_week;
  128. $todayCount = $huafei_today+$jd_today+$pdd_today+$tb_today+$movie_today;
  129. $list5[] = ['count' => $weekCount, 'name' => '周订单总数'];
  130. $list5[] = ['count' => $todayCount, 'name' => '日订单总数'];
  131. //线下订单总数
  132. //总数
  133. $tuikuanren = Db::name('order_merchant')->where($where)->count();
  134. $weekCount = Db::name('order_merchant')->where($weekWhere)->count();
  135. $todayCount = Db::name('order_merchant')->where($dayWhere)->count();
  136. $list6[] = ['count' => $weekCount, 'name' => '周订单总数'];
  137. $list6[] = ['count' => $todayCount, 'name' => '日订单总数'];
  138. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaomoney), 'name' => '会员专区订单总数', 'list' => $list1];
  139. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaocount), 'name' => '精彩生活区订单总数', 'list' => $list2];
  140. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($chengjiaoren), 'name' => '商贸区订单总数', 'list' => $list3];
  141. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanmoney), 'name' => '复购区订单总数', 'list' => $list4];
  142. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuancount), 'name' => '三方平台订单总数', 'list' => $list5];
  143. $data[] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($tuikuanren), 'name' => '线下订单总数', 'list' => $list6];
  144. return $data;
  145. }
  146. /**
  147. * 用户概况
  148. * @param int $mer_id
  149. * @return array
  150. * @throws \Exception
  151. */
  152. public function user_overview($mer_id = 0)
  153. {
  154. $where = "1=1 ";
  155. if ($mer_id) {
  156. $mer_uid = Db::name('merchant')->where('mer_id', $mer_id)->value('uid');
  157. $userRepository = app()->make(UserRepository::class);
  158. $chilid_userids = $userRepository->getSpreadUidBreak($mer_uid);
  159. $chilid_userids_string = "1";
  160. if (!empty($chilid_userids)) {
  161. $chilid_userids_string = implode(',',$chilid_userids);
  162. }
  163. $where .= "and uid in ({$chilid_userids_string})";
  164. }
  165. $type = input('type', 1);
  166. $day = input('day', '');
  167. if ($type == 1 and $day != '') {
  168. $where .= " and DATE(create_time) = '" . $day . "'";
  169. }
  170. if ($type == 2 and $day != '') {
  171. $date = new \DateTime($day);
  172. $year = $date->format('Y');
  173. $month = $date->format('m');
  174. $where .= " and YEAR(create_time) = " . $year . " AND MONTH(create_time) = " . $month;
  175. }
  176. $dataQuery = Db::query("SELECT user_group,count(uid) count FROM `rrx_user` where {$where} group by user_group");
  177. $dataQuery = array_column($dataQuery, 'count', 'user_group');
  178. $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");
  179. $maker = array_column($maker, 'count', 'k');
  180. $data['one'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[1] ?? 0), 'name' => '消费者'];
  181. $data['one'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[2] ?? 0), 'name' => '业务员'];
  182. $data['one'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[3] ?? 0), 'name' => '业务经理'];
  183. $data['one'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[5] ?? 0), 'name' => '初级合伙人'];
  184. $data['one'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[6] ?? 0), 'name' => '中级合伙人'];
  185. $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[7] ?? 0), 'name' => '高级合伙人'];
  186. $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => (int)($dataQuery[8] ?? 0), 'name' => '董事'];
  187. $maker = Db::query("SELECT count(uid) as count FROM `rrx_user` where {$where} and originator_id_old > 0");
  188. $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($maker[0]['count'] ?? 0), 'name' => '联创'];
  189. $maker = Db::query("SELECT count(user_id) as count FROM `rrx_old_user_stock` where {$where}");
  190. $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($maker[0]['count'] ?? 0), 'name' => '股权'];
  191. $maker = Db::query("SELECT count(uid) as count FROM `rrx_merchant` where {$where}");
  192. $data['tow'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($maker[0]['count'] ?? 0), 'name' => '商户'];
  193. $res['left'] = $data;
  194. return $res;
  195. }
  196. /**
  197. * 会员概况
  198. * @param int $mer_id
  199. * @return array
  200. * @throws \Exception
  201. */
  202. public function member_overview($mer_id = 0)
  203. {
  204. $where = " 1=1";
  205. $sWeekWhere = " 1=1";
  206. $weekWhere = " 1=1";
  207. $dayWhere = " 1=1";
  208. $currentDate = date('Y-m-d');
  209. // 上周的开始日期(周一)
  210. $startDate = date('Y-m-d', strtotime('last Monday', strtotime($currentDate)));
  211. // 上周的结束日期(周日)
  212. $endDate = date('Y-m-d', strtotime('last Sunday', strtotime($currentDate)));
  213. // 获取今天的日期和时间
  214. $today = new \DateTime();
  215. // 计算一周前的日期
  216. $oneWeekAgo = clone $today; // 克隆一个对象,避免修改原始对象
  217. $oneWeekAgo->sub(new \DateInterval('P1W')); // 减去一周
  218. // 格式化日期
  219. $todayFormatted = $today->format('Y-m-d');
  220. $oneWeekAgoFormatted = $oneWeekAgo->format('Y-m-d');
  221. //上周时间条件
  222. $sWeekWhere .= " and DATE(create_time) >= '" . $startDate . "' and DATE(create_time) <= '" . $endDate . "'";
  223. //周时间条件
  224. $weekWhere .= " and DATE(create_time) >= '" . $oneWeekAgoFormatted . "' and DATE(create_time) <= '" . $todayFormatted . "'";
  225. //今日时间条件
  226. $dayWhere .= " and DATE(create_time) = '" . $todayFormatted . "'";
  227. $userCount = Db::name('user')->where($where)->count();
  228. $userDayCount = Db::name('user')->where($dayWhere)->count();
  229. $userDjCount = Db::name('user')->where($where)->where('status', 0)->count();
  230. // 会员专区业绩
  231. $chengjiaomoney = Db::name('store_order')->where($where)->where('paid', 1)->where('mer_id', 496)->sum('pay_price');
  232. $sWeekCount = Db::name('store_order')->where($sWeekWhere)->where('paid', 1)->where('mer_id', 496)->sum('pay_price');
  233. $weekCount = Db::name('store_order')->where($weekWhere)->where('paid', 1)->where('mer_id', 496)->sum('pay_price');
  234. $todayCount = Db::name('store_order')->where($dayWhere)->where('paid', 1)->where('mer_id', 496)->sum('pay_price');
  235. $data[] = ['className' => 'el-icon-s-goods', 'count' => $userCount, 'name' => '会员总人数'];
  236. $data[] = ['className' => 'el-icon-s-goods', 'count' => $userDayCount, 'name' => '今日新增会员'];
  237. $data[] = ['className' => 'el-icon-s-goods', 'count' => $userDjCount, 'name' => '被冻结会员数'];
  238. $data[] = ['className' => 'el-icon-s-goods', 'count' => $chengjiaomoney, 'name' => '会员专区总业绩'];
  239. $data[] = ['className' => 'el-icon-s-goods', 'count' => $sWeekCount, 'name' => '会员专区上周总业绩'];
  240. $data[] = ['className' => 'el-icon-s-goods', 'count' => $weekCount, 'name' => '会员专区本周总业绩'];
  241. $data[] = ['className' => 'el-icon-s-goods', 'count' => $todayCount, 'name' => '会员专区今日总业绩'];
  242. $res['left'][] = $data;
  243. return $res;
  244. }
  245. /**
  246. * pv概况
  247. * @param int $mer_id
  248. * @return array
  249. * @throws \Exception
  250. */
  251. public function pv_overview($mer_id = 0)
  252. {
  253. $where = "1=1 ";
  254. $sWeekWhere = " 1=1";
  255. $weekWhere = " 1=1";
  256. $dayWhere = " 1=1";
  257. $currentDate = date('Y-m-d');
  258. // 上周的开始日期(周一)
  259. $startDate = date('Y-m-d', strtotime('last Monday', strtotime($currentDate)));
  260. // 上周的结束日期(周日)
  261. $endDate = date('Y-m-d', strtotime('last Sunday', strtotime($currentDate)));
  262. // 获取今天的日期和时间
  263. $today = new \DateTime();
  264. // 计算一周前的日期
  265. $oneWeekAgo = clone $today; // 克隆一个对象,避免修改原始对象
  266. $oneWeekAgo->sub(new \DateInterval('P1W')); // 减去一周
  267. // 格式化日期
  268. $todayFormatted = $today->format('Y-m-d');
  269. $oneWeekAgoFormatted = $oneWeekAgo->format('Y-m-d');
  270. //上周时间条件
  271. $sWeekWhere .= " and DATE(addtime) >= '" . $startDate . "' and DATE(addtime) <= '" . $endDate . "'";
  272. //周时间条件
  273. $weekWhere .= " and DATE(addtime) >= '" . $oneWeekAgoFormatted . "' and DATE(addtime) <= '" . $todayFormatted . "'";
  274. //今日时间条件
  275. $dayWhere .= " and DATE(addtime) = '" . $todayFormatted . "'";
  276. $pvCount = Db::name('user_pv_log')->where($where)->sum('pv');
  277. // $pvCunCount = Db::name('user_pv_log')->where($where)->where('mer_id', 496)->sum('pv');
  278. $weekCount = Db::name('user_pv_log')->where($weekWhere)->sum('pv');
  279. $todayCount = Db::name('user_pv_log')->where($dayWhere)->sum('pv');
  280. $data[] = ['className' => 'el-icon-s-goods', 'count' => $pvCount, 'name' => '平台总PV'];
  281. // $data[] = ['className' => 'el-icon-s-goods', 'count' => $pvCunCount, 'name' => '会员存量总PV'];
  282. $data[] = ['className' => 'el-icon-s-goods', 'count' => $weekCount, 'name' => '本周新增PV总量'];
  283. $data[] = ['className' => 'el-icon-s-goods', 'count' => $todayCount, 'name' => '今日新增PV总量'];
  284. $res['left'][] = $data;
  285. return $res;
  286. }
  287. /**
  288. * vr概况
  289. * @param int $mer_id
  290. * @return array
  291. * @throws \Exception
  292. */
  293. public function vr_overview($mer_id = 0)
  294. {
  295. $where = "1=1 ";
  296. $sWeekWhere = " 1=1";
  297. $weekWhere = " 1=1";
  298. $dayWhere = " 1=1";
  299. $currentDate = date('Y-m-d');
  300. // 上周的开始日期(周一)
  301. $startDate = date('Y-m-d', strtotime('last Monday', strtotime($currentDate)));
  302. // 上周的结束日期(周日)
  303. $endDate = date('Y-m-d', strtotime('last Sunday', strtotime($currentDate)));
  304. // 获取今天的日期和时间
  305. $today = new \DateTime();
  306. // 计算一周前的日期
  307. $oneWeekAgo = clone $today; // 克隆一个对象,避免修改原始对象
  308. $oneWeekAgo->sub(new \DateInterval('P1W')); // 减去一周
  309. // 格式化日期
  310. $todayFormatted = $today->format('Y-m-d');
  311. $oneWeekAgoFormatted = $oneWeekAgo->format('Y-m-d');
  312. //上周时间条件
  313. $sWeekWhere .= " and DATE(addtime) >= '" . $startDate . "' and DATE(addtime) <= '" . $endDate . "'";
  314. //周时间条件
  315. $weekWhere .= " and DATE(addtime) >= '" . $oneWeekAgoFormatted . "' and DATE(addtime) <= '" . $todayFormatted . "'";
  316. //今日时间条件
  317. $dayWhere .= " and DATE(addtime) = '" . $todayFormatted . "'";
  318. $vrCount = Db::name('user_sign_vr')->where($where)->sum('number');
  319. $vrUserCount = Db::name('user')->where($where)->sum('vr');
  320. $vrWeekCount = Db::name('user_sign_vr')->where($weekWhere)->where('type', 1)->sum('number');
  321. $vrDayCount = Db::name('user_sign_vr')->where($dayWhere)->where('type', 1)->sum('number');
  322. $vrXhCount = Db::name('user_sign_vr')->where($where)->where('type', 2)->sum('number');
  323. $vrWeekXhCount = Db::name('user_sign_vr')->where($weekWhere)->where('type', 2)->sum('number');
  324. $vrDayXhCount = Db::name('user_sign_vr')->where($dayWhere)->where('type', 2)->sum('number');
  325. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrCount, 'name' => '平台总VR'];
  326. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrUserCount, 'name' => '会员存量总VR'];
  327. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrWeekCount, 'name' => '本周新增VR总量'];
  328. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrDayCount, 'name' => '今日新增VR总量'];
  329. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrXhCount, 'name' => '会员消耗总VR'];
  330. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrWeekXhCount, 'name' => '本周消耗VR总量'];
  331. $data[] = ['className' => 'el-icon-s-goods', 'count' => $vrDayXhCount, 'name' => '今日消耗VR总量'];
  332. $res['left'][] = $data;
  333. return $res;
  334. }
  335. /**
  336. * 积分概况
  337. * @param int $mer_id
  338. * @return array
  339. * @throws \Exception
  340. */
  341. public function jifen_overview($mer_id = 0)
  342. {
  343. $where = "1=1 ";
  344. $sWeekWhere = " 1=1";
  345. $weekWhere = " 1=1";
  346. $dayWhere = " 1=1";
  347. $currentDate = date('Y-m-d');
  348. // 上周的开始日期(周一)
  349. $startDate = date('Y-m-d', strtotime('last Monday', strtotime($currentDate)));
  350. // 上周的结束日期(周日)
  351. $endDate = date('Y-m-d', strtotime('last Sunday', strtotime($currentDate)));
  352. // 获取今天的日期和时间
  353. $today = new \DateTime();
  354. // 计算一周前的日期
  355. $oneWeekAgo = clone $today; // 克隆一个对象,避免修改原始对象
  356. $oneWeekAgo->sub(new \DateInterval('P1W')); // 减去一周
  357. // 格式化日期
  358. $todayFormatted = $today->format('Y-m-d');
  359. $oneWeekAgoFormatted = $oneWeekAgo->format('Y-m-d');
  360. //上周时间条件
  361. $sWeekWhere .= " and DATE(addtime) >= '" . $startDate . "' and DATE(addtime) <= '" . $endDate . "'";
  362. //周时间条件
  363. $weekWhere .= " and DATE(addtime) >= '" . $oneWeekAgoFormatted . "' and DATE(addtime) <= '" . $todayFormatted . "'";
  364. //今日时间条件
  365. $dayWhere .= " and DATE(addtime) = '" . $todayFormatted . "'";
  366. $jfCount = Db::name('user_sign_score')->where($where)->sum('reward_socre');
  367. $jfUserCount = Db::name('user')->where($where)->sum('score');
  368. $jfWeekCount = Db::name('user_sign_score')->where($weekWhere)->where('pm', 1)->sum('reward_socre');
  369. $jfDayCount = Db::name('user_sign_score')->where($dayWhere)->where('pm', 1)->sum('reward_socre');
  370. $jfXhCount = Db::name('user_sign_score')->where($where)->where('pm', 2)->sum('reward_socre');
  371. $jfWeekXhCount = Db::name('user_sign_score')->where($weekWhere)->where('pm', 2)->sum('reward_socre');
  372. $jfDayXhCount = Db::name('user_sign_score')->where($dayWhere)->where('pm', 2)->sum('reward_socre');
  373. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfCount, 'name' => '平台总积分'];
  374. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfUserCount, 'name' => '会员存量总积分'];
  375. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfWeekCount, 'name' => '本周新增积分总量'];
  376. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfDayCount, 'name' => '今日新增积分总量'];
  377. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfXhCount, 'name' => '会员消耗总积分'];
  378. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfWeekXhCount, 'name' => '本周消耗积分总量'];
  379. $data[] = ['className' => 'el-icon-s-goods', 'count' => $jfDayXhCount, 'name' => '今日消耗积分总量'];
  380. $res['left'][] = $data;
  381. return $res;
  382. }
  383. public function jieyu($type, $day, $mer_id = 0)
  384. {
  385. if ($mer_id) {
  386. $uid = Db::name('merchant')->where('mer_id', $mer_id)->value('uid');
  387. $where = "mer_id = " . $mer_id . " and paid = 1";
  388. $where_order = "mer_id = " . $mer_id . " and paid = 1 and douhuomall=0";
  389. $bill_where = "mer_id = " . $mer_id . " and commission_type in (7, 17, 19) and status =1 and source=0 and uid={$uid}";
  390. $yanglao_where = "mer_id = " . $mer_id . " and commission_type =5 and status =1 and source=0 and uid={$uid}";
  391. } else {
  392. $where = "paid = 1";
  393. $where_order = "paid = 1 and (douhuomall=1 or mer_id=496)";
  394. $bill_where = "commission_type !=5 and source=0 ";
  395. $yanglao_where = " commission_type =5 and source=0 ";
  396. }
  397. if ($type == 1 and $day != '') {
  398. $lastDay = date('Y-m-d', strtotime($day));
  399. $day = $lastDay;
  400. $where .= " and DATE(pay_time) = '" . $day . "'";
  401. $where_order .= " and DATE(hf_clear_time) = '" . $day . "'";
  402. $ruzhang = Db::name('enterprise_platform_income_detail')
  403. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  404. ->when($mer_id, function ($query) use ($mer_id) {
  405. $query->where('mer_id', $mer_id)
  406. ->where('deal_type', 1);
  407. }, function ($query) use ($mer_id) {
  408. $query->where('mer_id', $mer_id)
  409. ->whereIn('deal_type', [6, 7]);
  410. })
  411. ->where("deal_time like '" . $lastDay . "%'")->sum('money');
  412. $tixinan = Db::name('enterprise_platform_income_detail')
  413. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  414. ->when($mer_id, function ($query) use ($mer_id) {
  415. $query->where('mer_id', $mer_id)
  416. ->where('deal_type', 2);
  417. }, function ($query) use ($mer_id) {
  418. $query->where('deal_type', 5);
  419. })
  420. ->sum('money');
  421. $my_money = Db::name('enterprise_platform_income_detail')
  422. ->alias('epid')
  423. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  424. ->where("store_order.douhuomall", 0)
  425. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  426. ->when($mer_id, function ($query) use ($mer_id) {
  427. $query->where('epid.mer_id', $mer_id);
  428. })
  429. ->where('epid.deal_type', 1)
  430. ->where("epid.deal_time like '" . $lastDay . "%'")
  431. ->sum('epid.money');
  432. $shouyi = Db::name('user_bill')
  433. ->where($bill_where)
  434. ->whereBetween('take_time', [strtotime($day), strtotime($day) + 24 * 3600])
  435. ->sum('number');//
  436. $yanglao = Db::name('user_bill')
  437. ->where($yanglao_where)
  438. ->whereBetween('take_time', [strtotime($day), strtotime($day) + 24 * 3600])
  439. ->sum('number');//养老金
  440. $jieyu = Db::name('enterprise_day_bill')
  441. ->when($mer_id, function ($query) use ($mer_id) {
  442. $query->where('mer_id', $mer_id);
  443. })
  444. ->where('day', $lastDay)->value('balance');
  445. $integral = Db::name('user_sign_score')
  446. ->where('pm', 1)
  447. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  448. ->sum('reward_socre');
  449. $gongxian = Db::name('user_sign_gongxian')
  450. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  451. ->sum('number');
  452. $jingdou = Db::name('user_sign_jingdou')
  453. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  454. ->sum('number');
  455. $hongbao = Db::name('user_sign_hongbao')
  456. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  457. ->sum('number');
  458. $fugou = Db::name('user_sign_fugou')
  459. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  460. ->sum('number');
  461. $vr = Db::name('user_sign_vr')
  462. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  463. ->sum('number');
  464. $suoke = Db::name('user_bill')
  465. ->where('commission_type', 7)
  466. ->whereBetween('create_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  467. ->sum('number');
  468. $pv = Db::name('user_pv_log')
  469. ->whereBetween('settlement_time', [date('Y-m-d H:i:s', strtotime($day)), date('Y-m-d H:i:s', strtotime($day) + 24 * 3600)])
  470. ->sum('pv');
  471. } else if ($type == 2 and $day != '') {
  472. $date = new \DateTime($day);
  473. $year = $date->format('Y');
  474. $month = $date->format('m');
  475. $where .= " and YEAR(pay_time) = " . $year . " AND MONTH(pay_time) = " . $month;
  476. $where_order .= " and YEAR(hf_clear_time) = " . $year . " AND MONTH(hf_clear_time) = " . $month;
  477. $yue = date('Y-m', strtotime($day));
  478. $lastDay = $date->format('Y-m-t');
  479. $ruzhang = Db::name('enterprise_platform_income_detail')
  480. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  481. ->when($mer_id, function ($query) use ($mer_id) {
  482. $query->where('mer_id', $mer_id)
  483. ->where('deal_type', 1);
  484. }, function ($query) use ($mer_id) {
  485. $query->where('mer_id', $mer_id)
  486. ->whereIn('deal_type', [6, 7]);
  487. })
  488. ->where("deal_time like '" . $yue . "%'")
  489. ->sum('money');
  490. $tixinan = Db::name('enterprise_platform_income_detail')
  491. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  492. ->when($mer_id, function ($query) use ($mer_id) {
  493. $query->where('mer_id', $mer_id)
  494. ->where('deal_type', 2);
  495. }, function ($query) use ($mer_id) {
  496. $query->where('deal_type', 5);
  497. })
  498. ->sum('money');
  499. $my_money = Db::name('enterprise_platform_income_detail')
  500. ->alias('epid')
  501. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  502. ->where("store_order.douhuomall", 0)
  503. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  504. ->when($mer_id, function ($query) use ($mer_id) {
  505. $query->where('epid.mer_id', $mer_id);
  506. })
  507. ->where('epid.deal_type', 1)
  508. ->where("epid.deal_time like '" . $yue . "%'")
  509. ->sum('epid.money');
  510. $shouyi = Db::name('user_bill')
  511. ->where($bill_where)
  512. ->whereBetween('take_time', [strtotime(date('Y-m-01 00:00:00', strtotime($year))), strtotime($lastDay) + 24 * 3600])
  513. ->sum('number');//
  514. $yanglao = Db::name('user_bill')
  515. ->where($yanglao_where)
  516. ->whereBetween('take_time', [strtotime(date('Y-m-01 00:00:00', strtotime($year))), strtotime($lastDay) + 24 * 3600])
  517. ->sum('number');//养老金
  518. $jieyu = Db::name('enterprise_day_bill')
  519. ->when($mer_id, function ($query) use ($mer_id) {
  520. $query->where('mer_id', $mer_id);
  521. })
  522. ->where('day', $lastDay)->value('balance');
  523. $integral = Db::name('user_sign_score')
  524. ->where('pm', 1)
  525. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  526. ->sum('reward_socre');
  527. $gongxian = Db::name('user_sign_gongxian')
  528. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  529. ->sum('number');
  530. $jingdou = Db::name('user_sign_jingdou')
  531. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  532. ->sum('number');
  533. $hongbao = Db::name('user_sign_hongbao')
  534. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  535. ->sum('number');
  536. $fugou = Db::name('user_sign_fugou')
  537. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  538. ->sum('number');
  539. $vr = Db::name('user_sign_vr')
  540. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  541. ->sum('number');
  542. $suoke = Db::name('user_bill')
  543. ->where('commission_type', 7)
  544. ->whereBetween('create_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  545. ->sum('number');
  546. $pv = Db::name('user_pv_log')
  547. ->whereBetween('settlement_time', [date('Y-m-01 00:00:00', strtotime($year)), date('Y-m-d H:i:s', strtotime($lastDay) + 24 * 3600)])
  548. ->sum('pv');
  549. } else {
  550. $ruzhang = Db::name('enterprise_platform_income_detail')->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  551. ->when($mer_id, function ($query) use ($mer_id) {
  552. $query->where('mer_id', $mer_id)
  553. ->where('deal_type', 1);
  554. }, function ($query) use ($mer_id) {
  555. $query->where('mer_id', $mer_id)
  556. ->whereIn('deal_type', [6, 7]);
  557. })
  558. ->sum('money');
  559. $tixinan = Db::name('enterprise_platform_income_detail')
  560. ->where("deal_time <'" . date('Y-m-d H:i:s') . "'")
  561. ->when($mer_id, function ($query) use ($mer_id) {
  562. $query->where('mer_id', $mer_id)
  563. ->where('deal_type', 2);
  564. }, function ($query) use ($mer_id) {
  565. $query->where('deal_type', 5);
  566. })
  567. ->sum('money');
  568. $my_money = Db::name('enterprise_platform_income_detail')
  569. ->alias('epid')
  570. ->leftJoin('store_order store_order', 'store_order.order_id=epid.order_id')
  571. ->where("store_order.douhuomall", 0)
  572. ->where("epid.deal_time <'" . date('Y-m-d H:i:s') . "'")
  573. ->when($mer_id, function ($query) use ($mer_id) {
  574. $query->where('epid.mer_id', $mer_id)
  575. ->where('epid.deal_type', 1);
  576. }, function ($query) use ($mer_id) {
  577. $query->where('epid.deal_type', 6);
  578. })
  579. ->sum('epid.money');
  580. $shouyi = Db::name('user_bill')
  581. ->where($bill_where)
  582. ->sum('number');
  583. //养老金
  584. $yanglao = Db::name('user_bill')
  585. ->where($yanglao_where)
  586. ->sum('number');//养老金
  587. $jieyu = Db::name('enterprise_day_bill')
  588. ->where('mer_id', $mer_id)
  589. ->order('day desc')->value('balance');
  590. $integral = Db::name('user_sign_score')
  591. ->where('pm', 1)
  592. ->sum('reward_socre');
  593. $gongxian = Db::name('user_sign_gongxian')
  594. ->sum('number');
  595. $jingdou = Db::name('user_sign_jingdou')
  596. ->sum('number');
  597. $hongbao = Db::name('user_sign_hongbao')
  598. ->sum('number');
  599. $fugou = Db::name('user_sign_fugou')
  600. ->sum('number');
  601. $vr = Db::name('user_sign_vr')
  602. ->sum('number');
  603. $suoke = Db::name('user_bill')
  604. ->where('commission_type', 7)
  605. ->sum('number');
  606. $pv = Db::name('user_pv_log')
  607. ->sum('pv');
  608. }
  609. $yingyemoney = Db::name('store_order')->where($where)->sum('pay_price');
  610. $hf_fee_amt = Db::name('store_order')->where($where_order)->sum('hf_fee_amt');//汇付手续费
  611. return compact('yingyemoney', 'hf_fee_amt', 'my_money', 'tixinan', 'ruzhang', 'shouyi', 'jieyu', 'integral', 'yanglao', 'gongxian', 'jingdou', 'hongbao', 'fugou', 'vr', 'suoke', 'pv');
  612. }
  613. /**
  614. * 用户账单
  615. * @return mixed
  616. */
  617. public function user_bill($mer_id = 0)
  618. {
  619. $page = input('page');
  620. $limit = input('limit');
  621. $where = request()->params(['date']);
  622. $params = request()->params(['commission_type', 'uid', 'status', 'phone', 'user_group', 'status']);
  623. $data = [];
  624. //商户ID
  625. $query = Db::name('user_bill')
  626. ->alias('ub')
  627. ->leftJoin('user u', 'u.uid=ub.uid')
  628. ->when($mer_id, function ($query) use ($mer_id) {
  629. $query->where('ub.mer_id', $mer_id);
  630. })
  631. ->when(isset($params['commission_type']) && $params['commission_type'] == 5, function ($query) use ($params) {
  632. // 养老金
  633. $query->where('ub.commission_type', 5);
  634. }, function ($query) use ($params) {
  635. // 非养老金
  636. $query->whereIn('ub.commission_type', [3, 16, 14, 10, 12, 20, 15, 7, 19]);
  637. })
  638. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  639. $query->where('ub.uid', $params['uid']);
  640. })
  641. ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
  642. $query->where('ub.commission_type', $params['commission_type']);
  643. })
  644. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  645. $query->where('ub.status', $params['status']);
  646. })
  647. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  648. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  649. })
  650. ->when(isset($params['user_group']) && $params['user_group'] != '', function ($query) use ($params) {
  651. $query->where('u.user_group', $params['user_group']);
  652. });
  653. $query1 = clone $query;
  654. $query2 = clone $query;
  655. $query3 = clone $query;
  656. $query4 = clone $query;
  657. //导出数据
  658. $is_excel = request()->param('is_excel', 0);
  659. if($is_excel == 1){
  660. $date['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
  661. ->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')
  662. ->order('ub.bill_id', 'desc')
  663. ->select();
  664. if (isset($params['commission_type']) && $params['commission_type'] == 5) {
  665. $title = '养老金账单';
  666. $arr = [];
  667. foreach ($date['list'] as $k=>$item){
  668. switch ($item['status']) {
  669. case '1':
  670. $item['status'] = '有效';
  671. break;
  672. case '-1':
  673. $item['status'] = '已失效';
  674. break;
  675. case '0':
  676. $item['status'] = '待确定';
  677. break;
  678. }
  679. switch ($item['user_group']) {
  680. case '1':
  681. $item['user_group'] = '消费者';
  682. break;
  683. case '2':
  684. $item['user_group'] = '业务员';
  685. break;
  686. case '3':
  687. $item['user_group'] = '业务经理';
  688. break;
  689. case '4':
  690. $item['user_group'] = '初级合伙人';
  691. break;
  692. case '5':
  693. $item['user_group'] = '中级合伙人';
  694. break;
  695. case '6':
  696. $item['user_group'] = '高级合伙人';
  697. break;
  698. case '7':
  699. $item['user_group'] = '董事';
  700. break;
  701. }
  702. $arr[] = array(
  703. $item['bill_id'],
  704. $item['create_time'],
  705. $item['nickname'],
  706. $item['phone'],
  707. $item['user_group'],
  708. $item['number'],
  709. $item['status'],
  710. $item['order_sn'],
  711. $item['mark']
  712. );
  713. }
  714. return $this->getStatisticsExcel([
  715. 'ID','时间','用户昵称','手机号','当前身份','金额','状态','关联订单','说名',
  716. ], $arr, $title);
  717. } else {
  718. $title = '佣金账单';
  719. $arr = [];
  720. foreach ($date['list'] as $k=>$item){
  721. switch ($item['status']) {
  722. case '1':
  723. $item['status'] = '有效';
  724. break;
  725. case '-1':
  726. $item['status'] = '已失效';
  727. break;
  728. case '0':
  729. $item['status'] = '待确定';
  730. break;
  731. }
  732. switch ($item['user_group']) {
  733. case '1':
  734. $item['user_group'] = '消费者';
  735. break;
  736. case '2':
  737. $item['user_group'] = '业务员';
  738. break;
  739. case '3':
  740. $item['user_group'] = '业务经理';
  741. break;
  742. case '4':
  743. $item['user_group'] = '初级合伙人';
  744. break;
  745. case '5':
  746. $item['user_group'] = '中级合伙人';
  747. break;
  748. case '6':
  749. $item['user_group'] = '高级合伙人';
  750. break;
  751. case '7':
  752. $item['user_group'] = '董事';
  753. break;
  754. }
  755. $arr[] = array(
  756. $item['bill_id'],
  757. $item['create_time'],
  758. $item['nickname'],
  759. $item['phone'],
  760. $item['user_group'],
  761. $item['number'],
  762. $item['status'],
  763. $item['order_sn'],
  764. $item['mark']
  765. );
  766. }
  767. return $this->getStatisticsExcel([
  768. 'ID','时间','用户昵称','手机号','当前身份','金额','状态','关联订单','说名',
  769. ], $arr, $title);
  770. }
  771. }
  772. $data['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
  773. ->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')
  774. ->order('ub.bill_id', 'desc')
  775. ->page($page, $limit)
  776. ->select()
  777. ->each(function ($item) {
  778. if($item['take_time'])
  779. $item['take_time'] = date('Y-m-d H:i:s', $item['take_time']);
  780. return $item;
  781. });
  782. $data['count'] = $query->count();
  783. $statistics = $query1->field('sum(ub.number) money,ub.commission_type')->group('ub.commission_type')->select()->toArray();
  784. $statistics = array_column($statistics, 'money', 'commission_type');
  785. $statistics_tow = $query3->field('sum(ub.number) money,ub.status')->group('ub.status')->select()->toArray();
  786. $statistics_tow = array_column($statistics_tow, 'money', 'status');
  787. //佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费 7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12区县代区域收益√ 13消费循环佣金 14-推荐代理收益√ 15邀请小区团长升级√ 16大V经理分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√' 20省级代理区域收益√
  788. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '佣金奖励总额'];
  789. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[1] ?? 0), 'name' => '已结算佣金'];
  790. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[0] ?? 0), 'name' => '未结算佣金'];
  791. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics_tow[-1] ?? 0), 'name' => '已失效佣金'];
  792. $transition_vr = Db::name('user_transition_vr')->where('type', 1)->sum('number');
  793. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($transition_vr), 'name' => '佣金转VR'];
  794. $user_extra_money = Db::name('user_extract')->where('status', 1)->sum('extract_price');
  795. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现佣金'];
  796. $data['statistics'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($user_extra_money), 'name' => '已提现金额'];
  797. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[3] ?? 0), 'name' => '直推奖'];
  798. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[16] ?? 0), 'name' => '大V经理分享奖'];
  799. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[14] ?? 0), 'name' => '推荐代理商收益'];
  800. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[10] ?? 0), 'name' => '推荐创客收益'];
  801. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[12] ?? 0), 'name' => '区县代区域收益'];
  802. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[20] ?? 0), 'name' => '省级代理区域收益'];
  803. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[15] ?? 0), 'name' => '邀请小区团长升级奖'];
  804. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[7] ?? 0), 'name' => '跨店奖励'];
  805. // $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[19] ?? 0), 'name' => '创客实际补贴'];
  806. $statistics = $query2->field('sum(ub.number) money,ub.status')->group('ub.status')->select()->toArray();
  807. $statistics = array_column($statistics, 'money', 'status');
  808. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '养老金总额'];
  809. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[1] ?? 0), 'name' => '已结算养老金'];
  810. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[0] ?? 0), 'name' => '未结算养老金'];
  811. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($statistics[-1] ?? 0), 'name' => '已失效养老金'];
  812. $gzc_number = $query4->where('ub.gzc', 1)->sum('ub.number');
  813. $data['statistics']['yanglao'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim($gzc_number ?? 0), 'name' => '已入账养老金'];
  814. return $data;
  815. }
  816. /**
  817. * 用户账单
  818. * @return mixed
  819. */
  820. public function user_bill_maker($mer_id = 0, $uid = 0)
  821. {
  822. $page = input('page');
  823. $limit = input('limit');
  824. $where = request()->params(['date']);
  825. $params = request()->params(['commission_type', 'uid', 'status', 'phone', 'user_group', 'status']);
  826. $data = [];
  827. //商户ID
  828. $query = Db::name('user_bill')
  829. ->alias('ub')
  830. ->leftJoin('user u', 'u.uid=ub.uid')
  831. ->when($mer_id, function ($query) use ($mer_id) {
  832. $query->where('ub.mer_id', $mer_id);
  833. })
  834. ->when($uid, function ($query) use ($uid) {
  835. $query->where('ub.uid', $uid);
  836. })
  837. ->when(isset($params['commission_type']) && $params['commission_type'] == 5, function ($query) use ($params) {
  838. // 养老金
  839. $query->where('ub.commission_type', 5);
  840. }, function ($query) use ($params) {
  841. // 非养老金
  842. $query->whereIn('ub.commission_type', [3, 16, 14, 10, 12, 20, 15, 7, 19]);
  843. })
  844. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  845. $query->where('ub.uid', $params['uid']);
  846. })
  847. ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
  848. $query->where('ub.commission_type', $params['commission_type']);
  849. })
  850. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  851. $query->where('ub.status', $params['status']);
  852. })
  853. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  854. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  855. })
  856. ->when(isset($params['user_group']) && $params['user_group'] != '', function ($query) use ($params) {
  857. $query->where('u.user_group', $params['user_group']);
  858. });
  859. $query1 = clone $query;
  860. $query2 = clone $query;
  861. $data['list'] = $this->date_where($query, $where['date'], 'ub.create_time')
  862. ->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')
  863. ->when(!$uid, function ($query) use ($uid) {
  864. $query->group('ub.uid');
  865. })
  866. ->when($uid, function ($query) use ($uid) {
  867. $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');
  868. $query->group('task_time_group');
  869. })
  870. ->order('ub.bill_id', 'desc')
  871. ->page($page, $limit)
  872. ->select()
  873. ->each(function ($item) {
  874. if($item['take_time'])
  875. $item['take_time'] = date('Y-m-d H:i:s', $item['take_time']);
  876. return $item;
  877. });
  878. $statistics = $query1->field('sum(ub.number) money,ub.commission_type')->group('ub.commission_type')->select()->toArray();
  879. $statistics = array_column($statistics, 'money', 'commission_type');
  880. //佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费 7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12区县代区域收益√ 13消费循环佣金 14-推荐代理收益√ 15邀请小区团长升级√ 16大V经理分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√' 20省级代理区域收益√
  881. $data['statistics']['commission'][] = ['className' => 'el-icon-s-goods', 'count' => set_price_rtrim(array_sum($statistics)), 'name' => '创客合伙人佣金总额'];
  882. return $data;
  883. }
  884. /**
  885. * 积分统计
  886. * @return mixed
  887. */
  888. public function integral_list($mer_id = 0)
  889. {
  890. $page = input('page');
  891. $limit = input('limit');
  892. $where = request()->params(['date']);
  893. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  894. if($params['status'] == 99){
  895. unset($params['status']);
  896. $params['pm'] = 2;
  897. }
  898. $date = [];
  899. //商户ID
  900. $query = Db::name('user_sign_score')
  901. ->alias('uss')
  902. ->leftJoin('user u', 'u.uid=uss.uid')
  903. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  904. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  905. $query->where('uss.uid', $params['uid']);
  906. })
  907. ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  908. $query->where('uss.pm', $params['pm']);
  909. })
  910. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  911. $query->where('uss.status', $params['status']);
  912. })
  913. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  914. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  915. })
  916. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  917. $query->where('type', $params['type']);
  918. });
  919. $query1 = clone $query;
  920. $query2 = clone $query;
  921. $query3 = clone $query;
  922. $query4 = clone $query;
  923. $query5 = clone $query;
  924. $query6 = clone $query;
  925. $query7 = clone $query;
  926. //导出数据
  927. $is_excel = request()->param('is_excel', 0);
  928. if($is_excel == 1){
  929. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  930. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pm,uss.reward_socre,o.order_sn,uss.status,uss.mark,u.score')
  931. ->order('uss.id', 'desc')
  932. ->select();
  933. $arr = [];
  934. foreach ($date['list'] as $k=>$item){
  935. switch ($item['status']) {
  936. case '1':
  937. $item['status'] = '有效';
  938. break;
  939. case '-1':
  940. $item['status'] = '待确认';
  941. break;
  942. case '0':
  943. $item['status'] = '已失效';
  944. break;
  945. }
  946. $arr[] = array(
  947. $item['id'],
  948. date('Y-m-d H:i:s', $item['addtime']),
  949. $item['nickname'],
  950. $item['phone'],
  951. $item['reward_socre'],
  952. $item['status'],
  953. $item['order_sn'],
  954. $item['mark']
  955. );
  956. }
  957. return $this->getStatisticsExcel([
  958. 'ID','时间','用户昵称','手机号','积分数','结算状态','关联订单','说名',
  959. ], $arr, '积分统计');
  960. }
  961. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  962. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pm,uss.reward_socre,o.order_sn,uss.status,uss.mark,u.score')
  963. ->page($page, $limit)
  964. ->order('uss.id', 'desc')
  965. ->select()
  966. ->each(function ($item) {
  967. $item['mark'] = $item['mark'];
  968. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  969. return $item;
  970. });
  971. $date['count'] = $query->count();
  972. $date['statistics']['all'] = decimal2($query1->where('pm', 1)->sum('reward_socre'));
  973. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->where('pm', 1)->sum('reward_socre'));
  974. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->where('pm', 1)->sum('reward_socre'));
  975. $date['statistics']['lost'] = decimal2($query4->where('pm', 2)->sum('reward_socre'));
  976. // $date['statistics']['deduct'] = decimal2($query5->where('uss.status', 1)->where('pm', 2)->sum('reward_socre'));
  977. // $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'));
  978. return $date;
  979. }
  980. /**
  981. * 京豆统计
  982. * @return mixed
  983. */
  984. public function jingdou_list($mer_id = 0)
  985. {
  986. $page = input('page');
  987. $limit = input('limit');
  988. $where = request()->params(['date']);
  989. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  990. if($params['status'] == 99){
  991. unset($params['status']);
  992. $params['type'] = 2;
  993. }
  994. $date = [];
  995. //商户ID
  996. $query = Db::name('user_sign_jingdou')
  997. ->alias('uss')
  998. ->leftJoin('user u', 'u.uid=uss.uid')
  999. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1000. // ->date_where($query, $where['date'], 'uss,addtime', '-', 2)
  1001. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1002. $query->where('uss.uid', $params['uid']);
  1003. })
  1004. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  1005. // $query->where('uss.pm', $params['pm']);
  1006. // })
  1007. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1008. $query->where('uss.status', $params['status']);
  1009. })
  1010. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1011. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1012. })
  1013. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1014. $query->where('type', $params['type']);
  1015. });
  1016. $query1 = clone $query;
  1017. $query2 = clone $query;
  1018. $query3 = clone $query;
  1019. $query4 = clone $query;
  1020. $query5 = clone $query;
  1021. $query6 = clone $query;
  1022. $query7 = clone $query;
  1023. //导出数据
  1024. $is_excel = request()->param('is_excel', 0);
  1025. if($is_excel == 1){
  1026. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1027. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1028. ->order('uss.id', 'desc')
  1029. ->select();
  1030. $arr = [];
  1031. foreach ($date['list'] as $k=>$item){
  1032. switch ($item['status']) {
  1033. case '1':
  1034. $item['status'] = '有效';
  1035. break;
  1036. case '-1':
  1037. $item['status'] = '待确认';
  1038. break;
  1039. case '0':
  1040. $item['status'] = '已失效';
  1041. break;
  1042. }
  1043. $arr[] = array(
  1044. $item['id'],
  1045. date('Y-m-d H:i:s', $item['addtime']),
  1046. $item['nickname'],
  1047. $item['phone'],
  1048. $item['number'],
  1049. $item['status'],
  1050. $item['order_sn'],
  1051. $item['mark']
  1052. );
  1053. }
  1054. return $this->getStatisticsExcel([
  1055. 'ID','时间','用户昵称','手机号','京豆数','状态','关联订单','说名',
  1056. ], $arr, '京豆统计');
  1057. }
  1058. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1059. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1060. ->page($page, $limit)
  1061. ->order('uss.id', 'desc')
  1062. ->select()
  1063. ->each(function ($item) {
  1064. $item['mark'] = $item['mark'];
  1065. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1066. return $item;
  1067. });
  1068. $date['count'] = $query->count();
  1069. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1070. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  1071. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  1072. $date['statistics']['lost'] = decimal2($query4->where('uss.type', 2)->sum('number'));
  1073. return $date;
  1074. }
  1075. /**
  1076. * 贡献值统计
  1077. * @return mixed
  1078. */
  1079. public function contribute_list($mer_id = 0)
  1080. {
  1081. $page = input('page');
  1082. $limit = input('limit');
  1083. $where = request()->params(['date']);
  1084. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  1085. $date = [];
  1086. //商户ID
  1087. $query = Db::name('user_sign_gongxian')
  1088. ->alias('uss')
  1089. ->leftJoin('user u', 'u.uid=uss.uid')
  1090. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1091. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1092. $query->where('uss.uid', $params['uid']);
  1093. })
  1094. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1095. $query->where('uss.status', $params['status']);
  1096. })
  1097. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1098. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1099. })
  1100. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1101. $query->where('type', $params['type']);
  1102. });
  1103. $query1 = clone $query;
  1104. $query2 = clone $query;
  1105. $query3 = clone $query;
  1106. $query4 = clone $query;
  1107. $query5 = clone $query;
  1108. $query6 = clone $query;
  1109. $query7 = clone $query;
  1110. //导出数据
  1111. $is_excel = request()->param('is_excel', 0);
  1112. if($is_excel == 1){
  1113. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1114. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1115. ->order('uss.number', 'desc')
  1116. ->select();
  1117. $arr = [];
  1118. foreach ($date['list'] as $k=>$item){
  1119. switch ($item['status']) {
  1120. case '1':
  1121. $item['status'] = '有效';
  1122. break;
  1123. case '-1':
  1124. $item['status'] = '待确认';
  1125. break;
  1126. case '0':
  1127. $item['status'] = '已失效';
  1128. break;
  1129. }
  1130. $arr[] = array(
  1131. $item['id'],
  1132. date('Y-m-d H:i:s', $item['addtime']),
  1133. $item['nickname'],
  1134. $item['phone'],
  1135. $item['number'],
  1136. $item['status'],
  1137. $item['order_sn'],
  1138. $item['mark']
  1139. );
  1140. }
  1141. return $this->getStatisticsExcel([
  1142. 'ID','时间','用户昵称','手机号','贡献值数','贡献值状态','关联订单','说名',
  1143. ], $arr, '贡献值统计');
  1144. }
  1145. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1146. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1147. ->page($page, $limit)
  1148. ->order('uss.number', 'desc')
  1149. ->select()
  1150. ->each(function ($item) {
  1151. $item['mark'] = $item['mark'];
  1152. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1153. return $item;
  1154. });
  1155. $date['count'] = $query->count();
  1156. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1157. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  1158. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  1159. $date['statistics']['lost'] = decimal2($query4->where('uss.status', 0)->sum('number'));
  1160. return $date;
  1161. }
  1162. /**
  1163. * 复购金统计
  1164. * @return mixed
  1165. */
  1166. public function fugou_list($mer_id = 0)
  1167. {
  1168. $page = input('page');
  1169. $limit = input('limit');
  1170. $where = request()->params(['date']);
  1171. $params = request()->params(['commission_type', 'type', 'uid', 'pm', 'phone','status']);
  1172. if($params['status'] == 99){
  1173. unset($params['status']);
  1174. $params['type'] = 2;
  1175. }
  1176. $date = [];
  1177. //商户ID
  1178. $query = Db::name('user_sign_fugou')
  1179. ->alias('uss')
  1180. ->leftJoin('user u', 'u.uid=uss.uid')
  1181. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1182. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1183. $query->where('uss.uid', $params['uid']);
  1184. })
  1185. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  1186. // $query->where('uss.pm', $params['pm']);
  1187. // })
  1188. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1189. $query->where('uss.status', $params['status']);
  1190. })
  1191. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1192. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1193. })
  1194. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1195. $query->where('type', $params['type']);
  1196. })
  1197. ->when(isset($params['commission_type']) && $params['commission_type'] != '', function ($query) use ($params) {
  1198. $query->where('uss.commission_type', $params['commission_type']);
  1199. });
  1200. $query1 = clone $query;
  1201. $query2 = clone $query;
  1202. $query3 = clone $query;
  1203. $query4 = clone $query;
  1204. $query5 = clone $query;
  1205. $query6 = clone $query;
  1206. $query7 = clone $query;
  1207. //导出数据
  1208. $is_excel = request()->param('is_excel', 0);
  1209. if($is_excel == 1){
  1210. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1211. ->field('uss.id,uss.addtime,uss.commission_type,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1212. ->order('uss.id', 'desc')
  1213. ->select();
  1214. $arr = [];
  1215. foreach ($date['list'] as $k=>$item){
  1216. switch ($item['status']) {
  1217. case '1':
  1218. $item['status'] = '有效';
  1219. break;
  1220. case '-1':
  1221. $item['status'] = '待确认';
  1222. break;
  1223. case '0':
  1224. $item['status'] = '已失效';
  1225. break;
  1226. }
  1227. $arr[] = array(
  1228. $item['id'],
  1229. date('Y-m-d H:i:s', $item['addtime']),
  1230. $item['nickname'],
  1231. $item['phone'],
  1232. $item['number'],
  1233. $item['status'],
  1234. $item['order_sn'],
  1235. $item['mark']
  1236. );
  1237. }
  1238. return $this->getStatisticsExcel([
  1239. 'ID','时间','用户昵称','手机号','复购金数','复购金状态','关联订单','说名',
  1240. ], $arr, '复购金统计');
  1241. }
  1242. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1243. ->field('uss.id,uss.addtime,uss.commission_type,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1244. ->page($page, $limit)
  1245. ->order('uss.id', 'desc')
  1246. ->select()
  1247. ->each(function ($item) {
  1248. $item['mark'] = $item['mark'];
  1249. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1250. return $item;
  1251. });
  1252. $date['count'] = $query->count();
  1253. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1254. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  1255. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  1256. $date['statistics']['lost'] = decimal2($query4->where('uss.type', 2)->sum('number'));
  1257. return $date;
  1258. }
  1259. /**
  1260. * 红包统计
  1261. * @return mixed
  1262. */
  1263. public function hongbao_list($mer_id = 0)
  1264. {
  1265. $page = input('page');
  1266. $limit = input('limit');
  1267. $where = request()->params(['date']);
  1268. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  1269. $date = [];
  1270. //商户ID
  1271. $query = Db::name('user_sign_hongbao')
  1272. ->alias('uss')
  1273. ->leftJoin('user u', 'u.uid=uss.uid')
  1274. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1275. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1276. $query->where('uss.uid', $params['uid']);
  1277. })
  1278. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  1279. // $query->where('uss.pm', $params['pm']);
  1280. // })
  1281. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1282. $query->where('uss.status', $params['status']);
  1283. })
  1284. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1285. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1286. })
  1287. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1288. $query->where('type', $params['type']);
  1289. });
  1290. $query1 = clone $query;
  1291. $query2 = clone $query;
  1292. $query3 = clone $query;
  1293. $query4 = clone $query;
  1294. $query5 = clone $query;
  1295. $query6 = clone $query;
  1296. $query7 = clone $query;
  1297. //导出数据
  1298. $is_excel = request()->param('is_excel', 0);
  1299. if($is_excel == 1){
  1300. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1301. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1302. ->order('uss.id', 'desc')
  1303. ->select();
  1304. $arr = [];
  1305. foreach ($date['list'] as $k=>$item){
  1306. switch ($item['status']) {
  1307. case '1':
  1308. $item['status'] = '有效';
  1309. break;
  1310. case '-1':
  1311. $item['status'] = '待确认';
  1312. break;
  1313. case '0':
  1314. $item['status'] = '已失效';
  1315. break;
  1316. }
  1317. $arr[] = array(
  1318. $item['id'],
  1319. date('Y-m-d H:i:s', $item['addtime']),
  1320. $item['nickname'],
  1321. $item['phone'],
  1322. $item['number'],
  1323. $item['status'],
  1324. $item['order_sn'],
  1325. $item['mark']
  1326. );
  1327. }
  1328. return $this->getStatisticsExcel([
  1329. 'ID','时间','用户昵称','手机号','红包数','红包状态','关联订单','说名',
  1330. ], $arr, '红包统计');
  1331. }
  1332. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1333. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.status,uss.mark,u.score')
  1334. ->page($page, $limit)
  1335. ->order('uss.id', 'desc')
  1336. ->select()
  1337. ->each(function ($item) {
  1338. $item['mark'] = $item['mark'];
  1339. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1340. return $item;
  1341. });
  1342. $date['count'] = $query->count();
  1343. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1344. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));
  1345. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));
  1346. $date['statistics']['tixian'] = decimal2($query4->where('uss.status', 0)->sum('number'));
  1347. $date['statistics']['zhuan_vr'] = decimal2('0');
  1348. return $date;
  1349. }
  1350. /**
  1351. * VR统计
  1352. * @return mixed
  1353. */
  1354. public function vr_list($mer_id = 0)
  1355. {
  1356. $page = input('page');
  1357. $limit = input('limit');
  1358. $where = request()->params(['date']);
  1359. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  1360. $date = [];
  1361. //商户ID
  1362. $query = Db::name('user_sign_vr')
  1363. ->alias('uss')
  1364. ->leftJoin('user u', 'u.uid=uss.uid')
  1365. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1366. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1367. $query->where('uss.uid', $params['uid']);
  1368. })
  1369. // ->when(isset($params['pm']) && $params['pm'] != '', function ($query) use ($params) {
  1370. // $query->where('uss.pm', $params['pm']);
  1371. // })
  1372. // ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1373. // $query->where('uss.status', $params['status']);
  1374. // })
  1375. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1376. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1377. })
  1378. ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1379. $query->where('type', $params['type']);
  1380. });
  1381. $query1 = clone $query;
  1382. $query2 = clone $query;
  1383. $query3 = clone $query;
  1384. $query4 = clone $query;
  1385. $query5 = clone $query;
  1386. $query6 = clone $query;
  1387. $query7 = clone $query;
  1388. //导出数据
  1389. $is_excel = request()->param('is_excel', 0);
  1390. if($is_excel == 1){
  1391. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1392. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.type,uss.mark,u.score')
  1393. ->order('uss.id', 'desc')
  1394. ->select();
  1395. $arr = [];
  1396. foreach ($date['list'] as $k=>$item){
  1397. switch ($item['type']) {
  1398. case '1':
  1399. $item['type'] = '转入';
  1400. break;
  1401. case '2':
  1402. $item['type'] = '消耗';
  1403. break;
  1404. }
  1405. $arr[] = array(
  1406. $item['id'],
  1407. date('Y-m-d H:i:s', $item['addtime']),
  1408. $item['nickname'],
  1409. $item['phone'],
  1410. $item['number'],
  1411. $item['type'],
  1412. $item['mark']
  1413. );
  1414. }
  1415. return $this->getStatisticsExcel([
  1416. 'ID','时间','用户昵称','手机号','VR数','VR类型','说名',
  1417. ], $arr, 'VR统计');
  1418. }
  1419. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1420. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,uss.type,uss.mark,u.score')
  1421. ->page($page, $limit)
  1422. ->order('uss.id', 'desc')
  1423. ->select()
  1424. ->each(function ($item) {
  1425. $item['mark'] = $item['mark'];
  1426. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1427. return $item;
  1428. });
  1429. $date['count'] = $query->count();
  1430. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1431. // $date['statistics']['clear'] = decimal2($query2->where('uss.type', 1)->sum('number'));
  1432. $date['statistics']['nclear'] = decimal2($query3->where('uss.type', 2)->sum('number'));
  1433. return $date;
  1434. }
  1435. /**
  1436. * PV统计
  1437. * @return mixed
  1438. */
  1439. public function pv_list($mer_id = 0)
  1440. {
  1441. $page = input('page');
  1442. $limit = input('limit');
  1443. $where = request()->params(['date']);
  1444. $params = request()->params([ 'uid', 'pm', 'phone','status']);
  1445. // if($params['status'] == 99){
  1446. // unset($params['status']);
  1447. // $params['type'] = 2;
  1448. // }
  1449. $date = [];
  1450. //商户ID
  1451. $query = Db::name('user_pv_log')
  1452. ->alias('uss')
  1453. ->leftJoin('user u', 'u.uid=uss.uid')
  1454. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1455. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1456. $query->where('uss.uid', $params['uid']);
  1457. })
  1458. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1459. $query->where('uss.status', $params['status']);
  1460. })
  1461. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1462. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1463. });
  1464. // ->when(isset($params['type']) && $params['type'] != '', function ($query) use ($params) {
  1465. // $query->where('type', $params['type']);
  1466. // });
  1467. $query1 = clone $query;
  1468. $query2 = clone $query;
  1469. $query3 = clone $query;
  1470. $query4 = clone $query;
  1471. $query5 = clone $query;
  1472. $query6 = clone $query;
  1473. $query7 = clone $query;
  1474. //导出数据
  1475. $is_excel = request()->param('is_excel', 0);
  1476. if($is_excel == 1){
  1477. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1478. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pv,o.order_sn,uss.status,uss.mark,u.score')
  1479. ->order('uss.id', 'desc')
  1480. ->select();
  1481. $arr = [];
  1482. foreach ($date['list'] as $k=>$item){
  1483. switch ($item['status']) {
  1484. case '1':
  1485. $item['status'] = '有效';
  1486. break;
  1487. case '-1':
  1488. $item['status'] = '待确认';
  1489. break;
  1490. case '0':
  1491. $item['status'] = '已失效';
  1492. break;
  1493. }
  1494. $arr[] = array(
  1495. $item['id'],
  1496. date('Y-m-d H:i:s', $item['addtime']),
  1497. $item['nickname'],
  1498. $item['phone'],
  1499. $item['pv'],
  1500. $item['status'],
  1501. $item['order_sn'],
  1502. $item['mark']
  1503. );
  1504. }
  1505. return $this->getStatisticsExcel([
  1506. 'ID','时间','用户昵称','手机号','PV数','状态','关联订单','说名',
  1507. ], $arr, 'PV统计');
  1508. }
  1509. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1510. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.pv,o.order_sn,uss.status,uss.mark,u.score')
  1511. ->page($page, $limit)
  1512. ->order('uss.id', 'desc')
  1513. ->select()
  1514. ->each(function ($item) {
  1515. $item['mark'] = $item['mark'];
  1516. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1517. return $item;
  1518. });
  1519. $date['count'] = $query->count();
  1520. $date['statistics']['all'] = decimal2($query1->sum('uss.pv'));//平台PV总数
  1521. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('uss.pv'));//已结算PV总数
  1522. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('uss.pv'));//未结算PV总数
  1523. $date['statistics']['lost'] = decimal2($query4->where('uss.status', 0)->sum('uss.pv'));//已失效PV总数
  1524. $hongbao = Db::name('user_sign_hongbao')->where('status', 1)->sum('number');
  1525. $date['statistics']['deduct'] = decimal2($hongbao);//已结算红包总额
  1526. $date['statistics']['all_mp1'] = bcsub($date['statistics']['clear'], $date['statistics']['deduct'], 2);//可分红PV数
  1527. return $date;
  1528. }
  1529. /**
  1530. * 商户分润统计
  1531. * @return mixed
  1532. */
  1533. public function fenrun_list($mer_id = 0)
  1534. {
  1535. $page = input('page');
  1536. $limit = input('limit');
  1537. $where = request()->params(['date']);
  1538. $params = request()->params(['type', 'uid', 'pm', 'phone','status']);
  1539. if($params['status'] == 99){
  1540. unset($params['status']);
  1541. $params['type'] = 2;
  1542. }
  1543. $date = [];
  1544. //商户ID
  1545. $query = Db::name('user_sign_fenrun')
  1546. ->alias('uss')
  1547. ->leftJoin('user u', 'u.uid=uss.uid')
  1548. ->leftJoin('store_order o', 'o.order_id=uss.order_id')
  1549. ->leftJoin('merchant m', 'm.mer_id=o.mer_id')
  1550. ->when(isset($params['uid']) && $params['uid'] != '', function ($query) use ($params) {
  1551. $query->where('uss.uid', $params['uid']);
  1552. })
  1553. ->when(isset($params['status']) && $params['status'] != '', function ($query) use ($params) {
  1554. $query->where('uss.status', $params['status']);
  1555. })
  1556. ->when(isset($params['phone']) && $params['phone'] != '', function ($query) use ($params) {
  1557. $query->whereLike('u.phone', '%' . $params['phone'] . '%');
  1558. });
  1559. $query1 = clone $query;
  1560. $query2 = clone $query;
  1561. $query3 = clone $query;
  1562. $query4 = clone $query;
  1563. $query5 = clone $query;
  1564. $query6 = clone $query;
  1565. $query7 = clone $query;
  1566. //导出数据
  1567. $is_excel = request()->param('is_excel', 0);
  1568. if($is_excel == 1){
  1569. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1570. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,o.total_price,uss.status,uss.mark,u.score,m.mer_name')
  1571. ->order('uss.id', 'desc')
  1572. ->select();
  1573. $arr = [];
  1574. foreach ($date['list'] as $k=>$item){
  1575. switch ($item['status']) {
  1576. case '1':
  1577. $item['status'] = '有效';
  1578. break;
  1579. case '-1':
  1580. $item['status'] = '待确认';
  1581. break;
  1582. case '0':
  1583. $item['status'] = '已失效';
  1584. break;
  1585. }
  1586. $arr[] = array(
  1587. $item['id'],
  1588. date('Y-m-d H:i:s', $item['addtime']),
  1589. $item['number'],
  1590. $item['total_price'],
  1591. $item['status'],
  1592. $item['mer_name'],
  1593. $item['order_sn']
  1594. );
  1595. }
  1596. return $this->getStatisticsExcel([
  1597. 'ID','时间','商户分润金额','订单金额','状态','店铺名称','关联订单',
  1598. ], $arr, '商户分润统计');
  1599. }
  1600. $date['list'] = $this->date_where($query, $where['date'], 'uss.addtime', '-', 2)
  1601. ->field('uss.id,uss.addtime,u.nickname,u.phone,uss.number,o.order_sn,o.total_price,uss.status,uss.mark,u.score,m.mer_name')
  1602. ->page($page, $limit)
  1603. ->order('uss.id', 'desc')
  1604. ->select()
  1605. ->each(function ($item) {
  1606. $item['mark'] = $item['mark'];
  1607. $item['addtime'] = date('Y-m-d H:i:s', $item['addtime']);
  1608. return $item;
  1609. });
  1610. $date['count'] = $query->count();
  1611. $date['statistics']['all'] = decimal2($query1->sum('number'));
  1612. $date['statistics']['clear'] = decimal2($query2->where('uss.status', 1)->sum('number'));//已结算
  1613. $date['statistics']['nclear'] = decimal2($query3->where('uss.status', -1)->sum('number'));//未结算
  1614. $date['statistics']['lost'] = decimal2($query4->where('uss.status', 0)->sum('number'));//已失效
  1615. return $date;
  1616. }
  1617. /**
  1618. * 获取统计导出
  1619. */
  1620. public function getStatisticsExcel($header,$arr,$title)
  1621. {
  1622. $filename = $title.'_'.date('YmdHis').'_'.rand(10000,99999);
  1623. $name = $filename;
  1624. $info = '生成时间:' . date('Y-m-d H:i:s',time());
  1625. $suffix='xlsx';
  1626. $path='extract';
  1627. unset($_instance);
  1628. $_instance = SpreadsheetExcelService::instance_xin();
  1629. $_path =$_instance
  1630. ->createOrActive()
  1631. ->setExcelHeader($header)
  1632. ->setExcelTile($title, $name, $info)
  1633. ->setExcelContent($arr)
  1634. ->excelSave($filename, $suffix, $path);
  1635. $domain = request()->domain();
  1636. $data= [
  1637. 'name' => $filename.'.'.$suffix,
  1638. 'status' => 1,
  1639. 'path' => $domain.'/'.$_path
  1640. ];
  1641. return $data;
  1642. }
  1643. /**
  1644. * 列表中的时间条件
  1645. */
  1646. public function date_where($Db, $where, $prefix = 'so.create_time', $field = '-', $type = 1)
  1647. {
  1648. if (!isset($where)) return $Db;
  1649. if ($type == 1) {
  1650. switch ($where) {
  1651. case 'today':
  1652. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('today')), date('Y-m-d H:i:s', strtotime('tomorrow -1second'))]);
  1653. break;
  1654. case 'week':
  1655. $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'))]);
  1656. break;
  1657. case 'month':
  1658. $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'))]);
  1659. break;
  1660. case 'year':
  1661. $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'))]);
  1662. break;
  1663. case 'yesterday':
  1664. $Db->whereBetween($prefix, [date('Y-m-d H:i:s', strtotime('yesterday')), date('Y-m-d H:i:s', strtotime('today -1second'))]);
  1665. break;
  1666. case 'quarter':
  1667. list($startTime, $endTime) = getMonth();
  1668. $Db = $Db->where($prefix, '>', $startTime);
  1669. $Db = $Db->where($prefix, '<', $endTime);
  1670. break;
  1671. case 'lately7':
  1672. $Db = $Db->where($prefix, 'between', [date('Y-m-d', strtotime("-7 day")), date('Y-m-d H:i:s')]);
  1673. break;
  1674. case 'lately30':
  1675. $Db = $Db->where($prefix, 'between', [date('Y-m-d', strtotime("-30 day")), date('Y-m-d H:i:s')]);
  1676. break;
  1677. default:
  1678. if (strstr($where, $field) !== false) {
  1679. list($startTime, $endTime) = explode($field, $where);
  1680. if (strlen($startTime) == 4) {
  1681. $Db->whereBetweenTime($prefix, date('Y-m-d H:i:s', strtotime($startTime)), date('Y-m-d H:i:s', strtotime($startTime . ' +1day -1second')));
  1682. } else {
  1683. if ($startTime == $endTime) {
  1684. $Db = $Db->whereDay($prefix, $startTime);
  1685. } else {
  1686. $Db = $Db->where($prefix, '>', date('Y-m-d H:i:s', strtotime($startTime)));
  1687. $Db = $Db->where($prefix, '<', date('Y-m-d H:i:s', strtotime($endTime)));
  1688. }
  1689. }
  1690. }
  1691. break;
  1692. }
  1693. } else {
  1694. switch ($where) {
  1695. case 'today':
  1696. $Db->whereBetween($prefix, [strtotime('today'), strtotime('tomorrow -1second')]);
  1697. break;
  1698. case 'week':
  1699. $Db->whereBetween($prefix, [strtotime('this week 00:00:00'), strtotime('next week 00:00:00 -1second')]);
  1700. break;
  1701. case 'month':
  1702. $Db->whereBetween($prefix, [strtotime('first Day of this month 00:00:00'), strtotime('first Day of next month 00:00:00 -1second')]);
  1703. break;
  1704. case 'year':
  1705. $Db->whereBetween($prefix, [strtotime('this year 1/1'), strtotime('next year 1/1 -1second')]);
  1706. break;
  1707. case 'yesterday':
  1708. $Db->whereBetween($prefix, [strtotime('yesterday'), strtotime('today -1second')]);
  1709. break;
  1710. case 'quarter':
  1711. list($startTime, $endTime) = getMonthTime();
  1712. $Db = $Db->where($prefix, '>', $startTime);
  1713. $Db = $Db->where($prefix, '<', $endTime);
  1714. break;
  1715. case 'lately7':
  1716. $Db = $Db->where($prefix, 'between', [strtotime("-7 day"), time()]);
  1717. break;
  1718. case 'lately30':
  1719. $Db = $Db->where($prefix, 'between', [strtotime("-30 day"), time()]);
  1720. break;
  1721. default:
  1722. if (strstr($where, $field) !== false) {
  1723. list($startTime, $endTime) = explode($field, $where);
  1724. if (strlen($startTime) == 4) {
  1725. $Db->whereBetweenTime($prefix, strtotime($startTime), strtotime($startTime . ' +1day -1second'));
  1726. } else {
  1727. if ($startTime == $endTime) {
  1728. $Db = $Db->whereDay($prefix, $startTime);
  1729. } else {
  1730. $Db = $Db->where($prefix, '>', strtotime($startTime));
  1731. $Db = $Db->where($prefix, '<', strtotime($endTime));
  1732. }
  1733. }
  1734. }
  1735. break;
  1736. }
  1737. }
  1738. return $Db;
  1739. }
  1740. public function income_detail($id, $mer_id = 0)
  1741. {
  1742. //商户ID
  1743. $data = Db::name('enterprise_platform_income_detail')
  1744. ->field('money,pm,title,deal_time,deal_order_sn,deal_type,order_sn,uid,order_id,user_extra_id')
  1745. ->where('id', $id)
  1746. ->when($mer_id, function ($query) use ($mer_id) {
  1747. $query->where('mer_id', $mer_id);
  1748. })
  1749. ->find();
  1750. $data['user_info'] = Db::name('user')->where('uid', $data['uid'])->field('nickname,phone')->find();
  1751. //交易类型 1自营订单入账(商户) 2佣金提现到账(商户) 3订单支付 4商户佣金提现 5用户佣金提现 6订单入账 7 创客自营订单让利
  1752. switch ($data['deal_type']) {
  1753. case 1:
  1754. case 3:
  1755. case 6:
  1756. case 7:
  1757. $data['order_info'] = Db::name('store_order')
  1758. ->alias('o')
  1759. ->join('user_bill u', 'u.order_sn=o.order_sn')
  1760. ->join('store_order_extend soe', 'soe.order_id=o.order_id')
  1761. ->field('o.total_price,o.hf_fee_amt,o.create_time,u.number as yanglao,soe.shop_bonus_rate,total_postage')
  1762. ->where('o.order_id', $data['order_id'])
  1763. ->where('u.commission_type', 5)
  1764. ->find();
  1765. if (!$data['order_info']) {
  1766. $data['order_info'] = Db::name('store_order')
  1767. ->alias('o')
  1768. ->field('o.total_price,o.hf_fee_amt,o.create_time')
  1769. ->where('o.order_id', $data['order_id'])
  1770. ->find();
  1771. $data['order_info']['yanglao'] = 0;
  1772. }
  1773. if (!isset($data['order_info']['hf_fee_amt']) || $data['order_info']['hf_fee_amt'] == null) {
  1774. $data['order_info']['hf_fee_amt'] = 0;
  1775. }
  1776. //创客让利总额
  1777. $order_extend = Db::name('store_order_extend')->where('order_id', $data['order_id'])->find();
  1778. $shop_bonus_rate = $order_extend['shop_bonus_rate'] ?? 0;
  1779. $data['order_info']['shop_bonus_rate'] = $shop_bonus_rate;
  1780. $data['order_info']['shop_bonus_price'] = 0;
  1781. if ($mer_id != 496) {
  1782. $data['order_info']['shop_bonus_price'] = $data['order_info']['total_price'] * $order_extend['shop_bonus_rate'];
  1783. }
  1784. break;
  1785. case 2:
  1786. case 4:
  1787. case 5:
  1788. $data['user_extract_info'] = Db::name('user_extract')
  1789. ->field('extract_price,create_time,service_money,extract_type,real_name,bank_code,bank_address,bank_info,alipay_code,wechat')
  1790. ->where('extract_id', $data['user_extra_id'])
  1791. ->find();
  1792. $data['user_extract_info'] ['real_name'] = json_decode($data['user_extract_info'] ['bank_info'], true)['user_name'];
  1793. $data['user_extract_info'] ['bank_info'] = json_decode($data['user_extract_info'] ['bank_info'], true)['bank_name'];
  1794. break;
  1795. }
  1796. if (!$data)
  1797. throw new Exception('数据不存在');
  1798. return $data;
  1799. }
  1800. }