Merge branch 'developer' of http://39.98.45.134:8090/moa/amos-boot-biz into developer

amos-boot-biz-common/src/main/java/com/yeejoin/amos/boot/biz/common/bo/ReginParams.java

@@ -32,14 +32,14 @@ public class ReginParams implements Serializable {
 
     @Data
     public static class BusinessInfo implements Serializable {
-        private Long amosBizCode;
-        private String companyName;
-        private Long companySequenceNbr;
-        private String companyType;
+        private Long amosBizCode; //平台企业code
+        private String companyName; //公司名称
+        private Long companySequenceNbr; //公司SequenceNbr（业务）
+        private String companyType; //公司类型
         private Long amosUserCode;
-        private String userName;
-        private Long userSequenceNbr;
-        private String userType;
+        private String userName; //用户名称
+        private Long userSequenceNbr; //用户sequenceNbr(业务)
+        private String userType; //用户类型
     }
 
     public BusinessInfo getBusinessInfo() {

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/NoticeStatusEnum.java

@@ -8,8 +8,8 @@ import lombok.Getter;
 public enum NoticeStatusEnum {
     已提交("已提交","0"),
     已接收("已接收","1"),
-    已退回("已退回","2"),
-    已通过("已通过","3");
+    已退回("已退回","0"),
+    已通过("已通过","1");
 
     String name;
     String statusId;

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/OrgEnum.java

@@ -11,7 +11,7 @@ import java.util.HashMap;
 public enum OrgEnum {
     公司("COMPANY", "244", "公司",1),
     部门("DEPARTMENT", "245", "部门",2),
-    人员("PERSON", "246", "人员",3),
+    普通人员("PERSON", "246", "普通人员",3),
     焊工("WELDER","247","焊工",3),
     建设单位负责人("CHARGE","254","建设单位负责人",3),
     企业管理员("ADMIN","248","企业管理员",3),
@@ -33,7 +33,7 @@ public enum OrgEnum {
 
     static {
         for(OrgPersonEnum orgPersonEnum:OrgPersonEnum.values()){
-            map.put(orgPersonEnum.getName(),orgPersonEnum.getKey());
+            map.put(orgPersonEnum.getKey(),orgPersonEnum.getName());
         }
     }
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/ProblemProcessEnum.java

@@ -19,7 +19,8 @@ public enum ProblemProcessEnum {
     超期整改发送短信("超期整改发送短信","8","CQZGFSDX"),
     问题分类("问题分类","9","WTFL"),
     转人工("转人工","10","ZRG"),
-    结束("结束","11","JS");
+    结束("结束","11","JS"),
+    重大问题整改完成发送短信("重大问题整改完成发送短信","12","ZDWTZGWCFSDX");
 
     private String Name;
     private String key;

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/ProjectInitiationEnum.java

 package com.yeejoin.amos.boot.module.ugp.api.Enum;
 
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
 import java.util.HashMap;
 import java.util.Map;
 
+@Getter
+@AllArgsConstructor
 public enum ProjectInitiationEnum {
-    项目立项("1","项目立项"),
-    平台审核("2","平台审核"),
-    告知申请("3","告知申请"),
-    接受告知("4","接受告知"),
-    审查项目("5","审查项目"),
-    提交资料("6","提交资料"),
-    审批人审批("7","审批人审批"),
-    审核人审核("8","审核人审核"),
-    监检科室分配("9","监检科室分配"),
-    监检员分配("10","监检员分配"),
-    监检员审核("11","监检员审核"),
-    项目关闭("12","项目关闭"),
-    接受审查意见("13","接受审查意见");
+    项目立项("1","项目立项","XMLX"),
+    平台审核("2","平台审核","PTSH"),
+    告知申请("3","告知申请","GZSQ"),
+    接受告知("4","接受告知","JSGZ"),
+    审查项目("5","审查项目","SCXM"),
+    提交资料("6","提交资料","TJZL"),
+    审批人审批("7","审批人审批","SPRSP"),
+    审核人审核("8","审核人审核","SHRSH"),
+    监检科室分配("9","监检科室分配","JJKSFP"),
+    监检员分配("10","监检员分配","JJYFP"),
+    监检员审核("11","监检员审核","JJYSH"),
+    项目关闭("12","项目关闭","XMGB"),
+    接受审查意见("13","接受审查意见","JSSCYJ");
 
     private String status;
     private String name;
+    private String code;
 
     public static Map<String,String> getNameByStatusMap = new HashMap<String,String>();
     public static Map<String,String> getStatusByNameMap = new HashMap<String,String>();
+    public static Map<String,String> getCodeByNameMap = new HashMap<String,String>();
     static {
         for(ProjectInitiationEnum projectInitiationEnum:ProjectInitiationEnum.values()){
             getNameByStatusMap.put(projectInitiationEnum.status,projectInitiationEnum.name);
             getStatusByNameMap.put(projectInitiationEnum.name, projectInitiationEnum.status);
+            getCodeByNameMap.put(projectInitiationEnum.name,projectInitiationEnum.code);
         }
     }
 
 
-
-
-    ProjectInitiationEnum(String status, String name) {
-        this.status = status;
-        this.name = name;
-    }
-
-    public String getStatus() {
-        return status;
-    }
-
-    public void setStatus(String status) {
-        this.status = status;
-    }
-
-    public String getName() {
-        return name;
-    }
-
-    public void setName(String name) {
-        this.name = name;
-    }
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/SMSEnum.java

@@ -10,7 +10,8 @@ public enum SMSEnum {
     项目立项驳回短信("项目立项驳回短信","SMS_UGP_0002"),
     质量问题短信("质量问题短信","SMS_UGP_0003"),
     重大质量问题短信("重大质量问题短信","SMS_UGP_0004"),
-    超期整改短信("超期整改短信","SMS_UGP_0005");
+    超期整改短信("超期整改短信","SMS_UGP_0005"),
+    重大问题整改完成短信("重大问题整改完成短信","SMS_UGP_0006");
 
 
     private String name;

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/StageEnum.java

@@ -32,16 +32,16 @@ public enum  StageEnum {
 
 
 
-    public static Map<String,String> getNameByStatusMap = new HashMap<>();
-    public static Map<String,String> getStatusByNameMap = new HashMap<>();
+    public static Map<String,String> getNameByNameMap = new HashMap<>();
+    public static Map<String,String> getStatusByVerifyNameMap = new HashMap<>();
     static {
         for(StageEnum enums:StageEnum.values()){
-            getNameByStatusMap.put(enums.stage,enums.name);
-            getStatusByNameMap.put(enums.name, enums.stage);
+            getNameByNameMap.put(enums.stage,enums.name);
+            getStatusByVerifyNameMap.put(enums.stage, enums.verifyName);
         }
     }
 
 
 
 
-}
+}
\ No newline at end of file

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/VerifyEnum.java

@@ -10,16 +10,20 @@ import java.util.Map;
 @AllArgsConstructor
 public enum VerifyEnum {
 
-    未通过("0","未通过"),
-    已通过("1","已通过");
+    未通过("0","未通过","智能检验"),
+    已通过("1","已通过","人工检验");
 
     private String status;
     private String name;
 
-    public static Map<String,String> getTaskStatus=new HashMap<>();
+    private String type;
+
+    public static Map<String,String> getTaskName=new HashMap<>();
+    public static Map<String,String> getTaskType=new HashMap<>();
     static {
         for (VerifyEnum verifyEnum : VerifyEnum.values()){
-            getTaskStatus.put(verifyEnum.status, verifyEnum.name);
+            getTaskName.put(verifyEnum.status, verifyEnum.name);
+            getTaskType.put(verifyEnum.status, verifyEnum.type);
         }
 
     }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/Enum/VerifyTypeEnum.java

+package com.yeejoin.amos.boot.module.ugp.api.Enum;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+import java.util.HashMap;
+import java.util.Map;
+
+@Getter
+@AllArgsConstructor
+public enum VerifyTypeEnum {
+
+    智能检验("0","智能检验"),
+    人工检验("1","人工检验");
+
+    private String status;
+    private String name;
+
+    public static Map<String,String> getVerifyname=new HashMap<>();
+    static {
+        for (VerifyTypeEnum verifyTypeEnum:VerifyTypeEnum.values() ){
+            getVerifyname.put(verifyTypeEnum.status, verifyTypeEnum.name);
+        }
+    }
+
+}

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/constants/XJConstant.java

@@ -21,9 +21,16 @@ public class XJConstant {
     public static final String CHECK_TYPE = "CHECK_TYPE";
     public static final String DEPT_WF_MAP_DIC_CODE = "DEPT_WF_MAP";
 
+
     /** 企业用户注册前缀 */
     public static final String UGP_USER_TEL = "ugp_tel_";
 
+    //审核/审批状态
+    public static final String PROCESS_PROJECT_STATE="processProjectState";
+    //监管科室
+    public static final String INS_DEP = "insDep";
+    public static final String INS_PRESON = "insPerson";
+
     /**
      * 构造方法
      */

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/AcceptDto.java

@@ -6,6 +6,8 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.util.Date;
+
 /**
  * @Author cpp
  * @Description
@@ -17,7 +19,64 @@ import lombok.EqualsAndHashCode;
 public class AcceptDto  extends BaseDto {
 
     private static final long serialVersionUID = 1L;
+   //人员信息
+    @ApiModelProperty(value = "项目id")
+    private Long projectId;
+    @ApiModelProperty(value = "焊口编号")
+    private String code;
+    @ApiModelProperty(value = "焊接定位信息")
+    private String peopleLocation;
+    @ApiModelProperty(value = "人脸识别图片信息")
+    private String peoplePhoto;
+    @ApiModelProperty(value = "人员id")
+    private String userId;
+    @ApiModelProperty(value = "阶段检验")
+    private String stage;
+
+   //设备
+   @ApiModelProperty(value = "设备id")
+   private String facilityId;
+    @ApiModelProperty(value = "检定状态")
+    private String calibrationStatus;
+    @ApiModelProperty(value = "设备图片")
+    private String facilityPhoto;
+    //管材
+    @ApiModelProperty(value = "管材id")
+    private String materialId;
+    @ApiModelProperty(value = "管材图片信息")
+    private String materialPhoto;
+
+    //工艺
+    @ApiModelProperty(value = "焊接工艺")
+    private String craft;
+    @ApiModelProperty(value = "焊机设备id")
+    private String weldingId;
+    @ApiModelProperty(value = "工艺图片")
+    private String craftPhoto;
+    //埋深
+    @ApiModelProperty(value = "埋深检测方式")
+    private String depthType;
+     @ApiModelProperty(value = "埋深")
+     private String depth;
+     @ApiModelProperty(value = "埋深定位信息")
+     private String depthLocation;
+     @ApiModelProperty(value = "埋深图片信息")
+     private String depthPhoto;
 
+    //耐压
+    @ApiModelProperty(value = "耐压设备id")
+    private String pressureId;
+    @ApiModelProperty(value = "压力测试")
+    private String pressureTest;
+    @ApiModelProperty(value = "耐压测试定位信息")
+    private String pressureLocation;
+    @ApiModelProperty(value = "耐压图片信息")
+    private String pressurePhoto;
+    //定位
+    @ApiModelProperty(value = "焊口精确定位方式")
+    private String locationType;
+   @ApiModelProperty(value = "图片信息")
+   private String locationPhoto;
 
 
 

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/InstallNoticePageDto.java

@@ -68,4 +68,8 @@ public class InstallNoticePageDto extends BaseDto {
     @ApiModelProperty(value = "告知申请提交日期")
     private String noticeDate;
 
+    private Boolean approved;
+
+    public String approvedName;
+
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/ProjectDto.java

 package com.yeejoin.amos.boot.module.ugp.api.dto;
 
+import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.annotation.TableField;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
@@ -85,5 +86,21 @@ public class ProjectDto  extends BaseDto {
     @ApiModelProperty(value = "备注")
     private String remark;
 
+    /**
+     * 监检部门
+     */
+    private String inspectionUnit;
+    /**
+     * 监察部门
+     */
+    private String superviseDept;
 
+    private JSONArray subForm;
+
+    private String examineProjectState;
+
+    private String processProjectState;
+
+    private String insDep;
+    private String insPerson;
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/ProjectMaterialDto.java

+package com.yeejoin.amos.boot.module.ugp.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 材料信息表
+ *
+ * @author system_generator
+ * @date 2022-09-22
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="MaterialDto", description="材料信息表")
+public class ProjectMaterialDto extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+
+    @ApiModelProperty(value = "名称")
+    private String name;
+
+    @ApiModelProperty(value = "项目id")
+    private Long companyId;
+
+    @ApiModelProperty(value = "管材编号")
+    private String code;
+
+    @ApiModelProperty(value = "管材类别")
+    private String type;
+
+    @ApiModelProperty(value = "管材规格")
+    private String spec;
+
+    @ApiModelProperty(value = "管材壁厚")
+    private Integer wallThickness;
+
+    @ApiModelProperty(value = "生产厂家")
+    private String manufacturer;
+
+    @ApiModelProperty(value = "生产日期")
+    private Date manufactureDate;
+
+    @ApiModelProperty(value = "生产编号")
+    private String batchNum;
+
+    @ApiModelProperty(value = "管道直径")
+    private Double diameter;
+
+    @ApiModelProperty(value = "管道材料")
+    private String material;
+
+    @ApiModelProperty(value = "管道长度")
+    private Double length;
+
+    @ApiModelProperty(value = "厂家所在地")
+    private String manufactureAddr;
+
+    @ApiModelProperty(value = "是否审批通过（1通过，0未通过）")
+    private Boolean approved;
+
+    @ApiModelProperty(value = "单位机构代码")
+    private String orgCode;
+
+    @ApiModelProperty(value = "项目名称")
+    private String  projectName;
+
+    @ApiModelProperty(value = "项目资源id")
+    private Long  projectResourceId;
+}

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/SmartListDto.java

+package com.yeejoin.amos.boot.module.ugp.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * @Author cpp
+ * @Description  智能监检列表
+ * @Date 2022/10/19
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="SmartListDto", description="智能监检列表")
+public class SmartListDto extends BaseDto {
+
+    @ApiModelProperty(value = "项目id")
+    private Long projectId;
+    @ApiModelProperty(value = "项目名称")
+    private String name;
+
+    @ApiModelProperty(value = "项目编号")
+    private String projectCode;
+
+    @ApiModelProperty(value = "检验检测单位")
+    private String companyName;
+
+    @ApiModelProperty(value = "检验负责人")
+    private String usrName;
+
+    @ApiModelProperty(value = "检验员")
+    private String inspector;
+
+    @ApiModelProperty(value = "检验状态")
+    private String status;
+
+    @ApiModelProperty(value = "检验方式")
+    private String type;
+
+    @ApiModelProperty(value = "交检日期")
+    private Date submitTime;
+
+    @ApiModelProperty(value = "检验时间")
+    private Date verifyTime;
+
+    //管材
+    @ApiModelProperty(value = "焊口编号")
+    private String code;
+    @ApiModelProperty(value = "管材厂家")
+    private String manufacturer;
+    @ApiModelProperty(value = "管材批号")
+    private String batchNumber;
+    @ApiModelProperty(value = "质量许可")
+    private String permission;
+    @ApiModelProperty(value = "焊工编号")
+    private String personWeld;
+    @ApiModelProperty(value = "管材定位信息")
+    private String tubularlocatingInformation;
+
+    //设备
+    @ApiModelProperty(value = "焊机编号")
+    private String facilityNumber;
+    @ApiModelProperty(value = "焊机名称")
+    private String facilityName;
+    @ApiModelProperty(value = "焊机定位信息")
+    private String facilityLocation;
+    @ApiModelProperty(value = "检定状态")
+    private String facilityStatus;
+
+
+
+    //人员
+    @ApiModelProperty(value = "焊工姓名")
+    private String peopleName;
+    @ApiModelProperty(value = "持证状态")
+    private String peopleStatus;
+    @ApiModelProperty(value = "焊接定位信息")
+    private String peopleLocation;
+
+     // 工艺
+     @ApiModelProperty(value = "焊接工艺")
+     private String craft;
+
+    @ApiModelProperty(value = "焊接时长")
+    private String duration;
+
+    //耐压
+    @ApiModelProperty(value = "耐压测试编号")
+    private String pressureNumber;
+    @ApiModelProperty(value = "耐压设备名称")
+    private String pressureName;
+    @ApiModelProperty(value = "耐压设备编码")
+    private String pressureCode;
+    @ApiModelProperty(value = "测试压力Mpa")
+    private String mpa;
+    @ApiModelProperty(value = "耐压测试定位")
+    private String pressureLocation;
+
+    //敷设位置标定检验
+    @ApiModelProperty(value = "焊口精确定位方式")
+    private String preciseWeldingPosition;
+    @ApiModelProperty(value = "位置标定检验结果")
+    private String resuts;
+
+
+    @ApiModelProperty(value = "检验检测阶段")
+    private String stage;
+
+
+
+
+
+}

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/SuperviseRuleDto.java

@@ -26,7 +26,7 @@ public class SuperviseRuleDto  extends BaseDto {
     private String adminRegion;
 
     @ApiModelProperty(value = "行政区域代码")
-    private String adminRegionCode;
+    private Integer adminRegionCode;
 
     @ApiModelProperty(value = "监察部门id")
     private Long superviseDeptId;

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/entity/Project.java

@@ -148,5 +148,4 @@ public class Project extends BaseEntity {
      */
     @TableField("remark")
     private String remark;
-
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/entity/SuperviseRule.java

@@ -32,7 +32,7 @@ public class SuperviseRule extends BaseEntity {
      * 行政区域代码
      */
 	@TableField("admin_region_code")
-    private String adminRegionCode;
+    private Integer adminRegionCode;
 
     /**
      * 监察部门id

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/mapper/ProjectMapper.java

 package com.yeejoin.amos.boot.module.ugp.api.mapper;
 
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectDto;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
 import org.springframework.web.bind.annotation.RequestParam;
 
+import java.util.Map;
+
 /**
  * 项目信息表 Mapper 接口
  *
@@ -18,4 +21,6 @@ public interface ProjectMapper extends BaseMapper<Project> {
     //通过name查询一条数据
     ProjectDto selectOneByName(@RequestParam String name);
 
+    ProjectDto getDetail(Long sequenceNbr);
+
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/mapper/ProjectResourceMapper.java

@@ -2,9 +2,7 @@ package com.yeejoin.amos.boot.module.ugp.api.mapper;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.yeejoin.amos.boot.module.ugp.api.dto.InstallNoticeMsgPageDto;
-import com.yeejoin.amos.boot.module.ugp.api.dto.MaterialDto;
-import com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.*;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Material;
 import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
@@ -31,6 +29,8 @@ public interface ProjectResourceMapper extends BaseMapper<ProjectResource> {
     WelderEquipmentDto customSelectById(@Param("sequenceNbr") Long sequenceNbr);
 
     //管材页面分页,根据名称、编号筛选
-    Page<MaterialDto>  MaterialPage(IPage<MaterialDto> page ,@Param("name") String name, @Param("code") String code);
+    Page<ProjectMaterialDto>  MaterialPage(IPage<ProjectMaterialDto> page ,@Param("name") String name, @Param("code") String code);
 
+    //根据resource_id删除项目焊工人员信息
+    Boolean deleteByResourceId(Long resourceId);
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/mapper/WeldMapper.java

@@ -19,4 +19,7 @@ public interface WeldMapper extends BaseMapper<Weld> {
    @Select ("select project_id,super_inspec_status from tz_ugp_weld where project_id =#{projectId}")
     List<WeldDto> select(Long projectId);
 
+   @Select("SELECT * from tz_ugp_weld where code = #{code} and project_id =#{projectId}")
+    Weld getWeldByCodeAndProjectId(String code,Long projectId);
+
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/service/IProjectResourceService.java

@@ -9,14 +9,14 @@ import org.aspectj.weaver.ast.Test;
  * 项目资源表（包括焊工、管材、设备）接口类
  *
  * @author system_generator
- * @date 2022-09-22
+ * @date 2022-10-21
  */
 public interface IProjectResourceService {
 
     //焊机设备表
     Page<WelderEquipmentDto> installNoticeMsgList(Page<WelderEquipmentDto> page, String name, String type);
     //焊机设备页面分页查询
-    Page<WelderEquipmentDto> selectByName(Page<WelderEquipmentDto> page, String name ,String unit);
+    WelderEquipmentDto selectByName(Long sequenceNbr);
 
     Page<WelderEquipmentDto> selectByInfo(Page<WelderEquipmentDto> page, Test info , String unit);
     //根据sequenceNbr查询列表数据

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/service/IVerifyService.java

 package com.yeejoin.amos.boot.module.ugp.api.service;
 
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.yeejoin.amos.boot.module.ugp.api.dto.FacilityDto;
-import com.yeejoin.amos.boot.module.ugp.api.dto.IntelligentInspectionDto;
-import com.yeejoin.amos.boot.module.ugp.api.dto.TubingDto;
-import com.yeejoin.amos.boot.module.ugp.api.dto.WorkerDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.SmartListDto;
 
 /**
  * 智能监检管理表接口类
@@ -13,9 +10,6 @@ import com.yeejoin.amos.boot.module.ugp.api.dto.WorkerDto;
  * @date 2022-09-22
  */
 public interface IVerifyService {
-
-    Page<TubingDto> selectInspection(Page<TubingDto> page, TubingDto dto);
-    Page<WorkerDto> selectWorker(Page<WorkerDto> page, WorkerDto dto);
-    Page<FacilityDto> selectFacility(Page<FacilityDto> page, FacilityDto dto);
+    Page<SmartListDto> commonality(String stage, Page<SmartListDto> page);
 
 }

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/resources/mapper/InstallNoticeMapper.xml

@@ -4,7 +4,7 @@
 
     <!--    查询安装告知申请页面-->
     <select id="installNoticePage" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.InstallNoticePageDto">
-        SELECT a.* ,u2.biz_org_name,u1.biz_org_name
+        SELECT a.* ,u2.biz_org_name AS inspectionUnit,u1.biz_org_name AS superviseDept
         FROM (SELECT
                   tz_ugp_install_notice.sequence_nbr,
                   tz_ugp_project.`NAME`,
@@ -17,7 +17,8 @@
                   supervise_dept_id,
                   inspection_unit_id,
                   notice_status,
-                  notice_date
+                  notice_date,
+                approved
               FROM
                   tz_ugp_install_notice
                       LEFT JOIN tz_ugp_project ON tz_ugp_install_notice.project_id = tz_ugp_project.sequence_nbr

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/resources/mapper/ProjectMapper.xml

@@ -9,4 +9,12 @@
         where name = #{name}
     </select>
 
+    <select id="getDetail" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.ProjectDto">
+        SELECT p.*,ou1.biz_org_name AS inspection_unit,ou2.biz_org_name AS supervise_dept
+        FROM tz_ugp_project AS p
+                 LEFT JOIN tz_ugp_supervise_rule AS r ON r.admin_region_code = p.install_region_code
+                 LEFT JOIN cb_org_usr AS ou1 ON ou1.sequence_nbr = r.inspection_unit_id
+                 LEFT JOIN cb_org_usr AS ou2 ON ou2.sequence_nbr = r.supervise_dept_id
+        WHERE p.sequence_nbr = #{sequenceNbr}
+    </select>
 </mapper>

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/resources/mapper/ProjectResourceMapper.xml

@@ -3,7 +3,9 @@
 <mapper namespace="com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper">
 
     <select id="WelderEquipment" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto">
-        SELECT tz_ugp_equipment.name,
+        SELECT
+        tz_ugp_project_resource.sequence_nbr,
+        tz_ugp_equipment.name,
         tz_ugp_equipment.code,
         tz_ugp_equipment.type,
         tz_ugp_project.name AS projectName,
@@ -14,98 +16,99 @@
         tz_ugp_equipment.verify_status,
         info,
         tz_ugp_project_resource.sequence_nbr as project_resource_id
-        FROM tz_ugp_project
-        inner join tz_ugp_project_resource on tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
-        and tz_ugp_project_resource.type = 'equipment'
-        inner join tz_ugp_equipment on tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
-        left join tz_ugp_attachment on tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id and
-        tz_ugp_attachment.type = 'enuipment'
-        <where>
+        FROM tz_ugp_project_resource
+        LEFT JOIN tz_ugp_project ON tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
+        LEFT JOIN tz_ugp_equipment ON tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
+        left join tz_ugp_attachment ON tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id
+        WHERE tz_ugp_project_resource.type = 'equipment'
             <if test="name != null and name != ''">
                 and tz_ugp_equipment.name like '%${name}%'
             </if>
             <if test="type != null and type != ''">
                 and tz_ugp_equipment.type like '%${type}%'
             </if>
-        </where>
     </select>
     <select id="selectByName" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto">
         SELECT tz_ugp_equipment.name,
         tz_ugp_equipment.code,
         tz_ugp_equipment.type,
-        tz_ugp_project.name as project_Name,
+        tz_ugp_project.name AS projectName,
+        tz_ugp_project.sequence_nbr AS projectId,
         tz_ugp_equipment.manufacturer,
         tz_ugp_equipment.manufacture_date,
         tz_ugp_equipment.service_life,
         tz_ugp_equipment.verify_status,
-        info
-        FROM tz_ugp_project
-        inner join tz_ugp_project_resource on tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
-        and tz_ugp_project_resource.type = 'equipment'
-        inner join tz_ugp_equipment on tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
-        left join tz_ugp_attachment on tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id and
-        tz_ugp_attachment.type = 'enuipment'
-        <where>
+        info,
+        tz_ugp_project_resource.sequence_nbr as project_resource_id
+        FROM tz_ugp_project_resource
+        LEFT JOIN tz_ugp_project ON tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
+        LEFT JOIN tz_ugp_equipment ON tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
+        left join tz_ugp_attachment ON tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id
+        WHERE tz_ugp_project_resource.type = 'equipment'
             <if test="name != null and name != ''">
                 and tz_ugp_project.name = #{name}
             </if>
             <if test="unit != null and unit != ''">
                 and tz_ugp_project.construction_unit_id = #{unit}
             </if>
-        </where>
     </select>
     <select id="selectByInfo" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto">
         SELECT tz_ugp_equipment.name,
         tz_ugp_equipment.code,
         tz_ugp_equipment.type,
-        tz_ugp_project.name AS project_Name,
+        tz_ugp_project.name AS projectName,
+        tz_ugp_project.sequence_nbr AS projectId,
         tz_ugp_equipment.manufacturer,
         tz_ugp_equipment.manufacture_date,
         tz_ugp_equipment.service_life,
         tz_ugp_equipment.verify_status,
-        info
-        FROM tz_ugp_project
-        inner join tz_ugp_project_resource on tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
-        and tz_ugp_project_resource.type = 'equipment'
-        inner join tz_ugp_equipment on tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
-        left join tz_ugp_attachment on tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id and
-        tz_ugp_attachment.type = 'enuipment'
-        <where>
+        info,
+        tz_ugp_project_resource.sequence_nbr as project_resource_id
+        FROM tz_ugp_project_resource
+        LEFT JOIN tz_ugp_project ON tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
+        LEFT JOIN tz_ugp_equipment ON tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
+        left join tz_ugp_attachment ON tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id
+        WHERE tz_ugp_project_resource.type = 'equipment'
             <if test="info != null and info != ''">
                 and tz_ugp_attachment.info = #{info}
             </if>
             <if test="unit != null and unit != ''">
                 and tz_ugp_attachment.company_id = #{unit}
             </if>
-        </where>
     </select>
     <select id="customSelectById"
             resultType="com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto">
         SELECT tz_ugp_equipment.name,
                tz_ugp_equipment.code,
                tz_ugp_equipment.type,
-               tz_ugp_project.name AS project_Name,
+               tz_ugp_project.name AS projectName,
+               tz_ugp_project.sequence_nbr AS projectId,
                tz_ugp_equipment.manufacturer,
                tz_ugp_equipment.manufacture_date,
                tz_ugp_equipment.service_life,
                tz_ugp_equipment.verify_status,
-               info
-        FROM tz_ugp_project
-                 inner join tz_ugp_project_resource on tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
-            and tz_ugp_project_resource.type = 'equipment'
-                 inner join tz_ugp_equipment on tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
-                 left join tz_ugp_attachment on tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id and
-                                                tz_ugp_attachment.type = 'enuipment'
-            where tz_ugp_equipment.sequence_nbr = #{sequenceNbr}
+               info,
+               tz_ugp_project_resource.sequence_nbr as project_resource_id
+        FROM tz_ugp_project_resource
+                 LEFT JOIN tz_ugp_project ON tz_ugp_project.sequence_nbr = tz_ugp_project_resource.project_id
+                 LEFT JOIN tz_ugp_equipment ON tz_ugp_project_resource.resource_id = tz_ugp_equipment.sequence_nbr
+                 left join tz_ugp_attachment ON tz_ugp_equipment.sequence_nbr = tz_ugp_attachment.source_id
+        WHERE tz_ugp_project_resource.type = 'equipment' and  tz_ugp_project_resource.sequence_nbr = #{sequenceNbr}
     </select>
 
 <!--    //管材页面分页,根据名称、编号筛选-->
-<!--    Page<MaterialDto>  MaterialPage(IPage<MaterialDto> page ,@Param("name") String name, @Param("code") String code);-->
-    <select id="MaterialPage" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.MaterialDto">
-        SELECT tz_ugp_material.* FROM tz_ugp_material,tz_ugp_project_resource ,tz_ugp_project
-        WHERE tz_ugp_project_resource.project_id=tz_ugp_project.sequence_nbr
-          AND  tz_ugp_project_resource.resource_id=tz_ugp_material.sequence_nbr
-          AND tz_ugp_project_resource.type="material"
+    <select id="MaterialPage" resultType="com.yeejoin.amos.boot.module.ugp.api.dto.ProjectMaterialDto">
+        SELECT tz_ugp_material.*,tz_ugp_project.name AS projectName ,tz_ugp_project_resource.sequence_nbr as projectResourceId
+        FROM  tz_ugp_project_resource
+                  LEFT JOIN tz_ugp_material ON tz_ugp_project_resource.resource_id=tz_ugp_material.sequence_nbr
+                  LEFT JOIN tz_ugp_project ON tz_ugp_project_resource.project_id=tz_ugp_project.sequence_nbr
+        WHERE tz_ugp_project_resource.type="material"
           AND tz_ugp_material.name LIKE  '%${name}%' AND tz_ugp_material.code LIKE '%${code}%'
     </select>
+
+    <!--    //根据resource_id删除项目焊工人员信息-->
+    <delete id="deleteByResourceId" >
+        delete  FROM tz_ugp_project_resource where resource_id=#{resourceId}
+    </delete>
+
 </mapper>

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/resources/mapper/VerifyMapper.xml

@@ -48,9 +48,10 @@
         vf.project_id =pt.sequence_nbr
         and
         pt.is_delete='0'
+        <if test="stage != '' and stage != null">
         and
 		vf.stage =#{stage}
-
+        </if>
     </select>
 
 </mapper>

amos-boot-system-ugp/amos-boot-module-ugp-biz/pom.xml

@@ -21,6 +21,17 @@
             <artifactId>amos-boot-module-common-biz</artifactId>
             <version>${amos-biz-boot.version}</version>
         </dependency>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-biz-common</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.24</version>
+        </dependency>
+
     </dependencies>
     <build>
         <plugins>

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/CompanyController.java

@@ -24,6 +24,7 @@ import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import com.yeejoin.amos.feign.privilege.model.CompanyModel;
+import com.yeejoin.amos.feign.privilege.model.RoleModel;
 import com.yeejoin.amos.feign.privilege.util.DesUtil;
 import com.yeejoin.amos.feign.systemctl.Systemctl;
 import com.yeejoin.amos.feign.systemctl.model.RegionModel;
@@ -79,6 +80,7 @@ public class CompanyController extends BaseController {
 	@Autowired
 	RedisUtils redisUtils;
 
+
     /**
      * 新增企业信息表
      *
@@ -195,58 +197,12 @@ public class CompanyController extends BaseController {
 	@PostMapping(value = "check")
 	@ApiOperation(httpMethod = "POST", value = "根据sequenceNbr更新，并创建单位及管理员", notes = "根据sequenceNbr更新，并创建单位及管理员")
 	public ResponseModel<Boolean> companyCheck(@RequestBody CompanyDto model,Long sequenceNbr,String bizOrgType) throws Exception{
-
-		Company company = companyServiceImpl.getById(sequenceNbr);
-		company.setApproved(model.getApproved());
-
-		if (company.getApproved().equals("已审核")){
-			final CompanyModel companyModel = new CompanyModel();
-			AgencyUserModel agencyUserModel = new AgencyUserModel();
-
-			//创建平台企业
-			companyModel.setCompanyName(company.getName());
-			companyModel.setCompanyCode(company.getCreditCode());
-			companyModel.setAddress(company.getAddress());
-			companyModel.setParentId(0L);
-			companyModel.setLevel("headquarter");
-			companyModel.setAgencyCode("ugp");
-			CompanyModel companyModelFeignClient = Privilege.companyClient.create(companyModel).getResult();
-
-			//创建平台用户
-			String adminName = company.getAdminName();
-			String adminLoginName = company.getAdminLoginName();
-			String adminPhone = company.getAdminTel();
-			String adminPassword = company.getAdminLoginPwd();
-			agencyUserModel.setRealName(adminName);
-			agencyUserModel.setAgencyCode("ugp");
-			agencyUserModel.setLockStatus("UNLOCK");
-			agencyUserModel.setMobile(adminPhone);
-			agencyUserModel.setCreateTime(new Date());
-			agencyUserModel.setUserName(adminLoginName);
-			agencyUserModel.setPassword(DesUtil.encode(adminPassword, secretKey));
-			agencyUserModel.setRePassword(DesUtil.encode(adminPassword, secretKey));
-			Privilege.agencyUserClient.create(agencyUserModel);
-
-			//企业动态表单存储
-			JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(company));
-			jsonObject.put("amosOrgId",companyModelFeignClient.getSequenceNbr());
-			jsonObject.put("amosOrgCode",companyModelFeignClient.getOrgCode());
-			orgServiceImpl.dataHandling(jsonObject,bizOrgType,null);
-
-			//企业管理员人员 动态表单存储
-			jsonObject = null;
-			jsonObject.put("name",adminName);
-			jsonObject.put("phone",adminPhone);
-			jsonObject.put("amosOrgId",agencyUserModel.getSequenceNbr());
-			jsonObject.put("amosOrgCode",agencyUserModel.getUserId());
-			orgServiceImpl.dataHandling(jsonObject, OrgEnum.企业管理员.getKey(),null);
-		}
-		return ResponseHelper.buildResponse(companyServiceImpl.updateById(company));
+		return ResponseHelper.buildResponse(companyServiceImpl.companyCheck(model,sequenceNbr,bizOrgType));
 	}
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
 	@PostMapping(value = "test")
-	@ApiOperation(httpMethod = "Post", value = "根据sequenceNbr更新，并创建单位及管理员", notes = "根据sequenceNbr更新，并创建单位及管理员")
+	@ApiOperation(httpMethod = "Post", value = "（测试）存储动态表单", notes = "（测试）存储动态表单")
 	public ResponseModel<OrgUsrDto> getInfo(@RequestBody JSONObject jsonObject, String bizOrgType,String sequenceNbr){
 		return ResponseHelper.buildResponse(orgServiceImpl.dataHandling(jsonObject,bizOrgType,sequenceNbr));
 	}

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/InstallNoticeController.java

@@ -197,12 +197,12 @@ public class InstallNoticeController extends BaseController {
 	public ResponseModel<InstallNoticeDto> saveInstallNotice(@RequestBody JSONObject object,@RequestParam(required = false) String noticeStatus ) {
 		InstallNoticeDto installNoticeDto = new InstallNoticeDto();
 
-//		final ProjectDto projectDto = projectServiceImpl.queryBySeq(object.getLong("name"));
+		final ProjectDto projectDto = projectServiceImpl.queryBySeq(object.getLong("name"));
 		installNoticeDto.setProjectId(object.getLong("name"));
 		installNoticeDto.setNoticeStatus(noticeStatus);
 		installNoticeDto.setNoticeDate(new Date());
 		installNoticeDto.setApproved(false);
-//		installNoticeDto.setOrganizationCode(orgServiceImpl.getOrgUsr().getBizOrgCode());
+		installNoticeDto.setOrganizationCode(orgServiceImpl.getOrgUsr().getBizOrgCode());
 		installNoticeDto.setLicenseNum(object.getString("licenseNum"));
 		installNoticeDto.setLicenseCompany(object.getString("licenseCompany"));
 		final JSONArray licenseAttch = object.getJSONArray("licenseAttch");
@@ -211,7 +211,7 @@ public class InstallNoticeController extends BaseController {
 		installNoticeDto.setLicenseAttch(JSON.toJSONString(licenseAttch));
 		installNoticeDto.setContractAttch(JSON.toJSONString(contractAttch));
 
-//		projectInitiationServiceImpl.execute(projectDto.getInstanceId(),installNoticeDto,"1");
+		projectInitiationServiceImpl.execute(projectDto.getInstanceId(),installNoticeDto,"1");
 		return  ResponseHelper.buildResponse(installNoticeServiceImpl.createWithModel(installNoticeDto));
 	}
 
@@ -284,9 +284,15 @@ public class InstallNoticeController extends BaseController {
 		return null;
 
 	}
+
+	/**
+	 * 监察部门接受安装告知
+	 * @param sequenceNbr
+	 * @return
+	 */
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
 	@PostMapping(value = "/acceptNotification")
-	@ApiOperation(httpMethod = "get", value = "接受告知", notes = "接受告知")
+	@ApiOperation(httpMethod = "get", value = "监察部门接受安装告知", notes = "监察部门接受安装告知")
 	public ResponseModel<Boolean> acceptNotification(Long sequenceNbr){
 		InstallNotice installNotice = installNoticeServiceImpl.getById(sequenceNbr);
 		installNotice.setNoticeStatus(NoticeStatusEnum.已接收.getName());
@@ -294,4 +300,23 @@ public class InstallNoticeController extends BaseController {
 		projectInitiationServiceImpl.execute(project.getInstanceId(),installNotice,NoticeStatusEnum.已接收.getStatusId());
 		return ResponseHelper.buildResponse(installNoticeServiceImpl.updateById(installNotice));
 	}
+
+	/**
+	 * 监检部门审查(通过/退回)安装告知
+	 * @param sequenceNbr
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@PostMapping(value = "/inspectNotification")
+	@ApiOperation(httpMethod = "get", value = "监检部门审查(通过/退回)安装告知", notes = "监检部门审查(通过/退回)安装告知")
+	public ResponseModel<Boolean> inspectNotification(Long sequenceNbr,String option){
+		InstallNotice installNotice = installNoticeServiceImpl.getById(sequenceNbr);
+		installNotice.setApproved(true);
+		if(NoticeStatusEnum.已退回.equals(option)){
+			installNotice.setApproved(false);
+		}
+		Project project = projectServiceImpl.getById(installNotice.getProjectId());
+		projectInitiationServiceImpl.execute(project.getInstanceId(),installNotice,option);
+		return ResponseHelper.buildResponse(installNoticeServiceImpl.updateById(installNotice));
+	}
 }

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/ProjectController.java

 package com.yeejoin.amos.boot.module.ugp.biz.controller;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
+import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
+import com.yeejoin.amos.boot.module.ugp.api.constants.XJConstant;
 import com.yeejoin.amos.boot.module.ugp.api.dto.MaterialDto;
 import com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto;
+import com.yeejoin.amos.boot.module.ugp.api.entity.Attachment;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
-import com.yeejoin.amos.boot.module.ugp.biz.service.impl.OrgServiceImpl;
-import com.yeejoin.amos.boot.module.ugp.biz.service.impl.ProjectInitiationServiceImpl;
+import com.yeejoin.amos.boot.module.ugp.biz.service.impl.*;
 import org.springframework.beans.BeanUtils;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -21,7 +26,6 @@ import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
-import com.yeejoin.amos.boot.module.ugp.biz.service.impl.ProjectServiceImpl;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
@@ -50,6 +54,11 @@ public class ProjectController extends BaseController {
 	ProjectInitiationServiceImpl projectInitiationService;
 	@Autowired
 	OrgServiceImpl orgServiceImpl;
+	@Autowired
+	EquipmentServiceImpl equipmentService;
+	@Autowired
+	AttachmentServiceImpl attachmentServiceImpl;
+
 
 	/**
 	 * 新增项目信息表
@@ -199,6 +208,63 @@ public class ProjectController extends BaseController {
 		return ResponseHelper.buildResponse(projectServiceImpl.list(wrapper));
 	}
 
+	/**
+	 * 项目审核
+	 * @param sequenceNbr
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@ApiOperation(httpMethod = "GET", value = "项目审核", notes = "项目审核")
+	@PostMapping(value = "/processProject")
+	public ResponseModel<String> processProject(String sequenceNbr,@RequestBody JSONObject json){
+		String option = json.getString(XJConstant.PROCESS_PROJECT_STATE);
+		Project project = projectServiceImpl.getById(sequenceNbr);
+		JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project));
+		jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核不通过");
+		if("1".equals(option)){
+			jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"审核通过");
+		}
+		projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
+		return ResponseHelper.buildResponse("ok");
+	}
+
+
+	/**
+	 * 审核员项目审核
+	 * @param sequenceNbr
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@ApiOperation(httpMethod = "GET", value = "审核员项目审核", notes = "审核员项目审核")
+	@PostMapping(value = "/insProcess")
+	public ResponseModel<String> insProcess(String sequenceNbr,@RequestBody JSONObject json){
+		String option = json.getString(XJConstant.PROCESS_PROJECT_STATE);
+		Project project = projectServiceImpl.getById(sequenceNbr);
+		JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(project));
+		jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"符合");
+		if("0".equals(option)){
+			jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"不符合且不需要整改");
+			projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
+			projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
+		}else if("2".equals(option)){
+			jsonObject.put(XJConstant.PROCESS_PROJECT_STATE,"不符合且需要重新提交资料");
+		}
+		projectInitiationService.execute(project.getInstanceId(),jsonObject,option);
+		return ResponseHelper.buildResponse("ok");
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@ApiOperation(httpMethod = "POST", value = "添加附件", notes = "添加附件")
+	@PostMapping(value = "/saveOrUpdateFile")
+	public ResponseModel<String> saveOrUpdateFile(@RequestBody JSONObject jsonObject){
+		return ResponseHelper.buildResponse(projectServiceImpl.saveOrUpdateFile(jsonObject));
+	}
 
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@ApiOperation(httpMethod = "GET", value = "通过sequenceNbr查询项目详情", notes = "通过sequenceNbr查询项目详情")
+	@GetMapping(value = "/getDetail")
+	public ResponseModel<ProjectDto> getDetail(Long sequenceNbr){
+		return ResponseHelper.buildResponse(projectServiceImpl.getDetail(sequenceNbr));
+	}
 }
 

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/ProjectResourceController.java

 package com.yeejoin.amos.boot.module.ugp.biz.controller;
 
+import com.netflix.ribbon.proxy.annotation.Http;
 import com.yeejoin.amos.boot.module.ugp.api.dto.MaterialDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectMaterialDto;
 import com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectMapper;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
+import com.yeejoin.amos.boot.module.ugp.biz.service.impl.MaterialServiceImpl;
 import org.springframework.web.bind.annotation.RequestMapping;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.Api;
@@ -43,6 +46,8 @@ public class ProjectResourceController extends BaseController {
 
     @Autowired
     ProjectResourceMapper projectResourceMapper;
+    @Autowired
+    MaterialServiceImpl materialServiceImpl;
 
     /**
      * 新增项目资源表（包括焊工、管材、设备）
@@ -92,9 +97,9 @@ public class ProjectResourceController extends BaseController {
      */
     @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
     @GetMapping(value = "/{sequenceNbr}")
-    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个项目资源表（包括焊工、管材、设备）", notes = "根据sequenceNbr查询单个项目资源表（包括焊工、管材、设备）")
-    public ResponseModel<ProjectResourceDto> selectOne(@PathVariable Long sequenceNbr) {
-        return ResponseHelper.buildResponse(projectResourceServiceImpl.queryBySeq(sequenceNbr));
+    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询焊机设备）", notes = "根据sequenceNbr查询焊机设备")
+    public ResponseModel<WelderEquipmentDto> selectOne(@PathVariable Long sequenceNbr) {
+        return ResponseHelper.buildResponse(projectResourceServiceImpl.customSelectById(sequenceNbr));
     }
 
     /**
@@ -149,6 +154,13 @@ public class ProjectResourceController extends BaseController {
         return ResponseHelper.buildResponse(projectResourceServiceImpl.installNoticeMsgList(page, name, type));
     }
 
+    @TycloudOperation(ApiLevel =  UserType.AGENCY,needAuth = false)
+    @GetMapping(value = "/selectByName")
+    @ApiOperation(httpMethod = "GET", value = "焊机设备分页查询", notes = "焊机设备分页查询")
+    public ResponseModel<WelderEquipmentDto> selectByName(Long sequenceNbr){
+        return ResponseHelper.buildResponse(projectResourceServiceImpl.selectByName(sequenceNbr));
+    }
+
     /**
      * 项目设备新增
      */
@@ -190,15 +202,30 @@ public class ProjectResourceController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
     @GetMapping(value = "/materialPage")
     @ApiOperation(httpMethod = "GET", value = "焊机设备分页查询", notes = "焊机设备分页查询")
-    public ResponseModel<Page<MaterialDto>> queryForMaterialPage(
+    public ResponseModel<Page<ProjectMaterialDto>> queryForMaterialPage(
             @RequestParam(value = "current") int current,
             @RequestParam(value = "size") int size,
             @RequestParam(value = "name", required = false) String name,
             @RequestParam(value = "code", required = false) String code
     ) {
-        Page<MaterialDto> page = new Page<MaterialDto>();
+        Page<ProjectMaterialDto> page = new Page<ProjectMaterialDto>();
         page.setCurrent(current);
         page.setSize(size);
         return ResponseHelper.buildResponse(projectResourceMapper.MaterialPage(page,name,code));
     }
+
+    /**
+     * 根据sequenceNbr查询项目材料
+     *
+     * @param sequenceNbr  主键
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
+    @GetMapping(value = "IM/{sequenceNbr}")
+    @ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询材料和附件",  notes = "根据sequenceNbr查询材料和附件")
+    public ResponseModel<JSONObject> selectIMOne(@PathVariable Long sequenceNbr) {
+        JSONObject jsonObject = materialServiceImpl.groupBySeq(sequenceNbr);
+        jsonObject.getLong("sequenceNbr");
+        return ResponseHelper.buildResponse(materialServiceImpl.groupBySeq(sequenceNbr));
+    }
 }

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/SuperviseRuleController.java

@@ -64,7 +64,7 @@ public class SuperviseRuleController extends BaseController {
 //		getMap(map,result);
 //		//获取的Map中key是code，value是name
 //		model.setAdminRegion(map.get(model.getAdminRegionCode()));
-    	//外网调不到内网 暂时预留
+//    	//外网调不到内网 暂时预留
 //		OrgUsr orgUsr = orgServiceImpl.getOrgUsr();
 //		model.setSequenceNbr(orgUsr.getSequenceNbr());
 		model = superviseRuleServiceImpl.createWithModel(model);
@@ -139,7 +139,7 @@ public class SuperviseRuleController extends BaseController {
 	public ResponseModel<Page<SuperviseRuleDto>> queryForPage(
 			@RequestParam(value = "current") int current,
 			@RequestParam(value = "size") int size,
-			@RequestParam(value = "adminRegionCode", required = false) String adminRegionCode,
+			@RequestParam(value = "adminRegionCode", required = false) Integer adminRegionCode,
 			@RequestParam(value = "superviseDeptId", required = false) Long superviseDeptId,
 			@RequestParam(value = "inspectionUnitId", required = false) Long inspectionUnitId
 	) {
@@ -147,7 +147,7 @@ public class SuperviseRuleController extends BaseController {
 		Page<SuperviseRuleDto> page = new Page<SuperviseRuleDto>();
 	    page.setCurrent(current);
 	    page.setSize(size);
-	    return ResponseHelper.buildResponse(superviseRuleServiceImpl.queryForSuperviseRulePage(page, superviseDeptId, inspectionUnitId));
+	    return ResponseHelper.buildResponse(superviseRuleServiceImpl.queryForSuperviseRulePage(page, superviseDeptId, inspectionUnitId,adminRegionCode));
 	}
 
 	/**

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/VerifyController.java

 package com.yeejoin.amos.boot.module.ugp.biz.controller;
 
 import com.alibaba.fastjson.JSONObject;
+import com.yeejoin.amos.boot.module.ugp.api.Enum.StageEnum;
 import com.yeejoin.amos.boot.module.ugp.api.dto.*;
 import com.yeejoin.amos.boot.module.ugp.api.service.IVerifyService;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -111,7 +112,7 @@ public class VerifyController extends BaseController {
      *
 	 * @return
 	 */
-	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
 	@ApiOperation(httpMethod = "GET",value = "智能监检管理表列表全部数据查询",   notes = "智能监检管理表列表全部数据查询")
 	@GetMapping(value = "/list")
 	public ResponseModel<List<VerifyDto>> selectForList() {
@@ -126,46 +127,42 @@ public class VerifyController extends BaseController {
 
 
 
-
 	/**   cpp
 	 *
 	 *焊接管材检验信息列表
 	 * @param current
 	 * @param size
-	 * @param dto
 	 * @return
 	 */
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
-	@GetMapping(value = "/selectInspection")
+	@GetMapping(value = "/selectTubular")
 	@ApiOperation(httpMethod = "GET", value = "焊接管材检验信息列表", notes = "焊接管材检验信息列表")
-	public ResponseModel<Page<TubingDto>> selectInspection(@RequestParam(value = "current") int current, @RequestParam
-			(value = "size") int size, TubingDto dto) {
-		Page<TubingDto> page = new Page<>();
+	public ResponseModel<Page<SmartListDto>> selectTubular(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
 		page.setCurrent(current);
 		page.setSize(size);
-		return ResponseHelper.buildResponse(service.selectInspection(page,dto));
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前管材质量.getStage(),page));
 	}
-
-
 	/**   cpp
 	 *
 	 *查询焊接人员检验信息列表
 	 * @param current
 	 * @param size
-	 * @param dto
+	 * @param
 	 * @return
 	 */
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
 	@GetMapping(value = "/selectWorker")
 	@ApiOperation(httpMethod = "GET", value = "查询焊接人员检验信息列表", notes = "查询焊接人员检验信息列表")
-	public ResponseModel<Page<WorkerDto>> selectWorker(@RequestParam(value = "current") int current, @RequestParam
-			(value = "size") int size, WorkerDto dto) {
-		Page<WorkerDto> page = new Page<>();
+	public ResponseModel<Page<SmartListDto>> selectWorker(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
 		page.setCurrent(current);
 		page.setSize(size);
-		return ResponseHelper.buildResponse(service.selectWorker(page,dto));
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前人员.getStage(),page));
 	}
 
 	/**   cpp
@@ -173,41 +170,104 @@ public class VerifyController extends BaseController {
 	 *查询焊接设备检验信息列表
 	 * @param current
 	 * @param size
-	 * @param dto
 	 * @return
 	 */
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
 	@GetMapping(value = "/selectFacility")
 	@ApiOperation(httpMethod = "GET", value = "查询焊接设备检验信息列表", notes = "查询焊接设备检验信息列表")
-	public ResponseModel<Page<FacilityDto>> selectFacility(@RequestParam(value = "current") int current, @RequestParam
-			(value = "size") int size, FacilityDto dto) {
-		Page<FacilityDto> page = new Page<>();
+	public ResponseModel<Page<SmartListDto>> selectFacility(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
 		page.setCurrent(current);
 		page.setSize(size);
-		return ResponseHelper.buildResponse(service.selectFacility(page,dto));
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.焊前设备.getStage(),page));
 	}
+	/**   cpp
+	 *
+	 *查询焊接工艺检验信息列表
+	 * @param current
+	 * @param size
+	 * @return
+	 */
 
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@GetMapping(value = "/selectCraft")
+	@ApiOperation(httpMethod = "GET", value = "查询焊接工艺检验信息列表", notes = "查询焊接工艺检验信息列表")
+	public ResponseModel<Page<SmartListDto>> selectCraft(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
+		page.setCurrent(current);
+		page.setSize(size);
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.焊接工艺.getStage(),page));
+	}
+	/**   cpp
+	 *
+	 *查询管道耐压检验信息列表
+	 * @param current
+	 * @param size
+	 * @return
+	 */
 
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@GetMapping(value = "/selectVoltage")
+	@ApiOperation(httpMethod = "GET", value = "查询管道耐压检验信息列表", notes = "查询管道耐压检验信息列表")
+	public ResponseModel<Page<SmartListDto>> selectVoltage(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
+		page.setCurrent(current);
+		page.setSize(size);
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.管道耐压.getStage(),page));
+	}
 
+	/**   cpp
+	 *
+	 *敷设位置标定检验列表
+	 * @param current
+	 * @param size
+	 * @return
+	 */
 
-
-
+	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@GetMapping(value = "/selectLocation")
+	@ApiOperation(httpMethod = "GET", value = "敷设位置标定检验列表", notes = "敷设位置标定检验列表")
+	public ResponseModel<Page<SmartListDto>> selectLocation(@RequestParam(value = "current") int current, @RequestParam
+			(value = "size") int size) {
+		Page<SmartListDto> page = new Page<>();
+		page.setCurrent(current);
+		page.setSize(size);
+		return ResponseHelper.buildResponse(service.commonality(StageEnum.定位.getStage(),page));
+	}
 
 	/**
 	 *  cpp
-	 *
-	 *    校验
+	 *     校验
 	 * @param dto
 	 * @return
 	 */
-	@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+	@TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
 	@PostMapping(value = "/checks")
 	@ApiOperation(httpMethod = "POST", value = "校验app上传数据", notes = "校验app上传数据")
 	public ResponseModel<String> checks(@RequestBody AcceptDto dto) {
 		return ResponseHelper.buildResponse(verifyServiceImpl.checks(dto));
 	}
 
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
 	/**
 	 * 焊接工艺效验
 	 */

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/controller/WelderController.java

 package com.yeejoin.amos.boot.module.ugp.biz.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.module.common.api.dto.OrgUsrDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.InstallNoticeDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectDto;
 import com.yeejoin.amos.boot.module.ugp.api.dto.WelderDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.WelderEquipmentDto;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectMapper;
+import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectResourceMapper;
 import com.yeejoin.amos.boot.module.ugp.biz.service.impl.OrgServiceImpl;
+import com.yeejoin.amos.boot.module.ugp.biz.service.impl.ProjectResourceServiceImpl;
 import com.yeejoin.amos.boot.module.ugp.biz.service.impl.ProjectServiceImpl;
 import com.yeejoin.amos.boot.module.ugp.biz.service.impl.WelderServiceImpl;
 import io.swagger.annotations.Api;
@@ -22,6 +28,7 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
+import javax.servlet.http.HttpServletRequest;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -44,6 +51,12 @@ public class WelderController extends BaseController {
 
     @Autowired
     OrgServiceImpl orgServiceImpl;
+
+    @Autowired
+    ProjectResourceMapper projectResourceMapper;
+
+    @Autowired
+    ProjectResourceServiceImpl  projectResourceServiceImpl;
     /**
      * 新增/修改焊工信息
      *
@@ -51,10 +64,10 @@ public class WelderController extends BaseController {
      */
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @RequestMapping(value = "/saveWelder", method = RequestMethod.POST)
-    @ApiOperation(httpMethod = "POST", value = "新增焊工信息", notes = "新增焊工信息")
+    @ApiOperation(httpMethod = "POST", value = "新增人员信息", notes = "新增人员信息")
     public ResponseModel<OrgUsrDto> saveWelder(@RequestBody JSONObject jsonObject, @RequestParam String bizOrgType ,
                                             @RequestParam(required = false) String sequenceNbr) {
-        return ResponseHelper.buildResponse(orgServiceImpl.dataHandling(jsonObject,bizOrgType,sequenceNbr));
+        return ResponseHelper.buildResponse(welderServiceImpl.savePerson(jsonObject,bizOrgType,sequenceNbr));
     }
 
     /**
@@ -93,6 +106,16 @@ public class WelderController extends BaseController {
     }
 
     /**
+     * 项目焊工人员删除
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
+    @DeleteMapping(value = "/delWelder/{sequenceNbr}")
+    @ApiOperation(httpMethod = "Delete", value = "项目焊工人员删除", notes = "项目焊工人员删除")
+    public ResponseModel<Boolean> deleteByResourceId(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
+        return ResponseHelper.buildResponse(projectResourceMapper.deleteByResourceId(sequenceNbr));
+    }
+
+    /**
      * 当前登陆人所在公司/单位/企业 下的 所有焊工人员分页查询
      * @param current 当前页
      * @param current 每页大小
@@ -112,28 +135,29 @@ public class WelderController extends BaseController {
     }
 
     /**
-     * 根据sequenceNbr查询焊工信息
+     * 根据sequenceNbr查询人员信息
      *
      * @param sequenceNbr 主键
      * @return
      */
     @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
     @GetMapping(value = "/{sequenceNbr}")
-    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询项目焊工信息表", notes = "根据sequenceNbr查询项目焊工信息表")
+    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询人员信息", notes = "根据sequenceNbr查询人员信息")
     public ResponseModel<Map> selectOneById(@PathVariable String sequenceNbr) {
         return ResponseHelper.buildResponse(orgServiceImpl.getdetialInfo(sequenceNbr));
     }
 
     /**
-     * 根据sequenceNbr删除焊工信息
+     * 根据sequenceNbr删除人员信息表
      *
      * @param sequenceNbr 主键
      * @return
      */
     @TycloudOperation(ApiLevel = UserType.AGENCY,needAuth = false)
     @DeleteMapping(value = "/{sequenceNbr}")
-    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr删除项目焊工信息表", notes = "根据sequenceNbr删除项目焊工信息表")
+    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr删除人员信息表", notes = "根据sequenceNbr删除人员信息表")
     public void deleteOneById(@PathVariable String sequenceNbr) throws Exception {
         orgServiceImpl.delectInfo(sequenceNbr);
     }
+
 }

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/CompanyServiceImpl.java

@@ -5,26 +5,36 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.AbstractWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
-import com.yeejoin.amos.boot.module.ugp.api.Enum.CompanyTypeEnum;
 import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Company;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.CompanyMapper;
 import com.yeejoin.amos.boot.module.ugp.api.service.ICompanyService;
 import com.yeejoin.amos.boot.module.ugp.api.dto.CompanyDto;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
+import com.yeejoin.amos.feign.privilege.model.RoleModel;
+import com.yeejoin.amos.feign.privilege.util.DesUtil;
 import org.apache.lucene.queryparser.flexible.messages.Message;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import javax.annotation.Resource;
 import java.text.SimpleDateFormat;
+
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 import java.util.Locale;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -41,6 +51,12 @@ public class CompanyServiceImpl extends BaseService<CompanyDto, Company, Company
     @Autowired
     ICompanyService iCompanyService;
 
+    @Value("${amos.secret.key}")
+    String secretKey;
+
+    @Autowired
+    OrgServiceImpl orgServiceImpl;
+
     /**
      * 列表查询 示例
      */
@@ -68,21 +84,74 @@ public class CompanyServiceImpl extends BaseService<CompanyDto, Company, Company
 
 
 
-    /**
-     * 企业注册：3、账号信息提交
-     * @param object
-     * @return
-     */
-//
-//    public String saveInfo(Object object){
-//        JSONObject obj = JSONObject.parseObject(JSON.toJSONString(object));
-//        String name = obj.getString("name");
-//        String creditCode = obj.getString("creditCode");
-//        String createTime = obj.getString("createTime");
-//        String unitTel =
-//
-//        return null;
-//    }
 
+    public Boolean companyCheck(CompanyDto model, Long sequenceNbr, String bizOrgType) throws Exception{
+        Set<String> roleNameSet = new HashSet<>();
+        List<RoleModel> userRoleList = new ArrayList<>();
+        List<Long> roleIds = new ArrayList<>();
+        Map<Long, List<Long>> roleSeqsMap = new HashMap<>();
+        Map<Long,List<RoleModel>> orgRoles = new HashMap<>();
+
+        Company company = this.getById(sequenceNbr);
+        company.setApproved(model.getApproved());
+
+        if (company.getApproved().equals("已审核")){
+            final CompanyModel companyModel = new CompanyModel();
+            AgencyUserModel agencyUserModel = new AgencyUserModel();
+
+            //创建平台企业
+            companyModel.setCompanyName(company.getName());
+            companyModel.setCompanyCode(company.getCreditCode());
+            companyModel.setAddress(company.getAddress());
+            companyModel.setParentId(0L);
+            companyModel.setLevel("headquarter");
+            companyModel.setAgencyCode("ugp");
+            CompanyModel companyModelFeignClient = Privilege.companyClient.create(companyModel).getResult();
+
+        //创建平台用户
+            //设置用户角色
+            List<RoleModel> allRoleList = Privilege.roleClient.queryRoleList(null,null).getResult();
+            String[] unitTypeCodes = company.getType().split(",");
+            for(String code : unitTypeCodes) {
+                roleNameSet.add(OrgEnum.map.get(code));
+            }
+            userRoleList = allRoleList.stream().filter(r -> r.getRoleName().equals(roleNameSet)).collect(Collectors.toList());
+            userRoleList.stream().forEach(r -> {
+                roleIds.add(r.getSequenceNbr());
+            });
+            roleSeqsMap.put(companyModelFeignClient.getSequenceNbr(),roleIds);
+            orgRoles.put(companyModelFeignClient.getSequenceNbr(),userRoleList);
+            agencyUserModel.setOrgRoleSeqs(roleSeqsMap);
+            agencyUserModel.setOrgRoles(orgRoles);
+            //设置用户信息
+            String adminName = company.getAdminName();
+            String adminLoginName = company.getAdminLoginName();
+            String adminPhone = company.getAdminTel();
+            String adminPassword = company.getAdminLoginPwd();
+            agencyUserModel.setRealName(adminName);
+            agencyUserModel.setAgencyCode("ugp");
+            agencyUserModel.setLockStatus("UNLOCK");
+            agencyUserModel.setMobile(adminPhone);
+            agencyUserModel.setCreateTime(new Date());
+            agencyUserModel.setUserName(adminLoginName);
+            agencyUserModel.setPassword(DesUtil.encode(adminPassword, secretKey));
+            agencyUserModel.setRePassword(DesUtil.encode(adminPassword, secretKey));
+            Privilege.agencyUserClient.create(agencyUserModel);
+
+            //企业动态表单存储
+            JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(company));
+            jsonObject.put("amosOrgId",companyModelFeignClient.getSequenceNbr());
+            jsonObject.put("amosOrgCode",companyModelFeignClient.getOrgCode());
+            orgServiceImpl.dataHandling(jsonObject,bizOrgType,null);
+
+            //企业管理员人员 动态表单存储
+            jsonObject = null;
+            jsonObject.put("name",adminName);
+            jsonObject.put("phone",adminPhone);
+            jsonObject.put("amosOrgId",agencyUserModel.getSequenceNbr());
+            orgServiceImpl.dataHandling(jsonObject, OrgEnum.企业管理员.getKey(),null);
+        }
+        return this.updateById(company);
+    }
 
 }
\ No newline at end of file

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/InstallNoticeServiceImpl.java

 package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.yeejoin.amos.boot.module.ugp.api.dto.InstallNoticePageDto;
+import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectDto;
 import com.yeejoin.amos.boot.module.ugp.api.entity.InstallNotice;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.InstallNoticeMapper;
 import com.yeejoin.amos.boot.module.ugp.api.service.IInstallNoticeService;
 import com.yeejoin.amos.boot.module.ugp.api.dto.InstallNoticeDto;
 import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
 import org.springframework.stereotype.Service;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
+import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import java.sql.Wrapper;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -27,6 +37,8 @@ public class InstallNoticeServiceImpl extends BaseService<InstallNoticeDto,Insta
 
     @Autowired
     InstallNoticeMapper installNoticeMapper;
+    @Autowired
+    ProjectServiceImpl projectServiceImpl;
     /**
      * 分页查询
      */
@@ -45,7 +57,18 @@ public class InstallNoticeServiceImpl extends BaseService<InstallNoticeDto,Insta
      * 安装告知申请分页查询
      */
     public Page<InstallNoticePageDto> installNoticePage(Page<InstallNoticePageDto> page,String name,String constructionUnit)   {
-        return installNoticeMapper.installNoticePage(page,name,constructionUnit);
+        Page<InstallNoticePageDto> installNoticePage = installNoticeMapper.installNoticePage(page,name,constructionUnit);
+        List<InstallNoticePageDto> installNoticePageDtos = installNoticePage.getRecords();
+        for(InstallNoticePageDto installNoticePageDto:installNoticePageDtos){
+            if(!ValidationUtil.isEmpty(installNoticePageDto.getApproved())){
+                if(installNoticePageDto.getApproved()){
+                    installNoticePageDto.setApprovedName("通过");
+                }else{
+                    installNoticePageDto.setApprovedName("不通过");
+                }
+            }
+        }
+        return installNoticePage;
     }
 
     /**
@@ -56,4 +79,47 @@ public class InstallNoticeServiceImpl extends BaseService<InstallNoticeDto,Insta
     public InstallNoticeDto selectOneById(Long sequenceNbr){
         return installNoticeMapper.selectoneById(sequenceNbr);
     }
+
+    /**
+     * 新增安装告知申请,保存/提交
+     *
+     * @return
+     */
+     public InstallNoticeDto saveInstallNotice(JSONObject object, String noticeStatus ) {
+
+        InstallNoticeDto installNoticeDto = new InstallNoticeDto();
+//		final ProjectDto projectDto = projectServiceImpl.queryBySeq(object.getLong("name"));
+        installNoticeDto.setProjectId(object.getLong("name"));
+        installNoticeDto.setNoticeStatus(noticeStatus);
+        installNoticeDto.setNoticeDate(new Date());
+        installNoticeDto.setApproved(false);
+//		installNoticeDto.setOrganizationCode(orgServiceImpl.getOrgUsr().getBizOrgCode());
+        installNoticeDto.setLicenseNum(object.getString("licenseNum"));
+        installNoticeDto.setLicenseCompany(object.getString("licenseCompany"));
+        final JSONArray licenseAttch = object.getJSONArray("licenseAttch");
+        final JSONArray contractAttch = object.getJSONArray("contractAttch");
+        installNoticeDto.setLicenseAttch(JSON.toJSONString(licenseAttch));
+        installNoticeDto.setContractAttch(JSON.toJSONString(contractAttch));
+//		projectInitiationServiceImpl.execute(projectDto.getInstanceId(),installNoticeDto,"1");
+        return  installNoticeDto;
+    }
+
+    /**
+     * 根据sequenceNbr查询安装告知信息及附件
+     *
+     * @param sequenceNbr  主键
+     * @return
+     */
+    public JSONObject selectOneBySeq(Long sequenceNbr) {
+        final InstallNoticeDto installNoticeDto = selectOneById(sequenceNbr);
+        final ProjectDto projectDto = projectServiceImpl.queryBySeq(installNoticeDto.getProjectId());
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("name",projectDto.getSequenceNbr());
+        jsonObject.put("installRegion",projectDto.getInstallRegion());
+        jsonObject.put("licenseNum",installNoticeDto.getLicenseNum());
+        jsonObject.put("licenseCompany",installNoticeDto.getLicenseCompany());
+        jsonObject.put("licenseAttch",JSON.parseArray(installNoticeDto.getLicenseAttch()));
+        jsonObject.put("contractAttch",JSON.parseArray(installNoticeDto.getContractAttch()));
+        return jsonObject;
+    }
 }
\ No newline at end of file

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/OrgServiceImpl.java

@@ -18,8 +18,10 @@ import com.yeejoin.amos.boot.module.common.biz.service.impl.DynamicFormColumnSer
 import com.yeejoin.amos.boot.module.common.biz.service.impl.DynamicFormInstanceServiceImpl;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
+import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.DepartmentModel;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -129,16 +131,19 @@ public class OrgServiceImpl {
             orgUsr.setOrgExpandAttr1(jsonObject.getString("type"));
             orgUsr.setBizOrgCode(jsonObject.getString("creditCode"));
         }
-        if (OrgEnum.人员.getKey().equals(bizOrgType)){
+        if (OrgEnum.普通人员.getKey().equals(bizOrgType)){
             if (1==jsonObject.getInteger("isWelder")) {
                 orgUsr.setOrgExpandAttr1(OrgEnum.焊工.getKey());
+                orgUsr.setCode(getCode());
             }
             LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
             wrapper.eq(OrgUsr :: getAmosOrgId,String.valueOf(reginParams.getCompany().getSequenceNbr()));
             orgUsr.setParentId(String.valueOf(orgUsrServiceImpl.getOne(wrapper).getSequenceNbr()));
         }
         if (OrgEnum.部门.getKey().equals(bizOrgType)) {
-
+            LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(OrgUsr :: getAmosOrgId,String.valueOf(reginParams.getCompany().getSequenceNbr()));
+            orgUsr.setParentId(String.valueOf(orgUsrServiceImpl.getOne(wrapper).getSequenceNbr()));
         }
         //设置bizOrgCode
         if (orgUsr.getParentId() != null) {
@@ -154,6 +159,21 @@ public class OrgServiceImpl {
         return orgUsr;
     }
 
+    public String getCode(){
+        int c;
+        LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
+        wrapper.orderByDesc(OrgUsr::getCode).eq(OrgUsr::getOrgExpandAttr1,OrgEnum.焊工.getKey());
+        String code = orgUsrServiceImpl.list(wrapper).iterator().next().getCode();
+        if(ValidationUtil.isEmpty(code)){
+            c = 0001;
+        }else{
+            c = Integer.parseInt(code)+1;
+        }
+
+        String welderCode = OrgEnum.焊工.getKey() +"-"+ c;
+        return welderCode;
+    }
+
     /**
      * 用户单位信息redis获取
      **/
@@ -240,7 +260,7 @@ public class OrgServiceImpl {
         wrapper.eq(OrgUsr :: getAmosOrgId,String.valueOf(getReginParams().getCompany().getSequenceNbr()));
         LambdaQueryWrapper<OrgUsr> personWrapper = new LambdaQueryWrapper<>();
         personWrapper.eq(OrgUsr::getParentId,orgUsrServiceImpl.getOne(wrapper).getSequenceNbr())
-                .eq(OrgUsr :: getBizOrgType,OrgEnum.人员.getKey());
+                .eq(OrgUsr :: getBizOrgType,OrgEnum.普通人员.getKey());
         return orgUsrServiceImpl.list(personWrapper);
     }
 
@@ -286,7 +306,7 @@ public class OrgServiceImpl {
         OrgUsr orgUsr = getOrgUsrById(sequenceNbr);
         LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
         wrapper.like(OrgUsr :: getBizOrgCode,orgUsr.getBizOrgCode())
-                .eq(OrgUsr::getBizOrgType,OrgEnum.人员.getKey())
+                .eq(OrgUsr::getBizOrgType,OrgEnum.普通人员.getKey())
                 .ne(OrgUsr::getOrgExpandAttr1,OrgEnum.焊工.getKey());
         List<OrgUsr> orgUsrList = orgUsrServiceImpl.list(wrapper);
         return orgUsrList;
@@ -300,7 +320,7 @@ public class OrgServiceImpl {
     public void delectInfo(String sequencenNbr) throws Exception {
         OrgUsr orgUsr = getOrgUsrById(sequencenNbr);
         LambdaQueryWrapper<DynamicFormInstance> dynamicWrapper = new LambdaQueryWrapper<>();
-        if(OrgEnum.人员.getKey().equals(orgUsr.getBizOrgType())){
+        if(OrgEnum.普通人员.getKey().equals(orgUsr.getBizOrgType())){
             dynamicWrapper.eq(DynamicFormInstance::getInstanceId,sequencenNbr);
             alertFormValueServiceImpl.remove(dynamicWrapper);
         }else{
@@ -314,7 +334,34 @@ public class OrgServiceImpl {
                 throw new Exception("该企业/部门下还有人员，不可删除！");
             }
         }
+    }
+
+    /**
+     * 获取企业下的人员信息列表
+     * @param companyId 单位/企业id
+     * @return
+     */
+    public IPage getPersonInfo(String companyId,IPage page){
+        LambdaQueryWrapper<OrgUsr> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(OrgUsr :: getSequenceNbr ,companyId);
+        OrgUsr orgUsrCompany = orgUsrServiceImpl.getOne(wrapper);
 
+        LambdaQueryWrapper<OrgUsr> welderWrapper = new LambdaQueryWrapper<>();
+        welderWrapper.likeRight(OrgUsr :: getBizOrgCode,orgUsrCompany.getBizOrgCode()).eq(OrgUsr :: getBizOrgType, OrgEnum.普通人员.getKey());
+        List<OrgUsr> orgUsrList = new ArrayList<>();
+        if(ValidationUtil.isEmpty(page)){
+            orgUsrList = orgUsrServiceImpl.list(welderWrapper);
+            page = new Page();
+        }else{
+            orgUsrList = orgUsrServiceImpl.page(page,welderWrapper).getRecords();
+        }
 
+        List<Map> mapList = new ArrayList<>();
+        for (OrgUsr orgUsr : orgUsrList) {
+            Map map = getdetialInfo(String.valueOf(orgUsr.getSequenceNbr()));
+            mapList.add(map);
+        }
+        page.setRecords(mapList);
+        return page;
     }
 }

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/ProblemInitiationServiceImpl.java

@@ -4,13 +4,16 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.workflow.feign.WorkflowFeignService;
 import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.ugp.api.Enum.ProblemProcessEnum;
+import com.yeejoin.amos.boot.module.ugp.api.Enum.SMSEnum;
 import com.yeejoin.amos.boot.module.ugp.api.entity.*;
 import com.yeejoin.amos.feign.privilege.Privilege;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.CompanyModel;
 import com.yeejoin.amos.feign.systemctl.Systemctl;
 import com.yeejoin.amos.feign.systemctl.model.SmsRecordModel;
 import com.yeejoin.amos.feign.workflow.Workflow;
@@ -54,11 +57,15 @@ public class ProblemInitiationServiceImpl {
     @Autowired
     QualityProblemServiceImpl qualityProblemService;
 
-    private static String SMSCODE = "SMS_UGP_0003";
 
     @Value("${params.work.flow.problemDefinitionKey}")
     private String problemDefinitionKey;
 
+    @Value("supervisionRoleId")
+    private String supervisionRoleId;
+
+    @Value("installationRoleId")
+    private String installationRoleId;
 
     public String start(QualityProblem qualityProblem) {
         String instanceId = null;
@@ -80,6 +87,7 @@ public class ProblemInitiationServiceImpl {
         qualityProblem.setInstanceId(instanceId);
         qualityProblem.setStatus(projectInitiationService.getFlowTaskName(instanceId));
         qualityProblemService.updateById(qualityProblem);
+        sendSms(JSONObject.parseObject(JSONObject.toJSONString(qualityProblem)), SMSEnum.质量问题短信.getCode());
         return instanceId;
     }
 
@@ -96,7 +104,19 @@ public class ProblemInitiationServiceImpl {
 
         if (ProblemProcessEnum.重大问题发送短信.getName().equals(dataObject.getString("name"))) {
             if(!ValidationUtil.isEmpty(objectd)) {
-//                sendSms(object);
+                sendSms(object, SMSEnum.重大质量问题短信.getCode());
+            }
+        }
+
+        if (ProblemProcessEnum.超期整改发送短信.getName().equals(dataObject.getString("name"))) {
+            if(!ValidationUtil.isEmpty(objectd)) {
+                sendSms(object, SMSEnum.超期整改短信.getCode());
+            }
+        }
+
+        if (ProblemProcessEnum.重大问题整改完成发送短信.getName().equals(dataObject.getString("name"))) {
+            if(!ValidationUtil.isEmpty(objectd)) {
+                sendSms(object, SMSEnum.重大质量问题短信.getCode());
             }
         }
 
@@ -126,33 +146,75 @@ public class ProblemInitiationServiceImpl {
     }
 
 
-    public void sendSms(JSONObject object,String smsCode){
-        //设置短信发送的基本参数
-        HashMap<String, String> smsParams = new HashMap();
-        smsParams.put("smsCode", smsCode);
-        smsParams.put("companyName", object.getString("installationUnit"));
-        smsParams.put("projectName", object.getString("name"));
-        //条件构造器 通过项目id查出来的项目详情信息中的区域代码，在监管区域规则表中拿到详细信息中的监察部门id，在使用监察部门id查找到该部门下的用户List。
-        QueryWrapper<SuperviseRule> wrapper = new QueryWrapper<>();
-        wrapper.eq("admin_region_code", projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode());
-        String noticeUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId();
-        List<AgencyUserModel> agencyUserModelList = Privilege.agencyUserClient.queryByDepartmentId(Long.valueOf(noticeUnitId), null, null, null).getResult();
+    public void sendSms(JSONObject object, String smsCode){
+        Long sequenceNbr = object.getLong("sequenceNbr");
+        if(SMSEnum.项目安装告知申请.getCode().equals(smsCode)){
+            //设置短信发送的基本参数
+            HashMap<String, String> smsParams = new HashMap();
+            smsParams.put("smsCode", smsCode);
+            smsParams.put("projectName", object.getString("projectName"));
+            smsParams.put("problemDesc", object.getString("problemDesc"));
+            //条件构造器 通过项目id查出来的项目详情信息中的区域代码，在监管区域规则表中拿到详细信息中的监察部门id，在使用监察部门id拿到平台的监察部门id
+            LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode());
+            String noticeUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId();
+            sendMessage(sequenceNbr,noticeUnitId,smsParams,smsCode,supervisionRoleId);
+        }else if(SMSEnum.项目立项驳回短信.getCode().equals(smsCode)) {
+            //设置短信发送的基本参数
+            HashMap<String, String> smsParams = new HashMap();
+            smsParams.put("smsCode", smsCode);
+            smsParams.put("projectName", object.getString("projectName"));
+            smsParams.put("reviewInfo", object.getString("reviewInfo"));
+            //给监察发短信
+            LambdaQueryWrapper<SuperviseRule> wrapper = new LambdaQueryWrapper<>();
+            wrapper.eq(SuperviseRule::getAdminRegionCode, projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode());
+            String supervisionUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId();
+            sendMessage(sequenceNbr,supervisionUnitId,smsParams,smsCode,supervisionRoleId);
+            //给安装发短信
+            String installationUnitId = orgUsrServiceImpl.getById(projectServiceImpl.getById(object.getLong("projectId")).getInstallationUnitId()).getAmosOrgId();
+            sendMessage(sequenceNbr,installationUnitId,smsParams,smsCode,installationRoleId);
+        }
+
+    }
+
+
+    /**
+     * 发送短信
+     * @param sequenceNbr 任务id（项目/问题）
+     * @param noticeUnitId 平台目标企业id
+     * @param smsParams 短信参数
+     * @param smsCode 短信模板
+     * @param roleId 角色id
+     */
+    public void sendMessage(Long sequenceNbr,String noticeUnitId,HashMap<String, String> smsParams,String smsCode,String roleId){
+        //向noticeUnitId的部门发送短信
+        List<AgencyUserModel> agencyUserModelList = Privilege.agencyUserClient.queryByRoleId(roleId,null).getResult();
         //遍历用户List，拿到用户手机号、userId,来发短信、存短信日志。
         for (AgencyUserModel agencyUserModel : agencyUserModelList) {
-            LambdaQueryWrapper<OrgUsr> wrapperQueryWrapper = new LambdaQueryWrapper<>();
-            wrapperQueryWrapper.eq(OrgUsr::getAmosOrgCode,agencyUserModel.getUserId());
-
-            SmsRecordModel smsRecordModel = sendSmsMassage(SMSCODE, agencyUserModel.getMobile(), smsParams);
-            RectifyMsg rectifyMsg = new RectifyMsg();
-            if (ValidationUtil.isEmpty(smsRecordModel)) {
-                continue;
+            boolean bool = false;
+            List<CompanyModel> companyModelList = agencyUserModel.getCompanys();
+            for (CompanyModel companyModel : companyModelList) {
+                bool = companyModel.getSequenceNbr().equals(noticeUnitId);
+                if(bool){
+                    break;
+                }
+            }
+            if (bool) {
+                LambdaQueryWrapper<OrgUsr> wrapperQueryWrapper = new LambdaQueryWrapper<>();
+                wrapperQueryWrapper.eq(OrgUsr::getAmosOrgId,agencyUserModel.getSequenceNbr());
+
+                SmsRecordModel smsRecordModel = sendSmsMassage(smsCode, agencyUserModel.getMobile(), smsParams);
+                RectifyMsg rectifyMsg = new RectifyMsg();
+                if (ValidationUtil.isEmpty(smsRecordModel)) {
+                    continue;
+                }
+                rectifyMsg.setContent(smsRecordModel.getSmsContent());
+                rectifyMsg.setProblemId(sequenceNbr);
+                rectifyMsg.setNoticeUnitId(Long.valueOf(noticeUnitId));
+                rectifyMsg.setMsgReceiver(orgUsrServiceImpl.getOne(wrapperQueryWrapper).getSequenceNbr());
+                rectifyMsg.setSendTime(smsRecordModel.getSendTime());
+                rectifyMsgServiceImpl.save(rectifyMsg);
             }
-            rectifyMsg.setContent(smsRecordModel.getSmsContent());
-            rectifyMsg.setProblemId(object.getLong("sequenceNbr"));
-            rectifyMsg.setNoticeUnitId(Long.valueOf(noticeUnitId));
-            rectifyMsg.setMsgReceiver(orgUsrServiceImpl.getOne(wrapperQueryWrapper).getSequenceNbr());
-            rectifyMsg.setSendTime(smsRecordModel.getSendTime());
-            rectifyMsgServiceImpl.save(rectifyMsg);
         }
     }
 
@@ -167,6 +229,7 @@ public class ProblemInitiationServiceImpl {
         return smsRecordModel;
     }
 
+
     public void updateProBlemFlowStatus(String instanceId){
         LambdaQueryWrapper<QualityProblem> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(QualityProblem::getInstanceId,instanceId);

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/ProjectInitiationServiceImpl.java

@@ -80,6 +80,9 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
     @Autowired
     RectifyMsgServiceImpl rectifyMsgServiceImpl;
 
+    @Autowired
+    ProblemInitiationServiceImpl problemInitiationService;
+
     private final Logger logger = LoggerFactory.getLogger(ProjectInitiationServiceImpl.class);
 
     @Value("${params.work.flow.processDefinitionKey}")
@@ -140,22 +143,23 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
         }
         if(ProjectInitiationEnum.接受审查意见.getName().equals(dataObject.getString("name"))){
             projectInitiation.setTaskName(dataObject.getString("name")+"（流程结束！）");
+            if(!ValidationUtil.isEmpty(objectd)) {
+                problemInitiationService.sendSms(object, SMSEnum.项目立项驳回短信.getCode());
+            }
         }
 
         if (ProjectInitiationEnum.告知申请.getName().equals(dataObject.getString("name"))) {
             if(!ValidationUtil.isEmpty(objectd)) {
-                sendSms(object, SMSEnum.项目安装告知申请.getCode());
+                problemInitiationService.sendSms(object, SMSEnum.项目安装告知申请.getCode());
             }
         }
-        if ("监检科室分配".equals(dataObject.getString("name"))) {
-
-        }
-        if ("监检员分配".equals(dataObject.getString("name"))) {
 
+        if (ProjectInitiationEnum.项目关闭.getName().equals(dataObject.getString("name"))) {
+            if(!ValidationUtil.isEmpty(objectd)) {
+                problemInitiationService.sendSms(object, SMSEnum.项目立项驳回短信.getCode());
+            }
         }
-        if ("监检员审核".equals(dataObject.getString("name"))) {
 
-        }
 
         try {
             //组装信息
@@ -179,18 +183,6 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
         }
     }
 
-    @Transactional(rollbackFor = Exception.class)
-    public SmsRecordModel sendSmsMassage(String smsCode, String mobile, HashMap<String, String> smsParams){
-        SmsRecordModel smsRecordModel = new SmsRecordModel();
-
-        if(!ValidationUtil.isEmpty(mobile)){
-            smsParams.put("smsCode",smsCode);
-            smsParams.put("mobile",mobile);
-            smsRecordModel = Systemctl.smsClient.sendCommonSms(smsParams).getResult();
-        }
-        return smsRecordModel;
-    }
-
     /**
      * 获取流程当前任务名称
      * @param instanceId
@@ -209,37 +201,9 @@ public class ProjectInitiationServiceImpl extends BaseService<ProjectInitiationD
         LambdaQueryWrapper<Project> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(Project::getInstanceId,instanceId);
         Project project = projectService.getOne(wrapper);
-        project.setStatus(getFlowTaskName(instanceId));
+        project.setStatus(ProjectInitiationEnum.getCodeByNameMap.get(getFlowTaskName(instanceId)));
         projectService.updateById(project);
     }
 
-    public void sendSms(JSONObject object,String smsCode){
-        //设置短信发送的基本参数
-        HashMap<String, String> smsParams = new HashMap();
-        smsParams.put("smsCode", smsCode);
-        smsParams.put("companyName", object.getString("installationUnit"));
-        smsParams.put("projectName", object.getString("name"));
-        //条件构造器 通过项目id查出来的项目详情信息中的区域代码，在监管区域规则表中拿到详细信息中的监察部门id，在使用监察部门id查找到该部门下的用户List。
-        QueryWrapper<SuperviseRule> wrapper = new QueryWrapper<>();
-        wrapper.eq("admin_region_code", projectServiceImpl.getById(object.getLong("projectId")).getInstallRegionCode());
-        String noticeUnitId = orgUsrServiceImpl.getById(superviseRuleServiceImpl.getOne(wrapper).getSuperviseDeptId()).getAmosOrgId();
-        List<AgencyUserModel> agencyUserModelList = Privilege.agencyUserClient.queryByDepartmentId(Long.valueOf(noticeUnitId), null, null, null).getResult();
-        //遍历用户List，拿到用户手机号、userId,来发短信、存短信日志。
-        for (AgencyUserModel agencyUserModel : agencyUserModelList) {
-            LambdaQueryWrapper<OrgUsr> wrapperQueryWrapper = new LambdaQueryWrapper<>();
-            wrapperQueryWrapper.eq(OrgUsr::getAmosOrgCode,agencyUserModel.getUserId());
-
-            SmsRecordModel smsRecordModel = sendSmsMassage(smsCode, agencyUserModel.getMobile(), smsParams);
-            RectifyMsg rectifyMsg = new RectifyMsg();
-            if (ValidationUtil.isEmpty(smsRecordModel)) {
-                continue;
-            }
-            rectifyMsg.setContent(smsRecordModel.getSmsContent());
-            rectifyMsg.setProblemId(object.getLong("sequenceNbr"));
-            rectifyMsg.setNoticeUnitId(Long.valueOf(noticeUnitId));
-            rectifyMsg.setMsgReceiver(orgUsrServiceImpl.getOne(wrapperQueryWrapper).getSequenceNbr());
-            rectifyMsg.setSendTime(smsRecordModel.getSendTime());
-            rectifyMsgServiceImpl.save(rectifyMsg);
-        }
-    }
+
 }

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/ProjectResourceServiceImpl.java

@@ -62,8 +62,8 @@ public class ProjectResourceServiceImpl extends BaseService<ProjectResourceDto,P
     }
 
     @Override
-    public Page<WelderEquipmentDto> selectByName(Page<WelderEquipmentDto> page, String name, String unit) {
-        return null;
+    public WelderEquipmentDto selectByName(Long sequenceNbr) {
+        return this.projectResourceMapper.customSelectById(sequenceNbr);
     }
 
     @Override

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/ProjectServiceImpl.java

 package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
 
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.yeejoin.amos.boot.module.ugp.api.dto.MaterialDto;
+import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
+import com.yeejoin.amos.boot.module.ugp.api.constants.XJConstant;
 import com.yeejoin.amos.boot.module.ugp.api.dto.ProjectDto;
+import com.yeejoin.amos.boot.module.ugp.api.entity.Attachment;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectInitiation;
 import com.yeejoin.amos.boot.module.ugp.api.mapper.ProjectMapper;
 import com.yeejoin.amos.boot.module.ugp.api.service.IProjectService;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -25,11 +35,45 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project
     @Autowired
     ProjectMapper projectMapper;
 
+    @Autowired
+    AttachmentServiceImpl attachmentService;
+
+    @Autowired
+    ProjectInitiationServiceImpl projectInitiationService;
+
+    @Autowired
+    EquipmentServiceImpl equipmentService;
+
+
     /**
      * 分页查询
      */
     public Page<ProjectDto> queryForProjectPage(Page<ProjectDto> page ,String name,String constructionUnit) {
-        return this.queryForPage(page, null, false,name,constructionUnit);
+        Page<ProjectDto> projectDtoPage = this.queryForPage(page, null, false,name,constructionUnit);
+        List<ProjectDto> projects = projectDtoPage.getRecords();
+        for(ProjectDto project:projects){
+            getProjectState(project);
+        }
+        return projectDtoPage;
+    }
+
+    private void getProjectState(ProjectDto project) {
+        String state = "",insDep = "",insPerson = "";
+        LambdaQueryWrapper<ProjectInitiation> lambdaQueryWrap = new LambdaQueryWrapper<>();
+        lambdaQueryWrap.eq(ProjectInitiation::getInstanceId,project.getInstanceId())
+                .orderByDesc(ProjectInitiation::getSequenceNbr);
+
+        List<ProjectInitiation> projectInitiationList = projectInitiationService.list(lambdaQueryWrap);
+        if(!ValidationUtil.isEmpty(projectInitiationList)){
+            ProjectInitiation projectInitiation = projectInitiationList.iterator().next();
+            JSONObject jsonObject = JSON.parseObject(projectInitiation.getContext());
+            state = jsonObject.getString(XJConstant.PROCESS_PROJECT_STATE);
+            insDep = jsonObject.getString(XJConstant.INS_DEP);
+            insPerson = jsonObject.getString(XJConstant.INS_PRESON);
+        }
+        project.setExamineProjectState(state);
+        project.setInsDep(insDep);
+        project.setInsPerson(insPerson);
     }
 
 
@@ -64,8 +108,61 @@ public class ProjectServiceImpl extends BaseService<ProjectDto, Project, Project
      * @return
      */
     public List<Project> selectByidList(List<Long> ids){
-
         return projectMapper.selectBatchIds(ids);
+    }
+
+    public ProjectDto getDetail(Long sequenceNbr){
+
+        ProjectDto project = projectMapper.getDetail(sequenceNbr);
+        LambdaQueryWrapper<Attachment> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(Attachment::getSourceId,sequenceNbr);
+        try{
+            JSONArray jsonArray = JSON.parseArray(attachmentService.getOne(wrapper).getInfo());
+            project.setSubForm(jsonArray);
+        }catch (Exception e) {
+            System.out.println("该项目暂无附件");
+        }
+        project.getInstanceId();
+        getProjectState(project);
+        return project;
+    }
 
+
+    public String saveOrUpdateFile(JSONObject jsonObject){
+        JSONArray subForm = jsonObject.getJSONArray("subForm");
+        Long sequenceNbr = jsonObject.getLong("sequenceNbr");
+        LambdaQueryWrapper<Attachment> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(Attachment::getSourceId,sequenceNbr);
+        Attachment attachment = attachmentService.getOne(wrapper);
+        if(ValidationUtil.isEmpty(attachment)){
+            equipmentService.saveAttachment(subForm,sequenceNbr);
+        }else {
+            attachment.setInfo(JSON.toJSONString(subForm));
+            attachmentService.updateById(attachment);
+        }
+
+        Project project = this.getById(sequenceNbr);
+        ProjectDto projectDto = new ProjectDto();
+        BeanUtils.copyProperties(project,projectDto);
+        projectDto.setInsDep(jsonObject.getString("insDep"));
+        projectDto.setInsDep(jsonObject.getString("insPerson"));
+        projectDto.setProcessProjectState(jsonObject.getString("processProjectState"));
+        boolean design=false,install=false;
+        for(Object object:subForm){
+            JSONObject jo = JSON.parseObject(JSON.toJSONString(object));
+            String type = jo.getString("type");
+            if (OrgEnum.设计单位.getKey().equals(type)){
+                design=true;
+            }
+            if (OrgEnum.安装单位.getKey().equals(type)){
+                design=true;
+            }
+        }
+
+        if(design && install){
+            projectInitiationService.execute(project.getInstanceId(),projectDto,"1");
+        }
+        this.updateById(project);
+        return "ok";
     }
 }
\ No newline at end of file

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/SuperviseRuleServiceImpl.java

@@ -20,8 +20,11 @@ public class SuperviseRuleServiceImpl extends BaseService<SuperviseRuleDto,Super
     /**
      * 分页查询
      */
-    public Page<SuperviseRuleDto> queryForSuperviseRulePage(Page<SuperviseRuleDto> page, Long superviseDeptId, Long inspectionUnitId)   {
-        return this.queryForPage(page, null, false, superviseDeptId, inspectionUnitId );
+    public Page<SuperviseRuleDto> queryForSuperviseRulePage(Page<SuperviseRuleDto> page, Long superviseDeptId, Long inspectionUnitId,Integer adminRegionCode)   {
+        if(610000 == adminRegionCode){
+            return this.queryForPage(page, null, false, superviseDeptId, inspectionUnitId);
+        }
+        return this.queryForPage(page, null, false, superviseDeptId, inspectionUnitId,adminRegionCode );
     }
 
     /**

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/java/com/yeejoin/amos/boot/module/ugp/biz/service/impl/WelderServiceImpl.java

 package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
+import com.yeejoin.amos.boot.module.common.api.dto.OrgUsrDto;
+import com.yeejoin.amos.boot.module.ugp.api.Enum.OrgEnum;
 import com.yeejoin.amos.boot.module.ugp.api.Enum.ProjectResourceEnum;
 import com.yeejoin.amos.boot.module.ugp.api.entity.Project;
 import com.yeejoin.amos.boot.module.ugp.api.entity.ProjectResource;
 import com.yeejoin.amos.boot.module.ugp.biz.framework.BusinessIdentify;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.RoleModel;
+import com.yeejoin.amos.feign.privilege.util.DesUtil;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
+import java.util.stream.Collectors;
 
 @Service
 public class WelderServiceImpl {
@@ -27,6 +34,10 @@ public class WelderServiceImpl {
     @Autowired
     ProjectResourceServiceImpl projectResourceService;
 
+    @Value("${amos.secret.key}")
+    String secretKey;
+
+
 
     @BusinessIdentify
     public List<Map> getInfo(){
@@ -66,4 +77,52 @@ public class WelderServiceImpl {
         page.setTotal(getInfo().size());
         return page;
     }
+
+    /**
+     * 存人员信息至业务表及平台表
+     * @param jsonObject
+     * @param bizOrgType
+     * @param sequenceNbr
+     * @return
+     */
+    @BusinessIdentify
+    public OrgUsrDto savePerson(JSONObject jsonObject, String bizOrgType, String sequenceNbr){
+        Long companyId = orgService.getReginParams().getCompany().getSequenceNbr();
+        Set<String> roleNameSet = new HashSet<>();
+        List<RoleModel> userRoleList = new ArrayList<>();
+        List<Long> roleIds = new ArrayList<>();
+        Map<Long, List<Long>> roleSeqsMap = new HashMap<>();
+        AgencyUserModel agencyUserModel = new AgencyUserModel();
+        Map<Long,List<RoleModel>> orgRoles = new HashMap<>();
+        //用户基本信息
+        agencyUserModel.setRealName(jsonObject.getString("name"));
+        agencyUserModel.setAgencyCode("ugp");
+        agencyUserModel.setLockStatus("UNLOCK");
+        agencyUserModel.setMobile(jsonObject.getString("phone"));
+        agencyUserModel.setCreateTime(new Date());
+        agencyUserModel.setUserName(jsonObject.getString("phone"));
+        agencyUserModel.setPassword(DesUtil.encode(jsonObject.getString("phone"), secretKey));
+        agencyUserModel.setRePassword(DesUtil.encode(jsonObject.getString("phone"), secretKey));
+        //用户角色信息
+        List<RoleModel> allRoleList = Privilege.roleClient.queryRoleList(null,null).getResult();
+        if(1==jsonObject.getInteger("isWelder")){
+            roleNameSet.add(OrgEnum.焊工.getName());
+        } else {
+            roleNameSet.add(OrgEnum.普通人员.getName());
+        }
+        userRoleList = allRoleList.stream().filter(r -> r.getRoleName().equals(roleNameSet)).collect(Collectors.toList());
+        userRoleList.stream().forEach(r -> {
+            if (!roleIds.contains(r.getSequenceNbr())) {
+                roleIds.add(r.getSequenceNbr());
+            }
+        });
+        roleSeqsMap.put(companyId,roleIds);
+        orgRoles.put(companyId,userRoleList);
+        agencyUserModel.setOrgRoleSeqs(roleSeqsMap);
+        agencyUserModel.setOrgRoles(orgRoles);
+        //创建用户
+        agencyUserModel = Privilege.agencyUserClient.create(agencyUserModel).getResult();
+        jsonObject.put("amosOrgId",agencyUserModel.getSequenceNbr());
+        return orgService.dataHandling(jsonObject,bizOrgType,sequenceNbr);
+    }
 }