Merge remote-tracking branch 'origin/master'

initialize/timer.go

@@ -139,6 +139,11 @@ func Timer() {
 	//if err != nil {
 	//	fmt.Println("add SyncJfDevicesMessage timer error:", err)
 	//}
+	//定时获取机房小绵羊新号剩余
+	_, err := global.GVA_Timer.AddTaskByFunc("SyncJfXmyNewAccount", "0 0,43 * * * *", robotService.SyncJfXmyNewAccount)
+	if err != nil {
+		fmt.Println("add SyncJfXmyNewAccount timer error:", err)
+	}
 	//
 	//// 活跃定时推送消息
 	//_, err = global.GVA_Timer.AddTaskByFunc("TaskMsgSend", "20 2/32 8-21 * * *", syncData.TaskMsgSend)

service/system/sys_robot.go

@@ -74,6 +74,38 @@ func (robotService *RobotService) SyncJfDevicesMessage() {
 	return
 }
 
+// SyncJfXmyNewAccount 定时获取机房小绵羊新号剩余
+func (robotService *RobotService) SyncJfXmyNewAccount() {
+	
+	content := ">#### **【账号提醒】预警**  (" + time.Now().Format("2006-01-02 15:04:05") + ")：\n"
+	var keyWord string
+	result, err := robotService.RequestJfXmyNewAccount()
+	if err != nil {
+		global.GVA_LOG.Error("定时获取机房小绵羊新号剩余失败！！！")
+		keyWord = "定时获取机房小绵羊新号剩余失败！！！,错误信息：" + err.Error()
+		return
+	}
+	//global.GVA_LOG.Info(string(result))
+	accountNum, err := strconv.ParseInt(string(result), 10, 64)
+	if err != nil {
+		global.GVA_LOG.Error("定时获取机房小绵羊新号剩余失败2！！！")
+		keyWord = "定时获取机房小绵羊新号剩余失败2！！！,错误信息：" + err.Error()
+		return
+	}
+	if string(result) != "null" && string(result) != "" {
+		if accountNum <= 1000 {
+			keyWord += "机房小绵羊新号不足,请及时添加,当前剩余:" + string(result) + " \n"
+			//keyWord += "机房小绵羊新号当前剩余:" + string(result) + " \n"
+		}
+	}
+	if keyWord != "" {
+		content += keyWord
+		url := global.GVA_CONFIG.SendUrl.KeyWordSendUrl
+		_, _ = robotService.PostRobotToEnterpriseWeChatByMarkdown(url, content)
+	}
+	return
+}
+
 // RequestJfDevicesState 获取机房设备信息
 func (robotService *RobotService) RequestJfDevicesState(rack int) (result []byte, err error) {
 	jfUrl := "http://182.150.53.148:6007/v1/manage/chart"
@@ -83,3 +115,11 @@ func (robotService *RobotService) RequestJfDevicesState(rack int) (result []byte
 	result, err = utils.HttpGet(jfUrl, jfParams)
 	return
 }
+
+// RequestJfXmyNewAccount 获取机房小绵羊新号剩余
+func (robotService *RobotService) RequestJfXmyNewAccount() (result []byte, err error) {
+	jfUrl := "http://xjf.lianyou.fun:8099/v1/account/get_left_smallsheep_account"
+	jfParams := map[string]string{}
+	result, err = utils.HttpGet(jfUrl, jfParams)
+	return
+}