diff --git a/src/main/java/com/dsic/gj_erp/service/jcsj/impl/DmCzplpNewServiceImpl.java b/src/main/java/com/dsic/gj_erp/service/jcsj/impl/DmCzplpNewServiceImpl.java index 7ce9193..896cd06 100644 --- a/src/main/java/com/dsic/gj_erp/service/jcsj/impl/DmCzplpNewServiceImpl.java +++ b/src/main/java/com/dsic/gj_erp/service/jcsj/impl/DmCzplpNewServiceImpl.java @@ -102,14 +102,18 @@ public class DmCzplpNewServiceImpl extends ServiceImpltzjhs=new ArrayList<>(); dmCzplpNews.forEach(e->{ - DmTzjh tzjh=new DmTzjh(); - tzjh.setDcPl(e.getDcPl()); - tzjh.setDcFd(e.getDcFd()); - tzjh.setDcCh(e.getDcCh()); - tzjh.setXfqTlt(e.getXfqTlt()); - tzjh.setXfqLqb(e.getXfqLqb()); - tzjh.setXfqPtb(e.getXfqPtb()); - tzjhs.add(tzjh); + List list1 = dmTzjhService.list(new QueryWrapper().eq("dc_ch", e.getDcCh()).eq("dc_pl", e.getDcPl()).eq("dc_fd",e.getDcFd())); + if(list1.isEmpty()){ + DmTzjh tzjh=new DmTzjh(); + tzjh.setDcPl(e.getDcPl()); + tzjh.setDcFd(e.getDcFd()); + tzjh.setDcCh(e.getDcCh()); + tzjh.setXfqTlt(e.getXfqTlt()); + tzjh.setXfqLqb(e.getXfqLqb()); + tzjh.setXfqPtb(e.getXfqPtb()); + tzjhs.add(tzjh); + } + }); dmTzjhService.saveBatch(tzjhs); } @@ -166,7 +170,7 @@ public class DmCzplpNewServiceImpl extends ServiceImpl