监管平台接口转发服务

src/main/java/com/yizhu/supervise/controllers/SuperviseController.java

@@ -35,12 +35,28 @@ public class SuperviseController {
     private String  appSecret;
     @Value("${param.appKey}")
     private String  appKey;
+    @Value("${param.listNumber}")
+    private Integer  listNumber;
+
+    private HisResponseTO checkData(List<?> list ){
+        HisResponseTO<?> hisResponse = new HisResponseTO();
+        hisResponse.setCode(200);
+        if(list.size()>listNumber){
+            hisResponse.setCode(500);
+            hisResponse.setMsg("错误信息: 数据一次性不能超过"+listNumber+"条");
+        }
+        return hisResponse;
+    }
 
     @Operation(summary = "2.1.1.2.互联网医院药品目录推送接口", description = "互联网医院药品目录推送接口")
     @PostMapping("/sendDrugCategory")
     @ResponseBody
     public HisResponseTO sendDrugCategory(HttpServletRequest request,@Valid  @RequestBody List<DrugCategoryReq> list) {
         String urlType = request.getHeader("urlType");
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
             apiUrl = localUrl;
@@ -52,7 +68,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.DRUG_PUSH.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendDrugCategory  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -63,6 +79,10 @@ public class SuperviseController {
     @PostMapping("/sendConsultingIndicators")
     @ResponseBody
     public HisResponseTO sendConsultingIndicators(HttpServletRequest request,@Valid  @RequestBody List<ZiXunIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -75,7 +95,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ONLINE_CONSULTATION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendNursingMaterial  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -86,6 +106,10 @@ public class SuperviseController {
     @PostMapping("/sendReferralIndicator")
     @ResponseBody
     public HisResponseTO sendReferralIndicator(HttpServletRequest request,@Valid  @RequestBody List<FuzhenIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -98,7 +122,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ONLINE_FOLLOW_UP.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:在线复诊信息接口-/supervise/sendReferralIndicator  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -109,6 +133,10 @@ public class SuperviseController {
     @PostMapping("/sendRecipeIndicators")
     @ResponseBody
     public HisResponseTO sendRecipeIndicators(HttpServletRequest request,@Valid  @RequestBody List<RecipeIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -121,7 +149,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ONLINE_PRESCRIPTION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendRecipeIndicators  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -132,6 +160,10 @@ public class SuperviseController {
     @PostMapping("/sendRecipeVerificationIndicators")
     @ResponseBody
     public HisResponseTO sendRecipeVerificationIndicators(HttpServletRequest request,@Valid  @RequestBody List<RecipeVerificationIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -144,7 +176,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ONLINE_PRESCRIPTION_VERIFICATION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendRecipeVerificationIndicators  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -155,6 +187,10 @@ public class SuperviseController {
     @PostMapping("/sendAppointRecord")
     @ResponseBody
     public HisResponseTO sendAppointRecord(HttpServletRequest request,@Valid  @RequestBody List<AppointRecordIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -167,7 +203,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ONLINE_APPOINTMENT_REGISTRATION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendAppointRecord  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -178,6 +214,10 @@ public class SuperviseController {
     @PostMapping("/sendElectMedicalRecord")
     @ResponseBody
     public HisResponseTO sendElectMedicalRecord(HttpServletRequest request,@Valid  @RequestBody List<uploadElectMedicalRecordReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -190,7 +230,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.ELECTRONIC_MEDICAL_RECORD.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendElectMedicalRecord  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -201,6 +241,10 @@ public class SuperviseController {
     @PostMapping("/sendCloudAppointRecordIndicators")
     @ResponseBody
     public HisResponseTO sendCloudAppointRecordIndicators(HttpServletRequest request,@Valid  @RequestBody List<uploadCloudAppointRecordIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -213,7 +257,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_OUTPATIENT.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendCloudAppointRecordIndicators  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -225,6 +269,10 @@ public class SuperviseController {
     @PostMapping("/sendMeetClinicIndicators")
     @ResponseBody
     public HisResponseTO sendMeetClinicIndicators(HttpServletRequest request,@Valid  @RequestBody List<MeetClinicIndicatorsReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -237,7 +285,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_CONSULTATION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/sendMeetClinicIndicators  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -249,6 +297,10 @@ public class SuperviseController {
     @PostMapping("/pushRemoteRadiology")
     @ResponseBody
     public HisResponseTO pushRemoteRadiology(HttpServletRequest request,@Valid  @RequestBody List<pushRemoteRadiologyReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -261,7 +313,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_IMAGING.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushRemoteRadiology  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -272,6 +324,10 @@ public class SuperviseController {
     @PostMapping("/pushRemoteECG")
     @ResponseBody
     public HisResponseTO pushRemoteECG(HttpServletRequest request,@Valid  @RequestBody List<pushRemoteECGReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -284,7 +340,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_ELECTROCARDIOGRAM.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushRemoteECG  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -296,6 +352,10 @@ public class SuperviseController {
     @PostMapping("/pushRemotePathology")
     @ResponseBody
     public HisResponseTO pushRemotePathology(HttpServletRequest request,@Valid  @RequestBody List<pushRemotePathologyReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -308,7 +368,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_MEDICAL_RECORDS.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushRemotePathology  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -320,6 +380,10 @@ public class SuperviseController {
     @PostMapping("/pushRemoteTransfer")
     @ResponseBody
     public HisResponseTO pushRemoteTransfer(HttpServletRequest request,@Valid  @RequestBody List<pushRemoteTransferReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -332,7 +396,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.REMOTE_REFERRAL.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushRemotePathology  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -342,6 +406,10 @@ public class SuperviseController {
     @PostMapping("/sendBusinessInfoAfter")
     @ResponseBody
     public HisResponseTO sendBusinessInfoAfter(HttpServletRequest request,@Valid  @RequestBody List<BussAfterInfoReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -354,7 +422,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.EVALUATIVE_INFORMATION.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushMedicalDispute  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;
@@ -364,6 +432,10 @@ public class SuperviseController {
     @PostMapping("/pushMedicalDispute")
     @ResponseBody
     public HisResponseTO pushMedicalDispute(HttpServletRequest request,@Valid  @RequestBody List<MedicalDisputeReq> list) {
+        HisResponseTO<?> hisResponse  = this.checkData(list);
+        if(!hisResponse.isSuccess()){
+            return hisResponse;
+        }
         String urlType = request.getHeader("urlType");
         String apiUrl = url;
         if(StringUtils.isNotBlank(urlType)&&"1".equals(urlType)){
@@ -376,7 +448,7 @@ public class SuperviseController {
             return PostUtil.post(ServiceMethodEnum.MEDICAL_DISPUTES.getServiceMethod(), JSONObject.toJSONString(list));
         }catch (Exception e){
             log.error("方法名称:-/supervise/pushMedicalDispute  错误信息:"+e.getMessage());
-            HisResponseTO<?> hisResponse = new HisResponseTO();
+            hisResponse = new HisResponseTO();
             hisResponse.setCode(40012);
             hisResponse.setMsg("错误信息:"+e.getMessage());
             return hisResponse;

src/main/resources/application-dev.yml

@@ -31,4 +31,6 @@ param:
   #测试appSecret
   appSecret: 26b0e2f6efb44017bd03d53eb5505fcf
   #测试appKey
-  appKey: 9a35011886154dc3
+  appKey: 9a35011886154dc3
+  #一次性数据提交限制的数量
+  listNumber: 1000

src/main/resources/application-pro.yml

@@ -36,3 +36,5 @@ param:
   appSecret: 3d268ad353c9471b8fd07f19116156bc
   #测试appKey
   appKey: 6fd7d5a1d1584348
+  #一次性数据提交限制的数量
+  listNumber: 1000

src/main/resources/application-test.yml

@@ -31,3 +31,5 @@ param:
   appSecret: 26b0e2f6efb44017bd03d53eb5505fcf
   #测试appKey
   appKey: 9a35011886154dc3
+  #一次性数据提交限制的数量
+  listNumber: 1000