ermcpAreaStock.go 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412
  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. // 出入库类型
  129. if r.INOUTTYPE > 0 {
  130. sqlId.And("t.INOUTTYPE", r.INOUTTYPE)
  131. }
  132. // 合同id
  133. if len(r.SPOTCONTRACTID) > 0 {
  134. sqlId.And("t.SPOTCONTRACTID", r.SPOTCONTRACTID)
  135. }
  136. // 现货商品id
  137. if len(r.WRSTANDARDID) > 0 {
  138. sqlId.And("t.WRSTANDARDID", r.WRSTANDARDID)
  139. }
  140. // 品牌id
  141. if r.SPOTGOODSBRANDID > 0 {
  142. sqlId.And("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID)
  143. }
  144. // 型号id
  145. if r.SPOTGOODSMODELID > 0 {
  146. sqlId.And("t.SPOTGOODSMODELID", r.SPOTGOODSMODELID)
  147. }
  148. // 仓库id
  149. if len(r.WAREHOUSEINFOID) > 0 {
  150. sqlId.And("t.WAREHOUSEINFOID", r.WAREHOUSEINFOID)
  151. }
  152. // 日期范围
  153. if len(r.BeginDate) > 0 {
  154. if r.BeginDate == r.EndDate {
  155. sqlId.And("t.audittradedate", r.BeginDate)
  156. }else if r.EndDate > r.BeginDate {
  157. sqlId.BiggerOrEq("t.audittradedate", r.BeginDate)
  158. sqlId.LessOrEq("t.audittradedate", r.EndDate)
  159. }
  160. }
  161. // 出入库状态
  162. if len(r.FilterStatus) > 0 {
  163. sqlId.Join(fmt.Sprintf(" and t.APPLYSTATUS in(%v)", r.FilterStatus))
  164. }
  165. // 排序
  166. sqlId.Join(" order by t.APPLYTIME desc")
  167. return sqlId.String()
  168. }
  169. // 查询库存申请(记录)
  170. func (r *ErmcpAreaStockApply) GetDataEx() (interface{}, error) {
  171. sData := make([]ErmcpAreaStockApply, 0)
  172. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  173. if err == nil {
  174. for i := range sData {
  175. sData[i].calc()
  176. }
  177. }
  178. return sData, err
  179. }
  180. // ErmcpAreaStockApplySum 合同出入库数量汇总
  181. type ErmcpAreaStockApplySum struct {
  182. INOUTTYPE int32 `json:"inouttype" xorm:"'INOUTTYPE'"` // 出入库类型 - 1:采购入库 2:销售出库 3:生产入库 4:生产出库
  183. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 型号id
  184. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 品牌id
  185. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  186. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  187. TOTALQTY float64 `json:"totalqty" xorm:"'TOTALQTY'"` // 总数量
  188. SPOTCONTRACTID string `json:"spotcontractid" xorm:"'SPOTCONTRACTID'"` // 关联现货合同ID
  189. }
  190. func (r *ErmcpAreaStockApplySum) buildSql() string {
  191. sqlId := "select a.*, gb.brandname, gm.modelname" +
  192. " from (SELECT t.INOUTTYPE," +
  193. " t.SPOTGOODSMODELID," +
  194. " t.SPOTGOODSBRANDID," +
  195. " sum(t.QTY) TOTALQTY" +
  196. " FROM ERMCP_AREAINOUTSTOCKAPPLY t" +
  197. " WHERE t.applystatus= 2 and t.inouttype = %v and t.spotcontractid = %v" +
  198. " group by t.inouttype, t.spotgoodsbrandid, t.spotgoodsmodelid) a" +
  199. " left join spotgoodsbrand gb" +
  200. " on a.spotgoodsbrandid = gb.brandid" +
  201. " left join spotgoodsmodel gm" +
  202. " on a.spotgoodsmodelid = gm.modelid"
  203. sqlId = fmt.Sprintf(sqlId, r.INOUTTYPE, r.SPOTCONTRACTID)
  204. return sqlId
  205. }
  206. // GetDataEx 获取合同出入库汇总信息
  207. func (r *ErmcpAreaStockApplySum) GetDataEx() (interface{}, error) {
  208. sData := make([]ErmcpAreaStockApplySum, 0)
  209. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  210. return sData, err
  211. }
  212. // ErmcpAreaStock 机构库存表
  213. type ErmcpAreaStock struct {
  214. TODAYBUYINQTY float64 `json:"todaybuyinqty" xorm:"'TODAYBUYINQTY'"` // 今日采购入库量
  215. TODAYPRODUCEINQTY float64 `json:"todayproduceinqty" xorm:"'TODAYPRODUCEINQTY'"` // 今日生产入库量
  216. TODAYSELLOUTQTY float64 `json:"todayselloutqty" xorm:"'TODAYSELLOUTQTY'"` // 今日销售出库量
  217. TODAYPRODUCEOUTQTY float64 `json:"todayproduceoutqty" xorm:"'TODAYPRODUCEOUTQTY'"` // 今日生产出库量
  218. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  219. USERID int64 `json:"userid" xorm:"'USERID'"` // 机构ID
  220. WRSTANDARDID string `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  221. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 现货型号ID
  222. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 现货品牌ID
  223. WAREHOUSEINFOID string `json:"warehouseinfoid" xorm:"'WAREHOUSEINFOID'"` // 仓库ID
  224. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  225. ORISTOCK float64 `json:"oristock" xorm:"'ORISTOCK'"` // 期初库存量(昨日量)
  226. CURSTOCK float64 `json:"curstock" xorm:"'CURSTOCK'"` // 期末库存量(今日量)
  227. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  228. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  229. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位id
  230. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  231. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  232. WAREHOUSENAME string `json:"warehousename" xorm:"'WAREHOUSENAME'"` // 仓库名称
  233. WAREHOUSECODE string `json:"warehousecode" xorm:"'WAREHOUSECODE'"` // 仓库代码
  234. WAREHOUSETYPE int32 `json:"warehousetype" xorm:"'WAREHOUSETYPE'"` // 仓库类型 - 1 厂库 2 自有库 3 合作库
  235. USERNAME string `json:"username"` // 机构名称
  236. ENUMDICNAME string `json:"enumdicname"` // 单位名称
  237. }
  238. func (r *ErmcpAreaStock) calc() {
  239. r.USERNAME = mtpcache.GetUserNameByUserId(r.USERID)
  240. r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
  241. }
  242. func (r *ErmcpAreaStock) buildSql() string {
  243. var sqlId utils.SQLVal = "SELECT t.TODAYBUYINQTY," +
  244. " t.TODAYPRODUCEINQTY," +
  245. " t.TODAYSELLOUTQTY," +
  246. " t.TODAYPRODUCEOUTQTY," +
  247. " to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
  248. " t.USERID," +
  249. " t.WRSTANDARDID," +
  250. " t.SPOTGOODSMODELID," +
  251. " t.SPOTGOODSBRANDID," +
  252. " t.WAREHOUSEINFOID," +
  253. " t.DELIVERYGOODSID," +
  254. " t.ORISTOCK," +
  255. " t.CURSTOCK," +
  256. " w.wrstandardname," +
  257. " w.wrstandardcode," +
  258. " w.unitid," +
  259. " gb.brandname," +
  260. " gm.modelname," +
  261. " h.warehousename," +
  262. " h.warehousecode," +
  263. " h.warehousetype" +
  264. " FROM ERMCP_AREASTOCK t" +
  265. " LEFT JOIN WRSTANDARD w" +
  266. " on t.wrstandardid = w.wrstandardid" +
  267. " LEFT JOIN SPOTGOODSBRAND gb" +
  268. " on t.spotgoodsbrandid = gb.brandid" +
  269. " LEFT JOIN SPOTGOODSMODEL gm" +
  270. " on t.spotgoodsmodelid = gm.modelid" +
  271. " LEFT JOIN WAREHOUSEINFO h" +
  272. " on t.warehouseinfoid = h.autoid" +
  273. " WHERE 1 = 1"
  274. sqlId.And("t.USERID", r.USERID)
  275. sqlId.Join(" order by t.WRSTANDARDID, t.UPDATETIME desc")
  276. return sqlId.String()
  277. }
  278. // GetDataEx 获取机构库存信息
  279. func (r *ErmcpAreaStock) GetDataEx() (interface{}, error) {
  280. sData := make([]ErmcpAreaStock, 0)
  281. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  282. if err == nil {
  283. for i := range sData {
  284. sData[i].calc()
  285. }
  286. }
  287. return sData, err
  288. }
  289. // ErmcpAreaStockReport 库存报表
  290. type ErmcpAreaStockReport struct {
  291. USERID int64 `json:"userid" xorm:"'USERID'"` // 机构ID
  292. WRSTANDARDID string `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  293. SPOTGOODSMODELID int32 `json:"spotgoodsmodelid" xorm:"'SPOTGOODSMODELID'"` // 现货型号ID
  294. SPOTGOODSBRANDID int32 `json:"spotgoodsbrandid" xorm:"'SPOTGOODSBRANDID'"` // 现货品牌ID
  295. WAREHOUSEINFOID string `json:"warehouseinfoid" xorm:"'WAREHOUSEINFOID'"` // 仓库ID
  296. DELIVERYGOODSID int64 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  297. ORISTOCK float64 `json:"oristock" xorm:"'ORISTOCK'"` // 期初库存量
  298. CURSTOCK float64 `json:"curstock" xorm:"'CURSTOCK'"` // 期末库存量
  299. TODAYBUYINQTY float64 `json:"todaybuyinqty" xorm:"'TODAYBUYINQTY'"` // 今日采购入库量
  300. TODAYPRODUCEINQTY float64 `json:"todayproduceinqty" xorm:"'TODAYPRODUCEINQTY'"` // 今日生产入库量
  301. TODAYSELLOUTQTY float64 `json:"todayselloutqty" xorm:"'TODAYSELLOUTQTY'"` // 今日销售出库量
  302. TODAYPRODUCEOUTQTY float64 `json:"todayproduceoutqty" xorm:"'TODAYPRODUCEOUTQTY'"` // 今日生产出库量
  303. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  304. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  305. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  306. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位id
  307. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  308. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  309. WAREHOUSENAME string `json:"warehousename" xorm:"'WAREHOUSENAME'"` // 仓库名称
  310. WAREHOUSECODE string `json:"warehousecode" xorm:"'WAREHOUSECODE'"` // 仓库代码
  311. WAREHOUSETYPE int32 `json:"warehousetype" xorm:"'WAREHOUSETYPE'"` // 仓库类型 - 1 厂库 2 自有库 3 合作库
  312. USERNAME string `json:"username"` // 机构名称
  313. ENUMDICNAME string `json:"enumdicname"` // 单位名称
  314. ReportType int32 `json:"-"` // 报表类型 1-日报表 2-月报表
  315. ReportDate string `json:"-"` // 格式 日报表(YYYYMMDD) 月报表(YYYYMM)
  316. }
  317. func (r *ErmcpAreaStockReport) calc() {
  318. r.USERNAME = mtpcache.GetUserNameByUserId(r.USERID)
  319. r.ENUMDICNAME = mtpcache.GetEnumDicitemName(r.UNITID)
  320. }
  321. func (r *ErmcpAreaStockReport) buildSql() string {
  322. var sqlId utils.SQLVal = "SELECT t.TODAYBUYINQTY," +
  323. " t.TODAYPRODUCEINQTY," +
  324. " t.TODAYSELLOUTQTY," +
  325. " t.TODAYPRODUCEOUTQTY," +
  326. " to_char(t.UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
  327. " t.USERID," +
  328. " t.WRSTANDARDID," +
  329. " t.SPOTGOODSMODELID," +
  330. " t.SPOTGOODSBRANDID," +
  331. " t.WAREHOUSEINFOID," +
  332. " t.DELIVERYGOODSID," +
  333. " t.ORISTOCK," +
  334. " t.CURSTOCK," +
  335. " w.wrstandardname," +
  336. " w.wrstandardcode," +
  337. " w.unitid," +
  338. " gb.brandname," +
  339. " gm.modelname," +
  340. " h.warehousename," +
  341. " h.warehousecode," +
  342. " h.warehousetype" +
  343. " FROM %v t" +
  344. " LEFT JOIN WRSTANDARD w" +
  345. " on t.wrstandardid = w.wrstandardid" +
  346. " LEFT JOIN SPOTGOODSBRAND gb" +
  347. " on t.spotgoodsbrandid = gb.brandid" +
  348. " LEFT JOIN SPOTGOODSMODEL gm" +
  349. " on t.spotgoodsmodelid = gm.modelid" +
  350. " LEFT JOIN WAREHOUSEINFO h" +
  351. " on t.warehouseinfoid = h.autoid" +
  352. " WHERE 1 = 1"
  353. sqlId.And("t.USERID", r.USERID)
  354. if r.ReportType == 1 {
  355. // 日报表
  356. sqlId.FormatParam("RECKON_ERMCP_AREASTOCK")
  357. sqlId.And("t.reckondate", r.ReportDate)
  358. } else {
  359. // 月报表
  360. sqlId.FormatParam("REPORT_ERMCP_AREASTOCK")
  361. sqlId.And("t.cycletype", 1)
  362. sqlId.And("t.cycletime", r.ReportDate)
  363. }
  364. // 现货商品id
  365. if len(r.WRSTANDARDID) > 0 {
  366. sqlId.And("t.WRSTANDARDID", r.WRSTANDARDID)
  367. }
  368. // 品牌id
  369. if r.SPOTGOODSBRANDID > 0 {
  370. sqlId.And("t.SPOTGOODSBRANDID", r.SPOTGOODSBRANDID)
  371. }
  372. // 型号id
  373. if r.SPOTGOODSMODELID > 0 {
  374. sqlId.And("t.SPOTGOODSMODELID", r.SPOTGOODSMODELID)
  375. }
  376. // 仓库id
  377. if len(r.WAREHOUSEINFOID) > 0 {
  378. sqlId.And("t.WAREHOUSEINFOID", r.WAREHOUSEINFOID)
  379. }
  380. return sqlId.String()
  381. }
  382. // GetDataEx 查询库存报表
  383. func (r *ErmcpAreaStockReport) GetDataEx() (interface{}, error) {
  384. sData := make([]ErmcpAreaStockReport, 0)
  385. err := db.GetEngine().SQL(r.buildSql()).Find(&sData)
  386. if err == nil {
  387. for i := range sData {
  388. sData[i].calc()
  389. }
  390. }
  391. return sData, err
  392. }