Plantask.php 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254
  1. <?php
  2. namespace app\index\controller;
  3. use think\Controller;
  4. use think\Db;
  5. use app\common\model\Wallet;
  6. class Plantask extends Controller
  7. {
  8. public function index()
  9. {
  10. exit;
  11. }
  12. //推荐奖励
  13. //订单支付回调之后的任务,每分钟运行
  14. //烧伤
  15. public function auto_order_paid(){
  16. $map = [
  17. 'status' => 1,
  18. 'have_paid' => ['gt',0],
  19. 'paidtasktime' => 0,
  20. ];
  21. $order_list = Db::name('unishop_order')->where($map)->order('id asc')->limit(10)->select();
  22. if(empty($order_list)){
  23. echo '没有数据';
  24. exit;
  25. }
  26. Db::startTrans();
  27. $walletmodel = new Wallet();
  28. foreach($order_list as $key => $order){
  29. //直推代理商获益
  30. $intro_uid = Db::name('user')->where('id',$order['user_id'])->value('intro_uid');
  31. if($intro_uid){
  32. //直推的第一单金额,烧伤
  33. $map = [
  34. 'status' => 1,
  35. 'have_paid' => ['gt',0],
  36. 'user_id' => $intro_uid,
  37. ];
  38. $first_order = Db::name('unishop_order')->where($map)->order('have_paid asc')->value('order_price');
  39. $first_order = $first_order ?: 0;
  40. $jishu = $order['order_price'];
  41. $remark_shaoshang = '';
  42. if($first_order < $order['order_price']){
  43. $jishu = $first_order;
  44. $remark_shaoshang = '(烧伤)';
  45. }
  46. //奖励
  47. $bili = config('site.orderpaid_zhitui_bili') ?: 5;
  48. $score = bcdiv(bcmul($jishu,$bili,0),100,0);
  49. if($score > 0){
  50. $rs_wallet = $walletmodel->lockChangeAccountRemain($intro_uid,'score',$score,3,'直推代理奖励'.$remark_shaoshang,'unishop_order',$order['id'],$order['user_id']);
  51. if($rs_wallet['status'] === false){
  52. echo $rs_wallet['msg'];
  53. Db::rollback();
  54. exit;
  55. }
  56. $rs_wallet = $walletmodel->lockChangeAccountRemain($intro_uid,'shouyi',$score,31,'直推代理奖励'.$remark_shaoshang,'unishop_order',$order['id'],$order['user_id']);
  57. if($rs_wallet['status'] === false){
  58. echo $rs_wallet['msg'];
  59. Db::rollback();
  60. exit;
  61. }
  62. }
  63. }
  64. //订单完成
  65. $rs_order = Db::name('unishop_order')->where('id',$order['id'])->update(['paidtasktime'=>time()]);
  66. if($rs_order === false){
  67. echo '更新失败';
  68. Db::rollback();
  69. exit;
  70. }
  71. //循环结束
  72. }
  73. Db::commit();
  74. echo '成功'.count($order_list);
  75. }
  76. //总代奖励
  77. //自动结算10日前订单,每分钟运行
  78. public function auto_jiesuan_order(){
  79. $nowtime = time();
  80. $toweek = date('w',$nowtime);
  81. if($toweek == 0){
  82. //周日不结算(自动到下周一结算)
  83. echo '周日不结算';
  84. exit;
  85. }
  86. $tendays_ago = jiesuan_tendays_ago();
  87. // echo $tendays_ago;exit;
  88. //
  89. Db::startTrans();
  90. $order_map = [
  91. 'status' => 1,
  92. 'have_paid' => ['lt',$tendays_ago],
  93. 'jiesuantime' => 0,
  94. ];
  95. $order = Db::name('unishop_order')->where($order_map)->where('have_paid','gt',0)->order('id asc')->lock(true)->find();
  96. if(empty($order)){
  97. echo '没有数据';
  98. Db::rollback();
  99. exit;
  100. }
  101. // dump($order);
  102. //买家得到收益
  103. if($order['order_shouyi'] > 0){
  104. $shouyi = bcsub($order['order_shouyi'],$order['order_benjin']); //可提现收益
  105. $remark = '本金:'.$order['order_benjin'].',收益:'.$shouyi;
  106. $rs_wallet = model('wallet')->lockChangeAccountRemain($order['user_id'],'score',$order['order_shouyi'],5,$remark,'unishop_order',$order['id'],$order['user_id']);
  107. if($rs_wallet['status'] === false){
  108. echo $rs_wallet['msg'];
  109. Db::rollback();
  110. exit;
  111. }
  112. if($shouyi > 0){
  113. $rs_wallet = model('wallet')->lockChangeAccountRemain($order['user_id'],'shouyi',$shouyi,51,$remark,'unishop_order',$order['id'],$order['user_id']);
  114. if($rs_wallet['status'] === false){
  115. echo $rs_wallet['msg'];
  116. Db::rollback();
  117. exit;
  118. }
  119. }
  120. }
  121. /*
  122. //为上级做贡献,找到上级
  123. $intro_uid = Db::name('user')->where('id',$order['user_id'])->value('intro_uid');
  124. if(empty($intro_uid)){
  125. echo '没有上级,结束';
  126. Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>$nowtime]);
  127. Db::commit();
  128. exit;
  129. }
  130. //获取业绩
  131. $yeji = $this->jiesuan_yeji($intro_uid);
  132. // dump($yeji);
  133. //确定代理商等级,拿对应比例
  134. $rule = $this->jiesuan_daili_level($yeji);
  135. if($rule['bili'] == 0){
  136. echo '达不到第一级,结束';
  137. Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>$nowtime]);
  138. Db::commit();
  139. exit;
  140. }
  141. // dump($rule);
  142. //购买者业绩
  143. $buyer_yeji = $this->jiesuan_yeji($order['user_id']);
  144. //购买者等级
  145. $buyer_rule = $this->jiesuan_daili_level($buyer_yeji);
  146. $jicha_bili = $rule['bili'] - $buyer_rule['bili'];
  147. //给直推
  148. $score = bcdiv(bcmul($order['order_shouyi'],$jicha_bili,0),100,0);
  149. // dump($score);
  150. $remark = $intro_uid.':业绩'.$yeji.','.$rule['name'].'代理;'.$order['user_id'].':业绩'.$buyer_yeji.','.$buyer_rule['name'].'代理';
  151. //echo $remark;
  152. if($score > 0){
  153. $rs_wallet = model('wallet')->lockChangeAccountRemain($intro_uid,'score',$score,6,$remark,'unishop_order',$order['id'],$order['user_id']);
  154. if($rs_wallet['status'] === false){
  155. echo $rs_wallet['msg'];
  156. Db::rollback();
  157. exit;
  158. }
  159. }
  160. */
  161. //标记为结算
  162. $jiesuan = Db::name('unishop_order')->where('id',$order['id'])->update(['jiesuantime'=>$nowtime]);
  163. if($jiesuan === false){
  164. echo '修改状态失败';
  165. Db::rollback();
  166. exit;
  167. }
  168. //批发的都卖出
  169. $pifa = Db::name('unishop_order_product')->where('order_id',$order['id'])->update(['pifa_status'=>1]);
  170. if($pifa === false){
  171. echo '修改状态失败2';
  172. Db::rollback();
  173. exit;
  174. }
  175. Db::commit();
  176. echo '完成'.$order['id'];
  177. }
  178. //获取业绩
  179. private function jiesuan_yeji($user_id){
  180. //找到所有下级
  181. $commonuser = new \app\common\model\User();
  182. $user_ids = $commonuser->my_down_all($user_id,[$user_id]);
  183. if(empty($user_ids)){
  184. return 0;
  185. }
  186. $map = [
  187. 'status' => 1,
  188. 'have_paid' => ['gt',0],
  189. 'user_id' => ['IN',$user_ids],
  190. ];
  191. $yeji = Db::name('unishop_order')->where($map)->sum('order_price');
  192. //减去提现的
  193. $map = [
  194. 'status' => 1,
  195. 'user_id' => ['IN',$user_ids],
  196. ];
  197. $take_cash = Db::name('user_withdraw')->where($map)->sum('score');
  198. $yeji = $yeji - $take_cash;
  199. return $yeji;
  200. }
  201. //确认代理等级及规则
  202. private function jiesuan_daili_level($yeji){
  203. $data = Db::name('zongdai')->order('id asc')->select();
  204. $return = $data[0]; //默认第0个
  205. foreach($data as $key => $rule){
  206. if($yeji >= $rule['yeji']){
  207. $return = $rule;
  208. }
  209. }
  210. return $return;
  211. }
  212. }