new_warehouse_service.go 76KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014
  1. package service
  2. import (
  3. "XT_New/models"
  4. "errors"
  5. "fmt"
  6. "github.com/jinzhu/gorm"
  7. "math"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. //耗材出库
  13. func ConsumablesGoodDelivery(orgID int64, patient_id int64, record_time int64, goods *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut, count int64) (err error) {
  14. fmt.Println("出库数量2333333333333333333333333333333333hhha", goods.Count)
  15. //开事务
  16. var deliver_number int64 = 0
  17. var stock_number int64 = 0
  18. var maxNumber int64 = 0
  19. deliver_number = goods.Count
  20. // 根据先进先出原则,查询最先入库的批次,进行出库
  21. // 如果没有对应的库存,则报错
  22. warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId, goods.StorehouseId)
  23. if err != nil {
  24. return errors.New("库存数量不足")
  25. }
  26. stock_number = warehouse.StockCount
  27. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  28. if stock_number >= deliver_number {
  29. maxNumber = goods.Count
  30. //出库
  31. warehouse.StockCount = warehouse.StockCount - maxNumber
  32. warehouse.Mtime = time.Now().Unix()
  33. if warehouse.StockCount < 0 {
  34. return errors.New("库存数量不足")
  35. }
  36. errThree := UpDateWarehouseInfoByStock(&warehouse)
  37. if errThree != nil {
  38. return errThree
  39. }
  40. //查询剩余库存
  41. goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
  42. var sum_count int64
  43. for _, item := range goodList {
  44. sum_count += item.StockCount
  45. }
  46. warehouseOutInfo := &models.WarehouseOutInfo{
  47. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  48. WarehouseOutId: warehouseOut.ID,
  49. WarehouseInfotId: warehouse.ID,
  50. Status: 1,
  51. Ctime: time.Now().Unix(),
  52. Remark: warehouse.Remark,
  53. OrgId: orgID,
  54. Type: 1,
  55. Manufacturer: warehouse.Manufacturer,
  56. Dealer: warehouse.Dealer,
  57. IsSys: 1,
  58. SysRecordTime: record_time,
  59. GoodTypeId: goods.GoodTypeId,
  60. GoodId: goods.GoodId,
  61. PatientId: patient_id,
  62. Number: warehouse.Number,
  63. LicenseNumber: warehouse.LicenseNumber,
  64. Price: warehouse.PackingPrice,
  65. ExpiryDate: warehouse.ExpiryDate,
  66. ProductDate: warehouse.ProductDate,
  67. ProjectId: goods.ProjectId,
  68. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  69. StorehouseId: goods.StorehouseId,
  70. IsCheck: 1,
  71. OverCount: sum_count,
  72. }
  73. warehouseOutInfo.Count = count
  74. _, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
  75. if errcodes == gorm.ErrRecordNotFound {
  76. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  77. if errOne != nil {
  78. return errOne
  79. }
  80. } else if errcodes == nil {
  81. outInfoOne, _ := GetWarehouseOutInfoIsExistTwo(goods.GoodId, patient_id, record_time, goods.ProjectId)
  82. fmt.Println("goods.cout23323233223232323w", count)
  83. fmt.Println("outInfoOnewowowwowowowowowo", outInfoOne.Count)
  84. if count != outInfoOne.Count {
  85. UpdatedWarehouseOutInfo(warehouseOutInfo, goods.GoodId, patient_id, record_time, goods.ProjectId)
  86. }
  87. }
  88. lastOut, _ := FindWarehouseOutInfoByPatientId(patient_id, record_time, goods.GoodId, orgID)
  89. //查询已经出库的数据
  90. flowGood, _ := GetStockFlowIsBatchNumber(warehouse.ID, patient_id, record_time, goods.GoodId)
  91. var out_count int64
  92. var out_count_one int64
  93. for _, item := range flowGood {
  94. out_count += item.Count
  95. }
  96. //查询退库数据
  97. flowGoodTwo, _ := GetStockFlowIsBatchNumberThree(patient_id, record_time, goods.GoodId)
  98. for _, item := range flowGoodTwo {
  99. out_count_one += item.Count
  100. }
  101. fmt.Println("deliver_number", deliver_number)
  102. fmt.Println("out_count", out_count)
  103. fmt.Println("count", count)
  104. fmt.Println("cancel_out_count2333233", out_count_one)
  105. //如果本次出库数据大于历史出库数据 新增1条流水
  106. if count > (out_count - out_count_one) {
  107. flow := models.VmStockFlow{
  108. WarehouseOutId: warehouseOut.ID,
  109. WarehousingId: warehouse.ID,
  110. GoodId: goods.GoodId,
  111. Number: warehouse.Number,
  112. ProductDate: warehouse.ProductDate,
  113. ExpireDate: warehouse.ExpiryDate,
  114. Count: count - out_count + out_count_one,
  115. Price: warehouse.PackingPrice,
  116. Status: 1,
  117. Ctime: time.Now().Unix(),
  118. UserOrgId: orgID,
  119. Manufacturer: warehouse.Manufacturer,
  120. Dealer: warehouse.Dealer,
  121. LicenseNumber: warehouse.LicenseNumber,
  122. IsEdit: 2,
  123. Creator: warehouseOut.Creater,
  124. SystemTime: record_time,
  125. ConsumableType: 3,
  126. WarehouseOutDetailId: lastOut.ID,
  127. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  128. IsSys: 1,
  129. PatientId: patient_id,
  130. ProjectId: goods.ProjectId,
  131. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  132. StorehouseId: goods.StorehouseId,
  133. OverCount: sum_count,
  134. BuyPrice: warehouse.Price,
  135. }
  136. errThre := CreateStockFlowOne(flow)
  137. if errThre != nil {
  138. return errThre
  139. }
  140. }
  141. //如果本次出库数据小于历史出库数据 新增1条退库流水
  142. if count < (out_count - out_count_one) {
  143. operation_time := time.Now().Unix()
  144. //创建退库单
  145. timeStr := time.Now().Format("2006-01-02")
  146. timeArr := strings.Split(timeStr, "-")
  147. total, _ := FindAllCancelStockTotal(orgID)
  148. total = total + 1
  149. orderNumber := "CKTKD" + strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  150. cancelStock := models.CancelStock{
  151. OrderNumber: orderNumber,
  152. OperaTime: operation_time,
  153. OrgId: orgID,
  154. Creater: warehouseOut.Creater,
  155. Ctime: time.Now().Unix(),
  156. Status: 1,
  157. ReturnTime: record_time,
  158. Type: 1,
  159. StorehouseId: goods.StorehouseId,
  160. IsCheck: 1,
  161. }
  162. _, msgerrkonde := GetCancelStockDetailByOrderNumberOne(record_time, orgID)
  163. if msgerrkonde == gorm.ErrRecordNotFound {
  164. AddSigleCancelStock(&cancelStock)
  165. }
  166. cancel, _ := GetLastCancelStockById(orgID)
  167. manufacturer, _ := GetManufactureById(warehouse.Manufacturer)
  168. deaerler, _ := GetDealerById(warehouse.Dealer)
  169. cancelStockInfo := models.CancelStockInfo{
  170. GoodId: goods.GoodId,
  171. CancelStockId: cancel.ID,
  172. GoodTypeId: goods.GoodTypeId,
  173. Count: out_count - out_count_one - count,
  174. Price: warehouse.PackingPrice,
  175. Total: 0,
  176. ProductDate: warehouse.ProductDate,
  177. ExpiryDate: warehouse.ExpiryDate,
  178. Ctime: time.Now().Unix(),
  179. Status: 1,
  180. OrgId: orgID,
  181. OrderNumber: cancel.OrderNumber,
  182. Type: 0,
  183. Dealer: deaerler.DealerName,
  184. Manufacturer: manufacturer.ManufacturerName,
  185. Number: warehouse.Number,
  186. RegisterAccount: "",
  187. Remark: "",
  188. WarehouseInfoId: warehouse.ID,
  189. PatientId: patient_id,
  190. RecordDate: record_time,
  191. StorehouseId: goods.StorehouseId,
  192. IsCheck: 1,
  193. }
  194. CreateCancelStockInfoOne(&cancelStockInfo)
  195. cancelInfo, _ := GetLastCancelStockInfoByGoodId(goods.GoodId)
  196. flow := models.VmStockFlow{
  197. WarehousingId: warehouse.ID,
  198. GoodId: goods.GoodId,
  199. Number: warehouse.Number,
  200. LicenseNumber: warehouse.LicenseNumber,
  201. Count: out_count - out_count_one - count,
  202. UserOrgId: orgID,
  203. PatientId: patient_id,
  204. SystemTime: record_time,
  205. ConsumableType: 7,
  206. IsSys: 0,
  207. WarehousingOrder: "",
  208. WarehouseOutId: 0,
  209. WarehouseOutOrderNumber: "",
  210. IsEdit: 0,
  211. CancelStockId: cancel.ID,
  212. CancelOrderNumber: cancel.OrderNumber,
  213. Manufacturer: manufacturer.ID,
  214. Dealer: 0,
  215. Creator: warehouseOut.Creater,
  216. UpdateCreator: 0,
  217. Status: 1,
  218. Ctime: time.Now().Unix(),
  219. Mtime: 0,
  220. Price: warehouse.PackingPrice,
  221. WarehousingDetailId: warehouse.ID,
  222. WarehouseOutDetailId: lastOut.ID,
  223. CancelOutDetailId: cancelInfo.ID,
  224. ProductDate: warehouse.ProductDate,
  225. ExpireDate: warehouse.ExpiryDate,
  226. StorehouseId: goods.StorehouseId,
  227. BuyPrice: warehouse.Price,
  228. ProjectId: goods.ProjectId,
  229. }
  230. CreateStockFlowOne(flow)
  231. }
  232. details := models.BloodAutomaticReduceDetail{
  233. WarehouseOutId: lastOut.ID,
  234. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  235. PatientId: patient_id,
  236. Ctime: time.Now().Unix(),
  237. Mtime: time.Now().Unix(),
  238. Status: 1,
  239. RecordTime: record_time,
  240. OrgId: orgID,
  241. GoodId: goods.GoodId,
  242. GoodTypeId: goods.GoodTypeId,
  243. Count: count,
  244. ProjectId: goods.ProjectId,
  245. StorehouseId: goods.StorehouseId,
  246. }
  247. ////查询该耗材已经出库的数量
  248. _, errcode := GetAutoMaticReduceDetailTwenty(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  249. if errcode == gorm.ErrRecordNotFound {
  250. errTwo := CreateAutoReduceRecord(&details)
  251. if errTwo != nil {
  252. return errTwo
  253. }
  254. } else if errcode == nil {
  255. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  256. CreateAutoReduceRecord(&details)
  257. }
  258. return nil
  259. } else {
  260. // 当刚批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  261. warehouse.StockCount = 0
  262. warehouse.Mtime = time.Now().Unix()
  263. errThree := UpDateWarehouseInfoByStock(&warehouse)
  264. if errThree != nil {
  265. return errThree
  266. }
  267. goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
  268. var sum_count int64
  269. for _, item := range goodList {
  270. sum_count += item.StockCount
  271. }
  272. warehouseOutInfo := &models.WarehouseOutInfo{
  273. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  274. WarehouseOutId: warehouseOut.ID,
  275. WarehouseInfotId: warehouse.ID,
  276. Status: 1,
  277. Ctime: time.Now().Unix(),
  278. Remark: warehouse.Remark,
  279. OrgId: orgID,
  280. Type: 1,
  281. Manufacturer: warehouse.Manufacturer,
  282. Dealer: warehouse.Dealer,
  283. IsSys: 1,
  284. SysRecordTime: record_time,
  285. GoodTypeId: goods.GoodTypeId,
  286. GoodId: goods.GoodId,
  287. PatientId: patient_id,
  288. Number: warehouse.Number,
  289. LicenseNumber: warehouse.LicenseNumber,
  290. Price: warehouse.PackingPrice,
  291. ExpiryDate: warehouse.ExpiryDate,
  292. ProductDate: warehouse.ProductDate,
  293. ProjectId: goods.ProjectId,
  294. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  295. StorehouseId: goods.StorehouseId,
  296. IsCheck: 1,
  297. OverCount: sum_count,
  298. }
  299. warehouseOutInfo.Count = stock_number
  300. _, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, goods.PatientId, record_time, goods.ProjectId)
  301. if errcodes == gorm.ErrRecordNotFound {
  302. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  303. if errOne != nil {
  304. return errOne
  305. }
  306. } else if errcodes == nil {
  307. goods.Count = deliver_number - stock_number
  308. //更新数量为 该批次剩余数量 + 还有未出的数量
  309. warehouseOutInfo.Count = stock_number
  310. outInfoOne, _ := GetWarehouseOutInfoIsExistTwo(goods.GoodId, patient_id, record_time, goods.ProjectId)
  311. if count != outInfoOne.Count {
  312. UpdatedWarehouseOutInfo(warehouseOutInfo, goods.GoodId, patient_id, record_time, goods.ProjectId)
  313. }
  314. }
  315. lastOut, _ := FindWarehouseOutInfoByPatientId(patient_id, record_time, goods.GoodId, orgID)
  316. //查询该该批次已经出库的数据
  317. flowGood, _ := GetStockFlowIsBatchNumber(warehouse.ID, patient_id, record_time, goods.GoodId)
  318. var out_count int64
  319. var out_count_one int64
  320. for _, item := range flowGood {
  321. out_count += item.Count
  322. }
  323. flowGoodTwo, _ := GetStockFlowIsBatchNumberThree(patient_id, record_time, goods.GoodId)
  324. for _, item := range flowGoodTwo {
  325. out_count_one += item.Count
  326. }
  327. //如果出库数量 大于 历史出库数据 新增1条流水
  328. if count > out_count-out_count_one {
  329. flow := models.VmStockFlow{
  330. WarehouseOutId: warehouseOut.ID,
  331. WarehousingId: warehouse.ID,
  332. GoodId: goods.GoodId,
  333. Number: warehouse.Number,
  334. ProductDate: warehouse.ProductDate,
  335. ExpireDate: warehouse.ExpiryDate,
  336. Count: stock_number,
  337. Price: warehouse.PackingPrice,
  338. Status: 1,
  339. Ctime: time.Now().Unix(),
  340. UserOrgId: orgID,
  341. Manufacturer: warehouse.Manufacturer,
  342. Dealer: warehouse.Dealer,
  343. LicenseNumber: warehouse.LicenseNumber,
  344. IsEdit: 2,
  345. Creator: warehouseOut.Creater,
  346. SystemTime: record_time,
  347. ConsumableType: 3,
  348. WarehouseOutDetailId: lastOut.ID,
  349. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  350. IsSys: 1,
  351. PatientId: patient_id,
  352. ProjectId: goods.ProjectId,
  353. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  354. StorehouseId: goods.StorehouseId,
  355. OverCount: sum_count,
  356. BuyPrice: warehouse.Price,
  357. }
  358. errThre := CreateStockFlowOne(flow)
  359. if errThre != nil {
  360. return errThre
  361. }
  362. }
  363. //退库
  364. if count < out_count-out_count_one {
  365. operation_time := time.Now().Unix()
  366. //创建退库单
  367. timeStr := time.Now().Format("2006-01-02")
  368. timeArr := strings.Split(timeStr, "-")
  369. total, _ := FindAllCancelStockTotal(orgID)
  370. total = total + 1
  371. orderNumber := "CKTKD" + strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  372. cancelStock := models.CancelStock{
  373. OrderNumber: orderNumber,
  374. OperaTime: operation_time,
  375. OrgId: orgID,
  376. Creater: warehouseOut.Creater,
  377. Ctime: time.Now().Unix(),
  378. Status: 1,
  379. ReturnTime: record_time,
  380. Type: 1,
  381. StorehouseId: goods.StorehouseId,
  382. IsCheck: 1,
  383. }
  384. _, msgerrkonde := GetCancelStockDetailByOrderNumberOne(record_time, orgID)
  385. if msgerrkonde == gorm.ErrRecordNotFound {
  386. AddSigleCancelStock(&cancelStock)
  387. }
  388. cancel, _ := GetLastCancelStockById(orgID)
  389. manufacturer, _ := GetManufactureById(warehouse.Manufacturer)
  390. deaerler, _ := GetDealerById(warehouse.Dealer)
  391. cancelStockInfo := models.CancelStockInfo{
  392. GoodId: goods.GoodId,
  393. CancelStockId: cancel.ID,
  394. GoodTypeId: goods.GoodTypeId,
  395. Count: out_count - out_count_one - count,
  396. Price: warehouse.PackingPrice,
  397. Total: 0,
  398. ProductDate: warehouse.ProductDate,
  399. ExpiryDate: warehouse.ExpiryDate,
  400. Ctime: time.Now().Unix(),
  401. Status: 1,
  402. OrgId: orgID,
  403. OrderNumber: cancel.OrderNumber,
  404. Type: 0,
  405. Dealer: deaerler.DealerName,
  406. Manufacturer: manufacturer.ManufacturerName,
  407. Number: warehouse.Number,
  408. RegisterAccount: "",
  409. Remark: "",
  410. WarehouseInfoId: warehouse.ID,
  411. PatientId: patient_id,
  412. RecordDate: record_time,
  413. StorehouseId: goods.StorehouseId,
  414. IsCheck: 1,
  415. }
  416. CreateCancelStockInfoOne(&cancelStockInfo)
  417. cancelInfo, _ := GetLastCancelStockInfoByGoodId(goods.GoodId)
  418. flow := models.VmStockFlow{
  419. WarehousingId: warehouse.ID,
  420. GoodId: goods.GoodId,
  421. Number: warehouse.Number,
  422. LicenseNumber: warehouse.LicenseNumber,
  423. Count: out_count - count,
  424. UserOrgId: orgID,
  425. PatientId: patient_id,
  426. SystemTime: record_time,
  427. ConsumableType: 7,
  428. IsSys: 0,
  429. WarehousingOrder: "",
  430. WarehouseOutId: 0,
  431. WarehouseOutOrderNumber: "",
  432. IsEdit: 0,
  433. CancelStockId: cancel.ID,
  434. CancelOrderNumber: cancel.OrderNumber,
  435. Manufacturer: manufacturer.ID,
  436. Dealer: 0,
  437. Creator: warehouseOut.Creater,
  438. UpdateCreator: 0,
  439. Status: 1,
  440. Ctime: time.Now().Unix(),
  441. Mtime: 0,
  442. Price: warehouse.PackingPrice,
  443. WarehousingDetailId: warehouse.ID,
  444. WarehouseOutDetailId: lastOut.ID,
  445. CancelOutDetailId: cancelInfo.ID,
  446. ProductDate: warehouse.ProductDate,
  447. ExpireDate: warehouse.ExpiryDate,
  448. StorehouseId: goods.StorehouseId,
  449. BuyPrice: warehouse.Price,
  450. ProjectId: goods.ProjectId,
  451. }
  452. CreateStockFlowOne(flow)
  453. }
  454. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  455. goods.Count = deliver_number - stock_number
  456. ConsumablesGoodDelivery(orgID, patient_id, record_time, goods, warehouseOut, count)
  457. }
  458. return nil
  459. }
  460. func FindWarehouseOutInfoByPatientId(patient_id int64, record_time int64, good_id int64, org_id int64) (models.WarehouseOutInfo, error) {
  461. outInfo := models.WarehouseOutInfo{}
  462. err := XTReadDB().Where("patient_id = ? and sys_record_time = ? and good_id = ? and org_id = ? and status = 1", patient_id, record_time, good_id, org_id).Last(&outInfo).Error
  463. return outInfo, err
  464. }
  465. func UpdateDrugStockCount(drug_id int64, org_id int64, storehouse_id int64, flush_count int64) error {
  466. drug := models.XtDrugStockCount{}
  467. ut := XTWriteDB().Begin()
  468. err := ut.Model(&drug).Where("drug_id = ? and user_org_id = ? and storehouse_id = ? and status = 1", drug_id, org_id, storehouse_id).Update(map[string]interface{}{"flush_count": flush_count}).Error
  469. if err != nil {
  470. ut.Rollback()
  471. return err
  472. }
  473. ut.Commit()
  474. return err
  475. }
  476. func AddDrugCount(drug_id int64, org_id int64, storehouse_id int64, out_count int64) error {
  477. ut := XTWriteDB().Begin()
  478. err := ut.Model(&models.XtDrugStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id = ? and drug_id = ?", storehouse_id, org_id, drug_id).UpdateColumn("sum_out_count", gorm.Expr("sum_out_count + ?", out_count)).Error
  479. if err != nil {
  480. ut.Rollback()
  481. return err
  482. }
  483. err = ut.Model(&models.XtDrugStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id = ? and drug_id = ?", storehouse_id, org_id, drug_id).UpdateColumn("sum_act_out_count", gorm.Expr("sum_act_out_count + ?", out_count)).Error
  484. if err != nil {
  485. ut.Rollback()
  486. return err
  487. }
  488. ut.Commit()
  489. return err
  490. }
  491. func ReduceDrugCount(drug_id int64, org_id int64, storehouse_id int64, out_count int64) error {
  492. ut := XTWriteDB().Begin()
  493. err := ut.Model(&models.XtDrugStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id = ? and drug_id = ?", storehouse_id, org_id, drug_id).UpdateColumn("sum_out_count", gorm.Expr("sum_out_count - ?", out_count)).Error
  494. if err != nil {
  495. ut.Rollback()
  496. return err
  497. }
  498. err = ut.Model(&models.XtDrugStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id = ? and drug_id = ?", storehouse_id, org_id, drug_id).UpdateColumn("sum_act_out_count", gorm.Expr("sum_act_out_count - ?", out_count)).Error
  499. if err != nil {
  500. ut.Rollback()
  501. return err
  502. }
  503. ut.Commit()
  504. return err
  505. }
  506. func ReduceDrugCountTwo(drug_id int64, org_id int64, storehouse_id int64, out_count int64) error {
  507. ut := XTWriteDB().Begin()
  508. err := ut.Model(&models.XtDrugStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id = ? and drug_id = ?", storehouse_id, org_id, drug_id).UpdateColumn("sum_out_count", gorm.Expr("sum_out_count - ?", out_count)).Error
  509. if err != nil {
  510. ut.Rollback()
  511. return err
  512. }
  513. ut.Commit()
  514. return err
  515. }
  516. // 药品自动出库 递归方式
  517. func BloodDrugDeliverInfo(orgID int64, prescribingNumber float64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.DoctorAdvice) (err error) {
  518. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  519. var deliver_number int64 = 0
  520. var stock_number int64 = 0
  521. prescribingNumber_temp := strconv.FormatFloat(math.Abs(prescribingNumber), 'f', 0, 64)
  522. count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
  523. var drug_price float64
  524. if advice.PrescribingNumberUnit == drup.MaxUnit {
  525. deliver_number = count * drup.MinNumber
  526. } else {
  527. deliver_number = count
  528. }
  529. if advice.PrescribingNumberUnit == drup.MaxUnit {
  530. drug_price = drup.RetailPrice
  531. }
  532. fmt.Println(drug_price)
  533. if advice.PrescribingNumberUnit == drup.MinUnit {
  534. drug_price = drup.MinPrice
  535. }
  536. if advice.PrescribingNumberUnit != drup.MaxUnit || advice.PrescribingNumberUnit != drup.MinUnit {
  537. drug_price = drup.RetailPrice
  538. }
  539. // 根据先进先出原则,查询最先入库的批次,进行出库
  540. // 如果没有对应的库存,则报错
  541. storeConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  542. lastWarehouse, _ := FindLastDrugWarehousingInfoByID(advice.DrugId, storeConfig.DrugStorehouseOut)
  543. if lastWarehouse.StockMinNumber >= drup.MinNumber {
  544. var stockMax int64
  545. var stockMin int64
  546. stockMax = lastWarehouse.StockMinNumber / drup.MinNumber
  547. stockMin = lastWarehouse.StockMinNumber % drup.MinNumber
  548. ChangeMaxNumber(lastWarehouse.ID, stockMax)
  549. UpdateMinNumber(lastWarehouse.ID, stockMin)
  550. }
  551. warehouse, err := FindLastDrugWarehousingInfoByID(advice.DrugId, storeConfig.DrugStorehouseOut)
  552. if err != nil {
  553. return err
  554. }
  555. // 将该批次的剩余库存数量转换为拆零数量
  556. stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
  557. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  558. if stock_number >= deliver_number {
  559. var maxNumber int64 = 0
  560. var minNumber int64 = 0
  561. maxNumber = deliver_number / drup.MinNumber
  562. minNumber = deliver_number % drup.MinNumber
  563. if warehouse.StockMaxNumber == 0 && drup.MaxUnit == drup.MinUnit {
  564. minNumber = maxNumber
  565. }
  566. if drup.MaxUnit != drup.MinUnit {
  567. if warehouse.StockMaxNumber < maxNumber && warehouse.StockMinNumber < minNumber {
  568. return errors.New("库存数量不足")
  569. }
  570. }
  571. warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
  572. if warehouse.StockMaxNumber < 0 {
  573. warehouse.StockMaxNumber = 0
  574. }
  575. if warehouse.StockMinNumber < 0 {
  576. warehouse.StockMinNumber = 0
  577. }
  578. warehouse.Mtime = time.Now().Unix()
  579. if warehouse.StockMinNumber < minNumber {
  580. warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
  581. warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
  582. } else {
  583. if minNumber > 0 {
  584. warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
  585. }
  586. if minNumber == 0 && maxNumber != 1 && warehouse.StockMaxNumber <= 0 {
  587. if warehouse.StockMinNumber > 0 {
  588. warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
  589. }
  590. }
  591. }
  592. if maxNumber == 1 && minNumber == 0 && drup.MaxUnit != drup.MinUnit {
  593. if (warehouse.StockMinNumber - deliver_number) > 0 {
  594. warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
  595. }
  596. }
  597. if drup.MaxUnit != drup.MinUnit {
  598. if warehouse.StockMaxNumber < 0 && warehouse.StockMinNumber < 0 {
  599. return errors.New("库存数量不足")
  600. }
  601. }
  602. if warehouse.StockMinNumber <= 0 {
  603. warehouse.StockMinNumber = 0
  604. }
  605. //扣减库存数据
  606. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  607. if errThree != nil {
  608. return errThree
  609. }
  610. //查询剩余库存
  611. stockInfo, _ := GetDrugAllStockInfo(storeConfig.DrugStorehouseOut, orgID, advice.DrugId)
  612. var sum_count int64
  613. for _, its := range stockInfo {
  614. sum_count += its.StockMaxNumber*drup.MinNumber + its.StockMinNumber
  615. }
  616. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  617. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  618. WarehouseOutId: warehouseout.ID,
  619. Status: 1,
  620. Ctime: time.Now().Unix(),
  621. Remark: warehouse.Remark,
  622. OrgId: orgID,
  623. Type: 1,
  624. Manufacturer: warehouse.Manufacturer,
  625. Dealer: warehouse.Dealer,
  626. IsSys: 1,
  627. SysRecordTime: advice.RecordDate,
  628. DrugId: advice.DrugId,
  629. Number: warehouse.Number,
  630. BatchNumber: warehouse.BatchNumber,
  631. Price: warehouse.RetailPrice,
  632. CountUnit: drup.MinUnit,
  633. RetailPrice: warehouse.RetailPrice,
  634. ProductDate: warehouse.ProductDate,
  635. ExpiryDate: warehouse.ExpiryDate,
  636. PatientId: advice.PatientId,
  637. Count: deliver_number, //出最小单位
  638. WarehouseInfoId: warehouse.ID,
  639. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  640. StorehouseId: storeConfig.DrugStorehouseOut,
  641. IsCheck: 1,
  642. OverCount: sum_count,
  643. AdviceId: advice.ID,
  644. }
  645. //查询今日该药品该患者是否有出库数据
  646. lastDrugOutInfo, errThreeCode := GetNewDrugWarehouseOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId)
  647. if errThreeCode == gorm.ErrRecordNotFound {
  648. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  649. if errOne != nil {
  650. return errOne
  651. }
  652. }
  653. if errThreeCode == nil {
  654. errThree := UpdateSigleDrugWarehouseOutInfo(lastDrugOutInfo.ID, warehouseOutInfo)
  655. if errThree != nil {
  656. return errThree
  657. }
  658. }
  659. var out_count int64
  660. var cancel_count int64
  661. //查询出库数据
  662. infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  663. //查询退库数据
  664. cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  665. for _, item := range infoCountList {
  666. out_count += item.Count
  667. }
  668. for _, item := range cancelInfoList {
  669. cancel_count += item.Count
  670. }
  671. //如果本次出库数据大于历史出库数据 新增1条流水
  672. if deliver_number > (out_count - cancel_count) {
  673. drugflow := models.DrugFlow{
  674. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  675. WarehouseOutId: warehouseout.ID,
  676. DrugId: advice.DrugId,
  677. Number: warehouse.Number,
  678. ProductDate: warehouse.ProductDate,
  679. ExpireDate: warehouse.ExpiryDate,
  680. Count: deliver_number - (out_count - cancel_count), //按最小单位计算,
  681. Price: warehouse.RetailPrice,
  682. Status: 1,
  683. Ctime: time.Now().Unix(),
  684. UserOrgId: orgID,
  685. Manufacturer: warehouse.Manufacturer,
  686. Dealer: warehouse.Dealer,
  687. BatchNumber: warehouse.BatchNumber,
  688. MaxUnit: drup.MinUnit,
  689. ConsumableType: 3,
  690. IsEdit: 1,
  691. Creator: advice.ExecutionStaff,
  692. IsSys: 1,
  693. PatientId: advice.PatientId,
  694. SystemTime: advice.AdviceDate,
  695. WarehousingDetailId: warehouse.ID,
  696. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  697. StorehouseId: storeConfig.DrugStorehouseOut,
  698. WarehouseOutDetailId: lastDrugOutInfo.ID,
  699. OverCount: sum_count,
  700. AdviceId: advice.ID,
  701. LastPrice: warehouse.Price,
  702. }
  703. CreateDrugFlowOne(drugflow)
  704. //出库数量相加
  705. AddDrugCount(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, drugflow.Count)
  706. }
  707. //如果本次出库数据小于历史出库数据 新增1条退库流水
  708. if deliver_number < (out_count - cancel_count) {
  709. operation_time := time.Now().Unix()
  710. ctime := time.Now().Unix()
  711. timeStr := time.Now().Format("2006-01-02")
  712. timeArr := strings.Split(timeStr, "-")
  713. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  714. total = total + 1
  715. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  716. cancelStock := models.DrugCancelStock{
  717. OrderNumber: orderNumber,
  718. OperaTime: operation_time,
  719. OrgId: advice.UserOrgId,
  720. Creater: advice.ExecutionStaff,
  721. Ctime: ctime,
  722. Status: 1,
  723. ReturnTime: advice.AdviceDate,
  724. Dealer: 0,
  725. Manufacturer: 0,
  726. Type: 1,
  727. StorehouseId: storeConfig.DrugStorehouseOut,
  728. IsCheck: 1,
  729. }
  730. _, errCode := FindDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  731. if errCode == gorm.ErrRecordNotFound {
  732. AddSigleDrugCancelStock(&cancelStock)
  733. }
  734. lastDrugCancelStock, _ := FindLastDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  735. manufactureName, _ := GetManufactureById(warehouse.Manufacturer)
  736. dealer, _ := GetDealerById(warehouse.Dealer)
  737. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  738. cancelStockInfo := models.DrugCancelStockInfo{
  739. OrderNumber: cancelInfo.OrderNumber,
  740. CancelStockId: lastDrugCancelStock.ID,
  741. DrugId: advice.DrugId,
  742. Count: (out_count - cancel_count) - deliver_number,
  743. Status: 1,
  744. Ctime: ctime,
  745. OrgId: advice.UserOrgId,
  746. Type: 1,
  747. Manufacturer: manufactureName.ManufacturerName,
  748. Dealer: dealer.DealerName,
  749. Total: 0,
  750. RetailPrice: warehouse.RetailPrice,
  751. RetailTotalPrice: warehouse.RetailTotalPrice,
  752. Price: warehouse.Price,
  753. RegisterAccount: "",
  754. Remark: warehouse.Remark,
  755. BatchNumber: warehouse.BatchNumber,
  756. MaxUnit: drup.MinUnit,
  757. ProductDate: warehouse.ProductDate,
  758. ExpiryDate: warehouse.ExpiryDate,
  759. BatchNumberId: warehouse.ID,
  760. StorehouseId: storeConfig.DrugStorehouseOut,
  761. IsCheck: 1,
  762. }
  763. CreatedCancelStock(cancelStockInfo)
  764. flow := models.DrugFlow{
  765. WarehousingId: warehouse.ID,
  766. DrugId: warehouse.DrugId,
  767. Number: "",
  768. BatchNumber: warehouse.BatchNumber,
  769. Count: (out_count - cancel_count) - deliver_number,
  770. UserOrgId: advice.UserOrgId,
  771. PatientId: advice.PatientId,
  772. SystemTime: advice.AdviceDate,
  773. ConsumableType: 7,
  774. IsSys: 0,
  775. WarehousingOrder: "",
  776. WarehouseOutId: 0,
  777. WarehouseOutOrderNumber: "",
  778. IsEdit: 0,
  779. CancelStockId: cancelStock.ID,
  780. CancelOrderNumber: cancelStock.OrderNumber,
  781. Manufacturer: warehouse.Manufacturer,
  782. Dealer: warehouse.Dealer,
  783. Creator: advice.ExecutionStaff,
  784. UpdateCreator: 0,
  785. Status: 1,
  786. Ctime: time.Now().Unix(),
  787. Mtime: 0,
  788. Price: warehouse.RetailPrice,
  789. WarehousingDetailId: warehouse.ID,
  790. WarehouseOutDetailId: 0,
  791. CancelOutDetailId: lastDrugCancelStock.ID,
  792. ExpireDate: warehouse.ExpiryDate,
  793. ProductDate: warehouse.ProductDate,
  794. MaxUnit: drup.MinUnit,
  795. MinUnit: "",
  796. AdviceId: advice.ID,
  797. StorehouseId: storeConfig.DrugStorehouseOut,
  798. LastPrice: warehouse.Price,
  799. }
  800. CreateDrugFlowOne(flow)
  801. AddCancelSumCountOne(storeConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, flow.Count)
  802. //出库数量减
  803. ReduceDrugCountTwo(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, flow.Count)
  804. }
  805. //查询是否存在数据
  806. details := &models.DrugAutomaticReduceDetail{
  807. WarehouseOutId: warehouseout.ID,
  808. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  809. PatientId: advice.PatientId,
  810. Ctime: time.Now().Unix(),
  811. Mtime: time.Now().Unix(),
  812. Status: 1,
  813. RecordTime: advice.RecordDate,
  814. OrgId: orgID,
  815. DrugId: advice.DrugId,
  816. Count: deliver_number,
  817. CountUnit: drup.MinUnit,
  818. WarehouseInfoId: warehouse.ID,
  819. StorehouseId: storeConfig.DrugStorehouseOut,
  820. AdviceId: advice.ID,
  821. }
  822. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  823. if errTwo != nil {
  824. return errTwo
  825. }
  826. return nil
  827. } else {
  828. info := models.XtDrugWarehouseInfo{
  829. ID: warehouse.ID,
  830. WarehousingId: warehouse.WarehousingId,
  831. DrugId: warehouse.DrugId,
  832. Number: warehouse.Number,
  833. ProductDate: warehouse.ProductDate,
  834. ExpiryDate: warehouse.ExpiryDate,
  835. WarehousingCount: warehouse.WarehousingCount,
  836. Price: warehouse.RetailPrice,
  837. TotalPrice: warehouse.TotalPrice,
  838. Dealer: warehouse.Dealer,
  839. Manufacturer: warehouse.Manufacturer,
  840. Remark: warehouse.Remark,
  841. Ctime: warehouse.Ctime,
  842. Mtime: warehouse.Mtime,
  843. Status: 1,
  844. OrgId: warehouse.OrgId,
  845. IsReturn: warehouse.IsReturn,
  846. WarehousingOrder: warehouse.WarehousingOrder,
  847. Type: warehouse.Type,
  848. RetailPrice: warehouse.RetailPrice,
  849. RetailTotalPrice: warehouse.RetailPrice,
  850. StockMaxNumber: 0,
  851. StockMinNumber: 0,
  852. BatchNumber: warehouse.BatchNumber,
  853. MaxUnit: warehouse.MaxUnit,
  854. WarehousingInfoId: warehouse.WarehousingInfoId,
  855. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  856. StorehouseId: storeConfig.DrugStorehouseOut,
  857. IsCheck: 1,
  858. }
  859. //扣减库存
  860. errThree := UpDateDrugWarehouseInfoByStock(&info)
  861. if errThree != nil {
  862. return errThree
  863. }
  864. //查询剩余库存
  865. stockInfo, _ := GetDrugAllStockInfo(storeConfig.DrugStorehouseOut, orgID, advice.DrugId)
  866. var sum_count int64
  867. for _, its := range stockInfo {
  868. sum_count += its.StockMaxNumber*drup.MinNumber + its.StockMinNumber
  869. }
  870. // 当该批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  871. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  872. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  873. WarehouseOutId: warehouseout.ID,
  874. Status: 1,
  875. Ctime: time.Now().Unix(),
  876. Remark: warehouse.Remark,
  877. OrgId: orgID,
  878. Type: 1,
  879. Manufacturer: warehouse.Manufacturer,
  880. Dealer: warehouse.Dealer,
  881. IsSys: 1,
  882. SysRecordTime: advice.RecordDate,
  883. DrugId: advice.DrugId,
  884. Number: warehouse.Number,
  885. BatchNumber: warehouse.BatchNumber,
  886. Price: warehouse.RetailPrice,
  887. CountUnit: drup.MinUnit,
  888. ProductDate: warehouse.ProductDate,
  889. ExpiryDate: warehouse.ExpiryDate,
  890. PatientId: advice.PatientId,
  891. Count: stock_number,
  892. WarehouseInfoId: warehouse.ID,
  893. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  894. StorehouseId: storeConfig.DrugStorehouseOut,
  895. IsCheck: 1,
  896. OverCount: sum_count,
  897. AdviceId: advice.ID,
  898. }
  899. //查询是否存在出库数据
  900. _, errCode := GetSigleDrugWarehouseOutInfoSix(advice.PatientId, advice.AdviceDate, orgID, advice.ID)
  901. if errCode == gorm.ErrRecordNotFound {
  902. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  903. if errOne != nil {
  904. return errOne
  905. }
  906. }
  907. if errCode == nil {
  908. UpdateSingleDrugWarehouseOutInfo(advice.PatientId, advice.AdviceDate, orgID, warehouseOutInfo)
  909. }
  910. lastDrugOutInfo, _ := FindLastDrugWarehouseOutInfo(orgID)
  911. details := &models.DrugAutomaticReduceDetail{
  912. WarehouseOutId: warehouseout.ID,
  913. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  914. PatientId: advice.PatientId,
  915. Ctime: time.Now().Unix(),
  916. Mtime: time.Now().Unix(),
  917. Status: 1,
  918. RecordTime: advice.RecordDate,
  919. OrgId: orgID,
  920. DrugId: advice.DrugId,
  921. Count: stock_number,
  922. CountUnit: drup.MinUnit,
  923. WarehouseInfoId: warehouse.ID,
  924. StorehouseId: storeConfig.DrugStorehouseOut,
  925. AdviceId: advice.ID,
  926. }
  927. _, errcodeThree := FindDrugAutoReduceRecordInfo(advice.PatientId, advice.RecordDate, advice.DrugId)
  928. if errcodeThree == gorm.ErrRecordNotFound {
  929. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  930. if errTwo != nil {
  931. return errTwo
  932. }
  933. }
  934. if errcodeThree == nil {
  935. UpdateDrugAutoReduceRecordInfo(advice.PatientId, advice.RecordDate, advice.DrugId, details)
  936. }
  937. var out_count int64
  938. var cancel_count int64
  939. //查询出库数据
  940. infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  941. //查询退库数据
  942. cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  943. for _, item := range infoCountList {
  944. out_count += item.Count
  945. }
  946. for _, item := range cancelInfoList {
  947. cancel_count += item.Count
  948. }
  949. //如果本次出库数据大于历史出库数据 新增1条流水
  950. if deliver_number > (out_count - cancel_count) {
  951. drugflow := models.DrugFlow{
  952. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  953. WarehouseOutId: warehouseout.ID,
  954. DrugId: advice.DrugId,
  955. Number: warehouse.Number,
  956. ProductDate: warehouse.ProductDate,
  957. ExpireDate: warehouse.ExpiryDate,
  958. Count: stock_number,
  959. Price: warehouse.RetailPrice,
  960. Status: 1,
  961. Ctime: time.Now().Unix(),
  962. UserOrgId: orgID,
  963. Manufacturer: warehouse.Manufacturer,
  964. Dealer: warehouse.Dealer,
  965. BatchNumber: warehouse.BatchNumber,
  966. MaxUnit: drup.MinUnit,
  967. ConsumableType: 3,
  968. IsEdit: 1,
  969. Creator: advice.ExecutionStaff,
  970. IsSys: 1,
  971. PatientId: advice.PatientId,
  972. WarehousingDetailId: warehouse.ID,
  973. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  974. StorehouseId: storeConfig.DrugStorehouseOut,
  975. WarehouseOutDetailId: lastDrugOutInfo.ID,
  976. OverCount: sum_count,
  977. AdviceId: advice.ID,
  978. }
  979. CreateDrugFlowOne(drugflow)
  980. //出库数量相加
  981. AddDrugCount(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, drugflow.Count)
  982. }
  983. if deliver_number < (out_count - cancel_count) {
  984. operation_time := time.Now().Unix()
  985. ctime := time.Now().Unix()
  986. timeStr := time.Now().Format("2006-01-02")
  987. timeArr := strings.Split(timeStr, "-")
  988. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  989. total = total + 1
  990. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  991. cancelStock := models.DrugCancelStock{
  992. OrderNumber: orderNumber,
  993. OperaTime: operation_time,
  994. OrgId: advice.UserOrgId,
  995. Creater: advice.ExecutionStaff,
  996. Ctime: ctime,
  997. Status: 1,
  998. ReturnTime: advice.AdviceDate,
  999. Dealer: 0,
  1000. Manufacturer: 0,
  1001. Type: 1,
  1002. StorehouseId: storeConfig.DrugStorehouseOut,
  1003. IsCheck: 1,
  1004. }
  1005. _, errCode := FindDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1006. if errCode == gorm.ErrRecordNotFound {
  1007. AddSigleDrugCancelStock(&cancelStock)
  1008. }
  1009. lastDrugCancelStock, _ := FindLastDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1010. manufactureName, _ := GetManufactureById(warehouse.Manufacturer)
  1011. dealer, _ := GetDealerById(warehouse.Dealer)
  1012. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  1013. cancelStockInfo := models.DrugCancelStockInfo{
  1014. OrderNumber: cancelInfo.OrderNumber,
  1015. CancelStockId: lastDrugCancelStock.ID,
  1016. DrugId: advice.DrugId,
  1017. Count: (out_count - cancel_count) - deliver_number,
  1018. Status: 1,
  1019. Ctime: ctime,
  1020. OrgId: advice.UserOrgId,
  1021. Type: 1,
  1022. Manufacturer: manufactureName.ManufacturerName,
  1023. Dealer: dealer.DealerName,
  1024. Total: 0,
  1025. RetailPrice: warehouse.RetailPrice,
  1026. RetailTotalPrice: warehouse.RetailTotalPrice,
  1027. Price: warehouse.Price,
  1028. RegisterAccount: "",
  1029. Remark: warehouse.Remark,
  1030. BatchNumber: warehouse.BatchNumber,
  1031. MaxUnit: drup.MinUnit,
  1032. ProductDate: warehouse.ProductDate,
  1033. ExpiryDate: warehouse.ExpiryDate,
  1034. BatchNumberId: warehouse.ID,
  1035. StorehouseId: storeConfig.DrugStorehouseOut,
  1036. IsCheck: 1,
  1037. }
  1038. CreatedCancelStock(cancelStockInfo)
  1039. flow := models.DrugFlow{
  1040. WarehousingId: warehouse.ID,
  1041. DrugId: warehouse.DrugId,
  1042. Number: "",
  1043. BatchNumber: warehouse.BatchNumber,
  1044. Count: (out_count - cancel_count) - deliver_number,
  1045. UserOrgId: advice.UserOrgId,
  1046. PatientId: advice.PatientId,
  1047. SystemTime: advice.AdviceDate,
  1048. ConsumableType: 7,
  1049. IsSys: 0,
  1050. WarehousingOrder: "",
  1051. WarehouseOutId: 0,
  1052. WarehouseOutOrderNumber: "",
  1053. IsEdit: 0,
  1054. CancelStockId: cancelStock.ID,
  1055. CancelOrderNumber: cancelStock.OrderNumber,
  1056. Manufacturer: warehouse.Manufacturer,
  1057. Dealer: warehouse.Dealer,
  1058. Creator: advice.ExecutionStaff,
  1059. UpdateCreator: 0,
  1060. Status: 1,
  1061. Ctime: time.Now().Unix(),
  1062. Mtime: 0,
  1063. Price: warehouse.Price,
  1064. WarehousingDetailId: warehouse.ID,
  1065. WarehouseOutDetailId: 0,
  1066. CancelOutDetailId: lastDrugCancelStock.ID,
  1067. ExpireDate: warehouse.ExpiryDate,
  1068. ProductDate: warehouse.ProductDate,
  1069. MaxUnit: drup.MinUnit,
  1070. MinUnit: "",
  1071. AdviceId: advice.ID,
  1072. StorehouseId: storeConfig.DrugStorehouseOut,
  1073. }
  1074. CreateDrugFlowOne(flow)
  1075. AddCancelSumCountOne(storeConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, flow.Count)
  1076. ReduceDrugCountTwo(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, flow.Count)
  1077. }
  1078. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1079. prescribingNumber_two_temp := deliver_number - stock_number
  1080. overPlusNumber := float64(prescribingNumber_two_temp)
  1081. advice.PrescribingNumber = float64(prescribingNumber_two_temp)
  1082. advice.PrescribingNumberUnit = drup.MinUnit
  1083. BloodDrugDeliverInfo(orgID, overPlusNumber, warehouseout, drup, advice)
  1084. }
  1085. return
  1086. }
  1087. // 药品自动出库 递归方式
  1088. func BloodHisDrugDeliverInfo(orgID int64, prescribingNumber float64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.HisDoctorAdviceInfo) (err error) {
  1089. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  1090. var deliver_number int64 = 0
  1091. var stock_number int64 = 0
  1092. prescribingNumber_temp := strconv.FormatFloat(math.Abs(prescribingNumber), 'f', 0, 64)
  1093. count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
  1094. var drug_price float64
  1095. if advice.PrescribingNumberUnit == drup.MaxUnit {
  1096. deliver_number = count * drup.MinNumber
  1097. } else {
  1098. deliver_number = count
  1099. }
  1100. if advice.PrescribingNumberUnit == drup.MaxUnit {
  1101. drug_price = drup.RetailPrice
  1102. }
  1103. fmt.Println(drug_price)
  1104. if advice.PrescribingNumberUnit == drup.MinUnit {
  1105. drug_price = drup.MinPrice
  1106. }
  1107. if advice.PrescribingNumberUnit != drup.MaxUnit || advice.PrescribingNumberUnit != drup.MinUnit {
  1108. drug_price = drup.RetailPrice
  1109. }
  1110. // 根据先进先出原则,查询最先入库的批次,进行出库
  1111. // 如果没有对应的库存,则报错
  1112. storeConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
  1113. lastWarehouse, _ := FindLastDrugWarehousingInfoByID(advice.DrugId, storeConfig.DrugStorehouseOut)
  1114. if lastWarehouse.StockMinNumber >= drup.MinNumber {
  1115. var stockMax int64
  1116. var stockMin int64
  1117. stockMax = lastWarehouse.StockMinNumber / drup.MinNumber
  1118. stockMin = lastWarehouse.StockMinNumber % drup.MinNumber
  1119. ChangeMaxNumber(lastWarehouse.ID, stockMax)
  1120. UpdateMinNumber(lastWarehouse.ID, stockMin)
  1121. }
  1122. warehouse, err := FindLastDrugWarehousingInfoByID(advice.DrugId, storeConfig.DrugStorehouseOut)
  1123. if err != nil {
  1124. return err
  1125. }
  1126. // 将该批次的剩余库存数量转换为拆零数量
  1127. stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
  1128. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  1129. if stock_number >= deliver_number {
  1130. var maxNumber int64 = 0
  1131. var minNumber int64 = 0
  1132. maxNumber = deliver_number / drup.MinNumber
  1133. minNumber = deliver_number % drup.MinNumber
  1134. if warehouse.StockMaxNumber == 0 && drup.MaxUnit == drup.MinUnit {
  1135. minNumber = maxNumber
  1136. }
  1137. if drup.MaxUnit != drup.MinUnit {
  1138. if warehouse.StockMaxNumber < maxNumber && warehouse.StockMinNumber < minNumber {
  1139. return errors.New("库存数量不足")
  1140. }
  1141. }
  1142. warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
  1143. if warehouse.StockMaxNumber < 0 {
  1144. warehouse.StockMaxNumber = 0
  1145. }
  1146. if warehouse.StockMinNumber < 0 {
  1147. warehouse.StockMinNumber = 0
  1148. }
  1149. warehouse.Mtime = time.Now().Unix()
  1150. if warehouse.StockMinNumber < minNumber {
  1151. warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
  1152. warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
  1153. } else {
  1154. if minNumber > 0 {
  1155. warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
  1156. }
  1157. if minNumber == 0 && maxNumber != 1 && warehouse.StockMaxNumber <= 0 {
  1158. if warehouse.StockMinNumber > 0 {
  1159. warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
  1160. }
  1161. }
  1162. }
  1163. if maxNumber == 1 && minNumber == 0 && drup.MaxUnit != drup.MinUnit {
  1164. if (warehouse.StockMinNumber - deliver_number) > 0 {
  1165. warehouse.StockMinNumber = warehouse.StockMinNumber - deliver_number
  1166. }
  1167. }
  1168. if drup.MaxUnit != drup.MinUnit {
  1169. if warehouse.StockMaxNumber < 0 && warehouse.StockMinNumber < 0 {
  1170. return errors.New("库存数量不足")
  1171. }
  1172. }
  1173. if warehouse.StockMinNumber <= 0 {
  1174. warehouse.StockMinNumber = 0
  1175. }
  1176. //扣减库存数据
  1177. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  1178. if errThree != nil {
  1179. return errThree
  1180. }
  1181. //查询剩余库存
  1182. stockInfo, _ := GetDrugAllStockInfo(storeConfig.DrugStorehouseOut, orgID, advice.DrugId)
  1183. var sum_count int64
  1184. for _, its := range stockInfo {
  1185. sum_count += its.StockMaxNumber*drup.MinNumber + its.StockMinNumber
  1186. }
  1187. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  1188. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  1189. WarehouseOutId: warehouseout.ID,
  1190. Status: 1,
  1191. Ctime: time.Now().Unix(),
  1192. Remark: warehouse.Remark,
  1193. OrgId: orgID,
  1194. Type: 1,
  1195. Manufacturer: warehouse.Manufacturer,
  1196. Dealer: warehouse.Dealer,
  1197. IsSys: 1,
  1198. SysRecordTime: advice.RecordDate,
  1199. DrugId: advice.DrugId,
  1200. Number: warehouse.Number,
  1201. BatchNumber: warehouse.BatchNumber,
  1202. Price: warehouse.RetailPrice,
  1203. CountUnit: drup.MinUnit,
  1204. RetailPrice: warehouse.RetailPrice,
  1205. ProductDate: warehouse.ProductDate,
  1206. ExpiryDate: warehouse.ExpiryDate,
  1207. PatientId: advice.PatientId,
  1208. Count: deliver_number, //出最小单位
  1209. WarehouseInfoId: warehouse.ID,
  1210. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  1211. StorehouseId: storeConfig.DrugStorehouseOut,
  1212. IsCheck: 1,
  1213. OverCount: sum_count,
  1214. AdviceId: advice.ID,
  1215. }
  1216. //查询今日该药品该患者是否有出库数据
  1217. lastDrugOutInfo, _ := GetNewDrugWarehouseOutInfoSix(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID, warehouse.ID)
  1218. fmt.Println("lastDrugOutInfowwowowowoowowowowowowowowo", lastDrugOutInfo.ID)
  1219. if lastDrugOutInfo.ID == 0 {
  1220. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  1221. if errOne != nil {
  1222. return errOne
  1223. }
  1224. }
  1225. if lastDrugOutInfo.ID > 0 {
  1226. var his_count int64
  1227. if lastDrugOutInfo.CountUnit == drup.MaxUnit {
  1228. his_count = lastDrugOutInfo.Count * drup.MinNumber
  1229. }
  1230. if lastDrugOutInfo.CountUnit == drup.MinUnit {
  1231. his_count = lastDrugOutInfo.Count
  1232. }
  1233. if deliver_number != his_count {
  1234. errThree := UpdateSigleDrugWarehouseOutInfo(lastDrugOutInfo.ID, warehouseOutInfo)
  1235. if errThree != nil {
  1236. return errThree
  1237. }
  1238. }
  1239. }
  1240. var out_count int64
  1241. var cancel_count int64
  1242. //查询出库数据
  1243. infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  1244. //查询退库数据
  1245. cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  1246. for _, item := range infoCountList {
  1247. out_count += item.Count
  1248. }
  1249. for _, item := range cancelInfoList {
  1250. cancel_count += item.Count
  1251. }
  1252. fmt.Println("deliver_number", deliver_number)
  1253. fmt.Println("out_count", out_count)
  1254. fmt.Println("cancel_count", cancel_count)
  1255. //如果本次出库数据大于历史出库数据 新增1条流水
  1256. if deliver_number > (out_count - cancel_count) {
  1257. drugflow := models.DrugFlow{
  1258. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  1259. WarehouseOutId: warehouseout.ID,
  1260. DrugId: advice.DrugId,
  1261. Number: warehouse.Number,
  1262. ProductDate: warehouse.ProductDate,
  1263. ExpireDate: warehouse.ExpiryDate,
  1264. Count: deliver_number - (out_count - cancel_count), //按最小单位计算,
  1265. Price: warehouse.RetailPrice,
  1266. Status: 1,
  1267. Ctime: time.Now().Unix(),
  1268. UserOrgId: orgID,
  1269. Manufacturer: warehouse.Manufacturer,
  1270. Dealer: warehouse.Dealer,
  1271. BatchNumber: warehouse.BatchNumber,
  1272. MaxUnit: drup.MinUnit,
  1273. ConsumableType: 3,
  1274. IsEdit: 1,
  1275. Creator: advice.ExecutionStaff,
  1276. IsSys: 1,
  1277. PatientId: advice.PatientId,
  1278. SystemTime: advice.AdviceDate,
  1279. WarehousingDetailId: warehouse.ID,
  1280. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  1281. StorehouseId: storeConfig.DrugStorehouseOut,
  1282. WarehouseOutDetailId: lastDrugOutInfo.ID,
  1283. OverCount: sum_count,
  1284. AdviceId: advice.ID,
  1285. LastPrice: warehouse.Price,
  1286. }
  1287. CreateDrugFlowOne(drugflow)
  1288. //出库数量相加
  1289. AddDrugCount(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, drugflow.Count)
  1290. }
  1291. //如果本次出库数据小于历史出库数据 新增1条退库流水
  1292. if deliver_number < (out_count - cancel_count) {
  1293. operation_time := time.Now().Unix()
  1294. ctime := time.Now().Unix()
  1295. timeStr := time.Now().Format("2006-01-02")
  1296. timeArr := strings.Split(timeStr, "-")
  1297. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  1298. total = total + 1
  1299. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  1300. cancelStock := models.DrugCancelStock{
  1301. OrderNumber: orderNumber,
  1302. OperaTime: operation_time,
  1303. OrgId: advice.UserOrgId,
  1304. Creater: advice.ExecutionStaff,
  1305. Ctime: ctime,
  1306. Status: 1,
  1307. ReturnTime: advice.AdviceDate,
  1308. Dealer: 0,
  1309. Manufacturer: 0,
  1310. Type: 1,
  1311. StorehouseId: storeConfig.DrugStorehouseOut,
  1312. IsCheck: 1,
  1313. }
  1314. _, errCode := FindDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1315. if errCode == gorm.ErrRecordNotFound {
  1316. AddSigleDrugCancelStock(&cancelStock)
  1317. }
  1318. lastDrugCancelStock, _ := FindLastDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1319. manufactureName, _ := GetManufactureById(warehouse.Manufacturer)
  1320. dealer, _ := GetDealerById(warehouse.Dealer)
  1321. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  1322. cancelStockInfo := models.DrugCancelStockInfo{
  1323. OrderNumber: cancelInfo.OrderNumber,
  1324. CancelStockId: lastDrugCancelStock.ID,
  1325. DrugId: advice.DrugId,
  1326. Count: (out_count - cancel_count) - deliver_number,
  1327. Status: 1,
  1328. Ctime: ctime,
  1329. OrgId: advice.UserOrgId,
  1330. Type: 1,
  1331. Manufacturer: manufactureName.ManufacturerName,
  1332. Dealer: dealer.DealerName,
  1333. Total: 0,
  1334. RetailPrice: warehouse.RetailPrice,
  1335. RetailTotalPrice: warehouse.RetailTotalPrice,
  1336. Price: warehouse.Price,
  1337. RegisterAccount: "",
  1338. Remark: warehouse.Remark,
  1339. BatchNumber: warehouse.BatchNumber,
  1340. MaxUnit: drup.MinUnit,
  1341. ProductDate: warehouse.ProductDate,
  1342. ExpiryDate: warehouse.ExpiryDate,
  1343. BatchNumberId: warehouse.ID,
  1344. StorehouseId: storeConfig.DrugStorehouseOut,
  1345. IsCheck: 1,
  1346. }
  1347. CreatedCancelStock(cancelStockInfo)
  1348. flow := models.DrugFlow{
  1349. WarehousingId: warehouse.ID,
  1350. DrugId: warehouse.DrugId,
  1351. Number: "",
  1352. BatchNumber: warehouse.BatchNumber,
  1353. Count: out_count - cancel_count - deliver_number,
  1354. UserOrgId: advice.UserOrgId,
  1355. PatientId: advice.PatientId,
  1356. SystemTime: advice.AdviceDate,
  1357. ConsumableType: 7,
  1358. IsSys: 0,
  1359. WarehousingOrder: "",
  1360. WarehouseOutId: 0,
  1361. WarehouseOutOrderNumber: "",
  1362. IsEdit: 0,
  1363. CancelStockId: cancelStock.ID,
  1364. CancelOrderNumber: cancelStock.OrderNumber,
  1365. Manufacturer: warehouse.Manufacturer,
  1366. Dealer: warehouse.Dealer,
  1367. Creator: advice.ExecutionStaff,
  1368. UpdateCreator: 0,
  1369. Status: 1,
  1370. Ctime: time.Now().Unix(),
  1371. Mtime: 0,
  1372. Price: warehouse.RetailPrice,
  1373. WarehousingDetailId: warehouse.ID,
  1374. WarehouseOutDetailId: 0,
  1375. CancelOutDetailId: lastDrugCancelStock.ID,
  1376. ExpireDate: warehouse.ExpiryDate,
  1377. ProductDate: warehouse.ProductDate,
  1378. MaxUnit: drup.MinUnit,
  1379. MinUnit: "",
  1380. AdviceId: advice.ID,
  1381. StorehouseId: storeConfig.DrugStorehouseOut,
  1382. LastPrice: warehouse.Price,
  1383. }
  1384. CreateDrugFlowOne(flow)
  1385. AddCancelSumCountOne(storeConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, flow.Count)
  1386. ReduceDrugCountTwo(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, flow.Count)
  1387. }
  1388. //查询是否存在数据
  1389. details := &models.DrugAutomaticReduceDetail{
  1390. WarehouseOutId: warehouseout.ID,
  1391. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  1392. PatientId: advice.PatientId,
  1393. Ctime: time.Now().Unix(),
  1394. Mtime: time.Now().Unix(),
  1395. Status: 1,
  1396. RecordTime: advice.RecordDate,
  1397. OrgId: orgID,
  1398. DrugId: advice.DrugId,
  1399. Count: deliver_number,
  1400. CountUnit: drup.MinUnit,
  1401. WarehouseInfoId: warehouse.ID,
  1402. StorehouseId: storeConfig.DrugStorehouseOut,
  1403. AdviceId: advice.ID,
  1404. }
  1405. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  1406. if errTwo != nil {
  1407. return errTwo
  1408. }
  1409. return nil
  1410. } else {
  1411. info := models.XtDrugWarehouseInfo{
  1412. ID: warehouse.ID,
  1413. WarehousingId: warehouse.WarehousingId,
  1414. DrugId: warehouse.DrugId,
  1415. Number: warehouse.Number,
  1416. ProductDate: warehouse.ProductDate,
  1417. ExpiryDate: warehouse.ExpiryDate,
  1418. WarehousingCount: warehouse.WarehousingCount,
  1419. Price: warehouse.RetailPrice,
  1420. TotalPrice: warehouse.TotalPrice,
  1421. Dealer: warehouse.Dealer,
  1422. Manufacturer: warehouse.Manufacturer,
  1423. Remark: warehouse.Remark,
  1424. Ctime: warehouse.Ctime,
  1425. Mtime: warehouse.Mtime,
  1426. Status: 1,
  1427. OrgId: warehouse.OrgId,
  1428. IsReturn: warehouse.IsReturn,
  1429. WarehousingOrder: warehouse.WarehousingOrder,
  1430. Type: warehouse.Type,
  1431. RetailPrice: warehouse.RetailPrice,
  1432. RetailTotalPrice: warehouse.RetailPrice,
  1433. StockMaxNumber: 0,
  1434. StockMinNumber: 0,
  1435. BatchNumber: warehouse.BatchNumber,
  1436. MaxUnit: warehouse.MaxUnit,
  1437. WarehousingInfoId: warehouse.WarehousingInfoId,
  1438. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  1439. StorehouseId: storeConfig.DrugStorehouseOut,
  1440. IsCheck: 1,
  1441. }
  1442. //扣减库存
  1443. errThree := UpDateDrugWarehouseInfoByStock(&info)
  1444. if errThree != nil {
  1445. return errThree
  1446. }
  1447. //查询剩余库存
  1448. stockInfo, _ := GetDrugAllStockInfo(storeConfig.DrugStorehouseOut, orgID, advice.DrugId)
  1449. var sum_count int64
  1450. for _, its := range stockInfo {
  1451. sum_count += its.StockMaxNumber*drup.MinNumber + its.StockMinNumber
  1452. }
  1453. // 当该批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  1454. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  1455. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  1456. WarehouseOutId: warehouseout.ID,
  1457. Status: 1,
  1458. Ctime: time.Now().Unix(),
  1459. Remark: warehouse.Remark,
  1460. OrgId: orgID,
  1461. Type: 1,
  1462. Manufacturer: warehouse.Manufacturer,
  1463. Dealer: warehouse.Dealer,
  1464. IsSys: 1,
  1465. SysRecordTime: advice.RecordDate,
  1466. DrugId: advice.DrugId,
  1467. Number: warehouse.Number,
  1468. BatchNumber: warehouse.BatchNumber,
  1469. Price: warehouse.RetailPrice,
  1470. CountUnit: drup.MinUnit,
  1471. ProductDate: warehouse.ProductDate,
  1472. ExpiryDate: warehouse.ExpiryDate,
  1473. PatientId: advice.PatientId,
  1474. Count: stock_number,
  1475. WarehouseInfoId: warehouse.ID,
  1476. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  1477. StorehouseId: storeConfig.DrugStorehouseOut,
  1478. IsCheck: 1,
  1479. OverCount: sum_count,
  1480. AdviceId: advice.ID,
  1481. }
  1482. //查询是否存在出库数据
  1483. _, errCode := GetSigleDrugWarehouseOutInfo(advice.PatientId, advice.AdviceDate, orgID)
  1484. if errCode == gorm.ErrRecordNotFound {
  1485. fmt.Println("j你俩3233223323232323233wo")
  1486. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  1487. if errOne != nil {
  1488. return errOne
  1489. }
  1490. }
  1491. if errCode == nil {
  1492. lastDrugOutInfo, _ := GetSigleDrugWarehouseOutInfoOne(advice.PatientId, advice.AdviceDate, orgID)
  1493. var his_count int64
  1494. if lastDrugOutInfo.CountUnit == drup.MaxUnit {
  1495. his_count = lastDrugOutInfo.Count * drup.MinNumber
  1496. }
  1497. if lastDrugOutInfo.CountUnit == drup.MinUnit {
  1498. his_count = lastDrugOutInfo.Count
  1499. }
  1500. if deliver_number != his_count {
  1501. errThree := UpdateSingleDrugWarehouseOutInfoSix(advice.PatientId, advice.AdviceDate, orgID, warehouseOutInfo, advice.ID)
  1502. if errThree != nil {
  1503. return errThree
  1504. }
  1505. }
  1506. }
  1507. lastDrugOutInfo, _ := FindLastDrugWarehouseOutInfo(orgID)
  1508. details := &models.DrugAutomaticReduceDetail{
  1509. WarehouseOutId: warehouseout.ID,
  1510. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  1511. PatientId: advice.PatientId,
  1512. Ctime: time.Now().Unix(),
  1513. Mtime: time.Now().Unix(),
  1514. Status: 1,
  1515. RecordTime: advice.RecordDate,
  1516. OrgId: orgID,
  1517. DrugId: advice.DrugId,
  1518. Count: stock_number,
  1519. CountUnit: drup.MinUnit,
  1520. WarehouseInfoId: warehouse.ID,
  1521. StorehouseId: storeConfig.DrugStorehouseOut,
  1522. AdviceId: advice.ID,
  1523. }
  1524. _, errcodeThree := FindDrugAutoReduceRecordInfo(advice.PatientId, advice.RecordDate, advice.DrugId)
  1525. if errcodeThree == gorm.ErrRecordNotFound {
  1526. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  1527. if errTwo != nil {
  1528. return errTwo
  1529. }
  1530. }
  1531. if errcodeThree == nil {
  1532. UpdateDrugAutoReduceRecordInfo(advice.PatientId, advice.RecordDate, advice.DrugId, details)
  1533. }
  1534. var out_count int64
  1535. var cancel_count int64
  1536. //查询出库数据
  1537. infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  1538. //查询退库数据
  1539. cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
  1540. for _, item := range infoCountList {
  1541. out_count += item.Count
  1542. }
  1543. for _, item := range cancelInfoList {
  1544. cancel_count += item.Count
  1545. }
  1546. //如果本次出库数据大于历史出库数据 新增1条流水
  1547. if deliver_number > (out_count - cancel_count) {
  1548. drugflow := models.DrugFlow{
  1549. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  1550. WarehouseOutId: warehouseout.ID,
  1551. DrugId: advice.DrugId,
  1552. Number: warehouse.Number,
  1553. ProductDate: warehouse.ProductDate,
  1554. ExpireDate: warehouse.ExpiryDate,
  1555. Count: stock_number,
  1556. Price: warehouse.RetailPrice,
  1557. Status: 1,
  1558. Ctime: time.Now().Unix(),
  1559. UserOrgId: orgID,
  1560. Manufacturer: warehouse.Manufacturer,
  1561. Dealer: warehouse.Dealer,
  1562. BatchNumber: warehouse.BatchNumber,
  1563. MaxUnit: drup.MinUnit,
  1564. ConsumableType: 3,
  1565. IsEdit: 1,
  1566. Creator: advice.ExecutionStaff,
  1567. IsSys: 1,
  1568. PatientId: advice.PatientId,
  1569. WarehousingDetailId: warehouse.ID,
  1570. SupplyWarehouseId: warehouse.SupplyWarehouseId,
  1571. StorehouseId: storeConfig.DrugStorehouseOut,
  1572. WarehouseOutDetailId: lastDrugOutInfo.ID,
  1573. OverCount: sum_count,
  1574. AdviceId: advice.ID,
  1575. LastPrice: warehouse.Price,
  1576. }
  1577. CreateDrugFlowOne(drugflow)
  1578. //出库数量相加
  1579. AddDrugCount(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, drugflow.Count)
  1580. }
  1581. if deliver_number < (out_count - cancel_count) {
  1582. operation_time := time.Now().Unix()
  1583. ctime := time.Now().Unix()
  1584. timeStr := time.Now().Format("2006-01-02")
  1585. timeArr := strings.Split(timeStr, "-")
  1586. total, _ := FindAllDrugCancelStockTotal(advice.UserOrgId)
  1587. total = total + 1
  1588. orderNumber := "CKTKD" + strconv.FormatInt(advice.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
  1589. cancelStock := models.DrugCancelStock{
  1590. OrderNumber: orderNumber,
  1591. OperaTime: operation_time,
  1592. OrgId: advice.UserOrgId,
  1593. Creater: advice.ExecutionStaff,
  1594. Ctime: ctime,
  1595. Status: 1,
  1596. ReturnTime: advice.AdviceDate,
  1597. Dealer: 0,
  1598. Manufacturer: 0,
  1599. Type: 1,
  1600. StorehouseId: storeConfig.DrugStorehouseOut,
  1601. IsCheck: 1,
  1602. }
  1603. _, errCode := FindDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1604. if errCode == gorm.ErrRecordNotFound {
  1605. AddSigleDrugCancelStock(&cancelStock)
  1606. }
  1607. lastDrugCancelStock, _ := FindLastDrugCancelStock(advice.AdviceDate, advice.UserOrgId)
  1608. manufactureName, _ := GetManufactureById(warehouse.Manufacturer)
  1609. dealer, _ := GetDealerById(warehouse.Dealer)
  1610. cancelInfo, _ := GetLastDrugCancelStockById(advice.UserOrgId)
  1611. cancelStockInfo := models.DrugCancelStockInfo{
  1612. OrderNumber: cancelInfo.OrderNumber,
  1613. CancelStockId: lastDrugCancelStock.ID,
  1614. DrugId: advice.DrugId,
  1615. Count: (out_count - cancel_count) - deliver_number,
  1616. Status: 1,
  1617. Ctime: ctime,
  1618. OrgId: advice.UserOrgId,
  1619. Type: 1,
  1620. Manufacturer: manufactureName.ManufacturerName,
  1621. Dealer: dealer.DealerName,
  1622. Total: 0,
  1623. RetailPrice: warehouse.RetailPrice,
  1624. RetailTotalPrice: warehouse.RetailTotalPrice,
  1625. Price: warehouse.Price,
  1626. RegisterAccount: "",
  1627. Remark: warehouse.Remark,
  1628. BatchNumber: warehouse.BatchNumber,
  1629. MaxUnit: drup.MinUnit,
  1630. ProductDate: warehouse.ProductDate,
  1631. ExpiryDate: warehouse.ExpiryDate,
  1632. BatchNumberId: warehouse.ID,
  1633. StorehouseId: storeConfig.DrugStorehouseOut,
  1634. IsCheck: 1,
  1635. }
  1636. CreatedCancelStock(cancelStockInfo)
  1637. flow := models.DrugFlow{
  1638. WarehousingId: warehouse.ID,
  1639. DrugId: warehouse.DrugId,
  1640. Number: "",
  1641. BatchNumber: warehouse.BatchNumber,
  1642. Count: out_count - cancel_count - deliver_number,
  1643. UserOrgId: advice.UserOrgId,
  1644. PatientId: advice.PatientId,
  1645. SystemTime: advice.AdviceDate,
  1646. ConsumableType: 7,
  1647. IsSys: 0,
  1648. WarehousingOrder: "",
  1649. WarehouseOutId: 0,
  1650. WarehouseOutOrderNumber: "",
  1651. IsEdit: 0,
  1652. CancelStockId: cancelStock.ID,
  1653. CancelOrderNumber: cancelStock.OrderNumber,
  1654. Manufacturer: warehouse.Manufacturer,
  1655. Dealer: warehouse.Dealer,
  1656. Creator: advice.ExecutionStaff,
  1657. UpdateCreator: 0,
  1658. Status: 1,
  1659. Ctime: time.Now().Unix(),
  1660. Mtime: 0,
  1661. Price: warehouse.RetailPrice,
  1662. WarehousingDetailId: warehouse.ID,
  1663. WarehouseOutDetailId: 0,
  1664. CancelOutDetailId: lastDrugCancelStock.ID,
  1665. ExpireDate: warehouse.ExpiryDate,
  1666. ProductDate: warehouse.ProductDate,
  1667. MaxUnit: drup.MinUnit,
  1668. MinUnit: "",
  1669. AdviceId: advice.ID,
  1670. StorehouseId: storeConfig.DrugStorehouseOut,
  1671. LastPrice: warehouse.Price,
  1672. }
  1673. CreateDrugFlowOne(flow)
  1674. //退库数量增加
  1675. AddCancelSumCountOne(storeConfig.DrugStorehouseOut, advice.DrugId, advice.UserOrgId, flow.Count)
  1676. ReduceDrugCountTwo(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, flow.Count)
  1677. }
  1678. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1679. prescribingNumber_two_temp := deliver_number - stock_number
  1680. overPlusNumber := float64(prescribingNumber_two_temp)
  1681. advice.PrescribingNumber = float64(prescribingNumber_two_temp)
  1682. advice.PrescribingNumberUnit = drup.MinUnit
  1683. BloodHisDrugDeliverInfo(orgID, overPlusNumber, warehouseout, drup, advice)
  1684. }
  1685. return
  1686. }
  1687. func GetSigleDrugWarehouseOutInfoSix(patient_id int64, advice_date int64, orgid int64, advice_id int64) (*models.XtDrugWarehouseOutInfo, error) {
  1688. info := models.XtDrugWarehouseOutInfo{}
  1689. var err error
  1690. err = XTReadDB().Where("patient_id = ? and advice_date = ? and org_id = ? and status = 1 and advice_id =?", patient_id, advice_date, orgid, advice_id).Find(&info).Error
  1691. if err == gorm.ErrRecordNotFound {
  1692. return nil, err
  1693. }
  1694. if err != nil {
  1695. return nil, err
  1696. }
  1697. return &info, nil
  1698. }
  1699. func GetSigleDrugWarehouseOutInfo(patient_id int64, advice_date int64, orgid int64) (*models.XtDrugWarehouseOutInfo, error) {
  1700. info := models.XtDrugWarehouseOutInfo{}
  1701. var err error
  1702. err = XTReadDB().Where("patient_id = ? and sys_record_time = ? and org_id = ? and status = 1", patient_id, advice_date, orgid).Find(&info).Error
  1703. if err == gorm.ErrRecordNotFound {
  1704. return nil, err
  1705. }
  1706. if err != nil {
  1707. return nil, err
  1708. }
  1709. return &info, nil
  1710. }
  1711. func GetSigleDrugWarehouseOutInfoOne(patient_id int64, advice_date int64, orgid int64) (models.XtDrugWarehouseOutInfo, error) {
  1712. info := models.XtDrugWarehouseOutInfo{}
  1713. err = XTReadDB().Where("patient_id = ? and advice_date = ? and org_id = ? and status = 1", patient_id, advice_date, orgid).Find(&info).Error
  1714. return info, err
  1715. }
  1716. func UpdateSingleDrugWarehouseOutInfoSix(patient_id int64, advice_date int64, orgid int64, info *models.DrugWarehouseOutInfo, advice_id int64) error {
  1717. err := XTWriteDB().Model(&models.XtDrugWarehouseOutInfo{}).Where("patient_id = ? and advice_date = ? and org_id = ? and advice_id = ?", patient_id, advice_date, orgid, advice_id).Update(map[string]interface{}{"count": info.Count, "price": info.Price, "total_price": info.TotalPrice, "product_date": info.ProductDate, "expiry_date": info.ExpiryDate, "remark": info.Remark, "dealer": info.Dealer, "manufacturer": info.Manufacturer, "retail_price": info.RetailPrice, "number": info.Number, "batch_number": info.BatchNumber, "count_unit": info.CountUnit, "warehouse_info_id": info.WarehouseInfoId, "storehouse_id": info.StorehouseId}).Error
  1718. return err
  1719. }
  1720. func UpdateSingleDrugWarehouseOutInfo(patient_id int64, advice_date int64, orgid int64, info *models.DrugWarehouseOutInfo) error {
  1721. err := XTWriteDB().Model(&models.XtDrugWarehouseOutInfo{}).Where("patient_id = ? and advice_date = ? and org_id = ?", patient_id, advice_date, orgid).Update(map[string]interface{}{"count": info.Count, "price": info.Price, "total_price": info.TotalPrice, "product_date": info.ProductDate, "expiry_date": info.ExpiryDate, "remark": info.Remark, "dealer": info.Dealer, "manufacturer": info.Manufacturer, "retail_price": info.RetailPrice, "number": info.Number, "batch_number": info.BatchNumber, "count_unit": info.CountUnit, "warehouse_info_id": info.WarehouseInfoId, "storehouse_id": info.StorehouseId}).Error
  1722. return err
  1723. }
  1724. func FindDrugAutoReduceRecordInfo(patient_id int64, advice_date int64, orgid int64) (*models.DrugAutomaticReduceDetail, error) {
  1725. detail := models.DrugAutomaticReduceDetail{}
  1726. var err error
  1727. err = XTReadDB().Where("patient_id = ? and record_time = ? and org_id = ?", patient_id, advice_date, orgid).Find(&detail).Error
  1728. if err == gorm.ErrRecordNotFound {
  1729. return nil, err
  1730. }
  1731. if err != nil {
  1732. return nil, err
  1733. }
  1734. return &detail, nil
  1735. }
  1736. func UpdateDrugAutoReduceRecordInfo(patient_id int64, record_date int64, drug_id int64, detail *models.DrugAutomaticReduceDetail) error {
  1737. err := XTWriteDB().Model(&models.DrugAutomaticReduceDetail{}).Where("patient_id = ? and record_date = ? and drug_id = ?", patient_id, record_date, drug_id).Update(map[string]interface{}{"patient_id": detail.PatientId, "record_time": detail.RecordTime, "drug_id": detail.DrugId, "count": detail.Count, "count_unit": detail.CountUnit, "warehouse_info_id": detail.WarehouseInfoId, "advice_id": detail.AdviceId, "storehouse_id": detail.StorehouseId}).Error
  1738. return err
  1739. }
  1740. func GetNewDrugWarehouseOutInfoSix(drugid int64, patient_id int64, record_date int64, org_id int64, advice_id int64, warehouse_info_id int64) (models.DrugWarehouseOutInfo, error) {
  1741. info := models.DrugWarehouseOutInfo{}
  1742. var err error
  1743. err = XTReadDB().Where("drug_id = ? and patient_id = ? and sys_record_time = ? and org_id = ? and status = 1 and advice_id = ? and warehouse_info_id = ?", drugid, patient_id, record_date, org_id, advice_id, warehouse_info_id).Find(&info).Error
  1744. return info, err
  1745. }
  1746. func GetNewDrugWarehouseOutInfo(drugid int64, patient_id int64, record_date int64, org_id int64) (models.DrugWarehouseOutInfo, error) {
  1747. info := models.DrugWarehouseOutInfo{}
  1748. var err error
  1749. err = XTReadDB().Where("drug_id = ? and patient_id = ? and sys_record_time = ? and org_id = ? and status = 1 ", drugid, patient_id, record_date, org_id).Find(&info).Error
  1750. return info, err
  1751. }
  1752. func UpdateSigleDrugWarehouseOutInfo(id int64, info *models.DrugWarehouseOutInfo) error {
  1753. err := XTWriteDB().Model(models.DrugWarehouseOutInfo{}).Where("id = ? and status = 1", id).Update(map[string]interface{}{"warehouse_out_id": info.WarehouseOutId, "count": info.Count, "count_unit": info.CountUnit, "price": info.Price, "total_price": info.TotalPrice, "product_date": info.ProductDate, "expiry_date": info.ExpiryDate, "mtime": time.Now().Unix(), "remark": info.Remark, "dealer": info.Dealer, "manufacturer": info.Manufacturer, "retail_price": info.RetailPrice, "retail_total_price": info.RetailTotalPrice, "warehouse_info_id": info.WarehouseInfoId, "number": info.Number, "batch_number": info.BatchNumber, "advice_id": info.AdviceId, "storehouse_id": info.StorehouseId, "last_price": info.LastPrice, "over_count": info.OverCount}).Error
  1754. return err
  1755. }
  1756. func UpdateSigleDrugWarehouseOutInfoTwo(id int64, info *models.DrugWarehouseOutInfo) error {
  1757. err := XTWriteDB().Model(models.DrugWarehouseOutInfo{}).Where("id = ? and status = 1", id).Update(map[string]interface{}{"warehouse_out_id": info.WarehouseOutId, "count": info.Count, "count_unit": info.CountUnit, "price": info.Price, "total_price": info.TotalPrice, "product_date": info.ProductDate, "expiry_date": info.ExpiryDate, "mtime": time.Now().Unix(), "remark": info.Remark, "dealer": info.Dealer, "manufacturer": info.Manufacturer, "retail_price": info.RetailPrice, "retail_total_price": info.RetailTotalPrice, "warehouse_info_id": info.WarehouseInfoId, "number": info.Number, "batch_number": info.BatchNumber, "advice_id": info.AdviceId, "storehouse_id": info.StorehouseId, "last_price": info.LastPrice}).Error
  1758. return err
  1759. }
  1760. func FindDrugWarehouseOutInfoCount(drugid int64, patient_id int64, record_date int64, org_id int64, advice_id int64) (flow []*models.DrugFlow, err error) {
  1761. err = XTReadDB().Where("drug_id = ? and patient_id = ? and system_time = ? and user_org_id = ? and consumable_type = 3 and status = 1 and advice_id = ?", drugid, patient_id, record_date, org_id, advice_id).Find(&flow).Error
  1762. return flow, err
  1763. }
  1764. func FindDrugCancelOutInfo(drugid int64, patient_id int64, record_date int64, org_id int64, advice_id int64) (flow []*models.DrugFlow, err error) {
  1765. err = XTReadDB().Where("drug_id = ? and patient_id = ? and system_time = ? and user_org_id = ? and consumable_type = 7 and status = 1 and advice_id = ?", drugid, patient_id, record_date, org_id, advice_id).Find(&flow).Error
  1766. return flow, err
  1767. }
  1768. func FindDrugCancelStock(return_date int64, org_id int64) (*models.DrugCancelStock, error) {
  1769. stock := models.DrugCancelStock{}
  1770. var err error
  1771. err = XTReadDB().Where("return_date = ? and org_id = ? and status = 1", return_date, org_id).Find(&stock).Error
  1772. if err == gorm.ErrRecordNotFound {
  1773. return nil, err
  1774. }
  1775. if err != nil {
  1776. return nil, err
  1777. }
  1778. return &stock, nil
  1779. }
  1780. func FindLastDrugCancelStock(advice_date int64, org_id int64) (models.DrugCancelStock, error) {
  1781. cancelStock := models.DrugCancelStock{}
  1782. err := XTReadDB().Where("return_date = ? and org_id = ? and status = 1", advice_date, org_id).Find(&cancelStock).Error
  1783. return cancelStock, err
  1784. }
  1785. func GetAllSumDrugWarehouseOut(patient_id int64, user_org_id int64, advice_date int64) (advice []*models.HisDoctorAdvice, err error) {
  1786. err = XTReadDB().Where("patient_id = ? and user_org_id = ? and advice_date = ? and status = 1", patient_id, user_org_id, advice_date).Find(&advice).Error
  1787. return advice, err
  1788. }
  1789. func UpdateDrugWarehouseOutByPatientId(patient_id int64, advice_date int64, orgid int64, info models.DrugWarehouseOutInfo) error {
  1790. err := XTWriteDB().Model(&models.DrugWarehouseOutInfo{}).Where("patient_id = ? and sys_record_time = ? and org_id = ? and status = 1", patient_id, advice_date, orgid).Update(map[string]interface{}{"count": info.Count, "count_unit": info.CountUnit}).Error
  1791. return err
  1792. }