From 85d8efdb96a9b4900dbceef524a29690e13b7800 Mon Sep 17 00:00:00 2001
From: zhibing.pu <393733352@qq.com>
Date: 星期五, 28 六月 2024 09:39:06 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
MinistryOfTransport/src/main/java/com/sinata/ministryoftransport/util/TaskUtil.java | 112 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 112 insertions(+), 0 deletions(-)
diff --git a/MinistryOfTransport/src/main/java/com/sinata/ministryoftransport/util/TaskUtil.java b/MinistryOfTransport/src/main/java/com/sinata/ministryoftransport/util/TaskUtil.java
new file mode 100644
index 0000000..b25e658
--- /dev/null
+++ b/MinistryOfTransport/src/main/java/com/sinata/ministryoftransport/util/TaskUtil.java
@@ -0,0 +1,112 @@
+package com.sinata.ministryoftransport.util;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.aliyuncs.exceptions.ClientException;
+import com.sinata.ministryoftransport.server.IMinistryOfTransportService;
+import com.sinata.ministryoftransport.util.httpClinet.HttpResult;
+import com.sun.org.apache.bcel.internal.generic.FADD;
+import org.apache.http.HttpEntity;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.impl.conn.PoolingHttpClientConnectionManager;
+import org.apache.http.util.EntityUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
+
+
+/**
+ * 定时任务工具类
+ */
+@Component
+public class TaskUtil {
+
+ @Autowired
+ private ALiSendSms aLiSendSms;
+
+ private boolean push = false;
+
+ @Autowired
+ private IMinistryOfTransportService ministryOfTransportService;
+
+ private Integer counter = 0;
+
+
+
+ /**
+ * 每隔一分钟去处理的定时任务
+ */
+ @Scheduled(fixedRate = 1000 * 60)
+ public void taskMinute(){
+ try {
+ String baseInfoCompany = "{\"CompanyName\":\"昭通市睿邦科技有限公司\",\"Identifier\":\"91530600MA6K70Q50D\",\"Address\":530602,\"BusinessScope\":\"网络预约出租汽车客运\"," +
+ "\"ContactAddress\":\"云南省昭通市昭阳区龙泉路501号\",\"EconomicType\":\"150\",\"RegCapital\":\"一千万元\",\"LegalName\":\"虎尊国\",\"LegalID\":\"53210119760928201X\"," +
+ "\"LegalPhone\":\"13118708883\",\"State\":0,\"Flag\":2,\"UpdateTime\":\"" +System.currentTimeMillis() + "\"}";
+ String result = ministryOfTransportService.baseInfoCompany(baseInfoCompany);
+ HttpResult httpResult = JSON.parseObject(result, HttpResult.class);
+ if(httpResult.getCode() == 200 || httpResult.getCode() == 201){
+ counter = 0;
+ }
+ if(null == httpResult){
+ sendSms();
+ System.err.println("请求接口出错！");
+ return;
+ }
+ } catch (Exception e) {
+ sendSms();
+ e.printStackTrace();
+ }
+ }
+
+
+ /**
+ * 每天的1点执行的任务
+ */
+// @Scheduled(cron = "0 0 1 * * *")
+// public void taskDay(){
+// try {
+//
+// }catch (Exception e){
+// e.printStackTrace();
+// }
+// }
+
+
+
+ /**
+ * 每月第一天的1点执行的任务
+ */
+// @Scheduled(cron = "0 0 1 1 * *")
+// public void taskMonth(){
+// try {
+// }catch (Exception e){
+// e.printStackTrace();
+// }
+// }
+
+
+
+
+ /**
+ * 触发发送短信提醒
+ */
+ public void sendSms(){
+ counter++;
+ if(counter == 3){
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String time = sdf.format(new Date());
+ try {
+ aLiSendSms.sendSms("15907727138", "SMS_210780079", "{\"phone\":\"15907727138\",\"time\":\"" + time + "\"}");
+ } catch (ClientException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+}
--
Gitblit v1.7.1