v0.2.0 稳定版本

Author: kirito

README.md

@@ -40,9 +40,14 @@ Telegram Bot [@btcinfo_kirito_bot](https://t.me/btcinfo_kirito_bot) 暴躁老哥
   * `whale_apikey` - rss功能需要的apikey,[WhaleAlert](https://docs.whale-alert.io/#introduction),留空为不启用
     * 启用后，要用`setup.sql`初始化mysql数据库
     * 并填写相关设置
+    * `rss` - 服务器启动时，这些频道自动订阅
   * 其余保持默认
 * 执行 `./fkbro.exe -c config.json` ,也可以不用`-c`参数,默认执行目录下`config.json`
 * [release](https://github.com/zshorz/fkbro/releases) 里已经为Linux提供了编译好的二进制文件
 
+## 关于
+* 版本号格式 `x.y.z` - `y`为偶数的是稳定版本
+* donate - `17MaxVm9Zm8WQfHrrgA2LVzuEDdSL6AZVN`
+
 
 

callback.go

@@ -157,6 +157,7 @@ func recent(update *tgbotapi.Update) {
 			break
 		}
 		arr = append(arr, b)
+		<-time.After(time.Millisecond * 100) // 间隔100毫秒
 	}
 
 	msg.Text += ParseToString("recent", arr)
@@ -357,3 +358,22 @@ func send(msg *tgbotapi.MessageConfig, duration int) {
 		LoadTemplate(util.Config.StaticPath)
 	}
 }
+
+func addRss(username string) {
+	chat, err := Bot.TgBot.GetChat(tgbotapi.ChatConfig{
+		ChatID:             0,
+		SuperGroupUsername: "@"+username,
+	})
+	if err != nil {
+		return
+	}
+	liveMapLock.Lock()
+	_, ok := liveMap[username]
+	if ok {
+		delete(liveMap, username)
+	} else {
+		liveMap[username] = chat.ID
+	}
+	liveMapLock.Unlock()
+}
+

config.json

@@ -12,5 +12,6 @@
   "db_addr": "127.0.0.1:3306",
   "db_user": "root",
   "db_passwd": "123456",
-  "db_name": "fkbro"
+  "db_name": "fkbro",
+  "rss": ["fkbrolive"]
 }

live.go

@@ -111,11 +111,13 @@ func look(currency string) { // btc usdc
 				TomAddr:   trans.To.Address,
 				TomOwner:  trans.To.Owner,
 			}
-			switch currency {
-			case "btc":
-				al.SetURL("https://www.blockchain.com/btc/tx/" + al.Hash)
-			case "usdt":
-				al.SetURL("https://www.blockchain.com/eth/tx/0x" + al.Hash)
+			switch trans.Blockchain {
+			case "bitcoin":
+				al.SetURL("https://blockchair.com/zh/bitcoin/transaction/" + al.Hash)
+			case "ethereum":
+				al.SetURL("https://blockchair.com/zh/ethereum/transaction/0x" + al.Hash)
+			case "tron":
+				al.SetURL("https://tronscan.org/#/transaction/" + al.Hash)
 			}
 			Log.Debug(trans)
 			if trans.From.Owner != trans.To.Owner{ // 双方账户不一样才处理

main.go

@@ -51,6 +51,7 @@ func main() {
 		data.Log.SetLogLevel(ezlog.LogInfo)
 		WhaleAPI.Logger.SetLogLevel(ezlog.LogInfo)
 	}
+	doConfig()
 
 	Log.Info("create bot success")
 
@@ -76,6 +77,12 @@ func main() {
 	Log.Info("good bye: api query cnt", API.QueryCnt)
 }
 
+func doConfig() {
+	for _, s := range util.Config.Rss {
+		addRss(s)
+	}
+}
+
 func doSignal() {
 	sigs := make(chan os.Signal, 1)
 	signal.Notify(sigs, syscall.SIGINT, syscall.SIGHUP)

static/address.tmp

@@ -6,7 +6,4 @@
 `余额` : `{{.GetBalance}}BTC`
 `交易次数` : `{{.Tx_count}}`
 `最后一次交易` : `{{.Last_tx}}`
-`详情` : [btc.com](https://btc.com/{{.Address}})
-
-
-
+`详情` : [blockchair](https://blockchair.com/zh/bitcoin/address/{{.Address}})

static/block.tmp

@@ -6,4 +6,4 @@
 `块大小`: `{{.Size}}B`
 `时 间 `: `{{GetPastTime .Timestamp}}`
 `块哈希`: `{{.Hash}}`
-`详情 `: [btc.com](https://btc.com/{{.Hash}})
+`详情 `: [blockchair](https://blockchair.com/zh/bitcoin/block/{{.Hash}})

static/recent.tmp

@@ -6,4 +6,4 @@
 `大小` : `{{.Size}}B`
 `收益` : `{{.GetReword}}BTC`
 {{end}}
-`详情 `: [btc.com](https://btc.com)
+`详情 `: [blockchain](https://www.blockchain.com/zh/explorer)

static/transaction.tmp

@@ -8,4 +8,4 @@
 `时间` : `{{GetPastTime .Block_time}}`
 `输入` : `{{GetBtcValueString .Inputs_value}}BTC` `从{{.Inputs_count}}个地址`
 `输出` : `{{GetBtcValueString .Outputs_value}}BTC` `到{{.Outputs_count}}个地址`
-`详情 `: [btc.com](https://btc.com/{{.Hash}})
+`详情 `: [blockchair](https://blockchair.com/zh/bitcoin/transaction/{{.Hash}})

util/globalobj.go

@@ -22,6 +22,7 @@ type GlobalObj struct {
 	DbUser 		string 	`json:"db_user"`
 	DbPasswd 	string  `json:"db_passwd"`
 	DbName		string 	`json:"db_name"`
+	Rss 		[]string `json:"rss"` // 提前订阅的用户列表，服务启动自动订阅，不加@
 }