#!/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 ) :
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 } ' ) "
# 搜索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 " : 单位 }
"""
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)
