From d667538721abc0aa7e5dd1a6128704eeb42397d3 Mon Sep 17 00:00:00 2001 From: luyya Date: Fri, 27 Feb 2026 09:16:42 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BA=B3=E5=B7=9E=E4=BD=8D=E7=BD=AE=E6=B1=87?= =?UTF-8?q?=E8=81=9A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dromara/system/mapper/SysDeptMapper.java | 5 +++ .../system/schedule/JzDeptSchedule.java | 4 +- .../service/impl/SysDeptServiceImpl.java | 11 +++++- .../resources/mapper/system/SysDeptMapper.xml | 38 ++++++++++++++++++- 4 files changed, 55 insertions(+), 3 deletions(-) diff --git a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/mapper/SysDeptMapper.java b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/mapper/SysDeptMapper.java index 527563c2..473233bc 100644 --- a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/mapper/SysDeptMapper.java +++ b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/mapper/SysDeptMapper.java @@ -49,4 +49,9 @@ public interface SysDeptMapper extends BaseMapperPlus { List jzDept(String updateTime); + int insertDept(SysDept dept); + + int updateDept(SysDept dept); + + } diff --git a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/JzDeptSchedule.java b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/JzDeptSchedule.java index 0d21a9ec..52c27a5a 100644 --- a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/JzDeptSchedule.java +++ b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/schedule/JzDeptSchedule.java @@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.dromara.system.domain.SysDept; import org.dromara.system.domain.vo.SysDeptVo; import org.dromara.system.service.ISysDeptService; @@ -21,6 +22,7 @@ import java.util.List; @RequiredArgsConstructor @RestController +@Slf4j public class JzDeptSchedule { private final ISysDeptService deptService; @@ -108,6 +110,7 @@ public class JzDeptSchedule { public void jzDeptNew(){ Date time = DateUtil.offsetHour(new Date(),-1); List list = deptService.jzDpet(DateUtil.formatDateTime(time)); + log.error("要同步警综的机构:"+list.toString()); List sysList = new ArrayList<>(); for (SysDeptVo dept : list) { if ("1".equals(dept.getStatus())){ @@ -115,7 +118,6 @@ public class JzDeptSchedule { }else { dept.setStatus("1"); } - dept.setShortName(dept.getDeptName()); sysList.add(dept); } deptService.insertORUpdate(BeanUtil.copyToList(sysList, SysDept.class)); diff --git a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/service/impl/SysDeptServiceImpl.java b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/service/impl/SysDeptServiceImpl.java index d6469080..48cff5fa 100644 --- a/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/service/impl/SysDeptServiceImpl.java +++ b/stwzhj-modules/wzhj-system/src/main/java/org/dromara/system/service/impl/SysDeptServiceImpl.java @@ -402,7 +402,16 @@ public class SysDeptServiceImpl implements ISysDeptService { @Override public boolean insertORUpdate(List list) { - List batchResults = baseMapper.insertOrUpdate(list); + for (SysDept dept : list) { + SysDept d = baseMapper.selectOne(new LambdaQueryWrapper().eq(SysDept::getDeptId,dept.getDeptId()).last("limit 1")); + if(null != d){ + dept.setDeptId(d.getDeptId()); + baseMapper.updateDept(dept); + }else { + baseMapper.insertDept(dept); + } + } +// List batchResults = baseMapper.insertOrUpdate(list); return true; } diff --git a/stwzhj-modules/wzhj-system/src/main/resources/mapper/system/SysDeptMapper.xml b/stwzhj-modules/wzhj-system/src/main/resources/mapper/system/SysDeptMapper.xml index 441bf848..b5af27bf 100644 --- a/stwzhj-modules/wzhj-system/src/main/resources/mapper/system/SysDeptMapper.xml +++ b/stwzhj-modules/wzhj-system/src/main/resources/mapper/system/SysDeptMapper.xml @@ -230,11 +230,47 @@ + + insert into sys_dept( + dept_id, + parent_id, + dept_name, + short_name, + ancestors, + order_num, + status, + create_time + )values( + #{deptId}, + #{parentId}, + #{deptName}, + #{shortName}, + #{ancestors}, + #{orderNum}, + #{status}, + #{createTime} + ) + + + + update sys_dept + + parent_id = #{parentId}, + dept_name = #{deptName}, + short_name = #{shortName}, + ancestors = #{ancestors}, + order_num = #{orderNum}, + status = #{status}, + update_time = #{updateTime} + + where dept_id = #{deptId} + +