fastadmin_tailored/application/admin/controller/commission/Goods.php

<?php

namespace app\admin\controller\commission;

use app\common\controller\Backend;
use app\common\model\commission\CommissionGoods as CommissionGoodsModel;
use app\common\model\Goods as GoodsModel;
use app\common\model\commission\Level as LevelModel;
use app\common\Enum\CommissionGoodsEnum;
use app\common\Enum\GoodsEnum;
use app\common\Service\ShopConfigService;
use think\Db;

class Goods extends Backend
{
    protected $model = null;
    protected $goodsModel;
    
    /**
     * 无需登录的方法,同时也就无需鉴权了
     */
    protected $noNeedLogin = [];
    
    /**
     * 无需鉴权的方法,但需要登录
     */
    protected $noNeedRight = ['commission', 'detail'];
    
    /**
     * 快速搜索时执行查找的字段
     */
    protected $searchFields = 'id,title,subtitle';
    
    /**
     * 是否是关联查询
     */
    protected $relationSearch = false;

    public function _initialize()
    {
        parent::_initialize();
        $this->model = new GoodsModel();  // 使用商品模型作为主模型，以便使用FastAdmin的标准功能
        $this->goodsModel = new GoodsModel();
        
        // 传递枚举配置给前端
        $this->assignconfig('commission_goods_participate_list', CommissionGoodsEnum::$participateList);
        $this->assignconfig('commission_goods_order_status_list', CommissionGoodsEnum::$orderStatusList);
        $this->assignconfig('commission_goods_rule_type_list', CommissionGoodsEnum::$ruleTypeList);
        $this->assignconfig('commission_goods_level_list', CommissionGoodsEnum::$levelList);
        $this->assignconfig('commission_goods_self_buy_list', CommissionGoodsEnum::$selfBuyList);
        $this->assignconfig('commission_goods_settlement_list', CommissionGoodsEnum::$settlementList);
        $this->assignconfig('commission_goods_commission_settlement_list', CommissionGoodsEnum::$commissionSettlementList);
        $this->assignconfig('commission_goods_commission_type_list', CommissionGoodsEnum::$commissionTypeList);
        
        // 传递商品枚举配置给前端
        $this->assignconfig('goods_status_map', GoodsEnum::getGoodsStatusMap());
        $this->assignconfig('goods_spec_type_map', GoodsEnum::getSpecTypeMap());
        $this->assignconfig('goods_type_map', GoodsEnum::getGoodsTypeMap());
        $this->assignconfig('goods_delivery_type_map', GoodsEnum::getDeliveryTypeMap());
        $this->assignconfig('goods_express_type_map', GoodsEnum::getExpressTypeMap());
    }

    public function index()
    {
        if (!$this->request->isAjax()) {
            return $this->view->fetch();
        }

        //如果发送的来源是 Selectpage，则转发到 Selectpage
        if ($this->request->request('keyField')) {
            return $this->selectpage();
        }
        
        [$where, $sort, $order, $offset, $limit] = $this->buildparams();
        
        $list = $this->model
            ->with('commission_goods')
            ->where($where)
            ->order($sort, $order)
            ->paginate($limit);
        
        // 为列表项添加文本表示
        $items = collection($list->items())->each(function ($goods) {
            return $this->formatGoodsData($goods);
        });
        
        $result = ['total' => $list->total(), 'rows' => $items];
        return json($result);
    }

    /**
     * 详情
     *
     * @param  $id
     */
    public function detail($id)
    {
        $goodsList = collection(GoodsModel::with(['commission_goods'])->whereIn('id', $id)->select())->each(function ($goods) {
            $goods->skus = $goods->skus;
            $goods->sku_prices = $goods->sku_prices;
            
            // 使用统一的格式化方法
            return $this->formatGoodsData($goods);
        });

        // 获取分销配置
        $config = [
            'participate_list' => CommissionGoodsEnum::$participateList,
            'rule_type_list' => CommissionGoodsEnum::$ruleTypeList,
            'level_list' => CommissionGoodsEnum::$levelList,
            // 商品枚举配置
            'goods_status_map' => GoodsEnum::getGoodsStatusMap(),
            'goods_spec_type_map' => GoodsEnum::getSpecTypeMap(),
            'goods_type_map' => GoodsEnum::getGoodsTypeMap(),
            'goods_delivery_type_map' => GoodsEnum::getDeliveryTypeMap(),
            'goods_express_type_map' => GoodsEnum::getExpressTypeMap()
        ];
        
        $this->success('分销商品详情', null, [
            'goods' => $goodsList,
            'config' => $config
        ]);
    }

    /**
     * 设置佣金
     *
     * @param  $ids
     */
    public function commission($ids = null)
    {
        if (!$this->request->isPost()) {
            // GET请求，显示设置页面
            $goodsIds = explode(',', $ids);
            $goodsList = GoodsModel::whereIn('id', $goodsIds)
                ->with(['commission_goods'])
                ->select();
            
            // 获取分销商等级列表及其佣金规则
            $levelList = LevelModel::order('level asc')
                ->select();
            
            // 获取分销配置（用于显示默认佣金比例）
            $commissionConfig = ShopConfigService::getConfigs('shop.commission');
            
            // 提取默认佣金规则用于前端显示
            $defaultCommissionRules = [];
            foreach ($levelList as $level) {
                if (isset($level->commission_rules) && is_array($level->commission_rules)) {
                    $defaultCommissionRules[$level->level] = $level->commission_rules;
                }
            }
            
            // 获取第一个商品的分销数据（如果存在）
            $commissionData = null;
            if (isset($goodsList[0]) && $goodsList[0]->commission_goods) {
                $commissionData = $goodsList[0]->commission_goods->toArray();
                
                // 如果是默认规则，从系统配置中读取默认值用于前端显示
                if ($commissionData['rule_type'] == CommissionGoodsEnum::RULE_TYPE_DEFAULT) {
                    // 从分销配置中读取默认值
                    $commissionData['config'] = [
                        'self_buy' => $commissionConfig['self_buy'] ?? 1,
                        'level' => $commissionConfig['level'] ?? 3,
                        'reward_type' => $commissionConfig['reward_type'] ?? 'pay_price',
                        'reward_event' => $commissionConfig['reward_event'] ?? 'paid'
                    ];
                }
            } else {
                // 如果没有分销数据，创建默认数据，从系统配置中读取
                $commissionData = [
                    'rule_type' => CommissionGoodsEnum::RULE_TYPE_DEFAULT,
                    'status' => CommissionGoodsEnum::PARTICIPATE_NO,
                    'order_status' => CommissionGoodsEnum::ORDER_STATUS_YES,
                    'config' => [
                        'self_buy' => $commissionConfig['self_buy'] ?? 1,
                        'level' => $commissionConfig['level'] ?? 3,
                        'reward_type' => $commissionConfig['reward_type'] ?? 'pay_price',
                        'reward_event' => $commissionConfig['reward_event'] ?? 'paid'
                    ]
                ];
            }
            
            // 传递数据给前端
            $this->assignconfig('commission_data', $commissionData);
            $this->assignconfig('commission_config', $commissionConfig);
            $this->assignconfig('default_commission_rules', $defaultCommissionRules);
            
            $this->view->assign([
                'goods_list' => $goodsList,
                'level_list' => $levelList,
                'goods_ids' => $ids,
                'commission_data' => $commissionData, // 传递佣金数据用于数据初始化
                'commission_config' => $commissionConfig, // 传递分销配置
                'default_commission_rules' => $defaultCommissionRules, // 传递默认佣金规则
                // 商品枚举配置
                'goods_status_map' => GoodsEnum::getGoodsStatusMap(),
                'goods_spec_type_map' => GoodsEnum::getSpecTypeMap(),
                'goods_type_map' => GoodsEnum::getGoodsTypeMap(),
                'goods_delivery_type_map' => GoodsEnum::getDeliveryTypeMap(),
                'goods_express_type_map' => GoodsEnum::getExpressTypeMap(),
                // 分销商品枚举配置
                'commission_participate_list' => CommissionGoodsEnum::$participateList,
                'commission_order_status_list' => CommissionGoodsEnum::$orderStatusList,
                'commission_rule_type_list' => CommissionGoodsEnum::$ruleTypeList,
                'commission_level_list' => CommissionGoodsEnum::$levelList,
                'commission_self_buy_list' => CommissionGoodsEnum::$selfBuyList,
                'commission_settlement_list' => CommissionGoodsEnum::$settlementList,
                'commission_settlement_event_list' => CommissionGoodsEnum::$commissionSettlementList,
                'commission_type_list' => CommissionGoodsEnum::$commissionTypeList
            ]);
            
            return $this->view->fetch();
        }

        // POST请求，保存设置
        $this->token();
        $params = $this->request->post();
        
        // 验证必需参数
        if (empty($ids)) {
            $this->error('商品ID不能为空');
        }

        $result = Db::transaction(function () use ($ids, $params) {
            $goodsIds = explode(',', $ids);
            $count = 0;
            $ruleType = intval($params['rule_type'] ?? CommissionGoodsEnum::RULE_TYPE_DEFAULT);

            foreach ($goodsIds as $goods_id) {
                $goods_id = intval($goods_id);
                if ($goods_id <= 0) continue;

                // 查找或创建分销商品记录
                $commissionGoods = CommissionGoodsModel::where('goods_id', $goods_id)->find();
                if (!$commissionGoods) {
                    $commissionGoods = new CommissionGoodsModel();
                    $commissionGoods->goods_id = $goods_id;
                }

                // 保存规则类型（所有情况都需要）
                $commissionGoods->rule_type = $ruleType;
                
                // 根据不同规则类型处理
                if ($ruleType == CommissionGoodsEnum::RULE_TYPE_DEFAULT) {
                    // 默认规则：保存"是否参与"和"分销商业绩"设置，但不保存其他自定义配置
                    $commissionGoods->status = intval($params['status'] ?? CommissionGoodsEnum::PARTICIPATE_NO);
                    $commissionGoods->order_status = intval($params['order_status'] ?? CommissionGoodsEnum::ORDER_STATUS_YES);
                    $commissionGoods->config = []; // 不保存其他自定义配置
                    
                    // 删除可能存在的自定义佣金规则
                    Db::name('shop_commission_rules')
                        ->where('goods_id', $goods_id)
                        ->delete();
                        
                } else if (in_array($ruleType, [CommissionGoodsEnum::RULE_TYPE_CUSTOM, CommissionGoodsEnum::RULE_TYPE_BATCH])) {
                    // 独立规则或批量规则
                    $distributionStatus = intval($params['status'] ?? CommissionGoodsEnum::PARTICIPATE_NO);
                    $commissionGoods->status = $distributionStatus;
                    
                    // 只有在分销设置开启时才保存其他配置
                    if ($distributionStatus == CommissionGoodsEnum::PARTICIPATE_YES) {
                        // 保存分销商业绩设置
                        $commissionGoods->order_status = intval($params['order_status'] ?? CommissionGoodsEnum::ORDER_STATUS_YES);
                        
                        // 保存扩展配置到JSON字段中
                        $config = $commissionGoods->config ?? [];
                        
                        // 保存自购配置
                        if (isset($params['self_buy'])) {
                            $config['self_buy'] = intval($params['self_buy']);
                        }
                        
                        // 保存分销层级
                        if (isset($params['level'])) {
                            $config['level'] = intval($params['level']);
                        }
                        
                        // 保存商品结算方式
                        if (isset($params['reward_type'])) {
                            $config['reward_type'] = $params['reward_type'];
                        }
                        
                        // 保存佣金结算时机
                        if (isset($params['reward_event'])) {
                            $config['reward_event'] = $params['reward_event'];
                        }
                        
                        // 如果有其他自定义配置
                        if (!empty($params['config']) && is_array($params['config'])) {
                            $config = array_merge($config, $params['config']);
                        }
                        
                        $commissionGoods->config = $config;
                        
                        // 保存佣金规则
                        if (!empty($params['commission_rules'])) {
                            $this->saveCommissionRules($goods_id, $params['commission_rules'], $ruleType);
                        }
                    } else {
                        // 分销设置关闭时，清空相关配置但保留rule_type
                        $commissionGoods->order_status = CommissionGoodsEnum::ORDER_STATUS_YES; // 保持默认值
                        $commissionGoods->config = []; // 清空配置
                        
                        // 删除佣金规则
                        Db::name('shop_commission_rules')
                            ->where('goods_id', $goods_id)
                            ->delete();
                    }
                }

                $commissionGoods->save();
                $count++;
            }

            return $count;
        });

        if ($result) {
            $this->success('设置成功', '', $result);
        } else {
            $this->error('设置失败');
        }
    }

    /**
     * 保存佣金规则
     */
    private function saveCommissionRules($goodsId, $rulesData, $ruleType)
    {
        // 删除现有规则
        Db::name('shop_commission_rules')
            ->where('goods_id', $goodsId)
            ->delete();

        if (empty($rulesData) || !is_array($rulesData)) {
            return true;
        }

        $insertData = [];
        
        foreach ($rulesData as $agentLevel => $levelRules) {
            if (!is_array($levelRules)) continue;
            
            foreach ($levelRules as $commissionLevel => $rule) {
                if (empty($rule['value']) || bccomp($rule['value'], '0', 4) <= 0) {
                    continue;
                }
                
                $insertData[] = [
                    'goods_id' => $goodsId,
                    'sku_id' => 0, // 批量规则统一为0，独立规则需要具体SKU ID
                    'agent_level' => intval($agentLevel),
                    'level' => intval($commissionLevel), // 新表字段名为level
                    'type' => $rule['type'] ?? 'rate',
                    'value' => floatval($rule['value']),
                    'status' => 1,
                    'created_at' => date('Y-m-d H:i:s'),
                    'updated_at' => date('Y-m-d H:i:s')
                ];
            }
        }

        if (!empty($insertData)) {
            return Db::name('shop_commission_rules')->insertAll($insertData);
        }

        return true;
    }

    /**
     * 格式化商品数据，添加文本表示
     * 
     * @param object $goods 商品对象
     * @return object
     */
    private function formatGoodsData($goods)
    {
        // 添加商品状态和规格类型的文本表示
        $goods->status_text = GoodsEnum::getGoodsStatusText($goods->status);
        $goods->spec_type_text = GoodsEnum::getSpecTypeText($goods->spec_type);
        $goods->goods_type_text = GoodsEnum::getGoodsTypeText($goods->type);
        $goods->delivery_type_text = GoodsEnum::getDeliveryTypeText($goods->delivery_type ?? '');
        $goods->express_type_text = GoodsEnum::getExpressTypeText($goods->express_type ?? '');
        
        // 如果有分销商品信息，添加分销状态文本
        if ($goods->commission_goods) {
            $goods->commission_goods->participate_text = CommissionGoodsEnum::getParticipateText($goods->commission_goods->status);
            $goods->commission_goods->order_status_text = CommissionGoodsEnum::getOrderStatusText($goods->commission_goods->order_status);
            $goods->commission_goods->rule_type_text = CommissionGoodsEnum::getRuleTypeText($goods->commission_goods->rule_type);
            
            // 从config JSON中获取self_buy配置
            $config = $goods->commission_goods->config ?? [];
            $selfBuy = $config['self_buy'] ?? 0;
            $goods->commission_goods->self_buy = $selfBuy;
            $goods->commission_goods->self_buy_text = CommissionGoodsEnum::getSelfBuyText($selfBuy);
            
            // 添加颜色标识
            $goods->commission_goods->participate_color = CommissionGoodsEnum::getParticipateColor($goods->commission_goods->status);
            $goods->commission_goods->order_status_color = CommissionGoodsEnum::getOrderStatusColor($goods->commission_goods->order_status);
            $goods->commission_goods->self_buy_color = CommissionGoodsEnum::getSelfBuyColor($selfBuy);
            
            // 从config中获取其他配置
            $goods->commission_goods->level = $config['level'] ?? 0;
            $goods->commission_goods->reward_type = $config['reward_type'] ?? 'pay_price';
            $goods->commission_goods->reward_event = $config['reward_event'] ?? 'paid';
        }
        
        return $goods;
    }
    
    /**
     * 获取商品状态筛选选项
     * 
     * @return array
     */
    public function getStatusFilterOptions()
    {
        return [
            'goods_status' => GoodsEnum::getGoodsStatusMap(),
            'spec_type' => GoodsEnum::getSpecTypeMap(),
            'goods_type' => GoodsEnum::getGoodsTypeMap(),
            'commission_participate' => CommissionGoodsEnum::$participateList,
            'commission_rule_type' => CommissionGoodsEnum::$ruleTypeList
        ];
    }
    
    /**
     * 批量设置商品分销状态
     * 
     * @param string $ids 商品ID，多个用逗号分隔
     * @param int $status 分销状态
     * @return void
     */
    public function batchSetStatus($ids, $status)
    {
        if (!$this->request->isPost()) {
            $this->error('请求方式错误');
        }
        
        $goodsIds = explode(',', $ids);
        $status = intval($status);
        
        if (!CommissionGoodsEnum::isValidParticipate($status)) {
            $this->error('无效的分销状态');
        }
        
        $count = 0;
        foreach ($goodsIds as $goodsId) {
            $goodsId = intval($goodsId);
            if ($goodsId <= 0) continue;
            
            // 查找或创建分销商品记录
            $commissionGoods = CommissionGoodsModel::where('goods_id', $goodsId)->find();
            if (!$commissionGoods) {
                $commissionGoods = new CommissionGoodsModel();
                $commissionGoods->goods_id = $goodsId;
                $commissionGoods->order_status = 1; // 默认计入业绩
                $commissionGoods->rule_type = 0; // 默认使用默认规则
            }
            
            $commissionGoods->status = $status;
            $commissionGoods->save();
            $count++;
        }
        
        $this->success("已更新 {$count} 个商品的分销状态");
    }
}