first commit

.gitignore

@@ -0,0 +1,33 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/

README.md

@@ -0,0 +1,2 @@
+# qyzg-app
+

pom.xml

@@ -0,0 +1,81 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.unis.app</groupId>
+    <artifactId>qyzg-app</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <parent>
+        <groupId>com.unis.springcloud</groupId>
+        <artifactId>parent</artifactId>
+        <version>0.0.4-SNAPSHOT</version>
+    </parent>
+    <dependencies>
+        <!-- feign远程调用 -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+        </dependency>
+        <!--<dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
+        </dependency>-->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-config</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-config-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.unis.springcloud</groupId>
+            <artifactId>common</artifactId>
+            <version>0.0.5-SNAPSHOT</version>
+        </dependency>
+
+        <dependency>
+            <artifactId>qyzg-client</artifactId>
+            <groupId>com.unis.qyzg</groupId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.unis.flowable</groupId>
+            <artifactId>flowable-common</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+        </dependency>
+
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+        <finalName>qyzg-app</finalName>
+    </build>
+
+    <repositories>
+        <repository>
+            <id>spring-milestones</id>
+            <name>Spring Milestones</name>
+            <url>https://repo.spring.io/milestone</url>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </repository>
+    </repositories>
+
+</project>

src/main/java/com/unis/app/AppApplication.java

@@ -0,0 +1,20 @@
+package com.unis.app;
+
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.ComponentScan;
+
+@EnableFeignClients(basePackages = "com.unis")
+@EnableDiscoveryClient
+@ComponentScan("com.unis")
+@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
+public class AppApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(AppApplication.class, args);
+        System.out.println("=========================启动成功=============================");
+    }
+}

src/main/java/com/unis/app/config/FeignConfig.java

@@ -0,0 +1,28 @@
+package com.unis.app.config;
+
+import feign.RequestInterceptor;
+import feign.RequestTemplate;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.Enumeration;
+
+@Configuration
+public class FeignConfig implements RequestInterceptor {
+    @Override
+    public void apply(RequestTemplate template) {
+        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
+                .getRequestAttributes();
+        HttpServletRequest request = attributes.getRequest();
+        Enumeration<String> headerNames = request.getHeaderNames();
+        if (headerNames != null) {
+            while (headerNames.hasMoreElements()) {
+                String name = headerNames.nextElement();
+                String values = request.getHeader(name);
+                template.header(name, values);
+            }
+        }
+    }
+}

src/main/java/com/unis/app/config/SwaggerConfig.java

@@ -0,0 +1,22 @@
+package com.unis.app.config;
+
+import com.unis.common.utils.SwaggerUtil;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+@Configuration
+@EnableSwagger2
+public class SwaggerConfig {
+
+    @Value("${spring.application.name}")
+    private String applicationName;
+
+    @Bean
+    public Docket createRestApi() {
+        return SwaggerUtil.getDocket(applicationName);
+    }
+
+}

src/main/java/com/unis/app/controller/FlowAbleController.java

@@ -0,0 +1,247 @@
+package com.unis.app.controller;
+
+import com.unis.common.utils.CurrentUtil;
+import com.unis.common.utils.ResponseWrapper;
+import com.unis.flowable.common.vo.ExamineVO;
+import com.unis.qyzg.client.FlowableClient;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+
+
+/**
+ * @Auther:张新亮
+ * @Date: 2019/7/12 0012 13:51
+ * @Description:
+ */
+@RestController
+@RequestMapping("/flowAble")
+@Slf4j
+@Api(value = "工作流", tags = "工作流")
+public class FlowAbleController {
+    @Autowired
+    private FlowableClient flowAbleClient;
+
+
+    /**
+     * 查询待办个人任务和组任务合并列表---不分页
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "查询待办个人任务和组任务合并列表---不分页", notes = "参数：userType 10 管理端用户 20 企业端用户 ")
+    @GetMapping(value = "/findByUserAndGroupTaskNoPage/{userType}")
+    public ResponseWrapper findByUserAndGroupTaskNoPage(
+            @PathVariable("userType") String  userType
+    ) {
+        String title="查询待办个人任务和组任务合并列表---不分页";
+        try {
+            String userId="";
+            String areaCode="";
+            
+            if(userType.equals("0")) {
+            	
+            	userType="20";
+            }else {
+            	
+            	userType="10";
+            }
+            
+            
+            
+            if("20".equals(userType)){
+                userId=CurrentUtil.getCreditCode();
+                areaCode=CurrentUtil.getAreaCode();
+            }else{
+                userId=CurrentUtil.getUserId();
+                areaCode=CurrentUtil.getAreaCode();
+            }
+            ResponseWrapper responseWrapper=flowAbleClient.findByUserAndGroupTaskNoPage(userId,areaCode);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+
+    /**
+     * 查询办理任务明细  和审核信息
+     * @param taskId
+     * @return
+     */
+    @ApiOperation(value = "待办任务-----查询办理任务明细的---历吏记录审核信息和按钮", notes = "参数：taskId 任务ID  procInsId 流程ID ")
+    @GetMapping(value = "/findByFormKeyByTaskId/{taskId}/{procInsId}")
+    public ResponseWrapper findByFormKeyByTaskId(
+            @PathVariable("taskId") String taskId,
+            @PathVariable("procInsId") String procInsId
+    ) {
+        try {
+            ResponseWrapper responseWrapper=flowAbleClient.findByFormKeyByTaskId(taskId, procInsId);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("活动分页查询失败{}", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+    /**
+     * 查询待办个人任务和组任务合并列表---不分页
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "查询已办列表---不分页", notes = "参数：completeVO ")
+    @GetMapping(value = "/findByAlreadyDoneoPage/{userType}")
+    public ResponseWrapper findByAlreadyDoneoPage(
+            @PathVariable("userType") String  userType
+    ) {
+        String title="查询待办个人任务和组任务合并列表---不分页";
+        try {
+            String userId="";
+            if("20".equals(userType)){
+                userId=CurrentUtil.getCreditCode();
+            }else{
+                userId=CurrentUtil.getUserId();
+            }
+            ResponseWrapper responseWrapper=flowAbleClient.findByAlreadyDoneoPage(userId);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+    /**
+     * 查询已办理任务明细  和审核信息
+     * @param taskId
+     * @return
+     */
+    @ApiOperation(value = "已办理任务-----查询办理任务明细的---历吏记录审核信息", notes = "参数：taskId 任务ID  procInsId 流程ID ")
+    @GetMapping(value = "/findByAlreadyDone/{taskId}/{procInsId}")
+    public ResponseWrapper findByAlreadyDone(
+            @PathVariable("taskId") String taskId,
+            @PathVariable("procInsId") String procInsId
+    ) {
+        try {
+            ResponseWrapper responseWrapper=flowAbleClient.findByAlreadyDone(taskId, procInsId);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("活动分页查询失败{}", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+
+    @ApiOperation(value = "拾取任务，将组任务分给个人任务", notes = "参数：userId 用户  procInsId 流程ID ")
+    @GetMapping(value = "/claim/{taskId}")
+    public  ResponseWrapper claim(
+            @PathVariable String taskId
+    ) {
+        try {
+            String userId=CurrentUtil.getUserId();
+            ResponseWrapper responseWrapper= flowAbleClient.claim(taskId, userId);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseWrapper.error();
+        }
+    }
+
+
+
+
+
+
+    /**
+     * 工作流审批--通过，驳回,提交
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "工作流审批--提交、通过，驳回,受理、不受理,不通过", notes = "参数：completeVO ")
+    @PostMapping(value = "/startExamine")
+    public ResponseWrapper startExamine(
+            @RequestBody ExamineVO examineVO
+    ) {
+        String title="工作流审批--提交、通过，驳回,受理、不受理,不通过";
+        try {
+            String userId="";
+            String areaCode="";
+            if("20".equals(examineVO.getUserType())){
+                userId=CurrentUtil.getCreditCode();
+                areaCode=CurrentUtil.getAreaCode();
+                examineVO.setUserName(CurrentUtil.getCompanyName());
+            }else{
+                userId=CurrentUtil.getUserId();
+                areaCode=CurrentUtil.getAreaCode();
+                examineVO.setUserName(CurrentUtil.getUserName());
+            }
+            examineVO.setUserId(userId);
+            examineVO.setAreaCode(areaCode);
+
+            ResponseWrapper result=flowAbleClient.startExamine(examineVO);
+            if(result.getInfoCode()==200){
+                return ResponseWrapper.success(200, "查询成功", result.getData());
+            }else{
+                String data= (String) result.getData();
+                return ResponseWrapper.error();
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+    /**
+     * 查询企业资格详情
+     *
+     * @param lcslId
+     * @return
+     */
+    @ApiOperation(value = "根据流程ID生成流图 返回base64 编码", notes = "参数：资格id")
+    @GetMapping(value = "/findByLcslImage/{lcslId}")
+    public ResponseWrapper findByLcslImage(@PathVariable("lcslId") String lcslId) {
+
+        try {
+            ResponseWrapper responseWrapper = flowAbleClient.findByLcslImage(lcslId);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error();
+            }
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+
+    @ApiOperation(value = "根据流程ID查询审核记录", notes = "参数：procInstId 流程ID ")
+    @GetMapping(value = "/findByProcessInfo/{procInstId}")
+    public  ResponseWrapper findByProcessInfo(
+            @PathVariable String procInstId
+    ) {
+        try {
+            ResponseWrapper responseWrapper= flowAbleClient.findByProcessInfo(procInstId);
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return ResponseWrapper.error();
+        }
+    }
+
+
+}

src/main/java/com/unis/app/controller/QyzgZgController.java

@@ -0,0 +1,93 @@
+package com.unis.app.controller;
+
+import com.unis.common.utils.ResponseWrapper;
+import com.unis.qyzg.client.QyzgZgClient;
+import com.unis.qyzg.common.vo.QyzgQyzgxxVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+
+/**
+ * @Auther:张新亮
+ * @Date: 2019/7/25 0025 16:38
+ * @Description:
+ */
+@RestController
+@Slf4j
+@Api(value = "企业资格管理：资格信息", tags = "企业资格管理：资格信息")
+@RequestMapping("/qyzgZg")
+public class QyzgZgController {
+
+
+    @Autowired
+    private QyzgZgClient qyzgZgClient;
+
+
+    /**
+     * 省级承储资格列表
+     * provinceFindByPage
+     */
+    @ApiOperation(value = "省级承储资格列表", notes = "参数：模糊搜索 企业名称、所属地区、承储资格类型、仓容、有效日期")
+    @ApiImplicitParams({ @ApiImplicitParam(name = "page", value = "起始页", required = true),
+            @ApiImplicitParam(name = "size", value = "每页展示行数", required = true) })
+    @PostMapping(value = "/provinceFindByPage/{page}/{size}")
+    public ResponseWrapper provinceFindByPage(@RequestBody QyzgQyzgxxVO zgVO ,
+                                              @PathVariable Integer page, @PathVariable Integer size) {
+        try {
+            ResponseWrapper byPage = qyzgZgClient.findByPage(zgVO, page, size);
+            if (byPage.getInfoCode() != 200) {
+                return ResponseWrapper.error("列表查询失败，请联系管理员");
+            }
+            return ResponseWrapper.success(200, "查询成功" ,byPage.getData());
+        } catch (Exception e) {
+            log.error("用户分页查询失败{}", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 撤销企业资格
+     */
+    @ApiOperation(value = "撤销企业资格信息", notes = "参数：zgVO")
+    @PostMapping(value = "/cancelQualification")
+    public ResponseWrapper cancelQualification(@RequestBody QyzgQyzgxxVO zgVO) {
+
+        try {
+            ResponseWrapper responseWrapper = qyzgZgClient.cancelQualification(zgVO);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error("撤销发生异常，请联系管理员");
+            }
+            return ResponseWrapper.success();
+        } catch (Exception e) {
+            log.error("撤销对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+
+    /**
+     * 查询企业资格详情
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "根据id查询详情", notes = "参数：资格id")
+    @GetMapping(value = "/findById/{id}")
+    public ResponseWrapper findById(@PathVariable("id") String id) {
+
+        try {
+            ResponseWrapper byId = qyzgZgClient.findById(id);
+            if (byId.getInfoCode() != 200) {
+                return ResponseWrapper.error();
+            }
+            return ResponseWrapper.success(200, "查找成功", byId.getData());
+        } catch (Exception e) {
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+}

src/main/java/com/unis/app/controller/QyzgZgsqController.java

@@ -0,0 +1,279 @@
+package com.unis.app.controller;
+
+import com.unis.common.utils.CurrentUtil;
+import com.unis.common.utils.LsBeanUtils;
+import com.unis.common.utils.ResponseWrapper;
+import com.unis.flowable.common.vo.FlowAbleCompleteVO;
+import com.unis.qyzg.client.FlowableClient;
+import com.unis.qyzg.client.QyzgZgsqClient;
+import com.unis.qyzg.common.vo.QyzgZgsqSaveVO;
+import com.unis.qyzg.common.vo.QyzgZgsqVO;
+import com.unis.qyzg.common.vo.UpdateSqztVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Date;
+
+/**
+ * @Auther:张新亮
+ * @Date: 2019/7/25 0025 16:38
+ * @Description:
+ */
+@RestController
+@Slf4j
+@Api(value = "企业资格管理：资格申请", tags = "企业资格管理：资格申请")
+@RequestMapping("/qyzgZgsq")
+public class QyzgZgsqController {
+
+    @Autowired
+    private QyzgZgsqClient qyzgZgsqClient;
+
+    @ApiOperation(value = "资格申请列表信息", notes = "参数：模糊搜索参数 企业端：KZZD3不传值，管理端：KZZD3传'0'")
+    @ApiImplicitParams({@ApiImplicitParam(name = "page", value = "起始页", required = true),
+            @ApiImplicitParam(name = "size", value = "每页展示行数", required = true)})
+    @PostMapping(value = "/findByPage/{page}/{size}")
+    public ResponseWrapper findByPage(@RequestBody QyzgZgsqVO zgsq,
+                                      @PathVariable Integer page, @PathVariable Integer size) {
+        try {
+            ResponseWrapper byPage = qyzgZgsqClient.findByPage(zgsq, page, size);
+            if (byPage.getInfoCode() != 200) {
+                return ResponseWrapper.error("列表查询失败，请联系管理员");
+            }
+            return ResponseWrapper.success(200, "查询成功", byPage.getData());
+        } catch (Exception e) {
+            log.error("用户分页查询失败{}", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 更新接口
+     */
+    @ApiOperation(value = "更新接口", notes = "参数：QyzgZgsqSaveVO")
+    @PostMapping(value = "/update")
+    public ResponseWrapper update(@RequestBody QyzgZgsqVO zsqVO) {
+        zsqVO.setRefersher(CurrentUtil.getCompanyName());
+        //zsqVO.setQyName(CurrentUtil.getCompanyName());
+        zsqVO.setRefersherCode(CurrentUtil.getCreditCode());
+        zsqVO.setRefersherDate(new Date());
+        try {
+            ResponseWrapper responseWrapper = qyzgZgsqClient.updateQyzgZgsq(zsqVO);
+            if (responseWrapper.getInfoCode() != 200) {
+                return responseWrapper;
+            }
+            return ResponseWrapper.success();
+        } catch (Exception e) {
+            log.error("更新对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 代办事项修改
+     *
+     * @param zsqVO
+     * @return
+     */
+    @ApiOperation(value = "代办事项修改", notes = "参数：qyzgZgsqVO")
+    @PostMapping(value = "/updateZgsq")
+    public ResponseWrapper updateZgsq(@RequestBody QyzgZgsqVO zsqVO) {
+        try {
+            if (null == zsqVO.getKzzd3()) {
+                zsqVO.setRefersher(CurrentUtil.getCompanyName());
+                zsqVO.setRefersherCode(CurrentUtil.getCreditCode());
+            }
+            zsqVO.setRefersherDate(new Date());
+            ResponseWrapper responseWrapper = null;
+            try {
+                responseWrapper = qyzgZgsqClient.updateZgsq(zsqVO);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error("代办事项修改错误，请联系管理员");
+            }
+            return ResponseWrapper.success();
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("更新对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 保存----资格申请
+     *
+     * @param saveVO
+     * @return ResponseWrapper
+     */
+    @ApiOperation(value = "保存----资格申请", notes = "参数：资格申请 saveVO")
+    @PostMapping(value = "/save")
+    public ResponseWrapper save(@RequestBody QyzgZgsqSaveVO saveVO) {
+        //先判断企业是否可以新增申请
+        String tyshxydm = CurrentUtil.getCreditCode();
+        ResponseWrapper rs1 = qyzgZgsqClient.isNewApply(tyshxydm);
+        if (rs1.getInfoCode() != 200) {
+            return rs1;
+        }
+        Boolean isNewApply = (Boolean) rs1.getData();
+        if (!isNewApply) {
+            return ResponseWrapper.success(HttpStatus.BAD_REQUEST.value(), "该企业已申请且证书未过期，不能新增", null);
+        }
+        //可以新增申请
+        String title = "资格申请--保存";
+        try {
+            QyzgZgsqVO qyzgZgsqVO = LsBeanUtils.copyProperties(saveVO, QyzgZgsqVO.class);
+            qyzgZgsqVO.setQyId(CurrentUtil.getCreditCode());
+            qyzgZgsqVO.setCompanyName(CurrentUtil.getCompanyName());
+            qyzgZgsqVO.setCreateDate(new Date());
+            qyzgZgsqVO.setStatus(1);
+            qyzgZgsqVO.setCreator(CurrentUtil.getCompanyName());
+            qyzgZgsqVO.setCreatorCode(CurrentUtil.getCreditCode());
+            qyzgZgsqVO.setSqzt(saveVO.getSqzt());
+            qyzgZgsqVO.setAreaCode(CurrentUtil.getAreaCode());
+            //企业保存数据
+            ResponseWrapper responseWrapper = qyzgZgsqClient.save(qyzgZgsqVO);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error("对象已存在无法添加");
+            }
+            return ResponseWrapper.success(200, "保存成功", responseWrapper.getData());
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error(title + "发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 修改申请状态----资格申请
+     *
+     * @param
+     * @return ResponseWrapper
+     */
+    @ApiOperation(value = "修改申请状态----资格申请", notes = "参数：资格申请 id ,sczt 申请状态：0-草稿；1-审批中；2-审批完成（通过）；3-审批完成（未通过）, userType:用户类型  10 粮食局用户  20 企业用户")
+    @GetMapping(value = "/updateSqzt/{id}/{sqzt}/{userType}")
+    public ResponseWrapper updateSqzt(
+            @PathVariable("id") String id,
+            @PathVariable("sqzt") Integer sqzt,
+            @PathVariable("userType") String userType
+    ) {
+        String title = "资格申请--修改";
+        try {
+            UpdateSqztVO updateSqztVO = new UpdateSqztVO();
+            updateSqztVO.setRefersher(CurrentUtil.getCompanyName());
+            updateSqztVO.setRefersherCode(CurrentUtil.getCreditCode());
+            updateSqztVO.setRefersherDate(new Date());
+            updateSqztVO.setSqzt(sqzt);
+            updateSqztVO.setId(id);
+            updateSqztVO.setUserType(userType);
+            updateSqztVO.setAccount(CurrentUtil.getUserAccount());
+            updateSqztVO.setOrgName(CurrentUtil.getCompanyName());
+            updateSqztVO.setUserCreditCode(CurrentUtil.getCreditCode());
+            updateSqztVO.setAreaCode(CurrentUtil.getAreaCode());
+            //企业保存数据
+            ResponseWrapper responseWrapper = qyzgZgsqClient.updateSqzt(updateSqztVO);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error("对象已存在无法添加");
+            }
+            return ResponseWrapper.success();
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error(title + "发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 查询企业资格详情
+     *
+     * @param id
+     * @return
+     */
+    @ApiOperation(value = "根据id查询详情", notes = "参数：资格id")
+    @GetMapping(value = "/findById/{id}")
+    public ResponseWrapper findById(@PathVariable("id") String id) {
+        try {
+            ResponseWrapper responseWrapper = qyzgZgsqClient.findById(id);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error();
+            }
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 查询企业资格详情
+     *
+     * @param lcslId
+     * @return
+     */
+    @ApiOperation(value = "根据流程ID查询详情", notes = "参数：资格id")
+    @GetMapping(value = "/findByLcslId/{lcslId}")
+    public ResponseWrapper findByLcslId(@PathVariable("lcslId") String lcslId) {
+        try {
+            ResponseWrapper responseWrapper = qyzgZgsqClient.findByLcslId(lcslId);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error();
+            }
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    /**
+     * 根据areaCode获取该企业下的企业资格
+     *
+     * @param
+     * @return
+     */
+    @ApiOperation(value = "根据areaCode获取该企业下的企业资格", notes = "参数：areaCode ")
+    @GetMapping(value = "/selectQyzgAreaCode/{areaCode}")
+    public ResponseWrapper selectQyzgAreaCode(@PathVariable("areaCode") String areaCode) {
+        try {
+            ResponseWrapper responseWrapper = qyzgZgsqClient.selectQyzgAreaCode(areaCode);
+            if (responseWrapper.getInfoCode() != 200) {
+                return ResponseWrapper.error();
+            }
+            return responseWrapper;
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("查找对象，发生异常", e.getMessage());
+            return ResponseWrapper.error();
+        }
+    }
+
+    @ApiOperation("审核")
+    @PostMapping("/complete")
+    public ResponseWrapper complete(@RequestBody FlowAbleCompleteVO completeVO, @RequestParam("taskName") String taskName, @RequestParam("fjid") String fjid, @RequestParam("taskId") String taskId) {
+        return qyzgZgsqClient.complete(completeVO, taskName, fjid, taskId);
+    }
+
+
+    /**
+     * 功能描述: 备案填写---删除
+     *
+     * @Param: [id]
+     * @Return: com.unis.common.utils.ResponseWrapper
+     * @Author: zoujieli
+     * @Date: 2020-02-28 16:16
+     */
+    @ApiOperation(value = "根据备案申请ID删除备案信息")
+    @PutMapping(value = "/delete")
+    public ResponseWrapper deleteRecordCertificate(@RequestParam String id){
+        return qyzgZgsqClient.deleteRecordCertificate(id);
+    }
+
+}

src/main/java/com/unis/app/controller/RecordCertificateController.java

@@ -0,0 +1,76 @@
+package com.unis.app.controller;
+
+import com.unis.common.utils.CurrentUtil;
+import com.unis.common.utils.ResponseWrapper;
+import com.unis.qyzg.client.RecordCertificateClient;
+import com.unis.qyzg.common.vo.QyzgBazsVO;
+import com.unis.qyzg.common.vo.QyzgZgsqVO;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.Date;
+
+@RestController
+@Api(value = "备案证书管理", tags = "备案证书管理")
+@RequestMapping(value = "/recordCertificate")
+public class RecordCertificateController {
+
+    @Autowired
+    private RecordCertificateClient recordCertificateClient;
+
+    /**
+     * 备案证书管理---根据条件分页查询备案单位
+     */
+    @ApiOperation(value = "根据条件分页查询备案单位")
+    @PostMapping(value = "/pageList/{pageNum}/{pageSize}")
+    public ResponseWrapper selectRecordCompany(@RequestBody QyzgZgsqVO qyzgZgsqVO,
+                                        @PathVariable Integer pageNum,
+                                        @PathVariable Integer pageSize){
+        return recordCertificateClient.selectRecordCompany(qyzgZgsqVO, pageNum, pageSize);
+    }
+
+    /**
+     * 备案证书管理---新增/更新备案证书
+     */
+    @ApiOperation(value = "新增/更新备案证书")
+    @PostMapping(value = "/recordCompany")
+    public ResponseWrapper recordCompany(@RequestBody QyzgBazsVO qyzgBazsVO){
+//        if (qyzgBazsVO.getDwdm() == null){
+//            return ResponseWrapper.error(HttpStatus.BAD_REQUEST.value(), "单位代码（dwdm）不能为空", null);
+//        }
+        qyzgBazsVO.setCreator(CurrentUtil.getUserName());
+        qyzgBazsVO.setCreateDate(new Date());
+        qyzgBazsVO.setCreatorCode(CurrentUtil.getUserId());
+        qyzgBazsVO.setOrgCode(CurrentUtil.getOrgId());
+        return recordCertificateClient.recordCompany(qyzgBazsVO);
+    }
+
+    /**
+     * 备案证书管理---根据证书ID查询备案证书详情
+     */
+    @ApiOperation(value = "根据证书ID查询备案证书详情", notes = "params: 通过ID查询的时候，DWDM为null；通过DWDM查询的时候，ID = 0")
+    @GetMapping(value = "/certificateDetail/{id}")
+    public ResponseWrapper certificateDetail(@PathVariable(required = false) String id,
+                                             @RequestParam(required = false) String dwdm){
+        return recordCertificateClient.certificateDetail(id, dwdm);
+    }
+
+    /**
+     * 功能描述: 备案证书---列表
+     *
+     * @Param: [qyzgBazsVO]
+     * @Return: com.unis.common.utils.ResponseWrapper
+     * @Author: zoujieli
+     * @Date: 2020-02-28 14:32
+     */
+    @ApiOperation(value = "根据企业统一社会信用代码查询备案证书列表")
+    @PostMapping(value = "/certificatePageList/{pageNum}/{pageSize}")
+    public ResponseWrapper findCertificatePageList(@RequestBody QyzgBazsVO qyzgBazsVO,
+                                                   @PathVariable(name = "pageNum") int pageNum,
+                                                   @PathVariable(name = "pageSize") int pageSize){
+        return recordCertificateClient.findCertificatePageList(qyzgBazsVO, pageNum, pageSize);
+    }
+}

src/main/resources/bootstrap.yml

@@ -0,0 +1,52 @@
+server:
+  port: 13102
+spring:
+  application:
+    name: qyzg-app
+  #配置中心配置
+#  cloud:
+#    config:
+#      #使用discovery 时需要将eureka 写到该文件中，开发环境使用该方式,推荐使用。
+#      discovery:
+#        enabled: true
+#        service-id: config
+#      name: feign
+#      profile: dev
+#      username: configuser
+#      password: configpasd
+#      retry:
+#        max-attempts: 5
+#        max-interval: 2000
+#      #如果出现错误立刻停止服务。
+#      #fail-fast: true
+ribbon:
+  eureka:
+    enabled: true
+  ConnectTimeout: 60000
+  ReadTimeout: 60000
+  MaxTotalHttpConnections: 60000
+  MaxConnectionsPerHost: 60000
+hystrix:
+  command:
+    myusers-service:
+      execution:
+        isolation:
+          thread:
+            timeoutInMilliseconds: 60000
+#服务注册配置
+eureka:
+  client:
+    service-url:
+      defaultZone: http://172.16.0.4:11000/eureka/
+  instance:
+    prefer-ip-address: true
+    status-page-url-path: /swagger-ui.html
+#日志配置
+logging:
+  level:
+    com.unis.app: debug
+    root: warn
+    org.springframework.web: debug
+    org.hibernate: error
+    com.unis.app.controller: info
+  path: ./log/