java/SuperSaveDriving.git

New file
			@@ -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);
			}
			}
			}