Merge branch 'master' of git.patzn.com:wangweidong/patzn-cloud-service-hmhj

src/main/java/com/patzn/cloud/service/lims/hmhj/controller/EntrustSampleItemController.java

@@ -21,6 +21,7 @@ import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -42,6 +43,9 @@ public class EntrustSampleItemController extends ServiceController {
     @Autowired
     private IEntrustSampleItemService entrustSampleItemService;
 
+    @Autowired
+    private UserInfoServiceImpl userInfoService;
+
 
     @ApiOperation("分页列表")
     @ApiImplicitParams({
@@ -173,7 +177,7 @@ public class EntrustSampleItemController extends ServiceController {
     @PostMapping("/page_input_by_sample_right")
     public RestResult<Page<EntrustSampleItemVO>> getPageInputBySampleRight(EntrustSampleItemVO entrustSampleItem) {
         entrustSampleItem.setStatus(EntrustSampleItemStatusEnum.TEST);
-        entrustSampleItem.setTesterId(getAccount().getUserId());
+        handlerData(entrustSampleItem);
         return success(entrustSampleItemService.pageAllotBySampleRight(getPage(), entrustSampleItem));
     }
 
@@ -319,10 +323,19 @@ public class EntrustSampleItemController extends ServiceController {
     @PostMapping("/page_test_by_item_left")
     public RestResult<Page<EntrustSampleItemVO>> getPageTestByItemLeft(EntrustSampleItemVO entrustSampleItem) {
         entrustSampleItem.setStatus(EntrustSampleItemStatusEnum.TEST);
-        entrustSampleItem.setTesterId(getAccount().getUserId());
+        handlerData(entrustSampleItem);
         return success(entrustSampleItemService.pageByItemLeft(getPage(), entrustSampleItem));
     }
 
+    private void handlerData(EntrustSampleItemVO vo) {
+        // 数据来源
+        // 若为数据录入节点或者不为分组管理员,那么需要过滤数据
+        if ("TEST".equalsIgnoreCase(vo.getSource()) ||
+                !userInfoService.isGroupLeader(vo.getEntrustId(), getAccount())) {
+            vo.setTesterId(getAccount().getUserId());
+        }
+    }
+
 
     @ApiOperation("数据录入历史按照项目分配左侧分页列表")
     @ApiImplicitParams({
@@ -353,8 +366,7 @@ public class EntrustSampleItemController extends ServiceController {
     @PostMapping("/page_test_by_item_right")
     public RestResult<Page<EntrustSampleItemVO>> getPageTestByItemRight(EntrustSampleItemVO entrustSampleItem) {
         entrustSampleItem.setStatus(EntrustSampleItemStatusEnum.TEST);
-        // 限制只有当前人为检测人方可见
-        entrustSampleItem.setTesterId(getAccount().getUserId());
+        handlerData(entrustSampleItem);
         return success(entrustSampleItemService.pageByItemRight(getPage(), entrustSampleItem));
     }
 

src/main/java/com/patzn/cloud/service/lims/hmhj/service/impl/EntrustSampleItemServiceImpl.java

@@ -216,6 +216,8 @@ public class EntrustSampleItemServiceImpl extends BaseServiceImpl<EntrustSampleI
         Entrust entrust = getEntrustByItemId(ids[0]);
         if (null != entrust && isAllocatedByEntrustId(entrust.getId(), null)) {
             // 添加流程数据录入节点
+            // 从任务分配的流程,为了避免多次分配造成的entrust.flowStatus异常,此处重置flowStatus为ALLOT
+            entrust.setFlowStatus(EntrustFlowEnum.ALLOT.getName());
             if (entrustService.isCanIntoNextNode(entrust)) {
                 entrustService.submitToNextNode(entrust, account);
             } else {
@@ -1193,7 +1195,10 @@ public class EntrustSampleItemServiceImpl extends BaseServiceImpl<EntrustSampleI
         // 判定是否委托下的检测项目都已分配
         Entrust entrust = getEntrustByItemId(ids[0]);
         if (null != entrust && isAllocatedByEntrustId(entrust.getId(), ids)) {
-            // 添加流程数据录入节点
+            // 添加流程数据录入节点,自动分配
+            // 任务分配节点的自动分配,始终认为当前节点为任务分配节点,不做任何改变
+            //
+            entrust.setFlowStatus(EntrustFlowEnum.ALLOT.getName());
             if (entrustService.isCanIntoNextNode(entrust)) {
                 entrustService.submitToNextNode(entrust, account);
             } else {

src/main/java/com/patzn/cloud/service/lims/hmhj/service/impl/UserInfoServiceImpl.java

@@ -6,7 +6,9 @@ import com.patzn.cloud.commons.controller.LoginHelper;
 import com.patzn.cloud.feign.base.client.SysUserClient;
 import com.patzn.cloud.feign.lims.base.client.LmsUserGroupClient;
 import com.patzn.cloud.service.base.entity.SysUser;
+import com.patzn.cloud.service.hmhj.entity.Entrust;
 import com.patzn.cloud.service.lims.base.entity.LmsUserGroup;
+import com.patzn.cloud.service.lims.hmhj.service.IEntrustService;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -27,6 +29,9 @@ public class UserInfoServiceImpl {
     }
 
     @Autowired
+    private IEntrustService entrustService;
+
+    @Autowired
     private LmsUserGroupClient lmsUserGroupClient;
 
     public List<LmsUserGroup> getGroupList(Long userId) {
@@ -56,4 +61,19 @@ public class UserInfoServiceImpl {
         }
         return StringUtils.join(curGroupNameList, "-");
     }
+
+    public boolean isGroupLeader(Long entrustId, Account account) {
+        if (null == entrustId) {
+            return false;
+        }
+        Entrust entrust = entrustService.getById(entrustId);
+        if (null == entrust || StringUtils.isBlank(entrust.getTestSide())) {
+            return false;
+        }
+        List<LmsUserGroup> userGroups = lmsUserGroupClient.getByLeaderUserId(account.getUserId()).serviceData();
+        if (CollectionUtils.isEmpty(userGroups)) {
+            return false;
+        }
+        return userGroups.stream().anyMatch(t -> entrust.getTestSide().equals(t.getName()));
+    }
 }

src/main/resources/mapper/hmhj/EntrustSampleMapper.xml

@@ -162,6 +162,15 @@
         <if test="null!=vo.slotNo">
             AND  s.slot_no LIKE CONCAT('%',#{vo.slotNo},'%')
         </if>
+        <if test="null != vo.slotNoS || null != vo.slotNoE">
+            AND s.slot_no is not null
+        </if>
+        <if test="null != vo.slotNoS">
+            AND to_number(s.slot_no,'99999') &gt;= #{vo.slotNoS}
+        </if>
+        <if test="null != vo.slotNoE">
+            AND to_number(s.slot_no,'99999') &lt;= #{vo.slotNoE}
+        </if>
 
         ORDER BY  e.code,s.code
 

src/test/java/resources/db_sql/hmhj/v148/20210726新增炭块电阻率真实样品编号字段.sql

+--ldx start
+--ldx start
+
+alter table lms_tankuai_collect_data add true_sample_num varchar(255);
+comment on column lms_tankuai_collect_data.true_sample_num is '真实样品编号';
+
+--ldx end
\ No newline at end of file