manage_center_service.go 43KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174
  1. package service
  2. import (
  3. "strconv"
  4. "strings"
  5. "time"
  6. "XT_New/models"
  7. "github.com/jinzhu/gorm"
  8. )
  9. func GetDictionaryConfigList(orgID int64) (dataconfig interface{}, err error) {
  10. var configList []*models.DictionaryDataconfig
  11. err = readDb.Model(&models.DictionaryDataconfig{}).Where("(org_id in (0,?) and status = 1) or (status = 0 and delete_id_system > 0 and org_id = ?)", orgID, orgID).Order("orders asc, id asc").Find(&configList).Error
  12. if err != nil {
  13. return nil, err
  14. }
  15. // configResult := make([]*ConfigViewModel,0)
  16. childConfig := make(map[int64][]*models.DictionaryDataconfig)
  17. resultConfig := make(map[string][]*models.DictionaryConfigViewModel)
  18. deleteSystemChilds := make([]*models.DictionaryDataconfig, 0)
  19. editSystemChilds := make([]*models.DictionaryDataconfig, 0)
  20. for _, config := range configList {
  21. if config.Status == 1 && config.DeleteIdSystem > 0 {
  22. editSystemChilds = append(editSystemChilds, config)
  23. }
  24. if config.Status == 0 && config.DeleteIdSystem > 0 {
  25. deleteSystemChilds = append(deleteSystemChilds, config)
  26. }
  27. }
  28. continueFlag := false
  29. for _, config := range configList {
  30. continueFlag = false
  31. if config.ParentId == 0 {
  32. newConfig := &models.DictionaryConfigViewModel{
  33. ID: config.ID,
  34. ParentId: config.ParentId,
  35. Module: config.Module,
  36. OrgId: config.OrgId,
  37. Name: config.Name,
  38. FieldName: config.FieldName,
  39. Value: config.Value,
  40. CreateUserId: config.CreateUserId,
  41. Status: config.Status,
  42. Remark: config.Remark,
  43. Title: config.Title,
  44. Content: config.Content,
  45. }
  46. // configResult = append(configResult,newConfig)
  47. result := resultConfig[config.Module]
  48. if result == nil {
  49. result = make([]*models.DictionaryConfigViewModel, 0)
  50. }
  51. for _, vm := range editSystemChilds {
  52. if vm.DeleteIdSystem == config.ID {
  53. continueFlag = true
  54. break
  55. }
  56. }
  57. for _, _vm := range deleteSystemChilds {
  58. if _vm.DeleteIdSystem == config.ID {
  59. continueFlag = true
  60. break
  61. }
  62. }
  63. if config.OrgId != 0 && config.Status == 0 && config.DeleteIdSystem > 0 {
  64. continue
  65. }
  66. if continueFlag {
  67. continue
  68. }
  69. result = append(result, newConfig)
  70. resultConfig[config.Module] = result
  71. } else {
  72. childs := childConfig[config.ParentId]
  73. if childs == nil {
  74. childs = make([]*models.DictionaryDataconfig, 0)
  75. }
  76. continueFlag := false
  77. for _, vm := range editSystemChilds {
  78. if vm.DeleteIdSystem == config.ID {
  79. continueFlag = true
  80. break
  81. }
  82. }
  83. for _, _vm := range deleteSystemChilds {
  84. if _vm.DeleteIdSystem == config.ID {
  85. continueFlag = true
  86. break
  87. }
  88. }
  89. if config.OrgId != 0 && config.Status == 0 && config.DeleteIdSystem > 0 {
  90. continue
  91. }
  92. if continueFlag {
  93. continue
  94. }
  95. childs = append(childs, config)
  96. childConfig[config.ParentId] = childs
  97. }
  98. }
  99. for _, vm := range resultConfig {
  100. for _, _vm := range vm {
  101. _vm.Childs = childConfig[_vm.ID]
  102. }
  103. // vm.Childs = childConfig[vm.ID]
  104. }
  105. return resultConfig, err
  106. }
  107. func CreateDictionaryConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  108. // readDb.Model(&models.Dataconfig{}).Where("module = ? and parent_id = 0 and org_id in (0,?)",dataconfig.Module,dataconfig.OrgId).Count(&total)
  109. err = readDb.Create(&dataconfig).Error
  110. return
  111. }
  112. func GetDictionaryChildValue(module string, parent_id int64, org_id int64) (value int) {
  113. readDb.Model(&models.DictionaryDataconfig{}).Where("module=? and parent_id=? and org_id in (0,?)", module, parent_id, org_id).Count(&value)
  114. return
  115. }
  116. func FindDictionaryConfigByTitle(module string, title string, org_id int64) (dataconfig models.DictionaryDataconfig, err error) {
  117. err = readDb.Model(&models.DictionaryDataconfig{}).Where("module=? and title=? and org_id in (0,?) and status = 1", module, title, org_id).First(&dataconfig).Error
  118. return
  119. }
  120. func UpdateDictionaryTemplate(dataconfig *models.DictionaryDataconfig) (err error) {
  121. err = readDb.Model(&models.DictionaryDataconfig{}).Where("id =?", dataconfig.ID).Update(map[string]interface{}{"title": dataconfig.Title, "content": dataconfig.Content, "update_time": dataconfig.UpdatedTime, "remark": dataconfig.Remark}).Error
  122. return
  123. }
  124. func UpdateDictionaryChildConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  125. err = readDb.Model(&models.DictionaryDataconfig{}).Where("id =?", dataconfig.ID).Update(map[string]interface{}{"name": dataconfig.Name, "update_time": dataconfig.UpdatedTime, "remark": dataconfig.Remark, "orders": dataconfig.Order, "code": dataconfig.Code}).Error
  126. return
  127. }
  128. func DeleteDictionaryChildConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  129. err = readDb.Model(&models.DictionaryDataconfig{}).Where("id =?", dataconfig.ID).Update(map[string]interface{}{"status": dataconfig.Status, "update_time": dataconfig.UpdatedTime}).Error
  130. return
  131. }
  132. func CreateBaseDrugLib(lib *models.BaseDrugLib) (err error) {
  133. err = writeDb.Create(&lib).Error
  134. return
  135. }
  136. func UpdateBaseDrugLib(lib *models.BaseDrugLib) (err error) {
  137. err = writeDb.Save(lib).Error
  138. return
  139. }
  140. func FindBaseDrugLibRecordCount(lib *models.BaseDrugLib) (count int64) {
  141. readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? AND drug_name = ? AND drug_category = ? AND drug_spec=? AND drug_type=? AND status = 1", lib.OrgId, lib.DrugName, lib.DrugCategory, lib.DrugSpec, lib.DrugType).Count(&count)
  142. return
  143. }
  144. func FindBaseDrugLibRecordCountOne(lib *models.BaseDrugLib) (count int64) {
  145. readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? and drug_name = ? and dose = ? and dose_unit = ? and min_number = ? and min_unit = ? and max_unit = ? and manufacturer = ? and status = 1", lib.OrgId, lib.DrugName, lib.Dose, lib.DoseUnit, lib.MinNumber, lib.MinUnit, lib.MaxUnit, lib.Manufacturer).Count(&count)
  146. return
  147. }
  148. func FindAllDrugLibRecordTotal(org_id int64) (count int64) {
  149. readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? AND status = 1", org_id).Count(&count)
  150. return
  151. }
  152. func FindBaseDrugLibRecord(org_id int64, id int64) (lib models.BaseDrugLib, err error) {
  153. err = readDb.Model(&models.BaseDrugLib{}).Where("id = ? AND org_id = ? AND status = 1", id, org_id).First(&lib).Error
  154. return
  155. }
  156. func FindNewBaseDrugLibRecord(org_id int64, id int64, tx *gorm.DB) (lib models.BaseDrugLib, err error) {
  157. err = tx.Model(&models.BaseDrugLib{}).Where("id = ? AND org_id = ? AND status = 1", id, org_id).First(&lib).Error
  158. if err != gorm.ErrRecordNotFound {
  159. if err != nil {
  160. tx.Rollback()
  161. return
  162. }
  163. }
  164. return lib, err
  165. }
  166. func FindBaseDrugLibRecordSeven(org_id int64, id int64) (lib models.BaseDrugLibSeven, err error) {
  167. err = readDb.Select("id,drug_name,max_unit,min_number,min_unit,sum_count,is_user,is_pharmacy").Where("org_id = ? AND id = ? AND status = 1", org_id, id).First(&lib).Error
  168. return
  169. }
  170. func GetDrugAutoWarehouseOut(patient_id int64, advicedate int64, drugid int64) (*models.DrugWarehouseOutInfo, error) {
  171. detail := models.DrugWarehouseOutInfo{}
  172. err := XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1", patient_id, advicedate, drugid).Find(&detail).Error
  173. if err == gorm.ErrRecordNotFound {
  174. return nil, err
  175. }
  176. if err != nil {
  177. return nil, err
  178. }
  179. return &detail, nil
  180. }
  181. func GetDrugAutoWarehouseOutSeven(patient_id int64, advicedate int64, drugid int64, adviceid int64) (*models.DrugWarehouseOutInfo, error) {
  182. detail := models.DrugWarehouseOutInfo{}
  183. err := XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&detail).Error
  184. if err == gorm.ErrRecordNotFound {
  185. return nil, err
  186. }
  187. if err != nil {
  188. return nil, err
  189. }
  190. return &detail, nil
  191. }
  192. func GetDrugAutoWarehouseOutEight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (models.DrugWarehouseOutInfo, error) {
  193. detail := models.DrugWarehouseOutInfo{}
  194. err = XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&detail).Error
  195. return detail, err
  196. }
  197. func GetSelfDrugAutoWarehouseOutEight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (models.XtSelfDrugWarehouseOutInfo, error) {
  198. detail := models.XtSelfDrugWarehouseOutInfo{}
  199. err = XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&detail).Error
  200. return detail, err
  201. }
  202. func GetDrugAutoWarehouseOutTen(patient_id int64, advicedate int64, drugid int64, adviceid int64, warehouse_info_id int64) (models.DrugWarehouseOutInfo, error) {
  203. detail := models.DrugWarehouseOutInfo{}
  204. err = XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ? and warehouse_info_id = ?", patient_id, advicedate, drugid, adviceid, warehouse_info_id).Find(&detail).Error
  205. return detail, err
  206. }
  207. func GetSelfDrugAutoWarehouseOutTen(patient_id int64, advicedate int64, drugid int64, adviceid int64, warehouse_info_id int64) (models.XtSelfDrugWarehouseOutInfo, error) {
  208. detail := models.XtSelfDrugWarehouseOutInfo{}
  209. err = XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ? and warehouse_info_id = ?", patient_id, advicedate, drugid, adviceid, warehouse_info_id).Find(&detail).Error
  210. return detail, err
  211. }
  212. func GetDrugAutoWarehouseOutNight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (night []*models.DrugWarehouseOutInfo, err error) {
  213. err = XTReadDB().Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&night).Error
  214. return night, err
  215. }
  216. func GetSelfDrugAutoWarehouseOutNight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (night []*models.XtSelfDrugWarehouseOutInfo, err error) {
  217. err = XTReadDB().Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&night).Error
  218. return night, err
  219. }
  220. func ModifyDrugWarehouseInfoId(id int64, count int64) error {
  221. err = XTWriteDB().Model(&models.DrugWarehouseInfo{}).Where("id = ? and status=1", id).UpdateColumn("sum_count", gorm.Expr("sum_count + ?", count)).Error
  222. return err
  223. }
  224. func UpdateDrugWarehouse(id int64, info models.DrugWarehouseInfo) error {
  225. err := writeDb.Model(&models.DrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_min_number", gorm.Expr("stock_min_number + ?", info.StockMinNumber)).Error
  226. return err
  227. }
  228. func UpdateSelfDrugWarehouseOne(id int64, info models.XtSelfDrugWarehouseInfo) error {
  229. err := writeDb.Model(&models.XtSelfDrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_min_number", gorm.Expr("stock_min_number + ?", info.StockMinNumber)).Error
  230. return err
  231. }
  232. func UpdateDrugWarehouseOne(id int64, info models.DrugWarehouseInfo) error {
  233. err := writeDb.Model(&models.DrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_max_number", gorm.Expr("stock_max_number + ?", info.StockMaxNumber)).Error
  234. return err
  235. }
  236. func UpdateSelfDrugWarehouseTwo(id int64, info models.XtSelfDrugWarehouseInfo) error {
  237. err := writeDb.Model(&models.XtSelfDrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_max_number", gorm.Expr("stock_max_number + ?", info.StockMaxNumber)).Error
  238. return err
  239. }
  240. func GetBaseDrugLibList(org_id int64, keyword string, page int64, limit int64, is_use int64, is_charge int64, is_inject int64, manufacturer int64, isRecord int64) (list []*models.BaseDrugLib, total int64, err error) {
  241. db := readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? AND status = 1", org_id)
  242. if len(keyword) != 0 {
  243. keyword = "%" + keyword + "%"
  244. db = db.Where("drug_name Like ?", keyword)
  245. }
  246. if is_use != 0 {
  247. if is_use == 2 {
  248. db = db.Where("find_in_set('停用',drug_status) = 0")
  249. } else {
  250. db = db.Where("find_in_set('停用',drug_status) > 0")
  251. }
  252. }
  253. if is_charge == 1 {
  254. //if is_charge == 1 {
  255. // db = db.Where("find_in_set('收费',drug_status) > 0")
  256. //
  257. //} else {
  258. // db = db.Where("find_in_set('收费',drug_status) = 0")
  259. //}
  260. db = db.Where("is_record = ?", is_charge)
  261. }
  262. if is_charge == 2 {
  263. db = db.Where("is_record= 0 || is_record = 2")
  264. }
  265. if is_inject != 0 {
  266. //db = db.Where("drug_name Like ?", keyword)
  267. if is_inject == 1 {
  268. db = db.Where("find_in_set('注射类',drug_status) > 0")
  269. } else {
  270. db = db.Where("find_in_set('注射类',drug_status) = 0")
  271. }
  272. }
  273. if manufacturer > 0 {
  274. db = db.Where("manufacturer = ?", manufacturer)
  275. }
  276. if isRecord > 0 {
  277. db = db.Where("is_mark = ?", isRecord)
  278. }
  279. offset := (page - 1) * limit
  280. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  281. return
  282. }
  283. func CreateMedicineInsurancePercentage(mip *models.MedicineInsurancePercentage) (err error) {
  284. err = writeDb.Create(mip).Error
  285. return
  286. }
  287. func CreateUnitSafeguard(dus *models.DrugUnitSafeguard) (err error) {
  288. err = writeDb.Create(dus).Error
  289. return
  290. }
  291. func AddSigleMZSick(dealer *models.OutpatientServiceSick) (error, *models.OutpatientServiceSick) {
  292. err := writeDb.Create(&dealer).Error
  293. return err, dealer
  294. }
  295. func ModifyMZSick(mesick *models.OutpatientServiceSick) error {
  296. err := writeDb.Save(&mesick).Error
  297. return err
  298. }
  299. func FindAllMZSickList(orgId int64, page int64, limit int64) (list []*models.OutpatientServiceSick, total int64, err error) {
  300. offset := (page - 1) * limit
  301. db := readDb.Model(&models.OutpatientServiceSick{})
  302. db = db.Where("user_org_id = ? AND status = 1", orgId)
  303. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  304. return
  305. }
  306. func DeleteMZSickById(id int64) error {
  307. err := writeDb.Model(&models.OutpatientServiceSick{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  308. return err
  309. }
  310. func FindMZSickById(id int64) (*models.OutpatientServiceSick, error) {
  311. dealer := &models.OutpatientServiceSick{}
  312. err := readDb.Model(&models.OutpatientServiceSick{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  313. return dealer, err
  314. }
  315. func GetDrugWareoutInfo(id int64) (*models.XtDrugWarehouseInfo, error) {
  316. info := models.XtDrugWarehouseInfo{}
  317. err = XTReadDB().Model(&info).Where("drug_id = ? and status = 1", id).Find(&info).Error
  318. if err == gorm.ErrRecordNotFound {
  319. return nil, err
  320. }
  321. if err != nil {
  322. return nil, err
  323. }
  324. return &info, nil
  325. }
  326. func GetDrugWareOutById(id int64) (*models.XtDrugWarehouseOutInfo, error) {
  327. info := models.XtDrugWarehouseOutInfo{}
  328. err := XTReadDB().Model(&info).Where("drug_id = ? and status = 1", id).Find(&info).Error
  329. if err == gorm.ErrRecordNotFound {
  330. return nil, err
  331. }
  332. if err != nil {
  333. return nil, err
  334. }
  335. return &info, nil
  336. }
  337. func DeleteBaseDrugById(id int64) error {
  338. drug := models.XtBaseDrug{}
  339. err := XTWriteDB().Model(&drug).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"status": 0}).Error
  340. return err
  341. }
  342. func AddSigleAddition(dealer *models.XtHisAddtionConfig) (error, *models.XtHisAddtionConfig) {
  343. err := writeDb.Create(&dealer).Error
  344. return err, dealer
  345. }
  346. func ModifyAddition(mesick *models.XtHisAddtionConfig) error {
  347. err := writeDb.Save(&mesick).Error
  348. return err
  349. }
  350. func FindAllAdditionList(orgId int64, page int64, limit int64) (list []*models.XtHisAddtionConfig, total int64, err error) {
  351. offset := (page - 1) * limit
  352. db := readDb.Model(&models.XtHisAddtionConfig{})
  353. db = db.Where("user_org_id = ? AND status = 1", orgId)
  354. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  355. return
  356. }
  357. func DeleteAdditionById(id int64) error {
  358. err := writeDb.Model(&models.XtHisAddtionConfig{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  359. return err
  360. }
  361. func FindAdditionById(id int64) (*models.XtHisAddtionConfig, error) {
  362. dealer := &models.XtHisAddtionConfig{}
  363. err := readDb.Model(&models.XtHisAddtionConfig{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  364. return dealer, err
  365. }
  366. func AddSigleDiagnose(dealer *models.HisXtDiagnoseConfig) (error, *models.HisXtDiagnoseConfig) {
  367. err := writeDb.Create(&dealer).Error
  368. return err, dealer
  369. }
  370. func ModifyDiagnose(mesick *models.HisXtDiagnoseConfig) error {
  371. err := writeDb.Save(&mesick).Error
  372. return err
  373. }
  374. func FindAllDiagnoseList(orgId int64, page int64, limit int64) (list []*models.HisXtDiagnoseConfig, total int64, err error) {
  375. offset := (page - 1) * limit
  376. db := readDb.Model(&models.HisXtDiagnoseConfig{})
  377. db = db.Where("user_org_id = ? AND status = 1", orgId)
  378. err = db.Count(&total).Offset(offset).Limit(limit).Order("sort asc").Find(&list).Error
  379. return
  380. }
  381. func DeleteDiagnoseById(id int64) error {
  382. err := writeDb.Model(&models.HisXtDiagnoseConfig{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  383. return err
  384. }
  385. func FindDiagnoseById(id int64) (*models.HisXtDiagnoseConfig, error) {
  386. dealer := &models.HisXtDiagnoseConfig{}
  387. err := readDb.Model(&models.HisXtDiagnoseConfig{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  388. return dealer, err
  389. }
  390. func GetDoseCode(dose_id int64, user_org_id int64) (error, string) {
  391. var data models.DictDataconfig
  392. err := readDb.Model(&models.DictDataconfig{}).Where(" (user_org_id = ? Or user_org_id = 0) AND parent_id = 4 AND module = 'system' AND status = 1 AND value = ?", user_org_id, dose_id).First(&data).Error
  393. return err, data.Code
  394. }
  395. func GetAllDrugList(orgid int64) (drug []*models.BaseDrugLib, err error) {
  396. err = XTReadDB().Model(&drug).Where("org_id = ? and status = 1", orgid).Find(&drug).Error
  397. return drug, err
  398. }
  399. func GetAllMapDrugList(orgid int64) (drug []*models.BaseDrugLibSeven, err error) {
  400. err = XTReadDB().Model(&drug).Where("org_id = ? and status = 1", orgid).Find(&drug).Error
  401. return drug, err
  402. }
  403. //自动退库分装方法
  404. func DrugAutoAddCancelInfo(advice *models.HisDoctorAdviceInfo, creater int64) error {
  405. //查询该批次病人该药品出库数据
  406. info, _ := GetDrugAutoWarehouseOutEight(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID)
  407. list, _ := GetDrugAutoWarehouseOutNight(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID)
  408. storeHouseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  409. //退库
  410. drug, _ := FindBaseDrugLibRecord(advice.UserOrgId, advice.DrugId)
  411. //如果剩余数量 + 退库数量 < 总入库数量
  412. if len(list) > 0 {
  413. for _, its := range list {
  414. //查询该批次病人该药品出库数据
  415. infos, _ := GetDrugAutoWarehouseOutTen(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID, its.WarehouseInfoId)
  416. //查询该药品出库批次总入库数量
  417. druginfo, _ := GetDrugInfoSix(its.WarehouseInfoId, infos.OrgId)
  418. var out_count int64 //该批次出库库存
  419. var sum_count int64 //该批次总库存
  420. var over_count int64 //剩余数量
  421. if druginfo.MaxUnit != druginfo.MinUnit {
  422. over_count = druginfo.StockMaxNumber*drug.MinNumber + druginfo.StockMinNumber
  423. }
  424. if druginfo.MaxUnit == druginfo.MinUnit {
  425. over_count = druginfo.StockMaxNumber + druginfo.StockMinNumber
  426. }
  427. if infos.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  428. out_count = infos.Count * drug.MinNumber
  429. }
  430. if infos.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  431. out_count = infos.Count
  432. }
  433. if infos.CountUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  434. out_count = infos.Count
  435. }
  436. if druginfo.MaxUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  437. sum_count = druginfo.WarehousingCount * drug.MinNumber
  438. }
  439. if druginfo.MaxUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  440. sum_count = druginfo.WarehousingCount
  441. }
  442. if druginfo.MaxUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  443. sum_count = druginfo.WarehousingCount
  444. }
  445. if (over_count + out_count) <= sum_count {
  446. if its.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  447. //退库
  448. warehouseInfo := models.DrugWarehouseInfo{
  449. StockMinNumber: its.Count,
  450. }
  451. ModifyDrugWarehouseInfoId(its.WarehouseInfoId, its.Count)
  452. UpdateDrugWarehouse(its.WarehouseInfoId, warehouseInfo)
  453. //增加退库数量
  454. AddCancelSumCountOne(storeHouseConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, its.Count)
  455. //出库数量减少
  456. UpdateSumOutDrug(advice.UserOrgId, storeHouseConfig.DrugStorehouseOut, advice.DrugId, its.Count)
  457. }
  458. if its.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  459. warehouseInfo := models.DrugWarehouseInfo{
  460. StockMaxNumber: its.Count,
  461. }
  462. drug, _ := GetBaseDrugMedical(advice.DrugId)
  463. var sum_count = its.Count * drug.MinNumber
  464. ModifyDrugWarehouseInfoId(its.WarehouseInfoId, sum_count)
  465. UpdateDrugWarehouseOne(its.WarehouseInfoId, warehouseInfo)
  466. //增加退库数量
  467. AddCancelSumCountOne(storeHouseConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, its.Count*drug.MinNumber)
  468. //出库数量减少
  469. UpdateSumOutDrug(advice.UserOrgId, storeHouseConfig.DrugStorehouseOut, advice.DrugId, its.Count*drug.MinNumber)
  470. }
  471. if its.CountUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  472. warehouseInfo := models.DrugWarehouseInfo{
  473. StockMaxNumber: its.Count,
  474. }
  475. drug, _ := GetBaseDrugMedical(advice.DrugId)
  476. var sum_count = its.Count * drug.MinNumber
  477. ModifyDrugWarehouseInfoId(its.WarehouseInfoId, sum_count)
  478. UpdateDrugWarehouseOne(its.WarehouseInfoId, warehouseInfo)
  479. //增加退库数量
  480. AddCancelSumCountOne(storeHouseConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, its.Count*drug.MinNumber)
  481. //出库数量减少
  482. UpdateSumOutDrug(advice.UserOrgId, storeHouseConfig.DrugStorehouseOut, advice.DrugId, its.Count*drug.MinNumber)
  483. }
  484. }
  485. }
  486. floatPrescrip := strconv.FormatFloat(advice.PrescribingNumber, 'f', -1, 32)
  487. prescribingNumber, _ := strconv.ParseInt(floatPrescrip, 10, 64)
  488. if advice.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  489. operation_time := time.Now().Unix()
  490. ctime := time.Now().Unix()
  491. timeStr := time.Now().Format("2006-01-02")
  492. timeArr := strings.Split(timeStr, "-")
  493. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  494. total = total + 1
  495. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  496. cancelStock := models.DrugCancelStock{
  497. OrderNumber: orderNumber,
  498. OperaTime: operation_time,
  499. OrgId: advice.UserOrgId,
  500. Creater: creater,
  501. Ctime: ctime,
  502. Status: 1,
  503. ReturnTime: advice.AdviceDate,
  504. Dealer: info.Dealer,
  505. Manufacturer: info.Manufacturer,
  506. Type: 1,
  507. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  508. IsCheck: 1,
  509. }
  510. AddSigleDrugCancelStock(&cancelStock)
  511. manufactureName, _ := GetManufactureById(info.Manufacturer)
  512. dealer, _ := GetDealerById(info.Dealer)
  513. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  514. cancelStockInfo := models.DrugCancelStockInfo{
  515. OrderNumber: cancelInfo.OrderNumber,
  516. CancelStockId: cancelInfo.ID,
  517. DrugId: advice.DrugId,
  518. Count: prescribingNumber,
  519. Status: 1,
  520. Ctime: ctime,
  521. OrgId: advice.UserOrgId,
  522. Type: 1,
  523. Manufacturer: manufactureName.ManufacturerName,
  524. Dealer: dealer.DealerName,
  525. Total: 0,
  526. RetailPrice: info.RetailPrice,
  527. RetailTotalPrice: info.RetailTotalPrice,
  528. Price: info.Price,
  529. RegisterAccount: "",
  530. Remark: info.Remark,
  531. BatchNumber: info.BatchNumber,
  532. MaxUnit: advice.PrescribingNumberUnit,
  533. ProductDate: info.ProductDate,
  534. ExpiryDate: info.ExpiryDate,
  535. BatchNumberId: info.WarehouseInfoId,
  536. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  537. IsCheck: 1,
  538. PatientId: advice.PatientId,
  539. }
  540. //查询剩余库存
  541. stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, advice.UserOrgId, advice.DrugId)
  542. var sum_count int64
  543. for _, its := range stockInfo {
  544. if its.MaxUnit == drug.MaxUnit {
  545. its.StockMaxNumber = its.StockMaxNumber * drug.MinNumber
  546. }
  547. sum_count += its.StockMaxNumber + its.StockMinNumber
  548. }
  549. var count_one int64
  550. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  551. count_one = prescribingNumber * drug.MinNumber
  552. }
  553. if advice.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  554. count_one = prescribingNumber
  555. }
  556. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  557. count_one = prescribingNumber * drug.MinNumber
  558. }
  559. flow := models.DrugFlow{
  560. WarehousingId: info.WarehouseInfoId,
  561. DrugId: info.DrugId,
  562. Number: "",
  563. BatchNumber: info.BatchNumber,
  564. Count: count_one,
  565. UserOrgId: advice.UserOrgId,
  566. PatientId: advice.PatientId,
  567. SystemTime: info.SysRecordTime,
  568. ConsumableType: 7,
  569. IsSys: 0,
  570. WarehousingOrder: "",
  571. WarehouseOutId: 0,
  572. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  573. IsEdit: 0,
  574. CancelStockId: cancelStock.ID,
  575. CancelOrderNumber: cancelStock.OrderNumber,
  576. Manufacturer: info.Manufacturer,
  577. Dealer: info.Dealer,
  578. Creator: creater,
  579. UpdateCreator: 0,
  580. Status: 1,
  581. Ctime: info.SysRecordTime,
  582. Mtime: 0,
  583. Price: info.Price,
  584. WarehousingDetailId: info.WarehouseInfoId,
  585. WarehouseOutDetailId: 0,
  586. CancelOutDetailId: 0,
  587. ExpireDate: info.ExpiryDate,
  588. ProductDate: info.ProductDate,
  589. MaxUnit: drug.MinUnit,
  590. MinUnit: "",
  591. AdviceId: info.AdviceId,
  592. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  593. OverCount: sum_count,
  594. OperateTime: time.Now().Unix(),
  595. }
  596. CreatedCancelStock(cancelStockInfo)
  597. CreateDrugFlowOne(flow)
  598. //删除出库记录
  599. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID)
  600. //删除流水
  601. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID)
  602. }
  603. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  604. houseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  605. operation_time := time.Now().Unix()
  606. ctime := time.Now().Unix()
  607. timeStr := time.Now().Format("2006-01-02")
  608. timeArr := strings.Split(timeStr, "-")
  609. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  610. total = total + 1
  611. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  612. cancelStock := models.DrugCancelStock{
  613. OrderNumber: orderNumber,
  614. OperaTime: operation_time,
  615. OrgId: advice.UserOrgId,
  616. Creater: creater,
  617. Ctime: ctime,
  618. Status: 1,
  619. ReturnTime: advice.AdviceDate,
  620. Dealer: info.Dealer,
  621. Manufacturer: info.Manufacturer,
  622. Type: 1,
  623. StorehouseId: houseConfig.DrugStorehouseOut,
  624. IsCheck: 1,
  625. }
  626. AddSigleDrugCancelStock(&cancelStock)
  627. manufactureName, _ := GetManufactureById(info.Manufacturer)
  628. dealer, _ := GetDealerById(info.Dealer)
  629. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  630. cancelStockInfo := models.DrugCancelStockInfo{
  631. OrderNumber: cancelInfo.OrderNumber,
  632. CancelStockId: cancelInfo.ID,
  633. DrugId: info.DrugId,
  634. Count: prescribingNumber,
  635. Status: 1,
  636. Ctime: ctime,
  637. OrgId: advice.UserOrgId,
  638. Type: 1,
  639. Manufacturer: manufactureName.ManufacturerName,
  640. Dealer: dealer.DealerName,
  641. Total: 0,
  642. RetailPrice: info.RetailPrice,
  643. RetailTotalPrice: info.RetailTotalPrice,
  644. Price: info.Price,
  645. RegisterAccount: "",
  646. Remark: info.Remark,
  647. BatchNumber: info.BatchNumber,
  648. MaxUnit: advice.PrescribingNumberUnit,
  649. ProductDate: info.ProductDate,
  650. ExpiryDate: info.ExpiryDate,
  651. BatchNumberId: info.WarehouseInfoId,
  652. StorehouseId: houseConfig.DrugStorehouseOut,
  653. IsCheck: 1,
  654. }
  655. //查询剩余库存
  656. stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, advice.UserOrgId, advice.DrugId)
  657. var sum_count int64
  658. for _, its := range stockInfo {
  659. if its.MaxUnit == drug.MaxUnit {
  660. its.StockMaxNumber = its.StockMaxNumber * drug.MinNumber
  661. }
  662. sum_count += its.StockMaxNumber + its.StockMinNumber
  663. }
  664. var count_one int64
  665. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  666. count_one = prescribingNumber * drug.MinNumber
  667. }
  668. if advice.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  669. count_one = prescribingNumber
  670. }
  671. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  672. count_one = prescribingNumber * drug.MinNumber
  673. }
  674. flow := models.DrugFlow{
  675. WarehousingId: info.WarehouseInfoId,
  676. DrugId: info.DrugId,
  677. Number: "",
  678. BatchNumber: info.BatchNumber,
  679. Count: count_one,
  680. UserOrgId: advice.UserOrgId,
  681. PatientId: advice.PatientId,
  682. SystemTime: info.SysRecordTime,
  683. ConsumableType: 7,
  684. IsSys: 0,
  685. WarehousingOrder: "",
  686. WarehouseOutId: 0,
  687. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  688. IsEdit: 0,
  689. CancelStockId: cancelStock.ID,
  690. CancelOrderNumber: cancelStock.OrderNumber,
  691. Manufacturer: info.Manufacturer,
  692. Dealer: info.Dealer,
  693. Creator: creater,
  694. UpdateCreator: 0,
  695. Status: 1,
  696. Ctime: info.SysRecordTime,
  697. Mtime: 0,
  698. Price: info.Price,
  699. WarehousingDetailId: info.WarehouseInfoId,
  700. WarehouseOutDetailId: 0,
  701. CancelOutDetailId: 0,
  702. ExpireDate: info.ExpiryDate,
  703. ProductDate: info.ProductDate,
  704. MaxUnit: drug.MinUnit,
  705. MinUnit: "",
  706. AdviceId: info.AdviceId,
  707. StorehouseId: houseConfig.DrugStorehouseOut,
  708. OverCount: sum_count,
  709. OperateTime: time.Now().Unix(),
  710. }
  711. CreatedCancelStock(cancelStockInfo)
  712. CreateDrugFlowOne(flow)
  713. //删除出库记录
  714. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID)
  715. //删除流水
  716. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID)
  717. }
  718. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  719. houseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  720. operation_time := time.Now().Unix()
  721. ctime := time.Now().Unix()
  722. timeStr := time.Now().Format("2006-01-02")
  723. timeArr := strings.Split(timeStr, "-")
  724. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  725. total = total + 1
  726. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  727. cancelStock := models.DrugCancelStock{
  728. OrderNumber: orderNumber,
  729. OperaTime: operation_time,
  730. OrgId: advice.UserOrgId,
  731. Creater: creater,
  732. Ctime: ctime,
  733. Status: 1,
  734. ReturnTime: advice.AdviceDate,
  735. Dealer: info.Dealer,
  736. Manufacturer: info.Manufacturer,
  737. Type: 1,
  738. StorehouseId: houseConfig.DrugStorehouseOut,
  739. IsCheck: 1,
  740. }
  741. AddSigleDrugCancelStock(&cancelStock)
  742. manufactureName, _ := GetManufactureById(info.Manufacturer)
  743. dealer, _ := GetDealerById(info.Dealer)
  744. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  745. cancelStockInfo := models.DrugCancelStockInfo{
  746. OrderNumber: cancelInfo.OrderNumber,
  747. CancelStockId: cancelInfo.ID,
  748. DrugId: info.DrugId,
  749. Count: prescribingNumber,
  750. Status: 1,
  751. Ctime: ctime,
  752. OrgId: advice.UserOrgId,
  753. Type: 1,
  754. Manufacturer: manufactureName.ManufacturerName,
  755. Dealer: dealer.DealerName,
  756. Total: 0,
  757. RetailPrice: info.RetailPrice,
  758. RetailTotalPrice: info.RetailTotalPrice,
  759. Price: info.Price,
  760. RegisterAccount: "",
  761. Remark: info.Remark,
  762. BatchNumber: info.BatchNumber,
  763. MaxUnit: advice.PrescribingNumberUnit,
  764. ProductDate: info.ProductDate,
  765. ExpiryDate: info.ExpiryDate,
  766. BatchNumberId: info.WarehouseInfoId,
  767. StorehouseId: houseConfig.DrugStorehouseOut,
  768. IsCheck: 1,
  769. }
  770. //查询剩余库存
  771. stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, advice.UserOrgId, advice.DrugId)
  772. var sum_count int64
  773. for _, its := range stockInfo {
  774. if its.MaxUnit == drug.MaxUnit {
  775. its.StockMaxNumber = its.StockMaxNumber * drug.MinNumber
  776. }
  777. sum_count += its.StockMaxNumber + its.StockMinNumber
  778. }
  779. flow := models.DrugFlow{
  780. WarehousingId: info.WarehouseInfoId,
  781. DrugId: info.DrugId,
  782. Number: "",
  783. BatchNumber: info.BatchNumber,
  784. Count: prescribingNumber,
  785. UserOrgId: advice.UserOrgId,
  786. PatientId: advice.PatientId,
  787. SystemTime: info.SysRecordTime,
  788. ConsumableType: 7,
  789. IsSys: 0,
  790. WarehousingOrder: "",
  791. WarehouseOutId: 0,
  792. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  793. IsEdit: 0,
  794. CancelStockId: cancelStock.ID,
  795. CancelOrderNumber: cancelStock.OrderNumber,
  796. Manufacturer: info.Manufacturer,
  797. Dealer: info.Dealer,
  798. Creator: creater,
  799. UpdateCreator: 0,
  800. Status: 1,
  801. Ctime: info.SysRecordTime,
  802. Mtime: 0,
  803. Price: info.Price,
  804. WarehousingDetailId: info.WarehouseInfoId,
  805. WarehouseOutDetailId: 0,
  806. CancelOutDetailId: 0,
  807. ExpireDate: info.ExpiryDate,
  808. ProductDate: info.ProductDate,
  809. MaxUnit: advice.PrescribingNumberUnit,
  810. MinUnit: "",
  811. AdviceId: info.AdviceId,
  812. StorehouseId: houseConfig.DrugStorehouseOut,
  813. OverCount: sum_count,
  814. OperateTime: time.Now().Unix(),
  815. }
  816. CreatedCancelStock(cancelStockInfo)
  817. CreateDrugFlowOne(flow)
  818. //删除出库记录
  819. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID)
  820. //删除流水
  821. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID)
  822. }
  823. //更新字典里面的库存
  824. stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, advice.UserOrgId, advice.DrugId)
  825. //查询改药品信息
  826. medical, _ := GetBaseDrugMedical(advice.DrugId)
  827. var sum_count_one int64
  828. for _, its := range stockInfo {
  829. if its.MaxUnit == medical.MaxUnit {
  830. its.StockMaxNumber = its.StockMaxNumber * medical.MinNumber
  831. }
  832. sum_count_one += its.StockMaxNumber + its.StockMinNumber
  833. }
  834. UpdateBaseDrugSumTwo(advice.DrugId, sum_count_one, advice.UserOrgId)
  835. //更新库存
  836. UpdateSumDrug(advice.UserOrgId, storeHouseConfig.DrugStorehouseOut, advice.DrugId, sum_count_one)
  837. }
  838. return err
  839. }
  840. func GoodAutoAddCancelInfo(good *models.NewDialysisBeforePrepareGoods, creater int64) error {
  841. //查询已经出库数量
  842. info, _ := GetWareOutInfo(good.GoodId, good.RecordDate, good.UserOrgId, good.PatientId, good.OrderId)
  843. if len(info) > 0 {
  844. houseConfig, _ := GetAllStoreHouseConfig(good.UserOrgId)
  845. operation_time := time.Now().Unix()
  846. //创建退库单
  847. timeStr := time.Now().Format("2006-01-02")
  848. timeArr := strings.Split(timeStr, "-")
  849. total, _ := FindAllCancelStockTotal(good.UserOrgId)
  850. total = total + 1
  851. orderNumber := "CKTKD" + strconv.FormatInt(good.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  852. cancelStock := models.CancelStock{
  853. OrderNumber: orderNumber,
  854. OperaTime: operation_time,
  855. OrgId: good.UserOrgId,
  856. Creater: creater,
  857. Ctime: time.Now().Unix(),
  858. Status: 1,
  859. ReturnTime: good.RecordDate,
  860. Type: 1,
  861. StorehouseId: houseConfig.StorehouseOutInfo,
  862. IsCheck: 1,
  863. }
  864. _, msgerrkonde := GetCancelStockDetailByOrderNumberOne(good.RecordDate, good.UserOrgId)
  865. if msgerrkonde == gorm.ErrRecordNotFound {
  866. AddSigleCancelStock(&cancelStock)
  867. }
  868. cancel, _ := GetLastCancelStockById(good.UserOrgId)
  869. for _, item := range info {
  870. manufacturer, _ := GetManufactureById(item.Manufacturer)
  871. deaerler, _ := GetDealerById(item.Dealer)
  872. cancelStockInfo := models.CancelStockInfo{
  873. GoodId: good.GoodId,
  874. CancelStockId: cancel.ID,
  875. GoodTypeId: good.GoodTypeId,
  876. Count: item.Count,
  877. Price: item.Price,
  878. Total: 0,
  879. ProductDate: item.ProductDate,
  880. ExpiryDate: item.ExpiryDate,
  881. Ctime: time.Now().Unix(),
  882. Status: 1,
  883. OrgId: good.UserOrgId,
  884. OrderNumber: cancel.OrderNumber,
  885. Type: 0,
  886. Dealer: deaerler.DealerName,
  887. Manufacturer: manufacturer.ManufacturerName,
  888. Number: item.Number,
  889. RegisterAccount: "",
  890. Remark: "",
  891. WarehouseInfoId: item.WarehouseInfotId,
  892. PatientId: item.PatientId,
  893. RecordDate: item.SysRecordTime,
  894. StorehouseId: houseConfig.StorehouseOutInfo,
  895. IsCheck: 1,
  896. }
  897. CreateCancelStockInfoOne(&cancelStockInfo)
  898. cancelInfo, _ := GetLastCancelStockInfoByGoodId(good.GoodId)
  899. goodList, _ := GetSumGoodList(item.OrgId, houseConfig.StorehouseOutInfo, item.GoodId)
  900. var over_count int64
  901. for _, it := range goodList {
  902. over_count += it.StockCount
  903. }
  904. flow := models.VmStockFlow{
  905. WarehousingId: item.WarehouseInfotId,
  906. GoodId: item.GoodId,
  907. Number: item.Number,
  908. LicenseNumber: item.LicenseNumber,
  909. Count: item.Count,
  910. UserOrgId: item.OrgId,
  911. PatientId: item.PatientId,
  912. SystemTime: item.SysRecordTime,
  913. ConsumableType: 7,
  914. IsSys: 0,
  915. WarehousingOrder: "",
  916. WarehouseOutId: item.WarehouseOutId,
  917. WarehouseOutOrderNumber: item.WarehouseOutOrderNumber,
  918. IsEdit: 0,
  919. CancelStockId: cancel.ID,
  920. CancelOrderNumber: cancel.OrderNumber,
  921. Manufacturer: manufacturer.ID,
  922. Dealer: 0,
  923. Creator: creater,
  924. UpdateCreator: 0,
  925. Status: 1,
  926. Ctime: time.Now().Unix(),
  927. Mtime: 0,
  928. Price: item.Price,
  929. WarehousingDetailId: item.WarehouseInfotId,
  930. WarehouseOutDetailId: item.ID,
  931. CancelOutDetailId: cancelInfo.ID,
  932. ProductDate: item.ProductDate,
  933. ExpireDate: item.ExpiryDate,
  934. StorehouseId: houseConfig.StorehouseOutInfo,
  935. OverCount: over_count,
  936. OperateTime: time.Now().Unix(),
  937. }
  938. CreateStockFlowOne(flow)
  939. //回退库存
  940. UpDateWarehouseInfoByStockDelete(item.WarehouseInfotId, item.Count, item.PatientId, item.SysRecordTime, item.GoodId)
  941. //退库数量增加
  942. UpdateSumAddCancelCount(good.UserOrgId, good.GoodId, houseConfig.StorehouseOutInfo, good.Count)
  943. //出库数量减少
  944. UpdateSumCount(good.UserOrgId, houseConfig.StorehouseOutInfo, good.GoodId, good.Count)
  945. //删除出库表
  946. DeleteAutoRedeceDetailTenOne(good.UserOrgId, item.PatientId, item.SysRecordTime, item.GoodId, item.OrderId)
  947. goodListOne, _ := GetSumGoodList(item.OrgId, houseConfig.StorehouseOutInfo, item.GoodId)
  948. var flush_count int64
  949. for _, it := range goodListOne {
  950. flush_count += it.StockCount
  951. }
  952. //更新剩余库存
  953. UpdateSumGood(good.UserOrgId, houseConfig.StorehouseOutInfo, item.GoodId, flush_count)
  954. }
  955. }
  956. return err
  957. }
  958. func CreatePatientDiagnose(diagnose models.XtPatientDiagnose) error {
  959. err := XTWriteDB().Create(&diagnose).Error
  960. return err
  961. }
  962. func GetPatientDiagnose(limit int64, page int64, orgid int64) (list []*models.XtPatientDiagnose, total int64, err error) {
  963. db := XTReadDB().Model(&list).Where("status =1")
  964. if orgid > 0 {
  965. db = db.Where("user_org_id = ?", orgid)
  966. }
  967. offset := (page - 1) * limit
  968. err = db.Count(&total).Offset(offset).Limit(limit).Order("sort asc").Find(&list).Error
  969. return
  970. }
  971. func GetPatientDiagnoseDetail(id int64) (models.XtPatientDiagnose, error) {
  972. diagnose := models.XtPatientDiagnose{}
  973. err := XTReadDB().Where("id = ? and status =1", id).Find(&diagnose).Error
  974. return diagnose, err
  975. }
  976. func UpdatePatientCase(class_name string, sort int64, id int64) error {
  977. diagnose := models.XtPatientDiagnose{}
  978. err := XTReadDB().Model(&diagnose).Where("id = ? and status=1", id).Updates(map[string]interface{}{"class_name": class_name, "sort": sort}).Error
  979. return err
  980. }
  981. func DeletePatientDiagnose(id int64) error {
  982. err := XTWriteDB().Model(&models.XtPatientDiagnose{}).Where("id=? and status= 1", id).Updates(map[string]interface{}{"status": 0}).Error
  983. return err
  984. }
  985. func GetPatientGoodStockCount(patient_id int64, record_time int64, user_org_id int64) (auto []*models.AutomaticReduceDetail, err error) {
  986. err = XTReadDB().Where("patient_id = ? and record_time =? and org_id = ? and status=1", patient_id, record_time, user_org_id).Find(&auto).Error
  987. return auto, err
  988. }
  989. func GetHisAdvicelistTemplate(drug_id int64, user_org_id int64) (advice []*models.HisPrescriptionAdviceTemplate, err error) {
  990. err = XTReadDB().Where("drug_id = ? and org_id =? and status=1", drug_id, user_org_id).Find(&advice).Error
  991. return advice, err
  992. }
  993. func UpdateHisAdviceListTemplate(id int64, price float64) error {
  994. err := XTWriteDB().Model(&models.HisPrescriptionAdviceTemplate{}).Where("id =? and status=1", id).Updates(map[string]interface{}{"price": price}).Error
  995. return err
  996. }
  997. func ModifyGoodCodeWarehouseInfo(id int64, good_code string) (models.XtWarehouseInfoEight, error) {
  998. info := models.XtWarehouseInfoEight{}
  999. err := XTWriteDB().Model(&info).Where("id = ? and status=1", id).Updates(map[string]interface{}{"good_code": good_code}).Error
  1000. return info, err
  1001. }