/*
 * Copyright 2017-2020 吴学文 and java110 team.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.java110.job.adapt.hcIot.machine;

import com.alibaba.fastjson.JSONObject;
import com.java110.dto.accessControl.AccessControlWhiteAuthDto;
import com.java110.dto.accessControl.AccessControlWhiteDto;
import com.java110.dto.file.FileRelDto;
import com.java110.dto.owner.OwnerAttrDto;
import com.java110.dto.system.Business;
import com.java110.intf.common.*;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.job.adapt.hcIot.asyn.IIotSendAsyn;
import com.java110.po.accessControl.AccessControlWhitePo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.util.Assert;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.ImageUtils;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;

/**
 * HC iot 添加门禁白名单同步iot
 * <p>
 * 接口协议地址： https://gitee.com/java110/MicroCommunityThings/blob/master/back/docs/api.md
 *
 * @desc add by 吴学文 18:58
 */
@Component(value = "editAccessControlWhiteToIotAdapt")
public class EditAccessControlWhiteToIotAdapt extends DatabusAdaptImpl {

    @Autowired
    private IIotSendAsyn hcMachineAsynImpl;
    @Autowired
    IMachineInnerServiceSMO machineInnerServiceSMOImpl;


    @Autowired
    private IAccessControlWhiteV1InnerServiceSMO accessControlWhiteV1InnerServiceSMOImpl;

    @Autowired
    private IAccessControlWhiteAuthV1InnerServiceSMO accessControlWhiteAuthV1InnerServiceSMOImpl;

    @Autowired
    private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;

    @Autowired
    private IFileInnerServiceSMO fileInnerServiceSMOImpl;


    /**
     * accessToken={access_token}
     * &extCommunityUuid=01000
     * &extCommunityId=1
     * &devSn=111111111
     * &name=设备名称
     * &positionType=0
     * &positionUuid=1
     *
     * @param business   当前处理业务
     * @param businesses 所有业务信息
     */
    @Override
    public void execute(Business business, List<Business> businesses) {
        JSONObject data = business.getData();
        doSendMachine(business, data);
    }

    private void doSendMachine(Business business, JSONObject data) {

        AccessControlWhitePo accessControlWhitePo = BeanConvertUtil.covertBean(data, AccessControlWhitePo.class);

        AccessControlWhiteDto accessControlWhiteDto = new AccessControlWhiteDto();
        accessControlWhiteDto.setAcwId(accessControlWhitePo.getAcwId());
        accessControlWhiteDto.setCommunityId(accessControlWhiteDto.getCommunityId());
        accessControlWhiteDto.setPage(1);
        accessControlWhiteDto.setRow(1);
        List<AccessControlWhiteDto> accessControlWhiteDtos = accessControlWhiteV1InnerServiceSMOImpl.queryAccessControlWhites(accessControlWhiteDto);

        Assert.listOnlyOne(accessControlWhiteDtos, "门禁白名单不存在");

        AccessControlWhiteDto tmpAccessControlWhiteDto = accessControlWhiteDtos.get(0);
        FileRelDto fileRelDto = new FileRelDto();
        fileRelDto.setObjId(accessControlWhitePo.getAcwId());
        //fileRelDto.setRelTypeCd("10000");
        List<FileRelDto> fileRelDtos = fileRelInnerServiceSMOImpl.queryFileRels(fileRelDto);
        if (fileRelDtos == null || fileRelDtos.size() != 1) {
            return;
        }
        String fileName = fileRelDtos.get(0).getFileSaveName();


        if (StringUtil.isEmpty(fileName)) {
            return;
        }
        String imgUrl = MappingCache.getValue(MappingConstant.FILE_DOMAIN, "IMG_PATH");
        if (!fileName.startsWith("http")) {
            fileName = imgUrl + fileName;
        }

        String faceBase64 = ImageUtils.getBase64ByImgUrl(fileName);
        if (StringUtil.isEmpty(faceBase64)) {
            return;
        }

        AccessControlWhiteAuthDto accessControlWhiteAuthDto = new AccessControlWhiteAuthDto();
        accessControlWhiteAuthDto.setAcwId(accessControlWhiteDtos.get(0).getAcwId());
        List<AccessControlWhiteAuthDto> accessControlWhiteAuthDtos
                = accessControlWhiteAuthV1InnerServiceSMOImpl.queryAccessControlWhiteAuths(accessControlWhiteAuthDto);
        if (accessControlWhiteAuthDtos == null || accessControlWhiteAuthDtos.size() < 1) {
            return;
        }

        for (AccessControlWhiteAuthDto tmpAccessControlWhiteAuthDto : accessControlWhiteAuthDtos) {
            JSONObject postParameters = new JSONObject();

            postParameters.put("userId", tmpAccessControlWhiteDto.getPersonId());
            postParameters.put("faceBase64", faceBase64);
            postParameters.put("startTime", tmpAccessControlWhiteDto.getStartTime());
            postParameters.put("endTime", tmpAccessControlWhiteDto.getEndTime());
            postParameters.put("name", tmpAccessControlWhiteDto.getPersonName());
            postParameters.put("idNumber", tmpAccessControlWhiteDto.getIdCard());
            postParameters.put("link", tmpAccessControlWhiteDto.getTel());
            postParameters.put("machineCode", tmpAccessControlWhiteAuthDto.getMachineCode());
            postParameters.put("extMachineId", tmpAccessControlWhiteAuthDto.getMachineId());
            postParameters.put("extCommunityId", tmpAccessControlWhiteDto.getCommunityId());
            List<OwnerAttrDto> ownerAttrDtos = new ArrayList<>();
            OwnerAttrDto ownerAttrDto = new OwnerAttrDto();
            ownerAttrDto.setSpecCd(OwnerAttrDto.SPEC_CD_ACCESS_CONTROL_KEY);
            ownerAttrDto.setValue(tmpAccessControlWhiteDto.getAccessControlKey());
            ownerAttrDto.setCommunityId(tmpAccessControlWhiteDto.getCommunityId());
            ownerAttrDtos.add(ownerAttrDto);
            postParameters.put("attrs", ownerAttrDtos);
            hcMachineAsynImpl.sendUpdateOwner(postParameters);
        }
    }
}