#!/usr/bin/python
# -*- coding: UTF-8 -*-

from selenium import webdriver
from selenium.webdriver.common.keys import Keys
import time
import sys
import pymysql
reload(sys)
sys.setdefaultencoding('utf-8')

driver = webdriver.Firefox(executable_path="/Users/chanming/Desktop/geckodriver")
driver.get("https://pay.weixin.qq.com/index.php/partner/public/search")
time.sleep(2)
st=driver.find_element_by_id('searchPortalText')
st.send_keys(u"付")
driver.find_element_by_id("searchPortalSubmit").click()
time.sleep(3)
alist=list()
# map={'拓展地域:':'dis','联 系 人 :':'userName','电  话:':'phone','邮  箱:':'email','地  址:':'address','所属行业:':'industry'}
map={}
flag=True
for x in xrange(1,23):
	nextInput=driver.find_element_by_css_selector('.goto-area input')
	nextInput.clear()
	nextInput.send_keys(x)
	nextButton=driver.find_element_by_css_selector('.goto-area a')
	nextButton.click()
	time.sleep(1)
	searchList=driver.find_elements_by_css_selector('#searchResultList dl')
	for comp in searchList:
		obj={}
		obj['title']=comp.find_element_by_tag_name('dt').text
		propNameList=comp.find_elements_by_class_name('lbl')
		if flag:
			map[propNameList[0].text]='dis'
			map[propNameList[1].text]='userName'
			map[propNameList[2].text]='phone'
			map[propNameList[3].text]='email'
			map[propNameList[4].text]='address'
			map[propNameList[5].text]='industry'
			flag=False
		propList=comp.find_elements_by_class_name('ele')
		k=0
		for propName in propNameList:
			obj[map[propName.text]]=propList[k].text
			k=k+1
		alist.append(obj)
# print len(alist)
driver.close()
db = pymysql.connect(host = '127.0.0.1', port = 3306, user = 'json', passwd = '123456', db = 'youxia', charset="utf8")
cursor = db.cursor()
sql = 'insert into wx_pay_company(dis,userName,phone,email,address,industry,title) values(%s,%s,%s,%s,%s,%s,%s)'
for company in alist:
	if not company.has_key('dis'):
		company['dis']=''
	if not company.has_key('userName'):
		company['userName']=''
	if not company.has_key('phone'):
		company['phone']=''
	if not company.has_key('email'):
		company['email']=''
	if not company.has_key('address'):
		company['address']=''
	if not company.has_key('industry'):
		company['industry']=''
	cursor.execute(sql,(company['dis'],company['userName'],company['phone'],company['email'],company['address'],company['industry'],company['title']))
	db.commit()
cursor.close()
db.close()


print '运行结束'
01-07 01:57