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");
//    }
}