Method deleteSubscribe

plugin/minecraftobserver/store.go:160–194

删除订阅

(addr string, targetID int64, targetType int64)

// 删除订阅
func (d *db) deleteSubscribe(addr string, targetID int64, targetType int64) (err error) {
	if d == nil {
		return errDBConn
	}
	if addr == "" || targetID == 0 || targetType == 0 {
		return errParam
	}
	d.subscribeLock.Lock()
	defer d.subscribeLock.Unlock()
	// 检查是否存在
	if err = d.sdb.Model(&serverSubscribe{}).Where("server_addr = ? and target_id = ? and target_type = ?", addr, targetID, targetType).First(&serverSubscribe{}).Error; err != nil {
		if gorm.IsRecordNotFoundError(err) {
			return errors.New("未找到订阅")
		}
		// logrus.Errorln(logPrefix+"deleteSubscribe ERROR: ", err)
		return
	}

	if err = d.sdb.Where("server_addr = ? and target_id = ? and target_type = ?", addr, targetID, targetType).Delete(&serverSubscribe{}).Error; err != nil {
		// logrus.Errorln(logPrefix+"deleteSubscribe ERROR: ", err)
		return
	}

	// 扫描是否还有订阅，如果没有则删除服务器状态
	var cnt int
	err = d.sdb.Model(&serverSubscribe{}).Where("server_addr = ?", addr).Count(&cnt).Error
	if err != nil {
		// logrus.Errorln(logPrefix+"deleteSubscribe ERROR: ", err)
		return
	}
	if cnt == 0 {
		_ = d.delServerStatus(addr)
	}
	return
}

// 获取所有订阅
func (d *db) getAllSubscribes() (subs []serverSubscribe, err error) {