package com.ld.igds;

import com.bstek.bdf2.core.orm.hibernate.HibernateDao;
import com.ld.igds.common.CoreCommonService;
import com.ld.igds.inout.InoutConstant;
import com.ld.igds.models.InoutRecord;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.time.DateUtils;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Component
public class TestService extends HibernateDao {

    @Autowired
    private CoreCommonService commonService;


    private void initRecordCurStorage2(List<InoutRecord> listData) {
        if (null == listData || listData.isEmpty()) return;

        log.info("----------------开始执行重置出入库信息--------------");

        //更新实时库存
        Session session = this.getSessionFactory().openSession();
        try {
            InoutRecord perData;
            InoutRecord curData;
            for (int i = 1; i < listData.size(); i++) {
                perData = listData.get(i - 1);
                curData = listData.get(i);
                if ("IN".equals(perData.getType())) {
                    curData.setCurStorage(perData.getCurStorage() + perData.getSettleWeight());
                } else if ("OUT".equals(perData.getType())) {
                    curData.setCurStorage(perData.getCurStorage() - perData.getSettleWeight());
                } else if ("OVER".equals(perData.getType())) {
                    curData.setCurStorage(perData.getCurStorage() + perData.getSettleWeight());
                } else if ("LOSS".equals(perData.getType())) {
                    curData.setCurStorage(perData.getCurStorage() - perData.getSettleWeight());
                } else {
                    curData.setCurStorage(perData.getCurStorage());
                }
                listData.set(i, curData);

                //更新庫存
                String updateHql = "update " + InoutRecord.class.getName() + " set curStorage=:curStorage where companyId=:companyId and id=:id";
                Query query = session.createQuery(updateHql);
                query.setDouble("curStorage", curData.getCurStorage());
                query.setString("companyId", curData.getCompanyId());
                query.setString("id", curData.getId());
                query.executeUpdate();
                log.info("----------------DEPOTID={}----CUR={}----------", curData.getDepotId(), curData.getCurStorage());
            }

            log.info("----------------重置完成--------------");

        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            session.clear();
            session.close();
        }
    }


    public void initRecordCurStorageOUT(String depotId, String startDate) {
        try {
            Date start = DateUtils.parseDate(startDate, "yyyy-MM-dd");
            //获取所有的详细

            String hql = " from " + InoutRecord.class.getName()
                    + " where progress=:progress and recordStatus <>:statusError and recordStatus <>:statusDel and depotId=:depotId"
                    + " and completeTime > :start and (type =:typOut or type=:typeOver) "
                    + " order by completeTime";

            Map<String, Object> param = new HashMap<>();
            param.put("progress", InoutConstant.PROGRESS_RECORD);
            param.put("statusError", InoutConstant.RECORD_STATUS_ERROR);
            param.put("statusDel", InoutConstant.RECORD_STATUS_DEL);
            param.put("depotId", depotId);
            param.put("start", start);
            param.put("typOut", InoutConstant.TYPE_OUT);
            param.put("typeOver", "OVER");

            List<InoutRecord> listData = this.query(hql, param);


            if (null == listData || listData.isEmpty()) return;

            //更新出入库列表
            this.initRecordCurStorage2(listData);

            InoutRecord lastData = listData.get(listData.size()-1);

            commonService.updateDepotStorage(lastData.getCompanyId(), lastData.getDepotId(), lastData.getCurStorage() - lastData.getSettleWeight());

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void initRecordCurStorageIN(String depotId, String startDate) {
        try {
            Date start = DateUtils.parseDate(startDate, "yyyy-MM-dd");
            //获取所有的详细
            String hql = " from " + InoutRecord.class.getName()
                    + " where progress=:progress and recordStatus <>:statusError and recordStatus <>:statusDel and depotId=:depotId"
                    + " and completeTime > :start and (type =:typIn or type=:typeLOss) "
                    + " order by completeTime";

            Map<String, Object> param = new HashMap<String, Object>();
            param.put("progress", InoutConstant.PROGRESS_RECORD);
            param.put("statusError", InoutConstant.RECORD_STATUS_ERROR);
            param.put("statusDel", InoutConstant.RECORD_STATUS_DEL);
            param.put("depotId", depotId);
            param.put("start", start);
            param.put("typIn", InoutConstant.TYPE_IN);
            param.put("typeLOss", "LOSS");

            List<InoutRecord> listData = this.query(hql, param);

            if (null == listData || listData.isEmpty()) return;

            this.initRecordCurStorage2(listData);

            InoutRecord lastData = listData.get(listData.size() - 1);

            // 重新计算客户完成量
            commonService.updateDepotStorage(lastData.getCompanyId(), lastData.getDepotId(), lastData.getCurStorage() + lastData.getSettleWeight());

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

}