package com.zy.asrs.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.zy.asrs.entity.WrkDetl;
import com.zy.asrs.entity.WrkDetlLog;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.WrkMastLog;
import com.zy.asrs.mapper.WrkDetlLogMapper;
import com.zy.asrs.mapper.WrkDetlMapper;
import com.zy.asrs.mapper.WrkMastLogMapper;
import com.zy.asrs.mapper.WrkMastMapper;
import com.zy.asrs.service.WrkArchiveToLogService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.text.MessageFormat;
import java.util.List;

@Slf4j
@Service("wrkArchiveToLog")
public class WrkArchiveToLogServiceImpl implements WrkArchiveToLogService {

    @Autowired
    private WrkMastLogMapper wrkMastLogMapper;
    @Autowired
    private WrkDetlLogMapper wrkDetlLogMapper;
    @Autowired
    private WrkMastMapper wrkMastMapper;
    @Autowired
    private WrkDetlMapper wrkDetlMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void archiveMastAndDetlToLogThenDeleteCurrent(WrkMast wrkMast) {
        boolean printLog = !Cools.isEmpty(wrkMast)
                && Long.valueOf(30L).equals(wrkMast.getWrkSts())
                && "Y".equalsIgnoreCase(wrkMast.getFullPlt());

        Integer wrkNo = wrkMast.getWrkNo();
        boolean wrkMastLogSaved = wrkMastLogMapper.save(wrkNo) > 0;
        if (!wrkMastLogSaved) {
            log.error(MessageFormat.format("保存工作历史档[workNo={0}]失败", wrkNo));
        }
        int num = 0;
        List<WrkDetl> detls = wrkDetlMapper.selectByWrkNo(wrkNo);

        for (WrkDetl d : detls) {
            WrkDetlLog detlLog = new WrkDetlLog(d);
            num += wrkDetlLogMapper.insert(detlLog);
        }
        boolean wrkDetlLogSaved = num > 0;
//        boolean wrkDetlLogSaved = wrkDetlLogMapper.save(wrkNo) > 0;
        if (!wrkDetlLogSaved) {
            log.error(MessageFormat.format("保存工作明细历史档[workNo={0}]失败", wrkNo));
        }

        EntityWrapper<WrkMastLog> mastLogW = new EntityWrapper<>();
        mastLogW.eq("wrk_no", wrkNo);
        mastLogW.eq("io_time", wrkMast.getIoTime());
        int mastCount = wrkMastLogMapper.selectCount(mastLogW);
        EntityWrapper<WrkDetlLog> detlLogW = new EntityWrapper<>();
        detlLogW.eq("wrk_no", wrkNo);
        detlLogW.eq("io_time", wrkMast.getIoTime());
        int detlCount = wrkDetlLogMapper.selectCount(detlLogW);
        boolean wrkMastDeleted =false;
        boolean wrkDetlDeleted =false;
        if (mastCount > 0 && detlCount > 0) {
             wrkMastDeleted = wrkMastMapper.deleteById(wrkNo) > 0;
            if (!wrkMastDeleted) {
                log.error(MessageFormat.format("删除工作主档[workNo={0}]失败", wrkNo));
            }
             wrkDetlDeleted = wrkDetlMapper.delete(new EntityWrapper<WrkDetl>().eq("wrk_no", wrkNo)) > 0;
            if (!wrkDetlDeleted) {
                log.error(MessageFormat.format("删除工作明细档[workNo={0}]失败", wrkNo));
            }
        }
        if (printLog) {
            JSONObject detlJson = new JSONObject(true);
            detlJson.put("service", "WrkArchiveToLogService");
            detlJson.put("wrkNo", wrkNo);
            detlJson.put("wrkDetls", JSON.toJSON(detls));
            detlJson.put("wrkMast", (JSONObject) JSON.toJSON(wrkMast));
            detlJson.put("wrkMastDeleted", wrkMastDeleted);
            detlJson.put("wrkDetlDeleted", wrkDetlDeleted);
            log.info(detlJson.toJSONString());
        }
    }

}