#!/usr/bin/env python # -*- encoding: utf-8 -*- ''' @Date:2022/07/19 17:12:23 ''' from flask import jsonify, request, g, Blueprint from Common.Utils import PageParam, Utils from config.SystemConfig import SystemConfig from db_logic.medicament_record import BllMedicamentRecord from db_logic.medicament import BllMedicament from Common.auth import token_auth from apps.report.utils_base import download_file from Common.screen import get_storage_summary, get_drug_operate, get_all_inventory report_router = Blueprint("report", __name__) # 报表统计主页 @report_router.route("/report_home", methods=["GET", "POST"]) @token_auth.login_required def report_home_show(): func_type = request.values.get("func_type") resp_data = { "drug_use_type_data": "", "use_avg_info":{}, "drug_stock_expend": {"count_number":0, "data":""}, "drug_use_expend":"", "user_use_expend": "" } try: obj_data = BllMedicamentRecord() # 试剂使用统计 drug_use_type_data, avg_use_dic = obj_data.get_drug_record_count( func_type=func_type) # 消耗统计部分 drug_stock_expend, num_all = BllMedicament().get_drug_stock_use_classify( func_type=func_type ) # 试剂用量消耗 drug_use_expend = obj_data.report_home_drug_useing_classify( func_type=func_type ) # 用户试剂消耗 user_use_expend = obj_data.report_home_user_use_info( func_type=func_type ) resp_data["drug_use_type_data"] = drug_use_type_data resp_data["use_avg_info"] = avg_use_dic resp_data["drug_stock_expend"] = { "count_number": num_all, "data": drug_stock_expend } resp_data["drug_use_expend"] = drug_use_expend resp_data["user_use_expend"] = user_use_expend return jsonify(Utils.true_return(data=resp_data)) except Exception as error: return jsonify(Utils.except_return(msg=f"error:{error}", data=resp_data)) # 库存信息总览 @report_router.route("/stock_data_info", methods=["GET", "POST"]) # @token_auth.login_required def get_stock_data_info(): name = request.values.get("name", None) func_type = request.values.get("func_type") page = int(request.values.get('page', 1)) page_size = int(request.values.get('page_size', 15)) # TODO 添加房间筛选 client_place = request.values.get("palce") client_id = request.values.get("client_id") page_param = PageParam(page, page_size) # 导出报表功能 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None data_list = BllMedicament().get_stock_all_info( name=name, func_type=func_type, page_param=page_param, client_place=client_place, client_id=client_id ) data_list = Utils.msyql_table_model(data_list) if not download_tp: if data_list: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data_list})) else: return jsonify(Utils.true_return(data={"total_count": 0, "data": data_list})) else: file_name = request.values.get("file_name", "数据表") res = download_file( file_name=file_name, data_list=data_list, tp=download_tp ) if res: return res else: return jsonify(Utils.false_return()) # 入库信息查询and 试剂信息查询 @report_router.route("/drug_details_info", methods=["GET", "POST"]) @token_auth.login_required def drun_input_info(): # 获取参数 seach_word = request.values.get('seach_word') manufacturer = request.values.get("manufacturer") start_time = request.values.get("start_time") end_time = request.values.get("end_time") seach_user = request.values.get("seach_user") func_type = request.values.get("func_type") customer_id = None client_id = request.values.get("client_id") # TODO 添加房间筛选 client_place = request.values.get("place") # 分页处理 page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) page_param = PageParam(page, page_size) download_tp = request.values.get("download_type", 0) if download_tp: page_param = None # 获取数据 data = BllMedicament().getAllDrugList( search_word=seach_word, manufacturer=manufacturer, func_type=func_type, start_time=start_time, end_time=end_time, page_param=page_param, customer_id=customer_id, client_id=client_id, client_speci=client_place, seach_user=seach_user ) # 数据处理，列表key：value格式 data_list = Utils.msyql_table_model(data) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data_list})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( file_name=file_name, data_list=data_list, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 库存消耗 # 试剂名称、纯度、cas码 查询rms_medicament 分组后获取 @report_router.route("/stock_loss_info", methods=["GET", "POST"]) @token_auth.login_required def stock_loss_info(): # 获取参数 seach_word = request.values.get('seach_word') func_type = request.values.get("func_type") page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) page_param = PageParam(page, page_size) # 报表数据 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None # 获取数据结果 data = BllMedicamentRecord().durg_stock_loss( seach_word=seach_word, func_type=func_type, page_param=page_param) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( file_name=file_name, data_list=data, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 试剂用量消耗 @report_router.route("/drug_use_expend", methods=["GET", "POST"]) @token_auth.login_required def get_drug_use_expend(): # 参数获取 seach_word = request.values.get('seach_word') func_type = request.values.get("func_type") page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) page_param = PageParam(page, page_size) # 报表数据 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None # 获取数据 data = BllMedicamentRecord().durg_useing_info( seach_word=seach_word, func_type=func_type, page_param=page_param) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( # file_path=file_path, file_name=file_name, data_list=data, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 人员用量消耗 @report_router.route("/drug_user_use_expend", methods=["GET", "POST"]) @token_auth.login_required def get_drug_user_use_expend(): # 参数获取 seach_user = request.values.get('seach_user') start_time = request.values.get('start_time') end_time = request.values.get('end_time') func_type = request.values.get("func_type") page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) page_param = PageParam(page, page_size) # 报表数据 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None # 获取数据 data = BllMedicamentRecord().user_use_info( seach_user=seach_user, func_type=func_type, start_time=start_time, end_time=end_time, page_param=page_param) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( file_name=file_name, data_list=data, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 使用频率 @report_router.route("/use_frequency", methods=["GET", "POST"]) @token_auth.login_required def drug_use_frequency(): seach_word = request.values.get('seach_word') client_id = request.values.get("client_id") start_time = request.values.get('start_time') end_time = request.values.get('end_time') func_type = request.values.get("func_type") page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) page_param = PageParam(page, page_size) # 报表数据 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None data = BllMedicamentRecord().use_frequency( seach_word=seach_word, start_time=start_time, end_time=end_time, func_type=func_type, client_id=client_id, page_param=page_param) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( # file_path=file_path, file_name=file_name, data_list=data, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 入库、领用、归还记录 @report_router.route("/drug_log_type_info", methods=["GET", "POST"]) # @token_auth.login_required def drug_log_type_info(): page = int(request.values.get("page", 1)) page_size = int(request.values.get("page_size", 10)) statue_type = request.values.get("status") record_type = request.values.get("record_type") func_type = request.values.get("func_type") put_in_user_name = request.values.get("user_name") name = request.values.get("name") start_time = request.values.get("start_time") end_time = request.values.get("end_time") page_param = PageParam(page, page_size) # TODO 添加房间筛选 client_place = request.values.get("place") client_id = request.values.get("client_id") # 报表数据 download_tp = request.values.get("download_type", 0) if download_tp: page_param = None kwargs = { "record_type": record_type, "put_in_user_name": put_in_user_name, "func_type": func_type, "statue_type": statue_type, "name": name, "start_time": start_time, "end_time": end_time, "page_param": page_param, "client_place": client_place, "client_id": client_id } # 未入库记录 if record_type == "100": data_list, _ = BllMedicament().drug_show_un_warehoused_type_info(**kwargs) else: data_list = BllMedicament().drug_show_type_info(**kwargs) data_list = Utils.msyql_table_model(data_list) if not download_tp: return jsonify(Utils.true_return(data={"total_count": page_param.totalRecords, "data": data_list})) else: file_name = request.values.get("file_name", "数据表") rsp = download_file( # file_path=file_path, file_name=file_name, data_list=data_list, tp=download_tp ) if rsp: return rsp else: return jsonify(Utils.false_return()) # 入库验收表导出 @report_router.route("/putin_acceptance_record", methods=["GET", "POST"]) # @token_auth.login_required def get_putin_acceptance_record(): data = BllMedicament().execute( """ SELECT `name`, speci, remark5, date_format( expiration_date,'%Y-%m-%d') shelf_life, manufacturer, distributor, count(*) num, put_in_user_name, date_format( put_in_date,'%Y-%m-%d') put_in_date FROM `rms_medicament` GROUP BY `name`, purity, speci, remark5, DATE_FORMAT(put_in_date,"%Y-%m-%d") """ ).fetchall() data_list = Utils.msyql_table_model(data) for i in data_list: gg_ph = '' if str(i["speci"]) !='' and str(i["speci"]) !='None': gg_ph += str(i["speci"]) if str(i["remark5"]) !='' and str(i["remark5"]) !='None': if gg_ph: gg_ph += "," gg_ph += str(i["remark5"]) i["gg_ph"] = gg_ph i["acceptace"] = """□标识清晰\r\n□外观完整、无破损\r\n□形状无明显改变\r\n□符合申购要求""" i["shelf_life"] = str(i["shelf_life"]) file_name = "实验耗材入库验收记录表" data = download_file( # file_path=file_path, file_name=file_name, data_list=data_list, tp="12" ) if data: return data else: return jsonify(Utils.false_return()) @report_router.route("/storage", methods=["GET", "POST"]) def get_report_storage(): """ 大屏 获取出入库情况 :return: chemicals: 物品名 day_out_num： 今日出库数 day_in_num: 今日入库数 opt_count: 操作次数 """ storage_report_list = get_storage_summary() if not storage_report_list: storage_report_list = [{ "chemicals": "", "day_out_num": 0, "day_in_num": 0, "opt_count": 0 }] return jsonify(Utils.true_return(data=storage_report_list)) @report_router.route("/operation", methods=["GET", "POST"]) def get_report_operation(): """ 大屏 获取操作情况 :return: [{chemicals_name: 化学品, update_user: 操作人, update_type: 操作类型, update_time:操作时间}] """ # 1：入库2：领用3：归还 type_dict = { 1: "入库", 2: "领用", 3: "归还", } operate_list = get_drug_operate() result = [{ "chemicals": item.get("name"), "update_user": item.get("create_user_name"), "update_type": type_dict.get(item.get("record_type"), '未知'), "update_time": item.get("create_date") } for item in operate_list] return jsonify(Utils.true_return(data=result)) @report_router.route("/inventory", methods=["GET", "POST"]) def get_report_inventory(): """ 大屏 获取库存情况 :return: [{chemicals: 化学品, total_num: 库存量, total_weight: 总重量}] """ inventory_list = get_all_inventory() return jsonify(Utils.true_return(data=inventory_list))