package com.java110.user.cmd.user;

import com.alibaba.fastjson.JSONArray;
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.service.context.DataQuery;
import com.java110.service.smo.IQueryServiceSMO;
import com.java110.utils.constant.ServiceCodeConstant;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;

import java.text.ParseException;

@Java110Cmd(serviceCode = "query.staff.byName")
public class QueryStaffByNameCmd extends Cmd {

    @Autowired
    private IQueryServiceSMO queryServiceSMOImpl;

    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException {
        Assert.hasKeyAndValue(reqJson, "storeId", "请求报文中未包含storeId节点");
        Assert.hasKeyAndValue(reqJson, "name", "请求报文中未包含name节点");
    }

    @Override
    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
        JSONObject resultJson = JSONObject.parseObject("{\"total:\":10,\"datas\":[]}");
        DataQuery dataQuery = new DataQuery();
        dataQuery.setServiceCode(ServiceCodeConstant.SERVICE_CODE_QUERY_USER_BY_NAME);

        dataQuery.setRequestParams(reqJson);
        queryServiceSMOImpl.commonQueryService(dataQuery);
        ResponseEntity<String> responseEntity = dataQuery.getResponseEntity();

        if (responseEntity.getStatusCode() != HttpStatus.OK) {
            context.setResponseEntity(responseEntity);
            return;
        }

        String useIds = getUserIds(responseEntity);
        if (StringUtil.isEmpty(useIds)) {
            context.setResponseEntity(responseEntity);
            return;
        }
        JSONArray userInfos = getUserInfos(responseEntity);
        JSONObject paramIn = new JSONObject();
        paramIn.put("userIds", useIds);
        paramIn.put("storeId", reqJson.getString("storeId"));


        dataQuery = new DataQuery();
        dataQuery.setServiceCode(ServiceCodeConstant.SERVICE_CODE_QUERY_STOREUSER_BYUSERIDS);

        dataQuery.setRequestParams(paramIn);
        queryServiceSMOImpl.commonQueryService(dataQuery);
        responseEntity = dataQuery.getResponseEntity();

        if (responseEntity.getStatusCode() != HttpStatus.OK) {
            context.setResponseEntity(responseEntity);
            return;
        }

        resultJson.put("datas", getStaffUsers(userInfos, responseEntity));
        responseEntity = new ResponseEntity<String>(resultJson.toJSONString(), HttpStatus.OK);
        context.setResponseEntity(responseEntity);

    }

    /**
     * 查询商户员工
     *
     * @param userInfos      用户信息
     * @param responseEntity 商户返回的用户ID信息
     * @return
     */
    private JSONArray getStaffUsers(JSONArray userInfos, ResponseEntity<String> responseEntity) {


        JSONObject storeUserInfo = null;
        JSONArray newStaffUsers = new JSONArray();
        JSONArray storeUsers = JSONObject.parseObject(responseEntity.getBody().toString()).getJSONArray("storeUsers");
        if (storeUsers == null || storeUsers.size() < 1) {
            return newStaffUsers;
        }

        for (int storeUserIndex = 0; storeUserIndex < storeUsers.size(); storeUserIndex++) {
            storeUserInfo = storeUsers.getJSONObject(storeUserIndex);

            for (int userIndex = 0; userIndex < userInfos.size(); userIndex++) {
                if (userInfos.getJSONObject(userIndex).getString("userId").equals(storeUserInfo.getString("userId"))) {
                    newStaffUsers.add(userInfos.getJSONObject(userIndex));
                }
            }
        }


        return newStaffUsers;
    }

    /**
     * 获取用ID
     * 如：
     * 123,456,567
     *
     * @param responseEntity
     * @return
     */
    private String getUserIds(ResponseEntity<String> responseEntity) {
        JSONObject userInfo = null;
        String userId = "";
        JSONArray resultInfo = JSONObject.parseObject(responseEntity.getBody().toString()).getJSONArray("users");
        if (resultInfo == null || resultInfo.size() < 1) {
            return userId;
        }

        for (int userIndex = 0; userIndex < resultInfo.size(); userIndex++) {
            userInfo = resultInfo.getJSONObject(userIndex);
            userId += (userInfo.getString("userId") + ",");
        }

        userId = userId.length() > 0 ? userId.substring(0, userId.lastIndexOf(",")) : userId;

        return userId;
    }


    /**
     * 获取用户
     *
     * @param responseEntity
     * @return
     */
    private JSONArray getUserInfos(ResponseEntity<String> responseEntity) {
        JSONArray resultInfo = JSONObject.parseObject(responseEntity.getBody().toString()).getJSONArray("users");
        if (resultInfo == null || resultInfo.size() < 1) {
            return null;
        }

        return resultInfo;
    }


}