package com.yc.api.controller;
|
|
import com.alibaba.fastjson.JSON;
|
import com.yc.action.BaseAction;
|
import com.yc.action.grid.GTGrid;
|
import com.yc.action.grid.GridUtils;
|
import com.yc.api.bean.CartEntity;
|
import com.yc.api.bean.MatGroupEntity;
|
import com.yc.api.bean.*;
|
import com.yc.api.service.QrServiceIfc;
|
import com.yc.entity.DataSourceEntity;
|
import com.yc.exception.ApplicationException;
|
import com.yc.exception.CallBackMessage;
|
import com.yc.factory.FactoryBean;
|
import com.yc.multiData.MultiDataSource;
|
import com.yc.multiData.SpObserver;
|
import com.yc.open.mutual.controller.MutualController;
|
import com.yc.sdk.jedis.RedisKey;
|
import com.yc.sdk.shopping.action.api.ShopCcCode;
|
import com.yc.sdk.shopping.entity.*;
|
import com.yc.sdk.shopping.service.*;
|
import com.yc.sdk.shopping.service.PrepaidDeposit.PrepaidDepositIfc;
|
import com.yc.sdk.shopping.service.imagedata.ShoppingImageDataIfc;
|
import com.yc.sdk.shopping.service.register.AccountIfc;
|
import com.yc.sdk.shopping.service.share.ShareIfc;
|
import com.yc.sdk.shopping.util.HtmlUtil;
|
import com.yc.sdk.shopping.util.SettingKey;
|
import com.yc.service.BaseService;
|
import com.yc.service.grid.GridServiceIfc;
|
import com.yc.utils.SessionKey;
|
import org.apache.commons.lang.text.StrBuilder;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.dao.EmptyResultDataAccessException;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.context.request.async.WebAsyncTask;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import javax.servlet.http.HttpSession;
|
import java.util.*;
|
import java.util.concurrent.Callable;
|
import java.util.concurrent.TimeUnit;
|
import java.util.regex.Matcher;
|
import java.util.regex.Pattern;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* 扫码
|
*/
|
@RestController
|
public class QrCodeController extends BaseAction {
|
protected final Logger log = LoggerFactory.getLogger(this.getClass());
|
@Autowired
|
CartIfc cartIfc;
|
@Autowired
|
QrServiceIfc qrServiceIfc;
|
@Autowired
|
ShoppingImageDataIfc imgData;
|
@Autowired
|
SettingIfc settingIfc;
|
|
// 价格
|
@Autowired
|
MatPriceIfc matPriceIfc;
|
|
// 货币
|
@Autowired
|
CurrencyIfc currencyIfc;
|
|
// 商品资料
|
@Autowired
|
MatCodeIfc matCodeIfc;
|
|
// 商品附加图片信息
|
@Autowired
|
MatCodeImageIfc matCodeImageIfc;
|
|
// 商品选项
|
@Autowired
|
MatOptionIfc matOptionIfc;
|
|
|
// 消费积份
|
@Autowired
|
MatPointsIfc matPointsIfc;
|
|
// 商品促销活动关联表
|
@Autowired
|
MatDiscountIfc matDiscountIfc;
|
|
// 选项
|
@Autowired
|
MatComponentIfc matComponentIfc;
|
|
// 显示分享信息
|
@Autowired
|
ShareIfc shareIfc;
|
|
// 选项属性
|
@Autowired
|
MatAttrIfc matAttrIfc;
|
//优惠劵
|
@Autowired
|
CouponIfc couponIfc;
|
|
//预付订金分组
|
@Autowired
|
PrepaidDepositIfc prepaidDepositIfc;
|
|
@Autowired
|
AccountIfc accountIfc;
|
@Autowired
|
private GridServiceIfc gridService;
|
@Autowired
|
ThreadPoolTaskExecutor threadPoolExecutor;
|
@Autowired
|
ShoppingImageDataIfc shoppingImageDataIfc;
|
|
/**
|
* 获取清单
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/cartList.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object getCartList(String docCode, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
String dbid=request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"";
|
SpObserver.setDBtoInstance("_" +dbid );
|
String hostUrl = SettingKey.getHostUrlForImage(request);
|
final List<com.yc.api.bean.CartEntity> cartList = qrServiceIfc.getCartList(request.getSession().getAttribute(SessionKey.USERCODE) + "", docCode);
|
// cartList.stream().map(x -> {
|
// x.setPhotoPath(imgData.getImageUrl(x.getPhotoPath(), 120,
|
// 120, false,
|
// false, request));
|
// return x;
|
// }).collect(Collectors.toList());
|
cartList.stream().forEach(x -> {
|
x.setPhotoPath(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
x.setPhotoPathUrl(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
});
|
//合并相同商品，输出一个
|
final List<com.yc.api.bean.CartEntity> newCartList = new ArrayList<>();
|
String matCode="";
|
Iterator<CartEntity> iterator = cartList.iterator();
|
while (iterator.hasNext()) {
|
CartEntity cartEntity = iterator.next();
|
com.yc.api.bean.CartEntity cart=new com.yc.api.bean.CartEntity();
|
BeanUtils.copyProperties(cartEntity,cart);
|
double totalAmount=StringUtils.isNotBlank(cart.getAmount())?Double.parseDouble(cart.getAmount()):0;//合并总价
|
double totalQuantity=cart.getQuantity();//合并数量
|
iterator.remove();
|
if(!matCode.equalsIgnoreCase(cart.getMatCode())) {
|
matCode=cart.getMatCode();
|
Iterator<CartEntity> iterator2 = cartList.iterator();
|
while (iterator2.hasNext()) {
|
CartEntity cartEntity2 = iterator2.next();
|
if (cart.getMatCode().equalsIgnoreCase(cartEntity2.getMatCode())) {
|
totalAmount += Double.parseDouble(cartEntity2.getAmount());
|
totalQuantity += cartEntity2.getQuantity();
|
}
|
}
|
cart.setAmount(totalAmount + "");
|
cart.setQuantity(totalQuantity);
|
newCartList.add(cart);
|
}
|
}
|
//List<Gfrom> refFormIdList = getRefFormIdList(request, refFormid);
|
Map map = new HashMap();
|
map.put("carts", newCartList);
|
//map.put("refFormids", refFormIdList);
|
|
callBackMessage.setInfo(map);
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 删除
|
*
|
* @param request
|
* @param response
|
*/
|
@Transactional
|
@RequestMapping(value = "/qr/delCart.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask delCart(String idList, HttpServletRequest request, HttpServletResponse response) {
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
Callable<Object> callable = new CartCallable(null, null, idList, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 3);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("操作出错");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在购物车查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
/**
|
* 立即下单
|
*
|
* @param request
|
* @param response
|
*/
|
@Transactional
|
@RequestMapping(value = "/qr/postCarts.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask postCarts(@RequestBody PostCartEntity postCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
log.info("---------------------start:" + userCode + "-----------------");
|
Callable<Object> callable = new T120201Callable(postCartEntity, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 1);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("执行出错,请重新下单");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在【销售管理】-【销售订单】-【查询订单进度表】中查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
/**
|
* 在购物车通过多选物料生成单据
|
*
|
* @param postCartEntity 用;分隔的多个cartid
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/createPost.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask cartPost(@RequestBody PostCartEntity postCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
log.info("---------------------start:" + userCode + "-----------------");
|
Callable<Object> callable = new T120201Callable(postCartEntity, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 0);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("执行出错,请重新下单");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在【销售管理】-【销售订单】-【查询订单进度表】中查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
private class T120201Callable implements Callable<Object> {
|
PostCartEntity postCartEntity;
|
String userCode;
|
String dbid;
|
QrServiceIfc qrServiceIfc;
|
int actionType = 0;//0 表示从购物车下单，1 表示立即下单
|
String userName;
|
|
public T120201Callable(PostCartEntity postCartEntity, String userCode, String userName, String dbid, QrServiceIfc qrServiceIfc, int actionType) {
|
this.postCartEntity = postCartEntity;
|
this.userCode = userCode;
|
this.dbid = dbid;
|
this.qrServiceIfc = qrServiceIfc;
|
this.actionType = actionType;
|
this.userName = userName;
|
}
|
|
private String joinCartSql() {
|
final List<CartEntity> carts = postCartEntity.getCarts();
|
StrBuilder sb = new StrBuilder();
|
if (carts != null && carts.size() > 0) {
|
//声明变量
|
sb.append(" declare @CartId varchar(800) \n");
|
if (postCartEntity.getIsSaveAll() == 1) {
|
//先清空购物车
|
sb.append(" delete from t710205 where UserCode =" + GridUtils.prossSqlParm(postCartEntity.getUserCode()));
|
}
|
for (CartEntity cartEntity : carts) {
|
sb.append(" insert into t710205 (UserCode,UserName,CltCode,CltName,MatCode,MatName,Special,PhotoPath, \n")
|
.append(" Quantity,Price,Amount,WeightUom,DateAdded,VoucherDocCode,\n")
|
.append(" refDocCode,refFormId,refFormType,refRowId,isSelected,MatGroupStatus,SalesPrice,Discount,ManualPrice,skuId1,skuName1,skuId2,skuName2,skuId3,skuName3,skuId4,skuName4,skuId5,skuName5,skuId6,skuName6,skuId7,skuName7,skuId8,skuName8,skuId9,skuName9,skuId10,skuName10) \n")
|
.append(" values(" + GridUtils.prossSqlParm(postCartEntity.getUserCode()) + "," + GridUtils.prossSqlParm(userName) + "," + GridUtils.prossSqlParm(postCartEntity.getCltCode()) + "," + GridUtils.prossSqlParm(postCartEntity.getCltName()) + "," + GridUtils.prossSqlParm(cartEntity.getMatCode()) + "," + GridUtils.prossSqlParm(cartEntity.getMatName()) + "," + GridUtils.prossSqlParm(cartEntity.getSpecial()) + " ," + GridUtils.prossSqlParm(cartEntity.getPhotoPath()) + "," + cartEntity.getQuantity() + "," + cartEntity.getPrice() + ",round(isnull("+cartEntity.getQuantity()+",0) * isnull("+cartEntity.getManualPrice()+",0),2),null,getdate(),null," + GridUtils.prossSqlParm(postCartEntity.getRefDocCode()) + "," + postCartEntity.getRefFormId() + "," + postCartEntity.getRefFormType() + "," + GridUtils.prossSqlParm(postCartEntity.getRefRowId()) + ",1,1," + cartEntity.getSalesPrice() + "," + cartEntity.getDiscount() +"," + cartEntity.getManualPrice()+"," + cartEntity.getSkuId1()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName1())+"," + cartEntity.getSkuId2()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName2())+"," + cartEntity.getSkuId3()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName3())+"," + cartEntity.getSkuId4()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName4())+"," + cartEntity.getSkuId5()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName5())+"," + cartEntity.getSkuId6()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName6())+"," + cartEntity.getSkuId7()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName7())+"," + cartEntity.getSkuId8()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName8())+"," + cartEntity.getSkuId9()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName9())+"," + cartEntity.getSkuId10()+"," +GridUtils.prossSqlParm(cartEntity.getSkuName10()) + ")\n")
|
.append(" SELECT @CartId =isnull(@CartId,'')+cast(@@IDENTITY as varchar) +','; \n");
|
}
|
sb.append(" select @CartId=left(@cartId,len(@cartId)-1) \n");
|
}
|
return sb.toString();
|
}
|
|
@Override
|
public Object call() throws Exception {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
long startTime = System.currentTimeMillis();
|
try {
|
SpObserver.setDBtoInstance("_" + dbid);
|
String cartids = null;
|
String cartSql = null;
|
postCartEntity.setUserCode(userCode);
|
Map map = null;
|
if (dbid.equals("530")) {
|
//卤江南专用
|
map = qrServiceIfc.save120201(postCartEntity, userCode);
|
} else {
|
if (actionType == 1) {
|
if (postCartEntity == null || postCartEntity.getCarts() == null || postCartEntity.getCarts().size() == 0) {
|
throw new ApplicationException("没有商品，不能下单");
|
}
|
if (postCartEntity.getFormId() == null) {
|
throw new ApplicationException("生成单据所对应目标功能号不能为空");
|
}
|
cartSql = joinCartSql();
|
} else {
|
//在购物车下单，直接取carid
|
cartids = postCartEntity.getCartids();
|
}
|
map = qrServiceIfc.savePost(postCartEntity, cartids, userCode, cartSql);
|
if (map != null) {
|
postCartEntity.setCartids(map.get("cartIds") + "");
|
final Integer result = qrServiceIfc.delCart(postCartEntity);
|
map.remove("cartIds");
|
map.put("delable", result == -1 ? 1 : 0);
|
}
|
}
|
if (map == null || StringUtils.isBlank(GridUtils.prossRowSetDataType_String(map, "docCode"))) {
|
throw new ApplicationException(postCartEntity.getFormId() + "生成单据出错:单号为空");
|
}
|
log.info("cltCode:" + userCode + "-客户：" + userCode + "下单花费:" + (System.currentTimeMillis() - startTime));
|
callBackMessage.setInfo(map);
|
callBackMessage.sendSuccessMessageByDefault();
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
log.info("cltCode:" + userCode + "-客户下单出错：" + userCode + "花费:" + (System.currentTimeMillis() - startTime));
|
callBackMessage.sendErrorMessage(ex.getCause() != null ? ex.getCause().getMessage() : ex.getMessage());
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
log.info("---------------------end:" + userCode + "-----------------");
|
}
|
}
|
}
|
|
/**
|
* 新增
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/addCart.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask addCart(@RequestBody PostCartEntity postCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
postCartEntity.setUserCode(userCode);
|
Callable<Object> callable = new CartCallable(postCartEntity, null, null, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 1);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("操作出错");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在购物车查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
/**
|
* 保存购物车商品
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/saveAllCart.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask saveAllCart(@RequestBody PostCartEntity postCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
postCartEntity.setUserCode(userCode);
|
postCartEntity.setIsSaveAll(1);
|
Callable<Object> callable = new CartCallable(postCartEntity, null, null, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 4);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("操作出错");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在购物车查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
private class CartCallable implements Callable<Object> {
|
PostCartEntity postCartEntity;
|
String userCode;
|
String userName;
|
String dbid;
|
QrServiceIfc qrServiceIfc;
|
int actionType = 0;//1,新增(保存相同商品只更新数量) 2，修改 3，删除,4 保存购物车商品(覆盖原有商品)
|
CartEntity cartEntity;
|
String idList;
|
|
public CartCallable(PostCartEntity postCartEntity, CartEntity cartEntity, String idList, String userCode, String userName, String dbid, QrServiceIfc qrServiceIfc, int actionType) {
|
this.postCartEntity = postCartEntity;
|
this.userCode = userCode;
|
this.userName = userName;
|
this.dbid = dbid;
|
this.qrServiceIfc = qrServiceIfc;
|
this.actionType = actionType;
|
this.cartEntity = cartEntity;
|
this.idList = idList;
|
}
|
|
@Override
|
public Object call() throws Exception {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + dbid);
|
|
Map map = new HashMap();
|
switch (actionType) {
|
case 1:
|
case 4:
|
if (postCartEntity == null || postCartEntity.getCarts() == null || postCartEntity.getCarts().size() == 0) {
|
throw new ApplicationException("商品不能为空，新增失败");
|
}
|
final List<Map<String, Integer>> result = qrServiceIfc.saveCart(postCartEntity, userName);
|
if (result != null) {
|
//--增加返回购物车商品总数
|
Integer count = qrServiceIfc.getCartListCount(userCode, userName, postCartEntity.getRefDocCode());
|
map.put("data", result);
|
map.put("count", count);
|
}
|
break;
|
case 2:
|
if (cartEntity == null) {
|
throw new ApplicationException("商品不能为空，修改商品数量失败");
|
}
|
qrServiceIfc.updateCart(cartEntity);
|
break;
|
case 3:
|
if (idList == null) {
|
throw new ApplicationException("商品不能为空，删除商品失败");
|
}
|
cartIfc.delCart(idList);
|
break;
|
|
}
|
callBackMessage.setInfo(map);
|
callBackMessage.sendSuccessMessageByDefault();
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(ex.getCause() != null ? ex.getCause().getMessage() : ex.getMessage());
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
}
|
|
/**
|
* 更新
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/updateCart.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
WebAsyncTask updateCart(@RequestBody CartEntity cartEntity, HttpServletRequest request, HttpServletResponse response) {
|
String userCode = request.getSession().getAttribute(SessionKey.HRCODE) + "";
|
String userName = request.getSession().getAttribute(SessionKey.HRNAME) + "";
|
Callable<Object> callable = new CartCallable(null, cartEntity, null, userCode, userName, request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "", qrServiceIfc, 2);
|
//定义超时45秒
|
WebAsyncTask asyncTask = new WebAsyncTask(TimeUnit.SECONDS.toMillis(45), threadPoolExecutor, callable);
|
asyncTask.onCompletion(
|
() -> log.info("执行成功")
|
);
|
asyncTask.onError(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行出错");
|
callBackMessage.sendErrorMessage("操作出错");
|
return callBackMessage.toJSONObject();
|
}
|
);
|
asyncTask.onTimeout(
|
(Callable<Object>) () -> {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
log.info("执行超时");
|
callBackMessage.sendErrorMessage("服务器繁忙，正在排队处理，请不要重复提交，稍后请在购物车查看结果", -1003);
|
return callBackMessage.toJSONObject();
|
}
|
);
|
return asyncTask;
|
}
|
|
/**
|
* 新增客户资料
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/save170001.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object save170001(@RequestBody CustomerEntity customerEntity, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
checkFormPerssion(request, 170001);
|
String dbid = request.getSession().getAttribute(SessionKey.DATA_BASE_ID) + "";
|
SpObserver.setDBtoInstance("_" + dbid);
|
customerEntity.setAddress(customerEntity.getFullAddress());
|
CustomerEntity customer = null;
|
Integer result = null;
|
if (StringUtils.isBlank(customerEntity.getCltName())) {
|
throw new ApplicationException("客户名称不能为空");
|
}
|
if (StringUtils.isBlank(customerEntity.getTel())) {
|
throw new ApplicationException("客户电话不能为空");
|
}
|
if (customerEntity.getCltCode() == null || StringUtils.isBlank(customerEntity.getCltCode())) {
|
//新增
|
customer = accountIfc.saveNewCustomer(customerEntity, request.getSession().getAttribute(SessionKey.USERCODE) + "");
|
} else {
|
//修改
|
result = qrServiceIfc.update170001(customerEntity);
|
}
|
List<Map<String, Object>> meta = new ArrayList<>();
|
String sql = this.procssSQLPersion(request, meta);
|
final Map map = qrServiceIfc.get170001(customerEntity.getCltCode(), sql);
|
String docCode = map.get("docCode") + "";
|
//--生成二维码
|
QrCodeForAppEntity qrCodeForAppEntity = new QrCodeForAppEntity();
|
qrCodeForAppEntity.setAction(QrCodeForAppEntity.ViewDocument); //设置行为 Action
|
qrCodeForAppEntity.setAuthorCode((String) request.getSession().getAttribute(SessionKey.HRCODE));
|
qrCodeForAppEntity.setAuthorName((String) request.getSession().getAttribute(SessionKey.HRNAME));
|
qrCodeForAppEntity.setRefFormId(170001);
|
qrCodeForAppEntity.setRefDocCode(docCode);
|
qrCodeForAppEntity.setRefFormType(16);
|
qrCodeForAppEntity = qrServiceIfc.createQrCode(qrCodeForAppEntity);
|
if (qrCodeForAppEntity == null || StringUtils.isBlank(qrCodeForAppEntity.getQrCode())) {
|
throw new ApplicationException("请检查" + qrCodeForAppEntity.getRefFormId() + "在9801是否勾选上【生成单据二维码】参数设置");
|
} else {
|
map.put("qrCode", qrCodeForAppEntity.getQrCode());
|
}
|
|
//---与购物车中还没有关联的物料进行关联处理
|
final Integer updateresult = qrServiceIfc.updateRefBy170001(map.get("doccode") + "", map.get("formId") + "", map.get("formtype") + "", request.getSession().getAttribute(SessionKey.USERCODE) + "");
|
if (customer != null) {
|
callBackMessage.sendSuccessMessage("新建成功");
|
} else {
|
//修改
|
if (result == 0) {
|
throw new ApplicationException("更新客户资料出错");
|
} else {
|
callBackMessage.sendSuccessMessage("更新成功");
|
}
|
}
|
callBackMessage.setInfo(map);
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
ex.printStackTrace();
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 检查指定功能号是否有权限
|
*
|
* @param request
|
* @param formid
|
*/
|
public void checkFormPerssion(HttpServletRequest request, int formid) {
|
//---检查权限
|
if (Integer.parseInt(request.getSession().getAttribute(SessionKey.SUPPER_USER) + "") == 0) {
|
final Map attribute = (Map) request.getSession().getAttribute(SessionKey.PERSSION);
|
if (!attribute.containsKey(formid+"")) {// TODO key为String类型，containsKey传的参数类型也要强制转换成String类型 ,不然会出现本来是存在，又找不到的情况，特别注意
|
//不存在于权限集合表示不需要输出
|
throw new ApplicationException("没有新增客户资料的权限");
|
}
|
}
|
}
|
|
/**
|
* 搜索客户资料
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/list170001.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object list170001(@RequestBody ProducParmBean producParmBean, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
this.checkFormPerssion(request, 170001);
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
//--处理权限,读取9802设置
|
List<Map<String, Object>> meta = new ArrayList<>();
|
String sql = this.procssSQLPersion(request, meta);
|
GTGrid gtGrid =(GTGrid) FactoryBean.getBean("GTGrid");
|
final String dataGroupInfo = gtGrid.getDataGroupInfo(170001, request.getSession().getAttribute(SessionKey.USERCODE) + "", 0, request.getSession());
|
final List list = qrServiceIfc.list170001(producParmBean, sql,dataGroupInfo);
|
|
//if (list !=null&&list.size()>0) {
|
callBackMessage.sendSuccessMessage("成功");
|
callBackMessage.setInfo(list);
|
return callBackMessage.toJSONObject();
|
// }
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 显示客户资料明细
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/get170001.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object get170001(String cltCode, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
this.checkFormPerssion(request, 170001);
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
Map map = new HashMap();
|
//--处理权限,读取9802设置
|
List<Map<String, Object>> meta = new ArrayList<>();
|
String sql = this.procssSQLPersion(request, meta);
|
if (StringUtils.isNotBlank(cltCode)) {
|
map.put("customer", qrServiceIfc.get170001(cltCode, sql));
|
}
|
callBackMessage.sendSuccessMessage("成功");
|
map.put("9802", meta);
|
final BaseService baseService = (BaseService) FactoryBean.getBean("BaseService");
|
map.put("cltType", baseService.getSimpleJdbcTemplate().queryForList("select a.CltType as fieldId,a.CltType as fieldName from t110201 a order by a.CltType asc"));
|
callBackMessage.setInfo(map);
|
return callBackMessage.toJSONObject();
|
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 根据电话查询客户资料
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/get170001ByTel.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object get170001ByTel(String tel, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
this.checkFormPerssion(request, 170001);
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
Map map = new HashMap();
|
//--处理权限,读取9802设置
|
List<Map<String, Object>> meta = new ArrayList<>();
|
String sql = this.procssSQLPersion(request, meta);
|
|
if (StringUtils.isBlank(tel)) {
|
throw new ApplicationException("电话不能为空");
|
}
|
T110203 t110203 = qrServiceIfc.get170001ByTel(tel, sql);
|
callBackMessage.sendSuccessMessage("成功");
|
callBackMessage.setInfo(t110203);
|
return callBackMessage.toJSONObject();
|
|
} catch (EmptyResultDataAccessException e) {
|
callBackMessage.sendSuccessMessage("成功");
|
callBackMessage.setInfo(new T110203());
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
private String procssSQLPersion(HttpServletRequest request, List<Map<String, Object>> meta) {
|
final List<Map<String, Object>> list = gridService.getSimpleJdbcTemplate().queryForList("set nocount on ; select " + gridService.getGET_GFIELD().toLowerCase() + " from gfield where formid=170001 and headflag=0 order by statisid asc");
|
String sql = "";
|
List<String> valueExp = new ArrayList<>();//字段(id,权限,css,tips)
|
String fieldNames = ";cltcode;cltname;tel;tel2;fulladdress;clttype;linkman;";//需要显示的字段
|
for (Map<String, Object> map : list) {
|
String fieldId = GridUtils.prossRowSetDataType_String(map, "fieldid");
|
if (fieldNames.contains(";" + fieldId.toLowerCase() + ";")) {
|
Map<String, Object> met = new HashMap<>();
|
met.put("fieldId", fieldId.toLowerCase());
|
|
//--权限表达式
|
if (!"".equalsIgnoreCase(GridUtils.prossRowSetDataType_String(map, "ShowFieldValueExpression"))) {
|
String expr = " case when (" + map.get("ShowFieldValueExpression") + ") =1 then 1 when (" + map.get("ShowFieldValueExpression") + ") =2 then 2 else 0 end as [" + fieldId.toLowerCase() + "_expr]";
|
String value = " case (" + map.get("ShowFieldValueExpression") + ") when 0 then '******' else " + fieldId.toLowerCase() + " end as [" + fieldId.toLowerCase() + "]";
|
valueExp.add(value);
|
valueExp.add(expr);
|
} else {
|
valueExp.add("[" + fieldId.toLowerCase() + "]");
|
}
|
//只读
|
met.put("readOnly", GridUtils.prossRowSetDataType_Integer(map, "ReadOnly"));
|
//初始值
|
met.put("initValue", GridUtils.prossRowSetDataType_String(map, "initValue"));
|
meta.add(met);
|
}
|
}
|
|
sql = String.join(",", valueExp);
|
//替换会话参数
|
Pattern p = Pattern.compile("@.*?\\w+");// 匹配以@开头的单词
|
java.util.regex.Matcher propsMatcher = p.matcher(sql);
|
while (propsMatcher.find()) {
|
sql = sql.replaceAll(propsMatcher.group(), request.getSession().getAttribute(propsMatcher.group().toLowerCase()) + "");
|
}
|
return sql;
|
}
|
|
/**
|
* 保存扫码显示方式
|
*
|
* @param request
|
* @param response
|
*/
|
|
@RequestMapping(value = "/qr/qrScanType.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object saveQrSanType(int type, int isRelatingMaterialWhenNewCustomer, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
|
final Integer result = qrServiceIfc.saveQrScanType(request.getSession().getAttribute(SessionKey.USERCODE) + "",
|
request.getSession().getAttribute(SessionKey.USER_NAME) + "",
|
type, isRelatingMaterialWhenNewCustomer);
|
if (result > 0) {
|
callBackMessage.sendSuccessMessage("提交成功");
|
return callBackMessage.toJSONObject();
|
} else {
|
callBackMessage.sendErrorMessage("提交出错");
|
return callBackMessage.toJSONObject();
|
}
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 扫码取数
|
*
|
* @param refPostCartEntity 引用的原始单据功能号实体
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/qrScan.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object qrScan(@RequestBody PostCartEntity refPostCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
String dbid=request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"";
|
SpObserver.setDBtoInstance("_" + dbid);
|
T112002 t112002 = new T112002();
|
if (refPostCartEntity.getQrCode().startsWith("2003")) {
|
//API对接认证二维码
|
RedisTemplate redisTemplate = (RedisTemplate) FactoryBean.getBean("redisTemplate");
|
final Object object = redisTemplate.opsForValue().get(RedisKey.MUTUAL_QRCODE + ":" + refPostCartEntity.getQrCode());
|
if (object != null) {
|
t112002.setAction(QrCodeForAppEntity.AUTH);
|
//增加当前用户的companyName,logo。输出到前端
|
String companyName = request.getSession().getAttribute(SessionKey.COMPANY_NAME) + "";
|
String domain = request.getSession().getAttribute(SessionKey.DOMAIN) + "";
|
MutualController mutualController=(MutualController)FactoryBean.getBean("mutualController");
|
String logo =mutualController.getLogo(dbid);
|
Map ownMap =JSON.parseObject(String.valueOf(object),HashMap.class);
|
Map qrCodeDate=(Map)ownMap.get("qrCodeData");
|
qrCodeDate.put("ownCompanyName",companyName);
|
qrCodeDate.put("ownLogo",domain+logo);
|
t112002.setQueryString(GridUtils.toJson(ownMap));
|
Map map = new HashMap();
|
map.put("qrCodeInfo", t112002);
|
callBackMessage.setInfo(map);
|
} else {
|
throw new ApplicationException("二维码已过期");
|
}
|
} else {
|
t112002 = qrServiceIfc.getT112002(refPostCartEntity.getQrCode());
|
callBackMessage.setInfo(getProductInfo(t112002, refPostCartEntity, request, response));
|
}
|
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (EmptyResultDataAccessException e) {
|
callBackMessage.sendErrorMessage(refPostCartEntity.getQrCode() + "码不存在");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 通过原始单据取得引用物料列表
|
*
|
* @param refPostCartEntity 引用的原始单据功能号实体
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/getRefMatCodes.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object getRefMatCodes(@RequestBody PostCartEntity refPostCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
|
|
callBackMessage.setInfo(getRefMatCodeList(refPostCartEntity, request));
|
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (EmptyResultDataAccessException e) {
|
callBackMessage.sendErrorMessage(refPostCartEntity.getQrCode() + "码不存在");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
private Map getRefMatCodeList(PostCartEntity refPostCartEntity, HttpServletRequest request) {
|
Integer formid = refPostCartEntity.getFormId();
|
if (formid != null && formid != 0) {
|
//需要通过formid查找9802设置的QrCodeSqlScript,执行sql返回相关联的物料，返回给前端
|
final QrCodeRefEntity refProduct = qrServiceIfc.getRefProduct(formid);
|
if (refProduct != null) {
|
if (StringUtils.isNotBlank(refProduct.getQrCodeSqlScript())) {
|
Map qrMap = new HashMap();
|
if (StringUtils.isBlank(refProduct.getQrCodeRefRowId())) {
|
throw new ApplicationException("请在9802中为【" + refProduct.getFieldid() + "】字段设置参数【APP扫码|引用外表RowId字段名】");
|
}
|
qrMap.put("refRowid", refProduct.getQrCodeRefRowId());
|
if (StringUtils.isBlank(refProduct.getQrCodeRefDigit())) {
|
throw new ApplicationException("请在9802中为【" + refProduct.getFieldid() + "】字段设置参数【APP扫码|引用外表数量字段名】");
|
}
|
qrMap.put("refDigit", refProduct.getQrCodeRefDigit());
|
String sql = refProduct.getQrCodeSqlScript();
|
//&..&替换
|
Pattern p = Pattern.compile("&.*?&");
|
Matcher m = p.matcher(sql);
|
while (m.find()) {
|
String field = m.group().replaceAll("&", "");
|
if (field.equalsIgnoreCase("matcode")) {
|
|
sql = sql.replaceAll(m.group(), refPostCartEntity.getMatCode());
|
} else if (field.equalsIgnoreCase("refformid")) {
|
sql = sql.replaceAll(m.group(), refPostCartEntity.getRefFormId() + "");
|
} else if (field.equalsIgnoreCase("refdoccode")) {
|
sql = sql.replaceAll(m.group(), refPostCartEntity.getRefDocCode() + "");
|
} else if (field.equalsIgnoreCase("refformtype")) {
|
sql = sql.replaceAll(m.group(), refPostCartEntity.getRefFormType() + "");
|
}
|
}
|
//会话替换
|
sql = filterSession(sql, request);
|
List<Map<String, Object>> qrCodeSqlScriptMatCode = null;
|
try {
|
qrCodeSqlScriptMatCode = qrServiceIfc.getQrCodeSqlScriptMatCode(sql);
|
if (qrCodeSqlScriptMatCode != null && qrCodeSqlScriptMatCode.size() == 0) {
|
throw new ApplicationException("当前引用" + refPostCartEntity.getRefDocCode() + "单据不存在" + refPostCartEntity.getMatCode() + "物料，请重新确认");
|
}
|
} catch (EmptyResultDataAccessException e) {
|
throw new ApplicationException("当前引用" + refPostCartEntity.getRefDocCode() + "单据不存在" + refPostCartEntity.getMatCode() + "物料，请重新确认");
|
}
|
|
qrMap.put("refProduct", qrCodeSqlScriptMatCode);
|
return qrMap;
|
}
|
return null;
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 显示单据二维码
|
*
|
* @param qrCode 二维码
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/showQrCode.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object showQrCode(String qrCode, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
T112002 t112002 = qrServiceIfc.getT112002(qrCode);
|
callBackMessage.setInfo(imgData.getImageUrl(t112002.getQrCodeUnid(), null,
|
null, true,
|
false, request));
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (EmptyResultDataAccessException e) {
|
callBackMessage.sendErrorMessage(qrCode + "码不存在");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
private Map getProductInfo(T112002 t112002, PostCartEntity refPostCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
Map<String, Object> map = new HashMap<>();
|
map.put("qrCodeInfo", t112002);
|
if (QrCodeForAppEntity.ViewMaterial.equalsIgnoreCase(t112002.getAction())) {
|
//扫物料
|
Integer formid = refPostCartEntity.getFormId();
|
final Map matCodeMap = this.getMatCode(t112002.getMatCode(), request, response);
|
map.put("product", matCodeMap);
|
if (formid != null && formid != 0) {
|
refPostCartEntity.setMatCode(matCodeMap.get("MatCode") + "");
|
map.put("refData", this.getRefMatCodeList(refPostCartEntity, request));
|
}
|
|
} else if (QrCodeForAppEntity.ViewDocument.equalsIgnoreCase(t112002.getAction())) {
|
//扫单据
|
// refFormIdList = getRefFormIdList(request, t112002.getRefFormId());
|
//map.put("reFormids", refFormIdList);
|
}
|
return map;
|
}
|
|
private String filterSession(String filter, HttpServletRequest request) {
|
if ("".equals(filter)) return filter;
|
Pattern p = Pattern.compile("@.*?\\w+");
|
Matcher m = p.matcher(filter);
|
while (m.find()) {//存在
|
filter = filter.replaceAll(m.group(), request.getSession().getAttribute(m.group()) + "");
|
}
|
return filter;
|
}
|
|
/**
|
* 查看商品明细
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/product.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object product(String matCode, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
callBackMessage.setInfo(this.getMatCode(matCode, request, response));
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (EmptyResultDataAccessException e) {
|
callBackMessage.sendErrorMessage(matCode + "不存在");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 更新购物车里没有关联的物料到指定引用单据
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/updateRef.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object product(@RequestBody PostCartEntity postCartEntity, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
Integer result = qrServiceIfc.updateRef(postCartEntity);
|
if (result > 0) {
|
callBackMessage.sendSuccessMessageByDefault();
|
return callBackMessage.toJSONObject();
|
} else {
|
throw new ApplicationException("更新出错，请重试");
|
}
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 商品分类显示
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/matGroups.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object matGroups(HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
String dbid=request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"";
|
try {
|
SpObserver.setDBtoInstance("_" +dbid );
|
GTGrid gtGrid =(GTGrid)FactoryBean.getBean("GTGrid");
|
final HttpSession session = request.getSession();
|
final String dataGroupInfo = gtGrid.getDataGroupInfo(110501, session.getAttribute(SessionKey.USERCODE) + "", 0, session);
|
final List<MatGroupEntity> groups = qrServiceIfc.getMatGroups(dataGroupInfo);
|
List<Map> groupList = new ArrayList();
|
String matgourpId = null;
|
String hostUrl = SettingKey.getHostUrlForImage(request);
|
List<MatGroupEntity> mainGroup=groups.stream().filter(x->(
|
x.getParentRowid()==null||x.getParentRowid().equals(""))
|
).collect(Collectors.toList());
|
if(mainGroup!=null&&mainGroup.size()>0) {
|
for (MatGroupEntity matGroupEntity : mainGroup) {
|
Map matGroup = new HashMap();
|
//1级分类
|
matGroup.put("MatGroupName", matGroupEntity.getMatGroupName());
|
matGroup.put("MatGroup", matGroupEntity.getMatGroup());
|
if (matgourpId == null) {
|
matgourpId = matGroupEntity.getMatGroup();
|
}
|
//2级分类
|
List<MatGroupEntity> subMatGroupList = groups.stream().filter(x -> (
|
x.getParentRowid().equals(matGroupEntity.getRowid())
|
)).collect(Collectors.toList());//qrServiceIfc.getMatGroupsByParentRowId(matGroupEntity.getRowid());
|
List<Map> subList = new ArrayList<>();
|
if(subMatGroupList!=null&&subMatGroupList.size()>0) {
|
subMatGroupList.stream().forEach(x -> {
|
Map subMap = new HashMap();
|
subMap.put("SubMatGroupName", x.getMatGroupName());
|
subMap.put("SubMatGroup", x.getMatGroup());
|
subList.add(subMap);
|
});
|
}
|
matGroup.put("subList", subList);
|
groupList.add(matGroup);
|
}
|
final List<MatCodeEntity> matCodeEntityList = qrServiceIfc.getMatCodesByMatGroup(matgourpId, 50, 1);
|
// matCodeEntityList.stream().map(x -> {
|
// x.setPhotoPath(imgData.getImageUrl(x.getPhotoPath(), 120,
|
// 120, false,
|
// false, request));
|
// return x;
|
// }).collect(Collectors.toList());
|
matCodeEntityList.stream().forEach(x -> {
|
x.setPhotoPath(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
x.setPhotoPathUrl(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
});
|
Map nodes = new HashMap();
|
nodes.put("nodes", groupList);
|
nodes.put("data", matCodeEntityList);
|
nodes.put("appSalesOrderStyle", request.getSession().getAttribute(SessionKey.APP_SALESORDER_STYLE));
|
callBackMessage.setInfo(nodes);
|
}
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 商品列表显示
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/productList.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object productList(@RequestBody ProducParmBean producParmBean, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
String dbid=request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"";
|
String hostUrl = SettingKey.getHostUrlForImage(request);
|
SpObserver.setDBtoInstance("_" +dbid );
|
final List<MatCodeEntity> matCodeEntityList = qrServiceIfc.getMatCodesByMatGroup(producParmBean.getValue(), producParmBean.getLimit(), producParmBean.getPage());
|
|
// matCodeEntityList.stream().map(x -> {
|
// x.setPhotoPath(imgData.getImageUrl(x.getPhotoPath(), 120,
|
// 120, false,
|
// false, request));
|
// return x;
|
// }).collect(Collectors.toList());
|
matCodeEntityList.stream().forEach(x -> {
|
x.setPhotoPath(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
x.setPhotoPathUrl(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
});
|
callBackMessage.setInfo(matCodeEntityList);
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 商品搜索
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/searchProduct.do", method = RequestMethod.POST)
|
@CrossOrigin
|
public @ResponseBody
|
Object searchProduct(@RequestBody ProducParmBean producParmBean, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
String dbid=request.getSession().getAttribute(SessionKey.DATA_BASE_ID)+"";
|
SpObserver.setDBtoInstance("_" + dbid);
|
String hostUrl = SettingKey.getHostUrlForImage(request);
|
final List<MatCodeEntity> matCodeEntityList = qrServiceIfc.getMatCodesByMatGroupBySearch(producParmBean.getValue(), producParmBean.getLimit(), producParmBean.getPage());
|
// matCodeEntityList.stream().map(x -> {
|
// x.setPhotoPath(imgData.getImageUrl(x.getPhotoPath(), 120,
|
// 120, false,
|
// false, request));
|
// return x;
|
// }).collect(Collectors.toList());
|
matCodeEntityList.stream().forEach(x -> {
|
x.setPhotoPath(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
x.setPhotoPathUrl(SettingKey.getUrl(hostUrl, x.getPhotoPathUrl(), dbid+"",null));
|
});
|
callBackMessage.setInfo(matCodeEntityList);
|
callBackMessage.sendSuccessMessage("成功");
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 保存2002类型的二维码单据信息
|
*
|
* @param targetFormId 生成目标功能号
|
* @param targetFormName 生成目标功能名称
|
*/
|
@RequestMapping(value = "/qr/save112005.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object save112005(String qrCode, String targetFormId, String targetFormName, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
T112002 t112002 = qrServiceIfc.getT112002(qrCode);
|
if (t112002 != null && StringUtils.isNotBlank(t112002.getQueryString())) {
|
Map map = GridUtils.fromJson(t112002.getQueryString());
|
if (map != null) {
|
T112005 t112005 = new T112005();
|
t112005.setUserCode(request.getSession().getAttribute(SessionKey.USERCODE) + "");
|
t112005.setRefFormId(GridUtils.prossRowSetDataType_Int(map, "FormId"));
|
t112005.setRefFormType(GridUtils.prossRowSetDataType_Int(map, "FormType"));
|
t112005.setRefDocCode(GridUtils.prossRowSetDataType_String(map, "DocCode"));
|
t112005.setTargetFormId(targetFormId);
|
t112005.setTargetFormName(targetFormName);
|
t112005.setQrCode(qrCode);
|
t112005.setQrCodeUnid(t112002.getQrCodeUnid());
|
t112005.setQueryString(t112002.getQueryString());
|
Integer result = qrServiceIfc.save112005(t112005);
|
Map rst = new HashMap(2);
|
rst.put("qrCodeInfo", t112002);
|
rst.put("count", result);
|
callBackMessage.setInfo(rst);
|
callBackMessage.sendSuccessMessage("成功");
|
}
|
} else {
|
callBackMessage.sendErrorMessage(qrCode + "码查找不到相关数据");
|
}
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 删除2002类型的二维码单据信息
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/del112005.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object del112005(String docCode, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
T112005 t112005 = new T112005();
|
t112005.setUserCode(request.getSession().getAttribute(SessionKey.USERCODE) + "");
|
|
t112005.setRefDocCode(docCode);
|
|
Integer result = qrServiceIfc.del112005(t112005);
|
if (result > 0) {
|
callBackMessage.sendSuccessMessage("成功");
|
} else {
|
callBackMessage.sendErrorMessage("删除出错");
|
}
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 2002类型的二维码单据信息列表
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/list112005.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object list112005(HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
|
|
List<T112005> list112005 = qrServiceIfc.list112005(request.getSession().getAttribute(SessionKey.USERCODE) + "");
|
if (list112005 != null && list112005.size() > 0) {
|
callBackMessage.sendSuccessMessage("成功");
|
callBackMessage.setInfo(list112005);
|
}
|
return callBackMessage.toJSONObject();
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
/**
|
* 取得关联功能号
|
*
|
* @param request
|
* @param response
|
*/
|
@RequestMapping(value = "/qr/getRefFormIds.do", method = RequestMethod.GET)
|
@CrossOrigin
|
public @ResponseBody
|
Object getRefFormIds(Integer refFormid,Integer targetFormid, HttpServletRequest request, HttpServletResponse response) {
|
CallBackMessage callBackMessage = new CallBackMessage();
|
try {
|
SpObserver.setDBtoInstance("_" + request.getSession().getAttribute(SessionKey.DATA_BASE_ID));
|
final List<Gfrom> refFormIdList = this.getRefFormIdList(request, refFormid,targetFormid);
|
if (refFormIdList == null || refFormIdList.size() == 0) {
|
if (refFormid != null) {
|
//针对扫码方式，refFormid是有值
|
throw new ApplicationException("请设置要生成的目标单据功能号,在9802中为扫码字段设置【APP扫码|引用外表功能号【多值用分号隔开】】参数");
|
} else {
|
//针对下单方式，refFormid是没有值，也就是没有关联
|
throw new ApplicationException("在下单方式下请确保要生成的目标单据功能号,在9802中为扫码字段设置【APP扫码|引用外表功能号【多值用分号隔开】】参数要为空");
|
}
|
} else {
|
callBackMessage.sendSuccessMessage("成功");
|
callBackMessage.setInfo(refFormIdList);
|
return callBackMessage.toJSONObject();
|
}
|
} catch (Exception ex) {
|
callBackMessage.sendErrorMessage(this.getErrorMsg(ex));
|
return callBackMessage.toJSONObject();
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
public List<Gfrom> getRefFormIdList(HttpServletRequest request, Integer refFormid,Integer targetFormid) {
|
//---二维码关联的功能号
|
List<Gfrom> refFormIdList = qrServiceIfc.getRefFormIdList(refFormid);
|
if (refFormIdList == null || refFormIdList.size() == 0) {
|
throw new ApplicationException("未找到可生成的目标功能号");
|
}
|
return procFormLimitV2(request, refFormIdList,targetFormid);
|
}
|
|
public List<Gfrom> procFormLimit(HttpServletRequest request, List<Gfrom> refFormIdList) {
|
if (Integer.parseInt(request.getSession().getAttribute(SessionKey.SUPPER_USER) + "") == 0) {
|
//---取出当前用户的功能号权限集合
|
final Map attribute = (Map) request.getSession().getAttribute(SessionKey.PERSSION);
|
Iterator<Gfrom> iterator = refFormIdList.iterator();
|
while (iterator.hasNext()) {
|
Gfrom gfrom = iterator.next();
|
if (!attribute.containsKey(gfrom.getFormid() + "")) {
|
//不存在于权限集合表示不需要输出
|
iterator.remove();
|
}
|
}
|
}
|
return refFormIdList;
|
}
|
|
/**
|
* 增加对下单，采购订单下单的分别处理
|
* @param request
|
* @param refFormIdList
|
* @param targetFormid
|
* @return
|
*/
|
public List<Gfrom> procFormLimitV2(HttpServletRequest request, List<Gfrom> refFormIdList,Integer targetFormid) {
|
//---取出当前用户的功能号权限集合
|
final Map attribute = (Map) request.getSession().getAttribute(SessionKey.PERSSION);
|
Iterator<Gfrom> iterator = refFormIdList.iterator();
|
boolean isAdmin=false;//是否管理员
|
String supperUser= (String) request.getSession().getAttribute(SessionKey.SUPPER_USER);
|
if(StringUtils.isNotBlank(supperUser)){
|
if(Integer.parseInt(supperUser)==1){
|
isAdmin=true;
|
}
|
}
|
while (iterator.hasNext()) {
|
Gfrom gfrom = iterator.next();
|
if(targetFormid==null) {
|
//表示调用不是采购下单的另一个下单功能，则就算有生成130301权限也需要排除
|
if (130301==gfrom.getFormid().intValue()||(!isAdmin&&!attribute.containsKey(gfrom.getFormid() + ""))
|
) {
|
//不存在于权限集合表示不需要输出
|
iterator.remove();
|
}
|
}else{
|
//执行是采购订单下单,则除了自己(采购订单)，其他的都要排除
|
if(gfrom.getFormid()==null||gfrom.getFormid().intValue()!=targetFormid.intValue()){
|
iterator.remove();
|
}
|
}
|
}
|
return refFormIdList;
|
}
|
public Map getMatCode(String matCode, HttpServletRequest request, HttpServletResponse response) {
|
HttpSession session = request.getSession();
|
String userCode = (session.getAttribute(SessionKey.USERCODE) == null ? ""
|
: (String) session.getAttribute(SessionKey.USERCODE));
|
String openId = (session.getAttribute(SessionKey.WEIXIN_OPENID) == null ? "" : (String) session.getAttribute(SessionKey.WEIXIN_OPENID));
|
//String wx = (session.getAttribute(SessionKey.WEIXIN_FROM) == null ? "" : (String) session.getAttribute(SessionKey.WEIXIN_FROM));
|
|
boolean isMoblieBrowser = SettingKey.isMoblieBrowser(request);
|
|
//depositDocCode 和 depositRowId 表示取 维护抢购订金分组 710170 里的明细
|
String depositDocCode = request.getParameter("DepositDocCode");
|
String depositRowId = request.getParameter("DepositRowId");
|
|
|
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
//SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
SettingEntity settingEntity = null;
|
|
|
try {
|
DataSourceEntity dataSourceEntity = MultiDataSource.getDataSourceMap(request);
|
SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());// 切换数据源
|
settingEntity = settingIfc.getSettingEntity(request);
|
|
// 取网店 shopcccode
|
ShopCcCodeEntity shopCcCodeEntity = ShopCcCode.getShopCcCode(settingEntity, request);
|
|
|
String hostUrl = SettingKey.getHostUrl(request);
|
// 将微信corpid组装成url
|
String wxQueryString = SettingKey.getQueryStringByWx(request);
|
|
// 商品编号信息
|
MatCodeEntity matCodeEntity = qrServiceIfc.getMatCodeForAPP(matCode, shopCcCodeEntity.getShopCcCode());
|
if (matCodeEntity == null) {
|
throw new ApplicationException("商品编号【" + matCode + "】不存在");
|
|
}
|
// 商品附加图片信息
|
List<MatCodeImageEntity> matImageList = matCodeImageIfc.getMatCodeImage(matCode);
|
|
// 商品评价条数
|
Integer matReviewCount = 0;
|
matReviewCount = matCodeEntity.getRatingCount();
|
|
// 消费积份
|
Integer points = matPointsIfc.getMatPoints(matCode, null);
|
|
// 商品促销活动关联表
|
List<MatDiscountEntity> matDisList = matDiscountIfc.getMatDiscount(matCode, null);
|
|
// 取处理过的商品描述
|
String matDmatDescription = imgData.getDescriptionByNewImgLink(matCodeEntity.getDescription(), request);
|
|
// 购物车
|
// cartList = cartIfc.getCarts(userCode, sessionId,openId,cltCode);
|
|
// 关注商品资料
|
// matCodeList =
|
// matCodeIfc.getMatCodesByWishList(userCode,sessionId,openId,cltCode,shopCcCode);
|
// List<MatCodeEntity> matCodeCompareList =
|
// matCodeIfc.getMatCodesByCompare(userCode,sessionId,openId,cltCode,shopCcCode);
|
|
// 显示分享信息
|
// ShareEntity shareEntity=shareIfc.getShareEntity();
|
|
// 是否有选项要显示
|
boolean hasMatAttr = true;// matAttrIfc.hasMatAttr(matCode);
|
|
Map jsonObject = new HashMap();
|
|
String url = "", externalURL = "";
|
String imageHostUrl = shoppingImageDataIfc.getImageHostUrl(hostUrl);
|
if (matCodeEntity.getExternalURL() != null && !"".equals(matCodeEntity.getExternalURL())) {
|
externalURL = matCodeEntity.getExternalURL();
|
if (!externalURL.startsWith("http")) externalURL = imageHostUrl + externalURL;
|
String separator = "?";
|
int pos = externalURL.indexOf("?");
|
if (pos > 0) separator = "&";
|
externalURL = externalURL + (wxQueryString == null || "".equals(wxQueryString) ? "" : separator + wxQueryString);
|
} else {
|
url = imageHostUrl + SettingKey.getMatCodeUrl("", matCodeEntity.getMatCode(), isMoblieBrowser)
|
+ (wxQueryString == null || "".equals(wxQueryString) ? "" : "&" + wxQueryString);
|
}
|
|
jsonObject.put("ExternalUrl", externalURL);
|
//jsonObject.addProperty("url", url);
|
jsonObject.put("MatCodeUrl", url);
|
//主图片
|
jsonObject.put("PhotoPath",
|
SettingKey.getUrl(imageHostUrl, matCodeEntity.getPhotoPathUrl(), dataSourceEntity.getDbId() + "", null)
|
//+ (wxQueryString == null || "".equals(wxQueryString) ? "" : "?" + wxQueryString)
|
);
|
jsonObject.put("PhotoUnid", matCodeEntity.getPhotoPath());
|
// 主图片与多图片合并
|
List<String> subImageListArray = new ArrayList<>();
|
if (matCodeEntity.getPhotoPath() != null && !matCodeEntity.getPhotoPath().equals("")) {
|
subImageListArray.add(SettingKey.getUrl(imageHostUrl, matCodeEntity.getPhotoPathUrl(), dataSourceEntity.getDbId() + "", null));
|
// subImageListArray.add(imgData.getImageUrl(matCodeEntity.getPhotoPath(), settingEntity.getImageProductWidth(),
|
// settingEntity.getImageProductHeight(), settingEntity.isShowProductOrgImage(),
|
// settingEntity.isFromCached(), request)
|
// //+ (wxQueryString == null || "".equals(wxQueryString) ? "" : "?" + wxQueryString)
|
// );
|
}
|
//主图片与多图片合并
|
// for (int k = 0; matImageList != null && k < matImageList.size(); k++) {
|
// MatCodeImageEntity matImage = matImageList.get(k);
|
// subImageListArray.add(imgData.getImageUrl(matImage.getImage(), settingEntity.getImagePopupWidth(),
|
// settingEntity.getImagePopupHeight(), settingEntity.isShowPopupOrgImage(),
|
// settingEntity.isFromCached(), request)
|
// //+ (wxQueryString == null || "".equals(wxQueryString) ? "" : "?" + wxQueryString)
|
// );
|
// }
|
|
if (matCodeEntity.getImagesUrl() != null && !matCodeEntity.getImagesUrl().equals("")) {
|
String images[] = matCodeEntity.getImagesUrl().split(";");
|
for (int j = 0; j < images.length; j++) {
|
subImageListArray.add(SettingKey.getUrl(imageHostUrl, images[j], dataSourceEntity.getDbId() + "", null));
|
}
|
}
|
|
jsonObject.put("images", subImageListArray);
|
String cltCode = (String) session.getAttribute(SettingKey.CLTCODE);
|
|
//是否显示评价
|
jsonObject.put("isShowReviewStatus", settingEntity.getReviewStatus());
|
// 商品评价
|
if (settingEntity.getReviewStatus()) {
|
|
}
|
|
if (settingEntity.isShowBrand()) {
|
jsonObject.put("Brand", matCodeEntity.getBrand());
|
}
|
|
jsonObject.put("MatName", matCodeEntity.getMatName());
|
jsonObject.put("MatCode", matCodeEntity.getMatCode());
|
jsonObject.put("startupSkuParameters", matCodeEntity.isStartupSkuParameters());
|
jsonObject.put("ShopMatCode", matCodeEntity.getShopMatCode());
|
jsonObject.put("isShowMatCode", settingEntity.isShowMatCode());
|
jsonObject.put("isShowMatName", settingEntity.isShowMatName());
|
jsonObject.put("isShowSpecial", settingEntity.isShowSpecial());
|
jsonObject.put("isShowPrice", settingEntity.isShowPrice());
|
jsonObject.put("isShowPoints", settingEntity.isShowPoints());
|
jsonObject.put("isShowBrand", settingEntity.isShowBrand());
|
jsonObject.put("StockDisplay", settingEntity.getStockDisplay());
|
|
jsonObject.put("isStartupMatName2", settingEntity.isStartupMatName2());
|
jsonObject.put("isStartupMatName3", settingEntity.isStartupMatName3());
|
jsonObject.put("isStartupMatName4", settingEntity.isStartupMatName4());
|
|
if (settingEntity.isShowSpecial()) {
|
jsonObject.put("Special", matCodeEntity.getSpecial());
|
}
|
|
if (settingEntity.isStartupMatName2()) {
|
jsonObject.put("MatName2Label", settingEntity.getMatName2Label());
|
jsonObject.put("MatName2", matCodeEntity.getMatName2());
|
}
|
|
if (settingEntity.isStartupMatName3()) {
|
jsonObject.put("MatName3Label", settingEntity.getMatName3Label());
|
jsonObject.put("MatName3", matCodeEntity.getMatName3());
|
}
|
|
if (settingEntity.isStartupMatName4()) {
|
jsonObject.put("MatName4Label", settingEntity.getMatName4Label());
|
jsonObject.put("MatName4", matCodeEntity.getMatName4());
|
}
|
|
if (settingEntity.isShowPoints()) {
|
jsonObject.put("Points", matCodeEntity.getPoints()); // 奖励积分
|
jsonObject.put("SalesPoints", points + ""); // 消费积分
|
}
|
|
if (matCodeEntity.getStockStatusName() != null && !"".equals(matCodeEntity.getStockStatusName())) {
|
jsonObject.put("StockStatusName", matCodeEntity.getStockStatusName());
|
}
|
|
if (settingEntity.isShowPrice()) {
|
|
MatPriceEntity matPriceEntity = matPriceIfc.getMatPrice(matCodeEntity.getMatCode(), cltCode, null);
|
Double price = matPriceEntity.getPrice();
|
jsonObject.put("Price", price); // 实际价格，此价格可能低于“标价”
|
jsonObject.put("SalesPrice", matCodeEntity.getSalesPrice()); // 标价
|
jsonObject.put("purchasePrice", matCodeEntity.getPurchasePrice()); // 采购单价
|
|
CurrencyEntity currencyEntity = new CurrencyEntity(request);
|
jsonObject.put("Currency", currencyEntity == null ? "" : currencyEntity.getCurrency());
|
jsonObject.put("CurrencySign", currencyEntity == null ? "" : currencyEntity.getCurrencySign());
|
}
|
jsonObject.put("Quantity", matCodeEntity.getQuantity());
|
|
List<Map> matDisListJsonArray = new ArrayList<>();
|
// 商品促销活动关联表
|
for (int i = 0; matDisList != null && i < matDisList.size(); i++) {
|
Map subJsonObject = new HashMap();
|
subJsonObject.put("digit", matDisList.get(i).getDigit());
|
subJsonObject.put("price", matDisList.get(i).getPrice());
|
matDisListJsonArray.add(subJsonObject);
|
}
|
|
jsonObject.put("matdiscount", matDisListJsonArray);
|
|
// 获取商品选项(如：数量，日期。。。）
|
// matComponentIfc.getMatComponent(matCodeEntity, matCode,
|
// currencyEntityProd.getMemo(),isMoblieBrowser,false) ;
|
|
// 评星级分
|
if (settingEntity.isShowRatingOnHomePage()) {
|
jsonObject.put("RatingAvg", matCodeEntity.getRatingAvg() + "");
|
}
|
|
// 评价条数
|
if (settingEntity.getReviewStatus()) {
|
jsonObject.put("ReviewCount", (matReviewCount == null ? 0 : matReviewCount) + "");
|
}
|
|
// 商品描述
|
jsonObject.put("Description", matDmatDescription);
|
//是否显示属性
|
jsonObject.put("isShowMatAttr", hasMatAttr);
|
//最小起订数量
|
jsonObject.put("Mininum", matCodeEntity.getMininum());
|
|
//商品属性
|
List<Map> matAttrGroupJsonArray = new ArrayList<>();
|
if (hasMatAttr) {
|
List<MatAttrGroupEntity> matAttrGroupList = matAttrIfc.getMatAttrGroupByMatCode(matCode);
|
for (int j = 0; matAttrGroupList != null && j < matAttrGroupList.size(); j++) {
|
MatAttrGroupEntity matAttrGroupEntity = matAttrGroupList.get(j);
|
Map matAttrGroupJsonObject = new HashMap();
|
matAttrGroupJsonObject.put("AttrGroupName", matAttrGroupEntity.getAttrGroupName());
|
|
List<Map> matAttrJsonArray = new ArrayList<>();
|
List<MatAttrEntity> matAttrList = matAttrIfc.getMatAttr(matCode, matAttrGroupEntity.getAttrGroupId());
|
for (int i = 0; matAttrList != null && i < matAttrList.size(); i++) {
|
MatAttrEntity matAttr = matAttrList.get(i);
|
Map matAttrJsonObject = new HashMap();
|
matAttrJsonObject.put("AttrName", matAttr == null ? "" : matAttr.getAttrName());
|
matAttrJsonObject.put("Text", matAttr == null ? "" : matAttr.getText());
|
|
matAttrJsonArray.add(matAttrJsonObject);
|
}
|
matAttrGroupJsonObject.put("Attrs", matAttrJsonArray);
|
matAttrGroupJsonArray.add(matAttrGroupJsonObject);
|
}
|
|
}
|
jsonObject.put("matattr", matAttrGroupJsonArray);
|
// 相关商品资料集合 调用也可实现,只是要多发一次请求：
|
// http://mp.onbus.cn/shopping/getMatCodeList.do?matcode=xxx&fromdata=3
|
// 获取相关商品资料集合
|
List<MatCodeEntity> matRelList = matCodeIfc.getMatCodesByRelMat(matCode, shopCcCodeEntity.getShopCcCode(), cltCode,openId,0);
|
List<Map> relMatJsonArray = new ArrayList<>();
|
for (int i = 0; matRelList != null && i < matRelList.size(); i++) {
|
MatCodeEntity relMatCodeEntity = matRelList.get(i);
|
Map subJsonObject = new HashMap();
|
String relMatCodeUrl = "";
|
if (relMatCodeEntity.getExternalURL() != null && !"".equals(relMatCodeEntity.getExternalURL())) {
|
relMatCodeUrl = relMatCodeEntity.getExternalURL();
|
} else {
|
relMatCodeUrl = hostUrl
|
+ SettingKey.getMatCodeUrl("", relMatCodeEntity.getMatCode(), isMoblieBrowser)
|
+ (wxQueryString == null || "".equals(wxQueryString) ? "" : "&" + wxQueryString);
|
}
|
subJsonObject.put("url", relMatCodeUrl);
|
subJsonObject.put("PhotoPath",
|
SettingKey.getUrl(imageHostUrl, relMatCodeEntity.getPhotoPathUrl(), dataSourceEntity.getDbId() + "", null)
|
// + (wxQueryString == null || "".equals(wxQueryString) ? "" : "?" + wxQueryString)
|
);
|
|
subJsonObject.put("MatCode", relMatCodeEntity.getMatCode());
|
subJsonObject.put("isShowMatCode", settingEntity.isShowMatCode());
|
subJsonObject.put("isShowMatName", settingEntity.isShowMatName());
|
subJsonObject.put("isShowSpecial", settingEntity.isShowSpecial());
|
subJsonObject.put("isShowPrice", settingEntity.isShowPrice());
|
subJsonObject.put("isShowPoints", settingEntity.isShowPoints());
|
subJsonObject.put("isShowBrand", settingEntity.isShowBrand());
|
subJsonObject.put("StockDisplay", settingEntity.getStockDisplay());
|
|
if (settingEntity.isShowMatName()) {
|
subJsonObject.put("MatName", relMatCodeEntity.getMatName());
|
}
|
if (settingEntity.isShowDescription()) {
|
subJsonObject.put("Description", HtmlUtil.getShortDescription(
|
settingEntity.getProductDescriptionLength(), relMatCodeEntity.getDescription()));
|
}
|
if (settingEntity.isShowRatingOnHomePage()) {
|
subJsonObject.put("RatingAvg", matCodeEntity.getRatingAvg() + "");
|
}
|
if (settingEntity.isShowPrice()) {
|
|
MatPriceEntity matPriceEntity = matPriceIfc.getMatPrice(relMatCodeEntity.getMatCode(), cltCode, null);
|
Double price = matPriceEntity.getPrice();
|
subJsonObject.put("Price", price); // 实际价格，此价格可能低于“标价”
|
subJsonObject.put("SalesPrice", relMatCodeEntity.getSalesPrice()); // 标价
|
subJsonObject.put("purchasePrice", relMatCodeEntity.getPurchasePrice()); // 采购单价
|
|
CurrencyEntity currencyEntity = new CurrencyEntity(request);
|
subJsonObject.put("Currency", currencyEntity == null ? "" : currencyEntity.getCurrency());
|
subJsonObject.put("CurrencySign", currencyEntity == null ? "" : currencyEntity.getCurrencySign());
|
}
|
relMatJsonArray.add(subJsonObject);
|
}
|
jsonObject.put("relmatcode", relMatJsonArray);
|
|
//取 维护抢购订金分组 明细
|
if (depositDocCode != null && !"".equals(depositDocCode) && depositRowId != null && !"".equals(depositRowId)) {
|
PrepaidDepositDetailEntity prepaidDepositDetailEntity = prepaidDepositIfc.getPrepaidDepositDetail(depositDocCode, depositRowId, cltCode);
|
jsonObject.put("DepositAmount", prepaidDepositDetailEntity != null ? prepaidDepositDetailEntity.getDepositAmount() : 0);
|
jsonObject.put("ItemMemo", prepaidDepositDetailEntity != null ? prepaidDepositDetailEntity.getItemMemo() : "");
|
jsonObject.put("DepositDescription",
|
imgData.getImageUrl(prepaidDepositDetailEntity != null ? prepaidDepositDetailEntity.getDepositDescription() : "", settingEntity.getImageProductWidth(),
|
settingEntity.getImageProductHeight(), settingEntity.isShowProductOrgImage(),
|
settingEntity.isFromCached(), request)
|
);
|
jsonObject.put("isPaidDeposit", prepaidDepositDetailEntity != null && prepaidDepositDetailEntity.isPaidDeposit()); //抢购订金分组 里的 rowid ，功能号 710170
|
}
|
/*
|
//未使用的优惠卷
|
List<CouponEntity> couponList = couponIfc.getCouponList(cltCode, openId, matCode, false, wx, shopCcCodeEntity.getShopCcCode());
|
JsonArray couponListJsonArray = new JsonArray();
|
for (int i = 0; couponList != null && i < couponList.size(); i++) {
|
CouponEntity couponEntity = couponList.get(i);
|
JsonObject couponEntityJsonObject = new JsonObject();
|
couponEntityJsonObject.addProperty("CouponName", couponEntity.getCouponName()); //使用范围
|
couponEntityJsonObject.addProperty("CouponDocCode", couponEntity.getCouponDocCode()); //优惠券单号
|
couponEntityJsonObject.addProperty("CouponCode", couponEntity.getCouponCode()); //优惠券代码
|
couponEntityJsonObject.addProperty("Type", couponEntity.getType()); //优惠劵类型: 1 折扣（%） , 2 固定金额
|
couponEntityJsonObject.addProperty("Discount", couponEntity.getDiscount()); //优惠折扣（%）
|
couponEntityJsonObject.addProperty("SufficeAmount", couponEntity.getSufficeAmount()); //满多少金额可用
|
couponEntityJsonObject.addProperty("Total", couponEntity.getTotal()); //优惠金额
|
//couponStatus : //0 正常:可以抢 ; 1 已经抢完 ; 2 未开抢 ; 3 已经抢过了，不能重复抢 ; 4 已经提醒(微信模板消息提醒)
|
couponEntityJsonObject.addProperty("Status", couponEntity.getCouponStatus());
|
couponEntityJsonObject.addProperty("UsesTotal", couponEntity.getUsesTotal()); //本优惠卷总张数
|
couponEntityJsonObject.addProperty("UsedTimes", couponEntity.getUsedTimes()); //本优惠卷已抢的数量
|
|
couponEntityJsonObject.addProperty("BalanceSecond", couponEntity.getBalanceSecond()); //抢券开始时间余下的秒数，负数表示倒计时早已结束
|
couponEntityJsonObject.addProperty("DateStart", couponEntity.getDateStart() == null ? "" : sdf2.format(couponEntity.getDateStart())); //抢券开始时间
|
couponEntityJsonObject.addProperty("DateEnd", couponEntity.getDateEnd() == null ? "" : sdf2.format(couponEntity.getDateEnd())); //抢券结束时间
|
|
couponEntityJsonObject.addProperty("EffectiveDateStart", couponEntity.getEffectiveDateStart() == null ? "" : sdf.format(couponEntity.getEffectiveDateStart())); //有效使用开始期
|
couponEntityJsonObject.addProperty("EffectiveDateEnd", couponEntity.getEffectiveDateEnd() == null ? "" : sdf.format(couponEntity.getEffectiveDateEnd())); //有效使用结束期
|
couponEntityJsonObject.addProperty("Photo", imgData.getImageUrl(couponEntity.getPhoto(), 120, 120, settingEntity.isShowPopupOrgImage(), settingEntity.isFromCached(), request));
|
couponEntityJsonObject.addProperty("BannerImage", imgData.getImageUrl(couponEntity.getBannerImage(), settingEntity.getImageBannerWidth(), settingEntity.getImageBannerHeight(), settingEntity.isShowBannerOrgImage(), settingEntity.isFromCached(), request));
|
|
//已抢%
|
int progressRate = (couponEntity.getUsesTotal() == 0 ? 0 : couponEntity.getUsedTimes() * 100 / couponEntity.getUsesTotal());
|
couponEntityJsonObject.addProperty("ProgressRate", progressRate); //已抢进度%
|
couponListJsonArray.add(couponEntityJsonObject);
|
}
|
json.add("CouponList", couponListJsonArray);
|
|
*/
|
|
//----------获取 sku 参数，用于“加入购物车” 或“立即购买” 时弹出选择,Added by Johns Wang,2021-01-30
|
List<Map> skuMatCodeJsonArray = new ArrayList<>();
|
SkuMatCodeEntity skuMatCodeEntity=null;
|
List<Map> skuParameterJsonArray = new ArrayList<>();
|
if(matCodeEntity.isStartupSkuParameters()) {
|
List<SkuParameterEntity> skuParameterList = matCodeIfc.getSkuParameter(matCodeEntity.getMatCode(), shopCcCodeEntity.getShopCcCode(),
|
null, null, null, null, null, null, null, null, null, null);
|
skuMatCodeEntity = matCodeIfc.getSkuMatCodeByMatCode(matCodeEntity.getMatCode(), openId);
|
|
|
// 根据skuSetId去重,并按 SkuSetSort 排序输出
|
List<SkuParameterEntity> skuSetList = skuParameterList.stream().collect(
|
Collectors.collectingAndThen(
|
Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(SkuParameterEntity::getSkuSetId))), ArrayList::new)
|
);
|
for (int i = 0; skuSetList != null && i < skuSetList.size(); i++) {
|
Map skuSetEntityJsonObject = new HashMap();
|
Integer skuSetId = skuSetList.get(i).getSkuSetId();
|
skuSetEntityJsonObject.put("skuSetSort", skuSetList.get(i).getSkuSetSort());
|
skuSetEntityJsonObject.put("skuSetId", skuSetId);
|
skuSetEntityJsonObject.put("skuSetName", skuSetList.get(i).getSkuSetName());
|
List<SkuParameterEntity> skuList = skuParameterList.stream().filter(s -> s.getSkuSetId().intValue() == skuSetId.intValue()).collect(Collectors.toList());
|
List<Map> skuListJsonArray = new ArrayList<>();
|
for (int j = 0; skuList != null && j < skuList.size(); j++) {
|
Map skuEntityJsonObject = new HashMap();
|
//skuEntityJsonObject.addProperty("skuSetId", skuList.get(j).getSkuSetId());
|
skuEntityJsonObject.put("skuSort", skuList.get(j).getSkuSort());
|
skuEntityJsonObject.put("skuId", skuList.get(j).getSkuId());
|
skuEntityJsonObject.put("skuName", skuList.get(j).getSkuName());
|
skuEntityJsonObject.put("isEnableSelection", skuList.get(j).isEnableSelection());
|
skuListJsonArray.add(skuEntityJsonObject);
|
}
|
skuSetEntityJsonObject.put("skuList", skuListJsonArray);
|
skuParameterJsonArray.add(skuSetEntityJsonObject);
|
}
|
}
|
jsonObject.put("SkuParameterList", skuParameterJsonArray);
|
|
if (skuMatCodeEntity != null) {
|
Map skuEntityJsonObject = new HashMap();
|
skuEntityJsonObject.put("skuId1", skuMatCodeEntity.getSkuId1());
|
skuEntityJsonObject.put("skuName1", skuMatCodeEntity.getSkuName1());
|
skuEntityJsonObject.put("skuId2", skuMatCodeEntity.getSkuId2());
|
skuEntityJsonObject.put("skuName2", skuMatCodeEntity.getSkuName2());
|
skuEntityJsonObject.put("skuId3", skuMatCodeEntity.getSkuId3());
|
skuEntityJsonObject.put("skuName3", skuMatCodeEntity.getSkuName3());
|
skuEntityJsonObject.put("skuId4", skuMatCodeEntity.getSkuId4());
|
skuEntityJsonObject.put("skuName4", skuMatCodeEntity.getSkuName4());
|
skuEntityJsonObject.put("skuId5", skuMatCodeEntity.getSkuId5());
|
skuEntityJsonObject.put("skuName5", skuMatCodeEntity.getSkuName5());
|
skuEntityJsonObject.put("skuId6", skuMatCodeEntity.getSkuId6());
|
skuEntityJsonObject.put("skuName6", skuMatCodeEntity.getSkuName6());
|
skuEntityJsonObject.put("skuId7", skuMatCodeEntity.getSkuId7());
|
skuEntityJsonObject.put("skuName7", skuMatCodeEntity.getSkuName7());
|
skuEntityJsonObject.put("skuId8", skuMatCodeEntity.getSkuId8());
|
skuEntityJsonObject.put("skuName8", skuMatCodeEntity.getSkuName8());
|
skuEntityJsonObject.put("skuId9", skuMatCodeEntity.getSkuId9());
|
skuEntityJsonObject.put("skuName9", skuMatCodeEntity.getSkuName9());
|
skuEntityJsonObject.put("skuId10", skuMatCodeEntity.getSkuId10());
|
skuEntityJsonObject.put("skuName10", skuMatCodeEntity.getSkuName10());
|
skuEntityJsonObject.put("MatCode", skuMatCodeEntity.getMatCode());
|
skuEntityJsonObject.put("MatName", skuMatCodeEntity.getMatName());
|
skuEntityJsonObject.put("Special", skuMatCodeEntity.getSpecial());
|
skuEntityJsonObject.put("PhotoPath", skuMatCodeEntity.getPhotoPath());
|
skuMatCodeJsonArray.add(skuEntityJsonObject);
|
}
|
jsonObject.put("SkuMatCodeList", skuMatCodeJsonArray);
|
|
|
return jsonObject;
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
throw new ApplicationException(this.getErrorMsg(e));
|
} finally {
|
SpObserver.setDBtoInstance();
|
}
|
}
|
|
}
|
