using AnfleCrawler.Common;

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

namespace AnfleCrawler.DataAnalyzer

{

    internal class Qy58 : AnalyzerBase

    {

        public override void Init(PageCrawler crawler)

        {

            base.Init(crawler);

            var url = new Uri("http://qy.58.com/caohejing/pn1/?PGTID=14177711280840.45006677554920316&ClickID=1");

            //http://qy.58.com/19583455460359/?PGTID=14177659184690.5166369006238447&ClickID=4

            crawler.PushUrl(url, );

        }

        protected override void AnalyzeInternal(PageLandEntity current)

        {

            var lander = Crawler.Lander;

            var pHandler = CreateContentHandler(current);

            switch (current.Depth)

            {

                case :

                    {

                        pHandler.AjaxBlocks.Add(HACK);

                        var dom = lander.GetDocument(pHandler);

                        DoPerPaging(current, dom.DocumentNode, ".next");

                        foreach (var node in QueryNodes(dom.DocumentNode, ".compList a"))

                        {

                            var url = GetHref(node, current.Url);

                            Crawler.PushUrl(url, );

                        }

                    }

                    break;

                case :

                    {

                        var dom = lander.GetDocument(pHandler);

                        var attr = new AttributeFiller();

                        attr.Append("Name:{0}", QueryTexts(dom.DocumentNode, ".compT").First());

                        foreach (var th in QueryNodes(dom.DocumentNode, ".basicMsg table th").Skip())

                        {

                            string sTh = th.InnerText, sTd;

                            switch (sTh)

                            {

                                case "联系电话":

                                case "邮箱":

                                    var client = new System.Net.WebClient();

                                    var iNode = QueryNode(th.NextSibling, "img");

                                    byte[] imgRaw = client.DownloadData(GetHref(iNode, current.Url, attrName: "src"));

                                    var img = new System.Drawing.Bitmap(new System.IO.MemoryStream(imgRaw));

                                    sTd = OCR(img);

                                    break;

                                case "公司地址":

                                    sTd = QueryTexts(th.NextSibling, "span").First();

                                    break;

                                default:

                                    sTd = th.NextSibling.InnerText.HtmlTrim();

                                    break;

                            }

                            attr.Append("{0}:{1}", sTh, sTd);

                        }

                        var bo = new CompanyEntity();

                        bo.City = "上海";

                        bo.GroupName = "漕河泾企业";

                        bo.PageUrl = current.Url.OriginalString;

                        bo.UpdateDate = DateTime.Now;

                        attr.FillEntity(bo, new Dictionary<string, string>()

                        {

                            {"公司性质", "Nature"},

                            {"公司行业", "Industry"},

                            {"公司规模", "Scale"},

                            {"联系人", "ContactPerson"},

                            {"企业网址", "Website"},

                            {"联系电话", "Tel"},

                            {"邮箱", "Email"},

                            {"公司地址", "Address"},

                        });

                        Repository.SaveCompany(bo);

                        Crawler.OutWrite("保存企业 {0}", bo.Name);

                    }

                    break;

            }

        }

    }

}