warhouse_service.go 50KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448
  1. package service
  2. import (
  3. "XT_New/models"
  4. "XT_New/models/service"
  5. "XT_New/utils"
  6. "errors"
  7. "fmt"
  8. _ "fmt"
  9. "github.com/jinzhu/gorm"
  10. "math"
  11. "strconv"
  12. "strings"
  13. "time"
  14. )
  15. // 药品出库
  16. func DrugsDelivery(orgID int64, advice *models.DoctorAdvice) (err error) {
  17. // 1.判断药品是否来自专用字典的药品库
  18. // 2.判断当天当前机构有没有创建出库单,没有则创建
  19. // 3.创建出库流程
  20. // 3.1 实现先进先出逻辑 由于药品执行后,不可以修改和删除,所以不考虑出库后的退库和修改出库数量等
  21. isHasWay := false
  22. record_time := int64(0)
  23. if advice.Way == 1 {
  24. isHasWay = true
  25. record_time = advice.RecordDate
  26. }
  27. fmt.Println("isHasway99999999999999999999999999999999", isHasWay)
  28. if isHasWay {
  29. //判断当天当前机构有没有创建出库单,没有则创建
  30. out, err := FindDrugStockOutByIsSys(orgID, 1, record_time)
  31. if err == gorm.ErrRecordNotFound {
  32. timeStr := time.Now().Format("2006-01-02")
  33. timeArr := strings.Split(timeStr, "-")
  34. total, _ := FindAllDrugWarehouseOut(orgID)
  35. total = total + 1
  36. warehousing_out_order := strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
  37. number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
  38. number = number + total
  39. warehousing_out_order = "YPCKD" + strconv.FormatInt(number, 10)
  40. // creater := adminUserInfo.AdminUser.Id
  41. warehouseOut := models.DrugWarehouseOut{
  42. WarehouseOutOrderNumber: warehousing_out_order,
  43. OperationTime: time.Now().Unix(),
  44. OrgId: orgID,
  45. Creater: 0,
  46. Ctime: time.Now().Unix(),
  47. Status: 1,
  48. WarehouseOutTime: record_time,
  49. Dealer: 0,
  50. Manufacturer: 0,
  51. Type: 1,
  52. IsSys: 1,
  53. }
  54. err := AddSigleDrugWarehouseOut(&warehouseOut)
  55. if err != nil {
  56. utils.TraceLog("创建出库单失败 err = %v", err)
  57. return err
  58. } else {
  59. out = warehouseOut
  60. }
  61. }
  62. // 出库流程
  63. // 1.查询改药品在药品库的规格信息,并将处方里的规格进行换算(尽量将拆零单位转换成包装单位)
  64. drup, _ := FindBaseDrugLibRecord(orgID, advice.DrugId)
  65. if drup.ID > 0 {
  66. prescribingNumber := advice.PrescribingNumber
  67. DrugDeliverInfo(orgID, prescribingNumber, &out, &drup, advice)
  68. } else {
  69. return errors.New("药品信息不存在")
  70. }
  71. }
  72. return
  73. }
  74. // 药品出库 递归方式
  75. func DrugDeliverInfo(orgID int64, prescribingNumber float64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.DoctorAdvice) (err error) {
  76. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  77. var deliver_number int64 = 0
  78. var stock_number int64 = 0
  79. prescribingNumber_temp := strconv.FormatFloat(math.Abs(prescribingNumber), 'f', 0, 64)
  80. count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
  81. fmt.Println("单位1", advice.PrescribingNumber)
  82. fmt.Println("单位2", drup.MaxUnit)
  83. if advice.PrescribingNumberUnit == drup.MaxUnit {
  84. deliver_number = count * drup.MinNumber
  85. } else {
  86. deliver_number = count
  87. }
  88. // 根据先进先出原则,查询最先入库的批次,进行出库
  89. // 如果没有对应的库存,则报错
  90. //开启事物
  91. warehouse, err := FindLastDrugWarehousingInfoByID(advice.DrugId)
  92. if err != nil {
  93. return err
  94. }
  95. // 将该批次的剩余库存数量转换为拆零数量
  96. stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
  97. fmt.Println("stock_number999999999999", stock_number)
  98. fmt.Println("deliver_number88888888888", deliver_number)
  99. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  100. if stock_number >= deliver_number {
  101. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  102. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  103. WarehouseOutId: warehouseout.ID,
  104. Status: 1,
  105. Ctime: time.Now().Unix(),
  106. Remark: "",
  107. OrgId: orgID,
  108. Type: 1,
  109. Manufacturer: 0,
  110. Dealer: 0,
  111. IsSys: 1,
  112. SysRecordTime: advice.RecordDate,
  113. DrugId: advice.DrugId,
  114. }
  115. warehouseOutInfo.Count = deliver_number
  116. warehouseOutInfo.CountUnit = drup.MinUnit
  117. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  118. if errOne != nil {
  119. return errOne
  120. } else {
  121. details := &models.DrugAutomaticReduceDetail{
  122. WarehouseOutId: warehouseOutInfo.ID,
  123. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  124. PatientId: advice.PatientId,
  125. Ctime: time.Now().Unix(),
  126. Mtime: time.Now().Unix(),
  127. Status: 1,
  128. RecordTime: advice.RecordDate,
  129. OrgId: orgID,
  130. DrugId: advice.DrugId,
  131. Count: deliver_number,
  132. CountUnit: drup.MinUnit,
  133. }
  134. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  135. if errTwo != nil {
  136. return errTwo
  137. }
  138. }
  139. // 出库完成后,要减去对应批次的库存数量
  140. // 判断处方里药品单位是拆零单位还是包装单位, 如果是拆零单位,则根据规格,将拆零数量转为包装数量
  141. var maxNumber int64 = 0
  142. var minNumber int64 = 0
  143. if advice.PrescribingNumberUnit == drup.MinUnit {
  144. maxNumber = count / drup.MinNumber
  145. minNumber = count % drup.MinNumber
  146. } else {
  147. maxNumber = count
  148. }
  149. if warehouse.StockMaxNumber < maxNumber {
  150. return errors.New("库存数量不足")
  151. }
  152. warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
  153. warehouse.Mtime = time.Now().Unix()
  154. if warehouse.StockMinNumber < minNumber {
  155. warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
  156. warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
  157. } else {
  158. warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
  159. }
  160. if warehouse.StockMaxNumber < 0 {
  161. return errors.New("库存数量不足")
  162. }
  163. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  164. if errThree != nil {
  165. return errThree
  166. }
  167. return nil
  168. } else {
  169. // 当该批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  170. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  171. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  172. WarehouseOutId: warehouseout.ID,
  173. Status: 1,
  174. Ctime: time.Now().Unix(),
  175. Remark: "",
  176. OrgId: orgID,
  177. Type: 1,
  178. Manufacturer: 0,
  179. Dealer: 0,
  180. IsSys: 1,
  181. SysRecordTime: advice.RecordDate,
  182. DrugId: advice.DrugId,
  183. }
  184. warehouseOutInfo.Count = stock_number
  185. warehouseOutInfo.CountUnit = drup.MinUnit
  186. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  187. if errOne != nil {
  188. return errOne
  189. } else {
  190. details := &models.DrugAutomaticReduceDetail{
  191. WarehouseOutId: warehouseOutInfo.ID,
  192. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  193. PatientId: advice.PatientId,
  194. Ctime: time.Now().Unix(),
  195. Mtime: time.Now().Unix(),
  196. Status: 1,
  197. RecordTime: advice.RecordDate,
  198. OrgId: orgID,
  199. DrugId: advice.DrugId,
  200. Count: stock_number,
  201. CountUnit: drup.MinUnit,
  202. }
  203. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  204. if errTwo != nil {
  205. return errTwo
  206. }
  207. }
  208. // 出库完成后,要将该批次库存清零
  209. warehouse.StockMaxNumber = 0
  210. warehouse.StockMinNumber = 0
  211. warehouse.Mtime = time.Now().Unix()
  212. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  213. if errThree != nil {
  214. return errThree
  215. }
  216. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  217. prescribingNumber_two_temp := deliver_number - stock_number
  218. overPlusNumber := float64(prescribingNumber_two_temp)
  219. advice.PrescribingNumber = float64(prescribingNumber_two_temp)
  220. advice.PrescribingNumberUnit = drup.MinUnit
  221. DrugDeliverInfo(orgID, overPlusNumber, warehouseout, drup, advice)
  222. }
  223. return
  224. }
  225. // 药品出库
  226. func HisDrugsDelivery(orgID int64, advice *models.HisDoctorAdviceInfo) (err error) {
  227. // 1.判断药品是否来自专用字典的药品库
  228. // 2.判断当天当前机构有没有创建出库单,没有则创建
  229. // 3.创建出库流程
  230. // 3.1 实现先进先出逻辑 由于药品执行后,不可以修改和删除,所以不考虑出库后的退库和修改出库数量等
  231. isHasWay := false
  232. record_time := int64(0)
  233. isHasWay = true
  234. record_time = advice.RecordDate
  235. if isHasWay {
  236. //判断当天当前机构有没有创建出库单,没有则创建
  237. out, err := FindDrugStockOutByIsSys(orgID, 1, record_time)
  238. if err == gorm.ErrRecordNotFound {
  239. timeStr := time.Now().Format("2006-01-02")
  240. timeArr := strings.Split(timeStr, "-")
  241. total, _ := FindAllDrugWarehouseOut(orgID)
  242. total = total + 1
  243. warehousing_out_order := strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
  244. number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
  245. number = number + total
  246. warehousing_out_order = "YPCKD" + strconv.FormatInt(number, 10)
  247. // creater := adminUserInfo.AdminUser.Id
  248. warehouseOut := models.DrugWarehouseOut{
  249. WarehouseOutOrderNumber: warehousing_out_order,
  250. OperationTime: time.Now().Unix(),
  251. OrgId: orgID,
  252. Creater: 0,
  253. Ctime: time.Now().Unix(),
  254. Status: 1,
  255. WarehouseOutTime: record_time,
  256. Dealer: 0,
  257. Manufacturer: 0,
  258. Type: 1,
  259. IsSys: 1,
  260. }
  261. err := AddSigleDrugWarehouseOut(&warehouseOut)
  262. if err != nil {
  263. utils.TraceLog("创建出库单失败 err = %v", err)
  264. return err
  265. } else {
  266. out = warehouseOut
  267. }
  268. }
  269. // 出库流程
  270. // 1.查询改药品在药品库的规格信息,并将处方里的规格进行换算(尽量将拆零单位转换成包装单位)
  271. drup, _ := FindBaseDrugLibRecord(orgID, advice.DrugId)
  272. if drup.ID > 0 {
  273. prescribingNumber := advice.PrescribingNumber
  274. HisDrugDeliverInfo(orgID, prescribingNumber, &out, &drup, advice)
  275. } else {
  276. return errors.New("药品信息不存在")
  277. }
  278. }
  279. return
  280. }
  281. // 药品出库 递归方式
  282. func HisDrugDeliverInfo(orgID int64, prescribingNumber float64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.HisDoctorAdviceInfo) (err error) {
  283. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  284. var deliver_number int64 = 0
  285. var stock_number int64 = 0
  286. prescribingNumber_temp := strconv.FormatFloat(math.Abs(prescribingNumber), 'f', 0, 64)
  287. count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
  288. fmt.Println("单位99999999999999999999999999", advice.PrescribingNumberUnit)
  289. fmt.Println("drup777777777777766666666", drup.MaxUnit)
  290. if advice.PrescribingNumberUnit == drup.MaxUnit {
  291. deliver_number = count * drup.MinNumber
  292. } else {
  293. deliver_number = count
  294. }
  295. // 根据先进先出原则,查询最先入库的批次,进行出库
  296. // 如果没有对应的库存,则报错
  297. //开启事物
  298. warehouse, err := FindLastDrugWarehousingInfoByID(advice.DrugId)
  299. if err != nil {
  300. return err
  301. }
  302. // 将该批次的剩余库存数量转换为拆零数量
  303. stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
  304. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  305. if stock_number >= deliver_number {
  306. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  307. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  308. WarehouseOutId: warehouseout.ID,
  309. Status: 1,
  310. Ctime: time.Now().Unix(),
  311. Remark: "",
  312. OrgId: orgID,
  313. Type: 1,
  314. Manufacturer: 0,
  315. Dealer: 0,
  316. IsSys: 1,
  317. SysRecordTime: advice.RecordDate,
  318. DrugId: advice.DrugId,
  319. }
  320. warehouseOutInfo.Count = deliver_number
  321. warehouseOutInfo.CountUnit = drup.MinUnit
  322. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  323. if errOne != nil {
  324. return errOne
  325. } else {
  326. details := &models.DrugAutomaticReduceDetail{
  327. WarehouseOutId: warehouseOutInfo.ID,
  328. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  329. PatientId: advice.PatientId,
  330. Ctime: time.Now().Unix(),
  331. Mtime: time.Now().Unix(),
  332. Status: 1,
  333. RecordTime: advice.RecordDate,
  334. OrgId: orgID,
  335. DrugId: advice.DrugId,
  336. Count: deliver_number,
  337. CountUnit: drup.MinUnit,
  338. }
  339. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  340. if errTwo != nil {
  341. return errTwo
  342. }
  343. }
  344. // 出库完成后,要减去对应批次的库存数量
  345. // 判断处方里药品单位是拆零单位还是包装单位, 如果是拆零单位,则根据规格,将拆零数量转为包装数量
  346. var maxNumber int64 = 0
  347. var minNumber int64 = 0
  348. if advice.PrescribingNumberUnit == drup.MinUnit {
  349. maxNumber = count / drup.MinNumber
  350. minNumber = count % drup.MinNumber
  351. } else {
  352. maxNumber = count
  353. }
  354. if warehouse.StockMaxNumber < maxNumber {
  355. return errors.New("库存数量不足")
  356. }
  357. warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
  358. warehouse.Mtime = time.Now().Unix()
  359. if warehouse.StockMinNumber < minNumber {
  360. warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
  361. warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
  362. } else {
  363. warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
  364. }
  365. if warehouse.StockMaxNumber < 0 {
  366. return errors.New("库存数量不足")
  367. }
  368. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  369. if errThree != nil {
  370. return errThree
  371. }
  372. return nil
  373. } else {
  374. // 当该批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  375. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  376. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  377. WarehouseOutId: warehouseout.ID,
  378. Status: 1,
  379. Ctime: time.Now().Unix(),
  380. Remark: "",
  381. OrgId: orgID,
  382. Type: 1,
  383. Manufacturer: 0,
  384. Dealer: 0,
  385. IsSys: 1,
  386. SysRecordTime: advice.RecordDate,
  387. DrugId: advice.DrugId,
  388. }
  389. warehouseOutInfo.Count = stock_number
  390. warehouseOutInfo.CountUnit = drup.MinUnit
  391. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  392. if errOne != nil {
  393. return errOne
  394. } else {
  395. details := &models.DrugAutomaticReduceDetail{
  396. WarehouseOutId: warehouseOutInfo.ID,
  397. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  398. PatientId: advice.PatientId,
  399. Ctime: time.Now().Unix(),
  400. Mtime: time.Now().Unix(),
  401. Status: 1,
  402. RecordTime: advice.RecordDate,
  403. OrgId: orgID,
  404. DrugId: advice.DrugId,
  405. Count: stock_number,
  406. CountUnit: drup.MinUnit,
  407. }
  408. errTwo := AddSigleDrugAutoReduceRecordInfo(details)
  409. if errTwo != nil {
  410. return errTwo
  411. }
  412. }
  413. // 出库完成后,要将该批次库存清零
  414. warehouse.StockMaxNumber = 0
  415. warehouse.StockMinNumber = 0
  416. warehouse.Mtime = time.Now().Unix()
  417. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  418. if errThree != nil {
  419. return errThree
  420. }
  421. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  422. prescribingNumber_two_temp := deliver_number - stock_number
  423. overPlusNumber := float64(prescribingNumber_two_temp)
  424. advice.PrescribingNumber = float64(prescribingNumber_two_temp)
  425. advice.PrescribingNumberUnit = drup.MinUnit
  426. HisDrugDeliverInfo(orgID, overPlusNumber, warehouseout, drup, advice)
  427. }
  428. return
  429. }
  430. // 药品出库 递归方式
  431. func AutoDrugDeliverInfo(orgID int64, prescribingNumber int64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.DrugWarehouseOutInfo) (err error) {
  432. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  433. var deliver_number int64 = 0
  434. var stock_number int64 = 0
  435. fmt.Println("单位1", advice.CountUnit)
  436. fmt.Println("单位2", drup.MaxUnit)
  437. if advice.CountUnit == drup.MaxUnit {
  438. deliver_number = prescribingNumber * drup.MinNumber
  439. } else {
  440. deliver_number = prescribingNumber
  441. }
  442. // 根据先进先出原则,查询最先入库的批次,进行出库
  443. // 如果没有对应的库存,则报错
  444. //开启事物
  445. warehouse, err := FindLastDrugWarehousingInfoByID(advice.DrugId)
  446. if err != nil {
  447. return err
  448. }
  449. // 将该批次的剩余库存数量转换为拆零数量
  450. stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
  451. fmt.Println("88i8uu7777777777777777777777777777", stock_number)
  452. fmt.Println("77777544656666666666666666", deliver_number)
  453. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  454. if stock_number >= deliver_number {
  455. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  456. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  457. WarehouseOutId: warehouseout.ID,
  458. Status: 1,
  459. Ctime: time.Now().Unix(),
  460. Remark: "",
  461. OrgId: orgID,
  462. Type: 1,
  463. Manufacturer: 0,
  464. Dealer: 0,
  465. IsSys: 0,
  466. SysRecordTime: advice.Ctime,
  467. DrugId: advice.DrugId,
  468. }
  469. warehouseOutInfo.Count = deliver_number
  470. warehouseOutInfo.CountUnit = advice.CountUnit
  471. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  472. if errOne != nil {
  473. return errOne
  474. }
  475. // 出库完成后,要减去对应批次的库存数量
  476. // 判断处方里药品单位是拆零单位还是包装单位, 如果是拆零单位,则根据规格,将拆零数量转为包装数量
  477. var maxNumber int64 = 0
  478. var minNumber int64 = 0
  479. if advice.CountUnit == drup.MinUnit {
  480. maxNumber = prescribingNumber / drup.MinNumber
  481. minNumber = prescribingNumber % drup.MinNumber
  482. } else {
  483. maxNumber = prescribingNumber
  484. }
  485. if warehouse.StockMaxNumber < maxNumber {
  486. return errors.New("库存数量不足")
  487. }
  488. warehouse.StockMaxNumber = warehouse.StockMaxNumber - maxNumber
  489. warehouse.Mtime = time.Now().Unix()
  490. if warehouse.StockMinNumber < minNumber {
  491. warehouse.StockMaxNumber = warehouse.StockMaxNumber - 1
  492. warehouse.StockMinNumber = warehouse.StockMinNumber + drup.MinNumber - minNumber
  493. } else {
  494. warehouse.StockMinNumber = warehouse.StockMinNumber - minNumber
  495. }
  496. if warehouse.StockMaxNumber < 0 {
  497. return errors.New("库存数量不足")
  498. }
  499. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  500. if errThree != nil {
  501. return errThree
  502. }
  503. return nil
  504. } else {
  505. // 当该批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  506. warehouseOutInfo := &models.DrugWarehouseOutInfo{
  507. WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
  508. WarehouseOutId: warehouseout.ID,
  509. Status: 1,
  510. Ctime: time.Now().Unix(),
  511. Remark: "",
  512. OrgId: orgID,
  513. Type: 1,
  514. Manufacturer: 0,
  515. Dealer: 0,
  516. IsSys: 0,
  517. SysRecordTime: advice.Ctime,
  518. DrugId: advice.DrugId,
  519. }
  520. warehouseOutInfo.Count = stock_number
  521. warehouseOutInfo.CountUnit = advice.CountUnit
  522. errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
  523. if errOne != nil {
  524. return errOne
  525. }
  526. // 出库完成后,要将该批次库存清零
  527. warehouse.StockMaxNumber = 0
  528. warehouse.StockMinNumber = 0
  529. warehouse.Mtime = time.Now().Unix()
  530. errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
  531. if errThree != nil {
  532. return errThree
  533. }
  534. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  535. prescribingNumber_two_temp := deliver_number - stock_number
  536. advice.CountUnit = drup.MinUnit
  537. AutoDrugDeliverInfo(orgID, prescribingNumber_two_temp, warehouseout, drup, advice)
  538. }
  539. return
  540. }
  541. // 耗材出库
  542. func ConsumablesDeliveryTotal(orgID int64, patient_id int64, record_time int64, goods []*models.DialysisBeforePrepareGoods, goodOne []*models.NewDialysisBeforePrepareGoods) (err error) {
  543. //查询该患者当天已经出库的耗材信息
  544. goods_yc, _ := FindConsumablesByDateTwo(orgID, patient_id, record_time)
  545. for _, item := range goods_yc {
  546. fmt.Println("item0000000000000", item.Count)
  547. }
  548. for _, item := range goods {
  549. fmt.Println("item1111111111111", item.Count)
  550. }
  551. // 和新请求的出库数据进行对比,分出那些是继续出库的,那些是需要删除出库的
  552. for i := len(goods_yc) - 1; i >= 0; i-- {
  553. goods_yc_temp := goods_yc[i]
  554. for j := len(goods) - 1; j >= 0; j-- {
  555. goods_temp := goods[j]
  556. // 已经出库和新请求出库都存在该耗材,则判断出库数量,分成是继续出库,还是删除出库
  557. if goods_yc_temp.GoodTypeId == goods_temp.GoodTypeId && goods_yc_temp.GoodId == goods_temp.GoodId {
  558. // 已经出库和新请求出库的出库数量一致,则清除两个结构体里的数据(既不出库,也不删除出库)
  559. if goods_yc_temp.Count == goods_temp.Count {
  560. goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  561. goods = append(goods[:j], goods[j+1:]...)
  562. }
  563. fmt.Println("998888888888888", goods_yc_temp.Count)
  564. fmt.Println("7777777777777777", goods_temp.Count)
  565. // 如果已经出库的数量 大于 新请求出库的数量,则代表需要删除出库
  566. if goods_yc_temp.Count > goods_temp.Count {
  567. fmt.Println("进来了是吗")
  568. temp_count := goods_yc_temp.Count - goods_temp.Count
  569. goods_yc[i].Count = temp_count
  570. goods = append(goods[:j], goods[j+1:]...)
  571. break
  572. }
  573. fmt.Println("555555555555", goods_yc_temp.Count)
  574. fmt.Println("444444444444", goods_temp.Count)
  575. // 如果已经出库的数量 小于 新请求出库的梳理,则代表需要增加出库
  576. if goods_yc_temp.Count < goods_temp.Count {
  577. temp_count := goods_temp.Count - goods_yc_temp.Count
  578. fmt.Println("988888888888888", temp_count)
  579. goods[j].Count = temp_count
  580. goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  581. fmt.Println("888888888", goods_yc)
  582. }
  583. }
  584. }
  585. }
  586. // goods_yc 这个数据就是需要已经出库了,但是现在需要删除出库的耗材数据
  587. // goods 这个数据就是需要出库的耗材的数据
  588. fmt.Println("goods222222222222", goods)
  589. fmt.Println("goodsy999999999999", goods_yc)
  590. if len(goods) > 0 {
  591. out, err := FindStockOutByIsSys(orgID, 1, record_time)
  592. if err == gorm.ErrRecordNotFound {
  593. //没有记录,则创建出库单
  594. timeStr := time.Now().Format("2006-01-02")
  595. timeArr := strings.Split(timeStr, "-")
  596. total, _ := FindAllWarehouseOut(orgID)
  597. total = total + 1
  598. warehousing_out_order := strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
  599. number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
  600. number = number + total
  601. warehousing_out_order = "CKD" + strconv.FormatInt(number, 10)
  602. warehouseOut := models.WarehouseOut{
  603. WarehouseOutOrderNumber: warehousing_out_order,
  604. OperationTime: time.Now().Unix(),
  605. OrgId: orgID,
  606. Creater: 0,
  607. Ctime: time.Now().Unix(),
  608. Status: 1,
  609. WarehouseOutTime: record_time,
  610. Dealer: 0,
  611. Manufacturer: 0,
  612. Type: 1,
  613. IsSys: 1,
  614. }
  615. err := AddSigleWarehouseOut(&warehouseOut)
  616. if err != nil {
  617. utils.TraceLog("创建出库单失败 err = %v", err)
  618. return err
  619. } else {
  620. out = warehouseOut
  621. }
  622. }
  623. for _, item := range goods {
  624. for _, it := range goodOne {
  625. if item.GoodTypeId == it.GoodTypeId && it.GoodId == it.GoodId {
  626. it.NewCount = item.Count
  627. }
  628. }
  629. }
  630. for _, item := range goodOne {
  631. prepare := models.DialysisBeforePrepare{
  632. GoodTypeId: item.GoodTypeId,
  633. GoodId: item.GoodId,
  634. Count: item.Count,
  635. NewCount: item.NewCount,
  636. }
  637. fmt.Println("数量99999999999999999", item.Count)
  638. ConsumablesDelivery(orgID, patient_id, record_time, &prepare, &out, item.Count)
  639. }
  640. }
  641. if len(goods_yc) > 0 {
  642. for _, good_yc := range goods_yc {
  643. out, _ := FindStockOutByIsSys(orgID, 1, record_time)
  644. ConsumablesDeliveryDelete(orgID, patient_id, record_time, good_yc, &out)
  645. }
  646. }
  647. return nil
  648. }
  649. //耗材出库
  650. func ConsumablesDelivery(orgID int64, patient_id int64, record_time int64, goods *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut, count int64) (err error) {
  651. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  652. var deliver_number int64 = 0
  653. var stock_number int64 = 0
  654. var maxNumber int64 = 0
  655. deliver_number = goods.Count
  656. fmt.Println("添加数量", deliver_number)
  657. // 根据先进先出原则,查询最先入库的批次,进行出库
  658. // 如果没有对应的库存,则报错
  659. warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId)
  660. fmt.Println("库存数量", warehouse.StockCount)
  661. if err != nil {
  662. return
  663. }
  664. // 将该批次的剩余库存数量转换为拆零数量
  665. stock_number = warehouse.StockCount
  666. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  667. if stock_number >= deliver_number {
  668. warehouseOutInfo := &models.WarehouseOutInfo{
  669. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  670. WarehouseOutId: warehouseOut.ID,
  671. WarehouseInfotId: warehouse.ID,
  672. Status: 1,
  673. Ctime: time.Now().Unix(),
  674. Remark: "",
  675. OrgId: orgID,
  676. Type: 1,
  677. Manufacturer: 0,
  678. Dealer: 0,
  679. IsSys: 1,
  680. SysRecordTime: record_time,
  681. GoodTypeId: goods.GoodTypeId,
  682. GoodId: goods.GoodId,
  683. PatientId: patient_id,
  684. }
  685. warehouseOutInfo.Count = goods.Count
  686. stockInInfo, _ := FindLastStockInInfoRecord(goods.GoodId, orgID)
  687. warehouseOutInfo.Price = stockInInfo.Price
  688. //判断当前耗材是否有出库详情记录
  689. _, errcode := GetStockInRecoredByGoodId(goods.GoodId, goods.GoodTypeId, record_time, patient_id, orgID)
  690. if errcode == gorm.ErrRecordNotFound {
  691. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  692. if errOne != nil {
  693. return errOne
  694. } else {
  695. details := models.BloodAutomaticReduceDetail{
  696. WarehouseOutId: warehouseOutInfo.ID,
  697. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  698. PatientId: patient_id,
  699. Ctime: time.Now().Unix(),
  700. Mtime: time.Now().Unix(),
  701. Status: 1,
  702. RecordTime: record_time,
  703. OrgId: orgID,
  704. GoodId: goods.GoodId,
  705. GoodTypeId: goods.GoodTypeId,
  706. Count: count,
  707. }
  708. //查询当天耗材是否已经存在数据
  709. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  710. if errcode == gorm.ErrRecordNotFound {
  711. errTwo := CreateAutoReduceRecord(&details)
  712. if errTwo != nil {
  713. return errTwo
  714. }
  715. } else if errcode == nil {
  716. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  717. CreateAutoReduceRecord(&details)
  718. }
  719. }
  720. } else if errcode == nil {
  721. warehouseOutInfo := &models.WarehouseOutInfo{
  722. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  723. WarehouseOutId: warehouseOut.ID,
  724. WarehouseInfotId: warehouse.ID,
  725. Status: 1,
  726. Ctime: time.Now().Unix(),
  727. Remark: "",
  728. OrgId: orgID,
  729. Type: 1,
  730. Manufacturer: 0,
  731. Dealer: 0,
  732. IsSys: 1,
  733. SysRecordTime: record_time,
  734. GoodTypeId: goods.GoodTypeId,
  735. GoodId: goods.GoodId,
  736. PatientId: patient_id,
  737. }
  738. warehouseOutInfo.Count = goods.Count
  739. //更新入库详情表
  740. UpdateAutoMaticReduceDetail(goods.GoodId, goods.GoodTypeId, record_time, patient_id, orgID, warehouseOutInfo)
  741. details := models.BloodAutomaticReduceDetail{
  742. WarehouseOutId: warehouseOutInfo.ID,
  743. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  744. PatientId: patient_id,
  745. Ctime: time.Now().Unix(),
  746. Mtime: time.Now().Unix(),
  747. Status: 1,
  748. RecordTime: record_time,
  749. OrgId: orgID,
  750. GoodId: goods.GoodId,
  751. GoodTypeId: goods.GoodTypeId,
  752. Count: count,
  753. }
  754. //查询当天耗材是否已经存在数据
  755. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  756. if errcode == gorm.ErrRecordNotFound {
  757. errTwo := CreateAutoReduceRecord(&details)
  758. if errTwo != nil {
  759. return errTwo
  760. }
  761. } else if errcode == nil {
  762. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  763. CreateAutoReduceRecord(&details)
  764. }
  765. }
  766. fmt.Println("newcount9999999999999999999999999999999", goods.NewCount)
  767. if goods.NewCount == 0 {
  768. maxNumber = count
  769. } else {
  770. maxNumber = goods.NewCount
  771. }
  772. if warehouse.StockCount < maxNumber {
  773. return errors.New("库存数量不足")
  774. }
  775. warehouse.StockCount = warehouse.StockCount - maxNumber
  776. fmt.Println("999999999999999", warehouse.StockCount)
  777. warehouse.Mtime = time.Now().Unix()
  778. if warehouse.StockCount < 0 {
  779. return errors.New("库存数量不足")
  780. }
  781. errThree := UpDateWarehouseInfoByStock(&warehouse)
  782. if errThree != nil {
  783. return errThree
  784. }
  785. return nil
  786. } else {
  787. // 当改批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  788. warehouseOutInfo := &models.WarehouseOutInfo{
  789. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  790. WarehouseOutId: warehouseOut.ID,
  791. WarehouseInfotId: warehouse.ID,
  792. Status: 1,
  793. Ctime: time.Now().Unix(),
  794. Remark: "",
  795. OrgId: orgID,
  796. Type: 1,
  797. Manufacturer: 0,
  798. Dealer: 0,
  799. IsSys: 1,
  800. SysRecordTime: record_time,
  801. GoodTypeId: goods.GoodTypeId,
  802. GoodId: goods.GoodId,
  803. PatientId: patient_id,
  804. }
  805. warehouseOutInfo.Count = stock_number
  806. stockInInfo, _ := service.FindLastStockInInfoRecord(goods.GoodId, orgID)
  807. warehouseOutInfo.Price = stockInInfo.Price
  808. _, errcode := GetStockInRecoredByGoodId(goods.GoodId, goods.GoodTypeId, record_time, patient_id, orgID)
  809. if errcode == gorm.ErrRecordNotFound {
  810. errOne := service.AddSigleWarehouseOutInfo(warehouseOutInfo)
  811. if errOne != nil {
  812. return errOne
  813. } else {
  814. details := &models.AutomaticReduceDetail{
  815. WarehouseOutId: warehouseOutInfo.ID,
  816. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  817. PatientId: patient_id,
  818. Ctime: time.Now().Unix(),
  819. Mtime: time.Now().Unix(),
  820. Status: 1,
  821. RecordTime: record_time,
  822. OrgId: orgID,
  823. GoodId: goods.GoodId,
  824. GoodTypeId: goods.GoodTypeId,
  825. Count: goods.Count,
  826. }
  827. errTwo := service.AddSigleAutoReduceRecordInfo(details)
  828. if errTwo != nil {
  829. return errTwo
  830. }
  831. }
  832. // 出库完成后,要将该批次库存清零
  833. warehouse.StockCount = 0
  834. warehouse.Mtime = time.Now().Unix()
  835. errThree := UpDateWarehouseInfoByStock(&warehouse)
  836. if errThree != nil {
  837. return errThree
  838. }
  839. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  840. goods.Count = deliver_number - stock_number
  841. ConsumablesDelivery(orgID, patient_id, record_time, goods, warehouseOut, count)
  842. } else if errcode == nil {
  843. warehouseOutInfo := &models.WarehouseOutInfo{
  844. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  845. WarehouseOutId: warehouseOut.ID,
  846. WarehouseInfotId: warehouse.ID,
  847. Status: 1,
  848. Ctime: time.Now().Unix(),
  849. Remark: "",
  850. OrgId: orgID,
  851. Type: 1,
  852. Manufacturer: 0,
  853. Dealer: 0,
  854. IsSys: 1,
  855. SysRecordTime: record_time,
  856. GoodTypeId: goods.GoodTypeId,
  857. GoodId: goods.GoodId,
  858. PatientId: patient_id,
  859. }
  860. warehouseOutInfo.Count = goods.Count
  861. //更新入库详情表
  862. UpdateAutoMaticReduceDetail(goods.GoodId, goods.GoodTypeId, record_time, patient_id, orgID, warehouseOutInfo)
  863. details := models.BloodAutomaticReduceDetail{
  864. WarehouseOutId: warehouseOutInfo.ID,
  865. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  866. PatientId: patient_id,
  867. Ctime: time.Now().Unix(),
  868. Mtime: time.Now().Unix(),
  869. Status: 1,
  870. RecordTime: record_time,
  871. OrgId: orgID,
  872. GoodId: goods.GoodId,
  873. GoodTypeId: goods.GoodTypeId,
  874. Count: count,
  875. }
  876. //查询当天耗材是否已经存在数据
  877. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  878. if errcode == gorm.ErrRecordNotFound {
  879. errTwo := CreateAutoReduceRecord(&details)
  880. if errTwo != nil {
  881. return errTwo
  882. }
  883. } else if errcode == nil {
  884. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  885. CreateAutoReduceRecord(&details)
  886. }
  887. }
  888. }
  889. return nil
  890. }
  891. //耗材出库删除
  892. func ConsumablesDeliveryDelete(orgID int64, patient_id int64, record_time int64, good_yc *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut) (err error) {
  893. // 先根据相关信息查询当天该耗材的出库信息
  894. warehouseOutInfos, err := FindStockOutInfoByStock(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time, patient_id)
  895. if err != nil {
  896. return err
  897. }
  898. var delete_count int64 = 0
  899. for _, ware := range warehouseOutInfos {
  900. // 判断当前出库的数据和删除出库数量
  901. if good_yc.Count <= ware.Count {
  902. delete_count = good_yc.Count
  903. } else {
  904. delete_count = ware.Count
  905. }
  906. // 在出库记录表里记录退库详情
  907. warehouseOutInfo := &models.WarehouseOutInfo{
  908. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  909. WarehouseOutId: warehouseOut.ID,
  910. //WarehouseInfoId: warehouse.ID,
  911. Status: 1,
  912. Ctime: time.Now().Unix(),
  913. Remark: "",
  914. OrgId: orgID,
  915. Type: 1,
  916. Manufacturer: 0,
  917. Dealer: 0,
  918. IsSys: 2,
  919. SysRecordTime: record_time,
  920. GoodTypeId: good_yc.GoodTypeId,
  921. GoodId: good_yc.GoodId,
  922. PatientId: patient_id,
  923. }
  924. warehouseOutInfo.Count = delete_count
  925. stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  926. warehouseOutInfo.Price = stockInInfo.Price
  927. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  928. if errOne != nil {
  929. return errOne
  930. } else {
  931. details := &models.AutomaticReduceDetail{
  932. WarehouseOutId: warehouseOutInfo.ID,
  933. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  934. PatientId: patient_id,
  935. Ctime: time.Now().Unix(),
  936. Mtime: time.Now().Unix(),
  937. Status: 1,
  938. RecordTime: record_time,
  939. OrgId: orgID,
  940. GoodId: good_yc.GoodId,
  941. GoodTypeId: good_yc.GoodTypeId,
  942. Count: delete_count,
  943. Type: 2,
  944. }
  945. //查询是否当天已经存在数据
  946. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  947. if errcode == gorm.ErrRecordNotFound {
  948. errTwo := AddSigleAutoReduceRecordInfo(details)
  949. if errTwo != nil {
  950. return errTwo
  951. }
  952. } else if errcode == nil {
  953. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  954. AddSigleAutoReduceRecordInfo(details)
  955. }
  956. }
  957. // 删除出库完成后,要增加对应批次的库存数量
  958. errThree := UpDateWarehouseInfoByStockDelete(ware.WarehouseInfotId, delete_count)
  959. if errThree != nil {
  960. return errThree
  961. }
  962. // 增加了对应的库存后,看看还有多少需要退库的
  963. good_yc.Count = good_yc.Count - delete_count
  964. if good_yc.Count == 0 {
  965. return nil
  966. }
  967. }
  968. if good_yc.Count == 0 {
  969. return nil
  970. } else {
  971. return errors.New("退库和出库数据不匹配")
  972. }
  973. }
  974. func GetAutoReduceRecordInfoByPatientId(orgid int64, patient_id int64, recordTime int64) (autoReduce []*models.AutomaticReduceDetail, err error) {
  975. err = XTReadDB().Model(&autoReduce).Where("org_id = ? and patient_id = ? and record_time = ? and status = 1 and count<>0", orgid, patient_id, recordTime).Find(&autoReduce).Error
  976. return autoReduce, err
  977. }
  978. func DeleteDialysisBefor(orgid int64, patient_id int64, record_date int64, goodid int64, goodtypeid int64) error {
  979. prepare := models.DialysisBeforePrepare{}
  980. err := XTWriteDB().Model(&prepare).Where("user_org_id = ? and patient_id = ? and record_date = ? and status = 1 and good_id = ? and good_type_id = ?", orgid, patient_id, record_date, goodid, goodtypeid).Updates(map[string]interface{}{"status": 0, "count": 0, "mtime": time.Now().Unix()}).Error
  981. return err
  982. }
  983. func ConsumablesDeliveryTotalOne(orgID int64, patient_id int64, record_time int64, goods []*models.DialysisBeforePrepareGoods, goodOne []*models.NewDialysisBeforePrepareGoods) (err error) {
  984. //查询该患者当天已经出库的耗材信息
  985. goods_yc, _ := FindConsumablesByDateTwo(orgID, patient_id, record_time)
  986. for _, item := range goods_yc {
  987. fmt.Println("item0000000000000", item.Count)
  988. }
  989. for _, item := range goods {
  990. fmt.Println("item1111111111111", item.Count)
  991. }
  992. // 和新请求的出库数据进行对比,分出那些是继续出库的,那些是需要删除出库的
  993. for i := len(goods_yc) - 1; i >= 0; i-- {
  994. goods_yc_temp := goods_yc[i]
  995. for j := len(goods) - 1; j >= 0; j-- {
  996. goods_temp := goods[j]
  997. // 已经出库和新请求出库都存在该耗材,则判断出库数量,分成是继续出库,还是删除出库
  998. if goods_yc_temp.GoodTypeId == goods_temp.GoodTypeId && goods_yc_temp.GoodId == goods_temp.GoodId {
  999. // 已经出库和新请求出库的出库数量一致,则清除两个结构体里的数据(既不出库,也不删除出库)
  1000. if goods_yc_temp.Count == goods_temp.Count {
  1001. goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  1002. goods = append(goods[:j], goods[j+1:]...)
  1003. }
  1004. fmt.Println("998888888888888", goods_yc_temp.Count)
  1005. fmt.Println("7777777777777777", goods_temp.Count)
  1006. // 如果已经出库的数量 大于 新请求出库的数量,则代表需要删除出库
  1007. if goods_yc_temp.Count > goods_temp.Count {
  1008. fmt.Println("进来了是吗")
  1009. temp_count := goods_yc_temp.Count - goods_temp.Count
  1010. goods_yc[i].Count = temp_count
  1011. goods = append(goods[:j], goods[j+1:]...)
  1012. break
  1013. }
  1014. fmt.Println("555555555555", goods_yc_temp.Count)
  1015. fmt.Println("444444444444", goods_temp.Count)
  1016. // 如果已经出库的数量 小于 新请求出库的梳理,则代表需要增加出库
  1017. if goods_yc_temp.Count < goods_temp.Count {
  1018. temp_count := goods_temp.Count - goods_yc_temp.Count
  1019. fmt.Println("988888888888888", temp_count)
  1020. goods[j].Count = temp_count
  1021. goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  1022. fmt.Println("888888888", goods_yc)
  1023. }
  1024. }
  1025. }
  1026. }
  1027. // goods_yc 这个数据就是需要已经出库了,但是现在需要删除出库的耗材数据
  1028. // goods 这个数据就是需要出库的耗材的数据
  1029. fmt.Println("goods222222222222", goods)
  1030. fmt.Println("goodsy999999999999", goods_yc)
  1031. if len(goods) > 0 {
  1032. out, err := FindStockOutByIsSys(orgID, 1, record_time)
  1033. if err == gorm.ErrRecordNotFound {
  1034. //没有记录,则创建出库单
  1035. timeStr := time.Now().Format("2006-01-02")
  1036. timeArr := strings.Split(timeStr, "-")
  1037. total, _ := FindAllWarehouseOut(orgID)
  1038. total = total + 1
  1039. warehousing_out_order := strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
  1040. number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
  1041. number = number + total
  1042. warehousing_out_order = "CKD" + strconv.FormatInt(number, 10)
  1043. warehouseOut := models.WarehouseOut{
  1044. WarehouseOutOrderNumber: warehousing_out_order,
  1045. OperationTime: time.Now().Unix(),
  1046. OrgId: orgID,
  1047. Creater: 0,
  1048. Ctime: time.Now().Unix(),
  1049. Status: 1,
  1050. WarehouseOutTime: record_time,
  1051. Dealer: 0,
  1052. Manufacturer: 0,
  1053. Type: 1,
  1054. IsSys: 1,
  1055. }
  1056. err := AddSigleWarehouseOut(&warehouseOut)
  1057. if err != nil {
  1058. utils.TraceLog("创建出库单失败 err = %v", err)
  1059. return err
  1060. } else {
  1061. out = warehouseOut
  1062. }
  1063. }
  1064. for _, item := range goods {
  1065. for _, it := range goodOne {
  1066. if item.GoodTypeId == it.GoodTypeId && it.GoodId == it.GoodId {
  1067. it.NewCount = item.Count
  1068. }
  1069. }
  1070. }
  1071. for _, item := range goodOne {
  1072. //prepare := models.DialysisBeforePrepare{
  1073. // GoodTypeId: item.GoodTypeId,
  1074. // GoodId: item.GoodId,
  1075. // Count: item.Count,
  1076. // NewCount: item.NewCount,
  1077. //}
  1078. info := models.WarehouseOutInfo{
  1079. GoodTypeId: item.GoodTypeId,
  1080. GoodId: item.GoodId,
  1081. Count: item.Count,
  1082. }
  1083. ConsumablesDeliveryOne(orgID, record_time, &info, &out, item.Count)
  1084. }
  1085. }
  1086. if len(goods_yc) > 0 {
  1087. for _, good_yc := range goods_yc {
  1088. out, _ := FindStockOutByIsSys(orgID, 1, record_time)
  1089. ConsumablesDeliveryDeleteOne(orgID, record_time, good_yc, &out)
  1090. }
  1091. }
  1092. return nil
  1093. }
  1094. //耗材出库
  1095. func ConsumablesDeliveryOne(orgID int64, record_time int64, goods *models.WarehouseOutInfo, warehouseOut *models.WarehouseOut, count int64) (err error) {
  1096. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  1097. var deliver_number int64 = 0
  1098. var stock_number int64 = 0
  1099. var maxNumber int64 = 0
  1100. deliver_number = goods.Count
  1101. fmt.Println("添加数量", deliver_number)
  1102. // 根据先进先出原则,查询最先入库的批次,进行出库
  1103. // 如果没有对应的库存,则报错
  1104. warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId)
  1105. if err != nil {
  1106. return err
  1107. }
  1108. // 将该批次的剩余库存数量转换为拆零数量
  1109. stock_number = warehouse.StockCount
  1110. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  1111. if stock_number >= deliver_number {
  1112. warehouseOutInfo := &models.WarehouseOutInfo{
  1113. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1114. WarehouseOutId: warehouseOut.ID,
  1115. WarehouseInfotId: warehouse.ID,
  1116. Status: 1,
  1117. Ctime: time.Now().Unix(),
  1118. Remark: "",
  1119. OrgId: orgID,
  1120. Type: 1,
  1121. Manufacturer: 0,
  1122. Dealer: 0,
  1123. IsSys: 2,
  1124. SysRecordTime: record_time,
  1125. GoodTypeId: goods.GoodTypeId,
  1126. GoodId: goods.GoodId,
  1127. }
  1128. warehouseOutInfo.Count = goods.Count
  1129. stockInInfo, _ := FindLastStockInInfoRecord(goods.GoodId, orgID)
  1130. warehouseOutInfo.Price = stockInInfo.Price
  1131. //判断当前耗材是否有出库详情记录
  1132. _, errcode := GetStockInRecoredByGoodIdOne(goods.GoodId, goods.GoodTypeId, record_time, orgID)
  1133. if errcode == gorm.ErrRecordNotFound {
  1134. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1135. if errOne != nil {
  1136. return errOne
  1137. }
  1138. } else if errcode == nil {
  1139. warehouseOutInfo := &models.WarehouseOutInfo{
  1140. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1141. WarehouseOutId: warehouseOut.ID,
  1142. WarehouseInfotId: warehouse.ID,
  1143. Status: 1,
  1144. Ctime: time.Now().Unix(),
  1145. Remark: "",
  1146. OrgId: orgID,
  1147. Type: 1,
  1148. Manufacturer: 0,
  1149. Dealer: 0,
  1150. IsSys: 2,
  1151. SysRecordTime: record_time,
  1152. GoodTypeId: goods.GoodTypeId,
  1153. GoodId: goods.GoodId,
  1154. }
  1155. warehouseOutInfo.Count = goods.Count
  1156. }
  1157. maxNumber = goods.Count
  1158. if warehouse.StockCount < maxNumber {
  1159. return errors.New("库存数量不足")
  1160. }
  1161. warehouse.StockCount = warehouse.StockCount - maxNumber
  1162. warehouse.Mtime = time.Now().Unix()
  1163. if warehouse.StockCount < 0 {
  1164. return errors.New("库存数量不足")
  1165. }
  1166. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1167. if errThree != nil {
  1168. return errThree
  1169. }
  1170. return nil
  1171. } else {
  1172. // 当改批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  1173. warehouseOutInfo := &models.WarehouseOutInfo{
  1174. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1175. WarehouseOutId: warehouseOut.ID,
  1176. WarehouseInfotId: warehouse.ID,
  1177. Status: 1,
  1178. Ctime: time.Now().Unix(),
  1179. Remark: "",
  1180. OrgId: orgID,
  1181. Type: 1,
  1182. Manufacturer: 0,
  1183. Dealer: 0,
  1184. IsSys: 1,
  1185. SysRecordTime: record_time,
  1186. GoodTypeId: goods.GoodTypeId,
  1187. GoodId: goods.GoodId,
  1188. }
  1189. warehouseOutInfo.Count = stock_number
  1190. stockInInfo, _ := service.FindLastStockInInfoRecord(goods.GoodId, orgID)
  1191. warehouseOutInfo.Price = stockInInfo.Price
  1192. _, errcode := GetStockInRecoredByGoodIdOne(goods.GoodId, goods.GoodTypeId, record_time, orgID)
  1193. if errcode == gorm.ErrRecordNotFound {
  1194. errOne := service.AddSigleWarehouseOutInfo(warehouseOutInfo)
  1195. if errOne != nil {
  1196. return errOne
  1197. }
  1198. // 出库完成后,要将该批次库存清零
  1199. warehouse.StockCount = 0
  1200. warehouse.Mtime = time.Now().Unix()
  1201. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1202. if errThree != nil {
  1203. return errThree
  1204. }
  1205. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1206. goods.Count = deliver_number - stock_number
  1207. ConsumablesDeliveryOne(orgID, record_time, goods, warehouseOut, count)
  1208. } else if errcode == nil {
  1209. warehouseOutInfo := &models.WarehouseOutInfo{
  1210. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1211. WarehouseOutId: warehouseOut.ID,
  1212. WarehouseInfotId: warehouse.ID,
  1213. Status: 1,
  1214. Ctime: time.Now().Unix(),
  1215. Remark: "",
  1216. OrgId: orgID,
  1217. Type: 1,
  1218. Manufacturer: 0,
  1219. Dealer: 0,
  1220. IsSys: 1,
  1221. SysRecordTime: record_time,
  1222. GoodTypeId: goods.GoodTypeId,
  1223. GoodId: goods.GoodId,
  1224. }
  1225. warehouseOutInfo.Count = goods.Count
  1226. //更新入库详情表
  1227. UpdateAutoMaticReduceDetailOne(goods.GoodId, goods.GoodTypeId, record_time, orgID, warehouseOutInfo)
  1228. }
  1229. }
  1230. return nil
  1231. }
  1232. //耗材出库删除
  1233. func ConsumablesDeliveryDeleteOne(orgID int64, record_time int64, good_yc *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut) (err error) {
  1234. // 先根据相关信息查询当天该耗材的出库信息
  1235. warehouseOutInfos, err := FindStockOutInfoByStockOne(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time)
  1236. if err != nil {
  1237. return err
  1238. }
  1239. var delete_count int64 = 0
  1240. for _, ware := range warehouseOutInfos {
  1241. // 判断当前出库的数据和删除出库数量
  1242. if good_yc.Count <= ware.Count {
  1243. delete_count = good_yc.Count
  1244. } else {
  1245. delete_count = ware.Count
  1246. }
  1247. // 在出库记录表里记录退库详情
  1248. warehouseOutInfo := &models.WarehouseOutInfo{
  1249. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1250. WarehouseOutId: warehouseOut.ID,
  1251. //WarehouseInfoId: warehouse.ID,
  1252. Status: 1,
  1253. Ctime: time.Now().Unix(),
  1254. Remark: "",
  1255. OrgId: orgID,
  1256. Type: 1,
  1257. Manufacturer: 0,
  1258. Dealer: 0,
  1259. IsSys: 2,
  1260. SysRecordTime: record_time,
  1261. GoodTypeId: good_yc.GoodTypeId,
  1262. GoodId: good_yc.GoodId,
  1263. }
  1264. warehouseOutInfo.Count = delete_count
  1265. stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  1266. warehouseOutInfo.Price = stockInInfo.Price
  1267. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1268. if errOne != nil {
  1269. return errOne
  1270. }
  1271. // 删除出库完成后,要增加对应批次的库存数量
  1272. errThree := UpDateWarehouseInfoByStockDelete(ware.WarehouseInfotId, delete_count)
  1273. if errThree != nil {
  1274. return errThree
  1275. }
  1276. // 增加了对应的库存后,看看还有多少需要退库的
  1277. good_yc.Count = good_yc.Count - delete_count
  1278. if good_yc.Count == 0 {
  1279. return nil
  1280. }
  1281. }
  1282. if good_yc.Count == 0 {
  1283. return nil
  1284. } else {
  1285. return errors.New("退库和出库数据不匹配")
  1286. }
  1287. }