'wip(semantic):调整模板api接口'

This commit is contained in:
zhengxinonly
2021-09-12 18:16:02 +08:00
parent b9c449ad57
commit 550f99e468
30 changed files with 259 additions and 240 deletions
+8 -8
View File
@@ -49,7 +49,7 @@ class Departments(Resource):
db.session.add(dept)
db.session.commit()
return success_api(msg="成功")
return success_api(message="成功")
class Department(Resource):
@@ -67,7 +67,7 @@ class Department(Resource):
'address': dept.address,
}
# return make_response(render_template('department/edit.html', dept=dept))
return jsonify(success=True, msg='ok', dept=dept_data)
return dict(success=True, message='ok', dept=dept_data)
@authorize("admin:dept:edit", log=True)
def put(self, dept_id):
@@ -92,9 +92,9 @@ class Department(Resource):
}
res = CompanyDepartment.query.filter_by(id=dept_id).update(data)
if not res:
return fail_api(msg="更新失败")
return fail_api(message="更新失败")
db.session.commit()
return success_api(msg="更新成功")
return success_api(message="更新成功")
@authorize("admin:dept:remove", log=True)
def delete(self, dept_id):
@@ -102,8 +102,8 @@ class Department(Resource):
CompanyUser.query.filter_by(dept_id=dept_id).update({"dept_id": None})
db.session.commit()
if ret:
return success_api(msg="删除成功")
return fail_api(msg="删除失败")
return success_api(message="删除成功")
return fail_api(message="删除失败")
class DeptEnable(Resource):
@@ -114,5 +114,5 @@ class DeptEnable(Resource):
d.status = not d.status
db.session.commit()
message = '修改成功'
return success_api(msg=message)
return fail_api(msg="出错啦")
return success_api(message=message)
return fail_api(message="出错啦")
+10 -10
View File
@@ -166,13 +166,13 @@ class RightRights(Resource):
"data": power_data
}
return jsonify(res)
return res
@authorize("admin:power:remove", log=True)
def delete(self):
ids = request.form.getlist('ids[]')
batch_remove_power(ids)
return success_api(msg="批量删除成功")
return success_api(message="批量删除成功")
class RightPower(Resource):
@@ -196,9 +196,9 @@ class RightPower(Resource):
db.session.commit()
except Exception as e:
print(e)
return fail_api(msg='数据提交失败')
return fail_api(message='数据提交失败')
return success_api(msg="成功")
return success_api(message="成功")
@authorize("admin:power:remove", log=True)
def delete(self, power_id):
@@ -215,9 +215,9 @@ class RightPower(Resource):
db.session.commit()
if r:
return success_api(msg="删除成功")
return success_api(message="删除成功")
else:
return fail_api(msg="删除失败")
return fail_api(message="删除失败")
@authorize("admin:power:edit", log=True)
def put(self, power_id):
@@ -237,8 +237,8 @@ class RightPower(Resource):
db.session.commit()
if not power:
return fail_api(msg="更新权限失败")
return success_api(msg="更新权限成功")
return fail_api(message="更新权限失败")
return success_api(message="更新权限成功")
class RightPowerEnable(Resource):
@@ -250,9 +250,9 @@ class RightPowerEnable(Resource):
power.enable = not power.enable
db.session.commit()
message = "修改成功"
return success_api(msg=message)
return success_api(message=message)
else:
return fail_api(msg="出错啦")
return fail_api(message="出错啦")
class AdminConfigs(Resource):
+20 -26
View File
@@ -57,18 +57,16 @@ class RoleRoles(Resource):
paginate = RightsRole.query.filter(*filters).paginate(page=res.page, per_page=res.limit, error_out=False)
return table_api(data=[
{
'id': item.id,
'roleName': item.name,
'roleCode': item.code,
'enable': item.enable,
'remark': item.remark,
'details': item.details,
'sort': item.sort,
'create_at': item.create_at,
} for item in paginate.items
], count=paginate.total, code=0)
return table_api(result={'items': [{'id': item.id,
'roleName': item.name,
'roleCode': item.code,
'enable': item.enable,
'remark': item.remark,
'details': item.details,
'sort': item.sort,
'create_at': str(item.create_at), } for item in paginate.items],
'total': paginate.total}
, code=0)
@authorize("admin:role:remove", log=True)
@login_required
@@ -79,7 +77,7 @@ class RoleRoles(Resource):
res = parser.parse_args()
batch_remove_role(res.ids)
return success_api(msg="批量删除成功")
return success_api(message="批量删除成功")
class RoleRole(Resource):
@@ -104,7 +102,7 @@ class RoleRole(Resource):
)
db.session.add(role)
db.session.commit()
return success_api(msg="成功")
return success_api(message="成功")
# 更新角色
@authorize("admin:role:edit", log=True)
@@ -130,8 +128,8 @@ class RoleRole(Resource):
role = RightsRole.query.filter_by(id=role_id).update(data)
db.session.commit()
if not role:
return fail_api(msg="更新角色失败")
return success_api(msg="更新角色成功")
return fail_api(message="更新角色失败")
return success_api(message="更新角色成功")
class RoleEnable(Resource):
@@ -145,8 +143,8 @@ class RoleEnable(Resource):
message = "修改成功"
if not ret:
return fail_api(msg="出错啦")
return success_api(msg=message)
return fail_api(message="出错啦")
return success_api(message=message)
class RolePower(Resource):
@@ -158,20 +156,16 @@ class RolePower(Resource):
# 获取权限列表的 id
check_powers_list = [rp.id for rp in role.power]
powers = RightsPower.query.all() # 获取所有的权限
# power_schema = PowerSchema2(many=True) # 用已继承 ma.ModelSchema 类的自定制类生成序列化类
# 将所有的权限生产可序列化对象 json
# powers = power_schema.dump(powers) # 生成可序列化对象
powers = marshal(powers, power_fields)
for i in powers:
if int(i.get("powerId")) in check_powers_list:
i["checkArr"] = "1"
else:
i["checkArr"] = "0"
res = {
return {
"data": powers,
"status": {"code": 200, "message": "默认"}
}
return jsonify(res)
# 保存角色权限
@authorize("admin:role:edit", log=True)
@@ -195,7 +189,7 @@ class RolePower(Resource):
for p in powers:
role.power.append(p)
db.session.commit()
return success_api(msg="授权成功")
return success_api(message="授权成功")
# 角色删除
@authorize("admin:role:remove", log=True)
@@ -204,5 +198,5 @@ class RolePower(Resource):
res = remove_role(role_id)
print(res)
if not res:
return fail_api(msg="角色删除失败")
return success_api(msg="角色删除成功")
return fail_api(message="角色删除失败")
return success_api(message="角色删除成功")
+3 -1
View File
@@ -21,7 +21,9 @@ class FilePhotos(Resource):
photo_paginate = FilePhoto.query.order_by(desc(FilePhoto.create_at)).paginate(page=page, per_page=limit,
error_out=False)
data = marshal(photo_paginate.items, photo_fields)
return table_api(data=data, count=photo_paginate.total, code=0)
return table_api(result={'items': data,
'total': photo_paginate.total, },
code=0)
@authorize("admin:file:add", log=True)
def post(self):
+5 -6
View File
@@ -18,7 +18,6 @@ class Login(Resource):
def get(self):
if current_user.is_authenticated:
return redirect(url_for('admin.index'))
# TODO 分离视图操作 最终实现接口登录与视图登录两套逻辑
return make_response(render_template('index/login.html'))
def post(self):
@@ -28,14 +27,14 @@ class Login(Resource):
s_code = session.get("code", None)
if req.captcha != s_code:
return fail_api(msg="验证码错误")
return fail_api(message="验证码错误")
user = CompanyUser.query.filter_by(username=req.username).first()
if user is None:
return fail_api(msg="不存在的用户")
return fail_api(message="不存在的用户")
if user.enable == 0:
return fail_api(msg="用户被暂停使用")
return fail_api(message="用户被暂停使用")
if user.validate_password(req.password):
# 登录
@@ -45,6 +44,6 @@ class Login(Resource):
# 存入权限
add_auth_session()
return success_api(msg="登录成功")
return success_api(message="登录成功")
record_logging()
return fail_api(msg="用户名或密码错误")
return fail_api(message="用户名或密码错误")
+10 -10
View File
@@ -21,14 +21,14 @@ class UserStatus(Resource):
if res.operate == 1:
user = CompanyUser.query.get(user_id)
user.enable = res.operate
message = success_api(msg="启动成功")
message = success_api(message="启动成功")
else:
user = CompanyUser.query.filter_by(id=res.user_id).update({"enable": res.operate})
message = success_api(msg="禁用成功")
message = success_api(message="禁用成功")
if user:
db.session.commit()
else:
return fail_api(msg="出错啦")
return fail_api(message="出错啦")
return message
@@ -41,8 +41,8 @@ class UserAvatar(Resource):
ret.avatar = url
db.session.commit()
if not ret:
return fail_api(msg="出错啦")
return success_api(msg="修改成功")
return fail_api(message="出错啦")
return success_api(message="修改成功")
class UserInfo(Resource):
@@ -63,8 +63,8 @@ class UserInfo(Resource):
ret.remark = res.details
db.session.commit()
if not ret:
return fail_api(msg="出错啦")
return success_api(msg="更新成功")
return fail_api(message="出错啦")
return success_api(message="更新成功")
class UserPassword(Resource):
@@ -80,15 +80,15 @@ class UserPassword(Resource):
res = parser.parse_args()
if res.newPassword != res.confirmPassword:
return fail_api(msg='确认密码不一致')
return fail_api(message='确认密码不一致')
""" 修改当前用户密码 """
user = CompanyUser.query.get(user_id)
is_right = user.validate_password(res.oldPassword)
if not is_right:
return jsonify(success=False, msg="旧密码错误")
return jsonify(success=False, message="旧密码错误")
user.set_password(res.newPassword)
db.session.add(user)
db.session.commit()
return jsonify(success=True, msg="更改成功")
return jsonify(success=True, message="更改成功")
+13 -12
View File
@@ -90,12 +90,13 @@ class UserUsers(Resource):
'username': item.username,
'realname': item.realname,
'enable': item.enable,
'create_at': item.create_at,
'update_at': item.update_at,
'create_at': str(item.create_at),
'update_at': str(item.update_at),
'dept': dept_name(item.dept_id),
} for item in paginate.items]
return table_api(data=user_data, count=paginate.total, code=0)
return table_api(result={'items': user_data,
'total': paginate.total}
, code=0)
@authorize("admin:user:add", log=True)
def post(self):
@@ -111,7 +112,7 @@ class UserUsers(Resource):
role_ids = res.role_ids.split(',')
if is_user_exists(res.username):
return fail_api(msg="用户已经存在")
return fail_api(message="用户已经存在")
user = CompanyUser()
user.username = res.username
@@ -127,14 +128,14 @@ class UserUsers(Resource):
user.role.append(r)
db.session.commit()
return success_api(msg="增加成功", code=0)
return success_api(message="增加成功", code=0)
@authorize("admin:user:remove", log=True)
def delete(self):
"""批量删除"""
ids = request.form.getlist('ids[]')
batch_remove(ids)
return success_api(msg="批量删除成功")
return success_api(message="批量删除成功")
class UserUser(Resource):
@@ -154,7 +155,7 @@ class UserUser(Resource):
role_ids = res.role_ids.split(',')
if is_user_exists(res.username):
return fail_api(msg="用户已经存在")
return fail_api(message="用户已经存在")
user = CompanyUser()
user.username = res.username
@@ -170,15 +171,15 @@ class UserUser(Resource):
user.role.append(r)
db.session.commit()
return success_api(msg="增加成功", code=0)
return success_api(message="增加成功", code=0)
@authorize("admin:user:remove", log=True)
def delete(self, user_id):
# 删除用户
res = delete_by_id(user_id)
if not res:
return fail_api(msg="删除失败")
return success_api(msg="删除成功")
return fail_api(message="删除失败")
return success_api(message="删除成功")
class UserRole(Resource):
@@ -202,4 +203,4 @@ class UserRole(Resource):
update_user_role(user_id, role_ids)
return success_api(msg="更新成功")
return success_api(message="更新成功")