package com.aps.job.service.impl;

import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.aps.common.core.constant.SecurityConstants;
import com.aps.common.core.utils.DateUtils;
import com.aps.common.core.utils.StringUtils;
import com.aps.common.core.utils.uuid.IdUtils;
import com.aps.job.domain.ApsStandardProcessRouteHeaderJob;
import com.aps.job.domain.ApsStandardProcessRouteLineJob;
import com.aps.job.domain.ApsWorkOrderJobLog;
import com.aps.job.mapper.ApsStandardProcessRouteHeaderJobMapper;
import com.aps.job.mapper.ApsStandardProcessRouteLineJobMapper;
import com.aps.job.mapper.ApsWorkOrderJobLogMapper;
import com.aps.job.service.IApsStandardProcessRouteHeaderJobService;
import com.aps.system.api.RemoteCoreService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.client.RestTemplate;

import java.util.ArrayList;
import java.util.List;

/**
 * 标准工艺路线HeaderService业务层处理
 * 
 * @author hjy
 * @date 2025-05-09
 */
@Slf4j
@Service
public class ApsStandardProcessRouteHeaderJobServiceImpl implements IApsStandardProcessRouteHeaderJobService 
{
    @Autowired
    private ApsStandardProcessRouteHeaderJobMapper apsStandardProcessRouteHeaderJobMapper;

    @Autowired
    private ApsStandardProcessRouteLineJobMapper apsStandardProcessRouteLineJobMapper;

    @Value("${u9.processRouteUrl}")
    private String getProcessRouteUrl;

    @Autowired
    private ApsWorkOrderJobLogMapper jobLogMapper;

    @Autowired
    private RestTemplate restTemplate;

    @Autowired
    private RemoteCoreService remoteCoreService;

    /**
     * 查询标准工艺路线Header
     * 
     * @param id 标准工艺路线Header主键
     * @return 标准工艺路线Header
     */
    @Override
    public ApsStandardProcessRouteHeaderJob selectApsStandardProcessRouteHeaderJobById(Long id)
    {
        return apsStandardProcessRouteHeaderJobMapper.selectApsStandardProcessRouteHeaderJobById(id);
    }

    /**
     * 查询标准工艺路线Header列表
     * 
     * @param apsStandardProcessRouteHeaderJob 标准工艺路线Header
     * @return 标准工艺路线Header
     */
    @Override
    public List<ApsStandardProcessRouteHeaderJob> selectApsStandardProcessRouteHeaderJobList(ApsStandardProcessRouteHeaderJob apsStandardProcessRouteHeaderJob)
    {
        return apsStandardProcessRouteHeaderJobMapper.selectApsStandardProcessRouteHeaderJobList(apsStandardProcessRouteHeaderJob);
    }

    /**
     * 新增标准工艺路线Header
     * 
     * @param apsStandardProcessRouteHeaderJob 标准工艺路线Header
     * @return 结果
     */
    @Override
    public int insertApsStandardProcessRouteHeaderJob(ApsStandardProcessRouteHeaderJob apsStandardProcessRouteHeaderJob)
    {
        apsStandardProcessRouteHeaderJob.setCreateTime(DateUtils.getNowDate());
        return apsStandardProcessRouteHeaderJobMapper.insertApsStandardProcessRouteHeaderJob(apsStandardProcessRouteHeaderJob);
    }

    /**
     * 修改标准工艺路线Header
     * 
     * @param apsStandardProcessRouteHeaderJob 标准工艺路线Header
     * @return 结果
     */
    @Override
    public int updateApsStandardProcessRouteHeaderJob(ApsStandardProcessRouteHeaderJob apsStandardProcessRouteHeaderJob)
    {
        apsStandardProcessRouteHeaderJob.setUpdateTime(DateUtils.getNowDate());
        return apsStandardProcessRouteHeaderJobMapper.updateApsStandardProcessRouteHeaderJob(apsStandardProcessRouteHeaderJob);
    }

    /**
     * 批量删除标准工艺路线Header
     * 
     * @param ids 需要删除的标准工艺路线Header主键
     * @return 结果
     */
    @Override
    public int deleteApsStandardProcessRouteHeaderJobByIds(Long[] ids)
    {
        return apsStandardProcessRouteHeaderJobMapper.deleteApsStandardProcessRouteHeaderJobByIds(ids);
    }

    /**
     * 删除标准工艺路线Header信息
     * 
     * @param id 标准工艺路线Header主键
     * @return 结果
     */
    @Override
    public int deleteApsStandardProcessRouteHeaderJobById(Long id)
    {
        return apsStandardProcessRouteHeaderJobMapper.deleteApsStandardProcessRouteHeaderJobById(id);
    }

    @Override
    public boolean syncProcessRouteData(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) {
        JSONObject requestBody = new JSONObject();
        ResponseEntity<String> response = null;
        ApsWorkOrderJobLog jobLog = new ApsWorkOrderJobLog();
        String batchNum = "";
        try {
            // 设置请求头
            HttpHeaders headers = new HttpHeaders();
            headers.setContentType(MediaType.APPLICATION_JSON);
            // 设置请求体
            while (true) {
                batchNum = IdUtils.fastSimpleUUID();
                jobLog = new ApsWorkOrderJobLog();
                requestBody = new JSONObject();
                requestBody.put("PageIndex", pageIndex);
                requestBody.put("PageSize", pageSize);
                if(!StringUtils.isEmpty(orgCode)){
                    requestBody.put("OrgCode", orgCode);
                }
                // 创建HttpEntity对象
                HttpEntity<String> request = new HttpEntity<>(requestBody.toJSONString(), headers);
                // 发送POST请求
                response = restTemplate.postForEntity(getProcessRouteUrl, request, String.class);
                JSONObject responseBodyJson = JSONObject.parseObject(response.getBody());
                if (response.getStatusCode().is2xxSuccessful() && "200".equals(responseBodyJson.getString("status"))) {
                    JSONArray jsonArray = responseBodyJson.getJSONArray("data");
                    if (!jsonArray.isEmpty()) {
                        List<ApsStandardProcessRouteHeaderJob> headerList = new ArrayList<>();
                        List<ApsStandardProcessRouteLineJob> lineList = new ArrayList<>();
                        for (Object o : jsonArray) {
                            //o对象中的属性赋值给ApsBomHeaderJob对象
                            JSONObject routeHeader = (JSONObject) o;
                            JSONArray routeLines = routeHeader.getJSONArray("RoutingLines");
                            ApsStandardProcessRouteHeaderJob insertRouteHeader = new ApsStandardProcessRouteHeaderJob();
                            insertRouteHeader.setId(IdUtil.getSnowflakeNextId());
                            insertRouteHeader.setRouteId(routeHeader.getString("HID"));
                            insertRouteHeader.setItemCode(routeHeader.getString("HItemCode"));
                            insertRouteHeader.setVersion(routeHeader.getString("RoutingVersionCode"));
                            insertRouteHeader.setStartDate(DateUtils.parseDate(routeHeader.getString("HEffectiveDate")));
                            insertRouteHeader.setEndDate(DateUtils.parseDate(routeHeader.getString("HDisableDate")));
                            insertRouteHeader.setOrgCode(routeHeader.getString("HOrgCode"));
                            insertRouteHeader.setCreateBy(batchNum);
                            headerList.add(insertRouteHeader);
                            for(Object line : routeLines){
                                JSONObject lineJson = (JSONObject) line;
                                ApsStandardProcessRouteLineJob routeLine = new ApsStandardProcessRouteLineJob();
                                routeLine.setId(IdUtil.getSnowflakeNextId());
                                routeLine.setRouteId(lineJson.getString("HID"));
                                routeLine.setRouteNum(lineJson.getString("Sequence"));
                                routeLine.setRouteName(lineJson.getString("WorkCenterName"));
                                routeLine.setRouteCode(lineJson.getString("WorkCenterCode"));
                                routeLine.setStartDate(DateUtils.parseDate(lineJson.getString("LEffectiveDate")));
                                routeLine.setEndDate(DateUtils.parseDate(lineJson.getString("LDisableDate")));
                                routeLine.setOrgCode(lineJson.getString("LOrgCode"));
                                routeLine.setStandardTime(lineJson.getBigDecimal("StandardTime"));
                                routeLine.setCreateBy(batchNum);
                                lineList.add(routeLine);
                            }
                        }
                        List<ApsStandardProcessRouteHeaderJob> temp1 = new ArrayList<>();
                        for(int i=0;i<headerList.size();i++){
                            temp1.add(headerList.get(i));
                            if(temp1.size()>=20){
                                apsStandardProcessRouteHeaderJobMapper.insertProcessRouteHeaderBatch(temp1);
                                temp1 = new ArrayList<>();
                            }
                        }
                        List<ApsStandardProcessRouteLineJob> temp2 = new ArrayList<>();
                        for(int j=0;j<lineList.size();j++){
                            temp2.add(lineList.get(j));
                            if(temp2.size()>=20){
                                apsStandardProcessRouteLineJobMapper.insertProcessRouteLineBatch(temp2);
                                temp2 = new ArrayList<>();
                            }
                        }
                        jobLog.setRequestData(requestBody.toJSONString());
                        jobLog.setPageNum(Long.valueOf(pageIndex));
                        jobLog.setPageCount(Long.valueOf(pageSize));
                        jobLog.setCreateTime(DateUtils.getNowDate());
                        jobLog.setBizType("processRoute");
                        jobLog.setResult("header:"+headerList.size() + " line:"+lineList.size());
                        jobLog.setCreateBy(batchNum);
                        jobLogMapper.insertApsWorkOrderJobLog(jobLog);
                        log.info("标准工艺路线同步："+ JSON.toJSONString(jobLog));
                        pageIndex++;
                    }else{
                        break;
                    }
                }else{
                    jobLog.setRequestData(requestBody.toJSONString());
                    jobLog.setResponseData(response.getBody());
                    jobLog.setPageNum(Long.valueOf(pageIndex));
                    jobLog.setPageCount(Long.valueOf(pageSize));
                    jobLog.setCreateTime(DateUtils.getNowDate());
                    jobLog.setBizType("processRoute");
                    jobLog.setResult("error");
                    jobLog.setCreateBy(batchNum);
                    log.info("标准工艺路线同步："+ JSON.toJSONString(jobLog));
                    jobLogMapper.insertApsWorkOrderJobLog(jobLog);
                    break;
                }
            }
        }catch (Exception e){
            e.printStackTrace();
            jobLog.setRequestData(requestBody.toJSONString());
            jobLog.setResponseData(response.getBody());
            jobLog.setPageNum(Long.valueOf(pageIndex));
            jobLog.setPageCount(Long.valueOf(pageSize));
            jobLog.setCreateTime(DateUtils.getNowDate());
            jobLog.setBizType("processRoute");
            jobLog.setResult("error");
            jobLog.setCreateBy(batchNum);
            log.info("标准工艺路线同步："+ JSON.toJSONString(jobLog));
            jobLogMapper.insertApsWorkOrderJobLog(jobLog);
            return false;
        }
        return true;
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public boolean syncProcessRouteDataJob(Integer pageIndex, Integer pageSize, String orgCode, String itemCodeList) {
        try {

            apsStandardProcessRouteHeaderJobMapper.deleteProcessRouteHeaderJob();
            apsStandardProcessRouteLineJobMapper.deleteProcessRouteLineJob();
            boolean res = syncProcessRouteData(pageIndex, pageSize, orgCode, itemCodeList);
            if(!res){
                return false;
            }
            remoteCoreService.setProcessRouteDataToRedis(SecurityConstants.INNER);
            apsStandardProcessRouteHeaderJobMapper.deleteProcessRouteHeader();
            apsStandardProcessRouteLineJobMapper.deleteProcessRouteLine();
            apsStandardProcessRouteHeaderJobMapper.insertIntoProcessRouteHeader();
            apsStandardProcessRouteLineJobMapper.insertIntoProcessRouteLine();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return true;
    }
}