warhouse_service.go 53KB

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