Commit 4e9b721c authored by KeYong's avatar KeYong

Merge branch 'develop_tzs_register' of…

Merge branch 'develop_tzs_register' of http://36.40.66.175:5000/moa/amos-boot-biz into develop_tzs_register
parents c2592fbf 31190318
...@@ -30,7 +30,7 @@ import java.util.Objects; ...@@ -30,7 +30,7 @@ import java.util.Objects;
*/ */
public class BizCustomDateSerializer extends JsonSerializer<Date> { public class BizCustomDateSerializer extends JsonSerializer<Date> {
private List<String> customFields = Arrays.asList("acceptDate", "expiryDate","applicationDate"); private List<String> customFields = Arrays.asList("acceptDate", "expiryDate","applicationDate","noticeDate","installStartDate","handleDate");
public BizCustomDateSerializer() public BizCustomDateSerializer()
{ {
......
...@@ -110,4 +110,7 @@ public class JgEquipTransferDto extends BaseDto { ...@@ -110,4 +110,7 @@ public class JgEquipTransferDto extends BaseDto {
@ApiModelProperty(value = "设备地址") @ApiModelProperty(value = "设备地址")
private String concatenatedAddress; private String concatenatedAddress;
@ApiModelProperty(value = "流程建议")
private String processAdvice;
} }
...@@ -2,8 +2,10 @@ package com.yeejoin.amos.boot.module.jg.api.dto; ...@@ -2,8 +2,10 @@ package com.yeejoin.amos.boot.module.jg.api.dto;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto; import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.yeejoin.amos.boot.module.jg.api.common.BizCustomDateSerializer;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
...@@ -86,6 +88,7 @@ public class JgInstallationNoticeDto extends BaseDto { ...@@ -86,6 +88,7 @@ public class JgInstallationNoticeDto extends BaseDto {
@ApiModelProperty(value = "安装开始日期") @ApiModelProperty(value = "安装开始日期")
@JsonFormat(pattern = "yyyy-MM-dd") @JsonFormat(pattern = "yyyy-MM-dd")
@JsonSerialize(using = BizCustomDateSerializer.class)
private Date installStartDate; private Date installStartDate;
@ApiModelProperty(value = "安装竣工日期") @ApiModelProperty(value = "安装竣工日期")
...@@ -183,6 +186,7 @@ public class JgInstallationNoticeDto extends BaseDto { ...@@ -183,6 +186,7 @@ public class JgInstallationNoticeDto extends BaseDto {
private String isXixian; private String isXixian;
@JsonFormat(pattern = "yyyy-MM-dd") @JsonFormat(pattern = "yyyy-MM-dd")
@JsonSerialize(using = BizCustomDateSerializer.class)
@ApiModelProperty(value = "告知日期") @ApiModelProperty(value = "告知日期")
private Date noticeDate; private Date noticeDate;
...@@ -240,6 +244,7 @@ public class JgInstallationNoticeDto extends BaseDto { ...@@ -240,6 +244,7 @@ public class JgInstallationNoticeDto extends BaseDto {
private String equAddress; private String equAddress;
@ApiModelProperty(value = "办理日期") @ApiModelProperty(value = "办理日期")
@JsonSerialize(using = BizCustomDateSerializer.class)
private Date handleDate; private Date handleDate;
......
...@@ -203,4 +203,7 @@ public class JgMaintainNoticeDto extends BaseDto { ...@@ -203,4 +203,7 @@ public class JgMaintainNoticeDto extends BaseDto {
@ApiModelProperty(value = "状态") @ApiModelProperty(value = "状态")
private String status; private String status;
@ApiModelProperty(value = "下一执行节点ids")
private String nextExecuteIds;
} }
package com.yeejoin.amos.boot.module.jg.api.dto; package com.yeejoin.amos.boot.module.jg.api.dto;
import com.baomidou.mybatisplus.annotation.TableField;
import io.swagger.annotations.ApiModel; import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto; import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import java.util.Date; import java.util.Date;
/** /**
*
*
* @author system_generator * @author system_generator
* @date 2023-12-20 * @date 2023-12-20
*/ */
@Data @Data
@EqualsAndHashCode(callSuper = true) @EqualsAndHashCode (callSuper = true)
@ApiModel(value="JgRegistrationHistoryDto", description="") @ApiModel (value = "JgRegistrationHistoryDto", description = "")
public class JgRegistrationHistoryDto extends BaseDto { public class JgRegistrationHistoryDto extends BaseDto {
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "创建人ID") @ApiModelProperty (value = "创建人ID")
private String createUserId; private String createUserId;
@ApiModelProperty(value = "创建时间") @ApiModelProperty (value = "创建时间")
private Date createDate; private Date createDate;
@ApiModelProperty(value = "使用登记编号") @ApiModelProperty (value = "使用登记编号")
private String useRegistrationCode; private String useRegistrationCode;
@ApiModelProperty(value = "登记类别(改造登记、移装登记)") @ApiModelProperty (value = "登记类别(改造登记、移装登记)")
private String registrationClass; private String registrationClass;
@ApiModelProperty(value = "变更数据") @ApiModelProperty (value = "变更数据")
private String changeData; private String changeData;
@ApiModelProperty(value = "设备监管码") @ApiModelProperty (value = "设备监管码")
private String supervisoryCode; private String supervisoryCode;
@ApiModelProperty(value = "设备id") @ApiModelProperty (value = "设备id")
private String equId; private String equId;
@ApiModelProperty(value = "数据状态(新数据:new,历史数据:history)") @ApiModelProperty (value = "数据状态(新数据:new,历史数据:history)")
private String status; private String status;
@ApiModelProperty(value = "当前单据Id") @ApiModelProperty (value = "当前单据Id")
private String currentDocumentId; private String currentDocumentId;
@ApiModelProperty(value = "登记类型") @ApiModelProperty (value = "登记类型")
private String registrationType; private String registrationType;
@ApiModelProperty (value = "原有数据")
private String oldData;
} }
...@@ -100,4 +100,10 @@ public class JgScrapCancelDto extends BaseDto { ...@@ -100,4 +100,10 @@ public class JgScrapCancelDto extends BaseDto {
*/ */
private String useUnitName; private String useUnitName;
/**
* 设备ID
*/
private String record;
} }
...@@ -163,4 +163,6 @@ public class JgEquipTransfer extends BaseEntity { ...@@ -163,4 +163,6 @@ public class JgEquipTransfer extends BaseEntity {
@TableField(exist = false) @TableField(exist = false)
private String concatenatedAddress; private String concatenatedAddress;
@TableField(exist = false)
private String processAdvice;
} }
...@@ -2,7 +2,10 @@ package com.yeejoin.amos.boot.module.jg.api.entity; ...@@ -2,7 +2,10 @@ package com.yeejoin.amos.boot.module.jg.api.entity;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity; import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import com.yeejoin.amos.boot.module.jg.api.common.BizCustomDateSerializer;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
...@@ -153,6 +156,8 @@ public class JgInstallationNotice extends BaseEntity { ...@@ -153,6 +156,8 @@ public class JgInstallationNotice extends BaseEntity {
* 安装开始日期 * 安装开始日期
*/ */
@TableField("install_start_date") @TableField("install_start_date")
@JsonFormat(pattern = "yyyy-MM-dd")
@JsonSerialize(using = BizCustomDateSerializer.class)
private Date installStartDate; private Date installStartDate;
/** /**
...@@ -333,6 +338,8 @@ public class JgInstallationNotice extends BaseEntity { ...@@ -333,6 +338,8 @@ public class JgInstallationNotice extends BaseEntity {
* 告知日期 * 告知日期
*/ */
@TableField("notice_date") @TableField("notice_date")
@JsonFormat(pattern = "yyyy-MM-dd")
@JsonSerialize(using = BizCustomDateSerializer.class)
private Date noticeDate; private Date noticeDate;
/** /**
...@@ -384,6 +391,7 @@ public class JgInstallationNotice extends BaseEntity { ...@@ -384,6 +391,7 @@ public class JgInstallationNotice extends BaseEntity {
private String equAddress; private String equAddress;
@TableField("handle_date") @TableField("handle_date")
@JsonSerialize(using = BizCustomDateSerializer.class)
private Date handleDate; private Date handleDate;
} }
package com.yeejoin.amos.boot.module.jg.api.entity; package com.yeejoin.amos.boot.module.jg.api.entity;
import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity; import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
...@@ -25,13 +26,13 @@ public class JgRegistrationHistory extends BaseEntity { ...@@ -25,13 +26,13 @@ public class JgRegistrationHistory extends BaseEntity {
/** /**
* 创建人ID * 创建人ID
*/ */
@TableField("create_user_id") @TableField(value = "create_user_id", fill = FieldFill.INSERT_UPDATE)
private String createUserId; private String createUserId;
/** /**
* 创建时间 * 创建时间
*/ */
@TableField("create_date") @TableField(value = "create_date", fill = FieldFill.INSERT_UPDATE)
private Date createDate; private Date createDate;
/** /**
...@@ -82,4 +83,10 @@ public class JgRegistrationHistory extends BaseEntity { ...@@ -82,4 +83,10 @@ public class JgRegistrationHistory extends BaseEntity {
@TableField("registration_type") @TableField("registration_type")
private String registrationType; private String registrationType;
/**
* 原有数据
*/
@TableField("old_data")
private String oldData;
} }
...@@ -10,8 +10,8 @@ import lombok.Getter; ...@@ -10,8 +10,8 @@ import lombok.Getter;
@AllArgsConstructor @AllArgsConstructor
public enum MaintenceStatusEnum { public enum MaintenceStatusEnum {
SUBMIT("使用单位提交", "submit", "使用单位待提交", "维保单位已驳回", "使用单位撤回"), SUBMIT("使用单位提交", "submit", "使用单位待提交", "维保单位已驳回", "使用单位撤回"),
RECEIVE("维保单位审核确认", "receive", "维保单位待受理", "监管单位已驳回", "维保单位撤回"), RECEIVE("维保单位审核确认", "receive", "维保单位待受理", "监管单位已驳回", "维保单位撤回"),
PRELIMINARY("监管单位审核", "preliminary", "监管单位待受理", "", ""); PRELIMINARY("监管单位审核", "preliminary", "监管单位待受理", "", "");
......
...@@ -3,6 +3,11 @@ package com.yeejoin.amos.boot.module.jg.api.enums; ...@@ -3,6 +3,11 @@ package com.yeejoin.amos.boot.module.jg.api.enums;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Getter; import lombok.Getter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* 使用登记状态西悉尼 * 使用登记状态西悉尼
*/ */
...@@ -13,7 +18,7 @@ public enum WorkFlowStatusEnum { ...@@ -13,7 +18,7 @@ public enum WorkFlowStatusEnum {
/** /**
* 使用登记流程 * 使用登记流程
*/ */
USE_SUBMIT("使用单位提交", "useSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"), USE_SUBMIT("使用单位提交", "useSubmit", "使用单位待提交", "一级受理已驳回", "使用单位已撤回"),
USE_RECEIVE("一级受理", "useReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"), USE_RECEIVE("一级受理", "useReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
USE_PRELIMINARY("二级受理", "usePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"), USE_PRELIMINARY("二级受理", "usePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
USE_REEXAMINE("三级受理", "useReexamine", "三级待受理","",""), USE_REEXAMINE("三级受理", "useReexamine", "三级待受理","",""),
...@@ -22,15 +27,15 @@ public enum WorkFlowStatusEnum { ...@@ -22,15 +27,15 @@ public enum WorkFlowStatusEnum {
/** /**
* 维保流程 * 维保流程
*/ */
MAIN_SUBMIT("使用单位提交", "mainSubmit", "使用单位待提交", "维保单位已驳回", "使用单位撤回"), MAIN_SUBMIT("使用单位提交", "mainSubmit", "使用单位待提交", "维保单位已驳回", "使用单位撤回"),
MAIN_RECEIVE("维保单位审核确认", "mainReceive", "维保单位待受理", "监管单位已驳回", "维保单位撤回"), MAIN_RECEIVE("维保单位审核确认", "mainReceive", "维保单位待受理", "监管单位已驳回", "维保单位撤回"),
MAIN_PRELIMINARY("监管单位审核", "mainPreliminary", "监管单位待受理", "", ""), MAIN_PRELIMINARY("监管单位审核", "mainPreliminary", "监管单位待受理", "", ""),
/** /**
* 电梯注销 * 电梯注销
*/ */
CANCEL_SUBMIT("使用单位提交", "cancelSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"), CANCEL_SUBMIT("使用单位提交", "cancelSubmit", "使用单位待提交", "一级受理已驳回", "使用单位已撤回"),
CANCEL_RECEIVE("一级受理", "cancelReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"), CANCEL_RECEIVE("一级受理", "cancelReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
CANCEL_PRELIMINARY("二级受理", "cancelPreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"), CANCEL_PRELIMINARY("二级受理", "cancelPreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
CANCEL_REEXAMINE("三级受理", "cancelReexamine", "三级待受理", "", ""), CANCEL_REEXAMINE("三级受理", "cancelReexamine", "三级待受理", "", ""),
...@@ -38,10 +43,18 @@ public enum WorkFlowStatusEnum { ...@@ -38,10 +43,18 @@ public enum WorkFlowStatusEnum {
/** /**
* 改造登记流程 * 改造登记流程
*/ */
CHANGE_SUBMIT("使用单位提交", "changeSubmit", "使用单位待提交", "一级受理已驳回", "使用单位提交已撤回"), CHANGE_SUBMIT("使用单位提交", "changeSubmit", "使用单位待提交", "一级受理已驳回", "使用单位已撤回"),
CHANGE_RECEIVE("一级受理", "changeReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"), CHANGE_RECEIVE("一级受理", "changeReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
CHANGE_PRELIMINARY("二级受理", "changePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"), CHANGE_PRELIMINARY("二级受理", "changePreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
CHANGE_REEXAMINE("三级受理", "changeReexamine", "三级待受理", "", ""); CHANGE_REEXAMINE("三级受理", "changeReexamine", "三级待受理", "", ""),
/**
* 移装变更登记流程
*/
TRANSFER_SUBMIT("使用单位提交", "transferSubmit", "使用单位待提交", "一级受理已驳回", "使用单位已撤回"),
TRANSFER_RECEIVE("一级受理", "transferReceive", "一级待受理", "二级受理已驳回", "一级受理已撤回"),
TRANSFER_PRELIMINARY("二级受理", "transferPreliminary", "二级待受理", "三级受理已驳回", "二级受理已撤回"),
TRANSFER_REEXAMINE("三级受理", "transferReexamine", "三级待受理","","");
private final String name; private final String name;
...@@ -64,4 +77,29 @@ public enum WorkFlowStatusEnum { ...@@ -64,4 +77,29 @@ public enum WorkFlowStatusEnum {
} }
return null; return null;
} }
public static List<Map<String, String>> getInfoList(String code) {
List<Map<String, String>> resultList = new ArrayList<>();
for (WorkFlowStatusEnum constants : values()) {
if (constants.getCode().startsWith(code)) {
HashMap<String, String> hashMap = new HashMap<>();
hashMap.put("name", constants.getPass());
hashMap.put("value", constants.getPass());
resultList.add(hashMap);
HashMap<String, String> hashMap1 = new HashMap<>();
hashMap1.put("name", constants.getReject());
hashMap1.put("value", constants.getReject());
resultList.add(hashMap1);
HashMap<String, String> hashMap2 = new HashMap<>();
hashMap2.put("name", constants.getRollBack());
hashMap2.put("value", constants.getRollBack());
resultList.add(hashMap2);
}
}
HashMap<String, String> hashMap = new HashMap<>();
hashMap.put("name", "已完成");
hashMap.put("value", "已完成");
resultList.add(hashMap);
return resultList;
}
} }
...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jg.api.mapper; ...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.jg.api.mapper;
import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationReformEq; import com.yeejoin.amos.boot.module.jg.api.entity.JgChangeRegistrationReformEq;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update; import org.apache.ibatis.annotations.Update;
/** /**
...@@ -14,4 +15,7 @@ import org.apache.ibatis.annotations.Update; ...@@ -14,4 +15,7 @@ import org.apache.ibatis.annotations.Update;
public interface JgChangeRegistrationReformEqMapper extends BaseMapper<JgChangeRegistrationReformEq> { public interface JgChangeRegistrationReformEqMapper extends BaseMapper<JgChangeRegistrationReformEq> {
@Update("update tzs_jg_change_registration_reform_eq set is_invalid = 1 where equ_id = #{equipId} and equip_transfer_id != #{currentDocumentId} ") @Update("update tzs_jg_change_registration_reform_eq set is_invalid = 1 where equ_id = #{equipId} and equip_transfer_id != #{currentDocumentId} ")
void updateEquipIsVaildByEquipIdAndCurrentDocumentId(@Param("equipId") String equipId, @Param("currentDocumentId") String currentDocumentId); void updateEquipIsVaildByEquipIdAndCurrentDocumentId(@Param("equipId") String equipId, @Param("currentDocumentId") String currentDocumentId);
@Select("select equ_id from tzs_jg_change_registration_reform_eq where equip_transfer_id = #{currentDocumentId} ")
String selectEquipId(@Param("currentDocumentId") String currentDocumentId);
} }
...@@ -27,7 +27,7 @@ ...@@ -27,7 +27,7 @@
</select> </select>
<select id="getUserInfo" resultType="java.util.Map"> <select id="getUserInfo" resultType="java.util.Map">
SELECT SELECT
* phone
FROM FROM
"tzs_user_info" "tzs_user_info"
WHERE WHERE
......
...@@ -10,16 +10,18 @@ ...@@ -10,16 +10,18 @@
<select id="getListPage" resultType="java.util.Map"> <select id="getListPage" resultType="java.util.Map">
select ur.sequence_nbr as sequenceNbr, select ur.sequence_nbr as sequenceNbr,
ur.audit_status as auditStatus, ur.audit_status as auditStatus,
ur.reg_date as regDate,
ur.use_unit_name as useUnitName, ur.use_unit_name as useUnitName,
ur.use_registration_code as useRegistrationCode,
ur.status, ur.status,
ur.receive_org_name as receiveOrgName, ur.receive_org_name as receiveOrgName,
DATE_FORMAT(ur.reg_date,'%Y-%m-%d') as regDate,
DATE_FORMAT(ur.rec_date,'%Y-%m-%d') as recDate,
(SELECT name from tz_equipment_category where code = jri.EQU_CATEGORY) as equCategory, (SELECT name from tz_equipment_category where code = jri.EQU_CATEGORY) as equCategory,
jri.PRODUCT_NAME as productName, jri.PRODUCT_NAME as productName,
jri.EQU_CODE as equCode, jri.EQU_CODE as equCode,
use.USE_INNER_CODE as innerCode, use.USE_INNER_CODE as innerCode,
concat(use.PROVINCE_NAME,'-',use.CITY_NAME,'-',use.COUNTY_NAME) as place, concat(use.PROVINCE_NAME,'-',use.CITY_NAME,'-',use.COUNTY_NAME) as place,
ur.instance_id as instanceId, ifnull(ur.instance_id, '') as instanceId,
re.equ_id as equipId, re.equ_id as equipId,
ur.apply_no as applyNo, ur.apply_no as applyNo,
ifnull(ur.next_executor_ids,'') as nextExecutorIds, ifnull(ur.next_executor_ids,'') as nextExecutorIds,
...@@ -49,7 +51,7 @@ ...@@ -49,7 +51,7 @@
</foreach> </foreach>
</if> </if>
<if test="dto.dataType == 'jg' "> <if test="dto.dataType == 'jg' ">
and ur.receive_company_code = #{dto.unitCode} and ur.receive_org_code = #{dto.unitCode}
</if> </if>
<if test="dto.dataType == 'company' "> <if test="dto.dataType == 'company' ">
and ur.use_unit_credit_code = #{dto.unitCode} and ur.use_unit_credit_code = #{dto.unitCode}
......
...@@ -86,6 +86,7 @@ ...@@ -86,6 +86,7 @@
</if> </if>
<if test="type == 'installUnit'"> <if test="type == 'installUnit'">
AND jet.install_unit_credit_code = #{companyCode} AND jet.install_unit_credit_code = #{companyCode}
AND jet.instance_id is not null
</if> </if>
</where> </where>
ORDER BY jet.apply_date DESC ORDER BY jet.apply_date DESC
......
...@@ -4,30 +4,30 @@ ...@@ -4,30 +4,30 @@
<select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNotice"> <select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgInstallationNotice">
select select
isn.sequence_nbr AS sequenceNbr, isn.sequence_nbr AS sequenceNbr,
isn.apply_no AS applyNo, isn.apply_no AS applyNo,
isn.supervisory_code AS supervisoryCode, isn.supervisory_code AS supervisoryCode,
isn.notice_date AS noticeDate, isn.notice_date AS noticeDate,
isn.use_unit_name AS useUnitName, isn.use_unit_name AS useUnitName,
isn.receive_org_name AS receiveOrgName, isn.receive_org_name AS receiveOrgName,
isn.region_no AS regionNo, isn.region_no AS regionNo,
isn.install_start_date AS installStartDate, isn.install_start_date AS installStartDate,
isn.address AS address, isn.address AS address,
isn.notice_status AS noticeStatus, isn.notice_status AS noticeStatus,
isn.install_unit_name AS installUnitName, isn.install_unit_name AS installUnitName,
isn.province_name AS provinceName, isn.province_name AS provinceName,
isn.city_name AS cityName, isn.city_name AS cityName,
isn.county_name AS countyName, isn.county_name AS countyName,
isn.instance_id AS instanceId, isn.instance_id AS instanceId,
isn.promoter, isn.promoter,
isn.next_execute_ids AS nextExecuteIds, isn.next_execute_ids AS nextExecuteIds,
isn.instance_status AS instanceStatus, isn.instance_status AS instanceStatus,
isn.equ_address AS equAddress, isn.equ_address AS equAddress,
isn.handle_date AS handleDate, isn.handle_date AS handleDate,
isn.equ_list AS equList, isn.equ_list AS equList,
isn.notice_report_url AS noticeReportUrl isn.notice_report_url AS noticeReportUrl
FROM FROM
tzs_jg_installation_notice isn tzs_jg_installation_notice isn
<where> <where>
isn.is_delete = false isn.is_delete = false
<if test="param != null "> <if test="param != null ">
...@@ -118,6 +118,6 @@ ...@@ -118,6 +118,6 @@
LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
WHERE WHERE
isn.sequence_nbr = #{sequenceNbr} isn.sequence_nbr = #{sequenceNbr}
LIMIT 1 LIMIT 1
</select> </select>
</mapper> </mapper>
...@@ -2,39 +2,13 @@ ...@@ -2,39 +2,13 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.yeejoin.amos.boot.module.jg.api.mapper.JgMaintainNoticeMapper"> <mapper namespace="com.yeejoin.amos.boot.module.jg.api.mapper.JgMaintainNoticeMapper">
<update id="updatePromoter"> <update id="updatePromoter">
UPDATE tzs_jg_maintain_notice set promoter = null UPDATE tzs_jg_maintain_notice
set promoter = null
where sequence_nbr = #{id} where sequence_nbr = #{id}
</update> </update>
<select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNotice"> <select id="queryForPage" resultType="com.yeejoin.amos.boot.module.jg.api.entity.JgMaintainNotice">
select select isn.* FROM tzs_jg_maintain_notice isn
isn.sequence_nbr AS sequenceNbr,
isn.apply_no AS applyNo,
isn.notice_date AS noticeDate,
isn.use_unit_name AS useUnitName,
isn.receive_org_name AS receiveOrgName,
isn.address AS address,
isn.notice_status AS noticeStatus,
isn.install_unit_name AS installUnitName,
isn.province,
isn.city,
isn.county,
isn.factory_use_site_street,
isn.street_name,
isn.street,
isn.maintain_type,
isn.plan_date,
isn.notice_report_url,
isn.province_name AS provinceName,
isn.city_name AS cityName,
isn.county_name AS countyName,
isn.promoter,
isn.equ_category AS equCategory,
isn.equ_list_code AS equListCode,
isn.instance_id AS instanceId,
isn.accept_date AS acceptDate
FROM
tzs_jg_maintain_notice isn
<where> <where>
isn.is_delete = 0 isn.is_delete = 0
<if test="param != null "> <if test="param != null ">
...@@ -70,80 +44,75 @@ ...@@ -70,80 +44,75 @@
</select> </select>
<select id="queryEquipInformation" resultType="java.util.Map"> <select id="queryEquipInformation" resultType="java.util.Map">
select select isn.sequence_nbr AS sequenceNbr,
isn.sequence_nbr AS sequenceNbr, isn.apply_no AS applyNo,
isn.apply_no AS applyNo, isn.notice_date AS noticeDate,
isn.notice_date AS noticeDate, isn.use_unit_name AS useUnitName,
isn.use_unit_name AS useUnitName, isn.receive_org_name AS receiveOrgName,
isn.receive_org_name AS receiveOrgName, isn.address AS address,
isn.address AS address, isn.notice_status AS noticeStatus,
isn.notice_status AS noticeStatus, isn.install_unit_name AS installUnitName,
isn.install_unit_name AS installUnitName, isn.province,
isn.province, isn.city,
isn.city, isn.county,
isn.county, isn.factory_use_site_street AS factoryUseSiteStreet,
isn.factory_use_site_street AS factoryUseSiteStreet, isn.street_name AS streetName,
isn.street_name AS streetName, isn.street,
isn.street, isn.maintain_type AS maintainType,
isn.maintain_type AS maintainType, isn.notice_report_url AS noticeReportUrl,
isn.notice_report_url AS noticeReportUrl, isn.province_name AS provinceName,
isn.province_name AS provinceName, isn.city_name AS cityName,
isn.city_name AS cityName, isn.county_name AS countyName,
isn.county_name AS countyName, isn.instance_id AS instanceId,
isn.instance_id AS instanceId, isn.promoter,
isn.promoter, isn.equ_list_code AS equListCode,
isn.equ_category AS equCategory, isn.plan_date AS installStartDate,
isn.equ_list_code AS equListCode, isn.construction_manager AS installLeaderName,
isn.plan_date AS installStartDate, isn.construction_manager_phone AS installLeaderPhone,
isn.construction_manager AS installLeaderName, ri.equ_list AS equList,
isn.construction_manager_phone AS installLeaderPhone, ri.equ_category AS equCategory,
ri.equ_list AS equList, ri.EQU_DEFINE AS equDefine,
ri.equ_category AS equCategory, ri.product_name AS productName,
ri.EQU_DEFINE AS equDefine, ri.brand_name AS brandName,
ri.product_name AS productName, ri.equ_type AS equType,
ri.brand_name AS brandName, ri.equ_code AS equRegisterCode,
ri.equ_type AS equType, ri.equ_price AS equPrice,
ri.equ_code AS equRegisterCode, ri.product_photo AS productPhoto,
ri.equ_price AS equPrice, di.design_unit_credit_code AS designUnitCreditCode,
ri.product_photo AS productPhoto, di.design_unit_name AS designUnitName,
di.design_unit_credit_code AS designUnitCreditCode, di.design_license_num AS designLicenseNum,
di.design_unit_name AS designUnitName, di.design_use_date AS designUseDate,
di.design_license_num AS designLicenseNum, di.design_date AS designDate,
di.design_use_date AS designUseDate, di.drawing_do AS drawingDo,
di.design_date AS designDate, di.appraisal_unit AS appraisalUnit,
di.drawing_do AS drawingDo, di.appraisal_date AS appraisalDate,
di.appraisal_unit AS appraisalUnit, di.design_doc AS designDoc,
di.appraisal_date AS appraisalDate, di.design_standard AS designStandard,
di.design_doc AS designDoc, fi.produce_unit_credit_code AS produceUnitCreditCode,
di.design_standard AS designStandard, fi.produce_unit_name AS produceUnitName,
fi.produce_unit_credit_code AS produceUnitCreditCode, fi.produce_license_num AS produceLicenseNum,
fi.produce_unit_name AS produceUnitName, fi.FACTORY_NUM AS produceCode,
fi.produce_license_num AS produceLicenseNum, fi.FACTORY_NUM AS factoryNum,
fi.FACTORY_NUM AS produceCode, fi.produce_date AS produceDate,
fi.FACTORY_NUM AS factoryNum, fi.imported AS imported,
fi.produce_date AS produceDate, fi.produce_country AS produceCountry,
fi.imported AS imported, fi.factory_standard AS factoryStandard,
fi.produce_country AS produceCountry, fi.product_quality_yield_prove AS productQualityYieldProve,
fi.factory_standard AS factoryStandard, fi.ins_use_maintain_explain AS insUseMaintainExplain,
fi.product_quality_yield_prove AS productQualityYieldProve, ui.safety_manager AS safetyManager,
fi.ins_use_maintain_explain AS insUseMaintainExplain, ei.legal_person AS safetyManager,
ui.safety_manager AS safetyManager, ei.legal_phone AS safetyManagerPhone,
ei.legal_person AS safetyManager, ui.CITY_NAME AS useUnitCityName,
ei.legal_phone AS safetyManagerPhone, ui.COUNTY_NAME AS useUnitCountyName,
ui.CITY_NAME AS useUnitCityName, ei.ADDRESS AS useUnitAddress
ui.COUNTY_NAME AS useUnitCountyName, FROM tzs_jg_maintain_notice isn
ei.ADDRESS AS useUnitAddress LEFT JOIN tzs_jg_maintain_notice_eq re ON re.equip_transfer_id = isn.sequence_nbr
FROM LEFT JOIN idx_biz_jg_register_info ri ON ri.record = re.equ_id
tzs_jg_maintain_notice isn LEFT JOIN idx_biz_jg_design_info di ON di.record = re.equ_id
LEFT JOIN tzs_jg_maintain_notice_eq re ON re.equip_transfer_id = isn.sequence_nbr LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = re.equ_id
LEFT JOIN idx_biz_jg_register_info ri ON ri.record = re.equ_id LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = re.equ_id
LEFT JOIN idx_biz_jg_design_info di ON di.record = re.equ_id LEFT JOIN idx_biz_jg_use_info ui ON ui.record = re.equ_id
LEFT JOIN idx_biz_jg_factory_info fi ON fi.record = re.equ_id LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
LEFT JOIN idx_biz_jg_inspection_detection_info idi ON idi.record = re.equ_id WHERE isn.sequence_nbr = #{sequenceNbr} LIMIT 1
LEFT JOIN idx_biz_jg_use_info ui ON ui.record = re.equ_id
LEFT JOIN tz_base_enterprise_info ei ON ei.use_code = isn.use_unit_credit_code
WHERE
isn.sequence_nbr = #{sequenceNbr}
LIMIT 1
</select> </select>
</mapper> </mapper>
...@@ -128,7 +128,9 @@ ...@@ -128,7 +128,9 @@
rec_date, rec_date,
create_user_id, create_user_id,
create_date, create_date,
instance_id instance_id,
promoter,
next_execute_ids
FROM FROM
amos_tzs_biz.tzs_jg_maintenance_contract amos_tzs_biz.tzs_jg_maintenance_contract
<where> <where>
...@@ -155,11 +157,12 @@ ...@@ -155,11 +157,12 @@
and receive_org_code = #{contractDto.receiveOrgCode} and receive_org_code = #{contractDto.receiveOrgCode}
</if> </if>
<if test="contractDto.roleIds != null"> <if test="contractDto.roleIds != null">
<foreach collection='roleIds' item='role' open='and (' close=')' separator='or'> <foreach collection='contractDto.roleIds' item='role' open='and (' close=')' separator='or'>
instance_status like concat('%',#{role},'%') instance_status like concat('%',#{role},'%')
</foreach> </foreach>
</if> </if>
</where> </where>
order by apply_no desc
</select> </select>
<select id="queryBySequenceNbr" <select id="queryBySequenceNbr"
resultType="com.yeejoin.amos.boot.module.jg.api.dto.JgMaintenanceContractDto"> resultType="com.yeejoin.amos.boot.module.jg.api.dto.JgMaintenanceContractDto">
......
...@@ -12,8 +12,8 @@ ...@@ -12,8 +12,8 @@
select ur.sequence_nbr as sequenceNbr, select ur.sequence_nbr as sequenceNbr,
ur.instance_id as instanceId, ur.instance_id as instanceId,
ur.audit_status as auditStatus, ur.audit_status as auditStatus,
ur.rec_date as recDate, DATE_FORMAT(ur.rec_date,'%Y-%m-%d') as recDate,
ur.create_date as createDate, DATE_FORMAT(ur.create_date,'%Y-%m-%d') as createDate,
ur.receive_org_code as receiveOrgCode, ur.receive_org_code as receiveOrgCode,
ur.receive_org_name as receiveOrgName, ur.receive_org_name as receiveOrgName,
ur.receive_company_code as receiveCompanyCode, ur.receive_company_code as receiveCompanyCode,
...@@ -25,7 +25,7 @@ ...@@ -25,7 +25,7 @@
ur.instance_status as instanceStatus, ur.instance_status as instanceStatus,
ur.promoter, ur.promoter,
ifnull(ur.next_execute_ids,'') as nextExecuteIds, ifnull(ur.next_execute_ids,'') as nextExecuteIds,
audit_pass_date as auditPassDate, DATE_FORMAT(ur.audit_pass_date,'%Y-%m-%d') as auditPassDate,
use.USE_UNIT_CREDIT_CODE as useUnitCreditCode, use.USE_UNIT_CREDIT_CODE as useUnitCreditCode,
ur.use_unit_name as useUnitName, ur.use_unit_name as useUnitName,
ur.use_unit_code as useUnitCode, ur.use_unit_code as useUnitCode,
...@@ -35,7 +35,7 @@ ...@@ -35,7 +35,7 @@
jri.EQU_CODE as equCode, jri.EQU_CODE as equCode,
use.USE_INNER_CODE as innerCode, use.USE_INNER_CODE as innerCode,
use.ADDRESS as address, use.ADDRESS as address,
concat(use.PROVINCE_NAME,'-',use.CITY_NAME,'-',use.COUNTY_NAME) as place, CONCAT(use.PROVINCE_NAME,'', use.CITY_NAME, '', use.COUNTY_NAME, '', use.street_name, use.ADDRESS, '') AS place,
re.equ_id as equipId re.equ_id as equipId
from tzs_jg_scrap_cancel ur from tzs_jg_scrap_cancel ur
LEFT JOIN tzs_jg_scrap_cancel_eq re on ur.sequence_nbr = re.equip_transfer_id LEFT JOIN tzs_jg_scrap_cancel_eq re on ur.sequence_nbr = re.equip_transfer_id
...@@ -49,13 +49,13 @@ ...@@ -49,13 +49,13 @@
<if test="dto.auditStatus != null and dto.auditStatus != ''"> <if test="dto.auditStatus != null and dto.auditStatus != ''">
and ur.audit_status = #{dto.auditStatus} and ur.audit_status = #{dto.auditStatus}
</if> </if>
<!-- <if test="dto.equCode != null and dto.equCode != ''">--> <if test="dto.applyNo != null and dto.applyNo != ''">
<!-- and jri.EQU_CODE like concat('%',#{dto.equCode},'%')--> and ur.apply_no like concat('%',#{dto.applyNo},'%')
<!-- </if>--> </if>
<!-- <if test="dto.useUnitName != null and dto.useUnitName != ''">--> <if test="dto.cancelType != null and dto.cancelType != ''">
<!-- and use.USE_UNIT_NAME like concat('%',#{dto.useUnitName},'%')--> and ur.cancel_type = #{dto.cancelType}
<!-- </if>--> </if>
<!-- -->
<if test="roleIds != null and dto.type == 'supervision'"> <if test="roleIds != null and dto.type == 'supervision'">
<foreach collection='roleIds' item='role' open='and (' close=')' separator='or'> <foreach collection='roleIds' item='role' open='and (' close=')' separator='or'>
ur.instance_status like concat('%',#{role},'%') ur.instance_status like concat('%',#{role},'%')
......
...@@ -10,7 +10,7 @@ ...@@ -10,7 +10,7 @@
<select id="getListPage" resultType="java.util.Map"> <select id="getListPage" resultType="java.util.Map">
select ur.sequence_nbr as sequenceNbr, select ur.sequence_nbr as sequenceNbr,
ur.audit_status as auditStatus, ur.audit_status as auditStatus,
ur.reg_date as regDate, date_format(reg_date,'%Y-%m-%d') as regDate,
ur.use_unit_name as useUnitName, ur.use_unit_name as useUnitName,
ur.status, ur.status,
ur.receive_org_name as receiveOrgName, ur.receive_org_name as receiveOrgName,
...@@ -23,7 +23,8 @@ ...@@ -23,7 +23,8 @@
re.equ_id as equipId, re.equ_id as equipId,
ur.apply_no as applyNo, ur.apply_no as applyNo,
ur.next_execute_ids as nextExecuteIds, ur.next_execute_ids as nextExecuteIds,
ur.promoter ur.promoter,
ur.supervisory_code as supervisoryCode
from tzs_jg_use_registration ur from tzs_jg_use_registration ur
LEFT JOIN tzs_jg_use_registration_eq re on ur.sequence_nbr = re.equip_transfer_id LEFT JOIN tzs_jg_use_registration_eq re on ur.sequence_nbr = re.equip_transfer_id
LEFT JOIN idx_biz_jg_register_info jri on re.equ_id = jri.RECORD LEFT JOIN idx_biz_jg_register_info jri on re.equ_id = jri.RECORD
...@@ -58,7 +59,9 @@ ...@@ -58,7 +59,9 @@
order by ur.rec_date desc order by ur.rec_date desc
</select> </select>
<select id="getDetail" resultType="java.util.Map"> <select id="getDetail" resultType="java.util.Map">
SELECT jri.EQU_CODE as equCode, SELECT
jri.RECORD as equipId,
jri.EQU_CODE as equCode,
-- (SELECT name from tz_equipment_category where code = jri.EQU_CATEGORY) as equCategory, -- (SELECT name from tz_equipment_category where code = jri.EQU_CATEGORY) as equCategory,
-- (SELECT name from tz_equipment_category where code = jri.EQU_LIST) as equList, -- (SELECT name from tz_equipment_category where code = jri.EQU_LIST) as equList,
-- (SELECT name from tz_equipment_category where code = jri.EQU_DEFINE) as equDefine, -- (SELECT name from tz_equipment_category where code = jri.EQU_DEFINE) as equDefine,
...@@ -87,12 +90,13 @@ ...@@ -87,12 +90,13 @@
</select> </select>
<select id="getInspectDetail" resultType="java.util.Map"> <select id="getInspectDetail" resultType="java.util.Map">
SELECT INSPECT_TYPE as inspectType, SELECT INSPECT_TYPE as inspectType,
INSPECT_STAFF as inspctStaff, INSPECT_STAFF as inspectStaff,
INSPECT_CONCLUSION as inspectConclusion, INSPECT_CONCLUSION as inspectConclusion,
INSPECT_ORG_NAME as inspectOrgName, INSPECT_ORG_NAME as inspectOrgName,
INSPECT_DATE as inspectDate, INSPECT_DATE as inspectDate,
NEXT_INSPECT_DATE as nextInspectDate, NEXT_INSPECT_DATE as nextInspectDate,
INSPECT_REPORT as inspectReport INSPECT_REPORT as inspectReport,
INSPECT_ORG_CODE as inspectOrgCode
from idx_biz_jg_inspection_detection_info from idx_biz_jg_inspection_detection_info
where RECORD = #{id} where RECORD = #{id}
ORDER BY INSPECT_DATE desc LIMIT 1 ORDER BY INSPECT_DATE desc LIMIT 1
......
...@@ -7,7 +7,9 @@ import com.yeejoin.amos.boot.module.ymt.api.entity.EquipmentCategory; ...@@ -7,7 +7,9 @@ import com.yeejoin.amos.boot.module.ymt.api.entity.EquipmentCategory;
import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum; import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import javafx.scene.chart.ValueAxis;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
...@@ -85,8 +87,9 @@ public class CommonController extends BaseController { ...@@ -85,8 +87,9 @@ public class CommonController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getSecurityAdmin") @GetMapping(value = "/getSecurityAdmin")
@ApiOperation(httpMethod = "GET", value = "查找当前公司下所属的安全管理员", notes = "查找当前公司下所属的安全管理员") @ApiOperation(httpMethod = "GET", value = "查找当前公司下所属的安全管理员", notes = "查找当前公司下所属的安全管理员")
public ResponseModel<List<Map<String, Object>>> getSecurityAdmin(@RequestParam(value = "type") String type) { public ResponseModel<List<Map<String, Object>>> getSecurityAdmin(@RequestParam(value = "type") String type,
return ResponseHelper.buildResponse(commonService.getSecurityAdmin(type)); @RequestParam(value = "useUnitCode",required = false)String useUnitCode) {
return ResponseHelper.buildResponse(commonService.getSecurityAdmin(type,useUnitCode));
} }
...@@ -96,8 +99,8 @@ public class CommonController extends BaseController { ...@@ -96,8 +99,8 @@ public class CommonController extends BaseController {
* @return * @return
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUserInfo") @GetMapping(value = "/getUserPhone")
@ApiOperation(httpMethod = "GET", value = "查询安全管理员的基本信息", notes = "查询安全管理员的基本信息") @ApiOperation(httpMethod = "GET", value = "查询用户对应联系方式", notes = "查询用户对应联系方式")
public ResponseModel<Map<String,Object>> getUserInfo(@RequestParam(value = "sequenceNbr") String sequenceNbr) { public ResponseModel<Map<String,Object>> getUserInfo(@RequestParam(value = "sequenceNbr") String sequenceNbr) {
return ResponseHelper.buildResponse(commonService.getUserInfo(sequenceNbr)); return ResponseHelper.buildResponse(commonService.getUserInfo(sequenceNbr));
} }
...@@ -143,7 +146,7 @@ public class CommonController extends BaseController { ...@@ -143,7 +146,7 @@ public class CommonController extends BaseController {
} }
private Map<String, Object> mapPointTypeToMap(FlowStatusEnum e) { private Map<String, Object> mapPointTypeToMap(FlowStatusEnum e) {
if (FlowStatusEnum.TO_SUBMITTED.getCode() == e.getCode()) { if (FlowStatusEnum.TO_SUBMITTED.getCode() == e.getCode() || FlowStatusEnum.TO_BE_DISCARD.getCode() == e.getCode()) {
return null; return null;
} }
Map<String, Object> record = new HashMap<>(); Map<String, Object> record = new HashMap<>();
......
...@@ -114,7 +114,7 @@ public class JgChangeRegistrationReformController extends BaseController { ...@@ -114,7 +114,7 @@ public class JgChangeRegistrationReformController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "获取详情", notes = "获取详情") @ApiOperation(httpMethod = "GET", value = "获取详情", notes = "获取详情")
@GetMapping(value = "/getDetail") @GetMapping(value = "/getDetail")
public ResponseModel<Map<String, Object>> getDetail(@RequestParam("currentDocumentId") String currentDocumentId,@RequestParam("equipId") String equipId) { public ResponseModel<Map<String, Object>> getDetail(@RequestParam("currentDocumentId") String currentDocumentId,@RequestParam(value = "equipId",required = false) String equipId) {
return ResponseHelper.buildResponse(jgChangeRegistrationReformServiceImpl.getDetail(currentDocumentId,equipId)); return ResponseHelper.buildResponse(jgChangeRegistrationReformServiceImpl.getDetail(currentDocumentId,equipId));
} }
......
...@@ -39,7 +39,14 @@ public class JgEquipTransferByWorkFlowController extends BaseController { ...@@ -39,7 +39,14 @@ public class JgEquipTransferByWorkFlowController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/accept") @PostMapping(value = "/accept")
@ApiOperation(httpMethod = "POST", value = "设备移交受理", notes = "设备移交受理") @ApiOperation(httpMethod = "POST", value = "设备移交受理", notes = "设备移交受理")
public ResponseModel<JgEquipTransferDto> accept(@RequestBody JgEquipTransferDto jgEquipTransferDto, String op) { public ResponseModel<JgEquipTransferDto> accept(@RequestBody Map<String, Object> model, String op) {
LinkedHashMap equipTransferInfo = (LinkedHashMap)model.get("model");
String opinion = (String)model.get("opinion");
if (Objects.isNull(equipTransferInfo)) {
throw new IllegalArgumentException("参数equipTransferInfo不能为空");
}
JgEquipTransferDto jgEquipTransferDto = JSON.parseObject(JSON.toJSONString(equipTransferInfo), JgEquipTransferDto.class);
jgEquipTransferDto.setProcessAdvice(opinion);
jgEquipTransferServiceImpl.accept(jgEquipTransferDto,op); jgEquipTransferServiceImpl.accept(jgEquipTransferDto,op);
return ResponseHelper.buildResponse(null); return ResponseHelper.buildResponse(null);
} }
......
...@@ -208,12 +208,13 @@ public class JgMaintenanceContractController extends BaseController { ...@@ -208,12 +208,13 @@ public class JgMaintenanceContractController extends BaseController {
public ResponseModel<Page<JgMaintenanceContractVo>> queryForPage(@RequestParam(value = "current") int current, public ResponseModel<Page<JgMaintenanceContractVo>> queryForPage(@RequestParam(value = "current") int current,
@RequestParam(value = "size") int size, @RequestParam(value = "size") int size,
@RequestParam(value = "phase") int phase, @RequestParam(value = "phase") int phase,
Map<String,Object> map,
JgMaintenanceContractDto maintenanceContractDto) { JgMaintenanceContractDto maintenanceContractDto) {
Page<JgMaintenanceContract> page = new Page<>(); Page<JgMaintenanceContract> page = new Page<>();
page.setCurrent(current); page.setCurrent(current);
page.setSize(size); page.setSize(size);
ReginParams reginParams = getSelectedOrgInfo(); ReginParams reginParams = getSelectedOrgInfo();
Page<JgMaintenanceContractVo> contractDtoPage = jgMaintenanceContractServiceImpl.queryForPage(page, phase, maintenanceContractDto, reginParams); Page<JgMaintenanceContractVo> contractDtoPage = jgMaintenanceContractServiceImpl.queryForPage(page, phase, map, reginParams);
return ResponseHelper.buildResponse(contractDtoPage); return ResponseHelper.buildResponse(contractDtoPage);
} }
......
...@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONObject; ...@@ -6,6 +6,7 @@ import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jg.api.dto.JgScrapCancelDto; import com.yeejoin.amos.boot.module.jg.api.dto.JgScrapCancelDto;
import com.yeejoin.amos.boot.module.jg.api.enums.WorkFlowStatusEnum;
import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgScrapCancelServiceImpl; import com.yeejoin.amos.boot.module.jg.biz.service.impl.JgScrapCancelServiceImpl;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
...@@ -96,7 +97,7 @@ public class JgScrapCancelController extends BaseController { ...@@ -96,7 +97,7 @@ public class JgScrapCancelController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "POST", value = "列表全部数据查询", notes = "列表全部数据查询") @ApiOperation(httpMethod = "POST", value = "列表全部数据查询", notes = "列表全部数据查询")
@PostMapping(value = "/getList") @PostMapping(value = "/getList")
public ResponseModel<Page<Map<String, Object>>> getList(JgScrapCancelDto dto, public ResponseModel<Page<Map<String, Object>>> getList(@RequestBody JgScrapCancelDto dto,
@RequestParam(value = "current") int current, @RequestParam(value = "current") int current,
@RequestParam(value = "size") int size) { @RequestParam(value = "size") int size) {
Page<Map<String, Object>> page = new Page<>(current, size); Page<Map<String, Object>> page = new Page<>(current, size);
...@@ -131,4 +132,12 @@ public class JgScrapCancelController extends BaseController { ...@@ -131,4 +132,12 @@ public class JgScrapCancelController extends BaseController {
} }
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表筛选办理状态下拉", notes = "列表筛选办理状态下拉")
@GetMapping(value = "/getAuditStatusList")
public ResponseModel<List<Map<String, String>>> getAuditStatusList(@RequestParam(value = "code") String code) {
return ResponseHelper.buildResponse(WorkFlowStatusEnum.getInfoList(code));
}
} }
...@@ -103,10 +103,10 @@ public class JgUseRegistrationController extends BaseController { ...@@ -103,10 +103,10 @@ public class JgUseRegistrationController extends BaseController {
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET", value = "列表全部数据查询", notes = "列表全部数据查询") @ApiOperation(httpMethod = "GET", value = "详情", notes = "详情")
@GetMapping(value = "/getDetail") @GetMapping(value = "/getDetail")
public ResponseModel<Map<String, Object>> getDetail(@RequestParam("id") String id) { public ResponseModel<Map<String, Object>> getDetail(@RequestParam("record") String record, @RequestParam(value = "sequenceNbr", required = false) Long sequenceNbr) {
return ResponseHelper.buildResponse(jgUseRegistrationServiceImpl.getDetail(id)); return ResponseHelper.buildResponse(jgUseRegistrationServiceImpl.getDetail(record, sequenceNbr));
} }
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
......
...@@ -25,7 +25,7 @@ public interface ICommonService { ...@@ -25,7 +25,7 @@ public interface ICommonService {
List<Map<String,Object>> getUnitListByType(String type); List<Map<String,Object>> getUnitListByType(String type);
List<Map<String,Object>> getSecurityAdmin(String type); List<Map<String, Object>> getSecurityAdmin(String type, String useUnitCode);
Map<String,Object> getUserInfo(String sequenceNbr); Map<String,Object> getUserInfo(String sequenceNbr);
......
...@@ -171,10 +171,12 @@ public class CommonServiceImpl implements ICommonService { ...@@ -171,10 +171,12 @@ public class CommonServiceImpl implements ICommonService {
} }
@Override @Override
public List<Map<String, Object>> getSecurityAdmin(String type) { public List<Map<String, Object>> getSecurityAdmin(String type, String companyCode) {
ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class); if (ObjectUtils.isEmpty(companyCode)) {
CompanyBo company = reginParams.getCompany(); ReginParams reginParams = JSON.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
String companyCode = company.getCompanyCode(); CompanyBo company = reginParams.getCompany();
companyCode = company.getCompanyCode();
}
String postName = null; String postName = null;
if (type.equals("use")) { if (type.equals("use")) {
postName = "安全管理员"; postName = "安全管理员";
...@@ -185,6 +187,9 @@ public class CommonServiceImpl implements ICommonService { ...@@ -185,6 +187,9 @@ public class CommonServiceImpl implements ICommonService {
if (type.equals("agw")) { if (type.equals("agw")) {
postName = "安改维负责人"; postName = "安改维负责人";
} }
if (type.equals("wbry")) {
postName = "维保人员";
}
return ObjectUtils.isEmpty(postName) ? new ArrayList<>() : commonMapper.getSecurityAdmin(companyCode, postName); return ObjectUtils.isEmpty(postName) ? new ArrayList<>() : commonMapper.getSecurityAdmin(companyCode, postName);
} }
......
package com.yeejoin.amos.boot.module.jg.biz.service.impl; package com.yeejoin.amos.boot.module.jg.biz.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.map.MapBuilder;
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.alibaba.fastjson.JSONObject;
...@@ -31,7 +30,6 @@ import org.apache.commons.lang3.ObjectUtils; ...@@ -31,7 +30,6 @@ import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import org.typroject.tyboot.core.foundation.context.RequestContext; import org.typroject.tyboot.core.foundation.context.RequestContext;
...@@ -52,8 +50,7 @@ import java.util.stream.Collectors; ...@@ -52,8 +50,7 @@ import java.util.stream.Collectors;
@Service @Service
public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,JgEquipTransfer, JgEquipTransferMapper> implements IJgEquipTransferService { public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,JgEquipTransfer, JgEquipTransferMapper> implements IJgEquipTransferService {
@Value("${workflow.process-definition-key.equip-transfer:}") private static final String EQUIP_TRANSFER_PROCESS_KEY = "equipmentHandover";
private String equipTransferProcessKey;
private static final String SUBMIT_TYPE_FLOW = "1"; private static final String SUBMIT_TYPE_FLOW = "1";
@Autowired @Autowired
...@@ -98,7 +95,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -98,7 +95,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
for (int i = 0; i<deviceList.size() ; i++ for (int i = 0; i<deviceList.size() ; i++
) { ) {
ActWorkflowStartDTO dto = new ActWorkflowStartDTO(); ActWorkflowStartDTO dto = new ActWorkflowStartDTO();
dto.setProcessDefinitionKey(equipTransferProcessKey); dto.setProcessDefinitionKey(EQUIP_TRANSFER_PROCESS_KEY);
dto.setBusinessKey(String.valueOf(i)); dto.setBusinessKey(String.valueOf(i));
list.add(dto); list.add(dto);
} }
...@@ -156,10 +153,14 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -156,10 +153,14 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
String applyNo = applyNoList.get(i); String applyNo = applyNoList.get(i);
dto.setApplyNo(applyNo); dto.setApplyNo(applyNo);
dto.setApplyDate(new Date()); dto.setApplyDate(new Date());
dto.setNextExecuteIds(String.join(",", roleListSecond));
dto.setInstanceStatus(String.join(",", roleListFirst)); if(SUBMIT_TYPE_FLOW.equals(submitType)) {
dto.setPromoter(reginParams.getUserModel().getUserId()); dto.setNextExecuteIds(String.join(",", roleListSecond));
dto.setApplyStatus(taskName[0]); dto.setInstanceStatus(String.join(",", roleListFirst));
dto.setPromoter(reginParams.getUserModel().getUserId());
dto.setApplyStatus(taskName[0]);
}
jgEquipTransferEq.setEquId(String.valueOf(obj.get("SEQUENCE_NBR"))); jgEquipTransferEq.setEquId(String.valueOf(obj.get("SEQUENCE_NBR")));
jgEquipTransferEq.setEquipTransferId(applyNo); jgEquipTransferEq.setEquipTransferId(applyNo);
if (!CollectionUtils.isEmpty(instanceIdList)) { if (!CollectionUtils.isEmpty(instanceIdList)) {
...@@ -196,27 +197,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -196,27 +197,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
} }
} }
public Map<String, Object> getNextWorkflowNode(String instanceId) {
String role = "";
String taskName = "流程结束";
ArrayList<String> roleList = new ArrayList<>();
AjaxResult taskNoAuth = Workflow.taskClient.getTaskNoAuth(instanceId);
if (!org.springframework.util.ObjectUtils.isEmpty(taskNoAuth.get("data"))) {
JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data")));
String nextTaskId = nextTask.getString("id");
taskName = nextTask.getString("name");
AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId);
JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data")));
for (Object datum : data) {
if (((Map) datum).containsKey("groupId")) {
roleList.add(((Map) datum).get("groupId").toString());
}
}
}
role = String.join(",", roleList);
return MapBuilder.<String, Object>create().put("taskName", taskName).put("role", role).build();
}
void getNext(ArrayList<String> roleListFirst, String instanceId, String[] taskName) { void getNext(ArrayList<String> roleListFirst, String instanceId, String[] taskName) {
AjaxResult aj = Workflow.taskClient.getTaskNoAuth(instanceId); AjaxResult aj = Workflow.taskClient.getTaskNoAuth(instanceId);
JSONObject taskNoAuth = JSON.parseObject(JSON.toJSONString(aj.get("data"))); JSONObject taskNoAuth = JSON.parseObject(JSON.toJSONString(aj.get("data")));
...@@ -242,7 +222,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -242,7 +222,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
public String startFlow(String businessKey) throws Exception { public String startFlow(String businessKey) throws Exception {
// 重新开启工作流 // 重新开启工作流
ActWorkflowStartDTO dto = new ActWorkflowStartDTO(); ActWorkflowStartDTO dto = new ActWorkflowStartDTO();
dto.setProcessDefinitionKey(equipTransferProcessKey); dto.setProcessDefinitionKey(EQUIP_TRANSFER_PROCESS_KEY);
dto.setBusinessKey(StringUtils.defaultString(businessKey, "1")); dto.setBusinessKey(StringUtils.defaultString(businessKey, "1"));
AjaxResult ajaxResult = Workflow.taskClient.startByVariable(dto); AjaxResult ajaxResult = Workflow.taskClient.startByVariable(dto);
...@@ -283,7 +263,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -283,7 +263,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
return null; return null;
} }
Map<String, Object> equipTransferInfo = createEquipTransferInfo(equipTransfer); Map<String, Object> equipTransferInfo = new HashMap<>();
String[] fields = {"productPhoto", "designDoc", "designStandard", "factoryStandard", String[] fields = {"productPhoto", "designDoc", "designStandard", "factoryStandard",
"productQualityYieldProve", "insUseMaintainExplain", "inspectReport", "productQualityYieldProve", "insUseMaintainExplain", "inspectReport",
...@@ -295,9 +275,9 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -295,9 +275,9 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
handleJsonArrayFields(equipmentInfos.get(0), fields); handleJsonArrayFields(equipmentInfos.get(0), fields);
Map<String, Object> resultMap = new HashMap<>(); Map<String, Object> resultMap = new HashMap<>();
resultMap.put("transferInfo", equipmentInfos.get(0)); resultMap.putAll(equipTransferInfo);
resultMap.putAll(equipmentInfos.get(0));
equipTransferInfo.forEach((key, value) -> resultMap.computeIfAbsent(key, k -> value)); resultMap.putAll(createEquipTransferInfo(equipTransfer));
return resultMap; return resultMap;
} }
...@@ -309,8 +289,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -309,8 +289,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
private Map<String, Object> createEquipTransferInfo(JgEquipTransfer equipTransfer) { private Map<String, Object> createEquipTransferInfo(JgEquipTransfer equipTransfer) {
Map<String, Object> equipTransferInfo = new HashMap<>(BeanUtil.beanToMap(equipTransfer)); Map<String, Object> equipTransferInfo = new HashMap<>(BeanUtil.beanToMap(equipTransfer));
//equipTransferInfo.put("useUnitCreditCode", equipTransfer.getUseUnitCreditCode() + "_" + equipTransfer.getUseUnitName()); equipTransferInfo.put("installUnitCreditCode", equipTransfer.getInstallUnitCreditCode() + "_" + equipTransfer.getInstallUnitName());
//equipTransferInfo.put("installUnitCreditCode", equipTransfer.getInstallUnitCreditCode() + "_" + equipTransfer.getInstallUnitName());
return equipTransferInfo; return equipTransferInfo;
} }
...@@ -324,6 +303,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -324,6 +303,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
String[] taskName = new String[]{"流程结束"}; String[] taskName = new String[]{"流程结束"};
String userId = RequestContext.getExeUserId(); String userId = RequestContext.getExeUserId();
JgEquipTransfer jgEquipTransfer = this.baseMapper.selectById(jgEquipTransferDto.getSequenceNbr()); JgEquipTransfer jgEquipTransfer = this.baseMapper.selectById(jgEquipTransferDto.getSequenceNbr());
jgEquipTransfer.setProcessAdvice(jgEquipTransferDto.getProcessAdvice());
// 组装设备注册代码 // 组装设备注册代码
StringBuffer stringBuffer = new StringBuffer(); StringBuffer stringBuffer = new StringBuffer();
String ym = null; String ym = null;
...@@ -343,7 +323,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -343,7 +323,6 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
if(roleList.isEmpty()) { if(roleList.isEmpty()) {
jgEquipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode())); jgEquipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
jgEquipTransfer.setPromoter(""); jgEquipTransfer.setPromoter("");
//TODO
} else { } else {
jgEquipTransfer.setNextExecuteIds(String.join(",", roleList)); jgEquipTransfer.setNextExecuteIds(String.join(",", roleList));
if (!ObjectUtils.isEmpty(jgEquipTransfer.getInstanceStatus())) { if (!ObjectUtils.isEmpty(jgEquipTransfer.getInstanceStatus())) {
...@@ -357,8 +336,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -357,8 +336,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
} else { } else {
//驳回 //驳回
jgEquipTransfer.setPromoter(""); jgEquipTransfer.setPromoter("");
jgEquipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode())); jgEquipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.REJECTED.getCode()));
jgEquipTransfer.setInstanceStatus(String.valueOf(FlowStatusEnum.REJECTED.getCode()));
} }
updateById(jgEquipTransfer); updateById(jgEquipTransfer);
} }
...@@ -392,6 +370,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -392,6 +370,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
JgEquipTransfer equipTransfer = this.baseMapper.selectById(equipTransferInfo.getSequenceNbr()); JgEquipTransfer equipTransfer = this.baseMapper.selectById(equipTransferInfo.getSequenceNbr());
if (ajaxResult.getStatus() == 200) { if (ajaxResult.getStatus() == 200) {
equipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode())); equipTransfer.setApplyStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
equipTransfer.setPromoter("");
this.baseMapper.updateById(equipTransfer); this.baseMapper.updateById(equipTransfer);
} }
} }
...@@ -411,7 +390,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J ...@@ -411,7 +390,7 @@ public class JgEquipTransferServiceImpl extends BaseService<JgEquipTransferDto,J
// 发起流程 // 发起流程
if (!org.springframework.util.StringUtils.hasText(equipTransferDto.getInstanceId())) { if (!org.springframework.util.StringUtils.hasText(equipTransferDto.getInstanceId())) {
ActWorkflowStartDTO dto = new ActWorkflowStartDTO(); ActWorkflowStartDTO dto = new ActWorkflowStartDTO();
dto.setProcessDefinitionKey(equipTransferProcessKey); dto.setProcessDefinitionKey(EQUIP_TRANSFER_PROCESS_KEY);
dto.setBusinessKey("1"); dto.setBusinessKey("1");
try { try {
ajaxResult = Workflow.taskClient.startByVariable(dto); ajaxResult = Workflow.taskClient.startByVariable(dto);
......
...@@ -140,9 +140,9 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -140,9 +140,9 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
if (!ValidationUtil.isEmpty(notice.getStreet()) && !ValidationUtil.isEmpty(notice.getStreetName())) { if (!ValidationUtil.isEmpty(notice.getStreet()) && !ValidationUtil.isEmpty(notice.getStreetName())) {
maintainInfo.put("street", notice.getStreet() + "_" + notice.getStreetName()); maintainInfo.put("street", notice.getStreet() + "_" + notice.getStreetName());
} }
String[] fields = {"productPhoto", "designDoc", "designStandard", "factoryStandard", "productQualityYieldProve", String[] fields = {"productPhoto", "designDoc", "designStandard", "factoryStandard", "productQualityYieldProve",
"insUseMaintainExplain", "inspectReport", "proxyStatementAttachment", "installContractAttachment"}; "insUseMaintainExplain", "inspectReport", "proxyStatementAttachment", "installContractAttachment"};
// 设备信息 // 设备信息 "equCategory", "equDefine", "equRegisterCode", "produceCountry", "produceLicenseNum",
List<Map<String, Object>> equipmentInfos = jgMaintainNoticeMapper.queryEquipInformation(sequenceNbr); List<Map<String, Object>> equipmentInfos = jgMaintainNoticeMapper.queryEquipInformation(sequenceNbr);
for (String s : fields) { for (String s : fields) {
if (maintainInfo.containsKey(s)) if (maintainInfo.containsKey(s))
...@@ -242,7 +242,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -242,7 +242,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
if (Objects.nonNull(notice.getMaintainType())) { if (Objects.nonNull(notice.getMaintainType())) {
noticeDto.setMaintainTypeDesc(dictionaries.stream().filter(d -> notice.getMaintainType().equals(d.getCode())).map(DataDictionary::getName).collect(Collectors.joining())); noticeDto.setMaintainTypeDesc(dictionaries.stream().filter(d -> notice.getMaintainType().equals(d.getCode())).map(DataDictionary::getName).collect(Collectors.joining()));
} }
noticeDto.setFullAddress(notice.getProvinceName() + notice.getCityName() + notice.getCityName() + notice.getStreetName() + notice.getAddress()); noticeDto.setFullAddress(notice.getProvinceName() + notice.getCityName() + notice.getCountyName() + notice.getStreetName() + notice.getAddress());
return noticeDto; return noticeDto;
}).collect(java.util.stream.Collectors.toList()); }).collect(java.util.stream.Collectors.toList());
noticeDtoPage.setRecords(records); noticeDtoPage.setRecords(records);
...@@ -432,7 +432,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -432,7 +432,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
TaskResultDTO dto = new TaskResultDTO(); TaskResultDTO dto = new TaskResultDTO();
dto.setResultCode("approvalStatus"); dto.setResultCode("approvalStatus");
dto.setTaskId(taskId); dto.setTaskId(taskId);
dto.setComment("提交流程"); // dto.setComment("提交流程");
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = new HashMap<>();
map.put("approvalStatus", "0"); map.put("approvalStatus", "0");
dto.setVariable(map); dto.setVariable(map);
...@@ -464,6 +464,8 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -464,6 +464,8 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
String applyNo = applyNoList.get(i); String applyNo = applyNoList.get(i);
dto.setApplyNo(applyNo); dto.setApplyNo(applyNo);
dto.setNoticeDate(new Date()); dto.setNoticeDate(new Date());
dto.setEquCategory(String.valueOf(obj.get("EQU_CATEGORY")));
dto.setEquListCode(String.valueOf(obj.get("EQU_LIST_CODE")));
if (SUBMIT_TYPE_FLOW.equals(submitType)) { if (SUBMIT_TYPE_FLOW.equals(submitType)) {
dto.setNextExecuteIds(String.join(",", roleListSecond)); dto.setNextExecuteIds(String.join(",", roleListSecond));
dto.setInstanceStatus(String.join(",", roleListFirst)); dto.setInstanceStatus(String.join(",", roleListFirst));
...@@ -480,6 +482,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -480,6 +482,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
} else { } else {
dto.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode())); dto.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode()));
} }
dto.setCreateUserId(reginParams.getUserModel().getUserId());
list.add(dto); list.add(dto);
equipList.add(jgRelationEquip); equipList.add(jgRelationEquip);
}); });
...@@ -602,7 +605,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -602,7 +605,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
TaskResultDTO dto = new TaskResultDTO(); TaskResultDTO dto = new TaskResultDTO();
dto.setResultCode("approvalStatus"); dto.setResultCode("approvalStatus");
dto.setTaskId(taskId); dto.setTaskId(taskId);
dto.setComment("提交流程"); // dto.setComment("提交流程");
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = new HashMap<>();
map.put("approvalStatus", op); map.put("approvalStatus", op);
dto.setVariable(map); dto.setVariable(map);
...@@ -631,7 +634,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -631,7 +634,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
jgInstallationNotice.setStatus(taskName[0]); jgInstallationNotice.setStatus(taskName[0]);
jgInstallationNotice.setPromoter(""); jgInstallationNotice.setPromoter("");
jgInstallationNotice.setNextExecuteIds(String.join(",", roleList)); jgInstallationNotice.setNextExecuteIds(String.join(",", roleList));
jgInstallationNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_SUBMITTED.getCode())); jgInstallationNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.ROLLBACK.getCode()));
updateById(jgInstallationNotice); updateById(jgInstallationNotice);
} }
} }
...@@ -667,6 +670,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto ...@@ -667,6 +670,7 @@ public class JgMaintainNoticeServiceImpl extends BaseService<JgMaintainNoticeDto
map.put("cityCode", jgMaintainNotice.getCity()); map.put("cityCode", jgMaintainNotice.getCity());
map.put("countyCode", jgMaintainNotice.getCounty()); map.put("countyCode", jgMaintainNotice.getCounty());
map.put("equCategory", tzsJgRegistrationInfo.getEquCategory()); map.put("equCategory", tzsJgRegistrationInfo.getEquCategory());
jgMaintainNotice.setAcceptDate(new Date());
jgMaintainNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode())); jgMaintainNotice.setNoticeStatus(String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()));
generateMaintainNoticeReport(jgMaintainNotice.getSequenceNbr()); generateMaintainNoticeReport(jgMaintainNotice.getSequenceNbr());
jgMaintainNotice.setPromoter(""); jgMaintainNotice.setPromoter("");
......
...@@ -27,6 +27,7 @@ import com.yeejoin.amos.boot.module.jg.flc.api.fegin.WorkFlowFeignService; ...@@ -27,6 +27,7 @@ import com.yeejoin.amos.boot.module.jg.flc.api.fegin.WorkFlowFeignService;
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.enums.FlowStatusEnum; import com.yeejoin.amos.boot.module.ymt.api.enums.FlowStatusEnum;
import com.yeejoin.amos.boot.module.ymt.api.service.ICreateCodeService; import com.yeejoin.amos.boot.module.ymt.api.service.ICreateCodeService;
import com.yeejoin.amos.component.feign.model.FeignClientResult;
import com.yeejoin.amos.feign.workflow.Workflow; import com.yeejoin.amos.feign.workflow.Workflow;
import com.yeejoin.amos.feign.workflow.model.ActWorkflowStartDTO; import com.yeejoin.amos.feign.workflow.model.ActWorkflowStartDTO;
import com.yeejoin.amos.feign.workflow.model.AjaxResult; import com.yeejoin.amos.feign.workflow.model.AjaxResult;
...@@ -41,6 +42,7 @@ import org.springframework.util.ObjectUtils; ...@@ -41,6 +42,7 @@ import org.springframework.util.ObjectUtils;
import org.typroject.tyboot.core.foundation.context.RequestContext; import org.typroject.tyboot.core.foundation.context.RequestContext;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import java.awt.print.Book;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
...@@ -53,6 +55,7 @@ import java.util.stream.Collectors; ...@@ -53,6 +55,7 @@ import java.util.stream.Collectors;
@Service @Service
public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceContractDto, JgMaintenanceContract, JgMaintenanceContractMapper> implements IJgMaintenanceContractService { public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceContractDto, JgMaintenanceContract, JgMaintenanceContractMapper> implements IJgMaintenanceContractService {
public static final String SUBMIT_DATA = "0";
public static final String SUBMIT_TYPE_FLOW = "1"; public static final String SUBMIT_TYPE_FLOW = "1";
public static final String WB_PROCESS_DEFINITION_KEY = "maintenanceFiling"; public static final String WB_PROCESS_DEFINITION_KEY = "maintenanceFiling";
private static final String HANDLING_STATUS_DICTIONARY = "JGGZZZ"; private static final String HANDLING_STATUS_DICTIONARY = "JGGZZZ";
...@@ -79,8 +82,13 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -79,8 +82,13 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
*/ */
public Page<JgMaintenanceContractVo> queryForPage(Page<JgMaintenanceContract> page, public Page<JgMaintenanceContractVo> queryForPage(Page<JgMaintenanceContract> page,
int phase, int phase,
JgMaintenanceContractDto dto, // JgMaintenanceContractDto dto,
Map<String,Object> map,
ReginParams reginParams) { ReginParams reginParams) {
// JgMaintenanceContractDto dto = new JgMaintenanceContractDto();
// JgMaintenanceContractDto dto = (JgMaintenanceContractDto)map;
JgMaintenanceContractDto dto = JSON.parseObject(JSON.toJSONString(map.get("jgMaintenanceContractDto")), JgMaintenanceContractDto.class);
Page<JgMaintenanceContractDto> contractList = new Page<>(); Page<JgMaintenanceContractDto> contractList = new Page<>();
Page<JgMaintenanceContractVo> result = new Page<>(); Page<JgMaintenanceContractVo> result = new Page<>();
CompanyBo company = reginParams.getCompany(); CompanyBo company = reginParams.getCompany();
...@@ -308,7 +316,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -308,7 +316,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
@Transactional @Transactional
public void revocation(String instanceId) { public void revocation(String instanceId) {
ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class); ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
String taskName = ""; String taskCode = "";
JgMaintenanceContract jgMaintenanceContract = new JgMaintenanceContract(); JgMaintenanceContract jgMaintenanceContract = new JgMaintenanceContract();
LambdaQueryWrapper<JgMaintenanceContract> lambda = new QueryWrapper<JgMaintenanceContract>().lambda(); LambdaQueryWrapper<JgMaintenanceContract> lambda = new QueryWrapper<JgMaintenanceContract>().lambda();
lambda.eq(JgMaintenanceContract::getInstanceId, instanceId); lambda.eq(JgMaintenanceContract::getInstanceId, instanceId);
...@@ -317,9 +325,13 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -317,9 +325,13 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
workFlowFeginService.rollBack(instanceId); workFlowFeginService.rollBack(instanceId);
JSONObject taskNoAuth = workFlowFeginService.getTaskNoAuth(instanceId); JSONObject taskNoAuth = workFlowFeginService.getTaskNoAuth(instanceId);
JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data"))); JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data")));
taskName = nextTask.getString("name"); taskCode = nextTask.getString("name");
if (!ObjectUtils.isEmpty(taskNoAuth.get("data"))) { if (!ObjectUtils.isEmpty(taskNoAuth.get("data"))) {
String nextTaskId = nextTask.getString("id"); String nextTaskId = nextTask.getString("id");
FeignClientResult<JSONObject> nodeInfo = workFlowFeginService.getNodeInfo(nextTaskId);
JSONObject result = nodeInfo.getResult();
Map<String, Object> taskInfo = (Map<String, Object>) result.get("taskInfo");
taskCode = String.valueOf(taskInfo.get("taskDefinitionKey"));
AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId); AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId);
JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data"))); JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data")));
for (Object datum : data) { for (Object datum : data) {
...@@ -331,9 +343,9 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -331,9 +343,9 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
if (!ObjectUtils.isEmpty(taskName)) { if (!ObjectUtils.isEmpty(taskCode)) {
jgMaintenanceContract.setStatus(MaintenceStatusEnum.getMessage(taskName).getRollBack()); jgMaintenanceContract.setStatus(WorkFlowStatusEnum.getMessage(taskCode).getRollBack());
} }
String join = String.join(",", roleList); String join = String.join(",", roleList);
jgMaintenanceContract.setPromoter(reginParams.getUserModel().getUserId()); jgMaintenanceContract.setPromoter(reginParams.getUserModel().getUserId());
...@@ -374,6 +386,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -374,6 +386,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
// 新增编辑 // 新增编辑
if ("add".equals(String.valueOf(map.get("pageType")))) { if ("add".equals(String.valueOf(map.get("pageType")))) {
contract.setStatus(SUBMIT_DATA.equals(submit) ? WorkFlowStatusEnum.MAIN_SUBMIT.getPass() : WorkFlowStatusEnum.MAIN_RECEIVE.getPass());
this.save(contract); this.save(contract);
} else { } else {
this.getBaseMapper().updateById(contract); this.getBaseMapper().updateById(contract);
...@@ -414,16 +427,20 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -414,16 +427,20 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
public void updateExecuteIds(String instanceId, Long sequenceNbr, String operate){ public void updateExecuteIds(String instanceId, Long sequenceNbr, String operate){
ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class); ReginParams reginParams = JSONObject.parseObject(redisUtils.get(RedisKey.buildReginKey(RequestContext.getExeUserId(), RequestContext.getToken())).toString(), ReginParams.class);
String role = ""; String role = "";
String taskName = "流程结束"; String taskCode = FlowStatusEnum.TO_BE_FINISHED.getName();
ArrayList<String> roleList = new ArrayList<>(); ArrayList<String> roleList = new ArrayList<>();
JgMaintenanceContract jgMaintenanceContract = this.getBaseMapper().selectById(sequenceNbr); JgMaintenanceContract jgMaintenanceContract = this.getBaseMapper().selectById(sequenceNbr);
try { try {
// 查询下节点任务 // 查询下节点任务
JSONObject taskNoAuth = workFlowFeginService.getTaskNoAuth(instanceId); JSONObject taskNoAuth = workFlowFeginService.getTaskNoAuth(instanceId);
if (!ObjectUtils.isEmpty(taskNoAuth.get("data"))) { if (!ObjectUtils.isEmpty(taskNoAuth.get("data"))) {
JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data"))); JSONObject nextTask = JSON.parseObject(JSON.toJSONString(taskNoAuth.get("data")));
String nextTaskId = nextTask.getString("id"); String nextTaskId = nextTask.getString("id");
taskName = nextTask.getString("name"); FeignClientResult<JSONObject> nodeInfo = workFlowFeginService.getNodeInfo(nextTaskId);
JSONObject result = nodeInfo.getResult();
Map<String, Object> taskInfo = (Map<String, Object>) result.get("taskInfo");
taskCode = String.valueOf(taskInfo.get("taskDefinitionKey"));
AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId); AjaxResult taskGroupName = Workflow.taskClient.getTaskGroupName(nextTaskId);
JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data"))); JSONArray data = JSON.parseArray(JSON.toJSONString(taskGroupName.get("data")));
for (Object datum : data) { for (Object datum : data) {
...@@ -435,7 +452,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -435,7 +452,7 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
if (!"流程结束".equals(taskName)){ if (!FlowStatusEnum.TO_BE_FINISHED.getName().equals(taskCode)){
role= String.join(",", roleList); role= String.join(",", roleList);
jgMaintenanceContract.setNextExecuteIds(role); jgMaintenanceContract.setNextExecuteIds(role);
jgMaintenanceContract.setPromoter(reginParams.getUserModel().getUserId()); jgMaintenanceContract.setPromoter(reginParams.getUserModel().getUserId());
...@@ -447,15 +464,15 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC ...@@ -447,15 +464,15 @@ public class JgMaintenanceContractServiceImpl extends BaseService<JgMaintenanceC
} }
if ("0".equals(operate)){ if ("0".equals(operate)){
// 通过操作 // 通过操作
jgMaintenanceContract.setStatus(MaintenceStatusEnum.getMessage(taskName).getPass()); jgMaintenanceContract.setStatus(WorkFlowStatusEnum.getMessage(taskCode).getPass());
}else { }else {
// 驳回操作 // 驳回操作
jgMaintenanceContract.setStatus(MaintenceStatusEnum.getMessage(taskName).getReject()); jgMaintenanceContract.setStatus(WorkFlowStatusEnum.getMessage(taskCode).getReject());
jgMaintenanceContract.setPromoter(null); jgMaintenanceContract.setPromoter(null);
} }
}else { }else {
jgMaintenanceContract.setStatus(taskName); jgMaintenanceContract.setStatus(taskCode);
} }
this.getBaseMapper().updateById(jgMaintenanceContract); this.getBaseMapper().updateById(jgMaintenanceContract);
......
...@@ -452,7 +452,7 @@ public class JgReformNoticeServiceImpl extends BaseService<JgReformNoticeDto, Jg ...@@ -452,7 +452,7 @@ public class JgReformNoticeServiceImpl extends BaseService<JgReformNoticeDto, Jg
TaskResultDTO dto = new TaskResultDTO(); TaskResultDTO dto = new TaskResultDTO();
dto.setResultCode("approvalStatus"); dto.setResultCode("approvalStatus");
dto.setTaskId(taskId); dto.setTaskId(taskId);
dto.setComment("提交流程"); dto.setComment("");
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = new HashMap<>();
map.put("approvalStatus", "0"); map.put("approvalStatus", "0");
dto.setVariable(map); dto.setVariable(map);
......
...@@ -42,10 +42,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext; ...@@ -42,10 +42,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext;
import org.typroject.tyboot.core.rdbms.service.BaseService; import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.typroject.tyboot.core.restful.utils.ResponseModel; import org.typroject.tyboot.core.restful.utils.ResponseModel;
import java.util.ArrayList; import java.util.*;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* 服务实现类 * 服务实现类
...@@ -97,6 +94,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD ...@@ -97,6 +94,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
LambdaQueryWrapper<InspectionDetectionInfo> inspectionLambda = new QueryWrapper<InspectionDetectionInfo>().lambda(); LambdaQueryWrapper<InspectionDetectionInfo> inspectionLambda = new QueryWrapper<InspectionDetectionInfo>().lambda();
inspectionLambda.eq(InspectionDetectionInfo::getRecord, map.get("equipId")); inspectionLambda.eq(InspectionDetectionInfo::getRecord, map.get("equipId"));
// 更新检验检测信息 // 更新检验检测信息
inspectionDetectionInfo.setInspectReport(null);
inspectionDetectionInfoMapper.update(inspectionDetectionInfo, inspectionLambda); inspectionDetectionInfoMapper.update(inspectionDetectionInfo, inspectionLambda);
// 使用登记信息 // 使用登记信息
JgUseRegistration jgUseRegistration = new JgUseRegistration(); JgUseRegistration jgUseRegistration = new JgUseRegistration();
...@@ -271,6 +269,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD ...@@ -271,6 +269,7 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
if (!ObjectUtils.isEmpty(jgUseRegistration.getSupervisoryCode())) { if (!ObjectUtils.isEmpty(jgUseRegistration.getSupervisoryCode())) {
// 生成使用登记证编号 // 生成使用登记证编号
jgUseRegistration.setUseRegistrationCode(getCode(jgUseRegistration.getSupervisoryCode())); jgUseRegistration.setUseRegistrationCode(getCode(jgUseRegistration.getSupervisoryCode()));
jgUseRegistration.setRegDate(new Date());
} }
} }
this.getBaseMapper().updateById(jgUseRegistration); this.getBaseMapper().updateById(jgUseRegistration);
...@@ -375,18 +374,21 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD ...@@ -375,18 +374,21 @@ public class JgUseRegistrationServiceImpl extends BaseService<JgUseRegistrationD
this.update(jgUseRegistration, lambda); this.update(jgUseRegistration, lambda);
} }
public Map<String, Object> getDetail(String id) { public Map<String, Object> getDetail(String id, Long sequenceNbr) {
Map<String, Object> detail = this.baseMapper.getDetail(id); Map<String, Object> detail = this.baseMapper.getDetail(id);
Map<String, Object> inspectDetail = this.baseMapper.getInspectDetail(id); Map<String, Object> inspectDetail = this.baseMapper.getInspectDetail(id);
Map<String, Object> useDetail = this.baseMapper.getUseDetail(id); Map<String, Object> useDetail = this.baseMapper.getUseDetail(id);
detail.putAll(inspectDetail); detail.putAll(inspectDetail);
detail.putAll(useDetail); detail.putAll(useDetail);
detail.putAll(useDetail);
detail.put("proDuctPhoto", JSON.parse(String.valueOf(detail.get("proDuctPhoto")))); detail.put("proDuctPhoto", JSON.parse(String.valueOf(detail.get("proDuctPhoto"))));
detail.put("factoryStandard", JSON.parse(String.valueOf(detail.get("factoryStandard")))); detail.put("factoryStandard", JSON.parse(String.valueOf(detail.get("factoryStandard"))));
detail.put("productQualityYieldProve", JSON.parse(String.valueOf(detail.get("productQualityYieldProve")))); detail.put("productQualityYieldProve", JSON.parse(String.valueOf(detail.get("productQualityYieldProve"))));
detail.put("insUseMaintainExplanin", JSON.parse(String.valueOf(detail.get("insUseMaintainExplanin")))); detail.put("insUseMaintainExplanin", JSON.parse(String.valueOf(detail.get("insUseMaintainExplanin"))));
// detail.put("inspectReport", JSON.parse(String.valueOf(detail.get("inspectReport")))); detail.put("inspectReport", JSON.parse(String.valueOf(detail.get("inspectReport"))));
if (!ObjectUtils.isEmpty(sequenceNbr)){
JgUseRegistration jgUseRegistration = this.getBaseMapper().selectById(sequenceNbr);
detail.put("receiveOrgCode", jgUseRegistration.getReceiveCompanyCode());
}
return detail; return detail;
} }
......
...@@ -18,6 +18,7 @@ import java.util.Collections; ...@@ -18,6 +18,7 @@ import java.util.Collections;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.stream.Collectors;
/** /**
* @author system_generator * @author system_generator
...@@ -46,14 +47,32 @@ public class CommonController extends BaseController { ...@@ -46,14 +47,32 @@ public class CommonController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/getUserPhonesByPersonCode") @PostMapping(value = "/getUserPhonesByPersonCode")
@ApiOperation(httpMethod = "GET", value = "根据公司的unitCode获取检测检验人员列表", notes = "根据公司的unitCode获取检测检验人员列表") @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) {
List<TzsUserInfo> userPhones = commonserviceImpl.getUserPhonesByPersonCode(unitCode); List<TzsUserInfo> userPhones = commonserviceImpl.getUserPhonesByPersonCode(unitCode);
if (CollectionUtils.isEmpty(userPhones)){ if (CollectionUtils.isEmpty(userPhones)){
return null; 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);
return ResponseHelper.buildResponse(map);
}
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/getInnerPersonCodeByPersonCode")
@ApiOperation(httpMethod = "GET", value = "根据公司的unitCode获取检测检验人员内部编号", notes = "根据公司的unitCode获取检测检验人员内部编号")
public ResponseModel<Map<String,Object>> getInnerPersonCodeByPersonCode(@RequestParam String unitCode) {
List<TzsUserInfo> userPhones = commonserviceImpl.getUserPhonesByPersonCode(unitCode);
if (CollectionUtils.isEmpty(userPhones)){
return null;
}
List<String> phones = userPhones.stream().map(TzsUserInfo::getInnerPersonCode).collect(Collectors.toList());
String innerPersonCode = String.join(",", phones);
Map<String,Object> map = new HashMap<>(); Map<String,Object> map = new HashMap<>();
map.put("phone",userPhones.get(0).getPhone() == null?"":userPhones.get(0).getPhone()); map.put("innerPersonCode",innerPersonCode);
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
......
...@@ -16,6 +16,7 @@ import org.springframework.web.bind.annotation.RestController; ...@@ -16,6 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import com.yeejoin.amos.boot.biz.common.controller.BaseController; import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.JyjcOpeningApplicationServiceImpl; import com.yeejoin.amos.boot.module.jyjc.biz.service.impl.JyjcOpeningApplicationServiceImpl;
import org.typroject.tyboot.core.foundation.context.RequestContext; import org.typroject.tyboot.core.foundation.context.RequestContext;
import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
import org.typroject.tyboot.core.restful.exception.instance.BadRequest; import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import org.typroject.tyboot.core.restful.utils.ResponseHelper; import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel; import org.typroject.tyboot.core.restful.utils.ResponseModel;
...@@ -75,6 +76,10 @@ public class JyjcOpeningApplicationController extends BaseController { ...@@ -75,6 +76,10 @@ public class JyjcOpeningApplicationController extends BaseController {
@ApiOperation(httpMethod = "PUT", value = "保存并提交", notes = "保存并提交") @ApiOperation(httpMethod = "PUT", value = "保存并提交", notes = "保存并提交")
public ResponseModel<JyjcOpeningApplicationModel> updateBySequenceNbrAndStartFlow(@RequestBody JyjcOpeningApplicationModel model, @RequestParam(value = "sequenceNbr", required = false) Long sequenceNbr) { public ResponseModel<JyjcOpeningApplicationModel> updateBySequenceNbrAndStartFlow(@RequestBody JyjcOpeningApplicationModel model, @RequestParam(value = "sequenceNbr", required = false) Long sequenceNbr) {
model.setSequenceNbr(sequenceNbr); model.setSequenceNbr(sequenceNbr);
JyjcOpeningApplicationModel jyjcOpeningApplicationModel = jyjcOpeningApplicationServiceImpl.queryDetail(sequenceNbr);
if (jyjcOpeningApplicationModel == null || ValidationUtil.isEmpty(jyjcOpeningApplicationModel.getBaseUnitLicences()) || ValidationUtil.isEmpty(jyjcOpeningApplicationModel.getUserInfos())) {
throw new BadRequest("企业资质信息和检验人员信息为空,无法提交!");
}
return ResponseHelper.buildResponse(jyjcOpeningApplicationServiceImpl.saveOrUpdateModel(model,true)); return ResponseHelper.buildResponse(jyjcOpeningApplicationServiceImpl.saveOrUpdateModel(model,true));
} }
...@@ -242,4 +247,23 @@ public class JyjcOpeningApplicationController extends BaseController { ...@@ -242,4 +247,23 @@ public class JyjcOpeningApplicationController extends BaseController {
public ResponseModel<List<TzBaseEnterpriseInfo>> getInspectionUnitList() { public ResponseModel<List<TzBaseEnterpriseInfo>> getInspectionUnitList() {
return ResponseHelper.buildResponse(jyjcOpeningApplicationServiceImpl.getInspectionUnitList()); return ResponseHelper.buildResponse(jyjcOpeningApplicationServiceImpl.getInspectionUnitList());
} }
/**
* 作废
*
*
* @param
* @return {@link ResponseModel< List< TzBaseEnterpriseInfo>>}
* @author yangyang
* @throws
* @date 2023/12/22 16:13
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/discard")
@ApiOperation(httpMethod = "PUT", value = "作废", notes = "作废")
public ResponseModel<Boolean> doDiscard(@RequestBody Map<String,Object> params) {
String sequenceNbr = (String) params.get("sequenceNbr");
String remark = (String) params.get("remark");
return ResponseHelper.buildResponse(jyjcOpeningApplicationServiceImpl.doDiscard(Long.parseLong(sequenceNbr), remark));
}
} }
package com.yeejoin.amos.boot.module.jyjc.biz.service.impl; package com.yeejoin.amos.boot.module.jyjc.biz.service.impl;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; 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;
...@@ -50,8 +51,10 @@ public class CommonserviceImpl { ...@@ -50,8 +51,10 @@ public class CommonserviceImpl {
} }
public List<TzsUserInfo> getUserPhonesByPersonCode(String personCode) { public List<TzsUserInfo> getUserPhonesByPersonCode(String personCode) {
List<String> ids = StrUtil.split(personCode, ",");
QueryWrapper userInfoQueryWrapper = new QueryWrapper<>(); QueryWrapper userInfoQueryWrapper = new QueryWrapper<>();
userInfoQueryWrapper.eq("sequence_nbr", personCode); userInfoQueryWrapper.in("sequence_nbr", ids);
List<TzsUserInfo> userInfos = userInfoMapper.selectList(userInfoQueryWrapper); List<TzsUserInfo> userInfos = userInfoMapper.selectList(userInfoQueryWrapper);
return userInfos; return userInfos;
} }
......
...@@ -209,7 +209,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -209,7 +209,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
} }
/** /**
* 完成的时候废弃其他 * 完成的时候废弃其他已完成的申请单
* *
* *
* @param unitCode unitCode * @param unitCode unitCode
...@@ -225,6 +225,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -225,6 +225,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
} }
List<Long> ids = this.lambdaQuery().select(JyjcOpeningApplication::getSequenceNbr) List<Long> ids = this.lambdaQuery().select(JyjcOpeningApplication::getSequenceNbr)
.eq(JyjcOpeningApplication::getUnitCode, unitCode) .eq(JyjcOpeningApplication::getUnitCode, unitCode)
.eq(JyjcOpeningApplication::getStatus, FlowStatusEnum.TO_BE_FINISHED.getCode())
.list().stream().filter(o -> o.getSequenceNbr().compareTo(sequenceNbr) != 0) .list().stream().filter(o -> o.getSequenceNbr().compareTo(sequenceNbr) != 0)
.map(JyjcOpeningApplication::getSequenceNbr).collect(Collectors.toList()); .map(JyjcOpeningApplication::getSequenceNbr).collect(Collectors.toList());
if (ValidationUtil.isEmpty(ids)) { if (ValidationUtil.isEmpty(ids)) {
...@@ -235,6 +236,26 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -235,6 +236,26 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
return this.update(updateWrapper); return this.update(updateWrapper);
} }
public Boolean doDiscard(Long sequenceNbr, String remark) {
if (sequenceNbr == null) {
throw new BadRequest("sequenceNbr不能为空!");
}
JyjcOpeningApplication jyjcOpeningApplication = jyjcOpeningApplicationMapper.selectById(sequenceNbr);
if (jyjcOpeningApplication == null) {
return false;
}
if (!String.valueOf(FlowStatusEnum.TO_BE_FINISHED.getCode()).equals(jyjcOpeningApplication.getStatus())) {
throw new BadRequest("只有已完成的申请单才可以作废!");
}
UpdateWrapper<JyjcOpeningApplication> updateWrapper = new UpdateWrapper<>();
updateWrapper
.set("status", FlowStatusEnum.TO_BE_DISCARD.getCode())
.set("status_name", FlowStatusEnum.TO_BE_DISCARD.getName())
.set("remark", remark)
.eq("SEQUENCE_NBR", sequenceNbr);
return this.update(updateWrapper);
}
/** /**
* 分页查询 * 分页查询
...@@ -340,7 +361,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp ...@@ -340,7 +361,7 @@ public class JyjcOpeningApplicationServiceImpl extends BaseService<JyjcOpeningAp
// 获取检验人员信息 // 获取检验人员信息
QueryWrapper userInfoQueryWrapper = new QueryWrapper<>(); QueryWrapper userInfoQueryWrapper = new QueryWrapper<>();
userInfoQueryWrapper.eq("unit_code", unitCode); userInfoQueryWrapper.eq("unit_code", unitCode);
userInfoQueryWrapper.eq("is_delete", true); userInfoQueryWrapper.eq("is_delete", false);
List<TzsUserInfo> userInfos = userInfoMapper.selectList(userInfoQueryWrapper); List<TzsUserInfo> userInfos = userInfoMapper.selectList(userInfoQueryWrapper);
if (!ValidationUtil.isEmpty(userInfos)) { if (!ValidationUtil.isEmpty(userInfos)) {
// List<String> codes = userInfos.stream() // List<String> codes = userInfos.stream()
......
...@@ -86,4 +86,7 @@ public class TzsUserInfoDto extends BaseDto { ...@@ -86,4 +86,7 @@ public class TzsUserInfoDto extends BaseDto {
@ApiModelProperty(value = "任命文件") @ApiModelProperty(value = "任命文件")
private String appointDoc; private String appointDoc;
@ApiModelProperty(value = "人员内部编码")
private String innerPersonCode;
} }
...@@ -150,4 +150,9 @@ public class TzsUserInfo extends BaseEntity { ...@@ -150,4 +150,9 @@ public class TzsUserInfo extends BaseEntity {
*/ */
@TableField(value = "equip_type", updateStrategy = FieldStrategy.IGNORED) @TableField(value = "equip_type", updateStrategy = FieldStrategy.IGNORED)
private String equipType; private String equipType;
/**
* 内部人员编码
*/
@TableField("inner_person_code")
private String innerPersonCode;
} }
...@@ -183,7 +183,7 @@ public class TzBaseEnterpriseInfoController { ...@@ -183,7 +183,7 @@ public class TzBaseEnterpriseInfoController {
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/info") @GetMapping(value = "/info")
@ApiOperation(httpMethod = "GET", value = "查询企业端当前登录人所在企业详情", notes = "查询企业端当前登录人所在企业详情") @ApiOperation(httpMethod = "GET", value = "查询企业端当前登录人所在企业详情", notes = "查询企业端当前登录人所在企业详情")
public ResponseModel<IPage<TzBaseEnterpriseInfoDto>> pageInfo(PageParam pageParam) { public ResponseModel<IPage<TzBaseEnterpriseInfoDto>> pageInfo(PageParam pageParam) {
......
...@@ -231,12 +231,13 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI ...@@ -231,12 +231,13 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI
String roles = map.get("role").toString(); String roles = map.get("role").toString();
String status = map.get("status").toString(); String status = map.get("status").toString();
String roleGroupCode = map.get("roleGroup").toString(); String roleGroupCode = map.get("roleGroup").toString();
TzsUserInfo tzsUserInfo = tzsUserInfoMapper.selectById(sequenceNbr);
FeignClientResult<AgencyUserModel> userResult = null; FeignClientResult<AgencyUserModel> userResult = null;
try { try {
AgencyUserModel agencyUserModel = new AgencyUserModel(); AgencyUserModel agencyUserModel = new AgencyUserModel();
agencyUserModel.setUserName(loginName); agencyUserModel.setUserName(loginName);
agencyUserModel.setRealName(loginName); agencyUserModel.setRealName(tzsUserInfo.getName());
agencyUserModel.setLockStatus(status); agencyUserModel.setLockStatus(status);
agencyUserModel.setPassword(pwd); agencyUserModel.setPassword(pwd);
agencyUserModel.setRePassword(pwd); agencyUserModel.setRePassword(pwd);
...@@ -265,7 +266,7 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI ...@@ -265,7 +266,7 @@ public class TzsUserInfoServiceImpl extends BaseService<TzsUserInfoDto, TzsUserI
}); });
//添加人员管理角色 //添加人员管理角色
TzsUserInfo tzsUserInfo = tzsUserInfoMapper.selectById(sequenceNbr);
String post = tzsUserInfo.getPost(); String post = tzsUserInfo.getPost();
if(post.contains(PersonManageRoleEnum.code.getId().toString())){ if(post.contains(PersonManageRoleEnum.code.getId().toString())){
String companyType = tzsUserInfoMapper.selectCompanyTypeById(companySeq); String companyType = tzsUserInfoMapper.selectCompanyTypeById(companySeq);
......
...@@ -96,7 +96,7 @@ public class RegUnitInfoController extends BaseController { ...@@ -96,7 +96,7 @@ public class RegUnitInfoController extends BaseController {
return ResponseHelper.buildResponse(iRegUnitInfoService.submit(pageId, taskId, planInstanceId, topic, tableName, kv)); return ResponseHelper.buildResponse(iRegUnitInfoService.submit(pageId, taskId, planInstanceId, topic, tableName, kv));
} }
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false) @TycloudOperation(ApiLevel = UserType.AGENCY)
@RequestMapping(value = "/adminInfo", method = RequestMethod.GET) @RequestMapping(value = "/adminInfo", method = RequestMethod.GET)
@ApiOperation(httpMethod = "GET", value = "查询企业管理员信息", notes = "查询企业管理员信息") @ApiOperation(httpMethod = "GET", value = "查询企业管理员信息", notes = "查询企业管理员信息")
public ResponseModel<RegUnitInfoDto> adminInfo() { public ResponseModel<RegUnitInfoDto> adminInfo() {
......
...@@ -71,5 +71,6 @@ public class TzsUserInfoDto extends BaseDto { ...@@ -71,5 +71,6 @@ public class TzsUserInfoDto extends BaseDto {
@ApiModelProperty(value = "年龄") @ApiModelProperty(value = "年龄")
private Integer age; private Integer age;
@ApiModelProperty(value = "人员内部编码")
private String innerPersonCode;
} }
...@@ -117,4 +117,9 @@ public class TzsUserInfo extends BaseEntity { ...@@ -117,4 +117,9 @@ public class TzsUserInfo extends BaseEntity {
*/ */
@TableField("amos_user_id") @TableField("amos_user_id")
private String amosUserId; private String amosUserId;
/**
* 内部人员编码
*/
@TableField("inner_person_code")
private String innerPersonCode;
} }
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