feat: 增加Ota升级

dev
huangfeng 1 year ago
parent cfc3396c60
commit f9935b2a71

@ -38,7 +38,7 @@ public class CmdController extends BaseController {
map.put("yw_cmd_start_frpc", "开启frpc"); map.put("yw_cmd_start_frpc", "开启frpc");
map.put("yw_cmd_stop_frpc", "停止frpc"); map.put("yw_cmd_stop_frpc", "停止frpc");
map.put("i1_cmd_stop_aging_test", "停止老化测试"); map.put("i1_cmd_stop_aging_test", "停止老化测试");
map.put("updOta", "Ota升级"); map.put("yw_upd_ota", "Ota升级");
return ResponseReult.success(map); return ResponseReult.success(map);
} }

@ -184,6 +184,9 @@ public class CmdServiceImpl implements CmdService {
case "upgrade": case "upgrade":
this.upgrade(model); this.upgrade(model);
break; break;
case "yw_upd_ota":
this.updota(model);
break;
case "yw_cmd_start_frpc": case "yw_cmd_start_frpc":
this.startfrpc(model); this.startfrpc(model);
break; break;
@ -561,4 +564,38 @@ public class CmdServiceImpl implements CmdService {
cmdsMapper.insert(cmd); cmdsMapper.insert(cmd);
} }
} }
private void updota(CmdModel model) {
if (CollectionUtils.isEmpty(model.getTermIds())) {
throw new ApiException("termIds不能为空");
} else if (StringUtils.isBlank(model.getUrl())) {
throw new ApiException("url不能为空");
} else if (StringUtils.isBlank(model.getMd5())) {
throw new ApiException("md5不能为空");
} else if (StringUtils.isBlank(model.getFn())) {
throw new ApiException("fn不能为空");
}
String name = "yw_upd_ota";
for (Integer termId : model.getTermIds()) {
MntnCmdsExample example = new MntnCmdsExample();
MntnCmdsExample.Criteria criteria = example.createCriteria();
criteria.andTermIdEqualTo(termId);
criteria.andNameEqualTo(name);
cmdsMapper.deleteByExample(example);
HashMap<String, Object> map = new HashMap<>();
map.put("url", model.getUrl());
map.put("md5", model.getMd5());
map.put("fileName", model.getFn());
String json = JSONUtil.object2Json(map);
MntnCmds cmd = new MntnCmds();
cmd.setTermId(termId);
cmd.setName(name);
cmd.setCmd(json);
cmd.setCreateTime(new Date());
cmdsMapper.insert(cmd);
}
}
} }

Loading…
Cancel
Save