潘钊 / bsth_control · Files

package com.bsth.controller.realcontrol;

import com.alibaba.fastjson.JSONArray;
import com.bsth.common.ResponseCode;
import com.bsth.controller.BaseController;
import com.bsth.controller.realcontrol.dto.ChangePersonCar;
import com.bsth.controller.realcontrol.dto.DfsjChange;
import com.bsth.data.BasicData;
import com.bsth.data.schedule.DayOfSchedule;
import com.bsth.data.schedule.edit_logs.service.dto.SchEditInfoDto;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.bsth.entity.schedule.SchedulePlanInfo;
import com.bsth.service.realcontrol.ScheduleRealInfoService;
import org.apache.commons.lang3.StringEscapeUtils;
import org.joda.time.format.DateTimeFormat;
import org.joda.time.format.DateTimeFormatter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.*;

@RestController
@RequestMapping("/realSchedule")
public class ScheduleRealInfoController extends BaseController<ScheduleRealInfo, Long> {

	/*@Autowired
	GetSchedulePlanThread getSchedulePlanThread;*/

	@Autowired
	ScheduleRealInfoService scheduleRealInfoService;

	@Autowired
	DayOfSchedule dayOfSchedule;

	@RequestMapping(value = "/lines")
	public Map<String, Collection<ScheduleRealInfo>> findByLines(@RequestParam String lines) {
		return scheduleRealInfoService.findByLines(lines);
	}

	@RequestMapping(value = "/car")
	public List<ScheduleRealInfo> findByCar(String nbbm){
		return dayOfSchedule.findByNbbm(nbbm);
	}

	/**
	 *
	 * @Title: outgoAdjust @Description: TODO(待发调整) @param @param id
	 * 主键 @param @param remarks 备注 @param @param dfsj 待发时间（HH:mm） @throws
	 */
	@RequestMapping(value = "/outgoAdjust", method = RequestMethod.POST)
	public Map<String, Object> outgoAdjust(@RequestParam Long id, @RequestParam String remarks,
										   @RequestParam String dfsj,String bcType,
										   @RequestParam(defaultValue = "") String opType) {
		return scheduleRealInfoService.outgoAdjust(id, remarks, dfsj, bcType, opType);
	}

	/**
	 *
	 * @Title: destroy @Description: TODO(销毁，烂班) @param @param idsStr 要烂掉的班次ID ,分隔 
	 */
	@RequestMapping(value = "/destroy", method = RequestMethod.POST)
	public Map<String, Object> destroy(@RequestParam String idsStr
			/*, @RequestParam(defaultValue = "-1") int spaceAdjust*/,
									   @RequestParam String remarks, @RequestParam String adjustExps/*, @RequestParam(defaultValue = "0") int spaceNum*/) {
		return scheduleRealInfoService.destroy(idsStr/*, spaceAdjust*/, remarks, adjustExps/*, spaceNum*/);
	}

	/**
	 *
	 * @Title: carDeviceMapp @Description: TODO(获取车辆自编号和设备号对照，从缓存取) @throws
	 */
	@RequestMapping(value = "/carDeviceMapp", method = RequestMethod.GET)
	public Map<String, String> carDeviceMapp() {
		return BasicData.deviceId2NbbmMap.inverse();
	}

	/**
	 *
	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取驾驶员) @param @param
	 * lineId @throws
	 */
	@RequestMapping(value = "/driver", method = RequestMethod.GET)
	public List<Map<String, String>> findDriverByLine(@RequestParam String lineCode) {
		return scheduleRealInfoService.findDriverByLine(lineCode);
	}

	/**
	 *
	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取售票员) @param @param
	 * lineId @throws
	 */
	@RequestMapping(value = "/conductor", method = RequestMethod.GET)
	public List<Map<String, String>> findConductorByLine(@RequestParam String lineCode) {
		return scheduleRealInfoService.findConductorByLine(lineCode);
	}

	/**
	 *
	 * @Title: findPersionByLine @Description: TODO(根据线路主键获取车辆) @param @param
	 * lineId @throws
	 */
	@RequestMapping(value = "/cars", method = RequestMethod.GET)
	public List<Map<String, String>> findCarByLine(@RequestParam String lineCode) {
		return scheduleRealInfoService.findCarByLine(lineCode);
	}

	/**
	 *
	 * @Title: sreachNbbm @Description: TODO(搜索车辆内部编码) @throws
	 */
	@RequestMapping(value = "/sreachVehic", method = RequestMethod.GET)
	public List<Map<String, String>> sreachVehic(@RequestParam String nbbm) {
		return scheduleRealInfoService.sreachVehic(nbbm);
	}
	/**
	 *
	 * @Title: realOutAdjust
	 * @Description: TODO(实发调整)
	 * @param @param id 班次ID
	 * @param @param fcsjActual 实际发车时间 HH:mm
	 * @param @param remarks 备注
	 * @throws
	 */
	@RequestMapping(value = "/realOutAdjust", method = RequestMethod.POST)
	public Map<String, Object> realOutAdjust(@RequestParam Long id, @RequestParam String fcsjActual,
											 @RequestParam String remarks) {
		return scheduleRealInfoService.realOutAdjust(id, fcsjActual, remarks);
	}

	/**
	 *
	 * @Title: revokeDestroy
	 * @Description: TODO(撤销烂班)
	 * @param @param id
	 * @throws
	 */
	@RequestMapping(value = "/revokeDestroy", method = RequestMethod.POST)
	public Map<String, Object> revokeDestroy(@RequestParam Long id){
		return scheduleRealInfoService.revokeDestroy(id);
	}

	/**
	 *
	 * @Title: revokeRealOutgo
	 * @Description: TODO(撤销实发)
	 * @param @param id
	 * @throws
	 */
	@RequestMapping(value = "/revokeRealOutgo", method = RequestMethod.POST)
	public Map<String, Object> revokeRealOutgo(@RequestParam Long id){
		return scheduleRealInfoService.revokeRealOutgo(id);
	}

	/**
	 * 撤销执行
	 * @param id
	 * @return
	 */
	@RequestMapping(value = "/revokeRealArrive", method = RequestMethod.POST)
	public Map<String, Object> revokeRealArrive(@RequestParam Long id){
		return scheduleRealInfoService.revokeRealArrive(id);
	}

	/**
	 *
	 * @Title: spaceAdjust
	 * @Description: TODO(间隔调整)
	 * @param @param ids 要调整的班次数组ID
	 * @param @param space 间隔
	 * @throws
	 */
	@RequestMapping(value = "/spaceAdjust", method = RequestMethod.POST)
	public Map<String, Object> spaceAdjust(Long[] ids, Integer space){
		return scheduleRealInfoService.spaceAdjust(ids, space);
	}

	/**
	 *
	 * @Title: schInfoFineTune
	 * @Description: TODO(发车信息微调)
	 * @param @param map
	 * @throws
	 */
	@RequestMapping(value = "/schInfoFineTune", method = RequestMethod.POST)
	public Map<String, Object> schInfoFineTune(@RequestParam Map<String, String> map){
		return scheduleRealInfoService.schInfoFineTune(map);
	}

	/**
	 *
	 * @Title: outgoAdjustAll
	 * @Description: TODO(批量待发调整)
	 * @param @param list
	 * @throws
	 */
	@RequestMapping(value = "/outgoAdjustAll", method = RequestMethod.POST)
	public Map<String, Object> outgoAdjustAll(@RequestParam String params){
		//反转义
		params = StringEscapeUtils.unescapeHtml4(params);
		return scheduleRealInfoService.outgoAdjustAll(params);
	}

	/**
	 *
	 * @Title: findByLineAndUpDown
	 * @Description: TODO(根据线路和走向获取班次)
	 * @param @param line
	 * @param @param upDown
	 */
	@RequestMapping(value = "/findByLineAndUpDown")
	public List<ScheduleRealInfo> findByLineAndUpDown(@RequestParam String line,@RequestParam Integer upDown){
		return dayOfSchedule.findByLineAndUpDown(line, upDown);
	}

	/**
	 *
	 * @Title: findRouteByLine
	 * @Description: TODO(获取线路的站点，路段路由)
	 * @param @param lineCode
	 * @throws
	 */
	@RequestMapping(value = "/findRouteByLine")
	public Map<String, Object> findRouteByLine(@RequestParam String lineCode){
		return scheduleRealInfoService.findRouteByLine(lineCode);
	}

	/**
	 *
	 * @Title: removeChildTask
	 * @Description: TODO(删除子任务)
	 * @param @param taskId 子任务ID
	 * @throws
	 */
	@RequestMapping(value = "/childTask/{taskId}", method = RequestMethod.DELETE)
	public Map<String, Object> removeChildTask(@PathVariable("taskId") Long taskId){
		return scheduleRealInfoService.removeChildTask(taskId);
	}

	/**
	 *
	 * @Title: findByLineCode
	 * @Description: TODO(根据线路获取班次信息)
	 * @param @param lineCode
	 */
	@RequestMapping(value = "/lineCode/{lineCode}")
	public List<ScheduleRealInfo> findByLineCode(@PathVariable("lineCode") String lineCode){
		return dayOfSchedule.findByLineCode(lineCode);
	}

	@RequestMapping(value = "/queryUserInfo")
	public List<ScheduleRealInfo> queryUserInfo(@RequestParam String line,
												@RequestParam String date,@RequestParam String state) {
		return scheduleRealInfoService.queryUserInfo(line, date,state);
	}

	@RequestMapping(value = "/queryUserInfoPx")
	public List<ScheduleRealInfo> queryUserInfoPx(@RequestParam String line,
												  @RequestParam String date,@RequestParam String state,@RequestParam String type) {
		return scheduleRealInfoService.queryUserInfoPx(line, date,state,type);
	}

	@RequestMapping(value = "/exportWaybill",method = RequestMethod.GET)
	public List<ScheduleRealInfo> exportWaybill(@RequestParam String jName, @RequestParam String clZbh,
												@RequestParam String lpName,@RequestParam String date,@RequestParam String line) {
		return scheduleRealInfoService.exportWaybill(jName, clZbh, lpName,date,line);
	}

	@RequestMapping(value = "/exportWaybillQp",method = RequestMethod.GET)
	public List<ScheduleRealInfo> exportWaybillQp(@RequestParam String clZbh
			,@RequestParam String date,@RequestParam String line) {
		return scheduleRealInfoService.exportWaybillQp( clZbh, date,line);
	}


	@RequestMapping(value = "/dailyInfo")
	public List<Map<String, Object>> dailyInfo(@RequestParam String line, @RequestParam String date,@RequestParam String type) {
		return scheduleRealInfoService.dailyInfo(line, date, type);
	}

	@RequestMapping(value = "/historyMessage")
	public List<Object[]> historyMessage(@RequestParam String line, @RequestParam String date,
										 @RequestParam String code, @RequestParam String type) {
		return scheduleRealInfoService.historyMessage(line, date, code, type);
	}

	@RequestMapping(value="/findLine")
	public List<Map<String,String>> findLine(@RequestParam String line){
		return scheduleRealInfoService.findLine(line);
	}

	@RequestMapping(value="/findKMBC",method = RequestMethod.GET)
	public Map<String,Object> findKMBC(@RequestParam String jGh,@RequestParam String clZbh,@RequestParam String lpName
			,@RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.findKMBC(jGh, clZbh,lpName,date,line);
	}

	/**
	 * 路单公里统计 （闵行审计专用）
	 * @param jGh
	 * @param clZbh
	 * @param lpName
	 * @param date
	 * @param line
	 * @return
	 */
	@RequestMapping(value="/findKMBC_mh_2",method = RequestMethod.GET)
	public Map<String,Object> findKMBC_mh_2(@RequestParam String jGh,@RequestParam String clZbh,@RequestParam String lpName
			,@RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.findKMBC_mh_2(jGh, clZbh,lpName,date,line);
	}

	@RequestMapping(value="/findKMBCQp",method = RequestMethod.GET)
	public Map<String,Object> findKMBCQp(@RequestParam String clZbh
			,@RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.findKMBCQp(clZbh,date,line);
	}

	@RequestMapping(value="/findLpName")
	public List<Map<String,String>> findLpName(@RequestParam String lpName){
		return scheduleRealInfoService.findLpName(lpName);
	}

	@RequestMapping(value = "/account")
	public List<Map<String,Object>> account(@RequestParam String line, @RequestParam String date,
											@RequestParam String code,@RequestParam String xlName, @RequestParam String type) {
		return scheduleRealInfoService.account(line, date, code, xlName, type);
	}
	
	@RequestMapping(value = "/accountPx")
	public List<Map<String,Object>> accountPx(@RequestParam String line, @RequestParam String date,
											@RequestParam String code,@RequestParam String xlName, @RequestParam String px) {
		return scheduleRealInfoService.accountPx(line, date, code, xlName, px);
	}

	@RequestMapping(value = "/correctForm")
	public List<SchEditInfoDto> correctForm(@RequestParam String line, @RequestParam String date,
											@RequestParam String endDate,
											 @RequestParam String lpName, @RequestParam String code, 
											 @RequestParam String type,@RequestParam String changType) {
		return scheduleRealInfoService.correctForm(line, date, endDate, lpName, code, type,changType);
	}
	/**
	 * @Title queryListWaybill
	 * @Description 查询行车路单列表
	 * @param jName 驾驶员名字
	 * @param clZbh 车辆自编号（内部编号）
	 * @param lpName 路牌
	 * @return
	 */
	@RequestMapping(value="/queryListWaybill",method = RequestMethod.GET)
	public List<ScheduleRealInfo> queryListWaybill(@RequestParam String jName,@RequestParam String clZbh,@RequestParam String lpName
			,@RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.queryListWaybill(jName, clZbh,lpName,date,line);
	}

	/**
	 * @Title queryListWaybill
	 * @Description 查询行车路单列表（闵行审计专用路单）
	 * @param jName 驾驶员名字
	 * @param clZbh 车辆自编号（内部编号）
	 * @param lpName 路牌
	 * @return
	 */
	@RequestMapping(value="/queryListWaybill_mh_2",method = RequestMethod.GET)
	public List<ScheduleRealInfo> queryListWaybill_mh_2(@RequestParam String jName,@RequestParam String clZbh,@RequestParam String lpName
			,@RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.queryListWaybill2(jName, clZbh,lpName,date,line);
	}

	@RequestMapping(value="/queryListWaybillQp",method = RequestMethod.GET)
	public List<ScheduleRealInfo> queryListWaybillQp(@RequestParam String clZbh,
													 @RequestParam String date,@RequestParam String line){
		return scheduleRealInfoService.queryListWaybillQp(clZbh,date,line);
	}

	@RequestMapping(value="/statisticsDaily")
	public List<Map<String,Object>> statisticsDaily(@RequestParam String line, @RequestParam String date,
													@RequestParam String xlName, @RequestParam String type){
		return scheduleRealInfoService.statisticsDaily(line, date, xlName, type);
	}

	@RequestMapping(value="/statisticsDaily_mh_2")
	public List<Map<String,Object>> statisticsDaily_mh_2(@RequestParam String line, @RequestParam String date,
													@RequestParam String xlName, @RequestParam String type){
		return scheduleRealInfoService.statisticsDaily_mh_2(line, date, xlName, type);
	}

	@RequestMapping(value="/statisticsDailyTj")
	public List<Map<String,Object>> statisticsDailyTj(@RequestParam Map<String, Object> map){
		String gsdm="";
		if(map.get("gsdm")!=null){
			gsdm=map.get("gsdm").toString();
		}
		String fgsdm="";
		if(map.get("fgsdm")!=null){
			fgsdm=map.get("fgsdm").toString();
		}
		String line="";
		if(map.get("line")!=null){
			line=map.get("line").toString();
		}
		String date="";
		if(map.get("date")!=null){
			date=map.get("date").toString();
		}
		String date2="";
		if(map.get("date2")!=null){
			date2=map.get("date2").toString();
		}
		String xlName="";
		if(map.get("xlName")!=null){
			xlName=map.get("xlName").toString();
		}
		String type="";
		if(map.get("type")!=null){
			type=map.get("type").toString();
		}
		return scheduleRealInfoService.statisticsDailyTj(gsdm,fgsdm,line, date,date2, xlName, type);
	}

	@RequestMapping(value="/MapById",method = RequestMethod.GET)
	public Map<String, Object> MapById(@RequestParam("id") Long id){
		return scheduleRealInfoService.MapById(id);
	}

	/**
	 * @Title: scheduleDaily
	 * @Description: TODO(调度日报表)
	 * @param line 线路
	 * @param date 时间
	 * @return
	 */
	@RequestMapping(value="/scheduleDaily")
	public Map<String,Object> scheduleDaily(@RequestParam String line,@RequestParam String date){
		return scheduleRealInfoService.scheduleDaily(line,date);
	}

	@RequestMapping(value="/realScheduleList")
	public List<ScheduleRealInfo> realScheduleList(@RequestParam String line,@RequestParam String date){
		return scheduleRealInfoService.realScheduleList(line,date);
	}

	@RequestMapping(value="/realScheduleList_mh_2")
	public List<ScheduleRealInfo> realScheduleList_mh_2(@RequestParam String line,@RequestParam String date){
		return scheduleRealInfoService.realScheduleList_mh_2(line,date);
	}

	@RequestMapping(value="/realScheduleListQp")
	public List<ScheduleRealInfo> realScheduleListQp(@RequestParam String line,@RequestParam String date){
		return scheduleRealInfoService.realScheduleListQp(line,date);
	}

	@RequestMapping(value="/multi_tzrc", method=RequestMethod.POST)
	public Map<String, Object> multi_tzrc(@RequestParam String cpcsJson){
		cpcsJson = StringEscapeUtils.unescapeHtml4(cpcsJson);
		List<ChangePersonCar> cpcs = JSONArray.parseArray(cpcsJson, ChangePersonCar.class);
		return scheduleRealInfoService.multi_tzrc(cpcs);
	}

	@RequestMapping(value="/multi_dftz", method=RequestMethod.POST)
	public Map<String, Object> multi_dftz(@RequestParam String dcsJson){
		dcsJson = StringEscapeUtils.unescapeHtml4(dcsJson);
		List<DfsjChange> dfsjcs = JSONArray.parseArray(dcsJson, DfsjChange.class);
		return scheduleRealInfoService.multi_dftz(dfsjcs);
	}

	@RequestMapping(value="/changeBcType/{id}", method=RequestMethod.POST)
	public Map<String, Object> changeBcType(@PathVariable("id") Long id, String bcType, String remarks){
		return scheduleRealInfoService.changeBcType(id, bcType, remarks);
	}

	@RequestMapping(value="/history", method=RequestMethod.POST)
	public Map<String,Object> historySave(ScheduleRealInfo sch){
		return scheduleRealInfoService.historySave(sch);
	}


	private static DateTimeFormatter fmtyyyyMMdd = DateTimeFormat.forPattern("yyyy-MM-dd");
	private final static long ONE_DAY = 1000 * 60 * 60 * 24;
	/**
	 * 获取可编辑的历史班次日期
	 * @return
	 */
	@RequestMapping("dateArray")
	public List<String> dateArray(@RequestParam(defaultValue = "0") int c){
		List<String> rs = new ArrayList<>();

		long t = new Date().getTime();
		if(c != 1)
		 	t -= ONE_DAY - (1000 * 60 * 60 * 2);
		for(int i = 0; i < 3; i ++){
			rs.add(fmtyyyyMMdd.print(t));
			t -= ONE_DAY;
		}
		return rs;
	}

	@RequestMapping(value = "svgAttr", method = RequestMethod.POST)
	public Map<String, Object> svgAttr(@RequestParam String jsonStr){
		return scheduleRealInfoService.svgAttr(jsonStr);
	}

	@RequestMapping(value = "svgAttr", method = RequestMethod.GET)
	public Map<String, Object> findSvgAttr(@RequestParam  String idx){
		return scheduleRealInfoService.findSvgAttr(idx);
	}

	@RequestMapping(value = "addRemarks", method = RequestMethod.POST)
	public Map<String, Object> addRemarks(@RequestParam Long id, @RequestParam String remarks){
		return scheduleRealInfoService.addRemarks(id, remarks);
	}

	@RequestMapping(value = "scheduleDailyQp", method = RequestMethod.GET)
	public List<Map<String, Object>> scheduleDailyQp(@RequestParam String line,@RequestParam String date){
		return scheduleRealInfoService.scheduleDailyQp(line,date);
	}

	@RequestMapping(value = "scheduleDailyExport", method = RequestMethod.GET)
	public List<Map<String, Object>> scheduleDailyExport(@RequestParam Map<String, Object> map){
		return scheduleRealInfoService.scheduleDailyExport(map);
	}

	@RequestMapping(value = "exportWaybillMore", method = RequestMethod.GET)
	public Map<String, Object> exportWaybillMore(@RequestParam Map<String, Object> map){
		return scheduleRealInfoService.exportWaybillMore(map);
	}

	/**
	 * 获取当日计划排班 ， 从计划表抓取数据
	 * @return
	 */
	@RequestMapping(value = "currSchedulePlanByLineCode", method = RequestMethod.GET)
	public List<SchedulePlanInfo> currentSchedulePlan(@RequestParam String lineCode){
		return scheduleRealInfoService.currentSchedulePlan(lineCode);
	}

	@RequestMapping(value = "lpChangeMulti", method = RequestMethod.POST)
	public Map<String, Object> lpChangeMulti(@RequestParam String leftIdx, @RequestParam String rightIdx,@RequestParam int type){
		return scheduleRealInfoService.lpChangeMulti(leftIdx, rightIdx, type);
	}

	/**
	 * 删除当日实际排班
	 * @return
	 */
	@RequestMapping(value = "deleteRealSchedule", method = RequestMethod.POST)
	public Map<String, Object> deleteRealSchedule(@RequestParam String lineCode){
		return dayOfSchedule.deleteRealSchedule(lineCode);
	}

	/**
	 * 从计划表重新加载当日排班
	 * @param lineCode
	 * @return
	 */
	@RequestMapping(value = "reLoadRealSchedule", method = RequestMethod.POST)
	public Map<String, Object> reLoadRealSchedule(@RequestParam String lineCode){
		Map<String, Object> rs = new HashMap<>();
		List<ScheduleRealInfo> list = dayOfSchedule.findByLineCode(lineCode);
		if(list != null && list.size() > 0){
			rs.put("status", ResponseCode.ERROR);
			rs.put("msg", "失败，" + list.get(0).getXlName() + "当日存在实际排班，无法重新加载。");
			return rs;
		}

		int code = dayOfSchedule.reloadSch(lineCode);
		rs.put("status", code==0? ResponseCode.SUCCESS: ResponseCode.ERROR);
		return rs;
	}

	/**
	 * 误点调整
	 * @param idx
	 * @param minute
	 * @return
	 */
	@RequestMapping(value = "lateAdjust", method = RequestMethod.POST)
	public Map<String, Object> lateAdjust(@RequestParam String idx,@RequestParam float minute ){
		return scheduleRealInfoService.lateAdjust(idx, minute);
	}

	/**
	 * 获取所有应发未到的班次
	 * @param idx
	 * @return
	 */
	@RequestMapping(value = "allLate2")
	public List<ScheduleRealInfo> allLate2(@RequestParam String idx){
		return scheduleRealInfoService.allLate2(idx);
	}

	/**
	 * 添加一个临加到历史库
	 * @param sch
	 * @return
	 */
	@RequestMapping(value = "history/add", method = RequestMethod.POST)
	public Map<String, Object> addToHistory(ScheduleRealInfo sch){
		return scheduleRealInfoService.addToHistory(sch);
	}

	/**
	 * 从历史库里删除临加班次
	 * @param sch
	 * @return
	 */
	@RequestMapping(value = "history/{id}", method = RequestMethod.DELETE)
	public Map<String, Object> deleteToHistory(@PathVariable("id") Long id){
		return scheduleRealInfoService.deleteToHistory(id);
	}
}