|
@@ -27,6 +27,7 @@ import org.springblade.archive.vo.ArchiveAiNameVO1;
|
|
|
import org.springblade.common.utils.DeepSeekClient;
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.scheduling.annotation.Async;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -132,12 +133,18 @@ public class ArchiveAiNameServiceImpl extends BaseServiceImpl<ArchiveAiNameMappe
|
|
|
for (ArchiveAiNameVO1 archiveAiName : vos) {
|
|
|
if(archiveAiName.getStatus()==2&& StringUtils.isNotEmpty(archiveAiName.getArchiveNameAi())){
|
|
|
archiveAiName.setStatus(3);
|
|
|
- String sql=" update u_archives_auto set name='"+archiveAiName.getArchiveNameAi()+"' where id="+archiveAiName.getArchiveAutoId();
|
|
|
+ String sql=" update u_archives_auto set name='"+archiveAiName.getArchiveNameAi()+"', colour_status=2 where id="+archiveAiName.getArchiveAutoId();
|
|
|
jdbcTemplate.update(sql);
|
|
|
String sql2="update u_archive_ai_name set status=3 where id="+archiveAiName.getId();
|
|
|
jdbcTemplate.update(sql2);
|
|
|
}
|
|
|
}
|
|
|
+ Long taskId = vos.get(0).getTaskId();
|
|
|
+ String sql3="select * from u_archive_ai_name where task_id="+taskId+" and is_deleted=0";
|
|
|
+ List<ArchiveAiName> list = jdbcTemplate.query(sql3, new BeanPropertyRowMapper<>(ArchiveAiName.class));
|
|
|
+ if(list.stream().allMatch(item -> item.getStatus() >= 3)){
|
|
|
+ deletedArchiveAiTask(taskId);
|
|
|
+ };
|
|
|
return true;
|
|
|
}
|
|
|
|