From a60d3dd71b42b962d30c14dc59dcad958ee88da4 Mon Sep 17 00:00:00 2001
From: wuchunlei <mailcauchy@gmail.com>
Date: Thu, 18 Jul 2024 11:24:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E7=94=A8=E6=88=B7=E5=BC=80?=
 =?UTF-8?q?=E8=AF=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../peanut/modules/job/task/UserCourseBuyTask.java | 14 ++++++++++----
 1 file changed, 10 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/peanut/modules/job/task/UserCourseBuyTask.java b/src/main/java/com/peanut/modules/job/task/UserCourseBuyTask.java
index a95fe0a1..349cdff6 100644
--- a/src/main/java/com/peanut/modules/job/task/UserCourseBuyTask.java
+++ b/src/main/java/com/peanut/modules/job/task/UserCourseBuyTask.java
@@ -2,6 +2,7 @@ package com.peanut.modules.job.task;
 
 import cn.hutool.core.date.DateUtil;
 import org.apache.commons.lang.time.DateUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 import java.math.BigDecimal;
 import java.sql.*;
@@ -10,6 +11,9 @@ import java.util.Date;
 @Component("userCourseBuyTask")
 public class UserCourseBuyTask implements ITask{
 
+    @Value("${spring.profiles.active}")
+    private String active;
+
     @Override
     public void run(String params) {
         try {
@@ -17,16 +21,18 @@ public class UserCourseBuyTask implements ITask{
             Connection yljkconn = DriverManager.getConnection(
                     "jdbc:mysql://goldorchid.mysql.rds.aliyuncs.com:3309/everhealth?",
                     "yljkmaster", "Wu751019!@");
-            Connection fzdsconn = DriverManager.getConnection(
-                    "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true",
-                    "nuttyreading", "Wu751019!");
+            String url = "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book_test?rewriteBatchedStatements=true";
+            if ("prod".equals(active)){
+                url = "jdbc:mysql://rm-2zev4157t67trxuu3yo.mysql.rds.aliyuncs.com:3306/e_book?rewriteBatchedStatements=true";
+            }
+            Connection fzdsconn = DriverManager.getConnection(url , "nuttyreading", "Wu751019!");
             PreparedStatement addClassStatement = fzdsconn.prepareStatement(
                     "INSERT ignore INTO user_course_buy (user_id,course_id,catalogue_id,create_time,days,start_time,end_time) " +
                             "VALUES (?, ?, ?, ?, ?, ?, ?)");
             //查询前一天新开的课
             PreparedStatement classStatement = yljkconn.prepareStatement("select tc.superVIP,tc.cellPhone,tctc.* from  t_customer_taihu_class tctc " +
                     "left join t_customer tc on tc.oid = tctc.customerOid " +
-                    "where tctc.valid = 1 and tctc.status = '10' and DATE(tctc.createDate) = DATE('"+DateUtils.addDays(new Date(),-1)+"') and tc.superVIP = '0' ");
+                    "where tctc.valid = 1 and tctc.status = '10' and DATE(tctc.createDate) > DATE('"+DateUtil.format(DateUtils.addDays(new Date(),-1),"yyyy-MM-dd")+"') and tc.superVIP = '0' ");
             ResultSet classResultSet = classStatement.executeQuery();
             System.out.println("userCourseBuy数据统计完成-----");
             while (classResultSet.next()) {