绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
1 天以前 762eba0553917215d158eac8575ac0437c3216a7 
 framework/src/main/java/cn/lili/modules/order/order/serviceimpl/OrderServiceImpl.java


@@ -16,6 +16,7 @@


import cn.lili.common.event.TransactionCommitSendMQEvent;


import cn.lili.common.exception.ServiceException;


import cn.lili.common.properties.RocketmqCustomProperties;


import cn.lili.common.security.AuthUser;


import cn.lili.common.security.OperationalJudgment;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.security.enums.UserEnums;


@@ -25,6 +26,7 @@


import cn.lili.modules.goods.entity.dos.Goods;


import cn.lili.modules.goods.entity.dto.GoodsCompleteMessage;


import cn.lili.modules.goods.service.GoodsService;


import cn.lili.modules.lmk.enums.general.AdminRoleEnum;


import cn.lili.modules.member.entity.dto.MemberAddressDTO;


import cn.lili.modules.order.cart.entity.dto.TradeDTO;


import cn.lili.modules.order.cart.entity.enums.DeliveryMethodEnum;


@@ -38,6 +40,9 @@


import cn.lili.modules.order.trade.entity.dos.OrderLog;


import cn.lili.modules.order.trade.service.OrderLogService;


import cn.lili.modules.payment.entity.enums.PaymentMethodEnum;


import cn.lili.modules.permission.entity.dos.AdminUser;


import cn.lili.modules.permission.service.AdminUserService;


import cn.lili.modules.permission.service.RoleService;


import cn.lili.modules.promotion.entity.dos.Pintuan;


import cn.lili.modules.promotion.service.PintuanService;


import cn.lili.modules.store.entity.dto.StoreDeliverGoodsAddressDTO;


@@ -61,6 +66,7 @@


import cn.lili.trigger.model.TimeTriggerMsg;


import cn.lili.trigger.util.DelayQueueTools;


import cn.lili.utils.COSUtil;


import cn.lili.utils.CommonUtil;


import com.baomidou.mybatisplus.core.conditions.Wrapper;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


@@ -88,7 +94,7 @@


import java.net.URLEncoder;


import java.util.*;


import java.util.stream.Collectors;




import cn.lili.modules.permission.entity.dos.Role;


/**


 * 子订单业务层实现


 *


@@ -175,6 +181,12 @@


    private GoodsService goodsService;


    @Autowired


    private COSUtil cosUtil;


    @Autowired


    private AdminUserService adminUserService;


    @Autowired


    private RoleService roleService;






    @Override


    @Transactional(rollbackFor = Exception.class)


    public void intoDB(TradeDTO tradeDTO) {


@@ -233,15 +245,61 @@


        QueryWrapper queryWrapper = orderSearchParams.queryWrapper();


        queryWrapper.groupBy("o.id");


        queryWrapper.orderByDesc("o.id");


        return this.baseMapper.queryByParams(PageUtil.initPage(orderSearchParams), queryWrapper);


        IPage<OrderSimpleVO> page =  this.baseMapper.queryByParams(PageUtil.initPage(orderSearchParams), queryWrapper);




        if (!adminUserService.havePermissionRole(AdminRoleEnum.ORDER_INFO_PERMISSION)){


            for (OrderSimpleVO vo : page.getRecords()){


                vo.setConsigneeName(CommonUtil.maskName(vo.getConsigneeName()));


                vo.setConsigneeMobile(CommonUtil.maskMobile(vo.getConsigneeMobile()));


            }


        }


        return page;


    }








    @Override


    public IPage<OrderSimpleXcxVO> queryByXcxParams(OrderSearchParams orderSearchParams) {


    public IPage<OrderSimpleXcxVO> queryByXcxParams(OrderSearchXcxParams orderSearchParams) {


        QueryWrapper queryWrapper = orderSearchParams.queryWrapper();


        queryWrapper.groupBy("o.id");


        queryWrapper.orderByDesc("o.id");


        IPage<OrderSimpleXcxVO>  iPage = this.baseMapper.queryByXcxParams(PageUtil.initPage(orderSearchParams), queryWrapper);


        Set<String> goodsIds = new HashSet<>();


        for (OrderSimpleXcxVO orderSimpleVO : iPage.getRecords()) {


            orderSimpleVO.setOrderItems(orderSimpleVO.initOrderItems());


            String groupGoodsId = orderSimpleVO.getGroupGoodsId();


            if (StringUtils.isNotBlank(groupGoodsId)) {


                goodsIds.addAll(Arrays.asList(groupGoodsId.split(",")));


            }


        }


        if (CollectionUtil.isNotEmpty(goodsIds)) {


            List<Goods> list = goodsService.list(Wrappers.<Goods>lambdaQuery().in(Goods::getId, goodsIds));


            Map<String, String> goodsVideos = list


                    .stream().collect(Collectors.toMap(Goods::getId, g->


                            StringUtils.isNotBlank(g.getGoodsVideo())?g.getGoodsVideo():""


                    ));


            iPage.getRecords().forEach(orderSimpleVO -> {


                orderSimpleVO.getOrderItems().forEach(orderItem -> {


                    String videoUrl = goodsVideos.get(orderItem.getGoodsId());


                    if (StringUtils.isNotBlank(videoUrl)&&!videoUrl.contains("http")) {


                        orderItem.setVideo(cosUtil.getPreviewUrl(videoUrl));


                    }


                    String image = orderItem.getImage();


                    if (StringUtils.isNotBlank(image)&&!image.contains("http")) {


                        orderItem.setImage(cosUtil.getPreviewUrl(image));


                    }


                });


            });


        }


        return iPage;


    }




    @Override


    public IPage<OrderSimpleXcxVO> querySupplierOrderParams(SupplierOrderSearchParams orderSearchParams) {


        QueryWrapper queryWrapper = orderSearchParams.queryWrapper();


        queryWrapper.groupBy("o.id");


        queryWrapper.orderByDesc("o.id");


        IPage<OrderSimpleXcxVO>  iPage = this.baseMapper.querySupplierOrderParams(PageUtil.initPage(orderSearchParams), queryWrapper);


        Set<String> goodsIds = new HashSet<>();


        for (OrderSimpleXcxVO orderSimpleVO : iPage.getRecords()) {


            orderSimpleVO.setOrderItems(orderSimpleVO.initOrderItems());


@@ -340,8 +398,17 @@




    @Override


    public void queryExportOrder(HttpServletResponse response, OrderSearchParams orderSearchParams) {


        List<OrderExportDTO> orderExportDTOS = this.baseMapper.queryExportOrder(orderSearchParams.queryWrapper());




        XSSFWorkbook workbook = initOrderExportData(this.baseMapper.queryExportOrder(orderSearchParams.queryWrapper()));


        if (!adminUserService.havePermissionRole(AdminRoleEnum.ORDER_INFO_PERMISSION)){


            for (OrderExportDTO vo : orderExportDTOS){


                vo.setConsigneeName(CommonUtil.maskName(vo.getConsigneeName()));


                vo.setConsigneeMobile(CommonUtil.maskMobile(vo.getConsigneeMobile()));


            }


        }






        XSSFWorkbook workbook = initOrderExportData(orderExportDTOS);


        try {


            // 设置响应头


            String fileName = URLEncoder.encode("订单列表", "UTF-8");