|
@@ -1,12 +1,12 @@
|
|
|
package data_manage
|
|
|
|
|
|
import (
|
|
|
+ "eta_gn/eta_api/global"
|
|
|
"eta_gn/eta_api/utils"
|
|
|
"fmt"
|
|
|
"strings"
|
|
|
"time"
|
|
|
|
|
|
- "github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/rdlucklib/rdluck_tools/paging"
|
|
|
)
|
|
|
|
|
@@ -81,8 +81,10 @@ var BaseFromMysteelChemicalIndexCols = struct {
|
|
|
|
|
|
// Update 更新钢联化工指标基础信息
|
|
|
func (item *BaseFromMysteelChemicalIndex) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Update(item, cols...)
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //_, err = o.Update(item, cols...)
|
|
|
+
|
|
|
+ err = global.DmSQL["data"].Select(cols).Updates(item).Error
|
|
|
return
|
|
|
}
|
|
|
func (m *BaseFromMysteelChemicalIndex) GeItemsByCondition(condition string, pars []interface{}, limitSize int) (items []*BaseFromMysteelChemicalIndexItem, err error) {
|
|
@@ -90,6 +92,20 @@ func (m *BaseFromMysteelChemicalIndex) GeItemsByCondition(condition string, pars
|
|
|
pars = make([]interface{}, 0)
|
|
|
}
|
|
|
|
|
|
+ //sql := `select a.*,b.edb_info_id,b.unique_code as edb_unique_code,b.classify_id as edb_classify_id FROM base_from_mysteel_chemical_index AS a LEFT JOIN edb_info b on a.index_code=b.edb_code AND b.source=? WHERE 1=1 `
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //sql += ` order by a.base_from_mysteel_chemical_index_id desc `
|
|
|
+ //
|
|
|
+ //if limitSize > 0 {
|
|
|
+ // sql += " limit ? "
|
|
|
+ // pars = append(pars, limitSize)
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //_, err = o.Raw(sql, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, pars).QueryRows(&items)
|
|
|
+
|
|
|
sql := `select a.*,b.edb_info_id,b.unique_code as edb_unique_code,b.classify_id as edb_classify_id FROM base_from_mysteel_chemical_index AS a LEFT JOIN edb_info b on a.index_code=b.edb_code AND b.source=? WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -100,29 +116,27 @@ func (m *BaseFromMysteelChemicalIndex) GeItemsByCondition(condition string, pars
|
|
|
sql += " limit ? "
|
|
|
pars = append(pars, limitSize)
|
|
|
}
|
|
|
-
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Raw(sql, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, pars).QueryRows(&items)
|
|
|
-
|
|
|
+ err = global.DmSQL["data"].Raw(sql, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, pars).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// AddBaseFromMysteelChemicalIndex 添加钢联化工指标
|
|
|
func AddBaseFromMysteelChemicalIndex(item *BaseFromMysteelChemicalIndex) (lastId int64, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- lastId, err = o.Insert(item)
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
- item.BaseFromMysteelChemicalIndexId = int(lastId)
|
|
|
-
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //lastId, err = o.Insert(item)
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //item.BaseFromMysteelChemicalIndexId = int(lastId)
|
|
|
+ err = global.DmSQL["data"].Create(item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// AddBaseFromMysteelChemicalIndex 添加钢联化工指标
|
|
|
func BatchAddBaseFromMysteelChemicalIndex(items []*BaseFromMysteelChemicalIndex) (lastId int64, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.InsertMulti(len(items), items)
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //_, err = o.InsertMulti(len(items), items)
|
|
|
+ err = global.DmSQL["data"].CreateInBatches(items, utils.MultiAddNum).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -144,37 +158,49 @@ type MysteelChemicalFrequency struct {
|
|
|
|
|
|
// GetMysteelChemicalIndexByClassifyId 用于分类展示
|
|
|
func GetMysteelChemicalIndexByClassifyId(classifyId int) (items []*BaseFromMysteelChemicalClassifyItems, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT base_from_mysteel_chemical_index_id,base_from_mysteel_chemical_classify_id,index_name AS classify_name,
|
|
|
- sys_user_id,sys_user_real_name,sort,index_code
|
|
|
- FROM base_from_mysteel_chemical_index where base_from_mysteel_chemical_classify_id=? ORDER BY sort asc, create_time ASC `
|
|
|
- _, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
- return
|
|
|
-}
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT base_from_mysteel_chemical_index_id,base_from_mysteel_chemical_classify_id,index_name AS classify_name,
|
|
|
+ // sys_user_id,sys_user_real_name,sort,index_code
|
|
|
+ // FROM base_from_mysteel_chemical_index where base_from_mysteel_chemical_classify_id=? ORDER BY sort asc, create_time ASC `
|
|
|
+ //_, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
|
|
|
-// MysteelChemicalFrequencyByClassifyId 根据分类id获取钢联化工频度数据列表
|
|
|
-func MysteelChemicalFrequencyByClassifyId(classifyId int) (items []*MysteelChemicalFrequency, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- if classifyId == 0 {
|
|
|
- sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE frequency != "" GROUP BY frequency ORDER BY frequency ASC `
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
- return
|
|
|
- } else {
|
|
|
- sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id = ? AND frequency != "" GROUP BY frequency ORDER BY frequency ASC `
|
|
|
- _, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
- return
|
|
|
- }
|
|
|
-}
|
|
|
+ sql := ` SELECT base_from_mysteel_chemical_index_id,base_from_mysteel_chemical_classify_id,index_name AS classify_name,
|
|
|
+ sys_user_id,sys_user_real_name,sort,index_code
|
|
|
+ FROM base_from_mysteel_chemical_index where base_from_mysteel_chemical_classify_id=? ORDER BY sort asc, create_time ASC `
|
|
|
+ err = global.DmSQL["data"].Raw(sql, classifyId).Find(&items).Error
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+//// MysteelChemicalFrequencyByClassifyId 根据分类id获取钢联化工频度数据列表
|
|
|
+//func MysteelChemicalFrequencyByClassifyId(classifyId int) (items []*MysteelChemicalFrequency, err error) {
|
|
|
+// o := orm.NewOrmUsingDB("data")
|
|
|
+// if classifyId == 0 {
|
|
|
+// sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE frequency != "" GROUP BY frequency ORDER BY frequency ASC `
|
|
|
+// _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+// return
|
|
|
+// } else {
|
|
|
+// sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id = ? AND frequency != "" GROUP BY frequency ORDER BY frequency ASC `
|
|
|
+// _, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
+// return
|
|
|
+// }
|
|
|
+//}
|
|
|
|
|
|
// GetMysteelChemicalFrequency 获取钢联化工频度数据列表
|
|
|
func GetMysteelChemicalFrequency(condition string, pars []interface{}) (items []*MysteelChemicalFrequency, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE 1=1 AND frequency != "" `
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //sql += ` GROUP BY frequency ORDER BY frequency ASC `
|
|
|
+ //_, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT frequency FROM base_from_mysteel_chemical_index WHERE 1=1 AND frequency != "" `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` GROUP BY frequency ORDER BY frequency ASC `
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -204,32 +230,59 @@ type MysteelChemicalData struct {
|
|
|
|
|
|
// GetMysteelChemicalIndex 根据分类id获取钢联化工频度数据列表
|
|
|
func GetMysteelChemicalIndex(condition string, pars []interface{}) (items []*MysteelChemicalList, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
+ //
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //sql += ` ORDER BY base_from_mysteel_chemical_index_id ASC `
|
|
|
+ //_, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` ORDER BY base_from_mysteel_chemical_index_id ASC `
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexData 根据指标code获取钢联化工数据列表
|
|
|
func GetMysteelChemicalIndexData(indexCode string, startSize, pageSize int) (items []*MysteelChemicalData, err error) {
|
|
|
+ //sql := ` SELECT * FROM (
|
|
|
+ //SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
|
+ //ORDER BY data_time DESC
|
|
|
+ //)AS t
|
|
|
+ //GROUP BY t.data_time
|
|
|
+ //ORDER BY t.data_time DESC LIMIT ?,? `
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //_, err = o.Raw(sql, indexCode, startSize, pageSize).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT * FROM (
|
|
|
SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
|
ORDER BY data_time DESC
|
|
|
)AS t
|
|
|
GROUP BY t.data_time
|
|
|
ORDER BY t.data_time DESC LIMIT ?,? `
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Raw(sql, indexCode, startSize, pageSize).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexCode, startSize, pageSize).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexDataCount 根据指标code获取钢联化工数据列表 获取钢联数据总数
|
|
|
func GetMysteelChemicalIndexDataCount(indexCode string) (count int, err error) {
|
|
|
+ //sql := `SELECT COUNT(1) AS count FROM (
|
|
|
+ // SELECT * FROM (
|
|
|
+ //SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
|
+ //ORDER BY data_time DESC
|
|
|
+ //)AS t
|
|
|
+ //GROUP BY t.data_time
|
|
|
+ //ORDER BY t.data_time DESC
|
|
|
+ // )AS n `
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //err = o.Raw(sql, indexCode).QueryRow(&count)
|
|
|
+
|
|
|
sql := `SELECT COUNT(1) AS count FROM (
|
|
|
SELECT * FROM (
|
|
|
SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
@@ -238,24 +291,29 @@ func GetMysteelChemicalIndexDataCount(indexCode string) (count int, err error) {
|
|
|
GROUP BY t.data_time
|
|
|
ORDER BY t.data_time DESC
|
|
|
)AS n `
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&count)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexCode).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetBaseFromMysteelChemicalIndexByIndexId 根据指标id获取指标信息
|
|
|
func GetBaseFromMysteelChemicalIndexByIndexId(indexId int) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id=? `
|
|
|
+ //err = o.Raw(sql, indexId).QueryRow(&item)
|
|
|
+
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id=? `
|
|
|
- err = o.Raw(sql, indexId).QueryRow(&item)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexId).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetBaseFromMysteelChemicalIndexByCode 根据指标code获取指标信息
|
|
|
func GetBaseFromMysteelChemicalIndexByCode(indexCode string) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code=? `
|
|
|
+ //err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code=? `
|
|
|
- err = o.Raw(sql, indexCode).QueryRow(&item)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexCode).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -264,32 +322,41 @@ func GetBaseFromMysteelChemicalIndexByCodeList(indexCodeList []string) (items []
|
|
|
if len(indexCodeList) <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code IN (%s) `
|
|
|
+ //holder := make([]string, 0)
|
|
|
+ //for range indexCodeList {
|
|
|
+ // holder = append(holder, "?")
|
|
|
+ //}
|
|
|
+ //sql = fmt.Sprintf(sql, strings.Join(holder, ","))
|
|
|
+ //_, err = o.Raw(sql, indexCodeList).QueryRows(&items)
|
|
|
+
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE index_code IN (%s) `
|
|
|
holder := make([]string, 0)
|
|
|
for range indexCodeList {
|
|
|
holder = append(holder, "?")
|
|
|
}
|
|
|
sql = fmt.Sprintf(sql, strings.Join(holder, ","))
|
|
|
- _, err = o.Raw(sql, indexCodeList).QueryRows(&items)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// GetBaseFromMysteelChemicalIndexByClassifyIdAndName 根据分类id和指标名名获取指标信息
|
|
|
-func GetBaseFromMysteelChemicalIndexByClassifyIdAndName(classifyId int, chartName string) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id = ? and index_name = ? `
|
|
|
- err = o.Raw(sql, classifyId, chartName).QueryRow(&item)
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
-// GetBaseFromMysteelChemicalIndexListByClassifyId 根据指标分类id获取指标列表信息
|
|
|
-func GetBaseFromMysteelChemicalIndexListByClassifyId(classifyId int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id=? `
|
|
|
- _, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
- return
|
|
|
-}
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexCodeList).Find(&items).Error
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+//
|
|
|
+//// GetBaseFromMysteelChemicalIndexByClassifyIdAndName 根据分类id和指标名名获取指标信息
|
|
|
+//func GetBaseFromMysteelChemicalIndexByClassifyIdAndName(classifyId int, chartName string) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
+// o := orm.NewOrmUsingDB("data")
|
|
|
+// sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id = ? and index_name = ? `
|
|
|
+// err = o.Raw(sql, classifyId, chartName).QueryRow(&item)
|
|
|
+// return
|
|
|
+//}
|
|
|
+//
|
|
|
+//// GetBaseFromMysteelChemicalIndexListByClassifyId 根据指标分类id获取指标列表信息
|
|
|
+//func GetBaseFromMysteelChemicalIndexListByClassifyId(classifyId int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
+// o := orm.NewOrmUsingDB("data")
|
|
|
+// sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id=? `
|
|
|
+// _, err = o.Raw(sql, classifyId).QueryRows(&items)
|
|
|
+// return
|
|
|
+//}
|
|
|
|
|
|
// GetBaseFromMysteelChemicalIndexListByClassifyIdList 根据指标分类id集合获取指标列表信息
|
|
|
func GetBaseFromMysteelChemicalIndexListByClassifyIdList(classifyIdList []int) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
@@ -297,84 +364,140 @@ func GetBaseFromMysteelChemicalIndexListByClassifyIdList(classifyIdList []int) (
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id IN (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, classifyIdList).QueryRows(&items)
|
|
|
+
|
|
|
sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id IN (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, classifyIdList).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, classifyIdList).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetBaseFromMysteelChemicalDataMaxCount 获取分类下指标的最大数量
|
|
|
func GetBaseFromMysteelChemicalDataMaxCount(classifyId int) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT MAX(t.num) AS count FROM (
|
|
|
+ // SELECT COUNT(1) AS num FROM base_from_mysteel_chemical_index AS a
|
|
|
+ // INNER JOIN base_from_mysteel_chemical_data AS b ON a.base_from_mysteel_chemical_index_id=b.base_from_mysteel_chemical_index_id
|
|
|
+ // WHERE a.base_from_mysteel_chemical_classify_id=?
|
|
|
+ // GROUP BY a.base_from_mysteel_chemical_index_id
|
|
|
+ // )AS t `
|
|
|
+ //err = o.Raw(sql, classifyId).QueryRow(&count)
|
|
|
+
|
|
|
sql := `SELECT MAX(t.num) AS count FROM (
|
|
|
SELECT COUNT(1) AS num FROM base_from_mysteel_chemical_index AS a
|
|
|
INNER JOIN base_from_mysteel_chemical_data AS b ON a.base_from_mysteel_chemical_index_id=b.base_from_mysteel_chemical_index_id
|
|
|
WHERE a.base_from_mysteel_chemical_classify_id=?
|
|
|
GROUP BY a.base_from_mysteel_chemical_index_id
|
|
|
)AS t `
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&count)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, classifyId).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexDataByCode 通过钢联化工指标code获取所有数据列表
|
|
|
func GetMysteelChemicalIndexDataByCode(indexCode string) (items []*MysteelChemicalData, err error) {
|
|
|
+ //sql := ` SELECT * FROM (
|
|
|
+ //SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
|
+ //ORDER BY data_time DESC
|
|
|
+ //)AS t
|
|
|
+ //GROUP BY t.data_time
|
|
|
+ //ORDER BY t.data_time DESC `
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //_, err = o.Raw(sql, indexCode).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT * FROM (
|
|
|
SELECT DISTINCT a.index_code,a.value,a.data_time FROM base_from_mysteel_chemical_data AS a WHERE index_code=?
|
|
|
ORDER BY data_time DESC
|
|
|
)AS t
|
|
|
GROUP BY t.data_time
|
|
|
ORDER BY t.data_time DESC `
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- _, err = o.Raw(sql, indexCode).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, indexCode).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// MoveBaseFromMysteelChemicalIndex 移动钢联化工指标分类
|
|
|
func MoveBaseFromMysteelChemicalIndex(chartInfoId, classifyId int) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` UPDATE base_from_mysteel_chemical_index
|
|
|
+ // SET
|
|
|
+ // base_from_mysteel_chemical_classify_id = ?
|
|
|
+ // WHERE base_from_mysteel_chemical_index_id = ?`
|
|
|
+ //_, err = o.Raw(sql, classifyId, chartInfoId).Exec()
|
|
|
+
|
|
|
sql := ` UPDATE base_from_mysteel_chemical_index
|
|
|
SET
|
|
|
base_from_mysteel_chemical_classify_id = ?
|
|
|
WHERE base_from_mysteel_chemical_index_id = ?`
|
|
|
- _, err = o.Raw(sql, classifyId, chartInfoId).Exec()
|
|
|
+ err = global.DmSQL["data"].Exec(sql, classifyId, chartInfoId).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// UpdateBaseFromMysteelChemicalIndexByClassifyId 根据指标id更新排序
|
|
|
func UpdateBaseFromMysteelChemicalIndexByClassifyId(classifyId, nowSort, prevIndexInfoId int, updateSort string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` update base_from_mysteel_chemical_index set sort = ` + updateSort + ` WHERE base_from_mysteel_chemical_classify_id=? AND `
|
|
|
+ //if prevIndexInfoId > 0 {
|
|
|
+ // sql += ` ( sort > ? or (base_from_mysteel_chemical_index_id > ` + fmt.Sprint(prevIndexInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `))`
|
|
|
+ //}
|
|
|
+ //_, err = o.Raw(sql, classifyId, nowSort).Exec()
|
|
|
+
|
|
|
sql := ` update base_from_mysteel_chemical_index set sort = ` + updateSort + ` WHERE base_from_mysteel_chemical_classify_id=? AND `
|
|
|
if prevIndexInfoId > 0 {
|
|
|
sql += ` ( sort > ? or (base_from_mysteel_chemical_index_id > ` + fmt.Sprint(prevIndexInfoId) + ` and sort = ` + fmt.Sprint(nowSort) + `))`
|
|
|
}
|
|
|
- _, err = o.Raw(sql, classifyId, nowSort).Exec()
|
|
|
+ err = global.DmSQL["data"].Exec(sql, classifyId, nowSort).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetFirstBaseFromMysteelChemicalIndexByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
|
|
|
func GetFirstBaseFromMysteelChemicalIndexByClassifyId(classifyId int) (item *BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id=? order by sort asc,base_from_mysteel_chemical_index_id asc limit 1`
|
|
|
+ //err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
+
|
|
|
sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_classify_id=? order by sort asc,base_from_mysteel_chemical_index_id asc limit 1`
|
|
|
- err = o.Raw(sql, classifyId).QueryRow(&item)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, classifyId).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexCount 根据条件获取钢联化工数据
|
|
|
func GetMysteelChemicalIndexCount(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT COUNT(1) AS count FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
+ //
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //sql += ` ORDER BY base_from_mysteel_chemical_index_id ASC `
|
|
|
+ //err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+
|
|
|
sql := ` SELECT COUNT(1) AS count FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
|
}
|
|
|
sql += ` ORDER BY base_from_mysteel_chemical_index_id ASC `
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexList 根据分类id获取钢联化工频度数据列表
|
|
|
func GetMysteelChemicalIndexList(condition string, pars []interface{}, startSize, pageSize int, orderDesc string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
+ //
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //if orderDesc == `` {
|
|
|
+ // orderDesc = ` ASC `
|
|
|
+ //}
|
|
|
+ //sql += ` ORDER BY base_from_mysteel_chemical_index_id `
|
|
|
+ //sql += orderDesc
|
|
|
+ //sql += ` LIMIT ?,? `
|
|
|
+ //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
|
|
|
if condition != "" {
|
|
@@ -387,23 +510,22 @@ func GetMysteelChemicalIndexList(condition string, pars []interface{}, startSize
|
|
|
sql += ` ORDER BY base_from_mysteel_chemical_index_id `
|
|
|
sql += orderDesc
|
|
|
sql += ` LIMIT ?,? `
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
-
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-// GetMysteelChemicalIndexListGroupByUserId 根据指标id列表、用户分组获取指标信息
|
|
|
-func GetMysteelChemicalIndexListGroupByUserId(edbIdList []string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
- num := len(edbIdList)
|
|
|
- if num <= 0 {
|
|
|
- return
|
|
|
- }
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY sys_user_id `
|
|
|
- _, err = o.Raw(sql, edbIdList).QueryRows(&items)
|
|
|
-
|
|
|
- return
|
|
|
-}
|
|
|
+//// GetMysteelChemicalIndexListGroupByUserId 根据指标id列表、用户分组获取指标信息
|
|
|
+//func GetMysteelChemicalIndexListGroupByUserId(edbIdList []string) (items []*BaseFromMysteelChemicalIndex, err error) {
|
|
|
+// num := len(edbIdList)
|
|
|
+// if num <= 0 {
|
|
|
+// return
|
|
|
+// }
|
|
|
+// o := orm.NewOrmUsingDB("data")
|
|
|
+// sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) GROUP BY sys_user_id `
|
|
|
+// _, err = o.Raw(sql, edbIdList).QueryRows(&items)
|
|
|
+//
|
|
|
+// return
|
|
|
+//}
|
|
|
|
|
|
// GetMysteelChemicalIndexListByIndexId
|
|
|
// @Description: 根据指标id列表获取列表信息
|
|
@@ -415,10 +537,12 @@ func GetMysteelChemicalIndexListByIndexId(edbIdList []string) (items []*BaseFrom
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, edbIdList).QueryRows(&items)
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, edbIdList).QueryRows(&items)
|
|
|
|
|
|
+ sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ err = global.DmSQL["data"].Raw(sql, edbIdList).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -432,10 +556,12 @@ func GetMysteelChemicalIndexListByUserId(userIdList []int) (items []*BaseFromMys
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, userIdList).QueryRows(&items)
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, userIdList).QueryRows(&items)
|
|
|
|
|
|
+ sql := ` SELECT * FROM base_from_mysteel_chemical_index WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ err = global.DmSQL["data"].Raw(sql, userIdList).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -445,9 +571,11 @@ func ModifyMysteelChemicalIndexUserIdByCodeList(edbIdList []string, userId int,
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `UPDATE base_from_mysteel_chemical_index SET sys_user_id=?,sys_user_real_name=? WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, userId, userName, edbIdList).Exec()
|
|
|
sql := `UPDATE base_from_mysteel_chemical_index SET sys_user_id=?,sys_user_real_name=? WHERE base_from_mysteel_chemical_index_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, userId, userName, edbIdList).Exec()
|
|
|
+ err = global.DmSQL["data"].Exec(sql, userId, userName, edbIdList).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -464,19 +592,24 @@ func ModifyMysteelChemicalIndexUserIdByOldUserId(oldUserIdList []int, userId int
|
|
|
if num <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := `UPDATE base_from_mysteel_chemical_index SET sys_user_id=?,sys_user_real_name=? WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, userId, userName, oldUserIdList).Exec()
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `UPDATE base_from_mysteel_chemical_index SET sys_user_id=?,sys_user_real_name=? WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, userId, userName, oldUserIdList).Exec()
|
|
|
|
|
|
+ sql := `UPDATE base_from_mysteel_chemical_index SET sys_user_id=?,sys_user_real_name=? WHERE sys_user_id in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ err = global.DmSQL["data"].Exec(sql, userId, userName, oldUserIdList).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// GetMysteelChemicalIndexAdminList 获取所有指标创建人
|
|
|
func GetMysteelChemicalIndexAdminList() (list []int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := ` SELECT sys_user_id FROM base_from_mysteel_chemical_index GROUP BY sys_user_id `
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT sys_user_id FROM base_from_mysteel_chemical_index GROUP BY sys_user_id `
|
|
|
+ //
|
|
|
+ //_, err = o.Raw(sql).QueryRows(&list)
|
|
|
|
|
|
- _, err = o.Raw(sql).QueryRows(&list)
|
|
|
+ sql := ` SELECT sys_user_id FROM base_from_mysteel_chemical_index GROUP BY sys_user_id `
|
|
|
+ err = global.DmSQL["data"].Raw(sql).Find(&list).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -487,9 +620,12 @@ type TerminalNum struct {
|
|
|
|
|
|
// GetMysteelChemicalGroupTerminalNum 获取钢联化工指标的终端分布
|
|
|
func GetMysteelChemicalGroupTerminalNum() (items []*TerminalNum, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := ` SELECT terminal_code,count(1) num FROM base_from_mysteel_chemical_index GROUP BY terminal_code ORDER BY num ASC `
|
|
|
+ //_, err = o.Raw(sql).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT terminal_code,count(1) num FROM base_from_mysteel_chemical_index GROUP BY terminal_code ORDER BY num ASC `
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -530,19 +666,42 @@ type RefreshBaseEdbInfoResp struct {
|
|
|
// @return items []*BaseRefreshEdbInfo
|
|
|
// @return err error
|
|
|
func GetMysteelChemicalBaseInfoList(condition string, pars []interface{}, orderBy string, startSize, pageSize int) (total int, items []*BaseRefreshEdbInfo, err error) {
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
|
|
|
// 数量汇总
|
|
|
+ //totalSql := ` SELECT count(1) FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
+ //if condition != "" {
|
|
|
+ // totalSql += condition
|
|
|
+ //}
|
|
|
+ //err = o.Raw(totalSql, pars).QueryRow(&total)
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
totalSql := ` SELECT count(1) FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
totalSql += condition
|
|
|
}
|
|
|
- err = o.Raw(totalSql, pars).QueryRow(&total)
|
|
|
+ err = global.DmSQL["data"].Raw(totalSql, pars).Scan(&total).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 列表数据
|
|
|
+ //sql := ` SELECT base_from_mysteel_chemical_index_id as edb_info_id, base_from_mysteel_chemical_classify_id as classify_id,index_code,index_name,end_date,end_value,sys_user_id,sys_user_real_name,frequency,is_stop,terminal_code FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
+ //if condition != "" {
|
|
|
+ // sql += condition
|
|
|
+ //}
|
|
|
+ //
|
|
|
+ //if orderBy != "" {
|
|
|
+ // sql += ` ORDER BY ` + orderBy
|
|
|
+ //} else {
|
|
|
+ // sql += ` ORDER BY base_from_mysteel_chemical_index_id ASC `
|
|
|
+ //}
|
|
|
+ //sql += ` LIMIT ?,? `
|
|
|
+ //
|
|
|
+ //_, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+
|
|
|
sql := ` SELECT base_from_mysteel_chemical_index_id as edb_info_id, base_from_mysteel_chemical_classify_id as classify_id,index_code,index_name,end_date,end_value,sys_user_id,sys_user_real_name,frequency,is_stop,terminal_code FROM base_from_mysteel_chemical_index WHERE 1=1 `
|
|
|
if condition != "" {
|
|
|
sql += condition
|
|
@@ -555,7 +714,7 @@ func GetMysteelChemicalBaseInfoList(condition string, pars []interface{}, orderB
|
|
|
}
|
|
|
sql += ` LIMIT ?,? `
|
|
|
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, pars, startSize, pageSize).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -572,21 +731,27 @@ func ModifyMysteelChemicalUpdateStatus(edbIdList []int, indexCodeList []string,
|
|
|
if idNum <= 0 {
|
|
|
return
|
|
|
}
|
|
|
- o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
- defer func() {
|
|
|
- if err != nil {
|
|
|
- _ = o.Rollback()
|
|
|
- return
|
|
|
- }
|
|
|
- _ = o.Commit()
|
|
|
- }()
|
|
|
+ //o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //defer func() {
|
|
|
+ // if err != nil {
|
|
|
+ // _ = o.Rollback()
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ // _ = o.Commit()
|
|
|
+ //}()
|
|
|
|
|
|
// 更改数据源的更新状态
|
|
|
+ //sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE base_from_mysteel_chemical_index_id IN (` + utils.GetOrmInReplace(idNum) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, edbIdList).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE base_from_mysteel_chemical_index_id IN (` + utils.GetOrmInReplace(idNum) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, edbIdList).Exec()
|
|
|
+ err = global.DmSQL["data"].Exec(sql, isStop, edbIdList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -594,11 +759,18 @@ func ModifyMysteelChemicalUpdateStatus(edbIdList []int, indexCodeList []string,
|
|
|
codeNum := len(indexCodeList)
|
|
|
if codeNum <= 0 {
|
|
|
// 需要通过指标id列表查找code列表
|
|
|
+ //sql := ` SELECT index_code FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id IN (` + utils.GetOrmInReplace(idNum) + `) `
|
|
|
+ //_, err = o.Raw(sql, edbIdList).QueryRows(&indexCodeList)
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql := ` SELECT index_code FROM base_from_mysteel_chemical_index WHERE base_from_mysteel_chemical_index_id IN (` + utils.GetOrmInReplace(idNum) + `) `
|
|
|
- _, err = o.Raw(sql, edbIdList).QueryRows(&indexCodeList)
|
|
|
+ err = global.DmSQL["data"].Raw(sql, edbIdList).Find(&indexCodeList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
}
|
|
|
|
|
|
codeNum = len(indexCodeList)
|
|
@@ -608,12 +780,17 @@ func ModifyMysteelChemicalUpdateStatus(edbIdList []int, indexCodeList []string,
|
|
|
}
|
|
|
|
|
|
// 更改指标的更新状态
|
|
|
+ //sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND sub_source= ? AND edb_code IN (` + utils.GetOrmInReplace(codeNum) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, indexCodeList).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND sub_source= ? AND edb_code IN (` + utils.GetOrmInReplace(codeNum) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, indexCodeList).Exec()
|
|
|
+ err = global.DmSQL["data"].Exec(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, indexCodeList).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -626,35 +803,64 @@ func ModifyMysteelChemicalUpdateStatus(edbIdList []int, indexCodeList []string,
|
|
|
// @param isStop int
|
|
|
// @return err error
|
|
|
func ModifyMysteelChemicalUpdateStatusByEdbInfoId(edbInfoId, isStop int, edbCode string, calculateEdbInfoIds []int) (err error) {
|
|
|
- o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ //o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //defer func() {
|
|
|
+ // if err != nil {
|
|
|
+ // _ = o.Rollback()
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ // _ = o.Commit()
|
|
|
+ //}()
|
|
|
+
|
|
|
+ to := global.DmSQL["data"].Begin()
|
|
|
+
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- _ = o.Rollback()
|
|
|
- return
|
|
|
+ _ = to.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = to.Commit()
|
|
|
}
|
|
|
- _ = o.Commit()
|
|
|
}()
|
|
|
|
|
|
// 更改数据源的更新状态
|
|
|
+ //sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE index_code = ? `
|
|
|
+ //_, err = o.Raw(sql, isStop, edbCode).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE index_code = ? `
|
|
|
- _, err = o.Raw(sql, isStop, edbCode).Exec()
|
|
|
+ err = to.Exec(sql, isStop, edbCode).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 更改指标的更新状态
|
|
|
+ //sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND sub_source= ? AND edb_info_id=? `
|
|
|
+ //_, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, edbInfoId).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND sub_source= ? AND edb_info_id=? `
|
|
|
- _, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, edbInfoId).Exec()
|
|
|
+ err = to.Exec(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, 0, edbInfoId).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
if len(calculateEdbInfoIds) > 0 {
|
|
|
// 批量更新相关联的指标ID
|
|
|
+ //sql = ` UPDATE edb_info SET no_update = ? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, calculateEdbInfoIds).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql = ` UPDATE edb_info SET no_update = ? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, calculateEdbInfoIds).Exec()
|
|
|
+ err = to.Exec(sql, isStop, calculateEdbInfoIds).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -664,35 +870,64 @@ func ModifyMysteelChemicalUpdateStatusByEdbInfoId(edbInfoId, isStop int, edbCode
|
|
|
}
|
|
|
|
|
|
func ModifyMysteelChemicalUpdateStatusByEdbInfoIds(edbInfoIds []int, isStop int, edbCodes []string, calculateEdbInfoIds []int) (err error) {
|
|
|
- o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
- if err != nil {
|
|
|
- return
|
|
|
- }
|
|
|
+ //o, err := orm.NewOrmUsingDB("data").Begin()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+ //defer func() {
|
|
|
+ // if err != nil {
|
|
|
+ // _ = o.Rollback()
|
|
|
+ // return
|
|
|
+ // }
|
|
|
+ // _ = o.Commit()
|
|
|
+ //}()
|
|
|
+
|
|
|
+ to := global.DmSQL["data"].Begin()
|
|
|
+
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- _ = o.Rollback()
|
|
|
- return
|
|
|
+ _ = to.Rollback()
|
|
|
+ } else {
|
|
|
+ _ = to.Commit()
|
|
|
}
|
|
|
- _ = o.Commit()
|
|
|
}()
|
|
|
|
|
|
// 更改数据源的更新状态
|
|
|
+ //sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE index_code IN (` + utils.GetOrmInReplace(len(edbCodes)) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, edbCodes).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = ? WHERE index_code IN (` + utils.GetOrmInReplace(len(edbCodes)) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, edbCodes).Exec()
|
|
|
+ err = to.Exec(sql, isStop, edbCodes).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 更改指标的更新状态
|
|
|
+ //sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND edb_info_id IN (` + utils.GetOrmInReplace(len(edbInfoIds)) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, edbInfoIds).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql = ` UPDATE edb_info SET no_update = ? WHERE source = ? AND edb_info_id IN (` + utils.GetOrmInReplace(len(edbInfoIds)) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, edbInfoIds).Exec()
|
|
|
+ err = to.Exec(sql, isStop, utils.DATA_SOURCE_MYSTEEL_CHEMICAL, edbInfoIds).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
if len(calculateEdbInfoIds) > 0 {
|
|
|
// 批量更新相关联的指标ID
|
|
|
+ //sql = ` UPDATE edb_info SET no_update = ? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, calculateEdbInfoIds).Exec()
|
|
|
+ //if err != nil {
|
|
|
+ // return
|
|
|
+ //}
|
|
|
+
|
|
|
sql = ` UPDATE edb_info SET no_update = ? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(calculateEdbInfoIds)) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, calculateEdbInfoIds).Exec()
|
|
|
+ err = to.Exec(sql, isStop, calculateEdbInfoIds).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
@@ -715,9 +950,11 @@ func GetNotIsSupplierStopIndexByCodeList(codeList []string, isStop int) (items [
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- o := orm.NewOrmUsingDB("data")
|
|
|
- sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE is_supplier_stop = ? AND index_code in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
- _, err = o.Raw(sql, isStop, codeList).QueryRows(&items)
|
|
|
+ //o := orm.NewOrmUsingDB("data")
|
|
|
+ //sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE is_supplier_stop = ? AND index_code in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ //_, err = o.Raw(sql, isStop, codeList).QueryRows(&items)
|
|
|
|
|
|
+ sql := `SELECT * FROM base_from_mysteel_chemical_index WHERE is_supplier_stop = ? AND index_code in (` + utils.GetOrmInReplace(num) + `) `
|
|
|
+ err = global.DmSQL["data"].Raw(sql, isStop, codeList).Find(&items).Error
|
|
|
return
|
|
|
}
|