上传科室接口实现

hospital-manager/src/main/java/com/atguigu/hospital/service/impl/ApiServiceImpl.java

@@ -159,7 +159,7 @@ public class ApiServiceImpl implements ApiService {
             paramMap.put("bigname",jsonObject.getString("bigname"));
 
             paramMap.put("timestamp", HttpRequestHelper.getTimestamp());
-            paramMap.put("sign",HttpRequestHelper.getSign(paramMap, this.getSignKey()));
+            paramMap.put("sign",MD5.encrypt(this.getSignKey()));
             JSONObject respone = HttpRequestHelper.sendRequest(paramMap,this.getApiUrl()+"/api/hosp/saveDepartment");
             System.out.println(respone.toJSONString());
 

service/service_hosp/src/main/java/com/atguigu/yygu/hosp/controller/api/ApiController.java

@@ -6,6 +6,7 @@ import com.atguigu.yygu.common.helper.HttpRequestHelper;
 import com.atguigu.yygu.common.result.Result;
 import com.atguigu.yygu.common.result.ResultCodeEnum;
 import com.atguigu.yygu.common.utils.MD5;
+import com.atguigu.yygu.hosp.service.DepartmentService;
 import com.atguigu.yygu.hosp.service.HospitalService;
 import com.atguigu.yygu.hosp.service.HospitalSetService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -26,6 +27,9 @@ public class ApiController {
     @Autowired
     private HospitalSetService hospitalSetService;
 
+    @Autowired
+    private DepartmentService departmentService;
+
     //上传医院接口
     @PostMapping("saveHospital")
     public Result saveHospital(HttpServletRequest request){
@@ -86,5 +90,31 @@ public class ApiController {
         return Result.ok(hospital);
     }
 
+    //上传科室接口
+    @PostMapping("saveDepartment")
+    public Result saveDepartment(HttpServletRequest request){
+        //获取传递过来的医院信息
+        Map<String, String[]> requestMap = request.getParameterMap();
+        Map<String, Object> paramMap = HttpRequestHelper.switchMap(requestMap);
+
+        //获取医院编号
+        String hoscode = (String) paramMap.get("hoscode");
+
+        //1、获取医院系统传递过来的签名,签名是MD5加密之后的
+        String hospSign = (String) paramMap.get("sign");
+        //2、根据传递过来的医院编号，查询数据库，查询签名
+        String signKey=hospitalSetService.getSignKey(hoscode);
+        //3、把数据库查询出来的签名进行MD5加密
+        String signKeyMd5 = MD5.encrypt(signKey);
+        //4、判断签名是否一致
+        if(!hospSign.equals(signKeyMd5)){
+            throw new YyghException(ResultCodeEnum.SIGN_ERROR);
+        }
+        //调用service的方法
+        departmentService.save(paramMap);
+        return Result.ok();
+
+
+    }
 
 }

service/service_hosp/src/main/java/com/atguigu/yygu/hosp/repository/DepartmentRepository.java

+package com.atguigu.yygu.hosp.repository;
+
+import com.atguigu.yygh.model.hosp.Department;
+import org.springframework.data.mongodb.repository.MongoRepository;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface DepartmentRepository extends MongoRepository<Department,String> {
+    //根据医院编号和科室编号进行查询
+    Department getDepartmentByHoscodeAndDepcode(String hoscode, String depcode);
+}

service/service_hosp/src/main/java/com/atguigu/yygu/hosp/service/DepartmentService.java

+package com.atguigu.yygu.hosp.service;
+
+import java.util.Map;
+
+public interface DepartmentService {
+    //上传科室接口
+    void save(Map<String, Object> paramMap);
+}

service/service_hosp/src/main/java/com/atguigu/yygu/hosp/service/impl/DepartmentServiceImpl.java

+package com.atguigu.yygu.hosp.service.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.atguigu.yygh.model.hosp.Department;
+import com.atguigu.yygu.hosp.repository.DepartmentRepository;
+import com.atguigu.yygu.hosp.service.DepartmentService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.Map;
+
+@Service
+public class DepartmentServiceImpl implements DepartmentService {
+    @Autowired
+    private DepartmentRepository departmentRepository;
+
+    //上传科室接口
+    @Override
+    public void save(Map<String, Object> paramMap) {
+        //paramMap转换成department对象
+        String paramMapString = JSONObject.toJSONString(paramMap);
+        Department department= JSONObject.parseObject(paramMapString,Department.class);
+        //根据医院编号和科室编号进行查询
+        Department departmentExist=departmentRepository.
+                getDepartmentByHoscodeAndDepcode(department.getHoscode(),department.getDepcode());
+        //判断
+        if(departmentExist!=null){  //修改操作
+            departmentExist.setUpdateTime(new Date());
+            department.setIsDeleted(0);
+            departmentRepository.save(departmentExist);
+        }else{  //添加操作
+            department.setCreateTime(new Date());   //创建时间
+            department.setUpdateTime(new Date());   //修改时间
+            department.setIsDeleted(0);             //是否删除标志
+            departmentRepository.save(department);
+        }
+    }
+}

service/service_hosp/src/main/resources/application.properties

@@ -16,6 +16,7 @@ spring.datasource.password=123456
 spring.jackson.date-format=yyyy-MM-dd HH:mm:ss
 spring.jackson.time-zone=GMT+8
 
+#mongodb链接配置
 spring.data.mongodb.uri=mongodb://192.168.159.33:27017/yygh_hosp