|
|
|
@ -1,6 +1,7 @@ |
|
|
|
|
package org.jeecg.modules.tablex.service.impl; |
|
|
|
|
|
|
|
|
|
import org.jeecg.common.system.vo.LoginUser; |
|
|
|
|
import org.jeecg.modules.modulex.service.IModulexService; |
|
|
|
|
import org.jeecg.modules.tablex.entity.Tablex; |
|
|
|
|
import org.jeecg.modules.tablex.mapper.TablexMapper; |
|
|
|
|
import org.jeecg.modules.tablex.service.ITablexService; |
|
|
|
@ -29,6 +30,9 @@ public class TablexServiceImpl extends ServiceImpl<TablexMapper, Tablex> impleme |
|
|
|
|
@Autowired |
|
|
|
|
private WebSocketUtils webSocketUtils; |
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
private IModulexService modulexService; |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public void updateSql(String tableId, String sql) { |
|
|
|
|
tablexMapper.updateSql(tableId,sql); |
|
|
|
@ -46,6 +50,7 @@ public class TablexServiceImpl extends ServiceImpl<TablexMapper, Tablex> impleme |
|
|
|
|
Thread.sleep(1000L); |
|
|
|
|
message.put("uploaded", String.valueOf(i + 1)); |
|
|
|
|
this.save(tablexList.get(i)); |
|
|
|
|
modulexService.setmodule(tablexList.get(i).getId(), tablexList.get(i).getModuleId()); |
|
|
|
|
webSocketUtils.sendMessage(loginUser.getId(), message); |
|
|
|
|
} catch (InterruptedException e) { |
|
|
|
|
log.error(e.getMessage(), e); |
|
|
|
|