java 数据处理_[java] 数据处理

忘是亡心i 2022-11-01 14:00 243阅读 0赞

importjava.io.BufferedReader;importjava.io.File;importjava.io.FileReader;importjava.text.SimpleDateFormat;importjava.util.Date;importorg.apache.commons.math3.fitting.PolynomialCurveFitter;importorg.apache.commons.math3.fitting.WeightedObservedPoints;public classpredict\_temperature

\{private static String\[\] observed\_data(double flag, BufferedReader reader) throwsException

String line= null;

String\[\] i\_want= new String\[4\];if(flag > 0)

\{double tmp = 1000;

System.out.println(flag);while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value <=tmp)

tmp=value;else\{

i\_want\[0\] = item\[0\];

i\_want\[1\] = item\[4\].replace("\\"", "");break;

\}while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value >=tmp)

tmp=value;else

break;

\}while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value <=tmp)

tmp=value;else\{

i\_want\[2\] = item\[0\];

i\_want\[3\] = item\[4\].replace("\\"", "");break;

\}else\{double tmp = -1000;while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value >=tmp)

tmp=value;else\{

i\_want\[0\] = item\[0\];

i\_want\[1\] = item\[4\].replace("\\"", "");break;

\}while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value <=tmp)

tmp=value;else

break;

\}while((line=reader.readLine())!=null)

String item\[\]= line.split(",");double value = Double.parseDouble(item\[2\]);if(value >=tmp)

tmp=value;else\{

i\_want\[2\] = item\[0\];

i\_want\[3\] = item\[4\].replace("\\"", "");break;

\}returni\_want;

\}public static void main(String\[\] args) throwsException

WeightedObservedPoints points= newWeightedObservedPoints();

String input\_time= args\[1\] + " " + args\[2\];

File file= new File(args\[0\]);double time\_diff = 0;

BufferedReader reader= new BufferedReader(newFileReader(file));

reader.readLine();

reader.mark((int)file.length());/\*计算周期\*/

double compare\_item1 = Double.parseDouble(reader.readLine().split(",")\[2\]);double compare\_item2 = Double.parseDouble(reader.readLine().split(",")\[2\]);

String\[\] cycle\_result= new String\[4\];

cycle\_result= observed\_data(compare\_item1 -compare\_item2, reader);int start\_num = Integer.parseInt(cycle\_result\[0\]);int end\_num = Integer.parseInt(cycle\_result\[2\]);

SimpleDateFormat tmp\_day= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

Date start\_now= tmp\_day.parse(cycle\_result\[1\]);

Date end\_now= tmp\_day.parse(cycle\_result\[3\]);/\*计算周期\*/

int cycle = end\_num -start\_num;

reader.reset();

SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

SimpleDateFormat input\_time\_format= new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");

Date input\_time\_=input\_time\_format.parse(input\_time);

Date start\_time= null;int i = 0;

String line= null;

String time= null;while((line=reader.readLine())!=null)

String item\[\]= line.split(",");

time= item\[4\];double value = Double.parseDouble(item\[2\]);

time= time.replace("\\"", "");

Date now=sdf.parse(time);if(i == 0)

start\_time=now;double offset = (now.getTime() -start\_time.getTime());

points.add(offset, value);

time\_diff= (input\_time\_.getTime() - start\_time.getTime()) % (end\_now.getTime() -start\_now.getTime());if(i++ >cycle)break;

PolynomialCurveFitter fitter= PolynomialCurveFitter.create(2);double\[\] result =fitter.fit(points.toList());double result\_time = result\[2\] \* time\_diff \* time\_diff + result\[1\]\* time\_diff + result\[0\];

System.out.println(result\_time);

reader.close();