his_deposit_service.go 25KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897
  1. package service
  2. import (
  3. "XT_New/models"
  4. "XT_New/utils"
  5. "fmt"
  6. "github.com/jinzhu/gorm"
  7. "github.com/shopspring/decimal"
  8. "math/rand"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. //生成编号?+yymmdd+随机数(4位)
  14. //新增参数为CP
  15. //退款参数为AF
  16. func CreateCPCode(str string) string {
  17. s := fmt.Sprintf("%04v", rand.New(rand.NewSource(time.Now().UnixNano())).Int63n(10000))
  18. t := time.Now().Format("20060102")
  19. code := str + t + s
  20. return code
  21. }
  22. //获取his中的有效患者
  23. func GetHisUser(orgid int64) (hisname []models.GetHisName, err error) {
  24. err = XTReadDB().Model(&models.GetHisName{}).Where("status = 1 and user_org_id = ?", orgid).Find(&hisname).Error
  25. return
  26. }
  27. //获取his中的有效患者去除了转出和死亡的
  28. func GetHisUserToAlive(orgid int64) (hisname []models.GetHisName, err error) {
  29. err = XTReadDB().Model(&models.GetHisName{}).Where("status = 1 and user_org_id = ? and lapseto = 1", orgid).Find(&hisname).Error
  30. return
  31. }
  32. //获取his中的有效患者
  33. func GetHisUserName(orgid, id int64) (hisname models.GetHisName, err error) {
  34. err = XTReadDB().Model(&models.GetHisName{}).Where("status = 1 and user_org_id = ? and id = ?", orgid, id).Find(&hisname).Error
  35. return
  36. }
  37. //添加押金(开始)调用接口前记得判断审核状态,确认通过审核后在调用
  38. func UpDeposit(code, remarks string, his_patient_id, orgid, trial_status, createid int64, deposit decimal.Decimal) (err error) {
  39. //查押金表是否存在记录
  40. tmp, tmpdeposit := IsHisPatientId(his_patient_id, orgid)
  41. if tmp == 0 {
  42. //需要生成一条数据
  43. de := models.Deposit{
  44. UserOrgId: orgid,
  45. HisPatientId: his_patient_id,
  46. Ctime: time.Now().Unix(),
  47. Mtime: time.Now().Unix(),
  48. Status: 1,
  49. }
  50. i, d, err := AddDeposit(de)
  51. if err != nil || i == 0 {
  52. utils.ErrorLog("添加用户押金记录失败: %v", err.Error())
  53. return err
  54. }
  55. tmp = i
  56. tmpdeposit = d
  57. }
  58. s_deposit := tmpdeposit
  59. if trial_status == 1 {
  60. de := models.Deposit{
  61. ID: tmp,
  62. Mtime: time.Now().Unix(),
  63. Deposit: deposit.Add(tmpdeposit),
  64. }
  65. err = UpdateDeposit(de)
  66. if err != nil {
  67. utils.ErrorLog("添加用户押金失败: %v", err.Error())
  68. return
  69. }
  70. s_deposit = deposit.Add(tmpdeposit)
  71. }
  72. dehistory := models.DepositHistory{
  73. UserOrgId: orgid,
  74. HisPatientId: his_patient_id,
  75. DepositCode: code,
  76. Deposit: deposit, //本次操作的押金
  77. SurplusDeposit: s_deposit, //剩余金额
  78. DepositStatus: 1,
  79. Status: 1,
  80. CreateId: createid,
  81. Ctime: time.Now().Unix(),
  82. Mtime: time.Now().Unix(),
  83. TrialStatus: trial_status,
  84. Remarks: remarks,
  85. }
  86. err = AddDepositHistory(dehistory)
  87. if err != nil {
  88. utils.ErrorLog("添加用户押金历史记录失败: %v", err.Error())
  89. }
  90. return
  91. }
  92. //添加押金记录
  93. func AddDepositHistory(dh models.DepositHistory) error {
  94. err := XTWriteDB().Create(&dh).Error
  95. return err
  96. }
  97. //押金中添加一条记录,并返回该数据的id和押金余额(当没有该用户记录时调用)
  98. func AddDeposit(de models.Deposit) (int64, decimal.Decimal, error) {
  99. var tmp models.Deposit
  100. err := XTWriteDB().Create(&de).Find(&tmp).Error
  101. if err != nil {
  102. return 0, decimal.NewFromFloat(0.00), err
  103. }
  104. return tmp.ID, tmp.Deposit, err
  105. }
  106. //更改押金记录
  107. func UpdateDeposit(de models.Deposit) (err error) {
  108. err = XTWriteDB().Model(&models.Deposit{}).Where("id = ? and status = 1", de.ID).Updates(map[string]interface{}{
  109. "mtime": de.Mtime,
  110. "deposit": de.Deposit,
  111. }).Error
  112. return
  113. }
  114. //判断押金表是否存在当前的患者的一条有效数据,如果有返回id和押金余额,没有返回0
  115. func IsHisPatientId(his_patient_id, orgid int64) (int64, decimal.Decimal) {
  116. var tmp []models.Deposit
  117. XTReadDB().Model(&models.Deposit{}).Where("user_org_id = ? and his_patient_id = ? and status = 1", orgid, his_patient_id).Find(&tmp)
  118. if len(tmp) != 1 {
  119. return 0, decimal.NewFromFloat(0.00)
  120. }
  121. return tmp[0].ID, tmp[0].Deposit
  122. }
  123. //查询押金编号是否重复
  124. func FindDecimalCode(orgid int64, code string) bool {
  125. var total int
  126. XTReadDB().Model(&models.DepositHistory{}).Where("user_org_id = ? and deposit_code = ? and status = 1", orgid, code).Count(&total)
  127. if total > 0 {
  128. return true
  129. } else {
  130. return false
  131. }
  132. }
  133. //充值明细列表
  134. func DetailsList(orgid, stime, etime int64, keyword string, slicekey []int64) (deposithistory []models.DepositHistoryname, err error) {
  135. db := XTReadDB().Model(&models.DepositHistory{}).Where("status = 1 and user_org_id = ? and deposit_status = 1 ", orgid).Where("ctime >= ? and ctime <= ?", stime, etime)
  136. if len(keyword) > 0 {
  137. var tmp string = "deposit_code like ?"
  138. if len(slicekey) > 0 {
  139. for i := 0; i < len(slicekey); i++ {
  140. tmp = tmp + " or his_patient_id = " + strconv.FormatInt(slicekey[i], 10)
  141. }
  142. }
  143. keyword = "%" + keyword + "%"
  144. db = db.Where(tmp, keyword)
  145. }
  146. err = db.Order("ctime desc").Find(&deposithistory).Error
  147. return
  148. }
  149. //充值汇总列表
  150. func SummaryList(orgid, stime, etime int64, keyword string, slicekey []int64) (deposithistory []models.DepositHistory, err error) {
  151. db := XTReadDB().Model(&models.DepositHistory{}).Where("status = 1 and trial_status = 1 and user_org_id = ? and deposit_status = 1 ", orgid).Where("ctime >= ? and ctime <= ?", stime, etime)
  152. if len(slicekey) > 0 {
  153. tmp := ""
  154. for i := 0; i < len(slicekey); i++ {
  155. tmp = tmp + " his_patient_id = " + strconv.FormatInt(slicekey[i], 10)
  156. if i < len(slicekey)-1 {
  157. tmp = tmp + " or "
  158. }
  159. }
  160. db = db.Where(tmp)
  161. } else {
  162. if len(keyword) > 0 {
  163. return
  164. }
  165. }
  166. err = db.Order("ctime desc").Find(&deposithistory).Error
  167. return
  168. }
  169. //获取本周周一和周日的起止时间戳
  170. func GetMondayOfWeek() (int64, int64) {
  171. t := time.Now()
  172. dayObj := GetZeroTime(t)
  173. var dayStr string
  174. loc, _ := time.LoadLocation("Local")
  175. if t.Weekday() == time.Monday {
  176. dayStr = dayObj.Format("2006-01-02")
  177. } else {
  178. offset := int(time.Monday - t.Weekday())
  179. if offset > 0 {
  180. offset = -6
  181. }
  182. dayStr = dayObj.AddDate(0, 0, offset).Format("2006-01-02")
  183. }
  184. dayStr = dayStr + " 00:00:00"
  185. stime, _ := time.ParseInLocation("2006-01-02 15:04:05", dayStr, loc)
  186. return stime.Unix(), stime.Unix() + 604799
  187. }
  188. //获取本月的起止时间戳
  189. func GetMonth() (int64, int64) {
  190. timeNow := time.Now()
  191. timeToday := time.Date(timeNow.Year(), timeNow.Month(), timeNow.Day(), 0, 0, 0, 0, timeNow.Location()) // 获取当天0点时间 time类型
  192. timeMonthStartUnix1 := timeToday.AddDate(0, 0, -timeToday.Day()+1).Unix() // 获取本月第一天0点 时间戳类型
  193. timeMonthEndUnix1 := timeToday.AddDate(0, 1, -timeToday.Day()+1).Unix() - 1 // 获取下个月第一天/ 本月最后一天24点 时间戳类型
  194. return timeMonthStartUnix1, timeMonthEndUnix1
  195. }
  196. //获取创建者的姓名
  197. func GetCreateidName(id int64) string {
  198. var tmp models.CreateUser
  199. XTReadDB().Select("name").Where("id = ?", id).Find(&tmp)
  200. return tmp.Name
  201. }
  202. //审核通过
  203. func UpDecimalHistory(id int64) (err error) {
  204. //开事务
  205. tx := XTWriteDB().Begin()
  206. defer func() {
  207. if err != nil {
  208. utils.ErrorLog("事务失败,原因为: %v", err)
  209. tx.Rollback()
  210. } else {
  211. tx.Commit()
  212. }
  213. }()
  214. //查记录x2
  215. var history models.DepositHistory
  216. var detmp models.Deposit
  217. err = tx.Model(&models.DepositHistory{}).Where("id = ?", id).Find(&history).Error
  218. if err != nil {
  219. return
  220. }
  221. err = tx.Model(&models.Deposit{}).Where("user_org_id = ? and his_patient_id = ? and status = 1 ", history.UserOrgId, history.HisPatientId).Find(&detmp).Error
  222. if err != nil {
  223. return
  224. }
  225. //改状态,=====剩余押金
  226. err = tx.Model(models.DepositHistory{}).Where("id = ?", id).Updates(map[string]interface{}{
  227. "trial_status": 1,
  228. "surplus_deposit": detmp.Deposit.Add(history.Deposit),
  229. "mtime": time.Now().Unix(),
  230. }).Error
  231. if err != nil {
  232. return
  233. }
  234. //相加
  235. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", detmp.ID).Updates(map[string]interface{}{
  236. "mtime": time.Now().Unix(),
  237. "deposit": detmp.Deposit.Add(history.Deposit),
  238. }).Error
  239. return
  240. }
  241. //删除本次记录
  242. func DelDecimalHistory(id int64) (err error) {
  243. err = XTWriteDB().Model(models.DepositHistory{}).Where("id = ?", id).Updates(map[string]interface{}{
  244. "status": 0,
  245. "mtime": time.Now().Unix(),
  246. }).Error
  247. return
  248. }
  249. //根据id获取一条押金历史记录
  250. func GetDecimalHistoryOne(id int64) (history models.DepositHistory, err error) {
  251. err = XTReadDB().Model(&models.DepositHistory{}).Where("id = ?", id).Find(&history).Error
  252. return
  253. }
  254. //根据患者id获取该患者当前剩余的押金
  255. func GetUserMoney(id, orgid int64) decimal.Decimal {
  256. tmp := models.Deposit{}
  257. err := XTReadDB().Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", id, orgid).Find(&tmp).Error
  258. if err != nil {
  259. return decimal.NewFromFloat(0)
  260. }
  261. return tmp.Deposit
  262. }
  263. //查询时间段内患者的余额
  264. func GetMoneyforTime(id, orgid, etime int64) decimal.Decimal {
  265. tmp := models.DepositHistory{}
  266. XTReadDB().Model(&models.DepositHistory{}).Where("his_patient_id = ? and user_org_id = ? and status = 1 and mtime <= ?", id, orgid, etime).Order("mtime").Find(&tmp)
  267. return tmp.SurplusDeposit
  268. }
  269. //押金流水
  270. func GetFlowList(page, limit, id, orgid, stime, etime, deposit_status int64) (deposit []models.DepositHistory, total int64, err error) {
  271. s := "status = 1 and trial_status = 1 and user_org_id = ? and his_patient_id = ? and mtime >= ? and mtime <= ?"
  272. offset := (page - 1) * limit
  273. if deposit_status != 0 {
  274. s = s + " and deposit_status = " + strconv.FormatInt(deposit_status, 10)
  275. }
  276. err = XTReadDB().Model(&models.DepositHistory{}).Where(s, orgid, id, stime, etime).Count(&total).Offset(offset).Order("mtime desc").Limit(limit).Find(&deposit).Error
  277. return
  278. }
  279. //获取患者押金列表
  280. func GetUserList(page, limit, orgid int64, keyword string, slicekey []int64) (m []models.Deposit1, total int64, err error) {
  281. db := XTReadDB().Model(&models.Deposit{}).Where("status = 1 and user_org_id = ? ", orgid)
  282. offset := (page - 1) * limit
  283. if len(keyword) > 0 {
  284. db = db.Where(" his_patient_id = ? ", keyword)
  285. }
  286. err = db.Count(&total).Offset(offset).Order("mtime desc").Limit(limit).Find(&m).Error
  287. return
  288. }
  289. //扣费明细列表
  290. func DeductionList(orgid, stime, etime int64, keyword string, slicekey []int64) (deposithistory []models.DepositHistory, err error) {
  291. db := XTReadDB().Model(&models.DepositHistory{}).Where("status = 1 and user_org_id = ? and deposit_status = 2 ", orgid).Where("ctime >= ? and ctime <= ?", stime, etime)
  292. if len(keyword) > 0 {
  293. var tmp string = "deposit_code like ?"
  294. if len(slicekey) > 0 {
  295. for i := 0; i < len(slicekey); i++ {
  296. tmp = tmp + " or his_patient_id = " + strconv.FormatInt(slicekey[i], 10)
  297. }
  298. }
  299. keyword = "%" + keyword + "%"
  300. db = db.Where(tmp, keyword)
  301. }
  302. err = db.Order("ctime desc").Find(&deposithistory).Error
  303. return
  304. }
  305. //获取医疗费总额
  306. func MedicalTotal(orgid, id int64) decimal.Decimal {
  307. tmp := models.HisChargeSettleOrder{}
  308. //and status = 1 and order_status = 2
  309. XTReadDB().Model(&models.HisChargeSettleOrder{}).Where("id = ? and user_org_id = ? ", id, orgid).Find(&tmp)
  310. return decimal.NewFromFloat(tmp.MedfeeSumamt)
  311. }
  312. //根据就诊号查询出医收费类型
  313. func CodeToChargetype(orgid int64, code string) (s string) {
  314. tmp := models.HisPrintPatient{}
  315. tmp_hhcr := models.HisHospitalCheckRecordTwo{}
  316. XTReadDB().Model(&models.HisPrintPatient{}).Where("number = ? and user_org_id = ?", code, orgid).Find(&tmp)
  317. //tmp.BalanceAccountsType
  318. if tmp.BalanceAccountsType == 0 {
  319. XTReadDB().Model(&models.HisHospitalCheckRecordTwo{}).Where("number = ? and user_org_id = ?", code, orgid).Find(&tmp_hhcr)
  320. tmp.BalanceAccountsType = tmp_hhcr.BalanceAccountsType
  321. }
  322. switch tmp.BalanceAccountsType {
  323. case 1:
  324. s = "医保"
  325. case 2:
  326. s = "自费"
  327. case 3:
  328. s = "公费"
  329. case 4:
  330. s = "农保"
  331. case 5:
  332. s = "会员"
  333. case 6:
  334. s = "职工"
  335. case 7:
  336. s = "合同"
  337. case 8:
  338. s = "医保自费"
  339. default:
  340. s = "类型未定义"
  341. }
  342. return
  343. }
  344. //扣除患者的押金,并生成一条扣费历史记录
  345. //orgid 机构id;
  346. //his_user_id 患者id;
  347. //create_id 创建者id;
  348. //code 就诊号;
  349. //deposit 本次使用的押金金额,支持float64、int、int64、decimal.Decimal类型
  350. func SpendDeposit(orgid, his_user_id, create_id int64, code string, deposit interface{}) (err error) {
  351. tmp_deposit := decimal.Decimal{} //本次患者使用的押金
  352. tmp_deposit, err = ToDecimal(deposit)
  353. if err != nil {
  354. return
  355. }
  356. //开事务
  357. tx := XTWriteDB().Begin()
  358. defer func() {
  359. if err != nil {
  360. utils.ErrorLog("事务失败,原因为: %v", err.Error())
  361. tx.Rollback()
  362. } else {
  363. tx.Commit()
  364. }
  365. }()
  366. //查询患者押金
  367. tmp := models.Deposit{}
  368. err = tx.Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", his_user_id, orgid).Find(&tmp).Error
  369. if err != nil {
  370. err = fmt.Errorf("押金余额不足")
  371. return
  372. }
  373. //判断能否扣除
  374. if tmp.Deposit.Cmp(tmp_deposit) == -1 {
  375. err = fmt.Errorf("押金余额不足")
  376. return
  377. }
  378. //扣除患者押金
  379. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", tmp.ID).Updates(map[string]interface{}{
  380. "mtime": time.Now().Unix(),
  381. "deposit": tmp.Deposit.Sub(tmp_deposit),
  382. }).Error
  383. if err != nil {
  384. return
  385. }
  386. //生成一条历史记录
  387. dehistory := models.DepositHistory{
  388. UserOrgId: orgid,
  389. HisPatientId: his_user_id,
  390. DepositCode: code,
  391. Deposit: tmp_deposit,
  392. SurplusDeposit: tmp.Deposit.Sub(tmp_deposit),
  393. DepositStatus: 2,
  394. Status: 1,
  395. CreateId: create_id,
  396. Ctime: time.Now().Unix(),
  397. Mtime: time.Now().Unix(),
  398. TrialStatus: 1,
  399. }
  400. err = tx.Create(&dehistory).Error
  401. return
  402. }
  403. //新增一条退款申请
  404. func RefundApplication(orgid, his_patient_id, trial_status, createid int64, code string, deposit decimal.Decimal) (err error) {
  405. //开事务
  406. tx := XTWriteDB().Begin()
  407. defer func() {
  408. if err != nil {
  409. utils.ErrorLog("事务失败,原因为: %v", err.Error())
  410. tx.Rollback()
  411. } else {
  412. tx.Commit()
  413. }
  414. }()
  415. //获取患者当前余额
  416. tmp := models.Deposit{}
  417. err = tx.Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", his_patient_id, orgid).Find(&tmp).Error
  418. if err != nil {
  419. if err.Error() == "record not found" {
  420. err = fmt.Errorf("没有可退押金,保存失败")
  421. }
  422. return
  423. }
  424. //判断是否可以退款
  425. if tmp.Deposit.Cmp(deposit) == -1 {
  426. err = fmt.Errorf("退款金额不得大于押金余额!")
  427. return
  428. }
  429. s_deposit := tmp.Deposit
  430. //判断是否审核通过,通过更新当前押金,否则只新增一条历史记录
  431. if trial_status == 1 {
  432. //更新患者当前押金余额
  433. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", tmp.ID).Updates(map[string]interface{}{
  434. "mtime": time.Now().Unix(),
  435. "deposit": tmp.Deposit.Sub(deposit),
  436. }).Error
  437. if err != nil {
  438. return
  439. }
  440. s_deposit = tmp.Deposit.Sub(deposit)
  441. }
  442. //生成一条历史记录
  443. dehistory := models.DepositHistory{
  444. UserOrgId: orgid,
  445. HisPatientId: his_patient_id,
  446. DepositCode: code,
  447. Deposit: deposit,
  448. SurplusDeposit: s_deposit,
  449. DepositStatus: 3, //3退款,4退费
  450. Status: 1,
  451. CreateId: createid,
  452. Ctime: time.Now().Unix(),
  453. Mtime: time.Now().Unix(),
  454. TrialStatus: trial_status,
  455. }
  456. err = tx.Create(&dehistory).Error
  457. return
  458. }
  459. //退款审核通过/拒绝批量处理
  460. func RefundReviewMore(orgid, trial_status int64, ids string) (err error) {
  461. //处理下字符串
  462. t_ids := ""
  463. if ids[len(ids)-1] == 44 {
  464. t_ids = ids[:len(ids)-1]
  465. } else {
  466. t_ids = ids
  467. }
  468. tmp_id := strings.Split(t_ids, ",")
  469. //开事务
  470. tx := XTWriteDB().Begin()
  471. defer func() {
  472. if err != nil {
  473. utils.ErrorLog("事务失败,原因为: %v", err.Error())
  474. tx.Rollback()
  475. } else {
  476. tx.Commit()
  477. }
  478. }()
  479. //循环处理id
  480. for i := 0; i < len(tmp_id); i++ {
  481. var id int64
  482. id, err = strconv.ParseInt(tmp_id[i], 10, 64)
  483. if err != nil {
  484. return err
  485. }
  486. err = RefundReview(orgid, id, trial_status, tx)
  487. if err != nil {
  488. return err
  489. }
  490. }
  491. return err
  492. }
  493. //退款审核通过/拒绝
  494. func RefundReview(orgid, id, trial_status int64, tx *gorm.DB) (err error) {
  495. //根据id查询该条历史记录
  496. history := models.DepositHistory{}
  497. err = tx.Model(&models.DepositHistory{}).Where("id = ? and status = 1", id).Find(&history).Error
  498. if err != nil {
  499. return err
  500. }
  501. //判断状态是否为未审核
  502. if history.TrialStatus != 0 {
  503. err = fmt.Errorf("所选单据中包含了无需审核的单据")
  504. return err
  505. }
  506. //判断类型是否为3,3代表退款,4为退费
  507. if history.DepositStatus != 3 {
  508. err = fmt.Errorf("所选单据中包含了无需审核的单据")
  509. return err
  510. }
  511. up := make(map[string]interface{})
  512. //通过
  513. if trial_status == 1 {
  514. //拿患者的id和机构id在去查患者的余额
  515. tt := models.Deposit{}
  516. err = tx.Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", history.HisPatientId, orgid).Find(&tt).Error
  517. if err != nil {
  518. return err
  519. }
  520. //判断是否可以修改患者押金
  521. if tt.Deposit.Cmp(history.Deposit) == -1 {
  522. err = fmt.Errorf("当前押金余额小于退款金额,无法完成退款")
  523. return err
  524. }
  525. //修改患者押金
  526. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", tt.ID).Updates(map[string]interface{}{
  527. "mtime": time.Now().Unix(),
  528. "deposit": tt.Deposit.Sub(history.Deposit),
  529. }).Error
  530. if err != nil {
  531. return err
  532. }
  533. up = map[string]interface{}{
  534. "mtime": time.Now().Unix(),
  535. "surplus_deposit": tt.Deposit.Sub(history.Deposit),
  536. "trial_status": 1,
  537. }
  538. } else {
  539. up = map[string]interface{}{
  540. "mtime": time.Now().Unix(),
  541. "trial_status": 2,
  542. }
  543. }
  544. //修改一条历史记录
  545. err = tx.Model(&models.DepositHistory{}).Where("id = ? and status = 1", id).Updates(up).Error
  546. return err
  547. }
  548. //退款删除
  549. func DeleteRefund(orgid, id int64) (err error) {
  550. //根据id查询历史记录
  551. history := models.DepositHistory{}
  552. err = XTReadDB().Model(&models.DepositHistory{}).Where("id = ?", id).Find(&history).Error
  553. if err != nil {
  554. return
  555. }
  556. //判断是否可以删除
  557. if history.TrialStatus == 1 || history.DepositStatus != 3 {
  558. err = fmt.Errorf("当前状态不可删除!")
  559. return
  560. }
  561. //删除
  562. err = XTWriteDB().Model(&models.DepositHistory{}).Where("id = ?", id).Updates(map[string]interface{}{
  563. "mtime": time.Now().Unix(),
  564. "status": 0,
  565. }).Error
  566. return
  567. }
  568. //更改退款申请
  569. func ChangeRefund(orgid, his_patient_id, trial_status, id int64, code string, deposit decimal.Decimal) (err error) {
  570. //开事务
  571. tx := XTWriteDB().Begin()
  572. defer func() {
  573. if err != nil {
  574. utils.ErrorLog("事务失败,原因为: %v", err.Error())
  575. tx.Rollback()
  576. } else {
  577. tx.Commit()
  578. }
  579. }()
  580. //获取患者当前余额
  581. tmp := models.Deposit{}
  582. err = tx.Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", his_patient_id, orgid).Find(&tmp).Error
  583. if err != nil {
  584. return
  585. }
  586. //判断是否可以退款
  587. if tmp.Deposit.Cmp(deposit) == -1 {
  588. err = fmt.Errorf("退款金额不得大于押金余额!")
  589. return
  590. }
  591. up := make(map[string]interface{})
  592. //判断是否审核通过,通过更新当前押金,否则只新增一条历史记录
  593. if trial_status == 1 {
  594. //更新患者当前押金余额
  595. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", tmp.ID).Updates(map[string]interface{}{
  596. "mtime": time.Now().Unix(),
  597. "deposit": tmp.Deposit.Sub(deposit),
  598. }).Error
  599. if err != nil {
  600. return
  601. }
  602. up = map[string]interface{}{
  603. "mtime": time.Now().Unix(),
  604. "deposit_code": code,
  605. "his_patient_id": his_patient_id,
  606. "surplus_deposit": tmp.Deposit.Sub(deposit),
  607. "deposit": deposit,
  608. "trial_status": trial_status,
  609. }
  610. } else {
  611. up = map[string]interface{}{
  612. "mtime": time.Now().Unix(),
  613. "deposit_code": code,
  614. "his_patient_id": his_patient_id,
  615. "deposit": deposit,
  616. "trial_status": trial_status,
  617. }
  618. }
  619. //更新一条历史记录
  620. err = tx.Model(&models.DepositHistory{}).Where("id = ? and status = 1", id).Updates(up).Error
  621. return
  622. }
  623. //退款分页
  624. func RefundList(page, limit, orgid, stime, etime, refundtype, examinetype int64, keyword string, slicekey []int64) (depo []models.RefundList, total int64, err error) {
  625. db := XTReadDB().Model(&models.DepositHistory{}).Where("status = 1 and user_org_id = ? ", orgid).Where("ctime >= ? and ctime <= ?", stime, etime)
  626. offset := (page - 1) * limit
  627. //退款类型
  628. switch refundtype {
  629. case 0:
  630. db = db.Where(" deposit_status in (3,4) ")
  631. case 3, 4:
  632. db = db.Where(" deposit_status = ? ", refundtype)
  633. default:
  634. err = fmt.Errorf("退款类型错误")
  635. return
  636. }
  637. //审核状态
  638. switch examinetype {
  639. case 0, 1, 2:
  640. db = db.Where(" trial_status = ? ", examinetype)
  641. case 3: //代表查询全部
  642. db = db
  643. default:
  644. err = fmt.Errorf("审核状态错误")
  645. return
  646. }
  647. if len(keyword) > 0 {
  648. tmp := "deposit_code like ? "
  649. if len(slicekey) > 0 {
  650. for i := 0; i < len(slicekey); i++ {
  651. tmp = tmp + " or his_patient_id = " + strconv.FormatInt(slicekey[i], 10)
  652. }
  653. }
  654. keyword = "%" + keyword + "%"
  655. db = db.Where(tmp, keyword)
  656. }
  657. err = db.Count(&total).Offset(offset).Order("ctime desc").Limit(limit).Find(&depo).Error
  658. return
  659. }
  660. //退回患者的押金,并生成一条退费历史记录
  661. //orgid 机构id
  662. //his_user_id 患者id
  663. //code 编号
  664. //deposit 本次退费的金额,支持float64、int、int64、decimal.Decimal类型
  665. func MoneyIncrease(orgid, his_user_id int64, code string, deposit interface{}) (err error) {
  666. tmp_deposit := decimal.Decimal{}
  667. tmp_deposit, err = ToDecimal(deposit)
  668. if err != nil {
  669. return
  670. }
  671. //开事务
  672. tx := XTWriteDB().Begin()
  673. defer func() {
  674. if err != nil {
  675. utils.ErrorLog("事务失败,原因为: %v", err.Error())
  676. tx.Rollback()
  677. } else {
  678. tx.Commit()
  679. }
  680. }()
  681. //获取当前患者押金
  682. tmp := models.Deposit{}
  683. err = tx.Model(&models.Deposit{}).Where("his_patient_id = ? and user_org_id = ? and status = 1", his_user_id, orgid).Find(&tmp).Error
  684. if err != nil {
  685. return
  686. }
  687. //退回患者押金
  688. err = tx.Model(&models.Deposit{}).Where("id = ? and status = 1", tmp.ID).Updates(map[string]interface{}{
  689. "mtime": time.Now().Unix(),
  690. "deposit": tmp.Deposit.Add(tmp_deposit),
  691. }).Error
  692. if err != nil {
  693. return
  694. }
  695. //生成一条退费记录
  696. dehistory := models.DepositHistory{
  697. UserOrgId: orgid,
  698. HisPatientId: his_user_id,
  699. DepositCode: code,
  700. Deposit: tmp_deposit,
  701. SurplusDeposit: tmp.Deposit.Add(tmp_deposit),
  702. DepositStatus: 4,
  703. Status: 1,
  704. CreateId: 0,
  705. Ctime: time.Now().Unix(),
  706. Mtime: time.Now().Unix(),
  707. TrialStatus: 1,
  708. }
  709. err = tx.Create(&dehistory).Error
  710. return
  711. }
  712. func GetorgName(orgid int64) (name string) {
  713. tmp := models.GetorgName{}
  714. XTReadDB().Model(&models.GetorgName{}).Where("id = ? ", orgid).Find(&tmp)
  715. return tmp.OrgName
  716. }
  717. //根据id查询就诊号
  718. func FindcodeToid(id int64) (code string) {
  719. tmp := models.GetMdtrtId{}
  720. XTReadDB().Model(&models.GetMdtrtId{}).Where("id = ?", id).Find(&tmp)
  721. return tmp.MdtrtId
  722. }
  723. //根据id查询就诊号
  724. func FindnumberToid(id int64) (number string) {
  725. tmp := models.GetMdtrtId{}
  726. XTReadDB().Model(&models.GetMdtrtId{}).Where("id = ?", id).Find(&tmp)
  727. return tmp.Number
  728. }
  729. //扣费明细列表,查看详情按钮是否显示,0隐藏,1显示
  730. func IsButtonShow(code string, orgid, his_patient_id int64) (tmp int64) {
  731. var total int
  732. XTReadDB().Model(&models.RefundList{}).Where(" user_org_id = ? and his_patient_id = ? and deposit_code = ? and deposit_status = 4 and status = 1", orgid, his_patient_id, code).Count(&total)
  733. if total == 0 {
  734. return 1
  735. } else {
  736. //预防万一,多加一个验证
  737. if total%2 == 0 {
  738. return 1
  739. } else {
  740. return 0
  741. }
  742. }
  743. }
  744. //把其他的类型转换成decimal.Decimal类型
  745. func ToDecimal(i interface{}) (d decimal.Decimal, err error) {
  746. switch i.(type) {
  747. case float64:
  748. d = decimal.NewFromFloat(i.(float64))
  749. case decimal.Decimal:
  750. d = i.(decimal.Decimal)
  751. case int64:
  752. d = decimal.NewFromFloat(float64(i.(int64)))
  753. case int:
  754. d = decimal.NewFromFloat(float64(i.(int)))
  755. default:
  756. err = fmt.Errorf("类型解析错误")
  757. }
  758. return
  759. }
  760. func TypeConversion(tmp float64) (s string) {
  761. switch tmp {
  762. case 1:
  763. s = "g"
  764. case 2:
  765. s = "mg"
  766. case 3:
  767. s = "u"
  768. case 4:
  769. s = "ml"
  770. case 5:
  771. s = "万U"
  772. case 6:
  773. s = "枚"
  774. case 7:
  775. s = "粒"
  776. case 8:
  777. s = "片"
  778. case 9:
  779. s = "支"
  780. case 10:
  781. s = "μg"
  782. case 11:
  783. s = "iu"
  784. case 12:
  785. s = "包"
  786. case 13:
  787. s = "袋"
  788. case 14:
  789. s = "万"
  790. case 15:
  791. s = "万iu"
  792. case 16:
  793. s = "丸"
  794. case 17:
  795. s = "盒"
  796. case 18:
  797. s = "瓶"
  798. case 19:
  799. s = "瓶(袋)"
  800. case 20:
  801. s = "次"
  802. }
  803. return s
  804. }
  805. func TypeConversion02(tmp string) (s string) {
  806. switch tmp {
  807. case "1":
  808. s = "g"
  809. case "2":
  810. s = "mg"
  811. case "3":
  812. s = "u"
  813. case "4":
  814. s = "ml"
  815. case "5":
  816. s = "万U"
  817. case "6":
  818. s = "枚"
  819. case "7":
  820. s = "粒"
  821. case "8":
  822. s = "片"
  823. case "9":
  824. s = "支"
  825. case "10":
  826. s = "μg"
  827. case "11":
  828. s = "iu"
  829. case "12":
  830. s = "包"
  831. case "13":
  832. s = "袋"
  833. case "14":
  834. s = "万"
  835. case "15":
  836. s = "万iu"
  837. case "16":
  838. s = "丸"
  839. case "17":
  840. s = "盒"
  841. case "18":
  842. s = "瓶"
  843. case "19":
  844. s = "瓶(袋)"
  845. case "20":
  846. s = "次"
  847. default:
  848. s = tmp
  849. }
  850. return s
  851. }