时刻表明细(图形版本)制作批量插入代码写入

李强
1 parent 15fe5ca3
Showing 4 changed files with 119 additions and 4 deletions
src/main/java/com/bsth/controller/schedule/core/TTInfoDetailController.java
src/main/java/com/bsth/repository/schedule/GuideboardInfoRepository.java
src/main/java/com/bsth/service/schedule/TTInfoDetailService.java
src/main/java/com/bsth/service/schedule/impl/TTInfoDetailServiceImpl.java
@@ -8,6 +8,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PathVariable;
 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 java.util.HashMap;
@@ -87,5 +88,16 @@ public class TTInfoDetailController extends BController&lt;TTInfoDetail, Long&gt; {
         }
         return rtn;
     }
-
+    
+    /**
+     * 时刻表明细批量插入
+     * 
+     * @param entities
+     * 
+     * @return
+     */
+    @RequestMapping(value = "/skbDetailMxSave" ,method = RequestMethod.POST)
+    public Map<String, Object> skbDetailMxSave(@RequestParam Map<String, Object> entities){
+    	return ttInfoDetailService.skbDetailMxSave(entities);
+    }
 }
@@ -3,6 +3,7 @@ package com.bsth.repository.schedule;
 import java.util.List;
 import java.util.Map;
  
+import com.bsth.entity.Line;
 import com.bsth.entity.schedule.EmployeeConfigInfo;
 import com.bsth.entity.schedule.GuideboardInfo;
 import com.bsth.repository.BaseRepository;
@@ -37,4 +38,8 @@ public interface GuideboardInfoRepository extends BaseRepository&lt;GuideboardInfo,
             "where td.ttinfo.id=?1 " +
             "group by td.ttinfo.id, td.lp.id, td.lp.lpName")
     List<Map<String, Object>> findLpName(Long ttid);
+    
+    @Query(value = "SELECT g FROM GuideboardInfo g  where g.xl =?1 and g.lpName = ?2 and g.lpNo = ?3 and lpType =?4 and isCancel = 0")
+    List<GuideboardInfo> validateLp(Line xl,String lpName , int lpNo,String lpType);
+   
 }
@@ -6,6 +6,7 @@ import org.apache.commons.lang3.StringUtils;
  
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
  
 /**
  * Created by xu on 16/7/2.
@@ -200,5 +201,5 @@ public interface TTInfoDetailService extends BService&lt;TTInfoDetail, Long&gt; {
     // TODO：这个方法可以用通用方法解决，以后改
     List<TTInfoDetail> findBcdetails(Integer xlId, Long ttinfoId, Long lpId);
  
-
+    Map<String, Object> skbDetailMxSave(Map<String, Object> map);
 }
 package com.bsth.service.schedule.impl;
  
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.common.ResponseCode;
 import com.bsth.entity.CarPark;
+import com.bsth.entity.Line;
 import com.bsth.entity.LineInformation;
 import com.bsth.entity.StationRoute;
 import com.bsth.entity.schedule.GuideboardInfo;
 import com.bsth.entity.schedule.TTInfoDetail;
+import com.bsth.repository.CarParkRepository;
+import com.bsth.repository.LineRepository;
+import com.bsth.repository.StationRepository;
+import com.bsth.repository.schedule.GuideboardInfoRepository;
 import com.bsth.repository.schedule.TTInfoDetailRepository;
+import com.bsth.repository.schedule.TTInfoRepository;
 import com.bsth.service.CarParkService;
 import com.bsth.service.LineInformationService;
 import com.bsth.service.StationRouteService;
@@ -58,7 +67,16 @@ public class TTInfoDetailServiceImpl extends BServiceImpl&lt;TTInfoDetail, Long&gt; im
     private TTInfoDetailRepository ttInfoDetailRepository;
     @Autowired
     private DataToolsProperties dataToolsProperties;
-
+    @Autowired
+    private LineRepository lineRepository;
+    @Autowired
+    private TTInfoRepository infoRepository;
+    @Autowired
+    private StationRepository staRepository;
+    @Autowired
+    private CarParkRepository carParkRepository;
+    @Autowired
+    private GuideboardInfoRepository guideboardInfoRepository;
     @Autowired
     @Qualifier(value = "dataToolsServiceImpl")
     private DataToolsService dataToolsService;
@@ -512,5 +530,84 @@ public class TTInfoDetailServiceImpl extends BServiceImpl&lt;TTInfoDetail, Long&gt; im
     public List<TTInfoDetail> findBcdetails(Integer xlId, Long ttinfoId, Long lpId) {
         return ttInfoDetailRepository.findBcdetails(xlId, ttinfoId, lpId);
     }
-
+    
+    @Override
+   	public Map<String, Object> skbDetailMxSave(Map<String, Object> map) {
+   		Map<String, Object> rs_m = new HashMap<String,Object>();
+   		try {
+   			String d = map.get("d") == null ? null : map.get("d").toString();
+   	    	if(d!=null)
+   	    		ttInfoDetailRepository.save(jsonArrayToListEntity(d));
+   		} catch (Exception e) {
+   			e.printStackTrace();
+   			rs_m.put("status", ResponseCode.ERROR);
+   		}
+   		rs_m.put("status", ResponseCode.SUCCESS);
+   		return rs_m;
+   	}
+   	
+   	public List<TTInfoDetail> jsonArrayToListEntity(String jsonStr) throws Exception {
+   		List<TTInfoDetail> listTd = new ArrayList<TTInfoDetail>();
+   		JSONArray jsonArray = JSONArray.parseArray(jsonStr);
+   		for(int i =0; i<jsonArray.size();i++) {
+   			JSONObject jsonObj = jsonArray.getJSONObject(i);
+   			if(jsonObj.getString("bcType").equals("bd") || jsonObj.getString("bcType").equals("lc") || jsonObj.getString("bcType").equals("cf"))
+   				continue;
+   			listTd.add(objToEntity(jsonObj));
+   		}
+   		return listTd;
+   	}
+   	
+   	public TTInfoDetail objToEntity(JSONObject obj) throws Exception {
+   		TTInfoDetail td = new TTInfoDetail();
+   		Line xl = lineRepository.findOne(Integer.parseInt(obj.getString("xl"))); 
+   		td.setXl(xl);
+   		td.setTtinfo(obj.getString("ttinfo") == null ? null : infoRepository.findOne(Long.parseLong(obj.getString("ttinfo"))));
+   		td.setLp(getLp(xl,obj.getString("lp"),Integer.parseInt(obj.getString("lp")),obj.getString("lpType")));
+   		td.setFcno(Integer.parseInt(obj.getString("fcno")));
+   		td.setXlDir(dirToCod(obj.get("xlDir").toString()));
+   		td.setQdz( obj.getString("qdz") ==null? null : staRepository.findOne(Integer.parseInt(obj.getString("qdz"))));
+   		td.setZdz(obj.getString("zdz") ==null ? null :staRepository.findOne(Integer.parseInt(obj.getString("zdz"))));
+   		td.setTcc(carParkRepository.findOne(Integer.parseInt(obj.getString("tcc"))));
+   		td.setFcsj(obj.getString("fcsj"));
+   		td.setBcs(Integer.parseInt(obj.getString("bcs")));
+   		td.setJhlc(Double.parseDouble(obj.getString("jhlc")));
+   		td.setBcsj(Integer.parseInt(obj.getString("bcsj")));
+   		td.setBcType(obj.getString("bcType"));
+   		td.setIsFB(false);
+   		td.setIsSwitchXl(false);
+   		td.setSwitchXl(null);
+   		td.setSwitchXlDesc(null);
+   		td.setRemark(null);
+   		td.setCreateBy(null);
+   		td.setUpdateBy(null);
+   		return td;
+   	}
+   	
+   	public GuideboardInfo getLp(Line xl,String name, int code, String lpType) throws Exception {
+   		GuideboardInfo entity = new GuideboardInfo();
+   		List<GuideboardInfo> lgi = guideboardInfoRepository.validateLp(xl, name, code,lpType);
+   		if(lgi.size()>0) {
+   			entity = lgi.get(0);
+   		}else{
+   			entity.setXl(xl);
+   			entity.setLpNo(code);
+   			entity.setLpName(name);
+   			entity.setLpType(lpType);
+   			entity.setIsCancel(false);
+   			entity.setCreateBy(null);
+   			entity.setUpdateBy(null);
+   			guideboardInfoRepository.save(entity);
+   		} 
+   		return entity;
+   	}
+   	
+   	public String dirToCod(String str) throws Exception {
+   		String c = "";
+   		if(str.equals("relationshipGraph-up"))
+   			c = "0";
+   		else if(str.equals("relationshipGraph-down"))
+   			c = "1";
+   		return c;
+   	}
 }