Subversion Repositories SmartDukaan

    /**

     * Marks the COD orders with given AWB nos. as having been processed.

     * Updates the captured amount for the corresponding payment.

     * 

     * Returns a map of AWBs which were not processed and the associated reason. An AWB is not processed if:

     * 1. There is no order corresponding to an AWB number.

     * 2. The captured amount for a payment exceeds the total payment.

     * 3. The order corresponding to an AWB no. is in a state prior to DELIVERY_SUCCESS.

     * 

     * @param collectedAmountMap

     * @param xferBy

     * @param xferTxnId

     * @param xferDate

     */

    public Map<String,String> reconcileCodCollection(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate) throws TransactionServiceException, org.apache.thrift.TException;

    public void reconcileCodCollection(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate, org.apache.thrift.async.AsyncMethodCallback<AsyncClient.reconcileCodCollection_call> resultHandler) throws org.apache.thrift.TException;

    public Map<String,String> reconcileCodCollection(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate) throws TransactionServiceException, org.apache.thrift.TException

    {

      send_reconcileCodCollection(collectedAmountMap, xferBy, xferTxnId, xferDate);

      return recv_reconcileCodCollection();

    }

    public void send_reconcileCodCollection(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate) throws org.apache.thrift.TException

    {

      reconcileCodCollection_args args = new reconcileCodCollection_args();

      args.setCollectedAmountMap(collectedAmountMap);

      args.setXferBy(xferBy);

      args.setXferTxnId(xferTxnId);

      args.setXferDate(xferDate);

      sendBase("reconcileCodCollection", args);

    }

    public Map<String,String> recv_reconcileCodCollection() throws TransactionServiceException, org.apache.thrift.TException

    {

      reconcileCodCollection_result result = new reconcileCodCollection_result();

      receiveBase(result, "reconcileCodCollection");

      if (result.isSetSuccess()) {

        return result.success;

      }

      if (result.ex != null) {

        throw result.ex;

      }

      throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "reconcileCodCollection failed: unknown result");

    }

    public void reconcileCodCollection(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate, org.apache.thrift.async.AsyncMethodCallback<reconcileCodCollection_call> resultHandler) throws org.apache.thrift.TException {

      checkReady();

      reconcileCodCollection_call method_call = new reconcileCodCollection_call(collectedAmountMap, xferBy, xferTxnId, xferDate, resultHandler, this, ___protocolFactory, ___transport);

      this.___currentMethod = method_call;

      ___manager.call(method_call);

    }

    public static class reconcileCodCollection_call extends org.apache.thrift.async.TAsyncMethodCall {

      private Map<String,Double> collectedAmountMap;

      private String xferBy;

      private String xferTxnId;

      private long xferDate;

      public reconcileCodCollection_call(Map<String,Double> collectedAmountMap, String xferBy, String xferTxnId, long xferDate, org.apache.thrift.async.AsyncMethodCallback<reconcileCodCollection_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.collectedAmountMap = collectedAmountMap;

        this.xferBy = xferBy;

        this.xferTxnId = xferTxnId;

        this.xferDate = xferDate;

      }

      public void write_args(org.apache.thrift.protocol.TProtocol prot) throws org.apache.thrift.TException {

        prot.writeMessageBegin(new org.apache.thrift.protocol.TMessage("reconcileCodCollection", org.apache.thrift.protocol.TMessageType.CALL, 0));

        reconcileCodCollection_args args = new reconcileCodCollection_args();

        args.setCollectedAmountMap(collectedAmountMap);

        args.setXferBy(xferBy);

        args.setXferTxnId(xferTxnId);

        args.setXferDate(xferDate);

        args.write(prot);

        prot.writeMessageEnd();

      }

      public Map<String,String> getResult() throws TransactionServiceException, org.apache.thrift.TException {

        if (getState() != org.apache.thrift.async.TAsyncMethodCall.State.RESPONSE_READ) {

          throw new IllegalStateException("Method call not finished!");

        }

        org.apache.thrift.transport.TMemoryInputTransport memoryTransport = new org.apache.thrift.transport.TMemoryInputTransport(getFrameBuffer().array());

        org.apache.thrift.protocol.TProtocol prot = client.getProtocolFactory().getProtocol(memoryTransport);

        return (new Client(prot)).recv_reconcileCodCollection();

      }

    }

      processMap.put("reconcileCodCollection", new reconcileCodCollection());

    private static class reconcileCodCollection<I extends Iface> extends org.apache.thrift.ProcessFunction<I, reconcileCodCollection_args> {

      public reconcileCodCollection() {

        super("reconcileCodCollection");

      }

      protected reconcileCodCollection_args getEmptyArgsInstance() {

        return new reconcileCodCollection_args();

      }

      protected reconcileCodCollection_result getResult(I iface, reconcileCodCollection_args args) throws org.apache.thrift.TException {

        reconcileCodCollection_result result = new reconcileCodCollection_result();

        try {

          result.success = iface.reconcileCodCollection(args.collectedAmountMap, args.xferBy, args.xferTxnId, args.xferDate);

        } catch (TransactionServiceException ex) {

          result.ex = ex;

        }

        return result;

      }

    }

      } else {

        sb.append(this.ex);

      }

      first = false;

      sb.append(")");

      return sb.toString();

    }

    public void validate() throws org.apache.thrift.TException {

      // check for required fields

    }

    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {

      try {

        write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));

      } catch (org.apache.thrift.TException te) {

        throw new java.io.IOException(te);

      }

    }

    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {

      try {

        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);

      }

    }

  }

  public static class reconcileCodCollection_args implements org.apache.thrift.TBase<reconcileCodCollection_args, reconcileCodCollection_args._Fields>, java.io.Serializable, Cloneable   {

    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("reconcileCodCollection_args");

    private static final org.apache.thrift.protocol.TField COLLECTED_AMOUNT_MAP_FIELD_DESC = new org.apache.thrift.protocol.TField("collectedAmountMap", org.apache.thrift.protocol.TType.MAP, (short)1);

    private static final org.apache.thrift.protocol.TField XFER_BY_FIELD_DESC = new org.apache.thrift.protocol.TField("xferBy", org.apache.thrift.protocol.TType.STRING, (short)2);

    private static final org.apache.thrift.protocol.TField XFER_TXN_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("xferTxnId", org.apache.thrift.protocol.TType.STRING, (short)3);

    private static final org.apache.thrift.protocol.TField XFER_DATE_FIELD_DESC = new org.apache.thrift.protocol.TField("xferDate", org.apache.thrift.protocol.TType.I64, (short)4);

    private Map<String,Double> collectedAmountMap; // required

    private String xferBy; // required

    private String xferTxnId; // required

    private long xferDate; // 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 {

      COLLECTED_AMOUNT_MAP((short)1, "collectedAmountMap"),

      XFER_BY((short)2, "xferBy"),

      XFER_TXN_ID((short)3, "xferTxnId"),

      XFER_DATE((short)4, "xferDate");

      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();

      static {

        for (_Fields field : EnumSet.allOf(_Fields.class)) {

          byName.put(field.getFieldName(), field);

        }

      }

      /**

       * Find the _Fields constant that matches fieldId, or null if its not found.

       */

      public static _Fields findByThriftId(int fieldId) {

        switch(fieldId) {

          case 1: // COLLECTED_AMOUNT_MAP

            return COLLECTED_AMOUNT_MAP;

          case 2: // XFER_BY

            return XFER_BY;

          case 3: // XFER_TXN_ID

            return XFER_TXN_ID;

          case 4: // XFER_DATE

            return XFER_DATE;

          default:

            return null;

        }

      }

      /**

       * Find the _Fields constant that matches fieldId, throwing an exception

       * if it is not found.

       */

      public static _Fields findByThriftIdOrThrow(int fieldId) {

        _Fields fields = findByThriftId(fieldId);

        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");

        return fields;

      }

      /**

       * Find the _Fields constant that matches name, or null if its not found.

       */

      public static _Fields findByName(String name) {

        return byName.get(name);

      }

      private final short _thriftId;

      private final String _fieldName;

      _Fields(short thriftId, String fieldName) {

        _thriftId = thriftId;

        _fieldName = fieldName;

      }

      public short getThriftFieldId() {

        return _thriftId;

      }

      public String getFieldName() {

        return _fieldName;

      }

    }

    // isset id assignments

    private static final int __XFERDATE_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.COLLECTED_AMOUNT_MAP, new org.apache.thrift.meta_data.FieldMetaData("collectedAmountMap", org.apache.thrift.TFieldRequirementType.DEFAULT, 

          new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, 

              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), 

              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.DOUBLE))));

      tmpMap.put(_Fields.XFER_BY, new org.apache.thrift.meta_data.FieldMetaData("xferBy", org.apache.thrift.TFieldRequirementType.DEFAULT, 

          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));

      tmpMap.put(_Fields.XFER_TXN_ID, new org.apache.thrift.meta_data.FieldMetaData("xferTxnId", org.apache.thrift.TFieldRequirementType.DEFAULT, 

          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));

      tmpMap.put(_Fields.XFER_DATE, new org.apache.thrift.meta_data.FieldMetaData("xferDate", 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(reconcileCodCollection_args.class, metaDataMap);

    }

    public reconcileCodCollection_args() {

    }

    public reconcileCodCollection_args(

      Map<String,Double> collectedAmountMap,

      String xferBy,

      String xferTxnId,

      long xferDate)

    {

      this();

      this.collectedAmountMap = collectedAmountMap;

      this.xferBy = xferBy;

      this.xferTxnId = xferTxnId;

      this.xferDate = xferDate;

      setXferDateIsSet(true);

    }

    /**

     * Performs a deep copy on <i>other</i>.

     */

    public reconcileCodCollection_args(reconcileCodCollection_args other) {

      __isset_bit_vector.clear();

      __isset_bit_vector.or(other.__isset_bit_vector);

      if (other.isSetCollectedAmountMap()) {

        Map<String,Double> __this__collectedAmountMap = new HashMap<String,Double>();

        for (Map.Entry<String, Double> other_element : other.collectedAmountMap.entrySet()) {

          String other_element_key = other_element.getKey();

          Double other_element_value = other_element.getValue();

          String __this__collectedAmountMap_copy_key = other_element_key;

          Double __this__collectedAmountMap_copy_value = other_element_value;

          __this__collectedAmountMap.put(__this__collectedAmountMap_copy_key, __this__collectedAmountMap_copy_value);

        }

        this.collectedAmountMap = __this__collectedAmountMap;

      }

      if (other.isSetXferBy()) {

        this.xferBy = other.xferBy;

      }

      if (other.isSetXferTxnId()) {

        this.xferTxnId = other.xferTxnId;

      }

      this.xferDate = other.xferDate;

    }

    public reconcileCodCollection_args deepCopy() {

      return new reconcileCodCollection_args(this);

    }

    @Override

    public void clear() {

      this.collectedAmountMap = null;

      this.xferBy = null;

      this.xferTxnId = null;

      setXferDateIsSet(false);

      this.xferDate = 0;

    }

    public int getCollectedAmountMapSize() {

      return (this.collectedAmountMap == null) ? 0 : this.collectedAmountMap.size();

    }

    public void putToCollectedAmountMap(String key, double val) {

      if (this.collectedAmountMap == null) {

        this.collectedAmountMap = new HashMap<String,Double>();

      }

      this.collectedAmountMap.put(key, val);

    }

    public Map<String,Double> getCollectedAmountMap() {

      return this.collectedAmountMap;

    }

    public void setCollectedAmountMap(Map<String,Double> collectedAmountMap) {

      this.collectedAmountMap = collectedAmountMap;

    }

    public void unsetCollectedAmountMap() {

      this.collectedAmountMap = null;

    }

    /** Returns true if field collectedAmountMap is set (has been assigned a value) and false otherwise */

    public boolean isSetCollectedAmountMap() {

      return this.collectedAmountMap != null;

    }

    public void setCollectedAmountMapIsSet(boolean value) {

      if (!value) {

        this.collectedAmountMap = null;

      }

    }

    public String getXferBy() {

      return this.xferBy;

    }

    public void setXferBy(String xferBy) {

      this.xferBy = xferBy;

    }

    public void unsetXferBy() {

      this.xferBy = null;

    }

    /** Returns true if field xferBy is set (has been assigned a value) and false otherwise */

    public boolean isSetXferBy() {

      return this.xferBy != null;

    }

    public void setXferByIsSet(boolean value) {

      if (!value) {

        this.xferBy = null;

      }

    }

    public String getXferTxnId() {

      return this.xferTxnId;

    }

    public void setXferTxnId(String xferTxnId) {

      this.xferTxnId = xferTxnId;

    }

    public void unsetXferTxnId() {

      this.xferTxnId = null;

    }

    /** Returns true if field xferTxnId is set (has been assigned a value) and false otherwise */

    public boolean isSetXferTxnId() {

      return this.xferTxnId != null;

    }

    public void setXferTxnIdIsSet(boolean value) {

      if (!value) {

        this.xferTxnId = null;

      }

    }

    public long getXferDate() {

      return this.xferDate;

    }

    public void setXferDate(long xferDate) {

      this.xferDate = xferDate;

      setXferDateIsSet(true);

    }

    public void unsetXferDate() {

      __isset_bit_vector.clear(__XFERDATE_ISSET_ID);

    }

    /** Returns true if field xferDate is set (has been assigned a value) and false otherwise */

    public boolean isSetXferDate() {

      return __isset_bit_vector.get(__XFERDATE_ISSET_ID);

    }

    public void setXferDateIsSet(boolean value) {

      __isset_bit_vector.set(__XFERDATE_ISSET_ID, value);

    }

    public void setFieldValue(_Fields field, Object value) {

      switch (field) {

      case COLLECTED_AMOUNT_MAP:

        if (value == null) {

          unsetCollectedAmountMap();

        } else {

          setCollectedAmountMap((Map<String,Double>)value);

        }

        break;

      case XFER_BY:

        if (value == null) {

          unsetXferBy();

        } else {

          setXferBy((String)value);

        }

        break;

      case XFER_TXN_ID:

        if (value == null) {

          unsetXferTxnId();

        } else {

          setXferTxnId((String)value);

        }

        break;

      case XFER_DATE:

        if (value == null) {

          unsetXferDate();

        } else {

          setXferDate((Long)value);

        }

        break;

      }

    }

    public Object getFieldValue(_Fields field) {

      switch (field) {

      case COLLECTED_AMOUNT_MAP:

        return getCollectedAmountMap();

      case XFER_BY:

        return getXferBy();

      case XFER_TXN_ID:

        return getXferTxnId();

      case XFER_DATE:

        return Long.valueOf(getXferDate());

      }

      throw new IllegalStateException();

    }

    /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */

    public boolean isSet(_Fields field) {

      if (field == null) {

        throw new IllegalArgumentException();

      }

      switch (field) {

      case COLLECTED_AMOUNT_MAP:

        return isSetCollectedAmountMap();

      case XFER_BY:

        return isSetXferBy();

      case XFER_TXN_ID:

        return isSetXferTxnId();

      case XFER_DATE:

        return isSetXferDate();

      }

      throw new IllegalStateException();

    }

    @Override

    public boolean equals(Object that) {

      if (that == null)

        return false;

      if (that instanceof reconcileCodCollection_args)

        return this.equals((reconcileCodCollection_args)that);

      return false;

    }

    public boolean equals(reconcileCodCollection_args that) {

      if (that == null)

        return false;

      boolean this_present_collectedAmountMap = true && this.isSetCollectedAmountMap();

      boolean that_present_collectedAmountMap = true && that.isSetCollectedAmountMap();

      if (this_present_collectedAmountMap || that_present_collectedAmountMap) {

        if (!(this_present_collectedAmountMap && that_present_collectedAmountMap))

          return false;

        if (!this.collectedAmountMap.equals(that.collectedAmountMap))

          return false;

      }

      boolean this_present_xferBy = true && this.isSetXferBy();

      boolean that_present_xferBy = true && that.isSetXferBy();

      if (this_present_xferBy || that_present_xferBy) {

        if (!(this_present_xferBy && that_present_xferBy))

          return false;

        if (!this.xferBy.equals(that.xferBy))

          return false;

      }

      boolean this_present_xferTxnId = true && this.isSetXferTxnId();

      boolean that_present_xferTxnId = true && that.isSetXferTxnId();

      if (this_present_xferTxnId || that_present_xferTxnId) {

        if (!(this_present_xferTxnId && that_present_xferTxnId))

          return false;

        if (!this.xferTxnId.equals(that.xferTxnId))

          return false;

      }

      boolean this_present_xferDate = true;

      boolean that_present_xferDate = true;

      if (this_present_xferDate || that_present_xferDate) {

        if (!(this_present_xferDate && that_present_xferDate))

          return false;

        if (this.xferDate != that.xferDate)

          return false;

      }

      return true;

    }

    @Override

    public int hashCode() {

      return 0;

    }

    public int compareTo(reconcileCodCollection_args other) {

      if (!getClass().equals(other.getClass())) {

        return getClass().getName().compareTo(other.getClass().getName());

      }

      int lastComparison = 0;

      reconcileCodCollection_args typedOther = (reconcileCodCollection_args)other;

      lastComparison = Boolean.valueOf(isSetCollectedAmountMap()).compareTo(typedOther.isSetCollectedAmountMap());

      if (lastComparison != 0) {

        return lastComparison;

      }

      if (isSetCollectedAmountMap()) {

        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.collectedAmountMap, typedOther.collectedAmountMap);

        if (lastComparison != 0) {

          return lastComparison;

        }

      }

      lastComparison = Boolean.valueOf(isSetXferBy()).compareTo(typedOther.isSetXferBy());

      if (lastComparison != 0) {

        return lastComparison;

      }

      if (isSetXferBy()) {

        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.xferBy, typedOther.xferBy);

        if (lastComparison != 0) {

          return lastComparison;

        }

      }

      lastComparison = Boolean.valueOf(isSetXferTxnId()).compareTo(typedOther.isSetXferTxnId());

      if (lastComparison != 0) {

        return lastComparison;

      }

      if (isSetXferTxnId()) {

        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.xferTxnId, typedOther.xferTxnId);

        if (lastComparison != 0) {

          return lastComparison;

        }

      }

      lastComparison = Boolean.valueOf(isSetXferDate()).compareTo(typedOther.isSetXferDate());

      if (lastComparison != 0) {

        return lastComparison;

      }

      if (isSetXferDate()) {

        lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.xferDate, typedOther.xferDate);

        if (lastComparison != 0) {

          return lastComparison;

        }

      }

      return 0;

    }

    public _Fields fieldForId(int fieldId) {

      return _Fields.findByThriftId(fieldId);

    }

    public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException {

      org.apache.thrift.protocol.TField field;

      iprot.readStructBegin();

      while (true)

      {

        field = iprot.readFieldBegin();

        if (field.type == org.apache.thrift.protocol.TType.STOP) { 

          break;

        }

        switch (field.id) {

          case 1: // COLLECTED_AMOUNT_MAP

            if (field.type == org.apache.thrift.protocol.TType.MAP) {

              {

                org.apache.thrift.protocol.TMap _map109 = iprot.readMapBegin();

                this.collectedAmountMap = new HashMap<String,Double>(2*_map109.size);

                for (int _i110 = 0; _i110 < _map109.size; ++_i110)

                {

                  String _key111; // required

                  double _val112; // required

                  _key111 = iprot.readString();

                  _val112 = iprot.readDouble();

                  this.collectedAmountMap.put(_key111, _val112);

                }

                iprot.readMapEnd();

              }

            } else { 

              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);

            }

            break;

          case 2: // XFER_BY

            if (field.type == org.apache.thrift.protocol.TType.STRING) {

              this.xferBy = iprot.readString();

            } else { 

              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);

            }

            break;

          case 3: // XFER_TXN_ID

            if (field.type == org.apache.thrift.protocol.TType.STRING) {

              this.xferTxnId = iprot.readString();

            } else { 

              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);

            }

            break;

          case 4: // XFER_DATE

            if (field.type == org.apache.thrift.protocol.TType.I64) {

              this.xferDate = iprot.readI64();

              setXferDateIsSet(true);

            } else { 

              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);

            }

            break;

          default:

            org.apache.thrift.protocol.TProtocolUtil.skip(iprot, field.type);

        }

        iprot.readFieldEnd();

      }

      iprot.readStructEnd();

      validate();

    }

    public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException {

      validate();

      oprot.writeStructBegin(STRUCT_DESC);

      if (this.collectedAmountMap != null) {

        oprot.writeFieldBegin(COLLECTED_AMOUNT_MAP_FIELD_DESC);

        {

          oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.DOUBLE, this.collectedAmountMap.size()));

          for (Map.Entry<String, Double> _iter113 : this.collectedAmountMap.entrySet())

          {

            oprot.writeString(_iter113.getKey());

            oprot.writeDouble(_iter113.getValue());

          }

          oprot.writeMapEnd();

        }

        oprot.writeFieldEnd();

      }

      if (this.xferBy != null) {

        oprot.writeFieldBegin(XFER_BY_FIELD_DESC);

        oprot.writeString(this.xferBy);

        oprot.writeFieldEnd();

      }

      if (this.xferTxnId != null) {

        oprot.writeFieldBegin(XFER_TXN_ID_FIELD_DESC);

        oprot.writeString(this.xferTxnId);

        oprot.writeFieldEnd();

      }

      oprot.writeFieldBegin(XFER_DATE_FIELD_DESC);

      oprot.writeI64(this.xferDate);

      oprot.writeFieldEnd();

      oprot.writeFieldStop();

      oprot.writeStructEnd();

    }

    @Override

    public String toString() {

      StringBuilder sb = new StringBuilder("reconcileCodCollection_args(");

      boolean first = true;

      sb.append("collectedAmountMap:");

      if (this.collectedAmountMap == null) {

        sb.append("null");

      } else {

        sb.append(this.collectedAmountMap);

      }

      first = false;

      if (!first) sb.append(", ");

      sb.append("xferBy:");

      if (this.xferBy == null) {

        sb.append("null");

      } else {

        sb.append(this.xferBy);

      }

      first = false;

      if (!first) sb.append(", ");

      sb.append("xferTxnId:");

      if (this.xferTxnId == null) {

        sb.append("null");

      } else {

        sb.append(this.xferTxnId);

      }

      first = false;

      if (!first) sb.append(", ");

      sb.append("xferDate:");

      sb.append(this.xferDate);

      first = false;

      sb.append(")");

      return sb.toString();

    }

    public void validate() throws org.apache.thrift.TException {

      // check for required fields

    }

    private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException {

      try {

        write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out)));

      } catch (org.apache.thrift.TException te) {

        throw new java.io.IOException(te);

      }

    }

    private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException {

      try {

        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);

      }

    }

  }

  public static class reconcileCodCollection_result implements org.apache.thrift.TBase<reconcileCodCollection_result, reconcileCodCollection_result._Fields>, java.io.Serializable, Cloneable   {

    private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("reconcileCodCollection_result");

    private static final org.apache.thrift.protocol.TField SUCCESS_FIELD_DESC = new org.apache.thrift.protocol.TField("success", org.apache.thrift.protocol.TType.MAP, (short)0);

    private static final org.apache.thrift.protocol.TField EX_FIELD_DESC = new org.apache.thrift.protocol.TField("ex", org.apache.thrift.protocol.TType.STRUCT, (short)1);

    private Map<String,String> success; // required

    private TransactionServiceException ex; // 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 {

      SUCCESS((short)0, "success"),

      EX((short)1, "ex");

      private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();

      static {

        for (_Fields field : EnumSet.allOf(_Fields.class)) {

          byName.put(field.getFieldName(), field);

        }

      }

      /**

       * Find the _Fields constant that matches fieldId, or null if its not found.

       */

      public static _Fields findByThriftId(int fieldId) {

        switch(fieldId) {

          case 0: // SUCCESS

            return SUCCESS;

          case 1: // EX

            return EX;

          default:

            return null;

        }

      }

      /**

       * Find the _Fields constant that matches fieldId, throwing an exception

       * if it is not found.

       */

      public static _Fields findByThriftIdOrThrow(int fieldId) {

        _Fields fields = findByThriftId(fieldId);

        if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!");

        return fields;

      }

      /**

       * Find the _Fields constant that matches name, or null if its not found.

       */

      public static _Fields findByName(String name) {

        return byName.get(name);

      }

      private final short _thriftId;

      private final String _fieldName;

      _Fields(short thriftId, String fieldName) {

        _thriftId = thriftId;

        _fieldName = fieldName;

      }

      public short getThriftFieldId() {

        return _thriftId;

      }

      public String getFieldName() {

        return _fieldName;

      }

    }

    // isset id assignments

    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.SUCCESS, new org.apache.thrift.meta_data.FieldMetaData("success", org.apache.thrift.TFieldRequirementType.DEFAULT, 

          new org.apache.thrift.meta_data.MapMetaData(org.apache.thrift.protocol.TType.MAP, 

              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING), 

              new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))));

      tmpMap.put(_Fields.EX, new org.apache.thrift.meta_data.FieldMetaData("ex", org.apache.thrift.TFieldRequirementType.DEFAULT, 

          new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRUCT)));

      metaDataMap = Collections.unmodifiableMap(tmpMap);

      org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(reconcileCodCollection_result.class, metaDataMap);

    }

    public reconcileCodCollection_result() {

    }

    public reconcileCodCollection_result(

      Map<String,String> success,

      TransactionServiceException ex)

    {

      this();

      this.success = success;

      this.ex = ex;

    }

    /**

     * Performs a deep copy on <i>other</i>.

     */

    public reconcileCodCollection_result(reconcileCodCollection_result other) {

      if (other.isSetSuccess()) {

        Map<String,String> __this__success = new HashMap<String,String>();

        for (Map.Entry<String, String> other_element : other.success.entrySet()) {

          String other_element_key = other_element.getKey();

          String other_element_value = other_element.getValue();

          String __this__success_copy_key = other_element_key;

          String __this__success_copy_value = other_element_value;

          __this__success.put(__this__success_copy_key, __this__success_copy_value);

        }

        this.success = __this__success;

      }

      if (other.isSetEx()) {

        this.ex = new TransactionServiceException(other.ex);

      }

    }

    public reconcileCodCollection_result deepCopy() {

      return new reconcileCodCollection_result(this);

    }

    @Override

    public void clear() {

      this.success = null;

      this.ex = null;

    }

    public int getSuccessSize() {

      return (this.success == null) ? 0 : this.success.size();

    }

    public void putToSuccess(String key, String val) {

      if (this.success == null) {

        this.success = new HashMap<String,String>();

      }

      this.success.put(key, val);

    }

    public Map<String,String> getSuccess() {

      return this.success;

    }

    public void setSuccess(Map<String,String> success) {

      this.success = success;

    }

    public void unsetSuccess() {

      this.success = null;

    }

    /** Returns true if field success is set (has been assigned a value) and false otherwise */

    public boolean isSetSuccess() {

      return this.success != null;

    }

    public void setSuccessIsSet(boolean value) {

      if (!value) {

        this.success = null;

      }

    }

    public TransactionServiceException getEx() {

      return this.ex;

    }

    public void setEx(TransactionServiceException ex) {

      this.ex = ex;