设计模式-策略模式

策略模式：

　　属于行为模式,包含一个策略接口Strategy，四个以下（大于四个可以使用混合模式）的策略实现类，

　　一个使用该策略的类Context

实例：两个角色 厅店和能人  都有一个酬金明细，一个是分页查询厅店发放的酬金明细，一个是分页查询能人提现的酬金明细

1.一个策略接口Strategy

/**
 * 抽象酬金明细接口
 */
public interface MoneyDetailListPageStrategy {
    /**分页数据接口*/
    ResultJson getMoneyDetailListPage(MoneyDetailListPageVo pageVo, CpUserInfoDto userInfo);
}

2。策略实现类

　　2.1 能人角色的提现酬金明细

package com.inphase.demo.handler;

import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.inphase.ableperson.entity.CpOtherNeedsModel;
import com.inphase.ableperson.mapper.CpNeedsReportModelMapper;
import com.inphase.ableperson.mapper.CpOtherNeedsModelMapper;
import com.inphase.demo.common.domain.ResultJson;
import com.inphase.demo.entity.CpUserInfoDto;
import com.inphase.demo.entity.MoneyDetailListPage;
import com.inphase.demo.entity.MoneyDetailListPageDto;
import com.inphase.demo.mapper.user.CpReconciliationStatementMapper;
import com.inphase.demo.vo.MoneyDetailListPageVo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 能人分页查询酬金明细
 */
@Component("AblePersonMoneyDetailListPageStrategy")
@Slf4j
public class AblePersonMoneyDetailListPageStrategy implements MoneyDetailListPageStrategy{

    @Resource
    CpReconciliationStatementMapper cpReconciliationStatementMapper;
    @Resource
    CpNeedsReportModelMapper cpNeedsReportModelMapper;
    @Resource
    CpOtherNeedsModelMapper cpOtherNeedsModelMapper;

    @Override
    public ResultJson getMoneyDetailListPage(MoneyDetailListPageVo pageVo, CpUserInfoDto userInfo) {
        Map<String,Object> resultMap = new HashMap<>();
        pageVo.setPageNum((pageVo.getPageNum()-1)*pageVo.getPageSize());
        List<MoneyDetailListPageDto> moneyDetailListPageDtos = Optional.ofNullable(cpReconciliationStatementMapper.selectMoneyDetailListPage(userInfo.getMaId(), pageVo)).orElse(new ArrayList<>());
        int total = cpReconciliationStatementMapper.selectFountRows();
        log.info("查询明细数量："+moneyDetailListPageDtos.size());
        List<MoneyDetailListPage> moneyDetailListPages = null;
        if (moneyDetailListPageDtos.size()>0) {
            //1.根据
            moneyDetailListPages = moneyDetailListPageDtos.stream().map(dto -> {
                MoneyDetailListPage page = new MoneyDetailListPage();
                BeanUtils.copyProperties(dto, page);
                //参数赋值
                if (dto.getFlag() == 1) { //收入
                    if (ObjectUtil.isNotEmpty(dto.getAddTime())) {
                        Calendar c = Calendar.getInstance();

                        c.setTimeInMillis(dto.getAddTime() * 1000);
                        page.setAddTime(c.getTime());
                    }
                    if (ObjectUtil.isNotEmpty(dto.getOrderState())) {
                        String orderStateName = dto.getOrderState() == 1 ? "基本酬金" : "业务提成";
                        page.setOrderStateName(orderStateName);
                    }

                }
                if (dto.getFlag() == 2 && ObjectUtil.isNotEmpty(dto.getWithdrawStatus())) {
                    if (dto.getWithdrawStatus() == 3) { //提现完成
                        page.setWithdrawStatus(1);
                        page.setWithdrawStatusName("提现成功");
                    } else { //其余提现中
                        page.setWithdrawStatus(0);
                        page.setWithdrawStatusName("提现中");
                    }
                }
                return page;
            }).collect(Collectors.toList());
            dealWithOrderVal(moneyDetailListPages);
        }
        resultMap.put("total",total);

        resultMap.put("moneyDetailListPages",Optional.ofNullable(moneyDetailListPages).orElse(new ArrayList<>()));

        return ResultJson.success(resultMap);
    }

    //根据模板类型和模板id 赋值订单需求类型
    private void dealWithOrderVal(List<MoneyDetailListPage> moneyDetailListPages){
        moneyDetailListPages //只有收入才有详情
                .forEach(moneyDetailListPage -> {
                    System.out.println("moneyDetailListPage:"+moneyDetailListPage);
                    Integer modelType = moneyDetailListPage.getModelType();
                    if (ObjectUtil.isNotEmpty(modelType) &&  modelType==1){
                        Map<String, Object> map = cpNeedsReportModelMapper.commonDemandTem(moneyDetailListPage.getModelId());
                        moneyDetailListPage.setNeedsTypeName(map.get("nr_type_name")+"");
                    }
                    if (ObjectUtil.isNotEmpty(modelType) && modelType ==2){
                        QueryWrapper<CpOtherNeedsModel> otherWrapper = new QueryWrapper();
                        otherWrapper.eq("cp_o_id", moneyDetailListPage.getModelId());
                        CpOtherNeedsModel cpOtherNeedsModel = cpOtherNeedsModelMapper.selectOne(otherWrapper);
                        moneyDetailListPage.setNeedsTypeName(cpOtherNeedsModel.getNeedsDesc());
                    }
                });
    }
}

　　2.2 厅店角色的发放酬金明细

package com.inphase.demo.handler;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.inphase.ableperson.entity.CpNeedsFormOrder;
import com.inphase.ableperson.entity.CpOtherNeedsModel;
import com.inphase.ableperson.mapper.CpNeedsFormOrderMapper;
import com.inphase.ableperson.mapper.CpNeedsReportModelMapper;
import com.inphase.ableperson.mapper.CpOtherNeedsModelMapper;
import com.inphase.demo.common.domain.ResultJson;
import com.inphase.demo.entity.CpUserInfoDto;
import com.inphase.demo.entity.HallMoneyDetailListPage;
import com.inphase.demo.entity.HallMoneyDetailListPageDto;
import com.inphase.demo.entity.MoneyDetailListPage;
import com.inphase.demo.vo.MoneyDetailListPageVo;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.util.*;
import java.util.stream.Collectors;

/**
 * 厅店分页查询酬金明细
 */
@Component("HallMoneyDetailListPageStrategy")
@Slf4j
public class HallMoneyDetailListPageStrategy implements MoneyDetailListPageStrategy{

    @Resource
    private CpNeedsFormOrderMapper cpNeedsFormOrderMapper;

    @Resource
    CpNeedsReportModelMapper cpNeedsReportModelMapper;
    @Resource
    CpOtherNeedsModelMapper cpOtherNeedsModelMapper;

    @Override
    public ResultJson getMoneyDetailListPage(MoneyDetailListPageVo pageVo, CpUserInfoDto userInfo) {
        pageVo.setSmId(userInfo.getCpStoreMessageDtoList().get(0).getSmId());//TODO 单个厅店登录  临时
        Map<String,Object> resultMap = new HashMap<>();
        pageVo.setPageNum((pageVo.getPageNum()-1)*pageVo.getPageSize());
        List<HallMoneyDetailListPageDto> hallMoneyDetailListPageDtos =  Optional.ofNullable(cpNeedsFormOrderMapper.getHallMoneyDetailListPage(pageVo)).orElse(new ArrayList<>());
        int total = cpNeedsFormOrderMapper.selectFoundRows();
        log.info("查询已经发放订单基础信息明细数量："+hallMoneyDetailListPageDtos.size());
        List<HallMoneyDetailListPage> hallMoneyDetailListPages = hallMoneyDetailListPageDtos.stream().map(dto -> {
            HallMoneyDetailListPage page = new HallMoneyDetailListPage();
            BeanUtils.copyProperties(dto, page);
            page.setAddTime(DateUtil.date(dto.getAddTime()*1000));
            page.setFormOrderCheckTime(DateUtil.date(dto.getFormOrderCheckTime()*1000));
            //订单状态修改 订单状态1、酬金待审核；2、酬金审核通过；3、酬金审核不通过；4、酬金待提现（稽核后）；5、酬金已提现（提现后）；6、提成待审核；7、提成审核通过；8、提成审核未通过；9、提成待提现（稽核后）；10、提成已提现（提现后）',
            page.setFormOrderStauts(1);
            page.setFormOrderStautsName("发放成功");
            List<Integer> sendingStatus = Arrays.asList(2, 4, 7, 9);
            List<Integer> successStatus = Arrays.asList(5,10);
            Integer orderStauts = dto.getFormOrderStauts();
            if (sendingStatus.contains(orderStauts) ){
                page.setWithDrawalStateName("发放中");
            }
            if (successStatus.contains(orderStauts)){
                page.setWithDrawalStateName("发放成功");
            }
            return page;
        }).collect(Collectors.toList());
        dealWithOrderVal(hallMoneyDetailListPages);
        resultMap.put("total",total);
        resultMap.put("moneyDetailListPages",hallMoneyDetailListPages);
        return ResultJson.success(resultMap);
    }

    //根据模板类型和模板id 赋值订单需求类型
    private void dealWithOrderVal(List<HallMoneyDetailListPage> moneyDetailListPages){
        moneyDetailListPages
                .forEach(moneyDetailListPage -> {
                    //需求类型赋值
                    if (moneyDetailListPage.getModelType()==1){
                        Map<String, Object> map = cpNeedsReportModelMapper.commonDemandTem(moneyDetailListPage.getModelId());
                        moneyDetailListPage.setNeedsTypeName(map.get("nr_type_name")+"");
                    }
                    if (moneyDetailListPage.getModelType()==2){
                        QueryWrapper<CpOtherNeedsModel> otherWrapper = new QueryWrapper();
                        otherWrapper.eq("cp_o_id", moneyDetailListPage.getModelId());
                        CpOtherNeedsModel cpOtherNeedsModel = cpOtherNeedsModelMapper.selectOne(otherWrapper);
                        moneyDetailListPage.setNeedsTypeName(cpOtherNeedsModel.getNeedsDesc());
                    }

                });
    }


}

3.调用分页查询酬金明细的context类（spring的构造器注入）

package com.inphase.demo.handler;

import com.inphase.demo.common.domain.ResultJson;
import com.inphase.demo.entity.CpUserInfoDto;
import com.inphase.demo.vo.MoneyDetailListPageVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@Component
public class MoneyDetailListPageContext {

    @Autowired
    private Map<String, MoneyDetailListPageStrategy> strategyMap = new ConcurrentHashMap<>();

    public MoneyDetailListPageContext(Map<String, MoneyDetailListPageStrategy> strategyMap) {
        this.strategyMap.clear();
        strategyMap.forEach((k, v)-> this.strategyMap.put(k, v));
    }

    public ResultJson getMoneyDetailListPage(String strategy, MoneyDetailListPageVo listPageVo, CpUserInfoDto userInfo){
        return strategyMap.get(strategy).getMoneyDetailListPage(listPageVo,userInfo);
    }

}

4.调用不同的策略的Service层，其实也可以Service层作为context

/**
 * 用户登录注册
 */
@Service
@Slf4j
@Transactional
public class CpUserService {
     @Resource
    private MoneyDetailListPageContext moneyDetailListPageContext;
    
        /**
     * 获取金额明细信息
     * @param listPageVo 查询条件
     * @return 查询结果
     */
    public ResultJson getMoneyDetailListPage(MoneyDetailListPageVo listPageVo,CpUserInfoDto userInfo) {
        log.info("请求参数：MoneyDetailListPageVo==>"+listPageVo);
        log.info("请求参数：CpUserInfoDto==>"+userInfo);
        ResultJson resultJson;
        switch (listPageVo.getCpType()){
            case 1:
                resultJson = moneyDetailListPageContext.getMoneyDetailListPage("AblePersonMoneyDetailListPageStrategy", listPageVo, userInfo);
                break;
            case 2:
                resultJson = moneyDetailListPageContext.getMoneyDetailListPage("HallMoneyDetailListPageStrategy", listPageVo, userInfo);
                break;
            default:
                resultJson = ResultJson.error("请求参数cpType错误："+listPageVo.getCpType());
        }
        return resultJson;
    }
}