iamberry-common-parent/watero-rst-service/src/main/java/com/iamberry/rst/service/cm/RepairServiceImpl.java

package com.iamberry.rst.service.cm;

import com.iamberry.rst.core.cm.ClosedFitting;
import com.iamberry.rst.core.cm.ClosedProdcue;
import com.iamberry.rst.core.cm.Repair;
import com.iamberry.rst.faces.cm.RepairService;
import com.iamberry.rst.service.cm.mapper.ClosedFittingMapper;
import com.iamberry.rst.service.cm.mapper.ClosedProdcueMapper;
import com.iamberry.rst.service.cm.mapper.RepairMapper;
import org.apache.commons.lang.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

import java.util.List;

/**
 * 维修Service
 * Created by liuzhiwei on 2017/11/8.
 */
@Service
public class RepairServiceImpl implements RepairService {

    @Autowired
    private RepairMapper repairMapper;
    @Autowired
    private ClosedProdcueMapper closedProdcueMapper;
    @Autowired
    private ClosedFittingMapper closedFittingMapper;

    @Transactional
    @Override
    public Integer updateRepairInfo(Repair repair, String closedProducts, String closedFittings) {
        int productNum = 1;
        int fittingNum = 1;
        List<ClosedProdcue> produceList = new ArrayList<ClosedProdcue>();
        List<ClosedFitting> fittingList = new ArrayList<ClosedFitting>();
        if (StringUtils.isNotEmpty(closedProducts)) {
            ClosedProdcue closedProdcue = new ClosedProdcue();
            closedProdcue.setRelationId(repair.getRepairId());
            closedProdcue.setClosedProdcueType(4);
            //删除原有寄回产品
            int delNum = closedProdcueMapper.deleteProduce(closedProdcue);
            //去掉最后一个","
            closedProducts = closedProducts.substring(0,closedProducts.length()-1);
            String[] products = closedProducts.split(",");
            for (int i = 0;i < products.length;i++) {
                String[] colors = products[i].split(":");
                ClosedProdcue prodcue = new ClosedProdcue();
                prodcue.setRelationId(repair.getRepairId());
                prodcue.setClosedProdcueType(4);
                prodcue.setProductId(Integer.parseInt(colors[0]));
                prodcue.setColorId(Integer.parseInt(colors[1]));
                prodcue.setClosedProdcueNumber(Integer.parseInt(colors[2]));
                produceList.add(prodcue);
            }
            //批量添加寄回产品
            productNum = closedProdcueMapper.insert(produceList);
        }
        if (StringUtils.isNotEmpty(closedFittings)) {
            ClosedFitting closedFitting = new ClosedFitting();
            closedFitting.setRelationId(repair.getRepairId());
            closedFitting.setClosedFittingType(4);
            //删除原有寄回配件信息
            int delNum = closedFittingMapper.deleteFitting(closedFitting);
            closedFittings = closedFittings.substring(0,closedFittings.length()-1);
            String[] fittings = closedFittings.split(",");
            for (int i = 0;i < fittings.length;i++) {
                String[] fitting = fittings[i].split(":");
                ClosedFitting cFitting = new ClosedFitting();
                cFitting.setRelationId(repair.getRepairId());
                cFitting.setClosedFittingType(4);
                cFitting.setProductId(Integer.parseInt(fitting[0]));
                cFitting.setFittingsId(Integer.parseInt(fitting[1]));
                cFitting.setClosedFittingNumber(Integer.parseInt(fitting[2]));
                fittingList.add(cFitting);
            }
            //批量添加寄回配件
            fittingNum = closedFittingMapper.insert(fittingList);
        }

        int num = repairMapper.updateRepairInfo(repair);
        if (num > 0 && productNum > 0 && fittingNum > 0) {
            return 1;
        } else {
            return 0;
        }
    }

    @Override
    public List<Repair> listSynchronizingRepair(Repair repair) {
        return repairMapper.listSynchronizingRepair(repair);
    }

    @Override
    public Repair getRepair(Repair repair) {
        return repairMapper.getRepairInfo(repair);
    }
}