VideoJob.php 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246
  1. <?php
  2. namespace App\Jobs;
  3. use Illuminate\Bus\Queueable;
  4. use Illuminate\Contracts\Queue\ShouldQueue;
  5. use Illuminate\Foundation\Bus\Dispatchable;
  6. use Illuminate\Queue\InteractsWithQueue;
  7. use Illuminate\Queue\SerializesModels;
  8. use Illuminate\Support\Facades\DB;
  9. use Illuminate\Support\Facades\Redis;
  10. use Illuminate\Support\Facades\Config;
  11. use Illuminate\Support\Facades\Log;
  12. class GiftJob implements ShouldQueue
  13. {
  14. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  15. protected $msgid;
  16. /**
  17. * Create a new job instance.
  18. *
  19. * @return void
  20. */
  21. public function __construct($msgid)
  22. {
  23. //
  24. $this->msgid = $msgid;
  25. Log::info(date('Y-m-d H:i:d').':'.$msgid);
  26. }
  27. /**
  28. * Execute the job.
  29. *
  30. * @return void
  31. */
  32. public function handle()
  33. {
  34. $result = $this->goaaa();
  35. if($result === false){
  36. //防止失败
  37. $key = 'kgelavarel_giftjob_'.$this->msgid;
  38. $limit_rs = $this->apiLimit(2,3600000,$key);//一小时最多另执行2次
  39. if($limit_rs === true){
  40. //echo 123;
  41. dispatch((new GiftJob($this->msgid))->delay(60));//加入队列
  42. }else{
  43. //echo 345;
  44. }
  45. }
  46. }
  47. public function apiLimit($apiLimit = 1, $apiLimitTime = 1000, $key = '')
  48. {
  49. $app_name = Config::get('app.name');// laravel name
  50. $key = "{$app_name}:{$key}";
  51. $redis = Redis::connection();
  52. //
  53. //指定键值新增+1 并获取
  54. $count = $redis->incr($key);
  55. if ($count > $apiLimit) {
  56. return false;
  57. }
  58. //设置过期时间
  59. if ($count == 1) {
  60. $redis->pExpire($key, $apiLimitTime);
  61. }
  62. return true;
  63. }
  64. public function goaaa(){
  65. //
  66. $data = DB::table('hx_gift_user_party')->where('id',$this->msgid)->first();
  67. DB::beginTransaction();
  68. //用户信息
  69. $authuser_info = DB::table('hx_user')->where('id',$data->user_id)->value('nickname');
  70. $partyInfo = DB::table('hx_party')->where('id',$data->party_id)->first();
  71. $jewel_to_money = 1;
  72. $user_id = $data->user_to_id;
  73. // 添加获赠用户余额
  74. if($data->getvalue > 0){
  75. $getMoney = bcdiv($data->getvalue,$jewel_to_money,2);
  76. if($getMoney > 0){
  77. $rs_wallet = $this->lockChangeAccountRemain($user_id,$getMoney,'+',0,"{$authuser_info}送你{$data->gift_name}x{$data->number}",101,'money');
  78. if($rs_wallet['status'] == false){
  79. Db::rollback();
  80. return false;
  81. }
  82. }
  83. }
  84. // 增加房主抽成
  85. if ($partyInfo) {
  86. $guilderMoney = $data->guildermoney;
  87. if($guilderMoney > 0){
  88. $touserInfo = DB::table('hx_user')->where('id',$user_id)->value('nickname');
  89. $rs_wallet = $this->lockChangeAccountRemain($partyInfo->user_id,$guilderMoney,'+',0,"{$authuser_info}送礼物{$data->gift_name}x{$data->number}给{$touserInfo},房间礼物抽成",102,'money');
  90. if($rs_wallet['status'] == false){
  91. Db::rollback();
  92. return false;
  93. }
  94. }
  95. }
  96. Db::commit();
  97. return true;
  98. }
  99. /**
  100. *
  101. * @param floatval $number 金额(正数进账,负数出账)
  102. * @param $accountType 货币类型,money,score
  103. * @param $logtype 日志的类型
  104. * @param $remark 备注
  105. * @param $user_id 用户id
  106. * @param $table 来源表
  107. * @param $data_id 表id
  108. * @param $isAdmin 是否是管理员处理
  109. * @return array
  110. * @return array[status]
  111. * @return array[msg]
  112. * @return array[log_table]
  113. * @return array[log_id]
  114. */
  115. public function lockChangeAccountRemain($user_id,$money,$mode,$before = 0,$remark='',$logtype,$accountType='money',$extend = [])
  116. {
  117. //初始化
  118. $result = array(
  119. 'status'=>false,
  120. 'code' => 0, //报错时候采用
  121. 'msg'=>'',
  122. 'log_table' => '',
  123. 'log_id' => '',
  124. );
  125. //获取小数点
  126. $point = $accountType == 'money' ? 2 : 0;
  127. bcscale($point);
  128. //钱包名称
  129. $wallet_name = '余额';
  130. //数字纠正
  131. $money = abs($money);
  132. if($mode == '-'){
  133. $number = -$money;
  134. }else{
  135. $number = $money;
  136. }
  137. //检测
  138. $number = floatval( $number );
  139. if( $number == 0 )
  140. {
  141. $result['msg'] = '交易金额:0';
  142. return $result;
  143. }
  144. if(0 === bccomp($number, 0)){
  145. $result['msg'] = '交易金额:0';
  146. return $result;
  147. }
  148. //检测
  149. $wallet = DB::table('hx_user_wallet')->where('user_id',$user_id)->lockForUpdate()->first();
  150. if(empty($wallet))
  151. {
  152. $result['msg'] = '不存在的用户';
  153. return $result;
  154. }
  155. if(bccomp(bcadd($wallet->$accountType, $number), 0) === -1)
  156. {
  157. $result['code'] = 10;
  158. $result['msg'] = $wallet_name.'余额不足!';
  159. return $result;
  160. }
  161. if(0 !== bccomp($number, 0))
  162. {
  163. //钱币记录
  164. $data = array();
  165. $data['user_id'] = $user_id;
  166. $data['value'] = $money;
  167. $data['mode'] = $mode;
  168. $data['before'] = $wallet->$accountType;
  169. $data['balance'] = bcadd($wallet->$accountType, $number);
  170. $data['detail'] = $remark;
  171. $data['createtime'] = time();
  172. $data['type'] = $logtype;
  173. if ($accountType == 'jewel') {
  174. $data['cityname'] = isset($extend['cityname']) ? $extend['cityname'] : '';
  175. }
  176. //新的方式
  177. $rs1 = DB::table('hx_user_wallet')->where('user_id',$user_id)->update([$accountType => $data['balance']]);
  178. /////////////
  179. $log_table = 'hx_user_'.$accountType.'_log';
  180. $rs2_id = DB::table($log_table)->insertGetId($data);
  181. if($rs1 === false || $rs2_id === false){
  182. $result['msg'] = '更新财务记录失败!';
  183. return $result;
  184. }
  185. if( $rs1 !== false && $rs2_id !== false )
  186. {
  187. $result['status'] = true;
  188. $result['msg'] = '账户余额已更新!';
  189. $result['log_table'] = $accountType.'_log';
  190. $result['log_id'] = $rs2_id;
  191. return $result;
  192. }
  193. else
  194. {
  195. $result['msg'] = '更新财务记录失败!';
  196. return $result;
  197. }
  198. } else {
  199. $result['msg'] = '金额不足0.01';
  200. return $result;
  201. }
  202. }
  203. }