Taskorderguquan.php 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233
  1. <?php
  2. /**
  3. * @package merchant
  4. * @Author: Qinii
  5. * @Date: 2020/5/28
  6. */
  7. namespace app\controller\api\store\merchant;
  8. use think\App;
  9. use crmeb\basic\BaseController;
  10. use app\common\repositories\system\merchant\MerchantRepository as repository;
  11. use think\facade\Db;
  12. use think\facade\Log;
  13. use function Symfony\Component\VarDumper\Dumper\esc;
  14. class Taskorderguquan extends BaseController
  15. {
  16. public function lst6()
  17. {
  18. return;
  19. // return;
  20. // $store_product_datas = Db::name('old_user_of_goods_old')->select();
  21. //$week_record = 45500 + 60000 + 1400;
  22. //$week_record = 23800 + 60000;//20250222
  23. // $week_record = 64400;//20250303
  24. $week_record = 10500 + 50000; //20250310
  25. $stock_comm = round($week_record * 0.05 ,2);
  26. //获取股权分红的人
  27. $GetAllUserPackNum = db::name("old_user_stock")->sum("pack");//计算所有用户的份数总和
  28. $stockuserdatas = db::name("old_user_stock")->select();//获取所有用户
  29. if(count($stockuserdatas) > 0){
  30. $one_pack_comm_data = round($stock_comm / $GetAllUserPackNum,2);//获取每份的单佣金
  31. foreach ($stockuserdatas as &$v) {
  32. $v['getcomm'] = $v['pack'] * $one_pack_comm_data;
  33. $v['allgetcomm'] = $v['allgetcomm'] + $v['getcomm'];
  34. $v['update_time'] = time();
  35. $yj_90 = $v['getcomm'] * 0.9;
  36. $fg_10 = $v['getcomm'] * 0.1;
  37. // // 更新 user_stock 表中的记录
  38. $res = db::name("old_user_stock")->where("id", $v['id'])->update([
  39. 'getcomm' => $v['getcomm'],
  40. 'allgetcomm' => $v['allgetcomm'],
  41. 'update_time' => $v['update_time']
  42. ]);
  43. Db::name("user")->where("uid",$v['user_id'])->inc("brokerage_price", $yj_90)->save();
  44. $res1 = Db::name("user")->where("uid",$v['user_id'])->inc("total_amount_old", $yj_90)->save();
  45. $res2 = Db::name("user")->where("uid",$v['user_id'])->inc("amount_old", $yj_90)->save();
  46. $res3 = Db::name("user")->where("uid",$v['user_id'])->inc("fugou", $fg_10)->save();
  47. $res =true;
  48. if($res){
  49. $das = $this->change_user_log($v['user_id'],'amount_old',1, $yj_90,"member_award_stock","股权分红入账"."-".$v['pack']);//释放佣金
  50. //入账星级分红记录表
  51. $week_data = [];
  52. $week_data['user_id'] = $v['user_id'];
  53. $week_data['user_star_id'] = 0;
  54. $week_data['award_num'] = 0;
  55. $week_data['award_num_sm'] = 0;
  56. $week_data['remark'] = "股权分红主动执行" . $yj_90;
  57. $week_data['week_record'] = $week_record;
  58. $week_data['all_amount'] = $stock_comm;
  59. $week_data['radio'] = 2;
  60. $week_data['owner_bill'] = 0; //总流水金额
  61. $week_data['my_bill'] = 0; //我的流水
  62. $week_data['create_time'] = time();
  63. Db::name("old_user_weekaward")->insert($week_data);
  64. $userdatassss = db::name("old_user_jbp")->where("id",$v['user_id'])->find();
  65. $datas_log = [
  66. 'note'=>"名称:". $userdatassss['nick_name'] . " 用户:". $v['user_id'] . " 新增股权佣金:" . $yj_90,
  67. 'create_time'=>date('Y-m-d H:i:s')
  68. ];
  69. $con_data = Db::name('test_log')->insert($datas_log); //数据存到2.0数据表中
  70. $this->bill_user_log111111($v['user_id'],"股权分佣", $yj_90,"股权明细入账",13);//股权分佣明细2.0系统
  71. $this->fugou_user_log($v['user_id'],$fg_10,16,1,1);//复购金明细入账
  72. }
  73. }
  74. }
  75. //股权分红 end
  76. }
  77. //添加复购金
  78. public function fugou_user_log($uid,$num,$order_id,$type_inc_des,$status=-1){
  79. $fugou_data = Db::name('user')->where("uid",$uid)->find();
  80. $bill = [
  81. 'uid'=>$uid,
  82. 'number'=>$num,//数量
  83. 'status'=>$status,//复购金状态1-有效 0-失效 -1待确认
  84. 'mark'=>"复购金",//备注
  85. 'desc'=>"10%作为复购金",//描述
  86. 'order_id'=>$order_id,//订单id
  87. 'surplus'=>0,//剩余
  88. 'order_type'=>11,//关联订单ID
  89. 'type'=>$type_inc_des,//复购金类型 :1赠送,2消耗
  90. 'settlement_time'=>date('Y-m-d H:i:s'),//添加时间,
  91. 'addtime'=>time(),
  92. ];
  93. Db::name('user_sign_fugou')->insert($bill);
  94. }
  95. //添加平台分佣2.0系统收益明细日志(养老金金额)
  96. public function bill_user_log111111($uid,$name,$num,$mark,$comm){
  97. $con_data = Db::name('user')->where("uid",$uid)->find();
  98. //如果是会员专区就即刻到账
  99. // Db::name('user')->where("uid",$con_data['uid'])->update(['brokerage_price'=> $con_data['brokerage_price'] + $num]);
  100. $bill = [
  101. 'uid'=>$uid,
  102. 'link_id'=>0,//关联订单id
  103. 'pm'=>1,//0:支出,1:获得
  104. 'title'=>$name,//账单标题
  105. 'category'=>'now_money',//明细种类
  106. 'type'=>'commission',//明细类型
  107. 'number'=>$num,//明细数字
  108. 'balance'=>0,//剩余
  109. 'mark'=>$mark,//备注
  110. 'create_time'=>date('Y-m-d H:i:s'),//添加时间
  111. 'status'=>1,//0待确定,1有效,-1无效
  112. 'commission_type'=>$comm,//佣金类型 1代理费 2 消费佣金 3直推奖√ 4辖区佣金\r\n5 养老金√ 6 广告费
  113. //7 跨店奖励√ 8平台奖励 9渠道商\r\n10 推荐创客收益√ 11分红奖金√ 12代理区域收益√ 13消费循环佣金
  114. //14-推荐代理收益√ 15邀请小区团长升级√ 16大v分享奖√ 17创客合伙人√ 18积分奖励√ 19创客补贴√’
  115. 'order_sn'=>0,//订单号
  116. 'tripartite'=>0,//
  117. 'type_shop'=>0,//0平台1多多进宝2唯品会3苏宁易购4网易考拉5淘宝客6京东联盟7饿了么8线上
  118. 'mer_id'=>0,//商户id
  119. 'source'=>0,//1线下 0线上
  120. 'order_type'=>1,//1自营 2 第三方 订单类型
  121. 'is_red_brokerage'=>0,//1红积分对冲佣金 0正常佣金
  122. 'gzc'=>3,//养老金是否已进入公证处log表0:未进入。1:已进入
  123. 'take_time'=>'',//结算时间
  124. 'district_id'=>'',//
  125. 'street_id'=>'',//
  126. 'month'=>'',//月份
  127. ];
  128. Db::name('user_bill')->insert($bill);
  129. }
  130. //发放佣金 示例: $this->change_user_log($v,'amount',1,$all_award,"member_award","星级分红入账"."-".$value['title']);//释放佣金
  131. function change_user_log($user_id,$type,$change_status,$money,$routine,$remark="",$is_admin=1,$appoint_money = 0)
  132. {
  133. $transition = [
  134. 'pv'=>1,
  135. "gb"=>2,
  136. "df"=>3,
  137. "vr"=>4,
  138. "bt"=>5,
  139. "withdraw_quota_old"=>6,//提现
  140. "unsettled_pension"=>7,
  141. "amount_old"=>8//发放佣金
  142. ];
  143. $routineInfo = Db::name("old_routine_log_of_key")->where("key",$routine)->find();
  144. if(empty($routineInfo)) {
  145. return false;
  146. }
  147. $key_id = isset($routineInfo['id']) ? $routineInfo['id'] : 0;
  148. if($appoint_money > 0) {
  149. $alter_money = $appoint_money;
  150. }else{
  151. //再去查询变更前的 金额
  152. $alter_money = Db::name("user")->where('uid',$user_id)->value($type);
  153. }
  154. if($change_status == 1) {
  155. //新增前
  156. $alter_money = $alter_money-$money;
  157. }else if($change_status == 2){
  158. //减少前
  159. $alter_money = $alter_money + $money;
  160. }
  161. if($alter_money < 0) {
  162. $alter_money =0;
  163. }
  164. $inser_data = [];
  165. $inser_data['user_id'] = $user_id;
  166. $inser_data['type'] = $transition[$type];
  167. $inser_data['change_status'] = $change_status;
  168. $inser_data['money'] = $money;
  169. $inser_data['routine_log_of_key_id'] = $key_id;
  170. $inser_data['remark'] = $remark;
  171. $inser_data['is_admin'] = $is_admin;
  172. $inser_data['create_time'] = time();
  173. $inser_data['alter_money'] = isset($alter_money) ? $alter_money : 0;
  174. Db::name("old_user_log")->insert($inser_data);
  175. }
  176. }