package com.fgkj.test;

import java.math.BigDecimal;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import javax.mail.Folder;

import com.fgkj.dao.BattResAndTest;
import com.fgkj.dao.CallBack;
import com.fgkj.dao.DAOHelper;
import com.fgkj.dao.impl.BatttestdataDAOImpl;
import com.fgkj.dao.impl.Batttestdata_infDAOImpl;
import com.fgkj.dao.impl.BatttestdatastopDAOImpl;
import com.fgkj.db.DBUtil;
import com.fgkj.dto.Batttestdata;
import com.fgkj.dto.Batttestdata_inf;
import com.fgkj.dto.Batttestdatastop;

public class Create_dischargeData {
	public static void main(String[] args) {
		/*List list=get_record_num();
		System.out.println(list);
		for(int i=0;i<list.size();i++){
			int record_num=(Integer) list.get(i);
			List list1=get_record_data(record_num);
			BatttestdataDAOImpl bimpl=new BatttestdataDAOImpl();
			boolean bl=bimpl.add(list1);
			System.out.println(bl);
			BatttestdatastopDAOImpl bsimpl=new BatttestdatastopDAOImpl();
			if(i==(list.size()-1)){
				boolean bln=bsimpl.add(list1);
				System.out.println(bln);
			}
		}
		insert_monvols();*/
		//insert_monvols_stop();
		//random_tmp();
		//changeStop();
		createRtdata();
	}
	public static void createRtdata(){
		for(int i=1;i<109;i++){
			float mon_tmp=(float) (Math.random()+20);
			BigDecimal   bdt  =   new  BigDecimal((double)mon_tmp);  
			bdt   =  bdt.setScale(1,4);  
			mon_tmp  =  bdt.floatValue();
			
			float mon_vol=(float) (Math.random()/100.0+2.23);
			BigDecimal   bdv  =   new  BigDecimal((double)mon_vol);  
			bdv   =  bdv.setScale(3,4);  
			mon_vol  =  bdv.floatValue();
			
			float mon_res=(float) (Math.random()/100.0+0.3);
			BigDecimal   bdr  =   new  BigDecimal((double)mon_res);  
			bdr   =  bdr.setScale(3,4);  
			mon_res  =  bdr.floatValue();
			String sql="update db_ram_db.tb_batt_rtdata set mon_vol=? ,mon_tmp=?,mon_res=? where mon_num=? and battgroupid=1005075";
		    boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{mon_vol,mon_tmp,mon_res,i});
		}
	}
	public static void changeStop(){
		String sql="select record_num,mon_tmp,mon_num,battgroupid from db_batt_testdata.tb_batttestdata_1005075 where record_num=319 ";
	    List<Batttestdata> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batttestdata b=new Batttestdata();
						b.setBattGroupId(rs.getInt("battGroupId"));
						b.setRecord_num(rs.getInt("record_num"));
						b.setMon_tmp(rs.getFloat("mon_tmp"));
						b.setMon_num(rs.getInt("mon_num"));
						list.add(b);
					}
				} catch (SQLException e) {
					e.printStackTrace();
				}
				return list;
			}
		});
	    if(list!=null&&list.size()>0){
	    	for (int i=0;i<list.size();i++) {
	    		 BatttestdatastopDAOImpl bsimpl=new BatttestdatastopDAOImpl();
	    		 boolean  bl=bsimpl.updatenew(list.get(i));
	    		 System.out.println(i+"   "+bl+"  ");
			}
	    }
	}
	
	public static void random_tmp(){
		String sql="select distinct num,battgroupid from db_batt_testdata.tb_batttestdata_1005075 ";
	    List<Batttestdata> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batttestdata b=new Batttestdata();
						b.setNum(rs.getInt("num"));
						b.setBattGroupId(rs.getInt("battGroupId"));
						list.add(b);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
	    if(list!=null&&list.size()>0){
	    	for (int i=0;i<list.size();i++) {
	    		 BatttestdataDAOImpl bimpl=new BatttestdataDAOImpl();
	    		 boolean  bl=bimpl.updatenew(list.get(i));
	    		 System.out.println(i+"   "+bl+"  "+list.get(i).getNum());
			}
	    }
	}
	public static void insert_monvols_stop(){
		String sql="select battgroupid,sum(mon_vol) as mon_vols,record_num from db_batt_testdata.tb_batttestdatastop_1005075 GROUP BY record_num";
	    List<Mon_vols> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
			    List list=new ArrayList();
			    try {
					while(rs.next()){
						Mon_vols ms=new Mon_vols();
						ms.setBattggroupid(rs.getInt("battgroupid"));
						float mon_vols=rs.getFloat("mon_vols");
						BigDecimal   bd  =   new  BigDecimal((double)mon_vols);  
						bd   =  bd.setScale(1,4);  
						mon_vols  =  bd.floatValue(); 
						System.out.println(mon_vols);
						ms.setMon_vols(mon_vols);
						ms.setRecord_num(rs.getInt("record_num"));
						list.add(ms);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
	    if(list!=null&&list.size()>0){
	    	for (Mon_vols ms: list) {
	    		BatttestdatastopDAOImpl bsimpl=new BatttestdatastopDAOImpl();
	    		bsimpl.update(ms);
			}
	       
	    }
	}
	public static void insert_monvols(){
		String sql="select battgroupid,sum(mon_vol) as mon_vols,record_num from db_batt_testdata.tb_batttestdata_1005075 GROUP BY record_num";
	    List<Mon_vols> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			
			public List getResults(ResultSet rs) {
			    List list=new ArrayList();
			    try {
					while(rs.next()){
						Mon_vols ms=new Mon_vols();
						ms.setBattggroupid(rs.getInt("battgroupid"));
						float mon_vols=rs.getFloat("mon_vols");
						BigDecimal   bd  =   new  BigDecimal((double)mon_vols);  
						bd   =  bd.setScale(1,4);  
						mon_vols  =  bd.floatValue(); 
						System.out.println(mon_vols);
						ms.setMon_vols(mon_vols);
						ms.setRecord_num(rs.getInt("record_num"));
						list.add(ms);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
	    if(list!=null&&list.size()>0){
	    	for (Mon_vols ms: list) {
	    		BatttestdataDAOImpl bimpl=new BatttestdataDAOImpl();
	    		bimpl.update(ms);
			}
	       
	    }
	}
	
	public void insert_inf(){
		String sql="SELECT * FROM db_batt_testdata.tb_batttestdata_inf where BattGroupId=1005066  and test_type=3 and test_record_count=1";
		List<Batttestdata_inf> list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batttestdata_inf b=new Batttestdata_inf();
						b.setNum(rs.getInt("num"));
						b.setBattGroupId(rs.getInt("BattGroupId"));
						b.setTest_record_count(rs.getInt("test_record_count"));
						b.setTest_record_count_ex(rs.getInt("test_record_count_ex"));
						b.setTest_type(rs.getInt("test_type"));
						b.setRecord_time_interval(rs.getInt("record_time_interval"));
						b.setData_new(rs.getInt("data_new"));
						b.setData_available(rs.getInt("data_available"));						
						b.setRecord_num(rs.getInt("record_num"));
						b.setTest_starttime(rs.getTimestamp("test_starttime"));
						b.setTest_starttime_ex(rs.getTimestamp("test_starttime_ex"));
						b.setTest_starttype(rs.getInt("test_starttype"));
						b.setRecord_time(rs.getTimestamp("record_time"));
						b.setTest_timelong(rs.getInt("test_timelong"));
						b.setTest_stoptype(rs.getInt("test_stoptype"));
						b.setGroup_vol(rs.getFloat("group_vol"));
						b.setTest_curr(rs.getFloat("test_curr"));
						b.setTest_cap(rs.getFloat("test_cap"));
						b.setMax_monnum(rs.getInt("max_monnum"));
						b.setMax_monvol(rs.getFloat("max_monvol"));
						b.setMin_monnum(rs.getInt("min_monnum"));
						b.setMin_monvol(rs.getFloat("min_monvol"));
						b.setMon_num(rs.getInt("mon_num"));
						b.setMon_vol(rs.getFloat("mon_vol"));
						b.setUpload_usr_id(rs.getInt("upload_usr_id"));
						list.add(b);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
	System.out.println(list.size());
	Batttestdata_inf dinf=list.get(list.size()-1);
	dinf.setBattGroupId(1005075);
	Batttestdata_infDAOImpl dimpl=new Batttestdata_infDAOImpl();
	System.out.println(dinf);
	boolean bl=dimpl.add(dinf);
	System.out.println(bl);
	}
	
	public static List get_record_num(){
		String sql="SELECT distinct record_num FROM db_batt_testdata.tb_batttestdata_1005066 where   test_record_count=1";
		List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						list.add(rs.getInt("record_num"));
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		return list;
	}
   public static List get_record_data(int record_num){
	   String sql1="SELECT * FROM db_batt_testdata.tb_batttestdata_1005066 where   test_record_count=1 and record_num="+record_num;
		List<Batttestdata> list1=DAOHelper.executeQuery(sql1, DBUtil.getConn(), null, new CallBack() {
			public List getResults(ResultSet rs) {
				List list=new ArrayList();
				try {
					while(rs.next()){
						Batttestdata b=new Batttestdata();
						b.setNum(rs.getInt("num"));
						b.setBattGroupId(rs.getInt("BattGroupId"));
						b.setTest_record_count(rs.getInt("test_record_count"));
						b.setTest_type(rs.getInt("test_type"));
						b.setData_new(rs.getInt("data_new"));						
						b.setData_available(rs.getInt("data_available"));
						b.setRecord_num(rs.getInt("record_num"));
						b.setTest_starttime(rs.getTimestamp("test_starttime"));
						b.setRecord_time(rs.getTimestamp("record_time"));
						b.setTest_timelong(rs.getInt("test_timelong"));
						b.setOnline_vol(rs.getFloat("online_vol"));
						b.setGroup_vol(rs.getFloat("group_vol"));
						b.setTest_curr(rs.getFloat("test_curr"));
						b.setTest_cap(rs.getFloat("test_cap"));
						b.setMon_num(rs.getInt("mon_num"));
						b.setMon_vol(rs.getFloat("mon_vol"));
						b.setMon_tmp(rs.getFloat("mon_tmp"));
						list.add(b);
					}
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				return list;
			}
		});
		List list=new ArrayList();
		float mon_vols=0f;
		for(int i=0;i<4;i++){
			for (Batttestdata b : list1) {
				Batttestdata bl=clone(b);
				bl.setBattGroupId(1005075);
				bl.setMon_vol((float)(bl.getMon_vol()+0.01*i));
				bl.setMon_num(bl.getMon_num()+i*24);
				mon_vols+=bl.getMon_vol();
				list.add(bl);
			}
		}
		for (int j = 0; j < 12; j++) {
			Batttestdata bll=clone(list1.get(j));
			bll.setBattGroupId(1005075);
			bll.setMon_vol((float)(bll.getMon_vol()+0.01*5));
			bll.setMon_num(bll.getMon_num()+96);
			mon_vols+=bll.getMon_vol();
			list.add(bll);
		}
		System.out.println(mon_vols);
		return list;
   } 
   
   public static Batttestdata clone(Batttestdata bl){
	    Batttestdata b=new Batttestdata();
		b.setBattGroupId(bl.getBattGroupId());
		b.setTest_record_count(bl.getTest_record_count());
		b.setTest_type(bl.getTest_type());
		b.setData_new(bl.getData_new());						
		b.setData_available(bl.getData_available());
		b.setRecord_num(bl.getRecord_num());
		b.setTest_starttime(bl.getTest_starttime());
		b.setRecord_time(bl.getRecord_time());
		b.setTest_timelong(bl.getTest_timelong());
		b.setOnline_vol(bl.getOnline_vol());
		b.setGroup_vol(bl.getGroup_vol());
		b.setTest_curr(bl.getTest_curr());
		b.setTest_cap(bl.getTest_cap());
		b.setMon_num(bl.getMon_num());
		b.setMon_vol(bl.getMon_vol());
		b.setMon_tmp(bl.getMon_tmp());
		return b;
   }
}