package org.springblade.test;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import org.apache.logging.log4j.util.Strings;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springblade.common.utils.SpringUtils;
import org.springblade.core.test.BladeBootTest;
import org.springblade.core.test.BladeSpringExtension;
import org.springblade.core.tool.utils.SpringUtil;
import org.springblade.core.tool.utils.StringUtil;
import org.springblade.flow.engine.entity.FlowModel;
import org.springblade.flow.engine.service.FlowEngineService;
import org.springblade.modules.doorplateAddress.entity.DoorplateAddressEntity;
import org.springblade.modules.doorplateAddress.service.IDoorplateAddressService;
import org.springblade.modules.house.entity.HouseEntity;
import org.springblade.modules.house.service.IHouseService;
import org.springblade.modules.place.entity.PlaceEntity;
import org.springblade.modules.place.service.IPlaceService;
import org.springblade.modules.police.entity.PoliceAffairsGridEntity;
import org.springblade.modules.police.service.IPoliceAffairsGridService;
import org.springblade.modules.task.entity.TaskReportForRepairsEntity;
import org.springblade.modules.task.service.ITaskReportForRepairsService;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

/**
 * Blade单元测试
 *
 * @author Chill
 */
@ExtendWith(BladeSpringExtension.class)
@BladeBootTest(appName = "blade-runner", enableLoader = true)
public class BladeTest {

	@Autowired
	private FlowEngineService service;

	@Autowired
	private IPlaceService iPlaceService;

	@Autowired
	private IDoorplateAddressService iDoorplateAddressService;

	@Autowired
	private IHouseService iHouseService;

//	@Test
	public void test() {

		List<PlaceEntity> list = iPlaceService.list();
		for (PlaceEntity placeEntity : list) {
			DoorplateAddressEntity one = iDoorplateAddressService.getOne(Wrappers.<DoorplateAddressEntity>lambdaQuery()
				.eq(DoorplateAddressEntity::getAddressCode, placeEntity.getHouseCode()).last("limit 1"));
			if (one != null) {
				placeEntity.setAoiCode(one.getAoiCode());
				iPlaceService.updateById(placeEntity);
			}
		}

	}

//	@Test
	public void test2() {
		// 查询 警务网格为空的数据
		List<HouseEntity> list = iHouseService.list(Wrappers.<HouseEntity>lambdaQuery().eq(HouseEntity::getIsDeleted,0));
		// 遍历
		for (HouseEntity houseEntity : list) {
			if (!Strings.isBlank(houseEntity.getLng())) {
				// 空间分析
				//点坐标解析
				String point = "'POINT(" + houseEntity.getLng() + " " + houseEntity.getLat() + ")'";
				List<PoliceAffairsGridEntity> policeAffairsGridEntities
					= SpringUtil.getBean(IPoliceAffairsGridService.class).spatialAnalysis(point);
				if (policeAffairsGridEntities.size() > 0) {
					PoliceAffairsGridEntity policeAffairsGridEntity = policeAffairsGridEntities.get(0);
					houseEntity.setJwGridCode(policeAffairsGridEntity.getJwGridCode());
					// 更新
					iHouseService.updateById(houseEntity);
				}
			}
		}
	}

	@Test
	public void contextLoads() {
		System.out.println("=====数据迁移启动=====");

		// 获取 ACT_DE_MODEL 表需要转换的数据
		List<FlowModel> list = service.list();
		// 循环转换
		list.forEach(flowModel -> {
			if (StringUtil.isBlank(flowModel.getModelEditorXml())) {
				service.update(Wrappers.<FlowModel>lambdaUpdate()
					.set(FlowModel::getModelEditorXml, new String(service.getModelEditorXML(flowModel)))
					.ge(FlowModel::getId, flowModel.getId())
				);
			}
		});

		System.out.println("=====数据迁移完毕=====");
	}

}