commit

amd64/dispatch_server/package/infra/i_redis.go

@@ -2,6 +2,7 @@ package infra
 
 import (
 	"github.com/go-redis/redis"
+	"os"
 	"sync"
 )
 
@@ -25,5 +26,11 @@ func InitRedisClient(addr string, password string, db int) {
 	if err != nil {
 		GlobalLogger.Error("初始化 Redis 客户端报错:", err)
 	}
-	GlobalLogger.Error("初始化 Redis 客户端成功。")
+	// 清空当前选择的数据库
+	err = GlobalRedisClient.FlushDB().Err()
+	if err != nil {
+		GlobalLogger.Errorf("清空 redis 【%v】号库的数据时报错，初始化 Redis 客户端失败，错误信息为：%v", db, err)
+		os.Exit(0)
+	}
+	GlobalLogger.Infof("已清空 redis 【%v】号库的数据，初始化 Redis 客户端成功。", db)
 }

test/disk/main/main.go

@@ -1,44 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"os/exec"
-	"strconv"
-	"strings"
-)
-
-// getDiskUsage 解析 df 命令的输出
-// df -B1 /dev/vdb
-// Filesystem        1B-blocks        Used    Available Use% Mounted on
-// /dev/vdb       527371075584 16390344704 484120408064   4% /mnt/disk001
-func getDiskUsage(path string) (uint64, error) {
-	cmd := exec.Command("df", "-B1", path)
-	output, err := cmd.CombinedOutput()
-	if err != nil {
-		return 0, err
-	}
-
-	lines := strings.Split(string(output), "\n")
-	if len(lines) < 2 {
-		return 0, fmt.Errorf("unexpected output from df command")
-	}
-
-	fields := strings.Fields(lines[1])
-	if len(fields) < 3 {
-		return 0, fmt.Errorf("unexpected output format from df command")
-	}
-	parseUint, _ := strconv.ParseUint(fields[2], 10, 64)
-	return parseUint, nil
-}
-
-func main() {
-	path := "/dev/vdb" // 替换为您要查询的硬盘路径，如 "/dev/sda"
-
-	used, err := getDiskUsage(path)
-	if err != nil {
-		fmt.Println("Error:", err)
-		return
-	}
-
-	fmt.Printf("Used Disk Space: %d bytes\n", used)
-}

test/json/main/main.go

@@ -1,86 +0,0 @@
-package main
-
-import (
-	"cicv-data-closedloop/amd64/dispatch_server/package/entity"
-	"encoding/json"
-	"fmt"
-)
-
-func main() {
-
-	jsonData, _ := json.MarshalIndent(
-		&entity.Project{
-			ProjectId:          "项目ID",
-			AlgorithmObjectKey: "算法在阿里云的存储路径",
-			UserId:             "用户ID",
-			Parallelism:        10,
-			Tasks: []entity.Task{
-				{
-					Info: entity.TaskInfo{
-						ProjectId:   "项目ID",
-						TaskId:      "任务ID",
-						TaskPath:    "任务结果路径",
-						DefaultTime: "最大仿真时间",
-					},
-					Scenario: entity.TaskScenario{
-						ScenarioOsc:  "xosc或xml路径",
-						ScenarioOdr:  "xodr路径",
-						ScenarioOsgb: "osgb路径",
-					},
-					Vehicle: entity.TaskVehicle{
-						Model: entity.VehicleModel{ModelLabel: "模型标签"},
-						Dynamics: entity.VehicleDynamics{
-							DynamicsMaxspeed:              0,
-							DynamicsEnginepower:           0,
-							DynamicsMaxdecel:              0,
-							DynamicsMaxsteering:           0,
-							DynamicsMass:                  0,
-							DynamicsFrontsurfaceeffective: 0,
-							DynamicsAirdragcoefficient:    0,
-							DynamicsRollingresistance:     0,
-							DynamicsWheeldiameter:         0,
-							DynamicsWheeldrive:            "",
-							DynamicsOverallefficiency:     0,
-							DynamicsDistfront:             0,
-							DynamicsDistrear:              0,
-							DynamicsDistleft:              0,
-							DynamicsDistright:             0,
-							DynamicsDistheight:            0,
-							DynamicsWheelbase:             0,
-						},
-						Sensors: entity.VehicleSensors{
-							Camera: []entity.SensorCamera{
-								{},
-							},
-							OGT: []entity.SensorOgt{
-								{
-									Sensor:           entity.Sensor{},
-									SensorForHLeft:   0,
-									SensorForHRight:  0,
-									SensorForHTop:    0,
-									SensorForHBottom: 0,
-									SensorFilter:     "0,5,6",
-									SensorDisplay:    false,
-									SensorMaxObjects: 0,
-									SensorPort:       0,
-								}, {
-									Sensor:           entity.Sensor{},
-									SensorForHLeft:   0,
-									SensorForHRight:  0,
-									SensorForHTop:    0,
-									SensorForHBottom: 0,
-									SensorFilter:     "1,2,3,4",
-									SensorDisplay:    false,
-									SensorMaxObjects: 0,
-									SensorPort:       0,
-								},
-							},
-						},
-					},
-				},
-			},
-		},
-		"", " ",
-	)
-	fmt.Println(string(jsonData))
-}

test/main/main.go

@@ -1,34 +0,0 @@
-package main
-
-import (
-	"cicv-data-closedloop/common/util"
-	"fmt"
-)
-
-//type DeviceMonitor struct {
-//	Id               int    `db:"id" json:"id"`                               // 自增id
-//	TotalCpuUsage    string `db:"total_cpu_usage" json:"totalCpuUsage"`       // cpu总占用
-//	TotalMemoryUsage string `db:"total_memory_usage" json:"totalMemoryUsage"` // 内存总占用
-//	Top10Process     string `db:"top10_process" json:"top10Process"`          // cpu占用前十的进程信息
-//	DeviceNumber     string `db:"device_number" json:"deviceNumber"`          // cpu占用前十的进程信息
-//	SocIp            string `db:"soc_ip" json:"socIp"`                        // cpu占用前十的进程信息
-//}
-
-// 保存资源占用情况
-func main() {
-	responseString, err := util.HttpPostJsonWithHeaders(
-		"http://36.110.106.142:12341/web_server/monitor/insert",
-		map[string]string{"Authorization": "U9yKpD6kZZDDe4LFKK6myAxBUT1XRrDM"},
-		map[string]string{
-			"totalCpuUsage":    "util.ToString(util.GetCpuPercent())",
-			"totalMemoryUsage": " util.ToString(util.GetMemoryPercent())",
-			"top10Process":     " util.ToString(util.GetTop10())",
-			"deviceNumber":     "LocalConfig.EquipmentNo",
-			"socIp":            "LocalConfig.Node.Ip",
-		},
-	)
-	if err != nil {
-		fmt.Printf("发送数据监控信息报错%v，响应信息为：%v", err, responseString)
-	}
-	fmt.Printf("发送数据监控信息成功，响应信息为：%v", responseString)
-}

test/monitor/main/main.go

@@ -1,126 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"github.com/shirou/gopsutil/cpu"
-	"github.com/shirou/gopsutil/disk"
-	"github.com/shirou/gopsutil/mem"
-	"github.com/shirou/gopsutil/process"
-	"sort"
-	"time"
-)
-
-type ProcessInfo struct {
-	Pid      int32   `json:"pid"`
-	Name     string  `json:"name"`
-	CpuUsage float64 `json:"cpuUsage"`
-	MemUsage float32 `json:"memUsage"`
-}
-
-// GetCpuPercent cpu总占用率
-func GetCpuPercent() float64 {
-	percent, _ := cpu.Percent(time.Second, false)
-	return percent[0]
-}
-
-// GetMemoryPercent 内存总占用率
-func GetMemoryPercent() float64 {
-	memory, _ := mem.VirtualMemory()
-	return memory.UsedPercent
-}
-
-// GetDiskPercent 磁盘总占用率
-func GetDiskPercent() float64 {
-	parts, _ := disk.Partitions(true)
-	diskInfo, _ := disk.Usage(parts[0].Mountpoint)
-	return diskInfo.UsedPercent
-}
-
-func GetTop10CpuAndMem() ([]ProcessInfo, []ProcessInfo) {
-	// 获取所有进程的CPU占用率
-	processes, err := process.Processes()
-	if err != nil {
-		//fmt.Println("Error:", err)
-		return nil, nil
-	}
-
-	// 创建一个用于存储进程CPU占用率的映射
-	cpuPercent := make(map[int32]float64)
-	memPercent := make(map[int32]float32)
-
-	// 获取每个进程的CPU占用率
-	for _, p := range processes {
-		pid := p.Pid
-		cpuPercent[pid], err = p.CPUPercent()
-		memPercent[pid], err = p.MemoryPercent()
-	}
-
-	// 根据CPU占用率对进程进行排序
-	sortedPidsCpu := make([]int32, 0, len(cpuPercent))
-	sortedPidsMem := make([]int32, 0, len(cpuPercent))
-	for pid := range cpuPercent {
-		sortedPidsCpu = append(sortedPidsCpu, pid)
-	}
-
-	sort.Slice(sortedPidsCpu, func(i, j int) bool {
-		return cpuPercent[sortedPidsCpu[i]] > cpuPercent[sortedPidsCpu[j]]
-	})
-
-	// 输出前10个CPU占用率最高的进程名称
-	var top10Cpu []ProcessInfo
-
-	for i, pid := range sortedPidsCpu {
-		if i >= 10 {
-			break
-		}
-		p, err := process.NewProcess(pid)
-		if err != nil {
-			continue
-		}
-		name, _ := p.Name()
-		top10Cpu = append(top10Cpu, ProcessInfo{
-			Pid:      pid,
-			Name:     name,
-			CpuUsage: cpuPercent[pid],
-			MemUsage: memPercent[pid],
-		})
-	}
-
-	// --------------------- 内存
-	var top10Mem []ProcessInfo
-
-	for pid := range memPercent {
-		sortedPidsMem = append(sortedPidsMem, pid)
-	}
-
-	sort.Slice(sortedPidsMem, func(i, j int) bool {
-		return memPercent[sortedPidsMem[i]] > memPercent[sortedPidsMem[j]]
-	})
-
-	for i, pid := range sortedPidsMem {
-		if i >= 10 {
-			break
-		}
-		p, err := process.NewProcess(pid)
-		if err != nil {
-			continue
-		}
-		name, _ := p.Name()
-		top10Mem = append(top10Mem, ProcessInfo{
-			Pid:      pid,
-			Name:     name,
-			CpuUsage: cpuPercent[pid],
-			MemUsage: memPercent[pid],
-		})
-	}
-	return top10Cpu, top10Mem
-}
-
-func main() {
-	fmt.Println("cpu总占用率为：", GetCpuPercent())
-	fmt.Println("内存总占用率为：", GetMemoryPercent())
-	fmt.Println("磁盘总占用率为：", GetDiskPercent())
-	top10cpu, top10mem := GetTop10CpuAndMem()
-	fmt.Println("top10cpu为：", top10cpu)
-	fmt.Println("top10mem为：", top10mem)
-}

test/pdf/pdf.go

@@ -1,38 +0,0 @@
-package main
-
-import (
-	"github.com/signintech/gopdf"
-	"log"
-)
-
-func main() {
-
-	// 1 初始化 pdf 对象
-	pdf := gopdf.GoPdf{}
-	pdf.Start(gopdf.Config{PageSize: *gopdf.PageSizeA4})
-
-	// 2 添加一页
-	pdf.AddPage()
-
-	// 3
-	err := pdf.AddTTFFont("simfang", "D:\\code\\cicv-data-closedloop\\test\\pdf\\ttf\\simfang.ttf")
-	if err != nil {
-		log.Print(err.Error())
-		return
-	}
-
-	err = pdf.SetFont("simfang", "", 14)
-	if err != nil {
-		log.Print(err.Error())
-		return
-	}
-	err = pdf.Cell(nil, "您好")
-	if err != nil {
-		return
-	}
-	err = pdf.WritePdf("D:\\hello.pdf")
-	if err != nil {
-		return
-	}
-
-}