package com.java110.user.cmd.login;

import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.AuthenticationFactory;
import com.java110.doc.annotation.*;
import com.java110.dto.user.UserDto;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.CommonConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
import com.java110.utils.util.TeldUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;

import java.text.ParseException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Java110CmdDoc(title = "特来电获取token",
        description = "主要用于 特来电平台使用,<br/>" +
                "请求其他接口时 头信息中需要加 Authorization: Bearer token ，<br/>" +
                "token 是这个接口返回的内容<br/> " +
                "会话保持为2小时，请快要到2小时时，再次登录，保持会话</br>",
        httpMethod = "post",
        url = "http://{ip}:{port}/app/ext/{appId}/query_token",
        resource = "userDoc",
        author = "吴学文",
        serviceCode = "login.getTokenForTeld",
        seq = 1
)

@Java110ParamsDoc(
        headers = {
                @Java110HeaderDoc(name = "Content-Type", defaultValue = "application/json", description = "application/json"),
        },
        params = {
                @Java110ParamDoc(name = "OperatorID", length = 30, remark = "调用方的组织机构代码"),
                @Java110ParamDoc(name = "OperatorSecret", length = 30, remark = "服务方分配的唯一识别密钥"),
        })

@Java110ResponseDoc(
        params = {
                @Java110ParamDoc(name = "Ret", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
                @Java110ParamDoc(name = "Msg", type = "int", length = 11, defaultValue = "0", remark = "返回编号，0 成功 其他失败"),
                @Java110ParamDoc(name = "Data", type = "Object", remark = "有效数据"),
                @Java110ParamDoc(parentNodeName = "data", name = "TokenAvailableTime", type = "int", remark = "有效期"),
                @Java110ParamDoc(parentNodeName = "data", name = "AccessToken", type = "String", remark = "临时票据"),
        }
)

@Java110ExampleDoc(
        reqBody = "{\n" +
                "  \"OperatorID\": \"123456789\",\n" +
                "  \"Data\": \"mYvffpNoFf4E/ZTC1tOw41TC5OlkEobfAYCm5N8hEusaLUaUIqOrXtdbMrSck0DSmfM7mRuOGMoCQzH0nWPGuw==\",\n" +
                "  \"TimeStamp\": \"20180120165755\",\n" +
                "  \"Seq\": \"0001\",\n" +
                "  \"Sig\": \"D2D584A14F3F284445DF85D0E8C0697C\"\n" +
                "}",
        resBody = "{\n" +
                "    \"Ret\": 0,\n" +
                "    \"Msg\": \"\",\n" +
                "    \"Data\": \"uxeKP0ezR5yL8xSg4/ZCDh/N91/u86NXFxd2DrwZVW8zCPYcpl59Twz/yQZ3RaO4rDDrGmkvQignmNEJ+k4PGxdmIC+4fpJ8rU6osSobY+AeA0uueuQ5+eQiWBL6p6v5XMMm91brtK8yfFELYUWQzVcxABnAwK/+dyxtUhqLIxUpkwTEU/4ktN40df9IzzlLO5uvUknPGYu9yL0pp5w9vdRxmA1RiiTDNCysz6klr9bunGV3VJa2qpLcgeZMf/oG\",\n" +
                "    \"Sig\": \"58E52010C7DEE87FE183B0AFA5B2BE30\"\n" +
                "}"
)
@Java110Cmd(serviceCode = "query_token")
public class QueryTokenForTeldCmd extends Cmd {


    public static String OPERATOR_SECRET = "1234567890abcdef"; //

    //
    public static String OPERATOR_ID = "123456789"; //9位组织机构代码
    //	// open平台地址
    public static String URL = "http://hlht.telaidian.com.cn:9501/evcs/v20161110/";

    @Autowired
    private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;

    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {

        Assert.hasKeyAndValue(reqJson, "Data", "未包含加密报文");

    }

    @Override
    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {

        String signKey = MappingCache.getValue("TELD_DOMAIN","SIGN_KEY");
        String aesKey = MappingCache.getValue("TELD_DOMAIN","AES_KEY");
        String aesIv = MappingCache.getValue("TELD_DOMAIN","AES_IV");

        String data = TeldUtil.Decrypt(reqJson.getString("Data"), aesKey, aesIv);

        if (StringUtil.isEmpty(data)) {
            throw new CmdException("未包含报文");
        }

        JSONObject dataObj = JSONObject.parseObject(data);


        UserDto userDto = new UserDto();
        userDto.setTel(dataObj.getString("OperatorID"));
        userDto.setPassword(AuthenticationFactory.md5UserPassword(dataObj.getString("OperatorSecret")));
        List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);

        Assert.listOnlyOne(userDtos, "用户不存在");

        Map userMap = new HashMap();
        userMap.put(CommonConstant.LOGIN_USER_ID, userDtos.get(0).getUserId());
        userMap.put(CommonConstant.LOGIN_USER_NAME, userDtos.get(0).getUserName());
        String paramOut = "";
        try {
            String token = AuthenticationFactory.createAndSaveToken(userMap);
            JSONObject param = new JSONObject();
            param.put("OperatorID", dataObj.getString("OperatorID"));
            param.put("SuccStat", 0);
            param.put("AccessToken", token);
            param.put("TokenAvailableTime", 7200);
            param.put("FailReason", 0);
            paramOut = TeldUtil.generateSecurityParam(param.toJSONString(), aesKey, aesIv, signKey, dataObj.getString("OperatorID"));
            context.setResponseEntity(new ResponseEntity(paramOut, HttpStatus.OK));
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }


}