warhouse_service.go 72KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980
  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: deliver_number,
  844. Price: info.PackingPrice,
  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. PatientId: patient_id,
  859. }
  860. CreateStockFlowOne(flow)
  861. if errTwo != nil {
  862. return errTwo
  863. }
  864. } else if errcode == nil {
  865. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
  866. CreateAutoReduceRecord(&details)
  867. //插入库存流水表
  868. flow := models.VmStockFlow{
  869. WarehouseOutId: warehouseOut.ID,
  870. WarehousingId: warehouse.ID,
  871. GoodId: goods.GoodId,
  872. Number: warehouse.Number,
  873. ProductDate: warehouse.ProductDate,
  874. ExpireDate: warehouse.ExpiryDate,
  875. Count: deliver_number,
  876. Price: info.PackingPrice,
  877. Status: 1,
  878. Ctime: time.Now().Unix(),
  879. UserOrgId: orgID,
  880. Manufacturer: info.Manufacturer,
  881. Dealer: info.Dealer,
  882. LicenseNumber: warehouse.LicenseNumber,
  883. IsEdit: 2,
  884. Creator: warehouseOut.Creater,
  885. SystemTime: record_time,
  886. ConsumableType: 3,
  887. WarehouseOutDetailId: warehouseOutInfo.ID,
  888. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  889. IsSys: 1,
  890. PatientId: patient_id,
  891. }
  892. CreateStockFlowOne(flow)
  893. }
  894. maxNumber = goods.Count
  895. if warehouse.StockCount < maxNumber {
  896. return errors.New("库存数量不足")
  897. }
  898. warehouse.StockCount = warehouse.StockCount - maxNumber
  899. warehouse.Mtime = time.Now().Unix()
  900. if warehouse.StockCount < 0 {
  901. return errors.New("库存数量不足")
  902. }
  903. errThree := UpDateWarehouseInfoByStock(&warehouse)
  904. if errThree != nil {
  905. return errThree
  906. }
  907. return nil
  908. } else {
  909. // 当刚批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  910. warehouseOutInfo := &models.WarehouseOutInfo{
  911. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  912. WarehouseOutId: warehouseOut.ID,
  913. WarehouseInfotId: warehouse.ID,
  914. Status: 1,
  915. Ctime: time.Now().Unix(),
  916. Remark: warehouse.Remark,
  917. OrgId: orgID,
  918. Type: 1,
  919. Manufacturer: warehouse.Manufacturer,
  920. Dealer: warehouse.Dealer,
  921. IsSys: 1,
  922. SysRecordTime: record_time,
  923. GoodTypeId: goods.GoodTypeId,
  924. GoodId: goods.GoodId,
  925. PatientId: patient_id,
  926. Number: warehouse.Number,
  927. LicenseNumber: warehouse.LicenseNumber,
  928. Price: info.PackingPrice,
  929. ExpiryDate: warehouse.ExpiryDate,
  930. ProductDate: warehouse.ProductDate,
  931. }
  932. warehouseOutInfo.Count = stock_number
  933. _, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, goods.PatientId, record_time)
  934. if errcodes == gorm.ErrRecordNotFound {
  935. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  936. if errOne != nil {
  937. return errOne
  938. }
  939. //插入库存流水表
  940. flow := models.VmStockFlow{
  941. WarehouseOutId: warehouseOut.ID,
  942. WarehousingId: warehouse.ID,
  943. GoodId: goods.GoodId,
  944. Number: warehouse.Number,
  945. ProductDate: warehouse.ProductDate,
  946. ExpireDate: warehouse.ExpiryDate,
  947. Count: stock_number,
  948. Price: warehouse.Price,
  949. Status: 1,
  950. Ctime: time.Now().Unix(),
  951. UserOrgId: orgID,
  952. Manufacturer: info.Manufacturer,
  953. Dealer: info.Dealer,
  954. LicenseNumber: warehouse.LicenseNumber,
  955. IsEdit: 2,
  956. Creator: warehouseOut.Creater,
  957. SystemTime: record_time,
  958. ConsumableType: 3,
  959. WarehouseOutDetailId: warehouseOutInfo.ID,
  960. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  961. IsSys: 1,
  962. PatientId: patient_id,
  963. }
  964. CreateStockFlowOne(flow)
  965. } else if errcodes == nil {
  966. goods.Count = deliver_number - stock_number
  967. //更新数量为 刚批次剩余数量 + 还有未出的数量
  968. warehouseOutInfo.Count = goods.Count + stock_number
  969. UpdatedWarehouseOutInfo(warehouseOutInfo, goods.GoodId, goods.PatientId, record_time)
  970. //插入库存流水表
  971. flow := models.VmStockFlow{
  972. WarehouseOutId: warehouseOut.ID,
  973. WarehousingId: warehouse.ID,
  974. GoodId: goods.GoodId,
  975. Number: warehouse.Number,
  976. ProductDate: warehouse.ProductDate,
  977. ExpireDate: warehouse.ExpiryDate,
  978. Count: goods.Count + stock_number,
  979. Price: warehouse.Price,
  980. Status: 1,
  981. Ctime: time.Now().Unix(),
  982. UserOrgId: orgID,
  983. Manufacturer: info.Manufacturer,
  984. Dealer: info.Dealer,
  985. LicenseNumber: warehouse.LicenseNumber,
  986. IsEdit: 2,
  987. Creator: warehouseOut.Creater,
  988. SystemTime: record_time,
  989. ConsumableType: 3,
  990. WarehouseOutDetailId: warehouseOutInfo.ID,
  991. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  992. IsSys: 1,
  993. PatientId: patient_id,
  994. }
  995. CreateStockFlowOne(flow)
  996. }
  997. // 出库完成后,要将该批次库存清零
  998. warehouse.StockCount = 0
  999. warehouse.Mtime = time.Now().Unix()
  1000. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1001. if errThree != nil {
  1002. return errThree
  1003. }
  1004. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1005. goods.Count = deliver_number - stock_number
  1006. ConsumablesDelivery(orgID, patient_id, record_time, goods, warehouseOut, count)
  1007. }
  1008. return nil
  1009. }
  1010. //耗材出库删除
  1011. func ConsumablesDeliveryDelete(orgID int64, patient_id int64, record_time int64, good_yc *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut) (err error) {
  1012. // 先根据相关信息查询当天该耗材的出库信息
  1013. warehouseOutInfos, err := FindStockOutInfoByStock(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time, patient_id)
  1014. if err != nil {
  1015. return err
  1016. }
  1017. var delete_count int64 = 0
  1018. for _, ware := range warehouseOutInfos {
  1019. // 判断当前出库的数据和删除出库数量
  1020. if good_yc.Count <= ware.Count {
  1021. delete_count = good_yc.Count
  1022. } else {
  1023. delete_count = ware.Count
  1024. }
  1025. // 在出库记录表里记录退库详情
  1026. warehouseOutInfo := &models.WarehouseOutInfo{
  1027. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1028. WarehouseOutId: warehouseOut.ID,
  1029. //WarehouseInfoId: warehouse.ID,
  1030. Status: 1,
  1031. Ctime: time.Now().Unix(),
  1032. Remark: "",
  1033. OrgId: orgID,
  1034. Type: 1,
  1035. Manufacturer: 0,
  1036. Dealer: 0,
  1037. IsSys: 2,
  1038. SysRecordTime: record_time,
  1039. GoodTypeId: good_yc.GoodTypeId,
  1040. GoodId: good_yc.GoodId,
  1041. PatientId: patient_id,
  1042. }
  1043. warehouseOutInfo.Count = ware.Count - delete_count
  1044. stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  1045. warehouseOutInfo.Price = stockInInfo.Price
  1046. errOne := UpdateAutoMaticReduceDetail(good_yc.GoodId, good_yc.GoodTypeId, record_time, patient_id, orgID, warehouseOutInfo)
  1047. if errOne != nil {
  1048. return errOne
  1049. } else {
  1050. details := &models.AutomaticReduceDetail{
  1051. WarehouseOutId: warehouseOutInfo.ID,
  1052. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  1053. PatientId: patient_id,
  1054. Ctime: time.Now().Unix(),
  1055. Mtime: time.Now().Unix(),
  1056. Status: 1,
  1057. RecordTime: record_time,
  1058. OrgId: orgID,
  1059. GoodId: good_yc.GoodId,
  1060. GoodTypeId: good_yc.GoodTypeId,
  1061. Count: warehouseOutInfo.Count,
  1062. Type: 2,
  1063. }
  1064. //查询是否当天已经存在数据
  1065. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1066. if errcode == gorm.ErrRecordNotFound {
  1067. errTwo := AddSigleAutoReduceRecordInfo(details)
  1068. if errTwo != nil {
  1069. return errTwo
  1070. }
  1071. } else if errcode == nil {
  1072. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1073. AddSigleAutoReduceRecordInfo(details)
  1074. }
  1075. }
  1076. // 删除出库完成后,要增加对应批次的库存数量
  1077. errThree := UpDateWarehouseInfoByStockDelete(ware.WarehouseInfotId, delete_count)
  1078. if errThree != nil {
  1079. return errThree
  1080. }
  1081. // 增加了对应的库存后,看看还有多少需要退库的
  1082. good_yc.Count = good_yc.Count - delete_count
  1083. if good_yc.Count == 0 {
  1084. return nil
  1085. }
  1086. }
  1087. if good_yc.Count == 0 {
  1088. return nil
  1089. } else {
  1090. return errors.New("退库和出库数据不匹配")
  1091. }
  1092. }
  1093. func GetAutoReduceRecordInfoByPatientId(orgid int64, patient_id int64, recordTime int64) (autoReduce []*models.AutomaticReduceDetail, err error) {
  1094. err = XTReadDB().Model(&autoReduce).Where("org_id = ? and patient_id = ? and record_time = ? and status = 1", orgid, patient_id, recordTime).Find(&autoReduce).Error
  1095. return autoReduce, err
  1096. }
  1097. func DeleteDialysisBefor(orgid int64, patient_id int64, record_date int64, goodid int64, goodtypeid int64) error {
  1098. prepare := models.DialysisBeforePrepare{}
  1099. 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
  1100. return err
  1101. }
  1102. func DeleteDialysisBeforThree(orgid int64, patient_id int64, record_date int64) error {
  1103. prepare := models.DialysisBeforePrepare{}
  1104. 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
  1105. return err
  1106. }
  1107. //耗材出库
  1108. func ConsumablesDeliveryOne(orgID int64, record_time int64, goods *models.WarehouseOutInfo, warehouseOut *models.WarehouseOut, count int64, creator int64) (err error) {
  1109. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  1110. var deliver_number int64 = 0
  1111. var stock_number int64 = 0
  1112. var maxNumber int64 = 0
  1113. deliver_number = goods.Count
  1114. fmt.Println("添加数量", deliver_number)
  1115. // 根据先进先出原则,查询最先入库的批次,进行出库
  1116. // 如果没有对应的库存,则报错
  1117. warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId)
  1118. fmt.Println("err222222222222222222222", warehouse.StockCount)
  1119. if err != nil {
  1120. return err
  1121. }
  1122. // 将该批次的剩余库存数量转换为拆零数量
  1123. stock_number = warehouse.StockCount
  1124. fmt.Println("3434343434343434", stock_number)
  1125. fmt.Println("8888888888888888888", deliver_number)
  1126. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  1127. if stock_number >= deliver_number {
  1128. fmt.Println("g2332232332323232232323322332", goods.Price)
  1129. warehouseOutInfo := &models.WarehouseOutInfo{
  1130. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1131. WarehouseOutId: warehouseOut.ID,
  1132. WarehouseInfotId: warehouse.ID,
  1133. Status: 1,
  1134. Ctime: time.Now().Unix(),
  1135. Remark: goods.Remark,
  1136. OrgId: orgID,
  1137. Type: 1,
  1138. Manufacturer: goods.Manufacturer,
  1139. Dealer: goods.Dealer,
  1140. IsSys: 0,
  1141. SysRecordTime: record_time,
  1142. GoodTypeId: goods.GoodTypeId,
  1143. GoodId: goods.GoodId,
  1144. ExpiryDate: goods.ExpiryDate,
  1145. ProductDate: goods.ProductDate,
  1146. Number: goods.Number,
  1147. Price: goods.Price,
  1148. LicenseNumber: goods.LicenseNumber,
  1149. }
  1150. warehouseOutInfo.Count = goods.Count
  1151. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1152. if errOne != nil {
  1153. return errOne
  1154. }
  1155. stockFlow := models.VmStockFlow{
  1156. WarehousingId: warehouse.ID,
  1157. GoodId: goods.GoodId,
  1158. Number: goods.Number,
  1159. LicenseNumber: goods.LicenseNumber,
  1160. Count: goods.Count,
  1161. UserOrgId: goods.OrgId,
  1162. PatientId: goods.PatientId,
  1163. SystemTime: record_time,
  1164. ConsumableType: 2,
  1165. IsSys: goods.IsSys,
  1166. WarehousingOrder: "",
  1167. WarehouseOutId: warehouseOut.ID,
  1168. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1169. IsEdit: 1,
  1170. CancelStockId: 0,
  1171. CancelOrderNumber: "",
  1172. Manufacturer: goods.Manufacturer,
  1173. Dealer: goods.Dealer,
  1174. Creator: creator,
  1175. UpdateCreator: 0,
  1176. Status: 1,
  1177. Ctime: time.Now().Unix(),
  1178. Mtime: 0,
  1179. Price: goods.Price,
  1180. WarehousingDetailId: 0,
  1181. WarehouseOutDetailId: warehouseOutInfo.ID,
  1182. CancelOutDetailId: 0,
  1183. ProductDate: goods.ProductDate,
  1184. ExpireDate: goods.ExpiryDate,
  1185. }
  1186. //创建出库明细
  1187. CreateStockFlowOne(stockFlow)
  1188. maxNumber = goods.Count
  1189. if warehouse.StockCount < maxNumber {
  1190. return errors.New("库存数量不足")
  1191. }
  1192. warehouse.StockCount = warehouse.StockCount - maxNumber
  1193. warehouse.Mtime = time.Now().Unix()
  1194. if warehouse.StockCount < 0 {
  1195. return errors.New("库存数量不足")
  1196. }
  1197. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1198. if errThree != nil {
  1199. return errThree
  1200. }
  1201. } else {
  1202. // 当改批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  1203. warehouseOutInfo := &models.WarehouseOutInfo{
  1204. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1205. WarehouseOutId: warehouseOut.ID,
  1206. WarehouseInfotId: warehouse.ID,
  1207. Status: 1,
  1208. Ctime: time.Now().Unix(),
  1209. Remark: goods.Remark,
  1210. OrgId: orgID,
  1211. Type: 1,
  1212. Manufacturer: goods.Manufacturer,
  1213. Dealer: goods.Dealer,
  1214. IsSys: 0,
  1215. SysRecordTime: record_time,
  1216. GoodTypeId: goods.GoodTypeId,
  1217. GoodId: goods.GoodId,
  1218. ExpiryDate: goods.ExpiryDate,
  1219. ProductDate: goods.ProductDate,
  1220. Number: goods.Number,
  1221. Price: goods.Price,
  1222. LicenseNumber: goods.LicenseNumber,
  1223. }
  1224. warehouseOutInfo.Count = stock_number
  1225. info, errcodes := GetStockInRecoredByGoodIdOne(goods.GoodId, goods.GoodTypeId, goods.SysRecordTime, goods.OrgId)
  1226. if errcodes == gorm.ErrRecordNotFound {
  1227. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1228. if errOne != nil {
  1229. return errOne
  1230. }
  1231. } else {
  1232. warehouseOutInfo.Count = info.Count + stock_number
  1233. UpdateAutoMaticReduceDetailOne(goods.GoodId, goods.GoodTypeId, goods.SysRecordTime, goods.OrgId, warehouseOutInfo)
  1234. }
  1235. stockFlow := models.VmStockFlow{
  1236. WarehousingId: warehouse.ID,
  1237. GoodId: goods.GoodId,
  1238. Number: goods.Number,
  1239. LicenseNumber: goods.LicenseNumber,
  1240. Count: goods.Count,
  1241. UserOrgId: goods.OrgId,
  1242. PatientId: 0,
  1243. SystemTime: record_time,
  1244. ConsumableType: 2,
  1245. IsSys: 0,
  1246. WarehousingOrder: "",
  1247. WarehouseOutId: warehouseOut.ID,
  1248. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1249. IsEdit: 1,
  1250. CancelStockId: 0,
  1251. CancelOrderNumber: "",
  1252. Manufacturer: goods.Manufacturer,
  1253. Dealer: goods.Dealer,
  1254. Creator: creator,
  1255. UpdateCreator: 0,
  1256. Status: 1,
  1257. Ctime: time.Now().Unix(),
  1258. Mtime: 0,
  1259. Price: goods.Price,
  1260. WarehousingDetailId: 0,
  1261. WarehouseOutDetailId: warehouseOutInfo.ID,
  1262. CancelOutDetailId: 0,
  1263. ProductDate: goods.ProductDate,
  1264. ExpireDate: goods.ExpiryDate,
  1265. }
  1266. //创建出库明细
  1267. CreateStockFlowOne(stockFlow)
  1268. // 出库完成后,要将该批次库存清零
  1269. warehouse.StockCount = 0
  1270. warehouse.Mtime = time.Now().Unix()
  1271. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1272. if errThree != nil {
  1273. return errThree
  1274. }
  1275. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1276. goods.Count = deliver_number - stock_number
  1277. fmt.Println("goods3333333333333333333333", goods.Count)
  1278. ConsumablesDeliveryOne(orgID, record_time, goods, warehouseOut, count, creator)
  1279. }
  1280. return nil
  1281. }
  1282. //耗材出库删除
  1283. func ConsumablesDeliveryDeleteOne(orgID int64, record_time int64, good_yc *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut) (err error) {
  1284. // 先根据相关信息查询当天该耗材的出库信息
  1285. warehouseOutInfos, err := FindStockOutInfoByStockOne(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time)
  1286. if err != nil {
  1287. return err
  1288. }
  1289. var delete_count int64 = 0
  1290. for _, ware := range warehouseOutInfos {
  1291. // 判断当前出库的数据和删除出库数量
  1292. if good_yc.Count <= ware.Count {
  1293. delete_count = good_yc.Count
  1294. } else {
  1295. delete_count = ware.Count
  1296. }
  1297. // 在出库记录表里记录退库详情
  1298. warehouseOutInfo := &models.WarehouseOutInfo{
  1299. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1300. WarehouseOutId: warehouseOut.ID,
  1301. //WarehouseInfoId: warehouse.ID,
  1302. Status: 1,
  1303. Ctime: time.Now().Unix(),
  1304. Remark: "",
  1305. OrgId: orgID,
  1306. Type: 1,
  1307. Manufacturer: 0,
  1308. Dealer: 0,
  1309. IsSys: 0,
  1310. SysRecordTime: record_time,
  1311. GoodTypeId: good_yc.GoodTypeId,
  1312. GoodId: good_yc.GoodId,
  1313. }
  1314. warehouseOutInfo.Count = delete_count
  1315. stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  1316. warehouseOutInfo.Price = stockInInfo.Price
  1317. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1318. if errOne != nil {
  1319. return errOne
  1320. }
  1321. // 删除出库完成后,要增加对应批次的库存数量
  1322. errThree := UpDateWarehouseInfoByStockDelete(ware.WarehouseInfotId, delete_count)
  1323. if errThree != nil {
  1324. return errThree
  1325. }
  1326. // 增加了对应的库存后,看看还有多少需要退库的
  1327. good_yc.Count = good_yc.Count - delete_count
  1328. if good_yc.Count == 0 {
  1329. return nil
  1330. }
  1331. }
  1332. if good_yc.Count == 0 {
  1333. return nil
  1334. } else {
  1335. return errors.New("退库和出库数据不匹配")
  1336. }
  1337. }
  1338. //退库逻辑
  1339. func ConsumablesDeliveryTwo(orgID int64, goods *models.WarehouseOutInfo, count int64) (err error) {
  1340. // 判断处方里药品单位是拆零单位还是包装单位, 如果是包装单位,则根据规格,将包装数量转为拆零数量
  1341. var deliver_number int64 = 0
  1342. var stock_number int64 = 0
  1343. var maxNumber int64 = 0
  1344. deliver_number = goods.Count
  1345. fmt.Println("添加数量", deliver_number)
  1346. // 根据先进先出原则,查询最先入库的批次,进行出库
  1347. // 查询除自己以为的库存
  1348. warehouse, err := FindFirstWarehousingInfoByGoodId(goods.GoodId, goods.ID)
  1349. if err != nil {
  1350. return err
  1351. }
  1352. // 将该批次的剩余库存数量转换为拆零数量
  1353. stock_number = warehouse.StockCount
  1354. // 当库存数量大于或等于出库数量的话,则正常出库该批次
  1355. if stock_number >= deliver_number {
  1356. warehouseOutInfo := &models.WarehouseOutInfo{
  1357. WarehouseOutOrderNumber: goods.WarehouseOutOrderNumber,
  1358. WarehouseOutId: goods.ID,
  1359. WarehouseInfotId: warehouse.ID,
  1360. Status: 1,
  1361. Ctime: time.Now().Unix(),
  1362. Remark: goods.Remark,
  1363. OrgId: orgID,
  1364. Type: 1,
  1365. Manufacturer: goods.Manufacturer,
  1366. Dealer: goods.Dealer,
  1367. IsSys: 0,
  1368. GoodTypeId: goods.GoodTypeId,
  1369. GoodId: goods.GoodId,
  1370. ExpiryDate: goods.ExpiryDate,
  1371. ProductDate: goods.ProductDate,
  1372. Number: goods.Number,
  1373. Price: goods.Price,
  1374. LicenseNumber: goods.LicenseNumber,
  1375. ConsumableType: 2,
  1376. }
  1377. warehouseOutInfo.Count = goods.Count
  1378. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1379. if errOne != nil {
  1380. return errOne
  1381. }
  1382. maxNumber = goods.Count
  1383. if warehouse.StockCount < maxNumber {
  1384. return errors.New("库存数量不足")
  1385. }
  1386. warehouse.StockCount = warehouse.StockCount - maxNumber
  1387. warehouse.Mtime = time.Now().Unix()
  1388. if warehouse.StockCount < 0 {
  1389. return errors.New("库存数量不足")
  1390. }
  1391. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1392. if errThree != nil {
  1393. return errThree
  1394. }
  1395. } else {
  1396. // 当改批次的库存数量小于出库数量的话,则先把该批次出库完后,再进行递归出库
  1397. warehouseOutInfo := &models.WarehouseOutInfo{
  1398. WarehouseOutOrderNumber: goods.WarehouseOutOrderNumber,
  1399. WarehouseOutId: goods.ID,
  1400. WarehouseInfotId: warehouse.ID,
  1401. Status: 1,
  1402. Ctime: time.Now().Unix(),
  1403. Remark: goods.Remark,
  1404. OrgId: orgID,
  1405. Type: 1,
  1406. Manufacturer: goods.Manufacturer,
  1407. Dealer: goods.Dealer,
  1408. IsSys: 0,
  1409. GoodTypeId: goods.GoodTypeId,
  1410. GoodId: goods.GoodId,
  1411. ExpiryDate: goods.ExpiryDate,
  1412. ProductDate: goods.ProductDate,
  1413. Number: goods.Number,
  1414. Price: goods.Price,
  1415. LicenseNumber: goods.LicenseNumber,
  1416. ConsumableType: 2,
  1417. }
  1418. warehouseOutInfo.Count = stock_number
  1419. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1420. if errOne != nil {
  1421. return errOne
  1422. }
  1423. // 出库完成后,要将该批次库存清零
  1424. warehouse.StockCount = 0
  1425. warehouse.Mtime = time.Now().Unix()
  1426. errThree := UpDateWarehouseInfoByStock(&warehouse)
  1427. if errThree != nil {
  1428. return errThree
  1429. }
  1430. // 清零完该库存后,还有剩余出库未出完,进行对应的递归操作
  1431. goods.Count = deliver_number - stock_number
  1432. ConsumablesDeliveryTwo(orgID, goods, count)
  1433. }
  1434. return nil
  1435. }
  1436. func DeleteWarehouseInfo(id int64) error {
  1437. err := XTWriteDB().Model(models.WarehousingInfo{}).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"stock_count": 0}).Error
  1438. return err
  1439. }
  1440. //
  1441. ////当前数据比上一次出库数据少
  1442. //func ConsumablesDeliveryTotalSeven(orgID int64, patient_id int64, record_time int64, goods []*models.DialysisBeforePrepareGoods,creater int64,count int64) (err error) {
  1443. //
  1444. // fmt.Println("w我的中国馆公共区发电房阿道夫安抚安抚安抚安抚安抚安抚阿道夫阿道夫阿凡达阿道夫a",count)
  1445. // //查询该患者当天已经出库的耗材信息
  1446. // goods_yc, _ := FindConsumablesByDateThree(orgID, patient_id, record_time)
  1447. // // 和新请求的出库数据进行对比,分出那些是继续出库的,那些是需要删除出库的
  1448. // for i := len(goods_yc) - 1; i >= 0; i-- {
  1449. // goods_yc_temp := goods_yc[i]
  1450. // for j := len(goods) - 1; j >= 0; j-- {
  1451. // goods_temp := goods[j]
  1452. // // 已经出库和新请求出库都存在该耗材,则判断出库数量,分成是继续出库,还是删除出库
  1453. // if goods_yc_temp.GoodTypeId == goods_temp.GoodTypeId && goods_yc_temp.GoodId == goods_temp.GoodId {
  1454. // // 已经出库和新请求出库的出库数量一致,则清除两个结构体里的数据(既不出库,也不删除出库)
  1455. // if goods_yc_temp.Count == goods_temp.Count {
  1456. // goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  1457. // goods = append(goods[:j], goods[j+1:]...)
  1458. // break
  1459. // }
  1460. // // 如果已经出库的数量 大于 新请求出库的数量,则代表需要删除出库
  1461. // if goods_yc_temp.Count > goods_temp.Count {
  1462. //
  1463. // temp_count := goods_yc_temp.Count - goods_temp.Count
  1464. // goods_yc[i].Count = temp_count
  1465. // goods = append(goods[:j], goods[j+1:]...)
  1466. // break
  1467. // }
  1468. // // 如果已经出库的数量 小于 新请求出库的梳理,则代表需要增加出库
  1469. // if goods_yc_temp.Count < goods_temp.Count {
  1470. // temp_count := goods_temp.Count - goods_yc_temp.Count
  1471. // //fmt.Println("988888888888888", temp_count)
  1472. // goods[j].Count = temp_count
  1473. // goods_yc = append(goods_yc[:i], goods_yc[i+1:]...)
  1474. // //fmt.Println("888888888", goods_yc)
  1475. // break
  1476. // }
  1477. // }
  1478. // }
  1479. // }
  1480. //
  1481. // // goods_yc 这个数据就是需要已经出库了,但是现在需要删除出库的耗材数据
  1482. // // goods 这个数据就是需要出库的耗材的数据(新增的数据)
  1483. // fmt.Println("goodsy999999999999", goods_yc)
  1484. //
  1485. //
  1486. //
  1487. // //退库
  1488. // if len(goods_yc) > 0 {
  1489. // for _, good_yc := range goods_yc {
  1490. // out, _ := FindStockOutByIsSys(orgID, 1, record_time)
  1491. // ConsumablesDeliveryDeleteFour(orgID, record_time, good_yc, &out,patient_id,creater,count)
  1492. // }
  1493. // }
  1494. //
  1495. // return nil
  1496. //}
  1497. ////耗材出库删除
  1498. //func ConsumablesDeliveryDeleteFour(orgID int64, record_time int64, good_yc *models.BloodAutomaticReduceDetail, warehouseOut *models.WarehouseOut,patient_id int64,creater int64,count int64) (err error) {
  1499. //
  1500. // fmt.Println("count2323223884584854854854u5454785487547845785478758487545475475487,count",count)
  1501. // // 先根据相关信息查询当天该耗材的出库信息
  1502. // warehouseOutInfos, err := FindStockOutInfoByStockTwo(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time,good_yc.PatientId)
  1503. // fmt.Println("errr232323232323232323232323232",err)
  1504. // if err != nil {
  1505. // return err
  1506. // }
  1507. //
  1508. // var delete_count int64 = 0
  1509. //
  1510. // delete_count = warehouseOutInfos.Count - count
  1511. //
  1512. // fmt.Println("delete_count2323232",delete_count)
  1513. // // 在出库记录表里记录退库详情
  1514. // warehouseOutInfo := &models.WarehouseOutInfo{
  1515. // WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1516. // WarehouseOutId: warehouseOut.ID,
  1517. // Status: 1,
  1518. // Ctime: time.Now().Unix(),
  1519. // OrgId: orgID,
  1520. // Type: 1,
  1521. // IsSys: 1,
  1522. // SysRecordTime: record_time,
  1523. // GoodTypeId: good_yc.GoodTypeId,
  1524. // GoodId: good_yc.GoodId,
  1525. // PatientId:good_yc.PatientId,
  1526. // ConsumableType:2,
  1527. //
  1528. // }
  1529. // warehouseOutInfo.Count = count
  1530. //
  1531. // stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  1532. // warehouseOutInfo.Price = stockInInfo.Price
  1533. // warehouseOutInfo.Dealer = stockInInfo.Dealer
  1534. // warehouseOutInfo.Manufacturer = stockInInfo.Manufacturer
  1535. // warehouseOutInfo.ExpiryDate = stockInInfo.ExpiryDate
  1536. // warehouseOutInfo.ProductDate = stockInInfo.ProductDate
  1537. // warehouseOutInfo.Number = stockInInfo.Number
  1538. // warehouseOutInfo.LicenseNumber = stockInInfo.LicenseNumber
  1539. // warehouseOutInfo.WarehouseInfotId = stockInInfo.ID
  1540. // //查找当天是否存在出库记录
  1541. //
  1542. // _, errcod := GetWarehouseOutInfoIsExistOne(good_yc.GoodId, good_yc.PatientId, record_time)
  1543. // fmt.Println("errcode2323223255556652324242424242424242424242424242242",errcod)
  1544. // if errcod == gorm.ErrRecordNotFound{
  1545. // errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1546. // //插入详情明细表
  1547. // stockFlow := models.VmStockFlow{
  1548. // WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1549. // WarehouseOutId: warehouseOut.ID,
  1550. // GoodId: good_yc.GoodId,
  1551. // Number: stockInInfo.Number,
  1552. // ProductDate: stockInInfo.ProductDate,
  1553. // ExpireDate: stockInInfo.ExpiryDate,
  1554. // Count: count,
  1555. // Price: stockInInfo.Price,
  1556. // Status: 1,
  1557. // Ctime: time.Now().Unix(),
  1558. // UserOrgId: good_yc.OrgId,
  1559. // Manufacturer: stockInInfo.Manufacturer,
  1560. // Dealer: stockInInfo.Dealer,
  1561. // LicenseNumber: stockInInfo.LicenseNumber,
  1562. // IsEdit: 2,
  1563. // Creator: creater,
  1564. // SystemTime: record_time,
  1565. // ConsumableType: 2,
  1566. // WarehousingDetailId:0,
  1567. // IsSys:1,
  1568. // UpdateCreator:creater,
  1569. // }
  1570. // //创建流水表
  1571. // err := CreateStockFlowOne(stockFlow)
  1572. // fmt.Println("h2h3h2323342i24i242i4u2i4242u42424",err)
  1573. // if errOne != nil {
  1574. // return errOne
  1575. // }
  1576. // }else if errcod == nil{
  1577. // UpdatedWarehouseOutInfo(warehouseOutInfo,good_yc.GoodId,good_yc.PatientId,record_time)
  1578. // //插入详情明细表
  1579. // stockFlow := models.VmStockFlow{
  1580. // WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1581. // WarehouseOutId: warehouseOut.ID,
  1582. // GoodId: good_yc.GoodId,
  1583. // Number: stockInInfo.Number,
  1584. // ProductDate: stockInInfo.ProductDate,
  1585. // ExpireDate: stockInInfo.ExpiryDate,
  1586. // Count: count,
  1587. // Price: stockInInfo.Price,
  1588. // Status: 1,
  1589. // Ctime: time.Now().Unix(),
  1590. // UserOrgId: good_yc.OrgId,
  1591. // Manufacturer: stockInInfo.Manufacturer,
  1592. // Dealer: stockInInfo.Dealer,
  1593. // LicenseNumber: stockInInfo.LicenseNumber,
  1594. // IsEdit: 2,
  1595. // Creator: creater,
  1596. // SystemTime: record_time,
  1597. // ConsumableType: 2,
  1598. // WarehousingDetailId:0,
  1599. // IsSys:1,
  1600. // UpdateCreator:creater,
  1601. // }
  1602. // //创建流水表
  1603. // CreateStockFlowOne(stockFlow)
  1604. // }
  1605. //
  1606. //
  1607. //
  1608. // //更改自动出库的表格
  1609. // details := models.BloodAutomaticReduceDetail{
  1610. // WarehouseOutId: warehouseOutInfo.ID,
  1611. // WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  1612. // PatientId: patient_id,
  1613. // Ctime: time.Now().Unix(),
  1614. // Mtime: time.Now().Unix(),
  1615. // Status: 1,
  1616. // RecordTime: record_time,
  1617. // OrgId: orgID,
  1618. // GoodId: good_yc.GoodId,
  1619. // GoodTypeId: good_yc.GoodTypeId,
  1620. // Count: count,
  1621. // }
  1622. // //查询当天耗材是否已经存在数据
  1623. // _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1624. //
  1625. // if errcode == gorm.ErrRecordNotFound {
  1626. // errTwo := CreateAutoReduceRecord(&details)
  1627. // if errTwo != nil {
  1628. // return errTwo
  1629. // }
  1630. // } else if errcode == nil {
  1631. // DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1632. // CreateAutoReduceRecord(&details)
  1633. // }
  1634. // // 删除出库完成后,要增加对应批次的库存数量
  1635. // fmt.Println("deletecount2323232323232323232323232323",delete_count)
  1636. // errThree := UpDateWarehouseInfoByStockDelete(warehouseOutInfos.WarehouseInfotId, delete_count)
  1637. //
  1638. // if errThree != nil {
  1639. // return errThree
  1640. // }
  1641. //
  1642. //
  1643. // if good_yc.Count == 0 {
  1644. // return nil
  1645. // } else {
  1646. // return errors.New("退库和出库数据不匹配")
  1647. // }
  1648. //}
  1649. //耗材出库删除
  1650. func ConsumablesDeliveryDeleteFive(orgID int64, record_time int64, good_yc *models.BloodAutomaticReduceDetail, warehouseOut *models.WarehouseOut, patient_id int64, creater int64, count int64) (err error) {
  1651. fmt.Println("count23232323232323232323232323223223", count)
  1652. // 先根据相关信息查询当天该耗材的出库信息
  1653. warehouseOutInfos, err := FindStockOutInfoByStockTwo(orgID, good_yc.GoodTypeId, good_yc.GoodId, record_time, good_yc.PatientId)
  1654. fmt.Println("errr232323232323232323232323232", err)
  1655. if err != nil {
  1656. return err
  1657. }
  1658. var delete_count int64 = 0
  1659. delete_count = count - warehouseOutInfos.Count
  1660. // 判断当前出库的数据和删除出库数量
  1661. // 在出库记录表里记录退库详情
  1662. warehouseOutInfo := &models.WarehouseOutInfo{
  1663. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1664. WarehouseOutId: warehouseOut.ID,
  1665. Status: 1,
  1666. Ctime: time.Now().Unix(),
  1667. OrgId: orgID,
  1668. Type: 1,
  1669. IsSys: 1,
  1670. SysRecordTime: record_time,
  1671. GoodTypeId: good_yc.GoodTypeId,
  1672. GoodId: good_yc.GoodId,
  1673. PatientId: good_yc.PatientId,
  1674. ConsumableType: 2,
  1675. }
  1676. warehouseOutInfo.Count = count
  1677. stockInInfo, _ := FindLastStockInInfoRecord(good_yc.GoodId, orgID)
  1678. warehouseOutInfo.Price = stockInInfo.Price
  1679. warehouseOutInfo.Dealer = stockInInfo.Dealer
  1680. warehouseOutInfo.Manufacturer = stockInInfo.Manufacturer
  1681. warehouseOutInfo.ExpiryDate = stockInInfo.ExpiryDate
  1682. warehouseOutInfo.ProductDate = stockInInfo.ProductDate
  1683. warehouseOutInfo.Number = stockInInfo.Number
  1684. warehouseOutInfo.LicenseNumber = stockInInfo.LicenseNumber
  1685. warehouseOutInfo.WarehouseInfotId = stockInInfo.ID
  1686. //查找当天是否存在出库记录
  1687. _, errcod := GetWarehouseOutInfoIsExistOne(good_yc.GoodId, good_yc.PatientId, record_time)
  1688. fmt.Println("errcode2323223255556652324242424242424242424242424242242", errcod)
  1689. if errcod == gorm.ErrRecordNotFound {
  1690. errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
  1691. //插入详情明细表
  1692. stockFlow := models.VmStockFlow{
  1693. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1694. WarehouseOutId: warehouseOut.ID,
  1695. GoodId: good_yc.GoodId,
  1696. Number: stockInInfo.Number,
  1697. ProductDate: stockInInfo.ProductDate,
  1698. ExpireDate: stockInInfo.ExpiryDate,
  1699. Count: count,
  1700. Price: stockInInfo.Price,
  1701. Status: 1,
  1702. Ctime: time.Now().Unix(),
  1703. UserOrgId: good_yc.OrgId,
  1704. Manufacturer: stockInInfo.Manufacturer,
  1705. Dealer: stockInInfo.Dealer,
  1706. LicenseNumber: stockInInfo.LicenseNumber,
  1707. IsEdit: 2,
  1708. Creator: creater,
  1709. SystemTime: record_time,
  1710. ConsumableType: 3,
  1711. WarehousingDetailId: 0,
  1712. IsSys: 1,
  1713. UpdateCreator: creater,
  1714. }
  1715. //创建流水表
  1716. err := CreateStockFlowOne(stockFlow)
  1717. fmt.Println("h2h3h2323342i24i242i4u2i4242u42424", err)
  1718. if errOne != nil {
  1719. return errOne
  1720. }
  1721. } else if errcod == nil {
  1722. UpdatedWarehouseOutInfo(warehouseOutInfo, good_yc.GoodId, good_yc.PatientId, record_time)
  1723. //插入详情明细表
  1724. stockFlow := models.VmStockFlow{
  1725. WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
  1726. WarehouseOutId: warehouseOut.ID,
  1727. GoodId: good_yc.GoodId,
  1728. Number: stockInInfo.Number,
  1729. ProductDate: stockInInfo.ProductDate,
  1730. ExpireDate: stockInInfo.ExpiryDate,
  1731. Count: count,
  1732. Price: stockInInfo.Price,
  1733. Status: 1,
  1734. Ctime: time.Now().Unix(),
  1735. UserOrgId: good_yc.OrgId,
  1736. Manufacturer: stockInInfo.Manufacturer,
  1737. Dealer: stockInInfo.Dealer,
  1738. LicenseNumber: stockInInfo.LicenseNumber,
  1739. IsEdit: 2,
  1740. Creator: creater,
  1741. SystemTime: record_time,
  1742. ConsumableType: 3,
  1743. WarehousingDetailId: 0,
  1744. IsSys: 1,
  1745. UpdateCreator: creater,
  1746. }
  1747. //创建流水表
  1748. err := CreateStockFlowOne(stockFlow)
  1749. fmt.Println("h2h3h2323342i24i242i4u2i4242u42424", err)
  1750. }
  1751. //更改自动出库的表格
  1752. details := models.BloodAutomaticReduceDetail{
  1753. WarehouseOutId: warehouseOutInfo.ID,
  1754. WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
  1755. PatientId: patient_id,
  1756. Ctime: time.Now().Unix(),
  1757. Mtime: time.Now().Unix(),
  1758. Status: 1,
  1759. RecordTime: record_time,
  1760. OrgId: orgID,
  1761. GoodId: good_yc.GoodId,
  1762. GoodTypeId: good_yc.GoodTypeId,
  1763. Count: count,
  1764. }
  1765. //查询当天耗材是否已经存在数据
  1766. _, errcode := GetAutoMaticReduceDetail(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1767. if errcode == gorm.ErrRecordNotFound {
  1768. errTwo := CreateAutoReduceRecord(&details)
  1769. if errTwo != nil {
  1770. return errTwo
  1771. }
  1772. } else if errcode == nil {
  1773. DeleteAutoRedeceDetailTwo(orgID, patient_id, record_time, good_yc.GoodId, good_yc.GoodTypeId)
  1774. CreateAutoReduceRecord(&details)
  1775. }
  1776. // 删除出库完成后,要增加对应批次的库存数量
  1777. errThree := UpDateWarehouseInfoByStockDeleteOne(warehouseOutInfos.WarehouseInfotId, delete_count)
  1778. fmt.Println("sql2323234343434343434343434343434343434343343434")
  1779. if errThree != nil {
  1780. return errThree
  1781. }
  1782. if good_yc.Count == 0 {
  1783. return nil
  1784. } else {
  1785. return errors.New("退库和出库数据不匹配")
  1786. }
  1787. }