From 69f44f6202f08cf38b9c4fcb9698e19e62d6c53f Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Tue, 2 Aug 2022 18:01:56 +0800 Subject: [PATCH 1/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=205?= =?UTF-8?q?6827=20=E6=A0=87=E5=87=86=E5=90=88=E8=A7=84=E8=AF=84=E4=BC=B0?= =?UTF-8?q?=E6=B5=81=E7=A8=8B-=E9=A1=B9=E7=9B=AE=E5=88=86=E5=8F=91?= =?UTF-8?q?=E8=8A=82=E7=82=B9=EF=BC=8C=E9=80=89=E6=8B=A9=E9=A1=B9=E7=9B=AE?= =?UTF-8?q?=E9=80=BB=E8=BE=91=20=E5=BA=94=E8=AF=A5=E6=98=AF=E2=80=9C?= =?UTF-8?q?=E5=B7=B2=E7=BB=B4=E6=8A=A4=E2=80=9D+=E2=80=9C=E6=9C=AA?= =?UTF-8?q?=E7=BB=B4=E6=8A=A4=E2=80=9D=EF=BC=8C=E7=8E=B0=E5=9C=A8=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E7=9A=84=E6=8C=BA=E4=B9=B1=E7=9A=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sarStandProjectLibrary/SarStandProjectLibraryMapper.xml | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandProjectLibrary/SarStandProjectLibraryMapper.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandProjectLibrary/SarStandProjectLibraryMapper.xml index 10ba9e1d..0abda4a1 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandProjectLibrary/SarStandProjectLibraryMapper.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/sarStandProjectLibrary/SarStandProjectLibraryMapper.xml @@ -455,6 +455,9 @@ select sar_stand_project_library.* , ts_user.UNAME as uName from sar_stand_project_library left join ts_user on ts_user.USID = sar_stand_project_library.project_manager where 1=1 + + and sar_stand_project_library.flag=#{sarStandProjectLibrary.flag} + and sar_stand_project_library.management_host_name=#{sarStandProjectLibrary.managementHostName} @@ -481,6 +484,9 @@ select count(sar_stand_project_library.id) from sar_stand_project_library left join ts_user on ts_user.USID = sar_stand_project_library.project_manager where 1=1 + + and sar_stand_project_library.flag=#{sarStandProjectLibrary.flag} + and sar_stand_project_library.management_host_name=#{sarStandProjectLibrary.managementHostName} From aacd522b79be3813b96fd5036964c09cf56063d0 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Wed, 3 Aug 2022 15:50:00 +0800 Subject: [PATCH 2/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=205?= =?UTF-8?q?6881=20=E6=A0=87=E5=87=86=E6=8B=86=E5=88=86-=E8=AF=A6=E6=83=85-?= =?UTF-8?q?=E6=A8=A1=E6=9D=BF=E4=B8=8B=E8=BD=BD=EF=BC=8Ctoken=E6=97=A0?= =?UTF-8?q?=E6=95=88=20=EF=BC=8C=20=E6=B7=BB=E5=8A=A0=E7=99=BD=E5=90=8D?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/adc/da/login/security/WebMvcConfig.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/adc-da-jwtLogin/src/main/java/com/adc/da/login/security/WebMvcConfig.java b/adc-da-jwtLogin/src/main/java/com/adc/da/login/security/WebMvcConfig.java index 25d7f074..638172e0 100644 --- a/adc-da-jwtLogin/src/main/java/com/adc/da/login/security/WebMvcConfig.java +++ b/adc-da-jwtLogin/src/main/java/com/adc/da/login/security/WebMvcConfig.java @@ -52,6 +52,9 @@ public class WebMvcConfig implements WebMvcConfigurer { addInterceptor.excludePathPatterns("/api/sys/user/getById"); addInterceptor.excludePathPatterns("/api/person/userInfo/getByUserInfoCode"); addInterceptor.excludePathPatterns("/api/att/attFile/upload"); + // 标准拆分 模板下载 + addInterceptor.excludePathPatterns("/api/att/attFile/uploadModalFile"); + addInterceptor.excludePathPatterns("/api/sarStandardsInfo/sar-standards-info/exportStandardsInfoExcel"); addInterceptor.excludePathPatterns("/api/lawss/sarLawsInfo/exportStandardsInfoExcel"); // 提供自动发起复审流程 复审数据 From 4e90dfa1cf22bb08b772309980e620f687fcf115 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Thu, 4 Aug 2022 13:25:37 +0800 Subject: [PATCH 3/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=205?= =?UTF-8?q?6828=20=E9=A1=B9=E7=9B=AE=E8=AF=84=E4=BC=B0=E6=B5=81=E7=A8=8B?= =?UTF-8?q?=EF=BC=8C=E9=80=89=E6=8B=A9=E9=A1=B9=E7=9B=AE=E9=A1=B5=E9=9D=A2?= =?UTF-8?q?=EF=BC=8C=E9=A1=B9=E7=9B=AE=E6=98=BE=E7=A4=BA=E4=B8=8D=E5=85=A8?= =?UTF-8?q?=EF=BC=8C=E5=8F=AA=E6=98=BE=E7=A4=BA10=E6=9D=A1=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/SarStandProjectLibraryController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandProjectLibrary/controller/SarStandProjectLibraryController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandProjectLibrary/controller/SarStandProjectLibraryController.java index 1abb263f..00375a93 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandProjectLibrary/controller/SarStandProjectLibraryController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandProjectLibrary/controller/SarStandProjectLibraryController.java @@ -74,7 +74,7 @@ public class SarStandProjectLibraryController extends BaseController MaintenanceList = sarStandProjectLibraryService.queryMaintenanceProjectWorkFlow(Page,PageSize,sarDto); Map map = new HashMap(); map.put("Maintenance",MaintenanceList); From 67c4a1afd958f4cca64f4f785812803f5187e053 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Thu, 4 Aug 2022 16:10:45 +0800 Subject: [PATCH 4/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=205?= =?UTF-8?q?6904=20=E9=97=AE=E7=AD=94=E5=BA=93-=E8=AE=A2=E9=98=85=20?= =?UTF-8?q?=E7=A8=8B=E5=BA=8F=E5=BC=82=E5=B8=B8=20api/lawss/Subscription/i?= =?UTF-8?q?nsertSubscription=20=E8=BF=99=E4=B8=AA=E6=8E=A5=E5=8F=A3=20,=20?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20=E5=8F=96=E6=B6=88=E8=AE=A2=E9=98=85?= =?UTF-8?q?=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/AskQuestionsController.java | 24 +++++++++++--- .../controller/SubscriptionController.java | 32 +++++++++++++++---- .../slrs/StandardQA/entity/AskQuestions.java | 3 ++ .../slrs/StandardQA/entity/Subscription.java | 4 +++ 4 files changed, 51 insertions(+), 12 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 9a5ecd01..6ef0837a 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 @@ -2,12 +2,11 @@ package com.adc.da.slrs.StandardQA.controller; import com.adc.da.base.web.BaseController; import com.adc.da.slrs.StandardQA.dao.AskQuestionsDao; -import com.adc.da.slrs.StandardQA.entity.AskQuestions; -import com.adc.da.slrs.StandardQA.entity.AskQuestionsPage; -import com.adc.da.slrs.StandardQA.entity.AskUser; -import com.adc.da.slrs.StandardQA.entity.Reply; +import com.adc.da.slrs.StandardQA.entity.*; import com.adc.da.slrs.StandardQA.service.Impl.AskQuestionsServiceImpl; import com.adc.da.slrs.StandardQA.service.Impl.AskUserServiceImpl; +import com.adc.da.slrs.StandardQA.service.Impl.SubscriptionServiceImpl; +import com.adc.da.util.LoginUserUtil; import com.adc.da.util.UUIDUtils; import com.adc.da.util.http.ResponseMessage; import com.adc.da.util.http.Result; @@ -45,6 +44,9 @@ public class AskQuestionsController extends BaseController { @Autowired private AskUserServiceImpl askUserService; + @Autowired + private SubscriptionServiceImpl subscriptionService; + @GetMapping("/getAskQuestionsPage") public ResponseMessage> getAskQuestionsPage(AskQuestionsPage askQuestions){ IPage iPage = new Page<>(); @@ -58,7 +60,19 @@ public class AskQuestionsController extends BaseController { @PostMapping("/list") public ResponseMessage> getAskQuestionslistPage(@RequestBody AskQuestionsPage askQuestions){ - return Result.success(askQuestionsService.listPage(askQuestions)); + IPage iPage = askQuestionsService.listPage(askQuestions); + if(!iPage.getRecords().isEmpty()){ + iPage.getRecords().forEach(questions -> { + QueryWrapper queryWrapper = new QueryWrapper(); + queryWrapper.eq("ASK_ID",questions.getId()); + queryWrapper.eq("USID", LoginUserUtil.getUserId()); + List list = subscriptionService.list(queryWrapper); + if(!list.isEmpty()){ + questions.setSubState(list.get(0).getSubState()); + } + }); + } + return Result.success(iPage); } /** diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/SubscriptionController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/SubscriptionController.java index f8a6ec16..f300887b 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/SubscriptionController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/controller/SubscriptionController.java @@ -7,6 +7,7 @@ import com.adc.da.slrs.StandardQA.service.Impl.SubscriptionServiceImpl; import com.adc.da.util.http.ResponseMessage; import com.adc.da.util.http.Result; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import io.swagger.annotations.Api; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; @@ -14,6 +15,8 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.util.List; + /** * @Author: qk * @Date: 2022/6/7 0007 11:18 @@ -31,14 +34,29 @@ public class SubscriptionController extends BaseController { QueryWrapper queryWrapper = new QueryWrapper(); queryWrapper.eq("ASK_ID",subscription.getAskId()); queryWrapper.eq("USID",subscription.getUsId()); - int number = subscriptionService.count(queryWrapper); - if(number>0){ - return Result.success("200","此问题已订阅",null); - } - if(subscriptionService.save(subscription)){ - return Result.success("200","订阅成功",null); + List list = subscriptionService.list(queryWrapper); + if(!list.isEmpty()){ + UpdateWrapper updateWrapper = new UpdateWrapper(); + updateWrapper.eq("ASK_ID",subscription.getAskId()); + updateWrapper.eq("USID",subscription.getUsId()); + updateWrapper.set("SUB_STATE",subscription.getSubState()); + if(subscriptionService.update(updateWrapper)){ + if("y".equals(subscription.getSubState())){ + return Result.success("200","订阅成功",null); + }else { + return Result.success("200","取消订阅成功",null); + } + + }else { + return Result.success("-1","订阅失败",null); + } }else { - return Result.success("-1","订阅失败",null); + subscription.setSubState("y"); + if(subscriptionService.save(subscription)){ + return Result.success("200","订阅成功",null); + }else { + return Result.success("-1","订阅失败",null); + } } } } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestions.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestions.java index 84cf8afc..0f8c9755 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestions.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/AskQuestions.java @@ -101,4 +101,7 @@ public class AskQuestions extends BaseEntity { @TableField(exist = false) private String subscription; + @TableField(exist = false) + private String subState; + } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/Subscription.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/Subscription.java index 47c1169e..5e46f3bf 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/Subscription.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/StandardQA/entity/Subscription.java @@ -28,4 +28,8 @@ public class Subscription extends BaseEntity { @TableField("USID") @ApiModelProperty(value = "用户ID") private String usId; + + @TableField("SUB_STATE") + @ApiModelProperty(value = "订阅状态 默认 n 未订阅 y 已订阅") + private String subState; } From b792f585a481eebd5b48f4ec01e4d9424c3ed9a0 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Mon, 8 Aug 2022 16:49:23 +0800 Subject: [PATCH 5/8] feat: There is no way the, --- .../mybatis/mapper/askQuestions/AskQuestionsMapper.xml | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/adc-da-slrs/src/main/resources/mybatis/mapper/askQuestions/AskQuestionsMapper.xml b/adc-da-slrs/src/main/resources/mybatis/mapper/askQuestions/AskQuestionsMapper.xml index bf96e138..3873c0b7 100644 --- a/adc-da-slrs/src/main/resources/mybatis/mapper/askQuestions/AskQuestionsMapper.xml +++ b/adc-da-slrs/src/main/resources/mybatis/mapper/askQuestions/AskQuestionsMapper.xml @@ -140,7 +140,7 @@ LEFT JOIN reply ON aq.ID = reply.ASK_ID LEFT JOIN ts_user t1 ON t1.USID = aq.QUESTIONER LEFT JOIN ts_user t2 ON t2.USID = reply.ANSWERER - LEFT JOIN subscription su ON su.ASK_ID = aq.ID + LEFT JOIN subscription su ON su.ASK_ID = aq.ID and su.SUB_STATE = 'y' AND su.USID = #{askQuestions.answerer} @@ -172,7 +172,10 @@ LEFT JOIN subscription su ON su.ASK_ID = aq.ID - + 1=1 + + AND su.SUB_STATE = 'y' + AND aq.QUESTIONER =#{askQuestions.questioner} @@ -214,7 +217,7 @@ LEFT JOIN reply ON aq.ID = reply.ASK_ID AND reply.STATE = '0' LEFT JOIN ts_user t1 ON t1.USID = aq.QUESTIONER LEFT JOIN ts_user t2 ON t2.USID = reply.ANSWERER - LEFT JOIN subscription su ON su.ASK_ID = aq.ID + LEFT JOIN subscription su ON su.ASK_ID = aq.ID and su.SUB_STATE = 'y' AND su.USID = #{askQuestions.answerer} From abdff752091477e181666ff77f25691ace1877a5 Mon Sep 17 00:00:00 2001 From: zyd Date: Wed, 10 Aug 2022 08:11:38 +0800 Subject: [PATCH 6/8] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E6=9F=A5=E8=AF=A2?= =?UTF-8?q?=E4=BA=BA=E5=91=98=E6=97=B6=EF=BC=8C=E7=BB=84=E7=BB=87=E6=9C=BA?= =?UTF-8?q?=E6=9E=84=E5=B1=82=E7=BA=A7=E7=AD=89=E4=BA=8E3=E5=B1=82?= =?UTF-8?q?=E6=97=B6=EF=BC=8C=E8=8E=B7=E5=8F=96=E7=9A=84=E9=9B=86=E5=90=88?= =?UTF-8?q?=E6=95=B0=E9=87=8F=E9=94=99=E8=AF=AF=E5=AF=BC=E8=87=B4=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E6=8A=A5=E9=94=99=E6=97=A0=E6=B3=95=E9=80=89=E6=8B=A9?= =?UTF-8?q?=E4=BA=BA=E7=9A=84BUG?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/TsInstitutionServiceImpl.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/impl/TsInstitutionServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/impl/TsInstitutionServiceImpl.java index 217f872f..1e660d8f 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/impl/TsInstitutionServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarInstitution/service/impl/TsInstitutionServiceImpl.java @@ -288,16 +288,18 @@ public class TsInstitutionServiceImpl extends ServiceImpl tsInstitutions = new ArrayList<>(); List institutions = getTopChild(map,userVO.getInstitutionId(),topNum,tsInstitutions); if(!institutions.isEmpty()){ - if(institutions.size() >= topNum){ + if(institutions.size() > topNum){ userVO.setTopUnitId(institutions.get(topNum).getId()); userVO.setTopUnit(institutions.get(topNum).getName()); + }else if(institutions.size() == topNum){ + userVO.setTopUnitId(institutions.get(topNum-1).getId()); + userVO.setTopUnit(institutions.get(topNum-1).getName()); }else { - userVO.setTopUnitId(institutions.get(institutions.size()-1).getId()); - userVO.setTopUnit(institutions.get(institutions.size()-1).getName()); + userVO.setTopUnitId(institutions.get(institutions.size()-1).getId()); + userVO.setTopUnit(institutions.get(institutions.size()-1).getName()); } } } - } return res; } From 43c59e13e5aab8bde32185d6951fc1ceae72ae79 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Wed, 10 Aug 2022 16:26:36 +0800 Subject: [PATCH 7/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=20?= =?UTF-8?q?=E6=A0=87=E5=87=86=20=E8=A2=AB=E4=BB=A3=E6=9B=BF=20=E8=A1=A5?= =?UTF-8?q?=E6=BC=8F=E3=80=82=E3=80=82=20=E8=AF=A6=E6=83=85=E7=82=B9?= =?UTF-8?q?=E5=87=BB=E4=BB=A3=E6=9B=BF=E3=80=81=E8=A2=AB=E4=BB=A3=E6=9B=BF?= =?UTF-8?q?=E6=A0=87=E5=87=86=E6=95=88=E9=AA=8C=E6=8E=A5=E5=8F=A3=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../da/slrs/DataSync/DataSyncController.java | 12 + .../DataSync/service/IDataSyncService.java | 3 + .../service/impl/DataSyncServiceImpl.java | 209 ++++++++++++++++++ .../service/ISarBussionessStandService.java | 2 + .../impl/SarBussionessStandServiceImpl.java | 3 +- .../service/ISarStandardsInfoService.java | 2 + .../impl/SarStandardsInfoServiceImpl.java | 2 +- .../SarBussionessStandMapper.xml | 2 +- 8 files changed, 232 insertions(+), 3 deletions(-) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/DataSyncController.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/DataSyncController.java index a1cb94ee..f3cfe90c 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/DataSyncController.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/DataSyncController.java @@ -42,6 +42,18 @@ public class DataSyncController { private IDataSyncService iDataSyncService; + @ApiOperation("国内外标准库代替被代替 数据补全") + @PostMapping("/dtAndBdtToStandData") + public void dtAndBdtToStandData() { + iDataSyncService.dtAndBdtToStandData(); + } + + @ApiOperation("企业标准库代替被代替 数据补全") + @PostMapping("/dtAndBdtToBussData") + public void dtAndBdtToBussData() { + iDataSyncService.dtAndBdtToBussData(); + } + @ApiOperation("同步用户数据") @PostMapping("/importUserData") public String importUserData() throws Exception { diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/IDataSyncService.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/IDataSyncService.java index 986f24ed..8091c730 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/IDataSyncService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/IDataSyncService.java @@ -2,6 +2,9 @@ package com.adc.da.slrs.DataSync.service; public interface IDataSyncService { + void dtAndBdtToStandData(); + void dtAndBdtToBussData(); + public String dataSync(); public String orgDataSync(); diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java index b1e8cbd9..8855c313 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java @@ -2,10 +2,19 @@ package com.adc.da.slrs.DataSync.service.impl; import com.adc.da.login.util.UserUtils; import com.adc.da.slrs.DataSync.service.IDataSyncService; +import com.adc.da.slrs.sarBussStandAttrInfo.dao.SarBussStandAttrInfoDao; +import com.adc.da.slrs.sarBussStandAttrInfo.service.ISarBussStandAttrInfoService; +import com.adc.da.slrs.sarBussionessStand.entity.SarBussionessStand; +import com.adc.da.slrs.sarBussionessStand.service.ISarBussionessStandService; import com.adc.da.slrs.sarInstitution.entity.TsInstitution; import com.adc.da.slrs.sarInstitution.service.ITsInstitutionService; import com.adc.da.slrs.sarPosition.entity.TsPosition; import com.adc.da.slrs.sarPosition.service.ITsPositionService; +import com.adc.da.slrs.sarStandAttrInfo.dao.SarStandAttrInfoDao; +import com.adc.da.slrs.sarStandAttrInfo.entity.SarStandAttrInfo; +import com.adc.da.slrs.sarStandAttrInfo.service.ISarStandAttrInfoService; +import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfo; +import com.adc.da.slrs.sarStandardsInfo.service.ISarStandardsInfoService; import com.adc.da.slrs.sarUser.entity.TsUser; import com.adc.da.slrs.sarUser.service.ITsUserService; import com.adc.da.sync.service.SyncUserService; @@ -14,18 +23,22 @@ import com.adc.da.sys.entity.UserOrgEO; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import lombok.extern.log4j.Log4j; +import org.apache.commons.lang3.StringUtils; import org.apache.ibatis.jdbc.Null; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import java.sql.Timestamp; import java.util.*; +import java.util.stream.Collectors; @Service public class DataSyncServiceImpl implements IDataSyncService { @@ -37,10 +50,206 @@ public class DataSyncServiceImpl implements IDataSyncService { ITsUserService tsUserService; @Autowired ITsInstitutionService tsInstitutionService; + @Autowired + private ISarStandardsInfoService iSarStandardsInfoService; + @Autowired + private ISarBussionessStandService iSarBussionessStandService; + + @Autowired + private SarStandAttrInfoDao sarStandAttrInfoEODao; + + @Autowired + private ISarStandAttrInfoService iSarStandAttrInfoService; + + @Autowired + private SarBussStandAttrInfoDao sarBussStandAttrInfoEODao; + + @Autowired + private ISarBussStandAttrInfoService iSarBussStandAttrInfoService; + + private static Logger logger = LoggerFactory.getLogger(DataSyncServiceImpl.class); + @Transactional(rollbackFor = {RuntimeException.class,Exception.class}) + @Async + public void dtAndBdtToStandData(){ + QueryWrapper wrapper = new QueryWrapper(); + wrapper.select("sar_standards_info.*, r.DTBJH AS dtbzh, r.BDTBZH"); + wrapper.last("LEFT JOIN sar_stand_attr_info r ON r.STAND_ID = sar_standards_info.ID WHERE sar_standards_info.VALID_FLAG = '0'"); + List standardsInfos = iSarStandardsInfoService.list(wrapper); + + if(!standardsInfos.isEmpty()){ + + // 1. 遍历全部数据 + standardsInfos.forEach(info -> { + // 1.1 判断代替标准号 + if(StringUtils.isNotBlank(info.getDtbzh())){ + // 1.1.1 找出当前代替标准版所有被代替标准 + List dtList = Arrays.stream(info.getDtbzh().split(",")).map(String::trim).collect(Collectors.toList()); + if(!dtList.isEmpty()){ + for (String s : dtList) { + + if(s.contains("null")){ + continue; + } + List bdtList = standardsInfos.stream().filter(info1 -> { + if(StringUtils.isNotBlank(info1.getDtbzh()) && info1.getDtbzh().contains(s)){ + return true; + } + return false; + }).collect(Collectors.toList()); + // 1.1.1.1合并被代替标准 + if(!bdtList.isEmpty()){ + // 1.1.1.1.1 获取需要更新的代替标准 + List updInfo = standardsInfos.stream().filter(info1 -> { + String addStrandNumber = ""; + if (StringUtils.isNotEmpty(info1.getStandYear())) { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber() + "-" + info1.getStandYear(); + } else { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber(); + } + if(StringUtils.isNotBlank(addStrandNumber) && s.trim().equals(addStrandNumber.trim())){ + return true; + } + return false; + }).collect(Collectors.toList()); + + + // 1.1.1.1.2 是否存在需要更新的代替标准 + if(!updInfo.isEmpty()){ + // 1.1.1.1.2.1 拼接 被代替标准号 + String btd = bdtList.stream().map(info1 -> { + String addStrandNumber = ""; + if (StringUtils.isNotEmpty(info1.getStandYear())) { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber() + "-" + info1.getStandYear(); + } else { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber(); + } + return addStrandNumber; + }).collect(Collectors.joining(",")); + System.out.println(btd); + + // 1.1.1.1.2.2 找出已存在的被代替标准 及 去重, 如没找出，则使用最新被代替 + List notExBtdList = Arrays.stream(btd.split(",")).map(String::trim).collect(Collectors.toList()); + if(StringUtils.isNotBlank(updInfo.get(0).getBDTBZH())){ + List exBdtList = Arrays.stream(updInfo.get(0).getBDTBZH().split(",")).map(String::trim).collect(Collectors.toList()); + if(!exBdtList.isEmpty()){ + exBdtList = exBdtList.stream().filter(String -> { + if(StringUtils.isNotBlank(String) && !String.contains("null")){ + return true; + } + return false; + }).collect(Collectors.toList()); + notExBtdList.addAll(exBdtList); + notExBtdList = notExBtdList.stream().distinct().collect(Collectors.toList()); + } + } + String btdStr = notExBtdList.stream().map(String::toString).collect(Collectors.joining(",")); + + // 1.1.1.1.2.3 更新 + UpdateWrapper updateWrapper = new UpdateWrapper(); + updateWrapper.eq("STAND_ID",updInfo.get(0).getId()); + updateWrapper.set("BDTBZH",btdStr); + iSarStandAttrInfoService.update(updateWrapper); + } + } + } + } + } + }); + + } + + } + + @Transactional(rollbackFor = {RuntimeException.class,Exception.class}) + public void dtAndBdtToBussData(){ + QueryWrapper wrapper = new QueryWrapper(); + wrapper.select("sar_bussioness_stand.*, r.DTQBBHBUSS, r.BDTQBBHBUSS"); + wrapper.last("LEFT JOIN sar_buss_stand_attr_info r ON r.STAND_ID = sar_bussioness_stand.ID WHERE sar_bussioness_stand.VALID_FLAG = '0' and sar_bussioness_stand.id in ('021b0c0c9e774ba9a76abbf923d59f5','jdmygltv37qvyb5s87ea')"); + List bussionessStands = iSarBussionessStandService.list(wrapper); + + if(!bussionessStands.isEmpty()){ + + + + // 1. 遍历全部数据 + bussionessStands.forEach(info -> { + // 1.1 判断代替标准号 + if(StringUtils.isNotBlank(info.getDTQBBHBUSS())){ + // 1.1.1 找出当前代替标准版所有被代替标准 + List dtList = Arrays.stream(info.getDTQBBHBUSS().split(",")).map(String::trim).collect(Collectors.toList()); + if(!dtList.isEmpty()){ + for (String s : dtList) { + + if(s.contains("null")){ + continue; + } + List bdtList = bussionessStands.stream().filter(info1 -> { + if(StringUtils.isNotBlank(info1.getDTQBBHBUSS()) && info1.getDTQBBHBUSS().contains(s)){ + return true; + } + return false; + }).collect(Collectors.toList()); + // 1.1.1.1合并被代替标准 + if(!bdtList.isEmpty()){ + // 1.1.1.1.1 获取需要更新的代替标准 + List updInfo = bussionessStands.stream().filter(info1 -> { + if(StringUtils.isNotBlank(info1.getStandCode()) && s.trim().equals(info1.getStandCode().trim())){ + return true; + } + return false; + }).collect(Collectors.toList()); + + + // 1.1.1.1.2 是否存在需要更新的代替标准 + if(!updInfo.isEmpty()){ + // 1.1.1.1.2.1 拼接 被代替标准号 + String btd = bdtList.stream().map(info1 -> { + String addStrandNumber = ""; + if (StringUtils.isNotEmpty(info1.getStandYear())) { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber() + "-" + info1.getStandYear(); + } else { + addStrandNumber = info1.getStandSort() + " " + info1.getStandNumber(); + } + return addStrandNumber; + }).collect(Collectors.joining(",")); + System.out.println(btd); + + // 1.1.1.1.2.2 找出已存在的被代替标准 及 去重, 如没找出，则使用最新被代替 + List notExBtdList = Arrays.stream(btd.split(",")).map(String::trim).collect(Collectors.toList()); + if(StringUtils.isNotBlank(updInfo.get(0).getBDTQBBHBUSS())){ + List exBdtList = Arrays.stream(updInfo.get(0).getBDTQBBHBUSS().split(",")).map(String::trim).collect(Collectors.toList()); + if(!exBdtList.isEmpty()){ + exBdtList = exBdtList.stream().filter(String -> { + if(StringUtils.isNotBlank(String) && !String.contains("null")){ + return true; + } + return false; + }).collect(Collectors.toList()); + notExBtdList.addAll(exBdtList); + notExBtdList = notExBtdList.stream().distinct().collect(Collectors.toList()); + } + } + String btdStr = notExBtdList.stream().map(String::toString).collect(Collectors.joining(",")); + + // 1.1.1.1.2.3 更新 + UpdateWrapper updateWrapper = new UpdateWrapper(); + updateWrapper.eq("STAND_ID",updInfo.get(0).getId()); + updateWrapper.set("BDTQBBHBUSS",btdStr); + iSarBussStandAttrInfoService.update(updateWrapper); + } + } + } + } + } + }); + + } + + } @Transactional(rollbackFor = {RuntimeException.class,Exception.class}) public String dataSync(){ diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/ISarBussionessStandService.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/ISarBussionessStandService.java index 1ab4392a..2806da9e 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/ISarBussionessStandService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarBussionessStand/service/ISarBussionessStandService.java @@ -20,6 +20,8 @@ import java.util.List; */ public interface ISarBussionessStandService extends IService { + void updateCiteStand(SarBussionessStand sarBussionessStandEO, SarBussionessStand beforeSarStandardsInfo, String upField, String beUpedField); + SarBussionessStand getStandInfoByReviseStatus(String reviseStatus,String standSort,String taskId); void attrInfoDetails (SarBussionessStand row) throws Exception; 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 3aca0cb5..0efa0b7a 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 @@ -757,7 +757,7 @@ public class SarBussionessStandServiceImpl extends ServiceImpl queryByList(SarBussionessStandEOPage sarBussionessStandEOPage){ + sarBussionessStandEOPage.setValidFlag("0"); return this.baseMapper.queryByList(sarBussionessStandEOPage); } diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/ISarStandardsInfoService.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/ISarStandardsInfoService.java index f8cdc983..85d0593e 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/ISarStandardsInfoService.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/ISarStandardsInfoService.java @@ -19,6 +19,8 @@ import java.util.Map; */ public interface ISarStandardsInfoService extends IService { + void updateCiteStand(SarStandardsInfo sarStandardsInfoEO, SarStandardsInfo beforeSarStandardsInfo, String upField, String beUpedField); + // void reverseQueryStand(List ids, String standName,String type); List getSarStandardsInfoPage(SarStandardsInfoEOPage page) throws Exception; diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java index 1cbb819b..331cbcc8 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/sarStandardsInfo/service/impl/SarStandardsInfoServiceImpl.java @@ -1538,7 +1538,7 @@ public class SarStandardsInfoServiceImpl extends ServiceImpl - and stand_code ${standCodeOperator} #{standCode} + and trim(replace(stand_code,' ','')) ${standCodeOperator} trim(replace(#{standCode},' ','')) and id ${idOperator} #{id} From c86440eb96f8a193eb7cc910f5c7063ee998ce09 Mon Sep 17 00:00:00 2001 From: "396572590@qq.com" Date: Wed, 10 Aug 2022 16:55:50 +0800 Subject: [PATCH 8/8] =?UTF-8?q?feat:=20There=20is=20no=20way=20the,=20=20?= =?UTF-8?q?=E6=A0=87=E5=87=86=20=E8=A2=AB=E4=BB=A3=E6=9B=BF=20=E8=A1=A5?= =?UTF-8?q?=E6=BC=8F=E3=80=82=E3=80=82=20=E8=AF=A6=E6=83=85=E7=82=B9?= =?UTF-8?q?=E5=87=BB=E4=BB=A3=E6=9B=BF=E3=80=81=E8=A2=AB=E4=BB=A3=E6=9B=BF?= =?UTF-8?q?=E6=A0=87=E5=87=86=E6=95=88=E9=AA=8C=E6=8E=A5=E5=8F=A3=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java index 8855c313..31c4d65b 100644 --- a/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java +++ b/adc-da-slrs/src/main/java/com/adc/da/slrs/DataSync/service/impl/DataSyncServiceImpl.java @@ -165,6 +165,7 @@ public class DataSyncServiceImpl implements IDataSyncService { } @Transactional(rollbackFor = {RuntimeException.class,Exception.class}) + @Async public void dtAndBdtToBussData(){ QueryWrapper wrapper = new QueryWrapper(); wrapper.select("sar_bussioness_stand.*, r.DTQBBHBUSS, r.BDTQBBHBUSS");