From 546f680ff122dd0cdbfbab9d791dff919bd673f7 Mon Sep 17 00:00:00 2001 From: chenxinying <1039655633@qq.com> Date: Wed, 31 Jan 2024 11:28:04 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=AB=E9=A1=B9=E4=BD=9C=E4=B8=9A=E9=AB=98?= =?UTF-8?q?=E5=A4=84=E4=BD=9C=E4=B8=9A=E6=B5=81=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../datasource/eightwork/HighworkMapper.java | 26 + .../eightwork/HighworkSignMapper.java | 37 ++ .../eightwork/HighworkToMeasuresMapper.java | 57 ++ .../service/eightwork/HighworkService.java | 41 ++ .../eightwork/impl/HighworkServiceImpl.java | 334 ++++++++++++ .../datasource/eightwork/HighWorkMapper.xml | 491 ++++++++++++++++++ .../eightwork/HighworkSignMapper.xml | 140 +++++ .../eightwork/HighworkToMeasuresMapper.xml | 156 ++++++ 8 files changed, 1282 insertions(+) create mode 100644 src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkMapper.java create mode 100644 src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkSignMapper.java create mode 100644 src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkToMeasuresMapper.java create mode 100644 src/main/java/com/zcloud/service/eightwork/HighworkService.java create mode 100644 src/main/java/com/zcloud/service/eightwork/impl/HighworkServiceImpl.java create mode 100644 src/main/resources/mybatis/datasource/eightwork/HighWorkMapper.xml create mode 100644 src/main/resources/mybatis/datasource/eightwork/HighworkSignMapper.xml create mode 100644 src/main/resources/mybatis/datasource/eightwork/HighworkToMeasuresMapper.xml diff --git a/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkMapper.java b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkMapper.java new file mode 100644 index 0000000..81de8eb --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkMapper.java @@ -0,0 +1,26 @@ +package com.zcloud.mapper.datasource.eightwork; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * @author fangjiakai + * @date 2024/01/17 11:31 + */ +public interface HighworkMapper { + PageData getCode(PageData pd); + PageData findById(PageData pd); + void save(PageData pd); + void delete(PageData pd); + void edit(PageData pd); + void editStep(PageData pd); + List datalistPage(Page page); + + List listAllMeasures(); + + List checkWorkCount(PageData pd); + + List getFlowList(PageData pd); +} diff --git a/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkSignMapper.java b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkSignMapper.java new file mode 100644 index 0000000..8c4c3ae --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkSignMapper.java @@ -0,0 +1,37 @@ +package com.zcloud.mapper.datasource.eightwork; + +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * @author fangjiakai + * @date 2024/01/17 11:31 + */ +public interface HighworkSignMapper { + + /**新增 + * @param pd + * @throws Exception + */ + void save(PageData pd); + void saveBatch(List signers); + + /**修改 + * @param pd + * @throws Exception + */ + void edit(PageData pd); + + /**根据动火ID查询签字列表 + * @throws Exception + */ + List listById(PageData pd); + + List listAll(PageData sign); + + /**根据动火ID查询未签字列表 + * @throws Exception + */ + List checkUnsigned(PageData sign); +} diff --git a/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkToMeasuresMapper.java b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkToMeasuresMapper.java new file mode 100644 index 0000000..a62e0a9 --- /dev/null +++ b/src/main/java/com/zcloud/mapper/datasource/eightwork/HighworkToMeasuresMapper.java @@ -0,0 +1,57 @@ +package com.zcloud.mapper.datasource.eightwork; + +import com.zcloud.entity.PageData; + +import java.util.List; + +/** + * 说明：动火措施中间表 + * 作者：luoxiaobao + * 时间：2021-09-18 + * 官网：www.zcloudchina.com + */ +public interface HighworkToMeasuresMapper { + + /**新增 + * @param pd + * @throws Exception + */ + void save(PageData pd); + + void saveBatch(List signers); + + /**删除 + * @param pd + * @throws Exception + */ + void delete(PageData pd); + + /**修改 + * @param pd + * @throws Exception + */ + void edit(PageData pd); + + /**列表(全部) + * @param pd + * @throws Exception + */ + List listAll(PageData pd); + + /**通过id获取数据 + * @param pd + * @throws Exception + */ + PageData findById(PageData pd); + + /**批量删除 + * @param ArrayDATA_IDS + * @throws Exception + */ + void deleteAll(String[] ArrayDATA_IDS); + + List listAllMeasuresForSign(PageData pd); + + List listSignFinishMeasures(PageData pd); +} + diff --git a/src/main/java/com/zcloud/service/eightwork/HighworkService.java b/src/main/java/com/zcloud/service/eightwork/HighworkService.java new file mode 100644 index 0000000..fb0fef1 --- /dev/null +++ b/src/main/java/com/zcloud/service/eightwork/HighworkService.java @@ -0,0 +1,41 @@ +package com.zcloud.service.eightwork; + +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import org.springframework.web.multipart.MultipartFile; + +import java.util.List; + +/** + * @author fangjiakai + * @date 2024/01/17 11:29 + */ +public interface HighworkService { + void save(PageData pd)throws Exception; + + void edit(PageData pd)throws Exception; + + void delete(PageData pd)throws Exception; + + List list(Page page) throws Exception; + + void nextStep(PageData pd, MultipartFile[] files) throws Exception; + + PageData findById(PageData pd) throws Exception; + + PageData listSignFinished(PageData pd) throws Exception; + + PageData checkWorkCount(PageData pd); + + //获取所有措施(bus_highwork_measures) + List listAllMeasures() throws Exception; +// +// //获取需要签字的措施(bus_highworktomeasures) + List listAllMeasuresForSign(PageData pd) throws Exception; +// +// //获取所有签字完成的措施(bus_highworktomeasures) + List listSignFinishMeasures(PageData pd) throws Exception; + + + List getFlowList(PageData pd)throws Exception; +} diff --git a/src/main/java/com/zcloud/service/eightwork/impl/HighworkServiceImpl.java b/src/main/java/com/zcloud/service/eightwork/impl/HighworkServiceImpl.java new file mode 100644 index 0000000..9475ff0 --- /dev/null +++ b/src/main/java/com/zcloud/service/eightwork/impl/HighworkServiceImpl.java @@ -0,0 +1,334 @@ +package com.zcloud.service.eightwork.impl; + +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; +import com.zcloud.entity.Page; +import com.zcloud.entity.PageData; +import com.zcloud.mapper.datasource.eightwork.*; +import com.zcloud.service.eightwork.HotworkService; +import com.zcloud.util.Const; +import com.zcloud.util.DateUtil; +import com.zcloud.util.Smb; +import com.zcloud.util.UuidUtil; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.multipart.MultipartFile; +import com.zcloud.service.eightwork.HighworkService; + +import java.text.DecimalFormat; +import java.util.*; +import java.util.stream.Collectors; + +/** + * @author fangjiakai + * @date 2024/01/17 11:30 + */ +@Service +@Transactional //开启事物 +public class HighworkServiceImpl implements HighworkService { + + @Autowired + private HighworkMapper highworkMapper; + @Autowired + private EightWorkTaskFlowMapper eightWorkTaskFlowMapper; + @Autowired + private EightWorkFlowLogMapper eightWorkFlowLogMapper; + @Autowired + private HighworkSignMapper highworkSignMapper; + @Autowired + private HighworkToMeasuresMapper highworkToMeasuresMapper; + @Autowired + private com.zcloud.mapper.datasource.eightWork.EightWorkVideoManagerMapper eightworkvideomanagerMapper; + @Autowired + private Smb smb; + + private final String primary_key = "HIGHWORK_ID"; + private final String work_type = "HIGHWORK"; + @Override + @Transactional + public void save(PageData pd) throws Exception { + PageData pd2 = new PageData(); + Calendar calendar = Calendar.getInstance(); + DecimalFormat dft=new DecimalFormat("00"); + int year = calendar.get(Calendar.YEAR); + String month = dft.format(calendar.get(Calendar.MONTH) + 1); + String day = dft.format(calendar.get(Calendar.DAY_OF_MONTH)); + pd2.put("CREATDATE",year + "-" + month + "-" + day); + pd2.put("CORPINFO_ID",pd.get("CORPINFO_ID")); + pd2 = highworkMapper.getCode(pd2); //根据ID读取 + String code = "GC" + year + month + day + dft.format((Integer.parseInt(pd2.get("code").toString()) + 1)); + pd.put("CHECK_NO", code); + pd.put(primary_key, UuidUtil.get32UUID()); //主键 + pd.put("CREATTIME", DateUtil.date2Str(new Date())); //添加时间 + pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间 + pd.put("ISDELETE", "0"); //是否删除 1-是 0-否 + highworkMapper.save(pd); + + if (pd.get("APPLY_STATUS").equals("1")) { + PageData flow = getStep(pd.get("TASK_ID"),"1"); + saveLog(pd,pd.getString("CREATOR"),"1"); + saveNextSigner(pd,flow); + } + } + + @Override + @Transactional + public void edit(PageData pd) throws Exception { + pd.put("OPERATTIME", DateUtil.date2Str(new Date())); //修改时间 + highworkMapper.edit(pd); + + if (pd.get("APPLY_STATUS").equals("1")) { + pd.put("STEP_ID", 1); + highworkMapper.editStep(pd); + PageData flow = getStep(pd.get("TASK_ID"),"1"); + saveLog(pd,pd.getString("CREATOR"),"1"); + saveNextSigner(pd,flow); + } + } + + @Override + public void delete(PageData pd) throws Exception { + highworkMapper.delete(pd); + } + + @Override + public List list(Page page) throws Exception { + return highworkMapper.datalistPage(page); + } + + + /* + * 下一步 + */ + @Override + @Transactional + public void nextStep(PageData pd, MultipartFile[] files) throws Exception { + PageData work = this.findById(pd); + work.putAll(pd); + List filePaths = new ArrayList<>(); + for (int i = 0; i < files.length; i++) { + //保存签名文件 + String ffile = DateUtil.getDays(); + String fileName = UuidUtil.get32UUID() + files[i].getOriginalFilename().substring(files[i].getOriginalFilename().lastIndexOf(".")); + smb.sshSftp(files[i], fileName, Const.FILEPATHFILE + work.getString("CORPINFO_ID") + "/" + ffile); + filePaths.add(Const.FILEPATHFILE + work.getString("CORPINFO_ID") + "/" + ffile + "/" + fileName); + } + PageData flow = getStep(work.get("TASK_ID"), work.get("STEP_ID")); + work.put("STEP_ID", flow.get("NEXT_STEP_ID")); + + //保存签名信息 + PageData sign = new PageData(); + sign.put(primary_key, work.get(primary_key)); + sign.put("STEP_ID", work.get("STEP_ID")); + sign.put("SIGN_USER_ID", work.get("USER_ID")); + sign.put("SIGN_TIME", work.getString("SIGNTIME")); + sign.put("SIGN_PATH", String.join(",",filePaths)); + sign.put("DESCR", work.get("DESCR")); + + highworkSignMapper.edit(sign); + + if (work.get("MEASURES") != null && !work.get("MEASURES").equals("")) { //安全措施确认步骤 + saveMeasures(work); + } + + List unsignedList = highworkSignMapper.checkUnsigned(sign);//当前步骤未签名人列表 + if((unsignedList == null || unsignedList.size() == 0) && pd.getString("APPLY_STATUS").equals("1")){//如果没有未签人 则跳转下一步 + highworkMapper.editStep(work); + PageData currentflow = getStep(work.get("TASK_ID"), work.get("STEP_ID")); + + //保存日志 + saveLog(work,work.getString("USER_ID"),"1"); + + if("99".equals(currentflow.getString("NEXT_STEP_ID"))){ + eightworkvideomanagerMapper.editStatus(work); + + return; + } + if (work.get("PREPARERS") != null && !work.get("PREPARERS").equals("")) { //如果是设置安全措施确认人步骤 + savePreparers(work,currentflow); + } + saveNextSigner(work,currentflow); + }else if(pd.getString("APPLY_STATUS").equals("-1")){ + //保存日志 + saveLog(work,work.getString("USER_ID"),"-1"); + eightworkvideomanagerMapper.editStatus(work); + + work.put("STEP_ID",-1); + highworkMapper.editStep(work); + } + } + + @Override + public PageData findById(PageData pd) throws Exception { + PageData pageData = highworkMapper.findById(pd); + return pageData; + } + + @Override + public PageData listSignFinished(PageData pd) throws Exception { + Map> rmap = new HashMap<>(); + List varList = highworkSignMapper.listAll(pd); + if (varList != null && !varList.isEmpty()) { + varList.stream().forEach(item -> { + PageData sign = new PageData(); + sign.put("SIGN_PATH", item.getString("SIGN_PATH").split(",")); + sign.put("SIGN_TIME", item.getString("SIGN_TIME").split(",")); + + sign.put("DESCR", item.getString("DESCR") != null ? item.getString("DESCR") : "无"); + if(rmap.containsKey(item.getString("CODE"))){ + rmap.get(item.getString("CODE")).add(sign); + }else{ + List signs = new ArrayList<>(); + signs.add(sign); + rmap.put(item.getString("CODE"),signs); + } + }); + } + PageData rpd = new PageData(); + if (rmap != null && !rmap.isEmpty()) { + rpd.putAll(rmap); + } + return rpd; + } + + @Override + public PageData checkWorkCount(PageData pd) { + PageData rpd = new PageData(); + List varList = highworkMapper.checkWorkCount(pd); + + if (varList != null && !varList.isEmpty()) { + Map newMap = varList.stream() + .collect(Collectors.toMap(map -> map.getString("CODE"), map -> map.getString("COUNT"))); + + rpd.putAll(newMap); + } + return rpd; + } + + @Override + public List listAllMeasures() throws Exception { + return highworkMapper.listAllMeasures(); + + } + + @Override + public List listAllMeasuresForSign(PageData pd) throws Exception { + return highworkToMeasuresMapper.listAllMeasuresForSign(pd); + + } + + @Override + public List listSignFinishMeasures(PageData pd) throws Exception { + return highworkToMeasuresMapper.listSignFinishMeasures(pd); + } + + + @Override + public List getFlowList(PageData pd) throws Exception { + pd=findById(pd); + return highworkMapper.getFlowList(pd); + } + + private void saveNextSigner(PageData pd,PageData flow) throws Exception { + + pd.put("STEP_ID",flow.get("NEXT_STEP_ID")); + + if(pd.get(flow.get("NEXT_ACTOR_FIELD")) == null || pd.get(flow.get("NEXT_ACTOR_FIELD")).equals("")){ + return; + } + //提前保存下一步签字人 + List signers = new ArrayList<>(); + PageData signer = new PageData(); + signer.put("HIGHWORK_SIGN_ID", UuidUtil.get32UUID()); // 主键 + signer.put(primary_key, pd.get(primary_key)); + signer.put("CORPINFO_ID", pd.get("CORPINFO_ID")); + signer.put("SIGN_USER_ID", pd.get(flow.get("NEXT_ACTOR_FIELD"))); + signer.put("STEP_ID", flow.get("NEXT_STEP_ID")); + signers.add(signer); + highworkSignMapper.saveBatch(signers); + } + + private void saveMeasures(PageData pd) { + List list = (List) JSON.parse(pd.get("MEASURES").toString()); + for (JSONObject json : list) { + PageData measure = new PageData(); + measure.put("HIGHWORKTOMEASURES_ID",json.get("HIGHWORKTOMEASURES_ID")); + measure.put("STATUS", json.get("STATUS")); + measure.put("SIGN_PATH", json.get("SIGN_PATH")); + measure.put("SIGN_TIME", json.get("SIGN_TIME")); + measure.put("IMG_PATH", json.get("IMG_PATH")); + highworkToMeasuresMapper.edit(measure); + } + } + + private void savePreparers(PageData pd,PageData flow) { + List signers = new ArrayList<>(); + List list = (List) JSON.parse(pd.get("PREPARERS").toString()); + for (JSONObject json : list) { + PageData preparer = new PageData(); + preparer.put("HIGHWORKTOMEASURES_ID", UuidUtil.get32UUID()); // 主键 + preparer.put("HIGHWORK_ID", pd.get("HIGHWORK_ID")); + preparer.put("BUS_HIGHWORK_MEASURES_ID", json.get("BUS_HIGHWORK_MEASURES_ID")); + preparer.put("CONFIRM_ID", json.get("USER_ID")); + signers.add(preparer); + } + if(signers.size() > 0){ + highworkToMeasuresMapper.saveBatch(signers); + + //获取所有需要签名人 + List fieldList = signers.stream() + .map(map -> map.getString("CONFIRM_ID")) + .collect(Collectors.toList()); + Set fieldSet = new HashSet<>(fieldList); //去重 + + List uniqueList = new ArrayList<>(fieldSet); + List nextSigners = new ArrayList<>(); + uniqueList.forEach(item -> { // 保存下一步需要签名的人 + PageData signer = new PageData(); + signer.put("HIGHWORK_SIGN_ID", UuidUtil.get32UUID()); // 主键 + signer.put(primary_key, pd.get(primary_key)); + signer.put("CORPINFO_ID", pd.get("CORPINFO_ID")); + signer.put("SIGN_USER_ID", item); + signer.put("STEP_ID", flow.get("NEXT_STEP_ID")); + nextSigners.add(signer); + }); + + highworkSignMapper.saveBatch(nextSigners); + } + } + + private PageData getStep(Object TASK_ID, Object STEP_ID) throws Exception { + PageData flow = new PageData(); + flow.put("TASK_ID", TASK_ID); + flow.put("STEP_ID", STEP_ID); + flow = eightWorkTaskFlowMapper.getStep(flow); + return flow; + } + + private void saveLog(PageData pd,String act_user,String status) throws Exception { + PageData log = new PageData(); + log.put("LOG_ID", UuidUtil.get32UUID()); + log.put("WORK_ID", pd.get(primary_key)); + log.put("TASK_ID", pd.get("TASK_ID")); + log.put("STEP_ID", pd.get("STEP_ID")); + log.put("CORPINFO_ID", pd.get("CORPINFO_ID")); + log.put("CHECK_NO", pd.get("CHECK_NO")); + log.put("ACT_USER", act_user); + log.put("ACT_TIME", DateUtil.date2Str(new Date())); + log.put("STATUS", status); + log.put("WORK_TYPE",work_type); + eightWorkFlowLogMapper.save(log); + } + +// private void saveNext(PageData pd,PageData flow) throws Exception { +// PageData log = new PageData(); +// log.put("LOG_ID", UuidUtil.get32UUID()); +// log.put("WORK_ID", pd.get(primary_key)); +// log.put("TASK_ID", pd.get("TASK_ID")); +// log.put("STEP_ID", flow.get("NEXT_STEP_ID")); +// log.put("STATUS", "0"); +// eightWorkFlowLogMapper.save(log); +// } + +} diff --git a/src/main/resources/mybatis/datasource/eightwork/HighWorkMapper.xml b/src/main/resources/mybatis/datasource/eightwork/HighWorkMapper.xml new file mode 100644 index 0000000..bdcfcc7 --- /dev/null +++ b/src/main/resources/mybatis/datasource/eightwork/HighWorkMapper.xml @@ -0,0 +1,491 @@ + + + + + + BUS_HIGHWORK + + + + + f.HIGHWORK_ID, + f.CORPINFO_ID, + f.TASK_ID, + f.STEP_ID, + f.ISDELETE, + f.CREATTIME, + f.CREATOR, + f.OPERATTIME, + f.OPERATOR, + f.CHECK_NO, + f.WORK_CONTENT, + f.WORK_PLACE, + f.APPLY_DEPARTMENT_ID, + f.APPLY_USER_ID, + f.WORK_LEVEL, + f.WORK_START_DATE, + f.WORK_END_DATE, + f.SPECIAL_WORK, + f.RISK_IDENTIFICATION, + f.CONFESS_DEPARTMENT_ID, + f.CONFESS_USER_ID, + f.ACCEPT_CONFESS_DEPARTMENT_ID, + f.ACCEPT_CONFESS_USER_ID, + f.GUARDIAN_DEPARTMENT_ID, + f.GUARDIAN_USER_ID, + f.CONFIRM_DEPARTMENT_ID, + f.CONFIRM_USER_ID, + f.LEADER_DEPARTMENT_ID, + f.LEADER_USER_ID, + f.AUDIT_DEPARTMENT_ID, + f.AUDIT_USER_ID, + f.APPROVE_DEPARTMENT_ID, + f.APPROVE_USER_ID, + f.ACCEPT_DEPARTMENT_ID, + f.ACCEPT_USER_ID, + f.WORK_START_DEPARTMENT_ID, + f.WORK_START_USER_ID, + f.WORK_END_DEPARTMENT_ID, + f.WORK_END_USER_ID, + f.ACCEPT_TIME, + f.PLS_ID, + f.PLS_NAME, + f.WORK_POSITION, + f.WORK_USER_DEPARTMENT_ID, + f.WORK_USER_ID, + f.WORK_HIGH + + + + + HIGHWORK_ID, + CORPINFO_ID, + TASK_ID, + STEP_ID, + ISDELETE, + CREATTIME, + CREATOR, + OPERATTIME, + OPERATOR, + CHECK_NO, + WORK_CONTENT, + WORK_PLACE, + APPLY_DEPARTMENT_ID, + APPLY_USER_ID, + WORK_LEVEL, + WORK_START_DATE, + WORK_END_DATE, + SPECIAL_WORK, + RISK_IDENTIFICATION, + CONFESS_DEPARTMENT_ID, + CONFESS_USER_ID, + ACCEPT_CONFESS_DEPARTMENT_ID, + ACCEPT_CONFESS_USER_ID, + GUARDIAN_DEPARTMENT_ID, + GUARDIAN_USER_ID, + CONFIRM_DEPARTMENT_ID, + CONFIRM_USER_ID, + LEADER_DEPARTMENT_ID, + LEADER_USER_ID, + AUDIT_DEPARTMENT_ID, + AUDIT_USER_ID, + APPROVE_DEPARTMENT_ID, + APPROVE_USER_ID, + ACCEPT_DEPARTMENT_ID, + ACCEPT_USER_ID, + WORK_START_DEPARTMENT_ID, + WORK_START_USER_ID, + WORK_END_DEPARTMENT_ID, + WORK_END_USER_ID, + ACCEPT_TIME, + PLS_ID, + PLS_NAME, + WORK_POSITION, + WORK_USER_DEPARTMENT_ID, + WORK_USER_ID, + WORK_HIGH + + + + + #{HIGHWORK_ID}, + #{CORPINFO_ID}, + #{TASK_ID}, + #{STEP_ID}, + #{ISDELETE}, + #{CREATTIME}, + #{CREATOR}, + #{OPERATTIME}, + #{OPERATOR}, + #{CHECK_NO}, + #{WORK_CONTENT}, + #{WORK_PLACE}, + #{APPLY_DEPARTMENT_ID}, + #{APPLY_USER_ID}, + #{WORK_LEVEL}, + #{WORK_START_DATE}, + #{WORK_END_DATE}, + #{SPECIAL_WORK}, + #{RISK_IDENTIFICATION}, + #{CONFESS_DEPARTMENT_ID}, + #{CONFESS_USER_ID}, + #{ACCEPT_CONFESS_DEPARTMENT_ID}, + #{ACCEPT_CONFESS_USER_ID}, + #{GUARDIAN_DEPARTMENT_ID}, + #{GUARDIAN_USER_ID}, + #{CONFIRM_DEPARTMENT_ID}, + #{CONFIRM_USER_ID}, + #{LEADER_DEPARTMENT_ID}, + #{LEADER_USER_ID}, + #{AUDIT_DEPARTMENT_ID}, + #{AUDIT_USER_ID}, + #{APPROVE_DEPARTMENT_ID}, + #{APPROVE_USER_ID}, + #{ACCEPT_DEPARTMENT_ID}, + #{ACCEPT_USER_ID}, + #{WORK_START_DEPARTMENT_ID}, + #{WORK_START_USER_ID}, + #{WORK_END_DEPARTMENT_ID}, + #{WORK_END_USER_ID}, + #{ACCEPT_TIME}, + #{PLS_ID}, + #{PLS_NAME}, + #{WORK_POSITION}, + #{WORK_USER_DEPARTMENT_ID}, + #{WORK_USER_ID}, + #{WORK_HIGH} + + + + + + + + insert into + + ( + + ) values ( + + ) + + + + + update + + set + ISDELETE = '1' + where + HIGHWORK_ID = #{HIGHWORK_ID} + + + + + update + + set + HIGHWORK_ID = #{HIGHWORK_ID}, + CORPINFO_ID = #{CORPINFO_ID}, + TASK_ID = #{TASK_ID}, + OPERATTIME = #{OPERATTIME}, + OPERATOR = #{OPERATOR}, + CHECK_NO = #{CHECK_NO}, + WORK_CONTENT = #{WORK_CONTENT}, + WORK_PLACE = #{WORK_PLACE}, + APPLY_DEPARTMENT_ID = #{APPLY_DEPARTMENT_ID}, + APPLY_USER_ID = #{APPLY_USER_ID}, + WORK_LEVEL = #{WORK_LEVEL}, + WORK_START_DATE = #{WORK_START_DATE}, + WORK_END_DATE = #{WORK_END_DATE}, + SPECIAL_WORK = #{SPECIAL_WORK}, + RISK_IDENTIFICATION = #{RISK_IDENTIFICATION}, + CONFESS_DEPARTMENT_ID = #{CONFESS_DEPARTMENT_ID}, + CONFESS_USER_ID = #{CONFESS_USER_ID}, + ACCEPT_CONFESS_DEPARTMENT_ID = #{ACCEPT_CONFESS_DEPARTMENT_ID}, + ACCEPT_CONFESS_USER_ID = #{ACCEPT_CONFESS_USER_ID}, + GUARDIAN_DEPARTMENT_ID = #{GUARDIAN_DEPARTMENT_ID}, + GUARDIAN_USER_ID = #{GUARDIAN_USER_ID}, + CONFIRM_DEPARTMENT_ID = #{CONFIRM_DEPARTMENT_ID}, + CONFIRM_USER_ID = #{CONFIRM_USER_ID}, + LEADER_DEPARTMENT_ID = #{LEADER_DEPARTMENT_ID}, + LEADER_USER_ID = #{LEADER_USER_ID}, + AUDIT_DEPARTMENT_ID = #{AUDIT_DEPARTMENT_ID}, + AUDIT_USER_ID = #{AUDIT_USER_ID}, + APPROVE_DEPARTMENT_ID = #{APPROVE_DEPARTMENT_ID}, + APPROVE_USER_ID = #{APPROVE_USER_ID}, + ACCEPT_DEPARTMENT_ID = #{ACCEPT_DEPARTMENT_ID}, + ACCEPT_USER_ID = #{ACCEPT_USER_ID}, + WORK_START_DEPARTMENT_ID=#{WORK_START_DEPARTMENT_ID}, + WORK_START_USER_ID=#{WORK_START_USER_ID}, + WORK_END_DEPARTMENT_ID=#{WORK_END_DEPARTMENT_ID}, + WORK_END_USER_ID=#{WORK_END_USER_ID}, + ACCEPT_TIME = #{ACCEPT_TIME}, + PLS_ID = #{PLS_ID}, + PLS_NAME = #{PLS_NAME}, + WORK_POSITION =#{WORK_POSITION}, + WORK_USER_DEPARTMENT_ID = #{WORK_USER_DEPARTMENT_ID}, + WORK_USER_ID = #{WORK_USER_ID}, + WORK_HIGH = #{WORK_HIGH} + where + HIGHWORK_ID = #{HIGHWORK_ID} + + + + + + + + update + + set + + WORK_START_DATE = #{WORK_START_DATE}, + + + WORK_END_DATE = #{WORK_END_DATE}, + + + ACCEPT_TIME = #{ACCEPT_TIME}, + + STEP_ID = #{STEP_ID} + where + HIGHWORK_ID = #{HIGHWORK_ID} + + + + + + + + + + + diff --git a/src/main/resources/mybatis/datasource/eightwork/HighworkSignMapper.xml b/src/main/resources/mybatis/datasource/eightwork/HighworkSignMapper.xml new file mode 100644 index 0000000..a228d13 --- /dev/null +++ b/src/main/resources/mybatis/datasource/eightwork/HighworkSignMapper.xml @@ -0,0 +1,140 @@ + + + + + + + BUS_HIGHWORK_SIGN + + + + + SYS_DICTIONARIES + + + + + f.HIGHWORK_SIGN_ID, + f.HIGHWORK_ID, + f.CORPINFO_ID, + f.SIGN_USER_ID, + f.SIGN_PATH, + f.SIGN_TIME, + f.DESCR, + f.STEP_ID, + f.IMG_PATH + + + + + HIGHWORK_SIGN_ID, + HIGHWORK_ID, + CORPINFO_ID, + SIGN_USER_ID, + SIGN_PATH, + SIGN_TIME, + DESCR, + STEP_ID, + IMG_PATH + + + + + #{HIGHWORK_SIGN_ID}, + #{HIGHWORK_ID}, + #{CORPINFO_ID}, + #{SIGN_USER_ID}, + #{SIGN_PATH}, + #{SIGN_TIME}, + #{DESCR}, + #{STEP_ID}, + #{IMG_PATH} + + + + + insert into + + ( + + ) values ( + + ) + + + + insert into + + ( + HIGHWORK_SIGN_ID, + HIGHWORK_ID, + CORPINFO_ID, + SIGN_USER_ID, + STEP_ID + ) values + + (#{item.HIGHWORK_SIGN_ID}, + #{item.HIGHWORK_ID}, + #{item.CORPINFO_ID}, + #{item.SIGN_USER_ID}, + #{item.STEP_ID}) + + + + + + update + + set + DESCR = #{DESCR}, + SIGN_PATH = #{SIGN_PATH}, + SIGN_TIME= #{SIGN_TIME}, + IMG_PATH = #{IMG_PATH} + where + HIGHWORK_ID = #{HIGHWORK_ID} and SIGN_USER_ID = #{SIGN_USER_ID} and STEP_ID = #{STEP_ID} + + + + + + + + + + diff --git a/src/main/resources/mybatis/datasource/eightwork/HighworkToMeasuresMapper.xml b/src/main/resources/mybatis/datasource/eightwork/HighworkToMeasuresMapper.xml new file mode 100644 index 0000000..dacc1bc --- /dev/null +++ b/src/main/resources/mybatis/datasource/eightwork/HighworkToMeasuresMapper.xml @@ -0,0 +1,156 @@ + + + + + + + BUS_HIGHWORKTOMEASURES + + + + + SYS_DICTIONARIES + + + + + f.HIGHWORK_ID, + f.BUS_HIGHWORK_MEASURES_ID, + f.STATUS, + f.HIGHWORKTOMEASURES_ID, + f.CONFIRM_ID, + f.SIGN_PATH, + f.SIGN_TIME, + f.IMG_PATH + + + + + HIGHWORK_ID, + BUS_HIGHWORK_MEASURES_ID, + STATUS, + HIGHWORKTOMEASURES_ID, + CONFIRM_ID, + SIGN_PATH, + SIGN_TIME, + IMG_PATH + + + + + #{HIGHWORK_ID}, + #{BUS_HIGHWORK_MEASURES_ID}, + #{STATUS}, + #{HIGHWORKTOMEASURES_ID}, + #{CONFIRM_ID}, + #{SIGN_PATH}, + #{SIGN_TIME}, + #{IMG_PATH} + + + + + insert into + + ( + + ) values ( + + ) + + + + insert into + + ( + HIGHWORK_ID, + BUS_HIGHWORK_MEASURES_ID, + HIGHWORKTOMEASURES_ID, + CONFIRM_ID + ) values + + ( + #{item.HIGHWORK_ID}, + #{item.BUS_HIGHWORK_MEASURES_ID}, + #{item.HIGHWORKTOMEASURES_ID}, + #{item.CONFIRM_ID} + ) + + + + + + delete from + + where + HIGHWORK_ID = #{HIGHWORK_ID} + + + + + update + + set + STATUS = #{STATUS}, + SIGN_PATH = #{SIGN_PATH}, + IMG_PATH = #{IMG_PATH}, + SIGN_TIME = #{SIGN_TIME} + where + HIGHWORKTOMEASURES_ID = #{HIGHWORKTOMEASURES_ID} + + + + + + + + + + + update + + set + ISDELETE = '1' + where + HIGHWORKTOMEASURES_ID in + + #{item} + + + + + + + + +