Merge branch 'dev-xym-update1' of Server/we-com-manage into master

we-com-server/src/main/java/com/tzld/piaoquan/wecom/common/constant/MessageConstant.java

@@ -8,6 +8,8 @@ public interface MessageConstant {
     //推送保底内容
     String guaranteedText = "- 晚上好！愿这宁静的夜晚带给你心灵的放松与安宁，以下是大家都在看的爆款视频！";
 
+    String morningText = "早安，新的一天，愿你拥有最好的心情去迎接一切美好！爆款视频抢先观看，点击下方精彩不断～";
+
     //小程序id
     String appid = "wx7187c217efef24a7";
 

we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComHistoryDataJob.java

@@ -123,6 +123,7 @@ public class WeComHistoryDataJob {
         for (Staff staff : staffList) {
             SendDetail sendDetail = new SendDetail();
             sendDetail.setRemark(staff.getRemark());
+            sendDetail.setStaffId(staff.getId());
             List<Long> countList = new ArrayList<>();
             for (Integer status : statusList) {
                 HistoryMessageExample example = new HistoryMessageExample();
@@ -149,6 +150,13 @@ public class WeComHistoryDataJob {
             Long notSentCount = sendCountList.get(0);
             if (notSentCount != 0) {
                 LarkRobotUtil.sendMessage("@薛一鸣 存在未发送记录，请检查");
+                if (sendDetail.getStaffId() == 3) {
+                    LarkRobotUtil.sendTipMessage("@王钧灏 存在未发送记录，请检查");
+                } else if (sendDetail.getStaffId() == 4) {
+                    LarkRobotUtil.sendTipMessage("@刘坤宇 存在未发送记录，请检查");
+                } else {
+                    LarkRobotUtil.sendTipMessage("@孟庆红 存在未发送记录，请检查");
+                }
             }
             stringBuilder.append("总发送数量：").append(count).append("   ");
             stringBuilder.append("未发送数量：").append(sendCountList.get(0)).append("   ");
@@ -158,6 +166,7 @@ public class WeComHistoryDataJob {
             stringBuilder.append("\n");
         }
         LarkRobotUtil.sendMessage(stringBuilder.toString());
+        LarkRobotUtil.sendTipMessage(stringBuilder.toString());
     }
 
     private void selectGroupMsgList(Long startTime, Long endTime, Long corpId, Long staffId) {

we-com-server/src/main/java/com/tzld/piaoquan/wecom/job/WeComMessageDataJob.java

@@ -79,7 +79,7 @@ public class WeComMessageDataJob {
     Map<String, String> pageMap = new HashMap<>();
 
     //初始化操作
-    private void init() {
+    private void init(List<Long> staffIds) {
         //历史优质视频获取
         String sql = String.format("SELECT * FROM loghubods.history_good_video_can_push_user_list where dt = %s;",
                 DateUtil.getBeforeDayDateString());
@@ -126,7 +126,12 @@ public class WeComMessageDataJob {
         for (VideoParam videoParam : guaranteedParam.getVideoParamList()) {
             if (videoParam.getStaffId() == null) {
                 LarkRobotUtil.sendMessage("保底视频获取异常，StaffId为空" + DateUtil.getThatDayDateString());
-                throw new RuntimeException();
+                continue;
+            }
+            if (videoParam.getStaffId() != 0) {
+                if (!CollectionUtils.isEmpty(staffIds) && !staffIds.contains(videoParam.getStaffId())) {
+                    continue;
+                }
             }
             //默认组视频不做查询
             if (videoParam.getStaffId() == 0L) {
@@ -146,13 +151,12 @@ public class WeComMessageDataJob {
                 List<MessageAttachment> messageAttachmentList = messageAttachmentMapper.selectByExample(example);
                 if (CollectionUtils.isEmpty(messageAttachmentList)) {
                     LarkRobotUtil.sendMessage("保底视频不存在，请查看videoId=" + videoId);
-                    throw new RuntimeException();
+                    continue;
                 }
                 MessageAttachment messageAttachment = messageAttachmentList.get(0);
                 if (messageAttachment.getSendTime() != null
-                        && DateUtil.dateDifference(new Date(), messageAttachment.getSendTime()) < 180 * MILLISECOND_DAY) {
+                        && DateUtil.dateDifference(new Date(), messageAttachment.getSendTime()) < 90 * MILLISECOND_DAY) {
                     LarkRobotUtil.sendMessage("保底视频半年内已发送，请查看videoId=" + videoId);
-                    throw new RuntimeException();
                 }
             }
             //重新组合视频id
@@ -197,7 +201,6 @@ public class WeComMessageDataJob {
         if (StringUtils.isNotEmpty(param)) {
             xxlJobParam = JSONObject.parseObject(param, XxlJobParam.class);
         }
-        init();
         CorpExample corpExample = new CorpExample();
         if (xxlJobParam.getCorpId() != null) {
             corpExample.createCriteria().andIdEqualTo(xxlJobParam.getCorpId());
@@ -206,11 +209,15 @@ public class WeComMessageDataJob {
         if (CollectionUtils.isEmpty(corps)) {
             return ReturnT.SUCCESS;
         }
+        List<Long> staffIds = new ArrayList<>();
+        if (xxlJobParam.getStaffId() != null) {
+            staffIds.add(xxlJobParam.getStaffId());
+        }
+        if (!CollectionUtils.isEmpty(xxlJobParam.getStaffIds())) {
+            staffIds.addAll(xxlJobParam.getStaffIds());
+        }
+        init(staffIds);
         for (Corp corp : corps) {
-            Long staffId = null;
-            if (xxlJobParam.getStaffId() != null) {
-                staffId = xxlJobParam.getStaffId();
-            }
             UserExample userExample = new UserExample();
             userExample.createCriteria().andExternalUserIdIsNotNull().andCorpIdEqualTo(corp.getId());
             if (xxlJobParam.getUserId() != null) {
@@ -229,7 +236,7 @@ public class WeComMessageDataJob {
                 //落库逻辑
                 List<SendMessage> allSeneMessageList = new ArrayList<>();
                 for (User user : userList) {
-                    List<SendMessage> sendMessageList = getSendMessage(user, staffId, corp.getId());
+                    List<SendMessage> sendMessageList = getSendMessage(user, staffIds, corp.getId());
                     if (CollectionUtils.isEmpty(sendMessageList)) {
                         continue;
                     }
@@ -241,40 +248,54 @@ public class WeComMessageDataJob {
                 sendMessageMapper.insertList(allSeneMessageList);
             }
         }
-        //组装好当天要发送的消息后  记录时间  删除保底数据
-        saveGuaranteedVideoIdList();
+        //组装好当天要发送的消息后  记录时间
+        saveGuaranteedVideoIdList(staffIds);
         return ReturnT.SUCCESS;
     }
 
-    private void saveGuaranteedVideoIdList() {
+    private void saveGuaranteedVideoIdList(List<Long> staffIds) {
         String key = String.format(GUARANTEED_MINI_PROGRAM_KEY, DateUtil.getThatDayDateString());
         GuaranteedParam guaranteedParam = (GuaranteedParam) redisTemplate.opsForValue().get(key);
         if (guaranteedParam == null || CollectionUtils.isEmpty(guaranteedParam.getVideoParamList())) {
             return;
         }
-        Set<Long> videoIdSet = new HashSet<>();
-        for (VideoParam videoParam : guaranteedParam.getVideoParamList()) {
-            if (CollectionUtils.isEmpty(videoParam.getVideoIds())) {
-                continue;
+        if (CollectionUtils.isEmpty(staffIds)) {
+            Set<Long> videoIdSet = new HashSet<>();
+            for (VideoParam videoParam : guaranteedParam.getVideoParamList()) {
+                if (CollectionUtils.isEmpty(videoParam.getVideoIds())) {
+                    continue;
+                }
+                videoIdSet.addAll(videoParam.getVideoIds());
             }
-            videoIdSet.addAll(videoParam.getVideoIds());
-        }
-        List<Long> videoIdList = new ArrayList<>(videoIdSet);
-        MessageAttachmentExample example = new MessageAttachmentExample();
-        example.createCriteria().andMiniprogramVideoIdIn(videoIdList);
-        MessageAttachment updateMessageAttachment = new MessageAttachment();
-        updateMessageAttachment.setSendTime(new Date());
-        messageAttachmentMapper.updateByExampleSelective(updateMessageAttachment, example);
-        redisTemplate.delete(key);
+            List<Long> videoIdList = new ArrayList<>(videoIdSet);
+            MessageAttachmentExample example = new MessageAttachmentExample();
+            example.createCriteria().andMiniprogramVideoIdIn(videoIdList).andSendTimeIsNull();
+            MessageAttachment updateMessageAttachment = new MessageAttachment();
+            updateMessageAttachment.setSendTime(new Date());
+            messageAttachmentMapper.updateByExampleSelective(updateMessageAttachment, example);
+        } else {
+            for (VideoParam videoParam : guaranteedParam.getVideoParamList()) {
+                if (!CollectionUtils.isEmpty(staffIds) && staffIds.contains(videoParam.getStaffId())) {
+                    if (CollectionUtils.isEmpty(videoParam.getVideoIds())) {
+                        continue;
+                    }
+                    MessageAttachmentExample example = new MessageAttachmentExample();
+                    example.createCriteria().andMiniprogramVideoIdIn(videoParam.getVideoIds()).andStaffIdEqualTo(videoParam.getStaffId());
+                    MessageAttachment updateMessageAttachment = new MessageAttachment();
+                    updateMessageAttachment.setSendTime(new Date());
+                    messageAttachmentMapper.updateByExampleSelective(updateMessageAttachment, example);
+                }
+            }
+        }
     }
 
-    private List<SendMessage> getSendMessage(User user, Long staffId, Long corpId) {
+    private List<SendMessage> getSendMessage(User user, List<Long> staffIds, Long corpId) {
         StaffWithUserExample example = new StaffWithUserExample();
         StaffWithUserExample.Criteria criteria = example.createCriteria();
         criteria.andUserIdEqualTo(user.getId());
         criteria.andIsDeleteEqualTo(0);
-        if (staffId != null) {
-            criteria.andStaffIdEqualTo(staffId);
+        if (!CollectionUtils.isEmpty(staffIds)) {
+            criteria.andStaffIdIn(staffIds);
         }
         List<StaffWithUser> staffWithUserList = staffWithUserMapper.selectByExample(example);
         if (CollectionUtils.isEmpty(staffWithUserList)) {
@@ -406,27 +427,51 @@ public class WeComMessageDataJob {
             return ReturnT.SUCCESS;
         }
         for (SendMessage sendMessage : groupList) {
-            sendMessage.setIsSend(0);
-            sendMessage.setCreateTime(DateUtil.getThatDayDate());
-            List<String> sendUserList = sendMessageMapper.selectExternalUserId(sendMessage);
-            boolean flag = pushMessage(sendUserList, sendMessage);
-            if (flag) {
-                SendMessage updateSendMessage = new SendMessage();
-                updateSendMessage.setIsSend(1);
-                SendMessageExample example = new SendMessageExample();
-                example.createCriteria()
-                        .andVideoId1EqualTo(sendMessage.getVideoId1())
-                        .andVideoId2EqualTo(sendMessage.getVideoId2())
-                        .andVideoId3EqualTo(sendMessage.getVideoId3())
-                        .andStaffIdEqualTo(sendMessage.getStaffId())
-                        .andCreateTimeGreaterThan(DateUtil.getThatDayDate());
-                sendMessageMapper.updateByExampleSelective(updateSendMessage, example);
+            pushAndUpdateMessage(sendMessage);
+        }
+        Map<Long, List<SendMessage>> groupedByStaffId = groupList.stream().collect(Collectors.groupingBy(SendMessage::getStaffId));
+        for (Map.Entry<Long, List<SendMessage>> entry : groupedByStaffId.entrySet()) {
+            SendMessageExample example = new SendMessageExample();
+            example.createCriteria().andStaffIdEqualTo(entry.getKey()).andIsSendEqualTo(0)
+                    .andCreateTimeGreaterThan(DateUtil.getThatDayDate());
+            long l = sendMessageMapper.countByExample(example);
+            //增加重试
+            if (l > 0) {
+                List<SendMessage> retryGroupList = sendMessageMapper.getGroupList(DateUtil.getThatDayDate(), 0);
+                retryGroupList = retryGroupList.stream().filter(e -> Objects.equals(e.getStaffId(), entry.getKey()))
+                        .collect(Collectors.toList());
+                for (SendMessage sendMessage : retryGroupList) {
+                    pushAndUpdateMessage(sendMessage);
+                }
             }
-
+        }
+        SendMessageExample example = new SendMessageExample();
+        example.createCriteria().andIsSendEqualTo(0).andCreateTimeGreaterThan(DateUtil.getThatDayDate());
+        long l = sendMessageMapper.countByExample(example);
+        if (l > 0) {
+            LarkRobotUtil.sendMessage("存在发送失败消息，请检查@薛一鸣");
         }
         return ReturnT.SUCCESS;
     }
 
+    private void pushAndUpdateMessage(SendMessage sendMessage) {
+        sendMessage.setIsSend(0);
+        sendMessage.setCreateTime(DateUtil.getThatDayDate());
+        List<String> sendUserList = sendMessageMapper.selectExternalUserId(sendMessage);
+        boolean flag = pushMessage(sendUserList, sendMessage);
+        if (flag) {
+            SendMessage updateSendMessage = new SendMessage();
+            updateSendMessage.setIsSend(1);
+            SendMessageExample example = new SendMessageExample();
+            example.createCriteria()
+                    .andVideoId1EqualTo(sendMessage.getVideoId1())
+                    .andVideoId2EqualTo(sendMessage.getVideoId2())
+                    .andVideoId3EqualTo(sendMessage.getVideoId3())
+                    .andStaffIdEqualTo(sendMessage.getStaffId())
+                    .andCreateTimeGreaterThan(DateUtil.getThatDayDate());
+            sendMessageMapper.updateByExampleSelective(updateSendMessage, example);
+        }
+    }
 
     private boolean pushMessage(List<String> sendUserList, SendMessage sendMessage) {
         List<JSONObject> pushList = new ArrayList<>();
@@ -453,7 +498,8 @@ public class WeComMessageDataJob {
             example.createCriteria().andMiniprogramVideoIdEqualTo(videoId);
             List<MessageAttachment> messageAttachmentList = messageAttachmentMapper.selectByExample(example);
             if (CollectionUtils.isEmpty(messageAttachmentList)) {
-                throw new RuntimeException("附件信息查询异常");
+                log.error("附件信息查询异常");
+                return false;
             }
             MessageAttachment messageAttachment = messageAttachmentList.get(0);
             JSONObject miniprogram = new JSONObject();
@@ -508,4 +554,17 @@ public class WeComMessageDataJob {
     }
 
 
+    @XxlJob("existGuaranteesJob")
+    public ReturnT<String> existGuarantees(String param) {
+        //保底视频获取
+        String key = String.format(GUARANTEED_MINI_PROGRAM_KEY, DateUtil.getNextDayDateString());
+        GuaranteedParam guaranteedParam = (GuaranteedParam) redisTemplate.opsForValue().get(key);
+        if (guaranteedParam == null
+                || CollectionUtils.isEmpty(guaranteedParam.getVideoParamList())) {
+            LarkRobotUtil.sendMessage("保底视频异常，请检查" + DateUtil.getNextDayDateString());
+        }
+        return ReturnT.SUCCESS;
+    }
+
+
 }

we-com-server/src/main/java/com/tzld/piaoquan/wecom/model/bo/SendDetail.java

@@ -7,6 +7,8 @@ import java.util.List;
 @Data
 public class SendDetail {
 
+    private Long staffId;
+
     private String remark;
 
     private List<Long> sendCountList;

we-com-server/src/main/java/com/tzld/piaoquan/wecom/model/bo/XxlJobParam.java

@@ -1,8 +1,12 @@
 package com.tzld.piaoquan.wecom.model.bo;
 
 import lombok.Data;
+import lombok.ToString;
+
+import java.util.List;
 
 @Data
+@ToString
 public class XxlJobParam {
 
     private Long corpId;
@@ -13,5 +17,7 @@ public class XxlJobParam {
 
     private Long staffId;
 
+    private List<Long> staffIds;
+
     private Long userId;
 }

we-com-server/src/main/java/com/tzld/piaoquan/wecom/service/Impl/MessageAttachmentServiceImpl.java

@@ -42,6 +42,7 @@ import static com.tzld.piaoquan.wecom.common.constant.MessageConstant.appid;
 import static com.tzld.piaoquan.wecom.common.constant.OtherServerURL.POST_ADD_TENCENT;
 import static com.tzld.piaoquan.wecom.common.constant.OtherServerURL.POST_VIDEO_DETAIL_URL;
 import static com.tzld.piaoquan.wecom.common.constant.RedisConstant.GUARANTEED_MINI_PROGRAM_KEY;
+import static com.tzld.piaoquan.wecom.common.constant.TimeConstant.MILLISECOND_DAY;
 import static com.tzld.piaoquan.wecom.common.constant.WeComConstant.POST_WE_COM_MEDIA_UPLOAD;
 
 
@@ -95,6 +96,20 @@ public class MessageAttachmentServiceImpl implements MessageAttachmentService {
             if (CollectionUtils.isEmpty(videoParam.getVideoIds()) || videoParam.getVideoIds().size() < MAX_VIDEO_NUM) {
                 LarkRobotUtil.sendMessage("保底视频数量异常，请查看" + guaranteedParam.getDate());
             }
+            for (Long videoId : videoParam.getVideoIds()) {
+                MessageAttachmentExample example = new MessageAttachmentExample();
+                example.createCriteria().andMiniprogramVideoIdEqualTo(videoId).andStaffIdEqualTo(videoParam.getStaffId());
+                List<MessageAttachment> messageAttachmentList = messageAttachmentMapper.selectByExample(example);
+                if (CollectionUtils.isEmpty(messageAttachmentList)) {
+                    continue;
+                }
+                MessageAttachment messageAttachment = messageAttachmentList.get(0);
+                if (messageAttachment.getSendTime() != null
+                        && DateUtil.dateDifference(new Date(), messageAttachment.getSendTime()) < 90 * MILLISECOND_DAY) {
+                    LarkRobotUtil.sendMessage("保底视频半年内已发送，请查看videoId=" + videoId);
+                    return CommonResponse.create(500, "保底视频半年内已发送，请查看videoId=" + videoId);
+                }
+            }
             videoIds.addAll(videoParam.getVideoIds());
         }
         Map<Long, VideoDetail> coverMap = getVideoDetail(videoIds);
@@ -133,7 +148,7 @@ public class MessageAttachmentServiceImpl implements MessageAttachmentService {
         addMiniProgram(messageAttachmentList, null);
         String date = guaranteedParam.getDate();
         String key = String.format(GUARANTEED_MINI_PROGRAM_KEY, date);
-        redisTemplate.opsForValue().set(key, guaranteedParam);
+        redisTemplate.opsForValue().set(key, guaranteedParam, 14, TimeUnit.DAYS);
         return CommonResponse.success();
     }
 

we-com-server/src/main/java/com/tzld/piaoquan/wecom/service/Impl/MessageServiceImpl.java

@@ -7,6 +7,7 @@ import com.tzld.piaoquan.wecom.component.HttpPoolClient;
 import com.tzld.piaoquan.wecom.model.vo.MessageTextParam;
 import com.tzld.piaoquan.wecom.service.AccessTokenService;
 import com.tzld.piaoquan.wecom.service.MessageService;
+import com.tzld.piaoquan.wecom.utils.DateUtil;
 import com.tzld.piaoquan.wecom.utils.HttpClientUtil;
 import com.tzld.piaoquan.wecom.utils.LarkRobotUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -70,12 +71,14 @@ public class MessageServiceImpl implements MessageService {
     }
 
 
+
     @Override
     public String getMessageText() {
-        String text = (String) redisTemplate.opsForValue().get(PUSH_MESSAGE_TEXT);
-        if (StringUtils.isEmpty(text)) {
+        Integer hour = DateUtil.getHourOfDay();
+        if (hour < 12) {
+            return MessageConstant.morningText;
+        } else {
             return MessageConstant.guaranteedText;
         }
-        return text;
     }
 }

we-com-server/src/main/java/com/tzld/piaoquan/wecom/utils/DateUtil.java

@@ -1,10 +1,7 @@
 package com.tzld.piaoquan.wecom.utils;
 
 
-import java.time.Instant;
-import java.time.LocalDate;
-import java.time.LocalDateTime;
-import java.time.ZoneId;
+import java.time.*;
 import java.time.format.DateTimeFormatter;
 import java.util.Calendar;
 import java.util.Date;
@@ -34,6 +31,12 @@ public class DateUtil {
         return dateFormat.format(today);
     }
 
+    public static String getNextDayDateString() {
+        DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        LocalDate tomorrow = LocalDate.now().minusDays(-1);
+        return dateFormat.format(tomorrow);
+    }
+
 
     public static String getDayDateString(String pattern) {
         DateTimeFormatter dateFormat = DateTimeFormatter.ofPattern(pattern);
@@ -54,5 +57,9 @@ public class DateUtil {
         return Math.abs(date1.getTime() - date2.getTime());
     }
 
+    public static Integer getHourOfDay() {
+       Calendar calendar = Calendar.getInstance();
+        return calendar.get(Calendar.HOUR_OF_DAY);
+    }
 
 }

we-com-server/src/main/java/com/tzld/piaoquan/wecom/utils/LarkRobotUtil.java

@@ -17,6 +17,8 @@ public class LarkRobotUtil {
 
     private static final String URL = "https://open.feishu.cn/open-apis/bot/v2/hook/93787b70-33d3-42c1-beae-c09310c9b38b";
 
+    private static final String TIP_URL = "https://open.feishu.cn/open-apis/bot/v2/hook/0eb8793a-5bb3-43d7-aa74-fed1c91e3d9b";
+
     private static final HttpPoolClientUtil HTTP_POOL_CLIENT_UTIL_DEFAULT = HttpClientUtil.create(3000, 10000, 20, 100, 3, 3000);
 
 
@@ -41,6 +43,23 @@ public class LarkRobotUtil {
         }
     }
 
+    public static void sendTipMessage(String msg) {
+        sendTipMessage("text", "企微推送结果：" + msg);
+    }
+
+    public static void sendTipMessage(String type, String msg) {
+        try {
+            JSONObject param = new JSONObject();
+            param.put("msg_type", type);
+            JSONObject content = new JSONObject();
+            content.put("text", msg);
+            param.put("content", content);
+            HTTP_POOL_CLIENT_UTIL_DEFAULT.post(TIP_URL, param.toJSONString());
+        } catch (Exception e) {
+            log.error("Lark sendMessage error", e);
+        }
+    }
+
     private static String getSign(long timestamp) throws NoSuchAlgorithmException, InvalidKeyException {
         //把timestamp+"\n"+密钥当做签名字符串
         String stringToSign = timestamp + "\n" + SECRET;

we-com-server/src/main/resources/application-prod.properties

@@ -2,8 +2,7 @@ spring.datasource.username=crawler
 spring.datasource.password=crawler123456@
 spring.datasource.url=jdbc:mysql://rm-bp17q95335a99272b.mysql.rds.aliyuncs.com:3306/growth?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowMultiQueries=true
 
-spring.redis.database=2
-spring.redis.host=r-bp154bpw97gptefiqkpd.redis.rds.aliyuncs.com
+spring.redis.host=r-bp1m4nvh130sfjjc6f.redis.rds.aliyuncs.com
 spring.redis.port=6379
 spring.redis.password=Qingqu2019
 

we-com-server/src/main/resources/application-test.properties

@@ -4,8 +4,7 @@ spring.datasource.username=crawler
 spring.datasource.password=crawler123456@
 spring.datasource.url=jdbc:mysql://rm-bp1k5853td1r25g3n690.mysql.rds.aliyuncs.com:3306/piaoquan-crawler?useUnicode=true&characterEncoding=utf-8&zeroDateTimeBehavior=convertToNull&useSSL=false&allowMultiQueries=true
 
-spring.redis.database=2
-spring.redis.host=r-bp154bpw97gptefiqkpd.redis.rds.aliyuncs.com
+spring.redis.host=r-bp1m4nvh130sfjjc6fpd.redis.rds.aliyuncs.com
 spring.redis.port=6379
 spring.redis.password=Qingqu2019
 

we-com-server/src/main/resources/mybatis-generator-config.xml

@@ -27,7 +27,7 @@
         </commentGenerator>
 
         <jdbcConnection driverClass="com.mysql.jdbc.Driver"
-                        connectionURL="jdbc:mysql://rm-bp1159bu17li9hi94.mysql.rds.aliyuncs.com:3306/piaoquan-crawler?useUnicode=true&amp;characterEncoding=utf-8&amp;zeroDateTimeBehavior=convertToNull&amp;useSSL=false"
+                        connectionURL="jdbc:mysql://rm-bp17q95335a99272b.mysql.rds.aliyuncs.com:3306/growth?useUnicode=true&amp;characterEncoding=utf-8&amp;zeroDateTimeBehavior=convertToNull&amp;useSSL=false"
                         userId="crawler" password="crawler123456@">
         </jdbcConnection>