~huangh/gz-dyh.git

			@@ -22,6 +22,7 @@
			import cn.huge.module.draft.service.CasedraftInfoService;
			import cn.huge.module.mediate.dto.WechatBindCaseDTO;
			import cn.huge.module.sys.dto.FileIdTypeInfoBaseDTO;
			import com.alibaba.fastjson.JSON;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import org.apache.commons.collections.CollectionUtils;
			@@ -74,6 +75,9 @@

			@Autowired
			private SysClientImpl sysClient;

			@Autowired
			private CaseTaskService caseTaskService;

			/**
			* 更新对象
			@@ -194,8 +198,10 @@
			caseInfo.setDagents(dagents.toString());
			caseInfo.setCaseRef(utilsClient.createCaseRef());
			caseInfo.setCanal(CaseBaseConstsEnum.CASE_CANAL_1.getIndex());
			caseInfo.setCaseDes(CaseBaseConstsEnum.CASE_CANAL_1.getDes());
			//todo case_title生成、经纬度转换、来访形式
			caseInfo.setCanalName(CaseBaseConstsEnum.CASE_CANAL_1.getDes());
			caseInfo.setVisitWay(CaseBaseConstsEnum.VISIT_WAY_1.getIndex());
			caseInfo.setVisitWayName(CaseBaseConstsEnum.VISIT_WAY_1.getDes());
			//todo case_title生成、经纬度转换
			if(0 == registerSaveDTO.getOperateType()){
			caseInfo.setInputUnitId(loginUser.getUnitId());
			caseInfo.setInputUnitName(loginUser.getUnitName());
			@@ -204,25 +210,27 @@
			caseInfo.setInputWay(CaseBaseConsts.INPUT_WAY_1);
			caseInfo.setCreateTime(nowDate);
			caseInfo.setDeleteStatus(BaseConsts.DELETE_STATUS_0);

			CaseInfoUnfold caseInfoUnfold = new CaseInfoUnfold();
			caseInfoUnfold.setId(caseInfo.getId());
			caseInfoUnfold.setCreateTime(nowDate);
			caseInfoUnfold.setUpdateTime(nowDate);

			// 删除草稿案件
			if(1 == registerSaveDTO.getIsDraft() ){
			draftInfoService.removeDraftInfo(registerSaveDTO.getId());
			}

			//判断是否自行受理
			if(1 == registerSaveDTO.getIsSelfAccept()){
			//todo 流程接口修改status、status_name、process、process_name
			caseInfoUnfold.setMediateUnitId(loginUser.getUnitId());
			caseInfoUnfold.setMediateUnitName(loginUser.getUnitName());
			}
			// 新增纠纷信息
			this.save(caseInfo);
			// 新增纠纷信息扩展表
			CaseInfoUnfold caseInfoUnfold = new CaseInfoUnfold();
			caseInfoUnfold.setId(caseInfo.getId());
			caseInfoUnfold.setCreateTime(nowDate);
			caseInfoUnfold.setUpdateTime(nowDate);
			caseInfoUnfoldService.save(caseInfoUnfold);
			// 启动工作流
			// 判断是否自行受理
			if(1 == registerSaveDTO.getIsSelfAccept()){
			// 自行受理流程
			caseTaskService.webStartFlowZXSL(caseInfo, loginUser);
			}else {
			// 自动调度流程
			caseTaskService.webStartFlowLFDJ(caseInfo);
			}
			}else if(1 == registerSaveDTO.getOperateType()){
			this.updateById(caseInfo);
			}
			@@ -267,13 +275,13 @@
			//绑定当事人小程序
			this.setPartyUserId(casePerson);
			//添加申请方和被申请方人名组合
			if(CaseBaseConstsEnum.PERSON_TYPE_1.equals(casePerson.getPerType())){
			if(CaseBaseConstsEnum.PERSON_TYPE_1.getIndex().equals(casePerson.getPerType())){
			//申请方
			if (StringUtils.isNotEmpty(plaintiffs.toString())) {
			plaintiffs.append(BaseConsts.COMMA);
			}
			plaintiffs.append(casePerson.getTrueName());
			}else if(CaseBaseConstsEnum.PERSON_TYPE_2.equals(casePerson.getPerType())){
			}else if(CaseBaseConstsEnum.PERSON_TYPE_2.getIndex().equals(casePerson.getPerType())){
			//被申请方
			if (StringUtils.isNotEmpty(defendants.toString())) {
			defendants.append(BaseConsts.COMMA);
			@@ -301,12 +309,12 @@
			caseAgent.setUpdateTime(now);
			//绑定当事人小程序
			this.setPartyUserId(caseAgent);
			if(CaseBaseConstsEnum.PERSON_TYPE_3.equals(caseAgent.getPerType())) {
			if(CaseBaseConstsEnum.PERSON_TYPE_3.getIndex().equals(caseAgent.getPerType())) {
			if (StringUtils.isNotEmpty(pagents.toString())) {
			pagents.append(BaseConsts.COMMA);
			}
			pagents.append(caseAgent.getTrueName());
			}else if(CaseBaseConstsEnum.PERSON_TYPE_4.equals(caseAgent.getPerType())) {
			}else if(CaseBaseConstsEnum.PERSON_TYPE_4.getIndex().equals(caseAgent.getPerType())) {
			if (StringUtils.isNotEmpty(dagents.toString())) {
			dagents.append(BaseConsts.COMMA);
			}
			@@ -529,7 +537,6 @@
			StringBuffer defendants = new StringBuffer();
			StringBuffer pagents = new StringBuffer();
			StringBuffer dagents = new StringBuffer();
			int peopleNum = 0;

			CaseInfo caseInfo = new CaseInfo();
			CaseInfoUnfold caseInfoUnfold = new CaseInfoUnfold();
			@@ -555,15 +562,15 @@
			caseInfoUnfold.setUpdateTime(nowDate);

			// 常规登记-保存当事人
			peopleNum += this.saveCasePersonWechat(registerSaveDTO, plaintiffs, pagents, defendants, dagents,loginUser);
			caseInfo.setPeopleNum(peopleNum);
			this.saveCasePersonWechat(registerSaveDTO, plaintiffs, pagents, defendants, dagents,loginUser);
			caseInfo.setPlaintiffs(plaintiffs.toString());
			caseInfo.setPagents(pagents.toString());
			caseInfo.setDefendants(defendants.toString());
			caseInfo.setDagents(dagents.toString());
			//todo 流程接口修改status、status_name、process、process_name

			this.saveOrUpdate(caseInfo);

			// 启动工作流-自动调度流程
			caseTaskService.webStartFlowLFDJ(caseInfo);
			return registerSaveDTO.getId();
			}catch (Exception e){
			log.error("service方法[CaseInfoService.caseRegisterWechat]调用异常："+e, e);
			@@ -664,14 +671,18 @@
			* @return Page
			*/
			public Page<CaseInfoWeChatDTO> pageQueryWechat(String userId, PageRequest page, Map<String, Object> terms){
			PaUserDTO loginUser = custClient.paclientGetUser(userId);
			List<CaseInfoWeChatDTO> list = new ArrayList<>();
			String personType = terms.get("personType")+"";
			if(ObjectUtils.isEmpty(personType)){
			throw new RuntimeException("请选择人员类型");
			}
			if(ObjectUtils.isEmpty(loginUser.getIdcard())){
			return new PageImpl<CaseInfoWeChatDTO>(list, page, 0);
			}
			QueryWrapper<CasePerson> personWrapper = new QueryWrapper<>();
			personWrapper.select("case_id");
			personWrapper.eq("party_user_id", userId);
			personWrapper.eq("certi_no", loginUser.getIdcard());
			if("1".equals(personType)){
			personWrapper.eq("per_type",CaseBaseConstsEnum.PERSON_TYPE_1.getIndex());
			}else {