package services // //import ( // "encoding/json" // "fmt" // "hongze/hongqi_watch/global" // "hongze/hongqi_watch/models/index" // "hongze/hongqi_watch/utils" // "strconv" // "strings" // "sync" // "time" // // "github.com/rdlucklib/rdluck_tools/paging" // "github.com/xuri/excelize/v2" //) // //// Merge 合并指标 //func Merge() { // fmt.Println("merge start") // /* // 年底，季度，存放在一个excel中 // 月度30个指标存一个excel // 周度25个指标存放一个excel // 日度20个指标存一个excel // */ // //年度->38 // IndexYearMerge() // //季度->5 // IndexSeasonMerge() // //月度->86 // IndexMonthMerge() // //周度->292 // IndexWeekMerge() // //日度->114 // IndexDayMerge() // //merge_file_path // fmt.Println("merge end") //} // ////年度 //func IndexYearMerge() { // frequency := "年度" // fileName := "year" + ".xlsx" //保存的文件名称 // yearIndexFilePath := utils.IndexMsergeSaveDir + fileName // // var err error // // indexObj := new(index.BaseFromMysteelChemicalIndex) // yearList, err := indexObj.GetIndexByFrequency(frequency) // if err != nil { // fmt.Println("GetIndexByFrequency Err:" + err.Error()) // return // } // // if len(yearList) <= 0 { // return // } // // commentResult, err := GetIndexComment(yearIndexFilePath, yearList, 1) // if err != nil { // fmt.Println("GetIndexComment Err:" + err.Error()) // return // } // if utils.FileIsExist(yearIndexFilePath) { //修改文件 // fileObj, err := excelize.OpenFile(yearIndexFilePath) // if err != nil { // fmt.Println("打开文件失败,Err:" + err.Error()) // return // } // // fileObj.DeleteComment("Sheet1", "A1") // fileObj.AddComment("Sheet1", "A1", commentResult) // if err := fileObj.SaveAs(yearIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // fileObj.Close() // return // } // fileObj.Close() // } else { //新增文件 // templatePath := utils.IndexSaveDir + "index_template.xlsx" // templateFile, err := excelize.OpenFile(templatePath) // if err != nil { // fmt.Println("打开文件失败,Err:" + err.Error()) // return // } // templateFile.DeleteComment("Sheet1", "A1") // templateFile.AddComment("Sheet1", "A1", commentResult) // if err := templateFile.SaveAs(yearIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // templateFile.Close() // return // } // templateFile.Close() // } // //刷新数据 // //MysteelChemicalRefresh(yearIndexFilePath) // AddIndexRefreshToLpush(yearIndexFilePath) //} // ////季度 //func IndexSeasonMerge() { // frequency := "季度" // fileName := "season" + ".xlsx" //保存的文件名称 // seasonIndexFilePath := utils.IndexMsergeSaveDir + fileName // // var err error // // indexObj := new(index.BaseFromMysteelChemicalIndex) // seasonList, err := indexObj.GetIndexByFrequency(frequency) // if err != nil { // fmt.Println("GetIndexByFrequency Err:" + err.Error()) // return // } // // if len(seasonList) <= 0 { // return // } // // commentResult, err := GetIndexComment(seasonIndexFilePath, seasonList, 1) // if err != nil { // fmt.Println("GetIndexComment Err:" + err.Error()) // return // } // if utils.FileIsExist(seasonIndexFilePath) { //修改文件 // fileObj, err := excelize.OpenFile(seasonIndexFilePath) // if err != nil { // fmt.Println("打开文件失败,Err:" + err.Error()) // return // } // // fileObj.DeleteComment("Sheet1", "A1") // fileObj.AddComment("Sheet1", "A1", commentResult) // if err := fileObj.SaveAs(seasonIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // fileObj.Close() // return // } // fileObj.Close() // } else { //新增文件 // templatePath := utils.IndexSaveDir + "index_template.xlsx" // templateFile, err := excelize.OpenFile(templatePath) // if err != nil { // fmt.Println("打开文件失败,Err:" + err.Error()) // return // } // templateFile.DeleteComment("Sheet1", "A1") // templateFile.AddComment("Sheet1", "A1", commentResult) // if err := templateFile.SaveAs(seasonIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // templateFile.Close() // return // } // templateFile.Close() // } // //刷新数据 // //MysteelChemicalRefresh(seasonIndexFilePath) // AddIndexRefreshToLpush(seasonIndexFilePath) //} // ////月度 ////func IndexMonthMerge() { //// frequency := "月度" //// filePre := "month" //// pageSize := 30 //// var err error //// //// indexObj := new(index.BaseFromMysteelChemicalIndex) //// total, err := indexObj.GetIndexByFrequencyCount(frequency) //// if err != nil { //// fmt.Println("GetIndexByFrequencyCount Err:" + err.Error()) //// return //// } //// //// maxFileIndexItem, err := indexObj.GetMaxFileIndex(frequency) //// if err != nil { //// fmt.Println("GetMaxFileIndex Err:" + err.Error()) //// return //// } //// //// maxFileIndex := maxFileIndexItem.FileIndex //// if maxFileIndex <= 0 { //// maxFileIndex = 1 //// } //// //// fileName := filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// monthIndexFilePath := utils.IndexMsergeSaveDir + fileName //// //// indexTotal, err := indexObj.GetIndexCountByMergeFilePath(monthIndexFilePath) //// if err != nil { //// fmt.Println("GetIndexCountByMergeFilePath Err:" + err.Error()) //// return //// } //// //// if (indexTotal > int64(pageSize)/2) && maxFileIndex != 1 { //// maxFileIndex += 1 //// } //// //// fmt.Println("maxFileIndex:", maxFileIndex) //// totalPage := paging.PageCount(int(total), pageSize) //// fmt.Println("total:", total) //// fmt.Println("totalPage:", totalPage) //// for i := 1; i <= totalPage; i++ { //// //// offset := (i - 1) * pageSize //// //// fileName = filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// monthIndexFilePath := utils.IndexMsergeSaveDir + fileName //// fmt.Println(monthIndexFilePath) //// //// fmt.Println(offset, pageSize) //// pageList, err := indexObj.GetIndexByFrequencyPage(frequency, offset, pageSize) //// if err != nil { //// fmt.Println("GetIndexByFrequency Err:" + err.Error()) //// return //// } //// //// commentResult, err := GetIndexComment(monthIndexFilePath, pageList, maxFileIndex) //// if err != nil { //// fmt.Println("GetIndexComment Err:" + err.Error()) //// return //// } //// if utils.FileIsExist(monthIndexFilePath) { //修改文件 //// fileObj, err := excelize.OpenFile(monthIndexFilePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// //// fileObj.DeleteComment("Sheet1", "A1") //// fileObj.AddComment("Sheet1", "A1", commentResult) //// if err := fileObj.SaveAs(monthIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// fileObj.Close() //// return //// } //// fileObj.Close() //// } else { //新增文件 //// templatePath := utils.IndexSaveDir + "index_template.xlsx" //// templateFile, err := excelize.OpenFile(templatePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// templateFile.DeleteComment("Sheet1", "A1") //// templateFile.AddComment("Sheet1", "A1", commentResult) //// if err := templateFile.SaveAs(monthIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// templateFile.Close() //// return //// } //// templateFile.Close() //// } //// maxFileIndex += 1 //// time.Sleep(1 * time.Second) //// } ////} // //func IndexMonthMerge() { // frequency := "月度" // filePre := "month" // pageSize := 30 // err := indexMerge(frequency, filePre, pageSize) // if err != nil { // fmt.Println("合并月度指标失败，err:", err) // } //} // ////日度 ////func IndexDayMerge() { //// frequency := "日度" //// filePre := "day" //// pageSize := 30 //// var err error //// //// indexObj := new(index.BaseFromMysteelChemicalIndex) //// total, err := indexObj.GetIndexByFrequencyCount(frequency) //// if err != nil { //// fmt.Println("GetIndexByFrequencyCount Err:" + err.Error()) //// return //// } //// //// maxFileIndexItem, err := indexObj.GetMaxFileIndex(frequency) //// if err != nil { //// fmt.Println("GetMaxFileIndex Err:" + err.Error()) //// return //// } //// //// maxFileIndex := maxFileIndexItem.FileIndex //// if maxFileIndex <= 0 { //// maxFileIndex = 1 //// } //// //// fileName := filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// monthIndexFilePath := utils.IndexMsergeSaveDir + fileName //// //// indexTotal, err := indexObj.GetIndexCountByMergeFilePath(monthIndexFilePath) //// if err != nil { //// fmt.Println("GetIndexCountByMergeFilePath Err:" + err.Error()) //// return //// } //// //// if (indexTotal > int64(pageSize)/2) && maxFileIndex != 1 { //// maxFileIndex += 1 //// } //// //// fmt.Println("maxFileIndex:", maxFileIndex) //// totalPage := paging.PageCount(int(total), pageSize) //// fmt.Println("total:", total) //// fmt.Println("totalPage:", totalPage) //// for i := 1; i <= totalPage; i++ { //// //// offset := (i - 1) * pageSize //// //// fileName = filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// monthIndexFilePath := utils.IndexMsergeSaveDir + fileName //// fmt.Println(monthIndexFilePath) //// //// fmt.Println(offset, pageSize) //// pageList, err := indexObj.GetIndexByFrequencyPage(frequency, offset, pageSize) //// if err != nil { //// fmt.Println("GetIndexByFrequency Err:" + err.Error()) //// return //// } //// //// commentResult, err := GetIndexComment(monthIndexFilePath, pageList, maxFileIndex) //// if err != nil { //// fmt.Println("GetIndexComment Err:" + err.Error()) //// return //// } //// if utils.FileIsExist(monthIndexFilePath) { //修改文件 //// fileObj, err := excelize.OpenFile(monthIndexFilePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// //// fileObj.DeleteComment("Sheet1", "A1") //// fileObj.AddComment("Sheet1", "A1", commentResult) //// if err := fileObj.SaveAs(monthIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// fileObj.Close() //// return //// } //// fileObj.Close() //// } else { //新增文件 //// templatePath := utils.IndexSaveDir + "index_template.xlsx" //// templateFile, err := excelize.OpenFile(templatePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// templateFile.DeleteComment("Sheet1", "A1") //// templateFile.AddComment("Sheet1", "A1", commentResult) //// if err := templateFile.SaveAs(monthIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// templateFile.Close() //// return //// } //// templateFile.Close() //// } //// maxFileIndex += 1 //// time.Sleep(1 * time.Second) //// } ////} // //// IndexDayMerge 日度指标合并 //func IndexDayMerge() { // frequency := "日度" // filePre := "day" // pageSize := 30 //每个excel表需要的指标数 // err := indexMerge(frequency, filePre, pageSize) // if err != nil { // fmt.Println("合并日度指标失败，err:", err) // } //} // //// IndexWeekMerge 周度指标合并 //func IndexWeekMerge() { // frequency := "周度" // filePre := "week" // pageSize := 30 //每个excel表需要的指标数 // err := indexMerge(frequency, filePre, pageSize) // if err != nil { // fmt.Println("合并周度指标失败，err:", err) // } //} // ////func IndexWeekMerge() { //// frequency := "周度" //// filePre := "week" //// pageSize := 30 //每个excel表需要的指标数 //// firstIndexCount := pageSize //第一个添加的excel表需要的指标数 //// var err error //// //// indexObj := new(index.BaseFromMysteelChemicalIndex) //// //// // 获取未合并的指标总数量 //// total, err := indexObj.GetNoMergeIndexByFrequencyCount(frequency) //// if err != nil { //// fmt.Println("GetIndexByFrequencyCount Err:" + err.Error()) //// return //// } //// //未合并的指标总数量小于等于0，说明没有需要合并的指标 //// if total <=0{ //// return //// } //// //// // 获取最大的文件编号下标 //// maxFileIndexItem, err := indexObj.GetMaxFileIndex(frequency) //// if err != nil { //// fmt.Println("GetMaxFileIndex Err:" + err.Error()) //// return //// } //// //// maxFileIndex := maxFileIndexItem.FileIndex //// if maxFileIndex <= 0 { //// maxFileIndex = 1 //// } //// //// fileName := filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// maxMergeIndexFilePath := utils.IndexMsergeSaveDir + fileName //// //// // 根据文件下标获取该文件下标已经存在多少的指标 //// indexTotal, err := indexObj.GetIndexCountByMergeFilePath(maxMergeIndexFilePath) //// if err != nil { //// fmt.Println("GetIndexCountByMergeFilePath Err:" + err.Error()) //// return //// } //// //// // 如果最近的excel表的指标数量 少于 每页需要的指标数 //// if int(indexTotal) < pageSize { //// // 最近的excel表的待添加指标数 = 每页需要的指标数 - 已经添加的指标 //// firstIndexCount = pageSize - int(indexTotal) //// } //// //// fmt.Println("maxFileIndex:", maxFileIndex) //// //// // 除去第一个excel表的剩余需要添加的指标数量 //// nextTotal := int(total)-firstIndexCount //// // 总文件数 //// totalPage := paging.PageCount(nextTotal, pageSize) //// totalPage = totalPage+1 //需要加上除去在外面的指标（第一张excel） //// fmt.Println("total:", total) //// fmt.Println("totalPage:", totalPage) //// for i := 1; i <= totalPage; i++ { //// //offset := (i - 1) * pageSize //// //// fileName = filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 //// mergeIndexFilePath := utils.IndexMsergeSaveDir + fileName //// fmt.Println(mergeIndexFilePath) //// //// var list []*index.BaseFromMysteelChemicalIndex //// // 需要查询的指标数 //// size := pageSize //// if i == 1{ //// size = firstIndexCount // 第一页需要合并的新指标数 //// //// // 第一页需要的指标列表 //// tmpList ,tmpErr := indexObj.GetIndexByFrequencyListByMergeFilePath(frequency,mergeIndexFilePath) //// if tmpErr != nil{ //// fmt.Println("GetIndexByFrequencyListByMergeFilePath Err:" + err.Error()) //// return //// } //// list = tmpList //// } //// fmt.Println("需要查询",size,"个指标") //// //// //fmt.Println(offset, pageSize) //// //// // 当下需要合并到excel的指标 //// pageList, err := indexObj.GetNoMergeIndexByFrequencyPage(frequency, size) //// if err != nil { //// fmt.Println("GetIndexByFrequency Err:" + err.Error()) //// return //// } //// //// if len(list)>0{ //// pageList = append(pageList,list...) //// } //// //// commentResult, err := GetIndexComment(mergeIndexFilePath, pageList, maxFileIndex) //// if err != nil { //// fmt.Println("GetIndexComment Err:" + err.Error()) //// return //// } //// if utils.FileIsExist(mergeIndexFilePath) { //修改文件 //// fileObj, err := excelize.OpenFile(mergeIndexFilePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// //// fileObj.DeleteComment("Sheet1", "A1") //// fileObj.AddComment("Sheet1", "A1", commentResult) //// if err := fileObj.SaveAs(mergeIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// fileObj.Close() //// return //// } //// fileObj.Close() //// } else { //新增文件 //// templatePath := utils.IndexSaveDir + "index_template.xlsx" //// templateFile, err := excelize.OpenFile(templatePath) //// if err != nil { //// fmt.Println("打开文件失败,Err:" + err.Error()) //// return //// } //// templateFile.DeleteComment("Sheet1", "A1") //// templateFile.AddComment("Sheet1", "A1", commentResult) //// if err := templateFile.SaveAs(mergeIndexFilePath); err != nil { //// fmt.Println("保存失败,Err:" + err.Error()) //// templateFile.Close() //// return //// } //// templateFile.Close() //// } //// maxFileIndex += 1 //// time.Sleep(1 * time.Second) //// } ////} // //// indexMerge 指标合并 //// @params frequency string 频度 //// @params filePre string 文件名前缀 //// @params pageSize int 每个excel表中的指标数量 //func indexMerge(frequency, filePre string, pageSize int) (err error) { // firstIndexCount := pageSize //第一个添加的excel表需要的指标数 // indexObj := new(index.BaseFromMysteelChemicalIndex) // // // 获取未合并的指标总数量 // total, err := indexObj.GetNoMergeIndexByFrequencyCount(frequency) // if err != nil { // fmt.Println("GetIndexByFrequencyCount Err:" + err.Error()) // return // } // //未合并的指标总数量小于等于0，说明没有需要合并的指标 // if total <= 0 { // return // } // // // 获取最大的文件编号下标 // maxFileIndexItem, err := indexObj.GetMaxFileIndex(frequency) // if err != nil { // fmt.Println("GetMaxFileIndex Err:" + err.Error()) // return // } // // maxFileIndex := maxFileIndexItem.FileIndex // if maxFileIndex <= 0 { // maxFileIndex = 1 // } // // fileName := filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 // maxMergeIndexFilePath := utils.IndexMsergeSaveDir + fileName // // // 根据文件下标获取该文件下标已经存在多少的指标 // indexTotal, err := indexObj.GetIndexCountByMergeFilePath(maxMergeIndexFilePath) // if err != nil { // fmt.Println("GetIndexCountByMergeFilePath Err:" + err.Error()) // return // } // // // 如果最近的excel表的指标数量 少于 每页需要的指标数 // if int(indexTotal) < pageSize { // // 最近的excel表的待添加指标数 = 每页需要的指标数 - 已经添加的指标 // firstIndexCount = pageSize - int(indexTotal) // } // // fmt.Println("maxFileIndex:", maxFileIndex) // // // 除去第一个excel表的剩余需要添加的指标数量 // nextTotal := int(total) - firstIndexCount // // 总文件数 // totalPage := paging.PageCount(nextTotal, pageSize) // totalPage = totalPage + 1 //需要加上除去在外面的指标（第一张excel） // fmt.Println("total:", total) // fmt.Println("totalPage:", totalPage) // for i := 1; i <= totalPage; i++ { // //offset := (i - 1) * pageSize // // fileName = filePre + "_" + strconv.Itoa(maxFileIndex) + ".xlsx" //保存的文件名称 // mergeIndexFilePath := utils.IndexMsergeSaveDir + fileName // fmt.Println(mergeIndexFilePath) // // //var list []*index.BaseFromMysteelChemicalIndex // // 需要查询的指标数 // size := pageSize // if i == 1 { // size = firstIndexCount // 第一页需要合并的新指标数 // // // 第一页需要的指标列表 // //tmpList, tmpErr := indexObj.GetIndexByFrequencyListByMergeFilePath(frequency, mergeIndexFilePath) // //if tmpErr != nil { // // fmt.Println("GetIndexByFrequencyListByMergeFilePath Err:" + tmpErr.Error()) // // err = tmpErr // // return // //} // //list = tmpList // } // fmt.Println("需要查询", size, "个指标") // // //fmt.Println(offset, pageSize) // // // 当下需要合并到excel的指标 // pageList, tmpErr := indexObj.GetNoMergeIndexByFrequencyPage(frequency, size) // if tmpErr != nil { // fmt.Println("GetIndexByFrequency Err:" + tmpErr.Error()) // err = tmpErr // return // } // // //if len(list) > 0 { // // pageList = append(pageList, list...) // //} // // commentResult, tmpErr := GetIndexComment(mergeIndexFilePath, pageList, maxFileIndex) // if tmpErr != nil { // fmt.Println("GetIndexComment Err:" + tmpErr.Error()) // err = tmpErr // return // } // if utils.FileIsExist(mergeIndexFilePath) { //修改文件 // fileObj, tmpErr := excelize.OpenFile(mergeIndexFilePath) // if tmpErr != nil { // fmt.Println("打开文件失败,Err:" + tmpErr.Error()) // err = tmpErr // return // } // // fileObj.DeleteComment("Sheet1", "A1") // fileObj.AddComment("Sheet1", "A1", commentResult) // if err = fileObj.SaveAs(mergeIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // fileObj.Close() // return // } // fileObj.Close() // } else { //新增文件 // templatePath := utils.IndexSaveDir + "index_template.xlsx" // templateFile, tmpErr := excelize.OpenFile(templatePath) // if tmpErr != nil { // fmt.Println("打开文件失败,Err:" + tmpErr.Error()) // err = tmpErr // return // } // templateFile.DeleteComment("Sheet1", "A1") // templateFile.AddComment("Sheet1", "A1", commentResult) // if err = templateFile.SaveAs(mergeIndexFilePath); err != nil { // fmt.Println("保存失败,Err:" + err.Error()) // templateFile.Close() // return // } // templateFile.Close() // } // maxFileIndex += 1 // time.Sleep(1 * time.Second) // //刷新数据 // //MysteelChemicalRefresh(mergeIndexFilePath) // AddIndexRefreshToLpush(mergeIndexFilePath) // } // return //} // //func GetIndexComment(indexFilePath string, list []*index.BaseFromMysteelChemicalIndex, fileIndex int) (commentResult string, err error) { // runMode := "release" // indexInfo := new(IndexObj) // if utils.FileIsExist(indexFilePath) { //文件存在 // fmt.Println("utils.FileIsExist") // getCommentStr := GetComment(indexFilePath) // fmt.Println(getCommentStr) // // err = json.Unmarshal([]byte(getCommentStr), &indexInfo) // if err != nil { // fmt.Println("json.Unmarshal err:" + err.Error()) // return // } // } else { //文件不存在， // indexInfo.BlankValue = "0" // indexInfo.CanMark = true // indexInfo.ChartLineType = "0" // indexInfo.DateBlock = 0 // indexInfo.DateBlockCount = 1 // indexInfo.DateFormat = 0 // indexInfo.DateTimeTag = "637973605613980000" // indexInfo.EndDate = "" // indexInfo.ExportType = 0 // indexInfo.HasDescription = true // indexInfo.HasEmptyRows = false // indexInfo.HasFrequency = true // indexInfo.HasIndexID = true // indexInfo.HasLastDate = true // indexInfo.HasSourceName = true // indexInfo.HasTimeInterval = true // indexInfo.HasUnit = true // indexInfo.HasUpdateDate = true // indexInfo.IsCreateChart = false // indexInfo.IsDataSort = true // indexInfo.IsNewSheet = false // indexInfo.IsNewWorkbook = false // indexInfo.Position = "A1" // indexInfo.ShowBlankLines = false // indexInfo.StartDate = "" // indexInfo.Transpose = false // indexInfo.UpdateMode = 1 // indexInfo.LookModel.IsLast = false // indexInfo.LookModel.LookValue = 0 // indexInfo.LookModel.LookType = 0 // indexInfo.Ver = 3 // } // modelsList := make([]IndexModels, 0) // startDate := "1990-01-01" // // indexObj := new(index.BaseFromMysteelChemicalIndex) // // modelsList = append(modelsList, indexInfo.Models...) // // for k, v := range list { // fmt.Println(k, v) // item := new(IndexModels) // item.DataFormat = 0 // if v.IndexName == "" { // item.DataStartDate = startDate // } else { // item.DataStartDate = v.StartDate.Format(utils.FormatDate) // } // item.DefineName = "" // item.DefineUnit = "" // item.DisplayIndexCode = v.IndexCode // item.IndexCode = v.IndexCode // item.IndexFormula = v.IndexCode // item.PointValue = 0 // item.UnionStart = "" // modelsList = append(modelsList, *item) // // indexObj.IndexCode = v.IndexCode // indexObj.MergeFilePath = indexFilePath // indexObj.FileIndex = fileIndex // // updateColsArr := make([]string, 0) // updateColsArr = append(updateColsArr, "merge_file_path") // updateColsArr = append(updateColsArr, "file_index") // // err = indexObj.Update(runMode, updateColsArr) // if err != nil { // fmt.Println("indexObj.Update err:" + err.Error()) // return // } // } // // indexInfo.Models = modelsList // // indexStr, err := json.Marshal(indexInfo) // if err != nil { // fmt.Println("json.Marshal err:" + err.Error()) // return // } // text := string(indexStr) // text = strings.Trim(text, "{") // // commentMap := make(map[string]interface{}) // commentMap["author"] = "{" // commentMap["text"] = text // //commentMap["text"] = commentItem // // commentJson, err := json.Marshal(commentMap) // if err != nil { // fmt.Println("json.Marshal err:" + err.Error()) // } // commentResult = string(commentJson) // return //} // //type IndexObj struct { // BlankValue string `json:"BlankValue"` // CanMark bool `json:"CanMark"` // ChartLineType string `json:"ChartLineType"` // DateBlock int64 `json:"DateBlock"` // DateBlockCount int64 `json:"DateBlockCount"` // DateFormat int64 `json:"DateFormat"` // DateTimeTag string `json:"DateTimeTag"` // EndDate string `json:"EndDate"` // ExportType int64 `json:"ExportType"` // HasDescription bool `json:"HasDescription"` // HasEmptyRows bool `json:"HasEmptyRows"` // HasFrequency bool `json:"HasFrequency"` // HasIndexID bool `json:"HasIndexID"` // HasLastDate bool `json:"HasLastDate"` // HasSourceName bool `json:"HasSourceName"` // HasTimeInterval bool `json:"HasTimeInterval"` // HasUnit bool `json:"HasUnit"` // HasUpdateDate bool `json:"HasUpdateDate"` // IsCreateChart bool `json:"IsCreateChart"` // IsDataSort bool `json:"IsDataSort"` // IsNewSheet bool `json:"IsNewSheet"` // IsNewWorkbook bool `json:"IsNewWorkbook"` // Models []IndexModels `json:"Models"` // Position string `json:"Position"` // RangeData string `json:"RangeData"` // ShowBlankLines bool `json:"ShowBlankLines"` // StartDate string `json:"StartDate"` // Transpose bool `json:"Transpose"` // UpdateMode int64 `json:"UpdateMode"` // LookModel struct { // IsLast bool `json:"IsLast"` // LookValue int64 `json:"LookValue"` // LookType int64 `json:"lookType"` // } `json:"lookModel"` // Ver int64 `json:"ver"` //} // //type IndexModels struct { // DataFormat int64 `json:"DataFormat"` // DataStartDate string `json:"DataStartDate"` // DefineName string `json:"DefineName"` // DefineUnit string `json:"DefineUnit"` // DisplayIndexCode string `json:"DisplayIndexCode"` // IndexCode string `json:"IndexCode"` // IndexFormula string `json:"IndexFormula"` // PointValue int64 `json:"PointValue"` // UnionStart string `json:"UnionStart"` //} // //func DataAnalysis(filePath string) { // // runMode := "debug" // //runMode = "release" // // fmt.Println("filePath:", filePath) // time.Sleep(1 * time.Second) // if !utils.FileIsExist(filePath) { // fmt.Println("filePath is not exist:" + filePath) // return // } // //读取文件内容 // global.LOG.Info("WatchFile:" + filePath) // f, err := excelize.OpenFile(filePath) // global.LOG.Info("OpenFile:" + filePath) // if err != nil { // fmt.Println("OpenFile:" + filePath + ",Err:" + err.Error()) // return // } // defer func() { // if err := f.Close(); err != nil { // fmt.Println("FileClose Err:" + err.Error()) // return // } // }() // // indexObj := new(index.BaseFromMysteelChemicalIndex) // var wg = sync.WaitGroup{} // wg.Add(1) // go func() { // sheetList := f.GetSheetList() // for _, sv := range sheetList { // rows, err := f.GetRows(sv) // if err != nil { // fmt.Println("f.GetRows:err:" + err.Error()) // return // } // var nameArr []string // unitArr := make([]string, 0) // sourceArr := make([]string, 0) // codeArr := make([]string, 0) // frequencyArr := make([]string, 0) // dateArr := make([]string, 0) // describeArr := make([]string, 0) // endDateArr := make([]string, 0) // updateArr := make([]string, 0) // indexDateArr := make([]string, 0) // // dataMap := make(map[string][]string) // // var nameLen int // for rk, row := range rows { // if rk == 0 { // continue // } // if rk == 1 { // for ck, colCell := range row { // if ck >= 1 { // nameArr = append(nameArr, colCell) // } // } // nameLen = len(nameArr) // unitArr = make([]string, nameLen) // sourceArr = make([]string, nameLen) // codeArr = make([]string, nameLen) // frequencyArr = make([]string, nameLen) // dateArr = make([]string, nameLen) // describeArr = make([]string, nameLen) // endDateArr = make([]string, nameLen) // updateArr = make([]string, nameLen) // } else if rk == 2 { // for ck, colCell := range row { // if ck >= 1 { // unitArr[ck-1] = colCell // } // } // } else if rk == 3 { // for ck, colCell := range row { // if ck >= 1 { // //sourceArr = append(sourceArr, colCell) // sourceArr[ck-1] = colCell // } // } // } else if rk == 4 { // for ck, colCell := range row { // if ck >= 1 { // //codeArr = append(codeArr, colCell) // codeArr[ck-1] = colCell // } // } // } else if rk == 5 { // for ck, colCell := range row { // if ck >= 1 { // //frequencyArr = append(frequencyArr, colCell) // frequencyArr[ck-1] = colCell // } // } // } else if rk == 6 { // for ck, colCell := range row { // if ck >= 1 { // //dateArr = append(dateArr, colCell) // dateArr[ck-1] = colCell // } // } // } else if rk == 7 { // for ck, colCell := range row { // if ck >= 1 { // //describeArr = append(describeArr, colCell) // describeArr[ck-1] = colCell // } // } // } else if rk == 8 { // for ck, colCell := range row { // if ck >= 1 { // //endDateArr = append(endDateArr, colCell) // endDateArr[ck-1] = colCell // } // } // } else if rk == 9 { // for ck, colCell := range row { // if ck >= 1 { // //updateArr = append(updateArr, colCell) // updateArr[ck-1] = colCell // } // } // } else { // var date string // dataArr := make([]string, nameLen) // for ck, colCell := range row { // if ck == 0 { // date = colCell // indexDateArr = append(indexDateArr, date) // } else { // if colCell != "" { // dataArr[ck-1] = colCell // } // } // } // dataMap[date] = dataArr // } // } // // var indexId int64 // existDataMap := make(map[string]string) // for k, v := range nameArr { // indexName := v // indexCode := codeArr[k] // unit := unitArr[k] // source := sourceArr[k] // describe := describeArr[k] // dateStr := dateArr[k] // frequency := frequencyArr[k] // //判断指标是否存在 // var isAdd int // item, err := indexObj.GetIndexItem(runMode, indexCode) // if err != nil { // if err.Error() == "record not found" { // isAdd = 1 // } else { // isAdd = -1 // fmt.Println("GetIndexItem Err:" + err.Error()) // return // } // } // if item != nil && item.BaseFromMysteelChemicalIndexId > 0 { // fmt.Println("item:", item) // isAdd = 2 // } else { // isAdd = 1 // } // // var startDate, endDate string // startEndArr := strings.Split(dateStr, "～") // if len(startEndArr) >= 2 { // startDate = startEndArr[0] // endDate = startEndArr[1] // } // // if !strings.Contains(frequency, "度") { // frequency = frequency + "度" // } // // indexItem := new(index.BaseFromMysteelChemicalIndex) // if isAdd == 1 { // indexItem.IndexCode = indexCode // indexItem.IndexName = indexName // indexItem.Unit = unit // indexItem.Source = source // indexItem.Describe = describe // indexItem.StartDate, _ = time.ParseInLocation(utils.FormatDate, startDate, time.Local) // indexItem.EndDate, _ = time.ParseInLocation(utils.FormatDate, endDate, time.Local) // indexItem.Frequency = frequency // indexItem.FilePath = filePath // indexItem.MergeFilePath = filePath // err = indexItem.Add(runMode) // if err != nil { // fmt.Println("indexItem.add err:" + err.Error()) // return // } // indexId = indexObj.BaseFromMysteelChemicalIndexId // } else if isAdd == 2 { // indexItem.IndexCode = indexCode // indexItem.IndexName = indexName // indexItem.Unit = unit // indexItem.Source = source // indexItem.Describe = describe // indexItem.StartDate, _ = time.ParseInLocation(utils.FormatDate, startDate, time.Local) // indexItem.EndDate, _ = time.ParseInLocation(utils.FormatDate, endDate, time.Local) // indexItem.Frequency = frequency // indexItem.FilePath = filePath // indexItem.ModifyTime = time.Now() // indexId = item.BaseFromMysteelChemicalIndexId // //修改数据 // updateColsArr := make([]string, 0) // updateColsArr = append(updateColsArr, "index_name") // updateColsArr = append(updateColsArr, "unit") // updateColsArr = append(updateColsArr, "source") // updateColsArr = append(updateColsArr, "frequency") // updateColsArr = append(updateColsArr, "start_date") // updateColsArr = append(updateColsArr, "end_date") // updateColsArr = append(updateColsArr, "describe") // updateColsArr = append(updateColsArr, "end_date") // updateColsArr = append(updateColsArr, "modify_time") // updateColsArr = append(updateColsArr, "file_path") // // err = indexItem.Update(runMode, updateColsArr) // if err != nil { // fmt.Println("indexObj.Update err:" + err.Error()) // return // } // // dataObj := new(index.BaseFromMysteelChemicalData) // //获取已存在的所有数据 // dataList, err := dataObj.GetIndexDataList(runMode, indexCode) // if err != nil { // fmt.Println("GetIndexDataList Err:" + err.Error()) // return // } // fmt.Println("dataListLen:", len(dataList)) // for _, v := range dataList { // dateStr := v.DataTime.Format(utils.FormatDate) // existDataMap[dateStr] = v.Value // } // } // // dataList := make([]index.BaseFromMysteelChemicalData, 0) // for _, dv := range indexDateArr { // dataArr := dataMap[dv] // dataVal := dataArr[k] // updateDate := updateArr[k] // if dataVal != "" { // if _, ok := existDataMap[dv]; !ok { // dateTime, err := time.ParseInLocation(utils.FormatDate, dv, time.Local) // if err != nil { // fmt.Println("time.ParseInLocation Err:" + err.Error()) // return // } // dataItem := new(index.BaseFromMysteelChemicalData) // dataItem.BaseFromMysteelChemicalIndexId = indexId // dataItem.IndexCode = indexCode // dataItem.DataTime = dateTime // dataItem.Value = dataVal // dataItem.UpdateDate = updateDate // dataItem.CreateTime = time.Now() // dataItem.ModifyTime = time.Now() // dataList = append(dataList, *dataItem) // } // } // } // if len(dataList) > 0 { // dataObj := new(index.BaseFromMysteelChemicalData) // err = dataObj.Add(runMode, dataList) // if err != nil { // fmt.Println("dataObj.Add() Err:" + err.Error()) // return // } // } // } // } // wg.Done() // }() // wg.Wait() //}