/*
package com.thhy.screen.modules.biz.bigscreen.controller;

import com.alibaba.fastjson.JSON;
import com.thhy.general.common.BasicResult;
import com.thhy.general.common.enums.ProListenType;
import com.thhy.general.common.enums.TopicConstant;
import com.thhy.general.config.GlobalConfig;
import com.thhy.screen.modules.biz.bigscreen.entity.*;
import com.thhy.screen.modules.biz.bigscreen.mapper.BigScreenMapper;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.redisson.api.RBucket;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.websocket.Session;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CopyOnWriteArraySet;

@Component
@RocketMQMessageListener(topic = "prolistenexc",consumerGroup = TopicConstant.PROLISTENEXC_GROUP)
public class ExecProListen implements RocketMQListener<String> {

    @Autowired
    private RedissonClient redissonClient;

    @Autowired
    private GlobalConfig globalConfig;

    @Autowired
    private BigScreenMapper bigScreenMapper;

    private Logger logger = LoggerFactory.getLogger("ExecProListen");

    @Override
    public void onMessage(String s) {
        logger.info("生产监控终端处理收到消息"+s);
        System.out.println("需要更新的模块"+s);
        CopyOnWriteArraySet<Session> SESSIONS = ProListenSocketServer.SESSIONS;
        SESSIONS.forEach(session ->{
            try {
                List<Map<String,Object>> mapList = getData(session,s);

                if (session.isOpen()) {
                    session.getBasicRemote().sendText(JSON.toJSONString(BasicResult.success(mapList)));
                    logger.info("成功推送消息到生产监控大屏"+session.getId()+"___"+session.getRequestURI().getHost());
                }
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
        });
    }

    public List<Map<String,Object>> getData(Session session,String dataType){
        RBucket<String> companyRBucket = redissonClient.getBucket(globalConfig.getKeyPrefix()+":ws:company:"+session.getId());
        String companyId = companyRBucket.get();
        List<Map<String,Object>> mapList = new ArrayList<>();
        Map<String,Object> map = new HashMap<>();
        map.put("mod",dataType);
        if(dataType.equals(ProListenType.PIPEYEARMONTH)){
            //管片年度和月度
            Map<String,Object> map1 = new HashMap<>();
            PipePlanActual pipePlanActual = bigScreenMapper.pipePlanActual(companyId);
            map1.put("mod",ProListenType.PIPEPLANACTUAL);
            map1.put("pipePlanActual",pipePlanActual);
            mapList.add(map1);
            Map<String,Object> map2 = new HashMap<>();
            List<PipeMonthPlanActual> pipeMonthPlanActuals = bigScreenMapper.pipeMonthPlanActual(companyId);
            map2.put("mod",ProListenType.PIPEMONTHPLANACTUAL);
            map2.put("pipeMonthPlanActual",pipeMonthPlanActuals);
            mapList.add(map2);
            return mapList;
        }else if(dataType.equals(ProListenType.MATERIALWEEKANDMONTHS)){
            //原料消耗 周月
            List<MaterialWeekAndMonth> materialWeekAndMonths = bigScreenMapper.materialWeekAndMonth(companyId);
            map.put("materialWeekAndMonths",materialWeekAndMonths);
        }else if (dataType.equals(ProListenType.PIPEPLANACTUAL)){
            //年度生产计划和实际完成
            PipePlanActual pipePlanActual = bigScreenMapper.pipePlanActual(companyId);
            map.put("pipePlanActual",pipePlanActual);
        }else if (dataType.equals(ProListenType.PIPEMONTHPLANACTUAL)){
            //月度生产计划和实际完成
            List<PipeMonthPlanActual> pipeMonthPlanActuals = bigScreenMapper.pipeMonthPlanActual(companyId);
            map.put("pipeMonthPlanActual",pipeMonthPlanActuals);
        }else if (dataType.equals(ProListenType.WATERCULINFO)){
            //水养池
            List<WaterCulInfo> culInfoList = bigScreenMapper.WaterCulInfo(companyId);
            map.put("waterCulInfo",culInfoList);
        }else if (dataType.equals(ProListenType.REPOINFO)){
            //堆场
            List<RepoInfo> repoInfoList = bigScreenMapper.repoInfo(companyId);
            map.put("repoInfo",repoInfoList);
        }else if (dataType.equals(ProListenType.SENDINFO)){
            //发运
            Map<String,Object> map1 = new HashMap<>();
            List<SendInfo> sendInfoList = bigScreenMapper.sendInfo(companyId);
            map1.put("mod",ProListenType.SENDINFO);
            map1.put("sendInfo",sendInfoList);

            Map<String,Object> map2 = new HashMap<>();
            List<RepoInfo> repoInfoList = bigScreenMapper.repoInfo(companyId);
            map2.put("mod",ProListenType.REPOINFO);
            map2.put("repoInfo",repoInfoList);
            mapList.add(map1);
            mapList.add(map2);
            return mapList;
        }
        mapList.add(map);
        return mapList;
    }
}
*/