AI架构师的诞生：AI+传统DDD模式 = 实现开发效率提升75%

重构前实现

重构后实现

实现特点:

• 代码行数: 主方法42行 + 核心调用链路约1,500行；

• 复杂度: 高度耦合，包含多种业务逻辑混合；

• 重复代码: 存在大量商品类型判断逻辑；

实现特点:

• 代码行数: 主方法37行 + 核心调用链路约720行；

• 复杂度: 通过领域服务解耦，逻辑清晰；

• 职责分离: 每个上下文专注自己的业务逻辑；

核心实现逻辑:

@Overridepublic SingleResponse<ConfirmableServiceProgramDTO>     queryConfirmableProgramList(ConfirmableProgramQuery query){        try {        // step.1 参数校验和门店信息获取        if (query == null || query.getShopId() == null) {            return SingleResponse.buildFailure("参数不能为空");        }                ShopInfoDTO shopInfo = shopQueryAbility.queryShopInfo(query.getShopId());        if (shopInfo == null) {            return SingleResponse.buildFailure("门店不存在");        }                // step.2 获取可签方案列表 - 复杂的扩展点机制        List<ServiceProgramDTO> programs = new ArrayList<>();                // 获取所有商品信息        List<GoodsDTO> allGoods = goodsQueryAbility.queryAllGoods();                for (GoodsDTO goods : allGoods) {            // 重复的商品类型判断逻辑 - 问题点1            if (switch51ConfigGateway.superClientGoodId().equals(goods.getGoodsId())) {                // 超客商品特殊处理                if (validateSuperClientGoods(goods, shopInfo)) {                    ServiceProgramDTO program = buildSuperClientProgram(goods, shopInfo);                    programs.add(program);                }            } elseif (switch51ConfigGateway.platformDeliveryGoodId().equals(goods.getGoodsId())) {                // 平台配送商品特殊处理                if (validatePlatformDeliveryGoods(goods, shopInfo)) {                    ServiceProgramDTO program = buildPlatformDeliveryProgram(goods, shopInfo);                    programs.add(program);                }            } elseif (switch51ConfigGateway.selfDeliveryGoodId().equals(goods.getGoodsId())) {                // 自配送商品特殊处理                if (validateSelfDeliveryGoods(goods, shopInfo)) {                    ServiceProgramDTO program = buildSelfDeliveryProgram(goods, shopInfo);                    programs.add(program);                }            }            // ... 更多商品类型判断        }                // step.3 价格计算 - 内嵌在业务服务中        for (ServiceProgramDTO program : programs) {            // 硬编码的价格计算逻辑 - 问题点2            if (program.getDeliveryType().equals("PLATFORM")) {                program.setCommissionRate(new BigDecimal("0.08")); // 8%                program.setDeliveryFee(calculatePlatformDeliveryFee(program, shopInfo));            } elseif (program.getDeliveryType().equals("SELF")) {                program.setCommissionRate(new BigDecimal("0.10")); // 10%                program.setDeliveryFee(calculateSelfDeliveryFee(program, shopInfo));            }                        // 保底价计算            BigDecimal basePrice = priceCalculateAbility.calculateBasePrice(                program.getGoodsId(), shopInfo.getCategoryId());            program.setBasePrice(basePrice);        }                // step.4 活动处理 - 分散的活动逻辑        List<ActivityDTO> activities = activityQueryAbility.queryShopActivities(query.getShopId());        for (ServiceProgramDTO program : programs) {            for (ActivityDTO activity : activities) {                // 活动匹配逻辑分散 - 问题点3                if (activity.getType().equals("COMMISSION_DISCOUNT")) {                    if (activity.getTargetGoods().contains(program.getGoodsId())) {                        BigDecimal discountRate = activity.getDiscountRate();                        BigDecimal newRate = program.getCommissionRate().subtract(discountRate);                        program.setCommissionRate(newRate);                        program.setActivityId(activity.getActivityId());                    }                } elseif (activity.getType().equals("DELIVERY_DISCOUNT")) {                    // 配送费优惠逻辑                    if (activity.getTargetGoods().contains(program.getGoodsId())) {                        BigDecimal discountFee = activity.getDiscountAmount();                        BigDecimal newFee = program.getDeliveryFee().subtract(discountFee);                        program.setDeliveryFee(newFee);                    }                }            }        }                // step.5 构建返回结果        ConfirmableServiceProgramDTO result = new ConfirmableServiceProgramDTO();        result.setShopId(query.getShopId());        result.setPrograms(programs);        result.setTotalCount(programs.size());                return SingleResponse.of(result);            } catch (Exception e) {        logger.error("查询可签方案失败，shopId：{}，异常：{}",             query.getShopId(), e.getMessage(), e);        return SingleResponse.buildFailure("查询失败");    }}
// 重复的商品校验方法 - 在多个地方重复出现private boolean validateSuperClientGoods(GoodsDTO goods, ShopInfoDTO shopInfo){    // 重复的商品类型判断逻辑    if (!switch51ConfigGateway.superClientGoodId().equals(goods.getGoodsId())) {        returnfalse;    }        // 区域校验逻辑内嵌    List<String> allowedCities = goods.getAllowedCities();    if (!allowedCities.contains(shopInfo.getCity())) {        returnfalse;    }        // 品类校验逻辑内嵌    List<Long> allowedCategories = goods.getAllowedCategories();    if (!allowedCategories.contains(shopInfo.getCategoryId())) {        returnfalse;    }        returntrue;}
// 类似的重复方法还有：// validatePlatformDeliveryGoods()// validateSelfDeliveryGoods()// buildSuperClientProgram()// buildPlatformDeliveryProgram()// buildSelfDeliveryProgram()

核心实现逻辑:

@Overridepublic SingleResponse<ConfirmableServiceProgramDTO>     queryConfirmableProgramList(ConfirmableProgramQuery query){        // step.1 获取门店信息 - 门店上下文    ShopDomain shopDomain = shopDomainService        .getShop(query.getShopId());        // step.2 查询可签合同列表 - 合同上下文    List<ShopContractDomain> contracts =         shopContractDomainService        .getShopConfirmableContractList(shopDomain);        // step.3 商品校验 - 商品上下文    contracts = goodsDomainService        .filterAvailableContracts(contracts, shopDomain);        // step.4 价格计算 - 价格上下文    contracts = priceDomainService        .enrichContractPrice(contracts);        // step.5 活动匹配 - 活动上下文    contracts = activityDomainService        .applyActivityDiscount(contracts, shopDomain);        // step.6 转换为DTO返回    ConfirmableServiceProgramDTO result =         buildConfirmableServiceProgramDTO(contracts);        return SingleResponse.of(result);}

问题点:

• 业务逻辑高度耦合在一个方法中；

• 商品类型判断逻辑重复出现；

• 扩展点机制复杂，难以维护；

• 缺乏清晰的职责分离。

优势:

• 清晰的步骤分离，每步职责单一；

• 通过领域服务实现业务逻辑解耦；

• 消除重复代码，提高可维护性；

• 支持开闭原则，易于扩展。