Packages

c

seee.controller

SeeeController

class SeeeController extends Model

Annotations
@Singleton()
Linear Supertypes
Model, Topic, Producer, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SeeeController
  2. Model
  3. Topic
  4. Producer
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new SeeeController()(implicit ws: WSClient, aqua6boSurfaceQualitometerDao: Aqua6boSurfaceQualitometerDao, hydrobioSeeeDao: HydrobioSeeeDao, cityDao: CityDao, JobLogUtil: JobLogUtil, qualitometerDao: QualitometerDao, watershedDao: WatershedDao, watermassDao: WatermassDao, indicesDao: IndicesDao, parameterDao: ParameterDao, db: Database, anormQualityImportDao: AnormQualityImportDao, LogUtil: LogUtil)
    Annotations
    @Inject()

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def GetResultat(urlSeee: String, body: JsValue, code: String, jobExecutionId: Option[Long]): Option[Seq[String]]
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def calculOperation(typ: String, indicateurType: String, support: Int, code: String, importMode: Option[String], codeIndice: String, user: String, codeOpe: Option[Seq[Double]], theJobExecutionId: Option[Long]): Int
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  8. def createFile(directoryName: String, fileName: String): Option[File]
  9. def createOrUpdateQualitometer(qualito: Qualitometer, jobExecutionId: Option[Long], watermassCode: Option[String] = None): Option[Double]
  10. def csvExport(data: Seq[SeeeData]): Array[Byte]
  11. def csvExportI2M2(data: Seq[SeeeData]): Array[Byte]
  12. def csvExportIBMR(data: Seq[SeeeData]): Array[Byte]
  13. def csvExportODInvertebres(data: Seq[SeeeData]): Array[Byte]
  14. val debug: Boolean
  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  17. def execute(routingKey: String, message: JsValue): Unit
    Definition Classes
    SeeeControllerModel
  18. def executeManually(message: JsValue, headers: Map[String, Any], module: String, user: String): String
  19. def executeWrapper(routingKey: String, message: JsValue): Unit
    Definition Classes
    Model
  20. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  21. def getFile(directoryName: String, fileName: String): Option[File]
  22. def getParamCode(libelle: String)(implicit jobExecutionId: Long): String
  23. def getRoutingKey(): String
    Definition Classes
    SeeeControllerModel
  24. def handleError(e: Exception, jobExecutionId: Long): Unit
    Definition Classes
    SeeeControllerModel
  25. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  26. def initTopic(): (String, (String, JsValue) => Unit)
    Definition Classes
    Model → Topic
  27. def inserDiagODInvertebres(oneData: Array[String], theJobExecutionId: Option[Long], idQualito: Double, user: String, code: String): Int
  28. def inserintoBddDiagODInvertebres(oneData: Array[String], theJobExecutionId: Option[Long], idQualito: Double, user: String, code: String, parametre: Int, colonne: Int, codeOpe: Double): Int
  29. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  30. def launchCalcul(message: JsValue): Seq[Int]
  31. def launchCalculManually(message: JsValue): Int
  32. lazy val logUtil: LogUtil
    Definition Classes
    Topic
  33. lazy val logsUtil: LogUtil
    Definition Classes
    Producer
  34. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  35. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  36. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  37. implicit val reads: Reads[(Double, Option[Seq[Double]], Seq[String], String)]
  38. def runCMDInScript(dirPath: String, cmd: Seq[String], jobExecutionId: Option[Long]): String
  39. def sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
    Definition Classes
    Producer
  40. def sendRPC[A](routingKey: String, message: String, connection: Connection, channel: Channel, replyQueueName: String)(implicit rds: Reads[A], m: ClassTag[A]): Future[A]
    Definition Classes
    Producer
  41. def sendRPC[A](routingKey: String, message: String, timeout: Duration)(implicit rds: Reads[A], m: ClassTag[A]): A
    Definition Classes
    Producer
    Annotations
    @throws(classOf[java.util.concurrent.TimeoutException])
  42. def sendTopic(routingKey: String, message: String): Unit
    Definition Classes
    Producer
  43. def sendTopic(exchangeName: String, routingKey: String, queueName: String, message: String): Unit
    Definition Classes
    Producer
  44. def stationIntegration(integration: Boolean = true, code: String)(implicit jobExecutionId: Long): Option[Double]
  45. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  46. def toString(): String
    Definition Classes
    AnyRef → Any
  47. val urlSeee: String
  48. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  49. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  50. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  2. def sendRPC(routingKey: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) => Unit): Unit
    Definition Classes
    Producer
    Annotations
    @deprecated @Deprecated
    Deprecated

    Use sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A]): Future[JsResult[A]]

  3. def sendRPC(exchangeName: String, routingKey: String, queueName: String, message: String, consumerFn: (String, Envelope, BasicProperties, Array[Byte]) => Unit): Unit
    Definition Classes
    Producer
    Annotations
    @deprecated @Deprecated
    Deprecated

    Use sendRPC[A](routingKey: String, message: String)(implicit rds: Reads[A]): Future[JsResult[A]]

Inherited from Model

Inherited from Topic

Inherited from Producer

Inherited from AnyRef

Inherited from Any

Ungrouped