fix: 移动file文件操作包

lib/core/cmd/cmd.go

@@ -1,201 +0,0 @@
-package cmd
-
-import (
-	"bytes"
-	"context"
-	"fmt"
-	"os/exec"
-	"strings"
-	"time"
-)
-
-func Exec(cmdStr string) (string, error) {
-	ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
-	defer cancel()
-	cmd := exec.Command("bash", "-c", cmdStr)
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if ctx.Err() == context.DeadlineExceeded {
-		return "", fmt.Errorf("errCmdTimeout %v", err)
-	}
-	if err != nil {
-		errMsg := ""
-		if len(stderr.String()) != 0 {
-			errMsg = fmt.Sprintf("stderr: %s", stderr.String())
-		}
-		if len(stdout.String()) != 0 {
-			if len(errMsg) != 0 {
-				errMsg = fmt.Sprintf("%s; stdout: %s", errMsg, stdout.String())
-			} else {
-				errMsg = fmt.Sprintf("stdout: %s", stdout.String())
-			}
-		}
-		return errMsg, err
-	}
-	return stdout.String(), nil
-}
-
-func ExecWithTimeOut(cmdStr string, timeout time.Duration) (string, error) {
-	ctx, cancel := context.WithTimeout(context.Background(), timeout)
-	defer cancel()
-	cmd := exec.Command("bash", "-c", cmdStr)
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if ctx.Err() == context.DeadlineExceeded {
-		return "", fmt.Errorf("errCmdTimeout %v", err)
-	}
-	if err != nil {
-		errMsg := ""
-		if len(stderr.String()) != 0 {
-			errMsg = fmt.Sprintf("stderr: %s", stderr.String())
-		}
-		if len(stdout.String()) != 0 {
-			if len(errMsg) != 0 {
-				errMsg = fmt.Sprintf("%s; stdout: %s", errMsg, stdout.String())
-			} else {
-				errMsg = fmt.Sprintf("stdout: %s", stdout.String())
-			}
-		}
-		return errMsg, err
-	}
-	return stdout.String(), nil
-}
-
-func ExecCronjobWithTimeOut(cmdStr string, workdir string, timeout time.Duration) (string, error) {
-	ctx, cancel := context.WithTimeout(context.Background(), timeout)
-	defer cancel()
-	cmd := exec.Command("bash", "-c", cmdStr)
-	cmd.Dir = workdir
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if ctx.Err() == context.DeadlineExceeded {
-		return "", fmt.Errorf("errCmdTimeout %v", err)
-	}
-
-	errMsg := ""
-	if len(stderr.String()) != 0 {
-		errMsg = fmt.Sprintf("stderr:\n %s", stderr.String())
-	}
-	if len(stdout.String()) != 0 {
-		if len(errMsg) != 0 {
-			errMsg = fmt.Sprintf("%s \n\n; stdout:\n %s", errMsg, stdout.String())
-		} else {
-			errMsg = fmt.Sprintf("stdout:\n %s", stdout.String())
-		}
-	}
-	return errMsg, err
-}
-
-func Execf(cmdStr string, a ...interface{}) (string, error) {
-	cmd := exec.Command("bash", "-c", fmt.Sprintf(cmdStr, a...))
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if err != nil {
-		errMsg := ""
-		if len(stderr.String()) != 0 {
-			errMsg = fmt.Sprintf("stderr: %s", stderr.String())
-		}
-		if len(stdout.String()) != 0 {
-			if len(errMsg) != 0 {
-				errMsg = fmt.Sprintf("%s; stdout: %s", errMsg, stdout.String())
-			} else {
-				errMsg = fmt.Sprintf("stdout: %s", stdout.String())
-			}
-		}
-		return errMsg, err
-	}
-	return stdout.String(), nil
-}
-
-func ExecWithCheck(name string, a ...string) (string, error) {
-	cmd := exec.Command(name, a...)
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if err != nil {
-		errMsg := ""
-		if len(stderr.String()) != 0 {
-			errMsg = fmt.Sprintf("stderr: %s", stderr.String())
-		}
-		if len(stdout.String()) != 0 {
-			if len(errMsg) != 0 {
-				errMsg = fmt.Sprintf("%s; stdout: %s", errMsg, stdout.String())
-			} else {
-				errMsg = fmt.Sprintf("stdout: %s", stdout.String())
-			}
-		}
-		return errMsg, err
-	}
-	return stdout.String(), nil
-}
-
-func ExecScript(scriptPath, workDir string) (string, error) {
-	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Minute)
-	defer cancel()
-	cmd := exec.Command("bash", scriptPath)
-	cmd.Dir = workDir
-	var stdout, stderr bytes.Buffer
-	cmd.Stdout = &stdout
-	cmd.Stderr = &stderr
-	err := cmd.Run()
-	if ctx.Err() == context.DeadlineExceeded {
-		return "", fmt.Errorf("errCmdTimeout %v", err)
-	}
-	if err != nil {
-		errMsg := ""
-		if len(stderr.String()) != 0 {
-			errMsg = fmt.Sprintf("stderr: %s", stderr.String())
-		}
-		if len(stdout.String()) != 0 {
-			if len(errMsg) != 0 {
-				errMsg = fmt.Sprintf("%s; stdout: %s", errMsg, stdout.String())
-			} else {
-				errMsg = fmt.Sprintf("stdout: %s", stdout.String())
-			}
-		}
-		return errMsg, err
-	}
-	return stdout.String(), nil
-}
-
-func CheckIllegal(args ...string) bool {
-	if args == nil {
-		return false
-	}
-	for _, arg := range args {
-		if strings.Contains(arg, "&") || strings.Contains(arg, "|") || strings.Contains(arg, ";") ||
-			strings.Contains(arg, "$") || strings.Contains(arg, "'") || strings.Contains(arg, "`") ||
-			strings.Contains(arg, "(") || strings.Contains(arg, ")") || strings.Contains(arg, "\"") {
-			return true
-		}
-	}
-	return false
-}
-
-func HasNoPasswordSudo() bool {
-	cmd2 := exec.Command("sudo", "-n", "ls")
-	err2 := cmd2.Run()
-	return err2 == nil
-}
-
-func SudoHandleCmd() string {
-	cmd := exec.Command("sudo", "-n", "ls")
-	if err := cmd.Run(); err == nil {
-		return "sudo "
-	}
-	return ""
-}
-
-func Which(name string) bool {
-	_, err := exec.LookPath(name)
-	return err == nil
-}

lib/core/file/csv.go

@@ -1,88 +0,0 @@
-package file
-
-import (
-	"encoding/csv"
-	"os"
-	"path/filepath"
-	"strings"
-
-	"ems.agt/lib/log"
-)
-
-// 写入CSV文件，需要转换数据
-// 例如：
-// data := [][]string{}
-// data = append(data, []string{"姓名", "年龄", "城市"})
-// data = append(data, []string{"1", "2", "3"})
-// err := file.WriterCSVFile(data, filePath)
-func WriterCSVFile(data [][]string, filePath string) error {
-	// 获取文件所在的目录路径
-	dirPath := filepath.Dir(filePath)
-
-	// 确保文件夹路径存在
-	err := os.MkdirAll(dirPath, os.ModePerm)
-	if err != nil {
-		log.Errorf("创建文件夹失败 CreateFile %v", err)
-	}
-
-	// 创建或打开文件
-	file, err := os.Create(filePath)
-	if err != nil {
-		return err
-	}
-	defer file.Close()
-
-	// 创建CSV编写器
-	writer := csv.NewWriter(file)
-	defer writer.Flush()
-
-	// 写入数据
-	for _, row := range data {
-		writer.Write(row)
-	}
-	return nil
-}
-
-// 读取CSV文件，转换map数据
-func ReadCSVFile(filePath string) []map[string]string {
-	// 创建 map 存储 CSV 数据
-	arr := make([]map[string]string, 0)
-
-	// 打开 CSV 文件
-	file, err := os.Open(filePath)
-	if err != nil {
-		log.Fatal("无法打开 CSV 文件：", err)
-		return arr
-	}
-	defer file.Close()
-
-	// 创建 CSV Reader
-	reader := csv.NewReader(file)
-
-	// 读取 CSV 头部行
-	header, err := reader.Read()
-	if err != nil {
-		log.Fatal("无法读取 CSV 头部行：", err)
-		return arr
-	}
-
-	// 遍历 CSV 数据行
-	for {
-		// 读取一行数据
-		record, err := reader.Read()
-		if err != nil {
-			// 到达文件末尾或遇到错误时退出循环
-			break
-		}
-
-		// 将 CSV 数据插入到 map 中
-		data := make(map[string]string)
-		for i, value := range record {
-			key := strings.ToLower(header[i])
-			data[key] = value
-		}
-		arr = append(arr, data)
-	}
-
-	return arr
-}

lib/core/file/ssh.go

@@ -1,49 +0,0 @@
-package file
-
-import (
-	"fmt"
-	"os"
-	"os/exec"
-	"path/filepath"
-
-	"ems.agt/lib/core/conf"
-	"ems.agt/lib/log"
-)
-
-// 网元NE 文件复制到远程文件
-func FileSCPLocalToNe(neIp, localPath, nePath string) error {
-	usernameNe := conf.Get("ne.user").(string)
-	// scp /path/to/local/file.txt user@remote-server:/path/to/remote/directory/
-	neDir := fmt.Sprintf("%s@%s:%s", usernameNe, neIp, nePath)
-	cmd := exec.Command("scp", "-r", localPath, neDir)
-	out, err := cmd.CombinedOutput()
-	if err != nil {
-		return err
-	}
-	log.Infof("FileSCPLocalToNe %s", string(out))
-	return nil
-}
-
-// 网元NE 远程文件复制到本地文件
-func FileSCPNeToLocal(neIp, nePath, localPath string) error {
-	// 获取文件所在的目录路径
-	dirPath := filepath.Dir(localPath)
-
-	// 确保文件夹路径存在
-	err := os.MkdirAll(dirPath, os.ModePerm)
-	if err != nil {
-		log.Errorf("创建文件夹失败 CreateFile %v", err)
-		return err
-	}
-
-	usernameNe := conf.Get("ne.user").(string)
-	// scp user@remote-server:/path/to/remote/directory/ /path/to/local/file.txt
-	neDir := fmt.Sprintf("%s@%s:%s", usernameNe, neIp, nePath)
-	cmd := exec.Command("scp", "-r", neDir, localPath)
-	out, err := cmd.CombinedOutput()
-	if err != nil {
-		return err
-	}
-	log.Infof("FileSCPNeToLocal %s", string(out))
-	return nil
-}

lib/core/file/txt.go

@@ -1,79 +0,0 @@
-package file
-
-import (
-	"bufio"
-	"fmt"
-	"os"
-	"path/filepath"
-	"strings"
-
-	"ems.agt/lib/log"
-)
-
-// 写入Txt文件用,号分割 需要转换数据
-// 例如：
-// data := [][]string{}
-// data = append(data, []string{"姓名", "年龄", "城市"})
-// data = append(data, []string{"1", "2", "3"})
-// err := file.WriterCSVFile(data, filePath)
-func WriterTxtFile(data [][]string, filePath string) error {
-	// 获取文件所在的目录路径
-	dirPath := filepath.Dir(filePath)
-
-	// 确保文件夹路径存在
-	err := os.MkdirAll(dirPath, os.ModePerm)
-	if err != nil {
-		log.Errorf("创建文件夹失败 CreateFile %v", err)
-	}
-
-	// 创建或打开文件
-	file, err := os.Create(filePath)
-	if err != nil {
-		return err
-	}
-	defer file.Close()
-
-	// 创建一个 Writer 对象，用于将数据写入文件
-	writer := bufio.NewWriter(file)
-	for _, row := range data {
-		line := strings.Join(row, ",")
-		fmt.Fprintln(writer, line)
-	}
-
-	// 将缓冲区中的数据刷新到文件中
-	err = writer.Flush()
-	if err != nil {
-		log.Errorf("刷新缓冲区时发生错误:", err)
-		return err
-	}
-	return nil
-}
-
-// 读取Txt文件，用,号分割 转换数组数据
-func ReadTxtFile(filePath string) [][]string {
-	// 创建 map 存储 CSV 数据
-	arr := make([][]string, 0)
-
-	// 打开文本文件
-	file, err := os.Open(filePath)
-	if err != nil {
-		log.Fatal("无法打开文件:", err)
-		return arr
-	}
-	defer file.Close()
-
-	// 创建一个 Scanner 对象，用于逐行读取文件内容
-	scanner := bufio.NewScanner(file)
-	if scanner.Err() != nil {
-		log.Fatal("读取文件时出错:", scanner.Err())
-		return arr
-	}
-
-	for scanner.Scan() {
-		line := scanner.Text()
-		fields := strings.Split(line, ",")
-		arr = append(arr, fields)
-	}
-
-	return arr
-}