|
@@ -34,8 +34,10 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.jms.core.JmsMessagingTemplate;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
@@ -57,7 +59,7 @@ import java.util.stream.Collectors;
|
|
|
*/
|
|
|
@Slf4j
|
|
|
@Service
|
|
|
-public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
+public class ProjectService extends ServiceImpl<ProjectMapper, Project> {
|
|
|
|
|
|
@Resource
|
|
|
private ProjectLiftRelevanceService projectLiftRelevanceService;
|
|
@@ -164,6 +166,21 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
return baseMapper.findByCondition(request.getPage(), request);
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * @param request 项目名称
|
|
|
+ * @return 项目列表
|
|
|
+ * @description 获取物业端数据接口
|
|
|
+ * @date 2020/5/11 10:21 上午
|
|
|
+ */
|
|
|
+ public IPage<Project> propertyList(ProjectRequest request) {
|
|
|
+ String projectName = request.getProjectName();
|
|
|
+ IPage<Project> projectPage = new Page<>(request.getPageNum(), request.getPageSize());
|
|
|
+ return this.page(projectPage, new QueryWrapper<Project>()
|
|
|
+ .select("id", "project_name projectName", "mt_company_id mtCompanyId")
|
|
|
+ .eq(StringUtils.isNotBlank(projectName), "project_name", projectName)
|
|
|
+ );
|
|
|
+ }
|
|
|
+
|
|
|
/**
|
|
|
* @param mtCompanyId 公司id
|
|
|
* @param projectStatus 项目状态
|
|
@@ -226,7 +243,7 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
* @description 项目ID和名称列表
|
|
|
* @date 2019/12/16 4:21 PM
|
|
|
*/
|
|
|
- public List<Map<String,Object>> projectIDList(ProjectRequest request) {
|
|
|
+ public List<Map<String, Object>> projectIDList(ProjectRequest request) {
|
|
|
QueryWrapper<Project> queryWrapper = new QueryWrapper<>();
|
|
|
queryWrapper.eq(ObjectUtil.isNotEmpty(request.getMtCompanyId()), "mt_company_id", request.getMtCompanyId());
|
|
|
queryWrapper.eq(ObjectUtil.isNotEmpty(request.getRegionId()), "region_id", request.getRegionId());
|
|
@@ -240,8 +257,8 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
* @description 根据项目id列表查询项目列表数据
|
|
|
* @date 2020/2/17 4:47 下午
|
|
|
*/
|
|
|
- public List<MaintenancePlanPrintResponse> queryProjectListByIdList(List<Long> projectIdList){
|
|
|
- return baseMapper.queryProjectListByIdList(projectIdList);
|
|
|
+ public List<MaintenancePlanPrintResponse> queryProjectListByIdList(List<Long> projectIdList) {
|
|
|
+ return baseMapper.queryProjectListByIdList(projectIdList);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -291,7 +308,7 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
- * @param projectId 项目ID
|
|
|
+ * @param projectId 项目ID
|
|
|
* @param mtCompanyId 公司ID
|
|
|
* @return
|
|
|
* @description 新增项目及项目服务中消息推送
|
|
@@ -376,7 +393,7 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
return RestResponse.success(null, MessageUtils.get("msg.modify.success"));
|
|
|
}
|
|
|
|
|
|
- public List<Map<String,String>> exportList(List<String> ids){
|
|
|
+ public List<Map<String, String>> exportList(List<String> ids) {
|
|
|
return baseMapper.exportList(ids);
|
|
|
}
|
|
|
|
|
@@ -404,6 +421,7 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
log.error("项目数据导出失败", e);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
/**
|
|
|
* @param request projectId 项目id
|
|
|
* @return RestResponse 状态码和返回消息
|
|
@@ -460,20 +478,21 @@ public class ProjectService extends ServiceImpl<ProjectMapper,Project> {
|
|
|
return project;
|
|
|
}
|
|
|
|
|
|
- private void rollback(){
|
|
|
+ private void rollback() {
|
|
|
//强制手动事务回滚
|
|
|
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 根据表格解析的数据,组装project
|
|
|
- * @author wcz
|
|
|
+ *
|
|
|
* @param projectImportModels 解析excel得到项目数据
|
|
|
- * @param mtCompanyId 维保公司
|
|
|
+ * @param mtCompanyId 维保公司
|
|
|
* @return RestResponse
|
|
|
+ * @author wcz
|
|
|
*/
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public RestResponse assemble(List<ProjectImportModel> projectImportModels,Long mtCompanyId){
|
|
|
+ public RestResponse assemble(List<ProjectImportModel> projectImportModels, Long mtCompanyId) {
|
|
|
//检查列表有效性
|
|
|
Validate.notNull(projectImportModels, "没有数据");
|
|
|
//存放新建的project
|