Lianxun_Java.git

package com.java110.job.mall;
 
import com.alibaba.fastjson.JSONObject;
import com.java110.core.client.RestTemplate;
import com.java110.core.factory.AuthenticationFactory;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.log.LoggerFactory;
import com.java110.db.dao.impl.QueryServiceDAOImpl;
import com.java110.dto.machine.MachineTranslateErrorDto;
import com.java110.intf.common.IMachineTranslateErrorInnerServiceSMO;
import com.java110.po.machine.MachineTranslateErrorPo;
import com.java110.utils.cache.CommonCache;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.web.client.HttpStatusCodeException;
 
import java.util.Date;
import java.util.UUID;
 
@Service
public class SendMallImpl implements ISendMall {
    private final static Logger logger = LoggerFactory.getLogger(SendMallImpl.class);
 
    public static final String GET_TOKEN_URL = "/mall/api/login.pcUserLogin";
    private static final String DEFAULT_MALL_URL = "https://mall.homecommunity.cn";
    public static final String MALL_DOMAIN = "MALL"; // 物联网域
 
    public static final String MALL_TOKEN = "MALL_ACCESS_TOKEN";
    private static final String MALL_URL = "MALL_URL";
 
 
    @Autowired
    private RestTemplate outRestTemplate;
 
    @Autowired
    private IMachineTranslateErrorInnerServiceSMO machineTranslateErrorInnerServiceSMOImpl;
 
 
    @Override
    public ResultVo get(String url) {
        url = getUrl(url);
        HttpHeaders header = getHeaders(url, "", HttpMethod.GET);
        HttpEntity<String> httpEntity = new HttpEntity<String>("", header);
        ResponseEntity<String> tokenRes = null;
        try {
            tokenRes = outRestTemplate.exchange(url, HttpMethod.GET, httpEntity, String.class);
        } catch (HttpStatusCodeException e) {
            logger.error("调用异常", e);
            return new ResultVo(ResultVo.CODE_ERROR, e.getResponseBodyAsString());
        } catch (Exception e) {
            logger.error("调用异常", e);
            return new ResultVo(ResultVo.CODE_ERROR, e.getMessage());
        }
 
        String body = tokenRes.getBody();
        JSONObject paramOut = JSONObject.parseObject(body);
 
        return new ResultVo(paramOut.getIntValue("code"), paramOut.getString("msg"), paramOut.get("data"));
    }
 
    @Override
    public ResultVo post(String url, JSONObject paramIn) {
        url = getUrl(url);
        HttpHeaders header = getHeaders(url, paramIn.toJSONString(), HttpMethod.POST);
        HttpEntity<String> httpEntity = new HttpEntity<String>(paramIn.toJSONString(), header);
        ResponseEntity<String> tokenRes = null;
        try {
            tokenRes = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
        } catch (HttpStatusCodeException e) {
            logger.error("调用异常", e);
            return new ResultVo(ResultVo.CODE_ERROR, e.getResponseBodyAsString());
        } catch (Exception e) {
            logger.error("调用异常", e);
            return new ResultVo(ResultVo.CODE_ERROR, e.getMessage());
        }
        String body = tokenRes.getBody();
        JSONObject paramOut = JSONObject.parseObject(body);
 
        if (paramOut.getIntValue("code") != ResultVo.CODE_OK) {
            saveTranslateError(paramIn.getString("communityId"), paramIn.toJSONString(), body, url);
        }
 
        int total = 1;
        int records = 1;
        if (paramOut.containsKey("total")) {
            total = paramOut.getIntValue("total");
        }
 
        if (paramOut.containsKey("records")) {
            records = paramOut.getIntValue("records");
        }
 
        return new ResultVo(records, total, paramOut.getIntValue("code"), paramOut.getString("msg"), paramOut.get("data"));
    }
 
 
    public void saveTranslateError(String communityId, String reqJson, String resJson, String url) {
        MachineTranslateErrorPo machineTranslateErrorPo = new MachineTranslateErrorPo();
        machineTranslateErrorPo.setLogId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_logId));
        machineTranslateErrorPo.setCommunityId(communityId);
        machineTranslateErrorPo.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
        machineTranslateErrorPo.setReqBody(reqJson);
        machineTranslateErrorPo.setReqHeader("");
        machineTranslateErrorPo.setResBody(resJson);
        machineTranslateErrorPo.setReqPath(url);
        machineTranslateErrorPo.setCommunityId("-1");
        machineTranslateErrorPo.setReqType(MachineTranslateErrorDto.REQ_TYPE_URL);
        machineTranslateErrorInnerServiceSMOImpl.saveMachineTranslateError(machineTranslateErrorPo);
    }
 
 
    /**
     * 封装头信息
     *
     * @return
     */
    private HttpHeaders getHeaders(String url, String param, HttpMethod method) {
        HttpHeaders header = new HttpHeaders();
        header.add(CommonConstant.APP_ID.toLowerCase(), MappingCache.getValue(MALL_DOMAIN, "APP_ID"));
        header.add(CommonConstant.USER_ID.toLowerCase(), CommonConstant.ORDER_DEFAULT_USER_ID);
        header.add(CommonConstant.TRANSACTION_ID.toLowerCase(), UUID.randomUUID().toString());
        header.add(CommonConstant.REQUEST_TIME.toLowerCase(), DateUtil.getDefaultFormateTimeString(new Date()));
        createSign(header, method, url, param);
        header.add("Authorization", "Bearer " + getToken(false));
        return header;
    }
 
    public String getToken(boolean refreshAccessToken) {
        String token = CommonCache.getValue(MALL_TOKEN);
        if (!StringUtil.isEmpty(token) && !refreshAccessToken) {
            return token;
        }
 
        String url = getUrl(GET_TOKEN_URL);
 
        String userName = MappingCache.getValue(MALL_DOMAIN, "MALL_USERNAME");
        String password = MappingCache.getValue(MALL_DOMAIN, "MALL_PASSWORD");
        JSONObject param = new JSONObject();
        param.put("username", userName);
        param.put("passwd", password);
 
        HttpHeaders header = new HttpHeaders();
        header.add(CommonConstant.APP_ID.toLowerCase(), MappingCache.getValue(MALL_DOMAIN, "APP_ID"));
        header.add(CommonConstant.USER_ID.toLowerCase(), CommonConstant.ORDER_DEFAULT_USER_ID);
        header.add(CommonConstant.TRANSACTION_ID.toLowerCase(), UUID.randomUUID().toString());
        header.add(CommonConstant.REQUEST_TIME.toLowerCase(), DateUtil.getDefaultFormateTimeString(new Date()));
        createSign(header, HttpMethod.POST, url, param.toJSONString());
        HttpEntity<String> httpEntity = new HttpEntity<String>(param.toJSONString(), header);
 
        ResponseEntity<String> tokenRes = outRestTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
 
 
        JSONObject tokenObj = JSONObject.parseObject(tokenRes.getBody());
        if (tokenObj.getIntValue("code") != 0) {
            throw new IllegalArgumentException("获取token失败" + tokenRes.getBody());
        }
        if (!tokenObj.containsKey("token")) {
            throw new IllegalArgumentException("获取token失败" + tokenRes.getBody());
        }
 
        token = tokenObj.getString("token");
        int expiresIn = 30 * 60; //todo 30分钟
 
        CommonCache.setValue(MALL_TOKEN, token, expiresIn - 200);
 
        return token;
    }
 
    private static String getUrl(String param) {
        String url = MappingCache.getValue(MALL_DOMAIN, MALL_URL);
 
        if (StringUtil.isEmpty(url)) {
            return DEFAULT_MALL_URL + param;
        }
 
        return url + param;
    }
 
    /**
     * 创建鉴权
     *
     * @param headers
     * @param httpMethod
     * @param url
     * @param param
     */
    public static void createSign(HttpHeaders headers, HttpMethod httpMethod, String url, String param) {
        String appId = headers.getFirst(CommonConstant.APP_ID);
        String transactionId = headers.getFirst(CommonConstant.TRANSACTION_ID);
        String requestTime = headers.getFirst(CommonConstant.REQUEST_TIME);
        String securityCode = MappingCache.getValue(MALL_DOMAIN, "APP_SECRET");
 
        if (StringUtil.isEmpty(securityCode)) {
            return;
        }
        String paramStr = "";
        if (HttpMethod.GET == httpMethod) {
            paramStr = url.substring(url.indexOf("?"));
        } else {
            paramStr = param;
        }
        String sign = transactionId + requestTime + appId + paramStr + securityCode;
        headers.remove("sign");
        headers.add("sign", AuthenticationFactory.md5(sign));
    }
 
}