fuse/app/admin/logic/IndexLogic.php

<?php

namespace app\api\logic;

use app\model\CommonModel;
use app\model\SupplierModel;
use app\model\DevelopmentModel;
use think\Exception;
use think\facade\Cache;
use think\facade\Config;
use think\facade\Db;
use think\helper\Str;

class IndexLogic
{

    //刷新密钥
    public static function refreshSecret(array $param = [])
    {

        $supplier = SupplierModel::alias('a')
            ->field('a.id,a.code')
            ->join('wsm_supplier_contact b', 'b.code=a.code')
            ->where([
                'a.name' => $param['supplierName'],
                'a.legaler' => $param['legaler'],
                'a.registercode' => $param['registercode'],
                'b.contactor' => $param['contactor'],
                'b.mobile' => $param['mobile'],
                'a.is_del' => 0
            ])
            ->findOrEmpty()
            ->toArray();

        if (empty($supplier)) return json_show(CommonModel::$error_param, '相关供应商不存在');

        $clientID = $supplier['code'];//clientID，暂时取用供应商编码字段
        $clientSercert = Str::random(40, 5);//clientSercert，随机40个字符

        $data = array_merge($param, [
            'supplierNo' => $supplier['code'],
            'clientID' => $clientID,
            'clientSecret' => $clientSercert,
        ]);

        $id = DevelopmentModel::where('supplierNo', $supplier['code'])
            ->value('id', 0);

        if ($id) $res = DevelopmentModel::where('id', $id)->save($data); //更新
        else {
            $res = DevelopmentModel::create($data);
            $id = $res->id;
        } //新增

        if ($res) {

            Cache::set(Config::get('redis_key.development_clientID') . $clientID, json_encode(array_merge(['id' => $id], $data), JSON_UNESCAPED_UNICODE), 30 * 24 * 3600);

            return json_show(CommonModel::$success, '刷新密钥成功', ['clientID' => $clientID, 'clientSecret' => $clientSercert]);

        } else return json_show(CommonModel::$error_default, '刷新密钥失败');;


    }

    //修改开发信息中的推送地址
    public static function updatePushUrl(array $param = [])
    {

        $res = DevelopmentModel::where('supplierNo', request()->development['supplierNo'])
            ->save(['push_url' => implode(',', $param['push_url'])]);

        return $res ? json_show(CommonModel::$success, '修改推送地址成功') : json_show(CommonModel::$error_default, '修改推送地址失败');

    }

    //获取推送记录
    public static function getPushLog(array $param = [])
    {

        $res = Db::name('push_log')
            ->where('supplierNo', request()->development['supplierNo']);

        if ($param['push_url'] != '') $res->whereLike('push_url', '%' . $param['push_url'] . '%');
        if ($param['type']) $res->where('type', $param['type']);
        if ($param['start'] != '') $res->where('addtime', '>=', $param['start']);
        if ($param['end'] != '') $res->where('addtime', '<=', $param['end']);

        $count = $res->count('id');

        $list = $res
            ->page($param['page'], $param['size'])
            ->order('id')
            ->select()
            ->toArray();

        return json_show(CommonModel::$success, '获取推送记录成功', ['count' => $count, 'list' => $list]);

    }


    //获取上线平台列表
//    public static function getPlatformList(string $keyword = '', int $page = 1, int $size = 15)
//    {
//
//        $db = Db::connect('mysql_wsm')
//            ->name('platform')
//            ->where('is_del', 0);
//
//        if ($keyword != '') $db->whereLike('platform_name', '%' . $keyword . '%');
//
//        $count = $db->count('id');
//
//        $list = $db
//            ->field('id platform_id,platform_code,platform_name,platform_type')
//            ->order('id')
//            ->page($page, $size)
//            ->select()
//            ->toArray();
//
//        return json_show(0, '请求成功', ['count' => $count, 'list' => $list]);
//
//    }

    //获取分类列表
    public static function getCatList(string $keyword = '', int $pid = 0)
    {

        $db = Db::connect('mysql_wsm')
            ->name('cat')
            ->where(['is_del' => 0, 'pid' => $pid]);

        if ($keyword != '') $db->whereLike('cat_name', '%' . $keyword . '%');

        $count = $db->count('id');

        $list = $db
            ->field('id cat_id,cat_name,level')
            ->order('id')
            ->select()
            ->toArray();

        return json_show(0, '请求成功', ['count' => $count, 'list' => $list]);

    }

    //获取品牌列表
    public static function getBrandList(string $keyword = '', int $page = 1, int $size = 15)
    {

        $db = Db::connect('mysql_wsm')
            ->name('brand')
            ->where('is_del', 0);

        if ($keyword != '') $db->whereLike('brand_name', '%' . $keyword . '%');

        $count = $db->count('id');

        $list = $db
            ->field('id brand_id,brand_name')
            ->order('id')
            ->page($page, $size)
            ->select()
            ->toArray();

        return json_show(0, '请求成功', ['count' => $count, 'list' => $list]);

    }

    //获取单位列表
    public static function getUnitList(string $keyword = '', int $page = 1, int $size = 15)
    {

        $db = Db::connect('mysql_wsm')
            ->name('unit')
            ->where('is_del', 0);

        if ($keyword != '') $db->whereLike('unit', '%' . $keyword . '%');

        $count = $db->count('id');

        $list = $db
            ->field('id unit_id,unit unit_name')
            ->order('id')
            ->page($page, $size)
            ->select()
            ->toArray();

        return json_show(0, '请求成功', ['count' => $count, 'list' => $list]);

    }

    //获取规格标题列表
    public static function getSpecsTitleList(string $keyword = '')
    {

        $db = Db::connect('mysql_wsm')
            ->name('specs')
            ->where('is_del', 0);

        if ($keyword != '') $db->whereLike('spec_name', '%' . $keyword . '%');

        $list = $db
            ->field('id spec_id,spec_name')
            ->order('addtime', 'desc')
            ->select()
            ->toArray();

        return json_show(0, '请求成功', $list);

    }

    //获取规格值列表
    public static function getSpecsValueByTitleList(int $spec_id = 0)
    {

        $list = Db::connect('mysql_wsm')
            ->name('spec_value')
            ->field('spec_id ,id spec_value_id,spec_value')
            ->where(['is_del' => 0, 'spec_id' => $spec_id])
            ->order('id')
            ->select()
            ->toArray();

        return json_show(0, '请求成功', $list);

    }

    //创建规格值
    public static function createSpec(array $param = [])
    {
        $url = env('WSM_DOMAIN') . 'abutment/createSpec';

        $res = json_decode(curl_request($url, $param), true);

        if (isset($res) && $res['code'] == CommonModel::$success) return json_show(CommonModel::$success, '创建规格值成功');
        else throw new Exception($res['message']);

    }

    //获取省市区列表
    public static function getAreaList(int $level = 1, string $pid_code = '', string $keyword = '')
    {

        switch ($level) {
            case 1:
                $list = Db::connect('mysql_wsm')
                    ->name('province')
                    ->field('province_code code,name');
                break;
            case 2:
                $list = Db::connect('mysql_wsm')
                    ->name('city')
                    ->field('city_code code,name')
                    ->where('province_code', $pid_code);
                break;
            case 3:
                $list = Db::connect('mysql_wsm')
                    ->name('area')
                    ->field('area_code code,name')
                    ->where('city_code', $pid_code);
                break;
        }

        if ($keyword != '') $list->whereLike('name', '%' . $keyword . '%');

        $data = $list->order('id')
            ->select()
            ->toArray();

        return json_show(0, '获取成功', $data);
    }

    //获取业务公司编码
    public static function getCompanyNoList(string $keyword = '')
    {

        $db = Db::connect('mysql_wsm')
            ->name('business')->where('is_del', 0);

        if ($keyword != '') $db->whereLike('company|companyNo', '%' . $keyword . '%');

        $list = $db
            ->field('companyNo,company')
            ->order('id')
            ->select()
            ->toArray();

        return json_show(0, '请求成功', $list);

    }

    //专属类型列表
    public static function getExclusiveList(int $pid = 0, string $keyword = '')
    {
        $where = [['status', '=', 1], ['is_del', '=', 0], ['pid', '=', $pid]];
        if ($keyword !== '') $where[] = ['name', 'like', '%' . $keyword . '%'];

        $data = Db::connect('mysql_wsm')
            ->name('exclusive')
            ->field('id exclusive_id,name exclusive_name,level')
            ->where($where)
            ->select()
            ->toArray();

        return json_show(0, '获取成功', $data);

    }

    //上传图片
    public static function uploadImg(array $files = [])
    {

        $url = env('WSM_DOMAIN') . 'abutment/uploadImg';

//        halt($files->getPath().DIRECTORY_SEPARATOR.$files->getFilename(),$files->getType(),$files->getBasename());

//        $data = array('file' => new \CURLFile(realpath($path)));

        $res = curl_upload($url, $files);

        halt('请求结果：', $res);
        $res = json_decode(curl_request($url, ['image' => $files->getPath() . DIRECTORY_SEPARATOR . $files->getFilename()]), true);
        halt($res);
        if (isset($res) && $res['code'] == CommonModel::$success) return json_show(CommonModel::$success, '上传图片成功', $res['data']);
        else throw new Exception($res['message']);
    }

}