add

answer2.txt

+想有同款
+同求
+超羡慕
+时尚时尚最时尚
+不盘不行
+买买买！
+我有，等等发给你
+写的真的好棒呢
+小手已经动起来了
+想学都学不会
+心情好才是真的好
+我也是~
+小心楼主飘起来了
+买买买！
+希望博主越来越好
+我也关注啦
+楼主，写了好几篇有用的内容呢
+装进购物车吧
+对大家都有帮助
+还想看到更多，嘻嘻
+心动不如行动
+安排上了
+必须整一个
+我也超爱这个色系
+可爱的要命
+我也是
+实不相瞒，我也是
+没事，它还会回来的
+我觉得看看就够了
+看的有些心塞
+你值得拥有
+总能看到你
+送你上去
+WINK~ 
+优秀
+怎么啦？
+一起冲
+做梦都想变成这样的人
+稳住
+冲鸭！
+比纯净水还纯
+那你现在应该就挺满意的吧哈哈
+换成小姐姐么哈哈哈
+就这么简单吗
+我们都会在的
+也是我喜欢的
+土掉渣的情话么？
+捞你上去
+我要给小姐姐大心心哈哈
+那你想让小姐姐说啥
+不许叫我的小姐姐宝贝
+确实好看
+我见过你！！
+真是花式夸奖
+根本不用忍
+棒棒的
+赞同
+爱的不行
+自恋的感觉吗
+真的挺好看的
+我也这么觉得
+一直好看好不好
+必须的
+你自己数数
+选我选我选我
+词穷了都
+还有我还有我！！
+真会玩
+差的可能是颜值
+想学哈哈哈
+不，钻石粉
+我也喜欢
+日常夸赞是么哈哈
+就这个feel
+送你上去
+额滴个亲娘啊，这也太可爱了吧！同问这是哪个小仙女
+哪个最喜欢
+但是就是很喜欢是不是哈哈
+酷！
+滴!沙瓦迪卡
+我也期待
+我说好有用么
+这么直接的吗
+很喜欢小姐姐的内容
+没道理的赞同你
+支持支持
+我们和小姐姐差的就是颜值
+这条街最靓的
+期待你的第二次
+哈哈哈哈，催更+1
+小姐姐要多发发帖子呀
+小姐姐的帖子都超棒
+认认真真的听着
+也是我的小可爱
+我也学习了
+实不相瞒，我也喜欢
+很有品位哦 要继续喜欢我的小姐姐
+美坏了应该
+喜欢这一类的分享
+楼上就是彩虹屁本屁了
+啧啧啧，甜度满分
+我也想遇到小姐姐
+我也可！！！
+一直在+1
+我不管，我也想了
+毕竟是我爱的宝藏女孩
+想想就行╭(╯^╰)╮
+放进榜单！
+来晚了，想插队
+下次你一定会前排的
+时光老了也不散
+比心队形！
+你是住在like吗，这都被你等到了！
+是谁，跟我一样发现小可爱更新了！
+才没有，她是大家的宝藏
+看吼吼，plmm太棒了！
+翻我！翻我！
+淡定淡定，小姐姐的日常操作
+同意
+唉呀妈呀，贼稀罕
+我也好喜欢这一类的诶
+终于等到更新啦
+同等ing
+一起向前冲鸭
+棒当然是天生的
+什么小东西，人家是小可爱
+醒醒，你刷到了，别怀疑自己
+冯巩附体？
+哪哪都有你，到处跟plmm恋爱！
+比一点点还多一点点！
+me too
+木有感情的第一名
+看见你我也很开心
+双击666嘛
+记好这是第几次迟到了
+永远不会晚
+前面的姐妹一起哭
+我永远喜欢她.jpg
+哈哈，我Gucci的时候，眼泪也Prada的掉
+她肯定没忘记我萌♪(^∇^*)
+首先，你得跟我一样优秀
+辛亏没放弃
+小姐姐文笔还是蛮好的
+小粉丝+1
+这不是来了嘛
+来来来，给你让开了
+小姐姐经常又在发呀
+土味肉麻
+你好夸张啊
+我就看看不说话
+咋分享
+还能更直白么
+你还可以更疯狂
+酷！
+真的假的
+小姐姐经常发帖的呀
+惊到了嘛？
+小姐姐就是神仙本仙哈哈
+下班快乐
+me2
+OMG 这是在公开告白么
+666。。。
+意外的点在于…?
+小姐姐估计没戏，我勉强回复你一下吧
+小桃心好可爱
+土味情话？
+一起做更好的自己
+想我想到黑夜白天？
+那我给你当前排
+这是在找存在感么
+凑热闹
+这就有人告白了？
+你还能更快么
+同喜欢
+➕1
+试完了等你的帖子
+来来来，我来回复你
+你可以给小姐姐一个小红心
+给小姐姐笔芯
+想一同承包哈哈
+棒呆
+早早早
+没有最棒，只有更棒
+奖励你一个赞
+充实每一天
+我就看看小姐姐会不会给你翻牌
+你真会说话
+咦，小姐姐才不是你的宝贝
+你也太会夸人了
+小姐姐还有别的帖子也不错
+借着你的楼上去哈哈
+这个小姐姐之前的文章也超棒
+我也很喜欢
+你不想被赞到明年吗
+肯定啊
+等着你的分享
+这个可以收藏么
+小姐姐一般不回复
+这个有难度么？
+咋保存？
+可以确定了，确实有这么好看的
+你想得美
+围观+1
+占坑+1
+借楼留名
+挤挤
+瓜子汽水小板凳要哇
+带我一个
+我也是
+但是还是点进来了哈哈
+是的！
+我也在问我自己这个问题
+贵么
+有钱有钱
+这么速度
+这个能找到嘛？
+拿起我的小本本
+喜欢
+棒棒哒
+哈哈哈哈，真有意思
+我觉得也适合我
+羡慕，我也想找个适合我的
+真好
+哈哈哈哈哈哈希望是真的
+好帖，保存了
+一个够嘛
+重要的话说三遍是么哈哈
+不要抢我的小姐姐
+是哦
+必须的必
+我也来打call
+用给你递个电话么
+带上我
+为小姐姐心动过很多次了
+心动ing
+怎么试？教教我
+蛮有用的
+同码
+我也很喜欢呢
+同码！
+找到告诉我
+一起学习，天天向上
+cool~
+我也是呢
+我也是哈哈哈
+谁不是呢
+我希望有花不完的钱
+哈哈哈我也是
+同被吸引到了
+同被诱惑到了
+get+1
+怎么加？
+完美！
+是呢
+我同意
+好看哦
+酷的一匹
+超绝
+你好，我是小姐姐后援会会长哈哈
+我也是！
+我也没想到
+小姐姐的帖子都挺不错的
+蛮实用的
+下回我也试试
+感谢帖主呢
+我也可以！
+我不信~
+是的都好好看
+太逆生长了叭
+我也觉得是呢
+我也喜欢
+看到志同道合的胖友了
+可惜学不会~
+那当然了
+真的是被小姐姐的点戳中了
+喜欢的嘞
+找到了另一个小迷妹
+哈哈，我也是
+都很有用呢
+不要抢我的小姐姐
+带上我
+喜欢这种风格
+可以+1
+喜欢
+爱了爱了
+说的是呢
+这个小姐姐很厉害的
+真的好
+差的不是角度是颜值
+很实用呢
+小粉丝路过
+➕1
+棒呆
+真是种不完的草
+这个好可爱
+笔芯
+加上我
+相当可以
+大心心哈哈哈哈
+biubiubiu
+加个我的
+带上我
+get了
+赶紧拉起粉丝群哈哈
+同问
+同求
+哈哈哈 你这是一条语音评论么
+有链接嘛？
+说的是呢
+我也是
+get了
+码住
+你不是一个人，小姐姐分享的我也很喜欢呢
+√
+学起来
+哈哈我也是
+我也是
+喜欢呢
+喜欢
+是的了
+真的是！
+写的好棒
+加个“！”
+真的秀
+还是小姐姐写的好吧
+秀出新高度
+get.
+超爱
+赞同
+哈哈我也是
+码住
+腻害
+真的厉害
+同想试试
+我也这么想
+真可以试试
+米兔
+我这次就要试一试
+我好喜欢
+最喜欢干货了
+嗯嗯 我也是
+是的是的！
+哈哈哈是无敌了
+是的是的！
+好玩
+我也是超喜欢
+夸爆
+炒鸡棒
+心动到不行
+安排上了
+棒棒棒
+666
+感谢帖主
+是的！我都不知道在这里吃了多少安利了
+没能逃过被种草
+辛苦帖主
+喜欢呢
+我也是
+谢谢帖主
+感谢帖主
+也适合我，谢谢帖主
+是的哦 感谢楼主
+是的喂
+哈哈哈一样一样
+可以可以相当可以
+超棒的帖子
+棒棒的帖子
+也是我喜欢的
+我也喜欢这个帖子哈哈
+我也爱了
+哈哈哈哈哈我也是
+已经打开了某宝
+干货
+我也超爱
+赞赞赞
+666
+我也终于看到适合我的了
+wow！
+没错，是她是她就是她
+谁不是呢
+哈哈哈哈哈哈我也是
+吃土少女的自虐哈哈哈哈哈
+我也是 好喜欢啊
+我也是！终于！
+必须的！
+感觉蛮有用的
+你闺蜜：我不吃。哈哈哈哈哈
+呼呼，我已经是第二次被种草了
+激动！我也是
+我也要安利给我朋友
+哈哈哈哈哈好巧，我也在安利
+我也是！激动
+我也爱！
+我也在问自己这个问题
+我也是呢！超级喜欢
+因为要花钱了哈哈
+我也超级喜欢
+➕1
+我也是我也是
+我也是！真不容易
+哈哈哈我也是！
+我也炒鸡喜欢 get！
+也戳中我了
+wow
+要去安利我的姐妹
+立刻去分享给姐妹
+同求
+这个滤镜真好看
+小姐姐太棒了
+➕1我也想要
+仙女➕1
+谁不想要呢
+瓜子准备啦
+同意
+我缺的是摄影师吗。我缺的是颜值
+也太棒了吧
+我也想收藏!
+是啊，我也这种感觉
+是的呢，我最喜欢的博主
+点赞
+我最喜欢第二张
+喜欢
+我先！
+好像专业摄影师拍的诶
+姐妹，我也能拍
+码住哦
+okok
+d=====(￣▽￣*)b厉害
+我也想要连接
+我要多学习
+小姐姐是我的！
+同期待
+hhhh
+长得美就行
+想换头
+前排瓜子准备好了
+美就一个字
+那我就不一样了。我特别喜欢
+搓手期待
+biubiubiu
+举手报名，我也想和小姐姐当朋友
+前排先赞一个
+这个滤镜可真好看
+天气可真好啊
+你是调查户口的吗
+2333333
+我喜欢图2
+我家小姐姐最棒
+我也是我也是
+想知道怎么拍的
+我也觉得，一定是男朋友拍的
+这是哪里呀
+我是你的粉头
+火前留名
+赞一个赞一个
+同感同感
+吃下这枚安利喽
+赞一个
+感觉是专业的相机诶
+我先来承包
+哼。我先来的
+我喜欢封面！
+嘿嘿，是可爱的小姐姐没错了
+你也可以的
+前排留名
+小声bb）我也想
+我也是！不许跟我抢
+嗷嗷嗷我也觉得
+同求
+我也喜欢!
+你走开，小姐姐是我的
+爱辽
+我也想用。。。
+是我的小姐姐
+嗷嗷，你不喜欢我了吗
+太可爱喽，我喜欢的颜值类型
+我也想横着走！
+好甜啊
+你怎么也这么可爱啊
+点头同意
+美丽
+哼。我先来的
+拍照新姿势！
+我最喜欢封面
+手残党，学不会
+哇塞小姐姐好好看，爱了爱了
+求教程
+➕11111
+求连接呀
+直接被种草了
+感觉很有用
+好可爱
+同感
+种草了哦
+咱俩这么多同款吗
+可以看看我家的产品哦
+行走的种草机
+是的呢
+新技能get！

answer_reply.py

+import pymysql
+import traceback
+import logging
+import json
+from log_settings import *
+from auto_request import login, reply, get_comment, time_conv, get_answer_data, reply_answer, set_reply_to_redis
+from auto_request import host, user, db, passwd
+
+
+def get_data(numtime, numtime2):
+    try:
+        pc = pymysql.connect(host=host, user=user, passwd=passwd, db=db, port=3306)
+        cursor = pc.cursor()
+        cursor.execute(
+            "SELECT  user_id,id FROM topic WHERE is_online=1  and (create_time > '%s' and create_time < '%s' )" % (
+                numtime, numtime2))
+        data = cursor.fetchall()
+        topic_id = list(data)
+        topic_id_list = []
+        try:
+            for i in topic_id and topic_id:
+                cursor.execute(
+                    "select user_id from user_extra where user_id =" + str(i[0]) + " and is_shadow =0")
+                data = cursor.fetchall()
+                user_id = list(data)
+                print(user_id)
+                if user_id:
+                    topic_id_list.append(i)
+            logging.info("Database version : %s " % topic_id_list)
+            pc.close()
+
+        except:
+            logging.error("catch exception,get_data:%s" % traceback.format_exc())
+
+        return topic_id_list
+
+    except:
+        logging.error("catch exception,get_data:%s" % traceback.format_exc())
+        return []
+
+
+if __name__ == "__main__":
+
+    try:
+        logging.info("comment  answer one")
+        numtime1, numtime2 = time_conv(5, 0)
+        user_id = get_data(numtime1, numtime2)
+        redis_key1 = "cybertron:set_reply_id:five1"
+        redis_key2 = "cybertron:set_reply_id:five2"
+        reply_data_comment = []
+        if user_id:
+            for i in user_id:
+                cook = login()
+                comment1, comment2 = get_answer_data()
+                if cook is not None:
+                    response = reply_answer(cook, i[1], comment1)
+                    if len(response) > 1:
+                        data_dict = json.loads(response)
+                        reply_id = data_dict["data"]["id"]
+                        reply_user_id = data_dict["data"]["id"]["user"]["id"]
+                        reply_data_comment.append(
+                            {"id": reply_id, "reply_user_id": reply_user_id, "answer": comment2, "topic_id": i[1]})
+
+        redis_client = set_reply_to_redis()
+
+        have_reply = redis_client.get(redis_key1)
+        if have_reply:
+            redis_client.set(redis_key2, reply_data_comment)
+        else:
+            redis_client.set(redis_key1, reply_data_comment)
+
+    except:
+        logging.error("catch exception,main:%s" % traceback.format_exc())

auto_request.py

@@ -6,6 +6,7 @@ import traceback
 import logging
 import log_settings
 import json
+import redis
 import smtplib
 from email.mime.text import MIMEText
 from email.utils import formataddr
@@ -30,8 +31,8 @@ my_user6 = "lixiaofang@igengmei.com"
 #         'ENGINE': 'django.db.backends.mysql',
 #         'NAME': 'alpha',
 #         'USER': 'work',
-#         'PASSWORD': 'Gengmei123',
-#         'HOST': 'rm-2zeaut61u9sm21m0b.mysql.rds.aliyuncs.com',
+#         'PASSWORD': 'Gengmei123!',
+#         'HOST': '172.21.36.16',
 #         'PORT': '3306',
 #         'OPTIONS': {
 #             "init_command": "SET foreign_key_checks = 0;",
@@ -40,6 +41,7 @@ my_user6 = "lixiaofang@igengmei.com"
 #     }
 # }
 
+
 DATABASES = {
     'default': {
         'ENGINE': 'django.db.backends.mysql',
@@ -348,3 +350,82 @@ def get_error(line):
                 pass
     except:
         logging.error("catch exception,err_msg:%s" % traceback.format_exc())
+
+
+def get_answer_data():
+    try:
+
+        # 获取第一条评论
+        data = open("answer1.txt", "r")
+
+        answer_data1 = []
+        for i in data:
+            answer_data1.append(i)
+        num1 = random.randint(0, len(answer_data1))
+
+        comment1 = answer_data1[num1 - 1]
+
+        # 获取第二条评论
+        data = open("answer2.txt", "r")
+
+        answer_data2 = []
+        for i in data:
+            answer_data2.append(i)
+        comment2 = answer_data2[num1 - 1]
+
+        return comment1, comment2
+
+    except:
+
+        return ["", ""]
+
+
+def reply_answer(cookies_get, id, content):
+    try:
+        post_dict = {
+            'topic_id': id,
+            'content': content,
+            "type": 4
+        }
+        response = requests.post(url=auto_reply_url,
+                                 cookies=cookies_get,
+                                 data=post_dict)
+
+        logging.info("response.text:%s" % response.text)
+        get_error(response.text)
+
+        return response.text
+    except:
+
+        logging.error("catch exception,logins:%s" % traceback.format_exc())
+
+
+
+
+def set_reply_to_redis():
+    try:
+        redis_url = 'redis://127.0.0.1:6379/1'
+        redis_client = redis.StrictRedis.from_url(redis_url)
+
+        return redis_client
+    except:
+        logging.error("catch exception,logins:%s" % traceback.format_exc())
+
+
+def reply2(cookies_get, id, content,replied_id):
+    try:
+        post_dict = {
+            'topic_id': id,
+            'content': content,
+            "type": 4,
+            "replied_id":replied_id
+        }
+        response = requests.post(url=auto_reply_url,
+                                 cookies=cookies_get,
+                                 data=post_dict)
+
+        logging.info("response.text:%s" % response.text)
+        get_error(response.text)
+    except:
+
+        logging.error("catch exception,logins:%s" % traceback.format_exc())

reply_comment1.py

+import traceback
+import redis
+import logging
+import json
+from auto_request import set_reply_to_redis, reply2, login
+
+if __name__ == "__main__":
+
+    try:
+        redis_key1 = "cybertron:set_reply_id:five1"
+        redis_key2 = "cybertron:set_reply_id:five2"
+
+        redis_client = set_reply_to_redis()
+
+        have_reply1 = redis_client.get(redis_key1)
+        if have_reply1:
+            result = json.loads(str(have_reply1, encoding="utf-8"))
+            for item in result:
+                cook = login()
+                reply2(cook, item["topic_id"], item["answer"], item["id"])
+        else:
+            have_reply2 = redis_client.get(redis_key2)
+            result = json.loads(str(have_reply2, encoding="utf-8"))
+            for item in result:
+                cook = login()
+                reply2(cook, item["topic_id"], item["answer"], item["id"])
+
+
+    except:
+        logging.error("catch exception,main:%s" % traceback.format_exc())