class
TapWaterController extends Model
Instance Constructors
-
new
TapWaterController()(implicit jobLogUtil: JobLogUtil, logUtil: LogUtil, qualitometerDao: QualitometerDao, aqua6boTapWaterDao: Aqua6boTapWaterDao, operationDao: OperationDao, sampleDao: SampleDao, analysisDao: AnalysisDao, contributorDao: ContributorsDao, supportDao: SupportDao, aqua6boCityDao: Aqua6boCityDao, cityDao: CityDao, fractionDao: FractionDao, parameterDao: ParameterDao, installationDao: InstallationDao, qualitometerPointDao: QualitometerPointDao, distributionUnitDao: DistributionUnitDao, productionUnitDao: ProductionUnitDao, unitDao: UnitDao, stationLinkDao: StationLinkDao, db: Database)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
def
create(qualito: Qualitometer, jobExecutionId: Option[Long]): Option[Double]
-
def
createOrUpdateQualitometer(qualito: Qualitometer, jobExecutionId: Option[Long]): Option[Double]
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
execute(routingKey: String, message: JsValue): Unit
-
def
executeWrapper(routingKey: String, message: JsValue): Unit
-
def
filterByDate(samplings: Seq[TapWaterSampling], beginDate: Option[DateTime], endDate: Option[DateTime]): Seq[TapWaterSampling]
-
def
finalize(): Unit
-
def
findContributor(code: Option[String], contributors: Seq[Contributor]): Option[Contributor]
-
final
def
getClass(): Class[_]
-
def
getContributorId(contributorOption: Option[Contributor]): Option[Double]
-
def
getLabo(analysis: TapWaterAnalysis): Option[String]
-
def
getListOfDate(beginDate: DateTime, endDate: DateTime, period: Period): Seq[(Option[DateTime], Option[DateTime])]
-
def
getListOfDateRec(acc: Seq[(Option[DateTime], Option[DateTime])], beginDate: DateTime, endDate: DateTime, period: Period): Seq[(Option[DateTime], Option[DateTime])]
-
def
getRoutingKey(): String
-
def
handleError(e: Exception, jobExecutionId: Long): Unit
-
def
hashCode(): Int
-
def
initTopic(): (String, (String, JsValue) ⇒ Unit)
-
def
insertSurfaceQualitometer(samplings: Seq[TapWaterSampling], qualitoCode: String, qualitometerId: Double, user: Option[String] = None, defaultProducer: Option[Double], defaultLabo: Option[Double], defaultFraction: Option[Double])(implicit jobExecutionId: Long): Unit
-
def
integration(message: JsValue): Unit
-
final
def
isInstanceOf[T0]: Boolean
-
lazy val
logUtil: LogUtil
-
lazy val
logsUtil: LogUtil
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
samplingsIntegration(purge: Boolean, di: Boolean, dfi: Boolean, id: Double, qualitoCode: String, parameters: JobParameters, samplings: Seq[TapWaterSampling], defaultProducer: Option[Double], defaultLabo: Option[Double], defaultFraction: Option[Double])(implicit jobExecutionId: Long): Unit
-
def
sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
-
def
sendRPC[A](routingKey: String, message: String, connection: Connection, channel: Channel, replyQueueName: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
-
def
sendRPC[A](routingKey: String, message: String, timeout: Duration)(implicit rds: Reads[A], m: ClassTag[A]): A
-
def
sendTopic(routingKey: String, message: String): Unit
-
def
sendTopic(exchangeName: String, routingKey: String, queueName: String, message: String): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Deprecated Value Members
-
def
sendRPC(routingKey: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) ⇒ Unit): Unit
-
def
sendRPC(exchangeName: String, routingKey: String, queueName: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) ⇒ Unit): Unit
Inherited from Topic
Inherited from Producer
Inherited from AnyRef
Inherited from Any
