From 268463905d81ea27eb39e47362e7a972385c72fd Mon Sep 17 00:00:00 2001 From: sjssj Date: Sun, 1 Sep 2024 12:12:13 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84samples=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=EF=BC=8C=E5=88=A0=E9=99=A4=E6=93=8D=E4=BD=9C=E8=B5=B0gateway?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../craftsman/command/MetricDeleteCmdExe.java | 8 ++++---- .../craftsman/domain/gateway/MetricGateway.java | 1 + .../craftsman/gatewayimpl/MetricGatewayImpl.java | 12 +++++++++++- .../gatewayimpl/UserProfileGatewayImpl.java | 3 +++ 4 files changed, 19 insertions(+), 5 deletions(-) diff --git a/cola-samples/craftsman/craftsman-app/src/main/java/com/alibaba/craftsman/command/MetricDeleteCmdExe.java b/cola-samples/craftsman/craftsman-app/src/main/java/com/alibaba/craftsman/command/MetricDeleteCmdExe.java index fb86a139d..dd665838b 100644 --- a/cola-samples/craftsman/craftsman-app/src/main/java/com/alibaba/craftsman/command/MetricDeleteCmdExe.java +++ b/cola-samples/craftsman/craftsman-app/src/main/java/com/alibaba/craftsman/command/MetricDeleteCmdExe.java @@ -1,8 +1,8 @@ package com.alibaba.craftsman.command; import com.alibaba.cola.dto.Response; +import com.alibaba.craftsman.domain.gateway.MetricGateway; import com.alibaba.craftsman.dto.MetricDeleteCmd; -import com.alibaba.craftsman.gatewayimpl.database.MetricMapper; import org.springframework.stereotype.Component; import javax.annotation.Resource; @@ -17,12 +17,12 @@ public class MetricDeleteCmdExe{ @Resource - private MetricMapper metricMapper; + private MetricGateway metricGateway; public Response execute(MetricDeleteCmd cmd) { - metricMapper.delete(cmd.getMetricId(), cmd.getOperater()); + metricGateway.delete(cmd.getMetricId(), cmd.getOperater()); return Response.buildSuccess(); } -} \ No newline at end of file +} diff --git a/cola-samples/craftsman/craftsman-domain/src/main/java/com/alibaba/craftsman/domain/gateway/MetricGateway.java b/cola-samples/craftsman/craftsman-domain/src/main/java/com/alibaba/craftsman/domain/gateway/MetricGateway.java index 173079f3e..a8618eec7 100644 --- a/cola-samples/craftsman/craftsman-domain/src/main/java/com/alibaba/craftsman/domain/gateway/MetricGateway.java +++ b/cola-samples/craftsman/craftsman-domain/src/main/java/com/alibaba/craftsman/domain/gateway/MetricGateway.java @@ -19,4 +19,5 @@ public interface MetricGateway { List listByTechInfluence(String userId); BugMetric getBugMetric(String userId); AppMetric getAppMetric(String userId); + void delete(String id, String operator); } diff --git a/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/MetricGatewayImpl.java b/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/MetricGatewayImpl.java index 40b980e73..1d4eb1784 100644 --- a/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/MetricGatewayImpl.java +++ b/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/MetricGatewayImpl.java @@ -1,6 +1,7 @@ package com.alibaba.craftsman.gatewayimpl; import com.alibaba.craftsman.common.event.DomainEventPublisher; +import com.alibaba.craftsman.convertor.MetricConvertor; import com.alibaba.craftsman.domain.gateway.MetricGateway; import com.alibaba.craftsman.domain.metrics.MainMetricType; import com.alibaba.craftsman.domain.metrics.MetricItem; @@ -19,7 +20,6 @@ import com.alibaba.craftsman.gatewayimpl.rpc.BugMetricMapper; import com.alibaba.craftsman.gatewayimpl.rpc.dataobject.AppMetricDO; import com.alibaba.craftsman.gatewayimpl.rpc.dataobject.BugMetricDO; -import com.alibaba.craftsman.convertor.MetricConvertor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Component; @@ -51,6 +51,7 @@ public class MetricGatewayImpl implements MetricGateway { private DomainEventPublisher domainEventPublisher; + @Override public void save(MetricItem metricItem){ MetricDO metricDO = MetricConvertor.toDataObject(metricItem); @@ -64,6 +65,7 @@ public void save(MetricItem metricItem){ domainEventPublisher.publish(metricItemCreatedEvent); } + @Override public List listByTechContribution(String userId){ List metricDOList = metricMapper.listByMainMetric(userId, MainMetricType.TECH_CONTRIBUTION.getMetricCode()); RefactoringMetric refactoringMetric = new RefactoringMetric(); @@ -92,6 +94,7 @@ public List listByTechContribution(String userId){ return subMetricList; } + @Override public List listByTechInfluence(String userId){ List metricDOList = metricMapper.listByMainMetric(userId, MainMetricType.TECH_INFLUENCE.getMetricCode()); ATAMetric ataMetric = new ATAMetric(); @@ -124,6 +127,7 @@ public List listByTechInfluence(String userId){ return subMetricList; } + @Override public BugMetric getBugMetric(String userId){ BugMetricDO bugMetricDO = bugMetricMapper.getByUserId(userId); BugMetricItem bugMetricItem = new BugMetricItem(bugMetricDO.getBugCount(), bugMetricDO.getCheckInCodeCount()); @@ -132,6 +136,7 @@ public BugMetric getBugMetric(String userId){ return bugMetric; } + @Override public AppMetric getAppMetric(String userId){ List appMetricDOList = appMetricMapper.listByUserId(userId); AppMetric appMetric = new AppMetric(); @@ -142,4 +147,9 @@ public AppMetric getAppMetric(String userId){ }); return appMetric; } + + @Override + public void delete(String id, String operator) { + metricMapper.delete(id, operator); + } } diff --git a/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/UserProfileGatewayImpl.java b/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/UserProfileGatewayImpl.java index fa47469d2..c646d6d55 100644 --- a/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/UserProfileGatewayImpl.java +++ b/cola-samples/craftsman/craftsman-infrastructure/src/main/java/com/alibaba/craftsman/gatewayimpl/UserProfileGatewayImpl.java @@ -28,14 +28,17 @@ public class UserProfileGatewayImpl implements UserProfileGateway { private UserProfileMapper userProfileMapper; + @Override public void create(UserProfile userProfile) { userProfileMapper.create(UserProfileConvertor.toDataObjectForCreate(userProfile)); } + @Override public void update(UserProfile userProfile) { userProfileMapper.update(UserProfileConvertor.toDataObjectForUpdate(userProfile)); } + @Override public UserProfile getByUserId(String userId) { UserProfileDO userProfileDO = userProfileMapper.getByUserId(userId); if (userProfileDO == null) {