package org.springblade.modules.equipage.service.impl;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.springblade.core.log.exception.ServiceException;
|
import org.springblade.core.tool.utils.BeanUtil;
|
import org.springblade.modules.FTP.FtpUtil;
|
import org.springblade.modules.equipage.entity.Car;
|
import org.springblade.modules.equipage.entity.Gun;
|
import org.springblade.modules.equipage.excel.GunExcel;
|
import org.springblade.modules.equipage.excel.GunImporter;
|
import org.springblade.modules.equipage.mapper.GunMapper;
|
import org.springblade.modules.equipage.service.GunService;
|
import org.springblade.modules.equipage.vo.GunVo;
|
import org.springblade.modules.system.service.IUserDeptService;
|
import org.springblade.modules.system.service.MyAsyncService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.text.SimpleDateFormat;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 枪支服务实现类
|
* @author zhongrj
|
*/
|
@Service
|
public class GunServiceImpl extends ServiceImpl<GunMapper, Gun> implements GunService {
|
|
@Autowired
|
private IUserDeptService userDeptService;
|
@Autowired
|
private MyAsyncService myAsyncService;
|
|
/**
|
* 枪支分页信息
|
* @param page
|
* @param gun 枪支信息对象
|
* @return
|
*/
|
@Override
|
public IPage<GunVo> selectGunPage(IPage<GunVo> page, GunVo gun) {
|
return page.setRecords(baseMapper.selectGunPage(page, gun));
|
}
|
|
/**
|
* 详情
|
* @param gun 枪支信息对象
|
*/
|
@Override
|
public GunVo selectGunInfo(Gun gun) {
|
return baseMapper.selectGunInfo(gun);
|
}
|
|
|
/**
|
* 枪支导入
|
* @param data
|
* @param isCovered
|
* @param deptId
|
*/
|
@Override
|
public void importGun(List<GunExcel> data, Boolean isCovered, String deptId) {
|
if (data.size()>0){
|
//遍历
|
data.forEach(gunExcel -> {
|
Gun gun = Objects.requireNonNull(BeanUtil.copy(gunExcel, Gun.class));
|
//设置部门id
|
String deptIds = userDeptService.selectIn(gunExcel.getDeptId());
|
if (null!=deptIds && !deptIds.equals("")) {
|
if (null != deptId && !deptId.equals("")) {
|
if (!deptId.equals(deptIds)) {
|
throw new ServiceException("导入失败!不能导入不是本公司的枪支信息数据!");
|
}
|
}
|
gun.setDeptId(Long.parseLong(deptIds));
|
}else {
|
//如果deptIds 为空，则说明还没有改公司
|
throw new ServiceException("导入失败!公司名:["+gunExcel.getDeptId()+"]不存在!");
|
}
|
|
//脱敏处理
|
Gun gun1 = Objects.requireNonNull(BeanUtil.copy(gun, Gun.class));
|
gun1.setCardNumber("***");
|
gun1.setIssueTime(null);
|
gun1.setValidTime(null);
|
if (null!=gun1.getIssueUnit() && !gun1.getIssueUnit().equals("")){
|
gun1.setIssueUnit("***");
|
}
|
if (null!=gun1.getGunMode() && !gun1.getGunMode().equals("")){
|
gun1.setGunMode("***");
|
}
|
if (null!=gun1.getPersonInCharge() && !gun1.getPersonInCharge().equals("")){
|
gun1.setPersonInCharge("***");
|
}
|
if (null!=gun1.getCardNo() && !gun1.getCardNo().equals("")){
|
gun1.setCardNo("***");
|
}
|
|
//新增车辆数据
|
this.save(gun1);
|
|
//数据同步
|
String s1 =
|
"insert into sys_gun(id,issue_unit,card_number,gun_mode," +
|
"dept_id,person_in_charge,card_no) " +
|
"values(" + "'" + gun1.getId() + "'" + "," +
|
"'" + gun.getIssueUnit() + "'" + "," +
|
"'" + gun.getCardNumber() + "'" + "," +
|
"'" + gun.getGunMode() + "'" + "," +
|
"'" + gun.getDeptId() + "'" + "," +
|
"'" + gun.getPersonInCharge() + "'" + "," +
|
"'" +gun.getCardNo() + "'" + ")";
|
myAsyncService.FTP(s1);
|
|
});
|
}else {
|
throw new ServiceException("没有数据");
|
}
|
}
|
}
|
