src/main/java/at/ac/tuwien/sbc/valesriegler/group/DeliveryGroup.java

   1 package at.ac.tuwien.sbc.valesriegler.group;
   2
   3 import org.slf4j.Logger;
   4 import org.slf4j.LoggerFactory;
   5
   6 import at.ac.tuwien.sbc.valesriegler.common.HasId;
   7 import at.ac.tuwien.sbc.valesriegler.group.actions.DeliveryOrderRequest;
   8 import at.ac.tuwien.sbc.valesriegler.group.jms.JMSGroupConnector;
   9 import at.ac.tuwien.sbc.valesriegler.types.DeliveryGroupData;
  10 import at.ac.tuwien.sbc.valesriegler.types.DeliveryStatus;
  11
  12 public class DeliveryGroup implements Runnable, HasId {
  13         private static final Logger log = LoggerFactory.getLogger(DeliveryGroup.class);
  14         private static int idNext = 0;
  15
  16         private DeliveryGroupData deliveryGroupData;
  17
  18         public DeliveryGroup() {
  19                 deliveryGroupData = new DeliveryGroupData(++idNext);
  20         }
  21
  22         public DeliveryGroup(int id) {
  23                 deliveryGroupData = new DeliveryGroupData(id);
  24         }
  25
  26         public DeliveryGroupData getDeliveryGroupData() {
  27                 return deliveryGroupData;
  28         }
  29
  30         @Override
  31         public int getId() {
  32                 return deliveryGroupData.getId();
  33         }
  34
  35         public void setDeliveryGroupData(DeliveryGroupData deliveryGroupData) {
  36                 this.deliveryGroupData = deliveryGroupData;
  37         }
  38
  39         @Override
  40         public void run() {
  41                 log.debug("Thread started for:" + this);
  42                 try {
  43                         Thread.sleep((long) (Math.random() * 10000));
  44                         switch (deliveryGroupData.getDeliveryStatus()) {
  45                                 case START : // should not happen.
  46                                         break;
  47                                 case ORDER_PENDING :
  48                                         getDeliveryGroupData().getOrder().genId();
  49                                         JMSGroupConnector conn = JMSGroupConnector.getConnector(deliveryGroupData.getPizzeriaId());
  50                                         conn.send(new DeliveryOrderRequest(deliveryGroupData));
  51                                         break;
  52                                 case IN_PROGRESS : // do nothing
  53                                         break;
  54                                 case DELIVERED : // do nothing
  55                                         break;
  56                                 case PAID : // do nothing
  57                                         break;
  58                                 case IS_DELIVERED : // do nothing
  59                                         break;
  60                                 case DELIVERY_FAILED : // do nothing
  61                                         break;
  62                                 default : // do nothing
  63                                         break;
  64                         }
  65
  66                 } catch (InterruptedException e) {
  67                         e.printStackTrace();
  68                 }
  69         }
  70
  71         // lets order at the pizzaria.
  72         public void orderSomeFood() {
  73                 log.debug("orderSomeFood(): " + this);
  74                 deliveryGroupData.setDeliveryStatus(DeliveryStatus.ORDER_PENDING);
  75                 GroupAgent.getInstance().getGroupModel().fireTableDataChanged();
  76                 new Thread(this).start();
  77         }
  78 }