[add]服务发布

张洋洋

2025-02-20 acb0e0de3ba95f9f38996d049bc73231e563d3a1

[add]服务发布

 src/main/java/com/se/simu/controller/SimuController.java

@@ -397,7 +397,7 @@
            vo.setLinkName(linkUrl);
            asyncCall(tableName, dtos, vo, token);
            // 开始模拟计算
            boolean flag = simuFilesService.createByfiles(vo);
            boolean flag = simuFilesService.createByfiles(vo,token);
            return success(flag, flag ? "成功" : "失败");
        } catch (Exception ex) {
            return fail(ex, null);

 src/main/java/com/se/simu/service/SimuFilesService.java

@@ -114,7 +114,7 @@
     * @param vo VO
     * @return boolean
     */
    public boolean createByfiles(CreateFilesSimuVo vo) {
    public boolean createByfiles(CreateFilesSimuVo vo,String token) {
        Date now = new Date();
        String date = StringHelper.YMDHMS2_FORMAT.format(now);
        if (StringHelper.isEmpty(vo.getName())) {
@@ -131,7 +131,7 @@
        simu.setLinkUrl(vo.getLinkName());
        int rows = simuMapper.insert(simu);
        if (rows > 0) {
            asyncCall(simu);
            asyncCall(simu,token);
        }

        return rows > 0;
@@ -150,13 +150,13 @@
        f.mkdirs();
    }

    private void asyncCall(SimuPo simu) {
    private void asyncCall(SimuPo simu,String token) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        executor.execute(new Runnable() {
            @Override
            @SneakyThrows
            public void run() {
                cope(simu);
                cope(simu,token);
            }
        });
        executor.shutdown();
@@ -180,12 +180,11 @@
     * @param simu 模拟
     */

    private void cope(SimuPo simu) {
    private void cope(SimuPo simu,String token) {
        try {
            DataPo data = JSONUtil.toBean(simu.getData(), DataPo.class);

            update(simu, 1, null);
            String token = gedbService.getToken();
            GeDb db = gedbService.connectGedb(token, data);
            simu.setData(JSONUtil.toJsonStr(data));