huimv.farm.datacenter/huimv-farm-video/src/main/java/com/huimv/video/dhicc/timmer/SysTelcomEnentTimmer.java

package com.huimv.video.dhicc.timmer;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.huimv.video.dhicc.entity.SysTelecom;
import com.huimv.video.dhicc.entity.SysTelecomEvent;
import com.huimv.video.dhicc.entity.SysThreshold;
import com.huimv.video.dhicc.mapper.SysTelecomEventMapper;
import com.huimv.video.dhicc.mapper.SysTelecomMapper;
import com.huimv.video.dhicc.mapper.SysThresholdMapper;
import com.huimv.video.dhicc.service.ISysTelecomEventService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;


//主要用来生产烘干数据的 时间拿时间 --可以吧大华的代码赋值出来 自己改一改  应该是OK的
@Component
public class SysTelcomEnentTimmer {
    @Autowired
    private SysTelecomMapper sysTelecomMapper;
    @Autowired
    private SysTelecomEventMapper sysTelecomEventMapperMapper;
    @Autowired
    private ISysTelecomEventService sysTelecomEventService;

    @Autowired
    private SysThresholdMapper sysThresholdMapper ;
    //检查烘干是否合格--找出时间 阈值直接计算
   // @Scheduled(cron = " 0/10 * * * * ? ")
    @Scheduled(cron = " 0 */59 * * * ? ")
    private void checkOk() {

        //拿对应牧场的阈值
        LambdaQueryWrapper<SysThreshold> wrapper1 = Wrappers.lambdaQuery();
        wrapper1.eq(SysThreshold::getFarmId, 1);
        SysThreshold sysThreshold = sysThresholdMapper.selectOne(wrapper1);//System.out.println(sysTelecoms);
       // System.out.println("yuzhi"+sysThreshold);

        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        Calendar TimeDeviceId = Calendar.getInstance();
        TimeDeviceId.setTime(new Date());
        TimeDeviceId.add(Calendar.HOUR_OF_DAY, -30);
        Date began1time = TimeDeviceId.getTime();
        String startTime1 = format.format(began1time);
        String endTime1 = format.format(new Date());

        //拿事件
        LambdaQueryWrapper<SysTelecomEvent> wrapper = Wrappers.lambdaQuery();
        wrapper.eq(SysTelecomEvent::getFarmId, 1);
        wrapper.between(SysTelecomEvent::getEventTime, startTime1, endTime1);
        List<SysTelecomEvent> SysTelecomEvent = sysTelecomEventMapperMapper.selectList(wrapper);//System.out.println(sysTelecoms);
       // System.out.println("yuzhi"+SysTelecomEvent);

        for (SysTelecomEvent sysTelecomEvent : SysTelecomEvent) {
           // System.out.println("yuzhi"+sysTelecomEvent);
            Calendar eventTime = Calendar.getInstance();
            eventTime.setTime(sysTelecomEvent.getEventTime());
            //事件时间就是开始时间
            String EventStartTime = format.format(sysTelecomEvent.getEventTime());
            //一次烘干50度以上一般在8次左右  就是说40分钟  这里取一小时
            eventTime.add(Calendar.MINUTE, +60);
            Date EventEndTime1 = eventTime.getTime();
            String EventEndTime = format.format(EventEndTime1);

            //查第一次五十度事件之后的数据  统计持续在设定温度之上的事件
            LambdaQueryWrapper<SysTelecom> wrapper3 = Wrappers.lambdaQuery();
            wrapper3.eq(SysTelecom::getDeviceId, sysTelecomEvent.getDeviceId());
            wrapper3.eq(SysTelecom::getFarmId, 1);
            wrapper3.between(SysTelecom::getTimestamp, EventStartTime, EventEndTime);
            List<SysTelecom> sysTelecoms = sysTelecomMapper.selectList(wrapper3);//System.out.println(sysTelecoms);

           Integer count  =0;
            for (SysTelecom sysTelecom : sysTelecoms) {
                if (Double.parseDouble(sysTelecom.getTemp())>Double.parseDouble(sysThreshold.getBenconValue())){
                    count++;

                }
            }
             if(   Double.parseDouble(sysThreshold.getBenconValue())<  count*5){
                System.out.println("高于阈值温度时间"+count*5);
                 //正确烘干为1

                 sysTelecomEvent.setRemark("1");
             }else { sysTelecomEvent.setRemark("0");}
            System.out.println("存储"+sysTelecomEvent.getRemark());
            sysTelecomEventService.updateById(sysTelecomEvent);

            //System.out.println("事件时间=" + EventStartTime + sysTelecoms);
        }
    }

       //每小时执行一次
       //@Scheduled(cron = " 0 */59 * * * ? ")
       // @Scheduled(cron = " 0/5 * * * * ? ")
      // @Scheduled(cron = " 0/50 * * * * ? ")
       private void updateBox() {
           //获得设备列表 查找烘干数据
           SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
           LambdaQueryWrapper<SysTelecom> lambdaQueryWrapper =
                   new LambdaQueryWrapper<>();
           lambdaQueryWrapper
                   .select(SysTelecom::getDeviceId);
           List<String> collect = sysTelecomMapper.selectObjs(lambdaQueryWrapper).stream().map(o -> (String) o).collect(Collectors.toList());
           //System.out.println(collect);
           for (String deviceId : collect) {
               Calendar TimeDeviceId = Calendar.getInstance();
               TimeDeviceId.setTime(new Date());
               TimeDeviceId.add(Calendar.HOUR, -300);
               Date began1time = TimeDeviceId.getTime();
               String startTime1 = format.format(began1time);
               String endTime1 = format.format(new Date());
               LambdaQueryWrapper<SysTelecom> wrapper = Wrappers.lambdaQuery();
                   wrapper.eq(SysTelecom::getDeviceId, deviceId);
                   wrapper.eq(SysTelecom::getFarmId, 1);
                   wrapper.between(SysTelecom::getTimestamp, startTime1, endTime1);
               List<SysTelecom> sysTelecoms = sysTelecomMapper.selectList(wrapper);//System.out.println(sysTelecoms);
               for (SysTelecom sysTelecom : sysTelecoms) {
                    if( Double.parseDouble(sysTelecom.getTemp())>50){
                        System.out.println("温度"+sysTelecom.getTemp()+sysTelecom.getDeviceId()+sysTelecom.getTimestamp());
                        //产生时间段
                        Calendar eventTime = Calendar.getInstance();
                        eventTime.setTime(sysTelecom.getTimestamp());
                        eventTime.add(Calendar.MINUTE, -60);
                        Date began = eventTime.getTime();
                        String EventStartTime = format.format(began);
                        eventTime.add(Calendar.MINUTE, +110);
                        Date EventEndTime1 = eventTime.getTime();
                        String EventEndTime = format.format(EventEndTime1);
                        //查询在大于50摄氏度这条记录的 前60分钟 后60分钟  时间里，有没有存储过报警事件  有就放弃  没有就加一条
                        int count = sysTelecomEventService.count(Wrappers.<SysTelecomEvent>lambdaQuery()
                                .eq(SysTelecomEvent::getDeviceId,sysTelecom.getDeviceId())
                                .eq(SysTelecomEvent::getFarmId,sysTelecom.getFarmId())
                                .between(SysTelecomEvent::getEventTime, EventStartTime, EventEndTime));
                       System.out.println("插结果"+count);
                        if(count==0){
                           // System.out.println("保存了一条");
                            SysTelecomEvent sysTelecomEvent = new SysTelecomEvent();
                            sysTelecomEvent.setDeviceId(sysTelecom.getDeviceId());
                            sysTelecomEvent.setEventTime(sysTelecom.getTimestamp());
                            sysTelecomEvent.setEventId(sysTelecom.getId());
                            sysTelecomEvent.setFarmId(sysTelecom.getFarmId());
                            sysTelecomEvent.setRemark(sysTelecom.getTemp());
                            sysTelecomEventService.save(sysTelecomEvent);
                        }
                       // System.out.println("抛弃");
                    }
               }
           }
       }
}