|
@@ -1,7 +1,9 @@
|
|
|
package com.ruoyi.basicData.service.impl;
|
|
|
|
|
|
+import com.ruoyi.basicData.domain.FleetCarManage;
|
|
|
import com.ruoyi.basicData.domain.FleetDriverMsg;
|
|
|
import com.ruoyi.basicData.domain.TCorps;
|
|
|
+import com.ruoyi.basicData.mapper.FleetCarManageMapper;
|
|
|
import com.ruoyi.basicData.mapper.FleetDriverMsgMapper;
|
|
|
import com.ruoyi.basicData.mapper.TCorpsMapper;
|
|
|
import com.ruoyi.basicData.service.IFleetDriverMsgService;
|
|
@@ -41,15 +43,9 @@ public class FleetDriverMsgServiceImpl implements IFleetDriverMsgService {
|
|
|
private TCorpsMapper corpsMapper;
|
|
|
|
|
|
@Autowired
|
|
|
- private FleetDriverMsgMapper fleetDriverMsgMapper;
|
|
|
-
|
|
|
- @Autowired
|
|
|
private SysRoleMapper roleMapper;
|
|
|
|
|
|
@Autowired
|
|
|
- private FtmsorderbillscarsMapper ftmsorderbillscarsMapper;
|
|
|
-
|
|
|
- @Autowired
|
|
|
private SysUserMapper userMapper;
|
|
|
|
|
|
@Autowired
|
|
@@ -58,6 +54,15 @@ public class FleetDriverMsgServiceImpl implements IFleetDriverMsgService {
|
|
|
@Autowired
|
|
|
private SysUserRoleMapper userRoleMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private FleetDriverMsgMapper fleetDriverMsgMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private FleetCarManageMapper fleetCarManageMapper;
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private FtmsorderbillscarsMapper ftmsorderbillscarsMapper;
|
|
|
+
|
|
|
/**
|
|
|
* 查询【司机】
|
|
|
*
|
|
@@ -105,20 +110,26 @@ public class FleetDriverMsgServiceImpl implements IFleetDriverMsgService {
|
|
|
tCorps.setfTypename("司机");
|
|
|
tCorps.setfStatus("0");
|
|
|
if (null != tCorps.getfId()) {
|
|
|
- updateDriverPhone(tCorps);
|
|
|
+// updateDriverPhone(tCorps);
|
|
|
+ AjaxResult result = this.updateFleetCarManagePhone(tCorps);
|
|
|
+ String ajaxCode = result.get("code").toString();
|
|
|
+ if ("500".equals(ajaxCode)) {
|
|
|
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
+ return result;
|
|
|
+ }
|
|
|
tCorps.setUpdateTime(new Date());
|
|
|
tCorps.setUpdateBy(SecurityUtils.getUsername());
|
|
|
corpsMapper.updateTCorps(tCorps);
|
|
|
return AjaxResult.success();
|
|
|
} else {
|
|
|
SysUser sysUser = new SysUser();
|
|
|
+ sysUser.setUserName(tCorps.getfTel());
|
|
|
sysUser.setPhonenumber(tCorps.getfTel());
|
|
|
- sysUser.setUserName(tCorps.getLoginAccount());
|
|
|
SysUser userPhone = userMapper.checkPhoneUnique(sysUser.getPhonenumber());
|
|
|
- if (userMapper.checkUserNameUnique(sysUser.getUserName()) > 1) {
|
|
|
- return AjaxResult.error("新增用户'" + sysUser.getUserName() + "'失败,登录账号已存在");
|
|
|
- } else if (StringUtils.isNotNull(userPhone) && "T".equals(userPhone.getRelatedNo())) {
|
|
|
+ if (StringUtils.isNotNull(userPhone) && "T".equals(userPhone.getRelatedNo())) {
|
|
|
return AjaxResult.error("新增用户'" + sysUser.getUserName() + "'失败,手机号码已存在");
|
|
|
+ } else if (userMapper.checkUserNameUnique(sysUser.getUserName()) > 1) {
|
|
|
+ return AjaxResult.error("新增用户'" + sysUser.getUserName() + "'失败,登录账号已存在");
|
|
|
}
|
|
|
long userId = 0L;
|
|
|
// 查询是否有用户提前关注小程序
|
|
@@ -127,9 +138,8 @@ public class FleetDriverMsgServiceImpl implements IFleetDriverMsgService {
|
|
|
// 该用户提前关注小程序了
|
|
|
user.setRelatedNo("T");
|
|
|
user.setUserSystem("2");
|
|
|
- user.setNickName(tCorps.getfName());
|
|
|
user.setUpdateTime(new Date());
|
|
|
- user.setStatus("0");
|
|
|
+ user.setNickName(tCorps.getfName());
|
|
|
user.setUpdateBy(SecurityUtils.getUsername());
|
|
|
user.setPassword(SecurityUtils.encryptPassword(tCorps.getfTel()));
|
|
|
userMapper.updateUser(user);
|
|
@@ -194,6 +204,51 @@ public class FleetDriverMsgServiceImpl implements IFleetDriverMsgService {
|
|
|
ftmsorderbillscarsMapper.updateftmsorderbillscarsDriverNamePhone();
|
|
|
}
|
|
|
|
|
|
+ @Transactional
|
|
|
+ public AjaxResult updateFleetCarManagePhone(TCorps tCorps) {
|
|
|
+ TCorps corps = corpsMapper.selectTCorpsById(tCorps.getfId());
|
|
|
+ SysUser sysUser = userMapper.selectUserByTel(corps.getfTel());
|
|
|
+ if (StringUtils.isNotNull(sysUser)) {
|
|
|
+ SysUser user = new SysUser();
|
|
|
+ // 跟新用户手机号以及姓名
|
|
|
+ sysUser.setNickName(tCorps.getfName());
|
|
|
+ if (!sysUser.getPhonenumber().equals(tCorps.getfTel())) {
|
|
|
+ user.setUserSystem("2");
|
|
|
+ user.setUserType("11");
|
|
|
+ user.setUserName(tCorps.getfTel());
|
|
|
+ user.setNickName(tCorps.getfName());
|
|
|
+ user.setPhonenumber(tCorps.getfTel());
|
|
|
+ user.setPassword(SecurityUtils.encryptPassword(tCorps.getfTel()));
|
|
|
+ user.setCreateTime(new Date());
|
|
|
+ user.setCreateBy(SecurityUtils.getUsername());
|
|
|
+ userMapper.insertUser(user);
|
|
|
+ // 查询是否存在车队 角色
|
|
|
+ SysRole role = roleMapper.selectRoleByName("司机");
|
|
|
+ if (StringUtils.isNull(role)) {
|
|
|
+ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
+ return AjaxResult.error("未找到司机角色,请创建司机角色后提交");
|
|
|
+ }
|
|
|
+ // 创建用户与角色关联
|
|
|
+ List<SysUserRole> list = new ArrayList<SysUserRole>();
|
|
|
+ SysUserRole sysUserRole = new SysUserRole();
|
|
|
+ sysUserRole.setRoleId(role.getRoleId());
|
|
|
+ sysUserRole.setUserId(user.getUserId());
|
|
|
+ list.add(sysUserRole);
|
|
|
+ userRoleMapper.batchUserRole(list);
|
|
|
+ }
|
|
|
+ sysUser.setUpdateTime(new Date());
|
|
|
+ sysUser.setUpdateBy(SecurityUtils.getUsername());
|
|
|
+ userMapper.updateUser(sysUser);
|
|
|
+ }
|
|
|
+ FleetCarManage fleetCarManage = new FleetCarManage();
|
|
|
+ fleetCarManage.setDriverId(tCorps.getfId());
|
|
|
+ fleetCarManage.setDriverTel(tCorps.getfTel());
|
|
|
+ fleetCarManage.setDriverName(tCorps.getfName());
|
|
|
+ fleetCarManageMapper.updateFleetCarManageByDriverId(fleetCarManage);
|
|
|
+ return AjaxResult.success();
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
/**
|
|
|
* 修改【司机】
|
|
|
*
|