2022-10-02 02:46:47 +00:00
|
|
|
|
# -*- coding: utf-8 -*-
|
2022-10-02 05:38:20 +00:00
|
|
|
|
# 自动带图评价、追评、服务评价,需电脑端CK
|
|
|
|
|
# @Time : 2022/10/2
|
|
|
|
|
# @Author : @qiu-lzsnmb and @Dimlitter @Dylan
|
|
|
|
|
# @File : auto_comment.py
|
|
|
|
|
'''
|
|
|
|
|
new Env('自动评价');
|
|
|
|
|
8 8 2 10 * https://raw.githubusercontent.com/6dylan6/auto_comment/main/jd_comment.py
|
|
|
|
|
'''
|
2022-10-02 02:46:47 +00:00
|
|
|
|
import argparse
|
|
|
|
|
import copy
|
|
|
|
|
import logging
|
|
|
|
|
import os
|
|
|
|
|
import random
|
|
|
|
|
import sys
|
|
|
|
|
import time
|
2022-10-02 12:03:52 +00:00
|
|
|
|
|
2022-10-02 05:38:20 +00:00
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
import jieba # just for linting
|
|
|
|
|
import jieba.analyse
|
2022-10-02 12:47:20 +00:00
|
|
|
|
import requests
|
2022-10-02 05:38:20 +00:00
|
|
|
|
#import yaml
|
|
|
|
|
from lxml import etree
|
|
|
|
|
except:
|
2022-10-02 12:03:52 +00:00
|
|
|
|
print('解决依赖问题...稍等')
|
2022-10-02 05:38:20 +00:00
|
|
|
|
os.system('pip3 install lxml &> /dev/null')
|
|
|
|
|
os.system('pip3 install jieba &> /dev/null')
|
|
|
|
|
os.system('pip3 install zhon &> /dev/null')
|
2022-10-02 12:03:52 +00:00
|
|
|
|
os.system('pip3 install requests &> /dev/null')
|
2022-10-02 07:23:41 +00:00
|
|
|
|
import jieba
|
2022-10-02 05:38:20 +00:00
|
|
|
|
import jieba.analyse
|
|
|
|
|
#import yaml
|
|
|
|
|
from lxml import etree
|
2022-10-02 12:03:52 +00:00
|
|
|
|
import requests
|
2022-10-02 05:38:20 +00:00
|
|
|
|
|
|
|
|
|
|
2022-10-02 02:46:47 +00:00
|
|
|
|
|
|
|
|
|
import jdspider
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# constants
|
|
|
|
|
CONFIG_PATH = './config.yml'
|
|
|
|
|
USER_CONFIG_PATH = './config.user.yml'
|
|
|
|
|
ORDINARY_SLEEP_SEC = 10
|
|
|
|
|
SUNBW_SLEEP_SEC = 5
|
|
|
|
|
REVIEW_SLEEP_SEC = 10
|
|
|
|
|
SERVICE_RATING_SLEEP_SEC = 15
|
|
|
|
|
|
|
|
|
|
## logging with styles
|
|
|
|
|
## Reference: https://stackoverflow.com/a/384125/12002560
|
|
|
|
|
_COLORS = {
|
|
|
|
|
'black': 0,
|
|
|
|
|
'red': 1,
|
|
|
|
|
'green': 2,
|
|
|
|
|
'yellow': 3,
|
|
|
|
|
'blue': 4,
|
|
|
|
|
'magenta': 5,
|
|
|
|
|
'cyan': 6,
|
|
|
|
|
'white': 7
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
_RESET_SEQ = '\033[0m'
|
|
|
|
|
_COLOR_SEQ = '\033[1;%dm'
|
|
|
|
|
_BOLD_SEQ = '\033[1m'
|
|
|
|
|
_ITALIC_SEQ = '\033[3m'
|
|
|
|
|
_UNDERLINED_SEQ = '\033[4m'
|
|
|
|
|
|
|
|
|
|
_FORMATTER_COLORS = {
|
|
|
|
|
'DEBUG': _COLORS['blue'],
|
|
|
|
|
'INFO': _COLORS['green'],
|
|
|
|
|
'WARNING': _COLORS['yellow'],
|
|
|
|
|
'ERROR': _COLORS['red'],
|
|
|
|
|
'CRITICAL': _COLORS['red']
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
def format_style_seqs(msg, use_style=True):
|
|
|
|
|
if use_style:
|
|
|
|
|
msg = msg.replace('$RESET', _RESET_SEQ)
|
|
|
|
|
msg = msg.replace('$BOLD', _BOLD_SEQ)
|
|
|
|
|
msg = msg.replace('$ITALIC', _ITALIC_SEQ)
|
|
|
|
|
msg = msg.replace('$UNDERLINED', _UNDERLINED_SEQ)
|
|
|
|
|
else:
|
|
|
|
|
msg = msg.replace('$RESET', '')
|
|
|
|
|
msg = msg.replace('$BOLD', '')
|
|
|
|
|
msg = msg.replace('$ITALIC', '')
|
|
|
|
|
msg = msg.replace('$UNDERLINED', '')
|
|
|
|
|
|
|
|
|
|
class StyleFormatter(logging.Formatter):
|
|
|
|
|
def __init__(self, fmt=None, datefmt=None, use_style=True):
|
|
|
|
|
logging.Formatter.__init__(self, fmt, datefmt)
|
|
|
|
|
self.use_style = use_style
|
|
|
|
|
|
|
|
|
|
def format(self, record):
|
|
|
|
|
rcd = copy.copy(record)
|
|
|
|
|
levelname = rcd.levelname
|
|
|
|
|
if self.use_style and levelname in _FORMATTER_COLORS:
|
|
|
|
|
levelname_with_color = '%s%s%s' % (
|
|
|
|
|
_COLOR_SEQ % (30 + _FORMATTER_COLORS[levelname]),
|
|
|
|
|
levelname, _RESET_SEQ)
|
|
|
|
|
rcd.levelname = levelname_with_color
|
|
|
|
|
return logging.Formatter.format(self, rcd)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# 评价生成
|
|
|
|
|
def generation(pname, _class=0, _type=1, opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
items = ['商品名']
|
|
|
|
|
items.clear()
|
|
|
|
|
items.append(pname)
|
|
|
|
|
opts['logger'].debug('Items: %s', items)
|
|
|
|
|
loop_times = len(items)
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for i, item in enumerate(items):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', i + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Current item: %s', item)
|
2022-10-02 05:38:20 +00:00
|
|
|
|
spider = jdspider.JDSpider(item,ck)
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].debug('Successfully created a JDSpider instance')
|
|
|
|
|
# 增加对增值服务的评价鉴别
|
|
|
|
|
if "赠品" in pname or "非实物" in pname or "增值服务" in pname:
|
|
|
|
|
result = [
|
|
|
|
|
"赠品挺好的。",
|
|
|
|
|
"很贴心,能有这样免费赠送的赠品!",
|
|
|
|
|
"正好想着要不要多买一份增值服务,没想到还有这样的赠品。",
|
|
|
|
|
"赠品正合我意。",
|
|
|
|
|
"赠品很好,挺不错的。",
|
|
|
|
|
"本来买了产品以后还有些担心。但是看到赠品以后就放心了。",
|
|
|
|
|
"不论品质如何,至少说明店家对客的态度很好!",
|
|
|
|
|
"我很喜欢这些商品!",
|
|
|
|
|
"我对于商品的附加值很在乎,恰好这些赠品为这件商品提供了这样的的附加值,这令我很满意。"
|
|
|
|
|
"感觉现在的网购环境环境越来越好了,以前网购的时候还没有过么多贴心的赠品和增值服务",
|
|
|
|
|
"第一次用京东,被这种赠品和增值服物的良好态度感动到了。",
|
|
|
|
|
"赠品还行。"
|
|
|
|
|
]
|
|
|
|
|
else:
|
|
|
|
|
result = spider.getData(4, 3) # 这里可以自己改
|
|
|
|
|
opts['logger'].debug('Result: %s', result)
|
|
|
|
|
|
|
|
|
|
# class 0是评价 1是提取id
|
|
|
|
|
try:
|
|
|
|
|
name = jieba.analyse.textrank(pname, topK=5, allowPOS='n')[0]
|
|
|
|
|
opts['logger'].debug('Name: %s', name)
|
|
|
|
|
except Exception as e:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'jieba textrank analysis error: %s, name fallback to "宝贝"', e)
|
|
|
|
|
name = "宝贝"
|
|
|
|
|
if _class == 1:
|
|
|
|
|
opts['logger'].debug('_class is 1. Directly return name')
|
|
|
|
|
return name
|
|
|
|
|
else:
|
|
|
|
|
if _type == 1:
|
|
|
|
|
num = 6
|
|
|
|
|
elif _type == 0:
|
|
|
|
|
num = 4
|
|
|
|
|
num = min(num, len(result))
|
|
|
|
|
# use `.join()` to improve efficiency
|
|
|
|
|
comments = ''.join(random.sample(result, num))
|
|
|
|
|
opts['logger'].debug('_type: %d', _type)
|
|
|
|
|
opts['logger'].debug('num: %d', num)
|
|
|
|
|
opts['logger'].debug('Raw comments: %s', comments)
|
|
|
|
|
|
|
|
|
|
return 5, comments.replace("$", name)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# 查询全部评价
|
|
|
|
|
def all_evaluate(opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
N = {}
|
|
|
|
|
url = 'https://club.jd.com/myJdcomments/myJdcomment.action?'
|
|
|
|
|
opts['logger'].debug('URL: %s', url)
|
|
|
|
|
opts['logger'].debug('Fetching website data')
|
|
|
|
|
req = requests.get(url, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200', req.status_code)
|
|
|
|
|
req_et = etree.HTML(req.text)
|
|
|
|
|
opts['logger'].debug('Successfully parsed an XML tree')
|
|
|
|
|
evaluate_data = req_et.xpath('//*[@id="main"]/div[2]/div[1]/div/ul/li')
|
|
|
|
|
loop_times = len(evaluate_data)
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for i, ev in enumerate(evaluate_data):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', i + 1, loop_times)
|
|
|
|
|
na = ev.xpath('a/text()')[0]
|
|
|
|
|
opts['logger'].debug('na: %s', na)
|
|
|
|
|
#print(ev.xpath('b/text()')[0])
|
|
|
|
|
try:
|
|
|
|
|
num = ev.xpath('b/text()')[0]
|
|
|
|
|
opts['logger'].debug('num: %s', num)
|
|
|
|
|
except IndexError:
|
|
|
|
|
#opts['logger'].warning('Can\'t find num content in XPath, fallback to 0')
|
|
|
|
|
num = 0
|
|
|
|
|
N[na] = int(num)
|
|
|
|
|
return N
|
|
|
|
|
|
|
|
|
|
# 评价晒单
|
|
|
|
|
def sunbw(N, opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
Order_data = []
|
|
|
|
|
req_et = []
|
|
|
|
|
loop_times = 2
|
|
|
|
|
opts['logger'].debug('Fetching website data')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for i in range(loop_times):
|
|
|
|
|
url = (f'https://club.jd.com/myJdcomments/myJdcomment.action?sort=0&'
|
|
|
|
|
f'page={i + 1}')
|
|
|
|
|
opts['logger'].debug('URL: %s', url)
|
|
|
|
|
req = requests.get(url, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200', req.status_code)
|
|
|
|
|
req_et.append(etree.HTML(req.text))
|
|
|
|
|
opts['logger'].debug('Successfully parsed an XML tree')
|
|
|
|
|
opts['logger'].debug('Fetching data from XML trees')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for idx, i in enumerate(req_et):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Fetching order data in the default XPath')
|
|
|
|
|
elems = i.xpath(
|
|
|
|
|
'//*[@id="main"]/div[2]/div[2]/table/tbody')
|
|
|
|
|
opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
Order_data.extend(elems)
|
|
|
|
|
if len(Order_data) != N['待评价订单']:
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Count of fetched order data doesn\'t equal N["待评价订单"]')
|
|
|
|
|
opts['logger'].debug('Clear the list Order_data')
|
|
|
|
|
Order_data = []
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for idx, i in enumerate(req_et):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Fetching order data in another XPath')
|
|
|
|
|
elems = i.xpath(
|
|
|
|
|
'//*[@id="main"]/div[2]/div[2]/table')
|
|
|
|
|
opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
Order_data.extend(elems)
|
2022-10-02 05:38:20 +00:00
|
|
|
|
opts['logger'].info(f"当前共有{N['待评价订单']}个需要评价晒单。")
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].debug('Commenting on items')
|
|
|
|
|
for i, Order in enumerate(Order_data):
|
2022-10-02 07:23:41 +00:00
|
|
|
|
if i +1 > 10:
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].info(f'\t已评价10个订单,跳出')
|
|
|
|
|
break
|
|
|
|
|
oname = Order.xpath(
|
|
|
|
|
'tr[@class="tr-bd"]/td[1]/div[1]/div[2]/div/a/text()')[0]
|
|
|
|
|
pid = Order.xpath(
|
|
|
|
|
'tr[@class="tr-bd"]/td[1]/div[1]/div[2]/div/a/@href')[0].replace('//item.jd.com/', '').replace('.html', '')
|
|
|
|
|
oid = Order.xpath('tr[@class="tr-th"]/td/span[3]/a/text()')[0]
|
|
|
|
|
#print (oname,oid,pid)
|
|
|
|
|
#sys.exit()
|
|
|
|
|
opts['logger'].info(f'\t开始第{i+1}个订单: {oid}')
|
|
|
|
|
opts['logger'].debug('pid: %s', pid)
|
|
|
|
|
opts['logger'].debug('oid: %s', oid)
|
|
|
|
|
xing, Str = generation(oname, opts=opts)
|
2022-10-02 07:23:41 +00:00
|
|
|
|
opts['logger'].info(f'\t评价信息:{xing}星 ' + Str)
|
2022-10-02 02:46:47 +00:00
|
|
|
|
# 获取图片
|
|
|
|
|
url1 = (f'https://club.jd.com/discussion/getProductPageImageCommentList'
|
|
|
|
|
f'.action?productId={pid}')
|
|
|
|
|
opts['logger'].debug('Fetching images using the default URL')
|
|
|
|
|
opts['logger'].debug('URL: %s', url1)
|
|
|
|
|
req1 = requests.get(url1, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req1.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200', req1.status_code)
|
|
|
|
|
imgdata = req1.json()
|
|
|
|
|
opts['logger'].debug('Image data: %s', imgdata)
|
|
|
|
|
if imgdata["imgComments"]["imgCommentCount"] == 0:
|
|
|
|
|
opts['logger'].debug('Count of fetched image comments is 0')
|
|
|
|
|
opts['logger'].debug('Fetching images using another URL')
|
|
|
|
|
url1 = ('https://club.jd.com/discussion/getProductPageImage'
|
|
|
|
|
'CommentList.action?productId=1190881')
|
|
|
|
|
opts['logger'].debug('URL: %s', url1)
|
|
|
|
|
req1 = requests.get(url1, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req1.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200',
|
|
|
|
|
req1.status_code)
|
|
|
|
|
imgdata = req1.json()
|
|
|
|
|
opts['logger'].debug('Image data: %s', imgdata)
|
|
|
|
|
imgurl = imgdata["imgComments"]["imgList"][0]["imageUrl"]
|
|
|
|
|
opts['logger'].debug('Image URL: %s', imgurl)
|
|
|
|
|
|
2022-10-02 07:23:41 +00:00
|
|
|
|
opts['logger'].info(f'\t图片:{imgurl}')
|
2022-10-02 02:46:47 +00:00
|
|
|
|
# 提交晒单
|
|
|
|
|
opts['logger'].debug('Preparing for commenting')
|
|
|
|
|
url2 = "https://club.jd.com/myJdcomments/saveProductComment.action"
|
|
|
|
|
opts['logger'].debug('URL: %s', url2)
|
|
|
|
|
headers['Referer'] = ('https://club.jd.com/myJdcomments/orderVoucher.action')
|
|
|
|
|
headers['Origin'] = 'https://club.jd.com'
|
|
|
|
|
headers['Content-Type'] = 'application/x-www-form-urlencoded'
|
|
|
|
|
opts['logger'].debug('New header for this request: %s', headers)
|
|
|
|
|
data = {
|
|
|
|
|
'orderId': oid,
|
|
|
|
|
'productId': pid,
|
|
|
|
|
'score': str(xing), # 商品几星
|
|
|
|
|
'content': bytes(Str, encoding="gbk"), # 评价内容
|
|
|
|
|
'imgs': imgurl,
|
|
|
|
|
'saveStatus': 2,
|
|
|
|
|
'anonymousFlag': 1
|
|
|
|
|
}
|
|
|
|
|
opts['logger'].debug('Data: %s', data)
|
|
|
|
|
if not opts.get('dry_run'):
|
|
|
|
|
opts['logger'].debug('Sending comment request')
|
|
|
|
|
req_url2 = requests.post(url2, data=data, headers=headers)
|
|
|
|
|
else:
|
|
|
|
|
opts['logger'].debug('Skipped sending comment request in dry run')
|
|
|
|
|
opts['logger'].info('完成')
|
|
|
|
|
opts['logger'].debug('Sleep time (s): %.1f', SUNBW_SLEEP_SEC)
|
|
|
|
|
time.sleep(SUNBW_SLEEP_SEC)
|
|
|
|
|
N['待评价订单'] -= 1
|
|
|
|
|
return N
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# 追评
|
|
|
|
|
def review(N, opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
req_et = []
|
|
|
|
|
Order_data = []
|
|
|
|
|
loop_times = 2
|
|
|
|
|
opts['logger'].debug('Fetching website data')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for i in range(loop_times):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', i + 1, loop_times)
|
|
|
|
|
url = (f"https://club.jd.com/myJdcomments/myJdcomment.action?sort=3"
|
|
|
|
|
f"&page={i + 1}")
|
|
|
|
|
opts['logger'].debug('URL: %s', url)
|
|
|
|
|
req = requests.get(url, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200', req.status_code)
|
|
|
|
|
req_et.append(etree.HTML(req.text))
|
|
|
|
|
opts['logger'].debug('Successfully parsed an XML tree')
|
|
|
|
|
opts['logger'].debug('Fetching data from XML trees')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for idx, i in enumerate(req_et):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Fetching order data in the default XPath')
|
|
|
|
|
elems = i.xpath(
|
|
|
|
|
'//*[@id="main"]/div[2]/div[2]/table/tr[@class="tr-bd"]')
|
|
|
|
|
opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
Order_data.extend(elems)
|
|
|
|
|
if len(Order_data) != N['待追评']:
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Count of fetched order data doesn\'t equal N["待追评"]')
|
|
|
|
|
# NOTE: Need them?
|
|
|
|
|
# opts['logger'].debug('Clear the list Order_data')
|
|
|
|
|
# Order_data = []
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for idx, i in enumerate(req_et):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Fetching order data in another XPath')
|
|
|
|
|
elems = i.xpath(
|
|
|
|
|
'//*[@id="main"]/div[2]/div[2]/table/tbody/tr[@class="tr-bd"]')
|
|
|
|
|
opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
Order_data.extend(elems)
|
|
|
|
|
opts['logger'].info(f"当前共有{N['待追评']}个需要追评。")
|
|
|
|
|
opts['logger'].debug('Commenting on items')
|
|
|
|
|
for i, Order in enumerate(Order_data):
|
2022-10-02 07:23:41 +00:00
|
|
|
|
if i + 1 > 10:
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].info(f'\t已评价10个订单,跳出')
|
|
|
|
|
break
|
|
|
|
|
oname = Order.xpath('td[1]/div/div[2]/div/a/text()')[0]
|
|
|
|
|
_id = Order.xpath('td[3]/div/a/@href')[0]
|
|
|
|
|
opts['logger'].debug('_id: %s', _id)
|
|
|
|
|
url1 = ("https://club.jd.com/afterComments/"
|
|
|
|
|
"saveAfterCommentAndShowOrder.action")
|
|
|
|
|
opts['logger'].debug('URL: %s', url1)
|
|
|
|
|
pid, oid = _id.replace(
|
|
|
|
|
'http://club.jd.com/afterComments/productPublish.action?sku=',
|
|
|
|
|
"").split('&orderId=')
|
|
|
|
|
opts['logger'].debug('pid: %s', pid)
|
|
|
|
|
opts['logger'].debug('oid: %s', oid)
|
|
|
|
|
opts['logger'].info(f'\t开始第{i+1}个订单: {oid}')
|
|
|
|
|
_, context = generation(oname, _type=0, opts=opts)
|
2022-10-02 05:38:20 +00:00
|
|
|
|
opts['logger'].info(f'\t追评内容:{context}')
|
2022-10-02 02:46:47 +00:00
|
|
|
|
data1 = {
|
|
|
|
|
'orderId': oid,
|
|
|
|
|
'productId': pid,
|
|
|
|
|
'content': bytes(context, encoding="gbk"),
|
|
|
|
|
'anonymousFlag': 1,
|
|
|
|
|
'score': 5
|
|
|
|
|
}
|
|
|
|
|
opts['logger'].debug('Data: %s', data1)
|
|
|
|
|
if not opts.get('dry_run'):
|
|
|
|
|
opts['logger'].debug('Sending comment request')
|
|
|
|
|
req_url1 = requests.post(url1, headers=headers, data=data1)
|
|
|
|
|
else:
|
|
|
|
|
opts['logger'].debug('Skipped sending comment request in dry run')
|
|
|
|
|
opts['logger'].info('完成')
|
|
|
|
|
opts['logger'].debug('Sleep time (s): %.1f', REVIEW_SLEEP_SEC)
|
|
|
|
|
time.sleep(REVIEW_SLEEP_SEC)
|
|
|
|
|
N['待追评'] -= 1
|
|
|
|
|
return N
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# 服务评价
|
|
|
|
|
def Service_rating(N, opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
Order_data = []
|
|
|
|
|
req_et = []
|
|
|
|
|
loop_times = 2
|
|
|
|
|
opts['logger'].debug('Fetching website data')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for i in range(loop_times):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', i + 1, loop_times)
|
|
|
|
|
url = (f"https://club.jd.com/myJdcomments/myJdcomment.action?sort=4"
|
|
|
|
|
f"&page={i + 1}")
|
|
|
|
|
opts['logger'].debug('URL: %s', url)
|
|
|
|
|
req = requests.get(url, headers=headers)
|
|
|
|
|
opts['logger'].debug(
|
|
|
|
|
'Successfully accepted the response with status code %d',
|
|
|
|
|
req.status_code)
|
|
|
|
|
if not req.ok:
|
|
|
|
|
opts['logger'].warning(
|
|
|
|
|
'Status code of the response is %d, not 200', req.status_code)
|
|
|
|
|
req_et.append(etree.HTML(req.text))
|
|
|
|
|
opts['logger'].debug('Successfully parsed an XML tree')
|
|
|
|
|
opts['logger'].debug('Fetching data from XML trees')
|
|
|
|
|
opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
for idx, i in enumerate(req_et):
|
|
|
|
|
opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
opts['logger'].debug('Fetching order data in the default XPath')
|
|
|
|
|
elems = i.xpath(
|
|
|
|
|
'//*[@id="main"]/div[2]/div[2]/table/tbody/tr[@class="tr-bd"]')
|
|
|
|
|
opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
Order_data.extend(elems)
|
|
|
|
|
#if len(Order_data) != N['服务评价']:
|
|
|
|
|
# opts['logger'].debug(
|
|
|
|
|
# 'Count of fetched order data doesn\'t equal N["服务评价"]')
|
|
|
|
|
# opts['logger'].debug('Clear the list Order_data')
|
|
|
|
|
# Order_data = []
|
|
|
|
|
# opts['logger'].debug('Total loop times: %d', loop_times)
|
|
|
|
|
# for idx, i in enumerate(req_et):
|
|
|
|
|
# opts['logger'].debug('Loop: %d / %d', idx + 1, loop_times)
|
|
|
|
|
# opts['logger'].debug('Fetching order data in another XPath')
|
|
|
|
|
# elems = i.xpath(
|
|
|
|
|
# '//*[@id="main"]/div[2]/div[2]/table/tr[@class="tr-bd"]')
|
|
|
|
|
# opts['logger'].debug('Count of fetched order data: %d', len(elems))
|
|
|
|
|
# Order_data.extend(elems)
|
|
|
|
|
opts['logger'].info(f"当前共有{N['服务评价']}个需要服务评价。")
|
|
|
|
|
opts['logger'].debug('Commenting on items')
|
|
|
|
|
for i, Order in enumerate(Order_data):
|
2022-10-02 07:23:41 +00:00
|
|
|
|
if i + 1 > 10:
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].info(f'\t已评价10个订单,跳出')
|
|
|
|
|
break
|
|
|
|
|
oname = Order.xpath('td[1]/div[1]/div[2]/div/a/text()')[0]
|
|
|
|
|
oid = Order.xpath('td[4]/div/a[1]/@oid')[0]
|
|
|
|
|
opts['logger'].info(f'\t开始第{i+1}个订单: {oid}')
|
|
|
|
|
opts['logger'].debug('oid: %s', oid)
|
|
|
|
|
url1 = (f'https://club.jd.com/myJdcomments/insertRestSurvey.action'
|
|
|
|
|
f'?voteid=145&ruleid={oid}')
|
|
|
|
|
opts['logger'].debug('URL: %s', url1)
|
|
|
|
|
data1 = {
|
|
|
|
|
'oid': oid,
|
|
|
|
|
'gid': '32',
|
|
|
|
|
'sid': '186194',
|
|
|
|
|
'stid': '0',
|
|
|
|
|
'tags': '',
|
|
|
|
|
'ro591': f'591A{random.randint(4, 5)}', # 商品符合度
|
|
|
|
|
'ro592': f'592A{random.randint(4, 5)}', # 店家服务态度
|
|
|
|
|
'ro593': f'593A{random.randint(4, 5)}', # 快递配送速度
|
|
|
|
|
'ro899': f'899A{random.randint(4, 5)}', # 快递员服务
|
|
|
|
|
'ro900': f'900A{random.randint(4, 5)}' # 快递员服务
|
|
|
|
|
}
|
|
|
|
|
opts['logger'].debug('Data: %s', data1)
|
|
|
|
|
if not opts.get('dry_run'):
|
|
|
|
|
opts['logger'].debug('Sending comment request')
|
|
|
|
|
pj1 = requests.post(url1, headers=headers, data=data1)
|
|
|
|
|
else:
|
|
|
|
|
opts['logger'].debug('Skipped sending comment request in dry run')
|
2022-10-02 07:23:41 +00:00
|
|
|
|
opts['logger'].info("\t " + pj1.text)
|
2022-10-02 02:46:47 +00:00
|
|
|
|
opts['logger'].debug('Sleep time (s): %.1f', SERVICE_RATING_SLEEP_SEC)
|
|
|
|
|
time.sleep(SERVICE_RATING_SLEEP_SEC)
|
|
|
|
|
N['服务评价'] -= 1
|
|
|
|
|
return N
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def No(opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
opts['logger'].info('')
|
|
|
|
|
N = all_evaluate(opts)
|
|
|
|
|
s = '----'.join(['{} {}'.format(i, N[i]) for i in N])
|
|
|
|
|
opts['logger'].info(s)
|
|
|
|
|
opts['logger'].info('')
|
|
|
|
|
return N
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def main(opts=None):
|
|
|
|
|
opts = opts or {}
|
|
|
|
|
opts['logger'].info("开始京东自动评价!")
|
|
|
|
|
N = No(opts)
|
|
|
|
|
opts['logger'].debug('N value after executing No(): %s', N)
|
|
|
|
|
if not N:
|
2022-10-02 05:38:20 +00:00
|
|
|
|
opts['logger'].error('CK错误,请确认是否电脑版CK!')
|
2022-10-02 02:46:47 +00:00
|
|
|
|
exit()
|
|
|
|
|
if N['待评价订单'] != 0:
|
|
|
|
|
opts['logger'].info("1.开始评价晒单")
|
|
|
|
|
N = sunbw(N, opts)
|
|
|
|
|
opts['logger'].debug('N value after executing sunbw(): %s', N)
|
|
|
|
|
N = No(opts)
|
|
|
|
|
opts['logger'].debug('N value after executing No(): %s', N)
|
|
|
|
|
if N['待追评'] != 0:
|
|
|
|
|
opts['logger'].info("2.开始追评!")
|
|
|
|
|
N = review(N, opts)
|
|
|
|
|
opts['logger'].debug('N value after executing review(): %s', N)
|
|
|
|
|
N = No(opts)
|
|
|
|
|
opts['logger'].debug('N value after executing No(): %s', N)
|
|
|
|
|
if N['服务评价'] != 0:
|
|
|
|
|
opts['logger'].info('3.开始服务评价')
|
|
|
|
|
N = Service_rating(N, opts)
|
|
|
|
|
opts['logger'].debug('N value after executing Service_rating(): %s', N)
|
|
|
|
|
N = No(opts)
|
|
|
|
|
opts['logger'].debug('N value after executing No(): %s', N)
|
|
|
|
|
opts['logger'].info("本次运行完成!")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
# parse arguments
|
|
|
|
|
parser = argparse.ArgumentParser()
|
|
|
|
|
parser.add_argument('--dry-run',
|
|
|
|
|
help='have a full run without comment submission',
|
|
|
|
|
action='store_true')
|
|
|
|
|
parser.add_argument('--log-level',
|
|
|
|
|
help='specify logging level (default: info)',
|
|
|
|
|
default='INFO')
|
|
|
|
|
parser.add_argument('-o', '--log-file', help='specify logging file')
|
|
|
|
|
args = parser.parse_args()
|
|
|
|
|
if args.log_level.upper() not in [
|
|
|
|
|
'DEBUG', 'WARN', 'INFO', 'ERROR', 'FATAL'
|
|
|
|
|
# NOTE: `WARN` is an alias of `WARNING`. `FATAL` is an alias of
|
|
|
|
|
# `CRITICAL`. Using these aliases is for developers' and users'
|
|
|
|
|
# convenience.
|
|
|
|
|
# NOTE: Now there is no logging on `CRITICAL` level.
|
|
|
|
|
]:
|
|
|
|
|
args.log_level = 'INFO'
|
|
|
|
|
else:
|
|
|
|
|
args.log_level = args.log_level.upper()
|
|
|
|
|
opts = {
|
|
|
|
|
'dry_run': args.dry_run,
|
|
|
|
|
'log_level': args.log_level
|
|
|
|
|
}
|
|
|
|
|
if hasattr(args, 'log_file'):
|
|
|
|
|
opts['log_file'] = args.log_file
|
|
|
|
|
else:
|
|
|
|
|
opts['log_file'] = None
|
|
|
|
|
|
|
|
|
|
# logging on console
|
|
|
|
|
_logging_level = getattr(logging, opts['log_level'])
|
|
|
|
|
logger = logging.getLogger('comment')
|
|
|
|
|
logger.setLevel(level=_logging_level)
|
|
|
|
|
# NOTE: `%(levelname)s` will be parsed as the original name (`FATAL` ->
|
|
|
|
|
# `CRITICAL`, `WARN` -> `WARNING`).
|
|
|
|
|
# NOTE: The alignment number should set to 19 considering the style
|
|
|
|
|
# controling characters. When it comes to file logger, the number should
|
|
|
|
|
# set to 8.
|
2022-10-02 05:38:20 +00:00
|
|
|
|
formatter = StyleFormatter('%(asctime)s %(levelname)-19s %(message)s',"%F %T")
|
2022-10-02 02:46:47 +00:00
|
|
|
|
rawformatter = StyleFormatter('%(asctime)s %(levelname)-8s %(message)s', use_style=False)
|
|
|
|
|
console = logging.StreamHandler()
|
|
|
|
|
console.setLevel(_logging_level)
|
2022-10-02 05:38:20 +00:00
|
|
|
|
console.setFormatter(logging.Formatter('%(message)s'))
|
2022-10-02 02:46:47 +00:00
|
|
|
|
logger.addHandler(console)
|
|
|
|
|
opts['logger'] = logger
|
|
|
|
|
# It's a hack!!!
|
|
|
|
|
jieba.default_logger = logging.getLogger('jieba')
|
|
|
|
|
jieba.default_logger.setLevel(level=_logging_level)
|
|
|
|
|
jieba.default_logger.addHandler(console)
|
|
|
|
|
# It's another hack!!!
|
|
|
|
|
jdspider.default_logger = logging.getLogger('spider')
|
|
|
|
|
jdspider.default_logger.setLevel(level=_logging_level)
|
|
|
|
|
jdspider.default_logger.addHandler(console)
|
|
|
|
|
|
|
|
|
|
logger.debug('Successfully set up console logger')
|
|
|
|
|
logger.debug('CLI arguments: %s', args)
|
|
|
|
|
logger.debug('Opening the log file')
|
|
|
|
|
if opts['log_file']:
|
|
|
|
|
try:
|
|
|
|
|
handler = logging.FileHandler(opts['log_file'])
|
|
|
|
|
except Exception as e:
|
|
|
|
|
logger.error('Failed to open the file handler')
|
|
|
|
|
logger.error('Error message: %s', e)
|
|
|
|
|
sys.exit(1)
|
|
|
|
|
handler.setLevel(_logging_level)
|
|
|
|
|
handler.setFormatter(rawformatter)
|
|
|
|
|
logger.addHandler(handler)
|
|
|
|
|
jieba.default_logger.addHandler(handler)
|
|
|
|
|
jdspider.default_logger.addHandler(handler)
|
|
|
|
|
logger.debug('Successfully set up file logger')
|
|
|
|
|
logger.debug('Options passed to functions: %s', opts)
|
|
|
|
|
logger.debug('Builtin constants:')
|
|
|
|
|
logger.debug(' CONFIG_PATH: %s', CONFIG_PATH)
|
|
|
|
|
logger.debug(' USER_CONFIG_PATH: %s', USER_CONFIG_PATH)
|
|
|
|
|
logger.debug(' ORDINARY_SLEEP_SEC: %s', ORDINARY_SLEEP_SEC)
|
|
|
|
|
logger.debug(' SUNBW_SLEEP_SEC: %s', SUNBW_SLEEP_SEC)
|
|
|
|
|
logger.debug(' REVIEW_SLEEP_SEC: %s', REVIEW_SLEEP_SEC)
|
|
|
|
|
logger.debug(' SERVICE_RATING_SLEEP_SEC: %s', SERVICE_RATING_SLEEP_SEC)
|
|
|
|
|
|
|
|
|
|
# parse configurations
|
2022-10-02 05:38:20 +00:00
|
|
|
|
#logger.debug('Reading the configuration file')
|
|
|
|
|
#if os.path.exists(USER_CONFIG_PATH):
|
|
|
|
|
#logger.debug('User configuration file exists')
|
|
|
|
|
#_cfg_path = USER_CONFIG_PATH
|
|
|
|
|
#else:
|
|
|
|
|
#logger.debug('User configuration file doesn\'t exist, fallback to the default one')
|
|
|
|
|
#_cfg_path = CONFIG_PATH
|
|
|
|
|
# with open(_cfg_path, 'r', encoding='utf-8') as f:
|
|
|
|
|
#cfg = yaml.safe_load(f)
|
|
|
|
|
#print()
|
|
|
|
|
#logger.debug('Closed the configuration file')
|
|
|
|
|
#logger.debug('Configurations in Python-dict format: %s', cfg)
|
|
|
|
|
if "PC_COOKIE" in os.environ:
|
|
|
|
|
if len(os.environ["PC_COOKIE"]) > 1:
|
|
|
|
|
ck = os.environ["PC_COOKIE"]
|
2022-10-02 07:23:41 +00:00
|
|
|
|
logger.info ("已获取环境变量 CK")
|
2022-10-02 12:03:52 +00:00
|
|
|
|
else:
|
|
|
|
|
logger.info("没有设置变量PC_COOKIE,请添加电脑端CK到环境变量")
|
|
|
|
|
sys.exit(1)
|
2022-10-02 02:46:47 +00:00
|
|
|
|
headers = {
|
|
|
|
|
'cookie': ck.encode("utf-8"),
|
|
|
|
|
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.82 Safari/537.36',
|
|
|
|
|
'Connection': 'keep-alive',
|
|
|
|
|
'Cache-Control': 'max-age=0',
|
|
|
|
|
'sec-ch-ua': '" Not A;Brand";v="99", "Chromium";v="98", "Google Chrome";v="98"',
|
|
|
|
|
'sec-ch-ua-mobile': '?0',
|
|
|
|
|
'sec-ch-ua-platform': '"Windows"',
|
|
|
|
|
'DNT': '1',
|
|
|
|
|
'Upgrade-Insecure-Requests': '1',
|
|
|
|
|
'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,image/apng,*/*;q=0.8,application/signed-exchange;v=b3;q=0.9',
|
|
|
|
|
'Sec-Fetch-Site': 'same-site',
|
|
|
|
|
'Sec-Fetch-Mode': 'navigate',
|
|
|
|
|
'Sec-Fetch-User': '?1',
|
|
|
|
|
'Sec-Fetch-Dest': 'document',
|
|
|
|
|
'Referer': 'https://order.jd.com/',
|
|
|
|
|
'Accept-Encoding': 'gzip, deflate, br',
|
|
|
|
|
'Accept-Language': 'zh-CN,zh;q=0.9',
|
|
|
|
|
}
|
|
|
|
|
logger.debug('Builtin HTTP request header: %s', headers)
|
|
|
|
|
|
|
|
|
|
logger.debug('Starting main processes')
|
|
|
|
|
try:
|
|
|
|
|
main(opts)
|
|
|
|
|
# NOTE: It needs 3,000 times to raise this exception. Do you really want to
|
|
|
|
|
# do like this?
|
|
|
|
|
except RecursionError:
|
|
|
|
|
logger.error("多次出现未完成情况,程序自动退出")
|