update

whycrzg

2021-02-23 351b9a53cb9ecebdf8f79db0117f540d9c42c2a4

 src/main/java/com/fgkj/services/Batt_devalarm_dataService.java

@@ -1,31 +1,31 @@
package com.fgkj.services;

import com.fgkj.dto.BattInf;
import com.fgkj.dto.Batt_devalarm_data;
import com.fgkj.dto.ServiceModel;
import com.fgkj.dto.User_log;
import com.fgkj.dto.*;
import com.fgkj.mapper.UinfDaoFactory;
import com.fgkj.mapper.impl.Batt_devalarm_dataMapper;
import com.fgkj.mapper.impl.Battalarm_dataMapper;
import org.springframework.beans.factory.annotation.Autowired;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;

@Service
public class Batt_devalarm_dataService {

   @Autowired
   @Resource
   private Batt_devalarm_dataMapper mapper;

   @Autowired
   @Resource
   private Battalarm_dataMapper battAlarmDataMapper;

   private ServiceModel model;
   @Resource
   private User_logService userLogService;
   
   //3.4设备实时告警(确认和取消告警)
   public ServiceModel update(Object obj) {
      ServiceModel model = new ServiceModel();
      Boolean bl=mapper.update(obj);
      if(bl){
         model.setCode(1);
@@ -38,6 +38,7 @@
   }
   //3.4设备实时告警/历史告警(删除告警)
   public ServiceModel delete(Object obj) {
      ServiceModel model = new ServiceModel();
      Boolean bl=mapper.del(obj);
      if(bl){
         model.setCode(1);
@@ -50,24 +51,19 @@
   }

   //3.4设备实时告警(确认告警)<多数据修改>
   public ServiceModel updatePro(Object obj) {
      List<Batt_devalarm_data> list=(List<Batt_devalarm_data>) obj;
      ArrayList<String> sql_str = new ArrayList<String>();//存放所有的sql语句
   public ServiceModel updatePro(List<Batt_devalarm_data> list) {
      ServiceModel model = new ServiceModel();
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      for(int i=0;i<list.size();i++){
         Batt_devalarm_data ddata=list.get(i);
         String sql=mapper.updatePro(ddata);
         sql_str.add(sql);
         {
            String msg="确认"+ddata.getStationName()+ddata.getNote()+"的告警";
            User_log ulog= UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
            listU.add(ulog);
          }
      }
      //TODO perry待做
      Boolean bl= true;
      //Boolean bl= DateUtil.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      Boolean bl = mapper.updatePro(list)>0;
      userLogService.addPro(listU);//将用户的操作记录下来
      if(bl){
         model.setCode(1);
         model.setMsg("修改成功!");
@@ -78,24 +74,19 @@
      return model;   
   }
   //3.4设备实时告警(取消告警)<多数据修改>
   public ServiceModel cancelPro(Object obj) {
      List<Batt_devalarm_data> list=(List<Batt_devalarm_data>) obj;
      ArrayList<String> sql_str = new ArrayList<String>();//存放所有的sql语句
   public ServiceModel cancelPro(List<Batt_devalarm_data> list) {
      ServiceModel model = new ServiceModel();
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      for(int i=0;i<list.size();i++){
         Batt_devalarm_data ddata=list.get(i);
         String sql=mapper.cancelPro(ddata);
         sql_str.add(sql);
         {
            String msg="取消"+ddata.getStationName()+ddata.getNote()+"的告警";
            User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Alter, msg);
            listU.add(ulog);
          }
      }
      //TODO perry待做
      Boolean bl= true;
      //Boolean bl = DateUtil.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      Boolean bl= mapper.cancelPro(list)>0;
      userLogService.addPro(listU);//将用户的操作记录下来
      if(bl){
         model.setCode(1);
         model.setMsg("取消成功!");
@@ -106,24 +97,19 @@
      return model;   
   }
   //3.4设备实时告警/历史告警(删除告警)<多数据删除>
   public ServiceModel deletePro(Object obj) {
      List<Batt_devalarm_data> list=(List<Batt_devalarm_data>) obj;
      ArrayList<String> sql_str = new ArrayList<String>();//存放所有的sql语句
   public ServiceModel deletePro(List<Batt_devalarm_data> list) {
      ServiceModel model = new ServiceModel();
      List<User_log> listU=new ArrayList<User_log>();//存放user_log
      for(int i=0;i<list.size();i++){
         Batt_devalarm_data ddata=list.get(i);
         String sql=mapper.delPro(ddata);
         sql_str.add(sql);
         {
            String msg="删除"+ddata.getStationName()+ddata.getNote()+"的告警";
            User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Delete, msg);
            listU.add(ulog);
          }
      }
      //TODO perry待做
      Boolean bl= true;
      //Boolean bl = DateUtil.makeManualCommit(DBUtil.getConn(), sql_str);
      (new User_logService()).addPro(listU);//将用户的操作记录下来
      Boolean bl= mapper.delPro(list)>0;
      userLogService.addPro(listU);//将用户的操作记录下来
      if(bl){
         model.setCode(1);
         model.setMsg("删除成功!");
@@ -135,63 +121,55 @@
   }
   
   //3.3设备告警实时查询
   public ServiceModel serchByInfo(Object obj) {
      List list = mapper.serchByInfo(obj);
      if(list!=null&&list.size()>0){
         model.setCode(1);
         model.setMsg("查询成功!");
         model.setData(list);
      }else{
         model.setCode(0);
         model.setMsg("查询失败!");
      }
		
   public ServiceModel serchByInfo(Batt_devalarm_data bdd) {
      ServiceModel model = new ServiceModel();
      PageHelper.startPage(bdd.getPageBean().getPageNum(),bdd.getPageBean().getPageSize(),true);
      List list = mapper.serchByInfo(bdd);
      PageInfo<Batt_devalarm_data> pageInfo = new PageInfo<>(list);

      model.setCode(1);
      model.setData(pageInfo);
      return model;
   }
   //3.4设备告警历史记录查询
   public ServiceModel serchByCondition(Object obj) {
      List list=mapper.serchByCondition(obj);
      if(list!=null&&list.size()>0){
         model.setCode(1);
         model.setMsg("查询成功!");
         model.setData(list);
      }else{
         model.setCode(0);
         model.setMsg("查询失败!");
      }
   public ServiceModel serchByCondition(Batt_Maint_Dealarm bmd) {
      ServiceModel model = new ServiceModel();
      PageHelper.startPage(bmd.getPageBean().getPageNum(),bmd.getPageBean().getPageSize(),true);
      List list=mapper.serchByCondition(bmd);
      PageInfo<Batt_Maint_Dealarm> pageInfo = new PageInfo<>(list);

      model.setCode(1);
      model.setData(pageInfo);
      
      return model;
   }   
    
   
   //查询设备告警总数
   public ServiceModel searchNums(Object obj) {
      int nums= mapper.searchNums(obj);
      //TODO perry
      // model.setSum(nums);
   public ServiceModel searchNums(User_inf userInf) {
      ServiceModel model = new ServiceModel();
      int nums= mapper.searchNums(userInf);
      model.setCode(1);
      model.setData(nums);
      return model;
   }

   //点击项目下方的滚动，查询该设备告警的实时信息
   public ServiceModel  serchDev_alarm(Object obj){
      List list=mapper.serchDev_alarm(obj);
      if(list!=null && list.size()>0){
         model.setCode(1);
         model.setData(list);
         model.setMsg("查询成功!");
      }else{
         model.setCode(0);
         model.setMsg("查询失败!");
      }		
   public ServiceModel  serchDev_alarm(Batt_devalarm_data ddata){
      ServiceModel model = new ServiceModel();
      List list=mapper.serchDev_alarm(ddata);

      model.setCode(1);
      model.setData(list);
      return model;
   }
   /**
    * 查询设备实时告警记录(跨域新增)
    * @param obj
    * @return
    */
   public ServiceModel  searchDevAlarm(Object obj){
      List list=mapper.searchDevAlarm(obj);
   public ServiceModel  searchDevAlarm(Batt_devalarm_data ddata){
      ServiceModel model = new ServiceModel();
      List list=mapper.searchDevAlarm(ddata);
      if(list!=null && list.size()>0){
         model.setCode(1);
         model.setData(list);
@@ -204,9 +182,10 @@
   }

   //紫晶山西根据设备id和电池组id查询机房告警信息
   public ServiceModel seachStationAlarm(Object obj) {
      int number_d=mapper.seachStationAlarm(obj);
      int number_a=battAlarmDataMapper.seachStationAlarm(obj);
   public ServiceModel seachStationAlarm(BattInf binf) {
      ServiceModel model = new ServiceModel();
      int number_d=mapper.seachStationAlarm(binf);
      int number_a=battAlarmDataMapper.seachStationAlarm(binf);
      
      if(number_d>0||number_a>0){
         model.setCode(1);