综窗对接

sst-manager/src/main/java/com/mortals/xhx/common/utils/AESUtil.java

@@ -204,28 +204,38 @@ public class AESUtil {
         // AES支持三种长度的密钥：128位、192位、256位。
         // 代码中这种就是128位的加密密钥，16字节 * 8位/字节 = 128位。
         String random = "0000000671595991";
-        System.out.println("随机key:" + random);
-        System.out.println();
-
-        System.out.println("---------加密---------");
-        String aesResult = encrypt("511181198903042414", random);
-        System.out.println("aes加密结果:" + aesResult);
-        System.out.println();
+//        System.out.println("随机key:" + random);
+//        System.out.println();
+//
+//        System.out.println("---------加密---------");
+//        String aesResult = encrypt("511181198903042414", random);
+//        System.out.println("aes加密结果:" + aesResult);
+//        System.out.println();
+//
+//        System.out.println("---------解密---------");
+//        String decrypt = decrypt(aesResult, random);
+//        System.out.println("aes解密结果:" + decrypt);
+//        System.out.println();
+//
+//
+//        System.out.println("--------AES_CBC加密解密---------");
+//        String cbcResult = encryptCBC("511181198903042414", random);
+//        System.out.println("aes_cbc加密结果:" + cbcResult);
+//        System.out.println();
 
-        System.out.println("---------解密---------");
-        String decrypt = decrypt(aesResult, random);
-        System.out.println("aes解密结果:" + decrypt);
+        System.out.println("---------解密CBC---------");
+        String cbcDecrypt = decryptCBC("SWYgzz2KjYx+6TopctMpJQ==", random);
+        System.out.println("aes解密结果:" + cbcDecrypt);
         System.out.println();
 
-
-        System.out.println("--------AES_CBC加密解密---------");
-        String cbcResult = encryptCBC("511181198903042414", random);
-        System.out.println("aes_cbc加密结果:" + cbcResult);
+        System.out.println("---------解密CBC---------");
+        String cbcDecrypt1 = decryptCBC("DXgGKRNryrPM/eeUQiN4wlfpYNUZ0XIwumXNHRFQGZM=", random);
+        System.out.println("aes解密结果:" + cbcDecrypt1);
         System.out.println();
 
         System.out.println("---------解密CBC---------");
-        String cbcDecrypt = decryptCBC("R2tB6mi08cAZytixt0nANWQJxrr4pwpjsBVpQ82I4JM=", random);
-        System.out.println("aes解密结果:" + cbcDecrypt);
+        String cbcDecrypt2 = decryptCBC("6yPbSSjvMeFuJ2ONqNmSyA==", random);
+        System.out.println("aes解密结果:" + cbcDecrypt2);
         System.out.println();
     }
 }

sst-manager/src/main/java/com/mortals/xhx/module/sst/feign/IApiComplexFeign.java

+package com.mortals.xhx.module.sst.feign;
+
+import com.alibaba.fastjson.JSON;
+import com.mortals.xhx.common.code.ApiRespCodeEnum;
+import com.mortals.xhx.feign.IFeign;
+import com.mortals.xhx.feign.base.pdu.SitePdu;
+import com.mortals.xhx.feign.rsp.ApiResp;
+import com.mortals.xhx.module.sst.pdu.AcceptHandlingPdu;
+import com.mortals.xhx.module.sst.pdu.FindHandlingPageReq;
+import com.mortals.xhx.module.sst.pdu.SyntheticalMatterQuery;
+import com.mortals.xhx.module.sst.pdu.SyntheticalPdu;
+import feign.hystrix.FallbackFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.stereotype.Component;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(name = "complex-window-manager", path = "/complex", fallbackFactory =ComplexFeignFallbackFactory.class)
+public interface IApiComplexFeign extends IFeign {
+
+    /**
+     * 查询字典
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/common/queryDict")
+    String queryDict(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 查询可受理事项
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/event-implementation/list")
+    String eventList(@RequestBody SyntheticalMatterQuery query);
+
+    /**
+     * 查询事项详情
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/event-implementation/get-by-id")
+    String eventInfo(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 查询事项情形
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/bus-situation-material/getSituationMaterialTreeByEventIds")
+    String getSituationMaterialTreeByEventIds(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 根据事项EventId查询办理事项材料
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/material/findList")
+    String findMaterialList(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 根据事项情形查询办理事项材料
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/consulting-service/getMaterialByEventAndSituation")
+    String getMaterialByEventAndSituation(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 获取办件要素
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/event-implementation/getDynamicFormByEventIds")
+    String getDynamicFormByEventIds(@RequestBody SyntheticalPdu query);
+
+    /**
+     * 自助设备接件
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/self-device-info/acceptHandling")
+    String acceptHandling(@RequestBody AcceptHandlingPdu query);
+
+    /**
+     * 查询已受理事项列表
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/handling/findPageWithPermission")
+    String findPageWithPermission(@RequestBody FindHandlingPageReq query);
+
+    /**
+     * 查询已受理事项列表
+     * @param query
+     * @return
+     */
+    @PostMapping(value = "/api/common/downloadFileFtp")
+    String downloadFileFtp(@RequestBody FindHandlingPageReq query);
+
+}
+
+@Slf4j
+@Component
+class ComplexFeignFallbackFactory implements FallbackFactory<IApiComplexFeign> {
+
+    @Override
+    public IApiComplexFeign create(Throwable cause) {
+        return new IApiComplexFeign(){
+
+            @Override
+            public String queryDict(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法查询字典，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String eventList(SyntheticalMatterQuery query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法查询可受理事项，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String eventInfo(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String getSituationMaterialTreeByEventIds(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String findMaterialList(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String getMaterialByEventAndSituation(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String getDynamicFormByEventIds(SyntheticalPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String acceptHandling(AcceptHandlingPdu query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String findPageWithPermission(FindHandlingPageReq query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+
+            @Override
+            public String downloadFileFtp(FindHandlingPageReq query) {
+                ApiResp<String> failResp = new ApiResp<>();
+                failResp.setCode(ApiRespCodeEnum.FAILED.getValue());
+                failResp.setMsg("暂时无法调用接口，请稍后再试!");
+                return JSON.toJSONString(failResp);
+            }
+        };
+    }
+}

sst-manager/src/main/java/com/mortals/xhx/module/sst/pdu/FindHandlingPageReq.java

@@ -12,4 +12,6 @@ public class FindHandlingPageReq {
     private String search;
 
     private String encryptStr;
+
+    private String url;
 }

sst-manager/src/main/java/com/mortals/xhx/module/sst/web/SyntheticalController.java

@@ -16,6 +16,7 @@ import com.mortals.framework.util.StringUtils;
 import com.mortals.framework.web.BaseJsonBodyController;
 import com.mortals.xhx.common.utils.AESUtil;
 import com.mortals.xhx.module.matter.service.UserMatterApplyService;
+import com.mortals.xhx.module.sst.feign.IApiComplexFeign;
 import com.mortals.xhx.module.sst.pdu.*;
 import lombok.Getter;
 import org.apache.commons.collections4.CollectionUtils;
@@ -54,7 +55,8 @@ public class SyntheticalController extends BaseJsonBodyController {
     private String filePath;
 
     @Autowired
-    private UserMatterApplyService userMatterApplyService;
+    private IApiComplexFeign iApiComplexFeign;
+
 
     /**
      * 查询可受理事项
@@ -71,7 +73,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "查询可受理事项" ;
         try {
-            resp = doPost(url, jsonObject.toJSONString(query));
+            //resp = doPost(url, jsonObject.toJSONStriqng(query));
+            resp = iApiComplexFeign.eventList(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -97,7 +100,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "查询事项详情" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.eventInfo(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -123,7 +127,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "查询事项情形" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.getSituationMaterialTreeByEventIds(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -149,7 +154,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "根据事项EventId查询办理事项材料" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.findMaterialList(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -175,7 +181,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "根据事项情形查询办理事项材料" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.getMaterialByEventAndSituation(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -201,7 +208,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "获取办件要素" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.getDynamicFormByEventIds((query));
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -227,7 +235,8 @@ public class SyntheticalController extends BaseJsonBodyController {
         Map<String, Object> model = new HashMap();
         String busiDesc = "查询字典" ;
         try {
-            resp = doPost(url, JSONObject.toJSONString(query));
+            //resp = doPost(url, JSONObject.toJSONString(query));
+            resp = iApiComplexFeign.queryDict(query);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);
@@ -254,7 +263,21 @@ public class SyntheticalController extends BaseJsonBodyController {
         String busiDesc = "自助设备接件" ;
         try {
             doFileToBase64(pdu);
-            resp = doPost(url, JSONObject.toJSONString(pdu));
+            String random = "0000000671595991";
+            if(ObjectUtil.isNotEmpty(pdu.getApplicantLegal())){
+                pdu.getApplicantLegal().setApplicantIdNumber(AESUtil.decryptCBC(pdu.getApplicantLegal().getApplicantIdNumber(),random));
+                pdu.getApplicantLegal().setApplicantName(AESUtil.decryptCBC(pdu.getApplicantLegal().getApplicantName(),random));
+                pdu.getApplicantLegal().setDocumentId(AESUtil.decryptCBC(pdu.getApplicantLegal().getDocumentId(),random));
+                pdu.getApplicantLegal().setPhone(AESUtil.decryptCBC(pdu.getApplicantLegal().getPhone(),random));
+            }
+            if(ObjectUtil.isNotEmpty(pdu.getApplicantPersonal())){
+                pdu.getApplicantLegal().setApplicantIdNumber(AESUtil.decryptCBC(pdu.getApplicantLegal().getApplicantIdNumber(),random));
+                pdu.getApplicantLegal().setApplicantName(AESUtil.decryptCBC(pdu.getApplicantLegal().getApplicantName(),random));
+                pdu.getApplicantLegal().setDocumentId(AESUtil.decryptCBC(pdu.getApplicantLegal().getDocumentId(),random));
+                pdu.getApplicantLegal().setPhone(AESUtil.decryptCBC(pdu.getApplicantLegal().getPhone(),random));
+            }
+            //resp = doPost(url, JSONObject.toJSONString(pdu));
+            resp = iApiComplexFeign.acceptHandling(pdu);
             log.info("accept resp==>"+resp);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
 //            Rest<List<AcceptRspInfo>> rest = JSON.parseObject(resp, new TypeReference<Rest<List<AcceptRspInfo>>>() {
@@ -293,7 +316,34 @@ public class SyntheticalController extends BaseJsonBodyController {
                 pdu.setSearch(AESUtil.decryptCBC(pdu.getEncryptStr(),random));
                 log.info(JSONObject.toJSONString(pdu));
             }
-            resp = doPost(url, JSONObject.toJSONString(pdu));
+            //resp = doPost(url, JSONObject.toJSONString(pdu));
+            resp = iApiComplexFeign.findPageWithPermission(pdu);
+            this.recordSysLog(this.request, busiDesc + " 【成功】");
+        } catch (Exception e) {
+            this.doException(this.request, busiDesc + " 【异常】", model, e);
+            Rest<Object> ret = new Rest();
+            ret.setCode(-1);
+            ret.setMsg(busiDesc + " 【异常】");
+            resp = JSON.toJSONString(ret);
+        }
+        return resp;
+    }
+
+    /**
+     * 查询已受理事项列表
+     * @param pdu
+     * @return
+     */
+    @PostMapping({"api/common/downloadFileFtp"})
+    @UnAuth
+    public String downloadFileFtp(@RequestBody FindHandlingPageReq pdu) {
+        String url = GlobalSysInfo.getParamValue(PARAM_SERVER_CWS_HTTP_URL, "http://8.136.255.30:1086");
+        url += "/complex/api/common/downloadFileFtp";
+        String resp = null;
+        Map<String, Object> model = new HashMap();
+        String busiDesc = "查询已受理事项列表" ;
+        try {
+            resp = iApiComplexFeign.downloadFileFtp(pdu);
             this.recordSysLog(this.request, busiDesc + " 【成功】");
         } catch (Exception e) {
             this.doException(this.request, busiDesc + " 【异常】", model, e);