14 changed files with 792 additions and 0 deletions
			
			
		@ -0,0 +1,84 @@ | 
				
			|||
package com.epmet.dto; | 
				
			|||
 | 
				
			|||
import java.io.Serializable; | 
				
			|||
import java.util.Date; | 
				
			|||
import lombok.Data; | 
				
			|||
 | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Data | 
				
			|||
public class DataSyncConfigDTO implements Serializable { | 
				
			|||
 | 
				
			|||
    private static final long serialVersionUID = 1L; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * ID主键 | 
				
			|||
     */ | 
				
			|||
	private String id; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 客户ID。如果该角色由客户定制,其下的机关和部门都不再各自定制自己的角色,这个字段会比较有用。包括通用角色以及客户定制角色。 | 
				
			|||
     */ | 
				
			|||
	private String customerId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 部门编码 | 
				
			|||
     */ | 
				
			|||
	private String deptCode; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 部门名称 | 
				
			|||
     */ | 
				
			|||
	private String deptName; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 数据名称 | 
				
			|||
     */ | 
				
			|||
	private String dataName; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 开启:open;关闭:closed | 
				
			|||
     */ | 
				
			|||
	private String switchStatus; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 排序 | 
				
			|||
     */ | 
				
			|||
	private Integer sort; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 删除标识:0.未删除 1.已删除 | 
				
			|||
     */ | 
				
			|||
	private Integer delFlag; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 乐观锁 | 
				
			|||
     */ | 
				
			|||
	private Integer revision; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 创建人 | 
				
			|||
     */ | 
				
			|||
	private String createdBy; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 创建时间 | 
				
			|||
     */ | 
				
			|||
	private Date createdTime; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 更新人 | 
				
			|||
     */ | 
				
			|||
	private String updatedBy; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 更新时间 | 
				
			|||
     */ | 
				
			|||
	private Date updatedTime; | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,89 @@ | 
				
			|||
package com.epmet.dto; | 
				
			|||
 | 
				
			|||
import java.io.Serializable; | 
				
			|||
import java.util.Date; | 
				
			|||
import lombok.Data; | 
				
			|||
 | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Data | 
				
			|||
public class DataSyncScopeDTO implements Serializable { | 
				
			|||
 | 
				
			|||
    private static final long serialVersionUID = 1L; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 主键 | 
				
			|||
     */ | 
				
			|||
	private String id; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 客户ID。如果该角色由客户定制,其下的机关和部门都不再各自定制自己的角色,这个字段会比较有用。包括通用角色以及客户定制角色。 | 
				
			|||
     */ | 
				
			|||
	private String customerId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 数据更新配置表主键 | 
				
			|||
     */ | 
				
			|||
	private String dataSyncConfigId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 网格:grid, | 
				
			|||
社区级:community, | 
				
			|||
乡(镇、街道)级:street, | 
				
			|||
区县级: district, | 
				
			|||
市级: city | 
				
			|||
省级:province | 
				
			|||
     */ | 
				
			|||
	private String orgType; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 组织或者网格id | 
				
			|||
     */ | 
				
			|||
	private String orgId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * org_id的上级 | 
				
			|||
     */ | 
				
			|||
	private String pid; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * org_id的全路径,包含自身 | 
				
			|||
     */ | 
				
			|||
	private String orgIdPath; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 删除标识:0.未删除 1.已删除 | 
				
			|||
     */ | 
				
			|||
	private Integer delFlag; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 乐观锁 | 
				
			|||
     */ | 
				
			|||
	private Integer revision; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 创建人 | 
				
			|||
     */ | 
				
			|||
	private String createdBy; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 创建时间 | 
				
			|||
     */ | 
				
			|||
	private Date createdTime; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 更新人 | 
				
			|||
     */ | 
				
			|||
	private String updatedBy; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 更新时间 | 
				
			|||
     */ | 
				
			|||
	private Date updatedTime; | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,70 @@ | 
				
			|||
package com.epmet.controller; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.tools.aop.NoRepeatSubmit; | 
				
			|||
import com.epmet.commons.tools.page.PageData; | 
				
			|||
import com.epmet.commons.tools.utils.Result; | 
				
			|||
import com.epmet.commons.tools.validator.AssertUtils; | 
				
			|||
import com.epmet.commons.tools.validator.ValidatorUtils; | 
				
			|||
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.service.DataSyncConfigService; | 
				
			|||
import org.springframework.beans.factory.annotation.Autowired; | 
				
			|||
import org.springframework.web.bind.annotation.*; | 
				
			|||
 | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@RestController | 
				
			|||
@RequestMapping("dataSyncConfig") | 
				
			|||
public class DataSyncConfigController { | 
				
			|||
 | 
				
			|||
    @Autowired | 
				
			|||
    private DataSyncConfigService dataSyncConfigService; | 
				
			|||
 | 
				
			|||
    @RequestMapping("page") | 
				
			|||
    public Result<PageData<DataSyncConfigDTO>> page(@RequestParam Map<String, Object> params){ | 
				
			|||
        PageData<DataSyncConfigDTO> page = dataSyncConfigService.page(params); | 
				
			|||
        return new Result<PageData<DataSyncConfigDTO>>().ok(page); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @RequestMapping(value = "{id}",method = {RequestMethod.POST,RequestMethod.GET}) | 
				
			|||
    public Result<DataSyncConfigDTO> get(@PathVariable("id") String id){ | 
				
			|||
        DataSyncConfigDTO data = dataSyncConfigService.get(id); | 
				
			|||
        return new Result<DataSyncConfigDTO>().ok(data); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @NoRepeatSubmit | 
				
			|||
    @PostMapping("save") | 
				
			|||
    public Result save(@RequestBody DataSyncConfigDTO dto){ | 
				
			|||
        //效验数据
 | 
				
			|||
        ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class); | 
				
			|||
        dataSyncConfigService.save(dto); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @NoRepeatSubmit | 
				
			|||
    @PostMapping("update") | 
				
			|||
    public Result update(@RequestBody DataSyncConfigDTO dto){ | 
				
			|||
        //效验数据
 | 
				
			|||
        ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class); | 
				
			|||
        dataSyncConfigService.update(dto); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @PostMapping("delete") | 
				
			|||
    public Result delete(@RequestBody String[] ids){ | 
				
			|||
        //效验数据
 | 
				
			|||
        AssertUtils.isArrayEmpty(ids, "id"); | 
				
			|||
        dataSyncConfigService.delete(ids); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,70 @@ | 
				
			|||
package com.epmet.controller; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.tools.aop.NoRepeatSubmit; | 
				
			|||
import com.epmet.commons.tools.page.PageData; | 
				
			|||
import com.epmet.commons.tools.utils.Result; | 
				
			|||
import com.epmet.commons.tools.validator.AssertUtils; | 
				
			|||
import com.epmet.commons.tools.validator.ValidatorUtils; | 
				
			|||
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.DataSyncScopeDTO; | 
				
			|||
import com.epmet.service.DataSyncScopeService; | 
				
			|||
import org.springframework.beans.factory.annotation.Autowired; | 
				
			|||
import org.springframework.web.bind.annotation.*; | 
				
			|||
 | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@RestController | 
				
			|||
@RequestMapping("dataSyncScope") | 
				
			|||
public class DataSyncScopeController { | 
				
			|||
 | 
				
			|||
    @Autowired | 
				
			|||
    private DataSyncScopeService dataSyncScopeService; | 
				
			|||
 | 
				
			|||
    @RequestMapping("page") | 
				
			|||
    public Result<PageData<DataSyncScopeDTO>> page(@RequestParam Map<String, Object> params){ | 
				
			|||
        PageData<DataSyncScopeDTO> page = dataSyncScopeService.page(params); | 
				
			|||
        return new Result<PageData<DataSyncScopeDTO>>().ok(page); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @RequestMapping(value = "{id}",method = {RequestMethod.POST,RequestMethod.GET}) | 
				
			|||
    public Result<DataSyncScopeDTO> get(@PathVariable("id") String id){ | 
				
			|||
        DataSyncScopeDTO data = dataSyncScopeService.get(id); | 
				
			|||
        return new Result<DataSyncScopeDTO>().ok(data); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @NoRepeatSubmit | 
				
			|||
    @PostMapping("save") | 
				
			|||
    public Result save(@RequestBody DataSyncScopeDTO dto){ | 
				
			|||
        //效验数据
 | 
				
			|||
        ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class); | 
				
			|||
        dataSyncScopeService.save(dto); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @NoRepeatSubmit | 
				
			|||
    @PostMapping("update") | 
				
			|||
    public Result update(@RequestBody DataSyncScopeDTO dto){ | 
				
			|||
        //效验数据
 | 
				
			|||
        ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class); | 
				
			|||
        dataSyncScopeService.update(dto); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @PostMapping("delete") | 
				
			|||
    public Result delete(@RequestBody String[] ids){ | 
				
			|||
        //效验数据
 | 
				
			|||
        AssertUtils.isArrayEmpty(ids, "id"); | 
				
			|||
        dataSyncScopeService.delete(ids); | 
				
			|||
        return new Result(); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,16 @@ | 
				
			|||
package com.epmet.dao; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.mybatis.dao.BaseDao; | 
				
			|||
import com.epmet.entity.DataSyncConfigEntity; | 
				
			|||
import org.apache.ibatis.annotations.Mapper; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Mapper | 
				
			|||
public interface DataSyncConfigDao extends BaseDao<DataSyncConfigEntity> { | 
				
			|||
	 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,16 @@ | 
				
			|||
package com.epmet.dao; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.mybatis.dao.BaseDao; | 
				
			|||
import com.epmet.entity.DataSyncScopeEntity; | 
				
			|||
import org.apache.ibatis.annotations.Mapper; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Mapper | 
				
			|||
public interface DataSyncScopeDao extends BaseDao<DataSyncScopeEntity> { | 
				
			|||
	 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,51 @@ | 
				
			|||
package com.epmet.entity; | 
				
			|||
 | 
				
			|||
import com.baomidou.mybatisplus.annotation.TableName; | 
				
			|||
import com.epmet.commons.mybatis.entity.BaseEpmetEntity; | 
				
			|||
import lombok.Data; | 
				
			|||
import lombok.EqualsAndHashCode; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Data | 
				
			|||
@EqualsAndHashCode(callSuper=false) | 
				
			|||
@TableName("data_sync_config") | 
				
			|||
public class DataSyncConfigEntity extends BaseEpmetEntity { | 
				
			|||
 | 
				
			|||
	private static final long serialVersionUID = 1L; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 客户ID。如果该角色由客户定制,其下的机关和部门都不再各自定制自己的角色,这个字段会比较有用。包括通用角色以及客户定制角色。 | 
				
			|||
     */ | 
				
			|||
	private String customerId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 部门编码 | 
				
			|||
     */ | 
				
			|||
	private String deptCode; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 部门名称 | 
				
			|||
     */ | 
				
			|||
	private String deptName; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 数据名称 | 
				
			|||
     */ | 
				
			|||
	private String dataName; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 开启:open;关闭:closed | 
				
			|||
     */ | 
				
			|||
	private String switchStatus; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 排序 | 
				
			|||
     */ | 
				
			|||
	private Integer sort; | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,59 @@ | 
				
			|||
package com.epmet.entity; | 
				
			|||
 | 
				
			|||
import com.baomidou.mybatisplus.annotation.TableName; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.mybatis.entity.BaseEpmetEntity; | 
				
			|||
import lombok.Data; | 
				
			|||
import lombok.EqualsAndHashCode; | 
				
			|||
 | 
				
			|||
import java.util.Date; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Data | 
				
			|||
@EqualsAndHashCode(callSuper=false) | 
				
			|||
@TableName("data_sync_scope") | 
				
			|||
public class DataSyncScopeEntity extends BaseEpmetEntity { | 
				
			|||
 | 
				
			|||
	private static final long serialVersionUID = 1L; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 客户ID。如果该角色由客户定制,其下的机关和部门都不再各自定制自己的角色,这个字段会比较有用。包括通用角色以及客户定制角色。 | 
				
			|||
     */ | 
				
			|||
	private String customerId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 数据更新配置表主键 | 
				
			|||
     */ | 
				
			|||
	private String dataSyncConfigId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 网格:grid, | 
				
			|||
社区级:community, | 
				
			|||
乡(镇、街道)级:street, | 
				
			|||
区县级: district, | 
				
			|||
市级: city | 
				
			|||
省级:province | 
				
			|||
     */ | 
				
			|||
	private String orgType; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 组织或者网格id | 
				
			|||
     */ | 
				
			|||
	private String orgId; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * org_id的上级 | 
				
			|||
     */ | 
				
			|||
	private String pid; | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * org_id的全路径,包含自身 | 
				
			|||
     */ | 
				
			|||
	private String orgIdPath; | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,78 @@ | 
				
			|||
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.entity.DataSyncConfigEntity; | 
				
			|||
 | 
				
			|||
import java.util.List; | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
public interface DataSyncConfigService extends BaseService<DataSyncConfigEntity> { | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认分页 | 
				
			|||
     * | 
				
			|||
     * @param params | 
				
			|||
     * @return PageData<DataSyncConfigDTO> | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    PageData<DataSyncConfigDTO> page(Map<String, Object> params); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认查询 | 
				
			|||
     * | 
				
			|||
     * @param params | 
				
			|||
     * @return java.util.List<DataSyncConfigDTO> | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    List<DataSyncConfigDTO> list(Map<String, Object> params); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 单条查询 | 
				
			|||
     * | 
				
			|||
     * @param id | 
				
			|||
     * @return DataSyncConfigDTO | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    DataSyncConfigDTO get(String id); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认保存 | 
				
			|||
     * | 
				
			|||
     * @param dto | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void save(DataSyncConfigDTO dto); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认更新 | 
				
			|||
     * | 
				
			|||
     * @param dto | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void update(DataSyncConfigDTO dto); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 批量删除 | 
				
			|||
     * | 
				
			|||
     * @param ids | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void delete(String[] ids); | 
				
			|||
} | 
				
			|||
@ -0,0 +1,78 @@ | 
				
			|||
package com.epmet.service; | 
				
			|||
 | 
				
			|||
import com.epmet.commons.mybatis.service.BaseService; | 
				
			|||
import com.epmet.commons.tools.page.PageData; | 
				
			|||
import com.epmet.dto.DataSyncScopeDTO; | 
				
			|||
import com.epmet.entity.DataSyncScopeEntity; | 
				
			|||
 | 
				
			|||
import java.util.List; | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
public interface DataSyncScopeService extends BaseService<DataSyncScopeEntity> { | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认分页 | 
				
			|||
     * | 
				
			|||
     * @param params | 
				
			|||
     * @return PageData<DataSyncScopeDTO> | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    PageData<DataSyncScopeDTO> page(Map<String, Object> params); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认查询 | 
				
			|||
     * | 
				
			|||
     * @param params | 
				
			|||
     * @return java.util.List<DataSyncScopeDTO> | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    List<DataSyncScopeDTO> list(Map<String, Object> params); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 单条查询 | 
				
			|||
     * | 
				
			|||
     * @param id | 
				
			|||
     * @return DataSyncScopeDTO | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    DataSyncScopeDTO get(String id); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认保存 | 
				
			|||
     * | 
				
			|||
     * @param dto | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void save(DataSyncScopeDTO dto); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 默认更新 | 
				
			|||
     * | 
				
			|||
     * @param dto | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void update(DataSyncScopeDTO dto); | 
				
			|||
 | 
				
			|||
    /** | 
				
			|||
     * 批量删除 | 
				
			|||
     * | 
				
			|||
     * @param ids | 
				
			|||
     * @return void | 
				
			|||
     * @author generator | 
				
			|||
     * @date 2022-09-26 | 
				
			|||
     */ | 
				
			|||
    void delete(String[] ids); | 
				
			|||
} | 
				
			|||
@ -0,0 +1,82 @@ | 
				
			|||
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.dao.DataSyncConfigDao; | 
				
			|||
import com.epmet.dto.DataSyncConfigDTO; | 
				
			|||
import com.epmet.entity.DataSyncConfigEntity; | 
				
			|||
import com.epmet.service.DataSyncConfigService; | 
				
			|||
import org.apache.commons.lang3.StringUtils; | 
				
			|||
import org.springframework.stereotype.Service; | 
				
			|||
import org.springframework.transaction.annotation.Transactional; | 
				
			|||
 | 
				
			|||
import java.util.Arrays; | 
				
			|||
import java.util.List; | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新配置表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@Service | 
				
			|||
public class DataSyncConfigServiceImpl extends BaseServiceImpl<DataSyncConfigDao, DataSyncConfigEntity> implements DataSyncConfigService { | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    public PageData<DataSyncConfigDTO> page(Map<String, Object> params) { | 
				
			|||
        IPage<DataSyncConfigEntity> page = baseDao.selectPage( | 
				
			|||
                getPage(params, FieldConstant.CREATED_TIME, false), | 
				
			|||
                getWrapper(params) | 
				
			|||
        ); | 
				
			|||
        return getPageData(page, DataSyncConfigDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    public List<DataSyncConfigDTO> list(Map<String, Object> params) { | 
				
			|||
        List<DataSyncConfigEntity> entityList = baseDao.selectList(getWrapper(params)); | 
				
			|||
 | 
				
			|||
        return ConvertUtils.sourceToTarget(entityList, DataSyncConfigDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    private QueryWrapper<DataSyncConfigEntity> getWrapper(Map<String, Object> params){ | 
				
			|||
        String id = (String)params.get(FieldConstant.ID_HUMP); | 
				
			|||
 | 
				
			|||
        QueryWrapper<DataSyncConfigEntity> wrapper = new QueryWrapper<>(); | 
				
			|||
        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); | 
				
			|||
 | 
				
			|||
        return wrapper; | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    public DataSyncConfigDTO get(String id) { | 
				
			|||
        DataSyncConfigEntity entity = baseDao.selectById(id); | 
				
			|||
        return ConvertUtils.sourceToTarget(entity, DataSyncConfigDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void save(DataSyncConfigDTO dto) { | 
				
			|||
        DataSyncConfigEntity entity = ConvertUtils.sourceToTarget(dto, DataSyncConfigEntity.class); | 
				
			|||
        insert(entity); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void update(DataSyncConfigDTO dto) { | 
				
			|||
        DataSyncConfigEntity entity = ConvertUtils.sourceToTarget(dto, DataSyncConfigEntity.class); | 
				
			|||
        updateById(entity); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void delete(String[] ids) { | 
				
			|||
        // 逻辑删除(@TableLogic 注解)
 | 
				
			|||
        baseDao.deleteBatchIds(Arrays.asList(ids)); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,87 @@ | 
				
			|||
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.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; | 
				
			|||
 | 
				
			|||
import java.util.Arrays; | 
				
			|||
import java.util.List; | 
				
			|||
import java.util.Map; | 
				
			|||
 | 
				
			|||
/** | 
				
			|||
 * 数据更新范围表 | 
				
			|||
 * | 
				
			|||
 * @author generator generator@elink-cn.com | 
				
			|||
 * @since v1.0.0 2022-09-26 | 
				
			|||
 */ | 
				
			|||
@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( | 
				
			|||
                getPage(params, FieldConstant.CREATED_TIME, false), | 
				
			|||
                getWrapper(params) | 
				
			|||
        ); | 
				
			|||
        return getPageData(page, DataSyncScopeDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    public List<DataSyncScopeDTO> list(Map<String, Object> params) { | 
				
			|||
        List<DataSyncScopeEntity> entityList = baseDao.selectList(getWrapper(params)); | 
				
			|||
 | 
				
			|||
        return ConvertUtils.sourceToTarget(entityList, DataSyncScopeDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    private QueryWrapper<DataSyncScopeEntity> getWrapper(Map<String, Object> params){ | 
				
			|||
        String id = (String)params.get(FieldConstant.ID_HUMP); | 
				
			|||
 | 
				
			|||
        QueryWrapper<DataSyncScopeEntity> wrapper = new QueryWrapper<>(); | 
				
			|||
        wrapper.eq(StringUtils.isNotBlank(id), FieldConstant.ID, id); | 
				
			|||
 | 
				
			|||
        return wrapper; | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    public DataSyncScopeDTO get(String id) { | 
				
			|||
        DataSyncScopeEntity entity = baseDao.selectById(id); | 
				
			|||
        return ConvertUtils.sourceToTarget(entity, DataSyncScopeDTO.class); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void save(DataSyncScopeDTO dto) { | 
				
			|||
        DataSyncScopeEntity entity = ConvertUtils.sourceToTarget(dto, DataSyncScopeEntity.class); | 
				
			|||
        insert(entity); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void update(DataSyncScopeDTO dto) { | 
				
			|||
        DataSyncScopeEntity entity = ConvertUtils.sourceToTarget(dto, DataSyncScopeEntity.class); | 
				
			|||
        updateById(entity); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
    @Override | 
				
			|||
    @Transactional(rollbackFor = Exception.class) | 
				
			|||
    public void delete(String[] ids) { | 
				
			|||
        // 逻辑删除(@TableLogic 注解)
 | 
				
			|||
        baseDao.deleteBatchIds(Arrays.asList(ids)); | 
				
			|||
    } | 
				
			|||
 | 
				
			|||
} | 
				
			|||
@ -0,0 +1,6 @@ | 
				
			|||
<?xml version="1.0" encoding="UTF-8"?> | 
				
			|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> | 
				
			|||
 | 
				
			|||
<mapper namespace="com.epmet.dao.DataSyncConfigDao"> | 
				
			|||
 | 
				
			|||
</mapper> | 
				
			|||
@ -0,0 +1,6 @@ | 
				
			|||
<?xml version="1.0" encoding="UTF-8"?> | 
				
			|||
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> | 
				
			|||
 | 
				
			|||
<mapper namespace="com.epmet.dao.DataSyncScopeDao"> | 
				
			|||
 | 
				
			|||
</mapper> | 
				
			|||
					Loading…
					
					
				
		Reference in new issue