package org.springblade.modules.location.controller;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.csvreader.CsvReader;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import liquibase.pro.packaged.E;
import liquibase.pro.packaged.S;
import lombok.AllArgsConstructor;
import net.sf.json.JSONArray;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.springblade.common.utils.DowloadZipUtil;
import org.springblade.common.utils.FileZip;
import org.springblade.common.utils.HttpReqUtil;
import org.springblade.common.utils.Md5SignUtil;
import org.springblade.core.mp.support.Condition;
import org.springblade.core.mp.support.Query;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.FTP.FtpUtil;
import org.springblade.modules.equipage.service.CarService;
import org.springblade.modules.location.entity.Locus;
import org.springblade.modules.location.service.LocusService;
import org.springblade.modules.location.vo.LocusVo;
import org.springblade.modules.system.service.IUserService;
import org.springblade.modules.system.service.MyAsyncService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.awt.*;
import java.io.File;
import java.io.IOException;
import java.nio.charset.Charset;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.List;

import static org.springblade.common.config.FtpConfig.localPath;

/**
 * @author zhongrj
 * @time 2021-07-06
 * @desc 轨迹管理控制层
 */
@RestController
@AllArgsConstructor
@RequestMapping("/locus")
public class LocusController {

	private final LocusService locusService;
	private final CarService carService;
	private IUserService userService;
	private final MyAsyncService myAsyncService;

	/**
	 * 自定义分页
	 *
	 * @param query page,size
	 * @param locus 轨迹信息对象
	 */
	@GetMapping("/page")
	public R<IPage<LocusVo>> page(LocusVo locus, Query query) {
		IPage<LocusVo> pages = locusService.selectLocusPage(Condition.getPage(query), locus);
		return R.data(pages);
	}

	/**
	 * 新增
	 *
	 * @param locus 轨迹信息对象
	 */
	@PostMapping("/save")
	@ApiOperation(value = "新增", notes = "传入locus")
	public R save(@RequestBody Locus locus) {
		return R.status(locusService.save(locus));
	}

	/**
	 * 修改
	 *
	 * @param locus 轨迹信息对象
	 */
	@PostMapping("/update")
	public R update(@RequestBody Locus locus) {
		return R.status(locusService.updateById(locus));
	}

	/**
	 * 新增或修改
	 *
	 * @param locus 轨迹信息对象
	 */
	@PostMapping("/submit")
	public R submit(@RequestBody Locus locus) {
		return R.status(locusService.saveOrUpdate(locus));
	}

	/**
	 * 删除
	 *
	 * @param ids 轨迹信息ids 数组
	 */
	@PostMapping("/remove")
	public R remove(@ApiParam(value = "主键集合") @RequestParam String ids) {
		return R.status(locusService.removeByIds(Func.toLongList(ids)));
	}

	/**
	 * 详情
	 *
	 * @param locus 轨迹信息对象
	 */
	@GetMapping("/detail")
	@ApiOperation(value = "详情", notes = "传入locus")
	public R<LocusVo> detail(Locus locus) {
		LocusVo detail = locusService.selectLocusInfo(locus);
		return R.data(detail);
	}

	/**
	 * 查询车辆轨迹
	 */
	@GetMapping("/locationhistoryTrack")
	public void locationhistoryTrack() {
		String url = "http://dvopenapi.aimap.net.cn/openapi/device/historyTrack";
		String res = null;
		List<Map<Object, Object>> maps = carService.selectCar();
		for (int i = 0; i < maps.size(); i++) {
			Map<String, Object> params = new HashMap<>();
			params.put("imei", maps.get(i).get("code").toString());
			params.put("beginTime", "2021112510");
			params.put("endTime", "2021112511");
			params.put("rectify", 0);
			params.put("callbackUrl", "http://2h3f861221.wicp.vip/locus/SaveUrl");
			params.put("callbackId", maps.get(i).get("carnumber").toString());
			params.put("appId", "PO00000761");
			params.put("timestamp", System.currentTimeMillis());
			String secert = "dXRGb2pRNVdWOGQ3d1ouV29UYzc1MnJaUnBwTzUx";
			String computeSign = "";
			try {
				computeSign = Md5SignUtil.signRequest(params, secert);
			} catch (IOException e1) {
				e1.printStackTrace();
			}
			params.put("sign", computeSign);
			try {
				res = HttpReqUtil.getInstance().doPost(url, params, null);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

	}

	/**
	 * 轨迹回调
	 *
	 * @param callbackId
	 * @param fileUrl
	 */
	@PostMapping("/SaveUrl")
	@ApiOperation(value = "详情", notes = "传入car")
	public void SaveUrl(String callbackId, String fileUrl) throws Exception {
		DowloadZipUtil dowloadZipUtil = new DowloadZipUtil();
		File file = dowloadZipUtil.downloadFile(fileUrl, "/usr/local/nginx/dist/enterprises/car");
		//文件名
		String name = file.getName();
		String substring = name.substring(0, name.length() - 4);
		//解压数据
		FileZip fileZip = new FileZip();
		fileZip.ZipUncompress("/usr/local/nginx/dist/enterprises/car/" + substring + ".zip", "/usr/local/nginx/dist/enterprises/car");
		try {
			// 用来保存数据
			ArrayList<String[]> csvFileList = new ArrayList<String[]>();
			// 定义一个CSV路径
			String csvFilePath = "/usr/local/nginx/dist/enterprises/car/" + substring + ".csv";
			// 创建CSV读对象 例如:CsvReader(文件路径，分隔符，编码格式);
			CsvReader reader = new CsvReader(csvFilePath, ',', Charset.forName("UTF-8"));
			// 跳过表头 如果需要表头的话，这句可以忽略
			reader.readHeaders();
			// 逐行读入除表头的数据
			while (reader.readRecord()) {
				csvFileList.add(reader.getValues());
			}
			reader.close();
			Locus locus = new Locus();
			String s1 = "";
			if (csvFileList.size() != 0) {
				//遍历读取的CSV文件
				for (int row = 0; row < csvFileList.size(); row++) {
					// 取得第row行第0列的数据
					String cell = csvFileList.get(row)[0];
					String cell1 = csvFileList.get(row)[1];
					String cell2 = csvFileList.get(row)[2];
					Date date = timeStamp2Date(cell2);
					locus.setType(2);
					locus.setLongitude(cell);
					locus.setLatitude(cell1);
					locus.setRecordTime(date);
					locus.setWorkerId(callbackId);
					locusService.save(locus);
					//数据推送
					s1 +=
						"insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) " +
							"values(" + "'" + locus.getId() + "'" + "," +
							"'" + locus.getType() + "'" + "," +
							"'" + locus.getWorkerId() + "'" + "," +
							"'" + locus.getLongitude() + "'" + "," +
							"'" + locus.getLatitude() + "'" + "," +
							"'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")";
					if (row != csvFileList.size() - 1) {
						s1 += ";";
					}
				}
				//FtpUtil.sqlFileUpload(s1);
				myAsyncService.dataSync(s1);
				deletescsv(substring);
			}
			deletescsv(substring);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	public static Date timeStamp2Date(String time) {
		Long timeLong = Long.parseLong(time);
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//要转换的时间格式
		Date date;
		try {
			date = sdf.parse(sdf.format(timeLong));
			return date;
		} catch (ParseException e) {
			e.printStackTrace();
			return null;
		}

	}

//	@PostMapping("/ss")
//	public void Peog() throws Exception {
//		String url = "http://47.104.104.46/api/client/getgistrack.php";
//		Calendar calendar = Calendar.getInstance();
//		calendar.set(Calendar.HOUR_OF_DAY, calendar.get(Calendar.HOUR_OF_DAY) - 1);
//		SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:00:00");
//		//查询有押运人员的数据
//		List<Map<String, Object>> list = userService.selectEquipent();
//		for (int i = 0; i < list.size(); i++) {
//			//实时位置实体类
//			Locus locus = new Locus();
//			locus.setType(1);
//			String id = list.get(i).get("id").toString();
//			locus.setWorkerId(id);
//			Map<String, Object> params = new HashMap<>();
//			String equipmentCode = list.get(i).get("code").toString();
//			//设备imei号
//			params.put("number", 7730);
//			params.put("acc", equipmentCode);
//			params.put("startTime", "2021-12-01");
//			params.put("endTime", "2021-12-02");
//			String res = null;
//			res = HttpReqUtil.getInstance().doPost(url, params, null);
//			String a = "[" + res + "]";
//			JSONArray jsonArray = JSONArray.fromObject(a);
//			String track = jsonArray.getJSONObject(0).get("track").toString();
//			JSONArray jsonArray1 = JSONArray.fromObject(track);
//			String s1 = "";
//			for (int j = 0; j < jsonArray1.size(); j++) {
//				String gis_jd = jsonArray1.getJSONObject(j).get("gis_jd").toString();
//				String gis_wd = jsonArray1.getJSONObject(j).get("gis_wd").toString();
//				String date = jsonArray1.getJSONObject(j).get("date").toString();
//				SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
//				try {
//					//使用SimpleDateFormat的parse()方法生成Date
//					Date dates = sf.parse(date);
//					locus.setRecordTime(dates);
//					//打印Date
//				} catch (ParseException e) {
//					e.printStackTrace();
//				}
//				locus.setLongitude(gis_jd);
//				locus.setLatitude(gis_wd);
//				locusService.save(locus);
//				//数据推送
//				s1 += "insert into sys_locus(id,type,worker_id,longitude,latitude,record_time) values" +
//					" (" + "'" + locus.getId() + "'" + "," +
//					"'" + locus.getType() + "'" + "," +
//					"'" + locus.getWorkerId() + "'" + "," +
//					"'" + locus.getLongitude() + "'" + "," +
//					"'" + locus.getLatitude() + "'" + "," +
//					"'" + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(locus.getRecordTime()) + "'" + ")";
//				if (j != jsonArray1.size() - 1) {
//					s1 += ";";
//				}
//			}
//			FtpUtil.sqlFileUpload(s1);
//		}
//	}


	/**
	 * 删除本地csv文件
	 *
	 * @param fileName
	 */
	public static void deletescsv(String fileName) {
		File file = new File("D:\\caiji\\" + fileName + ".csv");
		if (file.isFile() && file.exists()) {
			file.delete();
		}
	}


}