attitude update frequency

pkg/producer/rpc.go

@@ -255,6 +255,7 @@ END;
 
 func (rpc *RPC) saveRPB(name string) error {
 	log.Infof("save RPC model to %s", name)
+	os.Remove(name)
 	model := rpc.Output()
 	f, err := os.Create(name)
 	if err != nil {

pkg/producer/scenes.go

@@ -14,6 +14,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"gocv.io/x/gocv"
 	"starwiz.cn/sjy01/image-proc/pkg/config"
+	"starwiz.cn/sjy01/image-proc/pkg/fusion"
 	"starwiz.cn/sjy01/image-proc/pkg/payload"
 	"starwiz.cn/sjy01/image-proc/pkg/rrc"
 	"starwiz.cn/sjy01/image-proc/pkg/utils"
@@ -241,7 +242,7 @@ func (r *Registrator) SaveScenesToTiff(panScenes []*Scene, mssScenes []*Scene) e
 func (r *Registrator) DoScenePansharpen(panScenes []*Scene, mssScenes []*Scene) error {
 	for i := 0; i < len(panScenes); i++ {
 		fusedTiff := strings.Replace(mssScenes[i].Tiff, "MSS", "FUS", -1)
-		err := GDALPansharpen(panScenes[i].Tiff, mssScenes[i].Tiff, fusedTiff)
+		err := fusion.Pansharpen(panScenes[i].Tiff, mssScenes[i].Tiff, fusedTiff, fusion.ESRI)
 		if err != nil {
 			return err
 		}