1 <?php 2 /** 3 * create by jxkshu 4 * Date 2017-09-28 5 * 用户签到领取红包 6 */ 7 /** 8 Redis 9 set: key signed:user:mark 标记已签到用户 10 val user_id 11 12 zset key signed:user:today:share:num 记录当天用户分享的次数，凌晨4点删除 13 score 分享的次数 14 val 用户ID 15 zset key signed:user:today:replenishment:num 记录当天用户已经补签的次数，凌晨4点删除 16 score 当天补签的次数 17 val 用户ID 18 */ 19 header("content-type:text/html;charset=utf-8"); 20 require_once('api.base.php'); 21 22 class m_signed extends base 23 { 24 private $redis = null; 25 private $log_dir = null; 26 27 public function __construct(){ 28 parent::__construct(); 29 30 $this->init(); 31 // parent::signer($_POST); 32 // parent::tokengoon($_POST); 33 34 // 连接redis 35 $this->redis = new MyRedis; 36 $this->redis = $this->redis->getRedisCli(); 37 38 // 创建单个文件夹 39 $this->log_dir = __DIR__ . '/../log/return_red_envelope/signed/'; 40 if(!is_dir($this->log_dir)): 41 mkdir($this->log_dir); 42 chmod($this->log_dir, 0777); 43 endif; 44 } 45 46 47 /** 48 * 用户 签到或者补签 49 * @param array $post 客户端传递的数据 50 * @return array 抢红包后的数据 51 */ 52 public function signed($post){ 53 54 parent::signer($_POST); 55 parent::tokengoon($_POST); 56 $user_id = (int)trim($post['user_id']); 57 58 // 延迟0.2秒，防并发 59 usleep(200000); 60 // 判断用户是签到还是补签 61 if( empty($post['type']) || $post['type']==0): 62 // 判断用户是否已签 63 $key = 'signed:user:mark'; 64 if(($this->redis->sIsMember($key, $user_id))): 65 return ['status'=>'fail', 'msg'=>'已签到']; 66 else: 67 // 二次判断用户是否已经签到 68 $day_start = strtotime(date('Y-m-d 0:0:0',time())); 69 $day_end = strtotime(date('Y-m-d 0:0:0',time()))+86399; 70 $sql = "SELECT count(id) as total from sign_red_envelopes where uid=$user_id and time>=$day_start and time<=$day_end and amount>0"; 71 $sign_num = (int) parent::result_first($sql); 72 if($sign_num>0): 73 return ['status'=>'fail', 'msg'=>'已签到']; 74 endif; 75 endif; 76 // 用户签到 77 $res = $this->userSigned($user_id, $post['time']); 78 else: 79 if( $post['time'] >= strtotime(date('Y-m-d 0:0:0'))): 80 return ['status'=>'fail', 'msg'=>'日期错误']; 81 endif; 82 $res = $this->userReplenishment($user_id, $post['time']); 83 endif; 84 85 if($res['status']=='fail'): 86 $this->writeLog(__FILE__, __LINE__, $res['msg']); 87 endif; 88 return $res; 89 } 90 91 92 /** 93 * 用户补签 94 * @param int $user_id 用户ID 95 * @param int $time 用户签到时间 96 * @return array status:状态、msg:信息、amount:奖励金额、replenishment_num:剩余可以补签的次数 97 */ 98 protected function userReplenishment($user_id, $time){ 99 100 // 获取用户当天已经补签的次数 101 $replenishment = $this->redis->zScore('signed:user:today:replenishment:num', $user_id); 102 // 获取用户当天线下消费额度 103 $tim = date('Ymd'); 104 $sql = "SELECT sum(amount) as total_amount FROM payinfo where pay_dateint='$tim' and uid=$user_id and status=1 and is_ol_verify=0"; 105 $total_amount = (int) parent::result_first($sql); 106 107 // 判断用户补签次数是否超出 108 $total_amount = (int) ($total_amount/58); 109 $replenishment = (int)$replenishment; 110 if( $total_amount<=$replenishment ): 111 return ['status'=>'fail', 'msg'=>'补签失败，消费额度不足！']; 112 endif; 113 114 // 补签次数累加1 115 $res = $this->redis->zIncrBy('signed:user:today:replenishment:num', 1, $user_id); 116 if(empty($res)): 117 return ['status'=>'fail', 'msg'=>'补签次数累加失败！']; 118 endif; 119 120 //获取用户补签奖励金额 121 $amount = mt_rand(50, 100) / 100; 122 123 // 记录用户补签信息 124 $data = [ 125 'uid' => $user_id, 126 'type' => 1, 127 'amount' => $amount, 128 'time' => $time, 129 ]; 130 $res = parent::insert('sign_red_envelopes', $data); 131 if(empty($res)): 132 return ['status'=>'fail', 'msg'=>'写入补签红包记录数据库失败！']; 133 endif; 134 135 // 累加用户签到奖励 136 $sql = "UPDATE userinfo SET sign_reward=(sign_reward+$amount),total_sign_reward=(total_sign_reward+$amount) where id=$user_id limit 1"; 137 $res = parent::query($sql); 138 if(empty($res)): 139 return ['status'=>'fail', 'msg'=>'累加用户补签奖励失败！']; 140 endif; 141 return ['status'=>'success', 'msg'=>'用户补签成功', 'amount'=>$amount, 'replenishment_num'=>($total_amount-$replenishment)]; 142 } 143 144 145 146 /** 147 * 用户签到 148 * @param int $user_id 用户ID 149 * @param int $time 用户签到时间 150 * @return array 151 */ 152 protected function userSigned($user_id, $time){ 153 154 // 获取签到奖励金额 155 $amount = self::getSignedAmount($user_id); 156 $data = [ 157 'uid' => $user_id, 158 'amount' => $amount, 159 'time' => $time, 160 ]; 161 $res = parent::insert('sign_red_envelopes', $data); 162 if(empty($res)): 163 return ['status'=>'fail', 'msg'=>'写入签到红包记录数据库失败！']; 164 endif; 165 166 // 累加用户签到奖励 167 $sql = "UPDATE userinfo SET sign_reward=(sign_reward+$amount),total_sign_reward=(total_sign_reward+$amount) where id=$user_id limit 1"; 168 $res = parent::query($sql); 169 if(empty($res)): 170 return ['status'=>'fail', 'msg'=>'累加用户签到奖励失败！']; 171 endif; 172 173 // 标记用户已经签到 174 $res = $this->redis->sAdd('signed:user:mark', $user_id); 175 return ['status'=>'success', 'amount'=>$amount]; 176 } 177 178 179 /** 180 * 获取用户签到奖励金额 181 * @param int $user_id 182 * @return float 奖励金额 183 */ 184 protected static function getSignedAmount($user_id){ 185 186 // 判断用户是不是第一次签到 187 $sql = "SELECT count(id) as total FROM sign_red_envelopes where uid=$user_id limit 1"; 188 $total = parent::result_first($sql); 189 190 // 获取签到奖励金额 191 if(empty($total)): 192 // 首次签到 193 $amount = mt_rand(1,2); 194 else: 195 //提升红包额度 196 $sql = "SELECT share_num from userinfo where id=$user_id limit 1"; 197 $share_num = parent::result_first($sql); 198 $share_num = ($share_num>20 ? 20 : $share_num); 199 $min = (0.1 + (0.1 * ($share_num*0.1))) * 100; 200 $max = (1 + (1*($share_num*0.05))) * 100; 201 $max = ($max>200 ? 200 : $max); 202 203 $amount = mt_rand($min, $max) / 100; 204 $amount = number_format($amount, 2); 205 endif; 206 207 return $amount; 208 } 209 210 211 // -------------------------------- 用户将奖励提转到58券 212 213 214 /** 215 * 用户将奖励提转到58券 216 * @param array $post=>user_id 用户id 217 * @return array 218 */ 219 public function rewardTo58voucher($post){ 220 221 parent::signer($_POST); 222 parent::tokengoon($_POST); 223 // 获取用户已经累计的签到红包 224 $sql = 'SELECT id,sign_reward FROM userinfo WHERE id='.$post['user_id'].' limit 1'; 225 $userinfo = parent::fetch_first($sql); 226 if($userinfo['sign_reward']<20): 227 return ['errcode'=>'44','msg'=>'代金券未满20']; 228 endif; 229 230 // 红包转换成58券 231 $sql='UPDATE userinfo SET sign_reward=0, red_reward=(red_reward+'.$userinfo['sign_reward'].') WHERE id='.$post['user_id'].' LIMIT 1'; 232 $res = parent::query($sql); 233 if(empty($res)): 234 return ['errcode'=>'3','msg'=>'服务器异常！']; 235 endif; 236 // 记录行为到红包 237 $tim = time(); 238 $data = [ 239 'uid'=>$post['user_id'], 240 'orderid'=>'', 241 'amount'=>$userinfo['sign_reward'], 242 'packet_status'=>1, 243 'receive_time'=>date('Y-m-d H:i:s', $tim), 244 'packet_type'=>6, 245 'add_time'=>date('Y-m-d H:i:s', $tim), 246 'dateint'=>date('Ymd', $tim), 247 ]; 248 $res = parent::insert('redpacket', $data); 249 if(empty($res)): 250 return ['errcode'=>'400','msg'=>'提转成功！但记录提转信息失败！']; 251 endif; 252 return ['errcode'=>0,'msg'=>'提转成功！']; 253 } 254 255 256 /** 257 * 获取剩余补签次数 258 * @param int $user_id 用户ID 259 * @return array 260 */ 261 public function getSignCard($user_id){ 262 263 parent::signer($_POST); 264 parent::tokengoon($_POST); 265 // 获取用户当天已经补签的次数 266 $replenishment = $this->redis->zScore('signed:user:today:replenishment:num', $user_id); 267 // 获取用户当天线下消费额度 268 $tim = date('Ymd'); 269 //$sql = "SELECT sum(amount) as total_amount FROM payinfo where pay_dateint='$tim' and uid=$user_id and status=1 and (order_type=0 or order_type=4)"; 270 $sql = "SELECT sum(amount) as total_amount FROM payinfo where pay_dateint='$tim' and uid=$user_id and status=1 "; 271 272 $total_amount = (int) parent::result_first($sql); 273 274 // 判断用户补签次数是否超出 275 $total_amount = (int) ($total_amount/58); 276 $replenishment = (int) $replenishment; 277 278 return ['card_num'=>($total_amount - $replenishment)]; 279 } 280 281 282 // 用户分享朋友圈来提升签到红包额度 283 public function userShareAppToPeople($user_id){ 284 285 parent::signer($_POST); 286 // 将分享次数暂时记录到redis，每天凌晨定时任务在写入数据库 287 $key = 'signed:user:today:share:num'; 288 $res = $this->redis->zIncrBy($key, 1, $user_id); 289 return ['signed_num'=>$res]; 290 } 291 292 293 // 写日志 294 private function writeLog($fil, $row, $remarks=''){ 295 $file = $this->log_dir . 'signed-'.date('Y-m').'.txt'; 296 $content = $fil.' Line ' . $row . ' failed '.date('Y-m-d H:i:s')." $remarks "; 297 file_put_contents($file, $content, FILE_APPEND); 298 } 299 300 301 302 303 //---------------------------- 获取用户签到界面的信息 304 305 public function getSignPageInfo($post){ 306 307 parent::signer($_POST); 308 parent::tokengoon($_POST); 309 $user_id = parent::parseuid($post); 310 $data = []; 311 312 // 分享URL 313 $tim = time(); 314 $salt = '58_life_circle_sign_share'; 315 $sign = mb_strcut(md5('58_life_circle_sign_share'.$tim), 0, 6, 'utf8'); 316 $data['share_url'] = 'http://api.licheepay.com/lzf/html/sign_share/h5.html?uid='.$user_id.'&time='.$tim.'&sign='.$sign; 317 // 广告图 318 $data['header_advert'] = [ 319 // [ 320 // 'img'=> 'http://adm.licheepay.com/upload/mall/1509331172.png', 321 // 'url'=> 'app_web_$$$https://s.click.taobao.com/7IlNyYw$$$', 322 // ], 323 // [ 324 // 'img'=> 'http://adm.licheepay.com/upload/mall/1509523936.png', 325 // 'url'=> 'app_web_>>>http://mp.weixin.qq.com/s/BDSD_jDgCmMxfCdieLxtxg<<<', 326 // ], 327 [ 328 'img'=> 'http://adm.licheepay.com/upload/img/ad/20170508161142.png', 329 'url'=> 'app_web_>>>http://mp.weixin.qq.com/s/BDSD_jDgCmMxfCdieLxtxg<<<', 330 ], 331 332 ]; 333 // 获取累计签到奖励 334 $sql = 'SELECT sign_reward,total_sign_reward FROM userinfo WHERE id='.$user_id.' limit 1'; 335 $temp_user_sign = parent::fetch_first($sql); 336 $data['sign_reward'] = $temp_user_sign['sign_reward']; 337 $data['total_sign_reward'] = $temp_user_sign['total_sign_reward']; 338 339 // 签到奖励提取状态【是否可提取】 340 $data['extract_status'] = 0; 341 if($temp_user_sign['sign_reward']>=20): 342 $data['extract_status'] = 1; 343 endif; 344 345 346 // 签到说明 347 $data['sign_explain'] = '1、签到后可抢代金券红包，满20券可用 348 2、用户每天可签到一次，每次可获得随机劵奖励 349 3、代金券每月15号自动清零，满20券请及时领取 350 4、线下消费满58元，可手动补签1次，当天有效 351 5、签到后分享好友，好友参与可提高次日红包金额'; 352 353 // 签到状态 354 // 判断用户是否已签 355 $data['signed_status'] = 0; 356 $key = 'signed:user:mark'; 357 if(($this->redis->sIsMember($key, $user_id))): 358 $data['signed_status'] = 1; 359 endif; 360 // // 二次判断用户是否已经签到 2017-11-01屏蔽 361 $day_start = strtotime(date('Y-m-d 0:0:0',time())); 362 $day_end = strtotime(date('Y-m-d 0:0:0',time()))+86399; 363 $sql = "SELECT count(id) as total from sign_red_envelopes where uid=$user_id and time>=$day_start and time<=$day_end and amount>0"; 364 $sign_num = (int) parent::result_first($sql); 365 if($sign_num<1): 366 $data['signed_status'] = 0; 367 else: 368 $data['signed_status'] = 1; 369 endif; 370 371 372 // 时间戳 373 $data['time'] = time(); 374 return $data; 375 } 376 377 378 379 // 获取用户签到信息日历 380 public function getUserSignInfoCalendar($post){ 381 382 parent::signer($_POST); 383 parent::tokengoon($_POST); 384 $user_id = parent::parseuid($post); 385 386 // 当前月份 387 $total_day = date('t'); 388 $current_month = date('m'); 389 $first_day = strtotime(date("Y-m-01")); 390 $last_day = $first_day + ($total_day*86400) - 1; 391 $sql = "SELECT FROM_UNIXTIME(time,'%e') as day,type 392 FROM sign_red_envelopes 393 WHERE uid=$user_id and time>=$first_day and time<=$last_day"; 394 //获取用户签到信息 395 $sign_info = parent::fetch_all($sql); 396 // 获取用户补签卡 397 $card_num = $this->getSignCard($user_id); 398 $card_num = $card_num['card_num']; 399 400 $today = date('d'); 401 // 1:未签、 2:已签到、3:已补签 4:可补签、 5:漏签、 6:不可签、 402 $temp_current = []; 403 for ($i=$total_day; $i>0; $i--) { 404 $status = 0; 405 // 签到或者补签 406 foreach ($sign_info as $sign) { 407 if($sign['day']==$i): 408 $status = empty($sign['type']) ? 2 : 3; 409 break; 410 endif; 411 } 412 // 1:未签 413 if($status==0 && $i==$today): 414 $status = 1; 415 endif; 416 //4:可补签 417 if($status==0 && $i<$today && $card_num>0): 418 $status = 4; 419 $card_num--; 420 endif; 421 // 6:不可签 422 if($status==0 && $i>$today): 423 $status = 6; 424 endif; 425 // 5:漏签 426 if($status==0): 427 $status = 5; 428 endif; 429 $temp_current[$i] = $status; 430 } 431 432 433 // 上月份 434 $last_month = date('m', time()) - 1; 435 if( $last_month<1 ): 436 $last_month = 12; 437 $time_str = (date('Y',time()) - 1) . '-12-01'; 438 $total_day = date('t', strtotime($time_str)); 439 $first_day = strtotime($time_str); 440 $last_day = $first_day + ($total_day*86400) - 1; 441 else: 442 $time_str = date('Y',time()) .'-'.$last_month.'-01'; 443 $total_day = date('t', strtotime( $time_str)); 444 $last_month = date('m', strtotime( $time_str)); 445 $first_day = strtotime( $time_str); 446 $last_day = $first_day + ($total_day*86400) - 1; 447 endif; 448 $sql = "SELECT FROM_UNIXTIME(time,'%e') as day,type 449 FROM sign_red_envelopes 450 WHERE uid=$user_id and time>=$first_day and time<=$last_day"; 451 //获取用户签到信息 452 $sign_info = parent::fetch_all($sql); 453 // 2:已签到、3:已补签 4:可补签、 5:漏签、 454 $temp_last = []; 455 for ($i=$total_day; $i>0; $i--) { 456 $status = 0; 457 // 签到或者补签 458 foreach ($sign_info as $sign) { 459 if($sign['day']==$i): 460 $status = empty($sign['type']) ? 2 : 3; 461 endif; 462 } 463 //可补签 464 if($status==0 && $card_num>0): 465 $status = 4; 466 $card_num--; 467 endif; 468 // 5:漏签 469 if($status==0): 470 $status = 5; 471 endif; 472 473 $temp_last[$i] = $status; 474 } 475 476 477 ksort($temp_current); //当前月份 478 ksort($temp_last); //上月份 479 $data = [ 480 [ 481 'month'=>$current_month, 482 'status' =>array_values($temp_current) 483 ], 484 [ 485 'month' =>$last_month, 486 'status'=>array_values($temp_last) 487 ], 488 ]; 489 return $data; 490 } 491 492 493 }//end