From b397b0aefc81cb0475d347ebad16e565254c06e2 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 18 三月 2023 17:28:38 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TSystemBulletinServiceImpl.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 56 insertions(+), 0 deletions(-)
diff --git a/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TSystemBulletinServiceImpl.java b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TSystemBulletinServiceImpl.java
new file mode 100644
index 0000000..105c494
--- /dev/null
+++ b/management/guns-admin/src/main/java/com/stylefeng/guns/modular/system/service/impl/TSystemBulletinServiceImpl.java
@@ -0,0 +1,56 @@
+package com.stylefeng.guns.modular.system.service.impl;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.stylefeng.guns.modular.system.dao.TDriverMapper;
+import com.stylefeng.guns.modular.system.enums.UserTypeEnum;
+import com.stylefeng.guns.modular.system.model.TDriver;
+import com.stylefeng.guns.modular.system.model.TSystemBulletin;
+import com.stylefeng.guns.modular.system.dao.TSystemBulletinMapper;
+import com.stylefeng.guns.modular.system.model.TSystemBulletinUser;
+import com.stylefeng.guns.modular.system.service.ITSystemBulletinService;
+import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.stylefeng.guns.modular.system.service.ITSystemBulletinUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * <p>
+ * 系统公告 服务实现类
+ * </p>
+ *
+ * @author stylefeng
+ * @since 2023-03-16
+ */
+@Service
+public class TSystemBulletinServiceImpl extends ServiceImpl<TSystemBulletinMapper, TSystemBulletin> implements ITSystemBulletinService {
+
+ @Autowired
+ private ITSystemBulletinUserService tSystemBulletinUserService;
+ @Autowired
+ private TDriverMapper tDriverMapper;
+
+ @Override
+ public void sendBulletin(TSystemBulletin tSystemBulletin) {
+ // 判断发送状态
+ if(2 == tSystemBulletin.getState()){
+ // 查找所有司机
+ List<TDriver> list = tDriverMapper.selectList(new EntityWrapper<TDriver>().eq("id",1));
+ List<TSystemBulletinUser> tSystemBulletinUsers = new ArrayList<>(list.size());
+ for (TDriver tDriver : list) {
+ TSystemBulletinUser tSystemBulletinUser = new TSystemBulletinUser();
+ tSystemBulletinUser.setCreateTime(new Date());
+ tSystemBulletinUser.setStatus(1);
+ tSystemBulletinUser.setSystemBulletinId(tSystemBulletin.getId());
+ tSystemBulletinUser.setUserId(tDriver.getId());
+ tSystemBulletinUser.setUserType(UserTypeEnum.DRIVER.getCode());
+ tSystemBulletinUser.setIsRead(0);
+ tSystemBulletinUsers.add(tSystemBulletinUser);
+ }
+ tSystemBulletinUserService.insertBatch(tSystemBulletinUsers);
+ }
+ }
+}
--
Gitblit v1.7.1