From 581610e750a5d12e122f2d67a335a6c50a2c12ca Mon Sep 17 00:00:00 2001 From: wxyclub Date: Mon, 22 Apr 2024 17:11:53 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20OA=E5=8F=91=E9=80=81=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E7=9A=84=E8=A1=A5=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WebServiceOAController.java | 37 +++++++++++++++++++ 1 file changed, 37 insertions(+) diff --git a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/controller/WebServiceOAController.java b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/controller/WebServiceOAController.java index 7410a96d..ac47b970 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/controller/WebServiceOAController.java +++ b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/controller/WebServiceOAController.java @@ -5,6 +5,7 @@ import java.util.*; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.serializer.SerializerFeature; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.tmsps.fk.common.util.JsonUtil; import com.ydw.bat.wkflow.business_activiti.dto.*; @@ -22,6 +23,8 @@ import com.alibaba.fastjson.JSONObject; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessEntrustService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNameService; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; +import com.ydw.bat.wkflow.business_main.datas.service.ISendTodoLogService; +import com.ydw.bat.wkflow.business_main.datas.service.impl.SendTodoLogServiceImpl; import com.ydw.bat.wkflow.business_oa.webService.service.WebServiceOAService; import com.ydw.bat.wkflow.business_oa.webService.todoContent.NotifyTodoSendContext; import com.ydw.bat.wkflow.business_oa.webService.todoContent.SendOAContent; @@ -83,4 +86,38 @@ public class WebServiceOAController extends BaseAction { return WrapMapper.ok(result); } + @Autowired + private ISendTodoLogService sendTodoLogService; + @ApiOperation(value = "OA发送失败的补发") + @GetMapping("/reissueSendOA") + public String reissueSendOA() throws Exception { + LambdaQueryWrapper wrapper = new LambdaQueryWrapper<>(); + wrapper.eq(SendTodoLog::getOperMesg,"okhttp post error >> ex = {} sun.security.validator.ValidatorException: PKIX path building failed: sun.security.provider.certpath.SunCertPathBuilderException: unable to find valid certification path to requested target"); + wrapper.gt(SendTodoLog::getCreateTime,"2024-04-19 18:00:00"); + wrapper.orderByAsc(SendTodoLog::getCreateTime); + List sendTodoLogList = sendTodoLogService.list(wrapper); + for (SendTodoLog sendTodoLog : sendTodoLogList) { + String msgType = sendTodoLog.getMsgType(); + String mesg = sendTodoLog.getMesg(); + JSONObject jsonObject = JSONObject.parseObject(mesg); + if ("0".equals(msgType)) { + // 待办 + JSONObject processNewJsonObject = jsonObject.getJSONObject("mesg"); + BusProcessNew busProcessNew = JSONObject.toJavaObject(processNewJsonObject, BusProcessNew.class); + webServiceOAService.sendTodo(busProcessNew); + } else if ("1".equals(msgType)) { + // 已办 + JSONObject notifyTodoSendContextJsonObject = JSONObject.parseObject(mesg); + NotifyTodoSendContext notifyTodoSendContext = JSONObject.toJavaObject(notifyTodoSendContextJsonObject, NotifyTodoSendContext.class); + webServiceOAService.setTodoDone(notifyTodoSendContext); + } else if ("3".equals(msgType)) { + // 删除 + String todoId = sendTodoLog.getTodoId(); + String userId = sendTodoLog.getUserId(); + webServiceOAService.deleteOAByMandatory(todoId,userId); + } + } + return "ok"; + } + }