|
@@ -46,17 +46,16 @@ namespace TEAMModelOS.Controllers
|
|
|
/// <returns></returns>
|
|
|
[ProducesDefaultResponseType]
|
|
|
[HttpPost("upsert")]
|
|
|
- public async Task<IActionResult> Upsert(SurveyDto request)
|
|
|
+ public async Task<IActionResult> Upsert(Survey request)
|
|
|
{
|
|
|
//ResponseBuilder builder = ResponseBuilder.custom();
|
|
|
//新增
|
|
|
//string code = request.survey.code;
|
|
|
var client = _azureCosmos.GetCosmosClient();
|
|
|
Survey survey;
|
|
|
- request.survey.pk = typeof(Survey).Name;
|
|
|
- request.survey.school = request.survey.code;
|
|
|
- request.survey.code = typeof(Survey).Name + "-" + request.survey.code;
|
|
|
- request.survey.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
|
|
|
+ request.school = request.code;
|
|
|
+ request.code = "Survey-" + request.code;
|
|
|
+ request.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
|
|
|
/*if (request.survey.publishModel.Equals("0"))
|
|
|
{
|
|
|
//request.survey.startTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
|
|
@@ -70,15 +69,15 @@ namespace TEAMModelOS.Controllers
|
|
|
request.survey.sequenceNumber = SequenceNumber;
|
|
|
|
|
|
}*/
|
|
|
- if (string.IsNullOrEmpty(request.survey.id))
|
|
|
+ if (string.IsNullOrEmpty(request.id))
|
|
|
{
|
|
|
- request.survey.id = Guid.NewGuid().ToString();
|
|
|
+ request.id = Guid.NewGuid().ToString();
|
|
|
//request.survey.status = 100;
|
|
|
- request.survey.progress = "pending";
|
|
|
+ request.progress = "pending";
|
|
|
//await _serviceBus.GetServiceBusClient().cancelMessage(Constants.TopicName, info.sequenceNumber);
|
|
|
/* long SequenceNumber = await _serviceBus.GetServiceBusClient().SendLeamMessage<Survey>(Constants.TopicName, request.survey.id, request.survey.code, request.survey.startTime);
|
|
|
request.survey.sequenceNumber = SequenceNumber;*/
|
|
|
- survey = await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(request.survey, new PartitionKey($"{request.survey.code}"));
|
|
|
+ survey = await client.GetContainer("TEAMModelOS", "Common").CreateItemAsync(request, new PartitionKey($"{request.code}"));
|
|
|
/*if (request.survey.scope.Equals("school"))
|
|
|
{
|
|
|
survey = await client.GetContainer("TEAMModelOS", "School").CreateItemAsync(request.survey, new PartitionKey($"Survey-{code}"));
|
|
@@ -87,17 +86,17 @@ namespace TEAMModelOS.Controllers
|
|
|
{
|
|
|
survey = await client.GetContainer("TEAMModelOS", "Teacher").CreateItemAsync(request.survey, new PartitionKey($"Survey-{code}"));
|
|
|
}*/
|
|
|
- await _serviceBus.GetServiceBusClient().SendLeamMessage<Survey>(Constants.TopicName, request.survey.id, request.survey.code, request.survey.startTime);
|
|
|
+ await _serviceBus.GetServiceBusClient().SendLeamMessage<Survey>(Constants.TopicName, request.id, request.code, request.startTime);
|
|
|
|
|
|
}
|
|
|
else {
|
|
|
- Survey info = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Survey>(request.survey.id, new PartitionKey($"{request.survey.code}"));
|
|
|
+ Survey info = await client.GetContainer("TEAMModelOS", "Common").ReadItemAsync<Survey>(request.id, new PartitionKey($"{request.code}"));
|
|
|
if (info.progress.Equals("going"))
|
|
|
{
|
|
|
return Ok(new { v = "活动正在进行中" });
|
|
|
}
|
|
|
//request.survey.code = info.code;
|
|
|
- request.survey.progress = info.progress;
|
|
|
+ request.progress = info.progress;
|
|
|
/*try {
|
|
|
await _serviceBus.GetServiceBusClient().cancelMessage(Constants.TopicName, info.sequenceNumber);
|
|
|
long SequenceNumber = await _serviceBus.GetServiceBusClient().SendLeamMessage<Survey>(Constants.TopicName, request.survey.id, request.survey.code, request.survey.startTime);
|
|
@@ -107,7 +106,7 @@ namespace TEAMModelOS.Controllers
|
|
|
//await _dingDing.SendBotMsg($"ServiceBusㄛExamBus()\n{e.Message}", GroupNames.醍摩豆服務運維群組);
|
|
|
} */
|
|
|
|
|
|
- survey = await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(request.survey, info.id, new PartitionKey($"{info.code}"));
|
|
|
+ survey = await client.GetContainer("TEAMModelOS", "Common").ReplaceItemAsync(request, info.id, new PartitionKey($"{info.code}"));
|
|
|
//request.survey.createTime = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
|
|
|
/*if (request.survey.scope.Equals("school"))
|
|
|
{
|