jyps/xlsx/xlsx_test.go

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"github.com/olivere/elastic/v7"
	"github.com/xuri/excelize/v2"
	util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"log"
	"os"
	"strconv"
	"strings"
	"testing"
	"time"
)

func TestA(T *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27017",
		Size:        10,
		DbName:      "wcc",
		//UserName:    "SJZY_RWbid_ES",
		//Password:    "SJZY@B4i4D5e6S",
		//Direct:      true,
	}
	Mgo.InitPool()

	f, err := excelize.OpenFile("./拼数据.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("Sheet1")
	if err != nil {
		fmt.Println(err)
		return
	}
	cells, _ := f.GetCols("Sheet2")

	for i := 1; i < len(rows); i++ {
		log.Print(rows[i][3])
		if rows[i][2] == "省级" {
			for k, v := range cells[0] {
				if k == 0 || v == "" {
					continue
				}

				insert := make(map[string]interface{})
				insert["top"] = rows[i][0]
				insert["area"] = rows[i][3]
				insert["level"] = rows[i][2]
				insert["sub"] = v
				insert["name"] = rows[i][3] + v
				Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
			}
		}

		if rows[i][2] == "市级" {
			for k, v := range cells[1] {
				if k == 0 || v == "" {
					continue
				}
				insert := make(map[string]interface{})
				insert["top"] = rows[i][0]
				insert["area"] = rows[i][3]
				insert["city"] = rows[i][4]
				insert["level"] = rows[i][2]
				insert["sub"] = v
				insert["name"] = rows[i][4] + v
				Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
			}
		}

		if rows[i][2] == "县级" {
			for k, v := range cells[2] {
				if k == 0 || v == "" {
					continue
				}
				insert := make(map[string]interface{})
				insert["top"] = rows[i][0]
				insert["area"] = rows[i][3]
				insert["city"] = rows[i][4]
				insert["district"] = rows[i][5]
				insert["level"] = rows[i][2]
				insert["sub"] = v
				insert["name"] = rows[i][4] + rows[i][5] + v
				Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
			}
		}
	}

	fmt.Println("over")
}

func TestA2(T *testing.T) {
	Mgo := &mongodb.MongodbSim{
		MongodbAddr: "127.0.0.1:27017",
		Size:        10,
		DbName:      "wcc",
	}
	Mgo.InitPool()

	f, err := excelize.OpenFile("./主体代码表.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("国民经济行业分类")
	if err != nil {
		fmt.Println(err)
		return
	}

	for i := 2; i < len(rows); i++ {
		log.Print("iii", i)
		var top1, top2, top3, top4, name string

		if len(rows[i]) <= 0 {
			continue
		}

		if len(rows[i]) > 0 {
			top1 = rows[i][0]
		}

		/**
		top2 := rows[i][1]
		top3 := rows[i][2]
		top4 := rows[i][3]
		name := rows[i][4]
		*/

		insert := map[string]interface{}{
			"top1": top1,
		}
		if len(rows[i]) > 1 {
			top2 = rows[i][1]
			insert["top2"] = top2
		}

		if len(rows[i]) > 2 {
			top3 = rows[i][2]
			insert["top2"] = top3
		}

		if len(rows[i]) > 3 {
			top4 = rows[i][3]
			insert["top2"] = top4
		}

		if len(rows[i]) > 4 {
			name = rows[i][4]
			insert["name"] = name
		}

		if len(rows[i]) > 5 {
			insert["desc"] = rows[i][5]
		}

		if top4 != "" {
			insert["level"] = 4
			insert["code"] = top1 + top4
		} else if top3 != "" {
			insert["level"] = 3
			insert["code"] = top1 + top3
		} else if top2 != "" {
			insert["level"] = 2
			insert["code"] = top1 + top2
		} else {
			insert["level"] = 1
			insert["code"] = top1
		}

		//insert := map[string]interface{}{
		//	"company_name": rows[i][2],
		//	"organizer":    rows[i][1],
		//}

		err = Mgo.InsertOrUpdate("wcc", "wcc_national_industries_classification", insert)
		if err != nil {
			log.Println("err", err)
		}
	}

	fmt.Println("over")
}

func TestB(T *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27083",
		Size:        10,
		DbName:      "qfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	f, err := excelize.OpenFile("./剑鱼标讯_数据导出.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("Sheet1")
	if err != nil {
		fmt.Println(err)
		return
	}
	for i := 1; i < len(rows); i++ {
		url := rows[i][2]
		log.Println(rows[i][1])
		id := GetIdByURL(url)
		re, _ := Mgo.FindById("bidding", id, nil)
		(*re)["wcc_id"] = i
		(*re)["toptype_old"] = (*re)["toptype"]
		(*re)["subtype_old"] = (*re)["subtype"]
		delete(*re, "toptype")
		delete(*re, "subtype")
		Mgo.SaveByOriID("wcc_bidding_0518", re)
	}

	log.Println("over")

}

// TestAAA 处理专项债券数据，导出专项债详情
func TestAAA(t *testing.T) {
	//87 竞品
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27081",
		Size:        10,
		DbName:      "py_theme",
		UserName:    "",
		Password:    "",
		Direct:      true,
	}
	Mgo.InitPool()
	sess := Mgo.GetMgoConn()
	defer Mgo.DestoryMongoConn(sess)

	//f, err := excelize.OpenFile("./山东2024专项债.xlsx")
	f, err := excelize.OpenFile("./天津专项债.xlsx")
	//detailName := "specialbond_detail_202412" //专项债详细表
	detailName := "specialbond_detail" //专项债详细表
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("项目列表")
	if err != nil {
		fmt.Println(err)
		return
	}

	keys := []string{"projectName", "totalInvestment", "regionName", "cityName", "countyName", "capital", "applyDebt", "portfolioFinancing", "specialDebtAsCapital",
		"expectedReturn", "projectCost", "projectTypeName3", "projectSubject", "startDate", "endDate", "operationStartDate",
		"operationEndDate", "sourceIncome", "constructionContent", "remarks", "portfolioFinancingSource", "costIncomePercent", "coverageMultiple", "implementingAgency",
		"accountingFirm", "lawFirm", "createTime", "updateTime"}
	titles := []string{"项目名称", "总投资（万元）", "省份", "地市", "区县", "不含专项债资本金（万元）", "申请专项债总额（万元）", "其他债务融资（万元）", "专项债作资本金（万元）", "预期收入（万元）", "成本",
		"项目领域", "项目业主", "建设期开始", "建设期结束", "运营期开始", "运营期结束", "收入来源", "建设内容", "特殊情况备注", "其他债务融资来源", "成本/收入（%）", "覆盖倍数", "主管部门", "会计所", "律所", "入库时间", "更新时间"}

	keys2 := []string{"bondName", "bondShortName", "bondNo", "regionName", "bondType1Name", "bondType2Name", "projectType1Name", "totalAmount", "issueDate", "issuePlaceName", "issueTerm", "issueInterestRate", "issuePhase", "payInterestMethodName",
		"newBondAmount", "counterBondAmount", "refinancingBondAmount", "redemptionMethod", "valueDate", "expiryDate", "payInterestDate", "latelyPayInterestDate", "lastPayInterest", "cumulativePayInterest"}

	titles2 := []string{"项目名称", "债券名称", "债券简称", "债券编码", "省份", "债券性质", "债券类型", "官方项目类型", "发行金额（万元）", "发行日期", "发行场所", "发行期限(年)", "发行利率(%)", "发行期数", "付息方式", "新增债券（亿元）", "置换债券（亿元）", "再融资债券（亿元）", "赎回方式",
		"起息日", "到息日", "付息日", "最近付息日", "上期已付息（亿元）", "累计付息（亿元）"}
	line := 0
	line++
	f.NewSheet("项目详情")
	f.NewSheet("债券详情")
	bondLine := 0
	//设置第一行title
	_ = f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &titles)
	_ = f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &titles2)
	//
	for i := 1; i < len(rows); i++ {
		projectName := rows[i][0]
		//projectName := "新建南通至宁波高速铁路（海盐段）"
		if i%10 == 0 {
			log.Println("iiii", i, projectName)
		}
		line++
		where := map[string]interface{}{
			"project.jcxx.projectName": projectName,
		}
		detail, _ := Mgo.FindOne(detailName, where)
		if len(*detail) == 0 {
			continue
		}
		insert := make([]interface{}, 0)
		if project, ok := (*detail)["project"].(map[string]interface{}); ok {
			if jcxx, ok := project["jcxx"].(map[string]interface{}); ok {
				for _, v := range keys {
					insert = append(insert, jcxx[v])
				}
			}
		}

		err := f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &insert)
		if err != nil {
			log.Println(err)
			return
		}

		// 债券基本信息
		if bonds, ok := (*detail)["bond"].([]interface{}); ok {
			for _, bond := range bonds {
				if bondData, ok := bond.(map[string]interface{}); ok {
					if jcxx, ok := bondData["jbxx"].(map[string]interface{}); ok {
						//if strings.Contains(util.ObjToString(jcxx["bondName"]), "2024") {
						bondInsert := make([]interface{}, 0)
						bondInsert = append(bondInsert, projectName)
						for _, v := range keys2 {
							bondInsert = append(bondInsert, jcxx[v])
						}
						bondLine++
						f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &bondInsert)
						//}
					}
				}
			}
		}
	}

}

// TestZZ 获取项目列表相关数据
func TestZZ(t *testing.T) {
	//87 竞品
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27081",
		Size:        10,
		DbName:      "py_theme",
		UserName:    "",
		Password:    "",
		Direct:      true,
	}
	Mgo.InitPool()
	sess := Mgo.GetMgoConn()
	defer Mgo.DestoryMongoConn(sess)

	//f, err := excelize.OpenFile("./山东2024专项债.xlsx")
	f, err := excelize.OpenFile("./天津市专项债数据.xlsx")
	//detailName := "specialbond_detail_202412" //专项债详细表
	listName := "specialbond_list,specialbond_list_history,specialbond_list_202503" //专项债详细表
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("项目列表")
	if err != nil {
		fmt.Println(err)
		return
	}

	keys := []string{"projectName", "presentIssueAmount", "issueTerm", "regionName", "cityName", "countyName", "totalInvestment", "issueDate"}

	titles := []string{"项目名称", "累计发行额（亿元）", "发行期限（年）", "省份", "城市", "区县", "总投资（亿元）", "发行时间"}
	line := 0
	line++
	_ = f.SetSheetRow("项目列表", fmt.Sprintf("%s%d", "A", line), &titles)
	for i := 1; i < len(rows); i++ {
		projectName := rows[i][0]
		if i%10 == 0 {
			log.Println("iiii", i, projectName)
		}
		line++
		where := map[string]interface{}{
			"projectName": projectName,
		}

		tables := strings.Split(listName, ",")
		insert := make([]interface{}, 0)
		for _, table := range tables {
			list, _ := Mgo.FindOne(table, where)
			if len(*list) == 0 {
				continue
			}

			for _, v := range keys {
				insert = append(insert, (*list)[v])
			}
			break
		}

		if len(insert) > 0 {
			err = f.SetSheetRow("项目列表", fmt.Sprintf("%s%d", "A", line), &insert)
			if err != nil {
				log.Println(err)
				return
			}
		}
	}

	log.Println("数据处理完毕")
}

func TestGetIdByURL(t *testing.T) {
	url := "https://www.jianyu360.cn/article/content/AHnY1xBfikoAjYsNGd4cE8JIzAvFj1jcXNlKDhROC4eWlFwA15UCZQ%3D.html"
	fmt.Println(GetIdByURL(url))
}

// TestArea 中国行政区划数据-民政部
func TestArea(t *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27083",
		Size:        10,
		DbName:      "qfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	f, err := excelize.OpenFile("./20240530_民政部统计数据.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("2023")
	if err != nil {
		fmt.Println(err)
		return
	}

	for i := 1; i < len(rows); i++ {
		data := map[string]interface{}{}
		if rows[i][0] == "省份" {
			data["level"] = 1
		} else if rows[i][0] == "城市" {
			data["level"] = 2
		} else {
			data["level"] = 3
		}
		log.Println(rows[i][1])
		parts := strings.Split(rows[i][1], "（")
		data["province"] = parts[0]
		data["province_code"] = rows[i][2]
		if len(rows[i]) > 3 {
			data["city"] = rows[i][3]
		}
		if len(rows[i]) > 4 {
			data["city_code"] = rows[i][4]
		}
		if len(rows[i]) > 5 {
			data["area"] = rows[i][5]
		}
		if len(rows[i]) > 6 {
			data["area_code"] = rows[i][6]
		}

		Mgo.Save("wcc_area_minzhengbu", data)
	}
}

// TestArea2 中国行政区划数据-统计局
func TestArea2(t *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27083",
		Size:        10,
		DbName:      "qfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	f, err := excelize.OpenFile("./20240530_统计局统计数据.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	rows, err := f.GetRows("2023")
	if err != nil {
		fmt.Println(err)
		return
	}

	for i := 1; i < len(rows); i++ {
		data := map[string]interface{}{}
		data["level"] = rows[i][0]
		log.Println(rows[i][1], rows[3])
		data["province"] = rows[i][1]
		data["province_code"] = rows[i][2]
		if len(rows[i]) > 3 {
			data["city"] = rows[i][3]
		}
		if len(rows[i]) > 4 {
			data["city_code"] = rows[i][4]
		}
		if len(rows[i]) > 5 {
			data["area"] = rows[i][5]
		}
		if len(rows[i]) > 6 {
			data["area_code"] = rows[i][6]
		}

		Mgo.Save("wcc_area_tongjiju", data)
	}
}

func TestHN(t *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27083",
		Size:        10,
		DbName:      "qfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	//181
	Mgo2 := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.4.181:27001",
		MongodbAddr: "127.0.0.1:27001",
		DbName:      "mixdata",
		Size:        10,
		UserName:    "",
		Password:    "",
		Direct:      true,
	}
	Mgo2.InitPool()

	f, err := excelize.OpenFile("./河南单位.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	sheet := "单位"
	rows, err := f.GetRows(sheet)
	if err != nil {
		fmt.Println(err)
		return
	}

	for i := 1; i < len(rows); i++ {
		name := rows[i][0]
		log.Println(i, "----", name)
		//res, _ := Mgo2.FindOne("special_enterprise", map[string]interface{}{"company_name": name})
		//if res != nil && len(*res) > 0 {
		//	f.SetCellValue(sheet, fmt.Sprintf("%s%d", "E", i+1), "special_enterprise")
		//	f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), (*res)["company_status"])
		//	f.SetCellValue(sheet, fmt.Sprintf("%s%d", "G", i+1), (*res)["company_type"])
		//} else {
		//	ra, _ := Mgo2.FindOne("special_gov_unit", map[string]interface{}{"company_name": name})
		//	if ra != nil && len(*ra) > 0 {
		//		f.SetCellValue(sheet, fmt.Sprintf("%s%d", "E", i+1), "special_gov_unit")
		//		f.SetCellValue(sheet, fmt.Sprintf("%s%d", "G", i+1), (*ra)["company_type"])
		//		if util.ObjToString((*ra)["company_status"]) != "" {
		//			f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), (*ra)["company_status"])
		//		} else {
		//			if util.IntAll((*ra)["use_flag"]) < 5 {
		//				f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), "正常")
		//			} else {
		//				f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), "废弃")
		//			}
		//		}
		//	}
		//}

		//
		data := map[string]interface{}{
			"detail": name,
		}

		res := getAreaInfo(data)
		if res != nil {
			city := res["city"]
			district := res["district"]
			f.SetCellValue("单位", fmt.Sprintf("%s%d", "B", i+1), city)
			f.SetCellValue("单位", fmt.Sprintf("%s%d", "C", i+1), district)
		}
	}

	f.Save()
	log.Println("结束")
}

// TestExportBidding 导出bidding数据
func TestExportBidding(t *testing.T) {
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.189.140:27080",
		MongodbAddr: "127.0.0.1:27083",
		Size:        10,
		DbName:      "qfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	sess := Mgo.GetMgoConn()
	defer Mgo.DestoryMongoConn(sess)

	//start, _ := time.Parse("2006-01-02 15:04:05", "2023-09-06 21:00:00")
	//end, _ := time.Parse("2006-01-02 15:04:05", "2023-09-07 09:00:00")
	//////
	//q := map[string]interface{}{
	//	"publish": map[string]interface{}{
	//		"$gte": 1701360000,
	//		"$lte": 1706716800,
	//	},
	//	//"modifyinfo.toptype": map[string]interface{}{
	//	//	"$exists": 1,
	//	//},
	//	"toptype": "拟建",
	//	//"title": map[string]interface{}{
	//	//	"$regex": "充电",
	//	//},
	//}

	q := map[string]interface{}{
		"s_classid": "57a189cbd368081d70e185cf",
		"s_name": map[string]interface{}{
			"$in": []string{"废标", "流标", "结果变更", "中标", "成交", "中选", "其它"},
		},
	}

	query := sess.DB("qfw").C("rc_rule").Find(q).Select(nil).Iter()

	count := 0
	file := time.Now().Format("20060102") + "导出数据.xlsx"
	currentPwd, _ := os.Getwd()
	exportFile := fmt.Sprintf("%s/%s", currentPwd, file)
	xlsx := excelize.NewFile(excelize.Options{ShortDatePattern: "yyyy/m/dd"})
	styleOne, _ := xlsx.NewStyle(
		&excelize.Style{
			Alignment: &excelize.Alignment{
				Horizontal: "left",
				Vertical:   "left",
			},
		},
	)
	line := 0
	sheet := "Sheet1"

	subtitles := []string{"s_name", "s_rule"}
	//subtitles := []string{"bidding_id", "title", "detail", "href", "jyhref", "toptype", "new_toptype", "new_subtype"}
	line++
	//设置第一行title
	_ = xlsx.SetSheetRow(sheet, fmt.Sprintf("%s%d", "A", line), &subtitles)
	for tmp := make(map[string]interface{}); query.Next(tmp); count++ {
		if count%1000 == 0 {
			log.Println("current --- ", count)
		}

		//company_phone := util.ObjToString(tmp["company_phone"])
		//if len(company_phone) != 11 {
		//	continue
		//}
		//if !validateMobileNumber(company_phone) {
		//	continue
		//}
		//if util.ObjToString(tmp["employee_name"]) == "" {
		//	continue
		//}

		//id := mongodb.BsonIdToSId(tmp["_id"])
		line++
		val := []interface{}{}
		for _, v := range subtitles {
			if v == "employee_name" {
				val = append(val, strings.Split(util.ObjToString(tmp["employee_name"]), ",")[0])
			} else {
				val = append(val, tmp[v])
			}

		}
		err := xlsx.SetSheetRow(sheet, fmt.Sprintf("%s%d", "A", line), &val)
		if err != nil {
			log.Println(err)
			return
		}
		_ = xlsx.SetCellStyle(sheet, fmt.Sprintf("%s%d", "A", line), "BA"+strconv.Itoa(line), styleOne)

		tmp = make(map[string]interface{})

	}
	xlsx.Path = exportFile
	xlsx.Save()

	log.Println("dealTmp over ", count)

}

// TestZXZ  专项债数据
//func TestZXZ(t *testing.T) {
//	//87 竞品
//	Mgo := &mongodb.MongodbSim{
//		//MongodbAddr: "172.17.189.140:27080",
//		MongodbAddr: "127.0.0.1:27081",
//		Size:        10,
//		DbName:      "py_theme",
//		UserName:    "",
//		Password:    "",
//		Direct:      true,
//	}
//	Mgo.InitPool()
//	sess := Mgo.GetMgoConn()
//	defer Mgo.DestoryMongoConn(sess)
//
//	//1.项目列表，查询条件
//	//where := map[string]interface{}{
//	//	"regionName": "安徽", //地区
//	//	"issueDate": map[string]interface{}{
//	//		"issueDate": map[string]interface{}{
//	//			"$gt": "2024",
//	//		},
//	//	},
//	//}
//
//	//tables := []string{"specialbond_list", "specialbond_list_202406", "specialbond_list_202407", "specialbond_list_202408"}
//
//	//for _, table := range tables {
//	//	datas, _ := Mgo.Find(table, where, nil, nil, false, -1, -1)
//	//
//	//}
//
//	f, err := excelize.OpenFile("./anhui-06.xlsx")
//	if err != nil {
//		fmt.Println(err)
//		return
//	}
//	defer func() {
//		f.Save()
//		if err := f.Close(); err != nil {
//			fmt.Println(err)
//		}
//	}()
//
//	//2.专项债详情
//	rows, err := f.GetRows("项目列表")
//	if err != nil {
//		fmt.Println(err)
//		return
//	}
//
//	keys := []string{"projectName", "totalInvestment", "regionName", "cityName", "countyName", "capital", "applyDebt", "portfolioFinancing", "specialDebtAsCapital",
//		"expectedReturn", "projectCost", "projectTypeName3", "projectSubject", "startDate", "endDate", "operationStartDate",
//		"operationEndDate", "sourceIncome", "constructionContent", "remarks", "portfolioFinancingSource", "costIncomePercent", "coverageMultiple", "implementingAgency",
//		"accountingFirm", "lawFirm", "createTime", "updateTime"}
//	titles := []string{"项目名称", "总投资（万元）", "省份", "地市", "区县", "不含专项债资本金（万元）", "申请专项债总额（万元）", "其他债务融资（万元）", "专项债作资本金（万元）", "预期收入（万元）", "成本",
//		"项目领域", "项目业主", "建设期开始", "建设期结束", "运营期开始", "运营期结束", "收入来源", "建设内容", "特殊情况备注", "其他债务融资来源", "成本/收入（%）", "覆盖倍数", "主管部门", "会计所", "律所", "入库时间", "更新时间"}
//
//	keys2 := []string{"bondName", "bondShortName", "bondNo", "regionName", "bondType1Name", "bondType2Name", "projectType1Name", "totalAmount", "issueDate", "issuePlaceName", "issueTerm", "issueInterestRate", "issuePhase", "payInterestMethodName",
//		"newBondAmount", "counterBondAmount", "refinancingBondAmount", "redemptionMethod", "valueDate", "expiryDate", "payInterestDate", "latelyPayInterestDate", "lastPayInterest", "cumulativePayInterest"}
//
//	titles2 := []string{"项目名称", "债券名称", "债券简称", "债券编码", "省份", "债券性质", "债券类型", "官方项目类型", "发行金额（万元）", "发行日期", "发行场所", "发行期限(年)", "发行利率(%)", "发行期数", "付息方式", "新增债券（亿元）", "置换债券（亿元）", "再融资债券（亿元）", "赎回方式",
//		"起息日", "到息日", "付息日", "最近付息日", "上期已付息（亿元）", "累计付息（亿元）"}
//	line := 0
//	line++
//	f.NewSheet("项目详情")
//	f.NewSheet("债券详情")
//	bondLine := 0
//	//设置第一行title
//	_ = f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &titles)
//	_ = f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &titles2)
//	//
//	for i := 1; i < len(rows); i++ {
//		projectName := rows[i][0]
//		//projectName := "新建南通至宁波高速铁路（海盐段）"
//		log.Println(projectName)
//		line++
//		where := map[string]interface{}{
//			"project.jcxx.projectName": projectName,
//		}
//		detail, _ := Mgo.FindOne("specialbond_detail_202406", where)
//		if len(*detail) == 0 {
//			continue
//		}
//		insert := make([]interface{}, 0)
//		if project, ok := (*detail)["project"].(map[string]interface{}); ok {
//			if jcxx, ok := project["jcxx"].(map[string]interface{}); ok {
//				for _, v := range keys {
//					insert = append(insert, jcxx[v])
//				}
//			}
//		}
//
//		err := f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &insert)
//		if err != nil {
//			log.Println(err)
//			return
//		}
//
//		// 债券基本信息
//		if bonds, ok := (*detail)["bond"].([]interface{}); ok {
//			for _, bond := range bonds {
//				if bondData, ok := bond.(map[string]interface{}); ok {
//					if jcxx, ok := bondData["jbxx"].(map[string]interface{}); ok {
//						//if strings.Contains(util.ObjToString(jcxx["bondName"]), "2024") {
//						bondInsert := make([]interface{}, 0)
//						bondInsert = append(bondInsert, projectName)
//						for _, v := range keys2 {
//							bondInsert = append(bondInsert, jcxx[v])
//						}
//						bondLine++
//						f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &bondInsert)
//					}
//				}
//			}
//		}
//	}
//}

// TestLianTong 7月非运营商中标数据比对缺失数据 -- 闫天磊
func TestLianTong(t *testing.T) {
	f, err := excelize.OpenFile("./7月非运营商中标数据比对缺失数据V1.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	//2.专项债详情
	rows, err := f.GetRows("基础数据")
	if err != nil {
		fmt.Println(err)
		return
	}

	// 86 mongo
	Mgo := &mongodb.MongodbSim{
		//MongodbAddr: "172.17.4.86:27080",
		MongodbAddr: "127.0.0.1:27082",
		Size:        10,
		DbName:      "jyqyfw",
		UserName:    "SJZY_RWbid_ES",
		Password:    "SJZY@B4i4D5e6S",
		Direct:      true,
	}
	Mgo.InitPool()

	//url := "http://172.17.4.184:19908"
	url := "http://127.0.0.1:19908"
	username := "jybid"
	password := "Top2023_JEB01i@31"
	index := "bidding" //索引名称
	// 创建 Elasticsearch 客户端
	client, err := elastic.NewClient(
		elastic.SetURL(url),
		elastic.SetBasicAuth(username, password),
		elastic.SetSniff(false),
	)
	if err != nil {
		log.Fatalf("创建 Elasticsearch 客户端失败：%s", err)
	}

	for i := 2; i < len(rows); i++ {
		area := rows[i][1]
		title := rows[i][2]
		buyer := rows[i][4]
		timeStr := rows[i][3]
		layout := "2006/01/02"
		t, err := time.Parse(layout, timeStr)
		if err != nil {
			fmt.Println(err)
			return
		}
		timestamp := t.Unix()

		if i%10 == 0 {
			log.Println("i", i, title)
			f.Save()
		}
		query := elastic.NewBoolQuery().
			Must(elastic.NewBoolQuery().Should(elastic.NewMatchQuery("title", title), elastic.NewMatchQuery("projectname", title))).
			//Must(elastic.NewTermQuery("title", title)).
			Must(elastic.NewTermQuery("area", area)).
			Must(elastic.NewTermQuery("buyer", buyer))

		// 执行查询
		searchResult, err := client.Search().
			Index(index).
			Query(query).
			Do(context.Background())
		if err != nil {
			log.Fatalf("Error executing search: %s", err)
		}

		if searchResult.TotalHits() > 0 {
			hit := searchResult.Hits.Hits[0]
			var doc map[string]interface{}
			err := json.Unmarshal(hit.Source, &doc)
			if err != nil {
				log.Printf("解析文档失败：%s", err)
				continue
			}
			publishTile := util.Int64All(doc["publishtime"])
			if publishTile < timestamp+3*24*3600 && publishTile > timestamp-3*24*3600 {
				id := util.ObjToString(doc["id"])
				jyurl := GetJyURLByID(id)
				f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "L", i+1), jyurl)
				f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "M", i+1), id)

				where2 := map[string]interface{}{
					"id":    id,
					"appid": "jyGQ1XQQsEAwNeSENOFR9D",
				}
				da, _ := Mgo.FindOne("usermail", where2)
				if len(*da) > 0 {
					f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "J", i+1), "是")
				} else {
					f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "J", i+1), "否")
				}
			} else {
				f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "I", i+1), "否")
			}
			//for _, hit := range searchResult.Hits.Hits {
			//
			//}
		} else {
			f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "I", i+1), "否")
		}
		f.Save()
	}
	log.Println("数据处理完毕")
}

func TestTaskFuc2(t *testing.T) {
	matchArr := make([]TagMatching, 0)
	//军队类
	jundui := "智慧,管护,办公,服务,维护,运维,代维,维保,改造,管理,监管,监控,安全,集成,开发,建设,疫情防控,公益诉讼,社会治理,市域治理,基层治理,警务调度,信访联防,陆军,空军,战支,联勤保障,军民融合,融通军产,军分区武装部,某部,营区安防,公安,交警,交通警察,出入境,边防,特勤,检察,法院,司法,政法,看守所,监狱,退役,双拥,优抚,军转干部,民政,养老,公共交通,交通,驾驶,驾校,运输,供应链,物流,机场,航空,港,公交,信息,数字,后勤管理,示教,远程,医共体,健康管理,人力资源,社会保障,现代农业产业园,医疗保障,畜牧一体化,工会,体育,税务,财政,煤田,纪委,红十字会,海关,统战,老干部,组织,科学技术厅,广播电视台,广播电视局,新华通讯社,长城新媒体集团,日报,宣传部,人民代表大会,科学技术协会,广电信息网络集团股份有限公司,智库,科学,统计局,审计局,省委办公厅,溯源,干部人事,健身,场馆,赛事,红十字,纪检委,红会,电子口岸,血站,港口,科技局,科学技术局,广电,新闻网,报社,媒体,报业,新闻,人大,科协,社会科学,社科,金审,人口,电子商务,市委办公室,追溯,档案,人居环境治理,技术升级,技术改造,应急指挥,景区,门票,分销,定位,全景,旅游,车载,车辆,信息安全,在线课程,布线,升级,改造,扩容,传输,入户,校园,政务,支付,财务,教育,财政,通信,通讯,视频,语音,数据,互联网,商务,小微,APN,因特网,IP,MSTP,VPDN,光纤,无线,GPRS,WiFi,扶贫,检察院,法院,公安,司法,政务,监测,政协,金税,履职,政务服务,放管服,公共资源,行政服务,行政审批,社会信用体系,效能监督,热线,政务数据,电视台,广播,传媒,杂志社,科学技术,科技园区,开发区管理委员,管委会,科技馆,科技创新,高新区发展,科技成果,影业,科技大厦,情报,科学器材,自然科学,科技信息和档案,科技金融,科学技术传播,青少年科技,企业创新促进,创新战略,普及推广,工作者,新华社,通讯社,舆论,智能化,门禁"
	tagJ1 := TagMatching{
		tagName:       "第一类",
		tagCode:       "001",
		matchField:    []string{"title"},
		matchKey:      jundui,
		matchKeyReg:   GetRegex(jundui),
		addField:      []string{"title"},
		addKey:        "平台,系统,软件,网络,云,通讯",
		addKeyReg:     GetRegex("平台,系统,软件,网络,云,通讯"),
		excludeField:  []string{"title"},
		excludeKey:    "超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,网上超市采购,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,雨污,保洁服务,物业服务,服装采购,中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取",
		excludeKeyReg: GetRegex("超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,网上超市采购,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,雨污,保洁服务,物业服务,服装采购,中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"),
	}
	matchArr = append(matchArr, tagJ1)

	key2 := "视频会议,视频监控,等保,信息化,机房,雪亮,智慧交管,智慧安防,智慧社区,天网,天幕,移动警务,综治,视联网,磐石,智慧监所,智慧平安,智慧检务,智慧法院,移动检务,掌上法院,直播听证,远程提讯,智慧监狱,智慧司法,智慧戒毒,智慧信访,绿色军营,智慧营区,二三级网,二级网,三级网,手机管控,智慧校园,智慧医院,智慧医保,智慧景区,智慧乡村,智慧食堂,一卡通,一脸通,银医,掌上医院,数据中心,风险普查,智慧城市,智慧城管,政务外网,云平台,物流系统,专线,电路,物联网,智慧医疗,互联互通,远程医疗,医疗云,影像云,PACS,HIS,云安全,云桌面,专属云,医院云,云服务,私有云,医院上云,云监控,云计算,云主机,桌面云,云医院,安全云,云办公,云专线,云客服,云终端,云网融合,专有云,云医疗,公有云,云应用,云化项目,智慧健康,系统平台,平台系统,信息服务平台,医联体,核酸检测系统,数字医疗,远程会诊,移动医护,网络安全,健康系统,专网,护理系统,胶片数字化,医废管理系统,安防系统,管理系统,卫健系统,服务系统,成像分析系统,一体化系统,呼叫系统,教学系统,体检系统,业务系统,定位系统,票据系统,医院系统,叫号系统,监护系统,导视系统,培训系统,监控系统,监测系统,标测系统,支持系统,用药系统,追溯系统,建设系统,超融合系统,病房净化系统,应用系统,系统功能,审核系统,影像系统,防护系统,导向系统,归档系统,备份系统,桌面系统,安保系统,发票系统,监管系统,决策系统,考核系统,物资系统,诊断系统,核算系统,电子签名系统,评价系统,安检系统,财务系统,系统开发,预约系统,分诊系统,合一系统,对讲系统,展示系统,调度系统,认证系统,办公系统,结算系统,干预系统,病案系统,筛查系统,管控系统,检验系统,防控系统,探视系统,引导系统,登记系统,上报系统,考试系统,传输系统采购,分配系统,报警系统,采集系统,监视系统,病理系统,收据系统,缴费系统,统计系统,报销系统,安全系统,报告系统,应急救援系统,测评系统,核酸快速检测系统,事件系统,一卡通系统,转播系统,接口系统,改造系统,互动系统,审计系统,核对系统,应急指挥系统,上传系统,评审系统,核签系统,共享系统,巡更系统,发布系统,排队系统,告警系统,疫苗接种告知确认系统,运维系统,支撑系统,内控系统,层析系统,导检系统,信息发布系统,卫生监督移动执法系统,疫苗接种系统,电子签核系统,应急系统,ERP系统,技术系统,仓储系统,支付系统,查询系统,前端系统,核查系统,人事系统,协同系统,住院系统,环境系统,面部跟踪系统,接警系统,审计大数据,电子病历,三农大数据,智慧渔业,数字乡村,5G,4G,智慧旅游平台,智慧停车,智慧农业,智慧气象,智慧建设,智慧城市建设,智慧水务,智慧档案,融媒体,VPDN,IDC,综合布线,IoT,光纤,综合管理平台,执法终端,慧眼,互联网+,呼叫中心,短彩信,校园网,网络存储设备,OA,办公自动化,高清视频,智能安防,监控安防,12345,12341,12342,12366,12328,12329,12333,12348,12351,12306,12316,12317,12322,12330,12319,12338,12378,12358,NB,辅警通,移动工作终端购置及通信服务,移动执法,一键报警,警务通,管控平台系统建设,数字化城市,4G单兵系统,综治视联网,数字化校园,云企信,云总机,融合总机,多媒通信,融合通信,视频通信,视频电话,无线商话,无线座机,交换机直连,集团通讯录,外勤管家,兵团社保通,商户管家,移动秀品,校讯通平台,集团V网,农信通,信息化终端设备服务系统,天眼,村村享,智慧交通,安全通讯,城域网,GPS,大数据,短信,防汛视频,数字校园,宽带,电子警察,智慧党建,智慧供水,高清会议,移动税务,WIFI,无线通信,检务通,云视频,可视一张网,智慧派出所,等级保护,智能扫码刷脸测温,智能测温,基层测温,智慧检务,智慧,医院信息化建设,智能信息化,机房运维,平安社区,四级网,智能接处警,智慧云,监控工程建设,安全监测设施,通信管道,数字城管,指挥调度系统,监控设备,智慧平安乡村,信息网建设,智能监控,网络建设,智慧教育,电教室,扫码测温,智能感知,长效管护平台,数字中心,智慧环卫,人脸识别,交通感知,移动办公,益农信息社,链路连接,人脸抓拍,电话系统,农村厕所管护,警务终端,城市综合管理,平安城市,弱电&&智能化,门禁,视频传输,安全防护体系,智能化,网络&&平台,卫星通信,卫星通讯,公网基站,通信&&基站,通讯&&基站,互联网&&接入,互联网&&服务,通信线路,通信&&服务,弱电&&系统"
	ex2 := "超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,网上超市采购,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,保洁服务,物业服务,服装采购中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
	tagJ2 := TagMatching{
		tagName:       "第2类",
		tagCode:       "002",
		matchField:    []string{"title"},
		matchKey:      key2,
		matchKeyReg:   GetRegex(key2),
		excludeField:  []string{"title"},
		excludeKey:    ex2,
		excludeKeyReg: GetRegex(ex2),
	}
	matchArr = append(matchArr, tagJ2)

	key3 := "智算云,智算中台,数字孪生平台,物联网平台,城市大脑,智慧停车,智慧灯杆,智慧社区,智慧养老,智慧小区,智慧物业,智慧乡村,智慧农业,智慧党建,数字乡村,智慧城市,数智城市,智治城市,数字驾驶舱,新型智慧城市,数据基础底座,智能视觉平台,云网资源接入,数字城市,数智城市,数字底座,超级大脑,城市大脑,全息路网,全息路口,智慧水务,智慧应急,智能装备,智慧城管,应急指挥系统,智慧消防,一网统管,数字政府,城市超脑,防欺凌&&报警,防欺凌&&预警,防欺凌&&终端,防欺凌&&AI,人工智能智算,算力卡,云智算,定制开发&&系统集成"
	ex3 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
	tagJ3 := TagMatching{
		tagName:       "第3类",
		tagCode:       "003",
		matchField:    []string{"title"},
		matchKey:      key3,
		matchKeyReg:   GetRegex(key3),
		excludeField:  []string{"title"},
		excludeKey:    ex3,
		excludeKeyReg: GetRegex(ex3),
	}

	matchArr = append(matchArr, tagJ3)
	key4 := "热线平台,综合布线,协同办公,远程办公,vpn,wifi,私有云,云桌面,云计算,桌面云,智能云,政务云,云平台,云迁移,云资源,云服务,公有云,云灾备,云存储,云租用,云租赁,边缘云,专享云,虚拟化,云办公,云基础,基础资源,医疗云,智造云,行业云,新沃云,云运维,云应用,云安全,灵云,人口普查,舆情&&分析,舆情监测,舆情监控,舆情&&系统,防勒索病毒,灾备平台,电子化规范,处方前置系统,合理用药,物联网,NB-IOT,烟感,IDC,ICT,机房&&租赁,机房&&租用,机房&&建设,机房&&迁移,机房&&搬迁,机房&&托管,5G,人脸识别,门禁&&系统,人脸&&闸机,容灾备份,等级保护,等保,等级评测,区块链,短信,彩信,固话,数字政府,平安社区,平安校园,共享交换平台,移动执法,平安城市,智慧矿山,雪亮,智慧旅游,智慧景区,电子围栏,明厨亮灶,智慧校务,远程教育,多媒体教学,智慧教育,智慧课堂,虚拟现实,大数据实训,工业机器人,教育信息化,数字校园,智慧校园,校园信息化,标准化&&考场,标准化&&考点,智慧考场,智慧考点,智能&&安检门,基础网络,弱电智能化,智能化工程,智慧居家,智能门禁,应急能力提升,教育&&设备,教学&&设备,教育&&装备,教学&&装备,智慧医院,智慧医疗,大数据监督平台,信息化,监测平台,风险普查,通信服务,雨水情,智慧市场监管,智能化,数据流量,移动办案,智慧环保,智能安防,移动警务,移动&&终端,无人农场,远程医疗,监管体系,智慧井盖,智能交通,房屋&&普查,应急管理体系,智慧办公,城市综合治理,智慧大厦,智慧养老,灾害防御系统,综合治理平台,排队叫号,教育&&一体化,教学&&一体化,智慧政协,智慧哨兵,电子政务,非现场执法,智慧园区,社会治理,水库安全运行,溯源体系,接处警,一张图,涉税数据,智慧监管,精准教学,远程接访,云广播,数字化城市,智慧警务,智慧人大,医共体,医联体,预警信息发布,移动护理,无纸化病案,智能医废,电子病历,协同共管,信创云,智慧医护,无线覆盖,移动专网,惠企&&平台,院前急救,数字化城管,IPV4,IPV6,智慧水利,智慧水务,云视讯,视频会议系统,视频会商,蓝天卫士,智慧工厂,远程医技,远程会诊,森林防火,森林火灾,电子表决,人像识别,录播教室,多规合一,96110,智能回访,舆情通,智能导航,智能导诊,智慧法制,呼叫平台,虚拟仿真,智慧教室,智慧路灯,班班通,改薄提升,电子警察,教育薄弱环节改善,教育薄改,管户设备,标准化考场,标准化考点,可视化指挥调度系统,基本装备采购,网络管理,国际业务专线,传输网络,指挥通信设备,4G无线图传,无线图传&&执法记录仪,专网,专线,信息系统,网络服务,天线地网,地网,移动医护,应急救援,全民健康信息平台,等保测评,疾病预防,精准预约,挂号系统,双重预防,预防体系,监控系统,动态监控,一村一警,等级测评,远程协同,转移支付,图像监测站,监测监控能力,监测监控&&设备,智慧&&系统集成,智能&&系统集成,通信系统,计算机网络,视频安防系统,通信光缆,自动化系统,流量计系统,决策支持系统,高精定位,移动办公,辅助办案,远程指挥,跨省通办,支付电子化,雪亮工程,基础电信业务运营商,广电网络运营商,溯源体系软件平台建设,治安防控,系统集成,远程取证,建筑承灾体,建筑受灾体,考评一体化,数字化,老旧小区,质量安全追溯体系,平安灯箱,雨水情测报,安全监测,安全运行,技能振兴,生态综合体,平安基层,尾水&&达标,尾水&&治理,互联&&电路,工业互联网,双高,监测&&技术&&服务,执法系统,应急&&广播,定位系统,城市&&平台建设,加油站涉税数据管理,无纸化办公,大数据&&平台,网格&&终端,一体化&&平台,疫情防控&&一体化,疫情&&平台,医疗&&共同体,重点隐患整治,技防监控,突发事件&&预警,公共数字文化,考试平台,安防工程,安防系统,水库监测,景区提升,美丽乡村,乡村振兴,智慧社区,智慧小区,智慧物业,智慧乡村,智慧农业,智慧党建,数字乡村,返贫监测,基层治理,乡村治理,航空巡护,房屋安全普查,厕所革命,履职平台,信道&&服务,信道租赁,综合治理,有诉即办,接诉即办,软件技术服务,感知设备,综合&&集成,现代&&产业园,场所码&&系统,网站群&&升级,数智化,运管服管理平台,城市生命线,智慧园林,智慧市政,智慧环卫,运管服&&平台,组网&&集成,组网&&服务,督查&&系统,督办&&系统,元宇宙,基础设施&&提升,湿地&&保护,湿地&&修复,追溯体系,人工影响天气能力,防汛&&装备,抢险&&装备,数字城市,数智城市,数字底座,超级大脑,城市大脑,全息路网,全息路口,车联网,智能网联,网联车,车路协同,车路智行,智慧出行,营运车辆监管,TOCC,交通运行监测,交通运行调度,车&&调度平台,车&&调度系统,电子站牌,智慧停车,智慧泊车,道路&&智能,网络&&建设,ipv,雾森,雾炮,数字孪生,薄弱环节改善,教育&&薄&&改,拆墙透绿,工控安全,一体化建设,烟草&&一体化,薄&&改&&提升,智慧交通,校园&&安防,智慧&&安防,移动互联网,互联网链路,移动&&链路,城市&&视频,城市&&监控,亮化工程,视频图像,图像解析,北斗定位,精准&&教学,弱电系统,自动审核,智能审核,旱作节水,农业技术,勤指情,智慧街面巡防,智慧安防小区,智感安防小区,公安信息化,公安科技装备,警务信息化,天网,治安视频监控,公安大数据,警务云,视频图像感知,全息感知网,视频智能化,视频云,视频监控平台,视频图像综合应用,视频图像信息数据库,视图库,视频图像解析,人脸聚档,公安技战法,社会治安防控体系,圈层查控,市域单元防控,治安要素管控,数字驾驶舱,新型智慧城市,数据基础底座,智能视觉平台,系统平台维护,云网资源接入,驾驶舱,水质&&监测,三级等保,会商系统,值班视频,机房托管,无线&&网,网&&接入,全光网,电子商务进农村,互联网法庭,办公流量,弱电&&设施,新型城市,战术子网,云监管,云&&平台,文旅&&云,固网&&业务,固网语音,电子监控,新媒体宣传,院内&&导航,高精矢量地图,地图模拟导航,平台搭建,录音录像系统,网络运维,基础软件,软件开发,公共停车系统,无纸化,城市综合提升,一件事,一次办,只跑一次,市带县,情指勤,情指行,互联互通,五级乙等,医院&&级&&等,视频会议,云&&部署,全域可视化,执法&&装备,舆情分析,语音服务平台,语音&&平台,12123,网络设备,信息技术类,技防体系,火灾探测报警器,独立式&&火灾探测,阅卷系统,全域感知,物联网平台,融媒体中心,智慧交管,智能交管,交通治理,交通综合治理,拥堵治理,缓堵提升,数智治理,数字道路,交通提升,交通大脑,大数据分析,评价诊断,辅助决策,交通参数,交通态势,边缘计算单元,边缘计算盒子,边缘信号控制,边缘智能信控,边缘信控盒子,信控一体机,信号控制优化,信号控制与优化,统一信控平台,信号控制系统,信控系统,信控联网,安全治理,城市交通,农村交通,农村安全,交通违法,机动车违法,非机动车违法,电动自行车违法,重点车辆违法,农村违法,交通执法,机动车执法,非机动车执法,电动自行车执法,重点车辆执法,农村执法,重点车辆,视频抓拍,机动车抓拍,非机动车抓拍,违法抓拍,执法抓拍,电动自行车抓拍,车辆抓拍,车辆档案,违法检测,事件检测,二次识别,违法识别,行为识别,特征识别,AI识别,AI分析,智能识别,智能分析,视频分析,视频解析,图片解析,智能算法,智能视觉,以图搜图,布控,检索比对,学院&&信息化,大学&&信息化,校园&&信息化,医院&&信息化,医疗&&信息化,学院&&智能化,大学&&智能化,校园&&智能化,医院&&智能化,医疗&&智能化,互联网接入,光纤,链路,通信&&传输,在线监管,12313,12315,警务通,辅警通,检务通,手机卡,审务通,狱警通,城管通,党务通,4G视频,车载定位,流量服务,移动4G手机,办公自动化,OA办公,保密终端,政务短信平台,移动专属合作,人像卡口,网络线路,网络升级,宽带提速,数据库建设,办案手持终端,防汛视频,光伏扶贫,监控系统联网监督系统,监控设备,宽带升级,政务办公系统,网络化管理,移动终端,视频监控,光纤租赁,数据共享中心,宽带接入,光纤线路租费,智慧城市指挥中心,卡口系统,网络改造,视频检测站,手持报警器,值班室视频,智慧供水,高清会议系统,云视频,移动通信业务,电视会议,联网系统,网络安全,信息管理平台,监控中心,信息平台,VPN专线,门户网站建设,信息共享平台,互联网平台集成服务,值班管理系统,高清视频会议,矿坑监测点,线路组网,公交车载WIFI,OA功能扩展,移动税务信息化,互联网接入服务,信息服务平台,数字化中心,前端信息点,智能办公系统,无线通信设备,电子监控平台,办公管理平台,移动云,MAS,管理信息网,数据共享平台,网络运营服务,村村响,免费WIFI,信息安全服务,保密通信服务,保障体系,移动安全,监控设施,网&&租赁,数字化采集,应用程序服务,调度平台,运营平台,农村厕所&&提升,农村厕所&&改造,粪污&&平台,智慧灌区,水利大脑,水旱灾害防御,河长制湖长制,水利云平台,数字大厅,数据大脑,企业上云,智能巡更,园区信息化服务,智慧水表,一网通办,一网通管,一体化政务服务,城市治理,市域治理,可视化调度,智慧城市,CIM,智慧政务,数字民生,智慧物流,智慧能源,数字物流,数字城管,食品安全,智慧工地,数字产业,数据智能,智慧应急,智能装备,智慧城管,应急指挥系统,智慧消防,一网统管,城市超脑,天眼,城市&&智能,城市&&网络,城市&&数字化,城市&&数智,智能环保,智能医疗,远程诊断,智慧经济,智慧居民,智慧安防,智能电网,智慧安居,智慧健康,数字交通,智慧电网,智慧燃气,一图全面感知,一键可知全局,一站创新平台,一体运行联动,城市运行管理体系,创业服务平台,数字化产业,智慧管廊,智慧文旅,文旅云,电子健康卡,数字&&保障&&中心,视觉计算,APP建设,应急指挥能力,警情分析,执法助手,执法办案,AIGC,创新应用中心,基层防灾,精准分析,算力,防欺凌,人工智能,集群"
	ex4 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
	tagJ4 := TagMatching{
		tagName:       "第4类",
		tagCode:       "004",
		matchField:    []string{"title"},
		matchKey:      key4,
		matchKeyReg:   GetRegex(key4),
		excludeField:  []string{"title"},
		excludeKey:    ex4,
		excludeKeyReg: GetRegex(ex4),
	}
	matchArr = append(matchArr, tagJ4)

	key5 := "专网,网络,链路,线路,互联网,宽带,带宽,链路"
	add5 := "租用,租赁,服务,接入"
	ex5 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"

	tagJ5 := TagMatching{
		tagName:       "第5类",
		tagCode:       "005",
		matchField:    []string{"title"},
		matchKey:      key5,
		matchKeyReg:   GetRegex(key5),
		addField:      []string{"title"},
		addKey:        add5,
		addKeyReg:     GetRegex(add5),
		excludeField:  []string{"title"},
		excludeKey:    ex5,
		excludeKeyReg: GetRegex(ex5),
	}
	matchArr = append(matchArr, tagJ5)

	key6 := "社会治理信息化,综合指挥调度系统,视频图像交换系统,智能巡护终端,大数据智能监管平台,灌溉&&一张网,水肥一体化,农田信息化工程,耕地质量监测,农田生产&&监测,农田科技&&监测,农作物良种对比试验站,森林资源视频监控,自然保护区&&智慧化,城市生命线,城市运管服,城市运行管理服务,城市运行监测,城市管理监督评价指标体系,城市灾害预警,预警指挥平台,物联感知支撑平台,地理信息支撑系统,溯源体系软件平台建设,AI声音安防卫士,智能音频分析,智能音频检测,防欺凌AI音频报警,智能语音警报设备,农田&&信息化,农田信息工程,农田&&监测,高标准农田&&智能化,高标准农田&&图斑,高标准农田&&灌溉,高标准农田&&大数据,高标准&&农田监测,农田监测系统,高标准农田&&信息化监测,算力"
	ex6 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取,起重机,材料,审计,编制服务,报告编制,会务服务"

	tagJ6 := TagMatching{
		tagName:       "第6类",
		tagCode:       "006",
		matchField:    []string{"title"},
		matchKey:      key6,
		matchKeyReg:   GetRegex(key6),
		excludeField:  []string{"title"},
		excludeKey:    ex6,
		excludeKeyReg: GetRegex(ex6),
	}
	matchArr = append(matchArr, tagJ6)

	key7 := "综合服务能力,监控,水库,灌区,风险"
	add7 := "提升,升级,改造,建设,信息化,雨水情,监测设施,监测预警,防控,预警,预防"
	ex7 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"

	tagJ7 := TagMatching{
		tagName:       "第7类",
		tagCode:       "007",
		matchField:    []string{"title"},
		matchKey:      key7,
		matchKeyReg:   GetRegex(key7),
		addField:      []string{"title"},
		addKey:        add7,
		addKeyReg:     GetRegex(add7),
		excludeField:  []string{"title"},
		excludeKey:    ex7,
		excludeKeyReg: GetRegex(ex7),
	}
	matchArr = append(matchArr, tagJ7)

	key8 := "火灾&&报警,医院&&达标,医养&&设备,医养综合体,考点&&改造,养老&&设施,养老&&设备,密评,网络&&提升,长距离对讲,防统方,机顶盒,污染&&基站,乐业小站,城市&&生命线,全息投影,电子签,远程医学,掌上医院,算力集群,算力平台,量子计算平台,算力&&建设,算力服务,专属云,智算&&云,组网,园区&&安防,一网统管,全息感知,全域感知,智慧热力,危化品监管,综合管廊,数字孪生,城市风险,城市&&平台建设,智慧&&路灯,智能&&路灯,智慧&&灯杆,智能&&灯杆,监控杆,智慧&&灯塔,多功能路灯,数字&&路灯,数字&&灯杆,多杆合一,预警&&能力,应急&&能力提升,预警&&指挥,预警&&提升,火险&&监测,火情&&监测,视频&&指挥&&调度,无人机&&平台,航空应急,网络&&感知,融合调度,河长制,AI音频,声纹识别,AI预警,智能语音,警报设备,安防卫士,校园&&安防,AI报警,声纹,警务综合,警综,签名捺印,电子签,案管,涉案语音处理,警情分析,执法助手,执法办案,生态&&监测站,环境&&监测站,油烟&&监测,感烟报警,烟感报警,大模型,数据模型,普查&&PDA,普查&&PAD,智慧农业,旱作节水,雨水情,无人农场,溯源体系,数字茶园,数字农田,智慧灌区,水旱灾害防御,农田&&信息化,农田信息工程,农田&&监测,高标准农田&&智能化,高标准农田&&图斑,高标准农田&&灌溉,耕地质量评估,土壤&&检测,高标准农田&&大数据,智慧农业,土肥监测,耕地核实入库,高标准&&农田监测,农田监测系统,高标准农田&&信息化监测,互联网&&安全,互联网&&设备,卡口测速,云教室,天空地&&一体,四情&&监测,基层&&医疗&&体系,基层&&卫生&&系统,基层&&医疗&&系统,电子班牌,监控&&补点,监控&&补盲,考点&&升级,风险管控&&平台,耕地&&预警,公立医院改革,医院&&高质量发展,窨井&&整治,物联网&&设备,自动监测站,物联&&感知,诊疗平台,中心平台软件,环境监测,4G图传,医院告知软件,作战系统,电子报规,监控&&系统,智慧化,政务&&网络,移动端&&服务,固网&&服务,金保,便民&&热线,服务&&热线,视联网,视频&&联网"
	ex8 := "家具,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
	tagJ8 := TagMatching{
		tagName:       "第8类",
		tagCode:       "008",
		matchField:    []string{"title"},
		matchKey:      key8,
		matchKeyReg:   GetRegex(key8),
		excludeField:  []string{"title"},
		excludeKey:    ex8,
		excludeKeyReg: GetRegex(ex8),
	}
	matchArr = append(matchArr, tagJ8)

	f, err := excelize.OpenFile("./7月非运营商中标数据比对缺失数据V1.xlsx")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer func() {
		f.Save()
		if err := f.Close(); err != nil {
			fmt.Println(err)
		}
	}()

	//2.专项债详情
	rows, err := f.GetRows("基础数据")
	if err != nil {
		fmt.Println(err)
		return
	}
	for i := 2; i < len(rows); i++ {
		title := rows[i][2]
		tmp := map[string]interface{}{
			"title": title,
		}
		_, match, _, ex := TaskTags(tmp, matchArr)
		if match == "" {
			f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "1")
		}
		if match != "" && ex != "" {
			f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "2")
		}
		if match != "" && ex == "" {
			f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "3")
		}
	}

	f.Save()
	log.Println("数据处理完毕")
}