add update keyword

ReadMe.md

@@ -18,4 +18,7 @@
 * /wxpy/acceptmsg
   * 500：校验失败
   * 501：模糊搜索keyword获取失败
-  * 502：num自增失败
+  * 502：num自增失败
+* /keyword/update
+  * 600：校验失败
+  * 601：更新keyword数据库修改失败

api.py

@@ -2,7 +2,7 @@
 import sys
 sys.path.append('./lib')
 from flask import Flask, escape, url_for, request, render_template, redirect, abort, send_from_directory, Response
-from allFunction import manageGet, managePost, manageInsertKeyword, manageDelKeyword, manageGetKeyword, manageMaterial, replySomething
+from allFunction import manageGet, managePost, manageInsertKeyword, manageDelKeyword, manageGetKeyword, manageMaterial, replySomething, manageUpdateKeyword
 from flask_apscheduler import APScheduler
 from wxRequest import requestsAccessToken
 scheduler = APScheduler()
@@ -87,4 +87,10 @@ def delKeyword():
 @app.route('/keyword/get', methods=["GET"])
 def getKeyword():
     res = manageGetKeyword(request)
+    return res
+
+# 更新关键词
+@app.route('/keyword/update', methods=["POST"])
+def updateKeyword():
+    res = manageUpdateKeyword(request)
     return res

lib/allFunction.py

@@ -7,11 +7,13 @@ import reply
 # 引入md5校验
 from hashlib import md5
 # 引入数据库操作函数
-from db import insertKeyword, delKeyword, getAllKeyword, fuzzySearch, addCount
+from db import insertKeyword, delKeyword, getAllKeyword, fuzzySearch, addCount, updateKeyword
 # 引入json
 import json
 # 引入获取微信图文信息
 from wxRequest import batchget_material
+# 引入时间
+import datetime
 
 # 主处理逻辑函数-----------------------------------------------------------
 
@@ -134,6 +136,21 @@ def manageDelKeyword(request):
 def manageGetKeyword(request):
     return getAllKeyword()
 
+# 处理更新关键词
+def manageUpdateKeyword(request):
+     # json化，应该能当dict用
+    try:
+        data_cache = json.loads(request.form['data'])
+    except Exception as e:
+        return {'errcode': 600, 'errmsg': '校验失败'}
+    # MD5校验
+    checked = checkData(data_cache)
+    data_cache.pop('sign')
+    if checked:
+        return updateKeyword(data_cache['id'], data_cache['keywords'], data_cache['content'],datetime.datetime.now().strftime('%Y-%m-%d'),data_cache['news'])
+    else:
+        return {'errcode': 600, 'errmsg': '校验失败'}
+
 # 工具函数---------------------------------------------------------------
 
 # 更新sha1

lib/db.py

@@ -99,4 +99,14 @@ def addCount(id):
         res = col('keyword').update_one({"_id": ObjectId(id)},{"$inc": {"num": 1}})
     except Exception as e:
         return {'errcode': 502, 'errmsg': 'num自增失败',}
-    return {'errcode': 200, 'errmsg': 'ok'}    
+    return {'errcode': 200, 'errmsg': 'ok'}    
+
+# 更新关键词
+def updateKeyword(id, keywords, content, date_now, news):
+    try:
+        col('keyword').update({"_id": ObjectId(id)},
+                             {'$set': {'keywords': keywords, 'content': content, 'date': date_now, 'news': news}})
+    except Exception as e:
+        # 失败
+        return {'errcode': 601, 'errmsg': '更新keyword数据库修改失败'}
+    return {'errcode': 200, 'errmsg': 'ok'}