qryErmcp3Report.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  1. /**
  2. * @Author: zou.yingbin
  3. * @Create : 2021/4/16 18:40
  4. * @Modify : 2021/4/16 18:40
  5. */
  6. package ermcp3
  7. import (
  8. "github.com/gin-gonic/gin"
  9. "mtp2_if/global/app"
  10. "mtp2_if/global/e"
  11. "mtp2_if/logger"
  12. "mtp2_if/models"
  13. "mtp2_if/mtpcache"
  14. "net/http"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. // 查询日期
  20. type QueryDate string
  21. // IsNumberic 判断是否为数字, queryType 1:8位日期 2:6位日期
  22. func (v QueryDate) IsNumberic(queryType int32) bool {
  23. if queryType == 1 {
  24. // 日报表 日期长度YYYYMMDD
  25. if len(v) != 8 {
  26. return false
  27. }
  28. } else if queryType == 2 {
  29. // 月报表 日期长度YYYYMM
  30. if len(v) != 6 {
  31. return false
  32. }
  33. }
  34. // 判断是否为数字
  35. if _, err := strconv.ParseInt(string(v), 10, 32); err != nil {
  36. return false
  37. }
  38. return true
  39. }
  40. // QryReportReq 查报表请求
  41. // @Param userid query int true "用户ID"
  42. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  43. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  44. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  45. type QryReportReq struct {
  46. USERID int64 `form:"userid" binding:"required"` // 用户id
  47. QUERYTYPE int32 `form:"querytype"` // 查询类型
  48. CYCLETYPE int32 `form:"cycletype"` // 周期类型
  49. CYCLETIME string `form:"cycletime" binding:"required"` // 周期时间
  50. TRADEDATE string // 交易日
  51. BEGINDATE string // 开始交易日
  52. ENDDATE string // 结束交易日
  53. }
  54. // Check 参数检查
  55. func (r *QryReportReq) Check() bool {
  56. // 兼容性处理, 月报表日期如果是yyyymmdd, 只取yyyymm
  57. if r.CYCLETYPE == 1 && len(r.CYCLETIME) > 6 {
  58. r.CYCLETIME = r.CYCLETIME[:6]
  59. }
  60. // 检查日期格式
  61. switch r.CYCLETYPE {
  62. case 0, 4:
  63. // 日/周报表 日期格式为yyyymmdd
  64. return QueryDate(r.CYCLETIME).IsNumberic(1)
  65. case 1:
  66. // 月 日期格式为yyyymm
  67. return QueryDate(r.CYCLETIME).IsNumberic(2)
  68. case 2, 3, 5:
  69. // nothing to do
  70. return true
  71. default:
  72. logger.GetLogger().Errorf("cycletype[%v] invalid", r.CYCLETYPE)
  73. return false
  74. }
  75. }
  76. // CovertRequest 转换查询请求, 日期格式等
  77. func (r *QryReportReq) CovertRequest() {
  78. // 日报表 -> 给TRADEDATE赋值
  79. if r.CYCLETYPE == 0 {
  80. r.TRADEDATE = r.CYCLETIME
  81. }
  82. // 周报表(YYYYMMDD) -> 周报表(YYYYIW)
  83. if r.QUERYTYPE == 1 && r.CYCLETYPE == 4 {
  84. r.BEGINDATE, r.ENDDATE = getDateScope(r.CYCLETYPE, r.CYCLETIME)
  85. r.CYCLETIME = mtpcache.GetWeekIW(r.CYCLETIME)
  86. }
  87. // 月报表 -> 获取起止日期
  88. if r.QUERYTYPE == 1 && r.CYCLETYPE == 1 {
  89. r.BEGINDATE, r.ENDDATE = getDateScope(r.CYCLETYPE, r.CYCLETIME)
  90. }
  91. // 周报表明细 -> 日报表明细([开始交易日,结束交易日])
  92. if r.QUERYTYPE == 2 && r.CYCLETYPE == 4 {
  93. r.BEGINDATE, r.ENDDATE = getDateScope(r.CYCLETYPE, r.CYCLETIME)
  94. r.CYCLETYPE = 0
  95. }
  96. // 月报表明细 -> 日报表明细([开始交易日,结束交易日])
  97. if r.QUERYTYPE == 2 && r.CYCLETYPE == 1 {
  98. r.BEGINDATE, r.ENDDATE = getDateScope(r.CYCLETYPE, r.CYCLETIME)
  99. r.CYCLETYPE = 0
  100. }
  101. }
  102. // getDateScope 获取日期范围
  103. func getDateScope(cycletype int32, cycletime string) (beginDate, endDate string) {
  104. switch cycletype {
  105. case 1: // 月(yyyymm)
  106. if len(cycletime) == 6 {
  107. year, _ := strconv.ParseInt(cycletime[0:4], 10, 32)
  108. month, _ := strconv.ParseInt(cycletime[4:], 10, 32)
  109. if year >= 1970 && year <= 9999 && month >= 1 && month <= 12 {
  110. // 计算日期范围
  111. beginDate = cycletime + "01"
  112. d := time.Date(int(year), time.Month(month), 1, 0, 0, 0, 0, time.Now().Location())
  113. last := d.AddDate(0, 1, -1)
  114. endDate = last.Format("20060102")
  115. } else {
  116. beginDate = cycletime + "01"
  117. endDate = cycletime + "31"
  118. }
  119. }
  120. case 2: // 季, 暂不实现
  121. case 3: // 年, 暂不实现
  122. case 4: // 周
  123. if w, ok := mtpcache.GetWeekInfo(cycletime); ok {
  124. beginDate = w.BeginDate
  125. endDate = w.EndDate
  126. } else {
  127. // 转换失败 : 一般来说不会转换失败
  128. logger.GetLogger().Errorf("covert cycletime to week fail:%v", cycletime)
  129. }
  130. }
  131. return
  132. }
  133. // QryReportDaySpotDetail 查询现货日报表详情(菜单:报表查询/现货报表/现货日报表详情) - 作废
  134. func QryReportDaySpotDetail(c *gin.Context) {
  135. a := app.GinUtils{Gin: app.Gin{C: c}}
  136. req := struct {
  137. USERID int64 `form:"userid" binding:"required"` // 用户id
  138. TRADEDATE string `form:"tradedate" binding:"required"` // 交易日
  139. DELIVERYGOODSID int32 `form:"deliverygoodsid" binding:"required"` // 现货商品id
  140. SPOTGOODSBRANDID int32 `form:"spotgoodsbrandid"` // 品牌id
  141. WRSTANDARDID int32 `form:"wrstandardid"` // 品类id
  142. }{}
  143. a.DoBindReq(&req)
  144. m := models.Ermcp3ReportOPLog{USERID: req.USERID, DELIVERYGOODSID: req.DELIVERYGOODSID,
  145. TRADEDATE: req.TRADEDATE, SPOTGOODSBRANDID: req.SPOTGOODSBRANDID, WRSTANDARDID: req.WRSTANDARDID,
  146. LogTypeFilter: "2,3,24,25,26,27"}
  147. a.DoGetDataI(&m)
  148. }
  149. // QryReportDayFinanceKx 查询财务日报表款项(菜单:报表查询/财务报表/日报表/款项) - 作废
  150. func QryReportDayFinanceKx(c *gin.Context) {
  151. a := app.GinUtils{Gin: app.Gin{C: c}}
  152. req := struct {
  153. USERID int64 `form:"userid" binding:"required"` // 用户id
  154. TRADEDATE string `form:"tradedate" binding:"required"` // 交易日
  155. }{}
  156. a.DoBindReq(&req)
  157. m := models.Ermcp3ReportOPLog{USERID: req.USERID, TRADEDATE: req.TRADEDATE, LogTypeFilter: "8,9,10"}
  158. a.DoGetDataI(&m)
  159. }
  160. // QryReportDayFinanceFp 查询财务日报表发票(菜单:报表查询/财务报表/日报表/发票) - 作废
  161. func QryReportDayFinanceFp(c *gin.Context) {
  162. a := app.GinUtils{Gin: app.Gin{C: c}}
  163. req := struct {
  164. USERID int64 `form:"userid" binding:"required"` // 用户id
  165. TRADEDATE string `form:"tradedate" binding:"required"` // 交易日
  166. }{}
  167. a.DoBindReq(&req)
  168. m := models.Ermcp3ReportOPLog{USERID: req.USERID, TRADEDATE: req.TRADEDATE, LogTypeFilter: "11, 12"}
  169. a.DoGetDataI(&m)
  170. }
  171. // QryReportDaySpot 查询现货日报表(菜单:报表查询/现货报表/现货日报表) - 作废
  172. func QryReportDaySpot(c *gin.Context) {
  173. a := app.GinUtils{Gin: app.Gin{C: c}}
  174. m := models.Ermcp3ReckonAreaSpotSub{}
  175. a.DoBindReq(&m)
  176. a.DoGetDataI(&m)
  177. }
  178. // QryReportMonthSpot 查询现货月报表(菜单:报表查询/现货报表/现货月报表) - 作废
  179. func QryReportMonthSpot(c *gin.Context) {
  180. a := app.GinUtils{Gin: app.Gin{C: c}}
  181. m := models.Ermcp3ReportAreaSpotSub{}
  182. a.DoBindReq(&m)
  183. a.DoGetDataI(&m)
  184. }
  185. // QryReportMonthSpotDetail 查询现货月报表详情(菜单:报表查询/现货月报表/现货月报表详情) - 作废
  186. func QryReportMonthSpotDetail(c *gin.Context) {
  187. a := app.GinUtils{Gin: app.Gin{C: c}}
  188. req := models.Ermcp3ReportAreaSpotSub{}
  189. a.DoBindReq(&req)
  190. if req.CYCLETYPE != 1 || len(req.CYCLETIME) != 6 {
  191. // 目前仅支持月报表明细, 月报表的日期应是6位,如 202101
  192. a.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
  193. return
  194. }
  195. t1 := req.CYCLETIME + "01"
  196. t2 := req.CYCLETIME + "31"
  197. // 月报表明细 = 01~31 日报表
  198. m := models.Ermcp3ReckonAreaSpotSub{
  199. AREAUSERID: req.AREAUSERID, DELIVERYGOODSID: req.DELIVERYGOODSID, ACCOUNTID: req.ACCOUNTID,
  200. WRSTANDARDID: req.WRSTANDARDID, SPOTGOODSBRANDID: req.SPOTGOODSBRANDID, BeginDate: t1, EndDate: t2}
  201. a.DoGetDataI(&m)
  202. }
  203. // QryAreaExpourseReport
  204. // @Summary 查询敞口报表
  205. // @Produce json
  206. // @Security ApiKeyAuth
  207. // @Param userid query int true "用户ID"
  208. // @Param querytype query int true "查询类型 1-报表, 这个接口只查报表;明细的字段完全不同,另有接口"
  209. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  210. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  211. // @Success 200 {array} models.Ermcp3ExpourseReport
  212. // @Failure 500 {object} app.Response
  213. // @Router /Ermcp3/QryAreaExpourseReport [get]
  214. // @Tags 企业风险管理v3(app)
  215. func QryAreaExpourseReport(c *gin.Context) {
  216. a := app.GinUtils{Gin: app.Gin{C: c}}
  217. req := QryReportReq{}
  218. a.DoBindReq(&req)
  219. a.CheckParam(&req)
  220. req.CovertRequest()
  221. m := models.Ermcp3ExpourseReport{AREAUSERID: req.USERID, QueryType: req.QUERYTYPE,
  222. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, RECKONDATE: req.TRADEDATE,
  223. BeginDate: req.BEGINDATE, EndDate: req.ENDDATE}
  224. a.DoGetDataI(&m)
  225. }
  226. // QryAreaExpourseContractDetail
  227. // @Summary 查询敞口合同明细(敞口报表/现货合同明细)
  228. // @Produce json
  229. // @Security ApiKeyAuth
  230. // @Param userid query int true "用户ID"
  231. // @Param middlegoodsid query int true "套保商品id"
  232. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  233. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  234. // @Success 200 {array} models.Ermcp3ExposureContractDetail
  235. // @Failure 500 {object} app.Response
  236. // @Router /Ermcp3/QryAreaExpourseContractDetail [get]
  237. // @Tags 企业风险管理v3(app)
  238. func QryAreaExpourseContractDetail(c *gin.Context) {
  239. a := app.GinUtils{Gin: app.Gin{C: c}}
  240. tmp := struct {
  241. USERID int64 `form:"userid" binding:"required"` // 用户id
  242. MIDDLEGOODSID int32 `form:"middlegoodsid" binding:"required"` // 套保商品id
  243. CYCLETYPE int32 `form:"cycletype"`
  244. CYCLETIME string `form:"cycletime"`
  245. }{}
  246. a.DoBindReq(&tmp)
  247. req := QryReportReq{USERID: tmp.USERID, QUERYTYPE: 2, CYCLETYPE: tmp.CYCLETYPE, CYCLETIME: tmp.CYCLETIME}
  248. a.CheckParam(&req)
  249. req.CovertRequest()
  250. m := models.Ermcp3ExposureContractDetail{USERID: req.USERID,
  251. MIDDLEGOODSID: tmp.MIDDLEGOODSID, TRADEDATE: req.TRADEDATE, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE}
  252. a.DoGetDataI(&m)
  253. }
  254. // QryAreaExpourseHedgeplanDetail
  255. // @Summary 查询敞口套保计划明细(敞口报表/套保计划明细)
  256. // @Produce json
  257. // @Security ApiKeyAuth
  258. // @Param userid query int true "用户ID"
  259. // @Param middlegoodsid query int true "套保商品id"
  260. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  261. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  262. // @Success 200 {array} models.Ermcp3ExposureHedgeplanDetail
  263. // @Failure 500 {object} app.Response
  264. // @Router /Ermcp3/QryAreaExpourseHedgeplanDetail [get]
  265. // @Tags 企业风险管理v3(app)
  266. func QryAreaExpourseHedgeplanDetail(c *gin.Context) {
  267. a := app.GinUtils{Gin: app.Gin{C: c}}
  268. tmp := struct {
  269. USERID int64 `form:"userid" binding:"required"` // 用户id
  270. MIDDLEGOODSID int32 `form:"middlegoodsid" binding:"required"` // 套保商品id
  271. CYCLETYPE int32 `form:"cycletype"`
  272. CYCLETIME string `form:"cycletime"`
  273. }{}
  274. a.DoBindReq(&tmp)
  275. req := QryReportReq{USERID: tmp.USERID, QUERYTYPE: 2, CYCLETYPE: tmp.CYCLETYPE, CYCLETIME: tmp.CYCLETIME}
  276. a.CheckParam(&req)
  277. req.CovertRequest()
  278. m := models.Ermcp3ExposureHedgeplanDetail{USERID: req.USERID,
  279. MIDDLEGOODSID: tmp.MIDDLEGOODSID, TRADEDATE: req.TRADEDATE, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE}
  280. a.DoGetDataI(&m)
  281. }
  282. // QryAreaExpourseFutuDetail
  283. // @Summary 查询敞口期货明细(敞口报表/期货明细)
  284. // @Produce json
  285. // @Security ApiKeyAuth
  286. // @Param userid query int true "用户ID"
  287. // @Param middlegoodsid query int true "套保商品id"
  288. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  289. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  290. // @Success 200 {array} models.Ermcp3ExposureFutuDetail
  291. // @Failure 500 {object} app.Response
  292. // @Router /Ermcp3/QryAreaExpourseFutuDetail [get]
  293. // @Tags 企业风险管理v3(app)
  294. func QryAreaExpourseFutuDetail(c *gin.Context) {
  295. a := app.GinUtils{Gin: app.Gin{C: c}}
  296. tmp := struct {
  297. USERID int64 `form:"userid" binding:"required"` // 用户id
  298. MIDDLEGOODSID int32 `form:"middlegoodsid" binding:"required"` // 套保商品id
  299. CYCLETYPE int32 `form:"cycletype"`
  300. CYCLETIME string `form:"cycletime"`
  301. }{}
  302. a.DoBindReq(&tmp)
  303. req := QryReportReq{USERID: tmp.USERID, QUERYTYPE: 2, CYCLETYPE: tmp.CYCLETYPE, CYCLETIME: tmp.CYCLETIME}
  304. a.CheckParam(&req)
  305. req.CovertRequest()
  306. m := models.Ermcp3ExposureFutuDetail{USERID: req.USERID,
  307. MIDDLEGOODSID: tmp.MIDDLEGOODSID, RECKONDATE: req.TRADEDATE, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE}
  308. a.DoGetDataI(&m)
  309. }
  310. // QryAreaExpourseParamChLogDetail
  311. // @Summary 查询敞口参数调整明细(敞口报表/参数调整明细)
  312. // @Produce json
  313. // @Security ApiKeyAuth
  314. // @Param userid query int true "用户ID"
  315. // @Param middlegoodsid query int true "套保商品id"
  316. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  317. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  318. // @Success 200 {array} models.Ermcp3ExposureParamChLog
  319. // @Failure 500 {object} app.Response
  320. // @Router /Ermcp3/QryAreaExpourseParamChLogDetail [get]
  321. // @Tags 企业风险管理v3(app)
  322. func QryAreaExpourseParamChLogDetail(c *gin.Context) {
  323. a := app.GinUtils{Gin: app.Gin{C: c}}
  324. tmp := struct {
  325. USERID int64 `form:"userid" binding:"required"` // 用户id
  326. MIDDLEGOODSID int64 `form:"middlegoodsid" binding:"required"` // 套保商品id
  327. CYCLETYPE int32 `form:"cycletype"`
  328. CYCLETIME string `form:"cycletime"`
  329. }{}
  330. a.DoBindReq(&tmp)
  331. req := QryReportReq{USERID: tmp.USERID, QUERYTYPE: 2, CYCLETYPE: tmp.CYCLETYPE, CYCLETIME: tmp.CYCLETIME}
  332. a.CheckParam(&req)
  333. req.CovertRequest()
  334. m := models.Ermcp3ExposureParamChLog{AREAUSERID: mtpcache.GetAreaUserId(req.USERID, 0),
  335. MIDDLEGOODSID: tmp.MIDDLEGOODSID, TRADEDATE: req.TRADEDATE, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE}
  336. a.DoGetDataI(&m)
  337. }
  338. // QryAreaSpotplReport
  339. // @Summary 查询现货报表
  340. // @Description 目前pcweb的日/周/月报表与手机端的汇总维度不同, 所以增加了可选参数sumflag参数, pcweb请填1
  341. // @Produce json
  342. // @Security ApiKeyAuth
  343. // @Param userid query int true "用户ID"
  344. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  345. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  346. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  347. // @Param deliverygoodsid query int false "现货品种id(明细必填)"
  348. // @Param currencyid query int false "币种id(明细必填)"
  349. // @Param sumflag query int false "日/周/月报表汇总维度 1:品种+品类"
  350. // @Success 200 {array} models.Ermcp3AreaSpotPLReport
  351. // @Failure 500 {object} app.Response
  352. // @Router /Ermcp3/QryAreaSpotplReport [get]
  353. // @Tags 企业风险管理v3(app)
  354. func QryAreaSpotplReport(c *gin.Context) {
  355. a := app.GinUtils{Gin: app.Gin{C: c}}
  356. req := QryReportReq{}
  357. a.DoBindReq(&req)
  358. a.CheckParam(&req)
  359. req2 := struct {
  360. DELIVERYGOODSID int64 `form:"deliverygoodsid"` // 品种
  361. WRSTANDARDID int64 `form:"wrstandardid"` // 品类
  362. CURRENCYID int32 `form:"currencyid"` // 币种
  363. SumFlag int32 `form:"sumflag"` // 日报表统计维度 1:品种+品类
  364. }{}
  365. sumFlag := c.Query("sumflag")
  366. if sumFlag == "1" {
  367. req2.SumFlag = 1
  368. }
  369. if req.QUERYTYPE == 2 {
  370. a.DoBindReq(&req2)
  371. a.CheckParamF(func() bool {
  372. if req2.DELIVERYGOODSID <= 0 || req2.CURRENCYID <= 0 {
  373. return false
  374. }
  375. return true
  376. })
  377. }
  378. req.CovertRequest()
  379. m := models.Ermcp3AreaSpotPLReport{AREAUSERID: req.USERID, QueryType: req.QUERYTYPE, RECKONDATE: req.TRADEDATE,
  380. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE,
  381. DELIVERYGOODSID: req2.DELIVERYGOODSID, WRSTANDARDID: req2.WRSTANDARDID, CURRENCYID: req2.CURRENCYID, SumFlag: req2.SumFlag}
  382. a.DoGetDataI(&m)
  383. }
  384. // QryFinanceReport
  385. // @Summary 查询财务报表
  386. // @Produce json
  387. // @Security ApiKeyAuth
  388. // @Param userid query int true "用户ID"
  389. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  390. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  391. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  392. // @Param currencyid query int false "币种id(报表明细必填)"
  393. // @Param sumfields query string false "汇总维度(逗号隔开) 1-品种 2-品类 3-品牌"
  394. // @Success 200 {array} models.Ermcp3FinanceReport
  395. // @Failure 500 {object} app.Response
  396. // @Router /Ermcp3/QryFinanceReport [get]
  397. // @Tags 企业风险管理v3(app)
  398. func QryFinanceReport(c *gin.Context) {
  399. a := app.GinUtils{Gin: app.Gin{C: c}}
  400. req := QryReportReq{}
  401. a.DoBindReq(&req)
  402. a.CheckParam(&req)
  403. req2 := struct {
  404. CURRENCYID int32 `form:"currencyid"` // 币种id
  405. SUMFIELDS string `form:"sumfields"` // 汇总维度
  406. }{}
  407. a.DoBindReq(&req2)
  408. a.CheckParamF(func() bool {
  409. if req.QUERYTYPE == 2 {
  410. return req2.CURRENCYID > 0
  411. }
  412. tmp := req2.SUMFIELDS
  413. req2.SUMFIELDS = strings.TrimSpace(req2.SUMFIELDS)
  414. for _, v := range req2.SUMFIELDS {
  415. if v != ',' {
  416. if v < '1' || v > '3' {
  417. logger.GetLogger().Errorf("QryFinanceReport sumfield[%v] check fail", tmp)
  418. return false
  419. }
  420. }
  421. }
  422. return true
  423. })
  424. req.CovertRequest()
  425. m := models.Ermcp3FinanceReport{AREAUSERID: req.USERID, QueryType: req.QUERYTYPE, RECKONDATE: req.TRADEDATE, SumFields: req2.SUMFIELDS,
  426. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE, CURRENCYID: req2.CURRENCYID}
  427. a.DoGetDataI(&m)
  428. }
  429. // QryAreaStockReport
  430. // @Summary 查询库存报表
  431. // @Produce json
  432. // @Security ApiKeyAuth
  433. // @Param userid query int true "用户ID"
  434. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  435. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  436. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  437. // @Param sumfields query string false "汇总维度(逗号隔开) 1-品种 2-品类 3-品牌 4-仓库"
  438. // @Param deliverygoodsid query int false "品种ID"
  439. // @Param wrstandardid query int false "品类ID"
  440. // @Param spotgoodsbrandid query int false "品牌ID"
  441. // @Param warehouseinfoid query int false "仓库ID"
  442. // @Success 200 {array} models.Ermcp3AreaStockReportEx
  443. // @Failure 500 {object} app.Response
  444. // @Router /Ermcp3/QryAreaStockReport [get]
  445. // @Tags 企业风险管理v3(app)
  446. func QryAreaStockReport(c *gin.Context) {
  447. a := app.GinUtils{Gin: app.Gin{C: c}}
  448. req := QryReportReq{}
  449. req2 := struct {
  450. SUMFIELDS string `form:"sumfields"` // 汇总维度
  451. DELIVERYGOODSID int32 `form:"deliverygoodsid"` // 现货品种id
  452. WRSTANDARDID int32 `form:"wrstandardid"` // 品类ID
  453. SPOTGOODSBRANDID int32 `form:"spotgoodsbrandid"` // 品牌id
  454. WAREHOUSEINFOID string `form:"warehouseinfoid"` // 仓库id
  455. }{}
  456. a.DoBindReq(&req)
  457. a.CheckParam(&req)
  458. a.DoBindReq(&req2)
  459. a.CheckParamF(func() bool {
  460. tmp := req2.SUMFIELDS
  461. req2.SUMFIELDS = strings.TrimSpace(req2.SUMFIELDS)
  462. for _, v := range req2.SUMFIELDS {
  463. if v != ',' {
  464. if v < '1' || v > '4' {
  465. logger.GetLogger().Errorf("sumfield[%v] check fail", tmp)
  466. return false
  467. }
  468. }
  469. }
  470. return true
  471. })
  472. req.CovertRequest()
  473. m := models.Ermcp3AreaStockReportEx{USERID: req.USERID, RECKONDATE: req.TRADEDATE,
  474. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE,
  475. DELIVERYGOODSID: req2.DELIVERYGOODSID, WRSTANDARDID: req2.WRSTANDARDID,
  476. SPOTGOODSBRANDID: req2.SPOTGOODSBRANDID, WAREHOUSEINFOID: req2.WAREHOUSEINFOID, SumFields: req2.SUMFIELDS}
  477. a.DoGetDataI(&m)
  478. }
  479. // QueryAreaStockReportDetail
  480. // 查询库存报表明细 - 作废
  481. func QueryAreaStockReportDetail(c *gin.Context) {
  482. a := app.GinUtils{Gin: app.Gin{C: c}}
  483. req := struct {
  484. USERID int64 `form:"userid" binding:"required"` // 机构ID
  485. DELIVERYGOODSID int32 `form:"deliverygoodsid"` // 现货品种id
  486. WRSTANDARDID int32 `form:"wrstandardid"` // 品类ID
  487. SPOTGOODSBRANDID int32 `form:"spotgoodsbrandid"` // 品牌id
  488. WAREHOUSEINFOID string `form:"warehouseinfoid"` // 现货仓库ID
  489. QUERYTYPE int32 `form:"querytype" binding:"required"` // 查询类型
  490. QUERYDATE string `form:"querydate" binding:"required"` // 查询日期
  491. DETAILTYPE int32 `form:"detailtype" binding:"required"` // 明细类型
  492. }{}
  493. a.DoBindReq(&req)
  494. if QueryDate(req.QUERYDATE).IsNumberic(req.QUERYTYPE) {
  495. var beginDate, endDate string
  496. if req.QUERYTYPE == 1 {
  497. beginDate = req.QUERYDATE
  498. endDate = beginDate
  499. } else if req.QUERYTYPE == 2 {
  500. beginDate = req.QUERYDATE + "01"
  501. endDate = req.QUERYDATE + "31"
  502. }
  503. m := models.Ermcp3AreaStockApply{USERID: req.USERID, WRSTANDARDID: req.WRSTANDARDID,
  504. SPOTGOODSBRANDID: req.SPOTGOODSBRANDID, DELIVERYGOODSID: req.DELIVERYGOODSID,
  505. WAREHOUSEINFOID: req.WAREHOUSEINFOID, BeginDate: beginDate, EndDate: endDate, APPLYSTATUS: 2}
  506. // 出入库类型(可多项,逗号隔开) 1:采购入库 2:销售出库 3:生产入库 4:生产出库"
  507. if req.DETAILTYPE == 1 {
  508. m.FilterType = "1,3"
  509. } else if req.DETAILTYPE == 2 {
  510. m.FilterType = "2,4"
  511. }
  512. a.DoGetDataI(&m)
  513. } else {
  514. a.Gin.Response(http.StatusBadRequest, e.INVALID_PARAMS, nil)
  515. }
  516. }
  517. // QryAreaSumPL
  518. // @Summary 查询汇总损益表
  519. // @Produce json
  520. // @Security ApiKeyAuth
  521. // @Param userid query int true "用户ID"
  522. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  523. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  524. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  525. // @Param currencyid query int false "币种id(明细必填)"
  526. // @Success 200 {array} models.Ermcp3ArealSumPL
  527. // @Failure 500 {object} app.Response
  528. // @Router /Ermcp3/QryAreaSumPL [get]
  529. // @Tags 企业风险管理v3(app)
  530. func QryAreaSumPL(c *gin.Context) {
  531. a := app.GinUtils{Gin: app.Gin{C: c}}
  532. req := QryReportReq{}
  533. a.DoBindReq(&req)
  534. a.CheckParam(&req)
  535. req2 := struct {
  536. CURRENCYID int32 `form:"currencyid"` // 币种id
  537. }{}
  538. a.DoBindReq(&req2)
  539. a.CheckParamF(func() bool {
  540. if req.QUERYTYPE == 2 {
  541. return req2.CURRENCYID > 0
  542. }
  543. return true
  544. })
  545. req.CovertRequest()
  546. m := models.Ermcp3ArealSumPL{AREAUSERID: req.USERID, QueryType: req.QUERYTYPE, RECKONDATE: req.TRADEDATE,
  547. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE, CURRENCYID: req2.CURRENCYID}
  548. a.DoGetDataI(&m)
  549. }
  550. // QryTaFutureDataReport
  551. // @Summary 查询期货报表
  552. // @Produce json
  553. // @Security ApiKeyAuth
  554. // @Param userid query int true "用户ID"
  555. // @Param querytype query int true "查询类型 1-报表 2-报表明细"
  556. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  557. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  558. // @Param currencyid query int false "币种id(查明细必填)"
  559. // @Param goodsgroupid query int false "品种id(查明细必填)"
  560. // @Param goodsid query int false "商品id(查明细必填)"
  561. // @Param buyorsell query int false "买卖方向(查明细必填)"
  562. // @Success 200 {array} models.Ermcp3TaFutuReDataReport
  563. // @Failure 500 {object} app.Response
  564. // @Router /Ermcp3/QryTaFutureDataReport [get]
  565. // @Tags 企业风险管理v3(app)
  566. func QryTaFutureDataReport(c *gin.Context) {
  567. a := app.GinUtils{Gin: app.Gin{C: c}}
  568. req := QryReportReq{}
  569. a.DoBindReq(&req)
  570. a.CheckParam(&req)
  571. req2 := struct {
  572. CURRENCYID int32 `form:"currencyid"` // 币种id
  573. GOODSGROUPID int32 `form:"goodsgroupid"` // 品种id
  574. GOODSID int32 `form:"goodsid"` // 商品id
  575. BUYORSELL int32 `form:"buyorsell"` // 买卖方向
  576. }{}
  577. a.DoBindReq(&req2)
  578. a.CheckParamF(func() bool {
  579. if req.QUERYTYPE == 2 {
  580. // 检查报表明细必填字段
  581. if req2.CURRENCYID == 0 || req2.GOODSGROUPID == 0 || req2.GOODSID == 0 {
  582. return false
  583. }
  584. }
  585. return true
  586. })
  587. req.CovertRequest()
  588. m := models.Ermcp3TaFutuReDataReport{USERID: req.USERID, QueryType: req.QUERYTYPE, RECKONDATE: req.TRADEDATE,
  589. CYCLETYPE: req.CYCLETYPE, CYCLETIME: req.CYCLETIME, BeginDate: req.BEGINDATE, EndDate: req.ENDDATE,
  590. CURRENCYID: req2.CURRENCYID, GOODSGROUPID: req2.GOODSGROUPID, GOODSID: req2.GOODSID, BUYORSELL: req2.BUYORSELL}
  591. a.DoGetDataI(&m)
  592. }
  593. // QrySCMiddleGoodsReport
  594. // @Summary 查询定价报表
  595. // @Produce json
  596. // @Security ApiKeyAuth
  597. // @Param userid query int true "用户ID"
  598. // @Param cycletype query int true "周期类型 - 0:日 1:月 2:季 3:年 4:周 5:全报表【原值】"
  599. // @Param cycletime query string true "周期时间 日(YYYYMMDD) 月(YYYYMM) 季(YYYYQ) 年(YYYY) 周(YYYYMMDD周内任意一天) 全(0)【原值】"
  600. // @Param spotcontractid query int fasle "合同id"
  601. // @Param middlegoodsid query int fasle "套保品种id"
  602. // @Param deliverygoodsid query int fasle "现货品种id"
  603. // @Param wrstandardid query int fasle "现货商品id"
  604. // @Param contractno query string fasle "合同编号(模糊匹配)"
  605. // @Success 200 {array} models.Ermcp3SCMiddleGoodsReport
  606. // @Failure 500 {object} app.Response
  607. // @Router /Ermcp3/QrySCMiddleGoodsReport [get]
  608. // @Tags 企业风险管理v3(app)
  609. func QrySCMiddleGoodsReport(c *gin.Context) {
  610. a := app.GinUtils{Gin: app.Gin{C: c}}
  611. m := models.Ermcp3SCMiddleGoodsReport{}
  612. req := QryReportReq{}
  613. a.DoBindReq(&req)
  614. req.QUERYTYPE = 1 // 查询报表
  615. a.CheckParam(&req)
  616. req.CovertRequest()
  617. a.DoBindReq(&m)
  618. m.RECKONDATE, m.CYCLETYPE, m.CYCLETIME = req.TRADEDATE, req.CYCLETYPE, req.CYCLETIME
  619. m.BeginDate, m.EndDate, m.QueryType = req.BEGINDATE, req.ENDDATE, req.QUERYTYPE
  620. a.DoGetDataI(&m)
  621. }