package com.moral.api.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.moral.api.entity.BenchmarkWindConfig;
import com.moral.api.entity.Device;
import com.moral.api.entity.WindModel;
import com.moral.api.entity.WindModelConfig;
import com.moral.api.mapper.BenchmarkWindConfigMapper;
import com.moral.api.mapper.DeviceMapper;
import com.moral.api.mapper.WindModelConfigMapper;
import com.moral.api.mapper.WindModelMapper;
import com.moral.api.service.WindModelService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.constant.Constants;
import com.moral.util.DateUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

/**
 * <p>
 *  服务实现类
 * </p>
 *
 * @author moral
 * @since 2022-08-10
 */
@Service
public class WindModelServiceImpl extends ServiceImpl<WindModelMapper, WindModel> implements WindModelService {

    @Autowired
    private BenchmarkWindConfigMapper benchmarkWindConfigMapper;

    @Autowired
    private RedisTemplate redisTemplate;

    @Autowired
    private WindModelMapper windModelMapper;

    @Autowired
    private DeviceMapper deviceMapper;

    @Autowired
    private WindModelConfigMapper windModelConfigMapper;

    @Override
    public void windFieldStatistics() {
        QueryWrapper<WindModelConfig> windModelConfigQueryWrapper = new QueryWrapper<>();
        windModelConfigQueryWrapper.eq("is_delete",Constants.NOT_DELETE);
        List<WindModelConfig> windModelConfigs = windModelConfigMapper.selectList(windModelConfigQueryWrapper);
        List<Integer> orgIdList = windModelConfigs.stream().map(WindModelConfig::getOrganizationId).collect(Collectors.toList());
        QueryWrapper<BenchmarkWindConfig> benchmarkWindConfigQueryWrapper = new QueryWrapper<>();
        benchmarkWindConfigQueryWrapper.eq("is_delete",Constants.NOT_DELETE);
        benchmarkWindConfigQueryWrapper.in("organization_id",orgIdList);
        List<Map<String, Object>> benchmarkWindConfigMaps = benchmarkWindConfigMapper.selectMaps(benchmarkWindConfigQueryWrapper);
        for (Map<String, Object> benchmarkWindConfig:benchmarkWindConfigMaps) {
            String benchmark = benchmarkWindConfig.get("benchmark").toString();
            String preservation = benchmarkWindConfig.get("preservation").toString();
            JSONObject benchmarkJson = JSONObject.parseObject(benchmark);
            JSONObject preservationJson = JSONObject.parseObject(preservation);
            Iterator benchmarkJsonIter = benchmarkJson.entrySet().iterator();
            Iterator preservationJsonIter = preservationJson.entrySet().iterator();
            JSONObject windModelJson = new JSONObject();
            while (benchmarkJsonIter.hasNext()) {
                Map.Entry entry = (Map.Entry) benchmarkJsonIter.next();
                if (redisTemplate.opsForHash().hasKey("data_second",entry.getValue())){
                    Object benchmarkObject = redisTemplate.opsForHash().get("data_second",entry.getValue());
                    Map benchmarkMap = JSONObject.parseObject(JSONObject.toJSONString(benchmarkObject), Map.class);
                    windModelJson.put(entry.getKey().toString(),benchmarkMap.get("a01008"));
                }
            }
            JSONObject windModelValue = new JSONObject();
            while (preservationJsonIter.hasNext()) {
                Map.Entry entry = (Map.Entry) preservationJsonIter.next();
                if (redisTemplate.opsForHash().hasKey("data_second",entry.getValue())){
                    Object preservationObject = redisTemplate.opsForHash().get("data_second",entry.getValue());
                    QueryWrapper<Device> deviceQueryWrapper = new QueryWrapper<>();
                    deviceQueryWrapper.eq("is_delete", Constants.NOT_DELETE);
                    deviceQueryWrapper.eq("mac",entry.getValue());
                    Device device = deviceMapper.selectOne(deviceQueryWrapper);
                    Map preservationMap = JSONObject.parseObject(JSONObject.toJSONString(preservationObject), Map.class);
                    Object[] preservationArray = new Object[4];
                    preservationArray[0] = device.getLongitude();
                    preservationArray[1] = device.getLatitude();
                    preservationArray[2] = preservationMap.get("a01007");
                    preservationArray[3] = preservationMap.get("a01008");
                    windModelValue.put(entry.getKey().toString(),preservationArray);
                }
            }
            int dayOfMonth = DateUtils.getDay(new Date());
            int remainder = dayOfMonth % 15;
            String remainderStr = "";
            if (remainder<10){
                remainderStr = "0"+remainder;
            }else {
                remainderStr = remainder+"";
            }
            Map<String,Object> insertMap = new HashMap<>();
            insertMap.put("destinationTab",benchmarkWindConfig.get("destination_tab").toString()+remainderStr);
            insertMap.put("json",windModelJson.toJSONString());
            insertMap.put("value",windModelValue.toJSONString());
            windModelMapper.insert(insertMap);
        }
    }
}