Commit 6246dc14 authored by 赵啸非's avatar 赵啸非

修改版本

parent fcf6fca4
...@@ -23,6 +23,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; ...@@ -23,6 +23,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import com.mortals.framework.springcloud.service.IApplicationStartedService; import com.mortals.framework.springcloud.service.IApplicationStartedService;
import org.springframework.util.ObjectUtils;
import java.util.List; import java.util.List;
...@@ -52,6 +53,11 @@ public class DemoStartedService implements IApplicationStartedService { ...@@ -52,6 +53,11 @@ public class DemoStartedService implements IApplicationStartedService {
SyncTreeSiteThread syncTreeSiteThread = new SyncTreeSiteThread(contextTemp); SyncTreeSiteThread syncTreeSiteThread = new SyncTreeSiteThread(contextTemp);
ThreadPool.getInstance().execute(syncTreeSiteThread); ThreadPool.getInstance().execute(syncTreeSiteThread);
if(ObjectUtils.isEmpty(userFeign)){
logger.info("userFeign未加载");
return;
}
userFeign.list(new UserPdu()).getData().getData().stream().forEach(userPdu->{ userFeign.list(new UserPdu()).getData().getData().stream().forEach(userPdu->{
Context context = new Context(); Context context = new Context();
......
...@@ -268,7 +268,7 @@ public class AppServiceImpl extends AbstractCRUDServiceImpl<AppDao, AppEntity, L ...@@ -268,7 +268,7 @@ public class AppServiceImpl extends AbstractCRUDServiceImpl<AppDao, AppEntity, L
versionEntity.initAttrValue(); versionEntity.initAttrValue();
versionEntity.setAppId(entity.getId()); versionEntity.setAppId(entity.getId());
versionEntity.setAppName(entity.getAppName()); versionEntity.setAppName(entity.getAppName());
versionEntity.setVersion(versionNum++); versionEntity.setVersion(++versionNum);
versionEntity.setNotes(entity.getNotes()); versionEntity.setNotes(entity.getNotes());
versionEntity.setFileName(entity.getFileName()); versionEntity.setFileName(entity.getFileName());
versionEntity.setFilePath(entity.getFilePath()); versionEntity.setFilePath(entity.getFilePath());
......
...@@ -44,12 +44,12 @@ public class AppVersionServiceImpl extends AbstractCRUDServiceImpl<AppVersionDao ...@@ -44,12 +44,12 @@ public class AppVersionServiceImpl extends AbstractCRUDServiceImpl<AppVersionDao
@Override @Override
public Rest<String> appDistribute(AppVersionEntity appVersionEntity, Context context) { public Rest<String> appDistribute(AppVersionEntity appVersionEntity, Context context) {
distributeFile(appVersionEntity, context); AppEntity appEntity = appService.get(appVersionEntity.getAppId(), context);
distributeFile(appVersionEntity, appEntity, context);
return Rest.ok("部署应用成功!"); return Rest.ok("部署应用成功!");
} }
private AppEntity distributeFile(AppVersionEntity appVersionEntity, Context context) { private String distributeFile(AppVersionEntity appVersionEntity, AppEntity appEntity, Context context) {
AppEntity appEntity = appService.get(appVersionEntity.getAppId(), context);
SiteEntity siteCache = siteService.getCache(appEntity.getSiteId().toString()); SiteEntity siteCache = siteService.getCache(appEntity.getSiteId().toString());
//判断文件是否存在 //判断文件是否存在
String targetFilePath = uploadService.getFilePath(appVersionEntity.getFilePath()); String targetFilePath = uploadService.getFilePath(appVersionEntity.getFilePath());
...@@ -71,17 +71,18 @@ public class AppVersionServiceImpl extends AbstractCRUDServiceImpl<AppVersionDao ...@@ -71,17 +71,18 @@ public class AppVersionServiceImpl extends AbstractCRUDServiceImpl<AppVersionDao
FileUtil.del(disPath); FileUtil.del(disPath);
} }
ZipUtils.unzip(new File(targetFilePath), disPath); ZipUtils.unzip(new File(targetFilePath), disPath);
return appEntity; return disPath;
} }
@Override @Override
public Rest<Void> appUsed(AppVersionEntity appVersionEntity, Context context) { public Rest<Void> appUsed(AppVersionEntity appVersionEntity, Context context) {
//使用 部署 //使用 部署
AppEntity appEntity = distributeFile(appVersionEntity, context); AppEntity appEntity = appService.get(appVersionEntity.getAppId(), context);
// ZipUtil.unzip(targetFilePath, disPath); String disPath = distributeFile(appVersionEntity, appEntity, context);
//更新app版本使用 //更新app版本使用
appVersionEntity.setUsed(YesNoEnum.YES.getValue()); appVersionEntity.setUsed(YesNoEnum.YES.getValue());
appVersionEntity.setDistributeFilePath(disPath);
this.getDao().update(new AppVersionQuery().appId(appVersionEntity.getAppId()).used(YesNoEnum.NO.getValue())); this.getDao().update(new AppVersionQuery().appId(appVersionEntity.getAppId()).used(YesNoEnum.NO.getValue()));
this.update(appVersionEntity, context); this.update(appVersionEntity, context);
......
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