Subversion Repositories SmartDukaan

package com.spice.profitmandi.web.controller;

import org.springframework.stereotype.Controller;

/*
 * import java.security.Key;
 * import java.time.LocalDate;
 * import java.time.LocalDateTime;
 * import java.time.ZoneId;
 * import java.time.format.DateTimeFormatter;
 * 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.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;
 */

import org.springframework.transaction.annotation.Transactional;

@Controller
@Transactional(rollbackFor = Throwable.class)
public class ThriweController {

    /* @Autowired
    private ResponseSender<?> responseSender;
    
    @Autowired
    private CustomerRepository customerRepository;
    
    @Autowired
    RestClient restClient;
    
    // @Value("${thriwe.account.token}")
    private String token;
    
    @Autowired
    CampaignRepository campaignRepository;
    
    @Autowired
    private ThriweMemberRepository thriweMemberRepository;
    
    @Autowired
    private Gson gson;
    
    
    private static final Logger LOGGER = LogManager.getLogger(ThriweController.class);
    
    
    @RequestMapping(value = "/thriwe/validate/customer", method = RequestMethod.GET)
    public ResponseEntity<?> validateCustomer(HttpServletRequest request) throws HttpHostConnectException, ProfitMandiBusinessException {
    
        List<Campaign> campaigns = campaignRepository.selectAll();
        String memberShipId = null;
        if (!campaigns.isEmpty()) {
    
            Campaign campaign = campaigns.get(0);
            Customer customer = customerRepository.selectById(32697);
    
            Map<String, String> params = new HashMap<String, String>();
            String userName = customer.getId() + "-" + campaign.getId();
            LOGGER.info("token {}", token);
    
    
            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);
            jsonObject.put("userName", userName);
            jsonObject.put("email", customer.getEmailId());
            jsonObject.put("mobileNumber", customer.getMobileNumber());
            jsonObject.put("firstName", customer.getFirstName());
            jsonObject.put("lastName", customer.getLastName());
            jsonObject.put("expiryDate", LocalDate.now().plusDays(4).format(DateTimeFormatter.ofPattern("dd/MM/yyyy")));
    
            LOGGER.info("jsonObject {}", jsonObject.toString());
    
            Map<String, Object> headersjwt = new HashMap<>();
            headersjwt.put("alg", "HS256");
            headersjwt.put("typ", "JWT");
    
            Key key = Keys.hmacShaKeyFor(secretKey.getBytes());
    
            String jwt = Jwts.builder().setHeaderParam("alg", "HS256").setHeaderParam("typ", "JWT").setPayload(jsonObject.toString()).signWith(key).compact();
    
            LOGGER.info("jwt {}", jwt);
    
    
            Map<String, String> headers = new HashMap<String, String>();
            headers.put("Project-Code", "SMART_DUKAAN");
            headers.put("X-Auth-Token", jwt);
            String url = "https://staging-india-api-gateway.thriwe.com/validate-user";
            HttpResponse response = restClient.getResponse(url, params, headers);
            LOGGER.info("response {}", response);
    
    
            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/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<?> benefitConfigs(HttpServletRequest request, @RequestParam String membershipId) throws HttpHostConnectException, ProfitMandiBusinessException {
    
    
        ThriweMembers thriweMember = thriweMemberRepository.selectByMembershipId(membershipId);
    
        Map<String, String> params = new HashMap<String, String>();
        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);
        LOGGER.info("response {}", response);
    
        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 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("Authorization", thriweMember.getAuthToken());
        headers.put("Project-Code", "SMART_DUKAAN");
    
        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("benefitResponse {}", benefitResponse);
    
        return responseSender.ok(benefitResponse);
    
    }
    
    
    @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");
    
        String url = "https://staging-india-api-gateway.thriwe.com/create-booking";
        String response = restClient.post(url, benefitGroup.toString(), headers);
    
        LOGGER.info("response {}", response);
        return responseSender.ok(true);
    }
    
    */
}