Subversion Repositories SmartDukaan

Rev

Rev 1149 | Rev 1220 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1149 Rev 1208
Line 171... Line 171...
171
    Parameters:
171
    Parameters:
172
     - orderId
172
     - orderId
173
    """
173
    """
174
    pass
174
    pass
175
 
175
 
-
 
176
  def markOrderAsOutOfStock(self, orderId):
-
 
177
    """
-
 
178
    Mark the given order as out of stock. Throws an exception if the order with the given Id couldn't be found.
-
 
179
    
-
 
180
    
-
 
181
    Parameters:
-
 
182
     - orderId
-
 
183
    """
-
 
184
    pass
-
 
185
 
176
  def markOrdersAsManifested(self, warehouseId, providerId):
186
  def markOrdersAsManifested(self, warehouseId, providerId):
177
    """
187
    """
178
    Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WH
188
    Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WH
179
    
189
    
180
    Parameters:
190
    Parameters:
Line 888... Line 898...
888
      return result.success
898
      return result.success
889
    if result.ex != None:
899
    if result.ex != None:
890
      raise result.ex
900
      raise result.ex
891
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLineItemsForOrder failed: unknown result");
901
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getLineItemsForOrder failed: unknown result");
892
 
902
 
-
 
903
  def markOrderAsOutOfStock(self, orderId):
-
 
904
    """
-
 
905
    Mark the given order as out of stock. Throws an exception if the order with the given Id couldn't be found.
-
 
906
    
-
 
907
    
-
 
908
    Parameters:
-
 
909
     - orderId
-
 
910
    """
-
 
911
    self.send_markOrderAsOutOfStock(orderId)
-
 
912
    return self.recv_markOrderAsOutOfStock()
-
 
913
 
-
 
914
  def send_markOrderAsOutOfStock(self, orderId):
-
 
915
    self._oprot.writeMessageBegin('markOrderAsOutOfStock', TMessageType.CALL, self._seqid)
-
 
916
    args = markOrderAsOutOfStock_args()
-
 
917
    args.orderId = orderId
-
 
918
    args.write(self._oprot)
-
 
919
    self._oprot.writeMessageEnd()
-
 
920
    self._oprot.trans.flush()
-
 
921
 
-
 
922
  def recv_markOrderAsOutOfStock(self, ):
-
 
923
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
924
    if mtype == TMessageType.EXCEPTION:
-
 
925
      x = TApplicationException()
-
 
926
      x.read(self._iprot)
-
 
927
      self._iprot.readMessageEnd()
-
 
928
      raise x
-
 
929
    result = markOrderAsOutOfStock_result()
-
 
930
    result.read(self._iprot)
-
 
931
    self._iprot.readMessageEnd()
-
 
932
    if result.success != None:
-
 
933
      return result.success
-
 
934
    if result.ex != None:
-
 
935
      raise result.ex
-
 
936
    raise TApplicationException(TApplicationException.MISSING_RESULT, "markOrderAsOutOfStock failed: unknown result");
-
 
937
 
893
  def markOrdersAsManifested(self, warehouseId, providerId):
938
  def markOrdersAsManifested(self, warehouseId, providerId):
894
    """
939
    """
895
    Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WH
940
    Marks all BILLED orders for a warehouse and a provider as SHIPPED_FROM_WH
896
    
941
    
897
    Parameters:
942
    Parameters:
Line 1123... Line 1168...
1123
    self._processMap["getOrdersForTransaction"] = Processor.process_getOrdersForTransaction
1168
    self._processMap["getOrdersForTransaction"] = Processor.process_getOrdersForTransaction
1124
    self._processMap["getOrdersForCustomer"] = Processor.process_getOrdersForCustomer
1169
    self._processMap["getOrdersForCustomer"] = Processor.process_getOrdersForCustomer
1125
    self._processMap["createOrder"] = Processor.process_createOrder
1170
    self._processMap["createOrder"] = Processor.process_createOrder
1126
    self._processMap["getOrder"] = Processor.process_getOrder
1171
    self._processMap["getOrder"] = Processor.process_getOrder
1127
    self._processMap["getLineItemsForOrder"] = Processor.process_getLineItemsForOrder
1172
    self._processMap["getLineItemsForOrder"] = Processor.process_getLineItemsForOrder
-
 
1173
    self._processMap["markOrderAsOutOfStock"] = Processor.process_markOrderAsOutOfStock
1128
    self._processMap["markOrdersAsManifested"] = Processor.process_markOrdersAsManifested
1174
    self._processMap["markOrdersAsManifested"] = Processor.process_markOrdersAsManifested
1129
    self._processMap["markOrdersAsPickedUp"] = Processor.process_markOrdersAsPickedUp
1175
    self._processMap["markOrdersAsPickedUp"] = Processor.process_markOrdersAsPickedUp
1130
    self._processMap["markOrdersAsDelivered"] = Processor.process_markOrdersAsDelivered
1176
    self._processMap["markOrdersAsDelivered"] = Processor.process_markOrdersAsDelivered
1131
    self._processMap["markOrdersAsFailed"] = Processor.process_markOrdersAsFailed
1177
    self._processMap["markOrdersAsFailed"] = Processor.process_markOrdersAsFailed
1132
    self._processMap["getAlerts"] = Processor.process_getAlerts
1178
    self._processMap["getAlerts"] = Processor.process_getAlerts
Line 1408... Line 1454...
1408
    oprot.writeMessageBegin("getLineItemsForOrder", TMessageType.REPLY, seqid)
1454
    oprot.writeMessageBegin("getLineItemsForOrder", TMessageType.REPLY, seqid)
1409
    result.write(oprot)
1455
    result.write(oprot)
1410
    oprot.writeMessageEnd()
1456
    oprot.writeMessageEnd()
1411
    oprot.trans.flush()
1457
    oprot.trans.flush()
1412
 
1458
 
-
 
1459
  def process_markOrderAsOutOfStock(self, seqid, iprot, oprot):
-
 
1460
    args = markOrderAsOutOfStock_args()
-
 
1461
    args.read(iprot)
-
 
1462
    iprot.readMessageEnd()
-
 
1463
    result = markOrderAsOutOfStock_result()
-
 
1464
    try:
-
 
1465
      result.success = self._handler.markOrderAsOutOfStock(args.orderId)
-
 
1466
    except TransactionServiceException, ex:
-
 
1467
      result.ex = ex
-
 
1468
    oprot.writeMessageBegin("markOrderAsOutOfStock", TMessageType.REPLY, seqid)
-
 
1469
    result.write(oprot)
-
 
1470
    oprot.writeMessageEnd()
-
 
1471
    oprot.trans.flush()
-
 
1472
 
1413
  def process_markOrdersAsManifested(self, seqid, iprot, oprot):
1473
  def process_markOrdersAsManifested(self, seqid, iprot, oprot):
1414
    args = markOrdersAsManifested_args()
1474
    args = markOrdersAsManifested_args()
1415
    args.read(iprot)
1475
    args.read(iprot)
1416
    iprot.readMessageEnd()
1476
    iprot.readMessageEnd()
1417
    result = markOrdersAsManifested_result()
1477
    result = markOrdersAsManifested_result()
Line 4078... Line 4138...
4078
      oprot.writeFieldEnd()
4138
      oprot.writeFieldEnd()
4079
    if self.ex != None:
4139
    if self.ex != None:
4080
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
4140
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
4081
      self.ex.write(oprot)
4141
      self.ex.write(oprot)
4082
      oprot.writeFieldEnd()
4142
      oprot.writeFieldEnd()
-
 
4143
    oprot.writeFieldStop()
-
 
4144
    oprot.writeStructEnd()
-
 
4145
 
-
 
4146
  def __repr__(self):
-
 
4147
    L = ['%s=%r' % (key, value)
-
 
4148
      for key, value in self.__dict__.iteritems()]
-
 
4149
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
4150
 
-
 
4151
  def __eq__(self, other):
-
 
4152
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
4153
 
-
 
4154
  def __ne__(self, other):
-
 
4155
    return not (self == other)
-
 
4156
 
-
 
4157
class markOrderAsOutOfStock_args:
-
 
4158
  """
-
 
4159
  Attributes:
-
 
4160
   - orderId
-
 
4161
  """
-
 
4162
 
-
 
4163
  thrift_spec = (
-
 
4164
    None, # 0
-
 
4165
    (1, TType.I64, 'orderId', None, None, ), # 1
-
 
4166
  )
-
 
4167
 
-
 
4168
  def __init__(self, orderId=None,):
-
 
4169
    self.orderId = orderId
-
 
4170
 
-
 
4171
  def read(self, iprot):
-
 
4172
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
4173
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
4174
      return
-
 
4175
    iprot.readStructBegin()
-
 
4176
    while True:
-
 
4177
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
4178
      if ftype == TType.STOP:
-
 
4179
        break
-
 
4180
      if fid == 1:
-
 
4181
        if ftype == TType.I64:
-
 
4182
          self.orderId = iprot.readI64();
-
 
4183
        else:
-
 
4184
          iprot.skip(ftype)
-
 
4185
      else:
-
 
4186
        iprot.skip(ftype)
-
 
4187
      iprot.readFieldEnd()
-
 
4188
    iprot.readStructEnd()
-
 
4189
 
-
 
4190
  def write(self, oprot):
-
 
4191
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
4192
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
4193
      return
-
 
4194
    oprot.writeStructBegin('markOrderAsOutOfStock_args')
-
 
4195
    if self.orderId != None:
-
 
4196
      oprot.writeFieldBegin('orderId', TType.I64, 1)
-
 
4197
      oprot.writeI64(self.orderId)
-
 
4198
      oprot.writeFieldEnd()
-
 
4199
    oprot.writeFieldStop()
-
 
4200
    oprot.writeStructEnd()
-
 
4201
 
-
 
4202
  def __repr__(self):
-
 
4203
    L = ['%s=%r' % (key, value)
-
 
4204
      for key, value in self.__dict__.iteritems()]
-
 
4205
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
4206
 
-
 
4207
  def __eq__(self, other):
-
 
4208
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
4209
 
-
 
4210
  def __ne__(self, other):
-
 
4211
    return not (self == other)
-
 
4212
 
-
 
4213
class markOrderAsOutOfStock_result:
-
 
4214
  """
-
 
4215
  Attributes:
-
 
4216
   - success
-
 
4217
   - ex
-
 
4218
  """
-
 
4219
 
-
 
4220
  thrift_spec = (
-
 
4221
    (0, TType.BOOL, 'success', None, None, ), # 0
-
 
4222
    (1, TType.STRUCT, 'ex', (TransactionServiceException, TransactionServiceException.thrift_spec), None, ), # 1
-
 
4223
  )
-
 
4224
 
-
 
4225
  def __init__(self, success=None, ex=None,):
-
 
4226
    self.success = success
-
 
4227
    self.ex = ex
-
 
4228
 
-
 
4229
  def read(self, iprot):
-
 
4230
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
4231
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
4232
      return
-
 
4233
    iprot.readStructBegin()
-
 
4234
    while True:
-
 
4235
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
4236
      if ftype == TType.STOP:
-
 
4237
        break
-
 
4238
      if fid == 0:
-
 
4239
        if ftype == TType.BOOL:
-
 
4240
          self.success = iprot.readBool();
-
 
4241
        else:
-
 
4242
          iprot.skip(ftype)
-
 
4243
      elif fid == 1:
-
 
4244
        if ftype == TType.STRUCT:
-
 
4245
          self.ex = TransactionServiceException()
-
 
4246
          self.ex.read(iprot)
-
 
4247
        else:
-
 
4248
          iprot.skip(ftype)
-
 
4249
      else:
-
 
4250
        iprot.skip(ftype)
-
 
4251
      iprot.readFieldEnd()
-
 
4252
    iprot.readStructEnd()
-
 
4253
 
-
 
4254
  def write(self, oprot):
-
 
4255
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
4256
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
4257
      return
-
 
4258
    oprot.writeStructBegin('markOrderAsOutOfStock_result')
-
 
4259
    if self.success != None:
-
 
4260
      oprot.writeFieldBegin('success', TType.BOOL, 0)
-
 
4261
      oprot.writeBool(self.success)
-
 
4262
      oprot.writeFieldEnd()
-
 
4263
    if self.ex != None:
-
 
4264
      oprot.writeFieldBegin('ex', TType.STRUCT, 1)
-
 
4265
      self.ex.write(oprot)
-
 
4266
      oprot.writeFieldEnd()
4083
    oprot.writeFieldStop()
4267
    oprot.writeFieldStop()
4084
    oprot.writeStructEnd()
4268
    oprot.writeStructEnd()
4085
 
4269
 
4086
  def __repr__(self):
4270
  def __repr__(self):
4087
    L = ['%s=%r' % (key, value)
4271
    L = ['%s=%r' % (key, value)