|
|
@@ -17,10 +17,12 @@ import cn.hutool.core.collection.CollStreamUtil;
|
|
|
import cn.hutool.core.util.IdUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import vip.xiaonuo.common.enums.CommonSortOrderEnum;
|
|
|
@@ -40,6 +42,7 @@ import vip.xiaonuo.sys.modular.user.mapper.SysUserMapper;
|
|
|
import javax.annotation.Resource;
|
|
|
import java.util.Date;
|
|
|
import java.util.List;
|
|
|
+import java.util.concurrent.atomic.AtomicInteger;
|
|
|
|
|
|
/**
|
|
|
* 下发用户日志表Service接口实现类
|
|
|
@@ -47,8 +50,12 @@ import java.util.List;
|
|
|
* @author pans
|
|
|
* @date 2025/09/04 14:40
|
|
|
**/
|
|
|
+@Slf4j
|
|
|
@Service
|
|
|
public class CollegeUserServiceImpl extends ServiceImpl<CollegeUserMapper, CollegeUser> implements CollegeUserService {
|
|
|
+
|
|
|
+ private AtomicInteger userAddCounter = new AtomicInteger(0);
|
|
|
+
|
|
|
@Resource
|
|
|
private SysUserMapper sysUserMapper;
|
|
|
@Override
|
|
|
@@ -67,6 +74,8 @@ public class CollegeUserServiceImpl extends ServiceImpl<CollegeUserMapper, Colle
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
@Override
|
|
|
public void add(CollegeUserAddParam collegeUserAddParam) {
|
|
|
+ int count = userAddCounter.incrementAndGet();
|
|
|
+ log.info("下发用户数据========================>"+JSON.toJSONString(collegeUserAddParam));
|
|
|
//添加用户下发日志表
|
|
|
CollegeUser collegeUser = BeanUtil.toBean(collegeUserAddParam, CollegeUser.class);
|
|
|
collegeUser.setCrateTime(new Date());
|
|
|
@@ -86,6 +95,7 @@ public class CollegeUserServiceImpl extends ServiceImpl<CollegeUserMapper, Colle
|
|
|
sysUser.setEmail(collegeUser.getEmail()); //邮箱
|
|
|
sysUser.setPhone(collegeUser.getPhone()); //电话
|
|
|
sysUser.setIdCardNumber(collegeUser.getPsptId()); //身份证号
|
|
|
+ sysUser.setEduIdentity("1"); //身份认证
|
|
|
if("0".equals(collegeUser.getSex())){ //性别
|
|
|
sysUser.setGender("男");
|
|
|
}else if("1".equals(collegeUser.getSex())){
|
|
|
@@ -117,6 +127,7 @@ public class CollegeUserServiceImpl extends ServiceImpl<CollegeUserMapper, Colle
|
|
|
user.setEmail(collegeUser.getEmail());
|
|
|
user.setPhone(collegeUser.getPhone());
|
|
|
user.setIdCardNumber(collegeUser.getPsptId());
|
|
|
+ user.setEduIdentity("1");
|
|
|
if("0".equals(collegeUser.getSex())){
|
|
|
user.setGender("男");
|
|
|
}else if("1".equals(collegeUser.getSex())){
|
|
|
@@ -135,8 +146,8 @@ public class CollegeUserServiceImpl extends ServiceImpl<CollegeUserMapper, Colle
|
|
|
user.setCreateTime(new Date());
|
|
|
sysUserMapper.insert(user);
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
+ log.info("用户数据下发成功:{}", JSON.toJSONString(collegeUserAddParam));
|
|
|
+ log.info("用户数据下发成功,下发条数:{}",count);
|
|
|
}
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class)
|