number_zj/20220330_Vote/Vote.Services/ApiController/ProjectsService.cs

using Ewide.Core.Util;
using Furion.DatabaseAccessor;
using Furion.DynamicApiController;
using Furion.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Vote.Services.Dto;

namespace Vote.Services.ApiController
{
    /// <summary>
    /// 项目
    /// </summary>
    [ApiDescriptionSettings("Vote", Order = 0)]
    [Route("/gb/yjb/api/projects")]
    public class ProjectsService : IDynamicApiController
    {
        private readonly IRepository<Entities.Projects> rep_Projects;
        private readonly IRepository<Entities.Experts> rep_Experts;
        private readonly IRepository<Entities.VoteRecords> rep_VoteRecords;
        public ProjectsService(IRepository<Entities.Projects> _rep_Projects, IRepository<Entities.Experts> _rep_Experts, IRepository<Entities.VoteRecords> _rep_VoteRecords)
        {
            rep_Projects = _rep_Projects;
            rep_Experts = _rep_Experts;
            rep_VoteRecords = _rep_VoteRecords;
        }
        /// <summary>
        /// 列表
        /// </summary> 
        /// <returns></returns> 
        [HttpPost]
        [Microsoft.AspNetCore.Authorization.AllowAnonymous]
        public async Task<dynamic> List(ProjectsInput args)
        {
            var data = await rep_Projects.DetachedEntities.Where(p => !p.IsDeleted)
                .Where(args.type != null, a => (int)a.type == args.type)
                .ProjectToType<ProjectsOutput>()
                .OrderBy(a => a.serial_number)
                .ToListAsync();
            return data;
        }

        /// <summary>
        /// 检验提交码
        /// </summary> 
        /// <returns></returns> 
        [HttpPost]
        [Microsoft.AspNetCore.Authorization.AllowAnonymous]
        public async Task<dynamic> CheckSubmitCode(CheckSubmitCodeInput args)
        {
            var data = await rep_Experts.DetachedEntities.Where(p => !p.IsDeleted)
                .Where(a => a.login_code == args.code)
                .FirstOrDefaultAsync();
            return data != null;
        }


        /// <summary>
        /// 提交
        /// </summary> 
        /// <returns></returns> 
        [HttpPost]
        [UnitOfWork]
        [Microsoft.AspNetCore.Authorization.AllowAnonymous]
        public async Task<dynamic> SubmitSubmitVote(SubmitInput args)
        {
            var data = await rep_Experts.DetachedEntities.Where(p => !p.IsDeleted)
                .Where(a => a.login_code == args.code)
                .FirstOrDefaultAsync();
            _ = (data == null) ? throw Oops.Oh("提交码错误") : 1;
            //var list = args.projects.Adapt<List<Entities.VoteRecords>>();
            //删除这个专家上次提交的结果
            //或者提示不能再次提交
            _ = (await rep_VoteRecords.DetachedEntities.Where(a => !a.IsDeleted && a.expert_login_code == args.code).CountAsync() > 0) ? throw Oops.Oh("已提交，无需再次提交") : 1;
            var now = DateTime.Now;
            args.projects.ForEach(async a =>
            {
                var model = new Entities.VoteRecords
                {
                    expert_login_code = args.code,
                    project_id = a.id,
                    is_agree = a.vote,
                    vote_time = now
                };
                await model.InsertOrUpdate();
            });
            return true;
        }
        private async Task<List<ProjectsList2Output>> GetVoteData()
        {
            var query = from a in rep_Projects.DetachedEntities
                        join b in rep_VoteRecords.DetachedEntities
                            on a.Id equals b.project_id into grouping
                        from p in grouping.DefaultIfEmpty()
                        group new { a, p } by new { a.Id, a.name, a.serial_number, a.type } into pp
                        select new ProjectsList2Output
                        {
                            serial_number = pp.Key.serial_number,
                            id = pp.Key.Id,
                            name = pp.Key.name,
                            yes_count = pp.Where(a => a.p.is_agree).Count(),
                            no_count = pp.Where(a => !a.p.is_agree).Count(),
                            type = pp.Key.type
                        };
            return await query.OrderBy(a => a.serial_number).ToListAsync();
        }
        /// <summary>
        /// 列表
        /// </summary> 
        /// <returns></returns> 
        [HttpPost]
        public async Task<dynamic> List2()
        {

            //var data = rep_Projects.DetachedEntities.Where(p => !p.IsDeleted)
            //    //.Where(args.type != null, a => (int)a.type == args.type)
            //    .Join(rep_VoteRecords.DetachedEntities, a => a.Id, a => a.project_id, (a, b) =>
            //    new
            //    {
            //        //a.Id,
            //        //type = (int)a.type,
            //        //serial_number = a.serial_number,
            //        //name = a.name,
            //        //no_count = b.Where(bb => !bb.is_agree).Count(),
            //        //yes_count = b.Where(bb => bb.is_agree).Count(),
            //    }).ToList();
            ////.ProjectToType<ProjectsList2Output>()
            ////.OrderBy(a => a.serial_number)
            ////.ToListAsync(); 
            var data = await GetVoteData();
            var data0 = data.Where(a => a.type == Entities.EnumProjectType.FangJian).ToList();
            var data1 = data.Where(a => a.type == Entities.EnumProjectType.ShiZheng).ToList();
            var data2 = data.Where(a => a.type == Entities.EnumProjectType.GuiDaoGongCheng).ToList();
            var data3 = data.Where(a => a.type == Entities.EnumProjectType.DianLiGongCheng).ToList();
            var data4 = data.Where(a => a.type == Entities.EnumProjectType.JiaoTongGongCheng).ToList();
            var data5 = data.Where(a => a.type == Entities.EnumProjectType.ShuiLiGongCheng).ToList();
            return new
            {
                data0,
                data1,
                data2,
                data3,
                data4,
                data5
            };
        }
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public async Task<dynamic> Download()
        {
            var data = await GetVoteData();
            var filepath = Tools.ExcelHelper.WriteTemplate(data, 4, "C");
            return new FileStreamResult(new FileStream(filepath, FileMode.Open), "application/octet-stream") { FileDownloadName = filepath };
        }
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public async Task<dynamic> ExpertVote()
        {
            var list = await rep_Experts.DetachedEntities.GroupJoin(rep_VoteRecords.DetachedEntities, a => a.login_code, a => a.expert_login_code, (a, b) => new { a, b })
                .SelectMany(a => a.b.DefaultIfEmpty(), (a, b) => new { a.a.Id, a.a.login_code, is_vote = b != null })
                .Distinct().ToListAsync();
            return list;
            //var query = from a in rep_Experts.DetachedEntities
            //            join b in rep_VoteRecords.DetachedEntities on a.login_code equals b.expert_login_code into temp
            //            from tt in temp.DefaultIfEmpty()
            //            select new
            //            {
            //                a.Id,
            //                a.login_code,
            //                is_vote = tt == null
            //            };
            //return await query.ToListAsync();


        }

    }
}