warhouse_service.go 72KB

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