xlsx_test.go 65 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218
  1. package main
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/olivere/elastic/v7"
  7. "github.com/xuri/excelize/v2"
  8. "go.mongodb.org/mongo-driver/bson"
  9. "go.mongodb.org/mongo-driver/mongo"
  10. "go.mongodb.org/mongo-driver/mongo/options"
  11. util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
  12. "jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
  13. "log"
  14. "os"
  15. "strconv"
  16. "strings"
  17. "testing"
  18. "time"
  19. )
  20. func TestExportCompanyType(T *testing.T) {
  21. ctx := context.Background()
  22. // MongoDB 连接字符串
  23. username := ""
  24. password := ""
  25. //hosts := []string{"172.17.4.181:27001"}
  26. hosts := []string{"127.0.0.1:27001"}
  27. uri, err := BuildMongoURI(username, password, hosts, nil)
  28. if err != nil {
  29. panic(err)
  30. }
  31. // MongoDB连接
  32. clientOptions := options.Client().ApplyURI(uri)
  33. clientOptions.SetDirect(true)
  34. client, err := mongo.Connect(ctx, clientOptions)
  35. if err != nil {
  36. log.Fatal(err)
  37. }
  38. defer client.Disconnect(ctx)
  39. db := client.Database("mixdata")
  40. collection := db.Collection("company_base")
  41. filter := bson.M{
  42. "company_status": bson.M{"$nin": []string{"注销", "吊销", "已吊销", "已注销"}},
  43. "use_flag": 0,
  44. }
  45. // 查询 distinct company_type
  46. types, err := collection.Distinct(ctx, "company_type", filter)
  47. if err != nil {
  48. log.Fatalf("查询 distinct 失败: %v", err)
  49. }
  50. fmt.Printf("共找到 %d 个 company_type\n", len(types))
  51. // 创建 Excel 文件
  52. f := excelize.NewFile()
  53. sheet := "Sheet1"
  54. // 设置第一行标题
  55. f.SetCellValue(sheet, "A1", "company_type")
  56. // 填写数据
  57. for i, t := range types {
  58. // 强制转成字符串
  59. str, ok := t.(string)
  60. if !ok {
  61. // 如果不是字符串,跳过
  62. continue
  63. }
  64. // Excel 行号从 2 开始
  65. cell := fmt.Sprintf("A%d", i+2)
  66. f.SetCellValue(sheet, cell, str)
  67. }
  68. // 保存 Excel 文件
  69. if err := f.SaveAs("company_types.xlsx"); err != nil {
  70. log.Fatalf("保存 Excel 失败: %v", err)
  71. }
  72. fmt.Println("导出完成,文件名:company_types0711.xlsx")
  73. }
  74. func TestA(T *testing.T) {
  75. Mgo := &mongodb.MongodbSim{
  76. //MongodbAddr: "172.17.189.140:27080",
  77. MongodbAddr: "127.0.0.1:27017",
  78. Size: 10,
  79. DbName: "wcc",
  80. //UserName: "SJZY_RWbid_ES",
  81. //Password: "SJZY@B4i4D5e6S",
  82. //Direct: true,
  83. }
  84. Mgo.InitPool()
  85. f, err := excelize.OpenFile("./拼数据.xlsx")
  86. if err != nil {
  87. fmt.Println(err)
  88. return
  89. }
  90. defer func() {
  91. if err := f.Close(); err != nil {
  92. fmt.Println(err)
  93. }
  94. }()
  95. rows, err := f.GetRows("Sheet1")
  96. if err != nil {
  97. fmt.Println(err)
  98. return
  99. }
  100. cells, _ := f.GetCols("Sheet2")
  101. for i := 1; i < len(rows); i++ {
  102. log.Print(rows[i][3])
  103. if rows[i][2] == "省级" {
  104. for k, v := range cells[0] {
  105. if k == 0 || v == "" {
  106. continue
  107. }
  108. insert := make(map[string]interface{})
  109. insert["top"] = rows[i][0]
  110. insert["area"] = rows[i][3]
  111. insert["level"] = rows[i][2]
  112. insert["sub"] = v
  113. insert["name"] = rows[i][3] + v
  114. Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
  115. }
  116. }
  117. if rows[i][2] == "市级" {
  118. for k, v := range cells[1] {
  119. if k == 0 || v == "" {
  120. continue
  121. }
  122. insert := make(map[string]interface{})
  123. insert["top"] = rows[i][0]
  124. insert["area"] = rows[i][3]
  125. insert["city"] = rows[i][4]
  126. insert["level"] = rows[i][2]
  127. insert["sub"] = v
  128. insert["name"] = rows[i][4] + v
  129. Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
  130. }
  131. }
  132. if rows[i][2] == "县级" {
  133. for k, v := range cells[2] {
  134. if k == 0 || v == "" {
  135. continue
  136. }
  137. insert := make(map[string]interface{})
  138. insert["top"] = rows[i][0]
  139. insert["area"] = rows[i][3]
  140. insert["city"] = rows[i][4]
  141. insert["district"] = rows[i][5]
  142. insert["level"] = rows[i][2]
  143. insert["sub"] = v
  144. insert["name"] = rows[i][4] + rows[i][5] + v
  145. Mgo.InsertOrUpdate("wcc", "wcc_0313", insert)
  146. }
  147. }
  148. }
  149. fmt.Println("over")
  150. }
  151. func TestA2(T *testing.T) {
  152. Mgo := &mongodb.MongodbSim{
  153. MongodbAddr: "127.0.0.1:27017",
  154. Size: 10,
  155. DbName: "wcc",
  156. }
  157. Mgo.InitPool()
  158. f, err := excelize.OpenFile("./主体代码表.xlsx")
  159. if err != nil {
  160. fmt.Println(err)
  161. return
  162. }
  163. defer func() {
  164. if err := f.Close(); err != nil {
  165. fmt.Println(err)
  166. }
  167. }()
  168. rows, err := f.GetRows("国民经济行业分类")
  169. if err != nil {
  170. fmt.Println(err)
  171. return
  172. }
  173. for i := 2; i < len(rows); i++ {
  174. log.Print("iii", i)
  175. var top1, top2, top3, top4, name string
  176. if len(rows[i]) <= 0 {
  177. continue
  178. }
  179. if len(rows[i]) > 0 {
  180. top1 = rows[i][0]
  181. }
  182. /**
  183. top2 := rows[i][1]
  184. top3 := rows[i][2]
  185. top4 := rows[i][3]
  186. name := rows[i][4]
  187. */
  188. insert := map[string]interface{}{
  189. "top1": top1,
  190. }
  191. if len(rows[i]) > 1 {
  192. top2 = rows[i][1]
  193. insert["top2"] = top2
  194. }
  195. if len(rows[i]) > 2 {
  196. top3 = rows[i][2]
  197. insert["top2"] = top3
  198. }
  199. if len(rows[i]) > 3 {
  200. top4 = rows[i][3]
  201. insert["top2"] = top4
  202. }
  203. if len(rows[i]) > 4 {
  204. name = rows[i][4]
  205. insert["name"] = name
  206. }
  207. if len(rows[i]) > 5 {
  208. insert["desc"] = rows[i][5]
  209. }
  210. if top4 != "" {
  211. insert["level"] = 4
  212. insert["code"] = top1 + top4
  213. } else if top3 != "" {
  214. insert["level"] = 3
  215. insert["code"] = top1 + top3
  216. } else if top2 != "" {
  217. insert["level"] = 2
  218. insert["code"] = top1 + top2
  219. } else {
  220. insert["level"] = 1
  221. insert["code"] = top1
  222. }
  223. //insert := map[string]interface{}{
  224. // "company_name": rows[i][2],
  225. // "organizer": rows[i][1],
  226. //}
  227. err = Mgo.InsertOrUpdate("wcc", "wcc_national_industries_classification", insert)
  228. if err != nil {
  229. log.Println("err", err)
  230. }
  231. }
  232. fmt.Println("over")
  233. }
  234. func TestB(T *testing.T) {
  235. Mgo := &mongodb.MongodbSim{
  236. //MongodbAddr: "172.17.189.140:27080",
  237. MongodbAddr: "127.0.0.1:27083",
  238. Size: 10,
  239. DbName: "qfw",
  240. UserName: "SJZY_RWbid_ES",
  241. Password: "SJZY@B4i4D5e6S",
  242. Direct: true,
  243. }
  244. Mgo.InitPool()
  245. f, err := excelize.OpenFile("./剑鱼标讯_数据导出.xlsx")
  246. if err != nil {
  247. fmt.Println(err)
  248. return
  249. }
  250. defer func() {
  251. if err := f.Close(); err != nil {
  252. fmt.Println(err)
  253. }
  254. }()
  255. rows, err := f.GetRows("Sheet1")
  256. if err != nil {
  257. fmt.Println(err)
  258. return
  259. }
  260. for i := 1; i < len(rows); i++ {
  261. url := rows[i][2]
  262. log.Println(rows[i][1])
  263. id := GetIdByURL(url)
  264. re, _ := Mgo.FindById("bidding", id, nil)
  265. (*re)["wcc_id"] = i
  266. (*re)["toptype_old"] = (*re)["toptype"]
  267. (*re)["subtype_old"] = (*re)["subtype"]
  268. delete(*re, "toptype")
  269. delete(*re, "subtype")
  270. Mgo.SaveByOriID("wcc_bidding_0518", re)
  271. }
  272. log.Println("over")
  273. }
  274. // TestAAA 处理专项债券数据,导出专项债详情
  275. func TestAAA(t *testing.T) {
  276. //87 竞品
  277. Mgo := &mongodb.MongodbSim{
  278. //MongodbAddr: "172.17.4.87:27080",
  279. MongodbAddr: "127.0.0.1:27081",
  280. Size: 10,
  281. DbName: "py_theme",
  282. UserName: "",
  283. Password: "",
  284. Direct: true,
  285. }
  286. Mgo.InitPool()
  287. sess := Mgo.GetMgoConn()
  288. defer Mgo.DestoryMongoConn(sess)
  289. //f, err := excelize.OpenFile("./山东2024专项债.xlsx")
  290. f, err := excelize.OpenFile("./天津专项债.xlsx")
  291. //detailName := "specialbond_detail_202412" //专项债详细表
  292. detailName := "specialbond_detail" //专项债详细表
  293. if err != nil {
  294. fmt.Println(err)
  295. return
  296. }
  297. defer func() {
  298. f.Save()
  299. if err := f.Close(); err != nil {
  300. fmt.Println(err)
  301. }
  302. }()
  303. rows, err := f.GetRows("项目列表")
  304. if err != nil {
  305. fmt.Println(err)
  306. return
  307. }
  308. keys := []string{"projectName", "totalInvestment", "regionName", "cityName", "countyName", "capital", "applyDebt", "portfolioFinancing", "specialDebtAsCapital",
  309. "expectedReturn", "projectCost", "projectTypeName3", "projectSubject", "startDate", "endDate", "operationStartDate",
  310. "operationEndDate", "sourceIncome", "constructionContent", "remarks", "portfolioFinancingSource", "costIncomePercent", "coverageMultiple", "implementingAgency",
  311. "accountingFirm", "lawFirm", "createTime", "updateTime"}
  312. titles := []string{"项目名称", "总投资(万元)", "省份", "地市", "区县", "不含专项债资本金(万元)", "申请专项债总额(万元)", "其他债务融资(万元)", "专项债作资本金(万元)", "预期收入(万元)", "成本",
  313. "项目领域", "项目业主", "建设期开始", "建设期结束", "运营期开始", "运营期结束", "收入来源", "建设内容", "特殊情况备注", "其他债务融资来源", "成本/收入(%)", "覆盖倍数", "主管部门", "会计所", "律所", "入库时间", "更新时间"}
  314. keys2 := []string{"bondName", "bondShortName", "bondNo", "regionName", "bondType1Name", "bondType2Name", "projectType1Name", "totalAmount", "issueDate", "issuePlaceName", "issueTerm", "issueInterestRate", "issuePhase", "payInterestMethodName",
  315. "newBondAmount", "counterBondAmount", "refinancingBondAmount", "redemptionMethod", "valueDate", "expiryDate", "payInterestDate", "latelyPayInterestDate", "lastPayInterest", "cumulativePayInterest"}
  316. titles2 := []string{"项目名称", "债券名称", "债券简称", "债券编码", "省份", "债券性质", "债券类型", "官方项目类型", "发行金额(万元)", "发行日期", "发行场所", "发行期限(年)", "发行利率(%)", "发行期数", "付息方式", "新增债券(亿元)", "置换债券(亿元)", "再融资债券(亿元)", "赎回方式",
  317. "起息日", "到息日", "付息日", "最近付息日", "上期已付息(亿元)", "累计付息(亿元)"}
  318. line := 0
  319. line++
  320. f.NewSheet("项目详情")
  321. f.NewSheet("债券详情")
  322. bondLine := 0
  323. //设置第一行title
  324. _ = f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &titles)
  325. _ = f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &titles2)
  326. //
  327. for i := 1; i < len(rows); i++ {
  328. projectName := rows[i][0]
  329. //projectName := "新建南通至宁波高速铁路(海盐段)"
  330. if i%10 == 0 {
  331. log.Println("iiii", i, projectName)
  332. }
  333. line++
  334. where := map[string]interface{}{
  335. "project.jcxx.projectName": projectName,
  336. }
  337. detail, _ := Mgo.FindOne(detailName, where)
  338. if len(*detail) == 0 {
  339. continue
  340. }
  341. insert := make([]interface{}, 0)
  342. if project, ok := (*detail)["project"].(map[string]interface{}); ok {
  343. if jcxx, ok := project["jcxx"].(map[string]interface{}); ok {
  344. for _, v := range keys {
  345. insert = append(insert, jcxx[v])
  346. }
  347. }
  348. }
  349. err := f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &insert)
  350. if err != nil {
  351. log.Println(err)
  352. return
  353. }
  354. // 债券基本信息
  355. if bonds, ok := (*detail)["bond"].([]interface{}); ok {
  356. for _, bond := range bonds {
  357. if bondData, ok := bond.(map[string]interface{}); ok {
  358. if jcxx, ok := bondData["jbxx"].(map[string]interface{}); ok {
  359. //if strings.Contains(util.ObjToString(jcxx["bondName"]), "2024") {
  360. bondInsert := make([]interface{}, 0)
  361. bondInsert = append(bondInsert, projectName)
  362. for _, v := range keys2 {
  363. bondInsert = append(bondInsert, jcxx[v])
  364. }
  365. bondLine++
  366. f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &bondInsert)
  367. //}
  368. }
  369. }
  370. }
  371. }
  372. }
  373. }
  374. // TestZZ 获取项目列表相关数据
  375. func TestZZ(t *testing.T) {
  376. //87 竞品
  377. Mgo := &mongodb.MongodbSim{
  378. //MongodbAddr: "172.17.4.87:27080",
  379. MongodbAddr: "127.0.0.1:27081",
  380. Size: 10,
  381. DbName: "py_theme",
  382. UserName: "",
  383. Password: "",
  384. Direct: true,
  385. }
  386. Mgo.InitPool()
  387. sess := Mgo.GetMgoConn()
  388. defer Mgo.DestoryMongoConn(sess)
  389. //f, err := excelize.OpenFile("./山东2024专项债.xlsx")
  390. f, err := excelize.OpenFile("./青岛市20250324专项债数据.xlsx")
  391. //detailName := "specialbond_detail_202412" //专项债详细表
  392. listName := "specialbond_list,specialbond_list_history,specialbond_list_202503" //专项债详细表
  393. if err != nil {
  394. fmt.Println(err)
  395. return
  396. }
  397. defer func() {
  398. f.Save()
  399. if err := f.Close(); err != nil {
  400. fmt.Println(err)
  401. }
  402. }()
  403. rows, err := f.GetRows("项目列表")
  404. if err != nil {
  405. fmt.Println(err)
  406. return
  407. }
  408. keys := []string{"projectName", "presentIssueAmount", "issueTerm", "regionName", "cityName", "countyName", "totalInvestment", "issueDate"}
  409. titles := []string{"项目名称", "累计发行额(亿元)", "发行期限(年)", "省份", "城市", "区县", "总投资(亿元)", "发行时间"}
  410. line := 0
  411. line++
  412. _ = f.SetSheetRow("项目列表", fmt.Sprintf("%s%d", "A", line), &titles)
  413. for i := 1; i < len(rows); i++ {
  414. projectName := rows[i][0]
  415. if i%10 == 0 {
  416. log.Println("iiii", i, projectName)
  417. }
  418. line++
  419. where := map[string]interface{}{
  420. "projectName": projectName,
  421. }
  422. tables := strings.Split(listName, ",")
  423. insert := make([]interface{}, 0)
  424. for _, table := range tables {
  425. list, _ := Mgo.FindOne(table, where)
  426. if len(*list) == 0 {
  427. continue
  428. }
  429. for _, v := range keys {
  430. insert = append(insert, (*list)[v])
  431. }
  432. break
  433. }
  434. if len(insert) > 0 {
  435. err = f.SetSheetRow("项目列表", fmt.Sprintf("%s%d", "A", line), &insert)
  436. if err != nil {
  437. log.Println(err)
  438. return
  439. }
  440. }
  441. }
  442. log.Println("数据处理完毕")
  443. }
  444. func TestGetIdByURL(t *testing.T) {
  445. url := "https://www.jianyu360.cn/article/content/AHnY1xBfikoAjYsNGd4cE8JIzAvFj1jcXNlKDhROC4eWlFwA15UCZQ%3D.html"
  446. fmt.Println(GetIdByURL(url))
  447. }
  448. // TestArea 中国行政区划数据-民政部
  449. func TestArea(t *testing.T) {
  450. Mgo := &mongodb.MongodbSim{
  451. //MongodbAddr: "172.17.189.140:27080",
  452. MongodbAddr: "127.0.0.1:27083",
  453. Size: 10,
  454. DbName: "qfw",
  455. UserName: "SJZY_RWbid_ES",
  456. Password: "SJZY@B4i4D5e6S",
  457. Direct: true,
  458. }
  459. Mgo.InitPool()
  460. f, err := excelize.OpenFile("./20240530_民政部统计数据.xlsx")
  461. if err != nil {
  462. fmt.Println(err)
  463. return
  464. }
  465. defer func() {
  466. if err := f.Close(); err != nil {
  467. fmt.Println(err)
  468. }
  469. }()
  470. rows, err := f.GetRows("2023")
  471. if err != nil {
  472. fmt.Println(err)
  473. return
  474. }
  475. for i := 1; i < len(rows); i++ {
  476. data := map[string]interface{}{}
  477. if rows[i][0] == "省份" {
  478. data["level"] = 1
  479. } else if rows[i][0] == "城市" {
  480. data["level"] = 2
  481. } else {
  482. data["level"] = 3
  483. }
  484. log.Println(rows[i][1])
  485. parts := strings.Split(rows[i][1], "(")
  486. data["province"] = parts[0]
  487. data["province_code"] = rows[i][2]
  488. if len(rows[i]) > 3 {
  489. data["city"] = rows[i][3]
  490. }
  491. if len(rows[i]) > 4 {
  492. data["city_code"] = rows[i][4]
  493. }
  494. if len(rows[i]) > 5 {
  495. data["area"] = rows[i][5]
  496. }
  497. if len(rows[i]) > 6 {
  498. data["area_code"] = rows[i][6]
  499. }
  500. Mgo.Save("wcc_area_minzhengbu", data)
  501. }
  502. }
  503. // TestArea2 中国行政区划数据-统计局
  504. func TestArea2(t *testing.T) {
  505. Mgo := &mongodb.MongodbSim{
  506. //MongodbAddr: "172.17.189.140:27080",
  507. MongodbAddr: "127.0.0.1:27083",
  508. Size: 10,
  509. DbName: "qfw",
  510. UserName: "SJZY_RWbid_ES",
  511. Password: "SJZY@B4i4D5e6S",
  512. Direct: true,
  513. }
  514. Mgo.InitPool()
  515. f, err := excelize.OpenFile("./20240530_统计局统计数据.xlsx")
  516. if err != nil {
  517. fmt.Println(err)
  518. return
  519. }
  520. defer func() {
  521. if err := f.Close(); err != nil {
  522. fmt.Println(err)
  523. }
  524. }()
  525. rows, err := f.GetRows("2023")
  526. if err != nil {
  527. fmt.Println(err)
  528. return
  529. }
  530. for i := 1; i < len(rows); i++ {
  531. data := map[string]interface{}{}
  532. data["level"] = rows[i][0]
  533. log.Println(rows[i][1], rows[3])
  534. data["province"] = rows[i][1]
  535. data["province_code"] = rows[i][2]
  536. if len(rows[i]) > 3 {
  537. data["city"] = rows[i][3]
  538. }
  539. if len(rows[i]) > 4 {
  540. data["city_code"] = rows[i][4]
  541. }
  542. if len(rows[i]) > 5 {
  543. data["area"] = rows[i][5]
  544. }
  545. if len(rows[i]) > 6 {
  546. data["area_code"] = rows[i][6]
  547. }
  548. Mgo.Save("wcc_area_tongjiju", data)
  549. }
  550. }
  551. func TestHN(t *testing.T) {
  552. Mgo := &mongodb.MongodbSim{
  553. //MongodbAddr: "172.17.189.140:27080",
  554. MongodbAddr: "127.0.0.1:27083",
  555. Size: 10,
  556. DbName: "qfw",
  557. UserName: "SJZY_RWbid_ES",
  558. Password: "SJZY@B4i4D5e6S",
  559. Direct: true,
  560. }
  561. Mgo.InitPool()
  562. //181
  563. Mgo2 := &mongodb.MongodbSim{
  564. //MongodbAddr: "172.17.4.181:27001",
  565. MongodbAddr: "127.0.0.1:27001",
  566. DbName: "mixdata",
  567. Size: 10,
  568. UserName: "",
  569. Password: "",
  570. Direct: true,
  571. }
  572. Mgo2.InitPool()
  573. f, err := excelize.OpenFile("./河南单位.xlsx")
  574. if err != nil {
  575. fmt.Println(err)
  576. return
  577. }
  578. defer func() {
  579. if err := f.Close(); err != nil {
  580. fmt.Println(err)
  581. }
  582. }()
  583. sheet := "单位"
  584. rows, err := f.GetRows(sheet)
  585. if err != nil {
  586. fmt.Println(err)
  587. return
  588. }
  589. for i := 1; i < len(rows); i++ {
  590. name := rows[i][0]
  591. log.Println(i, "----", name)
  592. //res, _ := Mgo2.FindOne("special_enterprise", map[string]interface{}{"company_name": name})
  593. //if res != nil && len(*res) > 0 {
  594. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "E", i+1), "special_enterprise")
  595. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), (*res)["company_status"])
  596. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "G", i+1), (*res)["company_type"])
  597. //} else {
  598. // ra, _ := Mgo2.FindOne("special_gov_unit", map[string]interface{}{"company_name": name})
  599. // if ra != nil && len(*ra) > 0 {
  600. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "E", i+1), "special_gov_unit")
  601. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "G", i+1), (*ra)["company_type"])
  602. // if util.ObjToString((*ra)["company_status"]) != "" {
  603. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), (*ra)["company_status"])
  604. // } else {
  605. // if util.IntAll((*ra)["use_flag"]) < 5 {
  606. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), "正常")
  607. // } else {
  608. // f.SetCellValue(sheet, fmt.Sprintf("%s%d", "F", i+1), "废弃")
  609. // }
  610. // }
  611. // }
  612. //}
  613. //
  614. data := map[string]interface{}{
  615. "detail": name,
  616. }
  617. res := getAreaInfo(data)
  618. if res != nil {
  619. city := res["city"]
  620. district := res["district"]
  621. f.SetCellValue("单位", fmt.Sprintf("%s%d", "B", i+1), city)
  622. f.SetCellValue("单位", fmt.Sprintf("%s%d", "C", i+1), district)
  623. }
  624. }
  625. f.Save()
  626. log.Println("结束")
  627. }
  628. // TestExportBidding 导出bidding数据
  629. func TestExportBidding(t *testing.T) {
  630. Mgo := &mongodb.MongodbSim{
  631. //MongodbAddr: "172.17.189.140:27080",
  632. MongodbAddr: "127.0.0.1:27083",
  633. Size: 10,
  634. DbName: "qfw",
  635. UserName: "SJZY_RWbid_ES",
  636. Password: "SJZY@B4i4D5e6S",
  637. Direct: true,
  638. }
  639. Mgo.InitPool()
  640. sess := Mgo.GetMgoConn()
  641. defer Mgo.DestoryMongoConn(sess)
  642. //start, _ := time.Parse("2006-01-02 15:04:05", "2023-09-06 21:00:00")
  643. //end, _ := time.Parse("2006-01-02 15:04:05", "2023-09-07 09:00:00")
  644. //////
  645. //q := map[string]interface{}{
  646. // "publish": map[string]interface{}{
  647. // "$gte": 1701360000,
  648. // "$lte": 1706716800,
  649. // },
  650. // //"modifyinfo.toptype": map[string]interface{}{
  651. // // "$exists": 1,
  652. // //},
  653. // "toptype": "拟建",
  654. // //"title": map[string]interface{}{
  655. // // "$regex": "充电",
  656. // //},
  657. //}
  658. q := map[string]interface{}{
  659. "s_classid": "57a189cbd368081d70e185cf",
  660. "s_name": map[string]interface{}{
  661. "$in": []string{"废标", "流标", "结果变更", "中标", "成交", "中选", "其它"},
  662. },
  663. }
  664. query := sess.DB("qfw").C("rc_rule").Find(q).Select(nil).Iter()
  665. count := 0
  666. file := time.Now().Format("20060102") + "导出数据.xlsx"
  667. currentPwd, _ := os.Getwd()
  668. exportFile := fmt.Sprintf("%s/%s", currentPwd, file)
  669. xlsx := excelize.NewFile(excelize.Options{ShortDatePattern: "yyyy/m/dd"})
  670. styleOne, _ := xlsx.NewStyle(
  671. &excelize.Style{
  672. Alignment: &excelize.Alignment{
  673. Horizontal: "left",
  674. Vertical: "left",
  675. },
  676. },
  677. )
  678. line := 0
  679. sheet := "Sheet1"
  680. subtitles := []string{"s_name", "s_rule"}
  681. //subtitles := []string{"bidding_id", "title", "detail", "href", "jyhref", "toptype", "new_toptype", "new_subtype"}
  682. line++
  683. //设置第一行title
  684. _ = xlsx.SetSheetRow(sheet, fmt.Sprintf("%s%d", "A", line), &subtitles)
  685. for tmp := make(map[string]interface{}); query.Next(tmp); count++ {
  686. if count%1000 == 0 {
  687. log.Println("current --- ", count)
  688. }
  689. //company_phone := util.ObjToString(tmp["company_phone"])
  690. //if len(company_phone) != 11 {
  691. // continue
  692. //}
  693. //if !validateMobileNumber(company_phone) {
  694. // continue
  695. //}
  696. //if util.ObjToString(tmp["employee_name"]) == "" {
  697. // continue
  698. //}
  699. //id := mongodb.BsonIdToSId(tmp["_id"])
  700. line++
  701. val := []interface{}{}
  702. for _, v := range subtitles {
  703. if v == "employee_name" {
  704. val = append(val, strings.Split(util.ObjToString(tmp["employee_name"]), ",")[0])
  705. } else {
  706. val = append(val, tmp[v])
  707. }
  708. }
  709. err := xlsx.SetSheetRow(sheet, fmt.Sprintf("%s%d", "A", line), &val)
  710. if err != nil {
  711. log.Println(err)
  712. return
  713. }
  714. _ = xlsx.SetCellStyle(sheet, fmt.Sprintf("%s%d", "A", line), "BA"+strconv.Itoa(line), styleOne)
  715. tmp = make(map[string]interface{})
  716. }
  717. xlsx.Path = exportFile
  718. xlsx.Save()
  719. log.Println("dealTmp over ", count)
  720. }
  721. // TestZXZ 专项债数据
  722. //func TestZXZ(t *testing.T) {
  723. // //87 竞品
  724. // Mgo := &mongodb.MongodbSim{
  725. // //MongodbAddr: "172.17.4.87:27080",
  726. // MongodbAddr: "127.0.0.1:27081",
  727. // Size: 10,
  728. // DbName: "py_theme",
  729. // UserName: "",
  730. // Password: "",
  731. // Direct: true,
  732. // }
  733. // Mgo.InitPool()
  734. // sess := Mgo.GetMgoConn()
  735. // defer Mgo.DestoryMongoConn(sess)
  736. //
  737. // //1.项目列表,查询条件
  738. // //where := map[string]interface{}{
  739. // // "regionName": "安徽", //地区
  740. // // "issueDate": map[string]interface{}{
  741. // // "issueDate": map[string]interface{}{
  742. // // "$gt": "2024",
  743. // // },
  744. // // },
  745. // //}
  746. //
  747. // //tables := []string{"specialbond_list", "specialbond_list_202406", "specialbond_list_202407", "specialbond_list_202408"}
  748. //
  749. // //for _, table := range tables {
  750. // // datas, _ := Mgo.Find(table, where, nil, nil, false, -1, -1)
  751. // //
  752. // //}
  753. //
  754. // f, err := excelize.OpenFile("./anhui-06.xlsx")
  755. // if err != nil {
  756. // fmt.Println(err)
  757. // return
  758. // }
  759. // defer func() {
  760. // f.Save()
  761. // if err := f.Close(); err != nil {
  762. // fmt.Println(err)
  763. // }
  764. // }()
  765. //
  766. // //2.专项债详情
  767. // rows, err := f.GetRows("项目列表")
  768. // if err != nil {
  769. // fmt.Println(err)
  770. // return
  771. // }
  772. //
  773. // keys := []string{"projectName", "totalInvestment", "regionName", "cityName", "countyName", "capital", "applyDebt", "portfolioFinancing", "specialDebtAsCapital",
  774. // "expectedReturn", "projectCost", "projectTypeName3", "projectSubject", "startDate", "endDate", "operationStartDate",
  775. // "operationEndDate", "sourceIncome", "constructionContent", "remarks", "portfolioFinancingSource", "costIncomePercent", "coverageMultiple", "implementingAgency",
  776. // "accountingFirm", "lawFirm", "createTime", "updateTime"}
  777. // titles := []string{"项目名称", "总投资(万元)", "省份", "地市", "区县", "不含专项债资本金(万元)", "申请专项债总额(万元)", "其他债务融资(万元)", "专项债作资本金(万元)", "预期收入(万元)", "成本",
  778. // "项目领域", "项目业主", "建设期开始", "建设期结束", "运营期开始", "运营期结束", "收入来源", "建设内容", "特殊情况备注", "其他债务融资来源", "成本/收入(%)", "覆盖倍数", "主管部门", "会计所", "律所", "入库时间", "更新时间"}
  779. //
  780. // keys2 := []string{"bondName", "bondShortName", "bondNo", "regionName", "bondType1Name", "bondType2Name", "projectType1Name", "totalAmount", "issueDate", "issuePlaceName", "issueTerm", "issueInterestRate", "issuePhase", "payInterestMethodName",
  781. // "newBondAmount", "counterBondAmount", "refinancingBondAmount", "redemptionMethod", "valueDate", "expiryDate", "payInterestDate", "latelyPayInterestDate", "lastPayInterest", "cumulativePayInterest"}
  782. //
  783. // titles2 := []string{"项目名称", "债券名称", "债券简称", "债券编码", "省份", "债券性质", "债券类型", "官方项目类型", "发行金额(万元)", "发行日期", "发行场所", "发行期限(年)", "发行利率(%)", "发行期数", "付息方式", "新增债券(亿元)", "置换债券(亿元)", "再融资债券(亿元)", "赎回方式",
  784. // "起息日", "到息日", "付息日", "最近付息日", "上期已付息(亿元)", "累计付息(亿元)"}
  785. // line := 0
  786. // line++
  787. // f.NewSheet("项目详情")
  788. // f.NewSheet("债券详情")
  789. // bondLine := 0
  790. // //设置第一行title
  791. // _ = f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &titles)
  792. // _ = f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &titles2)
  793. // //
  794. // for i := 1; i < len(rows); i++ {
  795. // projectName := rows[i][0]
  796. // //projectName := "新建南通至宁波高速铁路(海盐段)"
  797. // log.Println(projectName)
  798. // line++
  799. // where := map[string]interface{}{
  800. // "project.jcxx.projectName": projectName,
  801. // }
  802. // detail, _ := Mgo.FindOne("specialbond_detail_202406", where)
  803. // if len(*detail) == 0 {
  804. // continue
  805. // }
  806. // insert := make([]interface{}, 0)
  807. // if project, ok := (*detail)["project"].(map[string]interface{}); ok {
  808. // if jcxx, ok := project["jcxx"].(map[string]interface{}); ok {
  809. // for _, v := range keys {
  810. // insert = append(insert, jcxx[v])
  811. // }
  812. // }
  813. // }
  814. //
  815. // err := f.SetSheetRow("项目详情", fmt.Sprintf("%s%d", "A", line), &insert)
  816. // if err != nil {
  817. // log.Println(err)
  818. // return
  819. // }
  820. //
  821. // // 债券基本信息
  822. // if bonds, ok := (*detail)["bond"].([]interface{}); ok {
  823. // for _, bond := range bonds {
  824. // if bondData, ok := bond.(map[string]interface{}); ok {
  825. // if jcxx, ok := bondData["jbxx"].(map[string]interface{}); ok {
  826. // //if strings.Contains(util.ObjToString(jcxx["bondName"]), "2024") {
  827. // bondInsert := make([]interface{}, 0)
  828. // bondInsert = append(bondInsert, projectName)
  829. // for _, v := range keys2 {
  830. // bondInsert = append(bondInsert, jcxx[v])
  831. // }
  832. // bondLine++
  833. // f.SetSheetRow("债券详情", fmt.Sprintf("%s%d", "A", line), &bondInsert)
  834. // }
  835. // }
  836. // }
  837. // }
  838. // }
  839. //}
  840. // TestLianTong 7月非运营商中标数据比对缺失数据 -- 闫天磊
  841. func TestLianTong(t *testing.T) {
  842. f, err := excelize.OpenFile("./7月非运营商中标数据比对缺失数据V1.xlsx")
  843. if err != nil {
  844. fmt.Println(err)
  845. return
  846. }
  847. defer func() {
  848. f.Save()
  849. if err := f.Close(); err != nil {
  850. fmt.Println(err)
  851. }
  852. }()
  853. //2.专项债详情
  854. rows, err := f.GetRows("基础数据")
  855. if err != nil {
  856. fmt.Println(err)
  857. return
  858. }
  859. // 86 mongo
  860. Mgo := &mongodb.MongodbSim{
  861. //MongodbAddr: "172.17.4.86:27080",
  862. MongodbAddr: "127.0.0.1:27082",
  863. Size: 10,
  864. DbName: "jyqyfw",
  865. UserName: "SJZY_RWbid_ES",
  866. Password: "SJZY@B4i4D5e6S",
  867. Direct: true,
  868. }
  869. Mgo.InitPool()
  870. //url := "http://172.17.4.184:19908"
  871. url := "http://127.0.0.1:19908"
  872. username := "jybid"
  873. password := "Top2023_JEB01i@31"
  874. index := "bidding" //索引名称
  875. // 创建 Elasticsearch 客户端
  876. client, err := elastic.NewClient(
  877. elastic.SetURL(url),
  878. elastic.SetBasicAuth(username, password),
  879. elastic.SetSniff(false),
  880. )
  881. if err != nil {
  882. log.Fatalf("创建 Elasticsearch 客户端失败:%s", err)
  883. }
  884. for i := 2; i < len(rows); i++ {
  885. area := rows[i][1]
  886. title := rows[i][2]
  887. buyer := rows[i][4]
  888. timeStr := rows[i][3]
  889. layout := "2006/01/02"
  890. t, err := time.Parse(layout, timeStr)
  891. if err != nil {
  892. fmt.Println(err)
  893. return
  894. }
  895. timestamp := t.Unix()
  896. if i%10 == 0 {
  897. log.Println("i", i, title)
  898. f.Save()
  899. }
  900. query := elastic.NewBoolQuery().
  901. Must(elastic.NewBoolQuery().Should(elastic.NewMatchQuery("title", title), elastic.NewMatchQuery("projectname", title))).
  902. //Must(elastic.NewTermQuery("title", title)).
  903. Must(elastic.NewTermQuery("area", area)).
  904. Must(elastic.NewTermQuery("buyer", buyer))
  905. // 执行查询
  906. searchResult, err := client.Search().
  907. Index(index).
  908. Query(query).
  909. Do(context.Background())
  910. if err != nil {
  911. log.Fatalf("Error executing search: %s", err)
  912. }
  913. if searchResult.TotalHits() > 0 {
  914. hit := searchResult.Hits.Hits[0]
  915. var doc map[string]interface{}
  916. err := json.Unmarshal(hit.Source, &doc)
  917. if err != nil {
  918. log.Printf("解析文档失败:%s", err)
  919. continue
  920. }
  921. publishTile := util.Int64All(doc["publishtime"])
  922. if publishTile < timestamp+3*24*3600 && publishTile > timestamp-3*24*3600 {
  923. id := util.ObjToString(doc["id"])
  924. jyurl := GetJyURLByID(id)
  925. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "L", i+1), jyurl)
  926. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "M", i+1), id)
  927. where2 := map[string]interface{}{
  928. "id": id,
  929. "appid": "jyGQ1XQQsEAwNeSENOFR9D",
  930. }
  931. da, _ := Mgo.FindOne("usermail", where2)
  932. if len(*da) > 0 {
  933. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "J", i+1), "是")
  934. } else {
  935. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "J", i+1), "否")
  936. }
  937. } else {
  938. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "I", i+1), "否")
  939. }
  940. //for _, hit := range searchResult.Hits.Hits {
  941. //
  942. //}
  943. } else {
  944. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "I", i+1), "否")
  945. }
  946. f.Save()
  947. }
  948. log.Println("数据处理完毕")
  949. }
  950. func TestTaskFuc2(t *testing.T) {
  951. matchArr := make([]TagMatching, 0)
  952. //军队类
  953. jundui := "智慧,管护,办公,服务,维护,运维,代维,维保,改造,管理,监管,监控,安全,集成,开发,建设,疫情防控,公益诉讼,社会治理,市域治理,基层治理,警务调度,信访联防,陆军,空军,战支,联勤保障,军民融合,融通军产,军分区武装部,某部,营区安防,公安,交警,交通警察,出入境,边防,特勤,检察,法院,司法,政法,看守所,监狱,退役,双拥,优抚,军转干部,民政,养老,公共交通,交通,驾驶,驾校,运输,供应链,物流,机场,航空,港,公交,信息,数字,后勤管理,示教,远程,医共体,健康管理,人力资源,社会保障,现代农业产业园,医疗保障,畜牧一体化,工会,体育,税务,财政,煤田,纪委,红十字会,海关,统战,老干部,组织,科学技术厅,广播电视台,广播电视局,新华通讯社,长城新媒体集团,日报,宣传部,人民代表大会,科学技术协会,广电信息网络集团股份有限公司,智库,科学,统计局,审计局,省委办公厅,溯源,干部人事,健身,场馆,赛事,红十字,纪检委,红会,电子口岸,血站,港口,科技局,科学技术局,广电,新闻网,报社,媒体,报业,新闻,人大,科协,社会科学,社科,金审,人口,电子商务,市委办公室,追溯,档案,人居环境治理,技术升级,技术改造,应急指挥,景区,门票,分销,定位,全景,旅游,车载,车辆,信息安全,在线课程,布线,升级,改造,扩容,传输,入户,校园,政务,支付,财务,教育,财政,通信,通讯,视频,语音,数据,互联网,商务,小微,APN,因特网,IP,MSTP,VPDN,光纤,无线,GPRS,WiFi,扶贫,检察院,法院,公安,司法,政务,监测,政协,金税,履职,政务服务,放管服,公共资源,行政服务,行政审批,社会信用体系,效能监督,热线,政务数据,电视台,广播,传媒,杂志社,科学技术,科技园区,开发区管理委员,管委会,科技馆,科技创新,高新区发展,科技成果,影业,科技大厦,情报,科学器材,自然科学,科技信息和档案,科技金融,科学技术传播,青少年科技,企业创新促进,创新战略,普及推广,工作者,新华社,通讯社,舆论,智能化,门禁"
  954. tagJ1 := TagMatching{
  955. tagName: "第一类",
  956. tagCode: "001",
  957. matchField: []string{"title"},
  958. matchKey: jundui,
  959. matchKeyReg: GetRegex(jundui),
  960. addField: []string{"title"},
  961. addKey: "平台,系统,软件,网络,云,通讯",
  962. addKeyReg: GetRegex("平台,系统,软件,网络,云,通讯"),
  963. excludeField: []string{"title"},
  964. excludeKey: "超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,网上超市采购,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,雨污,保洁服务,物业服务,服装采购,中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取",
  965. excludeKeyReg: GetRegex("超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,网上超市采购,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,雨污,保洁服务,物业服务,服装采购,中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"),
  966. }
  967. matchArr = append(matchArr, tagJ1)
  968. 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,无线通信,检务通,云视频,可视一张网,智慧派出所,等级保护,智能扫码刷脸测温,智能测温,基层测温,智慧检务,智慧,医院信息化建设,智能信息化,机房运维,平安社区,四级网,智能接处警,智慧云,监控工程建设,安全监测设施,通信管道,数字城管,指挥调度系统,监控设备,智慧平安乡村,信息网建设,智能监控,网络建设,智慧教育,电教室,扫码测温,智能感知,长效管护平台,数字中心,智慧环卫,人脸识别,交通感知,移动办公,益农信息社,链路连接,人脸抓拍,电话系统,农村厕所管护,警务终端,城市综合管理,平安城市,弱电&&智能化,门禁,视频传输,安全防护体系,智能化,网络&&平台,卫星通信,卫星通讯,公网基站,通信&&基站,通讯&&基站,互联网&&接入,互联网&&服务,通信线路,通信&&服务,弱电&&系统"
  969. ex2 := "超声,输煤系统,采样及制样系统,装车系统,机电系统,MW,机组,放射,转炉,工程造价,纲要设计,脱水系统,翻车机,订单,医疗设备,肺结节,商务楼施工,破碎系统,油库系统,审计服务,空调系统,灭火系统,新订单,垃圾处理系统,生产机房,电除尘高频电源设备,冲击地压,微信平台,发酵集成,液压润滑系统,#,杂志采购,制氧系统,除臭系统,编制,kV,电气线路,铁路线路,渗沥液,高压细水雾灭火系统,场地授权,土建工程,生物,医疗器械,医贸,医疗设备,承德世纪兴宇建筑工程有限公司,天津国能华北电力技术工程有限公司,机电设备,建筑安装,工程咨询,空调工程,电力安装,X射线,药敏分析系统,热送调度系统,射频手术系统,肾镜系统,注射系统,胃肠系统,质谱仪筛查系统,勘察,手术系统,反洗钱系统,发电机,高低压系统,排水系统,升降平台,污水系统,供销社建设,消防系统,通风系统,人体生理实验系统,试验系统,污泥系统,主机热控系统,供水系统,电路整修,安装工程有限公司,劳务有限公司,除尘系统,装修工程,用地预审,运输自动化控制系统,化学水工系统,故障自动诊断系统,手术导航系统,灰硝硫系统,液压系统,脱硫系统,光纤打标机,制粉系统,净化系统,车辆租赁,空压机系统,校准系统,设计标段,取水系统,装饰工程,宣传视频制作,分析服务,铁路专线,制冷系统,点火系统,水处理系统,火检光纤,遥感资料,燃料系统,供电系统,供热系统,土建,新风系统,传输系统,火灾报警系统,液压及水系统,加油服务,空调采购,电气系统,物流传输系统,原煤筛分系统,汽车冲洗平台,长沙高新技术产业开发区管理委员会,防水工程,热水系统,综合管网工程,电路板,生活水系统,网线采购,电源线采购,配电系统,自动报警系统,温室气体连续监测系统,制水系统,热泵系统,热力管道,道路维修,管网改造,脱硝系统,AGC系统,公交专线,物业服务,废水系统,电伴热系统,上料系统,电务系统,控制系统,电路改造,手术麻醉管理系统,造价咨询,建筑修缮,课程,设计咨询,雨污分流系统,中央空调机房,印刷系统,天然气管网,DCS,赛事安全评估,轨道电路,制造平台,供暖系统,皮带系统,血流动力学监测,中继泵站,光伏发电,工程初步设计,照明系统,电力专线,水冷系统,散热系统,重症监护系统,管道专线,气体检测系统,采暖系统,激光测振系统,租用办公场所,焊接系统,无创定量诊断系统,风机房,手术管理系统,磁共振机房,洗车平台,隧道工程,电力接入系统,物业管理服务,网上超市采购,外墙粉刷,尾砂运输供给系统,换热机房,垂钓平台,可行性研究,地面系统,空气质量检测平台,车辆维保,卸料平台,直饮水系统,煤系统,余热利用系统,劳务分包,火气系统,排风系统,装修施工,办公桌椅采购,天翼云科技,载具采购,钢板机房,腔镜系统,吹灰系统,激光扫描系统,空调,冷却水,打印机,排潮系统,排烟系统,蒸汽系统,润滑系统,烧结系统,加热系统,粉刷,磐石公司,工程施工,内墙维修,除雾器系统,自流平,宣传服务,渣处理系统,雨水系统,主题宣传,天翼云科技河北分公司,车辆定点,装修,劳动技术服务,真空系统,施工,施工图设计,造影系统,制冷机房,GW,心脏,检修平台,冷水系统,消防改造,供热专线,专栏,给水系统,警服,被装,灭火剂,保洁服务,物业服务,服装采购中国移动,中移在线,中移系统,铁通,中国联通,联合网络通信,联通系统集成,中国电信,天翼视讯,天翼电信,天翼云,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  970. tagJ2 := TagMatching{
  971. tagName: "第2类",
  972. tagCode: "002",
  973. matchField: []string{"title"},
  974. matchKey: key2,
  975. matchKeyReg: GetRegex(key2),
  976. excludeField: []string{"title"},
  977. excludeKey: ex2,
  978. excludeKeyReg: GetRegex(ex2),
  979. }
  980. matchArr = append(matchArr, tagJ2)
  981. key3 := "智算云,智算中台,数字孪生平台,物联网平台,城市大脑,智慧停车,智慧灯杆,智慧社区,智慧养老,智慧小区,智慧物业,智慧乡村,智慧农业,智慧党建,数字乡村,智慧城市,数智城市,智治城市,数字驾驶舱,新型智慧城市,数据基础底座,智能视觉平台,云网资源接入,数字城市,数智城市,数字底座,超级大脑,城市大脑,全息路网,全息路口,智慧水务,智慧应急,智能装备,智慧城管,应急指挥系统,智慧消防,一网统管,数字政府,城市超脑,防欺凌&&报警,防欺凌&&预警,防欺凌&&终端,防欺凌&&AI,人工智能智算,算力卡,云智算,定制开发&&系统集成"
  982. ex3 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  983. tagJ3 := TagMatching{
  984. tagName: "第3类",
  985. tagCode: "003",
  986. matchField: []string{"title"},
  987. matchKey: key3,
  988. matchKeyReg: GetRegex(key3),
  989. excludeField: []string{"title"},
  990. excludeKey: ex3,
  991. excludeKeyReg: GetRegex(ex3),
  992. }
  993. matchArr = append(matchArr, tagJ3)
  994. 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,创新应用中心,基层防灾,精准分析,算力,防欺凌,人工智能,集群"
  995. ex4 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  996. tagJ4 := TagMatching{
  997. tagName: "第4类",
  998. tagCode: "004",
  999. matchField: []string{"title"},
  1000. matchKey: key4,
  1001. matchKeyReg: GetRegex(key4),
  1002. excludeField: []string{"title"},
  1003. excludeKey: ex4,
  1004. excludeKeyReg: GetRegex(ex4),
  1005. }
  1006. matchArr = append(matchArr, tagJ4)
  1007. key5 := "专网,网络,链路,线路,互联网,宽带,带宽,链路"
  1008. add5 := "租用,租赁,服务,接入"
  1009. ex5 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  1010. tagJ5 := TagMatching{
  1011. tagName: "第5类",
  1012. tagCode: "005",
  1013. matchField: []string{"title"},
  1014. matchKey: key5,
  1015. matchKeyReg: GetRegex(key5),
  1016. addField: []string{"title"},
  1017. addKey: add5,
  1018. addKeyReg: GetRegex(add5),
  1019. excludeField: []string{"title"},
  1020. excludeKey: ex5,
  1021. excludeKeyReg: GetRegex(ex5),
  1022. }
  1023. matchArr = append(matchArr, tagJ5)
  1024. key6 := "社会治理信息化,综合指挥调度系统,视频图像交换系统,智能巡护终端,大数据智能监管平台,灌溉&&一张网,水肥一体化,农田信息化工程,耕地质量监测,农田生产&&监测,农田科技&&监测,农作物良种对比试验站,森林资源视频监控,自然保护区&&智慧化,城市生命线,城市运管服,城市运行管理服务,城市运行监测,城市管理监督评价指标体系,城市灾害预警,预警指挥平台,物联感知支撑平台,地理信息支撑系统,溯源体系软件平台建设,AI声音安防卫士,智能音频分析,智能音频检测,防欺凌AI音频报警,智能语音警报设备,农田&&信息化,农田信息工程,农田&&监测,高标准农田&&智能化,高标准农田&&图斑,高标准农田&&灌溉,高标准农田&&大数据,高标准&&农田监测,农田监测系统,高标准农田&&信息化监测,算力"
  1025. ex6 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取,起重机,材料,审计,编制服务,报告编制,会务服务"
  1026. tagJ6 := TagMatching{
  1027. tagName: "第6类",
  1028. tagCode: "006",
  1029. matchField: []string{"title"},
  1030. matchKey: key6,
  1031. matchKeyReg: GetRegex(key6),
  1032. excludeField: []string{"title"},
  1033. excludeKey: ex6,
  1034. excludeKeyReg: GetRegex(ex6),
  1035. }
  1036. matchArr = append(matchArr, tagJ6)
  1037. key7 := "综合服务能力,监控,水库,灌区,风险"
  1038. add7 := "提升,升级,改造,建设,信息化,雨水情,监测设施,监测预警,防控,预警,预防"
  1039. ex7 := "监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  1040. tagJ7 := TagMatching{
  1041. tagName: "第7类",
  1042. tagCode: "007",
  1043. matchField: []string{"title"},
  1044. matchKey: key7,
  1045. matchKeyReg: GetRegex(key7),
  1046. addField: []string{"title"},
  1047. addKey: add7,
  1048. addKeyReg: GetRegex(add7),
  1049. excludeField: []string{"title"},
  1050. excludeKey: ex7,
  1051. excludeKeyReg: GetRegex(ex7),
  1052. }
  1053. matchArr = append(matchArr, tagJ7)
  1054. key8 := "火灾&&报警,医院&&达标,医养&&设备,医养综合体,考点&&改造,养老&&设施,养老&&设备,密评,网络&&提升,长距离对讲,防统方,机顶盒,污染&&基站,乐业小站,城市&&生命线,全息投影,电子签,远程医学,掌上医院,算力集群,算力平台,量子计算平台,算力&&建设,算力服务,专属云,智算&&云,组网,园区&&安防,一网统管,全息感知,全域感知,智慧热力,危化品监管,综合管廊,数字孪生,城市风险,城市&&平台建设,智慧&&路灯,智能&&路灯,智慧&&灯杆,智能&&灯杆,监控杆,智慧&&灯塔,多功能路灯,数字&&路灯,数字&&灯杆,多杆合一,预警&&能力,应急&&能力提升,预警&&指挥,预警&&提升,火险&&监测,火情&&监测,视频&&指挥&&调度,无人机&&平台,航空应急,网络&&感知,融合调度,河长制,AI音频,声纹识别,AI预警,智能语音,警报设备,安防卫士,校园&&安防,AI报警,声纹,警务综合,警综,签名捺印,电子签,案管,涉案语音处理,警情分析,执法助手,执法办案,生态&&监测站,环境&&监测站,油烟&&监测,感烟报警,烟感报警,大模型,数据模型,普查&&PDA,普查&&PAD,智慧农业,旱作节水,雨水情,无人农场,溯源体系,数字茶园,数字农田,智慧灌区,水旱灾害防御,农田&&信息化,农田信息工程,农田&&监测,高标准农田&&智能化,高标准农田&&图斑,高标准农田&&灌溉,耕地质量评估,土壤&&检测,高标准农田&&大数据,智慧农业,土肥监测,耕地核实入库,高标准&&农田监测,农田监测系统,高标准农田&&信息化监测,互联网&&安全,互联网&&设备,卡口测速,云教室,天空地&&一体,四情&&监测,基层&&医疗&&体系,基层&&卫生&&系统,基层&&医疗&&系统,电子班牌,监控&&补点,监控&&补盲,考点&&升级,风险管控&&平台,耕地&&预警,公立医院改革,医院&&高质量发展,窨井&&整治,物联网&&设备,自动监测站,物联&&感知,诊疗平台,中心平台软件,环境监测,4G图传,医院告知软件,作战系统,电子报规,监控&&系统,智慧化,政务&&网络,移动端&&服务,固网&&服务,金保,便民&&热线,服务&&热线,视联网,视频&&联网"
  1055. ex8 := "家具,监理服务,监理&&中选,监理项目,项目监理,工程监理,预算编制,代理机构&&遴选,代理机构&&选取"
  1056. tagJ8 := TagMatching{
  1057. tagName: "第8类",
  1058. tagCode: "008",
  1059. matchField: []string{"title"},
  1060. matchKey: key8,
  1061. matchKeyReg: GetRegex(key8),
  1062. excludeField: []string{"title"},
  1063. excludeKey: ex8,
  1064. excludeKeyReg: GetRegex(ex8),
  1065. }
  1066. matchArr = append(matchArr, tagJ8)
  1067. f, err := excelize.OpenFile("./7月非运营商中标数据比对缺失数据V1.xlsx")
  1068. if err != nil {
  1069. fmt.Println(err)
  1070. return
  1071. }
  1072. defer func() {
  1073. f.Save()
  1074. if err := f.Close(); err != nil {
  1075. fmt.Println(err)
  1076. }
  1077. }()
  1078. //2.专项债详情
  1079. rows, err := f.GetRows("基础数据")
  1080. if err != nil {
  1081. fmt.Println(err)
  1082. return
  1083. }
  1084. for i := 2; i < len(rows); i++ {
  1085. title := rows[i][2]
  1086. tmp := map[string]interface{}{
  1087. "title": title,
  1088. }
  1089. _, match, _, ex := TaskTags(tmp, matchArr)
  1090. if match == "" {
  1091. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "1")
  1092. }
  1093. if match != "" && ex != "" {
  1094. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "2")
  1095. }
  1096. if match != "" && ex == "" {
  1097. f.SetCellValue("基础数据", fmt.Sprintf("%s%d", "K", i+1), "3")
  1098. }
  1099. }
  1100. f.Save()
  1101. log.Println("数据处理完毕")
  1102. }