feature 代码提交

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/service/impl/SynchronizationDataServiceImpl.java

@@ -40,28 +40,40 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
         switch (code) {
             case "KC121":
                 apiRequestAndProcessingStrategy = new KC121ApiRequestAndProcessing();
+                break;
             case "KC123":
                 apiRequestAndProcessingStrategy = new KC123ApiRequestAndProcessing();
+                break;
             case "KC125":
                 apiRequestAndProcessingStrategy = new KC125ApiRequestAndProcessing();
+                break;
             case "KC127":
                 apiRequestAndProcessingStrategy = new KC127ApiRequestAndProcessing();
+                break;
             case "KC129":
                 apiRequestAndProcessingStrategy = new KC129ApiRequestAndProcessing();
+                break;
             case "KC131":
                 apiRequestAndProcessingStrategy = new KC131ApiRequestAndProcessing();
+                break;
             case "KC133":
                 apiRequestAndProcessingStrategy = new KC133ApiRequestAndProcessing();
+                break;
             case "KC135":
                 apiRequestAndProcessingStrategy = new KC135ApiRequestAndProcessing();
+                break;
             case "KC137":
                 apiRequestAndProcessingStrategy = new KC137ApiRequestAndProcessing();
+                break;
             case "KC139":
                 apiRequestAndProcessingStrategy = new KC139ApiRequestAndProcessing();
+                break;
             case "KC141":
                 apiRequestAndProcessingStrategy = new KC141ApiRequestAndProcessing();
+                break;
             case "KC143":
                 apiRequestAndProcessingStrategy = new KC143ApiRequestAndProcessing();
+                break;
             default:
                 break;
         }
@@ -78,28 +90,40 @@ public class SynchronizationDataServiceImpl implements SynchronizationDataServic
         switch (code) {
             case "KC122":
                 apiRequestAndProcessingStrategy = new KC122ApiRequestAndProcessing();
+                break;
             case "KC124":
                 apiRequestAndProcessingStrategy = new KC124ApiRequestAndProcessing();
+                break;
             case "KC126":
                 apiRequestAndProcessingStrategy = new KC126ApiRequestAndProcessing();
+                break;
             case "KC128":
                 apiRequestAndProcessingStrategy = new KC128ApiRequestAndProcessing();
+                break;
             case "KC130":
                 apiRequestAndProcessingStrategy = new KC130ApiRequestAndProcessing();
+                break;
             case "KC132":
                 apiRequestAndProcessingStrategy = new KC132ApiRequestAndProcessing();
+                break;
             case "KC134":
                 apiRequestAndProcessingStrategy = new KC134ApiRequestAndProcessing();
+                break;
             case "KC136":
                 apiRequestAndProcessingStrategy = new KC136ApiRequestAndProcessing();
+                break;
             case "KC138":
                 apiRequestAndProcessingStrategy = new KC138ApiRequestAndProcessing();
+                break;
             case "KC140":
                 apiRequestAndProcessingStrategy = new KC140ApiRequestAndProcessing();
+                break;
             case "KC142":
                 apiRequestAndProcessingStrategy = new KC142ApiRequestAndProcessing();
+                break;
             case "KC144":
                 apiRequestAndProcessingStrategy = new KC144ApiRequestAndProcessing();
+                break;
             default:
                 break;
         }

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/strategy/KC134ApiRequestAndProcessing.java

@@ -1,22 +1,16 @@
 package com.rongwei.bscommon.sys.strategy;
 
+import com.rongwei.bscommon.sys.service.impl.JtXcjhqdServiceImpl;
 import com.rongwei.bscommon.sys.utils.AttendanceAssessmentSdk;
-import com.rongwei.bsentity.domain.JtGsjtbsj;
 import com.rongwei.bsentity.dto.ApiCallDto;
 import com.rongwei.bsentity.dto.ApiReturnDto;
-import com.rongwei.bsentity.dto.OrgApiDataConfigDTO;
 import com.rongwei.rwcommon.base.R;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
-import java.util.ArrayList;
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 
-import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.assembleApiData;
-import static com.rongwei.bscommon.sys.utils.ApiDataOrgUtil.setOrdinaryDatePattern;
-
 /**
  * AssembleK34ApiData class
  *
@@ -28,16 +22,14 @@ public class KC134ApiRequestAndProcessing implements ApiRequestAndProcessingStra
     @Autowired
     private AttendanceAssessmentSdk attendanceAssessmentSdk;
 
-    @Override
-    public Map<String, Object> assembleData(String id,String dataId,String code) {
-        List<OrgApiDataConfigDTO> assembleData = new ArrayList<>();
-
-        assembleData.add(setOrdinaryDatePattern("DATAID", JtGsjtbsj::getDataid));
+    @Autowired
+    private JtXcjhqdServiceImpl jtXcjhqdService;
 
-        JtGsjtbsj jtGsjtbsj = new JtGsjtbsj();
-        Map<String, Object> stringObjectMap = new HashMap<String,Object>(){{
-            put("INDEXID",id);
-            put("DATAID",dataId);
+    @Override
+    public Map<String, Object> assembleData(String id, String dataId, String code) {
+        Map<String, Object> stringObjectMap = new HashMap<String, Object>() {{
+            put("INDEXID", id);
+            put("DATAID", dataId);
         }};
         return stringObjectMap;
     }
@@ -49,6 +41,7 @@ public class KC134ApiRequestAndProcessing implements ApiRequestAndProcessingStra
         paramVo.setApiCode(code);
         ApiReturnDto apiReturnDto = attendanceAssessmentSdk.apiCall(paramVo);
         // 后续逻辑处理
-        return R.ok();
+        jtXcjhqdService.removeById(id);
+        return R.ok("删除成功");
     }
 }

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/utils/AttendanceAssessmentSdk.java

@@ -10,7 +10,6 @@ import com.rongwei.bsentity.dto.ApiReturnDto;
 import com.rongwei.commonservice.service.ApiLogService;
 import com.rongwei.commonservice.service.RedisService;
 import com.rongwei.commonservice.service.SysConfigService;
-import com.rongwei.rwcommon.base.R;
 import com.rongwei.rwcommon.base.exception.CustomException;
 import com.rongwei.rwcommon.utils.Constants;
 import com.rongwei.rwcommon.utils.SecurityUtil;
@@ -31,6 +30,10 @@ import java.util.Date;
 import java.util.HashMap;
 import java.util.Map;
 
+import static com.rongwei.bscommon.sys.utils.JXKHConstant.BusinessReturnCode.CODE_101;
+import static com.rongwei.bscommon.sys.utils.JXKHConstant.BusinessReturnCode.CODE_103;
+import static com.rongwei.bscommon.sys.utils.JXKHConstant.StandardReturn.*;
+
 /**
  * 考勤考核系统对接SDK
  */
@@ -88,11 +91,8 @@ public class AttendanceAssessmentSdk {
         // 请求地址
         String url = this.clientIp + this.apiVirtualDirectoryMap.get(paramVo.getApiCode());
         logger.info("api地址：{}", url);
-
-
         ApiReturnDto apiReturnDto = null;
         String apiResult = null;
-
         /**********************组装请求参数**************************************/
         Map<String, Map<String, Object>> postData = new HashMap<>(2);
         Map<String, Object> requestData = getRequestData();
@@ -109,6 +109,28 @@ public class AttendanceAssessmentSdk {
             apiResult = HttpRequest.post(url).body(jsonStr).execute().body();
             logger.info("接口返回报文：{}", apiResult);
             apiReturnDto = JSONUtil.toBean(apiResult, ApiReturnDto.class);
+            switch (apiReturnDto.getApsStat()) {
+                case CODE_001:
+                    throw new CustomException("token校验失败");
+                case CODE_002:
+                    throw new CustomException("单位编码为空");
+                case CODE_003:
+                    throw new CustomException("接口无权限");
+                case CODE_004:
+                    throw new CustomException("token过期");
+                case CODE_006:
+                    throw new CustomException("数据超过最大处理数量");
+                default:
+                    break;
+            }
+            switch (apiReturnDto.getSuccessCode()) {
+                case CODE_101:
+                    throw new CustomException("必填项为空");
+                case CODE_103:
+                    throw new CustomException("数据主键或数据编码有误，数据操作失败");
+                default:
+                    break;
+            }
         } catch (Exception e) {
             e.printStackTrace();
             logger.error("接口调用异常", e.getMessage());

jsglkh-common/src/main/java/com/rongwei/bscommon/sys/utils/JXKHConstant.java

@@ -18,4 +18,46 @@ public class JXKHConstant {
         public static final String DATE_PATTERN_YMD_POINT = "yyyy.MM.dd";
     }
 
+    public static class BusinessReturnCode {
+        /**
+         * 接口执行成功
+         */
+        public static final int CODE_1100 = 1100;
+        /**
+         * 必填项xxx为空
+         */
+        public static final int CODE_101 = 101;
+        /**
+         * 数据主键或数据编码有误，数据操作失败
+         */
+        public static final int CODE_103 = 103;
+    }
+
+    public static class StandardReturn {
+        /**
+         * 请求成功
+         */
+        public static final String CODE_000 = "000";
+        /**
+         * token校验失败
+         */
+        public static final String CODE_001 = "001";
+        /**
+         * 单位编码为空
+         */
+        public static final String CODE_002 = "002";
+        /**
+         * 接口无权限
+         */
+        public static final String CODE_003 = "003";
+        /**
+         * token过期
+         */
+        public static final String CODE_004 = "004";
+        /**
+         * 数据超过最大处理数量
+         */
+        public static final String CODE_006 = "006";
+    }
 }
+