diff --git a/app/admin/controller/Source.php b/app/admin/controller/Source.php
index 08fcb24..639691f 100644
--- a/app/admin/controller/Source.php
+++ b/app/admin/controller/Source.php
@@ -372,31 +372,30 @@ class Source extends QfShop
         // 过滤掉空值的数组元素
         $urls = array_filter($urls);
         
-        $allData = array_map(function($item) {
-            $url = $item;
-            $code = '';
-        
-            // 检查是否包含 '?pwd=' 提取码格式
-            if (strpos($item, '?pwd=') !== false) {
-                // 使用 '?pwd=' 分割链接和提取码
-                list($url, $code) = explode('?pwd=', $item, 2);
-                $url = trim($url);  // 去掉 URL 中的空白字符
-                $code = trim($code);  // 提取码去掉空白字符
-            } 
-            // 检查是否包含逗号 ',' 提取码格式
-            else if (strpos($item, ',') !== false) {
-                // 使用 ',' 分割链接和提取码
-                list($url, $code) = explode(',', $item, 2);
-                $url = trim($url);  // 去掉 URL 中的空白字符
-                $code = trim($code);  // 提取码去掉空白字符
+        $allData = array_values(array_filter(array_map(function ($item) {
+            // 提取 URL
+            if (!preg_match('/https?:\/\/[^\s]+/', $item, $matches)) {
+                return null; // 没有匹配到 URL，直接丢弃
             }
         
+            $url = trim($matches[0]);
+            $code = '';
+        
+            // 提取提取码（?pwd= 或 , 分割）
+            if (preg_match('/\?pwd=([^,\s]+)/', $item, $pwdMatch)) {
+                $code = trim($pwdMatch[1]);
+            } elseif (preg_match('/,(.+)$/', $item, $commaMatch)) {
+                $code = trim($commaMatch[1]);
+            }
+        
+            // 返回结果时，确保 title 保持为空字符串
             return [
-                'url' => $url,  // 只取链接部分
+                'url' => $url,
                 'title' => '',
-                'code' => $code,  // 提取码部分
+                'code' => $code
             ];
-        }, $urls);
+        }, $urls)));
+        
         
         // 去重，使用 'url' 字段来去重
         $uniqueUrls = [];
diff --git a/extend/quarkPlugin/QuarkPlugin.php b/extend/quarkPlugin/QuarkPlugin.php
index def4fd3..a90c6ee 100644
--- a/extend/quarkPlugin/QuarkPlugin.php
+++ b/extend/quarkPlugin/QuarkPlugin.php
@@ -16,7 +16,7 @@ class QuarkPlugin
 
     public function __construct()
     {
-        //第三方转存接口地址
+        // 第三方转存接口地址
         $this->url = "";
         $this->model = new SourceModel();
         $this->SourceLogModel = new SourceLogModel();
@@ -25,44 +25,48 @@ class QuarkPlugin
 
     public function getFiles($quark_cookie)
     {
-        $urlData = array(
-            'cookie' => $quark_cookie??'',
-        );
-        $res = curlHelper(Request::domain()."/api/open/getFiles", "POST", $urlData)['body'];
+        $urlData = [
+            'cookie' => $quark_cookie ?? '',
+        ];
+        $res = curlHelper(Request::domain() . "/api/open/getFiles", "POST", $urlData)['body'];
         $res = json_decode($res, true);
 
-        if($res['code'] !== 200){
+        if ($res['code'] !== 200) {
             return jerr($res['message']);
         }
 
         return $res['data'];
     }
     
-    public function import($allData,$source_category_id)
+    public function import($allData, $source_category_id)
     {
         $this->source_category_id = $source_category_id;
 
         $length = count($allData);
+        $logId = $this->SourceLogModel->addLog('批量转入链接', $length);
 
-        $logId = $this->SourceLogModel->addLog('批量转入链接',$length);
-        $isType = 1;
-        $this->processDataConcurrently($allData, $logId, $length,10,$isType);
-        $this->SourceLogModel->editLog($logId,$length,'','',3);
+        foreach ($allData as $data) {
+            $this->processSingleData($data, $logId, $length, 1);
+        }
+
+        $this->SourceLogModel->editLog($logId, $length, '', '', 3);
     }
 
-    public function transfer($allData,$source_category_id)
+    public function transfer($allData, $source_category_id)
     {
         $this->source_category_id = $source_category_id;
 
         $length = count($allData);
+        $logId = $this->SourceLogModel->addLog('批量转存他人链接', $length);
 
-        $logId = $this->SourceLogModel->addLog('批量转存他人链接',$length);
+        foreach ($allData as $data) {
+            $this->processSingleData($data, $logId, $length);
+        }
 
-        $this->processDataConcurrently($allData, $logId, $length);
-        $this->SourceLogModel->editLog($logId,$length,'','',3);
+        $this->SourceLogModel->editLog($logId, $length, '', '', 3);
     }
 
-    public function transferAll($source_category_id,$day=0)
+    public function transferAll($source_category_id, $day = 0)
     {
         @set_time_limit(999999);
         
@@ -70,173 +74,101 @@ class QuarkPlugin
 
         // 分页转存
         $page_no = 1;
-        $dataList = '';
-        $logId = '';
         $allData = [];
-        while ($dataList=='' || !empty($dataList['items'])) {
-            $searchData =  array(
+        $logId = '';
+
+        while (true) {
+            $searchData = [
                 'page_no' => $page_no,
                 'page_size' => 10000,
                 'type' => 2, //从旧到新排序  也就是先采集旧数据
-                'day' => $day, //等2时 用于每日更新
+                'day' => $day,  //等2时 用于每日更新  默认0是全部数据
                 'category_id' => $this->source_category_id
-            );
-            $res = curlHelper($this->url."/api/search", "POST", $searchData)['body'];
+            ];
+            $res = curlHelper($this->url . "/api/search", "POST", $searchData)['body'];
             $res = json_decode($res, true);
 
+            if ($res['code'] !== 200 || empty($res['data']['items'])) {
+                break;
+            }
+
+            $dataList = $res['data'];
+            $allData = array_merge($allData, $dataList['items']);
             $page_no++;
 
-            if($res['code'] == 200){
-                $dataList = $res['data'];
-                $allData = array_merge($allData, $dataList['items']??[]);
-
-                if($logId == ''){
-                    $name = $day==2?'每日更新':'全部转存';
-                    $logId = $this->SourceLogModel->addLog($name,$dataList['total_result']);
-                }
-
+            if ($logId == '') {
+                $name = $day == 2 ? '每日更新' : '全部转存';
+                $logId = $this->SourceLogModel->addLog($name, $dataList['total_result']);
             }
-            // 可以添加一个最大重试次数的限制，防止无限循环
+
             if ($page_no > 1000) {
                 break;
             }
         }
 
-        $this->processDataConcurrently($allData, $logId, $dataList['total_result']);
-
-        $this->SourceLogModel->editLog($logId,$dataList['total_result'],'','',3);
-    }
-    
-    function processDataConcurrently($allData, $logId=0, $total_result=0,$batchSize=1,$isType=0) {
-        // $batchSize每批最多处理 5 个请求，并发量切勿设置过大 防止风控
-        $multiCurl = curl_multi_init();
-        $curlHandles = [];
-    
-        foreach ($allData as $key => $value) {
-            // 如已有此资源 跳过
-            $detail = $this->model->where('title', $value['title'])->find();
-            if (!empty($detail)) {
-                if(!empty($logId)){
-                    $this->SourceLogModel->editLog($logId, $total_result, 'skip_num', '重复跳过转存');
-                }
-                continue;
-            }
-    
-            // 处理 URL
-            $url = $value['url'];
-            $substring = strstr($url, 's/');
-            if ($substring !== false) {
-                $pwd_id = substr($substring, 2); // 去除 's/' 部分
-            } else {
-                if(!empty($logId)){
-                    $this->SourceLogModel->editLog($logId, $total_result, 'fail_num', '资源地址格式有误');
-                }
-                continue;
-            }
-    
-            // 生成请求数据
-            $urlData = [
-                'cookie' => Config('qfshop.quark_cookie') ?? '',
-                'Authorization' => Config('qfshop.Authorization') ?? '',
-                'expired_type' => 1, // 1正式资源 2临时资源
-                'to_pdir_fid' => '', //存入目标文件
-                'url' => $url,
-                'code' => $value['code']??'',
-                'isType' => $isType??0
-            ];
-    
-            // 创建单个 cURL 句柄
-            $ch = curl_init();
-            curl_setopt($ch, CURLOPT_URL, Request::domain() . "/api/open/transfer");
-            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-            curl_setopt($ch, CURLOPT_POST, true);
-            curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($urlData));
-    
-            // 将句柄添加到 multiCurl 中
-            curl_multi_add_handle($multiCurl, $ch);
-            $curlHandles[$key] = $ch;
-    
-            // 控制并发数量，达到 $batchSize 处理一次
-            if (count($curlHandles) >= $batchSize) {
-                $this->executeAndHandleCurlMulti($multiCurl, $curlHandles, $allData, $logId, $total_result);
-            }
+        foreach ($allData as $data) {
+            $this->processSingleData($data, $logId, count($allData));
         }
-    
-        // 处理剩余未满批次的请求
-        if (!empty($curlHandles)) {
-            $this->executeAndHandleCurlMulti($multiCurl, $curlHandles, $allData, $logId, $total_result);
-        }
-    
-        curl_multi_close($multiCurl);
+
+        $this->SourceLogModel->editLog($logId, count($allData), '', '', 3);
     }
-    
-    function executeAndHandleCurlMulti($multiCurl, &$curlHandles, $allData, $logId, $total_result) {
-        // 执行 cURL 多请求
-        $running = null;
-        do {
-            curl_multi_exec($multiCurl, $running);
-            curl_multi_select($multiCurl);
-        } while ($running > 0);
-    
-        // 获取结果并处理
-        foreach ($curlHandles as $key => $ch) {
-            $response = curl_multi_getcontent($ch);
-            curl_multi_remove_handle($multiCurl, $ch);
-            curl_close($ch);
-    
-            // 立即处理每个请求的返回结果
-            $res = json_decode($response, true);
-            $value = $allData[$key];
-    
-            if ($res['code'] !== 200) {
-                if ($res['message'] == 'capacity limit[{0}]') {
-                    if(!empty($logId)){
-                        $this->SourceLogModel->editLog($logId, $total_result, 'fail_num', $res['message']);
-                    }
-                    break;
-                } else {
-                    if(!empty($logId)){
-                        $this->SourceLogModel->editLog($logId, $total_result, 'fail_num', $res['message']);
-                    }
-                    continue;
-                }
-            }
 
-            if(empty($value['title'])){
-                $patterns = '/^\d+\./';
-                $title = preg_replace($patterns, '', $res['data']['title']);
-            }else{
-                $title = $value['title'];
-            }
-            
-            if(!empty($value['source_category_id'])){
-                $source_category_id = $value['source_category_id']??0;
-            }else{
-                $source_category_id = $this->source_category_id;
-            }
-            
-
-            // 添加资源到系统中
-            $data["title"] = $title;
-            $data["url"] = $res['data']['share_url'];
-            $data["is_type"] = determineIsType($data["url"]);
-            $data["code"] = $value['code']??'';
-            $data["source_category_id"] = $source_category_id;
-            $data["update_time"] = time();
-            $data["create_time"] = time();
-            $dataFid = $res['data']['fid']??'';
-            $data["fid"] = is_array($dataFid) ? json_encode($dataFid) : $dataFid;
-            
-            $this->model->insertGetId($data);
-            if(!empty($logId)){
-                $this->SourceLogModel->editLog($logId, $total_result, 'new_num', '');
+    function processSingleData($value, $logId = 0, $total_result = 0, $isType = 0)
+    {
+        $detail = $this->model->where('title', $value['title'])->find();
+        if (!empty($detail)) {
+            if (!empty($logId)) {
+                $this->SourceLogModel->editLog($logId, $total_result, 'skip_num', '重复跳过转存');
             }
+            return;
         }
-    
-        // 清空句柄
-        $curlHandles = [];
-    }
-    
-    
 
+        $url = $value['url'];
+        $substring = strstr($url, 's/');
+        if ($substring === false) {
+            if (!empty($logId)) {
+                $this->SourceLogModel->editLog($logId, $total_result, 'fail_num', '资源地址格式有误');
+            }
+            return;
+        }
+
+        $urlData = [
+            'cookie' => Config('qfshop.quark_cookie') ?? '',
+            'Authorization' => Config('qfshop.Authorization') ?? '',
+            'expired_type' => 1,  // 1正式资源 2临时资源
+            'to_pdir_fid' => '',  //存入目标文件
+            'url' => $url,
+            'code' => $value['code'] ?? '',
+            'isType' => $isType
+        ];
+
+        $res = curlHelper(Request::domain() . "/api/open/transfer", "POST", $urlData)['body'];
+        $res = json_decode($res, true);
+
+        if ($res['code'] !== 200) {
+            if (!empty($logId)) {
+                $this->SourceLogModel->editLog($logId, $total_result, 'fail_num', $res['message']);
+            }
+            return;
+        }
+
+        $title = empty($value['title']) ? preg_replace('/^\d+\./', '', $res['data']['title']) : $value['title'];
+        $source_category_id = $value['source_category_id'] ?? $this->source_category_id;
+
+        $data = [
+            "title" => $title,
+            "url" => $res['data']['share_url'],
+            "is_type" => determineIsType($res['data']['share_url']),
+            "code" => $value['code'] ?? '',
+            "source_category_id" => $source_category_id,
+            "update_time" => time(),
+            "create_time" => time(),
+            "fid" => is_array($res['data']['fid'] ?? '') ? json_encode($res['data']['fid']) : ($res['data']['fid'] ?? '')
+        ];
+
+        $this->model->insertGetId($data);
+        if (!empty($logId)) {
+            $this->SourceLogModel->editLog($logId, $total_result, 'new_num', '');
+        }
+    }
 }