Golang实现两种FTP连接的组织方式：通用方法与特定方法

在Go中，可以通过接口组合和嵌入来实现这种模式。以下是完整的解决方案：

package main

import (
	"fmt"
	"log"
)

// Meter 结构体
type Meter struct {
	ID          string
	OperationID string
	Unit        string
}

// Acquisition 接口
type Acquisition interface {
	FetchMeters() ([]Meter, error)
	Name() string
}

// FTP 基础结构体
type FTP struct {
	Username string
	Password string
	Url      string
	Port     string
	client   interface{} // 模拟FTP客户端
}

// FTPAcq 接口，定义特定方法
type FTPAcq interface {
	Acquisition
	Unzip(file string) string
	Download(file string) string
}

// FTP1 结构体
type FTP1 struct {
	FTP
}

// FTP2 结构体
type FTP2 struct {
	FTP
}

// NewFTP 创建基础FTP连接
func NewFTP(user, password, url, port string) (*FTP, error) {
	ftp := &FTP{
		Username: user,
		Password: password,
		Url:      url,
		Port:     port,
		client:   "connected",
	}
	return ftp, nil
}

// Download 通用方法
func (ftp *FTP) Download(file string) string {
	return fmt.Sprintf("Downloaded file from %s:%s", ftp.Url, ftp.Port)
}

// Name 方法
func (ftp *FTP) Name() string {
	return "BaseFTP"
}

// FTP1 的特定实现
func (ftp1 *FTP1) Unzip(file string) string {
	return "Unzipped with .gzip format"
}

func (ftp1 *FTP1) FetchMeters() ([]Meter, error) {
	log.Printf("%s is running", ftp1.Name())
	file := ftp1.Download("")
	unzipped := ftp1.Unzip(file)
	log.Printf("FTP1: %s", unzipped)
	
	return []Meter{
		{ID: "FTP1-001", OperationID: "OP1", Unit: "kWh"},
	}, nil
}

func (ftp1 *FTP1) Name() string {
	return "FTP1"
}

// FTP2 的特定实现
func (ftp2 *FTP2) Unzip(file string) string {
	return "Unzipped with .zip format"
}

func (ftp2 *FTP2) FetchMeters() ([]Meter, error) {
	log.Printf("%s is running", ftp2.Name())
	file := ftp2.Download("")
	unzipped := ftp2.Unzip(file)
	log.Printf("FTP2: %s", unzipped)
	
	return []Meter{
		{ID: "FTP2-001", OperationID: "OP2", Unit: "m³"},
	}, nil
}

func (ftp2 *FTP2) Name() string {
	return "FTP2"
}

func main() {
	var acqs []Acquisition
	
	// 创建基础FTP连接
	ftp, err := NewFTP("user", "password", "host", "21")
	if err != nil {
		panic(err)
	}
	
	// 创建特定FTP实例
	ftp1 := &FTP1{*ftp}
	ftp2 := &FTP2{*ftp}
	
	acqs = append(acqs, ftp1, ftp2)
	
	for _, acq := range acqs {
		meters, err := acq.FetchMeters()
		if err != nil {
			log.Printf("%s got error: %v", acq.Name(), err)
		}
		log.Printf("Meters: %v", meters)
	}
}

或者使用更简洁的接口组合方式：

package main

import (
	"fmt"
	"log"
)

// Unzipper 解压接口
type Unzipper interface {
	Unzip(file string) string
}

// Downloader 下载接口
type Downloader interface {
	Download(file string) string
}

// FTP 基础结构体实现通用方法
type FTP struct {
	Username string
	Password string
	Url      string
	Port     string
}

func (ftp *FTP) Download(file string) string {
	return fmt.Sprintf("Downloaded from %s", ftp.Url)
}

// FTP1 实现
type FTP1 struct {
	*FTP
}

func (f *FTP1) Unzip(file string) string {
	return "GZIP unzipped"
}

func (f *FTP1) FetchMeters() ([]Meter, error) {
	file := f.Download("")
	unzipped := f.Unzip(file)
	log.Printf("FTP1 processed: %s", unzipped)
	return []Meter{{ID: "1"}}, nil
}

func (f *FTP1) Name() string {
	return "FTP1"
}

// FTP2 实现
type FTP2 struct {
	*FTP
}

func (f *FTP2) Unzip(file string) string {
	return "ZIP unzipped"
}

func (f *FTP2) FetchMeters() ([]Meter, error) {
	file := f.Download("")
	unzipped := f.Unzip(file)
	log.Printf("FTP2 processed: %s", unzipped)
	return []Meter{{ID: "2"}}, nil
}

func (f *FTP2) Name() string {
	return "FTP2"
}

// 工厂函数
func NewFTP1(ftp *FTP) *FTP1 {
	return &FTP1{FTP: ftp}
}

func NewFTP2(ftp *FTP) *FTP2 {
	return &FTP2{FTP: ftp}
}

这样每个FTP类型都实现了自己的Unzip()方法，同时通过嵌入FTP结构体继承了通用的Download()方法。