|
@@ -31,6 +31,7 @@ import org.springblade.manager.service.ITableInfoService;
|
|
|
import org.springblade.manager.service.IWbsTreePrivateService;
|
|
|
import org.springblade.manager.vo.*;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
+import org.springframework.scheduling.annotation.Scheduled;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
@@ -1514,4 +1515,23 @@ public class WbsTreePrivateServiceImpl extends BaseServiceImpl<WbsTreePrivateMap
|
|
|
}
|
|
|
this.insertBatch(wbsTreePrivatesNew, 1000);
|
|
|
}
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 修改initTableId
|
|
|
+ */
|
|
|
+ @Scheduled(cron = "0 0 3 * * ?")
|
|
|
+ public void updateInitTableId() {
|
|
|
+ List<WbsTreePrivate> wbsTreePrivates = baseMapper.selectList(Wrappers.<WbsTreePrivate>lambdaQuery().isNull(WbsTreePrivate::getInitTableId).isNotNull(WbsTreePrivate::getInitTableName).ne(WbsTreePrivate::getType, 1));
|
|
|
+ List<TableInfo> list = baseMapper.selectTabInfoAll();
|
|
|
+ for (TableInfo tableInfo : list) {
|
|
|
+ for (WbsTreePrivate wbsTreePrivate : wbsTreePrivates) {
|
|
|
+ if (tableInfo.getTabEnName().equals(wbsTreePrivate.getInitTableName()) || tableInfo.getTabChName().equals(wbsTreePrivate.getInitTableName())) {
|
|
|
+ if (ObjectUtil.isEmpty(wbsTreePrivate.getInitTableId())) {
|
|
|
+ this.update(Wrappers.<WbsTreePrivate>lambdaUpdate().set(WbsTreePrivate::getInitTableId, String.valueOf(tableInfo.getId())).eq(WbsTreePrivate::getPKeyId, wbsTreePrivate.getPKeyId()));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|