views.py 文件源码

def storeSatelliteData(request, name):
    # reviews all the history of the satellite product

    satelliteObj = SatelliteData.objects.filter(name=name)
    if not satelliteObj:
        context = {'message': ('error', 'The satellite data "' + name + '" has not been found in the database.')}
    else:
        job = storeSatelliteDataWrapper.delay(name)
        satelliteObj[0].jobId = job.id
        satelliteObj[0].save()

        #=======================================================================
        # storeSatelliteDataWrapper(name)
        # satelliteObj = SatelliteData.objects.filter(name=name)
        # satelliteObj[0].jobId = None
        #=======================================================================

        context = {'jobId': satelliteObj[0].jobId,
                   'message': ('warning', 'Starting data preparation...'),
                   'state': 'PROGRESS'}

        # Add celery periodic task
        intervalSchedules = IntervalSchedule.objects.filter(period='hours', every='2')
        if intervalSchedules:
            intervalSchedule = intervalSchedules[0]
        else:
            intervalSchedule = IntervalSchedule(period='hours', every='2')
            intervalSchedule.save()

        periodicTasks = PeriodicTask.objects.filter(name=name + ' Update')
        if not periodicTasks:
            periodicTask = PeriodicTask(name=name + ' Update', task='updateSatelliteData', interval=intervalSchedule, args='["' + name + '"]')
            periodicTask.save()

    return JsonResponse(context)