场外加油导入

娄高锋
1 parent 7c8b0155
Showing 7 changed files with 235 additions and 1 deletions
src/main/java/com/bsth/controller/oil/CwjyController.java
src/main/java/com/bsth/repository/oil/CwjyRepository.java
src/main/java/com/bsth/service/oil/CwjyService.java
src/main/java/com/bsth/service/oil/impl/CwjyServiceImpl.java
src/main/resources/static/pages/forms/export/import_Jygl.xls
src/main/resources/static/pages/oil/jyglList.html
src/main/resources/static/pages/oil/upload.html
 package com.bsth.controller.oil;
+import java.io.File;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
@@ -11,6 +12,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
 import com.bsth.common.ResponseCode;
 import com.bsth.controller.BaseController;
@@ -22,6 +24,7 @@ import com.bsth.entity.sys.SysUser;
 import com.bsth.security.util.SecurityUtils;
 import com.bsth.service.oil.CwjyService;
 import com.bsth.util.PageObject;
+import com.google.common.io.Files;
 @RestController
 @RequestMapping("cwjy")
@@ -95,4 +98,23 @@ public class CwjyController extends BaseController&lt;Cwjy, Integer&gt;{
 		return maps;
 	}
+	/*
+	 * 场外加油导入
+	 */
+	@RequestMapping(value = "/uploadFile",method = RequestMethod.POST)
+	public String uploadFile(MultipartFile file, String gsbm_, String gsName,
+											String fgsbm_, String fgsName) throws Exception{
+		Map<String, Object> map = new HashMap<String, Object>();
+        File newFile = new File(
+        		getDataImportClasspath() + File.separator +
+                        file.getOriginalFilename());
+        Files.write(file.getBytes(), newFile);
+		String result = service.importExcel(newFile, gsbm_, gsName);
+		return "{\"result\":" + "\""+result+"\"}";
+	}
+
+	public String getDataImportClasspath(){
+		return this.getClass().getResource("/").getPath() + "/static/pages/oil";
+	}
+	
 }
@@ -33,5 +33,21 @@ public interface CwjyRepository extends BaseRepository&lt;Cwjy, Integer&gt;{
 	@Query(value="select * from bsth_c_cwjy where nbbm like %?1% and gsdm like %?2% and fgsdm like %?3% and line =?4",nativeQuery=true)
 	List<Cwjy> selectAll_s(String nbbm,String gsdm,String fgsdm,String line);
+
+	@Query(value="SELECT jzl FROM bsth_c_ylxxb where gsdm = ?1 and yyrq = ?2 and nbbm = ?3 and jylx = '1' ",nativeQuery=true)
+	List<Double> import_queryBySame( String gsbm, String rq, String nbbm);
+	
+	@Transactional
+    @Modifying
+    @Query(value="INSERT INTO bsth_c_ylxxb("+
+    			 "gsdm, yyrq, nbbm, jzl, stationid, bz, createtime, nylx, jylx)" +
+    			 " VALUES(" +
+    			 "?1,str_to_date(?2,'%Y-%m-%d'),?3,?4,?5,?6,str_to_date(?7,'%Y-%m-%d %H:%i:%s'), '0', '1') ", nativeQuery=true)
+	void import_insertData(String gsbm, String rq, String nbbm, String jzl, String jyz, String remarks, String createtime);
+	
+	@Transactional
+    @Modifying
+	@Query(value="UPDATE bsth_c_ylxxb set jzl = ?1 where gsdm = ?2 and yyrq = ?3 and nbbm = ?4 and jylx = '1' ",nativeQuery=true)
+	void import_UpdateJzl(String jdl, String gsbm, String rq, String nbbm);
 }
 package com.bsth.service.oil;
+import java.io.File;
 import java.util.List;
 import java.util.Map;
@@ -18,4 +19,6 @@ public interface CwjyService extends BaseService&lt;Cwjy, Integer&gt;{
 	Map<String, Object> savejzl(Map<String, Object> map) throws Exception ;
 	int checkNbbm(Cwjy t);
+	
+	public String importExcel(File file, String gsbm_, String gsName);
 }
 package com.bsth.service.oil.impl;
+import java.io.File;
+import java.io.FileInputStream;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.text.DecimalFormat;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
@@ -14,6 +17,11 @@ import java.util.Map;
 import javax.transaction.Transactional;
 import org.apache.commons.lang3.StringEscapeUtils;
+import org.apache.poi.hssf.usermodel.HSSFCell;
+import org.apache.poi.hssf.usermodel.HSSFRow;
+import org.apache.poi.hssf.usermodel.HSSFSheet;
+import org.apache.poi.hssf.usermodel.HSSFWorkbook;
+import org.apache.poi.poifs.filesystem.POIFSFileSystem;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -457,5 +465,79 @@ public class CwjyServiceImpl extends BaseServiceImpl&lt;Cwjy,Integer&gt; implements Cw
 	}
-
+	@Override
+	public String importExcel(File file, String gsbm, String gsName) {
+		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+		SimpleDateFormat sd = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+		DecimalFormat df = new DecimalFormat("######0.00");
+		List<String> textList = new ArrayList<String>();
+		try {
+			POIFSFileSystem fs = new POIFSFileSystem(new FileInputStream(file));
+			HSSFWorkbook wb = new HSSFWorkbook(fs);
+			HSSFSheet sheet = wb.getSheetAt(0);
+			// 取得总行数
+			int rowNum = sheet.getLastRowNum() + 1;
+			// 取得总列数
+			int cellNum = sheet.getRow(0).getLastCellNum();
+			HSSFRow row = null;
+			HSSFCell cell = null;
+			for(int i = 2; i < rowNum; i++){
+				row = sheet.getRow(i);
+				if (row == null){
+					continue;
+				}
+				String text = "";
+				for(int j = 0; j < cellNum; j++){
+					cell = row.getCell(j);
+					if(cell == null){
+						text += ",";
+						continue;
+					}
+						text += String.valueOf(cell) + ",";
+				}
+				String[] split = (text+";").split(",");
+				String str = "";
+				for(int j = 0; j < split.length && j < 5; j++){
+					str += split[j];
+				}
+				if(str.trim().length() == 0){
+					continue;
+				}
+				textList.add(text + ";");
+			}
+			for(int i = 0; i < textList.size(); i++){
+				String text = textList.get(i);
+				System.out.println(text);
+				String[] split = text.split(",");
+				String rq = split[0].trim();
+				String nbbm = split[1].trim();
+				double jzl = Double.valueOf(split[2].trim().length()!=0?split[2]:"0");
+				String jyz = split[3].trim();
+				String remarks = split[4].trim();
+				if(rq.trim().length() == 0){
+					rq = sdf.format(new Date());
+				}
+				
+				List<Double> jzl_ = repository.import_queryBySame(gsbm, rq, nbbm);
+//				
+				if(jzl_.size() == 0){
+					repository.import_insertData(gsbm, rq, nbbm,
+							df.format(jzl), jyz, remarks, sd.format(new Date()));
+				}else{
+					repository.import_UpdateJzl(df.format(jzl), gsbm, rq, nbbm);
+				}
+			}
+			wb.close();
+			fs.close();
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			return "文件导入失败";
+		} finally {
+			file.delete();
+		}
+		return "文件导入成功";
+	}
+	
+	
 }
@@ -22,6 +22,9 @@
 						class="caption-subject font-dark sbold uppercase">场外加油管理</span>
 				</div>
 				<div class="actions">
+					<button type="button" class="btn btn-circle blue" id="upload"><i class="fa fa-file-excel-o"></i>
+						导入Excel
+					</button> &nbsp;&nbsp;
 <!-- 					<a class="btn btn-circle blue" href="cylAdd.html" data-pjax><i class="fa fa-plus"></i> 添加</a> -->
 					<button type="button" class="btn btn-circle blue"  id="saveButton"><i class="fa fa-minus-square"></i> 保存</button>
 					<!-- <button type="button" class="btn btn-circle red" disabled="disabled" id="removeButton"><i class="fa fa-trash"></i> 删除用户</button> -->
@@ -112,6 +115,8 @@
 	</div>
 </div>
+<script src="/assets/js/ajaxfileupload/ajaxfileupload.js"></script>
+
 <script id="jygl_list_temp" type="text/html">
 {{each list as obj i}}
 <tr>
@@ -499,4 +504,10 @@ function changeEnabled(id,enabled){
 }
+//导入
+$("#upload").on("click", function(){
+	$.get('upload.html', function(m){$(pjaxContainer).append(m);});
+});
+
+
 </script>
 \ No newline at end of file
+<div class="modal fade" id="uploadFile" tabindex="-1" role="basic"
+	aria-hidden="true">
+	<div class="modal-dialog">
+		<div class="modal-content">
+			<div class="modal-header">
+				<button type="button" class="close" data-dismiss="modal"
+					aria-hidden="true"></button>
+				<h4 class="modal-title">导入Excel</h4>
+			</div>
+			<div class="modal-body">
+				<form class="form-horizontal" role="form" id="excelFile" method="post"
+						action="" enctype="multipart/form-data">
+					<input type="hidden" name="groupType" value="3">
+					<div class="alert alert-danger display-hide">
+						<button class="close" data-close="alert"></button>
+						您的输入有误，请检查下面的输入项
+					</div>
+					<div class="form-body">
+						<div class="form-group">
+							<label class="col-md-3 control-label">选择文件</label>
+							<div class="col-md-9">
+								<input type="file" name="file" id="file"
+									accept="application/vnd.ms-excel"/>
+								<input type=hidden name="gsbm_" id="gsbm_">
+								<input type="hidden" name="gsName" id="gsName">
+<!-- 								<input type="hidden" name="fgsbm_" id="fgsbm_"> -->
+<!-- 								<input type="hidden" name="fgsName" id="fgsName"> -->
+							</div>
+						</div>
+					</div>
+				</form>
+			</div>
+			<div class="modal-footer">
+				<button type="button" class="btn default" id="downLoad">下载模板</button>
+				<button type="button" class="btn default" data-dismiss="modal">取消</button>
+				<button type="button" class="btn btn-primary" id="submit">确认导入</button>
+			</div>
+		</div>
+	</div>
+</div>
+<script id="res_tbody_temp" type="text/html">
+
+</script>
+<script data-exclude=1>
+	$(function() {
+		var form = $('#excelFile');
+		var error = $('.alert-danger', form);
+		
+		$('#gsbm_').val($("select[name=gsdm_like]").val());
+		$('#gsName').val($("select[name=gsdm_like]").find("option:selected").text());
+// 		$('#fgsbm_').val($("#fgsbm").val());
+// 		$('#fgsName').val($("#fgsbm").find("option:selected").text());
+		
+		//modal 显示事件
+		$('#uploadFile').on('show.bs.modal', function(){
+		})
+		.modal('show');
+		
+		//提交
+// 		$('#submit').on('click', function() {
+// 			form.submit();
+// 		});
+		
+		$('#submit').on('click', function() {
+            var j = layer.load(2);
+			var param = {};
+			param.uploadDir = 'upload';
+			param["gsbm_"] = $('#gsbm_').val();
+			param["gsName"] = $('#gsName').val();
+// 			param["fgsbm_"] = $('#fgsbm_').val();
+// 			param["fgsName"] = $('#fgsName').val();
+			$.ajaxFileUpload({
+				url : '/cwjy/uploadFile',
+				secureuri : false,
+				fileElementId : 'file',
+				dataType : 'json',
+				data : param,
+				success : function(data) {
+	                layer.close(j);
+					alert(data.result);
+// 					alert("文件导入成功");
+					$('#uploadFile').modal('hide');
+					$('tr.filter .filter-submit').click();
+				},
+				error : function(data, status, e) {
+	                layer.close(j);
+					alert("文件导入失败");
+				}
+			})
+		});
+		
+		$('#downLoad').on('click', function(){
+			window.open("/downloadFile/downloadModel?fileName=import_Jygl");
+		});
+		
+		function getCurrSelNode(){
+			return $.jstree.reference("#modules_tree").get_selected(true);
+		}
+	});
+</script>
 \ No newline at end of file