|
@@ -104,7 +104,7 @@ func AddOrUpdateEdbInfoRelation(objectId, objectType int, relationList []*EdbInf
|
|
|
|
|
|
if len(refreshEdbInfoIds) > 0 {
|
|
|
//todo 是否需要所有指标的刷新状态
|
|
|
- sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) AND no_update = 1`
|
|
|
+ sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) `
|
|
|
_, err = o.Raw(sql, time.Now(), refreshEdbInfoIds).Exec()
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -172,7 +172,7 @@ func AddOrUpdateEdbInfoRelationMulti(relationList []*EdbInfoRelation, refreshEdb
|
|
|
|
|
|
if len(refreshEdbInfoIds) > 0 {
|
|
|
// todo 更新指标的刷新状态
|
|
|
- sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) AND no_update = 1`
|
|
|
+ sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) `
|
|
|
_, err = o.Raw(sql, time.Now(), refreshEdbInfoIds).Exec()
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -405,7 +405,7 @@ func ReplaceRelationEdbInfoId(oldEdbInfo, newEdbInfo *EdbInfo, edbRelationIds []
|
|
|
|
|
|
if len(refreshEdbInfoIds) > 0 {
|
|
|
// todo 更新指标的刷新状态
|
|
|
- sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) AND no_update = 1`
|
|
|
+ sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) `
|
|
|
_, err = o.Raw(sql, time.Now(), refreshEdbInfoIds).Exec()
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -479,7 +479,7 @@ func UpdateSecondRelationEdbInfoId(edbRelationIds []int, relationList []*EdbInfo
|
|
|
|
|
|
if len(refreshEdbInfoIds) > 0 {
|
|
|
// todo 更新指标的刷新状态
|
|
|
- sql := ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) AND no_update = 1`
|
|
|
+ sql = ` UPDATE edb_info SET no_update = 0, set_update_time=? WHERE edb_info_id IN (` + utils.GetOrmInReplace(len(refreshEdbInfoIds)) + `) `
|
|
|
_, err = o.Raw(sql, time.Now(), refreshEdbInfoIds).Exec()
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -489,7 +489,7 @@ func UpdateSecondRelationEdbInfoId(edbRelationIds []int, relationList []*EdbInfo
|
|
|
//更新数据源钢联化工指标
|
|
|
if len(indexCodeList) > 0 {
|
|
|
// 更改数据源的更新状态
|
|
|
- sql := ` UPDATE base_from_mysteel_chemical_index SET is_stop = 0 WHERE index_code IN (` + utils.GetOrmInReplace(len(indexCodeList)) + `) and is_stop=1`
|
|
|
+ sql = ` UPDATE base_from_mysteel_chemical_index SET is_stop = 0 WHERE index_code IN (` + utils.GetOrmInReplace(len(indexCodeList)) + `) and is_stop=1`
|
|
|
_, err = o.Raw(sql, indexCodeList).Exec()
|
|
|
if err != nil {
|
|
|
return
|
|
@@ -502,7 +502,7 @@ func UpdateSecondRelationEdbInfoId(edbRelationIds []int, relationList []*EdbInfo
|
|
|
relationCodes = append(relationCodes, relationCode)
|
|
|
}
|
|
|
if len(relationCodes) > 0 {
|
|
|
- sql := ` UPDATE edb_info_relation e1
|
|
|
+ sql = ` UPDATE edb_info_relation e1
|
|
|
JOIN edb_info_relation e2 ON e1.relation_code = e2.relation_code
|
|
|
SET e1.parent_relation_id = e2.edb_info_relation_id
|
|
|
WHERE
|