#!/usr/bin/env python # -*- encoding: utf-8 -*- ''' @Date:2022/07/18 16:54:45 ''' import sys import datetime from dateutil.relativedelta import relativedelta sys.path.append('.') from sqlalchemy import distinct, or_, and_, desc, asc from sqlalchemy.sql import func from db_logic.db_base import Repository from models.medicament_models import EntityMedicament, EntityMedicamentRecord, EntityMedicamentTemplate, EntityVariety, EntityMedicamentVariety from models.client_models import EntityClient from models.user_models import EntityUser from db_logic.meidcament_variety import BllMedicamentVariety from db_logic.variety import BllVariety from Common.Utils import Utils, DrugStatus, DrugRecordType client_list=['72e70542-b70d-11e8-aea5-448a5bc6c411','72e70542-b70d-11e8-aea5-448a5bc6c412','72e70542-b70d-11e8-aea5-448a5bc6c413','72e70542-b70d-11e8-aea5-448a5bc6c414','72e70542-b70d-11e8-aea5-448a5bc6c415','72e70542-b70d-11e8-aea5-448a5bc6c416','72e70542-b70d-11e8-aea5-448a5bc6c417'] #药剂流程业务逻辑类 class BllMedicament(Repository): def __init__(self, entityType=EntityMedicament): return super().__init__(entityType) def update(self, entity): entity.remark30 = '0' return super().update(entity) def get_register_list(self, user, page_param): # sql_all = f""" # select * from rms_user_apply # where # user_id='{user.user_id}' and # is_solve=1 and # solve_date > DATE_SUB('{Utils.get_str_datetime()}', INTERVAL 10 hour) # """ # data = self.execute(sql_all).fetchall() # data_list = [] # for i in data: # use_content = json.loads(i.use_content) # for j_index in range(len(use_content)): # j = use_content[j_index] # if not j.get("use_num"): # # j["stay_use_num"] = j.get("use_num") # drugobj =BllMedicament().findEntity(and_(EntityMedicament.status==4,EntityMedicament.medicament_id == j.get("medicament_id"))) # print(drugobj,'889898989898989') # if drugobj: # data_list.append(j) # #所有试剂 sql_all = f""" select * from rms_medicament where status=4 and by_user_id='{user.user_id}' """ try: total_count = self.execute(f"select count(*) num from rms_medicament where status=4 and by_user_id='{user.user_id}'").fetchone().num except Exception: total_count = 0 page_param.totalRecords = total_count # 调用分页组装sql sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() # 获取可入库层数据 def get_drug_save_db_info(self, drug_name, func_type): # sql_all = f""" # select name, IFNULL(num,0) number, c.client_name, c.client_id, cell_code, cell_speci from ( # select cell_code, a.client_id, cell_speci, client_name from ( # select * from rms_client_cell # ) a LEFT JOIN( # select client_id, client_name from rms_client # ) b on a.client_id = b.client_id # ) c LEFT JOIN( # select name, client_id, flow_position_code, count(*) num # from rms_medicament where `name` like '%{drug_name}%' and status=1 and func_type={func_type} # GROUP BY client_id, flow_position_code # ) d on c.client_id=d.client_id and c.cell_code=d.flow_position_code # HAVING number < 40 # """ sql_all = f""" select c.*, d.client_name from ( select a.cell_code,a.client_id, a.cell_speci, IFNULL(a.storage_quantity,0) storage_quantity, count(b.name) num, IFNULL(GROUP_CONCAT(b.name),'') name_json from (select * from rms_client_cell) a LEFT JOIN (select * from rms_medicament) b on a.client_id=b.client_id and a.cell_speci=b.place GROUP BY a.id order by a.cell_speci asc ) c LEFT JOIN (select * from rms_client where func_type={func_type}) d on c.client_id=d.client_id where d.client_name is not null order by d.client_name asc """ data = self.execute(sql_all).fetchall() data_list = [] data_dict = {} for i in data: if int(i.num) >= int(i.storage_quantity): continue # 处理当前试剂是否与试剂柜内的试剂冲突，当前试剂名称，数据库内当前层的试剂列表 # if drug_name in i.name_json.split(","): # pass if i.client_id in data_dict.keys(): data_dict[i.client_id]["client_cell"].append(i.cell_speci) else: client_dict = { "client_id": i.client_id, "client_name": i.client_name, "client_cell": [i.cell_speci] } data_dict[i.client_id] = client_dict data_dict[i.client_id]["client_cell"].sort() # data_dict = {} # for i in data: # if i.client_id in data_dict.keys(): # data_dict[i.client_id]["client_cell"].append(i.cell_speci) # else: # client_dict = { # "client_id": i.client_id, # "client_name": i.client_name, # "client_cell": [i.cell_speci] # } # data_dict[i.client_id] = client_dict data_list = [] for k,v in data_dict.items(): DrugSetPotionStorageIn = self.getDrugSetPotionStorageIn(drug_name, k) if DrugSetPotionStorageIn[0]: v["conflict"] = DrugSetPotionStorageIn[1] data_list.append(v) return data_list # 获取离保质期最近的同类药剂 def getDrugNearExpired(self, varietyId, customerId): drugList = self.findList( and_( EntityMedicament.status == DrugStatus.Normal, EntityMedicament.variety_id == varietyId )).order_by(EntityMedicament.expiration_date).limit(1) return drugList.first() # 根据条码获取试剂详细信息 def get_bar_code_drug_info(self, bar_code): return self.execute(f"select * from rms_medicament where bar_code='{bar_code}'").fetchall() # 获取库存余量 def get_drug_surplus(self, client_id, func_type, page_param): # 动态添加查询条件 where_base = "" if client_id: where_base = f" client_id='{client_id}'" if func_type: if where_base: where_base += " and " where_base += f" func_type='{func_type}'" if where_base: where_base = f" where {where_base} " sql_all = f""" select `name`, english_name, cas_number, speci, net_weight_unit, purity, manufacturer, sum(CASE WHEN `status`=1 THEN 1 ELSE 0 END) surplus_number from rms_medicament {where_base} GROUP BY `name`, speci, purity order by put_in_date desc """ # 查询页总数 try: total_count = len(self.execute(sql_all).fetchall()) except Exception: total_count = 0 # count_sql = f"SELECT count(*) FROM rms_medicament %s GROUP BY `name`, cas_number, purity" % where_base page_param.totalRecords = total_count # 调用分页组装sql sql_all = Utils.sql_paging_assemble(sql_all, page_param) data_list = self.execute(sql_all).fetchall() return data_list # 获取试剂库存消耗 def get_drug_stock_use_classify(self, func_type): sql_all = f""" select count(medicament_id) count_number, `status` from rms_medicament where func_type='{func_type}' GROUP BY `status` order by put_in_date desc """ # 查看分组数据 data = self.execute(sql_all).fetchall() # 计算总数 data_number = sum([i[0] for i in data]) data_li = Utils.msyql_table_model(data) data_list = [] # 计算百分比，组装数据 type_num = [] for i in data_li: new_dict = { # "ratio": str(round(i["count_number"] / data_number,2) * 100) + "%" "ratio": Utils.classify(i['count_number'], data_number) } new_dict.update(i) type_num.append(str(i["status"])) data_list.append(new_dict) set_num_li = list(set(["1", "2", "3"]).difference(set(type_num))) for i in set_num_li: data_list.append( { "status": int(i), "rotio": "0%", "count_number": "0" } ) return data_list, data_number #获取药剂列表 def getDrugList(self, customerId, keyWord, pageParam): keyWord = '%' + keyWord + '%' orm_query = self.findList().filter( EntityMedicament.customer_id == customerId ).filter( # or_(EntityMedicament.RFID.like(keyWord), EntityMedicament.name.like(keyWord)) or_(EntityMedicament.RFID.like(keyWord), EntityMedicament.name.like(keyWord)) ).order_by( # desc(EntityMedicament.PutInStorageDate) desc(EntityMedicament.put_in_date) ) return self.queryPage(orm_query, pageParam) # 试剂管理 def get_drug_list(self, client_id, seach_word, b_code, func_type, page_param, search_status): filter_base = "" if client_id: filter_base += f" client_id='{client_id}' " if seach_word: seach_word = f"%{seach_word}%" if filter_base: filter_base += " and " filter_base += f" (`name` like '{seach_word}' or english_name like '{seach_word}') " if search_status and int(search_status): if filter_base: filter_base += " and " filter_base += f" status='{search_status}'" # 搜索bar_code if b_code: if len(b_code) > 10 and str(func_type) == "1": new_code = '' for i in range(int(len(b_code) / 2)): new_code = b_code[i*2:(i+1)*2] + new_code else: new_code = b_code new_code = f"%{new_code}%" if filter_base: filter_base += " and " filter_base += f" bar_code like '{new_code}' or remark12 like '{new_code}' " # if filter_base: # if len(seach_word) > 10: # new_code = '' # for i in range(int(len(seach_word) / 2)): # new_code = seach_word[i*2:(i+1)*2] + new_code # else: # new_code = seach_word # TODO 确认下面这段和上面修改b_code代码作用 # new_code = f"%{new_code}%" # if filter_base: # filter_base += " or " # filter_base += f" (bar_code like '{new_code}' or bar_code like '{seach_word}' )" if func_type: if filter_base: filter_base += " and " filter_base += f" func_type='{func_type}'" if filter_base: filter_base = f" where {filter_base}" sql_all = f""" select * from rms_medicament {filter_base} and status != 3 order by put_in_date desc """ try: count_number = len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 page_param.totalRecords=count_number page_sql = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(page_sql).fetchall() # 选择药剂入库--试剂详情 def get_drug_info_distinct_list(self, seach_word, func_type, page_param, client_id=None): # 动态添加查询条件 filter_base = "" if client_id: filter_base += f"client_id='{client_id}'" if seach_word: seach_word = f"%{seach_word}%" if filter_base: filter_base += " and" filter_base += f" (`name` like '{seach_word}' or english_name like '{seach_word}') " if func_type: if filter_base: filter_base += " and" filter_base += f" func_type='{func_type}' " if filter_base: filter_base = f" where {filter_base}" sql_all = f""" select * from rms_medicament {filter_base} group by `name`, purity, speci order by put_in_date desc """ try: count_number = len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 page_param.totalRecords = count_number # 分页sql page_sql = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(page_sql).fetchall() # 药剂入库 def drugPutIn(self, entityDrug=EntityMedicament(), entityClient=EntityClient(), entityUser=EntityUser()): if entityClient.client_id not in client_list: entityDrugRecord = EntityMedicamentRecord( customer_id=entityClient.customer_id, client_id=entityClient.client_id, client_code=entityClient.client_code, variety_id=entityDrug.variety_id, medicament_id=entityDrug.medicament_id, price=entityDrug.price, record_type=DrugRecordType.PutIn, record_remain=float(entityDrug.remain) if entityDrug.remain else 0, is_empty=0, create_date=Utils.get_str_datetime(), create_user_id=entityUser.user_id, create_user_name=entityUser.real_name, ) # 创建事务 self.beginTrans() entityDrug.remark30 = '0' entityDrug.client_code = entityClient.client_code self.session.add(entityDrug) if entityDrug.status == 1 and entityClient.client_id not in client_list: self.session.add(entityDrugRecord) boolean_ = self.commitTrans() if boolean_ is None: return True return boolean_ # 药剂领用 def drugUse(self, entityDrug=EntityMedicament(), entityClient=EntityClient(), entityUser=EntityUser(),notes=''): #创建事务 self.beginTrans() entityDrug.remark30 = '0' self.session.merge(entityDrug) if entityClient.client_id not in client_list: entityDrugRecord = EntityMedicamentRecord( customer_id=entityClient.customer_id, client_id=entityClient.client_id, client_code=entityClient.client_code, variety_id=entityDrug.variety_id, medicament_id=entityDrug.medicament_id, price=entityDrug.price, record_type=DrugRecordType.Use, is_empty=0, record_remain=float(entityDrug.remain) if entityDrug.remain else 0, create_date=Utils.get_str_datetime(), create_user_id=entityUser.user_id, create_user_name=entityUser.real_name, notes = notes ) self.session.add(entityDrugRecord) entityVariety = BllMedicamentVariety().findEntity(entityDrug.variety_id) entityVariety.normal_count -= 1 entityVariety.use_count += 1 self.session.merge(entityVariety) self.commitTrans() # 药剂归还 def drugReturn(self, entityDrug=EntityMedicament(), entityClient=EntityClient(), entityUser=EntityUser()): #创建事务 self.beginTrans() entityDrug.remark30 = '0' self.session.merge(entityDrug) drug = BllMedicament().findEntity(entityDrug.medicament_id) lastRemain = float(drug.remain) if drug.remain else 0 if entityClient.client_id not in client_list: entityDrugRecord = EntityMedicamentRecord( customer_id=entityClient.customer_id, client_id=entityClient.client_id, client_code=entityClient.client_code, variety_id=entityDrug.variety_id, medicament_id=entityDrug.medicament_id, price=float(entityDrug.price) if entityDrug.price else 0, use_quantity=float(lastRemain) - float(entityDrug.remain if entityDrug.remain else 0), record_type=DrugRecordType.Return, record_remain=float(entityDrug.remain) if entityDrug.remain else 0, is_empty=1 if(entityDrug.status == DrugStatus.Empty) else 0, create_date=Utils.get_str_datetime(), create_user_id=entityUser.user_id, create_user_name=entityUser.real_name, ) # 液体用量数据保存 medicament_variety_obj = BllMedicamentVariety().findEntity( EntityMedicamentVariety.variety_id == entityDrug.variety_id) if medicament_variety_obj.net_weight_unit == 'ml' and medicament_variety_obj.density: use_volume = (float(lastRemain) - float( entityDrug.remain if entityDrug.remain else 0)) / medicament_variety_obj.density entityDrugRecord.use_volume = use_volume self.session.add(entityDrugRecord) entityVariety = BllMedicamentVariety().findEntity(entityDrug.variety_id) if(entityDrug.remain != 0): entityVariety.normal_count += 1 else: entityVariety.empty_count += 1 entityVariety.use_count -= 1 self.session.merge(entityVariety) self.commitTrans() remain_result = self.calculate_use_drug(drug, weight_remain=float(entityDrug.remain if entityDrug.remain else 0)) return remain_result # 药剂登记 def drugRegister(self, entityDrug, entityClient=EntityClient(), entityUser=EntityUser()): #创建事务 self.beginTrans() entityDrug.remark30 = '0' self.session.merge(entityDrug) drug = BllMedicament().findEntity(entityDrug.medicament_id) lastRemain = float(drug.remain) entityDrugRecord = EntityMedicamentRecord( customer_id=entityClient.customer_id, client_id=entityClient.client_id, client_code=entityClient.client_code, variety_id=entityDrug.variety_id, medicament_id=entityDrug.medicament_id, price=entityDrug.price, use_quantity=float(lastRemain) - float(entityDrug.remain if entityDrug.remain else 0), record_type=DrugRecordType.Register, record_remain=float(entityDrug.remain), is_empty=1 if(entityDrug.status == DrugStatus.Empty) else 0, create_date=Utils.get_str_datetime(), create_user_id=entityUser.user_id, create_user_name=entityUser.real_name, ) self.session.add(entityDrugRecord) self.commitTrans() # 获取领用和归还页面列表 管理员要能看到所有领用/归还列表数据 def drug_use_return(self, status, func_type, user, page_param, is_admin): filter_base = f" status={status} and func_type='{func_type}' " if not is_admin: filter_base += f"and by_user_id='{user.user_id}' " sql_all = f""" select * from rms_medicament where status={status} and func_type='{func_type}' and by_user_id='{user.user_id}' order by by_user_date desc """ print(sql_all,'00909') try: count_number = len(self.execute(sql_all).fetchall()) except: count_number = 0 page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) data_list = self.execute(sql_all).fetchall() return data_list # 获取库存信息总览 def get_stock_all_info(self, page_param, func_type,client_id, name=None, client_place=None): filter_base = "" if name: filter_base = f" `name` LIKE '%{name}%'" if func_type: if filter_base: filter_base += " and " filter_base += f" func_type='{func_type}' " if client_id: if filter_base: filter_base += " and " filter_base += f" client_id='{client_id}' " if filter_base: filter_base = f" where {filter_base}" #TODO 添加房间筛选 filter_base1 = "" if client_place: filter_base1 += f"where place='{client_place}'" # sql_all =f""" # select DISTINCT # `name`, speci, cas_number,net_weight_unit, purity, # manufacturer, distributor, net_weight, net_weight_unit, # client_id, put_in_user_name,category,expiration_date # sum(CASE WHEN `status`=1 THEN 1 ELSE 0 END) count_number, # sum(CASE WHEN `status`=1 THEN remain ELSE 0 END) sum_remain # FROM rms_medicament {filter_base} GROUP BY `name`, speci, purity order by put_in_date desc # """ sql_all = f""" select a.*, b.client_name from ( select DISTINCT `name`, speci, cas_number, purity, manufacturer, distributor, net_weight, net_weight_unit, client_id, put_in_user_name,category,expiration_date,put_in_date, sum(CASE WHEN `status`=1 THEN 1 ELSE 0 END) count_number, sum(CASE WHEN `status`=1 THEN remain ELSE 0 END) sum_remain FROM rms_medicament {filter_base} GROUP BY `name`, speci, purity )a LEFT JOIN ( select * from rms_client {filter_base1} ) b on a.client_id=b.client_id where b.client_name is not null order by a.put_in_date desc """ # 首次查询，判断长度，做分页使用 try: count_number = len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 # 组件分页参数，返回分页后数据 if page_param: page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() #获取所有药剂列表 def getAllDrugList(self, search_word, manufacturer, start_time, end_time, func_type, page_param, seach_user, customer_id=None, client_id=None, client_speci=None): # (Name like :searchWord or BarCode like :searchWord or EnglishName like :searchWord) filter_base = "" if customer_id: filter_base = f"customer_id='{customer_id}'" if client_id: if filter_base: filter_base += " and " filter_base += f"client_id='{client_id}'" # 名称搜索 if search_word: seach_w = f"%{search_word}%" if filter_base: filter_base += " and " bar_code, new_code = Utils.get_bar_code_reverse(search_word) filter_base += f" `name` like '{seach_w}' or english_name like '{seach_w}' or manufacturer like '{seach_w}' " filter_base += f" or bar_code='{bar_code}' or bar_code='{new_code}' " # 厂商搜索 if manufacturer: manufacturer = f"%{manufacturer}%" if filter_base: filter_base += " and " filter_base += f"manufacturer like '{manufacturer}'" # 时间范围搜索 if start_time and end_time: if filter_base: filter_base += " and " filter_base += f"put_in_date >= '{start_time}' and put_in_date<='{end_time}'" # 管理模块区分 if func_type: if filter_base: filter_base += " and " filter_base += f" func_type={func_type}" if seach_user: if filter_base: filter_base += " and " filter_base += f" put_in_user_name like '%{seach_user}%'" if filter_base: filter_base = "where " + filter_base # select * from rms_medicament {filter_base} #TODO 添加房间筛选 filter_base1 = "" if client_speci: filter_base1 += f"where place='{client_speci}'" sql_all = f""" select a.*,b.client_name from ( select name, english_name,bar_code,manufacturer,speci,remain,purity,production_date,shelf_life,expiration_date,put_in_date,put_in_user_name, status,by_user_name,client_id, is_packing, is_label, is_aspect from rms_medicament {filter_base} ) a LEFT JOIN( select client_id,client_name from rms_client {filter_base1} ) b on a.client_id=b.client_id where client_name is not null order by put_in_date desc """ # manufacturer = manufacturer, # start_time = start_time, # end_time = end_time, # 动态添加查询条件 # 获取数量做分页 try: count_number= len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 # 进行分页sql拼接 if page_param: page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() # 入库、领用、归还记录 def drug_show_type_info(self, record_type, start_time, end_time, put_in_user_name, name, func_type, client_id, statue_type, page_param, client_place): filter_base1 = '' if record_type: filter_base1 = f" WHERE record_type={record_type} " if put_in_user_name: filter_base1 += f" and create_user_name like '%{put_in_user_name}%'" if start_time and end_time: filter_base1 += f" and create_date >= '{start_time}' and create_date <= '{end_time}'" if client_id: filter_base1 += f" and client_id='{client_id}'" filter_base2 = '' if name: name = f"%{name}%" filter_base2 += f" (`name` like '{name}' or english_name like '{name}') " if statue_type and statue_type != '100': if filter_base2: filter_base2 += " and " filter_base2 = f" `status`={statue_type}" if func_type: if filter_base2: filter_base2 += " and " filter_base2 += f" func_type='{func_type}' " if filter_base2: filter_base2 = f" where {filter_base2}" #TODO 添加房间筛选 filter_base = "" if client_place: filter_base += f"where place='{client_place}'" sql_all = f""" select record_type, `name`, english_name, bar_code, purity, cas_number, speci, use_quantity, use_volume, `status`, create_date, create_user_name, a.client_id, client_code, client_name, unit_code from (select * from rms_medicament_record {filter_base1} ) as a LEFT JOIN( select medicament_id, `name`, english_name, bar_code, purity, speci, cas_number, net_weight, remain, `status`, by_user_date, by_user_name, unit_code FROM rms_medicament {filter_base2} ) as b on a.medicament_id=b.medicament_id LEFT JOIN(select client_id,client_name from rms_client {filter_base}) c on a.client_id=c.client_id where name is not null and client_name is not null ORDER BY create_date desc """ try: count_number = len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 if page_param: page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() def drug_show_un_warehoused_type_info(self, **kwargs): """ 未入库记录（未归还） :param kwargs: record_type, start_time, end_time, put_in_user_name, name, func_type, client_id, statue_type, page_param, client_place :return: """ filter_base1 = " where record_type=2 " if kwargs.get("put_in_user_name"): filter_base1 += f" and create_user_name like '%{kwargs.get('put_in_user_name')}%'" if kwargs.get("start_time") and kwargs.get("end_time"): filter_base1 += f" and create_date >= '{kwargs.get('start_time')}' and create_date <= '{kwargs.get('end_time')}'" if kwargs.get("client_id"): filter_base1 += f" and client_id='{kwargs.get('client_id')}'" filter_base2 = " `status` = 2 " if kwargs.get("func_type"): if filter_base2: filter_base2 += " and " filter_base2 += f" func_type='{kwargs.get('func_type')}' " if filter_base2: filter_base2 = f" where {filter_base2}" filter_base = "" if kwargs.get("client_place"): filter_base += f"where place='{kwargs.get('client_place')}'" sql_all = f""" select `name`, english_name, bar_code, purity, cas_number, speci, use_quantity, use_volume, `status`, create_date, create_user_name, a.client_id, client_code, client_name, unit_code from (select * from rms_medicament_record {filter_base1} ) as a LEFT JOIN( select medicament_id, `name`, english_name, bar_code, purity, speci, cas_number, net_weight, remain, `status`, by_user_date, by_user_name, unit_code FROM rms_medicament {filter_base2} ) as b on a.medicament_id=b.medicament_id LEFT JOIN(select client_id,client_name from rms_client {filter_base}) c on a.client_id=c.client_id where name is not null and client_name is not null GROUP BY b.medicament_id ORDER BY create_date desc """ try: count_number = len(self.execute(sql_all).fetchall()) except Exception: count_number = 0 if kwargs["page_param"]: kwargs["page_param"].totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, kwargs["page_param"]) return self.execute(sql_all).fetchall(), count_number def client_room_number(self): sql_all = """ select sum(record_num) value, client_speci name from ( select medicament_id, client_id from rms_medicament ) as a LEFT JOIN( SELECT count(*) record_num, medicament_id FROM rms_medicament_record WHERE record_type=2 GROUP BY medicament_id ) as b on a.medicament_id=b.medicament_id LEFT JOIN rms_client as c on a.client_id=c.client_id GROUP BY client_speci HAVING client_speci is not null """ return self.execute(sql_all).fetchall() # 手动输入入库模板时，获取分组后的试剂信息列表 def drug_group_info_list(self): sql_all = f""" select medicament_id, name as value, english_name, cas_number, purity, production_date, expiration_date, manufacturer,distributor,speci, net_weight_unit, total from rms_medicament group by `name`, speci, purity """ return self.execute(sql_all).fetchall() # 库存盘点获取分组后的试剂信息数据 def get_drug_stock_info(self, client_id): sql_all = f""" select count(*) stock_num, `name`, speci, purity from rms_medicament where client_id= '{client_id}' group by `name`, speci, purity """ return self.execute(sql_all).fetchall() # 可领用试剂列表 def use_drug_info_list(self, client_id, seach_word, page_param): filter_base = "" if client_id: filter_base += f"client_id='{client_id}'" if seach_word: if filter_base: filter_base += " and " name = f"%{seach_word}%" filter_base += f" (`name` like '{name}' or english_name like '{name}') " if filter_base: filter_base = f" and {filter_base}" # sql_all = f""" # select a.*,b.client_name from ( # select # `name`, speci, purity, count(*) drug_num, manufacturer, distributor,client_id,medicament_id # from # rms_medicament WHERE `status`=1 {filter_base} # GROUP BY # `name`, speci, purity, client_id # ) a LEFT JOIN ( # select * from rms_client # ) b on a.client_id = b.client_id # """ sql_all = f""" select a.*,b.client_name from ( select * from rms_medicament WHERE rms_medicament.func_type=1 and `status`=1 {filter_base} ) a LEFT JOIN ( select * from rms_client WHERE rms_client.place =10 ) b on a.client_id = b.client_id """ try: count_number = self.execute(f"select count(*) num from ({sql_all}) a").fetchone().num except Exception: count_number = 0 if page_param: page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() # 获取待入库and待归还试剂数据 def get_drug_type_list(self, status, client_id, page_param, user_id): filter_base = "" if status: filter_base += f" status={status} " if filter_base: filter_base += " and " if status == 5: filter_base += f" put_in_user_id='{user_id}'" else: filter_base += f" by_user_id='{user_id}'" if client_id =='72e70542-b70d-11e8-aea5-448a5bc6c411': if filter_base: filter_base += " and " filter_base += f" client_id in ('72e70542-b70d-11e8-aea5-448a5bc6c411','72e70542-b70d-11e8-aea5-448a5bc6c412','72e70542-b70d-11e8-aea5-448a5bc6c413','72e70542-b70d-11e8-aea5-448a5bc6c414') " if client_id =='72e70542-b70d-11e8-aea5-448a5bc6c415': if filter_base: filter_base += " and " filter_base += f" client_id in ('72e70542-b70d-11e8-aea5-448a5bc6c415','72e70542-b70d-11e8-aea5-448a5bc6c416') " if client_id =='72e70542-b70d-11e8-aea5-448a5bc6c417': if filter_base: filter_base += " and " filter_base += f" client_id in ('72e70542-b70d-11e8-aea5-448a5bc6c417') " if filter_base: filter_base = f" where {filter_base}" sql_all = f""" select * from rms_medicament {filter_base} """ print(sql_all) try: count_number = self.execute(f"select count(*) num from rms_medicament {filter_base} ").fetchone().num except Exception: count_number = 0 if page_param: page_param.totalRecords = count_number sql_all = Utils.sql_paging_assemble(sql_all, page_param) return self.execute(sql_all).fetchall() # 获取待入库and待归还试剂数据 def get_drug_type_list2(self, user_id): sql_all = f""" select * from rms_medicament where client_id in ('72e70542-b70d-11e8-aea5-448a5bc6c411','72e70542-b70d-11e8-aea5-448a5bc6c412','72e70542-b70d-11e8-aea5-448a5bc6c413','72e70542-b70d-11e8-aea5-448a5bc6c414','72e70542-b70d-11e8-aea5-448a5bc6c415','72e70542-b70d-11e8-aea5-448a5bc6c416','72e70542-b70d-11e8-aea5-448a5bc6c417') and ((status=5 and put_in_user_id='{user_id}') or (status=2 and by_user_id='{user_id}')) """ data =self.execute(sql_all).fetchall() if data: return True else: return False def getDrugSetPotionStorageIn(self,name,clientId=""): #print('clientId',clientId) allLabelSqlStr="SELECT group_concat(remark3) AS allLabels FROM( SELECT DISTINCT b.remark3 FROM rms_medicament as a LEFT JOIN rms_variety as b ON a.`name`=b.`name` WHERE b.purity='权限设置' and a.status=1 AND a.client_id='"+clientId+"')T" allLabels= self.execute(allLabelSqlStr).fetchone()[0] #print('allLabels:',allLabels) if allLabels: allLabelList=allLabels.split(',') drugVarietyEntity= BllVariety().findEntity(and_(EntityVariety.name==name,EntityVariety.purity=='权限设置')) #print('drugVarietyEntity.Remark3:',drugVarietyEntity.Remark3) if drugVarietyEntity: for sx in drugVarietyEntity.remark3.split(','): #print('sx:',sx) drugLabelsSqlstr="SELECT name2 AS reagent,relation FROM rms_medicament_relation a WHERE a.name1='"+sx+"' UNION SELECT name1 AS reagent,relation FROM rms_medicament_relation a WHERE a.name2='"+sx+"'" drugLabelList=self.execute(drugLabelsSqlstr).fetchall() #print('drugLabelList:',drugLabelList) for item in drugLabelList: if(item[0] in allLabelList): return(False,item[1]) return(True,'') else: return(True,'') else: return(True,'') def inster_log_shiji(self): import random name_list = ["砷", "硫酸", "氧化钠"] obj_list = [] for i in range(100): obj = EntityMedicament( bar_code= 10000 + i, client_id='1c39cb24-07f8-11ed-abd4-f47b094925e1', client_code="12345", name=random.choice(name_list), production_date=Utils.get_str_datetime(), shelf_life=10, remain=100, total=500, net_weight_unit="g", net_weight=100, purity="国标", put_in_date=Utils.get_str_datetime(), put_in_user_id='4cea74ee-0d8b-11ed-943e-f47b094925e1', put_in_user_name="admin", status=random.randint(1,3) ) obj_list.append(obj) self.insert_many(obj_list) def get_last_drug(self, client_id, drug_name, put_in_date, func_type): """ 判断获取最早入库试剂信息 """ filter_base = "" if func_type: filter_base += f"func_type='{func_type}'" if client_id: if filter_base: filter_base += " and " filter_base += f"client_id='{client_id}'" if drug_name: if filter_base: filter_base += " and " filter_base += f" `name`='{drug_name}' " if filter_base: filter_base = f" and {filter_base}" sql_all = f""" select a.*,b.client_name from ( select * from rms_medicament WHERE `status`=1 {filter_base} ) a LEFT JOIN ( select * from rms_client ) b on a.client_id = b.client_id order by a.put_in_date asc """ medicament_obj = self.execute(sql_all).fetchone() return medicament_obj def get_drug_total_num(self, filter_base): """ 获取药剂总数 :param filter_base: :return: """ if filter_base: filter_base = f" and {filter_base}" sql_all = f""" select count(medicament_id) count_number from rms_medicament where `status` != 3 {filter_base} """ # 查看分组数据 data = self.execute(sql_all).fetchone() return data.count_number if data.count_number else 0 def get_chemicals_total_num(self): """ 获取化学品总数量 :return: """ num = self.get_drug_total_num('') return num def get_chemicals_total_weight(self): """ 获取化学品总重量 :return: """ sql_all = f""" select sum(remain) total_weight from rms_medicament where `status` != 3 """ # 查看分组数据 data = self.execute(sql_all).fetchone() return data.total_weight if data.total_weight else 0 def get_chemicals_other_total_num(self): """ 获取其他化学品总数量 :return: standard_num 普通危化总数 2 reagent_num 易制毒易制爆总数 1 consumables_num 对照品数量 3 """ standard_num = self.get_drug_total_num("func_type=2") reagent_num = self.get_drug_total_num("func_type=1") consumables_num = self.get_drug_total_num("func_type=3") return standard_num, reagent_num, consumables_num def update_expiration_date(self, drug_entry): """ 更改试剂有效期 液体1年 ，普通固体5年， 易潮解固体2年 :param drug_entry: :return: """ # 从分类表中获取时间年份 medicament_variety_obj = BllMedicamentVariety().findEntity( EntityMedicamentVariety.variety_id == drug_entry.variety_id) if not medicament_variety_obj: return add_year = int(medicament_variety_obj.remark5) if medicament_variety_obj.remark5 else 1 date_now = datetime.datetime.now() add_expiration_date = (date_now + relativedelta(years=add_year)).strftime("%Y-%m-%d %H:%M:%S") if not drug_entry.expiration_date or add_expiration_date > str(drug_entry.expiration_date): return else: drug_entry.expiration_date = add_expiration_date self.beginTrans() self.session.merge(drug_entry) self.commitTrans() @staticmethod def calculate_use_drug(drug, weight_remain=0.0): """ 计算用量 :return: {"is_liquid": 是否为液体, "use_volume": 液体用量, "use_quality": 固体用量, "net_weight_unit": 单位} """ if not drug.remain: return medicament_variety_obj = BllMedicamentVariety().findEntity( EntityMedicamentVariety.variety_id == drug.variety_id) remain_result = { "is_liquid": False, "use_volume": 0, "use_quality": float(drug.remain) - float(weight_remain), "net_weight_unit": medicament_variety_obj.net_weight_unit } # 液体 if medicament_variety_obj.net_weight_unit == 'ml' and medicament_variety_obj.density: use_volume = remain_result["use_quality"] / medicament_variety_obj.density remain_result["is_liquid"] = True remain_result["use_volume"] = Utils.reserve_decimal(use_volume, 2) return remain_result if __name__ == '__main__': data = BllMedicament().getDrugSetPotionStorageIn("2-氨基苯酚", '1c39cb24-07f8-11ed-abd4-f47b094925e1') print(data) # from db_logic.medicament import BllMedicament # from Common.Utils import PageParam # page_param = PageParam(1, 10) # data = BllMedicament().inster_log_shiji() # print(data) # values= {} # page = values.get("page", 1) # page_size = values.get("page_size", 10) # record_type = values.get("record_type", 1) # put_in_user_name = values.get("put_in_user_name") # name = values.get("name") # start_time = values.get("start_time") # end_time = values.get("end_time") # page_param = PageParam(page, page_size) # typ_dic = BllMedicament().drug_show_type_info(record_type=record_type, put_in_user_name=put_in_user_name, # name=name, start_time=start_time, end_time=end_time, page_param=page_param # ) # print(typ_dic)