@Transactional
public User userEdit(String name,String mobile,String pwd,String ip,String type,Integer companyId,Integer roleId){User user = new User();user.setLoginKey(mobile);user.setLoginPwd(pwd);if(StringUtils.isNotBlank(name)){user.setName(name);}else {user.setName(mobile);}user.setUserState(Enums.UserState.Normal);user.setUnlockTime(null);user.setErrorLoginCount(0);user.setLastLoginIp(ip);user.setLastLoginTime(new Date());if ("Driver".equalsIgnoreCase(type)){user.setType(Enums.UserType.Driver);dao.save(user);Driver driver = new Driver();driver.setUserId(user.getId());driver.setCompanyId(companyId);driverDao.save(driver);}else if ("Passenger".equalsIgnoreCase(type)){user.setType(Enums.UserType.Passenger);dao.save(user);Passenger passenger = new Passenger();passenger.setUserId(user.getId());passenger.setPhone(mobile);passengerDao.save(passenger);}else if ("Admin".equalsIgnoreCase(type)){user.setType(Enums.UserType.Admin);user.setRoles(roleId);dao.save(user);}return user;
}/*** 上报信息*/
@Async
public void mocpassengerUpload(String mobile){boolean update = true;MocPassengerInfo mocPassengerInfo = passengerInfoDao.getRepo().findByPhone(mobile);if (mocPassengerInfo == null){mocPassengerInfo = new MocPassengerInfo();update = false;}mocPassengerInfo.setPhone(mobile);mocPassengerInfo.setRegister(new Date());mocPassengerInfo.setStatus(mocService.upload("*",mocPassengerInfo, update ? MocInfo.Action.Update : MocInfo.Action.Add));passengerInfoDao.save(mocPassengerInfo);}

@PostMapping("/api/user/register")
public Result register(@Pattern(regexp = Const.REGEXP_MOBILE, message = "手机号[mobile]格式不正确") String mobile,@NotBlank(message = "密码[passwd]不能为空值") String passwd,@NotBlank(message = "用户类型[type]不能为空值") String type,String name,Integer companyId,Integer roleId,HttpServletRequest request){Map<String, Object> data = new HashMap<>();try {User users = userService.findUser(mobile,type);if (users!=null){return Result.fail(206, "用户已存在！");}if (CommonKit.passwdMD5(passwd).equalsIgnoreCase(CommonKit.passwd(mobile.substring(5)))) {return Result.fail(206, "密码过于简单，请更换密码");}if(companyId==null){companyId = Integer.valueOf(company);}User user = userService.userEdit(name,mobile, CommonKit.passwdMD5(passwd), IpKit.getIpAddr(request), type, companyId,roleId);data.put("uid", user.getId());data.put("token", tokenService.generate(user.getId(), 5*24*60));data.put("name", user.getName());data.put("mobile", user.getLoginKey());data.put("avatar", user.getPicUrl()!=null?rootUrl + user.getPicUrl():"");if(type.equals("Driver")){data.put("cname", companyInfoService.getDao().findSnapshoot(companyId).getName());}if(type.equals("Passenger")){userService.mocpassengerUpload(mobile);}}catch (Exception e){e.printStackTrace();return Result.error(901,"注册失败！");}return Result.ok(data);
}

package net.web.config;import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;import java.util.concurrent.Executor;@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {@Overridepublic Executor getAsyncExecutor() {//线程池设置ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();taskExecutor.setCorePoolSize( 10 );//核心线程taskExecutor.setMaxPoolSize( 100 );//最大线程taskExecutor.setQueueCapacity( 40 );//队列大小taskExecutor.setThreadNamePrefix( "async-service-" );taskExecutor.initialize();return taskExecutor;}@Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {//直接返回 祖籍 AsyncUncaughtExceptionHandler 对象return AsyncConfigurer.super.getAsyncUncaughtExceptionHandler();}
}