From 1d53dd8f501a98ddcce8146443b51b357ef5f9b1 Mon Sep 17 00:00:00 2001
From: 13693261870 <252740454@qq.com>
Date: 星期四, 29 十二月 2022 16:55:46 +0800
Subject: [PATCH] 1
---
src/main/java/com/lf/server/service/show/ApplyService.java | 141 +++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 137 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/lf/server/service/show/ApplyService.java b/src/main/java/com/lf/server/service/show/ApplyService.java
index 97d604a..28ad5ac 100644
--- a/src/main/java/com/lf/server/service/show/ApplyService.java
+++ b/src/main/java/com/lf/server/service/show/ApplyService.java
@@ -1,11 +1,20 @@
package com.lf.server.service.show;
+import com.lf.server.entity.ctrl.DownloadReqEntity;
import com.lf.server.entity.show.ApplyEntity;
+import com.lf.server.entity.show.FlowEntity;
+import com.lf.server.entity.sys.UserEntity;
+import com.lf.server.helper.AesHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.mapper.show.ApplyMapper;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import java.sql.Timestamp;
+import java.util.ArrayList;
+import java.util.Arrays;
import java.util.List;
/**
@@ -17,14 +26,26 @@
@Autowired
ApplyMapper applyMapper;
+ @Autowired
+ FlowService flowService;
+
+ @Autowired
+ DataLibService dataLibService;
+
+ private final static Log log = LogFactory.getLog(ApplyService.class);
+
@Override
- public Integer selectCount(Integer userid) {
- return applyMapper.selectCount(userid);
+ public Integer selectCount(String uname, Integer status, Timestamp start, Timestamp end) {
+ uname = StringHelper.getLikeStr(uname);
+
+ return applyMapper.selectCount(uname, status, start, end);
}
@Override
- public List<ApplyEntity> selectByPage(Integer userid, Integer limit, Integer offset) {
- return applyMapper.selectByPage(userid, limit, offset);
+ public List<ApplyEntity> selectByPage(Integer userid, String uname, Integer status, Timestamp start, Timestamp end, Integer limit, Integer offset) {
+ uname = StringHelper.getLikeStr(uname);
+
+ return applyMapper.selectByPage(userid, uname, status, start, end, limit, offset);
}
@Override
@@ -35,6 +56,21 @@
@Override
public ApplyEntity selectById(int id) {
return applyMapper.selectById(id);
+ }
+
+ @Override
+ public UserEntity selectUserByDepid(Integer depid) {
+ return applyMapper.selectUserByDepid(depid);
+ }
+
+ @Override
+ public Integer selectSubmits(Integer userid) {
+ return applyMapper.selectSubmits(userid);
+ }
+
+ @Override
+ public List<FlowEntity> selectFlows(Integer applyid) {
+ return applyMapper.selectFlows(applyid);
}
@Override
@@ -66,4 +102,101 @@
public Integer updates(List<ApplyEntity> list) {
return applyMapper.updates(list);
}
+
+ @Override
+ public Integer updateForDiscard(Integer userid, Integer id) {
+ return applyMapper.updateForDiscard(userid, id);
+ }
+
+ @Override
+ public Integer updateForResubmit(Integer userid, Integer id) {
+ return applyMapper.updateForResubmit(userid, id);
+ }
+
+ @Override
+ public Integer updateForSubmit(Integer userid, Integer applyid, Integer flowId) {
+ return applyMapper.updateForSubmit(userid, applyid, flowId);
+ }
+
+ @Override
+ public Integer updateForReject(Integer userid, Integer applyid, Integer flowId) {
+ return applyMapper.updateForReject(userid, applyid, flowId);
+ }
+
+ /**
+ * 鎻掑叆鏁版嵁鐢宠
+ */
+ public Integer insertApply(UserEntity ue, DownloadReqEntity dr) throws Exception {
+ ApplyEntity apply = getApplyEntity(ue, dr);
+ int rows = applyMapper.insert(apply);
+ if (0 == rows) {
+ return 0;
+ }
+
+ List<FlowEntity> list = getFlowEntities(apply.getId(), ue, dr);
+ rows = flowService.inserts(list);
+
+ return rows;
+ }
+
+ /**
+ * 鑾峰彇鏁版嵁鐢宠瀹炰綋绫�
+ */
+ private ApplyEntity getApplyEntity(UserEntity ue, DownloadReqEntity dr) throws Exception {
+ // String dbPwd = Md5Helper.reverse(Md5Helper.generate(dr.getPwd()))
+ String aesPwd = AesHelper.encrypt(dr.getPwd());
+
+ ApplyEntity apply = new ApplyEntity();
+ apply.setUserid(ue.getId());
+ apply.setDepids(StringHelper.join(dr.getIds(), ","));
+ apply.setTabs(StringHelper.join(dr.getTabs(), ","));
+ apply.setEntities(StringHelper.join(dr.getEntities(), ","));
+ apply.setWkt(dr.getWkt());
+ apply.setPwd(aesPwd);
+ apply.setStatus(0);
+ apply.setCount(dr.getIds().size());
+ apply.setDescr(dr.getDescr());
+ apply.setCreateUser(ue.getId());
+
+ return apply;
+ }
+
+ /**
+ * 鑾峰彇鐢宠娴佺▼瀹炰綋绫婚泦鍚�
+ */
+ private List<FlowEntity> getFlowEntities(Integer applyId, UserEntity ue, DownloadReqEntity dr) {
+ List<FlowEntity> list = new ArrayList<>();
+ for (Integer depid : dr.getIds()) {
+ UserEntity user = selectUserByDepid(depid);
+ if (null == user) {
+ continue;
+ }
+
+ FlowEntity flow = new FlowEntity();
+ flow.setApplyid(applyId);
+ flow.setDepid(depid);
+ flow.setUserid(user.getId());
+ flow.setStatus(0);
+ flow.setDescr(null);
+ flow.setCreateUser(ue.getId());
+
+ list.add(flow);
+ }
+
+ return list;
+ }
+
+ /**
+ * 鎵撳寘DB鏁版嵁
+ */
+ public void zipDbData(UserEntity ue, ApplyEntity entity) {
+ try {
+ List<String> entities = Arrays.asList(entity.getEntities().split(","));
+ String pwd = AesHelper.decrypt(entity.getPwd());
+
+ dataLibService.createZipFile(ue, entities, entity.getWkt(), pwd);
+ } catch (Exception ex) {
+ log.error(ex.getMessage(), ex);
+ }
+ }
}
--
Gitblit v1.9.3