from flask import current_app, jsonify, request from flask_restful import Resource from flask_restful.reqparse import RequestParser from flask_jwt_extended import ( jwt_required, get_jwt_identity ) from application.signal_manager import signalManager from models.user import postUserSchema,deleteUserSchema,getListUserSchema,getUserSchema,putUserSchema from webcreator.response import ResponseCode, response_result class UserResource(Resource): def __init__(self): pass # 特殊参数,即不是从json获取参数的接口,可以将这个注释打开 # self.parser = RequestParser() def get(self): # 特殊参数,即不是从json获取参数的接口,可以将这个注释打开 # self.parser.add_argument("page", type=int, location="args", default=1) # self.parser.add_argument("pageSize", type=int, location="args", default=15) # args = self.parser.parse_args() try: json_payload = request.json print("========>", json_payload) data = getListUserSchema.load(json_payload) result = signalManager.actionGetUser.emit(**data) json_dumps = getListUserSchema.dump(result) return jsonify(json_dumps), 200 except Exception as e: current_app.logger.error(e) return response_result(ResponseCode.DB_ERROR) @jwt_required def post(self): try: json_payload = request.json data = postUserSchema.load(json_payload) result = signalManager.actionPostUser.emit(**data) json_dumps = postUserSchema.dump(result) return jsonify(json_dumps), 200 except Exception as e: current_app.logger.error(e) return response_result(ResponseCode.DB_ERROR) class UserResourceList(Resource): def __init__(self): pass # 特殊参数,即不是从json获取参数的接口,可以将这个注释打开 # self.parser = RequestParser() @jwt_required def get(self): # 特殊参数,即不是从json获取参数的接口,可以将这个注释打开 # self.parser.add_argument("page", type=int, location="args", default=1) # self.parser.add_argument("pageSize", type=int, location="args", default=15) # args = self.parser.parse_args() try: json_payload = request.json print("========>", json_payload) data = getUserSchema.load(json_payload) result = signalManager.actionGetUser.emit(**data) json_dumps = getUserSchema.dump(result) return jsonify(json_dumps), 200 except Exception as e: current_app.logger.error(e) return response_result(ResponseCode.DB_ERROR) @jwt_required def put(self): try: json_payload = request.json data = putUserSchema.load(json_payload) result = signalManager.actionPutUser.emit(**data) json_dumps = putUserSchema.dump(result) return jsonify(json_dumps), 200 except Exception as e: current_app.logger.error(e) return response_result(ResponseCode.DB_ERROR) @jwt_required def delete(self): try: json_payload = request.json data = deleteUserSchema.load(json_payload) result = signalManager.actionDeleteUser.emit(**data) json_dumps = deleteUserSchema.dump(result) return jsonify(json_dumps), 200 except Exception as e: current_app.logger.error(e) return response_result(ResponseCode.DB_ERROR)