From d03e4b0ff5f1f246025956b6522ef0122aa1cadc Mon Sep 17 00:00:00 2001 From: SUNJIABIN Date: Wed, 12 Apr 2023 09:31:22 +0800 Subject: [PATCH 01/10] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=AF=86=E5=88=AB?= =?UTF-8?q?=E4=BC=81=E6=A0=87=E5=AF=BC=E5=85=A5=E5=A4=B1=E8=B4=A5=E6=8F=90?= =?UTF-8?q?=E7=A4=BA=E7=9A=84=E5=8F=98=E9=87=8F=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/SarBussionessStandServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java index 4d30971d..7d9f64d1 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/impl/SarBussionessStandServiceImpl.java @@ -2132,6 +2132,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl Date: Wed, 12 Apr 2023 09:49:10 +0800 Subject: [PATCH 02/10] =?UTF-8?q?=E9=97=AE=E7=AD=94=E4=B8=AD=E5=BF=83=20?= =?UTF-8?q?=E6=88=91=E7=9A=84=E5=9B=9E=E7=AD=94=20=E8=BF=94=E5=9B=9EtaskID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/adc/da/FeignClient/workFlowFeignClient.java | 3 +++ .../com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java | 4 ++++ .../com/adc/da/workFlow/controller/WorkFlowController.java | 6 +++++- 3 files changed, 12 insertions(+), 1 deletion(-) diff --git a/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java b/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java index 131ae3bd..421cbe70 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java +++ b/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java @@ -486,4 +486,7 @@ public interface workFlowFeignClient { @RequestMapping(value = "/bat-wkflow/datas/bus-process-new/selectWenDan",method = RequestMethod.GET) Map selectWenDan(@RequestParam("taskId")String taskId); + + @RequestMapping(value = "/bat-wkflow/datas/bus-process-new/questionsAndAnswers",method = RequestMethod.GET) + BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer); } diff --git a/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java b/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java index 65d81685..b641bd80 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java +++ b/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java @@ -442,4 +442,8 @@ public class workFlowFeignClientImpl { public Map selectWenDan(@RequestParam("taskId") String taskId) { return workFlowFeignClient.selectWenDan(taskId); } + + public BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { + return workFlowFeignClient.questionsAndAnswers(askId,answerer); + } } diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java index 3effd7b0..703fe531 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java @@ -1094,5 +1094,9 @@ public class WorkFlowController { } return Result.success(); } - + @ApiOperation(value = "问答中心 个人中心 我的问答 回答无taskID问题") + @GetMapping("/questionsAndAnswers") + public BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { + return workFlowFeignClient.questionsAndAnswers(askId,answerer); + } } From 1cc2a9e3f324fce0a1f4667c7f531ad4e49b42a3 Mon Sep 17 00:00:00 2001 From: SUNJIABIN Date: Wed, 12 Apr 2023 10:29:09 +0800 Subject: [PATCH 03/10] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E4=BC=81=E6=A0=87?= =?UTF-8?q?=E7=BC=96=E8=BE=91=E7=B1=BB=E5=88=AB=E5=92=8C=E6=A0=87=E5=87=86?= =?UTF-8?q?=E5=8F=B7=E7=A9=BA=E6=A0=BC=E9=97=AE=E9=A2=98=E5=92=8C=E6=A0=A1?= =?UTF-8?q?=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SarBussionessStandController.java | 37 ++++++++++++++++--- .../entity/SarBussionessStandEOPage.java | 10 +++++ 2 files changed, 41 insertions(+), 6 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java index cd8ce7c4..3198eeea 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java @@ -207,11 +207,11 @@ public class SarBussionessStandController extends BaseController standlist = sarBussionessStandEOService.selectStandardsByStandNumber(standnumber); if (standlist.size() > 0) { @@ -221,7 +221,19 @@ public class SarBussionessStandController extends BaseController queryWrapper = new QueryWrapper<>(); + queryWrapper.eq(null!=standnumber,"STAND_CODE",standnumber) + .eq(null!=page.getStandName(),"STAND_NAME",page.getStandName()); + List list = sarBussionessStandEOService.list(queryWrapper); + Integer valIdFlag = 0; + for (SarBussionessStand stand :list){ + if ((list.size() >=1 && !stand.getId().equals(page.getId()))){ + valIdFlag = stand.getValidFlag(); + if (valIdFlag == 0){ + return Result.error("企标编号("+ standnumber +")或企标名称("+ page.getStandName() +")已存在"); + } + } + } } } return Result.success(); @@ -229,11 +241,24 @@ public class SarBussionessStandController extends BaseController queryWrapper = new QueryWrapper<>(); + queryWrapper.eq(null!=standnumber,"STAND_CODE",standnumber) + .eq(null!=page.getStandName(),"STAND_NAME",page.getStandName()); + List list = sarBussionessStandEOService.list(queryWrapper); + Integer valIdFlag = 0; + for (SarBussionessStand stand :list){ + if ((list.size() >=1 && !stand.getId().equals(page.getId()))){ + valIdFlag = stand.getValidFlag(); + if (valIdFlag == 0){ + return Result.error("企标编号("+ standnumber +")或企标名称("+ page.getStandName() +")已存在"); + } + } + } } } else { return Result.success(); } + return Result.success(); } /** diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java index d2cc26c9..b9a18752 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/entity/SarBussionessStandEOPage.java @@ -14,6 +14,16 @@ import java.util.List; */ public class SarBussionessStandEOPage extends BasePage { + private String standNumber; + + public String getStandNumber() { + return standNumber; + } + + public void setStandNumber(String standNumber) { + this.standNumber = standNumber; + } + private String textStatusBuss; private String reviseStatus; From 51e40593f804d364ef9b0cd689545248d69be7c9 Mon Sep 17 00:00:00 2001 From: SUNJIABIN Date: Wed, 12 Apr 2023 10:35:32 +0800 Subject: [PATCH 04/10] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E4=BC=81=E6=A0=87?= =?UTF-8?q?=E7=BC=96=E8=BE=91=E7=B1=BB=E5=88=AB=E5=92=8C=E6=A0=87=E5=87=86?= =?UTF-8?q?=E5=8F=B7=E7=A9=BA=E6=A0=BC=E9=97=AE=E9=A2=98=E5=92=8C=E6=A0=A1?= =?UTF-8?q?=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/SarBussionessStandController.java | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java index 3198eeea..ea3b3208 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/controller/SarBussionessStandController.java @@ -238,7 +238,19 @@ public class SarBussionessStandController extends BaseController queryWrapper = new QueryWrapper<>(); + queryWrapper.eq(null!=standnumber,"STAND_CODE",standnumber) + .eq(null!=page.getStandName(),"STAND_NAME",page.getStandName()); + List list = sarBussionessStandEOService.list(queryWrapper); + Integer valIdFlag = 0; + for (SarBussionessStand stand :list){ + if ((list.size() >=1 && !stand.getId().equals(page.getId()))){ + valIdFlag = stand.getValidFlag(); + if (valIdFlag == 0){ + return Result.error("企标编号("+ standnumber +")或企标名称("+ page.getStandName() +")已存在"); + } + } + } } } else { QueryWrapper queryWrapper = new QueryWrapper<>(); From 2690eb6890cecfe0dd2408231beffc0b55530bdc Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 14:38:14 +0800 Subject: [PATCH 05/10] =?UTF-8?q?=E9=97=AE=E7=AD=94=E4=B8=AD=E5=BF=83=20?= =?UTF-8?q?=E6=88=91=E7=9A=84=E5=9B=9E=E7=AD=94=20=E5=AE=9E=E7=8E=B0?= =?UTF-8?q?=E6=B5=81=E7=A8=8B=E7=BB=93=E6=9D=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/adc/da/FeignClient/workFlowFeignClient.java | 3 ++- .../com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java | 2 +- .../com/adc/da/workFlow/controller/WorkFlowController.java | 2 +- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java b/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java index 421cbe70..0e20eb4e 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java +++ b/adc-da-activiti/src/main/java/com/adc/da/FeignClient/workFlowFeignClient.java @@ -3,6 +3,7 @@ package com.adc.da.FeignClient; import com.adc.da.common.*; import com.adc.da.common.Category; import com.adc.da.common.Page; +import com.adc.da.http.ResponseMessage; import com.adc.da.workFlow.entity.BusProcessEvaluationHis; import com.adc.da.workFlow.entity.BusProcessModelHis; import com.adc.da.workFlow.entity.ProcessRollBackEO; @@ -488,5 +489,5 @@ public interface workFlowFeignClient { Map selectWenDan(@RequestParam("taskId")String taskId); @RequestMapping(value = "/bat-wkflow/datas/bus-process-new/questionsAndAnswers",method = RequestMethod.GET) - BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer); + ResponseMessage questionsAndAnswers(@RequestParam("askId") String askId, @RequestParam("answerer") String answerer); } diff --git a/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java b/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java index b641bd80..9107167a 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java +++ b/adc-da-activiti/src/main/java/com/adc/da/FeignClientImpl/workFlowFeignClientImpl.java @@ -443,7 +443,7 @@ public class workFlowFeignClientImpl { return workFlowFeignClient.selectWenDan(taskId); } - public BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { + public ResponseMessage questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { return workFlowFeignClient.questionsAndAnswers(askId,answerer); } } diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java index 703fe531..7f3a2975 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java @@ -1096,7 +1096,7 @@ public class WorkFlowController { } @ApiOperation(value = "问答中心 个人中心 我的问答 回答无taskID问题") @GetMapping("/questionsAndAnswers") - public BusProcessNew questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { + public ResponseMessage questionsAndAnswers(@RequestParam("askId") String askId,@RequestParam("answerer") String answerer) { return workFlowFeignClient.questionsAndAnswers(askId,answerer); } } From e84430c4a92644341e370ae6484e40cdde9cbbb2 Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 16:06:26 +0800 Subject: [PATCH 06/10] =?UTF-8?q?=E9=82=80=E8=AF=B7=E5=8F=AF=E9=82=80?= =?UTF-8?q?=E8=AF=B7=E5=A4=9A=E4=BA=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/AskUserController.java | 19 +++++++++++++++---- 1 file changed, 15 insertions(+), 4 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskUserController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskUserController.java index 28aeb7fe..bf5fa91a 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskUserController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskUserController.java @@ -8,6 +8,7 @@ import com.adc.da.slrs.StandardQA.service.Impl.AskUserServiceImpl; import com.adc.da.util.http.ResponseMessage; import com.adc.da.util.http.Result; import io.swagger.annotations.Api; +import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; @@ -15,6 +16,9 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.util.Arrays; +import java.util.List; + /** * @Author: qk * @Date: 2022/6/2 0002 8:44 @@ -28,10 +32,17 @@ public class AskUserController extends BaseController { private AskUserServiceImpl askUserService; @PostMapping("/insertAskUser") public ResponseMessage insertAskUser(@RequestBody AskUser askUser){ - if(askUserService.save(askUser)){ - return Result.success("200","邀请成功",null); - }else { - return Result.error("-1","添加失败",null); + if(StringUtils.isBlank(askUser.getUsid())){ + return Result.error(); } + String[] split = askUser.getUsid().split(","); + final List asList = Arrays.asList(split); + for (String uid: asList){ + AskUser askUserInfo = new AskUser(); + askUserInfo.setAsdId(askUser.getAsdId()); + askUserInfo.setUsid(uid); + askUserService.save(askUserInfo); + } + return Result.success(); } } From 7e6ca43fe1ee00d6239ff3dd85814e7062e3730d Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 16:07:23 +0800 Subject: [PATCH 07/10] =?UTF-8?q?=E9=A6=96=E9=A1=B5=20=E6=A0=87=E5=87=86?= =?UTF-8?q?=E9=97=AE=E7=AD=94=20=E5=88=86=E9=A1=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/AskQuestionsController.java | 33 ++++++++++ .../StandardQA/entity/AskQuestionsPage.java | 3 + .../service/AskQuestionsService.java | 4 +- .../service/impl/AskQuestionsServiceImpl.java | 64 +++++++++++++++++-- 4 files changed, 99 insertions(+), 5 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java index 98af36ae..a10509d5 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java @@ -58,12 +58,45 @@ public class AskQuestionsController extends BaseController { @GetMapping("/getAskQuestionsPage") public ResponseMessage> getAskQuestionsPage(AskQuestionsPage askQuestions){ + askQuestions.setPage(1l); + askQuestions.setPageSize(1000l); + askQuestions.setUserId("aideyu"); + if(StringUtils.isBlank(askQuestions.getUserId())){ + return Result.error(); + } + Set askIdList = askQuestionsService.getAskQuestionsPage(askQuestions); + //查询出所有的回答 IPage iPage = new Page<>(); iPage.setSize(askQuestions.getPageSize()); iPage.setPages(askQuestions.getPage()); QueryWrapper queryWrapper = new QueryWrapper(); queryWrapper.orderByDesc("QUESTION_TIME"); + if(!askIdList.isEmpty()){ + queryWrapper.in("id",askIdList); + } IPage page = askQuestionsService.page(iPage,queryWrapper); + if(!page.getRecords().isEmpty()){ + for (AskQuestions data : page.getRecords()){ + if(StringUtils.isNotBlank(data.getQuestioner())){ + TsUser tsUser = tsUserDao.selectById(data.getQuestioner()); + data.setQuestioner(tsUser.getUname()); + } + if(StringUtils.isNotBlank(data.getClassification())){ + if (data.getClassification().equals("BUSINESS_STAND")) { + data.setClassification("企业标准"); + } + if (data.getClassification().equals("FOREIGN")) { + data.setClassification("海外标准"); + } + if (data.getClassification().equals("INLAND")) { + data.setClassification("国内标准"); + } + if (data.getClassification().equals("OTHER")) { + data.setClassification("公共标准"); + } + } + } + } return Result.success(page); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestionsPage.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestionsPage.java index 7c3ee0f8..c3e60d73 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestionsPage.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestionsPage.java @@ -42,4 +42,7 @@ public class AskQuestionsPage { @ApiModelProperty(value = "标准ID") private String appendixName; + + @ApiModelProperty(value = "登录人") + private String userId; } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/AskQuestionsService.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/AskQuestionsService.java index 1b349281..33587c73 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/AskQuestionsService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/AskQuestionsService.java @@ -4,10 +4,12 @@ import com.adc.da.slrs.NewsFeed.entity.NewsFeed; import com.adc.da.slrs.StandardQA.entity.AskQuestions; import com.adc.da.slrs.StandardQA.entity.AskQuestionsPage; import com.adc.da.slrs.StandardQA.entity.Reply; +import com.adc.da.util.http.ResponseMessage; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import java.util.List; +import java.util.Set; /** * @Author: qk @@ -31,5 +33,5 @@ public interface AskQuestionsService extends IService { List getArchiveAskQuestions(String id); List getAskQuestionsByakId(String id,String state,String userId); - + Set getAskQuestionsPage(AskQuestionsPage askQuestions); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/impl/AskQuestionsServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/impl/AskQuestionsServiceImpl.java index 7958c3b1..aa50e6b3 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/impl/AskQuestionsServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/service/impl/AskQuestionsServiceImpl.java @@ -3,11 +3,10 @@ package com.adc.da.slrs.StandardQA.service.Impl; import com.adc.da.slrs.StandardQA.dao.AskQuestionsDao; import com.adc.da.slrs.StandardQA.dao.ReplyDao; -import com.adc.da.slrs.StandardQA.entity.AskQuestions; -import com.adc.da.slrs.StandardQA.entity.AskQuestionsPage; -import com.adc.da.slrs.StandardQA.entity.AskQuestionsReplyVO; -import com.adc.da.slrs.StandardQA.entity.Reply; +import com.adc.da.slrs.StandardQA.entity.*; import com.adc.da.slrs.StandardQA.service.AskQuestionsService; +import com.adc.da.slrs.sarUser.dao.TsUserDao; +import com.adc.da.slrs.sarUser.entity.TsUser; import com.adc.da.slrs.sarUser.entity.UpDTO; import com.adc.da.slrs.sarUser.service.ITsUserService; import com.adc.da.util.http.ResponseMessage; @@ -24,7 +23,10 @@ import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; +import java.util.HashSet; import java.util.List; +import java.util.Set; +import java.util.stream.Collectors; /** * @Author: qk @@ -44,6 +46,13 @@ public class AskQuestionsServiceImpl extends ServiceImpl getAskQuestions(AskQuestions askQuestions) { return askQuestionsDao.getAskQuestions(askQuestions); @@ -137,6 +146,53 @@ public class AskQuestionsServiceImpl extends ServiceImpl getAskQuestionsPage(AskQuestionsPage askQuestions) { + //当前人是法规部门 则返回未被回答的提问信息 + List uId = askQuestionsDao.getUId(); + for (String uid : uId){ + if(uid.equals(askQuestions.getUserId())){ + //查询所有的问 答 + List askQuestionsList = baseMapper.selectList(null); + List repLies = replyDao.selectList(null); + List askList = new ArrayList<>(); + for (AskQuestions ask: askQuestionsList){ + for (Reply reply: repLies){ + if(ask.getId().equals(reply.getAskId())){ + askList.add(ask); + } + } + } + askQuestionsList.removeAll(askList.stream().distinct().collect(Collectors.toList())); + Set askIdList = new HashSet<>(); + //所有没有回答的问题 + for (AskQuestions ask: askQuestionsList){ + askIdList.add(ask.getId()); + } + //查询出所有的回答 + return askIdList; + } + } + // 不是法规部门 但是被邀请回答 + QueryWrapper askQuestionsQueryWrapper = new QueryWrapper<>(); + askQuestionsQueryWrapper.eq("QUESTIONER",askQuestions.getUserId()); + List askQuestionsList = baseMapper.selectList(askQuestionsQueryWrapper); + Set askIdList = new HashSet<>(); + //所有没有回答的问题 + for (AskQuestions ask: askQuestionsList){ + askIdList.add(ask.getId()); + } + // 邀请当前人回答 + QueryWrapper objectQueryWrapper = new QueryWrapper<>(); + objectQueryWrapper.eq("USID",askQuestions.getUserId()); + List askUsers = askUserService.list(objectQueryWrapper); + for (AskUser askUser: askUsers){ + askIdList.add(askUser.getAsdId()); + } + //查询出所有的回答 + return askIdList; + } + public ResponseMessage selectAskReply(String id) { ArrayList objects = new ArrayList<>(); From d1ea9b85666ea9c72e07072d6a15d5ab020c956e Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 16:38:16 +0800 Subject: [PATCH 08/10] =?UTF-8?q?=E9=A6=96=E9=A1=B5=20=E6=A0=87=E5=87=86?= =?UTF-8?q?=E9=97=AE=E7=AD=94=20=E5=88=86=E9=A1=B5=20=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../da/slrs/StandardQA/controller/AskQuestionsController.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java index a10509d5..e92c093b 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/AskQuestionsController.java @@ -58,9 +58,6 @@ public class AskQuestionsController extends BaseController { @GetMapping("/getAskQuestionsPage") public ResponseMessage> getAskQuestionsPage(AskQuestionsPage askQuestions){ - askQuestions.setPage(1l); - askQuestions.setPageSize(1000l); - askQuestions.setUserId("aideyu"); if(StringUtils.isBlank(askQuestions.getUserId())){ return Result.error(); } From df23a1a69f38d8686932572024ec9036318735fb Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 18:41:34 +0800 Subject: [PATCH 09/10] =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=8F=91=E9=80=81?= =?UTF-8?q?=E6=8A=80=E6=9C=AF=E6=A0=87=E5=87=86=E6=B5=81=E7=A8=8B=E5=BE=85?= =?UTF-8?q?=E5=8A=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WorkFlowController.java | 91 +++++++++++++------ 1 file changed, 62 insertions(+), 29 deletions(-) diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java index 7f3a2975..f11e53a1 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java @@ -18,6 +18,8 @@ import com.adc.da.slrs.esRevisePlan.dao.EsRevisePlanDao; import com.adc.da.slrs.esRevisePlan.entity.EsRevisePlan; import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanLogService; import com.adc.da.slrs.esRevisePlan.service.IEsRevisePlanService; +import com.adc.da.slrs.sarInstitution.dao.TsInstitutionDao; +import com.adc.da.slrs.sarInstitution.entity.TsInstitution; import com.adc.da.slrs.sarUser.entity.TsUser; import com.adc.da.slrs.sarUser.service.ITsUserService; import com.adc.da.sys.common.EmailUtils; @@ -91,6 +93,9 @@ public class WorkFlowController { @Autowired private SarAgenldAcceptButtonServiceImpl sarAgenldAcceptButtonService; + @Autowired + private TsInstitutionDao tsInstitutionDao; + // @Autowired // private ExportExcelMapper exportExcelMapper; @@ -1024,32 +1029,26 @@ public class WorkFlowController { for (EsRevisePlan data : esRevisePlans){ //数据拼接 ProcessRollBackEO processRollBackEO = new ProcessRollBackEO(); - processRollBackEO.setUserId(userId); + //起草人 + processRollBackEO.setUserId(data.getDrafter()); processRollBackEO.setType("25"); //拼接json HashMap qbfsForm = new HashMap<>(); HashMap qbfsFormInfo = new HashMap<>(); - qbfsForm.put("bussSort",data.getBussSort()); - qbfsForm.put("esMatingRelations",data.getEsMatingRelations()); - qbfsForm.put("technologic",data.getTechnologic()); - qbfsForm.put("useLevel",data.getUseLevel()); - qbfsForm.put("isRelate",data.getIsRelate()); - qbfsForm.put("esStandRelations",data.getEsStandRelations()); - //数组格式 - String[] split = data.getArea().split(","); - qbfsForm.put("area",split); - qbfsForm.put("tsJson",data.getTsJson()); - qbfsForm.put("tsJsonName",data.getTsJsonName()); - qbfsForm.put("rqbJson",data.getRqbJson()); - qbfsForm.put("rqbName",data.getRqbName()); - qbfsForm.put("unit",data.getUnit()); - qbfsForm.put("unitName",data.getUnitName()); + qbfsForm.put("esName",data.getEsName()); qbfsForm.put("planStatus",data.getPlanStatus()); qbfsForm.put("reviseStatus",data.getReviseStatus()); + qbfsForm.put("drafter",data.getDrafter()); + TsUser byIdDrafter = userService.getById(data.getDrafter()); + if(byIdDrafter!=null){ + qbfsForm.put("drafterName",byIdDrafter.getUname()); + } qbfsForm.put("resPerson",data.getResPerson()); - qbfsForm.put("resPersonName",data.getResPersonName()); - + TsUser byIdResPrson = userService.getById(data.getResPerson()); + if(byIdResPrson!=null){ + qbfsForm.put("resPersonName",byIdResPrson.getUname()); + } String wgLeaderStr = data.getWgLeader(); if(wgLeaderStr!=null){ if(wgLeaderStr.endsWith(",")){ @@ -1057,17 +1056,49 @@ public class WorkFlowController { } } qbfsForm.put("wgLeader",wgLeaderStr); - qbfsForm.put("wgLeaderName",data.getWgLeaderName()); + qbfsForm.put("resPerson",data.getResPerson()); + TsUser byIdWgleader = userService.getById(data.getResPerson()); + if(byIdWgleader!=null){ + qbfsForm.put("wgLeaderName",byIdWgleader.getUname()); + } + + qbfsForm.put("standId",data.getStandId()); + qbfsForm.put("actualTime",data.getActualTime()); + qbfsForm.put("standNumber",data.getStandNumber()); qbfsForm.put("draftTime",simpleDateFormat.format(data.getDraftTime())); qbfsForm.put("releaseTime",simpleDateFormat.format(data.getReleaseTime())); - qbfsForm.put("drafter",data.getDrafter()); - qbfsForm.put("drafterName",data.getDrafterName()); + + //争议 + qbfsForm.put("unit",data.getUnit()); + TsInstitution tsInstitution = tsInstitutionDao.selectById(data.getUnit()); + if(tsInstitution!=null){ + qbfsForm.put("unitName",tsInstitution.getName()); + } + + qbfsForm.put("rqbJson",data.getRqbJson()); + qbfsForm.put("rqbName",data.getRqbName()); + qbfsForm.put("rqbCode",data.getRqbCode()); + qbfsForm.put("tsJson",data.getTsJson()); + qbfsForm.put("tsJsonName",data.getTsJsonName()); + qbfsForm.put("area",data.getArea()); + qbfsForm.put("areaName",data.getAreaName()); + qbfsForm.put("standType",data.getStandType()); + qbfsForm.put("standNum",data.getStandNum()); + qbfsForm.put("esMatingRelations",data.getEsMatingRelations()); + qbfsForm.put("esStandRelations",data.getEsStandRelations()); + qbfsForm.put("isRelate",data.getIsRelate()); + qbfsForm.put("useLevel",data.getUseLevel()); + TsUser byIdUseLevel = userService.getById(data.getUseLevel()); + if(byIdUseLevel!=null){ + qbfsForm.put("useLevelName",data.getUseLevelName()); + } + + qbfsForm.put("technologic",data.getTechnologic()); + qbfsForm.put("bussSort",data.getBussSort()); + qbfsForm.put("lxdName",""); + qbfsForm.put("lxd",data.getLxd()); qbfsForm.put("LXD",data.getLxd()); qbfsForm.put("LXDName",""); - //争议 - qbfsForm.put("lxd",""); - //争议 - qbfsForm.put("lxdName","立项单"); qbfsForm.put("addFlag","1"); if(jsonObject.get("prcCreateUser")!=null){ qbfsForm.put("prcCreateUser",jsonObject.get("prcCreateUser").toString()); @@ -1084,10 +1115,12 @@ public class WorkFlowController { BusMes busMes = new BusMes(); busMes.setPrcType("25"); busMes.setTaskIds(taskId); - busMes.setCreateUserName(userName); - if(jsonObject.get("prcCreateUser")!=null){ - busMes.setUserId(jsonObject.get("prcCreateUser").toString()); - } +// busMes.setCreateUserName(userName); +// if(jsonObject.get("prcCreateUser")!=null){ +// busMes.setUserId(jsonObject.get("prcCreateUser").toString()); +// } + busMes.setCreateUserName(data.getDrafterName()); + busMes.setUserId(data.getDrafter()); busMes.setJson(jsonMap); Wrapper stringWrapper = completeTaskByUserId(busMes); } From d478b373743ee4de305afe5319755a490be4591b Mon Sep 17 00:00:00 2001 From: gaojiabao Date: Wed, 12 Apr 2023 18:59:17 +0800 Subject: [PATCH 10/10] =?UTF-8?q?=E6=89=B9=E9=87=8F=E5=8F=91=E9=80=81?= =?UTF-8?q?=E6=8A=80=E6=9C=AF=E6=A0=87=E5=87=86=E6=B5=81=E7=A8=8B=E5=BE=85?= =?UTF-8?q?=E5=8A=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/adc/da/workFlow/controller/WorkFlowController.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java index f11e53a1..101132b5 100644 --- a/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java +++ b/adc-da-activiti/src/main/java/com/adc/da/workFlow/controller/WorkFlowController.java @@ -1100,9 +1100,10 @@ public class WorkFlowController { qbfsForm.put("LXD",data.getLxd()); qbfsForm.put("LXDName",""); qbfsForm.put("addFlag","1"); - if(jsonObject.get("prcCreateUser")!=null){ - qbfsForm.put("prcCreateUser",jsonObject.get("prcCreateUser").toString()); - qbfsForm.put("prcCreateUserName",userName); + qbfsForm.put("prcCreateUser",data.getDrafter()); + TsUser byIdDrafterInfo = userService.getById(data.getDrafter()); + if(byIdDrafterInfo!=null){ + qbfsForm.put("prcCreateUserName",byIdDrafterInfo.getUname()); } qbfsForm.put("nowEsId","操作成功"); qbfsForm.put("type","5");