package com.qianwen.smartman.modules.cps.controller;

import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;

import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;

import com.qianwen.core.boot.ctrl.BladeController;
import com.qianwen.core.datascope.props.DataScopeProperties;
import com.qianwen.core.mp.intercept.QueryInterceptor;
import com.qianwen.core.scanner.modular.annotation.GetResource;
import com.qianwen.core.scanner.modular.stereotype.ApiResource;
import com.qianwen.core.secure.annotation.PreAuth;
import com.qianwen.core.tenant.annotation.NonDS;
import com.qianwen.core.tool.api.R;
import com.qianwen.core.tool.utils.SpringUtil;
import com.qianwen.core.websocket.config.WebSocketMessageSender;
import com.qianwen.core.websocket.distribute.MessageDO;
import com.qianwen.core.websocket.distribute.RedisMessageDistributor;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.websocket.realtime.RealTimeDaraResponseJsonWebSocketMessage;
import com.qianwen.smartman.modules.cps.message.dto.TelemetryDataResponseDTO;
import com.qianwen.smartman.modules.cps.service.CollectDeviceTypeService;
import com.qianwen.smartman.modules.cps.service.ICommonGroupService;
import com.qianwen.smartman.modules.cps.service.WorkstationDatapointsService;
import com.qianwen.smartman.modules.cps.vo.CollectDeviceTypeVO;
import com.qianwen.smartman.modules.cps.vo.WorkstationDatapointsVO;
import com.qianwen.smartman.modules.cps.vo.WorkstationGroupVO;
import com.qianwen.smartman.modules.mdc.dto.ProcessParameterVO;
import com.qianwen.smartman.modules.mdc.mapper.SuperProcessParameterMapper;

import cn.hutool.json.JSONUtil;

import org.apache.commons.io.IOUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@Api(value = "test", tags = {"test"})
@RestController
@ApiResource({"smis/test"})
public class MyTestController {// extends BladeController
    
    @Autowired
    private WorkstationDatapointsService workstationDatapointsService;
   
    @Autowired
    private CollectDeviceTypeService typeService;
    
    @Autowired
    DataScopeProperties dsp;
    @Autowired
    QueryInterceptor qi;
    @Autowired
    SuperProcessParameterMapper pmapper;
    
    @GetMapping({"/dsp"})
    @ApiOperation("dsp")
    public R<String> showdsp() {
    	Properties props = System.getProperties();
        String appName = props.getProperty("spring.application.name");
        return R.data(appName);
    }
    
    @GetMapping({"/realtimesend"})
    @ApiOperation("realtimesend")
    public R<String> realtimesend(String wid,String k,String v) {
    	RedisMessageDistributor messageDistributor = (RedisMessageDistributor) SpringUtil.getBean(RedisMessageDistributor.class);
    	
    	RealTimeDaraResponseJsonWebSocketMessage jsonWebSocketMessage = new RealTimeDaraResponseJsonWebSocketMessage();
        jsonWebSocketMessage.setId(wid);
        
        Map<String, Object> map = WorkstationCache.getWorkstationRealTime(wid);
        map.keySet().forEach(key->{
        	if(key.equals(k)) {
        		Object d = map.get(k);
        		
        		TelemetryDataResponseDTO a = (TelemetryDataResponseDTO)d;
        		a.setV(v);
        		System.out.println(d);
        	}
        });
        jsonWebSocketMessage.setData(map);
        
        MessageDO messageDO = new MessageDO();
        messageDO.setNeedBroadcast(false);
        messageDO.setMessageText(JSONUtil.toJsonStr(jsonWebSocketMessage));
        messageDistributor.distribute(messageDO);
        
   
        return R.data("1");
    }
    
    
    
    @GetMapping({"/listDatapointsByWorkstationId"})
    @ApiOperation("根据工位id获取数据点")
    public R<String> listDatapointsByWorkstationId() {
    	
    	//InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("dp/dpstart.json");
    	String str;
		try {
			str = IOUtils.resourceToString("/dp/dpstart.json",  Charset.forName("utf8"));
		} catch (IOException e) {
			str = "error";
			e.printStackTrace();
		}

        return R.data(str);
    }
    
    
    @GetMapping({"/typelist"})
    @ApiOperation("采集类型列表")
    public R<List<CollectDeviceTypeVO>> typelist() {
    	
    	
        return R.data(typeService.typeList());
    }
    
    @GetMapping({"/lastP"})
    @ApiOperation("采集类型列表")
    public R<ProcessParameterVO> lastP() {//1656818952295661569_DeviceStatus
    	ProcessParameterVO vo = this.pmapper.lastParameterNotEqValue(1656818952295661569L, "DeviceStatus", "2");
    	ProcessParameterVO vo1 = this.pmapper.firstParameterEqValueGtTime(1656818952295661569L, "DeviceStatus", "2",System.currentTimeMillis()-20000);
    	
        return R.data(vo);
    }
    
    
}