SendStatsEmailService.php 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162
  1. <?php
  2. /**
  3. * Created by PhpStorm.
  4. * User: z_yang
  5. * Date: 2018/03/09
  6. * Time: 20:18
  7. */
  8. namespace App\Modules\Statistic\Services;
  9. use DB;
  10. use PHPMailer\PHPMailer\PHPMailer;
  11. class SendStatsEmailService
  12. {
  13. /**
  14. * 获取外部派单作品数据
  15. * @param $start_date
  16. * @param $to_date
  17. * @return mixed
  18. */
  19. public static function getOrderStats($start_date,$to_date) {
  20. $to_query = ['tmp.register_uv_rate>=0.85','tmp.register_uv_rate<=0.3'];
  21. //$to_query2 = ['s.register_user_num/s.uv>=0.85','s.register_user_num/s.uv>0.3 and s.register_user_num/s.uv<0.85','s.register_user_num/s.uv<=0.3'];
  22. $finnal = [[],[],[]];
  23. foreach ($to_query as $key=>$value){
  24. $sql = "select t.*,book_categories.pid,book_configs.recommend_index,books.category_id from (SELECT tmp.bid,tmp.book_name,sum(tmp.uv) UV,
  25. sum(tmp.register_user_num) register_user_sum,
  26. sum(tmp.recharge_amount) recharge_sum,
  27. sum(tmp.force_user_num) force_user_sum,
  28. sum(tmp.pay_user_num) pay_user_num,
  29. count(tmp.bid) send_orders_num
  30. FROM (
  31. select s.bid,s.book_name,s.uv,s.register_user_num,s.recharge_amount,s.force_user_num,s.pay_user_num,s.register_user_num/s.uv as register_uv_rate
  32. from send_orders_stats as s where s.send_time between '".$start_date."' and '".$to_date."'
  33. ) tmp
  34. WHERE $value GROUP BY tmp.bid) as t,books,book_categories,book_configs where books.id = t.bid and book_configs.bid=t.bid and book_categories.id = books.category_id";
  35. $res = DB::select($sql);
  36. foreach ($res as $item) {
  37. $temp = array(
  38. 'bid'=>$item->bid,
  39. 'book_name'=>$item->book_name,
  40. 'UV'=>$item->UV,
  41. 'register_user_sum'=>$item->register_user_sum,
  42. 'pay_user_num'=>$item->pay_user_num,
  43. 'recharge_sum'=>$item->recharge_sum,
  44. 'force_user_sum'=>$item->force_user_sum,
  45. 'pid'=>$item->pid,
  46. 'send_orders_num'=>$item->send_orders_num
  47. );
  48. $finnal[$key][] = $temp;
  49. }
  50. }
  51. return $finnal;
  52. }
  53. /**
  54. * 获取外部派单作品数据
  55. * @param $start_date
  56. * @param $to_date
  57. * @return mixed
  58. */
  59. public static function getOrderStatsNew() {
  60. $to_query = ['tmp.register_uv_rate>=0.85','tmp.register_uv_rate<=0.3'];
  61. //$to_query2 = ['s.register_user_num/s.uv>=0.85','s.register_user_num/s.uv>0.3 and s.register_user_num/s.uv<0.85','s.register_user_num/s.uv<=0.3'];
  62. $finnal = [[],[]];
  63. foreach ($to_query as $key=>$value){
  64. $level = $key+1;
  65. $res = DB::select("select * from (select t.*,book_categories.pid,book_configs.recommend_index,books.category_id from (SELECT tmp.bid,tmp.book_name,tmp.charge_type,tmp.is_on_shelf,sum(tmp.uv) UV,
  66. sum(tmp.register_user_num) register_user_sum,
  67. sum(tmp.recharge_amount) recharge_sum,
  68. sum(tmp.force_user_num) force_user_sum,
  69. sum(tmp.pay_user_num) pay_user_num,
  70. SUM(tmp.uv_one_day) AS uv_one_day_sum,
  71. SUM(tmp.uv_three_day) AS uv_three_day_sum,
  72. SUM(tmp.recharge_amount_in_one_day)-SUM(tmp.one_day_year_recharge) AS recharge_amount_in_one_day,
  73. SUM(tmp.recharge_amount_in_three_days)-SUM(tmp.three_day_year_recharge) AS recharge_amount_in_three_days
  74. FROM (
  75. select s.bid,s.book_name,book_configs.charge_type,book_configs.is_on_shelf,s.uv,s.register_user_num,s.recharge_amount,send_order_extra_stats.uv_one_day,send_order_extra_stats.uv_three_day,
  76. IFNULL((SELECT sum(price) FROM orders WHERE orders.send_order_id=s.send_order_id AND orders.`status`='PAID' AND orders.order_type='YEAR' AND orders.created_at > s.send_time AND UNIX_TIMESTAMP(orders.created_at)<=(UNIX_TIMESTAMP(s.send_time)+84600)),0) AS one_day_year_recharge,
  77. IFNULL((SELECT sum(price) FROM orders WHERE orders.send_order_id=s.send_order_id AND orders.`status`='PAID' AND orders.order_type='YEAR' AND orders.created_at > s.send_time AND UNIX_TIMESTAMP(orders.created_at)<=(UNIX_TIMESTAMP(s.send_time)+259200)),0) AS three_day_year_recharge,
  78. s.recharge_amount_in_one_day,s.recharge_amount_in_three_days,s.year_paid_num,
  79. s.force_user_num,s.pay_user_num,s.register_user_num/s.uv as register_uv_rate,s.force_user_num/s.register_user_num as force_sub_rate
  80. from send_orders_stats as s JOIN send_order_extra_stats ON send_order_extra_stats.send_order_id=s.send_order_id
  81. join book_configs on book_configs.bid=s.bid where book_configs.is_on_shelf in (1,2) and s.send_time between '".date('Y-m-d',strtotime('-34 day'))."' and '".date('Y-m-d 23:59:59',strtotime('-4 day'))."' and s.uv >= 100
  82. ) tmp
  83. WHERE $value and tmp.force_sub_rate <= 0.65 GROUP BY tmp.bid) as t,books,book_categories,book_configs where books.id = t.bid and book_configs.bid=t.bid and book_categories.id = books.category_id and book_categories.pid=2) tmp2 where tmp2.uv_one_day_sum >=1000
  84. ");
  85. //$res = DB::select($sql);
  86. foreach ($res as $item) {
  87. $one_day_recharge_uv_rate = $item->uv_one_day_sum>0?round($item->recharge_amount_in_one_day/$item->uv_one_day_sum,2):0;
  88. $three_days_recharge_uv_rate = $item->uv_three_day_sum>0?round($item->recharge_amount_in_three_days/$item->uv_three_day_sum,2):0;
  89. $three_days_recharge_one_day_uv = $item->uv_one_day_sum>0?round($item->recharge_amount_in_three_days/$item->uv_one_day_sum,2):0;
  90. if(($level==1 && (($item->charge_type=='BOOK' && $one_day_recharge_uv_rate>=1)||($item->charge_type=='CHAPTER' && $one_day_recharge_uv_rate>=0.8)))
  91. ||
  92. //($level==2 && (($item->charge_type=='BOOK' && $one_day_recharge_uv_rate>=0.85)||($item->charge_type=='CHAPTER' && $three_days_recharge_uv_rate>=1)))
  93. ($level==2 && (($item->charge_type=='BOOK' && $one_day_recharge_uv_rate>=0.85)||($item->charge_type=='CHAPTER' && $three_days_recharge_one_day_uv>=1.15)))
  94. ){
  95. $temp = array(
  96. 'bid'=>$item->bid,
  97. 'book_name'=>$item->book_name,
  98. 'UV'=>$item->UV,
  99. 'register_user_sum'=>$item->register_user_sum,
  100. 'pay_user_num'=>$item->pay_user_num,
  101. 'recharge_sum'=>$item->recharge_sum,
  102. 'force_user_sum'=>$item->force_user_sum,
  103. 'pid'=>$item->pid,
  104. 'charge_type'=>$item->charge_type,
  105. 'recharge_amount_in_one_day'=>$item->recharge_amount_in_one_day,
  106. 'recharge_amount_in_three_days'=>$item->recharge_amount_in_three_days,
  107. 'uv_one_day_sum'=>$item->uv_one_day_sum,
  108. 'uv_three_day_sum'=>$item->uv_three_day_sum,
  109. 'is_on_shelf'=>$item->is_on_shelf
  110. );
  111. $finnal[$key][] = $temp;
  112. }
  113. }
  114. }
  115. return $finnal;
  116. }
  117. public static function SendHtmlEmailWithAcce(array $to_email,array $param,$accessory=''){
  118. $mail = new PHPMailer(true);// Passing `true` enables exceptions
  119. $mail->CharSet = 'UTF-8';//'UTF-8';
  120. try {
  121. //Server settings
  122. $mail->SMTPDebug = 2; // Enable verbose debug output
  123. $mail->isSMTP(); // Set mailer to use SMTP
  124. $mail->Host = 'smtp.126.com'; //$mail->Host = 'smtp.126.com'; Specify main and backup SMTP servers
  125. $mail->SMTPAuth = true; // Enable SMTP authentication
  126. $mail->Username = 'tushengxiang@126.com'; //$mail->Username = 'tushengxiang@126.com'; // SMTP username
  127. $mail->Password = 'personsincere199'; // SMTP password
  128. $mail->SMTPSecure = 'ssl'; // Enable TLS encryption, `ssl` also accepted
  129. $mail->Port = 587; // TCP port to connect to
  130. //Recipients
  131. $mail->setFrom('tushengxiang@126.com', 'tusx');
  132. $mail->addAddress($to_email[0]['address'], $to_email[0]['name']);
  133. array_shift($to_email);
  134. foreach ($to_email as $item) {
  135. $mail->addCC($item['address'], $item['name']); // Add a recipient
  136. }
  137. //Attachments
  138. if($accessory) $mail->addAttachment($accessory);// Add attachments
  139. $mail->isHTML(true); // Set email format to HTML
  140. $mail->Subject = $param['subject'];
  141. $mail->Body = $param['body'];
  142. $mail->send();
  143. //echo 'Message has been sent';
  144. } catch (\Exception $e) {
  145. echo 'Message could not be sent. Mailer Error: ', $mail->ErrorInfo;
  146. }
  147. }
  148. }