From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/service/impl/mq/MQUnSendInfoServiceImpl.java | 106 ++++++++++++++++++++++++++-------------------------- 1 files changed, 53 insertions(+), 53 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/mq/MQUnSendInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/mq/MQUnSendInfoServiceImpl.java index cc8cd30..9b49b89 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/mq/MQUnSendInfoServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/mq/MQUnSendInfoServiceImpl.java @@ -1,53 +1,53 @@ -package com.yeshi.fanli.service.impl.mq; - -import java.util.Date; -import java.util.List; - -import javax.annotation.Resource; - -import org.springframework.stereotype.Service; - -import com.yeshi.fanli.dao.mybatis.mq.MQUnSendInfoMapper; -import com.yeshi.fanli.entity.mq.MQUnSendInfo; -import com.yeshi.fanli.exception.mq.MQUnSendInfoException; -import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService; -import com.yeshi.fanli.util.StringUtil; - -@Service -public class MQUnSendInfoServiceImpl implements MQUnSendInfoService { - - @Resource - private MQUnSendInfoMapper mqUnSendInfoMapper; - - @Override - public void addMQUnSendInfo(MQUnSendInfo info) throws MQUnSendInfoException { - if (StringUtil.isNullOrEmpty(info.getTag()) || StringUtil.isNullOrEmpty(info.getTopic()) - || StringUtil.isNullOrEmpty(info.getBody()) || StringUtil.isNullOrEmpty(info.getKey())) { - throw new MQUnSendInfoException(1, "淇℃伅涓嶅畬鏁�"); - } - MQUnSendInfo oldInfo = mqUnSendInfoMapper.selectByTopicTagAndKey(info.getTopic(), info.getTag(), info.getKey()); - if (oldInfo != null) - return; - if (info.getLastSendTime() == null) - info.setLastSendTime(new Date()); - mqUnSendInfoMapper.insertSelective(info); - } - - @Override - public List<MQUnSendInfo> listByMaxSendTime(Date maxSendTime, int page, int pageSize) { - return mqUnSendInfoMapper.listByMaxSendTime(maxSendTime, (page - 1) * pageSize, pageSize); - } - - @Override - public void deleteByPrimaryKey(Long id) { - mqUnSendInfoMapper.deleteByPrimaryKey(id); - } - - @Override - public void updateSendTime(Long id, Date sendTime) { - MQUnSendInfo info = new MQUnSendInfo(); - info.setId(id); - info.setLastSendTime(sendTime); - mqUnSendInfoMapper.updateByPrimaryKeySelective(info); - } -} +package com.yeshi.fanli.service.impl.mq; + +import java.util.Date; +import java.util.List; + +import javax.annotation.Resource; + +import org.springframework.stereotype.Service; + +import com.yeshi.fanli.dao.mybatis.mq.MQUnSendInfoMapper; +import com.yeshi.fanli.entity.mq.MQUnSendInfo; +import com.yeshi.fanli.exception.mq.MQUnSendInfoException; +import com.yeshi.fanli.service.inter.mq.MQUnSendInfoService; +import com.yeshi.fanli.util.StringUtil; + +@Service +public class MQUnSendInfoServiceImpl implements MQUnSendInfoService { + + @Resource + private MQUnSendInfoMapper mqUnSendInfoMapper; + + @Override + public void addMQUnSendInfo(MQUnSendInfo info) throws MQUnSendInfoException { + if (StringUtil.isNullOrEmpty(info.getTag()) || StringUtil.isNullOrEmpty(info.getTopic()) + || StringUtil.isNullOrEmpty(info.getBody()) || StringUtil.isNullOrEmpty(info.getKey())) { + throw new MQUnSendInfoException(1, "淇℃伅涓嶅畬鏁�"); + } + MQUnSendInfo oldInfo = mqUnSendInfoMapper.selectByTopicTagAndKey(info.getTopic(), info.getTag(), info.getKey()); + if (oldInfo != null) + return; + if (info.getLastSendTime() == null) + info.setLastSendTime(new Date()); + mqUnSendInfoMapper.insertSelective(info); + } + + @Override + public List<MQUnSendInfo> listByMaxSendTime(Date maxSendTime, int page, int pageSize) { + return mqUnSendInfoMapper.listByMaxSendTime(maxSendTime, (page - 1) * pageSize, pageSize); + } + + @Override + public void deleteByPrimaryKey(Long id) { + mqUnSendInfoMapper.deleteByPrimaryKey(id); + } + + @Override + public void updateSendTime(Long id, Date sendTime) { + MQUnSendInfo info = new MQUnSendInfo(); + info.setId(id); + info.setLastSendTime(sendTime); + mqUnSendInfoMapper.updateByPrimaryKeySelective(info); + } +} -- Gitblit v1.8.0