Client

README.md

@@ -1,3 +1,7 @@
 98110349     Arman Babaei
+
 98101363     M.Taha Jahani-Nezhad
+
 98106072     Ali Mahdavifar
+
+[Server repo](https://github.com/Arman17Babaei/ProjectServer)

pom.xml

@@ -76,6 +76,17 @@
             <artifactId>jfoenix</artifactId>
             <version>9.0.8</version>
         </dependency>
+        <dependency>
+            <groupId>io.jsonwebtoken</groupId>
+            <artifactId>jjwt</artifactId>
+            <version>0.2</version>
+        </dependency>
+        <dependency>
+            <groupId>javax</groupId>
+            <artifactId>javaee-api</artifactId>
+            <version>6.0</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
     <properties>
         <java.version>1.9</java.version>

src/main/java/controller/CustomerController.java

@@ -1,12 +1,17 @@
 package controller;
 
+import com.google.gson.JsonObject;
 import model.*;
 import model.exception.DefaultUser;
 
+import java.net.HttpURLConnection;
+import java.net.URL;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.HashMap;
 
+import static controller.Database.getJsonObjectFromReader;
+
 public class CustomerController extends UserController {
     private Customer customerLoggedOn;
 
@@ -16,7 +21,7 @@ public Customer getCustomerLoggedOn() {
 
     public CustomerController(Customer user, ProductController productController) {
         super(user, productController);
-        this.customerLoggedOn = (Customer) user;
+        this.customerLoggedOn = user;
     }
 
     public static Customer newDefaultUser() {
@@ -30,7 +35,7 @@ private String viewPersonalInfo() {
                 "Phone number: " + customerLoggedOn.getPhoneNumber() + "\n";
     }
 
-    public void changePersonalInfo(HashMap<String, String> infoToSet) {
+    public void changePersonalInfo(HashMap<String, String> infoToSet) throws Exception {
         super.changePersonalInfo(infoToSet);
     }
 
@@ -40,7 +45,7 @@ public void addAddress(HashMap<String, String> information) {
 
     public String getPaymentCheck() {
         try {
-            long totalPrice = purchase();
+            long totalPrice = purchase("e-wallet");
             return "Succesfully purchased\n" +
                     "Total price: " + totalPrice + "\n" +
                     "Your current credit: " + customerLoggedOn.getCredit();
@@ -49,7 +54,7 @@ public String getPaymentCheck() {
         }
     }
 
-    public String viewCartProducts() throws Exception {
+    public String viewCartProducts() {
         StringBuilder stringToReturn = new StringBuilder();
         stringToReturn.append("Product ID\tProduct name\tUnit price\tNumber\n");
         HashMap<Product, Integer> customerCart = customerLoggedOn.getCart();
@@ -101,16 +106,25 @@ public void decreaseNumberOfProduct(String productId) {
             removeFromCart(productId);
     }
 
-    public long getTotalPrice() throws Exception {
+    public long getTotalPrice() {
         long totalPrice = 0;
-        for (Product product : customerLoggedOn.getCart().keySet()) {
-            totalPrice += product.getPrice() * customerLoggedOn.getCart().get(product);
+        HashMap<Product, Integer> cart = customerLoggedOn.getCart();
+        for (Product product : cart.keySet()) {
+            totalPrice += cart.get(product) * product.getPrice();
         }
         if (customerLoggedOn.getDiscountUsed() != null)
             totalPrice *= (double) (100 - customerLoggedOn.getDiscountUsed().getDiscountPercent()) / 100;
         return totalPrice;
     }
 
+    public long getProductPrice (Product product, int num) {
+        long totalPrice = 0;
+        totalPrice += product.getPrice() * num;
+        if (customerLoggedOn.getDiscountUsed() != null)
+            totalPrice *= (double) (100 - customerLoggedOn.getDiscountUsed().getDiscountPercent()) / 100;
+        return totalPrice;
+    }
+
     public boolean validateDiscountCode(String code) {
         Discount discount = Database.getDiscountByCode(code);
         if (discount != null) {
@@ -131,12 +145,15 @@ public void removeDiscountCode () {
             customerLoggedOn.undoUseDiscount();
     }
 
-    public long purchase() throws Exception {
+    public long purchase(String method) throws Exception {
         long totalPrice = getTotalPrice();
-        customerLoggedOn.payCredit(totalPrice);
+        if (method.equalsIgnoreCase("e-wallet") && customerLoggedOn.getCredit() < totalPrice) {
+                throw new Exception("Not enough credit");
+        }
+        payEachSeller(method);
+        //creating log
         PurchaseLog newLog = createPurchaseLog();
         createSellLogForAllProducts();
-        payEachSeller();
         customerLoggedOn.deleteDiscount();
         Database.add(newLog);
         customerLoggedOn.addToPurchaseHistory(newLog);
@@ -146,15 +163,33 @@ public long purchase() throws Exception {
         return totalPrice;
     }
 
-    private void payEachSeller() {
-        for (Product product : customerLoggedOn.getCart().keySet()) {
-            Seller seller = product.getSellers().get(0);
-            seller.addToCredit(product.getPrice());
-            Database.update(seller, seller.getId());
+    private void payEachSeller(String method) throws Exception {
+        HashMap<Product, Integer> cart = customerLoggedOn.getCart();
+        for (Product product : cart.keySet()) {
+            String destId = product.getSellers().get(0).getId();
+            String reply;
+            if (method.equalsIgnoreCase("e-wallet"))
+                reply = sendCreditPaymentRequest(getProductPrice(product, cart.get(product)), destId);
+            else
+                reply = sendBankPaymentRequest(getProductPrice(product, cart.get(product)), destId);
+            System.out.println(product.getName() + ": " + reply);
         }
     }
 
-    public void createSellLogForAllProducts() {
+    private String sendBankPaymentRequest(long productPrice, String destId) throws Exception {
+        String url = Database.getServerUrl() + "paySellerByBankAccount" + "?username=" + userLoggedOn.getUsername()
+                + "&password=" + userLoggedOn.getPassword() + "&money=" + productPrice + "&sourceId="
+                + userLoggedOn.getBankAccountId() + "&destId=" + destId;
+        return sendRequestToServer(url);
+    }
+
+    private String sendCreditPaymentRequest(long productPrice, String destId) throws Exception {
+        String url = Database.getServerUrl() + "paySellerCredit" + "?sourceId=" + userLoggedOn.getId()
+                + "&money=" + productPrice + "&destId=" + destId;
+        return sendRequestToServer(url);
+    }
+
+    public void createSellLogForAllProducts() throws Exception {
         for (Product product : customerLoggedOn.getCart().keySet()) {
             SellLog log = product.createSellLog();
             log.setCustomer(customerLoggedOn);
@@ -163,13 +198,13 @@ public void createSellLogForAllProducts() {
         }
     }
 
-    public void addCustomerToProducts() throws Exception {
+    public void addCustomerToProducts() {
         for (Product product : this.customerLoggedOn.getCart().keySet()) {
             product.addBuyer(this.customerLoggedOn);
         }
     }
 
-    private PurchaseLog createPurchaseLog() throws Exception {
+    private PurchaseLog createPurchaseLog() {
         PurchaseLog log = new PurchaseLog();
         log.setDate(LocalDateTime.now());
         log.setAmountPaid(getTotalPrice());