|
|
@@ -46,7 +46,7 @@ type QueryAmountLogRsp struct {
|
|
|
// @Failure 500 {object} app.Response
|
|
|
// @Router /TaAccount/QueryAmountLog [get]
|
|
|
// @Tags 资金账户
|
|
|
-// 参数通用查询:QueryClientAmountLog
|
|
|
+// 参考通用查询:QueryClientAmountLog
|
|
|
func QueryAmountLog(c *gin.Context) {
|
|
|
appG := app.Gin{C: c}
|
|
|
|
|
|
@@ -103,11 +103,115 @@ func QueryAmountLog(c *gin.Context) {
|
|
|
rst = datas[0:0]
|
|
|
}
|
|
|
|
|
|
- logger.GetLogger().Infof("QueryRecieptOrder successed: %v", rst)
|
|
|
+ logger.GetLogger().Infof("QueryAmountLog successed: %v", rst)
|
|
|
appG.ResponseByPage(http.StatusOK, e.SUCCESS, rst, app.PageInfo{Page: req.Page, PageSize: req.PageSize, Total: len(datas)})
|
|
|
} else {
|
|
|
// 不分页
|
|
|
- logger.GetLogger().Infof("QueryRecieptOrder successed: %v", datas)
|
|
|
+ logger.GetLogger().Infof("QueryAmountLog successed: %v", datas)
|
|
|
+ appG.Response(http.StatusOK, e.SUCCESS, datas)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// QueryHisAmountLogReq 资金流水查询(历史)请求参数
|
|
|
+type QueryHisAmountLogReq struct {
|
|
|
+ app.PageInfo
|
|
|
+ AccountID string `form:"accountID"` // 资金账户
|
|
|
+ OperateType string `form:"operateType"` // 资金操作类型
|
|
|
+ StartDate string `form:"startDate"` // 开始时间
|
|
|
+ EndDate string `form:"endDate"` // 结束时间
|
|
|
+}
|
|
|
+
|
|
|
+// QueryHisAmountLogRsp 资金流水查询(历史)返回模型
|
|
|
+type QueryHisAmountLogRsp struct {
|
|
|
+ models.Histaaccountlog `xorm:"extends"`
|
|
|
+
|
|
|
+ MarketName string `json:"marketname" xorm:"'MARKETNAME'"` // 市场名称
|
|
|
+ TradeMode uint32 `json:"trademode" xorm:"'TRADEMODE'"` // 交易模式
|
|
|
+ GoodsCode string `json:"goodscode" xorm:"'GOODSCODE'"` // 商品代码
|
|
|
+ GoodsName string `json:"goodsname" xorm:"'GOODSNAME'"` // 商品名称
|
|
|
+ AGoodsCode string `json:"agoodscode" xorm:"'AGOODSCODE'"` // 竞拍商品代码
|
|
|
+ AGoodsName string `json:"agoodsname" xorm:"'GOODSNAME'"` // 竞拍商品名称
|
|
|
+ DGoodsCode string `json:"dgoodscode" xorm:"'DGOODSCODE'"` // 交割商品代码
|
|
|
+ DGoodsName string `json:"dgoodsname" xorm:"'DGOODSNAME'"` // 交割商品名称
|
|
|
+ OperateTypeName string `json:"OPERATETYPENAME" xorm:"OPERATETYPENAME"` // 资金操作类型名称
|
|
|
+}
|
|
|
+
|
|
|
+// QueryHisAmountLog 资金流水查询(历史)
|
|
|
+// @Summary 资金流水查询(历史)
|
|
|
+// @Produce json
|
|
|
+// @Security ApiKeyAuth
|
|
|
+// @Param page query int false "页码"
|
|
|
+// @Param pagesize query int false "每页条数"
|
|
|
+// @Param accountID query string true "资金账户 - 格式:1,2,3"
|
|
|
+// @Param OperateType query string false "资金操作类型 - 格式:1,2,3"
|
|
|
+// @Param startDate query string false "开始时间 - 闭区间,格式:yyyy-MM-dd"
|
|
|
+// @Param endDate query string false "结束时间 - 闭区间,格式:yyyy-MM-dd"
|
|
|
+// @Success 200 {object} QueryHisAmountLogRsp
|
|
|
+// @Failure 500 {object} app.Response
|
|
|
+// @Router /TaAccount/QueryHisAmountLog [get]
|
|
|
+// @Tags 资金账户
|
|
|
+// 参考通用查询:Client_QueryHis_taaccountlog
|
|
|
+func QueryHisAmountLog(c *gin.Context) {
|
|
|
+ appG := app.Gin{C: c}
|
|
|
+
|
|
|
+ // 获取请求参数
|
|
|
+ var req QueryHisAmountLogReq
|
|
|
+ if err := appG.C.ShouldBindQuery(&req); err != nil {
|
|
|
+ logger.GetLogger().Errorf("QueryHisAmountLog failed: %s", err.Error())
|
|
|
+ appG.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询数据
|
|
|
+ datas := make([]QueryHisAmountLogRsp, 0)
|
|
|
+ engine := db.GetEngine()
|
|
|
+ s := engine.Table("HIS_TAACCOUNTLOG").
|
|
|
+ Join("LEFT", "ENUMDICITEM", "ENUMDICITEM.ENUMITEMSTATUS = 1 and ENUMDICITEM.ENUMDICID = 39 and ENUMDICITEM.ENUMITEMNAME = HIS_TAACCOUNTLOG.OPERATETYPE").
|
|
|
+ Join("LEFT", "MARKET", "MARKET.MARKETID = HIS_TAACCOUNTLOG.MARKETID").
|
|
|
+ Join("LEFT", "GOODS", "GOODS.GOODSID = HIS_TAACCOUNTLOG.GOODSID").
|
|
|
+ Join("LEFT", "HIS_AUCTION_ORDERINFO", "HIS_AUCTION_ORDERINFO.GOODSID = HIS_TAACCOUNTLOG.GOODSID and HIS_AUCTION_ORDERINFO.ISVALIDDATA = 1").
|
|
|
+ Join("LEFT", "DELIVERYGOODS", "DELIVERYGOODS.DELIVERYGOODSID = HIS_TAACCOUNTLOG.GOODSID").
|
|
|
+ Select(`to_char(HIS_TAACCOUNTLOG.RELATIONORDERID) as RELATIONORDERID, HIS_TAACCOUNTLOG.*,
|
|
|
+ MARKET.MARKETNAME, MARKET.TRADEMODE,
|
|
|
+ GOODS.GOODSCODE, GOODS.GOODSNAME,
|
|
|
+ HIS_AUCTION_ORDERINFO.GOODSCODE AS AGOODSCODE, HIS_AUCTION_ORDERINFO.GOODSNAME AS AGOODSNAME,
|
|
|
+ DELIVERYGOODS.DELIVERYGOODSCODE AS DGOODSCODE, DELIVERYGOODS.DELIVERYGOODSNAME AS DGOODSNAME,
|
|
|
+ ENUMDICITEM.ENUMDICNAME AS OPERATETYPENAME`).
|
|
|
+ Where(fmt.Sprintf(`HIS_TAACCOUNTLOG.ISVALIDDATA = 1 and HIS_TAACCOUNTLOG.ACCOUNTID in (%s)`, req.AccountID)).Desc("HIS_TAACCOUNTLOG.AUTOID")
|
|
|
+ if len(req.OperateType) > 0 {
|
|
|
+ s = s.And(fmt.Sprintf("HIS_TAACCOUNTLOG.OPERATETYPE in (%s)", req.OperateType))
|
|
|
+ }
|
|
|
+ if err := s.Find(&datas); err != nil {
|
|
|
+ // 查询失败
|
|
|
+ logger.GetLogger().Errorf("QueryHisAmountLog failed: %s", err.Error())
|
|
|
+ appG.Response(http.StatusBadRequest, e.ERROR_QUERY_FAIL, nil)
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ // 查询成功返回
|
|
|
+ if req.PageSize > 0 {
|
|
|
+ // 分页
|
|
|
+ rst := make([]QueryHisAmountLogRsp, 0)
|
|
|
+ // 开始上标
|
|
|
+ start := req.Page * req.PageSize
|
|
|
+ // 结束下标
|
|
|
+ end := start + req.PageSize
|
|
|
+
|
|
|
+ if start <= len(datas) {
|
|
|
+ // 判断结束下标是否越界
|
|
|
+ if end > len(datas) {
|
|
|
+ end = len(datas)
|
|
|
+ }
|
|
|
+ rst = datas[start:end]
|
|
|
+ } else {
|
|
|
+ rst = datas[0:0]
|
|
|
+ }
|
|
|
+
|
|
|
+ logger.GetLogger().Infof("QueryHisAmountLog successed: %v", rst)
|
|
|
+ appG.ResponseByPage(http.StatusOK, e.SUCCESS, rst, app.PageInfo{Page: req.Page, PageSize: req.PageSize, Total: len(datas)})
|
|
|
+ } else {
|
|
|
+ // 不分页
|
|
|
+ logger.GetLogger().Infof("QueryHisAmountLog successed: %v", datas)
|
|
|
appG.Response(http.StatusOK, e.SUCCESS, datas)
|
|
|
}
|
|
|
}
|