GiftJob.php 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258
  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)->where('new_task_status',0)->first();
  67. if(empty($data)){
  68. return true;
  69. }
  70. DB::beginTransaction();
  71. //用户信息
  72. $authuser_info = DB::table('hx_user')->where('id',$data->user_id)->value('nickname');
  73. $partyInfo = DB::table('hx_party')->where('id',$data->party_id)->first();
  74. $jewel_to_money = 1;
  75. $user_id = $data->user_to_id;
  76. // 添加获赠用户余额
  77. if($data->getvalue > 0){
  78. $getMoney = bcdiv($data->getvalue,$jewel_to_money,2);
  79. if($getMoney > 0){
  80. $rs_wallet = $this->lockChangeAccountRemain($user_id,$getMoney,'+',0,"{$authuser_info}送你{$data->gift_name}x{$data->number}",101,'money',$this->msgid);
  81. if($rs_wallet['status'] == false){
  82. Db::rollback();
  83. return false;
  84. }
  85. }
  86. }
  87. // 增加房主抽成
  88. if ($partyInfo) {
  89. $guilderMoney = $data->guildermoney;
  90. if($guilderMoney > 0){
  91. $touserInfo = DB::table('hx_user')->where('id',$user_id)->value('nickname');
  92. $rs_wallet = $this->lockChangeAccountRemain($partyInfo->user_id,$guilderMoney,'+',0,"{$authuser_info}送礼物{$data->gift_name}x{$data->number}给{$touserInfo},房间礼物抽成",102,'money',$this->msgid);
  93. if($rs_wallet['status'] == false){
  94. Db::rollback();
  95. return false;
  96. }
  97. }
  98. }
  99. $update_data = ['new_task_status'=>1];
  100. $rs_update = DB::table('hx_gift_user_party')->where('id',$this->msgid)->update($update_data);
  101. if(!$rs_update){
  102. Db::rollBack();
  103. return false;
  104. }
  105. Db::commit();
  106. return true;
  107. }
  108. /**
  109. *
  110. * @param floatval $number 金额(正数进账,负数出账)
  111. * @param $accountType 货币类型,money,score
  112. * @param $logtype 日志的类型
  113. * @param $remark 备注
  114. * @param $user_id 用户id
  115. * @param $table 来源表
  116. * @param $data_id 表id
  117. * @param $isAdmin 是否是管理员处理
  118. * @return array
  119. * @return array[status]
  120. * @return array[msg]
  121. * @return array[log_table]
  122. * @return array[log_id]
  123. */
  124. public function lockChangeAccountRemain($user_id,$money,$mode,$before = 0,$remark='',$logtype,$accountType='money',$msgid = 0)
  125. {
  126. //初始化
  127. $result = array(
  128. 'status'=>false,
  129. 'code' => 0, //报错时候采用
  130. 'msg'=>'',
  131. 'log_table' => '',
  132. 'log_id' => '',
  133. );
  134. //获取小数点
  135. $point = $accountType == 'money' ? 2 : 0;
  136. bcscale($point);
  137. //钱包名称
  138. $wallet_name = '余额';
  139. //数字纠正
  140. $money = abs($money);
  141. if($mode == '-'){
  142. $number = -$money;
  143. }else{
  144. $number = $money;
  145. }
  146. //检测
  147. $number = floatval( $number );
  148. if( $number == 0 )
  149. {
  150. $result['msg'] = '交易金额:0';
  151. return $result;
  152. }
  153. if(0 === bccomp($number, 0)){
  154. $result['msg'] = '交易金额:0';
  155. return $result;
  156. }
  157. //检测
  158. $wallet = DB::table('hx_user_wallet')->where('user_id',$user_id)->lockForUpdate()->first();
  159. if(empty($wallet))
  160. {
  161. $result['msg'] = '不存在的用户';
  162. return $result;
  163. }
  164. if(bccomp(bcadd($wallet->$accountType, $number), 0) === -1)
  165. {
  166. $result['code'] = 10;
  167. $result['msg'] = $wallet_name.'余额不足!';
  168. return $result;
  169. }
  170. if(0 !== bccomp($number, 0))
  171. {
  172. //钱币记录
  173. $data = array();
  174. $data['user_id'] = $user_id;
  175. $data['value'] = $money;
  176. $data['mode'] = $mode;
  177. $data['before'] = $wallet->$accountType;
  178. $data['balance'] = bcadd($wallet->$accountType, $number);
  179. $data['detail'] = $remark;
  180. $data['createtime'] = time();
  181. $data['type'] = $logtype;
  182. $data['msgid'] = $msgid;
  183. //新的方式
  184. $rs1 = DB::table('hx_user_wallet')->where('user_id',$user_id)->update([$accountType => $data['balance']]);
  185. /////////////
  186. $log_table = 'hx_user_'.$accountType.'_log';
  187. $rs2_id = DB::table($log_table)->insertGetId($data);
  188. if($rs1 === false || $rs2_id === false){
  189. $result['msg'] = '更新财务记录失败!';
  190. return $result;
  191. }
  192. if( $rs1 !== false && $rs2_id !== false )
  193. {
  194. $result['status'] = true;
  195. $result['msg'] = '账户余额已更新!';
  196. $result['log_table'] = $accountType.'_log';
  197. $result['log_id'] = $rs2_id;
  198. return $result;
  199. }
  200. else
  201. {
  202. $result['msg'] = '更新财务记录失败!';
  203. return $result;
  204. }
  205. } else {
  206. $result['msg'] = '金额不足0.01';
  207. return $result;
  208. }
  209. }
  210. }