R/yadirGetBalance.R

In grkhr/ryandexdirect: Load Data From 'Yandex Direct'

yadirGetBalance <- function(Logins        = NULL, 
                             Token         = NULL,     
                             AgencyAccount = NULL,
                             TokenPath     = getwd()){

  # ðåçóëüòèðóþùèé ôðåéì
  result <- data.table()
  
  #Àâòîðèçàöèÿ
  if (length(Logins) > 1 || is.null(Logins)) {
  Token <- tech_auth(login = AgencyAccount, token = Token, AgencyAccount = AgencyAccount, TokenPath = TokenPath)
  } else {
  Token <- tech_auth(login = Logins, token = Token, AgencyAccount = AgencyAccount, TokenPath = TokenPath)  
  }
 
  # ñòàðòîâûé ýëåìåíò
  start_element <- 1
  
  # äîïóñòèìîå êîëè÷åñòâî ëîãèíîâ â îäíîì çàïðîñå
  lim <- 50
  
  # èíôîðìàöèÿ î ïîñëåäíåé èòåðàöèè
  ended <- FALSE
  
  while(ended == FALSE) {
  
   # îòäåëÿåì íóæíóþ ïîðöèþ ëîãèíîâ
   logins_temp <- head(Logins[start_element:length(Logins)], lim)
   
   #Äëÿ ïðàâèëüíîãî ôîðìèðîâàíèÿ JSON ñìîòðèì ê-âî ëîãèíîâ è â ñëó÷àå åñëè ëîãèí 1 òî ïðåîáðàçóåì åãî â list
   if(length(logins_temp)==1){
     logins_temp <- list(logins_temp)
    }
  
  #Ôîðìèðóåì òåëî çàïðîñà
  body_list <-  list(method = "AccountManagement",
                     param  = list(Action = "Get",
                                   SelectionCriteria = list(Logins = logins_temp)),
                     locale = "ru",
                     token = Token)

  #Ôîðìèðóåì òåëî çàïðîñà
  body_json <- toJSON(body_list, auto_unbox = T, pretty = TRUE)
  
  #Îáðàùàåìñÿ ê API
  answer <- POST("https://api.direct.yandex.ru/live/v4/json/", body = body_json)
  
  #Îñòàâëèâàåì ïðè îøèáêå
  stop_for_status(answer)
  
  #ïàðñèì ðåçóëüòàò
  dataRaw <- content(answer, "parsed", "application/json")
  
  #Åù¸ îäíà ïðîâåðêà íà îøèáêè
  if(!is.null(dataRaw$error_code)){
    stop(paste0("Error: code - ",dataRaw$error_code, ", message - ",dataRaw$error_str, ", detail - ",dataRaw$error_detail))
  }
  
  #Ïðåîáðàçóåì ïîëó÷åííûé ðåçóëüòàò â òàáëèöó
  result_temp <- fromJSON(content(answer, "text", "application/json", encoding = "UTF-8"),flatten = TRUE)$data$Accounts
  
  #Ïðîâåðÿåì âñå ëè ëîãèíû çàãðóçèëèñü
  errors_list <- fromJSON(content(answer, "text", "application/json", encoding = "UTF-8"),flatten = TRUE)$data$ActionsResult
  
  if(length(errors_list) > 0){
  error <- data.frame(login = errors_list$Login, do.call(rbind.data.frame, errors_list$Errors))
  packageStartupMessage(paste0("Next ",nrow(error)," account",ifelse(nrow(error) > 1, "s","")," get error with try get ballance:"), appendLF = T)
  
  for(err in 1:nrow(error)){
  packageStartupMessage(paste0("Login: ", error$login[err]), appendLF = T)
  packageStartupMessage(paste0("....Code: ", error$FaultCode[err]), appendLF = T)
  packageStartupMessage(paste0("....String: ", error$FaultString[err]), appendLF = T)  
  packageStartupMessage(paste0("....Detail: ", error$FaultDetail[err]), appendLF = T)
  }}
  
  # äîáàâëÿåì èíôîðìàöèþ â ðåçóëüòèðóþùèé ôðåéì
  result <- rbind(result, result_temp, fill = TRUE)
  
  # ïåðåäâèãàåì íà÷àëüíûé ýëåìåíò
  start_element <- start_element + lim
  # ïðîâåðÿåì íàäî ëè åù¸ îáðàùàòüñÿ ê àïè ñîñ ëåäóþùåé ïîðöèåé ëîãèíîâ
  if (start_element > length(Logins)) {
    ended <- TRUE
  }
 }    
  return(as.data.frame(result))}