/**

 * Project Name:padwebcollector

 * File Name:DiscussService.java

 * Package Name:com.pad.service

 * Date:2018年7月25日下午4:59:44

 * Copyright (c) 2018 All Rights Reserved.

 *

*/  

package com.pad.service;  

import java.util.ArrayList;

import java.util.List;

import org.openqa.selenium.By;

import org.openqa.selenium.WebDriver;

import org.openqa.selenium.WebElement;

import org.openqa.selenium.phantomjs.PhantomJSDriver;

import cn.edu.hfut.dmic.webcollector.crawler.DeepCrawler;

import cn.edu.hfut.dmic.webcollector.model.Links;

import cn.edu.hfut.dmic.webcollector.model.Page;

import com.pad.entity.DiscussInfo;

import com.pad.impl.DiscussInfoImpl;

public class DiscussService extends DeepCrawler {

    public DiscussService(String crawlPath) {

        super(crawlPath);

        // TODO Auto-generated constructor stub

    }

    @Override

    public Links visitAndGetNextLinks(Page page) {

        // TODO Auto-generated method stub

        WebDriver driver = getWebDriver(page);

        Analysis analysis = new Analysis();

        List<DiscussInfo> discusslist = new ArrayList();

        List<WebElement> list = driver.findElements(By.className("content"));

        int i = 1;

        String r_msg = "观望";

        for(WebElement el : list) {

            if(!"".equals(el.getText().trim())){

                r_msg = analysis.analysis(el.getText());

            }

            DiscussInfo info = new DiscussInfo();

            info.setLine_no(String.valueOf(i));

            info.setResult_msg(r_msg);

            info.setContent_msg(el.getText());

            discusslist.add(info);

            System.out.println(i+" "+el.getText());

            i++;

        }

        driver.close();

        driver.quit();

        DiscussInfoImpl impl = new DiscussInfoImpl();

        impl.saveData(discusslist);

        return null;

    }

    public static WebDriver getWebDriver(Page page) {

        System.setProperty("phantomjs.binary.path", "D:\\******\\phantomjs.exe");

        WebDriver driver = new PhantomJSDriver();

        driver.get(page.getUrl());

        return driver;

    }

    public static void main(String[] args) {

        DiscussService dis=new DiscussService("discuss");   
　　　　 dis.addSeed("https://*******/index/0000012");

        try {

        dis.start(1);

    } catch (Exception e) {

        e.printStackTrace();

    }

    }

}