package com.glxp.api.service.collect; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.github.pagehelper.PageHelper; import com.glxp.api.common.res.BaseResponse; import com.glxp.api.dao.collect.IoCollectLedGroupMapper; import com.glxp.api.entity.collect.IoCollectLedGroup; import com.glxp.api.entity.collect.IoCollectOrderBiz; import com.glxp.api.entity.thrsys.CodeRel; import com.glxp.api.enums.led.LedColorStatusEnum; import com.glxp.api.exception.JsonException; import com.glxp.api.req.collect.CollectLedGroupRequest; import com.glxp.api.req.collect.LedGroupRequest; import com.glxp.api.res.collect.IoCollectLedGroupResponse; import com.glxp.api.util.OkHttpCli; import org.springframework.stereotype.Service; import javax.annotation.Resource; import java.util.ArrayList; import java.util.Collections; import java.util.List; /** * @author : zhuzhu * @date : 2024/12/30 10:47 * @modyified By : */ @Service public class IoCollectLedGroupService extends ServiceImpl { @Resource IoCollectLedGroupMapper ioCollectLedGroupMapper; @Resource private OkHttpCli okHttpCli; public List filterList(CollectLedGroupRequest collectLedGroupRequest) { if (collectLedGroupRequest == null) { return Collections.emptyList(); } if (collectLedGroupRequest.getPage() != null) { int offset = (collectLedGroupRequest.getPage() - 1) * collectLedGroupRequest.getLimit(); PageHelper.offsetPage(offset, collectLedGroupRequest.getLimit()); } return ioCollectLedGroupMapper.filterList(collectLedGroupRequest); } public BaseResponse openLed(List collectOrderBizs) { LedGroupRequest ledGroupRequest = new LedGroupRequest(); for (IoCollectOrderBiz collectOrderBiz : collectOrderBizs){ IoCollectLedGroup one = getOne(new LambdaQueryWrapper().eq(IoCollectLedGroup::getRelId, collectOrderBiz.getRelId())); if (one == null){ throw new JsonException(500,"当前产品未绑定灯组"); } CollectLedGroupRequest collectLedGroupRequest = new CollectLedGroupRequest(); collectLedGroupRequest.setMac(one.getMac()); collectLedGroupRequest.setTimeout(one.getTimeout()); if (one.getLedMode()){ collectLedGroupRequest.setLedmode(1); }else { collectLedGroupRequest.setLedmode(0); } collectLedGroupRequest.setLednum(setLedNum(one)); ledGroupRequest.getData().add(collectLedGroupRequest); } String json = JSONUtil.toJsonStr(ledGroupRequest); String result = okHttpCli.doPostJson( "http://192.168.0.166:9099/wms/associate/lighttagsled", json); BaseResponse response = JSONObject.parseObject(result, new TypeReference>() { }); return response; } private Integer setLedNum(IoCollectLedGroup ioCollectLedGroup) { if (!ioCollectLedGroup.getRed()) { return LedColorStatusEnum.RED_FALSE.getReturnValue(); } if (!ioCollectLedGroup.getOrange()) { return LedColorStatusEnum.ORANGE_FALSE.getReturnValue(); } if (!ioCollectLedGroup.getBlue()) { return LedColorStatusEnum.BLUE_FALSE.getReturnValue(); } return LedColorStatusEnum.DEFAULT.getReturnValue(); } }