|
@@ -1,160 +0,0 @@
|
|
|
-package com.fdkankan.goods.service.impl;
|
|
|
-
|
|
|
-import com.fdkankan.agent.controller.request.RequestSearch;
|
|
|
-import com.fdkankan.common.base.AbstractService;
|
|
|
-import com.fdkankan.common.base.IOperations;
|
|
|
-import com.fdkankan.common.constant.ErrorCode;
|
|
|
-import com.fdkankan.common.response.ResultData;
|
|
|
-import com.fdkankan.common.util.FileUtil;
|
|
|
-import com.fdkankan.common.util.FileUtils;
|
|
|
-import com.fdkankan.common.validation.ValidationUtils;
|
|
|
-import com.fdkankan.goods.entity.CameraVersion;
|
|
|
-import com.fdkankan.goods.mapper.ICameraVersionMapper;
|
|
|
-import com.fdkankan.goods.service.ICameraVersionService;
|
|
|
-import org.apache.commons.lang.StringUtils;
|
|
|
-import org.slf4j.Logger;
|
|
|
-import org.slf4j.LoggerFactory;
|
|
|
-import org.springframework.stereotype.Service;
|
|
|
-import org.springframework.web.multipart.MultipartFile;
|
|
|
-
|
|
|
-import javax.annotation.Resource;
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
-import java.util.Base64;
|
|
|
-import java.util.Date;
|
|
|
-import java.util.LinkedHashMap;
|
|
|
-import java.util.List;
|
|
|
-
|
|
|
-@Service("CameraVersionService")
|
|
|
-public class CameraVersionService extends AbstractService<CameraVersion> implements ICameraVersionService {
|
|
|
-
|
|
|
- private static Logger log = LoggerFactory.getLogger("programLog");
|
|
|
-
|
|
|
- private static String ALIYUN_SSO_PATH = "camera_version/";
|
|
|
-
|
|
|
- private static String YAMAXUN_S3_PATH = "https://eurs3.4dkankan.com/camera_version/";
|
|
|
-
|
|
|
- private static String DIR_NAME = "camera_version/";
|
|
|
-
|
|
|
- public CameraVersionService() {
|
|
|
- this.setTableName("t_camera_version");
|
|
|
- }
|
|
|
- @Resource
|
|
|
- private ICameraVersionMapper tCameraVersionMapper;
|
|
|
-
|
|
|
- @Override
|
|
|
- protected IOperations<CameraVersion> getMapper() {
|
|
|
- return tCameraVersionMapper;
|
|
|
- }
|
|
|
- @Override
|
|
|
- public void setTableName(String tableName){
|
|
|
- this.tableName = tableName;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public ResultData updateStatus(Long id, String status, String type) {
|
|
|
- LinkedHashMap<String,String> condition = new LinkedHashMap<>();
|
|
|
- condition.put("id= "+id,"and");
|
|
|
- CameraVersion cameraVersion = this.getOne(condition);
|
|
|
- if(cameraVersion == null){
|
|
|
- return ResultData.error(ErrorCode.FAILURE_CODE_3001);
|
|
|
- }
|
|
|
- if (!ValidationUtils.validateRecStatus(status)) {
|
|
|
- return ResultData.error(ErrorCode.FAILURE_CODE_3001);
|
|
|
- }
|
|
|
-
|
|
|
- condition = new LinkedHashMap<>();
|
|
|
- if(StringUtils.isBlank(type)){
|
|
|
- type = "1";
|
|
|
- }
|
|
|
- condition.put("res_status = 'A'","and");
|
|
|
- condition.put("type = "+ type,"and");
|
|
|
- List<CameraVersion> list = this.getAllList(condition);
|
|
|
- for (CameraVersion version : list) {
|
|
|
- version.setAcStatus("I");
|
|
|
- }
|
|
|
- this.update(list);
|
|
|
-
|
|
|
- cameraVersion.setAcStatus(status);
|
|
|
- this.update(cameraVersion);
|
|
|
- return ResultData.ok();
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public ResultData searchLike(RequestSearch param) {
|
|
|
- Integer pageNum = Integer.valueOf(param.getPageNum());
|
|
|
- Integer pageSize = Integer.valueOf(param.getPageSize());
|
|
|
- String startDate = param.getStartDate();
|
|
|
- String endDate = param.getEndDate();
|
|
|
- String itemName = param.getItemName();
|
|
|
- Integer type = StringUtils.isNotBlank(param.getType()) ? Integer.valueOf(param.getType()) : 1;
|
|
|
-
|
|
|
- LinkedHashMap<String,String> condition = new LinkedHashMap<>();
|
|
|
- condition.put("rec_status ='A'","and");
|
|
|
- condition.put("camera_type ="+type,"and");
|
|
|
- if(StringUtils.isNotBlank(startDate)){
|
|
|
- condition.put("create_time >= '"+startDate+"'","and");
|
|
|
- }
|
|
|
- if(StringUtils.isNotBlank(endDate)){
|
|
|
- condition.put("create_time <= '"+endDate+"' ","and");
|
|
|
- }
|
|
|
- if(StringUtils.isNotBlank(itemName)){
|
|
|
- condition.put("((file_name like '%"+itemName+"%' )","and");
|
|
|
- condition.put("(version like '%"+itemName+"%' )","or");
|
|
|
- condition.put("(note_content like '%"+itemName+"%' ))","or");
|
|
|
- }
|
|
|
- List<CameraVersion> list = this.getList(condition, pageNum,pageSize,"create_time desc");
|
|
|
- Integer total = this.getCount(condition,null);
|
|
|
- return ResultData.ok(pageNum,pageSize,total,list);
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- /**
|
|
|
- * 上传文件到阿里云
|
|
|
- */
|
|
|
- @Override
|
|
|
- public ResultData upload(MultipartFile file, String version, String description, String minVersion, String StringType) throws Exception{
|
|
|
- Integer type = StringUtils.isNotBlank(StringType) ? Integer.valueOf(StringType) : 1;
|
|
|
- log.info("run upload");
|
|
|
- if (!file.isEmpty()&& file.getSize() <= 0) {
|
|
|
- return ResultData.error(ErrorCode.FAILURE_CODE_3017);
|
|
|
- }
|
|
|
-
|
|
|
- // 文件名全名
|
|
|
- String fullFileName = file.getOriginalFilename();
|
|
|
-
|
|
|
- // 将文件转字节-> 字符串
|
|
|
- String fileContent = Base64.getEncoder().encodeToString(file.getBytes());
|
|
|
-
|
|
|
- // 获取类路径
|
|
|
- String resourcePath = FileUtils.getResource();
|
|
|
- log.info("resourcePath: {}", resourcePath);
|
|
|
-
|
|
|
- // 创建目录
|
|
|
- String dirPath = resourcePath + DIR_NAME ;
|
|
|
- FileUtils.createDir(dirPath);
|
|
|
-
|
|
|
- // 拼接唯一文件名
|
|
|
- String fileName = dateStr() + fullFileName;
|
|
|
-
|
|
|
- // 文件保存路径
|
|
|
- String filePath = dirPath + dateStr() + fullFileName;
|
|
|
-
|
|
|
- // 写文件到本地
|
|
|
- FileUtils.base64ToFileWriter(fileContent, filePath);
|
|
|
- log.info("filePath: {}", filePath);
|
|
|
-
|
|
|
- // 读取本地文件
|
|
|
- byte[] content = FileUtil.getContent(filePath);
|
|
|
-
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- // 获取时间戳
|
|
|
- private String dateStr() {
|
|
|
- SimpleDateFormat df = new SimpleDateFormat("yyyyMMdd");
|
|
|
- String format = df.format(new Date());
|
|
|
- long timeMillis = System.currentTimeMillis();
|
|
|
- return format + "_" + timeMillis + "_";
|
|
|
- }
|
|
|
-}
|
|
|
-
|