Reconnect.go

package main


import (
"fmt"
	"time"
	"os/exec"
	"net/http"
	"io/ioutil"
	"strings"
	"encoding/json"
	"os"
)

type Account struct {
	Username string
	Password string
	QueryString string
}


func main() {

	//fmt.Println(getCurrentPath())
	//fmt.Println("网络异常，尝试断线重连中……")
	//data, _ := ioutil.ReadFile(getCurrentPath()+"account.json")
	//account :=Account{}
	//fmt.Println(string(data))
	//errJson := json.Unmarshal(data,&account)
	//if errJson!=nil{
	//	fmt.Println("username and password marshal erro:",errJson)
	//}
	//
	////url := "http://211.87.158.84/eportal/InterFace.do?method=login"
	//fmt.Println(account.Username)

	for
	{
		time.Sleep(1000000000)
		netWorkStatus := NetWorkStatus()
		//fmt.Println(netWorkStatus)
		if netWorkStatus == true {

			continue
		}else {
			fmt.Println("网络异常，尝试断线重连中……")
			data, _ := ioutil.ReadFile(getCurrentPath()+"account.json")
			account :=Account{}
			errJson := json.Unmarshal(data,&account)
			if errJson!=nil{
				fmt.Println("username and password marshal erro:",errJson)
			}

			url := "http://211.87.158.84/eportal/InterFace.do?method=login"
			fmt.Println(account.Username,"pass:",account.Password)
			payload := strings.NewReader("userId="+account.Username+"&password="+account.Password+"&service=internet&queryString="+account.QueryString+"&operatorPwd=&operatorUserId=&validcode=&passwordEncrypt=false&undefined=")

			req, _ := http.NewRequest("POST", url, payload)

			req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
			req.Header.Add("cache-control", "no-cache")
			req.Header.Add("Postman-Token", "99f9e080-8a59-4b57-a3c1-918dfd652c88")

			res, _ := http.DefaultClient.Do(req)

			defer res.Body.Close()
			body, _ := ioutil.ReadAll(res.Body)

			fmt.Println(res)
			fmt.Println(string(body))
		}
	}

}
func getCurrentPath() string {
	s, err := exec.LookPath(os.Args[0])
	checkErr(err)
	i := strings.LastIndex(s, "\\")
	path := string(s[0 : i+1])
	return path
}

func checkErr(err error) {
	if err != nil {
		panic(err)
	}
}

func NetWorkStatus() bool {
	cmd := exec.Command("ping", "www.baidu.com" )
	fmt.Println("正在检测网络状态", time.Now().Unix())
	err := cmd.Run()
	fmt.Println("检测网络状态完成 :", time.Now().Unix())
	if err != nil {

		fmt.Println(err)
		return false
	} else {
		fmt.Println("网络状态：良好")
	}
	return true

//	cmd := exec.Command("ping", "www.baidu.com")
//	var out bytes.Buffer
//	var stderr bytes.Buffer
//	cmd.Stdout = &out
//	cmd.Stderr = &stderr
//	err := cmd.Run()
//	if err != nil {
//		fmt.Println(fmt.Sprint(err) + ": " + stderr.String())
//		return false
//	}
//	fmt.Println("Result: " + out.String())
//return true
}