修复json请求获取错误

applications/view/admin/dict.py

@@ -45,7 +45,7 @@ def dict_type_add():
 @admin_dict.post('/dictType/save')
 @authorize("admin:dict:add", log=True)
 def dict_type_save():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     description = str_escape(req_json.get("description"))
     enable = str_escape(req_json.get("enable"))
     type_code = str_escape(req_json.get("typeCode"))
@@ -71,7 +71,7 @@ def dict_type_edit():
 @admin_dict.put('/dictType/update')
 @authorize("admin:dict:edit", log=True)
 def dict_type_update():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     id = str_escape(req_json.get("id"))
     description = str_escape(req_json.get("description"))
     enable = str_escape(req_json.get("enable"))
@@ -91,7 +91,7 @@ def dict_type_update():
 @admin_dict.put('/dictType/enable')
 @authorize("admin:dict:edit", log=True)
 def dict_type_enable():
-    _id = request.json.get('id')
+    _id = request.get_json(force=True).get('id')
     if id:
         res = curd.enable_status(DictType,_id)
         if not res:
@@ -104,7 +104,7 @@ def dict_type_enable():
 @admin_dict.put('/dictType/disable')
 @authorize("admin:dict:edit", log=True)
 def dict_type_dis_enable():
-    _id = request.json.get('id')
+    _id = request.get_json(force=True).get('id')
     if id:
         res = curd.disable_status(DictType,_id)
         if not res:
@@ -145,7 +145,7 @@ def dict_data_add():
 @admin_dict.post('/dictData/save')
 @authorize("admin:dict:add", log=True)
 def dict_data_save():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     data_label = str_escape(req_json.get("dataLabel"))
     data_value = str_escape(req_json.get("dataValue"))
     enable = str_escape(req_json.get("enable"))
@@ -172,7 +172,7 @@ def dict_data_edit():
 @admin_dict.put('/dictData/update')
 @authorize("admin:dict:edit", log=True)
 def dict_data_update():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     id = req_json.get("dataId")
     DictData.query.filter_by(id=id).update({
         "data_label": str_escape(req_json.get("dataLabel")),
@@ -189,7 +189,7 @@ def dict_data_update():
 @admin_dict.put('/dictData/enable')
 @authorize("admin:dict:edit", log=True)
 def dict_data_enable():
-    _id = request.json.get('dataId')
+    _id = request.get_json(force=True).get('dataId')
     if _id:
         res = curd.enable_status(model=DictData, id=_id)
         if not res:
@@ -202,7 +202,7 @@ def dict_data_enable():
 @admin_dict.put('/dictData/disable')
 @authorize("admin:dict:edit", log=True)
 def dict_data_disenable():
-    _id = request.json.get('dataId')
+    _id = request.get_json(force=True).get('dataId')
     if _id:
         res = curd.disable_status(model=DictData, id=_id)
         if not res:

applications/view/admin/mail.py

@@ -54,7 +54,7 @@ def add():
 @admin_mail.post('/save')
 @authorize("admin:mail:add", log=True)
 def save():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     receiver = str_escape(req_json.get("receiver"))
     subject = str_escape(req_json.get('subject'))
     content = str_escape(req_json.get('content'))

applications/view/admin/power.py

@@ -51,7 +51,7 @@ def select_parent():
 @admin_power.post('/save')
 @authorize("admin:power:add", log=True)
 def save():
-    req = request.json
+    req = request.get_json(force=True)
     icon = str_escape(req.get("icon"))
     openType = str_escape(req.get("openType"))
     parentId = str_escape(req.get("parentId"))
@@ -93,8 +93,8 @@ def edit(_id):
 @admin_power.put('/update')
 @authorize("admin:power:edit", log=True)
 def update():
-    req_json = request.json
-    id = request.json.get("powerId")
+    req_json = request.get_json(force=True)
+    id = request.get_json(force=True).get("powerId")
     data = {
         "icon": str_escape(req_json.get("icon")),
         "open_type": str_escape(req_json.get("openType")),
@@ -116,7 +116,7 @@ def update():
 @admin_power.put('/enable')
 @authorize("admin:power:edit", log=True)
 def enable():
-    _id = request.json.get('powerId')
+    _id = request.get_json(force=True).get('powerId')
     if id:
         res = curd.enable_status(Power, _id)
         if not res:
@@ -129,7 +129,7 @@ def enable():
 @admin_power.put('/disable')
 @authorize("admin:power:edit", log=True)
 def dis_enable():
-    _id = request.json.get('powerId')
+    _id = request.get_json(force=True).get('powerId')
     if id:
         res = curd.disable_status(Power, _id)
         if not res:

applications/view/admin/role.py

@@ -44,7 +44,7 @@ def add():
 @admin_role.post('/save')
 @authorize("admin:role:add", log=True)
 def save():
-    req = request.json
+    req = request.get_json(force=True)
     details = str_escape(req.get("details"))
     enable = str_escape(req.get("enable"))
     roleCode = str_escape(req.get("roleCode"))
@@ -122,7 +122,7 @@ def edit(id):
 @admin_role.put('/update')
 @authorize("admin:role:edit", log=True)
 def update():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     id = req_json.get("roleId")
     data = {
         "code": str_escape(req_json.get("roleCode")),
@@ -142,7 +142,7 @@ def update():
 @admin_role.put('/enable')
 @authorize("admin:role:edit", log=True)
 def enable():
-    id = request.json.get('roleId')
+    id = request.get_json(force=True).get('roleId')
     if id:
         res = enable_status(Role, id)
         if not res:
@@ -155,7 +155,7 @@ def enable():
 @admin_role.put('/disable')
 @authorize("admin:role:edit", log=True)
 def dis_enable():
-    _id = request.json.get('roleId')
+    _id = request.get_json(force=True).get('roleId')
     if _id:
         res = disable_status(Role, _id)
         if not res:

applications/view/admin/task.py

@@ -38,12 +38,12 @@ def add():
 
 @admin_task.post('/save')
 def save():
-    _id = request.json.get("id")
-    name = request.json.get("id")
-    type = request.json.get("type")
-    functions = request.json.get("functions")
-    datetime = request.json.get("datetime")
-    time = request.json.get("time")
+    _id = request.get_json(force=True).get("id")
+    name = request.get_json(force=True).get("id")
+    type = request.get_json(force=True).get("type")
+    functions = request.get_json(force=True).get("functions")
+    datetime = request.get_json(force=True).get("datetime")
+    time = request.get_json(force=True).get("time")
     if not hasattr(tasks, functions):
         return fail_api()
     if type == 'date':
@@ -87,7 +87,7 @@ def save():
 # 恢复
 @admin_task.put('/enable')
 def enable():
-    _id = request.json.get('id')
+    _id = request.get_json(force=True).get('id')
     # print(id)
     if _id:
         scheduler.resume_job(str(_id))
@@ -98,7 +98,7 @@ def enable():
 # 暂停
 @admin_task.put('/disable')
 def dis_enable():
-    _id = request.json.get('id')
+    _id = request.get_json(force=True).get('id')
     if _id:
         scheduler.pause_job(str(_id))
         return success_api(msg="暂停成功")

applications/view/admin/user.py

@@ -70,7 +70,7 @@ def add():
 @admin_user.post('/save')
 @authorize("admin:user:add", log=True)
 def save():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     a = req_json.get("roleIds")
     username = str_escape(req_json.get('username'))
     real_name = str_escape(req_json.get('realName'))
@@ -122,7 +122,7 @@ def edit(id):
 @admin_user.put('/update')
 @authorize("admin:user:edit", log=True)
 def update():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     a = str_escape(req_json.get("roleIds"))
     id = str_escape(req_json.get("userId"))
     username = str_escape(req_json.get('username'))
@@ -160,7 +160,7 @@ def profile():
 @admin_user.put('/updateAvatar')
 @login_required
 def update_avatar():
-    url = request.json.get("avatar").get("src")
+    url = request.get_json(force=True).get("avatar").get("src")
     r = User.query.filter_by(id=current_user.id).update({"avatar": url})
     db.session.commit()
     if not r:
@@ -172,7 +172,7 @@ def update_avatar():
 @admin_user.put('/updateInfo')
 @login_required
 def update_info():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     r = User.query.filter_by(id=current_user.id).update(
         {"realname": req_json.get("realName"), "remark": req_json.get("details")})
     db.session.commit()
@@ -192,7 +192,7 @@ def edit_password():
 @admin_user.put('/editPassword')
 @login_required
 def edit_password_put():
-    res_json = request.json
+    res_json = request.get_json(force=True)
     if res_json.get("newPassword") == '':
         return fail_api("新密码不得为空")
     if res_json.get("newPassword") != res_json.get("confirmPassword"):
@@ -211,7 +211,7 @@ def edit_password_put():
 @admin_user.put('/enable')
 @authorize("admin:user:edit", log=True)
 def enable():
-    _id = request.json.get('userId')
+    _id = request.get_json(force=True).get('userId')
     if _id:
         res = enable_status(model=User, id=_id)
         if not res:
@@ -224,7 +224,7 @@ def enable():
 @admin_user.put('/disable')
 @authorize("admin:user:edit", log=True)
 def dis_enable():
-    _id = request.json.get('userId')
+    _id = request.get_json(force=True).get('userId')
     if _id:
         res = disable_status(model=User, id=_id)
         if not res:

applications/view/department/__init__.py

@@ -55,7 +55,7 @@ def tree():
 @dept_bp.post('/save')
 @authorize("admin:dept:add", log=True)
 def save():
-    req_json = request.json
+    req_json = request.get_json(force=True)
     dept = Dept(
         parent_id=req_json.get('parentId'),
         dept_name=str_escape(req_json.get('deptName')),
@@ -83,7 +83,7 @@ def edit():
 @dept_bp.put('/enable')
 @authorize("admin:dept:edit", log=True)
 def enable():
-    id = request.json.get('deptId')
+    id = request.get_json(force=True).get('deptId')
     if id:
         enable = 1
         d = Dept.query.filter_by(id=id).update({"status": enable})
@@ -98,7 +98,7 @@ def enable():
 @dept_bp.put('/disable')
 @authorize("admin:dept:edit", log=True)
 def dis_enable():
-    id = request.json.get('deptId')
+    id = request.get_json(force=True).get('deptId')
     if id:
         enable = 0
         d = Dept.query.filter_by(id=id).update({"status": enable})
@@ -112,7 +112,7 @@ def dis_enable():
 @dept_bp.put('/update')
 @authorize("admin:dept:edit", log=True)
 def update():
-    json = request.json
+    json = request.get_json(force=True)
     id = json.get("deptId"),
     data = {
         "dept_name": validate.str_escape(json.get("deptName")),

applications/view/plugin/__init__.py

@@ -84,7 +84,7 @@ def data():
 @authorize("admin:plugin:enable", log=True)
 def enable():
     """启用插件"""
-    plugin_folder_name = request.json.get('plugin_folder_name')
+    plugin_folder_name = request.get_json(force=True).get('plugin_folder_name')
     if plugin_folder_name:
         try:
             if plugin_folder_name not in PLUGIN_ENABLE_FOLDERS:
@@ -118,7 +118,7 @@ def enable():
 @authorize("admin:plugin:enable", log=True)
 def disable():
     """禁用插件"""
-    plugin_folder_name = request.json.get('plugin_folder_name')
+    plugin_folder_name = request.get_json(force=True).get('plugin_folder_name')
     if plugin_folder_name:
         try:
             if plugin_folder_name in PLUGIN_ENABLE_FOLDERS: