Add script csv gen

ldvspec/lofardata/models.py

 from django.db import models
-from django_filters import rest_framework as filters
 from urllib.parse import urlsplit
+from django.contrib.auth.models import User
+from django.contrib.postgres.fields import ArrayField
+from celery.result import AsyncResult
 
 
 class DataLocation(models.Model):
@@ -74,3 +76,32 @@ class DataProductFilter(models.Model):
     field = models.CharField(max_length=100)
     name = models.CharField(max_length=20)
     lookup_type = models.CharField(max_length=100)
+
+
+class ATDBProcessingSite(models.Model):
+    name = models.CharField(primary_key=True, max_length=100)
+    url = models.URLField()
+    access_token = models.CharField(max_length=1000, null=True)
+
+
+class WorkSpecification(models.Model):
+    created_on = models.DateTimeField(auto_now_add=True)
+    created_by = models.ForeignKey(User, on_delete=models.DO_NOTHING, null=True)
+    filters = models.JSONField(null=True)
+    inputs = models.JSONField(null=True)
+    selected_workflow = models.CharField(max_length=500, null=True)
+    related_tasks = ArrayField(models.IntegerField(), null=True)
+    is_ready = models.BooleanField(default=False)
+    is_defined = models.BooleanField(default=False)
+    async_task_result = models.CharField(max_length=100, null=True)
+    processing_site = models.ForeignKey(ATDBProcessingSite, null=True, on_delete=models.DO_NOTHING)
+
+    def save(self, force_insert=False, force_update=False, using=None,
+             update_fields=None):
+        super(WorkSpecification, self).save(force_insert=force_insert, force_update=force_update, using=using,
+                                            update_fields=update_fields)
+        if self.async_task_result is None:
+            from lofardata.tasks import define_work_specification
+            res: AsyncResult = define_work_specification.delay(self.pk)
+            self.async_task_result = res.id
+            super(WorkSpecification, self).save(update_fields=['async_task_result'])