Просмотр исходного кода

[标签短信][修改][短信回调]

release_toaliyun_real
gongbiao 7 лет назад
Родитель
Сommit
c3b812817c
3 измененных файлов: 30 добавлений и 42 удалений
  1. +3
    -4
      mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java
  2. +2
    -2
      mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java
  3. +25
    -36
      mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java

+ 3
- 4
mallinkAdmin/src/main/java/com/simple/controller/WxMsgCallbackController.java Просмотреть файл

@@ -68,14 +68,13 @@ public class WxMsgCallbackController extends BaseController {
}


@RequestMapping(value = "/receivemsg/{bid}")
@PostMapping(value = "/receivemsg/{bid}")
public void receivemsg(@PathVariable String bid, @RequestParam Map<String, String> param) {
logger.info(param.toString());
//解析param数据插入数据库中
String item = param.get("item");
String sign = param.get("sign");
String tenantId = getTenantId();
wxMsgCallbackService.saveOrUpdate(tenantId, bid, item, sign);
wxMsgCallbackService.saveOrUpdate(bid, item, sign);

}

@@ -83,7 +82,7 @@ public class WxMsgCallbackController extends BaseController {
public void receivemodel(@PathVariable String bid, @RequestParam Map<String, String> param) {
logger.info(param.toString());
//解析param数据插入数据库中
wxMsgCallbackService.receivemodel(getTenantId(), bid, param);
wxMsgCallbackService.receivemodel(bid, param);

}



+ 2
- 2
mallinkService/src/main/java/com/simple/service/WxMsgCallbackService.java Просмотреть файл

@@ -39,9 +39,9 @@ public interface WxMsgCallbackService {
void deleteById(Long id);


void saveOrUpdate(String tenantId, String bid, String item, String sign);
void saveOrUpdate(String bid, String item, String sign);

void receivemodel(String tenantId, String bid, Map<String, String> param);
void receivemodel(String bid, Map<String, String> param);

void receiveverifymodel(String bid, Map<String,String> param);



+ 25
- 36
mallinkService/src/main/java/com/simple/service/impl/WxMsgCallbackServiceImpl.java Просмотреть файл

@@ -63,58 +63,47 @@ public class WxMsgCallbackServiceImpl implements WxMsgCallbackService {
}

@Override
public void saveOrUpdate(String tenantId,String bid, String item, String sign) {
public void saveOrUpdate(String bid, String item, String sign) {

WxMsgConfig wxMsgConfig = new WxMsgConfig();
wxMsgConfig.setTenantId(tenantId);
wxMsgConfig.setBid(bid);
List<WxMsgConfig> list = wxMsgConfigMapper.findList(wxMsgConfig);
if(list.size()==1) {
List<WxMsgCallback> wxMsgCallbacks = JSONArray.parseArray(item, WxMsgCallback.class);
wxMsgConfig = list.get(0);
wxMsgConfig.setRemains(wxMsgConfig.getRemains() - wxMsgCallbacks.size());
wxMsgConfigMapper.updateByPrimaryKeySelective(wxMsgConfig);

for (WxMsgCallback wxMsgCallback : wxMsgCallbacks) {
wxMsgCallback.setTenantId(wxMsgConfig.getTenantId());
wxMsgCallback.setSign(sign);
wxMsgCallback.setCreatetime(new Date());
wxMsgCallbackMapper.insertSelective(wxMsgCallback);
}
List<WxMsgCallback> wxMsgCallbacks = JSONArray.parseArray(item, WxMsgCallback.class);
wxMsgConfig = list.get(0);
wxMsgConfig.setRemains(wxMsgConfig.getRemains() - wxMsgCallbacks.size());
wxMsgConfigMapper.updateByPrimaryKeySelective(wxMsgConfig);

for (WxMsgCallback wxMsgCallback : wxMsgCallbacks) {
wxMsgCallback.setTenantId(wxMsgConfig.getTenantId());
wxMsgCallback.setSign(sign);
wxMsgCallback.setCreatetime(new Date());
wxMsgCallbackMapper.insertSelective(wxMsgCallback);
}

}

@Override
public void receivemodel(String tenantId, String bid, Map<String, String> param) {
WxMsgConfig wxMsgConfig = new WxMsgConfig();
wxMsgConfig.setTenantId(tenantId);
wxMsgConfig.setBid(bid);
List<WxMsgConfig> list = wxMsgConfigMapper.findList(wxMsgConfig);
if(list.size()==1) {
public void receivemodel(String bid, Map<String, String> param) {

WxMsgModel wxMsgModel = new WxMsgModel();
wxMsgModel.setModelId(Integer.valueOf(param.get("id")));
wxMsgModel = wxMsgModelMapper.findList(wxMsgModel).get(0);
wxMsgModel.setStatus(param.get("status").equals("1")?Integer.valueOf(param.get("status")):0);
wxMsgModelMapper.updateByPrimaryKeySelective(wxMsgModel);

WxMsgModel wxMsgModel = new WxMsgModel();
wxMsgModel.setModelId(Integer.valueOf(param.get("id")));
wxMsgModel = wxMsgModelMapper.findList(wxMsgModel).get(0);
wxMsgModel.setStatus(param.get("status").equals("1")?Integer.valueOf(param.get("status")):0);
wxMsgModelMapper.updateByPrimaryKeySelective(wxMsgModel);

}
}

@Override
public void receiveverifymodel(String bid, Map<String, String> param) {
WxMsgConfig wxMsgConfig = new WxMsgConfig();
wxMsgConfig.setBid(bid);
List<WxMsgConfig> list = wxMsgConfigMapper.findList(wxMsgConfig);
if(list.size()==1) {

WxMsgValidationcodeModel wxMsgModel = new WxMsgValidationcodeModel();
wxMsgModel.setModelId(Integer.valueOf(param.get("id")));
wxMsgModel = wxMsgValidationcodeModelMapper.findList(wxMsgModel).get(0);
wxMsgModel.setStatus(param.get("status").equals("1")?Integer.valueOf(param.get("status")):0);
wxMsgValidationcodeModelMapper.updateByPrimaryKeySelective(wxMsgModel);
WxMsgValidationcodeModel wxMsgModel = new WxMsgValidationcodeModel();
wxMsgModel.setModelId(Integer.valueOf(param.get("id")));
wxMsgModel = wxMsgValidationcodeModelMapper.findList(wxMsgModel).get(0);
wxMsgModel.setStatus(param.get("status").equals("1")?Integer.valueOf(param.get("status")):0);
wxMsgValidationcodeModelMapper.updateByPrimaryKeySelective(wxMsgModel);


}
}




Загрузка…
Отмена
Сохранить