| | |
| | | * @return String 纠纷编号 |
| | | */ |
| | | public String caseRegisterWechat(RegisterSaveDTO registerSaveDTO, String userId){ |
| | | try { |
| | | // 获取当前登录用户 |
| | | PaUserDTO loginUser = custClient.paclientGetUser(userId); |
| | | if(ObjectUtils.isEmpty(registerSaveDTO.getCustId())){ |
| | | registerSaveDTO.setCustId(loginUser.getCustId()); |
| | | } |
| | | // 获取当前登录用户 |
| | | PaUserDTO loginUser = custClient.paclientGetUser(userId); |
| | | if(ObjectUtils.isEmpty(registerSaveDTO.getCustId())){ |
| | | registerSaveDTO.setCustId(loginUser.getCustId()); |
| | | } |
| | | |
| | | Date nowDate = DateUtils.getNowDate(); |
| | | registerSaveDTO.setUpdateTime(nowDate); |
| | | Date nowDate = DateUtils.getNowDate(); |
| | | registerSaveDTO.setUpdateTime(nowDate); |
| | | |
| | | CaseInfo caseInfo = new CaseInfo(); |
| | | CaseInfoUnfold caseInfoUnfold = new CaseInfoUnfold(); |
| | | BeanUtils.copyProperties(registerSaveDTO, caseInfo); |
| | | if(ObjectUtils.isEmpty(caseInfo.getId())){ |
| | | caseInfo.setId(utilsClient.getNewTimeCaseId()); |
| | | } |
| | | CaseInfo caseInfo = new CaseInfo(); |
| | | CaseInfoUnfold caseInfoUnfold = new CaseInfoUnfold(); |
| | | BeanUtils.copyProperties(registerSaveDTO, caseInfo); |
| | | if(ObjectUtils.isEmpty(caseInfo.getId())){ |
| | | caseInfo.setId(utilsClient.getNewTimeCaseId()); |
| | | } |
| | | // caseInfo.setInputUnitId(loginUser.getUnitId()); |
| | | // caseInfo.setInputUnitName(loginUser.getUnitName()); |
| | | caseInfo.setInputUserId(loginUser.getId()); |
| | | caseInfo.setInputUserName(loginUser.getTrueName()); |
| | | caseInfo.setInputWay(CaseBaseConsts.INPUT_WAY_1); |
| | | caseInfo.setCreateTime(nowDate); |
| | | caseInfo.setUpdateTime(nowDate); |
| | | caseInfo.setVisitTime(nowDate); |
| | | caseInfo.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
| | | //坐标转换 |
| | | if(ObjectUtils.isNotEmpty(caseInfo.getLat()) && ObjectUtils.isNotEmpty(caseInfo.getLng())){ |
| | | PointXY pointXY = MapUtils.gcj02tobd09(Double.valueOf(caseInfo.getLng()), Double.valueOf(caseInfo.getLat())); |
| | | caseInfo.setLat(pointXY.getLat()+""); |
| | | caseInfo.setLng(pointXY.getLon()+""); |
| | | } |
| | | //todo case_title生成 |
| | | caseInfo.setCaseRef(utilsClient.createCaseRef()); |
| | | caseInfo.setInputUserId(loginUser.getId()); |
| | | caseInfo.setInputUserName(loginUser.getTrueName()); |
| | | caseInfo.setInputWay(CaseBaseConsts.INPUT_WAY_1); |
| | | caseInfo.setCreateTime(nowDate); |
| | | caseInfo.setUpdateTime(nowDate); |
| | | caseInfo.setVisitTime(nowDate); |
| | | caseInfo.setDeleteStatus(BaseConsts.DELETE_STATUS_0); |
| | | //坐标转换 |
| | | if(ObjectUtils.isNotEmpty(caseInfo.getLat()) && ObjectUtils.isNotEmpty(caseInfo.getLng())){ |
| | | PointXY pointXY = MapUtils.gcj02tobd09(Double.valueOf(caseInfo.getLng()), Double.valueOf(caseInfo.getLat())); |
| | | caseInfo.setLat(pointXY.getLat()+""); |
| | | caseInfo.setLng(pointXY.getLon()+""); |
| | | } |
| | | //todo case_title生成 |
| | | caseInfo.setCaseRef(utilsClient.createCaseRef()); |
| | | |
| | | // 为了演示先兼容小程序没属地问题,写死属地 |
| | | if (ObjectUtils.isEmpty(caseInfo.getQueProv())) { |
| | | // 为了演示先兼容小程序没属地问题,写死属地 |
| | | if (ObjectUtils.isEmpty(caseInfo.getQueProv())) { |
| | | // caseInfo.setQueProv("19"); |
| | | // caseInfo.setQueProvName("广东"); |
| | | // caseInfo.setQueCity("1601"); |
| | |
| | | // caseInfo.setQueRoad("62857"); |
| | | // caseInfo.setQueRoadName("新市街道"); |
| | | |
| | | // 根据经纬度查询问题属地 |
| | | QueAddrBaseDTO queAddrBaseDTO = sysClient.getQueAddrByBaiduiLngLat(caseInfo.getLng(), caseInfo.getLat()); |
| | | caseInfo.setQueProv(queAddrBaseDTO.getQueProv()); |
| | | caseInfo.setQueProvName(queAddrBaseDTO.getQueProvName()); |
| | | caseInfo.setQueCity(queAddrBaseDTO.getQueCity()); |
| | | caseInfo.setQueCityName(queAddrBaseDTO.getQueCityName()); |
| | | caseInfo.setQueArea(queAddrBaseDTO.getQueArea()); |
| | | caseInfo.setQueAreaName(queAddrBaseDTO.getQueAreaName()); |
| | | caseInfo.setQueRoad(queAddrBaseDTO.getQueRoad()); |
| | | caseInfo.setQueRoadName(queAddrBaseDTO.getQueRoadName()); |
| | | } |
| | | caseInfoUnfold.setId(caseInfo.getId()); |
| | | caseInfoUnfold.setCreateTime(nowDate); |
| | | caseInfoUnfold.setUpdateTime(nowDate); |
| | | // 根据经纬度查询问题属地 |
| | | QueAddrBaseDTO queAddrBaseDTO = sysClient.getQueAddrByBaiduiLngLat(caseInfo.getLng(), caseInfo.getLat()); |
| | | caseInfo.setQueProv(queAddrBaseDTO.getQueProv()); |
| | | caseInfo.setQueProvName(queAddrBaseDTO.getQueProvName()); |
| | | caseInfo.setQueCity(queAddrBaseDTO.getQueCity()); |
| | | caseInfo.setQueCityName(queAddrBaseDTO.getQueCityName()); |
| | | caseInfo.setQueArea(queAddrBaseDTO.getQueArea()); |
| | | caseInfo.setQueAreaName(queAddrBaseDTO.getQueAreaName()); |
| | | caseInfo.setQueRoad(queAddrBaseDTO.getQueRoad()); |
| | | caseInfo.setQueRoadName(queAddrBaseDTO.getQueRoadName()); |
| | | } |
| | | caseInfoUnfold.setId(caseInfo.getId()); |
| | | caseInfoUnfold.setCreateTime(nowDate); |
| | | caseInfoUnfold.setUpdateTime(nowDate); |
| | | |
| | | StringBuffer plaintiffs = new StringBuffer(); |
| | | StringBuffer defendants = new StringBuffer(); |
| | | StringBuffer pagents = new StringBuffer(); |
| | | StringBuffer dagents = new StringBuffer(); |
| | | // 常规登记-保存当事人 |
| | | int peopleNum = this.saveCasePersonWechat(registerSaveDTO, plaintiffs, pagents, defendants, dagents,loginUser); |
| | | caseInfo.setVisitPeopleNum(peopleNum); |
| | | caseInfo.setPlaintiffs(plaintiffs.toString()); |
| | | caseInfo.setPagents(pagents.toString()); |
| | | caseInfo.setDefendants(defendants.toString()); |
| | | caseInfo.setDagents(dagents.toString()); |
| | | StringBuffer plaintiffs = new StringBuffer(); |
| | | StringBuffer defendants = new StringBuffer(); |
| | | StringBuffer pagents = new StringBuffer(); |
| | | StringBuffer dagents = new StringBuffer(); |
| | | // 常规登记-保存当事人 |
| | | int peopleNum = this.saveCasePersonWechat(registerSaveDTO, plaintiffs, pagents, defendants, dagents,loginUser); |
| | | caseInfo.setVisitPeopleNum(peopleNum); |
| | | caseInfo.setPlaintiffs(plaintiffs.toString()); |
| | | caseInfo.setPagents(pagents.toString()); |
| | | caseInfo.setDefendants(defendants.toString()); |
| | | caseInfo.setDagents(dagents.toString()); |
| | | |
| | | //todo case_title生成 |
| | | //todo case_title生成 |
| | | // caseInfo.setCaseTitle(this.createCaseTitle(plaintiffs.toString(), defendants.toString(), caseInfo.getCaseTypeName())); |
| | | |
| | | caseInfo.setInfoProcess(CaseInfoProcessBaseConstsEnum.CASE_INFO_PROCESS_1.getIndex()); |
| | | caseInfo.setInfoProcessName(CaseInfoProcessBaseConstsEnum.CASE_INFO_PROCESS_1.getDes()); |
| | | caseInfo.setProcess(CaseProcessBaseConstsEnum.CASE_PROCESS_1.getIndex()); |
| | | caseInfo.setProcessName(CaseProcessBaseConstsEnum.CASE_PROCESS_1.getDes()); |
| | | caseInfo.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_1.getIndex()); |
| | | caseInfo.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_1.getDes()); |
| | | caseInfo.setCaseLevel(3); |
| | | caseInfo.setCanal(CaseBaseConstsEnum.CASE_CANAL_2.getIndex()); |
| | | caseInfo.setCanalName(CaseBaseConstsEnum.CASE_CANAL_2.getDes()); |
| | | caseInfo.setInfoProcess(CaseInfoProcessBaseConstsEnum.CASE_INFO_PROCESS_1.getIndex()); |
| | | caseInfo.setInfoProcessName(CaseInfoProcessBaseConstsEnum.CASE_INFO_PROCESS_1.getDes()); |
| | | caseInfo.setProcess(CaseProcessBaseConstsEnum.CASE_PROCESS_1.getIndex()); |
| | | caseInfo.setProcessName(CaseProcessBaseConstsEnum.CASE_PROCESS_1.getDes()); |
| | | caseInfo.setStatus(CaseStatusBaseConstsEnum.CASE_STATUS_1.getIndex()); |
| | | caseInfo.setStatusName(CaseStatusBaseConstsEnum.CASE_STATUS_1.getDes()); |
| | | caseInfo.setCaseLevel(3); |
| | | caseInfo.setCanal(CaseBaseConstsEnum.CASE_CANAL_2.getIndex()); |
| | | caseInfo.setCanalName(CaseBaseConstsEnum.CASE_CANAL_2.getDes()); |
| | | |
| | | caseInfo.setCaseRef(utilsClient.createCaseRef()); |
| | | caseInfo.setVisitWay(CaseBaseConstsEnum.VISIT_WAY_2.getIndex()); |
| | | caseInfo.setVisitWayName(CaseBaseConstsEnum.VISIT_WAY_2.getDes()); |
| | | // 临时加上一级纠纷类型 |
| | | caseInfo.setCaseTypeFirst("24_01-2"); |
| | | caseInfo.setCaseTypeFirstName("劳动社保"); |
| | | this.saveOrUpdate(caseInfo); |
| | | caseInfo.setCaseRef(utilsClient.createCaseRef()); |
| | | caseInfo.setVisitWay(CaseBaseConstsEnum.VISIT_WAY_2.getIndex()); |
| | | caseInfo.setVisitWayName(CaseBaseConstsEnum.VISIT_WAY_2.getDes()); |
| | | // 临时加上一级纠纷类型 |
| | | caseInfo.setCaseTypeFirst("24_01-2"); |
| | | caseInfo.setCaseTypeFirstName("劳动社保"); |
| | | this.saveOrUpdate(caseInfo); |
| | | |
| | | caseInfoUnfoldService.saveOrUpdate(caseInfoUnfold); |
| | | // 启动工作流-自动调度流程 |
| | | caseTaskService.webStartFlowLFDJ(caseInfo); |
| | | return registerSaveDTO.getId(); |
| | | }catch (Exception e){ |
| | | log.error("service方法[CaseInfoService.caseRegisterWechat]调用异常:"+e, e); |
| | | throw new ServiceException("CaseInfoService.caseRegisterWechat", e); |
| | | } |
| | | caseInfoUnfoldService.saveOrUpdate(caseInfoUnfold); |
| | | // 启动工作流-自动调度流程 |
| | | caseTaskService.webStartFlowLFDJ(caseInfo); |
| | | return registerSaveDTO.getId(); |
| | | } |
| | | |
| | | /** |