Commit 507758cd authored by 赵啸非's avatar 赵啸非

添加初始化数据库脚本

parent c70dc1a1
...@@ -66,9 +66,6 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity ...@@ -66,9 +66,6 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity
@Autowired @Autowired
private ResourceService resourceService; private ResourceService resourceService;
@Autowired
private SiteService siteService;
private void doHandlerUser(UserEntity entity) throws AppException { private void doHandlerUser(UserEntity entity) throws AppException {
if (StringUtils.isNotEmpty(entity.getLoginPwd())) { if (StringUtils.isNotEmpty(entity.getLoginPwd())) {
...@@ -311,7 +308,7 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity ...@@ -311,7 +308,7 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity
Context context = new Context(); Context context = new Context();
context.setUser(entity); context.setUser(entity);
ThreadPool.getInstance().execute(new SyncTreeSiteThread(siteService, context)); ThreadPool.getInstance().execute(new SyncTreeSiteThread( context));
} else { } else {
//更新 //更新
UserEntity userEntity = new UserEntity(); UserEntity userEntity = new UserEntity();
...@@ -319,7 +316,7 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity ...@@ -319,7 +316,7 @@ public class UserServiceImpl extends AbstractCRUDServiceImpl<UserDao, UserEntity
this.updateWidthDao(userEntity); this.updateWidthDao(userEntity);
Context context = new Context(); Context context = new Context();
context.setUser(userEntity); context.setUser(userEntity);
ThreadPool.getInstance().execute(new SyncTreeSiteThread(siteService, context)); ThreadPool.getInstance().execute(new SyncTreeSiteThread( context));
} }
}); });
} }
......
...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; ...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.mortals.framework.model.Context; import com.mortals.framework.model.Context;
import com.mortals.xhx.module.site.model.SiteTreeSelect; import com.mortals.xhx.module.site.model.SiteTreeSelect;
import com.mortals.xhx.module.site.service.SiteService; import com.mortals.xhx.module.site.service.SiteService;
import com.mortals.xhx.utils.SpringUtils;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.apachecommons.CommonsLog; import lombok.extern.apachecommons.CommonsLog;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -20,12 +21,11 @@ import java.util.List; ...@@ -20,12 +21,11 @@ import java.util.List;
@Slf4j @Slf4j
public class SyncTreeSiteThread implements Runnable { public class SyncTreeSiteThread implements Runnable {
private SiteService siteService;
private Context context; private Context context;
@Override @Override
public void run() { public void run() {
SiteService siteService = SpringUtils.getBean(SiteService.class);
List<SiteTreeSelect> siteTreeSelects = siteService.siteTree(context); List<SiteTreeSelect> siteTreeSelects = siteService.siteTree(context);
siteService.setSiteTree(siteTreeSelects, context); siteService.setSiteTree(siteTreeSelects, context);
log.info("刷新用户站点树=》userID:{} siteTree:{}",context.getUser().getId(), JSON.toJSONString(siteService.getSiteTree(context))); log.info("刷新用户站点树=》userID:{} siteTree:{}",context.getUser().getId(), JSON.toJSONString(siteService.getSiteTree(context)));
......
...@@ -38,9 +38,6 @@ import java.util.List; ...@@ -38,9 +38,6 @@ import java.util.List;
public class DemoStartedService implements IApplicationStartedService { public class DemoStartedService implements IApplicationStartedService {
private static Log logger = LogFactory.getLog(DemoStartedService.class); private static Log logger = LogFactory.getLog(DemoStartedService.class);
@Autowired
private SiteService siteService;
@Autowired @Autowired
private IUserFeign userFeign; private IUserFeign userFeign;
...@@ -52,7 +49,7 @@ public class DemoStartedService implements IApplicationStartedService { ...@@ -52,7 +49,7 @@ public class DemoStartedService implements IApplicationStartedService {
userEntity.setId(0L); userEntity.setId(0L);
Context contextTemp = new Context(); Context contextTemp = new Context();
contextTemp.setUser(userEntity); contextTemp.setUser(userEntity);
SyncTreeSiteThread syncTreeSiteThread = new SyncTreeSiteThread(siteService, contextTemp); SyncTreeSiteThread syncTreeSiteThread = new SyncTreeSiteThread(contextTemp);
ThreadPool.getInstance().execute(syncTreeSiteThread); ThreadPool.getInstance().execute(syncTreeSiteThread);
userFeign.list(new UserPdu()).getData().getData().stream().forEach(userPdu->{ userFeign.list(new UserPdu()).getData().getData().stream().forEach(userPdu->{
...@@ -63,7 +60,7 @@ public class DemoStartedService implements IApplicationStartedService { ...@@ -63,7 +60,7 @@ public class DemoStartedService implements IApplicationStartedService {
BeanUtils.copyProperties(userPdu, entity, BeanUtil.getNullPropertyNames(userPdu)); BeanUtils.copyProperties(userPdu, entity, BeanUtil.getNullPropertyNames(userPdu));
context.setUser(entity); context.setUser(entity);
ThreadPool.getInstance().execute(new SyncTreeSiteThread(siteService,context)); ThreadPool.getInstance().execute(new SyncTreeSiteThread(context));
}); });
} }
......
...@@ -49,7 +49,7 @@ public class SyncUserTaskImpl implements ITaskExcuteService { ...@@ -49,7 +49,7 @@ public class SyncUserTaskImpl implements ITaskExcuteService {
userPdu.setSize(-1); userPdu.setSize(-1);
Rest<RespData<List<UserPdu>>> list = userFeign.list(userPdu); Rest<RespData<List<UserPdu>>> list = userFeign.list(userPdu);
// userService.updateUserList(list.getData().getData()); userService.updateUserList(list.getData().getData());
//resourceService.updateUserList(); //resourceService.updateUserList();
/* UserPdu userPdu = new UserPdu(); /* UserPdu userPdu = new UserPdu();
......
...@@ -69,8 +69,6 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE ...@@ -69,8 +69,6 @@ public class SiteServiceImpl extends AbstractCRUDCacheServiceImpl<SiteDao, SiteE
private IUserFeign userFeign; private IUserFeign userFeign;
@Autowired @Autowired
private UserService userService; private UserService userService;
@Autowired
private ResourceService resourceService;
@Override @Override
protected void validData(SiteEntity entity, Context context) throws AppException { protected void validData(SiteEntity entity, Context context) throws AppException {
......
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