From 6e4481f095c1c565c6e68e9fbd95ade3ff361210 Mon Sep 17 00:00:00 2001 From: xin <1099200748@qq.com> Date: Fri, 30 May 2025 17:38:08 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/feature-leomon' --- oying-system/src/main/java/com/oying/modules/message/service/impl/MessageOrderBuyerServiceImpl.java | 83 +++++++++++++++++++++++++++++++++++++++++ 1 files changed, 83 insertions(+), 0 deletions(-) diff --git a/oying-system/src/main/java/com/oying/modules/message/service/impl/MessageOrderBuyerServiceImpl.java b/oying-system/src/main/java/com/oying/modules/message/service/impl/MessageOrderBuyerServiceImpl.java new file mode 100644 index 0000000..212e818 --- /dev/null +++ b/oying-system/src/main/java/com/oying/modules/message/service/impl/MessageOrderBuyerServiceImpl.java @@ -0,0 +1,83 @@ +package com.oying.modules.message.service.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.oying.modules.message.domain.MessageOrderBuyer; +import com.oying.utils.FileUtil; +import lombok.RequiredArgsConstructor; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.oying.modules.message.service.MessageOrderBuyerService; +import com.oying.modules.message.domain.dto.MessageOrderBuyerQueryCriteria; +import com.oying.modules.message.mapper.MessageOrderBuyerMapper; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import com.oying.utils.PageUtil; +import java.util.List; +import java.util.Map; +import java.io.IOException; +import javax.servlet.http.HttpServletResponse; +import java.util.ArrayList; +import java.util.LinkedHashMap; +import com.oying.utils.PageResult; + +/** +* @description 服务实现 +* @author 李萌 +* @date 2025-05-20 +**/ +@Service +@RequiredArgsConstructor +public class MessageOrderBuyerServiceImpl extends ServiceImpl<MessageOrderBuyerMapper, MessageOrderBuyer> implements MessageOrderBuyerService { + + private final MessageOrderBuyerMapper messageOrderBuyerMapper; + + @Override + public PageResult<MessageOrderBuyer> queryAll(MessageOrderBuyerQueryCriteria criteria, Page<Object> page){ + return PageUtil.toPage(messageOrderBuyerMapper.findAll(criteria, page)); + } + + @Override + public List<MessageOrderBuyer> queryAll(MessageOrderBuyerQueryCriteria criteria){ + return messageOrderBuyerMapper.findAll(criteria); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void create(MessageOrderBuyer resources) { + messageOrderBuyerMapper.insert(resources); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void update(MessageOrderBuyer resources) { + MessageOrderBuyer messageOrderBuyer = getById(resources.getId()); + messageOrderBuyer.copy(resources); + messageOrderBuyerMapper.updateById(messageOrderBuyer); + } + + @Override + @Transactional(rollbackFor = Exception.class) + public void deleteAll(List<Integer> ids) { + messageOrderBuyerMapper.deleteBatchIds(ids); + } + + @Override + public void download(List<MessageOrderBuyer> all, HttpServletResponse response) throws IOException { + List<Map<String, Object>> list = new ArrayList<>(); + for (MessageOrderBuyer messageOrderBuyer : all) { + Map<String, Object> map = new LinkedHashMap<>(); + map.put("订单ID", messageOrderBuyer.getOrderId()); + map.put("消息类型(订单状态变化、订单送达)", messageOrderBuyer.getMessageType()); + map.put("消息内容", messageOrderBuyer.getMessageContent()); + map.put("跳转链接", messageOrderBuyer.getLink()); + map.put("创建时间", messageOrderBuyer.getCreateTime()); + list.add(map); + } + FileUtil.downloadExcel(list, response); + } + + @Override + public MessageOrderBuyer findByOrderId(Integer orderId) { + return baseMapper.selectOne(new QueryWrapper<MessageOrderBuyer>().eq("order_id", orderId)); + } +} -- Gitblit v1.9.3