~zhitong.yu/NewBs.git

package com.hxzk.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hxzk.mapper.WarningDao;
import com.hxzk.pojo.TbSetting;
import com.hxzk.pojo.TbTag;
import com.hxzk.pojo.TbWarning;
import com.hxzk.service.SettingService;
import com.hxzk.service.WarningService;
import org.apache.ibatis.jdbc.Null;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.time.temporal.TemporalAdjusters;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
 
import static com.baomidou.mybatisplus.core.toolkit.StringPool.NULL;
 
@Service
public class WarningServiceImpl extends ServiceImpl<WarningDao, TbWarning> implements WarningService {
 
    private String wcl;
 
    @Autowired
    WarningDao warningDao;
    @Autowired
    SettingService settingService;
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findAll(Integer page, Integer limit) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        PageHelper.startPage(page,limit);
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelect();
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findAllAPI() {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelect();
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findAllHouTai(Integer page, Integer limit) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        PageHelper.startPage(page,limit);
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelectHouTai();
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findAllStatus(Integer page, Integer limit) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        PageHelper.startPage(page,limit);
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelect();
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findwarningSearch(Integer page, Integer limit, TbWarning warning) {
        QueryWrapper<TbWarning> queryWrapper = new QueryWrapper<>();
        PageHelper.startPage(page,limit);
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelectsearch(warning.getObjectid());
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<com.hxzk.deo.TbWarning> findwarningSearchHouTai(Integer page, Integer limit, TbWarning warning) {
        QueryWrapper<TbWarning> queryWrapper = new QueryWrapper<>();
        PageHelper.startPage(page,limit);
        List<com.hxzk.deo.TbWarning> cardList = warningDao.findSelectsearchHouTai(warning.getObjectid());
        PageInfo<com.hxzk.deo.TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public PageInfo<TbWarning> findwarningScreen(Integer page, Integer limit, TbWarning warning) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.like("type",warning.getType());
        PageHelper.startPage(page,limit);
        List<TbWarning> cardList = baseMapper.selectList(queryWrapper);
        PageInfo<TbWarning> info = new PageInfo<>(cardList);
        return info;
    }
 
    @Override
    public List<com.hxzk.deo.TbWarning> findDaPingGaoJing() {
        Languages();
       List<com.hxzk.deo.TbWarning> warnings = warningDao.findDaPingGaoJing(wcl);
       List<com.hxzk.deo.TbWarning> warningList = warningDao.findDaPingGaoJingRenYuanJuJi();
       for (int i = 0 ; i < warningList.size();i++){
           warnings.add(warningList.get(i));
       }
       return warnings;
    }
 
    @Override
    public Integer findDaPingWeiChuLiCount() {
        return warningDao.findDaPingWeiChuLiCount();
    }
 
    @Override
    public TbWarning findIdXiangXi(Integer id) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("id",id);
        return baseMapper.selectOne(queryWrapper);
    }
 
    @Override
    public TbWarning findIdXiangXitagid(Integer id) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("objectid",id);
        return baseMapper.selectOne(queryWrapper);
    }
 
    @Override
    public void ChuliWarning(TbWarning warning, String ids) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("id",ids);
        baseMapper.update(warning,queryWrapper);
    }
 
    @Override
    public void DaPingChuliWarning(TbWarning warning) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("objectid",warning.getObjectid());
        baseMapper.update(warning,queryWrapper);
    }
 
    @Override
    public TbWarning findtagidWarning(String ids) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("id",ids);
        return baseMapper.selectOne(queryWrapper);
    }
 
    @Override
    public void UpWarningIsshow(String type) {
            baseMapper.UpWarningIsshow(type);
    }
 
    @Override
    public void UpAllWarning(TbWarning warning) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        if (warning.getStatus().equals("Обработано")){
            queryWrapper.eq("status","Необработано");
        }else{
            queryWrapper.eq("status","未处理");
        }
 
        if (warning.getType().equals("全部") || warning.getType().equals("Bce")){
            if (warning.getType().equals("Bce")){
                warningDao.UpStatusAll(warning);
            }else{
                warningDao.UpStatusAll(warning);
            }
 
        }else{
            queryWrapper.eq("type",warning.getType());
            baseMapper.update(warning,queryWrapper);
        }
 
    }
 
    @Override
    public List<com.hxzk.deo.TbWarning> findNowAll(String type) {
        return warningDao.findNowAll(type);
    }
 
    @Override
    public TbWarning findIdWarning(Integer id) {
        QueryWrapper queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("id",id);
        return baseMapper.selectOne(queryWrapper);
    }
 
    @Override
    public void updateIDWarning(Integer id) {
        warningDao.updateIdWarning(id);
    }
 
    @Override
    public List<TbWarning> findYuYinWarning() {
        return warningDao.findYuYinWarning();
    }
 
    @Override
    public List<TbWarning> findYuYinWarningYiCi() {
        return warningDao.findYuYinWarningYiCi();
    }
 
    @Override
    public String UpWarningBaoLiu9(String[] dataArray) {
        for (int i = 0 ; i < dataArray.length;i++){
            String[] a = dataArray[i].split("-");
            warningDao.updateWarningBaoliu9(a[0]);
        }
        return "success";
    }
 
    @Override
    public List findTypeCountWarning() {
        List countList = new ArrayList<>();
        Integer sos = warningDao.FindSOSCount();
        Integer chuqu = warningDao.FindChuQuCount();
        Integer jinru = warningDao.FindJinRuCount();
        Integer dieluo = warningDao.FindDieLuoCount();
        Integer ceju = warningDao.FindCeJuCount();
        Integer didianliang = warningDao.FindDdlCount();
        Integer chaoyuan = warningDao.FindChaoYuanCount();
        countList.add(sos);
        countList.add(chuqu);
        countList.add(jinru);
        countList.add(dieluo);
        countList.add(ceju);
        countList.add(didianliang);
        countList.add(chaoyuan);
        return countList;
    }
 
    @Override
    public List findDayCountWarning() {
        List countList = new ArrayList<>();
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
 
        // 获取当前日期
        LocalDate today = LocalDate.now();
        // 获取当前月份的第一天
        LocalDate firstDayOfMonth = today.with(TemporalAdjusters.firstDayOfMonth());
        // 获取当前月份的最后一天
        LocalDate lastDayOfMonth = today.with(TemporalAdjusters.lastDayOfMonth());
 
        // 存储所有日期的列表
        List<LocalDateTime> dates = new ArrayList<>();
 
        // 遍历本月的每一天
        LocalDate currentDay = firstDayOfMonth;
        while (!currentDay.isAfter(lastDayOfMonth)) {
            // 将 LocalDate 转换为 LocalDateTime
            LocalDateTime dateTime = currentDay.atStartOfDay();
            dates.add(dateTime);
            // 递增一天
            currentDay = currentDay.plusDays(1);
        }
 
        // 打印所有日期
        for (LocalDateTime dateTime : dates) {
            countList.add(warningDao.FindDayCountWarning(dateTime.format(formatter)));
        }
        return countList;
    }
 
    public void Languages(){
        List<TbSetting> setting = settingService.FindSetting();
        if (setting.get(0).getLanguages().equals("0")){
            wcl = "未处理";
        }
        if (setting.get(0).getLanguages().equals("2")){
            wcl = "Необработано";
        }
    }
}