diff --git a/app/command/dayValue.php b/app/command/dayValue.php new file mode 100644 index 0000000..3a4f543 --- /dev/null +++ b/app/command/dayValue.php @@ -0,0 +1,42 @@ +setName('dayValue') + ->addArgument('dayValue', Argument::OPTIONAL, 'php think menu [1] / [2]') + ->setDescription('社区等级结算'); + } + + protected function execute(Input $input, Output $output) + { + + } + + +} diff --git a/app/common/repositories/store/StoreCategoryRepository.php b/app/common/repositories/store/StoreCategoryRepository.php index 461d789..ad5a38b 100644 --- a/app/common/repositories/store/StoreCategoryRepository.php +++ b/app/common/repositories/store/StoreCategoryRepository.php @@ -107,6 +107,7 @@ class StoreCategoryRepository extends BaseRepository */ public function getBrandList() { + return app()->make(StoreBrandRepository::class)->getAll(); } diff --git a/app/common/repositories/store/order/StoreOrderCreateRepository.php b/app/common/repositories/store/order/StoreOrderCreateRepository.php index 5dcaea7..d9fc6e5 100644 --- a/app/common/repositories/store/order/StoreOrderCreateRepository.php +++ b/app/common/repositories/store/order/StoreOrderCreateRepository.php @@ -1058,6 +1058,7 @@ class StoreOrderCreateRepository extends StoreOrderRepository $rate = bcmul($merchantCart['merchantCategory']['commission_rate'], 100, 4); } $user_address = isset($address) ? ($address['province'] . $address['city'] . $address['district'] . $address['street'] . $address['detail']) : ''; + //整理订单数据 $_order = [ 'cartInfo' => $merchantCart, @@ -1093,9 +1094,9 @@ class StoreOrderCreateRepository extends StoreOrderRepository 'coupon_price' => bcadd($merchantCart['order']['coupon_price'], $merchantCart['order']['platform_coupon_price'], 2), 'platform_coupon_price' => $merchantCart['order']['platform_coupon_price'], 'pay_type' => $pay_type, - 'user_address_id' => $user_address['address_id'] ?? 0, 'pay_image' => $pay_image ?? '', - 'pay_type_2' => $pay_type_2 ?? '' + 'pay_type_2' => $pay_type_2 ?? '', + 'user_address_id' => $address['address_id'] ?? 0, ]; $allUseCoupon = array_merge($allUseCoupon, $merchantCart['order']['useCouponIds']); $orderList[] = $_order; diff --git a/app/common/repositories/store/order/StoreOrderRepository.php b/app/common/repositories/store/order/StoreOrderRepository.php index a506888..4cdc6c5 100644 --- a/app/common/repositories/store/order/StoreOrderRepository.php +++ b/app/common/repositories/store/order/StoreOrderRepository.php @@ -754,7 +754,7 @@ class StoreOrderRepository extends BaseRepository $storeOrderStatusRepository->{$func}($orderStatus); }); //推送到贡献值结算队列 - Queue::push(OrderPartnerJob::class, compact('order')); + Queue::push(OrderPartnerJob::class, $order->toArray()); event('order.take', compact('order')); diff --git a/app/controller/admin/store/StoreBrand.php b/app/controller/admin/store/StoreBrand.php index 3065060..bec0814 100644 --- a/app/controller/admin/store/StoreBrand.php +++ b/app/controller/admin/store/StoreBrand.php @@ -16,6 +16,7 @@ use think\App; use crmeb\basic\BaseController; use app\validate\admin\StoreBrandValidate as validate; use app\common\repositories\store\StoreBrandRepository; +use app\common\repositories\store\CityAreaRepository; class StoreBrand extends BaseController { @@ -40,8 +41,8 @@ class StoreBrand extends BaseController */ public function lst() { - [$page , $limit] = $this->getPage(); - $where = $this->request->params(['brand_category_id','brand_name']); + [$page, $limit] = $this->getPage(); + $where = $this->request->params(['brand_category_id', 'brand_name']); return app('json')->success($this->repository->getList($where, $page, $limit)); } @@ -57,23 +58,23 @@ class StoreBrand extends BaseController return app('json')->success('添加成功'); } - public function update($id,validate $validate) + public function update($id, validate $validate) { $data = $this->checkParams($validate); - if(!$this->repository->meExists($id)) + if (!$this->repository->meExists($id)) return app('json')->fail('数据不存在'); if (!$this->repository->parentExists($data['brand_category_id'])) return app('json')->fail('上级分类不存在'); - $this->repository->update($id,$data); + $this->repository->update($id, $data); return app('json')->success('编辑成功'); } public function delete($id) { - if(!$this->repository->meExists($id)) + if (!$this->repository->meExists($id)) return app('json')->fail('数据不存在'); - if($this->repository->getBrandHasProduct($id)) + if ($this->repository->getBrandHasProduct($id)) return app('json')->fail('该品牌下存在商品'); $this->repository->delete($id); return app('json')->success('删除成功'); @@ -85,16 +86,17 @@ class StoreBrand extends BaseController return app('json')->fail('数据不存在'); return app('json')->success($this->repository->get($id)); } + /** * 验证 - * @param validate $validate + * @param validate $validate * @param bool $isCreate * @return array * @author Qinii */ public function checkParams(validate $validate) { - $data = $this->request->params(['brand_category_id','brand_name','is_show','sort','pic']); + $data = $this->request->params(['brand_category_id', 'brand_name', 'is_show', 'sort', 'pic']); $validate->check($data); return $data; } @@ -137,4 +139,16 @@ class StoreBrand extends BaseController $this->repository->update($id, ['is_show' => $status]); return app('json')->success('修改成功'); } + + public function all() + { + $data = $this->repository->getAll(); + return app('json')->success($data); + } + + public function getCitylist($id,CityAreaRepository $repository) + { + $where['parent_id'] = $id; + return app('json')->success($repository->getList($where)); + } } diff --git a/config/console.php b/config/console.php index a85141c..5f51478 100644 --- a/config/console.php +++ b/config/console.php @@ -39,5 +39,7 @@ return [ 'change:hotTop' => 'app\command\changeHotTop', //各种积分转换 'brand' => 'app\command\brand', + //社区贡献值结算 + 'dayValue' => 'app\command\dayValue', ], ]; diff --git a/config/partner.php b/config/partner.php index 4c20e0d..92b3727 100644 --- a/config/partner.php +++ b/config/partner.php @@ -16,21 +16,20 @@ return [ // 社区等级配置 'community_level' => [ [ - 'alias' => '一星社区服务商 ', - 'level_name' => 'S1', - 'min_price' => '30000', + 'alias' => '七星社区服务商 ', + 'level_name' => 'S7', + 'min_price' => '100000000', 'pay_community' => '0.03', - ], - [ - 'alias' => '二星社区服务商 ', - 'level_name' => 'S2', - 'min_price' => '300000', + ], [ + 'alias' => '六星社区服务商 ', + 'level_name' => 'S6', + 'min_price' => '10000000', 'pay_community' => '0.03', ], [ - 'alias' => '三星社区服务商 ', - 'level_name' => 'S3', - 'min_price' => '100000', + 'alias' => '五星社区服务商 ', + 'level_name' => 'S5', + 'min_price' => '10000000', 'pay_community' => '0.03', ], [ @@ -38,46 +37,45 @@ return [ 'level_name' => 'S4', 'min_price' => '3000000', 'pay_community' => '0.03', - ], - [ - 'alias' => '五星社区服务商 ', - 'level_name' => 'S5', - 'min_price' => '10000000', + ], [ + 'alias' => '三星社区服务商 ', + 'level_name' => 'S3', + 'min_price' => '100000', 'pay_community' => '0.03', ], [ - 'alias' => '六星社区服务商 ', - 'level_name' => 'S6', - 'min_price' => '10000000', + 'alias' => '二星社区服务商 ', + 'level_name' => 'S2', + 'min_price' => '300000', 'pay_community' => '0.03', ], [ - 'alias' => '七星社区服务商 ', - 'level_name' => 'S7', - 'min_price' => '100000000', + 'alias' => '一星社区服务商 ', + 'level_name' => 'S1', + 'min_price' => '30000', 'pay_community' => '0.03', ], ], //品牌代理商等级配置 'brand_level' => [ [ - 'alias' => '品牌体验官', - 'level_name' => 'B1', - 'min_price' => '10000', + 'alias' => '全球品牌代言人', + 'level_name' => 'B7', + 'min_price' => '1000000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], [ - 'alias' => '品牌推荐官', - 'level_name' => 'B2', - 'min_price' => '30000', + 'alias' => '亚太区品牌代言人', + 'level_name' => 'B6', + 'min_price' => '500000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], [ - 'alias' => '品牌推广大使', - 'level_name' => 'B3', - 'min_price' => '50000', + 'alias' => '中国区品牌代言人', + 'level_name' => 'B5', + 'min_price' => '300000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], @@ -89,23 +87,23 @@ return [ 'promotion_community' => '0.1' ], [ - 'alias' => '中国区品牌代言人', - 'level_name' => 'B5', - 'min_price' => '300000', + 'alias' => '品牌推广大使', + 'level_name' => 'B3', + 'min_price' => '50000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], [ - 'alias' => '亚太区品牌代言人', - 'level_name' => 'B6', - 'min_price' => '500000', + 'alias' => '品牌推荐官', + 'level_name' => 'B2', + 'min_price' => '30000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], [ - 'alias' => '全球品牌代言人', - 'level_name' => 'B7', - 'min_price' => '1000000', + 'alias' => '品牌体验官', + 'level_name' => 'B1', + 'min_price' => '10000', 'pay_community' => '0.3', 'promotion_community' => '0.1' ], diff --git a/crmeb/jobs/OrderPartnerJob.php b/crmeb/jobs/OrderPartnerJob.php index 1050cf5..9e177a7 100644 --- a/crmeb/jobs/OrderPartnerJob.php +++ b/crmeb/jobs/OrderPartnerJob.php @@ -32,8 +32,9 @@ use app\common\repositories\user\UserAddressRepository; class OrderPartnerJob implements JobInterface { - public function fire($job,$data) + public function fire($job, $data) { + file_put_contents('/tmp/debug_partner', '开始处理贡献值订单:'.var_export($data, 1), 8); try { //初始化贡献值 $bao_price = $mian_price = $ping_price = $total_price = 0; @@ -132,6 +133,8 @@ class OrderPartnerJob implements JobInterface 'street_id' => $address['street_id'] ?? '', 'created_time' => date('Y-m-d H:i:s'), 'baodan_liushui' => $bao_flowing, + 'miandan_liushui' => $mian_flowing, + 'ping_liushui' => $ping_flowing, ]; StoreOrderContribute::getDB()->insert($contribute_insert); //订单角色贡献值-30% @@ -197,7 +200,7 @@ class OrderPartnerJob implements JobInterface ->select()->toArray(); $role_ids = array_column($trade_roles, 'id'); - $trade_trade_data = array_column($trade_roles,null, '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) @@ -240,8 +243,8 @@ class OrderPartnerJob implements JobInterface ->whereIn('area_id', $area_ids) ->select()->toArray(); - $role_ids = array_column($area_roles, 'id'); - $trade_trade_data = array_column($area_roles, null,'id'); + $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) @@ -275,8 +278,8 @@ class OrderPartnerJob implements JobInterface ->where('is_area', 0) ->where('status', 1) ->select()->toArray(); - $role_ids = array_column($common_roles, 'id', ); - $common_trade_data = array_column($common_roles, null,'id'); + $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') @@ -284,7 +287,7 @@ class OrderPartnerJob implements JobInterface ->where('u.uid', '<>', $data['uid']) ->select(); - if(!empty($user_list)){ + if (!empty($user_list)) { $user_list = $user_list->toArray(); $user_count = count($user_list); foreach ($user_list as $cuk => $cuv) { @@ -310,6 +313,7 @@ class OrderPartnerJob implements JobInterface //批量增加用户贡献值日志 ValueContributionLog::getDB()->insertAll($user_log_data); + //社区等级判断 echo 'ok'; } catch (\Exception $e) { Log::info('订单角色贡献值处理失败; error : ' . $e->getMessage()); diff --git a/route/admin/product.php b/route/admin/product.php index 6c64907..39b71d4 100644 --- a/route/admin/product.php +++ b/route/admin/product.php @@ -150,6 +150,12 @@ Route::group(function () { Route::get('lst', '/lst')->name('systemStoreBrandLst')->option([ '_alias' => '列表', ]); + Route::get('brandList', '/all')->name('systemStoreBrandAll')->option([ + '_alias' => '列表', + ]); + Route::get('city/:id', '/getCitylist')->name('systemStoreCity')->option([ + '_alias' => '列表', + ]); Route::post('status/:id', '/switchStatus')->name('systemStoreBrandSwithStatus')->option([ '_alias' => '修改状态', ]);