|
|
|
|
@ -34,12 +34,13 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
|
|
|
|
|
public function fire($job, $data) |
|
|
|
|
{ |
|
|
|
|
file_put_contents('/tmp/debug_partner', '开始处理贡献值订单：'.var_export($data, 1), 8); |
|
|
|
|
file_put_contents('/tmp/debug_partner', '开始处理贡献值订单：' . var_export($data, 1), 8); |
|
|
|
|
try { |
|
|
|
|
//初始化贡献值 |
|
|
|
|
$bao_price = $mian_price = $ping_price = $total_price = 0; |
|
|
|
|
$bao_flowing = $mian_flowing = $ping_flowing = 0; |
|
|
|
|
$brand_ids = $trade_ids = $user_log_data = []; |
|
|
|
|
$admin_id = config('partner.gongxian_admin_id') ?? ''; |
|
|
|
|
//查询商品类型 -报单区 100% 免单区66.7% 平价区66.7% |
|
|
|
|
$order_product = StoreOrderProduct::getDB() |
|
|
|
|
->where('order_id', $data['order_id']) |
|
|
|
|
@ -95,7 +96,6 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
throw new Exception('订单没有指定三种类型商品，不计入贡献值统计'); |
|
|
|
|
} |
|
|
|
|
//读取品牌所属分类 |
|
|
|
|
|
|
|
|
|
if (!empty($brand_ids)) { |
|
|
|
|
$brand_ids = array_unique($brand_ids); |
|
|
|
|
$cat_ids = StoreBrand::getDB()->whereIn('brand_id', $brand_ids)->column('brand_category_id'); |
|
|
|
|
@ -163,20 +163,20 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
$role_ids = array_column($brand_roles, 'id'); |
|
|
|
|
$brand_brand_data = array_column($brand_roles, null, 'id'); |
|
|
|
|
|
|
|
|
|
$user_list = User::getDB()->alias('u') |
|
|
|
|
->leftJoin('UserPartner p', 'u.uid = p.uid') |
|
|
|
|
->whereIn('p.partner_id', $role_ids) |
|
|
|
|
->where('u.uid', '<>', $data['uid']) |
|
|
|
|
->field('u.*,p.partner_id') |
|
|
|
|
$role_list = UserPartner::getDB() |
|
|
|
|
->whereIn('partner_id', $role_ids) |
|
|
|
|
->where('uid', '<>', $data['uid']) |
|
|
|
|
->select()->toArray(); |
|
|
|
|
|
|
|
|
|
$user_count = count($user_list); |
|
|
|
|
foreach ($user_list as $buk => $buv) { |
|
|
|
|
foreach ($role_list as $buk => $buv) { |
|
|
|
|
$role_data = $brand_brand_data[$buv['partner_id']] ?? []; |
|
|
|
|
if (!empty($role_data)) { |
|
|
|
|
$role_value = bcmul($total_price, $role_data['ratio'] / 100, 2); |
|
|
|
|
$role_value = bcdiv($role_value, $user_count, 2); |
|
|
|
|
$user = User::getDB()->where('uid', $buv['uid'])->find(); |
|
|
|
|
if (empty($buv['uid'])) { |
|
|
|
|
$user = User::getDB()->where('uid', $admin_id)->find();; |
|
|
|
|
} else { |
|
|
|
|
$user = User::getDB()->where('uid', $buv['uid'])->find(); |
|
|
|
|
} |
|
|
|
|
$user->all_value = bcadd($user->all_value, $role_value, 2); |
|
|
|
|
$user->save(); |
|
|
|
|
$user_log_data[] = [ |
|
|
|
|
@ -201,19 +201,20 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
|
|
|
|
|
$role_ids = array_column($trade_roles, 'id'); |
|
|
|
|
$trade_trade_data = array_column($trade_roles, null, 'id'); |
|
|
|
|
$user_list = User::getDB()->alias('u') |
|
|
|
|
->leftJoin('UserPartner p', 'u.uid = p.uid') |
|
|
|
|
->whereIn('p.partner_id', $role_ids) |
|
|
|
|
->where('u.uid', '<>', $data['uid']) |
|
|
|
|
->field('u.*,p.partner_id') |
|
|
|
|
$role_list = UserPartner::getDB() |
|
|
|
|
->whereIn('partner_id', $role_ids) |
|
|
|
|
->where('uid', '<>', $data['uid']) |
|
|
|
|
->select()->toArray(); |
|
|
|
|
$user_count = count($user_list); |
|
|
|
|
foreach ($user_list as $tuk => $tuv) { |
|
|
|
|
|
|
|
|
|
foreach ($role_list as $tuk => $tuv) { |
|
|
|
|
$role_data = $trade_trade_data[$tuv['partner_id']] ?? []; |
|
|
|
|
if (!empty($role_data)) { |
|
|
|
|
$role_value = bcmul($total_price, $role_data['ratio'] / 100, 2); |
|
|
|
|
$role_value = bcdiv($role_value, $user_count, 2); |
|
|
|
|
$user = User::getDB()->where('uid', $tuv['uid'])->find(); |
|
|
|
|
if (empty($tuv['uid'])) { |
|
|
|
|
$user = User::getDB()->where('uid', $admin_id)->find();; |
|
|
|
|
} else { |
|
|
|
|
$user = User::getDB()->where('uid', $tuv['uid'])->find(); |
|
|
|
|
} |
|
|
|
|
$user->all_value = bcadd($user->all_value, $role_value, 2); |
|
|
|
|
$user->save(); |
|
|
|
|
$user_log_data[] = [ |
|
|
|
|
@ -245,19 +246,21 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
|
|
|
|
|
$role_ids = array_column($area_roles, 'id'); |
|
|
|
|
$trade_trade_data = array_column($area_roles, null, 'id'); |
|
|
|
|
$user_list = User::getDB()->alias('u') |
|
|
|
|
->leftJoin('UserPartner p', 'u.uid = p.uid') |
|
|
|
|
->whereIn('p.partner_id', $role_ids) |
|
|
|
|
->where('u.uid', '<>', $data['uid']) |
|
|
|
|
->field('u.*,p.partner_id') |
|
|
|
|
|
|
|
|
|
$role_list = UserPartner::getDB() |
|
|
|
|
->whereIn('partner_id', $role_ids) |
|
|
|
|
->where('uid', '<>', $data['uid']) |
|
|
|
|
->select()->toArray(); |
|
|
|
|
$user_count = count($user_list); |
|
|
|
|
foreach ($user_list as $auk => $auv) { |
|
|
|
|
|
|
|
|
|
foreach ($role_list as $auk => $auv) { |
|
|
|
|
$role_data = $trade_trade_data[$auv['partner_id']] ?? []; |
|
|
|
|
if (!empty($role_data)) { |
|
|
|
|
$role_value = bcmul($total_price, $role_data['ratio'] / 100, 2); |
|
|
|
|
$role_value = bcdiv($role_value, $user_count, 2); |
|
|
|
|
$user = User::getDB()->where('uid', $auv['uid'])->find(); |
|
|
|
|
if (empty($auv['uid'])) { |
|
|
|
|
$user = User::getDB()->where('uid', $admin_id)->find();; |
|
|
|
|
} else { |
|
|
|
|
$user = User::getDB()->where('uid', $auv['uid'])->find(); |
|
|
|
|
} |
|
|
|
|
$user->all_value = bcadd($user->all_value, $role_value, 2); |
|
|
|
|
$user->save(); |
|
|
|
|
$user_log_data[] = [ |
|
|
|
|
@ -271,6 +274,52 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
//查询大区角色 |
|
|
|
|
$region_list = config('partner.region_type'); |
|
|
|
|
$region_ids = []; |
|
|
|
|
if (!empty($province_id) && !empty($region_list)) { |
|
|
|
|
foreach ($region_list as $rv) { |
|
|
|
|
if (in_array($province_id, $rv['province_ids'])) { |
|
|
|
|
$region_ids[] = $rv['id']; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
if(!empty($region_ids)){ |
|
|
|
|
$region_roles = Partner::getDB() |
|
|
|
|
->where('status', 1) |
|
|
|
|
->whereNotIn('type', 2) |
|
|
|
|
->whereIn('region_id', $region_ids) |
|
|
|
|
->select()->toArray(); |
|
|
|
|
$role_ids = array_column($region_roles, 'id'); |
|
|
|
|
$regin_trade_data = array_column($region_roles, null, 'id'); |
|
|
|
|
|
|
|
|
|
$role_list = UserPartner::getDB() |
|
|
|
|
->whereIn('partner_id', $role_ids) |
|
|
|
|
->where('uid', '<>', $data['uid']) |
|
|
|
|
->select()->toArray(); |
|
|
|
|
|
|
|
|
|
foreach ($role_list as $ruk => $ruv) { |
|
|
|
|
$role_data = $regin_trade_data[$ruv['partner_id']] ?? []; |
|
|
|
|
if (!empty($role_data)) { |
|
|
|
|
$role_value = bcmul($total_price, $role_data['ratio'] / 100, 2); |
|
|
|
|
if (empty($ruv['uid'])) { |
|
|
|
|
$user = User::getDB()->where('uid', $admin_id)->find();; |
|
|
|
|
} else { |
|
|
|
|
$user = User::getDB()->where('uid', $ruv['uid'])->find(); |
|
|
|
|
} |
|
|
|
|
$user->all_value = bcadd($user->all_value, $role_value, 2); |
|
|
|
|
$user->save(); |
|
|
|
|
$user_log_data[] = [ |
|
|
|
|
'type' => 6, |
|
|
|
|
'types_of' => 1, |
|
|
|
|
'num' => $role_value, |
|
|
|
|
'ctime' => date('Y-m-d H:i:s'), |
|
|
|
|
'memo' => '订单消费大区贡献值', |
|
|
|
|
'user_id' => $ruv['uid'], |
|
|
|
|
]; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
//查询通用角色 |
|
|
|
|
$common_roles = Partner::getDB() |
|
|
|
|
@ -280,22 +329,22 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
->select()->toArray(); |
|
|
|
|
$role_ids = array_column($common_roles, 'id'); |
|
|
|
|
$common_trade_data = array_column($common_roles, null, 'id'); |
|
|
|
|
$user_list = User::getDB()->alias('u') |
|
|
|
|
->leftJoin('UserPartner p', 'u.uid = p.uid') |
|
|
|
|
->field('u.*,p.partner_id') |
|
|
|
|
->whereIn('p.partner_id', $role_ids) |
|
|
|
|
->where('u.uid', '<>', $data['uid']) |
|
|
|
|
$role_list = UserPartner::getDB() |
|
|
|
|
->whereIn('partner_id', $role_ids) |
|
|
|
|
->where('uid', '<>', $data['uid']) |
|
|
|
|
->select(); |
|
|
|
|
|
|
|
|
|
if (!empty($user_list)) { |
|
|
|
|
$user_list = $user_list->toArray(); |
|
|
|
|
$user_count = count($user_list); |
|
|
|
|
foreach ($user_list as $cuk => $cuv) { |
|
|
|
|
if (!empty($role_list)) { |
|
|
|
|
$role_list = $role_list->toArray(); |
|
|
|
|
foreach ($role_list as $cuk => $cuv) { |
|
|
|
|
$role_data = $common_trade_data[$cuv['partner_id']] ?? []; |
|
|
|
|
if (!empty($role_data)) { |
|
|
|
|
$role_value = bcmul($total_price, $role_data['ratio'] / 100, 2); |
|
|
|
|
$role_value = bcdiv($role_value, $user_count, 2); |
|
|
|
|
$user = User::getDB()->where('uid', $cuv['uid'])->find(); |
|
|
|
|
if (empty($cuv['uid'])) { |
|
|
|
|
$user = User::getDB()->where('uid', $admin_id)->find();; |
|
|
|
|
} else { |
|
|
|
|
$user = User::getDB()->where('uid', $cuv['uid'])->find(); |
|
|
|
|
} |
|
|
|
|
$user->all_value = bcadd($user->all_value, $role_value, 2); |
|
|
|
|
$user->save(); |
|
|
|
|
$user_log_data[] = [ |
|
|
|
|
@ -310,7 +359,6 @@ class OrderPartnerJob implements JobInterface |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//批量增加用户贡献值日志 |
|
|
|
|
ValueContributionLog::getDB()->insertAll($user_log_data); |
|
|
|
|
//社区等级判断 |
|
|
|
|
|
1748153932
1 year ago