package com.mandi.fendan.service.impl;

import java.lang.reflect.InvocationTargetException;
import java.util.*;

import javax.annotation.Resource;
import javax.transaction.Transactional;

import com.mandi.fendan.mapper.FdMxWlgsMapper;
import com.mandi.system.persist.Login;
import com.mandi.system.persist.UserType;
import org.springframework.stereotype.Service;

import com.google.gson.JsonObject;
import com.mandi.fendan.persist.Fd_Company;
import com.mandi.fendan.persist.Fd_Vehicle;

import org.apache.commons.beanutils.BeanUtils;
import org.apache.commons.lang3.StringUtils;

import com.mandi.basicconfig.mapper.NczsjMapper;
import com.mandi.basicconfig.penum.PrefixEnum;
import com.mandi.basicconfig.persist.Ncywdy;
import com.mandi.common.JSONobj;
import com.mandi.common.Wxhtmethod;
import com.mandi.dao.common.Daomethod;
import com.mandi.dao.common.ObjectResult;
import com.mandi.dao.common.PageRequest;
import com.mandi.dao.common.PageResult;
import com.mandi.fendan.mapper.Fd_CompanyMapper;
import com.mandi.fendan.mapper.Fd_VehicleMapper;
import com.mandi.fendan.mapper.Fd_fhdqMapper;
import com.mandi.fendan.service.Ifd_companyService;
import com.mandi.fendan.util.Contants;
import com.mandi.common.Pinyinmethod;
@Service
public class Fd_CompanyService implements Ifd_companyService {
	@Resource
	private Fd_CompanyMapper cmper;
	@Resource
	private Fd_fhdqMapper dqper;
	@Resource
	private Fd_VehicleMapper vhper;
	@Resource
	private NczsjMapper zsjper;

	@Resource
	private FdMxWlgsMapper fdMxWlgsMapper;

	@Override
	public ObjectResult<Fd_Company> get(String id) {
		ObjectResult<Fd_Company> prr = new ObjectResult<Fd_Company>();
		if(!StringUtils.isBlank(id)){
			Fd_Company fcy = cmper.get(id);
			prr.setCode(0);
			prr.setItem(fcy);
		}else{
			prr.setCode(1);
			prr.setErrmsg("编号不能为空");;
		}

		return prr;
	}
	@Override
	public ObjectResult<Fd_Company> getByCompanyNo(String companyNo) {
		ObjectResult<Fd_Company> prr = new ObjectResult<Fd_Company>();
		if(!StringUtils.isBlank(companyNo)){
			Fd_Company fcy = cmper.getByCompanyNo(companyNo);
			prr.setCode(0);
			prr.setItem(fcy);
		}else{
			prr.setCode(1);
			prr.setErrmsg("公司编号不能为空");;
		}

		return prr;
	}

	@Override
	public PageResult<Map<String, Object>> getlist(String name, PageRequest pr) {
		PageResult<Map<String, Object>> prr=new PageResult<Map<String, Object>>();
		List<Map<String, Object>> rl=new ArrayList<Map<String,Object>>();
		Map<String, Object> mp=new HashMap<String, Object>();
		mp.put("pagesize", pr.getPageSize());
		mp.put("page", pr.getStart());
		mp.put("name", name);
		List<Fd_Company> list;
		if(pr.isNeedPages())
		{
			int pages=cmper.getPages(mp);
			pages=Daomethod.countpages(pages, pr.getPageSize());
			prr.setPages(pages);
			list =cmper.getList(mp);
		}else{
			list = cmper.getList1(mp);
		}

		if(list!=null){
			for (Fd_Company fdc : list) {
				String comNo=fdc.getCompanyNo();
				Map<String, Object> rm=new HashMap<String, Object>();
				try {
					rm=BeanUtils.describe(fdc);
				} catch (IllegalAccessException | InvocationTargetException | NoSuchMethodException e) {
				}
				List<Ncywdy> cyl=this.cmper.getncYwdylist(comNo);
				rm.put("ywList", cyl);
				rl.add(rm);
			}
		}
		prr.setCode(0);
		prr.setList(rl);
		return prr;
	}

	@Override
	public List<Map<String, Object>> companytypehead(String search, int pagesize) {

		return null;
	}

	@Override
	public ObjectResult<Fd_Company> saveCompany(Fd_Company c,String ywdyNos) throws Exception {
		ObjectResult<Fd_Company> orr=new ObjectResult<Fd_Company>();
		if(c==null){
			orr.setCode(1);
			orr.setErrmsg("运输公司对象为空，不能保存");
			return orr;
		}
		if(StringUtils.isEmpty(c.getName())){
			orr.setCode(1);
			orr.setErrmsg("运输公司名字为空，不能保存");
			return orr;
		}
		String hdpinyin=Pinyinmethod.pinyinhds(c.getName());
		String pinyin=Pinyinmethod.pinyins(c.getName());
		c.setPinyin(pinyin);
		c.setHdpinyin(hdpinyin);
		String id=c.getId();
		try {
			Fd_Company c1= cmper.get(id);
			if(c1!=null){
				Fd_Company fcd=cmper.getByCompanyNo(c.getCompanyNo());
				if(fcd!=null&&!fcd.getId().equals(c1.getId())){
					orr.setCode(1);
					orr.setErrmsg("运输公司编号已存在，不能保存，请修改！");
					return orr;
				}

				c1.setCname(c.getCname());
				c1.setHdpinyin(c.getHdpinyin());
				c1.setPinyin(c.getPinyin());
				c1.setNote(c.getNote());
				c1.setCtime(new Date());
				c1.setCompanyNo(c.getCompanyNo());
				c1.setHasSPR(c.isHasSPR());
				c1.setName(c.getName());
				c1.setShortName(c.getShortName());
				cmper.update(c1);
				this.cmper.delCYnexus(c.getCompanyNo());
				orr.setItem(c1);
			}else{
				if(StringUtils.isEmpty(c.getCompanyNo())){
					JsonObject pfob=Wxhtmethod.postJsonStr(Contants.YKTgetPrefix_url,PrefixEnum.fd_Company.toString());
					ObjectResult<String> pfor=new ObjectResult<String>();
					String bsNo=JSONobj.getstring(pfob, "item");
					int code=JSONobj.getint(pfob, "code");
					String errmsg=JSONobj.getstring(pfob, "errmsg");
					pfor.setCode(code);
					pfor.setErrmsg(errmsg);
					pfor.setItem(bsNo);
					if(pfor==null||pfor.getCode()!=0){
						orr.setCode(1);
						orr.setErrmsg(pfor.getErrmsg());
						return orr;
					}
					c.setCompanyNo(pfor.getItem());
				}else{
					Fd_Company fcd=cmper.getByCompanyNo(c.getCompanyNo());
					if(fcd!=null){
						orr.setCode(1);
						orr.setErrmsg("运输公司编号已存在，不能保存，请修改！");
						return orr;
					}
				}
				c.setCtime(new Date());
				c.setId(UUID.randomUUID()+"");
				cmper.insert(c);
				orr.setItem(c);
			}
		} catch (Exception e) {
			throw new Exception(StringUtils.isEmpty(e.getMessage())?"物流公司保存出错！":e.getMessage());
		}
		//修改运输公司和业务单元关联表
		if(!StringUtils.isEmpty(ywdyNos)){
			for (String ywdyNo : ywdyNos.split(",")) {
				Ncywdy ywdy=this.zsjper.getNcywdybyCode(ywdyNo);
				if(ywdy==null)
					continue;
				this.cmper.insertCYnexus(c.getCompanyNo(), ywdyNo);
			}
		}

		orr.setCode(0);
		orr.setItem(c);
		return orr;
	}

	@Override
	public ObjectResult<Boolean> changeUsed(Fd_Company cp) {

		return null;
	}

	@Override
	@Transactional(rollbackOn=Exception.class)
	public ObjectResult<Boolean> delCompany(String companyNo) throws Exception{
		ObjectResult<Boolean> prr = new ObjectResult<Boolean>();
		if(!StringUtils.isBlank(companyNo)){

			try {
				Fd_Vehicle fdv=this.vhper.selectbyCompanyNo(companyNo);
				if(fdv!=null){
					prr.setCode(1);
					prr.setErrmsg("请先删除所属的该物流公司的车辆信息！");
					return prr;
				}
				cmper.delByCompanyNo(companyNo);
				this.dqper.delbywlgsCode(companyNo);
				this.cmper.delCYnexus(companyNo);
				prr.setCode(0);
				prr.setItem(true);
			} catch (Exception e) {
				throw new Exception(StringUtils.isEmpty(e.getMessage())?"物流公司删除程序出错！":e.getMessage());
			}
			prr.setCode(0);
			prr.setItem(true);
		}else{
			prr.setCode(1);
			prr.setErrmsg("公司编号不能为空");
		}
		return prr;

	}


	@Override
	public PageResult<Map<String, Object>> getcqList(String companyNo) {
		PageResult<Map<String, Object>> prr=new PageResult<Map<String,Object>>();
		LinkedList<Map<String, Object>> rl=new LinkedList<>();
		if(StringUtils.isNotBlank(companyNo)){
			List<Ncywdy> l=this.cmper.getncYwdylist(companyNo);

			Map<String, Ncywdy> map = new HashMap<>();
			for (Ncywdy ncy : l) { // 排重
				if (map.get(ncy.getCode()) == null)
					map.put(ncy.getCode(), ncy);
			}
			int a = 0;
			for (Map.Entry<String, Ncywdy> entry : map.entrySet()) {
				String code = entry.getKey();
				Map<String, Object> m = null;
				if(Contants.nc_ywdy_ZZ.equals(code)){
					m = new HashMap<>(2);
					m.put("name","郑州厂区");
					m.put("cqval",Contants.nc_ywdy_ZZ);
				}else if(Contants.nc_ywdy_MS.equals(code)){
					m = new HashMap<>(2);
					m.put("name","明晟厂区");
					m.put("cqval",Contants.nc_ywdy_MS);
				}else if(Contants.nc_ywdy_YR.equals(code)){
					m = new HashMap<>(2);
					m.put("name","义瑞厂区");
					m.put("cqval",Contants.nc_ywdy_YR);
				} else{
					if(a==0){ // 防止出现多个科技厂区
						m = new HashMap<>(2);
						m.put("name","科技厂区");
						m.put("cqval",Contants.nc_ywdy_KJ);
						a=1;
						// 特殊需求 科技要放到第一个
						rl.addFirst(m);
					}
					// 防止出现空行
					continue;
				}
				rl.add(m);
			}
			prr.setList(rl);
		}else{
			Map<String, Object> m2=new HashMap<String, Object>();
			m2.put("name","全部厂区");
			m2.put("cqval","");
			rl.add(m2);
			Map<String, Object> m=new HashMap<String, Object>();
			m.put("name","科技厂区");
			m.put("cqval",Contants.nc_ywdy_KJ);
			rl.add(m);
			Map<String, Object> m1=new HashMap<String, Object>();
			m1.put("name","郑州厂区");
			m1.put("cqval",Contants.nc_ywdy_ZZ);
			rl.add(m1);
			Map<String, Object> m3=new HashMap<String, Object>();
			m3.put("name","明晟厂区");
			m3.put("cqval",Contants.nc_ywdy_MS);
			rl.add(m3);
			Map<String, Object> m4=new HashMap<String, Object>();
			m4.put("name","义瑞厂区");
			m4.put("cqval",Contants.nc_ywdy_YR);
			rl.add(m4);
			prr.setList(rl);
		}
		prr.setCode(0);
		return prr;
	}
	@Override
	public PageResult<Map<String, Object>> getFdCqList(String companyNo, Login login) {
		PageResult<Map<String, Object>> prr=new PageResult<Map<String,Object>>();
		LinkedList<Map<String, Object>> rl=new LinkedList<>();
		if (!UserType.admin.toString().equals(login.getWorkerno())) {
			List<Map> l= fdMxWlgsMapper.selectChangqu(login.getUsername());

			Map<String,Map> map = new HashMap<>();
			for (Map map1 : l) { // 排重
				if (map1.get(map1.get("fd_cq")) == null)
					map.put(map1.get("fd_cq").toString(), map1);
			}
			int a = 0;
			for (Map.Entry<String, Map> entry : map.entrySet()) {
				String code = entry.getKey();
				Map<String, Object> m = null;
				if(Contants.nc_ywdy_ZZ.equals(code)){
					m = new HashMap<>(2);
					m.put("name","郑州厂区");
					m.put("cqval",Contants.nc_ywdy_ZZ);
				}else if(Contants.nc_ywdy_MS.equals(code)){
					m = new HashMap<>(2);
					m.put("name","明晟厂区");
					m.put("cqval",Contants.nc_ywdy_MS);
				}else if(Contants.nc_ywdy_YR.equals(code)){
					m = new HashMap<>(2);
					m.put("name","义瑞厂区");
					m.put("cqval",Contants.nc_ywdy_YR);
				} else{
					if(a==0){ // 防止出现多个科技厂区
						m = new HashMap<>(2);
						m.put("name","科技厂区");
						m.put("cqval",Contants.nc_ywdy_KJ);
						a=1;
						// 特殊需求 科技要放到第一个
						rl.addFirst(m);
					}
					// 防止出现空行
					continue;
				}
				rl.add(m);
			}
			prr.setList(rl);
		}else{
			Map<String, Object> m2=new HashMap<String, Object>();
			m2.put("name","全部厂区");
			m2.put("cqval","");
			rl.add(m2);
			Map<String, Object> m=new HashMap<String, Object>();
			m.put("name","科技厂区");
			m.put("cqval",Contants.nc_ywdy_KJ);
			rl.add(m);
			Map<String, Object> m1=new HashMap<String, Object>();
			m1.put("name","郑州厂区");
			m1.put("cqval",Contants.nc_ywdy_ZZ);
			rl.add(m1);
			Map<String, Object> m3=new HashMap<String, Object>();
			m3.put("name","明晟厂区");
			m3.put("cqval",Contants.nc_ywdy_MS);
			rl.add(m3);
			Map<String, Object> m4=new HashMap<String, Object>();
			m4.put("name","义瑞厂区");
			m4.put("cqval",Contants.nc_ywdy_YR);
			rl.add(m4);
			prr.setList(rl);
		}
		prr.setCode(0);
		return prr;
	}


}