|
|
@ -13,6 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
|
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
|
|
|
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
import java.util.List; |
|
|
|
import java.util.Map; |
|
|
|
import java.util.Map; |
|
|
@ -24,7 +25,7 @@ import java.util.Map; |
|
|
|
* @Version: V1.0 |
|
|
|
* @Version: V1.0 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Transactional |
|
|
|
@Service |
|
|
|
@Service |
|
|
|
public class FieldxServiceImpl extends ServiceImpl<FieldxMapper, Fieldx> implements IFieldxService { |
|
|
|
public class FieldxServiceImpl extends ServiceImpl<FieldxMapper, Fieldx> implements IFieldxService { |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
@ -40,9 +41,11 @@ public class FieldxServiceImpl extends ServiceImpl<FieldxMapper, Fieldx> impleme |
|
|
|
Thread.sleep(500L); |
|
|
|
Thread.sleep(500L); |
|
|
|
message.put("uploaded", String.valueOf(i + 1)); |
|
|
|
message.put("uploaded", String.valueOf(i + 1)); |
|
|
|
this.save(fieldxList.get(i)); |
|
|
|
this.save(fieldxList.get(i)); |
|
|
|
|
|
|
|
if(fieldxList.get(i).getAssociateTable()==null&&fieldxList.get(i).getAssociateField()==null){ |
|
|
|
Tablex tablex = tablexService.getById(fieldxList.get(i).getTableId()); |
|
|
|
Tablex tablex = tablexService.getById(fieldxList.get(i).getTableId()); |
|
|
|
tablexService.updateVersion(fieldxList.get(i).getTableId(), tablex.getVerison() + 1); |
|
|
|
tablexService.updateVersion(fieldxList.get(i).getTableId(), tablex.getVerison() + 1); |
|
|
|
tablexService.updateSql(fieldxList.get(i).getTableId(), fieldxController.createSql(fieldxList.get(i).getTableId())); |
|
|
|
tablexService.updateSql(fieldxList.get(i).getTableId(), fieldxController.createSql(fieldxList.get(i).getTableId())); |
|
|
|
|
|
|
|
} |
|
|
|
webSocketUtils.sendMessage(loginUser.getId(), message); |
|
|
|
webSocketUtils.sendMessage(loginUser.getId(), message); |
|
|
|
} catch (InterruptedException e) { |
|
|
|
} catch (InterruptedException e) { |
|
|
|
log.error(e.getMessage(), e); |
|
|
|
log.error(e.getMessage(), e); |
|
|
|