iro/job.py
changeset 20 0d7ffb9b2c7f
parent 19 fcf8489f1c2f
child 23 0180b538ed74
equal deleted inserted replaced
19:fcf8489f1c2f 20:0d7ffb9b2c7f
    20         self.providerlist=providerlist
    20         self.providerlist=providerlist
    21         self.provider=provider
    21         self.provider=provider
    22         self.name=name
    22         self.name=name
    23         self.status = "init"
    23         self.status = "init"
    24         self.dStatus={"good":[], "failed":[]}
    24         self.dStatus={"good":[], "failed":[]}
       
    25         self.id=None
    25 
    26 
    26     def start(self):
    27     def start(self):
    27         self.status = "started"
    28         self.status = "started"
    28         
    29         
    29     def stop(self):
    30     def stop(self):
    39         
    40         
    40     def getProvider(self):
    41     def getProvider(self):
    41         return None
    42         return None
    42         
    43         
    43     def addGood(self, good):
    44     def addGood(self, good):
       
    45         import logging
       
    46         logging.debug('Job(%d)-send to %s'%(self.id, str(good)))
    44         if type(good) == list:
    47         if type(good) == list:
    45             self.dStatus['good']=self.dStatus['good']+good
    48             self.dStatus['good']=self.dStatus['good']+good
    46         else:
    49         else:
    47             self.dStatus['good'].append(good)
    50             self.dStatus['good'].append(good)
    48     
    51     
    49     def addFailed(self, failed):
    52     def addFailed(self, failed):
       
    53         import logging
       
    54         logging.debug('Job(%d)-faild to send to %s'%(self.id, str(failed)))
    50         if type(failed) == list:
    55         if type(failed) == list:
    51             self.dStatus['failed']=self.dStatus['failed']+failed
    56             self.dStatus['failed']=self.dStatus['failed']+failed
    52         else:
    57         else:
    53             self.dStatus['failed'].append(failed)
    58             self.dStatus['failed'].append(failed)
    54 
    59 
    62         Job.__init__(self,providerlist,provider,  name)
    67         Job.__init__(self,providerlist,provider,  name)
    63         
    68         
    64     def stop(self):
    69     def stop(self):
    65         pass
    70         pass
    66     
    71     
    67     def start(self):
    72     def start(self, id=None):
       
    73         self.id=id
    68         Job.start(self)
    74         Job.start(self)
    69         self.getProvider().setJob(self)
    75         self.getProvider().setJob(self)
    70         self.message.sendto(self.getProvider(), self.recipients)
    76         self.message.sendto(self.getProvider(), self.recipients)
    71         self.status="sended"
    77         self.status="sended"
    72 
    78 
    81     def __init__(self,providerlist,provider, name, message,recipients):
    87     def __init__(self,providerlist,provider, name, message,recipients):
    82         MessageJob.__init__(self,providerlist,provider, name, message,recipients)
    88         MessageJob.__init__(self,providerlist,provider, name, message,recipients)
    83         
    89         
    84     def getProvider(self):
    90     def getProvider(self):
    85         return self.providerlist.getProvider("sms", self.provider)
    91         return self.providerlist.getProvider("sms", self.provider)
    86         
       
    87     def start(self):
       
    88         MessageJob.start(self)
       
    89 
    92 
    90 class FAXJob(MessageJob):
    93 class FAXJob(MessageJob):
    91     def __init__(self,providerlist,provider, name, message,recipients):
    94     def __init__(self,providerlist,provider, name, message,recipients):
    92         MessageJob.__init__(self,providerlist,provider, name, message,recipients)
    95         MessageJob.__init__(self,providerlist,provider, name, message,recipients)
    93         
    96