Commit d402b3a1 authored by limei's avatar limei

Merge branch 'developer' of http://39.98.45.134:8090/moa/amos-boot-biz into developer

parents 3268d426 fd3fd6b5
...@@ -59,4 +59,6 @@ public class EquipmentDto extends BaseDto { ...@@ -59,4 +59,6 @@ public class EquipmentDto extends BaseDto {
@ApiModelProperty(value = "单位机构代码") @ApiModelProperty(value = "单位机构代码")
private String orgCode; private String orgCode;
private String companyName;
} }
...@@ -57,4 +57,8 @@ public class InstallNoticeDto extends BaseDto { ...@@ -57,4 +57,8 @@ public class InstallNoticeDto extends BaseDto {
@ApiModelProperty(value = "安装负责人") @ApiModelProperty(value = "安装负责人")
private String installPri; private String installPri;
private String projectName;
private String companyName;
} }
...@@ -106,4 +106,5 @@ public class ProjectDto extends BaseDto { ...@@ -106,4 +106,5 @@ public class ProjectDto extends BaseDto {
private String insDep; private String insDep;
private String insPerson; private String insPerson;
private String startDateString;
} }
...@@ -25,7 +25,7 @@ public class ProjectMaterialDto extends BaseDto { ...@@ -25,7 +25,7 @@ public class ProjectMaterialDto extends BaseDto {
@ApiModelProperty(value = "名称") @ApiModelProperty(value = "名称")
private String name; private String name;
@ApiModelProperty(value = "项目id") @ApiModelProperty(value = "企业id")
private Long companyId; private Long companyId;
@ApiModelProperty(value = "管材编号") @ApiModelProperty(value = "管材编号")
......
package com.yeejoin.amos.boot.module.ugp.api.dto; package com.yeejoin.amos.boot.module.ugp.api.dto;
import com.yeejoin.amos.boot.module.ugp.api.entity.Equipment;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto; import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
...@@ -27,10 +28,73 @@ public class ProjectResourceDto extends BaseDto { ...@@ -27,10 +28,73 @@ public class ProjectResourceDto extends BaseDto {
@ApiModelProperty(value = "资源名称") @ApiModelProperty(value = "资源名称")
private String name; private String name;
@ApiModelProperty(value = "sb名称")
private String equipmentName;
@ApiModelProperty(value = "资源类型(welder、material、equipment)") @ApiModelProperty(value = "资源类型(welder、material、equipment)")
private String type; private String type;
@ApiModelProperty(value = "资源id") @ApiModelProperty(value = "资源id")
private Long resourceId; private Long resourceId;
@ApiModelProperty(value = "管材编号")
private String code;
@ApiModelProperty(value = "管材规格")
private String spec;
@ApiModelProperty(value = "管材壁厚")
private Integer wallThickness;
@ApiModelProperty(value = "生产厂家")
private String manufacturer;
@ApiModelProperty(value = "生产日期")
private Date manufactureDate;
@ApiModelProperty(value = "生产编号")
private String batchNum;
@ApiModelProperty(value = "项目名称")
private String projectName;
@ApiModelProperty(value = "项目资源id")
private Long projectResourceId;
Equipment equipment;
@ApiModelProperty(value = "企业id")
private Long companyId;
// private String equipmentCode;
// private String equipmentType;
// private String equipmentManufacturer;
// private String equipmentManufacture_date;
@ApiModelProperty(value = "使用年限")
private String serviceLife;
@ApiModelProperty(value = "检定状态")
private String verifyStatus;
@ApiModelProperty(value = "检验日期")
private Date inspectionDate;
@ApiModelProperty(value = "使用状态")
private String useStatus;
@ApiModelProperty(value = "备注")
private String remark;
@ApiModelProperty(value = "单位机构代码")
private String orgCode;
} }
package com.yeejoin.amos.boot.module.ugp.api.mapper; package com.yeejoin.amos.boot.module.ugp.api.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto; import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto;
import com.yeejoin.amos.boot.module.ugp.api.entity.Company; import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
...@@ -17,5 +18,5 @@ import java.util.List; ...@@ -17,5 +18,5 @@ import java.util.List;
*/ */
@Mapper @Mapper
public interface CompanyMapper extends BaseMapper<Company> { public interface CompanyMapper extends BaseMapper<Company> {
List<CompanyDto> queryCompanyPage(Company companyParam); IPage<CompanyDto> queryCompanyPage(IPage<CompanyDto> page,Company companyParam);
} }
...@@ -3,13 +3,13 @@ package com.yeejoin.amos.boot.module.ugp.api.mapper; ...@@ -3,13 +3,13 @@ package com.yeejoin.amos.boot.module.ugp.api.mapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.ugp.api.dto.*; import com.yeejoin.amos.boot.module.ugp.api.dto.*;
import com.yeejoin.amos.boot.module.ugp.api.entity.Material;
import com.yeejoin.amos.boot.module.ugp.api.entity.Project; import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource; import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.aspectj.weaver.ast.Test; import org.aspectj.weaver.ast.Test;
import org.springframework.web.bind.annotation.RequestBody;
import java.util.List; import java.util.List;
import java.util.Set; import java.util.Set;
...@@ -43,4 +43,7 @@ public interface ProjectResourceMapper extends BaseMapper<ProjectResource> { ...@@ -43,4 +43,7 @@ public interface ProjectResourceMapper extends BaseMapper<ProjectResource> {
* 根据登录人角色去筛选 * 根据登录人角色去筛选
*/ */
List<Project> getProjectPage(String roleName, String companyId, Set<String> codes); List<Project> getProjectPage(String roleName, String companyId, Set<String> codes);
List<ProjectResourceDto> getProjectMaterial(String type, Set<String> codes, @RequestBody(required = false) ProjectResourceDto projectResourceDto);
List<ProjectResourceDto> getProjectEquipment(String type, Set<String> codes,@RequestBody(required = false) ProjectResourceDto projectResourceDto);
} }
...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.api.service; ...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.api.service;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto; import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto;
import com.yeejoin.amos.boot.module.ugp.api.entity.Company; import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
...@@ -14,7 +15,7 @@ import com.yeejoin.amos.boot.module.ugp.api.entity.Company; ...@@ -14,7 +15,7 @@ import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
*/ */
public interface ICompanyService { public interface ICompanyService {
Page<CompanyDto> queryCompanyPage(int current, int size,Company company); IPage<CompanyDto> queryCompanyPage(int current, int size, Company company);
......
...@@ -6,11 +6,11 @@ ...@@ -6,11 +6,11 @@
<select id="queryCompanyPage" resultType="com.yeejoin.amos.boot.module.ugp.api.entity.Company"> <select id="queryCompanyPage" resultType="com.yeejoin.amos.boot.module.ugp.api.entity.Company">
select * from tz_ugp_company select * from tz_ugp_company
<where> <where>
<if test="name != '' and name != null"> <if test="companyParam.name != '' and companyParam.name != null">
and `name` like concat('%',#{name},'%') and `name` like concat('%',#{companyParam.name},'%')
</if> </if>
<if test="type != '' and type != null"> <if test="companyParam.type != '' and companyParam.type != null">
and `type` like concat('%',#{type},'%') and `type` like concat('%',#{companyParam.type},'%')
</if> </if>
</where> </where>
</select> </select>
......
...@@ -2,7 +2,7 @@ ...@@ -2,7 +2,7 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.ugp.api.mapper.EquipmentMapper"> <mapper namespace="com.yeejoin.amos.boot.module.ugp.api.mapper.EquipmentMapper">
<select id="queryEquipmentPage" resultType="com.yeejoin.amos.boot.module.ugp.api.entity.Equipment"> <select id="queryEquipmentPage" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.EquipmentDto">
select * from tz_ugp_equipment select * from tz_ugp_equipment
<where> <where>
<if test="equipment.name != '' and equipment.name != null"> <if test="equipment.name != '' and equipment.name != null">
......
...@@ -134,4 +134,72 @@ ...@@ -134,4 +134,72 @@
</where> </where>
</select> </select>
<select id="getProjectMaterial" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.ProjectResourceDto">
SELECT
material.`name`,
material.`code`,
material.type,
material.spec,
material.wall_thickness,
material.manufacturer,
material.manufacture_date,
material.batch_num,
material.sequence_nbr,
material.rec_date,
project.`name` AS projectName
FROM tz_ugp_project_resource resource
LEFT JOIN tz_ugp_material AS material ON resource.resource_id = material.sequence_nbr
LEFT JOIN tz_ugp_project AS project ON project.sequence_nbr = resource.project_id
<where>
resource.type = #{type}
<if test="projectResourceDto !=null">
<if test="projectResourceDto.name !=null and projectResourceDto.name != ''">
and material.`name` LIKE CONCAT("%",#{projectResourceDto.name},"%")
</if>
<if test="projectResourceDto.projectName !=null and projectResourceDto.projectName != ''">
and project.`name` LIKE CONCAT("%",#{projectResourceDto.projectName},"%")
</if>
</if>
<if test="codes !=null">
AND resource.project_id in
<foreach collection="codes" item = "item" index="index" open="(" separator="," close=")">
#{item}
</foreach>
</if>
</where>
</select>
<select id="getProjectEquipment" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.ProjectResourceDto">
SELECT
equipment.name ,
equipment.`code`,
equipment.type ,
equipment.manufacturer,
equipment.manufacture_date ,
equipment.service_life,
equipment.verify_status,
equipment.sequence_nbr,
project.`name` AS projectName
FROM tz_ugp_project_resource resource
LEFT JOIN tz_ugp_project AS project ON project.sequence_nbr = resource.project_id
LEFT JOIN tz_ugp_equipment AS equipment ON equipment.sequence_nbr = resource.resource_id
<where>
resource.type = #{type}
<if test="projectResourceDto !=null">
<if test="projectResourceDto.name !=null and projectResourceDto.name != ''">
and equipment.`name` LIKE CONCAT("%",#{projectResourceDto.name},"%")
</if>
<if test="projectResourceDto.projectName !=null and projectResourceDto.projectName != ''">
and project.`name` LIKE CONCAT("%",#{projectResourceDto.projectName},"%")
</if>
</if>
<if test="codes !=null">
AND resource.project_id in
<foreach collection="codes" item = "item" index="index" open="(" separator="," close=")">
#{item}
</foreach>
</if>
</where>
</select>
</mapper> </mapper>
...@@ -164,11 +164,10 @@ public class CompanyController extends BaseController { ...@@ -164,11 +164,10 @@ public class CompanyController extends BaseController {
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@GetMapping(value = "/page") @PostMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "企业信息表分页查询", notes = "企业信息表分页查询") @ApiOperation(httpMethod = "GET",value = "企业信息表分页查询", notes = "企业信息表分页查询")
public ResponseModel<Page<CompanyDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam public ResponseModel<IPage<CompanyDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size,Company company) { (value = "size") int size,@RequestBody Company company) {
return ResponseHelper.buildResponse(companyServiceImpl.queryCompanyPage(current,size,company)); return ResponseHelper.buildResponse(companyServiceImpl.queryCompanyPage(current,size,company));
} }
......
...@@ -142,8 +142,14 @@ public class EquipmentController extends BaseController { ...@@ -142,8 +142,14 @@ public class EquipmentController extends BaseController {
IPage<EquipmentDto> page = new Page<>(); IPage<EquipmentDto> page = new Page<>();
page.setSize(size); page.setSize(size);
page.setCurrent(current); page.setCurrent(current);
// equipment.setCompanyId(orgService.getReginParams().getBusinessInfo().getCompanySequenceNbr()); page = equipmentServiceImpl.queryEquipmentPage(page,equipment);
return ResponseHelper.buildResponse(equipmentServiceImpl.queryEquipmentPage(page,equipment)); List<EquipmentDto> equipments = page.getRecords();
if(!ValidationUtil.isEmpty(equipments)) {
for (EquipmentDto equipmentDto : equipments) {
equipmentDto.setCompanyName((String) orgService.getdetialInfo(String.valueOf(equipmentDto.getCompanyId())).get("name"));
}
}
return ResponseHelper.buildResponse(page);
} }
/** /**
......
...@@ -28,6 +28,7 @@ import io.swagger.annotations.Api; ...@@ -28,6 +28,7 @@ import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import java.text.ParseException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
...@@ -77,7 +78,6 @@ public class ProjectController extends BaseController { ...@@ -77,7 +78,6 @@ public class ProjectController extends BaseController {
public ResponseModel<ProjectDto> save(@RequestBody ProjectDto model) { public ResponseModel<ProjectDto> save(@RequestBody ProjectDto model) {
String regionName = "",regionCode = ""; String regionName = "",regionCode = "";
Map<String,String> map = getInfo(regionName,regionCode,Long.valueOf(model.getInstallRegionCode())); Map<String,String> map = getInfo(regionName,regionCode,Long.valueOf(model.getInstallRegionCode()));
model.setStartDate(new Date());
model.setSubmitDate(new Date()); model.setSubmitDate(new Date());
model.setInstallationUnit(orgServiceImpl.getOrgUsrById(String.valueOf(model.getInstallationUnitId())).getBizOrgName()); model.setInstallationUnit(orgServiceImpl.getOrgUsrById(String.valueOf(model.getInstallationUnitId())).getBizOrgName());
model.setDesignUnit(orgServiceImpl.getOrgUsrById(String.valueOf(model.getDesignUnitId())).getBizOrgName()); model.setDesignUnit(orgServiceImpl.getOrgUsrById(String.valueOf(model.getDesignUnitId())).getBizOrgName());
...@@ -162,6 +162,8 @@ public class ProjectController extends BaseController { ...@@ -162,6 +162,8 @@ public class ProjectController extends BaseController {
@GetMapping(value = "/{sequenceNbr}") @GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个项目信息表", notes = "根据sequenceNbr查询单个项目信息表") @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个项目信息表", notes = "根据sequenceNbr查询单个项目信息表")
public ResponseModel<ProjectDto> selectOne(@PathVariable Long sequenceNbr) { public ResponseModel<ProjectDto> selectOne(@PathVariable Long sequenceNbr) {
ProjectDto projectDto = projectServiceImpl.queryBySeq(sequenceNbr);
projectDto.setStartDateString(new SimpleDateFormat("yyy-MM-dd HH:mm:ss").format(projectDto.getStartDate()));
return ResponseHelper.buildResponse(projectServiceImpl.queryBySeq(sequenceNbr)); return ResponseHelper.buildResponse(projectServiceImpl.queryBySeq(sequenceNbr));
} }
...@@ -255,14 +257,29 @@ public class ProjectController extends BaseController { ...@@ -255,14 +257,29 @@ public class ProjectController extends BaseController {
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "GET", value = "项目审核", notes = "项目审核") @ApiOperation(httpMethod = "GET", value = "项目审核", notes = "项目审核")
@GetMapping(value = "/processProject") @PostMapping(value = "/processProject")
public ResponseModel<String> processProject(String sequenceNbr,String option){ public ResponseModel<String> processProject(@RequestParam("sequenceNbr") String sequenceNbr,String option,@RequestBody JSONObject json){
Project project = projectServiceImpl.getById(sequenceNbr); Project project = projectServiceImpl.getById(sequenceNbr);
JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project)); JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project));
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核不通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核不通过");
if("1".equals(option)){ if("1".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核通过"); jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核通过");
} }
if(ValidationUtil.isEmpty(option)){
option = json.getString(XJConstant.PROCESS_PROJECT_STATE);
if("1".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批通过");
} else if ("0".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审批不通过");
} else if ("2".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审核通过");
option = "1";
} else if ("3".equals(option)){
jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"资料审核不通过");
option = "0";
}
}
projectInitiationService.execute(project.getInstanceId(),jsonObject,option); projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
return ResponseHelper.buildResponse("ok"); return ResponseHelper.buildResponse("ok");
} }
......
...@@ -271,11 +271,11 @@ public class ProjectResourceController extends BaseController { ...@@ -271,11 +271,11 @@ public class ProjectResourceController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
@PostMapping(value = "/getResourceInfo") @PostMapping(value = "/getResourceInfo")
@ApiOperation(httpMethod = "POST",value = "根据type获取当前登录所在单位下的项目中的所有资源列表", notes = "根据type获取当前登录所在单位下的项目中的所有资源列表") @ApiOperation(httpMethod = "POST",value = "根据type获取当前登录所在单位下的项目中的所有资源列表", notes = "根据type获取当前登录所在单位下的项目中的所有资源列表")
public ResponseModel<IPage> getResourceInfo(Long current,Long size,String type){ public ResponseModel<IPage> getResourceInfo(Long current,Long size,String type,@RequestBody(required = false) ProjectResourceDto projectResourceinfo){
IPage page = new Page(); IPage page = new Page();
page.setSize(size); page.setSize(size);
page.setCurrent(current); page.setCurrent(current);
return ResponseHelper.buildResponse(projectResourceServiceImpl.getResourceInfo(type,page)); return ResponseHelper.buildResponse(projectResourceServiceImpl.getResourceInfo(type,page,projectResourceinfo));
} }
......
...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.biz.service.impl; ...@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.yeejoin.amos.boot.biz.common.bo.ReginParams; import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum; import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
import com.yeejoin.amos.boot.module.ugp.api.entity.Company; import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
...@@ -62,24 +63,12 @@ public class CompanyServiceImpl extends BaseService<CompanyDto, Company, Company ...@@ -62,24 +63,12 @@ public class CompanyServiceImpl extends BaseService<CompanyDto, Company, Company
/** /**
* 分页查询+筛选 * 分页查询+筛选
*/ */
public Page<CompanyDto> queryCompanyPage(int current, int size, Company company) { @Override
Page<CompanyDto> page = new Page<>(); public IPage<CompanyDto> queryCompanyPage(int current, int size, Company company) {
IPage<CompanyDto> page = new Page<>();
page.setSize(size); page.setSize(size);
page.setCurrent(current); page.setCurrent(current);
return companyMapper.queryCompanyPage(page,company);
this.list();
List<CompanyDto> companies = companyMapper.queryCompanyPage(company);
// List<CompanyDto> companyDtos = new ArrayList<>();
// BeanUtils.copyProperties(companies,companyDtos);
page.setRecords(companies);
// if (companyDto.getName() != null) {
// List<CompanyDto> collect = page1.getRecords().stream().filter(a -> a.getName().equals(companyDto.getName())).collect(Collectors.toList());
// page1.setRecords(collect);
// }
return page;
} }
/** /**
......
...@@ -104,6 +104,8 @@ public class InstallNoticeServiceImpl extends BaseService<InstallNoticeDto,Insta ...@@ -104,6 +104,8 @@ public class InstallNoticeServiceImpl extends BaseService<InstallNoticeDto,Insta
InstallNoticeDto installNoticeDto = new InstallNoticeDto(); InstallNoticeDto installNoticeDto = new InstallNoticeDto();
final ProjectDto projectDto = projectServiceImpl.queryBySeq(object.getLong("name")); final ProjectDto projectDto = projectServiceImpl.queryBySeq(object.getLong("name"));
installNoticeDto.setProjectId(object.getLong("name")); installNoticeDto.setProjectId(object.getLong("name"));
installNoticeDto.setProjectName(projectDto.getName());
installNoticeDto.setCompanyName(projectDto.getInstallationUnit());
installNoticeDto.setNoticeStatus(noticeStatus); installNoticeDto.setNoticeStatus(noticeStatus);
installNoticeDto.setNoticeDate(new Date()); installNoticeDto.setNoticeDate(new Date());
installNoticeDto.setApproved(false); installNoticeDto.setApproved(false);
......
package com.yeejoin.amos.boot.module.ugp.biz.service.impl; package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
...@@ -77,7 +78,11 @@ public class OrgServiceImpl { ...@@ -77,7 +78,11 @@ public class OrgServiceImpl {
BeanUtils.copyProperties(dynamicFormColumn, dynamicFormInstance); BeanUtils.copyProperties(dynamicFormColumn, dynamicFormInstance);
dynamicFormInstance.setFormColumnId(dynamicFormColumn.getSequenceNbr()); dynamicFormInstance.setFormColumnId(dynamicFormColumn.getSequenceNbr());
//通过字段名去拿到表单传来的值 //通过字段名去拿到表单传来的值
if("image".equals(dynamicFormColumn.getFieldCode())){
dynamicFormInstance.setFieldValue(JSON.toJSONString(jsonObject.getJSONArray(dynamicFormInstance.getFieldCode())));
}else{
dynamicFormInstance.setFieldValue(jsonObject.getString(dynamicFormInstance.getFieldCode())); dynamicFormInstance.setFieldValue(jsonObject.getString(dynamicFormInstance.getFieldCode()));
}
dynamicFormInstance.setInstanceId(orgUsr.getSequenceNbr()); dynamicFormInstance.setInstanceId(orgUsr.getSequenceNbr());
dynamicFormInstance.setSequenceNbr(null); dynamicFormInstance.setSequenceNbr(null);
dynamicFormInstanceList.add(dynamicFormInstance); dynamicFormInstanceList.add(dynamicFormInstance);
...@@ -235,7 +240,13 @@ public class OrgServiceImpl { ...@@ -235,7 +240,13 @@ public class OrgServiceImpl {
map.put("type",type); map.put("type",type);
map.put("sequenceNbr",sequenceNbr); map.put("sequenceNbr",sequenceNbr);
for (DynamicFormInstance dynamicFormInstance : dynamicFormInstanceList) { for (DynamicFormInstance dynamicFormInstance : dynamicFormInstanceList) {
map.put(dynamicFormInstance.getFieldCode(),dynamicFormInstance.getFieldValue()); if("image".equals(dynamicFormInstance.getFieldCode())){
if(!ValidationUtil.isEmpty(dynamicFormInstance.getFieldValue())){
map.put(dynamicFormInstance.getFieldCode(),JSON.parseArray(dynamicFormInstance.getFieldValue()));
}
} else {
map.put(dynamicFormInstance.getFieldCode(), dynamicFormInstance.getFieldValue());
}
} }
return map; return map;
} }
......
...@@ -156,7 +156,7 @@ public class ProblemInitiationServiceImpl { ...@@ -156,7 +156,7 @@ public class ProblemInitiationServiceImpl {
HashMap<String, String> smsParams = new HashMap(); HashMap<String, String> smsParams = new HashMap();
smsParams.put("smsCode", smsCode); smsParams.put("smsCode", smsCode);
smsParams.put("projectName", object.getString("projectName")); smsParams.put("projectName", object.getString("projectName"));
smsParams.put("problemDesc", object.getString("problemDesc")); smsParams.put("CompanyName", object.getString("CompanyName"));
//条件构造器 通过项目id查出来的项目详情信息中的区域代码,在监管区域规则表中拿到详细信息中的监察部门id,在使用监察部门id拿到平台的监察部门id //条件构造器 通过项目id查出来的项目详情信息中的区域代码,在监管区域规则表中拿到详细信息中的监察部门id,在使用监察部门id拿到平台的监察部门id
LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode()); wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode());
...@@ -211,7 +211,7 @@ public class ProblemInitiationServiceImpl { ...@@ -211,7 +211,7 @@ public class ProblemInitiationServiceImpl {
continue; continue;
} }
if(SMSEnum.项目安装告知申请.getCode().equals(smsCode) || SMSEnum.项目立项驳回短信.getCode().equals(smsCode)){ if(SMSEnum.项目安装告知申请.getCode().equals(smsCode) || SMSEnum.项目立项驳回短信.getCode().equals(smsCode)){
saveProjectSmsLog(smsRecordModel,sequenceNbr,noticeUnitId,agencyUserModel,object); saveProjectSmsLog(smsRecordModel,sequenceNbr,noticeUnitId,agencyUserModel,object,smsCode);
}else { }else {
saveProblemSmsLog(smsRecordModel,sequenceNbr,noticeUnitId,agencyUserModel); saveProblemSmsLog(smsRecordModel,sequenceNbr,noticeUnitId,agencyUserModel);
} }
...@@ -220,11 +220,32 @@ public class ProblemInitiationServiceImpl { ...@@ -220,11 +220,32 @@ public class ProblemInitiationServiceImpl {
} }
} }
public void saveProjectSmsLog(SmsRecordModel smsRecordModel,Long sequenceNbr,String noticeUnitId,AgencyUserModel agencyUserModel,JSONObject object){ public void saveProjectSmsLog(SmsRecordModel smsRecordModel,Long sequenceNbr,String noticeUnitId,AgencyUserModel agencyUserModel,JSONObject object,String smsCode){
String content = Systemctl.smsTemplateClient.seleteOne(smsCode).getResult().getSmsContent();
String projectName = object.getString("projectName");
String companyName = object.getString("companyName");
String reviewInfo = object.getString("reviewInfo");
if(!ValidationUtil.isEmpty(projectName)){
if(content.contains("${projectName}")) {
content = content.replace("${projectName}", projectName);
}
}
if(!ValidationUtil.isEmpty(companyName)){
if(content.contains("${companyName}")){
content = content.replace("${companyName}",companyName);
}
}
if(!ValidationUtil.isEmpty(reviewInfo)){
if(content.contains("${reviewInfo}")) {
content = content.replace("${reviewInfo}", reviewInfo);
}
}
LambdaQueryWrapper<OrgUsr> wrapperQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<OrgUsr> wrapperQueryWrapper = new LambdaQueryWrapper<>();
wrapperQueryWrapper.eq(OrgUsr::getAmosOrgId,agencyUserModel.getSequenceNbr()); wrapperQueryWrapper.eq(OrgUsr::getAmosOrgId,agencyUserModel.getSequenceNbr());
InstallNoticeMsg installNoticeMsg = new InstallNoticeMsg(); InstallNoticeMsg installNoticeMsg = new InstallNoticeMsg();
installNoticeMsg.setContent(smsRecordModel.getSmsContent()); installNoticeMsg.setContent(content);
installNoticeMsg.setInstallNoticeId(object.getLong("sequenceNbr")); installNoticeMsg.setInstallNoticeId(object.getLong("sequenceNbr"));
installNoticeMsg.setTargetUnitId(Long.valueOf(noticeUnitId)); installNoticeMsg.setTargetUnitId(Long.valueOf(noticeUnitId));
installNoticeMsg.setTargetPersonId(orgUsrServiceImpl.getOne(wrapperQueryWrapper).getSequenceNbr()); installNoticeMsg.setTargetPersonId(orgUsrServiceImpl.getOne(wrapperQueryWrapper).getSequenceNbr());
......
package com.yeejoin.amos.boot.module.ugp.biz.service.impl; package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; 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.metadata.IPage;
import com.yeejoin.amos.boot.biz.common.bo.ReginParams; import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity; import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
...@@ -20,7 +19,6 @@ import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper; ...@@ -20,7 +19,6 @@ import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
import com.yeejoin.amos.boot.module.ugp.api.service.IProjectResourceService; import com.yeejoin.amos.boot.module.ugp.api.service.IProjectResourceService;
import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectResourceDto; import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectResourceDto;
import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify; import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify;
import io.swagger.annotations.Api;
import org.aspectj.weaver.ast.Test; import org.aspectj.weaver.ast.Test;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
...@@ -33,8 +31,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -33,8 +31,6 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
import static com.yeejoin.amos.boot.module.ugp.api.Enum.ProjectResourceEnum.*; import static com.yeejoin.amos.boot.module.ugp.api.Enum.ProjectResourceEnum.*;
/** /**
...@@ -261,14 +257,17 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P ...@@ -261,14 +257,17 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P
* @return * @return
*/ */
@BusinessIdentify @BusinessIdentify
public IPage getResourceInfo(String type,IPage page){ public IPage getResourceInfo(String type,IPage page,ProjectResourceDto projectResourceinfo){
List<Project> projectList = this.getProjectList(); List<Project> projectList = this.getProjectList();
List<Long> projectIdList = new ArrayList<>(); List<Long> projectIdList = new ArrayList<>();
List<Long> idList = new ArrayList<>(); List<Long> idList = new ArrayList<>();
List list = new ArrayList<>(); List<ProjectResourceDto> list = new ArrayList<>();
Set<String> codes = new HashSet<>();
Map map = new HashMap(); Map map = new HashMap();
for(Project project:projectList){ for(Project project:projectList){
//获取项目id
projectIdList.add(project.getSequenceNbr()); projectIdList.add(project.getSequenceNbr());
codes.add(project.getSequenceNbr().toString());
map.put(project.getSequenceNbr(),project.getName()); map.put(project.getSequenceNbr(),project.getName());
} }
for(Long projectId:projectIdList){ for(Long projectId:projectIdList){
...@@ -277,7 +276,9 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P ...@@ -277,7 +276,9 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P
.eq(ProjectResource::getProjectId,projectId); .eq(ProjectResource::getProjectId,projectId);
IPage<ProjectResource> projectResourceList = this.page(page,projectResourceWrapper); IPage<ProjectResource> projectResourceList = this.page(page,projectResourceWrapper);
for(ProjectResource projectResource : projectResourceList.getRecords()){ for(ProjectResource projectResource : projectResourceList.getRecords()){
//获取资源ID
idList.add(projectResource.getResourceId()); idList.add(projectResource.getResourceId());
map.put(projectResource.getResourceId(),map.get(projectId)); map.put(projectResource.getResourceId(),map.get(projectId));
} }
} }
...@@ -290,34 +291,36 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P ...@@ -290,34 +291,36 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P
} }
page.setRecords(mapList); page.setRecords(mapList);
}else if(管材资源.getCode().equals(type)){ }else if(管材资源.getCode().equals(type)){
for(Long id:idList){ // for(Long id:idList){
ProjectMaterialDto projectMaterialDto = new ProjectMaterialDto(); // ProjectResourceDto projectMaterialDto = new ProjectResourceDto();
BeanUtils.copyProperties(materialService.getById(id),projectMaterialDto); List<ProjectResourceDto> projectResource1 = projectResourceMapper.getProjectMaterial(type, codes, projectResourceinfo);
//获取项目创建时间 //获取项目创建时间
LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>(); // LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(ProjectResource::getResourceId,id); // wrapper.eq(ProjectResource::getResourceId,id);
ProjectResource projectResource = projectResourceMapper.selectOne(wrapper); // ProjectResource projectResource = projectResourceMapper.selectOne(wrapper);
projectMaterialDto.setRecDate(projectResource.getRecDate()); // projectMaterialDto.setRecDate(projectResource.getRecDate());
projectMaterialDto.setProjectName(String.valueOf(map.get(id))); // projectMaterialDto.setProjectName(String.valueOf(map.get(id)));
projectMaterialDto.setProjectResourceId(id); // projectMaterialDto.setProjectResourceId(id);
list.add(projectMaterialDto);
} // }
page.setRecords(list); page.setRecords(projectResource1);
}else { }else {
for(Long id:idList){ // for(Long id:idList){
WelderEquipmentDto welderEquipmentDto = new WelderEquipmentDto(); // ProjectResourceDto projectResourceDto = new ProjectResourceDto();
BeanUtils.copyProperties(equipmentService.getById(id),welderEquipmentDto); List<ProjectResourceDto> projectResource1 = projectResourceMapper.getProjectEquipment(type, codes, projectResourceinfo);
//获取项目创建时间 // for (ProjectResourceDto i:projectResource1) {
LambdaQueryWrapper<ProjectResource> wrapper = new LambdaQueryWrapper<>(); // BeanUtils.copyProperties(i,projectResourceDto);
wrapper.eq(ProjectResource::getResourceId,id); // list.add(projectResourceDto);
ProjectResource projectResource = projectResourceMapper.selectOne(wrapper); // }
welderEquipmentDto.setRecDate(projectResource.getRecDate()); page.setRecords(projectResource1);
welderEquipmentDto.setProjectName(String.valueOf(map.get(id)));
welderEquipmentDto.setProjectResourceId(String.valueOf(id));
list.add(welderEquipmentDto);
}
page.setRecords(list);
} }
// }
return page; return page;
} }
} }
\ No newline at end of file
...@@ -96,11 +96,27 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project ...@@ -96,11 +96,27 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project
} }
if(ProjectInitiationEnum.平台审核.getName().equals(project.getStatus())){ if(ProjectInitiationEnum.平台审核.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){ if(ValidationUtil.isEmpty(state)){
state = "待审核"; state = "项目待审核";
} }
}else { } else if (ProjectInitiationEnum.告知申请.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){
state = "告知待申请";
}
} else if (ProjectInitiationEnum.接受告知.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){
state = "告知待接收";
}
} else if (ProjectInitiationEnum.审查项目.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){
state = "告知待接收";
}
} else if (ProjectInitiationEnum.提交资料.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){
state = "资料待上传";
}
} else if(ProjectInitiationEnum.项目立项.getName().equals(project.getStatus())){
if(ValidationUtil.isEmpty(state)){ if(ValidationUtil.isEmpty(state)){
state = "待上传资料"; state = "项目被驳回";
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment