From 3849263b31a16a91ff08acaa42786ecfde76f33c Mon Sep 17 00:00:00 2001
From: zhangback <zhangback@163.com>
Date: 星期四, 27 十一月 2025 20:18:08 +0800
Subject: [PATCH] 提交

---
 tms/src/main/java/com/ruoyi/tms/service/impl/TmsMessageNotifyServiceImpl.java |  182 +++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 182 insertions(+), 0 deletions(-)

diff --git a/tms/src/main/java/com/ruoyi/tms/service/impl/TmsMessageNotifyServiceImpl.java b/tms/src/main/java/com/ruoyi/tms/service/impl/TmsMessageNotifyServiceImpl.java
new file mode 100644
index 0000000..4230bde
--- /dev/null
+++ b/tms/src/main/java/com/ruoyi/tms/service/impl/TmsMessageNotifyServiceImpl.java
@@ -0,0 +1,182 @@
+package com.ruoyi.tms.service.impl;
+
+import java.util.List;
+
+import com.ruoyi.common.utils.DateUtils;
+import javax.annotation.Resource;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.stereotype.Service;
+import org.springframework.scheduling.annotation.Async;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import com.ruoyi.common.utils.PageUtils;
+import com.ruoyi.common.constant.Constants;
+import com.ruoyi.common.annotation.DataSource;
+import com.ruoyi.common.enums.DataSourceType;
+import com.ruoyi.common.core.service.BaseService;
+
+import com.ruoyi.tms.mapper.TmsMessageNotifyMapper;
+import com.ruoyi.tms.domain.TmsMessageNotify;
+import com.ruoyi.tms.service.ITmsMessageNotifyService;
+import com.ruoyi.common.core.text.Convert;
+
+/**
+ * 娑堟伅閫氱煡Service涓氬姟灞傚鐞�
+ *
+ * @author ruoyi
+ * @date 2025-11-26
+ */
+@Service
+@Transactional(rollbackFor = Exception.class)
+public class TmsMessageNotifyServiceImpl  extends BaseService<TmsMessageNotifyMapper, TmsMessageNotify> implements ITmsMessageNotifyService
+{
+    protected final Logger logger = LoggerFactory.getLogger(getClass());
+    @Resource
+    private TmsMessageNotifyMapper tmsMessageNotifyMapper;
+
+
+    /**
+     * 鏌ヨ娑堟伅閫氱煡
+     *
+     * @param id 娑堟伅閫氱煡ID
+     * @return 娑堟伅閫氱煡
+     */
+    @DataSource(DataSourceType.SLAVE)
+    @Override
+    public TmsMessageNotify selectTmsMessageNotifyById(Integer id)
+    {
+        return tmsMessageNotifyMapper.selectTmsMessageNotifyById(id);
+    }
+
+    /**
+     * 鏌ヨ娑堟伅閫氱煡 璁板綍鏁�
+     *
+     * @param tmsMessageNotify 娑堟伅閫氱煡
+     * @return 娑堟伅閫氱煡闆嗗悎
+     */
+    @DataSource(DataSourceType.SLAVE)
+    @Override
+    public int selectTmsMessageNotifyCount(TmsMessageNotify tmsMessageNotify)
+    {
+        return tmsMessageNotifyMapper.selectTmsMessageNotifyCount(tmsMessageNotify);
+    }
+
+    /**
+     * 鏌ヨ娑堟伅閫氱煡鍒楄〃
+     *
+     * @param tmsMessageNotify 娑堟伅閫氱煡
+     * @return 娑堟伅閫氱煡
+     */
+    @DataSource(DataSourceType.SLAVE)
+    @Override
+    public List<TmsMessageNotify> selectTmsMessageNotifyList(TmsMessageNotify tmsMessageNotify)
+    {
+        return tmsMessageNotifyMapper.selectTmsMessageNotifyList(tmsMessageNotify);
+    }
+
+    /**
+     * 鏌ヨ娑堟伅閫氱煡鍒楄〃 寮傛 瀵煎嚭
+     *
+     * @param tmsMessageNotify 娑堟伅閫氱煡
+     * @param exportKey 瀵煎嚭鍔熻兘鐨勫敮涓�鏍囪瘑
+     * @return 娑堟伅閫氱煡闆嗗悎
+     */
+    @DataSource(DataSourceType.SLAVE)
+    @Async
+    @Override
+    public void export(TmsMessageNotify tmsMessageNotify,String exportKey) {
+
+        super.export(TmsMessageNotify.class,exportKey,"tmsMessageNotifyData",(pageNum)->{
+            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
+            return selectTmsMessageNotifyList(tmsMessageNotify);
+        });
+    }
+
+
+    /**
+     * 鏂板娑堟伅閫氱煡
+     *
+     * @param tmsMessageNotify 娑堟伅閫氱煡
+     * @return 缁撴灉
+     */
+    @Override
+    public int insertTmsMessageNotify(TmsMessageNotify tmsMessageNotify)
+    {
+        tmsMessageNotify.setCreateTime(DateUtils.getNowDate());
+        return tmsMessageNotifyMapper.insertTmsMessageNotify(tmsMessageNotify);
+    }
+
+    /**
+     * 鏂板娑堟伅閫氱煡[鎵归噺]
+     *
+     * @param tmsMessageNotifys 娑堟伅閫氱煡
+     * @return 缁撴灉
+     */
+    @Override
+    public int insertTmsMessageNotifyBatch(List<TmsMessageNotify> tmsMessageNotifys)
+    {
+        int rows = tmsMessageNotifyMapper.insertTmsMessageNotifyBatch(tmsMessageNotifys);
+        return rows;
+    }
+
+    /**
+     * 淇敼娑堟伅閫氱煡
+     *
+     * @param tmsMessageNotify 娑堟伅閫氱煡
+     * @return 缁撴灉
+     */
+    @Override
+    public int updateTmsMessageNotify(TmsMessageNotify tmsMessageNotify)
+    {
+        tmsMessageNotify.setUpdateTime(DateUtils.getNowDate());
+        return tmsMessageNotifyMapper.updateTmsMessageNotify(tmsMessageNotify);
+    }
+
+    /**
+     * 淇敼娑堟伅閫氱煡[鎵归噺]
+     *
+     * @param tmsMessageNotifys 娑堟伅閫氱煡
+     * @return 缁撴灉
+     */
+    @Override
+    public int updateTmsMessageNotifyBatch(List<TmsMessageNotify> tmsMessageNotifys){
+        return tmsMessageNotifyMapper.updateTmsMessageNotifyBatch(tmsMessageNotifys);
+    }
+
+    /**
+     * 鍒犻櫎娑堟伅閫氱煡瀵硅薄
+     *
+     * @param ids 闇�瑕佸垹闄ょ殑鏁版嵁ID
+     * @return 缁撴灉
+     */
+    @Override
+    public int deleteTmsMessageNotifyByIds(String ids)
+    {
+        return deleteTmsMessageNotifyByIds(Convert.toIntArray(ids));
+    }
+
+    /**
+     * 鍒犻櫎娑堟伅閫氱煡瀵硅薄
+     *
+     *
+     * @param ids 闇�瑕佸垹闄ょ殑鏁版嵁ID
+     * @return 缁撴灉
+     */
+    @Override
+    public int deleteTmsMessageNotifyByIds(Integer[] ids)
+    {
+        return tmsMessageNotifyMapper.deleteTmsMessageNotifyByIds(ids);
+    }
+
+    /**
+     * 鍒犻櫎娑堟伅閫氱煡淇℃伅
+     *
+     * @param id 娑堟伅閫氱煡ID
+     * @return 缁撴灉
+     */
+    @Override
+    public int deleteTmsMessageNotifyById(Integer id)
+    {
+        return tmsMessageNotifyMapper.deleteTmsMessageNotifyById(id);
+    }
+}

--
Gitblit v1.8.0