Alltools.php 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380
  1. <?php
  2. namespace App\Common\Library;
  3. use Illuminate\Support\Facades\DB;
  4. class Alltools {
  5. //四大收益,视频,音频,私聊,礼物
  6. public function shouyi($user_id,$gold,$table,$table_id){
  7. //精确小数点
  8. bcscale(2);
  9. //枚举
  10. $table_enum = [
  11. 'user_match_audio_log' => [
  12. 'prefix'=>'audio',
  13. 'remark' =>'语音',
  14. ],
  15. 'user_match_typing_log' => [
  16. 'prefix'=>'typing',
  17. 'remark' =>'私聊',
  18. ],
  19. 'user_match_video_log' => [
  20. 'prefix'=>'video',
  21. 'remark' =>'视频',
  22. ],
  23. 'gift_user_typing' => [
  24. 'prefix'=>'gift',
  25. 'remark' =>'收礼',
  26. ],
  27. ];
  28. //变量前缀,钱包备注
  29. $prefix = $table_enum[$table]['prefix'];
  30. $remark = $table_enum[$table]['remark'];
  31. //配置
  32. $config_site = DB::table('mt_config')->whereIn('name',['shouyi_b2a_rate','shouyi_c2a_rate'])->pluck('value','name');
  33. //收益者本人
  34. $userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','shouyi_b2a_rate','shouyi_c2a_rate'])->where('id',$user_id)->first();
  35. //先确认自己的等级
  36. if($userinfo->group_id == 1){
  37. //充值者上级
  38. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','shouyi_b2a_rate','shouyi_c2a_rate'])->where('id',$userinfo->intro_uid)->first();
  39. if(empty($intro_userinfo)){return true;}
  40. //上级是二级邀请B1,贡献给A
  41. if($intro_userinfo->group_id == 2){
  42. //充值者上上级,也就是A
  43. $intro_intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','shouyi_b2a_rate','shouyi_c2a_rate'])->where('id',$intro_userinfo->agent_id)->first();
  44. if(empty($intro_intro_userinfo)){return true;}
  45. if($intro_intro_userinfo->group_id == 3){
  46. $shouyi_c2a_rate = !empty($intro_intro_userinfo->shouyi_c2a_rate) ? $intro_intro_userinfo->shouyi_c2a_rate : $config_site['shouyi_c2a_rate'];
  47. $jewelA = bcdiv(bcmul($gold,$shouyi_c2a_rate),100);
  48. $result = $this->lockChangeAccountRemain($intro_intro_userinfo->id,'agentjewel',$jewelA,52, $userinfo->username.$remark,$table,$table_id);
  49. if($result['status']===false)
  50. {
  51. //Db::rollback();
  52. return false;
  53. }
  54. }
  55. return true;
  56. }
  57. //上级是A
  58. if($intro_userinfo->group_id == 3){
  59. $shouyi_b2a_rate = !empty($intro_userinfo->shouyi_c2a_rate) ? $intro_userinfo->shouyi_c2a_rate : $config_site['shouyi_c2a_rate'];//b2a 与 b02a相等
  60. $jewelA = bcdiv(bcmul($gold,$shouyi_b2a_rate),100);
  61. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,52, $userinfo->username.$remark,$table,$table_id);
  62. if($result['status']===false)
  63. {
  64. //Db::rollback();
  65. return false;
  66. }
  67. return true;//结束了
  68. }
  69. }
  70. if($userinfo->group_id == 2){
  71. //充值者上级
  72. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','shouyi_b2a_rate','shouyi_c2a_rate'])->where('group_id',3)->where('id',$userinfo->agent_id)->first();
  73. if(empty($intro_userinfo)){return true;}
  74. $shouyi_b2a_rate = !empty($intro_userinfo->shouyi_b2a_rate) ? $intro_userinfo->shouyi_b2a_rate : $config_site['shouyi_b2a_rate'];
  75. $jewelA = bcdiv(bcmul($gold,$shouyi_b2a_rate),100);
  76. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,52, $userinfo->username.$remark,$table,$table_id);
  77. if($result['status']===false)
  78. {
  79. //Db::rollback();
  80. return false;
  81. }
  82. return true;//结束了
  83. }
  84. //没有推荐人,自己等级最高,可能需要注释
  85. if($userinfo->group_id == 3 && !empty($userinfo->intro_uid)){
  86. //充值者上级
  87. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','shouyi_b2a_rate','shouyi_c2a_rate'])->where('id',$userinfo->intro_uid)->first();
  88. if(empty($intro_userinfo)){return true;}
  89. $shouyi_b2a_rate = !empty($intro_userinfo->shouyi_b2a_rate) ? $intro_userinfo->shouyi_b2a_rate : $config_site['shouyi_b2a_rate'];
  90. $jewelA = bcdiv(bcmul($gold,$shouyi_b2a_rate),100);
  91. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,52, $userinfo->username.$remark,$table,$table_id);
  92. if($result['status']===false)
  93. {
  94. //Db::rollback();
  95. return false;
  96. }
  97. return true;//结束了
  98. }
  99. //////////////////
  100. return true;
  101. }
  102. //充值后奖金
  103. public function recharge($user_id,$gold,$table,$payorder_id,$remark = '',$times = 0){
  104. //充值者本人
  105. $userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('id',$user_id)->first();
  106. //配置
  107. $config_site = DB::table('mt_config')->whereIn('name',['invite_recharge_rate','recharge_b2a_rate','recharge_c2a_rate'])->pluck('value','name');
  108. //备注
  109. $remark = !empty($remark) ? $remark : $userinfo->username.'充值';
  110. //个人直推邀请充值
  111. if(!empty($userinfo->invite_uid) && $userinfo->gender == 1 && empty($userinfo->intro_uid)){
  112. $recharge_invite_rate = $config_site['invite_recharge_rate'];
  113. $jewel = bcdiv(bcmul($gold,$recharge_invite_rate,1),100,1);
  114. $result = $this->lockChangeAccountRemain($userinfo->invite_uid,'jewel',$jewel,41, $remark,'pay_order',$payorder_id);
  115. if($result['status']===false)
  116. {
  117. //Db::rollback();
  118. return false;
  119. }
  120. //D2C,C2A
  121. $invite_info = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('id',$userinfo->invite_uid)->first();
  122. if($userinfo->group_id == 1 && !empty($invite_info->intro_uid) && $times == 0){
  123. $times = 1;//可以执行的次数
  124. $recharge_rs = $this->recharge($userinfo->invite_uid,$jewel,'pay_order',$payorder_id,$invite_info->username.'邀请'.$remark,$times);
  125. return $recharge_rs;
  126. }
  127. }
  128. //没有推荐人,女性充值不返
  129. if(empty($userinfo->intro_uid) || ($userinfo->gender == 0 && $times == 0)){
  130. return true;
  131. }
  132. //精确小数点
  133. bcscale(2);
  134. //自己等级最高,可能需要注释掉
  135. if($userinfo->group_id == 3 && !empty($userinfo->intro_uid)){
  136. //充值者上级
  137. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('id',$userinfo->intro_uid)->first();
  138. if(empty($intro_userinfo)){return true;}
  139. $recharge_b2a_rate = !empty($intro_userinfo->recharge_b2a_rate) ? $intro_userinfo->recharge_b2a_rate : $config_site['recharge_b2a_rate'];
  140. $jewelA = bcdiv(bcmul($gold,$recharge_b2a_rate),100);
  141. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,51, $remark,'pay_order',$payorder_id);
  142. if($result['status']===false)
  143. {
  144. //Db::rollback();
  145. return false;
  146. }
  147. return true;//结束了
  148. }
  149. if($userinfo->group_id == 2){
  150. //充值者上级
  151. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('group_id',3)->where('id',$userinfo->agent_id)->first();
  152. if(empty($intro_userinfo)){return true;}
  153. $recharge_b2a_rate = !empty($intro_userinfo->recharge_b2a_rate) ? $intro_userinfo->recharge_b2a_rate : $config_site['recharge_b2a_rate'];
  154. $jewelA = bcdiv(bcmul($gold,$recharge_b2a_rate),100);
  155. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,51, $remark,'pay_order',$payorder_id);
  156. if($result['status']===false)
  157. {
  158. //Db::rollback();
  159. return false;
  160. }
  161. return true;//结束了
  162. }
  163. if($userinfo->group_id == 1){ //二次调用保证走这里
  164. //充值者上级
  165. $intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('id',$userinfo->intro_uid)->first();
  166. if(empty($intro_userinfo)){return true;}
  167. //上级是二级邀请B1,本人C1,贡献给B的上级A
  168. if($intro_userinfo->group_id == 2){
  169. //充值者上上级,也就是A
  170. $intro_intro_userinfo = DB::table('mt_user')->select(['id','username','group_id','intro_uid','invite_uid','agent_id','gender','recharge_b2a_rate','recharge_c2a_rate'])->where('id',$intro_userinfo->agent_id)->first();
  171. if(empty($intro_intro_userinfo)){return true;}
  172. if($intro_intro_userinfo->group_id == 3){
  173. $recharge_c2a_rate = !empty($intro_intro_userinfo->recharge_c2a_rate) ? $intro_intro_userinfo->recharge_c2a_rate : $config_site['recharge_c2a_rate'];
  174. $jewelA = bcdiv(bcmul($gold,$recharge_c2a_rate),100);
  175. $result = $this->lockChangeAccountRemain($intro_intro_userinfo->id,'agentjewel',$jewelA,51, $remark,'pay_order',$payorder_id);
  176. if($result['status']===false)
  177. {
  178. //Db::rollback();
  179. return false;
  180. }
  181. }
  182. return true;
  183. }
  184. //上级是A1
  185. if($intro_userinfo->group_id == 3){
  186. $recharge_c2a_rate = !empty($intro_userinfo->recharge_c2a_rate) ? $intro_userinfo->recharge_c2a_rate : $config_site['recharge_c2a_rate'];//b2a 与 b02a相等
  187. $jewelA = bcdiv(bcmul($gold,$recharge_c2a_rate),100);
  188. $result = $this->lockChangeAccountRemain($intro_userinfo->id,'agentjewel',$jewelA,51, $remark,'pay_order',$payorder_id);
  189. if($result['status']===false)
  190. {
  191. //Db::rollback();
  192. return false;
  193. }
  194. return true;//结束了
  195. }
  196. }
  197. return true;
  198. }
  199. /**
  200. *
  201. * @param floatval $number 金额(正数进账,负数出账)
  202. * @param $accountType 货币类型,money,score
  203. * @param $logtype 日志的类型
  204. * @param $remark 备注
  205. * @param $user_id 用户id
  206. * @param $table 来源表
  207. * @param $data_id 表id
  208. * @param $isAdmin 是否是管理员处理
  209. * @return array
  210. * @return array[status]
  211. * @return array[msg]
  212. * @return array[log_table]
  213. * @return array[log_id]
  214. */
  215. public function lockChangeAccountRemain($user_id,$accountType='gold',$number,$logtype='',$remark='',$table='',$table_id=0,$isAdmin=false)
  216. {
  217. //初始化
  218. $result = array(
  219. 'status'=>false,
  220. 'msg'=>'',
  221. 'log_table' => '',
  222. 'log_id' => '',
  223. );
  224. //获取小数点
  225. $point = 1;
  226. if($accountType == 'agentjewel'){
  227. $point = 2;
  228. }
  229. bcscale($point);
  230. //检测0
  231. $number = floatval( $number );
  232. if( $number == 0 )
  233. {
  234. $result['status'] = true;
  235. $result['msg'] = '交易金额:0';
  236. return $result;
  237. }
  238. if(0 === bccomp($number, 0)){
  239. $result['status'] = true;
  240. $result['msg'] = '交易金额:0';
  241. return $result;
  242. }
  243. //查询余额
  244. $wallet = DB::table('mt_user_wallet')->where('user_id',$user_id)->lockForUpdate()->first();
  245. if(empty($wallet))
  246. {
  247. $result['msg'] = '不存在的用户';
  248. return $result;
  249. }
  250. //扣除金币单独方法
  251. //gold的增加,jewel的增、减
  252. //之前的余额
  253. $wallet_before = $wallet->$accountType;
  254. //正常方法
  255. if(bccomp(bcadd($wallet_before, $number), 0) === -1)
  256. {
  257. $result['msg'] = '余额不足!';
  258. return $result;
  259. }
  260. //钱币操作
  261. $data = array();
  262. $data['user_id'] = $user_id;
  263. $data['log_type'] = $logtype;
  264. $data['money_type'] = $accountType;
  265. $data['before'] = $wallet_before;
  266. $data['change_value'] = $number;
  267. $data['remain'] = bcadd($wallet_before, $number);
  268. $data['table'] = $table;
  269. $data['table_id'] = $table_id;
  270. $data['remark'] = $remark;
  271. $data['createtime'] = time();
  272. $data['updatetime'] = time();
  273. $log_table = 'mt_user_gold_log';
  274. if($accountType == 'agentjewel'){
  275. $log_table = 'mt_user_agentjewel_log';
  276. }
  277. $rs2_id = DB::table($log_table)->insertGetId($data);
  278. //修改金额
  279. $rs1 = DB::table('mt_user_wallet')->where('user_id',$user_id)->update([$accountType => $data['remain']]);
  280. //操作数据库失败
  281. if($rs1 === false || $rs2_id === false){
  282. $result['msg'] = '更新财务记录失败!';
  283. return $result;
  284. }
  285. //默认成功
  286. $result['status'] = true;
  287. $result['msg'] = '账户余额已更新!';
  288. $result['log_table'] = $log_table;
  289. $result['log_id'] = $rs2_id;
  290. return $result;
  291. }
  292. }