using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using Newtonsoft.Json;
|
using Quartz;
|
using WIDESEA_Model.Models.Basic;
|
using WIDESEAWCS_Core.BaseRepository;
|
using WIDESEAWCS_Core.Helper;
|
using WIDESEAWCS_Core.HttpContextUser;
|
using WIDESEAWCS_Core.LogHelper;
|
using WIDESEAWCS_DTO.ERP;
|
using WIDESEAWCS_DTO.MES;
|
using WIDESEAWCS_Model.Models.ERP;
|
using WIDESEAWCS_QuartzJob;
|
|
namespace WIDESEAWCS_Tasks
|
{
|
[DisallowConcurrentExecution]
|
public class ERPJob : JobBase, IJob
|
{
|
private readonly IRepository<Dt_ERP> _ERPRepository;
|
|
//秒
|
private static int shijian = 0;
|
|
public ERPJob(IRepository<Dt_ERP> ERPRepository)
|
{
|
_ERPRepository = ERPRepository;
|
}
|
|
public Task Execute(IJobExecutionContext context)
|
{
|
try
|
{
|
//一天获取一次校验码
|
Thread.Sleep(1000);
|
shijian = shijian - 1;
|
//获取ERP的token
|
if (shijian <= 0)
|
{
|
string ERP = AppSettings.Get("ERP");
|
if (!string.IsNullOrEmpty(ERP))
|
{
|
Dt_ERP Dt_ERP = _ERPRepository.QueryFirst(x => x.Id == 1);
|
|
AppERP appERP = new AppERP();
|
appERP.appTicket = Dt_ERP.appTicket;
|
appERP.certificate = Dt_ERP.certificate;
|
|
var headers = new Dictionary<string, string>();
|
headers.Add("AppKey", Dt_ERP.AppKey);
|
headers.Add("AppSecret", Dt_ERP.AppSecret);
|
ERPtoken s = JsonConvert.DeserializeObject<ERPtoken>(HttpHelper.Post($"{ERP}/v1/common/auth/selfBuiltApp/generateToken", appERP.Serialize(), "application/json", headers));
|
if (s.result.Equals("true"))
|
{
|
Dt_ERP.Token = s.value.accessToken;
|
shijian = 86400;
|
|
_ERPRepository.UpdateData(Dt_ERP);
|
}
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
//写入日志
|
LogLock.OutLogAOP("ERP日志", new string[] { "ERP", $"{ex.Message}" });
|
}
|
return Task.CompletedTask;
|
}
|
}
|
}
|
