城燃管道相关业务提交

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/ProblemCodeLibDto.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 java.util.Date;
+
+@Data
+@ApiModel(value = "ProblemCodeLibDto", description = "质量问题代码库表")
+public class ProblemCodeLibDto extends BaseDto {
+    @ApiModelProperty("质量问题产生阶段")
+    private String genStage;
+
+    @ApiModelProperty("质量问题")
+    private String content;
+
+    @ApiModelProperty("质量问题代码")
+    private String code;
+
+    @ApiModelProperty("监管指标")
+    private String indicator;
+
+    @ApiModelProperty("监管指标单位")
+    private String idxUnit;
+
+    @ApiModelProperty("监管指标类型")
+    private String idxType;
+
+    @ApiModelProperty("监管指标阈值")
+    private String idxThresholds;
+
+    @ApiModelProperty("创建日期")
+    private Date createDate;
+
+    @ApiModelProperty("备注")
+    private String remark;
+}

amos-boot-system-ugp/amos-boot-module-ugp-api/src/main/java/com/yeejoin/amos/boot/module/ugp/api/dto/ProcessRelationDto.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;
+
+@Data
+@ApiModel(value="ProcessRelationDto", description="流程关联表")
+public class ProcessRelationDto extends BaseDto {
+    @ApiModelProperty("源id")
+    private Long sourceId;
+
+    @ApiModelProperty("流程实例id")
+    private Long instanceId;
+
+    @ApiModelProperty("流程状态")
+    private String status;
+
+    @ApiModelProperty("流程定义编码")
+    private String defCode;
+
+    @ApiModelProperty("流程名称")
+    private String defName;
+}

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

+package com.yeejoin.amos.boot.module.ugp.api.entity;
+
+import com.baomidou.mybatisplus.annotation.FieldFill;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+import java.util.Date;
+
+/**
+ * desc 质量问题代码库表
+ */
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("tz_ugp_problem_code_lib")
+public class ProblemCodeLib extends BaseEntity {
+    /**
+     * 质量问题产生阶段
+     */
+    @TableField("gen_stage")
+    private String genStage;
+
+    /**
+     * 质量问题
+     */
+    @TableField("content")
+    private String content;
+
+    /**
+     * 质量问题代码
+     */
+    @TableField("code")
+    private String code;
+
+    /**
+     * 监管指标
+     */
+    @TableField("indicator")
+    private String indicator;
+
+    /**
+     * 监管指标单位
+     */
+    @TableField("idx_unit")
+    private String idxUnit;
+
+    /**
+     * 监管指标类型
+     */
+    @TableField("idx_type")
+    private String idxType;
+
+    /**
+     * 监管指标阈值
+     */
+    @TableField("idx_thresholds")
+    private String idxThresholds;
+
+    /**
+     * 创建日期
+     */
+    @TableField(value = "create_date", fill = FieldFill.INSERT)
+    private Date createDate;
+
+    /**
+     * 备注
+     */
+    @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/ProcessRelation.java

+package com.yeejoin.amos.boot.module.ugp.api.entity;
+
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@Accessors(chain = true)
+@TableName("tz_ugp_process_relation")
+public class ProcessRelation extends BaseEntity {
+
+    /**
+     * 源id
+     */
+    @TableField("source_id")
+    private Long sourceId;
+    /**
+     * 流程实例id
+     */
+    @TableField("instance_id")
+    private Long instanceId;
+    /**
+     * 流程状态
+     */
+    @TableField("status")
+    private String status;
+    /**
+     * 流程定义编码
+     */
+    @TableField("def_code")
+    private String defCode;
+    /**
+     * 流程名称
+     */
+    @TableField("def_name")
+    private String defName;
+
+}

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

+package com.yeejoin.amos.boot.module.ugp.api.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProblemCodeLib;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface ProblemCodeLibMapper extends BaseMapper<ProblemCodeLib> {
+}

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

+package com.yeejoin.amos.boot.module.ugp.api.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProcessRelation;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface ProcessRelationMapper extends BaseMapper<ProcessRelation> {
+}

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

+package com.yeejoin.amos.boot.module.ugp.api.service;
+
+public interface IProblemCodeLibService {
+}

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

+package com.yeejoin.amos.boot.module.ugp.api.service;
+
+public interface IProcessRelationService {
+}

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.boot.module.ugp.api.mapper.ProblemCodeLibMapper">
+
+</mapper>

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

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yeejoin.amos.boot.module.ugp.api.mapper.ProcessRelationMapper">
+
+</mapper>

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

+package com.yeejoin.amos.boot.module.ugp.biz.controller;
+
+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.ugp.api.dto.ProblemCodeLibDto;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProblemCodeLib;
+import com.yeejoin.amos.boot.module.ugp.biz.service.impl.ProblemCodeLibServiceImpl;
+import com.yeejoin.amos.feign.privilege.Privilege;
+import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+import com.yeejoin.amos.feign.privilege.model.ApplicationModel;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.*;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+import org.typroject.tyboot.core.foundation.enumeration.UserType;
+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.annotation.Resource;
+import java.util.*;
+import java.util.stream.Collectors;
+
+@RestController
+@Api(tags = "质量问题代码库表Api")
+@RequestMapping(value = "/problemCodeLib")
+public class ProblemCodeLibController extends BaseController {
+
+    @Resource
+    ProblemCodeLibServiceImpl problemCodeLibServiceImpl;
+
+    @Value("${appCode.pipeline.image:studio_normalapp_3404491,upload/tzs/amos_studio/9C968B74AC9F8C9F21C8E4A284FDEAB4.png}")
+    private String pipeAppImage;
+
+    @Value("${appCode.gasBottle.image:studio_normalapp_4403119,upload/tzs/amos_studio/9C968B74AC9F8C9F21C8E4A284FDEAB4.png}")
+    private String gasBottleAppImage;
+
+
+    /**
+     * 新增质量监检信息表
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @PostMapping(value = "/save")
+    @ApiOperation(httpMethod = "POST", value = "新增质量问题代码库表", notes = "新增质量问题代码库表")
+    public ResponseModel<ProblemCodeLibDto> save(@RequestBody ProblemCodeLibDto model) {
+        model = problemCodeLibServiceImpl.createWithModel(model);
+        return ResponseHelper.buildResponse(model);
+    }
+
+    /**
+     * 根据sequenceNbr更新
+     *
+     * @param sequenceNbr 主键
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @PutMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新质量问题代码库表", notes = "根据sequenceNbr更新质量问题代码库表")
+    public ResponseModel<ProblemCodeLibDto> updateBySequenceNbrQualityInfo(@RequestBody ProblemCodeLibDto model, @PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+        model.setSequenceNbr(sequenceNbr);
+        return ResponseHelper.buildResponse(problemCodeLibServiceImpl.updateWithModel(model));
+    }
+
+    /**
+     * 根据sequenceNbr删除
+     *
+     * @param sequenceNbr 主键
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @DeleteMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除质量问题代码库表", notes = "根据sequenceNbr删除质量问题代码库表")
+    public ResponseModel<ProblemCodeLibDto> deleteBySequenceNbr(@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+        ProblemCodeLibDto model = new ProblemCodeLibDto();
+        model.setSequenceNbr(sequenceNbr);
+        model.setIsDelete(Boolean.FALSE);
+        return ResponseHelper.buildResponse(problemCodeLibServiceImpl.updateWithModel(model));
+    }
+
+    /**
+     * 根据sequenceNbr查询
+     *
+     * @param sequenceNbr 主键
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/{sequenceNbr}")
+    @ApiOperation(httpMethod = "GET", value = "根据sequenceNbr查询单个质量问题代码库表", notes = "根据sequenceNbr查询单个质量问题代码库表")
+    public ResponseModel<ProblemCodeLibDto> selectOne(@PathVariable Long sequenceNbr) {
+        return ResponseHelper.buildResponse(problemCodeLibServiceImpl.queryBySeq(sequenceNbr));
+    }
+
+    /**
+     * 列表分页查询
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @GetMapping(value = "/page")
+    @ApiOperation(httpMethod = "GET", value = "质量问题代码库表分页查询", notes = "质量问题代码库表分页查询")
+    public ResponseModel<IPage<ProblemCodeLib>> queryForPage(@RequestParam(value = "current") int current, @RequestParam
+            (value = "size") int size) {
+        Page<ProblemCodeLib> page = new Page<>();
+        page.setCurrent(current);
+        page.setSize(size);
+        return ResponseHelper.buildResponse(problemCodeLibServiceImpl.queryProblemCodeInfoPage(page));
+    }
+
+    /**
+     * 列表全部数据查询
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "质量问题代码库表列表全部数据查询", notes = "质量问题代码库表列表全部数据查询")
+    @GetMapping(value = "/list")
+    public ResponseModel<List<ProblemCodeLib>> selectForList() {
+        return ResponseHelper.buildResponse(problemCodeLibServiceImpl.queryProblemCodeInfoList());
+    }
+
+    /**
+     * 查询当前登录人的应用信息【燃气管道系统和气瓶安全追溯系统】
+     *
+     * @return List<Map < String, Object>> 查询当前登录人的应用信息【燃气管道系统和气瓶安全追溯系统】
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "查询当前登录人的应用信息【燃气管道系统和气瓶安全追溯系统】", notes = "查询当前登录人的应用信息【燃气管道系统和气瓶安全追溯系统】")
+    @GetMapping(value = "/queryApplyByToken")
+    public ResponseModel<Map<String, Object>> queryApplyByToken() {
+        String exeUserId = RequestContext.getExeUserId();
+        String[] pipeInfo = pipeAppImage.split(",");
+        //存放配置文件中取出的应用code和图片信息 key：应用Code  value：图片信息
+        Map<String, String> appCodeImageMap = new HashMap<>();
+        appCodeImageMap.put(pipeInfo[0], pipeInfo[1]);
+        String[] gasBottleInfo = gasBottleAppImage.split(",");
+        appCodeImageMap.put(gasBottleInfo[0], gasBottleInfo[1]);
+        //存放应用code用于下面过滤
+        List<String> list = Arrays.asList(pipeInfo[0], gasBottleInfo[0]);
+        AgencyUserModel result = Privilege.agencyUserClient.queryByUserId(exeUserId).getResult();
+        Map<String, String> appCodeMap = Privilege.applicationClient.queryAgencyApplications().getResult().stream().filter(t -> list.contains(t.getAppCode())).collect(Collectors.toMap(ApplicationModel::getAppCode, ApplicationModel::getAppName));
+        List<Map<String, Object>> resultList = new ArrayList<>();
+        result.getAppCodes().stream().filter(list::contains).forEach(item -> {
+            Map<String, Object> map = new HashMap<>();
+            map.put("appCode", item);
+            map.put("appName", appCodeMap.get(item));
+            map.put("image", appCodeImageMap.get(item));
+            resultList.add(map);
+        });
+        Map<String, Object> resultMap = new HashMap<>();
+        resultMap.put("current", 1);
+        resultMap.put("total", resultList.size());
+        resultMap.put("records", resultList);
+        return ResponseHelper.buildResponse(resultMap);
+    }
+}

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

+package com.yeejoin.amos.boot.module.ugp.biz.controller;
+
+import io.swagger.annotations.Api;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@Api(tags = "流程关联表Api")
+@RequestMapping(value = "/processRelation")
+public class ProcessRelationController {
+}

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

+package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
+
+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.module.ugp.api.dto.ProblemCodeLibDto;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProblemCodeLib;
+import com.yeejoin.amos.boot.module.ugp.api.mapper.ProblemCodeLibMapper;
+import com.yeejoin.amos.boot.module.ugp.api.service.IProblemCodeLibService;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class ProblemCodeLibServiceImpl extends BaseService<ProblemCodeLibDto, ProblemCodeLib, ProblemCodeLibMapper> implements IProblemCodeLibService {
+
+    @Resource
+    private ProblemCodeLibMapper problemCodeLibMapper;
+
+    public IPage<ProblemCodeLib> queryProblemCodeInfoPage(Page<ProblemCodeLib> page) {
+        LambdaQueryWrapper<ProblemCodeLib> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(ProblemCodeLib::getIsDelete, Boolean.FALSE);
+        return problemCodeLibMapper.selectPage(page, lambdaQueryWrapper);
+    }
+
+    public List<ProblemCodeLib> queryProblemCodeInfoList() {
+        LambdaQueryWrapper<ProblemCodeLib> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(ProblemCodeLib::getIsDelete, Boolean.FALSE);
+        return problemCodeLibMapper.selectList(lambdaQueryWrapper);
+    }
+}

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

+package com.yeejoin.amos.boot.module.ugp.biz.service.impl;
+
+import com.yeejoin.amos.boot.module.ugp.api.dto.ProcessRelationDto;
+import com.yeejoin.amos.boot.module.ugp.api.entity.ProcessRelation;
+import com.yeejoin.amos.boot.module.ugp.api.mapper.ProcessRelationMapper;
+import com.yeejoin.amos.boot.module.ugp.api.service.IProcessRelationService;
+import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
+@Service
+public class ProcessRelationServiceImpl extends BaseService<ProcessRelationDto, ProcessRelation, ProcessRelationMapper> implements IProcessRelationService {
+}

amos-boot-system-ugp/amos-boot-module-ugp-biz/src/main/resources/application-vb.properties

@@ -61,4 +61,10 @@ emqx.user-name=admin
 emqx.password=public
 
 ## 图片识别接口服务id
-maas.service.ocr.id=0a456d67-5e12-48af-8923-ccc447d4cb2b
\ No newline at end of file
+maas.service.ocr.id=0a456d67-5e12-48af-8923-ccc447d4cb2b
+
+# 城燃管道应用key和应用图片地址 用英文逗号隔开 前面为应用code 后面为图片地址
+appCode.pipeline.image=studio_normalapp_4403119,upload/tzs/amos_studio/9C968B74AC9F8C9F21C8E4A284FDEAB4.png
+
+# 气瓶安全追溯系统应用key和应用图片地址 用英文逗号隔开 前面为应用code 后面为图片地址
+appCode.gasBottle.image=studio_normalapp_3404491,upload/tzs/amos_studio/9C968B74AC9F8C9F21C8E4A284FDEAB4.png