znyc.recruitment.admin.api/Znyc.Recruitment.Admin.WebApi/Controllers/QuartzController.cs

using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Senparc.Weixin.MP.AdvancedAPIs;
using Senparc.Weixin.MP.AdvancedAPIs.TemplateMessage;
using System.Collections.Generic;
using System.Threading.Tasks;
using Znyc.Recruitment.Admin.AspNetCore.Controllers;
using Znyc.Recruitment.Admin.AspNetCore.Entitys;
using Znyc.Recruitment.Admin.Commons.Cache;
using Znyc.Recruitment.Admin.Commons.Entitys;
using Znyc.Recruitment.Admin.Security.Dtos;
using Znyc.Recruitment.Admin.Security.Entitys;
using Znyc.Recruitment.Admin.Security.IServices;
using Znyc.Recruitment.Admin.WebApi.Attributes;

namespace Znyc.Recruitment.Admin.WebApi.Controllers
{
    /// <summary>
    ///     定时调度
    /// </summary>
    [Quartz]
    [Route("api/Security/[controller]")]
    [AllowAnonymous]
    public class QuartzController : AreaApiController<ApiEntity, ApiOutputDto, ApiInputDto,
        IApiService, long>
    {
        private readonly IStatisticalService _statisticalService;
        private readonly IActivityService _activityService;
        private readonly IBannerService _bannerService;
        private readonly IApplyJobService _applyJobService;
        private readonly IRecruitmentService _recruitmentService;
        private readonly IIndustryJobsService _industryJobsService;

        /// <summary>
        ///     构造函数
        /// </summary>
        /// <param name="service"></param>
        /// <param name="statisticalService"></param>                
        /// <param name="activityService"></param>
        public QuartzController(IApiService service,
            IStatisticalService statisticalService,
            IActivityService activityService,
            IBannerService bannerService,
            IApplyJobService applyJobService,
            IRecruitmentService recruitmentService,
            IIndustryJobsService industryJobsService
        ) : base(service)
        {
            _service = service;
            _statisticalService = statisticalService;
            _activityService = activityService;
            _bannerService = bannerService;
            _applyJobService = applyJobService;
            _recruitmentService = recruitmentService;
            _industryJobsService = industryJobsService;
        }

        /// <summary>
        ///     添加统计数据
        /// </summary>
        /// <returns></returns>
        [HttpGet("InsertAsync")]
        [AllowAnonymous]

        //[FunctionAuthorize("Add")]
        public async Task<IActionResult> AddAsync()
        {
            CommonResult result = new CommonResult();
            result = await _statisticalService.InsertAsync();
            if (result.Success)
            {
                result.ErrCode = ErrCode.successCode;
                result.ErrMsg = ErrCode.err0;
            }
            else
            {
                result.ErrMsg = ErrCode.err43002;
                result.ErrCode = "43002";
            }

            return ToJsonContent(result);
        }


        /// <summary>
        ///     修改活动状态
        /// </summary>
        /// <returns></returns>
        [HttpGet("UpdateActivityStatusAsync")]
        [AllowAnonymous]
        public async Task<IActionResult> UpdateActivityStatusAsync()
        {
            CommonResult result = new CommonResult();
            CacheHelper cacheHelper = new CacheHelper();
            result = await _activityService.UpdateStatusAsync();
            if (result.Success)
            {
                cacheHelper.Remove("activity:list");
                result.ErrCode = ErrCode.successCode;
                result.ErrMsg = ErrCode.err0;
            }
            else
            {
                result.ErrMsg = ErrCode.err43002;
                result.ErrCode = "43002";
            }

            return ToJsonContent(result);
        }

        /// <summary>
        ///     修改广告状态
        /// </summary>
        /// <returns></returns>
        [HttpGet("UpdateBannerStatusAsync")]
        [AllowAnonymous]
        public async Task<IActionResult> UpdateBannerStatusAsync()
        {
            CommonResult result = new CommonResult();
            CacheHelper cacheHelper = new CacheHelper();
            result = await _bannerService.UpdateStatusAsync();
            if (result.Success)
            {
                cacheHelper.Remove("banner:list");
                result.ErrCode = ErrCode.successCode;
                result.ErrMsg = ErrCode.err0;
            }
            else
            {
                result.ErrMsg = ErrCode.err43002;
                result.ErrCode = "43002";
            }

            return ToJsonContent(result);
        }


        /// <summary>
        ///    求职信息匹配
        /// </summary>
        /// <returns></returns>
        [HttpGet("MatchingApplyJobAsync")]
        [AllowAnonymous]

        public async Task MatchingApplyJobAsync()
        {
            var applyJobs = await _applyJobService.GetListWhereAsync(" IsPublic=1 and IsDeleted=0 and Status=1");
            foreach (var applyJob in applyJobs)
            {
                var recruitment = await _recruitmentService.GetWhereAsync($" IndustryId={applyJob.IndustryId} && JobId={applyJob.JobId} &&  ProvinceId={applyJob.ProvinceId} && CityId={applyJob.CityId}");
                if (recruitment != null)
                {           //行业岗位
                    List<IndustryJobsOutputDto> industryJobs = await _industryJobsService.GetAllListAsync();
                    string jobName = industryJobs.Find(x => x.Id == recruitment.JobId)?.Name;
                    WeChat.CommonService.TemplateMessage.WeixinTemplate_Subscription data = new WeChat.CommonService.TemplateMessage.WeixinTemplate_Subscription("最新招聘信息通知！", "占位", jobName, recruitment.Address, "占位", "占位");
                    TemplateModel_MiniProgram miniProgram = new TemplateModel_MiniProgram();
                    miniProgram.appid = "wx71f2b227f8eaf00a";
                    miniProgram.pagepath = $"pages/detail/detail?type=recruitment&id={recruitment.Id}";
                    var result = await TemplateApi.SendTemplateMessageAsync("wx07c574aca93ae8d9", "oYbbE6Dh0e3P9s2cXF0vrISNhAZI", data.TemplateId, "pages/index/index", data, miniProgram);
                }
            }

        }


        /// <summary>
        ///    求职信息匹配
        /// </summary>
        /// <returns></returns>
        [HttpGet("MatchingRecruitmentAsync")]
        [AllowAnonymous]

        public async Task MatchingRecruitmentAsync()
        {
            var recruitments = await _recruitmentService.GetListWhereAsync(" IsPublic=1 and IsDeleted=0 and Status=1");
            foreach (var recruitment in recruitments)
            {
                var applyJob = await _applyJobService.GetWhereAsync($" IndustryId={recruitment.IndustryId} && JobId={recruitment.JobId} &&  ProvinceId={recruitment.ProvinceId} && CityId={recruitment.CityId}");
                if (applyJob != null)
                {           //行业岗位
                    List<IndustryJobsOutputDto> industryJobs = await _industryJobsService.GetAllListAsync();
                    string jobName = industryJobs.Find(x => x.Id == applyJob.JobId)?.Name;
                    WeChat.CommonService.TemplateMessage.WeixinTemplate_Subscription data = new WeChat.CommonService.TemplateMessage.WeixinTemplate_Subscription("最新求职信息通知！", "占位", jobName, applyJob.Address, "占位", "占位");
                    TemplateModel_MiniProgram miniProgram = new TemplateModel_MiniProgram();
                    miniProgram.appid = "wx71f2b227f8eaf00a";
                    miniProgram.pagepath = $"pages/detail/detail?type=apply&id={applyJob.Id}";
                    var result = await TemplateApi.SendTemplateMessageAsync("wx07c574aca93ae8d9", "oYbbE6Dh0e3P9s2cXF0vrISNhAZI", data.TemplateId, "pages/index/index", data, miniProgram);
                }
            }

        }
    }
}