From 3d37261cbde8207d17148da20b603ddbba4fd0e9 Mon Sep 17 00:00:00 2001
From: PoffyZhang <99775271@qq.com>
Date: Mon, 24 Jul 2023 15:41:23 +0800
Subject: [PATCH] =?UTF-8?q?=E9=87=8D=E6=96=B0=E5=88=9D=E5=A7=8B=E5=8C=96?=
 =?UTF-8?q?=20code?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ding/controller/DingInfoPullController.java    | 29 ++++--------------
 .../pmapi/organization/manage/ProcDefManage.java   | 34 ++++++++++++++++++++++
 2 files changed, 40 insertions(+), 23 deletions(-)

diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/ding/controller/DingInfoPullController.java b/pmapi/src/main/java/com/ningdatech/pmapi/ding/controller/DingInfoPullController.java
index f07e985..2107e02 100644
--- a/pmapi/src/main/java/com/ningdatech/pmapi/ding/controller/DingInfoPullController.java
+++ b/pmapi/src/main/java/com/ningdatech/pmapi/ding/controller/DingInfoPullController.java
@@ -1,36 +1,13 @@
 package com.ningdatech.pmapi.ding.controller;
 
-import cn.hutool.crypto.digest.MD5;
-import com.alibaba.fastjson.JSON;
-import com.ningdatech.pmapi.common.util.CryptUtils;
-import com.ningdatech.pmapi.common.util.HttpUtil;
-import com.ningdatech.pmapi.common.util.Md5Utils;
-import com.ningdatech.pmapi.common.util.RefreshKeyUtil;
 import com.ningdatech.pmapi.ding.task.EmployeeBatchGetTask;
 import com.ningdatech.pmapi.ding.task.GovBusinessStripsTask;
 import com.ningdatech.pmapi.ding.task.OrganizationBatchGetTask;
-import com.ningdatech.pmapi.irs.utils.RefreshTokenUtil;
 import com.ningdatech.pmapi.organization.manage.ProcDefManage;
 import io.swagger.annotations.ApiOperation;
-import liquibase.util.MD5Util;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.http.conn.ssl.NoopHostnameVerifier;
-import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
-import org.apache.http.conn.ssl.TrustStrategy;
-import org.apache.http.impl.client.CloseableHttpClient;
-import org.apache.http.impl.client.HttpClientBuilder;
-import org.apache.http.impl.client.HttpClients;
-import org.apache.http.ssl.SSLContexts;
-import org.springframework.http.ResponseEntity;
-import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
 import org.springframework.web.bind.annotation.*;
-import org.springframework.web.client.RestTemplate;
-
-import javax.net.ssl.SSLContext;
-import java.io.UnsupportedEncodingException;
-import java.net.URLEncoder;
-import java.security.NoSuchAlgorithmException;
 
 /**
  * <p>
@@ -103,4 +80,10 @@ public class DingInfoPullController {
     public String init() {
         return procDefManage.init();
     }
+
+    @ApiOperation(value = "系统流程配置初始化按区域", notes = "系统流程配置初始化按区域")
+    @GetMapping("/init/{areaCode}")
+    public String initByArea(@PathVariable String areaCode) {
+        return procDefManage.initByArea(areaCode);
+    }
 }
diff --git a/pmapi/src/main/java/com/ningdatech/pmapi/organization/manage/ProcDefManage.java b/pmapi/src/main/java/com/ningdatech/pmapi/organization/manage/ProcDefManage.java
index 24c6ad1..df538d6 100644
--- a/pmapi/src/main/java/com/ningdatech/pmapi/organization/manage/ProcDefManage.java
+++ b/pmapi/src/main/java/com/ningdatech/pmapi/organization/manage/ProcDefManage.java
@@ -101,4 +101,38 @@ public class ProcDefManage {
         defaultHistory.setVersion(0);
         orgProcdefHistoryService.save(defaultHistory);
     }
+
+    public String initByArea(String areaCode) {
+        List<DingOrganization> orgs = organizationService.list(Wrappers.lambdaQuery(DingOrganization.class)
+                .eq(DingOrganization::getTypeCode, DingOrganizationContant.UNIT_TYPE)
+                .eq(DingOrganization::getDivisionCode,areaCode));
+
+        log.info("{}地区 需要处理初始化单位配置的企业 数量为{}",areaCode,orgs.size());
+
+        for(DingOrganization org : orgs){
+            log.info("当前是 {}",org.getOrganizationName());
+            String orgCode = org.getOrganizationCode();
+
+            List<WflowOrgModels> models = orgProcdefService.list(Wrappers.lambdaQuery(WflowOrgModels.class)
+                    .eq(WflowOrgModels::getOrgCode, orgCode));
+
+            log.info("已经有的单位流程 {}", JSON.toJSONString(models));
+
+            List<String> types = models.stream().map(WflowOrgModels::getType).collect(Collectors.toList());
+            //默认流程
+            if(!types.contains(ProcessDefTypeEnum.DEFAULT.name())){
+                saveDef(org,ProcessDefTypeEnum.DEFAULT);
+            }
+            //盖章流程
+            if(!types.contains(ProcessDefTypeEnum.SEAL.name())){
+                saveDef(org,ProcessDefTypeEnum.SEAL);
+            }
+            //联审流程
+            if(!types.contains(ProcessDefTypeEnum.JOINT_REVIEW.name())){
+                saveDef(org,ProcessDefTypeEnum.JOINT_REVIEW);
+            }
+        }
+
+        return "初始化成功";
+    }
 }