package com.deloitte.sbg.controller

import cn.hutool.core.util.StrUtil
import com.alibaba.fastjson.JSON
import com.alibaba.fastjson.JSONObject
import com.common.annotation.NoToken
import com.common.core.enums.ResultCodeEnum
import com.common.core.exception.BizException
import com.alibaba.fastjson.serializer.SerializerFeature
import com.common.core.utils.IdUtils
import com.common.core.utils.RestUtil
import com.common.core.utils.SecretsManagerUtils
import com.common.core.utils.SpringContextUtils
import com.deloitte.system.model.Contact
import com.deloitte.system.model.Opportunity
import groovy.util.logging.Log
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.beans.factory.annotation.Value
import org.springframework.core.env.Environment
import org.springframework.http.HttpHeaders
import org.springframework.http.ResponseEntity
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.RestController
import org.springframework.web.client.HttpServerErrorException
import org.springframework.web.context.request.RequestContextHolder
import org.springframework.web.context.request.ServletRequestAttributes

import javax.servlet.http.HttpServletResponse
import java.util.logging.Level

/**
 * @Author: Ben Pi
 * @Date: 23/02/2022 13:50
 */


@RestController
@RequestMapping("/sbg")
@Log("log")
class SapSBGRest {

    @Value("\${sap.url}")
    private String sapurl;

    @Autowired
    private IdUtils idUtils;
    @Autowired
    private Environment env;
    @Autowired
    private SecretsManagerUtils secretsManagerUtils;

    @RequestMapping(value = "/001", method = RequestMethod.POST)
    def sbg001(@RequestBody def body) {
        log.info("001接口请求=====================body:"+body)
        HttpServletResponse resp = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse()
        JSONObject object = secretsManagerUtils.getSecret(env.getProperty("aws.secrets.systemauth"));
        String saptoken = object.getString("sap_token");
        try {
            for (int i = 0; i < body.SSBDCustomerContacts.SSBDCustomerContact.size(); i++) {
                //判断是客户还是联系人，客户信息CustomerCode和ContactCode相等，不需要做解密
                String customerCode = body.SSBDCustomerContacts.SSBDCustomerContact[i].CustomerCode
                String contactCode = body.SSBDCustomerContacts.SSBDCustomerContact[i].ContactCode
                if(customerCode.equals(contactCode)){
                    if (body.SSBDCustomerContacts.SSBDCustomerContact[i].DataId != null) {
                        body.SSBDCustomerContacts.SSBDCustomerContact[i].remove("DataId")
                    }
                    continue
                }

                Contact contact = new Contact().findById(body.SSBDCustomerContacts.SSBDCustomerContact[i].DataId.toString())
                if (!contact) {
                    throw new BizException("无效的dataId")
                }
                String contactOffice = contact.getLastName()
                String telephoneMobile = (StrUtil.isBlank(contact.getPhone())?"":contact.getPhone())+","+(StrUtil.isBlank(contact.getMobilePhone())?"":contact.getMobilePhone())
                String address = contact.getAddress1()
                String postalCode = contact.getPostcode()
                String faxEmail = (StrUtil.isBlank(contact.getFax())?"":contact.getFax())+","+(StrUtil.isBlank(contact.getEmail())?"":contact.getEmail())
                body.SSBDCustomerContacts.SSBDCustomerContact[i].ContactOffice = contactOffice
                body.SSBDCustomerContacts.SSBDCustomerContact[i].TelephoneMobile = telephoneMobile
                body.SSBDCustomerContacts.SSBDCustomerContact[i].Address = address
                body.SSBDCustomerContacts.SSBDCustomerContact[i].PostalCode = postalCode
                body.SSBDCustomerContacts.SSBDCustomerContact[i].FaxEmail = faxEmail
                if (body.SSBDCustomerContacts.SSBDCustomerContact[i].DataId != null) {
                    body.SSBDCustomerContacts.SSBDCustomerContact[i].remove("DataId")
                }
            }
            HttpHeaders header = new HttpHeaders()
            header.add("Authorization", "Basic " + saptoken)
            ResponseEntity sapRes= RestUtil.postNative(sapurl + "SBG001", header, null, JSONObject.toJSONString(body, SerializerFeature.WriteMapNullValue))
            resp.setStatus(sapRes.getStatusCodeValue())
            return "success"
        } catch(HttpServerErrorException e){
            log.log(new Level("ERROR", Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "001请求异常", e)
            resp.setStatus(e.getRawStatusCode())
            return JSON.parse(e.getResponseBodyAsString())
        } catch (Exception e) {
            log.log(new Level("ERROR",Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "001请求异常", e)
            resp.setStatus(Integer.valueOf(ResultCodeEnum.AWS_RT_ERROR.getCode()))
            throw new BizException(ResultCodeEnum.AWS_RT_ERROR)
        }
    }

    @RequestMapping(value = "/027", method = RequestMethod.POST)
    def sbg027(@RequestBody def body) {
        log.info("027接口请求=====================body:"+body)
        HttpServletResponse resp = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse()
        JSONObject object = secretsManagerUtils.getSecret(env.getProperty("aws.secrets.systemauth"));
        String saptoken = object.getString("sap_token");
        log.info("saptoken:"+saptoken);
        try {
            def datas = body.GeDatas
            for (int i = 0; i < datas.GeData.size(); i++) {
                Opportunity opportunity = new Opportunity().findById(datas.GeData[i].DataId)
                if (!opportunity) {
                    throw new BizException("无效的dataId")
                }
                datas.GeData[i].DealerSalesStaffName = opportunity.getDealerSalesStaffName()
                if (datas.GeData[i].DataId != null) {
                    datas.GeData[i].remove("DataId")
                }
            }
            HttpHeaders header = new HttpHeaders()
            header.add("Authorization", "Basic " + saptoken)
            ResponseEntity sapRes = RestUtil.postNativeObject(sapurl + "SBG027", header, null, JSONObject.toJSONString(body, SerializerFeature.WriteMapNullValue))
            resp.setStatus(sapRes.getStatusCodeValue())
            return "success"
        } catch(HttpServerErrorException e){
            log.log(new Level("ERROR", Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "027请求异常", e)
            resp.setStatus(e.getRawStatusCode())
            return JSON.parse(e.getResponseBodyAsString())
        } catch (Exception e) {
            log.log(new Level("ERROR",Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "027请求异常", e)
            resp.setStatus(Integer.valueOf(ResultCodeEnum.AWS_RT_ERROR.getCode()))
            throw new BizException(ResultCodeEnum.AWS_RT_ERROR)
        }
    }

    @RequestMapping(value = "/007", method = RequestMethod.POST)
    def sbg007(@RequestBody def body) {
        log.info("007接口请求=====================body:"+body)
        HttpServletResponse resp = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getResponse()
        JSONObject object = secretsManagerUtils.getSecret(env.getProperty("aws.secrets.systemauth"));
        String saptoken = object.getString("sap_token");
        try {
            def datas = body.GeDatas
            for (int i = 0; i < datas.GeData.size(); i++) {
                Opportunity opportunity = new Opportunity().findById(datas.GeData[i].DataId)
                if (!opportunity) {
                    throw new BizException("无效的dataId")
                }
                datas.GeData[i].DealerSalesStaffName = opportunity.getDealerSalesStaffName()
                if (datas.GeData[i].DataId != null) {
                    datas.GeData[i].remove("DataId")
                }
            }
            HttpHeaders header = new HttpHeaders()
            header.add("Authorization", "Basic " + saptoken)
            ResponseEntity sapRes = RestUtil.postNative(sapurl + "SBG007", header, null, JSONObject.toJSONString(body, SerializerFeature.WriteMapNullValue))
            resp.setStatus(sapRes.getStatusCodeValue())
            return "success"
        } catch(HttpServerErrorException e){
            log.log(new Level("ERROR", Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "007请求异常", e)
            resp.setStatus(e.getRawStatusCode())
            return JSON.parse(e.getResponseBodyAsString())
        } catch (Exception e) {
            log.log(new Level("ERROR",Integer.MAX_VALUE, "ch.qos.logback.classic.Logger"), "007请求异常", e)
            resp.setStatus(Integer.valueOf(ResultCodeEnum.AWS_RT_ERROR.getCode()))
            throw new BizException(ResultCodeEnum.AWS_RT_ERROR)
        }
    }
}