TEAMModelOS/TEAMModelOS/Controllers/Task/SurveyController.cs

using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TEAMModelOS.Models;
using TEAMModelOS.SDK.Context.Exception;
using TEAMModelOS.SDK.Extension.DataResult.JsonRpcRequest;
using TEAMModelOS.SDK.Extension.DataResult.JsonRpcResponse;
using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
using TEAMModelOS.SDK.Module.AzureCosmosDBV3;
using TEAMModelOS.Service.Models;
using TEAMModelOS.Service.Services.Learn.Interfaces;

namespace TEAMModelOS.Controllers
{
    /// <summary>
    /// 投票活动
    /// </summary>
    [Route("api/[controller]")]
    [ApiController]
    public class SurveyController : BaseController
    {
        private readonly IAzureCosmosDBV3Repository azureCosmosDBV3Repository;
 
        private readonly IServiceBusService _serviceBus;
        public SurveyController(IAzureCosmosDBV3Repository _azureCosmosDBV3Repository,  IServiceBusService serviceBus)
        {
            //  _timerWorkService = timerWorkService;
            _serviceBus = serviceBus;
              azureCosmosDBV3Repository = _azureCosmosDBV3Repository;
        }

        /// <summary>
        /// 新增 或 修改投票活动
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("upsert")]
        public async Task<BaseJosnRPCResponse> Upsert(JosnRPCRequest<SurveyDto> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            //新增
            if (string.IsNullOrEmpty(request.@params.survey.id))
            {
                request.@params.survey.id = Guid.NewGuid().ToString();
                request.@params.survey.status = 100;
            }
            if (request.@params.survey.publishModel.Equals("0"))
            {
                request.@params.survey.startTime = new DateTimeOffset(DateTime.UtcNow).ToUnixTimeMilliseconds();
                request.@params.survey.status = 200;
            }
            else if (request.@params.survey.publishModel.Equals("1"))
            {

                string msgId = Guid.NewGuid().ToString();
                long SequenceNumber = await _serviceBus.SendMessage<Survey>(Constants.TopicName, request.@params.survey.id, request.@params.survey.code, request.@params.survey.startTime, 200, msgId);
                request.@params.survey.sequenceNumber = SequenceNumber;

            }



            Survey homeWork = await azureCosmosDBV3Repository.SaveOrUpdate<Survey>(request.@params.survey);

            //设定结束时间
            string msgEndId = Guid.NewGuid().ToString();
            await _serviceBus.SendMessage<Survey>(Constants.TopicName, request.@params.survey.id, request.@params.survey.code, request.@params.survey.endTime, 300, msgEndId);

            //清除作业
            if (!request.@params.reset)
            {
                //查询之前是否有 关联关系表 HomeWorkStudent 有则删除
                List<SurveyRecord> surveyRecords = await azureCosmosDBV3Repository.FindByDict<SurveyRecord>(new Dictionary<string, object> { { "id", request.@params.survey.id } });
                if (surveyRecords.IsNotEmpty())
                {
                    await azureCosmosDBV3Repository.DeleteAll(surveyRecords);
                }

                ////根据作业发布对象查找到每一个具体学生生成关联关系表 HomeWorkStudent
                //List<Target> targets = request.@params.survey.target;
                //List<SurveyRecord> surveykStudents = new List<SurveyRecord>();
                //foreach (Target target in targets)
                //{
                   
                //    List<ClassStudent> classroom = await azureCosmosDBV3Repository.FindByDict<ClassStudent>(new Dictionary<string, object> { { "id", target.classroomCode } });
                //    if (classroom.IsNotEmpty() && classroom[0].code != null)
                //    {
                //        foreach (ClassStudent student in classroom)
                //        {
                //            SurveyRecord surveyStudent = new SurveyRecord();
                //            surveyStudent.id = request.@params.survey.id;
                //            surveyStudent.code = student.code;
                //            surveyStudent.classroom.code = target.classroomCode;
                //            surveyStudent.classroom.name = target.classroomName;
                //            surveykStudents.Add(surveyStudent);
                //        }
                //    }
                //}
                //if (surveykStudents.IsNotEmpty())
                //{
                //    foreach (SurveyRecord surveyRecord in surveykStudents)
                //    {
                //        List<Student> student = await azureCosmosDBV3Repository.FindById<Student>(surveyRecord.code);
                //        if (student.IsNotEmpty())
                //        {
                //            surveyRecord.name = student[0].name;
                //            surveyRecord.code = student[0].TEAMModelId;
                //        }
                //    }
                //    await azureCosmosDBV3Repository.SaveOrUpdateAll(surveykStudents);
                //}
            }
            return builder.Data(homeWork).build();
        }
        /// <summary>
        /// 查询投票活动
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("findSummary")]
        public async Task<BaseJosnRPCResponse> FindSummary(JosnRPCRequest<Dictionary<string, object>> request)
        {

            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<Survey> data = new List<Survey>();
            List<string> props = new List<string> { "id", "code", "name", "type", "status", "startTime" };
            if (request.@params.Keys.Count > 0)
            { 
                
                data = await azureCosmosDBV3Repository.FindByDict<Survey>(request.@params, props);
            }
            else
            {
                throw new BizException("参数异常", ResponseCode.PARAMS_ERROR);

            }
            return builder.Data(data).Extend(new Dictionary<string, object> { { "count", data.Count },{ "props", props } }).build();
        }
        /// <summary>
        /// 查询投票活动
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("find")]
        public async Task<BaseJosnRPCResponse> Find(JosnRPCRequest<Dictionary<string, object>> request)
        {

            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<Survey> data = new List<Survey>();
            if (request.@params.Keys.Count > 0)
            {
                data = await azureCosmosDBV3Repository.FindByDict<Survey>(request.@params);
            }
            else
            {
                throw new BizException("参数异常", ResponseCode.PARAMS_ERROR);

            }
            return builder.Data(data).Extend(new Dictionary<string, object> { { "count", data.Count } }).build();
        }

        /// <summary>
        /// 删除投票活动
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("delete")]
        public async Task<BaseJosnRPCResponse> Delete(JosnRPCRequest<List<IdPk>> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<IdPk> idPks = await azureCosmosDBV3Repository.DeleteAll<Survey>(request.@params);
            if (idPks.IsNotEmpty())
            {
                foreach (IdPk idPk in idPks)
                {
                    List<SurveyRecord> surveys = await azureCosmosDBV3Repository.FindByDict<SurveyRecord>(new Dictionary<string, object> { { "id", idPk.id } });
                    await azureCosmosDBV3Repository.DeleteAll(surveys);
                }
                builder.Data(idPks);
            }
            else
            {
                throw new BizException("删除失败", ResponseCode.FAILED);
            }
            return builder.build();
        }

        /// <summary>
        /// 撤消投票
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("cancel")]
        public async Task<BaseJosnRPCResponse> Cancel(JosnRPCRequest<string> surveyId)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<Survey> surveys = await azureCosmosDBV3Repository.FindByDict<Survey>(new Dictionary<string, object> { { "id", surveyId.@params } });

            foreach (Survey survey in surveys)
            {
                survey.status = 100;
            }
            List<Survey> survey1 = await azureCosmosDBV3Repository.UpdateAll<Survey>(surveys);

            //查询之前是否有 关联关系表  有则删除
            List<SurveyRecord> surveyStudents = await azureCosmosDBV3Repository.FindByDict<SurveyRecord>(new Dictionary<string, object> { { "id", surveyId.@params } });
            if (surveyStudents.IsNotEmpty())
            {
                await azureCosmosDBV3Repository.DeleteAll(surveyStudents);
            }
            return builder.Data(survey1).build();
        }

        /// <summary>
        /// 查询学生问卷调查记录
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("findRecord")]
        public async Task<BaseJosnRPCResponse> FindRecord(JosnRPCRequest<Dictionary<string, object>> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            List<SurveyRecord> data = new List<SurveyRecord>();

            if (request.@params.Keys.Count > 0)
            {
                data = await azureCosmosDBV3Repository.FindByDict<SurveyRecord>(request.@params);
            }
            else
            {
                throw new BizException("参数异常", ResponseCode.PARAMS_ERROR);
            }
            return builder.Data(data).Extend(new Dictionary<string, object> { { "count", data.Count } }).build();
        }
        /// <summary>
        /// 学生问卷作答
        /// </summary>
        /// <param name="request"></param>
        /// <returns></returns>
        [HttpPost("upsertRecord")]
        public async Task<BaseJosnRPCResponse> UpsertRecord(JosnRPCRequest<List<SurveyRecord>> request)
        {
            JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
            await azureCosmosDBV3Repository.SaveOrUpdateAll<SurveyRecord>(request.@params);
            return builder.Data(request.@params).build();
        }
        ///// <summary>
        ///// 学生提交问卷调查
        ///// </summary>
        ///// <param name="request"></param>
        ///// <returns></returns>
        //[HttpPost("action")]
        //public async Task<BaseJosnRPCResponse> Action(JosnRPCRequest<SurveyDto> request)
        //{
        //    JsonRPCResponseBuilder builder = JsonRPCResponseBuilder.custom();
        //    List<SurveyRecord> survey = await azureCosmosDBV3Repository.FindByDict<SurveyRecord>(new Dictionary<string, object> { { "id", request.@params.studentID }, { "id", request.@params.surveyWorkId } });
        //    SurveyRecord response = new SurveyRecord();
        //    if (survey.IsNotEmpty())
        //    {
        //        List<Survey> surveys = await azureCosmosDBV3Repository.FindByDict<Survey>(new Dictionary<string, object> { { "id", request.@params.surveyWorkId } });
        //        List<Survey.Option> options2 = surveys[0].option;
        //        bool flg = false;
        //        options2.ForEach(x => { if (x.code == request.@params.option) flg = true; });

        //        if (flg)
        //        {
        //            survey[0].option = request.@params.option;
        //            survey[0].submitTime = new DateTimeOffset(DateTime.UtcNow).ToUnixTimeMilliseconds();
        //            survey[0].submit = true;
        //            response = await azureCosmosDBV3Repository.SaveOrUpdate(survey[0]);

        //        }
        //        else throw new BizException($"该投票活动没有当前选项 { request.@params.option }", ResponseCode.FAILED);
        //    }
        //    return builder.Data(response).build();
        //}
    }
}