package com.ibeetl.admin.console.service;
|
|
import com.google.gson.Gson;
|
import com.ibeetl.admin.console.dao.OperateManageDao;
|
import com.ibeetl.admin.console.dao.SettingConsoleDao;
|
import com.ibeetl.admin.console.model.*;
|
import com.ibeetl.admin.console.util.DoubleUtil;
|
import com.ibeetl.admin.core.entity.CoreSetMoney;
|
import com.ibeetl.admin.core.entity.CoreUser;
|
import com.ibeetl.admin.core.entity.XzxCityPartner;
|
import com.ibeetl.admin.core.service.CoreBaseService;
|
import com.ibeetl.admin.core.service.CorePlatformService;
|
import com.ibeetl.admin.core.web.JsonResult;
|
import org.apache.commons.lang3.StringUtils;
|
import org.beetl.sql.core.engine.PageQuery;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
@Service
|
@Transactional
|
public class OperateManageApiService extends CoreBaseService<CoreSetMoney> {
|
|
Logger log = LoggerFactory.getLogger(this.getClass());
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
@Autowired
|
OperateManageDao operateManageDao;
|
@Autowired
|
SettingConsoleDao settingConsoleDao;
|
@Autowired
|
RedisService redisService;
|
@Autowired
|
XzxCityPartnerService cityPartnerService;
|
@Autowired
|
CorePlatformService platformService;
|
|
public List<Map<String, Object>> queryCityByPartnerId() {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
List<String> cityIds = operateManageDao.queryCityByPartnerId(partnerIds);
|
List<Map<String, Object>> list = operateManageDao.queryAreaByCityIds(cityIds);
|
return list;
|
}
|
|
public Map<String, Object> querOperaIteml(ItemModel item) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
//item.setPartnerIds(partnerIds);
|
if (null != partnerIds && partnerIds.size() > 0) {
|
List<String> townIds = cityPartnerService.queryTownIdsByPartnerId(partnerIds.get(0));
|
item.setTownIdList(townIds);
|
}
|
Map<String, Object> map = new HashMap<>();
|
int p = item.getPageNum();
|
p = (p - 1) * item.getLimitNum();
|
item.setPageNum(p);
|
List<ItemModel> list = operateManageDao.queryOperaIteml(item);
|
for (ItemModel itemModel : list) {
|
String townId = itemModel.getCityId();
|
if (null != townId && !"".equals(townId)) {
|
Map<String, Object> objmap = operateManageDao.queryCityByTownId(townId);
|
String cityId = objmap.get("cid").toString();
|
String pid = objmap.get("pid").toString();
|
|
List<List<String>> resList = new ArrayList<>();
|
List<String> detailList = new ArrayList<>();
|
detailList.add(pid);
|
detailList.add(cityId);
|
detailList.add(townId);
|
resList.add(detailList);
|
itemModel.setResultArea(resList);
|
|
}
|
|
}
|
map.put("data", list);
|
map.put("count", operateManageDao.queryOperaItemlCount(item));
|
map.put("code", 0);
|
return map;
|
}
|
|
public Map<String, Object> queryPackageOperaIteml(ItemModel item) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
item.setPartnerIds(partnerIds);
|
Map<String, Object> map = new HashMap<>();
|
int p = item.getPageNum();
|
p = (p - 1) * item.getLimitNum();
|
item.setPageNum(p);
|
List<ItemModel> list = operateManageDao.queryOperaIteml1(item);
|
map.put("data", list);
|
map.put("count", operateManageDao.queryOperaItemlCount1(item));
|
map.put("code", 0);
|
return map;
|
}
|
|
@Transactional(rollbackFor = SettingConsoleService.RollbackException.class)
|
public Map<String, Object> addOperateParent(ItemModel item) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
CoreUser user = platformService.getCurrentUser();
|
item.setPartnerId(user.getId() + "");
|
}
|
Map<String, Object> map = new HashMap<>();
|
item.setItemType(System.currentTimeMillis() + "" + (int) (Math.random() * (10000 - 10) + 10));
|
item.setCreateTime(sdf.format(new Date()));
|
// 对排序字段进行处理
|
setSort(item);
|
List<String> townIdList = item.getTownIdList();
|
int i = 0;
|
for (String townId : townIdList) {
|
item.setCityId(townId);
|
i = settingConsoleDao.insertItemOperate(item);
|
}
|
setSortAggin(item);
|
map.put("count", i);
|
map.put("code", 0);
|
return map;
|
}
|
|
@Transactional(rollbackFor = SettingConsoleService.RollbackException.class)
|
public Map<String, Object> addOperateParent1(ItemModel item) {
|
//CoreUser user = platformService.getCurrentUser();
|
//item.setPartnerId(item.getPackageId().getId()+"");
|
Map<String, Object> map = new HashMap<>();
|
item.setItemType(System.currentTimeMillis() + "" + (int) (Math.random() * (10000 - 10) + 10));
|
item.setCreateTime(sdf.format(new Date()));
|
// 对排序字段进行处理
|
setSort1(item);
|
int i = settingConsoleDao.insertItemOperate1(item);
|
setSortAggin1(item);
|
// updateItemForRedis();
|
//redisService.remove("environmentalInfoList");
|
//redisService.remove("environmentalInfoListNew");
|
//redisService.remove("xzx:sys:category");
|
|
map.put("count", i);
|
map.put("code", 0);
|
return map;
|
}
|
|
void setSort1(ItemModel item) {
|
ItemModel im = new ItemModel();
|
im.setLimit(1000);
|
im.setPackageId(item.getPackageId());
|
List<ItemModel> list = settingConsoleDao.querIteml1(im);
|
log.info("------list.size() : {} -----", list.size());
|
// 找到原始的sort数据
|
int originalSort = item.getSort();
|
|
for (ItemModel imx : list) {
|
if (originalSort <= imx.getSort()) {
|
imx.setSort(imx.getSort() + 1);
|
}
|
}
|
for (ItemModel imx : list) {
|
settingConsoleDao.updateItem1(imx);
|
}
|
}
|
|
void setSort(ItemModel item) {
|
ItemModel im = new ItemModel();
|
im.setLimit(1000);
|
im.setParentId(item.getParentId());
|
List<ItemModel> list = settingConsoleDao.querIteml(im);
|
log.info("------list.size() : {} -----", list.size());
|
// 找到原始的sort数据
|
int originalSort = item.getSort();
|
|
for (ItemModel imx : list) {
|
if (originalSort <= imx.getSort()) {
|
imx.setSort(imx.getSort() + 1);
|
}
|
}
|
for (ItemModel imx : list) {
|
settingConsoleDao.updateItem(imx);
|
}
|
}
|
|
void setSortAggin(ItemModel item) {
|
ItemModel im = new ItemModel();
|
im.setLimit(1000);
|
im.setParentId(item.getParentId());
|
List<ItemModel> list = settingConsoleDao.querIteml(im);
|
list.sort((x, y) -> Integer.compare(x.getSort(), y.getSort()));
|
int f = 1;
|
for (ItemModel itemModel : list) {
|
itemModel.setSort(f++);
|
}
|
for (ItemModel itemModel : list) {
|
settingConsoleDao.updateItem(itemModel);
|
}
|
}
|
|
void setSortAggin1(ItemModel item) {
|
ItemModel im = new ItemModel();
|
im.setLimit(1000);
|
im.setParentId(item.getParentId());
|
List<ItemModel> list = settingConsoleDao.querIteml1(im);
|
list.sort((x, y) -> Integer.compare(x.getSort(), y.getSort()));
|
int f = 1;
|
for (ItemModel itemModel : list) {
|
itemModel.setSort(f++);
|
}
|
for (ItemModel itemModel : list) {
|
settingConsoleDao.updateItem1(itemModel);
|
}
|
}
|
|
/**
|
* 更新redis里面的数据
|
*/
|
public void updateItemForRedis() {
|
List<ItemModel> list = operateManageDao.queryOperaItemAll();
|
list = parentUtils(list);
|
Gson gson = new Gson();
|
String str = gson.toJson(list);
|
redisService.set("environmentalInfoList", str);
|
}
|
|
public void updateItemForRedis1() {
|
List<ItemModel> list = operateManageDao.queryOperaItemAll1();
|
list = parentUtils(list);
|
Gson gson = new Gson();
|
String str = gson.toJson(list);
|
//redisService.set("environmentalInfoList", str);
|
}
|
|
// 递归操作父子结构数据
|
List<ItemModel> parentUtils(List<ItemModel> parentlist) {
|
List<ItemModel> list = new ArrayList<>();
|
for (ItemModel itemModel : parentlist) {
|
if (itemModel.getParentId() == null) {
|
itemModel.setList(childUtils(parentlist, itemModel.getId()));
|
list.add(itemModel);
|
}
|
}
|
log.info("----更新redis里面的分类数据：{}", list);
|
return list;
|
}
|
|
List<ItemModel> childUtils(List<ItemModel> childlist, Long id) {
|
List<ItemModel> list = new ArrayList<>();
|
for (ItemModel itemModel : childlist) {
|
if (itemModel.getParentId() == id) {
|
itemModel.setList(childUtils(childlist, itemModel.getId()));
|
list.add(itemModel);
|
}
|
}
|
return list;
|
}
|
|
public Map<String, Object> delPackageOperateItem(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
ItemModel im = new ItemModel();
|
im.setLimit(10);
|
im.setParentId(item.getId());
|
List<ItemModel> list = settingConsoleDao.querIteml1(im);
|
if (list.size() > 0) {
|
map.put("code", -1);
|
map.put("num", 0);
|
return map;
|
}
|
int i = settingConsoleDao.delItem1(item);
|
map.put("code", 0);
|
map.put("num", i);
|
return map;
|
}
|
|
public Map<String, Object> delOperateItem(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
ItemModel im = new ItemModel();
|
im.setLimit(10);
|
im.setParentId(item.getId());
|
List<ItemModel> list = settingConsoleDao.querIteml(im);
|
if (list.size() > 0) {
|
map.put("code", -1);
|
map.put("num", 0);
|
return map;
|
}
|
int i = settingConsoleDao.delItem(item);
|
// updateItemForRedis();
|
redisService.remove("environmentalInfoList");
|
redisService.remove("environmentalInfoListNew");
|
redisService.remove("xzx:sys:category");
|
map.put("code", 0);
|
map.put("num", i);
|
return map;
|
}
|
|
/**
|
* 更新
|
*
|
* @param item
|
* @return
|
*/
|
@Transactional(rollbackFor = SettingConsoleService.RollbackException.class)
|
public Map<String, Object> updateOperateItem(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
//ItemModel model = operateManageDao.queryItemById(item);
|
String cityId = item.getCityId();
|
//根据区域查询围栏
|
List<OrderModel> orderList = operateManageDao.queryOrderByCityId(cityId);
|
if (null != orderList && orderList.size() > 0) {
|
return null;
|
}
|
// 对排序字段进行处理
|
setSort(item);
|
int i = settingConsoleDao.updateItem(item);
|
setSortAggin(item);
|
|
redisService.remove("environmentalInfoList");
|
redisService.remove("environmentalInfoListNew");
|
//redisService.hdel( "xzx:sys:category", item.getCityId());
|
//redisService.remove("xzx:sys:category");
|
//redisService.remove("");
|
//updateItemForRedis();
|
map.put("code", 0);
|
map.put("num", i);
|
return map;
|
}
|
|
@Transactional(rollbackFor = SettingConsoleService.RollbackException.class)
|
public Map<String, Object> updateOperateItem1(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
// 对排序字段进行处理
|
setSort1(item);
|
int i = settingConsoleDao.updateItem1(item);
|
setSortAggin1(item);
|
map.put("code", 0);
|
map.put("num", i);
|
return map;
|
}
|
|
public Map<String, Object> queryOperateItemList(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
int p = item.getPageNum();
|
p = (p - 1) * item.getLimitNum();
|
item.setPageNum(p);
|
List<ItemModel> list = operateManageDao.queryOperateItemList(item);
|
for (ItemModel obj : list) {
|
obj = queryChildItem(obj);
|
}
|
map.put("data", list);
|
map.put("count", operateManageDao.queryOperateItemCount(item));
|
map.put("code", 0);
|
return map;
|
}
|
|
public Map<String, Object> queryOperateItemList1(ItemModel item) {
|
Map<String, Object> map = new HashMap<>();
|
int p = item.getPageNum();
|
p = (p - 1) * item.getLimitNum();
|
item.setPageNum(p);
|
List<ItemModel> list = operateManageDao.queryOperateItemList1(item);
|
for (ItemModel obj : list) {
|
obj = queryChildItem(obj);
|
}
|
map.put("data", list);
|
map.put("count", operateManageDao.queryOperateItemCount1(item));
|
map.put("code", 0);
|
return map;
|
}
|
|
/**
|
* 无限子类算法（时间有限）
|
*
|
* @param item
|
* @return
|
*/
|
private ItemModel queryChildItem(ItemModel item) {
|
List<ItemModel> child = operateManageDao.queryOperateItemChildren(item);
|
List<ItemModel> childm = new ArrayList<>();
|
for (ItemModel obj : child) {
|
childm.add(obj);
|
}
|
item.setChildren(childm);
|
for (ItemModel cObj : childm) {
|
if (null != cObj.getParentId()) {
|
queryChildItem(cObj);
|
}
|
}
|
return item;
|
}
|
|
|
public Map<String, Object> querySysStorageList(SysStorageApiModel storageModel) {
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
if (null != partnerIds && partnerIds.size() > 0) {
|
String partnerId = partnerIds.get(0);
|
List<String> townIds = cityPartnerService.queryTownIdsByPartnerId(partnerId);
|
storageModel.setTownIds(townIds);
|
}
|
Map<String, Object> m = new HashMap<>();
|
int p = storageModel.getPage();
|
p = (p - 1) * storageModel.getLimit();
|
storageModel.setPage(p);
|
m.put("data", operateManageDao.querySysStorageApiList(storageModel));
|
m.put("count", operateManageDao.querySysStorageApiCount(storageModel));
|
m.put("code", 0);
|
return m;
|
}
|
|
/**
|
* 修改仓库
|
*
|
* @param storageModel
|
* @return
|
*/
|
public int updateSysStorageApi(SysStorageApiModel storageModel) {
|
return operateManageDao.updateSysStorageApi(storageModel);
|
}
|
|
/**
|
* 删除仓库
|
*
|
* @param storageModel
|
* @return
|
*/
|
public int delSysStorageApi(SysStorageApiModel storageModel) {
|
return operateManageDao.delSysStorageApi(storageModel);
|
}
|
|
/**
|
* 添加仓库
|
*
|
* @param storageModel
|
* @return
|
*/
|
public int addSysStorageApi(SysStorageApiModel storageModel) {
|
storageModel.setCreateTime(sdf.format(new Date()));
|
return operateManageDao.addSysStorageApi(storageModel);
|
}
|
|
/**
|
* 查询
|
*
|
* @param bannerModel
|
* @return
|
*/
|
public Map<String, Object> queryBannerApiList(BannerModel bannerModel) {
|
Map<String, Object> map = new HashMap<>();
|
int p = bannerModel.getPage();
|
p = (p - 1) * bannerModel.getLimit();
|
bannerModel.setPage(p);
|
map.put("data", settingConsoleDao.queryBannerList(bannerModel));
|
map.put("count", settingConsoleDao.queryBannerListCount(bannerModel));
|
map.put("code", 0);
|
return map;
|
}
|
|
/**
|
* 添加
|
*
|
* @param bannerModel
|
* @return
|
*/
|
public JsonResult insertBannerApi(BannerModel bannerModel) {
|
CoreUser user = platformService.getCurrentUser();
|
XzxCityPartner partner = cityPartnerService.queryById(user.getId());
|
if (null != partner) {
|
bannerModel.setPartnerId(user.getId() + "");
|
} else {
|
if (null != bannerModel.getCityId() && !"".equals(bannerModel.getCityId())) {
|
partner = cityPartnerService.queryCityPartnerByCityId(bannerModel.getCityId());
|
if (null != partner) {
|
bannerModel.setPartnerId(partner.getId() + "");
|
}
|
}
|
}
|
|
bannerModel.setCreateTime(sdf.format(new Date()));
|
if (settingConsoleDao.insertBanner(bannerModel) > 0) {
|
return JsonResult.success();
|
} else {
|
return JsonResult.failMessage("保存失败");
|
}
|
}
|
|
/**
|
* 更新
|
*
|
* @param bannerModel
|
* @return
|
*/
|
public int updateBannerApi(BannerModel bannerModel) {
|
return settingConsoleDao.updateBanner(bannerModel);
|
}
|
|
/**
|
* 删除
|
*
|
* @param id
|
* @return
|
*/
|
public int delBannerApi(String id) {
|
//redisService.remove();
|
return settingConsoleDao.delBanner(id);
|
}
|
|
/**
|
* 根据条件查询
|
*
|
* @param query
|
*/
|
public void moneySetting(PageQuery<CoreSetMoney> query) {
|
PageQuery<CoreSetMoney> ret = settingConsoleDao.queryByCondtion(query);
|
queryListAfter(ret.getList());
|
}
|
|
@Transactional(rollbackFor = {})
|
public void updateMoneySetting(CoreSetMoney money) {
|
if (!StringUtils.isEmpty(money.getAgentPrice())) {
|
settingConsoleDao.updateAgentPrice(money);
|
}
|
if (!StringUtils.isEmpty(money.getTimeInterval())) {
|
settingConsoleDao.updateTimeInterval(money);
|
}
|
if (!StringUtils.isEmpty(money.getStartTime())) {
|
settingConsoleDao.updateStratTime(money);
|
}
|
if (!StringUtils.isEmpty(money.getEndTime())) {
|
settingConsoleDao.updateEndTime(money);
|
}
|
if (!StringUtils.isEmpty(money.getOverdrawPrice())) {
|
Map<String, Object> m = settingConsoleDao.queryOverdrawPrice();
|
String limitPrice = m.get("configValue").toString();
|
List<String> orderIds = settingConsoleDao.queryRKOrderIds(m.get("configValue").toString(), "1");
|
if (null != orderIds && orderIds.size() > 0) {
|
if (money.getOverdrawPrice().equals(m.get("configValue").toString())) {
|
// 需要更新所有account表的透支额度,但是不更新已经修改过的用户额度
|
money.setWarehousingPrice(DoubleUtil.roundTwo(money.getWarehousingPrice()));
|
money.setOverdrawPrice(DoubleUtil.roundTwo(money.getOverdrawPrice()));
|
settingConsoleDao.updateOverdrawPrice(money);
|
settingConsoleDao.updateAccountOverdrawPrice(money.getOverdrawPrice(), m.get("configValue").toString(), orderIds, null);
|
} else {
|
money.setWarehousingPrice(DoubleUtil.roundTwo(money.getWarehousingPrice()));
|
money.setOverdrawPrice(DoubleUtil.roundTwo(money.getOverdrawPrice()));
|
settingConsoleDao.updateOverdrawPrice(money);
|
settingConsoleDao.updateAccountOverdrawPrice(money.getOverdrawPrice(), m.get("configValue").toString(), orderIds, "1");
|
|
}
|
}
|
|
|
}
|
if (!StringUtils.isEmpty(money.getWarehousingPrice())) {
|
Map<String, Object> m = settingConsoleDao.queryWarehousingPrice();
|
List<String> orderIds = settingConsoleDao.queryRKOrderIds(m.get("configValue").toString(), null);
|
if (null != orderIds && orderIds.size() > 0) {
|
if (money.getOverdrawPrice().equals(m.get("configValue").toString())) {
|
money.setWarehousingPrice(DoubleUtil.roundTwo(money.getWarehousingPrice()));
|
money.setOverdrawPrice(DoubleUtil.roundTwo(money.getOverdrawPrice()));
|
settingConsoleDao.updateWarehousingPrice(money);
|
settingConsoleDao.updateAccountWarehousingPrice(money.getWarehousingPrice(), m.get("configValue").toString(), orderIds, null);
|
|
} else {
|
money.setWarehousingPrice(DoubleUtil.roundTwo(money.getWarehousingPrice()));
|
money.setOverdrawPrice(DoubleUtil.roundTwo(money.getOverdrawPrice()));
|
settingConsoleDao.updateWarehousingPrice(money);
|
settingConsoleDao.updateAccountWarehousingPrice(money.getWarehousingPrice(), m.get("configValue").toString(), orderIds, "1");
|
|
}
|
}
|
|
|
}
|
if (!StringUtils.isEmpty(money.getRechargePrice())) {
|
settingConsoleDao.updateRechargePrice(money);
|
}
|
|
if (!StringUtils.isEmpty(money.getOrderTimeout())) {
|
settingConsoleDao.updateOrderTimeout(money);
|
}
|
if (!StringUtils.isEmpty(money.getOrderTotal())) {
|
settingConsoleDao.updateOrderTotal(money);
|
}
|
|
}
|
|
public UserModel checkUserNameByPhone(String phone, String type) {
|
return operateManageDao.checkUserNameByPhone(phone, type);
|
}
|
}
|
