1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
package xyz.driver.pdsuidomain.fakes.entities
import xyz.driver.pdsuidomain.entities._
import xyz.driver.core.generators
import xyz.driver.core.generators._
import common._
import xyz.driver.pdsuicommon.concurrent.BridgeUploadQueue
import xyz.driver.pdsuicommon.domain.{TextJson, User}
import xyz.driver.pdsuidomain.fakes.entities.rep.{DocumentGen, MedicalRecordMetaGen, Common}
object RecordsProcessingApi {
private val maxCollectionNumber = 5
private val maxAttemtsNumber = 100
private def nextMedicalRecordMetasJson: TextJson[List[MedicalRecord.Meta]] =
TextJson(nextMedicalRecordMetas(nextInt(maxCollectionNumber, minValue = 0)))
private def nextDocuments: TextJson[List[Document]] =
TextJson(nextDocuments(nextInt(maxCollectionNumber, minValue = 0)))
def nextMedicalRecordStatus: MedicalRecord.Status =
generators.oneOf[MedicalRecord.Status](MedicalRecord.Status.All)
def nextMedicalRecordMeta: MedicalRecord.Meta =
MedicalRecordMetaGen.nextMedicalRecordMeta
def nextMedicalRecordMetas(count: Int): List[MedicalRecord.Meta] =
List.fill(count)(nextMedicalRecordMeta)
def nextMedicalRecordHistoryState: MedicalRecordHistory.State =
generators.oneOf[MedicalRecordHistory.State](MedicalRecordHistory.State.All)
def nextMedicalRecordHistoryAction: MedicalRecordHistory.Action =
generators.oneOf[MedicalRecordHistory.Action](MedicalRecordHistory.Action.All)
def nextDocument: Document =
DocumentGen.nextDocument
def nextDocuments(count: Int): List[Document] =
List.fill(count)(nextDocument)
def nextMedicalRecord() = {
MedicalRecord(
id = nextLongId[MedicalRecord],
status = nextMedicalRecordStatus,
previousStatus = nextOption(nextMedicalRecordStatus),
assignee = nextOption(nextStringId),
previousAssignee = nextOption(nextStringId),
lastActiveUserId = nextOption(nextStringId),
patientId = nextUuidId,
requestId = RecordRequestId(generators.nextUuid()),
disease = generators.nextString(),
caseId = nextOption(CaseId(generators.nextString())),
physician = nextOption(generators.nextString()),
meta = nextOption(nextMedicalRecordMetasJson),
predictedMeta = nextOption(nextMedicalRecordMetasJson),
predictedDocuments = nextOption(nextDocuments),
lastUpdate = nextLocalDateTime
)
}
def nextMedicalRecordHistory() = {
MedicalRecordHistory(
id = nextLongId[MedicalRecordHistory],
executor = nextStringId[User],
recordId = nextLongId[MedicalRecord],
state = nextMedicalRecordHistoryState,
action = nextMedicalRecordHistoryAction,
created = nextLocalDateTime
)
}
def nextMedicalRecordIssue(): MedicalRecordIssue = {
val pages = Common.genStartAndEndPages
MedicalRecordIssue(
id = nextLongId[MedicalRecordIssue],
userId = nextStringId[User],
recordId = nextLongId[MedicalRecord],
startPage = pages._1,
endPage = pages._2,
lastUpdate = nextLocalDateTime,
isDraft = nextBoolean(),
text = nextString(),
archiveRequired = nextBoolean()
)
}
def nextBridgeUploadQueueItem(): BridgeUploadQueue.Item = {
BridgeUploadQueue.Item(
kind = nextString(),
tag = nextString(),
created = nextLocalDateTime,
attempts = nextInt(maxAttemtsNumber, minValue = 0),
nextAttempt = nextLocalDateTime,
completed = nextBoolean(),
dependencyKind = nextOption(nextString()),
dependencyTag = nextOption(nextString())
)
}
def nextProviderType(): ProviderType = {
ProviderType(
id = nextLongId[ProviderType],
name = nextString()
)
}
}
|
