tanbin 1 год назад
Родитель
Сommit
d434466fb5

+ 24 - 5
device-api-service/src/main/java/com/xy/service/DeviceFaultInfoFlowServiceImpl.java

@@ -1,25 +1,30 @@
 package com.xy.service;
 
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.system.SystemUtil;
+import com.xy.dto.SysWorkUser.ListDto;
+import com.xy.dto.SysWorkUser.SysWorkVo;
 import com.xy.entity.DeviceFaultInfoFlow;
 import com.xy.mapper.DeviceFaultInfoFlowMapper;
 import com.xy.service.DeviceFaultInfoFlowService;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xy.utils.*;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Service;
 import io.swagger.annotations.Api;
 import lombok.AllArgsConstructor;
 
 import java.util.List;
-import com.xy.utils.R;
-import com.xy.utils.PageBean;
+
 import com.xy.dto.DeviceFaultInfoFlowDto;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.PostMapping;
 import io.swagger.annotations.ApiOperation;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.xy.utils.MybatisPlusQuery;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import org.springframework.validation.annotation.Validated;
-import com.xy.utils.Emptys;
 
 import static com.xy.utils.Beans.copy;
 import static com.xy.utils.PlusBeans.toIPage;
@@ -35,10 +40,13 @@ import static com.xy.utils.PlusBeans.toPageBean;
 * @since 2024-01-16
 */
 @Service
-@AllArgsConstructor
+@RequiredArgsConstructor
 @Api(tags = "设备故障处理流程")
 public class DeviceFaultInfoFlowServiceImpl extends ServiceImpl<DeviceFaultInfoFlowMapper, DeviceFaultInfoFlow> implements DeviceFaultInfoFlowService {
 
+    private final SysWorkUserService sysWorkUserService;
+
+
     @PostMapping("obj")
     @ApiOperation("对象查询")
     public R<DeviceFaultInfoFlowDto.Vo> obj(@RequestBody DeviceFaultInfoFlowDto.Vo vo) {
@@ -72,6 +80,17 @@ public class DeviceFaultInfoFlowServiceImpl extends ServiceImpl<DeviceFaultInfoF
     @ApiOperation("添加")
     public R save(@RequestBody @Validated DeviceFaultInfoFlowDto.Save save) {
         DeviceFaultInfoFlow saveInfo = copy(DeviceFaultInfoFlow.class, save);
+        Long operatorId = AuthorizeUtils.getLoginId(Long.class);
+        Long sysId = AuthorizeUtils.getSysId();
+        List<String> roleCodes = AuthorizeUtils.getRoleCodes(sysId);
+//        List<Long> roleIds = AuthorizeUtils.getRoleIds(sysId);
+        R<List<SysWorkVo>> listR = R.feignCheck(sysWorkUserService.list(new ListDto().setId(CollUtil.newArrayList(operatorId))));
+        List<SysWorkVo> data = listR.getData();
+        SysWorkVo sysWorkVo = data.get(0);
+        String roleNames = CollUtil.join(sysWorkVo.getRoleNames(), StrUtil.COMMA);
+        saveInfo.setOperatorRoleName(roleNames);
+        saveInfo.setOperatorRole( CollUtil.join(roleCodes, StrUtil.COMMA));
+        saveInfo.setOperatorId( operatorId);
         save(saveInfo);
         return R.ok();
     }