Edit C:\Users\Administrator\Desktop\galaxie\WEB-INF\classes\com\edeal\frontline\kpi\DataSetRecorder.class
Êþº¾ 3? 'com/edeal/frontline/kpi/DataSetRecorder java/lang/Object logger Lorg/apache/commons/logging/Log; ctx Lcom/edeal/frontline/FlContext; cal Ljava/util/GregorianCalendar; systemIdSql Ljava/lang/String; .$SWITCH_TABLE$com$edeal$frontline$kpi$AxisType [I <clinit> ()V Code %org/apache/commons/logging/LogFactory getLog 3(Ljava/lang/Class;)Lorg/apache/commons/logging/Log; LineNumberTable LocalVariableTable <init> ?(Lcom/edeal/frontline/FlContext;Ljava/util/GregorianCalendar;)V Exceptions &com/edeal/frontline/FrontlineException " $ & ( System * , + com/edeal/frontline/Utils - . validateActor W(Lcom/edeal/frontline/FlContext;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; * 0 1 2 formatToSQL E(Lcom/edeal/frontline/FlContext;Ljava/lang/String;)Ljava/lang/String; 4 this )Lcom/edeal/frontline/kpi/DataSetRecorder; context record W(Lcom/edeal/frontline/kpi/IDataSet;Lcom/edeal/frontline/SnapshotBean;Ljava/util/Date;)V ; =CalcMethod return a null IDataSet. No recording will be done. = ? > org/apache/commons/logging/Log @ A warn (Ljava/lang/Object;)V C java/lang/StringBuilder B " F (1>0 B H I J append -(Ljava/lang/String;)Ljava/lang/StringBuilder; L N M com/edeal/frontline/kpi/IDataSet O P getAxis1 %()Lcom/edeal/frontline/kpi/ICalcAxis; R AND T U V getReadColumns 8(ILcom/edeal/frontline/kpi/ICalcAxis;)Ljava/lang/String; X IS NOT NULL L Z [ P getAxis2 L ] ^ P getAxis3 ` ) B b c d toString ()Ljava/lang/String; f g h createInsertQuery °(Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/SnapshotBean;Ljava/util/Date;Z)Ljava/lang/String; j query: B l m (Ljava/lang/String;)V = o p A info L r s t getConnection 6(Lcom/edeal/frontline/FlContext;)Ljava/sql/Connection; v w x insertDataSet µ(Ljava/sql/Connection;Lcom/edeal/frontline/kpi/IDataSet;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Ljava/lang/String;)V L z { | getAggregate %()Lcom/edeal/frontline/kpi/Aggregate; ~ ? aggregate é(Ljava/sql/Connection;Lcom/edeal/frontline/SnapshotBean;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Ljava/util/Date;Lcom/edeal/frontline/kpi/Aggregate;Ljava/lang/String;Z)V ? ? è(Ljava/sql/Connection;Lcom/edeal/frontline/SnapshotBean;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Ljava/util/Date;Lcom/edeal/frontline/kpi/Aggregate;Ljava/lang/String;)V ? ? ? com/edeal/frontline/SnapshotBean ? d getSnaID ? ? ? updateFobStringValues ^(Ljava/sql/Connection;Ljava/util/Date;ILcom/edeal/frontline/kpi/ICalcAxis;Ljava/lang/String;)V ? ? ? java/lang/Throwable ? d getMessage = ? ? ? error *(Ljava/lang/Object;Ljava/lang/Throwable;)V ? Error recording dataset ? ? *(Ljava/lang/String;Ljava/lang/Throwable;)V L ? ? close ? ? d getSnaShsID ¢ ¤ £ com/edeal/frontline/FlContext ¥ ¦ getDataDictionary &()Lcom/edeal/frontline/DataDictionary; ¨ Shs ª Nu1 ¬ ® "com/edeal/frontline/DataDictionary ¯ ° getRefDisp J(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Object; ² java/lang/Double ± ´ µ ¶ intValue ()I ¸ Should only keep B º I » (I)Ljava/lang/StringBuilder; ½ executions in stat records. ¿ À Á keepOnly &(ILcom/edeal/frontline/SnapshotBean;)V ? Ã Ä Å getSnaLastRun ()Ljava/util/Date; ? Ç È É setSnaPrevRun (Ljava/util/Date;)V ? Ë Ì É setSnaLastRun ? Î Ï Ð save '()Lcom/edeal/frontline/OperationResult; Ò 0com/edeal/frontline/FieldNotInitializedException Ô )com/edeal/frontline/AccessDeniedException dataset "Lcom/edeal/frontline/kpi/IDataSet; sb "Lcom/edeal/frontline/SnapshotBean; runDate Ljava/util/Date; axisCount I isAggr Ljava/lang/StringBuilder; axis1 #Lcom/edeal/frontline/kpi/ICalcAxis; axis2 axis3 onlyNonAggregates insertQuery con Ljava/sql/Connection; e Ljava/lang/Throwable; refId history Ljava/lang/Double; keep StackMapTable ï !com/edeal/frontline/kpi/ICalcAxis ñ java/lang/String ó java/sql/Connection õ java/util/Date ÷ @SELECT DISTINCT SreSnapshotTime FROM StatRecords WHERE SreSnaID= ù ORDER BY 1 DESC û NOT IN ( ¢ ý s þ ()Ljava/sql/Connection; ò createStatement ()Ljava/sql/Statement; java/sql/Statement executeQuery ((Ljava/lang/String;)Ljava/sql/ResultSet; java/sql/ResultSet getTimestamp (I)Ljava/sql/Timestamp; , * 1 C(Lcom/edeal/frontline/FlContext;Ljava/util/Date;)Ljava/lang/String; next ()Z .DELETE FROM StatRecords WHERE SreSnapshotTime AND SreSnaID= executeUpdate (Ljava/lang/String;)I! Deleted # rows to ensure history size == % . Query was ' ?( java/lang/Exception **+, cleanUp @(Ljava/sql/Connection;Ljava/sql/Statement;Ljava/sql/ResultSet;)V st Ljava/sql/Statement; rs Ljava/sql/ResultSet; q kl i d Ljava/sql/Timestamp; deletes Ljava/lang/Exception;9 java/sql/Timestamp î;<= getType $()Lcom/edeal/frontline/kpi/AxisType; ?A@ com/edeal/frontline/kpi/AxisTypeBC FOB "Lcom/edeal/frontline/kpi/AxisType;E -com/edeal/frontline/kpi/FobToStringCalculator DG H Y(Lcom/edeal/frontline/FlContext;Ljava/sql/Connection;Ljava/util/Date;Ljava/lang/String;)V DJ cK '(ILcom/edeal/frontline/kpi/ICalcAxis;)V axisNum axis snaID toStringC /Lcom/edeal/frontline/kpi/FobToStringCalculator; tS java/sql/SQLException òUVW prepareStatement 0(Ljava/lang/String;)Ljava/sql/PreparedStatement; ¢YZ[ getIdFactory !()Lcom/edeal/frontline/IdFactory; ]_^ com/edeal/frontline/IdFactory` d getIDbdc java/sql/PreparedStatementef setString (ILjava/lang/String;)V Lhij getValue %()Lcom/edeal/frontline/kpi/SnapValue; lnm !com/edeal/frontline/kpi/SnapValueio ()Ljava/math/BigDecimal;bqrs setBigDecimal (ILjava/math/BigDecimal;)V lu Ov ()Ljava/lang/Object; xyz values G(Lcom/edeal/frontline/kpi/ICalcAxis;Ljava/lang/Object;)Ljava/util/List;|~} java/util/List? iterator ()Ljava/util/Iterator;??? java/util/Iteratorvb??? setObject (ILjava/lang/Object;)V??? hasNext l? [v l? ^vb?? addBatchb??? executeBatch ()[I L? Did ? insertions. R ? R?? getNextException ()Ljava/sql/SQLException; ps Ljava/sql/PreparedStatement; idFactory Lcom/edeal/frontline/IdFactory; totalInserted pendingBatch Z v #Lcom/edeal/frontline/kpi/SnapValue; objects Ljava/util/List; o Ljava/lang/Object; Ljava/sql/SQLException; e2 LocalVariableTypeTable $Ljava/util/List<Ljava/lang/Object;>; agg #Lcom/edeal/frontline/kpi/Aggregate; =µ¶ isDebugEnabled¸ aggregate a Bº I» -(Ljava/lang/Object;)Ljava/lang/StringBuilder;½ a =¿À A debug B à (I)VÅ SELECT Ç SreValue ÉËÊ !com/edeal/frontline/kpi/AggregateÌ 2 getSqlMethodÎ ! FROM StatRecords WHERE SreSnaID=Ð AND SreSnapshotTime=Ò AND SreIsCmeRow= ÔÖÕ java/lang/Boolean×Ø valueOf (Z)Ljava/lang/Boolean; *Ú 1Û F(Lcom/edeal/frontline/FlContext;Ljava/lang/Boolean;)Ljava/lang/String; ðÝÞ ¶ lengthà GROUP BY ðâãä substring (I)Ljava/lang/String; =æç isInfoEnabledé aggregate query: ë !com/edeal/frontline/kpi/DBDataSet êí î ¸(Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/ICalcAxis;Lcom/edeal/frontline/kpi/Aggregate;Ljava/sql/ResultSet;Ljava/sql/Connection;)Vð insert query: ò 'DELETE FROM StatRecords WHERE SreSnaID=ô +calcmethod rows deletions after aggregate: aggCmeRows groupCols group query dbDs #Lcom/edeal/frontline/kpi/DBDataSet; insertý java/util/ArrayList ü getStorageColumns 6(ILcom/edeal/frontline/kpi/ICalcAxis;)Ljava/util/List;| addAll (Ljava/util/Collection;)Z INSERT INTO StatRecords ( SreID, SreSnaID, SreValue, SreCreID, SreModID, SreCrDt, SreUpd, SreSnapshotTime, SreSnapshotWeek, SreSnapshotWYear , SreIsCmeRow) VALUES ( ?, ?_# , ?, %'& java/util/GregorianCalendar( É setTime %*+, get (I)I ./0 yearOfWeek 1(Ljava/util/GregorianCalendar;)Ljava/lang/Object;2 , ?|45 ¶ size isCmeRow toInsert field dateString $Ljava/util/List<Ljava/lang/String;>; Signature [(Lcom/edeal/frontline/kpi/ICalcAxis;Ljava/lang/Object;)Ljava/util/List<Ljava/lang/Object;>; î>?@ getNullValuePlaceholder 3(Lcom/edeal/frontline/FlContext;)Ljava/lang/Object;B &replacing null value with placeholder D (type: F userC: îHI d getUserCode ?KLC TIME îNOP getTimeGranularity +()Lcom/edeal/frontline/kpi/TimeGranularity; RTS 'com/edeal/frontline/kpi/TimeGranularityUV applyTo >(Ljava/util/GregorianCalendar;Ljava/util/Date;)Ljava/sql/Date; XZY java/lang/Integer×[ (I)Ljava/lang/Integer; ]_^ java/util/Arrays`a asList %([Ljava/lang/Object;)Ljava/util/List; value asDate tmpCal ret g ? ?ij ¶ ordinall SreAxisn Integerp Fobr Reft Stringv Date axisNumber J(ILcom/edeal/frontline/kpi/ICalcAxis;)Ljava/util/List<Ljava/lang/String;>; z|{ java/util/Collections}~ emptyList ()Ljava/util/List;? Week? WYear ? ??y? %()[Lcom/edeal/frontline/kpi/AxisType; ???C DELAY ???C IGNORED ???C INT ???C REF ???C STRING? java/lang/NoSuchFieldError SourceFile DataSetRecorder.java ! ) ¸ ³ ± o !*· !*+µ #*,µ %**´ #+'¸ )¸ /µ 3± # &