服务指令同步

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/directivetag/body/controller/DirectiveBodyTagController.java

@@ -1,5 +1,7 @@
 package com.nu.modules.directivetag.body.controller;
 
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -10,6 +12,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
@@ -36,6 +39,8 @@ import java.util.Map;
 public class DirectiveBodyTagController extends JeecgController<DirectiveBodyTag, IDirectiveBodyTagService> {
     @Autowired
     private IDirectiveBodyTagService directiveTagService;
+    @Autowired
+    private ISysBaseAPI sysBaseAPI;
 
     /**
      * 分页列表查询
@@ -73,6 +78,9 @@ public class DirectiveBodyTagController extends JeecgController<DirectiveBodyTag
     @ApiOperation(value = "体型标签-添加", notes = "体型标签-添加")
     @PostMapping(value = "/add")
     public Result<String> add(@RequestBody DirectiveBodyTag directiveTag) {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        directiveTag.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
+        directiveTag.setSysOrgCode(deptInfo.getString("code"));
         directiveTagService.save(directiveTag);
         return Result.OK("添加成功！");
     }

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/directivetag/emotion/controller/DirectiveEmotionTagController.java

@@ -1,5 +1,7 @@
 package com.nu.modules.directivetag.emotion.controller;
 
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -10,6 +12,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
@@ -36,6 +39,8 @@ import java.util.Map;
 public class DirectiveEmotionTagController extends JeecgController<DirectiveEmotionTag, IDirectiveEmotionTagService> {
     @Autowired
     private IDirectiveEmotionTagService directiveTagService;
+    @Autowired
+    private ISysBaseAPI sysBaseAPI;
 
     /**
      * 分页列表查询
@@ -73,6 +78,9 @@ public class DirectiveEmotionTagController extends JeecgController<DirectiveEmot
     @ApiOperation(value = "情绪标签-添加", notes = "情绪标签-添加")
     @PostMapping(value = "/add")
     public Result<String> add(@RequestBody DirectiveEmotionTag directiveTag) {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        directiveTag.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
+        directiveTag.setSysOrgCode(deptInfo.getString("code"));
         directiveTagService.save(directiveTag);
         return Result.OK("添加成功！");
     }

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/instructiontag/controller/InstructionTagController.java

@@ -10,7 +10,11 @@ import java.io.UnsupportedEncodingException;
 import java.net.URLDecoder;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
+
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
 import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
 import org.jeecg.common.util.oConvertUtils;
@@ -52,6 +56,8 @@ import org.apache.shiro.authz.annotation.RequiresPermissions;
 public class InstructionTagController extends JeecgController<InstructionTag, IInstructionTagService> {
     @Autowired
     private IInstructionTagService instructionTagService;
+    @Autowired
+    private ISysBaseAPI sysBaseAPI;
 
     /**
      * 分页列表查询
@@ -85,6 +91,9 @@ public class InstructionTagController extends JeecgController<InstructionTag, II
     @ApiOperation(value = "服务指令-分类标签-添加", notes = "服务指令-分类标签-添加")
     @PostMapping(value = "/add")
     public Result<String> add(@RequestBody InstructionTag instructionTag) {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        instructionTag.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
+        instructionTag.setSysOrgCode(deptInfo.getString("code"));
         instructionTagService.save(instructionTag);
         return Result.OK("添加成功！");
     }

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicecategory/controller/ConfigServiceCategoryController.java

@@ -1,5 +1,7 @@
 package com.nu.modules.servicecategory.controller;
 
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -10,6 +12,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
@@ -36,6 +39,8 @@ import java.util.Map;
 public class ConfigServiceCategoryController extends JeecgController<ConfigServiceCategory, IConfigServiceCategoryService> {
 	@Autowired
 	private IConfigServiceCategoryService configServiceCategoryService;
+	 @Autowired
+	 private ISysBaseAPI sysBaseAPI;
 
 	/**
 	 * 分页列表查询
@@ -73,6 +78,9 @@ public class ConfigServiceCategoryController extends JeecgController<ConfigServi
 	@ApiOperation(value="服务类别-添加", notes="服务类别-添加")
 	@PostMapping(value = "/add")
 	public Result<String> add(@RequestBody ConfigServiceCategory configServiceCategory) {
+		JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+		configServiceCategory.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
+		configServiceCategory.setSysOrgCode(deptInfo.getString("code"));
 		configServiceCategoryService.save(configServiceCategory);
 		return Result.OK("添加成功！");
 	}

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/controller/ConfigServiceDirectiveController.java

@@ -1,30 +1,25 @@
 package com.nu.modules.servicedirective.controller;
 
-import cn.hutool.core.collection.ListUtil;
+import cn.hutool.core.util.IdUtil;
-import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.nu.dto.DirectiveAsyncMQDto;
 import com.nu.modules.servicedirective.entity.ConfigServiceDirective;
 import com.nu.modules.servicedirective.entity.TreeNode;
 import com.nu.modules.servicedirective.service.IConfigServiceDirectiveService;
-import com.nu.modules.sysconfig.ISysConfigApi;
 import com.nu.utils.RabbitMQUtil;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.compress.utils.Lists;
 import org.apache.commons.lang.StringUtils;
-import org.apache.shiro.authz.annotation.RequiresPermissions;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
 import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.ModelAndView;
@@ -128,6 +123,7 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
     public Result<String> add(@RequestBody ConfigServiceDirective configServiceDirective) {
         //存储机构编码
         JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        configServiceDirective.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
         configServiceDirective.setSysOrgCode(deptInfo.getString("code"));
         //设置为“未授权”
         configServiceDirective.setStatus("1");
@@ -146,11 +142,11 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
             configServiceDirectiveService.removeEmotionTags(configServiceDirective);
         }
 
-        //同步给管理平台
+        //管理平台不存数据了，这个需求不要了！ 同步给管理平台
         {
-            DirectiveAsyncMQDto directiveAsyncMQDto = new DirectiveAsyncMQDto();
+//            DirectiveAsyncMQDto directiveAsyncMQDto = new DirectiveAsyncMQDto();
-            BeanUtils.copyProperties(configServiceDirective, directiveAsyncMQDto);
+//            BeanUtils.copyProperties(configServiceDirective, directiveAsyncMQDto);
-            rabbitMQUtil.sendToExchange("hldy.directive", "hldy.directive.audit", directiveAsyncMQDto);
+//            rabbitMQUtil.sendToExchange("hldy.directive", "hldy.directive.audit", directiveAsyncMQDto);
         }
 
         return Result.OK("添加成功！");
@@ -181,12 +177,12 @@ public class ConfigServiceDirectiveController extends JeecgController<ConfigServ
             configServiceDirectiveService.removeEmotionTags(configServiceDirective);
         }
 
-        //如果是未授权 则同步给管理平台进行更新
+        //管理平台不存数据了，这个需求不要了！ 如果是未授权 则同步给管理平台进行更新
-        if ("1".equals(configServiceDirective.getStatus())) {
+//        if ("1".equals(configServiceDirective.getStatus())) {
-            DirectiveAsyncMQDto directiveAsyncMQDto = new DirectiveAsyncMQDto();
+//            DirectiveAsyncMQDto directiveAsyncMQDto = new DirectiveAsyncMQDto();
-            BeanUtils.copyProperties(configServiceDirective, directiveAsyncMQDto);
+//            BeanUtils.copyProperties(configServiceDirective, directiveAsyncMQDto);
-            rabbitMQUtil.sendToExchange("hldy.directive", "hldy.directive.audit", directiveAsyncMQDto);
+//            rabbitMQUtil.sendToExchange("hldy.directive", "hldy.directive.audit", directiveAsyncMQDto);
-        }
+//        }
 
         return Result.OK("编辑成功!");
     }

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicedirective/service/impl/ConfigServiceDirectiveServiceImpl.java

@@ -27,7 +27,6 @@ import com.nu.utils.RabbitMQUtil;
 import org.apache.commons.lang.StringUtils;
 import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.vo.DictModel;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Lazy;

nursing-unit-services/nu-services-biz/src/main/java/com/nu/modules/servicetype/controller/ConfigServiceTypeController.java

@@ -1,5 +1,7 @@
 package com.nu.modules.servicetype.controller;
 
+import cn.hutool.core.util.IdUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -10,6 +12,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.aspect.annotation.AutoLog;
+import org.jeecg.common.system.api.ISysBaseAPI;
 import org.jeecg.common.system.base.controller.JeecgController;
 import org.jeecg.common.system.query.QueryGenerator;
 import org.jeecg.common.system.query.QueryRuleEnum;
@@ -36,6 +39,8 @@ import java.util.Map;
 public class ConfigServiceTypeController extends JeecgController<ConfigServiceType, IConfigServiceTypeService> {
     @Autowired
     private IConfigServiceTypeService configServiceTypeService;
+    @Autowired
+    private ISysBaseAPI sysBaseAPI;
 
     /**
      * 分页列表查询
@@ -73,6 +78,9 @@ public class ConfigServiceTypeController extends JeecgController<ConfigServiceTy
     @ApiOperation(value = "服务类型-添加", notes = "服务类型-添加")
     @PostMapping(value = "/add")
     public Result<String> add(@RequestBody ConfigServiceType configServiceType) {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        configServiceType.setId(deptInfo.getString("code") + IdUtil.simpleUUID());
+        configServiceType.setSysOrgCode(deptInfo.getString("code"));
         configServiceTypeService.save(configServiceType);
         return Result.OK("添加成功！");
     }