瀏覽代碼

Merge branch 'coal_fix_0729' into custom

zwxi 7 月之前
父節點
當前提交
921285d9a3
共有 1 個文件被更改,包括 14 次插入2 次删除
  1. 14 2
      controllers/commodity_coal.go

+ 14 - 2
controllers/commodity_coal.go

@@ -1059,14 +1059,17 @@ func (this *CoalMineDataController) Coastal() {
 	for _, sheet := range req.SheetData {
 		sheetName = sheet.Name
 		//遍历行读取
-		maxCol := sheet.MaxCol
-		for i := 0; i < maxCol; i++ {
+		maxRow := sheet.MaxRow
+		for i := 0; i < maxRow; i++ {
 			if i == 0 {
 				row := sheet.Rows[i]
 				cells := row.Cells
 				for k, cell := range cells {
 					if k > 0 && k < 9 {
 						text := cell.Value
+						if text == "" {
+							continue
+						}
 						groupMap[k] = text
 						var item models.BaseFromCoalmineMapping
 						//合计命名
@@ -1169,6 +1172,7 @@ func (this *CoalMineDataController) Coastal() {
 					codeMap[v.IndexName] = v.IndexCode
 					newId, err := models.AddBaseFromCoalmineMapping(v)
 					if err != nil {
+						utils.FileLog.Info("再次添加公司指标名称错误:", err)
 						fmt.Println("再次添加公司指标名称错误", err)
 						continue
 					} else {
@@ -1181,6 +1185,7 @@ func (this *CoalMineDataController) Coastal() {
 			}
 		}
 	}
+	utils.FileLog.Info("指标操作完成")
 	fmt.Println("指标操作完成")
 
 	//给indexItem中的code赋值并插入index表
@@ -1190,6 +1195,7 @@ func (this *CoalMineDataController) Coastal() {
 			newId, err := models.AddBaseFromCoalCoastalIndex(v)
 			if err != nil {
 				fmt.Println("添加数据错误", err)
+				utils.FileLog.Info("添加数据错误:", err)
 			} else {
 				fmt.Println("新增成功", newId)
 			}
@@ -1197,6 +1203,7 @@ func (this *CoalMineDataController) Coastal() {
 			if indexMap[v.IndexName+v.DataTime] != v.DealValue && v.DealValue != "" {
 				err = models.UpdateBaseFromCoalCoastalIndex(v)
 				if err != nil {
+					utils.FileLog.Info("修改数据错误错误:", err)
 					fmt.Println("修改数据错误错误", err)
 					return
 				}
@@ -1338,6 +1345,7 @@ func (this *CoalMineDataController) Inland() {
 								if err != nil {
 									parsedTime, err = time.Parse("2006/01/02", text)
 									if err != nil {
+										utils.FileLog.Info("解析时间字符串出错:", err)
 										fmt.Println("解析时间字符串出错:", err)
 										return
 									}
@@ -1375,6 +1383,7 @@ func (this *CoalMineDataController) Inland() {
 					codeMap[v.IndexName] = v.IndexCode
 					newId, err := models.AddBaseFromCoalmineMapping(v)
 					if err != nil {
+						utils.FileLog.Info("再次添加公司指标名称错误:", err)
 						fmt.Println("再次添加公司指标名称错误", err)
 						continue
 					} else {
@@ -1387,6 +1396,7 @@ func (this *CoalMineDataController) Inland() {
 			}
 		}
 	}
+	utils.FileLog.Info("指标操作完成:")
 	fmt.Println("指标操作完成")
 
 	//给indexItem中的code赋值并插入index表
@@ -1395,6 +1405,7 @@ func (this *CoalMineDataController) Inland() {
 		if indexMap[v.IndexName+v.DataTime] == "" && v.DealValue != "" {
 			newId, err := models.AddBaseFromCoalInlandIndex(v)
 			if err != nil {
+				utils.FileLog.Info("添加数据错误:", err)
 				fmt.Println("添加数据错误", err)
 			} else {
 				fmt.Println("新增成功", newId)
@@ -1403,6 +1414,7 @@ func (this *CoalMineDataController) Inland() {
 			if indexMap[v.IndexName+v.DataTime] != v.DealValue && v.DealValue != "" {
 				err = models.UpdateBaseFromCoalInlandIndex(v)
 				if err != nil {
+					utils.FileLog.Info("修改数据错误错误:", err)
 					fmt.Println("修改数据错误错误", err)
 					return
 				}