ermcpWrstandard.go 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240
  1. /**
  2. * @Author: zou.yingbin
  3. * @Create : 2021/1/13 11:16
  4. * @Modify : 2021/1/13 11:16
  5. */
  6. package models
  7. import (
  8. "fmt"
  9. "mtp2_if/db"
  10. "mtp2_if/logger"
  11. )
  12. // 现货商品表
  13. type ErmcpWrstandard struct {
  14. WRSTANDARDID int64 `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID(SEQ_WRSTANDARD)
  15. WRSTANDARDCODE string `json:"wrstandardcode" xorm:"'WRSTANDARDCODE'"` // 现货商品代码
  16. DELIVERYGOODSID int32 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 品种ID
  17. UNITID int32 `json:"unitid" xorm:"'UNITID'"` // 单位ID
  18. MINIVALUE int32 `json:"minivalue" xorm:"'MINIVALUE'"` // 最小变动值
  19. MINIVALUEDP int32 `json:"minivaluedp" xorm:"'MINIVALUEDP'"` // 最小变动值小数位
  20. REALMINIVALUE int32 `json:"realminivalue" xorm:"'REALMINIVALUE'"` // 实际最小变动值
  21. REALMINIVALUEDP int32 `json:"realminivaluedp" xorm:"'REALMINIVALUEDP'"` // 实际最小变动值小数位
  22. CREATORID int64 `json:"creatorid" xorm:"'CREATORID'"` // 创建人
  23. CREATETIME string `json:"createtime" xorm:"'CREATETIME'"` // 创建时间
  24. WRSTANDARDNAME string `json:"wrstandardname" xorm:"'WRSTANDARDNAME'"` // 现货商品名称
  25. AREAUSERID int `json:"areauserid" xorm:"'AREAUSERID'"` // 所属机构
  26. EnumdicName string `json:"enumdicname"` // 单位名称
  27. ISVALID int32 `json:"isvalid" xorm:"'ISVALID'"` // 是否有效 0-无效(停用) 1-有效(正常)
  28. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  29. REMARK string `json:"remark" xorm:"'REMARK'"` // 备注
  30. }
  31. func (r *ErmcpWrstandard) buildSql() string {
  32. str := "select WRSTANDARDID," +
  33. " WRSTANDARDCODE," +
  34. " DELIVERYGOODSID," +
  35. " UNITID," +
  36. " MINIVALUE," +
  37. " MINIVALUEDP," +
  38. " REALMINIVALUE," +
  39. " REALMINIVALUEDP," +
  40. " CREATORID," +
  41. " to_char(CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
  42. " WRSTANDARDNAME," +
  43. " ISVALID," +
  44. " to_char(UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME," +
  45. " REMARK," +
  46. " AREAUSERID" +
  47. " from wrstandard t" +
  48. " where t.AREAUSERID=%v"
  49. sqlId := fmt.Sprintf(str, r.AREAUSERID)
  50. if r.WRSTANDARDID > 0 {
  51. sqlId = sqlId + fmt.Sprintf(" and WRSTANDARDID=%v", r.WRSTANDARDID)
  52. }
  53. if r.ISVALID >= 0{
  54. sqlId = sqlId + fmt.Sprintf(" and t.ISVALID=%v", r.ISVALID)
  55. }
  56. return sqlId
  57. }
  58. // 查询现货商品
  59. func (r *ErmcpWrstandard) GetData() ([]ErmcpWrstandard, error) {
  60. sData := make([]ErmcpWrstandard, 0)
  61. e := db.GetEngine()
  62. if err := e.SQL(r.buildSql()).Find(&sData); err != nil {
  63. logger.GetLogger().Errorf("query wrstardard fail, %v", err)
  64. return sData, err
  65. }
  66. return sData, nil
  67. }
  68. // 商品型号表
  69. type GoodsTypeModel struct {
  70. MODELID int `json:"modelid" xorm:"'MODELID'"` // 型号ID
  71. MODELNAME string `json:"modelname" xorm:"'MODELNAME'"` // 型号名称
  72. WRSTANDARDID int64 `json:"-" xorm:"'WRSTANDARDID'"` // 现货商品ID
  73. DELIVERYGOODSID int32 `json:"-" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  74. AREAUSERID int `json:"-" xorm:"'AREAUSERID'"` // 所属机构
  75. ISVALID int32 `json:"-" xorm:"'ISVALID'"` // 是否有效 - 0:无效 1:有效
  76. CREATORSRC int32 `json:"-" xorm:"'CREATORSRC'"` // 创建人来源 - 1:管理端 2:终端
  77. CREATORID int32 `json:"-" xorm:"'CREATORID'"` // 创建人
  78. CREATETIME string `json:"-" xorm:"'CREATETIME'"` // SYSDATE 创建时间
  79. UPDATORSRC int32 `json:"-" xorm:"'UPDATORSRC'"` // 更新人来源 - 1:管理端 2:终端
  80. UPDATORID int32 `json:"-" xorm:"'UPDATORID'"` // 更新人
  81. UPDATETIME string `json:"updatetime" xorm:"'UPDATETIME'"` // 更新时间
  82. }
  83. // 获取商品型号表数据
  84. func (r *GoodsTypeModel) GetData() ([]GoodsTypeModel, error) {
  85. sData := make([]GoodsTypeModel, 0)
  86. if err := db.GetEngine().SQL(r.buildSql()).Find(&sData); err != nil {
  87. logger.GetLogger().Errorf("query goodsTypeModel fail, %v", err)
  88. return nil, err
  89. }
  90. return sData, nil
  91. }
  92. func (r *GoodsTypeModel) buildSql() string {
  93. sqlId := "select MODELID," +
  94. " MODELNAME," +
  95. " WRSTANDARDID," +
  96. " DELIVERYGOODSID," +
  97. " AREAUSERID," +
  98. " ISVALID," +
  99. " CREATORSRC," +
  100. " CREATORID," +
  101. " to_char(CREATETIME, 'yyyy-mm-dd hh24:mi:ss') CREATETIME," +
  102. " UPDATORSRC," +
  103. " UPDATORID," +
  104. " to_char(UPDATETIME, 'yyyy-mm-dd hh24:mi:ss') UPDATETIME" +
  105. " from spotgoodsmodel where ISVALID=1"
  106. if r.AREAUSERID > 0 {
  107. sqlId = sqlId + fmt.Sprintf(" and AREAUSERID=%v", r.AREAUSERID)
  108. }
  109. if r.WRSTANDARDID > 0 {
  110. sqlId = sqlId + fmt.Sprintf(" and WRSTANDARDID=%v", r.WRSTANDARDID)
  111. }
  112. return sqlId
  113. }
  114. // 商品品牌
  115. type GoodsBrand struct {
  116. BRANDID int `json:"brandid" xorm:"'bRANDID'"` // 品牌ID
  117. BRANDNAME string `json:"brandname" xorm:"'BRANDNAME'"` // 品牌名称
  118. WRSTANDARDID int64 `json:"-" xorm:"'WRSTANDARDID'"` // 现货商品ID
  119. DELIVERYGOODSID int32 `json:"-" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  120. AREAUSERID int `json:"-" xorm:"'AREAUSERID'"` // 所属机构
  121. ISVALID int32 `json:"isvalid" xorm:"'ISVALID'"` // 是否有效 - 0:无效 1:有效
  122. }
  123. func (r *GoodsBrand) buildSql() string {
  124. sqlId := "select BRANDID," +
  125. " BRANDNAME," +
  126. " WRSTANDARDID," +
  127. " DELIVERYGOODSID," +
  128. " AREAUSERID," +
  129. " ISVALID" +
  130. " from spotgoodsbrand" +
  131. " where ISVALID = 1"
  132. if r.AREAUSERID > 0 {
  133. sqlId = sqlId + fmt.Sprintf(" and AREAUSERID=%v", r.AREAUSERID)
  134. }
  135. if r.WRSTANDARDID > 0 {
  136. sqlId = sqlId + fmt.Sprintf(" and WRSTANDARDID=%v", r.WRSTANDARDID)
  137. }
  138. return sqlId
  139. }
  140. // 获取品牌数据
  141. func (r *GoodsBrand) GetData() ([]GoodsBrand, error) {
  142. sData := make([]GoodsBrand, 0)
  143. if err := db.GetEngine().SQL(r.buildSql()).Find(&sData); err != nil {
  144. logger.GetLogger().Errorf("query GoodsBrand fail, %v", err)
  145. return nil, err
  146. }
  147. return sData, nil
  148. }
  149. // 现货商品折算配置明细表
  150. type WRSConverTDetail struct {
  151. WRSTANDARDID int64 `json:"wrstandardid" xorm:"'WRSTANDARDID'"` // 现货商品ID
  152. DELIVERYGOODSID int32 `json:"deliverygoodsid" xorm:"'DELIVERYGOODSID'"` // 现货品种ID
  153. MIDDLEGOODSID int64 `json:"middlegoodsid" xorm:"'MIDDLEGOODSID'"` // 套保品种ID
  154. CONVERTRATIO float64 `json:"convertratio" xorm:"'CONVERTRATIO'"` // 套保系数
  155. MODIFYTIME string `json:"modifytime" xorm:"'MODIFYTIME'"` // 修改时间
  156. MIDDLEGOODSNAME string `json:"middlegoodsname" xorm:"'middlegoodsname'"` // 套保品种名称
  157. MIDDLEGOODSCODE string `json:"middlegoodscode" xorm:"'middlegoodscode'"` // 套保品种代码
  158. }
  159. func (r *WRSConverTDetail) buildSql() string {
  160. sqlId := "select t.WRSTANDARDID," +
  161. " t.DELIVERYGOODSID," +
  162. " t.MIDDLEGOODSID," +
  163. " t.CONVERTRATIO," +
  164. " to_char(t.MODIFYTIME, 'yyyy-mm-dd hh24:mi:ss') MODIFYTIME," +
  165. " m.middlegoodsname," +
  166. " m.middlegoodscode" +
  167. " from Erms2_Wrsconvertdetail t" +
  168. " left join erms_middlegoods m" +
  169. " on t.middlegoodsid = m.middlegoodsid" +
  170. " where 1=1"
  171. if r.WRSTANDARDID > 0 {
  172. sqlId = sqlId + fmt.Sprintf(" and t.wrstandardid=%v", r.WRSTANDARDID)
  173. }
  174. return sqlId
  175. }
  176. // 获取现货商品折算配置明细表数据
  177. func (r *WRSConverTDetail) GetData() ([]WRSConverTDetail, error) {
  178. sData := make([]WRSConverTDetail, 0)
  179. if err := db.GetEngine().SQL(r.buildSql()).Find(&sData); err != nil {
  180. logger.GetLogger().Errorf("query WRSConverTDetail fail, %v", err)
  181. return nil, err
  182. }
  183. return sData, nil
  184. }
  185. // 现货商品详细
  186. type ErmcpWrstandDetail struct {
  187. Wrd ErmcpWrstandard `json:"wrd"` // 基本信息
  188. GtList []GoodsTypeModel `json:"gtList"` // 型号列表
  189. GbList []GoodsBrand `json:"gbList"` // 品牌列表
  190. WrsList []WRSConverTDetail `json:"wrsList"` // 套保信息列表
  191. }
  192. // 查询现货商品详细
  193. func (r *ErmcpWrstandDetail) GetData() (ErmcpWrstandDetail, error) {
  194. // 获取基本信息
  195. m := ErmcpWrstandard{AREAUSERID: r.Wrd.AREAUSERID, WRSTANDARDID: r.Wrd.WRSTANDARDID, ISVALID: -1}
  196. d, err := m.GetData()
  197. if err != nil {
  198. return ErmcpWrstandDetail{}, err
  199. }
  200. if d == nil || len(d) == 0 {
  201. return ErmcpWrstandDetail{}, fmt.Errorf("no record")
  202. }
  203. rsp := ErmcpWrstandDetail{}
  204. rsp.Wrd = d[0]
  205. // 获取型号信息
  206. gt := GoodsTypeModel{AREAUSERID: rsp.Wrd.AREAUSERID, WRSTANDARDID: rsp.Wrd.WRSTANDARDID}
  207. if val, err := gt.GetData(); err == nil {
  208. rsp.GtList = val
  209. }
  210. // 获取品牌信息
  211. gb := GoodsBrand{AREAUSERID: rsp.Wrd.AREAUSERID, WRSTANDARDID: rsp.Wrd.WRSTANDARDID}
  212. if val, err := gb.GetData(); err == nil {
  213. rsp.GbList = val
  214. }
  215. // 获取套保信息
  216. wrs := WRSConverTDetail{WRSTANDARDID: rsp.Wrd.WRSTANDARDID}
  217. if val, err := wrs.GetData(); err == nil {
  218. rsp.WrsList = val
  219. }
  220. return rsp, nil
  221. }