whycrzg
2021-05-18 cabd8ad109f93fbfb76818a239189c1a5a8d1e1b
src/main/java/com/whyc/service/WindingExperimentService.java
@@ -1,6 +1,8 @@
package com.whyc.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.ExperimentMapper;
import com.whyc.mapper.ExperimentWindingStep1Mapper;
@@ -141,4 +143,177 @@
    }
    public Response delExperimentWindingbyId(String experimentId) {
        try {
            mapper1.delExperimentWindingbyId(experimentId);
            mapper2.delExperimentWindingbyId(experimentId);
        } catch (Exception e) {
            e.printStackTrace();
            return new Response().setMsg(0, "删除失败");
        }
        return new Response().setMsg(1, "删除成功");
    }
    /**
     * 根据 experimentId 编辑参数
     * @param windingStep1s
     * @return
     */
    public Response updateExperimentWindingStep1(List<ExperimentWindingStep1> windingStep1s) {
        boolean bl = true;
        TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
        if (windingStep1s != null && windingStep1s.size() > 0) {
            for (int i = 0; i < windingStep1s.size(); i++) {
                try {
                    ExperimentWindingStep1 windingStep1 = windingStep1s.get(i);
                    if (mapper1.updateById(windingStep1) > 0) {
                        bl = true;
                    } else {
                        bl = false;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
                    return new Response().setMsg(0, "修改失败");
                }
            }
        }
        if (bl) {
            dataSourceTransactionManager.commit(transactionStatus);
            return new Response().setMsg(1, "修改成功");
        } else {
            dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
            return new Response().setMsg(0, "修改失败");
        }
    }
    /**
     * 根据 experiment_id 编辑试验数据
     * @param windingStep2s
     * @return
     */
    public Response updateExperimentWindingStep2(List<ExperimentWindingStep2> windingStep2s) {
        boolean bl = true;
        TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
        if (windingStep2s != null && windingStep2s.size() > 0) {
            for (int i = 0; i < windingStep2s.size(); i++) {
                try {
                    ExperimentWindingStep2 windingStep2 = windingStep2s.get(i);
                    if (mapper2.updateById(windingStep2) > 0) {
                        bl = true;
                    } else {
                        bl = false;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
                    return new Response().setMsg(0, "修改失败");
                }
            }
        }
        if (bl) {
            dataSourceTransactionManager.commit(transactionStatus);
            return new Response().setMsg(1, "修改成功");
        } else {
            dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
            return new Response().setMsg(0, "修改失败");
        }
    }
    /**
     * 根据唯一ID编辑实验数据1
     * @param windingStep1s
     * @return
     */
    public Response updateExperimentWindingStep1ById(List<ExperimentWindingStep1> windingStep1s) {
        boolean bl = true;
        TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
        if (windingStep1s != null && windingStep1s.size() > 0) {
            for (int i = 0; i < windingStep1s.size(); i++) {
                try {
                    ExperimentWindingStep1 windingStep1 = windingStep1s.get(i);
                    if (mapper1.updateByPrimaryKey(windingStep1) > 0) {
                        bl = true;
                    } else {
                        bl = false;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
                    return new Response().setMsg(0, "修改失败");
                }
            }
        }
        if (bl) {
            dataSourceTransactionManager.commit(transactionStatus);
            return new Response().setMsg(1, "修改成功");
        } else {
            dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
            return new Response().setMsg(0, "修改失败");
        }
    }
    public Response updateExperimentWindingStep2ById(List<ExperimentWindingStep2> windingStep2s) {
        boolean bl = true;
        TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition);
        if (windingStep2s != null && windingStep2s.size() > 0) {
            for (int i = 0; i < windingStep2s.size(); i++) {
                try {
                    ExperimentWindingStep2 windingStep2 = windingStep2s.get(i);
                    if (mapper2.updateByPrimaryKey(windingStep2) > 0) {
                        bl = true;
                    } else {
                        bl = false;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
                    return new Response().setMsg(0, "修改失败");
                }
            }
        }
        if (bl) {
            dataSourceTransactionManager.commit(transactionStatus);
            return new Response().setMsg(1, "修改成功");
        } else {
            dataSourceTransactionManager.rollback(transactionStatus);       //事务回滚
            return new Response().setMsg(0, "修改失败");
        }
    }
    /**
     * 实验数据1
     * @param pageNum
     * @param pageSize
     * @return
     */
    public Response getExperimentWindingStep1(int pageNum, int pageSize) {
        PageHelper.startPage(pageNum, pageSize);
        List<ExperimentWindingStep1> list = mapper1.selectList(null);
        PageInfo<ExperimentWindingStep1> pageInfo = new PageInfo<>(list);
        return new Response<PageInfo<ExperimentWindingStep1>>().set(1, pageInfo);
    }
    /**
     * 实验数据2
     * @param pageNum
     * @param pageSize
     * @return
     */
    public Response getExperimentWindingStep2(int pageNum, int pageSize) {
        PageHelper.startPage(pageNum, pageSize);
        List<ExperimentWindingStep2> list = mapper2.selectList(null);
        PageInfo<ExperimentWindingStep2> pageInfo = new PageInfo<>(list);
        return new Response<PageInfo<ExperimentWindingStep2>>().set(1, pageInfo);
    }
}