From a3a24e1cf44aa4e95a8684c86455a2b7064ac623 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期二, 23 七月 2024 04:51:29 +0800
Subject: [PATCH] 定时删除本地存储的图片

---
 repository/subscribeRepo.go |   87 ++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 84 insertions(+), 3 deletions(-)

diff --git a/repository/subscribeRepo.go b/repository/subscribeRepo.go
index f6f505f..5f3d256 100644
--- a/repository/subscribeRepo.go
+++ b/repository/subscribeRepo.go
@@ -54,6 +54,87 @@
 	return err
 }
 
+func (s *SubscribeRepository) CancelSubscribe(sid string, req *vo.Subscribe) error {
+	var subscribeMsg vo.RequestCancelSubscribe
+	subscribeMsg.SubscribeObject = *req
+
+	if req.SubscribeID == "" {
+		return errors.New("璁㈤槄娑堟伅涓婚涓虹┖")
+	}
+
+	// 鏌ユ壘涓嬬骇
+	var platform models.SubPlatform
+	err := platform.FindById(sid)
+	if err != nil {
+		return err
+	}
+
+	uri := fmt.Sprintf("http://%s:%d/VIID/Subscribes/%s", platform.RemoteIP, platform.RemotePort, req.SubscribeID)
+	body, _ := json.Marshal(subscribeMsg)
+	if client.UpdateSubscribe(uri, body) != vo.StatusSuccess {
+		return errors.New("鍙戦�佽闃呮秷鎭け璐�")
+	}
+
+	var sub = models.Subscribe{
+		Id:     req.SubscribeID,
+		Status: req.SubscribeStatus,
+		FromId: sid,
+		Ext:    *req,
+	}
+
+	err = sub.Save()
+	if err != nil {
+		return err
+	}
+
+	return err
+}
+
+func (s *SubscribeRepository) UpdateSubscribe(sid string, req *vo.Subscribe) error {
+	var subscribeMsg vo.RequestSubscribe
+	subscribeMsg.SubscribeListObject.SubscribeObject = []vo.Subscribe{*req}
+
+	// 鏌ユ壘涓嬬骇
+	var platform models.SubPlatform
+	err := platform.FindById(sid)
+	if err != nil {
+		return err
+	}
+
+	uri := fmt.Sprintf("http://%s:%d/VIID/Subscribes", platform.RemoteIP, platform.RemotePort)
+	body, _ := json.Marshal(subscribeMsg)
+	if client.UpdateSubscribe(uri, body) != vo.StatusSuccess {
+		return errors.New("鍙戦�佽闃呮秷鎭け璐�")
+	}
+
+	var sub = models.Subscribe{
+		Id:     req.SubscribeID,
+		Status: req.SubscribeStatus,
+		FromId: sid,
+		Ext:    *req,
+	}
+
+	err = sub.Save()
+	if err != nil {
+		return err
+	}
+
+	return err
+}
+
+func (s *SubscribeRepository) RemoteList(sid string) ([]byte, error) {
+	// 鏌ユ壘涓嬬骇
+	var platform models.SubPlatform
+	err := platform.FindById(sid)
+	if err != nil {
+		return nil, err
+	}
+
+	uri := fmt.Sprintf("http://%s:%d/VIID/Subscribes", platform.RemoteIP, platform.RemotePort)
+
+	return client.GetSubscribes(uri)
+}
+
 func (s *SubscribeRepository) SaveReceiveSubscribe(fromId string, subscribe *vo.Subscribe) error {
 	var sub = models.Subscribe{
 		Id:     subscribe.SubscribeID,
@@ -67,7 +148,7 @@
 		return err
 	}
 
-	service.UpdateTaskProcs(sub.Id, vo.Msg_Type_Create_Subscribe, &sub)
+	service.UpdateNotificationTask(sub.Id, vo.Msg_Type_Create_Subscribe, &sub)
 
 	return err
 }
@@ -82,7 +163,7 @@
 	sub.Status = subscribe.SubscribeStatus
 	sub.Ext = *subscribe
 
-	service.UpdateTaskProcs(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, nil)
+	service.UpdateNotificationTask(subscribe.SubscribeID, vo.Msg_Type_Update_Subscribe, &sub)
 
 	return sub.Save()
 }
@@ -94,7 +175,7 @@
 		return err
 	}
 
-	service.UpdateTaskProcs(id, vo.Msg_Type_Delete_Subscribe, nil)
+	service.UpdateNotificationTask(id, vo.Msg_Type_Delete_Subscribe, nil)
 
 	return err
 }

--
Gitblit v1.8.0