Browse Source

fix:数据刷新

Roc 7 months ago
parent
commit
caec8b9078
1 changed files with 48 additions and 32 deletions
  1. 48 32
      controllers/target.go

+ 48 - 32
controllers/target.go

@@ -3248,38 +3248,54 @@ func (this *TargetController) ExcelDataAdd() {
 	updateEdbTradeMap := make(map[string]bool)
 	updateDataTradeMap := make(map[string]bool)
 	defer func() {
-		addRecordList := make([]*models.EdbinfoOpRecord, 0)
-		for tradeCode := range addEdbTradeMap {
-			addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
-				TradeCode:  tradeCode,
-				Remark:     "创建指标",
-				UserId:     sysUser.AdminId,
-				UserName:   sysUser.RealName,
-				CreateTime: time.Now(),
-			})
-		}
-		for tradeCode := range updateEdbTradeMap {
-			addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
-				TradeCode:  tradeCode,
-				Remark:     "编辑指标",
-				UserId:     sysUser.AdminId,
-				UserName:   sysUser.RealName,
-				CreateTime: time.Now(),
-			})
-		}
-		for tradeCode := range updateDataTradeMap {
-			addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
-				TradeCode:  tradeCode,
-				Remark:     "更新数据",
-				UserId:     sysUser.AdminId,
-				UserName:   sysUser.RealName,
-				CreateTime: time.Now(),
-			})
-		}
-		if len(addRecordList) > 0 {
-			obj := models.EdbinfoOpRecord{}
-			_ = obj.MulCreate(addRecordList)
-		}
+		go func(addEdbTradeMap, updateEdbTradeMap, updateDataTradeMap map[string]bool) {
+			addRecordList := make([]*models.EdbinfoOpRecord, 0)
+			for tradeCode := range addEdbTradeMap {
+				addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
+					TradeCode:  tradeCode,
+					Remark:     "创建指标",
+					UserId:     sysUser.AdminId,
+					UserName:   sysUser.RealName,
+					CreateTime: time.Now(),
+				})
+			}
+			for tradeCode := range updateEdbTradeMap {
+				addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
+					TradeCode:  tradeCode,
+					Remark:     "编辑指标",
+					UserId:     sysUser.AdminId,
+					UserName:   sysUser.RealName,
+					CreateTime: time.Now(),
+				})
+			}
+			for tradeCode := range updateDataTradeMap {
+				addRecordList = append(addRecordList, &models.EdbinfoOpRecord{
+					TradeCode:  tradeCode,
+					Remark:     "更新数据",
+					UserId:     sysUser.AdminId,
+					UserName:   sysUser.RealName,
+					CreateTime: time.Now(),
+				})
+			}
+			if len(addRecordList) > 0 {
+				obj := models.EdbinfoOpRecord{}
+				_ = obj.MulCreate(addRecordList)
+			}
+
+			//将该指标的code加入到 “手工数据导入后刷新” 缓存
+			if utils.Re == nil {
+				for tradeCode := range updateDataTradeMap {
+					// 更新手工数据的最大最小值
+					data.ModifyManualEdbMaxMinDate(tradeCode)
+					//将该指标的code加入到 “手工数据导入后刷新” 缓存
+					err := utils.Rc.LPush(utils.CACHE_IMPORT_MANUAL_DATA, tradeCode)
+					if err != nil {
+						fmt.Println("CACHE_IMPORT_MANUAL_DATA LPush Err:" + err.Error())
+					}
+				}
+
+			}
+		}(addEdbTradeMap, updateEdbTradeMap, updateDataTradeMap)
 	}()
 
 	//操作指标,新增指标及数据等