package com.ltkj.tduck.service.impl;
|
|
import cn.hutool.core.bean.BeanUtil;
|
import cn.hutool.core.map.MapUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ltkj.common.utils.ip.AddressUtils;
|
import com.ltkj.tduck.constant.CommonConstants;
|
import com.ltkj.tduck.domain.UserFormDataEntity;
|
import com.ltkj.tduck.mapper.UserFormDataMapper;
|
import com.ltkj.tduck.request.QueryFormResultRequest;
|
import com.ltkj.tduck.service.UserFormDataService;
|
import com.ltkj.tduck.service.UserFormItemService;
|
import com.ltkj.tduck.utils.CacheUtils;
|
import com.ltkj.tduck.utils.FormDataUtils;
|
import com.ltkj.tduck.utils.Result;
|
import com.ltkj.tduck.vo.FormDataTableVO;
|
import com.ltkj.tduck.vo.FormFieldVO;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import static com.ltkj.tduck.constant.FormRedisKeyConstants.FORM_RESULT_NUMBER;
|
|
|
/**
|
* 表单表单项(FormResult)表服务实现类
|
*
|
* @author smalljop
|
* @since 2020-11-23 14:09:22
|
*/
|
@Service
|
@Slf4j
|
@RequiredArgsConstructor
|
public class UserFormDataServiceImpl extends ServiceImpl<UserFormDataMapper, UserFormDataEntity> implements UserFormDataService {
|
|
private final UserFormItemService userFormItemService;
|
private final CacheUtils redisUtils;
|
private final FormDataUtils formDataUtils;
|
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Map<String, Object> saveFormResult(UserFormDataEntity entity) {
|
HashMap<String, Object> result = MapUtil.newHashMap();
|
String formKey = entity.getFormKey();
|
entity.setSubmitAddress(AddressUtils.getRealAddressByIP(entity.getSubmitRequestIp()));
|
entity.setSerialNumber(redisUtils.incr(StrUtil.format(FORM_RESULT_NUMBER, formKey), CommonConstants.ConstantNumber.ONE));
|
this.save(entity);
|
// formDataUtils.syncSaveFormData(entity);
|
result.put("id", entity.getId());
|
return result;
|
}
|
|
|
/**
|
* 下载表单结果中的附件
|
*
|
* @param request
|
* @return
|
*/
|
// @Override
|
// public Result downloadFormResultFile(QueryFormResultRequest request) {
|
// String uuid = IdUtil.simpleUUID();
|
// List<UserFormItemEntity> userFormItemEntityList = userFormItemService.list(Wrappers.<UserFormItemEntity>lambdaQuery().eq(UserFormItemEntity::getFormKey, request.getFormKey()).in(UserFormItemEntity::getType, CollUtil.newArrayList(FormItemTypeEnum.UPLOAD.toString(), FormItemTypeEnum.IMAGE_UPLOAD.toString())));
|
// //结果
|
// List<Map> rows = null;
|
// if (ObjectUtil.isNull(request.getCurrent()) && ObjectUtil.isNull(request.getSize())) {
|
// rows = formDataUtils.searchAll(request);
|
// } else {
|
// FormDataTableVO formDataTableVO = this.listFormDataTable(request);
|
// rows = formDataTableVO.getRows();
|
// }
|
// if (CollectionUtil.isEmpty(rows) || CollectionUtil.isEmpty(userFormItemEntityList)) {
|
// return Result.failed("暂无收集附件，无法下载");
|
// }
|
// List<Map> finalRows = rows;
|
// ThreadUtil.execAsync(() -> {
|
// TimeInterval timer = DateUtil.timer();
|
// List<String> paths = new ArrayList<>();
|
// List<InputStream> ins = new ArrayList<>();
|
// try {
|
// finalRows.forEach(result -> {
|
// int index = 0;
|
// userFormItemEntityList.forEach(item -> {
|
// List<UploadResultStruct> uploadResults = JsonUtils.jsonToList(JsonUtils.objToJson(MapUtil.get(result, item.getFormItemId(), List.class)), UploadResultStruct.class);
|
// if (CollectionUtil.isNotEmpty(uploadResults)) {
|
// uploadResults.forEach(uFile -> {
|
// if (StrUtil.isNotBlank(uFile.getUrl())) {
|
// paths.add(FileNameUtil.getName(uFile.getUrl()));
|
// byte[] bytes = HttpUtil.downloadBytes(uFile.getUrl());
|
// ins.add(IoUtil.toStream(bytes));
|
// }
|
// });
|
// }
|
// });
|
// AsyncProcessUtils.setProcess(uuid, ++index / finalRows.size());
|
// });
|
// // 压缩上传oss
|
// ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream();
|
// ZipUtil.zip(zipOutputStream, paths.toArray(new String[]{}), ins.toArray(new InputStream[]{}));
|
// String downloadUrl = OssStorageFactory.getStorageService().upload(zipOutputStream.toByteArray(), StorageUtils.generateFileName("download", ".zip"));
|
// AsyncProcessUtils.setProcess(uuid, downloadUrl);
|
// log.info("export file cost time: {}", timer.interval());
|
// } catch (Exception e) {
|
// log.error("download file", e);
|
// }
|
// });
|
// return Result.success(uuid);
|
// }
|
//
|
//
|
@Override
|
public FormDataTableVO listFormDataTable(QueryFormResultRequest request) {
|
return formDataUtils.search(request);
|
}
|
//
|
//
|
// @Override
|
// public Boolean deleteByIds(List<String> dataIdList, String formKey) {
|
// baseMapper.deleteBatchIds(dataIdList);
|
// formDataUtils.asyncDeleteEsDocument(dataIdList, formKey);
|
// return true;
|
// }
|
//
|
// @Override
|
// public Boolean updateFormResult(UserFormDataEntity entity) {
|
// UserFormDataEntity dataEntity = this.getById(entity.getId());
|
// dataEntity.setOriginalData(entity.getOriginalData());
|
// dataEntity.setUpdateBy(entity.getUpdateBy());
|
// boolean update = this.updateById(dataEntity);
|
// // 查询数据 同步到es 避免数据变空被覆盖
|
// formDataUtils.asyncUpdateEsDocument(dataEntity);
|
// return update;
|
// }
|
|
@Override
|
public Result getFormDataDetails(String dataId) {
|
Map<String, Object> result =new HashMap<>();
|
UserFormDataEntity dataEntity = this.getById(dataId);
|
List<FormFieldVO> formFields = userFormItemService.listFormFields(dataEntity.getFormKey());
|
// 表单字段
|
result.put("formFields", formFields);
|
// 表单填写数据
|
if (ObjectUtil.isNotNull(dataEntity)) {
|
Map<String, Object> originalData = dataEntity.getOriginalData();
|
dataEntity.setOriginalData(null);
|
originalData.putAll(BeanUtil.beanToMap(dataEntity, false, true));
|
result.put("formData", originalData);
|
}
|
return Result.success(result);
|
}
|
}
|
