ermcpAreaStock.go 19 KB

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