package Reimburse import ( "ERP_salary/logs" "ERP_salary/models/Account" "fmt" "github.com/beego/beego/v2/adapter/orm" orm2 "github.com/beego/beego/v2/client/orm" "gogs.baozhida.cn/zoie/ERP_libs/lib" "strconv" "strings" "time" ) const ( Delete int = iota WaitSubmit // 待提交审核 WaitAudit // 待审核 AuditPass // 审核通过 AuditUnPass // 审核不通过 RemitPart // 部分打款 RemitAll // 全部打款 ) var ( AuditMap = map[int]string{ WaitSubmit: "待提交审核", WaitAudit: "待审核", AuditPass: "审核通过", AuditUnPass: "审核不通过", RemitPart: "部分打款", RemitAll: "全部打款", } ) func Read_Audit_Get(Id int) string { v, ok := AuditMap[Id] if ok { return v } else { return "未知状态" } } // 报销 type Reimburse struct { Id int `orm:"column(ID);size(11);auto;pk"` T_uid string `orm:"index;size(64);null"` // 用户uuid T_date string `orm:"size(64);null"` // 提交日期,2023-08-11 T_money float32 `orm:"digits(12);decimals(2)"` // 报销总金额 T_remit float32 `orm:"digits(12);decimals(2)"` // 打款金额 T_State int `orm:"size(20);default(1)"` // 0 删除 1 未提交审核 2 待审核 3 审核通过 4 审核不通过 5 已部分打款 6 已全部打款 T_remit_detials string `orm:"size(1024)"` // 打款明细 日期,打款金额|日期,打款金额| T_approval_money float32 `orm:"digits(12);decimals(2)"` // 审批金额 CreateTime time.Time `orm:"column(create_time);type(timestamp);null;auto_now_add"` //auto_now_add 第一次保存时才设置时间 UpdateTime time.Time `orm:"column(update_time);type(timestamp);null;auto_now"` //auto_now 每次 model 保存时都会对时间自动更新 } func (t *Reimburse) TableName() string { return "reimburse" } type ReimburseDaoImpl struct { orm orm.Ormer } func NewReimburse(orm orm.Ormer) *ReimburseDaoImpl { return &ReimburseDaoImpl{orm: orm} } func init() { //注册模型 orm.Debug = true orm.RegisterModel(new(Reimburse)) } type Reimburse_R struct { Id int T_uid string // 用户uuid T_user_name string // 用户名称 T_date string // 提交日期,2023-08-11 T_money float32 // 报销总金额 T_remit float32 // 打款金额 T_approval_money float32 // 审批金额 T_State int // 0 删除 1 未提交审核 2 待审核 3 审核通过 4 审核不通过 5 已部分打款 6 已全部打款 } type RemitDetail_R struct { T_time string // 打款时间 T_money float32 // 打款金额 } type Reimburse_Detail struct { Id int T_uid string // 用户uuid T_user_name string // 用户名称 T_date string // 提交日期,2023-08-11 T_money float32 // 报销总金额 T_remit float32 // 打款金额 T_State int // 0 删除 1 未提交审核 2 待审核 3 审核通过 4 审核不通过 5 已部分打款 6 已全部打款 T_approval_money float32 // 审批金额 T_approval_opinion string // 审批意见 T_reimburse_details []ReimburseDetails_R // 报销明细 T_remit_detail []RemitDetail_R // 打款明细 } // ---------------- 特殊方法 ------------------- func ReimburseToReimburse_R(t Reimburse) (r Reimburse_R) { r.Id = t.Id r.T_uid = t.T_uid r.T_user_name = Account.Read_User_T_name_Get(t.T_uid) r.T_date = t.T_date r.T_money = t.T_money r.T_remit = t.T_remit r.T_State = t.T_State r.T_approval_money = t.T_approval_money return r } func ReimburseToReimburse_Detail(t Reimburse, T_reimburse_details []ReimburseDetails_R) (r Reimburse_Detail) { r.Id = t.Id r.T_uid = t.T_uid r.T_user_name = Account.Read_User_T_name_Get(t.T_uid) r.T_date = t.T_date r.T_money = t.T_money r.T_remit = t.T_remit r.T_State = t.T_State r.T_approval_money = t.T_approval_money r.T_reimburse_details = T_reimburse_details r.T_remit_detail = ReimburseToRemitDetail(t.T_remit_detials) return r } func ReimburseToRemitDetail(T_detail string) (r []RemitDetail_R) { if len(T_detail) == 0 { return } detailList := strings.Split(strings.Trim(T_detail, "|"), "|") for _, detail := range detailList { T_time := strings.Split(detail, ",")[0] T_money := lib.StringToFloat64TwoDecimal(strings.Split(detail, ",")[1]) r = append(r, RemitDetail_R{ T_time: T_time, T_money: float32(T_money), }) } return r } func (dao *ReimburseDaoImpl) Read_Reimburse_ById(id int) (r Reimburse, err error) { o := orm.NewOrm() r = Reimburse{Id: id} err = o.Read(&r) if err != nil { logs.Error(lib.FuncName(), err) return r, err } return r, err } // 添加 func (dao *ReimburseDaoImpl) Add_Reimburse(m Reimburse) (id int64, err error) { o := orm.NewOrm() id, err = o.Insert(&m) if err != nil { logs.Error(lib.FuncName(), err) return } return } // 修改 func (dao *ReimburseDaoImpl) Update_Reimburse(m Reimburse, cols ...string) (id int64, err error) { o := orm.NewOrm() id, err = o.Update(&m, cols...) if err != nil { logs.Error(lib.FuncName(), err) return } fmt.Println("Number of records updated in database:", id) return id, nil } // 删除 func (dao *ReimburseDaoImpl) Delete_Reimburse(m Reimburse) (id int64, err error) { o := orm.NewOrm() m.T_State = Delete id, err = o.Update(&m, "T_State") if err != nil { logs.Error(lib.FuncName(), err) return } fmt.Println("Number of records updated in database:", id) return id, nil } // 获取列表 func (dao *ReimburseDaoImpl) Read_Reimburse_List(T_uid string, page, page_z int) (r []Reimburse_R, cnt int64) { o := orm.NewOrm() // 也可以直接使用 Model 结构体作为表名 var map_r []Reimburse qs := o.QueryTable(new(Reimburse)) var offset int64 if page <= 1 { offset = 0 } else { offset = int64((page - 1) * page_z) } cond := orm.NewCondition() cond = cond.And("T_State__gt", Delete) if len(T_uid) > 0 { cond = cond.And("T_uid", T_uid) } var err error _, err = qs.Limit(page_z, offset).SetCond((*orm2.Condition)(cond)).OrderBy("-Id").All(&map_r) if err != nil { logs.Error(lib.FuncName(), err) return } cnt, err = qs.SetCond((*orm2.Condition)(cond)).Count() if err != nil { logs.Error(lib.FuncName(), err) return } for _, v := range map_r { r = append(r, ReimburseToReimburse_R(v)) } return r, cnt } // 获取列表 func (dao *ReimburseDaoImpl) Read_Reimburse_Finance_List(T_uuid string, page, page_z int) (r []Reimburse_R, cnt int64) { o := orm.NewOrm() // 也可以直接使用 Model 结构体作为表名 var map_r []Reimburse qs := o.QueryTable(new(Reimburse)) var offset int64 if page <= 1 { offset = 0 } else { offset = int64((page - 1) * page_z) } cond := orm.NewCondition() state := []int{WaitAudit, AuditPass, AuditUnPass, RemitPart, RemitAll} cond = cond.And("T_uid", T_uuid).And("T_State__in", state) var err error _, err = qs.Limit(page_z, offset).SetCond((*orm2.Condition)(cond)).OrderBy("-Id").All(&map_r) if err != nil { logs.Error(lib.FuncName(), err) return } cnt, err = qs.SetCond((*orm2.Condition)(cond)).Count() if err != nil { logs.Error(lib.FuncName(), err) return } for _, v := range map_r { r = append(r, ReimburseToReimburse_R(v)) } return r, cnt } func (dao *ReimburseDaoImpl) Read_T_uuid_List_by_State(state int) (lists []string) { o := orm.NewOrm() sql := "SELECT DISTINCT t_uid FROM reimburse WHERE t__state =" + strconv.Itoa(state) + " LIMIT 0,1000" _, err := o.Raw(sql).QueryRows(&lists) if err != nil { logs.Error(lib.FuncName(), err) return } return lists } func (dao *ReimburseDaoImpl) Read_T_uuid_List() (lists []string) { o := orm.NewOrm() sql := "SELECT DISTINCT t_uid FROM reimburse LIMIT 0,1000" _, err := o.Raw(sql).QueryRows(&lists) if err != nil { logs.Error(lib.FuncName(), err) return } return lists }