Subversion Repositories SmartDukaan

Rev

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

Rev 5496 Rev 5530
Line 24... Line 24...
24
    Parameters:
24
    Parameters:
25
     - serialNumber
25
     - serialNumber
26
    """
26
    """
27
    pass
27
    pass
28
 
28
 
29
  def getNonSeralizedInventoryItem(self, itemId, warehouseId):
29
  def getNonSeralizedInventoryItem(self, itemNumber, itemId, fulfilmentWarehouseId):
30
    """
30
    """
31
    Retrieves non-serialized inventory item from a given supplier
31
    Retrieves non-serialized inventory item from a given supplier
32
 
32
 
33
    Parameters:
33
    Parameters:
-
 
34
     - itemNumber
34
     - itemId
35
     - itemId
35
     - warehouseId
-
 
36
    """
-
 
37
    pass
-
 
38
 
-
 
39
  def scanSerializedItem(self, inventoryItem, type, billingWarehouseId):
-
 
40
    """
-
 
41
    Scan serialized items.
-
 
42
 
-
 
43
    Parameters:
-
 
44
     - inventoryItem
-
 
45
     - type
-
 
46
     - billingWarehouseId
36
     - fulfilmentWarehouseId
47
    """
37
    """
48
    pass
38
    pass
49
 
39
 
50
  def scan(self, inventoryItem, type, quantity, billingWarehouseId):
40
  def scan(self, inventoryItem, type, quantity, billingWarehouseId):
51
    """
41
    """
Line 189... Line 179...
189
      return result.success
179
      return result.success
190
    if result.wex is not None:
180
    if result.wex is not None:
191
      raise result.wex
181
      raise result.wex
192
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItem failed: unknown result");
182
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getInventoryItem failed: unknown result");
193
 
183
 
194
  def getNonSeralizedInventoryItem(self, itemId, warehouseId):
184
  def getNonSeralizedInventoryItem(self, itemNumber, itemId, fulfilmentWarehouseId):
195
    """
185
    """
196
    Retrieves non-serialized inventory item from a given supplier
186
    Retrieves non-serialized inventory item from a given supplier
197
 
187
 
198
    Parameters:
188
    Parameters:
-
 
189
     - itemNumber
199
     - itemId
190
     - itemId
200
     - warehouseId
191
     - fulfilmentWarehouseId
201
    """
192
    """
202
    self.send_getNonSeralizedInventoryItem(itemId, warehouseId)
193
    self.send_getNonSeralizedInventoryItem(itemNumber, itemId, fulfilmentWarehouseId)
203
    return self.recv_getNonSeralizedInventoryItem()
194
    return self.recv_getNonSeralizedInventoryItem()
204
 
195
 
205
  def send_getNonSeralizedInventoryItem(self, itemId, warehouseId):
196
  def send_getNonSeralizedInventoryItem(self, itemNumber, itemId, fulfilmentWarehouseId):
206
    self._oprot.writeMessageBegin('getNonSeralizedInventoryItem', TMessageType.CALL, self._seqid)
197
    self._oprot.writeMessageBegin('getNonSeralizedInventoryItem', TMessageType.CALL, self._seqid)
207
    args = getNonSeralizedInventoryItem_args()
198
    args = getNonSeralizedInventoryItem_args()
-
 
199
    args.itemNumber = itemNumber
208
    args.itemId = itemId
200
    args.itemId = itemId
209
    args.warehouseId = warehouseId
201
    args.fulfilmentWarehouseId = fulfilmentWarehouseId
210
    args.write(self._oprot)
202
    args.write(self._oprot)
211
    self._oprot.writeMessageEnd()
203
    self._oprot.writeMessageEnd()
212
    self._oprot.trans.flush()
204
    self._oprot.trans.flush()
213
 
205
 
214
  def recv_getNonSeralizedInventoryItem(self, ):
206
  def recv_getNonSeralizedInventoryItem(self, ):
Line 225... Line 217...
225
      return result.success
217
      return result.success
226
    if result.wex is not None:
218
    if result.wex is not None:
227
      raise result.wex
219
      raise result.wex
228
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getNonSeralizedInventoryItem failed: unknown result");
220
    raise TApplicationException(TApplicationException.MISSING_RESULT, "getNonSeralizedInventoryItem failed: unknown result");
229
 
221
 
230
  def scanSerializedItem(self, inventoryItem, type, billingWarehouseId):
-
 
231
    """
-
 
232
    Scan serialized items.
-
 
233
 
-
 
234
    Parameters:
-
 
235
     - inventoryItem
-
 
236
     - type
-
 
237
     - billingWarehouseId
-
 
238
    """
-
 
239
    self.send_scanSerializedItem(inventoryItem, type, billingWarehouseId)
-
 
240
    self.recv_scanSerializedItem()
-
 
241
 
-
 
242
  def send_scanSerializedItem(self, inventoryItem, type, billingWarehouseId):
-
 
243
    self._oprot.writeMessageBegin('scanSerializedItem', TMessageType.CALL, self._seqid)
-
 
244
    args = scanSerializedItem_args()
-
 
245
    args.inventoryItem = inventoryItem
-
 
246
    args.type = type
-
 
247
    args.billingWarehouseId = billingWarehouseId
-
 
248
    args.write(self._oprot)
-
 
249
    self._oprot.writeMessageEnd()
-
 
250
    self._oprot.trans.flush()
-
 
251
 
-
 
252
  def recv_scanSerializedItem(self, ):
-
 
253
    (fname, mtype, rseqid) = self._iprot.readMessageBegin()
-
 
254
    if mtype == TMessageType.EXCEPTION:
-
 
255
      x = TApplicationException()
-
 
256
      x.read(self._iprot)
-
 
257
      self._iprot.readMessageEnd()
-
 
258
      raise x
-
 
259
    result = scanSerializedItem_result()
-
 
260
    result.read(self._iprot)
-
 
261
    self._iprot.readMessageEnd()
-
 
262
    if result.wex is not None:
-
 
263
      raise result.wex
-
 
264
    return
-
 
265
 
-
 
266
  def scan(self, inventoryItem, type, quantity, billingWarehouseId):
222
  def scan(self, inventoryItem, type, quantity, billingWarehouseId):
267
    """
223
    """
268
    Scan non-serialized items.
224
    Scan non-serialized items.
269
 
225
 
270
    Parameters:
226
    Parameters:
Line 623... Line 579...
623
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
579
class Processor(shop2020.thriftpy.generic.GenericService.Processor, Iface, TProcessor):
624
  def __init__(self, handler):
580
  def __init__(self, handler):
625
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
581
    shop2020.thriftpy.generic.GenericService.Processor.__init__(self, handler)
626
    self._processMap["getInventoryItem"] = Processor.process_getInventoryItem
582
    self._processMap["getInventoryItem"] = Processor.process_getInventoryItem
627
    self._processMap["getNonSeralizedInventoryItem"] = Processor.process_getNonSeralizedInventoryItem
583
    self._processMap["getNonSeralizedInventoryItem"] = Processor.process_getNonSeralizedInventoryItem
628
    self._processMap["scanSerializedItem"] = Processor.process_scanSerializedItem
-
 
629
    self._processMap["scan"] = Processor.process_scan
584
    self._processMap["scan"] = Processor.process_scan
630
    self._processMap["scanSerializedItemForOrder"] = Processor.process_scanSerializedItemForOrder
585
    self._processMap["scanSerializedItemForOrder"] = Processor.process_scanSerializedItemForOrder
631
    self._processMap["scanForOrder"] = Processor.process_scanForOrder
586
    self._processMap["scanForOrder"] = Processor.process_scanForOrder
632
    self._processMap["createItemNumberMapping"] = Processor.process_createItemNumberMapping
587
    self._processMap["createItemNumberMapping"] = Processor.process_createItemNumberMapping
633
    self._processMap["getItemNumbers"] = Processor.process_getItemNumbers
588
    self._processMap["getItemNumbers"] = Processor.process_getItemNumbers
Line 670... Line 625...
670
    args = getNonSeralizedInventoryItem_args()
625
    args = getNonSeralizedInventoryItem_args()
671
    args.read(iprot)
626
    args.read(iprot)
672
    iprot.readMessageEnd()
627
    iprot.readMessageEnd()
673
    result = getNonSeralizedInventoryItem_result()
628
    result = getNonSeralizedInventoryItem_result()
674
    try:
629
    try:
675
      result.success = self._handler.getNonSeralizedInventoryItem(args.itemId, args.warehouseId)
630
      result.success = self._handler.getNonSeralizedInventoryItem(args.itemNumber, args.itemId, args.fulfilmentWarehouseId)
676
    except WarehouseServiceException, wex:
631
    except WarehouseServiceException, wex:
677
      result.wex = wex
632
      result.wex = wex
678
    oprot.writeMessageBegin("getNonSeralizedInventoryItem", TMessageType.REPLY, seqid)
633
    oprot.writeMessageBegin("getNonSeralizedInventoryItem", TMessageType.REPLY, seqid)
679
    result.write(oprot)
634
    result.write(oprot)
680
    oprot.writeMessageEnd()
635
    oprot.writeMessageEnd()
681
    oprot.trans.flush()
636
    oprot.trans.flush()
682
 
637
 
683
  def process_scanSerializedItem(self, seqid, iprot, oprot):
-
 
684
    args = scanSerializedItem_args()
-
 
685
    args.read(iprot)
-
 
686
    iprot.readMessageEnd()
-
 
687
    result = scanSerializedItem_result()
-
 
688
    try:
-
 
689
      self._handler.scanSerializedItem(args.inventoryItem, args.type, args.billingWarehouseId)
-
 
690
    except WarehouseServiceException, wex:
-
 
691
      result.wex = wex
-
 
692
    oprot.writeMessageBegin("scanSerializedItem", TMessageType.REPLY, seqid)
-
 
693
    result.write(oprot)
-
 
694
    oprot.writeMessageEnd()
-
 
695
    oprot.trans.flush()
-
 
696
 
-
 
697
  def process_scan(self, seqid, iprot, oprot):
638
  def process_scan(self, seqid, iprot, oprot):
698
    args = scan_args()
639
    args = scan_args()
699
    args.read(iprot)
640
    args.read(iprot)
700
    iprot.readMessageEnd()
641
    iprot.readMessageEnd()
701
    result = scan_result()
642
    result = scan_result()
Line 956... Line 897...
956
    return not (self == other)
897
    return not (self == other)
957
 
898
 
958
class getNonSeralizedInventoryItem_args:
899
class getNonSeralizedInventoryItem_args:
959
  """
900
  """
960
  Attributes:
901
  Attributes:
-
 
902
   - itemNumber
961
   - itemId
903
   - itemId
962
   - warehouseId
904
   - fulfilmentWarehouseId
963
  """
905
  """
964
 
906
 
965
  thrift_spec = (
907
  thrift_spec = (
966
    None, # 0
908
    None, # 0
-
 
909
    (1, TType.STRING, 'itemNumber', None, None, ), # 1
967
    (1, TType.I64, 'itemId', None, None, ), # 1
910
    (2, TType.I64, 'itemId', None, None, ), # 2
968
    (2, TType.I64, 'warehouseId', None, None, ), # 2
911
    (3, TType.I64, 'fulfilmentWarehouseId', None, None, ), # 3
969
  )
912
  )
970
 
913
 
971
  def __init__(self, itemId=None, warehouseId=None,):
914
  def __init__(self, itemNumber=None, itemId=None, fulfilmentWarehouseId=None,):
-
 
915
    self.itemNumber = itemNumber
972
    self.itemId = itemId
916
    self.itemId = itemId
973
    self.warehouseId = warehouseId
917
    self.fulfilmentWarehouseId = fulfilmentWarehouseId
974
 
918
 
975
  def read(self, iprot):
919
  def read(self, iprot):
976
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
920
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
977
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
921
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
978
      return
922
      return
Line 980... Line 924...
980
    while True:
924
    while True:
981
      (fname, ftype, fid) = iprot.readFieldBegin()
925
      (fname, ftype, fid) = iprot.readFieldBegin()
982
      if ftype == TType.STOP:
926
      if ftype == TType.STOP:
983
        break
927
        break
984
      if fid == 1:
928
      if fid == 1:
-
 
929
        if ftype == TType.STRING:
-
 
930
          self.itemNumber = iprot.readString();
-
 
931
        else:
-
 
932
          iprot.skip(ftype)
-
 
933
      elif fid == 2:
985
        if ftype == TType.I64:
934
        if ftype == TType.I64:
986
          self.itemId = iprot.readI64();
935
          self.itemId = iprot.readI64();
987
        else:
936
        else:
988
          iprot.skip(ftype)
937
          iprot.skip(ftype)
989
      elif fid == 2:
938
      elif fid == 3:
990
        if ftype == TType.I64:
939
        if ftype == TType.I64:
991
          self.warehouseId = iprot.readI64();
940
          self.fulfilmentWarehouseId = iprot.readI64();
992
        else:
941
        else:
993
          iprot.skip(ftype)
942
          iprot.skip(ftype)
994
      else:
943
      else:
995
        iprot.skip(ftype)
944
        iprot.skip(ftype)
996
      iprot.readFieldEnd()
945
      iprot.readFieldEnd()
Line 999... Line 948...
999
  def write(self, oprot):
948
  def write(self, oprot):
1000
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
949
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1001
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
950
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1002
      return
951
      return
1003
    oprot.writeStructBegin('getNonSeralizedInventoryItem_args')
952
    oprot.writeStructBegin('getNonSeralizedInventoryItem_args')
-
 
953
    if self.itemNumber is not None:
-
 
954
      oprot.writeFieldBegin('itemNumber', TType.STRING, 1)
-
 
955
      oprot.writeString(self.itemNumber)
-
 
956
      oprot.writeFieldEnd()
1004
    if self.itemId is not None:
957
    if self.itemId is not None:
1005
      oprot.writeFieldBegin('itemId', TType.I64, 1)
958
      oprot.writeFieldBegin('itemId', TType.I64, 2)
1006
      oprot.writeI64(self.itemId)
959
      oprot.writeI64(self.itemId)
1007
      oprot.writeFieldEnd()
960
      oprot.writeFieldEnd()
1008
    if self.warehouseId is not None:
961
    if self.fulfilmentWarehouseId is not None:
1009
      oprot.writeFieldBegin('warehouseId', TType.I64, 2)
962
      oprot.writeFieldBegin('fulfilmentWarehouseId', TType.I64, 3)
1010
      oprot.writeI64(self.warehouseId)
963
      oprot.writeI64(self.fulfilmentWarehouseId)
1011
      oprot.writeFieldEnd()
964
      oprot.writeFieldEnd()
1012
    oprot.writeFieldStop()
965
    oprot.writeFieldStop()
1013
    oprot.writeStructEnd()
966
    oprot.writeStructEnd()
1014
 
967
 
1015
  def validate(self):
968
  def validate(self):
Line 1081... Line 1034...
1081
    if self.wex is not None:
1034
    if self.wex is not None:
1082
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
1035
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
1083
      self.wex.write(oprot)
1036
      self.wex.write(oprot)
1084
      oprot.writeFieldEnd()
1037
      oprot.writeFieldEnd()
1085
    oprot.writeFieldStop()
1038
    oprot.writeFieldStop()
1086
    oprot.writeStructEnd()
-
 
1087
 
-
 
1088
  def validate(self):
-
 
1089
    return
-
 
1090
 
-
 
1091
 
-
 
1092
  def __repr__(self):
-
 
1093
    L = ['%s=%r' % (key, value)
-
 
1094
      for key, value in self.__dict__.iteritems()]
-
 
1095
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
1096
 
-
 
1097
  def __eq__(self, other):
-
 
1098
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
1099
 
-
 
1100
  def __ne__(self, other):
-
 
1101
    return not (self == other)
-
 
1102
 
-
 
1103
class scanSerializedItem_args:
-
 
1104
  """
-
 
1105
  Attributes:
-
 
1106
   - inventoryItem
-
 
1107
   - type
-
 
1108
   - billingWarehouseId
-
 
1109
  """
-
 
1110
 
-
 
1111
  thrift_spec = (
-
 
1112
    None, # 0
-
 
1113
    (1, TType.STRUCT, 'inventoryItem', (InventoryItem, InventoryItem.thrift_spec), None, ), # 1
-
 
1114
    (2, TType.I32, 'type', None, None, ), # 2
-
 
1115
    (3, TType.I64, 'billingWarehouseId', None, None, ), # 3
-
 
1116
  )
-
 
1117
 
-
 
1118
  def __init__(self, inventoryItem=None, type=None, billingWarehouseId=None,):
-
 
1119
    self.inventoryItem = inventoryItem
-
 
1120
    self.type = type
-
 
1121
    self.billingWarehouseId = billingWarehouseId
-
 
1122
 
-
 
1123
  def read(self, iprot):
-
 
1124
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
1125
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
1126
      return
-
 
1127
    iprot.readStructBegin()
-
 
1128
    while True:
-
 
1129
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
1130
      if ftype == TType.STOP:
-
 
1131
        break
-
 
1132
      if fid == 1:
-
 
1133
        if ftype == TType.STRUCT:
-
 
1134
          self.inventoryItem = InventoryItem()
-
 
1135
          self.inventoryItem.read(iprot)
-
 
1136
        else:
-
 
1137
          iprot.skip(ftype)
-
 
1138
      elif fid == 2:
-
 
1139
        if ftype == TType.I32:
-
 
1140
          self.type = iprot.readI32();
-
 
1141
        else:
-
 
1142
          iprot.skip(ftype)
-
 
1143
      elif fid == 3:
-
 
1144
        if ftype == TType.I64:
-
 
1145
          self.billingWarehouseId = iprot.readI64();
-
 
1146
        else:
-
 
1147
          iprot.skip(ftype)
-
 
1148
      else:
-
 
1149
        iprot.skip(ftype)
-
 
1150
      iprot.readFieldEnd()
-
 
1151
    iprot.readStructEnd()
-
 
1152
 
-
 
1153
  def write(self, oprot):
-
 
1154
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
1155
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
1156
      return
-
 
1157
    oprot.writeStructBegin('scanSerializedItem_args')
-
 
1158
    if self.inventoryItem is not None:
-
 
1159
      oprot.writeFieldBegin('inventoryItem', TType.STRUCT, 1)
-
 
1160
      self.inventoryItem.write(oprot)
-
 
1161
      oprot.writeFieldEnd()
-
 
1162
    if self.type is not None:
-
 
1163
      oprot.writeFieldBegin('type', TType.I32, 2)
-
 
1164
      oprot.writeI32(self.type)
-
 
1165
      oprot.writeFieldEnd()
-
 
1166
    if self.billingWarehouseId is not None:
-
 
1167
      oprot.writeFieldBegin('billingWarehouseId', TType.I64, 3)
-
 
1168
      oprot.writeI64(self.billingWarehouseId)
-
 
1169
      oprot.writeFieldEnd()
-
 
1170
    oprot.writeFieldStop()
-
 
1171
    oprot.writeStructEnd()
-
 
1172
 
-
 
1173
  def validate(self):
-
 
1174
    return
-
 
1175
 
-
 
1176
 
-
 
1177
  def __repr__(self):
-
 
1178
    L = ['%s=%r' % (key, value)
-
 
1179
      for key, value in self.__dict__.iteritems()]
-
 
1180
    return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
 
1181
 
-
 
1182
  def __eq__(self, other):
-
 
1183
    return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
 
1184
 
-
 
1185
  def __ne__(self, other):
-
 
1186
    return not (self == other)
-
 
1187
 
-
 
1188
class scanSerializedItem_result:
-
 
1189
  """
-
 
1190
  Attributes:
-
 
1191
   - wex
-
 
1192
  """
-
 
1193
 
-
 
1194
  thrift_spec = (
-
 
1195
    None, # 0
-
 
1196
    (1, TType.STRUCT, 'wex', (WarehouseServiceException, WarehouseServiceException.thrift_spec), None, ), # 1
-
 
1197
  )
-
 
1198
 
-
 
1199
  def __init__(self, wex=None,):
-
 
1200
    self.wex = wex
-
 
1201
 
-
 
1202
  def read(self, iprot):
-
 
1203
    if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
-
 
1204
      fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
-
 
1205
      return
-
 
1206
    iprot.readStructBegin()
-
 
1207
    while True:
-
 
1208
      (fname, ftype, fid) = iprot.readFieldBegin()
-
 
1209
      if ftype == TType.STOP:
-
 
1210
        break
-
 
1211
      if fid == 1:
-
 
1212
        if ftype == TType.STRUCT:
-
 
1213
          self.wex = WarehouseServiceException()
-
 
1214
          self.wex.read(iprot)
-
 
1215
        else:
-
 
1216
          iprot.skip(ftype)
-
 
1217
      else:
-
 
1218
        iprot.skip(ftype)
-
 
1219
      iprot.readFieldEnd()
-
 
1220
    iprot.readStructEnd()
-
 
1221
 
-
 
1222
  def write(self, oprot):
-
 
1223
    if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
-
 
1224
      oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
-
 
1225
      return
-
 
1226
    oprot.writeStructBegin('scanSerializedItem_result')
-
 
1227
    if self.wex is not None:
-
 
1228
      oprot.writeFieldBegin('wex', TType.STRUCT, 1)
-
 
1229
      self.wex.write(oprot)
-
 
1230
      oprot.writeFieldEnd()
-
 
1231
    oprot.writeFieldStop()
-
 
1232
    oprot.writeStructEnd()
1039
    oprot.writeStructEnd()
1233
 
1040
 
1234
  def validate(self):
1041
  def validate(self):
1235
    return
1042
    return
1236
 
1043