备份

flow_repeat/main.go

@@ -0,0 +1 @@
+package flow_repeat

src/dataMethod.go → udp_repeat/src/dataMethod.go

@@ -14,7 +14,7 @@ var cleanNameReg_3 = regexp.MustCompile("(公开|的)(比选|招标|单一来源
 
 var un_cleanNameReg_1 = regexp.MustCompile("(项目[一二三四五六七八九1-9][次](招标|中标|中标结果|成交|候选人|竞谈|竞争性磋商)(公告)?)$")
 
-//完善判重数据检测-前置条件
+// 完善判重数据检测-前置条件
 func convertArabicNumeralsAndLetters(data string) string {
 	newData := data
 	res1, _ := regexp.Compile("[a-zA-Z]+")
@@ -33,7 +33,7 @@ func convertArabicNumeralsAndLetters(data string) string {
 	return newData
 }
 
-//特殊词处理
+// 特殊词处理
 func dealWithSpecialPhrases(str1 string, str2 string) (string, string) {
 	newStr1 := str1
 	newStr2 := str2
@@ -47,7 +47,7 @@ func dealWithSpecialPhrases(str1 string, str2 string) (string, string) {
 	return newStr1, newStr2
 }
 
-//关键词数量v
+// 关键词数量v
 func dealWithSpecialWordNumber(info *Info, v *Info) int {
 	okNum := 0
 	if info.titleSpecialWord || info.specialWord {
@@ -59,7 +59,7 @@ func dealWithSpecialWordNumber(info *Info, v *Info) int {
 	return okNum
 }
 
-//关键词再次判断
+// 关键词再次判断
 func againRepeat(v *Info, info *Info, site bool) bool {
 	if isPublishtimeInterval(info.publishtime, v.publishtime) && site {
 		return true
@@ -93,7 +93,7 @@ func againRepeat(v *Info, info *Info, site bool) bool {
 	return false
 }
 
-//均含有关键词再次判断
+// 均含有关键词再次判断
 func againContainSpecialWord(v *Info, info *Info) bool {
 	if isBidopentimeInterval(info.bidopentime, v.bidopentime) {
 		return true
@@ -121,7 +121,7 @@ func againContainSpecialWord(v *Info, info *Info) bool {
 	return false
 }
 
-//提取标题-标段号处理
+// 提取标题-标段号处理
 func dealTitleSpecial(title1 string, title2 string) bool {
 	regular1 := "(包|标段|标包)[(（]?[0-9a-zA-Z一二三四五六七八九十零１２３４５６７８９]+[)）]?"
 	regular2 := "[0-9a-zA-Z一二三四五六七八九十零１２３４５６７８９]+(包|标段|标包)"
@@ -155,7 +155,7 @@ func dealTitleSpecial(title1 string, title2 string) bool {
 	}
 }
 
-//删除中标单位字符串中多余的空格(含tab)
+// 删除中标单位字符串中多余的空格(含tab)
 func deleteExtraSpaceName(s string) string {
 	//删除字符串中的多余空格，有多个空格时，仅保留一个空格
 	s1 := strings.Replace(s, "  ", " ", -1)      //替换tab为空格
@@ -171,7 +171,7 @@ func deleteExtraSpaceName(s string) string {
 	return string(s2)
 }
 
-//中标金额倍率：10000
+// 中标金额倍率：10000
 func isBidWinningAmount(f1 float64, f2 float64) bool {
 	if f1 == f2 || f1*10000 == f2 || f2*10000 == f1 {
 		return false
@@ -179,7 +179,7 @@ func isBidWinningAmount(f1 float64, f2 float64) bool {
 	return true
 }
 
-//时间间隔周期
+// 时间间隔周期
 func isTimeIntervalPeriod(i1 int64, i2 int64) bool {
 	if math.Abs(float64(i1-i2)) < 172800.0 {
 		return true
@@ -188,7 +188,7 @@ func isTimeIntervalPeriod(i1 int64, i2 int64) bool {
 	}
 }
 
-//开标时间区间为一天
+// 开标时间区间为一天
 func isBidopentimeInterval(i1 int64, i2 int64) bool {
 	if i1 == 0 || i2 == 0 {
 		return false
@@ -209,7 +209,7 @@ func isBidopentimeInterval(i1 int64, i2 int64) bool {
 	}
 }
 
-//发布时间区间为一天
+// 发布时间区间为一天
 func isPublishtimeInterval(i1 int64, i2 int64) bool {
 	if i1 == 0 || i2 == 0 {
 		return false
@@ -230,7 +230,7 @@ func isPublishtimeInterval(i1 int64, i2 int64) bool {
 	}
 }
 
-//时间区间为一天
+// 时间区间为一天
 func isTheSameDay(i1 int64, i2 int64) bool {
 	if i1 == 0 || i2 == 0 {
 		return false
@@ -244,7 +244,7 @@ func isTheSameDay(i1 int64, i2 int64) bool {
 	return false
 }
 
-//前置0 五要素均相等认为重复
+// 前置0 五要素均相等认为重复
 func leadingElementSame(v *Info, info *Info) bool {
 	isok := 0
 	if info.projectname != "" && v.projectname == info.projectname {
@@ -288,7 +288,7 @@ func leadingElementSame(v *Info, info *Info) bool {
 	return false
 }
 
-//前置0 竞品要素简易计算
+// 前置0 竞品要素简易计算
 func jingPinElementSame(v *Info, info *Info) bool {
 	if info.projectname != "" && v.projectname != info.projectname {
 		return false
@@ -305,7 +305,7 @@ func jingPinElementSame(v *Info, info *Info) bool {
 	return true
 }
 
-//buyer的优先级
+// buyer的优先级
 func buyerIsContinue(v *Info, info *Info) bool {
 	if !isTheSameDay(info.publishtime, v.publishtime) {
 		return true
@@ -327,7 +327,7 @@ func buyerIsContinue(v *Info, info *Info) bool {
 	return false
 }
 
-//判断~是否需要替换数据相关
+// 判断~是否需要替换数据相关
 func judgeIsReplaceInfo(s_href string, i_href string) bool {
 	if strings.Contains(s_href, "https://www.jianyu360.cn") && i_href != "" &&
 		!strings.Contains(i_href, "https://www.jianyu360.cn") {
@@ -336,7 +336,7 @@ func judgeIsReplaceInfo(s_href string, i_href string) bool {
 	return false
 }
 
-//查询抽取表数据
+// 查询抽取表数据
 func confrimExtractData(source_id string, info_id string) (bool, map[string]interface{}, map[string]interface{}) {
 	source_data := map[string]interface{}{}
 	info_data := map[string]interface{}{}
@@ -353,7 +353,7 @@ func confrimExtractData(source_id string, info_id string) (bool, map[string]inte
 	return isvalid, info_data, source_data
 }
 
-//查询历史抽取表数据
+// 查询历史抽取表数据
 func confrimHistoryExtractData(source_id string, info_id string) (bool, bool, map[string]interface{}, map[string]interface{}) {
 	source_data := map[string]interface{}{}
 	info_data := map[string]interface{}{}
@@ -376,7 +376,7 @@ func confrimHistoryExtractData(source_id string, info_id string) (bool, bool, ma
 	return isvalid, isexists, info_data, source_data
 }
 
-//查询bidding表数据
+// 查询bidding表数据
 func confrimBiddingData(source_id string, info_id string) (bool, map[string]interface{}, map[string]interface{}) {
 	source_data := map[string]interface{}{}
 	info_data := map[string]interface{}{}
@@ -393,7 +393,7 @@ func confrimBiddingData(source_id string, info_id string) (bool, map[string]inte
 	return isvalid, info_data, source_data
 }
 
-//是否为竞品链接
+// 是否为竞品链接
 func IsJpHref(href string) bool {
 	if strings.Contains(href, "www.jianyu360") && href != "" {
 		return true
@@ -401,7 +401,7 @@ func IsJpHref(href string) bool {
 	return false
 }
 
-//验证竞品是否重复
+// 验证竞品是否重复
 func confirmJingPinIsRepeatData(v *Info, info *Info) bool {
 	//标题验证~是否有关联~是否需要清洗数据-长度需要考虑
 	if v.c_title != "" && info.c_title != "" { //标题相似判断
@@ -433,7 +433,7 @@ func confirmJingPinIsRepeatData(v *Info, info *Info) bool {
 	return false
 }
 
-//通用清洗~清洗名称~过滤冗余~
+// 通用清洗~清洗名称~过滤冗余~
 func cleanNameFilterRedundant(name string) string {
 	new_name := name
 	new_name = cleanNameReg_0.ReplaceAllString(new_name, "")

src/dataMethodHeavy.go → udp_repeat/src/dataMethodHeavy.go

@@ -4,7 +4,7 @@ import (
 	"strings"
 )
 
-//判重方法1
+// 判重方法1
 func quickHeavyMethodOne(v *Info, info *Info, reason string) (bool, string) {
 
 	isMeet := false
@@ -65,7 +65,7 @@ func quickHeavyMethodOne(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//判重方法2
+// 判重方法2
 func quickHeavyMethodTwo(v *Info, info *Info, reason string) (bool, string) {
 	isMeet := false
 	isAgency := false
@@ -149,7 +149,7 @@ func quickHeavyMethodTwo(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//招标_A
+// 招标_A
 func tenderRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 
 	var ss string
@@ -209,7 +209,7 @@ func tenderRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//招标_B
+// 招标_B
 func tenderRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 
 	m, n := 0, 0
@@ -249,7 +249,7 @@ func tenderRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//招标_C
+// 招标_C
 func tenderRepeat_C(v *Info, info *Info) bool {
 
 	if v.budget != 0 && info.budget != 0 && v.budget != info.budget {
@@ -261,7 +261,7 @@ func tenderRepeat_C(v *Info, info *Info) bool {
 	return false
 }
 
-//中标_A
+// 中标_A
 func winningRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 
 	var ss string
@@ -308,7 +308,7 @@ func winningRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//中标_B
+// 中标_B
 func winningRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 
 	m, n := 0, 0
@@ -345,7 +345,7 @@ func winningRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//中标_C
+// 中标_C
 func winningRepeat_C(v *Info, info *Info) bool {
 
 	if v.bidamount != 0 && info.bidamount != 0 && isBidWinningAmount(v.bidamount, info.bidamount) {
@@ -363,7 +363,7 @@ func winningRepeat_C(v *Info, info *Info) bool {
 	return false
 }
 
-//合同_A
+// 合同_A
 func contractRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 
 	isMeet_1 := false
@@ -378,7 +378,7 @@ func contractRepeat_A(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//合同_B
+// 合同_B
 func contractRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 
 	isMeet_1 := false
@@ -392,7 +392,7 @@ func contractRepeat_B(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//合同_C
+// 合同_C
 func contractRepeat_C(v *Info, info *Info) bool {
 
 	if tenderRepeat_C(v, info) {
@@ -413,7 +413,7 @@ func contractRepeat_C(v *Info, info *Info) bool {
 	return false
 }
 
-//是否相似
+// 是否相似
 func isTheSimilarName(name1 string, name2 string) bool {
 	if strings.Contains(name1, name2) || strings.Contains(name2, name1) {
 		return true
@@ -421,7 +421,7 @@ func isTheSimilarName(name1 string, name2 string) bool {
 	return false
 }
 
-//快速低质量数据判重
+// 快速低质量数据判重
 func fastLowQualityHeavy(v *Info, info *Info, reason string) (bool, string) {
 	//区间间隔24小时
 	if !isTimeIntervalPeriod(v.publishtime, info.publishtime) {
@@ -470,7 +470,7 @@ func fastLowQualityHeavy(v *Info, info *Info, reason string) (bool, string) {
 	return false, reason
 }
 
-//类别细节原因记录
+// 类别细节原因记录
 func judgeLowQualityData(v *Info, info *Info, reason string) (bool, string) {
 	if info.projectname != "" && isTheSimilarName(info.projectname, v.projectname) {
 		reason = reason + "---项目名称"

src/datamap.go → udp_repeat/src/datamap.go

@@ -43,7 +43,7 @@ type Info struct {
 var datelimit = float64(432000) //五天
 var sitelock sync.Mutex         //锁
 
-//一般数据判重
+// 一般数据判重
 type datamap struct {
 	lock     sync.Mutex //锁
 	days     int        //保留几天数据
@@ -53,7 +53,7 @@ type datamap struct {
 	keys     map[string]bool
 }
 
-//历史~存量
+// 历史~存量
 func TimedTaskDatamap(days int, lasttime int64, numIndex int) *datamap {
 	datelimit = qutil.Float64All(days * 86400)
 	dm := &datamap{sync.Mutex{}, days, map[string][]*Info{}, []string{}, []string{}, map[string]bool{}}
@@ -125,7 +125,7 @@ func TimedTaskDatamap(days int, lasttime int64, numIndex int) *datamap {
 	return dm
 }
 
-//增量
+// 增量
 func NewDatamap(days int, lastid string) *datamap {
 	datelimit = qutil.Float64All(days * 86400 * 2)
 	dm := &datamap{sync.Mutex{}, days, map[string][]*Info{}, []string{}, []string{}, map[string]bool{}}
@@ -193,7 +193,7 @@ func NewDatamap(days int, lastid string) *datamap {
 	return dm
 }
 
-//数据构建
+// 数据构建
 func NewInfo(tmp map[string]interface{}) *Info {
 	subtype := qutil.ObjToString(tmp["subtype"])
 	if subtype == "招标" || subtype == "邀标" || subtype == "询价" ||
@@ -237,9 +237,9 @@ func NewInfo(tmp map[string]interface{}) *Info {
 	return info
 }
 
-//判重方法
-//判重方法
-//判重方法
+// 判重方法
+// 判重方法
+// 判重方法
 func (d *datamap) check(info *Info) (b bool, source *Info, reasons string) {
 	reason := ""
 	keys := []string{}
@@ -508,7 +508,7 @@ func (d *datamap) GetLatelyFiveDayDouble(t int64) []string { //增量-两倍
 	return array
 }
 
-//替换原始数据池-更新
+// 替换原始数据池-更新
 func (d *datamap) replacePoolData(newData *Info) {
 	d.lock.Lock()
 	ct := newData.publishtime
@@ -525,7 +525,7 @@ func (d *datamap) replacePoolData(newData *Info) {
 	d.lock.Unlock()
 }
 
-//相互替换数据池-暂时弃用
+// 相互替换数据池-暂时弃用
 func (d *datamap) replaceSourceData(newData *Info, oldData *Info) {
 	//删除数据池的老数据
 	ct_old := oldData.publishtime
@@ -573,7 +573,7 @@ func (d *datamap) replaceSourceData(newData *Info, oldData *Info) {
 	d.lock.Unlock()
 }
 
-//总计条数-暂时弃用
+// 总计条数-暂时弃用
 func (d *datamap) currentTotalCount() int {
 	num := qutil.IntAll(0)
 	for _, v := range d.data {

src/fullDataRepeat.go → udp_repeat/src/fullDataRepeat.go

@@ -12,7 +12,7 @@ var timeLayout = "2006-01-02"
 
 //var timeLayout = "2006-01-02 15:04:05"
 
-//划分时间段落
+// 划分时间段落
 func initModelArr() []map[string]interface{} {
 	modelArr := make([]map[string]interface{}, 0)
 	start := time.Date(2021, 12, 15, 0, 0, 0, 0, time.Local).Unix()
@@ -39,7 +39,7 @@ func initModelArr() []map[string]interface{} {
 	return modelArr
 }
 
-//全量数据处理
+// 全量数据处理
 func fullDataRepeat() {
 	modelArr := initModelArr()
 	for _, query := range modelArr {
@@ -49,7 +49,7 @@ func fullDataRepeat() {
 	}
 }
 
-//多线程~处理数据
+// 多线程~处理数据
 func dealWithfullData(query map[string]interface{}, time_str string) {
 
 	log.Println("开始处理~", time_str, "~", query)

src/historyRepeat.go → udp_repeat/src/historyRepeat.go

@@ -15,7 +15,7 @@ import (
 	"time"
 )
 
-//历史判重
+// 历史判重
 func historyRepeat() {
 	defer util.Catch()
 	for {
@@ -302,7 +302,7 @@ func historyRepeat() {
 	}
 }
 
-//判断是否在当前id段落
+// 判断是否在当前id段落
 func judgeIsCurIds(gtid string, lteid string, curid string) bool {
 
 	gt_time, _ := strconv.ParseInt(gtid[:8], 16, 64)
@@ -314,7 +314,7 @@ func judgeIsCurIds(gtid string, lteid string, curid string) bool {
 	return false
 }
 
-//迁移上一段数据
+// 迁移上一段数据
 func moveHistoryData(startid string, endid string) {
 	sess := data_mgo.GetMgoConn()
 	defer data_mgo.DestoryMongoConn(sess)
@@ -347,7 +347,7 @@ func moveHistoryData(startid string, endid string) {
 
 }
 
-//暂时弃用
+// 暂时弃用
 func moveTimeoutData() {
 	log.Println("部署迁移定时任务")
 	c := cron.New()

src/increaseRepeat.go → udp_repeat/src/increaseRepeat.go

@@ -11,7 +11,7 @@ import (
 	"time"
 )
 
-//开始增量判重程序
+// 开始增量判重程序
 func increaseRepeat(mapInfo map[string]interface{}) {
 	defer qu.Catch()
 	//区间id
@@ -191,7 +191,7 @@ func increaseRepeat(mapInfo map[string]interface{}) {
 	}
 }
 
-//更新流程记录id段落
+// 更新流程记录id段落
 func updateProcessUdpIdsInfo(sid string, eid string) {
 	//判重有合并操作~所以要联合查询
 	query := map[string]interface{}{
@@ -224,7 +224,7 @@ func updateProcessUdpIdsInfo(sid string, eid string) {
 	}
 }
 
-//更新ocr表~弃用
+// 更新ocr表~弃用
 func updateOcrFileData(cur_lteid string) {
 	//更新ocr 分类表-判重的状态
 	log.Println("开始更新Ocr表-标记", cur_lteid)

src/main.go → udp_repeat/src/main.go

@@ -50,7 +50,7 @@ var (
 // 初始化加载
 func init() {
 	flag.StringVar(&lastid, "id", "", "增量加载的lastid") //增量
-	flag.StringVar(&gtid, "gtid", "", "历史增量的起始id") //历史
+	flag.StringVar(&gtid, "gtid", "", "历史增量的起始id")   //历史
 	flag.StringVar(&sec_gtid, "sec_gtid", "", "全量分段起始id")
 	flag.StringVar(&sec_lteid, "sec_lteid", "", "全量分段结束id")
 	flag.Parse()
@@ -82,7 +82,7 @@ func lastUdpJob() {
 
 // 主函数
 func main() {
-	
+
 	go checkMailJob()
 	lastNodeResponse = time.Now().Unix()
 	updport := Sysconfig["udpport"].(string)

src/mgo.go → udp_repeat/src/mgo.go

@@ -182,7 +182,7 @@ func (m *MongodbSim) Close() {
 	<-m.pool
 }
 
-//批量插入
+// 批量插入
 func (m *MongodbSim) UpSertBulk(c string, doc ...[]map[string]interface{}) (map[int64]interface{}, bool) {
 	m.Open()
 	defer m.Close()
@@ -209,7 +209,7 @@ func (m *MongodbSim) UpSertBulk(c string, doc ...[]map[string]interface{}) (map[
 	return r.UpsertedIDs, true
 }
 
-//批量插入
+// 批量插入
 func (m *MongodbSim) SaveBulk(c string, doc ...map[string]interface{}) bool {
 	m.Open()
 	defer m.Close()
@@ -228,7 +228,7 @@ func (m *MongodbSim) SaveBulk(c string, doc ...map[string]interface{}) bool {
 	return true
 }
 
-//保存
+// 保存
 func (m *MongodbSim) Save(c string, doc map[string]interface{}) interface{} {
 	m.Open()
 	defer m.Close()
@@ -240,7 +240,7 @@ func (m *MongodbSim) Save(c string, doc map[string]interface{}) interface{} {
 	return r.InsertedID
 }
 
-//按条件更新
+// 按条件更新
 func (m *MongodbSim) Update(c string, q, u interface{}, upsert bool, multi bool) bool {
 	defer catch()
 	m.Open()
@@ -263,7 +263,7 @@ func (m *MongodbSim) Update(c string, q, u interface{}, upsert bool, multi bool)
 	return true
 }
 
-//更新by Id
+// 更新by Id
 func (m *MongodbSim) UpdateById(c, id string, doc map[string]interface{}) bool {
 	m.Open()
 	defer m.Close()
@@ -276,7 +276,7 @@ func (m *MongodbSim) UpdateById(c, id string, doc map[string]interface{}) bool {
 	return true
 }
 
-//删除by id
+// 删除by id
 func (m *MongodbSim) DeleteById(c, id string) int64 {
 	m.Open()
 	defer m.Close()
@@ -288,7 +288,7 @@ func (m *MongodbSim) DeleteById(c, id string) int64 {
 	return r.DeletedCount
 }
 
-//通过条件删除
+// 通过条件删除
 func (m *MongodbSim) Delete(c string, query map[string]interface{}) int64 {
 	m.Open()
 	defer m.Close()
@@ -300,7 +300,7 @@ func (m *MongodbSim) Delete(c string, query map[string]interface{}) int64 {
 	return r.DeletedCount
 }
 
-//findbyid
+// findbyid
 func (m *MongodbSim) FindById(c, id string) map[string]interface{} {
 	m.Open()
 	defer m.Close()
@@ -311,7 +311,7 @@ func (m *MongodbSim) FindById(c, id string) map[string]interface{} {
 	return v
 }
 
-//findone
+// findone
 func (m *MongodbSim) FindOne(c string, query map[string]interface{}) map[string]interface{} {
 	m.Open()
 	defer m.Close()
@@ -322,7 +322,7 @@ func (m *MongodbSim) FindOne(c string, query map[string]interface{}) map[string]
 	return v
 }
 
-//find
+// find
 func (m *MongodbSim) Find(c string, query map[string]interface{}, sort, fields interface{}) ([]map[string]interface{}, error) {
 	m.Open()
 	defer m.Close()
@@ -348,7 +348,7 @@ func ObjToM(query interface{}) *bson.M {
 	return ObjToMQ(query, true)
 }
 
-//obj(string,M)转M,查询用到
+// obj(string,M)转M,查询用到
 func ObjToMQ(query interface{}, isQuery bool) *bson.M {
 	data := make(bson.M)
 	defer catch()
@@ -413,7 +413,7 @@ func intAllDef(num interface{}, defaultNum int) int {
 	}
 }
 
-//创建_id
+// 创建_id
 func NewObjectId() primitive.ObjectID {
 	return primitive.NewObjectID()
 }
@@ -427,7 +427,7 @@ func BsonTOStringId(id interface{}) string {
 	return id.(primitive.ObjectID).Hex()
 }
 
-//出错拦截
+// 出错拦截
 func catch() {
 	if r := recover(); r != nil {
 		log.Println(r)

src/updateMethod.go → udp_repeat/src/updateMethod.go

@@ -17,7 +17,7 @@ func newUpdatePool() *updateInfo {
 	return update
 }
 
-//临时~新增组
+// 临时~新增组
 type addGroupInfo struct {
 	pool     chan map[string]interface{}
 	saveSize int
@@ -28,7 +28,7 @@ func newAddGroupPool() *addGroupInfo {
 	return info
 }
 
-//监听更新
+// 监听更新
 func (update *updateInfo) updateData() {
 	log.Println("开始不断监听--待更新数据")
 	tmpArr := make([][]map[string]interface{}, update.saveSize)
@@ -65,7 +65,7 @@ func (update *updateInfo) updateData() {
 	}
 }
 
-//监听新增
+// 监听新增
 func (info *addGroupInfo) addGroupData() {
 	tmpArr := make([]map[string]interface{}, info.saveSize)
 	tmpIndex := 0