|
|
@@ -2082,3 +2082,67 @@ func (r *GThjinvesotrdeposit) GetDataByPage() (interface{}, error, int, int, int
|
|
|
}
|
|
|
return sData, err, r.Page, r.PageSize, total
|
|
|
}
|
|
|
+
|
|
|
+type QueryMyDepositReq struct {
|
|
|
+ UserId int64 `form:"userId" binding:"required"` // 用户ID
|
|
|
+}
|
|
|
+
|
|
|
+func (r *Thjinvesotrdeposit) GetAll(req QueryMyDepositReq) (rsp []Thjinvesotrdeposit, err error) {
|
|
|
+ rsp = make([]Thjinvesotrdeposit, 0)
|
|
|
+ err = db.GetEngine().Where("userid = ?", req.UserId).Find(&rsp)
|
|
|
+
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// 比例变更流水
|
|
|
+type GThjinvesotrdepositlog struct {
|
|
|
+ LOGID string `json:"logid" xorm:"LOGID"` // 流水ID(336+Unix秒时间戳(10位)+xxxxxx)
|
|
|
+ USERID int64 `json:"userid" xorm:"USERID" form:"userid" binding:"required"` // 用户ID
|
|
|
+ DEPOSITRATE float64 `json:"depositrate" xorm:"DEPOSITRATE" form:"depositrate" binding:"required"` // 定金比例(选中比例)
|
|
|
+ ORIDEPOSITQTY int64 `json:"oridepositqty" xorm:"ORIDEPOSITQTY"` // 可用量(变更前)
|
|
|
+ CHANGEQTY int64 `json:"changeqty" xorm:"CHANGEQTY"` // 变更量
|
|
|
+ CURDEPOSITQTY string `json:"curdepositqty" xorm:"CURDEPOSITQTY"` // 可用量(变更后)
|
|
|
+ BUYUSERID int64 `json:"buyuserid" xorm:"BUYUSERID"` // 采购用户ID
|
|
|
+ WRTRADEDETAILID int64 `json:"wrtradedetailid" xorm:"WRTRADEDETAILID"` // 采购成交单ID
|
|
|
+ UPDATORID int64 `json:"updatorid" xorm:"UPDATORID"` // 更新人
|
|
|
+ UPDATETIME string `json:"updatetime" xorm:"UPDATETIME"` // 更新时间
|
|
|
+
|
|
|
+ Accountname string `json:"accountname" xorm:"ACCOUNTNAME"` // 用户名
|
|
|
+
|
|
|
+ PageEx `xorm:"extends"` // 页码信息
|
|
|
+}
|
|
|
+
|
|
|
+func (r *GThjinvesotrdepositlog) calc() {
|
|
|
+
|
|
|
+}
|
|
|
+
|
|
|
+func (r *GThjinvesotrdepositlog) buildSql() string {
|
|
|
+ var sqlId utils.SQLVal = `
|
|
|
+ select
|
|
|
+ t.UPDATETIME,
|
|
|
+ t.ORIDEPOSITQTY,
|
|
|
+ t.CHANGEQTY,
|
|
|
+ t.CURDEPOSITQTY,
|
|
|
+ ua.ACCOUNTNAME,
|
|
|
+ t.WRTRADEDETAILID
|
|
|
+ from THJ_InvesotrDepositLog t
|
|
|
+ left join useraccount ua on t.buyuserid = ua.userid
|
|
|
+ where t.userid = %v and t.depositrate = %v
|
|
|
+ order by t.logid desc
|
|
|
+ `
|
|
|
+ sqlId.FormatParam(r.USERID, r.DEPOSITRATE)
|
|
|
+
|
|
|
+ sqlId.Page(r.Page, r.PageSize)
|
|
|
+ return sqlId.String()
|
|
|
+}
|
|
|
+
|
|
|
+func (r *GThjinvesotrdepositlog) GetDataByPage() (interface{}, error, int, int, int) {
|
|
|
+ sData := make([]GThjinvesotrdepositlog, 0)
|
|
|
+ err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
|
|
|
+ total := 0
|
|
|
+ for i := range sData {
|
|
|
+ sData[i].calc()
|
|
|
+ total = sData[i].Total
|
|
|
+ }
|
|
|
+ return sData, err, r.Page, r.PageSize, total
|
|
|
+}
|