From 557c2711a3e103ebc3d0492344eca9730d5e92b2 Mon Sep 17 00:00:00 2001
From: 移动系统liao <liaoxujun@qq.com>
Date: 星期一, 17 二月 2025 10:47:47 +0800
Subject: [PATCH] 增加司机配送单超时处理任务,防止一直不停手机定位信息,

---
 CoreCms.Net.Task/RefreshWeChatAccessTokenJob.cs |   19 ++++++++++++++++---
 1 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/CoreCms.Net.Task/RefreshWeChatAccessTokenJob.cs b/CoreCms.Net.Task/RefreshWeChatAccessTokenJob.cs
index 916ecb2..fdef0d4 100644
--- a/CoreCms.Net.Task/RefreshWeChatAccessTokenJob.cs
+++ b/CoreCms.Net.Task/RefreshWeChatAccessTokenJob.cs
@@ -1,10 +1,10 @@
 锘�/***********************************************************************
- *            Project: CoreCms.Net                                     *
- *                Web: https://CoreCms.Net                             *
+ *            Project: baifenBinfa.Net                                     *
+ *                Web: https://baifenBinfa.com                             *
  *        ProjectName: 鐧惧垎鍏垫硶绠$悊绯荤粺                               *
  *             Author:                                        *
  *              Email:                               *
- *         CreateTime: 2020-08-25 1:25:29
+ *         CreateTime: 2024-03-11 09:33:00
  *        Description: 鏆傛棤
  ***********************************************************************/
 
@@ -142,6 +142,7 @@
                 if (!string.IsNullOrEmpty(_weChatOptions.WxOpenAppId) && !string.IsNullOrEmpty(_weChatOptions.WxOpenAppSecret))
                 {
                     var entity = await _weChatAccessTokenServices.QueryByClauseAsync(p => p.appId == _weChatOptions.WxOpenAppId && p.appType == (int)GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken);
+
                     if (entity == null || entity.expireTimestamp <= DateTimeOffset.Now.ToUnixTimeSeconds())
                     {
                         var client = _weChatApiHttpClientFactory.CreateWxOpenClient();
@@ -203,6 +204,18 @@
                     }
                     else
                     {
+
+
+
+                      var value=  await _redisOperationRepository.Get<WeChatAccessToken>(
+                               GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken.ToString());
+                        if (value == null)
+                        {
+                            //閲嶆柊璁剧疆key
+                            await _redisOperationRepository.SetAsync(
+                            GlobalEnumVars.AccessTokenEnum.WxOpenAccessToken.ToString(), entity,
+                            TimeSpan.FromMinutes(120));
+                        }
                         //鎻掑叆鏃ュ織
                         var model = new SysTaskLog
                         {

--
Gitblit v1.9.1