Merge branch 'develop' of http://132.232.92.186:3000/XinXiBu/OA2023 into develop

OASystem/OASystem.Api/Controllers/PersonnelModuleController.cs

@@ -18,6 +18,7 @@ using System.Data;
 using System.Diagnostics;
 using System.Globalization;
 using static OASystem.API.OAMethodLib.JWTHelper;
+using OASystem.API.OAMethodLib.DeepSeekAPI;
 
 namespace OASystem.API.Controllers
 {
@@ -40,6 +41,7 @@ namespace OASystem.API.Controllers
         private readonly GoodsRepository _goodsRep;
         private readonly DecreasePaymentsRepository _otherPaymentRep;
         private readonly FeeAuditRepository _feeAuditRep;
+        private readonly IDeepSeekService _deepSeekService;
 
         private readonly string url;
         private readonly string path;
@@ -57,6 +59,7 @@ namespace OASystem.API.Controllers
         /// <param name="sqlSugar"></param>
         /// <param name="otherPaymentRep"></param>
         /// <param name="feeAuditRep"></param>
+        /// <param name="deepSeekService"></param>
         public PersonnelModuleController(
             IHubContext<ChatHub, IChatClient> hubContext,
             IMapper mapper,
@@ -67,7 +70,8 @@ namespace OASystem.API.Controllers
             GoodsRepository goodsRep,
             SqlSugarClient sqlSugar,
             DecreasePaymentsRepository otherPaymentRep,
-            FeeAuditRepository feeAuditRep
+            FeeAuditRepository feeAuditRep,
+            IDeepSeekService deepSeekService
             )
         {
             _mapper = mapper;
@@ -90,6 +94,7 @@ namespace OASystem.API.Controllers
             _goodsRep = goodsRep;
             _otherPaymentRep = otherPaymentRep;
             _feeAuditRep = feeAuditRep;
+            _deepSeekService = deepSeekService;
         }
 
         #region 工资表单
@@ -3108,5 +3113,103 @@ OPTION (MAXRECURSION 0); -- 允许无限递归      ";
         //}
 
         #endregion
+
+        #region Ai绩效分析
+
+        [HttpGet]
+        public async Task<IActionResult> AiPerformanceAnalysis_JobMarketingAsync(int userId, DateTime start, DateTime end)
+        {
+            var jw = JsonView(false);
+
+            var user_entity = _sqlSugar.Queryable<Sys_Users>()
+                              .First(e => e.Id == userId && e.IsDel == 0);
+
+            if (user_entity == null)
+            {
+                jw.Msg = "用户不存在！";
+                return Ok(jw);
+            }
+
+            List<string> useridlist = new List<string> { user_entity.QiyeChatUserId };
+
+            //获取企微外出打卡信息
+            var checkin_data = await _qiYeWeChatApiService.GetCheckinDataAsync(useridlist, 2, start, end);
+            if (checkin_data.errcode != 0)
+            {
+                jw.Msg = "获取企微外出打卡信息失败！" + checkin_data.errmsg;
+                return Ok(jw);
+            }
+
+            //获取企微外出申请信息
+            var approval_data = await _qiYeWeChatApiService.GetApprovalInfoUpdateAsync(start, end, newCursor: "", size: 100, filters: new List<IQiYeWeChatApiService.FilterCondition>(){
+                 new
+                  IQiYeWeChatApiService.FilterCondition{
+                     key = "creator",
+                     value = user_entity.QiyeChatUserId
+                  },
+                  new IQiYeWeChatApiService.FilterCondition{
+                    key="record_type",
+                    value="4"
+                  }
+            });
+            if (approval_data.errcode != 0)
+            {
+                jw.Msg = "获取企微外出申请信息失败！" + approval_data.errmsg;
+                return Ok(jw);
+            }
+
+            List<ApprovalDetailView> detailViews = new List<ApprovalDetailView>();
+            foreach (var item in approval_data.sp_no_list)
+            {
+                var approval_detail = await _qiYeWeChatApiService.GetApprovalDetailAsync(item);
+                if (approval_detail.errcode != 0)
+                {
+                    jw.Msg = "获取企微外出申请详情失败！" + approval_detail.errmsg;
+                    return Ok(jw);
+                }
+                detailViews.Add(approval_detail);
+            }
+
+            string question = $"请根据以下数据分析用户绩效：";
+            question += $"外出打卡信息：{JsonConvert.SerializeObject(checkin_data.checkindata)}";
+            if (approval_data.sp_no_list.Count > 0)
+            {
+                question += $"外出申请信息：{JsonConvert.SerializeObject(detailViews)}";
+            }
+            question += $"请根据我提供的{user_entity.CnName}数据信息（提供的数据已经是一个月的数据），按照一个月拜访20个客户的标准判断是否合格，并给出分析报告。";
+
+            try
+            {
+                var resp = await _deepSeekService.ChatAsync(question);
+                if (!resp.Success)
+                {
+                    jw.Msg = "Ai分析用户绩效失败！" + resp.Message;
+                    return Ok(jw);
+                }
+
+                jw.Data = new
+                {
+                    checkin_data = checkin_data.checkindata,
+                    approval_data = approval_data.sp_no_list,
+                    detailViews = detailViews,
+                    Answer = resp.Answer
+                };
+            }
+            catch (Exception ex)
+            {
+                jw.Msg = "Ai分析用户绩效失败！" + ex.Message;
+                return Ok(jw);
+            }
+
+            jw.Code = 200;
+            jw.Msg = "查询成功！";
+
+            return Ok(jw);
+        }
+
+
+
+        #endregion
+
     }
 }

OASystem/OASystem.Api/OAMethodLib/QiYeWeChatAPI/AppNotice/Library.cs

@@ -1123,7 +1123,7 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice
         public static async Task<bool> SendUserMsg_GroupShare_ToJob(int diId)
         {
             Grp_DelegationInfo groupInfo = _grpDeleRep.Query<Grp_DelegationInfo>(s => s.Id == diId).First();
-            List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 24 || s.JobPostId == 25 || s.JobPostId == 28)).ToList();
+            List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 24 || s.JobPostId == 25 || s.JobPostId == 28 || s.JobPostId == 23)).ToList();
             //List<Sys_Users> list_user = _grpDeleRep.Query<Sys_Users>(s => s.IsDel == 0 && (s.JobPostId == 40 || s.JobPostId == 41)).ToList();
             List<string> userIds = new List<string>();
             list_user.ForEach(s => userIds.Add(s.Id.ToString()));

OASystem/OASystem.Api/OAMethodLib/QiYeWeChatAPI/IQiYeWeChatApiService.cs

@@ -134,6 +134,13 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
         ///// <returns></returns>
         //Task<ApprovalInfoView> GetApprovalInfoAsync(DateTime startDt, DateTime endDt, int record_type);
 
+        Task<ApprovalInfoView> GetApprovalInfoUpdateAsync(
+        DateTime startTime,
+        DateTime endTime,
+        string newCursor,
+        int size,
+        List<FilterCondition> filters);
+
         //// <summary>
         /// 批量获取审批详情
         /// <param name="startDt"></param>
@@ -210,5 +217,27 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
         /// <returns></returns>
         Task<GroupStatus_SendMessageView> GroupStatus_SendMessage_ToUser_Markdown(List<string> toUser, string msgContent, string msgType = "markdown");
         #endregion
+
+        /// <summary>
+        /// 筛选条件
+        /// </summary>
+        public class FilterCondition
+        {
+            /// <summary>
+            /// 筛选类型
+            /// template_id - 模板类型/模板id
+            /// creator - 申请人
+            /// department - 审批单提单者所在部门
+            /// sp_status - 审批状态
+            /// record_type - 审批单类型属性
+            /// </summary>
+            public string key { get; set; }
+
+            /// <summary>
+            /// 筛选值
+            /// </summary>
+            public string value { get; set; }
+        }
+
     }
 }

OASystem/OASystem.Api/OAMethodLib/QiYeWeChatAPI/QiYeWeChatApiService.cs

@@ -674,9 +674,9 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
         public async Task<object> QueryAssessmentByUser(DateTime startDt, DateTime endDt, List<string> qiyeUidList)
         {
             AssessmentByUserListView assessmentByUserListView = new AssessmentByUserListView();
-            List<AssessmentByUserView> AssessmentByUserView = new  List<AssessmentByUserView>();
+            List<AssessmentByUserView> AssessmentByUserView = new List<AssessmentByUserView>();
             assessmentByUserListView.Data = AssessmentByUserView;
-            assessmentByUserListView.errcode = 0;  
+            assessmentByUserListView.errcode = 0;
             assessmentByUserListView.errmsg = "成功";
 
             CheckInView? checkInView = new CheckInView();
@@ -744,7 +744,8 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
                 });
             }
 
-            if (errorUserList.Count > 0) {
+            if (errorUserList.Count > 0)
+            {
 
                 var dayInfo = await GetCheckinDataAsync(errorUserList, 3, startDt, endDt);
 
@@ -773,7 +774,7 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
                             {
                                 var linqFind = dic.First(x => x.Value.Contains(item.exception_type));
 
-                                var errinfo =  new Exception_info
+                                var errinfo = new Exception_info
                                 {
                                     Date = item.checkin_time_dt,
                                     Type = linqFind.Key,
@@ -1338,6 +1339,47 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
             return approvalInfoView;
         }
 
+        public async Task<ApprovalInfoView> GetApprovalInfoUpdateAsync(
+        DateTime startTime,
+        DateTime endTime,
+        string newCursor = "",
+        int size = 100,
+        List<IQiYeWeChatApiService.FilterCondition> filters = null)
+        {
+
+            long starttime = (long)(startTime - _1970).TotalSeconds;
+            long endtime = (long)(endTime - _1970).TotalSeconds;
+            var requestData = new
+            {
+                starttime = starttime,
+                endtime = endtime,
+                new_cursor = newCursor,
+                size = size,
+                filters = filters ?? new List<IQiYeWeChatApiService.FilterCondition>()
+            };
+
+            string jsonContent = JsonConvert.SerializeObject(requestData);
+            var httpContent = new StringContent(jsonContent, Encoding.UTF8, "application/json");
+            var token = await GetTokenAsync(5);
+
+            try
+            {
+                string url = "/cgi-bin/oa/getapprovalinfo?access_token=" + token.access_token;
+                HttpResponseMessage response = await _httpClient.PostAsync(url, httpContent);
+                response.EnsureSuccessStatusCode();
+                string responseContent = await response.Content.ReadAsStringAsync();
+                var result = JsonConvert.DeserializeObject<ApprovalInfoView>(responseContent);
+                return result;
+            }
+            catch (Exception ex)
+            {
+                ApprovalInfoView approvalInfoView = new ApprovalInfoView();
+                approvalInfoView.errcode = -1;
+                approvalInfoView.errmsg = ex.Message;
+                return approvalInfoView;
+            }
+        }
+
         /// <summary>
         /// 获取审批申请详情
         /// </summary>
@@ -1683,6 +1725,6 @@ namespace OASystem.API.OAMethodLib.QiYeWeChatAPI
             return (dt.ToUniversalTime().Ticks - 621355968000000000) / 10000000;
         }
 
-       
+
     }
 }