暂提

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/ConfigSwitchFormDTO.java

@@ -0,0 +1,26 @@
+package com.epmet.dto.form;
+
+import lombok.Data;
+
+import javax.validation.constraints.NotBlank;
+import java.io.Serializable;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/9/26 14:34
+ * @DESC
+ */
+@Data
+public class ConfigSwitchFormDTO implements Serializable {
+
+    private static final long serialVersionUID = 7510856043372376415L;
+
+    public interface ConfigSwitchForm{}
+
+    @NotBlank(message = "deptCode不能为空",groups = ConfigSwitchForm.class)
+    private String deptCode;
+
+    @NotBlank(message = "dataSyncConfigId不能为空",groups = ConfigSwitchForm.class)
+    private String dataSyncConfigId;
+    private String updatedBy;
+}

epmet-user/epmet-user-server/src/main/java/com/epmet/controller/DataSyncConfigController.java

@@ -1,7 +1,9 @@
 package com.epmet.controller;
 
+import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.aop.NoRepeatSubmit;
 import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.commons.tools.validator.AssertUtils;
 import com.epmet.commons.tools.validator.ValidatorUtils;
@@ -9,6 +11,7 @@ import com.epmet.commons.tools.validator.group.AddGroup;
 import com.epmet.commons.tools.validator.group.DefaultGroup;
 import com.epmet.commons.tools.validator.group.UpdateGroup;
 import com.epmet.dto.DataSyncConfigDTO;
+import com.epmet.dto.form.ConfigSwitchFormDTO;
 import com.epmet.service.DataSyncConfigService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -67,4 +70,18 @@ public class DataSyncConfigController {
         return new Result();
     }
 
+    /**
+     * Desc: 【数据配置】配置开关
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/26 14:36
+     */
+    @PostMapping("configSwitch")
+    public Result configSwitch(@RequestBody ConfigSwitchFormDTO formDTO, @LoginUser TokenDto tokenDto){
+        ValidatorUtils.validateEntity(formDTO, ConfigSwitchFormDTO.ConfigSwitchForm.class);
+        formDTO.setUpdatedBy(tokenDto.getUserId());
+        dataSyncConfigService.configSwitch(formDTO);
+        return new Result();
+    }
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/DataSyncConfigDao.java

@@ -1,6 +1,7 @@
 package com.epmet.dao;
 
 import com.epmet.commons.mybatis.dao.BaseDao;
+import com.epmet.dto.form.ConfigSwitchFormDTO;
 import com.epmet.entity.DataSyncConfigEntity;
 import org.apache.ibatis.annotations.Mapper;
 
@@ -12,5 +13,13 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface DataSyncConfigDao extends BaseDao<DataSyncConfigEntity> {
-	
+
+    /**
+     * Desc: 【数据配置】配置开关
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/26 14:36
+     */
+    void configSwitch(ConfigSwitchFormDTO formDTO);
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/DataSyncConfigService.java

@@ -3,6 +3,7 @@ package com.epmet.service;
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.dto.DataSyncConfigDTO;
+import com.epmet.dto.form.ConfigSwitchFormDTO;
 import com.epmet.entity.DataSyncConfigEntity;
 
 import java.util.List;
@@ -75,4 +76,12 @@ public interface DataSyncConfigService extends BaseService<DataSyncConfigEntity>
      * @date 2022-09-26
      */
     void delete(String[] ids);
+
+    /**
+     * Desc: 【数据配置】配置开关
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/26 14:36
+     */
+    void configSwitch(ConfigSwitchFormDTO formDTO);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncConfigServiceImpl.java

@@ -8,6 +8,7 @@ import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.dao.DataSyncConfigDao;
 import com.epmet.dto.DataSyncConfigDTO;
+import com.epmet.dto.form.ConfigSwitchFormDTO;
 import com.epmet.entity.DataSyncConfigEntity;
 import com.epmet.service.DataSyncConfigService;
 import org.apache.commons.lang3.StringUtils;
@@ -79,4 +80,16 @@ public class DataSyncConfigServiceImpl extends BaseServiceImpl<DataSyncConfigDao
         baseDao.deleteBatchIds(Arrays.asList(ids));
     }
 
+    /**
+     * Desc: 【数据配置】配置开关
+     * @param formDTO
+     * @author zxc
+     * @date 2022/9/26 14:36
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void configSwitch(ConfigSwitchFormDTO formDTO) {
+        baseDao.configSwitch(formDTO);
+    }
+
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/DataSyncScopeServiceImpl.java

@@ -3,16 +3,14 @@ package com.epmet.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
+import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.utils.ConvertUtils;
-import com.epmet.commons.tools.constant.FieldConstant;
 import com.epmet.dao.DataSyncScopeDao;
 import com.epmet.dto.DataSyncScopeDTO;
 import com.epmet.entity.DataSyncScopeEntity;
-import com.epmet.redis.DataSyncScopeRedis;
 import com.epmet.service.DataSyncScopeService;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -29,9 +27,6 @@ import java.util.Map;
 @Service
 public class DataSyncScopeServiceImpl extends BaseServiceImpl<DataSyncScopeDao, DataSyncScopeEntity> implements DataSyncScopeService {
 
-    @Autowired
-    private DataSyncScopeRedis dataSyncScopeRedis;
-
     @Override
     public PageData<DataSyncScopeDTO> page(Map<String, Object> params) {
         IPage<DataSyncScopeEntity> page = baseDao.selectPage(

epmet-user/epmet-user-server/src/main/resources/mapper/DataSyncConfigDao.xml

@@ -3,4 +3,13 @@
 
 <mapper namespace="com.epmet.dao.DataSyncConfigDao">
 
+    <!-- 【数据配置】配置开关 -->
+    <update id="configSwitch">
+        UPDATE data_sync_config
+        SET UPDATED_TIME = NOW(),
+            UPDATED_BY = #{updatedBy},
+            SWITCH_STATUS = CASE WHEN SWITCH_STATUS = 'open' THEN 'closed' ELSE 'open' END
+        WHERE id = #{dataSyncConfigId}
+          AND DEPT_CODE = #{deptCode}
+    </update>
 </mapper>