From b3acf754360f3ca381ae01fe9bbfb01ab129d1a9 Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 29 Mar 2023 18:49:01 +0800 Subject: [PATCH 1/7] =?UTF-8?q?=EF=BC=88OA=E5=88=A0=E9=99=A4=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E8=AE=B0=E5=BD=95=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datas/controller/OASendLogController.java | 15 ++++++ .../business_main/datas/entity/OASendLog.java | 47 +++++++++++++++++++ .../datas/mapper/OASendLogMapper.java | 8 ++++ .../datas/service/OASendLogService.java | 8 ++++ .../service/impl/OASendLogServiceImpl.java | 19 ++++++++ .../service/impl/WebServiceOAServiceImpl.java | 10 ++++ src/main/resources/mapper/datas/OASendLog.xml | 5 ++ 7 files changed, 112 insertions(+) create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/OASendLogController.java create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OASendLog.java create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/OASendLogMapper.java create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/service/OASendLogService.java create mode 100644 src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/OASendLogServiceImpl.java create mode 100644 src/main/resources/mapper/datas/OASendLog.xml diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/OASendLogController.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/OASendLogController.java new file mode 100644 index 00000000..1aeb1c63 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/OASendLogController.java @@ -0,0 +1,15 @@ +package com.ydw.bat.wkflow.business_main.datas.controller; + +import com.tmsps.fk.common.base.action.BaseAction; +import io.swagger.annotations.Api; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + + +@Api(description = "OA删除日志查询") +@RestController +@RequestMapping("/datas/OASendLogController") +public class OASendLogController extends BaseAction { + + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OASendLog.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OASendLog.java new file mode 100644 index 00000000..44868f01 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/entity/OASendLog.java @@ -0,0 +1,47 @@ +package com.ydw.bat.wkflow.business_main.datas.entity; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.experimental.Accessors; + +import java.util.Date; + +@EqualsAndHashCode(callSuper = false) +@Accessors(chain = true) +@TableName("OA_Send_LOG") +@ApiModel(value="OASendLog对象", description="") +@Data +public class OASendLog { + + @ApiModelProperty(value = "主键") + @TableId(value = "ID", type = IdType.UUID) + private String id; + + @ApiModelProperty(value = "类型") + @TableField("TYPE") + private String type; + + @ApiModelProperty(value = "日志") + @TableField("MSG_LOG") + private String msgLog; + + @ApiModelProperty(value = "方法") + @TableField("MEANS") + private String means; + + @TableField("CREATE_TIME") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + private Date createTime; + + @TableField("UPDATE_TIME") + @JsonFormat(timezone = "GMT+8", pattern = "yyyy-MM-dd HH:mm:ss") + private Date updateTime; + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/OASendLogMapper.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/OASendLogMapper.java new file mode 100644 index 00000000..98a64d49 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/OASendLogMapper.java @@ -0,0 +1,8 @@ +package com.ydw.bat.wkflow.business_main.datas.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.ydw.bat.wkflow.business_main.datas.entity.OASendLog; + +public interface OASendLogMapper extends BaseMapper { + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/OASendLogService.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/OASendLogService.java new file mode 100644 index 00000000..9fba0dc1 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/OASendLogService.java @@ -0,0 +1,8 @@ +package com.ydw.bat.wkflow.business_main.datas.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.ydw.bat.wkflow.business_main.datas.entity.OASendLog; + +public interface OASendLogService extends IService { + +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/OASendLogServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/OASendLogServiceImpl.java new file mode 100644 index 00000000..e4fa59d5 --- /dev/null +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/OASendLogServiceImpl.java @@ -0,0 +1,19 @@ +package com.ydw.bat.wkflow.business_main.datas.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ydw.bat.wkflow.business_main.datas.entity.OASendLog; +import com.ydw.bat.wkflow.business_main.datas.mapper.OASendLogMapper; +import com.ydw.bat.wkflow.business_main.datas.service.OASendLogService; +import org.springframework.stereotype.Service; + +@Service +public class OASendLogServiceImpl extends ServiceImpl implements OASendLogService { + + public String addOASendLog(OASendLog oaSendLog) { + int insert = baseMapper.insert(oaSendLog); + if(insert==1){ + return "1"; + } + return null; + } +} diff --git a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java index a5cbff85..77763ec9 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_oa/webService/service/impl/WebServiceOAServiceImpl.java @@ -8,6 +8,7 @@ import com.ydw.bat.wkflow.business_main.datas.entity.*; import com.ydw.bat.wkflow.business_main.datas.mapper.SendTodoLogMapper; 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.impl.OASendLogServiceImpl; import com.ydw.bat.wkflow.business_mq.service.CreateMQService; import com.ydw.bat.wkflow.business_oa.common.WebServiceConf; import com.ydw.bat.wkflow.business_oa.utils.OkHttpUtil; @@ -72,6 +73,9 @@ public class WebServiceOAServiceImpl implements WebServiceOAService { @Autowired private IBusProcessNameService iBusProcessNameService; + @Autowired + private OASendLogServiceImpl oaSendLogService; + public WebServiceOAServiceImpl(){ credentials = Credentials.basic(api_key,api_secret); } @@ -214,6 +218,12 @@ public class WebServiceOAServiceImpl implements WebServiceOAService { map.put("list",notifyTodoSendContextArrayList); net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(map); log.info("调用MQ数据！！！："+jsonObject.toString()); + OASendLog oaSendLog = new OASendLog(); + oaSendLog.setType("delete"); + oaSendLog.setCreateTime(new Date()); + oaSendLog.setMeans("deleteOAByPid"); + oaSendLog.setMsgLog(jsonObject.toString()); + oaSendLogService.addOASendLog(oaSendLog); oaService.setTodoDeleteMq(jsonObject.toString()); } } diff --git a/src/main/resources/mapper/datas/OASendLog.xml b/src/main/resources/mapper/datas/OASendLog.xml new file mode 100644 index 00000000..2641519b --- /dev/null +++ b/src/main/resources/mapper/datas/OASendLog.xml @@ -0,0 +1,5 @@ + + + + + From 4bf6f926ebc264b68ece009b18a0616120d8bb73 Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Thu, 30 Mar 2023 20:16:13 +0800 Subject: [PATCH 2/7] =?UTF-8?q?=E9=A6=96=E9=A1=B5=E4=BB=A3=E5=8A=9E?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=8C=89=E9=92=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datas/service/impl/BusProcessNewServiceImpl.java | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index b36fd699..f58d869b 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -93,14 +93,8 @@ public class BusProcessNewServiceImpl extends ServiceImpl Date: Fri, 31 Mar 2023 15:41:17 +0800 Subject: [PATCH 3/7] =?UTF-8?q?=E9=97=AE=E7=AD=94=E4=B8=AD=E5=BF=83=20?= =?UTF-8?q?=E9=A1=B5=E9=9D=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/BusProcessNewController.java | 13 +++++ .../datas/mapper/BusProcessNewMapper.java | 1 + .../datas/service/IBusProcessNewService.java | 4 ++ .../impl/BusProcessNewServiceImpl.java | 49 +++++++++++++++++++ .../listener/quizOrAnswer/answerBefore.java | 4 +- .../mapper/datas/BusProcessNewMapper.xml | 4 ++ 6 files changed, 74 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java index cad134c6..0cf1fe9c 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java @@ -14,6 +14,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import java.util.List; @@ -68,6 +69,18 @@ public class BusProcessNewController extends BaseAction { return iBusProcessNewService.selectBusProcessNew(taskId); } + @ApiOperation(value = "问答中心（第一个人回答以后删除其他人的代办任务以及OA提醒）") + @GetMapping("/deleteReplyToenNotice") + public String deleteReplyToenNotice(@RequestParam("taskId") String taskId, @RequestParam("answerer") String answerer){ + return iBusProcessNewService.deleteReplyToenNotice(taskId,answerer); + } + + @ApiOperation(value = "问答中心（第一个人回答以后删除其他人的代办任务以及OA提醒）") + @GetMapping("/selectAskId") + public String selectAskId(@RequestParam("taskId") String taskId){ + return iBusProcessNewService.selectAskId(taskId); + } + } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java index 9743050e..6b4a62e7 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java @@ -34,4 +34,5 @@ public interface BusProcessNewMapper extends BaseMapper { List everyDayTenOlockSAM(); + void deleteTask(@Param("taskId") String taskId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java index 2a6378cf..e33d36a5 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java @@ -37,4 +37,8 @@ public interface IBusProcessNewService extends IService { List everyDayTenOlockSAM(); String selectBusProcessNew(String taskId); + + String deleteReplyToenNotice(String taskId, String answerer); + + String selectAskId(String taskId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index f58d869b..63af2f54 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -1,13 +1,17 @@ package com.ydw.bat.wkflow.business_main.datas.service.impl; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessNewMapper; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.ydw.bat.wkflow.business_oa.webService.service.impl.WebServiceOAServiceImpl; import org.activiti.engine.TaskService; import org.activiti.engine.task.Task; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.*; @@ -24,8 +28,12 @@ import java.util.stream.Collectors; @Service public class BusProcessNewServiceImpl extends ServiceImpl implements IBusProcessNewService { + @Autowired private TaskService taskService; + @Autowired + private WebServiceOAServiceImpl webServiceOAService; + /* * @Author yuzhong * @Description @@ -98,4 +106,45 @@ public class BusProcessNewServiceImpl extends ServiceImpl objectQueryWrapper = new QueryWrapper<>(); + objectQueryWrapper.eq("TASK_ID",taskId); + List busProcessNews = baseMapper.selectList(objectQueryWrapper); + //获取pid + if(!busProcessNews.isEmpty()){ + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("P_ID",busProcessNews.get(0).getPId()); + List busProcessNewList = baseMapper.selectList(queryWrapper); + + for (BusProcessNew data : busProcessNewList){ + //通过taskId删除对应的任务。 + if(StringUtils.isNotBlank(data.getUserId()) && !data.getUserId().equals(answerer)){ + baseMapper.deleteTask(data.getTaskId()); + } + } + } + //删除OA待办 + if(StringUtils.isNotBlank(busProcessNews.get(0).getPId())){ + webServiceOAService.deleteOAByPid(busProcessNews.get(0).getPId()); + } + return "1"; + } + + @Override + public String selectAskId(String taskId) { + if(StringUtils.isNotBlank(taskId)){ + QueryWrapper objectQueryWrapper = new QueryWrapper<>(); + objectQueryWrapper.eq("TASK_ID",taskId); + List busProcessNews = baseMapper.selectList(objectQueryWrapper); + if(!busProcessNews.isEmpty()){ + String mesg = busProcessNews.get(0).getMesg(); + JSONObject jsonObject = JSON.parseObject(mesg); + JSONObject askQuestions = jsonObject.getJSONObject("askQuestions"); + String id = askQuestions.getString("id"); + return id; + } + } + return null; + } } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java index d1e861a0..3b923c18 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java @@ -1,5 +1,7 @@ package com.ydw.bat.wkflow.listener.quizOrAnswer; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; @@ -28,7 +30,7 @@ public class answerBefore implements TaskListener { CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); // 发送 oa 待办 设置 跳转页面 router ? 后面流程类型 - one1.setLink("standQA?prcType=27"); + one1.setLink("standQA?prcType=27&taskId="+one1.getTaskId()); one1.setTaskInfo(delegateTask.getName()); oaService.sendTodoMq(one1); } diff --git a/src/main/resources/mapper/datas/BusProcessNewMapper.xml b/src/main/resources/mapper/datas/BusProcessNewMapper.xml index e3a7a9b0..cff2392b 100644 --- a/src/main/resources/mapper/datas/BusProcessNewMapper.xml +++ b/src/main/resources/mapper/datas/BusProcessNewMapper.xml @@ -62,5 +62,9 @@ TASK_INFO = '标准化活动参会流程-流程结束' + + delete act_ru_task where ID_ = #{taskId} + + From 7121f00552515f505f43906fe86df8e3705977b5 Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Mon, 3 Apr 2023 10:11:43 +0800 Subject: [PATCH 4/7] =?UTF-8?q?=EF=BC=88=E5=88=A0=E9=99=A4=E5=BE=85?= =?UTF-8?q?=E5=8A=9E=E4=BB=BB=E5=8A=A1=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/resources/mapper/datas/BusProcessNewMapper.xml | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/main/resources/mapper/datas/BusProcessNewMapper.xml b/src/main/resources/mapper/datas/BusProcessNewMapper.xml index cff2392b..1561dbc3 100644 --- a/src/main/resources/mapper/datas/BusProcessNewMapper.xml +++ b/src/main/resources/mapper/datas/BusProcessNewMapper.xml @@ -63,7 +63,10 @@ - delete act_ru_task where ID_ = #{taskId} + delete act_ru_task + + ID_ = #{taskId} + From 0738eefbd1889e377271b9e88da80282d8edc39a Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Mon, 3 Apr 2023 11:18:40 +0800 Subject: [PATCH 5/7] =?UTF-8?q?=EF=BC=88=E5=88=A0=E9=99=A4=E6=9B=B4?= =?UTF-8?q?=E6=94=B9=E4=B8=BA=E5=AE=8C=E6=88=90=E4=BB=BB=E5=8A=A1=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/BusProcessNewController.java | 11 +++------- .../datas/mapper/BusProcessNewMapper.java | 2 -- .../datas/service/IBusProcessNewService.java | 2 +- .../impl/BusProcessNewServiceImpl.java | 22 ++++++------------- .../mapper/datas/BusProcessNewMapper.xml | 9 -------- 5 files changed, 11 insertions(+), 35 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java index 0cf1fe9c..a494e2ca 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/controller/BusProcessNewController.java @@ -11,11 +11,7 @@ import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.activiti.engine.task.Task; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; - -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; import java.util.List; @@ -70,8 +66,8 @@ public class BusProcessNewController extends BaseAction { } @ApiOperation(value = "问答中心（第一个人回答以后删除其他人的代办任务以及OA提醒）") - @GetMapping("/deleteReplyToenNotice") - public String deleteReplyToenNotice(@RequestParam("taskId") String taskId, @RequestParam("answerer") String answerer){ + @PostMapping("/deleteReplyToenNotice") + public List deleteReplyToenNotice(@RequestParam("taskId") String taskId, @RequestParam("answerer") String answerer){ return iBusProcessNewService.deleteReplyToenNotice(taskId,answerer); } @@ -81,6 +77,5 @@ public class BusProcessNewController extends BaseAction { return iBusProcessNewService.selectAskId(taskId); } - } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java index 6b4a62e7..96d425a9 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/mapper/BusProcessNewMapper.java @@ -33,6 +33,4 @@ public interface BusProcessNewMapper extends BaseMapper { List everyDayTenOlock(); List everyDayTenOlockSAM(); - - void deleteTask(@Param("taskId") String taskId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java index e33d36a5..5e66d3e5 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/IBusProcessNewService.java @@ -38,7 +38,7 @@ public interface IBusProcessNewService extends IService { String selectBusProcessNew(String taskId); - String deleteReplyToenNotice(String taskId, String answerer); + List deleteReplyToenNotice(String taskId, String answerer); String selectAskId(String taskId); } diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index 63af2f54..8775c500 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -107,28 +107,20 @@ public class BusProcessNewServiceImpl extends ServiceImpl deleteReplyToenNotice(String taskId, String answerer) { + ArrayList objects = new ArrayList<>(); QueryWrapper objectQueryWrapper = new QueryWrapper<>(); objectQueryWrapper.eq("TASK_ID",taskId); List busProcessNews = baseMapper.selectList(objectQueryWrapper); - //获取pid - if(!busProcessNews.isEmpty()){ - QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("P_ID",busProcessNews.get(0).getPId()); - List busProcessNewList = baseMapper.selectList(queryWrapper); - - for (BusProcessNew data : busProcessNewList){ - //通过taskId删除对应的任务。 - if(StringUtils.isNotBlank(data.getUserId()) && !data.getUserId().equals(answerer)){ - baseMapper.deleteTask(data.getTaskId()); - } - } - } //删除OA待办 if(StringUtils.isNotBlank(busProcessNews.get(0).getPId())){ webServiceOAService.deleteOAByPid(busProcessNews.get(0).getPId()); } - return "1"; + QueryWrapper objectQueryWrapperTaskId = new QueryWrapper<>(); + objectQueryWrapperTaskId.eq("P_ID",busProcessNews.get(0).getPId()); + List busProcessNewsArr = baseMapper.selectList(objectQueryWrapperTaskId); + //返回当前任务的所有 taskId + return busProcessNewsArr; } @Override diff --git a/src/main/resources/mapper/datas/BusProcessNewMapper.xml b/src/main/resources/mapper/datas/BusProcessNewMapper.xml index 1561dbc3..bd2df8df 100644 --- a/src/main/resources/mapper/datas/BusProcessNewMapper.xml +++ b/src/main/resources/mapper/datas/BusProcessNewMapper.xml @@ -61,13 +61,4 @@ CONCAT( date_sub( DATE_FORMAT( NOW(), '%Y-%m-%d' ), INTERVAL 1 DAY), '%')) and TASK_INFO = '标准化活动参会流程-流程结束' - - - delete act_ru_task - - ID_ = #{taskId} - - - - From 04cff8eaf5a867d765cd53440103dea0d922f11b Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Mon, 3 Apr 2023 11:52:21 +0800 Subject: [PATCH 6/7] =?UTF-8?q?=EF=BC=88=E5=AE=8C=E6=88=90=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datas/service/impl/BusProcessNewServiceImpl.java | 6 +++++- .../ydw/bat/wkflow/listener/quizOrAnswer/answerAfter.java | 1 + .../ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java | 2 +- 3 files changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index 8775c500..c164e2fa 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -3,6 +3,8 @@ package com.ydw.bat.wkflow.business_main.datas.service.impl; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.ydw.bat.wkflow.business_activiti.task.TodoTaskController; +import com.ydw.bat.wkflow.business_main.datas.entity.BusMes; import com.ydw.bat.wkflow.business_main.datas.entity.BusProcessNew; import com.ydw.bat.wkflow.business_main.datas.mapper.BusProcessNewMapper; import com.ydw.bat.wkflow.business_main.datas.service.IBusProcessNewService; @@ -108,7 +110,6 @@ public class BusProcessNewServiceImpl extends ServiceImpl deleteReplyToenNotice(String taskId, String answerer) { - ArrayList objects = new ArrayList<>(); QueryWrapper objectQueryWrapper = new QueryWrapper<>(); objectQueryWrapper.eq("TASK_ID",taskId); List busProcessNews = baseMapper.selectList(objectQueryWrapper); @@ -120,6 +121,9 @@ public class BusProcessNewServiceImpl extends ServiceImpl busProcessNewsArr = baseMapper.selectList(objectQueryWrapperTaskId); //返回当前任务的所有 taskId + + TodoTaskController todoTaskController =new TodoTaskController(); + return busProcessNewsArr; } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerAfter.java b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerAfter.java index 90a00879..4171e321 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerAfter.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerAfter.java @@ -92,6 +92,7 @@ public class answerAfter implements TaskListener { } } // 提交时，结束流程，保存当前节点信息 + delegateTask.setVariable("flag",1); BussUtils.endFunAll(delegateTask, prcName, busBean, object, "0", busProcessNameService, "27"); } } diff --git a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java index 3b923c18..d8d38401 100644 --- a/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java +++ b/src/main/java/com/ydw/bat/wkflow/listener/quizOrAnswer/answerBefore.java @@ -30,7 +30,7 @@ public class answerBefore implements TaskListener { CreateMQService oaService = SpringContextUtil.getBean(CreateMQService.class); // 发送 oa 待办 设置 跳转页面 router ? 后面流程类型 - one1.setLink("standQA?prcType=27&taskId="+one1.getTaskId()); + one1.setLink("questions2?prcType=27&taskId="+one1.getTaskId()); one1.setTaskInfo(delegateTask.getName()); oaService.sendTodoMq(one1); } From 25c777f68d4ef66bcb77e3e9654136cab3432209 Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Mon, 3 Apr 2023 11:53:24 +0800 Subject: [PATCH 7/7] =?UTF-8?q?=EF=BC=88=E4=BC=98=E5=8C=96=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datas/service/impl/BusProcessNewServiceImpl.java | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java index c164e2fa..b4bcc0b1 100644 --- a/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java +++ b/src/main/java/com/ydw/bat/wkflow/business_main/datas/service/impl/BusProcessNewServiceImpl.java @@ -117,14 +117,7 @@ public class BusProcessNewServiceImpl extends ServiceImpl objectQueryWrapperTaskId = new QueryWrapper<>(); - objectQueryWrapperTaskId.eq("P_ID",busProcessNews.get(0).getPId()); - List busProcessNewsArr = baseMapper.selectList(objectQueryWrapperTaskId); - //返回当前任务的所有 taskId - - TodoTaskController todoTaskController =new TodoTaskController(); - - return busProcessNewsArr; + return null; } @Override