更新 escheck

escheck/main.go

@@ -340,24 +340,43 @@ func (t *T) task() {
 			//	`<br>友云采_es统计` + strconv.Itoa(countComptet4) + `,mgo统计:` + fmt.Sprint(competeReal4) + `,差值:` + fmt.Sprint(competeReal4-countComptet4) + `,mgo总入库量` + fmt.Sprint(competCount4) +
 			//	`<br>新集群统计结果_es数量:` + strconv.Itoa(countNew) + `,mgo统计:` + fmt.Sprint(count3) + `,差值:` + fmt.Sprint(count3-countNew)
 
+			//html 格式
+			//var reportBuilder strings.Builder
+			//// 开始表格
+			//reportBuilder.WriteString("<table>")
+			//reportBuilder.WriteString(formattedTime)
+			//reportBuilder.WriteString("<tr><th>统计项</th><th>es统计</th><th>mgo统计</th><th>差值</th><th>mgo总入库量</th></tr>")
 			//
+			//addTableRow(&reportBuilder, "阿里云es集群", count, count3, count3-count, count2)
+			//addTableRow(&reportBuilder, "竟品统计结果", count1, count5, count5-count1, count4)
+			//addTableRow(&reportBuilder, "元博网", countComptet1, competeReal1, competeReal1-countComptet1, competCount1)
+			//addTableRow(&reportBuilder, "中国招标与采购网", countComptet2, competeReal2, competeReal2-countComptet2, competCount2)
+			//addTableRow(&reportBuilder, "北京隆道网络科技有限公司", countComptet3, competeReal3, competeReal3-countComptet3, competCount3)
+			//addTableRow(&reportBuilder, "友云采", countComptet4, competeReal4, competeReal4-countComptet4, competCount4)
+			//addTableRow(&reportBuilder, "标800", countComptet5, competeReal5, competeReal5-countComptet5, competCount5)
+			//addTableRow(&reportBuilder, "华为云es集群", countNew, count3, count3-countNew, count2)
+			//// 结束表格
+			//reportBuilder.WriteString("</table>")
+			//// 获取最终的报告字符串
+			//report = reportBuilder.String()
+
 			var reportBuilder strings.Builder
-			// 开始表格
-			reportBuilder.WriteString("<table>")
-			reportBuilder.WriteString(formattedTime)
-			reportBuilder.WriteString("<tr><th>统计项</th><th>es统计</th><th>mgo统计</th><th>差值</th><th>mgo总入库量</th></tr>")
-
-			addTableRow(&reportBuilder, "阿里云es集群", count, count3, count3-count, count2)
-			addTableRow(&reportBuilder, "竟品统计结果", count1, count5, count5-count1, count4)
-			addTableRow(&reportBuilder, "元博网", countComptet1, competeReal1, competeReal1-countComptet1, competCount1)
-			addTableRow(&reportBuilder, "中国招标与采购网", countComptet2, competeReal2, competeReal2-countComptet2, competCount2)
-			addTableRow(&reportBuilder, "北京隆道网络科技有限公司", countComptet3, competeReal3, competeReal3-countComptet3, competCount3)
-			addTableRow(&reportBuilder, "友云采", countComptet4, competeReal4, competeReal4-countComptet4, competCount4)
-			addTableRow(&reportBuilder, "标800", countComptet5, competeReal5, competeReal5-countComptet5, competCount5)
-			addTableRow(&reportBuilder, "华为云es集群", countNew, count3, count3-countNew, count2)
-			// 结束表格
-			reportBuilder.WriteString("</table>")
-			// 获取最终的报告字符串
+
+			// 添加时间
+			reportBuilder.WriteString(formattedTime + "\n")
+			// Markdown 表头
+			reportBuilder.WriteString("| 统计项 | es统计 | mgo统计 | 差值 | mgo总入库量 |\n")
+			reportBuilder.WriteString("|--------|--------|---------|------|--------------|\n")
+
+			addMarkdownRow(&reportBuilder, "阿里云es集群", count, count3, count3-count, count2)
+			addMarkdownRow(&reportBuilder, "竟品统计结果", count1, count5, count5-count1, count4)
+			addMarkdownRow(&reportBuilder, "元博网", countComptet1, competeReal1, competeReal1-countComptet1, competCount1)
+			addMarkdownRow(&reportBuilder, "中国招标与采购网", countComptet2, competeReal2, competeReal2-countComptet2, competCount2)
+			addMarkdownRow(&reportBuilder, "北京隆道网络科技有限公司", countComptet3, competeReal3, competeReal3-countComptet3, competCount3)
+			addMarkdownRow(&reportBuilder, "友云采", countComptet4, competeReal4, competeReal4-countComptet4, competCount4)
+			addMarkdownRow(&reportBuilder, "标800", countComptet5, competeReal5, competeReal5-countComptet5, competCount5)
+			addMarkdownRow(&reportBuilder, "华为云es集群", countNew, count3, count3-countNew, count2)
+
 			report = reportBuilder.String()
 
 			//存入数据库
@@ -423,6 +442,10 @@ func addTableRow(builder *strings.Builder, itemName string, esCount, mgoCount, d
 	builder.WriteString(fmt.Sprintf(`<tr><th>%s</th><th>%d</th><th>%d</th><th>%d</th><th>%d</th></tr>`, itemName, esCount, mgoCount, diff, mgoTotal))
 }
 
+func addMarkdownRow(builder *strings.Builder, itemName string, esCount, mgoCount, diff, mgoTotal int) {
+	builder.WriteString(fmt.Sprintf("| %s | %d | %d | %d | %d |\n", itemName, esCount, mgoCount, diff, mgoTotal))
+}
+
 // SendBot 发送企业微信
 func SendBot(webhookURL, msg string) (b bool) {
 	// 构造请求体