parent
6b02c081a3
commit
7bb5caaf5d
@ -0,0 +1,92 @@ |
||||
package com.cweb.controller; |
||||
|
||||
import com.hfkj.common.exception.ErrorCode; |
||||
import com.hfkj.common.exception.ErrorHelp; |
||||
import com.hfkj.common.exception.SysCode; |
||||
import com.hfkj.common.utils.ResponseMsgUtil; |
||||
import com.hfkj.entity.BsStore; |
||||
import com.hfkj.entity.BsStoreCid; |
||||
import com.hfkj.model.ResponseData; |
||||
import com.hfkj.service.BsStoreCidService; |
||||
import com.hfkj.service.BsStoreService; |
||||
import io.swagger.annotations.Api; |
||||
import io.swagger.annotations.ApiOperation; |
||||
import org.slf4j.Logger; |
||||
import org.slf4j.LoggerFactory; |
||||
import org.springframework.stereotype.Controller; |
||||
import org.springframework.web.bind.annotation.RequestBody; |
||||
import org.springframework.web.bind.annotation.RequestMapping; |
||||
import org.springframework.web.bind.annotation.RequestMethod; |
||||
import org.springframework.web.bind.annotation.ResponseBody; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.Date; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* @author sum1dream |
||||
*/ |
||||
@Controller |
||||
@RequestMapping(value = "/storeCid") |
||||
@Api(value = "门店CID") |
||||
public class BsStoreCidController { |
||||
|
||||
private static Logger log = LoggerFactory.getLogger(BsStoreCidController.class); |
||||
|
||||
@Resource |
||||
private BsStoreCidService bsStoreCidService; |
||||
|
||||
@Resource |
||||
private BsStoreService bsStoreService; |
||||
|
||||
@RequestMapping(value="/connectStoreCid",method = RequestMethod.POST) |
||||
@ResponseBody |
||||
@ApiOperation(value = "连接门店和CID") |
||||
public ResponseData connectStoreCid(@RequestBody BsStoreCid storeCid) { |
||||
try { |
||||
|
||||
if (storeCid == null |
||||
|| storeCid.getCid() == null |
||||
|| storeCid.getStoreId() == null |
||||
) { |
||||
log.error("configStore error!","参数错误"); |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); |
||||
} |
||||
|
||||
|
||||
BsStore store = bsStoreService.getStoreById(storeCid.getStoreId()); |
||||
|
||||
if (store == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "当前门店不存在！"); |
||||
} |
||||
|
||||
Map<String , Object> map = new HashMap<>(); |
||||
map.put("storeId" , storeCid.getStoreId()); |
||||
|
||||
BsStoreCid bsStoreCid = bsStoreCidService.findByMap(map); |
||||
|
||||
if (bsStoreCid == null) { |
||||
bsStoreCid = new BsStoreCid(); |
||||
bsStoreCid.setCid(storeCid.getCid()); |
||||
bsStoreCid.setStoreId(store.getId()); |
||||
bsStoreCid.setStoreNo(store.getStoreNo()); |
||||
bsStoreCid.setStoreName(store.getName()); |
||||
bsStoreCid.setCreateTime(new Date()); |
||||
bsStoreCid.setUpdateTime(new Date()); |
||||
bsStoreCidService.insertStoreCid(bsStoreCid); |
||||
} else { |
||||
bsStoreCid.setCid(storeCid.getCid()); |
||||
bsStoreCid.setUpdateTime(new Date()); |
||||
bsStoreCidService.editStoreCid(bsStoreCid); |
||||
} |
||||
|
||||
return ResponseMsgUtil.success("操作成功"); |
||||
|
||||
} catch (Exception e) { |
||||
log.error(e.getMessage(), e); |
||||
return ResponseMsgUtil.exception(e); |
||||
} |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,55 @@ |
||||
package com.hfkj.service; |
||||
|
||||
import com.alibaba.fastjson.JSONObject; |
||||
import com.hfkj.entity.BsStoreCid; |
||||
|
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* @author sum1dream |
||||
*/ |
||||
public interface BsStoreCidService { |
||||
|
||||
/** |
||||
* @Author Sum1Dream |
||||
* @Name insertStoreCid |
||||
* @Description // 新增门店cid内容
|
||||
* @Date 15:14 2023/6/14 |
||||
* @Param [storeCid] |
||||
* @Return void |
||||
*/ |
||||
void insertStoreCid(BsStoreCid storeCid); |
||||
|
||||
|
||||
/** |
||||
* @Author Sum1Dream |
||||
* @Name editStoreCid |
||||
* @Description // 编辑门店cid内容
|
||||
* @Date 15:15 2023/6/14 |
||||
* @Param [storeCid] |
||||
* @Return void |
||||
*/ |
||||
void editStoreCid(BsStoreCid storeCid); |
||||
|
||||
/** |
||||
* @Author Sum1Dream |
||||
* @Name findByMap |
||||
* @Description // 查询门店CID内容
|
||||
* @Date 15:40 2023/6/14 |
||||
* @Param [map] |
||||
* @Return com.hfkj.entity.BsStoreCid |
||||
*/ |
||||
BsStoreCid findByMap(Map<String , Object> map); |
||||
|
||||
/** |
||||
* @Author Sum1Dream |
||||
* @Name storePush |
||||
* @Description // 门店语音推送
|
||||
* @Date 16:11 2023/6/14 |
||||
* @Param [object] |
||||
* @Return void |
||||
*/ |
||||
void storePush(JSONObject object); |
||||
|
||||
|
||||
} |
||||
@ -0,0 +1,96 @@ |
||||
package com.hfkj.service.impl; |
||||
|
||||
import com.alibaba.fastjson.JSONObject; |
||||
import com.hfkj.common.exception.ErrorCode; |
||||
import com.hfkj.common.exception.ErrorHelp; |
||||
import com.hfkj.common.exception.SysCode; |
||||
import com.hfkj.dao.BsStoreCidMapper; |
||||
import com.hfkj.entity.BsStoreCid; |
||||
import com.hfkj.entity.BsStoreCidExample; |
||||
import com.hfkj.service.BsStoreCidService; |
||||
import com.hfkj.tts.HWYunSisService; |
||||
import com.hfkj.unipush.UniPushService; |
||||
import org.apache.commons.collections4.MapUtils; |
||||
import org.apache.commons.lang3.StringUtils; |
||||
import org.springframework.stereotype.Service; |
||||
|
||||
import javax.annotation.Resource; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
|
||||
/** |
||||
* @author sum1dream |
||||
*/ |
||||
@Service("bsStoreCidService") |
||||
public class BsStoreCidServiceImpl implements BsStoreCidService { |
||||
|
||||
@Resource |
||||
private BsStoreCidMapper bsStoreCidMapper; |
||||
|
||||
@Override |
||||
public void insertStoreCid(BsStoreCid storeCid) { |
||||
bsStoreCidMapper.insert(storeCid); |
||||
} |
||||
|
||||
@Override |
||||
public void editStoreCid(BsStoreCid storeCid) { |
||||
bsStoreCidMapper.updateByPrimaryKey(storeCid); |
||||
} |
||||
|
||||
@Override |
||||
public BsStoreCid findByMap(Map<String, Object> map) { |
||||
|
||||
BsStoreCidExample example = new BsStoreCidExample(); |
||||
BsStoreCidExample.Criteria criteria = example.createCriteria(); |
||||
|
||||
if (MapUtils.getLong(map, "storeId") != null) { |
||||
criteria.andStoreIdEqualTo(MapUtils.getLong(map, "storeId")); |
||||
} |
||||
|
||||
if (MapUtils.getLong(map, "storeNo") != null) { |
||||
criteria.andStoreNoEqualTo(MapUtils.getLong(map, "storeNo")); |
||||
} |
||||
|
||||
if (StringUtils.isNotBlank(MapUtils.getString(map, "storeName"))) { |
||||
criteria.andStoreNameLike("%"+MapUtils.getString(map, "storeName")+"%"); |
||||
} |
||||
|
||||
List<BsStoreCid> list = bsStoreCidMapper.selectByExample(example); |
||||
|
||||
if (list.size() > 0) { |
||||
return list.get(0); |
||||
} |
||||
|
||||
return null; |
||||
} |
||||
|
||||
@Override |
||||
public void storePush(JSONObject object) { |
||||
if (object == null || |
||||
object.getBigDecimal("price") == null || |
||||
object.getLong("storeId") == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.REQ_PARAMS_ERROR, ""); |
||||
} |
||||
|
||||
Map<String, Object> map = new HashMap<>(); |
||||
map.put("storeId", object.getLong("storeId")); |
||||
BsStoreCid bsStoreCid = findByMap(map); |
||||
|
||||
if (bsStoreCid == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "不存在推送关系"); |
||||
} |
||||
// 获取语音播报地址
|
||||
String auditPath = HWYunSisService.ttsCustomDemo(object); |
||||
|
||||
if (auditPath == null) { |
||||
throw ErrorHelp.genException(SysCode.System, ErrorCode.COMMON_ERROR, "生成语音失败"); |
||||
} |
||||
|
||||
object.put("cid", bsStoreCid.getCid()); |
||||
object.put("body", auditPath); |
||||
UniPushService.pushToSingleByCid(object); |
||||
|
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue