Commit dfc4c0a1 authored by yangyang's avatar yangyang

Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register

parents 920358a7 5c60d9ea
...@@ -538,6 +538,21 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste ...@@ -538,6 +538,21 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
scBuilder.minimumShouldMatch(1); scBuilder.minimumShouldMatch(1);
boolMust.must(scBuilder); boolMust.must(scBuilder);
} }
//设备种类编码
if (!ObjectUtils.isEmpty(map.getString("EQU_LIST_CODE"))) {
BoolQueryBuilder elcBuilder = QueryBuilders.boolQuery();
String test = QueryParser.escape(map.getString("EQU_LIST_CODE"));
elcBuilder.must(QueryBuilders.matchPhraseQuery("EQU_LIST_CODE", test));
boolMust.must(elcBuilder);
}
//设备种类名称
if (!ObjectUtils.isEmpty(map.getString("EQU_LIST"))) {
BoolQueryBuilder elBuilder = QueryBuilders.boolQuery();
String test = QueryParser.escape(map.getString("EQU_LIST"));
elBuilder.must(QueryBuilders.matchPhraseQuery("EQU_LIST", "*" + test + "*"));
boolMust.must(elBuilder);
}
builder.query(boolMust); builder.query(boolMust);
builder.sort("REC_DATE", SortOrder.DESC); builder.sort("REC_DATE", SortOrder.DESC);
......
...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; ...@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.aspose.words.SaveFormat; import com.aspose.words.SaveFormat;
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.yeejoin.amos.boot.biz.common.bo.ReginParams; import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
import com.yeejoin.amos.boot.biz.common.utils.DateUtils; import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
...@@ -21,6 +22,7 @@ import com.yeejoin.amos.boot.module.ymt.api.entity.OtherInfo; ...@@ -21,6 +22,7 @@ import com.yeejoin.amos.boot.module.ymt.api.entity.OtherInfo;
import com.yeejoin.amos.boot.module.ymt.api.entity.RegistrationInfo; import com.yeejoin.amos.boot.module.ymt.api.entity.RegistrationInfo;
import com.yeejoin.amos.boot.module.jg.biz.utils.ImageUtils; import com.yeejoin.amos.boot.module.jg.biz.utils.ImageUtils;
import com.yeejoin.amos.boot.module.jg.biz.utils.WordTemplateUtils; import com.yeejoin.amos.boot.module.jg.biz.utils.WordTemplateUtils;
import com.yeejoin.amos.boot.module.ymt.api.entity.SupervisoryCodeInfo;
import com.yeejoin.amos.boot.module.ymt.api.enums.ApplicationFormTypeEnum; import com.yeejoin.amos.boot.module.ymt.api.enums.ApplicationFormTypeEnum;
import com.yeejoin.amos.boot.module.ymt.api.mapper.*; import com.yeejoin.amos.boot.module.ymt.api.mapper.*;
import com.yeejoin.amos.boot.module.ymt.api.service.ICreateCodeService; import com.yeejoin.amos.boot.module.ymt.api.service.ICreateCodeService;
...@@ -93,6 +95,8 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN ...@@ -93,6 +95,8 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
OtherInfoMapper tzsJgOtherInfoMapper; OtherInfoMapper tzsJgOtherInfoMapper;
@Autowired @Autowired
TzsServiceFeignClient tzsServiceFeignClient; TzsServiceFeignClient tzsServiceFeignClient;
@Autowired
SupervisoryCodeInfoMapper supervisoryCodeInfoMapper;
...@@ -574,7 +578,6 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN ...@@ -574,7 +578,6 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
JgInstallationNotice jgInstallationNotice = this.baseMapper.selectById(noticeDto.getSequenceNbr()); JgInstallationNotice jgInstallationNotice = this.baseMapper.selectById(noticeDto.getSequenceNbr());
if(ajaxResult.getStatus() == 200) { if(ajaxResult.getStatus() == 200) {
jgInstallationNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode())); jgInstallationNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
jgInstallationNotice.setStatus(String.valueOf(FlowStatusEnum.ROBACK.getCode()));
jgInstallationNoticeMapper.updateById(jgInstallationNotice); jgInstallationNoticeMapper.updateById(jgInstallationNotice);
} }
} }
...@@ -603,6 +606,8 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN ...@@ -603,6 +606,8 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
queryWrapper2.eq(RegistrationInfo::getRecord,jgRelationEquip.getEquId()); queryWrapper2.eq(RegistrationInfo::getRecord,jgRelationEquip.getEquId());
RegistrationInfo tzsJgRegistrationInfo = tzsJgRegistrationInfoMapper.selectOne(queryWrapper2); RegistrationInfo tzsJgRegistrationInfo = tzsJgRegistrationInfoMapper.selectOne(queryWrapper2);
stringBuffer.append(tzsJgRegistrationInfo.getEquCategory()).append(jgInstallationNotice.getCity()).append(ym); stringBuffer.append(tzsJgRegistrationInfo.getEquCategory()).append(jgInstallationNotice.getCity()).append(ym);
String equCode = stringBuffer.toString(); String equCode = stringBuffer.toString();
String deviceRegistrationCode = iCreateCodeService.createDeviceRegistrationCode(equCode); String deviceRegistrationCode = iCreateCodeService.createDeviceRegistrationCode(equCode);
...@@ -615,6 +620,12 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN ...@@ -615,6 +620,12 @@ public class JgInstallationNoticeServiceImpl extends BaseService<JgInstallationN
ResponseModel<Map<String, Object>> code = tzsServiceFeignClient.createCode(map); ResponseModel<Map<String, Object>> code = tzsServiceFeignClient.createCode(map);
mapCode = code.getResult(); mapCode = code.getResult();
LambdaQueryWrapper<SupervisoryCodeInfo> queryWrapper3 = new LambdaQueryWrapper<>();
queryWrapper3.eq(SupervisoryCodeInfo::getSupervisoryCode,mapCode.get("superviseCode").toString());
SupervisoryCodeInfo supervisoryCodeInfo = supervisoryCodeInfoMapper.selectOne(queryWrapper3);
supervisoryCodeInfo.setStatus("1");
supervisoryCodeInfoMapper.updateById(supervisoryCodeInfo);
boolean submit = submit(jgInstallationNotice, op); boolean submit = submit(jgInstallationNotice, op);
if(submit) { if(submit) {
......
...@@ -18,7 +18,7 @@ import java.util.Map; ...@@ -18,7 +18,7 @@ import java.util.Map;
public interface JyjcInspectionApplicationMapper extends BaseMapper<JyjcInspectionApplication> { public interface JyjcInspectionApplicationMapper extends BaseMapper<JyjcInspectionApplication> {
public Page<JyjcInspectionApplication> queryForDataList( Page<JyjcInspectionApplication> page, String applicationNo, String inspectionClassify, String applicationUnitCode,String applicationUnitName, String equipClassify, String inspectionUnitCode,String inspectionUnitName, String applicationDate, String acceptDate, String inspectionChargePerson, String status , String bizType); public Page<JyjcInspectionApplicationModel> queryForDataList( Page<JyjcInspectionApplication> page, String applicationNo, String inspectionClassify, String applicationUnitCode,String applicationUnitName, String equipClassify, String inspectionUnitCode,String inspectionUnitName, String applicationDate, String acceptDate, String inspectionChargePerson, String status , String bizType);
Page<JyjcInspectionApplicationEquipModel> listByCategory(Page<JyjcInspectionApplicationEquipModel> page,@Param("equipClassify") String equipClassify); Page<JyjcInspectionApplicationEquipModel> listByCategory(Page<JyjcInspectionApplicationEquipModel> page,@Param("equipClassify") String equipClassify);
......
...@@ -3,26 +3,34 @@ ...@@ -3,26 +3,34 @@
<mapper namespace="com.yeejoin.amos.boot.module.jyjc.api.mapper.JyjcInspectionApplicationMapper"> <mapper namespace="com.yeejoin.amos.boot.module.jyjc.api.mapper.JyjcInspectionApplicationMapper">
<select id="queryForDataList" <select id="queryForDataList"
resultType="com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplication"> resultType="com.yeejoin.amos.boot.module.jyjc.api.model.JyjcInspectionApplicationModel">
select SELECT
tzjia.sequence_nbr, tzjia.sequence_nbr,
tzjia.process_instance_id, tzjia.process_instance_id,
tzjia.workflow_node, tzjia.workflow_node,
tzjia.biz_type, tzjia.biz_type,
tzjia.application_no, tzjia.application_no,
tzjia.inspection_type, tzjia.inspection_type,
(select name from cb_data_dictionary where cb_data_dictionary.code = tzjia.inspection_classify and cb_data_dictionary.type = 'JYJCLB') as inspectionClassify, cdd1.NAME AS inspectionClassify,
tzjia.inspection_unit_code, tzjia.inspection_unit_code,
(select name from cb_data_dictionary where cb_data_dictionary.code = tzjia.equip_classify and cb_data_dictionary.type = 'BJSBZL') as equipClassify, cdd.NAME AS equipClassify,
tzjia.number_of_equip, tzjia.number_of_equip,
tzjia.inspection_unit_code, tzjia.inspection_unit_code,
tzjia.application_date, tzjia.application_date,
tzjia.accept_date, tzjia.accept_date,
tzjia.inspection_charge_phone, tzjia.inspection_charge_phone,
tzjia.inspection_charge_person, tzjia.inspection_charge_person,
tzjia.status tzjia.status,
from tbei1.use_unit AS applicationUnitName,
tz_jyjc_inspection_application as tzjia tbei.use_unit AS inspectionUnitName,
cdd.NAME AS status
FROM
tz_jyjc_inspection_application AS tzjia
LEFT JOIN tz_base_enterprise_info tbei ON tbei.use_code = tzjia.application_unit_code
LEFT JOIN tz_base_enterprise_info tbei1 ON tbei1.use_code = tzjia.inspection_unit_code
LEFT JOIN cb_data_dictionary cdd ON cdd.code = tzjia.equip_classify
LEFT JOIN cb_data_dictionary cdd1 ON cdd1.code = tzjia.inspection_classify
LEFT JOIN cb_data_dictionary cdd2 ON cdd1.code = tzjia.status
<where> <where>
<if test=" applicationNo != null and applicationNo != ''"> <if test=" applicationNo != null and applicationNo != ''">
......
...@@ -124,7 +124,7 @@ public class JyjcInspectionApplicationController extends BaseController { ...@@ -124,7 +124,7 @@ public class JyjcInspectionApplicationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/pageByInstitution") @GetMapping(value = "/pageByInstitution")
@ApiOperation(httpMethod = "GET",value = "分页查询(检验机构)", notes = "分页查询(检验机构)") @ApiOperation(httpMethod = "GET",value = "分页查询(检验机构)", notes = "分页查询(检验机构)")
public ResponseModel<Page<JyjcInspectionApplication>> queryForPageByInstitution(@RequestParam(value = "current") int current,@RequestParam public ResponseModel<Page<JyjcInspectionApplicationModel>> queryForPageByInstitution(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size,@RequestParam(required = false) String applicationNo, (value = "size") int size,@RequestParam(required = false) String applicationNo,
@RequestParam(required = false) String inspectionClassify, @RequestParam(required = false) String inspectionClassify,
@RequestParam(required = false) String applicationUnitCode, @RequestParam(required = false) String applicationUnitCode,
...@@ -149,7 +149,7 @@ public class JyjcInspectionApplicationController extends BaseController { ...@@ -149,7 +149,7 @@ public class JyjcInspectionApplicationController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/pageByCompany") @GetMapping(value = "/pageByCompany")
@ApiOperation(httpMethod = "GET",value = "分页查询(报检单位)", notes = "分页查询(报检单位)") @ApiOperation(httpMethod = "GET",value = "分页查询(报检单位)", notes = "分页查询(报检单位)")
public ResponseModel<Page<JyjcInspectionApplication>> queryForPageByCompany(@RequestParam(value = "current") int current,@RequestParam public ResponseModel<Page<JyjcInspectionApplicationModel>> queryForPageByCompany(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size,@RequestParam(required = false) String applicationNo, (value = "size") int size,@RequestParam(required = false) String applicationNo,
@RequestParam(required = false) String inspectionClassify, @RequestParam(required = false) String inspectionClassify,
@RequestParam(required = false) String applicationUnitCode, @RequestParam(required = false) String applicationUnitCode,
......
...@@ -97,14 +97,6 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -97,14 +97,6 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
ActWorkflowStartDTO dto = new ActWorkflowStartDTO(); ActWorkflowStartDTO dto = new ActWorkflowStartDTO();
dto.setProcessDefinitionKey( model.getProcessKey()); dto.setProcessDefinitionKey( model.getProcessKey());
dto.setBusinessKey(buildOrderNo()); dto.setBusinessKey(buildOrderNo());
// dto.setCompleteFirstTask(true);
// JSONObject body = new JSONObject();
// String businessKey = buildOrderNo();
// body.put(WorkFlowEnum.BUSINESSKEY.getCode(), businessKey);
// body.put(WorkFlowEnum.processDefinitionKey.getCode(), model.getProcessKey());
// body.put("completeFirstTask", Boolean.TRUE);
// dto.setCompleteFirstTask(true);
try { try {
FeignClientResult ajaxResult = Workflow.taskV2Client.startByVariable(dto); FeignClientResult ajaxResult = Workflow.taskV2Client.startByVariable(dto);
String id = ((Map) ajaxResult.getResult()).get("id").toString(); String id = ((Map) ajaxResult.getResult()).get("id").toString();
...@@ -114,16 +106,9 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -114,16 +106,9 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
model.setStatus(String.valueOf(FlowStatusEnum.SUBMITTED.getCode()));
// JSONObject body = new JSONObject();
// String businessKey = buildOrderNo();
// body.put(WorkFlowEnum.BUSINESSKEY.getCode(), businessKey);
// body.put(WorkFlowEnum.processDefinitionKey.getCode(), model.getProcessKey());
// JSONObject jsonObject = workflowFeignService.startByVariable(body);
// String processId = JSONObject.parseObject(JSONObject.toJSONString(jsonObject.get("data"))).getString("id");
model.setStatus("已提交");
} else if (model.getOperationType().equals("1")) { } else if (model.getOperationType().equals("1")) {
model.setStatus("草稿"); model.setStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
} }
LambdaQueryWrapper<JyjcOpeningApplication> wa = new LambdaQueryWrapper<JyjcOpeningApplication>().eq(JyjcOpeningApplication::getUnitCode, model.getInspectionUnitCode()).eq(JyjcOpeningApplication::getStatus, FlowStatusEnum.HAVE_PROCESSED.getCode()); LambdaQueryWrapper<JyjcOpeningApplication> wa = new LambdaQueryWrapper<JyjcOpeningApplication>().eq(JyjcOpeningApplication::getUnitCode, model.getInspectionUnitCode()).eq(JyjcOpeningApplication::getStatus, FlowStatusEnum.HAVE_PROCESSED.getCode());
...@@ -214,7 +199,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -214,7 +199,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
jyjcInspectionApplicationAttachmentService.getBaseMapper().insert(attachments); jyjcInspectionApplicationAttachmentService.getBaseMapper().insert(attachments);
} }
} }
model.setStatus("已提交"); model.setStatus(String.valueOf(FlowStatusEnum.SUBMITTED.getCode()));
execueFlow(MapBuilder.<String, Object>create().put("op", "0").put("instanceId", model.getProcessInstanceId()).put("comments", "").build()); execueFlow(MapBuilder.<String, Object>create().put("op", "0").put("instanceId", model.getProcessInstanceId()).put("comments", "").build());
Map<String, Object> nextNodeInfo = workflowHelper.getNextWorkflowNode(model.getProcessInstanceId()); Map<String, Object> nextNodeInfo = workflowHelper.getNextWorkflowNode(model.getProcessInstanceId());
String role = (String) nextNodeInfo.get("role"); String role = (String) nextNodeInfo.get("role");
...@@ -255,7 +240,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -255,7 +240,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
} }
public Page<JyjcInspectionApplication> queryForJyjcInspectionApplicationPage(Page<JyjcInspectionApplication> page, public Page<JyjcInspectionApplicationModel> queryForJyjcInspectionApplicationPage(Page<JyjcInspectionApplication> page,
String applicationNo, String applicationNo,
String inspectionClassify, String inspectionClassify,
String applicationUnitCode, String applicationUnitCode,
...@@ -327,7 +312,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec ...@@ -327,7 +312,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
String type = (String) params.get("type"); String type = (String) params.get("type");
Long sequenceNbr = Long.parseLong(params.get("sequenceNbr") + ""); Long sequenceNbr = Long.parseLong(params.get("sequenceNbr") + "");
JyjcInspectionApplicationModel inspectionApplicationModel = this.queryBySeq(sequenceNbr); JyjcInspectionApplicationModel inspectionApplicationModel = this.queryBySeq(sequenceNbr);
params.put("status", FlowStatusEnum.SUBMITTED.getCode() + ""); params.put("status", FlowStatusEnum.TO_BE_FINISHED.getCode() + "");
updateModelByInstanceId(inspectionApplicationModel.getProcessInstanceId(), params); updateModelByInstanceId(inspectionApplicationModel.getProcessInstanceId(), params);
List<JyjcInspectionApplicationEquipModel> applicationEquipModels = applicationEquipService.listApplicationEquipByApplicationSeq(sequenceNbr); List<JyjcInspectionApplicationEquipModel> applicationEquipModels = applicationEquipService.listApplicationEquipByApplicationSeq(sequenceNbr);
if (inspectionApplicationModel == null || ValidationUtil.isEmpty(applicationEquipModels)) { if (inspectionApplicationModel == null || ValidationUtil.isEmpty(applicationEquipModels)) {
......
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