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