Recruitment.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264
  1. <?php namespace App\Http\Controllers\Api\Lottery;
  2. use App\Http\Controllers\Api\Api;
  3. use App\Models\Lottery\Recruitment as Model;
  4. use App\Models\Custom;
  5. use App\Models\CustomCoupon;
  6. use App\Models\CustomScore;
  7. use App\Models\CustomAmount;
  8. use App\Models\Lottery\RecruitmentRecord;
  9. use App\Models\Lottery\RecruitmentReward as RecruitmentReward;
  10. use Illuminate\Support\Facades\DB;
  11. use App\Models\WeiBan\Tags as WeiBanTags;
  12. /**
  13. * 积分抽奖
  14. *
  15. * @author 刘相欣
  16. *
  17. * */
  18. class Recruitment extends Api{
  19. /**
  20. * 获取抽奖配置 /api/lottery_recruitment/get_detail
  21. *
  22. *
  23. * */
  24. public function get_detail(Model $Model,Custom $Custom,RecruitmentReward $RecruitmentReward,RecruitmentRecord $RecruitmentRecord,WeiBanTags $WeiBanTags){
  25. // 接口验签
  26. // $this->verify_sign();
  27. // 检查登录
  28. $uid = $this->checkLogin();
  29. // 接收参数
  30. $id = request('id',0);
  31. // 获取活动
  32. $data = $Model->getOne($id);
  33. // 如果存在的话
  34. if( !$data ) return json_send(['code'=>'error','msg'=>'暂无活动','data'=>$data]);
  35. // 获取客户信息
  36. $custom = $Custom->getOne($uid);
  37. // 如果存在的话
  38. if( !$custom ) return json_send(['code'=>'no_login','msg'=>'请登录','data'=>['error'=>'无对应客户']]);
  39. // 如果客户注册时间不在活动期间
  40. if( $data['start_time'] > $custom['insert_time'] || $data['end_time'] < $custom['insert_time'] ) return json_send(['code'=>'error','msg'=>'账号不在活动范围','data'=>['error'=>'不在活动时间内注册']]);
  41. // 如果城市限制并且不在在城市范围内,不允许参加
  42. if ( $data['city_ids'] && !in_array($custom['city_id'],explode(',',$data['city_ids'])) ) return json_send(['code'=>'error','msg'=>'账号不在城市范围,请核对您的城市','data'=>['error'=>'不在标签范围内']]);
  43. // 判断是不是可以参与
  44. if( $data['tag_scope'] ) {
  45. // 解析数组
  46. $data['tag_scope'] = explode(',',$data['tag_scope']);
  47. // 查询用户标签
  48. $tags = $WeiBanTags->getListByWeibanExtid($custom['weiban_extid']);
  49. // 获取用户的标签
  50. $tags = array_column($tags,'name');
  51. $intersect = count(array_intersect($data['tag_scope'],$tags));
  52. // 判断标签是否必须同时满足
  53. if( $data['tag_scope_type'] == 1 ) {
  54. // 判断用户的标签是否全部满足于标签限制范围内
  55. if( $intersect != count($data['tag_scope']) ) return json_send(['code'=>'error','msg'=>'账号不在标签范围','data'=>['error'=>'不在标签范围内']]);
  56. }else{
  57. // 判断标签限制并且不在标签限制范围内,不允许参加
  58. if( !$intersect ) return json_send(['code'=>'error','msg'=>'账号不在标签范围','data'=>['error'=>'不在标签范围内']]);
  59. }
  60. }
  61. // 默认可以参加活动
  62. $data['allow_join'] = 1;
  63. // 奖品
  64. $reward = $RecruitmentReward->getListByLottery($data['id']);
  65. // 活动暂无奖品
  66. if( !$reward ) return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]);
  67. // 查询条件
  68. $map = [];
  69. // 判断周期
  70. if( !empty($data['freq']) ) {
  71. if( $data['freq'] == 1 ) $map = [['insert_time','>=',now()->addMinutes(-10)->getTimestamp()],['insert_time','<=',now()->endOfDay()->getTimestamp()]];
  72. // if( $data['freq'] == 1 ) $map = [['insert_time','>=',now()->startOfDay()->getTimestamp()],['insert_time','<=',now()->endOfDay()->getTimestamp()]];
  73. if( $data['freq'] == 2 ) $map = [['insert_time','>=',now()->startOfWeek()->getTimestamp()],['insert_time','<=',now()->endOfWeek()->getTimestamp()]];
  74. if( $data['freq'] == 3 ) $map = [['insert_time','>=',now()->startOfMonth()->getTimestamp()],['insert_time','<=',now()->endOfMonth()->getTimestamp()]];
  75. }
  76. // logo
  77. $data['logo'] = $data['logo'] ? path_compat($data['logo']) : '';
  78. // 查询用户已参与次数
  79. $data['join_num'] = (int)$RecruitmentRecord->query()->where([['custom_uid','=',$uid],['lottery_id','=',$id]])->where($map)->count();
  80. // 计算剩余次数
  81. $data['number'] = $data['lucky_num'] - $data['join_num'];
  82. // 最少为0,避免显示异常
  83. $data['number'] = $data['number'] < 0 ? 0 : $data['number'];
  84. // 时间处理
  85. $data['start_date'] = date('Y/m/d H:i',$data['start_time']);
  86. // 时间处理
  87. $data['end_date'] = date('Y/m/d H:i',$data['end_time']);
  88. // 通过活动ID,查询奖品
  89. $data['reward_list'] = [];
  90. // 奖品数据
  91. foreach ($reward as $value) {
  92. // 奖项
  93. $data['reward_list'][] = ['id'=>$value['id'],'name'=>$value['reward_name'],'img'=>$value['reward_thumb'],'reward_type'=>$value['reward_type']];
  94. }
  95. // 返回结果
  96. return json_send(['code'=>'success','msg'=>'获取成功','data'=>$data]);
  97. }
  98. /**
  99. * 抽奖 /api/lottery_recruitment/get_reward
  100. *
  101. * */
  102. public function get_reward(Model $Model,Custom $Custom,RecruitmentRecord $RecruitmentRecord,RecruitmentReward $RecruitmentReward,CustomCoupon $CustomCoupon,CustomScore $CustomScore,CustomAmount $CustomAmount,WeiBanTags $WeiBanTags){
  103. // 接口验签
  104. // $this->verify_sign();
  105. // 检查登录
  106. $uid = $this->checkLogin();
  107. // 获取活动
  108. $lotteryId = request('lottery_id',0);
  109. // 如果存在的话
  110. if( !$lotteryId ) return json_send(['code'=>'error','msg'=>'请选择参与的活动','data'=>['error'=>"抽奖活动ID有误"]]);
  111. // 获取客户信息
  112. $custom = $Custom->getOne($uid);
  113. // 如果存在的话
  114. if( !$custom ) return json_send(['code'=>'no_login','msg'=>'请登录','data'=>['error'=>'无对应客户']]);
  115. // 通过活动ID,查询奖品
  116. $data = $Model->getOne($lotteryId);
  117. // 如果存在的话
  118. if( !$data ) return json_send(['code'=>'error','msg'=>'活动不存在或未开始','data'=>$data]);
  119. // 活动时间判断
  120. if( $data['start_time'] > time() ) return json_send(['code'=>'error','msg'=>'活动暂未开始','data'=>$data]);
  121. // 活动时间判断
  122. if( $data['end_time'] < time() ) return json_send(['code'=>'error','msg'=>'活动已结束','data'=>$data]);
  123. // 如果客户注册时间不在活动期间
  124. if( $data['start_time'] > $custom['insert_time'] || $data['end_time'] < $custom['insert_time'] ) return json_send(['code'=>'error','msg'=>'账号不在活动范围','data'=>['error'=>'不在活动时间内注册']]);
  125. // 如果城市限制并且不在在城市范围内,不允许参加
  126. if ( $data['city_ids'] && !in_array($custom['city_id'],explode(',',$data['city_ids'])) ) return json_send(['code'=>'error','msg'=>'账号不在城市范围,请核对您的城市','data'=>['error'=>'不在标签范围内']]);
  127. // 判断是不是可以参与
  128. if( $data['tag_scope'] ) {
  129. // 解析数组
  130. $data['tag_scope'] = explode(',',$data['tag_scope']);
  131. // 查询用户标签
  132. $tags = $WeiBanTags->getListByWeibanExtid($custom['weiban_extid']);
  133. // 获取用户的标签
  134. $tags = array_column($tags,'name');
  135. $intersect = count(array_intersect($data['tag_scope'],$tags));
  136. // 判断标签是否必须同时满足
  137. if( $data['tag_scope_type'] == 1 ) {
  138. // 判断用户的标签是否全部满足于标签限制范围内
  139. if( $intersect != count($data['tag_scope']) ) return json_send(['code'=>'error','msg'=>'账号不在标签范围','data'=>['error'=>'不在标签范围内']]);
  140. }else{
  141. // 判断标签限制并且不在标签限制范围内,不允许参加
  142. if( !$intersect ) return json_send(['code'=>'error','msg'=>'账号不在标签范围','data'=>['error'=>'不在标签范围内']]);
  143. }
  144. }
  145. // 默认可以参加活动
  146. $data['allow_join'] = 1;
  147. // 奖品
  148. $reward = $RecruitmentReward->getListByLottery($data['id']);
  149. // 活动暂无奖品
  150. if( !$reward ) return json_send(['code'=>'error','msg'=>'活动暂未配置奖品','data'=>$data]);
  151. // 查询条件
  152. $map = [];
  153. // 判断周期
  154. if( !empty($data['freq']) ) {
  155. if( $data['freq'] == 1 ) $map = [['insert_time','>=',now()->addMinutes(-10)->getTimestamp()],['insert_time','<=',now()->endOfDay()->getTimestamp()]];
  156. // if( $data['freq'] == 1 ) $map = [['insert_time','>=',now()->startOfDay()->getTimestamp()],['insert_time','<=',now()->endOfDay()->getTimestamp()]];
  157. if( $data['freq'] == 2 ) $map = [['insert_time','>=',now()->startOfWeek()->getTimestamp()],['insert_time','<=',now()->endOfWeek()->getTimestamp()]];
  158. if( $data['freq'] == 3 ) $map = [['insert_time','>=',now()->startOfMonth()->getTimestamp()],['insert_time','<=',now()->endOfMonth()->getTimestamp()]];
  159. }
  160. // 查询用户已参与次数
  161. $data['join_num'] = (int)$RecruitmentRecord->query()->where([['custom_uid','=',$uid],['lottery_id','=',$lotteryId]])->where($map)->count();
  162. // 计算剩余次数
  163. $data['join_num'] = $data['lucky_num'] - $data['join_num'];
  164. // 如果次数不够
  165. if( $data['join_num'] <= 0 ) return json_send(['code'=>'error','msg'=>'抽奖次数已用完','data'=>['error'=>'抽奖次数已用完']]);
  166. // 抽奖记录
  167. $record = ['custom_uid'=>$uid,'lottery_id'=>$lotteryId,'reward_id'=>0,'reward_name'=>0,'status'=>1];
  168. // 开启事务
  169. DB::beginTransaction();
  170. try{
  171. // 是否限制中奖次数字段,没有默认中奖一次
  172. $data['max_reward'] = isset($data['max_reward']) ? 1 : $data['max_reward'];
  173. // 限制中奖则获取中奖次数
  174. $rewarTotal = $data['max_reward'] ? $RecruitmentRecord->query()->where([['lottery_id','=',$data['id']],['custom_uid','=',$uid],['reward_id','>',0]])->where($map)->count() : 0;
  175. // 中奖上限以后不再中奖
  176. $rewardIndex = ($data['max_reward'] && $rewarTotal >= $data['max_reward']) ? 0 : $RecruitmentReward->getRewardResult($reward);
  177. // 如果中奖,下标不是0
  178. if( $rewardIndex ) {
  179. // 获取奖品
  180. $rewardResult = $reward[$rewardIndex];
  181. // 奖品记录ID
  182. if( !empty($rewardResult['id']) ){
  183. // 如果是积分
  184. if( $rewardResult['reward_type'] == 1 ){
  185. // 积分大于0
  186. if( $rewardResult['reward_info'] > 0 ){
  187. // 积分发放
  188. $result = $CustomScore->trade($uid,$lotteryId,$rewardResult['reward_info'],7,5);
  189. // 发放失败,改为未中奖
  190. if( isset($result['error']) ) $rewardIndex = 0;
  191. // 发放成功,状态为已完成
  192. $record['status']= 8;
  193. }
  194. }
  195. // 优惠券,先进行发放
  196. if( $rewardResult['reward_type'] == 2 ){
  197. // 优惠券存在ID
  198. if( $rewardResult['reward_info'] > 0 ){
  199. // 积分给与
  200. $result = $CustomCoupon->giveCoupon($rewardResult['reward_info'],$uid);
  201. // 发放失败,改为未中奖
  202. if( !$result ) $rewardIndex = 0;
  203. // 发放成功,状态为已完成
  204. $record['status']= 8;
  205. }
  206. }
  207. // 红包
  208. if( $rewardResult['reward_type'] == 3 ){
  209. // 积分大于0
  210. if( $rewardResult['reward_info'] > 0 ){
  211. // 积分发放
  212. $result = $CustomAmount->trade($uid,$lotteryId,$rewardResult['reward_info'],4,1,'灯谜抽奖');
  213. // 发放失败,改为未中奖
  214. if( isset($result['error']) ) $rewardIndex = 0;
  215. // 发放成功,状态为已完成
  216. $record['status']= 8;
  217. }
  218. }
  219. // 如果是实物,要求填写地址,状态设置为0
  220. if( $rewardResult['reward_type'] == 5 ) $record['status'] = 0;
  221. }
  222. }
  223. // 中奖记录奖品
  224. if( $rewardIndex ) {
  225. // 记录,默认状态为1,进行中
  226. $record['reward_id'] = $reward[$rewardIndex]['id'];
  227. $record['reward_name'] = $reward[$rewardIndex]['reward_name'];
  228. // 扣减次数
  229. $RecruitmentReward->edit($rewardResult['id'],['reward_total'=>DB::raw('reward_total+-1')]);
  230. }
  231. // 写入记录
  232. $result = $RecruitmentRecord->add($record);
  233. // 写入失败
  234. if( !$result ) {
  235. // 回退数据
  236. DB::rollBack();
  237. // 提示
  238. return json_send(['code'=>'error','msg'=>'抽奖记录失败,请重试']);
  239. }
  240. // 提交事务
  241. DB::commit();
  242. // 通过活动ID,查询奖品
  243. $rewardList = [];
  244. // 奖品数据
  245. foreach ($reward as $value) {
  246. $rewardList[] = ['id'=>$value['id'],'name'=>$value['reward_name'],'img'=>$value['reward_thumb'],'reward_type'=>$value['reward_type']];
  247. }
  248. // 返回结果
  249. return json_send(['code'=>'success','msg'=>'抽奖成功','data'=>['reward_list'=>$rewardList,'reward_index'=>$rewardIndex,'join_num'=>$data['join_num']-1]]);
  250. // 异常处理
  251. } catch (\Throwable $th) {
  252. // 回退数据
  253. DB::rollBack();
  254. // 下单失败提示
  255. return json_send(['code'=>'error','msg'=>'抽奖失败,请重试','data'=>['error'=>$th->getMessage().$th->getLine()]]);
  256. }
  257. }
  258. }