package com.stylefeng.guns.modular.system.controller.general;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.stylefeng.guns.core.base.controller.BaseController;
import com.stylefeng.guns.core.common.constant.factory.PageFactory;
import com.stylefeng.guns.core.log.LogObjectHolder;
import com.stylefeng.guns.core.shiro.ShiroKit;
import com.stylefeng.guns.core.shiro.ShiroUser;
import com.stylefeng.guns.core.util.SinataUtil;
import com.stylefeng.guns.core.util.ToolUtil;
import com.stylefeng.guns.modular.system.model.*;
import com.stylefeng.guns.modular.system.service.*;
import com.stylefeng.guns.modular.system.util.PushMinistryOfTransportUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Controller;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * 分公司管理控制器
 *
 * @author fengshuonan
 * @Date 2020-06-06 09:15:48
 */
@Controller
@RequestMapping("/tCompany")
public class TCompanyController extends BaseController {

    private String PREFIX = "/system/tCompany/";

    @Autowired
    private ITCompanyService tCompanyService;

    @Autowired
    private ITRegionService tRegionService;

    @Autowired
    private IUserService userService;

    @Autowired
    private ITTaxiCardService cardService;
	
	@Autowired
	private ITCompanyCityService tCompanyCityService;
	
	@Autowired
	private PushMinistryOfTransportUtil pushMinistryOfTransportUtil;
	
	@Autowired
	private ISpellOrderRuleService spellOrderRuleService;

	@Autowired
	private ITDriverService tDriverService;

	@Autowired
	private ITDriverServiceService tDriverServiceService;

	@Autowired
	private IDriverWorkService driverWorkService;

    @Autowired
    private ITCarService tCarService;

    @Autowired
    private ITCarServiceService tCarServiceService;

	@Value("${pushMinistryOfTransport}")
	private boolean pushMinistryOfTransport;
	
	
	/**
	 * 跳转到修改平台信息
	 */
    @RequestMapping("/admin_update")
    public String tCompanyUpdate(Model model) {
	    ShiroUser user1 = ShiroKit.getUser();
        TCompany tCompany = tCompanyService.selectById(user1.getObjectId());
        model.addAttribute("item",tCompany);
        LogObjectHolder.me().set(tCompany);

        //省
        List<TRegion> provinceList = tRegionService.selectList(new EntityWrapper<TRegion>().eq("parent_id", 0));
        model.addAttribute("provinceList",provinceList);

        //系统用户对象
        User user = userService.selectById(user1.getId());
        model.addAttribute("user",user);

        //经营区域
        List<Map<String, Object>> scopeList = tCompanyService.getCompanyScopeById(tCompany.getId());
        model.addAttribute("scopeList",scopeList);

        //传递当前用户角色类型，用于控制非平台账号禁用经营业务和经营区域编辑
        model.addAttribute("roleType", user1.getRoleType());

        return PREFIX + "platformEdit.html";
    }

    /**
     * 跳转到分公司管理首页
     */
    @RequestMapping("")
    public String index() {
        return PREFIX + "tCompany.html";
    }

    /**
     * 跳转到加盟商管理首页
     */
    @RequestMapping("/franchisee")
    public String franchisee() {
        return PREFIX + "franchisee.html";
    }

    /**
     * 跳转到添加分公司管理
     */
    @RequestMapping("/tCompany_add")
    public String tCompanyAdd(Model model) {
        List<TRegion> provinceList = tRegionService.selectList(new EntityWrapper<TRegion>().eq("parent_id", 0));
        model.addAttribute("provinceList",provinceList);
        return PREFIX + "tCompany_add.html";
    }

    /**
     * 跳转到添加加盟商司管理
     */
    @RequestMapping("/tCompany_addFranchisee")
    public String tCompany_addFranchisee(Model model) {
	    Integer roleType = ShiroKit.getUser().getRoleType();
        if (1 == roleType){
            //查询分公司
            List<TCompany> companyList = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("type", 2));
            model.addAttribute("companyList",companyList);
        }else if (2 == roleType){
	        TCompany tCompany = tCompanyService.selectById(ShiroKit.getUser().getObjectId());
            model.addAttribute("company",tCompany);
        }
        model.addAttribute("roleType",roleType);
        return PREFIX + "tCompany_addFranchisee.html";
    }

    /**
     * 跳转到查看分公司详情
     */
    @RequestMapping("/tCompany_detail/{tCompanyId}")
    public String tCompany_detail(@PathVariable Integer tCompanyId, Model model) {
        TCompany tCompany = tCompanyService.selectById(tCompanyId);
        model.addAttribute("item",tCompany);
        LogObjectHolder.me().set(tCompany);

        //省
        List<TRegion> provinceList = tRegionService.selectList(new EntityWrapper<TRegion>().eq("parent_id", 0));
        model.addAttribute("provinceList",provinceList);

        //系统用户对象
        User user = userService.selectOne(new EntityWrapper<User>().eq("roleType", 2).eq("objectId", tCompanyId));
        model.addAttribute("user",user);

        //经营区域
        List<Map<String, Object>> scopeList = tCompanyService.getCompanyScopeById(tCompanyId);
        model.addAttribute("scopeList",scopeList);

        return PREFIX + "tCompany_detail.html";
    }

    /**
     * 跳转到修改分公司管理
     */
    @RequestMapping("/tCompany_update/{tCompanyId}")
    public String tCompanyUpdate(@PathVariable Integer tCompanyId, Model model) {
        TCompany tCompany = tCompanyService.selectById(tCompanyId);
        model.addAttribute("item",tCompany);
        LogObjectHolder.me().set(tCompany);

        //省
        List<TRegion> provinceList = tRegionService.selectList(new EntityWrapper<TRegion>().eq("parent_id", 0));
        model.addAttribute("provinceList",provinceList);

        //系统用户对象
        User user = userService.selectOne(new EntityWrapper<User>().eq("roleType", 2).eq("objectId", tCompanyId));
        model.addAttribute("user",user);

        //经营区域
        List<Map<String, Object>> scopeList = tCompanyService.getCompanyScopeById(tCompanyId);
        model.addAttribute("scopeList",scopeList);

        // 传递当前用户角色类型，用于控制非平台账号禁用经营业务和经营区域编辑
        model.addAttribute("roleType", ShiroKit.getUser().getRoleType());
        return PREFIX + "tCompany_edit.html";
    }

    /**
     * 跳转到查看加盟商
     */
    @RequestMapping("/tCompany_detailFranchisee/{tCompanyId}")
    public String tCompany_detailFranchisee(@PathVariable Integer tCompanyId, Model model) {
	    TCompany tCompany = tCompanyService.selectById(tCompanyId);
	    model.addAttribute("item", tCompany);
	    LogObjectHolder.me().set(tCompany);
	
	    Integer roleType = ShiroKit.getUser().getRoleType();
	    model.addAttribute("roleType", roleType);
	
	    TCompany obj = tCompanyService.selectById(tCompany.getSuperiorId());
	    if (SinataUtil.isNotEmpty(obj)) {
		    model.addAttribute("companyName", obj.getName());
	    } else {
		    model.addAttribute("companyName", "平台");
	    }
	
	
	    //系统用户对象
	    User user = userService.selectOne(new EntityWrapper<User>().eq("roleType", 3).eq("objectId", tCompanyId));
	    model.addAttribute("user", user);
	    return PREFIX + "tCompany_detailFranchisee.html";
    }

    /**
     * 跳转到修改分公司管理
     */
    @RequestMapping("/tCompany_updateFranchisee/{tCompanyId}")
    public String tCompany_updateFranchisee(@PathVariable Integer tCompanyId, Model model) {
	    TCompany tCompany = tCompanyService.selectById(tCompanyId);
	    model.addAttribute("item", tCompany);
	    LogObjectHolder.me().set(tCompany);
	
	    Integer roleType = ShiroKit.getUser().getRoleType();
	    if (1 == roleType) {
		    //查询分公司
		    List<TCompany> companyList = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("type", 2));
		    model.addAttribute("companyList", companyList);
	    } else if (2 == roleType) {
		    TCompany obj = tCompanyService.selectById(ShiroKit.getUser().getObjectId());
		    model.addAttribute("company", obj);
	    }
	    model.addAttribute("roleType", roleType);
	
	    //系统用户对象
	    User user = userService.selectOne(new EntityWrapper<User>().eq("roleType", 3).eq("objectId", tCompanyId));
	    model.addAttribute("user", user);
	    return PREFIX + "tCompany_updateFranchisee.html";
    }

    @RequestMapping(value = "/change")
    @ResponseBody
    public Object change(@RequestParam Integer code) {
        List<TRegion> list = new ArrayList<>();
        if (SinataUtil.isNotEmpty(code)){
            TRegion region = tRegionService.selectOne(new EntityWrapper<TRegion>().eq("code", code));
            list = tRegionService.selectList(new EntityWrapper<TRegion>().eq("parent_id", region.getId()));
        }
        return list;
    }



    ////   移除经营区域时校验
    @RequestMapping(value = "/searchArea")
    @ResponseBody
    public Object searchArea(Integer companyId, Integer id) {
        List<TTaxiCard> list = cardService.selectList(new EntityWrapper<TTaxiCard>().eq("companyId",companyId));
        for (TTaxiCard tTaxiCard : list) {
            if (ToolUtil.isNotEmpty(tTaxiCard.getCompanyCityId())){
                String[] arr = tTaxiCard.getCompanyCityId().split(";");
                for (String s : arr) {
                    if (s.equals(id.toString())){
                        return "该区域正被打车卡使用，不允许移除";
                    }
                }
            }
        }
        return SUCCESS_TIP;
    }




    /**
     * 获取分公司管理列表
     */
    @RequestMapping(value = "/list")
    @ResponseBody
    public Object list(String insertTime,
                       String name,
                       String principalName,
                       String principalPhone,
                       String adminName,
                       String adminPhone,
                       String serviceStr,
                       Integer state) {
        String beginTime = null;
        String endTime = null;
        if (SinataUtil.isNotEmpty(insertTime)){
            String[] timeArray = insertTime.split(" - ");
            beginTime = timeArray[0];
            endTime = timeArray[1];
        }
        Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
        page.setRecords(tCompanyService.getCompanyList(page,beginTime,endTime,name,principalName,principalPhone,adminName,adminPhone,serviceStr,state));
        return super.packForBT(page);
    }

    /**
     * 获取分公司管理列表
     */
    @RequestMapping(value = "/listFranchisee")
    @ResponseBody
    public Object listFranchisee(String insertTime,
                       String name,
                       String account,
                       String principalName,
                       String principalPhone,
                       String serviceStr,
                       Integer state) {
	    String beginTime = null;
	    String endTime = null;
	    if (SinataUtil.isNotEmpty(insertTime)) {
		    String[] timeArray = insertTime.split(" - ");
		    beginTime = timeArray[0];
		    endTime = timeArray[1];
	    }
	    Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
	    if (ShiroKit.getUser().getRoleType() == 3) {
		    page.setRecords(null);
	    } else {
		    page.setRecords(tCompanyService.getFranchiseeList(page, beginTime, endTime, name, account, principalName, principalPhone, serviceStr, state, ShiroKit.getUser().getRoleType(), ShiroKit.getUser().getObjectId()));
	    }
	    return super.packForBT(page);
    }


    /**
     * 新增分公司管理
     */
    @RequestMapping(value = "/add")
    @ResponseBody
    public Object add(TCompany tCompany,@RequestParam String subArr,String account,String password) {
		String name = tCompany.getName();
		name = name.replaceAll("& lt;", "<");
		name = name.replaceAll("& gt;", ">");
		name = name.replaceAll("& #40;", "(");
		name = name.replaceAll("& #41;", ")");
		tCompany.setName(name);
	    //判断账号是否已存在
	    int count = userService.selectCount(new EntityWrapper<User>().eq("account", account));
	    if (count > 0) {
		    return "error";
	    }
		if(ToolUtil.isEmpty(tCompany.getIdentifier())){
			return "统一社会信用代码不能为空";
		}
	    String commissionError = validateBusinessCommission(tCompany);
	    if (commissionError != null) {
		    return commissionError;
	    }
	    tCompany.setIsNeedFerry(2);
	    tCompany.setType(2);  //2：分公司
	    tCompany.setState(0); //0：正常
	    tCompany.setFlag("1");
	    tCompany.setInsertTime(new Date());
	    tCompany.setUpdateTime(new Date());
	    tCompanyService.insert(tCompany);
	    // 添加拼单设置
	    SpellOrderRule spellOrderRule = new SpellOrderRule();
	    spellOrderRule.setCompanyId(tCompany.getId());
	    spellOrderRuleService.insert(spellOrderRule);
	
	    //添加User对象
	    User user = new User();
	    user.setAccount(account);
	    user.setPhone(account);
	    user.setSalt(ShiroKit.getRandomSalt(5));
	    user.setPassword(ShiroKit.md5(password, user.getSalt()));
	    user.setRoleid("2");
	    user.setDeptid(25);
	    user.setStatus(1);
	    user.setCreatetime(new Date());
	    user.setRoleType(2);
	    user.setObjectId(tCompany.getId());
	    user.setName(tCompany.getName());
	    user.setSex(1);
	    userService.insert(user);

	    //添加经营区域
	    addSocpe(subArr, tCompany.getId());
	    return SUCCESS_TIP;
    }

    //添加经营区域
    public void addSocpe(String subArr,Integer id){
        JSONArray jsonArray = JSON.parseArray(subArr);


        List<Integer> integers = new ArrayList<>();
        for (int i = 0; i < jsonArray.size(); i++) {
            JSONObject jsonObject = jsonArray.getJSONObject(i);
            integers.add(jsonObject.getInteger("recordId"));
        }

        tCompanyCityService.delete(new EntityWrapper<TCompanyCity>().eq("companyId", id).notIn("id",integers));


        int size = jsonArray.size();
        for (int i = 0; i < size; i++){
            JSONObject jsonObject = jsonArray.getJSONObject(i);
            TCompanyCity tCompanyCity = tCompanyCityService.selectOne(new EntityWrapper<TCompanyCity>().eq("id", jsonObject.getInteger("recordId")).eq("companyId", id));
            if (SinataUtil.isEmpty(tCompanyCity)){
                tCompanyCity = new TCompanyCity();
                tCompanyCity.setProvinceCode(jsonObject.getInteger("provinceCode"));
                tCompanyCity.setCityCode(jsonObject.getInteger("cityCode"));
                tCompanyCity.setAreaCode(jsonObject.getInteger("areaCode"));
                tCompanyCity.setCompanyId(id);
                tCompanyCity.setState(1);
                tCompanyCityService.insert(tCompanyCity);
            }else{
                tCompanyCity.setProvinceCode(jsonObject.getInteger("provinceCode"));
                tCompanyCity.setCityCode(jsonObject.getInteger("cityCode"));
                tCompanyCity.setAreaCode(jsonObject.getInteger("areaCode"));
                tCompanyCityService.updateById(tCompanyCity);
            }
        }
    }

    /**
     * 删除分公司管理
     */
    @RequestMapping(value = "/delete")
    @ResponseBody
    public Object delete(@RequestParam Integer tCompanyId) {
	    TCompany tCompany = tCompanyService.selectById(tCompanyId);
	    tCompany.setFlag("3");
	    tCompanyService.updateById(tCompany);
	    return SUCCESS_TIP;
    }

    /**
     * 修改分公司管理
     */
    @RequestMapping(value = "/update")
    @ResponseBody
    @Transactional(rollbackFor = Exception.class)
    public Object update(TCompany tCompany,@RequestParam String subArr,String account,String password,Integer userId) {
		String name = tCompany.getName();
		name = name.replaceAll("& lt;", "<");
		name = name.replaceAll("& gt;", ">");
		name = name.replaceAll("& #40;", "(");
		name = name.replaceAll("& #41;", ")");
		tCompany.setName(name);
	    String commissionError = validateBusinessCommission(tCompany);
	    if (commissionError != null) {
		    return commissionError;
	    }
	    tCompany.setIsNeedFerry(2);
	    User user = userService.selectById(userId);
	    if(null != user && ToolUtil.isNotEmpty(password)){
		    user.setPassword(ShiroKit.md5(password, user.getSalt()));
		    userService.updateById(user);
	    }

	    // ========== 级联更新逻辑 ==========
	    TCompany oldCompany = tCompanyService.selectById(tCompany.getId());
	    if (oldCompany != null && oldCompany.getType() == 2) {
		    String driverServiceError = validateCancelledServiceDriverUsage(oldCompany, tCompany, true);
		    if (driverServiceError != null) {
			    return driverServiceError;
		    }
		    // 1. 检测并级联更新经营业务
		    cascadeUpdateBusinessScope(oldCompany, tCompany);

		    // 2. 更新分公司本身
		    tCompany.setUpdateTime(new Date());
		    tCompanyService.updateById(tCompany);
		    addSocpe(subArr, tCompany.getId());
	    } else {
		    tCompany.setUpdateTime(new Date());
		    tCompanyService.updateById(tCompany);
		    addSocpe(subArr, tCompany.getId());
	    }
	    // ========== 级联更新逻辑结束 ==========

	    TCompany tCompany1 = tCompanyService.selectById(tCompany.getId());
	    if (tCompany1.getType() == 1) {
		    new Thread(new Runnable() {
			    @Override
			    public void run() {
				    if (pushMinistryOfTransport) {//上传平台数据
					    pushMinistryOfTransportUtil.baseInfoCompanyPay();//上传网约车平台公司支付信息
					    pushMinistryOfTransportUtil.baseInfoCompany(tCompany.getId());
					    pushMinistryOfTransportUtil.baseInfoCompanyService();
					    pushMinistryOfTransportUtil.baseInfoCompanyPermit(tCompany.getId());
				    }
			    }
		    }).start();
	    }
	    return SUCCESS_TIP;
    }

    /**
     * 修改加盟商管理
     */
    @RequestMapping(value = "/updateFranchisee")
    @ResponseBody
    public Object updateFranchisee(TCompany tCompany,String account,String password,Integer userId) {
		String name = tCompany.getName();
		name = name.replaceAll("& lt;", "<");
		name = name.replaceAll("& gt;", ">");
		name = name.replaceAll("& #40;", "(");
		name = name.replaceAll("& #41;", ")");
		tCompany.setName(name);
	    String commissionError = validateBusinessCommission(tCompany);
	    if (commissionError != null) {
		    return commissionError;
	    }
	    tCompany.setIsNeedFerry(2);
	    TCompany oldCompany = tCompanyService.selectById(tCompany.getId());
	    String driverServiceError = validateCancelledServiceDriverUsage(oldCompany, tCompany, false);
	    if (driverServiceError != null) {
		    return driverServiceError;
	    }
	    tCompany.setUpdateTime(new Date());
//	    tCompany.setVersion(tCompany.getVersion() + 1);
	    tCompanyService.updateById(tCompany);
	
	    //修改账号密码
	    User user = userService.selectById(userId);
	    user.setPassword(ShiroKit.md5(password, user.getSalt()));
	    userService.updateById(user);
	    return SUCCESS_TIP;
    }
	
    /**
     * 新增加盟商管理
     */
    @RequestMapping(value = "/addFranchisee")
    @ResponseBody
    public Object addFranchisee(TCompany tCompany,String account,String password) {
		String name = tCompany.getName();
		name = name.replaceAll("& lt;", "<");
		name = name.replaceAll("& gt;", ">");
		name = name.replaceAll("& #40;", "(");
		name = name.replaceAll("& #41;", ")");
		tCompany.setName(name);
	    //判断账号是否已存在
	    int count = userService.selectCount(new EntityWrapper<User>().eq("account", account));
	    if (count > 0) {
		    return "error";
	    }
		if(ToolUtil.isEmpty(tCompany.getIdentifier())){
			return "统一社会信用代码不能为空";
		}
	    String commissionError = validateBusinessCommission(tCompany);
	    if (commissionError != null) {
		    return commissionError;
	    }
	    tCompany.setIsNeedFerry(2);
	    tCompany.setType(3);  //2：分公司
	    if (ShiroKit.getUser().getRoleType() == 2) {
		    tCompany.setSuperiorId(ShiroKit.getUser().getObjectId());
	    }
	    tCompany.setState(0); //0：正常
	    tCompany.setFlag("1");
	    tCompany.setInsertTime(new Date());
	    tCompanyService.insert(tCompany);
	
	    //添加User对象
	    User user = new User();
	    user.setAccount(account);
	    user.setPhone(account);
	    user.setSalt(ShiroKit.getRandomSalt(5));
	    user.setPassword(ShiroKit.md5(password, user.getSalt()));
	    user.setRoleid("3");
	    user.setDeptid(26);
	    user.setStatus(1);
	    user.setCreatetime(new Date());
	    user.setRoleType(3);
	    user.setObjectId(tCompany.getId());
	    user.setName(tCompany.getName());
	    user.setSex(1);
	    userService.insert(user);
	    return SUCCESS_TIP;
    }

	/**
	 * 级联更新经营业务
	 * 当分公司取消某项经营业务时，同步更新下属加盟商和司机
	 * @param oldCompany 更新前的分公司数据
	 * @param newCompany 更新后的分公司数据
	 */
	private void cascadeUpdateBusinessScope(TCompany oldCompany, TCompany newCompany) {
		Integer companyId = oldCompany.getId();

		// 1. 找出被取消的经营业务（从1变为2）
		List<Integer> cancelledServiceTypes = new ArrayList<>();
		// 快车: isSpe -> type=1
		if (isServiceCancelled(oldCompany.getIsSpe(), newCompany.getIsSpe())) {
			cancelledServiceTypes.add(1);
		}
		// 出租车: isTaxi -> type=2
		if (isServiceCancelled(oldCompany.getIsTaxi(), newCompany.getIsTaxi())) {
			cancelledServiceTypes.add(2);
		}
		// 跨城: isCross -> type=3
		if (isServiceCancelled(oldCompany.getIsCross(), newCompany.getIsCross())) {
			cancelledServiceTypes.add(3);
		}
		// 同城物流: isSameLogistics -> type=4
		if (isServiceCancelled(oldCompany.getIsSameLogistics(), newCompany.getIsSameLogistics())) {
			cancelledServiceTypes.add(4);
		}
		// 跨城物流: isCrossLogistics -> type=5
		if (isServiceCancelled(oldCompany.getIsCrossLogistics(), newCompany.getIsCrossLogistics())) {
			cancelledServiceTypes.add(5);
		}
		// 包车: isCharter -> type=6
		if (isServiceCancelled(oldCompany.getIsCharter(), newCompany.getIsCharter())) {
			cancelledServiceTypes.add(6);
		}

		if (cancelledServiceTypes.isEmpty()) {
			return; // 没有取消任何业务，无需级联更新
		}

		// 2. 查询该分公司下的所有加盟商
		List<TCompany> franchiseeList = tCompanyService.selectList(
			new EntityWrapper<TCompany>()
				.eq("type", 3)
				.eq("superiorId", companyId)
				.ne("flag", "3")
		);

		// 3. 更新加盟商的经营业务字段
		for (TCompany franchisee : franchiseeList) {
			updateFranchiseeBusinessScope(franchisee, cancelledServiceTypes);
		}

		// 4. 删除分公司直属司机的对应经营业务记录
		deleteDriverServices(companyId, null, cancelledServiceTypes);

		// 5. 删除分公司直属车辆的对应经营业务记录
		deleteCarServices(companyId, null, cancelledServiceTypes);

		// 6. 删除加盟商司机和车辆的对应经营业务记录
		List<Integer> franchiseeIds = franchiseeList.stream()
			.map(TCompany::getId)
			.collect(Collectors.toList());

		if (!franchiseeIds.isEmpty()) {
			for (Integer franchiseeId : franchiseeIds) {
				deleteDriverServices(null, franchiseeId, cancelledServiceTypes);
				deleteCarServices(null, franchiseeId, cancelledServiceTypes);
			}
		}
	}

	/**
	 * 判断经营业务是否被取消（从1变为2）
	 * @param oldValue 旧值
	 * @param newValue 新值
	 * @return true表示被取消
	 */
	private boolean isServiceCancelled(Integer oldValue, Integer newValue) {
		return Integer.valueOf(1).equals(oldValue) && Integer.valueOf(2).equals(newValue);
	}

	/**
	 * 更新加盟商的经营业务字段
	 * @param franchisee 加盟商
	 * @param cancelledTypes 被取消的业务类型列表
	 */
	private void updateFranchiseeBusinessScope(TCompany franchisee, List<Integer> cancelledTypes) {
		boolean needUpdate = false;

		// 快车
		if (cancelledTypes.contains(1) && Integer.valueOf(1).equals(franchisee.getIsSpe())) {
			franchisee.setIsSpe(2);
			needUpdate = true;
		}
		// 出租车
		if (cancelledTypes.contains(2) && Integer.valueOf(1).equals(franchisee.getIsTaxi())) {
			franchisee.setIsTaxi(2);
			needUpdate = true;
		}
		// 跨城
		if (cancelledTypes.contains(3) && Integer.valueOf(1).equals(franchisee.getIsCross())) {
			franchisee.setIsCross(2);
			needUpdate = true;
		}
		// 同城物流
		if (cancelledTypes.contains(4) && Integer.valueOf(1).equals(franchisee.getIsSameLogistics())) {
			franchisee.setIsSameLogistics(2);
			needUpdate = true;
		}
		// 跨城物流
		if (cancelledTypes.contains(5) && Integer.valueOf(1).equals(franchisee.getIsCrossLogistics())) {
			franchisee.setIsCrossLogistics(2);
			needUpdate = true;
		}
		// 包车
		if (cancelledTypes.contains(6) && Integer.valueOf(1).equals(franchisee.getIsCharter())) {
			franchisee.setIsCharter(2);
			needUpdate = true;
		}

		if (needUpdate) {
			franchisee.setUpdateTime(new Date());
			tCompanyService.updateById(franchisee);
		}
	}

	private String validateBusinessCommission(TCompany company) {
		if (Integer.valueOf(1).equals(company.getIsSpe()) && !hasCommissionSetting(company.getSpe())) {
			return "请先设置快车司机抽成";
		}
		if (Integer.valueOf(1).equals(company.getIsTaxi()) && !hasCommissionSetting(company.getTaxi())) {
			return "请先设置出租车司机抽成";
		}
		if (Integer.valueOf(1).equals(company.getIsCross()) && !hasCommissionSetting(company.getCross())) {
			return "请先设置跨城出行司机抽成";
		}
		return null;
	}

	private boolean hasCommissionSetting(String configText) {
		if (SinataUtil.isEmpty(configText)) {
			return false;
		}
		try {
			JSONObject config = JSON.parseObject(configText);
			JSONArray rules = config.getJSONArray("rules");
			if (hasCommissionRule(rules)) {
				return true;
			}
			JSONArray timeRules = config.getJSONArray("time_rules");
			if (timeRules != null) {
				for (int i = 0; i < timeRules.size(); i++) {
					if (hasCommissionRule(timeRules.getJSONArray(i))) {
						return true;
					}
				}
			}
		} catch (Exception e) {
			return false;
		}
		return false;
	}

	private boolean hasCommissionRule(JSONArray rules) {
		if (rules == null || rules.size() <= 0) {
			return false;
		}
		for (int i = 0; i < rules.size(); i++) {
			JSONObject rule = rules.getJSONObject(i);
			if (rule != null && rule.containsKey("percent") && SinataUtil.isNotEmpty(rule.getString("percent"))) {
				return true;
			}
		}
		return false;
	}

	private String validateCancelledServiceDriverUsage(TCompany oldCompany, TCompany newCompany, boolean includeFranchisee) {
		if (oldCompany == null || newCompany == null) {
			return null;
		}
		List<Integer> cancelledTypes = getCancelledCoreServiceTypes(oldCompany, newCompany);
		if (cancelledTypes.isEmpty()) {
			return null;
		}
		List<Integer> driverIds = getCompanyDriverIds(oldCompany.getId(), includeFranchisee);
		if (driverIds.isEmpty()) {
			return null;
		}
		for (Integer cancelledType : cancelledTypes) {
			if (hasDriverWorkingService(driverIds, cancelledType)) {
				return "当前公司内存在司机正在使用" + getServiceName(cancelledType) + "业务，无法变动";
			}
		}
		return null;
	}

	private List<Integer> getCancelledCoreServiceTypes(TCompany oldCompany, TCompany newCompany) {
		List<Integer> cancelledTypes = new ArrayList<>();
		if (isServiceCancelled(oldCompany.getIsSpe(), newCompany.getIsSpe())) {
			cancelledTypes.add(1);
		}
		if (isServiceCancelled(oldCompany.getIsTaxi(), newCompany.getIsTaxi())) {
			cancelledTypes.add(2);
		}
		if (isServiceCancelled(oldCompany.getIsCross(), newCompany.getIsCross())) {
			cancelledTypes.add(3);
		}
		return cancelledTypes;
	}

	private List<Integer> getCompanyDriverIds(Integer companyId, boolean includeFranchisee) {
		List<Integer> driverIds = new ArrayList<>();
		List<TDriver> companyDrivers = tDriverService.selectList(new EntityWrapper<TDriver>().ne("flag", "3").eq("companyId", companyId));
		addDriverIds(driverIds, companyDrivers);
		if (!includeFranchisee) {
			List<TDriver> franchiseeDrivers = tDriverService.selectList(new EntityWrapper<TDriver>().ne("flag", "3").eq("franchiseeId", companyId));
			addDriverIds(driverIds, franchiseeDrivers);
		}
		if (includeFranchisee) {
			List<TCompany> franchiseeList = tCompanyService.selectList(new EntityWrapper<TCompany>().eq("superiorId", companyId).eq("type", 3).ne("flag", "3"));
			for (TCompany franchisee : franchiseeList) {
				List<TDriver> franchiseeDrivers = tDriverService.selectList(new EntityWrapper<TDriver>().ne("flag", "3").eq("franchiseeId", franchisee.getId()));
				addDriverIds(driverIds, franchiseeDrivers);
			}
		}
		return driverIds;
	}

	private void addDriverIds(List<Integer> driverIds, List<TDriver> drivers) {
		if (drivers == null) {
			return;
		}
		for (TDriver driver : drivers) {
			if (driver != null && driver.getId() != null && !driverIds.contains(driver.getId())) {
				driverIds.add(driver.getId());
			}
		}
	}

	private boolean hasDriverWorkingService(List<Integer> driverIds, Integer serviceType) {
		if (driverIds == null || driverIds.isEmpty() || serviceType == null) {
			return false;
		}
		return driverWorkService.selectCount(new EntityWrapper<DriverWork>()
			.in("driverId", driverIds)
			.eq("state", 1)
			.like("type", String.valueOf(serviceType))) > 0;
	}

	private String getServiceName(Integer serviceType) {
		if (Integer.valueOf(1).equals(serviceType)) {
			return "快车";
		}
		if (Integer.valueOf(2).equals(serviceType)) {
			return "出租车";
		}
		if (Integer.valueOf(3).equals(serviceType)) {
			return "跨城出行";
		}
		return "";
	}

	/**
	 * 删除司机的经营业务记录
	 * @param companyId 分公司ID（查询直属司机时使用）
	 * @param franchiseeId 加盟商ID（查询加盟商司机时使用）
	 * @param serviceTypes 要删除的业务类型列表
	 */
	private void deleteDriverServices(Integer companyId, Integer franchiseeId, List<Integer> serviceTypes) {
		Wrapper<TDriver> wrapper = new EntityWrapper<TDriver>().ne("flag", "3");

		if (companyId != null) {
			// 查询分公司直属司机（companyId匹配且franchiseeId为空或0）
			wrapper.eq("companyId", companyId)
				.andNew()
				.isNull("franchiseeId")
				.or()
				.eq("franchiseeId", 0);
		} else if (franchiseeId != null) {
			// 查询加盟商司机
			wrapper.eq("franchiseeId", franchiseeId);
		} else {
			return;
		}

		List<TDriver> drivers = tDriverService.selectList(wrapper);

		for (TDriver driver : drivers) {
			tDriverServiceService.delete(
				new EntityWrapper<TDriverService>()
					.eq("driverId", driver.getId())
					.in("type", serviceTypes)
			);
		}
	}

	/**
	 * 删除车辆的经营业务记录
	 * @param companyId 分公司ID（查询直属车辆时使用）
	 * @param franchiseeId 加盟商ID（查询加盟商车辆时使用）
	 * @param serviceTypes 要删除的业务类型列表
	 */
	private void deleteCarServices(Integer companyId, Integer franchiseeId, List<Integer> serviceTypes) {
		Wrapper<TCar> wrapper = new EntityWrapper<TCar>().ne("state", 2);

		if (companyId != null) {
			// 查询分公司直属车辆（companyId匹配且franchiseeId为空或0）
			wrapper.eq("companyId", companyId)
				.andNew()
				.isNull("franchiseeId")
				.or()
				.eq("franchiseeId", 0);
		} else if (franchiseeId != null) {
			// 查询加盟商车辆
			wrapper.eq("franchiseeId", franchiseeId);
		} else {
			return;
		}

		List<TCar> cars = tCarService.selectList(wrapper);

		for (TCar car : cars) {
			tCarServiceService.delete(
				new EntityWrapper<TCarService>()
					.eq("carId", car.getId())
					.in("type", serviceTypes)
			);
		}
	}

}