/*
 *    Copyright (c) 2018-2025, ztt All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * Redistributions of source code must retain the above copyright notice,
 * this list of conditions and the following disclaimer.
 * Redistributions in binary form must reproduce the above copyright
 * notice, this list of conditions and the following disclaimer in the
 * documentation and/or other materials provided with the distribution.
 * Neither the name of the pig4cloud.com developer nor the names of its
 * contributors may be used to endorse or promote products derived from
 * this software without specific prior written permission.
 * Author: ztt
 */
package com.chinaztt.mes.basic.service.impl;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.ifs.api.feign.IfsFeignClient;
import com.chinaztt.mes.basic.dto.LocationDTO;
import com.chinaztt.mes.basic.dto.LocationIfsMoveDTO;
import com.chinaztt.mes.basic.entity.Factory;
import com.chinaztt.mes.basic.entity.Location;
import com.chinaztt.mes.basic.entity.Warehouse;
import com.chinaztt.mes.basic.excel.LocationData;
import com.chinaztt.mes.basic.mapper.FactoryMapper;
import com.chinaztt.mes.basic.mapper.LocationMapper;
import com.chinaztt.mes.basic.mapper.WarehouseMapper;
import com.chinaztt.mes.basic.service.LocationService;
import com.chinaztt.mes.basic.util.DictUtils;
import com.chinaztt.ztt.admin.api.entity.SysDictItem;
import com.chinaztt.ztt.admin.api.feign.RemoteParamService;
import com.chinaztt.ztt.common.core.constant.SecurityConstants;
import com.chinaztt.ztt.common.core.util.R;
import com.google.gson.Gson;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;

/**
 * 库位基础数据
 *
 * @author sunxl
 * @date 2020-09-21 08:18:12
 */
@Service
@AllArgsConstructor
public class LocationServiceImpl extends ServiceImpl<LocationMapper, Location> implements LocationService {
	private WarehouseMapper warehouseMapper;
	private FactoryMapper factoryMapper;
	private static final String LOCATION_QC_SEND_BACK = "LOCATION_QC_SEND_BACK";
	public static final String CONTRACT = "IFS_DOMAIN";
	private RemoteParamService remoteParamService;
	private IfsFeignClient ifsFeignClient;
	private DictUtils dictUtils;
	@Override
	public IPage<List<Location>> getLoc(Page page, QueryWrapper<LocationDTO> ew) {
		return baseMapper.getLoc(page, ew);
	}

	@Override
	public IPage<List<LocationDTO>> getLocationDtoPage(Page page, QueryWrapper<LocationDTO> ew) {
		return baseMapper.getLocationDtoPage(page, ew);
	}

	@Override
	public void deleteLocation(List<Long> ids) {
		baseMapper.deleteBatchIds(ids);
	}

	@Override
	public List<Location> getPrepare(Location location) {
		return baseMapper.getPrepare(location);
	}

	@Override
	public void importLocationExcel(List<LocationData> list) {
		if (CollectionUtil.isEmpty(list)) {
			return;
		}
		list.forEach(System.out::println);
		List<Factory> factories = factoryMapper.selectList(null);
		List<Warehouse> warehouses = warehouseMapper.selectList(null);
		List<SysDictItem> dict = dictUtils.getDict("warehouse_type");
		for (LocationData data : list) {
			QueryWrapper<Location>QueryWrapper = new QueryWrapper<>();
			QueryWrapper.lambda().eq(Location::getLocNo,data.getLocNo());
			Location location = baseMapper.selectOne(QueryWrapper);
			if(!Objects.isNull(location)){
				log.error("库位编号重复=====》"+data.getLocNo());
				continue;
			}
			Location newLocation = new Location();
			dict.forEach(a->{
				if (a.getLabel().equals(data.getLocType())){
					newLocation.setLocType(a.getValue());
				}
			});
			if("启用".equals(data.getLocState())){
				newLocation.setLocStatus(1);
			}else{
				newLocation.setLocStatus(0);
			}
			for (int i = 0; i <factories.size() ; i++) {
				if (factories.get(i).getFactoryName().equals(data.getFactoryName())){
					newLocation.setFactoryId(factories.get(i).getId());
				}
			}
			if (newLocation.getFactoryId()==null){
				log.error("工厂:" + data.getFactoryName() + "不存在");
				continue ;
			}
			for (int i = 0; i <warehouses.size() ; i++) {
				if (warehouses.get(i).getWarehouseName().equals(data.getWarehouseName())){
					newLocation.setLocGroup(warehouses.get(i).getId());
				}
			}
			if (newLocation.getLocGroup()==null){
				log.error("仓库:" + data.getWarehouseName() + "不存在");
				continue ;
			}
			newLocation.setLocName(data.getLocName());
			newLocation.setLocNo(data.getLocNo());
			newLocation.setIfsLocation(data.getIfsLocation());
			baseMapper.insert(newLocation);
		}
	}

	@Override
	public List<JSONObject> pdaList(QueryWrapper<LocationDTO> gen) {
		return baseMapper.pdaList(gen);
	}

	@Override
	public Location getDeaultLocation() {
		//查询参数配置的值
		String locationQcSendBack = remoteParamService.getByKey(LOCATION_QC_SEND_BACK, SecurityConstants.FROM_IN).getData();
		return baseMapper.selectOne(Wrappers.<Location>lambdaQuery().eq(Location::getLocNo, locationQcSendBack));
	}

	@Override
	public R getIfsLocation(String locationGroup, String locationNo, String locationDesc) {
		JSONObject jsonObject = new JSONObject();
		if (StringUtils.isNotBlank(locationGroup)) {
			jsonObject.put("LOCATION_GROUP", locationGroup);
		}
		if (StringUtils.isNotBlank(locationNo)) {
			jsonObject.put("LOCATION_NO", locationNo);
		}
		if (StringUtils.isNotBlank(locationDesc)) {
			jsonObject.put("LOCATION_DESC", locationDesc);
		}
		R result = ifsFeignClient.queryLocationInfoStd(jsonObject, true);
		if (result.getCode() == 0) {
			JSONObject data = (JSONObject) JSON.toJSON(result.getData());
			return R.ok(data.getJSONArray("LIST_INFO"), "OK");
		} else {
			return R.failed("IFS错误——" + result.getMsg());
		}
	}

	@Override
	public R getIfsLocationGroup() {
		R result = ifsFeignClient.queryLocationGroupStd(new JSONObject(), true);
		if (result.getCode() == 0) {
			JSONObject data = (JSONObject) JSON.toJSON(result.getData());
			return R.ok(data.getJSONArray("LIST_INFO"), "OK");
		} else {
			return R.failed("IFS错误——" + result.getMsg());
		}
	}

	@Override
	public R moveIfsLocation(LocationIfsMoveDTO moveDTO) {
		String contract = remoteParamService.getByKey(CONTRACT, SecurityConstants.FROM_IN).getData();
		if (StringUtils.isBlank(contract)) {
			throw new RuntimeException("系统参数中未配置IFS域，无法移库");
		}
		List<LocationIfsMoveDTO.DataBean> dataBeans = new ArrayList<>();
		moveDTO.getBATCH_INFO().forEach(e -> {
			if (!StrUtil.equals(e.getLOCATION_NO(), e.getTO_LOCATION_NO())) {
				e.setTO_CONTRACT(contract);
				dataBeans.add(e);
			}
		});
		if (CollectionUtil.isEmpty(dataBeans)) {
			return R.ok();
		}
		Gson gson = new Gson();
		String jsonstr = gson.toJson(moveDTO);
		JSONObject jsonObject = JSONObject.parseObject(jsonstr);//解决序列化时自动将大写转小写问题
		R response = ifsFeignClient.importMovePartStd(jsonObject, true);
		if (response.getCode() == 0) {
			return R.ok();
		} else {
			throw new RuntimeException("请求ifs失败" + response.getMsg());
		}
	}

	@Override
	public List<Map> getLocationByGroups(List<Long> localGroups) {
		List<Map> locationByGroups = baseMapper.getLocationByGroups(localGroups);
		return locationByGroups;
	}
}