tld-consumer-9560/src/main/java/com/tld/service/impl/AskGoodsServiceImpl.java

package com.tld.service.impl;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.tld.excel.ExcelUtils;
import com.tld.mapper.AskGoodsMapper;
import com.tld.mapper.ErrorMapper;
import com.tld.model.AskGoods;
import com.tld.model.Error;
import com.tld.model.Inventory;
import com.tld.model.ReturRemoval;
import com.tld.service.AskGoodsService;
import com.tld.util.DateUtil;
import com.tld.util.HttpClientUtil;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletResponse;
import java.text.SimpleDateFormat;
import java.util.*;

@Service
public class AskGoodsServiceImpl implements AskGoodsService {

    @Autowired
    private AskGoodsMapper askGoodsMapper;
    //redis锁
    @Autowired
    private RedissonClient redissonClient;

    @Autowired
    private ErrorMapper errorMapper;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> addAskGoods(List<Map<String,Object>> mapList) {
        Map<String, Object> map = new HashMap<>();
        try{
            List<AskGoods> askGoodsList = new LinkedList<AskGoods>();

            for(Map<String,Object> jsonMap:mapList) {
                List<Map<String, Object>> list = (List) jsonMap.get("datalist");
                for (Map<String, Object> element : list) {
                    AskGoods ag = new AskGoods();
                   //父表
                    ag.setAskGoodsId(jsonMap.get("requestOrderId").toString());
                    ag.setUniqueCode(jsonMap.get("requestOrderNo").toString());
                    ag.setCompanyNumber(jsonMap.get("companyNo").toString());
                    ag.setSqrq(jsonMap.get("requestDate").toString());//申请日期
                    ag.setDepartmentId(jsonMap.get("useDepartment").toString());
                    ag.setSourceType(jsonMap.get("sourceType").toString());
                    ag.setMoveType(jsonMap.get("moveType").toString());

                   //子表
                    ag.setEntryNumber(element.get("entryNumber").toString());
                    ag.setProductionCode(element.get("prodOrderNo").toString());
                    ag.setMaterialId(element.get("materialId").toString());
                    ag.setWbs(element.get("WBS").toString());
                    ag.setMeasurementId(element.get("measUnitId").toString());
                    ag.setNum(element.get("orderCount").toString());

                    askGoodsList.add(ag);
                }
            }
            for(AskGoods askGoods : askGoodsList) {
                int count = askGoodsMapper.getAskGoods(askGoods);
                if (count != 0) {
                    askGoodsMapper.updateAskGoodsNum(askGoods);
                } else {
                    if (askGoodsMapper.getAskGoodsf(askGoods) == 0) {
                        askGoodsMapper.addAskGoodsf(askGoods);
                    }
                    askGoodsMapper.addAskGoods(askGoods);
                }
                askGoodsMapper.addAskGoodsLog(askGoods);
            }
            map.put("status", "0000");
            map.put("msg","成功");
        }catch (Exception e){
            e.printStackTrace();
            map.put("status", "0009");
            map.put("msg", "服务器请求异常，请稍后再试");
        }
        return map;
    }

    @Override
    public Map<String, Object> getAskGoodsfList(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            List<AskGoods> list = askGoodsMapper.getAskGoodsfList(askGoods);
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> getAskGoodsMaterial(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            List<AskGoods> list = askGoodsMapper.getAskGoodsMaterial(askGoods);
            List<String> scanNum = new LinkedList<>();
            for(AskGoods askGoods1 : list){
                askGoods1.setUniqueCode(askGoods.getUniqueCode());
                askGoods1.setAskGoodsId(askGoods.getAskGoodsId());
                scanNum.add(askGoodsMapper.getScanNum(askGoods1));//扫描总数
            }
            map.put("scanNum", scanNum);
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> getMaterialCk(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            List<Inventory> list = new LinkedList<>();
            for(Inventory inventory : askGoodsMapper.getMaterialCk(askGoods)){
                AskGoods askGoods1 = askGoodsMapper.getAsk(inventory);
                if(askGoods1 != null){
                    if(Integer.parseInt(askGoods1.getNum()) != Integer.parseInt(inventory.getAmount())){
                        list.add(inventory);
                    }
                } else {
                    list.add(inventory);
                }
            }
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> addAskGoodsVitrual(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            Map<String, Object> mapVal = askGoodsMapper.getScanIsNot(askGoods);
            if((Double.parseDouble(mapVal.get("inventoryNum").toString()) - Double.parseDouble(mapVal.get("virtualNum").toString())) == 0){
                map.put("msg", "500");
                map.put("errMsg", "已全部出库");
                return map;
            }
            Inventory inventory = askGoodsMapper.getInventory(askGoods); //库存数量
            AskGoods askGoods1 = askGoodsMapper.getAsknInfo(askGoods); //要货单数量
            int alreadyNum =  askGoodsMapper.getAskInfoNumVitrual(askGoods);//已扫描总数
            int inventoryAlready =  askGoodsMapper.getInventoryAlready(askGoods);//库存已扫描数量
            int inventorySurplus = Integer.parseInt(inventory.getAmount()) - inventoryAlready; //库存剩余数量
            int surplusNum = Integer.parseInt(askGoods1.getNum()) - alreadyNum; //剩余要扫描数量

            if(surplusNum >= inventorySurplus){
                askGoods.setNum(String.valueOf(inventorySurplus));
            } else {
                askGoods.setNum(String.valueOf(surplusNum));
            }
            askGoods.setStorageLocationCode(inventory.getStorageLocationCode());//库存编号
            askGoodsMapper.addAskGoodsVitrual(askGoods);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> OutOfLibrary(String uniqueCode, String type, String askGoodsId) {
        Map<String, Object> map = new HashMap<>();
        //redis并发锁
        RLock lock = redissonClient.getLock(uniqueCode);
        lock.lock();
        try{
            List<AskGoods> list = askGoodsMapper.getVirtualUniqueCode(uniqueCode, type, askGoodsId);
            for(AskGoods askGoods : list){
                Inventory inventory = askGoodsMapper.getInventory(askGoods);
                //如果出库库存等于虚拟表库存则删除此库存
                if(Integer.parseInt(askGoods.getNum()) == Integer.parseInt(inventory.getAmount())){
                    askGoodsMapper.deleteInventory(inventory);
                } else {
                    inventory.setAmount(askGoods.getNum());
                    askGoodsMapper.updateInventory(inventory);
                }
                String materialId = askGoodsMapper.getMaterialId(askGoods.getWllbCode());//查询物料id
                AskGoods askGoods1 = askGoodsMapper.getAskDetailed(askGoodsId, materialId);//查询要料申请单内容
                ReturRemoval returRemoval = new ReturRemoval()
                        .setMaterialId(materialId)
                        .setAskGoodsId(askGoodsId)
                        .setWbs(askGoods1.getWbs())
                        .setNum(askGoods.getNum())
                        .setEntryNumber(askGoods1.getEntryNumber())
                        .setAskId(askGoods1.getId())
                        .setStorageLocationCode(askGoods.getStorageLocationCode());
                askGoodsMapper.addRemoval(askGoods);//插入出库流水
                askGoodsMapper.deleteVirtual(askGoods.getId());//删除已出虚拟表库存
                askGoodsMapper.addReturnGsRemoval(returRemoval);//新增返回gs数据子表信息
                askGoodsMapper.updateOutNum(askGoods.getNum(), askGoodsId, materialId);//修改出库数量
            }
            //查询要货单父级信息
            AskGoods askGoods3 = askGoodsMapper.getAskDetailedF(askGoodsId);
            String removalCode = codeGenerateCk();
            ReturRemoval returRemoval1 = new ReturRemoval()
                    .setAskGoodsId(askGoods3.getAskGoodsId())
                    .setRemovalCode(removalCode)
                    .setSourceType(askGoods3.getSourceType())
                    .setMoveType(askGoods3.getMoveType());
            askGoodsMapper.addReturnGsRemovalF(returRemoval1);//新增返回gs数据父表信息
            map.put("data", removalCode);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        } finally {
            //释放锁
            lock.unlock();
        }
        return map;
    }

    /**
     * 出库回传
     * @param removalCode
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void plugOutRemoval(String removalCode) {
        try{
            List<Map<String, Object>> mapList = askGoodsMapper.plugOutRemoval(removalCode);
            if(mapList.size() >0 ) {
                JSONObject returnData = new JSONObject();

                JSONObject strJson = new JSONObject();
                //父表
                strJson.put("askGoodsId", mapList.get(0).get("askGoodsId").toString());//要货单id
                strJson.put("removalCode", mapList.get(0).get("removalCode").toString());//出库单编号
                strJson.put("sourceType", mapList.get(0).get("sourceType").toString());//来源类型
                strJson.put("moveType", mapList.get(0).get("moveType").toString());//移动类型
                //子表
                List<JSONObject> list = new LinkedList<>();
                for(Map<String,Object> map:askGoodsMapper.getRemovalz(mapList.get(0).get("askGoodsId").toString())) {
                    JSONObject BillItems = new JSONObject();
                    BillItems.put("entryNumber", map.get("entryNumber"));//分录ID
//                    BillItems.put("PurOrderID", returnWarehousing.getOrderNumber());//采购单id
//                    BillItems.put("PurOrderItemID", returnWarehousing.getEntryNumber());//采购订单明细ID
                    BillItems.put("Material", map.get("materialId"));//物料id
                    BillItems.put("Quantity", map.get("num"));//数量
                    BillItems.put("FlexField1", map.get("wbs"));//wbs
                    BillItems.put("FlexField1Code", " ");//WBS编号
                    BillItems.put("FlexField1Name", " ");//WBS名称

                    list.add(BillItems);
                }
                strJson.put("BillItems", list);
                returnData.put("strJson", JSON.toJSONString(strJson));
                System.out.println(returnData);
                HttpClientUtil httpClientUtil1 = new HttpClientUtil();
                Map<String, Object> result = httpClientUtil1.doPost("http://localhost:3339/api/Values", returnData);
                if (Integer.parseInt(result.get("msg").toString()) != 200) {
                    //如果失败存入报错信息跟数据
                    Error error = new Error()
                            .setErrorInfo(result.get("data").toString())
                            .setUrl("http://localhost:44303/api/Values")
                            .setDataVal(strJson.toJSONString());
                    errorMapper.addError(error);
                }
            }
//            Calendar cal = Calendar.getInstance();
//            int year = cal.get(Calendar.YEAR);
//            int month = cal.get(Calendar.MONTH) + 1;
//            int day = cal.get(Calendar.DATE) ;
//            map.put("child", askGoodsMapper.getRemovalz(map.get("askGoodsId").toString()));
//            map.put("isNotRed", "0");
//            map.put("year", year);
//            map.put("month", month);
//            map.put("time", year + "-" + month + "-" + day);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    @Override
    public Map<String, Object> getRemoval(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            //查询数据
            PageHelper.startPage(askGoods.getPage(), askGoods.getLimit());
            PageInfo<AskGoods> list = new PageInfo<>(askGoodsMapper.getRemoval(askGoods));
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public void export(AskGoods askGoods, HttpServletResponse response) {
        try{
            //导出数据汇总
            List<List<Object>> sheetDataList = new ArrayList<>();
            //表头数据
            List<Object> head = Arrays.asList("物料名称", "供应商名称", "连翻号", "类型", "出库用户", "领用部门", "库位名称", "出库日期", "出库数量");
            //查询数据
            PageHelper.startPage(askGoods.getPage(), askGoods.getLimit());
            PageInfo<Map<String, Object>> list = new PageInfo<>(askGoodsMapper.export(askGoods));
            sheetDataList.add(head);
            for(Map<String, Object> userMap : list.getList()){
                List<Object> listSheet = new ArrayList<>();
                for(String key: userMap.keySet()){
                    listSheet.add(userMap.get(key));
                }
                sheetDataList.add(listSheet);
            }
            //当前时间
            Date time = new Date();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMddHHmmss");
            ExcelUtils.export(response, "出库流水数据导出" + sdf.format(time), sheetDataList);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    @Override
    public Map<String, Object> getAskGoodsVitrual(String uniqueCode, String type) {
        Map<String, Object> map = new HashMap<>();
        try{
            List<AskGoods> list = askGoodsMapper.getAskGoodsVitrual(uniqueCode, type);
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> delAskGoodsVitrual(String id, String type) {
        Map<String, Object> map = new HashMap<>();
        try{
            askGoodsMapper.delAskGoodsVitrual(id, type);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> getGoodsHalf(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            //查询数据
            PageHelper.startPage(askGoods.getPage(), askGoods.getLimit());
            PageInfo<AskGoods> list = new PageInfo<>(askGoodsMapper.getGoodsHalf(askGoods));
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public Map<String, Object> getRemovalHalfProduct(AskGoods askGoods) {
        Map<String, Object> map = new HashMap<>();
        try{
            //查询数据
            PageHelper.startPage(askGoods.getPage(), askGoods.getLimit());
            PageInfo<AskGoods> list = new PageInfo<>(askGoodsMapper.getRemovalHalfProduct(askGoods));
            map.put("data", list);
            map.put("msg", "200");
        }catch (Exception e){
            e.printStackTrace();
            map.put("msg", "500");
            map.put("errMsg", "失败");
        }
        return map;
    }

    @Override
    public void getRemovalHalfProductExcel(AskGoods askGoods, HttpServletResponse response) {
        try{
            //导出数据汇总
            List<List<Object>> sheetDataList = new ArrayList<>();
            //表头数据
            List<Object> head = Arrays.asList("物料名称", "出库数量", "用户名称", "出库时间", "要货单ID", "领用部门");
            //查询数据
            PageHelper.startPage(askGoods.getPage(), askGoods.getLimit());
            PageInfo<Map<String, Object>> list = new PageInfo<>(askGoodsMapper.getRemovalHalfProductExcel(askGoods));
            sheetDataList.add(head);
            for(Map<String, Object> userMap : list.getList()){
                List<Object> listSheet = new ArrayList<>();
                for(String key: userMap.keySet()){
                    listSheet.add(userMap.get(key));
                }
                sheetDataList.add(listSheet);
            }
            //当前时间
            Date time = new Date();
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMddHHmmss");
            ExcelUtils.export(response, "出库流水数据导出" + sdf.format(time), sheetDataList);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 出库单生成
     * @return
     */
    public String codeGenerateCk(){
        StringBuilder stringBuilder = new StringBuilder("CK");
        Date date = new Date();
        SimpleDateFormat sdf = new SimpleDateFormat("yyMMdd");
        stringBuilder.append(sdf.format(date));
        int count = askGoodsMapper.getReturnRemovalCount();
        for(int i = 0; i < 4 - (count + "").length(); i++){
            stringBuilder.append("0");
        }
        return (stringBuilder.append(count + 1)).toString();
    }
}