base_from_fenwei.go 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569
  1. package models
  2. import (
  3. "errors"
  4. "eta_gn/eta_index_lib/global"
  5. "eta_gn/eta_index_lib/utils"
  6. "fmt"
  7. "github.com/beego/beego/v2/client/orm"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. // BaseFromFenwei 涌溢咨询
  13. type BaseFromFenwei struct{}
  14. //type BaseFromFenweiData struct {
  15. // FenweiDataId int `orm:"column(fenwei_data_id);pk"`
  16. // FenweiIndexId int
  17. // IndexCode string
  18. // DataTime string
  19. // Value string
  20. // CreateTime time.Time
  21. // ModifyTime time.Time
  22. // DataTimestamp int64
  23. //}
  24. type BaseFromFenweiData struct {
  25. FenweiDataId int `gorm:"column:fenwei_data_id;primaryKey"`
  26. FenweiIndexId int `gorm:"column:fenwei_index_id"`
  27. IndexCode string `gorm:"column:index_code"`
  28. DataTime string `gorm:"column:data_time"`
  29. Value string `gorm:"column:value"`
  30. CreateTime time.Time `gorm:"column:create_time"`
  31. ModifyTime time.Time `gorm:"column:modify_time"`
  32. DataTimestamp int64 `gorm:"column:data_timestamp"`
  33. }
  34. func (m *BaseFromFenweiData) TableName() string {
  35. return "base_from_fenwei_data"
  36. }
  37. func GetBaseFromFenweiDataByCondition(condition string, pars []interface{}) (list []*BaseFromFenweiData, err error) {
  38. //o := orm.NewOrm()
  39. sql := `SELECT * FROM base_from_fenwei_data WHERE 1=1 `
  40. if condition != "" {
  41. sql += condition
  42. }
  43. //_, err = o.Raw(sql, pars).QueryRows(&list)
  44. err = global.DEFAULT_DmSQL.Raw(sql, pars).Find(&list).Error
  45. return
  46. }
  47. // Add 添加
  48. func (obj BaseFromFenwei) Add(edbCode string) (err error) {
  49. //o := orm.NewOrm()
  50. var condition string
  51. var pars []interface{}
  52. if edbCode != "" {
  53. condition += " AND index_code=? "
  54. pars = append(pars, edbCode)
  55. }
  56. fenweiBaseDataAll, err := GetBaseFromFenweiDataByCondition(condition, pars)
  57. if err != nil && err.Error() != utils.ErrNoRow() {
  58. return
  59. }
  60. var isAdd bool
  61. addSql := ` INSERT INTO edb_data_fenwei(edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) values `
  62. existMap := make(map[string]string)
  63. for _, sv := range fenweiBaseDataAll {
  64. eDate := sv.DataTime
  65. dataTime, err := time.Parse(utils.FormatDate, eDate)
  66. if err != nil {
  67. return err
  68. }
  69. timestamp := dataTime.UnixNano() / 1e6
  70. timeStr := fmt.Sprintf("%d", timestamp)
  71. if _, ok := existMap[eDate]; !ok {
  72. addSql += GetAddSql("0", edbCode, eDate, timeStr, sv.Value)
  73. isAdd = true
  74. }
  75. existMap[eDate] = sv.Value
  76. }
  77. if isAdd {
  78. addSql = strings.TrimRight(addSql, ",")
  79. utils.FileLog.Info("addSql:" + addSql)
  80. //_, err = o.Raw(addSql).Exec()
  81. err = global.DEFAULT_DmSQL.Exec(addSql).Error
  82. if err != nil {
  83. return err
  84. }
  85. }
  86. return
  87. }
  88. // Refresh 刷新汾渭数据指标数据
  89. func (obj BaseFromFenwei) Refresh(edbInfoId int, edbCode, startDate string) (err error) {
  90. source := obj.GetSource()
  91. //o := orm.NewOrm()
  92. if err != nil {
  93. return
  94. }
  95. edbInfoIdStr := strconv.Itoa(edbInfoId)
  96. //计算数据
  97. var condition string
  98. var pars []interface{}
  99. if edbCode != "" {
  100. condition += " AND index_code=? "
  101. pars = append(pars, edbCode)
  102. }
  103. if startDate != "" {
  104. condition += " AND data_time>=? "
  105. pars = append(pars, startDate)
  106. }
  107. fenweiDataList, err := GetBaseFromFenweiDataByCondition(condition, pars)
  108. if err != nil {
  109. return
  110. }
  111. // 真实数据的最大日期 , 插入规则配置的日期
  112. var realDataMaxDate, edbDataInsertConfigDate time.Time
  113. var edbDataInsertConfig *EdbDataInsertConfig
  114. var isFindConfigDateRealData bool //是否找到配置日期的实际数据的值
  115. {
  116. edbDataInsertConfig, err = GetEdbDataInsertConfigByEdbId(edbInfoId)
  117. if err != nil && err.Error() != utils.ErrNoRow() {
  118. return
  119. }
  120. if edbDataInsertConfig != nil {
  121. edbDataInsertConfigDate = edbDataInsertConfig.Date
  122. }
  123. }
  124. var existCondition string
  125. var existPars []interface{}
  126. existCondition += " AND edb_info_id=? "
  127. existPars = append(existPars, edbInfoId)
  128. if startDate != "" {
  129. existCondition += " AND data_time>=? "
  130. existPars = append(existPars, startDate)
  131. }
  132. existList, err := GetEdbDataByCondition(source, 0, existCondition, existPars)
  133. if err != nil {
  134. return err
  135. }
  136. existMap := make(map[string]*EdbInfoSearchData)
  137. for _, v := range existList {
  138. existMap[v.DataTime] = v
  139. }
  140. addSql := ` INSERT INTO edb_data_fenwei(edb_info_id,edb_code,data_time,value,create_time,modify_time,data_timestamp) values `
  141. var isAdd bool
  142. for _, v := range fenweiDataList {
  143. item := v
  144. eDate := item.DataTime
  145. dataTime, err := time.ParseInLocation(utils.FormatDate, eDate, time.Local)
  146. if err != nil {
  147. return err
  148. }
  149. if findItem, ok := existMap[v.DataTime]; !ok {
  150. sValue := item.Value
  151. timestamp := dataTime.UnixNano() / 1e6
  152. timeStr := fmt.Sprintf("%d", timestamp)
  153. addSql += GetAddSql(edbInfoIdStr, edbCode, eDate, timeStr, sValue)
  154. isAdd = true
  155. } else {
  156. if findItem != nil && utils.SubFloatToString(findItem.Value, 30) != item.Value {
  157. err = ModifyEdbDataById(source, 0, findItem.EdbDataId, item.Value)
  158. if err != nil {
  159. return err
  160. }
  161. }
  162. }
  163. // 下面代码主要目的是处理掉手动插入的数据判断
  164. {
  165. if realDataMaxDate.IsZero() || dataTime.After(realDataMaxDate) {
  166. realDataMaxDate = dataTime
  167. }
  168. if edbDataInsertConfigDate.IsZero() || dataTime.Equal(edbDataInsertConfigDate) {
  169. isFindConfigDateRealData = true
  170. }
  171. }
  172. }
  173. // 处理手工数据补充的配置
  174. HandleConfigInsertEdbData(realDataMaxDate, edbDataInsertConfig, edbInfoId, source, 0, existMap, isFindConfigDateRealData)
  175. if isAdd {
  176. addSql = strings.TrimRight(addSql, ",")
  177. //_, err = o.Raw(addSql).Exec()
  178. err = global.DEFAULT_DmSQL.Exec(addSql).Error
  179. if err != nil {
  180. fmt.Println("RefreshEdbDataFromBaiinfo add Err", err.Error())
  181. return
  182. }
  183. }
  184. return
  185. }
  186. // GetSource 获取来源编码id
  187. func (obj BaseFromFenwei) GetSource() int {
  188. return utils.DATA_SOURCE_FENWEI
  189. }
  190. // GetSourceName 获取来源名称
  191. func (obj BaseFromFenwei) GetSourceName() string {
  192. return utils.DATA_SOURCE_NAME_FENWEI
  193. }
  194. //type BaseFromFenweiIndex struct {
  195. // FenweiIndexId int64 `orm:"column(fenwei_index_id);pk"`
  196. // IndexCode string
  197. // IndexName string
  198. // Frequency string
  199. // Unit string
  200. // ClassifyId int
  201. // StartDate string
  202. // EndDate string
  203. // Sort int
  204. // TerminalCode string
  205. // CreateTime time.Time
  206. // ModifyTime time.Time
  207. //}
  208. type BaseFromFenweiIndex struct {
  209. FenweiIndexId int64 `gorm:"column:fenwei_index_id;primaryKey"`
  210. IndexCode string `gorm:"column:index_code"`
  211. IndexName string `gorm:"column:index_name"`
  212. Frequency string `gorm:"column:frequency"`
  213. Unit string `gorm:"column:unit"`
  214. ClassifyId int `gorm:"column:classify_id"`
  215. StartDate string `gorm:"column:start_date"`
  216. EndDate string `gorm:"column:end_date"`
  217. Sort int `gorm:"column:sort"`
  218. TerminalCode string `gorm:"column:terminal_code"`
  219. CreateTime time.Time `gorm:"column:create_time"`
  220. ModifyTime time.Time `gorm:"column:modify_time"`
  221. }
  222. func (m *BaseFromFenweiIndex) TableName() string {
  223. return "base_from_fenwei_index"
  224. }
  225. func (m *BaseFromFenweiIndex) Add() (lastId int64, err error) {
  226. //o := orm.NewOrm()
  227. //lastId, err = o.Insert(m)
  228. err = global.DEFAULT_DmSQL.Create(m).Error
  229. lastId = m.FenweiIndexId
  230. return
  231. }
  232. func (m *BaseFromFenweiIndex) Update(updateCols []string) (err error) {
  233. //o := orm.NewOrm()
  234. //_, err = o.Update(m, updateCols...)
  235. err = global.DEFAULT_DmSQL.Save(m).Error
  236. return
  237. }
  238. func (m *BaseFromFenweiIndex) ModifyIndexMaxAndMinDate(indexCode string, item *EdbInfoMaxAndMinInfo) (err error) {
  239. //o := orm.NewOrm()
  240. sql := ` UPDATE base_from_fenwei_index SET start_date=?,end_date=?,modify_time=NOW() WHERE index_code=? `
  241. //_, err = o.Raw(sql, item.MinDate, item.MaxDate, indexCode).Exec()
  242. err = global.DEFAULT_DmSQL.Exec(sql, item.MinDate, item.MaxDate, indexCode).Error
  243. return
  244. }
  245. func (m *BaseFromFenweiIndex) GetByIndexCode(indexCode string) (item *BaseFromFenweiIndex, err error) {
  246. //o := orm.NewOrm()
  247. sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
  248. //err = o.Raw(sql, indexCode).QueryRow(&item)
  249. err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
  250. return
  251. }
  252. func (m *BaseFromFenweiIndex) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BaseFromFenweiIndex, err error) {
  253. //o := orm.NewOrm()
  254. fields := strings.Join(fieldArr, ",")
  255. if len(fieldArr) == 0 {
  256. fields = `*`
  257. }
  258. order := `ORDER BY create_time DESC`
  259. if orderRule != "" {
  260. order = ` ORDER BY ` + orderRule
  261. }
  262. sql := fmt.Sprintf(`SELECT %s FROM base_from_fenwei_index WHERE 1=1 %s %s`, fields, condition, order)
  263. //_, err = o.Raw(sql, pars).QueryRows(&items)
  264. err = global.DEFAULT_DmSQL.Raw(sql, pars).Find(&items).Error
  265. return
  266. }
  267. type BaseFromFenweiIndexList struct {
  268. FenweiIndexId int64 `orm:"column(fenwei_index_id);pk"`
  269. IndexCode string
  270. IndexName string
  271. Frequency string
  272. Unit string
  273. ClassifyId int
  274. StartDate string
  275. EndDate string
  276. TerminalCode string
  277. CreateTime string
  278. ModifyTime string
  279. }
  280. func (y *BaseFromFenweiData) GetByIndexCode(indexCode string) (list []*BaseFromFenweiData, err error) {
  281. //o := orm.NewOrm()
  282. sql := ` SELECT * FROM base_from_fenwei_data WHERE index_code=? `
  283. //_, err = o.Raw(sql, indexCode).QueryRows(&list)
  284. err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&list).Error
  285. return
  286. }
  287. func (y *BaseFromFenweiData) AddMulti(item []*BaseFromFenweiData) (err error) {
  288. //o := orm.NewOrm()
  289. //_, err = o.InsertMulti(1, item)
  290. err = global.DEFAULT_DmSQL.CreateInBatches(item, len(item)).Error
  291. return
  292. }
  293. // HandleFenweiExcelData 汾渭数据的excel数据
  294. type HandleFenweiExcelData struct {
  295. //ClassifyName string `description:"指标目录"`
  296. //ClassifySort int `description:"指标目录排序号"`
  297. IndexName string `description:"指标名称"`
  298. IndexCode string `description:"指标编码"`
  299. Unit string `description:"单位"`
  300. Sort int `description:"排序号"`
  301. Frequency string `description:"频度"`
  302. ClassifyId int `description:"分类ID"`
  303. ExcelDataMap map[string]string
  304. }
  305. type HandleFenweiExcelDataReq struct {
  306. List []*HandleFenweiExcelData
  307. TerminalCode string `description:"编码"`
  308. }
  309. type FenWeiNetIndexInfo struct {
  310. FenweiIndexId int64 `orm:"column(fenwei_index_id);pk"`
  311. IndexName string `description:"指标名称"`
  312. //IndexCode string `description:"指标编码"`
  313. Unit string `description:"单位"`
  314. Frequency string `description:"频度"`
  315. TerminalCode string `description:"编码"`
  316. ClassifyName string `description:"分类名称"`
  317. DataTime string `description:"数据时间"`
  318. Value interface{} `description:"数据值"`
  319. }
  320. type HandleFenWeiNetDataReq struct {
  321. List []*FenWeiNetIndexInfo
  322. TerminalCode string `description:"编码"`
  323. }
  324. func (y *BaseFromFenweiData) GetMaxAndMinDateByIndexCode(indexCode string) (item *EdbInfoMaxAndMinInfo, err error) {
  325. //o := orm.NewOrm()
  326. sql := ` SELECT MIN(data_time) AS min_date,MAX(data_time) AS max_date,MIN(value) AS min_value,MAX(value) AS max_value FROM base_from_fenwei_data WHERE index_code=? `
  327. //err = o.Raw(sql, indexCode).QueryRow(&item)
  328. err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
  329. return
  330. }
  331. // BaseFromFenweiClassify 汾渭数据分类表
  332. type BaseFromFenweiClassify struct {
  333. ClassifyId int `gorm:"column:classify_id;primaryKey" description:"分类ID"`
  334. ClassifyName string `gorm:"column:classify_name" description:"分类名称"`
  335. ParentId int `gorm:"column:parent_id" description:"父级id"`
  336. SysUserId int `gorm:"column:sys_user_id" description:"创建人id"`
  337. SysUserRealName string `gorm:"column:sys_user_real_name" description:"创建人姓名"`
  338. Level int `gorm:"column:level" description:"层级"`
  339. Sort int `gorm:"column:sort" description:"排序字段,越小越靠前,默认值:10"`
  340. ModifyTime time.Time `gorm:"column:modify_time" description:"修改时间"`
  341. CreateTime time.Time `gorm:"column:create_time" description:"创建时间"`
  342. }
  343. //type BaseFromFenweiClassify struct {
  344. // ClassifyId int `orm:"column(classify_id);pk"`
  345. // ClassifyName string `description:"分类名称"`
  346. // ParentId int `description:"父级id"`
  347. // SysUserId int `description:"创建人id"`
  348. // SysUserRealName string `description:"创建人姓名"`
  349. // Level int `description:"层级"`
  350. // Sort int `description:"排序字段,越小越靠前,默认值:10"`
  351. // ModifyTime time.Time `description:"修改时间"`
  352. // CreateTime time.Time `description:"创建时间"`
  353. //}
  354. func (y *BaseFromFenweiClassify) Add() (lastId int64, err error) {
  355. //o := orm.NewOrm()
  356. //lastId, err = o.Insert(y)
  357. err = global.DEFAULT_DmSQL.Create(y).Error
  358. lastId = int64(y.ClassifyId)
  359. return
  360. }
  361. func (y *BaseFromFenweiClassify) Update(updateCols []string) (err error) {
  362. //o := orm.NewOrm()
  363. //_, err = o.Update(y, updateCols...)
  364. err = global.DEFAULT_DmSQL.Save(y).Error
  365. return
  366. }
  367. func (y *BaseFromFenweiClassify) GetByClassifyName(classifyName string) (item []*BaseFromFenweiClassify, err error) {
  368. //o := orm.NewOrm()
  369. sql := ` SELECT * FROM base_from_fenwei_classify WHERE classify_name=? `
  370. //_, err = o.Raw(sql, classifyName).QueryRows(&item)
  371. err = global.DEFAULT_DmSQL.Raw(sql, classifyName).Find(&item).Error
  372. if errors.Is(err, orm.ErrNoRows) {
  373. return nil, nil
  374. }
  375. return
  376. }
  377. func (y *BaseFromFenweiClassify) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BaseFromFenweiClassify, err error) {
  378. //o := orm.NewOrm()
  379. fields := strings.Join(fieldArr, ",")
  380. if len(fieldArr) == 0 {
  381. fields = `*`
  382. }
  383. order := `ORDER BY create_time DESC`
  384. if orderRule != "" {
  385. order = ` ORDER BY ` + orderRule
  386. }
  387. sql := fmt.Sprintf(`SELECT %s FROM base_from_fenwei_classify WHERE 1=1 %s %s`, fields, condition, order)
  388. //_, err = o.Raw(sql, pars).QueryRows(&items)
  389. err = global.DEFAULT_DmSQL.Raw(sql, pars).Find(&items).Error
  390. return
  391. }
  392. // BaseFromFenweiClassifyItem 汾渭数据分类信息
  393. //type BaseFromFenweiClassifyItem struct {
  394. // ClassifyId int `description:"分类ID"`
  395. // ClassifyName string `description:"分类名称"`
  396. // ParentId int `description:"父级id"`
  397. // Level int `description:"层级"`
  398. // Sort int `description:"排序字段"`
  399. // CreateTime string `description:"创建时间"`
  400. // ModifyTime string `description:"修改时间"`
  401. // Child []*BaseFromFenweiClassifyItem `description:"子分类"`
  402. //}
  403. // BaseFromFenweiClassifyItem 汾渭数据分类信息
  404. type BaseFromFenweiClassifyItem struct {
  405. ClassifyId int `gorm:"column:classify_id" description:"分类ID"`
  406. ClassifyName string `gorm:"column:classify_name" description:"分类名称"`
  407. ParentId int `gorm:"column:parent_id" description:"父级id"`
  408. Level int `gorm:"column:level" description:"层级"`
  409. Sort int `gorm:"column:sort" description:"排序字段"`
  410. CreateTime string `gorm:"column:create_time" description:"创建时间"`
  411. ModifyTime string `gorm:"column:modify_time" description:"修改时间"`
  412. Child []*BaseFromFenweiClassifyItem `description:"子分类"`
  413. }
  414. func (y *BaseFromFenweiClassify) Format2Item(origin *BaseFromFenweiClassify) (item *BaseFromFenweiClassifyItem) {
  415. if origin == nil {
  416. return
  417. }
  418. item = new(BaseFromFenweiClassifyItem)
  419. item.ClassifyId = origin.ClassifyId
  420. item.ClassifyName = origin.ClassifyName
  421. item.ParentId = origin.ParentId
  422. item.Level = origin.Level
  423. item.Sort = origin.Sort
  424. item.CreateTime = utils.TimeTransferString(utils.FormatDateTime, origin.CreateTime)
  425. item.ModifyTime = utils.TimeTransferString(utils.FormatDateTime, origin.ModifyTime)
  426. return
  427. }
  428. // MultiUpdateBaseFromFenweiDataValue 批量更新汾渭指标数据
  429. func MultiUpdateBaseFromFenweiDataValue(items []*BaseFromFenweiData) (err error) {
  430. if len(items) == 0 {
  431. return
  432. }
  433. //o := orm.NewOrm()
  434. sql := `UPDATE base_from_fenwei_data SET value = ?, modify_time = NOW() WHERE index_code = ? AND data_time = ? LIMIT 1`
  435. //p, err := o.Raw(sql).Prepare()
  436. if err != nil {
  437. return
  438. }
  439. //defer func() {
  440. // _ = p.Close()
  441. //}()
  442. for _, v := range items {
  443. if v.IndexCode == "" || v.DataTime == "" {
  444. continue
  445. }
  446. //_, err = p.Exec(v.Value, v.IndexCode, v.DataTime)
  447. err = global.DEFAULT_DmSQL.Exec(sql, v.Value, v.IndexCode, v.DataTime).Error
  448. if err != nil {
  449. return
  450. }
  451. }
  452. return
  453. }
  454. // GetBaseFromFenWeiIndexByIndexName 根据指标名称查询指标
  455. func GetBaseFromFenWeiIndexByIndexName(indexName string) (item *BaseFromFenweiIndex, err error) {
  456. //o := orm.NewOrm()
  457. sql := ` SELECT * FROM base_from_fenwei_index WHERE index_name=? `
  458. //err = o.Raw(sql, indexName).QueryRow(&item)
  459. err = global.DEFAULT_DmSQL.Raw(sql, indexName).Find(&item).Error
  460. if errors.Is(err, orm.ErrNoRows) {
  461. return nil, nil
  462. }
  463. return
  464. }
  465. // GetBaseFromFenweiDataByIndexCodeAndDataTime 根据指标编码和dataTime查询指标数据
  466. func GetBaseFromFenweiDataByIndexCodeAndDataTime(indexCode, dataTime string) (item *BaseFromFenweiData, err error) {
  467. //o := orm.NewOrm()
  468. sql := ` SELECT * FROM base_from_fenwei_data WHERE index_code=? AND data_time=? `
  469. //err = o.Raw(sql, indexCode, dataTime).QueryRow(&item)
  470. err = global.DEFAULT_DmSQL.Raw(sql, indexCode, dataTime).Find(&item).Error
  471. if errors.Is(err, orm.ErrNoRows) {
  472. return nil, nil
  473. }
  474. return
  475. }
  476. // BatchAddBaseFromFenWeiData 批量插入指标数据
  477. func BatchAddBaseFromFenWeiData(items []*BaseFromFenweiData) (err error) {
  478. if len(items) == 0 {
  479. return
  480. }
  481. //o := orm.NewOrm()
  482. //_, err = o.InsertMulti(1, items)
  483. err = global.DEFAULT_DmSQL.CreateInBatches(items, 1).Error
  484. return
  485. }
  486. // AddBaseFromFenWeiClassify 新增汾渭分类
  487. func AddBaseFromFenWeiClassify(item *BaseFromFenweiClassify) (classifyId int64, err error) {
  488. //o := orm.NewOrm()
  489. //classifyId, err = o.Insert(item)
  490. err = global.DEFAULT_DmSQL.Create(item).Error
  491. classifyId = int64(item.ClassifyId)
  492. return
  493. }
  494. // GetBaseFromFenWeiIndexByIndexCode 跟据指标编码查询指标信息
  495. func GetBaseFromFenWeiIndexByIndexCode(indexCode string) (item *BaseFromFenweiIndex, err error) {
  496. //o := orm.NewOrm()
  497. sql := ` SELECT * FROM base_from_fenwei_index WHERE index_code=? `
  498. //err = o.Raw(sql, indexCode).QueryRow(&item)
  499. err = global.DEFAULT_DmSQL.Raw(sql, indexCode).Find(&item).Error
  500. if errors.Is(err, orm.ErrNoRows) {
  501. return nil, nil
  502. }
  503. return
  504. }