|
@@ -10,6 +10,7 @@ import com.alibaba.druid.pool.DruidDataSource;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
import com.fdkankan.common.constant.CommonOperStatus;
|
|
import com.fdkankan.common.constant.CommonOperStatus;
|
|
import com.fdkankan.common.util.DateExtUtil;
|
|
import com.fdkankan.common.util.DateExtUtil;
|
|
|
|
+import com.fdkankan.dingtalk.DingTalkSendUtils;
|
|
import com.fdkankan.job.entity.SceneBuildProcessLog;
|
|
import com.fdkankan.job.entity.SceneBuildProcessLog;
|
|
import com.fdkankan.job.entity.ScenePlus;
|
|
import com.fdkankan.job.entity.ScenePlus;
|
|
import com.fdkankan.job.entity.ScenePro;
|
|
import com.fdkankan.job.entity.ScenePro;
|
|
@@ -18,6 +19,7 @@ import com.fdkankan.job.service.ISceneBuildProcessLogService;
|
|
import com.fdkankan.job.service.IScenePlusService;
|
|
import com.fdkankan.job.service.IScenePlusService;
|
|
import com.fdkankan.job.service.ISceneProService;
|
|
import com.fdkankan.job.service.ISceneProService;
|
|
import com.fdkankan.model.constants.SceneBuildProcessType;
|
|
import com.fdkankan.model.constants.SceneBuildProcessType;
|
|
|
|
+import com.taobao.api.ApiException;
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
import com.xxl.job.core.context.XxlJobHelper;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -26,6 +28,9 @@ import org.springframework.stereotype.Component;
|
|
|
|
|
|
import javax.sql.DataSource;
|
|
import javax.sql.DataSource;
|
|
import java.io.File;
|
|
import java.io.File;
|
|
|
|
+import java.io.UnsupportedEncodingException;
|
|
|
|
+import java.security.InvalidKeyException;
|
|
|
|
+import java.security.NoSuchAlgorithmException;
|
|
import java.sql.SQLException;
|
|
import java.sql.SQLException;
|
|
import java.util.Calendar;
|
|
import java.util.Calendar;
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
@@ -51,6 +56,8 @@ public class SceneCallCountHandler {
|
|
private ISceneProService sceneProService;
|
|
private ISceneProService sceneProService;
|
|
@Autowired
|
|
@Autowired
|
|
private ISceneBuildProcessLogService sceneBuildProcessLogService;
|
|
private ISceneBuildProcessLogService sceneBuildProcessLogService;
|
|
|
|
+ @Autowired
|
|
|
|
+ private DingTalkSendUtils dingTalkSendUtils;
|
|
|
|
|
|
public static final String DINGTALK_MSG_PATTERN =
|
|
public static final String DINGTALK_MSG_PATTERN =
|
|
"**日期**: %s\n\n" +
|
|
"**日期**: %s\n\n" +
|
|
@@ -60,7 +67,7 @@ public class SceneCallCountHandler {
|
|
"**错误日志**: %s";
|
|
"**错误日志**: %s";
|
|
|
|
|
|
@XxlJob("sceneCallCountHandler")
|
|
@XxlJob("sceneCallCountHandler")
|
|
- private void repairSceneUpXmlUrlOfVideos() throws SQLException {
|
|
|
|
|
|
+ private void repairSceneUpXmlUrlOfVideos() throws SQLException, NoSuchAlgorithmException, ApiException, InvalidKeyException, UnsupportedEncodingException {
|
|
XxlJobHelper.log("sceneCallCountHandler start.....");
|
|
XxlJobHelper.log("sceneCallCountHandler start.....");
|
|
|
|
|
|
Date time = Calendar.getInstance().getTime();
|
|
Date time = Calendar.getInstance().getTime();
|
|
@@ -113,7 +120,8 @@ public class SceneCallCountHandler {
|
|
v3Msg,
|
|
v3Msg,
|
|
errorMsg);
|
|
errorMsg);
|
|
|
|
|
|
- XxlJobHelper.log(ddMsg);
|
|
|
|
|
|
+// XxlJobHelper.log(ddMsg);
|
|
|
|
+ dingTalkSendUtils.sendActioncardMsgToDingRobot(ddMsg, "场景计算统计");
|
|
XxlJobHelper.log("sceneCallCountHandler end.....");
|
|
XxlJobHelper.log("sceneCallCountHandler end.....");
|
|
}
|
|
}
|
|
|
|
|