package com.tianbo.controller.lost;

import java.lang.reflect.InvocationTargetException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.servlet.http.HttpServletRequest;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.beanutils.ConvertUtils;
import org.apache.commons.beanutils.Converter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.tianbo.model.ManifestItem;
import com.tianbo.model.ManifestLostChange;
import com.tianbo.model.Sendlog;
import com.tianbo.service.ItemService;
import com.tianbo.service.LostChangeService;
import com.tianbo.service.SendLogService;
import com.tianbo.util.DateUtils;
import com.tianbo.util.json.AjaxJson;
import com.tianbo.util.json.JsonConversion;
import com.tianbo.util.xml.XmlGen;
import com.tianbo.xml.lost.AssociatedTransportDocument;
import com.tianbo.xml.lost.BorderTransportMeans;
import com.tianbo.xml.lost.Consignment;
import com.tianbo.xml.lost.TransportContractDocument;
import com.tianbo.xml.lostChange.AssociatedTransport;
import com.tianbo.xml.lostChange.ChangeBorderTransportMeans;
import com.tianbo.xml.lostChange.ChangeConsignment;
import com.tianbo.xml.lostChange.Commodity;
import com.tianbo.xml.lostChange.ConsignmentItem;
import com.tianbo.xml.lostChange.ConsignmentItemPackaging;
import com.tianbo.xml.lostChange.DeclarationXml;
import com.tianbo.xml.lostChange.GoodsMeasure;
import com.tianbo.xml.lostChange.HeadXml;
import com.tianbo.xml.lostChange.ManifestXml;
import com.tianbo.xml.lostChange.TransportContract;

@Controller
@RequestMapping("/lost/change")
public class LostChangeController {

	@Autowired
	private LostChangeService lostChangeService;
	
	@Autowired
	private ItemService itemService;
	
	
	@Autowired
	private SendLogService sendLogService;
	
	@RequestMapping(value = {"index", ""})
	public String toFlight(ModelMap model,HttpServletRequest request) {
		
		return "lost/change/list";
	}
	
	@RequestMapping(value ="editItem")
	public String editItem(ModelMap model,HttpServletRequest request) {
		String id = request.getParameter("id");
		if(id!=null||id!=""){
			model.put("ftId", id);
		}
		String waybillnomaster = request.getParameter("waybillnomaster");
		if(waybillnomaster!=null||waybillnomaster!=""){
			model.put("waybillnomaster", waybillnomaster);
		}
	
//		ManifestItem item = itemService.selectByPrimaryKey(id);
//		model.put("item", item);
		return "lost/change/item";
	}
	@RequestMapping(value ="edit")
	public String edit(ModelMap model,HttpServletRequest request) {
		model.put("waybillnomaster", request.getParameter("waybillnomaster"));
		model.put("ftId", request.getParameter("id"));
		return "lost/change/edit";
	}
	
	@ResponseBody
	@RequestMapping(value = "getList")
	public String getList(HttpServletRequest request,int page,int limit){
		int start = (page-1)*limit+1;
		int end = page*limit;
		List<ManifestLostChange> lost = lostChangeService.getList(start,end);
		ManifestLostChange ft = new ManifestLostChange();
		int count = lostChangeService.getCount(ft);
		Map<String,Object> map = new HashMap<>();
		if(!lost.isEmpty()){
			map.put("code", 0);
			map.put("count", count);
			map.put("msg", "success");
			map.put("data", lost);
		}else {
			map.put("code", -1);
			map.put("msg", "请检查网络连接或重试");
			map.put("data", "");
		}
		return JsonConversion.writeMapJSON(map);
	}
	
	
	@ResponseBody
	@RequestMapping(value = "getIteamList")
	public String getIteamList(HttpServletRequest request,String waybillnomaster){
	    Map<String,Object> map = new HashMap<>();
	    try {
            if(waybillnomaster!=null && waybillnomaster!=""){
            List<ManifestItem> ltem = itemService.getIteamList(waybillnomaster);
            if(!ltem.isEmpty()){
            	map.put("code", 0);
            	map.put("msg", "success");
            	map.put("data", ltem);
            }else {
            	map.put("code", 0);
            	map.put("msg", "success");
            	map.put("data", "");
            }
            
           }else{
               map.put("code", 0);
               map.put("msg", "success");
               map.put("data", "");  
           }
        } catch (Exception e) {
            map.put("code", -1);
            map.put("msg", "请检查网络连接或重试");
            map.put("data", "");
            e.printStackTrace();
        }
	    return JsonConversion.writeMapJSON(map);
	}
	
	@ResponseBody
	@RequestMapping(value = "selectByParam")
	public String selectByParam(HttpServletRequest request,int page,int limit,String flightno,String flightdate,String waybillnomaster,String waybillnosecondary){
		int start = (page-1)*limit+1;
		int end = page*limit;
		List<ManifestLostChange> lost = lostChangeService.selectByParam(start,end,flightno,flightdate,waybillnomaster,waybillnosecondary);
		ManifestLostChange fs = new ManifestLostChange();
		fs.setFlightno(flightno);
		int count = lostChangeService.getCount(fs);
		Map<String,Object> map = new HashMap<>();
		if(!lost.isEmpty()){
			map.put("code", 0);
			map.put("count", count);
			map.put("msg", "success");
			map.put("data", lost);
		}else {
			map.put("code", -1);
			map.put("msg", "无此条件信息");
			map.put("data", "");
		}
		return JsonConversion.writeMapJSON(map);
	}
	
	/**
	 * 编辑或新增
	 * @param lost
	 * @param redirectAttributes
	 * @return
	 * @throws InvocationTargetException 
	 * @throws IllegalAccessException 
	 */
	@ResponseBody
	@RequestMapping(value = "editForm")
	public AjaxJson editForm(ModelMap model,@RequestParam Map<String, Object> params) throws IllegalAccessException, InvocationTargetException {
	    ManifestLostChange lostChange = new ManifestLostChange();
	        DateConvert();//日期转化
    	    BeanUtils.populate(lostChange, params);
            String message = null;
            AjaxJson j = new AjaxJson();
            
            if(lostChange.getId()!=null&&lostChange.getId()!=""){ //存在ID 执行更新
            try {
                    lostChangeService.saveorupdate(lostChange);
                    j.setSuccess(true);
                    message = "修改成功";
                } catch (Exception e) {
                    j.setSuccess(false);
                    message = "修改失败";
                    e.printStackTrace();
                }
            } else {
                try {
                    lostChangeService.saveorupdate(lostChange);
                    j.setSuccess(true);
                    message = "保存成功";
                } catch (Exception e) {
                    j.setSuccess(false);
                    message = "保存失败";
                    e.printStackTrace();
                }
            }
            
            j.setMsg(message);
            return j;
    }

    /**
     *  日期转化
     */
    public void DateConvert() {
        ConvertUtils.register(new Converter() {
                    
                    @SuppressWarnings("rawtypes")
                    public Object convert(Class type, Object value) {
                        
                        
                        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
                        try {
                            return simpleDateFormat.parse(value.toString());
                        } catch (ParseException e) {
                            e.printStackTrace();
                        }
                        return null;
                    }
                }, Date.class);
    }
	
	/**
	 * 编辑或新增
	 * @param lost
	 * @param redirectAttributes
	 * @return
	 * @throws InvocationTargetException 
	 * @throws IllegalAccessException 
	 */
	@ResponseBody
	@RequestMapping(value = "editItemData")
	public AjaxJson editIteamData(ModelMap model,@RequestParam Map<String, Object> params) throws IllegalAccessException, InvocationTargetException {
		ManifestItem ml = new ManifestItem();
		BeanUtils.populate(ml, params);
		String message = null;
		AjaxJson j = new AjaxJson();
		
		try {
			 itemService.saveorupdate(ml);
				j.setSuccess(true);
				message = "保存成功";
			} catch (Exception e) {
				j.setSuccess(false);
				message = "保存失败";
				e.printStackTrace();
			}
			j.setMsg(message);	
			 return j;
		}
	
	   /**
     * 删除
     * @param lost
     * @param redirectAttributes
     * @return
     */
    @ResponseBody
    @RequestMapping(value = "delItem")
    public AjaxJson delItem(ModelMap model,HttpServletRequest request) {
        String id = request.getParameter("id");
        String message = null;
        AjaxJson j = new AjaxJson();
        
        try {
            
            itemService.deleteByPrimaryKey(id);
            j.setSuccess(true);
            message = "删除成功";
            
        } catch (Exception e) {
            j.setSuccess(false);
            message = "删除失败";
            e.printStackTrace();
        }
        j.setMsg(message);  
         return j;
    }
    
	
	/**
	 * 删除
	 * @param lost
	 * @param redirectAttributes
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "del")
	public AjaxJson delete(ModelMap model,HttpServletRequest request) {
		String id = request.getParameter("id");
		String message = null;
		AjaxJson j = new AjaxJson();
		
		try {
			
			lostChangeService.deleteByPrimaryKey(id);
			j.setSuccess(true);
			message = "删除成功";
			
		} catch (Exception e) {
			j.setSuccess(false);
			message = "删除失败";
			e.printStackTrace();
		}
		j.setMsg(message);	
		 return j;
	}
	
	/**
	 * 删除
	 * @param lost
	 * @param redirectAttributes
	 * @return
	 */
	@ResponseBody
	@RequestMapping(value = "updateStatues")
	public AjaxJson updateStatues(ModelMap model,HttpServletRequest request) {
		String id = request.getParameter("id");
		String message = null;
		AjaxJson j = new AjaxJson();
		
		try {
			
			ManifestLostChange manifestLoad = lostChangeService.selectByPrimaryKey(id);
			manifestLoad.setStatus("");
			lostChangeService.updateByPrimaryKeySelective(manifestLoad);
			j.setSuccess(true);
			message = "修改状态成功";
			
		} catch (Exception e) {
			j.setSuccess(false);
			message = "修改状态失败";
			e.printStackTrace();
		}
		j.setMsg(message);	
		 return j;
	}
	
	
	/**
	 * 申报
	 * @param lost
	 * @param redirectAttributes
	 * @return
	 * @throws InvocationTargetException 
	 * @throws IllegalAccessException 
	 */
	@ResponseBody
	@RequestMapping(value = "send")
	public AjaxJson send(ModelMap model,HttpServletRequest request,@RequestParam Map<String, Object> params) throws IllegalAccessException, InvocationTargetException {
		String id = request.getParameter("id");
		ManifestLostChange mf = new ManifestLostChange();
		DateConvert();//日期转化
        BeanUtils.populate(mf, params);
        
        List<ManifestItem> iteamList = itemService.getIteamList(mf.getWaybillnomaster());
       
        List<ConsignmentItem> consignmentItem = new ArrayList<>();
        
        for (ManifestItem manifestItem : iteamList) {
           
            ConsignmentItemPackaging consignmentItemPackaging = new ConsignmentItemPackaging();
            consignmentItemPackaging.setQuantityQuantity(manifestItem.getPiece()); //件数
            consignmentItemPackaging.setTypeCode(manifestItem.getPackageCode()); //包装代码
            
            GoodsMeasure goodsMeasure = new GoodsMeasure();
            goodsMeasure.setGrossMassMeasure(manifestItem.getWeight()); //重量
            
            Commodity commodity = new Commodity();
            commodity.setCargoDescription(manifestItem.getDescription());//货物描述
           
            ConsignmentItem item  = new ConsignmentItem();
            item.setSequenceNumeric(manifestItem.getOrderNumber());//商品序号
            item.setConsignmentItemPackaging(consignmentItemPackaging);//包装项信息
            item.setGoodsMeasure(goodsMeasure);//货物毛重
            item.setCommodity(commodity );
            consignmentItem.add(item);
        }
     

        String message = null;
		AjaxJson j = new AjaxJson();
		try {
			//保存至sendLog表
			Sendlog sendlog = new Sendlog();
			sendlog.setAutoid(UUID.randomUUID().toString());
			sendlog.setMessageautoid(id);
			sendlog.setCreatedate(new Date());
			sendlog.setMessagetype("MT8203");
			sendlog.setReceiption("发送落装改配申请");
			sendLogService.save(sendlog);
			//生成报文并发送
			ManifestXml manifestXml = new ManifestXml();
			
		     HeadXml headXml = new HeadXml();
		     DeclarationXml declaration = new DeclarationXml();
	            Consignment consign = new Consignment();
	            
	            TransportContractDocument transportContractDocument = new TransportContractDocument();
	            AssociatedTransportDocument associatedTransportDocument = new AssociatedTransportDocument();
	            TransportContract transportContract= new TransportContract();
	            AssociatedTransport associatedTransport = new AssociatedTransport();
	          
	            transportContractDocument.setId(mf.getWaybillnomaster());//改配前主单号
	            associatedTransportDocument.setId(mf.getWaybillnomaster()+"_"+mf.getWaybillnosecondary()); //改配前分单号
	            
	            consign.setTransportContractDocument(transportContractDocument);
	            consign.setAssociatedTransportDocument(associatedTransportDocument);
	          
	            ChangeConsignment changeConsignment = new ChangeConsignment();
	            
	            transportContract.setId(mf.getCwaybillnomaster());//改配后主单号
	            associatedTransport.setId(mf.getCwaybillnomaster()+"_"+mf.getCwaybillnosecondary()); //改配分单号
	            
	            changeConsignment.setTransportContractDocument(transportContract);
	            changeConsignment.setAssociatedTransportDocument(associatedTransport);
	            
	         
	            changeConsignment.setConsignmentItem(consignmentItem);
	         
	            consign.setChangeConsignment(changeConsignment);
	            
	            BorderTransportMeans borderTransportMeans = new BorderTransportMeans();
	            borderTransportMeans.setJourneyID(mf.getFlightno()+"/"+DateUtils.DateToString(mf.getFlightdate(), "yyyy-MM-dd HH:mm:ss").substring(0,10).replace("-", ""));//航次航班
             
                ChangeBorderTransportMeans changeBorderTransportMeans = new ChangeBorderTransportMeans();
                changeBorderTransportMeans.setJourneyID(mf.getCflightno()+"/"+DateUtils.DateToString(mf.getCflightdate(), "yyyy-MM-dd HH:mm:ss").substring(0,10).replace("-", ""));//航次航班
               
                declaration.setBorderTransportMeans(borderTransportMeans);
                declaration.setChangeBorderTransportMeans(changeBorderTransportMeans );
                declaration.setConsignment(consign);
                
	            manifestXml.setHeadXml(headXml);
	            manifestXml.setDeclarationXml(declaration);
	            
			XmlGen.genLostChangeXmlAndSend(manifestXml);
			j.setSuccess(true);
			message = "已发送申报报文";
			ManifestLostChange lost = lostChangeService.selectByPrimaryKey(id);
			lost.setStatus("01");//已发送
			lostChangeService.saveorupdate(lost);
		} catch (Exception e) {
			j.setSuccess(false);
			message = "申报报文发送失败";
			e.printStackTrace();
		}
		j.setMsg(message);	
		 return j;
	}

}