package com.ishop.merchant.service;
|
|
import com.iplatform.base.service_api.UserAndDeptServiceApi;
|
import com.iplatform.model.to.UserAndDeptTo;
|
import com.iplatform.model.to.UserAndDeptToResult;
|
import com.ishop.merchant.Constants;
|
import com.ishop.model.po.EbMerchant;
|
import com.ishop.model.po.EbMerchantDailyStatement;
|
import com.ishop.model.po.EbMerchantInfo;
|
import com.ishop.model.po.EbMerchantMonthStatement;
|
import com.ishop.model.po.EbShippingTemplates;
|
import com.walker.db.page.GenericPager;
|
import com.walker.infrastructure.time.TimeRange;
|
import com.walker.infrastructure.utils.DateUtils;
|
import com.walker.infrastructure.utils.NumberGenerator;
|
import com.walker.infrastructure.utils.StringUtils;
|
import com.walker.jdbc.service.BaseServiceImpl;
|
import com.walker.web.ResponseValue;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class MerchantServiceImpl extends BaseServiceImpl {
|
|
private UserAndDeptServiceApi userAndDeptServiceApi;
|
|
@Autowired
|
public MerchantServiceImpl(UserAndDeptServiceApi userAndDeptServiceApi){
|
this.userAndDeptServiceApi = userAndDeptServiceApi;
|
}
|
|
public void execOpenMerchant(int id){
|
EbMerchant merchant = new EbMerchant();
|
merchant.setId(id);
|
merchant.setIsSwitch(1);
|
|
this.save(merchant);
|
}
|
|
/**
|
* 更新商户配置信息。
|
* @param merchant
|
* @param merchantInfo
|
* @date 2023-06-09
|
*/
|
public void execUpdateConfigInfo(EbMerchant merchant, EbMerchantInfo merchantInfo){
|
this.save(merchant);
|
this.save(merchantInfo);
|
}
|
|
/**
|
* 平台更新商户基本信息，同步到系统机构。
|
* @param merchant
|
* @param userAndDeptTo
|
* @date 2023--7-20
|
*/
|
public void execUpdateMerchantPlatform(EbMerchant merchant, UserAndDeptTo userAndDeptTo){
|
ResponseValue responseValue = this.userAndDeptServiceApi.execUpdateTopOrgAndAdmin(userAndDeptTo);
|
if(!responseValue.isState()){
|
throw new IllegalStateException("商户机构更新错误：" + responseValue.getMsg());
|
}
|
this.save(merchant);
|
}
|
|
/**
|
* 创建新商户。
|
* @param merchant
|
* @param createType
|
* @param createId
|
* @param userAndDeptTo
|
*/
|
public void execInsertMerchant(EbMerchant merchant, String createType, long createId, UserAndDeptTo userAndDeptTo){
|
// 初始化管理员账号
|
// 初始化系统顶级机构
|
ResponseValue responseValue = this.userAndDeptServiceApi.execInsertTopOrgAndAdmin(userAndDeptTo);
|
if(!responseValue.isState()){
|
throw new IllegalStateException("商户机构创建错误：" + responseValue.getMsg());
|
}
|
|
UserAndDeptToResult userAndDeptToResult = (UserAndDeptToResult) responseValue.getData();
|
|
// int merchantId = this.queryNextId();
|
// 机构生成为int，强制转换即可
|
int merchantId = (int)userAndDeptToResult.getDeptId();
|
int otherId = Integer.parseInt(new StringBuilder(merchantId).append(1).toString());
|
merchant.setId(merchantId);
|
merchant.setCreateId(createId);
|
merchant.setCreateType(createType);
|
merchant.setCreateTime(DateUtils.getDateTimeNumber());
|
merchant.setUpdateTime(merchant.getCreateTime());
|
merchant.setAdminId(userAndDeptToResult.getUserId());
|
this.insert(merchant);
|
|
EbMerchantInfo merchantInfo = new EbMerchantInfo();
|
merchantInfo.setId(merchantId);
|
merchantInfo.setMerId(merchantId);
|
this.insert(merchantInfo);
|
|
// 初始化日/月帐单
|
EbMerchantDailyStatement dailyStatement = new EbMerchantDailyStatement();
|
EbMerchantMonthStatement monthStatement = new EbMerchantMonthStatement();
|
dailyStatement.setId(NumberGenerator.getLongSequenceNumber());
|
dailyStatement.setMerId(merchantId);
|
dailyStatement.setDataDate(DateUtils.getDateForHuman(System.currentTimeMillis()));
|
monthStatement.setId(dailyStatement.getId());
|
monthStatement.setMerId(merchantId);
|
monthStatement.setDataDate(dailyStatement.getDataDate().substring(0, 7));
|
this.insert(dailyStatement);
|
this.insert(monthStatement);
|
|
// 初始化一条全国包邮的运费模板
|
EbShippingTemplates shippingTemplates = new EbShippingTemplates();
|
shippingTemplates.setId(otherId);
|
shippingTemplates.setName(Constants.DEFAULT_NAME);
|
shippingTemplates.setType(Constants.CHARGE_MODE_TYPE_UNKNOWN);
|
shippingTemplates.setAppoint(Constants.APPOINT_TYPE_ALL);
|
shippingTemplates.setSort(999);
|
shippingTemplates.setMerId(merchantId);
|
this.insert(shippingTemplates);
|
}
|
|
/**
|
* 返回商户配置扩展信息。
|
* @param merId
|
* @return
|
* @date 2023-07-04
|
*/
|
public EbMerchantInfo queryMerchantInfo(int merId){
|
EbMerchantInfo info = new EbMerchantInfo();
|
info.setMerId(merId);
|
List<EbMerchantInfo> list = this.select(info);
|
return list.get(0);
|
}
|
|
public EbMerchant queryMerchantByName(String name){
|
EbMerchant ebMerchant = new EbMerchant();
|
ebMerchant.setName(name);
|
ebMerchant.setIsDel(0);
|
List<EbMerchant> list = this.select(ebMerchant);
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
return list.get(0);
|
}
|
public EbMerchant queryMerchantByPhone(String phone){
|
EbMerchant ebMerchant = new EbMerchant();
|
ebMerchant.setPhone(phone);
|
ebMerchant.setIsDel(0);
|
List<EbMerchant> list = this.select(ebMerchant);
|
if(StringUtils.isEmptyList(list)){
|
return null;
|
}
|
return list.get(0);
|
}
|
|
public GenericPager<EbMerchant> queryPageMerchantList(Integer categoryId
|
, Integer typeId, String phone, Boolean isSelf, Boolean isSwitch, TimeRange timeRange, String keywords){
|
Object[] sqlAndParameter = this.combineSqlAndParameter(SQL_QUERY_PREFIX_LIST
|
, categoryId, typeId, phone, isSelf, isSwitch, timeRange, keywords);
|
return this.selectSplit(sqlAndParameter[0].toString(), (Map<String, Object>)sqlAndParameter[1], new EbMerchant());
|
}
|
|
public int countMerchantTotal(Integer categoryId
|
, Integer typeId, String phone, Boolean isSelf, Boolean isSwitch, TimeRange timeRange, String keywords){
|
Object[] sqlAndParameter = this.combineSqlAndParameter(SQL_QUERY_PREFIX_COUNT
|
, categoryId, typeId, phone, isSelf, isSwitch, timeRange, keywords);
|
return this.queryForInt(sqlAndParameter[0].toString(), (Map<String, Object>)sqlAndParameter[1]);
|
}
|
|
private Object[] combineSqlAndParameter(String sqlPrefix, Integer categoryId
|
, Integer typeId, String phone, Boolean isSelf, Boolean isSwitch, TimeRange timeRange, String keywords){
|
Map<String, Object> parameters = new HashMap<>(4);
|
StringBuilder sql = new StringBuilder(sqlPrefix);
|
if(categoryId != null && categoryId.intValue() > 0){
|
sql.append(" and category_id=:categoryId");
|
parameters.put("categoryId", categoryId);
|
}
|
if(typeId != null && typeId.intValue() >= 0){
|
sql.append(" and type_id=:typeId");
|
parameters.put("typeId", typeId);
|
}
|
if(StringUtils.isNotEmpty(phone)){
|
sql.append(" and phone=:phone");
|
parameters.put("phone", phone);
|
}
|
if(isSelf != null){
|
sql.append(" and is_self=:isSelf");
|
parameters.put("isSelf", isSelf? 1:0);
|
}
|
if(isSwitch != null){
|
sql.append(" and is_switch=:isSwitch");
|
parameters.put("isSwitch", isSwitch? 1:0);
|
}
|
if(timeRange != null){
|
if(timeRange.getStartTime() != null){
|
sql.append(" and create_time >= :startTime");
|
parameters.put("startTime", timeRange.getStartTime());
|
}
|
if(timeRange.getEndTime() != null){
|
sql.append(" and create_time <= :endTime");
|
parameters.put("endTime", timeRange.getEndTime());
|
}
|
}
|
if(StringUtils.isNotEmpty(keywords)){
|
sql.append(" and (name like :k1 or keywords like :k2 or remark like :k3)");
|
String likeParam = "%" + keywords + "%";
|
parameters.put("k1", likeParam);
|
parameters.put("k2", likeParam);
|
parameters.put("k3", likeParam);
|
}
|
Object[] result = new Object[2];
|
result[0] = sql.toString();
|
result[1] = parameters;
|
return result;
|
}
|
|
/**
|
* 获得下一个可用的最大ID。
|
* @return
|
* @date 2023-05-17
|
*/
|
public int queryNextId(){
|
int maxId = this.queryForInt(SQL_MAX_ID, new Object[]{});
|
return maxId+1;
|
}
|
|
private static final String SQL_MAX_ID = "select max(id) from eb_merchant";
|
private static final String SQL_QUERY_PREFIX_COUNT = "select count(id) total from eb_merchant where 1=1";
|
private static final String SQL_QUERY_PREFIX_LIST = "select * from eb_merchant where 1=1";
|
}
|
