feat(admin): 新增网媒配置管理功能

- 添加网媒配置控制器、服务类和数据访问对象
- 实现配置项的增删改查接口
- 配置路由组并应用权限中间件
- 支持系统配置项保护机制
- 优化媒体数据同步逻辑，支持分页处理
- 增加自媒体数据结构与操作支持
- 调整数据库模型继承关系以提高代码复用性
- 扩展API服务能力，适配多种媒体类型同步需求

app/controller/admin/OnlineMediasConfigController.php

@@ -0,0 +1,60 @@
+<?php
+namespace app\controller\admin;
+
+
+use app\service\admin\OnlineMediasConfigService;
+use plugin\piadmin\app\utils\ArrayUtils;
+use support\Response;
+
+class OnlineMediasConfigController
+{
+    public function save(OnlineMediasConfigService $service): Response
+    {
+        $params = requestOnly([
+            'module_id' => 1,
+            'code' => '',
+            'name' => '',
+            'value' => '',
+            'pid' => '',
+            'status' => 1
+        ]);
+
+//        validate(SystemDeptValidate::class)->check($params, 'save');
+
+        return success($service->saveData($params));
+    }
+
+    public function update(OnlineMediasConfigService $service): Response
+    {
+        $params = requestOnly([
+            'id' => '',
+            'module_id' => 1,
+            'code' => '',
+            'name' => 1000,
+            'value' => '',
+            'pid' => '',
+            'status' => 1
+        ]);
+
+//        validate(SystemDeptValidate::class)->check($params, 'update');
+
+        return success($service->updateData(ArrayUtils::filterNotEmpty($params)));
+    }
+
+    public function index(OnlineMediasConfigService $service): Response
+    {
+        return success($service->listData());
+    }
+
+    public function read(OnlineMediasConfigService $service): Response
+    {
+        $id = input('id');
+        return success($service->readData($id));
+    }
+
+    public function delete(OnlineMediasConfigService $service): Response
+    {
+        $ids = input('ids');
+        return success($service->deleteData($ids));
+    }
+}

app/dao/admin/OnlineMediasConfigDao.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace app\dao\admin;
+
+use app\model\admin\OnlineMediasConfig;
+use plugin\piadmin\app\base\BaseDao;
+
+class OnlineMediasConfigDao extends BaseDao
+{
+    protected function setModel(): string
+    {
+        return OnlineMediasConfig::class;
+    }
+
+}

app/dao/admin/OnlineMediasDao.php

@@ -3,9 +3,9 @@
 namespace app\dao\admin;
 
 use app\model\admin\OnlineMedias;
-use plugin\piadmin\app\base\BaseModel;
+use plugin\piadmin\app\base\BaseDao;
 
-class OnlineMediasDao extends BaseModel
+class OnlineMediasDao extends BaseDao
 {
     protected function setModel(): string
     {

app/dao/admin/SelfMediasDao.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace app\dao\admin;
+
+use app\model\admin\SelfMedias;
+use plugin\piadmin\app\base\BaseDao;
+
+class SelfMediasDao extends BaseDao
+{
+    protected function setModel(): string
+    {
+        return SelfMedias::class;
+    }
+
+}

app/model/admin/OnlineMediasConfig.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace app\model\admin;
+
+use plugin\piadmin\app\base\BaseModel;
+
+/**
+ * AI创作指令模型
+ */
+class OnlineMediasConfig extends BaseModel
+{
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'geo_online_medias_config';
+
+    /**
+     * The primary key associated with the table.
+     *
+     * @var string
+     */
+    protected $primaryKey = 'id';
+
+    /**
+     * Indicates if the model should be timestamped.
+     *
+     * @var bool
+     */
+    public $timestamps = true;
+
+}

app/model/admin/SelfMedias.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace app\model\admin;
+
+use plugin\piadmin\app\base\BaseModel;
+
+/**
+ * AI创作指令模型
+ */
+class SelfMedias extends BaseModel
+{
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'geo_self_medias';
+
+    /**
+     * The primary key associated with the table.
+     *
+     * @var string
+     */
+    protected $primaryKey = 'id';
+
+    /**
+     * Indicates if the model should be timestamped.
+     *
+     * @var bool
+     */
+    public $timestamps = true;
+
+}

app/route/admin.php

@@ -1,7 +1,9 @@
 <?php
 
 use app\controller\admin\ApiController;
+use app\controller\admin\OnlineMediasConfigController;
 use plugin\piadmin\app\middleware\AdminAuthorizationMiddleware;
+use plugin\piadmin\app\middleware\PermissionsMiddleware;
 use Webman\Route;
 
 /**
@@ -13,7 +15,23 @@ Route::group('/service/v1', function () {
         Route::get('/syncResource', [ApiController::class, 'syncResource'])->setParams(['perm' => ['meijiequanSyncResource']]);
     });
 
+    //网媒选项配置
+    Route::group('/onlineMediasConfig', function () {
+        Route::post('/save', [OnlineMediasConfigController::class, 'save'])->setParams(['perm' => ['onlineMediasConfigSave']]);
+        Route::post('/update', [OnlineMediasConfigController::class, 'update'])->setParams(['perm' => ['onlineMediasConfigUpdate']]);
+        Route::get('/index', [OnlineMediasConfigController::class, 'index'])->setParams(['perm' => ['onlineMediasConfigIndex']]);
+        Route::get('/read', [OnlineMediasConfigController::class, 'read'])->setParams(['perm' => ['onlineMediasConfigRead']]);
+        Route::post('/delete', [OnlineMediasConfigController::class, 'delete'])->setParams(['perm' => ['onlineMediasConfigDelete']]);
+    });
+
+    //媒体圈媒体数据
+    Route::group('/medias', function () {
+        //网媒
+//        Route::get('/online', [OnlineMediasCont::class, 'online']);
+        //自媒体
+    });
+
 })->middleware([
     AdminAuthorizationMiddleware::class,
-//    PermissionsMiddleware::class
+    PermissionsMiddleware::class
 ]);

app/service/admin/ApiService.php

@@ -3,6 +3,7 @@
 namespace app\service\admin;
 
 use app\dao\admin\OnlineMediasDao;
+use app\dao\admin\SelfMediasDao;
 use plugin\piadmin\app\base\BaseService;
 use plugin\piadmin\app\exception\ApiException;
 use support\Db;
@@ -14,11 +15,13 @@ class ApiService extends BaseService
     protected $url = 'http://www.meijiequan.cn/api/companyResource/syncResource';
     protected $appkey = 'de06270f3515bad109aa1fd2c023dd41';
 
-    protected $dao;
+    protected $onlineMediasDao;
+    protected $selfMediasDao;
 
     public function __construct()
     {
-        $this->dao = app()->make(OnlineMediasDao::class);
+        $this->onlineMediasDao = app()->make(OnlineMediasDao::class);
+        $this->selfMediasDao = app()->make(SelfMediasDao::class);
     }
 
     /**
@@ -28,14 +31,18 @@ class ApiService extends BaseService
      * @param $type
      * @throws \Random\RandomException
      */
-    public function syncResource($type = 35075, $resourceData = [], $nexturl = null)
+    public function syncResource($model_id = 2, $resourceData = [], $nexturl = null, $currentPage = null)
     {
+        set_time_limit(-1);
+        $sum = 0;
+        $total = 0;
+        $page = $currentPage ?? 1;
         $url = $nexturl ?? $this->url;
         $requestData = array (
-            "resource_id"=>$type,
-            "model_id"=>"1",
-            "limit"=>"300",
-            "page"=>"1"
+//            "resource_id"=>$type,
+            "model_id"=>$model_id,
+            "limit"=>"1000",
+            "page"=>$page
         );
         //加密
         $data_info = serialize($requestData);
@@ -60,61 +67,91 @@ class ApiService extends BaseService
         curl_close($ch);
         $result = json_decode($output, true);
         if ($result['errorCode'] == '') {
+            $total = $result['data']['total'];
             //封装当前数据
             foreach ($result['data']['data'] as $item) {
                 //网媒
-                if ($type == '35075') {
+                if ($model_id == 1) {
                     //封装数据
                     $resourceData[] = [
-                        'id' => $item['id'],
-                        'model_id' => $item['model_id'],
-                        'name' => $item['name'],
-                        'price_assign' => $item['price_assign'],
-                        'pindaoleixing' => $item['pindaoleixing'],
-                        'zonghemenhu' => $item['zonghemenhu'],
-                        'quyu' => $item['quyu'],
-                        'meitianli' => $item['meitianli'],
-                        'lianjieleixing' => $item['lianjieleixing'],
-                        'shouluxiaoguo' => $item['shouluxiaoguo'],
-                        'weekend_active' => $item['weekend_active'],
-                        'meitiquanzhong' => $item['meitiquanzhong'],
-                        'tebiehangye' => $item['tebiehangye'],
-                        'jiegaoshijian' => $item['jiegaoshijian'],
-                        'baikelaiyuan' => $item['baikelaiyuan'],
-                        'wanshangkechu' => $item['wanshangkechu'],
-                        'kedaishipin' => $item['kedaishipin'],
-                        'jierikefa' => $item['jierikefa'],
-                        'anlijietu' => $item['anlijietu'],
-                        'no_disclaimer' => $item['no_disclaimer'],
-                        'can_sign' => $item['can_sign'],
-                        'wechat_open' => $item['wechat_open'],
-                        'has_read_count' => $item['has_read_count'],
-                        'avg_delivery_speed' => $item['avg_delivery_speed'],
-                        'publish_rate' => $item['publish_rate'],
-                        'ai_include' => $item['ai_include'],
-                        'meitibeizhu' => $item['meitibeizhu'],
-                        'status' => $item['status'],
+                        'id' => $item['id'] ?? '',
+                        'model_id' => $item['model_id'] ?? '',
+                        'name' => $item['name'] ?? '',
+                        'price_assign' => $item['price_assign'] ?? '',
+                        'pindaoleixing' => $item['pindaoleixing'] ?? '',
+                        'zonghemenhu' => $item['zonghemenhu'] ?? '',
+                        'quyu' => $item['quyu'] ?? '',
+                        'meitianli' => $item['meitianli'] ?? '',
+                        'lianjieleixing' => $item['lianjieleixing'] ?? '',
+                        'shouluxiaoguo' => $item['shouluxiaoguo'] ?? '',
+                        'weekend_active' => $item['weekend_active'] ?? '',
+                        'meitiquanzhong' => $item['meitiquanzhong'] ?? '',
+                        'tebiehangye' => $item['tebiehangye'] ?? '',
+                        'jiegaoshijian' => $item['jiegaoshijian'] ?? '',
+                        'baikelaiyuan' => $item['baikelaiyuan'] ?? '',
+                        'wanshangkechu' => $item['wanshangkechu'] ?? '',
+                        'kedaishipin' => $item['kedaishipin'] ?? '',
+                        'jierikefa' => $item['jierikefa'] ?? '',
+                        'anlijietu' => $item['anlijietu'] ?? '',
+                        'no_disclaimer' => $item['no_disclaimer'] ?? '',
+                        'can_sign' => $item['can_sign'] ?? '',
+                        'wechat_open' => $item['wechat_open'] ?? '',
+                        'has_read_count' => $item['has_read_count'] ?? '',
+                        'avg_delivery_speed' => $item['avg_delivery_speed'] ?? '',
+                        'publish_rate' => $item['publish_rate'] ?? '',
+                        'ai_include' => $item['ai_include'] ?? '',
+                        'meitibeizhu' => $item['meitibeizhu'] ?? '',
+                        'status' => $item['status'] ?? '',
                     ];
-                } else if ($type == '90063') {
+                } else if ($model_id == 2) {
                     //自媒体
-                    throw new \Exception('暂不支持');
+                    //封装数据
+                    $resourceData[] = [
+                        'id' => $item['id'] ?? '',
+                        'model_id' => $item['model_id'] ?? '',
+                        'name' => $item['name'] ?? '',
+                        'price_assign' => $item['price_assign'] ?? '',
+                        'pingtai' => $item['pingtai'] ?? '',
+                        'hangyefenlei' => $item['hangyefenlei'] ?? '',
+                        'meitianli' => $item['meitianli'] ?? '',
+                        'cankaofensishu' => $item['cankaofensishu'] ?? '',
+                        'huangv' => $item['huangv'] ?? '',
+                        'meitihao' => $item['meitihao'] ?? '',
+                        'shipinleixing' => $item['shipinleixing'] ?? '',
+                        'wanshangkechu' => $item['wanshangkechu'] ?? '',
+                        'jierikefa' => $item['jierikefa'] ?? '',
+                        'avg_delivery_speed' => $item['avg_delivery_speed'] ?? '',
+                        'publish_rate' => $item['publish_rate'] ?? '',
+                        'meitibeizhu' => $item['meitibeizhu'] ?? '',
+                        'status' => $item['status'] ?? '',
+                    ];
                 } else {
                     throw new \Exception('未知资源类型');
                 }
             }
+            $sum += sizeof($resourceData);
             Db::beginTransaction();
             try {
                 //保存当前页码数据
-                $this->dao->insertAll($resourceData);
+                if ($model_id == 1) {
+                    $this->onlineMediasDao->batchInsertOrUpdate($resourceData);
+                } else if ($model_id == 2) {
+                    $this->selfMediasDao->batchInsertOrUpdate($resourceData);
+                } else {
+                    throw new \Exception('未知资源类型');
+                }
                 Db::commit();
             } catch (Exception $exception) {
-                Db::rollBack();
-                throw new ApiException($exception->getMessage());
-            }
-            if (!empty($result['data']['next_url'])) {
-                //获取下一页数据
-                $this->syncResource($type, [], $result['data']['next_url']);
+//                Db::rollBack();
+//                throw new ApiException($exception->getMessage());
             }
+//            if (!empty($result['data']['next_url'])) {
+                if ($sum < $total) {
+                    $page = $page + 1;
+                    //获取下一页数据
+                    $this->syncResource($model_id, [], $this->url . '?page=' . $page, $page);
+                }
+//            }
         }
         return [
             'code' => $result['errorCode'],

app/service/admin/OnlineMediasConfigService.php

@@ -0,0 +1,106 @@
+<?php
+
+namespace app\service\admin;
+
+use app\dao\admin\OnlineMediasConfigDao;
+use plugin\piadmin\app\base\BaseService;
+use plugin\piadmin\app\exception\ApiException;
+use plugin\piadmin\app\utils\TreeUtils;
+use think\facade\Db;
+
+class OnlineMediasConfigService extends BaseService
+{
+    public function __construct()
+    {
+        $this->dao = app()->make(OnlineMediasConfigDao::class);
+    }
+
+    /**
+     * 保存数据
+     * @param array $params
+     * @return \plugin\piadmin\app\base\BaseModel
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function saveData(array $params)
+    {
+        return $this->dao->save($params);
+    }
+
+    /**
+     * 更新数据
+     * @param array $params
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function updateData(array $params)
+    {
+        $config = $this->dao->get(['id' => $params['id']]);
+        if (empty($config)) {
+            throw new ApiException('配置项不存在');
+        }
+        if ($config['is_system'] == 1) {
+            throw new ApiException('系统配置项不允许修改');
+        }
+        // 落库
+        Db::startTrans();
+        try {
+            $this->dao->update(['id' => $config['id']], $params);
+            Db::commit();
+        } catch (\Exception $exception) {
+            Db::rollback();
+            throw new ApiException($exception->getMessage());
+        }
+        return $params;
+    }
+
+    /**
+     * 列表数据
+     * @param array $params
+     * @return array
+     */
+    public function listData(): array
+    {
+        $query = [
+            'delete_time' => 0
+        ];
+        $list = $this->dao->selectList($query)->toArray();
+        return TreeUtils::toTree($list);
+    }
+
+    /**
+     * 详情数据
+     * @param mixed $id
+     * @return array
+     */
+    public function readData(mixed $id): array
+    {
+        $config = $this->dao->get(['id' => $id]);
+        if (empty($config)) {
+            return [];
+        }
+        if ($config['is_system'] == 1) {
+            throw new ApiException('系统配置项不允许查看');
+        }
+        return $config->toArray();
+    }
+
+    public function deleteData($ids)
+    {
+        // 落库
+        Db::startTrans();
+        try {
+            foreach ($ids as $id) {
+                $this->dao->update(['id' => $id, 'is_system' => 2], ['delete_time' => time()]);
+            }
+            Db::commit();
+        } catch (\Exception $exception) {
+            Db::rollback();
+            throw new ApiException($exception->getMessage());
+        }
+        return ['id' => $ids];
+    }
+
+}