|
|
@@ -1,18 +1,15 @@
|
|
|
package com.management.platform.service.impl;
|
|
|
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
|
|
-import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
|
|
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
-import com.baomidou.mybatisplus.extension.service.additional.update.impl.LambdaUpdateChainWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
-import com.github.pagehelper.util.StringUtil;
|
|
|
import com.management.platform.entity.*;
|
|
|
import com.management.platform.entity.dto.TaskDto;
|
|
|
-import com.management.platform.entity.vo.ContactsVo;
|
|
|
+import com.management.platform.entity.vo.TasKVo;
|
|
|
import com.management.platform.entity.vo.TasKVo;
|
|
|
import com.management.platform.mapper.*;
|
|
|
import com.management.platform.service.*;
|
|
|
@@ -35,6 +32,8 @@ import org.springframework.web.multipart.MultipartFile;
|
|
|
import javax.annotation.Resource;
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
import java.io.*;
|
|
|
+import java.lang.reflect.Field;
|
|
|
+import java.lang.reflect.Method;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.time.LocalDate;
|
|
|
import java.time.LocalDateTime;
|
|
|
@@ -66,6 +65,18 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements Ta
|
|
|
@Resource
|
|
|
private TaskRepeatDesignMapper taskRepeatDesignMapper;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private WxCorpInfoService wxCorpInfoService;
|
|
|
+
|
|
|
+ @Value(value = "${upload.path}")
|
|
|
+ private String path;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private ExcelExportServiceImpl excelExportService;
|
|
|
+
|
|
|
+ @Resource
|
|
|
+ private SysFormMapper sysFormMapper;
|
|
|
+
|
|
|
|
|
|
@Override
|
|
|
@Transactional
|
|
|
@@ -231,6 +242,270 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, Task> implements Ta
|
|
|
return msg;
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ @Transactional(rollbackFor = Exception.class)
|
|
|
+ public HttpRespMsg importData(MultipartFile multipartFile, HttpServletRequest request) {
|
|
|
+ HttpRespMsg msg=new HttpRespMsg();
|
|
|
+ String fileName = multipartFile.getOriginalFilename();
|
|
|
+ File file = new File(fileName == null ? "file" : fileName);
|
|
|
+ User user = userMapper.selectById(request.getHeader("token"));
|
|
|
+ Integer companyId = user.getCompanyId();
|
|
|
+ WxCorpInfo wxCorpInfo = wxCorpInfoService.getOne(new LambdaQueryWrapper<WxCorpInfo>().eq(WxCorpInfo::getCompanyId, companyId));
|
|
|
+
|
|
|
+ List<User> userList = userMapper.selectList(new LambdaQueryWrapper<User>().eq(User::getCompanyId, companyId));
|
|
|
+ InputStream inputStream = null;
|
|
|
+ OutputStream outputStream = null;
|
|
|
+
|
|
|
+ try {
|
|
|
+ inputStream = multipartFile.getInputStream();
|
|
|
+ outputStream = new FileOutputStream(file);
|
|
|
+ byte[] buffer = new byte[4096];
|
|
|
+ int temp = 0;
|
|
|
+ while ((temp = inputStream.read(buffer, 0, 4096)) != -1) {
|
|
|
+ outputStream.write(buffer, 0, temp);
|
|
|
+ }
|
|
|
+ inputStream.close();
|
|
|
+ outputStream.close();
|
|
|
+
|
|
|
+ //解析表格
|
|
|
+ HSSFWorkbook workbook = new HSSFWorkbook(new FileInputStream(file));
|
|
|
+ //我们只需要第一个sheet
|
|
|
+ HSSFSheet sheet = workbook.getSheetAt(0);
|
|
|
+ //由于第一行需要指明列对应的标题
|
|
|
+ int rowNum = sheet.getLastRowNum();
|
|
|
+ //获取当前表单模板 校验规则
|
|
|
+ SysForm sysForm = sysFormMapper.selectOne(new LambdaQueryWrapper<SysForm>().eq(SysForm::getCode, "Task").eq(SysForm::getCompanyId, companyId).eq(SysForm::getIsCurrent, 1));
|
|
|
+ if(sysForm==null){
|
|
|
+ msg.setError("当前模块未配置自定义模板,需先完成配置");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+
|
|
|
+ String config = sysForm.getConfig();
|
|
|
+ JSONObject configOb = JSON.parseObject(config);
|
|
|
+ JSONArray configObJSONArray = configOb.getJSONArray("list");
|
|
|
+
|
|
|
+ List<Task> importTaskList=new ArrayList<>();
|
|
|
+ List<String> userNameList=new ArrayList<>();
|
|
|
+ HttpRespMsg respMsg=new HttpRespMsg();
|
|
|
+
|
|
|
+ for (int rowIndex = 1; rowIndex <= rowNum; rowIndex++) {
|
|
|
+ HSSFRow row = sheet.getRow(rowIndex);
|
|
|
+ if (row == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //跳过空行
|
|
|
+ if (ExcelUtil.isRowEmpty(row)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //获取到当前行的列数据
|
|
|
+ int cellNum = row.getLastCellNum();
|
|
|
+
|
|
|
+ for (int i = 0; i < cellNum; i++) {
|
|
|
+ JSONObject item = configObJSONArray.getJSONObject(i);
|
|
|
+ String modelName = item.getString("model");
|
|
|
+ HSSFCell cell = row.getCell(i);
|
|
|
+ if(cell!=null){
|
|
|
+ switch (item.getString("type")){
|
|
|
+ case "time":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ case "int":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ default:cell.setCellType(CellType.STRING);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ if(modelName.equals("inchargerId")){
|
|
|
+ if(!org.springframework.util.StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ userNameList.add(cell.getStringCellValue());
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ System.out.println("参与搜素的人员列表"+userNameList + userNameList.size());
|
|
|
+ if(wxCorpInfo!=null&&wxCorpInfo.getSaasSyncContact()==1&&userNameList.size()>0){
|
|
|
+ respMsg = wxCorpInfoService.getBatchSearchUserInfo(wxCorpInfo, userNameList,null);
|
|
|
+ if(respMsg.code.equals("0")){
|
|
|
+ msg.setError("姓名为["+String.valueOf(respMsg.data)+"]的人员存在重复,请使用工号!");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ List<User> targetUserList= (List<User>) respMsg.data;
|
|
|
+
|
|
|
+ for (int rowIndex = 1; rowIndex <= rowNum; rowIndex++) {
|
|
|
+ HSSFRow row = sheet.getRow(rowIndex);
|
|
|
+ if (row == null) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //跳过空行
|
|
|
+ if (ExcelUtil.isRowEmpty(row)) {
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ //获取到当前行的列数据
|
|
|
+ int cellNum = row.getLastCellNum();
|
|
|
+ Task task=new Task();
|
|
|
+ task.setCompanyId(companyId);
|
|
|
+ task.setCreaterId(user.getId());
|
|
|
+ task.setCreateDate(LocalDate.now());
|
|
|
+ for (int i = 0; i < cellNum; i++) {
|
|
|
+ JSONObject item = configObJSONArray.getJSONObject(i);
|
|
|
+ String modelName = item.getString("model");
|
|
|
+ String className = modelName.substring(0, 1).toUpperCase() + modelName.substring(1);
|
|
|
+ String getter="get"+className;
|
|
|
+ String setter="set"+className;
|
|
|
+ HSSFCell cell = row.getCell(i);
|
|
|
+ if(cell!=null){
|
|
|
+ switch (item.getString("type")){
|
|
|
+ case "time":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ case "int":cell.setCellType(CellType.NUMERIC);
|
|
|
+ break;
|
|
|
+ default:cell.setCellType(CellType.STRING);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ Class<Task> taskClass = Task.class;
|
|
|
+ Field field = taskClass.getDeclaredField(modelName);
|
|
|
+ Class<?> type = field.getType();
|
|
|
+ Method method = taskClass.getMethod(setter, type);
|
|
|
+ //校验当前列是否为必填
|
|
|
+ JSONObject options = item.getJSONObject("options");
|
|
|
+ JSONObject rules = options.getJSONObject("rules");
|
|
|
+ Boolean required = rules.getBoolean("required");
|
|
|
+ if(required){
|
|
|
+ if(StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ msg.setError(item.getString("label")+"值不能为空值");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /*if(modelName.equals("taskCode")){
|
|
|
+ if(!org.springframework.util.StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ //系统中同公司已存在的产品编码 更新
|
|
|
+ Optional<Task> first = taskList.stream().filter(p ->p.getTaskCode()!=null&& p.getTaskCode().equals(cell.getStringCellValue())).findFirst();
|
|
|
+ if(first.isPresent()){
|
|
|
+ task.setId(first.get().getId());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }*/
|
|
|
+ if(modelName.equals("inchargerId")){
|
|
|
+ if(!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ String userName = cell.getStringCellValue();
|
|
|
+ Optional<User> first;
|
|
|
+ if(wxCorpInfo!=null&&wxCorpInfo.getSaasSyncContact()==1){
|
|
|
+ Optional<User> optional = targetUserList.stream().filter(tl -> tl.getName().equals(userName)).findFirst();
|
|
|
+ first= userList.stream().filter(u ->(u.getJobNumber()!=null&&u.getJobNumber().equals(userName))||(optional.isPresent()&&u.getCorpwxUserid()!=null&&u.getCorpwxUserid().equals(optional.get().getCorpwxUserid()))).findFirst();
|
|
|
+ }else {
|
|
|
+ first= userList.stream().filter(u -> u.getName().equals(userName)||(u.getJobNumber()!=null&&u.getJobNumber().equals(userName))).findFirst();
|
|
|
+ }
|
|
|
+ if (first.isPresent()) {
|
|
|
+ task.setOwnerId(first.get().getId());
|
|
|
+ } else {
|
|
|
+ throw new Exception("["+userName+"]在系统中不存在");
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+ /*if(cell.getCellType()==CellType.STRING.getCode()&&!StringUtils.isEmpty(cell.getStringCellValue())){
|
|
|
+ method.invoke(task,cell.getStringCellValue());
|
|
|
+ } else if (cell.getCellType()==CellType.NUMERIC.getCode()) {
|
|
|
+
|
|
|
+
|
|
|
+ }*/
|
|
|
+ if (cell != null && cell.getCellTypeEnum() != CellType.BLANK) {
|
|
|
+ if (cell.getCellTypeEnum() == CellType.STRING && cell.getStringCellValue() != null && !cell.getStringCellValue().isEmpty()) {
|
|
|
+ // 字符串类型不为空
|
|
|
+ method.invoke(task,cell.getStringCellValue());
|
|
|
+ } else if (cell.getCellTypeEnum() == CellType.NUMERIC) {
|
|
|
+ // 数值类型不为空
|
|
|
+ double numericCellValue = cell.getNumericCellValue();
|
|
|
+ if (type.getSimpleName().equals("Integer")){
|
|
|
+ int intValue = (int) numericCellValue;
|
|
|
+ method.invoke(task,intValue);
|
|
|
+ }
|
|
|
+ else {
|
|
|
+ method.invoke(task, numericCellValue);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ importTaskList.add(task);
|
|
|
+ }
|
|
|
+
|
|
|
+ if(importTaskList.size()>0){
|
|
|
+ if(!saveOrUpdateBatch(importTaskList)){
|
|
|
+ msg.setError("验证失败");
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (IOException e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ } catch (Exception e) {
|
|
|
+ throw new RuntimeException(e);
|
|
|
+ }
|
|
|
+
|
|
|
+ return msg;
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public HttpRespMsg exportData(TaskDto taskDto, HttpServletRequest request) throws Exception{
|
|
|
+ User user = userMapper.selectById(request.getHeader("token"));
|
|
|
+ SysForm sysForm = sysFormMapper.selectOne(new LambdaQueryWrapper<SysForm>().eq(SysForm::getCompanyId, user.getCompanyId()).eq(SysForm::getCode, "Task").eq(SysForm::getIsCurrent, 1));
|
|
|
+ WxCorpInfo wxCorpInfo = wxCorpInfoService.getOne(new LambdaQueryWrapper<WxCorpInfo>().eq(WxCorpInfo::getCompanyId, user.getCompanyId()));
|
|
|
+ String config = sysForm.getConfig();
|
|
|
+ JSONObject configOb = JSON.parseObject(config);
|
|
|
+ JSONArray configObJSONArray = configOb.getJSONArray("list");
|
|
|
+ List<List<String>> dataList=new ArrayList<>();
|
|
|
+ List<String> titleList=new ArrayList<>();
|
|
|
+ for (int i = 0; i < configObJSONArray.size(); i++) {
|
|
|
+ JSONObject item = configObJSONArray.getJSONObject(i);
|
|
|
+ titleList.add(item.getString("label"));
|
|
|
+ }
|
|
|
+ dataList.add(titleList);//设置表头
|
|
|
+
|
|
|
+ taskDto.setCompanyId(user.getCompanyId());
|
|
|
+ taskDto.setPageIndex(null).setPageSize(null);//暂时部不分页
|
|
|
+ List<TasKVo> taskVoList =taskMapper.getPageListTask(taskDto);
|
|
|
+ if (!taskVoList.isEmpty()){
|
|
|
+ taskVoList.forEach(tasKVo -> {
|
|
|
+ if (!tasKVo.getTaskExecutors().isEmpty()){
|
|
|
+ Integer taskId = tasKVo.getId();
|
|
|
+ LambdaQueryWrapper<TaskExecutor> lqw = new LambdaQueryWrapper<>();
|
|
|
+ lqw.eq(TaskExecutor::getTaskId,taskId);
|
|
|
+ List<TaskExecutor> taskExecutors = taskExecutorMapper.selectList(lqw);
|
|
|
+ tasKVo.setTaskExecutors(taskExecutors);
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
+ for (TasKVo tasKVo : taskVoList) {
|
|
|
+ List<String> item=new ArrayList<>();
|
|
|
+ for (int i = 0; i < configObJSONArray.size(); i++) {
|
|
|
+ JSONObject target = configObJSONArray.getJSONObject(i);
|
|
|
+ String model = target.getString("model");
|
|
|
+// String targetName = model.substring(0, 1).toUpperCase() + model.substring(1);
|
|
|
+ Class<? extends TasKVo> aClass = tasKVo.getClass();
|
|
|
+ String value="";
|
|
|
+// String value = String.valueOf(aClass.getMethod("get" + targetName).invoke(tasKVo)==null?"":aClass.getMethod("get" + targetName).invoke(tasKVo));
|
|
|
+ /*if(model.equals("inchargerId")){
|
|
|
+ if(wxCorpInfo!=null&&wxCorpInfo.getSaasSyncContact()==1){
|
|
|
+ value = "$userName"+String.valueOf(aClass.getMethod("getInchargerName").invoke(product))+"$";
|
|
|
+ }else {
|
|
|
+ value = String.valueOf(aClass.getMethod("getInchargerName").invoke(product));
|
|
|
+ }
|
|
|
+ }*/
|
|
|
+ /*if(model.equals("sex")){
|
|
|
+ value = String.valueOf(aClass.getMethod("getSex").invoke(tasKVo)).equals("null") ?"":String.valueOf(aClass.getMethod("getSex").invoke(tasKVo));
|
|
|
+ }*/
|
|
|
+ if(model.equals("taskName")){
|
|
|
+ value = String.valueOf(aClass.getMethod("getTaskName").invoke(tasKVo)).equals("null")?"":String.valueOf(aClass.getMethod("getTaskName").invoke(tasKVo));
|
|
|
+ }
|
|
|
+ item.add(value);
|
|
|
+ }
|
|
|
+ dataList.add(item);
|
|
|
+ }
|
|
|
+ String fileName="联系人表导出_"+ System.currentTimeMillis();
|
|
|
+ return excelExportService.exportGeneralExcelByTitleAndList(wxCorpInfo,fileName,dataList,path);
|
|
|
+ }
|
|
|
+
|
|
|
public void updateTaskRepeatConfigure(Task task){
|
|
|
task.setRepeatType(null).setRepeatEndNever(null).setRepeatEndCount(null)
|
|
|
.setRepeatEndDate(null).setRepeatDesignDay(null).setRepeatDesignSameday(null);
|
