新增能耗数据同步
This commit is contained in:
@@ -4,6 +4,7 @@ import com.baomidou.dynamic.datasource.annotation.DS;
|
|||||||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||||||
import com.lideeyunji.core.framework.entity.GrNhEntity;
|
import com.lideeyunji.core.framework.entity.GrNhEntity;
|
||||||
import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant;
|
import com.lideeyunji.tool.framework.common.constant.lideeYunJiBaseConstant;
|
||||||
|
import com.lideeyunji.tool.framework.sql.core.conditions.Wrapper;
|
||||||
import org.apache.ibatis.annotations.Param;
|
import org.apache.ibatis.annotations.Param;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -18,4 +19,12 @@ public interface GrNhMapper extends BaseMapper<GrNhEntity> {
|
|||||||
default int save(@Param("dataSourceType") String dataSourceType, GrNhEntity grNhEntity) {
|
default int save(@Param("dataSourceType") String dataSourceType, GrNhEntity grNhEntity) {
|
||||||
return this.insert(grNhEntity);
|
return this.insert(grNhEntity);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@DS(value = "#dataSourceType")
|
||||||
|
default int delete(@Param("dataSourceType") String dataSourceType, GrNhEntity grNhEntity) {
|
||||||
|
|
||||||
|
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -26,6 +26,7 @@ public class GrNhServiceImpl extends ServiceImpl<GrNhMapper, GrNhEntity> impleme
|
|||||||
@Override
|
@Override
|
||||||
@Transactional(rollbackFor = Exception.class)
|
@Transactional(rollbackFor = Exception.class)
|
||||||
public void delete(List<Long> idList) {
|
public void delete(List<Long> idList) {
|
||||||
|
|
||||||
removeByIds(idList);
|
removeByIds(idList);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user