qryErmcp3Report.go 27 KB

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