小碗熊cms5.0火车头采集器免登陆发布模块api

/app/api/controller/Postbot.php

接口文件放置位置

模块不需要登录， 模块配置哪里直接选择不登录

发布模块的表单字段及说明：

1. book_name 漫画名

2. nick_name 漫画别名

3. tags 分类，多个分类用|隔开

4. author 作者名字

5. end 状态，1代表完结，0代表连载中

6. cover_url 封面图远程地址

7. chapter_name 章节名

8. area_id 地区id

9. images 由图片标签组成的字符串，示例：

自动检测

<img src="http://www.m.com/1.jpg"><img src="http://www.m.com/2.jpg"><img src="http://www.m.com/3.jpg">

11. summary 漫画简介

12. api_key 后台配置的api_key

13. src 用来区别采集源，自己写

14. src_url 用来唯一定义每个漫画，可以是该漫画的url，也可以是该漫画在被采集站的id

15. c_src_url 用来唯一定义每个章节，与src_url同理

<?php
namespace apppicontroller;

use appmodelAuthor;
use appmodelBook;
use appmodelPhoto;
use thinkController;
use thinkRequest;
use appmodelChapter;
use appservicechapterService;
use appservicephotoService;

class Postbot
{
    protected $chapterService;
    protected $photoService;


    public function initialize()
    {
        $this->chapterService = new ppserviceChapterService();
        $this->photoService = new ppservicePhotoService();
    }

    public function save(Request $request)
    {
        if ($request->isPost()) {
            $data = $request->param();
            $key = $data['api_key'];
            if (empty($key) || is_null($key)) {
                return 'api密钥不能为空！';
            }
            if ($key != config('site.api_key')) {
                return 'api密钥错误！';
            }

            $book = Book::where('book_name', '=', trim($data['book_name']))->where('unique_id', '=', trim($data['unique_id']))->find();
            if (!$book) { //如果漫画不存在
                $author = Author::where('author_name', '=', trim($data['author']))->find();
                if (is_null($author)) {//如果作者不存在
                    $author = new Author();
                    $author->author_name = $data['author'] ?: '侠名';
                    $author->save();
                }
                $book = new Book();
                $book->unique_id = $data['unique_id'];
                $book->author_id = $author->id;
                $book->author_name = $data['author'] ?: '侠名';
                $book->area_id = trim($data['area_id']);
                $book->book_name = trim($data['book_name']);
                if (!empty($data['nick_name']) || !is_null($data['nick_name'])) {
                    $book->nick_name = trim($data['nick_name']);
                }
                $book->tags = trim($data['tags']);
                $book->end = trim($data['end']);
                $book->start_pay = trim($data['start_pay']);
                $book->money = trim($data['money']);
//                $info = $this->getImage($data['cover_url'], './img/' . date("Ymd"));
                $book->cover_url = trim($data['cover_url']);
                $book->summary = trim($data['summary']);
                $book->last_time = time();
                //      $book->update_week = rand(1, 7);
                //      $book->click = rand(1000, 9999);
                $book->save();
            }
            $map[] = ['chapter_name', '=', trim($data['chapter_name'])];
            $map[] = ['book_id', '=', $book->id];
            $chapter = Chapter::where($map)->find();
            if (!$chapter) {
                $chapter = new Chapter();
                $chapter->chapter_name = trim($data['chapter_name']);
                $chapter->book_id = $book->id;
                $lastChapterOrder = 0;

                if ($data['chapter_order']) {
                    $chapter->chapter_order = (int)$data['chapter_order'];
                } else {
                    $lastChapter = $this->getLastChapter($book['id']);
                    if ($lastChapter) {
                        $lastChapterOrder = $lastChapter->chapter_order;
                    }
                    $chapter->chapter_order = $lastChapterOrder + 1;
                }
                $chapter->update_time = time();
                $chapter->save();
            }
            $book->last_time = time();
            $book->save();
            $preg = '/srcs*=s*['"]?([^'"]*)['"]?/i';
            preg_match_all($preg, $data['images'], $img_urls);
            $lastOrder = 0;
            $lastPhoto = $this->getLastPhoto($chapter->id);
            if ($lastPhoto) {
                $lastOrder = $lastPhoto->pic_order + 1;
            }
            foreach ($img_urls[1] as $img_url) {
                $photo = new Photo();
                $photo->chapter_id = $chapter->id;
                $photo->pic_order = $lastOrder;
//                $info = $this->getImage($img_url, './img/' . date("Ymd"));

                $photo->img_url = $img_url;
                $photo->save();
                $lastOrder++;
            }
            echo "操作成功";
        }

    }

    public function getLastChapter($book_id)
    {
        return Chapter::where('book_id', '=', $book_id)->order('chapter_order', 'desc')->limit(1)->find();
    }

    public function getLastPhoto($chapter_id)
    {
        return Photo::where('chapter_id', '=', $chapter_id)->order('id', 'desc')->limit(1)->find();
    }

    /*功能：php完美实现下载远程图片保存到本地
  *参数：文件url,保存文件目录,保存文件名称，使用的下载方式
  *当保存文件名称为空时则使用远程文件原来的名称
  */
    function getImage($url, $save_dir = '/public/img/', $filename = '', $type = 1)
    {
        if (trim($url) == '') {
            return array('file_name' => '', 'save_path' => '', 'error' => 1);
        }
        if (trim($save_dir) == '') {
            $save_dir = './';
        }

        $url = str_replace('jpg
', 'jpg', $url);

        file_put_contents("result.txt", "url：" . $url . "
", FILE_APPEND);


        if (trim($filename) == '') {//保存文件名
            $ext = strrchr($url, '.');
//            if($ext!='.gif'&&$ext!='.jpg'){
//                return array('file_name'=>'','save_path'=>'','error'=>3);
//            }
            $filename = time() . rand(100000, 999999) . $ext;
        }
        if (0 !== strrpos($save_dir, '/')) {
            $save_dir .= '/';
        }
        //创建保存目录
        if (!file_exists($save_dir) && !mkdir($save_dir, 0777, true)) {
            return array('file_name' => '', 'save_path' => '', 'error' => 5);
        }
        //获取远程文件所采用的方法
        if ($type) {
            $img =$this-> http_curl($url);
            !$img && $img = $this->http_curl($url);
            !$img && $img = $this->http_curl($url);
        } else {
            ob_start();
            readfile($url);
            $img = ob_get_contents();
            ob_end_clean();
        }
        //$size=strlen($img);

//        dump($img);die;/
        //文件大小

//        dump($save_dir.$filename);die;
        $fp2 = @fopen($save_dir . $filename, 'a');
        fwrite($fp2, $img);
        fclose($fp2);
        unset($img, $url);
        return array('file_name' => $filename, 'save_path' => str_replace('./', '/', $save_dir . $filename), 'error' => 0);
    }


    function http_curl($url)
    {

        $ch = curl_init();
        $timeout = 5;
        $aHeader = array('Referer: https://www.baidu.com/');
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HTTPHEADER, $aHeader);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        $img = curl_exec($ch);
        curl_close($ch);
        return $img;
    }


}