|
|
@@ -0,0 +1,235 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace App\Jobs;
|
|
|
+
|
|
|
+use App\Modules\OfficialAccount\Models\ForceSubscribeUsers;
|
|
|
+use App\Modules\OfficialAccount\Models\OfficialAccount;
|
|
|
+use App\Modules\Statistic\Models\SendOrderBreadevenStat;
|
|
|
+use App\Modules\User\Services\UserDivisionCpcPropertyService;
|
|
|
+use Illuminate\Contracts\Queue\ShouldQueue;
|
|
|
+use Illuminate\Queue\InteractsWithQueue;
|
|
|
+use Illuminate\Queue\SerializesModels;
|
|
|
+
|
|
|
+class SendStatisticsList extends Job implements ShouldQueue
|
|
|
+{
|
|
|
+ use InteractsWithQueue, SerializesModels;
|
|
|
+ private $data;
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Create a new job instance.
|
|
|
+ *
|
|
|
+ * @return void
|
|
|
+ */
|
|
|
+ public function __construct($data)
|
|
|
+ {
|
|
|
+ $data['send_time']=date("Y-m-d H:i:s");
|
|
|
+ $this->data = $data;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * Execute the job.
|
|
|
+ *
|
|
|
+ * @return void
|
|
|
+ */
|
|
|
+ public function handle()
|
|
|
+ {
|
|
|
+
|
|
|
+ if($this->data['type'] == 'order_info'){
|
|
|
+ $this->orderInfo($this->data['data']);
|
|
|
+ }elseif($this->data['type'] == 'visit'){
|
|
|
+ $this->visit($this->data['data']['openid']);
|
|
|
+ }elseif($this->data['type'] == 'subscribe'){
|
|
|
+// \Log::info('SendStatisticsList data is');
|
|
|
+// \Log::info($this->data);
|
|
|
+ $this->subscribe($this->data['data']['uid']);
|
|
|
+ }
|
|
|
+ else{
|
|
|
+ $this->subscribe_info($this->data['data']);
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private function orderInfo($order_info){
|
|
|
+
|
|
|
+ $uid = $order_info['uid'];
|
|
|
+ \Log::info('orderInfo_start:'.$uid);
|
|
|
+ $sub_info = ForceSubscribeUsers::where('uid',$uid)->select('official_account_id','appid','created_at','distribution_channel_id')->first();
|
|
|
+ if(is_null($sub_info)){
|
|
|
+ \Log::info('sub_info_is_null:'.$uid);
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ $official = OfficialAccount::where('appid',$sub_info->appid)->select('id','nickname')->first();
|
|
|
+
|
|
|
+ $date = date('Y-m-d',strtotime($sub_info->created_at));
|
|
|
+ $old = $this->getDateRes($date,$sub_info->distribution_channel_id,$official->id);
|
|
|
+ $pay_end = $order_info['pay_end_at'];
|
|
|
+ $sub_timestamp = strtotime($sub_info->created_at);
|
|
|
+ if($pay_end){
|
|
|
+ $pay_end_timestamp = strtotime($pay_end);
|
|
|
+ }else{
|
|
|
+ $pay_end_timestamp = time();
|
|
|
+ }
|
|
|
+ $del = $pay_end_timestamp-$sub_timestamp;
|
|
|
+ if($old){
|
|
|
+
|
|
|
+ if($del <= 86400){
|
|
|
+ $old->recharge_amount_in_one_day = $old->recharge_amount_in_one_day+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_three_days = $old->recharge_amount_in_three_days+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_one_month = $old->recharge_amount_in_one_month+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_two_months = $old->recharge_amount_in_two_months+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_three_months = $old->recharge_amount_in_three_months+$order_info['price'];
|
|
|
+ }
|
|
|
+ if($del > 86400 && $del<= 86400*3){
|
|
|
+ $old->recharge_amount_in_three_days = $old->recharge_amount_in_three_days+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_one_month = $old->recharge_amount_in_one_month+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_two_months = $old->recharge_amount_in_two_months+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_three_months = $old->recharge_amount_in_three_months+$order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del > 86400*3 && $del <= 30*86400){
|
|
|
+ $old->recharge_amount_in_one_month = $old->recharge_amount_in_one_month+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_two_months = $old->recharge_amount_in_two_months+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_three_months = $old->recharge_amount_in_three_months+$order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del > 30*86400 && $del <= 60*86400){
|
|
|
+ $old->recharge_amount_in_two_months = $old->recharge_amount_in_two_months+$order_info['price'];
|
|
|
+ $old->recharge_amount_in_three_months = $old->recharge_amount_in_three_months+$order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del> 60*86400 && $del <= 90*86400){
|
|
|
+ $old->recharge_amount_in_three_months = $old->recharge_amount_in_three_months+$order_info['price'];
|
|
|
+ }
|
|
|
+ $old->save();
|
|
|
+ }else{
|
|
|
+
|
|
|
+ $nickname = '未知';
|
|
|
+ $official_account_id = 0;
|
|
|
+ if($official && isset($official->nickname)){
|
|
|
+ $nickname = $official->nickname;
|
|
|
+ }
|
|
|
+ if($official && isset($official->id)){
|
|
|
+ $official_account_id = $official->id;
|
|
|
+ }
|
|
|
+ $data = [];
|
|
|
+ $data['recharge_amount_in_one_day'] = 0;
|
|
|
+ $data['recharge_amount_in_three_days'] = 0;
|
|
|
+ $data['recharge_amount_in_one_month'] = 0;
|
|
|
+ $data['recharge_amount_in_two_months'] = 0;
|
|
|
+ $data['recharge_amount_in_three_months'] = 0;
|
|
|
+ $data['distribution_channel_id'] = $sub_info->distribution_channel_id;
|
|
|
+ $data['official_account_id'] = $official_account_id;
|
|
|
+ $data['official_account_name'] = $nickname;
|
|
|
+ $data['date'] = $date;
|
|
|
+ $data['force_user_num'] = 0;
|
|
|
+ $data['total_force_user_num'] = 0;
|
|
|
+ $data['unsubscribe_in_one_day_user_num'] =0;
|
|
|
+ if($del <= 86400){
|
|
|
+ $data['recharge_amount_in_one_day'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_three_days'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_one_month'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_two_months'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_three_months'] = $order_info['price'];
|
|
|
+ }
|
|
|
+ if($del > 86400 && $del<= 86400*3){
|
|
|
+ $data['recharge_amount_in_three_days'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_one_month'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_two_months'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_three_months'] = $order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del > 86400*3 && $del <= 30*86400){
|
|
|
+ $data['recharge_amount_in_one_month'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_two_months'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_three_months'] = $order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del > 30*86400 && $del <= 60*86400){
|
|
|
+ $data['recharge_amount_in_two_months'] = $order_info['price'];
|
|
|
+ $data['recharge_amount_in_three_months'] = $order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ if($del> 60*86400 && $del <= 90*86400){
|
|
|
+ $data['recharge_amount_in_three_months'] = $order_info['price'];
|
|
|
+ }
|
|
|
+
|
|
|
+ SendOrderBreadevenStat::create($data);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private function subscribe_info($subscribe_info){
|
|
|
+ $subscribe_info = (array) $subscribe_info;
|
|
|
+ $date = date('Y-m-d',strtotime($subscribe_info['created_at']));
|
|
|
+ $official = OfficialAccount::where('appid',$subscribe_info['appid'])->select('id','nickname')->first();
|
|
|
+ $old = $this->getDateRes($date,$subscribe_info['distribution_channel_id'],$official->id);
|
|
|
+
|
|
|
+ if($old){
|
|
|
+ if( (strtotime($subscribe_info['unsubscribe_time']) - strtotime($subscribe_info['created_at']) ) < 86400){
|
|
|
+ $old->unsubscribe_in_one_day_user_num +=1;
|
|
|
+ $old->save();
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ $data = [];
|
|
|
+
|
|
|
+
|
|
|
+ $nickname = '未知';
|
|
|
+ $official_account_id = 0;
|
|
|
+ if($official && isset($official->nickname)){
|
|
|
+ $nickname = $official->nickname;
|
|
|
+ }
|
|
|
+ if($official && isset($official->id)){
|
|
|
+ $official_account_id = $official->id;
|
|
|
+ }
|
|
|
+ $data['recharge_amount_in_one_day'] = 0;
|
|
|
+ $data['recharge_amount_in_three_days'] = 0;
|
|
|
+ $data['recharge_amount_in_one_month'] = 0;
|
|
|
+ $data['recharge_amount_in_two_months'] = 0;
|
|
|
+ $data['recharge_amount_in_three_months'] = 0;
|
|
|
+ $data['distribution_channel_id'] = $subscribe_info['distribution_channel_id'];
|
|
|
+ $data['official_account_id'] = $official_account_id;
|
|
|
+ $data['official_account_name'] = $nickname;
|
|
|
+ $data['date'] = $date;
|
|
|
+ $data['force_user_num'] = 0;
|
|
|
+ $data['total_force_user_num'] = 0;
|
|
|
+
|
|
|
+ if( (strtotime($subscribe_info['unsubscribe_time']) - strtotime($subscribe_info['created_at']) ) < 86400){
|
|
|
+ $data['unsubscribe_in_one_day_user_num'] =1;
|
|
|
+ }
|
|
|
+
|
|
|
+ SendOrderBreadevenStat::create($data);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ private function subscribe($uid){
|
|
|
+ if(!is_numeric($uid)) return ;
|
|
|
+ //UserDivisionCpcPropertyService::afterForceSubscribe($uid);
|
|
|
+ }
|
|
|
+
|
|
|
+ private function visit($openid){
|
|
|
+ $user = UserDivisionCpcPropertyService::userLevel($openid);
|
|
|
+ if(!$user){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+ if($user->type != 'NEW'){
|
|
|
+ return ;
|
|
|
+ }
|
|
|
+
|
|
|
+ $level = UserDivisionCpcPropertyService::getUserSubscribeAndChargeInfoByOpenid($openid);
|
|
|
+ if(!$level) return ;
|
|
|
+
|
|
|
+ if($level['type'] == $user->type) return ;
|
|
|
+
|
|
|
+ UserDivisionCpcPropertyService::update($openid,$level['property'],$level['type']);
|
|
|
+ }
|
|
|
+
|
|
|
+ private function getDateRes($date,$distribution_channel_id,$official_account_id){
|
|
|
+ return SendOrderBreadevenStat::where('date',$date)
|
|
|
+ ->where('distribution_channel_id',$distribution_channel_id)
|
|
|
+ ->where('official_account_id',$official_account_id)
|
|
|
+ ->first();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+}
|
