diff --git a/src/main/java/com/demo/cost/TbsServiceImpl.java b/src/main/java/com/demo/cost/TbsServiceImpl.java index 732e918..f1af15f 100644 --- a/src/main/java/com/demo/cost/TbsServiceImpl.java +++ b/src/main/java/com/demo/cost/TbsServiceImpl.java @@ -91,7 +91,7 @@ public class TbsServiceImpl { @SneakyThrows - private void removeByCostIds(List rmIDs){ + public void removeByCostIds(List rmIDs){ DbContext jslContext = TbsMapper.getJslDbContext(); String rmIdsString = "(" + rmIDs.stream().map(id -> "'" + id + "'").collect(Collectors.joining(",")) + ")"; jslContext.sql("delete from tbs_activity where cost_apply_id in " + rmIdsString).execute(); @@ -107,6 +107,9 @@ public class TbsServiceImpl { jslContext.sql("delete from tbs_budget_log where cost_apply_id in " + rmIdsString).execute(); jslContext.sql("delete from tbs_budget_cost_item where cost_apply_id in " + rmIdsString).execute(); jslContext.sql("delete from vtb_fund_flow where cost_apply_id in " + rmIdsString).execute(); + + jslContext.sql("delete from bir_activity_center_goods where cost_apply_id in " + rmIdsString).execute(); + jslContext.sql("delete from bir_base_activity where cost_apply_id in " + rmIdsString).execute(); } @Test diff --git a/src/main/java/com/demo/t20230821/DeleteRepeatCostApply.java b/src/main/java/com/demo/t20230821/DeleteRepeatCostApply.java new file mode 100644 index 0000000..95a0428 --- /dev/null +++ b/src/main/java/com/demo/t20230821/DeleteRepeatCostApply.java @@ -0,0 +1,31 @@ +package com.demo.t20230821; + +import com.demo.cost.TbsMapper; +import com.demo.cost.TbsServiceImpl; +import com.demo.jsl.entity.costapply.JslCostApply; +import com.demo.t20230821.entity.CodeEntity; +import lombok.SneakyThrows; +import org.junit.Test; +import org.noear.wood.DbContext; + +import java.util.List; +import java.util.stream.Collectors; + +/** + * @author YenHex + * @since 2023/8/21 + **/ +public class DeleteRepeatCostApply { + + @Test + @SneakyThrows + public void doAction(){ + DbContext jslContext = TbsMapper.getJslDbContext(); + String repeat_code_sql = "select `code`,min(id) as id from tbs_cost_apply where xlt_sync = 2 GROUP BY `code` HAVING count(*) >1"; + List selectByCodeList = jslContext.sql(repeat_code_sql).getList(CodeEntity.class); + List ids = selectByCodeList.stream().map(a->a.getId()+"").collect(Collectors.toList()); + //System.out.println(ids.size()); + //new TbsServiceImpl().removeByCostIds(ids); + } + +} diff --git a/src/main/java/com/demo/t20230821/entity/CodeEntity.java b/src/main/java/com/demo/t20230821/entity/CodeEntity.java new file mode 100644 index 0000000..16fefd5 --- /dev/null +++ b/src/main/java/com/demo/t20230821/entity/CodeEntity.java @@ -0,0 +1,16 @@ +package com.demo.t20230821.entity; + +import lombok.Data; + +/** + * @author YenHex + * @since 2023/8/21 + **/ +@Data +public class CodeEntity { + + Long id; + + String code; + +}