Commit cf962e18 authored by suhuiguang's avatar suhuiguang

1.检验检测-J065

parent 3246ce83
......@@ -46,6 +46,12 @@ public class JyjcInspectionApplication extends BaseEntity {
private String equipClassify;
/**
* 设备类别code
*/
@TableField("equ_category")
private String equCategory;
/**
* 报检单号
*/
@TableField("application_no")
......
......@@ -149,6 +149,10 @@ public class JyjcInspectionApplicationModel extends BaseModel {
@ApiModelProperty(value = "设备分类")
private String equList;
@ApiModelProperty(value = "设备类别code")
private String equCategory;
@ApiModelProperty(value = "监管码")
private String supervisoryCode;
......
......@@ -10,6 +10,8 @@ import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.EquipRegularlyRemindSe
import com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseEnterpriseInfoDto;
import com.yeejoin.amos.boot.module.ymt.api.entity.TzBaseEnterpriseInfo;
import com.yeejoin.amos.boot.module.ymt.api.entity.TzsUserInfo;
import com.yeejoin.amos.feign.systemctl.Systemctl;
import com.yeejoin.amos.feign.systemctl.model.DictionarieValueModel;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
......@@ -20,7 +22,6 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
......@@ -42,6 +43,8 @@ public class CommonController extends BaseController {
@Autowired
EquipRegularlyRemindServicelmpl equipRegularlyRemindServicelmpl;
private final static String SBZL_DICT_PRIFIX = "JYJC_SBZL";
/**
* 新增
*
......@@ -65,18 +68,18 @@ public class CommonController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/getUserPhonesByPersonCode")
@ApiOperation(httpMethod = "GET", value = "根据公司的unitCode获取检测检验人员联系电话", notes = "根据公司的unitCode获取检测检验人员联系电话")
public ResponseModel<Map<String,Object>> getUserPhonesByPersonCode(@RequestParam String unitCode) {
public ResponseModel<Map<String, Object>> getUserPhonesByPersonCode(@RequestParam String unitCode) {
if (unitCode.contains("_")) {
unitCode = unitCode.split("_")[0];
}
List<TzsUserInfo> userPhones = commonserviceImpl.getUserPhonesByPersonCode(unitCode);
if (CollectionUtils.isEmpty(userPhones)){
if (CollectionUtils.isEmpty(userPhones)) {
return null;
}
List<String> phones = userPhones.stream().map(TzsUserInfo::getPhone).collect(Collectors.toList());
String phone = String.join(",", phones);
Map<String,Object> map = new HashMap<>();
map.put("phone",phone);
Map<String, Object> map = new HashMap<>();
map.put("phone", phone);
return ResponseHelper.buildResponse(map);
}
......@@ -84,20 +87,21 @@ public class CommonController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/getInnerPersonCodeByPersonCode")
@ApiOperation(httpMethod = "POST", value = "根据公司的unitCode获取检测检验人员内部编号", notes = "根据公司的unitCode获取检测检验人员内部编号")
public ResponseModel<Map<String,Object>> getInnerPersonCodeByPersonCode(@RequestParam String unitCode) {
public ResponseModel<Map<String, Object>> getInnerPersonCodeByPersonCode(@RequestParam String unitCode) {
if (unitCode.contains("_")) {
unitCode = unitCode.split("_")[0];
}
List<TzsUserInfo> userPhones = commonserviceImpl.getUserPhonesByPersonCode(unitCode);
if (CollectionUtils.isEmpty(userPhones)){
if (CollectionUtils.isEmpty(userPhones)) {
return null;
}
List<String> phones = userPhones.stream().filter(e-> StringUtils.isNotEmpty(e.getInnerPersonCode())).map(TzsUserInfo::getInnerPersonCode).collect(Collectors.toList());
Map<String,Object> map = new HashMap<>();
if (CollectionUtils.isEmpty(phones)){
map.put("innerPersonCode"," ");
}else { String innerPersonCode = String.join(",", phones);
map.put("innerPersonCode",innerPersonCode);
List<String> phones = userPhones.stream().filter(e -> StringUtils.isNotEmpty(e.getInnerPersonCode())).map(TzsUserInfo::getInnerPersonCode).collect(Collectors.toList());
Map<String, Object> map = new HashMap<>();
if (CollectionUtils.isEmpty(phones)) {
map.put("innerPersonCode", " ");
} else {
String innerPersonCode = String.join(",", phones);
map.put("innerPersonCode", innerPersonCode);
}
return ResponseHelper.buildResponse(map);
......@@ -140,7 +144,7 @@ public class CommonController extends BaseController {
@PostMapping(value = "/bj/transfer")
@ApiOperation(httpMethod = "POST", value = "公共转办接口", notes = "公共转办接口")
public ResponseModel<Object> transferBJ(@RequestBody Map<String, Object> map) {
map.put("key","instance_id");
map.put("key", "instance_id");
Object result = taskModelService.transfer(map);
return ResponseHelper.buildResponse(result);
}
......@@ -154,7 +158,7 @@ public class CommonController extends BaseController {
@PostMapping(value = "/kt/transfer")
@ApiOperation(httpMethod = "POST", value = "公共转办接口", notes = "公共转办接口")
public ResponseModel<Object> transferKT(@RequestBody Map<String, Object> map) {
map.put("key","workflow_prostance_id");
map.put("key", "workflow_prostance_id");
Object result = taskModelService.transfer(map);
return ResponseHelper.buildResponse(result);
}
......@@ -167,4 +171,13 @@ public class CommonController extends BaseController {
@ApiParam(value = "人员类型", allowableValues = "jy,jc") @RequestParam String personType) {
return ResponseHelper.buildResponse(commonserviceImpl.getUserListByUnitCodeAndPost(unitCode, personType));
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/equList")
@ApiOperation(httpMethod = "GET", value = "按照业务类型查询设备种类,工作台使用", notes = "按照业务类型查询设备种类,工作台使用")
public ResponseModel<List<DictionarieValueModel>> equList(@RequestParam(value = "inspectionType") String bizType) {
String dictCode = String.format("%s_%s", SBZL_DICT_PRIFIX, bizType);
return ResponseHelper.buildResponse(Systemctl.dictionarieClient.dictValues(dictCode).getResult());
}
}
......@@ -155,7 +155,6 @@ public class JyjcInspectionApplicationController extends BaseController {
ReginParams reginParams = getSelectedOrgInfo();
inspectionUnitCode = reginParams.getCompany().getCompanyCode();
List<String> roleIds = StrUtil.split(roles, ",");
return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page, applicationNo, inspectionClassify, applicationUnitCode, equipClassify, inspectionUnitCode, applicationUnitName, inspectionUnitName, applicationDate, acceptDate, inspectionChargePerson, status, bizType));
}
......@@ -183,8 +182,6 @@ public class JyjcInspectionApplicationController extends BaseController {
page.setSize(size);
ReginParams reginParams = getSelectedOrgInfo();
applicationUnitCode = reginParams.getCompany().getCompanyCode();
List<String> roleIds = StrUtil.split(roles, ",");
// return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page,applicationNo,inspectionClassify,applicationUnitCode,equipClassify,inspectionUnitCode,applicationUnitName,inspectionUnitName,applicationDate,acceptDate,inspectionChargePerson,status,bizType,roleIds));
return ResponseHelper.buildResponse(jyjcInspectionApplicationServiceImpl.queryForJyjcInspectionApplicationPage(page, applicationNo, inspectionClassify, applicationUnitCode, equipClassify, inspectionUnitCode, applicationUnitName, inspectionUnitName, applicationDate, acceptDate, inspectionChargePerson, status, bizType));
}
......
package com.yeejoin.amos.boot.module.jyjc.biz.dao;
import com.yeejoin.amos.boot.module.ymt.api.dto.ESEquipmentCategoryDto;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface ESEquipmentCategory extends PagingAndSortingRepository<ESEquipmentCategoryDto, String> {
}
package com.yeejoin.amos.boot.module.jyjc.biz.service.impl;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplication;
import com.yeejoin.amos.boot.module.jyjc.api.entity.JyjcInspectionApplicationEquip;
import com.yeejoin.amos.boot.module.jyjc.api.model.InspectionPlanModel;
import com.yeejoin.amos.boot.module.jyjc.biz.dao.ESEquipmentCategory;
import com.yeejoin.amos.boot.module.ymt.api.dto.ESEquipmentCategoryDto;
import org.springframework.stereotype.Service;
import org.typroject.tyboot.core.rdbms.orm.entity.BaseEntity;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
/**
* @author Administrator
*/
......@@ -15,8 +23,16 @@ public class InspectionPlanServiceImpl {
private JyjcInspectionApplicationServiceImpl inspectionApplicationService;
public InspectionPlanServiceImpl(JyjcInspectionApplicationServiceImpl inspectionApplicationService) {
private JyjcInspectionApplicationEquipServiceImpl applicationEquipService;
private ESEquipmentCategory esEquipmentCategory;
public InspectionPlanServiceImpl(JyjcInspectionApplicationServiceImpl inspectionApplicationService,
JyjcInspectionApplicationEquipServiceImpl applicationEquipService,
ESEquipmentCategory esEquipmentCategory) {
this.inspectionApplicationService = inspectionApplicationService;
this.applicationEquipService = applicationEquipService;
this.esEquipmentCategory = esEquipmentCategory;
}
......@@ -31,6 +47,36 @@ public class InspectionPlanServiceImpl {
public JSONObject getDetail(String applicationSeq) {
JyjcInspectionApplication inspectionApplication = inspectionApplicationService.getById(applicationSeq);
// 初始时查询设备地址关联设备表
return inspectionApplication.getPlanData();
JSONObject jsonObject = inspectionApplication.getPlanData();
if(jsonObject == null){
jsonObject = new JSONObject();
String address = this.getOneEquipAddress(applicationSeq);
jsonObject.put("address", address);
}
return jsonObject;
}
private String getOneEquipAddress(String applicationSeq) {
// 查询报检的设备,返回地址,目前是单台报检,applicationEquips长度只有1,后续会多个
List<JyjcInspectionApplicationEquip> applicationEquips = applicationEquipService.list(new LambdaQueryWrapper<JyjcInspectionApplicationEquip>().eq(JyjcInspectionApplicationEquip::getApplicationSeq, applicationSeq));
// 拼接地址
List<String> allAddress = new ArrayList<>();
applicationEquips.forEach(e->{
String record = e.getEquipUnicode();
Optional<ESEquipmentCategoryDto> optional = esEquipmentCategory.findById(record);
if(optional.isPresent()){
ESEquipmentCategoryDto esEquipmentCategoryDto = optional.get();
allAddress.add(this.concatDetailAddress(esEquipmentCategoryDto));
}
});
return String.join(",", allAddress);
}
private String concatDetailAddress(ESEquipmentCategoryDto esEquipmentCategoryDto) {
// 省、市、区
String usePlace = esEquipmentCategoryDto.getUSE_PLACE();
// 详细地址
String address = esEquipmentCategoryDto.getADDRESS();
return String.format("%s%s",usePlace, address);
}
}
......@@ -121,6 +121,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
@Autowired
JyjcOpeningApplicationServiceImpl openingApplicationService;
@Transactional(rollbackFor = Exception.class)
public JyjcInspectionApplicationModel save(@RequestBody JSONObject obj) {
ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
......@@ -653,6 +654,7 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
* @author yangyang
* @date 2023/12/15 15:14
*/
@Transactional(rollbackFor = Exception.class)
public Boolean doReject(Map<String, Object> params) {
Long sequenceNbr = Long.parseLong(params.get("sequenceNbr") + "");
......@@ -709,42 +711,9 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
executeOneStep(model, taskName1, nextUserIds);
BeanUtils.copyProperties(model, entity);
this.updateById(entity);
// updateModelByInstanceId(sequenceNbr, instanceId, params, rollBack);
return true;
}
/**
* 接收/驳回通知检验单
*/
public void execueFlow(Map<String, Object> params) {
String op = params.get("op").toString();
String instanceId = params.get("instanceId").toString();
String comments = params.get("comments").toString();
try {
AjaxResult ajaxResult = Workflow.taskClient.getTaskNoAuth(instanceId);
JSONObject dataObject = JSON.parseObject(JSON.toJSONString(ajaxResult.get("data")));
if (ValidationUtil.isEmpty(dataObject)) {
log.warn("流程已结束, instanceId => {}", instanceId);
return;
}
String taskId = dataObject.getString("id");
//组装信息
TaskResultDTO dto = new TaskResultDTO();
dto.setResultCode("approvalStatus");
dto.setTaskId(taskId);
HashMap<String, Object> varibalble = new HashMap<>();
varibalble.put("approvalStatus", op);
dto.setVariable(varibalble);
dto.setComment(comments);
// 执行流程
AjaxResult ajaxResult1 = Workflow.taskClient.completeByTask(taskId, dto);
} catch (Exception e) {
e.printStackTrace();
log.error("执行工作流错误, => {}", params, e);
throw new BaseException("该项流程发生变化,刷新查看状态后重试", "400", "");
}
}
/**
* 撤回流程办理单
......@@ -805,7 +774,6 @@ public class JyjcInspectionApplicationServiceImpl extends BaseService<JyjcInspec
}
String status = (String) params.get("status");
List<String> persons = JSONArray.parseArray(JSON.toJSONString(params.get("inspectionChargePerson")), String.class);
// List<String> phones = JSONArray.parseArray(JSON.toJSONString(params.get("inspectionChargePhone")), String.class);
String inspectionChargePerson = persons == null ? "" : String.join(",", persons);
if (StringUtils.isNotBlank(inspectionChargePerson)) {
......
......@@ -143,8 +143,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
/**
* 所有人员资质检验检测项目key
*/
private final static String ZZXM_JYJC_DICT_KEY = "ZZXM_JYJC_ALL";
private final static String ZZXM_JYJC_DICT_KEY = "ZZXM_JYJC_ALL";
@Transactional(rollbackFor = {Exception.class, BaseException.class})
......@@ -441,7 +440,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
if (!ValidationUtil.isEmpty(userInfos)) {
List<TzsUserInfoVo> tzsUserInfoVos = userInfos.stream().map(userInfo -> {
TzsUserInfoVo vo = new TzsUserInfoVo();
BeanUtils.copyProperties(userInfo, vo, "identification", "profile", "permissionItem" ,"appointDoc");
BeanUtils.copyProperties(userInfo, vo, "identification", "profile", "permissionItem", "appointDoc");
if (!ObjectUtils.isEmpty(userInfo.getPermissionItem())) {
vo.setPermissionItem(JSON.parseArray(userInfo.getPermissionItem()));
vo.setPermissionItemName(this.castItemCode2Name(userInfo.getPermissionItem()));
......@@ -479,24 +478,24 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
}
private String castItemCode2Name(String permissionItem) {
if(permissionItemList == null){
if (permissionItemList == null) {
FeignClientResult<List<DictionarieValueModel>> itemDicts = Systemctl.dictionarieClient.dictValues(ZZXM_JYJC_DICT_KEY);
permissionItemList = itemDicts.getResult();
}
return permissionItemList.stream().filter(i-> permissionItem.contains(i.getDictDataKey())).map(this::buildItemWithCode).collect(Collectors.joining(","));
return permissionItemList.stream().filter(i -> permissionItem.contains(i.getDictDataKey())).map(this::buildItemWithCode).collect(Collectors.joining(","));
}
private String buildItemWithCode(DictionarieValueModel d) {
return String.format("%s[%s]",d.getDictDataValue(), d.getDictDataKey());
return String.format("%s[%s]", d.getDictDataValue(), d.getDictDataKey());
}
private String getDictNameByCode(String permissionLevel) {
if(StringUtils.isEmpty(permissionLevel)){
if (StringUtils.isEmpty(permissionLevel)) {
return "";
}
if(permissionLevelMap == null){
if (permissionLevelMap == null) {
FeignClientResult<List<DictionarieValueModel>> levelDicts = Systemctl.dictionarieClient.dictValues(RYJB_JYJC_DICT_KEY);
permissionLevelMap = levelDicts.getResult().stream().collect(Collectors.toMap(DictionarieValueModel::getDictDataKey, Function.identity(),(k1, k2)->k2));
permissionLevelMap = levelDicts.getResult().stream().collect(Collectors.toMap(DictionarieValueModel::getDictDataKey, Function.identity(), (k1, k2) -> k2));
}
return Optional.ofNullable(permissionLevelMap.get(permissionLevel).getDictDataValue()).orElse("");
}
......@@ -630,7 +629,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
}
public List<TzBaseEnterpriseInfoDto> getInspectionUnitList() {
List<TzBaseEnterpriseInfoDto> tzBaseEnterpriseInfos = enterpriseInfoMapper.getInspectionUnitList(CommonserviceImpl.UNIT_TYPE);
List<TzBaseEnterpriseInfoDto> tzBaseEnterpriseInfos = enterpriseInfoMapper.getInspectionUnitList();
if (ValidationUtil.isEmpty(tzBaseEnterpriseInfos)) {
return Collections.EMPTY_LIST;
}
......@@ -720,6 +719,6 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
@Override
public List<TzBaseEnterpriseInfoDto> getUnitListByRecord(String record) {
return ruleActionHandler.getInspectionUnitList(new ArrayList<>(),true,record, OpenBizTypeEnum.JC.getCode());
return ruleActionHandler.getInspectionUnitList(new ArrayList<>(), true, record, OpenBizTypeEnum.JC.getCode());
}
}
\ No newline at end of file
......@@ -18,51 +18,50 @@ import java.util.List;
*/
public interface TzBaseEnterpriseInfoMapper extends BaseMapper<TzBaseEnterpriseInfo> {
/**
* 查找企业关联设备详情列表
*
* @param sequenceNbr 企业id
* @return EquEnterDto 使用登记证代码、设备名称、设备类别、设备位置
*/
List<EquEnterDto> getInfo(String sequenceNbr);
/**
* 查找企业关联设备详情列表
*
* @param sequenceNbr 企业id
* @return EquEnterDto 使用登记证代码、设备名称、设备类别、设备位置
*/
List<EquEnterDto> getInfo(String sequenceNbr);
/**
* 根据企业名称查找设备
*
* @param useUnit 企业名称
* @return
*/
List<EquEnterDto> getInfoByUseUnit(String useUnit);
/**
* 根据企业名称查找设备
*
* @param useUnit 企业名称
* @return
*/
List<EquEnterDto> getInfoByUseUnit(String useUnit);
/**
* 根据企业名称查找企业详情信息
* @param useUnit
* @return
*/
TzBaseEnterpriseInfo selectByUseUnit(String useUnit);
/**
* 根据企业名称查找企业详情信息
*
* @param useUnit
* @return
*/
TzBaseEnterpriseInfo selectByUseUnit(String useUnit);
IPage<TzBaseEnterpriseInfoDto> page(Page<TzBaseEnterpriseInfoDto> page, TzBaseEnterpriseInfoDto tzBaseEnterpriseInfoDto);
IPage<TzBaseEnterpriseInfoDto> page(Page<TzBaseEnterpriseInfoDto> page, TzBaseEnterpriseInfoDto tzBaseEnterpriseInfoDto);
IPage<TzBaseEnterpriseInfoDto> pageList(Page<TzBaseEnterpriseInfoDto> page, TzBaseEnterpriseInfoDto tzBaseEnterpriseInfoDto, List orgCodeList);
IPage<TzBaseEnterpriseInfoDto> pageList(Page<TzBaseEnterpriseInfoDto> page, TzBaseEnterpriseInfoDto tzBaseEnterpriseInfoDto, List orgCodeList);
/**
* 查找企业关联设备详情列表
*
*/
List<TzBaseEnterpriseInfoDto> getInspectionUnitList(@Param("unitType") String unitType);
/**
* 查找企业关联设备详情列表
*/
List<TzBaseEnterpriseInfoDto> getInspectionUnitList();
List<TzBaseEnterpriseInfoDto> getInspectionUnitListByCode(@Param("list") List<String> codes, @Param("city") String city, @Param("openBizType") String openBizType);
List<TzBaseEnterpriseInfoDto> getInspectionUnitListByCode(@Param("list") List<String> codes, @Param("city") String city, @Param("openBizType") String openBizType);
/**
* 根据ID查找企业详情信息
*
*
* @param sequenceNbr sequenceNbr
* @return {@link TzBaseEnterpriseInfo}
* @author yangyang
* @throws
*/
TzBaseEnterpriseInfo selectBySeq(Long sequenceNbr);
/**
* 根据ID查找企业详情信息
*
* @param sequenceNbr sequenceNbr
* @return {@link TzBaseEnterpriseInfo}
* @throws
* @author yangyang
*/
TzBaseEnterpriseInfo selectBySeq(Long sequenceNbr);
}
......@@ -166,7 +166,7 @@
tz_base_enterprise_info info
inner JOIN tz_jyjc_opening_application tjoa ON info.use_code = tjoa.unit_code
AND status = '6616'
where unit_type LIKE CONCAT('%',#{unitType},'%') group by info.use_code
group by info.use_code
</select>
<select id="getInspectionUnitListByCode" resultType="com.yeejoin.amos.boot.module.ymt.api.dto.TzBaseEnterpriseInfoDto">
......
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