package com.nanometer.smartlab.api.schedule;

import com.alibaba.fastjson.JSON;
import com.nanometer.smartlab.entity.BaseMeta;
import com.nanometer.smartlab.service.*;
import com.nanometer.smartlab.util.Constants;
import org.apache.commons.lang.time.DateFormatUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;

import javax.annotation.Resource;
import java.text.ParseException;
import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedHashMap;
import java.util.List;

/**
 * Created by Caspar on 18/4/22.
 */
@Component
//@EnableScheduling
public class ReagentSyncSchedule {

    private static Logger logger = Logger.getLogger(ReagentSyncSchedule.class);

    @Value("${reagent.flow.url}")
    private String reagentFlowUrl;
    @Value("${reagent.status.url}")
    private String reagentStatusUrl;
    @Value("${sensors.url}")
    private String reagentSensorsUrl;
    @Lazy
    @Resource
    private BaseMetaService baseMetaService;
    @Lazy
    @Resource
    private OpeReagentStatusService reagentStatusService;
    @Lazy
    @Resource
    private OpeUseFlowService opeUseFlowService;
    @Lazy
    @Resource
    private SysContainerSensorsService sysContainerSensorsService;
    @Lazy
    @Resource
    private SysUserService sysUserService;

    private static String reagentStatusLastdate = null;
    private static String reagentFlowLastdate = null;

    //@Scheduled(fixedDelayString = "${reagent.status.schedule.delay}")
    public void syncReagentStatus(){
        Date current = new Date();
        BaseMeta baseMeta = null;
		baseMeta = baseMetaService.getBaseMeta("syncreagentstatuslastdata");
        if(reagentStatusLastdate == null) {
            reagentStatusLastdate = baseMeta.getMetaValue();
        }

        RestTemplate client = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        MultiValueMap<String, String> varParams= new LinkedMultiValueMap<String, String>();
        varParams.add("startTime",reagentStatusLastdate);
        String lastDate = DateFormatUtils.format(current, Constants.TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
        varParams.add("endTime",lastDate);

		logger.info("startTime： "+reagentStatusLastdate+"lastDate "+lastDate);

        HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<MultiValueMap<String, String>>(varParams, headers);
        ResponseEntity<LinkedHashMap> response = client.postForEntity(reagentStatusUrl, requestEntity , LinkedHashMap.class );
        List<LinkedHashMap> data = (ArrayList)response.getBody().get("data");
        if(CollectionUtils.isEmpty(data)==false){
            logger.info("result data: "+ JSON.toJSONString(data));
            reagentStatusService.syncOpeReagentStatus(data);
        }
        reagentStatusLastdate = lastDate;
        baseMeta.setMetaValue(reagentStatusLastdate);
        baseMetaService.updateBaseMeta(baseMeta);
    }

    //@Scheduled(fixedDelayString = "${reagent.flow.schedule.delay}")
    public void syncReagentFlow() throws ParseException{
        Date current = new Date();
        BaseMeta baseMeta = null;
		baseMeta = baseMetaService.getBaseMeta("syncreagentflowlastdata");
        if(reagentFlowLastdate == null) {
            reagentFlowLastdate = baseMeta.getMetaValue();
        }

        RestTemplate client = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        MultiValueMap<String, String> varParams= new LinkedMultiValueMap<String, String>();
        varParams.add("startTime",reagentFlowLastdate);
        String lastDate = DateFormatUtils.format(current, Constants.TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
        varParams.add("endTime",lastDate);

		logger.info("startTime： "+reagentStatusLastdate+"lastDate "+lastDate);

        HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<MultiValueMap<String, String>>(varParams, headers);
        ResponseEntity<LinkedHashMap> response = client.postForEntity(reagentFlowUrl, requestEntity , LinkedHashMap.class );
        List<LinkedHashMap> data = (ArrayList)response.getBody().get("data");
        if(CollectionUtils.isEmpty(data)==false){
            opeUseFlowService.syncReagentFlow(data);
            //[{"status":1,"containerCode":"c1000-001","updateTime":"2018-04-15 11:23:49","reagentCode":"r2010-0001","idcard":"u001"}....]
            logger.info("result data: "+JSON.toJSONString(data));
        }
        baseMeta.setMetaValue(lastDate);
        reagentFlowLastdate = lastDate;
        baseMetaService.updateBaseMeta(baseMeta);
    }

    //@Scheduled(fixedDelayString = "${sensors.schedule.delay}")
    public void syncSensors() {
        Date current = new Date();
        BaseMeta baseMeta = baseMetaService.getBaseMeta("syncsensorslastdata");
        RestTemplate client = new RestTemplate();
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
        MultiValueMap<String, String> varParams= new LinkedMultiValueMap<String, String>();
        varParams.add("startTime",baseMeta.getMetaValue());
        varParams.add("endTime",DateFormatUtils.format(current,Constants.TIME_PATTERN_YYYY_MM_DD_HH_MM_SS));
        HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<MultiValueMap<String, String>>(varParams, headers);
        ResponseEntity<LinkedHashMap> response = client.postForEntity(reagentSensorsUrl, requestEntity , LinkedHashMap.class );
        LinkedHashMap body = response.getBody();
        List<LinkedHashMap> data = body == null ? null : (ArrayList) body.get("data");
        if(!CollectionUtils.isEmpty(data)){
            try {
                logger.info("result data: " + JSON.toJSONString(data));
                sysContainerSensorsService.syncSysContainerSensors(data);
                //{"data": [{"containerCode": "c1000-003", "Temp": 28.0, "Flag": 16, "Humidity": 58, "updateTime": "2018-04-18 13:37:46", "voc1": 20}], "func": "sensors", "method": "POST", "message": "OK", "code": 0}
                baseMeta.setMetaValue(DateFormatUtils.format(current, Constants.TIME_PATTERN_YYYY_MM_DD_HH_MM_SS));
                baseMetaService.updateBaseMeta(baseMeta);
            }catch (Exception e){
                logger.error("error occured.", e);
            }
        }
    }


    @Scheduled(cron = "0 0 2 1 * ?")
    public void updateUserPoint() {
        logger.debug("updateUserPoint start,and now is "+new Date());
        sysUserService.updateUserPointBySelective(20,null);
        logger.debug("updateUserPoint end");
    }
}