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("approvalStatus",2)
|
.eq("status",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);
|
}
|
}
|
}
|
