|
|
@@ -90,9 +90,9 @@ class Taskorder extends BaseController
|
|
90
|
90
|
// var_dump($totalPv);return;
|
|
91
|
91
|
|
|
92
|
92
|
// $sf = $this->getStarLevel(221);
|
|
93
|
|
- //var_dump($sf);
|
|
94
|
|
- // $ss = $this->getbig_samll_datas(221);//222
|
|
95
|
|
-
|
|
|
93
|
+
|
|
|
94
|
+ //$ss = $this->getbig_samll_datas(17);//222
|
|
|
95
|
+ //var_dump($ss);
|
|
96
|
96
|
//$ff = $this->getPerformanceOf(221);
|
|
97
|
97
|
// var_dump($ff);
|
|
98
|
98
|
//var_dump($ss);
|
|
|
@@ -104,257 +104,7 @@ class Taskorder extends BaseController
|
|
104
|
104
|
//$week_record = 45500 + 1400 + 60000; //20250218
|
|
105
|
105
|
//$week_record =23800 + 60000; //20250222
|
|
106
|
106
|
// $week_record = 64400; //20250301
|
|
107
|
|
- $week_record = 10500 + 50000; //20250310
|
|
108
|
|
- //return;
|
|
109
|
|
-
|
|
110
|
|
-
|
|
111
|
|
- //股权分红 end
|
|
112
|
|
-
|
|
113
|
|
-
|
|
114
|
|
-
|
|
115
|
|
- //var_dump($week_record);die;//9912 8400
|
|
116
|
|
- //$star_list = Db::name("user_star")->order("statement_all_num desc")->select()->toArray();//旧星级等级
|
|
117
|
|
- $star_list = Db::name("old_user_starlevel")->order("statement_all_num desc")->select()->toArray();//星级等级
|
|
118
|
|
-
|
|
119
|
|
- $sales_arr = [];
|
|
120
|
|
- foreach ($star_list as $key => $value) {
|
|
121
|
|
- # code...
|
|
122
|
|
- $star_data = [];
|
|
123
|
|
- $star_data['profit_rate'] = $value['profit_rate'];
|
|
124
|
|
- $star_data['divider_people'] = [];
|
|
125
|
|
- $star_data['title'] = $value['title'];
|
|
126
|
|
- $sales_arr[$value['id']] = $star_data;
|
|
127
|
|
- }
|
|
128
|
|
-
|
|
129
|
|
-
|
|
130
|
|
-
|
|
131
|
|
- $list = Db::name("user")->where("user_level_id_old", "IN", [4,6])->where("status","<>",0)->select()->toArray();
|
|
132
|
|
- //var_dump($list);
|
|
133
|
|
-
|
|
134
|
|
- foreach ($list as $key => $value) {
|
|
135
|
|
- # code...
|
|
136
|
|
- $sales_incentive = $this->getStarLevel($value['uid']);//获取个人共建联盟和个人联盟所有金额,来对比星级联盟列表中处于那个阶段的 用户星级
|
|
137
|
|
- // var_dump( $sales_incentive);return;
|
|
138
|
|
- //这里的意思是将user_starlevel表中新增一个键名为divider_people,然后把符合当前合伙人级别的id都装进去
|
|
139
|
|
- //分红比例
|
|
140
|
|
- $rate_sales = isset($sales_incentive['profit_rate']) ? $sales_incentive['profit_rate'] :0; //profit_rate是分红的比例
|
|
141
|
|
- if($rate_sales > 0) {
|
|
142
|
|
- // var_dump($sales_incentive['title']);
|
|
143
|
|
- $sales_arr[$sales_incentive['id']]['divider_people'][] = $value['uid']; //$value['id']是自己的userid,$sales_incentive['id']是对应的合伙人级别id
|
|
144
|
|
- //$output->writeln('执行用户id-'.$value['id']);
|
|
145
|
|
-
|
|
146
|
|
- // $aa = db::name("user")->where("uid",$value['uid'])->find();
|
|
147
|
|
-
|
|
148
|
|
- // $sales_arr[$sales_incentive['id']]['divider_people_kkkkkkkkkkkkkkkkk'][] = "ID:" . $value['uid'] . " 昵称:" .$aa['user_name'] . " 姓名:" . $aa['uname_old'];
|
|
149
|
|
-
|
|
150
|
|
-
|
|
151
|
|
- // if($sales_incentive['title'] == "初级"){
|
|
152
|
|
- // // var_dump( $value['uid'] );
|
|
153
|
|
- // // if($v['user_level_id_old']==2){
|
|
154
|
|
- // Db::name("user")->where("uid",$value['uid'])->update(["user_group"=>4]);
|
|
155
|
|
- // //}
|
|
156
|
|
- // }
|
|
157
|
|
- }
|
|
158
|
|
- }
|
|
159
|
|
- //return;
|
|
160
|
|
- // var_dump($sales_arr);return;
|
|
161
|
|
- //移动指定ID
|
|
162
|
|
- // 要移动的ID数组
|
|
163
|
|
- // echo "以下是移动后的数组";
|
|
164
|
|
-// 要移动的ID数组
|
|
165
|
|
-$ids_to_remove_from_junior = array(12, 69, 144); // 从初级中移除的ID
|
|
166
|
|
-$ids_to_remove_from_intermediate = array(49); // 从中级中移除的ID
|
|
167
|
|
-
|
|
168
|
|
-// 查找初级并获取其divider_people
|
|
169
|
|
-$junior = &$sales_arr[1]['divider_people']; // 使用引用,以便直接修改数组
|
|
170
|
|
-
|
|
171
|
|
-// 查找中级并获取其divider_people
|
|
172
|
|
-$intermediate = &$sales_arr[2]['divider_people']; // 使用引用,以便直接修改数组
|
|
173
|
|
-
|
|
174
|
|
-// 从初级的divider_people中移除特定的ID
|
|
175
|
|
-foreach ($ids_to_remove_from_junior as $id) {
|
|
176
|
|
- $key = array_search($id, $junior);
|
|
177
|
|
- if ($key !== false) {
|
|
178
|
|
- unset($junior[$key]); // 移除初级中的特定ID
|
|
179
|
|
- }
|
|
180
|
|
-}
|
|
181
|
|
-
|
|
182
|
|
-// 从中级的divider_people中移除特定的ID
|
|
183
|
|
-foreach ($ids_to_remove_from_intermediate as $id) {
|
|
184
|
|
- $key = array_search($id, $intermediate);
|
|
185
|
|
- if ($key !== false) {
|
|
186
|
|
- unset($intermediate[$key]); // 移除中级中的特定ID
|
|
187
|
|
- }
|
|
188
|
|
-}
|
|
189
|
|
-
|
|
190
|
|
-// 重置数组的索引,因为unset会留下空位
|
|
191
|
|
-$sales_arr[1]['divider_people'] = array_values($junior);
|
|
192
|
|
-$sales_arr[2]['divider_people'] = array_values($intermediate);
|
|
193
|
|
-
|
|
194
|
|
-
|
|
195
|
|
-
|
|
196
|
|
-
|
|
197
|
|
-
|
|
198
|
|
-
|
|
199
|
|
-//var_dump($sales_arr);return; //把初级中的 id是 12,69, 144从初级中去掉 ,id是49,从中级中去掉
|
|
200
|
|
-
|
|
201
|
|
- //移动指定ID_end
|
|
202
|
|
-
|
|
203
|
|
- //var_dump($sales_arr);return;
|
|
204
|
|
- //$sales_arr获取分红的id和分红的比例
|
|
205
|
|
-
|
|
206
|
|
-
|
|
207
|
|
-
|
|
208
|
|
-
|
|
209
|
|
-
|
|
210
|
|
- //执行分开发放
|
|
211
|
|
- foreach($sales_arr as $key =>$value) {
|
|
212
|
|
- //比如这个周的总业绩是 8400
|
|
213
|
|
- $sales_arr[$key]['fs_money_nums'] = round($week_record * $value['profit_rate']/100,2);//周总业绩(8400) * 合伙人级别的分佣比例(15%) = 可分红的佣金(1260)
|
|
214
|
|
-
|
|
215
|
|
- //可分红的业绩(分为两半,各50%,一部分是分给双联盟比例,一部分是小业绩比例)
|
|
216
|
|
- $sales_arr[$key]['fs_money'] = round($sales_arr[$key]['fs_money_nums']/2,2);//把本周的业绩(8400) * 合伙人级别的分佣比例(15%) * 0.5 = 630(可分红佣金的 50%)
|
|
217
|
|
- $people_moneys = 0;//当前合伙人级别双联盟总业绩
|
|
218
|
|
-
|
|
219
|
|
- $user_pv_min = 0;//合伙人大小区业绩,其中少的
|
|
220
|
|
-
|
|
221
|
|
- foreach ($value['divider_people'] as $k => $v) {
|
|
222
|
|
- # code... 统计总双联盟流水
|
|
223
|
|
- $user_pv_nums = $this->getPerformanceOf($v);//这里的$v是当前这个级别包含的userid,比如现在这个中级,的divider_people包含17,39两个uerid
|
|
224
|
|
-
|
|
225
|
|
- //$datauser = db::name("user")->where("id",$v)->find();
|
|
226
|
|
-
|
|
227
|
|
-
|
|
228
|
|
- //var_dump($user_pv_nums);
|
|
229
|
|
- //die;//337400
|
|
230
|
|
-
|
|
231
|
|
-
|
|
232
|
|
- // var_dump("id:" . $v ." 用户:".$datauser['user_name']." 双区总业绩:" . $user_pv_nums);
|
|
233
|
|
- $people_moneys += $user_pv_nums;
|
|
234
|
|
-
|
|
235
|
|
-
|
|
236
|
|
-
|
|
237
|
|
- $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组,下标0是最小的值(业绩小的),下标1是最大的值(业绩大的)
|
|
238
|
|
-
|
|
239
|
|
- // var_dump("id:" . $v ." 用户:".$datauser['user_name']." 小区总业绩:" . $user_pv_small_num[0]);
|
|
240
|
|
- $user_pv_min += $user_pv_small_num[0];
|
|
241
|
|
-
|
|
242
|
|
-
|
|
243
|
|
- }
|
|
244
|
|
- //同级所有合伙人双联盟总业绩
|
|
245
|
|
- $sales_arr[$key]['owner_bill'] = $people_moneys;//当前级别所有的人的双联盟业绩(17和39都是中级合伙人,17的双区业绩是:337400 + 39的双区业绩是:189700 = 431032)
|
|
246
|
|
- //同级合伙人所有少的业绩总和
|
|
247
|
|
- $sales_arr[$key]['small_bill'] =$user_pv_min;//获取大小区业绩中,业绩少的部分,并将该级别的合伙人业绩最小的那部分全部加起来(17的大区业绩是 337400,小区业绩是 110110,
|
|
248
|
|
- //所以他的业绩小的是 110110,39的大区业绩是 189700,小区业绩是 53200,所以他的业绩小的是 53200,我们把该级别所有合伙人的小的那部分业绩加起来的和是 153300)
|
|
249
|
|
- }
|
|
250
|
|
- //die;
|
|
251
|
|
-
|
|
252
|
|
- //计算权重金额 只执行一次
|
|
253
|
|
-
|
|
254
|
|
- //执行分红
|
|
255
|
|
- foreach ($sales_arr as $key => $value) {
|
|
256
|
|
- # code...
|
|
257
|
|
- $amont = $value['fs_money'];//可分红的总佣金,分红佣金的一半,中级合伙61.95
|
|
258
|
|
- $fs_money_nums = $value['fs_money_nums'];//中级合伙人级别,可分红的总佣金
|
|
259
|
|
- $owner_bill = $value['owner_bill'];//当前级别合伙人下面所有的双联盟业绩
|
|
260
|
|
- $small_ow_bill = $value['small_bill'];//当前级别合伙人下面所有的小区(业绩小的部分)总业绩
|
|
261
|
|
-
|
|
262
|
|
- //执行分红
|
|
263
|
|
- if(count($value['divider_people']) <= 0 ) {
|
|
264
|
|
- continue;
|
|
265
|
|
- }
|
|
266
|
|
-
|
|
267
|
|
- // $every_award = round( $amont/count($value['divider_people']),2);//比如当前为中级,中级有两个人 17和39.那么可分红的佣金是61.95(可分红佣金的50%),两个人平均分,每一份就是30.975
|
|
268
|
|
- // if($every_award == 0) {
|
|
269
|
|
- // continue;
|
|
270
|
|
- // }
|
|
271
|
|
-
|
|
272
|
|
- //每人分红金额
|
|
273
|
|
- foreach ($value['divider_people'] as $v) {
|
|
274
|
|
- // var_dump($v);
|
|
275
|
|
- // $in_money = $every_award;
|
|
276
|
|
- //个人双区总佣金 权重 计算
|
|
277
|
|
- $my_bill = $this->getPerformanceOf($v);//比如uerid是12,他的双区总业绩就是287742
|
|
278
|
|
-
|
|
279
|
|
- //中级合伙人。userid=17可以分到双区可分红的金额
|
|
280
|
|
- $my_weight_money = round($amont * ($my_bill/$owner_bill),2);//可分红的佣金 * (中级合伙人个人的双区总业绩 / 当前等级所有合伙人的双联盟业绩) = 当前用户可以获取到的分红佣金(双区联盟总业绩加权佣金),287742 * (61.95/431032)=41.36
|
|
281
|
|
-
|
|
282
|
|
- //个人小区(佣金少的一部分) 权重 计算权重
|
|
283
|
|
- $user_pv_small_num = $this->getpersamllcomm($v);//返回是数组,下标0是最小的值(业绩小的),下标1是最大的值(业绩大的)
|
|
284
|
|
- $my_mix_money = round($amont * ($user_pv_small_num[0]/$small_ow_bill),2);
|
|
285
|
|
-
|
|
286
|
|
-
|
|
287
|
|
- # code...
|
|
288
|
|
- $all_award = $my_weight_money + $my_mix_money;
|
|
289
|
|
-
|
|
290
|
|
- //90%给佣金,10给复购金
|
|
291
|
|
- $yj_90 = $all_award * 0.9;
|
|
292
|
|
- $fg_10 = $all_award * 0.1;
|
|
293
|
|
-
|
|
294
|
|
-
|
|
295
|
|
-
|
|
296
|
|
- $userdatassss = db::name("old_user_jbp")->where("id",$v)->find();
|
|
297
|
|
- $datas_log = [
|
|
298
|
|
- 'note'=>"名称:". $userdatassss['nick_name'] ." 用户:". $v . " 双联盟总业绩:" . $owner_bill ." 我的双区业绩:". $my_bill . " 小区总业绩:".$small_ow_bill." 我的业绩小的:" . $user_pv_small_num[0] . " 可分红佣金:" .$amont . " 可分红总佣金:" . $fs_money_nums . " 小区业绩可分红:" . $my_mix_money . " 大区业绩可分红:" .$my_weight_money . " 实际分得:". $yj_90,
|
|
299
|
|
- 'create_time'=>date('Y-m-d H:i:s')
|
|
300
|
|
- ];
|
|
301
|
|
- $con_data = Db::name('test_log')->insert($datas_log); //数据存到2.0数据表中
|
|
302
|
|
-
|
|
303
|
|
- # code...
|
|
304
|
|
- $res = Db::name("user")->where("uid",$v)->inc("total_amount_old",$yj_90)->save();
|
|
305
|
|
-
|
|
306
|
|
- Db::name("user")->where("uid",$v)->inc("amount_old",$yj_90)->save();//不用冻结金额和提现额度来限制佣金发放
|
|
307
|
|
- Db::name("user")->where("uid",$v)->inc("brokerage_price",$yj_90)->save();
|
|
308
|
|
-
|
|
309
|
|
- Db::name("user")->where("uid",$v)->inc("fugou",$fg_10)->save();
|
|
310
|
|
-
|
|
311
|
|
-
|
|
312
|
|
-
|
|
313
|
|
- //if($res) {
|
|
314
|
|
- $this->change_user_log($v,'amount_old',1,$yj_90,"member_award","星级分红入账"."-".$value['title']);//释放佣金
|
|
315
|
|
- //入账星级分红记录表
|
|
316
|
|
- $week_data = [];
|
|
317
|
|
- $week_data['user_id'] = $v;
|
|
318
|
|
- $week_data['user_star_id'] = $key;
|
|
319
|
|
- $week_data['award_num'] = $my_weight_money;
|
|
320
|
|
- $week_data['award_num_sm'] = $my_mix_money;
|
|
321
|
|
- $week_data['remark'] = "星级分红主动执行:" . $yj_90;
|
|
322
|
|
- $week_data['week_record'] = $week_record;
|
|
323
|
|
- $week_data['all_amount'] = $fs_money_nums;
|
|
324
|
|
- $week_data['radio'] = 2;
|
|
325
|
|
- $week_data['owner_bill'] = $owner_bill; //总流水金额
|
|
326
|
|
- $week_data['my_bill'] = $my_bill; //我的流水
|
|
327
|
|
- $week_data['create_time'] = time();
|
|
328
|
|
-
|
|
329
|
|
- Db::name("old_user_weekaward")->insert($week_data);
|
|
330
|
|
-
|
|
331
|
|
-
|
|
332
|
|
- $this->bill_user_log111111($v,"合伙人分佣",$yj_90,"合伙人分佣明细入账",11);//联创分佣明细2.0系统
|
|
333
|
|
- $this->fugou_user_log($v,$fg_10,16,1,1);//复购金明细入账
|
|
334
|
|
- //}
|
|
335
|
|
- }
|
|
336
|
|
-
|
|
337
|
|
- }
|
|
338
|
|
-
|
|
339
|
|
- // $output->writeln('星级奖励发放成功');
|
|
340
|
|
- }
|
|
341
|
|
-
|
|
342
|
|
-//上上周和上上上周weeksage:2上上周,3是上上上周
|
|
343
|
|
-// public function getWeekStartEnd($weeksAgo = 2)
|
|
344
|
|
-// {
|
|
345
|
|
-// $now = time();
|
|
346
|
|
-// // 计算指定周次的周一 00:00 的时间戳
|
|
347
|
|
-// $mondayStart = strtotime('last Monday', strtotime('-' . $weeksAgo . ' weeks', $now));
|
|
348
|
|
-// if (date('w', $mondayStart) != 1) {
|
|
349
|
|
-// // 如果计算出的周一不是周一(即当天不是周一),则调整到正确的周一
|
|
350
|
|
-// $mondayStart = strtotime('last Monday', $mondayStart);
|
|
351
|
|
-// }
|
|
352
|
|
-// // 计算指定周次的周日 23:59:59 的时间戳
|
|
353
|
|
-// $sundayEnd = strtotime('next Sunday', $mondayStart) + 86399 - 1;
|
|
354
|
|
-
|
|
355
|
|
-// return [$mondayStart, $sundayEnd];
|
|
356
|
|
-// }
|
|
357
|
|
-
|
|
|
107
|
+
|
|
358
|
108
|
|
|
359
|
109
|
//添加复购金
|
|
360
|
110
|
public function fugou_user_log($uid,$num,$order_id,$type_inc_des,$status=-1){
|
|
|
@@ -1034,33 +784,70 @@ public function processArray($array) {
|
|
1034
|
784
|
}
|
|
1035
|
785
|
|
|
1036
|
786
|
// 根据父级uid,递归获取所有子级UID数组
|
|
1037
|
|
-function getRecursiveChildren($parentUid) {
|
|
1038
|
|
- $result = []; // 用于存储所有子级的 uid
|
|
|
787
|
+// function getRecursiveChildren($parentUid) {
|
|
|
788
|
+// $result = []; // 用于存储所有子级的 uid
|
|
|
789
|
+
|
|
|
790
|
+// // 定义递归函数
|
|
|
791
|
+// $recursion = function ($parentUid) use (&$result, &$recursion) {
|
|
|
792
|
+// // 查询当前父级的所有直接子级
|
|
|
793
|
+// $children = Db::name("user")
|
|
|
794
|
+// ->where("spread_uid", $parentUid)
|
|
|
795
|
+// ->column("uid"); // 获取子级的 uid 列表
|
|
|
796
|
+
|
|
|
797
|
+// // 如果没有子级,直接返回
|
|
|
798
|
+// if (empty($children)) {
|
|
|
799
|
+// return;
|
|
|
800
|
+// }
|
|
|
801
|
+
|
|
|
802
|
+// // 遍历每个子级
|
|
|
803
|
+// foreach ($children as $childUid) {
|
|
|
804
|
+// $result[] = $childUid; // 将子级的 uid 添加到结果数组
|
|
|
805
|
+// $recursion($childUid); // 递归查询子级的子级
|
|
|
806
|
+// }
|
|
|
807
|
+// };
|
|
|
808
|
+
|
|
|
809
|
+// // 从初始父级开始递归查询
|
|
|
810
|
+// $recursion($parentUid);
|
|
|
811
|
+
|
|
|
812
|
+// return array_unique($result); // 返回结果数组,并去重
|
|
|
813
|
+// }
|
|
1039
|
814
|
|
|
1040
|
|
- // 定义递归函数
|
|
1041
|
|
- $recursion = function ($parentUid) use (&$result, &$recursion) {
|
|
1042
|
|
- // 查询当前父级的所有直接子级
|
|
1043
|
|
- $children = Db::name("user")
|
|
1044
|
|
- ->where("spread_uid", $parentUid)
|
|
1045
|
|
- ->column("uid"); // 获取子级的 uid 列表
|
|
|
815
|
+ // 根据父级uid,递归获取所有子级UID数组
|
|
|
816
|
+ public function getRecursiveChildren($parentUid) {
|
|
|
817
|
+ $result = []; // 用于存储符合条件的子级 uid
|
|
1046
|
818
|
|
|
1047
|
|
- // 如果没有子级,直接返回
|
|
1048
|
|
- if (empty($children)) {
|
|
1049
|
|
- return;
|
|
1050
|
|
- }
|
|
|
819
|
+ // 定义递归函数
|
|
|
820
|
+ $recursion = function ($parentUid) use (&$result, &$recursion) {
|
|
|
821
|
+ // 查询当前父级的所有直接子级
|
|
|
822
|
+ $children = Db::name("user")
|
|
|
823
|
+ ->where("spread_uid", $parentUid)
|
|
|
824
|
+ ->column("uid"); // 获取子级的 uid 列表
|
|
1051
|
825
|
|
|
1052
|
|
- // 遍历每个子级
|
|
1053
|
|
- foreach ($children as $childUid) {
|
|
1054
|
|
- $result[] = $childUid; // 将子级的 uid 添加到结果数组
|
|
1055
|
|
- $recursion($childUid); // 递归查询子级的子级
|
|
1056
|
|
- }
|
|
1057
|
|
- };
|
|
|
826
|
+ // 如果没有子级,直接返回
|
|
|
827
|
+ if (empty($children)) {
|
|
|
828
|
+ return;
|
|
|
829
|
+ }
|
|
1058
|
830
|
|
|
1059
|
|
- // 从初始父级开始递归查询
|
|
1060
|
|
- $recursion($parentUid);
|
|
|
831
|
+ // 遍历每个子级
|
|
|
832
|
+ foreach ($children as $childUid) {
|
|
|
833
|
+ // 如果子级的 uid 小于或等于 611,跳过该子级及其所有子级
|
|
|
834
|
+ if ($childUid <= 611) {
|
|
|
835
|
+ continue;
|
|
|
836
|
+ }
|
|
1061
|
837
|
|
|
1062
|
|
- return array_unique($result); // 返回结果数组,并去重
|
|
1063
|
|
-}
|
|
|
838
|
+ // 将符合条件的子级 uid 添加到结果数组
|
|
|
839
|
+ $result[] = $childUid;
|
|
|
840
|
+
|
|
|
841
|
+ // 递归查询子级的子级
|
|
|
842
|
+ $recursion($childUid);
|
|
|
843
|
+ }
|
|
|
844
|
+ };
|
|
|
845
|
+
|
|
|
846
|
+ // 从初始父级开始递归查询
|
|
|
847
|
+ $recursion($parentUid);
|
|
|
848
|
+
|
|
|
849
|
+ return array_unique($result); // 返回结果数组,并去重
|
|
|
850
|
+ }
|
|
1064
|
851
|
|
|
1065
|
852
|
//挑出大小值
|
|
1066
|
853
|
function getMaxAndSumRest($array) {
|