FranklinWH-Toolbox/service/repositories/api/acceleronix/simCardManage.go

package acceleronix

import (
	"encoding/json"
	"fwh-toolbox-server/domain"

	"go.uber.org/zap"
)

// 查询SIM卡列表
func QuerySimCardList(page uint, size uint) (*domain.AcceleronixSimCardListResponse, error) {
	res, err := acceleronixHttpPost("/sim/page", domain.AcceleronixSimCardListRequestBody{
		PageNum:  page,
		PageSize: size,
	})
	if err != nil {
		zap.L().Error("QuerySimCardList failed.", zap.String("err", err.Error()))
		return nil, err
	}

	var resList domain.AcceleronixSimCardListResponse
	if err := json.Unmarshal(res.Body, &resList); err != nil {
		zap.L().Error("QuerySimCardList Unmarshal failed.", zap.String("err", err.Error()), zap.String("body", string(res.Body)))
		return nil, err
	}

	return &resList, nil
}

// 查询SIM卡详情
func QuerySimCardInfo(iccid string) (*domain.AcceleronixSimCardInfoResponse, error) {
	res, err := acceleronixHttpPost("/sim/detail", map[string]interface{}{
		"iccid": iccid,
	})
	if err != nil {
		zap.L().Error("QuerySimCardInfo failed.", zap.String("err", err.Error()))
		return nil, err
	}

	var resInfo domain.AcceleronixSimCardInfoResponse
	if err := json.Unmarshal(res.Body, &resInfo); err != nil {
		zap.L().Error("QuerySimCardInfo Unmarshal failed.", zap.String("err", err.Error()), zap.String("body", string(res.Body)))
		return nil, err
	}

	return &resInfo, nil
}

// 批量获取SIM卡数据用量信息
// month 格式YYYYMM exp.202301
func QueryBatchSimCardDataInfo(iccidList []string, month string) ([]domain.AcceleronixSimCardDataUsageInfoResponse, error) {
	res, err := acceleronixHttpPost("/sim/batchQueryMonthData", domain.AcceleronixBatchDataUsageRequestBody{
		Iccids: iccidList,
		Month:  month,
	})
	if err != nil {
		zap.L().Error("QueryBatchSimCardDataInfo failed.", zap.String("err", err.Error()))
		return nil, err
	}

	var resList []domain.AcceleronixSimCardDataUsageInfoResponse
	if err := json.Unmarshal(res.Body, &resList); err != nil {
		zap.L().Error("QueryBatchSimCardDataInfo Unmarshal failed.", zap.String("err", err.Error()), zap.String("body", string(res.Body)))
		return nil, err
	}

	return resList, nil
}

// 查询流量池列表
func QueryDataPoolList(page uint, size uint) (*domain.AcceleronixDataPoolListResponse, error) {
	res, err := acceleronixHttpPost("/dataPool/page", domain.AcceleronixDataPoolListRequestBody{
		PageNum:  page,
		PageSize: size,
	})
	if err != nil {
		zap.L().Error("QueryDataPoolList failed.", zap.String("err", err.Error()))
		return nil, err
	}

	var resList domain.AcceleronixDataPoolListResponse
	if err := json.Unmarshal(res.Body, &resList); err != nil {
		zap.L().Error("QueryDataPoolList Unmarshal failed.", zap.String("err", err.Error()), zap.String("body", string(res.Body)))
		return nil, err
	}

	return &resList, nil
}

// 查询流量池SIM详情
func QueryDataPoolSimInfo(dataPoolId string, page uint, size uint) (*domain.AcceleronixDataPoolSimInfoResponse, error) {
	res, err := acceleronixHttpPost("/dataPool/detail", map[string]interface{}{
		"dataPoolId": dataPoolId,
		"pageNum":    page,
		"pageSize":   size,
	})
	if err != nil {
		zap.L().Error("QueryDataPoolSimInfo failed.", zap.String("err", err.Error()))
		return nil, err
	}

	var resInfo domain.AcceleronixDataPoolSimInfoResponse
	if err := json.Unmarshal(res.Body, &resInfo); err != nil {
		zap.L().Error("QueryDataPoolSimInfo Unmarshal failed.", zap.String("err", err.Error()), zap.String("body", string(res.Body)))
		return nil, err
	}

	return &resInfo, nil
}