Commit afdd7be5 authored by 赵啸非's avatar 赵啸非

修改短信开关redis查询

parent 898cb092
...@@ -7,6 +7,7 @@ import com.mortals.framework.model.Context; ...@@ -7,6 +7,7 @@ import com.mortals.framework.model.Context;
import com.mortals.framework.service.ITask; import com.mortals.framework.service.ITask;
import com.mortals.framework.service.ITaskExcuteService; import com.mortals.framework.service.ITaskExcuteService;
import com.mortals.xhx.base.system.user.model.UserEntity; import com.mortals.xhx.base.system.user.model.UserEntity;
import com.mortals.xhx.base.system.user.model.UserQuery;
import com.mortals.xhx.base.system.user.service.UserService; import com.mortals.xhx.base.system.user.service.UserService;
import com.mortals.xhx.common.pdu.RespData; import com.mortals.xhx.common.pdu.RespData;
import com.mortals.xhx.common.pdu.user.UserPdu; import com.mortals.xhx.common.pdu.user.UserPdu;
...@@ -48,7 +49,10 @@ public class SyncUserTaskImpl implements ITaskExcuteService { ...@@ -48,7 +49,10 @@ public class SyncUserTaskImpl implements ITaskExcuteService {
//更新本地用户信息,并且更新用户树 //更新本地用户信息,并且更新用户树
list.getData().getData().forEach(user -> { list.getData().getData().forEach(user -> {
//查询用户是否存在, //查询用户是否存在,
UserEntity userEntity = userService.get(user.getId()); //UserEntity userEntity = userService.get(user.getId());
UserEntity userEntity =userService.selectOne(new UserQuery().loginName(user.getLoginName()));
if (ObjectUtils.isEmpty(userEntity)) { if (ObjectUtils.isEmpty(userEntity)) {
//新增 //新增
UserEntity entity = new UserEntity(); UserEntity entity = new UserEntity();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment