Skip to content

E
Education
Commit aadcc7cc authored by liudong1993's avatar liudong1993
Browse files
Options

Merge branch 'master' of http://gitlab.oytour.com/Kui2/education

parents a3a5b121 36e07629
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 237 additions and 62 deletions
Edu.Module.Course/ClassModule.cs
View file @ aadcc7cc
...@@ -2077,7 +2077,7 @@ namespace Edu.Module.Course ...@@ -2077,7 +2077,7 @@ namespace Edu.Module.Course
var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID); var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID);
#region 欠费提醒（销售） #region 欠费提醒（销售）
var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID); var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID);
if (!string.IsNullOrEmpty(queryTargetWorkId)) if (!string.IsNullOrEmpty(queryTargetWorkId)&& sellerInfo!=null )
{ {
// 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称 // 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称
var path = $"/sale/myOrder?OrderId={guestModel.OrderId}"; var path = $"/sale/myOrder?OrderId={guestModel.OrderId}";
...@@ -2135,10 +2135,11 @@ namespace Edu.Module.Course ...@@ -2135,10 +2135,11 @@ namespace Edu.Module.Course
{ {
var shengyuMoney = orderModel.PreferPrice - orderModel.Income + orderModel.Refund - orderModel.PlatformTax - orderModel.DiscountMoney - orderModel.LessPrice; var shengyuMoney = orderModel.PreferPrice - orderModel.Income + orderModel.Refund - orderModel.PlatformTax - orderModel.DiscountMoney - orderModel.LessPrice;
var classModel = classRepository.GetEntity<RB_Class_ViewModel>(guestModel.ClassId); var classModel = classRepository.GetEntity<RB_Class_ViewModel>(guestModel.ClassId);
var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID); var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.CreateBy);
#region 即将欠费提醒（销售） #region 即将欠费提醒（销售）
var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID); var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.CreateBy);
if (!string.IsNullOrEmpty(queryTargetWorkId)) if (!string.IsNullOrEmpty(queryTargetWorkId)&& sellerInfo!=null)
{ {
// 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称 // 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称
var path = $"/sale/myOrder?OrderId={guestModel.OrderId}"; var path = $"/sale/myOrder?OrderId={guestModel.OrderId}";
...@@ -2198,7 +2199,7 @@ namespace Edu.Module.Course ...@@ -2198,7 +2199,7 @@ namespace Edu.Module.Course
var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID); var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID);
#region 即将结课提醒 (销售端) #region 即将结课提醒 (销售端)
var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID); var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID);
if (!string.IsNullOrEmpty(queryTargetWorkId)) if (!string.IsNullOrEmpty(queryTargetWorkId)&&sellerInfo!=null)
{ {
// 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称 // 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称
var path = $"/sale/myOrder?OrderId={guestModel.OrderId}"; var path = $"/sale/myOrder?OrderId={guestModel.OrderId}";
...@@ -2261,7 +2262,7 @@ namespace Edu.Module.Course ...@@ -2261,7 +2262,7 @@ namespace Edu.Module.Course
var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID); var sellerInfo = UserReidsCache.GetUserLoginInfo(orderModel.EnterID);
#region 即将结课提醒 (销售端) #region 即将结课提醒 (销售端)
var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID); var queryTargetWorkId = accountRepository.GetWorkUserIdRepository(orderModel.EnterID);
if (!string.IsNullOrEmpty(queryTargetWorkId)) if (!string.IsNullOrEmpty(queryTargetWorkId)&& sellerInfo!=null)
{ {
// 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称 // 学员名称（名称+电话），剩余课时，关联单号，待收金额，班级老师，班级名称
var path = $"/sale/myOrder?OrderId={guestModel.OrderId}"; var path = $"/sale/myOrder?OrderId={guestModel.OrderId}";
...@@ -5289,7 +5290,8 @@ namespace Edu.Module.Course ...@@ -5289,7 +5290,8 @@ namespace Edu.Module.Course
//约课 //约课
planModel = class_PlanRepository.GetToDayClassPlanForYK(stuId, courseId, groupId); planModel = class_PlanRepository.GetToDayClassPlanForYK(stuId, courseId, groupId);
} }
else { else
{
planModel = class_PlanRepository.GetToDayClassPlan(classId, groupId); planModel = class_PlanRepository.GetToDayClassPlan(classId, groupId);
} }
if (planModel != null) if (planModel != null)
...@@ -5300,7 +5302,8 @@ namespace Edu.Module.Course ...@@ -5300,7 +5302,8 @@ namespace Edu.Module.Course
var ogModel = order_GuestRepository.GetEntity(guestId); var ogModel = order_GuestRepository.GetEntity(guestId);
zj = ogModel.CourseChapterNo + 1;//这次课的章节 zj = ogModel.CourseChapterNo + 1;//这次课的章节
} }
else { else
{
zj = planModel.LessonPlanNum + 1; zj = planModel.LessonPlanNum + 1;
} }
if (planModel.ClassDate.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd")) if (planModel.ClassDate.ToString("yyyy-MM-dd") == DateTime.Now.ToString("yyyy-MM-dd"))
...@@ -5571,5 +5574,52 @@ namespace Edu.Module.Course ...@@ -5571,5 +5574,52 @@ namespace Edu.Module.Course
} }
} }
} }
/// <summary>
/// 处理学生上课进度
/// </summary>
public void DealStudentCourseChapterNoModule()
{
string toDay = Common.ConvertHelper.FormatDate(DateTime.Now.AddDays(-1));
var planList = class_PlanRepository.GetClassPlanListExtRepository(new RB_Class_Plan_ViewModel() {
StartTime = toDay,
EndTime = toDay,
PlanType = 1
});
List<RB_Order_Guest_ViewModel> guestList = new List<RB_Order_Guest_ViewModel>();
if (planList != null && planList.Count > 0)
{
string classIds = string.Join(",", planList.Select(qitem => qitem.ClassId));
if (!string.IsNullOrEmpty(classIds))
{
guestList = order_GuestRepository.GetOrderGuestListRepository(new RB_Order_Guest_ViewModel()
{
ClassIds = classIds
});
}
}
if (guestList != null && guestList.Count > 0)
{
foreach (var item in guestList)
{
var tempPlanList = planList.Where(qitem => qitem.ClassId == item.ClassId)?.ToList();
decimal times = 0;
if (tempPlanList != null && tempPlanList.Count > 0)
{
times = tempPlanList.Sum(qitem => qitem.TimeHour) / 2;
}
if (times > 0)
{
var tempCourseChapterNo = item.CourseChapterNo + times;
Dictionary<string, object> fileds = new Dictionary<string, object>()
{
{nameof(RB_Order_Guest_ViewModel.CourseChapterNo), tempCourseChapterNo}
};
order_GuestRepository.Update(fileds, new WhereHelper(nameof(RB_Order_Guest_ViewModel.Id), item.Id));
}
}
}
}
} }
} }
\ No newline at end of file
Edu.Module.Customer/MarketConsultantModule.cs
View file @ aadcc7cc
...@@ -830,10 +830,28 @@ namespace Edu.Module.Customer ...@@ -830,10 +830,28 @@ namespace Edu.Module.Customer
var CurMonthFollow = tempDataList?.Sum(qitem => qitem.CurMonthFollow) ?? 0; var CurMonthFollow = tempDataList?.Sum(qitem => qitem.CurMonthFollow) ?? 0;
var LastMonthFollow = tempDataList?.Sum(qitem => qitem.LastMonthFollow) ?? 0; var LastMonthFollow = tempDataList?.Sum(qitem => qitem.LastMonthFollow) ?? 0;
var AgFollow = Math.Round(yesDataList?.Average(qitem => qitem.AgFollow) ?? 0, 2); decimal AgFollow = 0;
var YestodayAgFollow = Math.Round(yesDataList?.Average(qitem => qitem.YestodayAgFollow) ?? 0, 2); if (yesDataList != null && yesDataList.Where(qitem=>qitem.AgFollow>0).Count() > 0)
var CurWeekAgFollow = Math.Round(curWeekList?.Average(qitem => qitem.CurWeekAgFollow) ?? 0, 2); {
var LastWeekAgFollow = Math.Round(lastWeekList?.Average(qitem => qitem.LastWeekAgFollow) ?? 0, 2); AgFollow = Math.Round(yesDataList?.Average(qitem => qitem.AgFollow) ?? 0, 2);
}
decimal YestodayAgFollow = 0;
if (yesDataList != null && yesDataList.Where(qitem => qitem.YestodayAgFollow > 0).Count() > 0)
{
YestodayAgFollow= Math.Round(yesDataList?.Average(qitem => qitem.YestodayAgFollow) ?? 0, 2);
}
decimal CurWeekAgFollow = 0;
if (curWeekList != null && curWeekList.Where(qitem => qitem.CurWeekAgFollow > 0).Count() > 0)
{
CurWeekAgFollow= Math.Round(curWeekList?.Average(qitem => qitem.CurWeekAgFollow) ?? 0, 2);
}
decimal LastWeekAgFollow = 0;
Math.Round(lastWeekList?.Average(qitem => qitem.LastWeekAgFollow) ?? 0, 2);
decimal CurMonthAgFollow = 0; decimal CurMonthAgFollow = 0;
decimal LastMonthAgFollow = 0; decimal LastMonthAgFollow = 0;
if (tempDataList != null && tempDataList.Count > 0) if (tempDataList != null && tempDataList.Count > 0)
......
Edu.Module.User/StudentModule.cs
View file @ aadcc7cc
...@@ -181,9 +181,11 @@ namespace Edu.Module.User ...@@ -181,9 +181,11 @@ namespace Edu.Module.User
accountList = accountModule.GetAccountListExtModule(new RB_Account_ViewModel() { QIds = string.Join(",", empIdList) }); accountList = accountModule.GetAccountListExtModule(new RB_Account_ViewModel() { QIds = string.Join(",", empIdList) });
} }
//学员到访统计 //学员到访统计
var visitList = student_VisitRepository.GetStudentVisitStaticRepository(new RB_Student_Visit_Extend() var visitList = student_VisitRepository.GetStudentVisitStatic_V2Repository(new RB_Student_Visit_Extend()
{ {
QStuIds = stuIds QStuIds = stuIds,
StartDate=query.StartTime,
EndDate=query.EndTime,
}); });
//学员试听统计 //学员试听统计
var stuReserveList = visitor_ReserveRepository.GetStuReserveStaticsListRepository(new Model.ViewModel.Reserve.RB_Visitor_Reserve_Extend() var stuReserveList = visitor_ReserveRepository.GetStuReserveStaticsListRepository(new Model.ViewModel.Reserve.RB_Visitor_Reserve_Extend()
......
Edu.Repository/Customer/RB_Student_VisitRepository.cs
View file @ aadcc7cc
...@@ -134,6 +134,56 @@ WHERE 1=1 ...@@ -134,6 +134,56 @@ WHERE 1=1
return Get<RB_Student_Visit_Extend>(builder.ToString()).ToList(); return Get<RB_Student_Visit_Extend>(builder.ToString()).ToList();
} }
/// <summary>
/// 获取到访列表
/// </summary>
/// <param name="query"></param>
/// <returns></returns>
public List<RB_Student_Visit_Extend> GetStudentVisitStatic_V2Repository(RB_Student_Visit_Extend query)
{
StringBuilder builder = new StringBuilder();
builder.AppendFormat(@"
SELECT A.StuId,Count(1) AS VisitCount
FROM RB_Student_Visit AS A INNER JOIN rb_student AS B ON A.StuId=B.StuId
WHERE 1=1
");
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Student_Visit_Extend.Status), (int)DateStateEnum.Normal);
if (query != null)
{
if (query.Group_Id > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Student_Visit_Extend.Group_Id), query.Group_Id);
}
if (query.StuId > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Student_Visit_Extend.StuId), query.StuId);
}
if (!string.IsNullOrEmpty(query.QStuIds))
{
builder.AppendFormat(" AND A.{0} IN({1}) ", nameof(RB_Student_Visit_Extend.StuId), query.QStuIds);
}
if (query.CreateBy > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Student_Visit_Extend.CreateBy), query.CreateBy);
}
if (!string.IsNullOrEmpty(query.QCreateByIds))
{
builder.AppendFormat(" AND A.{0} IN({1}) ", nameof(RB_Student_Visit_Extend.CreateBy), query.QCreateByIds);
}
if (!string.IsNullOrEmpty(query.StartDate))
{
builder.AppendFormat(" AND A.{0}>='{1}' ", nameof(RB_Student_Visit_Extend.CreateTime), Common.ConvertHelper.FormatDate(query.StartDate));
}
if (!string.IsNullOrEmpty(query.EndDate))
{
builder.AppendFormat(" AND A.{0}<='{1} 23:59:59' ", nameof(RB_Student_Visit_Extend.CreateTime), Common.ConvertHelper.FormatDate(query.EndDate));
}
}
builder.AppendFormat(" GROUP BY A.StuId ");
builder.AppendFormat(" ORDER BY A.StuId ");
return Get<RB_Student_Visit_Extend>(builder.ToString()).ToList();
}
/// <summary> /// <summary>
/// 市场、课程顾问学员到访统计 /// 市场、课程顾问学员到访统计
/// </summary> /// </summary>
......
Edu.Repository/Grade/RB_Class_PlanRepository.cs
View file @ aadcc7cc
...@@ -75,6 +75,10 @@ WHERE 1=1 ...@@ -75,6 +75,10 @@ WHERE 1=1
{ {
builder.AppendFormat(" AND IFNULL(A.{0},'')<>'' ", nameof(RB_Class_Plan_ViewModel.RepeatPlanIds)); builder.AppendFormat(" AND IFNULL(A.{0},'')<>'' ", nameof(RB_Class_Plan_ViewModel.RepeatPlanIds));
} }
if (query.PlanType > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Class_Plan_ViewModel.PlanType), query.PlanType);
}
} }
return Get<RB_Class_Plan_ViewModel>(builder.ToString()).ToList(); return Get<RB_Class_Plan_ViewModel>(builder.ToString()).ToList();
} }
...@@ -123,10 +127,6 @@ WHERE 1=1 AND C.`Status`=0 AND C.ClassStatus<>3 ...@@ -123,10 +127,6 @@ WHERE 1=1 AND C.`Status`=0 AND C.ClassStatus<>3
{ {
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Class_Plan_ViewModel.TeacherId), query.TeacherId); builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Class_Plan_ViewModel.TeacherId), query.TeacherId);
} }
//if (query.School_Id > 0)
//{
// builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Class_Plan_ViewModel.School_Id), query.School_Id);
//}
if (query.ClassTimeId > 0) if (query.ClassTimeId > 0)
{ {
builder.AppendFormat(" AND time.{0}={1} ", nameof(RB_Class_Plan_ViewModel.ClassTimeId), query.ClassTimeId); builder.AppendFormat(" AND time.{0}={1} ", nameof(RB_Class_Plan_ViewModel.ClassTimeId), query.ClassTimeId);
...@@ -151,6 +151,10 @@ WHERE 1=1 AND C.`Status`=0 AND C.ClassStatus<>3 ...@@ -151,6 +151,10 @@ WHERE 1=1 AND C.`Status`=0 AND C.ClassStatus<>3
{ {
builder.AppendFormat(" AND DATE_FORMAT(A.{0},'%y/%m/%d')= DATE_FORMAT('{1}','%y/%m/%d') ", nameof(RB_Class_Plan_ViewModel.ClassDate), query.QClassDateStr); builder.AppendFormat(" AND DATE_FORMAT(A.{0},'%y/%m/%d')= DATE_FORMAT('{1}','%y/%m/%d') ", nameof(RB_Class_Plan_ViewModel.ClassDate), query.QClassDateStr);
} }
if (query.PlanType > 0)
{
builder.AppendFormat(" AND A.{0}={1} ", nameof(RB_Class_Plan_ViewModel.PlanType), query.PlanType);
}
} }
return Get<RB_Class_Plan_ViewModel>(builder.ToString()).ToList(); return Get<RB_Class_Plan_ViewModel>(builder.ToString()).ToList();
} }
......
Edu.Repository/Sell/RB_Order_GuestRepository.cs
View file @ aadcc7cc
...@@ -175,10 +175,7 @@ WHERE 1=1 AND A.Status=0 ...@@ -175,10 +175,7 @@ WHERE 1=1 AND A.Status=0
{ {
builder.AppendFormat($@" AND A.{nameof(RB_Order_Guest_ViewModel.Group_Id)} ={demodel.Group_Id}"); builder.AppendFormat($@" AND A.{nameof(RB_Order_Guest_ViewModel.Group_Id)} ={demodel.Group_Id}");
} }
//if (demodel.School_Id > 0)
//{
// builder.AppendFormat($@" AND A.{nameof(RB_Order_Guest_ViewModel.School_Id)} ={demodel.School_Id}");
//}
if (demodel.OrderId > 0) if (demodel.OrderId > 0)
{ {
builder.AppendFormat($@" AND A.{nameof(RB_Order_Guest_ViewModel.OrderId)} ={demodel.OrderId}"); builder.AppendFormat($@" AND A.{nameof(RB_Order_Guest_ViewModel.OrderId)} ={demodel.OrderId}");
......
Edu.Repository/User/RB_StudentRepository.cs
View file @ aadcc7cc
...@@ -422,6 +422,14 @@ WHERE 1=1 ...@@ -422,6 +422,14 @@ WHERE 1=1
{ {
builder.AppendFormat(" AND t.{0}={1} ", nameof(RB_Student_ViewModel.StuChannel), query.StuChannel); builder.AppendFormat(" AND t.{0}={1} ", nameof(RB_Student_ViewModel.StuChannel), query.StuChannel);
} }
if (query.CreateType > 0 && query.StuSourceId > 0)
{
builder.AppendFormat(" AND t.{0}={1} AND t.{2}={3} ",
nameof(RB_Student_ViewModel.CreateType),
(int)query.CreateType,
nameof(RB_Student_ViewModel.StuSourceId),
query.StuSourceId);
}
} }
builder.AppendFormat(" ORDER BY t.{0} DESC ", nameof(RB_Student_ViewModel.StuId)); builder.AppendFormat(" ORDER BY t.{0} DESC ", nameof(RB_Student_ViewModel.StuId));
return GetPage<RB_Student_ViewModel>(pageIndex, pageSize, out rowsCount, builder.ToString(), parameters).ToList(); return GetPage<RB_Student_ViewModel>(pageIndex, pageSize, out rowsCount, builder.ToString(), parameters).ToList();
......
Edu.WebApi/Controllers/User/UserController.cs
View file @ aadcc7cc
...@@ -690,7 +690,8 @@ namespace Edu.WebApi.Controllers.User ...@@ -690,7 +690,8 @@ namespace Edu.WebApi.Controllers.User
QStudentStatus=base.ParmJObj.GetInt("QStudentStatus"), QStudentStatus=base.ParmJObj.GetInt("QStudentStatus"),
AdvisorStatus=base.ParmJObj.GetInt("AdvisorStatus"), AdvisorStatus=base.ParmJObj.GetInt("AdvisorStatus"),
StuChannel=base.ParmJObj.GetInt("StuChannel"), StuChannel=base.ParmJObj.GetInt("StuChannel"),
CreateType=(StuCreateTypeEnum) base.ParmJObj.GetInt("CreateType"),
StuSourceId=base.ParmJObj.GetInt("StuSourceId"),
}; };
if (query.IsQueryMyStu == 1) if (query.IsQueryMyStu == 1)
{ {
......
Edu.WebApi/Timers/TimerJobj.cs
View file @ aadcc7cc
...@@ -41,6 +41,11 @@ namespace Edu.WebApi.Timers ...@@ -41,6 +41,11 @@ namespace Edu.WebApi.Timers
/// </summary> /// </summary>
private static readonly PaperModule paperModule = new PaperModule(); private static readonly PaperModule paperModule = new PaperModule();
/// <summary>
/// 班级处理类对象
/// </summary>
private static readonly ClassModule classModule = new ClassModule();
/// <summary> /// <summary>
/// 使用redis第几号库 /// 使用redis第几号库
/// </summary> /// </summary>
...@@ -48,6 +53,7 @@ namespace Edu.WebApi.Timers ...@@ -48,6 +53,7 @@ namespace Edu.WebApi.Timers
static readonly RedisHelper redis = new RedisHelper(REDIS_DB3); static readonly RedisHelper redis = new RedisHelper(REDIS_DB3);
/// <summary> /// <summary>
/// 课程顾问部和市场部数据统计 /// 课程顾问部和市场部数据统计
/// </summary> /// </summary>
...@@ -69,11 +75,13 @@ namespace Edu.WebApi.Timers ...@@ -69,11 +75,13 @@ namespace Edu.WebApi.Timers
static System.Timers.Timer marketTimer;//处理市场部和课程顾问部数据统计 static System.Timers.Timer marketTimer;//处理市场部和课程顾问部数据统计
static System.Timers.Timer dealStudentProgressTimer;//处理学员上课进度
public static void RunTimer() public static void RunTimer()
{ {
timer1 = new System.Timers.Timer timer1 = new System.Timers.Timer
{ {
Interval = (1000 * 60) * (60 * 3) //3销售 Interval = (1000 * 60) * (60 * 3) //3小时执行一次
}; };
timer1.Elapsed += new System.Timers.ElapsedEventHandler(ClearFile); timer1.Elapsed += new System.Timers.ElapsedEventHandler(ClearFile);
timer1.Enabled = true; timer1.Enabled = true;
...@@ -123,10 +131,17 @@ namespace Edu.WebApi.Timers ...@@ -123,10 +131,17 @@ namespace Edu.WebApi.Timers
marketTimer = new System.Timers.Timer() marketTimer = new System.Timers.Timer()
{ {
Interval = (1000 * 60) * (1) //1小时检查一次 Interval = (1000 * 60) * (60 * 1) //1小时
}; };
marketTimer.Elapsed += new System.Timers.ElapsedEventHandler(DealMarketConsultantData); marketTimer.Elapsed += new System.Timers.ElapsedEventHandler(DealMarketConsultantData);
marketTimer.Enabled = true; marketTimer.Enabled = true;
dealStudentProgressTimer = new System.Timers.Timer()
{
Interval = (1000 * 60) * (60 * 1) //1小时检查一次
};
dealStudentProgressTimer.Elapsed += new System.Timers.ElapsedEventHandler(DealStudentProgressModule);
dealStudentProgressTimer.Enabled = true;
} }
public static void RunStop() public static void RunStop()
...@@ -139,6 +154,7 @@ namespace Edu.WebApi.Timers ...@@ -139,6 +154,7 @@ namespace Edu.WebApi.Timers
examTimer.Enabled = false; examTimer.Enabled = false;
finishGuest.Enabled = false; finishGuest.Enabled = false;
marketTimer.Enabled = false; marketTimer.Enabled = false;
dealStudentProgressTimer.Enabled = false;
} }
/// <summary> /// <summary>
...@@ -152,9 +168,38 @@ namespace Edu.WebApi.Timers ...@@ -152,9 +168,38 @@ namespace Edu.WebApi.Timers
private static int examPublish_Timer = 0; private static int examPublish_Timer = 0;
private static int guestfinish_Timer = 0; private static int guestfinish_Timer = 0;
private static int marketconsultant_Timer = 0; private static int marketconsultant_Timer = 0;
private static int dealstudentprogress_Timer = 0;
private static readonly string createMarkDataKey = "createMarkDataKey";
private static readonly string dealStudentProgress = "dealStudentProgress";
/// <summary>
/// 处理学员上课进度
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
public static void DealStudentProgressModule(object sender, System.Timers.ElapsedEventArgs e)
{
if (Interlocked.Exchange(ref dealstudentprogress_Timer, 1) == 0)
{
var currentDate = DateTime.Now;
string cacheData = redis.Get(dealStudentProgress);
if (string.IsNullOrEmpty(cacheData))
{
redis.Set(dealStudentProgress, Common.ConvertHelper.FormatDate(currentDate));
cacheData = Common.ConvertHelper.FormatDate(currentDate);
}
if (!string.IsNullOrEmpty(cacheData) && cacheData != Common.ConvertHelper.FormatDate(currentDate))
{
redis.Set(dealStudentProgress, Common.ConvertHelper.FormatDate(currentDate));
classModule.DealStudentCourseChapterNoModule();
}
//处理学员进度
Interlocked.Exchange(ref dealstudentprogress_Timer, 0);
}
}
private static string createMarkDataKey = "createMarkDataKey";
/// <summary> /// <summary>
/// 定时生成市场部和课程顾问部数据统计 /// 定时生成市场部和课程顾问部数据统计
/// </summary> /// </summary>
...@@ -162,7 +207,7 @@ namespace Edu.WebApi.Timers ...@@ -162,7 +207,7 @@ namespace Edu.WebApi.Timers
/// <param name="e"></param> /// <param name="e"></param>
public static void DealMarketConsultantData(object sender, System.Timers.ElapsedEventArgs e) public static void DealMarketConsultantData(object sender, System.Timers.ElapsedEventArgs e)
{ {
if (Interlocked.Exchange(ref marketconsultant_Timer,1) == 0) if (Interlocked.Exchange(ref marketconsultant_Timer, 1) == 0)
{ {
var currentDate = DateTime.Now; var currentDate = DateTime.Now;
string cacheData = redis.Get(createMarkDataKey); string cacheData = redis.Get(createMarkDataKey);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment