sgh5安全检查下发时自定义选择接收人

src/view/safeCheck/safeCheck_item/index.vue

@@ -89,6 +89,17 @@
           @click="showDateTimePicker = true"
           :rules="[{ required: true, message: '请选择整改时限' }]"
         />
+        <van-field
+          readonly
+          :model-value="xfRepairDisplaySummary"
+          label="整改责任人"
+          placeholder=""
+          is-link
+          @click="openXfRepairPicker"
+        />
+        <div style="padding: 0 16px 12px;">
+          <van-button size="small" type="primary" plain block @click="resetXfRepairToDefault">恢复系统默认</van-button>
+        </div>
       </van-form>
     </van-dialog>
 
@@ -127,12 +138,21 @@
       </van-time-picker>
     </van-popup>
 
+    <OrganizationalWithLeafUser
+        :key="xfRepairSessionKey"
+        ref="PopupDepartmentLeaderNameRefXfRepair"
+        :main-key="xfRepairSessionKey"
+        @receive-from-child="handleTableDataUpdateXfRepair"
+    />
+
   </div>
 </template>
 
 <script setup>
-import { ref, reactive, onMounted, getCurrentInstance, nextTick, toRaw } from 'vue';
-import { Dialog, showDialog, showSuccessToast, showToast, Toast } from 'vant';
+import { ref, computed, onMounted, getCurrentInstance, toRaw } from 'vue';
+import { showConfirmDialog, showSuccessToast, showToast } from 'vant';
+import OrganizationalWithLeafUser from '@/components/OrganizationalWithLeafUser.vue';
+import { workflowSubmit } from '@/tools/workflow.js';
 
 const { proxy } = getCurrentInstance();
 
@@ -370,9 +390,96 @@ const submitXFForm = ref({
   repairDdlText: ''
 });
 
+const guid = () => {
+  function S4() {
+    return (((1 + Math.random()) * 0x10000) | 0).toString(16).substring(1);
+  }
+  return S4() + S4() + S4() + S4() + S4() + S4() + S4() + S4();
+};
+
+/** 下发隐患：整改责任人（默认岗位匹配，可选手工） */
+const PopupDepartmentLeaderNameRefXfRepair = ref(null);
+const xfRepairSessionKey = ref(guid());
+const xfRepairUseCustom = ref(false);
+const xfRepairUserCodes = ref('');
+const xfRepairUserNames = ref('');
+const defaultRepairL = ref('');
+
+const xfRepairDisplaySummary = computed(() => {
+  if (xfRepairUseCustom.value && xfRepairUserNames.value) {
+    return xfRepairUserNames.value;
+  }
+  const s = defaultRepairL.value || '';
+  const n = s ? s.split(';').filter(Boolean).length : 0;
+  if (n > 0) {
+    return `系统默认（已匹配 ${n} 人）`;
+  }
+  return '系统默认（未匹配到岗位人员时可点本行选择）';
+});
+
+const buildXfRepairSessionUsers = () => {
+  if (!xfRepairUseCustom.value || !xfRepairUserCodes.value) {
+    return [];
+  }
+  const codes = xfRepairUserCodes.value.split(',').map((c) => c.trim()).filter(Boolean);
+  const descs = xfRepairUserNames.value.split('、');
+  return codes.map((userCode, i) => ({
+    userCode,
+    userDesc: descs[i] != null ? descs[i] : ''
+  }));
+};
+
+const openXfRepairPicker = () => {
+  sessionStorage.setItem(xfRepairSessionKey.value, JSON.stringify(buildXfRepairSessionUsers()));
+  PopupDepartmentLeaderNameRefXfRepair.value?.open();
+};
+
+const handleTableDataUpdateXfRepair = (users) => {
+  if (!users || !users.length) {
+    resetXfRepairToDefault();
+    return;
+  }
+  const codes = [];
+  const descs = [];
+  for (const u of users) {
+    if (u && u.userCode) {
+      codes.push(u.userCode);
+      descs.push(u.userDesc || '');
+    }
+  }
+  if (!codes.length) {
+    showToast({ type: 'fail', message: '未解析到有效的整改人员' });
+    return;
+  }
+  xfRepairUserCodes.value = codes.join(',');
+  xfRepairUserNames.value = descs.join('、');
+  xfRepairUseCustom.value = true;
+};
+
+const resetXfRepairToDefault = () => {
+  xfRepairUseCustom.value = false;
+  xfRepairUserCodes.value = '';
+  xfRepairUserNames.value = '';
+};
+
 // 打开下发弹窗
 const handleSubmitXF = (row) => {
   currentSubmitRow.value = row;
+  xfRepairSessionKey.value = guid();
+  resetXfRepairToDefault();
+  defaultRepairL.value = '';
+  const repairDeptCode =
+    row.checkedDeptCode || query2.value?.checkedDeptCode || '';
+  if (repairDeptCode) {
+    proxy.$axios
+      .get('/sgsafe/Hiddendanger/queryUserIdByPostWithDeptCode', { deptCode: repairDeptCode })
+      .then((r) => {
+        if (r.data.code === 0 && r.data.data) {
+          defaultRepairL.value = r.data.data;
+        }
+      })
+      .catch(() => {});
+  }
   // 重置表单
   submitXFForm.value = {
     repairSuggest: '',
@@ -457,23 +564,157 @@ const confirmSubmitXF = async () => {
     const param = {
       json: JSON.stringify(submitData)
     };
-    
+
     const response = await proxy.$axios.post(url, param);
-    if (response.data.code === 0) {
+    if (response.data.code !== 0) {
+      showToast({
+        type: 'fail',
+        message: '操作失败！' + response.data.msg
+      });
+      return;
+    }
+
+    const data = response.data.data || {};
+    const hiddendangerId = data.hiddendangerId;
+    if (!hiddendangerId) {
       showToast({
         type: 'success',
-        message: '下发成功'
+        message: '保存成功'
       });
       submitXFDialogVisible.value = false;
-      // 刷新列表
+      resetXfRepairToDefault();
+      defaultRepairL.value = '';
       basicReset();
       onLoad();
+      return;
+    }
+
+    const row = currentSubmitRow.value;
+    const repairDeptCode =
+      row.checkedDeptCode || query2.value?.checkedDeptCode || '';
+
+    let repairL = '';
+    if (xfRepairUseCustom.value && xfRepairUserCodes.value) {
+      try {
+        const r = await proxy.$axios.post('sgsafe/Hiddendanger/qqId', {
+          params: xfRepairUserCodes.value
+        });
+        if (r.data.code === 0 && r.data.data) {
+          repairL = String(r.data.data)
+            .split(',')
+            .map((id) => 'U_' + id.trim())
+            .filter((x) => x.length > 2)
+            .join(';');
+        }
+      } catch (e) {
+        console.error('自定义整改人解析失败:', e);
+      }
+    }
+    if (!repairL && repairDeptCode) {
+      try {
+        const r = await proxy.$axios.get('/sgsafe/Hiddendanger/queryUserIdByPostWithDeptCode', {
+          deptCode: repairDeptCode
+        });
+        if (r.data.code === 0 && r.data.data) {
+          repairL = r.data.data;
+        }
+      } catch (e) {
+        console.error('获取整改人失败:', e);
+      }
+    }
+    if (!repairL) {
+      if (!repairDeptCode && !xfRepairUseCustom.value) {
+        showToast({
+          type: 'fail',
+          message: '受检部门代码为空，无法确定整改人，请点「选择」指定整改责任人'
+        });
+      } else if (xfRepairUseCustom.value) {
+        showToast({
+          type: 'fail',
+          message: '未能根据所选人员解析整改人，请重新选择或恢复系统默认'
+        });
+      } else {
+        showToast({
+          type: 'fail',
+          message: '未获取到整改人，请配置岗位人员或点「选择」手动指定'
+        });
+      }
+      submitXFDialogVisible.value = false;
+      resetXfRepairToDefault();
+      defaultRepairL.value = '';
+      basicReset();
+      onLoad();
+      return;
+    }
+
+    let acceptL = '';
+    if (row.checkPerson) {
+      try {
+        const r = await proxy.$axios.post('sgsafe/Hiddendanger/qqId', { params: row.checkPerson });
+        if (r.data.code === 0 && r.data.data) {
+          acceptL = String(r.data.data)
+            .split(',')
+            .map((id) => 'U_' + id.trim())
+            .join(';');
+        }
+      } catch (e) {
+        console.error('获取验收人失败:', e);
+      }
+    }
+    if (!acceptL) {
+      showToast({ type: 'fail', message: '验收人信息为空，无法提交审批' });
+      submitXFDialogVisible.value = false;
+      resetXfRepairToDefault();
+      defaultRepairL.value = '';
+      basicReset();
+      onLoad();
+      return;
+    }
+
+    try {
+      await showConfirmDialog({
+        title: '提示',
+        message: '确定提交审批？'
+      });
+    } catch {
+      showToast({ type: 'info', message: '已取消提交审批' });
+      submitXFDialogVisible.value = false;
+      resetXfRepairToDefault();
+      defaultRepairL.value = '';
+      basicReset();
+      onLoad();
+      return;
+    }
+
+    const variables = { id: hiddendangerId, repairL, acceptL };
+    const result = await workflowSubmit(
+      'hazardImmediatelyCM',
+      '隐患排查治理',
+      '初始化提交',
+      JSON.stringify(toRaw(variables)),
+      undefined,
+      undefined
+    );
+    if (result.status === 'success') {
+      await proxy.$axios.post('sgsafe/Hiddendanger/saveProcessInfo', {
+        json: JSON.stringify({
+          id: hiddendangerId,
+          workId: result.workId,
+          trackId: result.trackId
+        })
+      });
+      showSuccessToast('下发并提交审批成功');
     } else {
       showToast({
         type: 'fail',
-        message: '操作失败！' + response.data.msg
+        message: '提交审批失败，' + (result.msg || '')
       });
     }
+    submitXFDialogVisible.value = false;
+    resetXfRepairToDefault();
+    defaultRepairL.value = '';
+    basicReset();
+    onLoad();
   } catch (error) {
     console.error('下发失败:', error);
     showToast({
@@ -492,6 +733,8 @@ const cancelSubmitXF = () => {
     repairDdlText: ''
   };
   dateOrTime.value = false;
+  resetXfRepairToDefault();
+  defaultRepairL.value = '';
 };
 
 </script>