init proj

Author: Tomtao626

.gitignore

@@ -0,0 +1 @@
+.idea/*

Makefile

@@ -0,0 +1,14 @@
+SRC = $(wildcard *.go)
+GITVISION = `git describe`"-"`git rev-parse --short HEAD`
+all:simluatedev
+simluatedev:$(SRC)
+	go build -o azuretask -x -ldflags  " -w -s -X main.BuildVersion=$(GITVISION)" $^
+arm:
+
+	GOARM=7 GOARCH=arm64 GOOS=linux go build -x -ldflags "-w -s -X main.BuildVersion=$(GITVISION)" -o simluatedev $^
+
+
+clean:
+	rm -rvf simluatedev
+
+

README.md

@@ -0,0 +1,188 @@
+package main
+
+import (
+	"fmt"
+	"log"
+	"os"
+	"runtime"
+	"time"
+)
+
+var debuglevel = 4
+
+const (
+	//FatalLevel fatalerror
+	FatalLevel = 0
+	//ErrorLevel error happen
+	ErrorLevel = 1
+	//WarnLevel just warn something wrong
+	WarnLevel = 2
+	//InfoLevel info what happen
+	InfoLevel = 3
+	//DebugLevel for debug
+	DebugLevel = 4
+)
+
+var (
+	defaultLogLevel = DebugLevel
+	errLevels       = []string{"FATAL", "ERROR", "WARN", "INFO", "DEBUG"}
+)
+
+var blog = log.New(os.Stdout, "", 0)
+var logFlag = "azuretask"
+
+func output(level string, logFlag string, format string, v ...interface{}) {
+	pc, file, line, _ := runtime.Caller(2)
+	short := file
+
+	for i := len(file) - 1; i > 0; i-- {
+		if file[i] == '/' {
+			short = file[i+1:]
+			break
+		}
+	}
+	f := runtime.FuncForPC(pc)
+	fn := f.Name()
+
+	for i := len(fn) - 1; i > 0; i-- {
+		if fn[i] == '.' {
+			fn = fn[i+1:]
+			break
+		}
+	}
+
+	if format == "" {
+		blog.Printf("%v|%v|%v|%v|%v()|%v|%v", now(), level, logFlag, short, fn, line, fmt.Sprintln(v...))
+	} else {
+		blog.Printf("%v|%v|%v|%v|%v()|%v|%v", now(), level, logFlag, short, fn, line, fmt.Sprintf(format, v...))
+	}
+
+}
+func now() string {
+	t := time.Now()
+	return fmt.Sprintf("%v-%02d-%v %02d:%02d:%02d",
+		t.Year(), t.Month(), t.Day(),
+		t.Hour(), t.Minute(), t.Second())
+}
+
+//Debug for debug lowest level
+func Debug(v ...interface{}) {
+	if debuglevel >= DebugLevel {
+		output("DEBUG", logFlag, "", v...)
+	}
+}
+
+//Debugln same as Debug
+func Debugln(v ...interface{}) {
+	if debuglevel >= DebugLevel {
+		output("DEBUG", logFlag, "", v...)
+	}
+}
+
+//Debugf same as Debug
+func Debugf(format string, v ...interface{}) {
+	if debuglevel >= DebugLevel {
+		output("DEBUG", logFlag, format, v...)
+	}
+}
+
+//Info info level
+func Info(v ...interface{}) {
+	if debuglevel >= InfoLevel {
+		output("INFO", logFlag, "", v...)
+	}
+}
+
+//Infof info level
+func Infof(format string, v ...interface{}) {
+	if debuglevel >= InfoLevel {
+		output("INFO", logFlag, format, v...)
+	}
+}
+
+//Warning warning level
+func Warning(v ...interface{}) {
+	if debuglevel >= WarnLevel {
+		output("WARN", logFlag, "", v...)
+	}
+}
+
+//Warningln warning level
+func Warningln(v ...interface{}) {
+	if debuglevel >= WarnLevel {
+		output("WARN", logFlag, "", v...)
+	}
+}
+
+//Warningf warning level
+func Warningf(format string, v ...interface{}) {
+	if debuglevel >= WarnLevel {
+		output("WARN", logFlag, format, v...)
+	}
+}
+
+//Error error level
+func Error(v ...interface{}) {
+	if debuglevel >= ErrorLevel {
+		output("ERROR", logFlag, "", v...)
+	}
+}
+
+//Errorln error level
+func Errorln(v ...interface{}) {
+	if debuglevel >= ErrorLevel {
+		output("ERROR", logFlag, "", v...)
+	}
+}
+
+//Errorf error level
+func Errorf(format string, v ...interface{}) {
+	if debuglevel >= ErrorLevel {
+		output("ERROR", logFlag, format, v...)
+	}
+}
+
+//Fatal fatal error happen
+func Fatal(v ...interface{}) {
+	if debuglevel >= FatalLevel {
+		output("FATAL", logFlag, "", v...)
+	}
+}
+
+//Fatalf same as fatal
+func Fatalf(format string, v ...interface{}) {
+	if debuglevel >= FatalLevel {
+		output("FATAL", logFlag, format, v...)
+	}
+}
+
+//Logger init log func
+func Logger(filename string, level string) *os.File {
+	var f *os.File
+	if filename != "" {
+		var err error
+		f, err = os.OpenFile(filename, os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
+		if err != nil {
+			log.Fatal(err)
+		}
+		blog = log.New(f, "", 0)
+	}
+
+	for k, v := range errLevels {
+		if v == level {
+			debuglevel = k
+			Info("debuglevel:", v)
+		}
+	}
+
+	return f
+}
+
+func setDebugLevel(level string) {
+	for k, v := range errLevels {
+		if v == level {
+			debuglevel = k
+			Fatal("debuglevel:", v)
+		}
+	}
+}

blog.go

@@ -0,0 +1,56 @@
+package main
+
+import (
+	"bytes"
+	"crypto/tls"
+	"io/ioutil"
+	"net"
+	"net/http"
+	"time"
+)
+
+func getHttpClient() (client *http.Client) {
+	transport := http.Transport{
+		Dial:              dialTimeout,
+		DisableKeepAlives: true,
+		TLSClientConfig:   &tls.Config{InsecureSkipVerify: true},
+	}
+	client = &http.Client{
+		Transport: &transport,
+	}
+	return
+}
+
+func dialTimeout(network, addr string) (net.Conn, error) {
+	c, err := net.DialTimeout(network, addr, time.Second*50) //设置建立连接超时
+	if err != nil {
+		return nil, err
+	}
+	err = c.SetDeadline(time.Now().Add(10 * time.Second))
+	if err != nil {
+		return nil, err
+	} //设置发送接收数据超时
+	return c, nil
+}
+
+func HttpRequest(method, url string, body []byte, header map[string]string) (resp *http.Response, err error) {
+	newReq, _ := http.NewRequest(method, url, bytes.NewReader(body))
+
+	for k, v := range header {
+		newReq.Header.Set(k, v)
+	}
+
+	client := getHttpClient()
+	resp, err = client.Do(newReq)
+	if err != nil {
+		Error("new http req err.", err.Error())
+		return
+	}
+	return
+}
+
+func ParseResponseString(response *http.Response) (string, error) {
+	//var result map[string]interface{}
+	body, err := ioutil.ReadAll(response.Body) // response.Body 是一个数据流
+	return string(body), err                   // 将 io数据流转换为string类型返回！
+}

common.go

@@ -0,0 +1,74 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"os"
+	"time"
+
+	"toml"
+)
+
+const serviceName = "simluatedev"
+
+var BuildVersion = "default"
+
+var Config struct {
+	DeviceProvisioning struct {
+		PolicyName       string
+		Method           string
+		IdScope          string
+		OrderId          string
+		DevEndPoint      string
+		RegBaseUrl       string
+		RegStatusBaseUrl string
+	}
+
+	CommonKeys struct {
+		PrimaryKey     string
+		SecondaryKey   string
+		RegistrationId string
+	}
+
+	DataUploadConf struct {
+		IdentityId      string
+		Pid             string
+		MsgType         string
+		FirmwareVersion string
+		TimeVal         time.Duration
+	}
+
+	DirectMethodConf struct {
+		MethodName        string
+		SuccessStatusCode int
+		MethodJsonPath    string
+	}
+}
+
+func LoadCfg() {
+	showVersion := flag.Bool("v", false, "show version")
+	configFilePath := flag.String("c", "", "configure file path")
+	configFileTest := flag.Bool("t", false, "configure file test")
+	flag.Parse()
+	if *showVersion {
+		fmt.Println(BuildVersion)
+		os.Exit(0)
+	}
+	Info("cfg path :", *configFilePath)
+	if *configFilePath == "" {
+		*configFilePath = "config.toml"
+	}
+
+	var err error
+	if _, err = toml.DecodeFile(*configFilePath, &Config); err != nil {
+		Fatal("toml fail to parse file :", err)
+		os.Exit(-1)
+	}
+
+	Infof("%+v", Config)
+
+	if *configFileTest {
+		fmt.Printf("configuration file %s test is successful\n", *configFilePath)
+		os.Exit(0)
+	}
+}

config.go

@@ -0,0 +1,26 @@
+# DPS provisioning with symmetric key
+[DeviceProvisioning]
+Method = "symmetric_key"
+IdScope = "0cn000656B6"
+OrderId = "ce190381-3dwef-4d0jc-94h4e-ba7gdfb6c4a161d"
+PolicyName = "registration"
+DevEndPoint = "global.azure-devices-provisioning.cn"
+RegBaseUrl = "%s/%s/registrations/%s/register?api-version=2021-06-01"
+RegStatusBaseUrl = "%s/%s/registrations/%s?api-version=2021-06-01"
+
+[CommonKeys]
+PrimaryKey = "3k/K7JPeXrG+abUKsdglDkJbBqaB1D1PO74G/AqY4daC2hXMvdAl1nW2sfYfr7UGNvba2HRNhlUi9egqUbj6Hgbc1dg=="
+SecondaryKey = "SU3hAUJtnchjaz/DsdfHhyChbIUKdQq4nEFBPwEz5bg9sgm8byA6BzTso0sfGaKeLasJEBnRe1KnInYrooCgfkGKxg=="
+RegistrationId = "20220623device07" #设备mac
+
+[DataUploadConf]
+IdentityId = "0a527086c5gdfdb1d8b7a76cdfg5137020f801"
+Pid = "0000000000000000000000001ecdgc0000"
+MsgType = "dataUpload"
+FirmwareVersion = "1.0"
+TimeVal = 300 # 周期上报数据 默认300秒(1分钟)
+
+[DirectMethodConf]
+MethodName = "TestMethod" # 调用方法名称
+SuccessStatusCode = 200 # 调用方法名称返回code
+MethodJsonPath = "method.json" # # 调用方法返回参数配置文件