<?php
/**
 * Copyright 2012-2026 ShopeX (https://www.shopex.cn)
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
/**
 * 报价系统授权管理
 *
 * @author wangbiao@shopex.cn
 * @version 2024.08.22
 */
class wmsmgr_ctl_admin_smart extends desktop_controller
{
    var $workground = "wms_manager";
    
    protected $_channel_type = 'smart';
    
    function index()
    {
        $params = array(
            'title' => '报价系统授权',
            'actions' => array(
                'add' => array(
                    'label'  => '添加报价系统授权',
                    'href'   => 'index.php?app=wmsmgr&ctl=admin_smart&act=add',
                    'target' => "dialog::{width:600,height:450,title:'添加报价系统授权'}",
                ),
            ),
            'base_filter' => array('channel_type'=>$this->_channel_type),
            'use_buildin_new_dialog' => false,
            'use_buildin_set_tag'    => false,
            'use_buildin_recycle'    => false,
            'use_buildin_export'     => false,
            'use_buildin_import'     => false,
        );
        
        $this->finder('wmsmgr_mdl_smart', $params);
    }
    
    function add() {
        $this->_edit();
    }

    function edit($wms_id) {
        $this->_edit($wms_id);
    }

    private function _edit($wms_id = NULL)
    {
        if ($wms_id) {
            $smartMdl = $this->app->model('smart');
            $wms_detail = $smartMdl->dump($wms_id);
            
            $wms_detail['config'] = unserialize($wms_detail['config']);
            $wms_detail['adapter'] = kernel::single('wmsmgr_func')->getAdapterByChannelId($wms_id);
            $wms_detail['api_url'] = app::get('wmsmgr')->getConf('api_url' . $wms_detail['node_id']);
            
            $this->pagedata['wms'] = $wms_detail;
        }
        
        $adapter_list = kernel::single('wmsmgr_smart_config')->getAdapterList();
        $this->pagedata['adapter_list'] = $adapter_list;
        
        $this->display("add_smart.html");
    }

    /**
     * confightml
     * @param mixed $wms_id ID
     * @param mixed $adapter adapter
     * @return mixed 返回值
     */

    public function confightml($wms_id, $adapter)
    {
        switch ($adapter) {
            case 'openapiwms':
                if ($wms_id) {
                    $smartMdl = $this->app->model('smart');
                    $wms_detail = $smartMdl->dump($wms_id, 'node_type,node_id');
                    
                    $this->pagedata['config']['node_type'] = $wms_detail['node_type'];
                    $this->pagedata['wms_id'] = $wms_id;
                }
                break;
            default:
                # code...
                break;
        }
        
        //渠道
        $platform_list = kernel::single('wmsmgr_smart_config')->getPlatformList($adapter);
        
        $this->pagedata['platform_list'] = $platform_list;
        
        $this->display("smart/". $adapter .".html");
    }
    
    /**
     * platformconfig
     * @param mixed $wms_id ID
     * @param mixed $platform platform
     * @return mixed 返回值
     */
    public function platformconfig($wms_id, $platform)
    {
        $config = array('private_key'=>'', 'api_url'=>'');
        if ($wms_id) {
            $adapter = app::get('channel')->model('adapter')->dump(array('channel_id' => $wms_id));
            $config = @unserialize($adapter['config']);
        }
        
        //渠道
        $platform_params = kernel::single('wmsmgr_smart_config')->getPlatformParam($platform);
        
        $this->pagedata['config'] = $config;
        $this->pagedata['platform_params'] = $platform_params;
        $this->pagedata['platform'] = $platform;
        
        $this->display("smart/platformconfig.html");
    }

    function savesmart()
    {
        $smartMdl = $this->app->model("wms");
        
        $url = 'index.php?app=wmsmgr&ctl=admin_smart&act=index';
        $this->begin($url);
        
        //post
        $postData = array(
            'channel_type' => $this->_channel_type,
            'channel_bn' => $_POST['wms']['channel_bn'],
            'channel_name' => $_POST['wms']['channel_name'],
            'adapter' => $_POST['wms']['adapter'],
            'node_type' => $_POST['config']['node_type'],
        );
        
        //check
        if(empty($postData['channel_bn'])){
            $this->end(false, '请填写系统编码!');
        }
        
        if(empty($postData['channel_name'])){
            $this->end(false, '请填写系统名称!');
        }
        
        if(empty($postData['adapter'])){
            $this->end(false, '请选择系统适配器!');
        }
        
        if(empty($postData['node_type'])){
            $this->end(false, '请选择授权平台!');
        }
        
        //add OR update
        $channelInfo = array();
        $filter = array('channel_bn'=>$postData['channel_bn']);
        if($_POST['wms']['channel_id']){
            $channelInfo = $smartMdl->dump(array('channel_id'=>$_POST['wms']['channel_id']), '*');
            if($channelInfo){
                $filter['channel_id|noequal'] = $channelInfo['channel_id'];
            }
        }
        
        //判断数据是否已经存在
        $channelRow = $smartMdl->dump($filter, '*');
        if($channelRow){
            $this->end(false, '系统编码已经存在,不能重复!');
        }
        
        //check
        if ($channelInfo['node_id'] && $_POST['adapter'] != $_POST['wms']['adapter']) {
            $this->end(false, '绑定关系已存在情况下：不可切换仓储适配器!');
        }
        
        switch ($_POST['wms']['adapter']) {
            case 'openapiwms':
                $postData['node_id'] = sprintf('o%u', crc32(utils::array_md5($_POST['config']) . kernel::base_url()));
                
                //检验node_id是否存在
                $filter = array('node_id'=>$postData['node_id']);
                if ($channelInfo) {
                    $filter['channel_id|noequal'] = $channelInfo['channel_id'];
                }
                
                $checkInfo = $smartMdl->dump($filter, '*');
                if($checkInfo){
                    $this->end(false, app::get('base')->_('node_id重复：请更换秘钥,同时通知报价系统更改秘钥!'));
                }
                
                //判断config参数是否填写
                $params = kernel::single('wmsmgr_smart_config')->getPlatformParam($postData['node_type']);
                if ($params) {
                    foreach ($params as $key => $label)
                    {
                        if (!$_POST['config'][$key]) {
                            $this->end(false, $label .'：不能为空');
                        }
                    }
                }
            default:
                # code...
                break;
        }
        
        //config
        $postData['config'] = serialize($_POST['config']);
        
        //data
        if($channelInfo){
            $postData['channel_id'] = $channelInfo['channel_id'];
        }
        
        //save
        $isSave = $smartMdl->save($postData);
        if(!$isSave){
            $this->end(false, app::get('base')->_('保存数据失败!'));
        }
        
        //save adapter
        $adapter = array('channel_id'=>$postData['channel_id'], 'adapter'=>$postData['adapter'], 'config'=>$postData['config']);
        app::get('channel')->model('adapter')->save($adapter);
        
        $this->end(true, app::get('base')->_($rt ? '保存成功' : '保存失败'));
    }
    
    /**
     * 删除Channel
     * @return mixed 返回值
     */
    public function deleteChannel()
    {
        $this->begin('index.php?app=wmsmgr&ctl=admin_smart&act=index');
        
        $obj_channel = kernel::single('channel_channel');
        $obj_branch = kernel::single('ome_branch');
        
        if (is_array($_POST['channel_id']) && count($_POST['channel_id']) > 0) {
            $filter['channel_id'] = $_POST['channel_id'];
        } elseif (isset($_POST['isSelectedAll']) && $_POST['isSelectedAll'] == '_ALL_') {
            $filter = $_POST;
            unset($filter['app']);
            unset($filter['ctl']);
            unset($filter['act']);
            unset($filter['flt']);
            unset($filter['_finder']);
        }
        
        //获取所有已经绑定的应用channel_id
        $_bind_info = $obj_channel->getList($filter, '*');
        $_branch_bind_wms_info = $obj_branch->getBindWmsBranchList();
        $bind_channel_id = array(); #所有已经绑定的channel_id
        $bind_wms_id = array();
        $channel_name = array();
        
        if (!empty($_bind_info)) {
            foreach ($_bind_info as $v) {
                $channel_name[$v['channel_id']] = $v['channel_name'];
                $channel_id[] = $v['channel_id'];

                #把已经存在的绑定节点存起来
                if (strlen($v['node_id']) > 0 && !in_array($v['node_type'], array('selfwms', 'mobile', 'webpos'))) {
                    $bind_channel_id[] = $v['channel_id'];
                }

                if (in_array($v['node_type'], array('mobile', 'webpos'))) {
                    $this->end(false, $this->app->_('虚拟门店仓储类型不允许被删除!'));
                    exit;
                }
            }
        }
        
        if (!empty($_branch_bind_wms_info)) {
            foreach ($_branch_bind_wms_info as $v) {
                if (in_array($v['wms_id'], $channel_id)) {
                    $this->end(false, $this->app->_('仓储:' . $channel_name[$v['wms_id']] . '，已经绑定了仓库，请先解除绑定!'));
                    exit;
                }
            }
        }
        
        //验证即将被删除的这条channel_id是否已经解除绑定
        foreach ($channel_id as $id) {
            $result = array_search($id, $bind_channel_id);
            if ($result !== false) {
                $this->end(false, $this->app->_('删除前，请解除绑定!'));
                exit;
            }
        }
        
        //验证完毕，开始删除
        if ($obj_channel->delete(array('channel_id' => $channel_id))) {
            $this->end(true, $this->app->_('删除成功'));
        } else {
            $this->end(false, $this->app->_('删除失败'));
        }
    }

    /**
     * 申请绑定关系
     * @param string $app_id
     * @param string $callback 异步返回地址
     * @param string $api_url API通信地址
     */
    function apply_bindrelation($app_id = 'ome', $callback = '', $api_url = '')
    {
        $this->Certi = base_certificate::get('certificate_id');
        $this->Token = base_certificate::get('token');
        $this->Node_id = base_shopnode::node_id($app_id);
        $token = $this->Token;
        $sess_id = kernel::single('base_session')->sess_id();
        $apply['certi_id'] = $this->Certi;
        if ($this->Node_id)
            $apply['node_id'] = $this->Node_id;
        $apply['sess_id'] = $sess_id;
        $apply['certi_ac'] = base_certificate::getCertiAC($apply);

        $params = array(
            'source'    => 'apply',
            'certi_id'  => $apply['certi_id'],
            'node_id'   => $apply['node_id'],
            'sess_id'   => $apply['sess_id'],
            'certi_ac'  => $apply['certi_ac'],
            'callback'  => $callback,
            'api_url'   => $api_url,
            'show_type' => 'wms',
        );

        $this->pagedata['license_iframe'] = sprintf('<iframe width="100%%" frameborder="0" height="99%%" id="iframe" onload="this.height=document.documentElement.clientHeight-4" src="%s" ></iframe>', MATRIX_RELATION_URL . '?' . http_build_query($params));
        // $this->pagedata['license_iframe'] = '<iframe width="100%" frameborder="0" height="99%" id="iframe" onload="this.height=document.documentElement.clientHeight-4" src="' . MATRIX_RELATION_URL . '?source=apply&certi_id='.$apply['certi_id'].'&node_id=' . $apply['node_id'] . '&sess_id='.$apply['sess_id'].'&certi_ac='.$apply['certi_ac'].'&callback=' . $callback . '&api_url=' . $api_url .'" ></iframe>';

        $this->display('bindRelation.html');
    }

    /*
     * 查看绑定关系
     */
    function view_bindrelation()
    {
        $this->Certi = base_certificate::get('certificate_id');
        $this->Token = base_certificate::get('token');
        $this->Node_id = base_shopnode::node_id('ome');
        $token = $this->Token;
        $sess_id = kernel::single('base_session')->sess_id();
        $apply['certi_id'] = $this->Certi;
        $apply['node_id'] = $this->Node_id;
        $apply['sess_id'] = $sess_id;
        $apply['certi_ac'] = base_certificate::getCertiAC($apply);
        $callback = urlencode(kernel::openapi_url('openapi.channel', 'bindCallback'));
        $api_url = kernel::base_url(true) . kernel::url_prefix() . '/api';
        $api_url = urlencode($api_url);
        $op_id = kernel::single('desktop_user')->get_login_name();
        $op_user = kernel::single('desktop_user')->get_name();
        // $params = '&op_id='.$op_id.'&op_user='.$op_user;

        $params = array(
            'op_id'     => $op_id,
            'op_user'   => $op_user,
            'source'    => 'accept',
            'certi_id'  => $apply['certi_id'],
            'node_id'   => $this->Node_id,
            'sess_id'   => $apply['sess_id'],
            'certi_ac'  => $apply['certi_ac'],
            'callback'  => $callback,
            'api_url'   => $api_url,
            'show_type' => 'wms',
        );
        
        echo sprintf('<title>查看绑定关系</title><iframe width="100%%" height="95%%" frameborder="0" src="%s" ></iframe>', MATRIX_RELATION_URL . '?' . http_build_query($params));
    }
    
    /**
     * undocumented function
     * 
     * @return void
     * @author
     * */
    public function gen_private_key()
    {
        echo md5(uniqid());
        exit;
    }
    
    /**
     * 绑定店铺
     * 
     * @return void
     * @author 
     */
    public function bind_page($channel_id)
    {
        $this->pagedata['channel_id'] = $channel_id;

        $filter = array('filter_sql'=>' node_id != "" AND node_id IS NOT NULL');

        $wms = $this->app->model("wms")->db_dump($channel_id,'config');
        $wms['config'] = @unserialize($wms['config']);

        if (in_array($wms['config']['node_type'],array('bms','bim'))) {
            $filter['node_type'] = 'taobao';
        }

        if (in_array($wms['config']['node_type'],array('yph'))){
            $filter['node_type'] = '360buy';
        }
        $this->pagedata['filter'] = $filter;

        $this->display('bind/shop.html');
    }

    /**
     * 仓储绑定店铺
     * 
     * @return void
     * @author 
     */
    public function bind_shop()
    {
        $channel_id = $_POST['channel_id']; $shop_id = $_POST['shop_id'];

        $wmsModel = $this->app->model('smart');
        $wms = $wmsModel->db_dump(array('channel_id'=>$channel_id,'channel_type'=>$this->_channel_type));
        $wms['config'] = @unserialize($wms['config']);

        if (!$wms) parent::splash('error',null,'仓储不存在');

        if ($wms['node_id']) parent::splash('error',null,'仓储已经绑定');

        if (!$wms['config']['node_type'] || $wms['config']['node_type'] == 'other') parent::splash('error',null,'仓储不支持绑定店铺');

        $shop = app::get('ome')->model('shop')->dump($shop_id,'node_id,node_type');
        if (!$shop['node_id']) parent::splash('error',null,'店铺未绑定');

        $addon = array('node_id'=>$shop['node_id']);
        $node_id = sprintf('o%u', crc32(utils::array_md5($wms['config']) . kernel::base_url()));;
        $wmsModel->update(array('node_id'=>$node_id,'node_type'=>$wms['config']['node_type'],'addon'=>$addon),array('channel_id'=>$channel_id));

        parent::splash('success',null,'绑定成功');
    }

    /**
     * bindNodeId
     * @param mixed $channelId ID
     * @return mixed 返回值
     */
    public function bindNodeId($channelId) {
        $this->pagedata['channel_id'] = (int) $channelId;
        $this->display('bind/node_id.html');
    }

    /**
     * 设置NodeId
     * @return mixed 返回操作结果
     */
    public function setNodeId() {
        $channel_id = trim($_POST['channel_id']);
        $node_id = trim($_POST['node_id']);
        
        $wmsModel = $this->app->model('smart');
        $wms = $wmsModel->db_dump(array('channel_id'=>$channel_id,'channel_type'=>$this->_channel_type));
        $wms['config'] = @unserialize($wms['config']);

        if (!$wms) parent::splash('error',null,'仓储不存在');

        if ($wms['node_id']) parent::splash('error',null,'仓储已经绑定');

        if (!$wms['config']['node_type'] || $wms['config']['node_type'] == 'other') parent::splash('error',null,'仓储不支持填写node_id');

        $wmsModel->update(array('node_id'=>$node_id,'node_type'=>$wms['config']['node_type']),array('channel_id'=>$channel_id));

        parent::splash('success',null,'绑定成功');
    }
    
    /**
     * 仓储解绑店铺
     * 
     * @param Int $channel_id 仓库ID
     * @return void
     * @author 
     */
    public function unbind_shop($channel_id)
    {
        $affect_row = $this->app->model('smart')->update(array('node_id'=>null,'node_type'=>null), array('channel_id'=>$channel_id,'channel_type'=>$this->_channel_type));
        $affect_row && is_numeric($affect_row) ? parent::splash('success','index.php?app=wmsmgr&ctl=admin_smart&act=index','解绑成功') : parent::splash('error',null,'解绑失败');
    }
    
    /**
     * 检查是否允许解除绑定关系
     */
    public function unbind_verify($channel_id)
    {
        if (empty($channel_id)) {
            die("单据号传递错误！");
        }
        
        $wmsObj = $this->app->model('smart');
        $wmsInfo = $wmsObj->db_dump(array('channel_id'=>$channel_id, 'channel_type'=>$this->_channel_type), '*');
        if(empty($wmsInfo)){
            die("WMS仓储信息不存在！");
        }
        
        $this->pagedata['channel_id'] = $channel_id;
        $this->pagedata['wmsInfo'] = $wmsInfo;
        $this->display('bind/unbind_verify.html');
    }
    
    /**
     * 最终解除绑定关系
     */
    public function finish_unbind($channel_id)
    {
        $result = array('rsp'=>'fail', 'error_msg'=>'');
        
        //info
        $wmsObj = $this->app->model('smart');
        $wmsInfo = $wmsObj->db_dump(array('channel_id'=>$channel_id, 'channel_type'=>$this->_channel_type), '*');
        if(empty($wmsInfo)){
            $result['error_msg'] = 'WMS仓储信息不存在';
            echo json_encode($result);
            exit;
        }
        
        //解除绑定
        $affect_row = $wmsObj->update(array('node_id'=>null, 'node_type'=>null) ,array('channel_id'=>$channel_id,'channel_type'=>$this->_channel_type));
        if($affect_row && is_numeric($affect_row)){
            $result['rsp'] = 'succ';
            echo json_encode($result);
            exit;
        }else{
            $result['error_msg'] = '解除绑定失败';
            echo json_encode($result);
            exit;
        }
    }
}