ermcpAreaStock.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435
  1. /**
  2. * @Author: zou.yingbin
  3. * @Create : 2021/3/10 9:13
  4. * @Modify : 2021/3/10 9:13
  5. */
  6. package models
  7. import (
  8. "fmt"
  9. "mtp2_if/db"
  10. "mtp2_if/mtpcache"
  11. "mtp2_if/utils"
  12. )
  13. // ErmcpAreaStockApply 出入库申请
  14. type ErmcpAreaStockApply struct {
  15. INOUTAPPLYID string `json:"inoutapplyid" xorm:"'INOUTAPPLYID'"` // 申请ID(607+Unix秒时间戳(10位)+xxxxxx)
  16. USERID int64 `json:"userid" xorm:"'USERID'"` // 机构ID
  17. INOUTTYPE int32 `json:"inouttype" xorm:"'INOUTTYPE'"` // 出入库类型 - 1:采购入库 2:销售出库 3:生产入库 4:生产出库
  18. WRSTANDARDID string `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  19. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 现货型号ID
  20. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 现货品牌ID
  21. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  22. SPOTCONTRACTID string `json:"spotcontractid" xorm:"'SPOTCONTRACTID'"` // 关联现货合同ID
  23. WAREHOUSEINFOID string `json:"warehouseinfoid" xorm:"'WAREHOUSEINFOID'"` // 现货仓库ID
  24. QTY float64 `json:"qty" xorm:"'QTY'"` // 数量
  25. APPLYSTATUS int32 `json:"applystatus" xorm:"'APPLYSTATUS'"` // 申请状态 - 1:待审核 2:审核通过 3:审核拒绝 4:处理失败 5:已撤回
  26. APPLYSRC int32 `json:"applysrc" xorm:"'APPLYSRC'"` // 申请来源 - 1:管理端 2:终端
  27. APPLYID int64 `json:"applyid" xorm:"'APPLYID'"` // 申请人
  28. APPLYREMARK string `json:"applyremark" xorm:"'APPLYREMARK'"` // 申请备注
  29. APPLYTIME string `json:"applytime" xorm:"'APPLYTIME'"` // 申请时间
  30. AUDITSRC int32 `json:"auditsrc" xorm:"'AUDITSRC'"` // 审核来源 - 1:管理端 2:终端
  31. AUDITID int64 `json:"auditid" xorm:"'AUDITID'"` // 审核人
  32. AUDITTIME string `json:"audittime" xorm:"'AUDITTIME'"` // 审核时间
  33. AUDITREMARK string `json:"auditremark" xorm:"'AUDITREMARK'"` // 审核备注
  34. AUDITTRADEDATE string `json:"audittradedate" xorm:"'AUDITTRADEDATE'"` // 审核交易日(yyyyMMdd)
  35. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  36. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  37. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位id
  38. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  39. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  40. WAREHOUSENAME string `json:"warehousename" xorm:"'WAREHOUSENAME'"` // 仓库名称
  41. WAREHOUSECODE string `json:"warehousecode" xorm:"'WAREHOUSECODE'"` // 仓库代码
  42. WAREHOUSETYPE int32 `json:"warehousetype" xorm:"'WAREHOUSETYPE'"` // 仓库类型 - 1 厂库 2 自有库 3 合作库
  43. CONTRACTNO string `json:"contractno" xorm:"'CONTRACTNO'"` // 合同编号
  44. CONTRACTTYPE int32 `json:"contracttype" xorm:"'CONTRACTTYPE'"` // 现货合同类型 - 1:采购 -1:销售
  45. BUYUSERID int64 `json:"buyuserid" xorm:"'BUYUSERID'"` // 采购方userid
  46. SELLUSERID int64 `json:"selluserid" xorm:"'SELLUSERID'"` // 销售方userid
  47. PRICETYPE int32 `json:"pricetype" xorm:"'PRICETYPE'"` // 定价类型 - 1:一口价 2:点价 3:暂定价
  48. CONTRACTQTY float64 `json:"contractqty" xorm:"'CONTRACTQTY'"` // 合同量
  49. BUYUSERNAME string `json:"buyusername"` // 采购方名称
  50. SELLUSERNAME string `json:"sellusername"` // 销售方名称
  51. APPLYNAME string `json:"applyname"` // 申请人名称
  52. AUDITNAME string `json:"auditname"` // 审核人名称
  53. ENUMDICNAME string `json:"enumdicname"` // 现货商品单位名称
  54. FilterStatus string `json:"-"` // 查询条件, 申请状态, 逗号隔开
  55. FilterType string `json:"-"` // 查询条件, 出入库类型, 逗号隔开
  56. BeginDate string `json:"-"` // 开始日期
  57. EndDate string `json:"-"` // 结束日期
  58. }
  59. func (r *ErmcpAreaStockApply) calc() {
  60. // 采购方名称
  61. r.BUYUSERNAME = mtpcache.GetUserNameByUserId(r.BUYUSERID)
  62. // 销售方名称
  63. r.SELLUSERNAME = mtpcache.GetUserNameByUserId(r.SELLUSERID)
  64. // 申请人名称
  65. if r.APPLYSRC == 1 {
  66. r.APPLYNAME = mtpcache.GetSystemmangerLoginCode(r.APPLYID)
  67. } else {
  68. r.APPLYNAME = mtpcache.GetLoginCodeByLoginId(r.APPLYID)
  69. }
  70. // 审核人名称
  71. if r.AUDITSRC == 1 {
  72. r.AUDITNAME = mtpcache.GetSystemmangerLoginCode(r.AUDITID)
  73. } else {
  74. r.AUDITNAME = mtpcache.GetLoginCodeByLoginId(r.AUDITID)
  75. }
  76. // 单位名称
  77. r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
  78. }
  79. func (r *ErmcpAreaStockApply) buildSql() string {
  80. var sqlId utils.SQLVal = "SELECT to_char(t.INOUTAPPLYID) INOUTAPPLYID," +
  81. " t.USERID," +
  82. " t.INOUTTYPE," +
  83. " t.WRSTANDARDID," +
  84. " t.SPOTGOODSMODELID," +
  85. " t.SPOTGOODSBRANDID," +
  86. " t.DELIVERYGOODSID," +
  87. " to_char(t.SPOTCONTRACTID) SPOTCONTRACTID," +
  88. " to_char(t.WAREHOUSEINFOID) WAREHOUSEINFOID," +
  89. " t.QTY," +
  90. " t.APPLYSTATUS," +
  91. " t.APPLYSRC," +
  92. " t.APPLYID," +
  93. " t.APPLYREMARK," +
  94. " to_char(t.APPLYTIME, 'yyyy-mm-dd hh24:mi:ss') APPLYTIME," +
  95. " t.AUDITSRC," +
  96. " t.AUDITID," +
  97. " to_char(t.AUDITTIME, 'yyyy-mm-dd hh24:mi:ss') AUDITTIME," +
  98. " t.AUDITREMARK," +
  99. " t.AUDITTRADEDATE," +
  100. " w.wrstandardname," +
  101. " w.wrstandardcode," +
  102. " w.unitid," +
  103. " gb.brandname," +
  104. " gm.modelname," +
  105. " h.warehousename," +
  106. " h.warehousecode," +
  107. " h.warehousetype," +
  108. " s.contractno," +
  109. " s.contracttype," +
  110. " s.buyuserid," +
  111. " s.selluserid," +
  112. " s.pricetype," +
  113. " s.qty CONTRACTQTY" +
  114. " FROM ERMCP_AREAINOUTSTOCKAPPLY t" +
  115. " left join wrstandard w" +
  116. " on t.wrstandardid = w.wrstandardid" +
  117. " left join spotgoodsbrand gb" +
  118. " on t.spotgoodsbrandid = gb.brandid" +
  119. " left join spotgoodsmodel gm" +
  120. " on t.spotgoodsmodelid = gm.modelid" +
  121. " left join warehouseinfo h" +
  122. " on t.warehouseinfoid = h.autoid" +
  123. " left join ermcp_spotcontract s" +
  124. " on t.spotcontractid = s.spotcontractid" +
  125. " WHERE 1 = 1"
  126. // 用户id(必要条件)
  127. sqlId.And("t.USERID", r.USERID)
  128. // 合同id
  129. if len(r.SPOTCONTRACTID) > 0 {
  130. sqlId.And("t.SPOTCONTRACTID", r.SPOTCONTRACTID)
  131. }
  132. // 现货商品id
  133. if len(r.WRSTANDARDID) > 0 {
  134. sqlId.And("t.WRSTANDARDID", r.WRSTANDARDID)
  135. }
  136. // 品牌id
  137. if r.SPOTGOODSBRANDID > 0 {
  138. sqlId.And("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID)
  139. }
  140. // 型号id
  141. if r.SPOTGOODSMODELID > 0 {
  142. sqlId.And("t.SPOTGOODSMODELID", r.SPOTGOODSMODELID)
  143. }
  144. // 仓库id
  145. if len(r.WAREHOUSEINFOID) > 0 {
  146. sqlId.And("t.WAREHOUSEINFOID", r.WAREHOUSEINFOID)
  147. }
  148. // 日期范围
  149. if len(r.BeginDate) > 0 {
  150. if r.BeginDate == r.EndDate {
  151. sqlId.And("t.audittradedate", r.BeginDate)
  152. } else if r.EndDate > r.BeginDate {
  153. sqlId.BiggerOrEq("t.audittradedate", r.BeginDate)
  154. sqlId.LessOrEq("t.audittradedate", r.EndDate)
  155. }
  156. }
  157. // 出入库类型
  158. if len(r.FilterType) > 0 {
  159. if len(r.FilterType) == 1 {
  160. sqlId.And("t.INOUTTYPE", r.FilterType)
  161. } else {
  162. sqlId.Join(fmt.Sprintf(" and t.INOUTTYPE in(%v)", r.FilterType))
  163. }
  164. }
  165. // 出入库状态
  166. if len(r.FilterStatus) > 0 {
  167. sqlId.Join(fmt.Sprintf(" and t.APPLYSTATUS in(%v)", r.FilterStatus))
  168. }
  169. // 排序
  170. sqlId.Join(" order by t.APPLYTIME desc")
  171. return sqlId.String()
  172. }
  173. // 查询库存申请(记录)
  174. func (r *ErmcpAreaStockApply) GetDataEx() (interface{}, error) {
  175. sData := make([]ErmcpAreaStockApply, 0)
  176. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  177. if err == nil {
  178. for i := range sData {
  179. sData[i].calc()
  180. }
  181. }
  182. return sData, err
  183. }
  184. // ErmcpAreaStockApplySum 合同出入库数量汇总
  185. type ErmcpAreaStockApplySum struct {
  186. INOUTTYPE int32 `json:"inouttype" xorm:"'INOUTTYPE'"` // 出入库类型 - 1:采购入库 2:销售出库 3:生产入库 4:生产出库
  187. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 型号id
  188. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 品牌id
  189. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  190. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  191. TOTALQTY float64 `json:"totalqty" xorm:"'TOTALQTY'"` // 总数量
  192. SPOTCONTRACTID string `json:"spotcontractid" xorm:"'SPOTCONTRACTID'"` // 关联现货合同ID
  193. }
  194. func (r *ErmcpAreaStockApplySum) buildSql() string {
  195. sqlId := "select a.*, gb.brandname, gm.modelname" +
  196. " from (SELECT t.INOUTTYPE," +
  197. " t.SPOTGOODSMODELID," +
  198. " t.SPOTGOODSBRANDID," +
  199. " t.SPOTCONTRACTID," +
  200. " sum(t.QTY) TOTALQTY" +
  201. " FROM ERMCP_AREAINOUTSTOCKAPPLY t" +
  202. " WHERE t.applystatus= 2 and t.spotcontractid = %v" +
  203. " group by t.inouttype, t.spotgoodsbrandid, t.spotgoodsmodelid, t.spotcontractid) a" +
  204. " left join spotgoodsbrand gb" +
  205. " on a.spotgoodsbrandid = gb.brandid" +
  206. " left join spotgoodsmodel gm" +
  207. " on a.spotgoodsmodelid = gm.modelid"
  208. sqlId = fmt.Sprintf(sqlId, r.SPOTCONTRACTID)
  209. // 不关联合同id
  210. sqlId2 := "select a.*, gb.brandname, gm.modelname" +
  211. " from (SELECT t.INOUTTYPE," +
  212. " t.SPOTGOODSMODELID," +
  213. " t.SPOTGOODSBRANDID," +
  214. " t.SPOTCONTRACTID," +
  215. " sum(t.QTY) TOTALQTY" +
  216. " FROM ERMCP_AREAINOUTSTOCKAPPLY t" +
  217. " WHERE t.applystatus= 2" +
  218. " group by t.inouttype, t.spotgoodsbrandid, t.spotgoodsmodelid, t.SPOTCONTRACTID) a" +
  219. " left join spotgoodsbrand gb" +
  220. " on a.spotgoodsbrandid = gb.brandid" +
  221. " left join spotgoodsmodel gm" +
  222. " on a.spotgoodsmodelid = gm.modelid"
  223. if len(r.SPOTCONTRACTID) == 0 {
  224. return sqlId2
  225. }
  226. return sqlId
  227. }
  228. // GetDataEx 获取合同出入库汇总信息
  229. func (r *ErmcpAreaStockApplySum) GetDataEx() (interface{}, error) {
  230. sData := make([]ErmcpAreaStockApplySum, 0)
  231. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  232. return sData, err
  233. }
  234. // ErmcpAreaStock 机构库存表
  235. type ErmcpAreaStock struct {
  236. TODAYBUYINQTY float64 `json:"todaybuyinqty" xorm:"'TODAYBUYINQTY'"` // 今日采购入库量
  237. TODAYPRODUCEINQTY float64 `json:"todayproduceinqty" xorm:"'TODAYPRODUCEINQTY'"` // 今日生产入库量
  238. TODAYSELLOUTQTY float64 `json:"todayselloutqty" xorm:"'TODAYSELLOUTQTY'"` // 今日销售出库量
  239. TODAYPRODUCEOUTQTY float64 `json:"todayproduceoutqty" xorm:"'TODAYPRODUCEOUTQTY'"` // 今日生产出库量
  240. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  241. USERID int64 `json:"userid" xorm:"'USERID'"` // 机构ID
  242. WRSTANDARDID string `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  243. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 现货型号ID
  244. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 现货品牌ID
  245. WAREHOUSEINFOID string `json:"warehouseinfoid" xorm:"'WAREHOUSEINFOID'"` // 仓库ID
  246. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  247. ORISTOCK float64 `json:"oristock" xorm:"'ORISTOCK'"` // 期初库存量(昨日量)
  248. CURSTOCK float64 `json:"curstock" xorm:"'CURSTOCK'"` // 期末库存量(今日量)
  249. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  250. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  251. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位id
  252. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  253. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  254. WAREHOUSENAME string `json:"warehousename" xorm:"'WAREHOUSENAME'"` // 仓库名称
  255. WAREHOUSECODE string `json:"warehousecode" xorm:"'WAREHOUSECODE'"` // 仓库代码
  256. WAREHOUSETYPE int32 `json:"warehousetype" xorm:"'WAREHOUSETYPE'"` // 仓库类型 - 1 厂库 2 自有库 3 合作库
  257. USERNAME string `json:"username"` // 机构名称
  258. ENUMDICNAME string `json:"enumdicname"` // 单位名称
  259. }
  260. func (r *ErmcpAreaStock) calc() {
  261. r.USERNAME = mtpcache.GetUserNameByUserId(r.USERID)
  262. r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
  263. }
  264. func (r *ErmcpAreaStock) buildSql() string {
  265. var sqlId utils.SQLVal = "SELECT t.TODAYBUYINQTY," +
  266. " t.TODAYPRODUCEINQTY," +
  267. " t.TODAYSELLOUTQTY," +
  268. " t.TODAYPRODUCEOUTQTY," +
  269. " to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
  270. " t.USERID," +
  271. " t.WRSTANDARDID," +
  272. " t.SPOTGOODSMODELID," +
  273. " t.SPOTGOODSBRANDID," +
  274. " t.WAREHOUSEINFOID," +
  275. " t.DELIVERYGOODSID," +
  276. " t.ORISTOCK," +
  277. " t.CURSTOCK," +
  278. " w.wrstandardname," +
  279. " w.wrstandardcode," +
  280. " w.unitid," +
  281. " gb.brandname," +
  282. " gm.modelname," +
  283. " h.warehousename," +
  284. " h.warehousecode," +
  285. " h.warehousetype" +
  286. " FROM ERMCP_AREASTOCK t" +
  287. " LEFT JOIN WRSTANDARD w" +
  288. " on t.wrstandardid = w.wrstandardid" +
  289. " LEFT JOIN SPOTGOODSBRAND gb" +
  290. " on t.spotgoodsbrandid = gb.brandid" +
  291. " LEFT JOIN SPOTGOODSMODEL gm" +
  292. " on t.spotgoodsmodelid = gm.modelid" +
  293. " LEFT JOIN WAREHOUSEINFO h" +
  294. " on t.warehouseinfoid = h.autoid" +
  295. " WHERE 1 = 1"
  296. sqlId.And("t.USERID", r.USERID)
  297. sqlId.Join(" order by t.WRSTANDARDID, t.UPDATETIME desc")
  298. return sqlId.String()
  299. }
  300. // GetDataEx 获取机构库存信息
  301. func (r *ErmcpAreaStock) GetDataEx() (interface{}, error) {
  302. sData := make([]ErmcpAreaStock, 0)
  303. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  304. if err == nil {
  305. for i := range sData {
  306. sData[i].calc()
  307. }
  308. }
  309. return sData, err
  310. }
  311. // ErmcpAreaStockReport 库存报表
  312. type ErmcpAreaStockReport struct {
  313. USERID int64 `json:"userid" xorm:"'USERID'"` // 机构ID
  314. WRSTANDARDID string `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  315. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 现货型号ID
  316. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 现货品牌ID
  317. WAREHOUSEINFOID string `json:"warehouseinfoid" xorm:"'WAREHOUSEINFOID'"` // 仓库ID
  318. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  319. ORISTOCK float64 `json:"oristock" xorm:"'ORISTOCK'"` // 期初库存量
  320. CURSTOCK float64 `json:"curstock" xorm:"'CURSTOCK'"` // 期末库存量
  321. TODAYBUYINQTY float64 `json:"todaybuyinqty" xorm:"'TODAYBUYINQTY'"` // 今日采购入库量
  322. TODAYPRODUCEINQTY float64 `json:"todayproduceinqty" xorm:"'TODAYPRODUCEINQTY'"` // 今日生产入库量
  323. TODAYSELLOUTQTY float64 `json:"todayselloutqty" xorm:"'TODAYSELLOUTQTY'"` // 今日销售出库量
  324. TODAYPRODUCEOUTQTY float64 `json:"todayproduceoutqty" xorm:"'TODAYPRODUCEOUTQTY'"` // 今日生产出库量
  325. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  326. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  327. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  328. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位id
  329. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  330. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  331. WAREHOUSENAME string `json:"warehousename" xorm:"'WAREHOUSENAME'"` // 仓库名称
  332. WAREHOUSECODE string `json:"warehousecode" xorm:"'WAREHOUSECODE'"` // 仓库代码
  333. WAREHOUSETYPE int32 `json:"warehousetype" xorm:"'WAREHOUSETYPE'"` // 仓库类型 - 1 厂库 2 自有库 3 合作库
  334. USERNAME string `json:"username"` // 机构名称
  335. ENUMDICNAME string `json:"enumdicname"` // 单位名称
  336. ReportType int32 `json:"-"` // 报表类型 1-日报表 2-月报表
  337. ReportDate string `json:"-"` // 格式 日报表(YYYYMMDD) 月报表(YYYYMM)
  338. }
  339. func (r *ErmcpAreaStockReport) calc() {
  340. r.USERNAME = mtpcache.GetUserNameByUserId(r.USERID)
  341. r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
  342. }
  343. func (r *ErmcpAreaStockReport) buildSql() string {
  344. var sqlId utils.SQLVal = "SELECT t.TODAYBUYINQTY," +
  345. " t.TODAYPRODUCEINQTY," +
  346. " t.TODAYSELLOUTQTY," +
  347. " t.TODAYPRODUCEOUTQTY," +
  348. " to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
  349. " t.USERID," +
  350. " t.WRSTANDARDID," +
  351. " t.SPOTGOODSMODELID," +
  352. " t.SPOTGOODSBRANDID," +
  353. " t.WAREHOUSEINFOID," +
  354. " t.DELIVERYGOODSID," +
  355. " t.ORISTOCK," +
  356. " t.CURSTOCK," +
  357. " w.wrstandardname," +
  358. " w.wrstandardcode," +
  359. " w.unitid," +
  360. " gb.brandname," +
  361. " gm.modelname," +
  362. " h.warehousename," +
  363. " h.warehousecode," +
  364. " h.warehousetype" +
  365. " FROM %v t" +
  366. " LEFT JOIN WRSTANDARD w" +
  367. " on t.wrstandardid = w.wrstandardid" +
  368. " LEFT JOIN SPOTGOODSBRAND gb" +
  369. " on t.spotgoodsbrandid = gb.brandid" +
  370. " LEFT JOIN SPOTGOODSMODEL gm" +
  371. " on t.spotgoodsmodelid = gm.modelid" +
  372. " LEFT JOIN WAREHOUSEINFO h" +
  373. " on t.warehouseinfoid = h.autoid" +
  374. " WHERE 1 = 1"
  375. sqlId.And("t.USERID", r.USERID)
  376. if r.ReportType == 1 {
  377. // 日报表
  378. sqlId.FormatParam("RECKON_ERMCP_AREASTOCK")
  379. sqlId.And("t.reckondate", r.ReportDate)
  380. } else {
  381. // 月报表
  382. sqlId.FormatParam("REPORT_ERMCP_AREASTOCK")
  383. sqlId.And("t.cycletype", 1)
  384. sqlId.And("t.cycletime", r.ReportDate)
  385. }
  386. // 现货商品id
  387. if len(r.WRSTANDARDID) > 0 {
  388. sqlId.And("t.WRSTANDARDID", r.WRSTANDARDID)
  389. }
  390. // 品牌id
  391. if r.SPOTGOODSBRANDID > 0 {
  392. sqlId.And("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID)
  393. }
  394. // 型号id
  395. if r.SPOTGOODSMODELID > 0 {
  396. sqlId.And("t.SPOTGOODSMODELID", r.SPOTGOODSMODELID)
  397. }
  398. // 仓库id
  399. if len(r.WAREHOUSEINFOID) > 0 {
  400. sqlId.And("t.WAREHOUSEINFOID", r.WAREHOUSEINFOID)
  401. }
  402. return sqlId.String()
  403. }
  404. // GetDataEx 查询库存报表
  405. func (r *ErmcpAreaStockReport) GetDataEx() (interface{}, error) {
  406. sData := make([]ErmcpAreaStockReport, 0)
  407. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  408. if err == nil {
  409. for i := range sData {
  410. sData[i].calc()
  411. }
  412. }
  413. return sData, err
  414. }