hz_crm_eta/services/cache_queue.go

package services

import (
	"encoding/json"
	"fmt"
	"hongze/hz_crm_eta/global"
	"hongze/hz_crm_eta/utils"
)

// ListenSyncRole 同步角色
func ListenSyncRole() {
	defer func() {
		if err := recover(); err != nil {
			fmt.Println("[ListenSyncRole]", err)
		}
	}()
	for {
		global.Rc.Brpop(utils.CACHE_SYNC_ROLE, func(b []byte) {
			var d SyncRoleData
			_ = json.Unmarshal(b, &d)
			_ = HandleSyncRole(d)
		})
	}
}

// ListenSyncAdmin 同步用户
func ListenSyncAdmin() {
	defer func() {
		if err := recover(); err != nil {
			fmt.Println("[ListenSyncAdmin]", err)
		}
	}()
	for {
		global.Rc.Brpop(utils.CACHE_SYNC_ADMIN, func(b []byte) {
			var d SyncAdminData
			_ = json.Unmarshal(b, &d)
			_ = HandleSyncAdmin(d)
		})
	}
}

// ListenSyncDepartment 同步部门
func ListenSyncDepartment() {
	defer func() {
		if err := recover(); err != nil {
			fmt.Println("[ListenSyncDepartment]", err)
		}
	}()
	for {
		global.Rc.Brpop(utils.CACHE_SYNC_DEPARTMENT, func(b []byte) {
			var d SyncDepartmentData
			_ = json.Unmarshal(b, &d)
			_ = HandleSyncDepartment(d)
		})
	}
}

// ListenSyncGroup 同步分组
func ListenSyncGroup() {
	defer func() {
		if err := recover(); err != nil {
			fmt.Println("[ListenSyncGroup]", err)
		}
	}()
	for {
		global.Rc.Brpop(utils.CACHE_SYNC_GROUP, func(b []byte) {
			var d SyncGroupData
			_ = json.Unmarshal(b, &d)
			_ = HandleSyncGroup(d)
		})
	}
}