Commit 8862dd24 authored by chenzhao's avatar chenzhao

Merge branch 'developer' into wofkflow0620

# Conflicts: # amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/service/impl/SurveyInformationServiceImpl.java
parents 161531ed 7c2ea3bb
...@@ -88,4 +88,10 @@ public class PowerStationDto extends BaseDto { ...@@ -88,4 +88,10 @@ public class PowerStationDto extends BaseDto {
@ApiModelProperty(value = "契约锁合同id") @ApiModelProperty(value = "契约锁合同id")
private String contractLockId; private String contractLockId;
@ApiModelProperty(value = "盖章状态")
private String stampStatus;
@ApiModelProperty(value = "合同状态")
private String status;
} }
...@@ -10,8 +10,10 @@ ...@@ -10,8 +10,10 @@
hygf_peasant_household.regional_companies_name, hygf_peasant_household.regional_companies_name,
hygf_peasant_household.developer_code, hygf_peasant_household.developer_code,
hygf_peasant_household.developer_user_id, hygf_peasant_household.developer_user_id,
hygf_peasant_household.project_address_detail hygf_peasant_household.project_address_detail,
from hygf_power_station LEFT JOIN ( select peasant_household_id,initiate_status, contract_lock_id from hygf_household_contract where hygf_household_contract.status !='已作废' b.stamp_status,
b.status
from hygf_power_station LEFT JOIN ( select peasant_household_id,initiate_status, contract_lock_id,stamp_status,status from hygf_household_contract where hygf_household_contract.status !='已作废'
) b on b.peasant_household_id=hygf_power_station.peasant_household_id ) b on b.peasant_household_id=hygf_power_station.peasant_household_id
LEFT JOIN hygf_peasant_household on hygf_peasant_household.sequence_nbr=hygf_power_station.peasant_household_id LEFT JOIN hygf_peasant_household on hygf_peasant_household.sequence_nbr=hygf_power_station.peasant_household_id
where hygf_power_station.is_delete=0 where hygf_power_station.is_delete=0
......
...@@ -163,7 +163,10 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS ...@@ -163,7 +163,10 @@ public class PowerStationServiceImpl extends BaseService<PowerStationDto, PowerS
powerStation.setRecDate(new Date()); powerStation.setRecDate(new Date());
Boolean fl = this.saveOrUpdate(powerStation); //Boolean fl = this.saveOrUpdate(powerStation);
// 避免生成多份数据
Boolean fl = this.saveOrUpdate(powerStation,new LambdaQueryWrapper<PowerStation>()
.eq(PowerStation::getPeasantHouseholdId,powerStation.getPeasantHouseholdId()));
PowerStationNodeEnum powerStationNodeEnum = PowerStationNodeEnum PowerStationNodeEnum powerStationNodeEnum = PowerStationNodeEnum
.getNodeByCode(powerStation.getNextProcessNode()); .getNodeByCode(powerStation.getNextProcessNode());
......
...@@ -215,6 +215,7 @@ public class QiyuesuoServiceImpl { ...@@ -215,6 +215,7 @@ public class QiyuesuoServiceImpl {
List<Stamper> stampers = new ArrayList<>(); List<Stamper> stampers = new ArrayList<>();
stampers.add(stamper); stampers.add(stamper);
stampers.add(stamper2); stampers.add(stamper2);
//发起合同
SdkResponse<Object> data = this.getSdkResponse(result.getId(), stampers); SdkResponse<Object> data = this.getSdkResponse(result.getId(), stampers);
return result.getId(); return result.getId();
} }
......
...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl; ...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.hygf.biz.service.impl;
import cn.hutool.core.collection.CollectionUtil; import cn.hutool.core.collection.CollectionUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONArray;
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.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
...@@ -37,6 +38,8 @@ import org.typroject.tyboot.core.rdbms.service.BaseService; ...@@ -37,6 +38,8 @@ import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.typroject.tyboot.core.restful.exception.instance.BadRequest; import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import java.util.*; import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
/** /**
* 勘察信息服务实现类 * 勘察信息服务实现类
...@@ -46,31 +49,34 @@ import java.util.*; ...@@ -46,31 +49,34 @@ import java.util.*;
*/ */
@Service @Service
@Slf4j @Slf4j
public class SurveyInformationServiceImpl extends BaseService<SurveyInformationDto, SurveyInformation, SurveyInformationMapper> implements ISurveyInformationService { public class SurveyInformationServiceImpl
extends BaseService<SurveyInformationDto, SurveyInformation, SurveyInformationMapper>
implements ISurveyInformationService {
private static final String regionRedis = "app_region_redis";
private static final String OPERATION_TYPE_SUBMIT = "submit";
private static final String OPERATION_TYPE_APPLY = "apply";
private static final String IDX_REQUEST_STATE = "200";
@Autowired
protected EmqKeeper emqKeeper;
@Autowired @Autowired
SurveyDetailsServiceImpl surveyDetailsService; SurveyDetailsServiceImpl surveyDetailsService;
@Autowired @Autowired
InformationServiceImpl informationService; InformationServiceImpl informationService;
@Autowired @Autowired
ExtendedInformationServiceImpl extendedInformationService; ExtendedInformationServiceImpl extendedInformationService;
@Autowired @Autowired
CommercialServiceImpl commercialService; CommercialServiceImpl commercialService;
@Autowired @Autowired
PeasantHouseholdServiceImpl peasantHouseholdServiceImpl; PeasantHouseholdServiceImpl peasantHouseholdServiceImpl;
@Autowired @Autowired
DesignInformationServiceImpl designInformationService; DesignInformationServiceImpl designInformationService;
@Autowired @Autowired
WorkflowFeignClient workflowFeignClient; WorkflowFeignClient workflowFeignClient;
@Autowired @Autowired
RedisUtils redisUtils; RedisUtils redisUtils;
@Autowired @Autowired
IdxFeginService idxFeginService; IdxFeginService idxFeginService;
@Autowired @Autowired
...@@ -81,10 +87,22 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -81,10 +87,22 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
ToDoTasksMapper toDoTasksMapper; ToDoTasksMapper toDoTasksMapper;
@Autowired @Autowired
UserMessageMapper userMessageMapper; UserMessageMapper userMessageMapper;
@Value("${power.station.examine.pageId}")
private long pageId;
@Autowired
protected EmqKeeper emqKeeper;
@Value("${power.station.examine.planId}")
private String planId;
private static final String regionRedis = "app_region_redis";
private static final String OPERATION_TYPE_SUBMIT = "submit";
private static final String OPERATION_TYPE_APPLY = "apply";
private static final String IDX_REQUEST_STATE = "200";
@Autowired @Autowired
PersonnelBusinessMapper personnelBusinessMapper; PersonnelBusinessMapper personnelBusinessMapper;
@Autowired @Autowired
PeasantHouseholdMapper peasantHouseholdMapper; PeasantHouseholdMapper peasantHouseholdMapper;
@Autowired @Autowired
WorkOrderMapper workOrderMapper; WorkOrderMapper workOrderMapper;
@Autowired @Autowired
...@@ -95,6 +113,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -95,6 +113,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
ConstructionRecordsMapper constructionRecordsMapper; ConstructionRecordsMapper constructionRecordsMapper;
@Autowired @Autowired
BasicGridAcceptanceMapper basicGridAcceptanceMapper; BasicGridAcceptanceMapper basicGridAcceptanceMapper;
@Autowired @Autowired
SurveyInformationMapper surveyInformationMapper; SurveyInformationMapper surveyInformationMapper;
@Autowired @Autowired
...@@ -105,14 +124,9 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -105,14 +124,9 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
WorkOrderPowerStationMapper workOrderPowerStationMapper; WorkOrderPowerStationMapper workOrderPowerStationMapper;
@Autowired @Autowired
AmosRequestContext requestContext; AmosRequestContext requestContext;
@Autowired @Autowired
WorkflowImpl workflow; WorkflowImpl workflow;
@Value("${power.station.examine.pageId}")
private long pageId;
@Value("${power.station.examine.planId}")
private String planId;
@Autowired
private CommonServiceImpl commonService;
/** /**
* 分页查询 * 分页查询
...@@ -132,31 +146,37 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -132,31 +146,37 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
public SurveyInfoAllDto saveSurveyInfo(SurveyInfoAllDto surveyInfoAllDto, String operationType) { public SurveyInfoAllDto saveSurveyInfo(SurveyInfoAllDto surveyInfoAllDto, String operationType) {
try { try {
JSONArray regionName = getRegionName(); JSONArray regionName = getRegionName();
List<RegionModel> list = JSONArray.parseArray(regionName.toJSONString(), RegionModel.class); List<RegionModel> list = JSONArray.parseArray(regionName.toJSONString(), RegionModel.class);
// 更新勘察基本信息
//更新勘察基本信息 SurveyInformation surveyInformation = BeanDtoUtils.convert(surveyInfoAllDto.getSurveyInformation(),
SurveyInformation surveyInformation = BeanDtoUtils.convert(surveyInfoAllDto.getSurveyInformation(), SurveyInformation.class); SurveyInformation.class);
surveyInformation.setReview(0); surveyInformation.setReview(0);
if (OPERATION_TYPE_APPLY.equals(operationType) && null == surveyInformation.getCreatorTime()) { if (OPERATION_TYPE_APPLY.equals(operationType) && null == surveyInformation.getCreatorTime()) {
surveyInformation.setCreatorTime(new Date()); surveyInformation.setCreatorTime(new Date());
} }
this.saveOrUpdate(surveyInformation); this.saveOrUpdate(surveyInformation);
//更新扩展信息 // 更新扩展信息
ExtendedInformation extendedInformation = BeanDtoUtils.convert(surveyInfoAllDto.getExtendedInformation(), ExtendedInformation.class); ExtendedInformation extendedInformation = BeanDtoUtils.convert(surveyInfoAllDto.getExtendedInformation(),
ExtendedInformation.class);
extendedInformation.setSurveyInformationId(surveyInformation.getSequenceNbr()); extendedInformation.setSurveyInformationId(surveyInformation.getSequenceNbr());
extendedInformationService.saveOrUpdate(extendedInformation); // 避免生成多份数据
extendedInformationService.saveOrUpdate(extendedInformation, new LambdaQueryWrapper<ExtendedInformation>()
.eq(ExtendedInformation::getSurveyInformationId, surveyInformation.getSequenceNbr()));
//extendedInformationService.saveOrUpdate(extendedInformation);
//更新勘察明细信息 // 更新勘察明细信息
SurveyDetailsDto oldSurveyDetails = surveyInfoAllDto.getSurveyDetails(); SurveyDetailsDto oldSurveyDetails = surveyInfoAllDto.getSurveyDetails();
SurveyDetails surveyDetails = BeanDtoUtils.convert(oldSurveyDetails, SurveyDetails.class); SurveyDetails surveyDetails = BeanDtoUtils.convert(oldSurveyDetails, SurveyDetails.class);
surveyDetails.setSurveyInformationId(surveyInformation.getSequenceNbr()); surveyDetails.setSurveyInformationId(surveyInformation.getSequenceNbr());
surveyDetailsService.saveOrUpdate(surveyDetails); // 避免生成多份数据
surveyDetailsService.saveOrUpdate(surveyDetails, new LambdaQueryWrapper<SurveyDetails>()
.eq(SurveyDetails::getSurveyInformationId, surveyInformation.getSequenceNbr()));
//surveyDetailsService.saveOrUpdate(surveyDetails);
//更新商务信息 // 更新商务信息
CommercialDto oldCommercial = surveyInfoAllDto.getCommercial(); CommercialDto oldCommercial = surveyInfoAllDto.getCommercial();
Commercial commercial = BeanDtoUtils.convert(oldCommercial, Commercial.class); Commercial commercial = BeanDtoUtils.convert(oldCommercial, Commercial.class);
// 处理省市县 // 处理省市县
...@@ -170,22 +190,33 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -170,22 +190,33 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
commercial.setProjectAddressName(paddressName.substring(0, paddressName.length() - 1)); commercial.setProjectAddressName(paddressName.substring(0, paddressName.length() - 1));
commercial.setSurveyInformationId(surveyInformation.getSequenceNbr()); commercial.setSurveyInformationId(surveyInformation.getSequenceNbr());
commercialService.saveOrUpdate(commercial); // 避免生成多份数据
//勘察后,更新状态 commercialService.saveOrUpdate(commercial, new LambdaQueryWrapper<Commercial>()
.eq(Commercial::getSurveyInformationId, surveyInformation.getSequenceNbr()));
//commercialService.saveOrUpdate(commercial);
// 勘察后,更新状态
QueryWrapper<PeasantHousehold> peasantHouseholdQueryWrapper = new QueryWrapper<>(); QueryWrapper<PeasantHousehold> peasantHouseholdQueryWrapper = new QueryWrapper<>();
peasantHouseholdQueryWrapper.eq("survey_information_id", surveyInformation.getSequenceNbr()); peasantHouseholdQueryWrapper.eq("survey_information_id", surveyInformation.getSequenceNbr());
PeasantHousehold peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdQueryWrapper); PeasantHousehold peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper()
.selectOne(peasantHouseholdQueryWrapper);
//更新资料归档信息 // 更新资料归档信息
Information information = BeanDtoUtils.convert(surveyInfoAllDto.getInformation(), Information.class); Information information = BeanDtoUtils.convert(surveyInfoAllDto.getInformation(), Information.class);
information.setHouseProve(null == commercial ? null : (CollectionUtil.isNotEmpty(commercial.getRealEstateLegal()) ? commercial.getRealEstateLegal() : null)); information.setHouseProve(null == commercial ? null
information.setCardFile(null == commercial ? null : (CollectionUtil.isNotEmpty(commercial.getIdCardCredit()) ? commercial.getIdCardCredit() : null)); : (CollectionUtil.isNotEmpty(commercial.getRealEstateLegal()) ? commercial.getRealEstateLegal()
: null));
information.setCardFile(null == commercial ? null
: (CollectionUtil.isNotEmpty(commercial.getIdCardCredit()) ? commercial.getIdCardCredit() : null));
information.setCardFile(commercial.getAgentLegal()); information.setCardFile(commercial.getAgentLegal());
information.setArchivesNumber(this.getNo(CodeEnum.档案.getCode(), peasantHousehold.getRegionalCompaniesSeq())); information
.setArchivesNumber(this.getNo(CodeEnum.档案.getCode(), peasantHousehold.getRegionalCompaniesSeq()));
information.setFileNumber(this.getNo(CodeEnum.文件.getCode(), peasantHousehold.getRegionalCompaniesSeq())); information.setFileNumber(this.getNo(CodeEnum.文件.getCode(), peasantHousehold.getRegionalCompaniesSeq()));
information.setSurveyInformationId(surveyInformation.getSequenceNbr()); information.setSurveyInformationId(surveyInformation.getSequenceNbr());
informationService.saveOrUpdate(information);
// 避免生成多份数据
informationService.saveOrUpdate(information, new LambdaQueryWrapper<Information>()
.eq(Information::getSurveyInformationId, surveyInformation.getSequenceNbr()));
//informationService.saveOrUpdate(information);
peasantHousehold.setOwnersName(surveyInfoAllDto.getSurveyInformation().getOwnersName()); peasantHousehold.setOwnersName(surveyInfoAllDto.getSurveyInformation().getOwnersName());
peasantHousehold.setTelephone(surveyInfoAllDto.getSurveyInformation().getTelephone()); peasantHousehold.setTelephone(surveyInfoAllDto.getSurveyInformation().getTelephone());
...@@ -194,8 +225,10 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -194,8 +225,10 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
peasantHousehold.setProjectAddress(surveyInfoAllDto.getSurveyInformation().getProjectAddress()); peasantHousehold.setProjectAddress(surveyInfoAllDto.getSurveyInformation().getProjectAddress());
peasantHousehold.setProjectAddressDetail(surveyInfoAllDto.getSurveyInformation().getProjectAddressDetail()); peasantHousehold.setProjectAddressDetail(surveyInfoAllDto.getSurveyInformation().getProjectAddressDetail());
peasantHousehold.setPermanentAddress(surveyInfoAllDto.getSurveyInformation().getPermanentAddress()); peasantHousehold.setPermanentAddress(surveyInfoAllDto.getSurveyInformation().getPermanentAddress());
peasantHousehold.setPermanentAddressDetail(surveyInfoAllDto.getSurveyInformation().getPermanentAddressDetail()); peasantHousehold
peasantHousehold.setPermanentAddressDetail(surveyInfoAllDto.getSurveyInformation().getPermanentAddressDetail()); .setPermanentAddressDetail(surveyInfoAllDto.getSurveyInformation().getPermanentAddressDetail());
peasantHousehold
.setPermanentAddressDetail(surveyInfoAllDto.getSurveyInformation().getPermanentAddressDetail());
// 处理项目地址 // 处理项目地址
String projectAddressName = ""; String projectAddressName = "";
...@@ -207,7 +240,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -207,7 +240,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
} }
peasantHousehold.setProjectAddressName(projectAddressName.substring(0, projectAddressName.length() - 1)); peasantHousehold.setProjectAddressName(projectAddressName.substring(0, projectAddressName.length() - 1));
//常住地址 // 常住地址
String permanentAddressName = ""; String permanentAddressName = "";
for (Integer reg : surveyInfoAllDto.getSurveyInformation().getPermanentAddress()) { for (Integer reg : surveyInfoAllDto.getSurveyInformation().getPermanentAddress()) {
for (RegionModel re : list) { for (RegionModel re : list) {
...@@ -216,10 +249,11 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -216,10 +249,11 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
} }
} }
peasantHousehold.setPermanentAddressName(permanentAddressName.substring(0, permanentAddressName.length() - 1)); peasantHousehold
.setPermanentAddressName(permanentAddressName.substring(0, permanentAddressName.length() - 1));
if (OPERATION_TYPE_SUBMIT.equals(operationType)) { if (OPERATION_TYPE_SUBMIT.equals(operationType)) {
// peasantHousehold.setSurveyOrNot(1); // peasantHousehold.setSurveyOrNot(1);
} else if (OPERATION_TYPE_APPLY.equals(operationType)) { } else if (OPERATION_TYPE_APPLY.equals(operationType)) {
// 提交审核 // 提交审核
submitExamine(peasantHousehold); submitExamine(peasantHousehold);
...@@ -234,15 +268,17 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -234,15 +268,17 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
toDoTasksMapper.updateById(doTasks); toDoTasksMapper.updateById(doTasks);
emqKeeper.getMqttClient().publish("TASK_MESSAGE", JSON.toJSONString(doTasks).getBytes(), 2, false); emqKeeper.getMqttClient().publish("TASK_MESSAGE", JSON.toJSONString(doTasks).getBytes(), 2, false);
UserMessage userMessage = new UserMessage(doTasks.getType(), doTasks.getBusinessId(), doTasks.getAmosUserId(), new Date(), doTasks.getTaskName() + "已完成", doTasks.getAmosOrgCode()); UserMessage userMessage = new UserMessage(doTasks.getType(), doTasks.getBusinessId(),
doTasks.getAmosUserId(), new Date(), doTasks.getTaskName() + "已完成",
doTasks.getAmosOrgCode());
userMessageMapper.insert(userMessage); userMessageMapper.insert(userMessage);
emqKeeper.getMqttClient().publish("MY_MESSAGE", JSON.toJSONString(userMessage).getBytes(), 2, false); emqKeeper.getMqttClient().publish("MY_MESSAGE", JSON.toJSONString(userMessage).getBytes(), 2,
false);
} }
} }
peasantHouseholdServiceImpl.saveOrUpdate(peasantHousehold); peasantHouseholdServiceImpl.saveOrUpdate(peasantHousehold);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
throw new BadRequest("系统异常"); throw new BadRequest("系统异常");
...@@ -265,8 +301,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -265,8 +301,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
private void submitExamine(PeasantHousehold peasantHousehold) { private void submitExamine(PeasantHousehold peasantHousehold) {
PowerStation powerStation = powerStationService.getObjByNhId(String.valueOf(peasantHousehold.getSequenceNbr()),
PowerStation powerStation = powerStationService.getObjByNhId(String.valueOf(peasantHousehold.getSequenceNbr()), PowerStationProcessStateEnum.作废.getCode()); PowerStationProcessStateEnum.作废.getCode());
String taskId = null; String taskId = null;
Map<String, Object> objectMap = new HashMap<>(1); Map<String, Object> objectMap = new HashMap<>(1);
...@@ -275,7 +311,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -275,7 +311,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
// 保存并审核 // 保存并审核
try { try {
BasicGridAcceptance basicGridAcceptance = new BasicGridAcceptance(); BasicGridAcceptance basicGridAcceptance = new BasicGridAcceptance();
if (ObjectUtils.isNotEmpty(powerStation)) { if (ObjectUtils.isNotEmpty(powerStation)) {
// 工作流执行一步 // 工作流执行一步
...@@ -289,7 +324,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -289,7 +324,7 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
workflow.standard(basicGridAcceptance, standardDto, requestContext.getUserId()); workflow.standard(basicGridAcceptance, standardDto, requestContext.getUserId());
} else { } else {
// 第一步启动工作流 // 第一步启动工作流
//发起工作流 // 发起工作流
// 调用工作流执行第一个节点 // 调用工作流执行第一个节点
ProcessDto processDto = new ProcessDto(); ProcessDto processDto = new ProcessDto();
processDto.setBusinessKey(String.valueOf(peasantHousehold.getSequenceNbr())); processDto.setBusinessKey(String.valueOf(peasantHousehold.getSequenceNbr()));
...@@ -330,16 +365,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -330,16 +365,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
long idsk = peasantHousehold.getSequenceNbr(); long idsk = peasantHousehold.getSequenceNbr();
up.eq(PeasantHousehold::getSequenceNbr, idsk); up.eq(PeasantHousehold::getSequenceNbr, idsk);
peasantHouseholdMapper.update(null, up); peasantHouseholdMapper.update(null, up);
//发起待办
// commonService.buildTaskModel(buildDZSHTaskModel(peasantHousehold, basicGridAcceptance));
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
throw new BaseException("获取工作流节点失败!", "400", "获取工作流节点失败!"); throw new BaseException("获取工作流节点失败!", "400", "获取工作流节点失败!");
} }
// PowerStation powerStation = powerStationService.getObjByNhId(String.valueOf(peasantHousehold.getSequenceNbr()), PowerStationProcessStateEnum.作废.getCode()); // PowerStation powerStation = powerStationService.getObjByNhId(String.valueOf(peasantHousehold.getSequenceNbr()), PowerStationProcessStateEnum.作废.getCode());
// //
// String taskId = null; // String taskId = null;
...@@ -388,36 +419,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -388,36 +419,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
// } // }
} }
private List<TaskModelDto> buildDZSHTaskModel(PeasantHousehold peasantHousehold, BasicGridAcceptance basicGridAcceptance) { public SurveyInfoAllDto querySurveyInfo(String surveyInformationId, String peasantHouseholdId,
List<TaskModelDto> taskModelDtoList = new ArrayList<>(); String processInstanceId, AgencyUserModel userInfo) {
TaskModelDto taskModelDto = new TaskModelDto();
taskModelDto.setFlowCode(basicGridAcceptance.getNextTaskId());
taskModelDto.setFlowCreateDate(new Date());
taskModelDto.setFlowStatus(FlowStatusEnum.TO_BE_PROCESSED.getCode());
taskModelDto.setFlowStatusLabel(FlowStatusEnum.TO_BE_PROCESSED.getName());
taskModelDto.setPageType(null);
taskModelDto.setExecuteUserIds(basicGridAcceptance.getNextExecuteUserIds());
taskModelDto.setModel(peasantHousehold);
taskModelDto.setRelationId(basicGridAcceptance.getInstanceId());
taskModelDto.setRoutePath(null);
taskModelDto.setStartUserId(basicGridAcceptance.getRecUserId());
taskModelDto.setStartUser(basicGridAcceptance.getRecUserName());
taskModelDto.setStartDate(basicGridAcceptance.getRecDate());
taskModelDto.setStartUserCompanyName(peasantHousehold.getRegionalCompaniesName());
taskModelDto.setTaskName(basicGridAcceptance.getNextNodeName());
taskModelDto.setTaskCode(String.valueOf(basicGridAcceptance.getWorkOrderId()));
taskModelDto.setTaskType(BusinessTypeEnum.HYGF_DZ_SH.getCode());
taskModelDto.setTaskTypeLabel(BusinessTypeEnum.HYGF_DZ_SH.getName());
taskModelDto.setTaskStatus(TaskStatusEnum.UNDERWAY.getValue());
taskModelDto.setTaskStatusLabel(TaskStatusEnum.UNDERWAY.getName());
// taskModelDto.setTaskDesc();
// taskModelDto.setTaskContent();
taskModelDto.setNextExecuteUser(basicGridAcceptance.getNextExecutorIds());
taskModelDtoList.add(taskModelDto);
return taskModelDtoList;
}
public SurveyInfoAllDto querySurveyInfo(String surveyInformationId, String peasantHouseholdId, String processInstanceId, AgencyUserModel userInfo) {
SurveyInfoAllDto surveyInfoAllDto = new SurveyInfoAllDto(); SurveyInfoAllDto surveyInfoAllDto = new SurveyInfoAllDto();
PeasantHousehold peasantHousehold = new PeasantHousehold(); PeasantHousehold peasantHousehold = new PeasantHousehold();
...@@ -431,16 +434,16 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -431,16 +434,16 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
peasantHouseholdQueryWrapper.eq("survey_information_id", surveyInformationId); peasantHouseholdQueryWrapper.eq("survey_information_id", surveyInformationId);
peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdQueryWrapper); peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdQueryWrapper);
} }
//勘察基本信息 // 勘察基本信息
LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId); queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId);
SurveyInformation surveyInformation = this.baseMapper.selectOne(queryWrapper); SurveyInformation surveyInformation = this.baseMapper.selectOne(queryWrapper);
surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class)); surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class));
//农户信息 // 农户信息
// 获取用户所在经销商单位
//获取用户所在经销商单位 UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper.getUserUnitInformationDto(peasantHousehold.getDeveloperUserId()); .getUserUnitInformationDto(peasantHousehold.getDeveloperUserId());
BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation()); BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation());
surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName()); surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName());
...@@ -453,10 +456,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -453,10 +456,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) { if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) {
surveyInfoAllDto.getSurveyInformation().setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/"))); surveyInfoAllDto.getSurveyInformation()
.setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/")));
} }
if (!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())) { if (!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())) {
surveyInfoAllDto.getSurveyInformation().setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/"))); surveyInfoAllDto.getSurveyInformation()
.setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/")));
} }
if (peasantHousehold.getPermanentAddress() == null) { if (peasantHousehold.getPermanentAddress() == null) {
...@@ -464,9 +469,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -464,9 +469,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
surveyInfoAllDto.getSurveyInformation().setIsPermanent("1"); surveyInfoAllDto.getSurveyInformation().setIsPermanent("1");
} }
surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr()); surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr());
//制单时间 // 制单时间
surveyInfoAllDto.getSurveyInformation().setCreatorTime(surveyInformation.getCreatorTime()); surveyInfoAllDto.getSurveyInformation().setCreatorTime(surveyInformation.getCreatorTime());
QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>(); QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>();
...@@ -493,8 +497,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -493,8 +497,12 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
if (information == null) { if (information == null) {
surveyInfoAllDto.setInformation(new InformationDto()); surveyInfoAllDto.setInformation(new InformationDto());
} else { } else {
information.setHouseProve(null == commercial ? new ArrayList<>() : (CollectionUtil.isNotEmpty(commercial.getRealEstateLegal()) ? commercial.getRealEstateLegal() : new ArrayList<>())); information.setHouseProve(null == commercial ? new ArrayList<>()
information.setCardFile(null == commercial ? new ArrayList<>() : (CollectionUtil.isNotEmpty(commercial.getIdCardCredit()) ? commercial.getIdCardCredit() : new ArrayList<>())); : (CollectionUtil.isNotEmpty(commercial.getRealEstateLegal()) ? commercial.getRealEstateLegal()
: new ArrayList<>()));
information.setCardFile(null == commercial ? new ArrayList<>()
: (CollectionUtil.isNotEmpty(commercial.getIdCardCredit()) ? commercial.getIdCardCredit()
: new ArrayList<>()));
surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class)); surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class));
} }
...@@ -526,7 +534,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -526,7 +534,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
commercial.setSurveyPhotosWeb(list); commercial.setSurveyPhotosWeb(list);
if (information == null) { if (information == null) {
CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class); CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class);
commercialDto.setType("zrr"); commercialDto.setType("zrr");
...@@ -535,29 +542,32 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -535,29 +542,32 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} else { } else {
surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class)); surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class));
if (commercial != null && !StringUtils.isEmpty(commercial.getProjectAddressName())) { if (commercial != null && !StringUtils.isEmpty(commercial.getProjectAddressName())) {
surveyInfoAllDto.getCommercial().setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/"))); surveyInfoAllDto.getCommercial()
.setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/")));
} }
} }
QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>(); QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>();
extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId); extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId);
ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper().selectOne(extendedInformationQueryWrapper); ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper()
.selectOne(extendedInformationQueryWrapper);
if (information == null) { if (information == null) {
surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto()); surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto());
} else { } else {
surveyInfoAllDto.setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class)); surveyInfoAllDto
.setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class));
} }
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>(); QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr()); designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr());
DesignInformation designInformation = designInformationService.getBaseMapper().selectOne(designInformationQueryWrapper); DesignInformation designInformation = designInformationService.getBaseMapper()
.selectOne(designInformationQueryWrapper);
if (designInformation == null) { if (designInformation == null) {
surveyInfoAllDto.setDesignInformation(new DesignInformationDto()); surveyInfoAllDto.setDesignInformation(new DesignInformationDto());
} else { } else {
surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class)); surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class));
} }
LambdaQueryWrapper<WorkOrderPowerStation> up1 = new LambdaQueryWrapper(); LambdaQueryWrapper<WorkOrderPowerStation> up1 = new LambdaQueryWrapper();
up1.eq(WorkOrderPowerStation::getPeasantHouseholdId, peasantHouseholdId); up1.eq(WorkOrderPowerStation::getPeasantHouseholdId, peasantHouseholdId);
WorkOrderPowerStation workOrderPowerStation = workOrderPowerStationMapper.selectOne(up1); WorkOrderPowerStation workOrderPowerStation = workOrderPowerStationMapper.selectOne(up1);
...@@ -565,42 +575,53 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -565,42 +575,53 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
Long workOrderId = workOrderPowerStation.getWorkOrderId(); Long workOrderId = workOrderPowerStation.getWorkOrderId();
Long workOrderPowerStationId = workOrderPowerStation.getSequenceNbr(); Long workOrderPowerStationId = workOrderPowerStation.getSequenceNbr();
//派工单信息 // 派工单信息
LambdaQueryWrapper<WorkOrder> upl = new LambdaQueryWrapper(); LambdaQueryWrapper<WorkOrder> upl = new LambdaQueryWrapper();
upl.eq(WorkOrder::getSequenceNbr, workOrderId); upl.eq(WorkOrder::getSequenceNbr, workOrderId);
WorkOrder workOrder = workOrderMapper.selectOne(upl); WorkOrder workOrder = workOrderMapper.selectOne(upl);
//施工信息 // 施工信息
LambdaQueryWrapper<PowerStationConstructionData> up2 = new LambdaQueryWrapper(); LambdaQueryWrapper<PowerStationConstructionData> up2 = new LambdaQueryWrapper();
up2.eq(PowerStationConstructionData::getWorkOrderId, workOrderId); up2.eq(PowerStationConstructionData::getWorkOrderId, workOrderId);
up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId, workOrderPowerStationId); up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId, workOrderPowerStationId);
PowerStationConstructionData powerStationConstructionData = powerStationConstructionDataMapper.selectOne(up2); PowerStationConstructionData powerStationConstructionData = powerStationConstructionDataMapper
.selectOne(up2);
//工程信息 // 工程信息
LambdaQueryWrapper<PowerStationEngineeringInfo> up3 = new LambdaQueryWrapper(); LambdaQueryWrapper<PowerStationEngineeringInfo> up3 = new LambdaQueryWrapper();
up3.eq(PowerStationEngineeringInfo::getWorkOrderId, workOrderId); up3.eq(PowerStationEngineeringInfo::getWorkOrderId, workOrderId);
up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId, workOrderPowerStationId); up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId, workOrderPowerStationId);
PowerStationEngineeringInfo powerStationEngineeringInfo = powerStationEngineeringInfoMapper.selectOne(up3); PowerStationEngineeringInfo powerStationEngineeringInfo = powerStationEngineeringInfoMapper.selectOne(up3);
if (powerStationConstructionData != null) { if (powerStationConstructionData != null) {
powerStationEngineeringInfo = powerStationEngineeringInfo != null ? powerStationEngineeringInfo : new PowerStationEngineeringInfo(); powerStationEngineeringInfo = powerStationEngineeringInfo != null ? powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo()); : new PowerStationEngineeringInfo();
powerStationEngineeringInfo.setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo()); powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionCollectorBoxInfo(powerStationConstructionData.getConstructionCollectorBoxInfo()); .setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo());
powerStationEngineeringInfo.setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo()); powerStationEngineeringInfo
.setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo());
powerStationEngineeringInfo.setConstructionCollectorBoxInfo(
powerStationConstructionData.getConstructionCollectorBoxInfo());
powerStationEngineeringInfo
.setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo());
powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager()); powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager());
powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone()); powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone());
powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager()); powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager());
powerStationEngineeringInfo.setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone()); powerStationEngineeringInfo
.setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone());
} }
//并网信息 // 并网信息
LambdaQueryWrapper<HygfOnGrid> up4 = new LambdaQueryWrapper(); LambdaQueryWrapper<HygfOnGrid> up4 = new LambdaQueryWrapper();
up4.eq(HygfOnGrid::getWorkOrderId, workOrderId); up4.eq(HygfOnGrid::getWorkOrderId, workOrderId);
up4.eq(HygfOnGrid::getWorkOrderPowerStationId, workOrderPowerStationId); up4.eq(HygfOnGrid::getWorkOrderPowerStationId, workOrderPowerStationId);
HygfOnGrid hygfOnGrid = hygfOnGridMapper.selectOne(up4); HygfOnGrid hygfOnGrid = hygfOnGridMapper.selectOne(up4);
surveyInfoAllDto.setHygfOnGrid(hygfOnGrid != null ? hygfOnGrid : new HygfOnGrid()); surveyInfoAllDto.setHygfOnGrid(hygfOnGrid != null ? hygfOnGrid : new HygfOnGrid());
surveyInfoAllDto.setPowerStationConstructionData(powerStationConstructionData != null ? powerStationConstructionData : new PowerStationConstructionData()); surveyInfoAllDto
surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo != null ? powerStationEngineeringInfo : new PowerStationEngineeringInfo()); .setPowerStationConstructionData(powerStationConstructionData != null ? powerStationConstructionData
: new PowerStationConstructionData());
surveyInfoAllDto
.setPowerStationEngineeringInfo(powerStationEngineeringInfo != null ? powerStationEngineeringInfo
: new PowerStationEngineeringInfo());
surveyInfoAllDto.setWorkOrder(workOrder != null ? workOrder : new WorkOrder()); surveyInfoAllDto.setWorkOrder(workOrder != null ? workOrder : new WorkOrder());
} else { } else {
surveyInfoAllDto.setHygfOnGrid(new HygfOnGrid()); surveyInfoAllDto.setHygfOnGrid(new HygfOnGrid());
...@@ -609,7 +630,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -609,7 +630,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
surveyInfoAllDto.setWorkOrder(new WorkOrder()); surveyInfoAllDto.setWorkOrder(new WorkOrder());
} }
if (!StringUtils.isEmpty(processInstanceId)) { if (!StringUtils.isEmpty(processInstanceId)) {
try { try {
Map<String, Object> flowLoggerMap = workflowFeignClient.getFlowLogger(processInstanceId).getResult(); Map<String, Object> flowLoggerMap = workflowFeignClient.getFlowLogger(processInstanceId).getResult();
...@@ -619,11 +639,13 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -619,11 +639,13 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
} }
List<LinkedHashMap> flowLoggernew = new ArrayList<>(); List<LinkedHashMap> flowLoggernew = new ArrayList<>();
for (LinkedHashMap linkedHashMap : flowLogger) { for (LinkedHashMap linkedHashMap : flowLogger) {
if (linkedHashMap.get("operateDate") != null && !linkedHashMap.get("operateDate").toString().isEmpty()) { if (linkedHashMap.get("operateDate") != null
&& !linkedHashMap.get("operateDate").toString().isEmpty()) {
LinkedHashMap linke = new LinkedHashMap(); LinkedHashMap linke = new LinkedHashMap();
linke.put("approvalStatue", linkedHashMap.get("approvalStatue").toString()); linke.put("approvalStatue", linkedHashMap.get("approvalStatue").toString());
//审核意见 // 审核意见
List<LinkedHashMap> approvalSuggestion = (List<LinkedHashMap>) linkedHashMap.get("approvalSuggestion"); List<LinkedHashMap> approvalSuggestion = (List<LinkedHashMap>) linkedHashMap
.get("approvalSuggestion");
if (approvalSuggestion != null && !approvalSuggestion.isEmpty()) { if (approvalSuggestion != null && !approvalSuggestion.isEmpty()) {
linke.put("approvalSuggestion", approvalSuggestion.get(0).get("message")); linke.put("approvalSuggestion", approvalSuggestion.get(0).get("message"));
} }
...@@ -643,7 +665,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -643,7 +665,6 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
return surveyInfoAllDto; return surveyInfoAllDto;
} }
public JSONArray getRegionName() { public JSONArray getRegionName() {
JSONArray jsonArray = new JSONArray(); JSONArray jsonArray = new JSONArray();
if (redisUtils.hasKey(regionRedis)) { if (redisUtils.hasKey(regionRedis)) {
...@@ -652,7 +673,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD ...@@ -652,7 +673,8 @@ public class SurveyInformationServiceImpl extends BaseService<SurveyInformationD
Collection<RegionModel> regionChild = new ArrayList<>(); Collection<RegionModel> regionChild = new ArrayList<>();
RegionModel regionModel1 = new RegionModel(); RegionModel regionModel1 = new RegionModel();
regionChild.add(regionModel1); regionChild.add(regionModel1);
FeignClientResult<Collection<RegionModel>> collectionFeignClientResult = Systemctl.regionClient.queryForTreeParent(610000L); FeignClientResult<Collection<RegionModel>> collectionFeignClientResult = Systemctl.regionClient
.queryForTreeParent(610000L);
Collection<RegionModel> result = collectionFeignClientResult.getResult(); Collection<RegionModel> result = collectionFeignClientResult.getResult();
for (RegionModel regionModel : result) { for (RegionModel regionModel : result) {
if (regionModel.getChildren() != null && !regionModel.getChildren().isEmpty()) { if (regionModel.getChildren() != null && !regionModel.getChildren().isEmpty()) {
......
...@@ -926,6 +926,17 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto, UnitInfo, Unit ...@@ -926,6 +926,17 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto, UnitInfo, Unit
qu.eq(RegionalCompanies::getUnitId,unitInfo.getAmosCompanySeq()); qu.eq(RegionalCompanies::getUnitId,unitInfo.getAmosCompanySeq());
List<RegionalCompanies> oldList = regionalCompaniesMapper.selectList(qu); List<RegionalCompanies> oldList = regionalCompaniesMapper.selectList(qu);
regionalCompaniesMapper.delete(qu); regionalCompaniesMapper.delete(qu);
List<String> oldDisString = oldList.stream().map((regionalCompanies) -> regionalCompanies.getRegionalCompaniesSeq().toString()).collect(Collectors.toList());
List<String> newDisString = dis.stream().map((regionalCompaniesSeq) -> regionalCompaniesSeq.toString()).collect(Collectors.toList());
for(String item:oldDisString){
if(!newDisString.contains(item)){
throw new BadRequest("所属区域公司只能增加, 不能删除");
}
}
List<RegionalCompanies> regionalComp= new ArrayList<>(); List<RegionalCompanies> regionalComp= new ArrayList<>();
FeignClientResult<Collection<CompanyModel>> feignClientResult= Privilege.companyClient.querySubAgencyTree(regionalCompanies); FeignClientResult<Collection<CompanyModel>> feignClientResult= Privilege.companyClient.querySubAgencyTree(regionalCompanies);
List<CompanyModel> companyModel = (List<CompanyModel>)feignClientResult.getResult(); List<CompanyModel> companyModel = (List<CompanyModel>)feignClientResult.getResult();
......
...@@ -33,322 +33,281 @@ import java.util.*; ...@@ -33,322 +33,281 @@ import java.util.*;
* @date 2024-01-02 * @date 2024-01-02
*/ */
@Service @Service
public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,WorkOrderMapper> implements IWorkOrderService { public class WorkOrderServiceImpl extends BaseService<WorkOrderDto, WorkOrder, WorkOrderMapper>
implements IWorkOrderService {
@Autowired
RegionalCompaniesMapper regionalCompaniesMapper; @Autowired
RegionalCompaniesMapper regionalCompaniesMapper;
@Autowired
WorkOrderMapper workOrderMapper; @Autowired
@Autowired WorkOrderMapper workOrderMapper;
WorkOrderPowerStationServiceImpl workOrderPowerStationServiceImpl; @Autowired
WorkOrderPowerStationServiceImpl workOrderPowerStationServiceImpl;
@Autowired
WorkOrderPowerStationMapper workOrderPowerStationMapper; @Autowired
@Autowired WorkOrderPowerStationMapper workOrderPowerStationMapper;
DesignInformationMapper designInformationMapper; @Autowired
@Autowired DesignInformationMapper designInformationMapper;
PowerStationConstructionDataServiceImpl powerStationConstructionDataService; @Autowired
PowerStationConstructionDataServiceImpl powerStationConstructionDataService;
@Autowired @Autowired
SurveyDetailsServiceImpl surveyDetailsService; SurveyDetailsServiceImpl surveyDetailsService;
@Autowired @Autowired
InformationServiceImpl informationService; InformationServiceImpl informationService;
@Autowired @Autowired
ExtendedInformationServiceImpl extendedInformationService; ExtendedInformationServiceImpl extendedInformationService;
@Autowired @Autowired
CommercialServiceImpl commercialService; CommercialServiceImpl commercialService;
@Autowired @Autowired
PeasantHouseholdServiceImpl peasantHouseholdServiceImpl; PeasantHouseholdServiceImpl peasantHouseholdServiceImpl;
@Autowired @Autowired
DesignInformationServiceImpl designInformationService; DesignInformationServiceImpl designInformationService;
@Autowired @Autowired
PersonnelBusinessMapper personnelBusinessMapper; PersonnelBusinessMapper personnelBusinessMapper;
@Autowired @Autowired
SurveyInformationMapper surveyInformationMapper; SurveyInformationMapper surveyInformationMapper;
@Autowired @Autowired
PowerStationConstructionDataMapper powerStationConstructionDataMapper; PowerStationConstructionDataMapper powerStationConstructionDataMapper;
@Autowired @Autowired
PowerStationEngineeringInfoMapper powerStationEngineeringInfoMapper; PowerStationEngineeringInfoMapper powerStationEngineeringInfoMapper;
@Autowired @Autowired
PowerStationEngineeringInfoServiceImpl powerStationEngineeringInfoService; PowerStationEngineeringInfoServiceImpl powerStationEngineeringInfoService;
@Autowired @Autowired
HygfOnGridMapper hygfOnGridMapper; HygfOnGridMapper hygfOnGridMapper;
@Autowired @Autowired
ConstructionRecordsServiceImpl constructionRecordsServiceImpl; ConstructionRecordsServiceImpl constructionRecordsServiceImpl;
@Autowired @Autowired
ConstructionRecordsMapper constructionRecordsMapper; ConstructionRecordsMapper constructionRecordsMapper;
@Autowired @Autowired
BasicGridAcceptanceMapper basicGridAcceptanceMapper; BasicGridAcceptanceMapper basicGridAcceptanceMapper;
@Autowired @Autowired
WorkflowFeignClient workflowFeignClient; WorkflowFeignClient workflowFeignClient;
@Autowired
@Autowired PeasantHouseholdMapper peasantHouseholdMapper;
PeasantHouseholdMapper peasantHouseholdMapper;
/**
/** * 分页查询
* 分页查询 */
*/ public Page<WorkOrderDto> queryForWorkOrderPage(Page<WorkOrderDto> page) {
public Page<WorkOrderDto> queryForWorkOrderPage(Page<WorkOrderDto> page) { return this.queryForPage(page, null, false);
return this.queryForPage(page, null, false); }
}
/**
/** * 列表查询 示例
* 列表查询 示例 */
*/ public List<WorkOrderDto> queryForWorkOrderList() {
public List<WorkOrderDto> queryForWorkOrderList() { return this.queryForList("", false);
return this.queryForList("" , false); }
}
@Transactional
public WorkOrder saveWorkOrder(WorkOrder model, UserUnitInformationDto userUnitInformationDto) {
// 保存派工单
RegionalCompanies regionalCompanies = regionalCompaniesMapper.selectRegionName(model.getRegionCompanyId());
@Transactional String code = NumberUtil.getCode(CodeEnum.派工单.getCode(), regionalCompanies.getCompanyCode(),
public WorkOrder saveWorkOrder (WorkOrder model, UserUnitInformationDto userUnitInformationDto) { regionalCompanies.getRegionalAddress());
//保存派工单 model.setWorkOrderNum(code);
RegionalCompanies regionalCompanies= regionalCompaniesMapper.selectRegionName(model.getRegionCompanyId()); model.setRegionCompanyName(regionalCompanies.getRegionalCompaniesName());
String code= NumberUtil.getCode(CodeEnum.派工单.getCode(),regionalCompanies.getCompanyCode(),regionalCompanies.getRegionalAddress()); model.setRegionCode(regionalCompanies.getRegionalCompaniesCode());
model.setWorkOrderNum(code); model.setWorkOrderStatus(WorkOrderEnum.待施工.getCode());
model.setRegionCompanyName(regionalCompanies.getRegionalCompaniesName()); model.setRegionAddress(regionalCompanies.getRegionalAddress());
model.setRegionCode(regionalCompanies.getRegionalCompaniesCode()); // 获取经销商单位信息
model.setWorkOrderStatus(WorkOrderEnum.待施工.getCode()); model.setAmosDealerId(userUnitInformationDto.getAmosDealerId());
model.setRegionAddress(regionalCompanies.getRegionalAddress()); model.setAmosDealerName(userUnitInformationDto.getAmosDealerName());
//获取经销商单位信息 model.setAmosDealerOrgCode(userUnitInformationDto.getAmosDealerOrgCode());
model.setAmosDealerId(userUnitInformationDto.getAmosDealerId());
model.setAmosDealerName(userUnitInformationDto.getAmosDealerName()); workOrderMapper.insert(model);
model.setAmosDealerOrgCode(userUnitInformationDto.getAmosDealerOrgCode()); // 保存派工单 电站信息
List<PeasantHousehold> peasantHouseholdId = model.getPeasantHouseholdId();
workOrderMapper.insert(model);
//保存派工单 电站信息 List<ConstructionRecords> constructionRecordlist = new ArrayList<>();
List<PeasantHousehold> peasantHouseholdId=model.getPeasantHouseholdId(); List<WorkOrderPowerStation> li = new ArrayList<>();
for (PeasantHousehold peasantHousehold : peasantHouseholdId) {
List<ConstructionRecords> constructionRecordlist=new ArrayList<>(); WorkOrderPowerStation workOrderPowerStation = new WorkOrderPowerStation();
List<WorkOrderPowerStation> li=new ArrayList<>(); workOrderPowerStation.setPeasantHouseholdId(peasantHousehold.getSequenceNbr());
for (PeasantHousehold peasantHousehold : peasantHouseholdId) { workOrderPowerStation.setWorkOrderId(model.getSequenceNbr());
WorkOrderPowerStation workOrderPowerStation=new WorkOrderPowerStation(); workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待施工.getCode());
workOrderPowerStation.setPeasantHouseholdId(peasantHousehold.getSequenceNbr()); li.add(workOrderPowerStation);
workOrderPowerStation.setWorkOrderId(model.getSequenceNbr());
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待施工.getCode()); }
li.add(workOrderPowerStation); workOrderPowerStationServiceImpl.saveBatch(li);
} for (WorkOrderPowerStation workOrderPowerStation : li) {
workOrderPowerStationServiceImpl.saveBatch(li); // 增加操作日志
ConstructionRecords da = new ConstructionRecords(workOrderPowerStation.getRecUserName(), "新建派工单",
for (WorkOrderPowerStation workOrderPowerStation : li) { new Date(), "", workOrderPowerStation.getWorkOrderId(), workOrderPowerStation.getSequenceNbr(),
//增加操作日志 workOrderPowerStation.getPeasantHouseholdId(), "");
ConstructionRecords da=new ConstructionRecords( constructionRecordlist.add(da);
workOrderPowerStation.getRecUserName(),
"新建派工单", }
new Date(), constructionRecordsServiceImpl.saveBatch(constructionRecordlist);
"",
workOrderPowerStation.getWorkOrderId(), return model;
workOrderPowerStation.getSequenceNbr(), }
workOrderPowerStation.getPeasantHouseholdId(),
""); @Transactional
constructionRecordlist.add(da); public WorkOrder updateWorkOrder(WorkOrder model, UserUnitInformationDto userUnitInformationDto) {
// 保存派工单
} RegionalCompanies regionalCompanies = regionalCompaniesMapper.selectRegionName(model.getRegionCompanyId());
constructionRecordsServiceImpl.saveBatch(constructionRecordlist); model.setRegionCompanyName(regionalCompanies.getRegionalCompaniesName());
model.setRegionCode(regionalCompanies.getRegionalCompaniesCode());
model.setWorkOrderStatus(WorkOrderEnum.待施工.getCode());
return model; model.setRegionAddress(regionalCompanies.getRegionalAddress());
} // 获取经销商单位信息
@Transactional model.setAmosDealerId(userUnitInformationDto.getAmosDealerId());
public WorkOrder updateWorkOrder (WorkOrder model, UserUnitInformationDto userUnitInformationDto) { model.setAmosDealerName(userUnitInformationDto.getAmosDealerName());
//保存派工单 model.setAmosDealerOrgCode(userUnitInformationDto.getAmosDealerOrgCode());
RegionalCompanies regionalCompanies= regionalCompaniesMapper.selectRegionName(model.getRegionCompanyId()); workOrderMapper.updateById(model);
model.setRegionCompanyName(regionalCompanies.getRegionalCompaniesName()); LambdaQueryWrapper<WorkOrderPowerStation> up = new LambdaQueryWrapper();
model.setRegionCode(regionalCompanies.getRegionalCompaniesCode()); up.eq(WorkOrderPowerStation::getWorkOrderId, model.getSequenceNbr());
model.setWorkOrderStatus(WorkOrderEnum.待施工.getCode()); workOrderPowerStationMapper.delete(up);
model.setRegionAddress(regionalCompanies.getRegionalAddress()); // 保存派工单 电站信息
//获取经销商单位信息 List<PeasantHousehold> peasantHouseholdId = model.getPeasantHouseholdId();
model.setAmosDealerId(userUnitInformationDto.getAmosDealerId()); List<WorkOrderPowerStation> li = new ArrayList<>();
model.setAmosDealerName(userUnitInformationDto.getAmosDealerName()); for (PeasantHousehold peasantHousehold : peasantHouseholdId) {
model.setAmosDealerOrgCode(userUnitInformationDto.getAmosDealerOrgCode()); WorkOrderPowerStation workOrderPowerStation = new WorkOrderPowerStation();
workOrderMapper.updateById(model); workOrderPowerStation.setPeasantHouseholdId(peasantHousehold.getSequenceNbr());
LambdaQueryWrapper<WorkOrderPowerStation> up=new LambdaQueryWrapper(); workOrderPowerStation.setWorkOrderId(model.getSequenceNbr());
up.eq(WorkOrderPowerStation::getWorkOrderId,model.getSequenceNbr()); workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待施工.getCode());
workOrderPowerStationMapper.delete(up); li.add(workOrderPowerStation);
//保存派工单 电站信息 }
List<PeasantHousehold> peasantHouseholdId=model.getPeasantHouseholdId(); workOrderPowerStationServiceImpl.saveBatch(li);
List<WorkOrderPowerStation> li=new ArrayList<>();
for (PeasantHousehold peasantHousehold : peasantHouseholdId) { List<ConstructionRecords> constructionRecordlist = new ArrayList<>();
WorkOrderPowerStation workOrderPowerStation=new WorkOrderPowerStation(); for (WorkOrderPowerStation workOrderPowerStation : li) {
workOrderPowerStation.setPeasantHouseholdId(peasantHousehold.getSequenceNbr()); // 增加操作日志
workOrderPowerStation.setWorkOrderId(model.getSequenceNbr()); ConstructionRecords da = new ConstructionRecords(workOrderPowerStation.getRecUserName(), "编辑派工单",
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待施工.getCode()); new Date(), "", workOrderPowerStation.getWorkOrderId(), workOrderPowerStation.getSequenceNbr(),
li.add(workOrderPowerStation); workOrderPowerStation.getPeasantHouseholdId(), "");
} constructionRecordlist.add(da);
workOrderPowerStationServiceImpl.saveBatch(li);
}
List<ConstructionRecords> constructionRecordlist=new ArrayList<>(); constructionRecordsServiceImpl.saveBatch(constructionRecordlist);
for (WorkOrderPowerStation workOrderPowerStation : li) {
//增加操作日志 return model;
ConstructionRecords da=new ConstructionRecords( }
workOrderPowerStation.getRecUserName(),
"编辑派工单", public WorkOrder selectOne(Long sequenceNbr) {
new Date(), WorkOrder model = workOrderMapper.selectById(sequenceNbr);
"", List<PeasantHousehold> li = workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr, null);
workOrderPowerStation.getWorkOrderId(), model.setPeasantHouseholdId(li);
workOrderPowerStation.getSequenceNbr(), return model;
workOrderPowerStation.getPeasantHouseholdId(), }
"");
constructionRecordlist.add(da); public Map<String, Object> selectOneall(Long sequenceNbr) {
WorkOrder model = workOrderMapper.selectById(sequenceNbr);
} List<PeasantHousehold> lih = workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr, null);
constructionRecordsServiceImpl.saveBatch(constructionRecordlist);
// 获取所有电站Bom,分组合并,暂时不相加
List<Long> ids = new ArrayList<>();
return model; for (PeasantHousehold documentStation : lih) {
} ids.add(documentStation.getSequenceNbr());
}
public WorkOrder selectOne(Long sequenceNbr) { QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
WorkOrder model= workOrderMapper.selectById(sequenceNbr); designInformationQueryWrapper.in("peasant_household_id", ids);
List<PeasantHousehold> li=workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr,null); List<DesignInformation> li = designInformationMapper.selectList(designInformationQueryWrapper);
model.setPeasantHouseholdId(li); DesignInformation designInformation = new DesignInformation();
return model; // 组件
} List<Object> assembly = new ArrayList<>();
// 逆变器
public Map<String,Object> selectOneall(Long sequenceNbr) { List<Object> inverter = new ArrayList<>();
WorkOrder model= workOrderMapper.selectById(sequenceNbr); // 电表箱
List<PeasantHousehold> lih=workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr,null); List<Object> electricityMeter = new ArrayList<>();
// 电缆
List<Object> cable = new ArrayList<>();
for (DesignInformation des : li) {
//获取所有电站Bom,分组合并,暂时不相加 if (des.getAssembly() != null && !des.getAssembly().isEmpty()) {
List<Long> ids=new ArrayList<>(); assembly.addAll(des.getAssembly());
for (PeasantHousehold documentStation : lih) { }
ids.add(documentStation.getSequenceNbr()); if (des.getInverter() != null && !des.getInverter().isEmpty()) {
} inverter.addAll(des.getInverter());
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>(); }
designInformationQueryWrapper.in("peasant_household_id", ids); if (des.getElectricityMeter() != null && !des.getElectricityMeter().isEmpty()) {
List<DesignInformation> li = designInformationMapper.selectList(designInformationQueryWrapper); electricityMeter.addAll(des.getElectricityMeter());
DesignInformation designInformation=new DesignInformation(); }
//组件 if (des.getCable() != null && !des.getCable().isEmpty()) {
List<Object> assembly=new ArrayList<>(); cable.addAll(des.getCable());
//逆变器 }
List<Object> inverter=new ArrayList<>(); }
//电表箱 List<PeasantHousehold> list = workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr, null);
List<Object> electricityMeter=new ArrayList<>(); Map<String, Object> map = new HashMap<>();
//电缆 designInformation.setAssembly(assembly);
List<Object> cable=new ArrayList<>(); designInformation.setInverter(inverter);
for (DesignInformation des : li) { designInformation.setElectricityMeter(electricityMeter);
if(des.getAssembly()!=null&&!des.getAssembly().isEmpty()){ designInformation.setCable(cable);
assembly.addAll(des.getAssembly()); map.put("workOrder", model);
} map.put("designInformation", designInformation);
if(des.getInverter()!=null&&!des.getInverter().isEmpty()){ map.put("peasantHousehold", list);
inverter.addAll(des.getInverter());
} return map;
if(des.getElectricityMeter()!=null&&!des.getElectricityMeter().isEmpty()){
electricityMeter.addAll(des.getElectricityMeter()); }
}
if(des.getCable()!=null&&!des.getCable().isEmpty()){ @Transactional
cable.addAll(des.getCable()); public PowerStationConstructionData addOrUpdate(PowerStationConstructionData powerStationConstructionData) {
}
}
List<PeasantHousehold> list=workOrderPowerStationMapper.selectPeasantHousehold(sequenceNbr,null);
Map<String,Object> map =new HashMap<>();
designInformation.setAssembly(assembly);
designInformation.setInverter(inverter);
designInformation.setElectricityMeter(electricityMeter);
designInformation.setCable(cable);
map.put("workOrder",model);
map.put("designInformation",designInformation);
map.put("peasantHousehold",list);
return map;
}
@Transactional
public PowerStationConstructionData addOrUpdate(PowerStationConstructionData powerStationConstructionData){
// if(powerStationConstructionData.getSequenceNbr()!=null){ // if(powerStationConstructionData.getSequenceNbr()!=null){
//修改施工电站状态 // 修改施工电站状态
LambdaUpdateWrapper<WorkOrderPowerStation> up=new LambdaUpdateWrapper(); LambdaUpdateWrapper<WorkOrderPowerStation> up = new LambdaUpdateWrapper();
up.eq(WorkOrderPowerStation::getSequenceNbr,powerStationConstructionData.getWorkOrderPowerStationId()); up.eq(WorkOrderPowerStation::getSequenceNbr, powerStationConstructionData.getWorkOrderPowerStationId());
if(powerStationConstructionData.getConstructionStatus().equals("未完成")){ if (powerStationConstructionData.getConstructionStatus().equals("未完成")) {
up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.施工中.getCode()); up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.施工中.getCode());
}else{ } else {
up.set(WorkOrderPowerStation::getPowerStationConstructionStatus,WorkOrderEnum.待登记.getCode()); up.set(WorkOrderPowerStation::getPowerStationConstructionStatus, WorkOrderEnum.待登记.getCode());
WorkOrderPowerStation basicGridAcceptanc= workOrderPowerStationMapper.selectById(powerStationConstructionData.getWorkOrderPowerStationId()); WorkOrderPowerStation basicGridAcceptanc = workOrderPowerStationMapper
//施工完成 .selectById(powerStationConstructionData.getWorkOrderPowerStationId());
LambdaUpdateWrapper<PeasantHousehold> up1 =new LambdaUpdateWrapper<>(); // 施工完成
up1.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网完成.getCode()); LambdaUpdateWrapper<PeasantHousehold> up1 = new LambdaUpdateWrapper<>();
long idsk= basicGridAcceptanc.getPeasantHouseholdId(); up1.set(PeasantHousehold::getConstructionState, ArrivalStateeEnum.并网完成.getCode());
up1.eq(PeasantHousehold::getSequenceNbr,idsk); long idsk = basicGridAcceptanc.getPeasantHouseholdId();
peasantHouseholdMapper.update(null,up1); up1.eq(PeasantHousehold::getSequenceNbr, idsk);
peasantHouseholdMapper.update(null, up1);
}
workOrderPowerStationMapper.update(null,up); }
//修改派工单状态 workOrderPowerStationMapper.update(null, up);
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper(); // 修改派工单状态
qu.eq(WorkOrderPowerStation::getWorkOrderId,powerStationConstructionData.getWorkOrderId()); LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
List<String> d=new ArrayList<>(); qu.eq(WorkOrderPowerStation::getWorkOrderId, powerStationConstructionData.getWorkOrderId());
d.add(WorkOrderEnum.施工中.getCode()); List<String> d = new ArrayList<>();
d.add(WorkOrderEnum.待施工.getCode()); d.add(WorkOrderEnum.施工中.getCode());
qu.in(WorkOrderPowerStation::getPowerStationConstructionStatus,d); d.add(WorkOrderEnum.待施工.getCode());
List<WorkOrderPowerStation> list=workOrderPowerStationMapper.selectList(qu); qu.in(WorkOrderPowerStation::getPowerStationConstructionStatus, d);
List<WorkOrderPowerStation> list = workOrderPowerStationMapper.selectList(qu);
LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper(); LambdaUpdateWrapper<WorkOrder> upq = new LambdaUpdateWrapper();
upq.eq(WorkOrder::getSequenceNbr,powerStationConstructionData.getWorkOrderId()); upq.eq(WorkOrder::getSequenceNbr, powerStationConstructionData.getWorkOrderId());
if(list!=null&&!list.isEmpty()){ if (list != null && !list.isEmpty()) {
upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.施工中.getCode()); upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.施工中.getCode());
}else{ } else {
upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.登记中.getCode()); upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.登记中.getCode());
} }
workOrderMapper.update(null,upq); workOrderMapper.update(null, upq);
//新增施工信息 // 新增施工信息
powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData); powerStationConstructionDataService.saveOrUpdate(powerStationConstructionData);
// 增加操作日志
if (powerStationConstructionData.getSequenceNbr() != null) {
//增加操作日志 ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "编辑施工资料",
if(powerStationConstructionData.getSequenceNbr()!=null){ new Date(), "", powerStationConstructionData.getWorkOrderId(),
ConstructionRecords da=new ConstructionRecords( powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
powerStationConstructionData.getRecUserName(), constructionRecordsServiceImpl.save(da);
"编辑施工资料",
new Date(), } else {
"", ConstructionRecords da = new ConstructionRecords(powerStationConstructionData.getRecUserName(), "新增施工资料",
powerStationConstructionData.getWorkOrderId(), new Date(), "", powerStationConstructionData.getWorkOrderId(),
powerStationConstructionData.getWorkOrderPowerStationId(), powerStationConstructionData.getWorkOrderPowerStationId(), null, "");
null, constructionRecordsServiceImpl.save(da);
""); }
constructionRecordsServiceImpl.save(da);
}else{
ConstructionRecords da=new ConstructionRecords(
powerStationConstructionData.getRecUserName(),
"新增施工资料",
new Date(),
"",
powerStationConstructionData.getWorkOrderId(),
powerStationConstructionData.getWorkOrderPowerStationId(),
null,
"");
constructionRecordsServiceImpl.save(da);
}
// }else{ // }else{
// //修改施工电站状态 // //修改施工电站状态
...@@ -380,387 +339,399 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor ...@@ -380,387 +339,399 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor
// //
// } // }
return powerStationConstructionData;
return powerStationConstructionData; }
}
public Page<WorkOrder> selectPage(int pageNum, int pageSize, WorkOrder workOrder) {
PageHelper.startPage(pageNum, pageSize);
List<WorkOrder> list = workOrderMapper.selectWorkOrderList(workOrder);
PageInfo<WorkOrder> page = new PageInfo(list);
Page<WorkOrder> pagenew = new Page<WorkOrder>();
public Page<WorkOrder> selectPage( int pageNum,int pageSize, WorkOrder workOrder){ pagenew.setCurrent(pageNum);
PageHelper.startPage(pageNum, pageSize); pagenew.setTotal(page.getTotal());
List<WorkOrder> list=workOrderMapper.selectWorkOrderList(workOrder); pagenew.setSize(pageSize);
PageInfo<WorkOrder> page = new PageInfo(list); pagenew.setRecords(page.getList());
Page<WorkOrder> pagenew = new Page<WorkOrder>(); return pagenew;
pagenew.setCurrent(pageNum); }
pagenew.setTotal(page.getTotal());
pagenew.setSize(pageSize); public Page<WorkOrderPage> queryForwgpage(int pageNum, int pageSize, WorkOrderPage workOrder) {
pagenew.setRecords(page.getList()); PageHelper.startPage(pageNum, pageSize);
return pagenew; List<WorkOrderPage> list = workOrderMapper.queryForwgpage(workOrder);
} PageInfo<WorkOrderPage> page = new PageInfo(list);
Page<WorkOrderPage> pagenew = new Page<WorkOrderPage>();
pagenew.setCurrent(pageNum);
public Page<WorkOrderPage> queryForwgpage( int pageNum,int pageSize, WorkOrderPage workOrder){ pagenew.setTotal(page.getTotal());
PageHelper.startPage(pageNum, pageSize); pagenew.setSize(pageSize);
List<WorkOrderPage> list=workOrderMapper.queryForwgpage(workOrder); pagenew.setRecords(page.getList());
PageInfo<WorkOrderPage> page = new PageInfo(list); return pagenew;
Page<WorkOrderPage> pagenew = new Page<WorkOrderPage>(); }
pagenew.setCurrent(pageNum);
pagenew.setTotal(page.getTotal()); public SurveyInfoAllDto getsurveyQueryxq(Long peasantHouseholdId, Long workOrderId, Long workOrderPowerStationId) {
pagenew.setSize(pageSize);
pagenew.setRecords(page.getList()); SurveyInfoAllDto surveyInfoAllDto = new SurveyInfoAllDto();
return pagenew; PeasantHousehold peasantHousehold = new PeasantHousehold();
}
LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>();
peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId);
public SurveyInfoAllDto getsurveyQueryxq(Long peasantHouseholdId,Long workOrderId,Long workOrderPowerStationId) { peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper);
String surveyInformationId = String.valueOf(peasantHousehold.getSurveyInformationId());
SurveyInfoAllDto surveyInfoAllDto = new SurveyInfoAllDto();
PeasantHousehold peasantHousehold = new PeasantHousehold(); // 勘察基本信息
LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>();
LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>(); queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId);
peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId); SurveyInformation surveyInformation = surveyInformationMapper.selectOne(queryWrapper);
peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper); surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class));
String surveyInformationId = String.valueOf(peasantHousehold.getSurveyInformationId()); // 农户信息
//勘察基本信息 // 获取用户所在经销商单位
LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>(); UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId); .getUserUnitInformationDto(peasantHousehold.getDeveloperUserId());
SurveyInformation surveyInformation = surveyInformationMapper.selectOne(queryWrapper); BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation());
surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class)); surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName());
//农户信息 surveyInfoAllDto.getSurveyInformation().setDeveloperCode(userUnitInformationDto.getAmosDealerOrgCode());
surveyInfoAllDto.getSurveyInformation().setDeveloperId(userUnitInformationDto.getAmosDealerId());
//获取用户所在经销商单位
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto(peasantHousehold.getDeveloperUserId()); if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) {
BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation()); surveyInfoAllDto.getSurveyInformation()
surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName()); .setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/")));
surveyInfoAllDto.getSurveyInformation().setDeveloperCode(userUnitInformationDto.getAmosDealerOrgCode()); }
surveyInfoAllDto.getSurveyInformation().setDeveloperId(userUnitInformationDto.getAmosDealerId()); if (!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())) {
surveyInfoAllDto.getSurveyInformation()
if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) { .setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/")));
surveyInfoAllDto.getSurveyInformation().setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/"))); }
} if (peasantHousehold.getPermanentAddress() == null) {
if(!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())){ surveyInfoAllDto.getSurveyInformation().setPermanentAddress(peasantHousehold.getProjectAddress());
surveyInfoAllDto.getSurveyInformation().setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/"))); surveyInfoAllDto.getSurveyInformation().setIsPermanent("1");
} }
if(peasantHousehold.getPermanentAddress() ==null){ surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr());
surveyInfoAllDto.getSurveyInformation().setPermanentAddress(peasantHousehold.getProjectAddress()); QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>();
surveyInfoAllDto.getSurveyInformation().setIsPermanent("1"); surveyDetailsQueryWrapper.eq("survey_information_id", surveyInformationId);
} SurveyDetails surveyDetails = surveyDetailsService.getBaseMapper().selectOne(surveyDetailsQueryWrapper);
surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr());
QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>(); if (surveyDetails == null) {
surveyDetailsQueryWrapper.eq("survey_information_id", surveyInformationId); surveyInfoAllDto.setSurveyDetails(new SurveyDetailsDto());
SurveyDetails surveyDetails = surveyDetailsService.getBaseMapper().selectOne(surveyDetailsQueryWrapper); } else {
surveyInfoAllDto.setSurveyDetails(BeanDtoUtils.convert(surveyDetails, SurveyDetailsDto.class));
if(surveyDetails == null){ }
surveyInfoAllDto.setSurveyDetails(new SurveyDetailsDto()); QueryWrapper<Information> informationQueryWrapper = new QueryWrapper<>();
}else { informationQueryWrapper.eq("survey_information_id", surveyInformationId);
surveyInfoAllDto.setSurveyDetails(BeanDtoUtils.convert(surveyDetails, SurveyDetailsDto.class)); Information information = informationService.getBaseMapper().selectOne(informationQueryWrapper);
} if (information == null) {
QueryWrapper<Information> informationQueryWrapper = new QueryWrapper<>(); surveyInfoAllDto.setInformation(new InformationDto());
informationQueryWrapper.eq("survey_information_id", surveyInformationId); } else {
Information information = informationService.getBaseMapper().selectOne(informationQueryWrapper); surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class));
if(information == null){ }
surveyInfoAllDto.setInformation(new InformationDto()); QueryWrapper<Commercial> commercialQueryWrapper = new QueryWrapper<>();
}else { commercialQueryWrapper.eq("survey_information_id", surveyInformationId);
surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class)); Commercial commercial = commercialService.getBaseMapper().selectOne(commercialQueryWrapper);
} if (commercial == null) {
QueryWrapper<Commercial> commercialQueryWrapper = new QueryWrapper<>(); commercial = new Commercial();
commercialQueryWrapper.eq("survey_information_id", surveyInformationId); }
Commercial commercial = commercialService.getBaseMapper().selectOne(commercialQueryWrapper); commercial.setApplicant(peasantHousehold.getOwnersName());
if(commercial==null){ commercial.setIdCard(peasantHousehold.getIdCard());
commercial=new Commercial(); commercial.setTelephone(peasantHousehold.getTelephone());
} commercial.setProjectAddress(peasantHousehold.getProjectAddress());
commercial.setApplicant(peasantHousehold.getOwnersName()); commercial.setProjectAddressName(peasantHousehold.getProjectAddressName());
commercial.setIdCard(peasantHousehold.getIdCard()); commercial.setProjectAddressDetail(peasantHousehold.getProjectAddressDetail());
commercial.setTelephone(peasantHousehold.getTelephone()); commercial.setLegalContactTelephone(peasantHousehold.getTelephone());
commercial.setProjectAddress(peasantHousehold.getProjectAddress()); if (information == null) {
commercial.setProjectAddressName(peasantHousehold.getProjectAddressName()); CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class);
commercial.setProjectAddressDetail(peasantHousehold.getProjectAddressDetail()); commercialDto.setType("zrr");
commercial.setLegalContactTelephone(peasantHousehold.getTelephone()); commercialDto.setLegalType("zjdnhw");
if(information == null){ surveyInfoAllDto.setCommercial(commercialDto);
CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class); } else {
commercialDto.setType("zrr"); surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class));
commercialDto.setLegalType("zjdnhw"); if (commercial != null && !StringUtils.isEmpty(commercial.getProjectAddressName())) {
surveyInfoAllDto.setCommercial(commercialDto); surveyInfoAllDto.getCommercial()
}else { .setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/")));
surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class)); }
if(commercial !=null && !StringUtils.isEmpty(commercial.getProjectAddressName())){ }
surveyInfoAllDto.getCommercial().setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/"))); QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>();
} extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId);
} ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper()
QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>(); .selectOne(extendedInformationQueryWrapper);
extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId); if (information == null) {
ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper().selectOne(extendedInformationQueryWrapper); surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto());
if(information == null){ } else {
surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto()); surveyInfoAllDto
}else { .setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class));
surveyInfoAllDto.setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class)); }
} QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>(); designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr());
designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr()); DesignInformation designInformation = designInformationService.getBaseMapper()
DesignInformation designInformation = designInformationService.getBaseMapper().selectOne(designInformationQueryWrapper); .selectOne(designInformationQueryWrapper);
if(designInformation == null){ if (designInformation == null) {
surveyInfoAllDto.setDesignInformation(new DesignInformationDto()); surveyInfoAllDto.setDesignInformation(new DesignInformationDto());
}else { } else {
surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class)); surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class));
} }
//派工单信息 // 派工单信息
LambdaQueryWrapper<WorkOrder> upl=new LambdaQueryWrapper(); LambdaQueryWrapper<WorkOrder> upl = new LambdaQueryWrapper();
upl.eq(WorkOrder::getSequenceNbr,workOrderId); upl.eq(WorkOrder::getSequenceNbr, workOrderId);
WorkOrder workOrder= workOrderMapper.selectOne(upl); WorkOrder workOrder = workOrderMapper.selectOne(upl);
//施工信息 // 施工信息
LambdaQueryWrapper<PowerStationConstructionData> up2=new LambdaQueryWrapper(); LambdaQueryWrapper<PowerStationConstructionData> up2 = new LambdaQueryWrapper();
up2.eq(PowerStationConstructionData::getWorkOrderId,workOrderId); up2.eq(PowerStationConstructionData::getWorkOrderId, workOrderId);
up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId,workOrderPowerStationId); up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId, workOrderPowerStationId);
PowerStationConstructionData powerStationConstructionData=powerStationConstructionDataMapper.selectOne(up2); PowerStationConstructionData powerStationConstructionData = powerStationConstructionDataMapper.selectOne(up2);
//工程信息 // 工程信息
LambdaQueryWrapper<PowerStationEngineeringInfo> up3=new LambdaQueryWrapper(); LambdaQueryWrapper<PowerStationEngineeringInfo> up3 = new LambdaQueryWrapper();
up3.eq(PowerStationEngineeringInfo::getWorkOrderId,workOrderId); up3.eq(PowerStationEngineeringInfo::getWorkOrderId, workOrderId);
up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId,workOrderPowerStationId); up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId, workOrderPowerStationId);
PowerStationEngineeringInfo powerStationEngineeringInfo=powerStationEngineeringInfoMapper.selectOne(up3); PowerStationEngineeringInfo powerStationEngineeringInfo = powerStationEngineeringInfoMapper.selectOne(up3);
if(powerStationConstructionData!=null){ if (powerStationConstructionData != null) {
powerStationEngineeringInfo=powerStationEngineeringInfo!=null?powerStationEngineeringInfo:new PowerStationEngineeringInfo(); powerStationEngineeringInfo = powerStationEngineeringInfo != null ? powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo()); : new PowerStationEngineeringInfo();
powerStationEngineeringInfo.setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo()); powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionCollectorBoxInfo(powerStationConstructionData.getConstructionCollectorBoxInfo()); .setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo());
powerStationEngineeringInfo.setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo()); powerStationEngineeringInfo
powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager()); .setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo());
powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone()); powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager()); .setConstructionCollectorBoxInfo(powerStationConstructionData.getConstructionCollectorBoxInfo());
powerStationEngineeringInfo.setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone()); powerStationEngineeringInfo
} .setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo());
powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager());
powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone());
powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager());
//施工自审 powerStationEngineeringInfo
LambdaQueryWrapper<ConstructionRecords> up5=new LambdaQueryWrapper(); .setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone());
up5.eq(ConstructionRecords::getWorkOrderId,workOrderId); }
up5.eq(ConstructionRecords::getWorkOrderPowerStationId,workOrderPowerStationId);
up5.orderByAsc(ConstructionRecords::getRecDate); // 施工自审
List<ConstructionRecords> li=constructionRecordsMapper.selectList(up5); LambdaQueryWrapper<ConstructionRecords> up5 = new LambdaQueryWrapper();
ConstructionRecords data=new ConstructionRecords(); up5.eq(ConstructionRecords::getWorkOrderId, workOrderId);
data.setConstructionRecordsList(li); up5.eq(ConstructionRecords::getWorkOrderPowerStationId, workOrderPowerStationId);
surveyInfoAllDto.setConstructionRecords(data); up5.orderByAsc(ConstructionRecords::getRecDate);
List<ConstructionRecords> li = constructionRecordsMapper.selectList(up5);
ConstructionRecords data = new ConstructionRecords();
data.setConstructionRecordsList(li);
//并网信息 surveyInfoAllDto.setConstructionRecords(data);
LambdaQueryWrapper<HygfOnGrid> up4=new LambdaQueryWrapper();
up4.eq(HygfOnGrid::getWorkOrderId,workOrderId); // 并网信息
up4.eq(HygfOnGrid::getWorkOrderPowerStationId,workOrderPowerStationId); LambdaQueryWrapper<HygfOnGrid> up4 = new LambdaQueryWrapper();
HygfOnGrid hygfOnGrid=hygfOnGridMapper.selectOne(up4); up4.eq(HygfOnGrid::getWorkOrderId, workOrderId);
surveyInfoAllDto.setHygfOnGrid(hygfOnGrid!=null?hygfOnGrid:new HygfOnGrid()); up4.eq(HygfOnGrid::getWorkOrderPowerStationId, workOrderPowerStationId);
surveyInfoAllDto.setPowerStationConstructionData(powerStationConstructionData); HygfOnGrid hygfOnGrid = hygfOnGridMapper.selectOne(up4);
surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo); surveyInfoAllDto.setHygfOnGrid(hygfOnGrid != null ? hygfOnGrid : new HygfOnGrid());
surveyInfoAllDto.setWorkOrder(workOrder); surveyInfoAllDto.setPowerStationConstructionData(powerStationConstructionData);
surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo);
return surveyInfoAllDto; surveyInfoAllDto.setWorkOrder(workOrder);
}
return surveyInfoAllDto;
public PowerStationEngineeringInfoAllDto getPowerStationEngineeringInfo(Long workOrderPowerStationId) { }
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper(); public PowerStationEngineeringInfoAllDto getPowerStationEngineeringInfo(Long workOrderPowerStationId) {
qu.eq(WorkOrderPowerStation::getSequenceNbr,workOrderPowerStationId);
WorkOrderPowerStation workOrderPowerStation=workOrderPowerStationMapper.selectOne(qu); LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
Long peasantHouseholdId=workOrderPowerStation.getPeasantHouseholdId(); qu.eq(WorkOrderPowerStation::getSequenceNbr, workOrderPowerStationId);
Long workOrderId=workOrderPowerStation.getWorkOrderId(); WorkOrderPowerStation workOrderPowerStation = workOrderPowerStationMapper.selectOne(qu);
Long peasantHouseholdId = workOrderPowerStation.getPeasantHouseholdId();
PowerStationEngineeringInfoAllDto surveyInfoAllDto = new PowerStationEngineeringInfoAllDto(); Long workOrderId = workOrderPowerStation.getWorkOrderId();
PeasantHousehold peasantHousehold = new PeasantHousehold();
PowerStationEngineeringInfoAllDto surveyInfoAllDto = new PowerStationEngineeringInfoAllDto();
LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>(); PeasantHousehold peasantHousehold = new PeasantHousehold();
peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId);
peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper); LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>();
String surveyInformationId = String.valueOf(peasantHousehold.getSurveyInformationId()); peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId);
peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper);
//勘察基本信息 String surveyInformationId = String.valueOf(peasantHousehold.getSurveyInformationId());
LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId); // 勘察基本信息
SurveyInformation surveyInformation = surveyInformationMapper.selectOne(queryWrapper); LambdaQueryWrapper<SurveyInformation> queryWrapper = new LambdaQueryWrapper<>();
surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class)); queryWrapper.eq(SurveyInformation::getSequenceNbr, surveyInformationId);
//农户信息 SurveyInformation surveyInformation = surveyInformationMapper.selectOne(queryWrapper);
surveyInfoAllDto.setSurveyInformation(BeanDtoUtils.convert(surveyInformation, SurveyInformationDto.class));
//获取用户所在经销商单位 // 农户信息
UserUnitInformationDto userUnitInformationDto=personnelBusinessMapper.getUserUnitInformationDto(peasantHousehold.getDeveloperUserId());
BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation()); // 获取用户所在经销商单位
surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName()); UserUnitInformationDto userUnitInformationDto = personnelBusinessMapper
surveyInfoAllDto.getSurveyInformation().setDeveloperCode(userUnitInformationDto.getAmosDealerOrgCode()); .getUserUnitInformationDto(peasantHousehold.getDeveloperUserId());
surveyInfoAllDto.getSurveyInformation().setDeveloperId(userUnitInformationDto.getAmosDealerId()); BeanUtils.copyProperties(peasantHousehold, surveyInfoAllDto.getSurveyInformation());
surveyInfoAllDto.getSurveyInformation().setDeveloperName(userUnitInformationDto.getAmosDealerName());
if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) { surveyInfoAllDto.getSurveyInformation().setDeveloperCode(userUnitInformationDto.getAmosDealerOrgCode());
surveyInfoAllDto.getSurveyInformation().setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/"))); surveyInfoAllDto.getSurveyInformation().setDeveloperId(userUnitInformationDto.getAmosDealerId());
}
if(!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())){ if (!StringUtils.isEmpty(peasantHousehold.getProjectAddressName())) {
surveyInfoAllDto.getSurveyInformation().setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/"))); surveyInfoAllDto.getSurveyInformation()
} .setProjectAddressText(Arrays.asList(peasantHousehold.getProjectAddressName().split("/")));
if(peasantHousehold.getPermanentAddress() ==null){ }
surveyInfoAllDto.getSurveyInformation().setPermanentAddress(peasantHousehold.getProjectAddress()); if (!StringUtils.isEmpty(peasantHousehold.getPermanentAddressName())) {
surveyInfoAllDto.getSurveyInformation().setIsPermanent("1"); surveyInfoAllDto.getSurveyInformation()
} .setPermanentAddressText(Arrays.asList(peasantHousehold.getPermanentAddressName().split("/")));
surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr()); }
QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>(); if (peasantHousehold.getPermanentAddress() == null) {
surveyDetailsQueryWrapper.eq("survey_information_id", surveyInformationId); surveyInfoAllDto.getSurveyInformation().setPermanentAddress(peasantHousehold.getProjectAddress());
SurveyDetails surveyDetails = surveyDetailsService.getBaseMapper().selectOne(surveyDetailsQueryWrapper); surveyInfoAllDto.getSurveyInformation().setIsPermanent("1");
}
if(surveyDetails == null){ surveyInfoAllDto.getSurveyInformation().setSequenceNbr(surveyInformation.getSequenceNbr());
surveyInfoAllDto.setSurveyDetails(new SurveyDetailsDto()); QueryWrapper<SurveyDetails> surveyDetailsQueryWrapper = new QueryWrapper<>();
}else { surveyDetailsQueryWrapper.eq("survey_information_id", surveyInformationId);
surveyInfoAllDto.setSurveyDetails(BeanDtoUtils.convert(surveyDetails, SurveyDetailsDto.class)); SurveyDetails surveyDetails = surveyDetailsService.getBaseMapper().selectOne(surveyDetailsQueryWrapper);
}
if (surveyDetails == null) {
surveyInfoAllDto.setSurveyDetails(new SurveyDetailsDto());
} else {
surveyInfoAllDto.setSurveyDetails(BeanDtoUtils.convert(surveyDetails, SurveyDetailsDto.class));
}
// 商务信息 // 商务信息
QueryWrapper<Commercial> commercialQueryWrapper = new QueryWrapper<>(); QueryWrapper<Commercial> commercialQueryWrapper = new QueryWrapper<>();
commercialQueryWrapper.eq("survey_information_id", surveyInformationId); commercialQueryWrapper.eq("survey_information_id", surveyInformationId);
Commercial commercial = commercialService.getBaseMapper().selectOne(commercialQueryWrapper); Commercial commercial = commercialService.getBaseMapper().selectOne(commercialQueryWrapper);
if(commercial==null){ if (commercial == null) {
commercial=new Commercial(); commercial = new Commercial();
} }
commercial.setApplicant(peasantHousehold.getOwnersName()); commercial.setApplicant(peasantHousehold.getOwnersName());
commercial.setIdCard(peasantHousehold.getIdCard()); commercial.setIdCard(peasantHousehold.getIdCard());
commercial.setTelephone(peasantHousehold.getTelephone()); commercial.setTelephone(peasantHousehold.getTelephone());
commercial.setProjectAddress(peasantHousehold.getProjectAddress()); commercial.setProjectAddress(peasantHousehold.getProjectAddress());
commercial.setProjectAddressName(peasantHousehold.getProjectAddressName()); commercial.setProjectAddressName(peasantHousehold.getProjectAddressName());
commercial.setProjectAddressDetail(peasantHousehold.getProjectAddressDetail()); commercial.setProjectAddressDetail(peasantHousehold.getProjectAddressDetail());
commercial.setLegalContactTelephone(peasantHousehold.getTelephone()); commercial.setLegalContactTelephone(peasantHousehold.getTelephone());
// 资料归档 // 资料归档
QueryWrapper<Information> informationQueryWrapper = new QueryWrapper<>(); QueryWrapper<Information> informationQueryWrapper = new QueryWrapper<>();
informationQueryWrapper.eq("survey_information_id", surveyInformationId); informationQueryWrapper.eq("survey_information_id", surveyInformationId);
Information information = informationService.getBaseMapper().selectOne(informationQueryWrapper); Information information = informationService.getBaseMapper().selectOne(informationQueryWrapper);
if(information == null){ if (information == null) {
surveyInfoAllDto.setInformation(new InformationDto()); surveyInfoAllDto.setInformation(new InformationDto());
}else { } else {
// 将商务信息的房产证明文件数据赋值给资料归档的房产证明文件 // 将商务信息的房产证明文件数据赋值给资料归档的房产证明文件
information.setCardFile(commercial.getIdCardCredit()); information.setCardFile(commercial.getIdCardCredit());
surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class)); surveyInfoAllDto.setInformation(BeanDtoUtils.convert(information, InformationDto.class));
} }
if (information == null) {
if(information == null){ CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class);
CommercialDto commercialDto = BeanDtoUtils.convert(commercial, CommercialDto.class); commercialDto.setType("zrr");
commercialDto.setType("zrr"); commercialDto.setLegalType("zjdnhw");
commercialDto.setLegalType("zjdnhw"); surveyInfoAllDto.setCommercial(commercialDto);
surveyInfoAllDto.setCommercial(commercialDto); } else {
}else { surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class));
surveyInfoAllDto.setCommercial(BeanDtoUtils.convert(commercial, CommercialDto.class)); if (commercial != null && !StringUtils.isEmpty(commercial.getProjectAddressName())) {
if(commercial !=null && !StringUtils.isEmpty(commercial.getProjectAddressName())){ surveyInfoAllDto.getCommercial()
surveyInfoAllDto.getCommercial().setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/"))); .setProjectAddressText(Arrays.asList(commercial.getProjectAddressName().split("/")));
} }
} }
QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>(); QueryWrapper<ExtendedInformation> extendedInformationQueryWrapper = new QueryWrapper<>();
extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId); extendedInformationQueryWrapper.eq("survey_information_id", surveyInformationId);
ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper().selectOne(extendedInformationQueryWrapper); ExtendedInformation extendedInformation = extendedInformationService.getBaseMapper()
if(information == null){ .selectOne(extendedInformationQueryWrapper);
surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto()); if (information == null) {
}else { surveyInfoAllDto.setExtendedInformation(new ExtendedInformationDto());
surveyInfoAllDto.setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class)); } else {
} surveyInfoAllDto
QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>(); .setExtendedInformation(BeanDtoUtils.convert(extendedInformation, ExtendedInformationDto.class));
designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr()); }
DesignInformation designInformation = designInformationService.getBaseMapper().selectOne(designInformationQueryWrapper); QueryWrapper<DesignInformation> designInformationQueryWrapper = new QueryWrapper<>();
if(designInformation == null){ designInformationQueryWrapper.eq("peasant_household_id", peasantHousehold.getSequenceNbr());
surveyInfoAllDto.setDesignInformation(new DesignInformationDto()); DesignInformation designInformation = designInformationService.getBaseMapper()
}else { .selectOne(designInformationQueryWrapper);
surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class)); if (designInformation == null) {
} surveyInfoAllDto.setDesignInformation(new DesignInformationDto());
} else {
//派工单信息 surveyInfoAllDto.setDesignInformation(BeanDtoUtils.convert(designInformation, DesignInformationDto.class));
LambdaQueryWrapper<WorkOrder> upl=new LambdaQueryWrapper(); }
upl.eq(WorkOrder::getSequenceNbr,workOrderId);
WorkOrder workOrder= workOrderMapper.selectOne(upl); // 派工单信息
LambdaQueryWrapper<WorkOrder> upl = new LambdaQueryWrapper();
//施工信息 upl.eq(WorkOrder::getSequenceNbr, workOrderId);
LambdaQueryWrapper<PowerStationConstructionData> up2=new LambdaQueryWrapper(); WorkOrder workOrder = workOrderMapper.selectOne(upl);
up2.eq(PowerStationConstructionData::getWorkOrderId,workOrderId);
up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId,workOrderPowerStationId); // 施工信息
PowerStationConstructionData powerStationConstructionData=powerStationConstructionDataMapper.selectOne(up2); LambdaQueryWrapper<PowerStationConstructionData> up2 = new LambdaQueryWrapper();
up2.eq(PowerStationConstructionData::getWorkOrderId, workOrderId);
//工程信息 up2.eq(PowerStationConstructionData::getWorkOrderPowerStationId, workOrderPowerStationId);
PowerStationConstructionData powerStationConstructionData = powerStationConstructionDataMapper.selectOne(up2);
LambdaQueryWrapper<PowerStationEngineeringInfo> up3=new LambdaQueryWrapper();
up3.eq(PowerStationEngineeringInfo::getWorkOrderId,workOrderId); // 工程信息
up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId,workOrderPowerStationId);
PowerStationEngineeringInfo powerStationEngineeringInfo=powerStationEngineeringInfoMapper.selectOne(up3); LambdaQueryWrapper<PowerStationEngineeringInfo> up3 = new LambdaQueryWrapper();
if(powerStationConstructionData!=null){ up3.eq(PowerStationEngineeringInfo::getWorkOrderId, workOrderId);
powerStationEngineeringInfo=powerStationEngineeringInfo!=null?powerStationEngineeringInfo:new PowerStationEngineeringInfo(); up3.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId, workOrderPowerStationId);
powerStationEngineeringInfo.setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo()); PowerStationEngineeringInfo powerStationEngineeringInfo = powerStationEngineeringInfoMapper.selectOne(up3);
powerStationEngineeringInfo.setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo()); if (powerStationConstructionData != null) {
powerStationEngineeringInfo.setConstructionCollectorBoxInfo(powerStationConstructionData.getConstructionCollectorBoxInfo()); powerStationEngineeringInfo = powerStationEngineeringInfo != null ? powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo()); : new PowerStationEngineeringInfo();
powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager()); powerStationEngineeringInfo
powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone()); .setConstructionComponentInfo(powerStationConstructionData.getConstructionComponentInfo());
powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager()); powerStationEngineeringInfo
powerStationEngineeringInfo.setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone()); .setConstructionInverterInfo(powerStationConstructionData.getConstructionInverterInfo());
} powerStationEngineeringInfo
//并网信息 .setConstructionCollectorBoxInfo(powerStationConstructionData.getConstructionCollectorBoxInfo());
LambdaQueryWrapper<HygfOnGrid> up4=new LambdaQueryWrapper(); powerStationEngineeringInfo
up4.eq(HygfOnGrid::getWorkOrderId,workOrderId); .setConstructionGridBoxInfo(powerStationConstructionData.getConstructionGridBoxInfo());
up4.eq(HygfOnGrid::getWorkOrderPowerStationId,workOrderPowerStationId); powerStationEngineeringInfo.setProjectRegionManager(workOrder.getProjectRegionManager());
HygfOnGrid hygfOnGrid=hygfOnGridMapper.selectOne(up4); powerStationEngineeringInfo.setProjectRegionManagerPhone(workOrder.getProjectRegionManagerPhone());
surveyInfoAllDto.setHygfOnGrid(hygfOnGrid!=null?hygfOnGrid:new HygfOnGrid()); powerStationEngineeringInfo.setConstructionRegionManager(workOrder.getConstructionRegionManager());
surveyInfoAllDto.setPowerStationConstructionData(powerStationConstructionData); powerStationEngineeringInfo
surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo); .setConstructionRegionManagerPhone(workOrder.getConstructionRegionManagerPhone());
surveyInfoAllDto.setWorkOrder(workOrder); }
// 并网信息
//施工自审 LambdaQueryWrapper<HygfOnGrid> up4 = new LambdaQueryWrapper();
LambdaQueryWrapper<ConstructionRecords> up5=new LambdaQueryWrapper(); up4.eq(HygfOnGrid::getWorkOrderId, workOrderId);
up5.eq(ConstructionRecords::getWorkOrderId,workOrderId); up4.eq(HygfOnGrid::getWorkOrderPowerStationId, workOrderPowerStationId);
up5.eq(ConstructionRecords::getWorkOrderPowerStationId,workOrderPowerStationId); HygfOnGrid hygfOnGrid = hygfOnGridMapper.selectOne(up4);
up5.orderByAsc(ConstructionRecords::getRecDate); surveyInfoAllDto.setHygfOnGrid(hygfOnGrid != null ? hygfOnGrid : new HygfOnGrid());
List<ConstructionRecords> li=constructionRecordsMapper.selectList(up5); surveyInfoAllDto.setPowerStationConstructionData(powerStationConstructionData);
ConstructionRecords data=new ConstructionRecords(); surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo);
data.setConstructionRecordsList(li); surveyInfoAllDto.setWorkOrder(workOrder);
surveyInfoAllDto.setConstructionRecords(data);
// 施工自审
LambdaQueryWrapper<ConstructionRecords> up5 = new LambdaQueryWrapper();
up5.eq(ConstructionRecords::getWorkOrderId, workOrderId);
LambdaQueryWrapper<BasicGridAcceptance> quv=new LambdaQueryWrapper(); up5.eq(ConstructionRecords::getWorkOrderPowerStationId, workOrderPowerStationId);
quv.eq(BasicGridAcceptance::getPeasantHouseholdId,peasantHouseholdId); up5.orderByAsc(ConstructionRecords::getRecDate);
BasicGridAcceptance basicGridAcceptance= basicGridAcceptanceMapper.selectOne(quv); List<ConstructionRecords> li = constructionRecordsMapper.selectList(up5);
ConstructionRecords data = new ConstructionRecords();
//审核意见 data.setConstructionRecordsList(li);
if(Objects.nonNull(basicGridAcceptance) && !StringUtils.isEmpty(basicGridAcceptance.getInstanceId())){ surveyInfoAllDto.setConstructionRecords(data);
try {
Map<String, Object> flowLoggerMap = workflowFeignClient.getFlowLogger(basicGridAcceptance.getInstanceId()).getResult(); LambdaQueryWrapper<BasicGridAcceptance> quv = new LambdaQueryWrapper();
List<LinkedHashMap> flowLogger = (List<LinkedHashMap>) flowLoggerMap.get("flowLogger"); quv.eq(BasicGridAcceptance::getPeasantHouseholdId, peasantHouseholdId);
if (flowLogger.size() > 0 ){ BasicGridAcceptance basicGridAcceptance = basicGridAcceptanceMapper.selectOne(quv);
Collections.reverse(flowLogger);
} // 审核意见
List<LinkedHashMap> flowLoggernew =new ArrayList<>(); if (Objects.nonNull(basicGridAcceptance) && !StringUtils.isEmpty(basicGridAcceptance.getInstanceId())) {
for (LinkedHashMap linkedHashMap : flowLogger) { try {
if(linkedHashMap.get("operateDate")!=null&&!linkedHashMap.get("operateDate").toString().isEmpty()){ Map<String, Object> flowLoggerMap = workflowFeignClient
LinkedHashMap linke=new LinkedHashMap(); .getFlowLogger(basicGridAcceptance.getInstanceId()).getResult();
linke.put("approvalStatue",linkedHashMap.get("approvalStatue").toString()); List<LinkedHashMap> flowLogger = (List<LinkedHashMap>) flowLoggerMap.get("flowLogger");
//审核意见 if (flowLogger.size() > 0) {
List<LinkedHashMap> approvalSuggestion = (List<LinkedHashMap>)linkedHashMap.get("approvalSuggestion"); Collections.reverse(flowLogger);
if(approvalSuggestion!=null&&!approvalSuggestion.isEmpty()){ }
linke.put("approvalSuggestion",approvalSuggestion.get(0).get("message")); List<LinkedHashMap> flowLoggernew = new ArrayList<>();
} for (LinkedHashMap linkedHashMap : flowLogger) {
linke.put("taskName",linkedHashMap.get("taskName").toString()); if (linkedHashMap.get("operateDate") != null
linke.put("operator",linkedHashMap.get("operator").toString()); && !linkedHashMap.get("operateDate").toString().isEmpty()) {
linke.put("operateDate",linkedHashMap.get("operateDate").toString()); LinkedHashMap linke = new LinkedHashMap();
flowLoggernew.add(linke); linke.put("approvalStatue", linkedHashMap.get("approvalStatue").toString());
} // 审核意见
} List<LinkedHashMap> approvalSuggestion = (List<LinkedHashMap>) linkedHashMap
LoggerDto loggerDto =new LoggerDto(); .get("approvalSuggestion");
loggerDto.setLogger(flowLoggernew); if (approvalSuggestion != null && !approvalSuggestion.isEmpty()) {
surveyInfoAllDto.setLoggerDto(loggerDto); linke.put("approvalSuggestion", approvalSuggestion.get(0).get("message"));
} catch (Exception e){ }
e.printStackTrace(); linke.put("taskName", linkedHashMap.get("taskName").toString());
} linke.put("operator", linkedHashMap.get("operator").toString());
} linke.put("operateDate", linkedHashMap.get("operateDate").toString());
flowLoggernew.add(linke);
}
}
LoggerDto loggerDto = new LoggerDto();
return surveyInfoAllDto; loggerDto.setLogger(flowLoggernew);
surveyInfoAllDto.setLoggerDto(loggerDto);
} catch (Exception e) {
e.printStackTrace();
}
}
return surveyInfoAllDto;
// LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>(); // LambdaQueryWrapper<PeasantHousehold> peasantHouseholdWrapper = new LambdaQueryWrapper<>();
// peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId); // peasantHouseholdWrapper.eq(PeasantHousehold::getSequenceNbr, peasantHouseholdId);
// peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper); // peasantHousehold = peasantHouseholdServiceImpl.getBaseMapper().selectOne(peasantHouseholdWrapper);
...@@ -826,137 +797,140 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor ...@@ -826,137 +797,140 @@ public class WorkOrderServiceImpl extends BaseService<WorkOrderDto,WorkOrder,Wor
// surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo); // surveyInfoAllDto.setPowerStationEngineeringInfo(powerStationEngineeringInfo);
// return surveyInfoAllDto; // return surveyInfoAllDto;
} }
@Transactional(isolation = Isolation.REPEATABLE_READ)
public PowerStationEngineeringInfoAllDto addPowerStationEngineeringInfo(PowerStationEngineeringInfoAllDto powerStationEngineeringInfoAllDto){ @Transactional(isolation = Isolation.REPEATABLE_READ)
public PowerStationEngineeringInfoAllDto addPowerStationEngineeringInfo(
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper(); PowerStationEngineeringInfoAllDto powerStationEngineeringInfoAllDto) {
qu.eq(WorkOrderPowerStation::getSequenceNbr,powerStationEngineeringInfoAllDto.getWorkOrderPowerStationId());
WorkOrderPowerStation workOrderPowerStation=workOrderPowerStationMapper.selectOne(qu); LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
//修改电站状态 qu.eq(WorkOrderPowerStation::getSequenceNbr, powerStationEngineeringInfoAllDto.getWorkOrderPowerStationId());
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待审核.getCode()); WorkOrderPowerStation workOrderPowerStation = workOrderPowerStationMapper.selectOne(qu);
workOrderPowerStationMapper.updateById(workOrderPowerStation); // 修改电站状态
//修改派工单状态PowerStationEngineeringInfo workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.待审核.getCode());
LambdaQueryWrapper<WorkOrderPowerStation> qu1=new LambdaQueryWrapper(); workOrderPowerStationMapper.updateById(workOrderPowerStation);
qu1.eq(WorkOrderPowerStation::getWorkOrderId,workOrderPowerStation.getWorkOrderId()); // 修改派工单状态PowerStationEngineeringInfo
List<String> d=new ArrayList<>(); LambdaQueryWrapper<WorkOrderPowerStation> qu1 = new LambdaQueryWrapper();
d.add(WorkOrderEnum.施工中.getCode()); qu1.eq(WorkOrderPowerStation::getWorkOrderId, workOrderPowerStation.getWorkOrderId());
d.add(WorkOrderEnum.待施工.getCode()); List<String> d = new ArrayList<>();
d.add(WorkOrderEnum.待登记.getCode()); d.add(WorkOrderEnum.施工中.getCode());
qu1.in(WorkOrderPowerStation::getPowerStationConstructionStatus,d); d.add(WorkOrderEnum.待施工.getCode());
List<WorkOrderPowerStation> list=workOrderPowerStationMapper.selectList(qu1); d.add(WorkOrderEnum.待登记.getCode());
LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper(); qu1.in(WorkOrderPowerStation::getPowerStationConstructionStatus, d);
upq.eq(WorkOrder::getSequenceNbr,workOrderPowerStation.getWorkOrderId()); List<WorkOrderPowerStation> list = workOrderPowerStationMapper.selectList(qu1);
if(list==null||list.isEmpty()){ LambdaUpdateWrapper<WorkOrder> upq = new LambdaUpdateWrapper();
upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.审核中.getCode()); upq.eq(WorkOrder::getSequenceNbr, workOrderPowerStation.getWorkOrderId());
workOrderMapper.update(null,upq); if (list == null || list.isEmpty()) {
} upq.set(WorkOrder::getWorkOrderStatus, WorkOrderEnum.审核中.getCode());
//新增完工登记 workOrderMapper.update(null, upq);
PowerStationEngineeringInfo powerStationEngineeringInfo= powerStationEngineeringInfoAllDto.getPowerStationEngineeringInfo(); }
powerStationEngineeringInfo.setWorkOrderId(workOrderPowerStation.getWorkOrderId()); // 新增完工登记
powerStationEngineeringInfo.setWorkOrderPowerStationId(powerStationEngineeringInfoAllDto.getWorkOrderPowerStationId()); PowerStationEngineeringInfo powerStationEngineeringInfo = powerStationEngineeringInfoAllDto
powerStationEngineeringInfoService.saveOrUpdate(powerStationEngineeringInfo); .getPowerStationEngineeringInfo();
//增加操作日志 powerStationEngineeringInfo.setWorkOrderId(workOrderPowerStation.getWorkOrderId());
ConstructionRecords da=new ConstructionRecords( powerStationEngineeringInfo
powerStationEngineeringInfo.getRecUserName(), .setWorkOrderPowerStationId(powerStationEngineeringInfoAllDto.getWorkOrderPowerStationId());
"完工登记", powerStationEngineeringInfoService.saveOrUpdate(powerStationEngineeringInfo);
new Date(), // 增加操作日志
"", ConstructionRecords da = new ConstructionRecords(powerStationEngineeringInfo.getRecUserName(), "完工登记",
workOrderPowerStation.getWorkOrderId(), new Date(), "", workOrderPowerStation.getWorkOrderId(), workOrderPowerStation.getSequenceNbr(),
workOrderPowerStation.getSequenceNbr(), workOrderPowerStation.getPeasantHouseholdId(), "");
workOrderPowerStation.getPeasantHouseholdId(), constructionRecordsServiceImpl.save(da);
""); return powerStationEngineeringInfoAllDto;
constructionRecordsServiceImpl.save(da); }
return powerStationEngineeringInfoAllDto;
} public PowerStationEngineeringInfoAllDto getConstructionRecords(Long workOrderPowerStationId, String rename) {
LambdaQueryWrapper<WorkOrderPowerStation> qu = new LambdaQueryWrapper();
qu.eq(WorkOrderPowerStation::getSequenceNbr, workOrderPowerStationId);
public PowerStationEngineeringInfoAllDto getConstructionRecords(Long workOrderPowerStationId,String rename) { WorkOrderPowerStation workOrderPowerStation = workOrderPowerStationMapper.selectOne(qu);
Long peasantHouseholdId = workOrderPowerStation.getPeasantHouseholdId();
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper(); Long workOrderId = workOrderPowerStation.getWorkOrderId();
qu.eq(WorkOrderPowerStation::getSequenceNbr,workOrderPowerStationId); PowerStationEngineeringInfoAllDto surveyInfoAllDto = new PowerStationEngineeringInfoAllDto();
WorkOrderPowerStation workOrderPowerStation=workOrderPowerStationMapper.selectOne(qu); // 施工自审
Long peasantHouseholdId=workOrderPowerStation.getPeasantHouseholdId(); LambdaQueryWrapper<ConstructionRecords> up5 = new LambdaQueryWrapper();
Long workOrderId=workOrderPowerStation.getWorkOrderId(); up5.eq(ConstructionRecords::getWorkOrderId, workOrderId);
PowerStationEngineeringInfoAllDto surveyInfoAllDto = new PowerStationEngineeringInfoAllDto(); up5.eq(ConstructionRecords::getWorkOrderPowerStationId, workOrderPowerStationId);
//施工自审 up5.orderByDesc(ConstructionRecords::getRecDate);
LambdaQueryWrapper<ConstructionRecords> up5=new LambdaQueryWrapper(); List<ConstructionRecords> li = constructionRecordsMapper.selectList(up5);
up5.eq(ConstructionRecords::getWorkOrderId,workOrderId); ConstructionRecords data = new ConstructionRecords();
up5.eq(ConstructionRecords::getWorkOrderPowerStationId,workOrderPowerStationId); data.setConstructionRecordsList(li);
up5.orderByDesc(ConstructionRecords::getRecDate); data.setOperationTime(new Date());
List<ConstructionRecords> li=constructionRecordsMapper.selectList(up5); data.setOperator(rename);
ConstructionRecords data=new ConstructionRecords(); surveyInfoAllDto.setConstructionRecords(data);
data.setConstructionRecordsList(li); return surveyInfoAllDto;
data.setOperationTime(new Date());
data.setOperator(rename); }
surveyInfoAllDto.setConstructionRecords(data);
return surveyInfoAllDto; @Transactional(isolation = Isolation.REPEATABLE_READ)
}
@Transactional(isolation = Isolation.REPEATABLE_READ)
public ConstructionRecords addConstructionRecords(ConstructionRecords constructionRecords){ public ConstructionRecords addConstructionRecords(ConstructionRecords constructionRecords){
synchronized (constructionRecords.getPeasantHouseholdId()) {
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper();
LambdaQueryWrapper<WorkOrderPowerStation> qu=new LambdaQueryWrapper(); qu.eq(WorkOrderPowerStation::getSequenceNbr,constructionRecords.getWorkOrderPowerStationId());
qu.eq(WorkOrderPowerStation::getSequenceNbr,constructionRecords.getWorkOrderPowerStationId()); WorkOrderPowerStation workOrderPowerStation=workOrderPowerStationMapper.selectOne(qu);
WorkOrderPowerStation workOrderPowerStation=workOrderPowerStationMapper.selectOne(qu);
if(constructionRecords.getOperationResults().equals("通过")){
if(constructionRecords.getOperationResults().equals("通过")){ //修改电站状态
//修改电站状态 workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.已完工.getCode());
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.已完工.getCode());
//修改完工时间
//修改完工时间 LambdaUpdateWrapper<PowerStationEngineeringInfo> upq1=new LambdaUpdateWrapper();
LambdaUpdateWrapper<PowerStationEngineeringInfo> upq1=new LambdaUpdateWrapper(); upq1.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId,workOrderPowerStation.getSequenceNbr());
upq1.eq(PowerStationEngineeringInfo::getWorkOrderPowerStationId,workOrderPowerStation.getSequenceNbr()); upq1.set(PowerStationEngineeringInfo::getCompletionDate,new Date());
upq1.set(PowerStationEngineeringInfo::getCompletionDate,new Date()); powerStationEngineeringInfoMapper.update(null,upq1);
powerStationEngineeringInfoMapper.update(null,upq1);
BasicGridAcceptance dat=new BasicGridAcceptance();
BasicGridAcceptance dat=new BasicGridAcceptance(); dat.setWorkOrderId(workOrderPowerStation.getWorkOrderId());
dat.setWorkOrderId(workOrderPowerStation.getWorkOrderId()); dat.setWorkOrderPowerStationId(workOrderPowerStation.getSequenceNbr());
dat.setWorkOrderPowerStationId(workOrderPowerStation.getSequenceNbr()); dat.setPeasantHouseholdId(workOrderPowerStation.getPeasantHouseholdId());
dat.setPeasantHouseholdId(workOrderPowerStation.getPeasantHouseholdId()); dat.setGridStatus("1");
dat.setGridStatus("1");
//新增并网记录 //新增并网记录
basicGridAcceptanceMapper.insert(dat); LambdaQueryWrapper<BasicGridAcceptance> bga = new LambdaQueryWrapper<>();
workOrderPowerStationMapper.updateById(workOrderPowerStation); bga.eq(BasicGridAcceptance::getPeasantHouseholdId, workOrderPowerStation.getPeasantHouseholdId());
//修改派工单状态 BasicGridAcceptance b = basicGridAcceptanceMapper.selectOne(bga);
LambdaQueryWrapper<WorkOrderPowerStation> qu1=new LambdaQueryWrapper(); //防止重复增加
qu1.eq(WorkOrderPowerStation::getWorkOrderId,workOrderPowerStation.getWorkOrderId()); if(b==null)
List<String> d=new ArrayList<>(); {
d.add(WorkOrderEnum.施工中.getCode()); basicGridAcceptanceMapper.insert(dat);
d.add(WorkOrderEnum.待施工.getCode()); }
d.add(WorkOrderEnum.待登记.getCode()); workOrderPowerStationMapper.updateById(workOrderPowerStation);
d.add(WorkOrderEnum.待审核.getCode()); //修改派工单状态
qu1.in(WorkOrderPowerStation::getPowerStationConstructionStatus,d); LambdaQueryWrapper<WorkOrderPowerStation> qu1=new LambdaQueryWrapper();
List<WorkOrderPowerStation> list=workOrderPowerStationMapper.selectList(qu1); qu1.eq(WorkOrderPowerStation::getWorkOrderId,workOrderPowerStation.getWorkOrderId());
LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper(); List<String> d=new ArrayList<>();
upq.eq(WorkOrder::getSequenceNbr,workOrderPowerStation.getWorkOrderId()); d.add(WorkOrderEnum.施工中.getCode());
if(list==null||list.isEmpty()){ d.add(WorkOrderEnum.待施工.getCode());
upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.已完工.getCode()); d.add(WorkOrderEnum.待登记.getCode());
workOrderMapper.update(null,upq); d.add(WorkOrderEnum.待审核.getCode());
} qu1.in(WorkOrderPowerStation::getPowerStationConstructionStatus,d);
List<WorkOrderPowerStation> list=workOrderPowerStationMapper.selectList(qu1);
}else{ LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper();
//修改电站状态 upq.eq(WorkOrder::getSequenceNbr,workOrderPowerStation.getWorkOrderId());
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.未通过.getCode()); if(list==null||list.isEmpty()){
workOrderPowerStationMapper.updateById(workOrderPowerStation); upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.已完工.getCode());
LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper(); workOrderMapper.update(null,upq);
upq.eq(WorkOrder::getSequenceNbr,workOrderPowerStation.getWorkOrderId()); }
upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.未通过
.getCode()); }else{
workOrderMapper.update(null,upq); //修改电站状态
workOrderPowerStation.setPowerStationConstructionStatus(WorkOrderEnum.未通过.getCode());
} workOrderPowerStationMapper.updateById(workOrderPowerStation);
LambdaUpdateWrapper<WorkOrder> upq=new LambdaUpdateWrapper();
//增加操作日志 upq.eq(WorkOrder::getSequenceNbr,workOrderPowerStation.getWorkOrderId());
constructionRecords.setWorkOrderId(workOrderPowerStation.getWorkOrderId()); upq.set(WorkOrder::getWorkOrderStatus,WorkOrderEnum.未通过
constructionRecords.setOperationContent("完工自审-"+constructionRecords.getOperationResults()); .getCode());
constructionRecords.setWorkOrderPowerStationId(workOrderPowerStation.getSequenceNbr()); workOrderMapper.update(null,upq);
constructionRecords.setPeasantHouseholdId(workOrderPowerStation.getPeasantHouseholdId());
constructionRecordsServiceImpl.save(constructionRecords); }
//增加操作日志
constructionRecords.setWorkOrderId(workOrderPowerStation.getWorkOrderId());
constructionRecords.setOperationContent("完工自审-"+constructionRecords.getOperationResults());
constructionRecords.setWorkOrderPowerStationId(workOrderPowerStation.getSequenceNbr());
constructionRecords.setPeasantHouseholdId(workOrderPowerStation.getPeasantHouseholdId());
constructionRecordsServiceImpl.save(constructionRecords);
}
return constructionRecords; return constructionRecords;
} }
......
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