更新thrift 协议

FileController/FileController_test.go

+package FileController
+
+import (
+	"ficus_clientserver/config"
+	"fmt"
+	"testing"
+
+	. "bou.ke/monkey"
+)
+
+func TestGetFileInfo(t *testing.T) {
+	Patch(config.GetFileSecretId, func() string {
+		return "AKIDc5IFvXTasugMkGOcT4NPAhz0jBNVG1bu"
+	})
+	Patch(config.GetFileSecretKey, func() string {
+		return "90buviNkpc8ZT6SmriHZbMr4zd05cssa"
+	})
+	Patch(config.GetFileBucket, func() string {
+		return "gotest2"
+	})
+	Patch(config.GetFileBucketUrl, func() string {
+		return "https://gotest2-1251115246.cos.ap-chengdu.myqcloud.com"
+	})
+	Patch(config.GetFileBucketPath, func() string {
+		return "ficus/%v/6188/1.0.9/%v"
+	})
+	fcos := NewOss()
+	md5, url := fcos.GetFileInfo("adapter")
+	fmt.Println("md5", md5, "url", url)
+}

control/msgsend.go

@@ -2,8 +2,8 @@ package control
 
 import (
 	"context"
-	"ficus/mission"
-	"ficus/proto"
+	"ficus/dto/mission"
+	"ficus/dto/proto"
 	"ficus_clientserver/config"
 	"ficus_clientserver/model"
 	"ficus_clientserver/nethandle/thriftservice"

model/client.go

@@ -2,7 +2,7 @@ package model
 
 import (
 	"errors"
-	"ficus/device"
+	"ficus/dto/device"
 	"sync"
 
 	"github.com/apache/thrift/lib/go/thrift"

model/msg.go

@@ -2,7 +2,7 @@ package model
 
 import (
 	"container/list"
-	"ficus/mission"
+	"ficus/dto/mission"
 	"sync"
 )
 

model/msgcontrol.go

@@ -2,8 +2,8 @@ package model
 
 import (
 	"encoding/json"
-	"ficus/mission"
-	"ficus/proto"
+	"ficus/dto/mission"
+	"ficus/dto/proto"
 	"ficus_clientserver/config"
 	"ficus_clientserver/mqcontrol"
 	"fmt"

model/redisclient.go

@@ -2,7 +2,7 @@ package model
 
 import (
 	"encoding/json"
-	"ficus/mission"
+	"ficus/dto/mission"
 	"ficus_clientserver/config"
 	"fmt"
 	"time"

nethandle/devicehandler.go

@@ -2,14 +2,14 @@ package nethandle
 
 import (
 	"context"
-	"ficus/device"
-	"ficus/identity"
-	"ficus/service"
+	deviceservice "ficus/device"
+	device "ficus/dto/device"
+	"ficus/dto/identity"
 )
 
 type (
 	DeviceHandler interface {
-		service.DeviceService
+		deviceservice.DeviceService
 		SetDispatch() error
 	}
 
@@ -89,27 +89,27 @@ func (d *DeviceHandle) GetDeviceEx(ctx context.Context, uuid string) (r *device.
 	return
 }
 
-func (d *DeviceHandle) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
 
-func (d *DeviceHandle) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
 
-func (d *DeviceHandle) ListExpired(ctx context.Context, seconds int32, ip string) (r *service.DevicesPage, err error) {
+func (d *DeviceHandle) ListExpired(ctx context.Context, seconds int32, ip string) (r *device.DevicesPage, err error) {
 	return nil, nil
 }
 
-func (d *DeviceHandle) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
 
-func (d *DeviceHandle) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
 
-func (d *DeviceHandle) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return
 }
 
@@ -117,7 +117,7 @@ func (d *DeviceHandle) ListByVersionEx(ctx context.Context, ver string, page int
 //  - Filter
 //  - Page
 //  - PageSize
-func (d *DeviceHandle) ListDevicesEx(ctx context.Context, filter *service.DeviceFilter, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListDevicesEx(ctx context.Context, filter *device.DeviceFilter, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return
 }
 

nethandle/dispatchhandler.go

@@ -2,9 +2,9 @@ package nethandle
 
 import (
 	"context"
-	"ficus/device"
-	"ficus/mission"
-	"ficus/service"
+	dispatchservice "ficus/dispatch"
+	"ficus/dto/device"
+	"ficus/dto/mission"
 	"ficus_clientserver/config"
 	"ficus_clientserver/model"
 	"ficus_clientserver/tool"
@@ -14,7 +14,7 @@ import (
 
 type (
 	DispatchHandler interface {
-		service.DispatchService
+		dispatchservice.DispatchService
 		SetDispatch() error
 	}
 

nethandle/packagehandler.go

@@ -2,13 +2,13 @@ package nethandle
 
 import (
 	"context"
-	"ficus/pkg"
-	"ficus/service"
+	"ficus/dto/pkg"
+	pkgservice "ficus/pkg"
 )
 
 type (
 	PackageHandler interface {
-		service.PackageService
+		pkgservice.PackageService
 		SetDispatch() error
 	}
 	PackageHandle struct {
@@ -27,8 +27,8 @@ func (p *PackageHandle) GetSpec(ctx context.Context, pkgName string, ver string)
 	return p.PackageHandler.GetSpec(ctx, pkgName, ver)
 }
 
-func (p *PackageHandle) GetSpecByPartner(ctx context.Context, pkgName string, ver string, partnerId string) (r *pkg.PackageSpec, err error) {
-	return p.PackageHandler.GetSpecByPartner(ctx, pkgName, ver, partnerId)
+func (p *PackageHandle) GetSpecByFilter(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageResult_, err error) {
+	return p.PackageHandler.GetSpecByFilter(ctx, filter)
 }
 
 // Parameters:
@@ -37,13 +37,13 @@ func (p *PackageHandle) GetSpecByPartner(ctx context.Context, pkgName string, ve
 //  - Timeout
 //  - UploadSpec
 //  - Content
-func (p *PackageHandle) Upload(ctx context.Context, sessionId string, partnerId string, timeout int32, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadSpec, err error) {
+func (p *PackageHandle) Upload(ctx context.Context, filter *pkg.PackageFilter, sessionId string, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadResult_, err error) {
 	return
 }
 
 // Parameters:
 //  - SessionId
-func (p *PackageHandle) Pack(ctx context.Context, sessionId string) (r *pkg.PackageSpec, err error) {
+func (p *PackageHandle) Pack(ctx context.Context, filter *pkg.PackageFilter, releaseNote string) (r *pkg.PackageResult_, err error) {
 	return
 }
 
@@ -51,7 +51,8 @@ func (p *PackageHandle) Pack(ctx context.Context, sessionId string) (r *pkg.Pack
 //  - PartnerId
 //  - Page
 //  - PageSize
-func (p *PackageHandle) ListPackageEx(ctx context.Context, partnerId string, page int32, pageSize int32) (r *service.PackagesPage, err error) {
+
+func (p *PackageHandle) ListPackages(ctx context.Context, filter *pkg.PackageFilter, page int32, pageSize int32) (r *pkg.PackagesPage, err error) {
 	return
 }
 
@@ -59,7 +60,41 @@ func (p *PackageHandle) ListPackageEx(ctx context.Context, partnerId string, pag
 //  - Name
 //  - Ver
 //  - Enabled
-func (p *PackageHandle) EnablePackage(ctx context.Context, name string, ver string, enabled bool) (r bool, err error) {
+func (p *PackageHandle) EnablePackage(ctx context.Context, filter *pkg.PackageFilter, enabled bool) (r bool, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+func (p *PackageHandle) RemovePackage(ctx context.Context, filter *pkg.PackageFilter) (r bool, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+func (p *PackageHandle) GetEntry(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageEntryResult_, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - PkgEntry
+func (p *PackageHandle) CreateEntry(ctx context.Context, filter *pkg.PackageFilter, pkgEntry *pkg.PackageEntry) (r *pkg.PackageEntryResult_, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - Src
+//  - Dst
+func (p *PackageHandle) RenameEntry(ctx context.Context, filter *pkg.PackageFilter, src string, dst string) (r string, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - EntryName
+func (p *PackageHandle) RemoveEntry(ctx context.Context, filter *pkg.PackageFilter, entryName string) (r bool, err error) {
 	return
 }
 

nethandle/schedulehandler.go

@@ -3,8 +3,8 @@ package nethandle
 import (
 	"context"
 	"errors"
-	"ficus/mission"
-	"ficus/native/service"
+	"ficus/dto/mission"
+	scheduleservice "ficus/schedule"
 	"ficus_clientserver/model"
 
 	log "github.com/sirupsen/logrus"
@@ -12,7 +12,7 @@ import (
 
 type (
 	ScheduleHandler interface {
-		service.ScheduleService
+		scheduleservice.ScheduleService
 	}
 
 	ScheduleHandle struct {

nethandle/thriftservice/devicedispatch.go

@@ -2,9 +2,9 @@ package thriftservice
 
 import (
 	"context"
-	"ficus/device"
-	"ficus/identity"
-	"ficus/service"
+	deviceservice "ficus/device"
+	"ficus/dto/device"
+	"ficus/dto/identity"
 	"ficus_clientserver/config"
 	"ficus_clientserver/tool"
 	"net"
@@ -16,7 +16,7 @@ import (
 // DeviceDispatch 设备服务client
 // ip ,port 分别为设备服务的地址和端口
 type DeviceDispatch struct {
-	client *service.DeviceServiceClient
+	client *deviceservice.DeviceServiceClient
 	tran   *thrift.TFramedTransport
 }
 
@@ -84,33 +84,33 @@ func (d *DeviceDispatch) GetDeviceEx(ctx context.Context, uuid string) (r *devic
 	return
 }
 
-func (d *DeviceDispatch) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	defer d.tran.Close()
 	return nil, nil
 }
 
-func (d *DeviceDispatch) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	defer d.tran.Close()
 	return nil, nil
 }
 
-func (d *DeviceDispatch) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	defer d.tran.Close()
 	return nil, nil
 }
 
-func (d *DeviceDispatch) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	defer d.tran.Close()
 	return nil, nil
 }
 
-func (d *DeviceDispatch) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	defer d.tran.Close()
 	return
 }
 
 // 获取空闲设备
-func (d *DeviceDispatch) ListExpired(ctx context.Context, seconds int32, ip string) (r *service.DevicesPage, err error) {
+func (d *DeviceDispatch) ListExpired(ctx context.Context, seconds int32, ip string) (r *device.DevicesPage, err error) {
 	defer d.tran.Close()
 	r, err = d.client.ListExpired(ctx, seconds, ip)
 	log.Info("dispatch ListExpired", err, seconds, ip)
@@ -121,7 +121,7 @@ func (d *DeviceDispatch) ListExpired(ctx context.Context, seconds int32, ip stri
 //  - Filter
 //  - Page
 //  - PageSize
-func (d *DeviceDispatch) ListDevicesEx(ctx context.Context, filter *service.DeviceFilter, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceDispatch) ListDevicesEx(ctx context.Context, filter *device.DeviceFilter, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return
 }
 
@@ -152,7 +152,7 @@ func (d *DeviceDispatch) SetDispatch() error {
 		log.Error("Error opening socket to "+"localhost"+":"+"9099", err)
 		return err
 	}
-	client := service.NewDeviceServiceClientFactory(transport, protocolFactory)
+	client := deviceservice.NewDeviceServiceClientFactory(transport, protocolFactory)
 	d.tran = transport
 	d.client = client
 	return nil

nethandle/thriftservice/devicehandler.go

@@ -2,9 +2,8 @@ package thriftservice
 
 import (
 	"context"
-	"ficus/device"
-	"ficus/identity"
-	"ficus/service"
+	"ficus/dto/device"
+	"ficus/dto/identity"
 	"ficus_clientserver/nethandle"
 
 	log "github.com/sirupsen/logrus"
@@ -68,26 +67,26 @@ func (d *DeviceHandle) GetPeer(ctx context.Context, uuid string) (r string, err
 	//TODO 获取server ip
 	return "", nil
 }
-func (d *DeviceHandle) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByVersionEx(ctx context.Context, ver string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return
 }
 
 func (d *DeviceHandle) GetDeviceEx(ctx context.Context, uuid string) (r *device.DeviceEx, err error) {
 	return nil, nil
 }
-func (d *DeviceHandle) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByStatusEx(ctx context.Context, status int32, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
-func (d *DeviceHandle) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByOrganizationEx(ctx context.Context, org *identity.Organization, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
-func (d *DeviceHandle) ListExpired(ctx context.Context, seconds int32, ip string) (r *service.DevicesPage, err error) {
+func (d *DeviceHandle) ListExpired(ctx context.Context, seconds int32, ip string) (r *device.DevicesPage, err error) {
 	return nil, nil
 }
-func (d *DeviceHandle) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByGroupEx(ctx context.Context, group string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
-func (d *DeviceHandle) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListByRegionEx(ctx context.Context, rgn string, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return nil, nil
 }
 
@@ -95,7 +94,7 @@ func (d *DeviceHandle) ListByRegionEx(ctx context.Context, rgn string, page int3
 //  - Filter
 //  - Page
 //  - PageSize
-func (d *DeviceHandle) ListDevicesEx(ctx context.Context, filter *service.DeviceFilter, page int32, pageSize int32) (r *service.DevicesExPage, err error) {
+func (d *DeviceHandle) ListDevicesEx(ctx context.Context, filter *device.DeviceFilter, page int32, pageSize int32) (r *device.DevicesExPage, err error) {
 	return
 }
 

nethandle/thriftservice/dispatchhandler.go

@@ -2,9 +2,9 @@ package thriftservice
 
 import (
 	"context"
-	"ficus/device"
-	"ficus/mission"
-	"ficus/service"
+	dispatchservice "ficus/dispatch"
+	"ficus/dto/device"
+	"ficus/dto/mission"
 	"ficus_clientserver/model"
 	"ficus_clientserver/nethandle"
 
@@ -64,6 +64,6 @@ func NewMyTProcessorFactory(clientManager *model.ClientManager, msgControl *mode
 func (p *myProcessorFactory) GetProcessor(trans thrift.TTransport) thrift.TProcessor {
 	// 在这里创建 handler 主要是为了保存 ttransport，以便双向通信
 	handler := NewDispatchService(trans, p.clientManager, p.msgControl)
-	processor := service.NewDispatchServiceProcessor(handler)
+	processor := dispatchservice.NewDispatchServiceProcessor(handler)
 	return processor
 }

nethandle/thriftservice/messagedispatch.go

@@ -3,9 +3,9 @@ package thriftservice
 import (
 	"context"
 	"errors"
-	"ficus/device"
-	"ficus/mission"
-	"ficus/service"
+	dispatchservice "ficus/dispatch"
+	"ficus/dto/device"
+	"ficus/dto/mission"
 	"ficus_clientserver/config"
 	"ficus_clientserver/model"
 	"ficus_clientserver/tool"
@@ -19,14 +19,14 @@ type DispatchMsg struct {
 	trans          thrift.TTransport
 	clientManager  *model.ClientManager
 	msgControl     *model.MsgControl
-	callbackClient *service.DispatchServiceClient
+	callbackClient *dispatchservice.DispatchServiceClient
 }
 
 func NewDispatchMsgTrans(trans thrift.TTransport) *DispatchMsg {
 	d := &DispatchMsg{}
 	d.trans = trans
 
-	d.callbackClient = service.NewDispatchServiceClientFactory(thrift.NewTFramedTransport(trans), thrift.NewTCompactProtocolFactory())
+	d.callbackClient = dispatchservice.NewDispatchServiceClientFactory(thrift.NewTFramedTransport(trans), thrift.NewTCompactProtocolFactory())
 	return d
 }
 
@@ -35,7 +35,7 @@ func NewDispatchMsg(trans thrift.TTransport, clientManager *model.ClientManager,
 	d.clientManager = clientManager
 	d.msgControl = msgControl
 	d.trans = trans
-	d.callbackClient = service.NewDispatchServiceClientFactory(thrift.NewTFramedTransport(trans), thrift.NewTCompactProtocolFactory())
+	d.callbackClient = dispatchservice.NewDispatchServiceClientFactory(thrift.NewTFramedTransport(trans), thrift.NewTCompactProtocolFactory())
 	return d
 }
 
@@ -81,7 +81,7 @@ func (d *DispatchMsg) Feedback(ctx context.Context, response *mission.Message) (
 		return false, err
 	}
 	defer transport.Close()
-	client := service.NewDispatchServiceClientFactory(transport, protocolFactory)
+	client := dispatchservice.NewDispatchServiceClientFactory(transport, protocolFactory)
 	r, err = client.Feedback(context.Background(), response)
 	log.Infoln("dispatch Feedback result ", r, err, response)
 	return

nethandle/thriftservice/packagehandler.go

@@ -2,8 +2,7 @@ package thriftservice
 
 import (
 	"context"
-	"ficus/pkg"
-	"ficus/service"
+	"ficus/dto/pkg"
 	"ficus_clientserver/FileController"
 	"ficus_clientserver/nethandle"
 
@@ -35,24 +34,56 @@ func (s *PackageHandle) GetSpec(ctx context.Context, pkgName string, ver string)
 	return PackageHandler.GetSpec(ctx, pkgName, ver)
 }
 
-func (s *PackageHandle) GetSpecByPartner(ctx context.Context, pkgName string, ver string, partnerId string) (r *pkg.PackageSpec, err error) {
+func (s *PackageHandle) GetSpecByFilter(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageResult_, err error) {
 	PackageHandler := nethandle.NewPackageHandle(NewPackageDispatch())
-	return PackageHandler.GetSpecByPartner(ctx, pkgName, ver, partnerId)
+	return PackageHandler.GetSpecByFilter(ctx, filter)
 }
 
-func (s *PackageHandle) Upload(ctx context.Context, sessionId string, partnerId string, timeout int32, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadSpec, err error) {
+func (s *PackageHandle) Upload(ctx context.Context, filter *pkg.PackageFilter, sessionId string, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadResult_, err error) {
 	return
 }
 
-func (s *PackageHandle) Pack(ctx context.Context, sessionId string) (r *pkg.PackageSpec, err error) {
+func (s *PackageHandle) Pack(ctx context.Context, filter *pkg.PackageFilter, releaseNote string) (r *pkg.PackageResult_, err error) {
 	return
 }
 
-func (s *PackageHandle) ListPackageEx(ctx context.Context, partnerId string, page int32, pageSize int32) (r *service.PackagesPage, err error) {
+func (s *PackageHandle) ListPackages(ctx context.Context, filter *pkg.PackageFilter, page int32, pageSize int32) (r *pkg.PackagesPage, err error) {
 	return
 }
 
-func (s *PackageHandle) EnablePackage(ctx context.Context, name string, ver string, enabled bool) (r bool, err error) {
+func (s *PackageHandle) EnablePackage(ctx context.Context, filter *pkg.PackageFilter, enabled bool) (r bool, err error) {
+	return
+}
+
+func (p *PackageHandle) RemovePackage(ctx context.Context, filter *pkg.PackageFilter) (r bool, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+func (p *PackageHandle) GetEntry(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageEntryResult_, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - PkgEntry
+func (p *PackageHandle) CreateEntry(ctx context.Context, filter *pkg.PackageFilter, pkgEntry *pkg.PackageEntry) (r *pkg.PackageEntryResult_, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - Src
+//  - Dst
+func (p *PackageHandle) RenameEntry(ctx context.Context, filter *pkg.PackageFilter, src string, dst string) (r string, err error) {
+	return
+}
+
+// Parameters:
+//  - Filter
+//  - EntryName
+func (p *PackageHandle) RemoveEntry(ctx context.Context, filter *pkg.PackageFilter, entryName string) (r bool, err error) {
 	return
 }
 
@@ -70,33 +101,65 @@ func (s *PackageDispatch) GetSpec(ctx context.Context, pkgName string, ver strin
 	return
 }
 
-func (s *PackageDispatch) GetSpecByPartner(ctx context.Context, pkgName string, ver string, partnerId string) (r *pkg.PackageSpec, err error) {
-	log.Info("GetSpecByPartner", pkgName, ver)
-	fcos := FileController.NewOss()
-	md5, url := fcos.GetFileInfo(pkgName)
-	r = pkg.NewPackageSpec()
-	r.Pkg = pkg.NewPackage()
-	r.Pkg.Name = pkgName
-	r.Pkg.Version = ver
-	r.Pkg.PartnerId = partnerId
-	r.Md5 = md5
-	r.URL = url
+func (s *PackageDispatch) GetSpecByFilter(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageResult_, err error) {
+	// log.Info("GetSpecByFilter ", filter)
+	// fcos := FileController.NewOss()
+	// md5, url := fcos.GetFileInfo(pkgName)
+	// r = pkg.NewPackageSpec()
+	// r.Pkg = pkg.NewPackage()
+	// r.Pkg.Name = pkgName
+	// r.Pkg.Version = ver
+	// r.Pkg.PartnerId = partnerId
+	// r.Md5 = md5
+	// r.URL = url
+	return
+}
+
+func (s *PackageDispatch) Upload(ctx context.Context, filter *pkg.PackageFilter, sessionId string, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadResult_, err error) {
+	return
+}
+
+func (s *PackageDispatch) Pack(ctx context.Context, filter *pkg.PackageFilter, releaseNote string) (r *pkg.PackageResult_, err error) {
+	return
+}
+
+func (s *PackageDispatch) ListPackages(ctx context.Context, filter *pkg.PackageFilter, page int32, pageSize int32) (r *pkg.PackagesPage, err error) {
+	return
+}
+
+func (s *PackageDispatch) EnablePackage(ctx context.Context, filter *pkg.PackageFilter, enabled bool) (r bool, err error) {
+	return
+}
+
+func (p *PackageDispatch) RemovePackage(ctx context.Context, filter *pkg.PackageFilter) (r bool, err error) {
 	return
 }
 
-func (s *PackageDispatch) Upload(ctx context.Context, sessionId string, partnerId string, timeout int32, uploadSpec *pkg.UploadSpec, content []byte) (r *pkg.UploadSpec, err error) {
+// Parameters:
+//  - Filter
+func (p *PackageDispatch) GetEntry(ctx context.Context, filter *pkg.PackageFilter) (r *pkg.PackageEntryResult_, err error) {
 	return
 }
 
-func (s *PackageDispatch) Pack(ctx context.Context, sessionId string) (r *pkg.PackageSpec, err error) {
+// Parameters:
+//  - Filter
+//  - PkgEntry
+func (p *PackageDispatch) CreateEntry(ctx context.Context, filter *pkg.PackageFilter, pkgEntry *pkg.PackageEntry) (r *pkg.PackageEntryResult_, err error) {
 	return
 }
 
-func (s *PackageDispatch) ListPackageEx(ctx context.Context, partnerId string, page int32, pageSize int32) (r *service.PackagesPage, err error) {
+// Parameters:
+//  - Filter
+//  - Src
+//  - Dst
+func (p *PackageDispatch) RenameEntry(ctx context.Context, filter *pkg.PackageFilter, src string, dst string) (r string, err error) {
 	return
 }
 
-func (s *PackageDispatch) EnablePackage(ctx context.Context, name string, ver string, enabled bool) (r bool, err error) {
+// Parameters:
+//  - Filter
+//  - EntryName
+func (p *PackageDispatch) RemoveEntry(ctx context.Context, filter *pkg.PackageFilter, entryName string) (r bool, err error) {
 	return
 }
 

nethandle/thriftservice/schedulehandler.go

@@ -2,7 +2,7 @@ package thriftservice
 
 import (
 	"context"
-	"ficus/mission"
+	"ficus/dto/mission"
 	"ficus_clientserver/model"
 	"ficus_clientserver/nethandle"
 

work.go

@@ -3,11 +3,13 @@ package main
 import (
 	"bufio"
 	"context"
-	"ficus/device"
-	"ficus/mission"
-	native "ficus/native/service"
-	"ficus/proto"
-	"ficus/service"
+	deviceservice "ficus/device"
+	dispatchservice "ficus/dispatch"
+	"ficus/dto/device"
+	"ficus/dto/mission"
+	"ficus/dto/proto"
+	pkgservice "ficus/pkg"
+	scheduleservice "ficus/schedule"
 	"ficus_clientserver/config"
 	"ficus_clientserver/control"
 	"ficus_clientserver/model"
@@ -225,16 +227,16 @@ func StartThriftSever2() {
 	TMultiplexedProcessor := thrift.NewTMultiplexedProcessor()
 
 	deviceHandle := thriftservice.NewDeviceHandle()
-	deviceProcessor := service.NewDeviceServiceProcessor(deviceHandle)
+	deviceProcessor := deviceservice.NewDeviceServiceProcessor(deviceHandle)
 
 	dispatchHandle := thriftservice.NewDispatchService(nil, ClientManager, MsgControl)
-	dispatchProcessor := service.NewDispatchServiceProcessor(dispatchHandle)
+	dispatchProcessor := dispatchservice.NewDispatchServiceProcessor(dispatchHandle)
 
 	scheduleHandle := thriftservice.NewScheduleHandle(MsgControl, ClientManager)
-	scheduleProcessor := native.NewScheduleServiceProcessor(scheduleHandle)
+	scheduleProcessor := scheduleservice.NewScheduleServiceProcessor(scheduleHandle)
 
 	packageHandle := thriftservice.NewPackageHandle()
-	packageProcessor := service.NewPackageServiceProcessor(packageHandle)
+	packageProcessor := pkgservice.NewPackageServiceProcessor(packageHandle)
 
 	TMultiplexedProcessor.RegisterProcessor("Identity", deviceProcessor)
 	TMultiplexedProcessor.RegisterProcessor("Mission", dispatchProcessor)
@@ -254,7 +256,7 @@ func StartThriftSever2() {
 
 func StartHttpServer() {
 	scheduleHandle := thriftservice.NewScheduleHandle(MsgControl, ClientManager)
-	scheduleProcessor := native.NewScheduleServiceProcessor(scheduleHandle)
+	scheduleProcessor := scheduleservice.NewScheduleServiceProcessor(scheduleHandle)
 	scheduleProtocolFactory := thrift.NewTJSONProtocolFactory()
 	scheduleHandler := thrift.NewThriftHandlerFunc(scheduleProcessor, scheduleProtocolFactory, scheduleProtocolFactory)
 	mux := http.NewServeMux()