manage_center_service.go 29KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815
  1. package service
  2. import (
  3. "XT_New/models"
  4. "fmt"
  5. "github.com/jinzhu/gorm"
  6. "strconv"
  7. "strings"
  8. "time"
  9. )
  10. func GetDictionaryConfigList(orgID int64) (dataconfig interface{}, err error) {
  11. var configList []*models.DictionaryDataconfig
  12. 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
  13. if err != nil {
  14. return nil, err
  15. }
  16. // configResult := make([]*ConfigViewModel,0)
  17. childConfig := make(map[int64][]*models.DictionaryDataconfig)
  18. resultConfig := make(map[string][]*models.DictionaryConfigViewModel)
  19. deleteSystemChilds := make([]*models.DictionaryDataconfig, 0)
  20. editSystemChilds := make([]*models.DictionaryDataconfig, 0)
  21. for _, config := range configList {
  22. if config.Status == 1 && config.DeleteIdSystem > 0 {
  23. editSystemChilds = append(editSystemChilds, config)
  24. }
  25. if config.Status == 0 && config.DeleteIdSystem > 0 {
  26. deleteSystemChilds = append(deleteSystemChilds, config)
  27. }
  28. }
  29. continueFlag := false
  30. for _, config := range configList {
  31. continueFlag = false
  32. if config.ParentId == 0 {
  33. newConfig := &models.DictionaryConfigViewModel{
  34. ID: config.ID,
  35. ParentId: config.ParentId,
  36. Module: config.Module,
  37. OrgId: config.OrgId,
  38. Name: config.Name,
  39. FieldName: config.FieldName,
  40. Value: config.Value,
  41. CreateUserId: config.CreateUserId,
  42. Status: config.Status,
  43. Remark: config.Remark,
  44. Title: config.Title,
  45. Content: config.Content,
  46. }
  47. // configResult = append(configResult,newConfig)
  48. result := resultConfig[config.Module]
  49. if result == nil {
  50. result = make([]*models.DictionaryConfigViewModel, 0)
  51. }
  52. for _, vm := range editSystemChilds {
  53. if vm.DeleteIdSystem == config.ID {
  54. continueFlag = true
  55. break
  56. }
  57. }
  58. for _, _vm := range deleteSystemChilds {
  59. if _vm.DeleteIdSystem == config.ID {
  60. continueFlag = true
  61. break
  62. }
  63. }
  64. if config.OrgId != 0 && config.Status == 0 && config.DeleteIdSystem > 0 {
  65. continue
  66. }
  67. if continueFlag {
  68. continue
  69. }
  70. result = append(result, newConfig)
  71. resultConfig[config.Module] = result
  72. } else {
  73. childs := childConfig[config.ParentId]
  74. if childs == nil {
  75. childs = make([]*models.DictionaryDataconfig, 0)
  76. }
  77. continueFlag := false
  78. for _, vm := range editSystemChilds {
  79. if vm.DeleteIdSystem == config.ID {
  80. continueFlag = true
  81. break
  82. }
  83. }
  84. for _, _vm := range deleteSystemChilds {
  85. if _vm.DeleteIdSystem == config.ID {
  86. continueFlag = true
  87. break
  88. }
  89. }
  90. if config.OrgId != 0 && config.Status == 0 && config.DeleteIdSystem > 0 {
  91. continue
  92. }
  93. if continueFlag {
  94. continue
  95. }
  96. childs = append(childs, config)
  97. childConfig[config.ParentId] = childs
  98. }
  99. }
  100. for _, vm := range resultConfig {
  101. for _, _vm := range vm {
  102. _vm.Childs = childConfig[_vm.ID]
  103. }
  104. // vm.Childs = childConfig[vm.ID]
  105. }
  106. return resultConfig, err
  107. }
  108. func CreateDictionaryConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  109. // readDb.Model(&models.Dataconfig{}).Where("module = ? and parent_id = 0 and org_id in (0,?)",dataconfig.Module,dataconfig.OrgId).Count(&total)
  110. err = readDb.Create(&dataconfig).Error
  111. return
  112. }
  113. func GetDictionaryChildValue(module string, parent_id int64, org_id int64) (value int) {
  114. readDb.Model(&models.DictionaryDataconfig{}).Where("module=? and parent_id=? and org_id in (0,?)", module, parent_id, org_id).Count(&value)
  115. return
  116. }
  117. func FindDictionaryConfigByTitle(module string, title string, org_id int64) (dataconfig models.DictionaryDataconfig, err error) {
  118. err = readDb.Model(&models.DictionaryDataconfig{}).Where("module=? and title=? and org_id in (0,?) and status = 1", module, title, org_id).First(&dataconfig).Error
  119. return
  120. }
  121. func UpdateDictionaryTemplate(dataconfig *models.DictionaryDataconfig) (err error) {
  122. 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
  123. return
  124. }
  125. func UpdateDictionaryChildConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  126. 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
  127. return
  128. }
  129. func DeleteDictionaryChildConfig(dataconfig *models.DictionaryDataconfig) (err error) {
  130. err = readDb.Model(&models.DictionaryDataconfig{}).Where("id =?", dataconfig.ID).Update(map[string]interface{}{"status": dataconfig.Status, "update_time": dataconfig.UpdatedTime}).Error
  131. return
  132. }
  133. func CreateBaseDrugLib(lib *models.BaseDrugLib) (err error) {
  134. err = writeDb.Create(&lib).Error
  135. return
  136. }
  137. func UpdateBaseDrugLib(lib *models.BaseDrugLib) (err error) {
  138. err = writeDb.Save(lib).Error
  139. return
  140. }
  141. func FindBaseDrugLibRecordCount(lib *models.BaseDrugLib) (count int64) {
  142. 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)
  143. return
  144. }
  145. func FindBaseDrugLibRecordCountOne(lib *models.BaseDrugLib) (count int64) {
  146. 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)
  147. return
  148. }
  149. func FindAllDrugLibRecordTotal(org_id int64) (count int64) {
  150. readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? AND status = 1", org_id).Count(&count)
  151. return
  152. }
  153. func FindBaseDrugLibRecord(org_id int64, id int64) (lib models.BaseDrugLib, err error) {
  154. err = readDb.Model(&models.BaseDrugLib{}).Where("id = ? AND org_id = ? AND status = 1", id, org_id).First(&lib).Error
  155. return
  156. }
  157. func FindBaseDrugLibRecordSeven(org_id int64, id int64) (lib models.BaseDrugLibSeven, err error) {
  158. err = readDb.Select("id,drug_name,max_unit,min_number,min_unit,sum_count,is_user").Where("org_id = ? AND id = ? AND status = 1", org_id, id).First(&lib).Error
  159. return
  160. }
  161. func GetDrugAutoWarehouseOut(patient_id int64, advicedate int64, drugid int64) (*models.DrugWarehouseOutInfo, error) {
  162. detail := models.DrugWarehouseOutInfo{}
  163. err := XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1", patient_id, advicedate, drugid).Find(&detail).Error
  164. if err == gorm.ErrRecordNotFound {
  165. return nil, err
  166. }
  167. if err != nil {
  168. return nil, err
  169. }
  170. return &detail, nil
  171. }
  172. func GetDrugAutoWarehouseOutSeven(patient_id int64, advicedate int64, drugid int64, adviceid int64) (*models.DrugWarehouseOutInfo, error) {
  173. detail := models.DrugWarehouseOutInfo{}
  174. 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
  175. if err == gorm.ErrRecordNotFound {
  176. return nil, err
  177. }
  178. if err != nil {
  179. return nil, err
  180. }
  181. return &detail, nil
  182. }
  183. func GetDrugAutoWarehouseOutEight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (models.DrugWarehouseOutInfo, error) {
  184. detail := models.DrugWarehouseOutInfo{}
  185. 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
  186. return detail, err
  187. }
  188. func UpdateDrugWarehouse(id int64, info models.DrugWarehouseInfo) error {
  189. err := writeDb.Model(&models.DrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_min_number", gorm.Expr("stock_min_number + ?", info.StockMinNumber)).Error
  190. return err
  191. }
  192. func UpdateDrugWarehouseOne(id int64, info models.DrugWarehouseInfo) error {
  193. err := writeDb.Model(&models.DrugWarehouseInfo{}).Where("id = ?", id).UpdateColumn("stock_max_number", gorm.Expr("stock_max_number + ?", info.StockMaxNumber)).Error
  194. return err
  195. }
  196. 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) {
  197. db := readDb.Model(&models.BaseDrugLib{}).Where("org_id = ? AND status = 1", org_id)
  198. if len(keyword) != 0 {
  199. keyword = "%" + keyword + "%"
  200. db = db.Where("drug_name Like ?", keyword)
  201. }
  202. if is_use != 0 {
  203. if is_use == 2 {
  204. db = db.Where("find_in_set('停用',drug_status) = 0")
  205. } else {
  206. db = db.Where("find_in_set('停用',drug_status) > 0")
  207. }
  208. }
  209. if is_charge == 1 {
  210. //if is_charge == 1 {
  211. // db = db.Where("find_in_set('收费',drug_status) > 0")
  212. //
  213. //} else {
  214. // db = db.Where("find_in_set('收费',drug_status) = 0")
  215. //}
  216. db = db.Where("is_record = ?", is_charge)
  217. }
  218. if is_charge == 2 {
  219. db = db.Where("is_record= 0 || is_record = 2")
  220. }
  221. if is_inject != 0 {
  222. //db = db.Where("drug_name Like ?", keyword)
  223. if is_inject == 1 {
  224. db = db.Where("find_in_set('注射类',drug_status) > 0")
  225. } else {
  226. db = db.Where("find_in_set('注射类',drug_status) = 0")
  227. }
  228. }
  229. if manufacturer > 0 {
  230. db = db.Where("manufacturer = ?", manufacturer)
  231. }
  232. if isRecord > 0 {
  233. db = db.Where("is_mark = ?", isRecord)
  234. }
  235. offset := (page - 1) * limit
  236. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  237. return
  238. }
  239. func CreateMedicineInsurancePercentage(mip *models.MedicineInsurancePercentage) (err error) {
  240. err = writeDb.Create(mip).Error
  241. return
  242. }
  243. func CreateUnitSafeguard(dus *models.DrugUnitSafeguard) (err error) {
  244. err = writeDb.Create(dus).Error
  245. return
  246. }
  247. func AddSigleMZSick(dealer *models.OutpatientServiceSick) (error, *models.OutpatientServiceSick) {
  248. err := writeDb.Create(&dealer).Error
  249. return err, dealer
  250. }
  251. func ModifyMZSick(mesick *models.OutpatientServiceSick) error {
  252. err := writeDb.Save(&mesick).Error
  253. return err
  254. }
  255. func FindAllMZSickList(orgId int64, page int64, limit int64) (list []*models.OutpatientServiceSick, total int64, err error) {
  256. offset := (page - 1) * limit
  257. db := readDb.Model(&models.OutpatientServiceSick{})
  258. db = db.Where("user_org_id = ? AND status = 1", orgId)
  259. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  260. return
  261. }
  262. func DeleteMZSickById(id int64) error {
  263. err := writeDb.Model(&models.OutpatientServiceSick{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  264. return err
  265. }
  266. func FindMZSickById(id int64) (*models.OutpatientServiceSick, error) {
  267. dealer := &models.OutpatientServiceSick{}
  268. err := readDb.Model(&models.OutpatientServiceSick{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  269. return dealer, err
  270. }
  271. func GetDrugWareoutInfo(id int64) (*models.XtDrugWarehouseInfo, error) {
  272. info := models.XtDrugWarehouseInfo{}
  273. err = XTReadDB().Model(&info).Where("drug_id = ? and status = 1", id).Find(&info).Error
  274. if err == gorm.ErrRecordNotFound {
  275. return nil, err
  276. }
  277. if err != nil {
  278. return nil, err
  279. }
  280. return &info, nil
  281. }
  282. func GetDrugWareOutById(id int64) (*models.XtDrugWarehouseOutInfo, error) {
  283. info := models.XtDrugWarehouseOutInfo{}
  284. err := XTReadDB().Model(&info).Where("drug_id = ? and status = 1", id).Find(&info).Error
  285. if err == gorm.ErrRecordNotFound {
  286. return nil, err
  287. }
  288. if err != nil {
  289. return nil, err
  290. }
  291. return &info, nil
  292. }
  293. func DeleteBaseDrugById(id int64) error {
  294. drug := models.XtBaseDrug{}
  295. err := XTWriteDB().Model(&drug).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"status": 0}).Error
  296. return err
  297. }
  298. func AddSigleAddition(dealer *models.XtHisAddtionConfig) (error, *models.XtHisAddtionConfig) {
  299. err := writeDb.Create(&dealer).Error
  300. return err, dealer
  301. }
  302. func ModifyAddition(mesick *models.XtHisAddtionConfig) error {
  303. err := writeDb.Save(&mesick).Error
  304. return err
  305. }
  306. func FindAllAdditionList(orgId int64, page int64, limit int64) (list []*models.XtHisAddtionConfig, total int64, err error) {
  307. offset := (page - 1) * limit
  308. db := readDb.Model(&models.XtHisAddtionConfig{})
  309. db = db.Where("user_org_id = ? AND status = 1", orgId)
  310. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  311. return
  312. }
  313. func DeleteAdditionById(id int64) error {
  314. err := writeDb.Model(&models.XtHisAddtionConfig{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  315. return err
  316. }
  317. func FindAdditionById(id int64) (*models.XtHisAddtionConfig, error) {
  318. dealer := &models.XtHisAddtionConfig{}
  319. err := readDb.Model(&models.XtHisAddtionConfig{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  320. return dealer, err
  321. }
  322. func AddSigleDiagnose(dealer *models.HisXtDiagnoseConfig) (error, *models.HisXtDiagnoseConfig) {
  323. err := writeDb.Create(&dealer).Error
  324. return err, dealer
  325. }
  326. func ModifyDiagnose(mesick *models.HisXtDiagnoseConfig) error {
  327. err := writeDb.Save(&mesick).Error
  328. return err
  329. }
  330. func FindAllDiagnoseList(orgId int64, page int64, limit int64) (list []*models.HisXtDiagnoseConfig, total int64, err error) {
  331. offset := (page - 1) * limit
  332. db := readDb.Model(&models.HisXtDiagnoseConfig{})
  333. db = db.Where("user_org_id = ? AND status = 1", orgId)
  334. err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&list).Error
  335. return
  336. }
  337. func DeleteDiagnoseById(id int64) error {
  338. err := writeDb.Model(&models.HisXtDiagnoseConfig{}).Where("id = ? AND status = 1", id).Updates(map[string]interface{}{"mtime": time.Now().Unix(), "status": 0}).Error
  339. return err
  340. }
  341. func FindDiagnoseById(id int64) (*models.HisXtDiagnoseConfig, error) {
  342. dealer := &models.HisXtDiagnoseConfig{}
  343. err := readDb.Model(&models.HisXtDiagnoseConfig{}).Where("id = ? AND status = 1", id).First(&dealer).Error
  344. return dealer, err
  345. }
  346. func GetDoseCode(dose_id int64, user_org_id int64) (error, string) {
  347. var data models.DictDataconfig
  348. 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
  349. return err, data.Code
  350. }
  351. func GetAllDrugList(orgid int64) (drug []*models.BaseDrugLib, err error) {
  352. err = XTReadDB().Model(&drug).Where("org_id = ? and status = 1", orgid).Find(&drug).Error
  353. return drug, err
  354. }
  355. //自动退库分装方法
  356. func DrugAutoAddCancelInfo(advice *models.HisDoctorAdviceInfo, creater int64) error {
  357. //查询该病人该药品是否有库存记录
  358. info, _ := GetDrugAutoWarehouseOutEight(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID)
  359. storeHouseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  360. //如果剩余数量 + 退库数量 < 总入库数量
  361. if info.ID > 0 {
  362. //查询该药品出库批次总入库数量
  363. druginfo, error := GetDrugInfoSix(info.WarehouseInfoId, info.OrgId)
  364. fmt.Println(error)
  365. //退库
  366. drug, _ := FindBaseDrugLibRecord(advice.UserOrgId, advice.DrugId)
  367. var out_count int64 //该批次出库库存
  368. var sum_count int64 //该批次总库存
  369. var over_count int64 //剩余数量
  370. over_count = druginfo.StockMaxNumber*drug.MinNumber + druginfo.StockMinNumber
  371. if info.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  372. out_count = info.Count * drug.MinNumber
  373. }
  374. if info.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  375. out_count = info.Count
  376. }
  377. if info.CountUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  378. out_count = info.Count
  379. }
  380. if druginfo.MaxUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  381. sum_count = druginfo.WarehousingCount * drug.MinNumber
  382. }
  383. if druginfo.MaxUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  384. sum_count = druginfo.WarehousingCount
  385. }
  386. if druginfo.MaxUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  387. sum_count = druginfo.WarehousingCount
  388. }
  389. fmt.Println("该批次剩余库存", over_count)
  390. fmt.Println("该批次退库数量", out_count)
  391. fmt.Println("该批次总入库数量", sum_count)
  392. if (over_count + out_count) <= sum_count {
  393. if advice.PrescribingNumberUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
  394. floatPrescrip := strconv.FormatFloat(advice.PrescribingNumber, 'f', -1, 32)
  395. prescribingNumber, _ := strconv.ParseInt(floatPrescrip, 10, 64)
  396. //退库
  397. warehouseInfo := models.DrugWarehouseInfo{
  398. StockMinNumber: prescribingNumber,
  399. }
  400. UpdateDrugWarehouse(info.WarehouseInfoId, warehouseInfo)
  401. operation_time := time.Now().Unix()
  402. ctime := time.Now().Unix()
  403. timeStr := time.Now().Format("2006-01-02")
  404. timeArr := strings.Split(timeStr, "-")
  405. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  406. total = total + 1
  407. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  408. cancelStock := models.DrugCancelStock{
  409. OrderNumber: orderNumber,
  410. OperaTime: operation_time,
  411. OrgId: advice.UserOrgId,
  412. Creater: creater,
  413. Ctime: ctime,
  414. Status: 1,
  415. ReturnTime: advice.AdviceDate,
  416. Dealer: info.Dealer,
  417. Manufacturer: info.Manufacturer,
  418. Type: 1,
  419. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  420. IsCheck: 1,
  421. }
  422. AddSigleDrugCancelStock(&cancelStock)
  423. manufactureName, _ := GetManufactureById(info.Manufacturer)
  424. dealer, _ := GetDealerById(info.Dealer)
  425. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  426. cancelStockInfo := models.DrugCancelStockInfo{
  427. OrderNumber: cancelInfo.OrderNumber,
  428. CancelStockId: cancelInfo.ID,
  429. DrugId: info.DrugId,
  430. Count: info.Count,
  431. Status: 1,
  432. Ctime: ctime,
  433. OrgId: advice.UserOrgId,
  434. Type: 1,
  435. Manufacturer: manufactureName.ManufacturerName,
  436. Dealer: dealer.DealerName,
  437. Total: 0,
  438. RetailPrice: info.RetailPrice,
  439. RetailTotalPrice: info.RetailTotalPrice,
  440. Price: info.Price,
  441. RegisterAccount: "",
  442. Remark: info.Remark,
  443. BatchNumber: info.BatchNumber,
  444. MaxUnit: info.CountUnit,
  445. ProductDate: info.ProductDate,
  446. ExpiryDate: info.ExpiryDate,
  447. BatchNumberId: info.WarehouseInfoId,
  448. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  449. IsCheck: 1,
  450. }
  451. flow := models.DrugFlow{
  452. WarehousingId: 0,
  453. DrugId: info.DrugId,
  454. Number: "",
  455. BatchNumber: info.BatchNumber,
  456. Count: info.Count,
  457. UserOrgId: advice.UserOrgId,
  458. PatientId: 0,
  459. SystemTime: info.SysRecordTime,
  460. ConsumableType: 7,
  461. IsSys: 0,
  462. WarehousingOrder: "",
  463. WarehouseOutId: 0,
  464. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  465. IsEdit: 0,
  466. CancelStockId: cancelStock.ID,
  467. CancelOrderNumber: cancelStock.OrderNumber,
  468. Manufacturer: info.Manufacturer,
  469. Dealer: info.Dealer,
  470. Creator: creater,
  471. UpdateCreator: 0,
  472. Status: 1,
  473. Ctime: time.Now().Unix(),
  474. Mtime: 0,
  475. Price: info.Price,
  476. WarehousingDetailId: 0,
  477. WarehouseOutDetailId: 0,
  478. CancelOutDetailId: 0,
  479. ExpireDate: info.ExpiryDate,
  480. ProductDate: info.ProductDate,
  481. MaxUnit: info.CountUnit,
  482. MinUnit: "",
  483. AdviceId: info.AdviceId,
  484. StorehouseId: storeHouseConfig.DrugStorehouseOut,
  485. }
  486. CreatedCancelStock(cancelStockInfo)
  487. CreateDrugFlowOne(flow)
  488. //删除出库记录
  489. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID, info.WarehouseOutId)
  490. //删除流水
  491. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID, info.ID)
  492. }
  493. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
  494. houseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  495. floatPrescrip := strconv.FormatFloat(advice.PrescribingNumber, 'f', -1, 32)
  496. prescribingNumber, _ := strconv.ParseInt(floatPrescrip, 10, 64)
  497. if advice.PrescribingNumberUnit == drug.MaxUnit {
  498. warehouseInfo := models.DrugWarehouseInfo{
  499. StockMaxNumber: prescribingNumber,
  500. }
  501. UpdateDrugWarehouseOne(info.WarehouseInfoId, warehouseInfo)
  502. }
  503. operation_time := time.Now().Unix()
  504. ctime := time.Now().Unix()
  505. timeStr := time.Now().Format("2006-01-02")
  506. timeArr := strings.Split(timeStr, "-")
  507. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  508. total = total + 1
  509. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  510. cancelStock := models.DrugCancelStock{
  511. OrderNumber: orderNumber,
  512. OperaTime: operation_time,
  513. OrgId: advice.UserOrgId,
  514. Creater: creater,
  515. Ctime: ctime,
  516. Status: 1,
  517. ReturnTime: advice.AdviceDate,
  518. Dealer: info.Dealer,
  519. Manufacturer: info.Manufacturer,
  520. Type: 1,
  521. StorehouseId: houseConfig.DrugStorehouseOut,
  522. IsCheck: 1,
  523. }
  524. AddSigleDrugCancelStock(&cancelStock)
  525. fmt.Println("到这里了吗32222222222222222222222222222222222222222222222")
  526. manufactureName, _ := GetManufactureById(info.Manufacturer)
  527. dealer, _ := GetDealerById(info.Dealer)
  528. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  529. cancelStockInfo := models.DrugCancelStockInfo{
  530. OrderNumber: cancelInfo.OrderNumber,
  531. CancelStockId: cancelInfo.ID,
  532. DrugId: info.DrugId,
  533. Count: info.Count,
  534. Status: 1,
  535. Ctime: ctime,
  536. OrgId: advice.UserOrgId,
  537. Type: 1,
  538. Manufacturer: manufactureName.ManufacturerName,
  539. Dealer: dealer.DealerName,
  540. Total: 0,
  541. RetailPrice: info.RetailPrice,
  542. RetailTotalPrice: info.RetailTotalPrice,
  543. Price: info.Price,
  544. RegisterAccount: "",
  545. Remark: info.Remark,
  546. BatchNumber: info.BatchNumber,
  547. MaxUnit: info.CountUnit,
  548. ProductDate: info.ProductDate,
  549. ExpiryDate: info.ExpiryDate,
  550. BatchNumberId: info.WarehouseInfoId,
  551. StorehouseId: houseConfig.DrugStorehouseOut,
  552. IsCheck: 1,
  553. }
  554. flow := models.DrugFlow{
  555. WarehousingId: 0,
  556. DrugId: info.DrugId,
  557. Number: "",
  558. BatchNumber: info.BatchNumber,
  559. Count: info.Count,
  560. UserOrgId: advice.UserOrgId,
  561. PatientId: 0,
  562. SystemTime: info.SysRecordTime,
  563. ConsumableType: 7,
  564. IsSys: 0,
  565. WarehousingOrder: "",
  566. WarehouseOutId: 0,
  567. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  568. IsEdit: 0,
  569. CancelStockId: cancelStock.ID,
  570. CancelOrderNumber: cancelStock.OrderNumber,
  571. Manufacturer: info.Manufacturer,
  572. Dealer: info.Dealer,
  573. Creator: creater,
  574. UpdateCreator: 0,
  575. Status: 1,
  576. Ctime: time.Now().Unix(),
  577. Mtime: 0,
  578. Price: info.Price,
  579. WarehousingDetailId: 0,
  580. WarehouseOutDetailId: 0,
  581. CancelOutDetailId: 0,
  582. ExpireDate: info.ExpiryDate,
  583. ProductDate: info.ProductDate,
  584. MaxUnit: info.CountUnit,
  585. MinUnit: "",
  586. AdviceId: info.AdviceId,
  587. StorehouseId: houseConfig.DrugStorehouseOut,
  588. }
  589. CreatedCancelStock(cancelStockInfo)
  590. CreateDrugFlowOne(flow)
  591. //删除出库记录
  592. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID, info.WarehouseOutId)
  593. //删除流水
  594. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID, info.ID)
  595. }
  596. if advice.PrescribingNumberUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
  597. houseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  598. floatPrescrip := strconv.FormatFloat(advice.PrescribingNumber, 'f', -1, 32)
  599. prescribingNumber, _ := strconv.ParseInt(floatPrescrip, 10, 64)
  600. if advice.PrescribingNumberUnit == drug.MaxUnit {
  601. warehouseInfo := models.DrugWarehouseInfo{
  602. StockMaxNumber: prescribingNumber,
  603. }
  604. UpdateDrugWarehouseOne(info.WarehouseInfoId, warehouseInfo)
  605. }
  606. operation_time := time.Now().Unix()
  607. ctime := time.Now().Unix()
  608. timeStr := time.Now().Format("2006-01-02")
  609. timeArr := strings.Split(timeStr, "-")
  610. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  611. total = total + 1
  612. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  613. cancelStock := models.DrugCancelStock{
  614. OrderNumber: orderNumber,
  615. OperaTime: operation_time,
  616. OrgId: advice.UserOrgId,
  617. Creater: creater,
  618. Ctime: ctime,
  619. Status: 1,
  620. ReturnTime: advice.AdviceDate,
  621. Dealer: info.Dealer,
  622. Manufacturer: info.Manufacturer,
  623. Type: 1,
  624. StorehouseId: houseConfig.DrugStorehouseOut,
  625. IsCheck: 1,
  626. }
  627. AddSigleDrugCancelStock(&cancelStock)
  628. fmt.Println("到这里了吗32222222222222222222222222222222222222222222222")
  629. manufactureName, _ := GetManufactureById(info.Manufacturer)
  630. dealer, _ := GetDealerById(info.Dealer)
  631. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  632. cancelStockInfo := models.DrugCancelStockInfo{
  633. OrderNumber: cancelInfo.OrderNumber,
  634. CancelStockId: cancelInfo.ID,
  635. DrugId: info.DrugId,
  636. Count: info.Count,
  637. Status: 1,
  638. Ctime: ctime,
  639. OrgId: advice.UserOrgId,
  640. Type: 1,
  641. Manufacturer: manufactureName.ManufacturerName,
  642. Dealer: dealer.DealerName,
  643. Total: 0,
  644. RetailPrice: info.RetailPrice,
  645. RetailTotalPrice: info.RetailTotalPrice,
  646. Price: info.Price,
  647. RegisterAccount: "",
  648. Remark: info.Remark,
  649. BatchNumber: info.BatchNumber,
  650. MaxUnit: info.CountUnit,
  651. ProductDate: info.ProductDate,
  652. ExpiryDate: info.ExpiryDate,
  653. BatchNumberId: info.WarehouseInfoId,
  654. StorehouseId: houseConfig.DrugStorehouseOut,
  655. IsCheck: 1,
  656. }
  657. flow := models.DrugFlow{
  658. WarehousingId: 0,
  659. DrugId: info.DrugId,
  660. Number: "",
  661. BatchNumber: info.BatchNumber,
  662. Count: info.Count,
  663. UserOrgId: advice.UserOrgId,
  664. PatientId: 0,
  665. SystemTime: info.SysRecordTime,
  666. ConsumableType: 7,
  667. IsSys: 0,
  668. WarehousingOrder: "",
  669. WarehouseOutId: 0,
  670. WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
  671. IsEdit: 0,
  672. CancelStockId: cancelStock.ID,
  673. CancelOrderNumber: cancelStock.OrderNumber,
  674. Manufacturer: info.Manufacturer,
  675. Dealer: info.Dealer,
  676. Creator: creater,
  677. UpdateCreator: 0,
  678. Status: 1,
  679. Ctime: time.Now().Unix(),
  680. Mtime: 0,
  681. Price: info.Price,
  682. WarehousingDetailId: 0,
  683. WarehouseOutDetailId: 0,
  684. CancelOutDetailId: 0,
  685. ExpireDate: info.ExpiryDate,
  686. ProductDate: info.ProductDate,
  687. MaxUnit: info.CountUnit,
  688. MinUnit: "",
  689. AdviceId: info.AdviceId,
  690. StorehouseId: houseConfig.DrugStorehouseOut,
  691. }
  692. CreatedCancelStock(cancelStockInfo)
  693. CreateDrugFlowOne(flow)
  694. //删除出库记录
  695. UpdateDrugFlowSeven(info.PatientId, info.SysRecordTime, info.DrugId, advice.ID, info.ID, info.WarehouseOutId)
  696. //删除流水
  697. UpdateDrugFlowTens(info.PatientId, info.WarehouseOutOrderNumber, info.DrugId, advice.ID, info.ID)
  698. }
  699. }
  700. //更新字典里面的库存
  701. stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, advice.UserOrgId, advice.DrugId)
  702. //查询改药品信息
  703. medical, _ := GetBaseDrugMedical(advice.DrugId)
  704. var sum_count_one int64
  705. for _, its := range stockInfo {
  706. sum_count_one += its.StockMaxNumber*medical.MinNumber + its.StockMinNumber
  707. }
  708. UpdateBaseDrugSumTwo(advice.DrugId, sum_count_one, advice.UserOrgId)
  709. }
  710. return err
  711. }