liupeng 4 rokov pred
rodič
commit
03f65e8ecc

+ 12 - 5
code/sapparent/sapservice/src/main/java/org/fouram/job/CheckTaskSchedule.java

@@ -1,7 +1,9 @@
 package org.fouram.job;
 
+import org.fouram.core.plugin.weixin.cp.util.WXCpMessageUtil;
 import org.fouram.core.util.DateUtil;
 import org.fouram.core.util.LoggerUtil;
+import org.fouram.core.util.Tools;
 import org.fouram.service.SapCheckdateService;
 import org.fouram.service.SapEmployeeTimeService;
 import org.fouram.service.SapUserService;
@@ -37,11 +39,16 @@ public class CheckTaskSchedule {
 
 	public void taskBiz() throws Exception {
 		LoggerUtil.info(DateUtil.getTime());
-		if (DateUtil.getHour().equals("10") || DateUtil.getHour().equals("12") || DateUtil.getHour().equals("20")
-				|| DateUtil.getHour().equals("23")) {
-			LoggerUtil.info("执行开始:" + DateUtil.getTime());
-			executeBiz(DateUtil.getDay(), DateUtil.getHour());
-			LoggerUtil.info("执行结束:" + DateUtil.getTime());
+		try {
+			if (DateUtil.getHour().equals("10") || DateUtil.getHour().equals("12") || DateUtil.getHour().equals("20")
+					|| DateUtil.getHour().equals("23")) {
+				LoggerUtil.info("执行开始:" + DateUtil.getTime());
+				executeBiz(DateUtil.getDay(), DateUtil.getHour());
+				LoggerUtil.info("执行结束:" + DateUtil.getTime());
+			}
+		} catch (Exception e) {
+			WXCpMessageUtil.sendAdminError(Tools.getExceptionAllInfo(e));
+			LoggerUtil.error(e);
 		}
 	}
 

+ 33 - 28
code/sapparent/sapservice/src/main/java/org/fouram/job/MessageSchedule.java

@@ -2,6 +2,9 @@ package org.fouram.job;
 
 import java.util.List;
 
+import org.fouram.core.plugin.weixin.cp.util.WXCpMessageUtil;
+import org.fouram.core.util.LoggerUtil;
+import org.fouram.core.util.Tools;
 import org.fouram.entity.SapMessageUser;
 import org.fouram.entity.SapUser;
 import org.fouram.service.SapMessageUserService;
@@ -18,34 +21,36 @@ public class MessageSchedule {
 	private SapMessageUserService sapMessageUserService;
 
 	public void taskBiz() throws Exception {
-		
-		System.out.println(1/0);
-		
-		List<SapMessageUser> messageUsers = sapMessageUserService.selectList(null);
-		if (messageUsers.isEmpty()) {
-			return;
-		}
-		// 入职
-		List<SapUser> sapUsers = sapUserService.selectNotSendEntryMessageList();
-		StringBuffer messageContent = null;
-		for (SapUser sapUser : sapUsers) {
-			messageContent = new StringBuffer();
-			messageContent.append("有一个新员工入职,待同步企业微信").append("\n").append("员工姓名:").append(sapUser.getName())
-					.append("\n").append("手机号:").append(sapUser.getFormatMobile()).append("\n").append("邮箱:")
-					.append(sapUser.getRealEmail()).append("\n")
-					.append("<a href=\"https://studybom.suggest.vip/#/userSync/list\">立即同步</a>");
-			sapUserService.sendEntryMessage(messageContent.toString(), sapUser, messageUsers);
-		}
-		// 离职
-		sapUsers = sapUserService.selectNotSendLeaveMessageList();
-		messageContent = null;
-		for (SapUser sapUser : sapUsers) {
-			messageContent = new StringBuffer();
-			messageContent.append("有一个新员工离职,待同步企业微信").append("\n").append("员工姓名:").append(sapUser.getName())
-					.append("\n").append("手机号:").append(sapUser.getFormatMobile()).append("\n").append("邮箱:")
-					.append(sapUser.getRealEmail()).append("\n")
-					.append("<a href=\"https://studybom.suggest.vip/#/userSync/list\">立即同步</a>");
-			sapUserService.sendLeaveMessage(messageContent.toString(), sapUser, messageUsers);
+		try {
+			List<SapMessageUser> messageUsers = sapMessageUserService.selectList(null);
+			if (messageUsers.isEmpty()) {
+				return;
+			}
+			// 入职
+			List<SapUser> sapUsers = sapUserService.selectNotSendEntryMessageList();
+			StringBuffer messageContent = null;
+			for (SapUser sapUser : sapUsers) {
+				messageContent = new StringBuffer();
+				messageContent.append("有一个新员工入职,待同步企业微信").append("\n").append("员工姓名:").append(sapUser.getName())
+						.append("\n").append("手机号:").append(sapUser.getFormatMobile()).append("\n").append("邮箱:")
+						.append(sapUser.getRealEmail()).append("\n")
+						.append("<a href=\"https://studybom.suggest.vip/#/userSync/list\">立即同步</a>");
+				sapUserService.sendEntryMessage(messageContent.toString(), sapUser, messageUsers);
+			}
+			// 离职
+			sapUsers = sapUserService.selectNotSendLeaveMessageList();
+			messageContent = null;
+			for (SapUser sapUser : sapUsers) {
+				messageContent = new StringBuffer();
+				messageContent.append("有一个新员工离职,待同步企业微信").append("\n").append("员工姓名:").append(sapUser.getName())
+						.append("\n").append("手机号:").append(sapUser.getFormatMobile()).append("\n").append("邮箱:")
+						.append(sapUser.getRealEmail()).append("\n")
+						.append("<a href=\"https://studybom.suggest.vip/#/userSync/list\">立即同步</a>");
+				sapUserService.sendLeaveMessage(messageContent.toString(), sapUser, messageUsers);
+			}
+		} catch (Exception e) {
+			WXCpMessageUtil.sendAdminError(Tools.getExceptionAllInfo(e));
+			LoggerUtil.error(e);
 		}
 	}
 }

+ 1 - 0
code/sapparent/sapservice/src/main/java/org/fouram/service/SapUserService.java

@@ -464,6 +464,7 @@ public class SapUserService extends BaseService {
 			try {
 				this.updateSyncWxResult(sapUser.getPersonId());
 			} catch (Exception e) {
+				WXCpMessageUtil.sendAdminError(Tools.getExceptionAllInfo(e));
 				LoggerUtil.error(e);
 			}
 		}

+ 3 - 0
code/sapparent/sapservice/src/main/java/org/fouram/service/SyncSapUserToWxService.java

@@ -5,8 +5,10 @@ import java.util.concurrent.Executors;
 
 import org.fouram.constants.WebConstants;
 import org.fouram.core.base.service.BaseService;
+import org.fouram.core.plugin.weixin.cp.util.WXCpMessageUtil;
 import org.fouram.core.util.DateUtil;
 import org.fouram.core.util.LoggerUtil;
+import org.fouram.core.util.Tools;
 import org.fouram.dto.output.SyncWeixinUserOutput;
 import org.fouram.enums.DelFlagEnum;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -67,6 +69,7 @@ public class SyncSapUserToWxService extends BaseService {
 			sapUserService.updateAllNormalSyncWxResult();
 			LoggerUtil.info("updateAllNormalSyncWxResult:" + DateUtil.getTime());
 		} catch (Exception e) {
+			WXCpMessageUtil.sendAdminError(Tools.getExceptionAllInfo(e));
 			LoggerUtil.error(e);
 		} finally {
 			WebConstants.CACHE.remove(WebConstants.CACHE_SYNC_SAP);