package com.mandi.webservice.service.impl;

import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import com.mandi.common.JSONobj;
import com.mandi.common.Jacksonmethod;
import com.mandi.common.ParamFileter.Fileoperation;
import com.mandi.dao.common.ObjectResult;
import com.mandi.dao.common.PageResult;
import com.mandi.fendan.mapper.BusinessMapper;
import com.mandi.fendan.mapper.Fd_BsheetMapper;
import com.mandi.fendan.mapper.Fd_YKTMapper;
import com.mandi.fendan.persist.Fd_Bsheet;
import com.mandi.fendan.util.Contants;
import com.mandi.fendan.util.persist.Serviceenum;
import com.mandi.fendan.util.persist.WaitXSTD;
import com.mandi.servlet.file.impl.FileLoadImpl;
import com.mandi.webservice.service.IFdXSTDService;
import com.mandi.webservice.service.IInvoiceService;
import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Service
public class InvoiceService implements IInvoiceService{
	@Resource
	private IFdXSTDService fdser;
	@Resource
	private BusinessMapper bsPer;
	@Resource
	private Fd_BsheetMapper fdbPer;
	@Resource
	private Fd_YKTMapper yktmper;

	private Logger log= Logger.getLogger(FileLoadImpl.class);

	@Override
	public String action(HttpServletRequest r,String jsonParam) {
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "请求ip::::"+r.getRemoteAddr());
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "数据值::b::"+jsonParam);
		String action="";
		String dataArr="";
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			action=JSONobj.getstring(jo, "action");
			dataArr=jo.get("data").toString();
		} catch (Exception e) {

		}
//		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数action::::"+action);
//		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数dataArr::::"+dataArr);
		Map<String, Object> mm=new HashMap<String, Object>();
		ObjectResult<Boolean> orr=null;
		if(!StringUtils.isEmpty(action)){
			try {
				if(Contants.NcactionCode_add.equals(action)){
					orr=fdser.saveFd_xstd(dataArr);
				}else if(Contants.NcactionCode_del.equals(action)){
					orr=fdser.delFd_xstd(dataArr);
				}else if(Contants.NcactionCode_open.equals(action)){
					orr=fdser.openFd_xstd(dataArr);
				}else if(Contants.NcactionCode_close.equals(action)){
					orr=fdser.closeFd_xstd(dataArr);
				}else{
					mm.put("respcode", 999);
					mm.put("respmsg", "动作参数不正确！");
				}
				if(orr!=null){
					if(orr.getCode()==0){
						mm.put("respcode", 111);
						mm.put("respmsg", orr.getErrmsg());
					}else{
						mm.put("respcode", 999);
						mm.put("respmsg", orr.getErrmsg());
					}
				}
			} catch (Exception e) {
				mm.put("respcode", 999);
				mm.put("respmsg", "错误："+e.getMessage());
			}
		}else{
			mm.put("respcode", 999);
			mm.put("respmsg", "动作参数未找到！");
		}
		String str=Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String delLoading(HttpServletRequest r,String jsonParam) {
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "请求ip::::"+r.getRemoteAddr());
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数metaid::b::"+jsonParam);
		String cardID="";
		String yktywdh="";
		JsonArray dataArr=null;
		Map<String, Object> mm=new HashMap<String, Object>();
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			cardID=JSONobj.getstring(jo, "cardID");
			yktywdh=JSONobj.getstring(jo, "yktywdh");
			dataArr=JSONobj.getJsonArray(jo, "data");
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		ObjectResult<Boolean> prs=new ObjectResult<Boolean>();
		try {
			prs=fdser.delZCMX(cardID, yktywdh, dataArr);
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "delLoading返回值::::"+Jacksonmethod.tojson(prs, false));
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", e.getMessage());
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "delLoading返回值::::"+Jacksonmethod.tojson(mm, false));
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		if(prs!=null){
			if(prs.getCode()==0){
				mm.put("respcode", 111);
				mm.put("respmsg", "操作成功！");
			}else{
				if(prs.getCode()==2){
					mm.put("respcode", 222);
					mm.put("respmsg", prs.getErrmsg());
				}else{
					mm.put("respcode", 999);
					mm.put("respmsg", prs.getErrmsg());
				}
			}
		}
		String str=Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String addLoading(HttpServletRequest r,String jsonParam) {
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "请求ip::::"+r.getRemoteAddr());
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数metaid::b::"+jsonParam);
		String cardID="";
		String yktywdh="";
		JsonArray dataArr=null;
		Map<String, Object> mm=new HashMap<String, Object>();
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			cardID=JSONobj.getstring(jo, "cardID");
			yktywdh=JSONobj.getstring(jo, "yktywdh");
			dataArr=JSONobj.getJsonArray(jo, "data");
//			System.err.println("ddata::::"+dataArr);
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		PageResult<Map<String, Object>> prs=new PageResult<Map<String, Object>>();
		try {
			prs=fdser.addZCMX(cardID, yktywdh, dataArr);
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "addLoading返回值：：::"+Jacksonmethod.tojson(prs, false));
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", e.getMessage());
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "addLoading返回值::::"+Jacksonmethod.tojson(mm, false));
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		if(prs!=null){
			if(prs.getCode()==0){
				mm.put("respcode", 111);
				mm.put("respmsg", "操作成功！");
				mm.put("data", prs.getList());
			}else{
//				mm.put("respcode", 999);
//				mm.put("respmsg", prs.getErrmsg());
				if(prs.getCode()==2){
					mm.put("respcode", 222);
					mm.put("respmsg", prs.getErrmsg());
				}else{
					mm.put("respcode", 999);
					mm.put("respmsg", prs.getErrmsg());
				}
			}
		}
		String str=Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String zcFinish(HttpServletRequest r, String jsonParam) {
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "zcFinish参数map::::" + jsonParam);
		Map<String, Object> mm = new HashMap<String, Object>();
		String businessNo = "";
		boolean zcWc = false;
		try {
			JsonParser jp = new JsonParser();
			JsonObject jo = jp.parse(jsonParam).getAsJsonObject();
			businessNo = JSONobj.getstring(jo, "businessNo");
			zcWc = JSONobj.getbool(jo, "isWc");
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str = Jacksonmethod.tojson(mm, false);
			return str;
		}
		if (StringUtils.isBlank(businessNo)) {
			mm.put("respcode", 999);
			mm.put("respmsg", "业务单号参数为空！");
			String str = Jacksonmethod.tojson(mm, false);
			return str;
		}
		Fd_Bsheet fb = this.fdbPer.getbybsNo(businessNo);
		if (fb == null && fb.getStatus() != Serviceenum.在办) {
			mm.put("respcode", 999);
			mm.put("respmsg", "未找到在办业务单！");
			String str = Jacksonmethod.tojson(mm, false);
			return str;
		}
		Map<String, Object> xsTask = bsPer.selectTaskTime(businessNo);
		if (xsTask != null) {
			Map<String, Object> xstm = new HashMap<String, Object>();
			xstm.put("businessNo", businessNo);
			xstm.put("zcWc", zcWc);
			if (zcWc)
				xstm.put("zcwcTime", new Date());
			else
				xstm.put("zcwcTime", null);
			bsPer.updateZcWcTime(xstm);

			if (zcWc) {
				List<WaitXSTD> l = this.fdbPer.getAllKH(fb.getBsNo(), fb.getId());
				if (l != null) {
					boolean iscz = false;//收货单位在明细中是否存在
					WaitXSTD wt = null;
					for (WaitXSTD waitXSTD : l) {
						if (fb.getShdw().equals(waitXSTD.getTd_khmc())) {
							iscz = true;
							break;
						} else {
							if (wt == null && StringUtils.isNotBlank(waitXSTD.getTd_khmc())) {
								wt = waitXSTD;
							}
						}
					}
					if (!iscz && wt != null) {
						fb.setShdw(wt.getTd_khmc());
						this.yktmper.updateshcompany(fb.getBsNo(), wt.getTd_khmc(), wt.getTd_shdd());
					}
				}
			}
			mm.put("respcode", 111);
			mm.put("respmsg", "完成装车操作成功！");
		} else {
			mm.put("respcode", 999);
			mm.put("respmsg", "业务单号参数错误！");
		}
		String str = Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String getVInfo(HttpServletRequest r,String jsonParam) {

		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "getVInfo参数map::::"+jsonParam);
//		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数yktkh::::"+RequestParam.getString(r, "yktkh"));

		String cardID="";
		boolean needRecord=true;
		Map<String, Object> mm=new HashMap<String, Object>();
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			cardID=JSONobj.getstring(jo, "yktkh");
			if(jo.has("needRecord")) {
				needRecord = JSONobj.getbool(jo, "needRecord");
			}
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		ObjectResult<Map<String, Object>> prs=fdser.getcInfo(cardID,needRecord);
		if(prs.getCode() == 1) {
			log.info("卡号:" + cardID + "---- 错误："+ prs.getErrmsg());
		}
		if(prs!=null){
			if(prs.getCode()==0){
				mm=prs.getItem();
			}else{
				mm.put("respcode", 999);
				mm.put("respmsg", prs.getErrmsg());
			}
		}
		String str=Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String getxstdInfo(HttpServletRequest r, String jsonParam) {
		String xstdNo="";
		Map<String, Object> mm=new HashMap<String, Object>();
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			xstdNo=JSONobj.getstring(jo, "xstdNo");
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		ObjectResult<Map<String, Object>> or=fdser.getxstdInfo(xstdNo);
		String str="";
		if(or.getCode()!=0){
			str=Jacksonmethod.tojson(or, false);
		}else{
			str=Jacksonmethod.tojson(or.getItem(), false);
		}
		return str;
	}

	@Override
	public String savewdControl(HttpServletRequest r, String jsonParam) {
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "请求ip::::"+r.getRemoteAddr());
		Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "参数savewdControl::b::"+jsonParam);
		JsonArray dataArr=null;
		Map<String, Object> mm=new HashMap<String, Object>();
		try {
			JsonParser jp=new JsonParser();
			JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
			dataArr=JSONobj.getJsonArray(jo, "data");
			System.err.println("savewdControl ddata::::"+dataArr);
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", "数据解析出错！");
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		ObjectResult<Boolean> prs=new ObjectResult<Boolean>();
		try {
			prs=fdser.savewdControl(dataArr);
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "savewdControl返回值：：::"+Jacksonmethod.tojson(prs, false));
		} catch (Exception e) {
			mm.put("respcode", 999);
			mm.put("respmsg", e.getMessage());
			Fileoperation.AppendContentToFile(Fileoperation.gettestFileName(), "savewdControl返回值::::"+Jacksonmethod.tojson(mm, false));
			String str=Jacksonmethod.tojson(mm, false);
			return str;
		}
		if(prs!=null){
			if(prs.getCode()==0){
				mm.put("respcode", 111);
				mm.put("respmsg", "操作成功！");
			}else{
				mm.put("respcode", 999);
				mm.put("respmsg", prs.getErrmsg());
			}
		}
		String str=Jacksonmethod.tojson(mm, false);
		return str;
	}

	@Override
	public String receiveCurrWeight(HttpServletRequest r, String jsonParam) { // 获取业务单号 一次称重 二次称重
		JsonParser jp=new JsonParser();
		JsonObject jo=jp.parse(jsonParam).getAsJsonObject();
		String businessNo = JSONobj.getstring(jo, "businessNo");
		boolean firstWeighing = JSONobj.getbool(jo, "firstWeighing");
		boolean secondWeighing = JSONobj.getbool(jo, "secondWeighing");
		String sdepartNo = JSONobj.getstring(jo, "sdepartNo");
		if(StringUtils.isBlank(businessNo) || businessNo.indexOf("XS")!=0 || StringUtils.isBlank(sdepartNo)
		) {
			return null;
		}
		// 刷新
		if(firstWeighing || secondWeighing) { // 称重需要刷新一下
			if ("06".equals(sdepartNo)) { // 明晟
				synchronized (FdXSTDService.refreshMsLedLock) {
					if (FdXSTDService.refreshMsLedLock) { // 系统繁忙
						return null;
					}
				}
				try {
					synchronized (FdXSTDService.refreshMsLedLock) {
						FdXSTDService.refreshMsLedLock = true;
					}
					fdser.sendToMsLed(null);
				} finally {
					synchronized (FdXSTDService.refreshMsLedLock) {
						FdXSTDService.refreshMsLedLock = false;
					}
				}
			} else if ("08".equals(sdepartNo)) { // 义瑞
				synchronized (FdXSTDService.refreshYrLedLock) {
					if (FdXSTDService.refreshYrLedLock) { // 系统繁忙
						return null;
					}
				}
				try {
					synchronized (FdXSTDService.refreshYrLedLock) {
						FdXSTDService.refreshYrLedLock = true;
					}
					fdser.sendToYrLed(null);
				}finally {
					synchronized (FdXSTDService.refreshYrLedLock) {
						FdXSTDService.refreshYrLedLock = false;
					}
				}
			}
		} else if ("04".equals(sdepartNo)) { // 科技
			synchronized (FdXSTDService.refreshYrLedLock) {
				if (FdXSTDService.refreshKjLedLock) { // 系统繁忙
					return null;
				}
			}
			try {
				synchronized (FdXSTDService.refreshKjLedLock) {
					FdXSTDService.refreshKjLedLock = true;
				}
				fdser.sendToKjLed(null);
			} finally {
				synchronized (FdXSTDService.refreshKjLedLock) {
					FdXSTDService.refreshKjLedLock = false;
				}
			}
		}
		return null;
	}


}