Add files via upload

Author: Dimlitter

auto_comment_plus.py

@@ -0,0 +1,292 @@
+# -*- coding: utf-8 -*-
+# @Time : 2022/2/8 20:50
+# @Author : @qiu-lzsnmb and @Dimlitter
+# @File : auto_comment_plus.py
+
+import random
+import time
+import jieba.analyse
+import requests
+from lxml import etree
+import jdspider
+
+jieba.setLogLevel(jieba.logging.INFO)
+"""
+ck填到下面就好，只支持网页版的Ck
+以下为最短格式
+"""
+ck = ''
+
+headers = {
+    'cookie': ck,
+    'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/96.0.4664.93 Safari/537.36',
+}
+
+
+# 评价生成
+def generation(pname, _class=0, _type=1):
+    list = ['商品名']
+    list.clear()
+    list.append(pname)
+    for item in list:
+        spider = jdspider.JDSpider(item)
+        result = spider.getData(3, 3) #这里可以自己改
+
+    # 0是追评 1是评价
+    # class 0是评价 1是提取id
+    try:
+        name = jieba.analyse.textrank(pname, topK=5, allowPOS='n')[0]
+    except:
+        name = "宝贝"
+    if _class == 1:
+        return name
+    else:
+        datas = {
+            1: {
+                "开始": result,
+                "中间": result, #重复的几率不大，相信我（
+                "结束": result
+            },
+            0: {
+                "开始": result,
+                "中间": result,
+                "结束": result
+            }
+        }
+        if _type == 1:
+            comments = datas[_type]
+            return random.randint(3, 5), (
+                    random.choice(comments["开始"]) + random.choice(comments["中间"]) + random.choice(comments["结束"])).replace(
+                "$", name)
+        elif _type == 0:
+            comments = datas[_type]
+            return (
+                    random.choice(comments["开始"]) + random.choice(comments["中间"]) + random.choice(comments["结束"])).replace(
+                "$", name)
+
+
+# 查询全部评价
+def all_evaluate():
+    N = {}
+    url = 'https://club.jd.com/myJdcomments/myJdcomment.action?'
+    req = requests.get(url, headers=headers)
+    req_et = etree.HTML(req.text)
+    evaluate_data = req_et.xpath('//*[@id="main"]/div[2]/div[1]/div/ul/li')
+    # print(evaluate)
+    for i, ev in enumerate(evaluate_data):
+        na = ev.xpath('a/text()')[0]
+        try:
+            num = ev.xpath('b/text()')[0]
+        except IndexError:
+            num = 0
+        N[na] = int(num)
+    return N
+
+
+# 普通评价
+def ordinary(N):
+    Order_data = []
+    req_et = []
+    for i in range((N['待评价订单'] // 20) + 1):
+        url = f'https://club.jd.com/myJdcomments/myJdcomment.action?sort=0&page={i + 1}'
+        req = requests.get(url, headers=headers)
+        req_et.append(etree.HTML(req.text))
+    for i in req_et:
+        Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table/tbody'))
+    if len(Order_data) != N['待评价订单']:
+        Order_data = []
+        for i in req_et:
+            Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table'))
+
+    print(f"当前共有{N['待评价订单']}个评价。")
+    for i, Order in enumerate(Order_data):
+        oid = Order.xpath('tr[@class="tr-th"]/td/span[3]/a/text()')[0]
+        oname_data = Order.xpath('tr[@class="tr-bd"]/td[1]/div[1]/div[2]/div/a/text()')
+        pid_data = Order.xpath('tr[@class="tr-bd"]/td[1]/div[1]/div[2]/div/a/@href')
+        for oname, pid in zip(oname_data, pid_data):
+            pid = pid.replace('//item.jd.com/', '').replace('.html', '')
+
+            print(f"\t{i}.开始评价订单\t{oname}[{oid}]")
+            url2 = f"https://club.jd.com/myJdcomments/saveProductComment.action"
+            xing,Str = generation(oname)
+            xing = 5 #写死五星
+            print(f'\t\t评价内容,星级{xing}：', Str)
+            data2 = {
+                'orderId': oid,
+                'productId': pid,  # 商品id
+                'score': str(xing),  # 商品几星
+                'content': bytes(Str, encoding="gbk"),  # 评价内容
+                'saveStatus': '1',
+                'anonymousFlag': '1'
+            }
+            pj2 = requests.post(url2, headers=headers, data=data2)
+            time.sleep(20)
+    N['待评价订单'] -= 1
+    return N
+
+
+# 晒单评价
+def sunbw(N):
+    Order_data = []
+    for i in range((N['待晒单'] // 20) + 1):
+        url = f"https://club.jd.com/myJdcomments/myJdcomment.action?sort=1&page={i + 1}"
+        req = requests.get(url, headers=headers)
+        req_et = etree.HTML(req.text)
+        Order_data.extend(req_et.xpath('//*[@id="evalu01"]/div[2]/div[1]/div[@class="comt-plist"]/div[1]'))
+    print(f"当前共有{N['待晒单']}个需要晒单。")
+    for i, Order in enumerate(Order_data):
+        oname = Order.xpath('ul/li[1]/div/div[2]/div[1]/a/text()')[0]
+        pid = Order.xpath('@pid')[0]
+        oid = Order.xpath('@oid')[0]
+
+        print(f'\t开始晒单{i},{oname}')
+        # 获取图片
+        pname = generation(pname=oname, _class=1)
+        url1 = f"https://club.jd.com/discussion/getProductPageImageCommentList.action?productId={pid}"
+        imgdata = requests.get(url1, headers=headers).json()
+        if imgdata["imgComments"]["imgCommentCount"] == 0:
+            url1 = "https://club.jd.com/discussion/getProductPageImageCommentList.action?productId=1190881"
+            imgdata = requests.get(url1, headers=headers).json()
+        imgurl = imgdata["imgComments"]["imgList"][0]["imageUrl"]
+
+        #
+        print(f'\t\t图片url={imgurl}')
+        url2 = "https://club.jd.com/myJdcomments/saveShowOrder.action"  # 提交晒单
+        headers['Referer'] = 'https://club.jd.com/myJdcomments/myJdcomment.action?sort=1'
+        headers['Origin'] = 'https://club.jd.com'
+        headers['Content-Type'] = 'application/x-www-form-urlencoded'
+        data = {
+            'orderId': oid,
+            'productId': pid,
+            'imgs': imgurl,
+            'saveStatus': 3
+        }
+        req_url2 = requests.post(url2, data={
+            'orderId': oid,
+            'productId': pid,
+            'imgs': imgurl,
+            'saveStatus': 3
+        }, headers=headers)
+        print('完成')
+        time.sleep(50)
+        N['待晒单'] -= 1
+    return N
+
+
+# 追评
+def review(N):
+    req_et = []
+    Order_data = []
+    for i in range((N['待追评'] // 20) + 1):
+        url = f"https://club.jd.com/myJdcomments/myJdcomment.action?sort=3&page={i + 1}"
+        req = requests.get(url, headers=headers)
+        req_et.append(etree.HTML(req.text))
+    for i in req_et:
+        Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table/tr[@class="tr-bd"]'))
+    if len(Order_data) != N['待追评']:
+        for i in req_et:
+            Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table/tbody/tr[@class="tr-bd"]'))
+    print(f"当前共有{N['待追评']}个需要追评。")
+    for i, Order in enumerate(Order_data):
+        oname = Order.xpath('td[1]/div/div[2]/div/a/text()')[0]
+        _id = Order.xpath('td[3]/div/a/@href')[0]
+        print(f'\t开始第{i}，{oname}')
+        url1 = "https://club.jd.com/afterComments/saveAfterCommentAndShowOrder.action"
+        pid, oid = _id.replace('http://club.jd.com/afterComments/productPublish.action?sku=', "").split('&orderId=')
+        context = generation(oname, _type=0)
+        print(f'\t\t追评内容：{context}')
+        req_url1 = requests.post(url1, headers=headers, data={
+            'orderId': oid,
+            'productId': pid,
+            'content': bytes(context, encoding="gbk"),
+            'anonymousFlag': 1,
+            'score': 5
+        })
+        print('完成')
+        time.sleep(30)
+        N['待追评'] -= 1
+    return N
+
+
+# 服务评价
+def Service_rating(N):
+    Order_data = []
+    req_et = []
+    for i in range((N['服务评价'] // 20) + 1):
+        url = f"https://club.jd.com/myJdcomments/myJdcomment.action?sort=4&page={i + 1}"
+        req = requests.get(url, headers=headers)
+        req_et.append(etree.HTML(req.text))
+    for i in req_et:
+        Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table/tbody/tr[@class="tr-bd"]'))
+    if len(Order_data) != N['服务评价']:
+        Order_data = []
+        for i in req_et:
+            Order_data.extend(i.xpath('//*[@id="main"]/div[2]/div[2]/table/tr[@class="tr-bd"]'))
+    print(f"当前共有{N['服务评价']}个需要服务评价。")
+    for i, Order in enumerate(Order_data):
+        oname = Order.xpath('td[1]/div[1]/div[2]/div/a/text()')[0]
+        oid = Order.xpath('td[4]/div/a[1]/@oid')[0]
+        print(f'\t开始第{i}，{oname}')
+        url1 = f'https://club.jd.com/myJdcomments/insertRestSurvey.action?voteid=145&ruleid={oid}'
+        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)}'  # 快递员服务
+        }
+        pj1 = requests.post(url1, headers=headers, data=data1)
+        print("\t\t", pj1.text)
+        time.sleep(25)
+        N['服务评价'] -= 1
+    return N
+
+
+def No():
+    print()
+    N = all_evaluate()
+    for i in N:
+        print(i, N[i], end="----")
+    print()
+    return N
+
+
+def main():
+    print("开始京东批量评价！")
+    N = No()
+    if not N:
+        print('Ck出现错误，请重新抓取！')
+        exit()
+    if N['待评价订单'] != 0:
+        print("1.开始普通评价")
+        N = ordinary(N)
+        N = No()
+    if N['待晒单'] != 0:
+        print("2.开始晒单评价")
+        N = sunbw(N)
+        N = No()
+    if N['待追评'] != 0:
+        print("3.开始批量追评！")
+        N = review(N)
+        N = No()
+    if N['服务评价'] != 0:
+        print('4.开始服务评价')
+        N = Service_rating(N)
+        N = No()
+    print("全部完成啦！")
+    for i in N:
+        if N[i] != 0:
+            print("出现了二次错误，跳过了部分，重新尝试")
+            main()
+
+
+if __name__ == '__main__':
+    try:
+        main()
+    except RecursionError:
+        print("多次出现未完成情况，程序自动退出")