WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/ThriweController.java

 package com.spice.profitmandi.web.controller;
 import java.security.Key;
+import java.time.LocalDate;
-import java.security.NoSuchAlgorithmException;
+import java.time.LocalDateTime;
-import java.security.SecureRandom;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
-import java.util.Date;
+import java.util.Arrays;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import javax.servlet.http.HttpServletRequest;
+import org.apache.http.Header;
+import org.apache.http.HttpResponse;
 import org.apache.http.conn.HttpHostConnectException;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.json.JSONObject;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
-import com.auth0.jwt.interfaces.Signature;
+import com.google.gson.Gson;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.web.client.RestClient;
 import com.spice.profitmandi.common.web.util.ResponseSender;
+import com.spice.profitmandi.dao.entity.fofo.Campaign;
 import com.spice.profitmandi.dao.entity.fofo.Customer;
+import com.spice.profitmandi.dao.entity.fofo.ThriweMembers;
 import com.spice.profitmandi.dao.model.thriwe.benefit.BenefitGroup;
+import com.spice.profitmandi.dao.model.thriwe.benefit.BenefitResponse;
+import com.spice.profitmandi.dao.model.thriwe.benefitConfiguration.BenefitConfigurationResponse;
+import com.spice.profitmandi.dao.repository.fofo.CampaignRepository;
 import com.spice.profitmandi.dao.repository.fofo.CustomerRepository;
+import com.spice.profitmandi.dao.repository.fofo.ThriweMemberRepository;
+import io.jsonwebtoken.Jwts;
+import io.jsonwebtoken.security.Keys;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 @Controller
     @Autowired
     private ResponseSender<?> responseSender;
     @Autowired
-    RestClient restClient;
+    private CustomerRepository customerRepository;
+    @Autowired
+    RestClient restClient;
-    @Value("${thriwe.account.token}")
+   // @Value("${thriwe.account.token}")
     private String token;
     @Autowired
+    CampaignRepository campaignRepository;
+    @Autowired
-    private CustomerRepository customerRepository;
+    private ThriweMemberRepository thriweMemberRepository;
+    @Autowired
+    private Gson gson;
     private static final Logger LOGGER = LogManager.getLogger(ThriweController.class);
-    @RequestMapping(value = "/thriwe/validate/customer", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @RequestMapping(value = "/thriwe/validate/customer", method = RequestMethod.GET)
-    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
-    @ApiOperation(value = "")
     public ResponseEntity<?> validateCustomer(HttpServletRequest request) throws HttpHostConnectException, ProfitMandiBusinessException {
-        Map<String, String> params = new HashMap<String, String>();
+        List<Campaign> campaigns = campaignRepository.selectAll();
+        String memberShipId = null;
+        if (!campaigns.isEmpty()) {
+            Campaign campaign = campaigns.get(0);
-        Customer customer = customerRepository.selectById(32697);
+            Customer customer = customerRepository.selectById(32697);
+            Map<String, String> params = new HashMap<String, String>();
-        // String authToken = this.getToken(customer);
+            String userName = customer.getId() + "-" + campaign.getId();
+            LOGGER.info("token {}", token);
-        Map<String, String> headers = new HashMap<String, String>();
+            String secretKey = "smartdukan@thriwe_123smartdukaan";
+            JSONObject jsonObject = new JSONObject();
+            jsonObject.put("exp", LocalDateTime.now().plusDays(4).atZone(ZoneId.systemDefault()).toInstant().toEpochMilli() / 1000);
+            jsonObject.put("iat", LocalDateTime.now().atZone(ZoneId.systemDefault()).toInstant().toEpochMilli() / 1000);
-        headers.put("token", token);
+            jsonObject.put("userName", userName);
-        // headers.put("X-Auth-Token", authToken);
+            jsonObject.put("email", customer.getEmailId());
+            jsonObject.put("mobileNumber", customer.getMobileNumber());
-        headers.put("Project-Code", "SMART_DUKAAN");
+            jsonObject.put("firstName", customer.getFirstName());
+            jsonObject.put("lastName", customer.getLastName());
+            jsonObject.put("expiryDate", LocalDate.now().plusDays(4).format(DateTimeFormatter.ofPattern("dd/MM/yyyy")));
-      /*  Key key = Keys.secretKeyFor(SignatureAlgorithm.HS256);
+            LOGGER.info("jsonObject {}", jsonObject.toString());
-        // JSON data as a Map (Key-Value pairs)
-        Map<String, Object> jsonData = new HashMap<>();
+            Map<String, Object> headersjwt = new HashMap<>();
-        jsonData.put("exp", 1675145552L);
+            headersjwt.put("alg", "HS256");
-        jsonData.put("iat", 1674540752L);
-        jsonData.put("userName", "75gtf-765dvy-atd6-ffdfa");
-        jsonData.put("firstName", "Ishaan");
-        jsonData.put("lastName", "Sharma");
+            headersjwt.put("typ", "JWT");
-        jsonData.put("email", "ishaan.sharma@thriwe.com");
-        jsonData.put("mobile", "9560998243");
-        jsonData.put("validTill", "12-May-2024");
-        // Create the JWT
-        String jwt = Jwts.builder()
-                .setClaims(jsonData)
-                .signWith(key)
-                .compact();
-        System.out.println("Generated JWT: " + jwt);*/
-       // String secretKey = "your-secret-key"; // Replace with your actual secret key
-  //      String token = Jwts.builder().setPayload(jsonData).signWith(SignatureAlgorithm.HS256, secretKey).compact();
-    //    System.out.println("Generated JWT: " + token);
-        // JSON data as a string
-        // Generate the JWT
-      // Create the JWT
-        String url = "http://localhost:8083/validate-user";
-        String response = restClient.get(url, params, headers);
+            Key key = Keys.hmacShaKeyFor(secretKey.getBytes());
-        LOGGER.info("response {}", response);
+            String jwt = Jwts.builder().setHeaderParam("alg", "HS256").setHeaderParam("typ", "JWT").setPayload(jsonObject.toString()).signWith(key).compact();
-        return responseSender.ok(true);
+            LOGGER.info("jwt {}", jwt);
-    }
-    private static Key generateSecretKey() throws NoSuchAlgorithmException {
+            Map<String, String> headers = new HashMap<String, String>();
-        SecureRandom secureRandom = new SecureRandom();
+            headers.put("Project-Code", "SMART_DUKAAN");
-        byte[] bytes = new byte[32]; // 256 bits
+            headers.put("X-Auth-Token", jwt);
+            String url = "https://staging-india-api-gateway.thriwe.com/validate-user";
+            HttpResponse response = restClient.getResponse(url, params, headers);
-        secureRandom.nextBytes(bytes);
+            LOGGER.info("response {}", response);
-        return new javax.crypto.spec.SecretKeySpec(bytes, "HmacSHA256");
+            Header[] authToken = response.getHeaders("Authorization");
+            LOGGER.info("authToken {}", Arrays.asList(authToken).get(0).getValue());
-    }
+            ThriweMembers thriweMember = thriweMemberRepository.selectByUsername(userName, campaign.getStartDate(), campaign.getEndDate());
+            LOGGER.info("thriweMembers {}", thriweMember);
+            if (thriweMember != null) {
+                thriweMember.setAuthToken(Arrays.asList(authToken).get(0).getValue());
+                try {
+                    String responseString = restClient.toString(response.getEntity().getContent());
+                    LOGGER.info("responseString {}", new JSONObject(responseString).get("membershipId"));
+                    JSONObject responseJson = new JSONObject(responseString);
+                    String membershipId = responseJson.getString("membershipId");
+                    thriweMember.setMembershipId(membershipId);
+                    memberShipId = thriweMember.getMembershipId();
+                } catch (Exception e) {
+                    // TODO: handle exception
+                }
+            }
+        }
+        return responseSender.ok(memberShipId);
+    }
-    @RequestMapping(value = "/thriwe/benefitConfiguration", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @RequestMapping(value = "/thriwe/benefit-configs", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
     @ApiOperation(value = "")
-    public ResponseEntity<?> benefitConfiguration(HttpServletRequest request) throws HttpHostConnectException, ProfitMandiBusinessException {
+    public ResponseEntity<?> benefitConfigs(HttpServletRequest request, @RequestParam String membershipId) throws HttpHostConnectException, ProfitMandiBusinessException {
-        Map<String, String> params = new HashMap<String, String>();
-        Map<String, String> headers = new HashMap<String, String>();
+        ThriweMembers thriweMember = thriweMemberRepository.selectByMembershipId(membershipId);
+        Map<String, String> params = new HashMap<String, String>();
-        headers.put("token", token);
+        Map<String, String> headers = new HashMap<String, String>();
+        headers.put("Authorization", thriweMember.getAuthToken());
         headers.put("Project-Code", "SMART_DUKAAN");
         String url = "https://staging-india-api-gateway.thriwe.com/client/benefit-configs";
-        String response = restClient.get(url, params, headers);
+        String response = restClient.get(url, params, headers);
         LOGGER.info("response {}", response);
-        return responseSender.ok(true);
+        BenefitConfigurationResponse benefitConfigurationResponse = gson.fromJson(response, BenefitConfigurationResponse.class);
-    }
+        LOGGER.info("benefitConfigurationResponse {}", benefitConfigurationResponse);
+        return responseSender.ok(benefitConfigurationResponse);
+    }
     @RequestMapping(value = "/thriwe/benefits", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
     @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
     @ApiOperation(value = "")
-    public ResponseEntity<?> benefits(HttpServletRequest request, @RequestParam String configId) throws HttpHostConnectException, ProfitMandiBusinessException {
+    public ResponseEntity<?> benefits(HttpServletRequest request, @RequestParam String membershipId, @RequestParam String configId) throws HttpHostConnectException, ProfitMandiBusinessException {
+        ThriweMembers thriweMember = thriweMemberRepository.selectByMembershipId(membershipId);
         Map<String, String> params = new HashMap<String, String>();
         params.put("configId", configId);
         Map<String, String> headers = new HashMap<String, String>();
-        headers.put("token", token);
+        headers.put("Authorization", thriweMember.getAuthToken());
         headers.put("Project-Code", "SMART_DUKAAN");
-        String url = "https://staging-india-api-gateway.thriwe.com/client/benefit-configs";
+        String url = "https://staging-india-api-gateway.thriwe.com/client/benefit-items";
         String response = restClient.get(url, params, headers);
+        BenefitResponse benefitResponse = gson.fromJson(response, BenefitResponse.class);
-        LOGGER.info("response {}", response);
+        LOGGER.info("benefitResponse {}", benefitResponse);
+        return responseSender.ok(benefitResponse);
-        return responseSender.ok(true);
+    }
     @RequestMapping(value = "/thriwe/createBooking", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
     @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
     @ApiOperation(value = "")
     public ResponseEntity<?> createBooking(HttpServletRequest request, @RequestBody BenefitGroup benefitGroup) throws HttpHostConnectException, ProfitMandiBusinessException {
+        ThriweMembers thriweMember = thriweMemberRepository.selectByMembershipId(benefitGroup.getMembershipId());
         Map<String, String> headers = new HashMap<String, String>();
         headers.put("token", token);
         headers.put("Project-Code", "SMART_DUKAAN");

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/ThriweController.java – Rev 32367 → 32440