package com.iailab.module.device.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.iailab.common.enums.CommonConstant;
import com.iailab.framework.common.page.PageData;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.framework.common.util.object.ConvertUtils;
import com.iailab.common.utils.HttpsRequest;
import com.iailab.module.data.dto.FeignHttpApiDTO;
import com.iailab.module.data.api.IFeignDataApi;
import com.iailab.module.device.dao.DeviceInfoDao;
import com.iailab.module.device.dto.DeviceInfoDTO;
import com.iailab.module.device.entity.DeviceInfoEntity;
import com.iailab.module.device.service.DeviceInfoService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.util.*;

/**
 * @author PanZhibao
 * @Description
 * @createTime 2024年05月27日
 */
@Slf4j
@Service
public class DeviceInfoServiceImpl extends BaseServiceImpl<DeviceInfoDao, DeviceInfoEntity> implements DeviceInfoService {

    private String HTTP_API_CODE = "Dev.DeviceTree";

    @Resource
    private IFeignDataApi feignDataApi;

    @Resource
    private HttpsRequest httpsRequest;


    @Override
    public List<DeviceInfoDTO> list(Map<String, Object> params) {
        List<DeviceInfoEntity> list = baseDao.selectList(getWrapper(params));
        return ConvertUtils.sourceToTarget(list, DeviceInfoDTO.class);
    }

    private QueryWrapper<DeviceInfoEntity> getWrapper(Map<String, Object> params) {
        String pid = (String) params.get("pid");
        String no = (String) params.get("no");
        String name = (String) params.get("name");
        String isMain = (String) params.get("isMain");
        QueryWrapper<DeviceInfoEntity> wrapper = new QueryWrapper<>();
        wrapper.eq(StringUtils.isNotBlank(pid), "pid", pid)
                .like(StringUtils.isNotBlank(no), "no", no)
                .like(StringUtils.isNotBlank(name), "name", name)
                .eq(StringUtils.isNotBlank(isMain), "is_main", isMain);
        return wrapper;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void syncData() {
        FeignHttpApiDTO apiDTO = feignDataApi.getHttpApi(HTTP_API_CODE);
        Map<String, String> params = new HashMap<>();
        String responseStr = httpsRequest.doGet(apiDTO.getUrl(), params, "utf-8", "");
        JSONObject responseObj = JSON.parseObject(responseStr);
        if (!CommonConstant.STA_TRUE.equals(responseObj.get("sta").toString())) {
            log.info("接口异常");
        }
        JSONArray dataArray = responseObj.getJSONArray(CommonConstant.ZX_RES);
        if (CollectionUtils.isEmpty(dataArray)) {
            return;
        }
        List<DeviceInfoDTO> deviceInfoDTOS = dataArray.toJavaList(DeviceInfoDTO.class);
        for (int i = 0; i < deviceInfoDTOS.size(); i++) {
            DeviceInfoEntity entity0 = ConvertUtils.sourceToTarget(deviceInfoDTOS.get(i), DeviceInfoEntity.class);
            entity0.setId(UUID.randomUUID().toString());
            entity0.setCreateDate(new Date());
            entity0.setPid("0");
            baseDao.insert(entity0);
            List<DeviceInfoDTO> chd = deviceInfoDTOS.get(i).getChildren();
            if (CollectionUtils.isEmpty(chd)) {
                continue;
            }
            for (int j = 0; j < chd.size(); j++) {
                DeviceInfoEntity entity1 = ConvertUtils.sourceToTarget(chd.get(j), DeviceInfoEntity.class);
                entity1.setId(UUID.randomUUID().toString());
                entity1.setCreateDate(new Date());
                entity1.setPid(entity0.getId());
                baseDao.insert(entity1);
            }
        }
    }

    @Override
    public PageData<DeviceInfoDTO> page(Map<String, Object> params) {
        params.put("pid","0");
        IPage<DeviceInfoEntity> page = baseDao.selectPage(getPage(params, "no", true), getWrapper(params));
        return getPageData(page, DeviceInfoDTO.class);
    }

    @Override
    public List<DeviceInfoDTO> getchildrenList(String deviceId) {
        return baseDao.getchildrenList(deviceId);
    }

    @Override
    public DeviceInfoDTO get(String id) {

        DeviceInfoEntity entity = baseDao.selectById(id);

        return ConvertUtils.sourceToTarget(entity, DeviceInfoDTO.class);
    }

    @Override
    public void updateById(DeviceInfoDTO dto) {
        DeviceInfoEntity entity = ConvertUtils.sourceToTarget(dto, DeviceInfoEntity.class);
        baseDao.updateById(entity);
    }

    @Override
    public DeviceInfoDTO getByDevNo(String devNo) {
        QueryWrapper<DeviceInfoEntity> wrapper = new QueryWrapper<>();
        wrapper.eq("no", devNo);
        DeviceInfoEntity entity = baseDao.selectOne(wrapper);
        return ConvertUtils.sourceToTarget(entity, DeviceInfoDTO.class);
    }

    @Override
    public Long getTotal() {
        QueryWrapper<DeviceInfoEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("pid","0");
        return baseDao.selectCount(queryWrapper);
    }
}