package com.dsh.guns.modular.system.controller.general;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.dsh.course.feignClient.activity.DriverActivityClient;
|
import com.dsh.course.feignClient.activity.DriverActivityHistoryClient;
|
import com.dsh.course.feignClient.activity.DriverActivityOnlineClient;
|
import com.dsh.course.feignClient.activity.DriverActivityRegisterClient;
|
import com.dsh.course.feignClient.activity.model.*;
|
import com.dsh.guns.config.UserExt;
|
import com.dsh.guns.core.base.controller.BaseController;
|
import com.dsh.guns.core.common.constant.factory.PageFactory;
|
import com.dsh.guns.core.log.LogObjectHolder;
|
import com.dsh.guns.core.util.SinataUtil;
|
import com.dsh.guns.core.util.ToolUtil;
|
import com.dsh.guns.modular.system.model.*;
|
import com.dsh.guns.modular.system.service.*;
|
import net.sf.json.JSONObject;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.ui.Model;
|
import org.springframework.web.bind.annotation.PathVariable;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RequestParam;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 控制器
|
*
|
* @author fengshuonan
|
* @Date 2020-06-17 20:51:18
|
*/
|
@Controller
|
@RequestMapping("/driverActivity")
|
public class DriverActivityController extends BaseController {
|
|
private String PREFIX = "/system/driverActivity/";
|
|
// @Autowired
|
// private IDriverActivityService driverActivityService;
|
|
@Resource
|
private DriverActivityClient driverActivityClient;
|
|
@Resource
|
private DriverActivityRegisterClient driverActivityRegisterClient;
|
|
@Resource
|
private DriverActivityHistoryClient driverActivityHistoryClient;
|
|
@Resource
|
private DriverActivityOnlineClient driverActivityOnlineClient;
|
|
|
/**
|
* 跳转到首页
|
*/
|
@RequestMapping("")
|
public String index(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
model.addAttribute("type",UserExt.getUser().getObjectId());
|
return PREFIX + "driverActivity.html";
|
}
|
|
/**
|
* 跳转到添加 Redirecting to "Add".
|
*/
|
@RequestMapping("/driverActivity_add")
|
public String driverActivityAdd(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "driverActivity_add.html";
|
}
|
|
|
|
@RequestMapping("/driver")
|
public String driver(Model model) {
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "driver.html";
|
}
|
|
|
/**
|
* 跳转领取统计
|
* Redirect for statistics collection
|
* @return
|
*/
|
@RequestMapping("/receiveRecord")
|
public String receiveRecord(Model model,Integer activityId){
|
model.addAttribute("activityId",activityId);
|
|
|
DriverActivity driverActivity = driverActivityClient.queryById(activityId);
|
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
model.addAttribute("startTime", sdf.format(driverActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(driverActivity.getEndTime()));
|
|
// DriverActivityRegistered driverActivityRegistered = driverActivityRegisteredService.selectOne(new EntityWrapper<DriverActivityRegistered>().eq("driverActivityId",activityId).eq("type",1));
|
DriverActivityRegistered driverActivityRegistered = driverActivityRegisterClient.query1(new QueryBean(1, activityId));
|
model.addAttribute("id1",driverActivityRegistered.getId());
|
// driverActivityRegistered = driverActivityRegisteredService.selectOne(new EntityWrapper<DriverActivityRegistered>().eq("driverActivityId",activityId).eq("type",2));
|
driverActivityRegistered = driverActivityRegisterClient.query1(new QueryBean(2, activityId));
|
model.addAttribute("id2",driverActivityRegistered.getId());
|
// DriverActivityOnline driverActivityOnline = driverActivityOnlineService.selectOne(new EntityWrapper<DriverActivityOnline>().eq("driverActivityId",activityId).eq("type",1));
|
DriverActivityOnline driverActivityOnline = driverActivityClient.onLineQueryById(new QueryBean(1, activityId));
|
model.addAttribute("id3",driverActivityOnline.getId());
|
|
//统计专车在线 Statistical special car online
|
driverActivityOnline = driverActivityClient.onLineQueryById(new QueryBean(4, activityId));
|
model.addAttribute("id4",driverActivityOnline.getId());
|
// driverActivityOnline = driverActivityClient.onLineQueryById(new QueryBean(4, activityId));
|
// model.addAttribute("id5",driverActivityOnline.getId());
|
// DriverActivityOrder driverActivityOrder = driverActivityOrderService.selectOne(new EntityWrapper<DriverActivityOrder>().eq("driverActivityId",activityId));
|
DriverActivityOrder driverActivityOrder = driverActivityClient.orderQueryById(activityId).get(0);
|
model.addAttribute("id5",driverActivityOrder.getId());
|
model.addAttribute("language",UserExt.getLanguage());
|
|
model.addAttribute("language",UserExt.getLanguage());
|
model.addAttribute("language",UserExt.getLanguage());
|
return PREFIX + "receiveRecord.html";
|
}
|
|
@RequestMapping(value = "/receiveRecordDetail")
|
@ResponseBody
|
public Object receiveRecordDetail(String createTime,Integer activityId) {
|
String startTimes = null;
|
String endTimes = null;
|
if (SinataUtil.isNotEmpty(createTime)){
|
String[] timeArray = createTime.split(" - ");
|
startTimes = timeArray[0];
|
endTimes = timeArray[1];
|
}else{
|
DriverActivity driverActivity = driverActivityClient.queryById(activityId);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
|
startTimes=sdf.format(driverActivity.getStartTime());
|
endTimes=sdf.format(driverActivity.getEndTime());
|
}
|
Map<String,Object> map = new HashMap<>();
|
//统计邀请司机注册 Statistical invitation for driver registration.
|
DriverActivityHistoryReq driverActivityHistoryReq = new DriverActivityHistoryReq();
|
driverActivityHistoryReq.setDriverActivityId(activityId);
|
driverActivityHistoryReq.setType(1);
|
driverActivityHistoryReq.setEnd(endTimes);
|
driverActivityHistoryReq.setStart(startTimes);
|
DriverActivityHistoryRes driverActivityHistoryRes = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
|
Double totalMOney=0d;
|
Double money=0d;
|
Integer number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money1",money);
|
map.put("number1",number);
|
//统计邀请用户注册 Statistical invitation for user registration.
|
driverActivityHistoryReq.setType(2);
|
DriverActivityHistoryRes driverActivityHistoryRes1 = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
money=0d;
|
|
number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes1.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes1.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money2",money);
|
map.put("number2",number);
|
|
//摩托车在线奖励 Motorcycle Online Rewards
|
QueryDriverActivityOnlineReq req = new QueryDriverActivityOnlineReq();
|
req.setDriverActivityId(activityId);
|
req.setType(1);
|
List<DriverActivityOnline> driverActivityOnlines = driverActivityOnlineClient.queryDriverActivityOnline(req);
|
if(null != driverActivityOnlines){
|
DriverActivityOnline driverActivityOnline = driverActivityOnlines.get(0);
|
driverActivityHistoryReq.setActivityId(driverActivityOnline.getId());
|
}
|
driverActivityHistoryReq.setType(3);
|
DriverActivityHistoryRes driverActivityHistoryRes2 = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
money=0d;
|
number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes2.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes2.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money3",money);
|
map.put("number3",number);
|
|
//同城累计在线奖励 Accumulated In-City Online Reward
|
QueryDriverActivityOnlineReq req1 = new QueryDriverActivityOnlineReq();
|
req1.setDriverActivityId(activityId);
|
req1.setType(4);
|
List<DriverActivityOnline> driverActivityOnlines1 = driverActivityOnlineClient.queryDriverActivityOnline(req1);
|
if(null != driverActivityOnlines1){
|
DriverActivityOnline driverActivityOnline = driverActivityOnlines1.get(0);
|
driverActivityHistoryReq.setActivityId(driverActivityOnline.getId());
|
}
|
driverActivityHistoryReq.setType(3);
|
DriverActivityHistoryRes driverActivityHistoryRes3 = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
money=0d;
|
number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes3.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes3.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money4",money);
|
map.put("number4",number);
|
|
//订单量 order number
|
driverActivityHistoryReq.setActivityId(null);
|
driverActivityHistoryReq.setType(4);
|
DriverActivityHistoryRes driverActivityHistoryRes4 = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
money=0d;
|
number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes4.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes4.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money5",money);
|
map.put("number5",number);
|
|
//司机补贴 Driver's allowance
|
driverActivityHistoryReq.setType(5);
|
DriverActivityHistoryRes driverActivityHistoryRes5 = driverActivityHistoryClient.queryList(driverActivityHistoryReq);
|
money=0d;
|
number=0;
|
if(ToolUtil.isNotEmpty(driverActivityHistoryRes5.getList())) {
|
for (DriverActivityHistory history : driverActivityHistoryRes5.getList()) {
|
money += history.getMoney();
|
totalMOney += history.getMoney();
|
number++;
|
}
|
}
|
map.put("money6",money);
|
map.put("number6",number);
|
map.put("totalMOney",totalMOney);
|
return map;
|
}
|
/**
|
* 跳转到修改 Jump to modification.
|
*/
|
@RequestMapping("/driverActivity_update/{driverActivityId}")
|
public String driverActivityUpdate(@PathVariable Integer driverActivityId, Model model) {
|
// DriverActivity driverActivity = driverActivityService.selectById(driverActivityId);
|
DriverActivity driverActivity = driverActivityClient.queryById(driverActivityId);
|
model.addAttribute("item",driverActivity);
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
model.addAttribute("startTime", sdf.format(driverActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(driverActivity.getEndTime()));
|
model.addAttribute("online1",JSONObject.fromObject(driverActivityClient.onLineQueryById(new QueryBean(1,driverActivityId)).getContent()));
|
model.addAttribute("online3",JSONObject.fromObject(driverActivityClient.onLineQueryById(new QueryBean(4,driverActivityId)).getContent()));
|
// DriverActivityOrder driverActivityOrder = driverActivityOrderService.selectOne(new EntityWrapper<DriverActivityOrder>().eq("driverActivityId",driverActivityId));
|
// DriverActivityOrder driverActivityOrder = driverActivityClient.orderQueryById(driverActivityId).get(0);
|
// if(driverActivityOrder!=null){
|
// model.addAttribute("startTime1", driverActivityOrder.getStart()+" - "+driverActivityOrder.getEnd());
|
// }else{
|
// model.addAttribute("startTime1", "");
|
// }
|
ArrayList<Object> objects = new ArrayList<>();
|
List<DriverActivityOrder> driverActivityOrders = driverActivityClient.orderQueryById(driverActivityId);
|
int a =1;
|
for (DriverActivityOrder driverActivityOrder : driverActivityOrders) {
|
String content = driverActivityOrder.getContent();
|
JSONObject jsonObject = JSONObject.fromObject(content);
|
jsonObject.put("frist",a);
|
a++;
|
objects.add(jsonObject);
|
}
|
model.addAttribute("order",objects);
|
List<DriverActivitySubsidy> driverActivitySubsidy = driverActivityClient.subsidyQueryById(driverActivityId);
|
ArrayList<Object> objects1 = new ArrayList<>();
|
int b = 1;
|
for (DriverActivitySubsidy activitySubsidy : driverActivitySubsidy) {
|
String content = activitySubsidy.getContent();
|
JSONObject jsonObject = JSONObject.fromObject(content);
|
jsonObject.put("frist",b);
|
b++;
|
objects1.add(jsonObject);
|
}
|
model.addAttribute("subsidy",objects1);
|
|
model.addAttribute("regist1", JSONObject.fromObject(driverActivityRegisterClient.query1(new QueryBean(1,driverActivityId)).getContent()));
|
model.addAttribute("regist2", JSONObject.fromObject(driverActivityRegisterClient.query1(new QueryBean(2,driverActivityId)).getContent()));
|
|
LogObjectHolder.me().set(driverActivity);
|
return PREFIX + "driverActivity_edit.html";
|
}
|
|
/**
|
* 获取列表 get list
|
*/
|
@RequestMapping(value = "/list")
|
@ResponseBody
|
public Object list(String createTime,String name) {
|
String beginTime = null;
|
String endTime = null;
|
if (SinataUtil.isNotEmpty(createTime)){
|
String[] timeArray = createTime.split(" - ");
|
beginTime = timeArray[0];
|
endTime = timeArray[1];
|
}
|
Page<Map<String, Object>> page = new PageFactory<Map<String, Object>>().defaultPage();
|
page.setRecords(driverActivityClient.getList(new QueryDriverGetListReq(page,beginTime,endTime,name,UserExt.getUser().getRoleType(),UserExt.getUser().getObjectId())));
|
return super.packForBT(page);
|
}
|
|
/**
|
* 新增
|
*/
|
@RequestMapping(value = "/add")
|
@ResponseBody
|
public Object add(String name, String createTime, String json2, String json3,String json4,String json5,String json8,String driverId) {
|
User user = UserExt.getUser();
|
driverActivityClient.insertOrUpdate(new DriverActivityInsertReq(null,user.getObjectId(),user.getRoleType(),name,createTime,json2, json3, json4
|
, json5
|
, null,json8
|
,driverId));
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 删除
|
*/
|
@RequestMapping(value = "/delete")
|
@ResponseBody
|
public Object delete(@RequestParam Integer driverActivityId) {
|
driverActivityClient.deleteById(driverActivityId);
|
return SUCCESS_TIP;
|
}
|
|
/**
|
* 修改
|
*/
|
@RequestMapping(value = "/update")
|
@ResponseBody
|
public Object update(Integer id,String name, String createTime, String json2, String json3,String json4,String json5,String json6,String driverId) {
|
User user = UserExt.getUser();
|
driverActivityClient.insertOrUpdate(new DriverActivityInsertReq(id,user.getObjectId() ,user.getRoleType(),name,createTime, json2, json3
|
, json4
|
, json5
|
, json6,null,driverId
|
));
|
return SUCCESS_TIP;
|
}
|
@RequestMapping(value = "/updateStatus")
|
@ResponseBody
|
public Object updateStatus(DriverActivity driverActivity) {
|
driverActivityClient.updateStatus(driverActivity);
|
return SUCCESS_TIP;
|
}
|
|
@RequestMapping("/driverActivity_detail/{driverActivityId}")
|
public String driverActivityDetail(@PathVariable Integer driverActivityId,Integer type, Model model) {
|
// DriverActivity driverActivity = driverActivityService.selectById(driverActivityId);
|
DriverActivity driverActivity = driverActivityClient.queryById(driverActivityId);
|
model.addAttribute("item",driverActivity);
|
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
model.addAttribute("startTime", sdf.format(driverActivity.getStartTime()));
|
model.addAttribute("endTime", sdf.format(driverActivity.getEndTime()));
|
|
List<DriverActivityOrder> driverActivityOrders = driverActivityClient.orderQueryById(driverActivityId);
|
List<DriverActivitySubsidy> driverActivitySubsidy = driverActivityClient.subsidyQueryById(driverActivityId);
|
ArrayList<Object> objects = new ArrayList<>();
|
ArrayList<Object> objects1 = new ArrayList<>();
|
for (DriverActivitySubsidy activitySubsidy : driverActivitySubsidy) {
|
String content = activitySubsidy.getContent();
|
JSONObject jsonObject = JSONObject.fromObject(content);
|
objects1.add(jsonObject);
|
}
|
for (DriverActivityOrder driverActivityOrder : driverActivityOrders) {
|
String content = driverActivityOrder.getContent();
|
JSONObject jsonObject = JSONObject.fromObject(content);
|
net.sf.json.JSONArray num2 = jsonObject.getJSONArray("num2");
|
jsonObject.put("number",num2.size());
|
objects.add(jsonObject);
|
}
|
|
model.addAttribute("order",objects);
|
model.addAttribute("subsidy",objects1);
|
DriverActivityRegistered driverActivityRegistered = driverActivityRegisterClient.query1(new QueryBean(1, driverActivityId));
|
String content = driverActivityRegistered.getContent();
|
JSONObject jsonObject = JSONObject.fromObject(content);
|
model.addAttribute("regist1", jsonObject);
|
model.addAttribute("online1",JSONObject.fromObject(driverActivityClient.onLineQueryById(new QueryBean(1,driverActivityId)).getContent()));
|
model.addAttribute("regist2",JSONObject.fromObject(driverActivityRegisterClient.query1(new QueryBean(2,driverActivityId)).getContent()));
|
model.addAttribute("online3",JSONObject.fromObject(driverActivityClient.onLineQueryById(new QueryBean(4,driverActivityId)).getContent()));
|
model.addAttribute("type",type);
|
model.addAttribute("language",UserExt.getLanguage());
|
LogObjectHolder.me().set(driverActivity);
|
return PREFIX + "driverActivity_detail.html";
|
}
|
|
/**
|
* 跳转到立即处理页面 Redirect to the immediate processing page.
|
*/
|
@RequestMapping("/driverActivity_immediately/{id}")
|
public String driverActivityImmediately(@PathVariable Integer id, Model model) {
|
model.addAttribute("id",id);
|
return PREFIX + "driverActivity_immediately.html";
|
}
|
/**
|
* 立即处理操作 immediately hander
|
*/
|
@RequestMapping(value = "/immediately")
|
@ResponseBody
|
public Object immediately(@RequestParam Integer id,@RequestParam Integer state,@RequestParam String remark) {
|
// DriverActivity driverActivity = driverActivityService.selectById(id);
|
DriverActivity driverActivity = driverActivityClient.queryById(id);
|
if (SinataUtil.isNotEmpty(driverActivity)){
|
driverActivity.setStatus(state);
|
driverActivity.setRemark(remark);
|
driverActivityClient.updateStatus(driverActivity);
|
}
|
return SUCCESS_TIP;
|
}
|
@Autowired
|
private ITAuditRecordService auditRecordService;
|
|
@RequestMapping(value = "/submitInfo")
|
@ResponseBody
|
public Object submitInfo(@RequestParam Integer id,@RequestParam Integer check,@RequestParam String text) {
|
DriverActivity driverActivity = driverActivityClient.queryById(id);
|
if (SinataUtil.isNotEmpty(driverActivity)){
|
driverActivity.setStatus(check);
|
driverActivity.setRemark(text);
|
driverActivityClient.updateStatus(driverActivity);
|
}
|
TAuditRecord tAuditRecord = new TAuditRecord();
|
tAuditRecord.setRemark(text);
|
tAuditRecord.setAuditUserId(UserExt.getUser().getId());
|
tAuditRecord.setAuditTime(new Date());
|
tAuditRecord.setActivityType(1);
|
tAuditRecord.setActivityName(driverActivity.getName());
|
tAuditRecord.setActivityId(driverActivity.getId());
|
if(check==3){
|
tAuditRecord.setAuditStatus(2);
|
}else {
|
tAuditRecord.setAuditStatus(3);
|
}
|
auditRecordService.save(tAuditRecord);
|
return SUCCESS_TIP;
|
}
|
}
|
