计算指标关联表新增渠道子来源

models/edb_data_calculate_bp.go

@@ -65,6 +65,7 @@ func AddCalculateBp(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, edb
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = edbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -164,6 +165,7 @@ func EditCalculateBp(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromEd
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_cjjx.go

@@ -69,6 +69,7 @@ func AddCalculateCjjx(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, e
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = edbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -174,6 +175,7 @@ func EditCalculateCjjx(req *EdbInfoCalculateBatchEditReq, edbInfo, fromEdbInfo *
 				Sort:                      1,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             fromEdbInfo.SubSource,
 			}
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {

models/edb_data_calculate_correlation.go

@@ -85,6 +85,7 @@ func AddCalculateCorrelation(req *EdbInfoCalculateBatchSaveReq, edbCode, uniqueC
 		calculateMappingItem.FromTag = v.FromTag
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = edbInfo.SubSource
 		calculateMappingItemList = append(calculateMappingItemList, calculateMappingItem)
 	}
 
@@ -185,6 +186,7 @@ func EditCalculateCorrelation(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditRe
 		calculateMappingItem.FromTag = v.FromTag
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = edbInfo.SubSource
 		calculateMappingItemList = append(calculateMappingItemList, calculateMappingItem)
 
 	}

models/edb_data_calculate_hbz.go

@@ -65,6 +65,7 @@ func AddCalculateHbz(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, ed
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = edbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -158,6 +159,7 @@ func EditCalculateHbz(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromE
 				Sort:                      1,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             edbInfo.SubSource,
 			}
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {

models/edb_data_calculate_hcz.go

@@ -66,6 +66,7 @@ func AddCalculateHcz(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, ed
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -159,6 +160,7 @@ func EditCalculateHcz(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromE
 				Sort:                      1,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             fromEdbInfo.SubSource,
 			}
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {

models/edb_data_calculate_jp.go

@@ -92,6 +92,7 @@ func AddCalculateJp(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, edb
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -193,6 +194,7 @@ func EditCalculateJp(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromEd
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_kszs.go

@@ -81,6 +81,7 @@ func AddCalculateKszs(req *EdbInfoCalculateBatchSaveReq, edbCode, uniqueCode str
 		calculateMappingItem.FromTag = v.FromTag
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = edbInfo.SubSource
 		calculateMappingItemList = append(calculateMappingItemList, calculateMappingItem)
 
 		tagMap[v.FromTag] = v.EdbInfoId
@@ -166,6 +167,7 @@ func EditCalculateKszs(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq) (err
 		calculateMappingItem.FromTag = v.FromTag
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = edbInfo.SubSource
 		calculateMappingItemList = append(calculateMappingItemList, calculateMappingItem)
 
 		tagMap[v.FromTag] = v.EdbInfoId

models/edb_data_calculate_ljz.go

@@ -105,6 +105,7 @@ func (obj Ljz) Add(params AddCalculateBatchParams) (edbInfo *EdbInfo, err error,
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return
@@ -218,6 +219,7 @@ func (obj Ljz) Edit(params EditCalculateBatchParams) (err error, errMsg string)
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_ljznczj.go

@@ -105,6 +105,7 @@ func (obj LjzNczj) Add(params AddCalculateBatchParams) (edbInfo *EdbInfo, err er
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return
@@ -218,6 +219,7 @@ func (obj LjzNczj) Edit(params EditCalculateBatchParams) (err error, errMsg stri
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_ljztbpj.go

@@ -161,6 +161,7 @@ func AddCalculateLjztbpj(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, second
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             firstEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemA)
 		if tmpErr != nil {
@@ -187,6 +188,7 @@ func AddCalculateLjztbpj(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, second
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             secondEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemB)
 		if tmpErr != nil {
@@ -289,6 +291,7 @@ func EditCalculateLjztbpj(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbIn
 				Sort:                      1,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             firstEdbInfo.SubSource,
 			}
 			insertId, tmpErr := to.Insert(existItemA)
 			if tmpErr != nil {
@@ -328,6 +331,7 @@ func EditCalculateLjztbpj(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbIn
 				Sort:                      2,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             secondEdbInfo.SubSource,
 			}
 
 			insertId, tmpErr := to.Insert(existItemB)

models/edb_data_calculate_ljzzj.go

@@ -79,6 +79,7 @@ func (obj Ljzzj) Add(params AddCalculateBatchParams) (edbInfo *EdbInfo, err erro
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return
@@ -175,6 +176,7 @@ func (obj Ljzzj) Edit(params EditCalculateBatchParams) (err error, errMsg string
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_ljzzy.go

@@ -67,6 +67,7 @@ func AddCalculateLjzzy(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo,
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = edbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -166,6 +167,7 @@ func EditCalculateLjzzy(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fro
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_nh.go

@@ -65,6 +65,7 @@ func AddCalculateNh(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, edb
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -166,6 +167,7 @@ func EditCalculateNh(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromEd
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_nhcc.go

@@ -126,6 +126,7 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             firstEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemA)
 		if tmpErr != nil {
@@ -153,6 +154,7 @@ func AddCalculateNhcc(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             secondEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemB)
 		if tmpErr != nil {
@@ -274,6 +276,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
 					Sort:                      1,
 					CreateTime:                time.Now(),
 					ModifyTime:                time.Now(),
+					FromSubSource:             firstEdbInfo.SubSource,
 				}
 				insertId, tmpErr := to.Insert(existItemA)
 				if tmpErr != nil {
@@ -317,6 +320,7 @@ func EditCalculateNhcc(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
 				Sort:                      2,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             secondEdbInfo.SubSource,
 			}
 			insertId, tmpErr := to.Insert(existItemB)
 			if tmpErr != nil {
@@ -667,6 +671,7 @@ func CalculateComputeCorrelation(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             firstEdbInfo.SubSource,
 		}
 	}
 
@@ -684,6 +689,7 @@ func CalculateComputeCorrelation(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             secondEdbInfo.SubSource,
 		}
 	}
 

models/edb_data_calculate_nszydbpjjs.go

@@ -63,6 +63,7 @@ func AddCalculateNszydpjjs(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbIn
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -156,6 +157,7 @@ func EditCalculateNszydpjjs(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq,
 				Sort:                      1,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             fromEdbInfo.SubSource,
 			}
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {

models/edb_data_calculate_percentile.go

@@ -75,6 +75,7 @@ func (obj Percentile) Add(params AddCalculateBatchParams) (edbInfo *EdbInfo, err
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return
@@ -173,6 +174,7 @@ func (obj Percentile) Edit(params EditCalculateBatchParams) (err error, errMsg s
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_rjz.go

@@ -66,6 +66,7 @@ func AddCalculateRjz(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, ed
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -164,6 +165,7 @@ func EditCalculateRjz(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromE
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_standard_deviation.go

@@ -74,6 +74,7 @@ func (obj StandardDeviation) Add(params AddCalculateBatchParams) (edbInfo *EdbIn
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = edbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return

models/edb_data_calculate_tbz.go

@@ -66,6 +66,7 @@ func AddCalculateTbz(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, ed
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -164,6 +165,7 @@ func EditCalculateTbz(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromE
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_tcz.go

@@ -67,6 +67,7 @@ func AddCalculateTcz(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbInfo, ed
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -167,6 +168,7 @@ func EditCalculateTcz(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq, fromE
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {

models/edb_data_calculate_time_shift.go

@@ -68,6 +68,7 @@ func AddCalculateTimeShift(req *EdbInfoCalculateBatchSaveReq, fromEdbInfo *EdbIn
 			calculateMappingItem.FromTag = ""
 			calculateMappingItem.Source = edbInfo.Source
 			calculateMappingItem.SourceName = edbInfo.SourceName
+			calculateMappingItem.FromSubSource = edbInfo.SubSource
 			_, err = to.Insert(calculateMappingItem)
 			if err != nil {
 				return
@@ -168,6 +169,7 @@ func EditCalculateTimeShift(edbInfo *EdbInfo, req *EdbInfoCalculateBatchEditReq,
 					Sort:                      1,
 					CreateTime:                time.Now(),
 					ModifyTime:                time.Now(),
+					FromSubSource:             fromEdbInfo.SubSource,
 				}
 				_, err = to.Insert(calculateMappingItem)
 				if err != nil {

models/edb_data_calculate_zjpj.go

@@ -116,6 +116,7 @@ func AddCalculateZjpj(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             firstEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemA)
 		if tmpErr != nil {
@@ -142,6 +143,7 @@ func AddCalculateZjpj(req *EdbInfoCalculateBatchSaveReq, firstEdbInfo, secondEdb
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             secondEdbInfo.SubSource,
 		}
 		insertId, tmpErr := to.Insert(existItemB)
 		if tmpErr != nil {
@@ -245,6 +247,7 @@ func EditCalculateZjpj(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
 					Sort:                      1,
 					CreateTime:                time.Now(),
 					ModifyTime:                time.Now(),
+					FromSubSource:             firstEdbInfo.SubSource,
 				}
 				insertId, tmpErr := to.Insert(existItemA)
 				if tmpErr != nil {
@@ -286,6 +289,7 @@ func EditCalculateZjpj(req *EdbInfoCalculateBatchEditReq, edbInfo, firstEdbInfo,
 				Sort:                      2,
 				CreateTime:                time.Now(),
 				ModifyTime:                time.Now(),
+				FromSubSource:             secondEdbInfo.SubSource,
 			}
 			insertId, tmpErr := to.Insert(existItemB)
 			if tmpErr != nil {

models/edb_data_calculate_zsxy.go

@@ -73,6 +73,7 @@ func (obj ExponentialSmoothing) Add(params AddCalculateBatchParams) (edbInfo *Ed
 		calculateMappingItem.FromTag = ""
 		calculateMappingItem.Source = edbInfo.Source
 		calculateMappingItem.SourceName = edbInfo.SourceName
+		calculateMappingItem.FromSubSource = fromEdbInfo.SubSource
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {
 			return
@@ -170,6 +171,7 @@ func (obj ExponentialSmoothing) Edit(params EditCalculateBatchParams) (err error
 			Sort:                      1,
 			CreateTime:                time.Now(),
 			ModifyTime:                time.Now(),
+			FromSubSource:             fromEdbInfo.SubSource,
 		}
 		_, err = to.Insert(calculateMappingItem)
 		if err != nil {