WebSVN – SmartDukaan – Diff – /trunk/ThriftConfig/src/main/java/in/shop2020/model/v1/catalog/CatalogService.java

     public PrivateDeal getPrivateDealDetails(long item_id) throws org.apache.thrift.TException;
     public List<Item> getPrivateDealItems(long offset, long limit) throws org.apache.thrift.TException;
-    public Map<Long,PrivateDeal> getAllActivePrivateDeals() throws org.apache.thrift.TException;
+    public Map<Long,PrivateDeal> getAllActivePrivateDeals(List<Long> itemIds, long daysDelta) throws org.apache.thrift.TException;
     public boolean addOrUpdatePrivateDeal(PrivateDeal privateDeal) throws org.apache.thrift.TException;
     public List<Long> getPrivateDealsCatalogIds(long beginIndex, long totalItems) throws CatalogServiceException, org.apache.thrift.TException;
     public void getPrivateDealDetails(long item_id, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getPrivateDealDetails_call> resultHandler) throws org.apache.thrift.TException;
     public void getPrivateDealItems(long offset, long limit, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getPrivateDealItems_call> resultHandler) throws org.apache.thrift.TException;
-    public void getAllActivePrivateDeals(org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getAllActivePrivateDeals_call> resultHandler) throws org.apache.thrift.TException;
+    public void getAllActivePrivateDeals(List<Long> itemIds, long daysDelta, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getAllActivePrivateDeals_call> resultHandler) throws org.apache.thrift.TException;
     public void addOrUpdatePrivateDeal(PrivateDeal privateDeal, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.addOrUpdatePrivateDeal_call> resultHandler) throws org.apache.thrift.TException;
     public void getPrivateDealsCatalogIds(long beginIndex, long totalItems, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.getPrivateDealsCatalogIds_call> resultHandler) throws org.apache.thrift.TException;
         return result.success;
+      }
       throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "getPrivateDealItems failed: unknown result");
+    }
-    public Map<Long,PrivateDeal> getAllActivePrivateDeals() throws org.apache.thrift.TException
+    public Map<Long,PrivateDeal> getAllActivePrivateDeals(List<Long> itemIds, long daysDelta) throws org.apache.thrift.TException
+    {
-      send_getAllActivePrivateDeals();
+      send_getAllActivePrivateDeals(itemIds, daysDelta);
       return recv_getAllActivePrivateDeals();
+    }
-    public void send_getAllActivePrivateDeals() throws org.apache.thrift.TException
+    public void send_getAllActivePrivateDeals(List<Long> itemIds, long daysDelta) throws org.apache.thrift.TException
+    {
       getAllActivePrivateDeals_args args = new getAllActivePrivateDeals_args();
+      args.setItemIds(itemIds);
+      args.setDaysDelta(daysDelta);
       sendBase("getAllActivePrivateDeals", args);
+    }
     public Map<Long,PrivateDeal> recv_getAllActivePrivateDeals() throws org.apache.thrift.TException
+    {
         org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);
         return (new Client(prot)).recv_getPrivateDealItems();
+      }
+    }
-    public void getAllActivePrivateDeals(org.apache.thrift.async.AsyncMethodCallback<getAllActivePrivateDeals_call> resultHandler) throws org.apache.thrift.TException {
+    public void getAllActivePrivateDeals(List<Long> itemIds, long daysDelta, org.apache.thrift.async.AsyncMethodCallback<getAllActivePrivateDeals_call> resultHandler) throws org.apache.thrift.TException {
       checkReady();
-      getAllActivePrivateDeals_call method_call = new getAllActivePrivateDeals_call(resultHandler, this, ___protocolFactory, ___transport);
+      getAllActivePrivateDeals_call method_call = new getAllActivePrivateDeals_call(itemIds, daysDelta, resultHandler, this, ___protocolFactory, ___transport);
       this.___currentMethod = method_call;
       ___manager.call(method_call);
+    }
     public static class getAllActivePrivateDeals_call extends org.apache.thrift.async.TAsyncMethodCall {
+      private List<Long> itemIds;
+      private long daysDelta;
-      public getAllActivePrivateDeals_call(org.apache.thrift.async.AsyncMethodCallback<getAllActivePrivateDeals_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
+      public getAllActivePrivateDeals_call(List<Long> itemIds, long daysDelta, org.apache.thrift.async.AsyncMethodCallback<getAllActivePrivateDeals_call> resultHandler, org.apache.thrift.async.TAsyncClient client, org.apache.thrift.protocol.TProtocolFactory protocolFactory, org.apache.thrift.transport.TNonblockingTransport transport) throws org.apache.thrift.TException {
         super(client, protocolFactory, transport, resultHandler, false);
+        this.itemIds = itemIds;
+        this.daysDelta = daysDelta;
+      }
       public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {
         prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("getAllActivePrivateDeals", org.apache.thrift.protocol.TMessageType.CALL, 0));
         getAllActivePrivateDeals_args args = new getAllActivePrivateDeals_args();
+        args.setItemIds(itemIds);
+        args.setDaysDelta(daysDelta);
         args.write(prot);
         prot.writeMessageEnd();
+      }
       public Map<Long,PrivateDeal> getResult() throws org.apache.thrift.TException {
         return new getAllActivePrivateDeals_args();
+      }
       protected getAllActivePrivateDeals_result getResult(I iface, getAllActivePrivateDeals_args args) throws org.apache.thrift.TException {
         getAllActivePrivateDeals_result result = new getAllActivePrivateDeals_result();
-        result.success = iface.getAllActivePrivateDeals();
+        result.success = iface.getAllActivePrivateDeals(args.itemIds, args.daysDelta);
         return result;
+      }
+    }
     private static class addOrUpdatePrivateDeal<I extends Iface> extends org.apache.thrift.ProcessFunction<I, addOrUpdatePrivateDeal_args> {
+  }
   public static class getAllActivePrivateDeals_args implements org.apache.thrift.TBase<getAllActivePrivateDeals_args, getAllActivePrivateDeals_args._Fields>, java.io.Serializable, Cloneable   {
     private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("getAllActivePrivateDeals_args");
+    private static final org.apache.thrift.protocol.TField ITEM_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("itemIds", org.apache.thrift.protocol.TType.LIST, (short)1);
+    private static final org.apache.thrift.protocol.TField DAYS_DELTA_FIELD_DESC = new org.apache.thrift.protocol.TField("daysDelta", org.apache.thrift.protocol.TType.I64, (short)2);
+    private List<Long> itemIds; // required
+    private long daysDelta; // required
     /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
     public enum _Fields implements org.apache.thrift.TFieldIdEnum {
-;
+      ITEM_IDS((short)1, "itemIds"),
+      DAYS_DELTA((short)2, "daysDelta");
       private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
       static {
         for (_Fields field : EnumSet.allOf(_Fields.class)) {
       /**
        * Find the _Fields constant that matches fieldId, or null if its not found.
        */
       public static _Fields findByThriftId(int fieldId) {
         switch(fieldId) {
+          case 1: // ITEM_IDS
+            return ITEM_IDS;
+          case 2: // DAYS_DELTA
+            return DAYS_DELTA;
           default:
             return null;
+        }
+      }
       public String getFieldName() {
         return _fieldName;
+      }
+    }
+    // isset id assignments
+    private static final int __DAYSDELTA_ISSET_ID = 0;
+    private BitSet __isset_bit_vector = new BitSet(1);
     public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap;
     static {
       Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class);
+      tmpMap.put(_Fields.ITEM_IDS, new org.apache.thrift.meta_data.FieldMetaData("itemIds", org.apache.thrift.TFieldRequirementType.DEFAULT,
+          new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))));
+      tmpMap.put(_Fields.DAYS_DELTA, new org.apache.thrift.meta_data.FieldMetaData("daysDelta", org.apache.thrift.TFieldRequirementType.DEFAULT,
+          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
       metaDataMap = Collections.unmodifiableMap(tmpMap);
       org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(getAllActivePrivateDeals_args.class, metaDataMap);
+    }
     public getAllActivePrivateDeals_args() {
+    }
+    public getAllActivePrivateDeals_args(
+      List<Long> itemIds,
+      long daysDelta)
+    {
+      this();
+      this.itemIds = itemIds;
+      this.daysDelta = daysDelta;
+      setDaysDeltaIsSet(true);
+    }
     /**
      * Performs a deep copy on <i>other</i>.
      */
     public getAllActivePrivateDeals_args(getAllActivePrivateDeals_args other) {
+      __isset_bit_vector.clear();
+      __isset_bit_vector.or(other.__isset_bit_vector);
+      if (other.isSetItemIds()) {
+        List<Long> __this__itemIds = new ArrayList<Long>();
+        for (Long other_element : other.itemIds) {
+          __this__itemIds.add(other_element);
+        }
+        this.itemIds = __this__itemIds;
+      }
+      this.daysDelta = other.daysDelta;
+    }
     public getAllActivePrivateDeals_args deepCopy() {
       return new getAllActivePrivateDeals_args(this);
+    }
     @Override
     public void clear() {
+      this.itemIds = null;
+      setDaysDeltaIsSet(false);
+      this.daysDelta = 0;
+    }
+    public int getItemIdsSize() {
+      return (this.itemIds == null) ? 0 : this.itemIds.size();
+    }
+    public java.util.Iterator<Long> getItemIdsIterator() {
+      return (this.itemIds == null) ? null : this.itemIds.iterator();
+    }
+    public void addToItemIds(long elem) {
+      if (this.itemIds == null) {
+        this.itemIds = new ArrayList<Long>();
+      }
+      this.itemIds.add(elem);
+    }
+    public List<Long> getItemIds() {
+      return this.itemIds;
+    }
+    public void setItemIds(List<Long> itemIds) {
+      this.itemIds = itemIds;
+    }
+    public void unsetItemIds() {
+      this.itemIds = null;
+    }
+    /** Returns true if field itemIds is set (has been assigned a value) and false otherwise */
+    public boolean isSetItemIds() {
+      return this.itemIds != null;
+    }
+    public void setItemIdsIsSet(boolean value) {
+      if (!value) {
+        this.itemIds = null;
+      }
+    }
+    public long getDaysDelta() {
+      return this.daysDelta;
+    }
+    public void setDaysDelta(long daysDelta) {
+      this.daysDelta = daysDelta;
+      setDaysDeltaIsSet(true);
+    }
+    public void unsetDaysDelta() {
+      __isset_bit_vector.clear(__DAYSDELTA_ISSET_ID);
+    }
+    /** Returns true if field daysDelta is set (has been assigned a value) and false otherwise */
+    public boolean isSetDaysDelta() {
+      return __isset_bit_vector.get(__DAYSDELTA_ISSET_ID);
+    }
+    public void setDaysDeltaIsSet(boolean value) {
+      __isset_bit_vector.set(__DAYSDELTA_ISSET_ID, value);
+    }
     public void setFieldValue(_Fields field, Object value) {
       switch (field) {
+      case ITEM_IDS:
+        if (value == null) {
+          unsetItemIds();
+        } else {
+          setItemIds((List<Long>)value);
+        }
+        break;
+      case DAYS_DELTA:
+        if (value == null) {
+          unsetDaysDelta();
+        } else {
+          setDaysDelta((Long)value);
+        }
+        break;
+      }
+    }
     public Object getFieldValue(_Fields field) {
       switch (field) {
+      case ITEM_IDS:
+        return getItemIds();
+      case DAYS_DELTA:
+        return Long.valueOf(getDaysDelta());
+      }
       throw new IllegalStateException();
+    }
     /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */
       if (field == null) {
         throw new IllegalArgumentException();
+      }
       switch (field) {
+      case ITEM_IDS:
+        return isSetItemIds();
+      case DAYS_DELTA:
+        return isSetDaysDelta();
+      }
       throw new IllegalStateException();
+    }
     @Override
     public boolean equals(getAllActivePrivateDeals_args that) {
       if (that == null)
         return false;
+      boolean this_present_itemIds = true && this.isSetItemIds();
+      boolean that_present_itemIds = true && that.isSetItemIds();
+      if (this_present_itemIds || that_present_itemIds) {
+        if (!(this_present_itemIds && that_present_itemIds))
+          return false;
+        if (!this.itemIds.equals(that.itemIds))
+          return false;
+      }
+      boolean this_present_daysDelta = true;
+      boolean that_present_daysDelta = true;
+      if (this_present_daysDelta || that_present_daysDelta) {
+        if (!(this_present_daysDelta && that_present_daysDelta))
+          return false;
+        if (this.daysDelta != that.daysDelta)
+          return false;
+      }
       return true;
+    }
     @Override
     public int hashCode() {
+      }
       int lastComparison = 0;
       getAllActivePrivateDeals_args typedOther = (getAllActivePrivateDeals_args)other;
+      lastComparison = Boolean.valueOf(isSetItemIds()).compareTo(typedOther.isSetItemIds());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetItemIds()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.itemIds, typedOther.itemIds);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
+      lastComparison = Boolean.valueOf(isSetDaysDelta()).compareTo(typedOther.isSetDaysDelta());
+      if (lastComparison != 0) {
+        return lastComparison;
+      }
+      if (isSetDaysDelta()) {
+        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.daysDelta, typedOther.daysDelta);
+        if (lastComparison != 0) {
+          return lastComparison;
+        }
+      }
       return 0;
+    }
     public _Fields fieldForId(int fieldId) {
       return _Fields.findByThriftId(fieldId);
         field = iprot.readFieldBegin();
         if (field.type == org.apache.thrift.protocol.TType.STOP) {
           break;
+        }
         switch (field.id) {
+          case 1: // ITEM_IDS
+            if (field.type == org.apache.thrift.protocol.TType.LIST) {
+              {
+                org.apache.thrift.protocol.TList _list373 = iprot.readListBegin();
+                this.itemIds = new ArrayList<Long>(_list373.size);
+                for (int _i374 = 0; _i374 < _list373.size; ++_i374)
+                {
+                  long _elem375; // required
+                  _elem375 = iprot.readI64();
+                  this.itemIds.add(_elem375);
+                }
+                iprot.readListEnd();
+              }
+            } else {
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
+          case 2: // DAYS_DELTA
+            if (field.type == org.apache.thrift.protocol.TType.I64) {
+              this.daysDelta = iprot.readI64();
+              setDaysDeltaIsSet(true);
+            } else {
+              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+            }
+            break;
           default:
             org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
+        }
         iprot.readFieldEnd();
+      }
     public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {
       validate();
       oprot.writeStructBegin(STRUCT_DESC);
+      if (this.itemIds != null) {
+        oprot.writeFieldBegin(ITEM_IDS_FIELD_DESC);
+        {
+          oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, this.itemIds.size()));
+          for (long _iter376 : this.itemIds)
+          {
+            oprot.writeI64(_iter376);
+          }
+          oprot.writeListEnd();
+        }
+        oprot.writeFieldEnd();
+      }
+      oprot.writeFieldBegin(DAYS_DELTA_FIELD_DESC);
+      oprot.writeI64(this.daysDelta);
+      oprot.writeFieldEnd();
       oprot.writeFieldStop();
       oprot.writeStructEnd();
+    }
     @Override
     public String toString() {
       StringBuilder sb = new StringBuilder("getAllActivePrivateDeals_args(");
       boolean first = true;
+      sb.append("itemIds:");
+      if (this.itemIds == null) {
+        sb.append("null");
+      } else {
+        sb.append(this.itemIds);
+      }
+      first = false;
+      if (!first) sb.append(", ");
+      sb.append("daysDelta:");
+      sb.append(this.daysDelta);
+      first = false;
       sb.append(")");
       return sb.toString();
+    }
     public void validate() throws org.apache.thrift.TException {
+      }
+    }
     private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {
       try {
+        // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
+        __isset_bit_vector = new BitSet(1);
         read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in)));
       } catch (org.apache.thrift.TException te) {
         throw new java.io.IOException(te);
+      }
+    }
+        }
         switch (field.id) {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.MAP) {
+              {
-                org.apache.thrift.protocol.TMap _map373 = iprot.readMapBegin();
+                org.apache.thrift.protocol.TMap _map377 = iprot.readMapBegin();
-                this.success = new HashMap<Long,PrivateDeal>(2*_map373.size);
+                this.success = new HashMap<Long,PrivateDeal>(2*_map377.size);
-                for (int _i374 = 0; _i374 < _map373.size; ++_i374)
+                for (int _i378 = 0; _i378 < _map377.size; ++_i378)
+                {
-                  long _key375; // required
+                  long _key379; // required
-                  PrivateDeal _val376; // required
+                  PrivateDeal _val380; // required
-                  _key375 = iprot.readI64();
+                  _key379 = iprot.readI64();
-                  _val376 = new PrivateDeal();
+                  _val380 = new PrivateDeal();
-                  _val376.read(iprot);
+                  _val380.read(iprot);
-                  this.success.put(_key375, _val376);
+                  this.success.put(_key379, _val380);
+                }
                 iprot.readMapEnd();
+              }
             } else {
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
       if (this.isSetSuccess()) {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+        {
           oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, this.success.size()));
-          for (Map.Entry<Long, PrivateDeal> _iter377 : this.success.entrySet())
+          for (Map.Entry<Long, PrivateDeal> _iter381 : this.success.entrySet())
+          {
-            oprot.writeI64(_iter377.getKey());
+            oprot.writeI64(_iter381.getKey());
-            _iter377.getValue().write(oprot);
+            _iter381.getValue().write(oprot);
+          }
           oprot.writeMapEnd();
+        }
         oprot.writeFieldEnd();
+      }
+        }
         switch (field.id) {
           case 0: // SUCCESS
             if (field.type == org.apache.thrift.protocol.TType.LIST) {
+              {
-                org.apache.thrift.protocol.TList _list378 = iprot.readListBegin();
+                org.apache.thrift.protocol.TList _list382 = iprot.readListBegin();
-                this.success = new ArrayList<Long>(_list378.size);
+                this.success = new ArrayList<Long>(_list382.size);
-                for (int _i379 = 0; _i379 < _list378.size; ++_i379)
+                for (int _i383 = 0; _i383 < _list382.size; ++_i383)
+                {
-                  long _elem380; // required
+                  long _elem384; // required
-                  _elem380 = iprot.readI64();
+                  _elem384 = iprot.readI64();
-                  this.success.add(_elem380);
+                  this.success.add(_elem384);
+                }
                 iprot.readListEnd();
+              }
             } else {
               org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);
       if (this.isSetSuccess()) {
         oprot.writeFieldBegin(SUCCESS_FIELD_DESC);
+        {
           oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, this.success.size()));
-          for (long _iter381 : this.success)
+          for (long _iter385 : this.success)
+          {
-            oprot.writeI64(_iter381);
+            oprot.writeI64(_iter385);
+          }
           oprot.writeListEnd();
+        }
         oprot.writeFieldEnd();
       } else if (this.isSetCex()) {

Subversion Repositories SmartDukaan

(root)/trunk/ThriftConfig/src/main/java/in/shop2020/model/v1/catalog/CatalogService.java – Rev 11645 → 11653