moral.git - Gitblit

			@@ -1,38 +1,59 @@
			package com.moral.api.controller;

			import com.deepoove.poi.XWPFTemplate;
			import com.deepoove.poi.data.MiniTableRenderData;
			import com.deepoove.poi.data.RowRenderData;
			import com.deepoove.poi.data.TextRenderData;
			import com.moral.api.pojo.dto.historySecondCruiser.HistorySecondCruiserResultDTO;

			import cn.afterturn.easypoi.word.WordExportUtil;
			import io.swagger.annotations.Api;
			import io.swagger.annotations.ApiImplicitParam;
			import io.swagger.annotations.ApiImplicitParams;
			import io.swagger.annotations.ApiOperation;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.poi.xwpf.usermodel.XWPFDocument;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.util.CollectionUtils;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.util.ObjectUtils;
			import org.springframework.util.ResourceUtils;
			import org.springframework.web.bind.annotation.CrossOrigin;
			import org.springframework.web.bind.annotation.GetMapping;
			import org.springframework.web.bind.annotation.PostMapping;
			import org.springframework.web.bind.annotation.RequestBody;
			import org.springframework.web.bind.annotation.RequestMapping;
			import org.springframework.web.bind.annotation.RestController;
			import org.springframework.web.multipart.MultipartFile;
			import org.springframework.web.multipart.MultipartHttpServletRequest;

			import java.io.File;
			import java.io.FileOutputStream;
			import java.io.IOException;
			import java.io.OutputStream;
			import java.net.URLEncoder;
			import java.text.ParseException;
			import java.util.ArrayList;

			import java.util.HashMap;

			import java.util.List;
			import java.util.Map;


			import javax.servlet.http.HttpServletRequest;
			import javax.servlet.http.HttpServletResponse;

			import com.moral.api.entity.Dustld;
			import com.moral.api.pojo.bo.ExcelBO;
			import com.moral.api.pojo.dust.DustForm;
			import com.moral.api.pojo.vo.excel.DailyVo;
			import com.moral.api.service.DustldService;
			import com.moral.api.service.SpecialDeviceService;
			import com.moral.constant.ResponseCodeEnum;
			import com.moral.constant.ResultMessage;
			import com.moral.util.WebUtils;

			import static com.moral.api.controller.SysTestController.getPath;

			@Slf4j
			@Api(tags = {"走航车"})
			@@ -99,31 +120,19 @@
			@ApiImplicitParam(name = "mac", value = "设备mac", required = true, paramType = "query", dataType = "String"),
			@ApiImplicitParam(name = "time1", value = "时间，2021-08-18", required = true, paramType = "query", dataType = "String"),
			@ApiImplicitParam(name = "time2", value = "时间，2021-08-18", required = true, paramType = "query", dataType = "String"),
			@ApiImplicitParam(name = "type", value = "采集因子", required = true, paramType = "query", dataType = "String")
			@ApiImplicitParam(name = "type", value = "采集因子", required = true, paramType = "query", dataType = "String"),
			@ApiImplicitParam(name = "range", value = "范围", required = true, paramType = "query", dataType = "int")
			})
			public ResultMessage carTrajectoryNewAvg(HttpServletRequest request) {
			long stime = System.currentTimeMillis();
			Map<String, Object> params = WebUtils.getParametersStartingWith(request, null);
			if (!params.containsKey("mac") \|\| !params.containsKey("time1")\|\| !params.containsKey("type")\|\| !params.containsKey("time2")) {
			if (!params.containsKey("mac") \|\| !params.containsKey("time1")\|\|!params.containsKey("range")\|\| !params.containsKey("type")\|\| !params.containsKey("time2")) {
			return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());
			}
			List<HistorySecondCruiserResultDTO> response = specialDeviceService.carTrajectoryNewAvg(params);
			if(CollectionUtils.isEmpty(response)){
			return ObjectUtils.isEmpty(response) ? ResultMessage.ok() : ResultMessage.ok(response);
			}
			long etime = System.currentTimeMillis();
			/*List<Map<Integer,HistorySecondCruiserResultDTO>> mapList = new ArrayList<>();

			for(int i = 0 ;i<response.size();i++){
			Map<Integer,HistorySecondCruiserResultDTO> map = new HashMap<>();
			map.put(i,response.get(i));
			mapList.add(map);
			}*/
			//计算执行时间
			System.out.printf("执行时长：%d 毫秒.", (etime - stime));
			return ResultMessage.ok(response);


			return ObjectUtils.isEmpty(response) ? ResultMessage.ok() : ResultMessage.ok(response);

			}

			@@ -229,6 +238,32 @@
			return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(),ResponseCodeEnum.SUCCESS.getMsg(),map);
			}


			/**
			* 下载尘负荷报告
			* @return
			*/
			@PostMapping("dailyDustlds")
			@Transactional
			public ResultMessage dailyDustlds(@RequestBody Map<String,Object> params, HttpServletResponse response) throws IOException {

			// Map<String, Object> params = WebUtils.getParametersStartingWith(request, null);
			if (!params.containsKey("mac") \|\| !params.containsKey("startTime") \|\| !params.containsKey("endTime")){
			return ResultMessage.fail(ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode(), ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());
			}

			Map<String, Object> map = dustldService.dailyDustlds(params);
			if (ObjectUtils.isEmpty(map)){
			return ResultMessage.fail(ResponseCodeEnum.TARGET_IS_NULL.getCode(), ResponseCodeEnum.TARGET_IS_NULL.getMsg());
			}
			test(map,response);
			// return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(),ResponseCodeEnum.SUCCESS.getMsg(),map);
			return ResultMessage.ok();
			}




			/**
			* 查看路段高值
			* @param id
			@@ -264,4 +299,85 @@
			}



			public static void downloadWord(String fileName, Map<String, Object> params, HttpServletResponse response, String newFileName) {
			String path = getPath(fileName);//我这放 resources包下
			try {
			//获取模板文档
			OutputStream out = new FileOutputStream("G:\\home\\mon1\\" + newFileName);
			File rootFile = new File(ResourceUtils.getURL("classpath:").getPath());
			File file= new File(rootFile, path);
			XWPFDocument word = WordExportUtil.exportWord07(file.getPath(), params);
			response.setCharacterEncoding("utf-8");
			response.setContentType("multipart/form-data");
			response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(newFileName, "utf-8"));
			//OutputStream out = response.getOutputStream();
			word.write(out);
			out.flush();
			out.close();
			} catch (Exception e) {
			log.error ("导出失败，请联系网站管理员！", e);
			}
			}


			public void test( Map<String, Object> params,HttpServletResponse response) throws IOException {
			// String path="D:\\尘负荷监测报告.docx";
			String path = getPath("尘负荷监测报告.docx");
			try {
			//获取当前模板的路径
			File rootFile = new File(ResourceUtils.getURL("classpath:").getPath());
			File file= new File(rootFile, path);
			//第一步：读取模板
			XWPFTemplate compile = XWPFTemplate.compile(file.getPath());
			//第二步：创建数据，用于把我们模板中的{{}}包裹的变量替换掉,map中保存的key一定要和模板中的变量保持一致
			HashMap<String, Object> map = new HashMap<>();
			//设置单元格，表头
			RowRenderData header1 = RowRenderData.build(new TextRenderData("6495ED", "序号"), new TextRenderData("6495ED", "道路"),new TextRenderData("6495ED", "平均尘负荷（克/平方米）"));

			//设置表内容，如果在实际应用中，传入一个list集合或者数组，方可用foreach进行循环填充
			List<DustForm> list1 = (List<DustForm>) params.get("list1");

			ArrayList<Map<String, Object>> mapArrayList = (ArrayList<Map<String, Object>>) params.get("list3");
			ArrayList<RowRenderData> rsList1 = new ArrayList<>();
			ArrayList<RowRenderData> rsList3 = new ArrayList<>();

			for (int i = 0; i < list1.size(); i++) {
			DustForm dustForm = list1.get(i);
			RowRenderData row0 = RowRenderData.build(i+1+"",dustForm.getRoad(), dustForm.getValue()+"");
			rsList1.add(row0);
			}

			for (int i = 0; i < mapArrayList.size(); i++) {
			Map<String, Object> map1 = mapArrayList.get(i);
			RowRenderData row = RowRenderData.build(i + 1 + "", map1.get("road").toString(), map1.get("value1").toString(), map1.get("value2").toString(), map1.get("value3").toString());
			rsList3.add(row);
			}
			if (!ObjectUtils.isEmpty(mapArrayList)){
			map.put("table3", new MiniTableRenderData(rsList3));
			}
			map.put("table1", new MiniTableRenderData(header1, rsList1));
			String data = params.get("data").toString();
			map.put("data",data);
			map.put("time",params.get("time").toString());
			map.put("date1",params.get("date1").toString());
			map.put("date2",params.get("date2").toString());
			// map.put("data",params.get("data").toString());
			compile.render(map);
			// response.addHeader("Access-Contro1-Allow-Origin", "*");

			response.setHeader("Access-Control-Allow-Origin","*");//允许所有请求跨域
			response.setHeader("Access-Control-Allow-Methods", "*");//允许跨域的请求方法GET, POST, HEAD 等
			response.setHeader("Access-Control-Allow-Headers", "*");//允许跨域的请求头
			response.setHeader("Access-Control-Allow-Credentials", "true");//是否携带cooki

			compile.write(response.getOutputStream());
			compile.close();
			} catch (IOException e) {
			log.error ("导出失败，请联系网站管理员！", e);
			}

			}


			}