Major Collecting stuff

gistfile1.txt

AccountRepository.find().map { accounts =>
            accounts.map { account =>
              val eligable = reviewService.receivedReviewedInDays(account.recoInfo.recoId, millis).map {
                b => {
                  account.recoInfo.recoId -> b
                }
              }.collect {
                case (r, false) => r
              }.map { r =>
                taskService.isRecoIdEligibleForTask(r).map {
                  b2 => {
                    r -> b2
                  }
                }.collect {
                  case (r, true) => r
                }
              }.flatMap(nested => nested)

              val result = eligable.map { recoId =>
                val task = Task(
                  None,
                  None,
                  None,
                  recoId = recoId,
                  name = account.name,
                  contactPersons = account.contacts,
                  reviewCount = account.recoInfo.reviewsNow,
                  latestReview = account.recoInfo.latestReviewDate,
                  salesPerson = account.zoho.ownerName,
                  stopDate = account.salesOrder.stopDate,
                  taskStatus = TaskStatus.NEW,
                  disabled = false
                )
                taskService.createTask(task).map { maybeInsert =>
                  maybeInsert.fold(
                    exception => Logger.error(s"Could not save task $task, exception $exception"),
                    success => Logger.info(s"Task created: $task")
                  )
                }
              }
              result
            }
          }